using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;


using Newtonsoft.Json;
using Google.Protobuf.WellKnownTypes;


using ServerCore; using ServerBase;
using ServerCommon;


using MetaAssets;


namespace GameServer;

public class DBQAcceptQuest : QueryExecutorBase
{
    private string m_my_combination_key_for_pk = string.Empty;
    private UInt32 m_my_combination_key_for_sk = 0;
    private AcceptQuestVariable m_accept_quest_var = new();

    private QuestDoc? m_quest_doc_nullable = null;
    private QuestMailDoc? m_quest_mail_doc_nullable = null;

    private string m_quest_pk = string.Empty;
    private string m_quest_mail_pk = string.Empty;

    public DBQAcceptQuest(string myGuid, AcceptQuestVariable acceptQuestVar) 
        : base(typeof(DBQAcceptQuest).Name)
    {
        m_my_combination_key_for_pk = myGuid;
        m_accept_quest_var = acceptQuestVar;

        var quest_base_info = acceptQuestVar.m_quest_base_info_nullable;

        NullReferenceCheckHelper.throwIfNull(quest_base_info, () => $"quest_base_info is null !!!");

        m_my_combination_key_for_sk = quest_base_info.QuestId;
    }

    //===================================================================================================
    // DB 쿼리 직전에 준비해야 할 로직들을 작성한다.
    //===================================================================================================
    public override Task<Result> onPrepareQuery()
    {
        NullReferenceCheckHelper.throwIfNull(m_accept_quest_var.m_quest_base_info_nullable, () => "m_accept_quest_var.m_quest_base_info_nullable is null !!!");
        NullReferenceCheckHelper.throwIfNull(m_accept_quest_var.m_new_quest_nullable, () => "m_accept_quest_var.m_new_quest_nullable is null !!!");

        var result = new Result();

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

        var user_guid = player.getUserGuid();
        var quest_id = m_accept_quest_var.m_quest_base_info_nullable.QuestId;
        var quest = m_accept_quest_var.m_new_quest_nullable;

        var questAttribute = quest.getEntityAttribute<QuestAttribute>();
        NullReferenceCheckHelper.throwIfNull(questAttribute, () => "questAttribute is null !!!");

        m_quest_doc_nullable = questAttribute.m_quest_doc_nullable;
        NullReferenceCheckHelper.throwIfNull(m_quest_doc_nullable, () => "m_quest_doc_nullable is null !!!");

        m_quest_doc_nullable.setCombinationKeyForPKSK(m_my_combination_key_for_pk, m_my_combination_key_for_sk.ToString());

        var quest_error = m_quest_doc_nullable.onApplyPKSK();
        var mail_error = ServerErrorCode.Success;
        
        if (m_accept_quest_var.m_is_mail_quest)
        {
            m_quest_mail_doc_nullable = new QuestMailDoc(user_guid, quest_id, 0);
            m_quest_mail_doc_nullable.setCombinationKeyForPKSK(m_my_combination_key_for_pk, m_my_combination_key_for_sk.ToString());
            mail_error = m_quest_mail_doc_nullable.onApplyPKSK();
        }

        if (quest_error.isFail() || mail_error.isFail())
        {
            var err_msg = $"Failed to onApplyPKSK() !!! quest_error : {quest_error.toBasicString()},  mail_error : {mail_error.toBasicString()} - {player.toBasicString()}";
            result.setFail(quest_error, err_msg);
            Log.getLogger().error(err_msg);
            return Task.FromResult(result);
        }
        
        m_quest_pk = m_quest_doc_nullable.getPK();
        
        if (m_accept_quest_var.m_is_mail_quest)
        {
            NullReferenceCheckHelper.throwIfNull(m_quest_mail_doc_nullable, () => "m_quest_mail_doc_nullable is null !!!");

            m_quest_mail_pk = m_quest_mail_doc_nullable.getPK();
        }
        return Task.FromResult(result);
    }


