消息发送去掉遥测

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

@@ -394,10 +394,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                     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();
@@ -427,10 +424,12 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
                         try {
                             emqKeeper.getMqttClient().publish("emq.xf.created",jsonObjectXf.toString().getBytes(),1,false);
+                            log.info("遥测遥信数据推送云端kafka成功");
                         } catch (MqttException e) {
+                            log.error("遥测遥信数据推送云端kafka失败=====>" +  e.getMessage());
                             e.printStackTrace();
                         }
-
+                    }
                 }
             }
         });