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 | 18 +++++++++++++-----
1 files changed, 13 insertions(+), 5 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 7a60693..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,9 +2,10 @@
import com.terra.common.annotation.SysLog;
import com.terra.common.entity.lf.OperatePo;
-import com.terra.common.service.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.OperatePoMapper;
+import com.terra.common.mapper.CommonMapper;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -27,7 +28,10 @@
@Component
public class LogAspect {
@Resource
- OperatePoMapper operatePoMapper;
+ 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(req));
+
+ UserPo user = commonService.getCurrentUser(req);
+ if (null != user) {
+ po.setUserid(user.getId());
+ }
// 璁剧疆妯″潡
Tag tag = clazz.getAnnotation(Tag.class);
@@ -105,7 +113,7 @@
po.setBak(sysLog.value());
}
- operatePoMapper.insert(po);
+ commonMapper.insert(po);
} catch (Exception ex) {
log.error(ex.getMessage(), ex);
}
--
Gitblit v1.9.3