2025-03-12 合同下载调整

This commit is contained in:
15737803739 2025-03-12 21:16:15 +08:00
parent 4e163d3c4c
commit 031fdf31a9
2 changed files with 6 additions and 6 deletions

View File

@ -201,7 +201,7 @@ public class MsxfContractDownloadTasklet extends MsxfContractBatchTasklet {
} }
private void addrecordList(List<SysMqRecord> recordList,File fil,String bizNo,String bizDate) { private void addrecordList(List<SysMqRecord> recordList,File fil,String bizNo,String bizDate) {
if (fil.getName().contains(ContractConst.CONTRACT_POLICY)){ if (fil.getName().contains("_"+ContractConst.CONTRACT_POLICY)){
SysMqRecord mqRecordDown = new SysMqRecord(); SysMqRecord mqRecordDown = new SysMqRecord();
mqRecordDown.setId(idGenerator.nextIdStr()); mqRecordDown.setId(idGenerator.nextIdStr());
mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD); mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD);
@ -226,7 +226,7 @@ public class MsxfContractDownloadTasklet extends MsxfContractBatchTasklet {
mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK); mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK);
mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus()); mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus());
recordList.add(mqRecordBack); recordList.add(mqRecordBack);
} else if (fil.getName().contains("entrust")){ } else if (fil.getName().contains("_"+ContractConst.CONTRACT_PROXY)){
SysMqRecord mqRecordDown = new SysMqRecord(); SysMqRecord mqRecordDown = new SysMqRecord();
mqRecordDown.setId(idGenerator.nextIdStr()); mqRecordDown.setId(idGenerator.nextIdStr());
mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD); mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD);
@ -251,7 +251,7 @@ public class MsxfContractDownloadTasklet extends MsxfContractBatchTasklet {
mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK); mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK);
mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus()); mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus());
recordList.add(mqRecordBack); recordList.add(mqRecordBack);
} else if (fil.getName().contains(ContractConst.CONTRACT_FINANCING)) { } else if (fil.getName().contains("_"+ContractConst.CONTRACT_FINANCING)) {
SysMqRecord mqRecordDown = new SysMqRecord(); SysMqRecord mqRecordDown = new SysMqRecord();
mqRecordDown.setId(idGenerator.nextIdStr()); mqRecordDown.setId(idGenerator.nextIdStr());
mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD); mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD);
@ -276,7 +276,7 @@ public class MsxfContractDownloadTasklet extends MsxfContractBatchTasklet {
mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK); mqRecordBack.setBizType(ContractConst.BIZ_TYPE_FILE_BACK);
mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus()); mqRecordBack.setStatus(SysMqRecord.Status.DOING.getStatus());
recordList.add(mqRecordBack); recordList.add(mqRecordBack);
} else if (fil.getName().contains(ContractConst.INSTALLMENT_GUARANTEE)) { } else if (fil.getName().contains("_"+ContractConst.INSTALLMENT_GUARANTEE)) {
SysMqRecord mqRecordDown = new SysMqRecord(); SysMqRecord mqRecordDown = new SysMqRecord();
mqRecordDown.setId(idGenerator.nextIdStr()); mqRecordDown.setId(idGenerator.nextIdStr());
mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD); mqRecordDown.setBizType(ContractConst.BIZ_TYPE_FILE_DOWNLOAD);

View File

@ -72,8 +72,8 @@ public class MsxfContractToSFTPTasklet extends MsxfContractBatchTasklet {
public void runJob(JobReqEntity jobReqEntity, JobRespEntity jobRespEntity) throws Exception { public void runJob(JobReqEntity jobReqEntity, JobRespEntity jobRespEntity) throws Exception {
log.info("批量【msxfContractToSFTPTasklet】入参[{}]", jobReqEntity); log.info("批量【msxfContractToSFTPTasklet】入参[{}]", jobReqEntity);
String date = getDate(jobReqEntity); String date = getDate(jobReqEntity);
String bizDate = StringUtils.isEmpty(date) ? LocalDate.now().toString() : date; //String bizDate = StringUtils.isEmpty(date) ? LocalDate.now().toString() : date;
String formatDate = getYesDateFormats(bizDate); String formatDate = getYesDateFormats(date);
//状态枚举 参考SysMqRecord.java ,Status枚举 //状态枚举 参考SysMqRecord.java ,Status枚举
Integer status = getStatus(jobReqEntity); Integer status = getStatus(jobReqEntity);
String eventType = getEventType(jobReqEntity); String eventType = getEventType(jobReqEntity);