| | |
| | | ) |
| | | |
| | | type CameraTaskApi struct { |
| | | Ip string |
| | | Port int |
| | | } |
| | | |
| | | func (api CameraTaskApi) getBasicUrl() string { |
| | | if api.Ip == "" { |
| | | return BASIC_URL |
| | | } |
| | | if api.Ip == "" { |
| | | api.Ip = DEFAULT_IP |
| | | } |
| | | if api.Port == 0 { |
| | | api.Port = DEFAULT_PORT |
| | | } |
| | | return "http://"+api.Ip+":"+strconv.Itoa(api.Port) |
| | | } |
| | | |
| | | func (api CameraTaskApi) AddTask(cameraId string,taskId string) (bool,interface{}) { |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/addTask" |
| | | client := NewClient() |
| | | paramBody := map[string]interface{}{ |
| | | "cameraId": cameraId, |
| | | "taskId": taskId, |
| | | } |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody,nil,nil) |
| | | if err != nil { |
| | | return false,nil |
| | | } |
| | | var res Result |
| | | if err = json.Unmarshal(respBody, &res); err != nil { |
| | | return false,nil |
| | | } |
| | | return res.Success,res.Data |
| | | } |
| | | |
| | | func (api CameraTaskApi) CameraTaskSave(paramBody map[string]interface{}) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/saveTask" |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/saveTask" |
| | | client := NewClient() |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil) |
| | | if err != nil { |
| | |
| | | return res.Success,res.Data |
| | | } |
| | | |
| | | func (api CameraTaskApi) PasteRules(sourceId string, targetIds []string) bool { |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/pasteRules" |
| | | client := NewClient() |
| | | paramBody := map[string]interface{} { |
| | | "sourceId": sourceId, |
| | | "targetIds": targetIds, |
| | | } |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil) |
| | | if err != nil { |
| | | return false |
| | | } |
| | | var res Result |
| | | if err = json.Unmarshal(respBody, &res); err != nil { |
| | | return false |
| | | } |
| | | return res.Success |
| | | } |
| | | |
| | | func (api CameraTaskApi) FindTasksByCameraIds(cameraIds []string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/alltask" |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/alltask" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]interface{}) |
| | | paramBody["cameraIds"] = cameraIds |
| | |
| | | } |
| | | |
| | | func (api CameraTaskApi) CameraTaskAll(cameraId string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/task/"+cameraId |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/task/"+cameraId |
| | | client := NewClient() |
| | | paramQuery :=make(map[string]string) |
| | | paramQuery["cameraId"] = cameraId |
| | |
| | | } |
| | | |
| | | func (api CameraTaskApi) DeleteCameraTask(cameraId string,taskId string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId |
| | | client := NewClient() |
| | | respBody, err := client.DoPutRequest(url, CONTENT_TYPE_FORM, nil,nil) |
| | | respBody, err := client.DoDeleteRequest(url, CONTENT_TYPE_FORM, nil,nil) |
| | | if err != nil { |
| | | return false,nil |
| | | } |
| | |
| | | } |
| | | |
| | | func (api CameraTaskApi) SaveIsDataTrans(paramBody map[string]interface{}) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans" |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans" |
| | | client := NewClient() |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody,nil, nil) |
| | | if err != nil { |
| | |
| | | } |
| | | |
| | | func (api CameraTaskApi) SaveAlarmLevelByGroup(groupId string,alarmLevel int) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup" |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]interface{},0) |
| | | paramBody["group_id"] = groupId |
| | |
| | | |
| | | //更新摄像机任务状态 |
| | | func (api CameraTaskApi) UpdateCameraTaskStatus(cameraId string,taskId string,statusInt int) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus" |
| | | url := api.getBasicUrl() + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]string) |
| | | paramBody :=make(map[string]interface{}) |
| | | paramBody["cameraId"] = cameraId |
| | | paramBody["taskId"] = taskId |
| | | paramBody["status"] = strconv.Itoa(statusInt) |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, nil, paramBody, nil) |
| | | paramBody["status"] = statusInt |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil) |
| | | if err != nil { |
| | | return false,nil |
| | | } |