diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/RspDataDto.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/RspDataDto.java index dda6299..d40dcd3 100644 --- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/RspDataDto.java +++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/RspDataDto.java @@ -82,6 +82,10 @@ public class RspDataDto { @SerializedName("Capacity_A") private Double capacityA; + + @SerializedName("StatCycle") + @ApiModelProperty("接线方式") + private Integer StatCycle; } /** diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java b/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java index 184d022..bbf5b7f 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java @@ -406,6 +406,7 @@ public class MqttMessageHandler { csLineParam.setPtRatio(item.getPtRatio()); csLineParam.setCtRatio(item.getCtRatio()); csLineParam.setConType(item.getConType()); + csLineParam.setLineInterval(item.getStatCycle()); csLineFeignClient.updateLine(csLineParam); //生成监测点限值 Overlimit overlimit = COverlimitUtil.globalAssemble(item.getVolGrade().floatValue(),10f,10f,10f,0,0); @@ -429,6 +430,7 @@ public class MqttMessageHandler { csLineParam.setPtRatio(item.getPtRatio()); csLineParam.setCtRatio(item.getCtRatio()); csLineParam.setConType(item.getConType()); + csLineParam.setLineInterval(item.getStatCycle()); csLineFeignClient.updateLine(csLineParam); }); }