package com.changhong.epc.form.execute.impl;

import java.util.*;

import javax.annotation.Resource;

import com.changhong.autoform.entity.ProcessBudget;
import com.changhong.epc.bean.form.FormType;
import com.changhong.epc.form.execute.BudgetRecord;
import com.changhong.epc.form.execute.IFormOthersOperation;
import com.changhong.epc.form.execute.IProcessBudgetBack;
import com.iemsoft.framework.cloud.core.exception.IEMRuntimeException;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import com.iemsoft.framework.cloud.core.tools.SpringUtil;

import lombok.Data;

@Data
public class MainLogic {
	
	@Resource
	private IFormOthersOperation formOthersOperation = SpringUtil.getBean(IFormOthersOperation.class);
	
	// @Resource
	private IProcessBudgetBack processBudgetBack;
	
	private ProcessBudget processBudget;
	
	private Map<FormType, List<Integer>> pbs;
	
	private List<Double> pzMoney;
	private List<Double> pzMoneynew;
	private List<BudgetRecord> pdrs;
	
	private Double xyMoney = 0D;
	
	private Boolean flog = true;
	
	private List<BudgetRecord> ySs;
	private List<BudgetRecord> budgetRecords;
	
	private FormType billType;
	
	
	
	public void initData(ProcessBudget processBudget){
		pbs = new HashMap<>();
		for(FormType type : FormType.values()){
			pbs.put(type, new ArrayList<>());
		}
		pdrs = new ArrayList<>();
		pzMoney = new ArrayList<>();
		this.processBudget = processBudget;
	}
	
	public boolean addOfType(FormType formType, List<Integer> pds){
		if (pbs.get(formType).size() > 0){
			return false;
		}
		pbs.get(formType).addAll(pds);
		
		return true;
	}
	
	/**
	 * 查找
	 * @param formType
	 * @return
	 */
	public Integer findOfTypeEques(FormType formType){
		if(FormType.YS == formType){
			if(pbs.get(formType).size() > 0){
				Integer processBudget = pbs.get(formType).get(0);
				pbs.get(FormType.YS).remove(processBudget);
				return processBudget;
			}
		}
		return null;
	}
	
	public List<Integer> getYsDataRowNumbers(){
		return Optional.ofNullable(pbs.get(FormType.YS)).orElse(Collections.EMPTY_LIST);
	}
	
	public void exeLogic(){
		// 1. 预运行一次
		try {
			executePrimary(processBudget);
		} catch (Exception e) {
		}
		double  sum = 0D;
		pzMoneynew = new ArrayList<>(pzMoney);
		for(double s : pzMoney){
			sum = sum + s;
		}
//		if(xyMoney != sum){
//			throw new IEMRuntimeException("E001", "配置错误，配置金额与报销金额不符合！");
//		}
		
		splittingData(); 
		
		
		// 3. 没有一次出现异常，执行 真正的回写预算
		for (BudgetRecord budgetRecord : pdrs) {
			updateForm(budgetRecord);
		}
			
	}
	
	
	
	

	/**
	 * 
	 */
	private void splittingData() {
		// budgetRecords
		int i = 0;
		for(BudgetRecord brys : ySs){
			budgetRecords.remove(budgetRecords.size()-1);
			Double money = pzMoneynew.get(i);
			BudgetRecord budgetRecord = budgetRecords.get(budgetRecords.size()-1);
			budgetRecord.getMoney().money = money;
			budgetRecords.add(brys);
			
			executeProcessBudget(budgetRecords);
			
			i ++;
		}
	}

	public void setXyMoney(Double money) {
		if(flog){
			xyMoney = money;
		}
	}
	
	public void setPzMoney(List<String> obs){
		if(flog){
			obs.forEach(s->pzMoney.add(Double.parseDouble(s)));
		}
		flog = false;
	}
	
	public Integer loopNumber(){
		return pbs.get(FormType.YS).size();
	}
	
	public Double getEachMoney(){
		if(pzMoneynew == null || pzMoneynew.size() == 0){
			return 0D;
		}
		Double double1 = pzMoneynew.get(0);
		pzMoneynew.remove(0);
		return double1;
	}
	
