| | |
|---|
| | | |
|---|
| | | func Taskdolist(cid string, taskid string, data []byte) { |
|---|
| | | |
|---|
| | | fmt.Println("======================================") |
|---|
| | | fmt.Println() |
|---|
| | | // 数据加工(打标签) |
|---|
| | | sdkmsg := sdk.SdkData(cid, taskid, data) |
|---|
| | | fmt.Println("============================") |
|---|
| | | |
|---|
| | | fmt.Println("sdk 打标签： ", cid, taskid, len(data)) |
|---|
| | | if sdkmsg.Tasklab == nil { |
|---|
| | | fmt.Println("cid:%s 没有任务%s", cid, taskid) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 计算分发的主题 |
|---|
| | | SendTopic := sdk.SdkSendTopic(sdkmsg) |
|---|
| | |
|---|
| | | i++ |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | func Recv(cameraid string, socket SocketContext) { |
|---|
| | |
|---|
| | | continue |
|---|
| | | } else { |
|---|
| | | for _, taskid := range GetAlltask(cameraid) { |
|---|
| | | Taskdolist(cameraid, taskid, msg) |
|---|
| | | go Taskdolist(cameraid, taskid, msg) |
|---|
| | | fmt.Println("receive: ", len(msg), "cameraid: ", cameraid, "taskid: ", taskid) |
|---|
| | | } |
|---|
| | | } |
|---|
