派生自 ruleprocess
main.go
@@ -8,16 +8,16 @@ "bytes" "flag" "fmt" "ruleprocess/logger" "github.com/golang/protobuf/proto" "gocv.io/x/gocv" "image" "image/color" "os" "ruleprocess/cache" "ruleprocess/insertdata" "ruleprocess/ruleserver" "ruleprocess/util" "ruleprocess/logger" "ruleprocess/insertdata" "sync" ) var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip") @@ -26,23 +26,20 @@ var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新 var initchan = make(chan bool) func init () { var logFile = "./info.log" var logSaveDays = 15 // 日志初始化 logger.Config(logFile, logger.DebugLevel) logger.SetSaveDays(logSaveDays) logger.Info("loginit success !") logger.Config("./info.log", logger.DebugLevel) logger.Info("日志初始化成功！") } func main() { flag.Parse() wg := sync.WaitGroup{} wg.Add(1) wg.Add(2) dbapi.Init(*dbIp,*dbPort) go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕 fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 go ruleserver.TimeTicker() nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) @@ -76,7 +73,7 @@ } else { arg := ruleserver.SdkDatas{} m := paramFormat(msg, &arg) logger.Info("解析出来的数据：", arg) //logger.Info("解析出来的数据：", arg) ruleserver.Judge(&arg) // 把arg里的打的标签拿出来给m再封装一层 resultMag := ruleserver.ResultMsg{SdkMessage: m, RuleResult: arg.RuleResult} @@ -121,13 +118,12 @@ } i := protomsg.Image{} err = proto.Unmarshal(bdata, &i) logger.Info("----------------看看有几个算法：",len(m.Tasklab.Sdkinfos)) //logger.Info("----------------看看有几个算法：",len(m.Tasklab.Sdkinfos)) for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo算法 if sdkinfo.Sdktype == "Yolo" { arg := ruleserver.SdkData{} arg.TaskId = m.Tasklab.Taskid arg.SdkId = sdkinfo.Sdkid arg.SdkName = sdkinfo.SdkName arg.IpcId = sdkinfo.Ipcid arg.IsYolo = true bdata, err := util.UnCompress(m.Data) if err != nil { @@ -148,7 +144,7 @@ logger.Info("解析YOLO sdk数据时出现错误", err) continue } logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看yolo中有几个目标：",len(yoloParam.Infos)) //logger.Info("--------------看看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} @@ -164,8 +160,7 @@ if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测 arg := ruleserver.SdkData{} arg.TaskId = m.Tasklab.Taskid arg.SdkId = sdkinfo.Sdkid arg.SdkName = sdkinfo.SdkName arg.IpcId = sdkinfo.Ipcid arg.IsYolo = false bdata, err := util.UnCompress(m.Data) if err != nil { @@ -185,9 +180,9 @@ logger.Info("解析FACE sdk数据时出现错误", err) continue } logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸检测中有几个目标：",len(faceParam.Faces)) logger.Info("--------------看看人脸检测中有几个目标：",len(faceParam.Faces)) for _, info := range faceParam.Faces { photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.Quality)*100, IsYolo:false,ThftRes:*(info.Result)} photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.Quality)*100, IsYolo:false,ThftRes:*(info.Result),Feature:info.Feats} arg.Photo = append(arg.Photo, photoMap) } args.Sdkdata = append(args.Sdkdata,&arg) @@ -195,55 +190,55 @@ continue } } if sdkinfo.Sdktype == "FaceExtract" { // 人脸提取 arg := ruleserver.SdkData{} arg.TaskId = m.Tasklab.Taskid arg.SdkId = sdkinfo.Sdkid arg.SdkName = sdkinfo.SdkName arg.IsYolo = false bdata, err := util.UnCompress(m.Data) if err != nil { panic("解压缩图片时出现错误") } i := protomsg.Image{} err = proto.Unmarshal(bdata, &i) arg.ImageWidth = int(i.Width) arg.ImageHeight = int(i.Height) // 暂时写死，sdk还没有这俩算法 arg.KeepRight = false arg.IsStatic = false if len(sdkinfo.Sdkdata) > 1 { faceParam := protomsg.ParamFaceFeature{} err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) if err != nil { logger.Info("解析FACE sdk数据时出现错误", err) continue } for _,faceExtCom := range faceParam.ExtComp { binfos := protomsg.Binfos{} err := proto.Unmarshal(faceExtCom.Comp, &binfos) if err != nil { logger.Info("解析人脸比对数据时出现错误", err) continue } logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos) } logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸提取中有几个目标：",len(faceParam.ExtComp)) for _, extComp := range faceParam.ExtComp { baseinfos := protomsg.Binfos{} err1 := proto.Unmarshal(extComp.Comp, &baseinfos) if err1 != nil { logger.Info("解析FACE sdk数据时出现错误", err) continue } photoMap := ruleserver.PhotoMap{Rects: rectFormat(extComp.Pos.Pos.RcFace), Score: float64(extComp.Pos.Pos.Quality)*100, IsYolo:false,ThftRes:*(extComp.Pos.Result),Liker:baseinfos.Infos} arg.Photo = append(arg.Photo, photoMap) } args.Sdkdata = append(args.Sdkdata,&arg) } else { continue } } //if sdkinfo.Sdktype == "FaceExtract" { // 人脸提取 // arg := ruleserver.SdkData{} // arg.TaskId = m.Tasklab.Taskid // arg.SdkId = sdkinfo.Sdkid // arg.SdkName = sdkinfo.SdkName // arg.IsYolo = false // bdata, err := util.UnCompress(m.Data) // if err != nil { // panic("解压缩图片时出现错误") // } // i := protomsg.Image{} // err = proto.Unmarshal(bdata, &i) // arg.ImageWidth = int(i.Width) // arg.ImageHeight = int(i.Height) // // 暂时写死，sdk还没有这俩算法 // arg.KeepRight = false // arg.IsStatic = false // if len(sdkinfo.Sdkdata) > 1 { // faceParam := protomsg.ParamFaceFeature{} // err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) // if err != nil { // logger.Info("解析FACE sdk数据时出现错误", err) // continue // } // for _,faceExtCom := range faceParam.ExtComp { // binfos := protomsg.Binfos{} // err := proto.Unmarshal(faceExtCom.Comp, &binfos) // if err != nil { // logger.Info("解析人脸比对数据时出现错误", err) // continue // } // logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos.Infos[0].CompareScore) // } // logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸提取中有几个目标：",len(faceParam.ExtComp)) // for _, extComp := range faceParam.ExtComp { // baseinfos := protomsg.Binfos{} // err1 := proto.Unmarshal(extComp.Comp, &baseinfos) // if err1 != nil { // logger.Info("解析FACE sdk数据时出现错误", err) // continue // } // photoMap := ruleserver.PhotoMap{Rects: rectFormat(extComp.Pos.Pos.RcFace), Score: float64(extComp.Pos.Pos.Quality)*100, IsYolo:false,ThftRes:*(extComp.Pos.Result),Liker:baseinfos.Infos} // arg.Photo = append(arg.Photo, photoMap) // } // args.Sdkdata = append(args.Sdkdata,&arg) // } else { // continue // } //} } return m
