From b2a7c4aec7f2441fc545ada6cbd7d2a771331043 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 17 十二月 2019 12:45:18 +0800
Subject: [PATCH] ---
---
insertdata/insertDataToEs.go | 28 +++++++++++++++++++++++++---
1 files changed, 25 insertions(+), 3 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index 2e70d2a..05a014e 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -2,12 +2,34 @@
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) {
- p,err := plugin.Open("./algorithm/insertEs.so")
+ 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))
+ handle(msg,weedfsUrl,videoPersonUrl,serverIp,serverPort)
+}
+
+func handle (msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string) {
+ p,err := plugin.Open("./algorithm/middleware.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