添加persons 接口

zhangzengfei

2024-06-03 7eb122e20a75ed800cc96b1565522951286e4081

 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,
@@ -135,7 +148,7 @@
      return err
   }

   service.UpdateTaskProcs(sub.Id, vo.Msg_Type_Create_Subscribe, &sub)
   service.UpdateNotificationTask(sub.Id, vo.Msg_Type_Create_Subscribe, &sub)

   return err
}
@@ -150,7 +163,7 @@
   sub.Status = subscribe.SubscribeStatus
   sub.Ext = *subscribe

   service.UpdateTaskProcs(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, nil)
   service.UpdateNotificationTask(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, &sub)

   return sub.Save()
}
@@ -162,7 +175,7 @@
      return err
   }

   service.UpdateTaskProcs(id, vo.Msg_Type_Delete_Subscribe, nil)
   service.UpdateNotificationTask(id, vo.Msg_Type_Delete_Subscribe, nil)

   return err
}