~suntianyu/webserver.git

parent: 2dd1fa03 | 补丁 | 提交 | ignore whitespace

liuxiaolong

2019-09-19 d37076e765284f1cf8d4db7b9b34913ef07d9d34

get ServerId from cache

12个文件已修改

	controllers/capture.go	7 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/dbtableperson.go	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/dbtablesCon.go	4 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/es.go	7 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/esSearch.go	9 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/fileController.go	4 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/initForData.go	14 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/monitoring.go	7 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/taglist.go	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	controllers/tasklist.go	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	service/CameraVideoService.go	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	service/EnableStatusControlService.go	10 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 controllers/capture.go

@@ -1,7 +1,6 @@
package controllers

import (
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "fmt"
    "github.com/gin-gonic/gin"
@@ -42,7 +41,7 @@
    }
    //请求头
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        util.ResponseFormat(c,code.ComError,"es config err")
        return
@@ -50,9 +49,7 @@
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + index + "/_search"

    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

    prama := "{\"query\":{\"bool\":{\"filter\":[" +
        cameraIdStr +

 controllers/dbtableperson.go

@@ -313,7 +313,7 @@

func UpdateDbPersonsOfDbTable(id string) (message string) {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return "修改失败"
    }

 controllers/dbtablesCon.go

@@ -43,7 +43,7 @@
// 依据底库id  查询数据
func QueryDbTableInfo(tableId string) map[string]interface{} {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }
@@ -177,7 +177,7 @@
func UpdateEndTime(id string) (flag bool) {
    flag = false
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return false
    }

 controllers/es.go

@@ -1,7 +1,6 @@
package controllers

import (
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "fmt"
    "github.com/gin-gonic/gin"
@@ -106,16 +105,14 @@
    //使用es底层机制处理分页
    //请求头
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + index + "/_search?search_type=dfs_query_then_fetch"

    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

    //请求体
    prama := "{\"from\":\"" + esFrom + "\",\"size\":\"" + esSize + "\"," +

 controllers/esSearch.go

@@ -142,15 +142,14 @@
    //使用es底层机制处理分页
    //请求头
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + index + "/_search?search_type=dfs_query_then_fetch"
    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"

    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

    //请求体
    prama := "{\"from\":\"" + from + "\"," +
@@ -203,7 +202,7 @@

func GetLinkInfo(linkId string, id string) []map[string]interface{} {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }

 controllers/fileController.go

@@ -275,7 +275,7 @@
    }
    if len(captureIds) >0 {
        localConf, err2 := cache.GetServerInfo()
        if err2 !=nil || localConf.AlarmIp == "" {
        if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
            logger.Debug("localConfig is wrong!!!")
            return nil
        }
@@ -355,7 +355,7 @@
    var faceB []byte
    if searchBody.CaptureId != "" {//做查找此人,搜所有抓拍和底库
        localConf, err2 := cache.GetServerInfo()
        if err2 !=nil || localConf.AlarmIp == "" {
        if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
            logger.Debug("localConfig is wrong!!!")
            util.ResponseFormat(c,code.ComError,"localConf wrong")
            return

 controllers/initForData.go

@@ -1,7 +1,6 @@
package controllers

import (
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "fmt"
    "github.com/gin-gonic/gin"
@@ -33,7 +32,7 @@
    c.BindJSON(&searchBody)
    index := config.EsInfo.EsIndex.VideoPersons.IndexName + "," + config.EsInfo.EsIndex.Personaction.IndexName
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        util.ResponseFormat(c,code.ComError,"localConf wrong")
        return
@@ -49,9 +48,7 @@
        }
    }

    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}"
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}}"

    prama := "{\"query\":{\"bool\":{\"filter\":[{\"term\":{\"isAlarm\":\"1\"}}," +
        cameraIdStr +
@@ -98,16 +95,15 @@
    }
    //请求头
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        util.ResponseFormat(c,code.ComError,"localConf wrong")
        return
    }
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + index + "/_search"
    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}}"

    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}}"

    prama := "{\"query\":{\"bool\":{\"filter\":[" +
        cameraIdStr +

 controllers/monitoring.go

@@ -1,7 +1,6 @@
package controllers

import (
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "fmt"
    "strconv"
@@ -45,7 +44,7 @@
    }
    //请求头
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        util.ResponseFormat(c,code.ComError,"localConf wrong")
        return
@@ -53,9 +52,7 @@
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + index + "/_search"

    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"
    analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

    prama := "{\"query\":{\"bool\":{\"filter\":[" +
        cameraIdStr +

 controllers/taglist.go

@@ -54,7 +54,7 @@
func GetTotalFromDb(id string) (flag bool) {
    flag = false
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return false
    }

 controllers/tasklist.go

