From 9c8711046b00898717aa7a3b9f6dfee974d3f427 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Sun, 31 May 2020 22:23:05 +0800 Subject: [PATCH] 20200531 代码提交 --- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 486 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 471 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 af6f9ec..afcf057 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 @@ -4,7 +4,6 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; -import cn.hutool.crypto.digest.MD5; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.xcong.excoin.common.LoginUserUtils; @@ -13,21 +12,47 @@ 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.MemberDelCoinAddressDto; +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.MemberAuthenticationInfoVo; +import com.xcong.excoin.modules.member.parameter.vo.MemberAvivableCoinInfoVo; +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.MemberCoinInfoListVo; +import com.xcong.excoin.modules.member.parameter.vo.MemberCoinInfoVo; 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.MemberPersonCenterInfoVo; +import com.xcong.excoin.modules.member.parameter.vo.MemberSendCodeWayVo; import com.xcong.excoin.modules.member.service.MemberService; +import com.xcong.excoin.modules.platform.dao.PlatformFeeSettingDao; +import com.xcong.excoin.modules.platform.dao.PlatformSymbolsCoinDao; +import com.xcong.excoin.modules.platform.entity.PlatformFeeSettingEntity; +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; @@ -61,9 +86,27 @@ @Resource MemberAuthenticationDao memberAuthenticationDao; - @Autowired + @Resource RedisUtils redisUtils; - + + @Resource + MemberPaymentMethodDao memberPaymentMethodDao; + + @Resource + PlatformSymbolsCoinDao platformSymbolsCoinDao; + + @Resource + PlatformFeeSettingDao platformFeeSettingDao; + + @Resource + MemberCoinAddressDao memberCoinAddressDao; + + @Resource + private CommonService commonservice; + + @Resource + private MemberWalletContractSimulateDao memberWalletContractSimulateDao; + @Transactional() @Override public Result register(RegisterDto registerDto) { @@ -129,6 +172,15 @@ 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()) { @@ -172,38 +224,56 @@ } @Override + @Transactional 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); }else { return Result.fail(MessageSourceUtils.getString("member_service_0045")); } - if(type == 1) { - redisUtils.del("SMS_" + phone); - }else { - redisUtils.del("EMAIL_" + email); - } 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")); } /** @@ -298,4 +368,390 @@ 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(); + 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); + 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.setId(memberPaymentMethodEntity.getId()); + 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); + } + + @Override + @Transactional + public Result memberDelCoinAddress(@Valid MemberDelCoinAddressDto memberDelCoinAddressDto) { + //获取用户ID + Long memberId = LoginUserUtils.getAppLoginUser().getId(); + MemberEntity member = memberDao.selectById(memberId); + if(ObjectUtil.isNotEmpty(member)) { + Long id = memberDelCoinAddressDto.getId(); + memberCoinAddressDao.deleteById(id); + } + return Result.ok("success"); + } + + @Override + public Result memberAuthenticationInfo() { + //获取用户ID + Long memberId = LoginUserUtils.getAppLoginUser().getId(); + MemberEntity member = memberDao.selectById(memberId); + + Map<String, Object> columnMap = new HashMap<>(); + columnMap.put("member_id", memberId); + List<MemberAuthenticationEntity> selectByMap = memberAuthenticationDao.selectByMap(columnMap); + + MemberAuthenticationInfoVo memberAuthnticationInfoVo = new MemberAuthenticationInfoVo(); + memberAuthnticationInfoVo.setCertifyStatus(member.getCertifyStatus()); + if(CollUtil.isNotEmpty(selectByMap)) { + for(MemberAuthenticationEntity memberAuthenticationEntity : selectByMap) { + memberAuthnticationInfoVo.setFirstName(memberAuthenticationEntity.getFirstName()); + memberAuthnticationInfoVo.setSecondName(memberAuthenticationEntity.getSecondName()); + memberAuthnticationInfoVo.setNation(memberAuthenticationEntity.getNation()); + memberAuthnticationInfoVo.setIdCardNo(memberAuthenticationEntity.getIdcardNo()); + } + } + return Result.ok(memberAuthnticationInfoVo); + } + + @Override + public Result memberPersonCenterInfo() { + //获取用户ID + Long memberId = LoginUserUtils.getAppLoginUser().getId(); + MemberEntity member = memberDao.selectById(memberId); + + MemberPersonCenterInfoVo memberPersonCenterInfoVo = new MemberPersonCenterInfoVo(); + if(StrUtil.isNotEmpty(member.getPhone())) { + memberPersonCenterInfoVo.setPhone(1); + } + memberPersonCenterInfoVo.setPhone(0); + + if(StrUtil.isNotEmpty(member.getEmail())) { + memberPersonCenterInfoVo.setEmail(1); + } + memberPersonCenterInfoVo.setEmail(0); + + if(StrUtil.isNotEmpty(member.getTradePassword())) { + memberPersonCenterInfoVo.setTradePassword(1); + } + memberPersonCenterInfoVo.setTradePassword(0); + + if(StrUtil.isNotEmpty(member.getTradeAgingSetting().toString())) { + memberPersonCenterInfoVo.setTradeAgingSetting(MemberPersonCenterInfoVo.PWD_NEED_FORVER); + } + memberPersonCenterInfoVo.setTradeAgingSetting(MemberPersonCenterInfoVo.PWD_NEED_FORVER); + + return Result.ok(memberPersonCenterInfoVo); + } + + @Override + public Result memberCoinInfoList() { + //获取用户ID + Long memberId = LoginUserUtils.getAppLoginUser().getId(); + + MemberCoinInfoListVo memberCoinInfoListVo = new MemberCoinInfoListVo(); + List<PlatformSymbolsCoinEntity> selectByMap = platformSymbolsCoinDao.selectByMap(new HashMap<>()); + List<MemberCoinInfoVo> arrayList = new ArrayList<>(); + if(CollUtil.isNotEmpty(selectByMap)) { + for(PlatformSymbolsCoinEntity platformSymbolsCoinEntity : selectByMap) { + MemberCoinInfoVo memberCoinInfoVo = new MemberCoinInfoVo(); + memberCoinInfoVo.setName(platformSymbolsCoinEntity.getName()); + arrayList.add(memberCoinInfoVo); + } + } + memberCoinInfoListVo.setMemberCoinInfoVo(arrayList); + + return Result.ok(memberCoinInfoListVo); + } + + @Override + public Result memberAvivableCoinInfo(String symbol) { + //获取用户ID + Long memberId = LoginUserUtils.getAppLoginUser().getId(); + MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, symbol); + if (ObjectUtil.isEmpty(walletCoin)) { + return Result.fail(MessageSourceUtils.getString("member_service_0087")); + } + + MemberAvivableCoinInfoVo memberAvivableCoinInfoVo = new MemberAvivableCoinInfoVo(); + memberAvivableCoinInfoVo.setAvailableBalance(walletCoin.getAvailableBalance()); + + PlatformFeeSettingEntity feeSetting = platformFeeSettingDao.getFeeSettingByTypeAndSymbol(2,symbol); + memberAvivableCoinInfoVo.setFee(feeSetting.getFeePrice()); + return Result.ok(memberAvivableCoinInfoVo); + } + } -- Gitblit v1.9.1