From 63645d248c765244488cd34dbc1bb6528ca6b7c7 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 05 九月 2023 09:58:13 +0800
Subject: [PATCH] 修复编译
---
system-service/service/trial.go | 86 +++++++++++++++++++++---------------------
1 files changed, 43 insertions(+), 43 deletions(-)
diff --git a/system-service/service/trial.go b/system-service/service/trial.go
index f0c2178..dd72cb9 100644
--- a/system-service/service/trial.go
+++ b/system-service/service/trial.go
@@ -1,43 +1,43 @@
-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)
- }
-}
+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)
+ }
+}
--
Gitblit v1.8.0