package foundation.alert;

import foundation.action.ActionProvider;

public class AlertHandler extends ActionProvider {

	private static AlertHandler instance;
	
	@Override
	protected void publishMethod() {
		//1. 得到当前编码
		addMethod("sendAlertBatch");
		
		//2. 批量发送
		addMethod("sendAlertOne");
	}
	
	public static synchronized AlertHandler getInstance() {
		if (instance == null) {
			instance = new AlertHandler();
		}
		
		return instance;
	}

	public void sendAlertBatch() throws Exception {
		String ruleId;
		
		if (dataReader != null) {
			ruleId = dataReader.getString("ruleId");
		}
		else {
			ruleId = context.getParam();
		}
		
		AlertRuleBucket alertRuleBucket = AlertRuleBucket.getInstance();
		AlertRule alertRule = alertRuleBucket.getAlertRule(ruleId);
		
		alertRule.executeBatch();
	}
	
	public void sendAlertOne() throws Exception {
		String ruleId = dataReader.getString("ruleId");
		String documentId = dataReader.getString("id");
		
		AlertRuleBucket alertRuleBucket = AlertRuleBucket.getInstance();		
		AlertRule alertRule = alertRuleBucket.getAlertRule(ruleId);
		
		alertRule.executeOne(documentId);
	}
	
}