panlei
2019-07-13 72b2b494d5d69b64f4b094f21bc8ac7837b8d9e6
换个地儿插缓存数据
1个文件已修改
6 ■■■■■ 已修改文件
insertdata/insertDataToEs.go 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
insertdata/insertDataToEs.go
@@ -114,9 +114,8 @@
    }
    if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
        InsertFace(msg)
        InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
        InsertYolo(msg)
        InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
    }
    if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
        ChangeStatusFace(msg)
@@ -276,6 +275,7 @@
        if err1 != nil {
            logger.Error("上传ES出错!---", err1)
        }
        InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}
// 往es中插入yolo数据
@@ -360,6 +360,8 @@
            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) {