| | |
|---|
| | | "\"sort\":[{\"_score\":{\"order\":\"desc\"}},{\"picDate\":{\"order\":\"desc\"}}]," + |
|---|
| | | "\"_source\":[\"baseInfo\",\"alarmRules\",\"sex\",\"analyServerName\",\"sdkName\",\"ageDescription\",\"content\",\"id\",\"cameraAddr\",\"picMaxUrl\",\"picDate\",\"race\",\"videoUrl\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"isAlarm\",\"analyServerIp\",\"cameraId\"]" + |
|---|
| | | "}" |
|---|
| | | logger.Debug(prama) |
|---|
| | | //logger.Debug(prama) |
|---|
| | | //数据解析 |
|---|
| | | tokenRes := esutil.GetEsDataReq(url, prama, true) |
|---|
| | | return tokenRes |
|---|
| | |
|---|
| | | "sort" |
|---|
| | | "strconv" |
|---|
| | | "sync" |
|---|
| | | "time" |
|---|
| | | "webserver/extend/config" |
|---|
| | | "webserver/extend/logger" |
|---|
| | | "webserver/extend/util" |
|---|
| | |
|---|
| | | } |
|---|
| | | sock.AddTransport(ipc.NewTransport()) |
|---|
| | | sock.AddTransport(tcp.NewTransport()) |
|---|
| | | sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
|---|
| | | sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100) |
|---|
| | | //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
|---|
| | | if err = sock.Dial(url);err !=nil { |
|---|
| | | logger.Debug("can't dial on req socket:%s",err.Error()) |
|---|
| | | return nil |
|---|
