refactor(internal): 优化 OSS 预签名 URL 缓存刷新任务和英雄数据缓存逻辑
- 注释掉 OSS预签名 URL 缓存刷新任务的定时执行代码 - 在 hero/hero.go 中增加对 Redis缓存和英雄数据集的非空校验 - 修改 OSS预签名 URL 生成逻辑,自动替换为 CDN 域名
This commit is contained in:
@@ -7,12 +7,13 @@ import (
|
|||||||
"epic/internal/logic/i18n"
|
"epic/internal/logic/i18n"
|
||||||
"epic/internal/service"
|
"epic/internal/service"
|
||||||
"epic/internal/util"
|
"epic/internal/util"
|
||||||
"github.com/gogf/gf/v2/frame/g"
|
|
||||||
"github.com/gogf/gf/v2/net/ghttp"
|
|
||||||
"github.com/gogf/gf/v2/os/gcmd"
|
|
||||||
"os"
|
"os"
|
||||||
"os/signal"
|
"os/signal"
|
||||||
"syscall"
|
"syscall"
|
||||||
|
|
||||||
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
|
"github.com/gogf/gf/v2/net/ghttp"
|
||||||
|
"github.com/gogf/gf/v2/os/gcmd"
|
||||||
)
|
)
|
||||||
|
|
||||||
func CORS(r *ghttp.Request) {
|
func CORS(r *ghttp.Request) {
|
||||||
@@ -28,16 +29,16 @@ var (
|
|||||||
Func: func(ctx context.Context, parser *gcmd.Parser) (err error) {
|
Func: func(ctx context.Context, parser *gcmd.Parser) (err error) {
|
||||||
// 初始化i18n服务
|
// 初始化i18n服务
|
||||||
InitI18nService(ctx)
|
InitI18nService(ctx)
|
||||||
|
|
||||||
// 启动定时任务
|
// 启动定时任务
|
||||||
if err := service.Cron().StartAllJobs(ctx); err != nil {
|
if err := service.Cron().StartAllJobs(ctx); err != nil {
|
||||||
util.Error(ctx, "Failed to start cron jobs:", err)
|
util.Error(ctx, "Failed to start cron jobs:", err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// 设置优雅关闭
|
// 设置优雅关闭
|
||||||
setupGracefulShutdown(ctx)
|
setupGracefulShutdown(ctx)
|
||||||
|
|
||||||
s := g.Server()
|
s := g.Server()
|
||||||
s.Use(CORS)
|
s.Use(CORS)
|
||||||
s.Group("/", func(group *ghttp.RouterGroup) {
|
s.Group("/", func(group *ghttp.RouterGroup) {
|
||||||
@@ -58,17 +59,17 @@ func setupGracefulShutdown(ctx context.Context) {
|
|||||||
// 创建信号通道
|
// 创建信号通道
|
||||||
sigChan := make(chan os.Signal, 1)
|
sigChan := make(chan os.Signal, 1)
|
||||||
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
|
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
|
||||||
|
|
||||||
// 在后台监听信号
|
// 在后台监听信号
|
||||||
go func() {
|
go func() {
|
||||||
sig := <-sigChan
|
sig := <-sigChan
|
||||||
g.Log().Infof(ctx, "Received signal: %v, shutting down gracefully...", sig)
|
g.Log().Infof(ctx, "Received signal: %v, shutting down gracefully...", sig)
|
||||||
|
|
||||||
// 停止定时任务
|
// 停止定时任务
|
||||||
if err := service.Cron().StopAllJobs(ctx); err != nil {
|
if err := service.Cron().StopAllJobs(ctx); err != nil {
|
||||||
util.Error(ctx, "Failed to stop cron jobs:", err)
|
util.Error(ctx, "Failed to stop cron jobs:", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// 退出程序
|
// 退出程序
|
||||||
os.Exit(0)
|
os.Exit(0)
|
||||||
}()
|
}()
|
||||||
@@ -79,6 +80,6 @@ func InitI18nService(ctx context.Context) {
|
|||||||
// 启动i18n自动刷新
|
// 启动i18n自动刷新
|
||||||
i18nLogic := i18n.New()
|
i18nLogic := i18n.New()
|
||||||
i18nLogic.StartAutoRefresh(ctx)
|
i18nLogic.StartAutoRefresh(ctx)
|
||||||
|
|
||||||
util.Info(ctx, "i18n服务初始化完成")
|
util.Info(ctx, "i18n服务初始化完成")
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user