Merge branch '2.1.0' of http://git.ycjcjy.com/SpaceOfCheng/services into 2.1.0

controllers/course/order.go

@@ -8,6 +8,7 @@ import (
 	"spaceofcheng/services/utils"
 )
 
+// 下单
 func (c *CourseController) PostOrder() {
 	// 订单主信息
 	info := c.GetString("info")
@@ -42,3 +43,20 @@ func (c *CourseController) PostOrder() {
 
 	c.ResponseJSON(newOrders)
 }
+
+// ConfirmOrders 确认订单
+func (c *CourseController) ConfirmOrders() {
+
+	// 订单优惠券
+	customercouponid := c.GetString("customercouponid")
+
+	// 订单id
+	ordersid := c.GetString(":ordersid")
+
+	err := c.serv.ConfirmOrders(ordersid, customercouponid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("下单成功！")
+}

controllers/goods/order.go

@@ -107,12 +107,6 @@ func (c *GoodsController) PostOrder() {
 		c.ResponseError(errors.New("无有效订单详情信息"))
 	}
 
-	// 订单优惠券
-	customercouponid := c.GetString("customercouponid")
-	if customercouponid == "undefined" {
-		customercouponid = ""
-	}
-
 	//
 	var orderInfo model.TaGoodsOrders
 	var orderDetail []model.TaGoodsOrdersDetail
@@ -140,7 +134,7 @@ func (c *GoodsController) PostOrder() {
 		)
 	}
 
-	newOrders, err := c.serv.PreOrders(&orderInfo, orderDetail, customercouponid, innerUser)
+	newOrders, err := c.serv.PreOrders(&orderInfo, orderDetail, innerUser)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -152,7 +146,12 @@ func (c *GoodsController) PostOrder() {
 func (c *GoodsController) ConfirmOrders() {
 	ordersID := c.GetString(":ordersid")
 
-	if err := c.serv.ConfirmOrder(ordersID); err != nil {
+	// 订单优惠券
+	customercouponid := c.GetString("customercouponid")
+	if customercouponid == "undefined" {
+		customercouponid = ""
+	}
+	if err := c.serv.ConfirmOrder(ordersID, customercouponid); err != nil {
 		c.ResponseError(err)
 	}
 

models/course/order.go

@@ -65,3 +65,17 @@ func (m *CourseDAO) SaveOrdersCoupon(coupon *model.TaCourseOrdersCoupon, order *
 	_, err := m.db.Insert(coupon)
 	return err
 }
+
+// UpdateOrderPay 更新订单为已支付
+func (m *CourseDAO) UpdateOrderPay(info *model.TaCourseOrders) error {
+	info.IsPay = models.BOOL_TRUE
+	info.Status = models.STATUS_NORMAL
+	var cols = []string{
+		"is_pay",
+		"status",
+		"actual_amount",
+		"coupon_amount",
+	}
+	_, err := m.db.Cols(cols...).Where("orders_id=?", info.OrdersId).Update(info)
+	return err
+}

routers/wechat.go

@@ -36,6 +36,7 @@ func getWechatRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/order/goods", &goods.GoodsController{}, "post:PostOrder"),
 		beego.NSRouter("/order/goods/:ordersid", &goods.GoodsController{}, "put:ConfirmOrders"),
 		beego.NSRouter("/order/course", &course.CourseController{}, "post:PostOrder"),
+		beego.NSRouter("/order/course/:ordersid", &course.CourseController{}, "put:ConfirmOrders"),
 
 		// 课程
 		beego.NSRouter("/course/user", &course.CourseController{}, "get:GetCustomerCourse"),

service/course/order.go

@@ -71,6 +71,11 @@ func (s *CourseServ) ConfirmOrders(ordersID, customercouponid string) error {
 	if couseOrder.Status != models.STATUS_READY {
 		return errors.New("没有订单信息")
 	}
+
+	if couseOrder.IsPay != models.BOOL_TRUE {
+		return errors.New("订单已付款，请勿重复付款！")
+	}
+
 	cust := s.ctx.Get("customer").(model.TaCustomer)
 
 	// TODO
@@ -240,10 +245,10 @@ func (s *CourseServ) ConfirmOrders(ordersID, customercouponid string) error {
 	}
 
 	// 更新订单信息
-	// 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)
@@ -579,6 +584,7 @@ func (s *CourseServ) saveCustomerPayRec(account *model.TaCustomerAccount, info *
 // AddOrder 保存订单信息
 func (s *CourseServ) AddOrder(order *model.TaCourseOrders) (*model.TaCourseOrders, error) {
 	// 订单信息
+	order.Status = models.STATUS_READY
 	neworder, err := s.dao.SaveCourseOrder(order)
 	if err != nil {
 		utils.LogError("课程下单失败: " + err.Error())
@@ -590,10 +596,10 @@ func (s *CourseServ) AddOrder(order *model.TaCourseOrders) (*model.TaCourseOrder
 // 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("下单失败, 请重试")
-	// }
+	if err := s.dao.UpdateOrderPay(order); err != nil {
+		utils.LogError("课程下单失败: " + err.Error())
+		return errors.New("下单失败, 请重试")
+	}
 
 	// 默认城币购买
 	// courseObtaimType := models.COURSE_GETBY_COINCHG

service/goods/orders.go

@@ -20,14 +20,16 @@ import (
 func (s *GoodsServ) PreOrders(
 	info *model.TaGoodsOrders,
 	details []model.TaGoodsOrdersDetail,
-	customercouponid,
-	innerUser string) (*goods.OrdersDetail, error) {
-	// org := s.ctx.Get("org").(model.SysOrg)
+	innerUser string,
+) (*model.TaGoodsOrders, error) {
 	cust := s.ctx.Get("customer").(model.TaCustomer)
 
 	info.OrdersId = guid.NewGUIDString()
 	info.MakeStatus = goods.MAKESTATUS_NOTSTARTED
 	info.UserId = cust.CustomerId
+	info.IsPay = models.BOOL_FALSE
+	info.ActualAmount = "0.0"
+	info.CouponAmount = "0.0"
 	num, err := s.dao.GetOrderNumByUserNow(info.UserId)
 	if err != nil {
 		utils.LogError("获取5秒钟内是否下单错误:", err)
@@ -57,25 +59,48 @@ func (s *GoodsServ) PreOrders(
 		// 内部人员, 可以直接购买
 		// TODO
 	} else {
-		// 客户账户
+		info.PayType = models.CONSUME_COUPON
+	}
+
+	// 保存主订单
+	if err := s.dao.SaveOrders(info); err != nil {
+		return nil, err
+	}
+
+	// 保存订单明细
+	if err := s.dao.SaveOrdersDetail(details, info.OrdersId); err != nil {
+		return nil, err
+	}
+
+	return info, nil
+}
+
+// ConfirmOrder 订单确认
+func (s *GoodsServ) ConfirmOrder(
+	ordersID, customercouponid string,
+) error {
+	info, err := s.dao.GetOrdersByID(ordersID)
+	if err != nil {
+		return utils.LogError("获取订单失败", err)
+	}
+
+	if info.Status != models.STATUS_READY {
+		return errors.New("没有订单信息")
+	}
+
+	if info.IsPay == models.BOOL_TRUE {
+		return errors.New("订单已付款，请勿重复付款！")
+	}
+
+	if info.PayType == "sales" {
+		// 内部人员, 可以直接购买
+		// TODO
+	} else {
+		// 普通客户
 		account, err := s.custDAO.GetAccountByCust(info.UserId)
 		if err != nil {
 			utils.LogError("查询用户账户信息出错: " + err.Error())
-			return nil, errors.New("查询用户账户信息出错")
-		}
-
-		// 客户 VIP 卡
-		var vipAccount float64 = 0.0
-		vips, err := s.custDAO.GetValidVIPCards(info.UserId)
-		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
-			}
+			return errors.New("查询用户账户信息出错")
 		}
 
 		// 如果是使用优惠券
@@ -86,44 +111,43 @@ func (s *GoodsServ) PreOrders(
 			customerCoupon, err := s.couponDAO.GetCustomerCouponByID(customercouponid)
 			if err != nil {
 				utils.LogError("查询优惠券信息失败: " + err.Error())
-				return nil, errors.New("查询优惠券信息失败")
+				return errors.New("查询优惠券信息失败")
 			}
 			if customerCoupon == nil || customerCoupon.CustomerCouponId == "" {
-				return nil, errors.New("优惠券无效！")
+				return errors.New("优惠券无效！")
 			}
 
 			if customerCoupon.CaseId != info.CaseId {
-				return nil, errors.New("优惠券对应案场与下单案场不一致，不允许下单！")
+				return errors.New("优惠券对应案场与下单案场不一致，不允许下单！")
 			}
 
 			if customerCoupon.Status != models.STATUS_NORMAL || !customerCoupon.UseDate.IsZero() {
-				return nil, errors.New("优惠券已被使用！请重新选择优惠券！")
+				return errors.New("优惠券已被使用！请重新选择优惠券！")
 			}
 
 			if customerCoupon.StartDate.After(time.Now().Local()) {
-				return nil, errors.New("该优惠券还未到有效期，不允许下单！")
+				return errors.New("该优惠券还未到有效期，不允许下单！")
 			}
 			if customerCoupon.EndDate.Before(time.Now().Local()) {
-				return nil, errors.New("优惠券已失效，不允许下单！")
+				return errors.New("优惠券已失效，不允许下单！")
 			}
-
 			// 根据id获取优惠券信息
 			coupon, err := s.couponDAO.GetCouponInfoByCustomerCouponID(customercouponid)
 			if err != nil {
 				utils.LogError("查询优惠券信息失败: " + err.Error())
-				return nil, errors.New("查询优惠券信息失败")
+				return errors.New("查询优惠券信息失败")
 			}
 			// 遍历优惠券可抵用的商品
 			var dyGoods = model.TaGoodsOrdersDetail{
 				Price:   "0.0",
 				GoodsId: "",
 			}
-			for _, detail := range details {
-				if coupon.IsAll == models.BOOL_TRUE {
+			for _, detail := range info.Goods {
+				if coupon.IsAll == 1 {
 					dyprice, _ := strconv.ParseFloat(dyGoods.Price, 64)
 					detailprice, _ := strconv.ParseFloat(detail.Price, 64)
 					if dyprice < detailprice {
-						dyGoods = detail
+						dyGoods = detail.TaGoodsOrdersDetail
 					}
 				} else {
 					for _, target := range coupon.Targets {
@@ -131,7 +155,7 @@ func (s *GoodsServ) PreOrders(
 							dyprice, _ := strconv.ParseFloat(dyGoods.Price, 64)
 							detailprice, _ := strconv.ParseFloat(detail.Price, 64)
 							if dyprice < detailprice {
-								dyGoods = detail
+								dyGoods = detail.TaGoodsOrdersDetail
 							}
 						}
 					}
@@ -150,14 +174,21 @@ func (s *GoodsServ) PreOrders(
 					UsedAmount:       dyGoods.Price,
 					CustomerCouponId: customerCoupon.CustomerCouponId,
 				}
-				if err := s.dao.SaveOrdersCoupon(&ordersCoupon, info); err != nil {
+				if err := s.dao.SaveOrdersCoupon(&ordersCoupon, &info.TaGoodsOrders); err != nil {
 					utils.LogError("保存优惠信息出错: " + err.Error())
-					return nil, errors.New("保存优惠信息出错")
+					return errors.New("保存优惠信息出错")
 				}
 				info.CouponAmount = dyGoods.Price
 				// info.ActualAmount = "0.0"
+
+				// 优惠券核销
+				err := s.couponDAO.VerifyCustomerCoupon(customercouponid)
+				if err != nil {
+					utils.LogError("优惠券核销出错: " + err.Error())
+					return errors.New("优惠券核销出错")
+				}
 			} else {
-				return nil, errors.New("优惠券不可抵用商品")
+				return errors.New("优惠券不可抵用商品")
 			}
 		} else {
 			// 如果是使用城币
@@ -170,97 +201,10 @@ func (s *GoodsServ) PreOrders(
 		payMoney, _ := strconv.ParseFloat(info.Amount, 64)
 		payMoney = payMoney - couponAmount
 
-		if accMoney+vipAccount < payMoney {
-			return nil, errors.New("账户余额不足")
-		}
-
-		info.ActualAmount = strconv.FormatFloat(payMoney, 'f', -1, 64)
-		if payMoney > 0 && couponAmount > 0 && info.PayType != models.CONSUME_INNER {
-			info.PayType = models.CONSUME_COUPON_COIN
-		}
-	}
-
-	// 保存主订单
-	if err := s.dao.SaveOrders(info); err != nil {
-		return nil, err
-	}
-
-	// 保存订单明细
-	if err := s.dao.SaveOrdersDetail(details, info.OrdersId); err != nil {
-		return nil, err
-	}
-
-	newOrders, err := s.dao.GetOrdersDetailByID(info.OrdersId, models.STATUS_READY)
-	if err != nil {
-		return nil, utils.LogError("下单失败, 请重试", err.Error())
-	}
-
-	return newOrders, nil
-}
-
-// ConfirmOrder 订单确认
-// 1、订单状态修改为有效
-// 2、订单修改为支付状态
-// 3、卡券核销
-// 4、账户或者 VIP 卡扣钱
-func (s *GoodsServ) ConfirmOrder(ordersID string) error {
-	orders, err := s.dao.GetOrdersByID(ordersID)
-	if err != nil {
-		return utils.LogError("获取订单失败", err)
-	}
-
-	if orders.Status != models.STATUS_READY {
-		return errors.New("没有订单信息")
-	}
-
-	// 如果是内部人员
-	if orders.PayType == models.CONSUME_INNER {
-		// 查找禁用名单
-		fibUsers, err := s.userDAO.GetForbidUserByUserID(orders.UserId)
-		if err != nil {
-			return utils.LogError("校验下单人出错", err)
-		}
-
-		if fibUsers != nil && len(fibUsers) > 0 {
-			for _, u := range fibUsers {
-				if u.ForbidType == models.FORBID_ORDER && u.Status == models.STATUS_NORMAL {
-					return errors.New("当前下单人被禁止点单")
-				}
-			}
-		}
-	} else {
-		// 如果不是内部人员
-
-		// 如果使用了优惠券
-		coupons, err := s.dao.GetCouponByOrdersID(ordersID)
-		if err != nil {
-			return utils.LogError("校验订单优惠券失败", err)
-		}
-		if coupons != nil && len(coupons) > 0 {
-			for _, cp := range coupons {
-				if cp.Status != models.STATUS_NORMAL {
-					return errors.New("订单优惠券已经被使用, 请重新选择优惠券")
-				}
-
-				// 优惠券核销
-				err := s.couponDAO.VerifyCustomerCoupon(cp.CouponId)
-				if err != nil {
-					return utils.LogError("优惠券核销出错", err)
-				}
-
-				// 优惠券使用数量 + 1
-				if err := s.couponDAO.IncreseCouponUsedNum(cp.CouponId); err != nil {
-					return utils.LogError("更新优惠券使用出错", err)
-				}
-			}
-		}
-
-		// 如果使用了城币
-		actualPay, _ := strconv.ParseFloat(orders.ActualAmount, 64)
-		if actualPay > 0.01 {
-			var leftPay = actualPay
-
-			vips, err := s.custDAO.GetValidVIPCards(orders.UserId)
+		// 如果是城币, 则插入用户账户消费记录
+		if payMoney > 0 {
+			var leftPay = payMoney
+			vips, err := s.custDAO.GetValidVIPCards(info.UserId)
 			if err != nil {
 				return utils.LogError("查询用户 VIP卡 出错", err)
 			}
@@ -284,7 +228,7 @@ func (s *GoodsServ) ConfirmOrder(ordersID string) error {
 						leftPay -= vipMoney
 					}
 
-					if err := s.saveVipChangeRec(vipPay, &vip, &orders.TaGoodsOrders); err != nil {
+					if err := s.saveVipChangeRec(vipPay, &vip, &info.TaGoodsOrders); err != nil {
 						return utils.LogError("VIP卡扣款失败", err.Error())
 					}
 
@@ -293,50 +237,391 @@ func (s *GoodsServ) ConfirmOrder(ordersID string) error {
 					}
 				}
 			}
-
 			// 如果 VIP 卡余额不足, 则使用账户余额
 			if leftPay > 0.01 {
-				account, err := s.custDAO.GetAccountByCust(orders.UserId)
-				if err != nil {
-					return utils.LogError("查询用户账户信息出错", err)
-				}
-
-				accMoney, _ := strconv.ParseFloat(account.Amount, 64)
-				if accMoney < actualPay {
-					return errors.New("下单错误, 用户账户余额不足")
+				if leftPay > accMoney {
+					return errors.New("账户余额不足")
 				}
 
-				if err := s.saveCustomerPayRec(leftPay, account, &orders.TaGoodsOrders); err != nil {
-					return err
+				// 插入账户流水
+				if err := s.saveCustomerPayRec(leftPay, account, &info.TaGoodsOrders); err != nil {
+					utils.LogError("插入账户流水出错: " + err.Error())
+					return errors.New("写入账户流水出错")
 				}
 			}
 		}
-
-		// 不去校验商品及库存
-		// 因为暂时没有库存的概念
 	}
 
-	// 更新订单状态
-	orders.Status = models.STATUS_NORMAL
+	// 更新订单
+	orders := info.TaGoodsOrders
 	orders.IsPay = models.BOOL_TRUE
-	if err := s.dao.UpdateOrders(&orders.TaGoodsOrders, []string{"status", "is_pay"}); err != nil {
-		return utils.LogError("下单失败, 更新状态出错", err)
+	orders.Status = models.STATUS_NORMAL
+	if err := s.dao.UpdateOrders(&orders, []string{
+		"status", "is_pay", "coupon_amount", "actual_amount",
+	}); err != nil {
+		return nil
 	}
 
+	// 保存主订单
+	// if err := s.dao.SaveOrders(info); err != nil {
+	// 	return err
+	// }
+
+	// // 保存订单明细
+	// if err := s.dao.SaveOrdersDetail(details, info.OrdersId); err != nil {
+	// 	return err
+	// }
+
 	// 通知后端有新订单 - websocket
+	// orderList, err := s.GetOnLineOrders(info.CaseId, false)
+	// if err != nil {
+	// 	utils.LogError("获取新单列表出错: " + err.Error())
+	// 	return nil
+	// }
+	newOrder, err := s.GetNewGoods(info.OrdersId)
+	if err != nil {
+		// 下单流程已经结束, 不反馈错误
+		utils.LogError("获取数据失败：", err.Error())
+		return nil
+	}
+
 	msg := utils.Message{
 		To: utils.ClientID{
-			Groups: []string{orders.CaseId},
+			Groups: []string{info.CaseId},
 		},
 		Data: map[string][]interface{}{
-			"refreshOnlineGoodsOrders": []interface{}{*orders},
+			"refreshOnlineGoodsOrders": []interface{}{*newOrder},
 		},
 	}
 
+	utils.LogError("调用下单 Websocket ")
+
 	utils.SendMessage(msg, utils.WsMessage)
+
 	return nil
 }
 
+// // PreOrders 预下单
+// func (s *GoodsServ) PreOrders(
+// 	info *model.TaGoodsOrders,
+// 	details []model.TaGoodsOrdersDetail,
+// 	customercouponid,
+// 	innerUser string) (*goods.OrdersDetail, error) {
+// 	// org := s.ctx.Get("org").(model.SysOrg)
+// 	cust := s.ctx.Get("customer").(model.TaCustomer)
+
+// 	info.OrdersId = guid.NewGUIDString()
+// 	info.MakeStatus = goods.MAKESTATUS_NOTSTARTED
+// 	info.UserId = cust.CustomerId
+// 	num, err := s.dao.GetOrderNumByUserNow(info.UserId)
+// 	if err != nil {
+// 		utils.LogError("获取5秒钟内是否下单错误:", err)
+// 		return nil, errors.New("获取5秒钟内是否下单错误")
+// 	}
+// 	if num > 0 {
+// 		return nil, errors.New("5 秒内不能频繁下单")
+// 	}
+
+// 	// 校验下单内容
+// 	if err := s.validOrdersInfo(info); err != nil {
+// 		return nil, err
+// 	}
+
+// 	// 校验案场信息
+// 	if err := s.validOrdersCase(info, cust); err != nil {
+// 		return nil, err
+// 	}
+
+// 	// 校验各种金额
+// 	if err := s.validBillCharges(info, details); err != nil {
+// 		return nil, err
+// 	}
+
+// 	if innerUser == "sales" {
+// 		info.PayType = models.CONSUME_INNER
+// 		// 内部人员, 可以直接购买
+// 		// TODO
+// 	} else {
+// 		// 客户账户
+// 		account, err := s.custDAO.GetAccountByCust(info.UserId)
+// 		if err != nil {
+// 			utils.LogError("查询用户账户信息出错: " + err.Error())
+// 			return nil, errors.New("查询用户账户信息出错")
+// 		}
+
+// 		// 客户 VIP 卡
+// 		var vipAccount float64 = 0.0
+// 		vips, err := s.custDAO.GetValidVIPCards(info.UserId)
+// 		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
+// 			}
+// 		}
+
+// 		// 如果是使用优惠券
+// 		if customercouponid != "" {
+// 			info.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 != info.CaseId {
+// 				return nil, errors.New("优惠券对应案场与下单案场不一致，不允许下单！")
+// 			}
+
+// 			if customerCoupon.Status != models.STATUS_NORMAL || !customerCoupon.UseDate.IsZero() {
+// 				return nil, errors.New("优惠券已被使用！请重新选择优惠券！")
+// 			}
+
+// 			if customerCoupon.StartDate.After(time.Now().Local()) {
+// 				return nil, errors.New("该优惠券还未到有效期，不允许下单！")
+// 			}
+// 			if customerCoupon.EndDate.Before(time.Now().Local()) {
+// 				return nil, errors.New("优惠券已失效，不允许下单！")
+// 			}
+
+// 			// 根据id获取优惠券信息
+// 			coupon, err := s.couponDAO.GetCouponInfoByCustomerCouponID(customercouponid)
+// 			if err != nil {
+// 				utils.LogError("查询优惠券信息失败: " + err.Error())
+// 				return nil, errors.New("查询优惠券信息失败")
+// 			}
+// 			// 遍历优惠券可抵用的商品
+// 			var dyGoods = model.TaGoodsOrdersDetail{
+// 				Price:   "0.0",
+// 				GoodsId: "",
+// 			}
+// 			for _, detail := range details {
+// 				if coupon.IsAll == models.BOOL_TRUE {
+// 					dyprice, _ := strconv.ParseFloat(dyGoods.Price, 64)
+// 					detailprice, _ := strconv.ParseFloat(detail.Price, 64)
+// 					if dyprice < detailprice {
+// 						dyGoods = detail
+// 					}
+// 				} else {
+// 					for _, target := range coupon.Targets {
+// 						if target.TargetId == detail.GoodsId {
+// 							dyprice, _ := strconv.ParseFloat(dyGoods.Price, 64)
+// 							detailprice, _ := strconv.ParseFloat(detail.Price, 64)
+// 							if dyprice < detailprice {
+// 								dyGoods = detail
+// 							}
+// 						}
+// 					}
+// 				}
+// 			}
+// 			if dyGoods.GoodsId != "" {
+// 				// 优惠券可以抵用商品
+// 				var ordersCoupon = model.TaGoodsOrdersCoupon{
+// 					OrdersId:         info.OrdersId,
+// 					OrdersNo:         info.OrdersNo,
+// 					CouponId:         coupon.CouponId,
+// 					CouponName:       coupon.CouponName,
+// 					OrgId:            coupon.OrgId,
+// 					GoodsId:          dyGoods.GoodsId,
+// 					GoodsName:        dyGoods.GoodsName,
+// 					UsedAmount:       dyGoods.Price,
+// 					CustomerCouponId: customerCoupon.CustomerCouponId,
+// 				}
+// 				if err := s.dao.SaveOrdersCoupon(&ordersCoupon, info); err != nil {
+// 					utils.LogError("保存优惠信息出错: " + err.Error())
+// 					return nil, errors.New("保存优惠信息出错")
+// 				}
+// 				info.CouponAmount = dyGoods.Price
+// 				// info.ActualAmount = "0.0"
+// 			} else {
+// 				return nil, errors.New("优惠券不可抵用商品")
+// 			}
+// 		} else {
+// 			// 如果是使用城币
+// 			info.PayType = models.CONSUME_COINCHG
+// 			info.CouponAmount = "0.0"
+// 		}
+
+// 		accMoney, _ := strconv.ParseFloat(account.Amount, 64)
+// 		couponAmount, _ := strconv.ParseFloat(info.CouponAmount, 64)
+// 		payMoney, _ := strconv.ParseFloat(info.Amount, 64)
+// 		payMoney = payMoney - couponAmount
+
+// 		if accMoney+vipAccount < payMoney {
+// 			return nil, errors.New("账户余额不足")
+// 		}
+
+// 		info.ActualAmount = strconv.FormatFloat(payMoney, 'f', -1, 64)
+// 		if payMoney > 0 && couponAmount > 0 && info.PayType != models.CONSUME_INNER {
+// 			info.PayType = models.CONSUME_COUPON_COIN
+// 		}
+// 	}
+
+// 	// 保存主订单
+// 	if err := s.dao.SaveOrders(info); err != nil {
+// 		return nil, err
+// 	}
+
+// 	// 保存订单明细
+// 	if err := s.dao.SaveOrdersDetail(details, info.OrdersId); err != nil {
+// 		return nil, err
+// 	}
+
+// 	newOrders, err := s.dao.GetOrdersDetailByID(info.OrdersId, models.STATUS_READY)
+// 	if err != nil {
+// 		return nil, utils.LogError("下单失败, 请重试", err.Error())
+// 	}
+
+// 	return newOrders, nil
+// }
+
+// // ConfirmOrder 订单确认
+// // 1、订单状态修改为有效
+// // 2、订单修改为支付状态
+// // 3、卡券核销
+// // 4、账户或者 VIP 卡扣钱
+// func (s *GoodsServ) ConfirmOrder(ordersID string) error {
+// 	orders, err := s.dao.GetOrdersByID(ordersID)
+// 	if err != nil {
+// 		return utils.LogError("获取订单失败", err)
+// 	}
+
+// 	if orders.Status != models.STATUS_READY {
+// 		return errors.New("没有订单信息")
+// 	}
+
+// 	// 如果是内部人员
+// 	if orders.PayType == models.CONSUME_INNER {
+// 		// 查找禁用名单
+// 		fibUsers, err := s.userDAO.GetForbidUserByUserID(orders.UserId)
+// 		if err != nil {
+// 			return utils.LogError("校验下单人出错", err)
+// 		}
+
+// 		if fibUsers != nil && len(fibUsers) > 0 {
+// 			for _, u := range fibUsers {
+// 				if u.ForbidType == models.FORBID_ORDER && u.Status == models.STATUS_NORMAL {
+// 					return errors.New("当前下单人被禁止点单")
+// 				}
+// 			}
+// 		}
+// 	} else {
+// 		// 如果不是内部人员
+
+// 		// 如果使用了优惠券
+// 		coupons, err := s.dao.GetCouponByOrdersID(ordersID)
+// 		if err != nil {
+// 			return utils.LogError("校验订单优惠券失败", err)
+// 		}
+// 		if coupons != nil && len(coupons) > 0 {
+// 			for _, cp := range coupons {
+// 				if cp.Status != models.STATUS_NORMAL {
+// 					return errors.New("订单优惠券已经被使用, 请重新选择优惠券")
+// 				}
+
+// 				// 优惠券核销
+// 				err := s.couponDAO.VerifyCustomerCoupon(cp.CouponId)
+// 				if err != nil {
+// 					return utils.LogError("优惠券核销出错", err)
+// 				}
+
+// 				// 优惠券使用数量 + 1
+// 				if err := s.couponDAO.IncreseCouponUsedNum(cp.CouponId); err != nil {
+// 					return utils.LogError("更新优惠券使用出错", err)
+// 				}
+// 			}
+// 		}
+
+// 		// 如果使用了城币
+// 		actualPay, _ := strconv.ParseFloat(orders.ActualAmount, 64)
+// 		if actualPay > 0.01 {
+// 			var leftPay = actualPay
+
+// 			vips, err := s.custDAO.GetValidVIPCards(orders.UserId)
+// 			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, &orders.TaGoodsOrders); err != nil {
+// 						return utils.LogError("VIP卡扣款失败", err.Error())
+// 					}
+
+// 					if leftPay < 0.01 {
+// 						break
+// 					}
+// 				}
+// 			}
+
+// 			// 如果 VIP 卡余额不足, 则使用账户余额
+// 			if leftPay > 0.01 {
+// 				account, err := s.custDAO.GetAccountByCust(orders.UserId)
+// 				if err != nil {
+// 					return utils.LogError("查询用户账户信息出错", err)
+// 				}
+
+// 				accMoney, _ := strconv.ParseFloat(account.Amount, 64)
+// 				if accMoney < actualPay {
+// 					return errors.New("下单错误, 用户账户余额不足")
+// 				}
+
+// 				if err := s.saveCustomerPayRec(leftPay, account, &orders.TaGoodsOrders); err != nil {
+// 					return err
+// 				}
+// 			}
+// 		}
+
+// 		// 不去校验商品及库存
+// 		// 因为暂时没有库存的概念
+// 	}
+
+// 	// 更新订单状态
+// 	orders.Status = models.STATUS_NORMAL
+// 	orders.IsPay = models.BOOL_TRUE
+// 	if err := s.dao.UpdateOrders(&orders.TaGoodsOrders, []string{"status", "is_pay"}); err != nil {
+// 		return utils.LogError("下单失败, 更新状态出错", err)
+// 	}
+
+// 	// 通知后端有新订单 - websocket
+// 	msg := utils.Message{
+// 		To: utils.ClientID{
+// 			Groups: []string{orders.CaseId},
+// 		},
+// 		Data: map[string][]interface{}{
+// 			"refreshOnlineGoodsOrders": []interface{}{*orders},
+// 		},
+// 	}
+
+// 	utils.SendMessage(msg, utils.WsMessage)
+// 	return nil
+// }
+
 // saveCustomerPayRec 保存账户消费流水
 func (s *GoodsServ) saveCustomerPayRec(payMoney float64, account *model.TaCustomerAccount, info *model.TaGoodsOrders) error {
 	actAmount := strconv.FormatFloat(payMoney, 'f', -1, 64)

service/vipcard/vipcard.go

@@ -143,7 +143,7 @@ func (s *VipcardServ) SaveCustomerVip(vipchild *model.TaVipCardChild, createUser
 		ChangeType:    models.CONSUME_COINCHG,
 		ChangeSource:  models.ACCSOURCE_RECHARGE,
 		SourceId:      vipchild.VipCardChildId,
-		SourceName:    vipchild.VipCardChildCode,
+		SourceName:    "充值",
 		Amount:        info.Amount,
 		FloatType:     models.ACCOUNT_INCOME,
 		CreateUser:    createUser.UserId,