GetUnread.js 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. const API = require("../../lib/API.js")
  2. const db = require("../../plugin/DataBase/db.js")
  3. const AccessControl = require("../../lib/AccessControl.js")
  4. const { BaseStdResponse } = require("../../BaseStdResponse.js")
  5. class GetUnreadPopup extends API {
  6. constructor() {
  7. super()
  8. this.setPath('/Popup/Unread')
  9. this.setMethod('GET')
  10. }
  11. async onRequest(req, res) {
  12. const { uuid, session, limit } = req.query
  13. if ([uuid, session].some(v => v === '' || v === null || v === undefined))
  14. return res.json({ ...BaseStdResponse.MISSING_PARAMETER })
  15. if (!await AccessControl.checkSession(uuid, session))
  16. return res.status(401).json({ ...BaseStdResponse.ACCESS_DENIED })
  17. const take = Number(limit) > 0 ? Number(limit) : 1
  18. const sql = `
  19. SELECT
  20. p.id,
  21. p.title,
  22. p.content_html,
  23. p.priority,
  24. p.repeat_show,
  25. p.start_at,
  26. p.end_at,
  27. p.created_at,
  28. p.updated_at
  29. FROM site_popup p
  30. LEFT JOIN site_popup_read r ON r.popup_id = p.id AND r.user_uuid COLLATE utf8mb4_general_ci = CONVERT(? USING utf8mb4) COLLATE utf8mb4_general_ci
  31. WHERE
  32. p.is_active = 1
  33. AND (p.repeat_show = 1 OR r.popup_id IS NULL)
  34. AND (p.start_at IS NULL OR p.start_at <= NOW())
  35. AND (p.end_at IS NULL OR p.end_at >= NOW())
  36. ORDER BY p.priority DESC, p.id DESC
  37. LIMIT ?
  38. `
  39. const rows = await db.query(sql, [uuid, String(take)])
  40. if (!rows) return res.json({ ...BaseStdResponse.DATABASE_ERR })
  41. return res.json({
  42. ...BaseStdResponse.OK,
  43. data: rows
  44. })
  45. }
  46. }
  47. module.exports.GetUnreadPopup = GetUnreadPopup