| | |
| | | "gocv.io/x/gocv" |
| | | "image" |
| | | "image/color" |
| | | "log" |
| | | "os" |
| | | "ruleprocess/cache" |
| | | "ruleprocess/insertdata" |
| | |
| | | ) |
| | | var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip") |
| | | var dbPort = flag.Int("dbPort",8001,"default dbPort=8001") |
| | | var surveyPort = flag.Int("surveyPort",40007,"survey port") |
| | | var pubPort = flag.Int("pubPort",50007,"pubsub port") |
| | | var surveyPort = flag.Int("surveyPort",40007,"survey port") //心跳 |
| | | var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新 |
| | | var initchan = make(chan bool) |
| | | func main() { |
| | | flag.Parse() |
| | |
| | | arg.IsStatic = false |
| | | if len(sdkinfo.Sdkdata) > 1 { |
| | | // 大于1才有数据 |
| | | fmt.Println("----------------------------------------------------",m.Cid) |
| | | yoloParam := protomsg.ParamYoloObj{} |
| | | err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam) |
| | | if err != nil { |
| | | fmt.Println("解析YOLO sdk数据时出现错误", err) |
| | | continue |
| | | } |
| | | log.Println("--------------------看看yolo中有几个目标:",len(yoloParam.Infos)) |
| | | for _, info := range yoloParam.Infos { |
| | | if info.Typ == 0 { |
| | | photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob)*100,IsYolo:true} |