dispatch_process.h 31 KB

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