| | |
| | | map.put("low", low.setScale(decimal, RoundingMode.HALF_UP)); |
| | | map.put("volume", kline.getVolume()); |
| | | |
| | | if (line.equalsIgnoreCase(Kline.PERIOD_15MIN) || line.equalsIgnoreCase(Kline.PERIOD_30MIN) || line.equalsIgnoreCase(Kline.PERIOD_60MIN)) { |
| | | //if (line.equalsIgnoreCase(Kline.PERIOD_15MIN) || line.equalsIgnoreCase(Kline.PERIOD_30MIN) || line.equalsIgnoreCase(Kline.PERIOD_60MIN)) { |
| | | if (i == data.size() - 1) { |
| | | BeforeClose beforeClose = dataDBService.getBeforeClose(kline.getSymbol(), line, ts); |
| | | if (beforeClose != null) { |
| | |
| | | map.put("low", beforeClose.getMinClose().setScale(decimal, RoundingMode.HALF_UP)); |
| | | } |
| | | } |
| | | } |
| | | //} |
| | | list.add(map); |
| | | } |
| | | return list; |
| | |
| | | } |
| | | beforeClose.setMaxClose(convertToBigDecimal(resultMap.get("maxClose"))); |
| | | beforeClose.setMinClose(convertToBigDecimal(resultMap.get("minClose"))); |
| | | redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose , 5 , TimeUnit.MINUTES); |
| | | redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose , 1 , TimeUnit.MINUTES); |
| | | } |
| | | return beforeClose; |
| | | } |
| | |
| | | } else{ |
| | | order.setProfit(amount.negate()); |
| | | } |
| | | //逐仓强平利润固定-100% |
| | | if (order.getLocationType() == 0) { |
| | | order.setProfit(order.getDepositOpen().add(order.getAddDepositOpen()).negate()); |
| | | //强平利润固定-100% |
| | | order.setProfit(order.getDepositOpen().add(order.getAddDepositOpen()).negate()); |
| | | //全仓强平利润+账户余额 |
| | | if (order.getLocationType() == 1) { |
| | | Wallet wallet = this.walletService.findByUserId(order.getPartyId()); |
| | | order.setProfit(order.getProfit().subtract(wallet.getMoney())); |
| | | } |
| | | } |
| | | this.contractOrderService.updateByIdBuffer(order); |
| | |
| | | profit = point.multiply(new BigDecimal("0.01")).multiply(order.getVolumeOpen()).setScale(4, BigDecimal.ROUND_DOWN);; |
| | | System.out.println("------------------point-------------:"+point); |
| | | System.out.println("------------------profit------------:"+profit); |
| | | if (order.getLocationType() == 0) { |
| | | profit = order.getDepositOpen().add(order.getAddDepositOpen()).negate(); |
| | | System.out.println("------------------扣除保证金------------:"+profit); |
| | | profit = order.getDepositOpen().add(order.getAddDepositOpen()).negate(); |
| | | System.out.println("------------------扣除保证金------------:"+profit); |
| | | if (order.getLocationType() == 1) { |
| | | Wallet wallet = this.walletService.findByUserId(order.getPartyId()); |
| | | System.out.println("------------------扣除余额------------:"+wallet.getMoney()); |
| | | profit = profit.subtract(wallet.getMoney()); |
| | | } |
| | | if (ContractOrder.DIRECTION_BUY.equals(order.getDirection())) { |
| | | order.setProfit(profit); |