|
@@ -35,14 +35,19 @@ public class event implements MqttStrategy {
|
|
|
eventVO2.put("deviceId",eventVO1.get("deviceId"));
|
|
|
PatrolAgbox.updateHeart(eventVO2.toJSONString());
|
|
|
}else {
|
|
|
+ System.out.println("FEventReceiver消费者收到消息1: " + mqttBaseVO.getData().toString());
|
|
|
if (eventVO1.get("eventType").equals(33)||eventVO1.get("eventType").equals(34)||eventVO1.get(
|
|
|
"eventType").equals(9)){
|
|
|
+ System.out.println("FEventReceiver消费者收到消息2: " + mqttBaseVO.getData().toString());
|
|
|
eventVO.put("eventCode",5);
|
|
|
}else if (eventVO1.get("eventType").equals(8)){
|
|
|
- eventVO1.put("eventCode",3);
|
|
|
+ System.out.println("FEventReceiver消费者收到消息3: " + mqttBaseVO.getData().toString());
|
|
|
+ eventVO.put("eventCode",3);
|
|
|
}else if (eventVO1.get("eventType").equals(10)){
|
|
|
- eventVO1.put("eventCode",4);
|
|
|
+ System.out.println("FEventReceiver消费者收到消息4: " + mqttBaseVO.getData().toString());
|
|
|
+ eventVO.put("eventCode",4);
|
|
|
}else {
|
|
|
+ System.out.println("FEventReceiver消费者收到消息5: " + mqttBaseVO.getData().toString());
|
|
|
eventVO.put("eventCode",16);
|
|
|
}
|
|
|
String timeWithT = eventVO1.get("createTime").toString();
|