添加订阅修改接口

zhangzengfei

2024-05-16 e5be7a7ed63d4b4e4267057d84b77c4bd3c16781

 repository/subscribeRepo.go

@@ -13,7 +13,7 @@
   return SubscribeRepository{}
}

func (a *SubscribeRepository) CreateSubscribe(fromId string, subscribe *vo.Subscribe) error {
func (s *SubscribeRepository) CreateSubscribe(fromId string, subscribe *vo.Subscribe) error {
   var sub = models.Subscribe{
      Id:     subscribe.SubscribeID,
      Status: subscribe.SubscribeStatus,
@@ -31,7 +31,22 @@
   return err
}

func (a *SubscribeRepository) DeleteSubscribe(id string) error {
func (s *SubscribeRepository) UpdateSubscribe(subscribe *vo.Subscribe) error {
   var sub = models.Subscribe{}
   err := sub.FindById(subscribe.SubscribeID)
   if err != nil {
      return err
   }

   sub.Status = subscribe.SubscribeStatus
   sub.Ext = *subscribe

   service.UpdateTaskProcs(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, nil)

   return sub.Save()
}

func (s *SubscribeRepository) DeleteSubscribe(id string) error {
   var sub = models.Subscribe{}
   err := sub.DeleteById(id)
   if err != nil {
@@ -42,3 +57,9 @@

   return err
}

func (s *SubscribeRepository) List() ([]models.Subscribe, error) {
   var sub models.Subscribe

   return sub.FindAll()
}