blame | history | patch | commit | commitdiff | ignore whitespace
gao
2020-06-05 01aa2cc5c8fafd89ff763bfb0016c4983ff79648 
 src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java


@@ -182,7 +182,7 @@


                            }


                        }


                        //回报率


                        BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        BigDecimal returnRate = profitLossPrice.divide((order.getBondAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        contractOrderEntity.setRewardAmount(profitLossPrice);


                        contractOrderEntity.setRewardRatio(returnRate);


                        contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount());


@@ -191,14 +191,15 @@


                        BigDecimal totalReturn = BigDecimal.ZERO;


                        contractOrderService.save(contractOrderEntity);




                        contractEntrustOrderService.removeById(order.getId());


                        contractHoldOrderService.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());




                        memberWalletContractService.increaseWalletContractBalanceById(totalReturn, totalBalance, null, wallet.getId());




                        // 流水记录 TODO 531e


                        insertAccountFlow(order, wallet, profitLossPrice, "止盈平仓");


@@ -242,7 +243,7 @@


                    System.out.println("执行操作");


                    String symbol = order.getSymbol();


                    // 本次需要退回的预付款


                    BigDecimal prePrice = order.getPrePaymentAmount();


                    BigDecimal prePrice = order.getBondAmount();


                    Long memberId = order.getMemberId();


                    MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT");


                    if (wallet != null) {


@@ -270,7 +271,7 @@


                            }


                        }


                        //回报率


                        BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        BigDecimal returnRate = profitLossPrice.divide((order.getBondAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        contractOrderEntity.setRewardAmount(profitLossPrice);


                        contractOrderEntity.setRewardRatio(returnRate);


                        contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount());


@@ -278,6 +279,8 @@


                        contractOrderEntity.setClosingType(7);


                        BigDecimal totalReturn = BigDecimal.ZERO;


                        contractOrderService.save(contractOrderEntity);




                        contractHoldOrderService.removeById(order.getId());


                        // 将需要退回的减去手续费


                        BigDecimal needReturn = prePrice.add(profitLossPrice);


                        //总退回金额=保证金+收益-手续费


@@ -285,13 +288,13 @@


                        // 更新钱包


                        // 总的是收益-平仓手续费


                        BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount());


                        memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId());




                        memberWalletContractService.increaseWalletContractBalanceById(totalReturn, totalBalance, null, wallet.getId());




                        insertAccountFlow(order, wallet, profitLossPrice, "止盈平仓");




                        //返佣


                        calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2);


                        ThreadPoolUtils.calReturnMoney(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, AgentReturnEntity.ORDER_TYPE_CLOSE);


                    }


                }


            }


@@ -331,7 +334,7 @@


                    String symbol = order.getSymbol();


                    Long memberId = order.getMemberId();


                    // 本次需要退回的预付款


                    BigDecimal prePrice = order.getPrePaymentAmount();


                    BigDecimal prePrice = order.getBondAmount();


                    MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT");




                    if (wallet != null) {


@@ -359,7 +362,7 @@


                            }


                        }


                        //回报率


                        BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        BigDecimal returnRate = profitLossPrice.divide((order.getBondAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        contractOrderEntity.setRewardAmount(profitLossPrice);


                        contractOrderEntity.setRewardRatio(returnRate);


                        contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount());


@@ -367,6 +370,8 @@


                        contractOrderEntity.setClosingType(8);


                        BigDecimal totalReturn = BigDecimal.ZERO;


                        contractOrderService.save(contractOrderEntity);




                        contractHoldOrderService.removeById(order.getId());


                        // 将需要退回的减去手续费


                        BigDecimal needReturn = prePrice.add(profitLossPrice);


                        //总退回金额=保证金+收益-手续费


@@ -374,12 +379,13 @@


                        // 更新钱包


                        // 总的是收益-平仓手续费


                        BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount());


                        memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId());




                        memberWalletContractService.increaseWalletContractBalanceById(totalReturn, totalBalance, null, wallet.getId());




                        insertAccountFlow(order, wallet, profitLossPrice, "开多止损平仓");




                        //返佣


                        calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2);


                        ThreadPoolUtils.calReturnMoney(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, AgentReturnEntity.ORDER_TYPE_CLOSE);


                    }


                }


            }


