repository/subscribeRepo.go
@@ -122,6 +122,19 @@ return err } func (s *SubscribeRepository) RemoteList(sid string) ([]byte, error) { // 查找下级 var platform models.SubPlatform err := platform.FindById(sid) if err != nil { return nil, err } uri := fmt.Sprintf("http://%s:%d/VIID/Subscribes", platform.RemoteIP, platform.RemotePort) return client.GetSubscribes(uri) } func (s *SubscribeRepository) SaveReceiveSubscribe(fromId string, subscribe *vo.Subscribe) error { var sub = models.Subscribe{ Id: subscribe.SubscribeID,
