|
@@ -88,11 +88,9 @@ public class DataTransferServiceImpl implements DataTransferService {
|
|
|
@Override
|
|
|
public List<DataTransferBatchShortVo> queryDataTransferGroup(DataTransferDto dataTransferDto){
|
|
|
PageHelper.startPage(dataTransferDto.getPageNum(), dataTransferDto.getPageSize());
|
|
|
- List<DataTransferBatchShortVo> vos = dataTransferMapper.queryDataTransferGroup(dataTransferDto.getFieldName(),
|
|
|
+ return dataTransferMapper.queryDataTransferGroup(dataTransferDto.getFieldName(),
|
|
|
dataTransferDto.getBatchName(),
|
|
|
dataTransferDto.getRoleId());
|
|
|
- vos.stream().forEach(item -> item.setUniqueCode(UUIDTools.getShortUUIDLowCase()));
|
|
|
- return vos;
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -257,7 +255,7 @@ public class DataTransferServiceImpl implements DataTransferService {
|
|
|
DataTransferTypePathDto pathDto = getTransferAddr(dataTransferDto,dataTransferType);
|
|
|
if(pathDto != null && StringUtils.isNotBlank(pathDto.getTransferAddr())){
|
|
|
dataTransferPo.setTransferAddr(pathDto.getTransferAddr());
|
|
|
-// dataTransferPo.setTransferState(DATA_TRANSFERING_STATE);
|
|
|
+ dataTransferPo.setTransferState(DATA_TRANSFERING_STATE);
|
|
|
}
|
|
|
if(pathDto != null && pathDto.getTimeGranularity() != null){
|
|
|
dataTransferPo.setTimeGranularity(pathDto.getTimeGranularity());
|