create_sms_log_logic.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package smslog
  2. import (
  3. "context"
  4. "github.com/suyuan32/simple-admin-common/i18n"
  5. "github.com/zeromicro/go-zero/core/errorx"
  6. "github.com/suyuan32/simple-admin-message-center/types/mcms"
  7. "github.com/suyuan32/simple-admin-core/api/internal/svc"
  8. "github.com/suyuan32/simple-admin-core/api/internal/types"
  9. "github.com/zeromicro/go-zero/core/logx"
  10. )
  11. type CreateSmsLogLogic struct {
  12. logx.Logger
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. }
  16. func NewCreateSmsLogLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateSmsLogLogic {
  17. return &CreateSmsLogLogic{
  18. Logger: logx.WithContext(ctx),
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. }
  22. }
  23. func (l *CreateSmsLogLogic) CreateSmsLog(req *types.SmsLogInfo) (resp *types.BaseMsgResp, err error) {
  24. if !l.svcCtx.Config.McmsRpc.Enabled {
  25. return nil, errorx.NewCodeUnavailableError(i18n.ServiceUnavailable)
  26. }
  27. data, err := l.svcCtx.McmsRpc.CreateSmsLog(l.ctx,
  28. &mcms.SmsLogInfo{
  29. PhoneNumber: req.PhoneNumber,
  30. Content: req.Content,
  31. SendStatus: req.SendStatus,
  32. Provider: req.Provider,
  33. })
  34. if err != nil {
  35. return nil, err
  36. }
  37. return &types.BaseMsgResp{Msg: l.svcCtx.Trans.Trans(l.ctx, data.Msg)}, nil
  38. }