hotfix

httpcli/httpcli.go

@@ -308,7 +308,7 @@ func (req *Request) send(ctx context.Context, body io.Reader, buf *bytes.Buffer)
 			req.request.Header.Add(k, v)
 		}
 	}
-	logger.Info("httpCli req", logger.Any("url", req.url), logger.Any("header", req.request.Header), logger.Any("body", buf.String()), ctxUtils.CtxTraceIDField(ctx))
+	logger.Info("[httpCli] req", logger.Any("url", req.url), logger.Any("header", req.request.Header), logger.Any("body", buf.String()), ctxUtils.CtxTraceIDField(ctx))
 	req.request.Header.Add(ctxUtils.HeaderXRequestIDKey, ctxUtils.CtxRequestID(ctx))
 	if req.timeout < 1 {
 		req.timeout = defaultTimeout
@@ -324,7 +324,7 @@ func (req *Request) send(ctx context.Context, body io.Reader, buf *bytes.Buffer)
 		err = retry.Retry(func() error {
 			response, err := client.Do(req.request)
 			if err != nil {
-				logger.Info("httpCli fail", logger.Any("err", err), ctxUtils.CtxTraceIDField(ctx))
+				logger.Info("[httpCli] fail", logger.Any("err", err), ctxUtils.CtxTraceIDField(ctx))
 				return xerror.Wrap(err, "client do")
 			}
 			if response != nil {
@@ -342,7 +342,7 @@ func (req *Request) send(ctx context.Context, body io.Reader, buf *bytes.Buffer)
 				if c, _ := ctxUtils.GetGinCtx(ctx); c != nil {
 					entity.SetCopyApiRsp(c, buf)
 				}
-				logger.Info("httpCli rsp", logger.Any("header", resp.Header), logger.Any("body", bodyBuf.String()), ctxUtils.CtxTraceIDField(ctx))
+				logger.Info("[httpCli] rsp", logger.Any("header", resp.Header), logger.Any("body", bodyBuf.String()), ctxUtils.CtxTraceIDField(ctx))
 				if body != nil {
 					resp.Body = io.NopCloser(bodyBuf)
 				}
@@ -379,7 +379,7 @@ func (req *Request) send(ctx context.Context, body io.Reader, buf *bytes.Buffer)
 				err = xerror.New(e.Error())
 			}
 			bodyBuf := bytes.NewBuffer(body)
-			logger.Info("httpCli rsp", logger.Any("header", resp.Header), logger.Any("body", bodyBuf.String()), ctxUtils.CtxTraceIDField(ctx))
+			logger.Info("[httpCli] rsp", logger.Any("header", resp.Header), logger.Any("body", bodyBuf.String()), ctxUtils.CtxTraceIDField(ctx))
 			if c, _ := ctxUtils.GetGinCtx(ctx); c != nil {
 				entity.SetCopyApiRsp(c, bodyBuf)
 			}
@@ -390,7 +390,7 @@ func (req *Request) send(ctx context.Context, body io.Reader, buf *bytes.Buffer)
 	}
 
 	if err != nil {
-		logger.Error("httpCli fail", logger.Any("err", err), ctxUtils.CtxTraceIDField(ctx))
+		logger.Error("[httpCli] fail", logger.Any("err", err), ctxUtils.CtxTraceIDField(ctx))
 	}
 
 	ctxUtils.SetApiCost(ctx, resp.Header)