48 lines
1.1 KiB
Go
48 lines
1.1 KiB
Go
package admin
|
|
|
|
import (
|
|
"context"
|
|
"github.com/shopspring/decimal"
|
|
"nova_task/internal/model"
|
|
"nova_task/internal/pkg/errs"
|
|
"strings"
|
|
|
|
"nova_task/internal/svc"
|
|
"nova_task/internal/types"
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
)
|
|
|
|
type AddEmailRewardLogic struct {
|
|
logx.Logger
|
|
ctx context.Context
|
|
svcCtx *svc.ServiceContext
|
|
}
|
|
|
|
// 每日钱包签到任务
|
|
func NewAddEmailRewardLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AddEmailRewardLogic {
|
|
return &AddEmailRewardLogic{
|
|
Logger: logx.WithContext(ctx),
|
|
ctx: ctx,
|
|
svcCtx: svcCtx,
|
|
}
|
|
}
|
|
|
|
func (l *AddEmailRewardLogic) AddEmailReward(req *types.EmailReward) error {
|
|
emails := strings.Split(req.Email, ";")
|
|
for _, email := range emails {
|
|
_, err := l.svcCtx.EmailRewardModel.Insert(l.ctx, &model.NhEmailReward{
|
|
Email: email,
|
|
RewardType: req.RewardType,
|
|
Value: decimal.NewFromFloat(req.Value),
|
|
Remark: req.Remark,
|
|
})
|
|
if err != nil {
|
|
l.Errorw("add email reward failed", logx.Field("err", err), logx.Field("email", req.Email))
|
|
return errs.New(errs.ErrDatabaseOperate, err)
|
|
}
|
|
}
|
|
|
|
return errs.Success()
|
|
}
|