From 83531b65c6d9b9ffc23247ea0dc86ce6a1214aae Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Mon, 26 Jun 2023 20:09:33 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9E=E6=B8=B8=E6=88=8F?= =?UTF-8?q?=E6=B4=BB=E5=8A=A8=E5=8A=9F=E8=83=BD=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 允许创建具有开始结束时间的活动，支持通过事件的方式针对活动开始、活动结束、新的一天、玩家新的一天的情况进行处理 --- game/activity/activity.go | 223 ++++++++++++++++++++++++++++++ game/activity/activity_events.go | 6 + game/activity/activity_options.go | 64 +++++++++ 3 files changed, 293 insertions(+) create mode 100644 game/activity/activity.go create mode 100644 game/activity/activity_events.go create mode 100644 game/activity/activity_options.go diff --git a/game/activity/activity.go b/game/activity/activity.go new file mode 100644 index 0000000..71fa124 --- /dev/null +++ b/game/activity/activity.go @@ -0,0 +1,223 @@ +package activity + +import ( + "fmt" + "github.com/kercylan98/minotaur/utils/hash" + "github.com/kercylan98/minotaur/utils/offset" + "github.com/kercylan98/minotaur/utils/timer" + "github.com/kercylan98/minotaur/utils/times" + "time" +) + +func New[PlayerID comparable, Data any, PlayerData any](id int64, startTime, endTime time.Time, data Data, generatePlayerDataHandle func() PlayerData, options ...Option[PlayerID, Data, PlayerData]) *Activity[PlayerID, Data, PlayerData] { + activity := &Activity[PlayerID, Data, PlayerData]{ + id: id, + playerData: make(map[PlayerID]PlayerData), + newDay: map[PlayerID]int64{}, + online: map[PlayerID]struct{}{}, + data: data, + generatePlayerDataHandle: generatePlayerDataHandle, + } + for _, option := range options { + option(activity) + } + if activity.offset == nil { + activity.offset = offset.NewTime(0) + } + if activity.ticker == nil { + activity.ticker = timer.GetTicker(5) + } + activity.SetTime(startTime, endTime) + return activity +} + +type Activity[PlayerID comparable, Data any, PlayerData any] struct { + id int64 + ticker *timer.Ticker + offset *offset.Time + startTime time.Time + endTime time.Time + data Data + playerData map[PlayerID]PlayerData + newDay map[PlayerID]int64 + online map[PlayerID]struct{} + generatePlayerDataHandle func() PlayerData + + startEventHandles []StartEventHandle[PlayerID, Data, PlayerData] + finishEventHandles []FinishEventHandle[PlayerID, Data, PlayerData] + newDayEventHandles []NewDayEventHandle[PlayerID, Data, PlayerData] + playerNewDayEventHandles []PlayerNewDayEventHandle[PlayerID, Data, PlayerData] +} + +// GetId 获取活动 ID +func (slf *Activity[PlayerID, Data, PlayerData]) GetId() int64 { + return slf.id +} + +// Join 设置玩家加入活动 +func (slf *Activity[PlayerID, Data, PlayerData]) Join(playerId PlayerID) { + if !hash.Exist(slf.playerData, playerId) { + slf.playerData[playerId] = slf.generatePlayerDataHandle() + } + if slf.IsFirstDay() || !hash.Exist(slf.online, playerId) { + return + } + nd := slf.newDay[playerId] + if nd > 0 { + ndt := time.Unix(nd, 0) + now := slf.offset.Now() + if !times.IsSameDay(ndt, now) { + slf.onPlayerNewDayEvent(playerId) + slf.newDay[playerId] = now.Unix() + } + } +} + +// Leave 设置玩家离开活动 +func (slf *Activity[PlayerID, Data, PlayerData]) Leave(playerId PlayerID) { + delete(slf.online, playerId) +} + +// SetTime 设置活动开始时间和结束时间 +func (slf *Activity[PlayerID, Data, PlayerData]) SetTime(startTime, endTime time.Time) { + // 如果结束时间小于开始时间 + if endTime.Before(startTime) { + return + } + slf.startTime, slf.endTime = startTime, endTime + if !slf.IsOpen() { + slf.ticker.StopTimer(fmt.Sprintf("ACTIVITY_%d_END", slf.id)) + slf.ticker.StopTimer(fmt.Sprintf("ACTIVITY_%d_NEW_DAY", slf.id)) + } else { + slf.ticker.After(fmt.Sprintf("ACTIVITY_%d_END", slf.id), slf.endTime.Sub(slf.startTime), func() { + slf.onFinishEvent() + }) + now := slf.offset.Now() + next := times.GetToday(now).AddDate(0, 0, 1).Sub(now) + slf.nd(next) + } +} + +// IsFirstDay 检查是否是活动第一天 +func (slf *Activity[PlayerID, Data, PlayerData]) IsFirstDay() bool { + return times.IsSameDay(slf.startTime, slf.offset.Now()) +} + +// IsLastDay 检查是否是活动最后一天 +func (slf *Activity[PlayerID, Data, PlayerData]) IsLastDay() bool { + return times.IsSameDay(slf.endTime, slf.offset.Now()) +} + +// IsOpen 检查活动是否开放 +func (slf *Activity[PlayerID, Data, PlayerData]) IsOpen() bool { + now := slf.offset.Now() + return now.After(slf.startTime) && now.Before(slf.endTime) +} + +// GetData 获取活动数据 +func (slf *Activity[PlayerID, Data, PlayerData]) GetData() Data { + return slf.data +} + +// GetPlayerData 获取活动玩家数据 +func (slf *Activity[PlayerID, Data, PlayerData]) GetPlayerData(playerId PlayerID) PlayerData { + return slf.playerData[playerId] +} + +// GetLastNewDayTime 获取玩家最后触发新一天的时间 +func (slf *Activity[PlayerID, Data, PlayerData]) GetLastNewDayTime(playerId PlayerID) int64 { + return slf.newDay[playerId] +} + +// GetAllLastNewDayTime 获取所有玩家最后触发新一天的时间 +func (slf *Activity[PlayerID, Data, PlayerData]) GetAllLastNewDayTime() map[PlayerID]int64 { + return slf.newDay +} + +// GetAllPlayerData 获取所有玩家的活动数据 +func (slf *Activity[PlayerID, Data, PlayerData]) GetAllPlayerData() map[PlayerID]PlayerData { + return slf.playerData +} + +// GetStartTime 获取活动开始时间 +func (slf *Activity[PlayerID, Data, PlayerData]) GetStartTime() time.Time { + return slf.startTime +} + +// GetEndTime 获取活动结束时间 +func (slf *Activity[PlayerID, Data, PlayerData]) GetEndTime() time.Time { + return slf.endTime +} + +// GetEndOfDistanceTime 获取活动距离结束的时间 +// - 如果活动已经结束，将返回 <= 0 的数值 +func (slf *Activity[PlayerID, Data, PlayerData]) GetEndOfDistanceTime() time.Duration { + now := slf.offset.Now() + return slf.endTime.Sub(now) +} + +// GetPlayerCount 获取活动玩家数量 +func (slf *Activity[PlayerID, Data, PlayerData]) GetPlayerCount() int { + return len(slf.playerData) +} + +// DeletePlayerData 删除特定玩家的活动数据 +func (slf *Activity[PlayerID, Data, PlayerData]) DeletePlayerData(playerId PlayerID) { + delete(slf.playerData, playerId) +} + +// HasPlayer 检查活动中是否存在特定玩家 +func (slf *Activity[PlayerID, Data, PlayerData]) HasPlayer(playerId PlayerID) bool { + return hash.Exist(slf.playerData, playerId) +} + +// RegStartEvent 活动开始时将立即执行被注册的事件处理函数 +func (slf *Activity[PlayerID, Data, PlayerData]) RegStartEvent(handle StartEventHandle[PlayerID, Data, PlayerData]) { + slf.startEventHandles = append(slf.startEventHandles, handle) +} + +func (slf *Activity[PlayerID, Data, PlayerData]) onStartEvent() { + for _, handle := range slf.startEventHandles { + handle(slf) + } +} + +// RegFinishEvent 活动结束时将立即执行被注册的事件处理函数 +func (slf *Activity[PlayerID, Data, PlayerData]) RegFinishEvent(handle FinishEventHandle[PlayerID, Data, PlayerData]) { + slf.finishEventHandles = append(slf.finishEventHandles, handle) +} + +func (slf *Activity[PlayerID, Data, PlayerData]) onFinishEvent() { + for _, handle := range slf.finishEventHandles { + handle(slf) + } +} + +// RegNewDayEvent 活动到达新的一天时将立即执行被注册的事件处理函数 +func (slf *Activity[PlayerID, Data, PlayerData]) RegNewDayEvent(handle NewDayEventHandle[PlayerID, Data, PlayerData]) { + slf.newDayEventHandles = append(slf.newDayEventHandles, handle) +} + +func (slf *Activity[PlayerID, Data, PlayerData]) onNewDayEvent() { + for _, handle := range slf.newDayEventHandles { + handle(slf) + } +} + +// RegPlayerNewDayEvent 活动玩家到达新的一天时将立即执行被注册的事件处理函数 +func (slf *Activity[PlayerID, Data, PlayerData]) RegPlayerNewDayEvent(handle PlayerNewDayEventHandle[PlayerID, Data, PlayerData]) { + slf.playerNewDayEventHandles = append(slf.playerNewDayEventHandles, handle) +} + +func (slf *Activity[PlayerID, Data, PlayerData]) onPlayerNewDayEvent(playerId PlayerID) { + for _, handle := range slf.playerNewDayEventHandles { + handle(slf, playerId) + } +} + +func (slf *Activity[PlayerID, Data, PlayerData]) nd(next time.Duration) { + slf.ticker.After(fmt.Sprintf("ACTIVITY_%d_NEW_DAY", slf.id), next, func() { + slf.onNewDayEvent() + slf.nd(times.Day) + }) +} diff --git a/game/activity/activity_events.go b/game/activity/activity_events.go new file mode 100644 index 0000000..1aa5784 --- /dev/null +++ b/game/activity/activity_events.go @@ -0,0 +1,6 @@ +package activity + +type StartEventHandle[PlayerID comparable, Data any, PlayerData any] func(activity *Activity[PlayerID, Data, PlayerData]) +type FinishEventHandle[PlayerID comparable, Data any, PlayerData any] func(activity *Activity[PlayerID, Data, PlayerData]) +type NewDayEventHandle[PlayerID comparable, Data any, PlayerData any] func(activity *Activity[PlayerID, Data, PlayerData]) +type PlayerNewDayEventHandle[PlayerID comparable, Data any, PlayerData any] func(activity *Activity[PlayerID, Data, PlayerData], playerId PlayerID) diff --git a/game/activity/activity_options.go b/game/activity/activity_options.go new file mode 100644 index 0000000..12a3589 --- /dev/null +++ b/game/activity/activity_options.go @@ -0,0 +1,64 @@ +package activity + +import ( + "github.com/kercylan98/minotaur/utils/offset" + "github.com/kercylan98/minotaur/utils/timer" +) + +type Option[PlayerID comparable, Data any, PlayerData any] func(activity *Activity[PlayerID, Data, PlayerData]) + +// WithOffsetTime 通过活动时间使用偏移时间的方式创建活动 +func WithOffsetTime[PlayerID comparable, Data any, PlayerData any](offsetTime *offset.Time) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.offset = offsetTime + } +} + +// WithGlobalOffsetTime 通过活动时间使用全局偏移时间的方式创建活动 +func WithGlobalOffsetTime[PlayerID comparable, Data any, PlayerData any]() Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.offset = offset.GetGlobal() + } +} + +// WithTicker 通过使用特定的定时器创建活动 +func WithTicker[PlayerID comparable, Data any, PlayerData any](ticker *timer.Ticker) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.ticker = ticker + } +} + +// WithData 通过使用特定的活动数据创建活动 +func WithData[PlayerID comparable, Data any, PlayerData any](data Data) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.data = data + } +} + +// WithPlayerData 通过使用特定的玩家活动数据创建活动 +func WithPlayerData[PlayerID comparable, Data any, PlayerData any](playerId PlayerID, playerData PlayerData) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.playerData[playerId] = playerData + } +} + +// WithPlayerDataFromMap 通过使用 map 中的玩家活动数据创建活动 +func WithPlayerDataFromMap[PlayerID comparable, Data any, PlayerData any](playerData map[PlayerID]PlayerData) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.playerData = playerData + } +} + +// WithLastNewDayTime 通过使用特定的玩家最后触发新一天的时间数据创建活动 +func WithLastNewDayTime[PlayerID comparable, Data any, PlayerData any](playerId PlayerID, newDayTime int64) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.newDay[playerId] = newDayTime + } +} + +// WithLastNewDayTimeFromMap 通过使用 map 中的玩家最后触发新一天的时间数据创建活动 +func WithLastNewDayTimeFromMap[PlayerID comparable, Data any, PlayerData any](newDayTime map[PlayerID]int64) Option[PlayerID, Data, PlayerData] { + return func(activity *Activity[PlayerID, Data, PlayerData]) { + activity.newDay = newDayTime + } +}