From 1f06ab808f1dde3cc21651c56e70e6b76786e4c5 Mon Sep 17 00:00:00 2001 From: Fancy <Fancy.fx@outlook.com> Date: 星期四, 01 八月 2024 15:12:45 +0800 Subject: [PATCH] repair --- pms-parent/pms-web-station/src/main/java/com/dy/pmsStation/assemblyStep/AssemblyStepSv.java | 328 ++++++++++++++++++++++++++++++++++++++++++------------ 1 files changed, 254 insertions(+), 74 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..28deed1 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 @@ -33,9 +36,11 @@ 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; + private StaDeviceLifeLastMapper deviceLifeLastDao; private StaWipSnExMapper wipSnExDao; private StaDeviceProductionLogMapper deviceProductionLogDao; private StaAssemblyWorkLastMapper assemblyWorkLastDao; @@ -52,46 +57,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 +133,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,29 +147,33 @@ } 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)); int count = deviceLast.id == null ? deviceLastDao.insertSelective(deviceLast) : - deviceLastDao.updateByPrimaryKeySelective(deviceLast); + deviceLastDao.updateByPrimaryKey(deviceLast); saveDeviceProductionLog(deviceLast); @@ -157,7 +182,7 @@ saveDeviceLife(deviceLast); } if (CollectionUtils.isNotEmpty(materialList)) { - saveSnEx(workLast, deviceList, materialList, plan); + saveSnEx(workLast, deviceList, materialList); } return count; } @@ -172,146 +197,267 @@ 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.inLineTime = preRecord.inLineTime; + 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.planId = assemblyPlan.getId(); 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; - PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); - record.nodeContent = node.content; - if (node.isRecord) { - record.equipCycleContent = node.equipCycleContent; + Boolean isEnd = false;//鏄惁缁忓巻杩囨垨姝e湪缁忓巻缁撴潫鑺傜偣 + if (workLast.nodeId == null) { + if (record.outLineTime != null) { + isEnd = true; + } + } else { + PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); + record.nodeContent = node.content; + 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; + } } - record.status = getStatus(params.status, node.isEnd,params.workType); + record.status = getStatus(params.status, isEnd, workLast.workType.toString()); + record.result = getResult(params.status, workLast.workType.toString()); + assemblyPlanDao.updateByPrimaryKeySelective(assemblyPlan); 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 status 鐘舵�� + * @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.MarkQualified -> 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.MarkQualified -> 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.MarkQualified -> 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; + if(preDeviceRecord!=null) { + repairInfo.fromNode = preDeviceRecord.currNode; + } repairInfoDao.insertSelective(repairInfo); - StaDeviceLast deviceLast = buildDeviceLast(vo, workLast, vo.deviceNo); - + 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) { - saveDeviceLife(deviceLast); + if(preDeviceRecord.currNode != null){ + boolean isEndNode = nodeDao.isEndNode(preDeviceRecord.currNode); + if (isEndNode) { + saveDeviceLife(deviceLast); + } } 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); + deviceLastDao.updateByPrimaryKey(deviceLast); saveDeviceProductionLog(deviceLast); + PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); + if (node != null && 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.updateByPrimaryKey(deviceLast); + saveDeviceProductionLog(deviceLast); + PrProductionNode node = nodeDao.selectByPrimaryKey(workLast.nodeId); + if (node != null && node.isRecord) { + saveDeviceLife(deviceLast); + } + return count; + } + + //鏃犱换鍔¤鍒掍腑鐨勫叾浠� 浼爓orkId ,鎵嬪啓宸ヤ綔鍐呭 , 鏁伴噺 + @Transactional + public int otherWork(QueryVo vo) { + long workId = Long.parseLong(vo.workId); + StaAssemblyWorkLast workLast = assemblyWorkLastDao.selectByPrimaryKey(workId); + 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); + 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,12 +471,13 @@ doc.orgName = file.orgName; doc.extName = file.extName; }); - return proFiles; + return proFiles; } 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); } @@ -338,19 +485,21 @@ public List<PltProductTestInspectionItems> getTestItems(String proId) { Map<String, Object> params = new HashMap<>(); params.put("proId", proId); + params.put("disabled", "0"); 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 +513,7 @@ ins.orgName = file.orgName; ins.extName = file.extName; } + private PltProduct addWebUrl(PltProduct pro) { if (pro != null) { if (pro.image != null) { @@ -385,31 +535,61 @@ } 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