| | |
| | | package dbapi |
| | | |
| | | import ( |
| | | "encoding/json" |
| | | "strconv" |
| | | ) |
| | | |
| | | type CameraTaskApi struct { |
| | | |
| | | } |
| | | |
| | | func (api CameraTaskApi) CameraTaskSave(paramBody map[string]interface{}) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/saveTask" |
| | | client := NewClient() |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, 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) FindTasksByCameraIds(cameraIds []string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/alltask" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]interface{}) |
| | | paramBody["cameraIds"] = cameraIds |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, 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) CameraTaskAll(cameraId string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/task/"+cameraId |
| | | client := NewClient() |
| | | paramQuery :=make(map[string]string) |
| | | paramQuery["cameraId"] = cameraId |
| | | respBody, err := client.DoGetRequest(url, paramQuery,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) DeleteCameraTask(cameraId string,taskId string) (bool,interface{}) { |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/camera/delTask/"+cameraId+"/"+taskId |
| | | client := NewClient() |
| | | respBody, err := client.DoPutRequest(url, CONTENT_TYPE_FORM, 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) SaveIsDataTrans(paramBody map[string]interface{}) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveIsDataTrans" |
| | | client := NewClient() |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, 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) SaveAlarmLevelByGroup(groupId string,alarmLevel int) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/saveAlarmLevelByGroup" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]interface{},0) |
| | | paramBody["group_id"] = groupId |
| | | paramBody["alarm_level"] = alarmLevel |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, 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) UpdateCameraTaskStatus(cameraId string,taskId string,statusInt int) (bool,interface{}){ |
| | | url := BASIC_URL + DATA_URL_PREFIX + "/cameraTask/updateCameraTaskStatus" |
| | | client := NewClient() |
| | | paramBody :=make(map[string]interface{}) |
| | | paramBody["cameraId"] = cameraId |
| | | paramBody["taskId"] = taskId |
| | | paramBody["status"] = strconv.Itoa(statusInt) |
| | | 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 |
| | | } |