Skip to content

A
amos-boot-biz
Commit 6f65ce96 authored by 李腾威's avatar 李腾威
Browse files
Options

地图消息接口

parent 0d9374dd
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 12 deletions
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
View file @ 6f65ce96
...@@ -267,21 +267,19 @@ public class RepairConsultServiceImpl extends BaseService<RepairConsultDto,Repai ...@@ -267,21 +267,19 @@ public class RepairConsultServiceImpl extends BaseService<RepairConsultDto,Repai
if(flag) { if(flag) {
// 记录处置记录后修改 案件状态 // 记录处置记录后修改 案件状态
alertCalledServiceImpl.updateAlertStage(alertCalledVo,CZHJ); alertCalledServiceImpl.updateAlertStage(alertCalledVo,CZHJ);
if(null != user) {
// 警情伤亡消息 矩阵 消息 // 警情伤亡消息 矩阵 消息
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("userId",user.getUserId()); jsonObject.put("alertId",String.valueOf(alertCalledVo.getSequenceNbr()));
jsonObject.put("alertId",String.valueOf(alertCalledVo.getSequenceNbr())); try {
try { emqKeeper.getMqttClient().publish(alertHeartpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
emqKeeper.getMqttClient().publish(alertHeartpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false); emqKeeper.getMqttClient().publish(alertMatrixpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
emqKeeper.getMqttClient().publish(alertMatrixpushTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
} catch (MqttException e) { } catch (MqttException e) {
logger.error("mqtt发送失败" +jsonObject ); logger.error("mqtt发送失败" +jsonObject );
} catch (UnsupportedEncodingException e) { } catch (UnsupportedEncodingException e) {
logger.error("mqtt发送失败" +jsonObject ); logger.error("mqtt发送失败" +jsonObject );
}
} }
} }
return flag; return flag;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment