Commit 41a558c7 authored by litengwei's avatar litengwei

至少一次巡查触发逻辑

parent 4e251752
......@@ -2046,6 +2046,15 @@ public class EquipmentSpecificSerivceImpl extends ServiceImpl<EquipmentSpecificM
}
}
}
if(mapPatrol.size() == 0) {
Map<String, String> map = new HashMap<>();
map.put("bizOrgCode", "");
try {
emqKeeper.getMqttClient().publish("equip/patrol/put", JSONObject.toJSONString(map).getBytes(), 1, false);
} catch (MqttException exp) {
log.info(String.format("发送eqm转kafka消息失败:%s", exp.getMessage()));
}
}
}
void syncSystemctlMsg(Map<String, Object> map, String scrapTime, int i) {
......
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