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("数据有误!!!"); }