diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java index 831dc86f7..2b3f483ce 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java @@ -42,4 +42,6 @@ public interface WxCUserMapper extends CommonMapper { // void updateMsgCountDown(@Param("tenantId")String tenantId, @Param("openId")String openId); List findOpenIdList(@Param("userId")Long userId, @Param("tenantId")String tenantId); + + List findTokenList(@Param("userId")Long userId, @Param("tenantId")String tenantId); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java index c1d7878de..56340972e 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserServiceImpl.java @@ -47,6 +47,9 @@ public class WxCUserServiceImpl implements WxCUserService { @Autowired private MqBaseProducer mqBaseProducer; + @Autowired + private CUserTokenService cUserTokenService; + @Autowired @Qualifier("baseCUserTokenRedisTemplate") RedisTemplate baseCUserTokenRedisTemplate; @@ -321,6 +324,12 @@ public class WxCUserServiceImpl implements WxCUserService { @Override public void delForUserIdOnly(Long id, Long userId, String tenantId) { + List tokenList = wxCUserMapper.findTokenList(userId, tenantId); + if(tokenList != null){ + for (String token:tokenList) { + cUserTokenService.removeTokenCache(token); + } + } wxCUserMapper.delForUserIdOnly(id,userId,tenantId); } diff --git a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml index 8cfc343bc..c901eec67 100644 --- a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml @@ -434,6 +434,10 @@ where user_id = #{userId} and tenant_id = #{tenantId} and id != #{id} + +