20210517 云顶

xiaoyong931011

2021-05-18 d123da994f9e70a56a95586c3c9c2fd0f8cbcfce

 src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java

@@ -13,8 +13,10 @@
import com.xcong.excoin.common.configure.FebsConfigure;
import com.xcong.excoin.common.entity.FebsResponse;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.common.exception.GlobalException;
import com.xcong.excoin.modules.Sms106Send;
import com.xcong.excoin.modules.member.dto.MemberDetailConfirmDto;
import com.xcong.excoin.modules.member.entity.ActivityReceiveRecord;
import com.xcong.excoin.modules.member.entity.AgentFriendRelationEntity;
import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity;
import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity;
@@ -34,6 +36,7 @@
import com.xcong.excoin.modules.member.mapper.MemberQuickBuySaleMapper;
import com.xcong.excoin.modules.member.mapper.MemberWalletCoinMapper;
import com.xcong.excoin.modules.member.service.IMemberService;
import com.xcong.excoin.modules.member.vo.MemberActivityReceiveVo;
import com.xcong.excoin.modules.member.vo.MemberAuthenticationVo;
import com.xcong.excoin.modules.member.vo.MemberCoinChargeVo;
import com.xcong.excoin.modules.member.vo.MemberCoinWithdrawVo;
@@ -488,7 +491,7 @@
   }

   @Override
   @Transactional
   @Transactional(rollbackFor = Exception.class)
   public FebsResponse memberWithdrawCoinConfirm(@NotNull(message = "{required}") Long id) {
      
      MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id);
@@ -516,10 +519,19 @@
         columnMap.put("address", address);
         // 如果是内部转账 则需要将币加到内部地址
         List<MemberCoinAddressEntity> selectByMap = memberCoinAddressMapper.selectByMap(columnMap);
         if(selectByMap == null || selectByMap.isEmpty()) {
            return new FebsResponse().message("地址有误，请拒绝！");
         Long aimMemberId = null;
         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();
         }
         Long aimMemberId = selectByMap.get(0).getMemberId();
         MemberWalletCoinEntity aimWalletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(aimMemberId, symbol);
         
         BigDecimal addTotal = aimWalletCoin.getTotalBalance().add(selectById.getAmount());
@@ -2296,4 +2308,21 @@
      return selectMemberListInPage;
   }


   @Override
   public IPage<MemberActivityReceiveVo> memberActivityReceive(ActivityReceiveRecord activityReceiveRecord,
         QueryRequest request) {

      Page<ActivityReceiveRecord> page = new Page<>(request.getPageNum(), request.getPageSize());
      return memberMapper.memberActivityReceive(page, activityReceiveRecord);
   }


   @Override
   public IPage<ActivityReceiveRecord> seeReceiveInfo(QueryRequest request,
         ActivityReceiveRecord activityReceiveRecord) {
      Page<ActivityReceiveRecord> page = new Page<>(request.getPageNum(), request.getPageSize());
      return memberMapper.seeReceiveInfo(page, activityReceiveRecord);
   }

}