|
|
@@ -5,6 +5,7 @@ import (
|
|
|
"app/commons/core"
|
|
|
"app/commons/model/entity"
|
|
|
"fmt"
|
|
|
+
|
|
|
"github.com/spf13/cobra"
|
|
|
"gorm.io/gorm"
|
|
|
)
|
|
|
@@ -40,42 +41,11 @@ type MigrateTable interface {
|
|
|
}
|
|
|
|
|
|
var allTables = []MigrateTable{
|
|
|
- // 系统配置信息
|
|
|
- entity.NewSysSignConfig(),
|
|
|
- entity.NewAssetConfig(),
|
|
|
- entity.NewSysI18n(),
|
|
|
- entity.NewSysCoin(),
|
|
|
- entity.NewSysLevelConfig(),
|
|
|
- entity.NewSysJob(),
|
|
|
- // 用户
|
|
|
- entity.NewUser(),
|
|
|
- entity.NewUserQuota(),
|
|
|
- entity.NewUserLogs(),
|
|
|
- entity.NewUserRelationActionLog(),
|
|
|
- // 资产模块
|
|
|
- entity.NewAsset(),
|
|
|
- entity.NewAssetBill(),
|
|
|
- entity.NewAssetRwRecord(),
|
|
|
- entity.NewAssetRwCallbackLog(),
|
|
|
- // 新增指标模块
|
|
|
- entity.NewUserProfit(),
|
|
|
- entity.NewUserProfitRecord(),
|
|
|
- // 节点模块
|
|
|
- entity.NewNodeOrderPayments(),
|
|
|
- entity.NewNodeOrder(),
|
|
|
- entity.NewNodeInfo(),
|
|
|
- entity.NewNodeBanner(),
|
|
|
- // 业务模块
|
|
|
- entity.NewStakeProduct(), // 产品
|
|
|
- entity.NewStakeUserCurrentOrder(), // 活期订单
|
|
|
- entity.NewStakeUserCurrentOpsRecord(), // 活期操作记录
|
|
|
- //entity.NewStakeUserOrderPeriodSnapshot(), // 每期快照
|
|
|
- entity.NewStakeQueueInfo(), // 每气排队信息
|
|
|
- entity.NewStakePeriodJob(), // 每期任务
|
|
|
- // 促销活动模块
|
|
|
- entity.NewPromotionUpgradeLevel(), // 升级奖
|
|
|
+ // 系统表(仅保留必需的)
|
|
|
+ // entity.NewSysI18n(), // 国际化
|
|
|
+ entity.NewUserLogs(), // 用户操作日志(审计)
|
|
|
|
|
|
- // DayTask模块
|
|
|
+ // DayTask模块(核心业务表)
|
|
|
entity.NewDtUser(),
|
|
|
entity.NewDtUserLevel(),
|
|
|
entity.NewDtUserSocial(),
|
|
|
@@ -99,6 +69,41 @@ var allTables = []MigrateTable{
|
|
|
entity.NewDtCustomerService(),
|
|
|
}
|
|
|
|
|
|
+// 其他业务模块的表(暂时不使用,需要时再启用)
|
|
|
+var deprecatedTables = []MigrateTable{
|
|
|
+ // 系统配置信息
|
|
|
+ // entity.NewSysSignConfig(),
|
|
|
+ // entity.NewAssetConfig(),
|
|
|
+ // entity.NewSysCoin(),
|
|
|
+ // entity.NewSysLevelConfig(),
|
|
|
+ // entity.NewSysJob(),
|
|
|
+ // // 用户
|
|
|
+ // entity.NewUser(),
|
|
|
+ // entity.NewUserQuota(),
|
|
|
+ // entity.NewUserRelationActionLog(),
|
|
|
+ // // 资产模块
|
|
|
+ // entity.NewAsset(),
|
|
|
+ // entity.NewAssetBill(),
|
|
|
+ // entity.NewAssetRwRecord(),
|
|
|
+ // entity.NewAssetRwCallbackLog(),
|
|
|
+ // // 新增指标模块
|
|
|
+ // entity.NewUserProfit(),
|
|
|
+ // entity.NewUserProfitRecord(),
|
|
|
+ // // 节点模块
|
|
|
+ // entity.NewNodeOrderPayments(),
|
|
|
+ // entity.NewNodeOrder(),
|
|
|
+ // entity.NewNodeInfo(),
|
|
|
+ // entity.NewNodeBanner(),
|
|
|
+ // // 业务模块
|
|
|
+ // entity.NewStakeProduct(),
|
|
|
+ // entity.NewStakeUserCurrentOrder(),
|
|
|
+ // entity.NewStakeUserCurrentOpsRecord(),
|
|
|
+ // entity.NewStakeQueueInfo(),
|
|
|
+ // entity.NewStakePeriodJob(),
|
|
|
+ // // 促销活动模块
|
|
|
+ // entity.NewPromotionUpgradeLevel(),
|
|
|
+}
|
|
|
+
|
|
|
func migrateMain(db *gorm.DB) {
|
|
|
CurrentDatabase := db.Migrator().CurrentDatabase()
|
|
|
core.Log.Info(fmt.Sprintf("当前数据库[%s]", CurrentDatabase))
|