From 11ff1c8540356cc045b71b1aa56a7fbb6aa1283c Mon Sep 17 00:00:00 2001 From: ziming Date: Fri, 6 Jun 2025 09:31:12 +0800 Subject: [PATCH] WechatQuery --- internal/server/rds_consume.go | 4 ++-- internal/service/wechat_query.go | 6 +++--- internal/service/wechat_retry.go | 6 +++--- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/internal/server/rds_consume.go b/internal/server/rds_consume.go index 9eed6ef..895f7d3 100644 --- a/internal/server/rds_consume.go +++ b/internal/server/rds_consume.go @@ -26,11 +26,11 @@ func NewRdbConsumer( ) *RdbConsumer { manager := rdsmq.NewConsumerManager() - if cf := voucherService.GetConfig(); cf != nil { + if cf := voucherService.GetWechatQueryConfig(); cf != nil { manager.Add(cf) } - if cf2 := voucherService.GetWechatConfig(); cf2 != nil { + if cf2 := voucherService.GetWechatRetryConfig(); cf2 != nil { manager.Add(cf2) } diff --git a/internal/service/wechat_query.go b/internal/service/wechat_query.go index 35a2a9f..bce2bde 100644 --- a/internal/service/wechat_query.go +++ b/internal/service/wechat_query.go @@ -7,7 +7,7 @@ import ( "voucher/internal/pkg/rdsmq" ) -func (s *VoucherService) GetConfig() *rdsmq.ConsumeConfig { +func (s *VoucherService) GetWechatQueryConfig() *rdsmq.ConsumeConfig { queue := s.bc.RdsMQ.GetWechatQuery() if queue == nil { @@ -25,12 +25,12 @@ func (s *VoucherService) GetConfig() *rdsmq.ConsumeConfig { NumWorkers: queue.NumWorkers, WaitTime: queue.GetWaitTime().AsDuration(), RetryNum: queue.RetryNum, - Fn: s.Handle, + Fn: s.WechatQueryHandle, Logger: s.logHelper, } } -func (s *VoucherService) Handle(ctx context.Context, batchNo string) error { +func (s *VoucherService) WechatQueryHandle(ctx context.Context, batchNo string) error { if batchNo == "" { s.logHelper.Errorf("wechat query error: batchNo is empty") diff --git a/internal/service/wechat_retry.go b/internal/service/wechat_retry.go index 34cc754..1ba4d76 100644 --- a/internal/service/wechat_retry.go +++ b/internal/service/wechat_retry.go @@ -7,7 +7,7 @@ import ( "voucher/internal/pkg/rdsmq" ) -func (s *VoucherService) GetWechatConfig() *rdsmq.ConsumeConfig { +func (s *VoucherService) GetWechatRetryConfig() *rdsmq.ConsumeConfig { queue := s.bc.RdsMQ.GetWechatRetry() if queue == nil { @@ -25,12 +25,12 @@ func (s *VoucherService) GetWechatConfig() *rdsmq.ConsumeConfig { NumWorkers: queue.NumWorkers, WaitTime: queue.GetWaitTime().AsDuration(), RetryNum: queue.RetryNum, - Fn: s.HandleWechat, + Fn: s.HandleWechatRetry, Logger: s.logHelper, } } -func (s *VoucherService) HandleWechat(ctx context.Context, batchNo string) error { +func (s *VoucherService) HandleWechatRetry(ctx context.Context, batchNo string) error { if batchNo == "" { s.logHelper.Errorf("RdsMQ keySend error: batchNo is empty")