20200923

xiaoyong931011

2020-09-23 9fe6fee7de6b1e3d9c49f44bf1b99aa93cfff498

 src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java

@@ -2,10 +2,15 @@


import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;



import javax.annotation.Resource;



import com.xcong.excoin.modules.platform.entity.PlatformCnyUsdtExchangeEntity;

import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -22,12 +27,17 @@
import com.xcong.excoin.modules.coin.mapper.MemberAccountMoneyChangeMapper;

import com.xcong.excoin.modules.coin.parameter.dto.RecordsPageDto;

import com.xcong.excoin.modules.coin.parameter.vo.AllWalletCoinVo;

import com.xcong.excoin.modules.coin.parameter.vo.ContractSymbolListVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberAccountMoneyChangeInfoVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletAgentInfoVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletCoinInfoVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletCoinVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletContractInfoVo;

import com.xcong.excoin.modules.coin.service.CoinService;

import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;

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

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

import com.xcong.excoin.modules.contract.parameter.vo.HoldOrderListVo;

import com.xcong.excoin.modules.member.dao.MemberDao;

import com.xcong.excoin.modules.member.dao.MemberWalletAgentDao;

import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao;

@@ -37,6 +47,7 @@
import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;

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

import com.xcong.excoin.modules.platform.dao.PlatformCnyUsdtExchangeDao;

import com.xcong.excoin.utils.CacheSettingUtils;

import com.xcong.excoin.utils.CoinTypeConvert;

import com.xcong.excoin.utils.MessageSourceUtils;

import com.xcong.excoin.utils.RedisUtils;

@@ -65,6 +76,10 @@
    MemberDao memberDao;

    @Resource

    RedisUtils redisUtils;

    @Resource

    private ContractHoldOrderDao contractHoldOrderDao;

    @Resource

    private CacheSettingUtils cacheSettingUtils;





    @Override

@@ -180,23 +195,33 @@


        //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();



        PlatformCnyUsdtExchangeEntity cnyUsdtExchange = cnyUsdtExchangeDao.getCNYAndUSDTOne();

        BigDecimal cnyUsdt = cnyUsdtExchange.getValue();



        String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

        MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, walletCode);

        if (ObjectUtil.isEmpty(walletContract)) {

            return Result.fail(MessageSourceUtils.getString("member_service_0001"));

        }



        MemberWalletContractInfoVo memberWalletContractInfoVo = new MemberWalletContractInfoVo();

        memberWalletContractInfoVo.setFrozenBalance(walletContract.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setAvailableBalance(walletContract.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setTotalBalance(walletContract.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setTotalRMBBalance(walletContract.getTotalBalance().multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));



        return Result.ok(memberWalletContractInfoVo);

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

        columnMap.put("member_id", memberId);

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

      List<MemberWalletContractEntity> selectByMap = memberWalletContractDao.selectByMap(columnMap);

      BigDecimal totalCoin = BigDecimal.ZERO;

		
      List<MemberWalletContractInfoVo> list = new ArrayList<>();

      if(CollUtil.isNotEmpty(selectByMap)) {

         for(MemberWalletContractEntity memberWalletContractEntity : selectByMap) {

            MemberWalletContractInfoVo memberWalletContractInfoVo = new MemberWalletContractInfoVo();

            memberWalletContractInfoVo.setFrozenBalance(memberWalletContractEntity.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setAvailableBalance(memberWalletContractEntity.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setTotalBalance(memberWalletContractEntity.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setTotalRMBBalance(memberWalletContractEntity.getTotalBalance().multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setWalletCode(memberWalletContractEntity.getWalletCode()+"/USDT");

            list.add(memberWalletContractInfoVo);

            totalCoin = totalCoin.add(memberWalletContractEntity.getTotalBalance());

         }

      }

		
      map.put("memberWalletContractInfoVo", list);

      map.put("totalCoin", totalCoin.setScale(4, BigDecimal.ROUND_DOWN));

      map.put("availableCoin", totalCoin.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

        return Result.ok(map);

    }



    @Override

@@ -389,11 +414,44 @@
       }

       //获取用户ID

       Long memberId = LoginUserUtils.getAppLoginUser().getId();

       MemberEntity memberEntity = LoginUserUtils.getAppLoginUser();

    	
       List<ContractHoldOrderEntity> list = contractHoldOrderDao.selectHoldOrderListByMemberIdAndSymbol(memberEntity.getId(), symbol, 1);

       BigDecimal totalProfitOrLoss = BigDecimal.ZERO;

        if (CollUtil.isNotEmpty(list)) {

            for (ContractHoldOrderEntity holdOrderEntity : list) {

                // 获取最新价

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

                BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());

                // 盈亏

                BigDecimal rewardRatio = BigDecimal.ZERO;

                // 开多

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

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

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

                    // 开空

                } else {

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

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

                }



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

                    PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting();

                    if (rewardRatio.compareTo(BigDecimal.ZERO) > -1) {

                        rewardRatio = rewardRatio.multiply(BigDecimal.ONE.subtract(tradeSettingEntity.getProfitParam()));

                    } 
                }

                totalProfitOrLoss = totalProfitOrLoss.add(rewardRatio);

            }

        }

       

       String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

       MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbol);

       BigDecimal availableBalance = walletContract.getAvailableBalance();

       // 扣币

       if (totalProfitOrLoss.compareTo(BigDecimal.ZERO) < 0) {

          availableBalance = availableBalance.add(totalProfitOrLoss);

       }

       BigDecimal availableSubtract = availableBalance.subtract(balance);

       if (availableSubtract.compareTo(BigDecimal.ZERO) < 0) {

          return Result.fail(MessageSourceUtils.getString("member_service_0007"));

@@ -422,7 +480,6 @@
       }

       

       //更新合约全仓模式下的订单权益

        MemberEntity memberEntity = memberDao.selectById(memberId);

        String symbols = symbol+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

       

@@ -446,11 +503,10 @@
    }



    @Override

    public Result findWalletContractBySymbol() {

    public Result findWalletContractBySymbol(String symbol) {

        //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

        MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, walletCode);

        MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbol);

        BigDecimal availableBalance = walletContract.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN);

        return Result.ok(availableBalance);

    }

