修改事件数据转换错误

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttEventReceiveServiceImpl.java

 package com.yeejoin.equipmanage.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.equipmanage.common.entity.dto.MonitorEventDto;
 import com.yeejoin.equipmanage.common.enums.VideoEventEnum;
 import com.yeejoin.equipmanage.service.MqttEventReceiveService;
+
+import lombok.extern.slf4j.Slf4j;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -13,6 +17,7 @@ import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
+@Slf4j
 @Service
 public class MqttEventReceiveServiceImpl implements MqttEventReceiveService {
 
@@ -23,8 +28,9 @@ public class MqttEventReceiveServiceImpl implements MqttEventReceiveService {
   @Override
   @Transactional(rollbackFor = Exception.class)
   public void handlerMqttIncrementMessage(String topic, String message) {
-    JSONObject json = JSONObject.parseObject(message);
     try {
+      log.debug(message);
+      JSONObject json = JSON.parseObject(message);
       String deviceCode = json.getString("deviceCode");
       String event = json.getString("event");
       JSONObject eventJson = JSONObject.parseObject(event);
@@ -60,4 +66,9 @@ public class MqttEventReceiveServiceImpl implements MqttEventReceiveService {
       e.printStackTrace();
     }
   }
+  
+//  public static void main(String[] args) {
+//	  MqttEventReceiveServiceImpl m = new MqttEventReceiveServiceImpl();
+//	  m.handlerMqttIncrementMessage("", "{\"deviceCode\":\"13485741871310161013\",\"traceId\":\"-1202608724639988142\",\"event\":{\"pic\":\"upload/iot/1433672253282881537/752F8D2FCC745F218EE936C673DAB.jpg\",\"eventContent\":\"人数变化事件 \",\"eventType\":15}}");
+//  }
 }