添加删除站点后通知门户服务更新

portal-manager/src/main/java/com/mortals/xhx/module/user/service/impl/UserServiceImpl.java

@@ -243,16 +243,9 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity
         this.update(userEntity, context);
 
         //更新redis中 所有用户session信息
-        Set<String> keys = cacheService.scan(Constant.LOGIN_TOKEN_KEY + userEntity.getId());
-        keys.forEach(item->{
-            String token = StrUtil.subAfter(item, Constant.LOGIN_TOKEN_KEY + userEntity.getId() + ":", false);
-            userEntity.setToken(token);
-            userEntity.setExpireTime(DateUtils.addCurrDate(7).getTime());
-            authTokenService.setUser(userEntity);
-        });
+        updateRedisUserSession(userEntity);
     }
 
-
     @Override
     protected void saveAfter(UserEntity entity, Context context) throws AppException {
         super.saveAfter(entity, context);
@@ -286,7 +279,19 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity
                 userEntity.setId(item.getId());
                 userEntity.setSiteIds(siteIds);
                 this.dao.update(userEntity);
+
+                updateRedisUserSession(userEntity);
             }
         });
     }
+
+    private void updateRedisUserSession(UserEntity userEntity) {
+        Set<String> keys = cacheService.scan(Constant.LOGIN_TOKEN_KEY + userEntity.getId());
+        keys.forEach(key -> {
+            String token = StrUtil.subAfter(key, Constant.LOGIN_TOKEN_KEY + userEntity.getId() + ":", false);
+            userEntity.setToken(token);
+            userEntity.setExpireTime(DateUtils.addCurrDate(7).getTime());
+            authTokenService.setUser(userEntity);
+        });
+    }
 }
\ No newline at end of file