1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
#include "XStateChangeFieldsImp.h"
const std::string XEnumStateChangeFieldsStateChangeFieldsVersionMapping[] = {
"4.0"
};
const std::string XEnumStateChangeFieldsStateMapping[] = {
"inService",
"maintenance",
"outOfService"
};
XStateChangeFieldsImp::XStateChangeFieldsImp(std::shared_ptr<XCommonEventHeader> header,
XEnumStateChangeFieldsState newState,
XEnumStateChangeFieldsState oldState,
const XString& stateInterface):
header_(header),
newState_(newState),
oldState_(oldState),
stateChangeFieldsVersion_(XEnumStateChangeFieldsStateChangeFieldsVersion4_0),
stateInterface_(stateInterface)
{
}
std::string XStateChangeFieldsImp::toString()
{
try
{
auto js = toJson();
return js.dump();
}
catch (json::exception& e)
{
SPDLOG_ERROR("Fail to dump XStateChangeFields to json string:{}.", e.what());
return "";
}
}
void XStateChangeFieldsImp::setNewState(XEnumStateChangeFieldsState newState)
{
auto val = XEnumStateChangeFieldsStateMapping[newState];
comVals_["newState"] = val;
}
void XStateChangeFieldsImp::setOldState(XEnumStateChangeFieldsState oldState)
{
auto val = XEnumStateChangeFieldsStateMapping[oldState];
comVals_["oldState"] = val;
}
void XStateChangeFieldsImp::setAdditionalFields(const XHashMap& additionalFields)
{
additionalFields_ = additionalFields;
}
void XStateChangeFieldsImp::setStateInterface(const XString& stateInterface)
{
comVals_["stateInterface"] = stateInterface;
}
json XStateChangeFieldsImp::toJson()
{
try
{
json field = {
{"stateChangeFieldsVersion", XEnumStateChangeFieldsStateChangeFieldsVersionMapping[stateChangeFieldsVersion_]},
{"newState", XEnumStateChangeFieldsStateMapping[newState_]},
{"oldState", XEnumStateChangeFieldsStateMapping[oldState_]},
{"stateInterface", stateInterface_}
};
//optional val
if (!additionalFields_.empty())
{
field["additionalFields"] = additionalFields_;
}
field = mergeCommonValues(field, comVals_);
json jsEvent;
header_->setDomain(XEnumCommonEventHeaderDomainStateChange);
jsEvent["event"]["commonEventHeader"] = dynamic_pointer_cast<XJsonable>(header_)->toJson();
jsEvent["event"]["stateChangeFields"] = field;
return jsEvent;
}
catch (json::exception& e)
{
SPDLOG_ERROR("Fail to build XStateChangeFields to json object:{}.", e.what());
return json();
}
}
std::shared_ptr<XCommonEventHeader> XStateChangeFieldsImp::getCommonHeader()
{
return header_;
}
|
