Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4c24c4274c | ||
|
|
2a34ce6043 |
@@ -231,7 +231,7 @@ func (s *sGameAct) Del(uid int64, actId int) {
|
|||||||
keyCache := fmt.Sprintf("act:%v:%v", actId, uid)
|
keyCache := fmt.Sprintf("act:%v:%v", actId, uid)
|
||||||
|
|
||||||
//删除活动缓存
|
//删除活动缓存
|
||||||
g.Redis("redis").Del(ctx, keyCache)
|
g.Redis().Del(ctx, keyCache)
|
||||||
|
|
||||||
//删除当前活动储存
|
//删除当前活动储存
|
||||||
g.Model(Name).Where(do.GameAct{
|
g.Model(Name).Where(do.GameAct{
|
||||||
|
|||||||
@@ -7,13 +7,15 @@ import (
|
|||||||
"github.com/gogf/gf/v2/frame/g"
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
"github.com/gogf/gf/v2/os/gcron"
|
"github.com/gogf/gf/v2/os/gcron"
|
||||||
"github.com/gogf/gf/v2/os/gctx"
|
"github.com/gogf/gf/v2/os/gctx"
|
||||||
|
"github.com/gogf/gf/v2/os/gtime"
|
||||||
"github.com/gogf/gf/v2/os/gtimer"
|
"github.com/gogf/gf/v2/os/gtimer"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
ctx = gctx.New()
|
ctx = gctx.New()
|
||||||
|
startTime *gtime.Time
|
||||||
)
|
)
|
||||||
|
|
||||||
// sSystemCron 结构体定义了系统定时任务的秒计时器。
|
// sSystemCron 结构体定义了系统定时任务的秒计时器。
|
||||||
@@ -110,6 +112,12 @@ func (s *sSystemCron) AddCron(typ v1.CronType, _func func() error) {
|
|||||||
// @receiver s
|
// @receiver s
|
||||||
// @return err
|
// @return err
|
||||||
func (s *sSystemCron) StartCron() (err error) {
|
func (s *sSystemCron) StartCron() (err error) {
|
||||||
|
//预防重复启动
|
||||||
|
if startTime != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
startTime = gtime.Now()
|
||||||
|
|
||||||
g.Log().Debug(ctx, "启动计划任务定时器详情")
|
g.Log().Debug(ctx, "启动计划任务定时器详情")
|
||||||
//每秒任务
|
//每秒任务
|
||||||
gtimer.SetInterval(ctx, time.Second, func(ctx context.Context) {
|
gtimer.SetInterval(ctx, time.Second, func(ctx context.Context) {
|
||||||
|
|||||||
Reference in New Issue
Block a user