消防监督更新

amos-boot-module/amos-boot-module-biz/amos-boot-module-supervision-biz/src/main/java/com/yeejoin/amos/supervision/mqtt/AmosMqttListener.java

 package com.yeejoin.amos.supervision.mqtt;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.supervision.business.dto.OrgUsrFormDto;
 import com.yeejoin.amos.supervision.business.service.intfc.IPointService;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
@@ -25,17 +27,14 @@ public class AmosMqttListener extends EmqxListener {
 
     @Override
     public void processMessage(String topic, MqttMessage message) {
-        JSONObject jsonObject = JSONObject.parseObject(message.toString());
+        String msg = String.valueOf(message);
         if ("jcs/company/topic/add".equals(topic)) {
-
+            OrgUsrFormDto usrFormDto = JSON.parseObject(msg, OrgUsrFormDto.class);
+            iPointService.syncSavePoint(usrFormDto);
         } else {
-
+            iPointService.delPointByPointNo(Long.valueOf(msg));
         }
-        JSONObject result = jsonObject.getJSONObject("result");
-        String methodName = jsonObject.getString("methodName");
-        String path = result.getString("path");
         try {
-//            iPointService.syncSavePoint();
         } catch (Exception e) {
             log.info("同步机场单位消息失败:{}", e.getMessage());
         }