GetUserList.js 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130
  1. const API = require("../../../lib/API")
  2. const db = require("../../../plugin/DataBase/db")
  3. const AccessControl = require("../../../lib/AccessControl")
  4. const { BaseStdResponse } = require("../../../BaseStdResponse")
  5. class GetUserList extends API {
  6. constructor() {
  7. super();
  8. this.setPath('/Admin/User/GetUserList')
  9. this.setMethod('get')
  10. }
  11. async onRequest(req, res) {
  12. let { uuid, session, email, user_uuid, username, nickname, pagesize, current } = req.query
  13. if ([uuid, session, pagesize, current].some(value => value === '' || value === null || value === undefined))
  14. return res.json({
  15. ...BaseStdResponse.MISSING_PARAMETER
  16. })
  17. // 校验分页参数
  18. if (isNaN(pagesize) || pagesize <= 0 || pagesize > 50) {
  19. return res.json({
  20. ...BaseStdResponse.ERR,
  21. msg: '参数错误'
  22. })
  23. }
  24. if (isNaN(current) || current <= 0) {
  25. return res.json({
  26. ...BaseStdResponse.ERR,
  27. msg: '参数错误'
  28. })
  29. }
  30. // 检查 session
  31. if (!await AccessControl.checkSession(uuid, session))
  32. return res.status(401).json({
  33. ...BaseStdResponse.ACCESS_DENIED
  34. })
  35. // 检查权限
  36. let permission = await AccessControl.getPermission(uuid)
  37. if (!permission.includes("admin") && !permission.includes("service"))
  38. return res.json({
  39. ...BaseStdResponse.PERMISSION_DENIED
  40. })
  41. // 计算分页的 offset
  42. const offset = (current - 1) * pagesize
  43. let sql = `
  44. SELECT
  45. uuid, username, nickname, email, registTime, avatar, lepao_count,
  46. COALESCE(send_count_auto_approve, 0) AS send_count_auto_approve,
  47. social_type, lastTime
  48. FROM
  49. users
  50. WHERE
  51. 1 = 1
  52. `
  53. let countSql = `
  54. SELECT COUNT(*) AS total
  55. FROM users
  56. WHERE 1 = 1
  57. `
  58. let params = []
  59. let countParams = []
  60. if (user_uuid) {
  61. sql += ` AND uuid = ?`
  62. countSql += ` AND uuid = ?`
  63. params.push(user_uuid)
  64. countParams.push(user_uuid)
  65. }
  66. if (email) {
  67. sql += ` AND email = ?`
  68. countSql += ` AND email = ?`
  69. params.push(email)
  70. countParams.push(email)
  71. }
  72. if (username) {
  73. sql += ` AND username LIKE ?`
  74. countSql += ` AND username LIKE ?`
  75. params.push(`%${username}%`)
  76. countParams.push(`%${username}%`)
  77. }
  78. if (nickname) {
  79. sql += ` AND nickname LIKE ?`
  80. countSql += ` AND nickname LIKE ?`
  81. params.push(`%${nickname}%`)
  82. countParams.push(`%${nickname}%`)
  83. }
  84. sql += `
  85. ORDER BY id DESC
  86. LIMIT ? OFFSET ?;
  87. `
  88. params.push(String(pagesize), String(offset))
  89. let rows = await db.query(sql, params)
  90. let countResult = await db.query(countSql, countParams)
  91. if (!rows || !countResult)
  92. return res.json({
  93. ...BaseStdResponse.MISSING_FILE,
  94. msg: '获取用户数据失败!'
  95. })
  96. let total = countResult[0].total
  97. res.json({
  98. ...BaseStdResponse.OK,
  99. data: rows,
  100. pagination: {
  101. current,
  102. pagesize,
  103. total
  104. }
  105. })
  106. }
  107. }
  108. module.exports.GetUserList = GetUserList