From d6ed2678974b2750fd3b552cd607f487fbac0927 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 20 Feb 2024 16:51:23 +0800
Subject: [PATCH] 抽奖

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java |  163 +++++++-----------------------------------------------
 1 files changed, 22 insertions(+), 141 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 c308fb8..b584790 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
@@ -67,109 +67,47 @@
     @Transactional(rollbackFor = Exception.class)
     @Override
     public FebsResponse register(RegisterDto registerDto) {
-//        MallMember mallMember = this.baseMapper.selectInfoByAccount(registerDto.getAccount());
-//        if (mallMember != null) {
-//            throw new FebsException("该账号已被占用");
-//        }
-        String accountLogin = registerDto.getAccountLogin();
-        MallMember mallMember = this.baseMapper.selectByAccountLogin(accountLogin);
-        if (mallMember != null) {
-            throw new FebsException("该账号已被占用");
-        }
-
-//        List<MallMember> mallMembers = this.baseMapper.selectMemberByName(registerDto.getName());
-//        if (CollUtil.isNotEmpty(mallMembers)) {
-//            MallRegisterAppeal registerAppeal = mallRegisterAppealMapper.selectByPhoneAndName(registerDto.getName(), registerDto.getAccount());
-//            if (registerAppeal == null || registerAppeal.getStatus() != 1) {
-//                return new FebsResponse().code(HttpStatus.ACCEPTED).message("用户名已存在");
-//            }
-//        }
-
         String account = registerDto.getAccount();
-        if (!"admin".equals(registerDto.getRegistType())) {
-            String code = registerDto.getCode();
+        MallMember mallMember = this.baseMapper.selectInfoByAccount(account);
+        if (mallMember != null) {
+            throw new FebsException("账号已注册");
+        }
+        String code = registerDto.getCode();
+        if(!AppContants.PUBLIC_CODE.equals(code)){
             boolean flags = commonService.verifyCode(account, code);
             if (!flags) {
                 throw new FebsException("验证码错误");
             }
         }
-
         mallMember = new MallMember();
-        mallMember.setAccountLogin(accountLogin);
+        mallMember.setAccountLogin(account);
         mallMember.setPassword(SecureUtil.md5(registerDto.getPassword()));
-
-        // 判断账号类型
-        if (AppContants.ACCOUNT_TYPE_MOBILE.equals(registerDto.getType())) {
-            mallMember.setPhone(registerDto.getAccount());
-        } else {
-            mallMember.setEmail(registerDto.getAccount());
-        }
-
-        Integer count = this.baseMapper.selectCount(null);
-        if (count != null && count != 0) {
-            MallMember inviteMember = this.baseMapper.selectInfoByInviteId(registerDto.getInviteId());
-            if (inviteMember == null) {
-                throw new FebsException("邀请码不存在");
-            }
-
-            mallMember.setReferrerId(registerDto.getInviteId());
-
-        }
-        mallMember.setName(registerDto.getName());
+        mallMember.setPhone(registerDto.getAccount());
+        mallMember.setEmail(registerDto.getAccount());
+        mallMember.setName(account);
         mallMember.setAccountStatus(MallMember.ACCOUNT_STATUS_ENABLE);
         mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);
         mallMember.setLevel(AgentLevelEnum.ZERO_LEVEL.getCode());
         mallMember.setSex("男");
-        mallMember.setBindPhone(registerDto.getAccount());
-
-        this.baseMapper.insert(mallMember);
-
+        mallMember.setBindPhone(account);
         String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId());
         mallMember.setInviteId(inviteId);
-
-        //推荐人和推荐人链
-        boolean flag = false;
-        String parentId = mallMember.getReferrerId();
-        if (StrUtil.isBlank(parentId)) {
-            flag = true;
-        }
-        String ids = "";
-        while (!flag) {
-            if (StrUtil.isBlank(ids)) {
-                ids += parentId;
-            } else {
-                ids += ("," + parentId);
-            }
-            MallMember parentMember = this.baseMapper.selectInfoByInviteId(parentId);
-            if (parentMember == null) {
-                break;
-            }
-            parentId = parentMember.getReferrerId();
-            if (StrUtil.isBlank(parentMember.getReferrerId())) {
-                flag = true;
-            }
-        }
-
-        if (StrUtil.isNotBlank(ids)) {
-            mallMember.setReferrerIds(ids);
-        }
-        this.baseMapper.updateById(mallMember);
+        this.baseMapper.insert(mallMember);
 
         MallMemberWallet wallet = new MallMemberWallet();
         wallet.setBalance(BigDecimal.ZERO);
         wallet.setMemberId(mallMember.getId());
         mallMemberWalletMapper.insert(wallet);
-        return new FebsResponse().success().message("注册成功");
+        return new FebsResponse().success().message("操作成功");
     }
 
     @Override
     public FebsResponse toLogin(LoginDto loginDto) {
         String md5Pwd = SecureUtil.md5(loginDto.getPassword());
 
-//        MallMember mallMember = this.baseMapper.selectInfoByAccountAndPwd(loginDto.getAccount(), md5Pwd);
-        MallMember mallMember = this.baseMapper.selectInfoByAccountLoginAndPwd(loginDto.getAccount(), md5Pwd);
+        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())) {
@@ -204,13 +142,11 @@
         Long id = LoginUserUtil.getLoginUser().getId();
         MallMember mallMember = this.baseMapper.selectById(id);
 
-//        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getPhone());
-//        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getAccount());
         if (mallMember == null) {
             throw new FebsException("账号不存在");
         }
 
-        boolean b = commonService.verifyCode(forgetPwdDto.getAccount(), forgetPwdDto.getCode());
+        boolean b = commonService.verifyCode(mallMember.getPhone(), forgetPwdDto.getCode());
         if (!b) {
             throw new FebsException("验证码错误");
         }
@@ -219,49 +155,23 @@
         mallMember.setPassword(pwd);
 
         this.baseMapper.updateById(mallMember);
-        return new FebsResponse().success().message("重置成功");
+        return new FebsResponse().success().message("操作成功");
     }
 
     @Override
     public FebsResponse logout() {
         Long id = LoginUserUtil.getLoginUser().getId();
         redisUtils.del(AppContants.APP_LOGIN_PREFIX + id);
-        return new FebsResponse().success().message("退出登录");
+        return new FebsResponse().success().message("操作成功");
     }
 
     @Override
     public FebsResponse findMemberInfo() {
         Long id = LoginUserUtil.getLoginUser().getId();
         MallMember mallMember = this.baseMapper.selectById(id);
-
         MallMemberVo mallMemberVo = MallMemberConversion.INSTANCE.entityToVo(mallMember);
-
-        MallMember referMember = this.baseMapper.selectInfoByInviteId(mallMember.getReferrerId());
-        if (referMember != null) {
-            mallMemberVo.setReferrerName(referMember.getName());
-        }
-
-        if (StrUtil.isNotBlank(mallMember.getTradePassword())) {
-            mallMemberVo.setHasTradePwd(1);
-        }
-
-        MallMemberPayment payment = mallMemberPaymentMapper.selectByMemberId(id);
-        if (payment != null) {
-            mallMemberVo.setHasPayment(1);
-        }
-
-        DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.AGENT_LEVEL, mallMember.getLevel());
-        if (dic != null) {
-            mallMemberVo.setLevelName(dic.getDescription());
-        }
         MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(mallMemberVo.getId());
         mallMemberVo.setBalance(wallet.getBalance());
-        mallMemberVo.setScore(wallet.getScore());
-        mallMemberVo.setPrizeScore(wallet.getPrizeScore());
-        mallMemberVo.setTotalScore(wallet.getTotalScore());
-        mallMemberVo.setStar(wallet.getStar());
-        mallMemberVo.setVoucherCnt(wallet.getVoucherCnt());
-        mallMemberVo.setTotalCost(mallOrderInfoMapper.selectTotalAmount(id));
         return new FebsResponse().success().data(mallMemberVo);
     }
 
@@ -469,14 +379,7 @@
     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);
-            }
-        }
+        BigDecimal canMoney = wallet.getBalance();
         return canMoney;
     }
 
@@ -551,21 +454,6 @@
     }
 
     @Override
-    public void addRegisterAppeal(RegisterAppealDto registerAppeal) {
-        MallRegisterAppeal isExist = mallRegisterAppealMapper.selectByPhoneAndName(registerAppeal.getName(), registerAppeal.getPhone());
-        if (isExist != null) {
-            throw new FebsException("申诉已存在");
-        }
-
-        isExist = new MallRegisterAppeal();
-        isExist.setName(registerAppeal.getName());
-        isExist.setPhone(registerAppeal.getPhone());
-        isExist.setStatus(2);
-
-        mallRegisterAppealMapper.insert(isExist);
-    }
-
-    @Override
     public CashOutSettingVo cashOutSetting() {
         CashOutSettingVo cashOutSettingVo = new CashOutSettingVo();
         DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.CASHOUT_SETTING.getType(), DataDictionaryEnum.CASHOUT_SETTING.getCode());
@@ -608,7 +496,7 @@
         MallMemberBank mallMemberBank = MallMemberBankConversion.INSTANCE.dtoToentity(addMemberBankDto);
         mallMemberBank.setMemberId(member.getId());
         mallMemberBankMapper.insert(mallMemberBank);
-        return new FebsResponse().success();
+        return new FebsResponse().success().message("操作成功");
     }
 
     @Override
@@ -633,16 +521,9 @@
         Long id = updateMemberBankDto.getId();
         MallMemberBank mallMemberBank = mallMemberBankMapper.selectById(id);
         mallMemberBank.setName(updateMemberBankDto.getName());
-        mallMemberBank.setIdType(updateMemberBankDto.getIdType());
         mallMemberBank.setIdCardNum(updateMemberBankDto.getIdCardNum());
         mallMemberBank.setBankNo(updateMemberBankDto.getBankNo());
         mallMemberBank.setPhone(updateMemberBankDto.getPhone());
-        mallMemberBank.setDigitalNo(updateMemberBankDto.getDigitalNo());
-        mallMemberBank.setBankName(updateMemberBankDto.getBankName());
-        mallMemberBank.setSubbranchName(updateMemberBankDto.getSubbranchName());
-        mallMemberBank.setProvince(updateMemberBankDto.getProvince());
-        mallMemberBank.setCity(updateMemberBankDto.getCity());
-        mallMemberBank.setSkhh(updateMemberBankDto.getSkhh());
         mallMemberBankMapper.updateById(mallMemberBank);
         return new FebsResponse().success();
     }
@@ -666,7 +547,7 @@
 
     @Override
     public FebsResponse pwdForget(ForgetPwdDto forgetPwdDto) {
-        MallMember mallMember = this.baseMapper.selectInfoByAccountNew(forgetPwdDto.getAccountLogin(),forgetPwdDto.getPhone());
+        MallMember mallMember = this.baseMapper.selectInfoByAccount(forgetPwdDto.getAccount());
         if(ObjectUtil.isEmpty(mallMember)){
             throw new FebsException("账号不存在");
         }
@@ -680,6 +561,6 @@
         mallMember.setPassword(pwd);
 
         this.baseMapper.updateById(mallMember);
-        return new FebsResponse().success().message("重置成功");
+        return new FebsResponse().success().message("操作成功");
     }
 }

--
Gitblit v1.9.1