이번 포스팅은 단일 데이터 조회에 이어 xingAPI의 [반복 데이터 조회]에 대해 포스팅 해본다.
단일 데이터 조회처럼 C#으로 코드를 짤 것이며, xingAPI COM 개발 가이드에는 엑셀 VBA를 이용한 프로그램의 코드가 소개되어 있다.
이름에서 알 수 있듯이 반복적으로 구성되어 있는 데이터를 가져올때 사용하는 TR이다.
자동매매 프로그램에 어떤 기능을 넣느냐에 따라 다르겠지만, 이 TR이 많이 필요해 보이진 않는다.
나는 계좌에 매수되어있는 종목들의 정보를 가져오는데에 사용하겠다.
사실은 본인이 사용하고 싶다고 하더라도 xingAPI에서 해당 기능을 제고하는 TR에 대해서만 사용 가능하다.
먼저 원하는 기능에 맞는 TR을 찾아보자.
적절한 TR을 찾기 위해 DevCenter에 접속한 후 각 TR들을 눌러보면 뒤에 'OCCURS'라고 붙는 TR들이 존재한다. 이 TR들은 반복(OCCUR) 데이터 요청이 가능하다는 얘기다.
이 TR을 사용해서 내 계좌에 매수되어 있는 종목들의 정보를 한번에 받아와 보자.
데이터를 수신하는 방법만 다를 뿐 단일데이터 조회 방식과 같다.
반복데이터 조회는 XAQuery 객체를 사용.
- XAQuery 선언
- XAQuery 생성
- RES 등록
- 입력데이터 설정
- 입력데이터를 서버로 전송하기
- 서버로부터 데이터 받기
프로그램은 이전 포스팅에 사용한 프로그램에 기능을 추가해 구현해 본다.
이제 구현 후 테스트 해보자.
종목이 여러개 있어야하므로 모의투자로 접속해서 테스트 해보자.
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using XA_SESSIONLib;
using XA_DATASETLib;
namespace xingAPI_Test
{
public partial class xingAPI_Test : Form
{
// Global 변수
bool gIsConnHTS = false;
string gAccount = string.Empty;
// xingAPI Session 클래스 선언
XASessionClass myXASessionClass;
// xingAPI TR 클래스 선언
XAQueryClass CSPAQ12200; // 자산현황 조회
XAQueryClass t0424Occurs; // 잔고조회 - 종목리스트
public xingAPI_Test()
{
InitializeComponent();
// xingAPI Session 객체 생성
myXASessionClass = new XASessionClass();
}
// Form Load될 때 초기화
private void xingAPI_Test_Load(object sender, EventArgs e)
{
Realtime_Log.Items.Add("====== xingAPI Test 프로그램 시작 ======");
// HTS 로그인 핸들러 등록
myXASessionClass._IXASessionEvents_Event_Login += new XA_SESSIONLib._IXASessionEvents_LoginEventHandler(myXASessionClass_Login);
// xingAPI TR 이벤트 등록
CSPAQ12200 = new XAQueryClass();
CSPAQ12200.ResFileName = @"C:\eBEST\xingAPI\Res\CSPAQ12200.res"; // xingAPI 서버로부터 수신한 응답 메시지를 COM 버전의 API에서 사용할 수 있도록 Format을 맞춰주는 파일
CSPAQ12200.ReceiveData += CSPAQ12200ReceiveData; // xingAPI 서버로부터 CSPAQ12200의 응답 메시지를 수신할 함수 등록
// xingAPI 반복 데이터 조회 TR 이벤트 등록
t0424Occurs = new XAQueryClass();
t0424Occurs.ResFileName = @"C:\eBEST\xingAPI\Res\t0424.res";
t0424Occurs.ReceiveData += t0424ReceiveData;
}
// HTS 서버 접속
private void Btn_Conn_Server_Click(object sender, EventArgs e)
{
string serverType = "demo.ebestsec.co.kr";
gIsConnHTS = myXASessionClass.ConnectServer(serverType, 20001); // 20001은 HTS 서버 고정 Port 값
if (gIsConnHTS == true)
{
Realtime_Log.Items.Add("이베스트 모의투자 서버 접속 완료");
}
else // 연결 실패했을 경우
{
int ErrCode = myXASessionClass.GetLastError();
var ErrMsg = myXASessionClass.GetErrorMessage(ErrCode);
string err_log = String.Format("[서버연결] ERR - {0}({1})", ErrMsg, ErrCode);
}
}
// HTS 서버 로그인
private void Btn_Login_Click(object sender, EventArgs e)
{
if (gIsConnHTS == true) // HTS 서버 로그인은 서버 접속이 완료된 이후에만 가능.
{
bool reqLogin = ((XA_SESSIONLib.IXASession)myXASessionClass).Login(TB_User_ID.Text, TB_User_Passwd.Text,
"", 0, false); // 세번째 인자는 공인인증비번을 입력하는 칸이지만 보안을 위해 입력 받지 않고 보안 프로그램에서 입력하는 것이 좋다.
// reqLogin의 결과 값은 로그인 완료 여부가 아닌, 서버에 로그인 요청을 전송 완료 여부이다. 때문에 Login Handler 함수를
// 별도 추가하여 요청한 로그인 정보가 정상적으로 성공했는지 확인해야한다.
if (reqLogin == true)
{
Realtime_Log.Items.Add("HTS 로그인 요청 완료");
}
else
{
Realtime_Log.Items.Add("HTS 로그인 요청 실패");
int ErrCode = myXASessionClass.GetLastError();
var ErrMsg = myXASessionClass.GetErrorMessage(ErrCode);
string err_log = String.Format("[로그인] ERR - {0}({1})", ErrMsg, ErrCode);
}
}
}
// HTS 서버 로그인 결과
void myXASessionClass_Login(string code, string msg)
{
if (code == "0000") // code 0000은 성공을 의미
{
Realtime_Log.Items.Add("HTS 로그인 완료");
// 보유 계좌 정보 Loading
int AccountCount = myXASessionClass.GetAccountListCount();
for (int i = 0; i < AccountCount; i++)
{
string AccountNo = string.Empty;
string AccountName = string.Empty;
string AccountDetailName = string.Empty;
string AccountNickName = string.Empty;
string AccountFinal = string.Empty;
AccountNo = myXASessionClass.GetAccountList(i);
AccountName = myXASessionClass.GetAccountName(AccountNo);
AccountDetailName = myXASessionClass.GetAcctDetailName(AccountNo);
AccountNickName = myXASessionClass.GetAcctDetailName(AccountNo);
AccountFinal = AccountNo + "(" + AccountName + ")";
Realtime_Log.Items.Add(AccountFinal);
CB_Account_List.Items.Add(AccountNo);
}
Realtime_Log.Items.Add("보유 계좌 정보 Loading 완료");
}
}
// 보유 계좌 선택
private void Btn_Input_Account_Click(object sender, EventArgs e)
{
if (CB_Account_List.Text != "")
{
gAccount = CB_Account_List.Text;
string str_log = String.Format("[보유계좌선택] {0} 선택완료.", gAccount);
Realtime_Log.Items.Add(str_log);
}
}
// 자산현황 조회 [단일데이터]
private void Btn_Get_Balance_Click(object sender, EventArgs e)
{
// CSPAQ12200 TR의 InBlock 데이터 세팅
CSPAQ12200.SetFieldData("CSPAQ12200InBlock1", "RecCnt", 0, "00001");
CSPAQ12200.SetFieldData("CSPAQ12200InBlock1", "MgmtBrnNo", 0, " ");
CSPAQ12200.SetFieldData("CSPAQ12200InBlock1", "AcntNo", 0, gAccount);
CSPAQ12200.SetFieldData("CSPAQ12200InBlock1", "Pwd", 0, "실제계좌비번");
CSPAQ12200.SetFieldData("CSPAQ12200InBlock1", "BalCreTp", 0, "0");
// TR 요청
var result = CSPAQ12200.Request(false);
if (result > 0)
MessageBox.Show("CSPAQ12200 요청 완료");
else
MessageBox.Show("CSPAQ12200 요청 실패");
}
private void CSPAQ12200ReceiveData(string trCode)
{
// 요청한 CSPAQ12200 TR에 대한 응답 메시지 수신
// CSPAQ12200 TR의 OutBlock2에서 필요한 데이터 추출
// 1. 예탁자산 총액
var temp_value = CSPAQ12200.GetFieldData("CSPAQ12200OutBlock2", "DpsastTotamt", 0);
decimal estimated_assets = Convert.ToDecimal(temp_value);
// 2. D+1 예수금
temp_value = CSPAQ12200.GetFieldData("CSPAQ12200OutBlock2", "D1Dps", 0);
decimal d1_deposit = Convert.ToDecimal(temp_value);
// 3. D+2 예수금
temp_value = CSPAQ12200.GetFieldData("CSPAQ12200OutBlock2", "D2Dps", 0);
decimal d2_deposit = Convert.ToDecimal(temp_value);
// 4. 손익률
temp_value = CSPAQ12200.GetFieldData("CSPAQ12200OutBlock2", "PnlRat", 0);
double valuation_rate = Convert.ToDouble(temp_value);
// 5. 잔고평가금액
temp_value = CSPAQ12200.GetFieldData("CSPAQ12200OutBlock2", "BalEvalAmt", 0);
decimal evaluation_amounts = Convert.ToDecimal(temp_value);
string text = String.Format("[예탁자산총액 : {0:#,0}] [D+1 예수금 : {1:#,0}] [D+2 예수금 : {2:#,0}] [손익률 : {3:f2}%] [잔고평가금액 : {4:#,0}]",
estimated_assets, d1_deposit, d2_deposit, valuation_rate, evaluation_amounts);
MessageBox.Show(text);
}
// 계좌잔고 조회 [반복데이터]
private void Btn_Get_Items_Click(object sender, EventArgs e)
{
// 잔고 리스트 조회
string inform = String.Format("-- 잔고 리스트 조회");
Realtime_Log.Items.Add(inform);
t0424Occurs.SetFieldData("t0424InBlock", "accno", 0, gAccount);
t0424Occurs.SetFieldData("t0424InBlock", "passwd", 0, "실제계좌비번");
t0424Occurs.SetFieldData("t0424InBlock", "prcgb", 0, "1");
t0424Occurs.SetFieldData("t0424InBlock", "chegb", 0, "2");
t0424Occurs.SetFieldData("t0424InBlock", "dangb", 0, "0");
t0424Occurs.SetFieldData("t0424InBlock", "charge", 0, "0");
t0424Occurs.SetFieldData("t0424InBlock", "cts_expcode", 0, " ");
int result = t0424Occurs.Request(false);
if (result < 0)
{
inform = string.Format("[보유계좌] 계좌 잔고리스트(t0424) 요청이 실패했습니다. ret={0}", result);
Realtime_Log.Items.Add(inform);
}
}
private void t0424ReceiveData(string trCod)
{
// 전체 잔고 종목 횟수 가져오기
var count = t0424Occurs.GetBlockCount("t0424OutBlock1");
string inform = String.Format("잔고조회 종목 리스트 갯수 : {0}", count);
Realtime_Log.Items.Add(inform);
Realtime_Log.Items.Add("-------------------------------------------------------------------------------------------------------------------------------");
string title = String.Format("| {0,20} | {1,10} | {2,10} | {3,10} | {4,10} | {5,10} | {6,10} | {7,10} | {8,10} |", "종목명", "종목코드", "현재가", "매입가", "잔고수량", "매입금액", "평가금액", "평가손익", "수익률");
Realtime_Log.Items.Add(title);
Realtime_Log.Items.Add("-------------------------------------------------------------------------------------------------------------------------------");
// 가져온 종목 횟수 만큼 반복하면서 실제 종목 정보 가져오기
for (int index = 0; index < count; ++index)
{
var temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "expcode", index); // 종목코드
string expcode = Convert.ToString(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "hname", index); // 종목명
string hname = Convert.ToString(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "price", index); // 현재가
decimal price = Convert.ToDecimal(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "pamt", index); // 매입가
decimal pamt = Convert.ToDecimal(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "janqty", index); // 잔고수량
int janqty = Convert.ToInt16(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "mamt", index); // 매입금액
decimal mamt = Convert.ToDecimal(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "appamt", index); // 평가금액
decimal appamt = Convert.ToDecimal(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "dtsunik", index); // 평가손익
decimal dtsunik = Convert.ToDecimal(temp_value);
temp_value = t0424Occurs.GetFieldData("t0424OutBlock1", "sunikrt", index); // 수익율
double sunikrt = Convert.ToDouble(temp_value);
string contents = String.Format("| {0,20} | {1,10} | {2,10} | {3,10} | {4,10} | {5,10} | {6,10} | {7,10} | {8,10} |",
expcode, hname, price, pamt, janqty, mamt, appamt, dtsunik, sunikrt);
Realtime_Log.Items.Add(contents);
}
Realtime_Log.Items.Add("-------------------------------------------------------------------------------------------------------------------------------");
}
}
}
아래의 이전 포스팅을 참조해서 [서버연결]-[로그인]-[계좌선택]까지 완료해보자.
2020/08/24 - [Trading] - [Trading] xingAPI - 서버연결, 로그인, 보유계좌 불러오기
[Trading] xingAPI - 서버연결, 로그인, 보유계좌 불러오기
오늘은 xingAPI를 사용한 자동매매 프로그램을 만들기 위한 기본 작업들에 대한 포스팅을 하려 한다. 이 내용은 이베스트 투자증권의 xingAPI 소개자료에도 동일하게 소개되어 있는 내용이지만, 엑�
brandon-dev.tistory.com
이제 '계좌잔고 조회' 버튼을 누르면 종목 리스트가 표시될 것이다.
이제 이 정보들을 객체 List로 저장하도록 해서 DataGridView에 Binding하면, 실시간으로 계좌 종목 리스트를 갱신하며 리스트로 보여줄 수 있겠다.
다음은 DataGridView에 Binding하는 법을 포스팅 해보자.
'Trading' 카테고리의 다른 글
| [Trading] L-ATS 3.0의 시작 (0) | 2023.03.03 |
|---|---|
| [Trading] xingAPI - 데이터 표시하기 (4) | 2021.11.07 |
| [Trading] xingAPI - 단일 데이터 조회 (0) | 2020.09.02 |
| [Trading] xingAPI - 서버연결, 로그인, 보유계좌 불러오기 (0) | 2020.08.24 |
| [Trading] xingAPI - TR과 데이터 조회 (0) | 2020.08.23 |
