module_attendance_vehicle.h 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  1. #ifndef MODULE_ATTENDANCE_VEHICLE_H
  2. #define MODULE_ATTENDANCE_VEHICLE_H
  3. /**
  4. *@brief 车辆考勤模块
  5. *车辆进入某些特定区域,结束考勤;从特定区域进入其他区域,开始考勤
  6. *@author 戴月腾
  7. *@date 2018-08-07
  8. */
  9. #include <memory>
  10. #include <mutex>
  11. #include <map>
  12. #include <string>
  13. #include <chrono>
  14. #include <vector>
  15. #include <set>
  16. #include "module_const.h"
  17. #include "common_tool.h"
  18. #include"module_meta_date_changed.h"
  19. /**
  20. * @brief 车辆进入某些特定区域,结束考勤;从特定区域进入其他区域,开始考勤, 单例
  21. */
  22. class module_attendance_vehicle:public singleton_base<module_attendance_vehicle>
  23. {
  24. private:
  25. friend class singleton_base<module_attendance_vehicle>;
  26. module_attendance_vehicle()
  27. {
  28. }
  29. public:
  30. void on_enter(std::shared_ptr<card_location_base> card_ptr, std::shared_ptr<area_hover>&c)
  31. {
  32. auto area_ptr = c->m_area;
  33. //从考勤状态转换为结束考勤
  34. if(is_not_attendance_area(area_ptr->m_id, card_ptr->get_vehicle_type_id()))
  35. {
  36. save_attendance(card_ptr, area_ptr);
  37. }
  38. else//没在考勤状态转换为考勤状态
  39. {
  40. auto mine_tool_ptr = card_ptr->get_mine_tool();
  41. if(!mine_tool_ptr->is_attendance())
  42. {
  43. //考勤开始
  44. mine_tool_ptr->m_stat_attendance=AS_ATTENDANCE;
  45. mine_tool_ptr->m_attendance_start_time=std::chrono::system_clock::now();
  46. //作为一条开始考勤记录保存到数据库
  47. tool_db::save_attendance(card_ptr);
  48. log_info("车卡考勤开始:卡id=%d,卡type=%d,区域id=%d, stat_attendance=%d",
  49. card_ptr->m_id, card_ptr->m_type,
  50. area_ptr->m_id,mine_tool_ptr->m_stat_attendance);
  51. }
  52. }
  53. }
  54. // void on_hover(std::shared_ptr<card_location_base> card_ptr,std::shared_ptr<area_hover>&c)
  55. // {
  56. // }
  57. // void on_leave(std::shared_ptr<card_location_base> card_ptr,std::shared_ptr<area_hover>&c)
  58. // {
  59. // }
  60. void init_attendance_area_from_db()
  61. {
  62. const char *sql = "select a.area_id, a.att_rule_id, vt.vehicle_type_id \
  63. from dat_att_rule_area a, dat_att_rule_vehicle_type vt, dat_att_rule r\
  64. where a.att_rule_id=vt.att_rule_id and a.att_rule_id=r.att_rule_id;";
  65. std::string Error;
  66. YADB::CDBResultSet DBRes;
  67. sDBConnPool.Query(sql,DBRes,Error);
  68. if(!Error.empty())
  69. log_error("初始化attendance_area Error,%s",Error.c_str());
  70. uint64_t nCount = DBRes.GetRecordCount( Error );
  71. if (nCount > 0)
  72. {
  73. log_info( "init_attendance_area_from_db. The record count=%ld\n", nCount );
  74. m_map.clear();
  75. while ( DBRes.GetNextRecod(Error) )
  76. {
  77. int area_id = 0;
  78. DBRes.GetField( "area_id",area_id, Error );
  79. int att_rule_id = 0;
  80. DBRes.GetField( "att_rule_id",att_rule_id, Error );
  81. int vehicle_type_id = 0;
  82. DBRes.GetField( "vehicle_type_id",vehicle_type_id, Error );
  83. m_map.insert(std::make_pair(to_list_id(area_id, vehicle_type_id), att_rule_id));
  84. }
  85. }
  86. }
  87. ///area_ptr==nullptr 表示接收到 web的删除卡命令
  88. static void save_attendance(std::shared_ptr<card_location_base>& card_ptr, std::shared_ptr<area> area_ptr)
  89. {
  90. auto mine_tool_ptr = card_ptr->get_mine_tool();
  91. if(!mine_tool_ptr->is_attendance())
  92. {
  93. return;
  94. }
  95. //考勤结束
  96. mine_tool_ptr->m_stat_attendance=AS_NOT_ATTENDANCE;
  97. //作为一条结束考勤记录保存到数据库
  98. tool_db::save_attendance(card_ptr);
  99. if(area_ptr)
  100. {
  101. log_info("车卡考勤结束:卡id=%d,卡type=%d,区域id=%d, stat_attendance=%d",
  102. card_ptr->m_id, card_ptr->m_type,
  103. area_ptr->m_id,mine_tool_ptr->m_stat_attendance);
  104. }
  105. else
  106. {
  107. log_info("收到web的删除卡命令,车卡考勤结束:卡id=%d,卡type=%d,stat_attendance=%d",
  108. card_ptr->m_id, card_ptr->m_type,mine_tool_ptr->m_stat_attendance);
  109. }
  110. }
  111. private:
  112. bool is_not_attendance_area(int area_id, int vehicle_type_id)
  113. {
  114. return m_map.end() != m_map.find(to_list_id(area_id, vehicle_type_id));
  115. }
  116. uint64_t to_list_id(int area_id, int vehicle_type_id)
  117. {
  118. return (static_cast<uint64_t>(area_id)<<32) | static_cast<uint64_t>(vehicle_type_id);
  119. }
  120. ///area_id<<32| vehicle_type_id; att_rule_id
  121. std::unordered_map<uint64_t, int> m_map;
  122. };
  123. #endif // MODULE_ATTENDANCE_VEHICLE_H