Browse Source

2024-06-21

master
zelian_wu 2 years ago
parent
commit
224e918e1e
  1. 6
      src/main/java/com/spring/modules/cdc/task/GatherDataTask.java

6
src/main/java/com/spring/modules/cdc/task/GatherDataTask.java

@ -92,15 +92,15 @@ public class GatherDataTask {
if (ip.equals(line1IP)){ if (ip.equals(line1IP)){
List<DeviceVo> readXMZValueList = CollectUtils.getReadXMZValueList(deviceList, ip, new BigDecimal(line1Value)); List<DeviceVo> readXMZValueList = CollectUtils.getReadXMZValueList(deviceList, ip, new BigDecimal(line1Value));
deviceVos.addAll(readXMZValueList); deviceVos.addAll(readXMZValueList);
log.info("大线:{}",readXMZValueList.stream().map(DeviceVo::getValue));
log.info("大线:{}",readXMZValueList.stream().map(DeviceVo::getValue).collect(Collectors.toList()));
}else if (ip.equals(line2IP)){ }else if (ip.equals(line2IP)){
List<DeviceVo> readSLValueList = CollectUtils.getReadSLValueList(deviceList, ip, line2Port, new BigDecimal(line1Value)); List<DeviceVo> readSLValueList = CollectUtils.getReadSLValueList(deviceList, ip, line2Port, new BigDecimal(line1Value));
deviceVos.addAll(readSLValueList); deviceVos.addAll(readSLValueList);
log.info("小线:{}",readSLValueList.stream().map(DeviceVo::getValue));
log.info("小线:{}",readSLValueList.stream().map(DeviceVo::getValue).collect(Collectors.toList()));
}else if (ip.equals(line3IP)){ }else if (ip.equals(line3IP)){
List<DeviceVo> readValueList = CollectUtils.getReadValueList(deviceList, ip, new BigDecimal(line1Value)); List<DeviceVo> readValueList = CollectUtils.getReadValueList(deviceList, ip, new BigDecimal(line1Value));
deviceVos.addAll(readValueList); deviceVos.addAll(readValueList);
log.info("配胶间:{}",readValueList.stream().map(DeviceVo::getValue));
log.info("配胶间:{}",readValueList.stream().map(DeviceVo::getValue).collect(Collectors.toList()));
}else { }else {
log.info("数据有误!!!"); log.info("数据有误!!!");
} }

Loading…
Cancel
Save