tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-05-29 c15c349e0274096ea08f0bf2dd3e895c42a98570
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]
      }
   }
   if videoUrl == "" {
   fmt.Println("videoReqUrl: ",reqUrl)
   fmt.Println("video: ",videoUrl)
      fmt.Printf("imgKey:%s ,picDate:%s ,cameraId:%s ",imgKey,picDate,cameraId)
   }
   return videoUrl
}