| | |
| | | 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]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) |
| | | respBody, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil) |
| | | if err != nil { |
| | | return false,nil |
| | | } |
| | |
| | | "io/ioutil" |
| | | "log" |
| | | "net/http" |
| | | "strings" |
| | | "github.com/ajg/form" |
| | | ) |
| | | |
| | | type HttpClient struct{} |
| | |
| | | //发起POST请求 |
| | | func (httpApi HttpClient) DoPostRequest(url string, contentType string, body map[string]interface{}, params map[string]string, headers map[string]string) ([]byte, error) { |
| | | var resultBytes []byte |
| | | var request *http.Request |
| | | var err error |
| | | if contentType == CONTENT_TYPE_FORM || contentType == CONTENT_TYPE_MULFORM { |
| | | formData,err := form.EncodeToString(body) |
| | | if err !=nil { |
| | | return resultBytes,err |
| | | } |
| | | request, err = http.NewRequest("POST",url,strings.NewReader(formData)) |
| | | if err !=nil { |
| | | return resultBytes,err |
| | | } |
| | | } else { |
| | | var bodyJson []byte |
| | | if body != nil { |
| | | var err error |
| | |
| | | return resultBytes, err |
| | | } |
| | | } |
| | | request, err := http.NewRequest("POST", url, bytes.NewBuffer(bodyJson)) |
| | | request, err = http.NewRequest("POST", url, bytes.NewBuffer(bodyJson)) |
| | | if err != nil { |
| | | return resultBytes, err |
| | | } |
| | | } |
| | | |
| | | request.Header.Set("Content-type", contentType) |
| | | //add params |
| | | q := request.URL.Query() |