From 54b274998a6e839227a86a3f39ff2a9f69f32fcc Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期二, 30 七月 2024 14:35:11 +0800
Subject: [PATCH] 兼容无任务工作中的追溯信息

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java |  140 +++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 119 insertions(+), 21 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 ddb5aa2..8cf3d79 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
@@ -15,6 +15,7 @@
 import com.dy.pmsGlobal.pojoPr.PrProductionNode;
 import com.dy.pmsGlobal.pojoPr.PrWorkingInstruction;
 import com.dy.pmsGlobal.pojoSta.*;
+import com.dy.pmsGlobal.util.DeviceResult;
 import com.dy.pmsGlobal.util.DeviceStatus;
 import com.dy.pmsGlobal.util.QrCodeConstant;
 import lombok.extern.slf4j.Slf4j;
@@ -35,6 +36,7 @@
     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 static final String WORK_TYPE_OTHER = "5";
 
     private StaDeviceLastMapper deviceLastDao;
     private StaDeviceLifeMapper deviceLifeDao;
@@ -210,12 +212,13 @@
     private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast, String deviceNo) {
         //缁勮鏁版嵁
         StaDeviceLast record = new StaDeviceLast();
-        //pr_assembly_plan input_number +1  鎶曞叆鏁板姞1
-        PrAssemblyPlan assemblyPlan = assemblyPlanDao.selectByPrimaryKey(workLast.planId);
+        //pr_assembly_plan input_number +1  鎶曞叆鏁板姞1   鏍规嵁deviceNo 鎵惧埌瀵瑰簲浠诲姟
+        PrAssemblyPlan assemblyPlan = queryPlanByDeviceNo(deviceNo); //PrAssemblyPlan assemblyPlan = assemblyPlanDao.selectByPrimaryKey(workLast.planId);
         StaDeviceLast preRecord = deviceLastDao.selectByDeviceNo(deviceNo);
         if (preRecord != null) {
             record.id = preRecord.id;
             record.inTime = preRecord.outTime;
+            record.outLineTime = preRecord.outLineTime;//涓嬭竟鍒ゆ柇鏄惁缁撴潫浼氱敤鍒� 寰楃暀鐫�
         } else {
             record.inTime = new Date();
             record.inLineTime = new Date();
@@ -233,7 +236,9 @@
         record.assistants = workLast.assistants;
         record.errorMsg = params.errorMsg;
 
+        Boolean isEnd = false;//鏄惁缁忓巻杩囩粨鏉熻妭鐐�
         PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
+        //
         record.nodeContent = node.content;
         if (node.isRecord) {
             record.deviceCycleContent = node.deviceCycleContent;
@@ -241,12 +246,14 @@
         if (node.getIsEnd() && record.outLineTime == null) {
             record.outLineTime = new Date();
             assemblyPlan.setOutputNumber(assemblyPlan.getOutputNumber() + 1);
+            isEnd = true;
+        }else if(record.outLineTime != null){
+            isEnd = true;
         }
         assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan);
-        record.status = getStatus(params.status, node.isEnd, workLast.workType.toString());
-        if (record.status == null) {
-            record.status = preRecord.status;
-        }
+
+        record.status = getStatus(params.status, isEnd, workLast.workType.toString());
+        record.result = getResult(params.status, workLast.workType.toString());
         return record;
     }
 
@@ -265,33 +272,63 @@
     }
 
     /**
-     * 鐘舵��: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃
-     *
+     * 鍘熺姸鎬�: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃
+     *20240717褰撳墠鐘舵��  鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
      * @param status    鐘舵��
-     * @param isEndNode 鏄惁缁撴潫鑺傜偣
+     * @param isEnd 鏄惁缁忓巻杩囩粨鏉熻妭鐐�
      * @return 鐘舵��
      */
