|
|
@@ -39,7 +39,7 @@ func (this *jyCourseOnline) PayCallBack(param *CallBackParam) bool {
|
|
|
"out_trade_no": param.OutTradeno,
|
|
|
"order_money": param.TotalFee,
|
|
|
"product_type": "线上课程",
|
|
|
- }, "id,order_status,order_money,order_code,filter_id", "")
|
|
|
+ }, "id,order_status,order_money,order_code,filter_id,user_id", "")
|
|
|
pay_time := qutil.FormatDate(&now, qutil.Date_Full_Layout)
|
|
|
if orderdata != nil {
|
|
|
order_status := qutil.IntAll((*orderdata)["order_status"])
|
|
|
@@ -54,12 +54,21 @@ func (this *jyCourseOnline) PayCallBack(param *CallBackParam) bool {
|
|
|
"order_status": 1,
|
|
|
})
|
|
|
courseId := qutil.ObjToString((*orderdata)["filter_id"])
|
|
|
- if update && courseId != "" { //更新课程销量
|
|
|
+ if update && courseId != "" {
|
|
|
+ //更新课程销量
|
|
|
util.MQFW.Update("jy_course", &map[string]interface{}{
|
|
|
"_id": qutil.StringTOBsonId(courseId),
|
|
|
}, &map[string]interface{}{
|
|
|
"$inc": bson.M{"i_tradeRate": 1},
|
|
|
}, false, false)
|
|
|
+ //取消此用户其他此课程订单
|
|
|
+ util.Mysql.Update("dataexport_order", map[string]interface{}{
|
|
|
+ "user_id": (*orderdata)["user_id"],
|
|
|
+ "filter_id": courseId,
|
|
|
+ "order_status": 0,
|
|
|
+ }, map[string]interface{}{
|
|
|
+ "order_status": -2,
|
|
|
+ })
|
|
|
}
|
|
|
} else {
|
|
|
update = true
|
