net-service.cpp 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. #include <thread>
  2. #include <mutex>
  3. #include <atomic>
  4. #include <iostream>
  5. #include <memory>
  6. #include <string.h>
  7. #include <math.h>
  8. #include <log.h>
  9. #include <znet.h>
  10. #include <zstream.h>
  11. #include <sys/time.h>
  12. #include "worker.h"
  13. #include "tdoa_sync.h"
  14. #include "net-service.h"
  15. #include "ant.h"
  16. net_service::net_service()
  17. {
  18. m_loc_worker=nullptr;
  19. m_sync_worker=nullptr;
  20. m_loc_worker=worker::instance();
  21. m_sync_worker=tdoa_sync::instance();
  22. }
  23. net_service::~net_service()
  24. {
  25. if(m_loc_worker)
  26. m_loc_worker->stop();
  27. }
  28. void net_service::on_timer()
  29. {
  30. visit_site_status vss;
  31. sit_list::instance()->accept(vss);
  32. }
  33. void net_service::on_message(std::shared_ptr<client> clt,const char*data,size_t len)
  34. {
  35. logn_bin(1,"",data,len);//输出二进制日志
  36. zistream is(data,len-2);
  37. uint16_t cmd;
  38. is>>skip(2)>>cmd;
  39. switch(cmd)
  40. {
  41. case 0x843b://tof
  42. {
  43. uint32_t site_id;
  44. is>>site_id>>skip(12);
  45. auto site_ptr = sit_list::instance()->get(static_cast<int32_t>(site_id));
  46. if(!site_ptr)
  47. {
  48. log_error("在全局分站列表中找不到分站:分站id=%d", site_id);
  49. break;
  50. }
  51. site_ptr->set_client(clt);
  52. struct timeval tv;
  53. gettimeofday(&tv,NULL);
  54. uint64_t t = tv.tv_sec*1000 + tv.tv_usec/1000;
  55. int index=0;
  56. while(!is.eof())
  57. {
  58. uint64_t tstamp = t -1000 + 50 + index* 45;
  59. index++;
  60. task*t=task::alloc<message_locinfo>();
  61. message_locinfo&m=t->body<message_locinfo>();
  62. m.load(is,cmd==0x863b);
  63. m.m_time_stamp=tstamp;
  64. m.m_site_id=site_id;
  65. t->m_cmd_code=cmd;
  66. t->m_hash_id=m.m_card_id;
  67. m_loc_worker->request(t);
  68. }
  69. }
  70. break;
  71. case 0x863b://tdoa
  72. {
  73. uint32_t site_id;
  74. is>>site_id>>skip(12);
  75. while(!is.eof())
  76. {
  77. task*t=task::alloc<message_locinfo>();
  78. message_locinfo&m=t->body<message_locinfo>();
  79. m.load(is,cmd==0x863b);
  80. m.m_site_id=site_id;
  81. t->m_cmd_code=cmd;
  82. t->m_hash_id=m.m_card_id;
  83. m_sync_worker->translate(m);
  84. m_loc_worker->request(t);
  85. }
  86. }
  87. break;
  88. case 0xa78d://time sync
  89. {
  90. message_tdoasync m;
  91. m.load(is);
  92. m_sync_worker->on_message(m);
  93. }
  94. //site_message::on_sync(this,t.m_param1);
  95. break;
  96. case 0x853b://tof his
  97. case 0x873b://tdoa his
  98. break;
  99. case 0x804c://ctrl site message
  100. break;
  101. }
  102. }