增加单元测试，统一初始化方法

internal/boot/boot.go

@@ -1,28 +1,46 @@
 package boot
 
 import (
-	"context"
 	v1 "github.com/ayflying/utility_go/api/system/v1"
+	"github.com/ayflying/utility_go/drivers/db/elasticsearch"
+	"github.com/ayflying/utility_go/pkg/aycache"
 	"github.com/ayflying/utility_go/service"
 	"github.com/gogf/gf/v2/os/gctx"
-	"github.com/gogf/gf/v2/os/gtimer"
-	"time"
+	"math"
 )
 
 var (
-	ctx = gctx.GetInitCtx()
+	ctx   = gctx.GetInitCtx()
+	_func = []func(){}
 )
 
 func Boot() (err error) {
 	err = service.SystemCron().StartCron()
 
 	//用户活动持久化
-	gtimer.SetTimeout(ctx, time.Minute, func(ctx context.Context) {
-		service.SystemCron().AddCron(v1.CronType_DAILY, func() error {
-			service.GameAct().Saves()
-			return nil
-		})
+	service.SystemCron().AddCron(v1.CronType_DAILY, func() error {
+		return service.GameAct().Saves()
 	})
 
+	//初始化ES
+	elasticsearch.Init()
+
+	//初始化指标
+	service.SystemCron().AddCron(v1.CronType_MINUTE, func() error {
+		aycache.QPS.Set(math.Round(float64(aycache.QPSCount) / 60))
+		aycache.QPSCount = 0
+		return nil
+	})
+
+	//初始化自启动方法
+	for _, v := range _func {
+		v()
+	}
+
 	return nil
 }
+
+// AddFunc 注册方法，在启动时执行
+func AddFunc(f func()) {
+	_func = append(_func, f)
+}

internal/logic/gameAct/gameAct.go

@@ -11,6 +11,7 @@ import (
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gctx"
 	"github.com/gogf/gf/v2/os/gtime"
+	"github.com/gogf/gf/v2/util/gconv"
 	"strconv"
 	"strings"
 	"time"
@@ -130,7 +131,8 @@ func (s *sGameAct) Save(actId int) (err error) {
 			result := strings.Split(cacheKey, ":")
 			actId, err = strconv.Atoi(result[1])
 			var uid int64
-			uid, err = strconv.ParseInt(result[2], 10, 64)
+			uid = gconv.Int64(result[2])
+			//uid, err = strconv.ParseInt(result[2], 10, 64)
 			if err != nil {
 				continue
 			}