nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java

@@ -108,6 +108,7 @@ public class QmsIncomingInspectionTaskController extends BaseController {
     /**
      * 提交检测项
      */
+    @Transactional
     @PostMapping("pad/add-check-item")
     public ApiResult<Void> addCheckItem(@Valid @RequestBody QmsIncomingInspectionTaskTodoCheckSubmitQO request){
         incomingInspectionTaskControllerService.submitCheckItem(request);
@@ -117,6 +118,7 @@ public class QmsIncomingInspectionTaskController extends BaseController {
     /**
      * 暂存检验结果
      */
+    @Transactional
     @PostMapping("pad/staging")
     public ApiResult<Void> staging(@Valid @RequestBody QmsIncomingInspectionTaskSubmitQO request){
         incomingInspectionTaskControllerService.staging(request);
@@ -126,6 +128,7 @@ public class QmsIncomingInspectionTaskController extends BaseController {
     /**
      * 提交检验结果
      */
+    @Transactional
     @PostMapping("pad/submit")
     public ApiResult<Void> submit(@Valid @RequestBody QmsIncomingInspectionTaskSubmitQO request){
         incomingInspectionTaskControllerService.submit(request);
@@ -137,7 +140,7 @@ public class QmsIncomingInspectionTaskController extends BaseController {
      */
     @PostMapping("callback")
     public ApiResult<Void> callback(@RequestParam Long taskId){
-        wmsIncomingInspectionTaskCallbackService.process(taskId);
+        wmsIncomingInspectionTaskCallbackService.process(taskId, (short) 0);
         return ApiResult.success();
     }
 }

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

@@ -943,7 +943,6 @@ public class IncomingInspectionTaskControllerService {
         updateWrapper.update();
     }
 
-    @Transactional
     public void submit(@Valid QmsIncomingInspectionTaskSubmitQO request) {
         QmsIncomingInspectionTask task = incomingInspectionTaskService.getById(request.getTaskId());
         VUtil.trueThrowBusinessError(Objects.isNull(task)).throwMessage("任务不存在");
@@ -986,7 +985,7 @@ public class IncomingInspectionTaskControllerService {
         updateWrapper.update();
 
         if (task.getInspectionResult()) {
-            wmsIncomingInspectionTaskCallbackService.process(task.getId());
+            wmsIncomingInspectionTaskCallbackService.process(task.getId(), (short) 0);
         } else {
             issueTicketControllerService.initiate(task.getId());
         }

nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java

@@ -8,10 +8,8 @@ import com.nflg.wms.common.pojo.vo.QmsIncomingInspectionTaskVO;
 import com.nflg.wms.common.util.VUtil;
 import com.nflg.wms.repository.entity.QmsIncomingInspectionTask;
 import com.nflg.wms.repository.entity.QmsIncomingInspectionTaskRecord;
-import com.nflg.wms.repository.entity.QmsIssueTicket;
 import com.nflg.wms.repository.service.IQmsIncomingInspectionTaskRecordService;
 import com.nflg.wms.repository.service.IQmsIncomingInspectionTaskService;
-import com.nflg.wms.repository.service.IQmsIssueTicketService;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -19,7 +17,6 @@ import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
-import java.util.Objects;
 
 /**
  * Wms来料检验任务回调服务
@@ -43,9 +40,6 @@ public class WmsIncomingInspectionTaskCallbackService {
     @Resource
     private WmsApiService wmsApiService;
 
-    @Resource
-    private IQmsIssueTicketService issueTicketService;
-
     /**
      * 向WMS系统发送来料检验任务回调
      */
@@ -158,31 +152,11 @@ public class WmsIncomingInspectionTaskCallbackService {
     /**
      * WMS系统来料检验任务回调
      * @param taskId            来料检验任务ID
-     */
-    public void process(Long taskId) {
-        QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId);
-        VUtil.trueThrowBusinessError(Objects.equals(taskVO.getCallbackResult(), true)).throwMessage("请勿重复回调");
-        VUtil.trueThrowBusinessError(taskVO.getInspectionStatus() != 2).throwMessage("来料检验任务状态不允许回调");
-        if (taskVO.getInspectionResult()) {
-            process(taskVO, (short) 0);
-        } else {
-            QmsIssueTicket issueTicket = issueTicketService.lambdaQuery()
-                    .eq(QmsIssueTicket::getSourceId, taskId)
-                    .eq(QmsIssueTicket::getStatus, 2)
-                    .orderByDesc(QmsIssueTicket::getId)
-                    .last("limit 1")
-                    .one();
-            VUtil.trueThrowBusinessError(Objects.isNull(issueTicket)).throwMessage("未找到符合条件的工单");
-            process(taskVO, issueTicket.getApprovalStatus());
-        }
-    }
-
-    /**
-     * WMS系统来料检验任务回调
-     * @param taskVO            来料检验任务VO
      * @param processingResult  处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用
      */
-    private void process(QmsIncomingInspectionTaskVO taskVO, Short processingResult) {
+    public void process(Long taskId, Short processingResult) {
+        QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId);
+        VUtil.trueThrowBusinessError(taskVO.getCallbackResult()).throwMessage("请勿重复回调");
         switch (taskVO.getInspectionType()) {
             case 1:
                 incoming(taskVO,processingResult);
@@ -195,15 +169,4 @@ public class WmsIncomingInspectionTaskCallbackService {
                 break;
         }
     }
-
-    /**
-     * WMS系统来料检验任务回调
-     * @param taskId            来料检验任务ID
-     * @param processingResult  处理结果：0=通过，3=报废，4=维修，5=挑选使用，6=让渡使用
-     */
-    private void process(Long taskId, Short processingResult) {
-        QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId);
-        VUtil.trueThrowBusinessError(Objects.equals(taskVO.getCallbackResult(),true)).throwMessage("请勿重复回调");
-        process(taskVO, processingResult);
-    }
 }

nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/vo/QmsIncomingInspectionTaskVO.java

@@ -125,7 +125,7 @@ public class QmsIncomingInspectionTaskVO {
     /**
      * 已检数量
      */
-    private Integer inspectedQty = 0;
+    private Integer inspectedQty;
 
     /**
      * 未检数量

nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml

@@ -138,8 +138,7 @@
             t2.task_no as related_task_no,
             t.update_user_id,
             t.update_user_name,
-        t.update_time,
+            t.update_time
-        t.detection_qty
         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