lakala

repository/pay/pay.go

@@ -788,7 +788,7 @@ func selectRefundBill(tx *sql.Tx, input *models.RefundParamInput) (string, strin
 	var platform_type uint8
 	var source_code uint8
 	var notice_request interface{}
-	var notice_response interface{}
+	var notice_response []byte
 	var notice_request2 []byte
 	//notice_request2 = []byte(`abc`)
 	//payment_order_code, paymoney
@@ -810,7 +810,11 @@ func selectRefundBill(tx *sql.Tx, input *models.RefundParamInput) (string, strin
 		}
 	} else if source_code==9 {
 		//聚合被扫
-		notice_request = notice_response
+		notice_request = make(map[string]interface{}, 0)
+		if err := json.Unmarshal(notice_response, &notice_request); err != nil {
+			return "", "", 0, 0, "", "", err
+		}
+		//notice_request = notice_response
 	} else {
 		//聚合收银台
 		notice_request = new(models.CashierNoticeInput)
@@ -853,14 +857,14 @@ func selectRefundBill(tx *sql.Tx, input *models.RefundParamInput) (string, strin
 		}
 	} else if source_code==9 {
 		//聚合被扫
-		//resp_data := notice_request.(map[string]interface{})["resp_data"]
-		//fmt.Println("resp_data返回值:", resp_data)
-		//if resp_data == nil {
-		//	return "", "", 0, 0, "", "", errors.New("数据错误:resp_data返回值为空")
-		//}
-		//log_no = resp_data.(map[string]interface{})["log_no"].(string) //拉卡拉对账单流水号
-		log_no = "66210310187398"
-		//fmt.Println("log_no返回值:", log_no)
+		resp_data := notice_request.(map[string]interface{})["resp_data"]
+		fmt.Println("resp_data返回值:", resp_data)
+		if resp_data == nil {
+			return "", "", 0, 0, "", "", errors.New("数据错误:resp_data返回值为空")
+		}
+		log_no = resp_data.(map[string]interface{})["log_no"].(string) //拉卡拉对账单流水号
+		//log_no = "66210310187398"
+		fmt.Println("log_no返回值:", log_no)
 		if log_no == "" {
 			return "", "", 0, 0, "", "", errors.New("数据错误:拉卡拉对账单流水号为空")
 		}