1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
3 #include "db_ido/timeperioddbobject.hpp"
4 #include "db_ido/dbtype.hpp"
5 #include "db_ido/dbvalue.hpp"
6 #include "icinga/timeperiod.hpp"
7 #include "icinga/legacytimeperiod.hpp"
8 #include "base/utility.hpp"
9 #include "base/exception.hpp"
10 #include "base/objectlock.hpp"
12 using namespace icinga;
14 REGISTER_DBTYPE(TimePeriod, "timeperiod", DbObjectTypeTimePeriod, "timeperiod_object_id", TimePeriodDbObject);
16 TimePeriodDbObject::TimePeriodDbObject(const DbType::Ptr& type, const String& name1, const String& name2)
17 : DbObject(type, name1, name2)
20 Dictionary::Ptr TimePeriodDbObject::GetConfigFields() const
22 TimePeriod::Ptr tp = static_pointer_cast<TimePeriod>(GetObject());
24 return new Dictionary({
25 { "alias", tp->GetDisplayName() }
29 Dictionary::Ptr TimePeriodDbObject::GetStatusFields() const
34 void TimePeriodDbObject::OnConfigUpdateHeavy()
36 TimePeriod::Ptr tp = static_pointer_cast<TimePeriod>(GetObject());
39 query_del1.Table = GetType()->GetTable() + "_timeranges";
40 query_del1.Type = DbQueryDelete;
41 query_del1.Category = DbCatConfig;
42 query_del1.WhereCriteria = new Dictionary({
43 { "timeperiod_id", DbValue::FromObjectInsertID(tp) }
47 Dictionary::Ptr ranges = tp->GetRanges();
52 time_t refts = Utility::GetTime();
53 ObjectLock olock(ranges);
54 for (const Dictionary::Pair& kv : ranges) {
55 int wday = LegacyTimePeriod::WeekdayFromString(kv.first);
60 tm reference = Utility::LocalTime(refts);
62 Array::Ptr segments = new Array();
63 LegacyTimePeriod::ProcessTimeRanges(kv.second, &reference, segments);
65 ObjectLock olock(segments);
66 for (const Value& vsegment : segments) {
67 Dictionary::Ptr segment = vsegment;
68 int begin = segment->Get("begin");
69 int end = segment->Get("end");
72 query.Table = GetType()->GetTable() + "_timeranges";
73 query.Type = DbQueryInsert;
74 query.Category = DbCatConfig;
75 query.Fields = new Dictionary({
76 { "instance_id", 0 }, /* DbConnection class fills in real ID */
77 { "timeperiod_id", DbValue::FromObjectInsertID(tp) },
79 { "start_sec", begin % 86400 },
80 { "end_sec", end % 86400 }