From d6c5d0e95d62a195211aacaa91f28592659db567 Mon Sep 17 00:00:00 2001
From: xupei <xupei3360@163.com>
Date: Mon, 23 Jun 2025 10:53:30 +0800
Subject: [PATCH] =?UTF-8?q?TASK:=E6=9F=A5=E8=AF=A2=E4=BA=A4=E6=98=93?=
 =?UTF-8?q?=E8=AE=B0=E5=BD=95=20=E6=B7=BB=E5=8A=A0=E6=98=BE=E7=A4=BA?=
 =?UTF-8?q?=E6=80=BB=E9=87=91=E9=A2=9D=E5=92=8C=E4=BB=98=E6=AC=BE=E8=80=85?=
 =?UTF-8?q?=E9=82=AE=E7=AE=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../response/TransactionPageResponse.java     | 15 +++++++
 .../da/mapper/primary/PaymentInfoMapper.java  |  5 +++
 .../com/ai/da/model/vo/PaymentInfoVO.java     |  2 +
 .../impl/ConvenientInquiryServiceImpl.java    | 10 ++++-
 .../mapper/primary/PaymentInfoMapper.xml      | 39 +++++++++++++++++++
 5 files changed, 69 insertions(+), 2 deletions(-)
 create mode 100644 src/main/java/com/ai/da/common/response/TransactionPageResponse.java

diff --git a/src/main/java/com/ai/da/common/response/TransactionPageResponse.java b/src/main/java/com/ai/da/common/response/TransactionPageResponse.java
new file mode 100644
index 00000000..25200d49
--- /dev/null
+++ b/src/main/java/com/ai/da/common/response/TransactionPageResponse.java
@@ -0,0 +1,15 @@
+package com.ai.da.common.response;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+@Data
+@NoArgsConstructor
+@ApiModel("交易记录分页响应结果")
+public class TransactionPageResponse<T> extends PageBaseResponse<T> {
+
+    private BigDecimal totalAmount;
+}
diff --git a/src/main/java/com/ai/da/mapper/primary/PaymentInfoMapper.java b/src/main/java/com/ai/da/mapper/primary/PaymentInfoMapper.java
index 9384ad6b..0dc85cce 100644
--- a/src/main/java/com/ai/da/mapper/primary/PaymentInfoMapper.java
+++ b/src/main/java/com/ai/da/mapper/primary/PaymentInfoMapper.java
@@ -6,6 +6,7 @@ import com.ai.da.model.vo.PaymentInfoVO;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.math.BigDecimal;
 import java.util.List;
 import java.util.Map;
 
@@ -24,6 +25,10 @@ public interface PaymentInfoMapper extends BaseMapper<PaymentInfo> {
                                          String country, String city, String startTime, String endTime, String payer
     );
 
+    BigDecimal queryTotalPaymentAmount(String paymentType,String payerTotal, String type, String status,
+                                       String country, String city, String startTime, String endTime, String payer
+    );
+
     List<Map<String, String>> getCities();
 
     List<Map<String, String>> getCountries();
diff --git a/src/main/java/com/ai/da/model/vo/PaymentInfoVO.java b/src/main/java/com/ai/da/model/vo/PaymentInfoVO.java
index caa1955c..98ac7f14 100644
--- a/src/main/java/com/ai/da/model/vo/PaymentInfoVO.java
+++ b/src/main/java/com/ai/da/model/vo/PaymentInfoVO.java
@@ -13,6 +13,8 @@ public class PaymentInfoVO {
     private Long id;
     @ApiModelProperty("付款用户名")
     private String payer;
+    @ApiModelProperty("付款者邮箱")
+    private String email;
     @ApiModelProperty("选择的支付平台 PayPal || Stripe || Alipay-HK")
     private String platform;
     @ApiModelProperty("支付的金额 单位:HKD")
diff --git a/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java b/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java
index 8e92d0a8..2f5804a4 100644
--- a/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java
@@ -5,6 +5,7 @@ import com.ai.da.common.constant.CommonConstant;
 import com.ai.da.common.context.UserContext;
 import com.ai.da.common.enums.CreditsEventsEnum;
 import com.ai.da.common.response.PageBaseResponse;
+import com.ai.da.common.response.TransactionPageResponse;
 import com.ai.da.common.utils.CopyUtil;
 import com.ai.da.common.utils.DateUtil;
 import com.ai.da.mapper.primary.*;
@@ -610,16 +611,21 @@ public class ConvenientInquiryServiceImpl extends ServiceImpl<QuestionnaireMappe
                 queryPaymentInfoDTO.getType(), queryPaymentInfoDTO.getStatus(),
                 queryPaymentInfoDTO.getCountry(), queryPaymentInfoDTO.getCity(),
                 queryPaymentInfoDTO.getStartTime(), queryPaymentInfoDTO.getEndTime(), queryPaymentInfoDTO.getPayer());
