use camera and localconfig cache

liuxiaolong

2019-07-02 6d0a2b62a05d146440b425598201d52a56b8c911

 insertdata/insertDataToEs.go

@@ -6,6 +6,7 @@
   "fmt"
   "log"
   "net"
   "ruleprocess/cache"
   "strings"
   "time"

@@ -74,7 +75,7 @@
   TaskName        string      `json:"taskName"`
   SdkName         string      `json:"sdkName"`
   Content         string      `json:"content"`
   AlarmRules      []AlarmRule `json: "alramRules"`
   AlarmRules      []AlarmRule `json:"alarmRules"`
   AnalyServerId   string      `json:"analyServerId"`
   AnalyServerName string      `json:"analyServerName"`
   AnalyServerIp   string      `json:"analyServerIp"`
@@ -98,7 +99,7 @@
func InsertToEs(msg ruleserver.ResultMsg) {

   // 直接从规则的标签数据里拿符合规则的人脸结果
   if len(msg.RuleResult["faces"].([]ruleserver.Arg)) > 0 {
   if msg.RuleResult["faces"] != nil && len(msg.RuleResult["faces"].([]ruleserver.Arg)) > 0 {
      log.Println("往ES插人脸数据")
      for _, face := range msg.RuleResult["faces"].([]ruleserver.Arg) {
         // 上传大图
@@ -173,10 +174,12 @@
            if err != nil {
               log.Println("es can not execute right.")
            }
         }else {
            log.Println("跟底库的相似数据---------：",face.Liker)
         }
      }
   }
   if len(msg.RuleResult["yolo"].([]ruleserver.Result)) > 0 {
   if msg.RuleResult["yolo"] != nil && len(msg.RuleResult["yolo"].([]ruleserver.Result)) > 0 {
      log.Println("往ES插yolo数据")
      var sdkNames string = ""
      alarmRules := []AlarmRule{}
@@ -195,21 +198,26 @@
         }
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
         log.Println("已报警并上传改帧图片到服务器")
         //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
         resp, err =util.DrawPolygonOnImage(i)
         if err != nil {
            log.Println("画框或上传图片服务器出错",err)
         }else{
            log.Println("已报警并上传改帧图片到服务器")
         }
      } else {
         isAlarm = "0"
         // 不是报警数据不存
         return
      }
      log.Println("图片上传返回值：", resp)
      // 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("查询摄像机信息失败")
      }
@@ -245,7 +253,9 @@
      }
      err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
      if err != nil {
         log.Println("es can not execute right.")
         log.Println("往ES插入数据失败",err)
      } else {
         log.Println("__________________________________________往ES插入数据成功")
      }
   }
}