using Google.Protobuf; using Google.Protobuf.WellKnownTypes; using ServerCore; using ServerBase; using ServerCommon; using ServerCommon.BusinessLogDomain; using MetaAssets; namespace GameServer.PacketHandler; [PacketHandler("", typeof(ServerMessage.Types.GS2MQS_NTF_FARMING_END), typeof(NtfFarmingEndMQPacketHandler), typeof(RabbitMQ4Game))] public class NtfFarmingEndMQPacketHandler : PacketRecvHandler { public override async Task onProcessPacket(ISession session, IMessage recvMessage) { var result = new Result(); var msg = recvMessage as ServerMessage; ArgumentNullException.ThrowIfNull(msg, $"msg is null !!!"); var ntf_msg_farming_end = msg.NtfFarmingEnd; ArgumentNullException.ThrowIfNull(ntf_msg_farming_end, $"ntf_msg_farming_end is null !!!"); var server_logic = GameServerApp.getServerLogic(); var player_manager = server_logic.getPlayerManager(); ArgumentNullException.ThrowIfNull(player_manager, $"player_manager is null !!!"); if (player_manager.tryGetUserByPrimaryKey(ntf_msg_farming_end.UserGuid, out var found_user) == false) { var err_msg = $"Failed to tryGetUserByPrimaryKey() !!!, Not found Player !!! : UserGuid:{msg.ReceiveMailNoti.AccountGuid}"; result.setFail(ServerErrorCode.UserNotLogin, err_msg); Log.getLogger().info(result.toBasicString()); return result; } var player_action = found_user.getEntityAction(); ArgumentNullException.ThrowIfNull(player_action, $"player_action is null !!! - {found_user.toBasicString()}"); var farming_summary = ntf_msg_farming_end.FarmingSummary; ArgumentNullException.ThrowIfNull(farming_summary, $"farming_summary is null !!! - {found_user.toBasicString()}"); if (FarmingSummonedEntityType.Beacon == farming_summary.FarmingSummonType) { var had_ugc_npcs = player_action.getHadUgcNpcs(); ArgumentNullException.ThrowIfNull(had_ugc_npcs, $"had_ugc_npcs is null !!! - {found_user.toBasicString()}"); if (false == had_ugc_npcs.TryGetValue(farming_summary.FarmingEntityGuid, out var found_ugc_npc)) { var err_msg = $"Not found UgcNpc !!! : ugcNpcMetaGuid:{farming_summary.FarmingEntityGuid} - {found_user.toBasicString()}"; result.setFail(ServerErrorCode.UgcNpcNotFound, err_msg); Log.getLogger().info(result.toBasicString()); return result; } Log.getLogger().info($"UgcNpc reset of State !!! in onProcessPacket() by GS2MQS_NTF_FARMING_END : {found_ugc_npc.toStateString()} - {found_ugc_npc.toBasicString()}"); var farming_action = found_ugc_npc.getEntityAction(); ArgumentNullException.ThrowIfNull(farming_action, $"farming_action is null !!! - {found_user.toBasicString()}"); result = await farming_action.resetFarmingState(ntf_msg_farming_end.IsApplyDb == BoolType.True); if(result.isFail()) { var err_msg = $"Failed to resetFarmingState() !!! : {result.toBasicString()} - {found_user.toBasicString()}"; Log.getLogger().error(err_msg); return result; } } FarmingNotifyHelper.send_GS2C_NTF_FARMING_END(found_user, farming_summary); return result; } }