messagelistlogic.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. package logic
  2. import (
  3. "app.yhyue.com/moapp/MessageCenter/api/internal/svc"
  4. "app.yhyue.com/moapp/MessageCenter/api/internal/types"
  5. "app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
  6. "context"
  7. "github.com/zeromicro/go-zero/core/logx"
  8. )
  9. type MessageListLogic struct {
  10. logx.Logger
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. }
  14. func NewMessageListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *MessageListLogic {
  15. return &MessageListLogic{
  16. Logger: logx.WithContext(ctx),
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. }
  20. }
  21. func (l *MessageListLogic) MessageList(req *types.MessageListReq) (resp *types.MessageListResp, err error) {
  22. // todo: add your logic here and delete this line
  23. result := new(types.MessageListResp)
  24. lsi := l.svcCtx.MessageCenter
  25. res, err := lsi.UserMsgList(l.ctx, &messageclient.UserMsgListReq{
  26. MsgType: req.MsgType,
  27. Appid: req.AppId,
  28. SortSize: req.SortSize,
  29. UserId: req.UserId,
  30. Read: req.IsRead,
  31. OffSet: req.Offset,
  32. PageSize: req.Size,
  33. IsColumn: req.IsColumn,
  34. IsColumnNewMsg: req.IsColumnNewMsg,
  35. IsMsgList: req.IsMsgList,
  36. })
  37. if err != nil {
  38. return nil, err
  39. }
  40. result.Code = res.Code
  41. result.Message = res.Message
  42. result.Total = res.Count
  43. result.Unread = res.Unread
  44. if res.List != nil && len(res.List) > 0 {
  45. for _, v := range res.List {
  46. result.Data = append(result.Data, map[string]interface{}{
  47. "id": v.Id,
  48. "appid": v.Appid,
  49. "receive_name": v.ReceiveName,
  50. "send_userid": v.SendUserId,
  51. "send_name": v.SendName,
  52. "createtime": v.Createtime,
  53. "title": v.Title,
  54. "msg_type": v.MsgType,
  55. "link": v.Link,
  56. "cite_id": v.CiteId,
  57. "content": v.Content,
  58. "isRead": v.IsRead,
  59. "msgLogId": v.MsgLogId,
  60. "url": v.Url,
  61. })
  62. }
  63. }
  64. if res.Last != nil {
  65. result.Last = map[string]interface{}{
  66. "id": res.Last.Id,
  67. "appid": res.Last.Appid,
  68. "receive_name": res.Last.ReceiveName,
  69. "send_userid": res.Last.SendUserId,
  70. "send_name": res.Last.SendName,
  71. "createtime": res.Last.Createtime,
  72. "title": res.Last.Title,
  73. "msg_type": res.Last.MsgType,
  74. "link": res.Last.Link,
  75. "cite_id": res.Last.CiteId,
  76. "content": res.Last.Content,
  77. "isRead": res.Last.IsRead,
  78. "msgLogId": res.Last.MsgLogId,
  79. "url": res.Last.Url,
  80. }
  81. }
  82. if res.Column != nil && len(res.Column) > 0 {
  83. var columns []map[string]interface{}
  84. for _, vs := range res.Column {
  85. var column = map[string]interface{}{
  86. "name": vs.Name,
  87. "img": vs.Img,
  88. "msg_type": vs.MsgType,
  89. "unreadMessages": vs.UnreadMessages,
  90. }
  91. var cn []map[string]interface{}
  92. for _, v := range vs.Data {
  93. cn = append(cn, map[string]interface{}{
  94. "id": v.Id,
  95. "appid": v.Appid,
  96. "receive_name": v.ReceiveName,
  97. "send_userid": v.SendUserId,
  98. "send_name": v.SendName,
  99. "createtime": v.Createtime,
  100. "title": v.Title,
  101. "msg_type": v.MsgType,
  102. "link": v.Link,
  103. "cite_id": v.CiteId,
  104. "content": v.Content,
  105. "isRead": v.IsRead,
  106. "msgLogId": v.MsgLogId,
  107. })
  108. }
  109. column["msgData"] = cn
  110. columns = append(columns, column)
  111. }
  112. result.Column = columns
  113. }
  114. return result, nil
  115. }