Compare commits

...

8 Commits

Author SHA1 Message Date
Kei-Luna
ecf2446598 Weapon_OneKeyToMax 2026-05-31 05:17:08 +09:00
Kei-Luna
75d840974b Item_Recycle 2026-05-31 05:02:04 +09:00
Kei-Luna
d6f57053dd Update README_jp.md 2026-05-30 17:52:15 +09:00
Kei-Luna
518c04fdb4 Fixed an issue where clicking on a feature not yet implemented on the server side would cause an infinite loading loop. 2026-05-27 07:12:31 +09:00
Kei-Luna
a9b57fc1b7 MoneySync 2026-05-27 06:09:29 +09:00
Kei-Luna
63dc993614 IBLogic 2026-05-26 09:02:03 +09:00
Kei-Luna
26e4d6fd0f BattlePass 2026-05-26 08:49:39 +09:00
Kei-Luna
5de3551ef3 DLCLogic_CheckOpenAct 2026-05-26 07:47:49 +09:00
20 changed files with 1527 additions and 33 deletions

View File

@@ -0,0 +1,23 @@
using Newtonsoft.Json;
namespace MikuSB.Data.Excel;
[ResourceEntity("battlepass/timelist.json")]
public class BattlePassTimeExcel : ExcelResource
{
[JsonProperty("ID")] public uint Id { get; set; }
[JsonProperty("StartTime")] public string StartTime { get; set; } = "";
[JsonProperty("EndTime")] public string EndTime { get; set; } = "";
[JsonProperty("BuyStartTime")] public string BuyStartTime { get; set; } = "";
[JsonProperty("BuyEndTime")] public string BuyEndTime { get; set; } = "";
[JsonProperty("Condition")] public string Condition { get; set; } = "";
[JsonProperty("ExpStep")] public uint ExpStep { get; set; }
[JsonProperty("MaxExPerWeek")] public uint MaxExPerWeek { get; set; }
public override uint GetId() => Id;
public override void Loaded()
{
GameData.BattlePassTimeData[Id] = this;
}
}

View File

@@ -0,0 +1,21 @@
using Newtonsoft.Json;
namespace MikuSB.Data.Excel;
[ResourceEntity("dlc/dlc_activities.json")]
public class DlcActivityExcel : ExcelResource
{
[JsonProperty("ID")] public uint Id { get; set; }
[JsonProperty("StartTime")] public string StartTime { get; set; } = "";
[JsonProperty("EndTime")] public string EndTime { get; set; } = "";
[JsonProperty("EnterStartTime")] public string EnterStartTime { get; set; } = "";
[JsonProperty("CloseEndTime")] public string CloseEndTime { get; set; } = "";
[JsonProperty("Condition")] public string Condition { get; set; } = "";
public override uint GetId() => Id;
public override void Loaded()
{
GameData.DlcActivityData[Id] = this;
}
}

View File

@@ -0,0 +1,76 @@
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
namespace MikuSB.Data.Excel;
[ResourceEntity("purchase/ibgoods.json")]
public class IbGoodsExcel : ExcelResource
{
[JsonProperty("GoodsId")] private JToken? GoodsIdRaw { get; set; }
[JsonProperty("Type")] private JToken? TypeRaw { get; set; }
[JsonProperty("PreId")] private JToken? PreIdRaw { get; set; }
[JsonProperty("LimitTimes")] private JToken? LimitTimesRaw { get; set; }
[JsonProperty("Item")] private JToken? ItemRaw { get; set; }
[JsonProperty("Cost")] private JToken? CostRaw { get; set; }
[JsonProperty("Cost2")] private JToken? Cost2Raw { get; set; }
[JsonProperty("PcId")] public string PcId { get; set; } = "";
[JsonProperty("IosId")] public string IosId { get; set; } = "";
[JsonProperty("AndroidId")] public string AndroidId { get; set; } = "";
public override uint GetId() => GoodsId;
public override void Loaded()
{
GameData.IbGoodsData[GoodsId] = this;
}
[JsonIgnore]
public uint GoodsId => ReadUInt(GoodsIdRaw);
[JsonIgnore]
public int Type => (int)ReadUInt(TypeRaw);
[JsonIgnore]
public uint PreId => ReadUInt(PreIdRaw);
[JsonIgnore]
public uint LimitTimes => ReadUInt(LimitTimesRaw);
[JsonIgnore]
public List<uint> Item => ReadUIntList(ItemRaw);
[JsonIgnore]
public List<uint> Cost => ReadUIntList(CostRaw);
[JsonIgnore]
public List<uint> Cost2 => ReadUIntList(Cost2Raw);
public string GetProductId() =>
!string.IsNullOrWhiteSpace(PcId) ? PcId :
!string.IsNullOrWhiteSpace(AndroidId) ? AndroidId :
IosId;
private static uint ReadUInt(JToken? token)
{
if (token == null || token.Type is JTokenType.Null or JTokenType.Undefined)
return 0;
if (token.Type == JTokenType.Integer)
return token.Value<uint>();
if (token.Type == JTokenType.String && uint.TryParse(token.Value<string>(), out var value))
return value;
return 0;
}
private static List<uint> ReadUIntList(JToken? token)
{
if (token is not JArray array)
return [];
return array
.Select(entry => entry.Type == JTokenType.Integer ? entry.Value<uint>() : 0u)
.ToList();
}
}

View File

@@ -10,8 +10,17 @@ public class OtherItemExcel : ExcelResource
public uint Detail { get; set; } public uint Detail { get; set; }
public uint Particular { get; set; } public uint Particular { get; set; }
public uint Level { get; set; } public uint Level { get; set; }
public string LuaType { get; set; } = "";
[JsonProperty("UseMode")] public JToken? UseModeRaw { get; set; }
[JsonProperty("Param1")] public JToken? Param1Raw { get; set; }
[JsonProperty("GMnum")] public JToken? GMnumRaw { get; set; } [JsonProperty("GMnum")] public JToken? GMnumRaw { get; set; }
[JsonIgnore]
public uint UseMode => ReadUInt(UseModeRaw);
[JsonIgnore]
public uint Param1 => ReadUInt(Param1Raw);
[JsonIgnore] [JsonIgnore]
public uint GMnum => ReadUInt(GMnumRaw); public uint GMnum => ReadUInt(GMnumRaw);

View File

