main.cpp 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. #include <ev++.h>
  2. #include <log.h>
  3. #include <net-service.h>
  4. #include "db_api/CDBSingletonDefine.h"
  5. #include "websocket/wsClientMgr.h"
  6. #include "websocket/wsTimerThread.h"
  7. #include "card.h"
  8. #include "ant.h"
  9. #include "area.h"
  10. #include "card_path.h"
  11. #include "landmark.h"
  12. #include "special_area.h"
  13. #include "mine.h"
  14. #include "event.h"
  15. #include"module_service/module_mgr.h"
  16. #include <config_file.h>
  17. #include "three_rates.h"
  18. #include "mine_business.h"
  19. #include "main_test.h"
  20. #include "ya_setting.h"
  21. config_file config;
  22. static void handlereader(uint32_t readerid,bool duration,uint32_t t)
  23. {
  24. }
  25. struct Init_Setting
  26. {
  27. void init()
  28. {
  29. std::string url=config.get("service.websocket_url","ws://127.0.0.1:8086");
  30. int32_t send_interval =config.get("service.interval_send_json_postion",1);
  31. std_info("json_interval:%d",send_interval);
  32. std::vector<std::string> url_list;
  33. url_list.push_back(url);
  34. wsClientMgr_init(url_list,send_interval);//init websocket
  35. YADB::_DB_POOL_SETTING_ DBSetting;
  36. DBSetting.Host = config.get("db.host","127.0.0.1");
  37. DBSetting.User = config.get("db.user","root");
  38. DBSetting.PWD = config.get("db.passwd","123456");
  39. DBSetting.DBName = config.get("db.dbname","yaxt");
  40. DBSetting.CharSet = config.get("db.charset","utf8");
  41. DBSetting.TimeOut = config.get("db.conn_timeout",5);
  42. DBSetting.PoolSize = config.get("db.pool_size",30);
  43. _mysql_init(DBSetting);
  44. CYaSetting::Init_sys_setting();
  45. sit_list::instance()->load_from_db();
  46. card_list::instance()->init_card_from_db();
  47. std_info("here....");
  48. area_list::instance()->init_from_db();
  49. std_info("here....");
  50. Landmark_list::instance()->init_from_db();
  51. //auto a = Landmark_list::instance()->get(5,id,pt);
  52. //std_info("test landmark:id:%d,dir:%d,dis:%.2f",std::get<0>(a),std::get<1>(a),std::get<2>(a));
  53. special_area_list::instance()->init_from_db();
  54. //auto s = special_area_list::instance()->get_special_id(1013,point(4727,-254),2);
  55. //std_info("test special_area:%d",s);
  56. getchar();
  57. mine_business::inst()->load();
  58. card_list::instance()->load_his_card_postion_from_db();
  59. event_list::instance()->load_his_data_from_db();
  60. db_para dp;
  61. dp.Host=DBSetting.Host;
  62. dp.User=DBSetting.User;
  63. dp.PWD=DBSetting.PWD ;
  64. dp.DBName=DBSetting.DBName;
  65. dp.CharSet=DBSetting.CharSet ;
  66. dp.TimeOut=DBSetting.TimeOut;
  67. dp.PoolSize=DBSetting.PoolSize;
  68. init_three_rates(dp);
  69. printf("Init_Setting::init Success. \n" );
  70. }
  71. void init_three_rates(const db_para& dbs)
  72. {
  73. std_info("three_rates ...................");
  74. init_para ip;
  75. ip.send_pt = handlereader;
  76. three_rates::get_instance()->init(ip,dbs);
  77. three_rates::get_instance()->start();
  78. }
  79. void _mysql_init(YADB::_DB_POOL_SETTING_ &dps)
  80. {
  81. std::string szError = "";
  82. //创建连接池
  83. if ( !sDBConnPool.Create( dps, szError ) )
  84. {
  85. log_error("数据库线程池创建失败,Err=%s\n", szError.c_str());
  86. }
  87. }
  88. void wsClientMgr_init(const std::vector<std::string>&uri_list,int32_t st)
  89. {
  90. std::map<std::string, YA::MSG_HANDLE_FUNC_TYPE> MsgFuncList;
  91. //MsgFuncList.insert( std::make_pair( "req_all_person_on_car", On_req_all_person_on_car ) );
  92. module_mgr::init(config, MsgFuncList);
  93. swsClientMgr.Build( uri_list, MsgFuncList );
  94. //连接服务器
  95. if ( swsClientMgr.connect() != 0 )
  96. {
  97. log_error("web socket init failed.");
  98. std_error("web socket init failed.");
  99. return;
  100. }
  101. //登录
  102. swsClientMgr.login();
  103. //init thread...
  104. YA::_THREAD_CONFIG_ Config;
  105. Config.SendInterval = st;
  106. swsTimerThrd.Init( Config );
  107. swsTimerThrd.Start();
  108. }
  109. };
  110. void cleanup()
  111. {
  112. module_mgr::stop();
  113. }
  114. void usage(char ** argv)
  115. {
  116. std::string cmd(argv[1]);
  117. if(cmd=="--help" || cmd == "-H")
  118. {
  119. printf("用法:yals [选项]文件...\n");
  120. printf("选项:\n");
  121. printf("--help 显示此帮助说明\n");
  122. printf("-v|--version 显示采集程序版本信息\n");
  123. }
  124. else if(cmd == "--version" || cmd == "-v")
  125. {
  126. printf("yals (采集程序) 0.1.0\n");
  127. }
  128. else
  129. {
  130. printf("Unknown option:%s\n",cmd.c_str());
  131. printf( "usage:yals [--version][--help][-v][-H]\n");
  132. }
  133. }
  134. int main(int argc ,char * argv[])
  135. {
  136. if(argc >1)
  137. {
  138. usage(argv);
  139. return 0;
  140. }
  141. log_init("../etc/log.ini");
  142. if(config.open("../etc/config.ini"))
  143. return -1;
  144. Init_Setting is;
  145. is.init();
  146. card_path::init();
  147. test_find_path(point(4600,-75),point(4727,-90));
  148. module_mgr::start();
  149. atexit(&cleanup);
  150. printf("\nservice_handle::instance(&mh)->run(%d); \n",4000);
  151. net_service mh;
  152. int port=config.get("service.port",4000);
  153. service_handle::instance(&mh)->run(port);
  154. sDBConnPool.Close();
  155. sleep(1);
  156. printf("YA-SERV Server Exit ...\n");
  157. return 0;
  158. }