msgCenterController.js 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. 'use strict';
  2. const Controller = require('egg').Controller;
  3. // 消息中心统计分析管理
  4. class MsgCenterController extends Controller {
  5. constructor(ctx) {
  6. super(ctx);
  7. // 特殊的入参校验可以重写在这,默认可以使用commonRule
  8. this.createRule = {
  9. msgType: { type: 'number', required: false },
  10. startTime: { type: 'number', min: 0 }, // 开始时间的时间戳 包含
  11. endTime: { type: 'number', min: 0 }, // 结束时间的时间戳 不包含(客户端处理结束时间 下一日 ,下一月第一日 ,下一年第一日)
  12. type: [ '0', '1', '2' ], // 类型分为 0日 1月 2年
  13. };
  14. }
  15. // 消息渠道统计
  16. async channel() {
  17. const { ctx, service } = this;
  18. // 校验参数 组装参数
  19. const payload = ctx.validate();
  20. // 调用 Service 进行业务处理
  21. const data = await service.msgCenterRecordService2.channel(payload);
  22. // 设置响应内容和响应状态码
  23. ctx.success({ data });
  24. }
  25. // 消息查看率统计
  26. async read() {
  27. const { ctx, service } = this;
  28. // 校验参数 组装参数
  29. const payload = ctx.validate(this.createRule);
  30. // 调用 Service 进行业务处理
  31. const data = await service.msgCenterRecordService2.read(payload);
  32. // 设置响应内容和响应状态码
  33. ctx.success({ data });
  34. }
  35. // 消息抵达率统计
  36. async over() {
  37. const { ctx, service } = this;
  38. // 校验参数 组装参数
  39. const payload = ctx.validate();
  40. // 调用 Service 进行业务处理
  41. const data = await service.msgCenterRecordService2.over(payload);
  42. // 设置响应内容和响应状态码
  43. ctx.success({ data });
  44. }
  45. }
  46. module.exports = MsgCenterController;