@@ -6,6 +6,7 @@ namespace MikuSB.Data.Excel;
public class RecycleExcel : ExcelResource public class RecycleExcel : ExcelResource
{ {
public int ID { get; set; } public int ID { get; set; }
public JToken? RecycleReward { get; set; }
public JToken? RecycleBase { get; set; } public JToken? RecycleBase { get; set; }
public JToken? RecycleRatio { get; set; } public JToken? RecycleRatio { get; set; }

View File

@@ -13,6 +13,7 @@ public class SupportCardExcel : ExcelResource
public uint Icon { get; set; } public uint Icon { get; set; }
public uint ProvideExp { get; set; } public uint ProvideExp { get; set; }
public uint Color { get; set; } public uint Color { get; set; }
[JsonProperty("RecycleID")] public int RecycleID { get; set; }
[JsonProperty("LevelLimitID")] public int LevelLimitId { get; set; } [JsonProperty("LevelLimitID")] public int LevelLimitId { get; set; }
[JsonProperty("AffixPool")] public List<int> AffixPool { get; set; } = []; [JsonProperty("AffixPool")] public List<int> AffixPool { get; set; } = [];
[JsonProperty("AffixCost")] public JToken? AffixCostRaw { get; set; } [JsonProperty("AffixCost")] public JToken? AffixCostRaw { get; set; }

View File

@@ -59,6 +59,9 @@ public static class GameData
public static Dictionary<uint, FishingFoodExcel> FishingFoodData { get; private set; } = []; public static Dictionary<uint, FishingFoodExcel> FishingFoodData { get; private set; } = [];
public static Dictionary<uint, VirCaptureTowerExcel> VirCaptureTowerData { get; private set; } = []; public static Dictionary<uint, VirCaptureTowerExcel> VirCaptureTowerData { get; private set; } = [];
public static Dictionary<uint, DreamCardActivityExcel> DreamCardActivityData { get; private set; } = []; public static Dictionary<uint, DreamCardActivityExcel> DreamCardActivityData { get; private set; } = [];
public static Dictionary<uint, DlcActivityExcel> DlcActivityData { get; private set; } = [];
public static Dictionary<uint, BattlePassTimeExcel> BattlePassTimeData { get; private set; } = [];
public static Dictionary<uint, IbGoodsExcel> IbGoodsData { get; private set; } = [];
} }
public static class GameResourceTemplateId public static class GameResourceTemplateId

View File

@@ -205,6 +205,8 @@ public class PlayerInstance(PlayerGameData data)
Pid = (ulong)Data.Uid, Pid = (ulong)Data.Uid,
Account = displayName, Account = displayName,
Provider = displayName, Provider = displayName,
Channel = "gm",
Subchannel = "gm",
Name = displayName, Name = displayName,
Level = Data.Level, Level = Data.Level,
Sex = Data.Gender, Sex = Data.Gender,
@@ -242,6 +244,11 @@ public class PlayerInstance(PlayerGameData data)
proto.StrAttrs[ToShiftedAttrKey(x.Gid, x.Sid)] = x.Val; proto.StrAttrs[ToShiftedAttrKey(x.Gid, x.Sid)] = x.Val;
} }
foreach (var (key, value) in BuildMoneySync())
{
proto.Money[key] = value;
}
proto.ShowItems.AddRange(Data.ShowItems); proto.ShowItems.AddRange(Data.ShowItems);
return proto; return proto;
@@ -295,6 +302,24 @@ public class PlayerInstance(PlayerGameData data)
return (gid << 16) | sid; return (gid << 16) | sid;
} }
public Dictionary<string, int> BuildMoneySync()
{
var currentMoney = (int)Math.Min(int.MaxValue, GetAttrValue(1, 3));
var sync = new Dictionary<string, int>(StringComparer.OrdinalIgnoreCase)
{
["."] = currentMoney,
["gm.gm"] = currentMoney,
["jinshan.jinshan"] = currentMoney,
["pc_jinshan.pc_jinshan"] = currentMoney
};
return sync;
}
private uint GetAttrValue(uint gid, uint sid)
{
return Data.Attrs.FirstOrDefault(x => x.Gid == gid && x.Sid == sid)?.Val ?? 0;
}
public void BuildPlayerAttr(bool additional = false) public void BuildPlayerAttr(bool additional = false)
{ {
var bootstrapAttrs = BuildLobbyBootstrapAttrs().ToList(); var bootstrapAttrs = BuildLobbyBootstrapAttrs().ToList();

View File

@@ -8,6 +8,7 @@ public static class CallGSRouter
{ {
private static readonly Logger Logger = new("CallGS"); private static readonly Logger Logger = new("CallGS");
private static readonly Dictionary<string, ICallGSHandler> Handlers = []; private static readonly Dictionary<string, ICallGSHandler> Handlers = [];
private const string UnavailableTipKey = "ui.TxtNotOpen";
public static void Init() public static void Init()
{ {
@@ -32,11 +33,13 @@ public static class CallGSRouter
catch (Exception e) catch (Exception e)
{ {
Logger.Error($"[{req.Api}] {e.Message}", e); Logger.Error($"[{req.Api}] {e.Message}", e);
await SendUnavailableResponse(connection, req.Api);
} }
return; return;
} }
Logger.Error($"No handler for CallGS API: {req.Api}"); Logger.Error($"No handler for CallGS API: {req.Api}");
await SendUnavailableResponse(connection, req.Api);
} }
public static async Task SendScript(Connection connection, string api, string arg, NtfSyncPlayer extra = null!) public static async Task SendScript(Connection connection, string api, string arg, NtfSyncPlayer extra = null!)
@@ -44,4 +47,11 @@ public static class CallGSRouter
var rsp = new NtfCallScript { Api = api, Arg = arg, ExtraSync = extra }; var rsp = new NtfCallScript { Api = api, Arg = arg, ExtraSync = extra };
await connection.SendPacket(CmdIds.NtfScript, rsp); await connection.SendPacket(CmdIds.NtfScript, rsp);
} }
private static Task SendUnavailableResponse(Connection connection, string api)
{
// Many client Lua handlers treat sErr/sError as a recoverable failure path,
// which is preferable to leaving the request hanging forever.
return SendScript(connection, api, $$"""{"sErr":"{{UnavailableTipKey}}","sError":"{{UnavailableTipKey}}"}""");
}
} }

View File

@@ -0,0 +1,113 @@
using MikuSB.Data;
using MikuSB.Data.Excel;
using MikuSB.Database.Player;
using MikuSB.GameServer.Game.Player;
using MikuSB.Proto;
using System.Globalization;
using System.Text.Json.Nodes;
namespace MikuSB.GameServer.Server.CallGS.Handlers.BattlePass;
[CallGSApi("BattlePassLogic_ClientRefresh")]
public class BattlePassLogic_ClientRefresh : ICallGSHandler
{
private const uint GroupId = 25;
private const uint CurIdSid = 1;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var now = DateTime.Now;
var battlePass = ResolveCurrent(GameData.BattlePassTimeData.Values, now);
var player = connection.Player!;
var sync = new NtfSyncPlayer();
if (battlePass == null)
{
SetAttr(player, CurIdSid, 0, sync);
await CallGSRouter.SendScript(connection, "BattlePassLogic_ClientRefresh", "{}", sync);
return;
}
SetAttr(player, CurIdSid, battlePass.Id, sync);
var response = new JsonObject
{
["nId"] = battlePass.Id,
["nStartTime"] = ToUnixSeconds(ParseConfigTime(battlePass.StartTime)),
["nEndTime"] = ToUnixSeconds(ParseConfigTime(battlePass.EndTime))
};
await CallGSRouter.SendScript(connection, "BattlePassLogic_ClientRefresh", response.ToJsonString(), sync);
}
private static BattlePassTimeExcel? ResolveCurrent(IEnumerable<BattlePassTimeExcel> configs, DateTime now)
{
var parsed = configs
.Select(x => new
{
Config = x,
Start = ParseConfigTime(x.StartTime),
End = ParseConfigTime(x.EndTime)
})
.Where(x => x.Start.HasValue && x.End.HasValue)
.OrderBy(x => x.Start)
.ToList();
var current = parsed.FirstOrDefault(x => x.Start <= now && now < x.End);
if (current != null)
return current.Config;
var latestStarted = parsed.LastOrDefault(x => x.Start <= now && x.End > x.Start);
return latestStarted?.Config;
}
private static DateTime? ParseConfigTime(string? raw)
{
if (string.IsNullOrWhiteSpace(raw))
return null;
var normalized = raw.Trim().Trim('[', ']');
if (normalized.Length != 12)
return null;
return DateTime.TryParseExact(
normalized,
"yyyyMMddHHmm",
CultureInfo.InvariantCulture,
DateTimeStyles.None,
out var value)
? value
: null;
}
private static long ToUnixSeconds(DateTime? value)
{
return value.HasValue ? new DateTimeOffset(value.Value).ToUnixTimeSeconds() : 0L;
}
private static void SetAttr(PlayerInstance player, uint sid, uint value, NtfSyncPlayer sync)
{
var attr = GetOrCreateAttr(player, sid);
if (attr.Val != value)
{
attr.Val = value;
sync.Custom[player.ToPackedAttrKey(GroupId, sid)] = value;
sync.Custom[player.ToShiftedAttrKey(GroupId, sid)] = value;
}
}
private static PlayerAttr GetOrCreateAttr(PlayerInstance player, uint sid)
{
var attr = player.Data.Attrs.FirstOrDefault(x => x.Gid == GroupId && x.Sid == sid);
if (attr != null)
return attr;
attr = new PlayerAttr
{
Gid = GroupId,
Sid = sid
};
player.Data.Attrs.Add(attr);
return attr;
}
}

