CT_project/plc调度节点/dispatch/dispatch_command.h

#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 <string>
#include <map>
#include <glog/logging.h>



//调度指令模块, 主要是与数据库的表 command_queue 同步, 然后按照一定的策略
class Dispatch_command
{
public:
#define PARK_TIME_FLAG	101		//存车时间标记, 用于记录时差
#define PICK_TIME_FLAG	102		//取车时间标记, 用于记录时差



	//调度指令模块 的状态
	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格式
		std::string							m_plc_measure_info;					//plc感测信息的DebugString, 里面自带车高, 小1.5  中1.7  大1.9,
		measure_info						m_plc_measure_info_msg;				//plc感测信息的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);
	//检查出口取车是否完成, 指定的出口有取车完成指令就返回成功, 否则报错.
	Error_manager check_pickup_is_finish(int export_id);
	//检查入口存车是否开始, 指定的入口有存车开始指令就返回成功, 否则报错.
	Error_manager check_park_is_start(int import_id);
	//获取指定入口的 存车流程的 唯一码,
	Error_manager get_primary_key_for_store(int import_id, std::string & primary_key );

	//删除 指令队列, 根据出口编号
	Error_manager delete_command_queue_for_export_id(int export_id);

	//添加plc数据储存
	Error_manager insert_plc_data(std::string plc_data, float hearbeat);
public://get or set member variable

protected://member functions

	//获取调度指令, 与数据库同步 command_queue, statu指令状态, 0:排队等待, 1正在运行, 2:已经完成
	Error_manager query_all_dispatch_command(int statu);

	//对调度指令进行排序, 选出最优解, 比较存车和取车
	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();
	//查询 取车的车辆plc感测信息    取车指令 根据key 查询感测信息
	Error_manager query_dispatch_vehicle_for_primary_key_ex();

	//更新 车位状态, 根据车位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 select_vehicle_for_car_number();
	//增加 车辆表, 存车指令 完成后添加车辆信息
	Error_manager insert_vehicle_for_car_number();
	//20230213 huli  add plc car_wheel_base
	Error_manager insert_vehicle_for_car_number_ex();
	//增加 车辆表, 存车指令 完成后添加车辆信息, park_statu停车状态, 0:不存在, 1:存车中, 2:取车中, 3:在楼上存车
	Error_manager updata_vehicle_for_car_number(int park_statu);
	//删除 车辆表, 取车指令 完成后删除车辆信息
	Error_manager delete_vehicle_for_car_number();

	//增加 记录表, 存车指令 完成后添加存车记录
	Error_manager insert_record_for_park_start();
	//增加 记录表, 存车指令 完成后添加存车记录
	Error_manager updata_record_for_park_end();
	//更新 记录表, 取车指令 完成后更新取车记录
	Error_manager updata_record_for_pick_start();
	//更新 记录表, 取车指令 完成后更新取车记录
	Error_manager updata_record_for_pick_end();
	//更新 记录表, 取车指令 完成后更新取车记录, 撤销指令, 没有取车时间差
	Error_manager updata_record_for_pick_end_ex();

	//计算汽车在车库的存车时间, 从存车开始到取车结束, 返回 parking_time, 单位秒.
	Error_manager get_parking_time(std::string primary_key, int & parking_time );

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<std::string, Dispatch_command_info>	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__