u

dsk-system/src/main/java/com/dsk/system/service/impl/ISysTenantServiceImpl.java

 package com.dsk.system.service.impl;
 
 import cn.dev33.satoken.secure.BCrypt;
+import cn.dev33.satoken.session.SaSession;
+import cn.dev33.satoken.session.TokenSign;
+import cn.dev33.satoken.stp.StpUtil;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.convert.Convert;
+import cn.hutool.core.map.MapUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.dsk.common.constant.CacheConstants;
 import com.dsk.common.constant.CacheNames;
 import com.dsk.common.constant.Constants;
 import com.dsk.common.constant.TenantConstants;
 import com.dsk.common.core.domain.PageQuery;
+import com.dsk.common.core.domain.dto.UserOnlineDTO;
 import com.dsk.common.core.domain.entity.SysDictData;
 import com.dsk.common.core.domain.entity.SysDictType;
 import com.dsk.common.core.page.TableDataInfo;
+import com.dsk.common.enums.UserStatus;
 import com.dsk.common.exception.ServiceException;
+import com.dsk.common.utils.MessageUtils;
 import com.dsk.common.utils.PasswordUtils;
 import com.dsk.common.utils.StringUtils;
+import com.dsk.common.utils.redis.RedisUtils;
 import com.dsk.system.domain.*;
 import com.dsk.system.domain.bo.SysTenantBo;
 import com.dsk.system.domain.vo.SysTenantVo;
 import com.dsk.system.mapper.*;
 import com.dsk.system.service.ISysTenantService;
+import com.dsk.system.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.sms4j.api.SmsBlend;
 import org.dromara.sms4j.api.entity.SmsResponse;
 import org.dromara.sms4j.core.factory.SmsFactory;
 import org.dromara.sms4j.provider.enumerate.SupplierType;
+import org.omg.CORBA.Object;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.ObjectUtils;
 
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 企业Service业务层处理
@@ -393,6 +408,24 @@ public class ISysTenantServiceImpl implements ISysTenantService {
             roleMenuMapper.delete(
                     new LambdaQueryWrapper<SysRoleMenu>().in(SysRoleMenu::getRoleId, roleIds).notIn(!menuIds.isEmpty(), SysRoleMenu::getMenuId, menuIds));
         }
+        try {
+            //清除企业用户登录信息
+            List<SysUser> tenantUsers = userMapper.selectList(Wrappers.<SysUser>lambdaQuery()
+                    .eq(SysUser::getTenantId, tenantId).eq(SysUser::getStatus, UserStatus.OK.getCode()));
+            if (!CollectionUtils.isEmpty(tenantUsers)) {
+                for (SysUser tenantUser : tenantUsers) {
+                    String key = "global:Authorization:login:session:00:" + tenantUser.getUserId();
+                    if (RedisUtils.hasKey(key)) {
+                        SaSession session = RedisUtils.getCacheObject(key);
+                        List<TokenSign> tokenSignList = session.getTokenSignList();
+                        tokenSignList.forEach(sign -> StpUtil.kickoutByTokenValue(sign.getValue()));
+                    }
+                }
+            }
+        } catch (Exception e) {
+            log.error("清除企业用户登录信息操作失败！error={}", e.getMessage());
+        }
+
         return true;
     }