Open API

# 현재가 조회: GET /market/v1/prices
res = call("GET", "/market/v1/prices", {"mrkt_div_code": "J", "iscd": "138040"})
p = res["data"]
print(p["kor_isnm"], p["stck_prpr"], "전일대비", p["prdy_vrss"], f"({p['prdy_ctrt']}%)", "누적거래량", p["acml_vol"])
print("시가", p["oprc"], "고가", p["hprc"], "저가", p["lprc"], "상한가", p["mxpr"], "하한가", p["llam"], "PER", p["per"])

# 일봉 조회: GET /market/v1/candles/days. 최근 일자부터 내려오며, 장 마감 후에는 당일 봉도 포함됩니다
res = call("GET", "/market/v1/candles/days", {"mrkt_div_code": "J", "iscd": "138040"})
for row in res["data"][:5]:
    print(row["date"], "시가", row["oprc"], "고가", row["hprc"], "저가", row["lprc"],
          "종가", row["stck_clpr"], "거래량", row["acml_vol"])

import datetime

# 매수 주문: POST /trading/v1/orders/buy. 매도는 /trading/v1/orders/sell 이고 본문은 같습니다
body = {
    "iscd": "A138040",           # 종목코드. 주문할 때는 "A" + 6자리
    "odqt": 1,                   # 주문수량
    "oder_unpr": 50000,          # 주문단가. 시장가("05")는 0
    "oder_cls_code": "01",       # 주문구분. 01 지정가, 05 시장가, 06 조건부지정가, 12 최유리, 13 최우선
    "oder_cond_cls_code": "0",   # 주문조건. 0 일반, 3 IOC, 4 FOK
    "orgl_oder_no": 0,           # 원주문번호. 신규 주문은 0
    "whol_rctf_cncl_yn": "N",    # 전체정정취소여부. 신규 주문은 "N"
    "warn_cnfr_yn": "N",         # 경고확인여부. 경고 응답을 확인하고 다시 보낼 때 "A"
    "exch_kind_code": "01",      # 거래소. 01 KRX, 02 NXT, 03 SOR
}
res = call("POST", "/trading/v1/orders/buy", body=body)
d = res["data"]
if d["warn_cls_code"] != "0":
    # 접수되지 않은 상태입니다. warn_msg 를 확인하고 동의한 뒤 warn_cnfr_yn="A" 로 같은 주문을 다시 보내면 접수됩니다
    print("경고", d["warn_cls_code"], d["warn_msg"])
else:
    print("주문 접수 완료, 주문번호", d["oder_no"])   # rsp_cd "0001" 은 접수가 됐다는 뜻이지 체결 확정이 아닙니다

# 주문내역 조회: GET /trading/v1/orders/history. 체결 수량과 미체결 수량을 확인합니다
today = datetime.date.today().strftime("%Y%m%d")
res = call("GET", "/trading/v1/orders/history",
           {"oder_date": today,          # 주문일자 YYYYMMDD
            "deal_cls_code": "0",        # 매매구분. 0 전체, 1 매도, 2 매수
            "cntg_cls_code": "0"})       # 체결구분. 0 전체, 1 체결 있음, 2 미체결 있음
for o in res["data"]:
    print(o["oder_no"], o["kor_issu_abwr_name"], "매수" if o["deal_cls_code"] == "2" else "매도",
          o["odqt"], "주 @", o["oder_unpr"], "체결", o["total_cntg_qty"], "미체결", o["ncnt_qty"])

# 호가 조회: GET /market/v1/orderbook
res = call("GET", "/market/v1/orderbook", {"mrkt_div_code": "J", "iscd": "138040"})
b = res["data"]
print("호가시각", b["prpr_hour"], "현재가", b["stck_prpr"])
print("매도1", b["askp"], b["askp_rsqn1"], "| 매수1", b["bidp"], b["bidp_rsqn1"])   # 1단계만 번호가 없습니다
for i in range(2, 11):
    print(f"매도{i}", b[f"askp{i}"], b[f"askp_rsqn{i}"], f"| 매수{i}", b[f"bidp{i}"], b[f"bidp_rsqn{i}"])
print("총매도잔량", b["total_askp_rsqn"], "총매수잔량", b["total_bidp_rsqn"])

# 예수금 상세: GET /accounts/v1/me/deposit. 요청 항목은 없고 data 는 객체입니다
dep = call("GET", "/accounts/v1/me/deposit")["data"]
print("예수금", dep["tfam"], "D+2 예수금", dep["d2_aft_tfam"],
      "출금가능", dep["drng_able_amt"], "주문가능현금", dep["oder_able_cash_amt"])

# 자산평가: GET /accounts/v1/me/valuation. 요청 항목은 없고 data 는 객체입니다
val = call("GET", "/accounts/v1/me/valuation")["data"]
print("총자산", val["aset_vltn_amt"], "주식평가", val["mksc_vltn_amt"], "매입금액", val["byng_amt"], "대출", val["loan_amt"])

# 보유종목별 평가: GET /accounts/v1/me/holdings. data 는 배열이고, nthn_rmnd_incu_yn 을 "Y" 로 보내면 잔고가 0 인 종목도 포함됩니다
rows = call("GET", "/accounts/v1/me/holdings", {"nthn_rmnd_incu_yn": "N"})["data"]
for h in rows:
    print(h["iscd"], h["isnm"], h["mksc_cls_name"], "수량", h["rmnd_qty"], "매입단가", h["byng_unpr"],
          "현재가", h["psnt_prc"], "평가금액", h["vltn_amt"], "평가손익", h["vltn_prls_amt"], f"({h['ert']}%)")

import json
import websocket   # pip install websocket-client

ws = websocket.create_connection(WS_URL, timeout=30)
ws.send(json.dumps({
    "header": {"token": f"Bearer {get_token()}", "tr_type": "1"},   # tr_type: 1 구독 등록, 2 구독 해지
    "body": {"tr_cd": "ohhts_stck_cntg", "tr_key": "138040"},       # 국내주식 체결(KRX). 종목코드 6자리
}))
try:
    while True:
        msg = json.loads(ws.recv())
        head = msg.get("header", {})
        if "rsp_cd" in head:                            # 구독 응답(ACK). 성공이면 "00000"
            if head["rsp_cd"] not in ("00000", "0000"):
                raise RuntimeError(f"구독 실패 {head['rsp_cd']} {head.get('rsp_msg')}")
            print("구독 완료")
            continue
        b = msg["body"]                                 # 체결 통보 (현재가 prpr, 건별 체결량 cntg_vol)
        print(b["bsop_hour"], "현재가", b["prpr"], "전일대비", b["prdy_vrss_sign"], b["prdy_vrss"],
              "체결량", b["cntg_vol"], "누적", b["acml_vol"], "매도1", b["askp1"], "매수1", b["bidp1"])
finally:
    ws.close()