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