| | |
| | | memberWalletCoinMapper.updateById(walletCoin); |
| | | |
| | | if ("Y".equals(selectById.getIsInside())) { |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("symbol", symbol); |
| | | columnMap.put("address", address); |
| | | // 如果是内部转账 则需要将币加到内部地址 |
| | | List<MemberCoinAddressEntity> selectByMap = memberCoinAddressMapper.selectByMap(columnMap); |
| | | |
| | | Long aimMemberId = null; |
| | | if(CollUtil.isEmpty(selectByMap)) { |
| | | // return new FebsResponse().message("地址有误,请拒绝!"); |
| | | // throw new GlobalException("地址有误,请拒绝!"); |
| | | MemberEntity memberEntity = memberMapper.selectMemberInfoByQueryKey(address); |
| | | if(symbol.equals("XCH")){ |
| | | MemberEntity memberEntity = memberMapper.selectMemberByInviteId(address); |
| | | if (memberEntity == null) { |
| | | throw new GlobalException("地址有误或用户不存在,请拒绝!"); |
| | | } |
| | | |
| | | aimMemberId = memberEntity.getId(); |
| | | } else { |
| | | aimMemberId = selectByMap.get(0).getMemberId(); |
| | | }else{ |
| | | Map<String, Object> columnMap = new HashMap<>(); |
| | | columnMap.put("symbol", symbol); |
| | | columnMap.put("address", address); |
| | | // 如果是内部转账 则需要将币加到内部地址 |
| | | List<MemberCoinAddressEntity> selectByMap = memberCoinAddressMapper.selectByMap(columnMap); |
| | | if(CollUtil.isEmpty(selectByMap)) { |
| | | // return new FebsResponse().message("地址有误,请拒绝!"); |
| | | // throw new GlobalException("地址有误,请拒绝!"); |
| | | MemberEntity memberEntity = memberMapper.selectMemberInfoByQueryKey(address); |
| | | if (memberEntity == null) { |
| | | throw new GlobalException("地址有误或用户不存在,请拒绝!"); |
| | | } |
| | | |
| | | aimMemberId = memberEntity.getId(); |
| | | } else { |
| | | aimMemberId = selectByMap.get(0).getMemberId(); |
| | | } |
| | | } |
| | | MemberWalletCoinEntity aimWalletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(aimMemberId, symbol); |
| | | |