forked from PGR/ascnet
1
0
Fork 0
ascnet/AscNet.GameServer/Handlers/CharacterModule.cs

490 lines
20 KiB
C#

using AscNet.Common;
using AscNet.Common.Database;
using AscNet.Common.MsgPack;
using AscNet.Common.Util;
using AscNet.Table.V2.share.character;
using AscNet.Table.V2.share.character.enhanceskill;
using AscNet.Table.V2.share.character.grade;
using AscNet.Table.V2.share.character.quality;
using AscNet.Table.V2.share.character.skill;
using AscNet.Table.V2.share.item;
using MessagePack;
using MongoDB.Driver.Linq;
namespace AscNet.GameServer.Handlers
{
#region MsgPackScheme
#pragma warning disable CS8618 // Non-nullable field must contain a non-null value when exiting constructor. Consider declaring as nullable.
[MessagePackObject(true)]
public class CharacterUpgradeEnhanceSkillRequest
{
public int Count;
public int SkillGroupId;
}
[MessagePackObject(true)]
public class CharacterUpgradeEnhanceSkillResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterUnlockEnhanceSkillRequest
{
public int SkillGroupId;
}
[MessagePackObject(true)]
public class CharacterUnlockEnhanceSkillResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterLevelUpRequest
{
public uint TemplateId;
public Dictionary<int, int> UseItems;
}
[MessagePackObject(true)]
public class CharacterLevelUpResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterUnlockSkillGroupRequest
{
public int SkillGroupId;
}
[MessagePackObject(true)]
public class CharacterUnlockSkillGroupResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterPromoteQualityRequest
{
public int TemplateId;
}
[MessagePackObject(true)]
public class CharacterPromoteQualityResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterActivateStarRequest
{
public int TemplateId;
}
[MessagePackObject(true)]
public class CharacterActivateStarResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterPromoteGradeRequest
{
public int TemplateId;
}
[MessagePackObject(true)]
public class CharacterPromoteGradeResponse
{
public int Code;
}
[MessagePackObject(true)]
public class CharacterExchangeRequest
{
public int TemplateId;
}
[MessagePackObject(true)]
public class CharacterExchangeResponse
{
public int Code;
}
[MessagePackObject(true)]
public class FashionSyncNotify
{
public List<FashionList> FashionList = new();
}
#pragma warning restore CS8618 // Non-nullable field must contain a non-null value when exiting constructor. Consider declaring as nullable.
#endregion
internal class CharacterModule
{
[RequestPacketHandler("CharacterLevelUpRequest")]
public static void CharacterLevelUpRequestHandler(Session session, Packet.Request packet)
{
CharacterLevelUpRequest request = packet.Deserialize<CharacterLevelUpRequest>();
CharacterTable? characterData = TableReaderV2.Parse<CharacterTable>().FirstOrDefault(x => x.Id == request.TemplateId);
if (characterData is null || !session.character.Characters.Any(x => x.Id == characterData.Id))
{
// CharacterManagerGetCharacterTemplateNotFound
session.SendResponse(new CharacterLevelUpResponse() { Code = 20009001 }, packet.Id);
return;
}
NotifyItemDataList notifyItemData = new();
int totalExp = 0;
foreach (var item in request.UseItems)
{
ItemTable? itemTable = TableReaderV2.Parse<ItemTable>().FirstOrDefault(x => x.Id == item.Key);
if (itemTable is not null)
{
totalExp += itemTable.GetCharacterExp(characterData.Type) * item.Value;
notifyItemData.ItemDataList.Add(session.inventory.Do(item.Key, item.Value * -1));
}
}
session.SendPush(notifyItemData);
var characterUp = session.character.AddCharacterExp(characterData.Id, totalExp, (int)session.player.PlayerData.Level);
if (characterUp is not null)
{
NotifyCharacterDataList notifyCharacterData = new();
notifyCharacterData.CharacterDataList.Add(characterUp);
session.SendPush(notifyCharacterData);
}
session.SendResponse(new CharacterLevelUpResponse(), packet.Id);
}
[RequestPacketHandler("CharacterPromoteGradeRequest")]
public static void CharacterPromoteGradeRequestHandler(Session session, Packet.Request packet)
{
CharacterPromoteGradeRequest req = packet.Deserialize<CharacterPromoteGradeRequest>();
var character = session.character.Characters.Find(c => c.Id == req.TemplateId);
var currentGrade = TableReaderV2.Parse<CharacterGradeTable>().Find(x => x.CharacterId == req.TemplateId && x.Grade == character?.Grade);
if (character is not null && currentGrade is not null)
{
var nextGrade = TableReaderV2.Parse<CharacterGradeTable>().Where(x => x.CharacterId == req.TemplateId && x.Grade > character.Grade).OrderBy(x => x.Grade).FirstOrDefault()?.Grade ?? character.Grade;
if (character.Grade == nextGrade)
{
// CharacterManagerMaxGrade
session.SendResponse(new CharacterPromoteGradeResponse() { Code = 20009019 }, packet.Id);
return;
}
if (currentGrade.UseItemKey is not null)
{
NotifyItemDataList notifyItemData = new();
notifyItemData.ItemDataList.Add(session.inventory.Do(currentGrade.UseItemKey ?? 1, (currentGrade.UseItemCount ?? 0) * -1));
session.SendPush(notifyItemData);
}
character.Grade = nextGrade;
session.SendPush(new NotifyCharacterDataList()
{
CharacterDataList = { character }
});
}
session.SendResponse(new CharacterPromoteGradeResponse(), packet.Id);
}
[RequestPacketHandler("CharacterActivateStarRequest")]
public static void CharacterActivateStarRequestHandler(Session session, Packet.Request packet)
{
CharacterActivateStarRequest req = packet.Deserialize<CharacterActivateStarRequest>();
var character = session.character.Characters.Find(c => c.Id == req.TemplateId);
var characterData = TableReaderV2.Parse<CharacterTable>().Find(x => x.Id == req.TemplateId);
var characterQualityFragment = TableReaderV2.Parse<CharacterQualityFragmentTable>().Find(x => x.Type == characterData?.Type && x.Quality == character?.Quality);
try
{
if (character is null)
{
// CharacterManagerGetCharacterByIdNotFound
throw new ServerCodeException("Character data not found!", 20009011);
}
if (characterData is null)
{
// CharacterManagerGetCharacterDataNotFound
throw new ServerCodeException("Character table data not found!", 20009021);
}
if (characterQualityFragment is null)
{
// CharacterManagerGetQualityFragmentTemplateNotFound
throw new ServerCodeException("Character quality fragment table data not found!", 20009004);
}
if (character.Star < characterQualityFragment.StarUseCount.Count)
{
if (characterQualityFragment.StarUseCount[character.Star] > 0)
{
NotifyItemDataList notifyItemData = new();
notifyItemData.ItemDataList.Add(session.inventory.Do(characterData.ItemId, characterQualityFragment.StarUseCount[character.Star] * -1));
session.SendPush(notifyItemData);
}
character.Star++;
}
else
{
// CharacterManagerActivateStarMaxStar
throw new ServerCodeException("Character star already maxed!", 20009015);
}
}
catch (ServerCodeException ex)
{
session.SendResponse(new CharacterActivateStarResponse() { Code = ex.Code }, packet.Id);
return;
}
session.SendPush(new NotifyCharacterDataList()
{
CharacterDataList = { character }
});
session.SendResponse(new CharacterActivateStarResponse(), packet.Id);
}
[RequestPacketHandler("CharacterPromoteQualityRequest")]
public static void CharacterPromoteQualityRequestHandler(Session session, Packet.Request packet)
{
CharacterPromoteQualityRequest req = packet.Deserialize<CharacterPromoteQualityRequest>();
var character = session.character.Characters.Find(c => c.Id == req.TemplateId);
var characterData = TableReaderV2.Parse<CharacterTable>().Find(x => x.Id == req.TemplateId);
var characterQualityFragment = TableReaderV2.Parse<CharacterQualityFragmentTable>().Find(x => x.Type == characterData?.Type && x.Quality == character?.Quality);
try
{
if (character is null)
{
// CharacterManagerGetCharacterByIdNotFound
throw new ServerCodeException("Character data not found!", 20009011);
}
if (characterData is null)
{
// CharacterManagerGetCharacterDataNotFound
throw new ServerCodeException("Character table data not found!", 20009021);
}
if (characterQualityFragment is null)
{
// CharacterManagerGetQualityFragmentTemplateNotFound
throw new ServerCodeException("Character quality fragment table data not found!", 20009004);
}
if (TableReaderV2.Parse<CharacterQualityFragmentTable>().Any(x => x.Type == characterData?.Type && x.Quality == character?.Quality + 1))
{
if (characterQualityFragment.PromoteUseCoin is not null && characterQualityFragment.PromoteUseCoin > 0)
{
NotifyItemDataList notifyItemData = new();
notifyItemData.ItemDataList.Add(session.inventory.Do(characterQualityFragment.PromoteItemId ?? 1, (characterQualityFragment.PromoteUseCoin ?? 0) * -1));
session.SendPush(notifyItemData);
}
character.Star = 0;
character.Quality++;
}
else
{
// CharacterManagerMaxQuality
throw new ServerCodeException("Character quality already maxed!", 20009016);
}
}
catch (ServerCodeException ex)
{
session.SendResponse(new CharacterPromoteQualityResponse() { Code = ex.Code }, packet.Id);
return;
}
session.SendPush(new NotifyCharacterDataList()
{
CharacterDataList = { character }
});
session.SendResponse(new CharacterPromoteQualityResponse(), packet.Id);
}
[RequestPacketHandler("CharacterUnlockSkillGroupRequest")]
public static void CharacterUnlockSkillGroupRequestHandler(Session session, Packet.Request packet)
{
CharacterUnlockSkillGroupRequest request = packet.Deserialize<CharacterUnlockSkillGroupRequest>();
NotifyCharacterDataList notifyCharacterData = new();
var affectedChars = TableReaderV2.Parse<CharacterSkillTable>().Where(x => x.SkillGroupId.Contains(request.SkillGroupId)).Select(x => x.CharacterId);
foreach (var character in session.character.Characters.Where(x => affectedChars.Any(y => y == x.Id)))
{
character.SkillList.AddRange(TableReaderV2.Parse<CharacterSkillGroupTable>().Where(x => x.Id == request.SkillGroupId).SelectMany(x => x.SkillId).Select(x => new CharacterSkill() { Id = (uint)x, Level = 1 }));
notifyCharacterData.CharacterDataList.Add(character);
}
session.SendPush(notifyCharacterData);
session.SendResponse(new CharacterUpgradeSkillGroupResponse(), packet.Id);
}
[RequestPacketHandler("CharacterUpgradeSkillGroupRequest")]
public static void CharacterUpgradeSkillGroupRequestHandler(Session session, Packet.Request packet)
{
CharacterUpgradeSkillGroupRequest request = packet.Deserialize<CharacterUpgradeSkillGroupRequest>();
var upgradeResult = session.character.UpgradeCharacterSkillGroup(request.SkillGroupId, request.Count);
NotifyCharacterDataList notifyCharacterData = new();
notifyCharacterData.CharacterDataList.AddRange(session.character.Characters.Where(x => upgradeResult.AffectedCharacters.Contains(x.Id)));
NotifyItemDataList notifyItemData = new();
notifyItemData.ItemDataList.AddRange(new Item[] {
session.inventory.Do(Inventory.Coin, upgradeResult.CoinCost * -1),
session.inventory.Do(Inventory.SkillPoint, upgradeResult.SkillPointCost * -1)
});
session.SendPush(notifyCharacterData);
session.SendPush(notifyItemData);
session.SendResponse(new CharacterUpgradeSkillGroupResponse(), packet.Id);
}
[RequestPacketHandler("CharacterUnlockEnhanceSkillRequest")]
public static void CharacterUnlockEnhanceSkillRequestHandler(Session session, Packet.Request packet)
{
CharacterUnlockEnhanceSkillRequest request = packet.Deserialize<CharacterUnlockEnhanceSkillRequest>();
var enhanceSkillIds = TableReaderV2.Parse<EnhanceSkillGroupTable>().Where(x => x.Id == request.SkillGroupId).SelectMany(x => x.SkillId);
NotifyItemDataList notifyItemData = new();
NotifyCharacterDataList notifyCharacterData = new();
foreach (var enhanceSkillId in enhanceSkillIds)
{
var affectedChars = TableReaderV2.Parse<EnhanceSkillTable>().Where(x => x.SkillGroupId.Contains(request.SkillGroupId)).Select(x => x.CharacterId).ToList();
foreach (var character in session.character.Characters.Where(x => affectedChars.Contains((int)x.Id)))
{
if (character.EnhanceSkillList.Any(x => x.Id == enhanceSkillId))
{
// CharacterSkillUnlocked
session.SendResponse(new CharacterUnlockEnhanceSkillResponse() { Code = 20009047 }, packet.Id);
return;
}
character.EnhanceSkillList.Add(new()
{
Id = (uint)enhanceSkillId,
Level = 1
});
notifyCharacterData.CharacterDataList.Add(character);
}
EnhanceSkillUpgradeTable? upgradeTable = TableReaderV2.Parse<EnhanceSkillUpgradeTable>().Find(x => x.SkillId == enhanceSkillId && x.Level == 0);
if (upgradeTable is null)
continue;
for (int i = 0; i < Math.Min(upgradeTable.CostItem.Count, upgradeTable.CostItemCount.Count); i++)
{
notifyItemData.ItemDataList.Add(session.inventory.Do(upgradeTable.CostItem[i], upgradeTable.CostItemCount[i] * -1));
}
}
session.SendPush(notifyItemData);
session.SendPush(notifyCharacterData);
session.SendResponse(new CharacterUnlockEnhanceSkillResponse(), packet.Id);
}
[RequestPacketHandler("CharacterUpgradeEnhanceSkillRequest")]
public static void CharacterUpgradeEnhanceSkillRequestHandler(Session session, Packet.Request packet)
{
CharacterUpgradeEnhanceSkillRequest request = packet.Deserialize<CharacterUpgradeEnhanceSkillRequest>();
var enhanceSkillIds = TableReaderV2.Parse<EnhanceSkillGroupTable>().Where(x => x.Id == request.SkillGroupId).SelectMany(x => x.SkillId);
NotifyItemDataList notifyItemData = new();
NotifyCharacterDataList notifyCharacterData = new();
foreach (var enhanceSkillId in enhanceSkillIds)
{
foreach (var character in session.character.Characters.Where(x => x.EnhanceSkillList.Any(x => x.Id == enhanceSkillId)))
{
for (int j = 0; j < request.Count; j++)
{
var skill = character.EnhanceSkillList.Find(x => x.Id == enhanceSkillId);
if (skill is not null)
{
EnhanceSkillUpgradeTable? upgradeTable = TableReaderV2.Parse<EnhanceSkillUpgradeTable>().Find(x => x.SkillId == enhanceSkillId && x.Level == skill.Level);
skill.Level++;
if (upgradeTable is null)
continue;
for (int i = 0; i < Math.Min(upgradeTable.CostItem.Count, upgradeTable.CostItemCount.Count); i++)
{
notifyItemData.ItemDataList.Add(session.inventory.Do(upgradeTable.CostItem[i], upgradeTable.CostItemCount[i] * -1));
}
}
}
notifyCharacterData.CharacterDataList.Add(character);
}
}
session.SendPush(notifyItemData);
session.SendPush(notifyCharacterData);
session.SendResponse(new CharacterUpgradeEnhanceSkillResponse(), packet.Id);
}
[RequestPacketHandler("CharacterExchangeRequest")]
public static void CharacterExchangeRequestHandler(Session session, Packet.Request packet)
{
CharacterExchangeRequest request = packet.Deserialize<CharacterExchangeRequest>();
CharacterTable? characterData = TableReaderV2.Parse<CharacterTable>().FirstOrDefault(x => x.Id == request.TemplateId);
if (characterData is null)
{
CharacterExchangeResponse rsp = new()
{
// CharacterManagerGetCharacterTemplateNotFound
Code = 20009001
};
session.SendResponse(rsp, packet.Id);
return;
}
if (!session.inventory.Items.Any(x => x.Id == characterData.ItemId && x.Count >= 50))
{
CharacterExchangeResponse rsp = new()
{
// ItemCountNotEnough
Code = 20012004
};
session.SendResponse(rsp, packet.Id);
return;
}
NotifyItemDataList notifyItemData = new();
// TODO: idk if it's always 50, please investigate later...
notifyItemData.ItemDataList.Add(session.inventory.Do(characterData.ItemId, 50 * -1));
session.SendPush(notifyItemData);
try
{
NotifyEquipDataList notifyEquipData = new();
FashionSyncNotify fashionSync = new();
NotifyCharacterDataList notifyCharacterData = new();
var addRet = session.character.AddCharacter((uint)request.TemplateId);
notifyEquipData.EquipDataList.Add(addRet.Equip);
fashionSync.FashionList.Add(addRet.Fashion);
notifyCharacterData.CharacterDataList.Add(addRet.Character);
session.SendPush(notifyEquipData);
session.SendPush(fashionSync);
session.SendPush(notifyCharacterData);
}
catch (ServerCodeException ex)
{
CharacterExchangeResponse rsp = new() { Code = ex.Code };
session.SendResponse(rsp, packet.Id);
return;
}
session.SendResponse(new CharacterExchangeResponse(), packet.Id);
}
}
}