package foundation.alert;

import foundation.dao.Filter;
import foundation.dao.OrderBy;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
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
	}
}