| | |
| | | .setMatnrId(matnr.getId()); |
| | | orderItems.add(orderItem); |
| | | |
| | | |
| | | // purchaseItemService.update(new LambdaUpdateWrapper<>().set(PurchaseItem::getAnfme, )); |
| | | |
| | | PurchaseItem purchaseItem = purchaseItemService.getOne(new LambdaQueryWrapper<PurchaseItem>().eq(PurchaseItem::getId, item.getId())); |
| | | if (Objects.isNull(purchaseItem)) { |
| | | throw new CoolException("单据不存在!!"); |
| | | } |
| | | purchaseItem.setQty(purchaseItem.getQty() + item.getAnfme()); |
| | | if (!purchaseItemService.updateById(purchaseItem)) { |
| | | throw new CoolException("PO单明细修改失败!!"); |
| | | } |
| | | } |
| | | |
| | | double sum = orderItems.stream().mapToDouble(AsnOrderItem::getAnfme).sum(); |
| | |
| | | } |
| | | //任务执行完成,修改已完成数量和PO单执行状态 |
| | | purchase.setQty(sum + purchase.getQty()) |
| | | .setAnfme(purchase.getAnfme() - sum) |
| | | .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val); |
| | | |
| | | if (!purchaseService.saveOrUpdate(purchase)) { |
| | |
| | | list.forEach(item -> { |
| | | PurchaseItem purchaseItem = purchaseItemService.getById(item.getPoDetlId()); |
| | | if (!Objects.isNull(purchaseItem)) { |
| | | purchaseItem.setQty(purchaseItem.getQty() - item.getAnfme()) |
| | | .setAnfme(purchaseItem.getAnfme() + item.getAnfme()); |
| | | purchaseItem.setQty(purchaseItem.getQty() - item.getAnfme()); |
| | | } |
| | | if (!purchaseItemService.updateById(purchaseItem)) { |
| | | throw new CoolException("PO单明细更新失败!!"); |
| | |
| | | Purchase purchase = purchaseService.getOne(new LambdaQueryWrapper<Purchase>() |
| | | .eq(Purchase::getCode, list.stream().findFirst().get().getPoCode())); |
| | | purchase.setQty(purchase.getQty() - sum) |
| | | .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val) |
| | | .setAnfme(purchase.getAnfme() + sum); |
| | | .setExceStatus(POExceStatus.PO_EXCE_STATUS_EXCE_ING.val); |
| | | |
| | | if (!purchaseService.updateById(purchase)) { |
| | | throw new CoolException("PO单据更新失败!!"); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | if (!asnOrderItemService.remove(new LambdaQueryWrapper<AsnOrderItem>() |
| | | .in(AsnOrderItem::getAsnId, ids))) { |