mqtt接收数据

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/subscribe/PushCallback.java

@@ -134,6 +134,9 @@ public class PushCallback implements MqttCallback {
             PublishMQTT publishMQTT = new PublishMQTT();
             publishMQTT.start("tcp://192.168.1.68:1883", chip, "admin", "admin", "huimv_down_" + chip, jsonObject.toJSONString());
             log.info("---设备控制发送完成---");
+        }  else if (messages.equals("dev_ctrl_suc")) {
+            PublishMQTT publishMQTT = new PublishMQTT();
+            publishMQTT.start("tcp://192.168.1.68:1883", chip, "admin", "admin", "huimv_down_" + chip,"已应答");
         } else {
             JSONObject jsonObject = JSON.parseObject(messages);
             System.out.println("这里是1111：" + jsonObject);
@@ -192,10 +195,7 @@ public class PushCallback implements MqttCallback {
                 envAmmonia.setUnitId(deviceRegister.getUnitId());
                 ammoniaService.save(envAmmonia);
                 log.info("---氨气保存成功！----");
-            }
-
-
-            if (ObjectUtil.isNotEmpty(jsonObject.get("alarm_event"))) {
+            } else if (ObjectUtil.isNotEmpty(jsonObject.get("alarm_event"))) {
                 log.info("----报警信息开始保存---");
                 IEnvAlarmTypeService alarmTypeService = SpringUtil.getBean(IEnvAlarmTypeService.class);
                 JSONObject jsonObject1 = (JSONObject) jsonObject.get("alarm_event");
@@ -208,7 +208,6 @@ public class PushCallback implements MqttCallback {
                 } catch (Exception e) {
                     System.out.println(e);
                 }
-
                 alarmTypeService.save(envAlarmType);
                 log.info("----报警信息保存成功！----");
             }