echo
/
route
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

超标原因调整。

This commit is contained in:
dengwc 2024-04-15 17:06:27 +08:00
parent d02276ea0d
commit cf0986a837
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/chint/domain/factoriy/order_record/LyStatementOrder.java
View File

@ -98,8 +98,8 @@ public class LyStatementOrder {
try { try {
// 关闭线程池 // 关闭线程池
executor.shutdown(); executor.shutdown();
// 等待所有任务执行完成或者超时时间到达（这里设置为一天） // 等待所有任务执行完成或者超时时间到达（这里设置为6小时）
boolean flag = executor.awaitTermination(1, TimeUnit.HOURS); boolean flag = executor.awaitTermination(6, TimeUnit.HOURS);
} catch (InterruptedException e) { } catch (InterruptedException e) {
// 处理中断异常 // 处理中断异常
log.error(e.getMessage()); log.error(e.getMessage());

6
src/main/java/com/chint/domain/service/BPMOrderDomainService.java
View File

@ -38,6 +38,7 @@ import java.math.BigDecimal;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.Optional;
import static com.chint.infrastructure.constant.BPMConstant.*; import static com.chint.infrastructure.constant.BPMConstant.*;
import static com.chint.infrastructure.constant.BPMConstant.REFUND_TYPE_FLIGHT; import static com.chint.infrastructure.constant.BPMConstant.REFUND_TYPE_FLIGHT;
@ -118,7 +119,10 @@ public class BPMOrderDomainService {
case LEG_TYPE_OTHER -> bpmParamFactory.creatAuditParamByOther(orderDetail); case LEG_TYPE_OTHER -> bpmParamFactory.creatAuditParamByOther(orderDetail);
default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND); default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND);
}; };
exceedStandardDto.setReason(command.getReason()); String currentReason = exceedStandardDto.getReason();
if (StringUtils.isBlank(currentReason)) {
exceedStandardDto.setReason(command.getReason());
}
DelayDispatch.attemptToSend(() -> bpmRequest.exceedStandard(exceedStandardDto, sysCode, employeeNo, accountCompany).getSuccess(), DelayDispatch.attemptToSend(() -> bpmRequest.exceedStandard(exceedStandardDto, sysCode, employeeNo, accountCompany).getSuccess(),
0); 0);
} }