From 7125d7c2be53db25b8a11d42abc8730b36ef61bc Mon Sep 17 00:00:00 2001 From: yangyang Date: 星期二, 15 七月 2025 13:23:30 +0800 Subject: [PATCH] 任务工作档生成播种明细 --- zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java | 70 +++++++++++++++++++---------------- 1 files changed, 38 insertions(+), 32 deletions(-) diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java index 71af48e..8c4ccf6 100644 --- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java +++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/manage/OutManage.java @@ -1021,9 +1021,10 @@ * 鏍规嵁涓嶅悓搴撲綅绫诲瀷鐢熸垚鍑哄簱鎷h揣鍗曟垨CTU浠诲姟妗� * * @param dto - * @param wave + * @param */ - private void outStockByArea(OrderOutMergeParamDto dto, Wave wave) { + @Transactional(rollbackFor = Exception.class) + public void outStockByArea(OrderOutMergeParamDto dto, Wave wave) { List<OrderOutMergeParam> params = dto.getList(); if (params.isEmpty()) { throw new CoolException("鍙傛暟涓嶈兘涓虹┖"); @@ -1137,9 +1138,12 @@ } String matUniqueKey = Utils.getMatUniqueKey(taskDetl.getMatnr(), taskDetl.getBatch(), taskDetl.getUniqueField()); - WaveDetl waveDetl = waveDetlService.getOne(new LambdaQueryWrapper<WaveDetl>().eq(WaveDetl::getStockIndex, matUniqueKey).eq(WaveDetl::getWaveId, wave.getId())); + logger.error("Matnr------>{}", taskDetl.getMatnr()); + WaveDetl waveDetl = waveDetlService.getOne(new LambdaQueryWrapper<WaveDetl>() + .eq(WaveDetl::getStockIndex, matUniqueKey) + .eq(WaveDetl::getWaveId, wave.getId())); if (waveDetl == null) { - throw new CoolException("娉㈡鏁版嵁涓嶅瓨鍦�"); + throw new CoolException("waveId:" + wave.getId() + "鐗╂枡锛�" + taskDetl.getMatnr() + "娉㈡鏁版嵁涓嶅瓨鍦�"); } waveDetl.setWorkQty(waveDetl.getWorkQty() + taskDetl.getAnfme()); waveDetl.setUpdateTime(new Date()); @@ -1153,28 +1157,30 @@ throw new CoolException("褰撳墠娉㈡璁㈠崟涓嶅瓨鍦紒锛�"); } - List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>() - .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel, task.getTargetSite())); +// List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>() +// .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel, task.getTargetSite())); +// +// if (cacheSites.isEmpty()) { +// throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�"); +// } +// +// if (cacheSites.size() < orders.size()) { +// throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�"); +// } - if (cacheSites.isEmpty()) { - throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�"); - } - - if (cacheSites.size() < orders.size()) { - throw new CoolException("缂撳瓨绔欑┖闂翠笉瓒筹紝璇风◢鍚庡啀璇�"); - } - - for (int i = 0; i < orders.size(); i++) { - CacheSite cacheSite = cacheSites.get(i); - cacheSite.setOrderId(orders.get(i).getId()); - cacheSite.setOrderNo(orders.get(i).getOrderNo()); - cacheSite.setSiteStatus(CacheSiteStatusType.R.id); - cacheSite.setBarcode(loc.getBarcode()); - cacheSite.setUpdateTime(new Date()); - if (!cacheSiteService.updateById(cacheSite)) { - throw new CoolException("缂撳瓨绔欐洿鏂板け璐�"); - } - } +// for (int i = 0; i < orders.size(); i++) { +// CacheSite cacheSite = cacheSiteService.getOne(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderId, orders.get(i).getId())); +// if (Objects.isNull(cacheSite)) { +// cacheSite.setOrderId(orders.get(i).getId()); +// cacheSite.setOrderNo(orders.get(i).getOrderNo()); +// cacheSite.setSiteStatus(CacheSiteStatusType.R.id); +// cacheSite.setBarcode(loc.getBarcode()); +// cacheSite.setUpdateTime(new Date()); +// if (!cacheSiteService.updateById(cacheSite)) { +// throw new CoolException("缂撳瓨绔欐洿鏂板け璐�"); +// } +// } +// } //搴撲綅F => R loc.setLocStsId(LocStsType.R.val()); @@ -1226,7 +1232,7 @@ /** * @author Ryan * @date 2025/7/4 - * @description: 鐢熼潰鎷h揣鏄庣粏 + * @description: 鐢熸垚鎷h揣鏄庣粏 * @version 1.0 */ @Transactional(rollbackFor = Exception.class) @@ -1496,12 +1502,12 @@ continue; } OrderOutMergeDto outMergeParam = new OrderOutMergeDto(); - outMergeParam.setAnfme(outLocDetl.getAnfme()) - .setLocNo(outLocDetl.getLocNo()) - .setLocDetlId(detl.getId()) - .setLocId(detl.getLocId()) - .setMatnr(outLocDetl.getMatnr()) - .setBatch(detl.getBatch()); + outMergeParam.setAnfme(outLocDetl.getAnfme()); + outMergeParam.setLocNo(outLocDetl.getLocNo()); + outMergeParam.setLocDetlId(detl.getId()); + outMergeParam.setLocId(detl.getLocId()); + outMergeParam.setMatnr(outLocDetl.getMatnr()); + outMergeParam.setBatch(detl.getBatch()); orders.add(outMergeParam); //鏍规嵁搴撲綅ID鍒嗙粍 -- Gitblit v1.9.1