package policy;

import java.util.Date;
import java.util.List;

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

import foundation.action.ActionProvider;
import foundation.dao.DataPackage;
import foundation.dao.DataSource;
import foundation.data.entity.Entity;
import foundation.data.object.DataObject;
import foundation.persist.NamedSQL;
import foundation.token.IOnlineUser;
import foundation.util.Util;
import policy.price.OnsitesResult;
import policy.price.PolicyBucket;
import policy.price.PricesResult;
import policy.price.outline.DomainOnsiteResult;
import policy.price.outline.DomainPriceResult;
import policy.price.outline.OnsiteOutline;
import policy.price.outline.PricesOutline;
import policy.rule.CheckBoard;
import policy.rule.RuleBucket;
import policy.rule.RuleRuntimes;

public class PolicyCenter extends ActionProvider {
	
	
    protected static Logger logger;
    
    static {
    	logger = LogManager.getLogger(PolicyCenter.class);
    }
    
	@Override
	protected void publishMethod() {
		//1. 获取价格列表
		addMethod("getPriceList");
		
		//2. 获取即时政策
		addMethod("getOnsiteDiscounts");
		
		//3. 下单前获取下单上下文(是否可下单，可下单公司、BU等)
		addMethod("getOrderContext");
		
		//4.1 订单计算
		addMethod("orderCalculate");
		
		//4.2 订单检查（保存）
		addMethod("policyCheckSave");
		
		//4.3 订单检查（提交）
		addMethod("policyCheckCommit");
		
		//4.4 订单检查（生效）
		addMethod("policyCheckOpen");
		
		//4.5 订单检查看板
		addMethod("policyCheckBoard");		
		
		//5. 获取价格概况
		addMethod("getPriceOutline");
		
		//6. 获取折扣概况 
		addMethod("getOnsiteOutline");
		
		//7. 获取当前BU下的订单检查规则 
		addMethod("getChenckRulesByBU");
		
		//8. 刷新价格列表
		addMethod("refreshPriceList");
		
		//9. 刷新即时政策
		addMethod("refreshOnsiteList");
		
		//10. 根据终止日期刷新状态（备案，协议，价格）
		addMethod("refreshStateBySuspendDate");
	}

	public void getPriceList() throws Exception {
		String customerId = dataReader.getString("customer_id");
		List<String> skuIdList = dataReader.getStringList("sku_id");
		boolean includeNotActive = dataReader.getBoolean("include_not_active", false);

		if (Util.isEmpty(customerId) && skuIdList.isEmpty()) {
			return;
		}
		
		//1. 刷新价格
		PolicyLoader.refreshPriceList();
		
		//2. 获取价格
		PricesResult pricesResult = new PricesResult(skuIdList, includeNotActive);
		
		PolicyBucket policyBucket = PolicyBucket.getInstance();
		policyBucket.getPriceList(customerId, pricesResult);
		
		//3. 返回价格
		dataWriter.addValue(pricesResult);
	}
	
	public void getOnsiteDiscounts() throws Exception {
		String customerId = dataReader.getString("customer_id");
		String productLineId = dataReader.getString("bu_id");
		boolean includeNotActive = dataReader.getBoolean("include_not_active", false);
		
		if (Util.isEmpty(customerId) || Util.isEmpty(productLineId)) {
			dataWriter.reportOneError("getOnsiteDiscounts", "产品线或客户为空，无法获取当前客户优惠政策...");
			return;
		}
		
		//1. 刷新政策
		PolicyLoader.refreshOnsiteList();
		
		//2. 获取政策
		OnsitesResult qtyResult = new OnsitesResult(includeNotActive);
		
		PolicyBucket policyBucket = PolicyBucket.getInstance();
		policyBucket.getOnsiteDiscounts(customerId, productLineId, qtyResult);
		
		//3. 返回政策
		dataWriter.addValue("onsiteDiscounts", qtyResult);
	}
	
	public void getOrderContext() throws Exception {
		
	}
	
