return false when write error

liuxiaolong

2019-06-13 e7cab31e1177c33e1f5d738b1f7743c1975aecc5

 esutil/EsClient.go

@@ -81,6 +81,7 @@
            return errors.New("picMaxurl is not string"), nil
         }


         if !strings.HasPrefix(pmax, "http") {
            source["picMaxUrl"] = picurl + pmax

@@ -93,6 +94,10 @@

         if !strings.HasPrefix(psm, "http") {
            source["picSmUrl"] = picurl + psm
         }

         if source["sdkType"] != "人脸" {//行为没有存储大图
            source["picMaxUrl"] = source["picSmUrl"]
         }

         prace, exist := source["Race"]
@@ -242,6 +247,7 @@
   if err !=nil{
      return ""
   }

   var resp RespVideo
   err = json.Unmarshal(respBytes, &resp)
   if err !=nil {
@@ -261,7 +267,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
}
@@ -325,13 +336,20 @@
   return value[i-1]
}

func PostAction(sec int, Eurl string, picurl string) []byte {
func PostAction(sec int, Eurl string, picurl string, ishub string) []byte {
   index := "videopersons,personaction"
   url := fmt.Sprintf("%s%s%s", Eurl, index, "/_search")

   seccond := strconv.Itoa(sec)

   prama := "{\"query\":{\"bool\":{\"filter\":[{\"range\":{\"picDate\":{\"gte\":\"now+8h-" + seccond + "s\",\"lt\":\"now+8h\"}}}]}},\"size\":\"1000\",\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," +
   preSec := ""
   if sec > 60 {
      preSec = "-60s"
   }
   var ishubReq =""
   if ishub == "hub" {
      ishubReq = "{\"term\":{\"personIsHub\":\"1\"}},"
   }
   prama := "{\"query\":{\"bool\":{\"filter\":["+ishubReq+"{\"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\"]" +
      "}"
   err, tokenRes := GetEsDataReq(url, prama, picurl, true)