| | |
| | | |
| | | func TestPushImgMsg() { |
| | | InitService() |
| | | proImg := readImgFile() |
| | | |
| | | if b, err := proto.Marshal(&proImg);err !=nil{ |
| | | i := readImgFile() |
| | | fmt.Printf("width:%d,height:%d,data.length:%d,timestamp:%s,id:%d\n",i.Width,i.Height,len(i.Data),i.Timestamp,i.Id) |
| | | if b, err := proto.Marshal(&i);err !=nil{ |
| | | fmt.Println("protoImage marshal err") |
| | | return |
| | | } else { |
| | | bc := make([]byte,len(b)) |
| | | ht := make([]int, 64<<10) |
| | | n,err := lz4.CompressBlock(b,bc,ht) |
| | | n,err := lz4.CompressBlock(b, bc, ht) |
| | | if err !=nil { |
| | | fmt.Println(err) |
| | | } |
| | |
| | | fmt.Println("file not exist") |
| | | return i |
| | | } |
| | | height := int32(picMat.Rows()) |
| | | width := int32(picMat.Cols()) |
| | | data := picMat.ToBytes() |
| | | //wrMat,_ := gocv.NewMatFromBytes(picMat.Rows(),picMat.Cols(),gocv.MatTypeCV8UC3,data) |
| | | // |
| | | //gocv.IMWrite("xxx.jpg", wrMat) |
| | | |
| | | i = protomsg.Image{ |
| | | Width:int32(picMat.Rows()), |
| | | Height:int32(picMat.Cols()), |
| | | Timestamp:formatTimeStr, |
| | | Data:[]byte(picMat.DataPtrUint8()), |
| | | Width: width, |
| | | Height: height, |
| | | Timestamp: formatTimeStr, |
| | | Data: data, |
| | | Id: timeUnix, |
| | | } |
| | | fmt.Println("gocv read img completed") |
| | | return i |
| | | } |
| | | |
| | |
| | | sdkInfos := rMsg.Tasklab.Sdkinfos |
| | | fmt.Println("Len(sdkInfos)=",len(sdkInfos)) |
| | | for _,swt :=range sdkInfos{ |
| | | fmt.Println("sdkName:",swt.SdkName) |
| | | if swt.Sdktype =="FaceDetect"{ |
| | | fmt.Println("人脸检测结果") |
| | | var rfd protomsg.ResultFaceDetect |
| | | err := proto.Unmarshal(swt.Sdkdata, &rfd) |
| | | if err !=nil { |
| | | fmt.Println("faceDetect result unmarshal err:",err) |
| | | } else { |
| | | fmt.Println("FacePos:",rfd.Pos) |
| | | fmt.Println("ThftResult:",rfd.Result) |
| | | } |
| | | } |
| | | if swt.Sdktype == "FaceExtract"{ |
| | | fmt.Println("sdkName:",swt.SdkName) |
| | | |
| | | fmt.Println("sdkData.len:",len(swt.Sdkdata)) |
| | | var pff protomsg.ParamFaceFeature |
| | | if err := proto.Unmarshal(swt.Sdkdata, &pff);err !=nil{ |
| | | fmt.Println("ParamFaceFeature unmarshal err:",err) |
| | | //fmt.Println("ParamFaceFeature unmarshal err:",err) |
| | | } else { |
| | | fmt.Println("目标数:",len(pff.ExtComp)) |
| | | for _,fea :=range pff.ExtComp{ |