修复编译

zhangzengfei

2023-09-05 63645d248c765244488cd34dbc1bb6528ca6b7c7

 system-service/controllers/proxySync.go

@@ -1,30 +1,30 @@
package controllers

import (
   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/logger.git"
   "vamicro/system-service/serf"
)

type ProxySync struct {
}

/**
代理支持所有应用广播同步消息到serf集群中
*/
func (ps *ProxySync) Sync(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   type PSyncVo struct {
      Body string `json:"body"`
   }
   var reqBody PSyncVo
   err := c.BindJSON(&reqBody)
   if err != nil {
      return &bhomeclient.Reply{Msg: err.Error()}
   }
   err = serf.SyncProxy(serf.DataSystemSerfSubscribe, []byte(reqBody.Body))
   if err != nil {
      logger.Error("SyncProxy err:", err)
      return &bhomeclient.Reply{Msg: err.Error()}
   }
   return &bhomeclient.Reply{Success: true, Msg: "同步成功"}
}
package controllers



import (

   "basic.com/valib/bhomeclient.git"

   "basic.com/valib/logger.git"

   "vamicro/system-service/serf"

)



type ProxySync struct {

}



/**

代理支持所有应用广播同步消息到serf集群中

*/

func (ps *ProxySync) Sync(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {

   type PSyncVo struct {

      Body string `json:"body"`

   }

   var reqBody PSyncVo

   err := c.BindJSON(&reqBody)

   if err != nil {

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

   }

   err = serf.SyncProxy(serf.DataSystemSerfSubscribe, []byte(reqBody.Body))

   if err != nil {

      logger.Error("SyncProxy err:", err)

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

   }

   return &bhomeclient.Reply{Success: true, Msg: "同步成功"}

}