From 069a8bfdac267391a9fd6b481da11d04ec0ee16f Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Sun, 31 May 2020 14:42:49 +0800
Subject: [PATCH] modify regist interface
---
src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 101 +++++++++++++++++++++++++++++++++++++-------------
1 files changed, 75 insertions(+), 26 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 9217b09..1d746f9 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
@@ -12,6 +12,7 @@
import com.xcong.excoin.common.enumerates.SymbolEnum;
import com.xcong.excoin.common.response.Result;
import com.xcong.excoin.common.system.dto.RegisterDto;
+import com.xcong.excoin.common.system.service.CommonService;
import com.xcong.excoin.modules.member.dao.*;
import com.xcong.excoin.modules.member.entity.*;
import com.xcong.excoin.modules.member.parameter.dto.MemberAddCoinAddressDto;
@@ -32,6 +33,7 @@
import com.xcong.excoin.modules.member.parameter.vo.MemberPaymethodDetailVo;
import com.xcong.excoin.modules.member.service.MemberService;
import com.xcong.excoin.modules.platform.dao.PlatformSymbolsCoinDao;
+import com.xcong.excoin.modules.platform.entity.PlatformSymbolsCoinEntity;
import com.xcong.excoin.utils.MessageSourceUtils;
import com.xcong.excoin.utils.RedisUtils;
import com.xcong.excoin.utils.ShareCodeUtil;
@@ -42,6 +44,7 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -87,6 +90,9 @@
@Resource
MemberCoinAddressDao memberCoinAddressDao;
+
+ @Resource
+ private CommonService commonservice;
@Transactional()
@Override
@@ -153,6 +159,14 @@
walletContract.setWalletCode(CoinTypeEnum.USDT.name());
memberWalletContractDao.insert(walletContract);
+ MemberWalletContractSimulateEntity walletContractSimulate = new MemberWalletContractSimulateEntity();
+ walletContractSimulate.setMemberId(member.getId());
+ walletContractSimulate.setAvailableBalance(new BigDecimal(AppContants.INIT_SIMULATE_MONEY));
+ walletContractSimulate.setTotalBalance(new BigDecimal(AppContants.INIT_SIMULATE_MONEY));
+ walletContractSimulate.setFrozenBalance(AppContants.INIT_MONEY);
+ walletContractSimulate.setBorrowedFund(AppContants.INIT_MONEY);
+ walletContractSimulate.setWalletCode(CoinTypeEnum.USDT.name());
+
// 初始化币币钱包
for (CoinTypeEnum coinTypeEnum : CoinTypeEnum.values()) {
@@ -200,23 +214,23 @@
public Result memberForgetPwd(@Valid MemberForgetPwdDto memberForgetPwdDto) {
int type = memberForgetPwdDto.getType();
- String phone = memberForgetPwdDto.getPhone();
- String email = memberForgetPwdDto.getEmail();
+ String account = memberForgetPwdDto.getAccount();
String code = memberForgetPwdDto.getCode();
String password = memberForgetPwdDto.getPassword();
Map<String, Object> hashMap = new HashMap<>();
if(type == 1) {
- hashMap.put("phone", phone);
+ hashMap.put("phone", account);
}else {
- hashMap.put("email", email);
+ hashMap.put("email", account);
}
List<MemberEntity> member = memberDao.selectByMap(hashMap);
if (CollUtil.isEmpty(member)) {
return Result.fail(MessageSourceUtils.getString("member_service_0047"));
}
- boolean verificationCode = verificationCode(type, phone, code, email);
- if(verificationCode) {
+
+ boolean flag = commonservice.verifyCode(account, code);
+ if(flag) {
MemberEntity memberEntity = member.get(0);
memberEntity.setPassword(SecureUtil.md5(password));
memberDao.updateById(memberEntity);
@@ -224,9 +238,9 @@
return Result.fail(MessageSourceUtils.getString("member_service_0045"));
}
if(type == 1) {
- redisUtils.del("SMS_" + phone);
+ redisUtils.del("SMS_" + account);
}else {
- redisUtils.del("EMAIL_" + email);
+ redisUtils.del("EMAIL_" + account);
}
return Result.ok(MessageSourceUtils.getString("member_service_0048"));
}
@@ -359,22 +373,32 @@
String code = memberUpdateTradePwdDto.getCode();
String password = memberUpdateTradePwdDto.getPassword();
+ String account = memberUpdateTradePwdDto.getAccount();
String phone = memberEntity.getPhone();
String email = memberEntity.getEmail();
int type = memberUpdateTradePwdDto.getType();
- boolean verificationCode = verificationCode(type, phone, code, email);
- if(verificationCode) {
- memberEntity.setTradePassword(SecureUtil.md5(password));
- memberDao.updateById(memberEntity);
- }else {
+
+ //验证手机号或者邮箱是否是该账户绑定的手机号或者邮箱
+ if(MemberEntity.ACCOUNT_TYPE_PHONE.equals(type) && !phone.equals(account)) {
return Result.fail(MessageSourceUtils.getString("member_service_0041"));
}
- if(type == 1) {
- redisUtils.del("SMS_" + phone);
- }else {
- redisUtils.del("EMAIL_" + email);
+ if(MemberEntity.ACCOUNT_TYPE_EMAIL.equals(type) && !email.equals(account)) {
+ return Result.fail(MessageSourceUtils.getString("member_service_0041"));
}
- return Result.ok(MessageSourceUtils.getString("member_service_0051"));
+
+ boolean flag = commonservice.verifyCode(account, code);
+ if (flag) {
+ memberEntity.setTradePassword(SecureUtil.md5(password));
+ memberDao.updateById(memberEntity);
+ if(MemberEntity.ACCOUNT_TYPE_PHONE.equals(type)) {
+ redisUtils.del("SMS_" + phone);
+ }else {
+ redisUtils.del("EMAIL_" + email);
+ }
+ return Result.ok(MessageSourceUtils.getString("member_service_0051"));
+ }
+ return Result.fail(MessageSourceUtils.getString("member_service_0041"));
+
}
@Override
@@ -408,20 +432,21 @@
String code = memberForgetPwdDto.getCode();
String password = memberForgetPwdDto.getPassword();
- String phone = memberForgetPwdDto.getPhone();
- String email = memberForgetPwdDto.getEmail();
+ String account = memberForgetPwdDto.getAccount();
int type = memberForgetPwdDto.getType();
- boolean verificationCode = verificationCode(type, phone, code, email);
- if(verificationCode) {
+
+ boolean flag = commonservice.verifyCode(account, code);
+ if(flag) {
memberEntity.setTradePassword(SecureUtil.md5(password));
memberDao.updateById(memberEntity);
}else {
return Result.fail(MessageSourceUtils.getString("member_service_0015"));
}
+
if(type == 1) {
- redisUtils.del("SMS_" + phone);
+ redisUtils.del("SMS_" + account);
}else {
- redisUtils.del("EMAIL_" + email);
+ redisUtils.del("EMAIL_" + account);
}
return Result.ok(MessageSourceUtils.getString("member_service_0068"));
}
@@ -515,6 +540,7 @@
}
@Override
+ @Transactional
public Result memberBindPhone(@Valid MemberBindPhoneDto memberBindPhoneDto) {
//获取用户ID
Long memberId = LoginUserUtils.getAppLoginUser().getId();
@@ -541,6 +567,7 @@
}
@Override
+ @Transactional
public Result memberBindEmail(@Valid MemberBindEmailDto memberBindEmailDto) {
//获取用户ID
@@ -597,6 +624,8 @@
memberCoinAddressVo.setMemberId(memberCoinAddressEntity.getMemberId());
memberCoinAddressVo.setPrivateKey(memberCoinAddressEntity.getPrivateKey());
memberCoinAddressVo.setSymbol(memberCoinAddressEntity.getSymbol());
+ memberCoinAddressVo.setLabel(memberCoinAddressEntity.getLabel());
+ memberCoinAddressVo.setSymbolscoinId(memberCoinAddressEntity.getSymbolscoinId());
arrayList.add(memberCoinAddressVo);
}
}
@@ -606,9 +635,29 @@
}
@Override
+ @Transactional
public Result memberAddCoinAddress(@Valid MemberAddCoinAddressDto memberAddCoinAddressDto) {
- // TODO Auto-generated method stub
- return null;
+
+ //获取用户ID
+ Long memberId = LoginUserUtils.getAppLoginUser().getId();
+ String address = memberAddCoinAddressDto.getAddress();
+ String isBiyict = memberAddCoinAddressDto.getIsBiyict();
+ Long symbolscoinId = memberAddCoinAddressDto. getSymbolscoinId();
+ String remark = memberAddCoinAddressDto.getRemark();
+
+ PlatformSymbolsCoinEntity platformSymbolsCoinEntity = platformSymbolsCoinDao.selectById(symbolscoinId);
+
+ MemberCoinAddressEntity memberCoinAddressEntity = new MemberCoinAddressEntity();
+ memberCoinAddressEntity.setAddress(address);
+ memberCoinAddressEntity.setMemberId(memberId);
+ memberCoinAddressEntity.setIsBiyict(isBiyict);
+ memberCoinAddressEntity.setSymbolscoinId(symbolscoinId);
+ memberCoinAddressEntity.setLabel(remark);
+ memberCoinAddressEntity.setSymbol(platformSymbolsCoinEntity.getName());
+
+ memberCoinAddressDao.insert(memberCoinAddressEntity);
+
+ return Result.ok(MessageSourceUtils.getString("member_service_0024"));
}
}
--
Gitblit v1.9.1