updatemessagereadlogic.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package logic
  2. import (
  3. "context"
  4. "app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
  5. "app.yhyue.com/moapp/MessageCenter/rpc/message"
  6. "app.yhyue.com/moapp/MessageCenter/service"
  7. "github.com/tal-tech/go-zero/core/logx"
  8. )
  9. type UpdateMessageReadLogic struct {
  10. ctx context.Context
  11. svcCtx *svc.ServiceContext
  12. logx.Logger
  13. }
  14. func NewUpdateMessageReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateMessageReadLogic {
  15. return &UpdateMessageReadLogic{
  16. ctx: ctx,
  17. svcCtx: svcCtx,
  18. Logger: logx.WithContext(ctx),
  19. }
  20. }
  21. // 修改用户指定分类下的消息已读未读
  22. func (l *UpdateMessageReadLogic) UpdateMessageRead(in *message.UpdateMessageReadReq) (*message.UpdateMessageReadResp, error) {
  23. // todo: add your logic here and delete this line
  24. m := service.MessageService{}
  25. status, err := m.UpdateMessageReadStatus(int(in.MsgType), in.ReceiveUserid, in.AppId)
  26. if status == 0 && err != nil {
  27. return &message.UpdateMessageReadResp{
  28. Code: 1,
  29. Message: "修改消息已读失败",
  30. Status: 0,
  31. }, err
  32. }
  33. return &message.UpdateMessageReadResp{
  34. Code: 1,
  35. Message: "修改消息已读成功",
  36. Status: 1,
  37. }, nil
  38. }