voucher

2025-12-05 09:11:41 +08:00 · 2025-12-05 09:11:41 +08:00 · fb8fda6f0e
parent d64c8ea435
commit fb8fda6f0e
1 changed files with 2 additions and 0 deletions
--- a/internal/server/wechat_consumer.go
+++ b/internal/server/wechat_consumer.go
@ -150,6 +150,8 @@ func (w *WechatNotifyConsumer) processMessage(msg mq_http_sdk.ConsumeMessageEntr
 		}
 	}()

+	log.Warnf("微信回调消费接收消息成功 messageId:%s, messageTag:%s, message:%s", msg.MessageId, msg.MessageTag, msg.MessageBody)
+
 	ctx := context.Background()
 	if err := w.voucherService.WechatUseNotifyConsumer(ctx, msg.MessageTag, msg.MessageBody); err != nil {
 		//log.Errorf("微信回调消费接收消息成功,处理失败 messageId:%s, messageTag:%s, message:%s, err:%+v", msg.MessageId, msg.MessageTag, msg.MessageBody, err)