楽天証券で自動売買をPython自作する
MARKETSPEED II RSS × xlwingsで発注まで自動化する設計

xlwings>=0.31          # Excel操作（COM経由）
pandas>=2.2
numpy>=1.26
requests>=2.32         # Discord通知用
python-dotenv>=1.0

# 本コードは本人利用に限り自由に使用可。再配布・商用利用・販売は禁止。
import xlwings as xw

# すでに開いている bot.xlsx に接続する（新規に開かない）
book = xw.Book("bot.xlsx")

data  = book.sheets["data"]
order = book.sheets["order"]

# --- 読み取り ---
price = data.range("B2").value                 # 単一セル
table = data.range("A2:F50").value             # 範囲（リストのリストで返る）

# pandas DataFrame として読む（ヘッダ付きの表を想定）
import pandas as pd
df = data.range("A1").expand().options(pd.DataFrame, header=1, index=False).value

# --- 書き込み ---
order.range("B2").value = 7203                 # 銘柄コード
order.range("B3").value = 100                  # 数量

# --- 再計算を明示的に走らせる ---
book.app.calculate()

print(f"現在値: {price}")

# 本コードは本人利用に限り自由に使用可。再配布・商用利用・販売は禁止。
# MARKETSPEED II RSS を xlwings 経由で扱うためのラッパー。
# 注意：関数名・引数・セル配置は各自の環境と公式マニュアルに合わせて調整すること。
import time
import logging
from typing import Optional, Any

import xlwings as xw

log = logging.getLogger(__name__)


class RssError(RuntimeError):
    """RSSの状態異常（未接続・発注不可など）"""


class RssClient:
    def __init__(self, book_name: str = "bot.xlsx"):
        self.book = xw.Book(book_name)
        self.data = self.book.sheets["data"]
        self.order = self.book.sheets["order"]
        self.state = self.book.sheets["state"]

    # ---------- 状態確認 ----------
    def is_connected(self) -> bool:
        """RSSが接続中かどうか（接続ステータスを表示するセルを参照）"""
        return str(self.state.range("B1").value or "").strip() == "接続中"

    def is_orderable(self) -> bool:
        """発注可かどうか。別ブックを開くなどで落ちることがあるため毎回確認する"""
        return str(self.state.range("B2").value or "").strip() == "発注可"

    def assert_ready(self) -> None:
        if not self.is_connected():
            raise RssError("RSSが接続中ではありません。MARKETSPEED IIを確認してください。")
        if not self.is_orderable():
            raise RssError(
                "ステータスが『発注可』ではありません。"
                "別のExcelブックを開いた等で解除された可能性があります。"
                "自動で再有効化はせず、手動で状態を確認してください。"
            )

    # ---------- データ取得 ----------
    def wait_value(self, sheet, addr: str, timeout: float = 10.0,
                   interval: float = 0.3) -> Optional[Any]:
        """RSSは非同期取得のため、値が確定するまで待つ"""
        deadline = time.time() + timeout
        while time.time() < deadline:
            v = sheet.range(addr).value
            if v not in (None, "", 0):
                return v
            self.book.app.calculate()
            time.sleep(interval)
        log.warning("値の取得がタイムアウトしました: %s", addr)
        return None

    def get_price(self, code: int) -> Optional[float]:
        """銘柄コードをセットして現在値を読む"""
        self.data.range("B1").value = code
        self.book.app.calculate()
        v = self.wait_value(self.data, "B2")
        return float(v) if v is not None else None

    def get_buying_power(self) -> float:
        v = self.wait_value(self.state, "B5")
        return float(v) if v is not None else 0.0

    # ---------- 発注 ----------
    def send_order(self, order_id: str, code: int, side: str,
                   qty: int, price: Optional[float] = None) -> str:
        """
        発注セルに値を書き込んで注文を送信する。
        order_id は一意であること。同じIDでの再送は受け付けられない（＝冪等）。
        """
        self.assert_ready()

        if qty <= 0 or qty % 100 != 0:
            raise ValueError(f"数量が不正です（100株単位）: {qty}")

        self.order.range("B2").value = order_id
        self.order.range("B3").value = code
        self.order.range("B4").value = side               # "買" / "売"
        self.order.range("B5").value = qty
        self.order.range("B6").value = "指値" if price else "成行"
        self.order.range("B7").value = price if price else ""

        # 発注関数を評価させる
        self.book.app.calculate()

        # 結果セル（発注関数の戻り値）を待つ
        result = self.wait_value(self.order, "B10", timeout=15.0)
        log.info("発注結果 id=%s code=%s %s %s株 -> %s",
                 order_id, code, side, qty, result)
        return str(result) if result is not None else "UNKNOWN"

