20200720 代码提交

xiaoyong931011

2020-07-20 394a93c64be8d057a2c3553aaca0045d08010f6a

 src/main/java/com/xcong/excoin/modules/trademanage/service/impl/TradeManageServiceImpl.java

@@ -1,151 +1,205 @@
package com.xcong.excoin.modules.trademanage.service.impl;


import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.common.utils.CoinTypeConvert;
import com.xcong.excoin.common.utils.RedisUtils;
import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity;
import com.xcong.excoin.modules.member.entity.MemberEntity;
import com.xcong.excoin.modules.member.mapper.MemberAccountMoneyChangeMapper;
import com.xcong.excoin.modules.member.mapper.MemberMapper;
import com.xcong.excoin.modules.trademanage.entity.AgentReturnEntity;
import com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity;
import com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity;
import com.xcong.excoin.modules.trademanage.entity.MemberWalletAgentEntity;
import com.xcong.excoin.modules.trademanage.mapper.AgentReturnMapper;
import com.xcong.excoin.modules.trademanage.mapper.ContractHoldOrderEntityMapper;
import com.xcong.excoin.modules.trademanage.mapper.ContractOrderMapper;
import com.xcong.excoin.modules.trademanage.mapper.MemberWalletAgentMapper;
import com.xcong.excoin.modules.trademanage.service.TradeManageService;
import com.xcong.excoin.modules.trademanage.vo.MemberAccountInfoVo;
import lombok.RequiredArgsConstructor;

@Service
@RequiredArgsConstructor
public class TradeManageServiceImpl extends ServiceImpl<ContractHoldOrderEntityMapper, ContractHoldOrderEntity> implements TradeManageService{

   private final ContractHoldOrderEntityMapper contractHoldOrderEntityMapper;
	
   private final MemberMapper memberMapper;
	
   private final MemberWalletAgentMapper memberWalletAgentMapper;

   private final MemberAccountMoneyChangeMapper memberAccountMoneyChangeMapper;
	
   private final ContractOrderMapper contractHoldOrderMapper;
	
   private final AgentReturnMapper agentReturnMapper;
	
   private final RedisUtils redisUtils;
	
   @Override
   public IPage<ContractHoldOrderEntity> findContractHoldOrderListInPage(
         ContractHoldOrderEntity contractHoldOrderEntity, QueryRequest request) {
      Page<ContractHoldOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<ContractHoldOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderEntityMapper.selectContractHoldOrderListInPage(page, contractHoldOrderEntity);
      List<ContractHoldOrderEntity> records = findMemberAccountInfoListInPage.getRecords();
		
      if (records != null) {
            for (ContractHoldOrderEntity holdOrderEntity : records) {
               MemberEntity selectById = memberMapper.selectById(holdOrderEntity.getMemberId());
                // 获取最新价
                BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));
                BigDecimal lotNumber = holdOrderEntity.getSymbolSku();
                // 盈亏
                BigDecimal rewardRatio = BigDecimal.ZERO;
                // 开多
                if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {
                    // (最新价-开仓价)*规格*张数
                    rewardRatio = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));
                    // 开空
                } else {
                    // (开仓价-最新价)*规格*张数
                    rewardRatio = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));
                }

                if (selectById.getIsProfit() == MemberEntity.IS_PROFIT_Y) {
                   String selectTradeSetting = memberMapper.selectTradeSetting();
                    BigDecimal profitParam=new BigDecimal(selectTradeSetting);  
                    if (rewardRatio.compareTo(BigDecimal.ZERO) > -1) {
                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.subtract(profitParam));
                    } else {
                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.add(profitParam));
                    }
                }

                holdOrderEntity.setRewardRatio(rewardRatio);
            }
        }
      return findMemberAccountInfoListInPage;
   }

   @Override
   public IPage<MemberAccountInfoVo> findMemberAccountInfoListInPage(MemberEntity memberEntity, QueryRequest request) {
      Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberAccountInfoVo> selectMemberListInPage = memberMapper.findMemberAccountInfoListInPage(page, memberEntity);
      List<MemberAccountInfoVo> records = selectMemberListInPage.getRecords();
      if(records.size() > 0) {
         for(MemberAccountInfoVo memberAccountInfoVo : records) {
            Long memberId = memberAccountInfoVo.getId();
            String inviteId = memberMapper.selectAgentForAccount(memberId);
            if("".equals(inviteId) || inviteId == null) {
               memberAccountInfoVo.setIsSuAccount(0);
            }else {
               memberAccountInfoVo.setIsSuAccount(1);
            }
            Map<String, Object> columnMap = new HashMap<>();
            columnMap.put("member_id", memberId);
            List<MemberWalletAgentEntity> selectByMap = memberWalletAgentMapper.selectByMap(columnMap);
            if(selectByMap.size() > 0) {
               BigDecimal availableBalance = selectByMap.get(0).getAvailableBalance();
               memberAccountInfoVo.setAgentAvailableBalance(availableBalance);
            }
				
         }
      }
        return selectMemberListInPage;
   }

   @Override
   public IPage<MemberAccountMoneyChangeEntity> findMemberAgentReturnInfoInPage(
         MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity, QueryRequest request) {
      Page<MemberAccountMoneyChangeEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<MemberAccountMoneyChangeEntity> findMemberAccountInfoListInPage = memberAccountMoneyChangeMapper.findMemberAccountInfoListInPage(page, memberAccountMoneyChangeEntity);
      return findMemberAccountInfoListInPage;
   }

   @Override
   public IPage<ContractOrderEntity> findMemberHistoryOrderInfoInPage(
         ContractOrderEntity contractOrderEntity, QueryRequest request) {
      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findMemberHistoryOrderInfoInPage(page, contractOrderEntity);
      return findMemberAccountInfoListInPage;
   }

   @Override
   public IPage<AgentReturnEntity> findMemberAgentReturnInfosInPage(AgentReturnEntity agentReturnEntity,
         QueryRequest request) {
      Page<AgentReturnEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<AgentReturnEntity> findMemberAccountInfoListInPage = agentReturnMapper.findMemberAgentReturnInfosInPage(page, agentReturnEntity);
      return findMemberAccountInfoListInPage;
   }

   @Override
   public IPage<ContractOrderEntity> findMemberHistoryOrderAllInfoInPage(ContractOrderEntity contractOrderEntity,
         QueryRequest request) {
      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findMemberHistoryOrderInfoAllInPage(page, contractOrderEntity);
      return findMemberAccountInfoListInPage;
   }

}
package com.xcong.excoin.modules.trademanage.service.impl;





