test_parkspace_sample.cpp 3.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. /*
  2. * @Description: 测试车位分配模块通信情况
  3. * @Author: yct
  4. * @Date: 2020-07-08 15:51:46
  5. * @LastEditTime: 2020-07-24 10:54:17
  6. * @LastEditors: yct
  7. */
  8. #include "../parkspace_allocation/parkspace_allocation_communicator.h"
  9. #include "../parkspace_allocation/parkspace_allocator.h"
  10. int main()
  11. {
  12. //20200129test
  13. google::InitGoogleLogging("parkspace_allocator");
  14. google::SetStderrLogging(google::INFO);
  15. google::InstallFailureSignalHandler();
  16. FLAGS_colorlogtostderr = true;
  17. Parkspace_allocation_communicator *p_parkspace_allocation_communicater = Parkspace_allocation_communicator::get_instance_pointer();
  18. Parkspace_allocator *p_parkspace_allocator = Parkspace_allocator::get_instance_pointer();
  19. parkspace_proto::database_config config;
  20. config.set_db_ip("192.168.0.164");
  21. config.set_db_port(3306);
  22. config.set_db_username("root");
  23. config.set_db_passwd("123456");
  24. config.set_db_name("test");
  25. config.set_db_conn_pool_size(5);
  26. p_parkspace_allocator->parkspace_allocator_init(4, config);
  27. p_parkspace_allocation_communicater->communication_connect("tcp://192.168.0.64:30000");
  28. p_parkspace_allocation_communicater->communication_bind("tcp://192.168.0.64:30008");
  29. // p_parkspace_allocation_communicater->communication_bind("tcp://192.168.2.125:7001");
  30. // p_parkspace_allocation_communicater->communication_connect("tcp://127.0.0.1:7000");
  31. p_parkspace_allocation_communicater->communication_run();
  32. // // 初始化车位,创建三个车位
  33. // message::Parkspace_allocation_status_msg parkspace_status;
  34. // for (size_t i = 1; i < 1000; i++)
  35. // {
  36. // message::Parkspace_info* space = parkspace_status.add_parkspace_info();
  37. // space->set_parkspace_id(i);
  38. // space->set_index(i);
  39. // space->set_direction(message::Direction::eForward);
  40. // space->set_floor(2+i);
  41. // space->set_length(5.5);
  42. // space->set_width(2.2);
  43. // space->set_height(1.75);
  44. // space->set_parkspace_status(message::Parkspace_status::eParkspace_empty);
  45. // }
  46. // message::Base_info base_msg;
  47. // message::Error_manager error;
  48. // base_msg.set_msg_type(message::Message_type::eParkspace_allocation_response_msg);
  49. // base_msg.set_timeout_ms(1000);
  50. // base_msg.set_sender(message::Communicator::eParkspace);
  51. // base_msg.set_receiver(message::Communicator::eMain);
  52. // error.set_error_code(0);
  53. // parkspace_status.mutable_base_info()->CopyFrom(base_msg);
  54. // parkspace_status.mutable_error_manager()->CopyFrom(error);
  55. // p_parkspace_allocation_communicater->update_parkspace_status(parkspace_status);
  56. int k=1;
  57. while(1) {
  58. // message::Parkspace_info space;
  59. // space.set_parkspace_id(3);
  60. // space.set_index(k);
  61. // space.set_direction(message::Direction::eForward);
  62. // space.set_floor(k*3);
  63. // space.set_length(5500);
  64. // space.set_width(2200);
  65. // space.set_height(k*400);
  66. // space.set_parkspace_status(message::Parkspace_status::eParkspace_occupied);
  67. // p_parkspace_allocator->update_parkspace_status(3, space);
  68. usleep(1000*1000);
  69. k++;
  70. }
  71. p_parkspace_allocator->parkspace_allocator_uninit();
  72. return 0;
  73. }