panlei
2019-07-08 d5fab9d5ff335edeb8cff771ad6e7ceac60e3af9
main.go
@@ -1,22 +1,57 @@
package main
import (
   "fmt"
   "ruleprocess/ruleserver"
   "ruleprocess/insertdata"
   "sync"
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/deliver.git"
   "bufio"
   "bytes"
   "flag"
   "fmt"
   "github.com/golang/protobuf/proto"
   "gocv.io/x/gocv"
   "image"
   "image/color"
   "os"
   "ruleprocess/cache"
   "ruleprocess/insertdata"
   "ruleprocess/ruleserver"
   "ruleprocess/util"
   "ruleprocess/logger"
   "sync"
)
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 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 !")
}
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初始化完毕
   go ruleserver.TimeTicker()
   nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
   wg.Wait()
   //resp,err := DrawPolygonOnImage()
   //if err != nil {
   //   logger.Println("画框或者上传有问题")
   //}
   //logger.Println(resp["fileUrl"].(string))
}
func nReciever(url string, m deliver.Mode, count int) {
   c := deliver.NewServer(m, url)
@@ -35,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.ArgsFromSdk{}
            m := paramFormat(msg,&arg)
            fmt.Println("解析出来的数据:",arg)
            ruleserver.MainJudge(&arg)
            arg := ruleserver.SdkDatas{}
            m := paramFormat(msg, &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)
@@ -53,11 +89,21 @@
   }
}
// 将外部传进来的sdk数据包解成 ArgsFromSdk
func paramFormat(msg []byte,arg *ruleserver.ArgsFromSdk) protomsg.SdkMessage {
// 将外部传进来的rect(top,bottom,left,right)转化为自己内部的rect(left top width height)
func rectFormat(rcobj *protomsg.Rect) ruleserver.Rect {
   rect := ruleserver.Rect{}
   rect.X = float64(rcobj.Left)
   rect.Y = float64(rcobj.Top)
   rect.Width = float64(rcobj.Right - rcobj.Left)
   rect.Height = float64(rcobj.Bottom - rcobj.Top)
   return rect
}
// 将外部传进来的sdk数据包解成 SdkDatas
func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage {
   defer func() {
      if err := recover();err != nil{
         fmt.Println("解包过程的错误",err.(string))
      if err := recover(); err != nil {
         logger.Info("解包过程的错误", err.(string))
      }
   }()
@@ -67,60 +113,240 @@
   if err != nil {
      panic("解析msg时出现错误")
   }
   arg.CameraId = m.Cid
   arg.TaskId = m.Tasklab.Taskid
   bdata,err := UnCompress(m.Data)
   args.CameraId = m.Cid
   // 把图片的二进制解压缩进行画框在压缩回去
   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
   fmt.Println("从mongos中拿到的数据包长度为:", len(msg))
   //logger.Info("----------------看看有几个算法:",len(m.Tasklab.Sdkinfos))
   for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo算法
      if sdkinfo.Sdktype == "Yolo" {
         yoloParam := protomsg.ParamYoloObj{}
         err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam)
         arg := ruleserver.SdkData{}
         arg.TaskId = m.Tasklab.Taskid
         arg.SdkId = sdkinfo.Sdkid
         arg.SdkName = sdkinfo.SdkName
         arg.IsYolo = true
         bdata, err := util.UnCompress(m.Data)
         if err != nil {
            fmt.Println("解析FACE sdk数据时出现错误", err)
            continue
            panic("解压缩图片时出现错误")
         }
         for _, info := range yoloParam.Infos {
            photoMap := ruleserver.PhotoMap{Rects:rectFormat(info.RcObj, i.Width, i.Height), Score: float64(info.Prob)}
            arg.Photo = append(arg.Photo, photoMap)
         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 {
            // 大于1才有数据
            yoloParam := protomsg.ParamYoloObj{}
            err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam)
            if err != nil {
               logger.Info("解析YOLO sdk数据时出现错误", err)
               continue
            }
            logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看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}
                  arg.Photo = append(arg.Photo, photoMap)
               }
            }
            args.Sdkdata = append(args.Sdkdata,&arg)
         } else {
            continue
         }
      }
      if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测
         faceParam := protomsg.ParamFacePos{}
         err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
         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 {
            fmt.Println("解析YOLO sdk数据时出现错误", err)
            continue
            panic("解压缩图片时出现错误")
         }
         for _, info := range faceParam.Faces {
            photoMap := ruleserver.PhotoMap{Rects:ruleserver.Rect{}, Score: float64(info.Pos.Quality)}
            arg.Photo = append(arg.Photo, photoMap)
         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.ParamFacePos{}
            err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
            if err != nil {
               logger.Info("解析FACE sdk数据时出现错误", err)
               continue
            }
            logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸检测中有几个目标:",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),Feature:info.Feats}
               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
}
// 将外部传进来的rect(top,bottom,left,right)转化为自己内部的rect(left top width height)
func rectFormat(rcobj *protomsg.Rect, width int32, height int32) ruleserver.Rect {
   rect := ruleserver.Rect{}
   rect.X = float64(rcobj.Left)
   rect.Y = float64(rcobj.Top)
   rect.Width = float64(width - rcobj.Left - rcobj.Right)
   rect.Height = float64(height - rcobj.Top - rcobj.Bottom)
   return rect
func DrawPolygonOnImage()(maps map[string]interface{}, err0 error){
   // draw the rook
   //rook := gocv.NewMatWithSize(w, w, gocv.MatTypeCV8UC3)
   //imgs := gocv.NewMat()
   ddd, err := RetrieveROM("./105.jpg")
   if err != nil {
      logger.Info("解码有误",err)
   }
   bbb := bytes.NewBuffer(ddd)  // 必须加一个buffer 不然没有read方法就会报错
   rook, _ := gocv.NewMatFromBytes(500, 500, gocv.MatTypeCV8UC3, bbb.Bytes())
   defer rook.Close()
   green := color.RGBA{0, 255, 0, 0}
   points := [][]image.Point{
      {
         image.Pt(100., 100),
         image.Pt(100., 400),
         image.Pt(400, 400),
         image.Pt(400, 100),
      },
   }
   gocv.FillPoly(&rook, points, green)
   // 上传
   //fdata,_ := gocv.IMEncode(".jpg",rook)
   //body := &bytes.Buffer{}
   //writer := multipart.NewWriter(body)
   //_, err1 := writer.CreateFormFile("file", "fasjuierf")
   //if err1 != nil {
   //   return nil, err1
   //}
   //boundary := writer.Boundary()
   ////close_string := fmt.Sprintf("\r\n--%s--\r\n", boundary)
   //close_buf := bytes.NewBufferString(fmt.Sprintf("\r\n--%s--\r\n", boundary))
   //file := bytes.NewBuffer(fdata)
   //request_reader := io.MultiReader(body, file, close_buf)
   ////_, err = io.Copy(part, file)
   ////writer.WriteField(key, val)
   //request, err := http.NewRequest("POST", "http://192.168.1.182:6333/submit", request_reader)
   //request.Header.Add("Content-Type", writer.FormDataContentType())
   //timeout := time.Duration(5 * time.Second) //超时时间50ms
   //client := &http.Client{Timeout: timeout}
   //resp, err := client.Do(request)
   //if err != nil {
   //   logger.Fatal(err)
   //   return nil, err
   //}
   //defer func() {
   //   if r := recover(); r != nil {
   //      fmt.Printf("panic的内容%v\n", r)
   //      msg := "上传图片服务器异常"
   //      if _, ok := r.(error); ok {
   //         msg = r.(error).Error()
   //         logger.Info("panic--recover()得到的是error类型")
   //      }
   //      if _, ok := r.(string); ok {
   //         msg = r.(string)
   //         logger.Info("panic--recover()得到的是string类型")
   //      }
   //      err0 = errors.New(msg)
   //   }
   //}()
   //defer resp.Body.Close()
   //{
   //   body := &bytes.Buffer{}
   //   _, err := body.ReadFrom(resp.Body)
   //   if err != nil {
   //      logger.Fatal(err)
   //   }
   //   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 {
   //      return nil, err
   //   }
      return nil, nil
   //}
}
// 把图片转成二进制流
func RetrieveROM(filename string) ([]byte, error) {
   file, err := os.Open(filename)
   if err != nil {
      return nil, err
   }
   defer file.Close()
   stats, statsErr := file.Stat()
   if statsErr != nil {
      return nil, statsErr
   }
   var size int64 = stats.Size()
   bytes := make([]byte, size)
   bufr := bufio.NewReader(file)
   _, err = bufr.Read(bytes)
   return bytes, err
}