algorithm/car/plate.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" algorithm/face/face.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" algorithm/faceCompare/faceCompare.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" algorithm/intrusion/intrusion.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" algorithm/middleware/middleware.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "encoding/json" "github.com/knetic/govaluate" "plugin" algorithm/middleware/readyData.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/golang/protobuf/proto" uuid "github.com/satori/go.uuid" "ruleprocess/ruleserver" algorithm/personUnsual/personUnsual.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/structure" "strconv" algorithm/static/static.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/knetic/govaluate" "ruleprocess/ruleserver" "ruleprocess/structure" insertdata/insertDataToEs.go
@@ -1,7 +1,7 @@ package insertdata import ( "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "encoding/base64" "encoding/json" "errors" labelFilter/readyDataForLabel.go
@@ -1,7 +1,7 @@ package labelFilter import ( "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "ruleprocess/cache" "ruleprocess/structure" "time" labelFilter/req.go
@@ -2,7 +2,7 @@ import ( "basic.com/dbapi.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "fmt" "nanomsg.org/go-mangos" "nanomsg.org/go-mangos/protocol/rep" labelFilter/ruleForLabel.go
@@ -3,7 +3,7 @@ import ( "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "github.com/golang/protobuf/proto" "github.com/knetic/govaluate" "ruleprocess/structure" main.go
@@ -12,11 +12,11 @@ "ruleprocess/structure" "time" "basic.com/valib/logger.git" //"basic.com/valib/logger.git" "flag" "fmt" "github.com/spf13/viper" log "github.com/jeanphorn/log4go" //"github.com/spf13/viper" logger "github.com/jeanphorn/log4go" "ruleprocess/cache" "ruleprocess/ruleserver" "sync" @@ -34,18 +34,18 @@ // 日志初始化 insertdata.Init(*env) var logFile = "./logger/" if viper.GetString("LogBasePath") != "" { logFile = viper.GetString("LogBasePath") } logFile = logFile + "ruleprocess.log" fmt.Println("日志地址:",logFile) logger.Config(logFile, logger.DebugLevel) logger.SetSaveDays(7) //var logFile = "./logger/" //if viper.GetString("LogBasePath") != "" { // logFile = viper.GetString("LogBasePath") //} //logFile = logFile + "ruleprocess.log" //fmt.Println("日志地址:",logFile) //logger.Config(logFile, logger.DebugLevel) //logger.SetSaveDays(7) // log4go logger.LoadConfiguration("./logger/log4go.json") logger.Info("日志初始化成功!") // log4go log.LoadConfiguration("./logger/log4go.json") } func main() { //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 @@ -93,7 +93,7 @@ //go func(msg []byte) { logger.Debug("当前时间戳:", time.Now().Unix()) log.Warn(time.Now().Format("2006-01-02 15:04:05")) //logger.Warn(time.Now().Format("2006-01-02 15:04:05")) arg := structure.SdkDatas{} //paramFormat(msg, &arg) start := time.Now() @@ -118,7 +118,7 @@ } func CallParamFormat(msg []byte, args *structure.SdkDatas) protomsg.SdkMessage{ log.Info("呼叫中间件格式化数据") logger.Info("呼叫中间件格式化数据") p,err := plugin.Open("./algorithm/middleware.so") if err != nil { panic(err) ruleserver/attachInfo.go
@@ -2,7 +2,7 @@ import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" uuid "github.com/satori/go.uuid" "ruleprocess/cache" ) ruleserver/geoPolygon_test.go
@@ -1,7 +1,7 @@ package ruleserver import ( "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "encoding/json" "fmt" "ruleprocess/structure" ruleserver/personTrack.go
@@ -3,7 +3,7 @@ import ( "basic.com/pubsub/protomsg.git" "github.com/golang/protobuf/proto" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "ruleprocess/structure" "sync" ) ruleserver/pushPolygonForTrack.go
@@ -3,7 +3,7 @@ import ( "basic.com/pubsub/protomsg.git" "ruleprocess/cache" "ruleprocess/logger" logger "github.com/jeanphorn/log4go" "ruleprocess/structure" "github.com/kirinlabs/HttpRequest" "strconv" ruleserver/readyDataForRule.go
@@ -3,7 +3,7 @@ import ( "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "encoding/json" "errors" "fmt" ruleserver/ruleToformula.go
@@ -5,7 +5,7 @@ "github.com/knetic/govaluate" "plugin" "ruleprocess/cache" "ruleprocess/logger" logger "github.com/jeanphorn/log4go" "ruleprocess/structure" "sort" "strconv" ruleserver/server.go
@@ -4,7 +4,7 @@ "basic.com/pubsub/protomsg.git" "basic.com/valib/gopherdiscovery.git" "github.com/gogo/protobuf/proto" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "time" ) ruleserver/timeTicker.go
@@ -2,7 +2,7 @@ import ( "fmt" "basic.com/valib/logger.git" logger "github.com/jeanphorn/log4go" "ruleprocess/structure" "strings" "time"