From 2d35acb93b1654c660153edaddd55a50bf447fe4 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期三, 14 八月 2024 17:05:34 +0800
Subject: [PATCH] fix addAssistant
---
pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/workOrder/WorkOrderSv.java | 152 +++++++++++++++++++++++++++++---------------------
1 files changed, 88 insertions(+), 64 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 43c43f0..d1150fa 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
@@ -3,6 +3,7 @@
import com.alibaba.excel.util.StringUtils;
import com.dy.pmsGlobal.daoBa.BaUserMapper;
import com.dy.pmsGlobal.daoPlt.PltProductMapper;
+import com.dy.pmsGlobal.daoPlt.PltProductionLineMapper;
import com.dy.pmsGlobal.daoPlt.PltStationMapper;
import com.dy.pmsGlobal.daoPr.PrAssemblyPlanMapper;
import com.dy.pmsGlobal.daoPr.PrProductionNodeMapper;
@@ -10,6 +11,7 @@
import com.dy.pmsGlobal.daoSta.StaAssemblyWorkLastMapper;
import com.dy.pmsGlobal.pojoBa.BaUser;
import com.dy.pmsGlobal.pojoPlt.PltProduct;
+import com.dy.pmsGlobal.pojoPlt.PltProductionLine;
import com.dy.pmsGlobal.pojoPlt.PltStation;
import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan;
import com.dy.pmsGlobal.pojoPr.PrProductionNode;
@@ -39,8 +41,8 @@
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";
+// private static final String USER_PREFIX = "101";
+// private static final String STATION_PREFIX = "103";
private PrAssemblyPlanMapper assemblyDao;
private BaUserMapper baUserDao;
@@ -49,6 +51,7 @@
private StaAssemblyWorkHistoryMapper assemblyWorkHistoryDao;
private PrProductionNodeMapper nodeDao;
private PltProductMapper productDao;
+ private PltProductionLineMapper lineDao;
@Autowired
public void setAssemblyDao(PrAssemblyPlanMapper assemblyDao) {
@@ -85,6 +88,10 @@
this.productDao = productDao;
}
+ @Autowired
+ public void setLineDao(PltProductionLineMapper lineDao) {
+ this.lineDao = lineDao;
+ }
public BaUser getUserInfo(String id) {
Long userId = null;
@@ -92,7 +99,7 @@
throw new RuntimeException("鍛樺伐缂栫爜涓嶈兘涓虹┖");
}
//鐢ㄦ埛101
- if (id.startsWith(USER_PREFIX)) {
+ if (id.startsWith(QrCodeConstant.TypeWorker)) {
userId = Long.parseLong(id.toString().substring(3));
} else {
userId = Long.parseLong(id.toString());
@@ -113,7 +120,7 @@
throw new RuntimeException("宸ョ珯缂栫爜涓嶈兘涓虹┖");
}
//宸ョ珯103
- if (id.startsWith(STATION_PREFIX)) {
+ if (id.startsWith(QrCodeConstant.TypeStation)) {
stationId = Long.parseLong(id.toString().substring(3));
} else {
stationId = Long.parseLong(id.toString());
@@ -123,6 +130,13 @@
throw new RuntimeException("宸ョ珯缂栫爜:" + stationId + "涓嶅湪绯荤粺涓�,璇峰厛缁存姢宸ョ珯淇℃伅");
} else if (stationInfo.getDisabled()) {
throw new RuntimeException("宸ョ珯(" + stationInfo.getName() + ")缂栫爜:" + stationId + "鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤宸ョ珯");
+ }
+ //妫�鏌ョ嚎浣撴槸鍚﹁绂佺敤
+ PltProductionLine lineInfo = lineDao.selectByPrimaryKey(stationInfo.getLineId());
+ if (lineInfo == null ) {
+ throw new RuntimeException("宸ョ珯(" + stationInfo.getName() + ")缂栫爜:" + stationId + "鎵�鍦ㄧ嚎浣撶紪鐮�:" + lineInfo.getId() + "鍦ㄧ郴缁熶笉瀛樺湪,璇峰厛鎵剧鐞嗕汉鍛樻鏌�");
+ }else if(lineInfo.getDisabled()){
+ throw new RuntimeException("宸ョ珯(" + stationInfo.getName() + ")缂栫爜:" + stationId + "鎵�鍦ㄧ嚎浣撶紪鐮�:" + lineInfo.getName() + "鍦ㄧ郴缁熷凡绂佺敤,璇峰厛鍚敤绾夸綋");
}
return stationInfo;
}
@@ -135,12 +149,12 @@
throw new RuntimeException("宸ョ珯缂栫爜鎴栧憳宸ョ紪鐮佸潎涓嶈兘涓虹┖,璇锋鏌�");
}
//宸ョ珯103
- if (vo.getStationId().startsWith(USER_PREFIX)) {
+ if (vo.getStationId().startsWith(QrCodeConstant.TypeWorker)) {
userInfo = getUserInfo(vo.getStationId());
} else {
stationInfo = getStationInfo(vo.getStationId());
}
- if (vo.getUserId().startsWith(STATION_PREFIX)) {
+ if (vo.getUserId().startsWith(QrCodeConstant.TypeStation)) {
stationInfo = getStationInfo(vo.getUserId());
} else {
userInfo = getUserInfo(vo.getUserId());
@@ -157,17 +171,25 @@
param.setStationId(stationInfo.getId());
param.setStatus(STATUS_NORMAL);
List<StaAssemblyWorkLast> workLasts = assemblyWorkLastDao.selectList(param);
- long userId = userInfo.getId();
+ //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) {
+ StaAssemblyWorkLast paramQuery = new StaAssemblyWorkLast();
+ paramQuery.setUserId(userInfo.getId());
+ paramQuery.setStationId(stationInfo.getId());
+ paramQuery.setPlanId(vo.getPlanId());
+ paramQuery.setProcessId(vo.getProcessId());
+ paramQuery.setNodeId(vo.getNodeId());
+ paramQuery.setWorkType(vo.getWorkType());
+ StaAssemblyWorkLast userStation = assemblyWorkLastDao.existsEntity(paramQuery);
+ //List<StaAssemblyWorkLast> userStationList = workLasts.stream().filter(item -> userId == item.getUserId()).collect(Collectors.toList());
+ if (userStation == null) {
//鍒犻櫎宸ョ珯鐧诲綍淇℃伅
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() + ".璇峰厛璁╁叾瑙ｇ粦");
} else {
- BeanUtils.copyProperties(userStationList.get(0), result);
+ BeanUtils.copyProperties(userStation, result);
}
}
if (result.getId() == null) {
@@ -191,8 +213,8 @@
}
BaUser userInfo = getUserInfo(result.getUserId().toString());
PltStation stationInfo = getStationInfo(result.getStationId().toString());
- //濡傛灉鏄淮淇畐ork_type 娌℃湁 planId processId nodeId
- if (WORK_TYPE_REPAIR.equals(result.getWorkType())) {
+ //濡傛灉鏄棤浠诲姟璁″垝 濡傜淮淇畐ork_type 娌℃湁 planId processId nodeId
+ if (result.getPlanId() != null) {
//鏍￠獙planId processId nodeId
PrAssemblyPlan assyPlan = assemblyDao.selectByPrimaryKey(result.getPlanId());
boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
@@ -220,9 +242,11 @@
}
return result;
} else {
+ List<PrProductionNode> nodeInfo = assyPlan.getProcess().getNodes().stream()
+ .filter(node -> node.id.equals(result.getNodeId())).collect(Collectors.toList());
result.setPlanName(assyPlan.getName());
result.setProcessName(assyPlan.getProcessName());
- result.setNodeName(assyPlan.getProcess().getNodes().get(0).getContent());
+ result.setNodeName(nodeInfo.get(0).getContent());
//鎵惧埌瀵瑰簲鐨勪骇鍝佷俊鎭�
PltProduct product = productDao.selectByPrimaryKey(assyPlan.getProId());
if (product != null) {
@@ -267,58 +291,58 @@
//鍏坈heck
StaAssemblyWorkLast checkResult = checkUserAndStationUsed(vo);
//鏍￠獙planId processId nodeId
- PrAssemblyPlan assyPlan = assemblyDao.selectByPrimaryKey(vo.getPlanId());
- if (assyPlan == null) {
- throw new RuntimeException("缁勮浠诲姟宸茬粡鍦ㄧ郴缁熶腑鍒犻櫎璇锋鏌�,鍒锋柊骞堕噸鏂伴�夋嫨浠诲姟");
+ PrAssemblyPlan assyPlan = null;
+ 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("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
+ }
}
- boolean hasNodeId = assyPlan.getProcess().getNodes().stream()
- .anyMatch(node -> node.id.equals(vo.getNodeId()));
- if (!hasNodeId) {
- throw new RuntimeException("鑺傜偣淇℃伅鏈夎鎴栬鍏朵粬浜哄憳淇敼,璇烽噸鏂伴�夋嫨鑺傜偣淇℃伅");
+ StaAssemblyWorkLast result = new StaAssemblyWorkLast();
+ //鏌ヨ鍒板綋鍓嶇殑淇℃伅 濡傛灉鐧诲綍淇℃伅涓�妯′竴鏍�,涓嶄細鏇存柊
+ if (checkResult.getId() != null) {
+ BeanUtils.copyProperties(checkResult, result);//checkResult鎷疯礉鍒皉esult
+ result.setDt(new Date());
+ assemblyWorkLastDao.updateByPrimaryKeySelective(result);
+ }else{
+ //閫愪釜灏佽淇濆瓨
+ BeanUtils.copyProperties(vo, result);//vo鎷疯礉鍒皉esult
+ result.setUserId(checkResult.getUserId());
+ result.setStationId(checkResult.getStationId());
+ result.setLineId(checkResult.getLineId());
+ result.setStatus(STATUS_NORMAL);
+ result.setStartTime(new Date());
+ if (vo.getPlanId() != null) {
+ result.setPlanId(assyPlan.getId());
+ result.setProcessId(assyPlan.getProcess().getId());
+ result.setNodeId(vo.getNodeId());
+ }
+ int count = assemblyWorkLastDao.insertSelective(result);
+ if (count <= 0) {
+ throw new RuntimeException("鏁版嵁搴撳瓨鍌ㄥけ璐�");
+ }
}
-
- //鏁版嵁閫愪釜灏佽杩斿洖
- vo.setLineId(checkResult.getLineId());
- StaAssemblyWorkLast staLast = new StaAssemblyWorkLast();
- BeanUtils.copyProperties(vo, staLast);
- staLast.setUserId(checkResult.getUserId());
- staLast.setStationId(checkResult.getStationId());
- int count = 0;
- 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 {
- //淇濆瓨涓�鏉istory?
- 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());
- count = assemblyWorkLastDao.updateByPrimaryKeySelective(staLast);
+ 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(nodeInfo.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);
}
- if (count <= 0) {
- 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 = QrCodeConstant.TypeProduct + product.getCode() + assyPlan.getBatchNo();
- result.setDevicePrefix(devicePrefix);
return result;
}
@@ -363,7 +387,7 @@
}
BaUser userInfo = getUserInfo(assistant);
//褰撳墠鐧诲綍浜轰笉鑳芥槸杈呭姪浜哄憳
- if (workLast.getUserId() == userInfo.getId()) {
+ if (workLast.getUserId().intValue() == userInfo.getId().intValue()) {
throw new RuntimeException(userInfo.getName() + "鏄綋鍓嶇櫥褰曚汉鍛�,涓嶅繀娣诲姞涓鸿緟鍔╀汉鍛�.");
}
String userId = userInfo.getId().toString();
@@ -390,7 +414,7 @@
if (workLast == null) {
throw new RuntimeException("绯荤粺涓病鏈夊綋鍓嶇櫥褰曚俊鎭�,璇锋鏌ユ垨閲嶆柊鐧诲綍");
}
- if ((!StringUtils.isBlank(assistant)) && assistant.startsWith(USER_PREFIX)) {
+ if ((!StringUtils.isBlank(assistant)) && assistant.startsWith(QrCodeConstant.TypeWorker)) {
assistant = assistant.substring(3);
}
if (!StringUtils.isBlank(workLast.getAssistants())) {
--
Gitblit v1.8.0