| | |
| | | "net/http" |
| | | _ "net/http/pprof" |
| | | "ruleprocess/insertdata" |
| | | "ruleprocess/logger" |
| | | "ruleprocess/structure" |
| | | "ruleprocess/util" |
| | | "time" |
| | |
| | | "flag" |
| | | "fmt" |
| | | "github.com/golang/protobuf/proto" |
| | | "basic.com/valib/logger.git" |
| | | //"gocv.io/x/gocv" |
| | | //"image" |
| | | //"image/color" |
| | |
| | | } else { |
| | | //runtime.GOMAXPROCS(runtime.NumCPU()) |
| | | //logger.Debug("使用的cpu个数:",runtime.NumCPU()) |
| | | //go func(msg []byte) { |
| | | go func(msg []byte) { |
| | | logger.Debug("当前时间戳:", time.Now().Unix()) |
| | | arg := structure.SdkDatas{} |
| | | //paramFormat(msg, &arg) |
| | |
| | | logger.Debug("插入完Es所用时间:", time.Since(start)) |
| | | //事件推送 |
| | | //go labelFilter.Judge(resultMsg) |
| | | //}(msg) |
| | | logger.OutPutByPanlei() |
| | | }(msg) |
| | | } |
| | | } |
| | | } |
| | |
| | | for _, info := range yoloParam.Infos { |
| | | if info.Typ == 0 { |
| | | //logger.Debug("-------------yolo的坐标有几个",info.RcObj) |
| | | photoMap := structure.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob) * 100, IsYolo: true} |
| | | photoMap := structure.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob) * 100, IsYolo: true,Id:info.ObjID} |
| | | arg.Photo = append(arg.Photo, photoMap) |
| | | yoloNum++ |
| | | } |