| | |
| | | "log" |
| | | "mime/multipart" |
| | | "net/http" |
| | | "strconv" |
| | | "strings" |
| | | "time" |
| | | |
| | |
| | | for _, value := range dat["hits"].([]interface{}) { |
| | | source := value.(map[string]interface{})["_source"].(map[string]interface{}) |
| | | source["id"] = value.(map[string]interface{})["_id"] |
| | | sdkType := source["sdkType"] |
| | | /*sdkType := source["sdkType"] |
| | | if sdkType != nil { |
| | | sdk, _ := strconv.Atoi(sdkType.(string)) |
| | | source["sdkType"] = sdkTypeToValue(sdk) |
| | | } |
| | | }*/ |
| | | sources = append(sources, source) |
| | | } |
| | | data["datalist"] = sources |
| | |
| | | } |
| | | |
| | | //sdk类型 |
| | | func sdkTypeToValue(i int) string { |
| | | /*func sdkTypeToValue(i int) string { |
| | | value := []string{"人脸", "车辆", "人体", "入侵", "拥挤", "靠右行", "人员异常", "个体静止"} |
| | | return value[i-1] |
| | | } |
| | | }*/ |
| | | |
| | | func PutEsDataReq(url string, parama string) (map[string]interface{}, error) { |
| | | //fmt.Println("es 查询请求路径" + url) // 配置信息 获取 |
| | |
| | | return dat, nil |
| | | } |
| | | |
| | | func PostFormData(uri string, filename, paramName string, file multipart.File) (maps map[string]interface{}, err0 error) { |
| | | func PostFormData(uri string, filename, paramName string, fileBytes []byte) (maps map[string]interface{}, err0 error) { |
| | | body := &bytes.Buffer{} |
| | | writer := multipart.NewWriter(body) |
| | | _, err := writer.CreateFormFile(paramName, filename) |
| | |
| | | return nil, err |
| | | } |
| | | boundary := writer.Boundary() |
| | | //close_string := fmt.Sprintf("\r\n--%s--\r\n", boundary) |
| | | close_buf := bytes.NewBufferString(fmt.Sprintf("\r\n--%s--\r\n", boundary)) |
| | | fmt.Println("PostFormData.fileLen:",len(fileBytes)) |
| | | file := bytes.NewBuffer(fileBytes) |
| | | request_reader := io.MultiReader(body, file, close_buf) |
| | | //_, err = io.Copy(part, file) |
| | | //writer.WriteField(key, val) |
| | | |
| | | request, err := http.NewRequest("POST", uri, request_reader) |
| | | request.Header.Add("Content-Type", writer.FormDataContentType()) |
| | | timeout := time.Duration(5 * time.Second) //超时时间50ms |