Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
wr
2025-06-12 09:52:12 +08:00
parent 02947219f4
commit 5cfe6ccfc3
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java
View File

@@ -72,7 +72,6 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService {
lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate())); lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate()));
List<String> devIdList = calculatedParam.getIdList(); List<String> devIdList = calculatedParam.getIdList();
List<List<String>> pendingIds = ListUtils.partition(devIdList,NUM);
List<DataOnlineRateDto.Detail> list = new ArrayList<>(); List<DataOnlineRateDto.Detail> list = new ArrayList<>();
if(ObjectUtil.isNotNull(calculatedParam.getType())){ if(ObjectUtil.isNotNull(calculatedParam.getType())){
if(calculatedParam.getType()==1){ if(calculatedParam.getType()==1){
@@ -104,8 +103,8 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService {
} }
}else{ }else{
List<PqsCommunicateDto> outCommunicateData = new ArrayList<>(); List<PqsCommunicateDto> outCommunicateData = new ArrayList<>();
for (List<String> pendingId : pendingIds) { for (String s : devIdList) {
lineParam.setLineId(pendingId); lineParam.setLineId(Arrays.asList(s));
List<PqsCommunicateDto> data = communicateFeignClient.getRawDataLatest(lineParam).getData(); List<PqsCommunicateDto> data = communicateFeignClient.getRawDataLatest(lineParam).getData();
outCommunicateData.addAll(data); outCommunicateData.addAll(data);
} }