	public void orderCalculate() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		//1. 获取BU
		String buId = getBUId(dataPackage);
		
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.reportOneError("policyCheckOpen", "无法获得订单BU");
		}
		
		//2. 获取校验规则，进行校验
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		rules.calculateData(dataPackage, dataWriter);
		dataPackage.setResultData(DataSource.DB);
		
		//3 返回结果
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void policyCheckSave() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		//1. 获取BU
		String buId = getBUId(dataPackage);
		
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.reportOneError("policyCheckOpen", "无法获得订单BU");
		}
		
		//2. 获取校验规则，进行校验
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		rules.check(dataPackage, OrderEvent.Save, dataWriter);
	}
	
	public void policyCheckCommit() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		//1. 获取BU
		String buId = getBUId(dataPackage);
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.reportOneError("policyCheckOpen", "无法获得订单BU");
		}
		
		//2. 获取校验规则，进行校验
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		boolean success = rules.check(dataPackage, OrderEvent.Commit, dataWriter);
		
		if (!success) {
			task.terminate();
		}
	}
	
	public void policyCheckOpen() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		
		//1. 获取BU
		String buId = getBUId(dataPackage);
		
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.reportOneError("policyCheckOpen", "无法获得订单BU");
		}
		
		//2. 获取校验规则，进行校验
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		rules.check(dataPackage, OrderEvent.Open, dataWriter);
	}
	
	public void policyCheckBoard() throws Exception {
		DataPackage dataPackage = dataReader.getDataPackage();
		IOnlineUser onlineUser = IOnlineUser.getInstance();
		
		CheckBoard result = new CheckBoard();
		
		//1. 获取BU
		String buId = onlineUser.getBUId();
		if (Util.isEmpty(buId)) {
			Entity master = dataPackage.getMasterEntity();
			buId = master.getString("bu_id");
		}
		
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.addValue(result);
		}
		
		//2. 获取校验规则，进行校验
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		rules.createCheckBoard(dataPackage, result, dataWriter);
		
		//3 返回结果
		dataWriter.addValue(result);		
	}
	
	public void getPriceOutline() throws Exception {
		String buId = dataReader.getString("bu_id");
		String productId = dataReader.getString("product_id");
		String skuId = dataReader.getString("sku_id");
		
		PolicyBucket policyBucket = PolicyBucket.getInstance();
		
		//1. 刷新价格
		PolicyLoader.refreshPriceList();
		
		//2. 查询某个SKU的价格概览
		if (!Util.isEmpty(skuId)) {
			DomainPriceResult result = policyBucket.getSKUPriceList(skuId);
			dataWriter.addValue(result);
			return;
		}
		
		//3. 查询某个产品的价格概览
		if (!Util.isEmpty(productId)) {
			DomainPriceResult result = policyBucket.getProductPriceList(productId);
			dataWriter.addValue(result);
			return;
		}
		
		//4. 查询某个产品线的价格概览
		if (!Util.isEmpty(buId)) {
			DomainPriceResult result = policyBucket.getProductLinePriceList(buId);
			dataWriter.addValue(result);
			return;
		}
		
		//5. 获取全部价格概览
		PricesOutline pricesOutline = new PricesOutline();
		policyBucket.getPriceOutline(pricesOutline);
		dataWriter.addValue(pricesOutline);
	}
	
	public void getOnsiteOutline() throws Exception {
		String buId = dataReader.getString("bu_id");
		String productId = dataReader.getString("product_id");
		String skuId = dataReader.getString("sku_id");
		
		PolicyBucket policyBucket = PolicyBucket.getInstance();
		
		//1. 刷新政策
		PolicyLoader.refreshOnsiteList();
		
		//2. 查询某个SKU的价格概览
		if (!Util.isEmpty(skuId)) {
			DomainOnsiteResult result = policyBucket.getSKUOnsiteList(skuId);
			dataWriter.addValue(result);
			return;
		}
		
		//3. 查询某个产品的价格概览
		if (!Util.isEmpty(productId)) {
			DomainOnsiteResult result = policyBucket.getProductOnsiteList(productId);
			dataWriter.addValue(result);
			return;
		}
		
		//4. 查询某个产品线的价格概览
		if (!Util.isEmpty(buId)) {
			DomainOnsiteResult result = policyBucket.getProductLineOnsiteList(buId);
			dataWriter.addValue(result);
			return;
		}
		
		//5. 获取政策
		OnsiteOutline onsiteOutline = new OnsiteOutline();
		policyBucket.getOnsiteOutline(onsiteOutline);
		dataWriter.addValue(onsiteOutline);
	}
	
	public void getChenckRulesByBU() throws Exception {
		CheckBoard result = new CheckBoard();
		
		//1. 获取BU
		String buId = dataReader.getString("bu_id");
		
		if (Util.isEmpty(buId)) {
			logger.error("无法获得订单BU");
			dataWriter.addValue(result);
		}
		
		//2. 获取校验规则
		RuleRuntimes rules = RuleBucket.getRuleRuntimes(buId);
		
		//3 返回结果
		dataWriter.addValue(rules);	
	}
	
	public void refreshPriceList() throws Exception {
		int cnt = PolicyLoader.refreshPriceList();
		dataWriter.addValue(cnt);
	}
	
	public void refreshOnsiteList() throws Exception {
		int cnt = PolicyLoader.refreshOnsiteList();
		dataWriter.addValue(cnt);
	}
	
	private String getBUId(DataPackage dataPackage) throws Exception {
		String buId = null;
		Entity master = dataPackage.getMasterEntity(DataSource.DB, DataSource.Request);
		
		if (master != null) {
			buId = master.getString("bu_id");
		}
		
		return buId;
	}

	public void refreshStateBySuspendDate() throws Exception {
		String dataName = null;
		
		//1. 页面请求会执行
		if (dataReader != null) {
			dataName = dataReader.getDomain().getDataName();
		}
		
		//2. 定时任务会执行
		if (Util.isEmpty(dataName)) {
			dataName = context.getStepParam();
		}
		
		//3. 获取表名
		if (Util.isEmpty(dataName)) {
			logger.error("dataname is empty, skip refreshStateBySuspendDate");
			return;
		}
		
		DataObject dataObject = DataObject.getInstance(dataName);
		String tableName = dataObject.getTableName();
		
		//3. 
		NamedSQL namedSQL = NamedSQL.getInstance("refreshStateBySuspendDate");
		namedSQL.setParam("tableName", tableName);
		namedSQL.setParam("currentDate", new Date(), true);
		int exeCount = namedSQL.execute();
		
		logger.info("失效 dataName：{}， {} 条", dataName, exeCount);
	}
}