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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
package res_m
import (
"git.hilo.cn/hilo-common/domain"
"git.hilo.cn/hilo-common/resource/mysql"
"gorm.io/gorm"
"gorm.io/gorm/clause"
"hilo-group/_const/enum/gift_e"
"hilo-group/myerr"
"hilo-group/myerr/bizerr"
)
type ResGift struct {
mysql.Entity
//*domain.ModelBase `gorm:"-"`
*domain.Model `gorm:"-"`
Name mysql.Str
IconUrl mysql.Str
SvagUrl mysql.Str
MusicUrl mysql.Str
Column uint16
DiamondNum mysql.Num
BeanNum mysql.Num
ReceiveDiamondNum mysql.Num
Second mysql.Num // obsolete
N mysql.Num
GroupBroadcast bool
Cp bool
Together bool
Status mysql.UserYesNo
GiftType mysql.Type
}
func (rg *ResGift) FindValid(db *gorm.DB) ([]ResGift, error) {
rows := make([]ResGift, 0)
rg.Status = mysql.USER
if err := db.Where(rg).Order("n ASC").Find(&rows).Error; err != nil {
return nil, err
}
return rows, nil
}
type ResGiftAvatar struct {
mysql.Entity
//*domain.ModelBase `gorm:"-"`
*domain.Model `gorm:"-"`
ResGiftId mysql.ID
Type gift_e.ResGiftAvatarType
SendUserId mysql.ID
ReceiverUserId mysql.ID
}
func (rga *ResGiftAvatar) Find(db *gorm.DB) ([]ResGiftAvatar, error) {
rows := make([]ResGiftAvatar, 0)
if err := db.Where(rga).Find(&rows).Error; err != nil {
return nil, err
}
return rows, nil
}
func (rga *ResGiftAvatar) Save(db *gorm.DB) error {
return db.Clauses(clause.OnConflict{
DoUpdates: clause.AssignmentColumns([]string{"send_user_id"}),
}).Create(rga).Error
}
func GetResGiftAvatar(model *domain.Model, t gift_e.ResGiftAvatarType) (ResGiftAvatar, error) {
resGiftAvatar := ResGiftAvatar{}
if err := model.Db.Model(&ResGiftAvatar{}).Where(&ResGiftAvatar{
Type: t,
}).First(&resGiftAvatar).Error; err != nil {
return ResGiftAvatar{}, myerr.WrapErr(err)
}
return resGiftAvatar, nil
}
/**
* 获取礼物
**/
func GetGiftWithValid(model *domain.Model, id mysql.ID) (*ResGift, error) {
var resGift ResGift
if err := model.Db.First(&resGift, id).Error; err != nil {
return nil, myerr.WrapErr(err)
}
if resGift.Status == mysql.NOUSER {
return nil, bizerr.ResGiftNoUser
}
return &resGift, nil
}
func (gift *ResGift) StatusToCancle() *ResGift {
gift.Status = 1
return gift
}
/**
* 根据排序号查询礼物配置
**/
func GetGiftByOrderId(model *domain.Model, n mysql.Num) (*ResGift, error) {
var resGift ResGift
if err := model.Db.Where("n = ?", n).First(&resGift).Error; err != nil {
if err == gorm.ErrRecordNotFound {
return nil, nil
} else {
return nil, myerr.WrapErr(err)
}
}
return &resGift, nil
}
/**
* 添加礼物配置
**/
func AddGiftConfig(model *domain.Model, input ResGift) error {
return model.Db.Create(&input).Error
}
/**
* 修改礼物配置
**/
func UpdateGift(model *domain.Model, input ResGift) error {
return model.Db.Omit("music_url", "GroupBroadcast", "cp", "together").Save(&input).Error
}
func UpdateGiftStatus(model *domain.Model, giftId mysql.ID, status mysql.UserYesNo) error {
return model.Db.Table("res_gift").Where("id = ?", giftId).Update("status", status).Error
}
func GetGiftN(db *gorm.DB, n mysql.Num) ([]mysql.Num, error) {
rows := make([]ResGift, 0)
if err := db.Model(&ResGift{}).Where("n >= ?", n).Order("n").Find(&rows).Error; err != nil {
return nil, err
}
result := make([]mysql.Num, 0)
for _, i := range rows {
result = append(result, i.N)
}
return result, nil
}
func UpdateGiftN(model *domain.Model, beginN, endN mysql.Num) error {
return model.Db.Table("res_gift").Where("n >= ? AND n < ?", beginN, endN).Update("n", gorm.Expr("n+1")).Error
}
type GiftDetailInfo struct {
IconUrl string `json:"iconUrl"`
SvgaUrl string `json:"svgaUrl"`
SenderAvatar string `json:"senderAvatar"` //key：sender_avatar
ReceiverAvatar string `json:"receiverAvatar"` //key：receiver_avatar
}