xiaoyong931011
2021-03-23 1cb1f88c71eaafe867c8eff12839ff5bcfd64657
src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -3,10 +3,14 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
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.modules.Sms106Send;
@@ -93,10 +97,10 @@
      if(records != null && records.size() > 0) {
         for(AgentFriendRelationEntity agentFriendRelation : records) {
            String inviteId = agentFriendRelation.getInviteId();
            if("90457646".equals(inviteId)) {
            if("rxadr3".equals(inviteId)) {
               //该邀请码下的所有代理
               Map<String, Object> columnMap = new HashMap<>();
               columnMap.put("referer_id", "90457646");
               columnMap.put("referer_id", "rxadr3");
               List<AgentFriendRelationEntity> selectByMap = agentFriendRelationMapper.selectByMap(columnMap);
               
               if(selectByMap != null && selectByMap.size() > 0) {
@@ -396,6 +400,23 @@
   @Override
   public IPage<MemberCoinChargeVo> findMemberApplyCoinListInPage(MemberCoinChargeEntity memberCoinChargeEntity,
         QueryRequest request) {
      //查询条件 查询某条线下的所有数据
      String account = memberCoinChargeEntity.getAccount();
      //如果account为空,查询全部,account不为空查询对应的memberEntity
      if(StrUtil.isNotEmpty(account)) {
         MemberEntity selectMemberByAccount = memberMapper.selectMemberByAccount(account);
         String inviteId = selectMemberByAccount.getInviteId();
         Long id = selectMemberByAccount.getId();
         memberCoinChargeEntity.setMemberId(id);
         memberCoinChargeEntity.setInviteId(inviteId);
      }else {
         MemberEntity memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
         String inviteId = memberEntity.getInviteId();
         Long id = memberEntity.getId();
         memberCoinChargeEntity.setMemberId(id);
         memberCoinChargeEntity.setInviteId(inviteId);
      }
      Page<MemberCoinChargeEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberCoinChargeVo> findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinListInPage(page, memberCoinChargeEntity);
      List<MemberCoinChargeVo> records = findmemberQuickBuySaleListInPage.getRecords();
@@ -421,8 +442,24 @@
   @Override
   public IPage<MemberCoinWithdrawVo> findmemberWithdrawCoinListInPage(
         MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) {
      Page<MemberCoinWithdrawEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      //查询条件 查询某条线下的所有数据
      String account = memberCoinWithdrawEntity.getAccount();
      //如果account为空,查询全部,account不为空查询对应的memberEntity
      if(StrUtil.isNotEmpty(account)) {
         MemberEntity selectMemberByAccount = memberMapper.selectMemberByAccount(account);
         String inviteId = selectMemberByAccount.getInviteId();
         Long id = selectMemberByAccount.getId();
         memberCoinWithdrawEntity.setMemberId(id);
         memberCoinWithdrawEntity.setInviteId(inviteId);
      }else {
         MemberEntity memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
         String inviteId = memberEntity.getInviteId();
         Long id = memberEntity.getId();
         memberCoinWithdrawEntity.setMemberId(id);
         memberCoinWithdrawEntity.setInviteId(inviteId);
      }
      
      Page<MemberCoinWithdrawEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberCoinWithdrawVo> findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findmemberWithdrawCoinListInPage(page, memberCoinWithdrawEntity);
      List<MemberCoinWithdrawVo> records = findmemberQuickBuySaleListInPage.getRecords();
      if(records != null && records.size() > 0) {
@@ -2182,4 +2219,79 @@
      return findmemberQuickBuySaleListInPage;
   }
   @Override
   public IPage<MemberDataInfoVo> findAllDataInfoListInPage(MemberEntity memberEntity, QueryRequest request) {
      String account = memberEntity.getAccount();
      String isTest = memberEntity.getIsTest();
      //如果account为空,查询全部,account不为空查询对应的memberEntity
      if(StrUtil.isNotEmpty(account)) {
         memberEntity = memberMapper.selectMemberByAccount(account);
      }else {
         memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
      }
      memberEntity.setIsTest(isTest);
      Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberDataInfoVo> selectMemberListInPage = memberMapper.findMemberDataInfoOneAllRealInPage(page, memberEntity);
      //USDT充币总额+USDT提币总额
       String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForAllDataInfo(memberEntity);
       String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForAllDataInfo(memberEntity);
       String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForAllDataInfo(memberEntity);
       String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForAllDataInfo(memberEntity);
      //佣金
      String returnMoneyByMid = memberMapper.selectReturnMoneyForAllDataInfo(memberEntity);
      //开仓手续费
      String closingpriceByMid = memberMapper.selectClosingpriceForAllDataInfo(memberEntity);
      //平仓总手续费
      String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForForAllDataInfo(memberEntity);
      //总盈亏
      String rewardratioByMid = memberMapper.selectRewardratioForAllDataInfo(memberEntity);
      //持仓人数
      String notNullNumber = memberMapper.selectSFCCForAllDataInfo(memberEntity);
      //币币账户不为空的人数
      String walletNumber = memberMapper.selectBBZHForAllDataInfo(memberEntity);
      //合约账户不为空的人数
      String walletCoinNumber = memberMapper.selectHYZHForAllDataInfo(memberEntity);
      //持仓手续费
      String doingPrice = memberMapper.selectprepriceForAllDataInfo(memberEntity);
      //账户金额
      String walletNum = memberMapper.selectBBZCForAllDataInfo(memberEntity);
      String walletCoinNum = memberMapper.selectHYZCForAllDataInfo(memberEntity);
      String agentNum = memberMapper.selectDLZCForAllDataInfo(memberEntity);
      double allCoin = 0 ;
      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))
            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))
            +(agentNum == null ? 0 : Double.parseDouble(agentNum));
      double platformProfitAndLoss = 0 ;
      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));
      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));
      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));
      List<MemberDataInfoVo> records = selectMemberListInPage.getRecords();
      for(MemberDataInfoVo memberDataInfoVo : records) {
         memberDataInfoVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));
         memberDataInfoVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));
         memberDataInfoVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
         memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));
         memberDataInfoVo.setClosingPrice(closingpriceByMid == null ? "0" : closingpriceByMid);
         memberDataInfoVo.setSellClosingPrice(sellClosingpriceByMid == null ? "0" : sellClosingpriceByMid);
         memberDataInfoVo.setFee(returnMoneyByMid == null ? "0" : returnMoneyByMid);
         memberDataInfoVo.setYingkui(rewardratioByMid == null ? "0" : rewardratioByMid);
         memberDataInfoVo.setNotNullNumber(notNullNumber == null ? "0" : notNullNumber);
         memberDataInfoVo.setWalletNumber(walletNumber == null ? "0" : walletNumber);
         memberDataInfoVo.setWalletCoinNumber(walletCoinNumber == null ? "0" : walletCoinNumber);
         memberDataInfoVo.setPlatformProfitAndLoss(platformProfitAndLoss == 0 ? "0" : platformProfitAndLoss+"");
         memberDataInfoVo.setDoingPrice(doingPrice == null ? "0" : doingPrice);
         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);
         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);
         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);
         memberDataInfoVo.setAllCoin(allCoin);
      }
      selectMemberListInPage.setTotal(1);
      return selectMemberListInPage;
   }
}