imgnews.js 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. 'use strict';
  2. const assert = require('assert');
  3. const moment = require('moment');
  4. const Service = require('egg').Service;
  5. class ImgnewsService extends Service {
  6. constructor(ctx) {
  7. super(ctx);
  8. this.model = this.ctx.model.Imgnews;
  9. this.column = this.ctx.model.Column;
  10. this.pages = this.ctx.model.Pages;
  11. }
  12. async create({ type, bind, date, img, url, content, describe, title, isshow, twoTitle }) {
  13. assert(bind, '绑定类型不存在');
  14. // assert(img, '图片不存在');
  15. assert(title, '标题不存在');
  16. try {
  17. const createAt = moment().format('x');
  18. const updateAt = moment().format('x');
  19. const item = await this.model.create({ title, type, bind, date, img, url, content, describe, createAt, updateAt, isshow, twoTitle });
  20. return { errcode: 0, errmsg: '', data: item };
  21. } catch (error) {
  22. throw error;
  23. }
  24. }
  25. async update({ id, type, bind, date, img, url, content, describe, title, isshow, twoTitle }) {
  26. assert(id, 'id不存在');
  27. try {
  28. const res = await this.model.findOne({ _id: id });
  29. if (!res) return { errcode: -1001, errmsg: '数据不存在', data: '' };
  30. const updateAt = moment().format('x');
  31. await this.model.updateOne({ _id: id }, { title, type, bind, date, img, url, content, describe, updateAt, isshow, twoTitle });
  32. return { errcode: 0, errmsg: '', data: 'update' };
  33. } catch (error) {
  34. throw error;
  35. }
  36. }
  37. async delete({ id }) {
  38. assert(id, 'id不存在');
  39. try {
  40. const res = await this.model.findOne({ _id: id });
  41. if (!res) return { errcode: -1001, errmsg: '数据不存在', data: '' };
  42. await this.model.remove({ _id: id });
  43. return { errcode: 0, errmsg: '', data: 'delete' };
  44. } catch (error) {
  45. throw error;
  46. }
  47. }
  48. async query({ skip, limit, title, date, bind, isshow, twoTitle }) {
  49. const filter = {};
  50. if (title || date) filter.$or = [];
  51. if (title) filter.$or.push({ code: { $regex: title } });
  52. if (twoTitle) filter.$or.push({ code: { $regex: twoTitle } });
  53. if (date) filter.$or.push({ date: { $regex: date } });
  54. if (bind) filter.bind = bind;
  55. if (isshow) filter.isshow = isshow;
  56. try {
  57. // let res;
  58. // const total = await this.model.find({ ...filter }, { content: false });
  59. // if (skip && limit) {
  60. // res = await this.model.find({ ...filter }, { content: false })
  61. // .skip(Number(skip) * Number(limit))
  62. // .limit(Number(limit));
  63. // } else {
  64. // res = await this.model.find({ ...filter }, { content: false });
  65. // }
  66. // return { errcode: 0, errmsg: '', data: res, total: total.length };
  67. // 获取完整未分页结果
  68. const totalList = await this.model.find({ ...filter }, { content: false });
  69. // 在 JS 层进行排序:将 date 为 0 的放最后,其它按 date 降序
  70. const sorted = totalList.sort((a, b) => {
  71. const aDate = a.date || 0;
  72. const bDate = b.date || 0;
  73. // 把 date=0 的排在后面
  74. if (aDate === 0 && bDate !== 0) return 1;
  75. if (aDate !== 0 && bDate === 0) return -1;
  76. return bDate - aDate; // 正常降序排序
  77. });
  78. // 再进行分页
  79. let res = sorted;
  80. if (skip && limit) {
  81. const start = Number(skip) * Number(limit);
  82. const end = start + Number(limit);
  83. res = sorted.slice(start, end);
  84. }
  85. return {
  86. errcode: 0,
  87. errmsg: '',
  88. data: res,
  89. total: totalList.length,
  90. };
  91. } catch (error) {
  92. throw error;
  93. }
  94. }
  95. async fetch({ id }) {
  96. try {
  97. const res = await this.model.findOne({ _id: id });
  98. if (!res) return { errcode: -1001, errmsg: '数据不存在', data: '' };
  99. return { errcode: 0, errmsg: '', data: res };
  100. } catch (error) {
  101. throw error;
  102. }
  103. }
  104. }
  105. module.exports = ImgnewsService;