From 9e984cdb5a66693e4d8945c80e1d3ab3db41500e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Tue, 16 Sep 2025 10:22:18 +0800 Subject: [PATCH] order_notify --- internal/server/rds_consume.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/internal/server/rds_consume.go b/internal/server/rds_consume.go index 9a888f4..52e2805 100644 --- a/internal/server/rds_consume.go +++ b/internal/server/rds_consume.go @@ -34,14 +34,18 @@ func NewRdbConsumer( manager.Add(cf1) } - if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil { - manager.Add(cf2) - } + //if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil { + // manager.Add(cf2) + //} if cf3 := voucherService.GetRetryNotifyConfig(); cf3 != nil { manager.Add(cf3) } + if cf4 := voucherService.GetOrderNotifyRetryConfig(); cf4 != nil { + manager.Add(cf4) + } + return &RdbConsumer{hLog: hLog, conf: conf, manager: manager} }