# 本コードは本人利用に限り自由に使用可。再配布・商用利用・販売は禁止。
import json
import logging
import os
import time
from datetime import datetime, date
from pathlib import Path

import requests
from dotenv import load_dotenv

from rss_client import RssClient, RssError

load_dotenv()
WEBHOOK = os.getenv("DISCORD_WEBHOOK_URL")

STATE_FILE = Path("state/sent_orders.json")   # 送信済み発注IDの永続化
KILL_FILE  = Path("KILL")                     # このファイルを置くと停止する
WATCH      = [7203, 6758, 9984]
MAX_ORDERS_PER_DAY = 5
CAPITAL    = 1_000_000
RISK_RATE  = 0.02

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s %(levelname)s %(message)s",
    handlers=[logging.FileHandler("logs/bot.log", encoding="utf-8"),
              logging.StreamHandler()],
)
log = logging.getLogger("bot")


def notify(msg: str) -> None:
    log.info(msg)
    if WEBHOOK:
        try:
            requests.post(WEBHOOK, json={"content": msg[:1900]}, timeout=10)
        except Exception as e:
            log.warning("通知失敗: %s", e)


def load_sent() -> set:
    if STATE_FILE.exists():
        return set(json.loads(STATE_FILE.read_text(encoding="utf-8")))
    return set()


def save_sent(sent: set) -> None:
    STATE_FILE.parent.mkdir(parents=True, exist_ok=True)
    STATE_FILE.write_text(json.dumps(sorted(sent), ensure_ascii=False),
                          encoding="utf-8")


def make_order_id(code: int, side: str, when: date, seq: int) -> str:
    """再起動しても同じ条件なら同じIDになるよう決定論的に採番する"""
    return f"{when:%Y%m%d}-{code}-{side}-{seq:03d}"


def should_buy(rss: RssClient, code: int) -> bool:
    """戦略ロジック。ここを差し替えて使う。"""
    price = rss.get_price(code)
    if price is None:
        return False
    # 例：終値が任意の閾値を上回ったら、など実際の条件に置き換える
    return False       # ← デフォルトでは発注しない（安全側）


def main() -> None:
    rss = RssClient("bot.xlsx")
    sent = load_sent()
    today = date.today()
    orders_today = sum(1 for x in sent if x.startswith(f"{today:%Y%m%d}"))

    notify(f"bot起動 / 本日の発注済み: {orders_today}件")

    while True:
        # --- キルスイッチ ---
        if KILL_FILE.exists():
            notify("KILLファイルを検出したため停止します。")
            break

        # --- 日次上限 ---
        if orders_today >= MAX_ORDERS_PER_DAY:
            notify(f"本日の発注上限({MAX_ORDERS_PER_DAY}件)に到達したため停止します。")
            break

        try:
            rss.assert_ready()
        except RssError as e:
            # 自動で復旧させない。人間が状態を確認するまで待機する
            notify(f"[停止] RSSの状態異常: {e}")
            break

        for code in WATCH:
            try:
                if not should_buy(rss, code):
                    continue

                price = rss.get_price(code)
                if not price:
                    continue

                # ロットは資金比リスクから算出し、100株単位に丸める
                stop_width = price * 0.05                 # 例：5%を損切り幅とする
                shares = int((CAPITAL * RISK_RATE) / stop_width // 100 * 100)
                if shares < 100:
                    log.info("%s: 必要リスク率に収まる数量が単元未満のため見送り", code)
                    continue

                oid = make_order_id(code, "BUY", today, orders_today + 1)
                if oid in sent:
                    log.info("%s: 送信済みのためスキップ", oid)
                    continue

                result = rss.send_order(oid, code, "買", shares, price=None)
                sent.add(oid)
                save_sent(sent)                # ← 発注直後に必ず永続化する
                orders_today += 1
                notify(f"発注 {oid} {code} 買 {shares}株 成行 -> {result}")

            except Exception as e:
                log.exception("銘柄%s の処理で例外: %s", code, e)
                notify(f"[エラー] {code}: {e}")

        time.sleep(30)

    notify("bot終了")


if __name__ == "__main__":
    main()