From 95ca755d6e6e69b51866b702484168fe5c4efa40 Mon Sep 17 00:00:00 2001 From: zelian_wu Date: Fri, 21 Jun 2024 16:57:37 +0800 Subject: [PATCH] 2024-06-21 --- .../com/spring/modules/cdc/task/GatherDataTask.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java b/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java index aa114dd0..40e3429b 100644 --- a/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java +++ b/src/main/java/com/spring/modules/cdc/task/GatherDataTask.java @@ -90,11 +90,17 @@ public class GatherDataTask { for (String ip : map.keySet()) { List deviceList = map.get(ip); if (ip.equals(line1IP)){ - deviceVos.addAll(CollectUtils.getReadXMZValueList(deviceList,ip,new BigDecimal(line1Value))); + List readXMZValueList = CollectUtils.getReadXMZValueList(deviceList, ip, new BigDecimal(line1Value)); + deviceVos.addAll(readXMZValueList); + log.info("大线:{}",readXMZValueList.stream().map(DeviceVo::getValue)); }else if (ip.equals(line2IP)){ - deviceVos.addAll(CollectUtils.getReadSLValueList(deviceList,ip,line2Port,new BigDecimal(line1Value))); + List readSLValueList = CollectUtils.getReadSLValueList(deviceList, ip, line2Port, new BigDecimal(line1Value)); + deviceVos.addAll(readSLValueList); + log.info("小线:{}",readSLValueList.stream().map(DeviceVo::getValue)); }else if (ip.equals(line3IP)){ - deviceVos.addAll(CollectUtils.getReadValueList(deviceList,ip,new BigDecimal(line1Value))); + List readValueList = CollectUtils.getReadValueList(deviceList, ip, new BigDecimal(line1Value)); + deviceVos.addAll(readValueList); + log.info("配胶间:{}",readValueList.stream().map(DeviceVo::getValue)); }else { log.info("数据有误！！！"); }