using Google.Protobuf;
using Google.Protobuf.WellKnownTypes;


using ServerCore;
using ServerBase;
using ServerCommon;
using ServerCommon.BusinessLogDomain;
using MetaAssets;


using ITEM_GUID = System.String;


namespace GameServer.PacketHandler;

[PacketHandler(typeof(ClientToGameReq), typeof(ClientToGameReq.Types.SellItemReq), typeof(SellItemPacketHandler), typeof(GameLoginListener))]
public class SellItemPacketHandler : PacketRecvHandler
{
    private static void send_S2C_ACK_SELL_MY_ITEM(Player? owner, Result result, ITEM_GUID item_guid, int sell_count)
    {
        var ack_packet = new ClientToGame
        {
            Response = new ClientToGameRes
            {
                ErrorCode = result.ErrorCode,
                SellItemRes = new ClientToGameRes.Types.SellItemRes()
            }
        };

        if (result.isSuccess())
        {
            ack_packet.Response.SellItemRes.ItemGuid = item_guid;
            ack_packet.Response.SellItemRes.Count = sell_count;
            
                
            var account_attribute = owner!.getOriginEntityAttribute<AccountAttribute>();
            var level_attribute = owner.getOriginEntityAttribute<LevelAttribute>();
            var money_attribute = owner.getOriginEntityAttribute<MoneyAttribute>();
            var nickname_attribute = owner.getOriginEntityAttribute<NicknameAttribute>();

            var char_info = new CharInfo
            {
                Level = (int)level_attribute!.Level,
                Exp = (int)level_attribute.Exp,
                
                Gold = money_attribute!.Gold,
                Sapphire = money_attribute.Sapphire,
                Calium = money_attribute.Calium,
                Ruby = money_attribute.Ruby,
                
                Usergroup = account_attribute!.AuthAdminLevelType.ToString(), 
                Operator = (int)account_attribute.AuthAdminLevelType,
                
                DisplayName = nickname_attribute!.Nickname,
                LanguageInfo = (int)account_attribute.LanguageType,
                
                IsIntroComplete = 1
            };
            ack_packet.Response.SellItemRes.CurrencyInfo = char_info;
        }

        GameServerApp.getServerLogic().onSendPacket(owner!, ack_packet);
    }

    public override async Task<Result> onProcessPacket(ISession entityWithSession, IMessage recvMessage)
    {
        var result = new Result();
        string err_msg;
        var entity_player = entityWithSession as Player;
        NullReferenceCheckHelper.throwIfNull(entity_player, () => $"entity_player is null !!!");

        // 1. 기본 정보 체크
        var request = (recvMessage as ClientToGame)?.Request.SellItemReq;
        if (null == request)
        {
            err_msg = $"Failed to get Request !!! : {nameof(ClientToGame.Request.SellItemReq)}";
            result.setFail(ServerErrorCode.InvalidArgument, err_msg);
            Log.getLogger().error(result.toBasicString());

            send_S2C_ACK_SELL_MY_ITEM(entity_player, result, string.Empty, 0);
            return result;
        }

        var inventory_action = entity_player.getEntityAction<InventoryActionBase>();
        var found_item = inventory_action.tryGetItemByItemGuid(request.ItemGuid);
        
        var item_id = found_item?.getItemMeta()?.ItemId ?? 0;
        if (item_id <= 0)
        {
            err_msg = $"Failed to get item_id !!! : {nameof(ClientToGame.Request.SellItemReq)}";
            result.setFail(ServerErrorCode.InvalidArgument, err_msg);
            Log.getLogger().error(result.toBasicString());

            send_S2C_ACK_SELL_MY_ITEM(entity_player, result, string.Empty, 0);
            return result;
        }

        result = await entity_player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "SellMyItem", sellItemDelegate);
        if (result.isFail())
        {
            err_msg = $"Failed to runTransactionRunnerSafely()!!! : {result.toBasicString()} - {entity_player.toBasicString()}";
            Log.getLogger().error(err_msg);
            send_S2C_ACK_SELL_MY_ITEM(entity_player, result, string.Empty, 0);
            return result;
        }

