修复编译

zhangzengfei

2023-09-05 63645d248c765244488cd34dbc1bb6528ca6b7c7

 system-service/controllers/syncEsNode.go

@@ -1,38 +1,38 @@
package controllers

import (
   "basic.com/pubsub/esutil.git"
   "basic.com/valib/bhomeclient.git"
   "vamicro/config"
   "vamicro/system-service/sys"
)

type SyncEsNodeController struct {
}

type HostInfo struct {
   BinPath    string   `json:"binPath"`
   ConfigPath string   `json:"configPath"`
   Hosts      []string `json:"hosts"`
}

//同步Hosts
func (sen *SyncEsNodeController) SynchronizeHosts(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   var hi HostInfo
   c.BindJSON(&hi)
   localIp, _, _ := sys.GetLocalIP(config.Server.NetworkAdapter)
   localPort := "9200"
   sp := esutil.StopServer(hi.BinPath, localIp, localPort)
   if sp == false {
      return &bhomeclient.Reply{Msg: "配置文件错误，本机ip获取失败"}
   }
   _, errS := esutil.SetDiscoveryZenPingUnicastHosts(hi.ConfigPath, hi.Hosts)
   if errS != nil {
      return &bhomeclient.Reply{Msg: errS.Error()}
   }
   st := esutil.StartServer(hi.BinPath, localIp, localPort)
   if st == false {
      return &bhomeclient.Reply{Msg: "服务启动超时"}
   }
   return &bhomeclient.Reply{Success: true, Msg: "修改成功"}
}
package controllers



import (

   "basic.com/pubsub/esutil.git"

   "basic.com/valib/bhomeclient.git"

   "vamicro/config"

   "vamicro/system-service/sys"

)



type SyncEsNodeController struct {

}



type HostInfo struct {

   BinPath    string   `json:"binPath"`

   ConfigPath string   `json:"configPath"`

   Hosts      []string `json:"hosts"`

}



//同步Hosts

func (sen *SyncEsNodeController) SynchronizeHosts(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {

   var hi HostInfo

   c.BindJSON(&hi)

   localIp, _, _ := sys.GetLocalIP(config.Server.NetworkAdapter)

   localPort := "9200"

   sp := esutil.StopServer(hi.BinPath, localIp, localPort)

   if sp == false {

      return &bhomeclient.Reply{Msg: "配置文件错误，本机ip获取失败"}

   }

   _, errS := esutil.SetDiscoveryZenPingUnicastHosts(hi.ConfigPath, hi.Hosts)

   if errS != nil {

      return &bhomeclient.Reply{Msg: errS.Error()}

   }

   st := esutil.StartServer(hi.BinPath, localIp, localPort)

   if st == false {

      return &bhomeclient.Reply{Msg: "服务启动超时"}

   }

   return &bhomeclient.Reply{Success: true, Msg: "修改成功"}

}