package com.xcong.excoin.modules.okxNewPrice.okxWs.wanggeList;

import com.xcong.excoin.rabbit.pricequeue.AscBigDecimal;
import com.xcong.excoin.rabbit.pricequeue.DescBigDecimal;

import java.math.BigDecimal;
import java.util.concurrent.PriorityBlockingQueue;

/**
 * 网格交易服务接口
 * 定义了网格交易的核心操作方法，包括初始化网格、开仓和平仓等操作
 * @author Administrator
 */
public interface WangGeListService {

    /**
     * 初始化网格交易
     * 创建并初始化用于网格交易的价格队列，按照价格升序排列
     * @return 初始化结果信息，返回按价格升序排列的阻塞队列
     */
    PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx);

    /**
     * 初始化开仓操作
     * 根据指定价格初始化开仓队列，将开仓价格点加入到价格队列中
     * @param jiaGe 开仓价格
     * @param queueAsc 价格队列，用于存储按升序排列的价格点
     */
    PriorityBlockingQueue<DescBigDecimal> initKaiCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc);

    /**
     * 初始化平仓操作
     * 根据指定价格初始化平仓队列，将平仓价格点加入到价格队列中
     * @param jiaGe 开仓价格
     * @param queueAsc 价格队列，用于存储按升序排列的价格点
     */
    PriorityBlockingQueue<AscBigDecimal> initPingCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc);


}