tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-11-04 a07cb9faca7bd4232a4230399eccb23d4b2acc0d
esutil/EsClient.go
@@ -361,25 +361,28 @@
}
func PostAction(sec int, Eurl string, picurl string, ishub string, size int, lastT time.Time, curTime time.Time) []byte {
   lastTimeStr := lastT.Format("2006-01-02 15:04:05")
   curTimeStr := curTime.Format("2006-01-02 15:04:05")
   //lastTimeStr := lastT.Format("2006-01-02 15:04:05")
   //curTimeStr := curTime.Format("2006-01-02 15:04:05")
   index := "videopersons,personaction"
   url := fmt.Sprintf("%s%s%s", Eurl, index, "/_search")
   startTime := time.Now()
   sizeStr :=""
   if size <=0 {
      sizeStr = "100"
      sizeStr = "1000"
   } else {
      sizeStr = strconv.Itoa(size)
   }
   preSec := "10"
   if sec <=0 {
      preSec = "10"
   }
   var filterArr []string
   if ishub == "hub" {
      filterArr = append(filterArr,"{\"term\":{\"personIsHub\":\"1\"}}")
   }
   filterArr = append(filterArr, "{\"range\":{\"picDate\":{\"gte\":\""+lastTimeStr+"\",\"lt\":\""+curTimeStr+"\"}}}")
   filterArr = append(filterArr, "{\"range\":{\"picDate\":{\"gte\":\"now+8h-"+preSec+"s\",\"lt\":\"now+8h\"}}}")
   filterStr := ""
   if len(filterArr) >0 {