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


@@ -4,33 +4,30 @@


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.ProcessRouteItemMapper;


import com.ruoyi.production.mapper.ProcessRouteMapper;


import com.ruoyi.production.mapper.ProductOrderMapper;


import com.ruoyi.production.mapper.ProductProcessRouteItemMapper;


import com.ruoyi.production.pojo.ProcessRoute;


import com.ruoyi.production.pojo.ProcessRouteItem;


import com.ruoyi.production.pojo.ProductOrder;


import com.ruoyi.production.pojo.ProductProcessRouteItem;


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.*;


import java.time.LocalDate;


import java.time.format.DateTimeFormatter;


import java.util.Arrays;


import java.util.List;


import java.util.Objects;


import java.util.Set;


import java.util.function.Function;


import java.util.stream.Collectors;




@@ -53,11 +50,14 @@


    private ProductOrderMapper productOrderMapper;




    private ProcessRouteItemMapper processRouteItemMapper;




    private ProductProcessRouteItemMapper productProcessRouteItemMapper;


    @Autowired




    private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;


    @Autowired




    private ProcessRouteMapper processRouteMapper;




    private ProductWorkOrderMapper productWorkOrderMapper;




    @Override


    public SalesLedgerProduct selectSalesLedgerProductById(Long id) {


@@ -104,10 +104,10 @@


        // 1. 先查询要删除的子表记录，获取对应的 salesLedgerId


        List<SalesLedgerProduct> deletedProducts = salesLedgerProductMapper.selectBatchIds(Arrays.asList(ids));


        if (deletedProducts.isEmpty()) {


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


            return 0;


        }




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


        // 可能属于多个主表


        Set<Long> mainIds = deletedProducts.stream()


                .map(SalesLedgerProduct::getSalesLedgerId)


                .filter(Objects::nonNull)


@@ -116,12 +116,40 @@


        // 2. 执行删除操作


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


        //删除对应的生产订单


        for (Long id : ids) {


            ProductOrder productOrder = productOrderMapper.selectOne(new LambdaQueryWrapper<ProductOrder>().eq(ProductOrder::getProductModelId, id));


            if (productOrder != null) {


                productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>().eq(ProductProcessRouteItem::getRouteId, productOrder.getId()));


                productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>().eq(ProductOrder::getProductModelId, id));


        //批量查询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进行金额更新


@@ -161,12 +189,45 @@


            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(productOrder.getProductModelId());


                    productProcessRouteItem.setProductModelId(processRouteItem.getProductModelId());


                    productProcessRouteItem.setProcessId(processRouteItem.getProcessId());


                    productProcessRouteItem.setRouteId(productOrder.getId());


                    productProcessRouteItemMapper.insert(productProcessRouteItem);


                    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.setWorkOrderNo(workOrderNoStr);


                        productWorkOrder.setStatus(1);




                        productWorkOrderMapper.insert(productWorkOrder);


                    }




                }


                productOrder.setRouteId(processRoute.getId());


                productOrderMapper.updateById(productOrder);