From 534a2af69534dac43292e5d95974697c5cda3908 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9B=B9=E9=B9=8F=E9=A3=9E?= Date: Tue, 16 Jun 2026 11:50:26 +0800 Subject: [PATCH] =?UTF-8?q?refactor(inspection):=20=E7=AE=80=E5=8C=96?= =?UTF-8?q?=E6=9D=A5=E6=96=99=E6=A3=80=E9=AA=8C=E4=BB=BB=E5=8A=A1=E5=A4=84?= =?UTF-8?q?=E7=90=86=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 移除了检测方法类型的条件判断分支 - 统一了事务同步处理流程 - 简化了不合格数量检查和工单发起逻辑 - 保留了异步回调服务调用的核心功能 - 优化了代码结构提高可维护性 --- ...comingInspectionTaskControllerService.java | 40 +++++-------------- 1 file changed, 10 insertions(+), 30 deletions(-) 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 855e1b25..473b14a1 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 @@ -1180,38 +1180,18 @@ public class IncomingInspectionTaskControllerService { updateWrapper.update(); - long testingMethodId = dictionaryItemService.getIdByCode("InspectionStandardTestingMethod", "Full"); - if (Objects.equals(task.getTestingMethodDictItemId(), testingMethodId)) { - //全检 - if (TransactionSynchronizationManager.isSynchronizationActive()) { - TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { - @Override - public void afterCommit() { - wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); - } - }); - } else { - wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); - } - if (task.getUnqualifiedQty() > 0) { - issueTicketControllerService.initiate(task.getId()); - } - } else { - //抽样 - if (request.getQualified()) { - if (TransactionSynchronizationManager.isSynchronizationActive()) { - TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { - @Override - public void afterCommit() { - wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); - } - }); - } else { + if (task.getUnqualifiedQty() > 0) { + issueTicketControllerService.initiate(task.getId()); + } + if (TransactionSynchronizationManager.isSynchronizationActive()) { + TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { + @Override + public void afterCommit() { wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); } - } else { - issueTicketControllerService.initiate(task.getId()); - } + }); + } else { + wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); } }