| | |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.hutool.crypto.SecureUtil; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | 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.system.dto.RegisterDto; |
| | | import com.xcong.excoin.common.system.service.CommonService; |
| | | import com.xcong.excoin.modules.coin.dao.MemberAccountMoneyChangeDao; |
| | | import com.xcong.excoin.modules.coin.dao.ZhiYaDao; |
| | | import com.xcong.excoin.modules.coin.entity.MemberAccountMoneyChange; |
| | | import com.xcong.excoin.modules.coin.entity.ZhiYaEntity; |
| | | import com.xcong.excoin.modules.coin.parameter.vo.ZhiyaInfoVo; |
| | | 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.MemberSubmitCoinApplyDto; |
| | | 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.dto.MemberUpdateTradersPwdTimeDto; |
| | | import com.xcong.excoin.modules.member.parameter.dto.*; |
| | | import com.xcong.excoin.modules.member.parameter.vo.*; |
| | | import com.xcong.excoin.modules.member.service.MemberService; |
| | | import com.xcong.excoin.modules.platform.dao.PlatformFeeSettingDao; |
| | |
| | | import com.xcong.excoin.utils.MessageSourceUtils; |
| | | import com.xcong.excoin.utils.RedisUtils; |
| | | import com.xcong.excoin.utils.ShareCodeUtil; |
| | | import com.xcong.excoin.utils.ThreadPoolUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.security.core.context.SecurityContextHolder; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | private MemberWalletCoinDao memberWalletCoinDao; |
| | | |
| | | @Resource |
| | | private ZhiYaDao zhiYaDao; |
| | | |
| | | @Resource |
| | | private MemberLevelRateDao memberLevelRateDao; |
| | | |
| | | @Resource |
| | |
| | | |
| | | @Resource |
| | | MemberCoinWithdrawDao memberCoinWithdrawDao; |
| | | |
| | | |
| | | @Resource |
| | | AppVersionDao appVersionDao; |
| | | @Resource |
| | | private MemberSettingDao memberSettingDao; |
| | | |
| | | @Resource |
| | | private MemberWalletContractSimulateDao memberWalletContractSimulateDao; |
| | |
| | | if (member != null) { |
| | | 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())); |
| | |
| | | // 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) { |
| | | member.setRefererId(registerDto.getRefererId()); |
| | | } |
| | | } |
| | | |
| | | member.setRefererId(registerDto.getRefererId()); |
| | | member.setAccountStatus(MemberEntity.ACCOUNT_STATUS_ENABLE); |
| | | member.setAccountType(registerDto.getType()); |
| | | member.setAccountType(MemberEntity.ACCOUNT_TYPE_NORMAL); |
| | | member.setAgentLevel(MemberEntity.ACCOUNT_AGENT_LEVEL); |
| | | member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_UN_SUBMIT); |
| | | member.setIsForce(0); |
| | | member.setIsForce(1); |
| | | member.setIsProfit(0); |
| | | member.setSpread(BigDecimal.ZERO); |
| | | memberDao.insert(member); |
| | | |
| | | MemberSettingEntity memberSettingEntity = new MemberSettingEntity(); |
| | | memberSettingEntity.setSpread(BigDecimal.ONE); |
| | | memberSettingEntity.setClosingSpread(BigDecimal.valueOf(5)); |
| | | memberSettingEntity.setForceParam(BigDecimal.valueOf(0.0030)); |
| | | memberSettingEntity.setMemberId(member.getId()); |
| | | memberSettingDao.insert(memberSettingEntity); |
| | | |
| | | String inviteId = ShareCodeUtil.toSerialCode(member.getId()); |
| | | member.setInviteId(inviteId); |
| | |
| | | boolean flag = false; |
| | | String parentId = member.getRefererId(); |
| | | String ids = ""; |
| | | while (!flag) { |
| | | while (!flag && StringUtils.isNotBlank(parentId)) { |
| | | ids += ("," + parentId); |
| | | MemberEntity parentMember = memberDao.selectMemberInfoByInviteId(parentId); |
| | | if (parentMember == null) { |
| | | break; |
| | | } |
| | | parentId = parentMember.getRefererId(); |
| | | if(StringUtils.isBlank(parentId)){ |
| | | break; |
| | | } |
| | | if (parentMember.getRefererId().equals(parentMember.getInviteId())) { |
| | | flag = true; |
| | | } |
| | |
| | | memberWalletCoinDao.insert(walletCoin); |
| | | } |
| | | |
| | | //初始化质押 |
| | | ZhiYaEntity zhiYaEntity = new ZhiYaEntity(); |
| | | zhiYaEntity.setMemberId(member.getId()); |
| | | zhiYaEntity.setAvailableBalance(AppContants.INIT_MONEY); |
| | | zhiYaEntity.setFrozenBalance(AppContants.INIT_MONEY); |
| | | zhiYaEntity.setTotalBalance(AppContants.INIT_MONEY); |
| | | zhiYaDao.insert(zhiYaEntity); |
| | | |
| | | // 初始化代理佣金钱包 |
| | | MemberWalletAgentEntity walletAgent = new MemberWalletAgentEntity(); |
| | | walletAgent.setMemberId(member.getId()); |
| | |
| | | levelRate.setSymbol(symbolEnum.getValue()); |
| | | memberLevelRateDao.insert(levelRate); |
| | | } |
| | | return Result.ok("success"); |
| | | |
| | | return Result.ok(MessageSourceUtils.getString("home_service_0009")); |
| | | } |
| | | |
| | | @Override |
| | |
| | | //获取用户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 (MemberEntity.CERTIFY_STATUS_ING.equals(member.getCertifyStatus())) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_4000")); |
| | | } |
| | | if (ObjectUtil.isNotEmpty(member)) { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("member_id", memberId); |
| | | MemberAuthenticationEntity memberAuthenticationEntity = new MemberAuthenticationEntity(); |
| | | List<MemberAuthenticationEntity> selectByMap = memberAuthenticationDao.selectByMap(columnMap); |
| | | if(CollUtil.isNotEmpty(selectByMap)) { |
| | | memberAuthenticationEntity = selectByMap.get(0); |
| | | } |
| | | |
| | | MemberAuthenticationEntity memberAuthenticationEntity = new MemberAuthenticationEntity(); |
| | | |
| | | if (MemberEntity.CERTIFY_STATUS_Y == member.getCertifyStatus()) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0055")); |
| | | } |
| | |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0059")); |
| | | } |
| | | memberAuthenticationEntity.setSecondName(memberAuthenticationDto.getSecondName()); |
| | | |
| | | |
| | | String type = memberAuthenticationDto.getType(); |
| | | memberAuthenticationEntity.setType(type); |
| | | |
| | | |
| | | String idCardNo = memberAuthenticationDto.getIdCardNo(); |
| | | if (StrUtil.isBlank(idCardNo)) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0060")); |
| | | 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")); |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0060")); |
| | | } |
| | | // 同一个人只能认证一次 |
| | | int authenByMemberId = memberAuthenticationDao.findAuthenByMemberId(memberId); |
| | | if (authenByMemberId > 0) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0055")); |
| | | } |
| | | if (StrUtil.isBlank(memberAuthenticationDto.getIdCardFront()) |
| | | || StrUtil.isBlank(memberAuthenticationDto.getIdCardReverse()) |
| | |
| | | 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); |
| | | memberDao.updateById(member); |
| | | /** |
| | | * TODO dingtalk |
| | | |
| | | Constant.excutor.execute(new Runnable() { |
| | | @Override public void run() { |
| | | DingTalkUtils.sendActionCard(4); |
| | | } |
| | | });*/ |
| | | ThreadPoolUtils.sendDingTalk(4); |
| | | return Result.ok(MessageSourceUtils.getString("member_service_0024")); |
| | | } |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0063")); |
| | |
| | | @Transactional |
| | | public Result memberTradersPwd(@Valid MemberForgetPwdDto memberForgetPwdDto) { |
| | | //获取用户ID |
| | | MemberEntity memberEntity = LoginUserUtils.getAppLoginUser(); |
| | | Long memberId = LoginUserUtils.getAppLoginUser().getId(); |
| | | MemberEntity memberEntity = memberDao.selectById(memberId); |
| | | |
| | | String code = memberForgetPwdDto.getCode(); |
| | | String password = memberForgetPwdDto.getPassword(); |
| | |
| | | if (!MemberEntity.CERTIFY_STATUS_Y.equals(member.getCertifyStatus())) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0077")); |
| | | } |
| | | |
| | | |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("member_id", memberId); |
| | | List<MemberPaymentMethodEntity> selectByMap = memberPaymentMethodDao.selectByMap(columnMap); |
| | | if(CollUtil.isNotEmpty(selectByMap)) { |
| | | for(MemberPaymentMethodEntity memberPaymentMethodEntity : selectByMap) { |
| | | if(memberPaymethodDto.getAccount().equals(memberPaymentMethodEntity.getAccount())) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0097")); |
| | | } |
| | | } |
| | | } |
| | | List<MemberPaymentMethodEntity> selectByMap = memberPaymentMethodDao.selectByMap(columnMap); |
| | | if (CollUtil.isNotEmpty(selectByMap)) { |
| | | for (MemberPaymentMethodEntity memberPaymentMethodEntity : selectByMap) { |
| | | if (memberPaymethodDto.getAccount().equals(memberPaymentMethodEntity.getAccount())) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0097")); |
| | | } |
| | | } |
| | | } |
| | | String account = memberPaymethodDto.getAccount(); |
| | | String bank = memberPaymethodDto.getBank(); |
| | | String name = memberPaymethodDto.getName(); |
| | |
| | | @Override |
| | | @Transactional |
| | | public Result memberBindPhone(@Valid MemberBindPhoneDto memberBindPhoneDto) { |
| | | //获取用户ID |
| | | //获取用户ID |
| | | Long memberId = LoginUserUtils.getAppLoginUser().getId(); |
| | | String phone = memberBindPhoneDto.getPhone(); |
| | | String code = memberBindPhoneDto.getCode(); |
| | |
| | | MemberEntity member = memberDao.selectById(memberId); |
| | | |
| | | if (ObjectUtil.isNotEmpty(member)) { |
| | | if (!commonservice.verifyCode(phone, code)) { |
| | | if (!commonservice.mutiVerifyCode(member.getEmail(), memberBindPhoneDto.getOtherCode(), phone, code)) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0013")); |
| | | } |
| | | // 验证邮箱验证码 |
| | | // if (!commonservice.verifyCode(member.getEmail(), memberBindPhoneDto.getOtherCode())) { |
| | | // return Result.fail("邮箱"+MessageSourceUtils.getString("member_service_0013")); |
| | | // } |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("phone", phone); |
| | | List<MemberEntity> selectByMap = memberDao.selectByMap(columnMap ); |
| | | if(CollUtil.isEmpty(selectByMap)) { |
| | | member.setPhone(phone); |
| | | memberDao.updateById(member); |
| | | return Result.ok(MessageSourceUtils.getString("member_service_0014")); |
| | | }else { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_1400")); |
| | | List<MemberEntity> selectByMap = memberDao.selectByMap(columnMap); |
| | | if (CollUtil.isEmpty(selectByMap)) { |
| | | member.setPhone(phone); |
| | | memberDao.updateById(member); |
| | | return Result.ok(MessageSourceUtils.getString("member_service_0014")); |
| | | } else { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_1400")); |
| | | } |
| | | } |
| | | |
| | |
| | | @Transactional |
| | | public Result memberBindEmail(@Valid MemberBindEmailDto memberBindEmailDto) { |
| | | |
| | | //获取用户ID |
| | | //获取用户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); |
| | | boolean flag = commonservice.mutiVerifyCode(email, code, member.getPhone(), memberBindEmailDto.getOtherCode()); |
| | | // boolean flag2 = commonservice.verifyCode(member.getPhone(), memberBindEmailDto.getOtherCode()); |
| | | if(!flag){ |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0013")); |
| | | } |
| | | // if(!flag2){ |
| | | // return Result.fail("手机"+MessageSourceUtils.getString("member_service_0013")); |
| | | // } |
| | | if (ObjectUtil.isNotEmpty(member)) { |
| | | if (flag) { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("email", email); |
| | | List<MemberEntity> selectByMap = memberDao.selectByMap(columnMap ); |
| | | if(CollUtil.isEmpty(selectByMap)) { |
| | | member.setEmail(email); |
| | | List<MemberEntity> selectByMap = memberDao.selectByMap(columnMap); |
| | | if (CollUtil.isEmpty(selectByMap)) { |
| | | member.setEmail(email); |
| | | memberDao.updateById(member); |
| | | return Result.ok(MessageSourceUtils.getString("member_service_0018")); |
| | | }else { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_1400")); |
| | | } else { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_1400")); |
| | | } |
| | | } |
| | | } |
| | |
| | | MemberCoinAddressEntity memberCoinAddressEntity = new MemberCoinAddressEntity(); |
| | | memberCoinAddressEntity.setAddress(address); |
| | | memberCoinAddressEntity.setMemberId(memberId); |
| | | memberCoinAddressEntity.setIsBiyict(isBiyict); |
| | | memberCoinAddressEntity.setIsBiyict(MemberCoinAddressEntity.IS_BIYICT_NO); |
| | | memberCoinAddressEntity.setSymbolscoinId(symbolscoinId); |
| | | memberCoinAddressEntity.setLabel(remark); |
| | | memberCoinAddressEntity.setSymbol(platformSymbolsCoinEntity.getName()); |
| | |
| | | MemberEntity member = memberDao.selectById(memberId); |
| | | |
| | | 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); |
| | | if(CollUtil.isEmpty(selectByMap)) { |
| | | memberPersonCenterInfoVo.setMemberPaymentMethod(0); |
| | | }else { |
| | | memberPersonCenterInfoVo.setMemberPaymentMethod(1); |
| | | if (CollUtil.isEmpty(selectByMap)) { |
| | | memberPersonCenterInfoVo.setMemberPaymentMethod(0); |
| | | } else { |
| | | memberPersonCenterInfoVo.setMemberPaymentMethod(1); |
| | | } |
| | | |
| | | |
| | | if (StrUtil.isNotEmpty(member.getPhone())) { |
| | | memberPersonCenterInfoVo.setPhone(1); |
| | | } else { |
| | |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0087")); |
| | | } |
| | | |
| | | MemberAvivableCoinInfoVo memberAvivableCoinInfoVo = new MemberAvivableCoinInfoVo(); |
| | | memberAvivableCoinInfoVo.setAvailableBalance(walletCoin.getAvailableBalance()); |
| | | List<MemberAvivableCoinInfoVo> arrayList = new ArrayList<>(); |
| | | |
| | | PlatformFeeSettingEntity feeSetting = platformFeeSettingDao.getFeeSettingByTypeAndSymbol(2, symbol); |
| | | if (ObjectUtil.isEmpty(feeSetting)) { |
| | | |
| | | 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 |
| | |
| | | //获取用户ID |
| | | Long memberId = LoginUserUtils.getAppLoginUser().getId(); |
| | | MemberEntity member = memberDao.selectById(memberId); |
| | | String golden_limit_transfer = redisUtils.getString("GOLDEN_LIMIT_TRANSFER"); |
| | | // 判断是否限制 |
| | | if(StringUtils.isNotBlank(member.getPhone()) &&StringUtils.isNotBlank(golden_limit_transfer) && golden_limit_transfer.contains(member.getPhone())){ |
| | | return Result.fail("此账号有财务问题,需联系客服"); |
| | | } |
| | | if(StringUtils.isNotBlank(member.getEmail()) &&StringUtils.isNotBlank(golden_limit_transfer) && golden_limit_transfer.contains(member.getEmail())){ |
| | | return Result.fail("此账号有财务问题,需联系客服"); |
| | | } |
| | | if (member.getCertifyStatus() != MemberEntity.CERTIFY_STATUS_Y) { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0077")); |
| | | } |
| | |
| | | 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()); |
| | |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("symbol", memberSubmitCoinApplyDto.getSymbol()); |
| | | columnMap.put("address", memberSubmitCoinApplyDto.getAddress()); |
| | | columnMap.put("is_biyict", MemberCoinAddressEntity.IS_BIYICT_YES); |
| | | List<MemberCoinAddressEntity> selectByMap = memberCoinAddressDao.selectByMap(columnMap); |
| | | if (CollUtil.isEmpty(selectByMap)) { |
| | | memberCoinWithdrawEntity.setIsInside(MemberCoinWithdrawEntity.ISINSIDE_NO); |
| | |
| | | MemberAccountMoneyChange accountRecord = new MemberAccountMoneyChange(); |
| | | accountRecord.setContent("提币"); |
| | | accountRecord.setMemberId(memberId); |
| | | accountRecord.setAmount(memberSubmitCoinApplyDto.getCoinNumber()); |
| | | accountRecord.setAmount(coinNumber); |
| | | accountRecord.setWithdrawId(memberCoinWithdrawEntity.getId()); |
| | | accountRecord.setStatus(MemberAccountMoneyChange.STATUS_WAIT_INTEGER); |
| | | accountRecord.setSymbol(memberSubmitCoinApplyDto.getSymbol()); |
| | | accountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_COIN); |
| | | memberAccountMoneyChangeDao.insert(accountRecord); |
| | | /** |
| | | * TODO dingtalk |
| | | Constant.excutor.execute(new Runnable() { |
| | | @Override public void run() { |
| | | DingTalkUtils.sendActionCard(3); |
| | | } |
| | | }); |
| | | */ |
| | | |
| | | ThreadPoolUtils.sendDingTalk(3); |
| | | return Result.ok(MessageSourceUtils.getString("member_service_0086")); |
| | | } else { |
| | | return Result.fail(MessageSourceUtils.getString("member_service_0005")); |
| | |
| | | return Result.ok(""); |
| | | } |
| | | |
| | | @Override |
| | | public Result getAppVersionInfo() { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | List<AppVersionEntity> selectByMap = appVersionDao.selectByMap(columnMap); |
| | | List<Object> arrayList = new ArrayList<>(); |
| | | if(CollUtil.isNotEmpty(selectByMap)) { |
| | | for(AppVersionEntity appVersionEntity : selectByMap) { |
| | | AppVersionVo appVersionVo = new AppVersionVo(); |
| | | appVersionVo.setAddress(appVersionEntity.getAddress()); |
| | | appVersionVo.setType(appVersionEntity.getType()); |
| | | appVersionVo.setVersion(appVersionEntity.getVersion()); |
| | | arrayList.add(appVersionVo); |
| | | } |
| | | } |
| | | return Result.ok(arrayList); |
| | | } |
| | | @Override |
| | | public Result getAppVersionInfo() { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | List<AppVersionEntity> selectByMap = appVersionDao.selectByMap(columnMap); |
| | | List<Object> arrayList = new ArrayList<>(); |
| | | if (CollUtil.isNotEmpty(selectByMap)) { |
| | | for (AppVersionEntity appVersionEntity : selectByMap) { |
| | | AppVersionVo appVersionVo = new AppVersionVo(); |
| | | appVersionVo.setAddress(appVersionEntity.getAddress()); |
| | | appVersionVo.setType(appVersionEntity.getType()); |
| | | appVersionVo.setVersion(appVersionEntity.getVersion()); |
| | | arrayList.add(appVersionVo); |
| | | } |
| | | } |
| | | return Result.ok(arrayList); |
| | | } |
| | | |
| | | @Override |
| | | public Result getPcVersionInfo() { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | List<AppVersionEntity> selectByMap = appVersionDao.selectByMap(columnMap); |
| | | List<Object> arrayList = new ArrayList<>(); |
| | | if (CollUtil.isNotEmpty(selectByMap)) { |
| | | for (AppVersionEntity appVersionEntity : selectByMap) { |
| | | AppVersionVo appVersionVo = new AppVersionVo(); |
| | | appVersionVo.setAddress(appVersionEntity.getAddress()); |
| | | appVersionVo.setType(appVersionEntity.getType()); |
| | | appVersionVo.setVersion(appVersionEntity.getVersion()); |
| | | arrayList.add(appVersionVo); |
| | | } |
| | | } |
| | | return Result.ok(arrayList); |
| | | } |
| | | |
| | | @Override |
| | | public Result memberTeam(MemberTeamRecordsPageDto memberTeamRecordsPageDto) { |
| | | //获取用户ID |
| | | Long memberId = LoginUserUtils.getAppLoginUser().getId(); |
| | | MemberEntity member = memberDao.selectById(memberId); |
| | | Page<MemberTeamVo> page = new Page<>(memberTeamRecordsPageDto.getPageNum(), memberTeamRecordsPageDto.getPageSize()); |
| | | MemberEntity memberEntity = new MemberEntity(); |
| | | memberEntity.setId(memberId); |
| | | memberEntity.setInviteId(member.getInviteId()); |
| | | IPage<MemberTeamVo> lists = memberDao.selectAllTeamByInviteIdInPage(page, memberEntity); |
| | | return Result.ok(lists); |
| | | } |
| | | } |
| | | |
| | | |