package biz.notify;
|
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.entity.Filter;
|
import foundation.data.entity.OrderBy;
|
import foundation.data.object.DataObject;
|
import foundation.server.Initializer;
|
|
public class AlertRuleLoader extends Initializer {
|
|
@Override
|
public void startUp() throws Exception {
|
load();
|
}
|
|
private void load() throws Exception {
|
AlertRuleBucket ruleBucket = AlertRuleBucket.getInstance();
|
loadAlterRule(ruleBucket);
|
}
|
|
private void loadAlterRule(AlertRuleBucket ruleBucket) throws Exception {
|
DataObject dataObject = DataObject.getInstance("sys_alert_setting");
|
EntitySet entitySet = dataObject.getTableEntitySet();
|
|
for (Entity entity: entitySet) {
|
ruleBucket.loadOneRule(entity);
|
}
|
|
//2. 通知对象
|
dataObject = DataObject.getInstance("sys_alert_notifier");
|
entitySet = dataObject.getTableEntitySet(new Filter("is_active", "T"), new OrderBy("parent_id"));
|
AlertRule rule;
|
|
for (Entity entity: entitySet) {
|
rule = ruleBucket.getCachedOne(entity.getString("parent_id"));
|
rule.loadOneNotifier(entity);
|
}
|
}
|
|
@Override
|
public void shutDown() throws Exception {
|
// TODO Auto-generated method stub
|
}
|
}
|