| | |
| | | return null; |
| | | } |
| | | if (CoinEnums.POSSIDE_LONG.getCode().equals(posSide)){ |
| | | return caoZuoLong(accountName); |
| | | return caoZuoLong(accountName,markPx); |
| | | }else if (CoinEnums.POSSIDE_SHORT.getCode().equals(posSide)){ |
| | | return caoZuoShort(accountName); |
| | | return caoZuoShort(accountName,markPx); |
| | | }else{ |
| | | log.error("账户未设置持仓方向......"); |
| | | return null; |
| | |
| | | } |
| | | |
| | | @Override |
| | | public String caoZuoLong(String accountName) { |
| | | public String caoZuoLong(String accountName,String markPxStr) { |
| | | log.info("开始看涨执行操作CaoZuoServiceImpl......"); |
| | | try { |
| | | |
| | | String positionAccountName = PositionsWs.initAccountName(accountName, CoinEnums.POSSIDE_LONG.getCode()); |
| | | // 获取标记价格和平均持仓价格 |
| | | BigDecimal markPx = PositionsWs.getAccountMap(positionAccountName).get("markPx"); |
| | | // BigDecimal markPx = PositionsWs.getAccountMap(positionAccountName).get("markPx"); |
| | | BigDecimal markPx = new BigDecimal(markPxStr); |
| | | BigDecimal avgPx = PositionsWs.getAccountMap(positionAccountName).get("avgPx"); |
| | | log.info("开仓价格: {}, 当前价格:{},匹配队列中......", avgPx, markPx); |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public String caoZuoShort(String accountName) { |
| | | public String caoZuoShort(String accountName,String markPxStr) { |
| | | log.info("开始看空执行操作CaoZuoServiceImpl......"); |
| | | try { |
| | | |
| | | |
| | | String positionAccountName = PositionsWs.initAccountName(accountName, CoinEnums.POSSIDE_SHORT.getCode()); |
| | | // 获取标记价格和平均持仓价格 |
| | | BigDecimal markPx = PositionsWs.getAccountMap(positionAccountName).get("markPx"); |
| | | // BigDecimal markPx = PositionsWs.getAccountMap(positionAccountName).get("markPx"); |
| | | BigDecimal markPx = new BigDecimal(markPxStr); |
| | | BigDecimal avgPx = PositionsWs.getAccountMap(positionAccountName).get("avgPx"); |
| | | log.info("开仓价格: {}, 当前价格:{},匹配队列中......", avgPx, markPx); |
| | | |