carrier.cpp 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432
  1. //
  2. // Created by huli on 2021/3/12.
  3. //
  4. #include "carrier.h"
  5. #include "dispatch_manager.h"
  6. Carrier::Carrier()
  7. {
  8. m_request_x = 0; //搬运器坐标x轴,
  9. m_request_y = 0; //搬运器坐标y轴,
  10. m_request_z = 0; //搬运器坐标z轴,
  11. m_request_y1 = 0; //搬运器坐标y1轴, 搬运器抓车杆纵向移动(前轮抓杆)
  12. m_request_y2 = 0; //搬运器坐标y2轴, 搬运器抓车杆纵向移动(后轮抓杆)
  13. m_request_clamp_motion = E_CLAMP_NO_ACTION; //搬运器夹车杆. 0=无动作,1=夹紧,2=松开
  14. m_request_joint_motion_x = E_JOINT_NO_ACTION; //电梯与X轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  15. m_request_joint_motion_y = E_JOINT_NO_ACTION; //小跑车与Y轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  16. m_request_space_id = 0; //搬运器空间位置的id.
  17. m_request_floor_id = 0; //搬运器楼层位置的id.
  18. m_request_wheelbase = 0; //搬运器抓车杆前后轮距.
  19. m_respons_status = RESPONS_WORKING; //指令完成状态, 搬运器答复指令, 返回任务完成的情况
  20. m_respons_x = 0; //搬运器坐标x轴,
  21. m_respons_y = 0; //搬运器坐标y轴,
  22. m_respons_z = 0; //搬运器坐标z轴,
  23. m_respons_y1 = 0; //搬运器坐标y1轴, 搬运器抓车杆纵向移动(前轮抓杆)
  24. m_respons_y2 = 0; //搬运器坐标y2轴, 搬运器抓车杆纵向移动(后轮抓杆)
  25. m_respons_clamp_motion = E_CLAMP_NO_ACTION; //搬运器夹车杆. 0=无动作,1=夹紧,2=松开
  26. m_respons_joint_motion_x = E_JOINT_NO_ACTION; //电梯与X轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  27. m_respons_joint_motion_y = E_JOINT_NO_ACTION; //小跑车与Y轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  28. m_respons_space_id = 0; //搬运器空间位置的id.
  29. m_respons_floor_id = 0; //搬运器楼层位置的id.
  30. m_respons_wheelbase = 0; //搬运器抓车杆前后轮距.
  31. m_status_updata_time = std::chrono::system_clock::now();
  32. m_last_heartbeat = 0; //上一次的心跳
  33. m_actual_device_status = HARDWARE_DEVICE_UNKNOWN; //搬运器的硬件设备状态
  34. m_actual_load_status = LOAD_UNKNOWN; //搬运器的负载状态, 小跑车上面是否有车.
  35. m_actual_x = 0; //搬运器坐标x轴,
  36. m_actual_y = 0; //搬运器坐标y轴,
  37. m_actual_z = 0; //搬运器坐标z轴,
  38. m_actual_y1 = 0; //搬运器坐标y1轴, 搬运器抓车杆纵向移动(前轮抓杆)
  39. m_actual_y2 = 0; //搬运器坐标y2轴, 搬运器抓车杆纵向移动(后轮抓杆)
  40. m_actual_clamp_motion1 = E_CLAMP_NO_ACTION; //小跑车夹车杆. 0=无动作,1=夹紧,2=松开
  41. m_actual_clamp_motion2 = E_CLAMP_NO_ACTION; //小跑车夹车杆. 0=无动作,1=夹紧,2=松开
  42. m_actual_small_sports_car_motion = E_SMALL_SPORTS_NO_ACTION;
  43. m_actual_joint_motion_x1 = E_JOINT_NO_ACTION; //电梯与X轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  44. m_actual_joint_motion_x2 = E_JOINT_NO_ACTION; //电梯与X轴的横向轨道对接,0=无动作,1=进行对接, 2=松开对接
  45. memset(m_actual_error_code, 0, 50); //搬运器设备的报警信息位
  46. memset(m_actual_warning_code, 0, 50); //升降机设备的报警信息位
  47. m_actual_coordinates_id = 0;
  48. m_actual_coordinates_rows = 0;
  49. m_actual_coordinates_columns = 0;
  50. }
  51. Carrier::~Carrier()
  52. {
  53. }
  54. //检查任务类型, 子类必须重载, 用来检查输入的任务是否为子类所需的.
  55. Error_manager Carrier::check_task_type(std::shared_ptr<Task_Base> p_task)
  56. {
  57. //检查任务类型,
  58. if (p_task->get_task_type() != Task_Base::Task_type::CARRIER_TASK)
  59. {
  60. return Error_manager(Error_code::CARRIER_TASK_TYPE_ERROR, Error_level::MINOR_ERROR,
  61. "Carrier::check_task_type get_task_type() != CARRIER_TASK ");
  62. }
  63. return Error_code::SUCCESS;
  64. }
  65. //获取硬件设备的状态, 必须子类继承
  66. Carrier::Hardware_device_status Carrier::get_actual_device_status()
  67. {
  68. return m_actual_device_status;
  69. }
  70. //把任务单写入到内存中, 子类必须重载
  71. Error_manager Carrier::write_task_to_memory(std::shared_ptr<Task_Base> p_task)
  72. {
  73. //检查任务类型,
  74. if (p_task->get_task_type() != Task_Base::Task_type::CARRIER_TASK)
  75. {
  76. return Error_manager(Error_code::CARRIER_TASK_TYPE_ERROR, Error_level::MINOR_ERROR,
  77. "Carrier::check_task_type get_task_type() != CARRIER_TASK ");
  78. }
  79. else
  80. {
  81. std::unique_lock<std::mutex> t_lock(m_lock);
  82. Carrier_task* tp_carrier_task = (Carrier_task*)p_task.get();
  83. std::unique_lock<std::mutex> t_lock1(tp_carrier_task->m_lock);
  84. m_request_key = tp_carrier_task->m_request_key;
  85. m_request_x = tp_carrier_task->m_request_x;
  86. m_request_y = tp_carrier_task->m_request_y;
  87. m_request_z = tp_carrier_task->m_request_z;
  88. m_request_y1 = tp_carrier_task->m_request_y1;
  89. m_request_y2 = tp_carrier_task->m_request_y2;
  90. m_request_clamp_motion = (Dispatch_device_base::Clamp_motion)tp_carrier_task->m_request_clamp_motion;
  91. m_request_joint_motion_x = (Dispatch_device_base::Joint_motion)tp_carrier_task->m_request_joint_motion_x;
  92. m_request_joint_motion_y = (Dispatch_device_base::Joint_motion)tp_carrier_task->m_request_joint_motion_y;
  93. m_request_space_id = tp_carrier_task->m_request_space_id;
  94. m_request_floor_id = tp_carrier_task->m_request_floor_id;
  95. m_request_wheelbase = tp_carrier_task->m_request_wheelbase;
  96. return Error_code::SUCCESS;
  97. }
  98. return Error_code::SUCCESS;
  99. }
  100. //更新设备底层通信数据, 子类必须重载
  101. Error_manager Carrier::update_device_communication()
  102. {
  103. std::unique_lock<std::mutex> t_lock1(Dispatch_communication::get_instance_references().m_data_lock);
  104. std::unique_lock<std::mutex> t_lock(m_lock);
  105. //请求消息, 调度->plc
  106. Dispatch_communication::Carrier_request_from_dispatch_to_plc_for_data * tp_carrier_request_from_dispatch_to_plc_for_data =
  107. & Dispatch_communication::get_instance_references().m_carrier_request_from_dispatch_to_plc_for_data[m_device_id];
  108. Dispatch_communication::Carrier_request_from_dispatch_to_plc_for_key * tp_carrier_request_from_dispatch_to_plc_for_key =
  109. & Dispatch_communication::get_instance_references().m_carrier_request_from_dispatch_to_plc_for_key[m_device_id];
  110. memset(tp_carrier_request_from_dispatch_to_plc_for_key->m_request_key, 0, 50);
  111. int t_size = m_request_key.size()<=50 ? m_request_key.size() : 50 ;
  112. memcpy(tp_carrier_request_from_dispatch_to_plc_for_key->m_request_key, m_request_key.c_str(), t_size);
  113. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_x = m_request_x;
  114. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_y = m_request_y;
  115. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_z = m_request_z;
  116. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_y1 = m_request_y1;
  117. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_y2 = m_request_y2;
  118. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_clamp_motion = m_request_clamp_motion;
  119. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_joint_motion_x = m_request_joint_motion_x;
  120. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_joint_motion_y = m_request_joint_motion_y;
  121. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_space_id = m_request_space_id;
  122. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_floor_id = m_request_floor_id;
  123. tp_carrier_request_from_dispatch_to_plc_for_data->m_request_wheelbase = m_request_wheelbase;
  124. //答复消息, plc->调度
  125. Dispatch_communication::Carrier_response_from_plc_to_dispatch * tp_carrier_response_from_plc_to_dispatch =
  126. & Dispatch_communication::get_instance_references().m_carrier_response_from_plc_to_dispatch[m_device_id];
  127. m_respons_key = (char*) tp_carrier_response_from_plc_to_dispatch->m_respons_key;
  128. m_respons_status = (Dispatch_device_base::Respons_status)tp_carrier_response_from_plc_to_dispatch->m_respons_status;
  129. m_respons_x = tp_carrier_response_from_plc_to_dispatch->m_respons_x;
  130. m_respons_y = tp_carrier_response_from_plc_to_dispatch->m_respons_y;
  131. m_respons_z = tp_carrier_response_from_plc_to_dispatch->m_respons_z;
  132. m_respons_y1 = tp_carrier_response_from_plc_to_dispatch->m_respons_y1;
  133. m_respons_y2 = tp_carrier_response_from_plc_to_dispatch->m_respons_y2;
  134. m_respons_clamp_motion = (Dispatch_device_base::Clamp_motion)tp_carrier_response_from_plc_to_dispatch->m_respons_clamp_motion;
  135. m_respons_joint_motion_x = (Dispatch_device_base::Joint_motion)tp_carrier_response_from_plc_to_dispatch->m_respons_joint_motion_x;
  136. m_respons_joint_motion_y = (Dispatch_device_base::Joint_motion)tp_carrier_response_from_plc_to_dispatch->m_respons_joint_motion_y;
  137. m_respons_space_id = tp_carrier_response_from_plc_to_dispatch->m_respons_space_id;
  138. m_respons_floor_id = tp_carrier_response_from_plc_to_dispatch->m_respons_floor_id;
  139. m_respons_wheelbase = tp_carrier_response_from_plc_to_dispatch->m_respons_wheelbase;
  140. //状态消息, plc->调度
  141. Dispatch_communication::Carrier_status_from_plc_to_dispatch *tp_carrier_status_from_plc_to_dispatch =
  142. & Dispatch_communication::get_instance_references().m_carrier_status_from_plc_to_dispatch[m_device_id];
  143. //设备异常 //注注注注注注注注意了, ==的优先级比&要高.
  144. if ( (tp_carrier_status_from_plc_to_dispatch->m_safe_status & 0x02) == 0 )
  145. {
  146. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_EMERGENCY_STOP;
  147. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_FAULT;
  148. }
  149. else if ( (tp_carrier_status_from_plc_to_dispatch->m_safe_status & 0x01) == 0 )
  150. {
  151. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_FAULT;
  152. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_FAULT;
  153. }
  154. else if ( (tp_carrier_status_from_plc_to_dispatch->m_safe_status & 0x08) == 0 )
  155. {
  156. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_COLLISION;
  157. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_FAULT;
  158. }
  159. //正常状态
  160. else
  161. {
  162. if (tp_carrier_status_from_plc_to_dispatch->m_work_status == 1)
  163. {
  164. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_WORKING;
  165. }
  166. else if(tp_carrier_status_from_plc_to_dispatch->m_work_status == 2)
  167. {
  168. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_READY;
  169. }
  170. else if(tp_carrier_status_from_plc_to_dispatch->m_work_status == 0)
  171. {
  172. m_actual_device_status = Dispatch_device_base::HARDWARE_DEVICE_UNKNOWN;
  173. }
  174. //故障恢复之后 E_FAULT ->> E_THREE_LEVEL_WORK
  175. if ( m_dispatch_device_status == Dispatch_device_base::DISPATCH_DEVICE_FAULT )
  176. {
  177. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_THREE_LEVEL_WORK;
  178. }
  179. //else 流程状态维持不变
  180. }
  181. m_actual_load_status = (Dispatch_device_base::Load_status)tp_carrier_status_from_plc_to_dispatch->m_actual_load_status;
  182. m_actual_x = tp_carrier_status_from_plc_to_dispatch->m_actual_x;
  183. m_actual_y = tp_carrier_status_from_plc_to_dispatch->m_actual_y;
  184. //plc没有 给3楼的中跑车写入z轴, 所以手动写入z轴, 方便后面判断坐标
  185. if ( m_device_id == 2 && m_actual_x >1)
  186. {
  187. m_actual_z = Dispatch_coordinates::get_instance_references().m_carrier_3th_floor_z;
  188. }
  189. else
  190. {
  191. m_actual_z = tp_carrier_status_from_plc_to_dispatch->m_actual_z;
  192. }
  193. m_actual_y1 = tp_carrier_status_from_plc_to_dispatch->m_actual_y1;
  194. m_actual_y2 = tp_carrier_status_from_plc_to_dispatch->m_actual_y2;
  195. m_actual_clamp_motion1 = (Dispatch_device_base::Clamp_motion)tp_carrier_status_from_plc_to_dispatch->m_actual_clamp_motion1;
  196. m_actual_clamp_motion2 = (Dispatch_device_base::Clamp_motion)tp_carrier_status_from_plc_to_dispatch->m_actual_clamp_motion2;
  197. m_actual_small_sports_car_motion = (Dispatch_device_base::Small_sports_car_motion)tp_carrier_status_from_plc_to_dispatch->m_actual_small_sports_car_motion;
  198. m_actual_joint_motion_x1 = (Dispatch_device_base::Joint_motion)tp_carrier_status_from_plc_to_dispatch->m_actual_joint_motion_x1;
  199. m_actual_joint_motion_x2 = (Dispatch_device_base::Joint_motion)tp_carrier_status_from_plc_to_dispatch->m_actual_joint_motion_x2;
  200. memcpy(m_actual_error_code, tp_carrier_status_from_plc_to_dispatch->m_actual_error_code, 50);
  201. memcpy(m_actual_warning_code, tp_carrier_status_from_plc_to_dispatch->m_actual_warning_code, 50);
  202. m_actual_error_description = (char*)(tp_carrier_status_from_plc_to_dispatch->m_actual_error_description-2);
  203. update_actual_coordinates_id();
  204. //通过心跳帧来判断通信是否正常
  205. if ( m_last_heartbeat != tp_carrier_status_from_plc_to_dispatch->m_heartbeat )
  206. {
  207. m_last_heartbeat = tp_carrier_status_from_plc_to_dispatch->m_heartbeat;
  208. m_status_updata_time = std::chrono::system_clock::now();
  209. // std::cout << " 111111111111111111111111111 = " << 123 << std::endl;
  210. // std::cout << " tp_carrier_request_from_dispatch_to_plc_for_key->m_request_key = " << tp_carrier_request_from_dispatch_to_plc_for_key->m_request_key << std::endl;
  211. // std::cout << " tp_carrier_response_from_plc_to_dispatch->m_respons_key = " << tp_carrier_response_from_plc_to_dispatch->m_respons_key << std::endl;
  212. // int a = tp_carrier_status_from_plc_to_dispatch->m_work_status;
  213. // std::cout << " tp_carrier_status_from_plc_to_dispatch->m_work_status = " << a << std::endl;
  214. // std::cout << " m_request_key = " << m_request_key << std::endl;
  215. // std::cout << " m_respons_key = " << m_respons_key << std::endl;
  216. // std::cout << " m_actual_device_status = " << m_actual_device_status << std::endl;
  217. // std::cout << " 111111111111111111111111111 = " << 456 << std::endl;
  218. //重连之后,搬运器状态 E_DISCONNECT ->> E_THREE_LEVEL_WORK
  219. if ( m_dispatch_device_status == Dispatch_device_base::DISPATCH_DEVICE_DISCONNECT )
  220. {
  221. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_THREE_LEVEL_WORK;
  222. }
  223. }
  224. else if(std::chrono::system_clock::now() - m_status_updata_time > std::chrono::milliseconds(COMMUNICATION_OVER_TIME_MS))
  225. {
  226. m_dispatch_device_status = Dispatch_device_base::DISPATCH_DEVICE_DISCONNECT;
  227. }
  228. //else 继续等待,直到消息刷新或者超时.
  229. return Error_code::SUCCESS;
  230. }
  231. //从内存中读数据到任务单, 子类必须重载
  232. Error_manager Carrier::check_and_read_memory_to_task(std::shared_ptr<Task_Base> p_task)
  233. {
  234. // std::cout << " huli test :::: " << " ((((((((((((((((((((((((((333333333333333333 = " << 333 << std::endl;
  235. // std::cout << " huli test :::: " << " m_request_key = " << m_request_key << std::endl;
  236. // std::cout << " huli test :::: " << " m_respons_key = " << m_respons_key << std::endl;
  237. // std::cout << " huli test :::: " << " m_respons_status = " << m_respons_status << std::endl;
  238. // std::cout << " huli test :::: " << " )))))))))))))))))))))))))))))))4444444444444 = " << 444 << std::endl;
  239. Dispatch_communication::get_instance_references().communication_start();
  240. //检查任务类型,
  241. if (p_task->get_task_type() != Task_Base::Task_type::CARRIER_TASK)
  242. {
  243. return Error_manager(Error_code::CARRIER_TASK_TYPE_ERROR, Error_level::MINOR_ERROR,
  244. "Carrier::check_task_type get_task_type() != CARRIER_TASK ");
  245. }
  246. else
  247. {
  248. std::unique_lock<std::mutex> t_lock(m_lock);
  249. if ( m_respons_key == m_request_key && m_respons_status != RESPONS_WORKING )
  250. {
  251. Carrier_task* tp_carrier_task = (Carrier_task*)p_task.get();
  252. std::unique_lock<std::mutex> t_lock1(tp_carrier_task->m_lock);
  253. tp_carrier_task->m_respons_key = m_respons_key;
  254. tp_carrier_task->m_respons_status = (Carrier_task::Respons_status)m_respons_status;
  255. tp_carrier_task->m_respons_x = m_respons_x;
  256. tp_carrier_task->m_respons_y = m_respons_y;
  257. tp_carrier_task->m_respons_z = m_respons_z;
  258. tp_carrier_task->m_respons_y1 = m_respons_y1;
  259. tp_carrier_task->m_respons_y2 = m_respons_y2;
  260. tp_carrier_task->m_respons_clamp_motion = (Carrier_task::Clamp_motion)m_respons_clamp_motion;
  261. tp_carrier_task->m_respons_joint_motion_x = (Carrier_task::Joint_motion)m_respons_joint_motion_x;
  262. tp_carrier_task->m_respons_joint_motion_y = (Carrier_task::Joint_motion)m_respons_joint_motion_y;
  263. tp_carrier_task->m_respons_space_id = m_respons_space_id;
  264. tp_carrier_task->m_respons_floor_id = m_respons_floor_id;
  265. tp_carrier_task->m_respons_wheelbase = m_respons_wheelbase;
  266. //如果故障,则添加错误码
  267. if ( m_respons_status == RESPONS_MINOR_ERROR || m_respons_status == RESPONS_CRITICAL_ERROR )
  268. {
  269. //添加错误码
  270. Error_manager t_error(CARRIER_RESPONS_ERROR, MINOR_ERROR, "m_respons_status is error");
  271. tp_carrier_task->set_task_error_manager(t_error);
  272. }
  273. std::cout << " huli test :::: " << " {{{{{{{{{{{{{{{{{{{{{ 33333333333333333333333333333333333333333 }}}}}}}}}}}}}}}}}}}}}}}}}}= " << 333 << std::endl;
  274. std::cout << " huli test :::: " << " m_request_key = " << m_request_key << std::endl;
  275. std::cout << " huli test :::: " << " m_request_x = " << m_request_x << std::endl;
  276. std::cout << " huli test :::: " << " m_request_y = " << m_request_y << std::endl;
  277. std::cout << " huli test :::: " << " m_request_z = " << m_request_z << std::endl;
  278. std::cout << " huli test :::: " << " m_request_clamp_motion = " << m_request_clamp_motion << std::endl;
  279. std::cout << " huli test :::: " << " m_request_wheelbase = " << m_request_wheelbase << std::endl;
  280. std::cout << " huli test :::: " << " m_request_y1 = " << m_request_y1 << std::endl;
  281. std::cout << " huli test :::: " << " m_request_y2 = " << m_request_y2 << std::endl;
  282. std::cout << " m_request_joint_motion_x = " << m_request_joint_motion_x << std::endl;
  283. std::cout << " huli test :::: " << " m_respons_key = " << m_respons_key << std::endl;
  284. std::cout << " huli test :::: " << " m_respons_status = " << m_respons_status << std::endl;
  285. std::cout << " huli test :::: " << " m_respons_x = " << m_respons_x << std::endl;
  286. std::cout << " huli test :::: " << " m_respons_y = " << m_respons_y << std::endl;
  287. std::cout << " huli test :::: " << " m_respons_z = " << m_respons_z << std::endl;
  288. std::cout << " huli test :::: " << " m_respons_clamp_motion = " << m_respons_clamp_motion << std::endl;
  289. std::cout << " huli test :::: " << " m_respons_wheelbase = " << m_respons_wheelbase << std::endl;
  290. std::cout << " huli test :::: " << " m_respons_y1 = " << m_respons_y1 << std::endl;
  291. std::cout << " huli test :::: " << " m_respons_y2 = " << m_respons_y2 << std::endl;
  292. std::cout << " m_respons_joint_motion_x = " << m_respons_joint_motion_x << std::endl;
  293. std::cout << " m_actual_device_status = " << m_actual_device_status << std::endl;
  294. std::cout << " huli test :::: " << " m_actual_x = " << m_actual_x << std::endl;
  295. std::cout << " huli test :::: " << " m_actual_y = " << m_actual_y << std::endl;
  296. std::cout << " huli test :::: " << " m_actual_z = " << m_actual_z << std::endl;
  297. std::cout << " huli test :::: " << " m_actual_y1 = " << m_actual_y1 << std::endl;
  298. std::cout << " huli test :::: " << " m_actual_y2 = " << m_actual_y2 << std::endl;
  299. std::cout << " huli test :::: " << " m_actual_clamp_motion1 = " << m_actual_clamp_motion1 << std::endl;
  300. std::cout << " huli test :::: " << " {{{{{{{{{{{{{{{{{{{{{{{{{{{{ 44444444444444444444444444444444444444444 }}}}}}}}}}}}}}}}}}}}}}}}= " << 444 << std::endl;
  301. return Error_code::SUCCESS;
  302. }
  303. //返回没有收到数据
  304. else
  305. {
  306. return Error_code::NODATA;
  307. }
  308. }
  309. return Error_code::SUCCESS;
  310. }
  311. //取消下发的指令
  312. Error_manager Carrier::cancel_command()
  313. {
  314. //以后再写 need programe
  315. //目前调度和plc的通信指令做的很简单,没有暂停和急停 复位等操作.
  316. //这里先空着,以后再写.
  317. //调度模块单方面销毁任务, 不管底层plc的执行情况, 也不去告知plc任务取消.
  318. return Error_code::SUCCESS;
  319. }
  320. //更新真实 空间位置的id.
  321. Error_manager Carrier::update_actual_coordinates_id()
  322. {
  323. Dispatch_coordinates * tp_dispatch_coordinates = Dispatch_coordinates::get_instance_pointer();
  324. float t_distance_min = 999999;
  325. float t_distance_current = 0;
  326. int t_index_min = 0;
  327. //找出最近的坐标点
  328. for (auto iter = tp_dispatch_coordinates->m_packspace_coordinates.begin(); iter != tp_dispatch_coordinates->m_packspace_coordinates.end(); ++iter)
  329. {
  330. //只算x轴和z轴
  331. t_distance_current = (m_actual_x - iter->second.x)*(m_actual_x - iter->second.x) + (m_actual_z - iter->second.z)*(m_actual_z - iter->second.z);
  332. if ( t_distance_current < t_distance_min )
  333. {
  334. t_distance_min = t_distance_current;
  335. t_index_min = iter->first;
  336. }
  337. }
  338. m_actual_coordinates_id = t_index_min;
  339. //更新空间锁, 只是 覆盖写入加锁.
  340. if ( m_actual_coordinates_id != 0 )
  341. {
  342. Dispatch_manager::get_instance_references().set_space_lock_for_carrier(m_actual_coordinates_id, m_device_id);
  343. }
  344. // if ( get_device_id() == 2 )
  345. // {
  346. // for (auto iter = tp_dispatch_coordinates->m_carrier_coordinates.begin(); iter != tp_dispatch_coordinates->m_carrier_coordinates.end(); ++iter)
  347. // {
  348. // if ( Common_data::approximate_difference(m_actual_x, iter->second.x, 100) &&
  349. // Common_data::approximate_difference(m_actual_y, iter->second.y, 500) &&
  350. // Common_data::approximate_difference(tp_dispatch_coordinates->m_carrier_3th_floor_z, iter->second.z, 200) )
  351. // {
  352. // m_actual_coordinates_id = iter->first;
  353. // }
  354. // }
  355. // }
  356. // else
  357. // {
  358. // for (auto iter = tp_dispatch_coordinates->m_carrier_coordinates.begin(); iter != tp_dispatch_coordinates->m_carrier_coordinates.end(); ++iter)
  359. // {
  360. // if ( Common_data::approximate_difference(m_actual_x, iter->second.x, 100) &&
  361. // Common_data::approximate_difference(m_actual_y, iter->second.y, 500) &&
  362. // Common_data::approximate_difference(m_actual_z, iter->second.z, 200) )
  363. // {
  364. // m_actual_coordinates_id = iter->first;
  365. // }
  366. // }
  367. // }
  368. return Error_code::SUCCESS;
  369. }