From 3a454e86f28c0e5a50332c2d3760598d36d800da Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 09 十二月 2019 17:43:54 +0800
Subject: [PATCH] es模块儿做成so

---
 insertdata/insertDataToEs.go |   26 ++++++++++++++++++++++++--
 1 files changed, 24 insertions(+), 2 deletions(-)

diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index 2e70d2a..d44ccec 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -2,11 +2,33 @@
 
 import (
 	"plugin"
+	"ruleprocess/cache"
+	"basic.com/valib/logger.git"
 	"ruleprocess/structure"
+	"strconv"
 )
 
-
+var weedfsUrl, videoPersonUrl, personAction string
+var serverIp string
+var serverPort string
 func InsertToEs(msg structure.ResultMsg) {
+	defer func() {
+		if err := recover(); err != nil {
+			logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
+		}
+	}()
+	localConfig1, err := cache.GetServerInfo()
+	if err != nil {
+		panic("閰嶇疆鏂囦欢涓嶅悎娉�")
+	}
+	weedfsUrl = "http://" + localConfig1.WebPicIp + ":" + strconv.Itoa(int(localConfig1.WebPicPort)) + "/submit"
+	videoPersonUrl = "http://" + localConfig1.AlarmIp + ":" + strconv.Itoa(int(localConfig1.AlarmPort)) + "/" + structure.EsInfo.EsIndex.AIOcean.IndexName + "/" + structure.EsInfo.EsIndex.AIOcean.IndexType+"?refresh=true"
+	serverIp = localConfig1.AlarmIp
+	serverPort = strconv.Itoa(int(localConfig1.AlarmPort))
+
+}
+
+func handle (msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string) {
 	p,err :=  plugin.Open("./algorithm/insertEs.so")
 	if err != nil {
 		panic(err)
@@ -15,5 +37,5 @@
 	if err1 != nil {
 		panic("娌℃湁鎵惧埌涓棿浠剁殑鏍煎紡鍖栨暟鎹嚱鏁�")
 	}
-	f.(func(msg structure.ResultMsg))(msg)
+	f.(func(msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string))(msg,weedfsUrl,videoPersonUrl,serverIp,serverPort)
 }

--
Gitblit v1.8.0