产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
maven
5 天以前 9aec7c5d4e11dcd66f0c886c759bbaa54efe6211 
 src/main/java/com/ruoyi/sales/controller/SalesLedgerController.java


@@ -1,5 +1,6 @@


package com.ruoyi.sales.controller;




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


import com.baomidou.mybatisplus.core.metadata.IPage;


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


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


@@ -8,20 +9,38 @@


import com.ruoyi.framework.aspectj.lang.enums.BusinessType;


import com.ruoyi.framework.web.controller.BaseController;


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


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


import com.ruoyi.framework.web.page.TableDataInfo;


import com.ruoyi.sales.dto.InvoiceLedgerDto;


import com.ruoyi.sales.dto.SalesLedgerDto;


import com.ruoyi.sales.mapper.InvoiceLedgerMapper;


import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;


import com.ruoyi.sales.mapper.ReceiptPaymentMapper;


import com.ruoyi.sales.pojo.InvoiceLedger;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.ReceiptPayment;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.service.ICommonFileService;


import com.ruoyi.sales.service.ISalesLedgerService;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import io.swagger.annotations.ApiParam;


import lombok.AllArgsConstructor;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.util.CollectionUtils;


import org.springframework.web.bind.annotation.*;


import org.springframework.web.multipart.MultipartFile;




import javax.servlet.http.HttpServletResponse;


import java.io.FileNotFoundException;


import java.io.IOException;


import java.io.InputStream;


import java.io.OutputStream;


import java.math.BigDecimal;


import java.net.URLEncoder;


import java.util.ArrayList;


import java.util.Collection;


import java.util.List;


import java.util.Objects;


import java.util.stream.Collectors;


@@ -35,6 +54,8 @@


@RestController


@RequestMapping("/sales/ledger")


@AllArgsConstructor


@Api(tags = "销售台账")


@Slf4j


public class SalesLedgerController extends BaseController {




    private ISalesLedgerService salesLedgerService;


@@ -43,6 +64,62 @@




    @Autowired


    private InvoiceLedgerMapper invoiceLedgerMapper;




    @Autowired


    private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




    @Autowired


    private ReceiptPaymentMapper receiptPaymentMapper;




    /**


     * 导入销售台账


     */


    @Log(title = "导入销售台账", businessType = BusinessType.INSERT)


    @PostMapping("/import")


    @ApiOperation("导入销售台账")


    public AjaxResult importData(@RequestParam("file")


                                 @ApiParam(value = "Excel文件", required = true)


                                 MultipartFile file) {


        return salesLedgerService.importData(file);


    }




    @ApiOperation("导出销售台账模板")


    @PostMapping("/exportTemplate")


    public void exportTemplate(HttpServletResponse response) {


        // 1. 模板文件在resources/static下的路径


        String templatePath = "static/销售台账导入模板.xlsx";




        // 2. 获取模板文件的输入流


        try (InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream(templatePath)) {


            if (inputStream == null) {


                throw new FileNotFoundException("模板文件不存在：" + templatePath);


            }




            // 3. 设置响应头，触发浏览器下载


            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");


            response.setCharacterEncoding("utf-8");


            String fileName = URLEncoder.encode("销售台账导入模板.xlsx", "utf-8").replaceAll("\\+", "%20");


            response.setHeader("Content-disposition", "attachment;filename*=utf-8''" + fileName);




            // 4. 将模板文件写入响应输出流


            try (OutputStream outputStream = response.getOutputStream()) {


                byte[] buffer = new byte[1024];


                int len;


                while ((len = inputStream.read(buffer)) > 0) {


                    outputStream.write(buffer, 0, len);


                }


                outputStream.flush();


            }


        } catch (IOException e) {


            log.error("导出销售台账模板失败", e);


            // 若模板文件读取失败，返回错误提示


            try {


                response.getWriter().write("模板导出失败：" + e.getMessage());


            } catch (IOException ex) {


                log.error("响应输出错误", ex);


            }


        }


    }




    /**


     * 查询销售台账列表


@@ -65,10 +142,10 @@


                if (salesLedger.getId().intValue() == invoiceLedgerDto.getSalesLedgerId()) {


                    BigDecimal noInvoiceAmountTotal = salesLedger.getContractAmount().subtract(invoiceLedgerDto.getInvoiceTotal());


                    salesLedger.setNoInvoiceAmountTotal(noInvoiceAmountTotal);




                }


            }


        }




        return getDataTable(list);


    }




@@ -89,6 +166,20 @@


        List<SalesLedger> list = salesLedgerService.selectSalesLedgerList(salesLedgerDto);


        ExcelUtil<SalesLedger> util = new ExcelUtil<SalesLedger>(SalesLedger.class);


        util.exportExcel(response, list, "销售台账数据");


    }




    /**


     * 导出开票登记列表


     */


    @Log(title = "导出开票登记列表", businessType = BusinessType.EXPORT)


    @PostMapping("/exportOne")


