改图片服务器地址

panlei

2019-07-17 5f48e7f9c10ed76112986b9d59c9517845df6b35

改图片服务器地址

 insertdata/insertDataToEs.go

@@ -307,7 +307,7 @@
        if len(alarmRules) > 0 {
            isAlarm = 1
            //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
            resp, err = util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result))
            resp, err = util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result),weedfsUrl)
            if err != nil {
                logger.Error("画框或上传图片服务器出错", err)
            } else {
@@ -382,7 +382,7 @@
    i := protomsg.Image{}
    err = proto.Unmarshal(bdata, &i)
    //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
    resp, err := util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result))
    resp, err := util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result),weedfsUrl)
    if err != nil {
        logger.Error("画框或上传图片服务器出错", err)
    } else {

 util/simpleCV.go

@@ -155,7 +155,7 @@
    }
}

func DrawPolygonOnImage(cameraId string, img protomsg.Image, results []ruleserver.Result) (maps map[string]interface{}, err0 error) {
func DrawPolygonOnImage(cameraId string, img protomsg.Image, results []ruleserver.Result,url string) (maps map[string]interface{}, err0 error) {

    rook, _ := gocv.NewMatFromBytes(int(img.Height), int(img.Width), gocv.MatTypeCV8UC3, img.Data)
    //rook := gocv.IMRead("/home/user/workspace/ruleprocess/util/105.jpg",gocv.IMReadColor)
@@ -182,7 +182,7 @@
        }
    }
    //return nil,nil
    maps,err0 = UploadFromMat(rook)
    maps,err0 = UploadFromMat(url,rook)
    return
}


 util/upload.go

@@ -137,7 +137,7 @@
    }
}

func UploadFromMat(rook gocv.Mat)(maps map[string]interface{}, err0 error){
func UploadFromMat(url string,rook gocv.Mat)(maps map[string]interface{}, err0 error){
    // 上传
    fdata, _ := gocv.IMEncode(".jpg", rook)
    body := &bytes.Buffer{}
@@ -153,7 +153,7 @@
    request_reader := io.MultiReader(body, file, close_buf)
    //_, err = io.Copy(part, file)
    //writer.WriteField(key, val)
    request, err := http.NewRequest("POST", "http://192.168.1.182:6333/submit", request_reader)
    request, err := http.NewRequest("POST", url, request_reader)
    request.Header.Add("Content-Type", writer.FormDataContentType())
    timeout := time.Duration(5 * time.Second) //超时时间50ms
    client := &http.Client{Timeout: timeout}