基于CTP的国内期货程序化交易之报单流程讲解

2024-08-28 14:08

本文主要是介绍基于CTP的国内期货程序化交易之报单流程讲解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

       相比国外期货交易开发,国内期货交易开发就有些繁琐了,坑比较多。第一就是交易时间段多,像国外期货美原油,全天23小时连续交易,而国内期货沪金,全天分四个时间段交易,分别为9:00至10:15、10:30至11:30、13:30至15:00及21:00至次日02:30。交易时间段多,平仓时间段也多,这样无形中就增加了很多业务逻辑。另外,就是交易规则多,上期所的期货品种平仓时又分平今和平仓,这样平仓报单时就要根据成交时间分别判断,是前一个交易日的单子还是当前交易日的单子,否则报单参数不正确,单子将直接被交易系统拒绝。开发过程中主要用到的头文件为:ThostFtdcTraderApi.h、ThostFtdcUserApiDataType.h及ThostFtdcUserApiStruct.h,动态库为:libthosttraderapi.so。下面是一些代码示例:
       1. 创建CTP api实例:
CThostFtdcTraderApi *pTradeApi = CThostFtdcTraderApi::CreateFtdcTraderApi(dirName);
       通过调用CreateFtdcTraderApi()创建api实例——pTradeApi,随后调用该实例发起各种请求,比如连接服务器、用户登录、报单、撤单、查询持仓、查询资金等等。
       2. 创建CTP api回调实例:
CFtdcTradeSpi *pTradeSpi = new CFtdcTradeSpi(pTradeApi, this);
       这个需要自己编写相应实现类,需要继承上期技术提供的CThostFtdcTraderSpi类。重写该类里面的方法,以处理服务器发过来的各类数据。
       3. 将上述两个实例关联起来,并发起连接服务器请求:
pTradeApi->RegisterSpi(pTradeSpi);
pTradeSpi->connect(serverAddr, brokerId, username, password);
       连接服务器以及实例初始化相关代码:
void CFtdcTradeSpi::connect(string serverAddr, string brokerId, string username, string password)
{serverAddr_ = serverAddr;brokerId_ = brokerId;username_ = username;password_ = password;pTradeApi_->SubscribePublicTopic(THOST_TERT_QUICK);pTradeApi_->SubscribePrivateTopic(THOST_TERT_QUICK);pTradeApi_->RegisterFront((char *)serverAddr_.c_str());pTradeApi_->Init();
}
       连接请求发出后,OnFrontConnected()会响应请求,然后在该函数内可以调用登录函数pTradeApi_->ReqUserLogin()完成用户登录操作,相应的OnRspUserLogin()会响应请求。由于国内期货在交易日内首次登录时需要做投资者结算结果确认操作,所以在OnRspUserLogin()函数内,可以进一步调用pTradeApi_->ReqSettlementInfoConfirm()做投资者结算结果确认,确认结果将在OnRspSettlementInfoConfirm()内返回。做完投资者结算结果确认操作,整个服务器连接与用户登录过程就完成了,可以正常下单交易了。
