---
panlei
2019-07-02 d4c91ea1e23a594ee8eeb7248741e1aac4ff870e
insertdata/insertDataToEs.go
@@ -6,10 +6,10 @@
   "fmt"
   "log"
   "net"
   "ruleprocess/cache"
   "strings"
   "time"
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   "github.com/golang/protobuf/proto"
   "github.com/satori/go.uuid"
@@ -114,8 +114,8 @@
         fmt.Println(bigPhotoUrl)
         if len(face.Liker) == 0 {
            // 人脸检测,没有相似的底库人员
            flag, localConfig := dbapi.SysSetApi{}.GetServerInfo()
            if !flag {
            localConfig, err := cache.GetServerInfo()
            if err != nil {
               log.Println("查询本机信息失败!")
            }
            serverIp, err := GetLocalIP()
@@ -150,7 +150,7 @@
               face.ThftRes.Smile,
               face.ThftRes.Beauty,
               "不是每个人脸算法都有",
               resp["fileUrl"].(string),
               strings.Split(resp["fileUrl"].(string), "/")[1],
               "暂无集群",
               localConfig.ServerId,
               localConfig.ServerName,
@@ -198,7 +198,7 @@
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
         resp, err =util.DrawPolygonOnImage(i)
         resp, err =util.DrawPolygonOnImage(msg.Cid,i)
         if err != nil {
            log.Println("画框或上传图片服务器出错",err)
         }else{
@@ -211,12 +211,12 @@
      }
      // log.Println("图片上传返回值:", resp)
      // 查询本机信息
      flag, localConfig := dbapi.SysSetApi{}.GetServerInfo()
      if !flag {
      localConfig, err := cache.GetServerInfo()
      if err !=nil {
         log.Println("查询本机信息失败!")
      }
      // 查询cameraName
      camera, err := dbapi.CameraApi{}.GetCameraById(msg.Cid)
      camera, err := cache.GetCameraById(msg.Cid)
      if err != nil {
         log.Println("查询摄像机信息失败")
      }
@@ -225,7 +225,7 @@
         uuid.NewV4().String(),
         msg.Cid,
         camera.Name,
         msg.Caddr,
         camera.Addr,
         msg.Tasklab.Taskid,
         msg.Tasklab.Taskname,
         sdkNames,