1024PM

controllers/course/order.go

@@ -15,10 +15,6 @@ func (c *CourseController) PostOrder() {
 		c.ResponseError(errors.New("无有效订单信息"))
 	}
 
-	// 订单优惠券
-	customercouponid := c.GetString("customercouponid")
-
-	//
 	var orderInfo model.TaCourseOrders
 	//	var orderCoupon []model.TaCourseOrdersCoupon
 
@@ -39,10 +35,10 @@ func (c *CourseController) PostOrder() {
 			http.StatusNotAcceptable,
 		)
 	}
-
-	if err := c.serv.Orders(&orderInfo, customercouponid); err != nil {
+	newOrders, err := c.serv.PreOrders(&orderInfo)
+	if err != nil {
 		c.ResponseError(err)
 	}
 
-	c.ResponseJSON("ok")
+	c.ResponseJSON(newOrders)
 }

models/course/order.go

@@ -12,7 +12,7 @@ import (
 )
 
 // SaveCourseOrder 保存订单
-func (m *CourseDAO) SaveCourseOrder(order *model.TaCourseOrders) error {
+func (m *CourseDAO) SaveCourseOrder(order *model.TaCourseOrders) (*model.TaCourseOrders, error) {
 
 	if order.OrdersId == "" {
 		order.OrdersId = guid.NewGUIDString()
@@ -26,7 +26,7 @@ func (m *CourseDAO) SaveCourseOrder(order *model.TaCourseOrders) error {
 	order.OrdersNo = ordersno
 	order.CreateDate = time.Now()
 	_, err := m.db.Insert(order)
-	return err
+	return order, err
 }
 
 // GetOrderByID 根据id获取订单明细

service/course/course.go

@@ -9,6 +9,7 @@ import (
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/system"
+	"spaceofcheng/services/models/vipcard"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 	"strings"
@@ -22,6 +23,7 @@ type CourseServ struct {
 	custDAO   *customer.CustomerDAO
 	userDAO   *system.UserDAO
 	couponDAO *coupon.CouponDAO
+	vipDAO    *vipcard.VipcardDAO
 }
 
 // NewCourseServ 初始化
@@ -33,6 +35,7 @@ func NewCourseServ(ctx *utils.Context) *CourseServ {
 		custDAO:   customer.NewCustomerDAO(ctx),
 		userDAO:   system.NewUserDAO(ctx),
 		couponDAO: coupon.NewCouponDAO(ctx),
+		vipDAO:    vipcard.NewVipcardDAO(ctx),
 	}
 }
 

service/course/order.go

@@ -13,13 +13,12 @@ import (
 )
 
 // PreOrders 预下单
+// 保存订单信息
 func (s *CourseServ) PreOrders(
 	couseOrder *model.TaCourseOrders,
-	customercouponid string,
-) error {
+) (*model.TaCourseOrders, error) {
 	org := s.ctx.Get("org").(model.SysOrg)
 	cust := s.ctx.Get("customer").(model.TaCustomer)
-
 	// 校验人员
 	couseOrder.CustomerId = cust.CustomerId
 	if cust.UserId != "" {
@@ -30,16 +29,14 @@ func (s *CourseServ) PreOrders(
 		// 默认是卡券支付
 		couseOrder.PayType = models.CONSUME_COUPON
 	}
-
 	// 校验课程
 	course, err := s.validCourse(couseOrder)
 	if err != nil {
-		return err
+		return nil, err
 	}
 	if course.CourseDetail == nil || len(course.CourseDetail) == 0 {
-		return errors.New("定单课程尚未排课, 不能下单")
+		return nil, errors.New("定单课程尚未排课, 不能下单")
 	}
-
 	couseOrder.OrdersId = guid.NewGUIDString()
 	couseOrder.Price = course.Price // 课程价格, 即为订单价格
 	couseOrder.ActualAmount = course.Price
@@ -54,19 +51,42 @@ func (s *CourseServ) PreOrders(
 	} else {
 		couseOrder.CustomerName = cust.CustomerName
 	}
+	// 入库
+	neworder, err := s.AddOrder(couseOrder)
+	if err != nil {
+		utils.LogError("课程下单失败: " + err.Error())
+		return nil, errors.New("下单失败, 请重试")
+	}
+	return neworder, nil
+}
+
+// ConfirmOrders 确认订单
+func (s *CourseServ) ConfirmOrders(ordersID, customercouponid string) error {
 
-	// 客户 VIP 卡
-	var vipAccount float64 = 0.0
-	vips, err := s.custDAO.GetValidVIPCards(cust.CustomerId)
+	couseOrder, err := s.dao.GetOrderByID(ordersID)
 	if err != nil {
-		return nil, utils.LogError("查询用户VIP卡信息出错", err.Error())
+		return utils.LogError("获取订单失败", err)
 	}
 
-	if vips != nil && len(vips) > 0 {
-		for _, vip := range vips {
-			vipMoney, _ := strconv.ParseFloat(vip.Balance, 64)
-			vipAccount += vipMoney
-		}
+	if couseOrder.Status != models.STATUS_READY {
+		return errors.New("没有订单信息")
+	}
+	cust := s.ctx.Get("customer").(model.TaCustomer)
+
+	// TODO
+	// 校验案场
+	// caseID := couseOrder.CaseId
+	// if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
+	// 	return err
+	// }
+
+	// 校验课程
+	course, err := s.validCourse(couseOrder)
+	if err != nil {
+		return err
+	}
+	if course.CourseDetail == nil || len(course.CourseDetail) == 0 {
+		return errors.New("定单课程尚未排课, 不能下单")
 	}
 
 	account, err := s.custDAO.GetAccountByCust(cust.CustomerId)
@@ -143,10 +163,6 @@ func (s *CourseServ) PreOrders(
 			return errors.New("保存优惠信息出错")
 		}
 
-		if err := s.couponDAO.IncreseCouponUsedNum(coupon.CouponId); err != nil {
-			return utils.LogError("保存优惠信息出错", err.Error())
-		}
-
 		// 优惠券核销
 		err = s.couponDAO.VerifyCustomerCoupon(customercouponid)
 		if err != nil {
@@ -174,23 +190,60 @@ func (s *CourseServ) PreOrders(
 
 	// 用户账户  -- 内部人员也可以购买
 	if actualAmount > 0 {
+		var leftPay = actualAmount
+		vips, err := s.custDAO.GetValidVIPCards(cust.CustomerId)
+		if err != nil {
+			return utils.LogError("查询用户 VIP卡 出错", err)
+		}
+
+		var vipAccount float64
+		if vips != nil && len(vips) > 0 {
+			for _, vip := range vips {
+				vipMoney, _ := strconv.ParseFloat(vip.Balance, 64)
+				vipAccount += vipMoney
+
+				// 当前扣款
+				var vipPay float64
+				if vipMoney > leftPay {
+					// 如果卡余额比 需要扣款的多, 那么就只扣这一张卡
+					// 通过 leftPay < 0.01 来判断
+					vipPay = leftPay
+					leftPay = 0
+				} else {
+					// 如果余额不够, 先扣掉本张卡余额, 继续循环
+					vipPay = vipMoney
+					leftPay -= vipMoney
+				}
+
+				if err := s.saveVipChangeRec(vipPay, &vip, couseOrder); err != nil {
+					return utils.LogError("VIP卡扣款失败", err.Error())
+				}
 
-		if actualAmount > accMoney+vipAccount {
-			return errors.New("账户余额不足")
+				if leftPay < 0.01 {
+					break
+				}
+			}
 		}
 
-		// 插入账户流水
-		if err := s.saveCustomerPayRec(account, couseOrder); err != nil {
-			utils.LogError("插入账户流水出错: " + err.Error())
-			return errors.New("写入账户流水出错")
+		// 如果 VIP 卡余额不足, 则使用账户余额
+		if leftPay > 0.01 {
+			if leftPay > accMoney {
+				return errors.New("账户余额不足")
+			}
+
+			// 插入账户流水
+			if err := s.saveCustomerPayRec(account, couseOrder, leftPay); err != nil {
+				utils.LogError("插入账户流水出错: " + err.Error())
+				return errors.New("写入账户流水出错")
+			}
 		}
 	}
 
-	// 入库
-	if err := s.SaveOrder(couseOrder, course); err != nil {
-		utils.LogError("课程下单失败: " + err.Error())
-		return errors.New("下单失败, 请重试")
-	}
+	// 更新订单信息
+	// if err := s.SaveOrder(couseOrder, course); err != nil {
+	// 	utils.LogError("课程下单失败: " + err.Error())
+	// 	return errors.New("下单失败, 请重试")
+	// }
 
 	// 发送短信
 	utils.SendSMS("orders", cust.Phone, course.CourseName)
@@ -198,19 +251,225 @@ func (s *CourseServ) PreOrders(
 	return nil
 }
 
-func (s *CourseServ) ConfirmOrders(ordersID string) error {
-	orders, err := s.dao.GetOrderByID(ordersID)
-	if err != nil {
-		return utils.LogError("获取订单失败", err)
-	}
-
-	if orders.Status != models.STATUS_READY {
-		return errors.New("没有订单信息")
+// saveVipChangeRec 保存vip消费记录
+func (s *CourseServ) saveVipChangeRec(payMoney float64, custVIP *model.TaCustomerVip, info *model.TaCourseOrders) error {
+	vipChange := new(model.TaCustomerVipChange)
+	vipChange.CustomerVipId = custVIP.CustomerVipId
+	vipChange.CustomerId = info.CustomerId
+	vipChange.OrgId = info.OrgId
+	vipChange.CaseId = info.CaseId
+	vipChange.ChangeType = models.CONSUME_COINCHG
+	vipChange.FloatType = models.ACCOUNT_SPENT
+	vipChange.SourceId = info.OrdersId
+	vipChange.SourceName = info.CustomerName + "课程下单"
+	vipChange.Amount = strconv.FormatFloat(payMoney, 'f', -1, 64)
+
+	if err := s.vipDAO.InsertCustomerVipChange(*vipChange); err != nil {
+		return err
 	}
 
-	return nil
+	return s.custDAO.UpdateCustVipCardAmount(custVIP, payMoney)
 }
 
+// // PreOrders 预下单
+// func (s *CourseServ) PreOrders(
+// 	couseOrder *model.TaCourseOrders,
+// 	customercouponid string,
+// ) (*course.CourseDetail, error) {
+// 	org := s.ctx.Get("org").(model.SysOrg)
+// 	cust := s.ctx.Get("customer").(model.TaCustomer)
+
+// 	// 校验人员
+// 	couseOrder.CustomerId = cust.CustomerId
+// 	if cust.UserId != "" {
+// 		// 内部人员
+// 		// 如果是内部人员购买或者兑换课程, 卡券或者城币就从内部人员自己的账户走
+// 		couseOrder.PayType = models.CONSUME_INNER
+// 	} else {
+// 		// 默认是卡券支付
+// 		couseOrder.PayType = models.CONSUME_COUPON
+// 	}
+
+// 	// 校验课程
+// 	course, err := s.validCourse(couseOrder)
+// 	if err != nil {
+// 		return nil, err
+// 	}
+// 	if course.CourseDetail == nil || len(course.CourseDetail) == 0 {
+// 		return nil, errors.New("定单课程尚未排课, 不能下单")
+// 	}
+
+// 	couseOrder.OrdersId = guid.NewGUIDString()
+// 	couseOrder.Price = course.Price // 课程价格, 即为订单价格
+// 	couseOrder.ActualAmount = course.Price
+// 	couseOrder.CourseName = course.CourseName
+// 	couseOrder.CourseNum = course.CourseNum
+// 	couseOrder.OrgId = org.OrgId
+// 	couseOrder.Status = models.STATUS_READY
+// 	couseOrder.IsPay = models.BOOL_FALSE
+
+// 	if cust.Name != "" {
+// 		couseOrder.CustomerName = cust.Name
+// 	} else {
+// 		couseOrder.CustomerName = cust.CustomerName
+// 	}
+
+// 	// 客户 VIP 卡
+// 	var vipAccount float64 = 0.0
+// 	vips, err := s.custDAO.GetValidVIPCards(cust.CustomerId)
+// 	if err != nil {
+// 		return nil, utils.LogError("查询用户VIP卡信息出错", err.Error())
+// 	}
+
+// 	if vips != nil && len(vips) > 0 {
+// 		for _, vip := range vips {
+// 			vipMoney, _ := strconv.ParseFloat(vip.Balance, 64)
+// 			vipAccount += vipMoney
+// 		}
+// 	}
+
+// 	account, err := s.custDAO.GetAccountByCust(cust.CustomerId)
+// 	if err != nil {
+// 		utils.LogError("查询用户账户信息出错: " + err.Error())
+// 		return nil, errors.New("查询用户账户信息出错")
+// 	}
+// 	accMoney, _ := strconv.ParseFloat(account.Amount, 64)
+
+// 	if customercouponid != "" {
+// 		// 校验卡券, 同时进行卡券的注销或者已使用的更新操作
+// 		// TODO
+// 		couseOrder.PayType = models.CONSUME_COUPON
+
+// 		// 优惠券校验
+// 		customerCoupon, err := s.couponDAO.GetCustomerCouponByID(customercouponid)
+// 		if err != nil {
+// 			utils.LogError("查询优惠券信息失败: " + err.Error())
+// 			return nil, errors.New("查询优惠券信息失败")
+// 		}
+// 		if customerCoupon == nil || customerCoupon.CustomerCouponId == "" {
+// 			return nil, errors.New("优惠券无效！")
+// 		}
+
+// 		if customerCoupon.CaseId != couseOrder.CaseId {
+// 			return nil, errors.New("优惠券对应案场与下单案场不一致，不允许下单！")
+// 		}
+
+// 		if customerCoupon.Status != models.STATUS_NORMAL || !customerCoupon.UseDate.IsZero() {
+// 			return nil, errors.New("优惠券已被使用！请重新选择优惠券！")
+// 		}
+
+// 		// 根据id获取优惠券信息
+// 		coupon, err := s.couponDAO.GetCouponInfoByCustomerCouponID(customercouponid)
+// 		if err != nil {
+// 			utils.LogError("查询优惠券信息失败: " + err.Error())
+// 			return nil, errors.New("查询优惠券信息失败")
+// 		}
+
+// 		if coupon.StartDate.After(time.Now().Local()) {
+// 			return nil, errors.New("该优惠券还未到有效期，不允许下单！")
+// 		}
+// 		if coupon.EndDate.Before(time.Now().Local()) {
+// 			return nil, errors.New("优惠券已失效，不允许下单！")
+// 		}
+
+// 		// 判断优惠券是否可以抵用商品
+// 		var isdy = false
+// 		if coupon.IsAll == 1 {
+// 			isdy = true
+// 			couseOrder.CouponAmount = coupon.Price
+// 		} else {
+// 			for _, target := range coupon.Targets {
+// 				if target.TargetId == course.CourseId {
+// 					isdy = true
+// 				}
+// 			}
+// 			couseOrder.CouponAmount = coupon.Price
+// 		}
+// 		if !isdy {
+// 			return nil, errors.New("优惠券不可抵用该课程")
+// 		}
+// 		var ordersCoupon = model.TaCourseOrdersCoupon{
+// 			OrdersId:         couseOrder.OrdersId,
+// 			CouponId:         coupon.CouponId,
+// 			CouponName:       coupon.CouponName,
+// 			UsedAmount:       couseOrder.CouponAmount,
+// 			CustomerCouponId: customerCoupon.CustomerCouponId,
+// 			CourseId:         course.CourseId,
+// 			CourseName:       course.CourseName,
+// 		}
+// 		if err := s.dao.SaveOrdersCoupon(&ordersCoupon, couseOrder); err != nil {
+// 			utils.LogError("保存优惠信息出错: " + err.Error())
+// 			return nil, errors.New("保存优惠信息出错")
+// 		}
+
+// 		if err := s.couponDAO.IncreseCouponUsedNum(coupon.CouponId); err != nil {
+// 			return nil, utils.LogError("保存优惠信息出错", err.Error())
+// 		}
+
+// 		// 优惠券核销
+// 		err = s.couponDAO.VerifyCustomerCoupon(customercouponid)
+// 		if err != nil {
+// 			utils.LogError("优惠券核销出错: " + err.Error())
+// 			return nil, errors.New("优惠券核销出错")
+// 		}
+// 	} else {
+// 		couseOrder.PayType = models.CONSUME_COINCHG
+// 		couseOrder.CouponAmount = "0.0"
+// 	}
+
+// 	couponAmount, _ := strconv.ParseFloat(couseOrder.CouponAmount, 64)
+// 	payMoney, _ := strconv.ParseFloat(couseOrder.Price, 64)
+// 	payMoney = payMoney - couponAmount
+
+// 	couseOrder.ActualAmount = strconv.FormatFloat(payMoney, 'f', -1, 64)
+
+// 	// 校验金额
+// 	// if err := s.validBillCharges(couseOrder, coupons); err != nil {
+// 	// 	return err
+// 	// }
+
+// 	// 实际支付
+// 	actualAmount := payMoney
+
+// 	// 用户账户  -- 内部人员也可以购买
+// 	if actualAmount > 0 {
+
+// 		if actualAmount > accMoney+vipAccount {
+// 			return nil, errors.New("账户余额不足")
+// 		}
+
+// 		// 插入账户流水
+// 		// if err := s.saveCustomerPayRec(account, couseOrder); err != nil {
+// 		// 	utils.LogError("插入账户流水出错: " + err.Error())
+// 		// 	return nil, errors.New("写入账户流水出错")
+// 		// }
+// 	}
+
+// 	// 入库
+// 	if err := s.SaveOrder(couseOrder, course); err != nil {
+// 		utils.LogError("课程下单失败: " + err.Error())
+// 		return nil, errors.New("下单失败, 请重试")
+// 	}
+
+// 	// 发送短信
+// 	utils.SendSMS("orders", cust.Phone, course.CourseName)
+
+// 	return nil, nil
+// }
+
+// func (s *CourseServ) ConfirmOrders(ordersID string) error {
+// 	orders, err := s.dao.GetOrderByID(ordersID)
+// 	if err != nil {
+// 		return utils.LogError("获取订单失败", err)
+// 	}
+
+// 	if orders.Status != models.STATUS_READY {
+// 		return errors.New("没有订单信息")
+// 	}
+
+// 	return nil
+// }
+
 // validCourse 校验课程
 func (s *CourseServ) validCourse(order *model.TaCourseOrders) (*course.CourseDetail, error) {
 	if order.CourseId == "" {
@@ -301,10 +560,10 @@ func (s *CourseServ) validBillCharges(
 }
 
 // saveCustomerPayRec 保存账户消费流水
-func (s *CourseServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *model.TaCourseOrders) error {
+func (s *CourseServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *model.TaCourseOrders, leftPay float64) error {
 	accBill := new(model.TaAccountChange)
 	accBill.AccountId = account.AccountId
-	accBill.Amount = info.ActualAmount
+	accBill.Amount = strconv.FormatFloat(leftPay, 'f', -1, 64)
 	accBill.CaseId = info.CaseId
 	accBill.ChangeSource = models.ACCSOURCE_COURSE_ORDERS
 	accBill.ChangeType = models.CONSUME_COINCHG
@@ -317,13 +576,24 @@ func (s *CourseServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *
 	return s.custDAO.InsertAccountRecords(accBill)
 }
 
-// SaveOrder 保存订单明细
-func (s *CourseServ) SaveOrder(order *model.TaCourseOrders, course *course.CourseDetail) error {
+// AddOrder 保存订单信息
+func (s *CourseServ) AddOrder(order *model.TaCourseOrders) (*model.TaCourseOrders, error) {
 	// 订单信息
-	if err := s.dao.SaveCourseOrder(order); err != nil {
+	neworder, err := s.dao.SaveCourseOrder(order)
+	if err != nil {
 		utils.LogError("课程下单失败: " + err.Error())
-		return errors.New("下单失败, 请重试")
+		return nil, errors.New("下单失败, 请重试")
 	}
+	return neworder, nil
+}
+
+// SaveOrder 保存订单明细
+func (s *CourseServ) SaveOrder(order *model.TaCourseOrders, course *course.CourseDetail) error {
+	// 订单信息
+	// if err := s.dao.SaveCourseOrder(order); err != nil {
+	// 	utils.LogError("课程下单失败: " + err.Error())
+	// 	return errors.New("下单失败, 请重试")
+	// }
 
 	// 默认城币购买
 	// courseObtaimType := models.COURSE_GETBY_COINCHG

service/vipcard/vipcard.go

@@ -127,6 +127,7 @@ func (s *VipcardServ) SaveCustomerVip(vipchild *model.TaVipCardChild, createUser
 		OrgId:          vipchild.OrgId,
 		SalesId:        vipchild.SalesId,
 		SalesName:      vipchild.SalesName,
+		PayAmount:      "0",
 	}
 	info, err := s.dao.AddCustomerVip(customerVip)
 	if err != nil {