        await QuestManager.It.QuestCheck(entity_player, new QuestItem(EQuestEventTargetType.ITEM, EQuestEventNameType.SOLD, item_id));

        return result;

        async Task<Result> sellItemDelegate() =>
            await sellItemAsync(entity_player, request.ItemGuid, request.Count);
    }

    private async Task<Result> sellItemAsync(Player player, string item_guid, int sell_count)
    {
        var result = new Result();
        string err_msg;
        
        var shop_action = player.getEntityAction<ShopAction>();
        var inventory_action = player.getEntityAction<InventoryActionBase>();

        // 1. 아이템 소유 확인
        var found_item = inventory_action.tryGetItemByItemGuid(item_guid);
        if (null == found_item)
        {
            err_msg = $"Failed to find item : {item_guid}";
            result.setFail(ServerErrorCode.NotFoundItem, err_msg);
            Log.getLogger().error(err_msg);
            return result;
        }
        
        var found_attribute = found_item.getEntityAttribute<ItemAttributeBase>();
        NullReferenceCheckHelper.throwIfNull(found_attribute, () => $"found_attribute is null !!!");

        // 2. 아이템 판매 조건 체크
        result = shop_action.checkItemSellConditionAsync(found_attribute, sell_count);
        if (result.isFail()) return result;
        
        // 3. 아이템 삭제
        (result, var delete_item) = await inventory_action.tryDeleteItemByGuid(item_guid, (ushort)sell_count);
        if (result.isFail())
        {
            err_msg = $"Failed to tryDeleteItem() !!! : {result.toBasicString()} - {item_guid} - {sell_count}";
            Log.getLogger().error(err_msg);
            return result;
        }
        
        var delete_item_attribute = delete_item?.getEntityAttribute<UserItemAttribute>();
        if (null == delete_item_attribute)
        {
            err_msg = $"Failed to get item attribute : {nameof(UserItemAttribute)}";
            result.setFail(ServerErrorCode.EntityAttributeIsNull, err_msg);
            Log.getLogger().error(err_msg);
            return result;
        }
        
        // 4. 재화 지급
        // 4-1. item data 가져오기
        var check_item = ShopHelper.checkItemIdFromTableData((int)delete_item_attribute.ItemMetaId);
        if (check_item.result.isFail() || null == check_item.item_data)
        {
            Log.getLogger().error(check_item.result.ResultString);
            return check_item.result;
        }
        
        // 4-2. 재화 지급
        var money_action = player.getEntityAction<MoneyAction>();

        var check_currency_type = ShopHelper.checkCurrencyTypeFromCurrencyId(check_item.item_data.SellId);
        if (check_currency_type.result.isFail()) return check_currency_type.result;
        
        result = await money_action.changeMoney(check_currency_type.currencyType, sell_count * check_item.item_data.SellPrice);
        if (result.isFail()) return result;

        // 5. sold list 의 item 수정
        var sold_action = shop_action.getSolProductAction();
        var item_doc = delete_item_attribute.makeDocBase();

        var attrib = item_doc.getAttrib<ItemAttrib>();
        NullReferenceCheckHelper.throwIfNull(attrib, () => $"attrib is null !!!");

        attrib.ItemStackCount = (ushort)sell_count;
        result = await sold_action.setSoldProduct(delete_item_attribute.ItemGuid, item_doc);
        if (result.isFail()) return result;
        
        // 6. DB 갱신
        var batch = new QueryBatchEx<QueryRunnerWithDocument>( player, LogActionType.ShopSell, GameServerApp.getServerLogic().getDynamoDbClient());
        batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner());
        batch.addQuery(new QueryFinal());

        result = await QueryHelper.sendQueryAndBusinessLog(batch);
        if (result.isFail()) return result;

        send_S2C_ACK_SELL_MY_ITEM(player, result, item_guid, delete_item_attribute.ItemStackCount);
        
        return result;
    }
}