s_cherry_e/sr/nodes/map/player/player_timer.go

package mapPlayer

import (
	"f1-game/internal/data"
	"f1-game/internal/event"
	"f1-game/nodes/map/internal/db"
	"f1-game/nodes/map/player/conscript"
	"f1-game/nodes/map/player/facility"
	"f1-game/nodes/map/player/hero"
	sandMap "f1-game/nodes/map/player/map"
	show "f1-game/nodes/map/player/show"
	"f1-game/nodes/map/player/storage"
	"f1-game/nodes/map/player/team"
	"time"
)

func (p *actorPlayer) startTimer() {
	//移除所有定时器
	p.Timer().RemoveAll()

	// 添加跨天定时器
	p.Timer().AddFixedHour(int(data.Const.ResetTime), 0, 0, p.onCrossDayTimer)
	// 添加每秒定时器
	p.Timer().Add(1*time.Second, p.every1STimer)
	// 资源定时器
	p.Timer().Add(3*time.Second, p.every3STimer)
	// 每隔5秒检查自动防守
	p.Timer().Add(5*time.Second, p.every5Stimer)
}

// onCrossDayTimer 跨天执行定时器
func (p *actorPlayer) onCrossDayTimer() {
	// 不在线不处理跨天，等下次登录的时候处理
	if !p.isOnline {
		return
	}

	// 更新时间
	p.updateNowTime()

	playerTable := db.GetMapPlayerTable(p.playerID)
	// 跨天重置处理
	p.onReset(playerTable, false)

	p.Debug("[crossDay] isOnline = %v", p.isOnline)
}

// oneSecondTimer 每1秒定时器
func (p *actorPlayer) every1STimer() {
	p.updateNowTime()

	nowSecond := p.now.ToSecond()
	facility.Service().CheckQueue(p.playerID, nowSecond)
	conscript.Service().ConscriptSettle(p.playerID, nowSecond)

	// 检查守军状态
	playerTable := db.GetMapPlayerTable(p.playerID)
	if playerTable == nil {
		return
	}
	playerTable.CheckDefendStatus(nowSecond)
	// 城外征兵
	team.Service().TeamOutsideAutoTroopsTimer(p.playerID, nowSecond)

	// 定时检测是否可以城外征兵
	team.Service().CheckCanOutsideAutoTroopsTimer(p.playerID, p.now.ToSecond())
}

// threeSecondTimer 每3秒定时器
func (p *actorPlayer) every3STimer() {
	playerTable := db.GetMapPlayerTable(p.playerID)
	if playerTable == nil {
		return
	}

	hero.Service().CheckAddEnergyTimer(playerTable, p.now.ToSecond())

	// 检查资源自动产出
	storage.Service().CheckAutoAdd(playerTable, p.now.ToSecond(), p.isOnline)

	// 检查主城显示过期
	show.Service().CheckMainCityShowExpire(playerTable, p.now.ToSecond())

	// 检查VIP是否过期
	if !playerTable.Vip.IsExpired && playerTable.Vip.ExpireTime < p.now.ToMillisecond() {
		// 设置过期状态
		playerTable.Vip.IsExpired = true
		playerTable.Save2Queue()
	}
}

func (p *actorPlayer) every5Stimer() {
	playerTable := db.GetMapPlayerTable(p.playerID)
	if playerTable == nil {
		return
	}

	// 检查自动防守
	sandMap.Service().CheckAutoDefend(playerTable, p.now.ToMillisecond())
}

// onReset 重置处理(每次登录、跨天触发)
func (p *actorPlayer) onReset(playerTable *db.MapPlayerTable, byLogin bool) {
	playerTable.Stats.CheckReset(p.now)

	// 无需重置,则跳过
	if !playerTable.Stats.IsCanReset() {
		return
	}

	// 各系统模块执行重置
	ServiceOnReset(playerTable, p.now, byLogin)

	// 发送跨天重置事件
	p.PostEvent(event.NewPlayerReset(p.playerID))

	p.Warn("daily reset finish. playerID=%d", p.playerID)
}