| | |
| | | return err |
| | | } |
| | | |
| | | service.UpdateTaskProcs(sub.Id, vo.Msg_Type_Create_Subscribe, &sub) |
| | | service.UpdateNotificationTask(sub.Id, vo.Msg_Type_Create_Subscribe, &sub) |
| | | |
| | | return err |
| | | } |
| | |
| | | sub.Status = subscribe.SubscribeStatus |
| | | sub.Ext = *subscribe |
| | | |
| | | service.UpdateTaskProcs(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, &sub) |
| | | service.UpdateNotificationTask(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, &sub) |
| | | |
| | | return sub.Save() |
| | | } |
| | |
| | | return err |
| | | } |
| | | |
| | | service.UpdateTaskProcs(id, vo.Msg_Type_Delete_Subscribe, nil) |
| | | service.UpdateNotificationTask(id, vo.Msg_Type_Delete_Subscribe, nil) |
| | | |
| | | return err |
| | | } |