Browse Source

增加在线查询

xusl 1 year ago
parent
commit
3bec3777d7

+ 43 - 0
backend/src/main/java/com/jiayue/ssi/controller/SysUserController.java

@@ -759,4 +759,47 @@ public class SysUserController {
             throw new CustomException("注销用户异常", e);
         }
     }
+
+    /**
+     * 获取用户分页信息(查询在线用户使用 其中屏蔽了状态为注销的用户)
+     *
+     * @return 用户信息
+     */
+    @GetMapping(value = "/getUserByHealthy")
+    @PreAuthorize("@ss.hasPermi('monitor:onLine:list')")
+    @PreventReplay
+    public ResponseVO getUserByHealthy(String currentPage, String pageSize, String onLineStatus) throws CustomException {
+        try {
+            Integer cp;
+            if (StringUtils.isNotEmpty(currentPage)) {
+                if (NumberUtil.isInteger(currentPage)) {
+                    cp = Integer.parseInt(currentPage);
+                } else {
+                    return ResponseVO.fail("currentPage不是整数!");
+                }
+            } else {
+                return ResponseVO.fail("currentPage不能是空!");
+            }
+
+            Integer ps;
+            if (StringUtils.isNotEmpty(pageSize)) {
+                if (NumberUtil.isInteger(pageSize)) {
+                    ps = Integer.parseInt(pageSize);
+                } else {
+                    return ResponseVO.fail("pageSize不是整数!");
+                }
+            } else {
+                return ResponseVO.fail("pageSize不能是空!");
+            }
+            QueryWrapper<SysUser> wrapper = new QueryWrapper<>();
+            wrapper.ne("status", "2");
+            if (StringUtils.isNotEmpty(onLineStatus)) {
+                wrapper.eq("online_status", onLineStatus);
+            }
+            Page<SysUser> result = sysUserService.page(new Page<>(cp, ps), wrapper);
+            return ResponseVO.success(result);
+        } catch (Exception e) {
+            throw new CustomException("获取用户异常", e);
+        }
+    }
 }