From 72219adeceb06a060978e876880750f804df5772 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期一, 22 七月 2024 16:24:05 +0800
Subject: [PATCH] login bug

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java |  233 +++++++++++++++++++++++++++++++++-------------------------
 1 files changed, 133 insertions(+), 100 deletions(-)

diff --git a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java
index feabcb0..bf136dc 100644
--- a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java
+++ b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java
@@ -15,6 +15,7 @@
 import com.dy.pmsGlobal.pojoPr.PrProductionNode;
 import com.dy.pmsGlobal.pojoSta.StaAssemblyWorkHistory;
 import com.dy.pmsGlobal.pojoSta.StaAssemblyWorkLast;
+import com.dy.pmsGlobal.util.QrCodeConstant;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -32,6 +33,11 @@
     private static final int STATUS_WORK_LAST_LOGOUT = 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 static final String USER_PREFIX = "101";
     private static final String STATION_PREFIX = "103";
@@ -121,52 +127,6 @@
         return stationInfo;
     }
 
-    public StaAssemblyWorkLast checkStationUsed(String id) {
-        StaAssemblyWorkLast result = new StaAssemblyWorkLast();
-        PltStation stationInfo = null;
-        if (StringUtils.isBlank(id)) {
-            throw new RuntimeException("宸ョ珯缂栫爜涓嶈兘涓虹┖,璇锋鏌�");
-        }
-        stationInfo = getStationInfo(id);
-        //妫�鏌ヨ〃涓璼tationId鏄惁宸茬粡瀛樺湪
-        StaAssemblyWorkLast param = new StaAssemblyWorkLast();
-        param.setStationId(stationInfo.getId());
-        param.setStatus(STATUS_NORMAL);
-        List<StaAssemblyWorkLast> workLasts = assemblyWorkLastDao.selectList(param);
-        if (workLasts.size() > 0) {
-            BeanUtils.copyProperties(workLasts.get(0), result);
-            //鏍¢獙planId processId nodeId
-            PrAssemblyPlan assyPlan = assemblyDao.selectByPrimaryKey(workLasts.get(0).getPlanId());
-            if (assyPlan == null) {
-                //鐩存帴鍒犻櫎璁板綍
-                logout(workLasts.get(0).getId().toString());
-            }
-            boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
-                    .anyMatch(node -> node.id.equals(workLasts.get(0).getNodeId()));
-            if (!hasNodeId) {
-                //鐩存帴鍒犻櫎璁板綍
-                logout(workLasts.get(0).getId().toString());
-            } else {
-                result.setPlanName(assyPlan.getName());
-                result.setProcessName(assyPlan.getProcessName());
-                result.setNodeName(assyPlan.getProcess().getNodes().get(0).getContent());
-                //鎵惧埌瀵瑰簲鐨勪骇鍝佷俊鎭�
-                PltProduct  product = productDao.selectByPrimaryKey(assyPlan.getProId());
-                if (product == null) {
-                    throw new RuntimeException("浜у搧淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇风櫥褰曠鐞嗙郴缁熸煡鐪嬩换鍔″叧鑱斾骇鍝両D涓�:" + assyPlan.getProId());
-                }
-                result.setProName(product.getName());
-                String devicePrefix = "110" + product.getCode() + assyPlan.getBatchNo();
-                result.setDevicePrefix(devicePrefix);
-            }
-        }
-        result.setStationId(stationInfo.getId());
-        result.setStationName(stationInfo.getName());
-        result.setLineId(stationInfo.getLineId());
-        result.setLineName(stationInfo.getLineName());
-        return result;
-    }
-
     public StaAssemblyWorkLast checkUserAndStationUsed(QueryVo vo) {
         StaAssemblyWorkLast result = new StaAssemblyWorkLast();
         PltStation stationInfo = null;
@@ -201,11 +161,16 @@
         if (workLasts.size() > 0) {
             List<StaAssemblyWorkLast> userStationList = workLasts.stream().filter(item -> userId == item.getUserId()).collect(Collectors.toList());
             if (userStationList.size() == 0) {
-                throw new RuntimeException("鍛樺伐(" + workLasts.get(0).getUserName() + ")缂栫爜:" + workLasts.get(0).getUserId() + "宸茬粡缁戝畾璇ュ伐绔�(" + workLasts.get(0).getStationName() + ")缂栫爜:" + workLasts.get(0).getStationId() + ".璇峰厛璁╁叾瑙g粦");
+                //鍒犻櫎宸ョ珯鐧诲綍淇℃伅
+                for (int i = 0; i < workLasts.size(); i++) {
+                    logout(workLasts.get(i).getId().toString());
+                }
+                //throw new RuntimeException("鍛樺伐(" +userInfo.getName() + ")缂栫爜:" + workLasts.get(0).getUserId() + "宸茬粡缁戝畾璇ュ伐绔�(" + stationInfo.getName() + ")缂栫爜:" + workLasts.get(0).getStationId() + ".璇峰厛璁╁叾瑙g粦");
             } else {
                 BeanUtils.copyProperties(userStationList.get(0), result);
             }
-        } else {
+        }
+        if (result.getId() == null) {
             result.setUserId(userInfo.getId());
             result.setUserName(userInfo.getName());
             result.setStationId(stationInfo.getId());
@@ -215,30 +180,115 @@
         return result;
     }
 
+    public StaAssemblyWorkLast getWorkLast(String workId) {
+        if (StringUtils.isBlank(workId)) {
+            throw new RuntimeException("鐧诲綍ID涓虹┖,璇疯仈绯荤鐞嗗憳鏌ョ湅骞惰В鍐抽棶棰�.");
+        }
+        StaAssemblyWorkLast result = assemblyWorkLastDao.selectByPrimaryKey(Long.parseLong(workId));
+        if (result == null) {
+            throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�");
+            //return null;
+        }
+        BaUser userInfo = getUserInfo(result.getUserId().toString());
+        PltStation stationInfo = getStationInfo(result.getStationId().toString());
+        //濡傛灉鏄棤浠诲姟璁″垝 濡傜淮淇畐ork_type 娌℃湁 planId processId nodeId
+        if (result.getPlanId() != null) {
+            //鏍¢獙planId processId nodeId
+            PrAssemblyPlan assyPlan = assemblyDao.selectByPrimaryKey(result.getPlanId());
+            boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
+                    .anyMatch(node -> node.id.equals(result.getNodeId()));
+            if (userInfo == null || stationInfo == null || assyPlan == null || (!hasNodeId)) {
+                //鐩存帴鍒犻櫎璁板綍
+                logout(result.getId().toString());
+                result.setId(null);
+                result.setStatus(STATUS_WORK_LAST_LOGOUT);
+                if (userInfo == null) {
+                    result.setUserId(null);
+                    result.setUserName("");
+                }
+                if (stationInfo == null) {
+                    result.setStationId(null);
+                    result.setStationName("");
+                }
+                if (assyPlan == null) {
+                    result.setPlanId(null);
+                    result.setPlanName("");
+                }
+                if (!hasNodeId) {
+                    result.setNodeId(null);
+                    result.setNodeName("");
+                }
+                return result;
+            } else {
+                result.setPlanName(assyPlan.getName());
+                result.setProcessName(assyPlan.getProcessName());
+                result.setNodeName(assyPlan.getProcess().getNodes().get(0).getContent());
+                //鎵惧埌瀵瑰簲鐨勪骇鍝佷俊鎭�
+                PltProduct product = productDao.selectByPrimaryKey(assyPlan.getProId());
+                if (product != null) {
+                    result.setProId(product.getId());
+                    result.setProName(product.getName());
+                    String devicePrefix = QrCodeConstant.TypeProduct + product.getCode() + assyPlan.getBatchNo();
+                    result.setDevicePrefix(devicePrefix);
+                }
+            }
+        }
+        result.setStationId(stationInfo.getId());
+        result.setStationName(stationInfo.getName());
+        result.setLineId(stationInfo.getLineId());
+        result.setLineName(stationInfo.getLineName());
+        return result;
+    }
+
+    public StaAssemblyWorkLast checkStationUsed(String stationId) {
+        StaAssemblyWorkLast result = new StaAssemblyWorkLast();
+        PltStation stationInfo = null;
+        if (StringUtils.isBlank(stationId)) {
+            throw new RuntimeException("宸ョ珯缂栫爜涓嶈兘涓虹┖,璇锋鏌�");
+        }
+        stationInfo = getStationInfo(stationId);
+        //妫�鏌ヨ〃涓璼tationId鏄惁宸茬粡瀛樺湪
+        StaAssemblyWorkLast param = new StaAssemblyWorkLast();
+        param.setStationId(stationInfo.getId());
+        param.setStatus(STATUS_NORMAL);
+        List<StaAssemblyWorkLast> workLasts = assemblyWorkLastDao.selectList(param);
+        if (workLasts.size() > 0) {
+            result = getWorkLast(workLasts.get(0).getId().toString());
+        }
+        result.setStationId(stationInfo.getId());
+        result.setStationName(stationInfo.getName());
+        result.setLineId(stationInfo.getLineId());
+        result.setLineName(stationInfo.getLineName());
+        return result;
+    }
+
     @Transactional
     public StaAssemblyWorkLast save(QueryVo vo) {
         //鍏坈heck
         StaAssemblyWorkLast checkResult = checkUserAndStationUsed(vo);
-        //鏍¢獙planId processId nodeId
-        PrAssemblyPlan assyPlan = assemblyDao.selectByPrimaryKey(vo.getPlanId());
-        if (assyPlan == null) {
-            throw new RuntimeException("缁勮浠诲姟宸茬粡鍦ㄧ郴缁熶腑鍒犻櫎璇锋鏌�,鍒锋柊骞堕噸鏂伴�夋嫨浠诲姟");
-        }
-        boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
-                .anyMatch(node -> node.id.equals(vo.getNodeId()));
-        if (!hasNodeId) {
-            throw new RuntimeException("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
-        }
-
-        //鎬庝箞灏嗗彧鍖呭惈杩欎釜鑺傜偣鐨勪俊鎭叏閮ㄥ洖浼犲憿
+        //鏁版嵁閫愪釜灏佽杩斿洖
         vo.setLineId(checkResult.getLineId());
         StaAssemblyWorkLast staLast = new StaAssemblyWorkLast();
         BeanUtils.copyProperties(vo, staLast);
         staLast.setUserId(checkResult.getUserId());
         staLast.setStationId(checkResult.getStationId());
+        //鏍¢獙planId processId nodeId
+        PrAssemblyPlan assyPlan = new PrAssemblyPlan();
+        if (vo.getPlanId() != null) {
+            assyPlan = assemblyDao.selectByPrimaryKey(vo.getPlanId());
+            if (assyPlan == null) {
+                throw new RuntimeException("缁勮浠诲姟宸茬粡鍦ㄧ郴缁熶腑鍒犻櫎璇锋鏌�,鍒锋柊骞堕噸鏂伴�夋嫨浠诲姟");
+            }
+            boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
+                    .anyMatch(node -> node.id.equals(vo.getNodeId()));
+            if (!hasNodeId) {
+                throw new RuntimeException("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
+            }
+        }
+
         int count = 0;
         if (checkResult.getId() == null) {
-            BeanUtils.copyProperties(vo, staLast);
+            BeanUtils.copyProperties(vo, staLast);//vo鎷疯礉鍒皊taLast
             staLast.setUserId(checkResult.getUserId());
             staLast.setStationId(checkResult.getStationId());
             staLast.setStatus(STATUS_NORMAL);
@@ -247,9 +297,12 @@
         } else {
             //淇濆瓨涓�鏉istory?
             BeanUtils.copyProperties(checkResult, staLast);
-            staLast.setPlanId(assyPlan.getId());
-            staLast.setProcessId(assyPlan.getProcess().getId());
-            staLast.setNodeId(vo.getNodeId());
+            if (vo.getPlanId() != null) {
+                staLast.setPlanId(assyPlan.getId());
+                staLast.setProcessId(assyPlan.getProcess().getId());
+                staLast.setNodeId(vo.getNodeId());
+            }
+            staLast.setWorkType(vo.getWorkType());
             staLast.setStatus(STATUS_NORMAL);
             staLast.setStartTime(new Date());
             count = assemblyWorkLastDao.updateByPrimaryKeySelective(staLast);
@@ -258,19 +311,22 @@
             throw new RuntimeException("鏁版嵁搴撳瓨鍌ㄥけ璐�");
         }
         StaAssemblyWorkLast result = assemblyWorkLastDao.selectByPrimaryKey(staLast.getId());
-        List<PrProductionNode> nodeInfo = assyPlan.getProcess().getNodes().stream()
-                .filter(node -> node.id.equals(vo.getNodeId())).collect(Collectors.toList());
-        result.setPlanName(assyPlan.getName());
-        result.setProcessName(assyPlan.getProcessName());
-        result.setNodeName(assyPlan.getProcess().getNodes().get(0).getContent());
-        //鎵惧埌瀵瑰簲鐨勪骇鍝佷俊鎭�
-        PltProduct  product = productDao.selectByPrimaryKey(assyPlan.getProId());
-        if (product == null) {
-            throw new RuntimeException("浜у搧淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇风櫥褰曠鐞嗙郴缁熸煡鐪嬩换鍔″叧鑱斾骇鍝両D涓�:" + assyPlan.getProId());
+        if (assyPlan != null) {
+            List<PrProductionNode> nodeInfo = assyPlan.getProcess().getNodes().stream()
+                    .filter(node -> node.id.equals(vo.getNodeId())).collect(Collectors.toList());
+            result.setPlanName(assyPlan.getName());
+            result.setProcessName(assyPlan.getProcessName());
+            result.setNodeName(assyPlan.getProcess().getNodes().get(0).getContent());
+            //鎵惧埌瀵瑰簲鐨勪骇鍝佷俊鎭�
+            PltProduct product = productDao.selectByPrimaryKey(assyPlan.getProId());
+            if (product == null) {
+                throw new RuntimeException("浜у搧淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇风櫥褰曠鐞嗙郴缁熸煡鐪嬩换鍔″叧鑱斾骇鍝両D涓�:" + assyPlan.getProId());
+            }
+            result.setProId(product.getId());
+            result.setProName(product.getName());
+            String devicePrefix = QrCodeConstant.TypeProduct + product.getCode() + assyPlan.getBatchNo();
+            result.setDevicePrefix(devicePrefix);
         }
-        result.setProName(product.getName());
-        String devicePrefix = "110" + product.getCode() + assyPlan.getBatchNo();
-        result.setDevicePrefix(devicePrefix);
         return result;
     }
 
@@ -287,6 +343,7 @@
         // 淇濆瓨history
         StaAssemblyWorkHistory history = new StaAssemblyWorkHistory();
         BeanUtils.copyProperties(workLast, history);
+        history.setWorkId(workLast.getId());
         //history.setId(null);
         int count = assemblyWorkHistoryDao.insertSelective(history);
         //鍒犻櫎last
@@ -304,28 +361,6 @@
             });
         });*/
         return planList;
-    }
-
-    //workId   assistants 浼犵殑鏄崟涓殑userId  蹇呬紶鍙傛暟
-    public List<BaUser> updateAssistant(QueryVo vo) {
-        //鎵惧埌workId
-        StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(vo.getWorkId());
-        if (workLast == null) {
-            throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
-        }
-        //濡傛灉assistants 鏈�101 鍒欏垹鎺�
-        StringBuilder sb = new StringBuilder();
-        String[] assistantArr = vo.getAssistants().split(",");
-        for (String item : assistantArr) {
-            if (item.startsWith(USER_PREFIX)) {
-                sb.append(item.substring(3)).append(",");
-            } else {
-                sb.append(item).append(",");
-            }
-        }
-        String assistantStr = assistantArr.length > 0 ? sb.deleteCharAt(sb.length() - 1).toString() : "";
-        List<BaUser> userInfo = baUserDao.selectByAssistants(vo.getAssistants());
-        return userInfo;
     }
 
     public int addAssistant(String workId, String assistant) {
@@ -390,6 +425,4 @@
         List<BaUser> assistantList = baUserDao.selectByAssistants(workLast.getAssistants());
         return assistantList;
     }
-
-
 }
\ No newline at end of file

--
Gitblit v1.8.0