| | |
| | | "fmt" |
| | | "io/ioutil" |
| | | "net" |
| | | "os" |
| | | "ruleprocess/cache" |
| | | "ruleprocess/logger" |
| | | "strings" |
| | |
| | | } |
| | | |
| | | // 往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) |
| | | //} |
| | | } |
| | | |
| | |
| | | } |
| | | if linkFlag { |
| | | // 联动数据中包含本帧数据,插入联动数据后就不需要插入本帧数据了 |
| | | os.Exit(1) |
| | | return |
| | | } |
| | | isAlarm := 0 |