    //===================================================================================================
    // onPrepareQuery()를 성공할 경우 호출된다.
    //===================================================================================================
    public override async Task<Result> onQuery()
    {
        NullReferenceCheckHelper.throwIfNull(m_quest_doc_nullable, () => "m_quest_doc_nullable is null !!!");
        NullReferenceCheckHelper.throwIfNull(m_quest_mail_doc_nullable, () => "m_quest_mail_doc_nullable is null !!!");

        var result = new Result();

        var owner = getOwner();
        NullReferenceCheckHelper.throwIfNull(owner, () => "owner is null !!!");

        var query_batch = getQueryBatch();
        NullReferenceCheckHelper.throwIfNull(query_batch, () => $"query_batch is null !!!");

        var db_connector = query_batch.getDynamoDbConnector();

        var ctxs = new List<DynamoDbDocumentQueryContext>();

        (result, var quest_document) = await m_quest_doc_nullable.onCopyToDocument();
        if (result.isFail())
        {
            var err_msg = $"Failed to onCopyToDocument() !!! : {result.toBasicString()}, m_quest_pk:{m_quest_pk} - {toBasicString()}";
            Log.getLogger().error(err_msg);
            return result;
        }

        var table = db_connector.getTableByDoc<QuestDoc>();
        var quest_docmument_ctx = new DynamoDbDocumentQueryContext(table.TableName, quest_document, QueryType.Insert);
        ctxs.Add(quest_docmument_ctx);

        if (m_accept_quest_var.m_is_mail_quest)
        {
            (result, var mail_document) = await m_quest_mail_doc_nullable.onCopyToDocument();
            if (result.isFail())
            {
                var err_msg = $"Failed to onCopyToDocument() !!! : {result.toBasicString()}, m_quest_mail_pk:{m_quest_mail_pk} - {toBasicString()}";
                Log.getLogger().error(err_msg);
                return result;
            }

            var quest_mail_docmument_ctx = new DynamoDbDocumentQueryContext(table.TableName, mail_document, QueryType.Delete);
            ctxs.Add(quest_mail_docmument_ctx);
        }

        (result, _) = await table.simpleTransactWriteWithDocument(ctxs, 2, query_batch.getTransId());
        if (result.isFail())
        {
            var err_msg = $"Failed to simpleTransactWriteWithDocument() !!! : {result.toBasicString()}, m_quest_pk:{m_quest_pk}, m_quest_mail_pk:{m_quest_mail_pk} - {toBasicString()}";
            Log.getLogger().error(err_msg);
        }

        return result;
    }


    //===================================================================================================
    // DB 쿼리를 성공하고, doFnCommit()가 QueryResultType.NotCalledQueryFunc를 반환할 경우 호출된다.
    //===================================================================================================
    public override Task onQueryResponseCommit()
    {
        NullReferenceCheckHelper.throwIfNull(m_accept_quest_var.m_new_quest_nullable, () => "m_accept_quest_var.m_new_quest_nullable is null !!!");
        NullReferenceCheckHelper.throwIfNull(m_accept_quest_var.m_quest_base_info_nullable, () => "m_accept_quest_var.m_quest_base_info_nullable is null !!!");

        //여기서 메모리 업데이트
        var owner = getOwner();
        NullReferenceCheckHelper.throwIfNull(owner, () => "owner is null !!!");

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

        var quests = quest_action.getQuests();
        var quest_meta = m_accept_quest_var.m_quest_base_info_nullable;
        NullReferenceCheckHelper.throwIfNull(quest_meta, () => "quest_meta is null !!!");

        var quest_type = EnumHelper.convertEnumTypeAndValueStringToEnum(quest_meta.QuestType, EQuestType.NORMAL);

        if (false == quests.TryAdd((quest_type, quest_meta.QuestId), m_accept_quest_var.m_new_quest_nullable))
        {
            var err_msg = $"new quest try add fail QuestId = {m_accept_quest_var.m_quest_base_info_nullable.QuestId}, quests = {JsonConvert.SerializeObject(quests)} - {toBasicString()}";
            Log.getLogger().error(err_msg);
        }

        return Task.CompletedTask;
    }


    //===================================================================================================
    // DB 쿼리를 실패하고, doFnRollback()가 QueryResultType.NotCalledQueryFunc를 반환할 경우 호출된다.
    //===================================================================================================
    public override Task onQueryResponseRollback(Result errorResult)
    {
        return Task.CompletedTask;
    }

    private new Player? getOwner() => getQueryBatch()?.getLogActor() as Player;
}