GetAccount.js 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. const API = require("../../../lib/API.js");
  2. const db = require("../../../plugin/DataBase/db.js");
  3. const { BaseStdResponse } = require("../../../BaseStdResponse.js");
  4. const AccessControl = require("../../../lib/AccessControl.js");
  5. class GetAccount extends API {
  6. constructor() {
  7. super();
  8. this.setPath('/Lepao/Account')
  9. this.setMethod('GET')
  10. }
  11. async onRequest(req, res) {
  12. let { uuid, session, email, area, username, student_num, state, 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. endpoint: 1513126
  17. })
  18. // 校验分页参数
  19. if (isNaN(pagesize) || pagesize <= 0 || pagesize > 50) {
  20. return res.json({
  21. ...BaseStdResponse.ERR,
  22. msg: '参数错误'
  23. })
  24. }
  25. if (isNaN(current) || current <= 0) {
  26. return res.json({
  27. ...BaseStdResponse.ERR,
  28. msg: '参数错误'
  29. })
  30. }
  31. if (!await AccessControl.checkSession(uuid, session))
  32. return res.status(401).json({
  33. ...BaseStdResponse.ACCESS_DENIED
  34. })
  35. const offset = (current - 1) * pagesize
  36. let sql = `
  37. SELECT
  38. l.id,
  39. l.name,
  40. l.student_num,
  41. l.create_time,
  42. l.update_time,
  43. l.state,
  44. l.area,
  45. l.auto_time,
  46. l.total_num,
  47. l.term_num,
  48. l.academy_name,
  49. l.sex,
  50. l.user_avatar,
  51. l.grade_id,
  52. l.email,
  53. l.auto_run,
  54. l.notes,
  55. f.face_code,
  56. f.create_time AS face_time,
  57. f.state AS face_state
  58. FROM
  59. lepao_account l
  60. LEFT JOIN
  61. lepao_face f
  62. ON
  63. l.student_num = f.student_num
  64. WHERE
  65. l.create_user = ?
  66. `
  67. let countSql = `
  68. SELECT COUNT(*) AS total
  69. FROM
  70. lepao_account l
  71. WHERE l.create_user = ?
  72. `
  73. let params = [uuid]
  74. let countParams = [uuid]
  75. if (email) {
  76. sql += ` AND l.email = ?`
  77. countSql += ` AND l.email = ?`
  78. params.push(email)
  79. countParams.push(email)
  80. }
  81. if (area) {
  82. sql += ` AND l.area = ?`
  83. countSql += ` AND l.area = ?`
  84. params.push(area)
  85. countParams.push(area)
  86. }
  87. if (student_num) {
  88. sql += ` AND l.student_num LIKE ?`
  89. countSql += ` AND l.student_num LIKE ?`
  90. params.push(`%${student_num}%`)
  91. countParams.push(`%${student_num}%`)
  92. }
  93. if (username) {
  94. sql += ` AND l.name LIKE ?`
  95. countSql += ` AND l.name LIKE ?`
  96. params.push(`%${username}%`)
  97. countParams.push(`%${username}%`)
  98. }
  99. if (state !== -1) {
  100. sql += ` AND l.state = ?`
  101. countSql += ` AND l.state = ?`
  102. params.push(state)
  103. countParams.push(state)
  104. }
  105. sql += `
  106. ORDER BY l.create_time DESC
  107. LIMIT ? OFFSET ?;
  108. `
  109. params.push(String(pagesize), String(offset))
  110. let rows = await db.query(sql, params)
  111. let countResult = await db.query(countSql, countParams)
  112. if (!rows || !countResult)
  113. return res.json({
  114. ...BaseStdResponse.MISSING_FILE,
  115. msg: '获取乐跑账号数据失败!'
  116. })
  117. let total = countResult[0].total
  118. res.json({
  119. ...BaseStdResponse.OK,
  120. data: rows,
  121. pagination: {
  122. current,
  123. pagesize,
  124. total
  125. }
  126. })
  127. }
  128. }
  129. module.exports.GetAccount = GetAccount;