closechatsessionlogic.go 1.0 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. package logic
  2. import (
  3. quitl "app.yhyue.com/moapp/jybase/common"
  4. "app.yhyue.com/moapp/jybase/encrypt"
  5. "context"
  6. "github.com/zeromicro/go-zero/core/logx"
  7. "messagecenter/api/messagecenter/internal/svc"
  8. "messagecenter/api/messagecenter/internal/types"
  9. "messagecenter/rpc/messagecenter/messagecenter"
  10. )
  11. type CloseChatSessionLogic struct {
  12. logx.Logger
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. }
  16. func NewCloseChatSessionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CloseChatSessionLogic {
  17. return &CloseChatSessionLogic{
  18. Logger: logx.WithContext(ctx),
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. }
  22. }
  23. func (l *CloseChatSessionLogic) CloseChatSession(req *types.CloseSessionReq) (*types.CommonRes, error) {
  24. chatMession := &messagecenter.CloseSessionReq{SessionId: quitl.Int64All(encrypt.SE.Decode4Hex(req.SessionId))}
  25. resp, err := l.svcCtx.Message.CloseChatSession(l.ctx, chatMession)
  26. if err != nil {
  27. return nil, err
  28. }
  29. return &types.CommonRes{
  30. Error_msg: resp.ErrorMsg,
  31. Error_code: int(resp.ErrorCode),
  32. }, nil
  33. }