lakala

repository/pay/pay.go

@@ -60,6 +60,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 
 	billID, err := InsertPayBill(tx, input, orderID)
 	if err != nil {
+		tx.Rollback()
 		return nil, err
 	}
 
@@ -214,6 +215,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 	} else if input.SourceCode==9 {
 		//聚合被扫(扫码枪)
 		if input.DynamicID=="" {
+			tx.Rollback()
 			return nil, errors.New("输入项「dynamic_id」为空错误")
 		}
 
@@ -240,6 +242,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 		data["req_data"] = data2
 
 	} else {
+		tx.Rollback()
 		return nil, errors.New("输入参数「source_code」错误，有效值为[1-6,9,15-17]")
 	}
 	//数据重组 - end
@@ -251,6 +254,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 	// 插入下单请求参数
 	err = InsertPayBillDetailRequestBody(tx, billID, data)
 	if err != nil {
+		tx.Rollback()
 		return nil, err
 	}
 
@@ -258,6 +262,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 	if err != nil {
 		//this.Data["json"] = utils.CheckError(errors.New("Map转化为byte数组失败"),"异常")
 		//this.ServeJSON()
+		tx.Rollback()
 		return nil, err
 	}
 
@@ -277,6 +282,7 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 	err, response, lakala_rtn := lakala_post(input, url, orderID, data_json)
 	if err != nil {
 		InsertPayBillDetailResponseBody(tx, billID, lakala_rtn) //todo
+		tx.Rollback()
 		return nil, err
 	}
 
@@ -284,9 +290,11 @@ func UnifiedOrder(input *models.PlaceAnOrderParamInput, ip string) (interface{},
 	err = InsertPayBillDetailResponseBody(tx, billID, lakala_rtn)
 	if err != nil {
 		//beego.Error("下单请求成功 --- 但插入成功后的参数失败")
+		tx.Rollback()
 		return nil, err
 	}
 
+	tx.Commit()
 	return response, nil
 }