rakor
/
wms
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor(inspection): 简化来料检验任务处理逻辑 

- 移除了检测方法类型的条件判断分支
- 统一了事务同步处理流程
- 简化了不合格数量检查和工单发起逻辑
- 保留了异步回调服务调用的核心功能
- 优化了代码结构提高可维护性
This commit is contained in:
曹鹏飞 2026-06-16 11:50:26 +08:00
parent dddbcf6700
commit 534a2af695
1 changed files with 10 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/IncomingInspectionTaskControllerService.java
View File

@ -1180,38 +1180,18 @@ public class IncomingInspectionTaskControllerService {
updateWrapper.update(); updateWrapper.update();
long testingMethodId = dictionaryItemService.getIdByCode("InspectionStandardTestingMethod", "Full"); if (task.getUnqualifiedQty() > 0) {
if (Objects.equals(task.getTestingMethodDictItemId(), testingMethodId)) { issueTicketControllerService.initiate(task.getId());
//全检 }
if (TransactionSynchronizationManager.isSynchronizationActive()) { if (TransactionSynchronizationManager.isSynchronizationActive()) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override @Override
public void afterCommit() { 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 {
wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0); wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0);
} }
} else { });
issueTicketControllerService.initiate(task.getId()); } else {
} wmsIncomingInspectionTaskCallbackService.processAsync(task.getId(), (short) 0);
} }
} }