ai_dianshang/server/internal/service/coupon.go

package service

import (
	"dianshang/internal/model"
	"dianshang/internal/repository"
	"errors"
	"fmt"
	"time"
)

// CouponService 优惠券服务
type CouponService struct {
	couponRepo *repository.CouponRepository
}

// NewCouponService 创建优惠券服务
func NewCouponService(couponRepo *repository.CouponRepository) *CouponService {
	return &CouponService{
		couponRepo: couponRepo,
	}
}

// GetAvailableCoupons 获取可用优惠券列表
func (s *CouponService) GetAvailableCoupons() ([]model.Coupon, error) {
	return s.couponRepo.GetAvailableCoupons()
}

// GetAvailableCouponsWithUserStatus 获取可用优惠券列表（包含用户已领取状态）
func (s *CouponService) GetAvailableCouponsWithUserStatus(userID uint) ([]map[string]interface{}, error) {
	// 获取所有可用优惠券
	coupons, err := s.couponRepo.GetAvailableCoupons()
	if err != nil {
		return nil, err
	}

	var result []map[string]interface{}
	
	// 如果用户已登录，检查每个优惠券的领取状态
	for _, coupon := range coupons {
		couponData := map[string]interface{}{
			"id":          coupon.ID,
			"name":        coupon.Name,
			"type":        coupon.Type,
			"value":       coupon.Value,
			"min_amount":  coupon.MinAmount,
			"description": coupon.Description,
			"start_time":  coupon.StartTime,
			"end_time":    coupon.EndTime,
			"total_count": coupon.TotalCount,
			"used_count":  coupon.UsedCount,
			"is_received": false, // 默认未领取
		}

		// 如果用户已登录，检查是否已领取
		if userID > 0 {
			exists, err := s.couponRepo.CheckUserCouponExists(userID, coupon.ID)
			if err == nil {
				couponData["is_received"] = exists
			}
		}

		result = append(result, couponData)
	}

	return result, nil
}

// GetUserCoupons 获取用户优惠券
func (s *CouponService) GetUserCoupons(userID uint, status int) ([]model.UserCoupon, error) {
	return s.couponRepo.GetUserCoupons(userID, status)
}

// ReceiveCoupon 领取优惠券
func (s *CouponService) ReceiveCoupon(userID, couponID uint) error {
	// 检查优惠券是否存在且有效
	coupon, err := s.couponRepo.GetByID(couponID)
	if err != nil {
		return errors.New("优惠券不存在")
	}

	// 检查是否在有效期内
	now := time.Now()
	if now.Before(coupon.StartTime) || now.After(coupon.EndTime) {
		return errors.New("优惠券不在有效期内")
	}

	// 检查是否还有库存
	if coupon.TotalCount > 0 && coupon.UsedCount >= coupon.TotalCount {
		return errors.New("优惠券已被领完")
	}

	// 检查用户是否已经领取过
	exists, err := s.couponRepo.CheckUserCouponExists(userID, couponID)
	if err != nil {
		return err
	}
	if exists {
		return errors.New("您已经领取过该优惠券")
	}

	// 创建用户优惠券记录
	userCoupon := &model.UserCoupon{
		UserID:   userID,
		CouponID: couponID,
		Status:   0, // 未使用
	}

	return s.couponRepo.CreateUserCoupon(userCoupon)
}

// UseCoupon 使用优惠券
func (s *CouponService) UseCoupon(userID, userCouponID, orderID uint) error {
	// 获取用户优惠券
	userCoupon, err := s.couponRepo.GetUserCouponByID(userCouponID)
	if err != nil {
		return errors.New("优惠券不存在")
	}

	// 检查是否属于该用户
	if userCoupon.UserID != userID {
		return errors.New("无权使用该优惠券")
	}

	// 检查是否已使用
	if userCoupon.Status != 0 {
		return errors.New("优惠券已使用或已过期")
	}

	// 检查优惠券是否在有效期内
	now := time.Now()
	if now.Before(userCoupon.Coupon.StartTime) || now.After(userCoupon.Coupon.EndTime) {
		return errors.New("优惠券不在有效期内")
	}

	// 更新优惠券状态为已使用
	return s.couponRepo.UseCoupon(userCouponID, orderID)
}

// ValidateCoupon 验证优惠券是否可用
func (s *CouponService) ValidateCoupon(userID, userCouponID uint, orderAmount float64) (*model.UserCoupon, float64, error) {
	// 获取用户优惠券
	userCoupon, err := s.couponRepo.GetUserCouponByID(userCouponID)
	if err != nil {
		return nil, 0, errors.New("优惠券不存在")
	}

	// 检查是否属于该用户
	if userCoupon.UserID != userID {
		return nil, 0, errors.New("无权使用该优惠券")
	}

	// 检查是否已使用
	if userCoupon.Status != 0 {
		return nil, 0, errors.New("优惠券已使用或已过期")
	}

	// 检查优惠券是否在有效期内
	now := time.Now()
	if now.Before(userCoupon.Coupon.StartTime) || now.After(userCoupon.Coupon.EndTime) {
		return nil, 0, errors.New("优惠券不在有效期内")
	}

	// 检查最低消费金额
	minAmount := float64(userCoupon.Coupon.MinAmount) / 100 // 分转元
	if orderAmount < minAmount {
		return nil, 0, errors.New(fmt.Sprintf("订单金额不满足优惠券使用条件，最低需要%.2f元", minAmount))
	}

	// 计算优惠金额
	var discountAmount float64
	switch userCoupon.Coupon.Type {
	case 1: // 满减券
		discountAmount = float64(userCoupon.Coupon.Value) / 100 // 分转元
	case 2: // 折扣券
		discountRate := float64(userCoupon.Coupon.Value) / 100 // 85 -> 0.85
		discountAmount = orderAmount * (1 - discountRate)
	case 3: // 免邮券
		discountAmount = 0 // 免邮券的优惠金额在运费中体现
	default:
		return nil, 0, errors.New("不支持的优惠券类型")
	}

	// 确保优惠金额不超过订单金额
	if discountAmount > orderAmount {
		discountAmount = orderAmount
	}

	return userCoupon, discountAmount, nil
}

// GetAvailableCouponsForOrder 获取订单可用的优惠券
func (s *CouponService) GetAvailableCouponsForOrder(userID uint, orderAmount float64) ([]model.UserCoupon, error) {
	// 获取用户未使用的优惠券
	userCoupons, err := s.couponRepo.GetUserCoupons(userID, 1) // 1表示未使用(API状态值)
	if err != nil {
		return nil, err
	}

	var availableCoupons []model.UserCoupon
	now := time.Now()

	for _, userCoupon := range userCoupons {
		// 严格检查优惠券状态：必须是未使用状态(0)且没有关联订单
		if userCoupon.Status != 0 || userCoupon.OrderID != nil {
			continue
		}

		// 检查是否在有效期内
		if now.Before(userCoupon.Coupon.StartTime) || now.After(userCoupon.Coupon.EndTime) {
			continue
		}

		// 检查优惠券模板是否可用
		if userCoupon.Coupon.Status != 1 {
			continue
		}

		// 检查最低消费金额
		minAmount := float64(userCoupon.Coupon.MinAmount) / 100 // 分转元
		if orderAmount >= minAmount {
			availableCoupons = append(availableCoupons, userCoupon)
		}
	}

	return availableCoupons, nil
}