반응형
특강 2에서 주식일봉차트조회를 위한 명령어를 어떻게 보내는지 알아 보았습니다. 그리고 commRqData를 이용해 요청 결과에 대한 값을 받아 왔고 그 데이터를 컴퓨터에 저장해 보겠습니다.
[유튜브 강의, 링크]와 같이 보시면 많은 도움이 되실 겁니다.
1. 주식일봉차트 요청 결과값 slot에 받아오기
저번 강의에서 보시면 데이터를 받아올 때 "주식일봉차트조회"라는 이름으로 받아오고 있습니다. 그러면 slot에서도 동일한 이름으로 받아 와야 겠죠?
아래는 trdata_slot의 문구이며, 저번 강의에서 받아오느 종목별기관매매요청2 다음에 elif 구문을 사용하여 만약 sRQName 이 "주식일봉차트조회"라면 아래 문구를 수행해라는 의미입니다.
- self.k를 사용해 메타클래스 기반 싱글턴에 접속 후 키움 서버로 메시지 전송을 위해 kiwoom.dynamicCall을 사용합니다. 요청 주문은 특정 데이터를 받아오는 함수 GetCommData이고 요청 값은 싱글데이터인 "종목코드" 입니다. "종목코드"를 code에 받아온 후 혹시 발생하는 여백 문제를 해결하기 위해 strip()함수를 사용하여 code = code.strip() 함수를 작성합니다.
- 그리고 멀티데이터를 받아올 준비를 하는데 내가 받아오는 종목에 일별 데이터가 몇개 있는지 확인하기 위해 GetRepeatCnt 함수를 사용합니다. 이 함수를 사용하면 멀티데이터 개수를 확인 할 수 있습니다. 일반적으로 600개의 데이터(600일치)가 넘어오고 신규상장된 주식의 경우(200일 전에 상장된 주식) 상장일에 맞춰 데이터가 넘어옵니다.(200일 치 데이터)
- 멀티데이터는 저번 강의와 동일하게 for 문을 사용해서 가져오도록 하겠습니다. 아래의 GetCommDataEx를 하면 for 문을 쓰지 않고 멀티데이터를 다 받아올 수 있으나 우리는 코딩도 같이 배워야 하기 때문에 아래 화면처럼 for 문을 이용해 코딩을 할 것입니다.
"GetCommDataEx(QString, QString)", sTrCode, sRQName
- for i in range(cnt) : range함수를 사용하는데 range(600)은 : 0, 1, 2, 3, 4, 5...599가 들어가게 됩니다. 총 600개이죠.
- data라는 리스트 객체를 만듭니다. 저장되는 데이터는 리스트로 들어가게 됩니다. 즉 종목마다 일반적으로 600개의 데이터 묶음이 저장됩니다.
[[현재가, 거래량, 거래대금, 일자, 시가, 고가, 저가], [현재가, 거래량, 거래대금, 일자, 시가, 고가, 저가],....] 이런식으로 600개의 데이터 입니다.
- self.Precdic_start라는 객체는 밑에 공유 코드에서는 삭제하도록 하겠습니다. 미래를 예측하기 위한 코드인데 강의에서는 다루지 않을 예정입니다.
- self.calcul_data.append(data.copy()) : 역배열 차트를 계산하기 위해 이 데이터를 이용할 것입니다. copy는 레지스터 주소가 중복되지 않게 데이터를 복사시키는 방법입니다.
2. 요약 및 Qthread_2에 코딩된 코드 공개
주식일봉차트 정보를 받아오는 코딩을 마무리 하였습니다. 싱글데이터는 코드 번호만 가져오고 나머지 멀티데이터는 600개의 데이터를 가져왔습니다. 600개 데이터 의미는 600일치의 데이터를 가져오는 것과 동일합니다. 만약 신규 상장된 주식일 경우(600일치 데이터가 없을 경우) 상장 일수만큼의 데이터만 가져옵니다.
가져온 데이터를 data라는 리스트 및 self.calcul_data에 append 함수 및 copy 함수를 이용해 저장합니다.
다음 코딩에서는 self.calcul_data에 저장된 데이터를 이용해 이평선을 만들어 보도록 하겠습니다. 감사합니다.
Qthread_2.py의 스크립트의 공개되는 코드입니다.
반응형
from PyQt5.QtCore import * # eventloop/스레드를 사용 할 수 있는 함수 가져옴.
from kiwoom import Kiwoom # 로그인을 위한 클래스
from PyQt5.QtWidgets import * # PyQt import
from PyQt5.QtTest import * # 시간관련 함수
from datetime import datetime, timedelta # 특정 일자를 조회
class Thread2(QThread):
def __init__(self, parent): # 부모의 윈도우 창을 가져올 수 있다.
super().__init__(parent) # 부모의 윈도우 창을 초기화 한다.
self.parent = parent # 부모의 윈도우를 사용하기 위한 조건
################## 키움서버 함수를 사용하기 위해서 kiwoom의 능력을 상속 받는다.
self.k = Kiwoom()
################## 사용되는 변수
self.Find_down_Screen = "1200" # 계좌평가잔고내역을 받기위한 스크린
self.code_in_all = None # 1600개 코드 중 1개 코드, 쌓이지 않고 계속 갱신
################## 기관/외국인 매매동향 가져오기 사용되는 변수
self.Predic_Screen = "1400" # 일봉차트를 가져오기위한 스크린
self.calcul_data = [] # 받아온 종목의 다양한 값(현재가/고가/저가 등)을 계산한다.
self.second_filter = [] # 역배열인지 확인
self.Predic_start = [] # 미래예측
###### 슬롯
self.k.kiwoom.OnReceiveTrData.connect(self.trdata_slot) # 내가 알고 있는 Tr 슬롯에다 특정 값을 던져 준다.
###### EventLoop
self.detail_account_info_event_loop = QEventLoop() # 계좌 이벤트루프
###### 기관외국인 평균가 가져오기
self.C_K_F_class()
###### 역배열 평가
self.Invers_arrangement()
###### 결과 붙이기(gui)
column_head = ["종목코드", "종목명", "위험도"]
colCount = len(column_head)
rowCount = len(self.k.acc_portfolio)
self.parent.Danger_wd.setColumnCount(colCount) # 행 갯수
self.parent.Danger_wd.setRowCount(rowCount) # 열 갯수 (종목 수)
self.parent.Danger_wd.setHorizontalHeaderLabels(column_head) # 행의 이름 삽입
index2 = 0
for k in self.k.acc_portfolio.keys():
self.parent.Danger_wd.setItem(index2, 0, QTableWidgetItem(str(k)))
self.parent.Danger_wd.setItem(index2, 1, QTableWidgetItem(self.k.acc_portfolio[k]["종목명"]))
self.parent.Danger_wd.setItem(index2, 2, QTableWidgetItem(self.k.acc_portfolio[k]["위험도"]))
index2 += 1
def C_K_F_class(self):
code_list = []
for code in self.k.acc_portfolio.keys():
code_list.append(code)
print("계좌 종목 개수 %s" % (code_list))
#self.parent.progressBar5.setMaximum(len(code_list) - 1) /차 후 설명 드리겠습니다.
for idx, code in enumerate(code_list):
#self.parent.progressBar5.setValue(idx) / 차 후 설명드리겠습니다.
QTest.qWait(1000)
self.k.kiwoom.dynamicCall("DisconnectRealData(QString)", self.Find_down_Screen) # 해당 스크린을 끊고 다시 시작
self.code_in_all = code # 종목코드 선언 (중간에 코드 정보 받아오기 위해서)
print("%s / %s : 종목 검사 중 코드이름 : %s." % (idx + 1, len(code_list), self.code_in_all))
date_today = datetime.today().strftime("%Y%m%d")
date_prev = datetime.today() - timedelta(10) # 넉넉히 10일전의 데이터를 받아온다. 또는 20일이상 데이터도 필요
date_prev = date_prev.strftime("%Y%m%d")
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "종목코드", code)
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "시작일자", date_prev)
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "종료일자", date_today)
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "기관추정단가구분", "1")
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "외인추정단가구분", "1")
self.k.kiwoom.dynamicCall("CommRqData(String, String, int, String)", "종목별기관매매추이요청2", "opt10045", "0", self.Find_down_Screen)
self.detail_account_info_event_loop.exec_()
def Invers_arrangement(self):
code_list = []
for code in self.k.acc_portfolio.keys():
code_list.append(code)
print("계좌포함 종목 %s" % (code_list))
for idx, code in enumerate(code_list):
QTest.qWait(1000)
self.k.kiwoom.dynamicCall("DisconnectRealData(QString)", self.Predic_Screen) # 해당 스크린을 끊고 다시 시작
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "종목코드", code)
self.k.kiwoom.dynamicCall("SetInputValue(QString, QString)", "수정주가구분", "1") # 수정주가구분 0: 액면분할등이 포함되지 않음, 1: 포함됨
self.k.kiwoom.dynamicCall("CommRqData(QString, QString, int, QString)", "주식일봉차트조회", "opt10081", "0", self.Predic_Screen)
self.detail_account_info_event_loop.exec_()
def kigwan_meme_dong2(self, a, c): # a. 기관일별순매수량, b. 종가/기관/외국인 평균가, c. 외국인일별순매수량, d. 등락률
a = a[0:4]
c = c[0:4]
print(a)
# a = sum(a, [])
# c = sum(c, [])
if a[0] < 0 and a[1] < 0 and a[2] < 0 and a[3] < 0 and c[0] < 0 and c[1] < 0 and c[2] < 0 and c[3] < 0:
self.k.acc_portfolio[self.code_in_all].update({"위험도": "손절"})
elif a[0] < 0 and a[1] < 0 and a[2] < 0 and c[0] < 0 and c[1] < 0 and c[2] < 0:
self.k.acc_portfolio[self.code_in_all].update({"위험도": "주의"})
elif a[0] < 0 and a[1] < 0 and c[0] < 0 and c[1] < 0:
self.k.acc_portfolio[self.code_in_all].update({"위험도": "관심"})
else:
self.k.acc_portfolio[self.code_in_all].update({"위험도": "낮음"})
def trdata_slot(self, sScrNo, sRQName, sTrCode, sRecordName, sPrevNext):
if sRQName == "종목별기관매매추이요청2":
cnt2 = self.k.kiwoom.dynamicCall("GetRepeatCnt(QString, QString)", sTrCode, sRQName) # 10일치 이상을 하려면 이부분에 10일치 이상데이터 필요
self.calcul2_data = []
self.calcul2_data2 = []
self.calcul2_data3 = []
self.calcul2_data4 = []
for i in range(cnt2): #
Kigwan_meme = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, i, "기관일별순매매수량"))
Kigwan_meme_ave = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, 0, "기관추정평균가"))
Forgin_meme = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, i, "외인일별순매매수량"))
Forgin_meme_ave = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, 0, "외인추정평균가"))
percentage = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, i, "등락율"))
Jongga = (self.k.kiwoom.dynamicCall("GetCommData(String, String, int, String)", sTrCode, sRQName, i, "종가"))
self.calcul2_data.append(int(Kigwan_meme.strip()))
self.calcul2_data2.append(abs(int(Jongga.strip())))
self.calcul2_data2.append(abs(int(Kigwan_meme_ave.strip())))
self.calcul2_data2.append(abs(int(Forgin_meme_ave.strip())))
self.calcul2_data3.append(int(Forgin_meme.strip()))
self.calcul2_data4.append(float(percentage.strip()))
# 여기까지 code의 기관일별순매수량, 외국인일별순매수량, 기관/외국인 평균가, 등락률 정보가 나온다.
# self.kigwan_meme_dong2(self.calcul2_data, self.calcul2_data2[0:3], self.calcul2_data3, self.calcul2_data4)
self.kigwan_meme_dong2(self.calcul2_data, self.calcul2_data3)
self.detail_account_info_event_loop.exit()
elif sRQName == "주식일봉차트조회":
code = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "종목코드")
code = code.strip() # 여백 발생 방지
cnt = self.k.kiwoom.dynamicCall("GetRepeatCnt(QString, QString)", sTrCode, sRQName)
# print("데이터 일수 %s" % cnt)
# 600일치 데이터를 한번에 받아오는 함수 : GetCommDataEx, 리스트로 반환
# data = self.dynamicCall("GetCommDataEx(QString, QString)", sTrCode, sRQName)
# [['', '현재가', '거래량', '거래대금', '날짜', '시가', '고가', '저가', ''], [ ........
for i in range(cnt): # [0] ~ [599]
data = []
current_price = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "현재가")
value = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "거래량")
trading_value = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "거래대금")
date = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "일자") # 접수, 확인, 채결
start_price = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "시가")
high_price = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "고가")
low_price = self.k.kiwoom.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "저가")
data.append("") # 빈칸을 만들어 주는 이유는 GetCommDataEx함수의 반환값과 동일하게 하기 위해서
data.append(current_price.strip())
data.append(value.strip())
data.append(trading_value.strip())
data.append(date.strip())
data.append(start_price.strip())
data.append(high_price.strip())
data.append(low_price.strip())
data.append("")
#self.Predic_start.append(int(current_price.strip()))
self.calcul_data.append(data.copy()) # 리스트로 데이터가 들어간다.반응형
'주식 자동매매 강의 > 기초반(모든 코딩의 뿌리)' 카테고리의 다른 글
| [특강 5] 주식 역배열 차트 탐지 알고리즘 제작 완료, 파이썬 코드 공유 (2) | 2022.05.24 |
|---|---|
| [특강 4] 역배열 차트 주식 탐지 알고리즘(4), 5일/20일 이평선 만든 후 역배열 탐지하기 (3) | 2022.05.24 |
| [특강 2] 역배열 차트 주식 탐지 알고리즘(2), 주식일봉차트 보내기 (2) | 2022.05.21 |
| [특강 1] 역배열 차트 주식 탐지 알고리즘(1), 개념 설명, 알면 피할 수 있다 (2) | 2022.05.20 |
| 주식자동매매 31강. 계좌관리하기 (8), opt10045 최종 요약 및 코드 공개 (7) | 2022.05.19 |
