dispatch_process.h 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567
  1. #define MAIN_TEST 1
  2. //#define PROCESS_TEST 1
  3. #define TIME_TEST 1
  4. /*
  5. dispatch_source 和 dispatch_destination 的表示含义
  6. 1~165 2楼~12楼的停车位
  7. 1100 0号出口(在一楼)(目前没有)
  8. 1101~1106 1~6号出入口 (在一楼)
  9. 1107 7号出口(在一楼)
  10. 1201~1206 1~6号出入口上方2楼处
  11. 1301~1306 1~6号出入口上方3楼处
  12. 1401~1406 1~6号出入口上方4楼处
  13. 2101~2112 左侧电梯井(1楼~12楼)(一号搬运器的待机点)
  14. 2201~2212 右侧电梯井(1楼~12楼)(二号搬运器的待机点)
  15. */
  16. #ifndef NNXX_TESTS_DISPATCH_PROCESS_H
  17. #define NNXX_TESTS_DISPATCH_PROCESS_H
  18. #include <error_code.h>
  19. #include "../tool/thread_condition.h"
  20. #include "../tool/TaskQueue/BaseTask.h"
  21. #include "../tool/common_data.h"
  22. #include <glog/logging.h>
  23. #include "../dispatch/carrier.h"
  24. #include "../dispatch/catcher.h"
  25. #include "../dispatch/passageway.h"
  26. #include "../dispatch/dispatch_coordinates.h"
  27. #include "../message/dispatch_message.pb.h"
  28. #include "../message/dispatch_control.pb.h"
  29. #include "../tool/point3D_tool.h"
  30. #include <atomic>
  31. //调度流程 存车
  32. class Dispatch_process : public tq::BaseTask
  33. {
  34. public:
  35. //调度指令超时时间 300000ms = 5min
  36. #define DISPATCH_PROCESS_TIMEOUT_MS 600000
  37. //调度指令超时时间 衰减值 在原有的基础上减少10秒
  38. #define DISPATCH_PROCESS_ATTENUATION_TIMEOUT_MS 10000
  39. //调度默认 差值 2mm (比较结果, 对精度要求较高)
  40. #define DISPATCH_DEFAULT_DIFFERENCE 2
  41. //调度默认 比值 1% (比较结果, 对精度要求较高)
  42. #define DISPATCH_DEFAULT_RATE 0.01
  43. //调度流程的状态, 控制步骤(对于整个大的调度任务)
  44. enum Dispatch_process_status
  45. {
  46. DISPATCH_PROCESS_STATUS_UNKNOW = 0, //未知
  47. DISPATCH_PROCESS_CREATED = 1, //流程创建,
  48. DISPATCH_PROCESS_READY = 2, //流程准备,待机
  49. DISPATCH_PROCESS_WORKING_PICKUP = 103, //流程取车
  50. DISPATCH_PROCESS_WORKING_STORE = 104, //流程存车
  51. DISPATCH_PROCESS_CONNECT_DEVICE = 3, //流程 连接设备
  52. DISPATCH_PROCESS_WORKING = 4, //流程工作正忙, 进行长流程
  53. DISPATCH_PROCESS_RESPONSE = 5, //流程 给调度控制答复
  54. DISPATCH_PROCESS_DISCONNECT_DEVICE = 6, //流程 解除设备
  55. DISPATCH_PROCESS_OVER = 7, //流程完成
  56. DISPATCH_PROCESS_RELEASE = 8, //流程释放
  57. DISPATCH_PROCESS_FAULT = 10, //故障
  58. DISPATCH_PROCESS_MOTION_FAILED = 11, //单个小动作执行失败
  59. };
  60. //调度控制的状态, 控制步骤(对于一个设备的长流程的控制)
  61. enum Dispatch_control_status
  62. {
  63. // DISPATCH_CONTROL_STATUS_UNKNOW = 0, //未知
  64. // DISPATCH_CONTROL_CREATED = 1, //流程创建,
  65. // DISPATCH_CONTROL_READY = 2, //流程准备,待机
  66. // DISPATCH_CONTROL_CONNECT_DEVICE = 3, //流程 连接设备
  67. DISPATCH_CONTROL_WORKING = 4, //流程工作正忙, 进行长流程
  68. DISPATCH_CONTROL_TASK_WITHDRAW = 5, //流程 收回任务单
  69. DISPATCH_CONTROL_RESPONSE = 6, //流程 给调度控制答复
  70. // DISPATCH_CONTROL_DISCONNECT_DEVICE = 7, //流程 解除设备
  71. // DISPATCH_CONTROL_OVER = 8, //流程完成
  72. // DISPATCH_CONTROL_RELEASE = 9, //流程释放
  73. //
  74. // DISPATCH_CONTROL_FAULT = 10, //故障
  75. // DISPATCH_CONTROL_MOTION_FAILED = 11, //单个小动作执行失败
  76. DISPATCH_CONTROL_STATUS_UNKNOW = 0, //未知
  77. DISPATCH_CONTROL_CREATED = 1, //流程创建,
  78. DISPATCH_CONTROL_READY = 2, //流程准备,待机
  79. DISPATCH_CONTROL_CONNECT_DEVICE = 3, //流程 连接设备
  80. DISPATCH_CARRIER_PICKUP_START = 200, //取车流程 开始
  81. DISPATCH_CARRIER_PICKUP_1 = 201,
  82. DISPATCH_CARRIER_PICKUP_2 = 202,
  83. DISPATCH_CARRIER_PICKUP_3 = 203,
  84. DISPATCH_CARRIER_PICKUP_4 = 204,
  85. DISPATCH_CARRIER_PICKUP_5 = 205,
  86. DISPATCH_CARRIER_PICKUP_6 = 206,
  87. DISPATCH_CARRIER_PICKUP_7 = 207,
  88. DISPATCH_CARRIER_PICKUP_8 = 208,
  89. DISPATCH_CARRIER_PICKUP_9 = 209,
  90. DISPATCH_CARRIER_PICKUP_10 = 210,
  91. DISPATCH_CARRIER_PICKUP_11 = 211,
  92. DISPATCH_CARRIER_PICKUP_12 = 212,
  93. DISPATCH_CARRIER_PICKUP_13 = 213,
  94. DISPATCH_CARRIER_PICKUP_14 = 214,
  95. DISPATCH_CARRIER_PICKUP_15 = 215,
  96. DISPATCH_CARRIER_PICKUP_16 = 216,
  97. DISPATCH_CARRIER_PICKUP_17 = 217,
  98. DISPATCH_CARRIER_PICKUP_18 = 218,
  99. DISPATCH_CARRIER_PICKUP_19 = 219,
  100. DISPATCH_CARRIER_PICKUP_20 = 220,
  101. DISPATCH_CARRIER_PICKUP_21 = 221,
  102. DISPATCH_CARRIER_PICKUP_22 = 222,
  103. DISPATCH_CARRIER_PICKUP_23 = 223,
  104. DISPATCH_CARRIER_PICKUP_24 = 224,
  105. DISPATCH_CARRIER_PICKUP_25 = 225,
  106. DISPATCH_CARRIER_PICKUP_26 = 226,
  107. DISPATCH_CARRIER_PICKUP_27 = 227,
  108. DISPATCH_CARRIER_PICKUP_28 = 228,
  109. DISPATCH_CARRIER_PICKUP_29 = 229,
  110. DISPATCH_CARRIER_PICKUP_30 = 230,
  111. DISPATCH_CARRIER_PICKUP_31 = 231,
  112. DISPATCH_CARRIER_PICKUP_32 = 232,
  113. DISPATCH_CARRIER_PICKUP_33 = 233,
  114. DISPATCH_CARRIER_PICKUP_34 = 234,
  115. DISPATCH_CARRIER_PICKUP_35 = 235,
  116. DISPATCH_CARRIER_PICKUP_36 = 236,
  117. DISPATCH_CARRIER_PICKUP_37 = 237,
  118. DISPATCH_CARRIER_PICKUP_38 = 238,
  119. DISPATCH_CARRIER_PICKUP_39 = 239,
  120. DISPATCH_CARRIER_PICKUP_40 = 240,
  121. DISPATCH_CARRIER_PICKUP_41 = 241,
  122. DISPATCH_CARRIER_PICKUP_42 = 242,
  123. DISPATCH_CARRIER_PICKUP_43 = 243,
  124. DISPATCH_CARRIER_PICKUP_44 = 244,
  125. DISPATCH_CARRIER_PICKUP_45 = 245,
  126. DISPATCH_CARRIER_PICKUP_46 = 246,
  127. DISPATCH_CARRIER_PICKUP_47 = 247,
  128. DISPATCH_CARRIER_PICKUP_48 = 248,
  129. DISPATCH_CARRIER_PICKUP_49 = 249,
  130. DISPATCH_CARRIER_PICKUP_50 = 250,
  131. DISPATCH_CARRIER_PICKUP_51 = 251,
  132. DISPATCH_CARRIER_PICKUP_52 = 252,
  133. DISPATCH_CARRIER_PICKUP_53 = 253,
  134. DISPATCH_CARRIER_PICKUP_54 = 254,
  135. DISPATCH_CARRIER_PICKUP_55 = 255,
  136. DISPATCH_CARRIER_PICKUP_56 = 256,
  137. DISPATCH_CARRIER_PICKUP_57 = 257,
  138. DISPATCH_CARRIER_PICKUP_58 = 258,
  139. DISPATCH_CARRIER_PICKUP_59 = 259,
  140. DISPATCH_CARRIER_PICKUP_60 = 260,
  141. DISPATCH_CARRIER_PICKUP_61 = 261,
  142. DISPATCH_CARRIER_PICKUP_70 = 270,
  143. DISPATCH_CARRIER_PICKUP_71 = 271,
  144. DISPATCH_CARRIER_PICKUP_72 = 272,
  145. DISPATCH_CARRIER_PICKUP_73 = 273,
  146. DISPATCH_CARRIER_PICKUP_74 = 274,
  147. DISPATCH_CARRIER_PICKUP_75 = 275,
  148. DISPATCH_CARRIER_PICKUP_76 = 276,
  149. DISPATCH_CARRIER_PICKUP_77 = 277,
  150. DISPATCH_CARRIER_PICKUP_78 = 278,
  151. DISPATCH_CARRIER_PICKUP_79 = 279,
  152. DISPATCH_CARRIER_PICKUP_80 = 280,
  153. DISPATCH_CARRIER_PICKUP_81 = 281,
  154. DISPATCH_CARRIER_PICKUP_82 = 282,
  155. DISPATCH_CARRIER_PICKUP_83 = 283,
  156. DISPATCH_CARRIER_PICKUP_84 = 284,
  157. DISPATCH_CARRIER_PICKUP_85 = 285,
  158. DISPATCH_CARRIER_PICKUP_86 = 286,
  159. DISPATCH_CARRIER_PICKUP_87 = 287,
  160. DISPATCH_CARRIER_PICKUP_88 = 288,
  161. DISPATCH_CARRIER_PICKUP_89 = 289,
  162. DISPATCH_CARRIER_PICKUP_END = 299,
  163. DISPATCH_CATCHER_PICKUP_START = 300, //取车流程 开始
  164. DISPATCH_CATCHER_PICKUP_1 = 301,
  165. DISPATCH_CATCHER_PICKUP_2 = 302,
  166. DISPATCH_CATCHER_PICKUP_3 = 303,
  167. DISPATCH_CATCHER_PICKUP_4 = 304,
  168. DISPATCH_CATCHER_PICKUP_5 = 305,
  169. DISPATCH_CATCHER_PICKUP_6 = 306,
  170. DISPATCH_CATCHER_PICKUP_7 = 307,
  171. DISPATCH_CATCHER_PICKUP_8 = 308,
  172. DISPATCH_CATCHER_PICKUP_9 = 309,
  173. DISPATCH_CATCHER_PICKUP_10 = 310,
  174. DISPATCH_CATCHER_PICKUP_11 = 311,
  175. DISPATCH_CATCHER_PICKUP_12 = 312,
  176. DISPATCH_CATCHER_PICKUP_13 = 313,
  177. DISPATCH_CATCHER_PICKUP_14 = 314,
  178. DISPATCH_CATCHER_PICKUP_15 = 315,
  179. DISPATCH_CATCHER_PICKUP_16 = 316,
  180. DISPATCH_CATCHER_PICKUP_17 = 317,
  181. DISPATCH_CATCHER_PICKUP_18 = 318,
  182. DISPATCH_CATCHER_PICKUP_19 = 319,
  183. DISPATCH_CATCHER_PICKUP_20 = 320,
  184. DISPATCH_CATCHER_PICKUP_21 = 321,
  185. DISPATCH_CATCHER_PICKUP_22 = 322,
  186. DISPATCH_CATCHER_PICKUP_23 = 323,
  187. DISPATCH_CATCHER_PICKUP_24 = 324,
  188. DISPATCH_CATCHER_PICKUP_25 = 325,
  189. DISPATCH_CATCHER_PICKUP_26 = 326,
  190. DISPATCH_CATCHER_PICKUP_27 = 327,
  191. DISPATCH_CATCHER_PICKUP_28 = 328,
  192. DISPATCH_CATCHER_PICKUP_29 = 329,
  193. DISPATCH_CATCHER_PICKUP_30 = 330,
  194. DISPATCH_CATCHER_PICKUP_31 = 331,
  195. DISPATCH_CATCHER_PICKUP_32 = 332,
  196. DISPATCH_CATCHER_PICKUP_33 = 333,
  197. DISPATCH_CATCHER_PICKUP_34 = 334,
  198. DISPATCH_CATCHER_PICKUP_35 = 335,
  199. DISPATCH_CATCHER_PICKUP_36 = 336,
  200. DISPATCH_CATCHER_PICKUP_37 = 337,
  201. DISPATCH_CATCHER_PICKUP_38 = 338,
  202. DISPATCH_CATCHER_PICKUP_39 = 339,
  203. DISPATCH_CATCHER_PICKUP_END = 399,
  204. DISPATCH_CARRIER_STORE_START = 400, //取车流程 开始
  205. DISPATCH_CARRIER_STORE_1 = 401,
  206. DISPATCH_CARRIER_STORE_2 = 402,
  207. DISPATCH_CARRIER_STORE_3 = 403,
  208. DISPATCH_CARRIER_STORE_4 = 404,
  209. DISPATCH_CARRIER_STORE_5 = 405,
  210. DISPATCH_CARRIER_STORE_6 = 406,
  211. DISPATCH_CARRIER_STORE_7 = 407,
  212. DISPATCH_CARRIER_STORE_8 = 408,
  213. DISPATCH_CARRIER_STORE_9 = 409,
  214. DISPATCH_CATCHER_STORE_START = 500, //取车流程 开始
  215. DISPATCH_CATCHER_STORE_1 = 501,
  216. DISPATCH_CATCHER_STORE_2 = 502,
  217. DISPATCH_CATCHER_STORE_3 = 503,
  218. DISPATCH_CATCHER_STORE_4 = 504,
  219. DISPATCH_CATCHER_STORE_5 = 505,
  220. DISPATCH_CATCHER_STORE_6 = 506,
  221. DISPATCH_CATCHER_STORE_7 = 507,
  222. DISPATCH_CATCHER_STORE_8 = 508,
  223. DISPATCH_CATCHER_STORE_9 = 509,
  224. DISPATCH_CONTROL_DISCONNECT_DEVICE = 7, //流程 解除设备
  225. DISPATCH_CONTROL_OVER = 8, //流程完成
  226. DISPATCH_CONTROL_RELEASE = 9, //流程释放
  227. DISPATCH_CONTROL_FAULT = 10, //故障
  228. DISPATCH_CONTROL_MOTION_FAILED = 11, //单个小动作执行失败
  229. };
  230. //调度控制节点, 对应一个设备
  231. struct Dispatch_control_node
  232. {
  233. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤(对于一个设备的长流程的控制)
  234. std::shared_ptr<Dispatch_device_base> mp_dispatch_device; //调度设备指针, 内存由Dispatch_manager来管理
  235. std::shared_ptr<Task_Base> mp_dispatch_task; //调度任务指针, 内存由本模块管理
  236. //注释
  237. message::Dispatch_control_request_msg m_dispatch_control_request_msg; //3调度控制的任务请求(调度算法->调度管理) 注释
  238. message::Dispatch_control_response_msg m_dispatch_control_response_msg; //4调度控制的任务答复(调度管理->调度算法) 注释
  239. Point3D_tool::Point3D m_source_coordinates; //起点 的坐标 (Dispatch_control 长流程的起点) 注释
  240. Point3D_tool::Point3D m_destination_coordinates; //终点 的坐标 (Dispatch_control 长流程的终点) 注释
  241. Error_manager m_error; //错误码
  242. std::chrono::system_clock::time_point m_time_to_send_control_response; //发送 控制的任务答复 的时间 注释
  243. };
  244. //调度设备机器人节点
  245. struct Dispatch_catcher_node
  246. {
  247. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤
  248. bool m_dispatch_control_start_flag =false; //调度设备机器人启动标志位
  249. // 核心机器人, 2号
  250. std::shared_ptr<Dispatch_device_base> mp_main_catcher; //调度设备指针, 内存由Dispatch_manager来管理
  251. std::shared_ptr<Task_Base> mp_main_catcher_task; //调度任务指针, 内存由本模块管理
  252. //跟随搬运器, 3号搬运器
  253. bool m_following_flag; //3号搬运器是否跟随机器人, 如果车位在3楼, 则为false
  254. std::shared_ptr<Dispatch_device_base> mp_following_carrier; //调度设备指针, 内存由Dispatch_manager来管理
  255. std::shared_ptr<Task_Base> mp_following_carrier_task; //调度任务指针, 内存由本模块管理
  256. //目前没有让别人避让的功能
  257. Error_manager m_error; //错误码
  258. };
  259. //调度设备搬运器节点
  260. struct Dispatch_carrier_node
  261. {
  262. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤
  263. bool m_dispatch_control_start_flag =false; //调度设备机器人启动标志位
  264. //核心搬运器, 搬运汽车的搬运器
  265. std::shared_ptr<Dispatch_device_base> mp_main_carrier; //调度设备指针, 内存由Dispatch_manager来管理
  266. std::shared_ptr<Task_Base> mp_main_carrier_task; //调度任务指针, 内存由本模块管理
  267. //给机器人发送避让指令, 2号机器人(可选)
  268. std::shared_ptr<Dispatch_device_base> mp_avoid_catcher; //调度设备指针, 内存由Dispatch_manager来管理
  269. std::shared_ptr<Task_Base> mp_avoid_catcher_task; //调度任务指针, 内存由本模块管理
  270. Error_manager m_error; //错误码
  271. };
  272. public:
  273. Dispatch_process();
  274. Dispatch_process(const Dispatch_process& other)= default;
  275. Dispatch_process& operator =(const Dispatch_process& other)= default;
  276. ~Dispatch_process();
  277. public://API functions
  278. //初始化, 就把主控发送的请求传入即可.
  279. Error_manager Dispatch_process_init(message::Dispatch_request_msg &dispatch_request_msg);
  280. //反初始化
  281. Error_manager Dispatch_process_uninit();
  282. //检查流程是否空闲待机
  283. Error_manager check_process_ready();
  284. //判断是否为待机,
  285. virtual bool is_ready();
  286. //能否在左侧路径存车
  287. bool is_able_store_left_path();
  288. //能否在右侧路径存车
  289. bool is_able_store_right_path();
  290. //能否在临时缓存位存车
  291. bool is_able_store_temporary_cache_path();
  292. //能否在临时缓存位存车
  293. bool is_able_store_temporary_cache_path_2nd_floor();
  294. //能否在临时缓存位存车
  295. bool is_able_store_temporary_cache_path_3rd_floor();
  296. public://get or set member variable
  297. void set_main_carrier(std::shared_ptr<Dispatch_device_base> p_carrier);
  298. std::string get_dispatch_control_command_key(Dispatch_catcher_node & dispatch_catcher_node);
  299. std::string get_dispatch_control_command_key(Dispatch_carrier_node & dispatch_carrier_node);
  300. protected://主流程
  301. //主线程
  302. virtual void Main();
  303. //检查调度请求
  304. Error_manager check_dispatch_request_msg();
  305. //等待资源分配
  306. Error_manager wait_resource_allocation();
  307. //调度控制取车
  308. Error_manager dispatch_control_motion_pickup();
  309. //调度控制存车
  310. Error_manager dispatch_control_motion_store();
  311. //检查核心搬运器
  312. Error_manager check_main_carrier(Dispatch_carrier_node & dispatch_carrier_node);
  313. //检查核心抓取器
  314. Error_manager check_main_catcher(Dispatch_catcher_node & dispatch_catcher_node);
  315. //连接搬运器, 创建新的任务单 与设备建立连接, 只能成功, 失败就要进入故障处理
  316. Error_manager connect_dispatch_carrier(std::shared_ptr<Dispatch_device_base> & p_carrier, std::shared_ptr<Task_Base> & p_carrier_task, Dispatch_device_base::Dispatch_task_level dispatch_task_level);
  317. //连接抓取器, 创建新的任务单 与设备建立连接, 可以失败, 失败就重新执行
  318. Error_manager connect_dispatch_catcher(std::shared_ptr<Dispatch_device_base> & p_catcher, std::shared_ptr<Task_Base> & p_catcher_task, Dispatch_device_base::Dispatch_task_level dispatch_task_level);
  319. //断开调度设备, 收回任务单, 释放任务单 与设备解除连接
  320. Error_manager disconnect_dispatch_device(std::shared_ptr<Dispatch_device_base> & p_device, std::shared_ptr<Task_Base> & p_device_task);
  321. //发送调度总计划
  322. Error_manager send_dispatch_plan_request_msg();
  323. //调度控制, 并根据完成情况给答复
  324. Error_manager dispatch_control_motion();
  325. //等待控制指令
  326. Error_manager wait_dispatch_control_request_msg(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  327. //连接调度设备, 创建新的任务单 与设备建立连接
  328. Error_manager connect_dispatch_device(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  329. //执行调度控制指令, 并根据完成情况给答复
  330. Error_manager excute_dispatch_control(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  331. //流程通知设备 收回任务单
  332. Error_manager dispatch_control_withdraw_task(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  333. //发送调度控制答复, 发给调度控制的
  334. Error_manager send_dispatch_control_response_msg(int dispatch_device_type, Dispatch_control_node & dispatch_control_node, message::Dispatch_device_task_status dispatch_device_task_status);
  335. //断开调度设备, 释放任务单 与设备解除连接
  336. Error_manager disconnect_dispatch_device(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  337. //等待调度总计划答复
  338. Error_manager wait_dispatch_plan_response_msg();
  339. //发送调度答复, 发给主控的
  340. Error_manager send_dispatch_response_msg();
  341. //通知调度管理, 释放资源,
  342. Error_manager release_resource();
  343. //异常处理
  344. Error_manager Exception_handling();
  345. protected://长流程
  346. //机器手去入口抓车(例如:机器手移动到2号入口上方,然后下降到一楼抓车,最后上升到最上方)
  347. Error_manager excute_robot_catch_car_from_inlet(Dispatch_control_node & dispatch_control_node);
  348. //机器手把车放到中跑车上面(例如:机器手下降到中跑车上放车,最后上升到最上方)(通过目标点 指定放到哪一个中跑车上)
  349. Error_manager excute_robot_put_car_to_carrier(Dispatch_control_node & dispatch_control_node);
  350. //机器手去中跑车上抓车(例如:机器手移动到1号中跑车上方,然后下降到中跑车抓车,最后上升到最上方)
  351. Error_manager excute_robot_catch_car_from_carrier(Dispatch_control_node & dispatch_control_node);
  352. //机器手去出口放车(例如:机器手移动到3号出口上方,然后下降到一楼放车,最后上升到最上方)
  353. Error_manager excute_robot_put_car_to_outlet(Dispatch_control_node & dispatch_control_node);
  354. //机器手的自由移动(例如:机器手移动到6号出入口的上方4楼处,给其他设备避让)(不进行抓车和放车的操作)
  355. Error_manager excute_robot_move(Dispatch_control_node & dispatch_control_node);
  356. //搬运器从机器手上接车(例如:搬运器移动到2号入口的上方,然后等待机器手把车放到中跑车上,小跑车保持松夹杆状态)
  357. Error_manager excute_carrier_receive_car_from_robot(Dispatch_control_node & dispatch_control_node);
  358. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至电梯井)
  359. Error_manager excute_carrier_store_car_to_parkingspace(Dispatch_control_node & dispatch_control_node);
  360. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至56车位外面即可)
  361. Error_manager excute_carrier_store_car_to_parkingspace_ex(Dispatch_control_node & dispatch_control_node);
  362. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至电梯井)
  363. Error_manager excute_carrier_pickup_car_from_parkingspace(Dispatch_control_node & dispatch_control_node);
  364. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至56车位外面即可)
  365. Error_manager excute_carrier_pickup_car_from_parkingspace_ex(Dispatch_control_node & dispatch_control_node);
  366. //搬运器把车交付给机器手(例如:搬运器移动到3号入口的上方,小跑车松夹杆,然后等待机器手把车从中跑车上取走)
  367. Error_manager excute_carrier_deliver_car_to_robot(Dispatch_control_node & dispatch_control_node);
  368. //搬运器的自由移动(可以提前到2楼来准备接车,或者为了避让就退回至电梯井)(小跑车不进行取车和存车)
  369. Error_manager excute_carrier_move(Dispatch_control_node & dispatch_control_node);
  370. //执行通道口动作
  371. Error_manager excute_passageway_motion(Dispatch_control_node & dispatch_control_node);
  372. protected://短流程
  373. //检查 任务单 是否完成任务, 里面不会调整短步骤
  374. Error_manager check_task_status(std::shared_ptr<Task_Base> p_task);
  375. //检查 任务单 是否完成任务, 里面会调整短步骤
  376. Error_manager check_task_status(std::shared_ptr<Task_Base> p_task, Dispatch_control_status & dispatch_control_status);
  377. //检查 任务单 是否完成任务, 里面会调整短步骤
  378. Error_manager check_task_ex(std::shared_ptr<Task_Base> p_task, int& step);
  379. //机器手调整到 正常待机的姿态(调节夹杆和轴距)
  380. Error_manager catcher_adjust_to_ready(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  381. //机器手 移动z
  382. Error_manager catcher_move_z(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target);
  383. //机器手调整到 准备从地面抓车前的姿态
  384. Error_manager catcher_adjust_from_ground(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  385. //机器手 修正轴距, 如果轴距大于3000mm, 那么就要修正轴距.
  386. Error_manager catcher_adjust_wheel_base(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  387. //机器手 移动c轴 夹杆
  388. Error_manager catcher_move_c(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, Catcher_task::Clamp_motion target);
  389. //机器手调整到 对接搬运器的姿态
  390. Error_manager catcher_adjust_to_carrier(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, bool reverse_flag);
  391. //机器手调整到 准备把车放到地面的姿态
  392. Error_manager catcher_adjust_to_ground(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  393. //机器手调整到 对接搬运器的姿态
  394. Error_manager catcher_adjust_from_carrier(Dispatch_control_node & dispatch_control_node, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  395. //搬运器调整到 正常待机的姿态(调节夹杆和轴距)
  396. Error_manager carrier_adjust_to_ready(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates);
  397. //搬运器 移动x
  398. Error_manager carrier_move_x(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target);
  399. //搬运器 移动y
  400. Error_manager carrier_move_y(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target);
  401. //搬运器 移动z
  402. Error_manager carrier_move_z(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target);
  403. //搬运器 移动c轴 夹车杆
  404. Error_manager carrier_move_c(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, Carrier_task::Clamp_motion target);
  405. //搬运器调整 水平的交接
  406. Error_manager carrier_joint_x(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, Carrier_task::Joint_motion target);
  407. //搬运器 修正轴距
  408. Error_manager carrier_adjust_wheel_base(Dispatch_control_node & dispatch_control_node, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates);
  409. //机器手 准备开始, 需要同步任务单和设备真实数据.
  410. Error_manager catcher_ready_to_start(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  411. //机器手调整到 正常待机的姿态(调节夹杆和轴距)
  412. Error_manager catcher_adjust_to_ready(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  413. //机器手 移动x
  414. Error_manager catcher_move_x(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_x);
  415. //机器手 移动y
  416. Error_manager catcher_move_y(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_y);
  417. //机器手 移动z
  418. Error_manager catcher_move_z(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_z);
  419. //机器手调整到 准备从地面抓车前的姿态
  420. Error_manager catcher_adjust_from_ground(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  421. //机器手 修正轴距, 如果轴距大于3000mm, 那么就要修正轴距.
  422. Error_manager catcher_adjust_wheel_base(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates);
  423. //机器手 移动c轴 夹杆
  424. Error_manager catcher_move_c(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, Catcher_task::Clamp_motion target);
  425. //机器手调整到 对接搬运器的姿态
  426. Error_manager catcher_adjust_to_carrier(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_x, bool reverse_flag);
  427. //机器手调整到 准备把车放到地面的姿态
  428. Error_manager catcher_adjust_to_ground(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_x, float target_y);
  429. //机器手调整到 对接搬运器的姿态
  430. Error_manager catcher_adjust_from_carrier(std::string dispatch_control_command_key, Catcher * tp_catcher, Catcher_task * tp_catcher_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_x);
  431. //搬运器 准备开始, 需要同步任务单和设备真实数据.
  432. Error_manager carrier_ready_to_start(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates);
  433. //搬运器调整到 正常待机的姿态(调节夹杆和轴距)
  434. Error_manager carrier_adjust_to_ready(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates);
  435. //搬运器 移动x
  436. Error_manager carrier_move_x(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_x);
  437. //搬运器 移动y
  438. Error_manager carrier_move_y(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_y);
  439. //搬运器 移动z
  440. Error_manager carrier_move_z(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, float target_z);
  441. //搬运器 移动c轴 夹车杆
  442. Error_manager carrier_move_c(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, Carrier_task::Clamp_motion target);
  443. //搬运器调整 水平的交接
  444. Error_manager carrier_joint_x(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates, Carrier_task::Joint_motion target);
  445. //搬运器 修正轴距
  446. Error_manager carrier_adjust_wheel_base(std::string dispatch_control_command_key, Carrier * tp_carrier, Carrier_task * tp_carrier_task, Dispatch_coordinates * tp_dispatch_coordinates);
  447. public://member variable
  448. std::atomic<Dispatch_process_status> m_dispatch_process_status; //调度流程的状态, 控制步骤
  449. //流程总规划数据, 外部指令
  450. std::mutex m_lock;
  451. Common_data::Dispatch_process_type m_dispatch_process_type; //调度任务类型
  452. int m_dispatch_source; //调度的起点,源头 (Dispatch_plan 总计划的起点)
  453. int m_dispatch_destination; //调度的终点,目的地(Dispatch_plan 总计划的终点)
  454. Common_data::Car_measure_information m_car_measure_information; //整车的测量信息
  455. Common_data::Parkspace_information m_parkspace_information_optimal; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  456. Common_data::Parkspace_information m_parkspace_information_left; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  457. Common_data::Parkspace_information m_parkspace_information_right; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  458. Common_data::Parkspace_information m_parkspace_information_temporary; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  459. Common_data::Parkspace_type m_parkspace_type; //车位类型
  460. Common_data::Car_type m_car_type; //车辆类型
  461. bool m_temporary_cache_flag; //是否使用临时缓存的标记位
  462. std::string m_command_key; //任务唯一码, 索引
  463. int m_timeout_ms; //超时时间,单位ms
  464. std::chrono::system_clock::time_point m_start_time; //流程开始时间
  465. Error_manager m_result; //流程的执行结果
  466. float m_wheel_base; //轮距
  467. //调度设备控制节点, 核心设备由调度管理进行资源分配, 本流程模块只负责使用
  468. Dispatch_catcher_node m_dispatch_catcher_node; //调度设备机器人节点
  469. Dispatch_carrier_node m_dispatch_carrier_node; //调度设备搬运器节点
  470. //调度控制的长流程节点map
  471. std::map<int, Dispatch_control_node> m_dispatch_control_node_map;
  472. //通信缓存
  473. message::Dispatch_request_msg m_dispatch_request_msg; //1执行搬运请求(主控->调度管理)
  474. message::Dispatch_plan_request_msg m_dispatch_plan_request_msg; //2调度总规划的请求, 用于启动整个调度算法(调度管理->调度算法)
  475. message::Dispatch_plan_response_msg m_dispatch_plan_response_msg; //5调度总规划的答复(调度算法->调度管理)
  476. message::Dispatch_response_msg m_dispatch_response_msg; //6搬运动作执行完成后反馈结果(调度管理->主控)
  477. //流程通信顺序为 收1->发2 ->收3->发4->收3->发4->收3->发4..... ->收5->发6
  478. // std::chrono::system_clock::time_point m_time_to_send_control_response; //发送 控制的任务答复 的时间
  479. private:
  480. };
  481. #endif //NNXX_TESTS_DISPATCH_PROCESS_H