mirror of
https://github.com/FlourishingWorld/hk4e.git
synced 2026-02-04 14:12:27 +08:00
171 lines
7.5 KiB
Go
171 lines
7.5 KiB
Go
package model
|
|
|
|
import (
|
|
"hk4e/pkg/logger"
|
|
"hk4e/protocol/proto"
|
|
|
|
"go.mongodb.org/mongo-driver/bson/primitive"
|
|
)
|
|
|
|
const (
|
|
DbNone = iota
|
|
DbInsert
|
|
DbDelete
|
|
DbNormal
|
|
)
|
|
|
|
const (
|
|
SceneNone = iota
|
|
SceneInitFinish
|
|
SceneEnterDone
|
|
)
|
|
|
|
type GameObject interface {
|
|
}
|
|
|
|
type Player struct {
|
|
// 离线数据 请尽量不要定义接口等复杂数据结构
|
|
ID primitive.ObjectID `bson:"_id,omitempty"`
|
|
PlayerID uint32 `bson:"PlayerID"` // 玩家uid
|
|
IsBorn bool // 是否完成开场动画
|
|
NickName string // 昵称
|
|
Signature string // 签名
|
|
HeadImage uint32 // 头像
|
|
Birthday []uint8 // 生日
|
|
NameCard uint32 // 当前名片
|
|
NameCardList []uint32 // 已解锁名片列表
|
|
FriendList map[uint32]bool // 好友uid列表
|
|
FriendApplyList map[uint32]bool // 好友申请uid列表
|
|
OfflineTime uint32 // 离线时间点
|
|
OnlineTime uint32 // 上线时间点
|
|
TotalOnlineTime uint32 // 累计在线时长
|
|
PropertiesMap map[uint16]uint32 // 玩家自身相关的一些属性
|
|
FlyCloakList []uint32 // 风之翼列表
|
|
CostumeList []uint32 // 角色衣装列表
|
|
SceneId uint32 // 场景
|
|
CmdPerm uint8 // 玩家命令权限等级
|
|
SafePos *Vector // 在陆地时的坐标
|
|
Pos *Vector // 坐标
|
|
Rot *Vector // 朝向
|
|
DbItem *DbItem // 道具
|
|
DbWeapon *DbWeapon // 武器
|
|
DbReliquary *DbReliquary // 圣遗物
|
|
DbTeam *DbTeam // 队伍
|
|
DbAvatar *DbAvatar // 角色
|
|
DbGacha *DbGacha // 卡池
|
|
DbQuest *DbQuest // 任务
|
|
DbWorld *DbWorld // 大世界
|
|
// 在线数据 请随意 记得加忽略字段的tag
|
|
LastSaveTime uint32 `bson:"-" msgpack:"-"` // 上一次存档保存时间
|
|
DbState int `bson:"-" msgpack:"-"` // 数据库存档状态
|
|
WorldId uint32 `bson:"-" msgpack:"-"` // 所在的世界id
|
|
GameObjectGuidCounter uint64 `bson:"-" msgpack:"-"` // 游戏对象guid计数器
|
|
LastKeepaliveTime uint32 `bson:"-" msgpack:"-"` // 上一次保持活跃时间
|
|
ClientTime uint32 `bson:"-" msgpack:"-"` // 客户端本地时钟
|
|
ClientRTT uint32 `bson:"-" msgpack:"-"` // 客户端网络往返时延
|
|
GameObjectGuidMap map[uint64]GameObject `bson:"-" msgpack:"-"` // 游戏对象guid映射表
|
|
Online bool `bson:"-" msgpack:"-"` // 在线状态
|
|
Pause bool `bson:"-" msgpack:"-"` // 暂停状态
|
|
SceneJump bool `bson:"-" msgpack:"-"` // 是否场景切换
|
|
SceneLoadState int `bson:"-" msgpack:"-"` // 场景加载状态
|
|
CoopApplyMap map[uint32]int64 `bson:"-" msgpack:"-"` // 敲门申请的玩家uid及时间
|
|
StaminaInfo *StaminaInfo `bson:"-" msgpack:"-"` // 耐力在线数据
|
|
VehicleInfo *VehicleInfo `bson:"-" msgpack:"-"` // 载具在线数据
|
|
ClientSeq uint32 `bson:"-" msgpack:"-"` // 客户端发包请求的序号
|
|
CombatInvokeHandler *InvokeHandler[proto.CombatInvokeEntry] `bson:"-" msgpack:"-"` // combat转发器
|
|
AbilityInvokeHandler *InvokeHandler[proto.AbilityInvokeEntry] `bson:"-" msgpack:"-"` // ability转发器
|
|
GateAppId string `bson:"-" msgpack:"-"` // 网关服务器的appid
|
|
AnticheatAppId string `bson:"-" msgpack:"-"` // 反作弊服务器的appid
|
|
GCGCurGameGuid uint32 `bson:"-" msgpack:"-"` // GCG玩家所在的游戏guid
|
|
GCGInfo *GCGInfo `bson:"-" msgpack:"-"` // 七圣召唤信息
|
|
XLuaDebug bool `bson:"-" msgpack:"-"` // 是否开启客户端XLUA调试
|
|
NetFreeze bool `bson:"-" msgpack:"-"` // 客户端网络上下行冻结状态
|
|
LastSceneBlockAoiMoveTime uint64 `bson:"-" msgpack:"-"` // 上一次移动处理场景区块aoi的时间
|
|
// 特殊数据
|
|
ChatMsgMap map[uint32][]*ChatMsg `bson:"-" msgpack:"-"` // 聊天信息 数据量偏大 只从db读写 不保存到redis
|
|
}
|
|
|
|
func (p *Player) GetNextGameObjectGuid() uint64 {
|
|
p.GameObjectGuidCounter++
|
|
return uint64(p.PlayerID)<<32 + p.GameObjectGuidCounter
|
|
}
|
|
|
|
func (p *Player) InitOnlineData() {
|
|
// 在线数据初始化
|
|
p.GameObjectGuidMap = make(map[uint64]GameObject)
|
|
p.CoopApplyMap = make(map[uint32]int64)
|
|
p.StaminaInfo = NewStaminaInfo()
|
|
p.VehicleInfo = NewVehicleInfo()
|
|
p.CombatInvokeHandler = NewInvokeHandler[proto.CombatInvokeEntry]()
|
|
p.AbilityInvokeHandler = NewInvokeHandler[proto.AbilityInvokeEntry]()
|
|
p.GCGInfo = NewGCGInfo() // 临时测试用数据
|
|
}
|
|
|
|
// 多人世界网络同步包转发器
|
|
|
|
type InvokeEntryType interface {
|
|
proto.CombatInvokeEntry | proto.AbilityInvokeEntry
|
|
}
|
|
|
|
type InvokeHandler[T InvokeEntryType] struct {
|
|
EntryListForwardAll []*T
|
|
EntryListForwardAllExceptCur []*T
|
|
EntryListForwardHost []*T
|
|
EntryListForwardServer []*T
|
|
}
|
|
|
|
func NewInvokeHandler[T InvokeEntryType]() (r *InvokeHandler[T]) {
|
|
r = new(InvokeHandler[T])
|
|
r.InitInvokeHandler()
|
|
return r
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) InitInvokeHandler() {
|
|
i.EntryListForwardAll = make([]*T, 0)
|
|
i.EntryListForwardAllExceptCur = make([]*T, 0)
|
|
i.EntryListForwardHost = make([]*T, 0)
|
|
i.EntryListForwardServer = make([]*T, 0)
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) AddEntry(forward proto.ForwardType, entry *T) {
|
|
switch forward {
|
|
case proto.ForwardType_FORWARD_TO_ALL:
|
|
i.EntryListForwardAll = append(i.EntryListForwardAll, entry)
|
|
case proto.ForwardType_FORWARD_TO_ALL_EXCEPT_CUR:
|
|
fallthrough
|
|
case proto.ForwardType_FORWARD_TO_ALL_EXIST_EXCEPT_CUR:
|
|
i.EntryListForwardAllExceptCur = append(i.EntryListForwardAllExceptCur, entry)
|
|
case proto.ForwardType_FORWARD_TO_HOST:
|
|
i.EntryListForwardHost = append(i.EntryListForwardHost, entry)
|
|
case proto.ForwardType_FORWARD_TO_PEER:
|
|
i.EntryListForwardAllExceptCur = append(i.EntryListForwardAllExceptCur, entry)
|
|
case proto.ForwardType_FORWARD_ONLY_SERVER:
|
|
i.EntryListForwardServer = append(i.EntryListForwardServer, entry)
|
|
default:
|
|
logger.Error("forward type: %v, entry: %v", forward, entry)
|
|
}
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) AllLen() int {
|
|
return len(i.EntryListForwardAll)
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) AllExceptCurLen() int {
|
|
return len(i.EntryListForwardAllExceptCur)
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) HostLen() int {
|
|
return len(i.EntryListForwardHost)
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) ServerLen() int {
|
|
return len(i.EntryListForwardServer)
|
|
}
|
|
|
|
func (i *InvokeHandler[T]) Clear() {
|
|
i.EntryListForwardAll = make([]*T, 0)
|
|
i.EntryListForwardAllExceptCur = make([]*T, 0)
|
|
i.EntryListForwardHost = make([]*T, 0)
|
|
i.EntryListForwardServer = make([]*T, 0)
|
|
}
|