TickTrader/mdspiimp.cpp at main · dragon86cn/TickTrader · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
#include "mdspiimp.h"
#include "tradewidget.h"
#include <QDebug>

extern loginWin *loginW;
extern TradeWidget *g_tw;

extern quint32 CreateNewRequestID();

CMdSpiImp::CMdSpiImp(CThostFtdcMdApi* pMdApi)
    :m_pQuotApi(pMdApi)
{
    loginFlags = false;
}

CMdSpiImp::~CMdSpiImp()
{

}

void CMdSpiImp::OnFrontConnected()
{
    qInfo() << "CMdSpiImp::OnFrontConnected";
    if(!loginFlags)
    {
        CThostFtdcReqUserLoginField login = {0};
        strncpy( login.BrokerID, loginW->m_users.BrokerID, sizeof(login.BrokerID));
        strncpy( login.UserID, loginW->userName, sizeof(login.UserID));
        strncpy( login.Password, loginW->password, sizeof(login.Password));
        strcpy( login.UserProductInfo, "TICKTRADER" );
        strcpy( login.MacAddress, "fe80::75ef:97de:2366:e490" );
        strcpy( login.ClientIPAddress, "10.150.1.23" );

        quint32 nRequestID = CreateNewRequestID();
        int ret = m_pQuotApi->ReqUserLogin(&login, nRequestID);
        qInfo() << "ReqUserLogin ret: " << ret;
    }
}

void CMdSpiImp::OnFrontDisconnected(int nReason)
{

}

void CMdSpiImp::OnRspUserLogin(CThostFtdcRspUserLoginField *pRspUserLogin, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{
    if(pRspInfo && pRspInfo->ErrorID!=0){
        return;
    }
    if(!pRspUserLogin)
        return;
    loginFlags = true;
    // 遍历一次订阅列表
    int count = 1;
    char **InstrumentID = new char*[count];
    QMapIterator<QString, CThostFtdcInstrumentField *> s(g_tw->insMap_dy);
    while (s.hasNext())
    {
        QString key = s.next().key();
        CThostFtdcInstrumentField * si = g_tw->insMap_dy[key];
        if(!si)
            continue;
        InstrumentID[0] = si->InstrumentID;
        m_pQuotApi->SubscribeMarketData(InstrumentID, 1); // 订阅行情
    }
    delete[] InstrumentID;
}

void CMdSpiImp::OnRspUserLogout(CThostFtdcUserLogoutField *pUserLogout, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{

}

void CMdSpiImp::OnRspSubMarketData(CThostFtdcSpecificInstrumentField *pSpecificInstrument, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
{
}

//void CMdSpiImp::OnRspUnSubMarketData(CThostFtdcSpecificInstrumentField *pSpecificInstrument, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast)
//{

//}

void CMdSpiImp::OnRtnDepthMarketData(CThostFtdcDepthMarketDataField *pDepthMarketData)
{
    if(pDepthMarketData)
    {
        g_tw->priceEmit(pDepthMarketData);
    }
}