From 973022f0585dbada665543db56e64e1ce3816150 Mon Sep 17 00:00:00 2001
From: 刘小明 <liuxm_a@163.com>
Date: 星期四, 04 七月 2024 16:01:27 +0800
Subject: [PATCH] 添加测试品检接口

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java |  103 ++++++++++++++++++++++++++++++++-------------------
 1 files changed, 64 insertions(+), 39 deletions(-)

diff --git a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
index cbd6c1e..44c26a6 100644
--- a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
+++ b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
@@ -1,16 +1,20 @@
 package com.dy.pmsStation.assemblyStep;
 
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.dy.pmsGlobal.daoPlt.PltProductMapper;
 import com.dy.pmsGlobal.daoPlt.PltProductQualityInspectionItemsMapper;
 import com.dy.pmsGlobal.daoPlt.PltProductTestInspectionItemsMapper;
 import com.dy.pmsGlobal.daoPr.PrAssemblyPlanMapper;
 import com.dy.pmsGlobal.daoPr.PrProductionNodeMapper;
 import com.dy.pmsGlobal.daoSta.*;
+import com.dy.pmsGlobal.pojoPlt.PltProduct;
 import com.dy.pmsGlobal.pojoPlt.PltProductQualityInspectionItems;
 import com.dy.pmsGlobal.pojoPlt.PltProductTestInspectionItems;
 import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan;
 import com.dy.pmsGlobal.pojoPr.PrProductionNode;
 import com.dy.pmsGlobal.pojoSta.*;
+import com.dy.pmsGlobal.util.DeviceStatus;
 import com.dy.pmsGlobal.util.QrCodeConstant;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
@@ -23,10 +27,10 @@
 @Slf4j
 @Service
 public class AssemblyStepSv {
-    private static final int STATUS_OK = 1;
-    private static final int STATUS_COMPLETE = 2;
-    private static final int STATUS_REPAIR = 3;
-    private static final int STATUS_WASTE = 4;
+    private static final String WORK_TYPE_ASSEMBLY = "1";
+    private static final String WORK_TYPE_TEST = "2";
+    private static final String WORK_TYPE_INSPECTION = "3";
+    private static final String WORK_TYPE_REPAIR = "4";
 
     private StaDeviceLastMapper deviceLastDao;
     private StaDeviceLifeMapper deviceLifeDao;
@@ -39,55 +43,50 @@
     private StaRepairInfoMapper repairInfoDao;
     private PltProductQualityInspectionItemsMapper qualityItemsDao;
     private PltProductTestInspectionItemsMapper testItemsDao;
-
+    private PltProductMapper productDao;
     @Autowired
     public void setDeviceLastDao(StaDeviceLastMapper deviceLastDao) {
         this.deviceLastDao = deviceLastDao;
     }
-
     @Autowired
     public void setDeviceLifeDao(StaDeviceLifeMapper deviceLifeDao) {
         this.deviceLifeDao = deviceLifeDao;
     }
-
     @Autowired
     public void setWipSnExDao(StaWipSnExMapper wipSnExDao) {
         this.wipSnExDao = wipSnExDao;
     }
-
     @Autowired
     public void setDeviceProductionLogDao(StaDeviceProductionLogMapper deviceProductionLogDao) {
         this.deviceProductionLogDao = deviceProductionLogDao;
     }
-
     @Autowired
     public void setAssemblyWorkLastDao(StaAssemblyWorkLastMapper assemblyWorkLastDao) {
         this.assemblyWorkLastDao = assemblyWorkLastDao;
     }
-
     @Autowired
     public void setAssemblyPlanDao(PrAssemblyPlanMapper assemblyPlanDao) {
         this.assemblyPlanDao = assemblyPlanDao;
     }
-
     @Autowired
     public void setNodeDao(PrProductionNodeMapper nodeDao) {
         this.nodeDao = nodeDao;
     }
-
     @Autowired
     public void setRepairInfoDao(StaRepairInfoMapper repairInfoDao) {
         this.repairInfoDao = repairInfoDao;
     }
-
     @Autowired
     public void setQualityItemsDao(PltProductQualityInspectionItemsMapper qualityItemsDao) {
         this.qualityItemsDao = qualityItemsDao;
     }
-
     @Autowired
     public void setTestItemsDao(PltProductTestInspectionItemsMapper testItemsDao) {
         this.testItemsDao = testItemsDao;
+    }
+    @Autowired
+    public void setProductDao(PltProductMapper productDao) {
+        this.productDao = productDao;
     }
 
     @Transactional
@@ -103,11 +102,11 @@
         // 鍒嗙被璁惧鍙峰拰鐗╂枡鍙�
         List<String> deviceList = new ArrayList<>();
         List<String> materialList = new ArrayList<>();
-
+        List<PltProduct> productList = productDao.selectAll(null);
         deviceSet.forEach(device -> {
             if (device.contains(plan.batchNo)) {
                 deviceList.add(device);
-            } else {
+            } else if(isOurProduct(device,productList)){
                 materialList.add(device);
             }
         });
@@ -148,7 +147,7 @@
         deviceLifeDao.insertSelective(life);
     }
 
