| | |
| | | |
| | | import cn.dev33.satoken.annotation.SaCheckPermission; |
| | | import cn.dev33.satoken.exception.NotLoginException; |
| | | import cn.dev33.satoken.stp.StpLogic; |
| | | import cn.dev33.satoken.stp.StpUtil; |
| | | import cn.hutool.core.bean.BeanUtil; |
| | | import com.ruoyi.common.annotation.Log; |
| | |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.RequiredArgsConstructor; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.Collections; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | |
| | | @SaCheckPermission("monitor:online:list") |
| | | @GetMapping("/list") |
| | | public TableDataInfo<SysUserOnline> list(String ipaddr, String userName) { |
| | | Collection<String> keys = RedisUtils.keys(Constants.ONLINE_TOKEN_KEY + "*"); |
| | | // 获取所有未过期的 token |
| | | List<String> keys = StpUtil.searchTokenValue("", -1, 0); |
| | | List<UserOnlineDTO> userOnlineDTOList = new ArrayList<>(); |
| | | for (String key : keys) { |
| | | userOnlineDTOList.add(RedisUtils.getCacheObject(key)); |
| | | // 如果已经过期则踢下线 |
| | | if (StpUtil.stpLogic.getTokenActivityTimeoutByToken(key) < 0) { |
| | | StpUtil.kickoutByTokenValue(key); |
| | | continue; |
| | | } |
| | | String onlineKey = key.replace(Constants.LOGIN_TOKEN_KEY, Constants.ONLINE_TOKEN_KEY); |
| | | userOnlineDTOList.add(RedisUtils.getCacheObject(onlineKey)); |
| | | } |
| | | if (StringUtils.isNotEmpty(ipaddr) && StringUtils.isNotEmpty(userName)) { |
| | | userOnlineDTOList = userOnlineDTOList.stream().filter(userOnline -> |
| | |
| | | @DeleteMapping("/{tokenId}") |
| | | public AjaxResult<Void> forceLogout(@PathVariable String tokenId) { |
| | | try { |
| | | StpUtil.logoutByTokenValue(tokenId); |
| | | StpUtil.kickoutByTokenValue(tokenId); |
| | | } catch (NotLoginException e) { |
| | | } |
| | | return AjaxResult.success(); |