extend_spi.cpp

#include "include/common.h"
using namespace std;
//common buffer
char common_buffer[1000];
extern InitWindow* init_window;
extend_spi::extend_spi(CThostFtdcTraderApi* api){
	setTapi(api);
}

//前端链接函数
void extend_spi::OnFrontConnected(){
	log_info("trader front connectted,now authenticating ...");
	system_status::is_trader_connected=true;
}
//认证结果回调函数
void extend_spi::OnRspAuthenticate(CThostFtdcRspAuthenticateField *rsp_auth_field, CThostFtdcRspInfoField *error_info, int nRequestID, bool bIsLast) {
	#ifdef DEBUG
	log_info("Authenticate Response:");
	log_str("BrokerID:",rsp_auth_field->BrokerID);
	log_str("UserID:",rsp_auth_field->UserID);
	log_str("AppID:",rsp_auth_field->AppID);

	log_str("AppType:");log_str(rsp_auth_field->AppType);
	log_str("ErrorID");log_str(error_info->ErrorID);
	log_str("ErrorMsg",error_info->ErrorMsg);	
	#endif
	if(!error_info->ErrorID){
		system_status::is_authen_success=true;
		log_info("Authentication Success.");
		log_info("Now Signing in...");
	}
}
//登录结果函数
void extend_spi::OnRspUserLogin(CThostFtdcRspUserLoginField *rsp_login_field, CThostFtdcRspInfoField *error_info, int nRequestID, bool bIsLast){
	#ifdef DEBUG
	log_info("Login Response:");
	log_str("Trading Day:",rsp_login_field->TradingDay);
	log_str("SessionID:");log_str(rsp_login_field->SessionID);
	log_str("ErrorID");log_str(error_info->ErrorID);
    GbkToUtf8(error_info->ErrorMsg,strlen(error_info->ErrorMsg),common_buffer,sizeof(common_buffer));
    log_str("ErrorMsg",common_buffer);
	#endif
    system_status::is_trader_logined=true;
	if(!error_info->ErrorID){
        system_status::is_login_success=true;
        log_info("====Trader Login Success====");
		CThostFtdcQrySettlementInfoField settle_info_field;
		strcpy(settle_info_field.BrokerID,"9999");
		strcpy(settle_info_field.InvestorID,"177050");
		strcpy(settle_info_field.TradingDay,rsp_login_field->TradingDay);
		this->getTapi()->ReqQrySettlementInfo(&settle_info_field,0);
	}
    else{
        system_status::is_login_success=false;
        log_str("error id:",int2c(error_info->ErrorID));
        char dst[10000];
        GbkToUtf8(error_info->ErrorMsg,strlen(error_info->ErrorMsg),dst,10000);
        log_info(dst);
    }
}
void extend_spi::OnRspQrySettlementInfo(CThostFtdcSettlementInfoField *pSettlementInfo, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast){
	log_info("OnRspQrySettlementInfo");
	if(pSettlementInfo!=NULL){
		log_str("content:");
		char dst[10000];
		GbkToUtf8(pSettlementInfo->Content,strlen(pSettlementInfo->Content),dst,10000);
		log_info(dst);
	}
	else log_str("content null");
    system_status::is_settlement=true;

	//Send settlement confirm info
	CThostFtdcSettlementInfoConfirmField settle_confirm_field;
	strcpy(settle_confirm_field.BrokerID,"9999");
	strcpy(settle_confirm_field.InvestorID,"177050");
	this->getTapi()->ReqSettlementInfoConfirm(&settle_confirm_field,0);

}
void extend_spi::OnRspSettlementInfoConfirm(CThostFtdcSettlementInfoConfirmField *pSettlementInfoConfirm, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast){
	log_info("OnRspQrySettlementInfoConfirm");
	if(!pRspInfo->ErrorID) log_str("Confirm success");
	else log_error("Error message:",pRspInfo->ErrorMsg);
    system_status::is_confrim=true;
}

void extend_spi::OnRtnOrder(CThostFtdcOrderField *pOrder){
    log_info("On Rtn Order:");
	cout<<"Order status:";log_str(pOrder->OrderStatus);
    char dst[10000];
    GbkToUtf8(pOrder->StatusMsg,strlen(pOrder->StatusMsg),dst,10000);
    log_info(dst);
    cout<<"requet id:"<<pOrder->RequestID<<endl;

    unsigned int request_id;
    sscanf(pOrder->OrderRef,"%d",&request_id);
    init_window->setorderstatus_request(QString::number(request_id),QString::fromStdString(dst));

}
void extend_spi::OnRspOrderInsert(CThostFtdcInputOrderField *pInputOrder, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast){

    log_error("On Rsp Order Insert");
	printf("ErrorID:%d",pRspInfo->ErrorID);
	if(!pRspInfo->ErrorID) log_info("Insert request send success");
    else {
        char dst[10000];
        GbkToUtf8(pRspInfo->ErrorMsg,strlen(pRspInfo->ErrorMsg),dst,10000);
        log_info(dst);
    }
}
void extend_spi::OnRtnTrade(CThostFtdcTradeField* f){
    log_info("Rtn Trade");
}
void extend_spi::OnErrRtnOrderInsert(CThostFtdcInputOrderField *f,CThostFtdcRspInfoField *c){
    log_info("OnErrorRtnOrderInsert");
}
void extend_spi::OnRspParkedOrderInsert(CThostFtdcParkedOrderField *pParkedOrder, CThostFtdcRspInfoField *pRspInfo, int nRequestID, bool bIsLast){
	ofstream fout("output.txt");
	log_info("OnRspParkedOrderInsert function");
	printf("ErrorID:%d",pRspInfo->ErrorID);
	if(!pRspInfo->ErrorID) log_info("Insert request send success");
	else log_info("Error Msg:",pRspInfo->ErrorMsg);
	fout<<(pRspInfo->ErrorMsg);
}