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);
|
|
|
}
|
