package com.base.util;

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

import com.amarsoft.app.alarm.AlarmMessage;
import com.amarsoft.app.alarm.CheckItem;
import com.amarsoft.app.alarm.DefaultCheckItemRunner;
import com.amarsoft.app.alarm.DefaultScenarioContextLoader;
import com.amarsoft.app.alarm.ItemGroup;
import com.amarsoft.app.alarm.ScenarioContext;
import com.amarsoft.app.alarm.ScenarioContextLoader;
import com.amarsoft.app.alarm.StringTool;
import com.amarsoft.are.ARE;
import com.amarsoft.are.jbo.JBOTransaction;
import com.amarsoft.are.lang.StringX;
import com.amarsoft.awe.util.ObjectConverts;
import com.amarsoft.awe.util.Transaction;
import com.tenwa.flow.warning.Warning;

public class ScenarioUtil {
	List<Map<String, Object>> list;
	String sMsg;

	public String getsMsg() {
		return sMsg;
	}

	public List<Map<String, Object>> getList() {
		return list;
	}

	public boolean autoRiskScan(String sScenarioID, String sBizArgs,
			String sSubTypeNo, JBOTransaction tx, Transaction sqlca)
			throws Exception {

		boolean sReturn = true;
		if (StringX.isSpace(sScenarioID)) {
			sMsg = "sScenarioID不能为空!";
			return false;
		}
		if (StringX.isSpace(sBizArgs)) {
			sMsg = "sBizArgs不能为空!";
			return false;
		}

		Warning warning = new Warning();
		warning.setScenarioid(sScenarioID);
		warning.setSubTypeNo(sSubTypeNo);
		String sRes = warning.selectByScenarioid(tx);

		String autoCommit = "false";
		if ("failed".equals(sRes.toLowerCase())) {
			sMsg = "无需风险预警!";
			return true;
		} else {
			if (sBizArgs.indexOf("isAutoCommit=true") >= 0) {
				autoCommit = "true";
			}
			// 获得组件参数
			System.out.println(sBizArgs);
			sBizArgs = sBizArgs.replace("&", ",");
			ARE.getLog().debug("传入业务参数:" + sBizArgs);
			// 加载器
			ScenarioContextLoader loader = new DefaultScenarioContextLoader();
			((DefaultScenarioContextLoader) loader).init(sqlca, sScenarioID,
					sBizArgs, sSubTypeNo);
			ScenarioContext context = loader.getContext(); // 获取下文容器
			context.setCheckItemRunner(new DefaultCheckItemRunner()); // 模型运行器
			String scenarioSerializable = ObjectConverts.getString(context); // 序列化

			List<ItemGroup> gList0 = context.getScenario().getGroupList();
			List<ItemGroup> gList = new ArrayList<ItemGroup>();

			// 根据运行条件进行预处理,分组下检查项检查条件均没通过，则不显示该分组
			for (int i = 0; i < gList0.size(); i++) {
				ItemGroup group = gList0.get(i);
				List<CheckItem> ckList0 = group.getCheckItemList();
				List<CheckItem> ckList1 = new ArrayList<CheckItem>(); // 存放检查通过的
				for (int j = 0; j < ckList0.size(); j++) {
					CheckItem ckItem = ckList0.get(j);
					String sCondition = ckItem.getRunCondition(); // 运行条件
					if (sCondition != null && sCondition.length() > 0) {
						boolean bCondition = StringTool.runAmarScript(sqlca,
								sCondition, context.getParameter())
								.booleanValue();
						if (!bCondition)
							continue;
						else
							ckList1.add(ckItem);
					} else {
						ckList1.add(ckItem);
					}
				}
				if (ckList1.size() > 0) { // 重组分组
					group.getCheckItemList().clear();
					group.getCheckItemList().addAll(ckList1);
					gList.add(group);
				}
			}
			for (int i = 0; i < gList.size(); i++) {
				ItemGroup group = gList.get(i);
				List<CheckItem> ckList = group.getCheckItemList();
				String sGroupId = group.getGroupID();
				String sGroupName = group.getGroupName();
				list = new ArrayList<Map<String, Object>>();
				for (int j = 0; j < ckList.size(); j++) {
					CheckItem ckItem = ckList.get(j);
					// String sItemId = ckItem.getItemID();
					String viewerScript = ckItem.getBizViewer();
					if (viewerScript == null)
						viewerScript = "";
					else
						viewerScript = StringTool.pretreat(
								context.getParameter(), viewerScript);
					
					if (ckItem.getItemID().equals("0028")) {
						autoCommit="fales";
						continue;
					} else {
						String sItemName = ckItem.getItemName();
						String sItemId = ckItem.getItemID();
						try {
							Map<String, Object> map = alarmModelInvoker(
									sGroupId, sItemId, sqlca, tx,
									scenarioSerializable);
							map.put("sItemName", sItemName);
							map.put("sGroupName", sGroupName);
							list.add(map);
							if (map.get("sStatus") == null ? false
									: (boolean) map.get("sStatus") == false) {
								sReturn = false;
							}
						} catch (Exception e) {
							ARE.getLog().error(e);
							return false;
						}
					}
				}
			}
		}
		return sReturn;
	}

