From 4a35dea2b0976e7fdb0e2b1a0d7d9b8ac2af0fe4 Mon Sep 17 00:00:00 2001
From: Fancy <Fancy.fx@outlook.com>
Date: 星期五, 01 十一月 2024 09:18:49 +0800
Subject: [PATCH] get product
---
pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java | 238 ++++++++++++++++++++++++++++++++++++++---------------------
1 files changed, 153 insertions(+), 85 deletions(-)
diff --git a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
index ddc69aa..6cddd03 100644
--- a/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
+++ b/pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java
@@ -7,18 +7,23 @@
import com.dy.pmsGlobal.daoPr.PrAssemblyPlanMapper;
import com.dy.pmsGlobal.daoPr.PrProductionNodeMapper;
import com.dy.pmsGlobal.daoSta.*;
+import com.dy.pmsGlobal.daoTst.TstCommandMapper;
import com.dy.pmsGlobal.dyFile.FileOperate;
import com.dy.pmsGlobal.dyFile.FileRestVo;
import com.dy.pmsGlobal.pojoOth.OthFile;
import com.dy.pmsGlobal.pojoPlt.*;
import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan;
+import com.dy.pmsGlobal.pojoPr.PrBillOfMaterial;
import com.dy.pmsGlobal.pojoPr.PrProductionNode;
import com.dy.pmsGlobal.pojoPr.PrWorkingInstruction;
import com.dy.pmsGlobal.pojoSta.*;
+import com.dy.pmsGlobal.pojoTst.TstCommand;
import com.dy.pmsGlobal.util.DeviceResult;
import com.dy.pmsGlobal.util.DeviceStatus;
import com.dy.pmsGlobal.util.QrCodeConstant;
+import com.dy.pmsGlobal.util.UserUtil;
import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.common.utils.PojoUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
@@ -36,6 +41,7 @@
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 WORK_TYPE_OTHER = "5";
private StaDeviceLastMapper deviceLastDao;
private StaDeviceLifeMapper deviceLifeDao;
@@ -49,6 +55,7 @@
private StaRepairInfoMapper repairInfoDao;
private PltProductQualityInspectionItemsMapper qualityItemsDao;
private PltProductTestInspectionItemsMapper testItemsDao;
+ private TstCommandMapper tstCommandDao;
private PltProductMapper productDao;
private PltProParamsMapper paramsDao;
private PltProductFileMapper productFileDao;
@@ -137,6 +144,11 @@
this.deviceLifeLastDao = deviceLifeLastDao;
}
+ @Autowired
+ public void setTstCommandDao(TstCommandMapper tstCommandDao) {
+ this.tstCommandDao = tstCommandDao;
+ }
+
@Transactional
public int save(QueryVo params) {
long workId = Long.parseLong(params.workId);
@@ -172,7 +184,7 @@
StaDeviceLast deviceLast = buildDeviceLast(params, workLast, deviceList.get(0));
int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
- deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+ deviceLastDao.updateByPrimaryKey(deviceLast);
saveDeviceProductionLog(deviceLast);
@@ -217,6 +229,7 @@
if (preRecord != null) {
record.id = preRecord.id;
record.inTime = preRecord.outTime;
+ record.inLineTime = preRecord.inLineTime;
record.outLineTime = preRecord.outLineTime;//涓嬭竟鍒ゆ柇鏄惁缁撴潫浼氱敤鍒� 寰楃暀鐫�
} else {
record.inTime = new Date();
@@ -224,34 +237,43 @@
assemblyPlan.setInputNumber(assemblyPlan.getInputNumber() + 1);
}
record.outTime = new Date();
-
- record.planId = workLast.planId;
+ record.planId = assemblyPlan.getId();
record.workId = Long.parseLong(params.workId);
record.stationId = workLast.stationId;
record.deviceNo = deviceNo;
record.currNode = workLast.nodeId;
-
record.updatedBy = workLast.userId;
record.assistants = workLast.assistants;
record.errorMsg = params.errorMsg;
- Boolean isEnd = false;//鏄惁缁忓巻杩囩粨鏉熻妭鐐�
- PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
- record.nodeContent = node.content;
- if (node.isRecord) {
- record.deviceCycleContent = node.deviceCycleContent;
+ Boolean isEnd = false;//鏄惁缁忓巻杩囨垨姝ｅ湪缁忓巻缁撴潫鑺傜偣
+ if (workLast.nodeId == null) {
+ if (record.outLineTime != null) {
+ isEnd = true;
+ }
+ if(StringUtils.isNotBlank(params.getContent())){
+ record.nodeContent = params.getContent();
+ }
+ } else {
+ PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
+ record.nodeContent = node.content;
+ PrProductionNode nextNode = nodeDao.selectNodeBySort(node.getProcessId() , (node.getSort() + 1));
+ record.nextNodeContent = nextNode.content;
+ record.nextNode = nextNode.id;
+ if (node.isRecord) {
+ record.deviceCycleContent = node.deviceCycleContent;
+ }
+ if (node.getIsEnd() && record.outLineTime == null) {
+ record.outLineTime = new Date();
+ assemblyPlan.setOutputNumber(assemblyPlan.getOutputNumber() + 1);
+ isEnd = true;
+ } else if (record.outLineTime != null) {
+ isEnd = true;
+ }
}
- if (node.getIsEnd() && record.outLineTime == null) {
- record.outLineTime = new Date();
- assemblyPlan.setOutputNumber(assemblyPlan.getOutputNumber() + 1);
- isEnd = true;
- }else if(record.outLineTime != null){
- isEnd = true;
- }
- assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan);
-
record.status = getStatus(params.status, isEnd, workLast.workType.toString());
record.result = getResult(params.status, workLast.workType.toString());
+ assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan);
return record;
}
@@ -271,14 +293,15 @@
/**
* 鍘熺姸鎬�: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃
- *20240717褰撳墠鐘舵�� 鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
- * @param status 鐘舵��
- * @param isEnd 鏄惁缁忓巻杩囩粨鏉熻妭鐐�
+ * 20240717褰撳墠鐘舵�� 鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾
+ *
+ * @param status 鐘舵��
+ * @param isEnd 鏄惁缁忓巻杩囩粨鏉熻妭鐐�
* @return 鐘舵��
*/
private Integer getStatus(String status, boolean isEnd, String workType) {
//缁勮 2024/07/17 鐩墠缁勮workType 1 鍙湁MarkOk //娴嬭瘯 //鍝佹
- if (WORK_TYPE_ASSEMBLY.equals(workType) || WORK_TYPE_TEST.equals(workType) || WORK_TYPE_INSPECTION.equals(workType) || WORK_TYPE_REPAIR.equals(workType)) {
+ if (WORK_TYPE_ASSEMBLY.equals(workType) || WORK_TYPE_TEST.equals(workType) || WORK_TYPE_INSPECTION.equals(workType) || WORK_TYPE_REPAIR.equals(workType)|| WORK_TYPE_OTHER.equals(workType)) {
return switch (status) {
case QrCodeConstant.MarkOk -> isEnd ? DeviceStatus.COMPLETED.getCode() : DeviceStatus.ASSEMBLING.getCode();
case QrCodeConstant.MarkQualified -> isEnd ? DeviceStatus.COMPLETED.getCode() : DeviceStatus.ASSEMBLING.getCode();
@@ -290,34 +313,36 @@
//缁翠慨
throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
}
+
/**
* 缁撴灉: 1:閫氳繃,2:娴嬭瘯閫氳繃,3:鍝佹閫氳繃,4:缁翠慨閫氳繃,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃,7:鎶ュ簾
- * @param status 鍓嶇鍑烘潵鐨勭姸鎬�
+ *
+ * @param status 鍓嶇鍑烘潵鐨勭姸鎬�
* @return 缁撴灉
*/
private Integer getResult(String status, String workType) {
- //缁勮
- if (WORK_TYPE_ASSEMBLY.equals(workType)) {
+ //缁勮 涓存椂浠诲姟-鍏朵粬
+ if (WORK_TYPE_ASSEMBLY.equals(workType) || WORK_TYPE_OTHER.equals(workType)) {
return switch (status) {
case QrCodeConstant.MarkOk -> DeviceResult.PASS.getCode();
default -> throw new RuntimeException("鐘舵�侀敊璇�");
};
//娴嬭瘯
- }else if (WORK_TYPE_TEST.equals(workType)) {
+ } else if (WORK_TYPE_TEST.equals(workType)) {
return switch (status) {
- case QrCodeConstant.MarkQualified -> DeviceResult.TEST_PASS.getCode();
+ case QrCodeConstant.MarkQualified -> DeviceResult.TEST_PASS.getCode();
case QrCodeConstant.MarkUnqualified -> DeviceResult.TEST_FAIL.getCode();
default -> throw new RuntimeException("鐘舵�侀敊璇�");
};
//鍝佹
- }else if (WORK_TYPE_INSPECTION.equals(workType)) {
+ } else if (WORK_TYPE_INSPECTION.equals(workType)) {
return switch (status) {
case QrCodeConstant.MarkQualified -> DeviceResult.INSPECTION_PASS.getCode();
case QrCodeConstant.MarkUnqualified -> DeviceResult.INSPECTION_FAIL.getCode();
default -> throw new RuntimeException("鐘舵�侀敊璇�");
};
//缁翠慨
- }else if (WORK_TYPE_REPAIR.equals(workType)) {
+ } else if (WORK_TYPE_REPAIR.equals(workType)) {
return switch (status) {
case QrCodeConstant.MarkOk -> DeviceResult.REPAIR_PASS.getCode();
case QrCodeConstant.MarkWaste -> DeviceResult.WASTE.getCode();
@@ -326,6 +351,7 @@
}
throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType);
}
+
@Transactional
public int repair(QueryVo vo) {
long workId = Long.parseLong(vo.workId);
@@ -340,16 +366,18 @@
repairInfo.repairTime = new Date();
repairInfo.repairBy = workLast.userId;
repairInfo.repairReason = vo.errorMsg;
- repairInfo.fromNode = preDeviceRecord.currNode;
+ if (preDeviceRecord != null) {
+ repairInfo.fromNode = preDeviceRecord.currNode;
+ }
repairInfoDao.insertSelective(repairInfo);
StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
-
+ deviceLast.setRepairId(repairInfo.getId());
int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
- deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+ deviceLastDao.updateByPrimaryKey(deviceLast);
saveDeviceProductionLog(deviceLast);
- boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode);
- if (isEndNode) {
+ //鍙缁忓巻杩囩粨鏉熻妭鐐�,灏变竴鐩磋褰昫evice life
+ if (preDeviceRecord != null && preDeviceRecord.getOutLineTime() != null) {
saveDeviceLife(deviceLast);
}
return count;
@@ -364,10 +392,10 @@
}
StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
- deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+ deviceLastDao.updateByPrimaryKey(deviceLast);
saveDeviceProductionLog(deviceLast);
PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
- if (node.isRecord) {
+ if (node != null && node.isRecord) {
saveDeviceLife(deviceLast);
}
return count;
@@ -382,14 +410,15 @@
}
StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
- deviceLastDao.updateByPrimaryKeySelective(deviceLast);
+ deviceLastDao.updateByPrimaryKey(deviceLast);
saveDeviceProductionLog(deviceLast);
PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId);
- if (node.isRecord) {
+ if (node != null && node.isRecord) {
saveDeviceLife(deviceLast);
}
return count;
}
+
//鏃犱换鍔¤鍒掍腑鐨勫叾浠� 浼爓orkId ,鎵嬪啓宸ヤ綔鍐呭 , 鏁伴噺
@Transactional
public int otherWork(QueryVo vo) {
@@ -398,24 +427,34 @@
if (workLast == null) {
throw new RuntimeException("绯荤粺涓病鏈夎鏉＄櫥褰曚俊鎭�");
}
- //淇濆瓨宸ヤ綔璁板綍
- StaDeviceProductionLog log = new StaDeviceProductionLog();
- log.setId(null); // 璁惧鐢熶骇鏃ュ織ID璁句负null锛岃〃绀烘柊澧�
- log.setDeviceNo(""); //RepairId planId currNode deviceCycleContent memo
- log.setWorkId(workId);
- log.setStationId(workLast.getStationId());
- log.setNodeContent(vo.getContent());
- log.setStatus(DeviceStatus.COMPLETED.getCode());//瀹屾垚鐘舵��
- log.setResult(DeviceResult.PASS.getCode());//閫氳繃
- log.setErrorMsg(vo.getErrorMsg());
- log.setAssistants(workLast.getAssistants());
- log.setInTime(new Date());
- log.setOutTime(new Date());
- log.setUpdatedBy(workLast.getUserId());
- log.setNumber(vo.getNumber());
- int count = deviceProductionLogDao.insertSelective(log);
+ int count = 0;
+ //淇濆瓨宸ヤ綔璁板綍 //濡傛灉鏈夎澶囩爜
+ if(vo.deviceNo != null && StringUtils.isNotBlank(vo.deviceNo[0])){
+ StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]);
+ count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) :
+ deviceLastDao.updateByPrimaryKey(deviceLast);
+ saveDeviceProductionLog(deviceLast);
+ }else{
+ StaDeviceProductionLog log = new StaDeviceProductionLog();
+ log.setId(null); // 璁惧鐢熶骇鏃ュ織ID璁句负null锛岃〃绀烘柊澧�
+ log.setDeviceNo(""); //RepairId planId currNode deviceCycleContent memo
+ log.setWorkId(workId);
+ log.setStationId(workLast.getStationId());
+ log.setNodeContent(vo.getContent());
+ log.setStatus(DeviceStatus.COMPLETED.getCode());//瀹屾垚鐘舵��
+ log.setResult(DeviceResult.PASS.getCode());//閫氳繃
+ log.setErrorMsg(vo.getErrorMsg());
+ log.setAssistants(workLast.getAssistants());
+ log.setInTime(new Date());
+ log.setOutTime(new Date());
+ log.setUpdatedBy(workLast.getUserId());
+ log.setNumber(vo.getNumber());
+ count = deviceProductionLogDao.insertSelective(log);
+
+ }
return count;
}
+
//鏍规嵁鑺傜偣鏌ュ嚭鑺傜偣浣滀笟鎸囧涔�
public PrProductionNode getSopByNodeId(String nodeId) {
if (com.alibaba.excel.util.StringUtils.isBlank(nodeId)) {
@@ -427,6 +466,9 @@
}
if (node.instruction != null) {
addUrl(node.instruction);
+ }
+ if (node.bill != null) {
+ addBillUrl(node.bill);
}
return node;
}
@@ -452,7 +494,7 @@
return;
}
FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
- doc.webUrl = fileRestVo.fileSysRestUrl + fileRestVo.fileWebDownloadPath + doc.fileId;
+ doc.webUrl = fileRestVo.fileWebDownloadPath + doc.fileId;
doc.orgName = file.orgName;
doc.extName = file.extName;
});
@@ -462,6 +504,7 @@
public List<PltProductQualityInspectionItems> getQualityItems(String proId) {
Map<String, Object> params = new HashMap<>();
params.put("proId", proId);//item start count
+ params.put("disabled", "0");
//鏌ヨ绗﹀悎鏉′欢鐨勮褰�
return qualityItemsDao.selectSome(params);
}
@@ -469,6 +512,7 @@
public List<PltProductTestInspectionItems> getTestItems(String proId) {
Map<String, Object> params = new HashMap<>();
params.put("proId", proId);
+ params.put("disabled", "0");
return testItemsDao.selectSome(params);
}
@@ -492,32 +536,32 @@
return;
}
FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
- ins.webUrl = fileRestVo.fileSysRestUrl + fileRestVo.fileWebDownloadPath + ins.fileId;
+ ins.webUrl = fileRestVo.fileWebDownloadPath + ins.fileId;
ins.orgName = file.orgName;
ins.extName = file.extName;
}
- private PltProduct addWebUrl(PltProduct pro) {
- if (pro != null) {
- if (pro.image != null) {
- String filePathWithWebUrl = getFilePathWithWebUrl(pro.image);
- pro.imageWebPath = filePathWithWebUrl;
- pro.imageWebPathZip = fileOperate.getImgFileZipPath(filePathWithWebUrl);
- }
-
- pro.proFiles.stream().forEach(doc -> {
- OthFile file = othFileMapper.selectByPrimaryKey(doc.fileId);
- if (file == null) {
- return;
- }
- FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
- doc.webUrl = fileRestVo.fileSysRestUrl + fileRestVo.fileWebDownloadPath + doc.fileId;
- doc.orgName = file.orgName;
- doc.extName = file.extName;
- });
- }
- return pro;
- }
+// private PltProduct addWebUrl(PltProduct pro) {
+// if (pro != null) {
+// if (pro.image != null) {
+// String filePathWithWebUrl = getFilePathWithWebUrl(pro.image);
+// pro.imageWebPath = filePathWithWebUrl;
+// pro.imageWebPathZip = fileOperate.getImgFileZipPath(filePathWithWebUrl);
+// }
+//
+// pro.proFiles.stream().forEach(doc -> {
+// OthFile file = othFileMapper.selectByPrimaryKey(doc.fileId);
+// if (file == null) {
+// return;
+// }
+// FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
+// doc.webUrl = fileRestVo.fileWebDownloadPath + doc.fileId;
+// doc.orgName = file.orgName;
+// doc.extName = file.extName;
+// });
+// }
+// return pro;
+// }
private String getFilePathWithWebUrl(Long fileId) {
OthFile file = othFileMapper.selectByPrimaryKey(fileId);
@@ -525,7 +569,7 @@
return fileRestVo.fileWebUrl + file.filePath;
}
- public Map<String, String> queryByDeviceNo(String deviceNo,List<PltProduct> productList) {
+ public Map<String, String> queryByDeviceNo(String deviceNo, List<PltProduct> productList) {
Map<String, String> map = new HashMap<>();
map.put("deviceNo", deviceNo);
map.put("proName", "");
@@ -533,7 +577,7 @@
map.put("proId", "");
map.put("proCode", "");
//鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡
- if(CollectionUtils.isEmpty(productList)){
+ if (CollectionUtils.isEmpty(productList)) {
productList = productDao.selectAll(null);
}
PltProduct product = null;
@@ -546,24 +590,26 @@
map.put("proType", product.getType());
BigInteger proId = BigInteger.valueOf(product.getId());
map.put("proId", proId.toString());
- map.put("proCode",product.getCode());
+ map.put("proCode", product.getCode());
}
return map;
}
+
//鏌ヨ浜у搧鎵�鍦ㄧ殑浠诲姟
public PrAssemblyPlan queryPlanByDeviceNo(String deviceNo) {
String proCode = "";
String lotCode = "";
if (StringUtils.isNotEmpty(deviceNo) && deviceNo.length() == 22) {
- proCode = deviceNo.substring(3,6);
- lotCode = deviceNo.substring(6,15);
+ proCode = deviceNo.substring(3, 6);
+ lotCode = deviceNo.substring(6, 15);
}
- PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode,lotCode);
- if(plan != null){
+ PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode, lotCode);
+ if (plan != null) {
plan.setBatchNo(lotCode);
}
return plan;
}
+
public List<StaDeviceLife> queryLifeByDeviceNo(String deviceNo) {
return deviceLifeDao.selectByDeviceNo(deviceNo);
}
@@ -572,5 +618,27 @@
return deviceProductionLogDao.selectByDeviceNo(devoiceNo);
}
-
+ private void addBillUrl(PrBillOfMaterial bill) {
+ if (bill == null || bill.fileId == null) {
+ return;
+ }
+ OthFile file = othFileMapper.selectByPrimaryKey(bill.fileId);
+ if (file == null) {
+ return;
+ }
+ FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash);
+ bill.webUrl = fileRestVo.fileWebDownloadPath + bill.fileId;
+ bill.orgName = file.orgName;
+ bill.extName = file.extName;
+ }
+ public List<TstCommand> getCommand(String proId, int type) {
+ Map<String, Object> params = new HashMap<>();
+ params.put("proId", proId);
+ params.put("type", type);
+ return tstCommandDao.selectSome(params);
+ }
+ public List<PltProduct> selectAll(QueryVo queryVo) {
+ Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
+ return productDao.selectAll(params);
+ }
}
--
Gitblit v1.8.0