@@ -7,6 +7,8 @@ import ( | |||||
"xorm.io/xorm" | "xorm.io/xorm" | ||||
) | ) | ||||
// | |||||
func GetMoneyReward(eg *xorm.Engine, uid, date, month string) *model.MoneyReward { | func GetMoneyReward(eg *xorm.Engine, uid, date, month string) *model.MoneyReward { | ||||
var data model.MoneyReward | var data model.MoneyReward | ||||
get, err := eg.Where("uid=? and date=?", uid, date).Get(&data) | get, err := eg.Where("uid=? and date=?", uid, date).Get(&data) | ||||
@@ -4,6 +4,8 @@ import ( | |||||
"time" | "time" | ||||
) | ) | ||||
// | |||||
type MoneyReward struct { | type MoneyReward struct { | ||||
Id int `json:"id" xorm:"not null pk autoincr INT(11)"` | Id int `json:"id" xorm:"not null pk autoincr INT(11)"` | ||||
Uid int `json:"uid" xorm:"INT(11)"` | Uid int `json:"uid" xorm:"INT(11)"` | ||||
@@ -1,5 +1,7 @@ | |||||
package model | package model | ||||
// | |||||
type UserExtendTotal struct { | type UserExtendTotal struct { | ||||
Id int `json:"id" xorm:"not null pk autoincr INT(11)"` | Id int `json:"id" xorm:"not null pk autoincr INT(11)"` | ||||
Uid int `json:"uid" xorm:"default 0 INT(11)"` | Uid int `json:"uid" xorm:"default 0 INT(11)"` | ||||
@@ -435,7 +435,7 @@ var RabbitMqQueueKeyList = []*MqQueue{ | |||||
ConsumeFunName: "WithdrawConsume", | ConsumeFunName: "WithdrawConsume", | ||||
}, | }, | ||||
{ | { | ||||
ExchangeName: "canal.topic", | |||||
ExchangeName: "canal.topic", // | |||||
Name: "canal_fin_user_flow", | Name: "canal_fin_user_flow", | ||||
Type: TopicQueueType, | Type: TopicQueueType, | ||||
IsPersistent: false, | IsPersistent: false, | ||||
@@ -24,6 +24,7 @@ type CanalUserMoney struct { | |||||
UpdateAt string `json:"update_at" xorm:"updated not null default CURRENT_TIMESTAMP comment('更新时间') TIMESTAMP"` | UpdateAt string `json:"update_at" xorm:"updated not null default CURRENT_TIMESTAMP comment('更新时间') TIMESTAMP"` | ||||
} | } | ||||
// | |||||
type CanalUserMoneyMessage[T any] struct { | type CanalUserMoneyMessage[T any] struct { | ||||
Data []T `json:"data"` | Data []T `json:"data"` | ||||
Database string `json:"database"` | Database string `json:"database"` | ||||