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 | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index d44ccec..05a014e 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -8,9 +8,9 @@
"strconv"
)
-var weedfsUrl, videoPersonUrl, personAction string
-var serverIp string
-var serverPort string
+//var weedfsUrl, videoPersonUrl, personAction string
+//var serverIp string
+//var serverPort string
func InsertToEs(msg structure.ResultMsg) {
defer func() {
if err := recover(); err != nil {
@@ -21,15 +21,15 @@
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))
-
+ 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/insertEs.so")
+ p,err := plugin.Open("./algorithm/middleware.so")
if err != nil {
panic(err)
}
--
Gitblit v1.8.0