通貨ペアの要求 < x > SecurityListRequest に対する返答 < y > SecurityList を受け取ります
返答には利用可能な 通貨ペア 情報がぎっしり？詰め込まれているので、１つ１つ取り出して、ＤＢへ保存しときます
ついでにレート情報の要求も投げ込めるようにしときましょう
レート情報を受け取った後の情報保持用に変数の初期化なんかもやっときます
メッセージ受信 < y > SecurityList
resp_y__SecurityList.cpp
#include "config.h"
#include "Application.h"
#include "quickfix/Session.h"
#include <iostream>
/* y */
void Application::onMessage(const FIX44::SecurityList& message, const FIX::SessionID& sessionID )
{
std::cout << "<y> SecurityList: " << std::endl << message.toXML() << std::endl;
/* Get Message Data */
/* 146 */ FIX::FieldBase symbolCount( FIX::FIELD::NoRelatedSym, "0" );
message.getFieldIfSet( symbolCount );
/* Check Counter - none return */
if(std::stoi(symbolCount.getString()) <= 0) return;
/* UPDATE ALL Status - flase */
FIX::MySQLQuery q( "UPDATE `T_SYMBOL` SET `Status` = 0 WHERE `Status` = 1;" );
m_sql->execute( q );
/* INIT rate vector */
rate.clear();
rate.shrink_to_fit();
rate.resize(std::stoi(symbolCount.getString()));
/* Loop: Currency Pair */
for( int i=1; i <= std::stoi(symbolCount.getString()); i++ )
{
/* 146 */ FIX44::SecurityList::NoRelatedSym r;
message.getGroup(i, r);
/* 55 */ FIX::FieldBase symbol( FIX::FIELD::Symbol, "NA");
r.getFieldIfSet( symbol );
/* SELECT SYMBOL */
bool getRate = false;
std::ostringstream s1;
s1 << "SELECT `Symbol`, `GetRate` FROM `T_SYMBOL` WHERE `Symbol` = '" << symbol << "'";
FIX::MySQLQuery q1( s1.str() );
m_sql->execute( q1 );
/* UPDATE Status - true */
if( q1.rows() != 0 )
{
std::ostringstream s2;
s2 << "UPDATE `T_SYMBOL`" <<
" SET `Status` = 0" <<
" WHERE `Symbol` = '" << symbol << "'";
FIX::MySQLQuery q2( s2.str() );
m_sql->execute( q2 );
/* Get Rate? */
if (std::string(q1.getValue(0,1)) == "1")
getRate = true;
}
/* INSERT SYMBOL Status - true */
else
{
std::ostringstream s3;
s3 << "INSERT INTO `T_SYMBOL` " <<
" ( `Symbol`, `Status` ) " <<
" VALUES ('" << symbol << "', 0 )";
FIX::MySQLQuery q3( s3.str() );
m_sql->execute( q3 );
}
/* Symbol : map - vector */
m_symbol[symbol.getString()] = (i - 1);
rate[ m_symbol[symbol.getString()] ].Symbol = symbol.getString();
rate[ m_symbol[symbol.getString()] ].feedStatus = false;
/* Get Market Data Rate */
if( getRate )
{
/* <V> */ MarketDataRequest(); // symbol.getString() );
}
}
/* End : Currency Pair */
}
ってな感じの処理になってます
T_SYMBOL テーブル
通貨ペアを保存するためのテーブルはこんな感じ
examples/tradeclient/sql/T_SYMBOL.sql
DROP TABLE IF EXISTS T_SYMBOL;
CREATE TABLE T_SYMBOL
(
`Symbol` VARCHAR(7) NOT NULL COMMENT '55 ',
`Status` CHAR(1) NOT NULL DEFAULT 0 COMMENT '---- 0:FALSE 1:TRUE ',
`GetRate` CHAR(1) NOT NULL DEFAULT 0 COMMENT '---- 0:None 1:GetRate ',
`Created_at` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
`Updated_at` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`Deleted_at` DATETIME NULL,
PRIMARY KEY (`Symbol`)
)
COMMENT 'Symbol List';
INSERT INTO `T_SYMBOL` (`Symbol`, `GetRate`) VALUES ('USD/JPY', '1');
INSERT INTO `T_SYMBOL` (`Symbol`, `GetRate`) VALUES ('EUR/JPY', '1');
INSERT INTO `T_SYMBOL` (`Symbol`, `GetRate`) VALUES ('EUR/USD', '1');
DESC T_SYMBOL;
Status が "0" ならCNEXの対象外通貨ペア
GetRate が "0" ならレート情報の受信は行わない
という感じ
とりあえず３ペアをレート情報受信対象としてレコード追加しときます。
・USD/JPY
・EUR/JPY
・EUR/USD
レート情報保存領域
構造体を定義しときます
Rate.h
typedef struct {
std::string Symbol;
double Bid;
long BidSize;
long BidOrder;
double Spred;
double Ask;
long AskSize;
long AskOrder;
double High;
double Low;
std::string Time;
bool feedStatus;
} Rate;
Application.h ヘッダーファイル
レート情報保存領域とかの準備を
Application.h
@@ -37,6 +37,8 @@
#include "resp_CG_PartyDetailsListReport.h" // resp < CG >
#include "resp_PU_OrderRateUpdate.h" // resp < PU >
+#include "Rate.h"
+
#include <queue>
#include <vector>
#include <map>
@@ -84,6 +86,9 @@ private:
std::string m_accountID;
std::string m_partyID;
+ std::map<std::string, int> m_symbol;
+ std::vector<Rate> rate;
+
void onCreate( const FIX::SessionID& ) {}
void onLogon( const FIX::SessionID& sessionID );
void onLogout( const FIX::SessionID& sessionID );
ヘッダーファイル Rate.h を読み込んで、保存領域を宣言
make 対象に追加
Makefile.am
@@ -4,6 +4,7 @@ tradeclient_SOURCES = \
tradeclient.cpp \
Application.h \
Application.cpp \
+ Rate.h \
resp_8__ExecutionReport.cpp \
resp_9__OrderCancelReject.cpp \
resp_AO_RequestForPositionsAck.cpp \
コンパイル
tradeclient]$ make clean
tradeclient]$ make
エラーなく終了すること
受信メッセージサンプル
8=FIX.4.4
9=939
35=y
49=CNX
34=3
52=20170412-15:39:30.879
56=Demo_Trd
320=SecListReq_20170412-153930.773
322=1
560=0
146=19
55=USD/JPY 870=2 871=18 872=2 871=16 872=2
55=AUD/CHF 870=2 871=18 872=4 871=16 872=4
55=USD/CHF 870=2 871=18 872=4 871=16 872=4
55=AUD/USD 870=2 871=18 872=4 871=16 872=4
55=EUR/CHF 870=2 871=18 872=4 871=16 872=4
55=EUR/AUD 870=2 871=18 872=4 871=16 872=4
55=EUR/GBP 870=2 871=18 872=4 871=16 872=4
55=EUR/JPY 870=2 871=18 872=2 871=16 872=2
55=EUR/USD 870=2 871=18 872=4 871=16 872=4
55=GBP/USD 870=2 871=18 872=4 871=16 872=4
55=ZAR/JPY 870=2 871=18 872=2 871=16 872=2
55=NZD/USD 870=2 871=18 872=4 871=16 872=4
55=GBP/CHF 870=2 871=18 872=4 871=16 872=4
55=CHF/JPY 870=2 871=18 872=2 871=16 872=2
55=CAD/CHF 870=2 871=18 872=4 871=16 872=4
55=GBP/JPY 870=2 871=18 872=2 871=16 872=2
55=AUD/JPY 870=2 871=18 872=2 871=16 872=2
55=CAD/JPY 870=2 871=18 872=2 871=16 872=2
55=NZD/JPY 870=2 871=18 872=2 871=16 872=2
10=156
こんな感じのメッセージを受け取るハズ
＜前 【QuickFIX】08 通貨ペア要求 SecurityListRequest
次＞ 【QuickFIX】10 デモ環境サーバへ接続
一覧
01 サンプルのコンパイル
02 ログイン時にPassword(554)を送信
03 送受信ログをMySQLに保存
04 情報保存用にMySQLコネクションを保持..他
05 各種メッセージの枠を作成
06 独自メッセージ仕様
07 セッション開始 TradingSessionStatus
08 通貨ペア要求 SecurityListRequest
09 通貨ペア取得 SecurityList
10 デモ環境サーバへ接続
11 ログ出力設定
12 マーケット情報要求 < V > MarketDataRequest
13 マーケット情報受信 < X > MarketDataIncrementalRefresh
14 口座情報要求 < AN > RequestForPositions
15 口座情報取得 < AZ > CollateralResponse