| | |
| | | import com.ruoyi.account.pojo.AccountIncome; |
| | | import com.ruoyi.account.service.AccountIncomeService; |
| | | import com.ruoyi.common.enums.SaleEnum; |
| | | import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum; |
| | | import com.ruoyi.common.enums.StockOutUnQualifiedRecordTypeEnum; |
| | | import com.ruoyi.common.utils.DateUtils; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | | import com.ruoyi.framework.security.LoginUser; |
| | | import com.ruoyi.procurementrecord.utils.StockUtils; |
| | | import com.ruoyi.sales.pojo.SalesLedgerProduct; |
| | | import com.ruoyi.quality.pojo.QualityInspect; |
| | | import com.ruoyi.quality.mapper.QualityInspectMapper; |
| | | import com.ruoyi.purchase.dto.PurchaseReturnOrderDto; |
| | | import com.ruoyi.purchase.dto.PurchaseReturnOrderProductsDto; |
| | | import com.ruoyi.purchase.mapper.PurchaseReturnOrderProductsMapper; |
| | |
| | | @Resource |
| | | private AccountIncomeService accountIncomeService; |
| | | |
| | | @Resource |
| | | private StockUtils stockUtils; |
| | | |
| | | @Resource |
| | | private QualityInspectMapper qualityInspectMapper; |
| | | |
| | | @Override |
| | | public IPage<PurchaseReturnOrderVo> listPage(Page page, PurchaseReturnOrderDto purchaseReturnOrderDto) { |
| | | return purchaseReturnOrdersMapper.listPage(page, purchaseReturnOrderDto); |
| | |
| | | this.save(purchaseReturnOrderDto); |
| | | |
| | | if (!purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos().isEmpty()) { |
| | | // 先查询所有销售台账产品信息,用于后续库存扣减 |
| | | List<Long> productIds = purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos().stream() |
| | | .map(PurchaseReturnOrderProductsDto::getSalesLedgerProductId) |
| | | .distinct() |
| | | .filter(Objects::nonNull) |
| | | .collect(Collectors.toList()); |
| | | List<SalesLedgerProduct> salesLedgerProducts = salesLedgerService.getSalesLedgerProductListByIds(productIds, SaleEnum.PURCHASE); |
| | | Map<Long, SalesLedgerProduct> productMap = salesLedgerProducts.stream() |
| | | .collect(Collectors.toMap(SalesLedgerProduct::getId, product -> product)); |
| | | |
| | | for (PurchaseReturnOrderProductsDto purchaseReturnOrderProductsDto : purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos()) { |
| | | purchaseReturnOrderProductsDto.setSalesLedgerProductId(purchaseReturnOrderProductsDto.getSalesLedgerProductId()); |
| | | purchaseReturnOrderProductsDto.setPurchaseReturnOrderId(purchaseReturnOrderDto.getId()); |
| | |
| | | // 这里为新增因此id为null |
| | | purchaseReturnOrderProductsDto.setId(null); |
| | | purchaseReturnOrderProductsMapper.insert(purchaseReturnOrderProductsDto); |
| | | |
| | | // 同步进行库存扣减和出库记录 |
| | | SalesLedgerProduct salesLedgerProduct = productMap.get(purchaseReturnOrderProductsDto.getSalesLedgerProductId()); |
| | | if (salesLedgerProduct != null && salesLedgerProduct.getProductModelId() != null) { |
| | | // 根据 SalesLedgerProduct 中的 isChecked 判断是否需要质检 |
| | | Boolean isChecked = salesLedgerProduct.getIsChecked(); |
| | | if (Boolean.TRUE.equals(isChecked)) { |
| | | // 需要质检,根据质检结果判断 |
| | | LambdaQueryWrapper<QualityInspect> inspectQueryWrapper = new LambdaQueryWrapper<>(); |
| | | inspectQueryWrapper.eq(QualityInspect::getPurchaseLedgerId, purchaseReturnOrderDto.getPurchaseLedgerId()); |
| | | QualityInspect inspect = qualityInspectMapper.selectOne(inspectQueryWrapper); |
| | | if (inspect == null) { |
| | | throw new RuntimeException("该采购订单没有质检记录"); |
| | | } |
| | | // 获取质检记录的结果 |
| | | String checkResult = inspect.getCheckResult(); |
| | | if ("合格".equals(checkResult)) { |
| | | // 质检合格,扣减合格库存 |
| | | stockUtils.substractStock( |
| | | salesLedgerProduct.getProductModelId(), |
| | | purchaseReturnOrderProductsDto.getReturnQuantity(), |
| | | StockOutQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(), |
| | | purchaseReturnOrderDto.getId() |
| | | ); |
| | | } else if ("不合格".equals(checkResult)) { |
| | | // 质检不合格,扣减不合格库存 |
| | | stockUtils.subtractUnStock( |
| | | salesLedgerProduct.getProductModelId(), |
| | | purchaseReturnOrderProductsDto.getReturnQuantity(), |
| | | StockOutUnQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(), |
| | | purchaseReturnOrderDto.getId() |
| | | ); |
| | | } else { |
| | | throw new RuntimeException("质检结果不正确: " + checkResult); |
| | | } |
| | | } else { |
| | | // 不需要质检,扣减合格库存 |
| | | stockUtils.substractStock( |
| | | salesLedgerProduct.getProductModelId(), |
| | | purchaseReturnOrderProductsDto.getReturnQuantity(), |
| | | StockOutQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(), |
| | | purchaseReturnOrderDto.getId() |
| | | ); |
| | | } |
| | | } |
| | | } |
| | | }else { |
| | | throw new RuntimeException("请选择退货商品"); |
| | |
| | | updateWrapperAccountIncome.eq(AccountIncome::getIncomeType, 4); |
| | | accountIncomeService.remove(updateWrapperAccountIncome); |
| | | } |
| | | } |
| | | } |