import java.math.BigDecimal;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



import org.springframework.stereotype.Service;



import com.baomidou.mybatisplus.core.metadata.IPage;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.xcong.excoin.common.entity.QueryRequest;

import com.xcong.excoin.common.utils.CoinTypeConvert;

import com.xcong.excoin.common.utils.RedisUtils;

import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity;

import com.xcong.excoin.modules.member.entity.MemberEntity;

import com.xcong.excoin.modules.member.mapper.MemberAccountMoneyChangeMapper;

import com.xcong.excoin.modules.member.mapper.MemberMapper;

import com.xcong.excoin.modules.trademanage.entity.AgentReturnEntity;

import com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity;

import com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity;

import com.xcong.excoin.modules.trademanage.entity.MemberWalletAgentEntity;

import com.xcong.excoin.modules.trademanage.mapper.AgentReturnMapper;

import com.xcong.excoin.modules.trademanage.mapper.ContractHoldOrderEntityMapper;

import com.xcong.excoin.modules.trademanage.mapper.ContractOrderMapper;

import com.xcong.excoin.modules.trademanage.mapper.MemberWalletAgentMapper;

import com.xcong.excoin.modules.trademanage.service.TradeManageService;

import com.xcong.excoin.modules.trademanage.vo.MemberAccountInfoVo;

import lombok.RequiredArgsConstructor;



@Service

@RequiredArgsConstructor

public class TradeManageServiceImpl extends ServiceImpl<ContractHoldOrderEntityMapper, ContractHoldOrderEntity> implements TradeManageService{



   private final ContractHoldOrderEntityMapper contractHoldOrderEntityMapper;

	
   private final MemberMapper memberMapper;

	
   private final MemberWalletAgentMapper memberWalletAgentMapper;



   private final MemberAccountMoneyChangeMapper memberAccountMoneyChangeMapper;

	
   private final ContractOrderMapper contractHoldOrderMapper;

	
   private final AgentReturnMapper agentReturnMapper;

	
   private final RedisUtils redisUtils;

	
   @Override

   public IPage<ContractHoldOrderEntity> findContractHoldOrderListInPage(

         ContractHoldOrderEntity contractHoldOrderEntity, QueryRequest request) {

      Page<ContractHoldOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<ContractHoldOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderEntityMapper.selectContractHoldOrderListInPage(page, contractHoldOrderEntity);

      List<ContractHoldOrderEntity> records = findMemberAccountInfoListInPage.getRecords();

		
      if (records != null) {

            for (ContractHoldOrderEntity holdOrderEntity : records) {

               MemberEntity selectById = memberMapper.selectById(holdOrderEntity.getMemberId());

                // 获取最新价

                BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));

                BigDecimal lotNumber = holdOrderEntity.getSymbolSku();

                // 盈亏

                BigDecimal rewardRatio = BigDecimal.ZERO;

                // 开多

                if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {

                    // (最新价-开仓价)*规格*张数

                    rewardRatio = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));

