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