-    private Integer getStatus(String status, boolean isEndNode, String workType) {
-        //缁勮,缁翠慨
-        if (WORK_TYPE_ASSEMBLY.equals(workType) || WORK_TYPE_REPAIR.equals(workType)) {
+    private Integer getStatus(String status, boolean isEnd, String workType) {
+        //缁勮   2024/07/17 鐩墠缁勮workType 1 鍙湁MarkOk     //娴嬭瘯    //鍝佹
+        if (WORK_TYPE_ASSEMBLY.equals(workType) || WORK_TYPE_TEST.equals(workType) || WORK_TYPE_INSPECTION.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.MarkOk -> isEnd ? DeviceStatus.COMPLETED.getCode() : DeviceStatus.ASSEMBLING.getCode();
+                case QrCodeConstant.MarkQualified -> isEnd ? DeviceStatus.COMPLETED.getCode() : DeviceStatus.ASSEMBLING.getCode();
+                case QrCodeConstant.MarkUnqualified -> 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)) {
+        }
+        //缁翠慨
+        throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
+    }
+    /**
+     * 缁撴灉: 1:閫氳繃,2:娴嬭瘯閫氳繃,3:鍝佹閫氳繃,4:缁翠慨閫氳繃,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃,7:鎶ュ簾
+     * @param status    鍓嶇鍑烘潵鐨勭姸鎬�
+     * @return 缁撴灉
+     */
+    private Integer getResult(String status, String workType) {
+        //缁勮
+        if (WORK_TYPE_ASSEMBLY.equals(workType)) {
             return switch (status) {
-                case QrCodeConstant.MarkOk -> null;//DeviceStatus.COMPLETED.getCode();
-                case QrCodeConstant.MarkUnqualified -> DeviceStatus.TEST_FAILED.getCode();
-                case QrCodeConstant.MarkWaste -> DeviceStatus.WASTE.getCode();
+                case QrCodeConstant.MarkOk -> DeviceResult.PASS.getCode();
+                default -> throw new RuntimeException("鐘舵�侀敊璇�");
+            };
+            //娴嬭瘯
+        }else if (WORK_TYPE_TEST.equals(workType)) {
+            return switch (status) {
+                case QrCodeConstant.MarkQualified  -> DeviceResult.TEST_PASS.getCode();
+                case QrCodeConstant.MarkUnqualified -> DeviceResult.TEST_FAIL.getCode();
+                default -> throw new RuntimeException("鐘舵�侀敊璇�");
+            };
+            //鍝佹
+        }else if (WORK_TYPE_INSPECTION.equals(workType)) {
+            return switch (status) {
+                case QrCodeConstant.MarkQualified -> DeviceResult.INSPECTION_PASS.getCode();
+                case QrCodeConstant.MarkUnqualified -> DeviceResult.INSPECTION_FAIL.getCode();
+                default -> throw new RuntimeException("鐘舵�侀敊璇�");
+            };
+            //缁翠慨
+        }else if (WORK_TYPE_REPAIR.equals(workType)) {
+            return switch (status) {
+                case QrCodeConstant.MarkOk -> DeviceResult.REPAIR_PASS.getCode();
+                case QrCodeConstant.MarkWaste -> DeviceResult.WASTE.getCode();
                 default -> throw new RuntimeException("鐘舵�侀敊璇�");
             };
         }
         throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
     }
-
+    @Transactional
     public int repair(QueryVo vo) {
         long workId = Long.parseLong(vo.workId);
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId);
@@ -320,6 +357,7 @@
         return count;
     }
 
+    @Transactional
     public int testing(QueryVo vo) {
         long workId = Long.parseLong(vo.workId);
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId);
@@ -337,6 +375,49 @@
         return count;
     }
 
+    @Transactional
+    public int inspectQuality(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[0]);
+        int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
+                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+        saveDeviceProductionLog(deviceLast);
+        PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
+        if (node.isRecord) {
+            saveDeviceLife(deviceLast);
+        }
+        return count;
+    }
+    //鏃犱换鍔¤鍒掍腑鐨勫叾浠� 浼爓orkId ,鎵嬪啓宸ヤ綔鍐呭 , 鏁伴噺
+    @Transactional
+    public int otherWork(QueryVo vo) {
+        long workId = Long.parseLong(vo.workId);
+        StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId);
+        if (workLast == null) {
+            throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�");
+        }
+        //淇濆瓨宸ヤ綔璁板綍
+        StaDeviceProductionLog log = new StaDeviceProductionLog();
+        log.setId(null); // 璁惧鐢熶骇鏃ュ織ID璁句负null锛岃〃绀烘柊澧�
+        log.setDeviceNo("");  //RepairId  planId  currNode deviceCycleContent  memo
+        log.setWorkId(workId);
+        log.setStationId(workLast.getStationId());
+        log.setNodeContent(vo.getContent());
+        log.setStatus(DeviceStatus.COMPLETED.getCode());//瀹屾垚鐘舵��
+        log.setResult(DeviceResult.PASS.getCode());//閫氳繃
+        log.setErrorMsg(vo.getErrorMsg());
+        log.setAssistants(workLast.getAssistants());
+        log.setInTime(new Date());
+        log.setOutTime(new Date());
+        log.setUpdatedBy(workLast.getUserId());
+        log.setNumber(vo.getNumber());
+        int count = deviceProductionLogDao.insertSelective(log);
+        return count;
+    }
     //鏍规嵁鑺傜偣鏌ュ嚭鑺傜偣浣滀笟鎸囧涔�
     public PrProductionNode getSopByNodeId(String nodeId) {
         if (com.alibaba.excel.util.StringUtils.isBlank(nodeId)) {
@@ -452,6 +533,7 @@
         map.put("proName", "");
         map.put("proType", "");
         map.put("proId", "");
+        map.put("proCode", "");
         //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡
         if(CollectionUtils.isEmpty(productList)){
             productList = productDao.selectAll(null);
@@ -466,10 +548,24 @@
             map.put("proType", product.getType());
             BigInteger proId = BigInteger.valueOf(product.getId());
             map.put("proId", proId.toString());
+            map.put("proCode",product.getCode());
         }
         return map;
     }
-
+    //鏌ヨ浜у搧鎵�鍦ㄧ殑浠诲姟
+    public PrAssemblyPlan queryPlanByDeviceNo(String deviceNo) {
+        String proCode = "";
+        String lotCode = "";
+        if (StringUtils.isNotEmpty(deviceNo) && deviceNo.length() == 22) {
+            proCode = deviceNo.substring(3,6);
+            lotCode = deviceNo.substring(6,15);
+        }
+        PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode,lotCode);
+        if(plan != null){
+            plan.setBatchNo(lotCode);
+        }
+        return plan;
+    }
     public List<StaDeviceLife> queryLifeByDeviceNo(String deviceNo) {
         return deviceLifeDao.selectByDeviceNo(deviceNo);
     }
@@ -477,4 +573,6 @@
     public List<StaDeviceProductionLog> queryLogByDeviceNo(String devoiceNo) {
         return deviceProductionLogDao.selectByDeviceNo(devoiceNo);
     }
+
+
 }

--
Gitblit v1.8.0