add heartbeat

龙赣华

2019-05-31 3c8609a3da72cb2f3610f3f1789dafacc6c0f40f

 camera/camera.go

@@ -5,9 +5,9 @@

        "basic.com/dbapi.git"
        "basic.com/valib/deliver.git"
        "basic.com/pubsub/protomsg.git"

        "github.com/long/test/sdk"
   "github.com/long/test/util"

        "context"
        "fmt"
@@ -28,20 +28,17 @@

var camval dbapi.CameraApi

//get camera with task
var cameraTasks []protomsg.CameraAndTaskInfo

func Init() {

    fmt.Println("============ camera info ====================")
    ctsid := camval.FindAll()

    fmt.Println("==============camera camera with task ================")
    cameraTasks=camval.FindAllCameraAndTask()
   for _, cd := range util.CameraIds {
      fmt.Println(cd)
      fmt.Println()
   }

    go CreateCamera(Initchannel)

    for _, cam := range ctsid {
   for _, cam := range util.CameraIds {
        Initchannel <- cam.Id
    }
}
@@ -109,7 +106,7 @@

//   根据cid 获取 所有的任务
func GetAlltask(cid string) (tasks []string) {
    for _, camsingle := range cameraTasks {
   for _, camsingle := range util.CameraTasks {
        if cid == camsingle.Camera.Id {
            for _, tasksingle := range camsingle.Tasks {
                tasks = append(tasks, tasksingle.Taskid)