package com.changhong.epc.form.service.budget.tool.impl;

import com.changhong.epc.bean.form.FormType;
import com.changhong.epc.bean.tenant.system.SystemConfig;
import com.changhong.epc.bean.tenant.system.SystemForm;
import com.changhong.epc.form.service.budget.CheckFormDataServes;
import com.changhong.epc.form.service.budget.department.model.BudgetExtend;
import com.changhong.epc.form.service.budget.impl.GetConstant;
import com.changhong.epc.form.service.budget.tool.UpdateBudgetFactory;
import com.changhong.epc.form.service.budget.tool.entity.UpdateBudgetEntity;
import com.changhong.epc.rely.api.epc.tenant.SystemConfigApi;
import com.codingapi.tx.annotation.TxTransaction;
import com.iemsoft.framework.cloud.core.thread.Keys;
import com.iemsoft.framework.cloud.core.thread.ThreadData;
import com.iemsoft.framework.cloud.core.tools.Assert;
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.ModelMap;

import javax.annotation.Resource;

import java.util.List;
import java.util.Map;
import java.util.Objects;

@Service(UpdateBudgetFactory.CONTRACT_INFO_TYPE)
@Slf4j
@Scope("prototype")
public class ContractInfoUpdate extends AbstractUpdateBudget{

    private Map<String, Object> contractInfo;

    private Map<String, Object> budgetChildInfo;

    @Resource
    private CheckFormDataServes checkFormDataServes;
    
    @Resource
    private SystemConfigApi systemConfigApi;

    @Override
    public void checkBudget(UpdateBudgetEntity updateBudgetEntity) {
        this.contractInfo = getFormInfo(updateBudgetEntity);
        Integer budgetId = getParentId(contractInfo);
        if(budgetId == null){
            return;
        }
        this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
        Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
        if(contractInfo.get(CONTRACT_MONEY) == null || getBudgetBalance(budgetChildInfo) == null){
            return;
        }
//        addLock(budgetId);
        // 验证预算
        Assert.condition(
                toDouble(contractInfo.get(CONTRACT_MONEY)) > toDouble(getBudgetBalance(budgetChildInfo))
                , BUDGET_MONEY_NOT_ENOUGH);
    }

    @Override
    @TxTransaction
    @Transactional
    public void updateBudget(UpdateBudgetEntity updateBudgetEntity) {
        super.updateBudget(updateBudgetEntity);
        checkBudget(updateBudgetEntity);
        if(ObjectUtil.empty(this.budgetChildInfo) || contractInfo.get(CONTRACT_MONEY) == null){
            account(updateBudgetEntity.getFormId(),ThreadData.get(Keys.TENANT_ID), Objects.toString(updateBudgetEntity.getDataRowNum(),""));
            return;
        }
        double money = toDouble(getBudgetBalance(budgetChildInfo)) - toDouble(contractInfo.get(CONTRACT_MONEY));
        checkMoney(money);

        addBudgetLogMoney(
                this.budgetChildInfo
                , money
                , updateBudgetEntity.getFormId()
                , this.contractInfo
                , toDouble(contractInfo.get(CONTRACT_MONEY))
        );
        // 修改预算
        updateData(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM
                , getDataRowNum(budgetChildInfo)
                , new ModelMap(BUDGET_ITEM_BALANCE, format(money,getFormBase(getFormId(SystemForm.BUDGET_FORM_ID)),BUDGET_ITEM_BALANCE)));
    }


