create_email_log_logic.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package emaillog
  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 CreateEmailLogLogic struct {
  12. logx.Logger
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. }
  16. func NewCreateEmailLogLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateEmailLogLogic {
  17. return &CreateEmailLogLogic{
  18. Logger: logx.WithContext(ctx),
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. }
  22. }
  23. func (l *CreateEmailLogLogic) CreateEmailLog(req *types.EmailLogInfo) (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.CreateEmailLog(l.ctx,
  28. &mcms.EmailLogInfo{
  29. Target: req.Target,
  30. Subject: req.Subject,
  31. Content: req.Content,
  32. SendStatus: req.SendStatus,
  33. Provider: req.Provider,
  34. })
  35. if err != nil {
  36. return nil, err
  37. }
  38. return &types.BaseMsgResp{Msg: l.svcCtx.Trans.Trans(l.ctx, data.Msg)}, nil
  39. }