View File

@@ -0,0 +1,112 @@
using MikuSB.Data;
using MikuSB.Data.Excel;
using MikuSB.Database.Player;
using MikuSB.GameServer.Game.Player;
using MikuSB.Proto;
using System.Globalization;
using System.Text.Json.Nodes;
namespace MikuSB.GameServer.Server.CallGS.Handlers.DLC;
[CallGSApi("DLCLogic_CheckOpenAct")]
public class DLCLogic_CheckOpenAct : ICallGSHandler
{
private const uint GroupId = 15;
private const uint ActIdSid = 1;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var now = DateTime.Now;
var act = ResolveCurrent(GameData.DlcActivityData.Values, now);
if (act == null)
{
await CallGSRouter.SendScript(connection, "DLCLogic_CheckOpenAct", "{\"bOpen\":false}");
return;
}
var player = connection.Player!;
var sync = new NtfSyncPlayer();
SetAttr(player, ActIdSid, act.Id, sync);
var response = new JsonObject
{
["bOpen"] = true,
["nId"] = act.Id,
["nStartTime"] = ToUnixSeconds(ParseConfigTime(act.EnterStartTime)),
["nEndTime"] = ToUnixSeconds(ParseConfigTime(act.CloseEndTime))
};
await CallGSRouter.SendScript(connection, "DLCLogic_CheckOpenAct", response.ToJsonString(), sync);
}
private static DlcActivityExcel? ResolveCurrent(IEnumerable<DlcActivityExcel> configs, DateTime now)
{
var parsed = configs
.Select(x => new
{
Config = x,
Start = ParseConfigTime(x.EnterStartTime),
End = ParseConfigTime(x.CloseEndTime)
})
.Where(x => x.Start.HasValue && x.End.HasValue)
.OrderBy(x => x.Start)
.ToList();
var current = parsed.FirstOrDefault(x => x.Start <= now && now < x.End);
if (current != null)
return current.Config;
var latestStarted = parsed.LastOrDefault(x => x.Start <= now && x.End > x.Start);
return latestStarted?.Config;
}
private static DateTime? ParseConfigTime(string? raw)
{
if (string.IsNullOrWhiteSpace(raw))
return null;
var normalized = raw.Trim().Trim('[', ']');
if (normalized.Length != 12)
return null;
return DateTime.TryParseExact(
normalized,
"yyyyMMddHHmm",
CultureInfo.InvariantCulture,
DateTimeStyles.None,
out var value)
? value
: null;
}
private static long ToUnixSeconds(DateTime? value)
{
return value.HasValue ? new DateTimeOffset(value.Value).ToUnixTimeSeconds() : 0L;
}
private static void SetAttr(PlayerInstance player, uint sid, uint value, NtfSyncPlayer sync)
{
var attr = GetOrCreateAttr(player, sid);
if (attr.Val != value)
{
attr.Val = value;
sync.Custom[player.ToPackedAttrKey(GroupId, sid)] = value;
sync.Custom[player.ToShiftedAttrKey(GroupId, sid)] = value;
}
}
private static PlayerAttr GetOrCreateAttr(PlayerInstance player, uint sid)
{
var attr = player.Data.Attrs.FirstOrDefault(x => x.Gid == GroupId && x.Sid == sid);
if (attr != null)
return attr;
attr = new PlayerAttr
{
Gid = GroupId,
Sid = sid
};
player.Data.Attrs.Add(attr);
return attr;
}
}

View File