@@ -418,7 +424,7 @@


                    String symbol = order.getSymbol();


                    Long memberId = order.getMemberId();


                    // 本次需要退回的预付款


                    BigDecimal prePrice = order.getPrePaymentAmount();


                    BigDecimal prePrice = order.getBondAmount();


                    MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT");




                    if (wallet != null) {


@@ -446,7 +452,7 @@


                            }


                        }


                        //回报率


                        BigDecimal returnRate = profitLossPrice.divide((order.getPrePaymentAmount().subtract(contractOrderEntity.getClosingFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        BigDecimal returnRate = profitLossPrice.divide((order.getBondAmount().subtract(contractOrderEntity.getOpeningFeeAmount())), 8, BigDecimal.ROUND_DOWN);


                        contractOrderEntity.setRewardAmount(profitLossPrice);


                        contractOrderEntity.setRewardRatio(returnRate);


                        contractOrderEntity.setClosingFeeAmount(order.getOpeningFeeAmount());


@@ -454,6 +460,9 @@


                        contractOrderEntity.setClosingType(9);


                        BigDecimal totalReturn = BigDecimal.ZERO;


                        contractOrderService.save(contractOrderEntity);




                        contractHoldOrderService.removeById(order.getId());




                        // 将需要退回的减去手续费


                        BigDecimal needReturn = prePrice.add(profitLossPrice);


                        //总退回金额=保证金+收益-手续费


@@ -461,13 +470,12 @@


                        // 更新钱包


                        // 总的是收益-平仓手续费


                        BigDecimal totalBalance = profitLossPrice.subtract(contractOrderEntity.getClosingFeeAmount());


                        memberWalletContractService.increaseWalletContractBalanceById(totalBalance, totalReturn, null, wallet.getId());


                        memberWalletContractService.increaseWalletContractBalanceById(totalReturn, totalBalance, null, wallet.getId());




                        insertAccountFlow(order, wallet, profitLossPrice, "开空止损平仓");




                        //返佣


                        calYj(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, 2);




                        ThreadPoolUtils.calReturnMoney(order.getMemberId(), order.getOpeningFeeAmount(), contractOrderEntity, AgentReturnEntity.ORDER_TYPE_CLOSE);


                    }


                }


            }


@@ -546,6 +554,7 @@


                contractOrderEntity.setEntrustOpeningPrice(coinsCoinsOrder.getEntrustPrice());


                contractOrderEntity.setEntrustTime(coinsCoinsOrder.getCreateTime());


                contractOrderEntity.setOpeningTime(new Date());


                


                contractOrderEntity.setId(null);


                contractOrderService.save(contractOrderEntity);


                // 发送爆仓的队列


@@ -562,9 +571,10 @@


                // 扣除手续费


                BigDecimal totalBalance = openFeePrice.negate();


                contractEntrustOrderService.removeById(coinsCoinsOrder.getId());


                memberWalletContractService.increaseWalletContractBalanceById(null, totalBalance, null, wallet.getId());


                // TODO 531 待写


                calYj(memId, openFeePrice, contractOrderEntity, 1);


                memberWalletContractService.increaseWalletContractBalanceById(null, totalBalance, coinsCoinsOrder.getBondAmount().negate(), wallet.getId());




                //返佣


                ThreadPoolUtils.calReturnMoney(memberEntity.getId(), openFeePrice, contractOrderEntity, AgentReturnEntity.ORDER_TYPE_OPEN);


            }


        }


    }


@@ -575,15 +585,11 @@


     * @param


     */


    public void dealCoinOut(List<ContractHoldOrderEntity> orderList, List<OrderModel> orderModels) {


        // 需要比较查询到的和消息发来的单的爆仓操作次序号是否相同


        // 构建map




        if (CollectionUtils.isNotEmpty(orderList)) {


            Map<Long, Integer> modelMap = new HashMap<Long, Integer>();


            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();


@@ -595,9 +601,6 @@


                }


                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);


@@ -620,30 +623,19 @@


                    //删除次仓订单


                    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())));


                    contractOrderEntity.setClosingFeeAmount(coinsOrder.getOpeningFeeAmount());


                    contractOrderEntity.setRewardAmount(coinsOrder.getBondAmount().subtract(contractOrderEntity.getOpeningFeeAmount()).negate());


                    contractOrderService.save(contractOrderEntity);




                    //更新用户钱包数据


                    MemberWalletContractEntity usdt = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memId, "USDT");




                    // Double totalPrice = wallet.getTotalBalance() - coinsOrder.getPrePrice();


                    // 减去的时候用负数


                    BigDecimal totalPrice = coinsOrder.getPrePaymentAmount().negate();


                    //Double totalPrice = - coinsOrder.getPrePrice();


                    BigDecimal totalPrice = coinsOrder.getBondAmount().negate();


                    memberWalletContractService.increaseWalletContractBalanceById(null, totalPrice, null, usdt.getId());


                    // 流水记录 TODO


                    MemberAccountFlowEntity record = new MemberAccountFlowEntity();


@@ -653,13 +645,12 @@


                    record.setBalance(usdt.getAvailableBalance());


                    record.setMemberId(memId);


                    record.setSymbol(coinsOrder.getSymbol());


                    record.setPrice(coinsOrder.getPrePaymentAmount());


                    record.setPrice(coinsOrder.getBondAmount());


                    memberAccountFlowEntityDao.insert(record);


                }


            }


        }


    }






    public void calYj(Long mid, BigDecimal money, ContractOrderEntity order, int type) {


        if (money != null) {


@@ -733,8 +724,5 @@


            agent.setInviteId(entry.getKey());


            agentReturnDao.insert(agent);


        }






    }




}