产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
9 小时以前 1cf91e355038837f30f2d727507b2229263d7de7 
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java


@@ -8,6 +8,9 @@


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.framework.web.domain.R;


import com.ruoyi.procurementrecord.utils.StockUtils;


import com.ruoyi.production.dto.ProductStructureDto;


import com.ruoyi.production.mapper.*;


import com.ruoyi.production.pojo.*;


import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;


@@ -19,10 +22,14 @@


import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.mapper.ShippingInfoMapper;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.sales.pojo.ShippingInfo;


import com.ruoyi.sales.service.ISalesLedgerProductService;


import com.ruoyi.stock.mapper.StockInventoryMapper;


import com.ruoyi.stock.pojo.StockInventory;


import lombok.AllArgsConstructor;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


@@ -31,6 +38,7 @@




import java.lang.reflect.Field;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.time.LocalDate;


import java.time.format.DateTimeFormatter;


import java.util.*;


@@ -70,6 +78,17 @@


    private ProductionProductOutputMapper productionProductOutputMapper;


    private ProductionProductInputMapper productionProductInputMapper;


    private QualityInspectMapper qualityInspectMapper;


    private ShippingInfoMapper shippingInfoMapper;


    private ShippingInfoServiceImpl shippingInfoService;




    private StockUtils stockUtils;








    @Autowired


    private ProductStructureMapper productStructureMapper;


    @Autowired


    private StockInventoryMapper stockInventoryMapper;




    @Override


    public SalesLedgerProduct selectSalesLedgerProductById(Long id) {


@@ -83,6 +102,20 @@


//                .eq(SalesLedgerProduct::getType, salesLedgerProduct.getType());


        List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectSalesLedgerProductList(salesLedgerProduct);


        if(!CollectionUtils.isEmpty(salesLedgerProducts)){


            salesLedgerProducts.forEach(item -> {


                // 发货信息


                ShippingInfo shippingInfo = shippingInfoMapper.selectOne(new LambdaQueryWrapper<ShippingInfo>()


                        .eq(ShippingInfo::getSalesLedgerProductId, item.getId())


                        .orderByDesc(ShippingInfo::getCreateTime)


                        .last("limit 1"));


                if(shippingInfo != null){


                    item.setShippingDate(shippingInfo.getShippingDate());


                    item.setShippingCarNumber(shippingInfo.getShippingCarNumber());


                    item.setShippingStatus(shippingInfo.getStatus());


                    item.setExpressCompany(shippingInfo.getExpressCompany());


                    item.setExpressNumber(shippingInfo.getExpressNumber());


                }


            });


            // 开票


            InvoiceRegistrationProductDto invoiceRegistrationProductDto = new InvoiceRegistrationProductDto();


            invoiceRegistrationProductDto.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId().intValue());


@@ -106,6 +139,8 @@


                    ledgerProduct.setInvoiceAmount(invoiceAmount);


                    ledgerProduct.setNoInvoiceNum(noInvoiceNum);


                    ledgerProduct.setNoInvoiceAmount(noInvoiceAmount);






                }


            }




@@ -125,6 +160,12 @@


        if (deletedProducts.isEmpty()) {


            return 0; // 没有可删除的数据


        }


        //删除发货信息


        List<ShippingInfo> shippingInfos = shippingInfoMapper.selectList(new LambdaQueryWrapper<ShippingInfo>()


                .in(ShippingInfo::getSalesLedgerProductId, Arrays.asList(ids)));


        if(!CollectionUtils.isEmpty(shippingInfos)){


            shippingInfoService.delete(shippingInfos.stream().map(ShippingInfo::getId).collect(Collectors.toList()));


        }




        // 可能属于多个主表


        Set<Long> mainIds = deletedProducts.stream()


@@ -135,45 +176,7 @@


        // 2. 执行删除操作


        int result = salesLedgerProductMapper.deleteBatchIds(Arrays.asList(ids));


        //删除对应的生产订单


        //批量查询productOrder


        List<ProductOrder> productOrders = productOrderMapper.selectList(


                new LambdaQueryWrapper<ProductOrder>()


                        .in(ProductOrder::getProductModelId, ids)


        );




        if (!CollectionUtils.isEmpty(productOrders)) {


            List<Long> orderIds = productOrders.stream()


                    .map(ProductOrder::getId)


                    .collect(Collectors.toList());




            // 批量查询processRouteItems


            List<ProductProcessRouteItem> allRouteItems = productProcessRouteItemMapper.selectList(


                    new LambdaQueryWrapper<ProductProcessRouteItem>()


                            .in(ProductProcessRouteItem::getProductOrderId, orderIds)


            );




            if (!CollectionUtils.isEmpty(allRouteItems)) {


                List<Long> routeItemIds = allRouteItems.stream()


                        .map(ProductProcessRouteItem::getId)


                        .collect(Collectors.toList());




                // 批量删除workOrder


                productWorkOrderMapper.delete(new LambdaQueryWrapper<ProductWorkOrder>()


                                .in(ProductWorkOrder::getProductProcessRouteItemId, routeItemIds));


            }




            // 批量删除productProcessRouteItem


            productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>()


                            .in(ProductProcessRouteItem::getProductOrderId, orderIds));




            // 批量删除productProcessRoute


            productProcessRouteMapper.delete(new LambdaQueryWrapper<ProductProcessRoute>()


                    .in(ProductProcessRoute::getProductOrderId, orderIds));




            // 批量删除productOrder


            productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()


                    .in(ProductOrder::getProductModelId, ids));


        }


        deleteProductionData(Arrays.asList(ids));




        // 3. 对每个主表ID进行金额更新


        for (Long salesLedgerId : mainIds) {


@@ -478,4 +481,39 @@


            throw new RuntimeException("动态更新主表金额失败", e);


        }


    }


    @Override


    public R judgmentInventory(SalesLedgerProduct salesLedgerProduct) {


        //获取产品最新的工艺路线


        ProcessRoute processRoute = processRouteMapper.selectOne(new QueryWrapper<ProcessRoute>().lambda().eq(ProcessRoute::getProductModelId, salesLedgerProduct.getProductModelId()).orderByDesc(ProcessRoute::getCreateTime).last("LIMIT 1"));


        if (processRoute == null) {


            return R.fail("请先设置工艺路线");


        }


        List<ProductStructureDto> productStructureDtos = productStructureMapper.listBybomId(processRoute.getBomId());


        if (productStructureDtos.isEmpty()) {


            return R.fail("请先设置产品结构");


        }


        int count = 0;


        StringBuilder stringBuffer = new StringBuilder();


        for (ProductStructureDto productStructureDto : productStructureDtos) {


            StockInventory stockInventory = stockInventoryMapper.selectOne(new QueryWrapper<StockInventory>().lambda().eq(StockInventory::getProductModelId, productStructureDto.getProductModelId()));




            //所需数量


            BigDecimal multiply = salesLedgerProduct.getQuantity().multiply(productStructureDto.getUnitQuantity());


            BigDecimal subtract =stockInventory.getQualitity().subtract(stockInventory.getLockedQuantity()).subtract(multiply).divide(BigDecimal.ONE, 2, RoundingMode.CEILING);


            if (subtract.compareTo(BigDecimal.ZERO) <= 0) {


                count++;


                stringBuffer.append(productStructureDto.getProductName())


                        .append("-")


                        .append(productStructureDto.getModel())


                        .append("库存不足，少")


                        .append(subtract)


                        .append(System.lineSeparator());


            }


        }


        if (count>0) {


            return R.fail(stringBuffer.toString());


        }else {


            return R.ok();


        }


    }


}