From 1f06ab808f1dde3cc21651c56e70e6b76786e4c5 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期四, 01 八月 2024 15:12:45 +0800
Subject: [PATCH] repair

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java |  131 ++++++++++++++++++++++++++-----------------
 1 files changed, 79 insertions(+), 52 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 336c43f..28deed1 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
@@ -36,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;
@@ -172,7 +173,7 @@
 
         StaDeviceLast deviceLast = buildDeviceLast(params, workLast, deviceList.get(0));
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
-                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+                deviceLastDao.updateByPrimaryKey(deviceLast);
 
         saveDeviceProductionLog(deviceLast);
 
@@ -217,6 +218,7 @@
         if (preRecord != null) {
             record.id = preRecord.id;
             record.inTime = preRecord.outTime;
+            record.inLineTime = preRecord.inLineTime;
             record.outLineTime = preRecord.outLineTime;//涓嬭竟鍒ゆ柇鏄惁缁撴潫浼氱敤鍒� 寰楃暀鐫�
         } else {
             record.inTime = new Date();
@@ -224,34 +226,37 @@
             assemblyPlan.setInputNumber(assemblyPlan.getInputNumber() + 1);
         }
         record.outTime = new Date();
-
-        record.planId = workLast.planId;
+        record.planId = assemblyPlan.getId();
         record.workId = Long.parseLong(params.workId);
         record.stationId = workLast.stationId;
         record.deviceNo = deviceNo;
         record.currNode = workLast.nodeId;
-
         record.updatedBy = workLast.userId;
         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;
+        Boolean isEnd = false;//鏄惁缁忓巻杩囨垨姝e湪缁忓巻缁撴潫鑺傜偣
+        if (workLast.nodeId == null) {
+            if (record.outLineTime != null) {
+                isEnd = true;
+            }
+        } else {
+            PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
+            record.nodeContent = node.content;
+            if (node.isRecord) {
+                record.deviceCycleContent = node.deviceCycleContent;
+            }
+            if (node.getIsEnd() && record.outLineTime == null) {
+                record.outLineTime = new Date();
+                assemblyPlan.setOutputNumber(assemblyPlan.getOutputNumber() + 1);
+                isEnd = true;
+            } else if (record.outLineTime != null) {
+                isEnd = true;
+            }
         }
-        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, isEnd, workLast.workType.toString());
         record.result = getResult(params.status, workLast.workType.toString());
+        assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan);
         return record;
     }
 
@@ -271,9 +276,10 @@
 
     /**
      * 鍘熺姸鎬�: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃
-     *20240717褰撳墠鐘舵��  鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
-     * @param status    鐘舵��
-     * @param isEnd 鏄惁缁忓巻杩囩粨鏉熻妭鐐�
+     * 20240717褰撳墠鐘舵��  鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
+     *
+     * @param status 鐘舵��
+     * @param isEnd  鏄惁缁忓巻杩囩粨鏉熻妭鐐�
      * @return 鐘舵��
      */
     private Integer getStatus(String status, boolean isEnd, String workType) {
@@ -290,9 +296,11 @@
         //缁翠慨
         throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
     }
+
     /**
      * 缁撴灉: 1:閫氳繃,2:娴嬭瘯閫氳繃,3:鍝佹閫氳繃,4:缁翠慨閫氳繃,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃,7:鎶ュ簾
-     * @param status    鍓嶇鍑烘潵鐨勭姸鎬�
+     *
+     * @param status 鍓嶇鍑烘潵鐨勭姸鎬�
      * @return 缁撴灉
      */
     private Integer getResult(String status, String workType) {
@@ -303,21 +311,21 @@
                 default -> throw new RuntimeException("鐘舵�侀敊璇�");
             };
             //娴嬭瘯
-        }else if (WORK_TYPE_TEST.equals(workType)) {
+        } else if (WORK_TYPE_TEST.equals(workType)) {
             return switch (status) {
-                case QrCodeConstant.MarkQualified  -> DeviceResult.TEST_PASS.getCode();
+                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)) {
+        } 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)) {
+        } else if (WORK_TYPE_REPAIR.equals(workType)) {
             return switch (status) {
                 case QrCodeConstant.MarkOk -> DeviceResult.REPAIR_PASS.getCode();
                 case QrCodeConstant.MarkWaste -> DeviceResult.WASTE.getCode();
@@ -326,6 +334,7 @@
         }
         throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
     }
