From 2c38fb7ab234af82a0575c828e7c2b696f74c441 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期二, 21 四月 2026 09:51:24 +0800
Subject: [PATCH] feat: 采购业务汇总统计接口

---
 src/main/java/com/ruoyi/purchase/controller/ProcurementBusinessSummaryController.java    |   14 +++-
 src/main/resources/mapper/sales/SalesLedgerProductMapper.xml                             |  106 +++++++++++++++++++++++++----------
 src/main/java/com/ruoyi/purchase/dto/ProcurementBusinessSummaryStatisticsDto.java        |   22 +++++++
 src/main/java/com/ruoyi/sales/mapper/SalesLedgerProductMapper.java                       |   10 ++-
 src/main/java/com/ruoyi/purchase/service/impl/ProcurementBusinessSummaryServiceImpl.java |    9 ++-
 5 files changed, 120 insertions(+), 41 deletions(-)

diff --git a/src/main/java/com/ruoyi/purchase/controller/ProcurementBusinessSummaryController.java b/src/main/java/com/ruoyi/purchase/controller/ProcurementBusinessSummaryController.java
index 9370ddb..a4f93ab 100644
--- a/src/main/java/com/ruoyi/purchase/controller/ProcurementBusinessSummaryController.java
+++ b/src/main/java/com/ruoyi/purchase/controller/ProcurementBusinessSummaryController.java
@@ -8,7 +8,7 @@
 import com.ruoyi.framework.web.controller.BaseController;
 import com.ruoyi.framework.web.domain.AjaxResult;
 import com.ruoyi.purchase.dto.ProcurementBusinessSummaryDto;
-import com.ruoyi.purchase.pojo.PurchaseLedger;
+import com.ruoyi.purchase.dto.ProcurementBusinessSummaryStatisticsDto;
 import com.ruoyi.purchase.service.impl.ProcurementBusinessSummaryServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -19,7 +19,6 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletResponse;
