| | |
| | | util.ResponseFormat(c, code.Success, data) |
| | | } |
| | | |
| | | func getAlarmLevel(alarmlevel int) (string) { |
| | | d := dbapi.DicApi{} |
| | | res,data := d.FindByType("ALARMLEVEL") |
| | | if data == nil { |
| | | fmt.Println("data is nil") |
| | | } |
| | | fmt.Println(res) |
| | | // fmt.Println(data) |
| | | alarmLevel := make(map[int]string) |
| | | |
| | | tmp := data.(map[string]interface{}) |
| | | |
| | | for _,value := range tmp["ALARMLEVEL"].([]interface{}) { |
| | | // fmt.Println(value.(map[string]interface{})["value"]," ",value.(map[string]interface{})["name"]) |
| | | val := value.(map[string]interface{})["value"].(string) |
| | | name := value.(map[string]interface{})["name"].(string) |
| | | vl,err := strconv.Atoi(val) |
| | | if err != nil { |
| | | fmt.Println(err) |
| | | } |
| | | alarmLevel[vl] = name |
| | | |
| | | } |
| | | |
| | | // fmt.Println(alarmLevel) |
| | | |
| | | alarmLevelRes = alarmLevel[alarmlevel] |
| | | return alarmLevelRes |
| | | } |
| | | |
| | | func findEsData(searchBody map[string]interface{}) map[string]interface{} { |
| | | webPage := int(searchBody["page"].(float64)) |
| | | |
| | |
| | | index = config.EsInfo.EsIndex.VideoPersons.IndexName |
| | | esTableIdStr = "{\"terms\":{\"baseInfo.tableId\":[\"" + esTableId + "\"]}}," |
| | | } |
| | | //判断收藏状态 |
| | | isCollectStr := "" |
| | | isCollect := searchBody["collection"].(string) |
| | | if isCollect != "" { |
| | | isCollectStr = "{\"term\":{\"isCollect\":\"" + isCollect + "\"}}," |
| | | } |
| | | //判断布防等级id |
| | | alarmLevelId :=searchBody["alarmlevel"].(int) |
| | | alarmLevelStr := "" |
| | | if alarmLevelId != nil && alarmLevelId != 0{ |
| | | if alarmLevelId != -1 { |
| | | id := getAlarmLevel(alarmLevelId) |
| | | alarmLevelStr = "{\"terms\":{\"alarmRules.alarmLevel\":[\"" + id + "\"]}},{\"terms\":{\"alarmRules.defenceState\":[\"true\"]}}," |
| | | |
| | | }else{ |
| | | alarmLevelStr = "{\"terms\":{\"alarmRules.defenceState\":[\"false\"]}}," |
| | | } |
| | | } |
| | | |
| | | //使用es底层机制处理分页 |
| | | //请求头 |
| | | url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport + |
| | |
| | | "\"query\":{\"bool\":{" + queryStr + |
| | | "\"filter\":[" + |
| | | cameraIdStr + |
| | | alarmLevelStr + |
| | | taskIdStr + |
| | | isCollectStr + |
| | | esTableIdStr + |