From cdfb66472c06c611c5370f442208b0388d6347ef Mon Sep 17 00:00:00 2001 From: 刘小明 <liuxm_a@163.com> Date: 星期三, 24 七月 2024 09:53:57 +0800 Subject: [PATCH] 添加品检接口 --- pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java | 259 +++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 197 insertions(+), 62 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 674443e..b94f17d 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 @@ -15,6 +15,7 @@ import com.dy.pmsGlobal.pojoPr.PrProductionNode; import com.dy.pmsGlobal.pojoPr.PrWorkingInstruction; import com.dy.pmsGlobal.pojoSta.*; +import com.dy.pmsGlobal.util.DeviceResult; import com.dy.pmsGlobal.util.DeviceStatus; import com.dy.pmsGlobal.util.QrCodeConstant; import lombok.extern.slf4j.Slf4j; @@ -24,7 +25,9 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.math.BigInteger; import java.util.*; +import java.util.stream.Collectors; @Slf4j @Service @@ -36,6 +39,7 @@ private StaDeviceLastMapper deviceLastDao; private StaDeviceLifeMapper deviceLifeDao; + private StaDeviceLifeLastMapper deviceLifeLastDao; private StaWipSnExMapper wipSnExDao; private StaDeviceProductionLogMapper deviceProductionLogDao; private StaAssemblyWorkLastMapper assemblyWorkLastDao; @@ -52,46 +56,57 @@ private OthFileMapper othFileMapper; @Value("${dy.webFile.fmUrl}") private String fmUrl; + @Autowired public void setDeviceLastDao(StaDeviceLastMapper deviceLastDao) { this.deviceLastDao = deviceLastDao; } + @Autowired public void setDeviceLifeDao(StaDeviceLifeMapper deviceLifeDao) { this.deviceLifeDao = deviceLifeDao; } + @Autowired public void setWipSnExDao(StaWipSnExMapper wipSnExDao) { this.wipSnExDao = wipSnExDao; } + @Autowired public void setDeviceProductionLogDao(StaDeviceProductionLogMapper deviceProductionLogDao) { this.deviceProductionLogDao = deviceProductionLogDao; } + @Autowired public void setAssemblyWorkLastDao(StaAssemblyWorkLastMapper assemblyWorkLastDao) { this.assemblyWorkLastDao = assemblyWorkLastDao; } + @Autowired public void setAssemblyPlanDao(PrAssemblyPlanMapper assemblyPlanDao) { this.assemblyPlanDao = assemblyPlanDao; } + @Autowired public void setNodeDao(PrProductionNodeMapper nodeDao) { this.nodeDao = nodeDao; } + @Autowired public void setRepairInfoDao(StaRepairInfoMapper repairInfoDao) { this.repairInfoDao = repairInfoDao; } + @Autowired public void setQualityItemsDao(PltProductQualityInspectionItemsMapper qualityItemsDao) { this.qualityItemsDao = qualityItemsDao; } + @Autowired public void setTestItemsDao(PltProductTestInspectionItemsMapper testItemsDao) { this.testItemsDao = testItemsDao; } + @Autowired public void setProductDao(PltProductMapper productDao) { this.productDao = productDao; @@ -117,6 +132,11 @@ this.othFileMapper = othFileMapper; } + @Autowired + public void setDeviceLifeLastDao(StaDeviceLifeLastMapper deviceLifeLastDao) { + this.deviceLifeLastDao = deviceLifeLastDao; + } + @Transactional public int save(QueryVo params) { long workId = Long.parseLong(params.workId); @@ -126,24 +146,28 @@ } PrAssemblyPlan plan = assemblyPlanDao.selectByPrimaryKey(workLast.getPlanId()); // 楠岃瘉骞跺鐞嗚澶囧彿鍜岀墿鏂欏彿 - Set<String> deviceSet = new HashSet<>(Arrays.asList(params.deviceNo.split(","))); + Set<String> deviceSet = new HashSet<>(Arrays.asList(params.deviceNo)); // 鍒嗙被璁惧鍙峰拰鐗╂枡鍙� List<String> deviceList = new ArrayList<>(); - List<String> materialList = new ArrayList<>(); + List<Map<String, String>> materialList = new ArrayList<>(); List<PltProduct> productList = productDao.selectAll(null); - deviceSet.forEach(device -> { - if (device.contains(plan.batchNo)) { - deviceList.add(device); - } else if(isOurProduct(device,productList)){ - materialList.add(device); + deviceSet.forEach(deviceNo -> { + if (deviceNo.contains(plan.batchNo)) { + deviceList.add(deviceNo); + } else { + //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡,濡傛灉鏄�,鍒欐坊鍔犵墿鏂欏埌ex琛ㄤ腑 + Map<String, String> result = queryByDeviceNo(deviceNo, productList); + if (StringUtils.isNotBlank(result.get("proName"))) { + materialList.add(result); + } } }); if (deviceList.isEmpty()) { - throw new RuntimeException("璁惧鍙�(" + params.deviceNo + ")鍧囦笉灞炰簬褰撳墠浠诲姟璁″垝"); + throw new RuntimeException("璁惧鍙�(" + Arrays.toString(params.deviceNo) + ")鍧囦笉灞炰簬褰撳墠浠诲姟璁″垝"); } if (deviceList.size() > 1) { - throw new RuntimeException("璁惧鍙锋湁涓斿彧鑳芥湁涓�涓睘浜庡綋鍓嶄换鍔¤鍒�"); + throw new RuntimeException("鍦ㄤ骇璁惧(" + deviceList.stream().collect(Collectors.joining(",")) + ")鏈変笖鍙兘鏈変竴涓睘浜庡綋鍓嶄换鍔¤鍒�"); } StaDeviceLast deviceLast = buildDeviceLast(params, workLast, deviceList.get(0)); @@ -157,7 +181,7 @@ saveDeviceLife(deviceLast); } if (CollectionUtils.isNotEmpty(materialList)) { - saveSnEx(workLast, deviceList, materialList, plan); + saveSnEx(workLast, deviceList, materialList); } return count; } @@ -172,97 +196,153 @@ private void saveDeviceLife(StaDeviceLast deviceLast) { StaDeviceLife life = new StaDeviceLife(); BeanUtils.copyProperties(deviceLast, life); + life.setId(null); deviceLifeDao.insertSelective(life); + + StaDeviceLifeLast lastLife = new StaDeviceLifeLast(); + BeanUtils.copyProperties(deviceLast, lastLife); + lastLife.setId(null); + int count = deviceLifeLastDao.updateByDeviceNo(lastLife); + if (count == 0) { + deviceLifeLastDao.insertSelective(lastLife); + } } - private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast,String deviceNo) { + private StaDeviceLast buildDeviceLast(QueryVo params, StaAssemblyWorkLast workLast, String deviceNo) { //缁勮鏁版嵁 StaDeviceLast record = new StaDeviceLast(); - + //pr_assembly_plan input_number +1 鎶曞叆鏁板姞1 鏍规嵁deviceNo 鎵惧埌瀵瑰簲浠诲姟 + PrAssemblyPlan assemblyPlan = queryPlanByDeviceNo(deviceNo); //PrAssemblyPlan assemblyPlan = assemblyPlanDao.selectByPrimaryKey(workLast.planId); StaDeviceLast preRecord = deviceLastDao.selectByDeviceNo(deviceNo); if (preRecord != null) { record.id = preRecord.id; record.inTime = preRecord.outTime; + record.outLineTime = preRecord.outLineTime;//涓嬭竟鍒ゆ柇鏄惁缁撴潫浼氱敤鍒� 寰楃暀鐫� + } else { + record.inTime = new Date(); + record.inLineTime = new Date(); + assemblyPlan.setInputNumber(assemblyPlan.getInputNumber() + 1); } record.outTime = new Date(); record.planId = workLast.planId; record.workId = Long.parseLong(params.workId); record.stationId = workLast.stationId; - record.equipNo = deviceNo; + record.deviceNo = deviceNo; record.currNode = workLast.nodeId; record.updatedBy = workLast.userId; - record.assistants = params.assistants; + 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.equipCycleContent = node.equipCycleContent; + record.deviceCycleContent = node.deviceCycleContent; } - record.status = getStatus(params.status, node.isEnd,params.workType); + 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()); return record; } - private void saveSnEx(StaAssemblyWorkLast workLast, List<String> deviceList, List<String> materialList, PrAssemblyPlan plan) { - for (String material : materialList) { + private void saveSnEx(StaAssemblyWorkLast workLast, List<String> deviceList, List<Map<String, String>> materialList) { + for (Map<String, String> material : materialList) { StaWipSnEx snEx = new StaWipSnEx(); snEx.deviceNo = deviceList.get(0); - snEx.productId = plan.process.proId; - snEx.productNo = material; + snEx.productNo = material.get("deviceNo"); + snEx.productName = material.get("proName"); + snEx.productId = Long.parseLong(material.get("proId")); snEx.createTime = workLast.startTime; snEx.createBy = workLast.userId; - snEx.productName = plan.proName; + wipSnExDao.insertSelective(snEx); } } /** - * 鐘舵��: 1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾 - * + * 鍘熺姸鎬�: 0:寰呯敓浜�,1:缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃 + *20240717褰撳墠鐘舵�� 鐘舵��: 1, 缁勮涓�,2:瀹屾垚,3:缁翠慨,4:鎶ュ簾 * @param status 鐘舵�� - * @param isEndNode 鏄惁缁撴潫鑺傜偣 + * @param isEnd 鏄惁缁忓巻杩囩粨鏉熻妭鐐� * @return 鐘舵�� */ - private int getStatus(String status, boolean isEndNode,String workType) { - //缁勮,缁翠慨 - if (WORK_TYPE_ASSEMBLY.equals(workType)||WORK_TYPE_REPAIR.equals(workType)) { + 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)) { return switch (status) { - case QrCodeConstant.MarkOk -> isEndNode? DeviceStatus.COMPLETED.getCode(): DeviceStatus.ASSEMBLING.getCode(); - case QrCodeConstant.MarkUnqualified, QrCodeConstant.MarkPreUnqualified -> DeviceStatus.REPAIR.getCode(); + case QrCodeConstant.MarkOk -> isEnd ? DeviceStatus.COMPLETED.getCode() : DeviceStatus.ASSEMBLING.getCode(); + case QrCodeConstant.MarkUnqualified -> DeviceStatus.REPAIR.getCode(); case QrCodeConstant.MarkWaste -> DeviceStatus.WASTE.getCode(); default -> throw new RuntimeException("鐘舵�侀敊璇�"); }; - //鍝佹,娴嬭瘯 - }else if(WORK_TYPE_INSPECTION.equals(workType)||WORK_TYPE_TEST.equals(workType)){ + } + //缁翠慨 + throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType); + } + /** + * 缁撴灉: 1:閫氳繃,2:娴嬭瘯閫氳繃,3:鍝佹閫氳繃,4:缁翠慨閫氳繃,5:娴嬭瘯涓嶉�氳繃,6:鍝佹涓嶉�氳繃,7:鎶ュ簾 + * @param status 鍓嶇鍑烘潵鐨勭姸鎬� + * @return 缁撴灉 + */ + private Integer getResult(String status, String workType) { + //缁勮 + if (WORK_TYPE_ASSEMBLY.equals(workType)) { return switch (status) { - case QrCodeConstant.MarkOk -> DeviceStatus.COMPLETED.getCode(); - case QrCodeConstant.MarkUnqualified -> DeviceStatus.TEST_FAILED.getCode(); - case QrCodeConstant.MarkWaste -> DeviceStatus.WASTE.getCode(); + case QrCodeConstant.MarkOk -> DeviceResult.PASS.getCode(); + default -> throw new RuntimeException("鐘舵�侀敊璇�"); + }; + //娴嬭瘯 + }else if (WORK_TYPE_TEST.equals(workType)) { + return switch (status) { + case QrCodeConstant.MarkOk -> DeviceResult.TEST_PASS.getCode(); + case QrCodeConstant.MarkUnqualified -> DeviceResult.TEST_FAIL.getCode(); + default -> throw new RuntimeException("鐘舵�侀敊璇�"); + }; + //鍝佹 + }else if (WORK_TYPE_INSPECTION.equals(workType)) { + return switch (status) { + case QrCodeConstant.MarkOk -> DeviceResult.INSPECTION_PASS.getCode(); + case QrCodeConstant.MarkUnqualified -> DeviceResult.INSPECTION_FAIL.getCode(); + default -> throw new RuntimeException("鐘舵�侀敊璇�"); + }; + //缁翠慨 + }else if (WORK_TYPE_REPAIR.equals(workType)) { + return switch (status) { + case QrCodeConstant.MarkOk -> DeviceResult.REPAIR_PASS.getCode(); + case QrCodeConstant.MarkWaste -> DeviceResult.WASTE.getCode(); default -> throw new RuntimeException("鐘舵�侀敊璇�"); }; } throw new RuntimeException("鐘舵�侀敊璇紝鏃犳晥鐨勮妭鐐圭被鍨�: " + workType); } - + @Transactional public int repair(QueryVo vo) { long workId = Long.parseLong(vo.workId); StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId); if (workLast == null) { throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�"); } - StaDeviceLast preDeviceRecord = deviceLastDao.selectByDeviceNo(vo.deviceNo); + StaDeviceLast preDeviceRecord = deviceLastDao.selectByDeviceNo(vo.deviceNo[0]); StaRepairInfo repairInfo = new StaRepairInfo(); repairInfo.workId = workId; - repairInfo.equipNo = vo.deviceNo; + repairInfo.deviceNo = vo.deviceNo[0]; repairInfo.repairTime = new Date(); repairInfo.repairBy = workLast.userId; repairInfo.repairReason = vo.errorMsg; repairInfo.fromNode = preDeviceRecord.currNode; repairInfoDao.insertSelective(repairInfo); - StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo); + StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]); int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) : deviceLastDao.updateByPrimaryKeySelective(deviceLast); @@ -274,44 +354,69 @@ return count; } + @Transactional public int testing(QueryVo vo) { long workId = Long.parseLong(vo.workId); StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId); if (workLast == null) { throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�"); } - - StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo); + StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]); int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) : deviceLastDao.updateByPrimaryKeySelective(deviceLast); saveDeviceProductionLog(deviceLast); + PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); + if (node.isRecord) { + saveDeviceLife(deviceLast); + } return count; } + + @Transactional + public int inspectQuality(QueryVo vo) { + long workId = Long.parseLong(vo.workId); + StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId); + if (workLast == null) { + throw new RuntimeException("绯荤粺涓病鏈夎鏉$櫥褰曚俊鎭�"); + } + StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo[0]); + int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) : + deviceLastDao.updateByPrimaryKeySelective(deviceLast); + saveDeviceProductionLog(deviceLast); + PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); + if (node.isRecord) { + saveDeviceLife(deviceLast); + } + return count; + } + //鏍规嵁鑺傜偣鏌ュ嚭鑺傜偣浣滀笟鎸囧涔� public PrProductionNode getSopByNodeId(String nodeId) { - if(com.alibaba.excel.util.StringUtils.isBlank(nodeId)){ + if (com.alibaba.excel.util.StringUtils.isBlank(nodeId)) { throw new RuntimeException("鑺傜偣ID涓嶈兘涓虹┖"); } PrProductionNode node = nodeDao.selectByPrimaryKey(Long.parseLong(nodeId)); - if(node == null){ + if (node == null) { throw new RuntimeException("鑺傜偣ID涓嶅瓨鍦�,璇锋鏌�"); } - if(node.instruction != null){ + if (node.instruction != null) { addUrl(node.instruction); } - return node; + return node; } + //涓昏鎶�鏈弬鏁� 淇╀釜鏂规硶鍚� platform-->product-->productSv public List<PltProductParams> getParamsByProId(String proId) { - if(StringUtils.isBlank(proId)){ + if (StringUtils.isBlank(proId)) { throw new RuntimeException("浜у搧ID涓嶈兘涓虹┖"); } List<PltProductParams> proParams = paramsDao.selectParams(Long.parseLong(proId)); - return proParams; + return proParams; } + // 鏍规嵁浜у搧鏌ュ嚭浜у搧鏂囦欢 public List<PltProductFile> getFileByProId(String proId) { - if(StringUtils.isBlank(proId)){ + if (StringUtils.isBlank(proId)) { throw new RuntimeException("浜у搧ID涓嶈兘涓虹┖"); } List<PltProductFile> proFiles = productFileDao.selectDocuments(Long.parseLong(proId)); @@ -325,7 +430,7 @@ doc.orgName = file.orgName; doc.extName = file.extName; }); - return proFiles; + return proFiles; } public List<PltProductQualityInspectionItems> getQualityItems(String proId) { @@ -341,16 +446,17 @@ return testItemsDao.selectSome(params); } - private boolean isOurProduct(String deviceNo, List<PltProduct> products){ - if(StringUtils.isNotEmpty(deviceNo) && deviceNo.length() ==22 ){ - for(PltProduct product:products){ - if(deviceNo.startsWith(QrCodeConstant.TypeProduct + product.getCode())){ + private boolean isOurProduct(String deviceNo, List<PltProduct> products) { + if (StringUtils.isNotEmpty(deviceNo) && deviceNo.length() == 22) { + for (PltProduct product : products) { + if (deviceNo.startsWith(QrCodeConstant.TypeProduct + product.getCode())) { return true; } } } return false; } + private void addUrl(PrWorkingInstruction ins) { if (ins == null || ins.fileId == null) { return; @@ -364,6 +470,7 @@ ins.orgName = file.orgName; ins.extName = file.extName; } + private PltProduct addWebUrl(PltProduct pro) { if (pro != null) { if (pro.image != null) { @@ -385,31 +492,59 @@ } return pro; } + private String getFilePathWithWebUrl(Long fileId) { OthFile file = othFileMapper.selectByPrimaryKey(fileId); FileRestVo fileRestVo = fileOperate.parseHashcode(fmUrl, file.hash); return fileRestVo.fileWebUrl + file.filePath; } - public Map<String,String> queryByDeviceNo(String deviceNo) { - Map<String,String> map = new HashMap<>(); + public Map<String, String> queryByDeviceNo(String deviceNo,List<PltProduct> productList) { + Map<String, String> map = new HashMap<>(); map.put("deviceNo", deviceNo); - map.put("proName", "-"); - map.put("proType", "-"); - - PltProduct product = productDao.selectByCode(deviceNo.substring(3,6)); - if(product != null){ + map.put("proName", ""); + map.put("proType", ""); + map.put("proId", ""); + map.put("proCode", ""); + //鍒ゆ柇鏄笉鏄槸鏈巶鐗╂枡 + if(CollectionUtils.isEmpty(productList)){ + productList = productDao.selectAll(null); + } + PltProduct product = null; + if (StringUtils.isNotEmpty(deviceNo) && deviceNo.length() == 22) { + product = productList.stream().filter(p -> deviceNo.startsWith(QrCodeConstant.TypeProduct + p.getCode())).findFirst().orElse(null); + } + if (product != null) { + map.put("deviceNo", deviceNo); map.put("proName", product.getName()); map.put("proType", product.getType()); + BigInteger proId = BigInteger.valueOf(product.getId()); + map.put("proId", proId.toString()); + 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); + } + PrAssemblyPlan plan = assemblyPlanDao.selectByDeviceNo(proCode,lotCode); + if(plan != null){ + plan.setBatchNo(lotCode); + } + return plan; + } public List<StaDeviceLife> queryLifeByDeviceNo(String deviceNo) { - return deviceLifeDao.selectByEquipNo(deviceNo); + return deviceLifeDao.selectByDeviceNo(deviceNo); } public List<StaDeviceProductionLog> queryLogByDeviceNo(String devoiceNo) { - return deviceProductionLogDao.selectByEquipNo(devoiceNo); + return deviceProductionLogDao.selectByDeviceNo(devoiceNo); } + + } -- Gitblit v1.8.0