| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | pmax, exist := source["picMaxUrl"].(string) |
|---|
| | | //fmt.Println("picMaxUrl: ",pmax) |
|---|
| | | if !exist { |
|---|
| | | return errors.New("picMaxurl is not string"), nil |
|---|
| | | } |
|---|
| | |
|---|
| | | if !exist { |
|---|
| | | return errors.New("picSmUrl is not string"), nil |
|---|
| | | } |
|---|
| | | |
|---|
| | | //fmt.Println("picSmUrl: ",psm) |
|---|
| | | if !strings.HasPrefix(psm, "http") { |
|---|
| | | source["picSmUrl"] = picurl + psm |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | func getVideoUrl(source map[string]interface{}) (videoUrl string) { |
|---|
| | | func getVideoUrl(source map[string]interface{}) (videoUrl string){ |
|---|
| | | imgKey := source["imgKey"].(string) |
|---|
| | | picDte := source["picDate"].(string) //抓拍日期 |
|---|
| | | cameraId := source["videoReqNum"].(string) //摄像机id |
|---|
| | | indeviceId := source["indeviceid"].(string) //分析设备id |
|---|
| | | picDte := source["picDate"].(string)//抓拍日期 |
|---|
| | | cameraId := source["videoReqNum"].(string)//摄像机id |
|---|
| | | indeviceId := source["indeviceid"].(string)//分析设备id |
|---|
| | | deviceMap := make(map[string]string,0) |
|---|
| | | deviceMap["DSVAD010120181119"] = "http://172.17.50.241:11111/getRecordVideoPath" |
|---|
| | | deviceMap["DSVAD010220181119"] = "http://172.17.50.242:11111/getRecordVideoPath" |
|---|
| | | deviceMap["DSVAD010320181119"] = "http://172.17.50.243:11111/getRecordVideoPath" |
|---|
| | | deviceMap["DSVAD010420181119"] = "http://172.17.50.244:11111/getRecordVideoPath" |
|---|
| | | |
|---|
| | | var deviceMap map[string]string |
|---|
| | | deviceMap["DSVAD010120181119"] = "http://58.118.225.79:41241/ManCarAnaly/perVideoPic/uploadRtnVideo" |
|---|
| | | deviceMap["DSVAD010220181119"] = "http://58.118.225.79:41242/ManCarAnaly/perVideoPic/uploadRtnVideo" |
|---|
| | | deviceMap["DSVAD010320181119"] = "http://58.118.225.79:41243/ManCarAnaly/perVideoPic/uploadRtnVideo" |
|---|
| | | deviceMap["DSVAD010420181119"] = "http://58.118.225.79:41244/ManCarAnaly/perVideoPic/uploadRtnVideo" |
|---|
| | | ngxMap := make(map[string]string,0) |
|---|
| | | ngxMap["DSVAD010120181119"] = "http://58.118.225.79:44180/videosource" |
|---|
| | | ngxMap["DSVAD010220181119"] = "http://58.118.225.79:44280/videosource" |
|---|
| | | ngxMap["DSVAD010320181119"] = "http://58.118.225.79:44380/videosource" |
|---|
| | | ngxMap["DSVAD010420181119"] = "http://58.118.225.79:44480/videosource" |
|---|
| | | |
|---|
| | | |
|---|
| | | reqUrl := deviceMap[indeviceId] |
|---|
| | | var paramMap map[string]interface{} |
|---|
| | | paramMap := make(map[string]interface{},0) |
|---|
| | | paramMap["imgKey"] = imgKey |
|---|
| | | paramMap["picDate"] = picDte |
|---|
| | | paramMap["videoPath"] = cameraId |
|---|
| | | paramMap["videoNum"] = cameraId |
|---|
| | | |
|---|
| | | respBytes, err := doPostRequest(reqUrl, "application/x-www-form-urlencoded", paramMap, nil, nil) |
|---|
| | | if err != nil { |
|---|
| | | respBytes, err := doPostRequest(reqUrl, "application/json", paramMap, nil, nil) |
|---|
| | | if err !=nil{ |
|---|
| | | return "" |
|---|
| | | } |
|---|
| | | var resp RespVideo |
|---|
| | | err = json.Unmarshal(respBytes, &resp) |
|---|
| | | if err != nil { |
|---|
| | | if err !=nil { |
|---|
| | | return "" |
|---|
| | | } |
|---|
| | | return resp.VideoPath |
|---|
| | | filePath := resp.FilePath |
|---|
| | | |
|---|
| | | if !strings.Contains(filePath, "/cut"){ |
|---|
| | | return "" |
|---|
| | | } else { |
|---|
| | | strArr := strings.Split(filePath, "/cut") |
|---|
| | | ngxUrl := ngxMap[indeviceId] |
|---|
| | | if ngxUrl !="" && len(strArr) >0 { |
|---|
| | | return ngxUrl + strArr[1] |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | return "" |
|---|
| | | } |
|---|
| | | |
|---|
| | | type RespVideo struct { |
|---|
| | | Code int32 `json:"code"` |
|---|
| | | ErrorStr string `json:"errorStr"` |
|---|
| | | Msg string `json:"msg"` |
|---|
| | | Resp interface{} |
|---|
| | | Status string `json:"status"` |
|---|
| | | VideoPath string `json:"videoPath"` |
|---|
| | | type RespVideo struct{ |
|---|
| | | FilePath string `json:"file_path"` |
|---|
| | | } |
|---|
| | | |
|---|
| | | func doPostRequest(url string, contentType string, body map[string]interface{}, params map[string]string, headers map[string]string) ([]byte, error) { |
|---|
| | | var resultBytes []byte |
|---|
| | | var bodyJson []byte |
|---|
| | |
|---|
| | | seccond := strconv.Itoa(sec) |
|---|
| | | |
|---|
| | | prama := "{\"query\":{\"bool\":{\"filter\":[{\"term\":{\"personIsHub\":\"1\"}},{\"range\":{\"picDate\":{\"gte\":\"now+8h-" + seccond + "s\",\"lt\":\"now+8h\"}}}]}},\"size\":\"1000\",\"sort\":[{\"picDate\":{\"order\":\"desc\"}}]," + |
|---|
| | | "\"_source\":[\"baseInfo\",\"gender\",\"indeviceName\",\"imageKey\",\"sdkType\",\"ageDescription\",\"indeviceid\",\"content\",\"ID\",\"picAddress\",\"picMaxUrl\",\"picDate\",\"race\",\"videoNum\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"IDCard\",\"videoIp\",\"videoReqNum\"]" + |
|---|
| | | "\"_source\":[\"baseInfo\",\"gender\",\"indeviceName\",\"imgKey\",\"sdkType\",\"ageDescription\",\"indeviceid\",\"content\",\"ID\",\"picAddress\",\"picMaxUrl\",\"picDate\",\"race\",\"videoNum\",\"picSmUrl\",\"taskName\",\"personIsHub\",\"IDCard\",\"videoIp\",\"videoReqNum\"]" + |
|---|
| | | "}" |
|---|
| | | err, tokenRes := GetEsDataReq(url, prama, picurl, true) |
|---|
| | | |
|---|
