diff --git a/app/db/db_money_reward.go b/app/db/db_money_reward.go index 1008198..af4ca8b 100644 --- a/app/db/db_money_reward.go +++ b/app/db/db_money_reward.go @@ -7,6 +7,8 @@ import ( "xorm.io/xorm" ) +// + func GetMoneyReward(eg *xorm.Engine, uid, date, month string) *model.MoneyReward { var data model.MoneyReward get, err := eg.Where("uid=? and date=?", uid, date).Get(&data) diff --git a/app/db/model/money_reward.go b/app/db/model/money_reward.go index e9414f4..8bad5b3 100644 --- a/app/db/model/money_reward.go +++ b/app/db/model/money_reward.go @@ -4,6 +4,8 @@ import ( "time" ) +// + type MoneyReward struct { Id int `json:"id" xorm:"not null pk autoincr INT(11)"` Uid int `json:"uid" xorm:"INT(11)"` diff --git a/app/db/model/user_extend_total.go b/app/db/model/user_extend_total.go index cb15913..c881d3d 100644 --- a/app/db/model/user_extend_total.go +++ b/app/db/model/user_extend_total.go @@ -1,5 +1,7 @@ package model +// + type UserExtendTotal struct { Id int `json:"id" xorm:"not null pk autoincr INT(11)"` Uid int `json:"uid" xorm:"default 0 INT(11)"` diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index 299ce10..e175bb2 100644 --- a/consume/md/consume_key.go +++ b/consume/md/consume_key.go @@ -435,7 +435,7 @@ var RabbitMqQueueKeyList = []*MqQueue{ ConsumeFunName: "WithdrawConsume", }, { - ExchangeName: "canal.topic", + ExchangeName: "canal.topic", // Name: "canal_fin_user_flow", Type: TopicQueueType, IsPersistent: false, diff --git a/consume/md/md_canal_user_money.go b/consume/md/md_canal_user_money.go index a1de585..8188e76 100644 --- a/consume/md/md_canal_user_money.go +++ b/consume/md/md_canal_user_money.go @@ -24,6 +24,7 @@ type CanalUserMoney struct { UpdateAt string `json:"update_at" xorm:"updated not null default CURRENT_TIMESTAMP comment('更新时间') TIMESTAMP"` } +// type CanalUserMoneyMessage[T any] struct { Data []T `json:"data"` Database string `json:"database"`