From 514e7bb724c28fa35f495394e2db51b43acb8e01 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= <zi__mm@163.com>
Date: Thu, 13 Mar 2025 14:33:14 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/data/mixrepoimpl/cmb.go          | 6 +++---
 internal/data/wechatrepoimpl/cpn.go       | 2 +-
 internal/server/wechat_notify_consumer.go | 2 ++
 3 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/internal/data/mixrepoimpl/cmb.go b/internal/data/mixrepoimpl/cmb.go
index 6329246..2c91877 100644
--- a/internal/data/mixrepoimpl/cmb.go
+++ b/internal/data/mixrepoimpl/cmb.go
@@ -222,16 +222,16 @@ func (s *CmbMixRepoImpl) Request(ctx context.Context, req *v1.CmbRequest, uri st
 		return nil, err
 	}
 
-	log.Warnf("请求掌上生活响应结果,url=%s,bodyBytes=%s", r, string(bodyBytes))
+	log.Warnf("请求掌上生活响应结果,url:%s,bodyBytes:%s", r, string(bodyBytes))
 
 	var response *v1.CmbReply
 	if err = json.Unmarshal(bodyBytes, &response); err != nil {
-		log.Errorf("请求掌上生活返回数据解析报错,bodyBytes=%s,err=%s", string(bodyBytes), err.Error())
+		log.Errorf("请求掌上生活返回数据解析报错,err:%s", string(bodyBytes), err.Error())
 		return nil, err
 	}
 
 	if response.RespCode != vo.CmbResponseStatusSuccess.GetValue() {
-		log.Errorf("请求掌上生活返回报错,url=%s,err=%s", r, response.RespMsg)
+		log.Errorf("请求掌上生活返回报错,err:%s", r, response.RespMsg)
 		return nil, fmt.Errorf(response.RespMsg)
 	}
 
diff --git a/internal/data/wechatrepoimpl/cpn.go b/internal/data/wechatrepoimpl/cpn.go
index 41a226f..bd412a5 100644
--- a/internal/data/wechatrepoimpl/cpn.go
+++ b/internal/data/wechatrepoimpl/cpn.go
@@ -101,7 +101,7 @@ func (c *CpnRepoImpl) Query(ctx context.Context, orderWechat *bo.OrderBo) (vo.Or
 			return 0, err
 		}
 
-		log.Errorf("请求微信返回错误=%s", string(bodyBytes))
+		log.Errorf("请求微信返回错误:%s", string(bodyBytes))
 
 		if err = json.Unmarshal(bodyBytes, &ErrBody); err != nil {
 			return 0, err
diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go
index 7b7f6d5..dc94ac0 100644
--- a/internal/server/wechat_notify_consumer.go
+++ b/internal/server/wechat_notify_consumer.go
@@ -38,6 +38,8 @@ func (w *WechatNotifyConsumer) Start(ctx context.Context) error {
 		return nil
 	}
 
+	fmt.Printf("wechat notify consumer 启动中...")
+
 	// 设置HTTP协议客户端接入点，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。
 	endpoint := w.conf.WechatNotifyMQ.EndPoint
 	// 请确保环境变量ALIBABA_CLOUD_ACCESS_KEY_ID、ALIBABA_CLOUD_ACCESS_KEY_SECRET已设置。