|
@@ -123,19 +123,7 @@ void Event::handle_alarm_event(EVENT_TYPE et,uint64_t id,double limit_value,doub
|
|
}
|
|
}
|
|
if(ev_ptr)
|
|
if(ev_ptr)
|
|
{
|
|
{
|
|
- char sql[LENGTH_SQL] = {0};
|
|
|
|
- std::string _time = tool_time::to_str_ex(ev_ptr->m_cur_time);
|
|
|
|
- sprintf(sql,
|
|
|
|
- "INSERT IGNORE INTO his_event_data(event_id, stat, event_type_id, obj_type_id, obj_id, \
|
|
|
|
- map_id, area_id, limit_value, cur_value, x, y, cur_time, description, \
|
|
|
|
- landmark_id, landmark_dist,direction_mapper_id )\
|
|
|
|
- VALUES(%ld, %d, %d, %d, %s, %d, %d, %.2f, %.2f, %f, %f, '%s', '%s', %d, %10.3f, %d);",
|
|
|
|
- ev_ptr->get_id(), ev_ptr->m_status, ev_ptr->m_ev_type, ev_ptr->m_obj_type, ev_ptr->m_obj_id.c_str(),
|
|
|
|
- ev_ptr->m_map_id, ev_ptr->m_area_id, ev_ptr->m_limit_value, ev_ptr->m_cur_value, ev_ptr->x, ev_ptr->y,
|
|
|
|
- _time.c_str(), ev_ptr->m_desc.c_str(),
|
|
|
|
- ev_ptr->m_landmarkid, ev_ptr->m_landmarkdist, ev_ptr->m_landmarkdirect);
|
|
|
|
-
|
|
|
|
- db_tool::PushAsync(sql);
|
|
|
|
|
|
+ event_list::save_event(ev_ptr);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -228,6 +216,23 @@ std::shared_ptr<ya_event> event_list::get_event_card(uint32_t card_id, int card_
|
|
return base::get(to_list_id(ev_type, OT_CARD, id64));
|
|
return base::get(to_list_id(ev_type, OT_CARD, id64));
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+void event_list::save_event(std::shared_ptr<ya_event> ev_ptr)
|
|
|
|
+{
|
|
|
|
+ char sql[LENGTH_SQL] = {0};
|
|
|
|
+ std::string _time = tool_time::to_str_ex(ev_ptr->m_cur_time);
|
|
|
|
+ sprintf(sql,
|
|
|
|
+ "INSERT IGNORE INTO his_event_data(event_id, stat, event_type_id, obj_type_id, obj_id, \
|
|
|
|
+ map_id, area_id, limit_value, cur_value, x, y, cur_time, description, \
|
|
|
|
+ landmark_id, landmark_dist,direction_mapper_id )\
|
|
|
|
+ VALUES(%ld, %d, %d, %d, %s, %d, %d, %.2f, %.2f, %f, %f, '%s', '%s', %d, %10.3f, %d);",
|
|
|
|
+ ev_ptr->get_id(), ev_ptr->m_status, ev_ptr->m_ev_type, ev_ptr->m_obj_type, ev_ptr->m_obj_id.c_str(),
|
|
|
|
+ ev_ptr->m_map_id, ev_ptr->m_area_id, ev_ptr->m_limit_value, ev_ptr->m_cur_value, ev_ptr->x, ev_ptr->y,
|
|
|
|
+ _time.c_str(), ev_ptr->m_desc.c_str(),
|
|
|
|
+ ev_ptr->m_landmarkid, ev_ptr->m_landmarkdist, ev_ptr->m_landmarkdirect);
|
|
|
|
+
|
|
|
|
+ db_tool::PushAsync(sql);
|
|
|
|
+}
|
|
|
|
+
|
|
void event_list::load_his_data_from_db()
|
|
void event_list::load_his_data_from_db()
|
|
{
|
|
{
|
|
std::unordered_map<uint64_t, std::shared_ptr<ya_event>> map;
|
|
std::unordered_map<uint64_t, std::shared_ptr<ya_event>> map;
|