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