package service
|
|
import (
|
"time"
|
|
"basic.com/valib/go-aiot.git/client"
|
"basic.com/valib/logger.git"
|
)
|
|
const (
|
// 集群数据上报
|
ClusterDataReport = "cluster-data-report"
|
// 设备安装数据上报
|
DeviceSdkAppDataReport = "device-sdk-app-data-report"
|
// 摄像机上报
|
CameraDataReport = "camera-data-report"
|
// 摄像机传感器上报
|
SensorDataReport = "sensor-data-report"
|
// 国标摄像机上报
|
CameraGb28181DataReport = "camera-gb28181-data-report"
|
// 场景上报
|
ScenesDataReport = "scenes-data-report"
|
// 算力设置上报
|
PollConfigDataReport = "poll-config-data-report"
|
)
|
|
const (
|
// 集群数据上报间隔时长
|
AiotClusterReport = 60 * time.Second
|
// 设备安装信息上报间隔
|
AiotDeviceAppSdkReport = 120 * time.Second
|
// 摄像机上报间隔
|
AiotCameraDataReport = 120 * time.Second
|
)
|
|
// 执行数据上报
|
func startSync(cli *client.Client) {
|
// 集群同步ticker
|
clusterTicker := time.NewTicker(AiotClusterReport)
|
// 设备信息同步ticker
|
deviceTicker := time.NewTicker(AiotDeviceAppSdkReport)
|
// 同步摄像机
|
cameraTicker := time.NewTicker(AiotCameraDataReport)
|
|
// 启动同步
|
go func() {
|
defer func() {
|
if r := recover(); r != nil {
|
logger.Errorf("startSync recover r=%v", r)
|
}
|
}()
|
|
for {
|
select {
|
case <-clusterTicker.C:
|
if !cli.IsClosed() {
|
// 同步集群信息
|
go syncClusterData(cli)
|
}
|
case <-deviceTicker.C:
|
if !cli.IsClosed() {
|
// 同步设备信息
|
go syncDeviceInfo(cli)
|
}
|
case <-cameraTicker.C:
|
if !cli.IsClosed() {
|
// 同步摄像机
|
go syncCamera(cli)
|
}
|
}
|
}
|
}()
|
if !cli.IsClosed() {
|
// 同步集群信息
|
syncClusterData(cli)
|
// 同步设备信息
|
syncDeviceInfo(cli)
|
// 同步摄像机
|
syncCamera(cli)
|
}
|
}
|
