From 5cfe6ccfc30ab8f071118414d4a599e1e084d30a Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Thu, 12 Jun 2025 09:52:12 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../serviceimpl/line/IDataOnlineRateServiceImpl.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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); }