liuxiaolong
2019-07-29 1e519b668aea20bffc959c315ee9db03843ba181
fix sock
2个文件已修改
6 ■■■■ 已修改文件
controllers/esSearch.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/FaceCompareService.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
controllers/esSearch.go
@@ -146,7 +146,7 @@
        "\"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
service/FaceCompareService.go
@@ -13,7 +13,6 @@
    "sort"
    "strconv"
    "sync"
    "time"
    "webserver/extend/config"
    "webserver/extend/logger"
    "webserver/extend/util"
@@ -157,7 +156,8 @@
    }
    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