diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java index d01c607..a57a611 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java +++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/IDataOnlineRateServiceImpl.java @@ -72,7 +72,6 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService { lineParam.setEndTime(TimeUtils.getEndOfDay(calculatedParam.getDataDate())); List devIdList = calculatedParam.getIdList(); - List> pendingIds = ListUtils.partition(devIdList,NUM); List list = new ArrayList<>(); if(ObjectUtil.isNotNull(calculatedParam.getType())){ if(calculatedParam.getType()==1){ @@ -104,8 +103,8 @@ public class IDataOnlineRateServiceImpl implements IDataOnlineRateService { } }else{ List outCommunicateData = new ArrayList<>(); - for (List pendingId : pendingIds) { - lineParam.setLineId(pendingId); + for (String s : devIdList) { + lineParam.setLineId(Arrays.asList(s)); List data = communicateFeignClient.getRawDataLatest(lineParam).getData(); outCommunicateData.addAll(data); }