|
|
|
|
@ -1,11 +1,11 @@
|
|
|
|
|
package leshuazf
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"go.dtapp.net/library/golog"
|
|
|
|
|
"go.dtapp.net/library/gomongo"
|
|
|
|
|
"go.dtapp.net/library/gorandom"
|
|
|
|
|
"go.dtapp.net/library/gorequest"
|
|
|
|
|
"go.dtapp.net/library/gotime"
|
|
|
|
|
"go.dtapp.net/library/utils/golog"
|
|
|
|
|
"gorm.io/gorm"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
@ -17,7 +17,7 @@ type App struct {
|
|
|
|
|
mongo *gomongo.Client // 日志数据库
|
|
|
|
|
pgsql *gorm.DB // pgsql数据库
|
|
|
|
|
client *gorequest.App // 请求客户端
|
|
|
|
|
log *golog.Client // 日志服务
|
|
|
|
|
log *golog.Api // 日志服务
|
|
|
|
|
logTableName string // 日志表名
|
|
|
|
|
logStatus bool // 日志状态
|
|
|
|
|
}
|
|
|
|
|
@ -29,7 +29,10 @@ func NewApp(agentId string, environment string, keyAgent string, pgsql *gorm.DB)
|
|
|
|
|
app.pgsql = pgsql
|
|
|
|
|
app.logStatus = true
|
|
|
|
|
app.logTableName = "leshuazf"
|
|
|
|
|
app.log = golog.NewClientApi(pgsql, app.logTableName)
|
|
|
|
|
app.log = golog.NewApi(&golog.ApiConfig{
|
|
|
|
|
Db: pgsql,
|
|
|
|
|
TableName: app.logTableName,
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
return app
|
|
|
|
|
}
|
|
|
|
|
@ -71,9 +74,6 @@ func (app *App) request(url string, params map[string]interface{}, method string
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 日志
|
|
|
|
|
if app.mongo != nil && app.mongo.Db != nil {
|
|
|
|
|
go app.mongoLog(request)
|
|
|
|
|
}
|
|
|
|
|
if app.logStatus == true {
|
|
|
|
|
go app.postgresqlLog(request)
|
|
|
|
|
}
|
|
|
|
|
|
