main.cpp 5.4 KB

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