产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yaowanxin
4 天以前 277b5047d00a3e9094bafd5ecb078976fbf6a92d 
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java


@@ -1,25 +1,32 @@


package com.ruoyi.sales.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.mapper.BaseMapper;


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


import com.ruoyi.production.mapper.*;


import com.ruoyi.production.pojo.*;


import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;


import com.ruoyi.purchase.pojo.PurchaseLedger;


import com.ruoyi.sales.dto.InvoiceRegistrationProductDto;


import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.sales.service.ISalesLedgerProductService;


import lombok.AllArgsConstructor;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;




import java.lang.reflect.Field;


import java.math.BigDecimal;


import java.util.Arrays;


import java.util.List;


import java.util.Objects;


import java.util.Set;


import java.time.LocalDate;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.function.Function;


import java.util.stream.Collectors;




@@ -39,6 +46,18 @@




    private PurchaseLedgerMapper purchaseLedgerMapper;




    private ProductOrderMapper productOrderMapper;




    private ProcessRouteItemMapper processRouteItemMapper;




    private ProductProcessRouteItemMapper productProcessRouteItemMapper;




    private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




    private ProcessRouteMapper processRouteMapper;




    private ProductWorkOrderMapper productWorkOrderMapper;




    @Override


    public SalesLedgerProduct selectSalesLedgerProductById(Long id) {


        return salesLedgerProductMapper.selectById(id);


@@ -46,10 +65,32 @@




    @Override


    public List<SalesLedgerProduct> selectSalesLedgerProductList(SalesLedgerProduct salesLedgerProduct) {


        LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>();


        queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerProduct.getSalesLedgerId())


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


        return salesLedgerProductMapper.selectList(queryWrapper);


//        LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>();


//        queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerProduct.getSalesLedgerId())


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


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


        if(!CollectionUtils.isEmpty(salesLedgerProducts)){


            InvoiceRegistrationProductDto invoiceRegistrationProductDto = new InvoiceRegistrationProductDto();


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


            List<InvoiceRegistrationProductDto> invoiceRegistrationProductDtoList = invoiceRegistrationProductMapper.invoiceRegistrationProductList(invoiceRegistrationProductDto);


            // 统计开票登记产品的已开票数/已开票金额


            if (!CollectionUtils.isEmpty(invoiceRegistrationProductDtoList)) {


                for (SalesLedgerProduct ledgerProduct : salesLedgerProducts) {


                    BigDecimal invoiceNum = BigDecimal.ZERO;


                    BigDecimal invoiceAmount = BigDecimal.ZERO;


                    for (InvoiceRegistrationProductDto registrationProductDto : invoiceRegistrationProductDtoList) {


                        if(ledgerProduct.getId().intValue() == registrationProductDto.getSalesLedgerProductId()){


                            invoiceNum =  invoiceNum.add(registrationProductDto.getInvoiceNum());


                            invoiceAmount = invoiceAmount.add(registrationProductDto.getInvoiceAmount());


                        }


                    }


                    ledgerProduct.setInvoiceNum(invoiceNum);


                    ledgerProduct.setInvoiceAmount(invoiceAmount);


                }


            }




        }


        return salesLedgerProducts;


    }




    @Override


@@ -65,7 +106,7 @@


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


        }




        // 可能属于多个主表（但通常一个接口只处理一个主表）


        // 可能属于多个主表


        Set<Long> mainIds = deletedProducts.stream()


                .map(SalesLedgerProduct::getSalesLedgerId)


                .filter(Objects::nonNull)


@@ -73,6 +114,42 @@




        // 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::getRouteId, 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));


            }




            // 批量删除processRouteItem


            productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>()


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




            // 批量删除productOrder


            productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()


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


        }




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


        for (Long salesLedgerId : mainIds) {


@@ -95,11 +172,71 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrUpdateSalesLedgerProduct(SalesLedgerProduct salesLedgerProduct) {


        //未开票数量+金额


        salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());


        salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());


        int result;


        Long salesLedgerId = salesLedgerProduct.getSalesLedgerId();


        if (salesLedgerProduct.getId() == null) {


            result = salesLedgerProductMapper.insert(salesLedgerProduct);


            ProductOrder productOrder = new ProductOrder();


            productOrder.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId());


            productOrder.setProductModelId(salesLedgerProduct.getId());


            productOrder.setNpsNo("SC" + String.format("%08d", salesLedgerProduct.getId()));


            productOrderMapper.insert(productOrder);




            ProcessRoute processRoute = processRouteMapper.selectOne(new QueryWrapper<ProcessRoute>().lambda().eq(ProcessRoute::getProductModelId, salesLedgerProduct.getProductModelId()));


            if (processRoute != null) {


                List<ProcessRouteItem> processRouteItems = processRouteItemMapper.selectList(new QueryWrapper<ProcessRouteItem>().lambda().eq(ProcessRouteItem::getRouteId, processRoute.getId()));


                // 生成当前日期的前缀：年月日


                String datePrefix = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));


                for (ProcessRouteItem processRouteItem : processRouteItems) {


                    ProductProcessRouteItem productProcessRouteItem = new ProductProcessRouteItem();


                    productProcessRouteItem.setProductModelId(processRouteItem.getProductModelId());


                    productProcessRouteItem.setProcessId(processRouteItem.getProcessId());


                    productProcessRouteItem.setRouteId(productOrder.getId());


                    int insert = productProcessRouteItemMapper.insert(productProcessRouteItem);


                    if (insert > 0) {


                        // 查询今日已存在的最大工单号


                        QueryWrapper<ProductWorkOrder> queryWrapper = new QueryWrapper<>();


                        queryWrapper.likeRight("work_order_no", datePrefix)


                                .orderByDesc("work_order_no")


                                .last("LIMIT 1");




                        ProductWorkOrder lastWorkOrder = productWorkOrderMapper.selectOne(queryWrapper);




                        int sequenceNumber = 1; // 默认序号


                        if (lastWorkOrder != null && lastWorkOrder.getWorkOrderNo() != null) {


                            String lastNo = lastWorkOrder.getWorkOrderNo().toString();


                            if (lastNo.startsWith(datePrefix)) {


                                String seqStr = lastNo.substring(datePrefix.length());


                                try {


                                    sequenceNumber = Integer.parseInt(seqStr) + 1;


                                } catch (NumberFormatException e) {


                                    sequenceNumber = 1;


                                }


                            }


                        }


                        // 生成完整的工单号


                        String workOrderNoStr = String.format("%s%03d", datePrefix, sequenceNumber);


                        ProductWorkOrder productWorkOrder = new ProductWorkOrder();


                        productWorkOrder.setProductProcessRouteItemId(productProcessRouteItem.getId());


                        productWorkOrder.setProductOrderId(productOrder.getId());


                        productWorkOrder.setPlanQuantity(salesLedgerProduct.getQuantity());


                        productWorkOrder.setWorkOrderNo(workOrderNoStr);


                        productWorkOrder.setStatus(1);




                        productWorkOrderMapper.insert(productWorkOrder);


                    }




                }


                productOrder.setRouteId(processRoute.getId());


                productOrderMapper.updateById(productOrder);


            }






        } else {


            salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());


            result = salesLedgerProductMapper.updateById(salesLedgerProduct);


        }