From c3b12de28b5c9dd01841cf34033b871d20edc8f7 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 01 七月 2019 17:06:40 +0800
Subject: [PATCH] 挪到main下测

---
 105.jpg |    0 
 main.go |  116 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 115 insertions(+), 1 deletions(-)

diff --git a/105.jpg b/105.jpg
new file mode 100644
index 0000000..c5e3e68
--- /dev/null
+++ b/105.jpg
Binary files differ
diff --git a/main.go b/main.go
index 2518815..bad642c 100644
--- a/main.go
+++ b/main.go
@@ -1,11 +1,23 @@
 package main
 
 import (
+	"bufio"
+	"bytes"
+	"encoding/json"
+	"errors"
 	"fmt"
+	"gocv.io/x/gocv"
+	"image"
+	"image/color"
+	"io"
 	"log"
+	"mime/multipart"
+	"net/http"
+	"os"
 	"ruleprocess/insertdata"
 	"ruleprocess/ruleserver"
 	"ruleprocess/util"
+	"time"
 
 	"basic.com/pubsub/protomsg.git"
 	"basic.com/valib/deliver.git"
@@ -18,7 +30,7 @@
 	//go ruleserver.TimeTicker()
 	//nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
 	//wg.Wait()
-	resp,err := util.DrawPolygonOnImage()
+	resp,err := DrawPolygonOnImage()
 	if err != nil {
 		log.Println("鐢绘鎴栬�呬笂浼犳湁闂")
 	}
@@ -208,4 +220,106 @@
 
 	}
 	return m
+}
+
+func DrawPolygonOnImage()(maps map[string]interface{}, err0 error){
+	// draw the rook
+	//rook := gocv.NewMatWithSize(w, w, gocv.MatTypeCV8UC3)
+	//imgs := gocv.NewMat()
+	ddd, err := RetrieveROM("./l05.jpg")
+	if err != nil {
+		fmt.Println("瑙ｇ爜鏈夎",err)
+	}
+	bbb := bytes.NewBuffer(ddd)  // 蹇呴』鍔犱竴涓猙uffer 涓嶇劧娌℃湁read鏂规硶灏变細鎶ラ敊
+	rook, _ := gocv.NewMatFromBytes(500, 500, gocv.MatTypeCV8UC3, bbb.Bytes())
+	defer rook.Close()
+	green := color.RGBA{0, 255, 0, 0}
+	points := [][]image.Point{
+		{
+			image.Pt(100., 100),
+			image.Pt(100., 400),
+			image.Pt(400, 400),
+			image.Pt(400, 100),
+		},
+	}
+	gocv.FillPoly(&rook, points, green)
+	// 涓婁紶
+	fdata,_ := gocv.IMEncode(".jpg",rook)
+	body := &bytes.Buffer{}
+	writer := multipart.NewWriter(body)
+	_, err1 := writer.CreateFormFile("file", "fasjuierf")
+	if err1 != nil {
+		return nil, err1
+	}
+	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))
+	file := bytes.NewBuffer(fdata)
+	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.Header.Add("Content-Type", writer.FormDataContentType())
+	timeout := time.Duration(5 * time.Second) //瓒呮椂鏃堕棿50ms
+	client := &http.Client{Timeout: timeout}
+	resp, err := client.Do(request)
+	if err != nil {
+		log.Fatal(err)
+		return nil, err
+	}
+	defer func() {
+		if r := recover(); r != nil {
+			fmt.Printf("panic鐨勫唴瀹�%v\n", r)
+			msg := "涓婁紶鍥剧墖鏈嶅姟鍣ㄥ紓甯�"
+			if _, ok := r.(error); ok {
+				msg = r.(error).Error()
+				fmt.Println("panic--recover()寰楀埌鐨勬槸error绫诲瀷")
+			}
+			if _, ok := r.(string); ok {
+				msg = r.(string)
+				fmt.Println("panic--recover()寰楀埌鐨勬槸string绫诲瀷")
+			}
+			err0 = errors.New(msg)
+		}
+	}()
+	defer resp.Body.Close()
+	{
+		body := &bytes.Buffer{}
+		_, err := body.ReadFrom(resp.Body)
+		if err != nil {
+			log.Fatal(err)
+		}
+		fmt.Println(resp.StatusCode)
+		//fmt.Println(resp.Header)
+		fmt.Println(body)
+		//decoder := json.NewDecoder(strings.NewReader(body.String()))
+		decoder := make(map[string]interface{})
+		if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil {
+			return nil, err
+		}
+		return decoder, nil
+	}
+}
+
+// 鎶婂浘鐗囪浆鎴愪簩杩涘埗娴�
+func RetrieveROM(filename string) ([]byte, error) {
+	file, err := os.Open(filename)
+
+	if err != nil {
+		return nil, err
+	}
+	defer file.Close()
+
+	stats, statsErr := file.Stat()
+	if statsErr != nil {
+		return nil, statsErr
+	}
+
+	var size int64 = stats.Size()
+	bytes := make([]byte, size)
+
+	bufr := bufio.NewReader(file)
+	_, err = bufr.Read(bytes)
+
+	return bytes, err
 }
\ No newline at end of file

--
Gitblit v1.8.0