地图消息接口

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/RepairConsultServiceImpl.java

@@ -267,18 +267,20 @@ public class RepairConsultServiceImpl extends BaseService<RepairConsultDto,Repai
         if(flag) {
             // 记录处置记录后修改 案件状态
             alertCalledServiceImpl.updateAlertStage(alertCalledVo,CZHJ);
-            // 警情伤亡消息 矩阵 消息
-            JSONObject jsonObject = new JSONObject();
-            jsonObject.put("userId",user.getUserId());
-            jsonObject.put("alertId",alertCalledVo.getSequenceNbr());
-            try {
-                emqKeeper.getMqttClient().publish(alertHeartpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
-                emqKeeper.getMqttClient().publish(alertMatrixpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
+            if(null != user) {
+                // 警情伤亡消息 矩阵 消息
+                JSONObject jsonObject = new JSONObject();
+                jsonObject.put("userId",user.getUserId());
+                jsonObject.put("alertId",String.valueOf(alertCalledVo.getSequenceNbr()));
+                try {
+                    emqKeeper.getMqttClient().publish(alertHeartpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
+                    emqKeeper.getMqttClient().publish(alertMatrixpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
 
-            } catch (MqttException e) {
-                logger.error("mqtt发送失败" +jsonObject );
-            } catch (UnsupportedEncodingException e) {
-                logger.error("mqtt发送失败" +jsonObject );
+                } catch (MqttException e) {
+                    logger.error("mqtt发送失败" +jsonObject );
+                } catch (UnsupportedEncodingException e) {
+                    logger.error("mqtt发送失败" +jsonObject );
+                }
             }
         }
         return flag;