在service-agbox网关服务模块中巡检设备事件中增加调用更新心跳信息接口

service-agbox/service-agbox-biz/src/main/java/com/usky/agbox/service/mqtt/event/event.java

@@ -23,12 +23,17 @@ public class event implements MqttStrategy {
         try {
             JSONObject eventVO1 = JSONObject.parseObject(mqttBaseVO.getData().toString());
             JSONObject eventVO = new JSONObject();
+            JSONObject eventVO2 = new JSONObject();
             if (eventVO1.get("eventType").equals(31)){
                 eventVO1.put("eventCode",1);
                 PatrolAgbox.addEvent(eventVO1.toString());
+                eventVO2.put("deviceId",eventVO1.get("deviceId"));
+                PatrolAgbox.updateHeart(eventVO2.toJSONString());
             }else if (eventVO1.get("eventType").equals(32)){
                 eventVO1.put("eventCode",2);
                 PatrolAgbox.addEvent(eventVO1.toString());
+                eventVO2.put("deviceId",eventVO1.get("deviceId"));
+                PatrolAgbox.updateHeart(eventVO2.toJSONString());
             }else {
                 if (eventVO1.get("eventType").equals(33)||eventVO1.get("eventType").equals(34)){
                     eventVO.put("eventCode",5);
@@ -41,6 +46,8 @@ public class event implements MqttStrategy {
                 eventVO.put("name",eventVO1.get("createBy"));
                 eventVO.put("certifiedNo","");
                 PatrolAgbox.addEvent(eventVO.toJSONString());
+                eventVO2.put("deviceId",eventVO1.get("deviceId"));
+                PatrolAgbox.updateHeart(eventVO2.toJSONString());
             }
             System.out.println("FEventReceiver消费者收到消息： " + mqttBaseVO.getData().toString());
         } catch (Exception e){