package com.xcong.excoin.modules.member.service.impl; 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; import com.xcong.excoin.modules.member.dto.MemberDetailConfirmDto; import com.xcong.excoin.modules.member.entity.AgentFriendRelationEntity; import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity; import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity; import com.xcong.excoin.modules.member.entity.MemberCoinAddressEntity; import com.xcong.excoin.modules.member.entity.MemberCoinChargeEntity; import com.xcong.excoin.modules.member.entity.MemberCoinWithdrawEntity; import com.xcong.excoin.modules.member.entity.MemberEntity; import com.xcong.excoin.modules.member.entity.MemberQuickBuySaleEntity; import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity; import com.xcong.excoin.modules.member.mapper.AgentFriendRelationMapper; import com.xcong.excoin.modules.member.mapper.MemberAccountMoneyChangeMapper; import com.xcong.excoin.modules.member.mapper.MemberAuthenticationMapper; import com.xcong.excoin.modules.member.mapper.MemberCoinAddressMapper; import com.xcong.excoin.modules.member.mapper.MemberCoinChargeMapper; import com.xcong.excoin.modules.member.mapper.MemberCoinWithdrawMapper; import com.xcong.excoin.modules.member.mapper.MemberMapper; 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.MemberAuthenticationVo; import com.xcong.excoin.modules.member.vo.MemberCoinChargeVo; import com.xcong.excoin.modules.member.vo.MemberCoinWithdrawVo; import com.xcong.excoin.modules.member.vo.MemberDataInfoVo; import com.xcong.excoin.modules.member.vo.MemberInfoDetailVo; import com.xcong.excoin.modules.member.vo.MemberQuickBuySaleVo; import com.xcong.excoin.modules.member.vo.MemberQuickSaleVo; import lombok.RequiredArgsConstructor; import java.math.BigDecimal; import java.text.DecimalFormat; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import javax.validation.Valid; import javax.validation.constraints.NotNull; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * @author wzy * @date 2020-06-10 **/ @Slf4j @Service @RequiredArgsConstructor public class MemberServiceImpl extends ServiceImpl implements IMemberService { private final MemberMapper memberMapper; private final MemberQuickBuySaleMapper memberQuickBuySaleMapper; private final MemberWalletCoinMapper memberWalletCoinMapper; private final MemberAccountMoneyChangeMapper memberAccountMoneyChangeMapper; private final MemberCoinChargeMapper memberCoinChargeMapper; private final MemberCoinWithdrawMapper memberCoinWithdrawMapper; private final MemberCoinAddressMapper memberCoinAddressMapper; private final MemberAuthenticationMapper memberAuthenticationMapper; private final AgentFriendRelationMapper agentFriendRelationMapper; @Override public IPage findAgentInfoListInPage(AgentFriendRelationEntity agentFriendRelationEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = agentFriendRelationMapper.findAgentFriendRelationListInPage(page, agentFriendRelationEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); List arraylist = new ArrayList<>(); if(records != null && records.size() > 0) { for(AgentFriendRelationEntity agentFriendRelation : records) { String inviteId = agentFriendRelation.getInviteId(); if("rxadr3".equals(inviteId)) { //该邀请码下的所有代理 Map columnMap = new HashMap<>(); columnMap.put("referer_id", "rxadr3"); List selectByMap = agentFriendRelationMapper.selectByMap(columnMap); if(selectByMap != null && selectByMap.size() > 0) { int i = 1; for(AgentFriendRelationEntity agentFriendRelationEntityTeam : selectByMap){ agentFriendRelationEntityTeam.setTeam(i+""); arraylist.add(agentFriendRelationEntityTeam); String inviteIdTeam = agentFriendRelationEntityTeam.getInviteId(); // 当前邀请码下的所有代理MemberID List lowLevelList = agentFriendRelationMapper.selectAgentFriendRelationByMap(inviteIdTeam); if(lowLevelList != null && lowLevelList.size() > 0) { for(AgentFriendRelationEntity lowLevelAgentFriendRelationEntity: lowLevelList) { lowLevelAgentFriendRelationEntity.setTeam(i+""); arraylist.add(lowLevelAgentFriendRelationEntity); } } i++; } } } if(arraylist != null && arraylist.size() > 0) { for(AgentFriendRelationEntity teamagentFriendRelationEntity : arraylist) { if(inviteId.equals(teamagentFriendRelationEntity.getInviteId())) { String team = teamagentFriendRelationEntity.getTeam(); agentFriendRelation.setTeam(team); } } } } } if(records != null && records.size() > 0) { for(AgentFriendRelationEntity agentFriendRelation : records) { List arrayList = new ArrayList<>(); String inviteId = agentFriendRelation.getInviteId(); String inviteIdCZ = null; String inviteIdTX = null; String inviteIdSY = null; // 当前邀请码下的所有代理MemberID List lowLevelList = agentFriendRelationMapper.selectAgentFriendRelationByMap(inviteId); List memberLevel = memberMapper.selectMemberBylowLevelInviteId(inviteId); arrayList.addAll(memberLevel); if(lowLevelList != null && lowLevelList.size() > 0) { for(AgentFriendRelationEntity lowLevelMemberId : lowLevelList) { Long memberId = lowLevelMemberId.getMemberId(); arrayList.add(memberId.toString()); List memberlowLevel = memberMapper.selectMemberBylowLevelInviteId(lowLevelMemberId.getInviteId()); arrayList.addAll(memberlowLevel); } Set set = new HashSet<>(); List newList = new ArrayList<>(); set.addAll(arrayList); newList.addAll(set); //获取对应的充值提现 double czNumber = 0; double txNumber = 0; if(newList != null && newList.size() > 0) { agentFriendRelation.setPromotionNumber(newList.size()); for(String memberId : newList) { //充币 String selectCBByMemberId = memberCoinChargeMapper.selectCBByMemberId(memberId); //充值 String selectCZByMemberI = memberQuickBuySaleMapper.selectCZByMemberId(memberId); //提币 String selectTBByMemberId = memberCoinWithdrawMapper.selectTBByMemberId(memberId); //提现 String selectTXByMemberId = memberQuickBuySaleMapper.selectTXByMemberId(memberId); czNumber = czNumber + (selectCBByMemberId == null ? 0 : Double.parseDouble(selectCBByMemberId)); czNumber = czNumber + (selectCZByMemberI == null ? 0 : Double.parseDouble(selectCZByMemberI)); txNumber = txNumber + (selectTBByMemberId == null ? 0 : Double.parseDouble(selectTBByMemberId)); txNumber = txNumber + (selectTXByMemberId == null ? 0 : Double.parseDouble(selectTXByMemberId)); } } inviteIdCZ = czNumber+""; inviteIdTX = txNumber+""; inviteIdSY = (czNumber-txNumber)+""; } agentFriendRelation.setTotalRecharge(inviteIdCZ == null ? "0.0" : inviteIdCZ); agentFriendRelation.setTotalWithdrawal(inviteIdTX == null ? "0.0" : inviteIdTX); agentFriendRelation.setTotalPerformance(inviteIdSY == null ? "0.0" : inviteIdSY); } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = this.baseMapper.selectMemberListInPage(page, memberEntity); List records = selectMemberListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberEntity memberEntitys : records) { String firstName = (memberEntitys.getFirstName() == null ? "" : memberEntitys.getFirstName()); String secondName = (memberEntitys.getSecondName() == null ? "" : memberEntitys.getSecondName()); memberEntitys.setRealName(firstName+secondName); } } return selectMemberListInPage; } @Override public IPage findmemberQuickBuySaleListInPage( MemberQuickBuySaleEntity memberQuickBuySaleEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberQuickBuySaleMapper.findmemberQuickBuySaleListInPage(page, memberQuickBuySaleEntity); return findmemberQuickBuySaleListInPage; } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberChargeUsdtConfirm(Long id) { MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id); if(!MemberQuickBuySaleEntity.CHARGE_STATUS_PAID.equals(memberQuickBuySaleEntity.getOrderStatus())) { return new FebsResponse().message("只允许已付款状态操作"); } Long memberId = memberQuickBuySaleEntity.getMemberId(); BigDecimal amountUsdt = memberQuickBuySaleEntity.getAmountUsdt(); String walletCode = "USDT"; MemberEntity selectById = this.baseMapper.selectById(memberId); if(ObjectUtils.isEmpty(selectById)) { return new FebsResponse().message("用户已不存在"); } //获取币币钱包 MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance(); BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance(); memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt)); memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt)); // 更新 memberWalletCoinMapper.updateById(memberWalletCoinEntity); // 更新状态 memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_CHECKED); memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity); //添加币币资金划转历史记录 MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); memberAccountMoneyChangeEntity.setContent("OTC转入"); memberAccountMoneyChangeEntity.setMemberId(memberId); memberAccountMoneyChangeEntity.setAmount(amountUsdt); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setSymbol("USDT"); memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setCreateTime(new Date()); memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setUpdateTime(new Date()); memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); /** * todo SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String chargeTime = format.format(memberQuickBuySaleEntity.getChargeTime()); // 将当前时间袼式化为指定的格式 String usdt = memberQuickBuySaleEntity.getAmountUsdt()+"USDT"; //发送短信提醒 String smsContent = "【Excoin】尊敬的用户您好!您于"+chargeTime+"充值"+usdt+"已成功到账,请您及时查收!订单号为:"+memberChargeUsdt.getOrderCode()+"。"; SmsUtils.hxSmsSend(member.getPhone(), smsContent); */ return new FebsResponse().success(); } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberChargeUsdtCancel(@NotNull(message = "{required}") Long id) { MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id); if(MemberQuickBuySaleEntity.CHARGE_STATUS_CHECKED.equals(memberQuickBuySaleEntity.getOrderStatus()) || MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_USER.equals(memberQuickBuySaleEntity.getOrderStatus()) || MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_SYSTEM.equals(memberQuickBuySaleEntity.getOrderStatus())) { return new FebsResponse().message("不允许系统撤单操作"); } memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_SYSTEM); memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity); return new FebsResponse().success(); } @Override public IPage findmemberQuickSaleListInPage(MemberQuickBuySaleEntity memberQuickBuySaleEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberQuickBuySaleMapper.findmemberQuickSaleListInPage(page, memberQuickBuySaleEntity); return findmemberQuickBuySaleListInPage; } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberExtractUsdtCancel(@NotNull(message = "{required}") Long id) { MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id); if(!MemberQuickBuySaleEntity.CHARGE_STATUS_CREATE.equals(memberQuickBuySaleEntity.getOrderStatus())) { return new FebsResponse().message("只允许待付款状态操作"); } Long memberId = memberQuickBuySaleEntity.getMemberId(); BigDecimal amountUsdt = memberQuickBuySaleEntity.getAmountUsdt(); String walletCode = "USDT"; MemberEntity selectById = this.baseMapper.selectById(memberId); if(ObjectUtils.isEmpty(selectById)) { return new FebsResponse().message("用户已不存在"); } //获取币币钱包 MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); BigDecimal frozenBalance = memberWalletCoinEntity.getFrozenBalance(); BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance(); BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance(); memberWalletCoinEntity.setFrozenBalance(frozenBalance.subtract(amountUsdt)); memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt)); memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt)); // 更新 memberWalletCoinMapper.updateById(memberWalletCoinEntity); // 更新状态 memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_SYSTEM); memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity); /** * todo SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String chargeTime = format.format(memberQuickBuySaleEntity.getChargeTime()); // 将当前时间袼式化为指定的格式 String usdt = memberQuickBuySaleEntity.getAmountUsdt()+"USDT"; //发送短信提醒 String smsContent = "【Excoin】尊敬的用户您好!您于"+chargeTime+"充值"+usdt+"已成功到账,请您及时查收!订单号为:"+memberChargeUsdt.getOrderCode()+"。"; SmsUtils.hxSmsSend(member.getPhone(), smsContent); */ return new FebsResponse().success(); } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberExtractUsdtConfirm(@NotNull(message = "{required}") Long id) { MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id); if(!MemberQuickBuySaleEntity.CHARGE_STATUS_CREATE.equals(memberQuickBuySaleEntity.getOrderStatus())) { return new FebsResponse().message("只允许待付款状态操作"); } Long memberId = memberQuickBuySaleEntity.getMemberId(); BigDecimal amountUsdt = memberQuickBuySaleEntity.getAmountUsdt(); String walletCode = "USDT"; MemberEntity selectById = this.baseMapper.selectById(memberId); if(ObjectUtils.isEmpty(selectById)) { return new FebsResponse().message("用户已不存在"); } //获取币币钱包 MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); BigDecimal frozenBalance = memberWalletCoinEntity.getFrozenBalance(); memberWalletCoinEntity.setFrozenBalance(frozenBalance.subtract(amountUsdt)); memberWalletCoinMapper.updateById(memberWalletCoinEntity); memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_PAID); memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity); //添加币币资金划转历史记录 MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); memberAccountMoneyChangeEntity.setContent("提现"); memberAccountMoneyChangeEntity.setMemberId(memberId); memberAccountMoneyChangeEntity.setAmount(amountUsdt); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setSymbol(walletCode); memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setCreateTime(new Date()); memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setUpdateTime(new Date()); memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); /** SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String chargeTime = format.format(memberQuickBuySaleEntity.getUpdateTime()); // 将当前时间袼式化为指定的格式 String usdt = amountUsdt+"USDT"; //发送短信提醒 String smsContent = "【Excoin】尊敬的用户您好!您于"+chargeTime+"提现"+usdt+"已成功到账,请您及时查收!订单号为:"+memberQuickBuySaleEntity.getOrderCode()+"。"; SmsUtils.hxSmsSend(selectById.getPhone(), smsContent); * */ return new FebsResponse().success(); } @Override public IPage 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 page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinListInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(CollUtil.isNotEmpty(records)) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findmemberWithdrawCoinListInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { //查询条件 查询某条线下的所有数据 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 page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findmemberWithdrawCoinListInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); } } return findmemberQuickBuySaleListInPage; } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberWithdrawCoinConfirm(@NotNull(message = "{required}") Long id) { MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id); Long memberId = selectById.getMemberId(); String symbol = selectById.getSymbol(); String address = selectById.getAddress(); int status = selectById.getStatus(); if(status != 1) { return new FebsResponse().fail().message("只有等待审核的状态才能确认!"); } // 查询币币钱包 MemberWalletCoinEntity walletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId, symbol); BigDecimal total = walletCoin.getTotalBalance().subtract(selectById.getAmount()).subtract(selectById.getFeeAmount()); walletCoin.setTotalBalance(total); BigDecimal frozen = walletCoin.getFrozenBalance().subtract(selectById.getAmount()); walletCoin.setFrozenBalance(frozen); memberWalletCoinMapper.updateById(walletCoin); if ("Y".equals(selectById.getIsInside())) { Map columnMap = new HashMap<>(); columnMap.put("symbol", symbol); columnMap.put("address", address); // 如果是内部转账 则需要将币加到内部地址 List selectByMap = memberCoinAddressMapper.selectByMap(columnMap); if(selectByMap == null || selectByMap.isEmpty()) { return new FebsResponse().fail().message("地址有误,请拒绝!"); } Long aimMemberId = selectByMap.get(0).getMemberId(); MemberWalletCoinEntity aimWalletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(aimMemberId, symbol); BigDecimal addTotal = aimWalletCoin.getTotalBalance().add(selectById.getAmount()); BigDecimal addAvailable = aimWalletCoin.getAvailableBalance().add(selectById.getAmount()); aimWalletCoin.setTotalBalance(addTotal); aimWalletCoin.setAvailableBalance(addAvailable); memberWalletCoinMapper.updateById(aimWalletCoin); MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); memberAccountMoneyChangeEntity.setContent("收款"); memberAccountMoneyChangeEntity.setMemberId(aimMemberId); memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setSymbol(selectById.getSymbol()); memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setCreateTime(new Date()); memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setUpdateTime(new Date()); memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); } Map columnMaps = new HashMap<>(); columnMaps.put("withdraw_id", selectById.getId()); List selectByMap2 = memberAccountMoneyChangeMapper.selectByMap(columnMaps); MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setAmount(selectById.getAmount().negate()); memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_Y); memberCoinWithdrawMapper.updateById(selectById); MemberEntity memberEntity = memberMapper.selectById(memberId); String phone = memberEntity.getPhone(); //String email = memberEntity.getEmail(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String time = format.format(new Date()); // 将当前时间袼式化为指定的格式 log.info("---->{}", phone); if(StrUtil.isNotBlank(phone)) { Sms106Send.sendWithdrawalCoinMsg(phone, time); } /** //短信提醒 SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String chargeTime = format.format(new Date()); // 将当前时间袼式化为指定的格式 String usdt = selectById.getAmount()+"USDT"; * 发送短信提醒 todo String smsContent = "【Excoin】尊敬的用户您好!您于"+chargeTime+"提现"+usdt+"已成功到账,请您及时查收!"; SmsUtils.hxSmsSend(member.getPhone(), smsContent); */ return new FebsResponse().success(); } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberWithdrawCoinCancel(@NotNull(message = "{required}") Long id) { MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id); Long memberId = selectById.getMemberId(); String symbol = selectById.getSymbol(); int status = selectById.getStatus(); if(status != 1) { return new FebsResponse().fail().message("只有等待审核的状态才能拒绝!"); } // 查询币币钱包 MemberWalletCoinEntity walletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId, symbol); BigDecimal available = walletCoin.getAvailableBalance().add(selectById.getAmount()); walletCoin.setAvailableBalance(available); BigDecimal frozen = walletCoin.getFrozenBalance().subtract(selectById.getAmount()); walletCoin.setFrozenBalance(frozen); memberWalletCoinMapper.updateById(walletCoin); // 提币退款记录 Map columnMaps = new HashMap<>(); columnMaps.put("withdraw_id", selectById.getId()); List selectByMap2 = memberAccountMoneyChangeMapper.selectByMap(columnMaps); MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_FAIL_INTEGER); memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_N); memberCoinWithdrawMapper.updateById(selectById); return new FebsResponse().success(); } @Override public MemberAuthenticationVo selectMemberAuthenticationById(long id) { MemberAuthenticationVo memberAuthenticationEntity = memberAuthenticationMapper.findMemberAuthenticationByMemberId(id); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); memberAuthenticationEntity.setRealName(firstName+"-"+secondName); return memberAuthenticationEntity; } @Override @Transactional(rollbackFor = Exception.class) public FebsResponse memberDetailConfirm(@Valid MemberDetailConfirmDto memberDetailConfirmDto) { Long id = memberDetailConfirmDto.getId(); MemberEntity selectById = memberMapper.selectById(id); Integer certifyStatus = selectById.getCertifyStatus(); if(!MemberEntity.CERTIFY_STATUS_ING.equals(certifyStatus)) { return new FebsResponse().fail().message("只有【待审核】状态才能提交!"); } MemberAuthenticationVo memberAuthenticationEntity = memberAuthenticationMapper.findMemberAuthenticationByMemberId(id); if(memberDetailConfirmDto.getIsok() == 1) { selectById.setCertifyStatus(MemberEntity.CERTIFY_STATUS_Y); }else { selectById.setCertifyStatus(MemberEntity.CERTIFY_STATUS_N); Map columnMap = new HashMap<>(); columnMap.put("member_id", selectById.getId()); memberAuthenticationMapper.deleteByMap(columnMap); } selectById.setIdcardNo(memberAuthenticationEntity.getIdcardNo()); memberMapper.updateById(selectById); return new FebsResponse().success(); } @Override public List selectMemberDataInfoById(long id) { Map columnMap = new HashMap<>(); columnMap.put("member_id", id); List selectByMap = memberCoinChargeMapper.selectByMap(columnMap); return selectByMap; } @Override public IPage findMemberDataInfoDtoListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.selectMemberDataInfoDtoListInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealData(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealData(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealData(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealData(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealData(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealData(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealData(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealData(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicRealData(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicRealData(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicRealData(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealData(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealData(); String walletCoinNum = memberMapper.selectHYZCForBasicRealData(); String agentNum = memberMapper.selectDLZCForBasicRealData(); 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 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; } @Override public MemberEntity selectMemberByid(long id) { MemberEntity selectById = memberMapper.selectById(id); return selectById; } @Override public FebsResponse memberDataInfoList(@NotNull(message = "{required}") long id) { Map columnMap = new HashMap<>(); columnMap.put("member_id", id); columnMap.put("STATUS", 2); List selectByMap = memberCoinWithdrawMapper.selectByMap(columnMap); return new FebsResponse().data(selectByMap); } @Override public FebsResponse addCoinConfirm(@Valid MemberEntity memberEntity) { Long memberId = memberEntity.getId(); String walletCode = "USDT"; BigDecimal amountUsdt = memberEntity.getCoinNumber(); MemberEntity selectById = this.baseMapper.selectById(memberId); if(ObjectUtils.isEmpty(selectById)) { return new FebsResponse().message("用户已不存在"); } //获取币币钱包 MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance(); BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance(); memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt)); memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt)); // 更新 memberWalletCoinMapper.updateById(memberWalletCoinEntity); //添加币币资金划转历史记录 MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); memberAccountMoneyChangeEntity.setContent("充值"); memberAccountMoneyChangeEntity.setMemberId(memberId); memberAccountMoneyChangeEntity.setAmount(amountUsdt); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setSymbol("USDT"); memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setCreateTime(new Date()); memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); memberAccountMoneyChangeEntity.setUpdateTime(new Date()); memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); /** * todo SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); String chargeTime = format.format(memberQuickBuySaleEntity.getChargeTime()); // 将当前时间袼式化为指定的格式 String usdt = memberQuickBuySaleEntity.getAmountUsdt()+"USDT"; //发送短信提醒 String smsContent = "【Excoin】尊敬的用户您好!您于"+chargeTime+"充值"+usdt+"已成功到账,请您及时查收!订单号为:"+memberChargeUsdt.getOrderCode()+"。"; SmsUtils.hxSmsSend(member.getPhone(), smsContent); */ return new FebsResponse().success(); } @Override public MemberInfoDetailVo selectMemberInfoDetailById(long id) { MemberCoinWithdrawEntity selectById = memberCoinWithdrawMapper.selectById(id); Long memberId = selectById.getMemberId(); MemberInfoDetailVo memberInfoDetailVo = new MemberInfoDetailVo(); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB)); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS)); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ)); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); //总剩余 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)); memberInfoDetailVo.setTotalCoin(platformProfitAndLoss); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setFee(returnMoneyByMid == null ? 0 : Double.parseDouble(returnMoneyByMid)); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setClosingPrice(closingpriceByMid == null ? 0 : Double.parseDouble(closingpriceByMid)); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setSellClosingPrice(sellClosingpriceByMid == null ? 0 : Double.parseDouble(sellClosingpriceByMid)); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setPlatformProfitAndLoss(rewardratioByMid == null ? 0 : Double.parseDouble(rewardratioByMid)); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setDoingPrice(doingPrice == null ? 0 : Double.parseDouble(doingPrice)); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum)); String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setTotalContract(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum)); String agentNum = memberMapper.selectDLZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAgentNum(agentNum == null ? 0 : Double.parseDouble(agentNum)); return memberInfoDetailVo; } @Override public IPage findmemberApplyCoinAloneInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findmemberApplyCoinAloneInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberWithdrawCoinAloneInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinAloneInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberAloneInPage(MemberEntity member, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = this.baseMapper.findMemberAloneInPage(page, member); List records = selectMemberListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberEntity memberEntitys : records) { String firstName = (memberEntitys.getFirstName() == null ? "" : memberEntitys.getFirstName()); String secondName = (memberEntitys.getSecondName() == null ? "" : memberEntitys.getSecondName()); memberEntitys.setRealName(firstName+secondName); } } return selectMemberListInPage; } @Override public IPage findMemberDataInfoAloneDtoListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.selectMemberDataInfoDtoRealListInPageAlone(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataAlone(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataAlone(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealDataAlone(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealDataAlone(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealDataAlone(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealDataAlone(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealDataAlone(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataAlone(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicRealDataAlone(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicRealDataAlone(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicRealDataAlone(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealDataAlone(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealDataAlone(); String walletCoinNum = memberMapper.selectHYZCForBasicRealDataAlone(); String agentNum = memberMapper.selectDLZCForBasicRealDataAlone(); 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 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; } @Override public IPage findMemberDataInfoAllInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.selectMemberDataInfoDtoListInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicData(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicData(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicData(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicData(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealData(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicData(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicData(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicData(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicData(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicData(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicData(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicData(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicData(); String walletCoinNum = memberMapper.selectHYZCForBasicData(); String agentNum = memberMapper.selectDLZCForBasicData(); 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 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; } @Override public IPage findMemberDataInfoAllAloneListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.selectMemberDataInfoDtoListInPageAlone(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicAllDataAlone(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicAllDataAlone(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicAllDataAlone(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicAllDataAlone(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicAllDataAlone(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicAllDataAlone(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicAllDataAlone(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicAllDataAlone(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicAllDataAlone(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicAllDataAlone(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicAllDataAlone(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicAllDataAlone(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicAllDataAlone(); String walletCoinNum = memberMapper.selectHYZCForBasicAllDataAlone(); String agentNum = memberMapper.selectDLZCForBasicAllDataAlone(); 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 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; } @Override public IPage findMemberListTestInPage(MemberEntity member, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = this.baseMapper.findMemberListTestInPage(page, member); List records = selectMemberListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberEntity memberEntitys : records) { String firstName = (memberEntitys.getFirstName() == null ? "" : memberEntitys.getFirstName()); String secondName = (memberEntitys.getSecondName() == null ? "" : memberEntitys.getSecondName()); memberEntitys.setRealName(firstName+secondName); } } return selectMemberListInPage; } @Override public IPage findMemberWithdrawCoinTestListInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinTestListInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberApplyCoinAloneTestInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinAloneTestInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberAloneTestInPage(MemberEntity member, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = this.baseMapper.findMemberAloneTestInPage(page, member); List records = selectMemberListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberEntity memberEntitys : records) { String firstName = (memberEntitys.getFirstName() == null ? "" : memberEntitys.getFirstName()); String secondName = (memberEntitys.getSecondName() == null ? "" : memberEntitys.getSecondName()); memberEntitys.setRealName(firstName+secondName); } } return selectMemberListInPage; } @Override public IPage findMemberDataInfoAloneTestDtoListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoAloneTestDtoListInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealTestDataAlone(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealTestDataAlone(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealTestDataAlone(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealTestDataAlone(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealTestDataAlone(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealTestDataAlone(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealTestDataAlone(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealTestDataAlone(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicRealTestDataAlone(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicRealTestDataAlone(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicRealTestDataAlone(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealTestDataAlone(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealTestDataAlone(); String walletCoinNum = memberMapper.selectHYZCForBasicRealTestDataAlone(); String agentNum = memberMapper.selectDLZCForBasicRealTestDataAlone(); 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)-6780)); platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); List 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)-6780)); 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; } @Override public IPage findMemberDataInfoAllAloneTestListInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoAllAloneTestListInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealTestAllDataAlone(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealTestAllDataAlone(); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealTestAllDataAlone(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealTestAllDataAlone(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealTestAllDataAlone(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealTestAllDataAlone(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealTestAllDataAlone(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealTestAllDataAlone(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForBasicRealTestAllDataAlone(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForBasicRealTestAllDataAlone(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForBasicRealTestAllDataAlone(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealTestAllDataAlone(); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealTestAllDataAlone(); String walletCoinNum = memberMapper.selectHYZCForBasicRealTestAllDataAlone(); String agentNum = memberMapper.selectDLZCForBasicRealTestAllDataAlone(); 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)-6780)); platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); List 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)-6780)); 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; } @Override public MemberInfoDetailVo selectMemberInfoDetailByInviteId(String inviteId) { String id = memberMapper.selectMemberInfoDetailByInviteId(inviteId); Long memberId = Long.parseLong(id); MemberInfoDetailVo memberInfoDetailVo = new MemberInfoDetailVo(); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB)); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS)); //USDT充值总额+USDT提现总额 String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ)); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); //总剩余 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)); memberInfoDetailVo.setTotalCoin(platformProfitAndLoss); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setFee(returnMoneyByMid == null ? 0 : Double.parseDouble(returnMoneyByMid)); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setClosingPrice(closingpriceByMid == null ? 0 : Double.parseDouble(closingpriceByMid)); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setSellClosingPrice(sellClosingpriceByMid == null ? 0 : Double.parseDouble(sellClosingpriceByMid)); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setPlatformProfitAndLoss(rewardratioByMid == null ? 0 : Double.parseDouble(rewardratioByMid)); //持仓手续费 String doingPrice = memberMapper.selectprepriceForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setDoingPrice(doingPrice == null ? 0 : Double.parseDouble(doingPrice)); //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum)); String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setTotalContract(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum)); String agentNum = memberMapper.selectDLZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setAgentNum(agentNum == null ? 0 : Double.parseDouble(agentNum)); return memberInfoDetailVo; } @Override public IPage memberDataInfoListSearchs(MemberEntity member, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = this.baseMapper.selectDataInfoListSearchs(page, member); List records = selectMemberListInPage.getRecords(); Set set = new HashSet<>(); if(CollUtil.isNotEmpty(records)) { if(StrUtil.isNotBlank(member.getAccount())) { MemberEntity memberEntity = records.get(0); //当前查询下级关系 String inviteId = memberEntity.getInviteId(); List members = memberMapper.selectMemberDataInfoListSearchs(inviteId); if(CollUtil.isNotEmpty(members)) { for(MemberEntity semberEntity : members) { set.add(semberEntity); } } //当前查询上级关系 String refererIds = memberEntity.getRefererIds(); String[] strs = refererIds.split(","); if(ObjectUtil.isNotEmpty(strs)) { for(int i=0,len=strs.length;i 0) { records.addAll(set); } } return selectMemberListInPage; } @Override public IPage findMemberApplyCoinOneInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinOneInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberApplyCoinTwoInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinTwoInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberApplyCoinTeeInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinTeeInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberApplyCoinOneAllInPage(MemberCoinChargeEntity memberCoinChargeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinOneAllInPage(page, memberCoinChargeEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinChargeVo memberCoinChargeVo : records) { Long memberId = memberCoinChargeVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinChargeVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberWithdrawCoinOneInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinOneInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberWithdrawCoinTwoInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinTwoInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberWithdrawCoinTeeInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinTeeInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberWithdrawCoinAllOneInPage( MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findMemberWithdrawCoinAllOneInPage(page, memberCoinWithdrawEntity); List records = findmemberQuickBuySaleListInPage.getRecords(); if(records != null && records.size() > 0) { for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); Long memberId = memberCoinWithdrawVo.getMemberId(); Map columnMap = new HashMap<>(); columnMap.put("member_id", memberId); List selectByMap = memberAuthenticationMapper.selectByMap(columnMap); if(selectByMap != null && selectByMap.size() > 0) { MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); String firstName = memberAuthenticationEntity.getFirstName(); String secondName = memberAuthenticationEntity.getSecondName(); String realName = firstName + secondName; memberCoinWithdrawVo.setRealName(realName); } } } return findmemberQuickBuySaleListInPage; } @Override public IPage findMemberDataInfoOneInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoOneInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoOne(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoOne(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoOne(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoOne(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoOne(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoOne(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoOne(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoOne(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoOne(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoOne(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoOne(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoOne(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoOne(); String walletCoinNum = memberMapper.selectHYZCForDataInfoOne(); String agentNum = memberMapper.selectDLZCForDataInfoOne(); 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 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; } @Override public IPage findMemberDataInfoOneRealInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoOneRealInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoOneReal(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoOneReal(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoOneReal(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoOneReal(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoOneReal(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoOneReal(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoOneReal(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoOneReal(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoOneReal(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoOneReal(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoOneReal(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoOneReal(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoOneReal(); String walletCoinNum = memberMapper.selectHYZCForDataInfoOneReal(); String agentNum = memberMapper.selectDLZCForDataInfoOneReal(); 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 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; } @Override public IPage findMemberDataInfoTwoInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoTwoInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoTwo(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoTwo(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoTwo(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoTwo(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoTwo(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoTwo(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoTwo(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoTwo(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoTwo(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoTwo(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoTwo(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoTwo(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoTwo(); String walletCoinNum = memberMapper.selectHYZCForDataInfoTwo(); String agentNum = memberMapper.selectDLZCForDataInfoTwo(); 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 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; } @Override public IPage findMemberDataInfoTwoRealInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoTwoRealInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoTwoReal(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoTwoReal(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoTwoReal(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoTwoReal(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoTwoReal(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoTwoReal(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoTwoReal(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoTwoReal(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoTwoReal(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoTwoReal(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoTwoReal(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoTwoReal(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoTwoReal(); String walletCoinNum = memberMapper.selectHYZCForDataInfoTwoReal(); String agentNum = memberMapper.selectDLZCForDataInfoTwoReal(); 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 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; } @Override public IPage findMemberDataInfoTeeInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoTeeInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoTee(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoTee(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoTee(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoTee(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoTee(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoTee(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoTee(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoTee(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoTee(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoTee(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoTee(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoTee(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoTee(); String walletCoinNum = memberMapper.selectHYZCForDataInfoTee(); String agentNum = memberMapper.selectDLZCForDataInfoTee(); 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 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; } @Override public IPage findMemberDataInfoTeeRealInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoTeeRealInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoTeeReal(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoTeeReal(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoTeeReal(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoTeeReal(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoTeeReal(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoTeeReal(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoTeeReal(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoTeeReal(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoTeeReal(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoTeeReal(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoTeeReal(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoTeeReal(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoTeeReal(); String walletCoinNum = memberMapper.selectHYZCForDataInfoTeeReal(); String agentNum = memberMapper.selectDLZCForDataInfoTeeReal(); 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 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; } @Override public IPage findMemberDataInfoOneAllInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoOneAllInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoOneAll(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoOneAll(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoOneAll(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoOneAll(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoOneAll(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoOneAll(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoOneAll(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoOneAll(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoOneAll(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoOneAll(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoOneAll(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoOneAll(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoOneAll(); String walletCoinNum = memberMapper.selectHYZCForDataInfoOneAll(); String agentNum = memberMapper.selectDLZCForDataInfoOneAll(); 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 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; } @Override public IPage findMemberDataInfoOneAllRealInPage(MemberEntity memberEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage selectMemberListInPage = memberMapper.findMemberDataInfoOneAllRealInPage(page, memberEntity); //USDT充币总额+USDT提币总额 String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForDataInfoOneAllReal(); String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForDataInfoOneAllReal(); String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForDataInfoOneAllReal(); String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForDataInfoOneAllReal(); //佣金 String returnMoneyByMid = memberMapper.selectReturnMoneyForDataInfoOneAllReal(); //开仓手续费总额 String closingpriceByMid = memberMapper.selectClosingpriceForDataInfoOneAllReal(); //平仓总手续费 String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForDataInfoOneAllReal(); //总盈亏 String rewardratioByMid = memberMapper.selectRewardratioForDataInfoOneAllReal(); //持仓人数 String notNullNumber = memberMapper.selectSFCCForDataInfoOneAllReal(); //币币账户不为空的人数 String walletNumber = memberMapper.selectBBZHForDataInfoOneAllReal(); //合约账户不为空的人数 String walletCoinNumber = memberMapper.selectHYZHForDataInfoOneAllReal(); //持仓手续费 String doingPrice = memberMapper.selectprepriceForDataInfoOneAllReal(); //账户金额 String walletNum = memberMapper.selectBBZCForDataInfoOneAllReal(); String walletCoinNum = memberMapper.selectHYZCForDataInfoOneAllReal(); String agentNum = memberMapper.selectDLZCForDataInfoOneAllReal(); 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 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; } @Override public IPage memberBoBiList( MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity, QueryRequest request) { Page page = new Page<>(request.getPageNum(), request.getPageSize()); IPage findmemberQuickBuySaleListInPage = memberMapper.memberBoBiList(page, memberAccountMoneyChangeEntity); return findmemberQuickBuySaleListInPage; } @Override public IPage 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 page = new Page<>(request.getPageNum(), request.getPageSize()); IPage 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.00 ; 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 records = selectMemberListInPage.getRecords(); for(MemberDataInfoVo memberDataInfoVo : records) { DecimalFormat df = new DecimalFormat("0.00"); 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 == "0" ? "0" : df.format(Double.parseDouble(closingpriceByMid))); memberDataInfoVo.setSellClosingPrice(sellClosingpriceByMid == "0" ? "0" : df.format(Double.parseDouble(sellClosingpriceByMid))); memberDataInfoVo.setFee(returnMoneyByMid == "0" ? "0" : df.format(Double.parseDouble(returnMoneyByMid))); memberDataInfoVo.setYingkui(rewardratioByMid == null ? "0" : df.format(Double.parseDouble(rewardratioByMid))); memberDataInfoVo.setNotNullNumber(notNullNumber == null ? "0" : notNullNumber); memberDataInfoVo.setWalletNumber(walletNumber == null ? "0" : walletNumber); memberDataInfoVo.setWalletCoinNumber(walletCoinNumber == null ? "0" : walletCoinNumber); memberDataInfoVo.setPlatformProfitAndLoss(platformProfitAndLoss == 0.00 ? "0" : df.format(platformProfitAndLoss)); memberDataInfoVo.setDoingPrice(doingPrice == "0" ? "0" : df.format(Double.parseDouble(doingPrice))); memberDataInfoVo.setWalletNum(walletNum == null ? "0" : df.format(Double.parseDouble(walletNum))); memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : df.format(Double.parseDouble(walletCoinNum))); memberDataInfoVo.setAgentNum(agentNum == null ? "0" : df.format(Double.parseDouble(agentNum))); memberDataInfoVo.setAllCoin(allCoin); } selectMemberListInPage.setTotal(1); return selectMemberListInPage; } }