⚠️【非推奨】FIX API入門③｜Python注文送信→ Python cBotを使おう

# 0.01ロットでゴールドを買う
new_order("XAUUSD", "BUY", 0.01)

# ❌ 文字列（動かない）
f"55=XAUUSD{SOH}"

# ✅ 数値ID
f"55=41{SOH}"

# 「0.01ロット買いたい」

# ❌ ロット数をそのまま（動かない）
f"38=0.01{SOH}"

# ❌ FXの計算式を全商品に適用（危険！）
qty = 0.01 * 100000  # = 1000
f"38=1000{SOH}"

【送信した内容】
38=1000（1000オンス）

【ブローカーの解釈】
1000オンス ÷ 100オンス/ロット = 10ロット

【必要証拠金】
$4,450 × 1000オンス ÷ 100(レバレッジ) = $44,500
約667万円

【口座残高】
250万円

【結果】
NOT_ENOUGH_MONEY 💀

def calculate_order_qty(symbol_id: int, lot_size: float) -> int:
    """商品タイプに応じたOrderQty計算"""

    # ゴールド (XAUUSD) - ID=41
    if symbol_id == 41:
        return int(lot_size * 100)     # 0.01 lot = 1

    # シルバー (XAGUSD) - ID=42
    elif symbol_id == 42:
        return int(lot_size * 5000)    # 0.01 lot = 50

    # 原油 (USOIL) - ID=43
    elif symbol_id == 43:
        return int(lot_size * 1000)    # 0.01 lot = 10

    # FX通貨ペア (デフォルト)
    else:
        return int(lot_size * 100000)  # 0.01 lot = 1000

def build_new_order(symbol_id: int, side: str, lot_size: float, order_type: int = 1):
    """
    NewOrderSingle (35=D) を組み立て

    Args:
        symbol_id: シンボルID（数値）
        side: "BUY" or "SELL"
        lot_size: ロット数（0.01など）
        order_type: 1=成行, 2=指値
    """
    global seq_num

    # ClOrdID（一意な注文ID）
    cl_ord_id = f"{symbol_id}_{int(time.time() * 1000)}"

    # Side: 1=BUY, 2=SELL
    side_code = "1" if side.upper() == "BUY" else "2"

    # OrderQty（商品別計算）
    qty = calculate_order_qty(symbol_id, lot_size)

    # ボディ組み立て
    body = (
        f"35=D{SOH}"
        f"49={SENDER_COMP_ID}{SOH}"
        f"56={TARGET_COMP_ID}{SOH}"
        f"57=TRADE{SOH}"
        f"34={seq_num}{SOH}"
        f"52={get_utc_timestamp()}{SOH}"
        f"11={cl_ord_id}{SOH}"        # ClOrdID
        f"55={symbol_id}{SOH}"         # Symbol（数値）
        f"54={side_code}{SOH}"         # Side
        f"38={qty}{SOH}"               # OrderQty（重要！）
        f"40={order_type}{SOH}"        # OrdType
        f"60={get_utc_timestamp()}{SOH}" # TransactTime
    )

    # ヘッダー + チェックサム
    body_length = len(body.encode('ascii'))
    header = f"8=FIX.4.4{SOH}9={body_length}{SOH}"
    msg_without_checksum = header + body
    checksum = calc_checksum(msg_without_checksum)

    seq_num += 1
    return msg_without_checksum + checksum, cl_ord_id

# ゴールド0.01ロット BUY
msg, order_id = build_new_order(symbol_id=41, side="BUY", lot_size=0.01)
send_message(trade_sock, msg)

# GBPUSD 0.05ロット SELL
msg, order_id = build_new_order(symbol_id=2, side="SELL", lot_size=0.05)
send_message(trade_sock, msg)

← 8=FIX.4.4|...|35=8|11=41_1704520800000|150=0|39=0|...
← 8=FIX.4.4|...|35=8|11=41_1704520800000|150=F|39=2|31=4452.02|721=1001179|...

def parse_execution_report(msg: str) -> dict:
    """ExecutionReportを解析"""
    fields = {}
    for part in msg.split(SOH):
        if "=" in part:
            tag, value = part.split("=", 1)
            fields[tag] = value

    exec_type = fields.get("150", "")
    ord_status = fields.get("39", "")

    result = {
        "cl_ord_id": fields.get("11", ""),
        "exec_type": exec_type,
        "ord_status": ord_status,
        "price": fields.get("31", ""),
        "qty": fields.get("32", ""),
        "position_id": fields.get("721", ""),  # ← 重要！
        "text": fields.get("58", ""),
    }

    # 状態判定
    if exec_type == "F" and ord_status == "2":
        result["status"] = "FILLED"
        print(f"🎉 約定成功！価格: {result['price']}, ポジションID: {result['position_id']}")
    elif exec_type == "8" or ord_status == "8":
        result["status"] = "REJECTED"
        print(f"❌ 拒否: {result['text']}")
    elif exec_type == "0":
        result["status"] = "NEW"
        print(f"📝 注文受付: {result['cl_ord_id']}")

    return result

