口座情報の取得を < AN > RequestForPositions で要求します
send_AN_RequestForPositions.cpp
#include "config.h"
#include "Application.h"
#include "quickfix/Session.h"
#include <iostream>
/* AN */
void Application::RequestForPositions(
/* 715 */ const std::string& clearingBusinessDate
, /* 724 */ const int reqType
)
{
FIX44::RequestForPositions message;
/* 710 */ message.set( FIX::PosReqID( "PosReq_" + YmdHMSs() ));
/* 263 */ message.set( FIX::SubscriptionRequestType(FIX::SubscriptionRequestType_SNAPSHOT_PLUS_UPDATES /* 1 */ ) );
/* 724 */ message.set( FIX::PosReqType( reqType )); /* 0 Position, 1 Trade */
/* 0=Position: < AP > Position Report
* 1=Trades: All Margin Info, including
* < AZ > Collateral Response,
* < AP > Position Report,
* < BA > Collateral Report,
* < CG > Party Details List
*
*/
/* 453 */ FIX44::RequestForPositions::NoPartyIDs parties;
/* 448 */ parties.set(FIX::PartyID( m_partyID ));
/* 452 */ parties.set(FIX::PartyRole( FIX::PartyRole_CLIENT_ID /* 3 */ ));
message.addGroup( parties );
/* 1 */ message.set( FIX::Account( m_accountID ));
/* 581 */ message.set( FIX::AccountType( FIX::AccountType_ACCOUNT_IS_CARRIED_ON_CUSTOMER_SIDE_OF_BOOKS /* 1 */ ));
/* 60 */ message.set( FIX::TransactTime() );
/* Clearing Business Date :: format YYYYMMDD-HH:mm:ss */
if ( clearingBusinessDate != "" )
{
LOG_DEBUG << "clearingBusinessDate: " << clearingBusinessDate;
/* 715 */ message.set( FIX::ClearingBusinessDate( clearingBusinessDate.substr(0,8) )); // + "-00:00:00"));
}
else
{
/* 715 */ message.set( FIX::ClearingBusinessDate( YmdHMS("%Y%m%d") ));
}
/* Insert T_BALANCE :: */
std::string s1 = "INSERT INTO `T_BALANCE` (`Account`) VALUES ('"+ m_accountID +"')";
FIX::MySQLQuery q1( s1 );
if( m_sql->execute( q1 ) != true )
{
LOG_WARNING << "INSERT ERROR T_BALANCE :" << q1.reason() << std::endl << s1;
}
else
{
LOG_VERBOSE << "INSERT T_BALANCE : " << q1.reason() << std::endl << s1;
}
/* send message */
SetMessageHeader( message );
FIX::Session::sendToTarget( message );
// std::cout << "<AN> RequestforPositions: " << std::endl << message.toXML() << std::endl;
LOG_DEBUG << "<AN> RequestforPositions: " << std::endl << message;
LOG_VERBOSE << "<AN> RequestforPositions: " << std::endl << message.toXML();
}
引数でいつからの情報を取得するのかという日付を受け取れるようにしときます。
あと、取得タイプ。
日付は１９日以内？しか指定できないようです
取得タイプ ０ は現在のポジション情報のみ
１ で口座情報もとれるので、デフォルトは１を指定しときます。
口座情報を受け取った後のDB格納用に基本情報を INSERT しておいてます
Application.h
引数情報を変更したので、ヘッダーも編集
あと、日付を取得する処理と残高をカンマ区切りで表示するための処理も追加したのでそこも変更
Application.h
・・・
/* AF */ void OrderMassStatusRequest();
/* AN */ void RequestForPositions(
const std::string& clearingBusinessDate = ""
, const int reqType = FIX::PosReqType_TRADES /* 0=Position 1=Trade */
);
・・・
std::string YmdHMS( const char* = "%Y%m%d-%H%M%S" );
std::string numFormat(const long);
Application.cpp
Application.cpp
・・・
std::string Application::YmdHMS( const char* format )
{
FIX::UtcTimeStamp time;
struct tm aa = time.getTmUtc();
char buf[ 100 ];
std::strftime(buf, sizeof(buf), format, &aa);
return buf;
}
std::string Application::numFormat( const long num )
{
std::vector<long> sepnum;
long number = abs(num);
long sgn = num >= 0 ? 1 : -1;
while ( number / 1000 ) {
sepnum.push_back(number % 1000);
number /= 1000;
}
std::stringstream ss;
ss << number * sgn;
for ( std::vector<long>::reverse_iterator i = sepnum.rbegin();
i < sepnum.rend(); i++ ) {
ss << "," << std::setfill('0') << std::setw(3) << *i;
}
return std::string(ss.str());
}
日付を取得する処理と残高をカンマ区切りで表示するための処理の実態を定義
ＤＢにテーブル追加
口座情報を保存するためのテーブルも作成
T_BALANCE
DROP TABLE IF EXISTS T_BALANCE;
CREATE TABLE T_BALANCE
(
`Account` VARCHAR(32) NOT NULL COMMENT '1 Account ID',
`TransactTime` CHAR(17) NULL COMMENT '60 yyyymmdd-hh:mm:ss',
`Currency` CHAR(3) NULL COMMENT '15 ',
`MarginRatio` REAL NULL COMMENT '898 Account equity ratio',
`StartCash` INT UNSIGNED NULL COMMENT '921 current trading day opening balance',
`EndCash` INT UNSIGNED NULL COMMENT '922 current balance max 40億',
`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 (`Account`)
)
COMMENT 'Balance';
DESC T_BALANCE;
口座情報の履歴も保存
T_BALANCE_HIST
DROP TABLE IF EXISTS T_BALANCE_HIST;
CREATE TABLE T_BALANCE_HIST
(
`id` INT UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 'id',
`Account` VARCHAR(32) NOT NULL COMMENT '1 Account ID',
`Result` CHAR(1) NOT NULL COMMENT '905 1:Accepted 3:Reject',
`TransactTime` CHAR(17) NOT NULL COMMENT '60 yyyymmdd-hh:mm:ss',
`TransactDay` CHAR(8) NOT NULL COMMENT '60 yyyymmdd',
`FinansialStatus` CHAR(1) NOT NULL COMMENT '291 1=Disabled 3:Active',
`Currency` CHAR(3) NULL COMMENT '15 ',
`MarginRatio` REAL NULL COMMENT '898 Account equity ratio',
`StartCash` INT UNSIGNED NULL COMMENT '921 current trading day opening balance',
`EndCash` INT UNSIGNED NULL COMMENT '922 current balance max 40億',
`Created_at` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
INDEX `I_BALANCE_HIST_Day` (`TransactDay`)
)
COMMENT 'Balance History';
DESC T_BALANCE_HIST;
＜前 【QuickFIX】13 マーケット情報受信 < X > MarketDataIncrementalRefresh
次＞ 【QuickFIX】15 口座情報取得 < AZ > CollateralResponse
一覧
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