From db6b066e20b525ff30d2bc1c71173a74b5410f21 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Wed, 10 Apr 2024 14:04:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=80=E4=B8=AA=E6=A9=98=E5=AD=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/db/db_money_reward.go | 2 ++ app/db/model/money_reward.go | 2 ++ app/db/model/user_extend_total.go | 2 ++ consume/md/consume_key.go | 2 +- consume/md/md_canal_user_money.go | 1 + 5 files changed, 8 insertions(+), 1 deletion(-) 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"`