联动任务缓存数据(结构重整)

panlei

2019-07-31 81c415b1cfccc2db3dfd437d2da24f11b255fabe

联动任务缓存数据(结构重整)

 insertdata/insertDataToEs.go

@@ -7,6 +7,7 @@
    "fmt"
    "io/ioutil"
    "net"
    "os"
    "ruleprocess/cache"
    "ruleprocess/logger"
    "strings"
@@ -111,27 +112,34 @@
}

// 往ES插数据
//func InsertToEs(msg ruleserver.ResultMsg) {
//    var timeLabel string
//    // 直接从规则的标签数据里拿符合规则的人脸结果
//    if msg.RuleResult["timeLabel"] != nil {
//        timeLabel = msg.RuleResult["timeLabel"].(string)
//    }
//    logger.Debug("插入数据前看看报警标志位：", timeLabel)
//    if timeLabel == "01" { // 无定时器状态要插入的报警数据
//        InsertFace(msg)
//        flag := ruleserver.BodyIsSame(msg.SdkMessage)
//        if !flag {
//            InsertYolo(msg)
//        }
//    }
//    if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
//        InsertFace(msg)
//        InsertYolo(msg)
//    }
//    //if timeLabel == "12" { // 并非报警数据，只是状态改变的数据
//    //    //ChangeStatusFace(msg)
//    //    ChangeStatusYolo(msg)
//    //}
//}
func InsertToEs(msg ruleserver.ResultMsg) {
    var timeLabel string
    // 直接从规则的标签数据里拿符合规则的人脸结果
    if msg.RuleResult["timeLabel"] != nil {
        timeLabel = msg.RuleResult["timeLabel"].(string)
    }
    logger.Debug("插入数据前看看报警标志位：", timeLabel)
    if timeLabel == "01" { // 无定时器状态要插入的报警数据
        InsertFace(msg)
        flag := ruleserver.BodyIsSame(msg.SdkMessage)
        if !flag {
    //flag := ruleserver.BodyIsSame(msg.SdkMessage)
    //if !flag {
            InsertYolo(msg)
        }
    }
    if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
        InsertFace(msg)
        InsertYolo(msg)
    }
    //if timeLabel == "12" { // 并非报警数据，只是状态改变的数据
    //    //ChangeStatusFace(msg)
    //    ChangeStatusYolo(msg)
    //}
}

@@ -366,6 +374,7 @@
            }
            if linkFlag {
                // 联动数据中包含本帧数据，插入联动数据后就不需要插入本帧数据了
                os.Exit(1)
                return
            }
            isAlarm := 0