From 32d0aa7ac0034561d3b8b5a9d35a54ba1cace6a6 Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期二, 06 五月 2025 17:00:08 +0800 Subject: [PATCH] #pda物料组托 --- rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java | 153 +++++++++++++++++++++++++++++++------------------- 1 files changed, 95 insertions(+), 58 deletions(-) diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java index 537556c..3edd8e4 100644 --- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java +++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java @@ -23,6 +23,7 @@ import com.vincent.rsf.server.manager.entity.*; import com.vincent.rsf.server.manager.enums.AsnExceStatus; import com.vincent.rsf.server.manager.enums.PakinIOStatus; +import com.vincent.rsf.server.manager.enums.QlyIsptResult; import com.vincent.rsf.server.manager.enums.QlyIsptStatus; import com.vincent.rsf.server.manager.mapper.*; import com.vincent.rsf.server.manager.service.*; @@ -254,10 +255,14 @@ // if (dto.getReceiptQty().compareTo(dto.getAnfme()) > 0) { // throw new CoolException("鏀惰揣鏁伴噺涓嶈兘澶т簬閲囪喘鏁伴噺锛侊紒"); // } - AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>() - .eq(AsnOrderItem::getAsnCode, asnCode) - .eq(AsnOrderItem::getTrackCode, dto.getBarcode()) - .eq(AsnOrderItem::getMatnrId, dto.getMatnrId())); +// AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>() +// .eq(AsnOrderItem::getAsnCode, asnCode) +// .eq(AsnOrderItem::getId, dto.getId()) +// .eq(AsnOrderItem::getTrackCode, dto.getBarcode()) +// .eq(AsnOrderItem::getSplrBatch, dto.getSplrBatch())); + + AsnOrderItem orderItem = asnOrderItemMapper.resultById(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getId, dto.getId())); + if (Objects.isNull(orderItem)) { throw new CoolException("閫氱煡鍗曟槑缁嗕笉瀛樺湪锛侊紒"); } @@ -289,49 +294,9 @@ if (asnOrderItemMapper.updateById(orderItem) < 1) { throw new CoolException("閫氱煡鍗曟槑缁嗘暟閲忎慨鏀瑰け璐ワ紒锛�"); } + /**淇濆瓨鏄庣粏鑷虫敹璐у尯**/ + extracted(loginUserId, dto, areasItem, orderItem, asnOrder, matnr); - WarehouseAreasItem item = new WarehouseAreasItem(); -// SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); -// String format = null; -// if (Objects.isNull(dto.getProdTime())) { -// format = dateFormat.format(dto.getProdTime()); -// } - item.setTrackCode(dto.getBarcode()) - .setAreaName(areasItem.getName()) - .setAreaId(areasItem.getId()) - .setAsnItemId(orderItem.getId()) - .setAsnCode(asnOrder.getCode()) - .setAsnId(asnOrder.getId()) - .setProdTime(dto.getProdTime()) - .setWeight(dto.getWeigth()) - //搴撳瓨鍗曚綅涓烘渶灏忓崟浣� - .setUnit(orderItem.getStockUnit()) - .setStockUnit(orderItem.getStockUnit()) - .setBatch(StringUtils.isBlank(orderItem.getBatch()) ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto) : orderItem.getBatch()) - .setAnfme(dto.getReceiptQty()) - .setSplrBatch(dto.getSplrBatch()) - .setMatnrCode(matnr.getCode()) - .setUpdateBy(loginUserId) - .setCreateBy(loginUserId) - .setMatnrId(matnr.getId()) - .setMaktx(matnr.getName()) - .setWeight(matnr.getWeight()) - .setFieldsIndex(orderItem.getFieldsIndex()) - .setShipperId(matnr.getShipperId()); - //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲 - - WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>() - .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId()) - .eq(WarehouseAreasItem::getTrackCode, item.getTrackCode()) - .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch())); - if (!Objects.isNull(serviceOne)) { - item.setAnfme(item.getAnfme() + serviceOne.getAnfme()); - item.setId(serviceOne.getId()); - } - - if (!warehouseAreasItemService.saveOrUpdate(item)) { - throw new CoolException("鏀惰揣澶辫触锛侊紒"); - } } AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, asnCode)); @@ -343,6 +308,65 @@ } return R.ok("鏀惰揣鎴愬姛锛侊紒"); + } + + private void extracted(Long loginUserId, ReceiptDetlsDto dto, WarehouseAreas areasItem, AsnOrderItem orderItem, AsnOrder asnOrder, Matnr matnr) { + WarehouseAreasItem item = new WarehouseAreasItem(); + item.setTrackCode(dto.getBarcode()) + .setAreaName(areasItem.getName()) + .setAreaId(areasItem.getId()) + .setAsnItemId(orderItem.getId()) + .setAsnCode(asnOrder.getCode()) + .setAsnId(asnOrder.getId()) + .setProdTime(dto.getProdTime()) + .setWeight(dto.getWeigth()) + //搴撳瓨鍗曚綅涓烘渶灏忓崟浣� + .setUnit(orderItem.getStockUnit()) + .setStockUnit(orderItem.getStockUnit()) + .setBatch(StringUtils.isBlank(orderItem.getBatch()) ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto) : orderItem.getBatch()) + .setAnfme(dto.getReceiptQty()) + .setSplrBatch(dto.getSplrBatch()) + .setMatnrCode(matnr.getCode()) + .setUpdateBy(loginUserId) + .setCreateBy(loginUserId) + .setMatnrId(matnr.getId()) + .setMaktx(matnr.getName()) + .setWeight(matnr.getWeight()) + .setFieldsIndex(orderItem.getFieldsIndex()) + .setShipperId(matnr.getShipperId()); + //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲 + WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>() + .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId()) + .eq(WarehouseAreasItem::getTrackCode, item.getTrackCode()) + .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch())); + if (!Objects.isNull(serviceOne)) { + item.setAnfme(item.getAnfme() + serviceOne.getAnfme()); + } + + //鏈川妫� + if (!warehouseAreasItemService.saveOrUpdate(item)) { + throw new CoolException("鏀惰揣澶辫触锛侊紒"); + } + +// if (null != orderItem.getSafeQty() || null != orderItem.getDisQty() ) { +// +// } +// else { +// //涓嶅悎鏍兼暟閲� +// if (orderItem.getDisQty().compareTo(0.00) > 0) { +// item.setIsptQty(orderItem.getDisQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val); +// if (!warehouseAreasItemService.saveOrUpdate(item)) { +// throw new CoolException("鏀惰揣澶辫触锛侊紒"); +// } +// } +// +// item.setIsptQty(orderItem.getSafeQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val); +// if (!warehouseAreasItemService.saveOrUpdate(item)) { +// throw new CoolException("鏀惰揣澶辫触锛侊紒"); +// } +// } + + } /** @@ -358,7 +382,9 @@ } List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>() .eq(AsnOrderItem::getAsnCode, params.getAsnCode()) - .eq(!Objects.isNull(params.getTrackCode()), AsnOrderItem::getTrackCode, params.getTrackCode())); + .eq(!Objects.isNull(params.getTrackCode()), AsnOrderItem::getTrackCode, params.getTrackCode()) + .eq(!Cools.isEmpty(params.getMatnrCode()), AsnOrderItem::getMatnrCode, params.getMatnrCode()) + ); if (Objects.isNull(asnOrderItem)) { throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�"); @@ -420,8 +446,9 @@ * @time 2025/4/7 16:58 */ @Override - public R getDeltByCode(Map<String, Object> params ) { - String code = params.get("code").toString(); + public R getDeltByCode(Map<String, Object> params) { + Object code = params.get("code"); + Object matnrCode = params.get("matnrCode"); String batch = null; if (!Objects.isNull(params.get("batch"))) { batch = params.get("batch").toString(); @@ -429,10 +456,11 @@ //TODO 鍚庣画闇�鏍规嵁绛栫暐閰嶇疆锛岃幏鍙栫粍鎷栨暟鎹�傚锛氭贩瑁咃紝鎸夋壒娆℃贩瑁呯瓑 LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new QueryWrapper<WarehouseAreasItem>() .select("SUM(anfme) as anfme, track_code, asn_code, id, splr_batch, ispt_result, plat_item_id, batch,unit, stock_unit, qty, work_qty, matnr_code, matnr_id, maktx").lambda() - .eq(StringUtils.isNotBlank(code), WarehouseAreasItem::getTrackCode, code) + .eq(!Objects.isNull(code), WarehouseAreasItem::getTrackCode, code) .eq(StringUtils.isNotBlank(batch), WarehouseAreasItem::getSplrBatch, batch) + .eq(!Objects.isNull(matnrCode), WarehouseAreasItem::getMatnrCode, matnrCode) .groupBy(WarehouseAreasItem::getSplrBatch, WarehouseAreasItem::getAsnId, WarehouseAreasItem::getAreaId, WarehouseAreasItem::getMatnrId); - return R.ok(warehouseAreasItemService.getOne(queryWrapper, false)); + return R.ok(warehouseAreasItemService.list(queryWrapper)); } /** @@ -446,6 +474,11 @@ @Override public WaitPakin mergeItems(WaitPakinParam waitPakin, Long userId) { return waitPakinService.mergeItems(waitPakin, userId); + } + + @Override + public WaitPakin mergeMatnrItems(WaitPakinParam waitPakin, Long userId) { + return waitPakinService.mergeMatnrItems(waitPakin, userId); } /** @@ -938,6 +971,7 @@ ReceiptDetlsDto detlsDto = new ReceiptDetlsDto(); detlsDto.setAsnCode(asnOrderItem.getAsnCode()) + .setId(asnOrderItem.getId()) .setMaktx(asnOrderItem.getMaktx()) .setFieldsIndex(asnOrderItem.getFieldsIndex()) .setBarcode(asnOrderItem.getTrackCode()) @@ -947,7 +981,10 @@ .setPoCode(asnOrderItem.getPoCode()) .setAnfme(asnOrderItem.getAnfme()) .setPurQty(asnOrderItem.getPurQty()) - .setSplrBatch(asnOrderItem.getSplrBatch()); + .setSplrBatch(asnOrderItem.getSplrBatch()) + .setMatnr(asnOrderItem.getMatnrCode()) + .setInspect(asnOrderItem.getIsptResult$()) //璐ㄦ缁撴灉 + ; Matnr matnr = matnrMapper.selectById(asnOrderItem.getMatnrId()); if (Objects.isNull(matnr)) { @@ -956,12 +993,12 @@ //SET 鐗╂枡鏈�澶у瓨鏀炬暟閲� detlsDto.setMaxQty(matnr.getMaxQty()) .setMatnrId(matnr.getId()); - QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>() - .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId())); - if (!Objects.isNull(inspect)) { - //set 璐ㄦ缁撴灉 - detlsDto.setInspect(inspect.getStatus$()); - } +// QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>() +// .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId())); +// if (!Objects.isNull(inspect)) { +// //set 璐ㄦ缁撴灉 +// detlsDto.setInspect(inspect.getStatus$()); +// } //鑾峰彇褰撳墠搴撳瓨淇℃伅 LocItem stockItem = locItemService.getOne(new LambdaQueryWrapper<LocItem>() // .eq(LocItem::getOrderItemId, asnOrderItem.getId()) -- Gitblit v1.9.1