using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using ServerCore; using ServerBase; using ServerCommon; using ServerCommon.BusinessLogDomain; using MetaAssets; using static ClientToGameReq.Types; using static ClientToGameRes.Types; namespace GameServer.PacketHandler; [PacketHandler(typeof(ClientToGameReq), typeof(UseToolItemReq), typeof(ItemToolUsePacketHandler), typeof(GameLoginListener))] public class ItemToolUsePacketHandler : PacketRecvHandler { public static bool send_S2C_ACK_ITEM_TOOL_USE(Player owner, Result result) { var ack_packet = new ClientToGame(); ack_packet.Response = new ClientToGameRes(); ack_packet.Response.ErrorCode = result.ErrorCode; ack_packet.Response.UseToolItemRes = new UseToolItemRes(); if (false == GameServerApp.getServerLogic().onSendPacket(owner, ack_packet)) { return false; } return true; } public override async Task onProcessPacket(ISession entityWithSession, Google.Protobuf.IMessage recvMessage) { var result = new Result(); var err_msg = string.Empty; var entity_player = entityWithSession as Player; NullReferenceCheckHelper.throwIfNull(entity_player, () => "player is null !!!"); var recv_msg = recvMessage as ClientToGame; ArgumentNullReferenceCheckHelper.throwIfNull(recv_msg, () => $"recv_msg is null !!! - {entity_player.toBasicString()}"); var request = recv_msg.Request.UseToolItemReq; ArgumentNullReferenceCheckHelper.throwIfNull(request, () => $"request is null !!! - {entity_player.toBasicString()}"); var server_logic = GameServerApp.getServerLogic(); var player_action = entity_player.getEntityAction(); NullReferenceCheckHelper.throwIfNull(player_action, () => $"player_action is null !!! - {entity_player.toBasicString()}"); var selected_character = player_action.getSelectedCharacter(); if (null == selected_character) { err_msg = $"Not selected Character !!! - {entity_player.toBasicString()}"; result.setFail(ServerErrorCode.CharacterNotSelected, err_msg); Log.getLogger().error(result.toBasicString()); send_S2C_ACK_ITEM_TOOL_USE(entity_player, result); return result; } var fn_item_tool_use = async delegate () { var result = new Result(); var item_tool_action = entity_player.getEntityAction(); NullReferenceCheckHelper.throwIfNull(item_tool_action, () => $"item_tool_action is null !!! - {entity_player.toBasicString()}"); result = await item_tool_action.tryUseItemTool( request.EquipedToolItemStep, request.EquipedToolItemRandomState , (Int64)request.ActionStartTime ); if (result.isFail()) { err_msg = $"Failed to tryUseItemTool() !!! : {result.toBasicString()} - {entity_player.toBasicString()}"; Log.getLogger().error(err_msg); send_S2C_ACK_ITEM_TOOL_USE(entity_player, result); return result; } var batch = new QueryBatchEx( entity_player, LogActionType.ItemUse , server_logic.getDynamoDbClient() , true ); { batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner()); } result = await QueryHelper.sendQueryAndBusinessLog(batch); if (result.isFail()) { return result; } send_S2C_ACK_ITEM_TOOL_USE(entity_player, result); item_tool_action.send_S2C_NTF_ITEM_TOOL_USE(); return result; }; result = await entity_player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "ItemToolUse", fn_item_tool_use); if (result.isFail()) { err_msg = $"Failed to runTransactionRunnerSafely() !!! : {result.toBasicString()} - {entity_player.toBasicString()}"; Log.getLogger().error(err_msg); } return result; } }