findmessagelogic.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package logic
  2. import (
  3. "context"
  4. "github.com/zeromicro/go-zero/core/logx"
  5. "messagecenter/api/messagecenter/internal/svc"
  6. "messagecenter/api/messagecenter/internal/types"
  7. "messagecenter/rpc/messagecenter/messagecenter"
  8. )
  9. type FindMessageLogic struct {
  10. logx.Logger
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. }
  14. func NewFindMessageLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FindMessageLogic {
  15. return &FindMessageLogic{
  16. Logger: logx.WithContext(ctx),
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. }
  20. }
  21. func (l *FindMessageLogic) FindMessage(req *types.MessageReq) (*types.CommonRes, error) {
  22. // todo: add your logic here and delete this line
  23. resp, err := l.svcCtx.Message.FindMessage(l.ctx, &messagecenter.MessageReq{
  24. UserType: req.UserType,
  25. MsgType: req.MsgType,
  26. SendId: req.SendId,
  27. PageIndex: req.PageIndex,
  28. PageSize: req.PageSize,
  29. EntUserId: req.EntUserId,
  30. EntId: req.EntId,
  31. CustomerEntId: req.CustomerEntId,
  32. NewUserId: req.NewUserId,
  33. })
  34. if err != nil {
  35. return nil, err
  36. }
  37. return &types.CommonRes{
  38. Error_msg: resp.ErrorMsg,
  39. Error_code: int(resp.ErrorCode),
  40. Data: resp.Data,
  41. Count: resp.Count,
  42. }, nil
  43. }