| | |
|---|
| | | // @Description 实时监控比对数据 |
|---|
| | | // @Accept json |
|---|
| | | // @Produce json |
|---|
| | | // @Tags es |
|---|
| | | // @Tags realTime |
|---|
| | | // @Param obj body map true "底库数据" |
|---|
| | | // @Success 200 {string} json "{"code":200, msg:"目录结构数据", success:true}" |
|---|
| | | // @Failure 500 {string} json "{"code":500, msg:"返回错误信息", success:false}" |
|---|
| | |
|---|
| | | cameraIdStr = "{\"terms\":{\"cameraId\":[\"" + esCameraId + "\"]}}," |
|---|
| | | } |
|---|
| | | //判断任务ID |
|---|
| | | taskIdStr := "" |
|---|
| | | taskIdStr := "{\"terms\":{\"taskId\":[]}}," |
|---|
| | | taskId := searchBody["tasks"].([]interface{}) |
|---|
| | | if taskId != nil && len(taskId) > 0 { |
|---|
| | | esTaskId := strings.Replace(strings.Trim(fmt.Sprint(taskId), "[]"), " ", "\",\"", -1) |
|---|
| | |
|---|
| | | cameraIdStr + |
|---|
| | | taskIdStr + |
|---|
| | | analyServerFilterStr + |
|---|
| | | "{\"range\":{\"picDate\":{\"gte\":\"now+8h-5000s\",\"lt\":\"now+8h\"}}}]}}," + |
|---|
| | | "{\"range\":{\"picDate\":{\"gte\":\"now+8h-15s\",\"lt\":\"now+8h\"}}}]}}," + |
|---|
| | | "\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," + |
|---|
| | | "\"size\":\"1000\"," + |
|---|
| | | "\"_source\":[\"baseInfo\",\"gender\",\"indeviceName\",\"sdkType\",\"ageDescription\",\"content\",\"ID\",\"picAddress\",\"picMaxUrl\",\"picDate\",\"race\",\"videoNum\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"IDCard\",\"videoIp\",\"cameraId\"]}" |
|---|
| | | "\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\"]}" |
|---|
| | | fmt.Println(prama) |
|---|
| | | tokenRes := esutil.GetEsDataReq(url, prama, true) |
|---|
| | | /* for _, value := range tokenRes["datalist"].([]interface{}) { |
|---|
