pdf导出前先校验生成pdf
This commit is contained in:
Harryxzy
parent
8d18c0e5cb
commit
509257b419
|
|
@ -33,6 +33,7 @@ import weaver.common.MessageUtil;
|
|||
import weaver.conn.RecordSet;
|
||||
import weaver.email.EmailWorkRunnable;
|
||||
import weaver.file.ImageFileManager;
|
||||
import weaver.general.Util;
|
||||
import weaver.hrm.company.SubCompanyComInfo;
|
||||
import weaver.hrm.resource.ResourceComInfo;
|
||||
|
||||
|
|
@ -199,6 +200,7 @@ public class SalaryBillBO {
|
|||
log.error("资源异常", e);
|
||||
}
|
||||
companyName = subCompanyComInfo.getSubCompanyname(resourceComInfo.getSubCompanyID(employeeId + ""));
|
||||
companyName = Util.formatMultiLang(companyName);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -23,6 +23,10 @@ public interface SalaryBillService {
|
|||
*/
|
||||
Map<String, Object> grant(SalarySendGrantParam queryParam);
|
||||
|
||||
Map<String, Object> reGenPdf(SalarySendGrantParam queryParam);
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 获取内容
|
||||
* @param sendId
|
||||
|
|
@ -46,6 +50,8 @@ public interface SalaryBillService {
|
|||
|
||||
String exportPdf(SalaryExportPdfParam param);
|
||||
|
||||
String genPdfBeforeExport(SalaryExportPdfParam salaryExportPdfParam);
|
||||
|
||||
/**
|
||||
* 工资单撤回
|
||||
*
|
||||
|
|
|
|||
|
|
@ -1,5 +1,6 @@
|
|||
package com.engine.salary.service.impl;
|
||||
|
||||
import cn.hutool.core.io.FileUtil;
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.api.formmode.mybatis.util.SqlProxyHandle;
|
||||
|
|
@ -37,6 +38,7 @@ import com.engine.salary.util.JsonUtil;
|
|||
import com.engine.salary.util.SalaryDateUtil;
|
||||
import com.engine.salary.util.SalaryEntityUtil;
|
||||
import com.engine.salary.util.SalaryI18nUtil;
|
||||
import com.engine.salary.util.pdf.HtmlToPdf;
|
||||
import com.google.common.collect.Lists;
|
||||
import com.weaver.util.threadPool.ThreadPoolUtil;
|
||||
import com.weaver.util.threadPool.constant.ModulePoolEnum;
|
||||
|
|
@ -200,6 +202,44 @@ public class SalaryBillServiceImpl extends Service implements SalaryBillService
|
|||
return new HashMap<>();
|
||||
}
|
||||
|
||||
/**
|
||||
* 对于已经发送的工资单，重新生成pdf
|
||||
* @param param
|
||||
* @return
|
||||
*/
|
||||
@Override
|
||||
public Map<String, Object> reGenPdf(SalarySendGrantParam param) {
|
||||
// 1.检查和获取工资单发放
|
||||
SalarySendPO salarySend = checkAndGetSalarySend(param.getSalarySendId());
|
||||
// 获取默认模板
|
||||
SalarySobPO salarySob = getSalarySobService(user).getById(salarySend.getSalarySobId());
|
||||
List<SalaryTemplatePO> salaryTemplates = salarySob == null ? Lists.newArrayList() : getSalaryTemplateService(user).getDefaultTemplates(Arrays.asList(salarySend.getSalarySobId(), salarySob.getId()));
|
||||
SalaryTemplatePO salaryTemplate = salaryTemplates.get(0);
|
||||
List<Long> ids = param.getIds();
|
||||
if (param.getSalarySendRangeIds() != null) {
|
||||
//如果传了范围id，则使用范围id发放
|
||||
ids = getSalarySendRangeService(user)
|
||||
.getSendInfoIdsBySendId(salarySend.getId(), param.getSalarySendRangeIds(), SalarySendGrantTypeEnum.GRANT);
|
||||
if (ids.isEmpty()) {// 由于查出来是空的，会导致全部发放，在此进行拦截
|
||||
throw new SalaryRunTimeException("工资发放范围内没有匹配员工");
|
||||
}
|
||||
}
|
||||
try {
|
||||
TaxAgentPO taxAgentPO = getTaxAgentService(user).getById(salarySob.getTaxAgentId());
|
||||
// 1.构建发送参数
|
||||
SalaryBillSendDTO salaryBillSendParam = buildSendParams(salarySend, taxAgentPO.getName(), salaryTemplate);
|
||||
// 2.获取可发送的列表，此步最耗时，需要解密核算数据
|
||||
List<Integer> sendStatusList = Arrays.asList(SalarySendStatusEnum.UNSEND.getValue(), SalarySendStatusEnum.WITHDRAW.getValue(), SalarySendStatusEnum.ALREADYSEND.getValue());
|
||||
List<Map<String, Object>> enableSendList = getEnableSendList(salarySend, ids, salaryBillSendParam, sendStatusList);
|
||||
//生成pdf
|
||||
genPdf(salaryBillSendParam, enableSendList, true);
|
||||
getProgressService(user).finish(SalaryCacheKey.SALARY_GRANT_PROGRESS + "_" + salarySend.getId(), true);
|
||||
} catch (Exception e) {
|
||||
log.info("发送出错：{}", e.getMessage(), e);
|
||||
}
|
||||
return new HashMap<>();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 处理发送
|
||||
|
|
@ -221,13 +261,14 @@ public class SalaryBillServiceImpl extends Service implements SalaryBillService
|
|||
SalaryBillSendDTO salaryBillSendParam = buildSendParams(salarySend, taxAgentPO.getName(), salaryTemplate);
|
||||
|
||||
// 2.获取可发送的列表，此步最耗时，需要解密核算数据
|
||||
List<Map<String, Object>> enableSendList = getEnableSendList(salarySend, ids, salaryBillSendParam);
|
||||
List<Integer> sendStatusList = Arrays.asList(SalarySendStatusEnum.UNSEND.getValue(), SalarySendStatusEnum.WITHDRAW.getValue());
|
||||
List<Map<String, Object>> enableSendList = getEnableSendList(salarySend, ids, salaryBillSendParam, sendStatusList);
|
||||
|
||||
// 3.发送消息：先修改数据再发消息，避免出错后无法撤回
|
||||
List<Long> successIds = sendMessage(enableSendList, salaryBillSendParam);
|
||||
|
||||
//生成pdf
|
||||
genPdf(salaryBillSendParam, enableSendList);
|
||||
genPdf(salaryBillSendParam, enableSendList, false);
|
||||
|
||||
// 4.发放
|
||||
grantSendInfo(successIds, salarySend, salaryTemplate, salaryBillSendParam);
|
||||
|
|
@ -250,35 +291,44 @@ public class SalaryBillServiceImpl extends Service implements SalaryBillService
|
|||
}
|
||||
}
|
||||
|
||||
private void genPdf(SalaryBillSendDTO salaryBillSendParam, List<Map<String, Object>> enableSendList) {
|
||||
private void genPdf(SalaryBillSendDTO salaryBillSendParam, List<Map<String, Object>> enableSendList, boolean isSync) {
|
||||
if (GEN_PDF) {
|
||||
LocalRunnable localRunnable = new LocalRunnable() {
|
||||
@Override
|
||||
public void execute() {
|
||||
// 获取人员完整信息
|
||||
Map<String, DataCollectionEmployee> allEmployeeMap = getEmployeeWholeInfo(enableSendList);
|
||||
//生成工资单pdf
|
||||
enableSendList.forEach(e -> {
|
||||
// 构建人员信息
|
||||
SalaryBillBO.buildEmployeeInfo(salaryBillSendParam, allEmployeeMap.get(e.get("employeeId").toString()));
|
||||
SalaryBillBO.genPdf(e, salaryBillSendParam);
|
||||
});
|
||||
if (isSync) {
|
||||
genPdf(salaryBillSendParam, enableSendList);
|
||||
} else {
|
||||
LocalRunnable localRunnable = new LocalRunnable() {
|
||||
@Override
|
||||
public void execute() {
|
||||
genPdf(salaryBillSendParam, enableSendList);
|
||||
}
|
||||
};
|
||||
ThreadPoolUtil.fixedPoolExecute(ModulePoolEnum.OTHER, "salaryBillGenPdf", localRunnable);
|
||||
}
|
||||
|
||||
//合并工资单pdf
|
||||
//1、先获取所有工资单
|
||||
Long id = salaryBillSendParam.getSalarySend().getId();
|
||||
List<SalarySendInfoPO> salarySendInfos = getSalarySendInfoMapper().listSome(SalarySendInfoPO.builder().salarySendId(id).sendStatus(1).build());
|
||||
//2、工资单pdf转为路径
|
||||
String yyyyMM = SalaryDateUtil.getFormatYearMonth(salaryBillSendParam.getSalaryDate());
|
||||
List<String> filesToMerge = salarySendInfos.stream().map(po -> HrmSalaryPayrollConf.GEN_PATH + yyyyMM + File.separator + id + File.separator + po.getId() + ".pdf").collect(Collectors.toList());
|
||||
String pdfPath = HrmSalaryPayrollConf.GEN_PATH + yyyyMM + File.separator + id + File.separator + id + ".pdf";
|
||||
SalaryBillBO.mergePdf(pdfPath, filesToMerge);
|
||||
}
|
||||
};
|
||||
ThreadPoolUtil.fixedPoolExecute(ModulePoolEnum.OTHER, "salaryBillGenPdf", localRunnable);
|
||||
}
|
||||
}
|
||||
|
||||
private void genPdf(SalaryBillSendDTO salaryBillSendParam, List<Map<String, Object>> enableSendList) {
|
||||
// 获取人员完整信息
|
||||
Map<String, DataCollectionEmployee> allEmployeeMap = getEmployeeWholeInfo(enableSendList);
|
||||
//生成工资单pdf
|
||||
enableSendList.forEach(e -> {
|
||||
// 构建人员信息
|
||||
SalaryBillBO.buildEmployeeInfo(salaryBillSendParam, allEmployeeMap.get(e.get("employeeId").toString()));
|
||||
SalaryBillBO.genPdf(e, salaryBillSendParam);
|
||||
});
|
||||
|
||||
//合并工资单pdf
|
||||
//1、先获取所有工资单
|
||||
Long id = salaryBillSendParam.getSalarySend().getId();
|
||||
List<SalarySendInfoPO> salarySendInfos = getSalarySendInfoMapper().listSome(SalarySendInfoPO.builder().salarySendId(id).sendStatus(1).build());
|
||||
//2、工资单pdf转为路径
|
||||
String yyyyMM = SalaryDateUtil.getFormatYearMonth(salaryBillSendParam.getSalaryDate());
|
||||
List<String> filesToMerge = salarySendInfos.stream().map(po -> HrmSalaryPayrollConf.GEN_PATH + yyyyMM + File.separator + id + File.separator + po.getId() + ".pdf").collect(Collectors.toList());
|
||||
String pdfPath = HrmSalaryPayrollConf.GEN_PATH + yyyyMM + File.separator + id + File.separator + id + ".pdf";
|
||||
SalaryBillBO.mergePdf(pdfPath, filesToMerge);
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建发送参数
|
||||
*
|
||||
|
|
@ -394,12 +444,12 @@ public class SalaryBillServiceImpl extends Service implements SalaryBillService
|
|||
* @param ids
|
||||
* @return
|
||||
*/
|
||||
private List<Map<String, Object>> getEnableSendList(SalarySendPO salarySend, List<Long> ids, SalaryBillSendDTO salaryBillSendParam) {
|
||||
private List<Map<String, Object>> getEnableSendList(SalarySendPO salarySend, List<Long> ids, SalaryBillSendDTO salaryBillSendParam, List<Integer> sendStatus) {
|
||||
SalarySendInfoQueryParam queryParam = new SalarySendInfoQueryParam();
|
||||
queryParam.setSalarySendId(salarySend.getId());
|
||||
// 空就是所有
|
||||
queryParam.setIds(ids);
|
||||
queryParam.setSendStatuss(Arrays.asList(SalarySendStatusEnum.UNSEND.getValue(), SalarySendStatusEnum.WITHDRAW.getValue()));
|
||||
queryParam.setSendStatuss(sendStatus);
|
||||
// 2.获取基本数据
|
||||
List<SalarySendInfoListDTO> list = Lists.newArrayList();
|
||||
if (CollectionUtils.isEmpty(ids)) {
|
||||
|
|
@ -500,6 +550,57 @@ public class SalaryBillServiceImpl extends Service implements SalaryBillService
|
|||
return path;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String genPdfBeforeExport(SalaryExportPdfParam param) {
|
||||
// 先判断对应路径下是否存在pdf
|
||||
SalarySendPO salarySend = checkAndGetSalarySend(param.getSalarySendId());
|
||||
String yearMonth = SalaryDateUtil.getFormatYearMonth(salarySend.getSalaryMonth());
|
||||
String pdfPath = HrmSalaryPayrollConf.GEN_PATH + File.separator + yearMonth + File.separator + salarySend.getId() + File.separator + "%s" + ".pdf";
|
||||
Long id = param.getId();
|
||||
if (id == null) {
|
||||
pdfPath = String.format(pdfPath, param.getSalarySendId());
|
||||
} else {
|
||||
pdfPath = String.format(pdfPath, id);
|
||||
}
|
||||
File file = new File(pdfPath);
|
||||
if (file.exists()) {
|
||||
return "success";
|
||||
}
|
||||
|
||||
// 判断对应路径下是否存在html
|
||||
String htmlPath = HrmSalaryPayrollConf.GEN_PATH + File.separator + yearMonth + File.separator + salarySend.getId() + File.separator + "%s" + ".html";
|
||||
if (id == null) {
|
||||
htmlPath = String.format(htmlPath, param.getSalarySendId());
|
||||
} else {
|
||||
htmlPath = String.format(htmlPath, id);
|
||||
}
|
||||
file = new File(htmlPath);
|
||||
if (file.exists()) {
|
||||
// 将html转成pdf
|
||||
FileUtil.del(pdfPath);
|
||||
HtmlToPdf.convert(HrmSalaryPayrollConf.TO_PDF_TOOL_PATH, htmlPath, pdfPath);
|
||||
mergePdf(param, yearMonth);
|
||||
return "success";
|
||||
}
|
||||
|
||||
// 先生成html再生成pdf
|
||||
SalarySendGrantParam grantParam = SalarySendGrantParam.builder().salarySendId(param.getSalarySendId()).ids(Collections.singletonList(param.getId())).build();
|
||||
reGenPdf(grantParam);
|
||||
return "success";
|
||||
|
||||
}
|
||||
|
||||
private void mergePdf(SalaryExportPdfParam param, String yearMonth) {
|
||||
//合并工资单pdf
|
||||
//1、先获取所有工资单
|
||||
Long salarySendId = param.getSalarySendId();
|
||||
List<SalarySendInfoPO> salarySendInfos = getSalarySendInfoMapper().listSome(SalarySendInfoPO.builder().salarySendId(salarySendId).sendStatus(1).build());
|
||||
//2、工资单pdf转为路径
|
||||
List<String> filesToMerge = salarySendInfos.stream().map(po -> HrmSalaryPayrollConf.GEN_PATH + yearMonth + File.separator + salarySendId + File.separator + po.getId() + ".pdf").collect(Collectors.toList());
|
||||
String pdfPath = HrmSalaryPayrollConf.GEN_PATH + yearMonth + File.separator + salarySendId + File.separator + salarySendId + ".pdf";
|
||||
SalaryBillBO.mergePdf(pdfPath, filesToMerge);
|
||||
}
|
||||
|
||||
public List<Map<String, Object>> getSendInfoList(Long sendId, List<Long> ids) {
|
||||
|
||||
SalarySendPO salarySend = getSalarySendMapper().getById(sendId);
|
||||
|
|
|
|||
|
|
@ -560,6 +560,30 @@ public class SalaryBillController {
|
|||
//
|
||||
// }
|
||||
|
||||
|
||||
/**
|
||||
* 下载pdf前先进行校验 生成
|
||||
* @param request
|
||||
* @param response
|
||||
* @return
|
||||
*/
|
||||
@GET
|
||||
@Path("/genPdfBeforeExport")
|
||||
@Produces(MediaType.APPLICATION_JSON)
|
||||
public String genPdfBeforeExport(@Context HttpServletRequest request, @Context HttpServletResponse response) {
|
||||
User user = HrmUserVarify.getUser(request, response);
|
||||
SalaryExportPdfParam salaryExportPdfParam = new SalaryExportPdfParam();
|
||||
String id = request.getParameter("id");
|
||||
if (StringUtils.isNotBlank(id)) {
|
||||
salaryExportPdfParam.setId(Long.valueOf(id));
|
||||
}
|
||||
String salarySendId = request.getParameter("salarySendId");
|
||||
if (StringUtils.isNotBlank(salarySendId)) {
|
||||
salaryExportPdfParam.setSalarySendId(Long.valueOf(salarySendId));
|
||||
}
|
||||
return new ResponseResult<SalaryExportPdfParam, String>(user).run(getSalarySendWrapper(user)::genPdfBeforeExport, salaryExportPdfParam);
|
||||
}
|
||||
|
||||
@GET
|
||||
@Path("/exportPdf")
|
||||
public Response downloadPdfFile(@Context HttpServletRequest request, @Context HttpServletResponse response) {
|
||||
|
|
|
|||
|
|
@ -742,4 +742,8 @@ public class SalarySendWrapper extends Service implements SalarySendWrapperProxy
|
|||
public Map<String, String> getToken(Long uid) {
|
||||
return SalaryTokenUtil.GetToken( uid);
|
||||
}
|
||||
|
||||
public String genPdfBeforeExport(SalaryExportPdfParam salaryExportPdfParam) {
|
||||
return getSalaryBillService(user).genPdfBeforeExport(salaryExportPdfParam);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue