修复编译

zhangzengfei

2023-09-05 63645d248c765244488cd34dbc1bb6528ca6b7c7

 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)

   }

}