    /**
     * 预算回写
     */
    public Integer budgetWirteBack(BudgetExtend budgetExtend){
    	this.contractInfo = getFormInfo(new UpdateBudgetEntity(budgetExtend.getFormId(),budgetExtend.getDatarowNum()));
    	log.debug("当前执行状态："+contractInfo.get(STATE_EXECUTION));
    	Assert.condition(contractInfo.get(STATE_EXECUTION)!=null&& !Objects.equals("",contractInfo.get(STATE_EXECUTION)), CONTRACT_OVER);
    	log.debug("开始合同信息预算回写");
        //判断合同执行状态，修改控件值
    	log.debug("当前合同执行状态:"+budgetExtend.getData());
        if(ObjectUtil.notEmpty(budgetExtend.getData())
                && !Objects.equals(Objects.toString(budgetExtend.getData().get(STATE_EXECUTION),null)
                , GetConstant.getConstant(STATE_EXECUTION))) {
            updateData(budgetExtend.getFormId(), null
                    , budgetExtend.getDatarowNum()
                    , budgetExtend.getData());
            //取出实时已付金额
            Double sum = 0d;
            for(Map<String,Object> map:checkFormDataServes.getSumAlreadyPaid(budgetExtend)){
                if(map.get(ALREADYPAID)!=null){
                    sum+=toDouble(map.get(ALREADYPAID));
                }
            }
            log.debug("当前合同已付金额为:"+sum);
            //回写预算
            Assert.condition((toDouble(this.contractInfo.get(CONTRACT_MONEY))-sum)<0, OVERTOP_CONTRACT_MONEY);
            Integer budgetId = getParentId(contractInfo);
            if(budgetId == null){
                return 0;
            }
            this.budgetChildInfo = getFormInfo(this.getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
            Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
            if(contractInfo.get(CONTRACT_MONEY) == null || getBudgetBalance(budgetChildInfo) == null){
                return 0;
            }
            log.debug("当前预算余额:"+this.budgetChildInfo.get(BUDGET_ITEM_BALANCE));
            Double budgetbl = toDouble(this.budgetChildInfo.get(BUDGET_ITEM_BALANCE))+(toDouble(this.contractInfo.get(CONTRACT_MONEY))-sum);
            log.debug("预算回写后余额:"+budgetbl);
            //回写预算
            updateData(this.getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, getDataRowNum(this.budgetChildInfo),
                    new ModelMap(BUDGET_ITEM_BALANCE, format(budgetbl,getFormBase(budgetExtend.getFormId()),BUDGET_ITEM_BALANCE)));
        }
        return 1;
    }

    @Override
    public void flowAfterCall(UpdateBudgetEntity updateBudgetEntity) {
        account(updateBudgetEntity.getFormId(),ThreadData.get(Keys.TENANT_ID), Objects.toString(updateBudgetEntity.getDataRowNum(),""));
    }

    @Override
    public void rollback(UpdateBudgetEntity updateBudgetEntity) {
        super.rollback(updateBudgetEntity);
        this.contractInfo = getFormInfo(updateBudgetEntity);
        Integer budgetId = getParentId(contractInfo);
        if(budgetId == null){
            return;
        }
        this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
        Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
        if(contractInfo.get(CONTRACT_MONEY) == null || getBudgetBalance(budgetChildInfo) == null){
            return;
        }
        double money = toDouble(getBudgetBalance(budgetChildInfo)) + toDouble(contractInfo.get(CONTRACT_MONEY));

        addBudgetLogMoney(
                this.budgetChildInfo
                , money
                , updateBudgetEntity.getFormId()
                , this.contractInfo
                , toDouble(contractInfo.get(CONTRACT_MONEY))
        );
        // 修改预算
        updateData(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM
                , getDataRowNum(budgetChildInfo)
                , new ModelMap(BUDGET_ITEM_BALANCE, format(money,getFormBase(getFormId(SystemForm.BUDGET_FORM_ID)),BUDGET_ITEM_BALANCE)));
    }

    @Override
    public FormType getFormType() {
        return FormType.HTXX;
    }
    List<SystemConfig> config = null;
    public String getFormId(SystemForm systemForm){
    	if(this.config == null){
    		this.config = systemConfigApi.getSystemConfigs(new SystemConfig("formInfo"));
    	}
    	SystemConfig sys = config.stream().filter(fi->Objects.equals(fi.getCkey(),systemForm.toString())).findFirst().orElse(null);
    	return sys!=null?sys.getCvalue():null;
    }
 
}