@@ -0,0 +1,316 @@
using MikuSB.Data;
using MikuSB.Data.Excel;
using MikuSB.Database;
using MikuSB.Database.Inventory;
using MikuSB.Enums.Item;
using MikuSB.Proto;
using Newtonsoft.Json.Linq;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace MikuSB.GameServer.Server.CallGS.Handlers.Inventory;
[CallGSApi("Item_Recycle")]
public class Item_Recycle : ICallGSHandler
{
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var player = connection.Player!;
var req = JsonSerializer.Deserialize<ItemRecycleParam>(param);
if (req?.TbItems == null || req.TbItems.Count == 0)
{
await CallGSRouter.SendScript(connection, "Item_Recycle", "{\"sErr\":\"error.BadParam\"}");
return;
}
var config = RecycleConfig.Load();
var itemsToRecycle = new List<(BaseGameItemInfo Item, int RecycleId)>();
foreach (var uniqueId in req.TbItems)
{
BaseGameItemInfo? item = player.InventoryManager.GetWeaponItem((uint)uniqueId)
?? (BaseGameItemInfo?)player.InventoryManager.GetSupportCardItem((uint)uniqueId);
if (item == null)
{
await CallGSRouter.SendScript(connection, "Item_Recycle", "{\"sErr\":\"error.Recycle.ItemNotExists\"}");
return;
}
var recycleId = GetRecycleId(item);
if (recycleId <= 0 || !config.HasConfig(recycleId))
{
await CallGSRouter.SendScript(connection, "Item_Recycle", "{\"sErr\":\"error.Recycle.ItemCanNotRecycle\"}");
return;
}
itemsToRecycle.Add((item, recycleId));
}
var sync = new NtfSyncPlayer();
foreach (var (item, recycleId) in itemsToRecycle)
{
var rewards = config.CalcRewards(item, recycleId);
foreach (var reward in rewards)
await GrantRewardAsync(player, sync, reward);
RemoveItem(player.InventoryManager.InventoryData, item, sync);
}
DatabaseHelper.SaveDatabaseType(player.InventoryManager.InventoryData);
await CallGSRouter.SendScript(connection, "Item_Recycle", "{}", sync);
}
private static int GetRecycleId(BaseGameItemInfo item)
{
if (item.ItemType == ItemTypeEnum.TYPE_WEAPON)
{
var t = GameData.WeaponData.Values.FirstOrDefault(x =>
GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level) == item.TemplateId);
return t?.RecycleID ?? 0;
}
if (item.ItemType == ItemTypeEnum.TYPE_SUPPORT)
{
var t = GameData.SupportCardData.FirstOrDefault(x => x.TemplateId == item.TemplateId);
return t?.RecycleID ?? 0;
}
return 0;
}
private static void RemoveItem(InventoryData inventory, BaseGameItemInfo item, NtfSyncPlayer sync)
{
var removed = item.ToProto();
removed.Count = 0;
sync.Items.Add(removed);
if (item.ItemType == ItemTypeEnum.TYPE_WEAPON)
inventory.Weapons.Remove(item.UniqueId);
else
inventory.SupportCards.Remove(item.UniqueId);
}
private static async Task GrantRewardAsync(GameServer.Game.Player.PlayerInstance player, NtfSyncPlayer sync, IReadOnlyList<uint> reward)
{
if (reward.Count < 5) return;
var itemType = (ItemTypeEnum)reward[0];
var detail = reward[1];
var particular = reward[2];
var level = reward[3];
var count = Math.Max(1u, reward[4]);
switch (itemType)
{
case ItemTypeEnum.TYPE_SUPPLIES:
{
var templateId = (uint)GameResourceTemplateId.FromGdpl(reward[0], detail, particular, level);
if (!GameData.SuppliesData.TryGetValue(templateId, out var supplies)) break;
var item = await player.InventoryManager.AddSuppliesItem(supplies, count, sendPacket: false);
if (item != null) sync.Items.Add(item.ToProto());
break;
}
}
}
}
internal sealed class RecycleConfig
{
private readonly Dictionary<int, RecycleEntry> _entries;
private readonly List<SupplyTemplate> _weaponSupplies;
private readonly List<SupplyTemplate> _supportSupplies;
private readonly Dictionary<int, ulong> _weaponLevelExp;
private readonly Dictionary<int, ulong> _supportLevelExp;
private readonly Dictionary<int, ulong> _weaponLevelExpSsr;
private readonly Dictionary<int, ulong> _supportLevelExpSsr;
private RecycleConfig(
Dictionary<int, RecycleEntry> entries,
List<SupplyTemplate> weaponSupplies,
List<SupplyTemplate> supportSupplies,
Dictionary<int, ulong> weaponLevelExp,
Dictionary<int, ulong> weaponLevelExpSsr,
Dictionary<int, ulong> supportLevelExp,
Dictionary<int, ulong> supportLevelExpSsr)
{
_entries = entries;
_weaponSupplies = weaponSupplies;
_supportSupplies = supportSupplies;
_weaponLevelExp = weaponLevelExp;
_weaponLevelExpSsr = weaponLevelExpSsr;
_supportLevelExp = supportLevelExp;
_supportLevelExpSsr = supportLevelExpSsr;
}
public static RecycleConfig Load()
{
var entries = new Dictionary<int, RecycleEntry>();
foreach (var row in GameData.RecycleData.Values)
{
var fixedRewards = ParseRewards(row.RecycleReward);
var recycleBase = GetUInt(row.RecycleBase);
var recycleRatio = GetDecimal(row.RecycleRatio);
entries[row.ID] = new RecycleEntry(fixedRewards, recycleBase, recycleRatio);
}
var weaponSupplies = new List<SupplyTemplate>();
var supportSupplies = new List<SupplyTemplate>();
foreach (var s in GameData.AllSuppliesData)
{
if (s.ProvideExp == 0) continue;
if (s.Genre == 5 && s.Detail == 2)
weaponSupplies.Add(new SupplyTemplate(s.Genre, s.Detail, s.Particular, s.Level, s.ProvideExp));
else if (s.Genre == 5 && s.Detail == 3)
supportSupplies.Add(new SupplyTemplate(s.Genre, s.Detail, s.Particular, s.Level, s.ProvideExp));
}
weaponSupplies.Sort((a, b) => b.ProvideExp.CompareTo(a.ProvideExp));
supportSupplies.Sort((a, b) => b.ProvideExp.CompareTo(a.ProvideExp));
var weaponLevelExp = BuildLevelExpTable(GameData.UpgradeExpData.Values.Select(x => (x.Lv, x.WeaponNeedExp)));
var weaponLevelExpSsr = BuildLevelExpTable(GameData.UpgradeExpData.Values.Select(x => (x.Lv, x.SSRWeaponNeedExp)));
var supportLevelExp = BuildLevelExpTable(GameData.UpgradeExpData.Values.Select(x => (x.Lv, x.SusNeedExp)));
var supportLevelExpSsr = BuildLevelExpTable(GameData.UpgradeExpData.Values.Select(x => (x.Lv, x.SSRSusNeedExp)));
return new RecycleConfig(entries, weaponSupplies, supportSupplies, weaponLevelExp, weaponLevelExpSsr, supportLevelExp, supportLevelExpSsr);
}
public bool HasConfig(int recycleId) => _entries.ContainsKey(recycleId);
public List<IReadOnlyList<uint>> CalcRewards(BaseGameItemInfo item, int recycleId)
{
if (!_entries.TryGetValue(recycleId, out var entry))
return [];
var rewards = new List<IReadOnlyList<uint>>(entry.FixedRewards);
var expRewards = CalcExpRewards(item, entry);
rewards.AddRange(expRewards);
return rewards;
}
private List<IReadOnlyList<uint>> CalcExpRewards(BaseGameItemInfo item, RecycleEntry entry)
{
if (entry.RecycleRatio == 0) return [];
List<SupplyTemplate> supplies;
Dictionary<int, ulong> levelExp;
if (item.ItemType == ItemTypeEnum.TYPE_WEAPON)
{
supplies = _weaponSupplies;
var color = GetItemColor(item);
levelExp = color == 5 ? _weaponLevelExpSsr : _weaponLevelExp;
}
else if (item.ItemType == ItemTypeEnum.TYPE_SUPPORT)
{
supplies = _supportSupplies;
var color = GetItemColor(item);
levelExp = color == 5 ? _supportLevelExpSsr : _supportLevelExp;
}
else
{
return [];
}
var baseExp = (ulong)entry.RecycleBase;
var levelAccum = levelExp.GetValueOrDefault((int)item.Level);
var totalExp = (ulong)Math.Floor((baseExp + levelAccum + item.Exp) * (double)entry.RecycleRatio);
if (totalExp == 0 || supplies.Count == 0) return [];
var rewards = new List<IReadOnlyList<uint>>();
var remaining = totalExp;
foreach (var supply in supplies)
{
if (remaining == 0) break;
var count = remaining / supply.ProvideExp;
if (count == 0) continue;
remaining -= count * supply.ProvideExp;
rewards.Add([supply.Genre, supply.Detail, supply.Particular, supply.Level, (uint)Math.Min(count, 99999)]);
}
return rewards;
}
private static List<IReadOnlyList<uint>> ParseRewards(JToken? token)
{
if (token == null) return [];
if (token is JArray outerArray)
{
var rewards = new List<IReadOnlyList<uint>>();
foreach (var element in outerArray)
{
if (element is JArray inner && inner.Count >= 4)
{
var reward = inner.Select(x => x.Value<uint>()).ToArray();
if (reward.Length < 5)
reward = [.. reward, 1];
rewards.Add(reward);
}
}
return rewards;
}
return [];
}
private static int GetItemColor(BaseGameItemInfo item)
{
if (item.ItemType == ItemTypeEnum.TYPE_WEAPON)
{
var t = GameData.WeaponData.Values.FirstOrDefault(x =>
GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level) == item.TemplateId);
return t?.Color ?? 0;
}
if (item.ItemType == ItemTypeEnum.TYPE_SUPPORT)
{
var t = GameData.SupportCardData.FirstOrDefault(x => x.TemplateId == item.TemplateId);
return (int)(t?.Color ?? 0);
}
return 0;
}
private static Dictionary<int, ulong> BuildLevelExpTable(IEnumerable<(int Lv, uint NeedExp)> source)
{
var table = new Dictionary<int, ulong>();
ulong accumulated = 0;
foreach (var (lv, needExp) in source.OrderBy(x => x.Lv))
{
table[lv] = accumulated;
accumulated += needExp;
}
return table;
}
private static uint GetUInt(JToken? token) => token?.Type switch
{
JTokenType.Integer => token.Value<uint>(),
JTokenType.Float => (uint)Math.Max(0, token.Value<decimal>()),
JTokenType.String when uint.TryParse(token.Value<string>(), out var r) => r,
_ => 0
};
private static decimal GetDecimal(JToken? token) => token?.Type switch
{
JTokenType.Integer => token.Value<decimal>(),
JTokenType.Float => token.Value<decimal>(),
JTokenType.String when decimal.TryParse(token.Value<string>(), out var r) => r,
_ => 0m
};
}
internal readonly record struct RecycleEntry(
List<IReadOnlyList<uint>> FixedRewards,
uint RecycleBase,
decimal RecycleRatio);
internal readonly record struct SupplyTemplate(uint Genre, uint Detail, uint Particular, uint Level, uint ProvideExp);
internal sealed class ItemRecycleParam
{
[JsonPropertyName("tbItems")]
public List<int> TbItems { get; set; } = [];
}

