| | |
| | | |
| | | tB, err := json.Marshal(source["targetInfo"]) |
| | | if err != nil { |
| | | log.Log.Infoln("err:", err) |
| | | continue |
| | | } |
| | | |
| | | tiArr := []TargetInfo{} |
| | | err = json.Unmarshal(tB, &tiArr) |
| | | if err !=nil { |
| | | log.Log.Infoln("err:", err) |
| | | continue |
| | | } |
| | | if len(tiArr) > 0 { |
| | |
| | | var filterArr []string |
| | | //是否查报警数据 |
| | | if ishub == "hub" { |
| | | filterArr = append(filterArr,"{\"term\":{\"alarmRules.alarmLevel.raw\":\"一级\"}}") |
| | | filterArr = append(filterArr,"{\"term\":{\"alarmRules.alarmLevel.raw\":\"二级\"}}") |
| | | } |
| | | |
| | | filterArr = append(filterArr, "{\"range\":{\"picDate\":{\"gte\":\"now+8h-"+preSec+"s\",\"lt\":\"now+8h\"}}}") |
| | |
| | | log.Log.Errorln("GetEsDataReq err:", err) |
| | | return nil |
| | | } |
| | | log.Log.Infoln("tokenRes:", tokenRes) |
| | | jsonstring, _ := json.Marshal(tokenRes) |
| | | log.Log.Infoln("len(result):", len(jsonstring)) |
| | | if len(jsonstring) <= 26 { |
| | | return nil |
| | | } |