From 40e90ca2c934c8505f2a9e9b1c4f076657008369 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期五, 05 七月 2019 10:34:00 +0800
Subject: [PATCH] 添加日志系统
---
main.go | 34 +++++++++++++++++++++++++++-------
1 files changed, 27 insertions(+), 7 deletions(-)
diff --git a/main.go b/main.go
index c8545c9..6ccfb71 100644
--- a/main.go
+++ b/main.go
@@ -17,6 +17,7 @@
"ruleprocess/insertdata"
"ruleprocess/ruleserver"
"ruleprocess/util"
+ "ruleprocess/logger"
"sync"
)
var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip")
@@ -24,6 +25,15 @@
var surveyPort = flag.Int("surveyPort",40007,"survey port") //蹇冭烦
var pubPort = flag.Int("pubPort",50007,"pubsub port") //鏁版嵁鏇存柊
var initchan = make(chan bool)
+func init () {
+ var logFile = "/opt/ruleLog/error.log"
+ var logSaveDays = 15
+
+ // 鏃ュ織鍒濆鍖�
+ logger.Config(logFile, logger.DebugLevel)
+ logger.SetSaveDays(logSaveDays)
+ logger.Info("loginit success !")
+}
func main() {
flag.Parse()
wg := sync.WaitGroup{}
@@ -38,9 +48,9 @@
wg.Wait()
//resp,err := DrawPolygonOnImage()
//if err != nil {
- // log.Println("鐢绘鎴栬�呬笂浼犳湁闂")
+ // logger.Println("鐢绘鎴栬�呬笂浼犳湁闂")
//}
- //log.Println(resp["fileUrl"].(string))
+ //logger.Println(resp["fileUrl"].(string))
}
func nReciever(url string, m deliver.Mode, count int) {
c := deliver.NewServer(m, url)
@@ -109,7 +119,7 @@
}
i := protomsg.Image{}
err = proto.Unmarshal(bdata, &i)
-
+ logger.Info("----------------鐪嬬湅鏈夊嚑涓畻娉曪細",len(m.Tasklab.Sdkinfos))
for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo绠楁硶
if sdkinfo.Sdktype == "Yolo" {
arg := ruleserver.SdkData{}
@@ -136,6 +146,7 @@
fmt.Println("瑙ｆ瀽YOLO sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err)
continue
}
+ logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅yolo涓湁鍑犱釜鐩爣锛�",len(yoloParam.Infos))
for _, info := range yoloParam.Infos {
if info.Typ == 0 {
photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob)*100,IsYolo:true}
@@ -166,13 +177,13 @@
arg.KeepRight = false
arg.IsStatic = false
if len(sdkinfo.Sdkdata) > 1 {
- fmt.Println("----------------------------------------------------",m.Caddr)
faceParam := protomsg.ParamFacePos{}
err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
if err != nil {
fmt.Println("瑙ｆ瀽FACE sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err)
continue
}
+ logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅浜鸿劯妫�娴嬩腑鏈夊嚑涓洰鏍囷細",len(faceParam.Faces))
for _, info := range faceParam.Faces {
photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.Quality)*100, IsYolo:false,ThftRes:*(info.Result)}
arg.Photo = append(arg.Photo, photoMap)
@@ -200,13 +211,22 @@
arg.KeepRight = false
arg.IsStatic = false
if len(sdkinfo.Sdkdata) > 1 {
- fmt.Println("----------------------------------------------------",m.Caddr)
faceParam := protomsg.ParamFaceFeature{}
err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
if err != nil {
fmt.Println("瑙ｆ瀽FACE sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err)
continue
}
+ for _,faceExtCom := range faceParam.ExtComp {
+ binfos := protomsg.Binfos{}
+ err := proto.Unmarshal(faceExtCom.Comp, &binfos)
+ if err != nil {
+ fmt.Println("瑙ｆ瀽浜鸿劯姣斿鏁版嵁鏃跺嚭鐜伴敊璇�", err)
+ continue
+ }
+ logger.Info("_________________________________________________________________瑙ｆ瀽鍑虹殑浜鸿劯鐨勭浉浼肩殑搴曞簱鏁版嵁",binfos)
+ }
+ logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅浜鸿劯鎻愬彇涓湁鍑犱釜鐩爣锛�",len(faceParam.ExtComp))
for _, extComp := range faceParam.ExtComp {
baseinfos := protomsg.Binfos{}
err1 := proto.Unmarshal(extComp.Comp, &baseinfos)
@@ -269,7 +289,7 @@
//client := &http.Client{Timeout: timeout}
//resp, err := client.Do(request)
//if err != nil {
- // log.Fatal(err)
+ // logger.Fatal(err)
// return nil, err
//}
//defer func() {
@@ -292,7 +312,7 @@
// body := &bytes.Buffer{}
// _, err := body.ReadFrom(resp.Body)
// if err != nil {
- // log.Fatal(err)
+ // logger.Fatal(err)
// }
// fmt.Println(resp.StatusCode)
// //fmt.Println(resp.Header)
--
Gitblit v1.8.0