diff --git a/consume/zhios_fast_return_order_refund.go b/consume/zhios_fast_return_order_refund.go index eeabbcb..e6dc687 100644 --- a/consume/zhios_fast_return_order_refund.go +++ b/consume/zhios_fast_return_order_refund.go @@ -108,8 +108,21 @@ func handleZhiosFastReturnOrderRefund(msg []byte) error { orderData.IsWaitReduce = 2 sql := "UPDATE user_alipay_info SET money=money-? WHERE uid=?" db.QueryNativeString(eg, sql, money, orderData.Uid) + } eg.Where("ord_id=?", oid).Cols("is_wait_reduce").Update(&orderData) - + if orderData.IsWaitReduce == 2 { + args1 := map[string]string{ + "out_request_no": utils.Int64ToStr(orderData.OrdId), + "is_fulfilled": "false", + "credit_biz_order_id": orderData.FastSignId, + "remark": "", + } + if orderData.State != 4 { + args1["is_fulfilled"] = "true" + } + args1 = CommInfo(eg, mid, args1) + pay.CreditagreementOrderFinish(args1) + } return nil }