From 631a5aa09e0147ca81fffcb1434e57b1cd1ba6f6 Mon Sep 17 00:00:00 2001
From: lisy <linlangsur163@163.com>
Date: 星期三, 09 八月 2023 09:34:53 +0800
Subject: [PATCH] app端口:积分变动记录增加变动类型字段,代码同步更新;积分兑换操作的数量校验功能完善

---
 cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java |   28 +++++++++++++++++-----------
 1 files changed, 17 insertions(+), 11 deletions(-)

diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java
index 46a22c8..753b6a0 100644
--- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java
+++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/UserIntegralChangesServiceImpl.java
@@ -12,6 +12,7 @@
 import com.dsh.account.model.IntegralListQuery;
 import com.dsh.account.model.SaveUserIntegralChangesVo;
 import com.dsh.account.model.vo.userBenefitDetail.ExchangeDetailsResponse;
+import com.dsh.account.model.vo.userBenefitDetail.ExchangeDetailsVo;
 import com.dsh.account.model.vo.userBenefitDetail.IntegralsData;
 import com.dsh.account.model.vo.userBenefitDetail.PointDetailsVo;
 import com.dsh.account.service.UserIntegralChangesService;
@@ -120,23 +121,28 @@
         appUser.setIntegral(appUser.getIntegral() + vo.getIntegral());
         userIntegralChanges.setNewIntegral(appUser.getIntegral());
         userIntegralChanges.setInsertTime(new Date());
+        userIntegralChanges.setCategory(1);
         this.save(userIntegralChanges);
     }
 
     @Override
     public List<ExchangeDetailsResponse> queryExchangeGoodsdetails(Integer userIdFormRedis, Integer useType, Integer goodType) {
-        List<ExchangeDetailsResponse> integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis);
-        if (ToolUtil.isNotEmpty(useType)){
-            integralExchangeDetails = integralExchangeDetails.stream()
-                    .filter(response -> Objects.equals(response.getUseStatus(), useType))
-                    .collect(Collectors.toList());
+        List<ExchangeDetailsResponse> detailsResponses = new ArrayList<>();
+        ExchangeDetailsVo integralExchangeDetails = mcClient.getIntegralExchangeDetails(userIdFormRedis);
+        if (ToolUtil.isNotEmpty(integralExchangeDetails.getDetailsResponses())){
+            detailsResponses = integralExchangeDetails.getDetailsResponses();
+            if (ToolUtil.isNotEmpty(useType)){
+                detailsResponses = integralExchangeDetails.getDetailsResponses().stream()
+                        .filter(response -> Objects.equals(response.getUseStatus(), useType))
+                        .collect(Collectors.toList());
+            }
+            if (ToolUtil.isNotEmpty(goodType)){
+                detailsResponses = integralExchangeDetails.getDetailsResponses().stream()
+                        .filter(response -> Objects.equals(response.getGoodType(), goodType))
+                        .collect(Collectors.toList());
+            }
         }
-        if (ToolUtil.isNotEmpty(goodType)){
-            integralExchangeDetails = integralExchangeDetails.stream()
-                    .filter(response -> Objects.equals(response.getGoodType(), goodType))
-                    .collect(Collectors.toList());
-        }
-        return integralExchangeDetails;
+        return detailsResponses;
     }
 
     @Override

--
Gitblit v1.7.1