tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-05-29 c15c349e0274096ea08f0bf2dd3e895c42a98570
fix bug
1个文件已修改
12 ■■■■■ 已修改文件
esutil/EsClient.go 12 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
esutil/EsClient.go
@@ -108,7 +108,6 @@
            source["ageDescription"] = getAgeDesc(source["Age"])
            source["videoNum"] = getVideoUrl(source)
            fmt.Println("BaseName: ", source["BaseName"])
            picDate := source["picDate"].(string)
            lastIdx := strings.LastIndex(picDate,":")
            picDateStr := picDate[:lastIdx]
@@ -217,7 +216,7 @@
func getVideoUrl(source map[string]interface{}) (videoUrl string){
    imgKey := source["imgKey"].(string)
    picDte := source["picDate"].(string)//抓拍日期
    picDate := source["picDate"].(string)//抓拍日期
    cameraId := source["videoReqNum"].(string)//摄像机id
    indeviceId := source["indeviceid"].(string)//分析设备id
    deviceMap := make(map[string]string,0)
@@ -236,7 +235,7 @@
    reqUrl := deviceMap[indeviceId]
    paramMap := make(map[string]interface{},0)
    paramMap["imgKey"] = imgKey
    paramMap["picDate"] = picDte
    paramMap["picDate"] = picDate
    paramMap["videoNum"] = cameraId
    respBytes, err := doPostRequest(reqUrl, "application/json", paramMap, nil, nil)
@@ -259,8 +258,11 @@
            videoUrl = ngxUrl + strArr[1]
        }
    }
    fmt.Println("videoReqUrl: ",reqUrl)
    fmt.Println("video: ",videoUrl)
    if videoUrl == "" {
        fmt.Println("videoReqUrl: ",reqUrl)
        fmt.Printf("imgKey:%s ,picDate:%s ,cameraId:%s ",imgKey,picDate,cameraId)
    }
    return videoUrl
}