| | |
| | | } |
| | | if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧 |
| | | InsertFace(msg) |
| | | InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | InsertYolo(msg) |
| | | InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | |
| | | } |
| | | if timeLabel == "12" { // 并非报警数据,只是状态改变的数据 |
| | | ChangeStatusFace(msg) |
| | |
| | | if err1 != nil { |
| | | logger.Error("上传ES出错!---", err1) |
| | | } |
| | | InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | } |
| | | |
| | | // 往es中插入yolo数据 |
| | |
| | | logger.Warn("__________________________________________往ES插入yolo数据成功") |
| | | //os.Exit(1) |
| | | } |
| | | logger.Debug("============瞅瞅缓存数据:",msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) |
| | | } |
| | | } |
| | | func ChangeStatusYolo(msg ruleserver.ResultMsg) { |