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 |  298 ++++++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 232 insertions(+), 66 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 cf7956c..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
@@ -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;
@@ -24,7 +25,9 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.math.BigInteger;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -33,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;
@@ -53,46 +57,57 @@
     private OthFileMapper othFileMapper;
     @Value("${dy.webFile.fmUrl}")
     private String fmUrl;
+
     @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;
@@ -117,6 +132,7 @@
     public void setOthFileMapper(OthFileMapper othFileMapper) {
         this.othFileMapper = othFileMapper;
     }
+
     @Autowired
     public void setDeviceLifeLastDao(StaDeviceLifeLastMapper deviceLifeLastDao) {
         this.deviceLifeLastDao = deviceLifeLastDao;
@@ -134,26 +150,30 @@
         Set<String> deviceSet = new HashSet<>(Arrays.asList(params.deviceNo));
         // 鍒嗙被璁惧鍙峰拰鐗╂枡鍙�
         List<String> deviceList = new ArrayList<>();
-        List<String> materialList = new ArrayList<>();
+        List<Map<String, String>> materialList = new ArrayList<>();
         List<PltProduct> productList = productDao.selectAll(null);
-        deviceSet.forEach(device -> {
-            if (device.contains(plan.batchNo)) {
-                deviceList.add(device);
-            } else if(isOurProduct(device,productList)){
-                materialList.add(device);
+        deviceSet.forEach(deviceNo -> {
+            if (deviceNo.contains(plan.batchNo)) {
+                deviceList.add(deviceNo);
+            } else {
+                //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡,濡傛灉鏄�,鍒欐坊鍔犵墿鏂欏埌ex琛ㄤ腑
+                Map<String, String> result = queryByDeviceNo(deviceNo, productList);
+                if (StringUtils.isNotBlank(result.get("proName"))) {
+                    materialList.add(result);
+                }
             }
         });
 
         if (deviceList.isEmpty()) {
-            throw new RuntimeException("璁惧鍙�(" + params.deviceNo + ")鍧囦笉灞炰簬褰撳墠浠诲姟璁″垝");
+            throw new RuntimeException("璁惧鍙�(" + Arrays.toString(params.deviceNo) + ")鍧囦笉灞炰簬褰撳墠浠诲姟璁″垝");
         }
         if (deviceList.size() > 1) {
-            throw new RuntimeException("璁惧鍙锋湁涓斿彧鑳芥湁涓�涓睘浜庡綋鍓嶄换鍔¤鍒�");
+            throw new RuntimeException("鍦ㄤ骇璁惧(" + deviceList.stream().collect(Collectors.joining(",")) + ")鏈変笖鍙兘鏈変竴涓睘浜庡綋鍓嶄换鍔¤鍒�");
         }
 
         StaDeviceLast deviceLast = buildDeviceLast(params, workLast, deviceList.get(0));
         int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
-                deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+                deviceLastDao.updateByPrimaryKey(deviceLast);
 
         saveDeviceProductionLog(deviceLast);
 
@@ -162,7 +182,7 @@
             saveDeviceLife(deviceLast);
         }
         if (CollectionUtils.isNotEmpty(materialList)) {
-            saveSnEx(workLast, deviceList, materialList, plan);
+            saveSnEx(workLast, deviceList, materialList);
         }
         return count;
     }
@@ -184,82 +204,138 @@
         BeanUtils.copyProperties(deviceLast, lastLife);
         lastLife.setId(null);
         int count = deviceLifeLastDao.updateByDeviceNo(lastLife);
-        if (count == 0){
+        if (count == 0) {
             deviceLifeLastDao.insertSelective(lastLife);
         }
     }
 
-    private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast,String deviceNo) {
+    private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast, String deviceNo) {
         //缁勮鏁版嵁
         StaDeviceLast record = new StaDeviceLast();
-
+        //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.inLineTime = preRecord.inLineTime;
+            record.outLineTime = preRecord.outLineTime;//涓嬭竟鍒ゆ柇鏄惁缁撴潫浼氱敤鍒� 寰楃暀鐫�
+        } else {
+            record.inTime = new Date();
+            record.inLineTime = new Date();
+            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;
 
-        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;
+            }
         }
-        record.status = getStatus(params.status, node.isEnd,workLast.workType.toString());
+        record.status = getStatus(params.status, isEnd, workLast.workType.toString());
+        record.result = getResult(params.status, workLast.workType.toString());
+        assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan);
         return record;
     }
 
