package com.xcong.excoin.modules.contract.service.impl; import com.alibaba.fastjson.JSONObject; import com.xcong.excoin.modules.coin.dao.MemberAccountFlowEntityDao; import com.xcong.excoin.modules.coin.entity.MemberAccountFlowEntity; import com.xcong.excoin.modules.contract.entity.ContractEntrustOrderEntity; import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity; import com.xcong.excoin.modules.contract.entity.ContractOrderEntity; import com.xcong.excoin.modules.contract.mapper.ContractEntrustOrderEntityMapper; import com.xcong.excoin.modules.contract.mapper.ContractHoldOrderEntityMapper; import com.xcong.excoin.modules.contract.service.ContractEntrustOrderService; import com.xcong.excoin.modules.contract.service.ContractHoldOrderService; import com.xcong.excoin.modules.contract.service.ContractOrderService; import com.xcong.excoin.modules.member.dao.AgentReturnDao; import com.xcong.excoin.modules.member.entity.AgentReturnEntity; import com.xcong.excoin.modules.member.entity.MemberEntity; import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity; import com.xcong.excoin.modules.member.parameter.vo.NeedMoneyMemberVo; import com.xcong.excoin.modules.member.service.MemberService; import com.xcong.excoin.modules.member.service.MemberWalletContractService; import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity; import com.xcong.excoin.rabbit.pricequeue.OrderModel; import com.xcong.excoin.rabbit.producer.OrderProducer; import com.xcong.excoin.utils.CacheSettingUtils; import com.xcong.excoin.utils.CalculateUtil; import com.xcong.excoin.utils.ThreadPoolUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; /** * @author helius */ @Slf4j @Service public class OrderWebsocketServiceImpl { @Resource ContractHoldOrderService contractHoldOrderService; @Resource ContractOrderService contractOrderService; @Resource ContractEntrustOrderService contractEntrustOrderService; @Resource MemberWalletContractService memberWalletContractService; @Resource CacheSettingUtils cacheSettingUtils; @Resource OrderProducer producer; @Resource MemberService memberService; @Resource private AgentReturnDao agentReturnDao; @Resource private MemberAccountFlowEntityDao memberAccountFlowEntityDao; public void dealOrderFromMq(List list, Integer type) { if (CollectionUtils.isNotEmpty(list)) { String batchno = UUID.randomUUID().toString(); // 更新订单状态 // 更新为不可平仓状态 int count = contractHoldOrderService.updateContractHoldOrderCanNotClosingByIds(list, batchno); // 查询 if (count > 0) { // 查询 List coinsCoinsOrders = contractHoldOrderService.selectContractHoldOrderByBatchNo(batchno); // 根据状态调用不同的方法 // 1：买入委托2：开多3:开空4：平多5：平空6:爆仓平多7:爆仓平空8:撤单9:止盈平多10：止盈平空11：止损平多12：止损平空 // 6在这里是爆仓 包括爆空和暴多 switch (type) { case 6: this.dealCoinOut(coinsCoinsOrders, list); break; case 9: this.dealForMoreStopPro(coinsCoinsOrders, list); break; case 10: this.dealForLessStopPro(coinsCoinsOrders, list); break; case 11: this.dealForMoreLoss(coinsCoinsOrders, list); break; case 12: this.dealForLessLoss(coinsCoinsOrders, list); break; default: break; } } } } public void dealForLimitMq(List list) { if (CollectionUtils.isNotEmpty(list)) { //查询限价委托的单 String batchno = UUID.randomUUID().toString(); List ids = new ArrayList<>(); list.forEach(model -> ids.add(model.getOrderId())); List contractEntrustOrderEntities = contractEntrustOrderService.selectEntrustOrderListByIds(ids); if (CollectionUtils.isNotEmpty(contractEntrustOrderEntities)) { this.dealLimitBuyOrder(contractEntrustOrderEntities); } } } /** * 开多止盈 */ @Transactional(rollbackFor = Exception.class) public void dealForMoreStopPro(List orderList, List list) { if (CollectionUtils.isNotEmpty(orderList)) { Map modelMap = new HashMap(); for (OrderModel model : list) { modelMap.put(model.getOrderId(), new BigDecimal(model.getPrice())); } for (ContractHoldOrderEntity order : orderList) { Long orderId = order.getId(); System.out.println("开多止盈订单号：" + order.getOrderNo()); System.out.println("传来的止盈价格：" + modelMap.get(order.getId())); if (null != order.getStopProfitPrice()) { BigDecimal closePrice = order.getStopProfitPrice(); BigDecimal queuePrice = modelMap.get(order.getId()); System.out.println("订单的止盈价格：" + closePrice); // 判断 保留七位是为了忽略以为小数 防止不精确导致的不相等 if (queuePrice.compareTo(closePrice) != 0) { // 不能止盈 System.out.println("数据库价格：" + queuePrice.toPlainString() + "--价格不能止盈：" + closePrice); //更新数据 contractHoldOrderService.updateOrderIsCanClosingAndBatchNoById(orderId); continue; } System.out.println("执行操作"); // 止盈价 String symbol = order.getSymbol(); // 本次需要退回的保证金 BigDecimal prePrice = order.getBondAmount(); Long memberId = order.getMemberId(); MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT"); if (wallet != null) { // 历史订单 ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(order); contractOrderEntity.setClosingTime(new Date()); contractOrderEntity.setId(null); // 本次平仓数量 int currentFlat = order.getSymbolCnt(); BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol()); // 盈亏额度= (当前的币种的平仓价-下单时的建仓价)*购买的手数/规格*倍率 BigDecimal profitLossPrice = (closePrice .subtract(order.getOpeningPrice())) .multiply(new BigDecimal(currentFlat)) .multiply(symbolSku).setScale(8, BigDecimal.ROUND_DOWN); MemberEntity memberEntity = memberService.getById(memberId); if (memberEntity.getIsProfit() == 1) { PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting(); if (profitLossPrice.compareTo(BigDecimal.ZERO) > 0) { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.subtract(tradeSetting.getProfitParam())); } else { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.add(tradeSetting.getProfitParam())); } } //回报率 BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN); contractOrderEntity.setRewardAmount(profitLossPrice); contractOrderEntity.setRewardRatio(returnRate); contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount()); contractOrderEntity.setClosingPrice(closePrice); contractOrderEntity.setClosingType(6); BigDecimal totalReturn = BigDecimal.ZERO; contractOrderService.save(contractOrderEntity); contractEntrustOrderService.removeById(order.getId()); // 将需要退回的减去手续费 BigDecimal needReturn = prePrice.add(profitLossPrice); //总退回金额=保证金+收益-手续费 totalReturn = needReturn.subtract(contractOrderEntity.getClosingFeeAmount()); // 总的是收益-平仓手续费 BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount()); memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId()); // 流水记录 TODO 531e insertAccountFlow(order, wallet, profitLossPrice, "止盈平仓"); //返佣 ThreadPoolUtils.calReturnMoney(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, AgentReturnEntity.ORDER_TYPE_CLOSE); } } } } } /** * 开空止盈 */ public void dealForLessStopPro(List orderList, List list) { //List orderList = orderMapper.selectOrderByBatchNo(batchno); //System.out.println("开空止盈订单batchno：" + batchno); if (CollectionUtils.isNotEmpty(orderList)) { Map modelMap = new HashMap(); for (OrderModel model : list) { modelMap.put(model.getOrderId(), new BigDecimal(model.getPrice())); } for (ContractHoldOrderEntity order : orderList) { System.out.println("开空止盈订单号：" + order.getOrderNo()); System.out.println("传来的止盈价格：" + modelMap.get(order.getId()).toPlainString()); BigDecimal closePrice = order.getStopProfitPrice(); Long orderId = order.getId(); if (null != closePrice) { // 止盈价 System.out.println("订单的止盈价格：" + closePrice); System.out.println(closePrice.compareTo(modelMap.get(order.getId()))); BigDecimal queuePrice = modelMap.get(order.getId()).setScale(7, RoundingMode.HALF_UP); if (closePrice.compareTo(queuePrice) != 0) { System.out.println("数据库价格：" + queuePrice.toPlainString() + "--价格不能开空止盈：" + closePrice); contractHoldOrderService.updateOrderIsCanClosingAndBatchNoById(orderId); continue; } System.out.println("执行操作"); String symbol = order.getSymbol(); // 本次需要退回的预付款 BigDecimal prePrice = order.getPrePaymentAmount(); Long memberId = order.getMemberId(); MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT"); if (wallet != null) { // 历史订单 ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(order); contractOrderEntity.setClosingTime(new Date()); contractOrderEntity.setId(null); // 本次平仓数量 int currentFlat = order.getSymbolCnt(); BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol()); // 盈亏额度= (当前的币种的平仓价-下单时的建仓价)*购买的手数/规格*倍率 BigDecimal profitLossPrice = (order.getOpeningPrice() .subtract(closePrice)) .multiply(new BigDecimal(currentFlat + "")) .multiply(symbolSku).setScale(8, BigDecimal.ROUND_DOWN); MemberEntity memberEntity = memberService.getById(memberId); if (memberEntity.getIsProfit() == 1) { PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting(); if (profitLossPrice.compareTo(BigDecimal.ZERO) > 0) { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.subtract(tradeSetting.getProfitParam())); } else { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.add(tradeSetting.getProfitParam())); } } //回报率 BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN); contractOrderEntity.setRewardAmount(profitLossPrice); contractOrderEntity.setRewardRatio(returnRate); contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount()); contractOrderEntity.setClosingPrice(closePrice); contractOrderEntity.setClosingType(7); BigDecimal totalReturn = BigDecimal.ZERO; contractOrderService.save(contractOrderEntity); // 将需要退回的减去手续费 BigDecimal needReturn = prePrice.add(profitLossPrice); //总退回金额=保证金+收益-手续费 totalReturn = needReturn.subtract(contractOrderEntity.getClosingFeeAmount()); // 更新钱包 // 总的是收益-平仓手续费 BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount()); memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId()); insertAccountFlow(order, wallet, profitLossPrice, "止盈平仓"); //返佣 calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2); } } } } } /** * 开多止损 * * @param */ public void dealForMoreLoss(List orderList, List list) { //List orderList = orderMapper.selectOrderByBatchNo(batchno); //System.out.println("开多止损批次号batchno：" + batchno); if (CollectionUtils.isNotEmpty(orderList)) { Map modelMap = new HashMap(); for (OrderModel model : list) { modelMap.put(model.getOrderId(), new BigDecimal(model.getPrice())); } for (ContractHoldOrderEntity order : orderList) { System.out.println("开多止损订单号：" + order.getOrderNo()); Long orderId = order.getId(); System.out.println("传来的止损价格：" + modelMap.get(orderId)); if (null != order.getStopLossPrice()) { // 止损价 BigDecimal closePrice = order.getStopLossPrice(); System.out.println("订单止损价格：" + closePrice.toPlainString()); BigDecimal queuePrice = modelMap.get(orderId); if (closePrice.compareTo(queuePrice) != 0) { System.out.println("数据库价格：" + queuePrice.toPlainString() + "--价格不能开多止损：" + closePrice); contractHoldOrderService.updateOrderIsCanClosingAndBatchNoById(orderId); continue; } System.out.println("执行操作"); String symbol = order.getSymbol(); Long memberId = order.getMemberId(); // 本次需要退回的预付款 BigDecimal prePrice = order.getPrePaymentAmount(); MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT"); if (wallet != null) { // 历史订单 ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(order); contractOrderEntity.setClosingTime(new Date()); contractOrderEntity.setId(null); // 本次平仓数量 int currentFlat = order.getSymbolCnt(); BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol()); // 盈亏额度= (当前的币种的平仓价-下单时的建仓价)*购买的手数/规格*倍率 BigDecimal profitLossPrice = (closePrice .subtract(order.getOpeningPrice())) .multiply(new BigDecimal(currentFlat + "")) .multiply(symbolSku).setScale(8, BigDecimal.ROUND_DOWN); MemberEntity memberEntity = memberService.getById(memberId); if (memberEntity.getIsProfit() == 1) { PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting(); if (profitLossPrice.compareTo(BigDecimal.ZERO) > 0) { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.subtract(tradeSetting.getProfitParam())); } else { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.add(tradeSetting.getProfitParam())); } } //回报率 BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN); contractOrderEntity.setRewardAmount(profitLossPrice); contractOrderEntity.setRewardRatio(returnRate); contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount()); contractOrderEntity.setClosingPrice(closePrice); contractOrderEntity.setClosingType(8); BigDecimal totalReturn = BigDecimal.ZERO; contractOrderService.save(contractOrderEntity); // 将需要退回的减去手续费 BigDecimal needReturn = prePrice.add(profitLossPrice); //总退回金额=保证金+收益-手续费 totalReturn = needReturn.subtract(contractOrderEntity.getClosingFeeAmount()); // 更新钱包 // 总的是收益-平仓手续费 BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount()); memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId()); insertAccountFlow(order, wallet, profitLossPrice, "开多止损平仓"); //返佣 calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2); } } } } } /** * 开空止损 * * @param */ public void dealForLessLoss(List orderList, List list) { // List orderList = orderMapper.selectOrderByBatchNo(batchno); //System.out.println("开空止损批次号batchno：" + batchno); if (CollectionUtils.isNotEmpty(orderList)) { Map modelMap = new HashMap(); for (OrderModel model : list) { modelMap.put(model.getOrderId(), new BigDecimal(model.getPrice())); } for (ContractHoldOrderEntity order : orderList) { Long orderId = order.getId(); System.out.println("传来的止损价格：" + modelMap.get(orderId).toPlainString()); System.out.println("开空止损订单号：" + order.getOrderNo()); if (null != order.getStopLossPrice()) { // 止损价 BigDecimal closePrice = order.getStopLossPrice(); System.out.println("订单止损价格：" + closePrice.toPlainString()); BigDecimal queuePrice = modelMap.get(orderId); if (closePrice.compareTo(queuePrice) != 0) { System.out.println("数据库价格：" + queuePrice.toPlainString() + "--价格不能开空止损：" + closePrice); contractHoldOrderService.updateOrderIsCanClosingAndBatchNoById(orderId); continue; } System.out.println("执行操作"); String symbol = order.getSymbol(); Long memberId = order.getMemberId(); // 本次需要退回的预付款 BigDecimal prePrice = order.getPrePaymentAmount(); MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT"); if (wallet != null) { // 历史订单 ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(order); contractOrderEntity.setClosingTime(new Date()); contractOrderEntity.setId(null); // 本次平仓数量 int currentFlat = order.getSymbolCnt(); BigDecimal symbolSku = cacheSettingUtils.getSymbolSku(order.getSymbol()); // 盈亏额度= (当前的币种的平仓价-下单时的建仓价)*购买的手数/规格*倍率 BigDecimal profitLossPrice = (order.getOpeningPrice() .subtract(closePrice)) .multiply(new BigDecimal(currentFlat + "")) .multiply(symbolSku).setScale(8, BigDecimal.ROUND_DOWN); MemberEntity memberEntity = memberService.getById(memberId); if (memberEntity.getIsProfit() == 1) { PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting(); if (profitLossPrice.compareTo(BigDecimal.ZERO) > 0) { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.subtract(tradeSetting.getProfitParam())); } else { profitLossPrice = profitLossPrice.multiply(BigDecimal.ONE.add(tradeSetting.getProfitParam())); } } //回报率 BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN); contractOrderEntity.setRewardAmount(profitLossPrice); contractOrderEntity.setRewardRatio(returnRate); contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount()); contractOrderEntity.setClosingPrice(closePrice); contractOrderEntity.setClosingType(9); BigDecimal totalReturn = BigDecimal.ZERO; contractOrderService.save(contractOrderEntity); // 将需要退回的减去手续费 BigDecimal needReturn = prePrice.add(profitLossPrice); //总退回金额=保证金+收益-手续费 totalReturn = needReturn.subtract(contractOrderEntity.getClosingFeeAmount()); // 更新钱包 // 总的是收益-平仓手续费 BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount()); memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId()); insertAccountFlow(order, wallet, profitLossPrice, "开空止损平仓"); //返佣 calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2); } } } } } private void insertAccountFlow(ContractHoldOrderEntity order, MemberWalletContractEntity wallet, BigDecimal profitLossPrice, String source) { MemberAccountFlowEntity record = new MemberAccountFlowEntity(); record.setCreateTime(new Date()); record.setSource(source); record.setRemark(source); record.setBalance(wallet.getAvailableBalance()); record.setMemberId(order.getMemberId()); record.setSymbol(order.getSymbol()); record.setPrice(profitLossPrice.add(order.getPrePaymentAmount())); memberAccountFlowEntityDao.insert(record); } /** * 限价委托 * * @param */ public void dealLimitBuyOrder(List orderList) { //List orderList = orderMapper.selectOrderByBatchNo(batchno); if (CollectionUtils.isNotEmpty(orderList)) { ContractHoldOrderEntity contractHoldOrderEntity = null; for (ContractEntrustOrderEntity coinsCoinsOrder : orderList) { MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(coinsCoinsOrder.getMemberId(), "USDT"); if (wallet == null) { continue; } // 委托单bean转换为持仓单bean contractHoldOrderEntity = ContractEntrustOrderEntityMapper.INSTANCE.entrustOrderToHoldOrder(coinsCoinsOrder); contractHoldOrderEntity.setId(null); Long memId = coinsCoinsOrder.getMemberId(); MemberEntity memberEntity = memberService.getById(memId); BigDecimal entrustPrice = coinsCoinsOrder.getEntrustPrice(); int symbolCnt = coinsCoinsOrder.getSymbolCnt(); int type = coinsCoinsOrder.getEntrustType(); if (type == 1) { // 开多 contractHoldOrderEntity.setOpeningType(ContractHoldOrderEntity.OPENING_TYPE_MORE); } else { // 开空 contractHoldOrderEntity.setOpeningType(ContractHoldOrderEntity.OPENING_TYPE_LESS); } //持仓单赋值 contractHoldOrderEntity.setMemberId(memId); contractHoldOrderEntity.setIsCanClosing(ContractHoldOrderEntity.ORDER_CAN_CLOSING_Y); contractHoldOrderEntity.setMarkPrice(coinsCoinsOrder.getEntrustPrice()); contractHoldOrderEntity.setBondAmount(coinsCoinsOrder.getBondAmount()); // 开仓手续费 建仓价*规格*手数*手续费率 BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(coinsCoinsOrder.getSymbol()); PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting(); BigDecimal openFeePrice = coinsCoinsOrder.getEntrustPrice().multiply(lotNumber) .multiply(new BigDecimal(coinsCoinsOrder.getSymbolCnt())) .multiply(tradeSettingEntity.getFeeRatio().divide(new BigDecimal(100))) .setScale(8, BigDecimal.ROUND_DOWN); contractHoldOrderEntity.setOpeningFeeAmount(openFeePrice); contractHoldOrderEntity.setVersion(1); BigDecimal forceSetPrice = CalculateUtil.getForceSetPrice(coinsCoinsOrder.getBondAmount().subtract(openFeePrice), entrustPrice, symbolCnt, lotNumber, type, memberEntity); contractHoldOrderEntity.setForceClosingPrice(forceSetPrice); contractHoldOrderEntity.setLeverRatio(coinsCoinsOrder.getLeverRatio()); contractHoldOrderEntity.setOpeningPrice(entrustPrice); contractHoldOrderEntity.setTradeType(ContractHoldOrderEntity.TRADE_TYPE_LIMIT); contractHoldOrderService.save(contractHoldOrderEntity); // 需要一个历史插入 ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(contractHoldOrderEntity); contractOrderEntity.setEntrustOpeningPrice(coinsCoinsOrder.getEntrustPrice()); contractOrderEntity.setEntrustTime(coinsCoinsOrder.getCreateTime()); contractOrderEntity.setOpeningTime(new Date()); contractOrderEntity.setId(null); contractOrderService.save(contractOrderEntity); // 发送爆仓的队列 // 市价 if (coinsCoinsOrder.getEntrustType() == 1) { // 开多 OrderModel model = new OrderModel(contractHoldOrderEntity.getId(), 6, contractHoldOrderEntity.getForceClosingPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), coinsCoinsOrder.getSymbol(), 1); producer.sendPriceOperate(JSONObject.toJSONString(model)); } else { // 开空 OrderModel model = new OrderModel(contractHoldOrderEntity.getId(), 7, contractHoldOrderEntity.getForceClosingPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), coinsCoinsOrder.getSymbol(), 1); producer.sendPriceOperate(JSONObject.toJSONString(model)); } // 扣除手续费 BigDecimal totalBalance = openFeePrice.negate(); contractEntrustOrderService.removeById(coinsCoinsOrder.getId()); memberWalletContractService.increaseWalletContractBalanceById(null, totalBalance, null, wallet.getId()); // TODO 531 待写 calYj(memId, openFeePrice, contractOrderEntity, 1); } } } /** * 爆仓 * * @param */ public void dealCoinOut(List orderList, List orderModels) { // 需要比较查询到的和消息发来的单的爆仓操作次序号是否相同 // 构建map if (CollectionUtils.isNotEmpty(orderList)) { Map modelMap = new HashMap(); for (OrderModel model : orderModels) { modelMap.put(model.getOrderId(), model.getOperateNo()); } // TradeSetting tradeSetting = tradeMapper.findTradeSetting(); for (ContractHoldOrderEntity coinsOrder : orderList) { Long orderId = coinsOrder.getId(); Integer operateNo = coinsOrder.getOperateNo(); //判断当前订单是否是最新的爆仓价 不相等时直接进入下一个订单 if (!modelMap.get(orderId).equals(operateNo)) { // 将订单更新为可平仓并删除批次号 contractHoldOrderService.updateOrderIsCanClosingAndBatchNoById(orderId); continue; } boolean isDone = false; Long memId = coinsOrder.getMemberId(); MemberEntity byId = memberService.getById(memId); String symbol = coinsOrder.getSymbol(); //TradeSymbolSku symbolSku = tradeMapper.findSymbolSkubySymbol(symbol); BigDecimal nowPrice = coinsOrder.getForceClosingPrice(); // 创建订单(加入历史表的订单) ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(coinsOrder); //查询是否满足爆仓条件 if (coinsOrder.getOpeningType() == ContractHoldOrderEntity.OPENING_TYPE_MORE) { //如果是开多,当前价小于预估强平价即为爆仓 // 设置平仓类型 // 爆仓平多 contractOrderEntity.setClosingType(4); //更新用户钱包数据 isDone = true; } else { //如果是开空，当前价大于预估强平价即为爆仓 contractOrderEntity.setClosingType(5); //更新主表订单状态位为“已平仓” isDone = true; } if (isDone) { //删除次仓订单 contractHoldOrderService.removeById(orderId); //系统自动平仓（爆仓） // Double closingPrice = nowPrice // .multiply(new BigDecimal(tradeSetting.getClosingRatio()).divide(new BigDecimal(100), 8, BigDecimal.ROUND_DOWN)) // .multiply(symbolSku.getLotNumber())// 规格 // .multiply(new BigDecimal(coinsOrder.getSymbolSkuNumber())) // .setScale(8, BigDecimal.ROUND_DOWN).doubleValue(); //更新主表订单状态位为“已平仓” contractOrderEntity.setId(null); contractOrderEntity.setClosingPrice(BigDecimal.ZERO); //order.setPayTotalPrice(coinsOrder.getPrePrice()+coinsOrder.getClosingPrice());// 总支付金额(预付款) contractOrderEntity.setClosingPrice(nowPrice); contractOrderEntity.setClosingTime(new Date()); contractOrderEntity.setRewardAmount((coinsOrder.getOpeningFeeAmount().multiply(new BigDecimal("2")).subtract(coinsOrder.getPrePaymentAmount()))); //order.setRewardRatio(-(coinsOrder.getPrePrice() - (2*coinsOrder.getClosingPrice()))); contractOrderService.save(contractOrderEntity); //更新用户钱包数据 MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, "USDT"); // Double totalPrice = wallet.getTotalBalance() - coinsOrder.getPrePrice(); // 减去的时候用负数 BigDecimal totalPrice = coinsOrder.getPrePaymentAmount().negate(); //Double totalPrice = - coinsOrder.getPrePrice(); memberWalletContractService.increaseWalletContractBalanceById(null, totalPrice, null, usdt.getId()); // 流水记录 TODO MemberAccountFlowEntity record = new MemberAccountFlowEntity(); record.setCreateTime(new Date()); record.setSource("系统自动平仓"); record.setRemark("系统自动平仓"); record.setBalance(usdt.getAvailableBalance()); record.setMemberId(memId); record.setSymbol(coinsOrder.getSymbol()); record.setPrice(coinsOrder.getPrePaymentAmount()); memberAccountFlowEntityDao.insert(record); } } } } public void calYj(Long mid, BigDecimal money, ContractOrderEntity order, int type) { if (money != null) { money = money.multiply(new BigDecimal(0.7868)); } MemberEntity member = memberService.getById(mid); String[] referenceIds = member.getRefererIds().split(","); List ids = Arrays.asList(referenceIds); // 判断该用户是否为代理商 NeedMoneyMemberVo needMoneyMember = memberService.selectFriendRelationUserByMemberId(mid); // 查询该用户下所有需要返佣的代理商 List list = memberService.selectAllNeedMoneyMember(ids); TreeMap treeMap = new TreeMap<>(new Comparator() { @Override public int compare(Integer o1, Integer o2) { return o2.compareTo(o1); } }); // 建立层级关系 for (int i = 0; i < list.size(); i++) { treeMap.put(list.get(i).getLevelId(), list.get(i)); } // 该用户为代理商则判断is_self字段，判断是否保留其手续费 // 该用户为代理商则判断is_self字段，判断是否保留其手续费 if (needMoneyMember != null && needMoneyMember.getFeeIsSelf() == 1) { treeMap.put(needMoneyMember.getLevelId(), needMoneyMember); } // 存放uid以及对应uid用户的佣金 Map map = new HashMap<>(); Iterator> it = treeMap.entrySet().iterator(); BigDecimal lastRate = BigDecimal.ZERO; BigDecimal lastYj = BigDecimal.ZERO; while (it.hasNext()) { Map.Entry entry = it.next(); NeedMoneyMemberVo member1 = entry.getValue(); // 上下级佣金比率相减后乘以手续费 -- 即用户所得佣金 lastYj = (member1.getReturnRatio().subtract(lastRate)).multiply(money); lastRate = member1.getReturnRatio(); map.put(member1.getInviteId(), lastYj); } // 输出对应佣金是否正确 Iterator> it1 = map.entrySet().iterator(); List agentList = new ArrayList(); while (it1.hasNext()) { Map.Entry entry = it1.next(); // System.out.println(entry.getKey() + "-----" + entry.getValue()); MemberEntity agentMember = memberService.selectMemberInfoByInviteId(entry.getKey()); AgentReturnEntity agent = new AgentReturnEntity(); agent.setMemberId(mid); agent.setOrderId(order.getId()); agent.setOrderNo(order.getOrderNo()); agent.setRefererId(agentMember.getId()); agent.setOrderType(order.getOrderType()); agent.setReturnSymbol(order.getSymbol()); agent.setIsReturn(0); agent.setReturnAmount(entry.getValue()); agent.setClosingType(order.getClosingType()); if (type == 1) {//开仓 agent.setOpeningFeeAmount(order.getOpeningFeeAmount()); } else if (type == 2) {//平仓 agent.setClosingFeeAmount(order.getClosingFeeAmount()); } else {//持仓费 agent.setHoldingFeeAmount(order.getHoldAmount()); } agent.setInviteId(entry.getKey()); agentReturnDao.insert(agent); } } }