GetLepaoRecords.js 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  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 AdminGetLepaoRecords extends API {
  6. constructor() {
  7. super();
  8. this.setPath('/Admin/Lepao/Records')
  9. this.setMethod('GET')
  10. }
  11. async onRequest(req, res) {
  12. let { uuid, session, name, lepao_account, email, 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) {
  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. // 检查权限
  36. let permission = await AccessControl.getPermission(uuid)
  37. if (!permission.includes("admin") && !permission.includes("server"))
  38. return res.json({
  39. ...BaseStdResponse.PERMISSION_DENIED
  40. })
  41. // 计算分页的 offset
  42. const offset = (current - 1) * pagesize
  43. let sql = `
  44. SELECT
  45. r.id,
  46. r.uuid,
  47. r.time,
  48. r.area,
  49. r.lepao_account,
  50. r.startTime,
  51. r.endTime,
  52. r.distance,
  53. r.state,
  54. a.name,
  55. u.avatar,
  56. u.username
  57. FROM
  58. lepao_record r
  59. LEFT JOIN
  60. lepao_account a
  61. ON
  62. r.lepao_account = a.student_num
  63. LEFT JOIN
  64. users u
  65. ON
  66. r.uuid = u.uuid
  67. WHERE
  68. 1 = 1
  69. `
  70. let countSql = `
  71. SELECT COUNT(*) AS total
  72. FROM lepao_record r
  73. JOIN lepao_account a ON r.lepao_account = a.student_num
  74. WHERE 1 = 1
  75. `
  76. let params = []
  77. let countParams = []
  78. if (lepao_account) {
  79. sql += ` AND r.lepao_account LIKE ?`
  80. countSql += ` AND r.lepao_account LIKE ?`
  81. params.push(`%${lepao_account}%`)
  82. countParams.push(`%${lepao_account}%`)
  83. }
  84. if (email) {
  85. sql += ` AND a.email = ?`
  86. countSql += ` AND a.email = ?`
  87. params.push(email)
  88. countParams.push(email)
  89. }
  90. if (name) {
  91. sql += ` AND a.name LIKE ?`
  92. countSql += ` AND a.name LIKE ?`
  93. params.push(`%${name}%`)
  94. countParams.push(`%${name}%`)
  95. }
  96. sql += `
  97. ORDER BY id DESC
  98. LIMIT ? OFFSET ?;
  99. `
  100. params.push(String(pagesize), String(offset))
  101. let rows = await db.query(sql, params)
  102. let countResult = await db.query(countSql, countParams)
  103. if (!rows || !countResult)
  104. return res.json({
  105. ...BaseStdResponse.DATABASE_ERR
  106. })
  107. let total = countResult[0].total
  108. res.json({
  109. ...BaseStdResponse.OK,
  110. data: rows,
  111. pagination: {
  112. current,
  113. pagesize,
  114. total
  115. }
  116. })
  117. }
  118. }
  119. module.exports.AdminGetLepaoRecords = AdminGetLepaoRecords