关闭超长无用的日志,增加接受报文日志

src/main/java/com/sooka/sponest/lawenforcement/device/controller/DeviceController.java

@@ -38,7 +38,6 @@ public class DeviceController extends BaseController {
      */
     @PostMapping("/deviceOpenOrClose")
     public AjaxResult deviceOpenOrClose(@RequestBody String arr){
-        log.info("接受的执法设备参数：{}",arr);
         if(StringUtils.isEmpty(arr)){
             return AjaxResult.error("数据为空");
         }

src/main/java/com/sooka/sponest/lawenforcement/record/service/impl/LawenforcementRecordServiceImpl.java

@@ -71,6 +71,8 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
      */
     @Override
     public int insertEnforceLawInfoByList(JSONArray records) {
+        log.error("============================================数据开始===================================================");
+        log.error("接受到的报文数据长度===>{}",records.size());
         //存储原始报文
         return insertJsonData(records);
     }
@@ -340,6 +342,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
                 idArray.add(message.getString("id"));
                 recordMap.put(message.getString("id"), message);
             }
+            log.info("本次数据的id集合===>{}",idArray);
 
             //遍历报文数据,存储需要的信息
            /* recordListMessage.forEach(message->{
@@ -349,6 +352,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
 
             //调用获取数据方法,查出存在的数据
             List<Map<String, Object>> existMessage = recordMapper.getExistMessage(idArray);
+            log.error("获取存在的数据量===>{}",existMessage.size());
 
             //对存在的数据进行遍历更新;并且在recordMap中移除已经更新的数据
             existMessage.forEach(existMap -> {
@@ -363,6 +367,8 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
                     addMessage.put("updateTime", simpleDateFormat.format(new Date()));
                     addMessage.put("dataUpdateTime", message.getString("updateTime"));
                     recordMapper.updateJsonData(addMessage);
+                }else{
+                    log.error("时间相同====>数据id===>{};获取的报文数据:{}<<>>;mysql数据:{}", message.getString("id"), message, existMap);
                 }
 
                 //移除更新的记录
@@ -390,6 +396,7 @@ public class LawenforcementRecordServiceImpl extends BaseServiceImpl implements
             if (StringUtils.isNotEmpty(addMessageList)) {
                 recordMapper.batchInsert(addMessageList);
             }
+            log.error("============================================stop处理完成===================================================");
             return 1;
         } catch (Exception e) {
             log.error(e.getMessage());