@@ -24,7 +24,7 @@
// @Router /data/api-v/es/tagList [POST]
func (sc *EsSearchController) PostEsTaskList(c *gin.Context) {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        util.ResponseFormat(c,code.ComError,"localConf wrong")
        return

 service/CameraVideoService.go

@@ -14,7 +14,7 @@
// 地库人员数据 为 比对做准备
func QueryDbPersonsForCompare(reqBody models.EsSearch) map[string]interface{} {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }

 service/EnableStatusControlService.go

@@ -1,7 +1,6 @@
package service

import (
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "encoding/json"
    "fmt"
@@ -15,14 +14,13 @@

func GetVerificationData() []map[string]interface{} {
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return nil
    }
    url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
        "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search"
    var setApi dbapi.SysSetApi
    _, sysconf := setApi.GetServerInfo()

    jsonDSL := `{
    "query": {
        "bool": {
@@ -33,7 +31,7 @@
                },
                {
                    "terms": {
                        "analyServerId": ["` + sysconf.ServerId + `",""]
                        "analyServerId": ["` + localConf.ServerId + `",""]
                    }
                }
            ]
@@ -90,7 +88,7 @@
    }
    enable := strconv.Itoa(status)
    localConf, err2 := cache.GetServerInfo()
    if err2 !=nil || localConf.AlarmIp == "" {
    if err2 !=nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
        logger.Debug("localConfig is wrong!!!")
        return "localConf wrong"
    }

			@@ -1,7 +1,6 @@
			package controllers

			import (
			"basic.com/dbapi.git"
			"basic.com/valib/logger.git"
			"fmt"
			"github.com/gin-gonic/gin"
			@@ -42,7 +41,7 @@
			}
			//请求头
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			util.ResponseFormat(c,code.ComError,"es config err")
			return
			@@ -50,9 +49,7 @@
			url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
			"/" + index + "/_search"

			var setApi dbapi.SysSetApi
			_, sysconf := setApi.GetServerInfo()
			analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"
			analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

			prama := "{\"query\":{\"bool\":{\"filter\":[" +
			cameraIdStr +

			@@ -313,7 +313,7 @@

			func UpdateDbPersonsOfDbTable(id string) (message string) {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return "修改失败"
			}

			@@ -43,7 +43,7 @@
			// 依据底库id 查询数据
			func QueryDbTableInfo(tableId string) map[string]interface{} {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}
			@@ -177,7 +177,7 @@
			func UpdateEndTime(id string) (flag bool) {
			flag = false
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return false
			}

			@@ -142,15 +142,14 @@
			//使用es底层机制处理分页
			//请求头
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}
			url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
			"/" + index + "/_search?search_type=dfs_query_then_fetch"
			var setApi dbapi.SysSetApi
			_, sysconf := setApi.GetServerInfo()
			analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + sysconf.ServerId + "\"}},"

			analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}},"

			//请求体
			prama := "{\"from\":\"" + from + "\"," +
			@@ -203,7 +202,7 @@

			func GetLinkInfo(linkId string, id string) []map[string]interface{} {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}

			@@ -275,7 +275,7 @@
			}
			if len(captureIds) >0 {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}
			@@ -355,7 +355,7 @@
			var faceB []byte
			if searchBody.CaptureId != "" {//做查找此人,搜所有抓拍和底库
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			util.ResponseFormat(c,code.ComError,"localConf wrong")
			return

			@@ -54,7 +54,7 @@
			func GetTotalFromDb(id string) (flag bool) {
			flag = false
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return false
			}

			@@ -24,7 +24,7 @@
			// @Router /data/api-v/es/tagList [POST]
			func (sc EsSearchController) PostEsTaskList(c gin.Context) {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			util.ResponseFormat(c,code.ComError,"localConf wrong")
			return

			@@ -14,7 +14,7 @@
			// 地库人员数据为比对做准备
			func QueryDbPersonsForCompare(reqBody models.EsSearch) map[string]interface{} {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}

			@@ -1,7 +1,6 @@
			package service

			import (
			"basic.com/dbapi.git"
			"basic.com/valib/logger.git"
			"encoding/json"
			"fmt"
			@@ -15,14 +14,13 @@

			func GetVerificationData() []map[string]interface{} {
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return nil
			}
			url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
			"/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search"
			var setApi dbapi.SysSetApi
			_, sysconf := setApi.GetServerInfo()

			jsonDSL := `{
			"query": {
			"bool": {
			@@ -33,7 +31,7 @@
			},
			{
			"terms": {
			"analyServerId": ["` + sysconf.ServerId + `",""]
			"analyServerId": ["` + localConf.ServerId + `",""]
			}
			}
			]
			@@ -90,7 +88,7 @@
			}
			enable := strconv.Itoa(status)
			localConf, err2 := cache.GetServerInfo()
			if err2 !=nil \|\| localConf.AlarmIp == "" {
			if err2 !=nil \|\| localConf.AlarmIp == "" \|\| localConf.ServerId == "" {
			logger.Debug("localConfig is wrong!!!")
			return "localConf wrong"
			}