fix: add new models to autoMigrate and start season reset worker
This commit is contained in:
parent
edfa5f1449
commit
8dce6ae11a
@ -7,6 +7,7 @@ import (
|
|||||||
"os/signal"
|
"os/signal"
|
||||||
"strconv"
|
"strconv"
|
||||||
"syscall"
|
"syscall"
|
||||||
|
"time"
|
||||||
|
|
||||||
"dubbo.apache.org/dubbo-go/v3/client"
|
"dubbo.apache.org/dubbo-go/v3/client"
|
||||||
_ "dubbo.apache.org/dubbo-go/v3/imports"
|
_ "dubbo.apache.org/dubbo-go/v3/imports"
|
||||||
@ -151,6 +152,18 @@ func main() {
|
|||||||
rankingProvider := provider.NewRankingProvider(rankingService)
|
rankingProvider := provider.NewRankingProvider(rankingService)
|
||||||
logger.Logger.Info("Provider layer initialized")
|
logger.Logger.Info("Provider layer initialized")
|
||||||
|
|
||||||
|
// 启动赛季重置 Worker(每小时检查一次)
|
||||||
|
seasonResetWorker := assetLevelProvider.GetSeasonResetWorker()
|
||||||
|
go func() {
|
||||||
|
ticker := time.NewTicker(time.Hour)
|
||||||
|
defer ticker.Stop()
|
||||||
|
for {
|
||||||
|
<-ticker.C
|
||||||
|
seasonResetWorker.Run()
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
logger.Logger.Info("Season reset worker started")
|
||||||
|
|
||||||
// 创建 Dubbo 服务器
|
// 创建 Dubbo 服务器
|
||||||
srv, err := server.NewServer(
|
srv, err := server.NewServer(
|
||||||
server.WithServerProtocol(
|
server.WithServerProtocol(
|
||||||
@ -206,6 +219,10 @@ func autoMigrate() error {
|
|||||||
&models.AssetLike{},
|
&models.AssetLike{},
|
||||||
&models.Material{},
|
&models.Material{},
|
||||||
&models.AssetMaterialRelation{},
|
&models.AssetMaterialRelation{},
|
||||||
|
&models.AssetLevelRecord{},
|
||||||
|
&models.AssetLevelChangeLog{},
|
||||||
|
&models.Season{},
|
||||||
|
&models.SeasonDecayConfig{},
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, table := range tables {
|
for _, table := range tables {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user