From c70e92bedb031f28648a0d6e358ac7a1ecdfefea Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 31 Aug 2023 14:22:51 +0800
Subject: [PATCH] 退款查询

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java |   19 +++++++++++++++++++
 1 files changed, 19 insertions(+), 0 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
index 4465115..ec85264 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
@@ -592,4 +592,23 @@
         mallMemberBankMapper.deleteById(id);
         return new FebsResponse().success();
     }
+
+    @Override
+    public FebsResponse redBag() {
+        MallMember member = LoginUserUtil.getLoginUser();
+        List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectByMemberIdAndTypeAndStatusAndDate(member.getId(), MoneyFlowTypeEnum.SCORE_POOL.getValue(), 1, new Date());
+        if(CollUtil.isEmpty(mallMoneyFlows)){
+            throw new FebsException("没有红包");
+        }
+        BigDecimal amount = BigDecimal.ZERO;
+        for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
+            mallMoneyFlow.setStatus(2);
+            mallMoneyFlowMapper.updateById(mallMoneyFlow);
+
+            amount = mallMoneyFlow.getAmount().abs();
+        }
+        walletService.add(amount, member.getId(), "commission");
+        walletService.reduce(amount.negate(), member.getId(), "score");
+        return new FebsResponse().success().message("领取成功");
+    }
 }

--
Gitblit v1.9.1