package lottery_prize_info

import (
	"context"
	"demo/internal/dao"
	"demo/internal/model/do"
	"fmt"
	"github.com/gogf/gf/v2/os/gtime"

	"demo/api/lottery_prize_info/v1"
)

func (c *ControllerV1) Create(ctx context.Context, req *v1.CreateReq) (res *v1.CreateRes, err error) {
	saveData := []do.LotteryPrizeInfo{}
	for i := 0; i < len(req.LpiList); i++ {
		jyPrize := JyPrizeMap[fmt.Sprint(req.LpiList[i].PbId)]
		saveData = append(saveData, do.LotteryPrizeInfo{
			ActiveId:       req.ActiveId,
			State:          req.LpiList[i].State,
			Mold:           req.LpiList[i].Mold,
			PbId:           req.LpiList[i].PbId,
			JyPrize:        jyPrize,
			Frequency:      req.LpiList[i].Frequency,
			Probability:    req.LpiList[i].Probability,
			Inventory:      req.LpiList[i].Total,
			Total:          req.LpiList[i].Total,
			AlarmSwitch:    req.LpiList[i].AlarmSwitch,
			AlarmThreshold: req.LpiList[i].AlarmThreshold,
			Target:         req.LpiList[i].Target,
			DailyNum:       req.LpiList[i].DailyNum,
			CreateTime:     gtime.Now(),
		})
	}
	_, err = dao.LotteryPrizeInfo.Ctx(ctx).Data(saveData).Insert()
	return nil, err
}