#ifndef __DISPATCH_COMMAND_HH__ #define __DISPATCH_COMMAND_HH__ #include "../tool/singleton.h" #include "../tool/thread_condition.h" #include "../error_code/error_code.h" #include "../dispatch/database_controller.h" #include "../message/message.pb.h" #include "../tool/common_data.h" #include #include #include //调度指令模块, 主要是与数据库的表 command_queue 同步, 然后按照一定的策略 class Dispatch_command { public: //调度指令模块 的状态 enum Dispatch_command_status { E_DISPATCH_COMMAND_UNKNOW = 0, //未知 E_DISPATCH_COMMAND_READY = 1, //准备,待机 E_DISPATCH_COMMAND_BUSY = 2, //工作正忙 E_DISPATCH_COMMAND_DISCONNECT = 3, //断连 E_DISPATCH_COMMAND_FAULT = 100, //故障 }; //调度指令, 格式和数据库的 command_queue 保持一致 struct Dispatch_command_info { std::string m_car_number; //车牌号 std::string m_primary_key; //唯一码 int m_unit; //单元号, 1~3 int m_queue_id; //排序的id, 从0开始递增 int m_type; //指令类型, 0无效, 1存车, 2取车, int m_statu; //指令状态, 0排队中, 1正在工作, 2已完成, 3故障异常 std::string m_space_info; //车位信息的DebugString, 默认没有, 存车要根据感测信息的车高去申请车位, 取车根据车牌号找车位 parkspace_info m_parkspace_info_msg; //车位信息的proto格式 std::string m_measure_info; //感测信息的DebugString, 里面自带车高, 小1.5 中1.7 大1.9, measure_info m_measure_info_msg; //感测信息的proto格式 int m_export_id; //出入口id, 1~6 int m_useless_distance; //空跑的路程, }; //调度车位信息, 格式和数据库的 space 保持一致 struct Dispatch_space_info { int m_id; //车位id int m_floor; //车位楼层 int m_subID; //层内id float m_height; //车位高度, 小1.55 中1.75 大2.2, std::string m_car_number; //车牌号 int m_unit; //单元号, 1~3 int m_statu; //车位状态, 0可用, 1故障 }; //调度车辆信息, 格式和数据库的 vehicle 保持一致 struct Dispatch_vehicle_info { std::string m_car_number; //车牌号 std::string m_primary_key; //唯一码 std::string m_actually_measure_info; //感测信息的DebugString, 里面自带车高, 小1.5 中1.7 大1.9, measure_info m_actually_measure_info_msg; //感测信息的proto格式 }; public: Dispatch_command(); Dispatch_command(const Dispatch_command& other)= default; Dispatch_command& operator =(const Dispatch_command& other)= default; ~Dispatch_command(); public://API functions //调度开始前, 向数据库发送请求的相关操作, 输入 穿梭机所在的楼层, 调度id 0~2, 空闲出口id, 如果不是0,就表示有空闲的出口 Error_manager dispatch_request_to_sql(int plc_floor, int dispatch_id, int outlet_ready); //调度完成后, 向数据库发送答复的相关操作 Error_manager dispatch_response_to_sql(Error_manager error); //调度 , 向数据库 重新分配车位, Error_manager dispatch_reallocate_to_sql(Common_data::Car_type reallocate_car_type, int outlet_ready); //检查出口是否空闲, 检查指令队列的取车完成的出口id是否存在, 不存在就是空闲,返回成功 Error_manager check_export_id_is_ready(int export_id); public://get or set member variable protected://member functions //获取调度指令, 与数据库同步 command_queue Error_manager query_all_dispatch_command(); //对调度指令进行排序, 选出最优解, 比较存车和取车 Error_manager sort_dispatch_command_for_total(); //对调度指令进行排序, 选出最优解, 只比较存车 Error_manager sort_dispatch_command_for_park(); //获取 指定车高 指定单元 的车位信息,用于车位分配, 找不到就会报错, Error_manager query_specify_height_unit_parkspace_info(int unit, float height, Dispatch_space_info & dispatch_space_info); //查询空闲车位最优解, 存车指令 根据调度指令最优解 获取 空闲车位最优解 Error_manager query_dispatch_space_optimal(); //查询空闲车位最优解, 存车指令 根据调度指令最优解 获取 空闲车位最优解 Error_manager query_dispatch_space_optimal(Common_data::Car_type reallocate_car_type); //查询 取车的车位 取车指令 根据车牌号 查询对应的车位 Error_manager query_dispatch_space_for_car_number(); //查询 取车的车辆感测信息 取车指令 根据key 查询感测信息 Error_manager query_dispatch_vehicle_for_primary_key(); //更新 车位状态, 根据车位ID 修改车牌号即可, Error_manager update_parkspace_info_write_car_number(); //更新 车位状态, 找到车牌号, 写NULL Error_manager update_parkspace_info_clear_car_number(); //更新 指令队列, 根据车牌号 修改状态即可, //指令状态, 0排队中, 1正在工作, 2已完成, 3故障异常 Error_manager update_command_queue_for_statu(int statu); //更新 指令队列, 根据车牌号 修改状态即可, //指令状态, 0排队中, 1正在工作, 2已完成, 3故障异常 // Error_manager update_command_queue_for_statu(int statu, std::string error_description); //更新 指令队列, 根据车牌号 删除指令 Error_manager delete_command_queue_for_statu(); //制作存车表单 Error_manager create_park_table(); //制作取车表单 Error_manager create_pick_table(int outlet_ready); //增加 车辆表, 存车指令 完成后添加车辆信息 Error_manager insert_vehicle_for_car_number(); //删除 车辆表, 取车指令 完成后删除车辆信息 Error_manager delete_vehicle_for_car_number(); protected://member variable public: Dispatch_command_status m_dispatch_command_status; //调度指令模块 的状态 std::mutex m_lock; // 锁. int m_dispatch_id; //调度id, 0-2 int m_unit; //单元号 int m_device_floor; //穿梭机所在的楼层, 存车完在对应的车位楼层, 取车完在1楼 int m_outlet_ready; //取车空闲出口id, 0表示没有出口, 1~6表示空闲出口 std::map m_dispatch_command_map; //调度指令map, 数据库的所有信息 std::string m_car_number_optimal; //调度指令最优解 Dispatch_space_info m_dispatch_space_info; //调度车位最优解 Dispatch_vehicle_info m_dispatch_vehicle_info; //调度车位最优解 Common_data::Dispatch_process_type m_dispatch_process_type ; //调度流程类型 park_table m_park_table_msg; //停车表单 pick_table m_pick_table_msg; //取车表单 Common_data::Car_type m_car_type; //车的大小 private: }; #endif // __DISPATCH_COMMAND_HH__