package com.xcong.excoin.modules.member.service.impl;
|
|
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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.xcong.excoin.common.LoginUserUtils;
|
import com.xcong.excoin.common.contants.AppContants;
|
import com.xcong.excoin.common.enumerates.CoinTypeEnum;
|
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;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberAuthenticationDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberBindEmailDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberBindPhoneDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberDelPaymethodDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberForgetPwdDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberPaymethodDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberUpdatePwdDto;
|
import com.xcong.excoin.modules.member.parameter.dto.MemberUpdateTradePwdDto;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberCoinAddressCountListVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberCoinAddressCountVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberCoinAddressListVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberCoinAddressVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberInfoVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberPaymethodDetailListVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberPaymethodDetailVo;
|
import com.xcong.excoin.modules.member.parameter.vo.MemberSendCodeWayVo;
|
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;
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
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;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.validation.Valid;
|
|
/**
|
* @author wzy
|
* @date 2020-05-18
|
**/
|
@Slf4j
|
@Service
|
public class MemberServiceImpl extends ServiceImpl<MemberDao, MemberEntity> implements MemberService {
|
|
@Resource
|
private MemberDao memberDao;
|
|
@Resource
|
private MemberWalletAgentDao memberWalletAgentDao;
|
|
@Resource
|
private MemberWalletContractDao memberWalletContractDao;
|
|
@Resource
|
private MemberWalletCoinDao memberWalletCoinDao;
|
|
@Resource
|
private MemberLevelRateDao memberLevelRateDao;
|
|
@Resource
|
MemberAuthenticationDao memberAuthenticationDao;
|
|
@Resource
|
RedisUtils redisUtils;
|
|
@Resource
|
MemberPaymentMethodDao memberPaymentMethodDao;
|
|
@Resource
|
PlatformSymbolsCoinDao platformSymbolsCoinDao;
|
|
@Resource
|
MemberCoinAddressDao memberCoinAddressDao;
|
|
@Resource
|
private CommonService commonservice;
|
|
@Resource
|
private MemberWalletContractSimulateDao memberWalletContractSimulateDao;
|
|
@Transactional()
|
@Override
|
public Result register(RegisterDto registerDto) {
|
// 查询是否存在该账号用户
|
MemberEntity member = memberDao.selectMemberInfoByAccount(registerDto.getAccount());
|
if (member != null) {
|
return Result.fail("账号已存在");
|
}
|
|
member = new MemberEntity();
|
member.setPassword(SecureUtil.md5(registerDto.getPassword()));
|
|
// 判断账号类型
|
if (MemberEntity.ACCOUNT_TYPE_PHONE == registerDto.getType()) {
|
member.setPhone(registerDto.getAccount());
|
} else if (MemberEntity.ACCOUNT_TYPE_EMAIL == registerDto.getType()) {
|
member.setEmail(registerDto.getAccount());
|
} else {
|
return Result.fail("账号类型错误");
|
}
|
|
// 判断是否拥有推荐人，若为空则默认系统
|
if (StrUtil.isBlank(registerDto.getRefererId())) {
|
registerDto.setRefererId(AppContants.SYSTEM_REFERER);
|
}
|
|
member.setRefererId(registerDto.getRefererId());
|
member.setAccountStatus(MemberEntity.ACCOUNT_STATUS_ENABLE);
|
member.setAccountType(registerDto.getType());
|
member.setAgentLevel(MemberEntity.ACCOUNT_AGENT_LEVEL);
|
member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_ING);
|
member.setIsForce(0);
|
member.setIsProfit(0);
|
memberDao.insert(member);
|
|
String inviteId = ShareCodeUtil.toSerialCode(member.getId());
|
member.setInviteId(inviteId);
|
|
boolean flag = false;
|
String parentId = member.getRefererId();
|
String ids = "";
|
while (!flag) {
|
ids += ("," + parentId);
|
MemberEntity parentMember = memberDao.selectMemberInfoByRefererId(parentId);
|
if (parentMember == null) {
|
break;
|
}
|
parentId = parentMember.getRefererId();
|
if (parentMember.getRefererId().equals(parentMember.getInviteId())) {
|
flag = true;
|
}
|
}
|
member.setRefererIds(ids);
|
memberDao.updateById(member);
|
|
//初始化合约钱包
|
MemberWalletContractEntity walletContract = new MemberWalletContractEntity();
|
walletContract.setMemberId(member.getId());
|
walletContract.setAvailableBalance(AppContants.INIT_MONEY);
|
walletContract.setFrozenBalance(AppContants.INIT_MONEY);
|
walletContract.setTotalBalance(AppContants.INIT_MONEY);
|
walletContract.setBorrowedFund(AppContants.INIT_MONEY);
|
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());
|
memberWalletContractSimulateDao.insert(walletContractSimulate);
|
|
|
// 初始化币币钱包
|
for (CoinTypeEnum coinTypeEnum : CoinTypeEnum.values()) {
|
MemberWalletCoinEntity walletCoin = new MemberWalletCoinEntity();
|
walletCoin.setWalletCode(coinTypeEnum.name());
|
walletCoin.setMemberId(member.getId());
|
walletCoin.setAvailableBalance(AppContants.INIT_MONEY);
|
walletCoin.setFrozenBalance(AppContants.INIT_MONEY);
|
walletCoin.setTotalBalance(AppContants.INIT_MONEY);
|
walletCoin.setBorrowedFund(AppContants.INIT_MONEY);
|
memberWalletCoinDao.insert(walletCoin);
|
}
|
|
// 初始化代理佣金钱包
|
MemberWalletAgentEntity walletAgent = new MemberWalletAgentEntity();
|
walletAgent.setMemberId(member.getId());
|
walletAgent.setWalletCode(CoinTypeEnum.USDT.name());
|
memberWalletAgentDao.insert(walletAgent);
|
|
// 初始化杠杆
|
for(SymbolEnum symbolEnum : SymbolEnum.values()) {
|
MemberLevelRateEntity levelRate = new MemberLevelRateEntity();
|
levelRate.setMemberId(member.getId());
|
levelRate.setSymbol(symbolEnum.getValue());
|
memberLevelRateDao.insert(levelRate);
|
}
|
return Result.ok("success");
|
}
|
|
@Override
|
public Result getMemberInfo() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity memberEntity = memberDao.selectById(memberId);
|
MemberInfoVo memberInfoVo = new MemberInfoVo();
|
if (ObjectUtil.isNotEmpty(memberEntity)) {
|
memberInfoVo.setPhone(memberEntity.getPhone());
|
memberInfoVo.setInviteId(memberEntity.getInviteId());
|
}
|
return Result.ok(memberInfoVo);
|
}
|
|
@Override
|
@Transactional
|
public Result memberForgetPwd(@Valid MemberForgetPwdDto memberForgetPwdDto) {
|
|
int type = memberForgetPwdDto.getType();
|
String account = memberForgetPwdDto.getAccount();
|
String code = memberForgetPwdDto.getCode();
|
String password = memberForgetPwdDto.getPassword();
|
|
Map<String, Object> hashMap = new HashMap<>();
|
if(type == 1) {
|
hashMap.put("phone", account);
|
}else {
|
hashMap.put("email", account);
|
}
|
List<MemberEntity> member = memberDao.selectByMap(hashMap);
|
if (CollUtil.isEmpty(member)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0047"));
|
}
|
|
boolean flag = commonservice.verifyCode(account, code);
|
if(flag) {
|
MemberEntity memberEntity = member.get(0);
|
memberEntity.setPassword(SecureUtil.md5(password));
|
memberDao.updateById(memberEntity);
|
}else {
|
return Result.fail(MessageSourceUtils.getString("member_service_0045"));
|
}
|
return Result.ok(MessageSourceUtils.getString("member_service_0048"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberUpdatePwd(@Valid MemberUpdatePwdDto memberUpdatePwdDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity memberEntity = memberDao.selectById(memberId);
|
|
String code = memberUpdatePwdDto.getCode();
|
String password = memberUpdatePwdDto.getPassword();
|
String phone = memberUpdatePwdDto.getPhone();
|
String email = memberUpdatePwdDto.getEmail();
|
int type = memberUpdatePwdDto.getType();
|
boolean verificationCode = verificationCode(type, phone, code, email);
|
if(verificationCode) {
|
memberEntity.setPassword(SecureUtil.md5(password));
|
memberDao.updateById(memberEntity);
|
}else {
|
return Result.fail(MessageSourceUtils.getString("member_service_0041"));
|
}
|
return Result.ok(MessageSourceUtils.getString("member_service_0040"));
|
}
|
|
/**
|
* 验证输入的验证码
|
* @param type 验证类型1：电话2：邮箱
|
* @param phone
|
* @param email
|
* @param code 验证码
|
* @return
|
*/
|
private boolean verificationCode(Integer type,String phone,String code,String email) {
|
boolean verificationCode = false;
|
if(type == 1) {
|
String smsCode = redisUtils.get("SMS_" + phone) + "";
|
if(code.equals(smsCode)) {
|
verificationCode = true;
|
}
|
}else {
|
String emailCode = redisUtils.get("EMAIL_" + email) + "";
|
if(code.equals(emailCode)) {
|
verificationCode = true;
|
}
|
}
|
return verificationCode;
|
}
|
|
@Override
|
@Transactional
|
public Result memberAuthentication(@Valid MemberAuthenticationDto memberAuthenticationDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity member = memberDao.selectById(memberId);
|
if (ObjectUtil.isNotEmpty(member)) {
|
MemberAuthenticationEntity memberAuthenticationEntity = new MemberAuthenticationEntity();
|
if (MemberEntity.CERTIFY_STATUS_Y == member.getCertifyStatus()) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0055"));
|
}
|
if (MemberEntity.CERTIFY_STATUS_ING == member.getCertifyStatus()) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0056"));
|
}
|
memberAuthenticationEntity.setMemberId(memberId);
|
|
if (StrUtil.isBlank(memberAuthenticationDto.getNation())) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0057"));
|
}
|
memberAuthenticationEntity.setNation(memberAuthenticationDto.getNation());
|
|
if (StrUtil.isBlank(memberAuthenticationDto.getFirstName())) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0058"));
|
}
|
memberAuthenticationEntity.setFirstName(memberAuthenticationDto.getFirstName());
|
|
if (StrUtil.isBlank(memberAuthenticationDto.getSecondName())) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0059"));
|
}
|
memberAuthenticationEntity.setSecondName(memberAuthenticationDto.getSecondName());
|
|
String idCardNo = memberAuthenticationDto.getIdCardNo();
|
if (StrUtil.isBlank(idCardNo)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0060"));
|
}
|
memberAuthenticationEntity.setIdcardNo(idCardNo);
|
//同一个身份证号码不能重复实名认证
|
int count = memberAuthenticationDao.findMemberbyIdCardNoCount(idCardNo);
|
if (count > 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0060"));
|
}
|
if (StrUtil.isBlank(memberAuthenticationDto.getIdCardFront())
|
|| StrUtil.isBlank(memberAuthenticationDto.getIdCardReverse())
|
|| StrUtil.isBlank(memberAuthenticationDto.getIdCardImage())) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0061"));
|
}
|
memberAuthenticationEntity.setIdcardImageFront(memberAuthenticationDto.getIdCardFront());
|
memberAuthenticationEntity.setIdcardImageBack(memberAuthenticationDto.getIdCardReverse());
|
memberAuthenticationEntity.setIdcardImageInHand(memberAuthenticationDto.getIdCardImage());
|
memberAuthenticationDao.insert(memberAuthenticationEntity);
|
|
member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_ING);
|
member.setIdcardNo(idCardNo);
|
memberDao.updateById(member);
|
/**
|
* TODO dingtalk
|
|
Constant.excutor.execute(new Runnable() {
|
@Override
|
public void run() {
|
DingTalkUtils.sendActionCard(4);
|
}
|
});*/
|
return Result.ok(MessageSourceUtils.getString("member_service_0024"));
|
}
|
return Result.fail(MessageSourceUtils.getString("member_service_0063"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberUpdateTradePwd(@Valid MemberUpdateTradePwdDto memberUpdateTradePwdDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity memberEntity = memberDao.selectById(memberId);
|
|
String code = memberUpdateTradePwdDto.getCode();
|
String password = memberUpdateTradePwdDto.getPassword();
|
String account = memberUpdateTradePwdDto.getAccount();
|
String phone = memberEntity.getPhone();
|
String email = memberEntity.getEmail();
|
int type = memberUpdateTradePwdDto.getType();
|
|
//验证手机号或者邮箱是否是该账户绑定的手机号或者邮箱
|
if(MemberEntity.ACCOUNT_TYPE_PHONE.equals(type) && !phone.equals(account)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0041"));
|
}
|
if(MemberEntity.ACCOUNT_TYPE_EMAIL.equals(type) && !email.equals(account)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0041"));
|
}
|
|
boolean flag = commonservice.verifyCode(account, code);
|
if (flag) {
|
memberEntity.setTradePassword(SecureUtil.md5(password));
|
memberDao.updateById(memberEntity);
|
return Result.ok(MessageSourceUtils.getString("member_service_0051"));
|
}
|
return Result.fail(MessageSourceUtils.getString("member_service_0045"));
|
|
}
|
|
@Override
|
@Transactional
|
public Result memberLogout() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity memberEntity = memberDao.selectById(memberId);
|
if (ObjectUtil.isEmpty(memberEntity)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0003"));
|
}
|
|
return Result.ok(MessageSourceUtils.getString("member_service_0071"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberTradersPwd(@Valid MemberForgetPwdDto memberForgetPwdDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity memberEntity = memberDao.selectById(memberId);
|
|
String code = memberForgetPwdDto.getCode();
|
String password = memberForgetPwdDto.getPassword();
|
String account = memberForgetPwdDto.getAccount();
|
int type = memberForgetPwdDto.getType();
|
|
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"));
|
}
|
|
return Result.ok(MessageSourceUtils.getString("member_service_0068"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberAddPaymethod(@Valid MemberPaymethodDto memberPaymethodDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity member = memberDao.selectById(memberId);
|
|
if(!MemberEntity.CERTIFY_STATUS_Y.equals(member.getCertifyStatus())) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0077"));
|
}
|
String account = memberPaymethodDto.getAccount();
|
String bank = memberPaymethodDto.getBank();
|
String name = memberPaymethodDto.getName();
|
String paymentQrcode = memberPaymethodDto.getPaymentQrcode();
|
String paymentType = memberPaymethodDto.getPaymentType();
|
String subBank = memberPaymethodDto.getSubBank();
|
String isDefualt = memberPaymethodDto.getIsDefualt();
|
MemberPaymentMethodEntity memberPaymentMethodEntity = new MemberPaymentMethodEntity();
|
memberPaymentMethodEntity.setMemberId(memberId);
|
memberPaymentMethodEntity.setAccount(account);
|
memberPaymentMethodEntity.setBank(bank);
|
memberPaymentMethodEntity.setName(name);
|
memberPaymentMethodEntity.setPaymentQrcode(paymentQrcode);
|
memberPaymentMethodEntity.setPaymentType(paymentType);
|
memberPaymentMethodEntity.setSubBank(subBank);
|
memberPaymentMethodEntity.setIsDefualt(isDefualt);
|
memberPaymentMethodDao.insert(memberPaymentMethodEntity);
|
return Result.ok(MessageSourceUtils.getString("member_service_0024"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberDelPaymethod(@Valid MemberDelPaymethodDto memberDelPaymethodDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Long id = memberDelPaymethodDto.getId();
|
Map<String,Object> columnMap = new HashMap<>();
|
columnMap.put("id", id);
|
columnMap.put("member_id", memberId);
|
memberPaymentMethodDao.deleteByMap(columnMap);
|
return Result.ok("success");
|
}
|
|
@Override
|
public Result memberPaymethodDetail(long id) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberPaymentMethodEntity memberPaymentMethod = memberPaymentMethodDao.selectById(id);
|
|
MemberPaymethodDetailVo memberPaymethodDetailVo = new MemberPaymethodDetailVo();
|
memberPaymethodDetailVo.setAccount(memberPaymentMethod.getAccount());
|
memberPaymethodDetailVo.setBank(memberPaymentMethod.getBank());
|
memberPaymethodDetailVo.setMemberId(memberId);
|
memberPaymethodDetailVo.setName(memberPaymentMethod.getName());
|
memberPaymethodDetailVo.setPaymentQrcode(memberPaymentMethod.getPaymentQrcode());
|
memberPaymethodDetailVo.setPaymentType(memberPaymentMethod.getPaymentType());
|
memberPaymethodDetailVo.setSubBank(memberPaymentMethod.getSubBank());
|
|
return Result.ok(memberPaymethodDetailVo);
|
}
|
|
@Override
|
public Result memberPaymethodDetailList() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Map<String,Object> columnMap = new HashMap<>();
|
columnMap.put("member_id", memberId);
|
List<MemberPaymentMethodEntity> selectByMap = memberPaymentMethodDao.selectByMap(columnMap);
|
List<MemberPaymethodDetailVo> arrayList = new ArrayList<>();
|
if(CollUtil.isNotEmpty(selectByMap)) {
|
for(MemberPaymentMethodEntity memberPaymentMethodEntity : selectByMap) {
|
MemberPaymethodDetailVo memberPaymethodDetailVo = new MemberPaymethodDetailVo();
|
memberPaymethodDetailVo.setAccount(memberPaymentMethodEntity.getAccount());
|
memberPaymethodDetailVo.setBank(memberPaymentMethodEntity.getBank());
|
memberPaymethodDetailVo.setMemberId(memberId);
|
memberPaymethodDetailVo.setName(memberPaymentMethodEntity.getName());
|
memberPaymethodDetailVo.setPaymentQrcode(memberPaymentMethodEntity.getPaymentQrcode());
|
memberPaymethodDetailVo.setPaymentType(memberPaymentMethodEntity.getPaymentType());
|
memberPaymethodDetailVo.setSubBank(memberPaymentMethodEntity.getSubBank());
|
arrayList.add(memberPaymethodDetailVo);
|
}
|
}
|
|
MemberPaymethodDetailListVo memberPaymethodDetailListVo = new MemberPaymethodDetailListVo();
|
memberPaymethodDetailListVo.setMemberPaymethodDetailVo(arrayList);
|
return Result.ok(memberPaymethodDetailListVo);
|
}
|
|
@Override
|
@Transactional
|
public Result memberBindPhone(@Valid MemberBindPhoneDto memberBindPhoneDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
String phone = memberBindPhoneDto.getPhone();
|
String code = memberBindPhoneDto.getCode();
|
|
MemberEntity member = memberDao.selectById(memberId);
|
String smsCode = redisUtils.get("SMS_" + phone) + "";
|
|
if (ObjectUtil.isNotEmpty(member)) {
|
if (StrUtil.isEmpty(smsCode)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0038"));
|
}
|
if (!smsCode.equals(code)) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0013"));
|
}
|
member.setPhone(phone);
|
memberDao.updateById(member);
|
return Result.ok(MessageSourceUtils.getString("member_service_0014"));
|
}
|
|
return Result.fail(MessageSourceUtils.getString("member_service_0015"));
|
}
|
|
@Override
|
@Transactional
|
public Result memberBindEmail(@Valid MemberBindEmailDto memberBindEmailDto) {
|
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
String email = memberBindEmailDto.getEmail();
|
String code = memberBindEmailDto.getCode();
|
|
MemberEntity member = memberDao.selectById(memberId);
|
boolean flag = commonservice.verifyCode(email, code);
|
if (ObjectUtil.isNotEmpty(member)) {
|
if (flag) {
|
member.setEmail(email);
|
memberDao.updateById(member);
|
return Result.ok(MessageSourceUtils.getString("member_service_0018"));
|
}
|
}
|
return Result.fail(MessageSourceUtils.getString("member_service_0019"));
|
}
|
|
@Override
|
public Result memberCoinAddressCount() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
List<MemberCoinAddressCountVo> list = platformSymbolsCoinDao.selectCoinAddressCount(memberId);
|
MemberCoinAddressCountListVo memberCoinAddressCountListVo = new MemberCoinAddressCountListVo();
|
if(CollUtil.isNotEmpty(list)) {
|
memberCoinAddressCountListVo.setMemberCoinAddressCountVo(list);
|
return Result.ok(memberCoinAddressCountListVo);
|
}
|
return Result.fail(MessageSourceUtils.getString("member_service_0020"));
|
}
|
|
@Override
|
public Result memberCoinAddressList(String symbol) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Map<String, Object> columnMap = new HashMap<>();
|
columnMap.put("member_id", memberId);
|
columnMap.put("symbol", symbol);
|
List<MemberCoinAddressEntity> selectByMap = memberCoinAddressDao.selectByMap(columnMap);
|
MemberCoinAddressListVo memberCoinAddressListVo = new MemberCoinAddressListVo();
|
List<MemberCoinAddressVo> arrayList = new ArrayList<>();
|
if(CollUtil.isNotEmpty(selectByMap)) {
|
for(MemberCoinAddressEntity memberCoinAddressEntity : selectByMap) {
|
MemberCoinAddressVo memberCoinAddressVo = new MemberCoinAddressVo();
|
memberCoinAddressVo.setId(memberCoinAddressEntity.getId());
|
memberCoinAddressVo.setAddress(memberCoinAddressEntity.getAddress());
|
memberCoinAddressVo.setIsBiyict(memberCoinAddressEntity.getIsBiyict());
|
memberCoinAddressVo.setMemberId(memberCoinAddressEntity.getMemberId());
|
memberCoinAddressVo.setPrivateKey(memberCoinAddressEntity.getPrivateKey());
|
memberCoinAddressVo.setSymbol(memberCoinAddressEntity.getSymbol());
|
memberCoinAddressVo.setLabel(memberCoinAddressEntity.getLabel());
|
memberCoinAddressVo.setSymbolscoinId(memberCoinAddressEntity.getSymbolscoinId());
|
arrayList.add(memberCoinAddressVo);
|
}
|
}
|
memberCoinAddressListVo.setMemberCoinAddressVo(arrayList);
|
|
return Result.ok(memberCoinAddressListVo);
|
}
|
|
@Override
|
@Transactional
|
public Result memberAddCoinAddress(@Valid MemberAddCoinAddressDto memberAddCoinAddressDto) {
|
|
//获取用户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"));
|
}
|
|
@Override
|
public Result memberSendCodeWay() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberEntity member = memberDao.selectById(memberId);
|
MemberSendCodeWayVo memberSendCodeWayVo = new MemberSendCodeWayVo();
|
if(ObjectUtil.isNotEmpty(member)) {
|
memberSendCodeWayVo.setPhone(member.getPhone());
|
memberSendCodeWayVo.setEmail(member.getEmail());
|
}
|
return Result.ok(memberSendCodeWayVo);
|
}
|
|
}
|
