Method CreateLotteryDraw

internal/service/lotteryDraw.go:456–503

CreateLotteryDraw 创建新的抽奖活动

(ctx context.Context, input domain.LotteryDraw)

// CreateLotteryDraw 创建新的抽奖活动
func (s *lotteryDrawService) CreateLotteryDraw(ctx context.Context, input domain.LotteryDraw) error {
	// 验证输入
	if err := validateLotteryDrawInput(input); err != nil {
		s.l.Error("invalid lottery draw input", zap.Error(err))
		return err
	}

	// 检查名称唯一性
	exists, err := s.repo.ExistsLotteryDrawByName(ctx, input.Name)
	if err != nil {
		s.l.Error("failed to check lottery draw name uniqueness", zap.String("name", input.Name), zap.Error(err))
		return err
	}

	if exists {
		return errors.New("同名的抽奖活动已存在")
	}

	// 设置状态
	currentTime := time.Now().Unix()
	var status string
	switch {
	case input.EndTime <= currentTime:
		status = domain.LotteryStatusCompleted
	case input.StartTime <= currentTime:
		status = domain.LotteryStatusActive
	default:
		status = domain.LotteryStatusPending
	}

	// 创建抽奖活动
	lotteryDraw := domain.LotteryDraw{
		Name:        input.Name,
		Description: input.Description,
		StartTime:   input.StartTime,
		EndTime:     input.EndTime,
		Status:      status,
	}

	if err := s.repo.CreateLotteryDraw(ctx, lotteryDraw); err != nil {
		s.l.Error("failed to create lottery draw", zap.String("name", input.Name), zap.Error(err))
		return err
	}

	s.l.Info("lottery draw created", zap.String("name", input.Name))

	return nil
}

// GetLotteryDrawByID 根据ID获取抽奖活动
func (s *lotteryDrawService) GetLotteryDrawByID(ctx context.Context, id int) (domain.LotteryDraw, error) {