From 17dd0fc6e9656dae18f07aa96ace5392fb9c126e Mon Sep 17 00:00:00 2001
From: dzc <2388224167@qq.com>
Date: Tue, 12 May 2026 10:16:38 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E5=88=A0=E9=99=A4=E7=BC=93?=
 =?UTF-8?q?=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/bsd/pjcloud/admin/service/SysUserService.java    | 2 ++
 .../bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java    | 4 +++-
 .../admin/service/impl/SysUserTransactionServiceImpl.java     | 1 +
 3 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java
index 87b208c90..c028f67fd 100644
--- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java
+++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/SysUserService.java
@@ -239,4 +239,6 @@ public interface SysUserService extends IService<SysUser> {
      * @return
      */
     List<SimpleUserListVO> listUserIdByDeptId(Long deptId, String name);
+
+    void deleteDiscountsCacheByUserId(Long userId);
 }
diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java
index 7c5055ca0..c0c2c12b4 100644
--- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java
+++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserServiceImpl.java
@@ -61,6 +61,7 @@ import com.bsd.pjcloud.common.core.util.MsgUtils;
 import com.bsd.pjcloud.common.core.util.R;
 import com.bsd.pjcloud.common.data.datascope.DataScope;
 import com.bsd.pjcloud.common.data.resolver.ParamResolver;
+import com.bsd.pjcloud.common.data.tenant.TenantContextHolder;
 import com.bsd.pjcloud.common.excel.vo.ErrorMessage;
 import com.bsd.pjcloud.common.security.service.PjcloudUser;
 import com.bsd.pjcloud.common.security.util.SecurityUtils;
@@ -1069,9 +1070,10 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
         return count > 0;
     }
 
+    @Override
     public void deleteDiscountsCacheByUserId(Long userId) {
         if (ObjectUtil.isEmpty(userId)) return;
-        String pattern = CacheConstants.WALLET_USER_DISCOUNTS_LIST + "::" + userId + ":*";
+        String pattern = TenantContextHolder.getTenantId() + ":" + CacheConstants.WALLET_USER_DISCOUNTS_LIST + "::" + userId + ":*";
         Set<String> keys = new HashSet<>();
         stringRedisTemplate.execute((RedisCallback<Void>) connection -> {
             Cursor<byte[]> cursor = connection.scan(
diff --git a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserTransactionServiceImpl.java b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserTransactionServiceImpl.java
index 3fb9c2beb..f65aea0d6 100644
--- a/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserTransactionServiceImpl.java
+++ b/pjcloud-upms/pjcloud-upms-biz/src/main/java/com/bsd/pjcloud/admin/service/impl/SysUserTransactionServiceImpl.java
@@ -230,6 +230,7 @@ public class SysUserTransactionServiceImpl extends ServiceImpl<SysUserTransactio
                     RequestContextHolder.setRequestAttributes(requestAttributes);
                     remoteWalletService.userChange(detail.getUserId(), Boolean.FALSE);
                 });
+                sysUserService.deleteDiscountsCacheByUserId(detail.getUserId());
             }
         } catch (Exception e) {
             e.printStackTrace();