                    // 开空

                } else {

                    // (开仓价-最新价)*规格*张数

                    rewardRatio = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));

                }



                if (selectById.getIsProfit() == MemberEntity.IS_PROFIT_Y) {

                   String selectTradeSetting = memberMapper.selectTradeSetting();

                    BigDecimal profitParam=new BigDecimal(selectTradeSetting);  
                    if (rewardRatio.compareTo(BigDecimal.ZERO) > -1) {

                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.subtract(profitParam));

                    } else {

                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.add(profitParam));

                    }

                }



                holdOrderEntity.setRewardRatio(rewardRatio);

            }

        }

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<MemberAccountInfoVo> findMemberAccountInfoListInPage(MemberEntity memberEntity, QueryRequest request) {

      Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<MemberAccountInfoVo> selectMemberListInPage = memberMapper.findMemberAccountInfoListInPage(page, memberEntity);

      List<MemberAccountInfoVo> records = selectMemberListInPage.getRecords();

      if(records.size() > 0) {

         for(MemberAccountInfoVo memberAccountInfoVo : records) {

            Long memberId = memberAccountInfoVo.getId();

            //总盈亏

            String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataBymid(memberId);

              BigDecimal bd=new BigDecimal(rewardratioByMid);

            memberAccountInfoVo.setRewardratioByMid(bd);

            String inviteId = memberMapper.selectAgentForAccount(memberId);

            if("".equals(inviteId) || inviteId == null) {

               memberAccountInfoVo.setIsSuAccount(0);

            }else {

               memberAccountInfoVo.setIsSuAccount(1);

            }

            Map<String, Object> columnMap = new HashMap<>();

            columnMap.put("member_id", memberId);

            List<MemberWalletAgentEntity> selectByMap = memberWalletAgentMapper.selectByMap(columnMap);

            if(selectByMap.size() > 0) {

               BigDecimal availableBalance = selectByMap.get(0).getAvailableBalance();

               memberAccountInfoVo.setAgentAvailableBalance(availableBalance);

            }

				
         }

         selectMemberListInPage.setTotal(records.size()); 
      }

        return selectMemberListInPage;

   }



   @Override

   public IPage<MemberAccountMoneyChangeEntity> findMemberAgentReturnInfoInPage(

         MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity, QueryRequest request) {

      Page<MemberAccountMoneyChangeEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<MemberAccountMoneyChangeEntity> findMemberAccountInfoListInPage = memberAccountMoneyChangeMapper.findMemberAccountInfoListInPage(page, memberAccountMoneyChangeEntity);

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<ContractOrderEntity> findMemberHistoryOrderInfoInPage(

         ContractOrderEntity contractOrderEntity, QueryRequest request) {

      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findMemberHistoryOrderInfoInPage(page, contractOrderEntity);

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<AgentReturnEntity> findMemberAgentReturnInfosInPage(AgentReturnEntity agentReturnEntity,

         QueryRequest request) {

      Page<AgentReturnEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<AgentReturnEntity> findMemberAccountInfoListInPage = agentReturnMapper.findMemberAgentReturnInfosInPage(page, agentReturnEntity);

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<ContractOrderEntity> findMemberHistoryOrderAllInfoInPage(ContractOrderEntity contractOrderEntity,

         QueryRequest request) {

      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findMemberHistoryOrderInfoAllInPage(page, contractOrderEntity);

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<ContractHoldOrderEntity> findContractHoldOrderAloneInPage(

         ContractHoldOrderEntity contractHoldOrderEntity, QueryRequest request) {

      Page<ContractHoldOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<ContractHoldOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderEntityMapper.findContractHoldOrderAloneInPage(page, contractHoldOrderEntity);

      List<ContractHoldOrderEntity> records = findMemberAccountInfoListInPage.getRecords();

		
      if (records != null) {

            for (ContractHoldOrderEntity holdOrderEntity : records) {

               MemberEntity selectById = memberMapper.selectById(holdOrderEntity.getMemberId());

                // 获取最新价

                BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));

                BigDecimal lotNumber = holdOrderEntity.getSymbolSku();

                // 盈亏

                BigDecimal rewardRatio = BigDecimal.ZERO;

                // 开多

                if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {

                    // (最新价-开仓价)*规格*张数

                    rewardRatio = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));

                    // 开空

                } else {

                    // (开仓价-最新价)*规格*张数

                    rewardRatio = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(lotNumber).multiply(new BigDecimal(holdOrderEntity.getSymbolCnt()));

                }



                if (selectById.getIsProfit() == MemberEntity.IS_PROFIT_Y) {

                   String selectTradeSetting = memberMapper.selectTradeSetting();

                    BigDecimal profitParam=new BigDecimal(selectTradeSetting);  
                    if (rewardRatio.compareTo(BigDecimal.ZERO) > -1) {

                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.subtract(profitParam));

                    } else {

                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.add(profitParam));

                    }

                }



                holdOrderEntity.setRewardRatio(rewardRatio);

            }

        }

      return findMemberAccountInfoListInPage;

   }



   @Override

   public IPage<ContractOrderEntity> findHistoryOrderInfoAloneInfoInPage(ContractOrderEntity contractOrderEntity,

         QueryRequest request) {

      Page<ContractOrderEntity> page = new Page<>(request.getPageNum(), request.getPageSize());

      IPage<ContractOrderEntity> findMemberAccountInfoListInPage = contractHoldOrderMapper.findHistoryOrderInfoAloneInfoInPage(page, contractOrderEntity);

      return findMemberAccountInfoListInPage;

   }



}