| | |
| | | |
| | | var sender chan []byte = make(chan []byte) |
| | | var receiver chan string = make(chan string) |
| | | var initFlag bool = false |
| | | |
| | | var sock mangos.Socket |
| | | func Init() { |
| | | go Push() |
| | |
| | | |
| | | // 人体跟踪算法 |
| | | func Entrance(rule *protomsg.Rule, am *structure.AreaMap, lable *structure.Others, args *structure.SdkDatas, message *protomsg.SdkMessage) structure.LittleRuleResult { |
| | | logger.Info("置位符号为:",initFlag) |
| | | if !initFlag { |
| | | logger.Info("置位符号为:",structure.InitFlag) |
| | | if !structure.InitFlag { |
| | | Init() |
| | | } |
| | | if rule.PolygonId == am.AreaId { // 首先这条规则得是这个算法的规则,其次规则所对应的区域id要跟区域数据的id对的上 |
| | |
| | | logger.Error("请求socket拨号失败: %s", err.Error()) |
| | | } |
| | | //logger.Info("序列化数据") |
| | | initFlag = true |
| | | logger.Info("置位initFlag:",initFlag) |
| | | structure.InitFlag = true |
| | | logger.Info("置位initFlag:",structure.InitFlag) |
| | | for { |
| | | select { |
| | | case data := <- sender: |