-    private void saveSnEx(StaAssemblyWorkLast workLast, List<String> deviceList, List<String> materialList, PrAssemblyPlan plan) {
-        for (String material : materialList) {
+    private void saveSnEx(StaAssemblyWorkLast workLast, List<String> deviceList, List<Map<String, String>> materialList) {
+        for (Map<String, String> material : materialList) {
             StaWipSnEx snEx = new StaWipSnEx();
             snEx.deviceNo = deviceList.get(0);
-            snEx.productId = plan.process.proId;
-            snEx.productNo = material;
+            snEx.productNo = material.get("deviceNo");
+            snEx.productName = material.get("proName");
+            snEx.productId = Long.parseLong(material.get("proId"));
             snEx.createTime = workLast.startTime;
             snEx.createBy = workLast.userId;
-            snEx.productName = plan.proName;
+
             wipSnExDao.insertSelective(snEx);
         }
     }
 
     /**
-     * 鐘舵��: 1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
+     * 鍘熺姸鎬�: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃
+     * 20240717褰撳墠鐘舵��  鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
      *
-     * @param status    鐘舵��
-     * @param isEndNode 鏄惁缁撴潫鑺傜偣
+     * @param status 鐘舵��
+     * @param isEnd  鏄惁缁忓巻杩囩粨鏉熻妭鐐�
      * @return 鐘舵��
      */
-    private int 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 -> 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);
@@ -273,59 +349,115 @@
         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;
     }
 
+    @Transactional
     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[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 != null && node.isRecord) {
+            saveDeviceLife(deviceLast);
+        }
         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.updateByPrimaryKey(deviceLast);
+        saveDeviceProductionLog(deviceLast);
+        PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
+        if (node != null && 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)){
+        if (com.alibaba.excel.util.StringUtils.isBlank(nodeId)) {
             throw new RuntimeException("鑺傜偣ID涓嶈兘涓虹┖");
         }
         PrProductionNode node = nodeDao.selectByPrimaryKey(Long.parseLong(nodeId));
-        if(node == null){
+        if (node == null) {
             throw new RuntimeException("鑺傜偣ID涓嶅瓨鍦�,璇锋鏌�");
         }
-        if(node.instruction != null){
+        if (node.instruction != null) {
             addUrl(node.instruction);
         }
-        return  node;
+        return node;
     }
+
     //涓昏鎶�鏈弬鏁�    淇╀釜鏂规硶鍚� platform-->product-->productSv
     public List<PltProductParams> getParamsByProId(String proId) {
-        if(StringUtils.isBlank(proId)){
+        if (StringUtils.isBlank(proId)) {
             throw new RuntimeException("浜у搧ID涓嶈兘涓虹┖");
         }
         List<PltProductParams> proParams = paramsDao.selectParams(Long.parseLong(proId));
-        return  proParams;
+        return proParams;
     }
+
     // 鏍规嵁浜у搧鏌ュ嚭浜у搧鏂囦欢
     public List<PltProductFile> getFileByProId(String proId) {
-        if(StringUtils.isBlank(proId)){
+        if (StringUtils.isBlank(proId)) {
             throw new RuntimeException("浜у搧ID涓嶈兘涓虹┖");
         }
         List<PltProductFile> proFiles = productFileDao.selectDocuments(Long.parseLong(proId));
@@ -339,12 +471,13 @@
             doc.orgName = file.orgName;
             doc.extName = file.extName;
         });
-        return  proFiles;
+        return proFiles;
     }
 
     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);
     }
@@ -352,19 +485,21 @@
     public List<PltProductTestInspectionItems> getTestItems(String proId) {
         Map<String, Object> params = new HashMap<>();
         params.put("proId", proId);
+        params.put("disabled", "0");
         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())){
+    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;
     }
+
     private void addUrl(PrWorkingInstruction ins) {
         if (ins == null || ins.fileId == null) {
             return;
@@ -378,6 +513,7 @@
         ins.orgName = file.orgName;
         ins.extName = file.extName;
     }
+
     private PltProduct addWebUrl(PltProduct pro) {
         if (pro != null) {
             if (pro.image != null) {
@@ -399,24 +535,52 @@
         }
         return pro;
     }
+
     private String getFilePathWithWebUrl(Long fileId) {
         OthFile file = othFileMapper.selectByPrimaryKey(fileId);
         FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
         return fileRestVo.fileWebUrl + file.filePath;
     }
 
-    public Map<String,String> queryByDeviceNo(String deviceNo) {
-        Map<String,String> map = new HashMap<>();
+    public Map<String, String> queryByDeviceNo(String deviceNo, List<PltProduct> productList) {
+        Map<String, String> map = new HashMap<>();
         map.put("deviceNo", deviceNo);
-        map.put("proName", "-");
-        map.put("proType", "-");
-
-        PltProduct product = productDao.selectByCode(deviceNo.substring(3,6));
-        if(product != null){
+        map.put("proName", "");
+        map.put("proType", "");
+        map.put("proId", "");
+        map.put("proCode", "");
+        //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡
+        if (CollectionUtils.isEmpty(productList)) {
+            productList = productDao.selectAll(null);
+        }
+        PltProduct product = null;
+        if (StringUtils.isNotEmpty(deviceNo) && deviceNo.length() == 22) {
+            product = productList.stream().filter(p -> deviceNo.startsWith(QrCodeConstant.TypeProduct + p.getCode())).findFirst().orElse(null);
+        }
+        if (product != null) {
+            map.put("deviceNo", deviceNo);
             map.put("proName", product.getName());
             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) {
@@ -426,4 +590,6 @@
     public List<StaDeviceProductionLog> queryLogByDeviceNo(String devoiceNo) {
         return deviceProductionLogDao.selectByDeviceNo(devoiceNo);
     }
+
+
 }

--
Gitblit v1.8.0