| | |
|---|
| | | analyServerFilterStr + |
|---|
| | | "{\"range\":{\"picDate\":{\"from\":\"" + gteDate + "\",\"to\":\"" + lteDate + "\",\"include_lower\":true,\"include_upper\":true,\"boost\":1}}}]}}," + |
|---|
| | | "\"sort\":[{\"_score\":{\"order\":\"desc\"}},{\"picDate\":{\"order\":\"desc\"}}]," + |
|---|
| | | "\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\"]" + |
|---|
| | | "\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\",\"linkId\"]" + |
|---|
| | | "}" |
|---|
| | | //logger.Debug("findEsData.param:",prama) |
|---|
| | | //数据解析 |
|---|
| | | tokenRes := esutil.GetEsDataReq(url, prama, true) |
|---|
| | | return tokenRes |
|---|
| | | fmt.Println(tokenRes) |
|---|
| | | tmpAllDate := make(map[string]interface{}) |
|---|
| | | tmpDate := make(map[string][]interface{}) |
|---|
| | | tmpAllDate["total"] = tokenRes["total"] |
|---|
| | | data := tokenRes["datalist"] |
|---|
| | | for _, masterInfoValues := range data.([]interface{}) { |
|---|
| | | masterInfo := masterInfoValues.(map[string]interface{}) |
|---|
| | | sources := make([]map[string]interface{}, 0) |
|---|
| | | sources = append(sources, masterInfo) |
|---|
| | | linkId := "" |
|---|
| | | if masterInfo["linkId"] != nil { |
|---|
| | | linkId = masterInfo["linkId"].(string) |
|---|
| | | } |
|---|
| | | id := masterInfo["id"].(string) |
|---|
| | | if linkId != "" { |
|---|
| | | linkInfo := GetLinkInfo(linkId, id) |
|---|
| | | for _, slaveInfoValues := range linkInfo { |
|---|
| | | slaveInfo := slaveInfoValues |
|---|
| | | sources = append(sources, slaveInfo) |
|---|
| | | } |
|---|
| | | fmt.Println(linkInfo) |
|---|
| | | |
|---|
| | | } |
|---|
| | | tmpDate["datalist"] = append(tmpDate["datalist"], sources) |
|---|
| | | |
|---|
| | | fmt.Println(sources) |
|---|
| | | } |
|---|
| | | tmpAllDate["datalist"] = tmpDate["datalist"] |
|---|
| | | return tmpAllDate |
|---|
| | | } |
|---|
| | | |
|---|
| | | func GetLinkInfo(linkId string, id string) []map[string]interface{} { |
|---|
| | | url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport + |
|---|
| | | "/" + config.EsInfo.EsIndex.VideoPersons.IndexName + "," + config.EsInfo.EsIndex.Personaction.IndexName + "/_search?search_type=dfs_query_then_fetch" |
|---|
| | | jsonDSL := "{\"query\":{\"bool\":{\"filter\":[{\"term\":{\"linkId.keyword\":\"" + linkId + "\"}}],\"must_not\":[{\"term\":{\"_id\":\"" + id + "\"}}]}},\"size\":100}" |
|---|
| | | |
|---|
| | | buf, err := esutil.EsReq("POST", url, []byte(jsonDSL)) |
|---|
| | | if err != nil { |
|---|
| | | logger.Debug(err) |
|---|
| | | } |
|---|
| | | |
|---|
| | | sources, err := esutil.Sourcelist(buf) |
|---|
| | | if err != nil { |
|---|
| | | logger.Debug(err) |
|---|
| | | } |
|---|
| | | return sources |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //sdkTYype字典"\"_source\":[\"BaseName\",\"Gender\",\"Race\",\"content\",\"idcard\",\"picAddress\",\"picDate\",\"sdkType\",\"Age\",\"personId\",\"personIsHub\",\"personPicUrl\",\"picLocalUrl\",\"picSmUrl\",\"videoIp\",\"videoNum\",\"cameraId\",\"ageDescription\",\"likePer\"]" + |
|---|
