联动任务缓存数据

panlei

2019-07-30 0cacae93b146ea559cbc5980ddeb53893e5fab41

 insertdata/insertDataToEs.go

@@ -360,20 +360,22 @@
         //InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
         // 把缓存的数据上传后得到地址存进去
         // 解压缩并上传图片
         msg1 := msg.RuleResult["cacheData"].(ruleserver.ResultMsg)
         bdata, err := util.UnCompress(msg1.Data)
         if err != nil {
            panic("解压缩图片时出现错误")
         msgs := msg.RuleResult["cacheData"].([]ruleserver.ResultMsg)
         for _,msg1 := range msgs {
            bdata, err := util.UnCompress(msg1.Data)
            if err != nil {
               panic("解压缩图片时出现错误")
            }
            i := protomsg.Image{}
            err = proto.Unmarshal(bdata, &i)
            resp1, err1 := util.DrawPolygonOnImage(msg1.Cid, i, msg1.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
            if err1 != nil {
               logger.Error("缓存数据画框或上传图片服务器出错", err)
            } else {
               logger.Info("上传的图片信息：", resp1)
            }
            url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
         }
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         resp1, err1 := util.DrawPolygonOnImage(msg1.Cid, i, msg1.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
         if err1 != nil {
            logger.Error("缓存数据画框或上传图片服务器出错", err)
         } else {
            logger.Info("上传的图片信息：", resp1)
         }
         url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
      }
      url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1])
      esDataId := uuid.NewV4().String()