View File

@@ -0,0 +1,59 @@
using MikuSB.Database;
using MikuSB.Database.Player;
using MikuSB.GameServer.Game.Player;
using MikuSB.Proto;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace MikuSB.GameServer.Server.CallGS.Handlers.Misc;
[CallGSApi("Adjust_Record")]
public class Adjust_Record : ICallGSHandler
{
private const uint GroupId = 107;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var req = JsonSerializer.Deserialize<AdjustRecordParam>(param);
if (req == null || req.Type == 0)
{
await CallGSRouter.SendScript(connection, "Adjust_Record", "null");
return;
}
var player = connection.Player!;
var sync = new NtfSyncPlayer();
var attr = GetOrCreateAttr(player, req.Type);
if (attr.Val == 0)
{
attr.Val = 1;
sync.Custom[player.ToPackedAttrKey(GroupId, req.Type)] = 1;
sync.Custom[player.ToShiftedAttrKey(GroupId, req.Type)] = 1;
DatabaseHelper.SaveDatabaseType(player.Data);
}
await CallGSRouter.SendScript(connection, "Adjust_Record", "null", sync);
}
private static PlayerAttr GetOrCreateAttr(PlayerInstance player, uint sid)
{
var attr = player.Data.Attrs.FirstOrDefault(x => x.Gid == GroupId && x.Sid == sid);
if (attr != null)
return attr;
attr = new PlayerAttr
{
Gid = GroupId,
Sid = sid
};
player.Data.Attrs.Add(attr);
return attr;
}
}
internal sealed class AdjustRecordParam
{
[JsonPropertyName("nType")]
public uint Type { get; set; }
}

View File

