Commit daca9c41 authored by litengwei's avatar litengwei

中心BUG修改

parent a6eb8465
......@@ -2051,10 +2051,11 @@ public class EquipmentSpecificSerivceImpl extends ServiceImpl<EquipmentSpecificM
}
}
if(mapPatrol.size() == 0) {
Map<String, String> map = new HashMap<>();
Map<String, Object> map = new HashMap<>();
map.put("bizOrgCode", "");
mapList.add(map);
try {
emqKeeper.getMqttClient().publish("equip/patrol/put", JSONObject.toJSONString(map).getBytes(), 2, false);
emqKeeper.getMqttClient().publish("equip/patrol/put", JSONObject.toJSONString(mapList).getBytes(), 2, false);
} catch (MqttException exp) {
log.info(String.format("发送eqm转kafka消息失败:%s", exp.getMessage()));
}
......
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