| | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/deliver.git" |
| | | "ruleprocess/insertdata" |
| | | "ruleprocess/labelFilter" |
| | | "ruleprocess/util" |
| | | |
| | | //"bufio" |
| | |
| | | // 将打完标签的数据插入到ES |
| | | insertdata.InsertToEs(resultMsg) |
| | | //事件推送 |
| | | //labelFilter.Judge(resultMsg) |
| | | go labelFilter.Judge(resultMsg) |
| | | } |
| | | } |
| | | } |
| | |
| | | panic("解析msg时出现错误") |
| | | } |
| | | |
| | | logger.Info("接到数据,摄像机为:",m.Cid) |
| | | // 先进行一下追踪 |
| | | //ruleserver.FaceIsSame(&m) |
| | | args.CameraId = m.Cid |
| | |
| | | logger.Info("解析FACE sdk数据时出现错误", err) |
| | | continue |
| | | } |
| | | logger.Info("--------------追踪之后yolo的个数:",len(faceParam.Faces)) |
| | | logger.Info("--------------追踪之后人脸的个数:",len(faceParam.Faces)) |
| | | for _, info := range faceParam.Faces { |
| | | //logger.Info("_______________________________________________第一次看相似值:",info.Pos.FAngle.Confidence*100) |
| | | photoMap := ruleserver.PhotoMap{Id:info.Pos.FaceID,Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.FAngle.Confidence*100), IsYolo:false,ThftRes:*(info.Result),Feature:info.Feats} |