log Async

upstream/dwd/dwd.go

@@ -69,7 +69,8 @@ type CommonRes struct {
 
 func post(ctx context.Context, method string, req interface{}) (res *CommonRes, err error) {
 
-	Start := gtime.TimestampMilli()
+	//Start := gtime.TimestampMilli()
+	g.Log().Ctx(ctx).Info(gtime.Now().String())
 	AccessToken, err := Token.Access(ctx)
 	if err != nil {
 		return
@@ -93,9 +94,11 @@ func post(ctx context.Context, method string, req interface{}) (res *CommonRes,
 		ctx = context.WithValue(ctx, "Method", "POST")
 		ctx = context.WithValue(ctx, "URI", method)
 		if err != nil {
-			g.Log().Async(true).Ctx(ctx).Cat(PkgName).Cat("error").Infof("参数【%v】错误【%v】响应时间【%v】", request.MustToJsonString(), err.Error(), gtime.TimestampMilli()-Start)
+			g.Log().Ctx(ctx).Info(gtime.Now().String())
+			//g.Log().Async(true).Ctx(ctx).Cat(PkgName).Cat("error").Infof("参数【%v】错误【%v】响应时间【%v】", request.MustToJsonString(), err.Error(), gtime.TimestampMilli()-Start)
 		} else {
-			g.Log().Async(true).Ctx(ctx).Cat(PkgName).Infof("参数【%v】响应【%v】响应时间【%v】", request.MustToJsonString(), str, gtime.TimestampMilli()-Start)
+			g.Log().Ctx(ctx).Info(gtime.Now().String())
+			//g.Log().Async(true).Ctx(ctx).Cat(PkgName).Infof("参数【%v】响应【%v】响应时间【%v】", request.MustToJsonString(), str, gtime.TimestampMilli()-Start)
 		}
 	}()
 	str = resp.ReadAllString()