#include "BattleProcessTask.h"

#include "Utils/Ranges.hpp"
#include <chrono>
#include <future>
#include <thread>

#include "Utils/NoWarningCV.h"

#include "Config/Miscellaneous/BattleDataConfig.h"
#include "Config/Miscellaneous/CopilotConfig.h"
#include "Config/Miscellaneous/TilePack.h"
#include "Config/TaskData.h"
#include "Controller.h"
#include "Task/ProcessTask.h"
#include "Utils/Algorithm.hpp"
#include "Utils/ImageIo.hpp"
#include "Utils/Logger.hpp"
#include "Vision/MatchImageAnalyzer.h"
#include "Vision/Miscellaneous/BattleImageAnalyzer.h"
#include "Vision/Miscellaneous/BattleSkillReadyImageAnalyzer.h"
#include "Vision/OcrWithPreprocessImageAnalyzer.h"

using namespace asst::battle;
using namespace asst::battle::copilot;

asst::BattleProcessTask::BattleProcessTask(const AsstCallback& callback, Assistant* inst, std::string_view task_chain)
    : AbstractTask(callback, inst, task_chain), BattleHelper(inst)
{}
bool asst::BattleProcessTask::_run()
{
    LogTraceFunction;
    clear();

    if (!calc_tiles_info(m_stage_name)) {
        Log.error("get stage info failed");
        return false;
    }

    load_cache();
    update_deployment(true);
    to_group();

    for (size_t i = 0; i < m_combat_data.actions.size() && !need_exit(); ++i) {
        do_action(i);
    }

    return true;
}

void asst::BattleProcessTask::clear()
{
    BattleHelper::clear();

    m_oper_in_group.clear();
    m_in_bullet_time = false;
}

bool asst::BattleProcessTask::set_stage_name(const std::string& stage_name)
{
    LogTraceFunction;

    if (!BattleHelper::set_stage_name(stage_name)) {
        json::value info = basic_info_with_what("UnsupportedLevel");
        auto& details = info["details"];
        details["level"] = m_stage_name;
        callback(AsstMsg::SubTaskExtraInfo, info);

        return false;
    }

    m_combat_data = Copilot.get_data();

    return true;
}

void asst::BattleProcessTask::load_cache()
{
    LogTraceFunction;

    for (const auto& oper_list : m_combat_data.groups | views::values) {
        for (const auto& oper : oper_list) {
            load_avatar_cache(oper.name, true);
        }
    }
    // TODO: 识别编队，额外加载编队中有的干员的缓存
}

bool asst::BattleProcessTask::to_group()
{
    std::unordered_map<std::string, std::vector<std::string>> groups;
    for (const auto& [group_name, oper_list] : m_combat_data.groups) {
        std::vector<std::string> oper_name_list;
        ranges::transform(oper_list, std::back_inserter(oper_name_list), [](const auto& oper) { return oper.name; });
        groups.emplace(group_name, std::move(oper_name_list));
    }

    std::unordered_set<std::string> char_set;
    for (const auto& oper : m_cur_deployment_opers | views::values) {
        char_set.emplace(oper.name);
    }

    auto result_opt = algorithm::get_char_allocation_for_each_group(groups, char_set);
    if (!result_opt) {
        return false;
    }
    m_oper_in_group = *result_opt;

    std::unordered_map<std::string, std::string> ungrouped;
    const auto& grouped_view = m_oper_in_group | views::values;
    for (const auto& name : char_set) {
        if (ranges::find(grouped_view, name) != grouped_view.end()) {
            continue;
        }
        ungrouped.emplace(name, name);
    }
    m_oper_in_group.merge(ungrouped);

    for (const auto& [group_name, oper_name] : m_oper_in_group) {
        auto& this_group = m_combat_data.groups[group_name];
        auto iter = ranges::find_if(this_group, [&oper_name](const auto& oper) { return oper.name == oper_name; });
        if (iter == this_group.end()) {
            continue;
        }
        m_skill_usage.emplace(oper_name, iter->skill_usage);
    }

    return true;
}

bool asst::BattleProcessTask::do_action(size_t action_index)
{
    const auto& action = m_combat_data.actions.at(action_index);

    notify_action(action);

    if (!wait_condition(action)) {
        return false;
    }
    if (action.pre_delay > 0) {
        sleep_with_use_ready_skill(action.pre_delay);
        // 等待之后画面可能会变化，更新下干员信息
        update_deployment();
    }

    bool ret = false;
    const std::string& name = m_oper_in_group[action.group_name];
    const auto& location = action.location;

    switch (action.type) {
    case ActionType::Deploy:
        ret = deploy_oper(name, location, action.direction);
        if (ret) m_in_bullet_time = false;
        break;

    case ActionType::Retreat:
        ret = m_in_bullet_time ? click_retreat() : (location.empty() ? retreat_oper(location) : retreat_oper(name));
        if (ret) m_in_bullet_time = false;
        break;

    case ActionType::UseSkill:
        ret = m_in_bullet_time ? click_skill() : (location.empty() ? use_skill(location) : use_skill(name));
        if (ret) m_in_bullet_time = false;
        break;

    case ActionType::SwitchSpeed:
        ret = speed_up();
        break;

    case ActionType::BulletTime:
        ret = enter_bullet_time_for_next_action(action_index + 1, location, name);
        if (ret) m_in_bullet_time = true;
        break;

    case ActionType::SkillUsage:
        m_skill_usage[action.group_name] = action.modify_usage;
        ret = true;
        break;

    case ActionType::Output:
        // DoNothing
        ret = true;
        break;

    case ActionType::SkillDaemon:
        ret = wait_for_end();
        break;
    }

    sleep_with_use_ready_skill(action.post_delay);

    return ret;
}

