| | |
| | | logger.Debug("插入数据前看看报警标志位:", timeLabel) |
| | | if timeLabel == "01" { // 无定时器状态要插入的报警数据 |
| | | InsertFace(msg) |
| | | ruleserver.BodyIsSame(msg.SdkMessage) |
| | | InsertYolo(msg) |
| | | flag := ruleserver.BodyIsSame(msg.SdkMessage) |
| | | if !flag { |
| | | InsertYolo(msg) |
| | | } |
| | | } |
| | | if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧 |
| | | InsertFace(msg) |
| | |
| | | } |
| | | 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, |