From fcef1709332335663b703f4cbe6e1deb4f8d3189 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Tue, 28 Apr 2026 17:10:33 +0800 Subject: [PATCH] =?UTF-8?q?feat(async-callback):=20=E6=96=B0=E5=A2=9EWMS?= =?UTF-8?q?=E6=9D=A5=E6=96=99=E6=A3=80=E9=AA=8C=E4=BB=BB=E5=8A=A1=E5=BC=82?= =?UTF-8?q?=E6=AD=A5=E5=9B=9E=E8=B0=83=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在AsyncConfig中添加名为wmsCallbackExecutor的线程池配置 - 在QmsApplication中启用@EnableAsync支持异步任务执行 - WmsIncomingInspectionTaskCallbackService新增processAsync方法实现异步处理 - process方法新增processingResult参数以支持多种处理结果回调 - 修改IncomingInspectionTaskControllerService根据检验结果调用不同回调逻辑 - 修改QmsIssueTicketControllerService审批后调用异步回调接口更新WMS状态 - QmsIncomingInspectionTaskController回调接口添加processingResult参数 - 在数据库查询中新增callback_result字段支持回调结果判定 - WmsIncomingInspectionTaskCallbackQO及WmsInventoryInspectionTaskCallbackQO添加processingResult属性 - 异步回调处理过程中增加重复回调校验及回调类型判断逻辑 --- .../com/nflg/qms/admin/QmsApplication.java | 2 ++ .../nflg/qms/admin/config/AsyncConfig.java | 17 ++++++++++ .../QmsIncomingInspectionTaskController.java | 2 +- ...comingInspectionTaskControllerService.java | 9 ++++- .../QmsIssueTicketControllerService.java | 5 +++ ...IncomingInspectionTaskCallbackService.java | 33 +++++++++++++++---- .../WmsIncomingInspectionTaskCallbackQO.java | 5 +++ .../WmsInventoryInspectionTaskCallbackQO.java | 5 +++ .../QmsIncomingInspectionTaskMapper.xml | 3 +- 9 files changed, 71 insertions(+), 10 deletions(-) diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/QmsApplication.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/QmsApplication.java index 7801c664..ce9aeb32 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/QmsApplication.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/QmsApplication.java @@ -7,6 +7,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.context.annotation.ComponentScan; import org.springframework.retry.annotation.EnableRetry; +import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.annotation.EnableScheduling; @Slf4j @@ -15,6 +16,7 @@ import org.springframework.scheduling.annotation.EnableScheduling; @EnableDiscoveryClient @EnableScheduling @EnableRetry +@EnableAsync public class QmsApplication { public static void main(String[] args) { diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/config/AsyncConfig.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/config/AsyncConfig.java index 08244936..e37f3f9e 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/config/AsyncConfig.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/config/AsyncConfig.java @@ -21,4 +21,21 @@ public class AsyncConfig { executor.initialize(); return executor; } + + @Bean(name = "wmsCallbackExecutor") + public Executor getAsyncExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + // 核心线程数（平时保持的线程数量） + executor.setCorePoolSize(5); + // 最大线程数（高峰期最多扩容到这个数量） + executor.setMaxPoolSize(20); + // 队列容量（核心线程满后，任务会放进队列，队列满后才扩容最大线程） + executor.setQueueCapacity(100); + // 线程空闲存活时间（秒） + executor.setKeepAliveSeconds(60); + // 线程名称前缀，方便在日志中排查问题 + executor.setThreadNamePrefix("wms-callback-async-"); + executor.initialize(); + return executor; + } } diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java index 32c2ed3e..7faa9a75 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java @@ -140,7 +140,7 @@ public class QmsIncomingInspectionTaskController extends BaseController { */ @PostMapping("callback") public ApiResult callback(@RequestParam Long taskId){ - wmsIncomingInspectionTaskCallbackService.process(taskId); + wmsIncomingInspectionTaskCallbackService.process(taskId, (short) 0); return ApiResult.success(); } } diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/IncomingInspectionTaskControllerService.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/IncomingInspectionTaskControllerService.java index 342ffcf2..57af8961 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/IncomingInspectionTaskControllerService.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/IncomingInspectionTaskControllerService.java @@ -110,6 +110,9 @@ public class IncomingInspectionTaskControllerService { @Resource private QmsIssueTicketControllerService issueTicketControllerService; + @Resource + private WmsIncomingInspectionTaskCallbackService wmsIncomingInspectionTaskCallbackService; + /** * 来料检验申请（对外接口） * 业务规则： @@ -954,7 +957,11 @@ public class IncomingInspectionTaskControllerService { updateWrapper.update(); - issueTicketControllerService.initiate(task.getId()); + if (task.getInspectionResult()) { + wmsIncomingInspectionTaskCallbackService.process(task.getId(), (short) 0); + } else { + issueTicketControllerService.initiate(task.getId()); + } } /** diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketControllerService.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketControllerService.java index 6e7707f4..1978d801 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketControllerService.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/QmsIssueTicketControllerService.java @@ -57,6 +57,9 @@ public class QmsIssueTicketControllerService { @Resource private QmsIssueTicketProcessControllerService issueTicketProcessControllerService; + @Resource + private WmsIncomingInspectionTaskCallbackService wmsIncomingInspectionTaskCallbackService; + /** * 审核质量问题工单 * 更新审批状态、审批意见、审批人信息、事故类型，并更新工单状态 @@ -88,6 +91,8 @@ public class QmsIssueTicketControllerService { .setApprovalTime(now); issueTicketService.updateById(entity); + + wmsIncomingInspectionTaskCallbackService.processAsync(entity.getSourceId(), request.getApprovalStatus()); } /** diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java index 56fd3600..dcae7505 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java @@ -13,6 +13,7 @@ import com.nflg.wms.repository.service.IQmsIncomingInspectionTaskService; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.util.List; @@ -42,7 +43,7 @@ public class WmsIncomingInspectionTaskCallbackService { /** * 向WMS系统发送来料检验任务回调 */ - private void incoming(QmsIncomingInspectionTaskVO taskVO) { + private void incoming(QmsIncomingInspectionTaskVO taskVO, Short processingResult) { WmsIncomingInspectionTaskCallbackQO qo = new WmsIncomingInspectionTaskCallbackQO() .setTaskNo(taskVO.getTaskNo()) .setInspectionType(taskVO.getInspectionType()) @@ -58,7 +59,8 @@ public class WmsIncomingInspectionTaskCallbackService { .setQualifiedQty(taskVO.getQualifiedQty()) .setUnqualifiedQty(taskVO.getUnqualifiedQty()) .setInspectionResult(taskVO.getInspectionResult()) - .setPurchaseGroup(taskVO.getPurchaseGroup()); + .setPurchaseGroup(taskVO.getPurchaseGroup()) + .setProcessingResult(processingResult); List records = incomingInspectionTaskRecordService.lambdaQuery() .select(QmsIncomingInspectionTaskRecord::getMaterialUniqueNo, QmsIncomingInspectionTaskRecord::getQualified) @@ -93,7 +95,7 @@ public class WmsIncomingInspectionTaskCallbackService { /** * 向WMS系统发送库存检验任务回调 */ - private void inventory(QmsIncomingInspectionTaskVO taskVO) { + private void inventory(QmsIncomingInspectionTaskVO taskVO, Short processingResult) { WmsInventoryInspectionTaskCallbackQO qo = new WmsInventoryInspectionTaskCallbackQO() .setTaskNo(taskVO.getTaskNo()) .setMaterialNo(taskVO.getMaterialNo()) @@ -104,7 +106,8 @@ public class WmsIncomingInspectionTaskCallbackService { .setInspectionQty(taskVO.getInspectionQty()) .setQualifiedQty(taskVO.getQualifiedQty()) .setUnqualifiedQty(taskVO.getUnqualifiedQty()) - .setInspectionResult(taskVO.getInspectionResult()); + .setInspectionResult(taskVO.getInspectionResult()) + .setProcessingResult(processingResult); List records = incomingInspectionTaskRecordService.lambdaQuery() .select(QmsIncomingInspectionTaskRecord::getMaterialUniqueNo, QmsIncomingInspectionTaskRecord::getQualified) @@ -136,14 +139,30 @@ public class WmsIncomingInspectionTaskCallbackService { } } - public void process(Long taskId) { + /** + * WMS系统来料检验任务回调 + * @param taskId 来料检验任务ID + * @param processingResult 处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用 + */ + @Async("wmsCallbackExecutor") + public void processAsync(Long taskId, Short processingResult) { + process(taskId, processingResult); + } + + /** + * WMS系统来料检验任务回调 + * @param taskId 来料检验任务ID + * @param processingResult 处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用 + */ + public void process(Long taskId, Short processingResult) { QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId); + VUtil.trueThrowBusinessError(taskVO.getCallbackResult()).throwMessage("请勿重复回调"); switch (taskVO.getInspectionType()) { case 1: - incoming(taskVO); + incoming(taskVO,processingResult); break; case 2: - inventory(taskVO); + inventory(taskVO,processingResult); break; default: VUtil.trueThrowBusinessError(true).throwMessage("无效的检验类型：" + taskVO.getInspectionType()); diff --git a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsIncomingInspectionTaskCallbackQO.java b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsIncomingInspectionTaskCallbackQO.java index b4df5033..2c44a08a 100644 --- a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsIncomingInspectionTaskCallbackQO.java +++ b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsIncomingInspectionTaskCallbackQO.java @@ -84,6 +84,11 @@ public class WmsIncomingInspectionTaskCallbackQO { */ private String purchaseGroup; + /** + * 处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用 + */ + private Short processingResult = 0; + /** * 合格物料唯一编号列表 */ diff --git a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsInventoryInspectionTaskCallbackQO.java b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsInventoryInspectionTaskCallbackQO.java index a535e3c4..e325c2a6 100644 --- a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsInventoryInspectionTaskCallbackQO.java +++ b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/qo/WmsInventoryInspectionTaskCallbackQO.java @@ -59,6 +59,11 @@ public class WmsInventoryInspectionTaskCallbackQO { */ private Boolean inspectionResult; + /** + * 处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用 + */ + private Short processingResult = 0; + /** * 合格物料唯一编号列表 */ diff --git a/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml b/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml index f127cedd..675876ff 100644 --- a/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml +++ b/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml @@ -211,7 +211,8 @@ t.purchase_group, t.warehouse, t.storage_location, - t.storage_days + t.storage_days, + t.callback_result FROM qms_incoming_inspection_task t LEFT JOIN qms_qc_material m ON t.material_id = m.id LEFT JOIN qms_inspection_standard s ON t.inspection_standard_id = s.id