	/**
	 * 预运行一次
	 * @param processBudget
	 */
	public void executePrimary(ProcessBudget processBudget) {
		// formOthersOperation.getMoneyCpnMdCode();
		
		budgetRecords = new ArrayList<>();
		processBudgetBack = new ProcessBudgetBack(this);
	
		/**
		 * FormType.BX
		 * formOthersOperation.getBillType(processBudget)
		 */
		billType = formOthersOperation.getBillType(processBudget);
		processBudget.setCostType(billType.toString());
		switch (billType) {
		// A.预算 
		case YS:
			processBudgetBack.exeBudget(budgetRecords, processBudget);
			
			// System.out.println(budgetRecords);
			break;
		
		// B.申请
		case SQ:
			processBudgetBack.exeApply(budgetRecords, processBudget);
			break;
			
		// 报销
		case BX:
			processBudgetBack.exeExpense(budgetRecords, processBudget);
			break;
		
		default:
			break;
		}	
		ySs = new ArrayList<>();
		ProcessBudget atProcessBudget = budgetRecords.get(budgetRecords.size() -1).getAtProcessBudget();
		
		for(Integer dataRowNumber : getYsDataRowNumbers()){
			ProcessBudget obj = JSONTool.toObj(JSONTool.toJson(atProcessBudget),ProcessBudget.class );
			obj.setDataRowNUm(dataRowNumber);
			processBudgetBack.exeBasics(ySs, obj);
		}
		
	}
	

	
	/**
	 * 真正开始执行业务逻辑
	 * @param budgetRecords2
	 */
	public void executeProcessBudget(List<BudgetRecord> bRs) {
		List<BudgetRecord> budgetRecords = JSONTool.toList(JSONTool.toJson(bRs), BudgetRecord.class);
		switch (billType) {
		
		// A.预算 
		case YS:

			if(budgetRecords.size() == 1){
				throw new IEMRuntimeException("C001", "没有上级预算！");
			}
			BudgetRecord budgetRecord = budgetRecords.get(0);
			// System.out.println("预算A的金额：" + budgetRecord.getMoney().money);
			BudgetRecord budgetRecord2 = budgetRecords.get(1);
			// System.out.println("预算B的金额：" + budgetRecord2.getMoney().money);
			budgetRecord2.getMoney().money = budgetRecord2.getMoney().money - budgetRecord.getMoney().money;
			if(budgetRecord2.getMoney().money < 0){
				throw new IEMRuntimeException("C001", "上级预算余额不足！");
			}
			setUpdateForm(budgetRecord2,budgetRecord2.getMoney().money );
			break;
		
		// B.申请
		case SQ:
			if(budgetRecords.size() == 1){
				// 没有上级报销
			}
			BudgetRecord b1 = budgetRecords.get(0);
			BudgetRecord b2 = budgetRecords.get(1);
			b2.getMoney().money = b2.getMoney().money - b1.getMoney().money;
			if(b2.getMoney().money < 0){
				throw new IEMRuntimeException("C001", "申请金额失败， 预算余额不足！");
			}
			// 正常
			setUpdateForm(b2, b2.getMoney().money);
			break;
			
		// 报销
		case BX:
			Double money;
			if(budgetRecords.size() == 1){
				// 没有上级报销
				throw new IEMRuntimeException("C001", "没有上级预算！");
			}
			BudgetRecord b01 = budgetRecords.get(0);
			BudgetRecord b02 = budgetRecords.get(1);
			BudgetRecord b03 = null;
			try {
				b03 = budgetRecords.get(2);
				if(b03 == null){
					throw new IEMRuntimeException("C002", "其他异常请找程序员询问。");
				}
				money = (b03.getMoney().money + b02.getMoney().money)- b01.getMoney().money;
				if(money < 0){
					throw new IEMRuntimeException("C001", "预算余额不足！");
				}
				setUpdateForm(b03,money);
				break;
			} catch (Exception e) {
			}
			
//			if(b02.getType() == FormType.SQ){
				
				// 正常
				
	//		}
			
			money = b02.getMoney().money - b01.getMoney().money;
			if(money < 0){
				throw new IEMRuntimeException("C001", "预算余额不足！");
			}
			// 正常
			setUpdateForm(b02,money);
			break;
		
		default:
			break;
		}
	}
	
	
	
	public void  setUpdateForm(BudgetRecord budgetRecord, Double money){
		//budgetRecord.getAtProcessBudget().setFormID("80b0627f825ef169x9da7646eb0847c0");
//		if(budgetRecord.getMoney().alias == null){
//			budgetRecord.getMoney().alias = "预算金额";
//		}
		budgetRecord.getMoney().money = money;
		pdrs.add(budgetRecord);
	}
	
	public void updateForm(BudgetRecord budgetRecord){
		// System.out.println(budgetRecord.getAtProcessBudget().getDataRowNUm());
		formOthersOperation.updateFormFieldProperty(budgetRecord.getAtProcessBudget(), budgetRecord.getMoney());			
	}
	
	
}