From 0e34cd88dffcdbcc45ade814af0594d49c53d489 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Sat, 18 Jun 2022 17:14:16 +0800 Subject: [PATCH] =?UTF-8?q?-=20=E4=BC=98=E5=8C=96log?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/sendcloud/mongo.go | 48 -------------------------------------- utils/golog/api.go | 5 ++++ 2 files changed, 5 insertions(+), 48 deletions(-) delete mode 100644 service/sendcloud/mongo.go diff --git a/service/sendcloud/mongo.go b/service/sendcloud/mongo.go deleted file mode 100644 index a7fe3dab..00000000 --- a/service/sendcloud/mongo.go +++ /dev/null @@ -1,48 +0,0 @@ -package sendcloud - -import ( - "go.dtapp.net/library/utils/gomongo" - "go.dtapp.net/library/utils/gorequest" - "net/http" -) - -// 日志 -type mongoZap struct { - RequestTime gomongo.BsonTime `json:"request_time" bson:"request_time"` //【请求】时间 - RequestUri string `json:"request_uri" bson:"request_uri"` //【请求】链接 - RequestUrl string `json:"request_url" bson:"request_url"` //【请求】链接 - RequestApi string `json:"request_api" bson:"request_api"` //【请求】接口 - RequestMethod string `json:"request_method" bson:"request_method"` //【请求】方式 - RequestParams gorequest.Params `json:"request_params" bson:"request_params"` //【请求】参数 - RequestHeader gorequest.Headers `json:"request_header" bson:"request_header"` //【请求】头部 - ResponseHeader http.Header `json:"response_header" bson:"response_header"` //【返回】头部 - ResponseStatusCode int `json:"response_status_code" bson:"response_status_code"` //【返回】状态码 - ResponseBody map[string]interface{} `json:"response_body" bson:"response_body"` //【返回】内容 - ResponseContentLength int64 `json:"response_content_length" bson:"response_content_length"` //【返回】大小 - ResponseTime gomongo.BsonTime `json:"response_time" bson:"response_time"` //【返回】时间 -} - -func (m *mongoZap) Database() string { - return "zap_log" -} - -func (m *mongoZap) TableName() string { - return "sendcloud" -} - -func (app *App) mongoLog(request gorequest.Response) { - _, _ = app.mongo.Model(&mongoZap{}).InsertOne(mongoZap{ - RequestTime: gomongo.BsonTime(request.RequestTime), //【请求】时间 - RequestUri: request.RequestUri, //【请求】链接 - RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接 - RequestApi: gorequest.UriParse(request.RequestUri).Path, //【请求】接口 - RequestMethod: request.RequestMethod, //【请求】方式 - RequestParams: request.RequestParams, //【请求】参数 - RequestHeader: request.RequestHeader, //【请求】头部 - ResponseHeader: request.ResponseHeader, //【返回】头部 - ResponseStatusCode: request.ResponseStatusCode, //【返回】状态码 - ResponseBody: gomongo.JsonDecodeNoError(request.ResponseBody), //【返回】内容 - ResponseContentLength: request.ResponseContentLength, //【返回】大小 - ResponseTime: gomongo.BsonTime(request.ResponseTime), //【返回】时间 - }) -} diff --git a/utils/golog/api.go b/utils/golog/api.go index 769bf4c2..d8c6029b 100644 --- a/utils/golog/api.go +++ b/utils/golog/api.go @@ -8,6 +8,7 @@ import ( "os" "runtime" "strings" + "unicode/utf8" ) type ApiConfig struct { @@ -75,6 +76,10 @@ func (p *Api) AutoMigrate() { // Record 记录日志 func (p *Api) Record(content ApiPostgresqlLog) *gorm.DB { + if utf8.ValidString(string(content.ResponseBody)) == false { + log.Println("内容格式无法记录") + return p.db + } content.SystemHostName = p.hostname if content.SystemInsideIp == "" { content.SystemInsideIp = p.insideIp