58=NOT_ENOUGH_MONEY:Not enough funds

58=INVALID_VOLUME

58=MARKET_CLOSED

BUYポジションを決済 → SELL注文を送信
SELLポジションを決済 → BUY注文を送信

def build_close_order(symbol_id: int, position_id: str, qty: int, current_side: str):
    """
    決済注文を組み立て

    Args:
        symbol_id: シンボルID
        position_id: 決済するポジションID
        qty: 決済数量（OrderQty形式）
        current_side: 現在のポジション方向（"BUY" or "SELL"）
    """
    global seq_num

    # 反対売買
    close_side = "2" if current_side.upper() == "BUY" else "1"

    cl_ord_id = f"close_{position_id}_{int(time.time() * 1000)}"

    body = (
        f"35=D{SOH}"
        f"49={SENDER_COMP_ID}{SOH}"
        f"56={TARGET_COMP_ID}{SOH}"
        f"57=TRADE{SOH}"
        f"34={seq_num}{SOH}"
        f"52={get_utc_timestamp()}{SOH}"
        f"11={cl_ord_id}{SOH}"
        f"55={symbol_id}{SOH}"
        f"54={close_side}{SOH}"
        f"38={qty}{SOH}"
        f"40=1{SOH}"  # 成行
        f"60={get_utc_timestamp()}{SOH}"
        f"721={position_id}{SOH}"   # ← ポジションIDを指定
    )

    body_length = len(body.encode('ascii'))
    header = f"8=FIX.4.4{SOH}9={body_length}{SOH}"
    msg_without_checksum = header + body
    checksum = calc_checksum(msg_without_checksum)

    seq_num += 1
    return msg_without_checksum + checksum

# ゴールド0.01ロットのBUYポジション(ID=1001179)を決済
close_msg = build_close_order(
    symbol_id=41,
    position_id="1001179",
    qty=1,  # 0.01ロット = 1（ゴールド）
    current_side="BUY"
)
send_message(trade_sock, close_msg)

def build_position_request():
    """ポジション照会リクエスト"""
    global seq_num

    pos_req_id = str(int(time.time()))

    body = (
        f"35=AN{SOH}"
        f"49={SENDER_COMP_ID}{SOH}"
        f"56={TARGET_COMP_ID}{SOH}"
        f"57=TRADE{SOH}"
        f"34={seq_num}{SOH}"
        f"52={get_utc_timestamp()}{SOH}"
        f"710={pos_req_id}{SOH}"   # これだけ！
    )

    body_length = len(body.encode('ascii'))
    header = f"8=FIX.4.4{SOH}9={body_length}{SOH}"
    msg_without_checksum = header + body
    checksum = calc_checksum(msg_without_checksum)

    seq_num += 1
    return msg_without_checksum + checksum

# ❌ 全部非対応！
f"1={ACCOUNT}{SOH}"        # Account
f"263=1{SOH}"              # SubscriptionRequestType
f"453=1{SOH}"              # NoPartyIDs
f"724=0{SOH}"              # PosReqType

# ✅ タグ710だけ
f"710={pos_req_id}{SOH}"

# 1. ログオン
logon_msg = build_logon_message()
send_message(sock, logon_msg)
response = receive_message(sock)

# 2. ログオン確認
if "35=A" not in response:
    print("❌ ログオン失敗")
    return

# 3. 注文送信
order_msg, order_id = build_new_order(
    symbol_id=41,      # XAUUSD
    side="BUY",
    lot_size=0.01
)
send_message(sock, order_msg)

# 4. 約定確認（受信ループ）
position_id = None
while True:
    msg = receive_message(sock)
    if "35=8" in msg:
        result = parse_execution_report(msg)
        if result["status"] == "FILLED":
            position_id = result["position_id"]
            print(f"✅ 約定！ポジションID: {position_id}")
            break

# 5. 決済（必要なタイミングで）
if position_id:
    close_msg = build_close_order(
        symbol_id=41,
        position_id=position_id,
        qty=1,
        current_side="BUY"
    )
    send_message(sock, close_msg)

# FX通貨ペア
qty = int(lot_size * 100000)   # 0.01 = 1000

# ゴールド
qty = int(lot_size * 100)      # 0.01 = 1

# シルバー
qty = int(lot_size * 5000)     # 0.01 = 50

# 原油
qty = int(lot_size * 1000)     # 0.01 = 10