添加级联,订阅功能

zhangzengfei

2024-05-16 790c60c55054b3e75043eaed11eaef8584d2001d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package repository
 
import (
    "gat1400Exchange/models"
    "gat1400Exchange/service"
    "gat1400Exchange/vo"
)
 
type SubscribeRepository struct {
}
 
func NewSubscribeRepository() SubscribeRepository {
    return SubscribeRepository{}
}
 
func (a *SubscribeRepository) CreateSubscribe(fromId string, subscribe *vo.Subscribe) error {
    var sub = models.Subscribe{
        Id:     subscribe.SubscribeID,
        Status: subscribe.SubscribeStatus,
        FromId: fromId,
        Ext:    *subscribe,
    }
 
    err := sub.Save()
    if err != nil {
        return err
    }
 
    service.UpdateTaskProcs(sub.Id, vo.Msg_Type_Create_Subscribe, &sub)
 
    return err
}
 
func (a *SubscribeRepository) DeleteSubscribe(id string) error {
    var sub = models.Subscribe{}
    err := sub.DeleteById(id)
    if err != nil {
        return err
    }
 
    service.UpdateTaskProcs(id, vo.Msg_Type_Delete_Subscribe, nil)
 
    return err
}