From 7f55c18d7db36c9cad2ac96e481680bc1107e51c Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Thu, 15 Jun 2023 11:16:11 +0800
Subject: [PATCH] Merge branch 'meiye_mall' of http://120.27.238.55:7000/r/xc-mall into meiye_mall

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java |   72 ++++++++++++++++++++++++++++--------
 1 files changed, 56 insertions(+), 16 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 1e66061..ba4403c 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
@@ -15,6 +15,7 @@
 import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
 import cc.mrbird.febs.mall.service.ICommonService;
 import cc.mrbird.febs.mall.vo.*;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.IdUtil;
@@ -36,6 +37,7 @@
 
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * @author wzy
@@ -112,8 +114,10 @@
         mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE);
         mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);
         mallMember.setLevel(AgentLevelEnum.ZERO_LEVEL.getCode());
-        mallMember.setSex("男");
+        mallMember.setSex(registerDto.getSex());
+        mallMember.setInsideWith(1);
         mallMember.setBindPhone(registerDto.getAccount());
+        mallMember.setSkin("default");
 
         this.baseMapper.insert(mallMember);
 
@@ -161,7 +165,7 @@
 
         MallMember mallMember = this.baseMapper.selectInfoByAccountAndPwd(loginDto.getAccount(), md5Pwd);
         if (mallMember == null) {
-            throw new FebsException("用户不存在或账号密码错误");
+            throw new FebsException("账号密码错误");
         }
 
         if (MallMember.ACCOUNT_STATUS_DISABLED.equals(mallMember.getAccountStatus())) {
@@ -191,10 +195,15 @@
         return rsa.encryptBase64(token + "_" + System.currentTimeMillis(), KeyType.PublicKey);
     }
 
+    public static void main(String[] args) {
+        RSA rsa = new RSA(null, AppContants.PUBLIC_KEY);
+        System.out.println(rsa.encryptBase64("fc848b76904a45e3bed8b6912921f36b" + "_" + System.currentTimeMillis(), KeyType.PublicKey));;
+    }
+
     @Override
     public FebsResponse forgetPwd(ForgetPwdDto forgetPwdDto) {
-        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getPhone());
-//        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getAccount());
+//        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getPhone());
+        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getAccount());
         if (mallMember == null) {
             throw new FebsException("账号不存在");
         }
@@ -224,6 +233,12 @@
         MallMember mallMember = this.baseMapper.selectById(id);
 
         MallMemberVo mallMemberVo = MallMemberConversion.INSTANCE.entityToVo(mallMember);
+
+        mallMemberVo.setCanInvite(1);
+        if (MemberLevelEnum.ZERO_LEVEL.getType().equals(mallMemberVo.getLevel())) {
+            mallMemberVo.setInviteId(null);
+            mallMemberVo.setCanInvite(2);
+        }
 
         MallMember referMember = this.baseMapper.selectInfoByInviteId(mallMember.getReferrerId());
         if (referMember != null) {
@@ -364,6 +379,10 @@
         if (mallMember == null) {
             throw new FebsException("用户不存在");
         }
+        Integer insideWith = mallMember.getInsideWith() == null ? 2 :mallMember.getInsideWith();
+        if (1 != insideWith) {
+            throw new FebsException("功能升级中");
+        }
 
         Long memberId = LoginUserUtil.getLoginUser().getId();
         MallMember loginMember = this.baseMapper.selectById(memberId);
@@ -454,15 +473,8 @@
     public BigDecimal canMoney() {
         Long memberId = LoginUserUtil.getLoginUser().getId();
         MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
-        BigDecimal profit = mallMoneyFlowMapper.selectProfitByDateAndMemberId(memberId);
 
-        BigDecimal canMoney = wallet.getCommission();
-        if (profit != null) {
-            if(canMoney.compareTo(BigDecimal.ZERO) > 0) {
-                canMoney = canMoney.subtract(profit);
-            }
-        }
-        return canMoney;
+        return wallet.getBalance();
     }
 
     @Override
@@ -495,10 +507,7 @@
             commissionVo.setAvatar(referMember.getAvatar());
         }
 
-        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.AGENT_LEVEL, mallMember.getLevel());
-        if (dic != null) {
-            commissionVo.setLevelName(dic.getDescription());
-        }
+        commissionVo.setLevelName(MemberLevelTagDicEnums.getDesc(mallMember.getSex(), mallMember.getLevel()));
 
         MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(id);
         commissionVo.setCommission(wallet.getBalance());
@@ -624,6 +633,7 @@
         mallMemberBank.setPhone(updateMemberBankDto.getPhone());
         mallMemberBank.setDigitalNo(updateMemberBankDto.getDigitalNo());
         mallMemberBank.setBankName(updateMemberBankDto.getBankName());
+        mallMemberBank.setSubbranchName(updateMemberBankDto.getSubbranchName());
         mallMemberBankMapper.updateById(mallMemberBank);
         return new FebsResponse().success();
     }
@@ -634,4 +644,34 @@
         mallMemberBankMapper.deleteById(id);
         return new FebsResponse().success();
     }
+
+    @Override
+    public List<SkinTypeVo> findSkinList() {
+        MallMember loginUser = LoginUserUtil.getLoginUser();
+
+        MallMember member = this.baseMapper.selectById(loginUser.getId());
+        String level = member.getLevel();
+
+        // 全网分红 -- 代理和股东当作是女王殿下级别
+        if (MemberLevelEnum.getLevelCode(level) > MemberLevelEnum.FOUR_LEVEL.getCode()) {
+            level = MemberLevelEnum.FOUR_LEVEL.getType();
+        }
+        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.SKIN_TYPE_LIST, level);
+        if (dic == null || StrUtil.isBlank(dic.getValue())) {
+            throw new FebsException("请检查皮肤配置");
+        }
+
+        List<String> skipStrList = StrUtil.split(dic.getValue(), ';');
+        return skipStrList.stream().map(item -> JSONObject.parseObject(item, SkinTypeVo.class)).collect(Collectors.toList());
+    }
+
+    @Override
+    public void useSkin(String code) {
+        MallMember loginUser = LoginUserUtil.getLoginUser();
+
+        MallMember update = new MallMember();
+        update.setId(loginUser.getId());
+        update.setSkin(code);
+        this.baseMapper.updateById(update);
+    }
 }

--
Gitblit v1.9.1