| | |
|---|
| | | import ( |
|---|
| | | "context" |
|---|
| | | "encoding/json" |
|---|
| | | "gat1400Exchange/config" |
|---|
| | | "strings" |
|---|
| | | "sync" |
|---|
| | | "time" |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | func InitSubscribeTask() error { |
|---|
| | | func InitSubscribeTask() { |
|---|
| | | var s models.Subscribe |
|---|
| | | subList, err := s.FindAll() |
|---|
| | | subList, err := s.FindByFromId(config.ClientConf.ServerId) |
|---|
| | | if err != nil { |
|---|
| | | logger.Error("Find account by channel error:%v", err) |
|---|
| | | return err |
|---|
| | | logger.Error("Find subscribe error, server id %s, %v", config.ClientConf.ServerId, err) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | for idx, _ := range subList { |
|---|
| | |
|---|
| | | CreateTask(&subList[idx]) |
|---|
| | | } |
|---|
| | | |
|---|
| | | return nil |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | func AddFaceCapture(face *vo.FaceObject) { |
|---|
| | | func AddFaceNotification(face *vo.FaceObject) { |
|---|
| | | TaskProcMap.Range(func(key, value interface{}) bool { |
|---|
| | | value.(TaskProcInfo).task.AddFace(face) |
|---|
| | | return true |
|---|
| | | }) |
|---|
| | | |
|---|
| | | logger.Debug("添加人脸.") |
|---|
| | | //TaskWaitGroup.Wait() |
|---|
| | | logger.Debug("Add Face Notification.") |
|---|
| | | } |
|---|
| | | |
|---|
| | | func StopSubscribeTask() { |
|---|
