package com.changhong.epc.form.service.data.impl;
|
|
|
import com.changhong.epc.bean.form.*;
|
import com.changhong.epc.bean.form.budget.addBudget.AddBudget;
|
import com.changhong.epc.bean.parsing.BillInfo;
|
import com.changhong.epc.bean.parsing.BillVerify;
|
import com.changhong.epc.bean.tenant.cost.CostFromMapping;
|
import com.changhong.epc.bean.tenant.cost.extend.CostTypeExtend;
|
import com.changhong.epc.bean.tenant.system.SystemConfig;
|
import com.changhong.epc.bean.tenant.system.SystemForm;
|
import com.changhong.epc.constter.base.BaseConst;
|
import com.changhong.epc.constter.base.Context;
|
import com.changhong.epc.constter.form.budget.BudgetMsg;
|
import com.changhong.epc.constter.operationLog.OperationLogConst;
|
import com.changhong.epc.constter.system.SystemClients;
|
import com.changhong.epc.constter.system.businesscode.BudgetBusinessMeaningCode;
|
import com.changhong.epc.constter.system.run.EpcRestInterface;
|
import com.changhong.epc.constter.tenant.TenantUrlConst;
|
import com.changhong.epc.form.mapper.tenant.FormDataMapper;
|
import com.changhong.epc.form.mapper.tenant.bill.BillInfoMapper;
|
import com.changhong.epc.form.service.budget.department.util.AddMoney;
|
import com.changhong.epc.form.service.budget.department.util.FormCheck;
|
import com.changhong.epc.form.service.budget.impl.GetConstant;
|
import com.changhong.epc.form.service.data.FormDataService;
|
import com.changhong.epc.form.tool.FormNameTool;
|
import com.changhong.epc.rely.api.epc.admin.InitCompanyApi;
|
import com.changhong.epc.rely.api.epc.tenant.SystemConfigApi;
|
import com.codingapi.tx.annotation.TxTransaction;
|
import com.iemsoft.framework.cloud.core.base.ResMsg;
|
import com.iemsoft.framework.cloud.core.thread.ThreadData;
|
import com.iemsoft.framework.cloud.core.tools.JSONTool;
|
import com.iemsoft.framework.cloud.core.tools.MsgTool;
|
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
|
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
|
import com.iemsoft.framework.cloud.ribbon.RestInterface;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.ui.ModelMap;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
|
|
@Service("formDataService")
|
@Slf4j
|
public class FormDataServiceImpl implements BudgetMsg, SystemClients, FormDataService, BudgetBusinessMeaningCode, BaseConst , OperationLogConst {
|
|
@Resource
|
private FormCheck formCheck;
|
@Resource
|
private FormDataMapper formDataMapper;
|
@Resource
|
private InitCompanyApi initCompanyApi;
|
|
private static final String groupKey = "groupKey";
|
|
//主表单维度
|
private static final String ZORE = "0";
|
|
//子表单维度
|
private static final String ONE = "1";
|
|
private static final String SOLIDIFICATION = "solidification";
|
|
@Resource
|
private BillInfoMapper billMapper;
|
|
@Override
|
public Integer deleteFormData(FormDataEntity formData) {
|
// UserInfo userInfo = new UserInfo(); // 获取 tenantId
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
log.debug("开始执行删除表单数据123>--------------------{}","gqy");
|
int i = formDataMapper.deleteFormData(formData);
|
if (i > 0) {
|
try {
|
log.debug("准备记录日志:---------->");
|
initCompanyApi.addOperationLog(Objects.toString(formData.getFormId(),""),Objects.toString(formData.getDataIds().get(0),""),OperationLogConst.OPERATION_DELETE,formData.getUserName());
|
}catch (Exception e){
|
log.error("----------远程调用----------操作日志添加异常:{}",e.getMessage());
|
}
|
}
|
return i;
|
}
|
|
@Override
|
public List<Map<String, Object>> insertFormData(FormDataEntity formData) {
|
// UserInfo userInfo = new UserInfo();
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
List<Map<String, Object>> data = formData.getData();
|
if (ObjectUtil.notEmpty(data)) {
|
for (Map<String, Object> map : data) {
|
Map<String, Object> maps = new HashMap<String, Object>();
|
maps.put("DELETEFLG", 0);
|
maps.put("TENANTID", formData.getTenantId());
|
maps.put("CREATEUSER", "");
|
maps.put("UPDATEDATETIME", new Date());
|
maps.put("CREATEDATETIME", new Date());
|
maps.putAll(map);
|
formData.setMap(maps);
|
Integer i = formDataMapper.insertFormData(formData);
|
//----------→添加日志
|
if (i > 0) {
|
try {
|
log.debug("准备记录添加日志guo:---------->");
|
initCompanyApi.addOperationLog(Objects.toString(formData.getFormId(),""),Objects.toString(formData.getDataRowNum(),""),OperationLogConst.OPERATION_ADD,formData.getUserName());
|
}catch (Exception e){
|
log.error("----------远程调用----------操作日志添加异常:{}",e.getMessage());
|
}
|
}
|
//----------→添加日志
|
map.put("dataRowNum", formData.getDataRowNum());
|
}
|
}
|
return formData.getData();
|
}
|
|
@Override
|
@Transactional
|
@SuppressWarnings("unchecked")
|
public Integer updateFormData(FormDataEntity formData) {
|
// UserInfo userInfo = new UserInfo();
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
List<Map<String, Object>> data = formData.getData();
|
if (ObjectUtil.notEmpty(data)) {
|
for (Map<String, Object> map : data) {
|
Map<String, Object> maps = new HashMap<String, Object>();
|
maps.put("DELETEFLG", 0);
|
maps.put("TENANTID", formData.getTenantId());
|
maps.put("UPDATEDATETIME", new Date());
|
maps.put("CREATEDATETIME", new Date());
|
maps.putAll(map);
|
formData.setMap(maps);
|
formData.setParentDataRowNum((Integer) map.get("PARENTDATAROWNUM"));
|
formData.setDataRowNum(formData.getDataRowNum());
|
int i = formDataMapper.updateFormData(formData);
|
if (i > 0) {
|
try {
|
log.debug("准备记录日志:---------->");
|
initCompanyApi.addOperationLog(Objects.toString(formData.getFormId(),""),Objects.toString(formData.getDataRowNum(),""),OperationLogConst.OPERATION_EDIT,formData.getUserName());
|
}catch (Exception e){
|
log.error("----------远程调用----------操作日志添加异常:{}",e.getMessage());
|
}
|
}
|
return i;
|
}
|
}
|
return 0;
|
}
|
|
@Override
|
public Map<String, Object> searchFormData(FormDataEntity formData) {
|
// if(StringUtils.isBlank(formData.getFormId())){
|
// formName = FormNameTool.getFormTableName("001", formData.getChildAlias());
|
// }
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId()
|
, formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
// System.err.println(JSONTool.toJson(formName));
|
// System.err.println("查询表单数据:"+JSONTool.toJson(formData));
|
return formDataMapper.searchFormData(formData);
|
}
|
|
@Override
|
public List<Map<String, Object>> searchFormDataList(FormDataEntity formData) {
|
String formName;
|
if (formData.getChildAlias() != null)
|
formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
else
|
formName = FormNameTool.getFormTableName(formData.getTenantId(), formData.getFormId());
|
formData.setFormName(formName);
|
return formDataMapper.searchFormDataList(formData);
|
}
|
|
@Override
|
public Map<String, Object> searchFormInfo1(FormDataEntity formData) {
|
// System.out.println("开始查询表单数据");
|
String childAlias = formData.getChildAlias();
|
String formName;
|
List<Map<String, Object>> subData = new ArrayList<Map<String, Object>>();
|
if (childAlias != null) {
|
formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
subData = formDataMapper.searchFormDataLists(formData);
|
if (ObjectUtil.notEmpty(subData)) {
|
List<Integer> ids = formDataMapper.searchSubFormIds(formName, formData.getDataRowNum());
|
if (ObjectUtil.notEmpty(ids)) {
|
subData.stream()
|
.forEach(sub -> {
|
Integer id = Integer.valueOf(Objects.toString(sub.get("DATAROWNUM"), "0"));
|
int index = Arrays.binarySearch(ids.stream().toArray(Integer[]::new), id);
|
sub.put("index", index);
|
});
|
}
|
}
|
}
|
|
formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId());
|
formData.setFormName(formName);
|
formData.setChildAlias(null);
|
Map<String, Object> searchFormData = formDataMapper.searchFormData1(formData);
|
if (childAlias != null) {
|
searchFormData.put(childAlias, subData);
|
}
|
return searchFormData;
|
}
|
|
@Override
|
public List<Integer> selectRangeByIds(String formName,
|
String formDate, String toData, String budType, String currency, String occupy, Integer pageNum, Integer pageSize, String budProject, String budDep) {
|
return formDataMapper.selectRangeByIds(formName, formDate, toData, budType, currency, null, occupy, budProject, budDep, pageNum, pageSize);
|
}
|
|
@Override
|
public List<Integer> selectMainIdBySubIds(String formId, String rowId) {
|
return formDataMapper.selectMainIdBySubIds(formId, rowId);
|
}
|
|
@Override
|
public List<AddMoney> searchExtendFormData(String formName, String parentDataRowNum, String dataRowNum) {
|
return formDataMapper.searchExtendFormData(formName, parentDataRowNum, dataRowNum);
|
}
|
|
@Override
|
public int updateItemBalance(AddMoney add, String formName) {
|
return formDataMapper.updateItemBalance(add, formName);
|
}
|
|
@Override
|
public int updaterepayment(String formName, Integer OutstandingAmount, Integer alreadyRepaid,
|
Integer dataRowNum) {
|
return formDataMapper.updaterepayment(formName, OutstandingAmount, alreadyRepaid, dataRowNum);
|
}
|
|
/**
|
* 根据groupKey查出对应组
|
*
|
* @param formId
|
*/
|
private List<SystemConfig> getSysConfigCondition(String formId) {
|
return SpringUtil.getBean(SystemConfigApi.class)
|
.getSystemConfigs(SystemConfig.of(formId, "1"));
|
}
|
|
|
@Override
|
public String checkBugetData(CheckBuget checkBuget) {
|
//表单数据
|
BugetData bud = checkBuget.getData();
|
String key = null;
|
//判断是部门预算还是项目预算
|
|
if (GetConstant.getConstant(BUDGET_PROJECT).equals(bud.getBudget_type())) {
|
key = BUDGET_PROJECT_CONFIGURATION;
|
} else {
|
key = BUDGET_CONFIGURATION;
|
}
|
//查询系统配置
|
List<SystemConfig> configData = this.getSysConfigCondition(key);
|
if (configData == null) {
|
return "true";
|
}
|
BugetData da = null;
|
//重写-----------------------重写-----------------------
|
|
//最后匹配数据
|
da = this.matchingData(configData, bud);
|
// System.out.println("最终数据:"+JSONTool.toJson(da));
|
BugetData data = checkBuget.getData();
|
if (da == null) {
|
return MsgTool.get(BUDGETINFO_DEFICLENCY);
|
}
|
if (Objects.isNull(data)) {
|
return MsgTool.get(BUDGETINFO_NOTFOUND);
|
}
|
;
|
//主表单名。子表单名
|
String formName = FormNameTool.getFormTableName(checkBuget.getTenantID(), checkBuget.getFormID());
|
String subFormName = FormNameTool.getSubFormTableName(checkBuget.getTenantID(), checkBuget.getFormID(), BUDGET_SUB_FROM);
|
|
|
//取出可用预算单主表datarownum
|
List<Integer> selectRangeByIds = formDataMapper.selectRangeById(
|
formName,//主表单表单名
|
this.isNum(da.getBudgetStartDate()),//预算开始事件
|
this.isNum(da.getBudgetEndDate()),//预算结束事件
|
this.isNum(da.getBudget_type()),//预算类型
|
this.isNum(da.getCurrency()),//币种
|
this.isNum(da.getOccupy())
|
);
|
//
|
List<Integer> selectRangeByIdsOnlyOne = formDataMapper.selectRangeByIdOnlyOne(
|
formName,//主表单表单名
|
subFormName,//子表单表名
|
bud.getBudget_subFrom(),//行号
|
this.isNum(da.getBudgetStartDate()),//预算开始事件
|
this.isNum(da.getBudgetEndDate()),//预算结束事件
|
this.isNum(da.getBudget_type()),//预算类型
|
this.isNum(da.getCurrency()),//币种
|
this.isNum(da.getOccupy())
|
);
|
//时间没有相同得直接让人return
|
|
if (ObjectUtil.empty(selectRangeByIds)) {
|
return "true";
|
}
|
if (this.isNum(checkBuget.getDataRowNum()) != null && selectRangeByIds.size() > 0) {
|
int num = selectRangeByIds.indexOf(Integer.parseInt(checkBuget.getDataRowNum()));
|
if (num >= 0) {
|
selectRangeByIds.remove(num);
|
}
|
}
|
if (selectRangeByIds.size() == 0) {
|
return "true";
|
}
|
List<BugetSubForm> subs = da.getBudget_subFrom();
|
String res = null;
|
//循环查询子表单
|
if (ObjectUtil.notEmpty(subs)) {
|
for (BugetSubForm i : subs) {
|
res = formDataMapper.selectRangeByNumber(this.isNum(i.getC_Type())
|
, this.isNum(i.getBudget_itemDepartment())
|
, this.isNum(i.getBudget_project())
|
, subFormName, selectRangeByIdsOnlyOne);
|
String s = formDataMapper.selectByNumber(formName, res, NUMBER_BUDGET);
|
if (res != null) {
|
return MsgTool.get(DEP_RETEPI) + s;
|
}
|
}
|
}
|
|
// if( !"".equals(checkBuget.getData().getToWriteBudget())){
|
// Integer superDataRowNum = Integer.parseInt(checkBuget.getData().getToWriteBudget());
|
// FormDataEntity superFormParam = new FormDataEntity();
|
// superFormParam.setDataRowNum(superDataRowNum);
|
// superFormParam.setFormId(checkBuget.getFormID());
|
// superFormParam.setChildAlias(BUDGET_SUB_FROM);
|
// List<Map<String, Object>> superSubFormData = this.searchFormDataList(superFormParam);
|
//
|
// for(Map<String, Object> ssfd: superSubFormData){
|
// for(BugetSubForm busf:checkBuget.getData().getBudget_subFrom()){
|
// if(busf.getDATAROWNUM().equals(ssfd.get("DATAROWNUM").toString())){
|
// if(new BigDecimal(ssfd.get(BUDGET_ITEM_BALANCE).toString())
|
// .subtract(new BigDecimal(busf.getBudget_itemBalance())).compareTo(BigDecimal.ZERO) == -1)
|
// return "上级预算余额不足!";
|
// }
|
// }
|
// }
|
// }
|
|
// //检查部门
|
// for(BugetSubForm bugetS :data.getBudget_subFrom()){
|
// // System.err.println(bugetS.getBudget_itemDepartment());
|
// if("".equals(bugetS.getBudget_itemDepartment()) || bugetS.getBudget_itemDepartment() == null){
|
// return "当前部门为空";
|
// }
|
//// if(!"".equals(bugetS.getBudget_superDepartement()) && bugetS.getBudget_superDepartement() != null){
|
//// if(!formCheck.isOrg(bugetS.getBudget_superDepartement(), bugetS.getBudget_itemDepartment()))
|
//// return "部门非上下级!";
|
//// }
|
//
|
// }
|
|
return "true";
|
}
|
|
/**
|
* 查询相同币种的日期是否包含,交叉
|
*
|
* @return
|
*/
|
private List<Integer> checkDate(String formName, String startDate, String endDate, String currency) {
|
return formDataMapper.checkDate(formName, startDate, endDate, currency);
|
}
|
|
/**
|
* 查询上级
|
*/
|
@Override
|
public Map<String, Object> selectBudget(String orgs, String budget_itemCostType, String formName) {
|
return formDataMapper.selectBudget(orgs, budget_itemCostType, formName);
|
}
|
|
@Override
|
public List<BugetSubForm> searchBudgetSubForm(FormDataEntity formData, HashSet<?> costType) {
|
formData.setFormName(FormNameTool.getSubFormTableName(formData.getTenantId()
|
, formData.getFormId()
|
, formData.getChildAlias()));
|
return formDataMapper.searchBudgetSubForm(formData, costType);
|
}
|
|
@Override
|
public int updateExpendFormState(String voucherCode, String formId, int dataRowNum, Integer status, String tenantID) {
|
String formName = FormNameTool.getFormTableName(tenantID, formId);
|
return formDataMapper.updateExpendFormState(voucherCode, formName, dataRowNum, status);
|
}
|
|
@Override
|
public int updateFormAndBillInfo(BillInfo billInfo) {
|
// 临时解决主数据缺失
|
billInfo.setVerify(BillVerify.BQS);
|
int result = billMapper.updateBill(billInfo);
|
if (result == 0) {
|
result = billMapper.insert(billInfo);
|
}
|
// String formName = FormNameTool.getFormTableName(billInfo.getTenantID(), billInfo.getFormId());
|
String formName = FormNameTool.getFormTableName(ThreadData.get(TENANT_ID), billInfo.getFormId());
|
formDataMapper.updateExpendFormIfHaveOrderCode(formName, billInfo.getFormDataId(), billInfo.getOrderCode());
|
return result;
|
}
|
|
@Override
|
public int selectDataRowNum(Map<String, Object> map) {
|
return formDataMapper.selectDataRowNum(map.get("formId"), map.get("tenantId"), map.get("orderCode"));
|
}
|
|
/**
|
* 查询表单单条
|
*
|
* @param formDataEntity
|
* @return
|
*/
|
public Map<String, Object> selectFormDataOne(FormDataEntity formDataEntity) {
|
formDataEntity.setFormName(FormNameTool.getFormTableName(formDataEntity.getTenantId(), formDataEntity.getFormId()));
|
Map<String, Object> formDataInfo = formDataMapper.searchFormData(formDataEntity);
|
if (ObjectUtil.empty(formDataEntity.getChildAliaList()))
|
return formDataInfo;
|
formDataEntity.setParentDataRowNum(formDataEntity.getDataRowNum());
|
for (String childAlias : formDataEntity.getChildAliaList()) {
|
formDataEntity.setFormName(FormNameTool.getSubFormTableName(formDataEntity.getTenantId(), formDataEntity.getFormId(), childAlias));
|
formDataInfo.put(childAlias, formDataMapper.searchSubFormDataList(formDataEntity));
|
}
|
return formDataInfo;
|
}
|
|
@Override
|
public int updateForm(FormDataEntity formData) {
|
String tableName;
|
if (ObjectUtil.notEmpty(formData.getChildAlias())) {
|
tableName = "formdata_" + formData.getTenantId() + "_" + formData.getFormId() + "_" + formData.getChildAlias();
|
} else {
|
tableName = "formdata_" + formData.getTenantId() + "_" + formData.getFormId();
|
}
|
formData.setFormName(tableName);
|
int i = formDataMapper.updateFormData(formData);
|
if (i > 0) {
|
try {
|
log.debug("准备记录添加添加添加日志:---------->");
|
initCompanyApi.addOperationLog(Objects.toString(formData.getFormId(),""),Objects.toString(formData.getDataRowNum(),""),OperationLogConst.OPERATION_ADD,formData.getUserName());
|
}catch (Exception e){
|
log.error("----------远程调用----------操作日志添加异常:{}",e.getMessage());
|
}
|
}
|
|
|
return i;
|
}
|
|
@Override
|
@TxTransaction
|
@Transactional
|
public Integer updateState(ProcessState process) {
|
return formDataMapper.updateState(process);
|
}
|
|
@Override
|
public ProcessState selectState(ProcessState process) {
|
ProcessState pro = formDataMapper.selectState(process);
|
if (ObjectUtil.empty(pro)) {
|
return pro;
|
}
|
String formName = FormNameTool.getFormTableName(process.getTenantId(), process.getFormId());
|
try {
|
LinkedHashMap<String, Object> map = formDataMapper.selectNumber(formName, Objects.toString(process.getDataRowNum(), "0"));
|
pro.setMainInfo(map);
|
Set<String> set = map.keySet();
|
int count = 0;
|
for (String se : set) {
|
if (se.indexOf("number_") == 0 && ObjectUtil.notEmpty(map.get(se))) {
|
count += 1;
|
if (!Objects.equals("number_budget", se)) {
|
pro.setNumber(Objects.toString(map.get(se), "-"));
|
return pro;
|
|
}
|
}
|
}
|
//只有一个number_开头说明是预算单-----
|
if (count == 1) {
|
pro.setNumber(Objects.toString(map.get("number_budget"), "-"));
|
}
|
} catch (Exception e) {
|
pro.setNumber("-");
|
// System.err.println(e.getMessage());
|
}
|
|
return pro;
|
}
|
|
@Override
|
public Object selectCountMoney(FormDataEntity formData) {
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
|
formData.setFormName(formName);
|
formData.setMap(new ModelMap("stage", ""));
|
|
return formDataMapper.searchFormData(formData);
|
}
|
|
@Override
|
public Map<String, Object> searchFormInfo(FormDataEntity formData) {
|
String childAlias = formData.getChildAlias();
|
String formName;
|
List<Map<String, Object>> subData = new ArrayList<Map<String, Object>>();
|
if (childAlias != null) {
|
formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
subData = formDataMapper.searchFormDataList(formData);
|
}
|
|
formName = FormNameTool.getSubFormTableName(formData.getTenantId(), formData.getFormId());
|
formData.setFormName(formName);
|
formData.setChildAlias(null);
|
Map<String, Object> searchFormData = formDataMapper.searchFormData1(formData);
|
if (childAlias != null) {
|
searchFormData.put(childAlias, subData);
|
}
|
return searchFormData;
|
}
|
|
@Override
|
public int updataFormByCustom(String formName, int dataRowNum, Map<String, Object> fields) {
|
return formDataMapper.updataFormByCustom(formName, dataRowNum, fields);
|
}
|
|
@Override
|
public Map<String, Object> searchFormData1(FormDataEntity formData) {
|
// if(StringUtils.isBlank(formData.getFormId())){
|
// formName = FormNameTool.getFormTableName("001", formData.getChildAlias());
|
// }
|
String formName = FormNameTool.getSubFormTableName(formData.getTenantId()
|
, formData.getFormId(), formData.getChildAlias());
|
formData.setFormName(formName);
|
// System.err.println(JSONTool.toJson(formName));
|
// System.err.println("查询表单数据:"+JSONTool.toJson(formData));
|
return formDataMapper.searchFormData1(formData);
|
}
|
|
public String isNum(String o) {
|
return o != null && !"".equals(o) ? o : null;
|
}
|
|
/**
|
* 表单数据于维度匹配
|
*/
|
@SuppressWarnings("unchecked")
|
public BugetData matchingData(List<SystemConfig> config, BugetData bd) {
|
//接受主表数据
|
Map<String, Object> map = new HashMap<>();
|
//接受子表单数据
|
List<Map> subs = new ArrayList<>();
|
//主表数据
|
Map<String, String> da = JSONTool.toObj(JSONTool.toJson(bd), Map.class);
|
//子表单数据
|
List<Map> sub = JSONTool.toList(JSONTool.toJson(bd.getBudget_subFrom()), Map.class);
|
// System.out.println("主表数据:"+JSONTool.toJson(da));
|
if (ObjectUtil.empty(config)) {
|
config = new ArrayList<>();
|
}
|
for (SystemConfig con : config) {
|
// System.out.println("当前配置:"+JSONTool.toJson(con));
|
// System.out.println("当前数据:"+da.get(con.getCkey()));
|
if (ZORE.equals(con.getFlag())) {
|
if (this.isNum(da.get(con.getCkey())) == null) {
|
return null;
|
}
|
map.put(con.getCkey(), da.get(con.getCkey()));
|
}
|
}
|
if (ObjectUtil.empty(sub)) {
|
sub = new ArrayList<>();
|
}
|
// System.out.println("预算子表单为:"+JSONTool.toJson(sub));
|
for (Map m : sub) {
|
m.put("C_Type", m.get("C_Type"));
|
m.remove("c_Type");
|
Map<String, Object> su = new HashMap<>();
|
for (SystemConfig con : config) {
|
if (ONE.equals(con.getFlag())) {
|
if (this.isNum(Objects.toString(m.get(con.getCkey()))) == null) {
|
return null;
|
}
|
su.put(con.getCkey(), m.get(con.getCkey()));
|
}
|
}
|
subs.add(su);
|
}
|
map.put(BUDGET_SUB_FROM, subs);
|
|
|
return JSONTool.toObj(JSONTool.toJson(map), BugetData.class);
|
}
|
|
|
@Override
|
public Object checkSuperBudgetMoney(AddBudget addBudget) {
|
Integer toWriteBudgetId = addBudget.getDataRowNum();
|
Map<String, Object> result = new HashMap<String, Object>();//返回值集合
|
String fromId = GetConstant.getFormIdGetConstant(YS_FORMID);//预算表id
|
String budgetFormId2 = FormNameTool.getFormTableName(addBudget.getTenantId(), fromId);
|
String budgetSubFormId = FormNameTool.getSubFormTableName(addBudget.getTenantId(), fromId, BUDGET_SUB_FROM);
|
|
Map<String, Object> nowData2 = formDataMapper.searchFormData(new FormDataEntity(budgetFormId2, toWriteBudgetId));
|
|
|
Object toW = null;
|
if (nowData2 != null) {
|
toW = nowData2.get(TO_WRITE_BUDGET);
|
}
|
if (toW == null) {
|
result.put("notF", "T");
|
} else {
|
result.put("notF", "N");
|
FormDataEntity formData = new FormDataEntity();
|
formData.setFormName(budgetSubFormId);
|
formData.setChildAlias(BUDGET_SUB_FROM);
|
formData.setDataRowNum(toWriteBudgetId);
|
List<Map<String, Object>> subperData1 = formDataMapper.searchFormDataList(formData);
|
|
Integer toWBId = Integer.parseInt(toW.toString());
|
FormDataEntity superFormData = new FormDataEntity();
|
superFormData.setFormName(budgetSubFormId);
|
superFormData.setChildAlias(BUDGET_SUB_FROM);
|
superFormData.setDataRowNum(toWBId);
|
|
|
List<Map<String, Object>> subperData = formDataMapper.searchFormDataList(superFormData);
|
List<Map<String, Object>> listend = new ArrayList<Map<String, Object>>();
|
|
for (Map<String, Object> ma : subperData1) {
|
for (Map<String, Object> mae : subperData) {
|
if (ma.get("budget_superDepartement") != null && mae.get("budget_itemDepartment") != null && Objects.toString(ma.get("budget_superDepartement")).equals(mae.get("budget_itemDepartment"))) {
|
Map<String, Object> map1 = new HashMap<String, Object>();
|
map1.put("dep", ma.get("budget_itemDepartment"));
|
map1.put("C_Type", mae.get("C_Type"));
|
map1.put("balance", mae.get("budget_itemBalance"));
|
listend.add(map1);
|
}
|
}
|
}
|
|
// subperData.stream().forEach( map ->{
|
// Map<String,Object> map1 =new HashMap<String,Object>();
|
// map1.put("dep", map.get("budget_itemDepartment"));
|
// map1.put("C_Type", map.get("C_Type"));
|
// map1.put("balance", map.get("budget_itemBalance"));
|
// //if(null != (map.get("budget_itemBalance")) && map.get("budget_itemBalance") != null && ){
|
// //result.add(Double.parseDouble(map.get("budget_itemBalance").toString()));
|
//
|
// //}
|
// listend.add(map1);
|
// });
|
result.put("list", listend);
|
}
|
return result;
|
}
|
|
@Override
|
public Object checkAsserFixedMoney(Map<String, String> map) {
|
Map<String, Object> resMap = new HashMap<String, Object>();
|
String tenantId = map.get("tenantID");
|
String assetId = map.get("assetId");
|
String dataRowNum = map.get("dataRowNum");
|
String assetFromId = GetConstant.getFormIdGetConstant(SystemForm.ASSET_FORM_ID.name());
|
Map<String, String> assetMap = formDataMapper.selectAssetOri(tenantId, assetFromId, assetId);
|
String fromId = GetConstant.getFormIdGetConstant(YS_FORMID);
|
String budgetSubFormId = FormNameTool.getSubFormTableName(tenantId, fromId, BUDGET_SUB_FROM);
|
FormDataEntity superFormData = new FormDataEntity();
|
superFormData.setFormName(budgetSubFormId);
|
superFormData.setDataRowNum(Integer.parseInt(dataRowNum));
|
List<Map<String, Object>> subperData = formDataMapper.searchFormDataList(superFormData);
|
resMap.put("originalMoney", Double.parseDouble(Objects.toString(assetMap.get("originalMoney"))));
|
for (Map<String, Object> m : subperData) {
|
resMap.put("budgetItemBalance", Double.parseDouble(Objects.toString(m.get("budget_itemBalance"))));
|
}
|
return resMap;
|
}
|
|
/**
|
* 返回每页数据、页数、总条数
|
*/
|
@Override
|
public Object selectDatasByUserName(Map<String, String> map) {
|
Map<String, Object> endMap = new HashMap<String, Object>();
|
List<Map<String, Object>> maps = null;
|
int count = 0;
|
int countPage = 0;
|
String pageNum = map.get("pageNum");//页号
|
String pageSize = map.get("pageSize");//页大小
|
String costType = map.get("costType");
|
//费用类型 前端写死 差旅费
|
String formId = Objects.toString(formDataMapper.selectFormIdByCostTypeAndFormType(costType, SQ).get(FORM_ID));
|
String bxFormId = Objects.toString(formDataMapper.selectFormIdByCostTypeAndFormType(costType, BX).get(FORM_ID));
|
if (!"null".equals(formId) && !"".equals(formId)) {
|
String tenantId = Objects.toString(ThreadData.get(TENANT_ID));
|
String openId = Objects.toString(ThreadData.get(OPEN_ID));
|
count = formDataMapper.selectDataCountByUser(tenantId, formId, openId, costType);
|
countPage = count % Integer.parseInt(pageSize) > 0 ? count / Integer.parseInt(pageSize) + 1 : count / Integer.parseInt(pageSize);
|
if (countPage > 0) {
|
String begin = Objects.toString((Integer.parseInt(pageNum) - 1) * Integer.parseInt(pageSize));
|
maps = formDataMapper.selectDataListByUser(tenantId, formId, openId, costType, begin, pageSize);
|
}
|
}
|
endMap.put("list", maps);
|
endMap.put("countPage", countPage);
|
endMap.put("dataCount", count);
|
endMap.put("sqFormId", formId);
|
endMap.put("bxFormId", bxFormId);
|
return endMap;
|
}
|
|
@Override
|
public Object selectBXByRow(Map<String, String> map) {
|
String tenantId = Objects.toString(ThreadData.get(TENANT_ID));
|
return formDataMapper.selectDataBybussinessNumber(map.get("formId"), map.get("bussinessNumber"), tenantId);
|
}
|
|
@Transactional
|
@Override
|
public Integer updateSubFormDat(Map<String, Object> map) {
|
//表单id
|
String formId = Objects.toString(map.get("formID"));
|
//主表dataRowNum
|
Integer dataRowNum = Integer.parseInt(Objects.toString(map.get("dataRowNum")));
|
//租户id
|
String tenantID = Context.getTenantIdStr();
|
//表单数据
|
Map<String, Object> data = (Map<String, Object>) map.get("data");
|
//用于主表存储
|
Map<String, Object> datas = new HashMap<>();
|
data.entrySet().stream()
|
.forEach(entry -> {
|
if (entry.getValue() instanceof List) {
|
List<Map> list = (List<Map>) entry.getValue();
|
FormDataEntity formData = new FormDataEntity();
|
formData.setFormId(formId);
|
formData.setTenantId(tenantID);
|
for (Map ma : list) {
|
if (ma.get(DATAROWNUMBER) == null || "".equals(ma.get(DATAROWNUMBER))) {
|
continue;
|
}
|
Integer rowNum = Integer.parseInt(Objects.toString(ma.get(DATAROWNUMBER), ""));
|
formData.setDataRowNum(rowNum);
|
ma.remove(DATAROWNUMBER);
|
formData.setMap(ma);
|
formData.setChildAlias(entry.getKey());
|
// 修改子表单
|
this.updateForm(formData);
|
}
|
} else {
|
datas.put(entry.getKey(), entry.getValue());
|
}
|
});
|
FormDataEntity formData = new FormDataEntity();
|
formData.setMap(datas);
|
formData.setDataRowNum(dataRowNum);
|
formData.setTenantId(tenantID);
|
formData.setFormId(formId);
|
// 修改主表单
|
this.updateForm(formData);
|
return 1;
|
}
|
|
@Override
|
public String formSolidiFication(FormSolidiFication fs) {
|
String formName = "formdata_" + fs.getTenantId() + "_" + fs.getFormId();
|
FormDataEntity fd = new FormDataEntity();
|
fd.setDataRowNum(fs.getDataRowNum());
|
fd.setFormName(formName);
|
//取出主表数据
|
Map<String, Object> data = formDataMapper.searchFormData(fd);
|
data.remove(SOLIDIFICATION);
|
//取出子表数据
|
Map<String, Object> subData = new HashMap<>();
|
fs.getTableList().stream().forEach(o -> {
|
fd.setFormName(o.getTableName());
|
fd.setParentDataRowNum(fs.getDataRowNum());
|
subData.put(Objects.toString(o.getFormdataNum(), "0"),
|
formDataMapper.searchSubFormDataList(fd));
|
});
|
Map<String, Object> soData = new ModelMap("main", data)
|
.addAttribute("subs", subData);
|
//添加固化数据
|
return JSONTool.toJson(soData);
|
|
}
|
|
@Override
|
public List<Map<String, Object>> selectApply(ApplyCostForm applyCostForm) {
|
List<CostFromMapping> list = getApplyIds();
|
List<Map<String, Object>> res = null;
|
if (list == null || list.size() == 0) {
|
return res;
|
}
|
list.stream().forEach(o -> o.setFormId(o.getFId()));
|
|
Map<String, String> costs = getCostType(list);
|
if (ObjectUtil.empty(list)) {
|
return new ArrayList<>();
|
}
|
applyCostForm.setCostformMapping(list);
|
res = formDataMapper.selectApply(applyCostForm);
|
//人员主数据,转换业务类型
|
Map<String, Object> users = getUserMaster();
|
// System.out.println("业务类型:"+costs);
|
res.stream().forEach(o -> {
|
// System.out.println(Objects.toString(o.get(COST_TYPE)));
|
// System.out.println(costs.get(Objects.toString(o.get(COST_TYPE))));
|
o.put("C_Name", costs.get(Objects.toString(o.get(COST_TYPE))));
|
o.put(REIMBURSE_MAN, users.get(Objects.toString(o.get(REIMBURSE_MAN))));
|
});
|
return res;
|
}
|
|
/**
|
* 查询所有申请单id
|
*/
|
public List<CostFromMapping> getApplyIds() {
|
RestInterface restInterface = SpringUtil.getBean(SERVER_TENANT.getBeanName(), RestInterface.class);
|
Object data = restInterface.post(TenantUrlConst.REST_TENANT_COST_FORMID, new ModelMap("type", "SQ"), ResMsg.class, EpcRestInterface.getEpcHeads()).getData();
|
if (data != null) {
|
List<CostFromMapping> list = JSONTool.toList(JSONTool.toJson(data), CostFromMapping.class);
|
return list != null && list.size() > 0 ? list : null;
|
}
|
return null;
|
}
|
|
/**
|
* 取出所有业务类型
|
*/
|
public Map<String, String> getCostType(List<CostFromMapping> lists) {
|
Map<Integer, String> formMapping = new HashMap<>();
|
Map<String, String> map = new HashMap<>();
|
RestInterface restInterface = SpringUtil.getBean(SERVER_TENANT.getBeanName(), RestInterface.class);
|
Object data = restInterface.post(TenantUrlConst.REST_TENANT_COSTTYPE_SEACH, new ModelMap("type", "BX"), ResMsg.class, EpcRestInterface.getEpcHeads()).getData();
|
List<CostTypeExtend> list = JSONTool.toList(JSONTool.toJson(data), CostTypeExtend.class);
|
list.stream().forEach(o -> {
|
map.put(Objects.toString(o.getId()), o.getNodeName());
|
addExpenseFormId(o.getId(), o.getCostFromMapping(), formMapping);
|
if (o.getChildren().size() > 0) {
|
o.getChildren().stream().forEach(c -> {
|
map.put(Objects.toString(c.getId()), c.getNodeName());
|
addExpenseFormId(c.getId(), c.getCostFromMapping(), formMapping);
|
});
|
}
|
});
|
Iterator<CostFromMapping> iterator = lists.iterator();
|
while (iterator.hasNext()) {
|
CostFromMapping costFromMapping = iterator.next();
|
String fId = formMapping.get(costFromMapping.getCtId());
|
if (ObjectUtil.notEmpty(fId)) {
|
costFromMapping.setExpenseFormId(fId);
|
} else {
|
iterator.remove();
|
}
|
}
|
|
return map;
|
}
|
//
|
// public static void main(String... args){
|
// Map<Integer,String> formMapping = new HashMap<>();
|
// FormDataServiceImpl formDataService = new FormDataServiceImpl();
|
// Map<String, String> map = new HashMap<>();
|
// List<CostFromMapping> lists = JSONTool.toList("[{\"fId\":\"unlhUVmN\",\"ctId\":371,\"fName\":\"差旅申请单\",\"id\":1,\"type\":\"SQ\"},{\"fId\":\"f412933e70714f5297bfee0594b629d6\",\"ctId\":51,\"fName\":\"通用申请单\",\"id\":5,\"type\":\"SQ\"}]", CostFromMapping.class);
|
// List<CostTypeExtend> list = JSONTool.toList("[{\"nodeName\":\"费用业务\",\"children\":[{\"nodeName\":\"差旅费\",\"children\":[],\"costFromMapping\":[{\"fId\":\"awvI3wti\",\"fName\":\"差旅报销单SQ\",\"type\":\"BX\"}],\"id\":371,\"type\":\"1\",\"parentId\":17},{\"nodeName\":\"办公费\",\"children\":[],\"costFromMapping\":[{\"fId\":\"LNEC3mFp\",\"fName\":\"报销单通用SQ\",\"type\":\"BX\"}],\"id\":51,\"type\":\"1\",\"parentId\":17}],\"costFromMapping\":[],\"id\":17,\"parentId\":0}]",CostTypeExtend.class);
|
// list.stream().forEach(o-> {
|
// map.put(Objects.toString(o.getId()),o.getNodeName());
|
// formDataService.addExpenseFormId(o.getId(), o.getCostFromMapping(),formMapping);
|
// if(o.getChildren().size()>0){
|
// o.getChildren().stream().forEach(c->{
|
// map.put(Objects.toString(c.getId()),c.getNodeName());
|
// formDataService.addExpenseFormId(c.getId(), c.getCostFromMapping(),formMapping);
|
// });
|
// }
|
// });
|
// Iterator<CostFromMapping> iterator = lists.iterator();
|
// while (iterator.hasNext()){
|
// CostFromMapping costFromMapping = iterator.next();
|
// String fId = formMapping.get(costFromMapping.getCtId());
|
// if(ObjectUtil.notEmpty(fId)){
|
// costFromMapping.setExpenseFormId(fId);
|
// }else{
|
// iterator.remove();
|
// }
|
// }
|
//
|
// System.out.println(map);
|
// System.out.println(JSONTool.toJson(lists));
|
// }
|
|
/**
|
* 填充报销单formId,如果没有报销单，删除当前业务类型
|
*
|
* @return
|
*/
|
public void addExpenseFormId(Integer ctId, List<CostFromMapping> cost, Map<Integer, String> map) {
|
cost.stream().forEach(o -> map.put(ctId, o.getFId()));
|
}
|
|
public Map<String, Object> getUserMaster() {
|
|
RestInterface restInterface = SpringUtil.getBean(SERVER_TENANT.getBeanName(), RestInterface.class);
|
Object data = restInterface.post(TenantUrlConst.REST_TENANT_MASTERVALUE_SELECTVALUE, new ModelMap("defineCode", GetConstant.getConstant("personnel")), ResMsg.class, EpcRestInterface.getEpcHeads()).getData();
|
Map<String, Object> m = new HashMap<>();
|
if (data != null) {
|
JSONTool.toList(JSONTool.toJson(data), Map.class).stream().forEach(o -> {
|
m.put(Objects.toString(o.get("code")), o.get("value"));
|
});
|
}
|
return m;
|
|
}
|
|
|
}
|
