panlei
2019-06-29 cd4e70a405980e2c02466cc0a5964eabe69f216b
---注释
2个文件已修改
9 ■■■■■ 已修改文件
main.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/ruleToformula.go 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
main.go
@@ -42,7 +42,7 @@
                arg := ruleserver.SdkDatas{}
                m := paramFormat(msg, &arg)
                fmt.Println("解析出来的数据:", arg)
                ruleserver.Judge(&arg)
                ruleserver.Judge(arg)
                // 把arg里的打的标签拿出来给m再封装一层
                resultMag := ruleserver.ResultMsg{SdkMessage: m, RuleResult: arg.RuleResult}
                //fmt.Println("打完标签后的结果:",resultMag)
ruleserver/ruleToformula.go
@@ -190,7 +190,7 @@
}
// 对单帧图像的判断 是舍弃(或者说对于某些需求可以放ES数据库一份)还是返回
func Judge(args *SdkDatas) {
func Judge(args SdkDatas) {
    if len(args.Sdkdata) > 0 {
        // 拿到本摄像机的区域
        cameraPolygons := GetPolygons(args.CameraId)
@@ -226,10 +226,9 @@
        }
    }
}
func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) bool {
func RunRule(args SdkDatas, groupRule *protomsg.GroupRule, taskId string) bool {
    resultSplice := []*LittleRuleResult{}
    // 先过完条件规则
    log.Println("---------------------看下这个组规则:", groupRule.Rules)
    for j := 0; j < len(groupRule.Rules); j++ {
        for _, sdkData := range args.Sdkdata {
            if sdkData.SdkId == "812b674b-2375-4589-919a-5c1c3278a975" {
@@ -418,7 +417,7 @@
}
// 联动任务的处理
func linkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) {
func linkTask(args SdkDatas, groupRule *protomsg.GroupRule, taskId string) {
    // new一个定时器,如果以此groupId为标志的定时器不存在的话
    var flag bool = true
    var timeEle = TimeElement{N: 3, InitN: 3, GroupId: groupRule.GroupId}