| | |
| | | } |
| | | serverIp, err := GetLocalIP() |
| | | url := []string{} |
| | | url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1]) |
| | | if msg.RuleResult["cacheData"] != nil { |
| | | InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | //InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | // 把缓存的数据上传后得到地址存进去 |
| | | // 解压缩并上传图片 |
| | | msg1 := msg.RuleResult["cacheData"].(ruleserver.ResultMsg) |
| | |
| | | } |
| | | i := protomsg.Image{} |
| | | err = proto.Unmarshal(bdata, &i) |
| | | resp1, err1 := util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl) |
| | | resp1, err1 := util.DrawPolygonOnImage(msg1.Cid, i, msg1.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl) |
| | | if err1 != nil { |
| | | logger.Error("缓存数据画框或上传图片服务器出错", err) |
| | | } else { |
| | |
| | | } |
| | | url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1]) |
| | | } |
| | | url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1]) |
| | | esDataId := uuid.NewV4().String() |
| | | peraction := Personaction{ |
| | | esDataId, |