VDH
485 lines
21 KiB
C#
485 lines
21 KiB
C#
using BrewMonster;
|
|
using BrewMonster.Network;
|
|
using CSNetwork;
|
|
using CSNetwork.GPDataType;
|
|
using CSNetwork.Protocols;
|
|
using CSNetwork.Protocols.RPCData;
|
|
using PerfectWorld.Scripts.Player;
|
|
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Runtime.InteropServices;
|
|
using TMPro;
|
|
using UnityEngine;
|
|
using UnityEngine.SceneManagement;
|
|
|
|
namespace PerfectWorld.Scripts.Managers
|
|
{
|
|
namespace BrewMonster.Managers
|
|
{
|
|
[Serializable]
|
|
public class EC_ManPlayer : IMsgHandler
|
|
{
|
|
Dictionary<int, int> m_UkPlayerTab = new Dictionary<int, int>();
|
|
Dictionary<int, EC_ElsePlayer> m_PlayerTab = new Dictionary<int, EC_ElsePlayer>();
|
|
private readonly object m_csPlayerTab = new object();
|
|
CECHostPlayer m_pHostPlayer;
|
|
public int HandlerId => (int)MANAGER_INDEX.MAN_PLAYER;
|
|
public bool ProcessMessage(ECMSG Msg)
|
|
{
|
|
if (Msg.iSubID == 0)
|
|
{
|
|
if (GameController.Instance == null) return true;
|
|
GameController.Instance.GetHostPlayer().ProcessMessage(Msg);
|
|
}
|
|
else if (Msg.iSubID < 0)
|
|
{
|
|
switch ((int)Msg.dwMsg)
|
|
{
|
|
case int value when value == EC_MsgDef.MSG_PM_PLAYERINFO:
|
|
{
|
|
OnMsgPlayerInfo(Msg);
|
|
break;
|
|
}
|
|
case int value when value == EC_MsgDef.MSG_PM_PLAYERMOVE:
|
|
{
|
|
OnMsgPlayerMove(Msg);
|
|
break;
|
|
}
|
|
case int value when value == EC_MsgDef.MSG_PM_PLAYERSTOPMOVE:
|
|
{
|
|
OnMsgPlayerStopMove(Msg);
|
|
break;
|
|
}
|
|
case int value when value == EC_MsgDef.MSG_PM_FACTION_PVP_MASK_MODIFY:
|
|
Debug.Log("EC_MsgDef.MSG_PM_FACTION_PVP_MASK_MODIFY");
|
|
TransmitMessage(Msg);
|
|
break;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public void OnMsgPlayerInfo(ECMSG Msg)
|
|
{
|
|
int iHostID = Convert.ToInt32(Msg.dwParam3);
|
|
int lenghtByte = Marshal.SizeOf<int>();
|
|
byte[] byteArray = new byte[lenghtByte];
|
|
byte[] data = (byte[])Msg.dwParam1;
|
|
for (int i = 0; i < lenghtByte; i++)
|
|
{
|
|
byteArray[i] = data[i];
|
|
}
|
|
int cid = BitConverter.ToInt32(byteArray);
|
|
int commandID = Convert.ToInt32(Msg.dwParam2);
|
|
switch (commandID)
|
|
{
|
|
case CommandID.PLAYER_INFO_1:
|
|
case CommandID.PLAYER_ENTER_WORLD:
|
|
case CommandID.PLAYER_ENTER_SLICE:
|
|
{
|
|
if (cid != iHostID)
|
|
{
|
|
info_player_1 info_Player_1 = GPDataTypeHelper.FromBytes<info_player_1>((byte[])Msg.dwParam1);
|
|
RoleInfo roleInfo = (RoleInfo)Msg.dwParam4;
|
|
ElsePlayerEnter(info_Player_1, commandID, roleInfo);
|
|
GameController.Instance.Log("ElsePlayer has join");
|
|
}
|
|
break;
|
|
}
|
|
case CommandID.SELF_INFO_1:
|
|
cmd_self_info_1 info = GPDataTypeHelper.FromBytes<cmd_self_info_1>((byte[])Msg.dwParam1);
|
|
HostPlayerInfo1(info);
|
|
break;
|
|
case CommandID.PLAYER_INFO_2: break;
|
|
case CommandID.PLAYER_INFO_3: break;
|
|
case CommandID.PLAYER_INFO_4: break;
|
|
|
|
case CommandID.PLAYER_INFO_1_LIST:
|
|
{
|
|
byte[] bytes = (byte[])Msg.dwParam1;
|
|
cmd_player_info_1_list pCmd = GPDataTypeHelper.FromBytes<cmd_player_info_1_list>(bytes);
|
|
if (pCmd.count == 0)
|
|
{
|
|
break;
|
|
}
|
|
int lenght = Marshal.SizeOf<info_player_1>();
|
|
int preSize = 0;
|
|
byte[] pDataBuf = null;
|
|
preSize += Marshal.SizeOf<ushort>();
|
|
RoleInfo roleInfo = (RoleInfo)Msg.dwParam4;
|
|
for (int i = 0; i < pCmd.count; i++)
|
|
{
|
|
pDataBuf = new byte[lenght];
|
|
for (int j = 0; j < pDataBuf.Length; j++)
|
|
{
|
|
pDataBuf[j] = bytes[preSize + j];
|
|
}
|
|
info_player_1 Info = GPDataTypeHelper.FromBytes<info_player_1>(pDataBuf);
|
|
if (Info.cid != iHostID)
|
|
{
|
|
EC_ElsePlayer pPlayer = ElsePlayerEnter(Info, commandID, roleInfo);
|
|
}
|
|
|
|
// Calculate player info data size and skip it
|
|
int iSize = Marshal.SizeOf<info_player_1>();
|
|
if ((Info.state & PlayerNPCState.GP_STATE_ADV_MODE) != 0)
|
|
iSize += Marshal.SizeOf<int>() * 2;
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_SHAPE) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_EMOTE) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_EXTEND_PROPERTY) != 0)
|
|
iSize += Marshal.SizeOf<int>() * NumberDWORDsPlayerNPC.OBJECT_EXT_STATE_COUNT;
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_FACTION) != 0)
|
|
iSize += (Marshal.SizeOf<int>() + Marshal.SizeOf<byte>());
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_BOOTH) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
|
|
//// Parse effect data
|
|
if ((Info.state & PlayerNPCState.GP_STATE_EFFECT) != 0)
|
|
{
|
|
iSize += Marshal.SizeOf<byte>();
|
|
byte byNum = bytes[preSize + iSize];
|
|
|
|
if (byNum > 0)
|
|
iSize += byNum * Marshal.SizeOf<short>();
|
|
}
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_PARIAH) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_IN_MOUNT) != 0)
|
|
iSize += Marshal.SizeOf<ushort>() + Marshal.SizeOf<int>();
|
|
|
|
// Parse bind data
|
|
if ((Info.state & PlayerNPCState.GP_STATE_IN_BIND) != 0)
|
|
iSize += Marshal.SizeOf<char>() + Marshal.SizeOf<int>();
|
|
|
|
// Parse spouse data
|
|
if ((Info.state & PlayerNPCState.GP_STATE_SPOUSE) != 0)
|
|
iSize += Marshal.SizeOf<int>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_EQUIPDISABLED) != 0)
|
|
iSize += Marshal.SizeOf<long>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_PLAYERFORCE) != 0)
|
|
iSize += Marshal.SizeOf<int>();
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_MULTIOBJ_EFFECT) != 0)
|
|
{
|
|
int effectNum = Marshal.ReadInt32(bytes, iSize);//*(int*)(pDataBuf + iSize);
|
|
iSize += Marshal.SizeOf<int>();
|
|
|
|
if (effectNum > 0)
|
|
iSize += effectNum * (Marshal.SizeOf<int>() + Marshal.SizeOf<char>());
|
|
}
|
|
|
|
if ((Info.state & PlayerNPCState.GP_STATE_COUNTRY) != 0)
|
|
iSize += Marshal.SizeOf<int>();
|
|
if ((Info.state2 & PlayerNPCState2.GP_STATE2_TITLE) != 0)
|
|
iSize += Marshal.SizeOf<ushort>();
|
|
if ((Info.state2 & PlayerNPCState2.GP_STATE2_REINCARNATION) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
if ((Info.state2 & PlayerNPCState2.GP_STATE2_REALM) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
if ((Info.state2 & PlayerNPCState2.GP_STATE2_FACTION_PVP_MASK) != 0)
|
|
iSize += Marshal.SizeOf<byte>();
|
|
|
|
// Goblin refine data
|
|
if ((Info.state & PlayerNPCState.GP_STATE_GOBLINREFINE) != 0)
|
|
iSize += Marshal.SizeOf<int>();
|
|
|
|
//pDataBuf += iSize;
|
|
|
|
preSize += iSize;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
public void OnMsgPlayerMove(ECMSG Msg)
|
|
{
|
|
int iHostID = Convert.ToInt32(Msg.dwParam3);
|
|
cmd_object_move pCmd = GPDataTypeHelper.FromBytes<cmd_object_move>((byte[])Msg.dwParam1);
|
|
if (pCmd.use_time == 0)
|
|
return;
|
|
if (pCmd.id != iHostID)
|
|
{
|
|
EC_ElsePlayer pPlayer = SeekOutElsePlayer(pCmd.id);
|
|
if (pPlayer)
|
|
{
|
|
pPlayer.MoveTo(pCmd);
|
|
}
|
|
}
|
|
}
|
|
|
|
public bool HostPlayerInfo1(cmd_self_info_1 info)
|
|
{
|
|
//bool isDoneWorldRender = false;
|
|
//bool isDoneNPCRender = false;
|
|
//Action actLoadChar = () =>
|
|
//{
|
|
// if (!isDoneNPCRender || !isDoneWorldRender)
|
|
// {
|
|
// return;
|
|
// }
|
|
// GameController.Instance.InitCharacter(info);
|
|
//};
|
|
//string nameScene = "NPCRender";
|
|
//UnityGameSession.Instance.LoadScene(nameScene, LoadSceneMode.Single, (value) =>
|
|
//{
|
|
// isDoneNPCRender = value;
|
|
// actLoadChar?.Invoke();
|
|
//});
|
|
//nameScene = "WorldRender";
|
|
//UnityGameSession.Instance.LoadScene(nameScene, LoadSceneMode.Additive, (value) =>
|
|
//{
|
|
// isDoneWorldRender = value;
|
|
// actLoadChar?.Invoke();
|
|
//});
|
|
//UnityGameSession.Instance.LoadScene("HoangTest", LoadSceneMode.Single, (value) =>
|
|
//{
|
|
// isDoneWorldRender = value;
|
|
// actLoadChar?.Invoke();
|
|
//});
|
|
GameController.Instance.InitCharacter(info);
|
|
return true;
|
|
}
|
|
|
|
public EC_ElsePlayer ElsePlayerEnter(info_player_1 info, int iCmd, RoleInfo roleInfo)
|
|
{
|
|
// If this player's id is in unknown table, remove it because this player
|
|
// won't be unknown anymore
|
|
if (m_UkPlayerTab.TryGetValue(info.cid, out int value))
|
|
{
|
|
if (value != 0) // Pair.second != 0
|
|
{
|
|
m_UkPlayerTab.Remove(info.cid);
|
|
}
|
|
}
|
|
|
|
int iAppearFlag = (iCmd == (int)CommandID.PLAYER_ENTER_WORLD) ?
|
|
(int)PlayerAppearFlag.APPEAR_ENTERWORLD : (int)PlayerAppearFlag.APPEAR_RUNINTOVIEW;
|
|
|
|
// Has player been in active player table ?
|
|
EC_ElsePlayer pPlayer = GetElsePlayer(info.cid);
|
|
if (pPlayer)
|
|
{
|
|
// This player has existed in player table, call special initial function
|
|
// TODO: fix after pPlayer init
|
|
pPlayer.Init(roleInfo, info);
|
|
return pPlayer;
|
|
}
|
|
|
|
// Create a new player
|
|
if (!(pPlayer = CreateElsePlayer(roleInfo, info, iAppearFlag)))
|
|
{
|
|
return null;
|
|
}
|
|
lock (m_csPlayerTab)
|
|
{
|
|
if (m_PlayerTab.ContainsKey(info.cid))
|
|
{
|
|
m_PlayerTab[info.cid] = pPlayer;
|
|
}
|
|
else
|
|
{
|
|
m_PlayerTab.Add(info.cid, pPlayer);
|
|
}
|
|
}
|
|
return pPlayer;
|
|
}
|
|
|
|
private EC_ElsePlayer CreateElsePlayer(RoleInfo roleInfo, info_player_1 info, int iAppearFlag)
|
|
{
|
|
GameObject ob = GameController.Instance.InitCharacter(info);
|
|
EC_ElsePlayer elsePlayer = ob.AddComponent<EC_ElsePlayer>();
|
|
elsePlayer.GetComponent<CECHostPlayer>().enabled = false;
|
|
//init
|
|
elsePlayer.Init(roleInfo, info);
|
|
return elsePlayer;
|
|
}
|
|
|
|
public EC_ElsePlayer GetElsePlayer(int cid, long dwBornStamp = 0)
|
|
{
|
|
lock (m_csPlayerTab)
|
|
{
|
|
if (!m_PlayerTab.TryGetValue(cid, out var player))
|
|
return null;
|
|
if (dwBornStamp != 0)
|
|
{
|
|
//TO DO: fix after GetBornStamp() is create in code
|
|
//if (player.GetBornStamp() != dwBornStamp)
|
|
return null;
|
|
}
|
|
|
|
return player;
|
|
}
|
|
}
|
|
|
|
private EC_ElsePlayer SeekOutElsePlayer(int cid)
|
|
{
|
|
if (!m_PlayerTab.TryGetValue(cid, out var player))
|
|
{
|
|
// Couldn't find this else player, put it into unknown player table
|
|
m_UkPlayerTab[cid] = cid;
|
|
return null;
|
|
}
|
|
|
|
return player;
|
|
}
|
|
|
|
|
|
public bool OnMsgPlayerStopMove(ECMSG Msg)
|
|
{
|
|
cmd_object_stop_move pCmd = GPDataTypeHelper.FromBytes<cmd_object_stop_move>((byte[])Msg.dwParam1);
|
|
EC_ElsePlayer pPlayer = SeekOutElsePlayer(pCmd.id);
|
|
if (pPlayer)
|
|
pPlayer.StopMoveTo(pCmd);
|
|
return true;
|
|
}
|
|
|
|
//private cmd_object_move ConvertToStruct(byte[] bytes)
|
|
//{
|
|
// if (bytes.Length < Marshal.SizeOf<cmd_object_move>())
|
|
// {
|
|
// return default;
|
|
// }
|
|
|
|
// cmd_object_move result = new cmd_object_move();
|
|
// int preLenghtData = 0;
|
|
// int lenghtDataType = Marshal.SizeOf<int>();
|
|
// byte[] arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.id = BitConverter.ToInt32(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// lenghtDataType = Marshal.SizeOf<float>();
|
|
// arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.dest_X = BitConverter.ToSingle(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// lenghtDataType = Marshal.SizeOf<float>();
|
|
// arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.dest_Y = BitConverter.ToSingle(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// lenghtDataType = Marshal.SizeOf<float>();
|
|
// arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.dest_Z = BitConverter.ToSingle(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// lenghtDataType = Marshal.SizeOf<ushort>();
|
|
// arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.use_time = BitConverter.ToUInt16(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// lenghtDataType = Marshal.SizeOf<short>();
|
|
// arrByteData = GetBytes(bytes, lenghtDataType, preLenghtData);
|
|
// result.sSpeed = BitConverter.ToInt16(arrByteData);
|
|
|
|
// preLenghtData += lenghtDataType;
|
|
// result.move_mode = bytes[preLenghtData + 1];
|
|
// return result;
|
|
//}
|
|
|
|
private byte[] GetBytes(byte[] bytes, int length, int index)
|
|
{
|
|
byte[] arrByteData = new byte[length];
|
|
for (int i = 0; i < length; i++)
|
|
{
|
|
arrByteData[i] = bytes[i + index];
|
|
}
|
|
return arrByteData;
|
|
}
|
|
|
|
public void Initialize()
|
|
{
|
|
|
|
}
|
|
public bool TransmitMessage(ECMSG msg)
|
|
{
|
|
int cid = 0;
|
|
var host = GameController.Instance.GetHostPlayer();
|
|
|
|
switch (msg.dwMsg)
|
|
{
|
|
/*case long value when value == EC_MsgDef.MSG_PM_PLAYEREQUIPDATA:
|
|
if (msg.dwParam2 == S2C.EQUIP_DATA)
|
|
cid = ((cmd_equip_data)msg.dwParam1).idPlayer;
|
|
else // EQUIP_DATA_CHANGED
|
|
cid = ((cmd_equip_data_changed)msg.dwParam1).idPlayer;
|
|
break;*/
|
|
|
|
case long value when value == EC_MsgDef.MSG_PM_PLAYERBASEINFO:
|
|
cid = (int)((playerbaseinfo_re)msg.dwParam1).Player.id;
|
|
// Xoá khỏi cache
|
|
//g_pGame.GetGameSession().GetC2SCmdCache().RemovePlayerBaseInfo(cid);
|
|
break;
|
|
|
|
/*case long value when value == EC_MsgDef.MSG_PM_PLAYERCUSTOM:
|
|
cid = ((GetCustomData_Re)msg.dwParam1).cus_roleid;
|
|
break;
|
|
|
|
case long value when value == EC_MsgDef.MSG_PM_PLAYERFLY:
|
|
if (msg.dwParam2 == S2C.OBJECT_TAKEOFF)
|
|
cid = ((cmd_object_takeoff)msg.dwParam1).object_id;
|
|
else
|
|
cid = ((cmd_object_landing)msg.dwParam1).object_id;
|
|
break;*/
|
|
|
|
// ⚠️ Các case khác cũng tương tự, chỉ việc lấy ra đúng trường id / caster / user ...
|
|
// Do quá dài nên bạn có thể copy dần từng case từ C++ sang.
|
|
|
|
default:
|
|
System.Diagnostics.Debug.Assert(false, "Unknown message");
|
|
return false;
|
|
}
|
|
|
|
/* if (cid == 0)
|
|
{
|
|
System.Diagnostics.Debug.Assert(false, "cid = 0");
|
|
return false;
|
|
}
|
|
|
|
if (host != null && cid == host.GetCharacterID())
|
|
{
|
|
host.ProcessMessage(msg);
|
|
}
|
|
else
|
|
{
|
|
var elsePlayer = SeekOutElsePlayer(cid);
|
|
if (elsePlayer != null)
|
|
elsePlayer.ProcessMessage(msg);
|
|
}*/
|
|
|
|
return true;
|
|
}
|
|
|
|
// Get a player (may be host or else player) by id
|
|
public CECPlayer GetPlayer(int cid, uint dwBornStamp = 0)
|
|
{
|
|
CECHostPlayer pHost = GetHostPlayer();
|
|
if (pHost && pHost.GetCharacterID() == cid)
|
|
return pHost;
|
|
else
|
|
return GetElsePlayer(cid, dwBornStamp);
|
|
}
|
|
|
|
public CECHostPlayer GetHostPlayer()
|
|
{
|
|
return GameController.Instance.GetHostPlayer();
|
|
}
|
|
}
|
|
}
|
|
} |