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