| | |
| | | |
| | | import ( |
| | | "fmt" |
| | | "log" |
| | | "ruleprocess/insertdata" |
| | | "ruleprocess/ruleserver" |
| | | "ruleprocess/util" |
| | |
| | | "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) |