test_parkspace_sample.cpp 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  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. //wangkang 20200223
  9. #include "../parkspace_allocation/parkspace_communicator.h"
  10. #include "../parkspace_allocation/parkspace_manager.h"
  11. #include "database_controller.h"
  12. int main()
  13. {
  14. //huli 20210129
  15. //20200129test
  16. google::InitGoogleLogging("parkspace_allocator");
  17. google::SetStderrLogging(google::INFO);
  18. google::InstallFailureSignalHandler();
  19. FLAGS_colorlogtostderr = true;
  20. Parkspace_communicator *p_parkspace_allocation_communicater = Parkspace_communicator::get_instance_pointer();
  21. Parkspace_manager *p_parkspace_manage = Parkspace_manager::get_instance_pointer();
  22. // parkspace_proto::database_config config;
  23. // config.set_db_ip("127.0.0.1");
  24. // config.set_db_port(3306);
  25. // config.set_db_username("wk");
  26. // config.set_db_passwd("123456");
  27. // config.set_db_name("test");
  28. // config.set_db_conn_pool_size(5);
  29. // p_parkspace_allocator->parkspace_allocator_init(4, config);
  30. //
  31. // Database_controller::get_instance_references().database_controller_init();
  32. Database_controller::get_instance_pointer()->database_controller_init();
  33. // Database_controller::get_instance_pointer()->database_controller_init("127.0.0.1", 3306, "wk", "123456", "test");
  34. p_parkspace_allocation_communicater->communication_init();
  35. p_parkspace_manage->parkspace_manager_init(4);
  36. // p_parkspace_allocation_communicater->communication_bind("tcp://192.168.10.210:30005");
  37. // p_parkspace_allocation_communicater->communication_bind("tcp://192.168.1.38:30005");
  38. // p_parkspace_allocation_communicater->communication_run();
  39. //
  40. // message::Parkspace_allocation_status_msg parkspace_status;
  41. // for (size_t i = 1; i < 1000; i++)
  42. // {
  43. // message::Parkspace_info* space = parkspace_status.add_parkspace_info();
  44. // space->set_parkspace_id(i);
  45. // space->set_index(i);
  46. // space->set_direction(message::Direction::eForward);
  47. // space->set_floor(2+i);
  48. // space->set_length(5.5);
  49. // space->set_width(2.2);
  50. // space->set_height(1.75);
  51. // space->set_parkspace_status(message::Parkspace_status::eParkspace_empty);
  52. // }
  53. // message::Base_info base_msg;
  54. // message::Error_manager error;
  55. // base_msg.set_msg_type(message::Message_type::eParkspace_allocation_response_msg);
  56. // base_msg.set_timeout_ms(1000);
  57. // base_msg.set_sender(message::Communicator::eParkspace);
  58. // base_msg.set_receiver(message::Communicator::eMain);
  59. // error.set_error_code(0);
  60. // parkspace_status.mutable_base_info()->CopyFrom(base_msg);
  61. // parkspace_status.mutable_error_manager()->CopyFrom(error);
  62. // p_parkspace_allocation_communicater->update_parkspace_status(parkspace_status);
  63. int k=1;
  64. while(1) {
  65. // message::Parkspace_info space;
  66. // space.set_parkspace_id(3);
  67. // space.set_index(k);
  68. // space.set_direction(message::Direction::eForward);
  69. // space.set_floor(k*3);
  70. // space.set_length(5500);
  71. // space.set_width(2200);
  72. // space.set_height(k*400);
  73. // space.set_parkspace_status(message::Parkspace_status::eParkspace_occupied);
  74. // p_parkspace_allocator->update_parkspace_status(3, space);
  75. usleep(1000*1000);
  76. k++;
  77. }
  78. Database_controller::get_instance_pointer()->database_controller_uninit();
  79. return 0;
  80. }