void asst::BattleProcessTask::notify_action(const battle::copilot::Action& action)
{
    const static std::unordered_map<ActionType, std::string> ActionNames = {
        { ActionType::Deploy, "Deploy" },           { ActionType::UseSkill, "UseSkill" },
        { ActionType::Retreat, "Retreat" },         { ActionType::SkillDaemon, "SkillDaemon" },
        { ActionType::SwitchSpeed, "SwitchSpeed" }, { ActionType::SkillUsage, "SkillUsage" },
        { ActionType::BulletTime, "BulletTime" },   { ActionType::Output, "Output" },
    };

    json::value info = basic_info_with_what("CopilotAction");
    info["details"] |= json::object {
        { "action", ActionNames.at(action.type) },
        { "target", action.group_name },
        { "doc", action.doc },
        { "doc_color", action.doc_color },
    };
    callback(AsstMsg::SubTaskExtraInfo, info);
}

bool asst::BattleProcessTask::wait_condition(const Action& action)
{
    // 计算初始状态
    int cost_base = -1;
    // int cooling_base = -1;

    if (action.cost_changes != 0) {
        BattleImageAnalyzer analyzer(ctrler()->get_image());
        analyzer.set_target(BattleImageAnalyzer::Target::Cost);
        if (analyzer.analyze()) {
            cost_base = analyzer.get_cost();
        }
    }
    // if (action.cooling != 0) {
    //     BattleImageAnalyzer analyzer(image);
    //     analyzer.set_target(BattleImageAnalyzer::Target::Oper);
    //     if (analyzer.analyze()) {
    //         cooling_base =
    //             ranges::count_if(analyzer.get_opers(), [](const auto& oper) -> bool { return oper.cooling; });
    //     }
    // }

    // 计算击杀数
    while (!need_exit() && m_kills < action.kills) {
        BattleImageAnalyzer analyzer(ctrler()->get_image());
        if (m_total_kills) {
            analyzer.set_pre_total_kills(m_total_kills);
        }
        analyzer.set_target(BattleImageAnalyzer::Target::Kills);
        if (analyzer.analyze()) {
            m_kills = analyzer.get_kills();
            m_total_kills = analyzer.get_total_kills();
            if (m_kills >= action.kills) {
                break;
            }
        }
        use_all_ready_skill();
    }

    // 计算费用变化量
    if (action.cost_changes != 0 || action.costs) {
        while (!need_exit()) {
            BattleImageAnalyzer analyzer(ctrler()->get_image());
            analyzer.set_target(BattleImageAnalyzer::Target::Cost);
            if (analyzer.analyze()) {
                int cost = analyzer.get_cost();
                if (cost_base == -1) {
                    cost_base = cost;
                    continue;
                }
                if (action.cost_changes != 0) {
                    if ((cost_base + action.cost_changes < 0) ? (cost <= cost_base + action.cost_changes)
                                                              : (cost >= cost_base + action.cost_changes)) {
                        break;
                    }
                }
                if (action.costs && cost >= action.costs) {
                    break;
                }
            }
            use_all_ready_skill();
        }
    }

    // 计算有几个干员在cd
    if (action.cooling >= 0) {
        while (!need_exit()) {
            BattleImageAnalyzer analyzer(ctrler()->get_image());
            analyzer.set_target(BattleImageAnalyzer::Target::Oper);
            if (analyzer.analyze()) {
                int cooling_count = static_cast<int>(
                    ranges::count_if(analyzer.get_opers(), [](const auto& oper) -> bool { return oper.cooling; }));
                if (cooling_count == action.cooling) {
                    break;
                }
            }
            use_all_ready_skill();
        }
    }

    // 部署干员还有额外等待费用够或 CD 转好
    if (!m_in_bullet_time && action.type == ActionType::Deploy) {
        const std::string& name = m_oper_in_group[action.group_name];
        while (!need_exit()) {
            update_deployment();
            if (auto iter = m_cur_deployment_opers.find(name);
                iter != m_cur_deployment_opers.cend() && iter->second.available) {
                break;
            }
            use_all_ready_skill();
        }
    }

    return true;
}

bool asst::BattleProcessTask::enter_bullet_time_for_next_action(size_t next_index, const Point& location,
                                                                const std::string& name)
{
    LogTraceFunction;

    if (next_index > m_combat_data.actions.size()) {
        Log.error("Bullet time does not have the next step!");
        return false;
    }
    const auto& next_action = m_combat_data.actions.at(next_index);

    bool ret = false;
    switch (next_action.type) {
    case ActionType::Deploy:
        ret = click_oper_on_deployment(name);
        break;

    case ActionType::UseSkill:
    case ActionType::Retreat:
        ret = location.empty() ? click_oper_on_battlefiled(location) : click_oper_on_battlefiled(name);
        break;

    default:
        Log.error("Bullet time 's next step is not deploy, skill or retreat!");
        return false;
    }

    return true;
}

void asst::BattleProcessTask::sleep_with_use_ready_skill(unsigned millisecond)
{
    LogTraceScope(__FUNCTION__ + std::to_string(millisecond));

    using namespace std::chrono_literals;
    const auto start = std::chrono::steady_clock::now();
    const auto delay = millisecond * 1ms;

    while (!need_exit() && std::chrono::steady_clock::now() - start < delay) {
        use_all_ready_skill();
        std::this_thread::yield();
    }
}