+
     @Transactional
     public int repair(QueryVo vo) {
         long workId = Long.parseLong(vo.workId);
@@ -340,17 +349,21 @@
         repairInfo.repairTime = new Date();
         repairInfo.repairBy = workLast.userId;
         repairInfo.repairReason = vo.errorMsg;
-        repairInfo.fromNode = preDeviceRecord.currNode;
+        if(preDeviceRecord!=null) {
+            repairInfo.fromNode = preDeviceRecord.currNode;
+        }
         repairInfoDao.insertSelective(repairInfo);
 
         StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
-
+        deviceLast.setRepairId(repairInfo.getId());
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
-                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+                deviceLastDao.updateByPrimaryKey(deviceLast);
         saveDeviceProductionLog(deviceLast);
-        boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode);
-        if (isEndNode) {
-            saveDeviceLife(deviceLast);
+        if(preDeviceRecord.currNode != null){
+            boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode);
+            if (isEndNode) {
+                saveDeviceLife(deviceLast);
+            }
         }
         return count;
     }
@@ -364,10 +377,10 @@
         }
         StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
-                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+                deviceLastDao.updateByPrimaryKey(deviceLast);
         saveDeviceProductionLog(deviceLast);
         PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
-        if (node.isRecord) {
+        if (node != null && node.isRecord) {
             saveDeviceLife(deviceLast);
         }
         return count;
@@ -382,32 +395,42 @@
         }
         StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
-                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+                deviceLastDao.updateByPrimaryKey(deviceLast);
         saveDeviceProductionLog(deviceLast);
         PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
-        if (node.isRecord) {
+        if (node != null && node.isRecord) {
             saveDeviceLife(deviceLast);
         }
         return count;
     }
+
     //鏃犱换鍔¤鍒掍腑鐨勫叾浠� 浼爓orkId ,鎵嬪啓宸ヤ綔鍐呭 , 鏁伴噺
     @Transactional
-    public int other(QueryVo vo) {
+    public int otherWork(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);
-        }
+        //淇濆瓨宸ヤ綔璁板綍
+        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)) {
@@ -454,6 +477,7 @@
     public List<PltProductQualityInspectionItems> getQualityItems(String proId) {
         Map<String, Object> params = new HashMap<>();
         params.put("proId", proId);//item  start  count
+        params.put("disabled", "0");
         //鏌ヨ绗﹀悎鏉′欢鐨勮褰�
         return qualityItemsDao.selectSome(params);
     }
@@ -461,6 +485,7 @@
     public List<PltProductTestInspectionItems> getTestItems(String proId) {
         Map<String, Object> params = new HashMap<>();
         params.put("proId", proId);
+        params.put("disabled", "0");
         return testItemsDao.selectSome(params);
     }
 
@@ -517,7 +542,7 @@
         return fileRestVo.fileWebUrl + file.filePath;
     }
 
-    public Map<String, String> queryByDeviceNo(String deviceNo,List<PltProduct> productList) {
+    public Map<String, String> queryByDeviceNo(String deviceNo, List<PltProduct> productList) {
         Map<String, String> map = new HashMap<>();
         map.put("deviceNo", deviceNo);
         map.put("proName", "");
@@ -525,7 +550,7 @@
         map.put("proId", "");
         map.put("proCode", "");
         //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡
-        if(CollectionUtils.isEmpty(productList)){
+        if (CollectionUtils.isEmpty(productList)) {
             productList = productDao.selectAll(null);
         }
         PltProduct product = null;
@@ -538,24 +563,26 @@
             map.put("proType", product.getType());
             BigInteger proId = BigInteger.valueOf(product.getId());
             map.put("proId", proId.toString());
-            map.put("proCode",product.getCode());
+            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);
+            proCode = deviceNo.substring(3, 6);
+            lotCode = deviceNo.substring(6, 15);
         }
-        PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode,lotCode);
-        if(plan != null){
+        PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode, lotCode);
+        if (plan != null) {
             plan.setBatchNo(lotCode);
         }
         return plan;
     }
+
     public List<StaDeviceLife> queryLifeByDeviceNo(String deviceNo) {
         return deviceLifeDao.selectByDeviceNo(deviceNo);
     }

--
Gitblit v1.8.0