package com.changhong.epc.form.service.budget.tool.impl;
|
|
import com.changhong.epc.bean.form.FormType;
|
import com.changhong.epc.bean.form.budget.PersionBackMoney;
|
import com.changhong.epc.bean.tenant.cost.CostFromMapping;
|
import com.changhong.epc.bean.tenant.system.SystemForm;
|
import com.changhong.epc.constter.base.BaseConst;
|
import com.changhong.epc.form.mapper.tenant.FormDataMapper;
|
import com.changhong.epc.form.mapper.tenant.log.PersionBackMoneyMapper;
|
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.form.service.field.FormFieldService;
|
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.JSONTool;
|
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.math.NumberUtils;
|
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.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
|
/**
|
* 报销扣减预算
|
*/
|
@Service(UpdateBudgetFactory.BX_TYPE)
|
@Slf4j
|
@Scope("prototype")
|
public class ExpendBudgetUpdate extends AbstractUpdateBudget implements BaseConst {
|
|
private UpdateBudgetEntity applyEntity;
|
|
private Map<String, Object> applyInfo;
|
// 主表数据集合
|
private Map<String, Object> expendInfo;
|
|
private Map<String, Object> budgetChildInfo;
|
|
private double budgetMoney;
|
|
@Resource
|
private PersionBackMoneyMapper persionBackMoneyMapper;
|
|
@Resource
|
private FormDataMapper formDataMapper;
|
|
@Resource(name = "formFieldService")
|
private FormFieldService formFieldService;
|
|
// 子表单后缀
|
private static String PAYINFO = "_payinfo";
|
|
// 本次报销数据集合
|
private List<Map<String, Object>> list;
|
|
// 对应报销人的借款记录
|
private List<Map<String, Object>> borrowList;
|
|
//判断是否有子表单
|
private Integer count;
|
|
|
@Override
|
public void checkBudget(UpdateBudgetEntity updateBudgetEntity) {
|
this.expendInfo = getFormInfo(updateBudgetEntity);
|
this.applyEntity = getApplyInfo(
|
NumberUtils.createInteger(Objects.toString(this.expendInfo.get(EXPEND_COST_TYPE), "0")));
|
if (this.applyEntity == null) {
|
// 报销-预算
|
Integer budgetId = getParentId(this.expendInfo);
|
if (budgetId == null) {
|
log.warn("{}, 关联预算单id为空!", updateBudgetEntity);
|
return;
|
}
|
addLock(budgetId);
|
this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
|
Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
|
if (this.expendInfo.get(EXPEND_USE_MONEY) == null
|
|| this.budgetChildInfo.get(BUDGET_ITEM_BALANCE) == null) {
|
log.warn("{}, 报销金额:{}, 预算余额:{}"
|
, updateBudgetEntity
|
, this.expendInfo.get(EXPEND_USE_MONEY)
|
, this.budgetChildInfo.get(BUDGET_ITEM_BALANCE));
|
return;
|
}
|
this.budgetMoney = toDouble(this.budgetChildInfo.get(BUDGET_ITEM_BALANCE))
|
- toDouble(this.expendInfo.get(EXPEND_USE_MONEY));
|
Assert.condition(this.budgetMoney < 0, BUDGET_MONEY_NOT_ENOUGH);
|
} else {
|
// 报销-申请-预算
|
Integer applyId = getParentId(this.expendInfo);
|
if (applyId == null) {
|
log.warn("{}, 关联申请单id为空!", updateBudgetEntity);
|
return;
|
}
|
this.applyEntity.setDataRowNum(applyId);
|
this.applyInfo = getFormInfo(this.applyEntity);
|
Assert.condition(applyInfo == null, APPLY_INVALID);
|
Integer budgetId = getParentId(this.applyInfo);
|
if (budgetId == null) {
|
log.warn("{}, 关联预算单id为空!", updateBudgetEntity);
|
return;
|
}
|
addLock(budgetId);
|
this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
|
Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
|
if (this.expendInfo.get(EXPEND_USE_MONEY) == null
|
|| this.budgetChildInfo.get(BUDGET_ITEM_BALANCE) == null
|
|| this.applyInfo.get(APPLY_USE_MONEY) == null) {
|
log.warn("{}, 报销金额:{}, 预算余额:{}, 申请金额:{}"
|
, updateBudgetEntity
|
, this.expendInfo.get(EXPEND_USE_MONEY)
|
, this.budgetChildInfo.get(BUDGET_ITEM_BALANCE)
|
, this.applyInfo.get(APPLY_USE_MONEY));
|
return;
|
}
|
Assert.condition((this.budgetMoney = (toDouble(this.budgetChildInfo.get(BUDGET_ITEM_BALANCE))
|
+ toDouble(this.applyInfo.get(APPLY_USE_MONEY))
|
- toDouble(this.expendInfo.get(EXPEND_USE_MONEY)))) < 0, BUDGET_MONEY_NOT_ENOUGH);
|
//申请状态回写，只能被占用一次
|
updateData(this.applyEntity.getFormId(), null
|
, this.applyEntity.getDataRowNum()
|
, new ModelMap(PROCESS_FLAG, 1));
|
}
|
String childForm = updateBudgetEntity.getFormId() + PAYINFO;
|
count = formDataMapper.selectTableExist(childForm);
|
//如果有子表单
|
if (count > 0) {
|
// 判断金额是否合适
|
// 冲抵金额
|
Double money = this.persionMoney(updateBudgetEntity);
|
// 借款金额
|
Double borowMoney = this.allBorrowMoney();
|
//如果冲抵金额大于0，并且借款金额等于0或者冲抵金额大于了借款金额报错
|
if (money > 0) {
|
log.debug("本次冲抵金额为：" + money.toString());
|
Assert.condition(BigDecimal.valueOf(borowMoney).compareTo(BigDecimal.valueOf(0)) == 0 || money > borowMoney, PERSION_COST_OUT);
|
}
|
}
|
}
|
|
@Override
|
@TxTransaction
|
@Transactional
|
public void updateBudget(UpdateBudgetEntity updateBudgetEntity) {
|
super.updateBudget(updateBudgetEntity);
|
checkBudget(updateBudgetEntity);
|
if (ObjectUtil.empty(this.budgetChildInfo) || this.expendInfo.get(EXPEND_USE_MONEY) == null
|
|| this.budgetChildInfo.get(BUDGET_ITEM_BALANCE) == null
|
|| (this.applyInfo != null && this.applyInfo.get(APPLY_USE_MONEY) == null)) {
|
// account(updateBudgetEntity.getFormId(), ThreadData.get(Keys.TENANT_ID), Objects.toString(updateBudgetEntity.getDataRowNum(), ""));
|
return;
|
}
|
checkMoney(this.budgetMoney);
|
|
if (ObjectUtil.empty(applyInfo)) {
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney, updateBudgetEntity.getFormId(), this.expendInfo,
|
toDouble(expendInfo.get(EXPEND_USE_MONEY)));
|
} else {
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney
|
|
, updateBudgetEntity.getFormId(), this.expendInfo, toDouble(expendInfo.get(EXPEND_USE_MONEY))
|
|
, applyEntity.getFormId(), this.applyInfo, toDouble(this.applyInfo.get(APPLY_USE_MONEY)));
|
//回写借款金额
|
Object amountMoney = this.expendInfo.get(AMOUNTREPAYMENTS);
|
log.debug("当前报销单:" + JSONTool.toJson(this.expendInfo));
|
log.debug("还款金额为:" + amountMoney);
|
if (amountMoney != null && !Objects.equals("", amountMoney)) {
|
log.debug("报销还款金额回写-------->");
|
updateData(applyEntity.getFormId(), null, applyEntity.getDataRowNum()
|
, new ModelMap(ALREADYREPAID, amountMoney));
|
}
|
}
|
//formatDouble(formBaseEntity);
|
updateData(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, getDataRowNum(this.budgetChildInfo),
|
new ModelMap(BUDGET_ITEM_BALANCE, format(this.budgetMoney, getFormBase(getFormId(SystemForm.BUDGET_FORM_ID)), BUDGET_ITEM_BALANCE)));
|
|
}
|
|
|
@Override
|
public void flowAfterCall(UpdateBudgetEntity updateBudgetEntity) {
|
this.expendInfo = getFormInfo(updateBudgetEntity);
|
this.applyEntity = getApplyInfo(
|
NumberUtils.createInteger(Objects.toString(this.expendInfo.get(EXPEND_COST_TYPE), "0")));
|
if (this.applyEntity == null) {
|
// 报销-预算
|
Integer budgetId = getParentId(this.expendInfo);
|
if (budgetId == null) {
|
return;
|
}
|
delLock(budgetId);
|
} else {
|
// 报销-申请-预算
|
Integer applyId = getParentId(this.expendInfo);
|
if (applyId == null) {
|
return;
|
}
|
this.applyEntity.setDataRowNum(applyId);
|
this.applyInfo = getFormInfo(this.applyEntity);
|
Integer budgetId = getParentId(this.applyInfo);
|
if (budgetId == null) {
|
return;
|
}
|
delLock(budgetId);
|
}
|
account(updateBudgetEntity.getFormId(), ThreadData.get(Keys.TENANT_ID), Objects.toString(updateBudgetEntity.getDataRowNum(), ""));
|
// 调用报销单个人冲抵的方法判断
|
this.getPersionCostById(updateBudgetEntity);
|
}
|
|
@Override
|
public void rollback(UpdateBudgetEntity updateBudgetEntity) {
|
super.rollback(updateBudgetEntity);
|
this.expendInfo = getFormInfo(updateBudgetEntity);
|
this.applyEntity = getApplyInfo(
|
NumberUtils.createInteger(Objects.toString(this.expendInfo.get(EXPEND_COST_TYPE), "0")));
|
if (this.applyEntity == null) {
|
// 报销-预算
|
Integer budgetId = getParentId(this.expendInfo);
|
if (budgetId == null) {
|
log.warn("{}, 关联预算单id为空!", updateBudgetEntity);
|
return;
|
}
|
addLock(budgetId);
|
this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
|
Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
|
if (this.expendInfo.get(EXPEND_USE_MONEY) == null
|
|| this.budgetChildInfo.get(BUDGET_ITEM_BALANCE) == null) {
|
log.warn("{}, 报销金额:{}, 预算余额:{}"
|
, updateBudgetEntity
|
, this.expendInfo.get(EXPEND_USE_MONEY)
|
, this.budgetChildInfo.get(BUDGET_ITEM_BALANCE));
|
return;
|
}
|
this.budgetMoney = toDouble(this.budgetChildInfo.get(BUDGET_ITEM_BALANCE))
|
+ toDouble(this.expendInfo.get(EXPEND_USE_MONEY));
|
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney, updateBudgetEntity.getFormId(), this.expendInfo,
|
toDouble(expendInfo.get(EXPEND_USE_MONEY)));
|
} else {
|
// 报销-申请-预算
|
Integer applyId = getParentId(this.expendInfo);
|
if (applyId == null) {
|
log.warn("{}, 关联申请单id为空!", updateBudgetEntity);
|
return;
|
}
|
this.applyEntity.setDataRowNum(applyId);
|
this.applyInfo = getFormInfo(this.applyEntity);
|
Assert.condition(applyInfo == null, APPLY_INVALID);
|
Integer budgetId = getParentId(this.applyInfo);
|
if (budgetId == null) {
|
log.warn("{}, 关联预算单id为空!", updateBudgetEntity);
|
return;
|
}
|
addLock(budgetId);
|
this.budgetChildInfo = getFormInfo(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, budgetId);
|
Assert.condition(budgetChildInfo == null, BUDGET_INVALID);
|
if (this.expendInfo.get(EXPEND_USE_MONEY) == null
|
|| this.budgetChildInfo.get(BUDGET_ITEM_BALANCE) == null
|
|| this.applyInfo.get(APPLY_USE_MONEY) == null) {
|
log.warn("{}, 报销金额:{}, 预算余额:{}, 申请金额:{}"
|
, updateBudgetEntity
|
, this.expendInfo.get(EXPEND_USE_MONEY)
|
, this.budgetChildInfo.get(BUDGET_ITEM_BALANCE)
|
, this.applyInfo.get(APPLY_USE_MONEY));
|
return;
|
}
|
this.budgetMoney = (toDouble(this.budgetChildInfo.get(BUDGET_ITEM_BALANCE))
|
- toDouble(this.expendInfo.get(EXPEND_USE_MONEY))
|
+ toDouble(this.applyInfo.get(APPLY_USE_MONEY)));
|
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney
|
|
, updateBudgetEntity.getFormId(), this.expendInfo, toDouble(expendInfo.get(EXPEND_USE_MONEY))
|
|
, applyEntity.getFormId(), this.applyInfo, toDouble(this.applyInfo.get(APPLY_USE_MONEY)));
|
|
//回写借款金额
|
Object amountMoney = this.expendInfo.get(AMOUNTREPAYMENTS);
|
// log.debug("当前报销单:"+ JSONTool.toJson(this.expendInfo));
|
// log.debug("还款金额为:"+amountMoney);
|
if (amountMoney != null && !Objects.equals("", amountMoney)) {
|
// log.debug("报销还款金额回写-------->");
|
updateData(applyEntity.getFormId(), null, applyEntity.getDataRowNum()
|
, new ModelMap(ALREADYREPAID, 0));
|
// ,new ModelMap(ALREADYREPAID,amountMoney));
|
}
|
}
|
|
updateData(getFormId(SystemForm.BUDGET_FORM_ID), BUDGET_SUB_FROM, getDataRowNum(this.budgetChildInfo),
|
new ModelMap(BUDGET_ITEM_BALANCE, format(this.budgetMoney, getFormBase(getFormId(SystemForm.BUDGET_FORM_ID)), BUDGET_ITEM_BALANCE)));
|
}
|
|
@Override
|
public FormType getFormType() {
|
return FormType.BX;
|
}
|
|
public UpdateBudgetEntity getApplyInfo(Integer cType) {
|
String formId = null;
|
for (CostFromMapping costFromMapping : this.costFromMappings) {
|
if (Objects.equals(costFromMapping.getType(), FormType.SQ.toString())
|
&& Objects.equals(costFromMapping.getCtId(), cType)) {
|
formId = costFromMapping.getFId();
|
break;
|
}
|
}
|
if (formId == null) {
|
return null;
|
}
|
UpdateBudgetEntity updateBudgetEntity = new UpdateBudgetEntity();
|
updateBudgetEntity.setFormId(formId);
|
return updateBudgetEntity;
|
}
|
|
/**
|
* 如果为个人抵扣报销进入此方法
|
*/
|
public void getPersionCostById(UpdateBudgetEntity updateBudgetEntity) {
|
// 本次冲抵的所有的金额
|
Double money = this.persionMoney(updateBudgetEntity);
|
if (count > 0 && money > 0) {
|
// 借款单Id
|
String formId = getFormId(SystemForm.LOAN_FORM_ID);
|
if (ObjectUtil.empty(formId)) {
|
return;
|
}
|
// 不为空说明此人有借款
|
if (Objects.nonNull(borrowList) && borrowList.size() > 0) {
|
Double price = 0.0;
|
for (Map<String, Object> pb : borrowList) {
|
// 未还金额- 个人冲抵金额=判断借款单是否还完
|
price = Double.parseDouble(Objects.toString(pb.get(OUTSTANDING_AMOUNT), "0")) - money;
|
// 情况1 .本次抵扣正好还清借款
|
if (price >= 0) {
|
// 已还款金额=冲抵金额+已还金额
|
Double price2 = Double.parseDouble(Objects.toString(pb.get(ALREADY_REPAID), "0")) + money;
|
this.crudBorrowAndPersion(formId, money, price2, pb);
|
break;
|
}
|
// 冲抵还死第一条记录
|
if (price < 0) {
|
// 本条记录的冲抵金额
|
money = Double.parseDouble(Objects.toString(pb.get(OUTSTANDING_AMOUNT), "0"));
|
// 已还款金额=借款总金额
|
Double price2 = Double.parseDouble(Objects.toString(pb.get(APPLICATION_AMOUNT), "0"));
|
this.crudBorrowAndPersion(formId, money, price2, pb);
|
money = -price;
|
}
|
}
|
|
}
|
|
}
|
}
|
|
/**
|
* @param money 当前冲抵金额
|
* @param price 已还款金额
|
* @param pb 借款单数据 更新借款表
|
*/
|
public void crudBorrowAndPersion(String formId, Double money, Double price, Map<String, Object> pb) {
|
// 借款数据行号
|
Integer dataNum = Integer.parseInt(Objects.toString(pb.get(DATAROWNUMBER), "0"));
|
PersionBackMoney persionBackMoney = new PersionBackMoney();
|
persionBackMoney.initParam();
|
// 当前还款金额
|
persionBackMoney.setPayMoney(money);
|
persionBackMoney.setDataRowNum(dataNum);
|
persionBackMoney.setFormId(formId);
|
// 借款单没有币种
|
// persionBackMoney.setMoneyType();
|
persionBackMoney.setTendantId(Objects.toString(ThreadData.get(TENANT_ID)));
|
persionBackMoney.setDepartment(Objects.toString(pb.get(DEPARTMENT)));
|
String borrowTime = pb.get(CREATEDATETIME).toString();
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
persionBackMoney.setBorrowDate(formatter.parse(borrowTime));
|
} catch (ParseException e) {
|
// System.err.println(e.getMessage());
|
}
|
String openId = Objects.toString(pb.get(LOANPEOPLE));
|
persionBackMoney.setStaffId(openId);
|
persionBackMoney.setPosition(Objects.toString(pb.get(EMPLOYEE_POSITION)));
|
persionBackMoney.setPayDate(new Date());
|
// 未还总金额
|
persionBackMoney.setPayAllmoney(Double.parseDouble(Objects.toString(pb.get(APPLICATION_AMOUNT), "0")) - price);
|
persionBackMoney.setBorrowMoney(Double.parseDouble(Objects.toString(pb.get(APPLICATION_AMOUNT), "0")));
|
// 支付方式（1000000.个人抵扣2.其他的方式）
|
persionBackMoney.setPaymentMethod(GetConstant.getConstant(PERSION_COST_RETURN));
|
persionBackMoney.setOpenId(openId);
|
// 更新操作
|
persionBackMoneyMapper.insert(persionBackMoney);
|
/**
|
* 冲抵的日志
|
* 日志对象还款单
|
* 原始内容：未还款总金额
|
* 变更来源内容：冲抵金额 money
|
* */
|
if (ObjectUtil.empty(applyInfo)) {
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney, formId, this.expendInfo,
|
toDouble(expendInfo.get(EXPEND_USE_MONEY)));
|
} else {
|
addBudgetLogMoney(this.budgetChildInfo, budgetMoney
|
|
, formId, this.expendInfo, money
|
|
, applyEntity.getFormId(), this.applyInfo, toDouble(this.applyInfo.get(APPLY_USE_MONEY)));
|
}
|
|
|
// 更新借款单
|
updateData(formId, null, dataNum,
|
// 已还金额
|
new ModelMap(ALREADY_REPAID, format(price, getFormBase(formId), ALREADY_REPAID)).addAttribute(OUTSTANDING_AMOUNT,
|
// 未还金额
|
format((Double.parseDouble(Objects.toString(pb.get(APPLICATION_AMOUNT), "0")) - price), getFormBase(formId), OUTSTANDING_AMOUNT)));
|
}
|
|
/**
|
* 返回个人冲抵的金额
|
*/
|
public Double persionMoney(UpdateBudgetEntity updateBudgetEntity) {
|
// 个人冲抵金额
|
Double money = 0.0;
|
// 个人冲抵判断值
|
String keys = GetConstant.getConstant(PERSION_COST_RETURN);
|
// 报销子表单表名
|
String formName2 = updateBudgetEntity.getFormId() + PAYINFO;
|
// 主表表名
|
String formName = updateBudgetEntity.getFormId();
|
// 查询对应的报销单数据
|
list = formDataMapper.getPersionCostReturn(updateBudgetEntity.getDataRowNum(), formName, formName2);
|
for (Map<String, Object> m : list) {
|
// 个人冲抵暂定为“10000000”(页面显示现金)
|
if (Objects.equals(m.get(PAYWAY), keys) && StringUtils.isNotBlank(m.get(NETMONEY).toString())) {
|
// NETMONEY,支付金额key值
|
money += Double.parseDouble(Objects.toString(m.get(NETMONEY), "0"));
|
}
|
}
|
return money;
|
}
|
|
/**
|
* 全部借款金额
|
*/
|
public Double allBorrowMoney() {
|
String formId = getFormId(SystemForm.LOAN_FORM_ID);
|
Double borrowMoney = 0.0;
|
if (ObjectUtil.empty(formId)) {
|
return borrowMoney;
|
}
|
String openId = list.get(0).get(REIMBURSE_MAN).toString();
|
// 借款数据
|
borrowList = formDataMapper.getBorrowMoney(openId, formId);
|
for (Map<String, Object> m : borrowList) {
|
borrowMoney += Double.parseDouble(Objects.toString(m.get(OUTSTANDING_AMOUNT), "0"));
|
}
|
log.debug("当前借款金额为:" + borrowMoney.toString());
|
return borrowMoney;
|
}
|
|
}
|
