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


@@ -11,18 +11,16 @@


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.other.mapper.TempFileMapper;


import com.ruoyi.other.pojo.TempFile;


import com.ruoyi.sales.dto.MonthlyAmountDto;


import com.ruoyi.sales.dto.SalesLedgerDto;


import com.ruoyi.sales.mapper.CommonFileMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.CommonFile;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.*;


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;


@@ -32,9 +30,13 @@


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;


@@ -61,6 +63,13 @@


    private final CommonFileMapper commonFileMapper;




    private final TempFileMapper tempFileMapper;




    private final ReceiptPaymentMapper receiptPaymentMapper;




    private final InvoiceLedgerMapper invoiceLedgerMapper;




    @Autowired


    private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




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


    private String uploadDir;


@@ -122,6 +131,139 @@


                        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() {


        // 查询原始数据


        LambdaQueryWrapper<SalesLedger> queryWrapper = Wrappers.lambdaQuery();


        queryWrapper.select(SalesLedger::getCustomerId,


                        SalesLedger::getCustomerName,


                        SalesLedger::getContractAmount)


                .orderByDesc(SalesLedger::getContractAmount);


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




        // 按客户ID分组并聚合金额


        Map<Long, GroupedCustomer> groupedMap = new LinkedHashMap<>(); // 使用LinkedHashMap保持排序


        for (SalesLedger record : records) {


            groupedMap.computeIfAbsent(record.getCustomerId(),


                            k -> new GroupedCustomer(record.getCustomerId(), record.getCustomerName()))


                    .addAmount(record.getContractAmount());


        }




        // 转换为结果列表并取前5


        return groupedMap.values().stream()


                .sorted(Comparator.comparing(GroupedCustomer::getTotalAmount).reversed())


                .limit(5)


                .map(customer -> {


                    Map<String, Object> result = new HashMap<>();


                    result.put("customerId", customer.getCustomerId());


                    result.put("customerName", customer.getCustomerName());


                    result.put("totalAmount", customer.getTotalAmount());


                    return result;


                })


                .collect(Collectors.toList());


    }




    @Override


    public List<MonthlyAmountDto> getAmountHalfYear() {


        LocalDate now = LocalDate.now();


        YearMonth currentMonth = YearMonth.from(now);




        List<MonthlyAmountDto> monthlyAmounts = new ArrayList<>();




        for (int i = 0; i < 6; i++) {


            YearMonth targetMonth = currentMonth.minusMonths(i);


            LocalDate firstDayOfMonth = targetMonth.atDay(1);


            LocalDate firstDayOfNextMonth = targetMonth.plusMonths(1).atDay(1);




            LocalDateTime startOfMonth = firstDayOfMonth.atStartOfDay();


            LocalDateTime startOfNextMonth = firstDayOfNextMonth.atStartOfDay();




            LambdaQueryWrapper<ReceiptPayment> receiptPaymentLambdaQueryWrapper = new LambdaQueryWrapper<>();


            receiptPaymentLambdaQueryWrapper.ge(ReceiptPayment::getCreateTime, startOfMonth)


                    .lt(ReceiptPayment::getCreateTime, startOfNextMonth);




            LambdaQueryWrapper<InvoiceLedger> invoiceLedgerLambdaQueryWrapper = new LambdaQueryWrapper<>();


            invoiceLedgerLambdaQueryWrapper.ge(InvoiceLedger::getCreateTime, startOfMonth)


                    .lt(InvoiceLedger::getCreateTime, startOfNextMonth);




            // 获取回款金额


            List<ReceiptPayment> receiptPaymentList = receiptPaymentMapper.selectList(receiptPaymentLambdaQueryWrapper);


            //开票金额


            List<InvoiceLedger> invoiceLedgerList = invoiceLedgerMapper.selectList(invoiceLedgerLambdaQueryWrapper);




            // 使用 Stream 求和


            BigDecimal invoiceAmount = invoiceLedgerList.stream()


                    .map(InvoiceLedger::getInvoiceTotal)


                    .filter(Objects::nonNull)


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




            BigDecimal receiptAmount = receiptPaymentList.stream()


                    .map(ReceiptPayment::getReceiptPaymentAmount)


                    .filter(Objects::nonNull)


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




            MonthlyAmountDto monthlyAmount = new MonthlyAmountDto();


            monthlyAmount.setMonth(targetMonth.format(DateTimeFormatter.ofPattern("yyyy-MM")));


            monthlyAmount.setInvoiceAmount(invoiceAmount);


            monthlyAmount.setReceiptAmount(receiptAmount);




            monthlyAmounts.add(monthlyAmount);


        }




        return monthlyAmounts;


    }




    // 内部类用于存储聚合结果


    private static class GroupedCustomer {


        private final Long customerId;


        private final String customerName;


        private BigDecimal totalAmount = BigDecimal.ZERO;




        public GroupedCustomer(Long customerId, String customerName) {


            this.customerId = customerId;


            this.customerName = customerName;


        }




        public void addAmount(BigDecimal amount) {


            if (amount != null) {


                this.totalAmount = this.totalAmount.add(amount);


            }


        }




        public Long getCustomerId() {


            return customerId;


        }




        public String getCustomerName() {


            return customerName;


        }




        public BigDecimal getTotalAmount() {


            return totalAmount;


        }


    }




    /**


@@ -192,7 +334,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 +348,6 @@


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


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


            }




            return 1;


        } catch (IOException e) {


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


@@ -287,7 +428,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))


@@ -307,6 +448,8 @@


        if (!insertList.isEmpty()) {


            for (SalesLedgerProduct salesLedgerProduct : insertList) {


                salesLedgerProduct.setType(type);


                salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity().intValue());


                salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());


                salesLedgerProductMapper.insert(salesLedgerProduct);


            }


        }