	@SuppressWarnings("deprecation")
	public Map<String, Object> alarmModelInvoker(String sGroupId,
			String sItemId, Transaction Sqlca, JBOTransaction tx,
			String serializableScenario) throws Exception {
		Map<String, Object> map = new HashMap<String, Object>();
		try {
			if (serializableScenario == null)
				serializableScenario = "";

			if (serializableScenario.length() == 0)
				throw new Exception("场景对象获取错误！");
			try {

				ScenarioContext context = (ScenarioContext) ObjectConverts
						.getObject(serializableScenario);

				CheckItem chItem = context.getScenario().getCheckItem(sGroupId,
						sItemId);

				String sPassMessage = chItem.getPassMessage();
				String sNoPassMessage = chItem.getNoPassMessage();
				if (sPassMessage == null)
					sPassMessage = "";
				if (sNoPassMessage == null)
					sNoPassMessage = "";

				// AlarmMessage am = (AlarmMessage) context.getCheckItemRunner()
				// .run(Sqlca, chItem);
				AlarmMessage am = (AlarmMessage) context.getCheckItemRunner()
						.run(Sqlca, chItem);
				StringBuffer sbMessage = new StringBuffer();
				String sMessage = "";
				for (int j = 0; j < am.size(); j++) {
					sbMessage.append(am.getMessage(j) + "[~`~]");
				}
				if (sbMessage.length() > 5) {
					sMessage = sbMessage.substring(0, sbMessage.length() - 5);
				} else {
					sMessage = "";
				}

				// 如果执行后，返回的消息为空
				// 1.如果通过，则消息取配置的通过的提示消息
				// 2.如果未通过，则取配置的未通过的提示消息
				if (sMessage.equals("")) {
					if (am.isPass()) {
						sMessage = sPassMessage;
					} else {
						sMessage = sNoPassMessage;
					}
				}
				// Thread.sleep(200);
				// 生成JSON
				boolean sStatus = am.isPass();
				String sNoPassDeal = am.getNoPassDeal();
				String sMsg = sMessage;
				map.put("sStatus", sStatus);
				map.put("sNoPassDeal", sNoPassDeal);
				map.put("sMsg", sMsg);
				ARE.getLog().debug(
						"status:" + am.isPass() + "|message:" + sMessage);
			} catch (Exception e) {
				ARE.getLog().error(e);
				throw e;
			}
		} catch (Exception e) {
			if (Sqlca != null)
				Sqlca.getConnection().rollback();
			e.printStackTrace();
			ARE.getLog().error(e.getMessage(), e);
			throw e;
		} finally {
			if (Sqlca != null) {
				Sqlca.getConnection().commit();
				Sqlca.disConnect();
				Sqlca = null;
			}
		}
		return map;
	}
}