From 7883a7291f0b9055b514ee0c7d5d7dfe977cd525 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E5=BF=A0=E6=9E=97?= <170083662@qq.com>
Date: Wed, 30 Jul 2025 18:38:47 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=9F=E8=AE=A1=E8=AE=A2=E5=8D=95=E6=80=BB?=
 =?UTF-8?q?=E9=87=91=E9=A2=9D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../shop/controller/ShopOrderController.java  |  6 ++++++
 .../shop/mapper/ShopOrderMapper.java          | 11 ++++++++++
 .../shop/service/ShopOrderService.java        |  8 ++++++++
 .../service/impl/ShopOrderServiceImpl.java    | 20 +++++++++++++++++++
 4 files changed, 45 insertions(+)

diff --git a/src/main/java/com/gxwebsoft/shop/controller/ShopOrderController.java b/src/main/java/com/gxwebsoft/shop/controller/ShopOrderController.java
index 2d9df04..b18c133 100644
--- a/src/main/java/com/gxwebsoft/shop/controller/ShopOrderController.java
+++ b/src/main/java/com/gxwebsoft/shop/controller/ShopOrderController.java
@@ -207,6 +207,12 @@ public class ShopOrderController extends BaseController {
     return fail("修复失败");
   }
 
+  @Operation(summary = "统计订单总金额")
+  @GetMapping("/total")
+  public ApiResult<BigDecimal> total() {
+    return success(shopOrderService.total());
+  }
+
   @Schema(description = "异步通知")
   @PostMapping("/notify/{tenantId}")
   public String wxNotify(@RequestHeader Map<String, String> header, @RequestBody String body, @PathVariable("tenantId") Integer tenantId) {
diff --git a/src/main/java/com/gxwebsoft/shop/mapper/ShopOrderMapper.java b/src/main/java/com/gxwebsoft/shop/mapper/ShopOrderMapper.java
index 21977a6..88aaf0d 100644
--- a/src/main/java/com/gxwebsoft/shop/mapper/ShopOrderMapper.java
+++ b/src/main/java/com/gxwebsoft/shop/mapper/ShopOrderMapper.java
@@ -6,8 +6,10 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.gxwebsoft.shop.entity.ShopOrder;
 import com.gxwebsoft.shop.param.ShopOrderParam;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -41,4 +43,13 @@ public interface ShopOrderMapper extends BaseMapper<ShopOrder> {
 
     @InterceptorIgnore(tenantLine = "true")
     void updateByOutTradeNo(@Param("param") ShopOrder order);
+
+    /**
+     * 统计订单总金额
+     * 只统计已支付的订单（pay_status = 1）且未删除的订单（deleted = 0）
+     *
+     * @return 订单总金额
+     */
+    @Select("SELECT COALESCE(SUM(pay_price), 0) FROM shop_order WHERE pay_status = 1 AND deleted = 0 AND pay_price IS NOT NULL")
+    BigDecimal selectTotalAmount();
 }
diff --git a/src/main/java/com/gxwebsoft/shop/service/ShopOrderService.java b/src/main/java/com/gxwebsoft/shop/service/ShopOrderService.java
index fdfa4af..08e02ed 100644
--- a/src/main/java/com/gxwebsoft/shop/service/ShopOrderService.java
+++ b/src/main/java/com/gxwebsoft/shop/service/ShopOrderService.java
@@ -5,6 +5,7 @@ import com.gxwebsoft.common.core.web.PageResult;
 import com.gxwebsoft.shop.entity.ShopOrder;
 import com.gxwebsoft.shop.param.ShopOrderParam;
 
+import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 
@@ -47,4 +48,11 @@ public interface ShopOrderService extends IService<ShopOrder> {
     Boolean queryOrderByOutTradeNo(ShopOrder shopOrder);
 
     void updateByOutTradeNo(ShopOrder order);
+
+    /**
+     * 统计订单总金额
+     *
+     * @return 订单总金额
+     */
+    BigDecimal total();
 }
diff --git a/src/main/java/com/gxwebsoft/shop/service/impl/ShopOrderServiceImpl.java b/src/main/java/com/gxwebsoft/shop/service/impl/ShopOrderServiceImpl.java
index 60341d1..2921a5c 100644
--- a/src/main/java/com/gxwebsoft/shop/service/impl/ShopOrderServiceImpl.java
+++ b/src/main/java/com/gxwebsoft/shop/service/impl/ShopOrderServiceImpl.java
@@ -4,6 +4,7 @@
   import cn.hutool.core.util.StrUtil;
   import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
   import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+  import org.springframework.util.CollectionUtils;
   import com.gxwebsoft.common.core.config.ConfigProperties;
   import com.gxwebsoft.common.core.config.CertificateProperties;
   import com.gxwebsoft.common.core.utils.RedisUtil;
@@ -647,4 +648,23 @@ import com.gxwebsoft.common.core.service.PaymentCacheService;
       }
     }
 
+    @Override
+    public BigDecimal total() {
+      try {
+        // 使用数据库聚合查询统计订单总金额，性能更高
+        BigDecimal total = baseMapper.selectTotalAmount();
+
+        if (total == null) {
+          total = BigDecimal.ZERO;
+        }
+
+        log.info("统计订单总金额完成，总金额：{}", total);
+        return total;
+
+      } catch (Exception e) {
+        log.error("统计订单总金额失败", e);
+        return BigDecimal.ZERO;
+      }
+    }
+
   }