dispatch_process.h 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228
  1. /*
  2. dispatch_source 和 dispatch_destination 的表示含义
  3. 1~165 2楼~12楼的停车位
  4. 1100 0号出口(在一楼)(目前没有)
  5. 1101~1106 1~6号出入口 (在一楼)
  6. 1107 7号出口(在一楼)
  7. 1201~1206 1~6号出入口上方2楼处
  8. 1301~1306 1~6号出入口上方3楼处
  9. 1401~1406 1~6号出入口上方4楼处
  10. 2101~2112 左侧电梯井(1楼~12楼)(一号搬运器的待机点)
  11. 2201~2212 右侧电梯井(1楼~12楼)(二号搬运器的待机点)
  12. */
  13. #ifndef NNXX_TESTS_DISPATCH_PROCESS_H
  14. #define NNXX_TESTS_DISPATCH_PROCESS_H
  15. #include <error_code.h>
  16. #include "../tool/thread_condition.h"
  17. #include "../tool/TaskQueue/BaseTask.h"
  18. #include "../tool/common_data.h"
  19. #include <glog/logging.h>
  20. #include "../dispatch/carrier.h"
  21. #include "../dispatch/catcher.h"
  22. #include "../dispatch/passageway.h"
  23. #include "../dispatch/dispatch_coordinates.h"
  24. #include "../message/dispatch_message.pb.h"
  25. #include "../message/dispatch_control.pb.h"
  26. #include "../tool/point3D_tool.h"
  27. //调度流程 存车
  28. class Dispatch_process : public tq::BaseTask
  29. {
  30. public:
  31. //调度指令超时时间 300000ms = 5min
  32. #define DISPATCH_PROCESS_TIMEOUT_MS 300000
  33. //调度指令超时时间 衰减值 在原有的基础上减少30秒
  34. #define DISPATCH_PROCESS_ATTENUATION_TIMEOUT_MS 30000
  35. //调度流程的状态, 控制步骤
  36. enum Dispatch_process_status
  37. {
  38. DISPATCH_PROCESS_STATUS_UNKNOW = 0, //未知
  39. DISPATCH_PROCESS_CREATED = 1, //流程创建,
  40. DISPATCH_PROCESS_READY = 2, //流程准备,待机
  41. DISPATCH_PROCESS_CONNECT_DEVICE = 3, //流程 连接设备
  42. DISPATCH_PROCESS_WORKING = 4, //流程工作正忙, 进行长流程
  43. DISPATCH_PROCESS_RESPONSE = 5, //流程 给调度控制答复
  44. DISPATCH_PROCESS_OVER = 6, //流程完成
  45. DISPATCH_PROCESS_RELEASE = 7, //流程释放
  46. DISPATCH_PROCESS_FAULT = 10, //故障
  47. DISPATCH_PROCESS_MOTION_FAILED = 11, //单个小动作执行失败
  48. };
  49. //调度任务类型
  50. enum Dispatch_process_type
  51. {
  52. DISPATCH_PROCESS_TYPE_UNKNOW = 0, //未知
  53. DISPATCH_PROCESS_STORE = 101, //存车
  54. DISPATCH_PROCESS_PICKUP = 102, //取车
  55. };
  56. //机器手的动作, 控制步骤
  57. enum Dispatch_process_catcher_motion
  58. {
  59. CATCHER_MOTION_UNKNOW = 0, //未知
  60. };
  61. //搬运器的动作, 控制步骤
  62. enum Dispatch_process_carrier_motion
  63. {
  64. CARRIER_MOTION_UNKNOW = 0, //未知
  65. };
  66. public:
  67. Dispatch_process();
  68. Dispatch_process(const Dispatch_process& other)= default;
  69. Dispatch_process& operator =(const Dispatch_process& other)= default;
  70. ~Dispatch_process();
  71. public://API functions
  72. //初始化, 就把主控发送的请求传入即可.
  73. Error_manager Dispatch_process_init(message::Dispatch_request_msg dispatch_request_msg);
  74. //反初始化
  75. Error_manager Dispatch_process_uninit();
  76. public://get or set member variable
  77. protected://member functions
  78. //主线程
  79. virtual void Main();
  80. //检查调度请求
  81. Error_manager check_dispatch_request_msg();
  82. //发送调度总计划
  83. Error_manager send_dispatch_plan_request_msg();
  84. //等待控制指令
  85. Error_manager wait_dispatch_control_request_msg();
  86. //连接调度设备, 后续还需要检查设备姿态, 防止意外.
  87. Error_manager connect_dispatch_device();
  88. //检查机器手任务单
  89. Error_manager check_catcher_task();
  90. //检查搬运器任务单
  91. Error_manager check_carrier_task();
  92. //检查通道口任务单
  93. Error_manager check_passageway_task();
  94. //检查 任务单 是否完成任务, 里面会调整短步骤
  95. Error_manager check_task_ex(std::shared_ptr<Task_Base> p_catcher_task, int& step);
  96. //执行调度控制指令, 并根据完成情况给答复
  97. Error_manager excute_dispatch_control();
  98. //机器手去入口抓车(例如:机器手移动到2号入口上方,然后下降到一楼抓车,最后上升到最上方)
  99. Error_manager excute_robot_catch_car_from_inlet();
  100. //机器手把车放到中跑车上面(例如:机器手下降到中跑车上放车,最后上升到最上方)(通过目标点 指定放到哪一个中跑车上)
  101. Error_manager excute_robot_put_car_to_carrier();
  102. //机器手去中跑车上抓车(例如:机器手移动到1号中跑车上方,然后下降到中跑车抓车,最后上升到最上方)
  103. Error_manager excute_robot_catch_car_from_carrier();
  104. //机器手去出口放车(例如:机器手移动到3号出口上方,然后下降到一楼放车,最后上升到最上方)
  105. Error_manager excute_robot_put_car_to_outlet();
  106. //机器手的自由移动(例如:机器手移动到6号出入口的上方4楼处,给其他设备避让)(不进行抓车和放车的操作)
  107. Error_manager excute_robot_move();
  108. //搬运器从机器手上接车(例如:搬运器移动到2号入口的上方,然后等待机器手把车放到中跑车上,小跑车保持松夹杆状态)
  109. Error_manager excute_carrier_receive_car_from_robot();
  110. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至电梯井)
  111. Error_manager excute_carrier_store_car_to_parkingspace();
  112. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至56车位外面即可)
  113. Error_manager excute_carrier_store_car_to_parkingspace_ex();
  114. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至电梯井)
  115. Error_manager excute_carrier_pickup_car_from_parkingspace();
  116. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至56车位外面即可)
  117. Error_manager excute_carrier_pickup_car_from_parkingspace_ex();
  118. //搬运器把车交付给机器手(例如:搬运器移动到3号入口的上方,小跑车松夹杆,然后等待机器手把车从中跑车上取走)
  119. Error_manager excute_carrier_deliver_car_to_robot();
  120. //搬运器的自由移动(可以提前到2楼来准备接车,或者为了避让就退回至电梯井)(小跑车不进行取车和存车)
  121. Error_manager excute_carrier_move();
  122. //执行通道口动作
  123. Error_manager excute_passageway_motion();
  124. //等待调度总计划答复
  125. Error_manager wait_dispatch_plan_response_msg();
  126. //发送调度答复, 发给主控的
  127. Error_manager send_dispatch_response_msg();
  128. //通知调度管理, 释放资源,
  129. Error_manager release_resource();
  130. //异常处理
  131. Error_manager Exception_handling();
  132. //机器手调整到 正常待机的姿态
  133. Error_manager cartcher_adjust_to_ready(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  134. //机器手 移动z
  135. Error_manager cartcher_move_z(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target);
  136. //机器手调整到 准备从地面抓车前的姿态
  137. Error_manager cartcher_adjust_from_ground(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  138. //机器手 修正轴距, 如果轴距大于3000mm, 那么就要修正轴距.
  139. Error_manager cartcher_adjust_wheel_base(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  140. //机器手 移动c轴 夹杆
  141. Error_manager cartcher_move_c(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, Catcher_task::Clamp_motion target);
  142. //机器手调整到 准备把车放到搬运器的姿态
  143. Error_manager cartcher_adjust_to_carrier(Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  144. public://member variable
  145. Dispatch_process_status m_dispatch_process_status; //调度流程的状态, 控制步骤
  146. //流程总规划数据, 外部指令
  147. std::mutex m_lock;
  148. Dispatch_process_type m_dispatch_process_type; //调度任务类型
  149. int m_dispatch_source; //调度的起点,源头
  150. int m_dispatch_destination; //调度的终点,目的地
  151. Common_data::Car_measure_information m_car_measure_information; //整车的测量信息
  152. Common_data::Parkspace_information m_parkspace_information; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  153. //硬件资源
  154. std::shared_ptr<Dispatch_device_base> mp_catcher; //抓车器指针, 内存由Dispatch_manager来管理
  155. std::shared_ptr<Task_Base> mp_catcher_task; //抓车器任务, 内存由本模块管理
  156. std::shared_ptr<Dispatch_device_base> mp_carrier; //搬运器指针, 内存由Dispatch_manager来管理
  157. std::shared_ptr<Task_Base> mp_carrier_task; //搬运器任务, 内存由本模块管理
  158. std::shared_ptr<Dispatch_device_base> mp_passageway; //通道口指针, 内存由Dispatch_manager来管理
  159. std::shared_ptr<Task_Base> mp_passageway_task; //通道口任务, 内存由本模块管理
  160. std::string m_command_key; //任务唯一码
  161. int m_timeout_ms; //超时时间,单位ms
  162. std::chrono::system_clock::time_point m_start_time; //流程开始时间
  163. Error_manager m_result; //流程的执行结果
  164. Point3D_tool::Point3D m_source_coordinates; //起点 的坐标
  165. Point3D_tool::Point3D m_destination_coordinates; //终点 的坐标
  166. Dispatch_process_catcher_motion m_dispatch_process_catcher_motion; //机器手的动作, 控制步骤
  167. Dispatch_process_carrier_motion m_dispatch_process_carrier_motion; //搬运器的动作, 控制步骤
  168. //通信缓存
  169. message::Dispatch_request_msg m_dispatch_request_msg; //1执行搬运请求(主控->调度管理)
  170. message::Dispatch_plan_request_msg m_dispatch_plan_request_msg; //2调度总规划的请求, 用于启动整个调度算法(调度管理->调度算法)
  171. message::Dispatch_control_request_msg m_dispatch_control_request_msg; //3调度控制的任务请求(调度算法->调度管理)
  172. message::Dispatch_control_response_msg m_dispatch_control_response_msg; //4调度控制的任务答复(调度管理->调度算法)
  173. message::Dispatch_plan_response_msg m_dispatch_plan_response_msg; //5调度总规划的答复(调度算法->调度管理)
  174. message::Dispatch_response_msg m_dispatch_response_msg; //6搬运动作执行完成后反馈结果(调度管理->主控)
  175. //流程通信顺序为 收1->发2->收3->发4->收3->发4->收3->发4->收5->发6
  176. private:
  177. };
  178. #endif //NNXX_TESTS_DISPATCH_PROCESS_H