@@ -797,4 +853,117 @@
        return Result.ok(allWalletCoinVo);

   }



   @Override

   public Result getContractSymbolList() {

      //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        List<ContractSymbolListVo> list = memberWalletContractDao.findContractSymbolListBymemberId(memberId);

        if(CollUtil.isNotEmpty(list)) {

           for(ContractSymbolListVo contractSymbolListVo : list) {

              String walletCode = contractSymbolListVo.getWalletCode();

              walletCode = walletCode+"/USDT";

              contractSymbolListVo.setWalletCode(walletCode);

           }

        }

      return Result.ok(list);

   }



   @Override

   @Transactional(rollbackFor = Exception.class)

   public Result contractInTransfer(BigDecimal balance, String symbolIn, String symbolOut) {

      //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        //转入转出不能是同一账户

        if(symbolIn.equals(symbolOut)) {

           return Result.fail(MessageSourceUtils.getString("member_service_0098"));

        }

        if (balance.compareTo(BigDecimal.ZERO) <= 0) {

          return Result.fail(MessageSourceUtils.getString("member_service_0004"));

       }

        
        MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbolOut);

       BigDecimal availableBalance = walletContract.getAvailableBalance();

       // 扣币

       BigDecimal availableSubtract = availableBalance.subtract(balance);

       if (availableSubtract.compareTo(BigDecimal.ZERO) < 0) {

          return Result.fail(MessageSourceUtils.getString("member_service_0007"));

       }

       BigDecimal totalBalance = walletContract.getTotalBalance();

       BigDecimal totalSubtract = totalBalance.subtract(balance);

    	
       walletContract.setAvailableBalance(availableSubtract);

       walletContract.setTotalBalance(totalSubtract);

       int updateWalletCoinById = memberWalletContractDao.updateById(walletContract);

       if (updateWalletCoinById < 1) {

          return Result.fail(MessageSourceUtils.getString("member_service_0096"));

       }

    	
       //更新合约全仓模式下的订单权益

        MemberEntity memberEntity = memberDao.selectById(memberId);

        String symbols = symbolOut+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

        
        // 加币

        // 查询合约账户

        MemberWalletContractEntity walletContractIn = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbolIn);

        BigDecimal availableBalanceIn = walletContractIn.getAvailableBalance();

        BigDecimal addIn = availableBalanceIn.add(balance);

        walletContractIn.setAvailableBalance(addIn);

        BigDecimal totalBalanceIn = walletContractIn.getTotalBalance();

        BigDecimal totalBigDecimalIn = totalBalanceIn.add(balance);

        walletContractIn.setTotalBalance(totalBigDecimalIn);

        int updateWalletContractById = memberWalletContractDao.updateById(walletContractIn);

        if (updateWalletContractById < 1) {

            return Result.fail(MessageSourceUtils.getString("member_service_0096"));

        }

        
        //更新合约全仓模式下的订单权益

        String symbolIns = symbolIn+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbolIns, memberEntity);

        
        //添加币币资金划转历史记录

        MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();

        memberAccountRecord.setContent("转出至合约"+symbolIn+"账户");

        memberAccountRecord.setMemberId(memberId);

        memberAccountRecord.setAmount(balance.negate());

        memberAccountRecord.setStatus(MemberAccountMoneyChange.STATUS_SUCCESS_INTEGER);

        memberAccountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_CONTRACT);

        memberAccountMoneyChangeDao.insert(memberAccountRecord);



        //添加合约资金划转历史记录

        memberAccountRecord.setContent("由合约"+symbolOut+"账户转入至合约"+symbolIn+"账户");

        memberAccountRecord.setAmount(balance);

        memberAccountMoneyChangeDao.insert(memberAccountRecord);

        
        return Result.ok(MessageSourceUtils.getString("member_service_0006"));

   }

	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	


}