| | |
| | | } |
| | | |
| | | d["id"] = value.(map[string]interface{})["_id"] |
| | | |
| | | d["picDate"] = source["picDate"] |
| | | pmax, exist := source["picMaxUrl"] |
| | | if !exist { |
| | | continue |
| | |
| | | pmArr := pmax.([]interface{}) |
| | | if len(pmArr) > 0 { |
| | | d["picMaxUrl"] = pmArr[0] |
| | | } else { |
| | | d["picMaxUrl"] = "" |
| | | } |
| | | |
| | | tB, err := json.Marshal(source["targetInfo"]) |
| | |
| | | } else { |
| | | d["baseInfo"] = []interface{}{} |
| | | } |
| | | d["sdkType"] = "人脸" |
| | | } else { |
| | | d["sdkType"] = source["sdkName"] |
| | | d["picSmUrl"] = d["picMaxUrl"] |
| | | } |
| | | } else { |
| | | d["picSmUrl"] = d["picMaxUrl"] |
| | | } |
| | | |
| | | |
| | |
| | | filterStr = strings.Join(filterArr, ",") |
| | | } |
| | | param := "{\"query\":{\"bool\":{\"filter\":["+filterStr+"]}},\"size\":\""+sizeStr+"\",\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," + |
| | | "\"_source\":{\"includes\":[\"baseInfo\",\"targetInfo\",\"content\",\"id\",\"picMaxUrl\",\"picDate\",\"showLabels\",\"taskName\"],\"excludes\":[\"*.feature\",\"*.attachTarget\",\"*.targetLocation\",\"alarmRules\"]}" + |
| | | "\"_source\":{\"includes\":[\"baseInfo\",\"targetInfo\",\"content\",\"id\",\"picMaxUrl\",\"picDate\",\"showLabels\",\"taskName\",\"sdkName\"],\"excludes\":[\"*.feature\",\"*.attachTarget\",\"*.targetLocation\",\"alarmRules\"]}" + |
| | | "}" |
| | | err, tokenRes := GetEsDataReq(url, param, true) |
| | | |
| | |
| | | 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 |
| | | } |