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()
}