| | |
|---|
| | | "basic.com/pubsub/protomsg.git" |
|---|
| | | "basic.com/valib/deliver.git" |
|---|
| | | "ruleprocess/insertdata" |
|---|
| | | "ruleprocess/labelFilter" |
|---|
| | | "ruleprocess/util" |
|---|
| | | |
|---|
| | | //"bufio" |
|---|
| | |
|---|
| | | // 将打完标签的数据插入到ES |
|---|
| | | insertdata.InsertToEs(resultMsg) |
|---|
| | | //事件推送 |
|---|
| | | go labelFilter.Judge(resultMsg) |
|---|
| | | //go labelFilter.Judge(resultMsg) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | a.filterData = append(a.filterData, &arg1) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.targetNum,"---",len(a.filterData)) |
|---|
| | | //logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.targetNum,"---",len(a.filterData)) |
|---|
| | | a.time = time.Unix(time.Now().Unix(), 0).String()[11:16] |
|---|
| | | a.keepRight = arg.KeepRight |
|---|
| | | a.isStatic = arg.IsStatic |
|---|
