产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
chenrui
2025-05-20 487b30b77565d9b12f203a1234a93b80a8c59177 
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java


@@ -1,6 +1,7 @@


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.core.toolkit.CollectionUtils;


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


@@ -12,29 +13,37 @@


import com.ruoyi.other.mapper.TempFileMapper;


import com.ruoyi.other.pojo.TempFile;


import com.ruoyi.sales.dto.SalesLedgerDto;


import com.ruoyi.sales.mapper.SalesLedgerFileMapper;


import com.ruoyi.sales.mapper.CommonFileMapper;


import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.CommonFile;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerFile;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.sales.service.ISalesLedgerService;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.io.FilenameUtils;


import org.springframework.beans.BeanUtils;


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


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


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.data.redis.core.script.DefaultRedisScript;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;




import java.io.IOException;


import java.lang.reflect.Field;


import java.math.BigDecimal;


import java.nio.file.*;


import java.nio.file.Files;


import java.nio.file.Path;


import java.nio.file.Paths;


import java.nio.file.StandardCopyOption;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.YearMonth;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.concurrent.TimeUnit;


@@ -58,9 +67,12 @@




    private final SalesLedgerProductMapper salesLedgerProductMapper;




    private final SalesLedgerFileMapper salesLedgerFileMapper;


    private final CommonFileMapper commonFileMapper;




    private final TempFileMapper tempFileMapper;




    @Autowired


    private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




    @Value("${file.upload-dir}")


    private String uploadDir;


@@ -91,11 +103,35 @@


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


        productWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedger.getId());


        List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(productWrapper);


        // 查询未开票金额/未开票数


        if (CollectionUtils.isNotEmpty(products)) {


            QueryWrapper<InvoiceRegistrationProduct> productQueryWrapper = new QueryWrapper<>();


            List<Long> productIds = products.stream().map(SalesLedgerProduct::getId).collect(Collectors.toList());


            productQueryWrapper.in("sales_ledger_product_id", productIds);


            List<InvoiceRegistrationProduct> invoiceRegistrationProductList = invoiceRegistrationProductMapper.selectList(productQueryWrapper);


            if(CollectionUtils.isNotEmpty(invoiceRegistrationProductList)){


                for (SalesLedgerProduct product : products) {


                    for (InvoiceRegistrationProduct invoiceRegistrationProduct : invoiceRegistrationProductList) {


                        Integer salesLedgerProductId = invoiceRegistrationProduct.getSalesLedgerProductId();


                        Long id = product.getId();


                        if( null !=  id && null != salesLedgerProductId && id == salesLedgerProductId.longValue()){


                            product.setFutureTickets(Long.valueOf(invoiceRegistrationProduct.getNoInvoiceNum()));


                            product.setFutureTicketsAmount(invoiceRegistrationProduct.getNoInvoiceAmount());


                        }


                    }


                }


            }else {


                for (SalesLedgerProduct product : products) {


                    product.setFutureTickets(product.getQuantity().longValue());


                    product.setFutureTicketsAmount(product.getTaxInclusiveTotalPrice());


                }


            }


        }




        // 3.查询上传文件


        LambdaQueryWrapper<SalesLedgerFile> salesLedgerFileWrapper = new LambdaQueryWrapper<>();


        salesLedgerFileWrapper.eq(SalesLedgerFile::getLedgerId, salesLedger.getId());


        List<SalesLedgerFile> salesLedgerFiles = salesLedgerFileMapper.selectList(salesLedgerFileWrapper);


        LambdaQueryWrapper<CommonFile> salesLedgerFileWrapper = new LambdaQueryWrapper<>();


        salesLedgerFileWrapper.eq(CommonFile::getCommonId, salesLedger.getId());


        List<CommonFile> salesLedgerFiles = commonFileMapper.selectList(salesLedgerFileWrapper);




        // 4. 转换 DTO


        SalesLedgerDto resultDto = new SalesLedgerDto();


@@ -122,6 +158,33 @@


                        entry -> underlineToCamel(entry.getKey()),


                        Map.Entry::getValue))


        ).collect(Collectors.toList());


    }




    @Override


    public BigDecimal getContractAmount() {


        LocalDate now = LocalDate.now();


        YearMonth currentMonth = YearMonth.from(now);




        // 创建LambdaQueryWrapper


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


        queryWrapper.ge(SalesLedger::getEntryDate, currentMonth.atDay(1).atStartOfDay())  // 大于等于本月第一天


                .lt(SalesLedger::getEntryDate, currentMonth.plusMonths(1).atDay(1).atStartOfDay()); // 小于下月第一天




        // 执行查询并计算总和


        List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(queryWrapper);




        BigDecimal totalContractAmount = salesLedgers.stream()


                .map(SalesLedger::getContractAmount)


                .filter(Objects::nonNull)


                .reduce(BigDecimal.ZERO, BigDecimal::add);




        return totalContractAmount;


    }




    @Override


    public List getTopFiveList() {


        


        return null;


    }




    /**


@@ -192,7 +255,7 @@


            // 4. 处理子表数据


            List<SalesLedgerProduct> productList = salesLedgerDto.getProductData();


            if (productList != null && !productList.isEmpty()) {


                handleSalesLedgerProducts(salesLedger.getId(), productList,salesLedgerDto.getType());


                handleSalesLedgerProducts(salesLedger.getId(), productList, salesLedgerDto.getType());


                updateMainContractAmount(


                        salesLedger.getId(),


                        productList,


@@ -206,7 +269,6 @@


            if (salesLedgerDto.getTempFileIds() != null && !salesLedgerDto.getTempFileIds().isEmpty()) {


                migrateTempFilesToFormal(salesLedger.getId(), salesLedgerDto.getTempFileIds());


            }




            return 1;


        } catch (IOException e) {


            throw new BaseException("文件迁移失败: " + e.getMessage());


@@ -266,12 +328,13 @@


                log.info("文件迁移成功: {} -> {}", tempFile.getTempPath(), formalFilePath);




                // 更新文件记录（关联到业务ID）


                SalesLedgerFile fileRecord = new SalesLedgerFile();


                fileRecord.setLedgerId(businessId);


                CommonFile fileRecord = new CommonFile();


                fileRecord.setCommonId(businessId);


                fileRecord.setName(originalFilename);


                fileRecord.setUrl(formalFilePath.toString());


                fileRecord.setCreateTime(LocalDateTime.now());


                salesLedgerFileMapper.insert(fileRecord);


                fileRecord.setType("1");


                commonFileMapper.insert(fileRecord);




                // 删除临时文件记录


                tempFileMapper.deleteById(tempFile);


@@ -286,7 +349,7 @@


    }






    private void handleSalesLedgerProducts(Long salesLedgerId, List<SalesLedgerProduct> products,Integer type) {


    private void handleSalesLedgerProducts(Long salesLedgerId, List<SalesLedgerProduct> products, Integer type) {


        // 按ID分组，区分新增和更新的记录


        Map<Boolean, List<SalesLedgerProduct>> partitionedProducts = products.stream()


                .peek(p -> p.setSalesLedgerId(salesLedgerId))