package util
|
|
import (
|
"fmt"
|
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/r/dbapi.git"
|
"github.com/gogo/protobuf/proto"
|
"github.com/long/test/gopherdiscovery"
|
)
|
|
/*************************
|
* 1. store all struct data
|
* 2. define function for get difference data type
|
* 3. recive data from sqlite process. and call conpos function.
|
***********************/
|
|
var camval dbapi.CameraApi
|
var taskapi dbapi.TaskApi
|
var sdkapi dbapi.SdkApi
|
var IsInit bool
|
|
var CameraIds []protomsg.Camera
|
var CameraTasks []protomsg.CameraAndTaskInfo
|
|
var TaskSdks []protomsg.TaskSdkInfo
|
var Sdklist []string
|
|
//var urlServer = "tcp://192.168.1.11:40007"
|
//var urlPubSub = "tcp://192.168.1.11:50007"
|
|
var urlServer = "tcp://127.0.0.1:40007"
|
var urlPubSub = "tcp://127.0.0.1:50007"
|
|
var Sdkflag = make(chan bool)
|
var TaskSdkflag = make(chan bool)
|
var Cameraflag = make(chan bool)
|
|
var newsdkmsg = &protomsg.DbChangeMessage{}
|
|
func processinit(initchan chan bool) {
|
CameraIds = camval.FindAll()
|
|
fmt.Println("==============camera camera with task ================")
|
CameraTasks = camval.FindAllCameraAndTask()
|
fmt.Println(CameraTasks)
|
|
TaskSdks = taskapi.FindAll()
|
|
Sdklist = sdkapi.GetAllSdkIds()
|
initchan <- true
|
}
|
|
func Getdata(opt []byte) {
|
if err := proto.Unmarshal(opt, newsdkmsg); err != nil {
|
fmt.Println("publichshMessage ", err)
|
return
|
}
|
|
switch newsdkmsg.Table {
|
case protomsg.TableChanged_T_Camera:
|
fmt.Println("update camera")
|
CameraIds = camval.FindAll()
|
Cameraflag <- true
|
|
case protomsg.TableChanged_T_CameraTask:
|
fmt.Println("update cameratask")
|
CameraTasks = camval.FindAllCameraAndTask()
|
fmt.Println("update cameratask finished!")
|
|
case protomsg.TableChanged_T_TaskSdk:
|
fmt.Println("update tasksdk")
|
TaskSdks = taskapi.FindAll()
|
TaskSdkflag <- true
|
|
case protomsg.TableChanged_T_Sdk:
|
fmt.Println("update sdk")
|
Sdklist = sdkapi.GetAllSdkIds()
|
go func() {
|
Sdkflag <- true
|
}()
|
fmt.Println("update finished!")
|
|
default:
|
fmt.Println("unknow type operation")
|
}
|
fmt.Println(newsdkmsg)
|
}
|
|
func Init(initchan chan bool) {
|
clientOne, _ := gopherdiscovery.ClientWithSub(urlServer, urlPubSub, "ip:192.168.1.124")
|
recvinit := clientOne.HeartBeatMsg()
|
fmt.Println(<-recvinit)
|
processinit(initchan)
|
|
peers, _ := clientOne.Peers()
|
for x := range peers {
|
fmt.Println("client: ", string(x))
|
Getdata(x)
|
}
|
}
|
