Parcourir la source

调整MQ订阅解析

hanzhengyi il y a 10 mois
Parent
commit
76bc23e9c6

+ 5 - 1
service-agbox/service-agbox-biz/src/main/java/com/usky/agbox/service/listener/RabbitMQListener.java

@@ -31,7 +31,11 @@ public class RabbitMQListener {
                 eventVO1.put("eventCode",2);
                 PatrolAgbox.addEvent(eventVO1.toJSONString());
             }else {
-                eventVO.put("eventCode",16);
+                if (eventVO1.get("eventType").equals(33)||eventVO1.get("eventType").equals(34)){
+                    eventVO.put("eventCode",5);
+                }else {
+                    eventVO.put("eventCode",16);
+                }
                 String timeWithT = eventVO1.get("createTime").toString();
                 eventVO.put("deviceId",eventVO1.get("deviceId"));
                 eventVO.put("triggerTime",timeWithT.replace("T", " "));