1144 lines
58 KiB
Java
1144 lines
58 KiB
Java
package com.engine.salary.service.impl;
|
||
|
||
import cn.hutool.core.bean.BeanUtil;
|
||
import com.cloudstore.eccom.pc.table.WeaTableColumn;
|
||
import com.engine.common.util.ServiceUtil;
|
||
import com.engine.core.impl.Service;
|
||
import com.engine.salary.entity.hrm.DeptInfo;
|
||
import com.engine.salary.entity.hrm.SubCompanyInfo;
|
||
import com.engine.salary.entity.ly.dto.*;
|
||
import com.engine.salary.entity.ly.param.*;
|
||
import com.engine.salary.entity.ly.po.*;
|
||
import com.engine.salary.entity.salaryformula.ExpressFormula;
|
||
import com.engine.salary.entity.salaryformula.po.FormulaVar;
|
||
import com.engine.salary.enums.ly.LyFzhsTypeEnum;
|
||
import com.engine.salary.enums.ly.LyJDDirectionTypeEnum;
|
||
import com.engine.salary.enums.ly.LyPZTypeEnum;
|
||
import com.engine.salary.enums.salaryformula.ReferenceTypeEnum;
|
||
import com.engine.salary.exception.SalaryRunTimeException;
|
||
import com.engine.salary.formlua.entity.parameter.DataType;
|
||
import com.engine.salary.formlua.entity.standard.ExcelResult;
|
||
import com.engine.salary.mapper.ly.LyVoucherDetailMapper;
|
||
import com.engine.salary.mapper.ly.LyVoucherMapper;
|
||
import com.engine.salary.mapper.ly.UfKjkmMapper;
|
||
import com.engine.salary.service.*;
|
||
import com.engine.salary.util.SalaryDateUtil;
|
||
import com.engine.salary.util.SalaryEntityUtil;
|
||
import com.engine.salary.util.db.IdGenerator;
|
||
import com.engine.salary.util.db.MapperProxyFactory;
|
||
import com.engine.salary.util.page.PageInfo;
|
||
import com.engine.salary.util.page.SalaryPageUtil;
|
||
import com.engine.salary.util.xml.XStreamUtil;
|
||
import com.google.common.collect.Lists;
|
||
import lombok.extern.slf4j.Slf4j;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.apache.commons.collections4.MapUtils;
|
||
import org.apache.commons.httpclient.HttpClient;
|
||
import org.apache.commons.httpclient.methods.PostMethod;
|
||
import org.apache.commons.httpclient.methods.RequestEntity;
|
||
import org.apache.commons.httpclient.methods.StringRequestEntity;
|
||
import org.apache.commons.lang.StringUtils;
|
||
import org.apache.commons.lang3.math.NumberUtils;
|
||
import weaver.conn.RecordSet;
|
||
import weaver.general.BaseBean;
|
||
import weaver.general.Util;
|
||
import weaver.hrm.User;
|
||
|
||
import java.math.BigDecimal;
|
||
import java.util.*;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* @author Harryxzy
|
||
* @ClassName LyPZServiceImpl
|
||
* @date 2024/08/27 10:14
|
||
* @description
|
||
*/
|
||
@Slf4j
|
||
public class LyPZServiceImpl extends Service implements LyPZService {
|
||
|
||
private LySalaryReportService getLySalaryReportService(User user) {
|
||
return ServiceUtil.getService(LySalaryReportServiceImpl.class, user);
|
||
}
|
||
|
||
private LySocialReportService getLySocialReportService(User user) {
|
||
return ServiceUtil.getService(LySocialReportServiceImpl.class, user);
|
||
}
|
||
|
||
private LyFundReportService getLyFundReportService(User user) {
|
||
return ServiceUtil.getService(LyFundReportServiceImpl.class, user);
|
||
}
|
||
|
||
private FormulaRunService getFormulaRunService(User user) {
|
||
return ServiceUtil.getService(FormulaRunServiceImpl.class, user);
|
||
}
|
||
|
||
private LyVoucherMapper getLyVoucherMapper() {
|
||
return MapperProxyFactory.getProxy(LyVoucherMapper.class);
|
||
}
|
||
|
||
private LyVoucherDetailMapper getLyVoucherDetailMapper() {
|
||
return MapperProxyFactory.getProxy(LyVoucherDetailMapper.class);
|
||
}
|
||
|
||
private UfKjkmMapper getUfKjkmMapper() {
|
||
return MapperProxyFactory.getProxy(UfKjkmMapper.class);
|
||
}
|
||
|
||
private SalaryEmployeeService getSalaryEmployeeService(User user) {
|
||
return ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
|
||
}
|
||
|
||
private TaxAgentService getTaxAgentService(User user) {
|
||
return ServiceUtil.getService(TaxAgentServiceImpl.class, user);
|
||
}
|
||
|
||
@Override
|
||
public Map<String, Object> genPZ(LyPZGenParam queryParam) {
|
||
// 获取报表结果，并将其每一列都转换为变量
|
||
List<Long> reportDataIds = new ArrayList<>();
|
||
List<List<FormulaVar>> formulaVarsList = getLyReportFormulaVar(queryParam, reportDataIds);
|
||
// 校验这些数据是否已经生成过了凭证
|
||
verifyCanGen(queryParam, reportDataIds);
|
||
// 获取当前凭证对应的所有会计科目信息
|
||
List<UfKjkmPO> ufKjkmList = genKjkmList(queryParam.getPzlx());
|
||
|
||
Map<String, Map<String, Object>> pzDetailValueMap = new LinkedHashMap<>();
|
||
Map<String, Object> totalKjkmValueMap = new HashMap<String, Object>();
|
||
BaseBean baseBean = new BaseBean();
|
||
RecordSet rs = new RecordSet();
|
||
String yFlag = baseBean.getPropValue("lySalaryNCVoucher", "sfddpzfl_y_flag");
|
||
String dkgrsdsBm = baseBean.getPropValue("lySalaryNCVoucher", "kjkm_dkkrsds_bm");
|
||
// 获取所有的部门信息
|
||
List<DeptInfo> deptInfos = getSalaryEmployeeService(user).listAllDeptInfoList();
|
||
// key:分部id-部门名称， value:部门id
|
||
Map<String, DeptInfo> depInfoMap = SalaryEntityUtil.convert2Map(deptInfos, dep -> dep.getSubcompanyid1() + "-" + dep.getName());
|
||
Set<Long> subCompanyIds = new HashSet<>();
|
||
for(List<FormulaVar> varList : formulaVarsList) {
|
||
String subcompanyId = "";
|
||
// 获取他们的职能项目类型，如果是项目则单独统计，如果是职能获取他部门上“是否单独凭证分录”的属性
|
||
boolean singleCount = false;
|
||
Map<String, String> varMap = SalaryEntityUtil.convert2Map(varList, FormulaVar::getFieldId, FormulaVar::getContent);
|
||
subcompanyId = varMap.get("subcompanyId");
|
||
String znxmlxContent = varMap.get("职能项目类型");
|
||
if (StringUtils.isBlank(znxmlxContent)) {
|
||
singleCount = true;
|
||
} else {
|
||
if (znxmlxContent.equals("项目/案场")) {
|
||
singleCount = true;
|
||
} else if (znxmlxContent.equals("职能")) {
|
||
// 获取部门信息
|
||
DeptInfo dept = depInfoMap.get(subcompanyId + "-" + varMap.getOrDefault("职能项目名称", ""));
|
||
// 获取部门属性信息
|
||
if (dept == null) {
|
||
singleCount = true;
|
||
} else {
|
||
rs.execute("SELECT sfddpzfl FROM hrmdepartmentdefined where deptid=" + dept.getId());
|
||
if (rs.next()) {
|
||
if (rs.getInt("sfddpzfl") == new Integer(yFlag)) {
|
||
singleCount = true;
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
singleCount = true;
|
||
}
|
||
}
|
||
|
||
String key = "";
|
||
if (singleCount == false && znxmlxContent.equals("职能")) {
|
||
// 所有职能合并算
|
||
key = "职能";
|
||
} else {
|
||
key = varMap.get("职能项目名称");
|
||
}
|
||
Map<String, Object> kjkmValueMap = pzDetailValueMap.computeIfAbsent(key + "_split" + znxmlxContent + "_split" + subcompanyId, k -> new HashMap<String, Object>());
|
||
// 每一条记录都需要执行一遍公式并把结果相加
|
||
for (UfKjkmPO kjkm : ufKjkmList) {
|
||
// 给公式中的变量填入值
|
||
ExcelResult result = new ExcelResult();
|
||
try {
|
||
result = getFormulaRunService(user).run(kjkm.getKjkmSalaryItemFormula(), varList, null);
|
||
} catch (Exception e) {
|
||
log.error("express execute fail ", e);
|
||
result.setStatus(false);
|
||
result.setErrorMsg(e.getMessage());
|
||
}
|
||
//核算出错，给个默认值
|
||
if (!result.isStatus() || result.getData() == null) {
|
||
log.error("express execute fail status ", result.getErrorMsg());
|
||
result.setData("0");
|
||
}
|
||
String resultStr = result.getData() == null ? "0" : result.getData().toString();
|
||
BigDecimal resultBigDecimal = NumberUtils.isCreatable(resultStr) ? new BigDecimal(resultStr) : BigDecimal.ZERO;
|
||
if (kjkm.getSfhbtj() != null && kjkm.getSfhbtj().equals(NumberUtils.INTEGER_ONE)) {
|
||
// 需要合并计算的会计科目
|
||
totalKjkmValueMap.put(kjkm.getKmbm(), ((BigDecimal)totalKjkmValueMap.getOrDefault(kjkm.getKmbm(), new BigDecimal(0))).add(resultBigDecimal));
|
||
totalKjkmValueMap.put("subCompanyId", subcompanyId);
|
||
subCompanyIds.add(NumberUtils.isCreatable(subcompanyId) ? Long.valueOf(subcompanyId) : 0);
|
||
} else {
|
||
if (kjkm.getKmbm().equals(dkgrsdsBm) && queryParam.getPzlx().equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
kjkmValueMap.put(kjkm.getKmbm() + kjkm.getXzxm(), ((BigDecimal)kjkmValueMap.getOrDefault(kjkm.getKmbm() + kjkm.getXzxm(), new BigDecimal(0))).add(resultBigDecimal));
|
||
kjkmValueMap.put("subCompanyId", subcompanyId);
|
||
subCompanyIds.add(NumberUtils.isCreatable(subcompanyId) ? Long.valueOf(subcompanyId) : 0);
|
||
} else {
|
||
kjkmValueMap.put(kjkm.getKmbm(), ((BigDecimal)kjkmValueMap.getOrDefault(kjkm.getKmbm(), new BigDecimal(0))).add(resultBigDecimal));
|
||
kjkmValueMap.put("subCompanyId", subcompanyId);
|
||
subCompanyIds.add(NumberUtils.isCreatable(subcompanyId) ? Long.valueOf(subcompanyId) : 0);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
if (MapUtils.isNotEmpty(totalKjkmValueMap)) {
|
||
pzDetailValueMap.put("totalKjkm",totalKjkmValueMap);
|
||
}
|
||
// 封装会计科目的摘要信息、会计科目信息、借贷金额薪资,过滤金额为0的会计科目
|
||
List<LyPzPreview> lyPzPreviewList = new ArrayList<>();
|
||
Map<String, String> kmbmInfoMap = new HashMap<>();
|
||
List<UfKjkmPO> allKjkm = getUfKjkmMapper().listAll();
|
||
allKjkm.forEach(po -> kmbmInfoMap.put(po.getKmbm(), po.getKmmc()));
|
||
|
||
// 获取所有分部的辅助核算信息
|
||
List<LyFzhsInfo> fzhsList = getSalaryEmployeeService(user).listAllFzhsInfo();
|
||
Map<Long, LyFzhsInfo> lyFzhsInfoMap = SalaryEntityUtil.convert2Map(fzhsList, LyFzhsInfo::getSubCompanyId);
|
||
List<SubCompanyInfo> subCompanyInfoList = getSalaryEmployeeService(user).getSubCompanyInfoList(subCompanyIds.stream().collect(Collectors.toList()));
|
||
Map<Long, String> subCompanyMap = SalaryEntityUtil.convert2Map(subCompanyInfoList, SubCompanyInfo::getId, SubCompanyInfo::getName);
|
||
// 获取辅助核算列表信息
|
||
List<String> fzhsBmList = new ArrayList<>();
|
||
fzhsList.stream().forEach( info -> {
|
||
fzhsBmList.add(info.getFzhs());
|
||
fzhsBmList.add(info.getFzhsks());
|
||
fzhsBmList.add(info.getFzhssllb());
|
||
fzhsBmList.add(info.getFzhsfwlb());
|
||
});
|
||
// 根据辅助核算编码获取辅助核算浏览框
|
||
Map<String, LyFzhsBrowser> fzhsBrowserMap = getFzhsBrowserByBm(fzhsBmList);
|
||
// 获取对应的薪资所属月和季度（季度为上一季度）
|
||
queryParam.setSalaryMonthDate(SalaryDateUtil.dateStrToLocalYearMonth(queryParam.getSalaryMonth()));
|
||
String chnYearMonth = SalaryDateUtil.getFormatCHNYearMonth(queryParam.getSalaryMonthDate());
|
||
String chnLastSeason = getLastSeason(queryParam.getSalaryMonthDate());
|
||
// 获取摘要根据科目名称生成的摘要科目
|
||
List<String> xzffSpecialZyKjkmbm = Arrays.stream(baseBean.getPropValue("lySalaryNCVoucher", "xzff_special_zy_kjkmbm").split(",")).collect(Collectors.toList());
|
||
List<String> sbffSpecialZyKjkmbm = Arrays.stream(baseBean.getPropValue("lySalaryNCVoucher", "sbff_special_zy_kjkmbm").split(",")).collect(Collectors.toList());
|
||
// 社保公积金计提母子公司往来款
|
||
String sbgjjJtMzkswlkbm = baseBean.getPropValue("lySalaryNCVoucher", "sbgjj_jt_mzkswlkbm");
|
||
for(Map.Entry<String, Map<String, Object>> entry : pzDetailValueMap.entrySet()) {
|
||
Map<String, Object> kjkmValueMap = entry.getValue();
|
||
Long subCompanyId = Long.valueOf(kjkmValueMap.get("subCompanyId").toString());
|
||
LyFzhsInfo lyFzhsInfo = lyFzhsInfoMap.get(subCompanyId);
|
||
for (UfKjkmPO kjkm : ufKjkmList) {
|
||
// 获取该会计科目对应的辅助核算
|
||
BigDecimal value = new BigDecimal(0);
|
||
if (kjkm.getKmbm().equals(dkgrsdsBm) && queryParam.getPzlx().equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
value = (BigDecimal) kjkmValueMap.get(kjkm.getKmbm()+kjkm.getXzxm());
|
||
} else {
|
||
value = (BigDecimal) kjkmValueMap.get(kjkm.getKmbm());
|
||
}
|
||
if (value != null && !value.equals(BigDecimal.ZERO)) {
|
||
LyPzPreview build = LyPzPreview.builder()
|
||
.zy(genZy(chnYearMonth, chnLastSeason, queryParam.getPzlx(), entry.getKey(), kjkm.getSfsjdkm(), subCompanyMap, kjkm, xzffSpecialZyKjkmbm, sbffSpecialZyKjkmbm, sbgjjJtMzkswlkbm))
|
||
.kjkm(getFullPathKjkm(kjkm.getKmbm(), kmbmInfoMap))
|
||
.jfValue(kjkm.getFx().equals(LyJDDirectionTypeEnum.DEBIT.getValue()) ? value.toString() : "0.00")
|
||
.dfValue(kjkm.getFx().equals(LyJDDirectionTypeEnum.CREDIT.getValue()) ? value.toString() : "0.00")
|
||
.fzhsXmqs(lyFzhsInfo != null && kjkm.isFzhsFlag() ? fzhsBrowserMap.get(lyFzhsInfo.getFzhs()) : null)
|
||
.fzhsFwlb(lyFzhsInfo != null && kjkm.isFzhsFwlbFlag() ? fzhsBrowserMap.get(lyFzhsInfo.getFzhsfwlb()) : null)
|
||
.fzhsSllb(lyFzhsInfo != null && kjkm.isFzhsSllbFlag() ? fzhsBrowserMap.get(lyFzhsInfo.getFzhssllb()) : null)
|
||
.fzhsKs(lyFzhsInfo != null && kjkm.isFzhsKsFlag() ? fzhsBrowserMap.get(lyFzhsInfo.getFzhsks()) : null)
|
||
.dataSource(reportDataIds)
|
||
.build();
|
||
lyPzPreviewList.add(build);
|
||
}
|
||
}
|
||
}
|
||
|
||
List<WeaTableColumn> columns = new ArrayList<>();
|
||
columns.add(new WeaTableColumn("100px", "摘要" , "zy"));
|
||
columns.add(new WeaTableColumn("100px", "会计科目" , "kjkm"));
|
||
columns.add(new WeaTableColumn("100px", "辅助核算-项目期数" , "fzhsXmqs"));
|
||
columns.add(new WeaTableColumn("100px", "辅助核算-房屋类别" , "fzhsFwlb"));
|
||
columns.add(new WeaTableColumn("100px", "辅助核算-税率类别" , "fzhsSllb"));
|
||
columns.add(new WeaTableColumn("100px", "辅助核算-客商" , "fzhsKs"));
|
||
columns.add(new WeaTableColumn("100px", "辅助核算" , "fzhsOther"));
|
||
columns.add(new WeaTableColumn("100px", "借方金额" , "jfValue"));
|
||
columns.add(new WeaTableColumn("100px", "贷方金额" , "dfValue"));
|
||
|
||
Map<String, Object> resultMap = new HashMap<>();
|
||
resultMap.put("columns" , columns);
|
||
resultMap.put("data", lyPzPreviewList);
|
||
|
||
// 求合计值
|
||
BigDecimal jfTotal = new BigDecimal("0");
|
||
BigDecimal dfTotal = new BigDecimal("0");
|
||
for (LyPzPreview pzPreview : lyPzPreviewList) {
|
||
if (NumberUtils.isCreatable(pzPreview.getJfValue())) {
|
||
jfTotal = jfTotal.add(new BigDecimal(pzPreview.getJfValue()));
|
||
}
|
||
if (NumberUtils.isCreatable(pzPreview.getDfValue())) {
|
||
dfTotal = dfTotal.add(new BigDecimal(pzPreview.getDfValue()));
|
||
}
|
||
}
|
||
LyPzPreview sumPz = LyPzPreview.builder().zy("合计").jfValue(jfTotal.toPlainString()).dfValue(dfTotal.toPlainString()).build();
|
||
resultMap.put("totalData", sumPz);
|
||
return resultMap;
|
||
|
||
}
|
||
|
||
/**
|
||
* 根据凭证编码获取浏览框
|
||
* @param fzhsBmList
|
||
* @return
|
||
*/
|
||
private Map<String, LyFzhsBrowser> getFzhsBrowserByBm(List<String> fzhsBmList) {
|
||
if (CollectionUtils.isEmpty(fzhsBmList)) {
|
||
return Collections.emptyMap();
|
||
}
|
||
List<LyFzhsBrowser> lyFzhsBrowserList = new ArrayList<>();
|
||
RecordSet rs = new RecordSet();
|
||
BaseBean baseBean = new BaseBean();
|
||
String fzhslxFieldId = baseBean.getPropValue("lySalaryNCVoucher", "fzhslx_field_id");
|
||
List<List<String>> partition = Lists.partition(fzhsBmList, 500);
|
||
partition.forEach(part -> {
|
||
String bmIdStr = StringUtils.join(part, "','");
|
||
rs.execute("SELECT b.SELECTNAME,fzhslx,fzhslxbh,bh,mc FROM uf_ncfuhs a left join workflow_selectitem b on a.fzhslx= b.selectvalue where bh in ('" + bmIdStr + "') and fieldid= " +fzhslxFieldId );
|
||
while (rs.next()) {
|
||
LyFzhsBrowser browser = new LyFzhsBrowser();
|
||
browser.setFzhslx(rs.getString("SELECTNAME"));
|
||
browser.setBh(rs.getString("bh"));
|
||
browser.setMc(rs.getString("mc"));
|
||
browser.setFzhslxbh(rs.getString("fzhslxbh"));
|
||
lyFzhsBrowserList.add(browser);
|
||
}
|
||
});
|
||
return SalaryEntityUtil.convert2Map(lyFzhsBrowserList, LyFzhsBrowser::getBh);
|
||
}
|
||
|
||
/**
|
||
* 校验这些数据是否已经生成过了凭证
|
||
*
|
||
* @param queryParam
|
||
* @param reportDataIds
|
||
*/
|
||
private void verifyCanGen(LyPZGenParam queryParam, List<Long> reportDataIds) {
|
||
Date salaryMonth = SalaryDateUtil.dateStrToLocalYearMonth(queryParam.getSalaryMonth());
|
||
// 根据薪资所属月和凭证类型查询凭证
|
||
List<LyVoucherPO> lyVoucherPOS = getLyVoucherMapper().listSome(LyVoucherPO.builder().salaryMonth(salaryMonth).pzlx(queryParam.getPzlx()).ffgsqc(queryParam.getFfgsqc()).build());
|
||
List<Long> dataIds = lyVoucherPOS.stream()
|
||
.map(po -> po.getDataSource().split(","))
|
||
.flatMap(Arrays::stream)
|
||
.filter(NumberUtils::isCreatable)
|
||
.map(Long::valueOf)
|
||
.distinct()
|
||
.collect(Collectors.toList());
|
||
Optional<Long> existVoucher = reportDataIds.stream().filter(dataIds::contains).findFirst();
|
||
if (existVoucher.isPresent()) {
|
||
throw new SalaryRunTimeException("该数据已生成过凭证，请联系管理员删除后再重新生成凭证");
|
||
}
|
||
}
|
||
|
||
@Override
|
||
public PageInfo<Map<String, Object>> fzhsBrowserList(LyFzhslxParam queryParam) {
|
||
RecordSet rs = new RecordSet();
|
||
BaseBean baseBean = new BaseBean();
|
||
String fzhslxFieldId = baseBean.getPropValue("lySalaryNCVoucher", "fzhslx_field_id");
|
||
if (queryParam.getFzhslx() == null ) {
|
||
rs.execute("select bh,mc,fzhslx,fzhslxbh,b.selectname from uf_NCfuhs a left join workflow_selectitem b on a. fzhslx= b.SELECTVALUE where b.FIELDID=" + fzhslxFieldId );
|
||
} else {
|
||
rs.execute("select bh,mc,fzhslx,fzhslxbh,b.selectname from uf_NCfuhs a left join workflow_selectitem b on a. fzhslx= b.SELECTVALUE where b.FIELDID=" + fzhslxFieldId + " and a.fzhslx = "+ queryParam.getFzhslx());
|
||
}
|
||
List<Map<String, Object>> resultList = new ArrayList<>();
|
||
while (rs.next()) {
|
||
if (StringUtils.isNotBlank(queryParam.getKey())
|
||
&& !rs.getString("mc").contains(queryParam.getKey())
|
||
&& !rs.getString("bh").contains(queryParam.getKey())) {
|
||
|
||
} else {
|
||
Map<String, Object> resultMap = new HashMap<>();
|
||
resultMap.put("bh", rs.getString("bh"));
|
||
resultMap.put("mc", rs.getString("mc"));
|
||
resultMap.put("fzhslx", rs.getString("selectname"));
|
||
resultMap.put("fzhslxbh", rs.getString("fzhslxbh"));
|
||
resultList.add(resultMap);
|
||
}
|
||
}
|
||
return SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(), resultList);
|
||
}
|
||
|
||
/**
|
||
* 获取报表结果，并将其每一列都转换为变量
|
||
*
|
||
* @param queryParam
|
||
* @return
|
||
*/
|
||
private List<List<FormulaVar>> getLyReportFormulaVar(LyPZGenParam queryParam, List<Long> reportDataIds) {
|
||
List<List<FormulaVar>> formulaVarsList = new ArrayList<>();
|
||
if (queryParam.getPzlx().equals(LyPZTypeEnum.XZFFPZ.getValue()) || queryParam.getPzlx().equals(LyPZTypeEnum.XZJTPZ.getValue())) {
|
||
// 是工资单凭证
|
||
Map<String, Object> resultMap = getLySalaryReportService(user).listSalaryReport(LySalaryReportQueryParam.builder().salaryMonth(queryParam.getSalaryMonth()).ffgsqc(Collections.singletonList(queryParam.getFfgsqc())).export(true).build());
|
||
List<LySalaryReportPO> dataList = ((PageInfo<LySalaryReportPO>)resultMap.get("data")).getList();
|
||
// 将每一个结果转换成map的格式并作为变量存储
|
||
for (LySalaryReportPO po : dataList) {
|
||
reportDataIds.add(po.getId());
|
||
Map<String, Object> dataMap = BeanUtil.beanToMap(po);
|
||
List<FormulaVar> formulaVars = new ArrayList<>();
|
||
for (Map.Entry<String,Object> entry : dataMap.entrySet()) {
|
||
FormulaVar build = FormulaVar.builder()
|
||
.fieldId(entry.getKey())
|
||
.content(Util.null2String(entry.getValue()))
|
||
.fieldType(DataType.NUMBER)
|
||
.build();
|
||
if(entry.getKey().equals("ffgsqc") || entry.getKey().equals("fycdgsqc") || entry.getKey().equals("znxmmc")) {
|
||
build.setFieldType(DataType.STRING);
|
||
}
|
||
formulaVars.add(build);
|
||
}
|
||
formulaVarsList.add(formulaVars);
|
||
}
|
||
} else if (queryParam.getPzlx().equals(LyPZTypeEnum.SBJTPZ.getValue()) || queryParam.getPzlx().equals(LyPZTypeEnum.SBFFPZ.getValue())) {
|
||
// 是社保凭证
|
||
Map<String, Object> resultMap = getLySocialReportService(user).listSIReport(LySalaryReportQueryParam.builder().salaryMonth(queryParam.getSalaryMonth()).ffgsqc(Collections.singletonList(queryParam.getFfgsqc())).export(true).build());
|
||
List<LySocialReportPO> dataList = ((PageInfo<LySocialReportPO>)resultMap.get("data")).getList();
|
||
// 将每一个结果转换成map的格式并作为变量存储
|
||
for (LySocialReportPO po : dataList) {
|
||
reportDataIds.add(po.getId());
|
||
Map<String, Object> dataMap = BeanUtil.beanToMap(po);
|
||
List<FormulaVar> formulaVars = new ArrayList<>();
|
||
for (Map.Entry<String,Object> entry : dataMap.entrySet()) {
|
||
FormulaVar build = FormulaVar.builder()
|
||
.fieldId(entry.getKey())
|
||
.content(Util.null2String(entry.getValue()))
|
||
.fieldType(DataType.NUMBER)
|
||
.build();
|
||
if(entry.getKey().equals("ffgsqc") || entry.getKey().equals("fycdgsqc") || entry.getKey().equals("znxmmc")) {
|
||
build.setFieldType(DataType.STRING);
|
||
}
|
||
formulaVars.add(build);
|
||
}
|
||
formulaVarsList.add(formulaVars);
|
||
}
|
||
} else if (queryParam.getPzlx().equals(LyPZTypeEnum.GJJJTPZ.getValue()) || queryParam.getPzlx().equals(LyPZTypeEnum.GJJFFPZ.getValue())) {
|
||
// 是公积金凭证
|
||
Map<String, Object> resultMap = getLyFundReportService(user).listFundReport(LySalaryReportQueryParam.builder().salaryMonth(queryParam.getSalaryMonth()).ffgsqc(Collections.singletonList(queryParam.getFfgsqc())).export(true).build());
|
||
List<LyFundReportPO> dataList = ((PageInfo<LyFundReportPO>)resultMap.get("data")).getList();
|
||
// 将每一个结果转换成map的格式并作为变量存储
|
||
for (LyFundReportPO po : dataList) {
|
||
reportDataIds.add(po.getId());
|
||
Map<String, Object> dataMap = BeanUtil.beanToMap(po);
|
||
List<FormulaVar> formulaVars = new ArrayList<>();
|
||
for (Map.Entry<String,Object> entry : dataMap.entrySet()) {
|
||
FormulaVar build = FormulaVar.builder()
|
||
.fieldId(entry.getKey())
|
||
.content(Util.null2String(entry.getValue()))
|
||
.fieldType(DataType.NUMBER)
|
||
.build();
|
||
if(entry.getKey().equals("ffgsqc") || entry.getKey().equals("fycdgsqc") || entry.getKey().equals("znxmmc")) {
|
||
build.setFieldType(DataType.STRING);
|
||
}
|
||
formulaVars.add(build);
|
||
}
|
||
formulaVarsList.add(formulaVars);
|
||
}
|
||
}
|
||
return formulaVarsList;
|
||
}
|
||
|
||
/**
|
||
* 获取会计科目信息
|
||
*
|
||
* @param pzlx
|
||
* @return
|
||
*/
|
||
private List<UfKjkmPO> genKjkmList(Integer pzlx) {
|
||
List<UfKjkmPO> ufKjkmList = getUfKjkmMapper().listSome(UfKjkmPO.builder().pzlx(pzlx).build());
|
||
// 封装会计科目对应的公式及辅助核算信息
|
||
for(UfKjkmPO kjkm: ufKjkmList) {
|
||
ExpressFormula expressFormula = ExpressFormula.builder().name("t")
|
||
.referenceType(ReferenceTypeEnum.FORMULA.getValue())
|
||
.formula(kjkm.getXzxm())
|
||
.formulaRunScript(kjkm.getXzxm())
|
||
.extendParam("{}")
|
||
.build();
|
||
kjkm.setKjkmSalaryItemFormula(expressFormula);
|
||
String fzhs = kjkm.getFzhs();
|
||
if (StringUtils.isNotBlank(fzhs)) {
|
||
List<Integer> fzhsIdList = Arrays.stream(fzhs.split(",")).filter(NumberUtils::isCreatable).map(Integer::valueOf).collect(Collectors.toList());
|
||
if (fzhsIdList.contains(LyFzhsTypeEnum.XMQS.getValue())) {
|
||
kjkm.setFzhsFlag(true);
|
||
}
|
||
if (fzhsIdList.contains(LyFzhsTypeEnum.FWLB.getValue())) {
|
||
kjkm.setFzhsFwlbFlag(true);
|
||
}
|
||
if (fzhsIdList.contains(LyFzhsTypeEnum.KS.getValue())) {
|
||
kjkm.setFzhsKsFlag(true);
|
||
}
|
||
if (fzhsIdList.contains(LyFzhsTypeEnum.SLLB.getValue())) {
|
||
kjkm.setFzhsSllbFlag(true);
|
||
}
|
||
}
|
||
}
|
||
return ufKjkmList;
|
||
}
|
||
|
||
/**
|
||
* 生成摘要
|
||
*
|
||
* @param chnYearMonth
|
||
* @param chnLastSeason
|
||
* @param pzlx
|
||
* @return
|
||
*/
|
||
private String genZy(String chnYearMonth,
|
||
String chnLastSeason,
|
||
Integer pzlx,
|
||
String keyName,
|
||
Integer sfsjdkm,
|
||
Map<Long, String> subCompanyMap,
|
||
UfKjkmPO kjkm,
|
||
List<String> xzffFpecialZyKjkmbm,
|
||
List<String> sbffSpecialZyKjkmbm,
|
||
String sbgjjJtMzkswlkbm) {
|
||
String[] split = keyName.split("_split");
|
||
// "职能" / "职能项目名称"
|
||
String znxmmc = split.length > 1 ? split[0] : "";
|
||
// 职能项目类型 “职能”/“项目”
|
||
String znxmlx = split.length > 2 ? split[1] : "";
|
||
// 分部id
|
||
String subCompanyId = split.length > 3 ? split[2] : "0";
|
||
|
||
StringBuilder zySb = new StringBuilder();
|
||
if (pzlx.equals(LyPZTypeEnum.XZJTPZ.getValue())) {
|
||
zySb.append("计提");
|
||
// 所在分部名称规则
|
||
// 1、如果是项目则为项目职能名称；
|
||
// 2、如果是职能，合并的职能固定为”职能工资“，单独统计的职能为该部门对应的”分部名称“
|
||
if (znxmlx.equals("职能")) {
|
||
if (znxmmc.equals("职能")) {
|
||
zySb.append("职能");
|
||
} else {
|
||
// 分部名称
|
||
zySb.append(subCompanyMap.getOrDefault(Long.valueOf(subCompanyId), ""));
|
||
}
|
||
} else if (znxmlx.equals("项目/案场")) {
|
||
zySb.append(znxmmc);
|
||
}
|
||
if (sfsjdkm!= null && sfsjdkm.equals(1)) {
|
||
// 是绩效科目
|
||
zySb.append(chnLastSeason).append("绩效");
|
||
} else {
|
||
zySb.append(chnYearMonth).append("工资");
|
||
}
|
||
} else if (pzlx.equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
// 薪资发放凭证
|
||
// 发放+【职能、项目、分部】 +【绩效、工资、特殊会计科目】
|
||
zySb.append("发放");
|
||
if (znxmlx.equals("职能")) {
|
||
if (znxmmc.equals("职能")) {
|
||
zySb.append("职能");
|
||
} else {
|
||
// 分部名称
|
||
zySb.append(subCompanyMap.getOrDefault(Long.valueOf(subCompanyId), ""));
|
||
}
|
||
} else if (znxmlx.equals("项目/案场")) {
|
||
zySb.append(znxmmc);
|
||
}
|
||
|
||
if (sfsjdkm!= null && sfsjdkm.equals(1)) {
|
||
// 是绩效科目
|
||
zySb.append(chnLastSeason).append("绩效");
|
||
} else {
|
||
if (xzffFpecialZyKjkmbm.contains(kjkm.getKmbm())) {
|
||
zySb.append(kjkm.getKmmc());
|
||
} else {
|
||
zySb.append(chnYearMonth).append("工资");
|
||
}
|
||
}
|
||
} else if (pzlx.equals(LyPZTypeEnum.SBJTPZ.getValue()) || pzlx.equals(LyPZTypeEnum.GJJJTPZ.getValue())) {
|
||
// 社保公积金计提凭证
|
||
zySb.append("计提" + chnYearMonth)
|
||
.append(pzlx.equals(LyPZTypeEnum.SBJTPZ.getValue()) ? "社保" : "公积金");
|
||
} else if (pzlx.equals(LyPZTypeEnum.SBFFPZ.getValue()) || pzlx.equals(LyPZTypeEnum.GJJFFPZ.getValue())) {
|
||
// 社保公积金发放凭证
|
||
if (sbffSpecialZyKjkmbm.contains(kjkm.getKmbm())) {
|
||
zySb.append(kjkm.getKmmc());
|
||
} else {
|
||
if (sbgjjJtMzkswlkbm.equals(kjkm.getKmbm())) {
|
||
zySb.append("代缴纳");
|
||
} else {
|
||
zySb.append("银行扣");
|
||
}
|
||
zySb.append("" + chnYearMonth)
|
||
.append(pzlx.equals(LyPZTypeEnum.SBFFPZ.getValue()) ? "社保" : "公积金");
|
||
}
|
||
}
|
||
return zySb.toString();
|
||
}
|
||
|
||
/**
|
||
* 根据科目编码获取对应的全路径名称
|
||
* @param kmbm
|
||
* @param kmbmInfoMap
|
||
* @return
|
||
*/
|
||
private String getFullPathKjkm(String kmbm, Map<String, String> kmbmInfoMap) {
|
||
int length = kmbm.length();
|
||
if (length == 4) {
|
||
// 是一级科目，不需要拼接
|
||
return kmbm + "\\" + kmbmInfoMap.getOrDefault(kmbm, "");
|
||
} else if (length == 6) {
|
||
// 是二级科目，先找一级科目
|
||
String firstKjkmbm = kmbm.substring(0, 4);
|
||
String firstKjkm = kmbmInfoMap.getOrDefault(firstKjkmbm, "");
|
||
return kmbm + "\\" + firstKjkm + "\\" + kmbmInfoMap.getOrDefault(kmbm, "");
|
||
} else if (length == 8) {
|
||
// 是三级科目
|
||
String firstKjkmbm = kmbm.substring(0, 4);
|
||
String firstKjkm = kmbmInfoMap.getOrDefault(firstKjkmbm, "");
|
||
String secondKjkmbm = kmbm.substring(0, 6);
|
||
String secondKjkm = kmbmInfoMap.getOrDefault(secondKjkmbm, "");
|
||
return kmbm + "\\" + firstKjkm + "\\" + secondKjkm + "\\" +kmbmInfoMap.getOrDefault(kmbm, "");
|
||
} else {
|
||
return "科目编码格式错误！";
|
||
}
|
||
}
|
||
|
||
private String getLastSeason(Date currentDate) {
|
||
Calendar cal = Calendar.getInstance();
|
||
cal.setTime(currentDate);
|
||
|
||
// 确定当前日期所在的季度
|
||
int currentMonth = cal.get(Calendar.MONTH) + 1;
|
||
int currentQuarter = (currentMonth - 1) / 3 + 1;
|
||
|
||
// 计算上一个季度的季度号
|
||
int previousQuarter = currentQuarter - 1;
|
||
int previousYear = cal.get(Calendar.YEAR);
|
||
|
||
// 如果上一个季度跨越了年度
|
||
if (previousQuarter <= 0) {
|
||
previousQuarter += 4; // 上一个季度为上一年的第四个季度
|
||
previousYear -= 1;
|
||
}
|
||
|
||
// 格式化输出
|
||
String result = previousYear + "年" + previousQuarter + "季度";
|
||
return result;
|
||
}
|
||
|
||
/**
|
||
* 推送凭证
|
||
* @param pushParam
|
||
*/
|
||
@Override
|
||
public Map<String, Object> pushUCAndSave(LyVoucherPushParam pushParam) {
|
||
// 校验会计科目是否合法
|
||
verifyKjkm(pushParam);
|
||
// 推送凭证
|
||
pushVoucher(pushParam);
|
||
// 推送成功后修改报表数据的凭证生成状态
|
||
updateReportStatus(pushParam);
|
||
// 推送成功后保存凭证
|
||
return saveVoucher(pushParam);
|
||
}
|
||
|
||
/**
|
||
* 推送成功后修改报表数据的凭证生成状态
|
||
*
|
||
* @param pushParam
|
||
*/
|
||
private void updateReportStatus(LyVoucherPushParam pushParam) {
|
||
List<Long> dataSource = pushParam.getDataSource();
|
||
if (pushParam.getPzlx().equals(LyPZTypeEnum.XZJTPZ.getValue()) || pushParam.getPzlx().equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
List<LySalaryReportPO> salaryReportList = getLySalaryReportService(user).getByIds(dataSource);
|
||
salaryReportList.stream().forEach(po -> {
|
||
if (pushParam.getPzlx().equals(LyPZTypeEnum.XZJTPZ.getValue())) {
|
||
po.setXzjtpzFlag(NumberUtils.INTEGER_ONE);
|
||
} else if (pushParam.getPzlx().equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
po.setXzffpzFlag(NumberUtils.INTEGER_ONE);
|
||
}
|
||
getLySalaryReportService(user).update(po);
|
||
});
|
||
} else if (pushParam.getPzlx().equals(LyPZTypeEnum.SBJTPZ.getValue()) || pushParam.getPzlx().equals(LyPZTypeEnum.SBFFPZ.getValue())) {
|
||
List<LySocialReportPO> socialReportList = getLySocialReportService(user).getByIds(dataSource);
|
||
socialReportList.stream().forEach(po -> {
|
||
if (pushParam.getPzlx().equals(LyPZTypeEnum.SBJTPZ.getValue())) {
|
||
po.setSbjtpzFlag(NumberUtils.INTEGER_ONE);
|
||
} else if (pushParam.getPzlx().equals(LyPZTypeEnum.SBFFPZ.getValue())) {
|
||
po.setSbffpzFlag(NumberUtils.INTEGER_ONE);
|
||
}
|
||
getLySocialReportService(user).update(po);
|
||
});
|
||
} else if (pushParam.getPzlx().equals(LyPZTypeEnum.GJJJTPZ.getValue()) || pushParam.getPzlx().equals(LyPZTypeEnum.GJJFFPZ.getValue())) {
|
||
List<LyFundReportPO> fundReportList = getLyFundReportService(user).getByIds(dataSource);
|
||
fundReportList.stream().forEach(po -> {
|
||
if (pushParam.getPzlx().equals(LyPZTypeEnum.GJJJTPZ.getValue())) {
|
||
po.setGjjjtpzFlag(NumberUtils.INTEGER_ONE);
|
||
} else if (pushParam.getPzlx().equals(LyPZTypeEnum.GJJFFPZ.getValue())) {
|
||
po.setGjjffpzFlag(NumberUtils.INTEGER_ONE);
|
||
}
|
||
getLyFundReportService(user).update(po);
|
||
});
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 保存凭证
|
||
* @param pushParam
|
||
*/
|
||
private Map<String, Object> saveVoucher(LyVoucherPushParam pushParam) {
|
||
Map<String, Object> resultMap = new HashMap<String, Object>();
|
||
Date now = new Date();
|
||
long mainId = IdGenerator.generate();
|
||
LyVoucherPO voucher = LyVoucherPO
|
||
.builder()
|
||
.id(mainId)
|
||
.pzlx(pushParam.getPzlx())
|
||
.dataSource(StringUtils.join(pushParam.getDataSource(), ","))
|
||
.ffgsqc(pushParam.getFfgsqc())
|
||
.salaryMonth(SalaryDateUtil.dateStrToLocalYearMonth(pushParam.getSalaryMonth()))
|
||
.pkVoucher(pushParam.getPkVoucher())
|
||
.status(pushParam.getStatus())
|
||
.pushMsg(pushParam.getPushMsg())
|
||
.creator(Long.valueOf(user.getUID()))
|
||
.createTime(now)
|
||
.updateTime(now)
|
||
.deleteType(0)
|
||
.build();
|
||
getLyVoucherMapper().insertIgnoreNull(voucher);
|
||
pushParam.getDetails().stream().forEach(detail -> {
|
||
LyVoucherDetailPO voucherDetail = LyVoucherDetailPO
|
||
.builder()
|
||
.id(IdGenerator.generate())
|
||
.voucherId(mainId)
|
||
.zy(detail.getZy())
|
||
.kjkmId(detail.getKjkm())
|
||
.fzhsXmqsBm(detail.getFzhsXmqs().getBh())
|
||
.fzhsFwlbBm(detail.getFzhsFwlb().getBh())
|
||
.fzhsSllbBm(detail.getFzhsSllb().getBh())
|
||
.fzhsKsBm(detail.getFzhsKs().getBh())
|
||
.fzhsOtherBms(CollectionUtils.isEmpty(detail.getFzhsOtherBmList()) ? "" : detail.getFzhsOtherBmList().stream().map(LyFzhsBrowser::getBh).collect(Collectors.joining(",")) )
|
||
.jfValue(detail.getJfValue())
|
||
.dfValue(detail.getDfValue())
|
||
.creator(Long.valueOf(user.getUID()))
|
||
.createTime(now)
|
||
.updateTime(now)
|
||
.deleteType(0).build();
|
||
getLyVoucherDetailMapper().insertIgnoreNull(voucherDetail);
|
||
});
|
||
resultMap.put("status", (pushParam.getStatus() != null && pushParam.getStatus().equals(NumberUtils.INTEGER_ONE)) ? Boolean.TRUE : Boolean.FALSE);
|
||
resultMap.put("errMsg", pushParam.getPushMsg());
|
||
return resultMap;
|
||
}
|
||
|
||
/**
|
||
* 推送凭证
|
||
* @param pushParam
|
||
*/
|
||
private void pushVoucher(LyVoucherPushParam pushParam) {
|
||
Date salaryDate = SalaryDateUtil.dateStrToLocalYearMonth(pushParam.getSalaryMonth());
|
||
if (salaryDate == null) {
|
||
throw new SalaryRunTimeException("薪资所属月为空");
|
||
}
|
||
Calendar cal = Calendar.getInstance();
|
||
cal.setTime(salaryDate);
|
||
BaseBean baseBean = new BaseBean();
|
||
LyNCVoucher lyNCVoucher = new LyNCVoucher();
|
||
// 凭证类别 非空 （凭证类别)
|
||
String pkVoucherType = baseBean.getPropValue("lySalaryNCVoucherPushParam", "pk_voucher_type");
|
||
lyNCVoucher.setPkVouchertype(pkVoucherType);
|
||
// 会计年度 非空
|
||
lyNCVoucher.setYear(String.valueOf(cal.get(Calendar.YEAR)));
|
||
// 来源系统 非空 只支持模块编号
|
||
String pkSystem = baseBean.getPropValue("lySalaryNCVoucherPushParam", "pk_system");
|
||
lyNCVoucher.setPkSystem(pkSystem);
|
||
// 凭证类型值 0：正常凭证 3：数量调整凭证 不可空
|
||
String voucherKind = baseBean.getPropValue("lySalaryNCVoucherPushParam", "voucher_kind");
|
||
lyNCVoucher.setVoucherkind(voucherKind);
|
||
// 核算账簿 非空 （账簿_财务核算账簿）
|
||
lyNCVoucher.setPkAccountingbook(pushParam.getZbbm());
|
||
// lyNCVoucher.setPkAccountingbook("12re23r32");
|
||
// 会计期间 非空
|
||
lyNCVoucher.setPeriod(String.valueOf(cal.get(Calendar.MONTH)+1));
|
||
// 制单日期 非空
|
||
lyNCVoucher.setPrepareddate(SalaryDateUtil.getFormatLocalDateTime(new Date()));
|
||
// 制单人 非空 （用户）
|
||
String pkPrepared = baseBean.getPropValue("lySalaryNCVoucherPushParam", "pk_prepared");
|
||
lyNCVoucher.setPkPrepared(pkPrepared);
|
||
//所属组织 非空 （组织）
|
||
lyNCVoucher.setPkOrg(pushParam.getZbbm().split("-")[0]);
|
||
// lyNCVoucher.setPkOrg("201");
|
||
lyNCVoucher.setDiscardflag("N");
|
||
|
||
|
||
List<LyVoucherDetailPushParam> jfDetailList = new ArrayList<>();
|
||
List<LyVoucherDetailPushParam> dfDetailList = new ArrayList<>();
|
||
pushParam.getDetails().stream().forEach(detail -> {
|
||
if ((StringUtils.isNotBlank(detail.getJfValue())) && (!"0.00".equals(detail.getJfValue()))) {
|
||
jfDetailList.add(detail);
|
||
} else {
|
||
dfDetailList.add(detail);
|
||
}
|
||
});
|
||
ArrayList<LyNCVoucherDetail> lyNCVoucherDetailList = new ArrayList<>();
|
||
RecordSet rs = new RecordSet();
|
||
// 借方分录
|
||
for (int i = 0; i < jfDetailList.size(); i++) {
|
||
LyVoucherDetailPushParam detailParam = jfDetailList.get(i);
|
||
LyNCVoucherDetail lyNCVoucherDetail = new LyNCVoucherDetail();
|
||
// 分录号 非空
|
||
lyNCVoucherDetail.setDetailindex(String.valueOf(i+1));
|
||
// 摘要 非空
|
||
lyNCVoucherDetail.setExplanation(detailParam.getZy());
|
||
// 折本汇率
|
||
lyNCVoucherDetail.setExcrate2("1");
|
||
// 原币借方金额
|
||
lyNCVoucherDetail.setDebitamount(detailParam.getJfValue());
|
||
// 本币借方金额 可空
|
||
lyNCVoucherDetail.setLocaldebitamount(detailParam.getJfValue());
|
||
// 币种 非空
|
||
lyNCVoucherDetail.setPkCurrtype("CNY");
|
||
// 科目 非空
|
||
String kjkm = detailParam.getKjkm();
|
||
String kjkmbm = kjkm.split("\\\\")[0];
|
||
lyNCVoucherDetail.setPkAccasoa(kjkmbm);
|
||
// 辅助核算
|
||
List<LyNCVoucherAss> lyNCVoucherAssList = new ArrayList<>();
|
||
if (detailParam.getFzhsXmqs() != null) {
|
||
// 项目期数
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsXmqs().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsXmqs().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsFwlb() != null) {
|
||
// 房屋列别
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsFwlb().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsFwlb().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsSllb() != null) {
|
||
// 税率类别
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsSllb().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsSllb().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsKs() != null) {
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
// 客商
|
||
ass.setPkChecktype(detailParam.getFzhsKs().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsKs().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
// 其他
|
||
if (CollectionUtils.isNotEmpty(detailParam.getFzhsOtherBmList())) {
|
||
detailParam.getFzhsOtherBmList().stream().forEach(fzhs -> {
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(fzhs.getFzhslxbh());
|
||
ass.setPkCheckvalue(fzhs.getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
});
|
||
}
|
||
List<LyNCVoucherAss> assList = lyNCVoucherAssList.stream().filter(ass -> StringUtils.isNotBlank(ass.getPkChecktype())).collect(Collectors.toList());
|
||
lyNCVoucherDetail.setAss(assList);
|
||
lyNCVoucherDetailList.add(lyNCVoucherDetail);
|
||
}
|
||
|
||
// 贷方分录
|
||
for (int i = 0; i < dfDetailList.size(); i++) {
|
||
LyVoucherDetailPushParam detailParam = dfDetailList.get(i);
|
||
LyNCVoucherDetail lyNCVoucherDetail = new LyNCVoucherDetail();
|
||
// 分录号 非空
|
||
lyNCVoucherDetail.setDetailindex(lyNCVoucherDetailList.size() + String.valueOf(i+1));
|
||
// 摘要 非空
|
||
lyNCVoucherDetail.setExplanation(detailParam.getZy());
|
||
// 折本汇率
|
||
lyNCVoucherDetail.setExcrate2("1");
|
||
// 原币借方金额
|
||
lyNCVoucherDetail.setCreditamount(detailParam.getDfValue());
|
||
// 本币借方金额 可空
|
||
lyNCVoucherDetail.setLocalcreditamount(detailParam.getDfValue());
|
||
// 币种 非空
|
||
lyNCVoucherDetail.setPkCurrtype("CNY");
|
||
// 科目 非空
|
||
String kjkm = detailParam.getKjkm();
|
||
String kjkmbm = kjkm.split("\\\\")[0];
|
||
lyNCVoucherDetail.setPkAccasoa(kjkmbm);
|
||
// 辅助核算
|
||
List<LyNCVoucherAss> lyNCVoucherAssList = new ArrayList<>();
|
||
if (detailParam.getFzhsXmqs() != null) {
|
||
// 项目期数
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsXmqs().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsXmqs().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsFwlb() != null) {
|
||
// 房屋列别
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsFwlb().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsFwlb().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsSllb() != null) {
|
||
// 税率类别
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(detailParam.getFzhsSllb().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsSllb().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
if (detailParam.getFzhsKs() != null) {
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
// 客商
|
||
ass.setPkChecktype(detailParam.getFzhsKs().getFzhslxbh());
|
||
ass.setPkCheckvalue(detailParam.getFzhsKs().getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
}
|
||
// 其他
|
||
if (CollectionUtils.isNotEmpty(detailParam.getFzhsOtherBmList())) {
|
||
detailParam.getFzhsOtherBmList().stream().forEach(fzhs -> {
|
||
LyNCVoucherAss ass = new LyNCVoucherAss();
|
||
ass.setPkChecktype(fzhs.getFzhslxbh());
|
||
ass.setPkCheckvalue(fzhs.getBh());
|
||
lyNCVoucherAssList.add(ass);
|
||
});
|
||
}
|
||
List<LyNCVoucherAss> assList = lyNCVoucherAssList.stream().filter(ass -> StringUtils.isNotBlank(ass.getPkChecktype())).collect(Collectors.toList());
|
||
lyNCVoucherDetail.setAss(assList);
|
||
lyNCVoucherDetailList.add(lyNCVoucherDetail);
|
||
}
|
||
lyNCVoucher.setDetails(lyNCVoucherDetailList);
|
||
LyNCVoucherHead voucherHead = new LyNCVoucherHead();
|
||
voucherHead.setVoucherHead(lyNCVoucher);
|
||
|
||
LyNCVoucherUfinterface lyNCVoucherUfinterface = new LyNCVoucherUfinterface();
|
||
lyNCVoucherUfinterface.setVoucher(voucherHead);
|
||
|
||
String account = baseBean.getPropValue("lySalaryNCVoucherPushParam", "account");
|
||
lyNCVoucherUfinterface.setAccount(account);
|
||
String billtype = baseBean.getPropValue("lySalaryNCVoucherPushParam", "billtype");
|
||
lyNCVoucherUfinterface.setBilltype(billtype);
|
||
String businessunitcode = baseBean.getPropValue("lySalaryNCVoucherPushParam", "businessunitcode");
|
||
lyNCVoucherUfinterface.setBusinessunitcode(businessunitcode);
|
||
lyNCVoucherUfinterface.setFilename("");
|
||
lyNCVoucherUfinterface.setGroupcode("");
|
||
lyNCVoucherUfinterface.setIsexchange("");
|
||
lyNCVoucherUfinterface.setOrgcode("");
|
||
lyNCVoucherUfinterface.setReceiver("");
|
||
lyNCVoucherUfinterface.setReplace("");
|
||
lyNCVoucherUfinterface.setRoottag("");
|
||
String sender = baseBean.getPropValue("lySalaryNCVoucherPushParam", "sender");
|
||
lyNCVoucherUfinterface.setSender(sender);
|
||
// "<?xml version=\"1.0\" encoding='gb2312'?>"
|
||
String xml = XStreamUtil.marshal(lyNCVoucherUfinterface);
|
||
System.out.println(xml);
|
||
|
||
|
||
HttpClient httpClient = new HttpClient();
|
||
String accountParam = baseBean.getPropValue("lySalaryNCVoucherPushParam", "account_param");
|
||
String groupcodeParam = baseBean.getPropValue("lySalaryNCVoucherPushParam", "groupcode_param");
|
||
PostMethod httpPost = new PostMethod("http://172.18.0.10:8090/service/XChangeServlet?account="+accountParam+"&groupcode="+groupcodeParam);
|
||
httpPost.setRequestHeader("content-type", "application/json;charset=utf-8");
|
||
|
||
String result = "";
|
||
try {
|
||
RequestEntity entity = new StringRequestEntity( xml, "application/json", "UTF-8");
|
||
httpPost.setRequestEntity(entity);
|
||
httpClient.executeMethod(httpPost);
|
||
result = httpPost.getResponseBodyAsString();
|
||
System.out.println(result);
|
||
LyNCVoucherReturn lyNCVoucherReturn = XStreamUtil.unmarshal(LyNCVoucherReturn.class, StringUtils.substring(result,result.indexOf("<ufinterface"),result.indexOf("</ufinterface>")+14));
|
||
boolean success = lyNCVoucherReturn.getSuccessful().equals("Y");
|
||
if (!success) {
|
||
// 失败
|
||
String errorMsg = lyNCVoucherReturn.getSendresult().getResultdescription();
|
||
pushParam.setStatus(NumberUtils.INTEGER_ZERO);
|
||
pushParam.setPushMsg(errorMsg);
|
||
} else {
|
||
pushParam.setStatus(NumberUtils.INTEGER_ONE);
|
||
pushParam.setPushMsg("推送成功");
|
||
}
|
||
} catch (Exception e) {
|
||
baseBean.writeLog("推送错误" + e.getMessage());
|
||
throw new SalaryRunTimeException("推送错误，请联系管理员");
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 校验会计科目是否合法
|
||
* @param pushParam
|
||
*/
|
||
private void verifyKjkm(LyVoucherPushParam pushParam) {
|
||
if(StringUtils.isBlank(pushParam.getZbbm())) {
|
||
throw new SalaryRunTimeException("账簿编码不能为空");
|
||
}
|
||
// 校验科目id是否合规
|
||
Map<String, String> kmbmInfoMap = new HashMap<>();
|
||
List<UfKjkmPO> allKjkm = getUfKjkmMapper().listAll();
|
||
allKjkm.forEach(po -> kmbmInfoMap.put(po.getKmbm(), po.getKmmc()));
|
||
List<LyVoucherDetailPushParam> details = pushParam.getDetails();
|
||
List<String> kjlmList = new ArrayList<>();
|
||
details.stream().forEach(detail -> {
|
||
String kjkm = detail.getKjkm();
|
||
if (StringUtils.isNotBlank(kjkm)) {
|
||
kjlmList.add(kjkm);
|
||
} else {
|
||
throw new SalaryRunTimeException("会计科目不能为空");
|
||
}
|
||
});
|
||
List<String> failList = kjlmList.stream()
|
||
.filter(StringUtils::isNotBlank)
|
||
.distinct()
|
||
.filter(fullPath -> {
|
||
String[] split = fullPath.split("\\\\");
|
||
String kjkm = split[0];
|
||
String fullPathKjkm = getFullPathKjkm(kjkm, kmbmInfoMap);
|
||
return !fullPath.equals(fullPathKjkm);
|
||
}).collect(Collectors.toList());
|
||
if (CollectionUtils.isNotEmpty(failList)) {
|
||
throw new SalaryRunTimeException("推送凭证失败，以下科目信息不存在：" + failList);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 本地历史凭证列表
|
||
*
|
||
* @param queryParam
|
||
* @return
|
||
*/
|
||
@Override
|
||
public PageInfo<LyVoucherPO> historyVoucherList(LyVoucherQueryParam queryParam) {
|
||
List<LyVoucherPO> lyVoucherPOS = getLyVoucherMapper().listSome(LyVoucherPO.builder()
|
||
.pzlx(queryParam.getPzlx())
|
||
.salaryMonth(SalaryDateUtil.dateStrToLocalYearMonth(queryParam.getSalaryMonth()))
|
||
.id(queryParam.getId())
|
||
.build());
|
||
// 筛选法人主体
|
||
if (StringUtils.isNotBlank(queryParam.getFrzt())) {
|
||
lyVoucherPOS = lyVoucherPOS.stream().filter(po -> po.getFfgsqc().contains(queryParam.getFrzt())).collect(Collectors.toList());
|
||
}
|
||
// 分权
|
||
// 是否是薪酬总管理员
|
||
boolean isChief = getTaxAgentService(user).isChief((long) user.getUID());
|
||
if (!isChief) {
|
||
List<String> canManageFrztByUid = getLySalaryReportService(user).getCanManageFrztByUid(user);
|
||
lyVoucherPOS = lyVoucherPOS.stream().filter(po -> canManageFrztByUid.contains(po.getFfgsqc())).collect(Collectors.toList());
|
||
}
|
||
PageInfo<LyVoucherPO> pageInfo = SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(), lyVoucherPOS, LyVoucherPO.class);
|
||
List<LyVoucherPO> list = pageInfo.getList();
|
||
list.stream().forEach(voucher -> {
|
||
voucher.setPzlxStr(LyPZTypeEnum.getDefaultLabelByValue(voucher.getPzlx()));
|
||
voucher.setPushStatusStr(voucher.getStatus() != null && voucher.getStatus().equals(NumberUtils.INTEGER_ONE) ? "成功" : "失败");
|
||
voucher.setErrorMsg(voucher.getStatus() != null && voucher.getStatus().equals(NumberUtils.INTEGER_ONE) ? "" : voucher.getPushMsg().replace("\n","</br>"));
|
||
});
|
||
return SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(), lyVoucherPOS, LyVoucherPO.class);
|
||
}
|
||
|
||
@Override
|
||
public Map<String, Object> historyVoucherDetailList(Long voucherId) {
|
||
if (voucherId == null) {
|
||
return Collections.emptyMap();
|
||
}
|
||
List<LyVoucherDetailPO> lyVoucherDetailList = getLyVoucherDetailMapper().listSome(LyVoucherDetailPO.builder()
|
||
.voucherId(voucherId)
|
||
.build());
|
||
|
||
// 获取辅助核算浏览框list
|
||
List<String> fzhsBmList = new ArrayList<>();
|
||
lyVoucherDetailList.stream().forEach(detailPO -> {
|
||
fzhsBmList.add(detailPO.getFzhsXmqsBm());
|
||
fzhsBmList.add(detailPO.getFzhsFwlbBm());
|
||
fzhsBmList.add(detailPO.getFzhsSllbBm());
|
||
fzhsBmList.add(detailPO.getFzhsKsBm());
|
||
if (StringUtils.isNotBlank(detailPO.getFzhsOtherBms())) {
|
||
List<String> bmList = Arrays.stream(detailPO.getFzhsOtherBms().split(",")).collect(Collectors.toList());
|
||
fzhsBmList.addAll(bmList);
|
||
}
|
||
});
|
||
List<String> finalFzhsBmList = fzhsBmList.stream().filter(StringUtils::isNotBlank).collect(Collectors.toList());
|
||
Map<String, LyFzhsBrowser> fzhsBrowserByBm = getFzhsBrowserByBm(finalFzhsBmList);
|
||
|
||
List<LyVoucherDetailDTO> dtoList = lyVoucherDetailList.stream().map(detailPO -> {
|
||
String fzhsOtherBmStr = detailPO.getFzhsOtherBms();
|
||
List<LyFzhsBrowser> fzhsOtherBrowserList = new ArrayList<>();
|
||
if (StringUtils.isNotBlank(fzhsOtherBmStr)) {
|
||
fzhsOtherBrowserList = Arrays.stream(fzhsOtherBmStr.split(","))
|
||
.map(bm -> fzhsBrowserByBm.get(bm))
|
||
.filter(browser -> browser != null)
|
||
.collect(Collectors.toList());
|
||
}
|
||
return LyVoucherDetailDTO.builder()
|
||
.voucherId(detailPO.getVoucherId())
|
||
.zy(detailPO.getZy())
|
||
.kjkmId(detailPO.getKjkmId())
|
||
.fzhsXmqsBrowser(fzhsBrowserByBm.get(detailPO.getFzhsXmqsBm()))
|
||
.fzhsFwlbBrowser(fzhsBrowserByBm.get(detailPO.getFzhsFwlbBm()))
|
||
.fzhsSllbBrowser(fzhsBrowserByBm.get(detailPO.getFzhsSllbBm()))
|
||
.fzhsKsBrowser(fzhsBrowserByBm.get(detailPO.getFzhsKsBm()))
|
||
.fzhsOtherBrowserList(fzhsOtherBrowserList)
|
||
.jfValue(detailPO.getJfValue())
|
||
.dfValue(detailPO.getDfValue())
|
||
.build();
|
||
}).collect(Collectors.toList());
|
||
|
||
PageInfo<LyVoucherDetailDTO> pageInfo = new PageInfo<>(LyVoucherDetailDTO.class);
|
||
Map<String, Object> resultMap = new HashMap<>();
|
||
resultMap.put("data", dtoList);
|
||
resultMap.put("columns", pageInfo.getColumns());
|
||
return resultMap;
|
||
}
|
||
|
||
@Override
|
||
public void deleteHistoryVoucher(Long voucherId) {
|
||
// 判断是否是薪酬总管理员
|
||
boolean isChief = getTaxAgentService(user).isChief((long) user.getUID());
|
||
if (isChief) {
|
||
LyVoucherPO voucherPO = getLyVoucherMapper().getById(voucherId);
|
||
getLyVoucherMapper().delete(LyVoucherPO.builder().id(voucherId).build());
|
||
getLyVoucherDetailMapper().delete(LyVoucherDetailPO.builder().voucherId(voucherId).build());
|
||
// 修改报表中数据推送状态
|
||
Integer pzlx = voucherPO.getPzlx();
|
||
String dataSourceStr = voucherPO.getDataSource();
|
||
List<Long> dataSourceIdList = new ArrayList<>();
|
||
if (StringUtils.isNotBlank(dataSourceStr)) {
|
||
dataSourceIdList = Arrays.stream(dataSourceStr.split(",")).filter(NumberUtils::isCreatable).map(Long::valueOf).collect(Collectors.toList());
|
||
}
|
||
|
||
if (pzlx.equals(LyPZTypeEnum.XZJTPZ.getValue()) || pzlx.equals(LyPZTypeEnum.XZFFPZ.getValue())) {
|
||
// 薪资
|
||
List<LySalaryReportPO> lySalaryReportList = getLySalaryReportService(user).listByIds(dataSourceIdList);
|
||
lySalaryReportList.stream().forEach(po -> {
|
||
if (pzlx.equals(LyPZTypeEnum.XZJTPZ.getValue())) {
|
||
po.setXzjtpzFlag(NumberUtils.INTEGER_ZERO);
|
||
} else {
|
||
po.setXzffpzFlag(NumberUtils.INTEGER_ZERO);
|
||
}
|
||
getLySalaryReportService(user).updateIgnoreNull(po);
|
||
});
|
||
} else if (pzlx.equals(LyPZTypeEnum.SBJTPZ.getValue()) || pzlx.equals(LyPZTypeEnum.SBFFPZ.getValue())) {
|
||
// 社保
|
||
List<LySocialReportPO> lySocialReportList = getLySocialReportService(user).getByIds(dataSourceIdList);
|
||
lySocialReportList.stream().forEach(po -> {
|
||
if (pzlx.equals(LyPZTypeEnum.SBJTPZ.getValue())) {
|
||
po.setSbjtpzFlag(NumberUtils.INTEGER_ZERO);
|
||
} else {
|
||
po.setSbffpzFlag(NumberUtils.INTEGER_ZERO);
|
||
}
|
||
getLySocialReportService(user).updateIgnoreNull(po);
|
||
});
|
||
} else if (pzlx.equals(LyPZTypeEnum.GJJJTPZ.getValue()) || pzlx.equals(LyPZTypeEnum.GJJFFPZ.getValue())) {
|
||
// 公积金
|
||
List<LyFundReportPO> lyFundReportList = getLyFundReportService(user).getByIds(dataSourceIdList);
|
||
lyFundReportList.stream().forEach(po -> {
|
||
if (pzlx.equals(LyPZTypeEnum.GJJJTPZ.getValue())) {
|
||
po.setGjjjtpzFlag(NumberUtils.INTEGER_ZERO);
|
||
} else {
|
||
po.setGjjffpzFlag(NumberUtils.INTEGER_ZERO);
|
||
}
|
||
getLyFundReportService(user).updateIgnoreNull(po);
|
||
});
|
||
}
|
||
}
|
||
}
|
||
}
|