@@ -0,0 +1,451 @@
using MikuSB.Data;
using MikuSB.Data.Excel;
using MikuSB.Database;
using MikuSB.Database.Inventory;
using MikuSB.Database.Player;
using MikuSB.Enums.Item;
using MikuSB.GameServer.Game.Player;
using MikuSB.Proto;
using System.Globalization;
using System.Text.Json;
using System.Text.Json.Nodes;
using System.Text.Json.Serialization;
namespace MikuSB.GameServer.Server.CallGS.Handlers.Shop;
[CallGSApi("IBLogic_BuyGoods")]
public class IBLogic_BuyGoods : ICallGSHandler
{
private const uint BuyGroupId = 26;
private const uint RedGroupId = 113;
private const uint CashGroupId = 1;
private const uint BattlePassGroupId = 25;
private const uint BattlePassCurIdSid = 1;
private const uint BattlePassStatusSid = 2;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var req = JsonSerializer.Deserialize<IbBuyGoodsParam>(param);
var player = connection.Player!;
if (req?.Type == 3 && req.GoodsId > 0 && req.Count > 0)
{
await HandleBattlePassPurchase(connection, player, req);
return;
}
if (req == null ||
req.GoodsId == 0 ||
req.Count == 0 ||
!GameData.IbGoodsData.TryGetValue(req.GoodsId, out var goods))
{
await CallGSRouter.SendScript(connection, "IBLogic_BuyGoods", "{\"sErr\":\"error.BadParam\"}");
return;
}
if (goods.LimitTimes > 0)
{
var buyAttr = GetOrCreateAttr(player, BuyGroupId, req.GoodsId);
if (buyAttr.Val >= goods.LimitTimes)
{
await CallGSRouter.SendScript(connection, "IBLogic_BuyGoods", "{\"sErr\":\"tip.Mall_Limit_Buy\"}");
return;
}
}
var rewardItems = BuildRewardItems(goods, req);
if (rewardItems.Count == 0)
{
await CallGSRouter.SendScript(connection, "IBLogic_BuyGoods", "{\"sErr\":\"error.BadParam\"}");
return;
}
var sync = new NtfSyncPlayer();
foreach (var reward in rewardItems)
await GrantRewardAsync(player, sync, reward);
var buyCountAttr = GetOrCreateAttr(player, BuyGroupId, req.GoodsId);
buyCountAttr.Val += req.Count;
SyncAttr(player, sync, buyCountAttr);
var redAttr = GetOrCreateAttr(player, RedGroupId, req.GoodsId);
if (redAttr.Val == 0)
{
redAttr.Val = 1;
SyncAttr(player, sync, redAttr);
}
DatabaseHelper.SaveDatabaseType(player.Data);
DatabaseHelper.SaveDatabaseType(player.InventoryManager.InventoryData);
DatabaseHelper.SaveDatabaseType(player.CharacterManager.CharacterData);
var responseGoods = new JsonArray();
foreach (var reward in rewardItems)
{
var row = new JsonArray();
foreach (var value in reward)
row.Add((int)value);
responseGoods.Add(row);
}
var rsp = new JsonObject
{
["nGoodsId"] = (int)req.GoodsId,
["tbGoods"] = responseGoods
};
var productId = goods.GetProductId();
if (!string.IsNullOrWhiteSpace(productId))
rsp["sProductId"] = productId;
var cost = req.Index == 2 ? goods.Cost2 : goods.Cost;
if (cost.Count >= 2)
rsp["nTotalPrice"] = (int)cost[1];
await CallGSRouter.SendScript(connection, "IBLogic_BuyGoods", rsp.ToJsonString(), sync);
}
private static async Task HandleBattlePassPurchase(Connection connection, PlayerInstance player, IbBuyGoodsParam req)
{
var sync = new NtfSyncPlayer();
var battlePassId = ResolveCurrentBattlePassId();
if (battlePassId > 0)
{
var curIdAttr = GetOrCreateAttr(player, BattlePassGroupId, BattlePassCurIdSid);
curIdAttr.Val = battlePassId;
SyncAttr(player, sync, curIdAttr);
}
var statusAttr = GetOrCreateAttr(player, BattlePassGroupId, BattlePassStatusSid);
if (statusAttr.Val < 2)
{
statusAttr.Val = 2;
SyncAttr(player, sync, statusAttr);
}
var buyCountAttr = GetOrCreateAttr(player, BuyGroupId, req.GoodsId);
buyCountAttr.Val += req.Count;
SyncAttr(player, sync, buyCountAttr);
var redAttr = GetOrCreateAttr(player, RedGroupId, req.GoodsId);
if (redAttr.Val == 0)
{
redAttr.Val = 1;
SyncAttr(player, sync, redAttr);
}
DatabaseHelper.SaveDatabaseType(player.Data);
var rsp = new JsonObject
{
["nGoodsId"] = (int)req.GoodsId,
["tbGoods"] = new JsonArray()
};
await CallGSRouter.SendScript(connection, "IBLogic_BuyGoods", rsp.ToJsonString(), sync);
}
private static List<List<uint>> BuildRewardItems(IbGoodsExcel goods, IbBuyGoodsParam req)
{
var rewards = new List<List<uint>>();
if (goods.Item.Count >= 4)
rewards.Add(WithCount(goods.Item, req.Count));
if (req.SelectItem1?.Count >= 4)
rewards.Add(WithCount(req.SelectItem1, req.Count));
if (req.SelectItem2?.Count >= 4)
rewards.Add(WithCount(req.SelectItem2, req.Count));
return rewards;
}
private static List<uint> WithCount(IReadOnlyList<uint> item, uint buyCount)
{
var reward = item.Take(5).ToList();
while (reward.Count < 5)
reward.Add(1);
reward[4] = Math.Max(1u, reward[4]) * Math.Max(1u, buyCount);
return reward;
}
private static async Task GrantRewardAsync(PlayerInstance player, NtfSyncPlayer sync, IReadOnlyList<uint> reward)
{
if (reward.Count < 5)
return;
var itemType = (ItemTypeEnum)reward[0];
var detail = reward[1];
var particular = reward[2];
var level = reward[3];
var count = Math.Max(1u, reward[4]);
switch (itemType)
{
case ItemTypeEnum.TYPE_CARD:
for (var i = 0u; i < count; i++)
{
var character = await player.CharacterManager.AddCharacter(itemType, detail, particular, level, sendPacket: false);
if (character != null)
sync.Items.Add(character.ToProto());
}
break;
case ItemTypeEnum.TYPE_WEAPON:
for (var i = 0u; i < count; i++)
{
var weapon = await player.InventoryManager.AddWeaponItem(itemType, detail, particular, level, sendPacket: false);
if (weapon != null)
sync.Items.Add(weapon.ToProto());
}
break;
case ItemTypeEnum.TYPE_SUPPORT:
for (var i = 0u; i < count; i++)
{
var support = await player.InventoryManager.AddSupportCardItem(detail, particular, level, sendPacket: false);
if (support != null)
sync.Items.Add(support.ToProto());
}
break;
case ItemTypeEnum.TYPE_SUPPLIES:
{
var templateId = (uint)GameResourceTemplateId.FromGdpl(reward[0], detail, particular, level);
if (!GameData.SuppliesData.TryGetValue(templateId, out var supplies))
break;
var item = await player.InventoryManager.AddSuppliesItem(supplies, count, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
break;
}
case ItemTypeEnum.TYPE_USEABLE:
{
if (!TryGrantCashBox(player, sync, detail, particular, level, count))
{
var item = AddOtherItem(player.InventoryManager.InventoryData, reward[0], detail, particular, level, count);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
}
case ItemTypeEnum.TYPE_WEAPON_PART:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddWeaponPartItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_CARD_SKIN:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddSkinItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_HOUSE:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddHouseFurnitureItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_PROFILE:
case ItemTypeEnum.TYPE_FRAME:
case ItemTypeEnum.TYPE_BADGE:
case ItemTypeEnum.TYPE_COVER:
case ItemTypeEnum.TYPE_NAMECARD:
case ItemTypeEnum.TYPE_EXPRESSION:
case ItemTypeEnum.TYPE_BUBBLE:
case ItemTypeEnum.TYPE_ANALYST:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddProfileItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_WEAPON_SKIN:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddWeaponSkinItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_MANIFESTATION:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddManifestationItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_CARD_SKIN_PART:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddSkinPartItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_AR:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddArItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
case ItemTypeEnum.TYPE_CALL:
for (var i = 0u; i < count; i++)
{
var item = await player.InventoryManager.AddCallItem(itemType, detail, particular, level, sendPacket: false);
if (item != null)
sync.Items.Add(item.ToProto());
}
break;
}
}
private static BaseGameItemInfo? AddOtherItem(InventoryData inventory, uint genre, uint detail, uint particular, uint level, uint count)
{
var templateId = (uint)GameResourceTemplateId.FromGdpl(genre, detail, particular, level);
if (!GameData.OtherItemData.TryGetValue(templateId, out var otherItem))
return null;
var maxCount = otherItem.GMnum > 0 ? otherItem.GMnum : 99999u;
var existing = inventory.Items.Values.FirstOrDefault(x => x.TemplateId == templateId);
if (existing != null)
{
existing.ItemCount = Math.Min(existing.ItemCount + count, maxCount);
return existing;
}
var item = new BaseGameItemInfo
{
TemplateId = templateId,
UniqueId = inventory.NextUniqueUid++,
ItemType = ItemTypeEnum.TYPE_USEABLE,
ItemCount = Math.Min(count, maxCount)
};
inventory.Items[item.UniqueId] = item;
return item;
}
private static bool TryGrantCashBox(PlayerInstance player, NtfSyncPlayer sync, uint detail, uint particular, uint level, uint count)
{
var templateId = (uint)GameResourceTemplateId.FromGdpl((uint)ItemTypeEnum.TYPE_USEABLE, detail, particular, level);
if (!GameData.OtherItemData.TryGetValue(templateId, out var otherItem))
return false;
uint moneyType = otherItem.LuaType switch
{
"money_box" => 1,
"gold_box" => 2,
"silver_box" => 3,
"vigor_box" => 4,
_ => 0
};
if (moneyType == 0 || otherItem.Param1 == 0)
return false;
var amount = checked(otherItem.Param1 * count);
var sid = moneyType * 2 + 1;
var attr = GetOrCreateAttr(player, CashGroupId, sid);
attr.Val += amount;
SyncAttr(player, sync, attr);
if (moneyType == 1)
{
foreach (var (key, value) in player.BuildMoneySync())
sync.Money[key] = value;
}
return true;
}
private static uint ResolveCurrentBattlePassId()
{
var now = DateTime.Now;
var parsed = GameData.BattlePassTimeData.Values
.Select(x => new
{
Config = x,
Start = ParseConfigTime(x.StartTime),
End = ParseConfigTime(x.EndTime)
})
.Where(x => x.Start.HasValue && x.End.HasValue)
.OrderBy(x => x.Start)
.ToList();
var current = parsed.FirstOrDefault(x => x.Start <= now && now < x.End);
if (current != null)
return current.Config.Id;
var latestStarted = parsed.LastOrDefault(x => x.Start <= now && x.End > x.Start);
return latestStarted?.Config.Id ?? 0;
}
private static DateTime? ParseConfigTime(string? raw)
{
if (string.IsNullOrWhiteSpace(raw))
return null;
var normalized = raw.Trim().Trim('[', ']');
if (normalized.Length != 12)
return null;
return DateTime.TryParseExact(
normalized,
"yyyyMMddHHmm",
CultureInfo.InvariantCulture,
DateTimeStyles.None,
out var value)
? value
: null;
}
private static PlayerAttr GetOrCreateAttr(PlayerInstance player, uint gid, uint sid)
{
var attr = player.Data.Attrs.FirstOrDefault(x => x.Gid == gid && x.Sid == sid);
if (attr != null)
return attr;
attr = new PlayerAttr
{
Gid = gid,
Sid = sid
};
player.Data.Attrs.Add(attr);
return attr;
}
private static void SyncAttr(PlayerInstance player, NtfSyncPlayer sync, PlayerAttr attr)
{
sync.Custom[player.ToPackedAttrKey(attr.Gid, attr.Sid)] = attr.Val;
sync.Custom[player.ToShiftedAttrKey(attr.Gid, attr.Sid)] = attr.Val;
}
}
internal sealed class IbBuyGoodsParam
{
[JsonPropertyName("nType")]
public int Type { get; set; }
[JsonPropertyName("nGoodsId")]
public uint GoodsId { get; set; }
[JsonPropertyName("nCount")]
public uint Count { get; set; }
[JsonPropertyName("nIndex")]
public int Index { get; set; }
[JsonPropertyName("tbSelectItem1")]
public List<uint>? SelectItem1 { get; set; }
[JsonPropertyName("tbSelectItem2")]
public List<uint>? SelectItem2 { get; set; }
}

View File

@@ -0,0 +1,71 @@
using MikuSB.Database;
using MikuSB.Database.Player;
using MikuSB.GameServer.Game.Player;
using MikuSB.Proto;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace MikuSB.GameServer.Server.CallGS.Handlers.Shop;
[CallGSApi("IBLogic_GoodsRedDot")]
public class IBLogic_GoodsRedDot : ICallGSHandler
{
private const uint RedGroupId = 113;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var req = JsonSerializer.Deserialize<IbGoodsRedDotParam>(param);
if (req?.GoodsIds == null || req.GoodsIds.Count == 0)
{
await CallGSRouter.SendScript(connection, "IBLogic_GoodsRedDot", "null");
return;
}
var player = connection.Player!;
var sync = new NtfSyncPlayer();
var changed = false;
foreach (var goodsId in req.GoodsIds.Where(x => x > 0).Distinct())
{
var attr = GetOrCreateAttr(player, RedGroupId, goodsId);
if (attr.Val > 0)
continue;
attr.Val = 1;
SyncAttr(player, sync, attr);
changed = true;
}
if (changed)
DatabaseHelper.SaveDatabaseType(player.Data);
await CallGSRouter.SendScript(connection, "IBLogic_GoodsRedDot", "null", sync);
}
private static PlayerAttr GetOrCreateAttr(PlayerInstance player, uint gid, uint sid)
{
var attr = player.Data.Attrs.FirstOrDefault(x => x.Gid == gid && x.Sid == sid);
if (attr != null)
return attr;
attr = new PlayerAttr
{
Gid = gid,
Sid = sid
};
player.Data.Attrs.Add(attr);
return attr;
}
private static void SyncAttr(PlayerInstance player, NtfSyncPlayer sync, PlayerAttr attr)
{
sync.Custom[player.ToPackedAttrKey(attr.Gid, attr.Sid)] = attr.Val;
sync.Custom[player.ToShiftedAttrKey(attr.Gid, attr.Sid)] = attr.Val;
}
}
internal sealed class IbGoodsRedDotParam
{
[JsonPropertyName("tbList")]
public List<uint> GoodsIds { get; set; } = [];
}

