接口调整

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)
 	}
 

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

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已设置。