修改查询时间段

log-manager/src/main/java/com/mortals/xhx/base/framework/listener/ErrorMessageConsumerListener.java

@@ -48,24 +48,26 @@ public class ErrorMessageConsumerListener {
             entity.setCreateTime(new Date());
             if (!ObjectUtils.isEmpty(entity.getFingerprint())) {
                 //// TODO: 2022/8/24 指纹匹配
-            } else {
-                //比较message platform appname 如果相同 则checknum+1 并更新日志时间
-                ErrorLogQuery errorLogQuery = new ErrorLogQuery();
-                errorLogQuery.setAppName(entity.getAppName());
-                errorLogQuery.setPlatform(entity.getPlatform());
-                errorLogQuery.setErrorStack(entity.getErrorStack());
-                ErrorLogEntity errorLogEntity = errorLogService.selectOne(errorLogQuery, null);
-                if (!ObjectUtils.isEmpty(errorLogEntity)) {
-                    errorLogEntity.setCheckNum(errorLogEntity.getCheckNum() + 1);
-                    errorLogEntity.setLogTime(entity.getLogTime());
-                    errorLogEntity.setThreadNo(entity.getThreadNo());
-                    errorLogEntity.setCreateTime(new Date());
-                    errorLogEntity.setUpdateTime(new Date());
-                    errorLogService.update(errorLogEntity);
-                } else {
-                    errorLogService.save(entity);
-                }
             }
+            //比较message platform appname 如果相同 则checknum+1 并更新日志时间
+           /* ErrorLogQuery errorLogQuery = new ErrorLogQuery();
+            errorLogQuery.setAppName(entity.getAppName());
+            errorLogQuery.setPlatform(entity.getPlatform());
+            errorLogQuery.setErrorStack(entity.getErrorStack());
+            ErrorLogEntity errorLogEntity = errorLogService.selectOne(errorLogQuery, null);
+            if (!ObjectUtils.isEmpty(errorLogEntity)) {
+                errorLogEntity.setCheckNum(errorLogEntity.getCheckNum() + 1);
+                errorLogEntity.setLogTime(entity.getLogTime());
+                errorLogEntity.setThreadNo(entity.getThreadNo());
+                errorLogEntity.setCreateTime(new Date());
+                errorLogEntity.setUpdateTime(new Date());
+                errorLogService.update(errorLogEntity);
+            } else {
+                errorLogService.save(entity);
+            }*/
+
+
+            errorLogService.save(entity);
         }).count();
     }
 }

log-manager/src/main/java/com/mortals/xhx/module/error/web/ErrorLogController.java

@@ -69,7 +69,7 @@ public class ErrorLogController extends BaseCRUDJsonBodyMappingController<ErrorL
     @Override
     @UnAuth
     public String save(@RequestBody ErrorLogEntity entity) {
-        ErrorLogQuery errorLogQuery = new ErrorLogQuery();
+/*        ErrorLogQuery errorLogQuery = new ErrorLogQuery();
         errorLogQuery.setAppName(entity.getAppName());
         errorLogQuery.setPlatform(entity.getPlatform());
         errorLogQuery.setErrorStack(entity.getErrorStack());
@@ -78,7 +78,7 @@ public class ErrorLogController extends BaseCRUDJsonBodyMappingController<ErrorL
             entity.setId(errorLogEntity.getId());
             entity.setCheckNum(errorLogEntity.getCheckNum() + 1);
             entity.setUpdateTime(new Date());
-        }
+        }*/
         return super.save(entity);
     }
 
@@ -86,7 +86,7 @@ public class ErrorLogController extends BaseCRUDJsonBodyMappingController<ErrorL
     @Override
     @UnAuth
     public String batchSave(@RequestBody List<ErrorLogEntity> list) {
-        list.forEach(entity -> {
+/*        list.forEach(entity -> {
             ErrorLogQuery errorLogQuery = new ErrorLogQuery();
             errorLogQuery.setAppName(entity.getAppName());
             errorLogQuery.setPlatform(entity.getPlatform());
@@ -97,7 +97,7 @@ public class ErrorLogController extends BaseCRUDJsonBodyMappingController<ErrorL
                 entity.setCheckNum(errorLogEntity.getCheckNum() + 1);
                 entity.setUpdateTime(new Date());
             }
-        });
+        });*/
         return super.batchSave(list);
     }
 }
\ No newline at end of file