| | |
| | | var searchBody InitForMonitorArg |
| | | |
| | | c.BindJSON(&searchBody) |
| | | index := config.EsInfo.EsIndex.VideoPersons.IndexName + "," + config.EsInfo.EsIndex.Personaction.IndexName |
| | | index := config.EsInfo.EsIndex.AiOcean.IndexName |
| | | cameraIdStr := "" |
| | | linkTagInfoCameraIdStr := "" |
| | | cameraId := searchBody.TreeNodes |
| | | if cameraId != nil && len(cameraId) > 0 { |
| | | esCameraId := strings.Replace(strings.Trim(fmt.Sprint(cameraId), "[]"), " ", "\",\"", -1) |
| | | cameraIdStr = "{\"terms\":{\"cameraId\":[\"" + esCameraId + "\"]}}," |
| | | linkTagInfoCameraIdStr = "{\"terms\":{\"linkTagInfo.cameraId\":[\"" + esCameraId + "\"]}}," |
| | | } |
| | | //判断任务ID |
| | | taskIdStr := "{\"terms\":{\"taskId\":[]}}," |
| | | taskIdStr := "" |
| | | linkTagInfoTaskIdStr := "" |
| | | taskId := searchBody.Tasks |
| | | if taskId != nil && len(taskId) > 0 { |
| | | esTaskId := strings.Replace(strings.Trim(fmt.Sprint(taskId), "[]"), " ", "\",\"", -1) |
| | | taskIdStr = "{\"terms\":{\"taskId\":[\"" + esTaskId + "\"]}}," |
| | | linkTagInfoTaskIdStr = "{\"terms\":{\"linkTagInfo.taskId\":[\"" + esTaskId + "\"]}}," |
| | | } |
| | | //请求头 |
| | | localConf, err2 := cache.GetServerInfo() |
| | |
| | | "/" + index + "/_search" |
| | | |
| | | analyServerFilterStr := "{\"term\":{\"analyServerId\":\"" + localConf.ServerId + "\"}}," |
| | | linkTagInfoAnalyServerFilterStr := "{\"term\":{\"linkTagInfo.analyServerId\":\"" + localConf.ServerId + "\"}}," |
| | | |
| | | prama := "{\"query\":{\"bool\":{\"filter\":[" + |
| | | prama := "{\"query\":{\"bool\":{\"should\":[" + |
| | | "{\"bool\":{\"filter\":[" + |
| | | cameraIdStr + |
| | | taskIdStr + |
| | | analyServerFilterStr + |
| | | "{\"range\":{\"picDate\":{\"gte\":\"now+8h-15s\",\"lt\":\"now+8h\"}}}]}}," + |
| | | "{\"range\":{\"picDate\":{\"gte\":\"now+8h-15s\",\"lt\":\"now+8h\"}}}" + |
| | | "]}}," + |
| | | "{\"bool\":{\"filter\":[" + |
| | | linkTagInfoCameraIdStr + |
| | | linkTagInfoTaskIdStr + |
| | | linkTagInfoAnalyServerFilterStr + |
| | | "{\"range\":{\"linkTagInfo.picDate\":{\"gte\":\"now+8h-15s\",\"lt\":\"now+8h\"}}}" + |
| | | "]}}" + |
| | | "]}}," + |
| | | "\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," + |
| | | "\"size\":\"1000\"," + |
| | | "\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\"]}" |
| | | "\"_source\":{\"includes\":[],\"excludes\":[\"*.feature\"]}}" |
| | | fmt.Println(prama) |
| | | fmt.Println(url) |
| | | tokenRes := esutil.GetEsDataReq(url, prama, true) |