using System.Collections.Concurrent;


using ServerCore; using ServerBase;
using ServerCommon;


using MetaAssets;


using UGQDatabase.Models;


using static ClientToGameRes.Types;
using Org.BouncyCastle.Asn1.Ocsp;


namespace GameServer;

public class UgqTestAction : EntityActionBase
{
    private Lazy<ConcurrentDictionary<(UInt32, UInt32), QuestMetaAllBaseInfo>> m_ugq_test_quest_data = new Lazy<ConcurrentDictionary<(UInt32, UInt32), QuestMetaAllBaseInfo>>();

    public UgqTestAction(EntityBase owner) 
        : base(owner)
    {}

    public override void onClear()
    {
        return;
    }

    public override async Task<Result> onInit()
    {
        await Task.CompletedTask;
        var result = new Result();
        return result;
    }

    public async Task<(Result, GS2C_ACK_UGQ_TEST_ASSIGN?)> ugqTestAssign(UInt32 questId, UInt32 questRevision)
    {
        //Ugq 정보 호출해서 가져온다. questID로만 가져와서 처리 
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();

        GS2C_ACK_UGQ_TEST_ASSIGN ack = new();

        var ugq_api_manager = server_logic.GetUqgApiManager();
        var user_guid = player.getUserGuid();

        var ugq_info_action = player.getEntityAction<UgqInfoAction>();
        NullReferenceCheckHelper.throwIfNull(ugq_info_action, () => $"ugq_info_action is null !!! - {player.toBasicString()}");

        (var result, var quest_meta_all_base_info) = await QuestMetaManager.It.getQuestMeta(player, questId, questRevision, QuestContentState.Test);
        if (result.isFail()) return (result, null);


        var game_quest_data = quest_meta_all_base_info.m_quest_data_entity;
        var quest_base_info = quest_meta_all_base_info.m_quest_base_info;

        if (result.isFail())
        {
            var err_msg = $"Test UgqData Not Exist uger_guid : {user_guid}, questId : {questId}, revision : {questRevision}";
            Log.getLogger().error(err_msg);
            return (result, null);
        }

        NullReferenceCheckHelper.throwIfNull(game_quest_data, () => $"game_quest_data is null !!! - {player.toBasicString()}");
        NullReferenceCheckHelper.throwIfNull(quest_base_info, () => $"quest_base_info is null !!! - {player.toBasicString()}");

        var new_quest = new ServerCommon.Quest(player, player.getUserGuid());
        var accept_quest_var = new AcceptQuestVariable(quest_base_info, false, new_quest);

        result = await ugqTestQuestAssignAsync(game_quest_data, accept_quest_var);
        if (result.isFail()) return (result, null);

        new_quest = accept_quest_var.m_new_quest_nullable;
        NullReferenceCheckHelper.throwIfNull(new_quest, () => $"new_quest is null !!! - {player.toBasicString()}");

        var quest_action = player.getEntityAction<QuestAction>();
        quest_action.addNewQuest(questId, new_quest);

        return (result, ack);        
    }

