From 4393ca2779c7a23185aae747b67a93558dbb4a80 Mon Sep 17 00:00:00 2001
From: qushutong <1976590620@qq.com>
Date: Tue, 29 Aug 2023 15:01:53 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E7=99=BB=E5=BD=95=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/elink/esua/epdc/log/LogConsumer.java  | 64 +++++++++----------
 1 file changed, 32 insertions(+), 32 deletions(-)

diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/log/LogConsumer.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/log/LogConsumer.java
index eee0237c4..7622976eb 100644
--- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/log/LogConsumer.java
+++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/log/LogConsumer.java
@@ -64,39 +64,39 @@ public class LogConsumer implements CommandLineRunner {
     }
 
     private void receiveQueue() {
-        String key = RedisKeys.getSysLogKey();
-        //每次插入100条
-        int count = 100;
-        for (int i = 0; i < count; i++) {
-            log.info("1日志存储开始-------------");
-            BaseLog baseLog = (BaseLog) redisUtils.rightPop(key);
-            if (baseLog == null) {
-                return;
-            }
-            //登录日志
-            if (baseLog.getType() == LogTypeEnum.LOGIN.value()) {
-                SysLogLogin sysLogLogin = (SysLogLogin) baseLog;
-                SysLogLoginEntity entity = ConvertUtils.sourceToTarget(sysLogLogin, SysLogLoginEntity.class);
-                log.info("1登录日志开始-------------"+entity.toString());
-                sysLogLoginService.save(entity);
-            }
-
-            //操作日志
-            if (baseLog.getType() == LogTypeEnum.OPERATION.value()) {
-                SysLogOperation sysLogOperation = (SysLogOperation) baseLog;
-                SysLogOperationEntity entity = ConvertUtils.sourceToTarget(sysLogOperation, SysLogOperationEntity.class);
-                log.info("操作日志开始-------------"+entity.toString());
-                sysLogOperationService.save(entity);
-            }
-
-//            //异常日志
-//            if (baseLog.getType() == LogTypeEnum.ERROR.value()) {
-//                SysLogError logError = (SysLogError) baseLog;
-//                SysLogErrorEntity entity = ConvertUtils.sourceToTarget(logError, SysLogErrorEntity.class);
-//                log.info("异常日志开始-------------"+entity.toString());
-//                sysLogErrorService.save(entity);
+//        String key = RedisKeys.getSysLogKey();
+//        //每次插入100条
+//        int count = 100;
+//        for (int i = 0; i < count; i++) {
+//            log.info("1日志存储开始-------------");
+//            BaseLog baseLog = (BaseLog) redisUtils.rightPop(key);
+//            if (baseLog == null) {
+//                return;
+//            }
+//            //登录日志
+//            if (baseLog.getType() == LogTypeEnum.LOGIN.value()) {
+//                SysLogLogin sysLogLogin = (SysLogLogin) baseLog;
+//                SysLogLoginEntity entity = ConvertUtils.sourceToTarget(sysLogLogin, SysLogLoginEntity.class);
+//                log.info("1登录日志开始-------------"+entity.toString());
+//                sysLogLoginService.save(entity);
+//            }
+//
+//            //操作日志
+//            if (baseLog.getType() == LogTypeEnum.OPERATION.value()) {
+//                SysLogOperation sysLogOperation = (SysLogOperation) baseLog;
+//                SysLogOperationEntity entity = ConvertUtils.sourceToTarget(sysLogOperation, SysLogOperationEntity.class);
+//                log.info("操作日志开始-------------"+entity.toString());
+//                sysLogOperationService.save(entity);
 //            }
-        }
+//
+////            //异常日志
+////            if (baseLog.getType() == LogTypeEnum.ERROR.value()) {
+////                SysLogError logError = (SysLogError) baseLog;
+////                SysLogErrorEntity entity = ConvertUtils.sourceToTarget(logError, SysLogErrorEntity.class);
+////                log.info("异常日志开始-------------"+entity.toString());
+////                sysLogErrorService.save(entity);
+////            }
+//        }
     }
 
 }