package service
|
|
import (
|
"encoding/json"
|
"vamicro/saas-service/service/nodeService"
|
|
"basic.com/valib/go-aiot.git/aiotProto/aiot"
|
"basic.com/valib/go-aiot.git/client"
|
"basic.com/valib/logger.git"
|
)
|
|
// 同步集群数据
|
func syncClusterData(cli *client.Client) {
|
data := nodeService.Node
|
|
// 非集群信息，不在syncClusterData报，在syncDeviceSdkApp里报
|
if data.ClusterId == "" {
|
logger.Info("is not cluster, no report cluster info")
|
return
|
}
|
msgData, err := json.Marshal(data)
|
if err != nil {
|
logger.Error("Fail to marshal cluster data to saas", err)
|
}
|
|
report := aiot.DataReport{
|
DataKey: ClusterDataReport,
|
Data: msgData,
|
}
|
logger.Debugf("syncClusterData data=%v, dataKey=%v", string(msgData), report.DataKey)
|
// 集群数据拼装
|
reportData, _ := json.Marshal(report)
|
syncData := &aiot.Protocol{
|
Receiver: aiot.RECEIVER_TO_SAAS,
|
SenderId: nodeService.Node.NodeId,
|
MsgType: aiot.MSG_TYPE_DATA_REPORT,
|
ReqType: aiot.REQ_TYPE_REQUEST,
|
MsgProto: client.GetMsgProto(""),
|
Data: reportData,
|
}
|
// 上报集群数据
|
_ = cli.WriteBody(syncData)
|
}
|
