From 770da0e3e04da28d58a96526226ceece4e1a771e Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 26 十一月 2019 17:37:54 +0800
Subject: [PATCH] 加入车牌过滤

---
 main.go |   10 ++++++++--
 1 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/main.go b/main.go
index 8c4179e..ad83cc8 100644
--- a/main.go
+++ b/main.go
@@ -16,6 +16,7 @@
 	"flag"
 	"fmt"
 	"github.com/spf13/viper"
+	//log "github.com/jeanphorn/log4go"
 	"ruleprocess/cache"
 	"ruleprocess/ruleserver"
 	"sync"
@@ -42,6 +43,9 @@
 	logger.Config(logFile, logger.DebugLevel)
 	logger.SetSaveDays(7)
 	logger.Info("鏃ュ織鍒濆鍖栨垚鍔燂紒")
+
+	// log4go
+	//log.LoadConfiguration("./logger/log4go.json")
 }
 func main() {
 	//fmt.Println("缂撳瓨鍒濆鍖栧畬鎴�",<- initchan)//dbserver鍒濆鍖栧畬姣�
@@ -86,8 +90,9 @@
 			} else {
 				//runtime.GOMAXPROCS(runtime.NumCPU())
 				//logger.Debug("浣跨敤鐨刢pu涓暟锛�",runtime.NumCPU())
-				//go func(msg []byte) {
+				go func(msg []byte) {
 					logger.Debug("褰撳墠鏃堕棿鎴筹細", time.Now().Unix())
+					//log.Warn(time.Now().Format("2006-01-02 15:04:05"))
 					arg := structure.SdkDatas{}
 					//paramFormat(msg, &arg)
 					start := time.Now()
@@ -105,13 +110,14 @@
 					logger.Debug("鎻掑叆瀹孍s鎵�鐢ㄦ椂闂达細", esEnd)
 					//浜嬩欢鎺ㄩ��
 					labelFilter.PushSomthing(resultMsg)
-				//}(msg)
+				}(msg)
 			}
 		}
 	}
 }
 
 func CallParamFormat(msg []byte, args *structure.SdkDatas) protomsg.SdkMessage{
+	logger.Info("鍛煎彨涓棿浠舵牸寮忓寲鏁版嵁")
 	p,err :=  plugin.Open("./algorithm/middleware.so")
 	if err != nil {
 		panic(err)

--
Gitblit v1.8.0