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)