修复集群功能

zhangzengfei

2023-10-18 daac628c64069633787588372dea22499ac35396

 system-service/controllers/cluster.go

@@ -25,7 +25,7 @@
   var clusterE models.Cluster
   var reply = bhomeclient.Reply{
      Success: false,
      Msg:     "leave",
      Msg:     "",
      Data:    nil,
   }

@@ -37,9 +37,9 @@

         var nodeE models.Node
         nodes, _ := nodeE.FindNodesByClusterId(arr[0].ClusterId)
         logger.Debug("查询集群节点:", nodes)
         //logger.Debug("查询集群节点:", nodes)
         for _, node := range nodes {
            logger.Debug("节点:", node.NodeId, " servceId:", config.Server.AnalyServerId, " stat:", node.DriftState)
            //logger.Debug("节点:", node.NodeId, " serverId:", config.Server.AnalyServerId, " stat:", node.DriftState)
            if node.NodeId == config.Server.AnalyServerId {
               if node.DriftState == "master" {
                  reply.Msg = "master"
@@ -50,6 +50,7 @@
               break
            }
         }
         reply.Data = nodes
      }
   }