zhangzengfei
2024-10-20 b916f7c68a3e16413eac4be13f0404267561f90c
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
45
46
47
48
49
package models
 
import (
    "gat1400Exchange/vo"
)
 
type Subscribe struct {
    Id         string       `gorm:"column:id;primary_key;" json:"id"`
    Status     int          `gorm:"column:status" json:"status"` // 0:订阅中 1:已取消订阅 2:订阅到期 9:未订阅
    FromId     string       `gorm:"column:from_id" json:"from_id"`
    Ext        vo.Subscribe `gorm:"column:ext;type:json;not null;default '{}'" json:"ext"`
    CreateTime int64        `gorm:"column:create_time;autoCreateTime;" json:"create_time"`
    UpdateTime int64        `gorm:"column:update_time;autoUpdateTime" json:"-"`
    DeleteTime int64        `gorm:"column:delete_time" json:"-"`
}
 
func (s *Subscribe) TableName() string {
    return "subscribes"
}
 
func (s *Subscribe) FindById(id string) error {
    return db.Table(s.TableName()).First(&s, "id = ?", id).Error
}
 
func (s *Subscribe) Save() error {
    return db.Table(s.TableName()).Save(s).Error
}
 
func (s *Subscribe) DeleteById(id string) error {
    return db.Table(s.TableName()).Where("id = ?", id).Delete(s).Error
}
 
func (s *Subscribe) FindAll() ([]Subscribe, error) {
    var subs []Subscribe
    if err := db.Table(s.TableName()).Find(&subs).Error; err != nil {
        return nil, err
    }
 
    return subs, nil
}
 
func (s *Subscribe) FindByFromId(fromId string) ([]Subscribe, error) {
    var subs []Subscribe
    if err := db.Table(s.TableName()).Where("from_id = ?", fromId).Find(&subs).Error; err != nil {
        return nil, err
    }
 
    return subs, nil
}