GetAccountList.js 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196
  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 GetAccountList extends API {
  6. constructor() {
  7. super();
  8. this.setPath('/Admin/Lepao/Account')
  9. this.setMethod('get')
  10. }
  11. async onRequest(req, res) {
  12. let { uuid, session, email, area, user_uuid, username, student_num, state, auto_time, queryTime, 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. l.id,
  46. u.username AS create_user,
  47. u.avatar,
  48. l.name,
  49. l.email,
  50. l.student_num,
  51. l.create_time,
  52. l.update_time,
  53. l.user_avatar,
  54. l.academy_name,
  55. l.sex,
  56. l.area,
  57. l.grade_id,
  58. l.total_num,
  59. l.term_num,
  60. l.auto_run,
  61. l.auto_time,
  62. l.today_auto_time,
  63. l.state,
  64. l.auto_day,
  65. l.notes,
  66. l.deviceModel,
  67. l.userAgent,
  68. l.target_count,
  69. f.face_code,
  70. f.state AS face_state,
  71. f.create_time AS face_time,
  72. f.url AS face_url
  73. FROM
  74. lepao_account l
  75. LEFT JOIN
  76. users u
  77. ON
  78. l.create_user = u.uuid
  79. LEFT JOIN
  80. lepao_face f
  81. ON
  82. l.student_num = f.student_num
  83. WHERE
  84. 1 = 1
  85. `
  86. let countSql = `
  87. SELECT COUNT(*) AS total
  88. FROM
  89. lepao_account l
  90. LEFT JOIN
  91. users u
  92. ON
  93. l.create_user = u.uuid
  94. WHERE 1 = 1
  95. `
  96. let params = []
  97. let countParams = []
  98. if (user_uuid) {
  99. sql += ` AND l.create_user = ?`
  100. countSql += ` AND l.create_user = ?`
  101. params.push(user_uuid)
  102. countParams.push(user_uuid)
  103. }
  104. if (email) {
  105. sql += ` AND l.email = ?`
  106. countSql += ` AND l.email = ?`
  107. params.push(email)
  108. countParams.push(email)
  109. }
  110. if (area) {
  111. sql += ` AND l.area = ?`
  112. countSql += ` AND l.area = ?`
  113. params.push(area)
  114. countParams.push(area)
  115. }
  116. if (student_num) {
  117. sql += ` AND l.student_num LIKE ?`
  118. countSql += ` AND l.student_num LIKE ?`
  119. params.push(`%${student_num}%`)
  120. countParams.push(`%${student_num}%`)
  121. }
  122. if (username) {
  123. sql += ` AND l.name LIKE ?`
  124. countSql += ` AND l.name LIKE ?`
  125. params.push(`%${username}%`)
  126. countParams.push(`%${username}%`)
  127. }
  128. if (auto_time !== 0) {
  129. sql += ` AND l.auto_time = ?`
  130. countSql += ` AND l.auto_time = ?`
  131. params.push(auto_time)
  132. countParams.push(auto_time)
  133. }
  134. if (state !== -1) {
  135. sql += ` AND l.state = ?`
  136. countSql += ` AND l.state = ?`
  137. params.push(state)
  138. countParams.push(state)
  139. }
  140. if (queryTime || (Array.isArray(queryTime) && queryTime.length === 2)) {
  141. sql += ` AND ((l.update_time >= ? AND l.update_time < ?) OR (l.create_time >= ? AND l.create_time < ?))`
  142. countSql += ` AND ((l.update_time >= ? AND l.update_time < ?) OR (l.create_time >= ? AND l.create_time < ?))`
  143. params.push(queryTime[0], queryTime[1], queryTime[0], queryTime[1])
  144. countParams.push(queryTime[0], queryTime[1], queryTime[0], queryTime[1])
  145. }
  146. sql += `
  147. ORDER BY l.create_time DESC
  148. LIMIT ? OFFSET ?;
  149. `
  150. params.push(String(pagesize), String(offset))
  151. let rows = await db.query(sql, params)
  152. let countResult = await db.query(countSql, countParams)
  153. if (!rows || !countResult)
  154. return res.json({
  155. ...BaseStdResponse.MISSING_FILE,
  156. msg: '获取乐跑账号数据失败!'
  157. })
  158. let total = countResult[0].total
  159. res.json({
  160. ...BaseStdResponse.OK,
  161. data: rows,
  162. pagination: {
  163. current,
  164. pagesize,
  165. total
  166. }
  167. })
  168. }
  169. }
  170. module.exports.GetAccountList = GetAccountList