messagecountlogic.go 935 B

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. package logic
  2. import (
  3. "context"
  4. "messagecenter/rpc/messagecenter/messagecenter"
  5. "messagecenter/api/messagecenter/internal/svc"
  6. "messagecenter/api/messagecenter/internal/types"
  7. "github.com/zeromicro/go-zero/core/logx"
  8. )
  9. type MessageCountLogic struct {
  10. logx.Logger
  11. ctx context.Context
  12. svcCtx *svc.ServiceContext
  13. }
  14. func NewMessageCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) *MessageCountLogic {
  15. return &MessageCountLogic{
  16. Logger: logx.WithContext(ctx),
  17. ctx: ctx,
  18. svcCtx: svcCtx,
  19. }
  20. }
  21. func (l *MessageCountLogic) MessageCount(req *types.CountReq) (*types.CommonRes, error) {
  22. resp, err := l.svcCtx.Message.Count(l.ctx, &messagecenter.CountReq{
  23. UserType: req.UserType,
  24. EntUserId: req.EntUserId,
  25. NewUserId: req.NewUserId,
  26. })
  27. if err != nil {
  28. return nil, err
  29. }
  30. return &types.CommonRes{
  31. Error_msg: resp.ErrorMsg,
  32. Error_code: int(resp.ErrorCode),
  33. Data: resp.Count,
  34. }, nil
  35. }