From d72106a08e67b4e8869efbcb091a312f6f853563 Mon Sep 17 00:00:00 2001
From: liaoyulong <liaoyulong@adesk.com>
Date: Mon, 9 Mar 2026 14:10:33 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4act=E6=8C=81=E4=B9=85?=
 =?UTF-8?q?=E5=8C=96=E6=96=B9=E6=A1=88=E4=B8=8D=E6=94=BE=E5=9C=A8=E5=AE=9A?=
 =?UTF-8?q?=E6=97=B6=E4=BB=BB=E5=8A=A1=E4=B8=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/boot/boot.go             | 27 ++++++++++++++++++++-------
 internal/logic/gameAct/gameAct.go |  3 +--
 service/game_act.go               |  5 +++++
 service/game_kv.go                |  9 +++++++--
 4 files changed, 33 insertions(+), 11 deletions(-)

diff --git a/internal/boot/boot.go b/internal/boot/boot.go
index 811c5fd..70cf8ce 100644
--- a/internal/boot/boot.go
+++ b/internal/boot/boot.go
@@ -2,11 +2,12 @@ package boot
 
 import (
 	"context"
+	"time"
 
-	v1 "github.com/ayflying/utility_go/api/system/v1"
 	"github.com/ayflying/utility_go/service"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gctx"
+	"github.com/gogf/gf/v2/os/gtimer"
 )
 
 var (
@@ -18,17 +19,29 @@ func Boot() (err error) {
 	// 启动计划任务定时器，预防debug工具激活计划任务造成重复执行，此处不执行计划任务
 	//err = service.SystemCron().StartCron()
 
-	//用户活动持久化每小时执行一次
-	service.SystemCron().AddCronV2(v1.CronType_HOUR, func(context.Context) error {
-		go func() {
+	// //用户活动持久化每小时执行一次
+	// service.SystemCron().AddCronV2(v1.CronType_HOUR, func(context.Context) error {
+	// 	go func() {
+	// 		err = service.GameKv().SavesV1()
+	// 		err = service.GameAct().SavesV2()
+	// 		if err != nil {
+	// 			g.Log().Error(gctx.New(), err)
+	// 		}
+	// 	}()
+	// 	return nil
+	// }, true)
+
+	//延迟6秒执行定时器
+	gtimer.SetTimeout(ctx, time.Second*10, func(ctx context.Context) {
+		gtimer.SetInterval(ctx, time.Hour*2, func(ctx context.Context) {
 			err = service.GameKv().SavesV1()
 			err = service.GameAct().SavesV2()
 			if err != nil {
 				g.Log().Error(gctx.New(), err)
 			}
-		}()
-		return nil
-	}, true)
+		})
+
+	})
 
 	//初始化自启动方法
 	for _, v := range _func {
diff --git a/internal/logic/gameAct/gameAct.go b/internal/logic/gameAct/gameAct.go
index acb2436..0dc9c27 100644
--- a/internal/logic/gameAct/gameAct.go
+++ b/internal/logic/gameAct/gameAct.go
@@ -293,7 +293,7 @@ func (s *sGameAct) Save(ctx context.Context, actId int) (err error) {
 func (s *sGameAct) SavesV2() (err error) {
 	var ctx = gctx.New()
 	g.Log().Debug(ctx, "开始执行游戏act数据保存了")
-	RunTimeMax = gtime.Now().Add(time.Minute * 30)
+	RunTimeMax = gtime.Now().Add(time.Minute * 60)
 
 	// 使用局部通道替代包级通道，避免并发冲突
 	addChan := make(chan *entity.GameAct, 1000)
@@ -783,7 +783,6 @@ func (s *sGameAct) DelCacheKey(ctx context.Context, aid int, uid int64) {
 		g.Log().Error(ctx, err)
 	}
 }
-}
 
 // 清空GetRedDot缓存
 func (s *sGameAct) RefreshGetRedDotCache(uid int64) {
diff --git a/service/game_act.go b/service/game_act.go
index 6285bfd..e7e8501 100644
--- a/service/game_act.go
+++ b/service/game_act.go
@@ -76,6 +76,11 @@ type (
 		// Cache2AddChan 批量添加数据库
 		Cache2SqlChan(ctx context.Context, addChan chan *entity.GameAct, updateChan chan *entity.GameAct)
 		// SaveV2Batch 批量保存游戏活动数据 (优化版)
+		//
+		// @Description: 使用批量Redis MGET和批量数据库操作提升性能
+		// @param ctx context.Context: 上下文对象
+		// @param cacheKeys []string: 缓存键列表
+		// @return err error: 返回错误信息
 		SaveV2Batch(ctx context.Context, cacheKeys []string) (err error)
 		// 删除缓存key
 		DelCacheKey(ctx context.Context, aid int, uid int64)
diff --git a/service/game_kv.go b/service/game_kv.go
index 1f5ce6d..c1d3fd9 100644
--- a/service/game_kv.go
+++ b/service/game_kv.go
@@ -17,10 +17,15 @@ type (
 		// @receiver s: sGameKv的实例。
 		// @return err: 错误信息，如果操作成功，则为nil。
 		SavesV1() (err error)
-		// SavesV2Batch 批量保存游戏KV数据 (优化版)
-		SavesV2Batch(ctx context.Context, cacheKeys []string) (err error)
 		// 删除缓存key
 		DelCacheKey(ctx context.Context, uid int64)
+		// SavesV2Batch 批量保存游戏KV数据 (优化版)
+		//
+		// @Description: 使用批量Redis MGET和批量数据库操作提升性能
+		// @param ctx context.Context: 上下文对象
+		// @param cacheKeys []string: 缓存键列表
+		// @return err error: 返回错误信息
+		SavesV2Batch(ctx context.Context, cacheKeys []string) (err error)
 	}
 )