From eead3af59c94c35422463fbbd19d26dffcbacc06 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期五, 05 七月 2024 09:35:28 +0800
Subject: [PATCH] edit work last

---
 pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java |  290 +++++++++++++++++++++++++++++++++------------------------
 1 files changed, 166 insertions(+), 124 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 7f9c863..feabcb0 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,177 +1,211 @@
 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
 @Service
 public class WorkOrderSv {
+    private static final int STATUS_NORMAL = 1;
+    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 USER_PREFIX = "101";
+    private static final String STATION_PREFIX = "103";
+
     private PrAssemblyPlanMapper assemblyDao;
     private BaUserMapper baUserDao;
     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("101")){
+        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("103")){
+        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){
+
+    public StaAssemblyWorkLast checkStationUsed(String id) {
         StaAssemblyWorkLast result = new StaAssemblyWorkLast();
         PltStation stationInfo = null;
-        if(StringUtils.isBlank(id)){
+        if (StringUtils.isBlank(id)) {
             throw new RuntimeException("宸ョ珯缂栫爜涓嶈兘涓虹┖,璇锋鏌�");
         }
         stationInfo = getStationInfo(id);
         //妫�鏌ヨ〃涓璼tationId鏄惁宸茬粡瀛樺湪
         StaAssemblyWorkLast param = new StaAssemblyWorkLast();
         param.setStationId(stationInfo.getId());
-        param.setStatus(1);
+        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());
+        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){
+    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("101")){
+        if (vo.getStationId().startsWith(USER_PREFIX)) {
             userInfo = getUserInfo(vo.getStationId());
-        }else{
+        } else {
             stationInfo = getStationInfo(vo.getStationId());
         }
-        if(vo.getUserId().startsWith("103")){
+        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鏄惁宸茬粡瀛樺湪
         StaAssemblyWorkLast param = new StaAssemblyWorkLast();
         param.setStationId(stationInfo.getId());
-        param.setStatus(1);
+        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());
@@ -180,42 +214,43 @@
         }
         return result;
     }
+
     @Transactional
     public StaAssemblyWorkLast save(QueryVo vo) {
         //鍏坈heck
         StaAssemblyWorkLast checkResult = checkUserAndStationUsed(vo);
         //鏍¢獙planId processId nodeId
-        PrAssemblyPlan params = new PrAssemblyPlan();
-        params.setStatus(1);
-        params.setId(vo.getPlanId());
-        params.setProcessId(vo.getProcessId());
-        List<PrAssemblyPlan> planList = selectAssyPlanList(params);
-        boolean hasNodeId= planList.stream()
-                .flatMap(process -> process.nodes.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);
             staLast.setUserId(checkResult.getUserId());
             staLast.setStationId(checkResult.getStationId());
-            staLast.setStatus(1);
+            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(1);
+            staLast.setStatus(STATUS_NORMAL);
             staLast.setStartTime(new Date());
             count = assemblyWorkLastDao.updateByPrimaryKeySelective(staLast);
         }
@@ -223,65 +258,68 @@
             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.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("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�");
         }
         //鏇存柊鐧诲綍璁板綍
-        workLast.setStatus(2);
+        workLast.setStatus(STATUS_WORK_LAST_LOGOUT);
         workLast.setEndTime(new Date());
         // 淇濆瓨history
         StaAssemblyWorkHistory history = new StaAssemblyWorkHistory();
-        BeanUtils.copyProperties(workLast,history);
-        history.setId(null);
+        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 -> {
-            process.nodes.forEach(node -> {
+
+    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){
+        if (workLast == null) {
             throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
         }
         //濡傛灉assistants 鏈�101 鍒欏垹鎺�
         StringBuilder sb = new StringBuilder();
         String[] assistantArr = vo.getAssistants().split(",");
         for (String item : assistantArr) {
-            if(item.startsWith("101")){
+            if (item.startsWith(USER_PREFIX)) {
                 sb.append(item.substring(3)).append(",");
-            }else{
+            } else {
                 sb.append(item).append(",");
             }
         }
@@ -290,48 +328,49 @@
         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("101")){
+        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(",");
                 }
             }
@@ -341,13 +380,16 @@
         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());
         return assistantList;
     }
+
+
 }
\ No newline at end of file

--
Gitblit v1.8.0