Terminal_process_CT/exception/exception_solver.cpp

//
// Created by zx on 2020/8/20.
//

#include "exception_solver.h"
#include "command_manager.h"
#include "communication_message.h"
#include <glog/logging.h>

Exception_solver::Exception_solver() {

}
Exception_solver::~Exception_solver() {

}

Error_manager Exception_solver::add_task_cancel_condition(std::string license,Process_task* task)
{
    if(m_ptask_map.find(license)==true || task== nullptr)
    {
        return Error_manager(ERROR,MINOR_ERROR,"任务标识已存在,或者标识地址为null");
    }
    m_ptask_map[license]=task;
    return SUCCESS;
}

Error_manager Exception_solver::delete_task_cancel_condition(std::string license)
{
    if(m_ptask_map.find(license)==true)
    {
        m_ptask_map.erase(license);
        return SUCCESS;
    }
    return Error_manager(ERROR,MINOR_ERROR,"任务取消标志不存在");
}

Error_manager Exception_solver::consume_msg(Communication_message* p_msg)
{
    if(p_msg== nullptr)
        return Error_manager(POINTER_IS_NULL,CRITICAL_ERROR,"dispatch response msg pointer is null");


    switch (p_msg->get_message_type())
    {
        case Communication_message::eProcess_manual_operation_msg:
        {
            message::Process_manual_operation_msg msg;
            if(msg.ParseFromString(p_msg->get_message_buf())==false)
            {
                LOG(ERROR)<<"  手动消息解析失败  !!!";
                break;
            }
            if(msg.has_license()==false)
            {
                LOG(ERROR)<<"  手动消息解析失败  !!!";
                break;
            }
            LOG(INFO)<<"接收到手动消息//////////////////////////  : "<<msg.license();
            m_manual_msg_map[msg.license()]=msg;
            break;
        }
        case Communication_message::eEntrance_manual_operation_msg:
        {
            message::Entrance_manual_operation_msg msg;
            if(msg.ParseFromString(p_msg->get_message_buf())==false)
            {
                LOG(ERROR)<<"  手动消息解析失败  !!!";
                break;
            }
            LOG(INFO)<<" communication 接收到手动消息  : "<<msg.GetTypeName();
            switch (msg.process_type())
            {
                case message::eStoring:
                {
                    Command_manager::get_instance_pointer()->pause_entrance(msg.terminal_id(),msg.paused());
                    break;
                }
                case message::ePicking:
                {
                    Command_manager::get_instance_pointer()->pause_export(msg.terminal_id(),msg.paused());
                    break;
                }
            }
            break;
        }

        default:break;
    }
    return SUCCESS;
}


/*
     * 等待手动消息
     */
Error_manager Exception_solver::waitfor_manual_operate_msg(Process_task* task,message::Process_manual_operation_msg& msg)
{
    //清除旧的手动操作消息
    if(m_manual_msg_map.find(task->license()))
        m_manual_msg_map.erase(task->license());
    //监控新的手动操作消息
    while(task->is_canceled()==false)
    {
        if(m_manual_msg_map.find(task->license(),msg))
        {
            if(msg.has_base_info() && msg.has_license() && msg.has_operate_type() && msg.has_step_type())
            {
                if(msg.license()==task->license()&& msg.step_type()==task->current_step_type()) {
                    LOG(INFO) << " 查询到: " << task->license()<<"  操作类型:"<<Process_operation_type_Name(msg.operate_type());
                    return SUCCESS;
                }
                else
                {
                    LOG(WARNING)<<"xxxx .. ..  非当前步骤的手动操作 车牌: "<<msg.license()<<", 操作步骤:"<<Step_type_Name(msg.step_type());
                    m_manual_msg_map.erase(task->license());
                }
            }
        }
    }
    return TASK_CANCEL;
}

/*
     * 处理故障
     */
Error_manager Exception_solver::solve_exception(Error_manager code,Process_task* task)
{
    Error_manager code_operate;
    if(code.get_error_level()==MAJOR_ERROR)
    {
        //四级故障,任务未完成, 且模块未能回退并恢复到初始待机状态
        //关闭出入口
        if(task->get_process_type()==message::eStoring) {
            Command_manager::get_instance_pointer()->pause_entrance(task->terminal_id(),true);
            LOG(ERROR)<<"关闭入口:"<<task->terminal_id()<<"   故障  !!!!!!  等待手动操作 ... ";
            message::Process_manual_operation_msg operate_msg;
            code_operate=waitfor_manual_operate_msg(task,operate_msg);
            if(code_operate!=SUCCESS)
                return code_operate;
            switch (operate_msg.operate_type())
            {
                //取消任务
                case message::eManual_cancel:
                {
                    LOG(INFO) << "手动消息 ,车牌号  : " << task->license()<<"  操作类型:"<<Process_operation_type_Name(operate_msg.operate_type());
                    task->Cancel();
                    break;
                }
                case message::eManual_retry:{
                    LOG(INFO) << "手动消息 ,车牌号  : " << task->license()<<"  操作类型:"<<Process_operation_type_Name(operate_msg.operate_type());
                    break;
                }
                case message::eManual_ignore:
                {
                    LOG(INFO) << "手动消息 ,车牌号  : " << task->license()<<"  操作类型:"<<Process_operation_type_Name(operate_msg.operate_type());
                    task->next_step();
                    break;
                }
            }



        }
        if(task->get_process_type()==message::ePicking) {
            Command_manager::get_instance_pointer()->pause_export(task->terminal_id(),true);
            LOG(ERROR)<<"关闭出口:"<<task->terminal_id()<<"   四级故障  !!!!!!  等待手动操作 ...";
            message::Process_manual_operation_msg operate_msg;
            code_operate=waitfor_manual_operate_msg(task,operate_msg);
            if(code_operate!=SUCCESS)
                return code_operate;
        }

        //系统急停
        //Command_manager::get_instance_pointer()->pause_system();

    }
    if(code.get_error_level()<=MAJOR_ERROR)
    {
        //三级故障, 任务未完成,已恢复到待机状态
        return SUCCESS;
    }

    switch(code.get_error_code())
    {
        case ERROR:
        {
            break;
        }
    }
    return SUCCESS;
}