-    private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast, String deviceNo) {
+    private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast,String deviceNo) {
         //缁勮鏁版嵁
         StaDeviceLast record = new StaDeviceLast();
 
@@ -164,7 +163,6 @@
         record.stationId = workLast.stationId;
         record.equipNo = deviceNo;
         record.currNode = workLast.nodeId;
-//        record.setNextNode(getNextNode(params.status,workLast.nodeId));
 
         record.updatedBy = workLast.userId;
         record.assistants = params.assistants;
@@ -174,7 +172,7 @@
         if (node.isRecord) {
             record.equipCycleContent = node.equipCycleContent;
         }
-        record.status = getStatus(params.status, node.isEnd);
+        record.status = getStatus(params.status, node.isEnd,params.workType);
         return record;
     }
 
@@ -198,13 +196,25 @@
      * @param isEndNode 鏄惁缁撴潫鑺傜偣
      * @return 鐘舵��
      */
-    private int getStatus(String status, boolean isEndNode) {
-        return switch (status) {
-            case QrCodeConstant.MarkOk -> isEndNode ? STATUS_COMPLETE : STATUS_OK;
-            case QrCodeConstant.MarkUnqualified -> STATUS_REPAIR;
-            case QrCodeConstant.MarkWaste -> STATUS_WASTE;
-            default -> throw new RuntimeException("鐘舵�侀敊璇�");
-        };
+    private int getStatus(String status, boolean isEndNode,String workType) {
+        //缁勮,缁翠慨
+        if (WORK_TYPE_ASSEMBLY.equals(workType)||WORK_TYPE_REPAIR.equals(workType)) {
+            return switch (status) {
+                case QrCodeConstant.MarkOk -> isEndNode? DeviceStatus.COMPLETED.getCode(): DeviceStatus.ASSEMBLING.getCode();
+                case QrCodeConstant.MarkUnqualified, QrCodeConstant.MarkPreUnqualified -> DeviceStatus.REPAIR.getCode();
+                case QrCodeConstant.MarkWaste -> DeviceStatus.WASTE.getCode();
+                default -> throw new RuntimeException("鐘舵�侀敊璇�");
+            };
+        //鍝佹,娴嬭瘯
+        }else if(WORK_TYPE_INSPECTION.equals(workType)||WORK_TYPE_TEST.equals(workType)){
+            return switch (status) {
+                case QrCodeConstant.MarkOk -> DeviceStatus.COMPLETED.getCode();
+                case QrCodeConstant.MarkUnqualified -> DeviceStatus.TEST_FAILED.getCode();
+                case QrCodeConstant.MarkWaste -> DeviceStatus.WASTE.getCode();
+                default -> throw new RuntimeException("鐘舵�侀敊璇�");
+            };
+        }
+        throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
     }
 
     public int repair(QueryVo vo) {
@@ -223,25 +233,29 @@
         repairInfo.fromNode = preDeviceRecord.currNode;
         repairInfoDao.insertSelective(repairInfo);
 
-        StaDeviceLast deviceLast = new StaDeviceLast();
-        BeanUtils.copyProperties(preDeviceRecord, deviceLast);
-        deviceLast.repairId = repairInfo.id;
-        deviceLast.errorCode = vo.errorMsg;
-        deviceLast.assistants = vo.assistants;
-        //濡傛灉鍘熻妭鐐规槸缁撴潫鑺傜偣鎴栦箣鍚庣殑鑺傜偣锛屾槸鍒欐洿鏂颁负瀹屾垚,鍚﹀垯鏇存柊涓虹粍瑁呬腑(榛樿缁翠慨鑺傜偣鐨勭姸鎬佸彧鑳戒负 纭畾鎴� 鎶ュ簾)
-        boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode);
-        if (QrCodeConstant.MarkWaste.equals(vo.status)) {
-            deviceLast.status = STATUS_WASTE;
-        } else {
-            deviceLast.status = isEndNode ? STATUS_COMPLETE : STATUS_OK;
-        }
+        StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo);
+
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
                 deviceLastDao.updateByPrimaryKeySelective(deviceLast);
         saveDeviceProductionLog(deviceLast);
-
+        boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode);
         if (isEndNode) {
             saveDeviceLife(deviceLast);
         }
+        return count;
+    }
+
+    public int testing(QueryVo vo) {
+        long workId = Long.parseLong(vo.workId);
+        StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId);
+        if (workLast == null) {
+            throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�");
+        }
+
+        StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo);
+        int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
+                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+        saveDeviceProductionLog(deviceLast);
         return count;
     }
 
@@ -257,4 +271,15 @@
         params.put("proId", proId);
         return testItemsDao.selectSome(params);
     }
+
+    private boolean isOurProduct(String deviceNo, List<PltProduct> products){
+        if(StringUtils.isNotEmpty(deviceNo) && deviceNo.length() ==22 ){
+            for(PltProduct product:products){
+                if(deviceNo.startsWith(QrCodeConstant.TypeProduct + product.getCode())){
+                    return true;
+                }
+            }
+        }
+        return false;
+    }
 }

--
Gitblit v1.8.0