-import java.util.List;
 
 /**
  * @author :yys
@@ -35,8 +34,15 @@
     private ProcurementBusinessSummaryServiceImpl procurementBusinessSummaryService;
 
     @GetMapping("/listPage")
-    public AjaxResult listPage(Page page, ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
+    public AjaxResult listPage(Page<?> page, ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
         return AjaxResult.success(procurementBusinessSummaryService.listPage(page, procurementBusinessSummaryDto));
+    }
+
+    @ApiOperation("閲囪喘涓氬姟姹囨�荤粺璁★紙閲囪喘鎬婚/鍟嗗搧绉嶇被/閫�娆炬�婚锛�")
+    @GetMapping("/statistics")
+    public AjaxResult statistics(ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
+        ProcurementBusinessSummaryStatisticsDto stats = procurementBusinessSummaryService.statistics(procurementBusinessSummaryDto);
+        return AjaxResult.success(stats);
     }
 
     /**
@@ -45,7 +51,7 @@
     @Log(title = "瀵煎嚭閲囪喘鎶ヨ〃", businessType = BusinessType.EXPORT)
     @PostMapping("/export")
     public void export(HttpServletResponse response, ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
-        Page page = new Page(-1,-1);
+        Page<?> page = new Page<>(-1, -1);
         IPage<ProcurementBusinessSummaryDto> list = procurementBusinessSummaryService.listPage(page, procurementBusinessSummaryDto);
         ExcelUtil<ProcurementBusinessSummaryDto> util = new ExcelUtil<ProcurementBusinessSummaryDto>(ProcurementBusinessSummaryDto.class);
         util.exportExcel(response, list.getRecords(), "閲囪喘鎶ヨ〃");
diff --git a/src/main/java/com/ruoyi/purchase/dto/ProcurementBusinessSummaryStatisticsDto.java b/src/main/java/com/ruoyi/purchase/dto/ProcurementBusinessSummaryStatisticsDto.java
new file mode 100644
index 0000000..d34deda
--- /dev/null
+++ b/src/main/java/com/ruoyi/purchase/dto/ProcurementBusinessSummaryStatisticsDto.java
@@ -0,0 +1,22 @@
+package com.ruoyi.purchase.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+@Data
+@ApiModel("閲囪喘涓氬姟鏁版嵁缁熻")
+public class ProcurementBusinessSummaryStatisticsDto {
+
+    @ApiModelProperty("閲囪喘鎬婚")
+    private BigDecimal purchaseTotalAmount;
+
+    @ApiModelProperty("鍟嗗搧鍝佺被锛堝晢鍝佸垎绫伙級")
+    private Integer productCategoryCount;
+
+    @ApiModelProperty("閫�璐ф�婚")
+    private BigDecimal returnTotalAmount;
+}
+
diff --git a/src/main/java/com/ruoyi/purchase/service/impl/ProcurementBusinessSummaryServiceImpl.java b/src/main/java/com/ruoyi/purchase/service/impl/ProcurementBusinessSummaryServiceImpl.java
index ea0a3f8..09c5ab3 100644
--- a/src/main/java/com/ruoyi/purchase/service/impl/ProcurementBusinessSummaryServiceImpl.java
+++ b/src/main/java/com/ruoyi/purchase/service/impl/ProcurementBusinessSummaryServiceImpl.java
@@ -2,10 +2,9 @@
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.ruoyi.framework.web.domain.AjaxResult;
 import com.ruoyi.purchase.dto.ProcurementBusinessSummaryDto;
+import com.ruoyi.purchase.dto.ProcurementBusinessSummaryStatisticsDto;
 import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
-import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -21,7 +20,11 @@
     @Autowired
     private SalesLedgerProductMapper salesLedgerProductMapper;
 
-    public IPage<ProcurementBusinessSummaryDto> listPage(Page page, ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
+    public IPage<ProcurementBusinessSummaryDto> listPage(Page<?> page, ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
         return salesLedgerProductMapper.procurementBusinessSummaryListPage(page, procurementBusinessSummaryDto);
     }
+
+    public ProcurementBusinessSummaryStatisticsDto statistics(ProcurementBusinessSummaryDto procurementBusinessSummaryDto) {
+        return salesLedgerProductMapper.procurementBusinessSummaryStatistics(procurementBusinessSummaryDto);
+    }
 }
diff --git a/src/main/java/com/ruoyi/sales/mapper/SalesLedgerProductMapper.java b/src/main/java/com/ruoyi/sales/mapper/SalesLedgerProductMapper.java
index 686fc2e..bd095e7 100644
--- a/src/main/java/com/ruoyi/sales/mapper/SalesLedgerProductMapper.java
+++ b/src/main/java/com/ruoyi/sales/mapper/SalesLedgerProductMapper.java
@@ -3,8 +3,8 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ruoyi.common.config.MyBaseMapper;
-import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.purchase.dto.ProcurementBusinessSummaryDto;
+import com.ruoyi.purchase.dto.ProcurementBusinessSummaryStatisticsDto;
 import com.ruoyi.sales.dto.LossProductModelDto;
 import com.ruoyi.sales.dto.SalesLedgerProductDto;
 import com.ruoyi.sales.pojo.SalesLedgerProduct;
@@ -28,11 +28,13 @@
 
     SalesLedgerProduct selectSalesLedgerProductByMainId(@Param("productMainId") Long productMainId);
 
-    IPage<SalesLedgerProductDto> listPage(Page page, @Param("req") SalesLedgerProductDto salesLedgerProduct);
+    IPage<SalesLedgerProductDto> listPage(Page<?> page, @Param("req") SalesLedgerProductDto salesLedgerProduct);
 
-    IPage<SalesLedgerProductDto> listPagePurchaseLedger(Page page, @Param("req") SalesLedgerProductDto salesLedgerProduct);
+    IPage<SalesLedgerProductDto> listPagePurchaseLedger(Page<?> page, @Param("req") SalesLedgerProductDto salesLedgerProduct);
 
-    IPage<ProcurementBusinessSummaryDto> procurementBusinessSummaryListPage(Page page, @Param("req") ProcurementBusinessSummaryDto procurementBusinessSummaryDto);
+    IPage<ProcurementBusinessSummaryDto> procurementBusinessSummaryListPage(Page<?> page, @Param("req") ProcurementBusinessSummaryDto procurementBusinessSummaryDto);
+
+    ProcurementBusinessSummaryStatisticsDto procurementBusinessSummaryStatistics(@Param("req") ProcurementBusinessSummaryDto procurementBusinessSummaryDto);
 
     List<LossProductModelDto> selectProductBomStructure(@Param("salesLedegerId") Long salesLedegerId);
 
diff --git a/src/main/resources/mapper/sales/SalesLedgerProductMapper.xml b/src/main/resources/mapper/sales/SalesLedgerProductMapper.xml
index 64adc3f..46db172 100644
--- a/src/main/resources/mapper/sales/SalesLedgerProductMapper.xml
+++ b/src/main/resources/mapper/sales/SalesLedgerProductMapper.xml
@@ -104,42 +104,88 @@
         </where>
         order by slp.register_date desc
     </select>
+
     <select id="procurementBusinessSummaryListPage"
             resultType="com.ruoyi.purchase.dto.ProcurementBusinessSummaryDto">
         SELECT
-        slp.product_category AS productCategory,
-        slp.specification_model AS specificationModel,
-        sl.supplier_name AS supplierName,
-        SUM(slp.quantity) AS purchaseNum,
-        SUM(slp.tax_inclusive_total_price) AS purchaseAmount,
-        COUNT(DISTINCT slp.sales_ledger_id) AS purchaseTimes,
-        <!-- 骞冲潎鍗曚环 = 鎬婚噰璐噾棰�/鎬婚噰璐暟閲忥紝淇濈暀2浣嶅皬鏁帮紝閬垮厤闄�0 -->
-        ROUND(IF(SUM(slp.quantity) = 0, 0, SUM(slp.tax_inclusive_total_price) / SUM(slp.quantity)), 2) AS averagePrice,
-        <!-- 璇ヤ骇鍝佸ぇ绫讳笅鏈�鍚庝竴涓綍鍏ユ棩鏈燂紙鍙栧彴璐︿富琛ㄧ殑entry_date锛� -->
-        MAX(sl.entry_date) AS entryDate,
-        COALESCE(NULLIF(SUM(t1.return_quantity), 0), 0) AS return_quantity,
-        COALESCE(SUM(t2.total_amount), 0) AS return_amount,
-        pm.thickness
+            slp.product_category AS productCategory,
+            slp.specification_model AS specificationModel,
+            sl.supplier_name AS supplierName,
+            SUM(slp.quantity) AS purchaseNum,
+            SUM(slp.tax_inclusive_total_price) AS purchaseAmount,
+            COUNT(DISTINCT slp.sales_ledger_id) AS purchaseTimes,
+            <!-- 骞冲潎鍗曚环 = 鎬婚噰璐噾棰�/鎬婚噰璐暟閲忥紝淇濈暀2浣嶅皬鏁帮紝閬垮厤闄�0 -->
+            ROUND(IF(SUM(slp.quantity) = 0, 0, SUM(slp.tax_inclusive_total_price) / SUM(slp.quantity)), 2) AS averagePrice,
+            <!-- 璇ュ垎缁勪笅鏈�鍚庝竴涓綍鍏ユ棩鏈燂紙鍙栧彴璐︿富琛ㄧ殑entry_date锛� -->
+            MAX(sl.entry_date) AS entryDate,
+            COALESCE(SUM(rop.return_quantity), 0) AS return_quantity,
+            COALESCE(SUM(rop.allocated_return_amount), 0) AS return_amount,
+            pm.thickness
         FROM sales_ledger_product slp
-        <!-- 鍏宠仈鍙拌处涓昏〃锛氳幏鍙栧綍鍏ユ棩鏈焑ntry_date -->
-        LEFT JOIN purchase_ledger sl ON slp.sales_ledger_id = sl.id
-        left join purchase_return_order_products as t1 on t1.sales_ledger_product_id = slp.id
-        left join purchase_return_orders as t2 on t2.id = t1.purchase_return_order_id
-        left join product_model pm on pm.id = slp.product_model_id
+            <!-- 鍏宠仈鍙拌处涓昏〃锛氳幏鍙栧綍鍏ユ棩鏈焑ntry_date -->
+            LEFT JOIN purchase_ledger sl ON slp.sales_ledger_id = sl.id
+            LEFT JOIN (
+                SELECT
+                    t1.sales_ledger_product_id,
+                    t1.return_quantity,
+                    IF(q.sum_qty = 0 OR q.sum_qty IS NULL, 0, (t2.total_amount * (t1.return_quantity / q.sum_qty))) AS allocated_return_amount
+                FROM purchase_return_order_products t1
+                    INNER JOIN purchase_return_orders t2 ON t2.id = t1.purchase_return_order_id
+                    INNER JOIN (
+                        SELECT purchase_return_order_id, SUM(return_quantity) AS sum_qty
+                        FROM purchase_return_order_products
+                        GROUP BY purchase_return_order_id
+                    ) q ON q.purchase_return_order_id = t1.purchase_return_order_id
+            ) rop ON rop.sales_ledger_product_id = slp.id
+            LEFT JOIN product_model pm ON pm.id = slp.product_model_id
         WHERE slp.type = 2 <!-- 鍥哄畾绛涢�夛細閲囪喘鍙拌处锛坱ype=2锛� -->
-        <!-- 閲囪喘鏃ユ湡绛涢�夛細鍙�夋潯浠� -->
-        <if test="req.entryDateStart != null and req.entryDateEnd != null">
-            AND sl.entry_date BETWEEN #{req.entryDateStart} AND #{req.entryDateEnd} <!-- 鏃堕棿鑼冨洿锛氶潪绌烘湁鏁� -->
-        </if>
-        <!-- 浜у搧澶х被绛涢�夛細鍙�夋潯浠� -->
-        <if test="req.productCategory != null and req.productCategory != ''">
-            AND slp.product_category = #{req.productCategory}
-        </if>
-        <!-- 鎸変骇鍝佸ぇ绫诲垎缁勮仛鍚� -->
-        GROUP BY slp.product_category
-        <!-- 鎸変骇鍝佸ぇ绫绘帓搴� -->
-        ORDER BY slp.product_category
+            <!-- 閲囪喘鏃ユ湡绛涢�夛細鍙�夋潯浠� -->
+            <if test="req.entryDateStart != null and req.entryDateEnd != null">
+                AND sl.entry_date BETWEEN #{req.entryDateStart} AND #{req.entryDateEnd} <!-- 鏃堕棿鑼冨洿锛氶潪绌烘湁鏁� -->
+            </if>
+            <!-- 浜у搧澶х被绛涢�夛細鍙�夋潯浠� -->
+            <if test="req.productCategory != null and req.productCategory != ''">
+                AND slp.product_category = #{req.productCategory}
+            </if>
+        <!-- 鎸夊垎缁勭淮搴﹁仛鍚堬紙閬垮厤 ONLY_FULL_GROUP_BY 閿欒涓庝笉纭畾鍊硷級 -->
+        GROUP BY
+            slp.product_category,
+            slp.specification_model,
+            sl.supplier_name,
+            pm.thickness
+        ORDER BY
+            slp.product_category
     </select>
+
+    <select id="procurementBusinessSummaryStatistics"
+            resultType="com.ruoyi.purchase.dto.ProcurementBusinessSummaryStatisticsDto">
+        SELECT
+            COALESCE(SUM(slp.tax_inclusive_total_price), 0) AS purchaseTotalAmount,
+            COALESCE(COUNT(DISTINCT slp.product_category), 0) AS productCategoryCount,
+            COALESCE(SUM(rop.allocated_return_amount), 0) AS returnTotalAmount
+        FROM sales_ledger_product slp
+            LEFT JOIN purchase_ledger sl ON slp.sales_ledger_id = sl.id
+            LEFT JOIN (
+                SELECT
+                    t1.sales_ledger_product_id,
+                    IF(q.sum_qty = 0 OR q.sum_qty IS NULL, 0, (t2.total_amount * (t1.return_quantity / q.sum_qty))) AS allocated_return_amount
+                FROM purchase_return_order_products t1
+                    INNER JOIN purchase_return_orders t2 ON t2.id = t1.purchase_return_order_id
+                    INNER JOIN (
+                        SELECT purchase_return_order_id, SUM(return_quantity) AS sum_qty
+                        FROM purchase_return_order_products
+                        GROUP BY purchase_return_order_id
+                    ) q ON q.purchase_return_order_id = t1.purchase_return_order_id
+            ) rop ON rop.sales_ledger_product_id = slp.id
+        WHERE slp.type = 2
+            <if test="req.entryDateStart != null and req.entryDateEnd != null">
+                AND sl.entry_date BETWEEN #{req.entryDateStart} AND #{req.entryDateEnd}
+            </if>
+            <if test="req.productCategory != null and req.productCategory != ''">
+                AND slp.product_category = #{req.productCategory}
+            </if>
+    </select>
+
     <select id="selectProductBomStructure" resultType="com.ruoyi.sales.dto.LossProductModelDto">
         select
             a.model,

--
Gitblit v1.9.3