void CFtdcTradeSpi::OnFrontConnected()
{LOG_INFO << username_ << " 回调: 与服务器已建立连接, 开始登录";
}void CFtdcTradeSpi::OnRspUserLogin(CThostFtdcRspUserLoginField *pRspUserLogin, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{if (pRspUserLogin == NULL || pRspInfo == NULL){LOG_INFO << username_ << " 登录回调异常, 指针为空";return;}if (pRspInfo->ErrorID == Err_Succeed){LOG_INFO << username_ <<  " 登录成功, 开始投资者结算结果确认, 当前交易日: " << pTradeApi_->GetTradingDay();}
}void CFtdcTradeSpi::OnRspSettlementInfoConfirm(CThostFtdcSettlementInfoConfirmField *pSettlementInfoConfirm, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{if (pSettlementInfoConfirm == NULL || pRspInfo == NULL){LOG_INFO << username_ << " 投资者结算结果确认回调异常, 指针为空";return;}string errorMsg;getErrcodeDesc(pRspInfo->ErrorMsg, errorMsg);LOG_INFO << username_ << " "<< "经纪公司代码: " << pSettlementInfoConfirm->BrokerID << " "<< "投资者代码: " << pSettlementInfoConfirm->InvestorID << " "<< "确认日期: " << pSettlementInfoConfirm->ConfirmDate << " "<< "确认时间: " << pSettlementInfoConfirm->ConfirmTime << " "<< "回调: 错误信息, 错误码: " << pRspInfo->ErrorID << " " << errorMsg;
}
       4. 期货报单:
       (1)ReqOrderInsert():报单请求
CThostFtdcInputOrderField reqField;
memset(&reqField, 0, sizeof(CThostFtdcInputOrderField));
......
......
pTradeApi_->ReqOrderInsert(&reqField, orderInsertReqId_);
       与前文所讲解基本一致,大同小异。 需要正确填写买卖/方向、开仓/平仓、市价/限价、委托数量、委托价格等等,填写完毕就可以调用ReqOrderInsert()报单了。
       (2)OnRspOrderInsert():报单请求应答
void CFtdcTradeSpi::OnRspOrderInsert(CThostFtdcInputOrderField *pInputOrder, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{
}
       报单成功后,理论上该函数就会被回调。但通过查阅日志来看,可能上期技术为了简化逻辑,弱化了该函数,实际上该函数并没有被回调,当然,这也可能与所使用的sdk版本有关系。
       (3)OnRtnOrder():委托变化通知
void CFtdcTradeSpi::OnRtnOrder(CThostFtdcOrderField *pOrder)
{
}
       当委托状态发生变化时,会被回调。一般常见的委托状态主要有:未知、未成交还在队列中、部分成交还在队列中、完全成交等。一次报单,如果数量比较多,一般不会一次全部成交,而是会分多批次成交,所以该函数会不断被回调。随着不断回调,每次返回的委托量、成交量、剩余量等数据会不断变更。
       (4)OnRtnMatchInfo():成交信息变化推送通知
void CFtdcTradeSpi::OnRtnTrade(CThostFtdcTradeField *pTrade)
{
}
       该函数比较重要,返回的每一条信息都是成交信息,里面包含成交量、成交价、成交费用等等,这些都是投资者关心的数据。总体来说,整个报单过程与前文讲解的国外期货报单流程基本一致。不过有一点简化了,那就是不需要编写报单流控逻辑,因为CTP没有报单频率限制,但是有查询频率限制,这一点刚好和易盛的交易api相反,易盛是查询没频率限制,报单有频率限制。
       5.  查询期货账号持仓:
       查询持仓主要调用pTradeApi_->ReqQryInvestorPosition(),按照文档说明填写合适的参数即可。查询持仓响应函数为:
void CFtdcTradeSpi::OnRspQryInvestorPosition(CThostFtdcInvestorPositionField *pInvestorPosition, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{
}
       该函数需要由开发者自己重写,比较麻烦的是持仓数据不会一次全部返回,而是一批一批返回,需要自己按照多空方向分别做汇总计算才行。
       编写完代码,如何测试程序呢?貌似上期技术没有提供测试账号,不过可以到SimNow网站(http://www.simnow.com.cn/)注册交易测试账号,不知道SimNow和上期技术啥关系。注册成功后账号内既有100万,这样就可以测试开仓及平仓了。



这篇关于基于CTP的国内期货程序化交易之报单流程讲解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1114978

相关文章

redis-sentinel基础概念及部署流程

《redis-sentinel基础概念及部署流程》RedisSentinel是Redis的高可用解决方案,通过监控主从节点、自动故障转移、通知机制及配置提供,实现集群故障恢复与服务持续可用,核心组件包... 目录一. 引言二. 核心功能三. 核心组件四. 故障转移流程五. 服务部署六. sentinel部署

SpringBoot集成XXL-JOB实现任务管理全流程

《SpringBoot集成XXL-JOB实现任务管理全流程》XXL-JOB是一款轻量级分布式任务调度平台,功能丰富、界面简洁、易于扩展,本文介绍如何通过SpringBoot项目,使用RestTempl... 目录一、前言二、项目结构简述三、Maven 依赖四、Controller 代码详解五、Service

Unity新手入门学习殿堂级知识详细讲解(图文)

《Unity新手入门学习殿堂级知识详细讲解(图文)》Unity是一款跨平台游戏引擎,支持2D/3D及VR/AR开发,核心功能模块包括图形、音频、物理等,通过可视化编辑器与脚本扩展实现开发,项目结构含A... 目录入门概述什么是 UnityUnity引擎基础认知编辑器核心操作Unity 编辑器项目模式分类工程

MySQL 临时表与复制表操作全流程案例

《MySQL临时表与复制表操作全流程案例》本文介绍MySQL临时表与复制表的区别与使用,涵盖生命周期、存储机制、操作限制、创建方法及常见问题,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随小... 目录一、mysql 临时表(一)核心特性拓展(二)操作全流程案例1. 复杂查询中的临时表应用2. 临时

Conda国内镜像源及配置过程

《Conda国内镜像源及配置过程》文章介绍Conda镜像源使用方法,涵盖临时指定单个/多个源、永久配置及恢复默认设置,同时说明main(官方稳定)、free(逐渐弃用)、conda-forge(社区更... 目录一、Conda国内镜像源二、Conda临时使用镜像源指定单个源临时指定多个源创建环境时临时指定源

MySQL 升级到8.4版本的完整流程及操作方法

《MySQL升级到8.4版本的完整流程及操作方法》本文详细说明了MySQL升级至8.4的完整流程,涵盖升级前准备(备份、兼容性检查)、支持路径(原地、逻辑导出、复制)、关键变更(空间索引、保留关键字... 目录一、升级前准备 (3.1 Before You Begin)二、升级路径 (3.2 Upgrade

MySQL连表查询之笛卡尔积查询的详细过程讲解

《MySQL连表查询之笛卡尔积查询的详细过程讲解》在使用MySQL或任何关系型数据库进行多表查询时,如果连接条件设置不当,就可能发生所谓的笛卡尔积现象,:本文主要介绍MySQL连表查询之笛卡尔积查... 目录一、笛卡尔积的数学本质二、mysql中的实现机制1. 显式语法2. 隐式语法3. 执行原理(以Nes

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释:举个例子:✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多

Spring Boot 中的默认异常处理机制及执行流程

《SpringBoot中的默认异常处理机制及执行流程》SpringBoot内置BasicErrorController,自动处理异常并生成HTML/JSON响应,支持自定义错误路径、配置及扩展,如... 目录Spring Boot 异常处理机制详解默认错误页面功能自动异常转换机制错误属性配置选项默认错误处理