huangjiajun
4 months ago
1 changed files with 1 additions and 6 deletions
Unified View
Diff Options
+ 1
- 6
rule/installment_payment/installment_payment_auto_repaid.go
View File
| @@ -68,7 +68,7 @@ func InstallmentPaymentAutoRepaid(engine *xorm.Engine, masterId string, ch *rabb | |||||
| } | } | ||||
| // DealInstallmentPaymentAutoRepaid 处理分期付自动还款 | // 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() | now := time.Now() | ||||
| session := engine.NewSession() | session := engine.NewSession() | ||||
| defer func() { | defer func() { | ||||
| @@ -148,11 +148,6 @@ func DealInstallmentPaymentAutoRepaid(engine *xorm.Engine, args md.InstallmentPa | |||||
| Oid: oid, | Oid: oid, | ||||
| Provider: "installment_payment", | 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) | err1 := ch.PublishV2(md.RelateReward, zhios_order_relate_utils.SerializeStr(rewardData), md.RelateRewardData) | ||||
| if err1 != nil { | if err1 != nil { | ||||
| ch.PublishV2(md.RelateReward, zhios_order_relate_utils.SerializeStr(rewardData), md.RelateRewardData) | ch.PublishV2(md.RelateReward, zhios_order_relate_utils.SerializeStr(rewardData), md.RelateRewardData) | ||||