[파이썬] 키움증권 주식자동화 카톡(나와의채팅)으로 보내기 질문입니다

Question

안녕하세요 [키움증권] 주식 자동화를 구축중입니다. 그에 대한 결과 알림등을 slack 또는 카카오톡(나와의 채팅)으로 보내고자합니다.slack은 일부 유료 서비스라고 접었고, 현재 카카오 메시지 보내기로 진행중입니다. 카카오 메스트 메시지까지는 성공했는데, 주식 자동화 결과 데이터를 어떻게 실어서 카톡으로 보내야할지 모르겠습니다. [ kiwoom.py ]import os import sys from PyQt5.QAxContainer import * from PyQt5.QtCore import * from config.errorCode import * from PyQt5.QtTest import * from config.kiwoomType import * from config.log_class import * from config.slack import * # from kakao.kakao import * class Kiwoom(QAxWidget): def __init__(self): super().__init__() self.realType = RealType() self.logging = Logging() self.slack = Slack() #슬랙 동작 # self.kakao = Kakao() #print("kiwoom() class start. ") self.logging.logger.debug("Kiwoom() class start.") ####### event loop를 실행하기 위한 변수모음 self.login_event_loop = QEventLoop() #로그인 요청용 이벤트루프 self.detail_account_info_event_loop = QEventLoop() # 예수금 요청용 이벤트루프 self.calculator_event_loop = QEventLoop() ######################################### ########### 전체 종목 관리 self.all_stock_dict = {} ########################### ####### 계좌 관련된 변수 self.account_stock_dict = {} self.not_account_stock_dict = {} self.deposit = 0 #예수금 self.use_money = 0 #실제 투자에 사용할 금액 self.use_money_percent = 0.5 #예수금에서 실제 사용할 비율 self.output_deposit = 0 #출력가능 금액 self.total_profit_loss_money = 0 #총평가손익금액 self.total_profit_loss_rate = 0.0 #총수익률(%) ######################################## ######## 종목 정보 가져오기 self.portfolio_stock_dict = {} self.jango_dict = {} ######################## ########### 종목 분석 용 self.calcul_data = [] ########################################## ####### 요청 스크린 번호 self.screen_my_info = "2000" #계좌 관련한 스크린 번호 self.screen_calculation_stock = "4000" #계산용 스크린 번호 self.screen_real_stock = "5000" #종목별 할당할 스크린 번호 self.screen_meme_stock = "6000" #종목별 할당할 주문용스크린 번호 self.screen_start_stop_real = "1000" #장 시작/종료 실시간 스크린번호 ######################################## ######### 초기 셋팅 함수들 바로 실행 self.get_ocx_instance() #OCX 방식을 파이썬에 사용할 수 있게 변환해 주는 함수 self.event_slots() # 키움과 연결하기 위한 시그널 / 슬롯 모음 self.real_event_slot() # 실시간 이벤트 시그널 / 슬롯 연결 self.signal_login_commConnect() #로그인 요청 시그널 포함 self.get_account_info() #계좌번호 가져오기 self.detail_account_info() #예수금 요청 시그널 포함 self.detail_account_mystock() #계좌평가잔고내역 요청 시그널 포함 QTimer.singleShot(5000, self.not_concluded_account) #5초 뒤에 미체결 종목들 가져오기 실행 # self.talk_kakao() ######################################### QTest.qWait(10000) self.read_code() self.screen_number_setting() QTest.qWait(5000) #실시간 수신 관련 함수 self.dynamicCall("SetRealReg(QString, QString, QString, QString)", self.screen_start_stop_real, '', self.realType.REALTYPE['장시작시간']['장운영구분'], "0") for code in self.portfolio_stock_dict.keys(): screen_num = self.portfolio_stock_dict[code]['스크린번호'] fids = self.realType.REALTYPE['주식체결']['체결시간'] self.dynamicCall("SetRealReg(QString, QString, QString, QString)", screen_num, code, fids, "1") # self.slack.notification( # pretext="주식자동화 프로그램 동작", # title="주식 자동화 프로그램 동작", # fallback="주식 자동화 프로그램 동작", # text="주식 자동화 프로그램이 동작 되었습니다." # ) self.slack.send_msg(msg="주식 자동화 프로그램 동작되었습니다.") def get_ocx_instance(self): self.setControl("KHOPENAPI.KHOpenAPICtrl.1") # 레지스트리에 저장된 api 모듈 불러오기 def event_slots(self): self.OnEventConnect.connect(self.login_slot) # 로그인 관련 이벤트 self.OnReceiveTrData.connect(self.trdata_slot) # 트랜잭션 요청 관련 이벤트 self.OnReceiveMsg.connect(self.msg_slot) def real_event_slot(self): self.OnReceiveRealData.connect(self.realdata_slot) # 실시간 이벤트 연결 self.OnReceiveChejanData.connect(self.chejan_slot) #종목 주문체결 관련한 이벤트 def signal_login_commConnect(self): self.dynamicCall("CommConnect()") # 로그인 요청 시그널 self.login_event_loop.exec_() # 이벤트루프 실행 def login_slot(self, err_code): self.logging.logger.debug(errors(err_code)[1]) #로그인 처리가 완료됐으면 이벤트 루프를 종료한다. self.login_event_loop.exit() def get_account_info(self): account_list = self.dynamicCall("GetLoginInfo(QString)", "ACCNO") # 계좌번호 반환 account_num = account_list.split(';')[0] self.account_num = account_num self.logging.logger.debug("계좌번호 : %s" % account_num) def detail_account_info(self, sPrevNext="0"): self.dynamicCall("SetInputValue(QString, QString)", "계좌번호", self.account_num) self.dynamicCall("SetInputValue(QString, QString)", "비밀번호", "0000") self.dynamicCall("SetInputValue(QString, QString)", "비밀번호입력매체구분", "00") self.dynamicCall("SetInputValue(QString, QString)", "조회구분", "1") self.dynamicCall("CommRqData(QString, QString, int, QString)", "예수금상세현황요청", "opw00001", sPrevNext, self.screen_my_info) self.detail_account_info_event_loop.exec_() def detail_account_mystock(self, sPrevNext="0"): self.dynamicCall("SetInputValue(QString, QString)", "계좌번호", self.account_num) self.dynamicCall("SetInputValue(QString, QString)", "비밀번호", "0000") self.dynamicCall("SetInputValue(QString, QString)", "비밀번호입력매체구분", "00") self.dynamicCall("SetInputValue(QString, QString)", "조회구분", "1") self.dynamicCall("CommRqData(QString, QString, int, QString)", "계좌평가잔고내역요청", "opw00018", sPrevNext, self.screen_my_info) self.detail_account_info_event_loop.exec_() def not_concluded_account(self, sPrevNext="0"): self.dynamicCall("SetInputValue(QString, QString)", "계좌번호", self.account_num) self.dynamicCall("SetInputValue(QString, QString)", "체결구분", "1") self.dynamicCall("SetInputValue(QString, QString)", "매매구분", "0") self.dynamicCall("CommRqData(QString, QString, int, QString)", "실시간미체결요청", "opt10075", sPrevNext, self.screen_my_info) self.detail_account_info_event_loop.exec_() def trdata_slot(self, sScrNo, sRQName, sTrCode, sRecordName, sPrevNext): if sRQName == "예수금상세현황요청": deposit = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "예수금") self.deposit = int(deposit) use_money = float(self.deposit) * self.use_money_percent self.use_money = int(use_money) self.use_money = self.use_money / 4 output_deposit = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "출금가능금액") self.output_deposit = int(output_deposit) self.logging.logger.debug("예수금 : %s" % self.output_deposit) self.stop_screen_cancel(self.screen_my_info) self.detail_account_info_event_loop.exit() elif sRQName == "계좌평가잔고내역요청": total_buy_money = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "총매입금액") self.total_buy_money = int(total_buy_money) total_profit_loss_money = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "총평가손익금액") self.total_profit_loss_money = int(total_profit_loss_money) total_profit_loss_rate = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "총수익률(%)") self.total_profit_loss_rate = float(total_profit_loss_rate) self.logging.logger.debug("계좌평가잔고내역요청 싱글데이터 : %s - %s - %s" % (total_buy_money, total_profit_loss_money, total_profit_loss_rate)) rows = self.dynamicCall("GetRepeatCnt(QString, QString)", sTrCode, sRQName) for i in range(rows): code = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "종목번호") # 출력 : A039423 // 알파벳 A는 장내주식, J는 ELW종목, Q는 ETN종목 code = code.strip()[1:] code_nm = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "종목명") # 출럭 : 한국기업평가 stock_quantity = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "보유수량") # 보유수량 : 000000000000010 buy_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "매입가") # 매입가 : 000000000054100 learn_rate = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "수익률(%)") # 수익률 : -000000001.94 current_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "현재가") # 현재가 : 000000003450 total_chegual_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "매입금액") possible_quantity = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "매매가능수량") self.logging.logger.debug("종목코드: %s - 종목명: %s - 보유수량: %s - 매입가:%s - 수익률: %s - 현재가: %s" % ( code, code_nm, stock_quantity, buy_price, learn_rate, current_price)) if code in self.account_stock_dict: # dictionary 에 해당 종목이 있나 확인 pass else: self.account_stock_dict[code] = {} code_nm = code_nm.strip() stock_quantity = int(stock_quantity.strip()) buy_price = int(buy_price.strip()) learn_rate = float(learn_rate.strip()) current_price = int(current_price.strip()) total_chegual_price = int(total_chegual_price.strip()) possible_quantity = int(possible_quantity.strip()) self.account_stock_dict[code].update({"종목명": code_nm}) self.account_stock_dict[code].update({"보유수량": stock_quantity}) self.account_stock_dict[code].update({"매입가": buy_price}) self.account_stock_dict[code].update({"수익률(%)": learn_rate}) self.account_stock_dict[code].update({"현재가": current_price}) self.account_stock_dict[code].update({"매입금액": total_chegual_price}) self.account_stock_dict[code].update({'매매가능수량' : possible_quantity}) self.logging.logger.debug("sPreNext : %s" % sPrevNext) print("계좌에 가지고 있는 종목은 %s " % rows) if sPrevNext == "2": self.detail_account_mystock(sPrevNext="2") else: self.detail_account_info_event_loop.exit() elif sRQName == "실시간미체결요청": rows = self.dynamicCall("GetRepeatCnt(QString, QString)", sTrCode, sRQName) for i in range(rows): code = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "종목코드") code_nm = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "종목명") order_no = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "주문번호") order_status = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "주문상태") # 접수,확인,체결 order_quantity = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "주문수량") order_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "주문가격") order_gubun = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "주문구분") # -매도, +매수, -매도정정, +매수정정 not_quantity = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "미체결수량") ok_quantity = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "체결량") code = code.strip() code_nm = code_nm.strip() order_no = int(order_no.strip()) order_status = order_status.strip() order_quantity = int(order_quantity.strip()) order_price = int(order_price.strip()) order_gubun = order_gubun.strip().lstrip('+').lstrip('-') not_quantity = int(not_quantity.strip()) ok_quantity = int(ok_quantity.strip()) if order_no in self.not_account_stock_dict: pass else: self.not_account_stock_dict[order_no] = {} self.not_account_stock_dict[order_no].update({'종목코드': code}) self.not_account_stock_dict[order_no].update({'종목명': code_nm}) self.not_account_stock_dict[order_no].update({'주문번호': order_no}) self.not_account_stock_dict[order_no].update({'주문상태': order_status}) self.not_account_stock_dict[order_no].update({'주문수량': order_quantity}) self.not_account_stock_dict[order_no].update({'주문가격': order_price}) self.not_account_stock_dict[order_no].update({'주문구분': order_gubun}) self.not_account_stock_dict[order_no].update({'미체결수량': not_quantity}) self.not_account_stock_dict[order_no].update({'체결량': ok_quantity}) self.logging.logger.debug("미체결 종목 : %s " % self.not_account_stock_dict[order_no]) self.detail_account_info_event_loop.exit() elif sRQName == "주식일봉차트조회": code = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, 0, "종목코드") code = code.strip() # data = self.dynamicCall("GetCommDataEx(QString, QString)", sTrCode, sRQName) # [[‘’, ‘현재가’, ‘거래량’, ‘거래대금’, ‘날짜’, ‘시가’, ‘고가’, ‘저가’. ‘’], [‘’, ‘현재가’, ’거래량’, ‘거래대금’, ‘날짜’, ‘시가’, ‘고가’, ‘저가’, ‘’]. […]] cnt = self.dynamicCall("GetRepeatCnt(QString, QString)", sTrCode, sRQName) self.logging.logger.debug("남은 일자 수 %s" % cnt) for i in range(cnt): data = [] current_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "현재가") # 출력 : 000070 value = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "거래량") # 출력 : 000070 trading_value = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "거래대금") # 출력 : 000070 date = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "일자") # 출력 : 000070 start_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "시가") # 출력 : 000070 high_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "고가") # 출력 : 000070 low_price = self.dynamicCall("GetCommData(QString, QString, int, QString)", sTrCode, sRQName, i, "저가") # 출력 : 000070 data.append("") 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.calcul_data.append(data.copy()) if sPrevNext == "2": self.day_kiwoom_db(code=code, sPrevNext=sPrevNext) else: self.logging.logger.debug("총 일수 %s" % len(self.calcul_data)) pass_success = False # 120일 이평선을 그릴만큼의 데이터가 있는지 체크 if self.calcul_data == None or len(self.calcul_data) < 120: pass_success = False else: # 120일 이평선의 최근 가격 구함 total_price = 0 for value in self.calcul_data[:120]: total_price += int(value[1]) moving_average_price = total_price / 120 # 오늘자 주가가 120일 이평선에 걸쳐있는지 확인 bottom_stock_price = False check_price = None if int(self.calcul_data[0][7]) <= moving_average_price and moving_average_price <= int(self.calcul_data[0][6]): self.logging.logger.debug("오늘 주가 120이평선 아래에 걸쳐있는 것 확인") bottom_stock_price = True check_price = int(self.calcul_data[0][6]) # 과거 일봉 데이터를 조회하면서 120일 이평선보다 주가가 계속 밑에 존재하는지 확인 prev_price = None if bottom_stock_price == True: moving_average_price_prev = 0 price_top_moving = False idx = 1 while True: if len(self.calcul_data[idx:]) < 120: # 120일치가 있는지 계속 확인 self.logging.logger.debug("120일치가 없음") break total_price = 0 for value in self.calcul_data[idx:120+idx]: total_price += int(value[1]) moving_average_price_prev = total_price / 120 if moving_average_price_prev <= int(self.calcul_data[idx][6]) and idx <= 20: self.logging.logger.debug("20일 동안 주가가 120일 이평선과 같거나 위에 있으면 조건 통과 못함") price_top_moving = False break elif int(self.calcul_data[idx][7]) > moving_average_price_prev and idx > 20: # 120일 이평선 위에 있는 구간 존재 self.logging.logger.debug("120일치 이평선 위에 있는 구간 확인됨") price_top_moving = True prev_price = int(self.calcul_data[idx][7]) break idx += 1 # 해당부분 이평선이 가장 최근의 이평선 가격보다 낮은지 확인 if price_top_moving == True: if moving_average_price > moving_average_price_prev and check_price > prev_price: self.logging.logger.debug("포착된 이평선의 가격이 오늘자 이평선 가격보다 낮은 것 확인") self.logging.logger.debug("포착된 부분의 저가가 오늘자 주가의 고가보다 낮은지 확인") pass_success = True if pass_success == True: self.logging.logger.debug("조건부 통과됨") code_nm = self.dynamicCall("GetMasterCodeName(QString)", code) f = open("files/condition_stock.txt", "a", encoding="utf8") f.write("%s %s %s " % (code, code_nm, str(self.calcul_data[0][1]))) f.close() elif pass_success == False: self.logging.logger.debug("조건부 통과 못함") self.calcul_data.clear() self.calculator_event_loop.exit() def stop_screen_cancel(self, sScrNo=None): self.dynamicCall("DisconnectRealData(QString)", sScrNo) # 스크린번호 연결 끊기 def get_code_list_by_market(self, market_code): ''' 종목코드 리스트 받기 #0:장내, 10:코스닥 :param market_code: 시장코드 입력 :return: ''' code_list = self.dynamicCall("GetCodeListByMarket(QString)", market_code) code_list = code_list.split(';')[:-1] return code_list def calculator_fnc(self): ''' 종목 분석관련 함수 모음 :return: ''' code_list = self.get_code_list_by_market("10") self.logging.logger.debug("코스닥 갯수 %s " % len(code_list)) for idx, code in enumerate(code_list): self.dynamicCall("DisconnectRealData(QString)", self.screen_calculation_stock) # 스크린 연결 끊기 self.logging.logger.debug("%s / %s : KOSDAQ Stock Code : %s is updating... " % (idx + 1, len(code_list), code)) self.day_kiwoom_db(code=code) def day_kiwoom_db(self, code=None, date=None, sPrevNext="0"): QTest.qWait(3600) #3.6초마다 딜레이를 준다. self.dynamicCall("SetInputValue(QString, QString)", "종목코드", code) self.dynamicCall("SetInputValue(QString, QString)", "수정주가구분", "1") if date != None: self.dynamicCall("SetInputValue(QString, QString)", "기준일자", date) self.dynamicCall("CommRqData(QString, QString, int, QString)", "주식일봉차트조회", "opt10081", sPrevNext, self.screen_calculation_stock) # Tr서버로 전송 -Transaction self.calculator_event_loop.exec_() def read_code(self): if os.path.exists("files/condition_stock.txt"): # 해당 경로에 파일이 있는지 체크한다. f = open("files/condition_stock.txt", "r", encoding="utf8") # "r"을 인자로 던져주면 파일 내용을 읽어 오겠다는 뜻이다. lines = f.readlines() #파일에 있는 내용들이 모두 읽어와 진다. for line in lines: #줄바꿈된 내용들이 한줄 씩 읽어와진다. if line != "": ls = line.split(" ") stock_code = ls[0] stock_name = ls[1] stock_price = int(ls[2].split(" ")[0]) stock_price = abs(stock_price) self.portfolio_stock_dict.update({stock_code:{"종목명":stock_name, "현재가":stock_price}}) f.close() def merge_dict(self): self.all_stock_dict.update({"계좌평가잔고내역": self.account_stock_dict}) self.all_stock_dict.update({'미체결종목': self.not_account_stock_dict}) self.all_stock_dict.update({'포트폴리오종목': self.portfolio_stock_dict}) def screen_number_setting(self): screen_overwrite = [] #계좌평가잔고내역에 있는 종목들 for code in self.account_stock_dict.keys(): if code not in screen_overwrite: screen_overwrite.append(code) #미체결에 있는 종목들 for order_number in self.not_account_stock_dict.keys(): code = self.not_account_stock_dict[order_number]['종목코드'] if code not in screen_overwrite: screen_overwrite.append(code) #포트폴리로에 담겨있는 종목들 for code in self.portfolio_stock_dict.keys(): if code not in screen_overwrite: screen_overwrite.append(code) # 스크린번호 할당 cnt = 0 for code in screen_overwrite: temp_screen = int(self.screen_real_stock) meme_screen = int(self.screen_meme_stock) if (cnt % 50) == 0: temp_screen += 1 self.screen_real_stock = str(temp_screen) if (cnt % 50) == 0: meme_screen += 1 self.screen_meme_stock = str(meme_screen) if code in self.portfolio_stock_dict.keys(): self.portfolio_stock_dict[code].update({"스크린번호": str(self.screen_real_stock)}) self.portfolio_stock_dict[code].update({"주문용스크린번호": str(self.screen_meme_stock)}) elif code not in self.portfolio_stock_dict.keys(): self.portfolio_stock_dict.update({code: {"스크린번호": str(self.screen_real_stock), "주문용스크린번호": str(self.screen_meme_stock)}}) cnt += 1 # 실시간 데이터 얻어오기 def realdata_slot(self, sCode, sRealType, sRealData): if sRealType == "장시작시간": fid = self.realType.REALTYPE[sRealType]['장운영구분'] # (0:장시작전, 2:장종료전(20분), 3:장시작, 4,8:장종료(30분), 9:장마감) value = self.dynamicCall("GetCommRealData(QString, int)", sCode, fid) if value == '0': self.logging.logger.debug("장 시작 전") elif value == '3': self.logging.logger.debug("장 시작") elif value == "2": self.logging.logger.debug("장 종료, 동시호가로 넘어감") elif value == "4": self.logging.logger.debug("3시30분 장 종료") for code in self.portfolio_stock_dict.keys(): self.dynamicCall("SetRealRemove(QString, QString)", self.portfolio_stock_dict[code]['스크린번호'], code) QTest.qWait(5000) self.file_delete() self.calculator_fnc() sys.exit() elif sRealType == "주식체결": a = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['체결시간']) # 출력 HHMMSS b = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['현재가']) # 출력 : +(-)2520 b = abs(int(b)) c = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['전일대비']) # 출력 : +(-)2520 c = abs(int(c)) d = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['등락율']) # 출력 : +(-)12.98 d = float(d) e = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['(최우선)매도호가']) # 출력 : +(-)2520 e = abs(int(e)) f = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['(최우선)매수호가']) # 출력 : +(-)2515 f = abs(int(f)) g = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['거래량']) # 출력 : +240124 매수일때, -2034 매도일 때 g = abs(int(g)) h = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['누적거래량']) # 출력 : 240124 h = abs(int(h)) i = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['고가']) # 출력 : +(-)2530 i = abs(int(i)) j = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['시가']) # 출력 : +(-)2530 j = abs(int(j)) k = self.dynamicCall("GetCommRealData(QString, int)", sCode, self.realType.REALTYPE[sRealType]['저가']) # 출력 : +(-)2530 k = abs(int(k)) if sCode not in self.portfolio_stock_dict: self.portfolio_stock_dict.update({sCode:{}}) self.portfolio_stock_dict[sCode].update({"체결시간": a}) self.portfolio_stock_dict[sCode].update({"현재가": b}) self.portfolio_stock_dict[sCode].update({"전일대비": c}) self.portfolio_stock_dict[sCode].update({"등락율": d}) self.portfolio_stock_dict[sCode].update({"(최우선)매도호가": e}) self.portfolio_stock_dict[sCode].update({"(최우선)매수호가": f}) self.portfolio_stock_dict[sCode].update({"거래량": g}) self.portfolio_stock_dict[sCode].update({"누적거래량": h}) self.portfolio_stock_dict[sCode].update({"고가": i}) self.portfolio_stock_dict[sCode].update({"시가": j}) self.portfolio_stock_dict[sCode].update({"저가": k}) if sCode in self.account_stock_dict.keys() and sCode not in self.jango_dict.keys(): asd = self.account_stock_dict[sCode] meme_rate = (b - asd['매입가']) / asd['매입가'] * 100 if asd['매매가능수량'] > 0 and (meme_rate > 5 or meme_rate < -5): order_success = self.dynamicCall( "SendOrder(QString, QString, QString, int, QString, int, int, QString, QString)", ["신규매도", self.portfolio_stock_dict[sCode]["주문용스크린번호"], self.account_num, 2, sCode, asd['매매가능수량'], 0, self.realType.SENDTYPE['거래구분']['시장가'], ""] ) if order_success == 0: self.logging.logger.debug("매도주문 전달 성공") del self.account_stock_dict[sCode] else: self.logging.logger.debug("매도주문 전달 실패") elif sCode in self.jango_dict.keys(): jd = self.jango_dict[sCode] meme_rate = (b - jd['매입단가']) / jd['매입단가'] * 100 if jd['주문가능수량'] > 0 and (meme_rate > 5 or meme_rate < -5): order_success = self.dynamicCall( "SendOrder(QString, QString, QString, int, QString, int, int, QString, QString)", ["신규매도", self.portfolio_stock_dict[sCode]["주문용스크린번호"], self.account_num, 2, sCode, jd['주문가능수량'], 0, self.realType.SENDTYPE['거래구분']['시장가'], ""] ) if order_success == 0: self.logging.logger.debug("매도주문 전달 성공") else: self.logging.logger.debug("매도주문 전달 실패") elif d > 2.0 and sCode not in self.jango_dict: self.logging.logger.debug("매수조건 통과 %s " % sCode) result = (self.use_money * 0.1) / e quantity = int(result) order_success = self.dynamicCall( "SendOrder(QString, QString, QString, int, QString, int, int, QString, QString)", ["신규매수", self.portfolio_stock_dict[sCode]["주문용스크린번호"], self.account_num, 1, sCode, quantity, e, self.realType.SENDTYPE['거래구분']['지정가'], ""] ) if order_success == 0: self.logging.logger.debug("매수주문 전달 성공") else: self.logging.logger.debug("매수주문 전달 실패") not_meme_list = list(self.not_account_stock_dict) for order_num in not_meme_list: code = self.not_account_stock_dict[order_num]["종목코드"] meme_price = self.not_account_stock_dict[order_num]['주문가격'] not_quantity = self.not_account_stock_dict[order_num]['미체결수량'] order_gubun = self.not_account_stock_dict[order_num]['주문구분'] if order_gubun == "매수" and not_quantity > 0 and e > meme_price: order_success = self.dynamicCall( "SendOrder(QString, QString, QString, int, QString, int, int, QString, QString)", ["매수취소", self.portfolio_stock_dict[sCode]["주문용스크린번호"], self.account_num, 3, code, 0, 0, self.realType.SENDTYPE['거래구분']['지정가'], order_num] ) if order_success == 0: self.logging.logger.debug("매수취소 전달 성공") else: self.logging.logger.debug("매수취소 전달 실패") elif not_quantity == 0: del self.not_account_stock_dict[order_num] # 실시간 체결 정보 def chejan_slot(self, sGubun, nItemCnt, sFidList): if int(sGubun) == 0: #주문체결 account_num = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['계좌번호']) sCode = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['종목코드'])[1:] stock_name = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['종목명']) stock_name = stock_name.strip() origin_order_number = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['원주문번호']) # 출력 : defaluse : "000000" order_number = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문번호']) # 출럭: 0115061 마지막 주문번호 order_status = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문상태']) # 출력: 접수, 확인, 체결 order_quan = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문수량']) # 출력 : 3 order_quan = int(order_quan) order_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문가격']) # 출력: 21000 order_price = int(order_price) not_chegual_quan = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['미체결수량']) # 출력: 15, default: 0 not_chegual_quan = int(not_chegual_quan) order_gubun = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문구분']) # 출력: -매도, +매수 order_gubun = order_gubun.strip().lstrip('+').lstrip('-') chegual_time_str = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['주문/체결시간']) # 출력: '151028' chegual_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['체결가']) # 출력: 2110 default : '' if chegual_price == '': chegual_price = 0 else: chegual_price = int(chegual_price) chegual_quantity = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['체결량']) # 출력: 5 default : '' if chegual_quantity == '': chegual_quantity = 0 else: chegual_quantity = int(chegual_quantity) current_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['현재가']) # 출력: -6000 current_price = abs(int(current_price)) first_sell_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['(최우선)매도호가']) # 출력: -6010 first_sell_price = abs(int(first_sell_price)) first_buy_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['주문체결']['(최우선)매수호가']) # 출력: -6000 first_buy_price = abs(int(first_buy_price)) ######## 새로 들어온 주문이면 주문번호 할당 if order_number not in self.not_account_stock_dict.keys(): self.not_account_stock_dict.update({order_number: {}}) self.not_account_stock_dict[order_number].update({"종목코드": sCode}) self.not_account_stock_dict[order_number].update({"주문번호": order_number}) self.not_account_stock_dict[order_number].update({"종목명": stock_name}) self.not_account_stock_dict[order_number].update({"주문상태": order_status}) self.not_account_stock_dict[order_number].update({"주문수량": order_quan}) self.not_account_stock_dict[order_number].update({"주문가격": order_price}) self.not_account_stock_dict[order_number].update({"미체결수량": not_chegual_quan}) self.not_account_stock_dict[order_number].update({"원주문번호": origin_order_number}) self.not_account_stock_dict[order_number].update({"주문구분": order_gubun}) self.not_account_stock_dict[order_number].update({"주문/체결시간": chegual_time_str}) self.not_account_stock_dict[order_number].update({"체결가": chegual_price}) self.not_account_stock_dict[order_number].update({"체결량": chegual_quantity}) self.not_account_stock_dict[order_number].update({"현재가": current_price}) self.not_account_stock_dict[order_number].update({"(최우선)매도호가": first_sell_price}) self.not_account_stock_dict[order_number].update({"(최우선)매수호가": first_buy_price}) elif int(sGubun) == 1: #잔고 account_num = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['계좌번호']) sCode = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['종목코드'])[1:] stock_name = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['종목명']) stock_name = stock_name.strip() current_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['현재가']) current_price = abs(int(current_price)) stock_quan = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['보유수량']) stock_quan = int(stock_quan) like_quan = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['주문가능수량']) like_quan = int(like_quan) buy_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['매입단가']) buy_price = abs(int(buy_price)) total_buy_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['총매입가']) # 계좌에 있는 종목의 총매입가 total_buy_price = int(total_buy_price) meme_gubun = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['매도매수구분']) meme_gubun = self.realType.REALTYPE['매도수구분'][meme_gubun] first_sell_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['(최우선)매도호가']) first_sell_price = abs(int(first_sell_price)) first_buy_price = self.dynamicCall("GetChejanData(int)", self.realType.REALTYPE['잔고']['(최우선)매수호가']) first_buy_price = abs(int(first_buy_price)) if sCode not in self.jango_dict.keys(): self.jango_dict.update({sCode:{}}) self.jango_dict[sCode].update({"현재가": current_price}) self.jango_dict[sCode].update({"종목코드": sCode}) self.jango_dict[sCode].update({"종목명": stock_name}) self.jango_dict[sCode].update({"보유수량": stock_quan}) self.jango_dict[sCode].update({"주문가능수량": like_quan}) self.jango_dict[sCode].update({"매입단가": buy_price}) self.jango_dict[sCode].update({"총매입가": total_buy_price}) self.jango_dict[sCode].update({"매도매수구분": meme_gubun}) self.jango_dict[sCode].update({"(최우선)매도호가": first_sell_price}) self.jango_dict[sCode].update({"(최우선)매수호가": first_buy_price}) if stock_quan == 0: del self.jango_dict[sCode] #송수신 메세지 get def msg_slot(self, sScrNo, sRQName, sTrCode, msg): self.logging.logger.debug("스크린: %s, 요청이름: %s, tr코드: %s --- %s" %(sScrNo, sRQName, sTrCode, msg)) # def talk_kakao(self): #파일 삭제 def file_delete(self): if os.path.isfile("files/condition_stock.txt"): os.remove("files/condition_stock.txt") [ 주식 자동화 결과 내용 ] [ kakao.py ]import requests import json class Kakao(): with open("C:/Users/황용하/PycharmProjects/stockAutoSystem/files/kakao_token.json","r") as fp: tokens = json.load(fp) url="https://kapi.kakao.com/v2/api/talk/memo/default/send" # kapi.kakao.com/v2/api/talk/memo/default/send headers={ "Authorization" : "Bearer " + tokens["access_token"] } data={ "template_object": json.dumps({ "object_type": "text", "text": "안녕? 나는 [키움증권] 주식자동화 AI도우미 '오래오' 라고해!!", "link": { "web_url" : "헤헤. text와 link 객체는 필수로 넣어야 하는 거구나? button_title과 buttons는 안 넣어도 상관 없지만 말이야!", "mobile_web_url" : "헤헤. text와 link 객체는 필수로 넣어야 하는 거구나? button_title과 buttons는 안 넣어도 상관 없지만 말이야!" }, "button_title" : "오레오" }) } response = requests.post(url, headers=headers, data=data) response.status_code if response.json().get('result_code') == 0: print('메시지를 성공적으로 보냈습니다.') else: print('메시지를 성공적으로 보내지 못했습니다. 오류메시지 : ' + str(response.json())) [ kakao_Config.py ] 카톡 서비스 이용을 위한 token.json을 write 해주는 코드입니다import requests import json url = 'https://kauth.kakao.com/oauth/token' rest_api_key = '8768214aa18b82395dab6a99e62bbed7' redirect_uri = 'https://localhost.com' authorize_code = 'HRA5Sx60E1tHszc_--FeJyqTy20czOEVpDUN0gopcBQAAAF-4sVxiQ' data = { "grant_type": "authorization_code", "client_id": "8768214aa18b82395dab6a99e62bbed7", "redirect_uri": "https://localhost.com", "code": "1dYOV_88X-wOhQUyANj-2bLA2C4Feisx-zX5knRijxGWwmnCVeOo9rxIeoC-736eSGkvjAopyV8AAAF-4sNNgQ" } response = requests.post(url, data=data) tokens = response.json() print(tokens) with open("/files/kakao_token.json", "w") as fp: json.dump(tokens, fp) 카톡 메시지 전송 성공 사진입니다 도와주십쇼 ㅠㅠ

페코옹 · Answer

엄청나군요 근데 key는 지우고 올리세요

슈퍼셀 · Answer

어이쿠야..^^

[파이썬] 키움증권 주식자동화 카톡(나와의채팅)으로 보내기 질문입니다

2개의 답변

Q&A 목록