package foundation.send.sms;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.dao.Filter;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.object.DataObject;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.server.Initializer;

public class SmsLoader extends Initializer{

	private static Logger logger;
	
	static {
		logger = LogManager.getLogger(SmsLoader.class);
	}
	
	@Override
	public void startUp() throws Exception {
		SmsCenter smsCenter = SmsCenter.getInstance();
		
		//1. 加载配置信息
		loadSmsConfig(smsCenter);
		
		loadSmsConfigDetail(smsCenter);
		
		//2. 注册action
		registerActions(smsCenter);
		
		//3. 激活配置
		smsCenter.activate();
	}

	private void registerActions(SmsCenter mailCenter) {
		AliyunSMSProvider aliyunSmsProvider = new AliyunSMSProvider();
		mailCenter.addOneProvider(aliyunSmsProvider);
	}

	private void loadSmsConfigDetail(SmsCenter smsCenter) {
		NamedSQL namedSQL = null;
		EntitySet entitySet = null;
		SmsBuilderDetail smsBuilderDetail = null;
		String parentId = "";
		
		logger.info("加载配置明细");
		try {
			 namedSQL = NamedSQL.getInstance("getSendConfigDetail");
			 namedSQL.setParam("type", "sms");
			 entitySet = SQLRunner.getEntitySet(namedSQL);
			 if (entitySet == null || entitySet.isEmpty()) {
				 return;
			 }
			 
			 for (Entity entity : entitySet) {
				  parentId = entity.getString("parent_id", "");
				  for (Map.Entry<String, SmsBuilder> smsEntry : smsCenter.getSmsBuilders().getItemMap().entrySet()) {
					   if (parentId.equalsIgnoreCase(smsEntry.getKey())) {
						   List<SmsBuilderDetail> smsBuilderDetailList = smsEntry.getValue().getSmsBuilderDetailList();
						   if (smsBuilderDetailList == null) {
							   smsBuilderDetailList = new ArrayList<SmsBuilderDetail>();
						   }
						   smsBuilderDetail = new SmsBuilderDetail();
						   smsBuilderDetail.setId(entity.getString("id", ""));
						   smsBuilderDetail.setParentId(entity.getString("parent_id", ""));
						   smsBuilderDetail.setBusinessCode(entity.getString("business_code", ""));
						   smsBuilderDetail.setBusinessName(entity.getString("business_name", ""));
						   smsBuilderDetail.setSubject(entity.getString("subject", ""));
						   smsBuilderDetail.setTemplate(entity.getString("template", ""));
						   smsBuilderDetail.setIsActive(entity.getString("is_active", ""));
						   smsBuilderDetail.setSignName(entity.getString("sign_name", ""));
						   smsBuilderDetail.setTemplateCode(entity.getString("template_code", ""));
						   smsBuilderDetailList.add(smsBuilderDetail);
						   smsEntry.getValue().setSmsBuilderDetailList(smsBuilderDetailList);
						   break;
					   }
				  }			  
			 }			
		} catch(Exception e) {
			 e.printStackTrace();
		}
	}

	private void loadSmsConfig(SmsCenter smsCenter) {
		DataObject dataObject = DataObject.getInstance("sys_send_config");
		EntitySet entitySet = null;
		Filter filter = new Filter();
		String platForm = "", id = "";
		SmsBuilder smsBuilder = null;
		logger.info("加载配置主体");
		
		try {
			 filter.add("type", "sms"); 
			 entitySet = dataObject.getTableEntitySet(filter);
			 if (entitySet == null || entitySet.isEmpty()) {
				 return;
			 }
			 for (Entity entity : entitySet) {
				  platForm = entity.getString("name", "");
				  id = entity.getString("id", "");
				  for (Entry<String, SmsConfig> smsEntry : SmsConfigerLoader.getSmsConfigMap().entrySet()) {
					   if (platForm.equalsIgnoreCase(smsEntry.getKey())) {
						   smsBuilder = new SmsBuilder();
						   smsBuilder.setId(entity.getString("id", ""));
						   smsBuilder.setType(entity.getString("type", ""));
						   smsBuilder.setName(entity.getString("name", ""));
						   smsBuilder.setSendAccount(entity.getString("account", ""));
						   smsBuilder.setPassword(entity.getString("password", ""));
						   smsBuilder.setIsActive(entity.getString("is_active", ""));
						   smsBuilder.setSmsConfig(smsEntry.getValue());
						   smsCenter.getSmsBuilders().add(id, smsBuilder);
						   break;
					   }
				  }			  
			 }
		} catch(Exception e) {
			 e.printStackTrace();
		}
	}

	@Override
	public void shutDown() throws Exception {
		// TODO Auto-generated method stub
	}

}