communication_message.h 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. //
  2. // Created by huli on 2020/6/29.
  3. //
  4. #ifndef NNXX_TESTS_COMMUNICATION_MESSAGE_H
  5. #define NNXX_TESTS_COMMUNICATION_MESSAGE_H
  6. #include "../error_code/error_code.h"
  7. #include <time.h>
  8. #include <sys/time.h>
  9. #include <chrono>
  10. //#include <iosfwd>
  11. #include <string>
  12. #include "../message/message_base.pb.h"
  13. class Communication_message
  14. {
  15. public:
  16. //消息类型定义,每个在网络上传输的消息必须含有这个属性
  17. enum Message_type
  18. {
  19. eBase_msg=0x00,
  20. eCommand_msg=0x01, //指令消息
  21. eLocate_status_msg=0x11, //定位模块状态消息
  22. eLocate_request_msg=0x12, //定位请求消息
  23. eLocate_response_msg=0x13, //定位反馈消息
  24. eDispatch_status_msg=0x21, //调度模块硬件状态消息
  25. eDispatch_request_msg=0x22, //请求调度消息
  26. eDispatch_response_msg=0x23, //调度结果反馈消息
  27. eParkspace_allocation_status_msg = 0x31, //车位分配模块状态消息,包括车位信息
  28. eParkspace_allocation_request_msg = 0x32, //请求分配车位消息
  29. eParkspace_allocation_response_msg = 0x33, //分配车位结果反馈消息
  30. eParkspace_search_request_msg = 0x34, //查询车位请求消息
  31. eParkspace_search_response_msg = 0x35, //查询车位反馈消息
  32. eParkspace_release_request_msg = 0x36, //释放车位请求消息
  33. eParkspace_release_response_msg = 0x37, //释放车位反馈消息
  34. eParkspace_force_update_request_msg = 0x38, //手动修改车位消息
  35. eParkspace_force_update_response_msg = 0x39,//手动修改车位反馈消息
  36. eParkspace_confirm_alloc_request_msg = 0x3A,//确认分配车位请求消息
  37. eParkspace_confirm_alloc_response_msg = 0x3B,//确认分配车位反馈消息
  38. eStore_command_request_msg=0x41, //终端停车请求消息
  39. eStore_command_response_msg=0x42, //停车请求反馈消息
  40. ePickup_command_request_msg=0x43, //取车请求消息
  41. ePickup_command_response_msg=0x44, //取车请求反馈消息
  42. eStoring_process_statu_msg=0x90, //停车进度条消息
  43. ePicking_process_statu_msg=0x91, //取车进度消息
  44. eCentral_controller_statu_msg=0xa0, //中控状态消息
  45. eEntrance_manual_operation_msg=0xb0, //针对出入口状态操作的手动消息
  46. eProcess_manual_operation_msg=0xb1,
  47. };
  48. //通讯单元
  49. enum Communicator
  50. {
  51. eEmpty=0x0000, //空
  52. eMain=0x0001, //主流程
  53. eTerminor=0x0100, //终端
  54. eParkspace=0x0200, //数据表
  55. eMeasurer=0x0300, //测量单元
  56. eProcess=0x0400, //调度机构
  57. //...
  58. };
  59. public:
  60. Communication_message();
  61. Communication_message(std::string message_buf);
  62. Communication_message(char* p_buf, int size);
  63. Communication_message(const Communication_message& other)= default;
  64. Communication_message& operator =(const Communication_message& other)= default;
  65. ~Communication_message();
  66. public://API functions
  67. bool is_over_time();
  68. public://get or set member variable
  69. void reset(const message::Base_info& base_info, std::string receive_string);
  70. Message_type get_message_type();
  71. Communicator get_sender();
  72. Communicator get_receiver();
  73. std::string& get_message_buf();
  74. protected://member variable
  75. Message_type m_message_type; //消息类型
  76. std::chrono::system_clock::time_point m_receive_time; //接收消息的时间点
  77. std::chrono::milliseconds m_timeout_ms; //超时时间, 整个软件都统一为毫秒
  78. Communicator m_sender; //发送者
  79. Communicator m_receiver; //接受者
  80. std::string m_message_buf; //消息数据
  81. private:
  82. };
  83. #endif //NNXX_TESTS_COMMUNICATION_MESSAGE_H