-
+        // 查询符合查询条件的总金额
+        BigDecimal payerTotal = paymentInfoMapper.queryTotalPaymentAmount(queryPaymentInfoDTO.getPlatform(), queryPaymentInfoDTO.getPayerTotal(),
+                queryPaymentInfoDTO.getType(), queryPaymentInfoDTO.getStatus(),
+                queryPaymentInfoDTO.getCountry(), queryPaymentInfoDTO.getCity(),
+                queryPaymentInfoDTO.getStartTime(), queryPaymentInfoDTO.getEndTime(), queryPaymentInfoDTO.getPayer());
         // 总页数
         double totalPage = Math.ceil((double) total / size);
         // 组装返回参数
-        PageBaseResponse<PaymentInfoVO> response = new PageBaseResponse<>();
+        TransactionPageResponse<PaymentInfoVO> response = new TransactionPageResponse<>();
         response.setContent(paymentInfoVOS);
         response.setPage(queryPaymentInfoDTO.getPage());
         response.setSize(size);
         response.setTotal(total);
         response.setPages((long) totalPage);
+        response.setTotalAmount(Objects.isNull(payerTotal) ? BigDecimal.ZERO : payerTotal);
         return response;
     }
 
diff --git a/src/main/resources/mapper/primary/PaymentInfoMapper.xml b/src/main/resources/mapper/primary/PaymentInfoMapper.xml
index c358a722..5a295797 100644
--- a/src/main/resources/mapper/primary/PaymentInfoMapper.xml
+++ b/src/main/resources/mapper/primary/PaymentInfoMapper.xml
@@ -48,6 +48,7 @@
         SELECT
         p.id,
         a.user_name payer,
+        a.user_email email,
         p.payment_type platform,
         p.payer_total,
         p.type,
@@ -149,6 +150,44 @@
         AND p.transaction_id NOT LIKE 'cs_test%'
     </select>
 
+    <select id="queryTotalPaymentAmount" resultType="java.math.BigDecimal">
+        SELECT SUM(p.payer_total)
+        FROM t_payment_info p
+        LEFT JOIN t_order_info o ON p.order_no = o.order_no
+        LEFT JOIN t_account a ON a.id = o.account_id
+        WHERE 1 = 1
+        <if test="paymentType != null and paymentType != ''">
+            AND p.payment_type = #{paymentType}
+        </if>
+        <if test="payerTotal != null and payerTotal != ''">
+            AND p.payer_total = #{payerTotal}
+        </if>
+        <if test="type != null and type != ''">
+            AND p.type = #{type}
+        </if>
+        <if test="status != null and status != ''">
+            AND
+            CASE
+            WHEN p.trade_state IN ('paid', 'COMPLETED', 'complete', 'liquidated') THEN 'Success'
+            WHEN p.trade_state IN ('failed', 'expired', 'VOIDED', 'void', 'uncollectible') THEN 'Fail'
+            ELSE 'Pending'
+            END = #{status}
+        </if>
+        <if test="country != null and country != ''">
+            AND p.country = #{country}
+        </if>
+        <if test="city != null and city != ''">
+            AND p.city = #{city}
+        </if>
+        <if test="startTime != null and startTime != '' and endTime != null and endTime != ''">
+            AND p.create_time BETWEEN #{startTime} AND #{endTime}
+        </if>
+        <if test="payer != null and payer != ''">
+            AND a.user_name = #{payer}
+        </if>
+        AND p.transaction_id NOT LIKE 'cs_test%'
+    </select>
+
     <select id="getCities" resultType="java.util.Map">
         SELECT DISTINCT city
         FROM t_payment_info