回调通知

internal/server/wechat_notify_consumer.go

@@ -80,10 +80,11 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
 					var handles []string
 					for _, v := range resp.Messages {
 						handles = append(handles, v.ReceiptHandle)
+
 						log.Warnf("微信回调消费接收消息成功 messageTag:%s, message: %s", v.MessageTag, v.MessageBody)
 
 						if err := w.voucherService.WechatUseNotifyConsumer(ctx, v.MessageTag, v.MessageBody); err != nil {
-							log.Errorf("微信回调消费处理失败err:%+v", err)
+							log.Errorf("微信回调消费处理失败:%+v", err)
 						}
 					}
 
@@ -128,7 +129,7 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m
 		// 长轮询消费消息，网络超时时间默认为35s。
 		// 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。
 		mqConsumer.ConsumeMessage(respChan, errChan,
-			3,  // 一次最多消费3条（最多可设置为16条）。
+			1,  // 一次最多消费3条（最多可设置为16条）。
 			10, // 长轮询时间3s（最多可设置为30s）。
 		)
 		<-endChan