package service
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"encoding/json"
|
"time"
|
"vamicro/extend/util"
|
"vamicro/system-service/models"
|
)
|
|
//判断升级或者其他操作导致通道数量变化
|
func WatchAuthSetChange(bk bhomeclient.Broker) {
|
for {
|
var lc models.LocalConfig
|
err := lc.Select()
|
if err == nil {
|
if !util.SysExpired && lc.RealMax != util.SysChCount && util.SysChCount != 0 {
|
lc.RealMax = util.SysChCount
|
lc.Update()
|
|
pMsg := protomsg.DbChangeMessage{
|
Table: protomsg.TableChanged_T_Server,
|
Action: protomsg.DbAction_Update,
|
}
|
pb, _ := json.Marshal(pMsg)
|
bk.Publish(ProcName, pb)
|
}
|
}
|
time.Sleep(time.Second * 10)
|
}
|
}
|
|
func TestGetTopicNode(ms *bhomeclient.MicroNode) {
|
for {
|
nodes := ms.GetLocalNetNodeByTopic("/data/api-v/sysset/getDeviceInfo")
|
for i := 0; i < len(nodes); i++ {
|
logger.Debug("GetNetNodeByTopic nodes[", i, "]:", nodes[i])
|
}
|
time.Sleep(time.Second * 10)
|
}
|
}
|
