From 88e467b44140cfd4cac253b0672cda954f7ac922 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期一, 01 七月 2019 17:03:51 +0800 Subject: [PATCH] 改方法名 --- main.go | 25 +++++++++++++++++++------ 1 files changed, 19 insertions(+), 6 deletions(-) diff --git a/main.go b/main.go index 363391c..2518815 100644 --- a/main.go +++ b/main.go @@ -2,6 +2,7 @@ import ( "fmt" + "log" "ruleprocess/insertdata" "ruleprocess/ruleserver" "ruleprocess/util" @@ -9,15 +10,19 @@ "basic.com/pubsub/protomsg.git" "basic.com/valib/deliver.git" "github.com/golang/protobuf/proto" - "sync" ) func main() { - wg := sync.WaitGroup{} - wg.Add(1) - go ruleserver.TimeTicker() - nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) - wg.Wait() + //wg := sync.WaitGroup{} + //wg.Add(1) + //go ruleserver.TimeTicker() + //nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) + //wg.Wait() + resp,err := util.DrawPolygonOnImage() + if err != nil { + log.Println("鐢绘鎴栬�呬笂浼犳湁闂") + } + log.Println(resp["fileUrl"].(string)) } func nReciever(url string, m deliver.Mode, count int) { c := deliver.NewServer(m, url) @@ -79,6 +84,14 @@ panic("瑙f瀽msg鏃跺嚭鐜伴敊璇�") } args.CameraId = m.Cid + // 鎶婂浘鐗囩殑浜岃繘鍒惰В鍘嬬缉杩涜鐢绘鍦ㄥ帇缂╁洖鍘� + bdata, err := util.UnCompress(m.Data) + if err != nil { + panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") + } + i := protomsg.Image{} + err = proto.Unmarshal(bdata, &i) + for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo绠楁硶 if sdkinfo.Sdktype == "Yolo" { arg := ruleserver.SdkData{} -- Gitblit v1.8.0