View File

@@ -0,0 +1,183 @@
using MikuSB.Data;
using MikuSB.Database;
using MikuSB.Database.Inventory;
using MikuSB.Proto;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace MikuSB.GameServer.Server.CallGS.Handlers.Weapon;
[CallGSApi("Weapon_OneKeyToMax")]
public class Weapon_OneKeyToMax : ICallGSHandler
{
private const uint MaxBreak = 6;
public async Task Handle(Connection connection, string param, ushort seqNo)
{
var player = connection.Player!;
var req = JsonSerializer.Deserialize<OneKeyToMaxParam>(param);
if (req == null || req.Id <= 0 || req.TbBreakUpgradeMat == null || req.TbBreakUpgradeMat.Count == 0)
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"error.BadParam\"}");
return;
}
var weapon = player.InventoryManager.GetWeaponItem((uint)req.Id);
if (weapon == null)
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"error.BadParam\"}");
return;
}
var config = WeaponUpgradeConfig.Load();
if (!config.TryGetWeaponTemplate(weapon.TemplateId, out var targetTemplate))
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"error.BadParam\"}");
return;
}
var inventory = player.InventoryManager.InventoryData;
var equippedWeaponIds = player.CharacterManager.CharacterData.Characters
.Select(x => x.WeaponUniqueId)
.Where(x => x != 0)
.ToHashSet();
// Validate all materials upfront before making any changes
foreach (var stage in req.TbBreakUpgradeMat)
{
if (stage == null || stage.Count < 3) continue;
var matList = stage[1].Deserialize<List<List<int>>>();
if (matList == null) continue;
foreach (var entry in matList)
{
if (entry == null || entry.Count < 2) continue;
var itemId = (uint)Math.Max(0, entry[0]);
var count = (uint)Math.Max(0, entry[1]);
if (itemId == 0 || count == 0) continue;
if (itemId == weapon.UniqueId)
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"tip.material_not_enough\"}");
return;
}
var material = FindInventoryItem(inventory, itemId);
if (material == null || material.ItemCount < count)
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"tip.material_not_enough\"}");
return;
}
if (material is GameWeaponInfo materialWeapon &&
(materialWeapon.EquipAvatarId != 0 || equippedWeaponIds.Contains(materialWeapon.UniqueId)))
{
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax", "{\"sErr\":\"tip.material_not_enough\"}");
return;
}
}
}
var syncItems = new List<Item>();
var weaponLevel = weapon.Level == 0 ? 1u : weapon.Level;
weapon.Level = weaponLevel;
// Process each break stage
foreach (var stage in req.TbBreakUpgradeMat)
{
if (stage == null || stage.Count < 3) continue;
var matList = stage[1].Deserialize<List<List<int>>>();
var doBreak = stage[2].GetInt32() == 1;
if (matList != null && matList.Count > 0)
{
// Aggregate materials, skip duplicates
var materialsUsed = new Dictionary<uint, uint>();
foreach (var entry in matList)
{
if (entry == null || entry.Count < 2) continue;
var itemId = (uint)Math.Max(0, entry[0]);
var count = (uint)Math.Max(0, entry[1]);
if (itemId == 0 || count == 0) continue;
materialsUsed[itemId] = materialsUsed.GetValueOrDefault(itemId) + count;
}
ulong totalExp = 0;
foreach (var (itemId, count) in materialsUsed)
{
var material = FindInventoryItem(inventory, itemId)!;
if (config.TryGetMaterialGain(material, out var gainExp))
totalExp += gainExp * count;
}
// Consume materials
foreach (var (itemId, count) in materialsUsed)
{
var material = FindInventoryItem(inventory, itemId)!;
material.ItemCount -= count;
if (material.ItemCount == 0)
{
RemoveInventoryItem(inventory, itemId);
var proto = material.ToProto();
proto.Count = 0;
syncItems.Add(proto);
}
else
{
syncItems.Add(material.ToProto());
}
}
// Apply exp to weapon
if (totalExp > 0)
{
var maxLevel = config.GetWeaponMaxLevel(targetTemplate.BreakLimitId, weapon.Break);
var (newLevel, newExp) = config.ApplyWeaponExp(weapon.Level, weapon.Exp, totalExp, targetTemplate.Color, maxLevel);
weapon.Level = newLevel;
weapon.Exp = newExp;
}
}
// Perform break
if (doBreak && weapon.Break < MaxBreak)
weapon.Break++;
}
syncItems.Add(weapon.ToProto());
DatabaseHelper.SaveDatabaseType(inventory);
var finalMaxLevel = config.GetWeaponMaxLevel(targetTemplate.BreakLimitId, weapon.Break);
var bMaxUnlock = finalMaxLevel > 0 && weapon.Level >= finalMaxLevel;
var sync = new NtfSyncPlayer();
sync.Items.AddRange(syncItems);
await CallGSRouter.SendScript(connection, "Weapon_OneKeyToMax",
$"{{\"bMaxUnLock\":{(bMaxUnlock ? "true" : "false")}}}", sync);
}
private static BaseGameItemInfo? FindInventoryItem(InventoryData inventory, uint itemId)
{
if (inventory.Weapons.TryGetValue(itemId, out var weapon)) return weapon;
if (inventory.Skins.TryGetValue(itemId, out var skin)) return skin;
if (inventory.Items.TryGetValue(itemId, out var item)) return item;
return null;
}
private static void RemoveInventoryItem(InventoryData inventory, uint itemId)
{
inventory.Weapons.Remove(itemId);
inventory.Skins.Remove(itemId);
inventory.Items.Remove(itemId);
}
}
internal sealed class OneKeyToMaxParam
{
[JsonPropertyName("Id")]
public int Id { get; set; }
[JsonPropertyName("tbBreakUpgradeMat")]
public List<List<System.Text.Json.JsonElement>> TbBreakUpgradeMat { get; set; } = [];
}

