dispatch_process.h 34 KB

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