| Line 56... |
Line 56... |
| 56 |
return null;
|
56 |
return null;
|
| 57 |
}
|
57 |
}
|
| 58 |
|
58 |
|
| 59 |
public void endMonitoring(EntityType entityType, String key) {
|
59 |
public void endMonitoring(EntityType entityType, String key) {
|
| 60 |
in.shop2020.alert.domain.MonitoredEntity entity = entityMapper.getEntity(entityType, key);
|
60 |
in.shop2020.alert.domain.MonitoredEntity entity = entityMapper.getEntity(entityType, key);
|
| - |
|
61 |
if(entity!=null){
|
| 61 |
if(entity.getEntityProcessedState().getValue() > EntityProcessedState.UNEXPIRED.getValue()) {
|
62 |
if(entity.getEntityProcessedState().getValue() > EntityProcessedState.UNEXPIRED.getValue()) {
|
| 62 |
in.shop2020.alert.domain.AlertedEntity alertedEntity = new in.shop2020.alert.domain.AlertedEntity();
|
63 |
in.shop2020.alert.domain.AlertedEntity alertedEntity = new in.shop2020.alert.domain.AlertedEntity();
|
| 63 |
alertedEntity.setEntityType(entity.getEntityType());
|
64 |
alertedEntity.setEntityType(entity.getEntityType());
|
| 64 |
alertedEntity.setEventType(entity.getEventType());
|
65 |
alertedEntity.setEventType(entity.getEventType());
|
| 65 |
alertedEntity.setEntityIdentifier(entity.getEntityIdentifier());
|
66 |
alertedEntity.setEntityIdentifier(entity.getEntityIdentifier());
|
| 66 |
alertedEntity.setEntityProperties(entity.getEntityProperties());
|
67 |
alertedEntity.setEntityProperties(entity.getEntityProperties());
|
| 67 |
if(entity.getEntityProcessedState().getValue() == EntityProcessedState.WARNING_SENT.getValue()) {
|
68 |
if(entity.getEntityProcessedState().getValue() == EntityProcessedState.WARNING_SENT.getValue()) {
|
| 68 |
alertedEntity.setLastAlertedTime(entity.getWarnExpiryTime());
|
69 |
alertedEntity.setLastAlertedTime(entity.getWarnExpiryTime());
|
| 69 |
alertedEntity.setEntityProcessedState(EntityProcessedState.WARNING_SENT);
|
70 |
alertedEntity.setEntityProcessedState(EntityProcessedState.WARNING_SENT);
|
| 70 |
entityMapper.insertAlertedEntity(alertedEntity);
|
71 |
entityMapper.insertAlertedEntity(alertedEntity);
|
| 71 |
|
72 |
|
| 72 |
AlertMapper alertMap;
|
73 |
AlertMapper alertMap;
|
| 73 |
String delayedEventDescription = "UNKNOWN";
|
74 |
String delayedEventDescription = "UNKNOWN";
|
| 74 |
alertMap = getAlertMapper(entity.getEntityType(), entity.getEventType());
|
75 |
alertMap = getAlertMapper(entity.getEntityType(), entity.getEventType());
|
| 75 |
if(alertMap!=null) {
|
76 |
if(alertMap!=null) {
|
| 76 |
delayedEventDescription = alertMap.getEventdesciption();
|
77 |
delayedEventDescription = alertMap.getEventdesciption();
|
| 77 |
}
|
78 |
}
|
| 78 |
alertLogger.warn("\tEntityType=" +
|
79 |
alertLogger.warn("\tEntityType=" +
|
| 79 |
entity.getEntityType() + " ; " + "\t" + entity.getEntityIdentifier() +
|
80 |
entity.getEntityType() + " ; " + "\t" + entity.getEntityIdentifier() +
|
| 80 |
"\tEventType=" + delayedEventDescription + " ; " + "AlertSeverity=WARN ; " +
|
81 |
"\tEventType=" + delayedEventDescription + " ; " + "AlertSeverity=WARN ; " +
|
| 81 |
"ExpiredTime=" + entity.getWarnExpiryTime());
|
82 |
"ExpiredTime=" + entity.getWarnExpiryTime());
|
| 82 |
}
|
83 |
}
|
| 83 |
else {
|
84 |
else {
|
| 84 |
alertedEntity.setLastAlertedTime(entity.getCriticalExpiryTime());
|
85 |
alertedEntity.setLastAlertedTime(entity.getCriticalExpiryTime());
|
| 85 |
alertedEntity.setEntityProcessedState(EntityProcessedState.CRITICAL_SENT);
|
86 |
alertedEntity.setEntityProcessedState(EntityProcessedState.CRITICAL_SENT);
|
| 86 |
entityMapper.insertAlertedEntity(alertedEntity);
|
87 |
entityMapper.insertAlertedEntity(alertedEntity);
|
| 87 |
|
88 |
|
| 88 |
AlertMapper alertMap;
|
89 |
AlertMapper alertMap;
|
| 89 |
String delayedEventDescription = "UNKNOWN";
|
90 |
String delayedEventDescription = "UNKNOWN";
|
| 90 |
alertMap = getAlertMapper(entity.getEntityType(), entity.getEventType());
|
91 |
alertMap = getAlertMapper(entity.getEntityType(), entity.getEventType());
|
| 91 |
if(alertMap!=null) {
|
92 |
if(alertMap!=null) {
|
| 92 |
delayedEventDescription = alertMap.getEventdesciption();
|
93 |
delayedEventDescription = alertMap.getEventdesciption();
|
| 93 |
}
|
94 |
}
|
| 94 |
alertLogger.error("\tEntityType=" +
|
95 |
alertLogger.error("\tEntityType=" +
|
| 95 |
entity.getEntityType() + " ; " + "\t" + entity.getEntityIdentifier() +
|
96 |
entity.getEntityType() + " ; " + "\t" + entity.getEntityIdentifier() +
|
| 96 |
"\tEventType=" + delayedEventDescription + " ; " + "AlertSeverity=CRITICAL ; " +
|
97 |
"\tEventType=" + delayedEventDescription + " ; " + "AlertSeverity=CRITICAL ; " +
|
| 97 |
"ExpiredTime=" + entity.getCriticalExpiryTime());
|
98 |
"ExpiredTime=" + entity.getCriticalExpiryTime());
|
| - |
|
99 |
}
|
| 98 |
}
|
100 |
}
|
| - |
|
101 |
entityMapper.removeMonitoredEntity(entityType, key);
|
| 99 |
}
|
102 |
}
|
| 100 |
entityMapper.removeMonitoredEntity(entityType, key);
|
- |
|
| 101 |
}
|
103 |
}
|
| 102 |
|
104 |
|
| 103 |
public void updateMonitoredObject(MonitoredEntity monitoredEntity)
|
105 |
public void updateMonitoredObject(MonitoredEntity monitoredEntity)
|
| 104 |
throws AlertServiceException{
|
106 |
throws AlertServiceException{
|
| 105 |
in.shop2020.alert.domain.MonitoredEntity entity = entityMapper.getEntity(monitoredEntity.getEntityType(),
|
107 |
in.shop2020.alert.domain.MonitoredEntity entity = entityMapper.getEntity(monitoredEntity.getEntityType(),
|