| | |
|---|
| | | import ( |
|---|
| | | "fmt" |
|---|
| | | "github.com/gin-gonic/gin" |
|---|
| | | "strings" |
|---|
| | | "webserver/extend/code" |
|---|
| | | "webserver/extend/config" |
|---|
| | | "webserver/extend/esutil" |
|---|
| | | "webserver/extend/util" |
|---|
| | | "strings" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | type RealTimeController struct{} |
|---|
| | |
|---|
| | | |
|---|
| | | c.BindJSON(&searchBody) |
|---|
| | | index := config.EsInfo.EsIndex.VideoPersons.IndexName + "," + config.EsInfo.EsIndex.Personaction.IndexName |
|---|
| | | videoReqNumStr := "" |
|---|
| | | videoReqNum := searchBody["treeNodes"].([]interface{}) |
|---|
| | | if videoReqNum != nil && len(videoReqNum) > 0 { |
|---|
| | | esVideoReqNum := strings.Replace(strings.Trim(fmt.Sprint(videoReqNum), "[]"), " ", "\",\"", -1) |
|---|
| | | videoReqNumStr = "{\"terms\":{\"videoReqNum\":[\"" + esVideoReqNum + "\"]}}," |
|---|
| | | cameraIdStr := "" |
|---|
| | | cameraId := searchBody["treeNodes"].([]interface{}) |
|---|
| | | if cameraId != nil && len(cameraId) > 0 { |
|---|
| | | esCameraId := strings.Replace(strings.Trim(fmt.Sprint(cameraId), "[]"), " ", "\",\"", -1) |
|---|
| | | cameraIdStr = "{\"terms\":{\"cameraId\":[\"" + esCameraId + "\"]}}," |
|---|
| | | } |
|---|
| | | //请求头 |
|---|
| | | url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport + |
|---|
| | | "/" + index + "/_search" |
|---|
| | | |
|---|
| | | prama := "{\"query\":{\"bool\":{\"filter\":[" + |
|---|
| | | videoReqNumStr + |
|---|
| | | cameraIdStr + |
|---|
| | | "{\"range\":{\"picDate\":{\"gte\":\"now+8h-5s\",\"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\",\"videoReqNum\"]}" |
|---|
| | | "\"_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{}) { |
|---|