View File

@@ -258,9 +258,9 @@ internal sealed class WeaponUpgradeConfig
var weaponTemplates = GameData.WeaponData.Values.ToDictionary( var weaponTemplates = GameData.WeaponData.Values.ToDictionary(
x => GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level), x => GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level),
x => new MaterialTemplate(x.Color, x.ProvideExp, x.ConsumeGold, x.RecycleID, x.BreakLimitID)); x => new MaterialTemplate(x.Color, x.ProvideExp, x.ConsumeGold, x.RecycleID, x.BreakLimitID));
var suppliesTemplates = GameData.SuppliesData.Values.ToDictionary( var suppliesTemplates = GameData.AllSuppliesData
x => GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level), .GroupBy(x => GameResourceTemplateId.FromGdpl(x.Genre, x.Detail, x.Particular, x.Level))
x => new MaterialTemplate(x.Color, x.ProvideExp, x.ConsumeGold, 0, 0)); .ToDictionary(g => g.Key, g => new MaterialTemplate(g.First().Color, g.First().ProvideExp, g.First().ConsumeGold, 0, 0));
return new WeaponUpgradeConfig(normalExp, ssrExp, breakLimits, recycleById, weaponTemplates, suppliesTemplates); return new WeaponUpgradeConfig(normalExp, ssrExp, breakLimits, recycleById, weaponTemplates, suppliesTemplates);
} }
@@ -271,6 +271,24 @@ internal sealed class WeaponUpgradeConfig
public bool TryGetSuppliesTemplate(ulong templateId, out MaterialTemplate template) => public bool TryGetSuppliesTemplate(ulong templateId, out MaterialTemplate template) =>
_suppliesTemplates.TryGetValue(templateId, out template!); _suppliesTemplates.TryGetValue(templateId, out template!);
public bool TryGetMaterialGain(BaseGameItemInfo item, out ulong exp)
{
exp = 0;
if (TryGetWeaponTemplate(item.TemplateId, out var weaponTemplate))
{
exp = weaponTemplate.ProvideExp;
if (item is GameWeaponInfo weapon && weapon.Level > 1)
exp += GetWeaponRecycleExp(weaponTemplate, weapon.Level);
return true;
}
if (TryGetSuppliesTemplate(item.TemplateId, out var suppliesTemplate))
{
exp = suppliesTemplate.ProvideExp;
return true;
}
return false;
}
public ulong GetWeaponRecycleExp(MaterialTemplate template, uint level) public ulong GetWeaponRecycleExp(MaterialTemplate template, uint level)
{ {
if (template.RecycleId <= 0 || !_recycleById.TryGetValue(template.RecycleId, out var recycle)) if (template.RecycleId <= 0 || !_recycleById.TryGetValue(template.RecycleId, out var recycle))

View File

@@ -126,6 +126,8 @@ public class PacketNtfCallScript : BasePacket
sync.Custom[Player.ToPackedAttrKey(gid, sid)] = val; sync.Custom[Player.ToPackedAttrKey(gid, sid)] = val;
sync.Custom[Player.ToShiftedAttrKey(gid, sid)] = val; sync.Custom[Player.ToShiftedAttrKey(gid, sid)] = val;
} }
foreach (var (key, value) in Player.BuildMoneySync())
sync.Money[key] = value;
proto.ExtraSync = sync; proto.ExtraSync = sync;
SetData(proto); SetData(proto);

View File

@@ -53,35 +53,35 @@ dotnet build
## 機能一覧 ## 機能一覧
* [x] ログインと基本的なアカウント入場 * [x] ログインシステム
* [x] プレイヤーデータの読み込み * [x] インベントリ
* [x] 所持品の読み込み * [x] 戦闘
* [x] キャラクターの読み込み * [x] キャラクター
* [x] スキンの読み込み * [x] GMメニュー
* [x] 武器の読み込み * [x] 武器
* [x] ロビー表示キャラクターの変更 * [x] 後方支援
* [x] キャラクタースキンの変更 * [x] アポカリプス
* [x] キャラクタースキン形態の変更 * [x] アウクトゥス
* [x] 武器の付け替え * [x] 神格神経
* [x] 武器の強化 * [x] キャラスキン
* [x] プレイヤー名の変更 * [x] 武器スキン
* [x] 現在対応済みロビー状態の基本保存 * [x] ガチャ
* [✓] メイン章のステージ入場と関連フロ * [x] メインストーリーチャプタ
* [✓] デイリーのステージ入場と関連フロー * [x] 社員寮
* [✓] 基本的なプレイヤー設定同期 * [x] ミニゲーム
* [✓] 基本的なプロフィール同期 * [x] 地下清掃
* [✓] イベント関連リクエスト * [x] ニューロンシュミレーション
* [✓] 実績関連リクエスト * [x] 戦術評価
* [✓] 編成関連リクエスト * [x] エピソードストーリー
* [✓] プレビュー関連リクエスト * [x] ルーチン作戦
* [✓] 一部のショップ関連リクエスト * [x] 逆説迷宮
* [ ] 完全な戦闘フロー * [x] ロビー画面の編集
* [ ] ミッション / クエスト進行 * [✓] 惑星開拓
* [ ] ガチャ / 募集システム * [✓] 夢の絵本
* [ ] 完全なショップ挙動 * [ ] ショップ
* [ ] マルチプレイシステム * [ ] マルチプレイシステム
* [ ] 基地 / 宿舎システム * [ ] 名誉紛争
* [ ] クライアント API 全体の対応
## 貢献者 ## 貢献者
- [Naruse](https://github.com/DevilProMT) - [Naruse](https://github.com/DevilProMT)

View File

@@ -1 +1 @@
v=4.4 v=4.5