From d3bb6745eb1da8f8c244f9393209e048395867f6 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期三, 10 七月 2024 17:14:00 +0800
Subject: [PATCH] add a inputtime and outputtime

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java |  188 ++++++++++++++++++++++++++---------------------
 1 files changed, 104 insertions(+), 84 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 e75269d..4f9fdf4 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
@@ -2,25 +2,22 @@
 
 import com.alibaba.excel.util.StringUtils;
 import com.dy.pmsGlobal.daoBa.BaUserMapper;
-import com.dy.pmsGlobal.daoOth.OthFileMapper;
+import com.dy.pmsGlobal.daoPlt.PltProductMapper;
 import com.dy.pmsGlobal.daoPlt.PltStationMapper;
 import com.dy.pmsGlobal.daoPr.PrAssemblyPlanMapper;
+import com.dy.pmsGlobal.daoPr.PrProductionNodeMapper;
 import com.dy.pmsGlobal.daoSta.StaAssemblyWorkHistoryMapper;
 import com.dy.pmsGlobal.daoSta.StaAssemblyWorkLastMapper;
-import com.dy.pmsGlobal.dyFile.FileOperate;
-import com.dy.pmsGlobal.dyFile.FileRestVo;
 import com.dy.pmsGlobal.pojoBa.BaUser;
-import com.dy.pmsGlobal.pojoOth.OthFile;
+import com.dy.pmsGlobal.pojoPlt.PltProduct;
 import com.dy.pmsGlobal.pojoPlt.PltStation;
 import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan;
 import com.dy.pmsGlobal.pojoPr.PrProductionNode;
-import com.dy.pmsGlobal.pojoPr.PrWorkingInstruction;
 import com.dy.pmsGlobal.pojoSta.StaAssemblyWorkHistory;
 import com.dy.pmsGlobal.pojoSta.StaAssemblyWorkLast;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -44,10 +41,8 @@
     private PltStationMapper pltStationDao;
     private StaAssemblyWorkLastMapper assemblyWorkLastDao;
     private StaAssemblyWorkHistoryMapper assemblyWorkHistoryDao;
-    private FileOperate fileOperate;
-    private OthFileMapper othFileMapper;
-    @Value("${dy.webFile.fmUrl}")
-    private String fmUrl;
+    private PrProductionNodeMapper nodeDao;
+    private PltProductMapper productDao;
 
     @Autowired
     public void setAssemblyDao(PrAssemblyPlanMapper assemblyDao) {
@@ -75,14 +70,15 @@
     }
 
     @Autowired
-    public void setFileOperate(FileOperate fileOperate) {
-        this.fileOperate = fileOperate;
+    public void setNodeDao(PrProductionNodeMapper nodeDao) {
+        this.nodeDao = nodeDao;
     }
 
     @Autowired
-    public void setOthFileMapper(OthFileMapper othFileMapper) {
-        this.othFileMapper = othFileMapper;
+    public void setPltProductDao(PltProductMapper productDao) {
+        this.productDao = productDao;
     }
+
 
     public BaUser getUserInfo(String id) {
         Long userId = null;
@@ -123,29 +119,6 @@
             throw new RuntimeException("宸ョ珯(" + stationInfo.getName() + ")缂栫爜:" + stationId + "鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤宸ョ珯");
         }
         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);
-        } else {
-            result.setStationId(stationInfo.getId());
-            result.setStationName(stationInfo.getName());
-            result.setLineId(stationInfo.getLineId());
-            result.setLineName(stationInfo.getLineName());
-        }
-        return result;
     }
 
     public StaAssemblyWorkLast checkUserAndStationUsed(QueryVo vo) {
@@ -196,13 +169,88 @@
         return result;
     }
 
+    public StaAssemblyWorkLast getWorkLast(String workId) {
+        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());
+        //鏍¢獙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);
+            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 = "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 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){
+        if (assyPlan == null) {
             throw new RuntimeException("缁勮浠诲姟宸茬粡鍦ㄧ郴缁熶腑鍒犻櫎璇锋鏌�,鍒锋柊骞堕噸鏂伴�夋嫨浠诲姟");
         }
         boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
@@ -210,7 +258,8 @@
         if (!hasNodeId) {
             throw new RuntimeException("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
         }
-        //鎬庝箞灏嗗彧鍖呭惈杩欎釜鑺傜偣鐨勪俊鎭叏閮ㄥ洖浼犲憿
+
+        //鏁版嵁閫愪釜灏佽杩斿洖
         vo.setLineId(checkResult.getLineId());
         StaAssemblyWorkLast staLast = new StaAssemblyWorkLast();
         BeanUtils.copyProperties(vo, staLast);
@@ -218,7 +267,7 @@
         staLast.setStationId(checkResult.getStationId());
         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);
@@ -227,8 +276,8 @@
         } else {
             //淇濆瓨涓�鏉istory?
             BeanUtils.copyProperties(checkResult, staLast);
-            staLast.setPlanId(vo.getPlanId());
-            staLast.setProcessId(vo.getProcessId());
+            staLast.setPlanId(assyPlan.getId());
+            staLast.setProcessId(assyPlan.getProcess().getId());
             staLast.setNodeId(vo.getNodeId());
             staLast.setStatus(STATUS_NORMAL);
             staLast.setStartTime(new Date());
@@ -238,10 +287,20 @@
             throw new RuntimeException("鏁版嵁搴撳瓨鍌ㄥけ璐�");
         }
         StaAssemblyWorkLast result = assemblyWorkLastDao.selectByPrimaryKey(staLast.getId());
-        List<PrProductionNode> nodeInfo =assyPlan.getProcess().getNodes().stream()
+        List<PrProductionNode> nodeInfo = assyPlan.getProcess().getNodes().stream()
                 .filter(node -> node.id.equals(vo.getNodeId())).collect(Collectors.toList());
-        assyPlan.getProcess().setNodes(nodeInfo);
-        result.setPlan(assyPlan);
+        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 = "110" + product.getCode() + assyPlan.getBatchNo();
+        result.setDevicePrefix(devicePrefix);
         return result;
     }
 
@@ -275,42 +334,6 @@
             });
         });*/
         return planList;
-    }
-
-    private void addUrl(PrWorkingInstruction ins) {
-        if (ins == null || ins.fileId == null) {
-            return;
-        }
-        OthFile file = othFileMapper.selectByPrimaryKey(ins.fileId);
-        if (file == null) {
-            return;
-        }
-        FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
-        ins.webUrl = fileRestVo.fileSysRestUrl + fileRestVo.fileWebDownloadPath + ins.fileId;
-        ins.orgName = file.orgName;
-        ins.extName = file.extName;
-    }
-
-    //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) {
@@ -375,7 +398,4 @@
         List<BaUser> assistantList = baUserDao.selectByAssistants(workLast.getAssistants());
         return assistantList;
     }
-    //鏍规嵁鑺傜偣鐨勬煡鍑鸿妭鐐逛綔涓氭寚瀵间功
-
-    // 鏍规嵁浜у搧鏌ュ嚭浜у搧鏂囦欢 涓昏鎶�鏈弬鏁�
 }
\ No newline at end of file

--
Gitblit v1.8.0