派生自 ruleprocess
main.go
@@ -26,7 +26,7 @@ var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新 var initchan = make(chan bool) func init () { var logFile = "/opt/ruleLog/error.log" var logFile = "./info.log" var logSaveDays = 15 // 日志初始化 @@ -41,7 +41,8 @@ dbapi.Init(*dbIp,*dbPort) go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) fmt.Println("cache init completed!!!",<- initchan)//dbserver初始化完毕 logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕 fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 go ruleserver.TimeTicker() nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) @@ -69,16 +70,17 @@ default: msg, err = c.Recv() if err != nil { logger.Info("recv error : ", err) fmt.Println("recv error : ", err) continue } else { arg := ruleserver.SdkDatas{} m := paramFormat(msg, &arg) fmt.Println("解析出来的数据：", arg) logger.Info("解析出来的数据：", arg) ruleserver.Judge(&arg) // 把arg里的打的标签拿出来给m再封装一层 resultMag := ruleserver.ResultMsg{SdkMessage: m, RuleResult: arg.RuleResult} //fmt.Println("打完标签后的结果：",resultMag) //logger.Info("打完标签后的结果：",resultMag) // 将打完标签的数据插入到ES insertdata.InsertToEs(resultMag) @@ -101,7 +103,7 @@ func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage { defer func() { if err := recover(); err != nil { fmt.Println("解包过程的错误", err.(string)) logger.Info("解包过程的错误", err.(string)) } }() @@ -143,7 +145,7 @@ yoloParam := protomsg.ParamYoloObj{} err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam) if err != nil { fmt.Println("解析YOLO sdk数据时出现错误", err) logger.Info("解析YOLO sdk数据时出现错误", err) continue } logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看yolo中有几个目标：",len(yoloParam.Infos)) @@ -180,7 +182,7 @@ faceParam := protomsg.ParamFacePos{} err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) if err != nil { fmt.Println("解析FACE sdk数据时出现错误", err) logger.Info("解析FACE sdk数据时出现错误", err) continue } logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸检测中有几个目标：",len(faceParam.Faces)) @@ -214,14 +216,14 @@ faceParam := protomsg.ParamFaceFeature{} err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) if err != nil { fmt.Println("解析FACE sdk数据时出现错误", err) logger.Info("解析FACE sdk数据时出现错误", err) continue } for _,faceExtCom := range faceParam.ExtComp { binfos := protomsg.Binfos{} err := proto.Unmarshal(faceExtCom.Comp, &binfos) if err != nil { fmt.Println("解析人脸比对数据时出现错误", err) logger.Info("解析人脸比对数据时出现错误", err) continue } logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos) @@ -231,7 +233,7 @@ baseinfos := protomsg.Binfos{} err1 := proto.Unmarshal(extComp.Comp, &baseinfos) if err1 != nil { fmt.Println("解析FACE sdk数据时出现错误", err) 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} @@ -253,7 +255,7 @@ //imgs := gocv.NewMat() ddd, err := RetrieveROM("./105.jpg") if err != nil { fmt.Println("解码有误",err) logger.Info("解码有误",err) } bbb := bytes.NewBuffer(ddd) // 必须加一个buffer 不然没有read方法就会报错 rook, _ := gocv.NewMatFromBytes(500, 500, gocv.MatTypeCV8UC3, bbb.Bytes()) @@ -298,11 +300,11 @@ // msg := "上传图片服务器异常" // if _, ok := r.(error); ok { // msg = r.(error).Error() // fmt.Println("panic--recover()得到的是error类型") // logger.Info("panic--recover()得到的是error类型") // } // if _, ok := r.(string); ok { // msg = r.(string) // fmt.Println("panic--recover()得到的是string类型") // logger.Info("panic--recover()得到的是string类型") // } // err0 = errors.New(msg) // } @@ -314,9 +316,9 @@ // if err != nil { // logger.Fatal(err) // } // fmt.Println(resp.StatusCode) // //fmt.Println(resp.Header) // fmt.Println(body) // logger.Info(resp.StatusCode) // //logger.Info(resp.Header) // logger.Info(body) // //decoder := json.NewDecoder(strings.NewReader(body.String())) // decoder := make(map[string]interface{}) // if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil {
