From ce4fb58f85eefe9fe6bb6213d8f1576d1925a5ef Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 07 Jul 2020 19:15:35 +0800
Subject: [PATCH] Merge branch 'master' of https://gitee.com/chonggaoxiao/new_excoin

---
 src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java |   62 +++++++++++++++++++++++-------
 1 files changed, 47 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
index 56ace36..cf2f185 100644
--- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -118,6 +118,11 @@
             return Result.fail("账号已存在");
         }
 
+        boolean isTrue = commonservice.verifyCode(registerDto.getAccount(), registerDto.getCode());
+        if (!isTrue) {
+            return Result.fail(MessageSourceUtils.getString("common_verify_code"));
+        }
+
         member = new MemberEntity();
         member.setPassword(SecureUtil.md5(registerDto.getPassword()));
 
@@ -134,9 +139,11 @@
 //        if (StrUtil.isBlank(registerDto.getRefererId())) {
 //            registerDto.setRefererId(AppContants.SYSTEM_REFERER);
 //        }
-        MemberEntity isExist = memberDao.selectMemberInfoByInviteId(registerDto.getRefererId());
-        if (isExist == null) {
-            return Result.fail("推荐人不存在");
+        if (!AppContants.SYSTEM_REFERER.equals(registerDto.getRefererId())) {
+            MemberEntity isExist = memberDao.selectMemberInfoByInviteId(registerDto.getRefererId());
+            if (isExist == null) {
+                return Result.fail("推荐人不存在");
+            }
         }
 
         member.setRefererId(registerDto.getRefererId());
@@ -146,6 +153,7 @@
         member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_UN_SUBMIT);
         member.setIsForce(0);
         member.setIsProfit(0);
+        member.setSpread(BigDecimal.ZERO);
         memberDao.insert(member);
 
         String inviteId = ShareCodeUtil.toSerialCode(member.getId());
@@ -320,8 +328,13 @@
         //获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
         MemberEntity member = memberDao.selectById(memberId);
+		if(MemberEntity.CERTIFY_STATUS_ING.equals(member.getCertifyStatus())) {
+			return Result.fail(MessageSourceUtils.getString("member_service_4000"));
+		}
         if (ObjectUtil.isNotEmpty(member)) {
-            MemberAuthenticationEntity memberAuthenticationEntity = new MemberAuthenticationEntity();
+        	
+        	MemberAuthenticationEntity memberAuthenticationEntity = new MemberAuthenticationEntity();
+			
             if (MemberEntity.CERTIFY_STATUS_Y == member.getCertifyStatus()) {
                 return Result.fail(MessageSourceUtils.getString("member_service_0055"));
             }
@@ -366,7 +379,16 @@
             memberAuthenticationEntity.setIdcardImageFront(memberAuthenticationDto.getIdCardFront());
             memberAuthenticationEntity.setIdcardImageBack(memberAuthenticationDto.getIdCardReverse());
             memberAuthenticationEntity.setIdcardImageInHand(memberAuthenticationDto.getIdCardImage());
-            memberAuthenticationDao.insert(memberAuthenticationEntity);
+            
+            Map<String, Object> columnMap = new HashMap<>();
+        	columnMap.put("member_id", memberId);
+        	List<MemberAuthenticationEntity> selectByMap = memberAuthenticationDao.selectByMap(columnMap);
+        	if(CollUtil.isEmpty(selectByMap)) {
+        		memberAuthenticationDao.insert(memberAuthenticationEntity);
+        	}else {
+        		memberAuthenticationEntity.setId(selectByMap.get(0).getId());
+        		memberAuthenticationDao.updateById(memberAuthenticationEntity);
+        	}
 
             member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_ING);
             member.setIdcardNo(idCardNo);
@@ -734,6 +756,9 @@
 
         MemberPersonCenterInfoVo memberPersonCenterInfoVo = new MemberPersonCenterInfoVo();
         
+        Integer certifyStatus = member.getCertifyStatus();
+        memberPersonCenterInfoVo.setCertifyStatus(certifyStatus);
+        
         Map<String, Object> columnMap = new HashMap<>();
         columnMap.put("member_id", memberId);
         List<MemberPaymentMethodEntity> selectByMap = memberPaymentMethodDao.selectByMap(columnMap);
@@ -798,15 +823,22 @@
             return Result.fail(MessageSourceUtils.getString("member_service_0087"));
         }
 
-        MemberAvivableCoinInfoVo memberAvivableCoinInfoVo = new MemberAvivableCoinInfoVo();
-        memberAvivableCoinInfoVo.setAvailableBalance(walletCoin.getAvailableBalance());
-
-        PlatformFeeSettingEntity feeSetting = platformFeeSettingDao.getFeeSettingByTypeAndSymbol(2, symbol);
-        if (ObjectUtil.isEmpty(feeSetting)) {
+        List<MemberAvivableCoinInfoVo> arrayList = new ArrayList<>();
+        
+        
+		List<PlatformFeeSettingEntity> feeSettingByTypeAndSymbolLable = platformFeeSettingDao.getFeeSettingsByTypeAndSymbol(2, symbol);
+        if (CollUtil.isEmpty(feeSettingByTypeAndSymbolLable)) {
             return Result.fail(MessageSourceUtils.getString("member_service_0087"));
         }
-        memberAvivableCoinInfoVo.setFee(feeSetting.getFeePrice());
-        return Result.ok(memberAvivableCoinInfoVo);
+        for(PlatformFeeSettingEntity platformFeeSettingEntity : feeSettingByTypeAndSymbolLable) {
+        	MemberAvivableCoinInfoVo memberAvivableCoinInfoVo = new MemberAvivableCoinInfoVo();
+        	memberAvivableCoinInfoVo.setAvailableBalance(walletCoin.getAvailableBalance());
+        	memberAvivableCoinInfoVo.setFee(platformFeeSettingEntity.getFeePrice());
+        	memberAvivableCoinInfoVo.setLable(platformFeeSettingEntity.getLable());
+        	arrayList.add(memberAvivableCoinInfoVo);
+        }
+        
+        return Result.ok(arrayList);
     }
 
     @Override
@@ -857,9 +889,9 @@
         if (flag) {
             MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, memberSubmitCoinApplyDto.getSymbol());
             BigDecimal availableBalance = walletCoin.getAvailableBalance();
-            BigDecimal coinNumber = memberSubmitCoinApplyDto.getCoinNumber().add(memberSubmitCoinApplyDto.getFeeAmount());
+            BigDecimal coinNumber = memberSubmitCoinApplyDto.getCoinNumber();
             if (availableBalance.compareTo(BigDecimal.ZERO) > 0
-                    && availableBalance.compareTo(coinNumber) > 0) {
+                    && availableBalance.compareTo(coinNumber) >= 0) {
                 //新增提币记录
                 MemberCoinWithdrawEntity memberCoinWithdrawEntity = new MemberCoinWithdrawEntity();
                 memberCoinWithdrawEntity.setAddress(memberSubmitCoinApplyDto.getAddress());
@@ -888,7 +920,7 @@
                 MemberAccountMoneyChange accountRecord = new MemberAccountMoneyChange();
                 accountRecord.setContent("提币");
                 accountRecord.setMemberId(memberId);
-                accountRecord.setAmount(memberSubmitCoinApplyDto.getCoinNumber());
+                accountRecord.setAmount(coinNumber);
                 accountRecord.setStatus(MemberAccountMoneyChange.STATUS_WAIT_INTEGER);
                 accountRecord.setSymbol(memberSubmitCoinApplyDto.getSymbol());
                 accountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_COIN);

--
Gitblit v1.9.1