From 1dd95f787aaeaa13092c11c9fcacd18d8f16508a Mon Sep 17 00:00:00 2001 From: hu xiaotong <416314413@163.com> Date: Mon, 27 Oct 2025 17:16:35 +0800 Subject: [PATCH] =?UTF-8?q?refactor(internal):=20=E4=BC=98=E5=8C=96=20OSS?= =?UTF-8?q?=20=E9=A2=84=E7=AD=BE=E5=90=8D=20URL=20=E7=BC=93=E5=AD=98?= =?UTF-8?q?=E5=88=B7=E6=96=B0=E4=BB=BB=E5=8A=A1=E5=92=8C=E8=8B=B1=E9=9B=84?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E7=BC=93=E5=AD=98=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 注释掉 OSS预签名 URL 缓存刷新任务的定时执行代码 - 在 hero/hero.go 中增加对 Redis缓存和英雄数据集的非空校验 - 修改 OSS预签名 URL 生成逻辑,自动替换为 CDN 域名 --- internal/cmd/cmd.go | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/internal/cmd/cmd.go b/internal/cmd/cmd.go index 337dace..d95ef8e 100644 --- a/internal/cmd/cmd.go +++ b/internal/cmd/cmd.go @@ -7,12 +7,13 @@ import ( "epic/internal/logic/i18n" "epic/internal/service" "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/signal" "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) { @@ -28,16 +29,16 @@ var ( Func: func(ctx context.Context, parser *gcmd.Parser) (err error) { // 初始化i18n服务 InitI18nService(ctx) - + // 启动定时任务 if err := service.Cron().StartAllJobs(ctx); err != nil { util.Error(ctx, "Failed to start cron jobs:", err) return err } - + // 设置优雅关闭 setupGracefulShutdown(ctx) - + s := g.Server() s.Use(CORS) s.Group("/", func(group *ghttp.RouterGroup) { @@ -58,17 +59,17 @@ func setupGracefulShutdown(ctx context.Context) { // 创建信号通道 sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM) - + // 在后台监听信号 go func() { sig := <-sigChan g.Log().Infof(ctx, "Received signal: %v, shutting down gracefully...", sig) - + // 停止定时任务 if err := service.Cron().StopAllJobs(ctx); err != nil { util.Error(ctx, "Failed to stop cron jobs:", err) } - + // 退出程序 os.Exit(0) }() @@ -79,6 +80,6 @@ func InitI18nService(ctx context.Context) { // 启动i18n自动刷新 i18nLogic := i18n.New() i18nLogic.StartAutoRefresh(ctx) - + util.Info(ctx, "i18n服务初始化完成") }