From ab40cf6a20ba0f8c34212c9df1a76558d79d40b9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Tue, 6 Sep 2022 10:04:08 +0800 Subject: [PATCH] - update --- api_gorm.go | 35 ++++++++++++++++++++--------------- api_mongo.go | 29 +++++++++++++++-------------- gin_gorm.go | 47 ++++++++++++++++++++++++++--------------------- gin_mongo.go | 29 +++++++++++++++-------------- 4 files changed, 76 insertions(+), 64 deletions(-) diff --git a/api_gorm.go b/api_gorm.go index 7d07d64..29acf2f 100644 --- a/api_gorm.go +++ b/api_gorm.go @@ -68,7 +68,9 @@ func NewApiGormClient(config *ApiGormClientConfig) (*ApiClient, error) { // 创建模型 func (c *ApiClient) gormAutoMigrate() (err error) { err = c.gormClient.Db.Table(c.gormConfig.tableName).AutoMigrate(&apiPostgresqlLog{}) - c.zapLog.WithLogger().Sugar().Info(err) + if err != nil { + c.zapLog.WithLogger().Sugar().Infof("[golog.api.gormAutoMigrate]：%s", err) + } return } @@ -96,21 +98,24 @@ type apiPostgresqlLog struct { } // 记录日志 -func (c *ApiClient) gormRecord(ctx context.Context, postgresqlLog apiPostgresqlLog) error { +func (c *ApiClient) gormRecord(ctx context.Context, postgresqlLog apiPostgresqlLog) (err error) { if utf8.ValidString(string(postgresqlLog.ResponseBody)) == false { postgresqlLog.ResponseBody = datatypes.JSON("") } postgresqlLog.SystemHostName = c.gormConfig.hostname - if postgresqlLog.SystemInsideIp == "" { - postgresqlLog.SystemInsideIp = c.gormConfig.insideIp - } + postgresqlLog.SystemInsideIp = c.gormConfig.insideIp postgresqlLog.GoVersion = c.gormConfig.goVersion postgresqlLog.TraceId = gotrace_id.GetTraceIdContext(ctx) - return c.gormClient.Db.Table(c.gormConfig.tableName).Create(&postgresqlLog).Error + err = c.gormClient.Db.Table(c.gormConfig.tableName).Create(&postgresqlLog).Error + if err != nil { + c.zapLog.WithLogger().Sugar().Errorf("[golog.api.gormRecord]：%s", err) + } + + return } // GormQuery 查询 @@ -135,18 +140,18 @@ func (c *ApiClient) GormMiddleware(ctx context.Context, request gorequest.Respon SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.HeaderIsImg() { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddleware]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddleware.isimg]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.JsonEncodeNoError(request.ResponseBody)) > 0 { data.ResponseBody = request.ResponseBody //【返回】数据 data.ResponseContent = dorm.JsonEncodeNoError(request.ResponseBody) //【返回】数据 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddleware]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddleware.len]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.gormRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.GormMiddleware]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.GormMiddleware]：%s\n", err.Error()) } } @@ -167,17 +172,17 @@ func (c *ApiClient) GormMiddlewareXml(ctx context.Context, request gorequest.Res SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.HeaderIsImg() { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddlewareXml]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddlewareXml.isimg]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.JsonEncodeNoError(request.ResponseBody)) > 0 { data.ResponseContent = dorm.JsonEncodeNoError(request.ResponseBody) //【返回】内容 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddlewareXml]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddlewareXml.len]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.gormRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.GormMiddlewareXml]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.GormMiddlewareXml]：%s\n", err.Error()) } } @@ -198,17 +203,17 @@ func (c *ApiClient) GormMiddlewareCustom(ctx context.Context, api string, reques SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.HeaderIsImg() { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddlewareCustom]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddlewareCustom.isimg]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.JsonEncodeNoError(request.ResponseBody)) > 0 { data.ResponseBody = request.ResponseBody //【返回】数据 data.ResponseContent = dorm.JsonEncodeNoError(request.ResponseBody) //【返回】数据 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.GormMiddlewareCustom]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.GormMiddlewareCustom.len]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.gormRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.GormMiddlewareCustom]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.GormMiddlewareCustom]：%s\n", err.Error()) } } diff --git a/api_mongo.go b/api_mongo.go index 0fac13c..0a8e22b 100644 --- a/api_mongo.go +++ b/api_mongo.go @@ -142,19 +142,20 @@ type apiMongolLog struct { } // 记录日志 -func (c *ApiClient) mongoRecord(ctx context.Context, mongoLog apiMongolLog) error { +func (c *ApiClient) mongoRecord(ctx context.Context, mongoLog apiMongolLog) (err error) { mongoLog.SystemHostName = c.mongoConfig.hostname - if mongoLog.SystemInsideIp == "" { - mongoLog.SystemInsideIp = c.mongoConfig.insideIp - } + mongoLog.SystemInsideIp = c.mongoConfig.insideIp mongoLog.GoVersion = c.mongoConfig.goVersion mongoLog.TraceId = gotrace_id.GetTraceIdContext(ctx) mongoLog.LogId = primitive.NewObjectID() - _, err := c.mongoClient.Database(c.mongoConfig.databaseName).Collection(c.mongoConfig.collectionName).InsertOne(mongoLog) + _, err = c.mongoClient.Database(c.mongoConfig.databaseName).Collection(c.mongoConfig.collectionName).InsertOne(mongoLog) + if err != nil { + c.zapLog.WithLogger().Sugar().Errorf("[golog.api.mongoRecord]：%s", err) + } return err } @@ -181,17 +182,17 @@ func (c *ApiClient) MongoMiddleware(ctx context.Context, request gorequest.Respo SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.ResponseHeader.Get("Content-Type") == "image/jpeg" || request.ResponseHeader.Get("Content-Type") == "image/png" || request.ResponseHeader.Get("Content-Type") == "image/jpg" { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddleware]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddleware.type]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.JsonDecodeNoError(request.ResponseBody)) > 0 { data.ResponseBody = dorm.JsonDecodeNoError(request.ResponseBody) //【返回】内容 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddleware]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddleware.len]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.mongoRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.MongoMiddleware]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.MongoMiddleware]：%s\n", err.Error()) } } @@ -212,17 +213,17 @@ func (c *ApiClient) MongoMiddlewareXml(ctx context.Context, request gorequest.Re SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.ResponseHeader.Get("Content-Type") == "image/jpeg" || request.ResponseHeader.Get("Content-Type") == "image/png" || request.ResponseHeader.Get("Content-Type") == "image/jpg" { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddlewareXml]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddlewareXml.type]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.XmlDecodeNoError(request.ResponseBody)) > 0 { data.ResponseBody = dorm.XmlDecodeNoError(request.ResponseBody) //【返回】内容 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddlewareXml]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddlewareXml]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.mongoRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.MongoMiddlewareXml]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.MongoMiddlewareXml]：%s\n", err.Error()) } } @@ -243,16 +244,16 @@ func (c *ApiClient) MongoMiddlewareCustom(ctx context.Context, api string, reque SdkVersion: sdkVersion, //【程序】Sdk版本 } if request.ResponseHeader.Get("Content-Type") == "image/jpeg" || request.ResponseHeader.Get("Content-Type") == "image/png" || request.ResponseHeader.Get("Content-Type") == "image/jpg" { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddlewareCustom]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddlewareCustom.type]：%s %s\n", data.RequestUri, request.ResponseHeader.Get("Content-Type")) } else { if len(dorm.JsonDecodeNoError(request.ResponseBody)) > 0 { data.ResponseBody = dorm.JsonDecodeNoError(request.ResponseBody) //【返回】内容 } else { - c.zapLog.WithTraceId(ctx).Sugar().Infof("[log.MongoMiddlewareCustom]：%s %s\n", data.RequestUri, request.ResponseBody) + c.zapLog.WithTraceId(ctx).Sugar().Infof("[golog.api.MongoMiddlewareCustom]：%s %s\n", data.RequestUri, request.ResponseBody) } } err := c.mongoRecord(ctx, data) if err != nil { - c.zapLog.WithTraceId(ctx).Sugar().Errorf("[log.MongoMiddlewareCustom]：%s\n", err.Error()) + c.zapLog.WithTraceId(ctx).Sugar().Errorf("[golog.api.MongoMiddlewareCustom]：%s\n", err.Error()) } } diff --git a/gin_gorm.go b/gin_gorm.go index fa22024..c464159 100644 --- a/gin_gorm.go +++ b/gin_gorm.go @@ -78,7 +78,9 @@ func NewGinGormClient(config *GinGormClientConfig) (*GinClient, error) { // 创建模型 func (c *GinClient) gormAutoMigrate() (err error) { err = c.gormClient.Db.Table(c.gormConfig.tableName).AutoMigrate(&ginPostgresqlLog{}) - c.zapLog.WithLogger().Sugar().Info(err) + if err != nil { + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.gormAutoMigrate]：%s", err) + } return err } @@ -117,17 +119,20 @@ type ginPostgresqlLog struct { } // gormRecord 记录日志 -func (c *GinClient) gormRecord(postgresqlLog ginPostgresqlLog) error { +func (c *GinClient) gormRecord(postgresqlLog ginPostgresqlLog) (err error) { postgresqlLog.SystemHostName = c.gormConfig.hostname - if postgresqlLog.SystemInsideIp == "" { - postgresqlLog.SystemInsideIp = c.gormConfig.insideIp - } + postgresqlLog.SystemInsideIp = c.gormConfig.insideIp postgresqlLog.GoVersion = c.gormConfig.goVersion postgresqlLog.SdkVersion = Version - return c.gormClient.Db.Table(c.gormConfig.tableName).Create(&postgresqlLog).Error + err = c.gormClient.Db.Table(c.gormConfig.tableName).Create(&postgresqlLog).Error + if err != nil { + c.zapLog.WithLogger().Sugar().Errorf("[golog.gin.gormRecord]：%s", err) + } + + return } func (c *GinClient) gormRecordJson(ginCtx *gin.Context, traceId string, requestTime time.Time, requestBody map[string]interface{}, responseCode int, responseBody string, startTime, endTime int64, clientIp, requestClientIpCountry, requestClientIpRegion, requestClientIpProvince, requestClientIpCity, requestClientIpIsp string) { @@ -164,12 +169,12 @@ func (c *GinClient) gormRecordJson(ginCtx *gin.Context, traceId string, requestT data.RequestBody = datatypes.JSON(dorm.JsonEncodeNoError(requestBody)) //【请求】请求主体 data.RequestContent = dorm.JsonEncodeNoError(requestBody) //【请求】请求内容 } else { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[log.gormRecordJson]：%s %s\n", data.RequestUri, requestBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.gormRecordJson.len]：%s %s\n", data.RequestUri, requestBody) } err := c.gormRecord(data) if err != nil { - c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gormRecordJson]：%s\n", err) + c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gin.gormRecordJson]：%s\n", err) } } @@ -206,12 +211,12 @@ func (c *GinClient) gormRecordXml(ginCtx *gin.Context, traceId string, requestTi if len(dorm.JsonEncodeNoError(requestBody)) > 0 { data.RequestContent = dorm.JsonEncodeNoError(requestBody) //【请求】请求内容 } else { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[log.gormRecordXml]：%s %s\n", data.RequestUri, requestBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.gormRecordXml.len]：%s %s\n", data.RequestUri, requestBody) } err := c.gormRecord(data) if err != nil { - c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gormRecordXml]：%s\n", err) + c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gin.gormRecordXml]：%s\n", err) } } @@ -232,7 +237,7 @@ func (c *GinClient) GormMiddleware() gin.HandlerFunc { data, _ := ioutil.ReadAll(ginCtx.Request.Body) if c.gormConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.GormMiddleware] %s\n", data) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.GormMiddleware] %s\n", data) } // 复用 @@ -268,12 +273,12 @@ func (c *GinClient) GormMiddleware() gin.HandlerFunc { } if c.gormConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.GormMiddleware.len(jsonBody)] %v\n", len(jsonBody)) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.GormMiddleware.len(jsonBody)] %v\n", len(jsonBody)) } if err != nil { if c.gormConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.GormMiddleware.json.Unmarshal] %s %s\n", jsonBody, err) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.GormMiddleware.json.Unmarshal] %s %s\n", jsonBody, err) } dataJson = false xmlBody = goxml.XmlDecode(string(data)) @@ -281,8 +286,8 @@ func (c *GinClient) GormMiddleware() gin.HandlerFunc { } if c.gormConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.GormMiddleware.xmlBody] %s\n", xmlBody) - c.zapLog.WithLogger().Sugar().Infof("[golog.GormMiddleware.jsonBody] %s\n", jsonBody) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.GormMiddleware.xmlBody] %s\n", xmlBody) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.GormMiddleware.jsonBody] %s\n", jsonBody) } clientIp := gorequest.ClientIp(ginCtx.Request) @@ -313,16 +318,16 @@ func (c *GinClient) GormMiddleware() gin.HandlerFunc { if dataJson { if c.gormConfig.debug { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.json.request_body] %s\n", jsonBody) - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.json.request_body] %s\n", dorm.JsonEncodeNoError(jsonBody)) - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.json.request_body] %s\n", datatypes.JSON(dorm.JsonEncodeNoError(jsonBody))) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.json.request_body] %s\n", jsonBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.json.request_body] %s\n", dorm.JsonEncodeNoError(jsonBody)) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.json.request_body] %s\n", datatypes.JSON(dorm.JsonEncodeNoError(jsonBody))) } c.gormRecordJson(ginCtx, traceId, requestTime, jsonBody, responseCode, responseBody, startTime, endTime, clientIp, requestClientIpCountry, requestClientIpRegion, requestClientIpProvince, requestClientIpCity, requestClientIpIsp) } else { if c.gormConfig.debug { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.xml.request_body] %s\n", xmlBody) - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.xml.request_body] %s\n", dorm.JsonEncodeNoError(xmlBody)) - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.GormMiddleware.gormRecord.xml.request_body] %s\n", datatypes.JSON(dorm.JsonEncodeNoError(xmlBody))) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.xml.request_body] %s\n", xmlBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.xml.request_body] %s\n", dorm.JsonEncodeNoError(xmlBody)) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.GormMiddleware.gormRecord.xml.request_body] %s\n", datatypes.JSON(dorm.JsonEncodeNoError(xmlBody))) } c.gormRecordXml(ginCtx, traceId, requestTime, xmlBody, responseCode, responseBody, startTime, endTime, clientIp, requestClientIpCountry, requestClientIpRegion, requestClientIpProvince, requestClientIpCity, requestClientIpIsp) } diff --git a/gin_mongo.go b/gin_mongo.go index 73dc6c9..aec1334 100644 --- a/gin_mongo.go +++ b/gin_mongo.go @@ -201,19 +201,20 @@ type ginMongoLog struct { } // 记录日志 -func (c *GinClient) mongoRecord(mongoLog ginMongoLog) error { +func (c *GinClient) mongoRecord(mongoLog ginMongoLog) (err error) { mongoLog.SystemHostName = c.mongoConfig.hostname - if mongoLog.SystemInsideIp == "" { - mongoLog.SystemInsideIp = c.mongoConfig.insideIp - } + mongoLog.SystemInsideIp = c.mongoConfig.insideIp mongoLog.GoVersion = c.mongoConfig.goVersion mongoLog.SdkVersion = Version mongoLog.LogId = primitive.NewObjectID() - _, err := c.mongoClient.Database(c.mongoConfig.databaseName).Collection(c.mongoConfig.collectionName).InsertOne(mongoLog) + _, err = c.mongoClient.Database(c.mongoConfig.databaseName).Collection(c.mongoConfig.collectionName).InsertOne(mongoLog) + if err != nil { + c.zapLog.WithLogger().Sugar().Errorf("[golog.gin.mongoRecord]：%s", err) + } return err } @@ -250,12 +251,12 @@ func (c *GinClient) mongoRecordJson(ginCtx *gin.Context, traceId string, request if len(dorm.JsonEncodeNoError(requestBody)) > 0 { data.RequestBody = requestBody //【请求】请求主体 } else { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[log.mongoRecordJson]：%s %s\n", data.RequestUri, requestBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.mongoRecordJson.len]：%s %s\n", data.RequestUri, requestBody) } err := c.mongoRecord(data) if err != nil { - c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.mongoRecordJson]：%s\n", err) + c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gin.mongoRecordJson]：%s\n", err) } } @@ -291,12 +292,12 @@ func (c *GinClient) mongoRecordXml(ginCtx *gin.Context, traceId string, requestT if len(dorm.JsonEncodeNoError(requestBody)) > 0 { data.RequestBody = requestBody //【请求】请求主体 } else { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[log.mongoRecordXml]：%s %s\n", data.RequestUri, requestBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.mongoRecordXml.len]：%s %s\n", data.RequestUri, requestBody) } err := c.mongoRecord(data) if err != nil { - c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.mongoRecordXml]：%s\n", err) + c.zapLog.WithTraceIdStr(traceId).Sugar().Errorf("[golog.gin.mongoRecordXml]：%s\n", err) } } @@ -317,7 +318,7 @@ func (c *GinClient) MongoMiddleware() gin.HandlerFunc { data, _ := ioutil.ReadAll(ginCtx.Request.Body) if c.mongoConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.MongoMiddleware] %s\n", data) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.MongoMiddleware] %s\n", data) } // 复用 @@ -353,12 +354,12 @@ func (c *GinClient) MongoMiddleware() gin.HandlerFunc { } if c.mongoConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.MongoMiddleware.len(jsonBody)] %v\n", len(jsonBody)) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.MongoMiddleware.len(jsonBody)] %v\n", len(jsonBody)) } if err != nil { if c.mongoConfig.debug { - c.zapLog.WithLogger().Sugar().Infof("[golog.MongoMiddleware.json.Unmarshal] %s %s\n", jsonBody, err) + c.zapLog.WithLogger().Sugar().Infof("[golog.gin.MongoMiddleware.json.Unmarshal] %s %s\n", jsonBody, err) } dataJson = false xmlBody = goxml.XmlDecode(string(data)) @@ -398,12 +399,12 @@ func (c *GinClient) MongoMiddleware() gin.HandlerFunc { if dataJson { if c.mongoConfig.debug { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.MongoMiddleware.mongoRecord.json.request_body] %s\n", jsonBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.MongoMiddleware.mongoRecord.json.request_body] %s\n", jsonBody) } c.mongoRecordJson(ginCtx, traceId, requestTime, jsonBody, responseCode, responseBody, startTime, endTime, clientIp, requestClientIpCountry, requestClientIpRegion, requestClientIpProvince, requestClientIpCity, requestClientIpIsp) } else { if c.mongoConfig.debug { - c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.MongoMiddleware.mongoRecord.xml.request_body] %s\n", xmlBody) + c.zapLog.WithTraceIdStr(traceId).Sugar().Infof("[golog.gin.MongoMiddleware.mongoRecord.xml.request_body] %s\n", xmlBody) } c.mongoRecordXml(ginCtx, traceId, requestTime, xmlBody, responseCode, responseBody, startTime, endTime, clientIp, requestClientIpCountry, requestClientIpRegion, requestClientIpProvince, requestClientIpCity, requestClientIpIsp) }