| | |
| | | } |
| | | |
| | | func (api Gb28181Api) Edit(paramBody map[string]interface{}) bool { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/configEdit" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | flag := false |
| | | url := DATA_URL_PREFIX + "/gb28181/configEdit" |
| | | client := NewClient(WithNodes(netNode)) |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) |
| | | if err != nil { |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) FindAreaByParentId(parentId string) (bool,interface{}) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/findAreaByParentId" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) |
| | | if netNode == nil { |
| | | return false, nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/gb28181/findAreaByParentId" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramMap := make(map[string]string, 0) |
| | | paramMap["parentId"] = parentId |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) NewGbId(code string) (bool,interface{}) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/newGbId" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) |
| | | if netNode == nil { |
| | | return false, nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/gb28181/newGbId" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramMap := make(map[string]string, 0) |
| | | paramMap["code"] = code |
| | |
| | | //searchType(0:全部,1:分析摄像机,2:监控摄像机) |
| | | //cameraName(摄像机名称) |
| | | func (api Gb28181Api) GetGb28181CameraTree(parentId string, searchType string, cameraName string) []TreeMenu { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/tree" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) |
| | | if netNode == nil { |
| | | return nil |
| | | } |
| | |
| | | |
| | | client := NewClient(WithNodes(netNode)) |
| | | |
| | | url := DATA_URL_PREFIX + "/gb28181/gb28181Tree" |
| | | params := make(map[string]string, 0) |
| | | params["parentId"] = parentId |
| | | params["searchType"] = searchType |
| | |
| | | |
| | | //国标树刷新 |
| | | func (api Gb28181Api) Gb28181TreeRefresh(id string) bool { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/treeRefresh" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | flag := false |
| | | url := DATA_URL_PREFIX + "/gb28181/gb28181TreeRefresh" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody := map[string]interface{}{ |
| | | "id":id, |
| | |
| | | |
| | | //国标树删除 |
| | | func (api Gb28181Api) Gb28181TreeDelete() bool { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/treeDelete" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | flag := false |
| | | url := DATA_URL_PREFIX + "/gb28181/gb28181TreeDelete" |
| | | client := NewClient(WithNodes(netNode)) |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, nil, nil, nil) |
| | | if err != nil { |
| | |
| | | |
| | | //获取本节点的所有国标摄像机 |
| | | func (api Gb28181Api) GetAllCamerasByServer(serverId string,cameraName string) (b bool,cams []protomsg.Camera) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/getAllCamerasByServer" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service,url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/gb28181/getAllCamerasByServer" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramQuery := make(map[string]string,0) |
| | | paramQuery["serverId"] = serverId |
| | |
| | | |
| | | //查找地图上的国标摄像机 |
| | | func (api Gb28181Api) FindOnMap(isOnMap bool, floor int, cameraName string) (b bool, cams []protomsg.Camera) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/findOnMap" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/camera/findOnMap" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody:= map[string]interface{}{ |
| | | "isOnMap": isOnMap, |
| | |
| | | |
| | | //更新摄像机经纬度以及楼层 |
| | | func (api Gb28181Api) UpdatePos(id string, floor int, longitude float32, latitude float32) bool { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updatePos" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | url := DATA_URL_PREFIX + "/camera/updatePos" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody:= map[string]interface{}{ |
| | | "id": id, |
| | |
| | | |
| | | //查集群内所有国标摄像机 |
| | | func (api Gb28181Api) NodeCamera() (bool, interface{}) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/nodeCamera" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/camera/nodeCamera" |
| | | client := NewClient(WithNodes(netNode)) |
| | | body, err := client.DoGetRequest(url, nil, nil) |
| | | if err != nil { |
| | |
| | | |
| | | //通过id获取国标进程中的摄像机坐标设置 |
| | | func (api Gb28181Api) Coord(cameraId string) (bool, interface{}) { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/coord" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | url := DATA_URL_PREFIX + "/camera/coord" |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramQuery := map[string]string { |
| | | "cameraId": cameraId, |
| | |
| | | |
| | | //更新国标进程中摄像机的转换坐标 |
| | | func (api Gb28181Api) UpdateCoord(paramBody map[string]interface{}) bool { |
| | | netNode := getNetNode(Topic_Gb28181_Service) |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateCoord" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | url := DATA_URL_PREFIX + "/camera/updateCoord" |
| | | client := NewClient(WithNodes(netNode)) |
| | | body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) |
| | | if err != nil { |
| | |
| | | |
| | | |
| | | func (api Gb28181Api) CameraUpdate(paramBody map[string]interface{}) bool { |
| | | url := DATA_URL_PREFIX + "/camera/update" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/update" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) UpdateSnapshotUrl(cameraId string, snapshot string) bool { |
| | | url := DATA_URL_PREFIX + "/camera/updateSnapshot" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateSnapshot" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | |
| | | |
| | | //通过cameraId获取摄像机信息 |
| | | func (api Gb28181Api) GetCameraById(cameraId string) (camera protomsg.Camera, err error) { |
| | | url := DATA_URL_PREFIX + "/camera/show" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/show" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return camera,errors.New("gb28181-service not found") |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) UpdateCameraArea(cameraId string, areaId string) bool { |
| | | url := DATA_URL_PREFIX + "/camera/updateCameraArea" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateCameraArea" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) FindAll() (cameras []protomsg.Camera) { |
| | | url := DATA_URL_PREFIX + "/camera/showAll" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/showAll" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return nil |
| | |
| | | //根据运行类型获取摄像机列表 |
| | | //runType(0:获取轮询列表,1:获取实时列表) |
| | | func (api Gb28181Api) GetCamerasByRunType(runType int,cameraName string)(flag bool,cameras []protomsg.Camera){ |
| | | url := DATA_URL_PREFIX + "/camera/getCamerasByRunType" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/getCamerasByRunType" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) UpdateRunEnable(cameraId string,runEnable bool) (bool,interface{}){ |
| | | url := DATA_URL_PREFIX + "/camera/updateRunEnable" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateRunEnable" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false, nil |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) UpdateIsRunningState(cameraId string,isRunning bool) (bool,interface{}){ |
| | | url := DATA_URL_PREFIX + "/camera/updateIsRunningState" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateIsRunningState" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | |
| | | } |
| | | |
| | | func (api Gb28181Api) UpdateIsRunningAll(cameraIds []string) (bool,interface{}){ |
| | | url := DATA_URL_PREFIX + "/camera/updateIsRunningAll" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/updateIsRunningAll" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | |
| | | |
| | | //批量切换摄像机轮询或实时状态 |
| | | func (api Gb28181Api) ChangeRunType(paramBody map[string]interface{}) (bool,interface{}){ |
| | | url := DATA_URL_PREFIX + "/camera/changeRunType" |
| | | url := DATA_URL_PREFIX + "/gb28181/camera/changeRunType" |
| | | netNode := getNetNode(url2Topic(Topic_Gb28181_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |