From 2db191d2c36c490f27a9e985005ef8cf4df261ee Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期一, 15 七月 2024 10:17:26 +0800
Subject: [PATCH] solve some bug

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java |  340 ++++++++++++++++++++++++++++++++------------------------
 1 files changed, 192 insertions(+), 148 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 dee4203..6bc3abd 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
@@ -1,33 +1,28 @@
 package com.dy.pmsStation.workOrder;
 
 import com.alibaba.excel.util.StringUtils;
-import com.dy.common.webUtil.BaseResponseUtils;
 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;
 
 import java.util.Date;
 import java.util.List;
-import java.util.concurrent.atomic.AtomicLong;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -46,124 +41,109 @@
     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) {
         this.assemblyDao = assemblyDao;
     }
+
     @Autowired
-    private void setBaUserDao(BaUserMapper baUserDao){
+    private void setBaUserDao(BaUserMapper baUserDao) {
         this.baUserDao = baUserDao;
     }
+
     @Autowired
-    private void setPltStationDao(PltStationMapper pltStationDao){
+    private void setPltStationDao(PltStationMapper pltStationDao) {
         this.pltStationDao = pltStationDao;
     }
+
     @Autowired
-    private void setStaAssemblyWorkHistoryDao(StaAssemblyWorkHistoryMapper assemblyWorkHistoryDao){
+    private void setStaAssemblyWorkHistoryDao(StaAssemblyWorkHistoryMapper assemblyWorkHistoryDao) {
         this.assemblyWorkHistoryDao = assemblyWorkHistoryDao;
     }
+
     @Autowired
-    private void setStaAssemblyWorkLastDao(StaAssemblyWorkLastMapper assemblyWorkLastDao){
+    private void setStaAssemblyWorkLastDao(StaAssemblyWorkLastMapper assemblyWorkLastDao) {
         this.assemblyWorkLastDao = assemblyWorkLastDao;
     }
+
     @Autowired
-    public void setFileOperate(FileOperate fileOperate){
-        this.fileOperate = fileOperate;
-    }
-    @Autowired
-    public void setOthFileMapper(OthFileMapper othFileMapper){
-        this.othFileMapper = othFileMapper;
+    public void setNodeDao(PrProductionNodeMapper nodeDao) {
+        this.nodeDao = nodeDao;
     }
 
-    public BaUser getUserInfo(String id){
+    @Autowired
+    public void setPltProductDao(PltProductMapper productDao) {
+        this.productDao = productDao;
+    }
+
+
+    public BaUser getUserInfo(String id) {
         Long userId = null;
-        if(StringUtils.isBlank(id)){
+        if (StringUtils.isBlank(id)) {
             throw new RuntimeException("鍛樺伐缂栫爜涓嶈兘涓虹┖");
         }
         //鐢ㄦ埛101
-        if(id.startsWith(USER_PREFIX)){
+        if (id.startsWith(USER_PREFIX)) {
             userId = Long.parseLong(id.toString().substring(3));
-        }else{
+        } else {
             userId = Long.parseLong(id.toString());
         }
         BaUser userInfo = baUserDao.selectByPrimaryKey(userId);
-        if(userInfo == null){
-            throw new RuntimeException("鍛樺伐缂栫爜:"+ userId +"涓嶅湪绯荤粺涓�,璇峰厛缁存姢鍛樺伐淇℃伅");
-        }else if(userInfo.getDisabled()){
-            throw new RuntimeException("鍛樺伐("+userInfo.getName()+")缂栫爜:"+ userId +"鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤鍛樺伐");
+        if (userInfo == null) {
+            throw new RuntimeException("鍛樺伐缂栫爜:" + userId + "涓嶅湪绯荤粺涓�,璇峰厛缁存姢鍛樺伐淇℃伅");
+        } else if (userInfo.getDisabled()) {
+            throw new RuntimeException("鍛樺伐(" + userInfo.getName() + ")缂栫爜:" + userId + "鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤鍛樺伐");
         }
         return userInfo;
     }
-    public PltStation getStationInfo(String id){
+
+    public PltStation getStationInfo(String id) {
         //浠呮鏌ュ伐绔欎俊鎭互鍙婂伐绔欏崰鐢ㄦ儏鍐�
         Long stationId = null;
-        if(StringUtils.isBlank(id)){
+        if (StringUtils.isBlank(id)) {
             throw new RuntimeException("宸ョ珯缂栫爜涓嶈兘涓虹┖");
         }
         //宸ョ珯103
-        if(id.startsWith(STATION_PREFIX)){
+        if (id.startsWith(STATION_PREFIX)) {
             stationId = Long.parseLong(id.toString().substring(3));
-        }else{
+        } else {
             stationId = Long.parseLong(id.toString());
         }
         PltStation stationInfo = pltStationDao.selectByPrimaryKey(stationId);
-        if(stationInfo == null){
-            throw new RuntimeException("宸ョ珯缂栫爜:"+ stationId +"涓嶅湪绯荤粺涓�,璇峰厛缁存姢宸ョ珯淇℃伅");
-        }else if(stationInfo.getDisabled()){
-            throw new RuntimeException("宸ョ珯("+stationInfo.getName()+")缂栫爜:"+ stationId +"鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤宸ョ珯");
+        if (stationInfo == null) {
+            throw new RuntimeException("宸ョ珯缂栫爜:" + stationId + "涓嶅湪绯荤粺涓�,璇峰厛缁存姢宸ョ珯淇℃伅");
+        } else if (stationInfo.getDisabled()) {
+            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){
+    public StaAssemblyWorkLast checkUserAndStationUsed(QueryVo vo) {
         StaAssemblyWorkLast result = new StaAssemblyWorkLast();
         PltStation stationInfo = null;
         BaUser userInfo = null;
-        if(StringUtils.isBlank(vo.getStationId()) || StringUtils.isBlank(vo.getUserId())){
+        if (StringUtils.isBlank(vo.getStationId()) || StringUtils.isBlank(vo.getUserId())) {
             throw new RuntimeException("宸ョ珯缂栫爜鎴栧憳宸ョ紪鐮佸潎涓嶈兘涓虹┖,璇锋鏌�");
         }
         //宸ョ珯103
-        if(vo.getStationId().startsWith(USER_PREFIX)){
+        if (vo.getStationId().startsWith(USER_PREFIX)) {
             userInfo = getUserInfo(vo.getStationId());
-        }else{
+        } else {
             stationInfo = getStationInfo(vo.getStationId());
         }
-        if(vo.getUserId().startsWith(STATION_PREFIX)){
+        if (vo.getUserId().startsWith(STATION_PREFIX)) {
             stationInfo = getStationInfo(vo.getUserId());
-        }else{
+        } else {
             userInfo = getUserInfo(vo.getUserId());
         }
-        if(userInfo == null && stationInfo == null){
-            throw new RuntimeException("鍛樺伐缂栫爜:"+ vo.getUserId() + "鍜屽伐绔欑紪鐮�:" + vo.getStationId() + "涓嶆纭�,璇锋鏌�");
-        }else if(userInfo == null){
-            throw new RuntimeException("鍛樺伐缂栫爜:"+ vo.getUserId() + "涓嶆纭�,璇锋鏌�");
-        }else if(stationInfo == null){
+        if (userInfo == null && stationInfo == null) {
+            throw new RuntimeException("鍛樺伐缂栫爜:" + vo.getUserId() + "鍜屽伐绔欑紪鐮�:" + vo.getStationId() + "涓嶆纭�,璇锋鏌�");
+        } else if (userInfo == null) {
+            throw new RuntimeException("鍛樺伐缂栫爜:" + vo.getUserId() + "涓嶆纭�,璇锋鏌�");
+        } else if (stationInfo == null) {
             throw new RuntimeException("宸ョ珯缂栫爜:" + vo.getStationId() + "涓嶆纭�,璇锋鏌�");
         }
         //妫�鏌ヨ〃涓璼tationId鏄惁宸茬粡瀛樺湪
@@ -172,14 +152,14 @@
         param.setStatus(STATUS_NORMAL);
         List<StaAssemblyWorkLast> workLasts = assemblyWorkLastDao.selectList(param);
         long userId = userInfo.getId();
-        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粦");
-            }else{
-                BeanUtils.copyProperties(userStationList.get(0),result);
+        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粦");
+            } else {
+                BeanUtils.copyProperties(userStationList.get(0), result);
             }
-        }else{
+        } else {
             result.setUserId(userInfo.getId());
             result.setUserName(userInfo.getName());
             result.setStationId(stationInfo.getId());
@@ -188,40 +168,120 @@
         }
         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());
+        //鏍¢獙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 = "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 params = new PrAssemblyPlan();
-        params.setStatus(STATUS_NORMAL);
-        params.setId(vo.getPlanId());
-        params.setProcessId(vo.getProcessId());
-        List<PrAssemblyPlan> planList = selectAssyPlanList(params);
-        boolean hasNodeId= planList.stream()
-                .flatMap(process -> process.getProcess().getNodes().stream())
+        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){
+        if (!hasNodeId) {
             throw new RuntimeException("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
         }
+
+        //鏁版嵁閫愪釜灏佽杩斿洖
         vo.setLineId(checkResult.getLineId());
         StaAssemblyWorkLast staLast = new StaAssemblyWorkLast();
-        BeanUtils.copyProperties(vo,staLast);
+        BeanUtils.copyProperties(vo, staLast);
         staLast.setUserId(checkResult.getUserId());
         staLast.setStationId(checkResult.getStationId());
         int count = 0;
-        if(checkResult.getId() == null){
-            BeanUtils.copyProperties(vo,staLast);
+        if (checkResult.getId() == null) {
+            BeanUtils.copyProperties(vo, staLast);//vo鎷疯礉鍒皊taLast
             staLast.setUserId(checkResult.getUserId());
             staLast.setStationId(checkResult.getStationId());
             staLast.setStatus(STATUS_NORMAL);
             staLast.setStartTime(new Date());
             count = assemblyWorkLastDao.insertSelective(staLast);
-        }else{
+        } else {
             //淇濆瓨涓�鏉istory?
-            BeanUtils.copyProperties(checkResult,staLast);
-            staLast.setPlanId(vo.getPlanId());
-            staLast.setProcessId(vo.getProcessId());
+            BeanUtils.copyProperties(checkResult, staLast);
+            staLast.setPlanId(assyPlan.getId());
+            staLast.setProcessId(assyPlan.getProcess().getId());
             staLast.setNodeId(vo.getNodeId());
             staLast.setStatus(STATUS_NORMAL);
             staLast.setStartTime(new Date());
@@ -231,13 +291,28 @@
             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());
+        }
+        result.setProId(product.getId());
+        result.setProName(product.getName());
+        String devicePrefix = "110" + product.getCode() + assyPlan.getBatchNo();
+        result.setDevicePrefix(devicePrefix);
         return result;
     }
+
     @Transactional
     public int logout(String id) {
         //鎵惧埌鐧诲綍璁板綍
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(Long.parseLong(id));
-        if(workLast == null){
+        if (workLast == null) {
             throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�");
         }
         //鏇存柊鐧诲綍璁板綍
@@ -245,101 +320,69 @@
         workLast.setEndTime(new Date());
         // 淇濆瓨history
         StaAssemblyWorkHistory history = new StaAssemblyWorkHistory();
-        BeanUtils.copyProperties(workLast,history);
+        BeanUtils.copyProperties(workLast, history);
         //history.setId(null);
         int count = assemblyWorkHistoryDao.insertSelective(history);
         //鍒犻櫎last
         assemblyWorkLastDao.deleteByPrimaryKey(Long.parseLong(id));
         return count;
     }
-    public List<PrAssemblyPlan> selectAssyPlanList(PrAssemblyPlan params){
-        List<PrAssemblyPlan> planList = assemblyDao.selectAssyPlanList(params);
-        planList.stream().forEach(process -> {
+
+    public List<PrAssemblyPlan> selectAssyPlanList(PrAssemblyPlan params) {
+        List<PrAssemblyPlan> planList = assemblyDao.selectAssyPlanSimplify(params);
+        /* planList.stream().forEach(process -> {
             process.getProcess().getNodes().forEach(node -> {
                 if(node.instruction != null){
                     addUrl(node.instruction);
                 }
             });
-        });
+        });*/
         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) {
+    public int addAssistant(String workId, String assistant) {
         //鎵惧埌workId
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(Long.parseLong(workId));
-        if(workLast == null){
+        if (workLast == null) {
             throw new RuntimeException("绯荤粺涓病鏈夊綋鍓嶇櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
         }
         BaUser userInfo = getUserInfo(assistant);
         //褰撳墠鐧诲綍浜轰笉鑳芥槸杈呭姪浜哄憳
-        if(workLast.getUserId() == userInfo.getId()){
-            throw new RuntimeException(userInfo.getName() +"鏄綋鍓嶇櫥褰曚汉鍛�,涓嶅繀娣诲姞涓鸿緟鍔╀汉鍛�.");
+        if (workLast.getUserId() == userInfo.getId()) {
+            throw new RuntimeException(userInfo.getName() + "鏄綋鍓嶇櫥褰曚汉鍛�,涓嶅繀娣诲姞涓鸿緟鍔╀汉鍛�.");
         }
         String userId = userInfo.getId().toString();
-        if(StringUtils.isBlank(workLast.getAssistants())){
+        if (StringUtils.isBlank(workLast.getAssistants())) {
             workLast.setAssistants(userId);
-        }else{
+        } else {
             //宸茬粡娣诲姞鐨勮緟鍔╀汉鍛� 涓嶅繀閲嶅娣诲姞
             String assistants = workLast.getAssistants();
             String[] assistantArr = assistants.split(",");
             for (String item : assistantArr) {
-                if(userId.equals(item)){
-                    throw new RuntimeException(userInfo.getName() +"宸茬粡娣诲姞涓鸿緟鍔╀汉鍛�,涓嶅繀閲嶅娣诲姞.");
+                if (userId.equals(item)) {
+                    throw new RuntimeException(userInfo.getName() + "宸茬粡娣诲姞涓鸿緟鍔╀汉鍛�,涓嶅繀閲嶅娣诲姞.");
                 }
             }
-            workLast.setAssistants(assistants +","+ userId);
+            workLast.setAssistants(assistants + "," + userId);
         }
         int count = assemblyWorkLastDao.updateByPrimaryKey(workLast);
         return count;
     }
-    public int removeAssistant(String workId ,String assistant) {
+
+    public int removeAssistant(String workId, String assistant) {
         //鎵惧埌workId
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(Long.parseLong(workId));
-        if(workLast == null){
+        if (workLast == null) {
             throw new RuntimeException("绯荤粺涓病鏈夊綋鍓嶇櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
         }
-        if((!StringUtils.isBlank(assistant)) && assistant.startsWith(USER_PREFIX)){
+        if ((!StringUtils.isBlank(assistant)) && assistant.startsWith(USER_PREFIX)) {
             assistant = assistant.substring(3);
         }
-        if(!StringUtils.isBlank(workLast.getAssistants())){
+        if (!StringUtils.isBlank(workLast.getAssistants())) {
             StringBuilder sb = new StringBuilder();
             String[] assistantArr = workLast.getAssistants().split(",");
             for (String item : assistantArr) {
-                if((!StringUtils.isBlank(assistant)) && (!assistant.equals(item))){
+                if ((!StringUtils.isBlank(assistant)) && (!assistant.equals(item))) {
                     sb.append(item).append(",");
                 }
             }
@@ -349,10 +392,11 @@
         int count = assemblyWorkLastDao.updateByPrimaryKey(workLast);
         return count;
     }
+
     public List<BaUser> getAssistantList(String workId) {
         //鎵惧埌workId
         StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(Long.parseLong(workId));
-        if(workLast == null){
+        if (workLast == null) {
             throw new RuntimeException("绯荤粺涓病鏈夊綋鍓嶇櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
         }
         List<BaUser> assistantList = baUserDao.selectByAssistants(workLast.getAssistants());

--
Gitblit v1.8.0