tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-05-30 a27f1d9078dba3b11f0a3c1e536a2f98b64d250d
esutil/EsClient.go
@@ -242,6 +242,7 @@
   if err !=nil{
      return ""
   }
   var resp RespVideo
   err = json.Unmarshal(respBytes, &resp)
   if err !=nil {
@@ -261,7 +262,12 @@
      }
   }
   if videoUrl == ""{
      fmt.Println("resp: ",resp)
      respMap := make(map[string]interface{},0)
      err := json.Unmarshal(respBytes, &respMap)
      if err !=nil {
         fmt.Println("resp UnmarshalToMap err: ",err)
      }
      fmt.Println("resp: ",respMap)
   }
   return videoUrl
}
@@ -331,8 +337,8 @@
   seccond := strconv.Itoa(sec)
   preSec := ""
   if sec > 30 {
      preSec = "-30s"
   if sec > 40 {
      preSec = "-40s"
   }
   prama := "{\"query\":{\"bool\":{\"filter\":[{\"range\":{\"picDate\":{\"gte\":\"now+8h-" + seccond + "s\",\"lt\":\"now+8h"+preSec+"\"}}}]}},\"size\":\"1000\",\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," +
      "\"_source\":[\"baseInfo\",\"Gender\",\"BaseName\",\"Age\",\"personId\",\"personPicUrl\",\"indeviceName\",\"imgKey\",\"sdkType\",\"ageDescription\",\"indeviceid\",\"content\",\"Id\",\"picAddress\",\"picMaxUrl\",\"picDate\",\"Race\",\"videoNum\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"idcard\",\"videoIp\",\"videoReqNum\"]" +