    public async Task<Result> ugqTestDelete(UInt32 questId)
    {
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();
        
        var quest_action = player.getEntityAction<QuestAction>();
        NullReferenceCheckHelper.throwIfNull(quest_action, () => $"quest_action is null !!! - {player.toBasicString()}");

        var result = quest_action.getQuest(EQuestType.UGQ, questId, out var quest);
        if (result.isFail())
        {
            return result;
        }
        ArgumentNullReferenceCheckHelper.throwIfNull(quest, () => $"quest is null !!! - {player.toBasicString()}");

        var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
        NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");

        var quest_doc = new QuestDoc(player.getUserGuid(), quest_attribute.QuestId, quest_attribute.UgqInfo.QuestRevision);
        (result, var copy_doc) = await quest_doc.onCopyToDocument();
        if (result.isFail())
        {
            var err_msg = $"Failed to onCopyToDocument() !!! : {result.toBasicString()} - {toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        var dynamo_db_client = server_logic.getDynamoDbClient();
        var table = dynamo_db_client.getTableByDoc<QuestDoc>();

        result = await table.simpleDeleteDocumentsWithBatchWrite([copy_doc]);
        if (result.isFail())
        {
            var err_msg = $"Failed to ugqTestDelete !!! id = {quest_attribute.QuestId}, revision = {quest_attribute.UgqInfo.QuestRevision} - {toBasicString()}";
            result.setFail(ServerErrorCode.DynamoDbDocCopyFailedToDocument, err_msg);
            Log.getLogger().error(err_msg);
            return result;
        }
        result = quest_action.deleteQuest(EQuestType.UGQ, questId);

        return result;
    }

    public async Task<Result> ugqTestDelete(QuestAttribute attribute)
    {
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();
        var quest_action = player.getEntityAction<QuestAction>();

        var dynamo_db_client = server_logic.getDynamoDbClient();

        var result = new Result();

        //(bool ret, var copy_doc) = await attribute.m_quest_doc_nullable.onCopyToDocument();
        //attribute.m_quest_doc_nullable.onApplyPKSK();

        var quest_doc = new QuestDoc(player.getUserGuid(), attribute.QuestId, attribute.UgqInfo.QuestRevision);
        (result, var copy_doc) = await quest_doc.onCopyToDocument();
        if (result.isFail())
        {            
            var err_msg = $"Failed to onCopyToDocument() !!! : {result.toBasicString()} - {toBasicString()}";
            Log.getLogger().error(err_msg);

            return result;
        }
        var table = dynamo_db_client.getTableByDoc<QuestDoc>();

        result = await table.simpleDeleteDocumentsWithBatchWrite([copy_doc]);
        if (result.isFail())
        {
            var err_msg = $"Failed to ugqTestDelete !!! : {result.toBasicString()}, id:{attribute.QuestId}, revision:{attribute.UgqInfo.QuestRevision} - {toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        return result;
    }

    private async Task<Result> ugqTestQuestAssignAsync(GameQuestDataEntity gameQuestData, AcceptQuestVariable acceptQuestVar)
    {
        var result = new Result();

        var server_logic = GameServerApp.getServerLogic();
        var ugq_api_manager = server_logic.GetUqgApiManager();

        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var user_guid = player.getUserGuid();

        var cost = gameQuestData.Cost;
        var account_attribute = player.getEntityAttribute<AccountAttribute>();
        NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");

        //퀘스트 정보 만들어서 저장
        var quest_accept_action = player.getEntityAction<QuestAcceptAction>();
        NullReferenceCheckHelper.throwIfNull(quest_accept_action, () => $"quest_accept_action is null !!! - {player.toBasicString()}");

        result = quest_accept_action.newQuestAssign(ref acceptQuestVar);
        if (result.isFail()) return result;

        ArgumentNullReferenceCheckHelper.throwIfNull(acceptQuestVar, () => $"acceptQuestVar is null !!! - {player.toBasicString()}");
        var new_quest = acceptQuestVar.m_new_quest_nullable;
        ArgumentNullReferenceCheckHelper.throwIfNull(new_quest, () => $"new_quest is null !!! - {player.toBasicString()}");

        var quest_attribute = new_quest.getEntityAttribute<QuestAttribute>();
        NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");

        (result, var new_quest_docbase) = await quest_attribute.toDocBase();
        if (result.isFail()) return result;
        NullReferenceCheckHelper.throwIfNull(new_quest_docbase, () => $"new_quest_docbase is null !!! - {player.toBasicString()}");

        var dynamo_db_client = server_logic.getDynamoDbClient();
        ArgumentNullException.ThrowIfNull(dynamo_db_client, $"dynamo_db_client is null !!!");

        (result, var new_quest_doc) = await new_quest_docbase.onCopyToDocument();
        if (result.isFail())
        {
            var err_msg = $"Failed to onCopyToDocument() !!! : {result.toBasicString()}, id:{quest_attribute.QuestId}, revision:{quest_attribute.UgqInfo.QuestRevision} - {toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        var table = dynamo_db_client.getTableByDoc<QuestDoc>();
        result = await table.simpleUpsertDocumentsWithBatchWrite([new_quest_doc]);
        if (result.isFail())
        {
            var err_msg = $"Failed to simpleUpsertDocumentsWithBatchWrite()  !!! : {result.toBasicString()}, id:{quest_attribute.QuestId}, revision:{quest_attribute.UgqInfo.QuestRevision} - {toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        //batch.appendBusinessLog(new UgqAssignBusinessLog(acceptQuestVar.m_quest_base_info_nullable.QuestId, acceptQuestVar.m_quest_base_info_nullable.QuestRevision));
        //result = await QueryHelper.sendQueryAndBusinessLog(batch);
        //if (result.isFail()) return result;


        return result;
    }

    public async Task<Result> ugqTestAbort(UInt32 questId, UInt32 questRevision)
    {
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();

        var quest_action = player.getEntityAction<QuestAction>();
        NullReferenceCheckHelper.throwIfNull(quest_action, () => $"quest_action is null !!!");

        var result = quest_action.getQuest(EQuestType.UGQ, questId, out var quest);
        if (result.isFail())
        {
            return result;
        }
        ArgumentNullReferenceCheckHelper.throwIfNull(quest, () => $"quest is null !!! - {player.toBasicString()}");

        var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
        NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");

        if (quest_attribute.IsComplete == 1)
        {
            var err_msg = $"can't abort ugq test cause alredy completed player = {player.toBasicString()}, questId = {questId}";
            result.setFail(ServerErrorCode.UgqTestQuestAlreadyCompleted, err_msg);
            Log.getLogger().warn(err_msg);
            return result;
        }

        var fn_transaction_runner = async delegate ()
        {
            var result = new Result();

            var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
            NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");
            quest_attribute.deleteEntityAttribute();

            var batch = new QueryBatchEx<QueryRunnerWithDocument>(player, LogActionType.UgqTestAbort, server_logic.getDynamoDbClient());
            {
                batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner());
            }

            batch.appendBusinessLog(new UgqTestAbortBusinessLog(questId, questRevision));

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

            return result;
        };

        result = await player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "UgqTestAbort", fn_transaction_runner);
        if (result.isFail())
        {
            var err_msg = $"Failed to runTransactionRunnerSafely() !!! : {result.toBasicString()} - {player.toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        result = quest_action.deleteQuest(EQuestType.UGQ, questId);
 
        var ugq_api_manager = server_logic.GetUqgApiManager();
        var account_attribute = player.getEntityAttribute<AccountAttribute>();
        NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");

        var language_type = account_attribute.LanguageType;

        var api_result = await ugq_api_manager.setTestUgqQuestAborted(player.getUserGuid(), questId, questRevision, language_type);
        if (api_result.isFail())
        {
            Log.getLogger().error($"Failed to setTestUgqQuestAborted() !!! : {api_result.toBasicString()} - {player.toBasicString()}");
        }

        return result;
    }

    public async Task<Result> ugqTestComplete(UInt32 questId, UInt32 questRevision)
    {
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();

        var quest_action = player.getEntityAction<QuestAction>();
        NullReferenceCheckHelper.throwIfNull(quest_action, () => $"quest_action is null !!! - {player.toBasicString()}");

        var result = quest_action.getQuest(EQuestType.UGQ, questId, out var quest);
        if (result.isFail())
        {
            return result;
        }
        ArgumentNullReferenceCheckHelper.throwIfNull(quest, () => $"quest is null !!! - {player.toBasicString()}");

        var fn_transaction_runner = async delegate ()
        {
            var result = new Result();

            var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
            NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");

            quest_attribute.deleteEntityAttribute();

            var batch = new QueryBatchEx<QueryRunnerWithDocument>(player, LogActionType.None, server_logic.getDynamoDbClient());
            {
                batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner());
            }

            batch.appendBusinessLog(new UgqTestCompleteBusinessLog(questId, questRevision));

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

            return result;
        };

        result = await player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "UgqTestComplete", fn_transaction_runner);
        if (result.isFail())
        {
            var err_msg = $"Failed to runTransactionRunnerSafely() !!! : {result.toBasicString()} - {player.toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }
        result = quest_action.deleteQuest(EQuestType.UGQ, questId);

        var ugq_api_manager = server_logic.GetUqgApiManager();

        var account_attribute = player.getEntityAttribute<AccountAttribute>();
        NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");

        var language_type = account_attribute.LanguageType;

        var api_result = await ugq_api_manager.setTestUgqQuestCompleted(player.getUserGuid(), questId, questRevision, language_type);
        if(api_result.isFail())
        {
            Log.getLogger().error($"Failed to setTestUgqQuestCompleted() !!! : {api_result.toBasicString()} - {player.toBasicString()}");
        }

        return result;
    }

    public async Task<Result> makeQuestFromTestUgq()
    {
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        var server_logic = GameServerApp.getServerLogic();
        
        var ugq_api_manager = server_logic.GetUqgApiManager();
        var user_guid = player.getUserGuid();

        var account_attribute = player.getEntityAttribute<AccountAttribute>();
        NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");

        var language_type = account_attribute.LanguageType;
        (var result, var user_quests_in_test_state) = await ugq_api_manager.getTestUgqIds(user_guid, language_type);
        if (result.isFail()) return result;
        NullReferenceCheckHelper.throwIfNull(user_quests_in_test_state, () => $"user_quests_in_test_state is null !!! - {player.toBasicString()}");

        var quest_action = player.getEntityAction<QuestAction>();
        NullReferenceCheckHelper.throwIfNull(quest_action, () => $"quest_action is null !!! - {player.toBasicString()}");

        var owned_test_ugqs = quest_action.getTestUgqs();

        HashSet<UInt32> contain_checked_ugq_ids = new();
        foreach (var user_quest_in_test_state in user_quests_in_test_state)
        {
            (var quest_id, var quest_revision) = QuestHelper.convertUgqQuestIdToQuestIdAndRevision(user_quest_in_test_state.ComposedQuestId);
            if (false == owned_test_ugqs.TryGetValue(quest_id, out var owned_test_ugq))
            {
                //없는 테스트 퀘스트니까 만들어줘야된다. 
                (var assing_resul, var ack) = await ugqTestAssign(quest_id, quest_revision);
                continue;
            }
            
            //있는 테스트 퀘스트 리비전 체크
            var quest_attribute = owned_test_ugq.getEntityAttribute<QuestAttribute>();
            NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");

            if (quest_attribute.UgqInfo.QuestRevision != quest_revision)
            {
                //다르면 삭제후 생성
                _= await ugqTestDelete(quest_id);
                _ = await ugqTestAssign(quest_id, quest_revision);
                contain_checked_ugq_ids.Add(quest_id);
                continue;
            }
                
            //기존 퀘스트 가지고 있으니까 체크된 항목에 일던 넣어놓는다.
            contain_checked_ugq_ids.Add(quest_id);
            continue;
        }

        foreach (var contain_quest_id in contain_checked_ugq_ids)
        {
            owned_test_ugqs.Remove(contain_quest_id, out _);
        }

        foreach (var delete_quest_id in owned_test_ugqs)
        {
            _ = await ugqTestDelete(delete_quest_id.Key);
        }

        return result;
    }

    public async Task<(Result, QuestMetaAllBaseInfo)> getUgqGameQuestTestData(UInt32 questId, UInt32 questRevision)
    {        
        var player = getOwner() as Player;
        NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");

        (var result, var game_quest_data) = await UgqMetaHelper.loadTestGameQuestGameDataEntity(player, questId, questRevision);
        if (result.isFail() || game_quest_data is null)
        {
            return (result, null!);
        }

        (result, var generated_quest_base_info) = UgqMetaHelper.generateUgqQuestBaseInfo(game_quest_data);
        if (result.isFail())
        {
            return (result, null!);
        }
        NullReferenceCheckHelper.throwIfNull(generated_quest_base_info, () => $"generated_quest_base_info is null !!! - {player.toBasicString()}");

        var info = new QuestMetaAllBaseInfo(UgqStateType.Test, QuestContentState.Test, generated_quest_base_info, game_quest_data);
        m_ugq_test_quest_data.Value.AddOrUpdate((questId, questRevision), info, (key, oldValue) => info);

        return (result, info);
    }
    
}