From b7becf98e156a8c5f0c89a926b70f7a528ea172b Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期二, 29 七月 2025 14:24:51 +0800
Subject: [PATCH] 添加分布式锁,解决重复执行任务问题

---
 se-common/src/main/java/com/terra/common/aspect/LogAspect.java |   12 ++++++++++--
 1 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/se-common/src/main/java/com/terra/common/aspect/LogAspect.java b/se-common/src/main/java/com/terra/common/aspect/LogAspect.java
index 831dae2..a7262f7 100644
--- a/se-common/src/main/java/com/terra/common/aspect/LogAspect.java
+++ b/se-common/src/main/java/com/terra/common/aspect/LogAspect.java
@@ -2,7 +2,8 @@
 
 import com.terra.common.annotation.SysLog;
 import com.terra.common.entity.lf.OperatePo;
-import com.terra.common.helper.TokenHelper;
+import com.terra.common.entity.lf.UserPo;
+import com.terra.common.service.CommonService;
 import com.terra.common.helper.WebHelper;
 import com.terra.common.mapper.CommonMapper;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -28,6 +29,9 @@
 public class LogAspect {
     @Resource
     CommonMapper commonMapper;
+
+    @Resource
+    CommonService commonService;
 
     private final static String SELECT = "select";
 
@@ -85,7 +89,11 @@
             po.setUrl(req.getServletPath());
             po.setIp(WebHelper.getIpAddress(req));
             po.setExec(time);
-            po.setUserid(TokenHelper.getCurrentUserId());
+
+            UserPo user = commonService.getCurrentUser(req);
+            if (null != user) {
+                po.setUserid(user.getId());
+            }
 
             // 璁剧疆妯″潡
             Tag tag = clazz.getAnnotation(Tag.class);

--
Gitblit v1.9.3