From 49dc91da55624eb63866fcf47c558761020e84b8 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 19 十一月 2019 14:19:54 +0800
Subject: [PATCH] ---

---
 insertdata/insertDataToEs.go |   44 +++++++++-----------------------------------
 1 files changed, 9 insertions(+), 35 deletions(-)

diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index 1b61223..9cda419 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -112,33 +112,6 @@
 	Y float64 `json:"y"`
 }
 
-//  yolo琛屼负鐨勬暟鎹粨鏋�
-//type Personaction struct {
-//	Id              string      `json:"id"`
-//	CameraId        string      `json:"cameraId"`
-//	CameraName      string      `json:"cameraName"`
-//	CameraAddr      string      `json:"cameraAddr"`
-//	TaskId          string      `json:"taskId"`
-//	TaskName        string      `json:"taskName"`
-//	SdkName         string      `json:"sdkName"`
-//	Content         string      `json:"content"`
-//	AlarmRules      []AlarmRule `json:"alarmRules"`
-//	AnalyServerId   string      `json:"analyServerId"`
-//	AnalyServerName string      `json:"analyServerName"`
-//	AnalyServerIp   string      `json:"analyServerIp"`
-//	ClusterId       string      `json:"clusterId"`
-//	PicSmUrl        []string    `json:"picSmUrl"`
-//	PicDate         string      `json:"picDate"`
-//	VideoUrl        string      `json:"videoUrl"`
-//	IsAlarm         int         `json:"isAlarm"`
-//	IsAckAlarm      int         `json:"isAckAlarm"`
-//	IsCollect       int         `json:"isCollect"`
-//	IsDelete        int         `json:"isDelete"`
-//	TargetInfo      []Target    `json:"targetInfo"`
-//	LinkTag         string      `json:"linkTag"`
-//	LinkTagInfo     []*LinkInfo `json:"linkTagInfo"`
-//}
-
 type AlarmRule struct {
 	GroupId      string `json:"groupId"`
 	AlarmLevel   string `json:"alarmLevel"`
@@ -154,11 +127,11 @@
 }
 
 func InsertToEs(msg structure.ResultMsg) {
-	//defer func() {
-	//	if err := recover(); err != nil {
-	//		logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
-	//	}
-	//}()
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
+		}
+	}()
 	localConfig1, err := cache.GetServerInfo()
 	if err != nil {
 		panic("閰嶇疆鏂囦欢涓嶅悎娉�")
@@ -237,7 +210,7 @@
 							msg.Tasklab.Taskid,
 							msg.Tasklab.Taskname,
 							sdkname,
-							time.Now().Format("2006-01-02 15:04:05"),
+							"",
 							alarmRules,
 							time.Now().Format("2006-01-02 15:04:05"), // 鍙娴嬶紝娌℃湁姣斿鏃堕棿
 							lable,
@@ -266,7 +239,7 @@
 						if err1 != nil {
 							logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
 						} else {
-							logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭�(浜鸿劯)锛�", resp1)
+							logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", sdkname,"---",resp1)
 							// 鍙戝嚭褰曞儚淇″彿
 							ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: face.Uuid, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{"-1"}, Type: 1})
 						}
@@ -776,8 +749,9 @@
 
 	case "plate":
 		// 杞︾墝杩愬姩鏂瑰悜锛�0 unknown, 1 left, 2 right, 3 up, 4 down
+		logger.Info("杞﹁締杞︾墝淇℃伅锛�",obj.Car.NColor,obj.Car.NCarColor,obj.Car.NCarLogo,obj.Car.NCarType,obj.Car.NDirection)
 		lable = obj.Car.License + "/" + cache.GetDic("nColor"+strconv.Itoa(int(obj.Car.NColor))) + "杞︾墝" + "/" +
-			cache.GetDic("nCarColor"+strconv.Itoa(int(obj.Car.NCarColor))) + "杞﹁締" + "/" + cache.GetDic("nCarLogo"+strconv.Itoa(int(obj.Car.NCarLogo))) + "/" + cache.GetDic("nCarLogo"+strconv.Itoa(int(obj.Car.NCarType)))
+			cache.GetDic("nCarColor"+strconv.Itoa(int(obj.Car.NCarColor))) + "杞﹁締" + "/" + "鍝佺墝锛�"+cache.GetDic("nCarLogo"+strconv.Itoa(int(obj.Car.NCarLogo))) + "/" + "鍨嬪彿锛�"+cache.GetDic("nCarType"+strconv.Itoa(int(obj.Car.NCarType)))
 		lableAttach = cache.GetDic("nDirection"+strconv.Itoa(int(obj.Car.NDirection))) + "/" + "杞︾墝缃俊搴︼細" + strconv.Itoa(int(obj.Car.NConfidence)) + "/" +
 			"杞︾墝浜害锛�" + strconv.Itoa(int(obj.Car.NBright)) + "/" + "杞︾殑浜害锛�" + strconv.Itoa(int(obj.Car.NCarBright)) + "/" + "璇嗗埆鏃堕棿锛�" + strconv.Itoa(int(obj.Car.NTime))
 	}

--
Gitblit v1.8.0