From 79bb08d3d79832d81fe6b27c8023be2609e8b76f Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Thu, 20 Jun 2024 18:20:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../installment_payment/installment_payment_auto_repaid.go | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/rule/installment_payment/installment_payment_auto_repaid.go b/rule/installment_payment/installment_payment_auto_repaid.go
index 6f43919..0a2ce52 100644
--- a/rule/installment_payment/installment_payment_auto_repaid.go
+++ b/rule/installment_payment/installment_payment_auto_repaid.go
@@ -68,7 +68,7 @@ func InstallmentPaymentAutoRepaid(engine *xorm.Engine, masterId string, ch *rabb
 }
 
 // DealInstallmentPaymentAutoRepaid 处理分期付自动还款
-func DealInstallmentPaymentAutoRepaid(engine *xorm.Engine, args md.InstallmentPaymentStructForAutoRepaid, masterId string) (err error) {
+func DealInstallmentPaymentAutoRepaid(engine *xorm.Engine, ch *rabbit.Channel, args md.InstallmentPaymentStructForAutoRepaid, masterId string) (err error) {
 	now := time.Now()
 	session := engine.NewSession()
 	defer func() {
@@ -148,11 +148,6 @@ func DealInstallmentPaymentAutoRepaid(engine *xorm.Engine, args md.InstallmentPa
 		Oid:      oid,
 		Provider: "installment_payment",
 	}
-	ch, err := rabbit.Cfg.Pool.GetChannel()
-	if err != nil {
-		return nil
-	}
-	defer ch.Release()
 	err1 := ch.PublishV2(md.RelateReward, zhios_order_relate_utils.SerializeStr(rewardData), md.RelateRewardData)
 	if err1 != nil {
 		ch.PublishV2(md.RelateReward, zhios_order_relate_utils.SerializeStr(rewardData), md.RelateRewardData)