tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-05-30 3a0bf0dda0b151c793838fb8474e173ba2624d34
esutil/EsClient.go
@@ -259,8 +259,7 @@
      }
   }
   if videoUrl == "" {
      fmt.Println("videoReqUrl: ",reqUrl)
      fmt.Printf("imgKey:%s ,picDate:%s ,cameraId:%s ",imgKey,picDate,cameraId)
      fmt.Printf("videoReqUrl:%s ,imgKey:%s ,picDate:%s ,cameraId:%s ",reqUrl,imgKey,picDate,cameraId)
   }
   return videoUrl
@@ -276,11 +275,13 @@
      var err error
      bodyJson, err = json.Marshal(body)
      if err != nil {
         log.Log.Errorln("doPostRequestMarshal err:",err)
         return resultBytes, err
      }
   }
   request, err := http.NewRequest("POST", url, bytes.NewBuffer(bodyJson))
   if err != nil {
      log.Log.Errorln("NewRequest ERR:",err)
      return resultBytes, err
   }
   request.Header.Set("Content-type", contentType)
@@ -304,11 +305,13 @@
   }
   resp, err := client.Do(request)
   if err != nil {
      log.Log.Errorln("DoRequest ERR:",err)
      return resultBytes, err
   }
   defer resp.Body.Close()
   resultBytes, err = ioutil.ReadAll(resp.Body)
   if err != nil {
      log.Log.Errorln("ReadAll ERR:",err)
      return resultBytes, err
   }
   return resultBytes, nil