From 1bf57dbbb7025facb8a3e3c2074e82af6f13b24f Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 28 Apr 2022 15:13:59 +0800
Subject: [PATCH] fix

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

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
index 9270c40..5b4e315 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java
@@ -3,6 +3,9 @@
 import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
 import cc.mrbird.febs.common.enumerates.AgentLevelEnum;
+import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
+import cc.mrbird.febs.common.exception.FebsException;
+import cc.mrbird.febs.common.utils.MallUtils;
 import cc.mrbird.febs.mall.dto.*;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.entity.MallNewsInfo;
@@ -13,6 +16,7 @@
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.hutool.crypto.SecureUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -37,6 +41,8 @@
 public class AdminMallMemberServiceImpl extends ServiceImpl<MallMemberMapper, MallMember> implements IAdminMallMemberService {
 
     private final MallMemberMapper mallMemberMapper;
+
+    private final MallMemberWalletMapper mallMemberWalletMapper;
 
     private final MallMoneyFlowMapper mallMoneyFlowMapper;
 
@@ -378,4 +384,69 @@
         return new FebsResponse().success();
     }
 
+    @Override
+    @Transactional
+    public FebsResponse updateSystemPay(MallSystemPayDto mallSystemPayDto) {
+        Long memberId = mallSystemPayDto.getId();
+        MallMember mallMember = mallMemberMapper.selectById(memberId);
+        if(ObjectUtil.isEmpty(mallMember)){
+            return new FebsResponse().fail().message("系统繁忙,请刷新页面重试");
+        }
+
+        BigDecimal bigDecimal = mallSystemPayDto.getAddBalance();
+        if(bigDecimal.compareTo(BigDecimal.ZERO) <= 0){
+            return new FebsResponse().fail().message("拨付数目需要大于0");
+        }
+
+        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
+        mallMemberWallet.setBalance(mallMemberWallet.getBalance().add(bigDecimal));
+        mallMemberWalletMapper.updateBalanceWithId(mallMemberWallet);
+
+        MallMoneyFlow flow = new MallMoneyFlow();
+        flow.setMemberId(memberId);
+        flow.setAmount(bigDecimal);
+//        flow.setType(MoneyFlowTypeEnum.SYSTEM_PAY.getValue());
+        flow.setOrderNo("SYS"+MallUtils.getOrderNum());
+        flow.setStatus(2);
+        mallMoneyFlowMapper.insert(flow);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public AdminAgentLevelSetInfoVo getAgentLevelSetInfoByMemberId(long id) {
+        AdminAgentLevelSetInfoVo adminAgentLevelSetInfoVo = mallMemberMapper.getAgentLevelSetInfoByMemberId(id);
+        return adminAgentLevelSetInfoVo;
+    }
+
+    @Override
+    public FebsResponse agentLevelSetUpdate(AgentLevelSetUpdateDto agentLevelSetUpdateDto) {
+        Long memberId = agentLevelSetUpdateDto.getId();
+        MallMember mallMember = mallMemberMapper.selectById(memberId);
+        if(ObjectUtil.isEmpty(mallMember)){
+            return new FebsResponse().fail().message("系统繁忙,请刷新页面重试");
+        }
+        mallMember.setLevel(agentLevelSetUpdateDto.getLevelCode());
+        mallMemberMapper.updateById(mallMember);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse resetPwd(Long id) {
+        MallMember mallMember = this.baseMapper.selectById(id);
+        if (mallMember == null) {
+            throw new FebsException("用户不存在");
+        }
+
+        String pwd = SecureUtil.md5("a123456");
+        mallMember.setPassword(pwd);
+        this.baseMapper.updateById(mallMember);
+        return new FebsResponse().success().message("重置成功");
+    }
+
+    @Override
+    public IPage<MallDataVo> getMallDataList(MallMember mallMember, QueryRequest request) {
+        Page<MallDataVo> page = new Page<>(request.getPageNum(), request.getPageSize());
+        IPage<MallDataVo> mallDataVos = this.baseMapper.getMallDataListInPage(page, mallMember);
+        return mallDataVos;
+    }
 }

--
Gitblit v1.9.1