遥测发消息开关

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -214,6 +214,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
     @Value("${isSendIot:false}")
     private Boolean isSendIot;
 
+    @Value("${is.open.telemetering:false}")
+    private Boolean isOpenTelemetering;
+
     private static Boolean jcsSwitch;
     @Value("${systemctl.jcs.switch}")
     public void setJcsSwitch(Boolean jcsSwitch){
@@ -392,9 +395,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                     // 遥测遥信数据推送云端kafka
                     JSONObject jsonObjectXf = new JSONObject();
                     jsonObjectXf.put("data_class", "realdata");
-                    // 遥测
+
                     if(equipmentSpeIndex.getIsTrend() == 1) {
+                        jsonObjectXf.put("data_type", "analog");
                     } else {
+                        jsonObjectXf.put("data_type", "state");
+                    }
+
                     String date = DateUtils.date2LongStr(new Date());
                     jsonObjectXf.put("op_type", "subscribe_emergency");
                     JSONObject jsonObjectCondition = new JSONObject();
@@ -422,6 +429,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
                     jsonObjectXf.put("data", jsonObjects);
 
+                    // 遥测
+                    if(!isOpenTelemetering && equipmentSpeIndex.getIsTrend() == 1) {
+                    } else {
                         try {
                             emqKeeper.getMqttClient().publish("emq.xf.created",jsonObjectXf.toString().getBytes(),1,false);
                             log.info("遥测遥信数据推送云端kafka成功");

amos-boot-system-equip/src/main/resources/application-dev.properties

@@ -115,3 +115,6 @@ equipment.pressurepump.stop=FHS_PressurePump_Stop
 # 站端标识
 state.code=JP
 state.name=NAME
+
+# 是否开启遥测数据上报
+is.open.telemetering=false
\ No newline at end of file