tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-11-04 a07cb9faca7bd4232a4230399eccb23d4b2acc0d
fix get data
1个文件已修改
13 ■■■■■ 已修改文件
esutil/EsClient.go 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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 {