| | |
| | | */ |
| | | @Override |
| | | public PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx) { |
| | | log.info("网格初始化中"); |
| | | PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeListQueue.getQueueAsc(); |
| | | queueAsc.clear(); |
| | | |
| | |
| | | } |
| | | |
| | | if (queueAsc.isEmpty()) { |
| | | log.info("网格初始化失败"); |
| | | log.error("网格初始化失败"); |
| | | return null; |
| | | } |
| | | |
| | | log.info("网格初始化成功"); |
| | | return queueAsc; |
| | | } catch (NumberFormatException e) { |
| | | log.error("解析价格参数失败", e); |
| | |
| | | } |
| | | } |
| | | StringBuilder kaiCangStr = new StringBuilder(); |
| | | kaiCangStr.append("队列: ["); |
| | | kaiCangStr.append("初始化下限队列: ["); |
| | | boolean first = true; |
| | | for (DescBigDecimal item : queueKaiCang) { |
| | | if (!first) { |
| | |
| | | } |
| | | |
| | | StringBuilder pingCangStr = new StringBuilder(); |
| | | pingCangStr.append("平仓队列: ["); |
| | | pingCangStr.append("初始化上限队列: ["); |
| | | boolean first = true; |
| | | for (AscBigDecimal item : queuePingCang) { |
| | | if (!first) { |