feat(coin): 添加ASTER币种支持

Administrator

5 days ago cd8ac9145c420fa25e113468360e37130fff0394

 src/main/java/com/xcong/excoin/rabbit/pricequeue/PricePriorityQueue.java

@@ -136,6 +136,48 @@

    private static Map<String, List<OrderModel>> SOL_MAP_ASC = null;

    /**
     * ETC 倒序队列 头元素最大 开多止盈 开空止损 开空爆仓 限价开空
     */
    private static PriorityBlockingQueue<DescBigDecimal> DOGE_QUEUE_DESC = null;

    private static Map<String, List<OrderModel>> DOGE_MAP_DESC = null;

    /**
     * ETC 正序队列 头元素最小 开多止损 开空止盈 开多爆仓 限价开多
     */
    private static PriorityBlockingQueue<AscBigDecimal> DOGE_QUEUE_ASC = null;

    private static Map<String, List<OrderModel>> DOGE_MAP_ASC = null;

    /**
     * ETC 倒序队列 头元素最大 开多止盈 开空止损 开空爆仓 限价开空
     */
    private static PriorityBlockingQueue<DescBigDecimal> SUI_QUEUE_DESC = null;

    private static Map<String, List<OrderModel>> SUI_MAP_DESC = null;

    /**
     * ETC 正序队列 头元素最小 开多止损 开空止盈 开多爆仓 限价开多
     */
    private static PriorityBlockingQueue<AscBigDecimal> SUI_QUEUE_ASC = null;

    private static Map<String, List<OrderModel>> SUI_MAP_ASC = null;

    /**
     * ETC 倒序队列 头元素最大 开多止盈 开空止损 开空爆仓 限价开空
     */
    private static PriorityBlockingQueue<DescBigDecimal> ASTER_QUEUE_DESC = null;

    private static Map<String, List<OrderModel>> ASTER_MAP_DESC = null;

    /**
     * ETC 正序队列 头元素最小 开多止损 开空止盈 开多爆仓 限价开多
     */
    private static PriorityBlockingQueue<AscBigDecimal> ASTER_QUEUE_ASC = null;

    private static Map<String, List<OrderModel>> ASTER_MAP_ASC = null;


    // 收到消息队列的方法 即收取到新的止盈止损等
    // 【1：买入委托2：开多3:开空4：平多5：平空6:爆仓平多7:爆仓平空8:撤单9:止盈平多10：止盈平空11：止损平多12：止损平空】
@@ -187,6 +229,21 @@
                        SOL_QUEUE_ASC = new PriorityBlockingQueue<AscBigDecimal>();
                    }
                    return SOL_QUEUE_ASC;
            case "DOGE/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (DOGE_QUEUE_ASC == null) {
                        DOGE_QUEUE_ASC = new PriorityBlockingQueue<AscBigDecimal>();
                    }
                    return DOGE_QUEUE_ASC;
            case "SUI/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (SUI_QUEUE_ASC == null) {
                        SUI_QUEUE_ASC = new PriorityBlockingQueue<AscBigDecimal>();
                    }
                    return SUI_QUEUE_ASC;
            case "ASTER/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (ASTER_QUEUE_ASC == null) {
                        ASTER_QUEUE_ASC = new PriorityBlockingQueue<AscBigDecimal>();
                    }
                    return ASTER_QUEUE_ASC;
            default:
                break;
        }
@@ -241,6 +298,21 @@
                        SOL_QUEUE_DESC = new PriorityBlockingQueue<DescBigDecimal>();
                    }
                    return SOL_QUEUE_DESC;
            case "DOGE/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (DOGE_QUEUE_DESC == null) {
                        DOGE_QUEUE_DESC = new PriorityBlockingQueue<DescBigDecimal>();
                    }
                    return DOGE_QUEUE_DESC;
            case "SUI/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (SUI_QUEUE_DESC == null) {
                        SUI_QUEUE_DESC = new PriorityBlockingQueue<DescBigDecimal>();
                    }
                    return SUI_QUEUE_DESC;
            case "ASTER/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                    if (ASTER_QUEUE_DESC == null) {
                        ASTER_QUEUE_DESC = new PriorityBlockingQueue<DescBigDecimal>();
                    }
                    return ASTER_QUEUE_DESC;
            default:
                break;
        }
@@ -363,6 +435,42 @@
                    }
                    return SOL_MAP_DESC;
                }
            case "DOGE/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                if (type == 12 || type == 9 || type == 7 || type == 3 || type == 4) {
                    if (DOGE_MAP_ASC == null) {
                        DOGE_MAP_ASC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return DOGE_MAP_ASC;
                } else {
                    if (DOGE_MAP_DESC == null) {
                        DOGE_MAP_DESC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return DOGE_MAP_DESC;
                }
            case "SUI/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                if (type == 12 || type == 9 || type == 7 || type == 3 || type == 4) {
                    if (SUI_MAP_ASC == null) {
                        SUI_MAP_ASC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return SUI_MAP_ASC;
                } else {
                    if (SUI_MAP_DESC == null) {
                        SUI_MAP_DESC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return SUI_MAP_DESC;
                }
            case "ASTER/USDT": // 开多止损 开空止盈 开多爆仓 限价开多
                if (type == 12 || type == 9 || type == 7 || type == 3 || type == 4) {
                    if (ASTER_MAP_ASC == null) {
                        ASTER_MAP_ASC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return ASTER_MAP_ASC;
                } else {
                    if (ASTER_MAP_DESC == null) {
                        ASTER_MAP_DESC = new ConcurrentHashMap<String,List<OrderModel>>();
                    }
                    return ASTER_MAP_DESC;
                }
            default:
                break;
        }