    public void exportOne(HttpServletResponse response, SalesLedgerDto salesLedgerDto) {


        Page page = new Page();


        page.setCurrent(-1);


        page.setSize(-1);


        IPage<SalesLedger> salesLedgerIPage = listPage(page, salesLedgerDto);


        ExcelUtil<SalesLedger> util = new ExcelUtil<SalesLedger>(SalesLedger.class);


        util.exportExcel(response, salesLedgerIPage == null ? new ArrayList<>() : salesLedgerIPage.getRecords(), "导出开票登记列表");


    }




    /**


@@ -161,8 +252,8 @@


     * 近半年开票,回款金额


     */


    @GetMapping("/getAmountHalfYear")


    public AjaxResult getAmountHalfYear() {


        return AjaxResult.success(salesLedgerService.getAmountHalfYear());


    public AjaxResult getAmountHalfYear(@RequestParam(value = "type",defaultValue = "1") Integer type) {


        return AjaxResult.success(salesLedgerService.getAmountHalfYear(type));


    }




    /**


@@ -180,6 +271,17 @@


        if(CollectionUtils.isEmpty(invoiceLedgerDtoList)){


            return iPage;


        }


        // 计算回款金额，待回款金额


        List<InvoiceRegistrationProduct> invoiceRegistrationProducts = invoiceRegistrationProductMapper.selectList(new LambdaQueryWrapper<InvoiceRegistrationProduct>()


                .in(InvoiceRegistrationProduct::getSalesLedgerId, salesLedgerIds));




        List<InvoiceLedger> invoiceLedgers = invoiceLedgerMapper.selectList(new LambdaQueryWrapper<InvoiceLedger>()


                .in(InvoiceLedger::getInvoiceRegistrationProductId, invoiceRegistrationProducts.stream().map(InvoiceRegistrationProduct::getId).collect(Collectors.toList())));


        List<ReceiptPayment> receiptPayments = new ArrayList<>();


        if(!CollectionUtils.isEmpty(invoiceLedgers)){


            receiptPayments = receiptPaymentMapper.selectList(new LambdaQueryWrapper<ReceiptPayment>()


                    .in(ReceiptPayment::getInvoiceLedgerId, invoiceLedgers.stream().map(InvoiceLedger::getId).collect(Collectors.toList())));


        }


        for (SalesLedger salesLedger : iPage.getRecords()) {


            boolean existFlag = false;


            BigDecimal noInvoiceAmountTotal = BigDecimal.ZERO;


@@ -189,6 +291,26 @@


                    noInvoiceAmountTotal = salesLedger.getContractAmount().subtract(invoiceLedgerDto.getInvoiceTotal());


                    invoiceTotal = invoiceLedgerDto.getInvoiceTotal();


                    existFlag = true;


                    if(!CollectionUtils.isEmpty(receiptPayments)){


                        List<InvoiceRegistrationProduct> collect = invoiceRegistrationProducts.stream()


                                .filter(item -> salesLedger.getId().equals(Long.parseLong(item.getSalesLedgerId().toString())))


                                .collect(Collectors.toList());


                        List<Integer> collect1 = collect.stream()


                                .map(InvoiceRegistrationProduct::getId).collect(Collectors.toList());


                        List<InvoiceLedger> collect2 = invoiceLedgers.stream()


                                .filter(item -> collect1.contains(item.getInvoiceRegistrationProductId()))


                                .collect(Collectors.toList());


                        // 获取已回款金额


                        List<ReceiptPayment> collect3 = receiptPayments.stream()


                                .filter(item -> collect2.stream().anyMatch(item1 -> item1.getId().equals(item.getInvoiceLedgerId())))


                                .collect(Collectors.toList());


                        BigDecimal receiptPaymentAmountTotal = collect3.stream().map(ReceiptPayment::getReceiptPaymentAmount)


                                .filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add);


                        // 获取待回款金额


                        BigDecimal noReceiptPaymentAmountTotal = invoiceLedgerDto.getInvoiceTotal().subtract(receiptPaymentAmountTotal);


                        salesLedger.setReceiptPaymentAmountTotal(receiptPaymentAmountTotal);


                        salesLedger.setNoReceiptAmount(noReceiptPaymentAmountTotal);


                    }


                    break;


                }


            }


@@ -202,8 +324,16 @@


        if (ObjectUtils.isNotEmpty(salesLedgerDto.getStatus())) {


            if (salesLedgerDto.getStatus()) {


                iPage.getRecords().removeIf(salesLedger -> Objects.equals(salesLedger.getNoInvoiceAmountTotal(), new BigDecimal("0.00")));


                iPage.setTotal(iPage.getRecords().size());


            }


        }




        return iPage;


    }




    @ApiOperation("查询销售台账消耗物料信息")


    @GetMapping("/getSalesLedgerWithProductsLoss")


    public R getSalesLedgerWithProductsLoss(Long salesLedgerId) {


        return R.ok(salesLedgerService.getSalesLedgerWithProductsLoss(salesLedgerId));


    }


}