dispatch_process.h 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  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_CARRIER_STORE_10 = 410,
  212. DISPATCH_CARRIER_STORE_11 = 411,
  213. DISPATCH_CARRIER_STORE_12 = 412,
  214. DISPATCH_CARRIER_STORE_13 = 413,
  215. DISPATCH_CARRIER_STORE_14 = 414,
  216. DISPATCH_CARRIER_STORE_15 = 415,
  217. DISPATCH_CARRIER_STORE_16 = 416,
  218. DISPATCH_CARRIER_STORE_17 = 417,
  219. DISPATCH_CARRIER_STORE_18 = 418,
  220. DISPATCH_CARRIER_STORE_19 = 419,
  221. DISPATCH_CARRIER_STORE_20 = 420,
  222. DISPATCH_CARRIER_STORE_21 = 421,
  223. DISPATCH_CARRIER_STORE_22 = 422,
  224. DISPATCH_CARRIER_STORE_23 = 423,
  225. DISPATCH_CARRIER_STORE_24 = 424,
  226. DISPATCH_CARRIER_STORE_25 = 425,
  227. DISPATCH_CARRIER_STORE_26 = 426,
  228. DISPATCH_CARRIER_STORE_27 = 427,
  229. DISPATCH_CARRIER_STORE_28 = 428,
  230. DISPATCH_CARRIER_STORE_29 = 429,
  231. DISPATCH_CARRIER_STORE_30 = 430,
  232. DISPATCH_CARRIER_STORE_31 = 431,
  233. DISPATCH_CARRIER_STORE_32 = 432,
  234. DISPATCH_CARRIER_STORE_33 = 433,
  235. DISPATCH_CARRIER_STORE_34 = 434,
  236. DISPATCH_CARRIER_STORE_35 = 435,
  237. DISPATCH_CARRIER_STORE_36 = 436,
  238. DISPATCH_CARRIER_STORE_37 = 437,
  239. DISPATCH_CARRIER_STORE_38 = 438,
  240. DISPATCH_CARRIER_STORE_39 = 439,
  241. DISPATCH_CARRIER_STORE_40 = 440,
  242. DISPATCH_CARRIER_STORE_41 = 441,
  243. DISPATCH_CARRIER_STORE_42 = 442,
  244. DISPATCH_CARRIER_STORE_43 = 443,
  245. DISPATCH_CARRIER_STORE_44 = 444,
  246. DISPATCH_CARRIER_STORE_45 = 445,
  247. DISPATCH_CARRIER_STORE_46 = 446,
  248. DISPATCH_CARRIER_STORE_47 = 447,
  249. DISPATCH_CARRIER_STORE_48 = 448,
  250. DISPATCH_CARRIER_STORE_49 = 449,
  251. DISPATCH_CARRIER_STORE_50 = 450,
  252. DISPATCH_CARRIER_STORE_51 = 451,
  253. DISPATCH_CARRIER_STORE_52 = 452,
  254. DISPATCH_CARRIER_STORE_53 = 453,
  255. DISPATCH_CARRIER_STORE_54 = 454,
  256. DISPATCH_CARRIER_STORE_55 = 455,
  257. DISPATCH_CARRIER_STORE_56 = 456,
  258. DISPATCH_CARRIER_STORE_57 = 457,
  259. DISPATCH_CARRIER_STORE_58 = 458,
  260. DISPATCH_CARRIER_STORE_59 = 459,
  261. DISPATCH_CARRIER_STORE_60 = 460,
  262. DISPATCH_CARRIER_STORE_61 = 461,
  263. DISPATCH_CARRIER_STORE_END = 499,
  264. DISPATCH_CATCHER_STORE_START = 500, //取车流程 开始
  265. DISPATCH_CATCHER_STORE_1 = 501,
  266. DISPATCH_CATCHER_STORE_2 = 502,
  267. DISPATCH_CATCHER_STORE_3 = 503,
  268. DISPATCH_CATCHER_STORE_4 = 504,
  269. DISPATCH_CATCHER_STORE_5 = 505,
  270. DISPATCH_CATCHER_STORE_6 = 506,
  271. DISPATCH_CATCHER_STORE_7 = 507,
  272. DISPATCH_CATCHER_STORE_8 = 508,
  273. DISPATCH_CATCHER_STORE_9 = 509,
  274. DISPATCH_CATCHER_STORE_10 = 510,
  275. DISPATCH_CATCHER_STORE_11 = 511,
  276. DISPATCH_CATCHER_STORE_12 = 512,
  277. DISPATCH_CATCHER_STORE_13 = 513,
  278. DISPATCH_CATCHER_STORE_14 = 514,
  279. DISPATCH_CATCHER_STORE_15 = 515,
  280. DISPATCH_CATCHER_STORE_16 = 516,
  281. DISPATCH_CATCHER_STORE_17 = 517,
  282. DISPATCH_CATCHER_STORE_18 = 518,
  283. DISPATCH_CATCHER_STORE_19 = 519,
  284. DISPATCH_CATCHER_STORE_20 = 520,
  285. DISPATCH_CATCHER_STORE_21 = 521,
  286. DISPATCH_CATCHER_STORE_22 = 522,
  287. DISPATCH_CATCHER_STORE_23 = 523,
  288. DISPATCH_CATCHER_STORE_24 = 524,
  289. DISPATCH_CATCHER_STORE_25 = 525,
  290. DISPATCH_CATCHER_STORE_26 = 526,
  291. DISPATCH_CATCHER_STORE_27 = 527,
  292. DISPATCH_CATCHER_STORE_28 = 528,
  293. DISPATCH_CATCHER_STORE_29 = 529,
  294. DISPATCH_CATCHER_STORE_30 = 530,
  295. DISPATCH_CATCHER_STORE_31 = 531,
  296. DISPATCH_CATCHER_STORE_32 = 532,
  297. DISPATCH_CATCHER_STORE_33 = 533,
  298. DISPATCH_CATCHER_STORE_34 = 534,
  299. DISPATCH_CATCHER_STORE_35 = 535,
  300. DISPATCH_CATCHER_STORE_36 = 536,
  301. DISPATCH_CATCHER_STORE_37 = 537,
  302. DISPATCH_CATCHER_STORE_38 = 538,
  303. DISPATCH_CATCHER_STORE_39 = 539,
  304. DISPATCH_CATCHER_STORE_END = 599,
  305. DISPATCH_CONTROL_DISCONNECT_DEVICE = 7, //流程 解除设备
  306. DISPATCH_CONTROL_OVER = 8, //流程完成
  307. DISPATCH_CONTROL_RELEASE = 9, //流程释放
  308. DISPATCH_CONTROL_FAULT = 10, //故障
  309. DISPATCH_CONTROL_MOTION_FAILED = 11, //单个小动作执行失败
  310. };
  311. //调度控制节点, 对应一个设备
  312. struct Dispatch_control_node
  313. {
  314. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤(对于一个设备的长流程的控制)
  315. std::shared_ptr<Dispatch_device_base> mp_dispatch_device; //调度设备指针, 内存由Dispatch_manager来管理
  316. std::shared_ptr<Task_Base> mp_dispatch_task; //调度任务指针, 内存由本模块管理
  317. //注释
  318. message::Dispatch_control_request_msg m_dispatch_control_request_msg; //3调度控制的任务请求(调度算法->调度管理) 注释
  319. message::Dispatch_control_response_msg m_dispatch_control_response_msg; //4调度控制的任务答复(调度管理->调度算法) 注释
  320. Point3D_tool::Point3D m_source_coordinates; //起点 的坐标 (Dispatch_control 长流程的起点) 注释
  321. Point3D_tool::Point3D m_destination_coordinates; //终点 的坐标 (Dispatch_control 长流程的终点) 注释
  322. Error_manager m_error; //错误码
  323. std::chrono::system_clock::time_point m_time_to_send_control_response; //发送 控制的任务答复 的时间 注释
  324. };
  325. //调度设备机器人节点
  326. struct Dispatch_catcher_node
  327. {
  328. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤
  329. bool m_dispatch_control_start_flag =false; //调度设备机器人启动标志位
  330. // 核心机器人, 2号
  331. std::shared_ptr<Dispatch_device_base> mp_main_catcher; //调度设备指针, 内存由Dispatch_manager来管理
  332. std::shared_ptr<Task_Base> mp_main_catcher_task; //调度任务指针, 内存由本模块管理
  333. Dispatch_device_base::Dispatch_task_level m_main_catcher_task_level;
  334. //跟随搬运器, 3号搬运器
  335. bool m_following_flag; //3号搬运器是否跟随机器人, 如果车位在3楼, 则为false
  336. std::shared_ptr<Dispatch_device_base> mp_following_carrier; //调度设备指针, 内存由Dispatch_manager来管理
  337. std::shared_ptr<Task_Base> mp_following_carrier_task; //调度任务指针, 内存由本模块管理
  338. //目前没有让别人避让的功能
  339. Error_manager m_error; //错误码
  340. };
  341. //调度设备搬运器节点
  342. struct Dispatch_carrier_node
  343. {
  344. Dispatch_control_status m_dispatch_control_status; //调度控制的状态, 控制步骤
  345. bool m_dispatch_control_start_flag =false; //调度设备机器人启动标志位
  346. //核心搬运器, 搬运汽车的搬运器
  347. std::shared_ptr<Dispatch_device_base> mp_main_carrier; //调度设备指针, 内存由Dispatch_manager来管理
  348. std::shared_ptr<Task_Base> mp_main_carrier_task; //调度任务指针, 内存由本模块管理
  349. Dispatch_device_base::Dispatch_task_level m_main_carrier_task_level;
  350. //给机器人发送避让指令, 2号机器人(可选)
  351. std::shared_ptr<Dispatch_device_base> mp_avoid_catcher; //调度设备指针, 内存由Dispatch_manager来管理
  352. std::shared_ptr<Task_Base> mp_avoid_catcher_task; //调度任务指针, 内存由本模块管理
  353. Error_manager m_error; //错误码
  354. };
  355. public:
  356. Dispatch_process();
  357. Dispatch_process(const Dispatch_process& other)= default;
  358. Dispatch_process& operator =(const Dispatch_process& other)= default;
  359. ~Dispatch_process();
  360. public://API functions
  361. //初始化, 就把主控发送的请求传入即可.
  362. Error_manager Dispatch_process_init(message::Dispatch_request_msg &dispatch_request_msg);
  363. //反初始化
  364. Error_manager Dispatch_process_uninit();
  365. //检查流程是否空闲待机
  366. Error_manager check_process_ready();
  367. //判断是否为待机,
  368. virtual bool is_ready();
  369. //能否在左侧路径存车
  370. bool is_able_store_left_path();
  371. //能否在右侧路径存车
  372. bool is_able_store_right_path();
  373. //能否在临时缓存位存车
  374. bool is_able_store_temporary_cache_path();
  375. //能否在临时缓存位存车
  376. bool is_able_store_temporary_cache_path_2nd_floor();
  377. //能否在临时缓存位存车
  378. bool is_able_store_temporary_cache_path_3rd_floor();
  379. public://get or set member variable
  380. void set_main_carrier(std::shared_ptr<Dispatch_device_base> p_carrier);
  381. std::string get_dispatch_control_command_key(Dispatch_catcher_node & dispatch_catcher_node);
  382. std::string get_dispatch_control_command_key(Dispatch_carrier_node & dispatch_carrier_node);
  383. protected://主流程
  384. //主线程
  385. virtual void Main();
  386. //检查调度请求
  387. Error_manager check_dispatch_request_msg();
  388. //等待资源分配
  389. Error_manager wait_resource_allocation();
  390. //调度控制取车
  391. Error_manager dispatch_control_motion_pickup();
  392. //调度控制存车
  393. Error_manager dispatch_control_motion_store();
  394. //检查核心搬运器
  395. Error_manager check_main_carrier(Dispatch_carrier_node & dispatch_carrier_node);
  396. //检查核心抓取器
  397. Error_manager check_main_catcher(Dispatch_catcher_node & dispatch_catcher_node);
  398. //连接搬运器, 创建新的任务单 与设备建立连接, 只能成功, 失败就要进入故障处理
  399. 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);
  400. //连接抓取器, 创建新的任务单 与设备建立连接, 可以失败, 失败就重新执行
  401. 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);
  402. //断开调度设备, 收回任务单, 释放任务单 与设备解除连接
  403. Error_manager disconnect_dispatch_device(std::shared_ptr<Dispatch_device_base> & p_device, std::shared_ptr<Task_Base> & p_device_task);
  404. //发送调度总计划
  405. Error_manager send_dispatch_plan_request_msg();
  406. //调度控制, 并根据完成情况给答复
  407. Error_manager dispatch_control_motion();
  408. //等待控制指令
  409. Error_manager wait_dispatch_control_request_msg(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  410. //连接调度设备, 创建新的任务单 与设备建立连接
  411. Error_manager connect_dispatch_device(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  412. //执行调度控制指令, 并根据完成情况给答复
  413. Error_manager excute_dispatch_control(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  414. //流程通知设备 收回任务单
  415. Error_manager dispatch_control_withdraw_task(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  416. //发送调度控制答复, 发给调度控制的
  417. 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);
  418. //断开调度设备, 释放任务单 与设备解除连接
  419. Error_manager disconnect_dispatch_device(int dispatch_device_type, Dispatch_control_node & dispatch_control_node);
  420. //等待调度总计划答复
  421. Error_manager wait_dispatch_plan_response_msg();
  422. //发送调度答复, 发给主控的
  423. Error_manager send_dispatch_response_msg();
  424. //通知调度管理, 释放资源,
  425. Error_manager release_resource();
  426. //异常处理
  427. Error_manager Exception_handling();
  428. protected://长流程
  429. //机器手去入口抓车(例如:机器手移动到2号入口上方,然后下降到一楼抓车,最后上升到最上方)
  430. Error_manager excute_robot_catch_car_from_inlet(Dispatch_control_node & dispatch_control_node);
  431. //机器手把车放到中跑车上面(例如:机器手下降到中跑车上放车,最后上升到最上方)(通过目标点 指定放到哪一个中跑车上)
  432. Error_manager excute_robot_put_car_to_carrier(Dispatch_control_node & dispatch_control_node);
  433. //机器手去中跑车上抓车(例如:机器手移动到1号中跑车上方,然后下降到中跑车抓车,最后上升到最上方)
  434. Error_manager excute_robot_catch_car_from_carrier(Dispatch_control_node & dispatch_control_node);
  435. //机器手去出口放车(例如:机器手移动到3号出口上方,然后下降到一楼放车,最后上升到最上方)
  436. Error_manager excute_robot_put_car_to_outlet(Dispatch_control_node & dispatch_control_node);
  437. //机器手的自由移动(例如:机器手移动到6号出入口的上方4楼处,给其他设备避让)(不进行抓车和放车的操作)
  438. Error_manager excute_robot_move(Dispatch_control_node & dispatch_control_node);
  439. //搬运器从机器手上接车(例如:搬运器移动到2号入口的上方,然后等待机器手把车放到中跑车上,小跑车保持松夹杆状态)
  440. Error_manager excute_carrier_receive_car_from_robot(Dispatch_control_node & dispatch_control_node);
  441. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至电梯井)
  442. Error_manager excute_carrier_store_car_to_parkingspace(Dispatch_control_node & dispatch_control_node);
  443. //搬运器把车存到停车位上(例如:小跑车夹车后,搬运器移动到56号停车位,然后小跑车将车存入车位,之后搬运器退回至56车位外面即可)
  444. Error_manager excute_carrier_store_car_to_parkingspace_ex(Dispatch_control_node & dispatch_control_node);
  445. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至电梯井)
  446. Error_manager excute_carrier_pickup_car_from_parkingspace(Dispatch_control_node & dispatch_control_node);
  447. //搬运器从停车位上取车(例如:搬运器移动到56号停车位,然后小跑车将车从车位取出,之后搬运器退回至56车位外面即可)
  448. Error_manager excute_carrier_pickup_car_from_parkingspace_ex(Dispatch_control_node & dispatch_control_node);
  449. //搬运器把车交付给机器手(例如:搬运器移动到3号入口的上方,小跑车松夹杆,然后等待机器手把车从中跑车上取走)
  450. Error_manager excute_carrier_deliver_car_to_robot(Dispatch_control_node & dispatch_control_node);
  451. //搬运器的自由移动(可以提前到2楼来准备接车,或者为了避让就退回至电梯井)(小跑车不进行取车和存车)
  452. Error_manager excute_carrier_move(Dispatch_control_node & dispatch_control_node);
  453. //执行通道口动作
  454. Error_manager excute_passageway_motion(Dispatch_control_node & dispatch_control_node);
  455. protected://短流程
  456. //检查 任务单 是否完成任务, 里面不会调整短步骤
  457. Error_manager check_task_status(std::shared_ptr<Task_Base> p_task);
  458. //检查 任务单 是否完成任务, 里面会调整短步骤
  459. Error_manager check_task_status(std::shared_ptr<Task_Base> p_task, Dispatch_control_status & dispatch_control_status);
  460. //检查 任务单 是否完成任务, 里面会调整短步骤
  461. Error_manager check_task_ex(std::shared_ptr<Task_Base> p_task, int& step);
  462. //机器手调整到 正常待机的姿态(调节夹杆和轴距)
  463. 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);
  464. //机器手 移动z
  465. 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);
  466. //机器手调整到 准备从地面抓车前的姿态
  467. 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);
  468. //机器手 修正轴距, 如果轴距大于3000mm, 那么就要修正轴距.
  469. 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);
  470. //机器手 移动c轴 夹杆
  471. 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);
  472. //机器手调整到 对接搬运器的姿态
  473. 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);
  474. //机器手调整到 准备把车放到地面的姿态
  475. 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);
  476. //机器手调整到 对接搬运器的姿态
  477. 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);
  478. //搬运器调整到 正常待机的姿态(调节夹杆和轴距)
  479. 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);
  480. //搬运器 移动x
  481. 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);
  482. //搬运器 移动y
  483. 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);
  484. //搬运器 移动z
  485. 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);
  486. //搬运器 移动c轴 夹车杆
  487. 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);
  488. //搬运器调整 水平的交接
  489. 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);
  490. //搬运器 修正轴距
  491. 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);
  492. //机器手 准备开始, 需要同步任务单和设备真实数据.
  493. 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);
  494. //机器手调整到 正常待机的姿态(调节夹杆和轴距)
  495. 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);
  496. //机器手 移动x
  497. 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);
  498. //机器手 移动y
  499. 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);
  500. //机器手 移动z
  501. 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);
  502. //机器手调整到 准备从地面抓车前的姿态
  503. 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);
  504. //机器手 修正轴距, 如果轴距大于3000mm, 那么就要修正轴距.
  505. 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);
  506. //机器手 移动c轴 夹杆
  507. 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);
  508. //机器手调整到 对接搬运器的姿态
  509. 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);
  510. //机器手调整到 准备把车放到地面的姿态
  511. 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);
  512. //机器手调整到 对接搬运器的姿态
  513. 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);
  514. //搬运器 准备开始, 需要同步任务单和设备真实数据.
  515. 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);
  516. //搬运器调整到 正常待机的姿态(调节夹杆和轴距)
  517. 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);
  518. //搬运器 移动x
  519. 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);
  520. //搬运器 移动y
  521. 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);
  522. //搬运器 移动z
  523. 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);
  524. //搬运器 移动c轴 夹车杆
  525. 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);
  526. //搬运器调整 水平的交接
  527. 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);
  528. //搬运器 修正轴距
  529. 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);
  530. public://member variable
  531. std::atomic<Dispatch_process_status> m_dispatch_process_status; //调度流程的状态, 控制步骤
  532. //流程总规划数据, 外部指令
  533. std::mutex m_lock;
  534. Common_data::Dispatch_process_type m_dispatch_process_type; //调度任务类型
  535. int m_dispatch_source; //调度的起点,源头 (Dispatch_plan 总计划的起点)
  536. int m_dispatch_destination; //调度的终点,目的地(Dispatch_plan 总计划的终点)
  537. Common_data::Car_measure_information m_car_measure_information; //整车的测量信息
  538. Common_data::Parkspace_information m_parkspace_information_optimal; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  539. Common_data::Parkspace_information m_parkspace_information_left; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  540. Common_data::Parkspace_information m_parkspace_information_right; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  541. Common_data::Parkspace_information m_parkspace_information_temporary; //单个车位基本信息与状态信息,车位信息以及车位上的车辆信息
  542. Common_data::Parkspace_type m_parkspace_type; //车位类型
  543. Common_data::Car_type m_car_type; //车辆类型
  544. bool m_temporary_cache_flag; //是否使用临时缓存的标记位
  545. std::string m_command_key; //任务唯一码, 索引
  546. int m_timeout_ms; //超时时间,单位ms
  547. std::chrono::system_clock::time_point m_start_time; //流程开始时间
  548. Error_manager m_result; //流程的执行结果
  549. float m_wheel_base; //轮距
  550. //调度设备控制节点, 核心设备由调度管理进行资源分配, 本流程模块只负责使用
  551. Dispatch_catcher_node m_dispatch_catcher_node; //调度设备机器人节点
  552. Dispatch_carrier_node m_dispatch_carrier_node; //调度设备搬运器节点
  553. //调度控制的长流程节点map
  554. std::map<int, Dispatch_control_node> m_dispatch_control_node_map;
  555. //通信缓存
  556. message::Dispatch_request_msg m_dispatch_request_msg; //1执行搬运请求(主控->调度管理)
  557. message::Dispatch_plan_request_msg m_dispatch_plan_request_msg; //2调度总规划的请求, 用于启动整个调度算法(调度管理->调度算法)
  558. message::Dispatch_plan_response_msg m_dispatch_plan_response_msg; //5调度总规划的答复(调度算法->调度管理)
  559. message::Dispatch_response_msg m_dispatch_response_msg; //6搬运动作执行完成后反馈结果(调度管理->主控)
  560. //流程通信顺序为 收1->发2 ->收3->发4->收3->发4->收3->发4..... ->收5->发6
  561. // std::chrono::system_clock::time_point m_time_to_send_control_response; //发送 控制的任务答复 的时间
  562. private:
  563. };
  564. #endif //NNXX_TESTS_DISPATCH_PROCESS_H