|
@@ -63,6 +63,12 @@ func GetGoodsInfoByActivity(item *models.ActivityDetail) (goodsListResp []*order
|
|
|
err = errors.New("GetCygxGoodsList, Err: " + e.Error())
|
|
|
return
|
|
|
}
|
|
|
+ //如果活动有自定义的价格就优先按照自定义的价格来
|
|
|
+ if item.ActivityPrice > 0 {
|
|
|
+ for k, _ := range goodsList {
|
|
|
+ goodsList[k].CurrentPrice = fmt.Sprint(item.ActivityPrice)
|
|
|
+ }
|
|
|
+ }
|
|
|
goodsListResp = goodsList
|
|
|
return
|
|
|
}
|
|
@@ -79,8 +85,8 @@ func GetHaverEquallyOrderByUser10Min(userId, goodsId int) (orderCode string) {
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
endTime := time.Now().Add(-10 * time.Minute)
|
|
|
- condition = ` AND order_status = 1 AND user_id = ? AND goods_id = ? AND create_time > ? ORDER BY order_id DESC `
|
|
|
- pars = append(pars, userId, goodsId, endTime)
|
|
|
+ condition = ` AND order_status = 1 AND user_id = ? AND goods_id = ? AND create_time > ? AND register_platform = ? ORDER BY order_id DESC `
|
|
|
+ pars = append(pars, userId, goodsId, endTime, utils.REGISTER_PLATFORM)
|
|
|
orderList, e := order.GetCygxOrderList(condition, pars, 0, 1)
|
|
|
if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
err = errors.New("GetCygxOrderList, Err: " + e.Error())
|
|
@@ -108,8 +114,8 @@ func GetHaverEquallyOrderByUser10MinByActivty(userId, sourceId int) (orderCode s
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
endTime := time.Now().Add(-10 * time.Minute)
|
|
|
- condition = ` AND order_status = 1 AND source = 'activity' AND user_id = ? AND source_id = ? AND create_time > ? ORDER BY order_id DESC `
|
|
|
- pars = append(pars, userId, sourceId, endTime)
|
|
|
+ condition = ` AND order_status = 1 AND source = 'activity' AND user_id = ? AND source_id = ? AND create_time > ? AND register_platform = ? ORDER BY order_id DESC `
|
|
|
+ pars = append(pars, userId, sourceId, endTime, utils.REGISTER_PLATFORM)
|
|
|
orderList, e := order.GetCygxOrderList(condition, pars, 0, 1)
|
|
|
if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
err = errors.New("GetCygxOrderList, Err: " + e.Error())
|
|
@@ -144,6 +150,11 @@ func HandleOrderHandle(itemCallback *WechatPayCallback) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ //修改过状态的不再二次处理
|
|
|
+ if orderDetail.OrderStatus == 2 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
go AddCygxOrderPayment(itemCallback) // 记录支付交易信息
|
|
|
|
|
|
if itemCallback.TradeState != "SUCCESS" { // 回调显示支付不成功,模版消息推送
|
|
@@ -152,10 +163,6 @@ func HandleOrderHandle(itemCallback *WechatPayCallback) {
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
- //修改过状态的不再二次处理
|
|
|
- if orderDetail.OrderStatus == 2 {
|
|
|
- return
|
|
|
- }
|
|
|
|
|
|
itemOrder := new(order.CygxOrder)
|
|
|
itemOrder.OrderCode = itemCallback.OutTradeNo
|
|
@@ -163,6 +170,7 @@ func HandleOrderHandle(itemCallback *WechatPayCallback) {
|
|
|
itemOrder.PayMoney = float64(float64(itemCallback.Amount.PayerTotal) / 100) // 金额分转换处理
|
|
|
itemOrder.OrderStatus = 2
|
|
|
itemOrder.OutTradeCode = itemCallback.TransactionID
|
|
|
+ itemOrder.TradeType = itemCallback.TradeType
|
|
|
|
|
|
//文章处理逻辑 OrderType int `comment:"订单类型,1:畅读卡订单,2:单场付费订单"`
|
|
|
if orderDetail.OrderType == 1 {
|
|
@@ -215,7 +223,6 @@ func HandleOrderHandle(itemCallback *WechatPayCallback) {
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
- fmt.Println(orderDetail.Source)
|
|
|
return
|
|
|
}
|
|
|
|