【Python×Discord】ラズパイトレーダー×Discord！定期レポート＆スラッシュコマンド遠隔操作で手元から完全制御する方法

【ラズパイ内のプロセス構成】

 [自動売買本体: Trade.py] (常駐)
    │ 5秒ごとのループで最新状況をアトミックにJSON書き出し
    ▼
 ./LogData/bot_status.json (状態データ)
 ./LogData/trade_control.json (制御フラグ)
    ▲
    ├─ [定期レポート: discord_report.py] (毎時0分にsystemdタイマー起動)
    │     Webhook経由で最新状況を1回POSTして即終了 (超軽量)
    │
    └─ [双方向Bot: discord_bot.py] (常駐)
          ・スラッシュコマンド受信（/status, /trade, /service, /reboot）
          ・15秒ごとの新着ポーリングで発注完了・実約定を即時通知

import json
import urllib.request
import os

# Webhook URLは環境変数から取得
WEBHOOK_URL = os.environ.get("DISCORD_WEBHOOK_URL")

def send_discord_report(status_data):
    """口座状態をEmbed形式でDiscordに送信する"""
    if not WEBHOOK_URL:
        print("Webhook URLが設定されていません")
        return

    # リッチな埋め込み(Embed)カードを作成
    embed = {
        "title": "📊 FX定期稼働レポート",
        "color": 0x2ecc71,  # 鮮やかなグリーン
        "fields": [
            {
                "name": "総資産 / 評価損益",
                "value": f"**{status_data['total_balance']:,}円** (損益: `{status_data['profit']:+,.0f}円`)",
                "inline": False
            },
            {
                "name": "証拠金 / 維持率",
                "value": f"拘束: `{status_data['used_margin']:,}円` | 維持率: **{status_data['margin_rate']:.1f}%**",
                "inline": False
            },
            {
                "name": "建玉数 / スワップ累計",
                "value": f"建玉: **{status_data['total_trades']}件** | スワップ: `{status_data['total_swap']:+,.0f}円`",
                "inline": False
            }
        ],
        "footer": {
            "text": f"最終更新: {status_data['updated_at']}"
        }
    }

    payload = {"embeds": [embed]}
    data = json.dumps(payload).encode("utf-8")

    req = urllib.request.Request(
        WEBHOOK_URL,
        data=data,
        headers={
            "Content-Type": "application/json",
            "User-Agent": "Mozilla/5.0 (compatible; FX-Trader-Bot/1.0)",
        },
        method="POST"
    )

    try:
        with urllib.request.urlopen(req, timeout=15) as resp:
            print(f"レポート送信成功: HTTP {resp.status}")
    except Exception as e:
        print(f"レポート送信エラー: {e}")

import os
import json
import asyncio
import subprocess
import discord
from discord import app_commands
from discord.ext import tasks

BOT_TOKEN = os.environ.get("DISCORD_BOT_TOKEN")
CHANNEL_ID = int(os.environ.get("DISCORD_CHANNEL_ID", "0"))
STATUS_FILE = "./LogData/bot_status.json"
CONTROL_FILE = "./LogData/trade_control.json"

class FXBotClient(discord.Client):
    def __init__(self):
        intents = discord.Intents.default()
        super().__init__(intents=intents)
        self.tree = app_commands.CommandTree(self)
        self.last_exec_time = ""

client = FXBotClient()

def load_status():
    """取引本体が書き出したJSONを読み込む"""
    try:
        with open(STATUS_FILE, "r", encoding="utf-8") as f:
            return json.load(f)
    except Exception:
        return None

# スラッシュコマンド: /status (口座状況確認)
@client.tree.command(name="status", description="現在の口座残高と稼働状況を確認します")
async def status_command(interaction: discord.Interaction):
    status = load_status()
    if not status:
        await interaction.response.send_message("⚠️ 状態ファイルを取得できませんでした。")
        return

    embed = discord.Embed(title="📊 口座・稼働ステータス", color=discord.Color.green())
    embed.add_field(name="総資産", value=f"**{status.get('total_balance', 0):,}円**", inline=True)
    embed.add_field(name="証拠金維持率", value=f"**{status.get('margin_rate', 0):.1f}%**", inline=True)
    embed.add_field(name="保有建玉", value=f"{status.get('total_trades', 0)}件", inline=True)
    embed.set_footer(text=f"更新日時: {status.get('updated_at', '-')}")
    await interaction.response.send_message(embed=embed)

# スラッシュコマンド: /trade (自動売買ON/OFF切り替え)
@client.tree.command(name="trade", description="自動売買の有効/無効を切り替えます")
@app_commands.choices(state=[
    app_commands.Choice(name="ON (自動売買有効)", value="ON"),
    app_commands.Choice(name="OFF (自動売買停止)", value="OFF")
])
async def trade_command(interaction: discord.Interaction, state: app_commands.Choice[str]):
    is_on = (state.value == "ON")
    try:
        with open(CONTROL_FILE, "w", encoding="utf-8") as f:
            json.dump({"trade_on": is_on}, f)
        emoji = "✅" if is_on else "⏸️"
        await interaction.response.send_message(f"{emoji} 自動売買を **【{state.value}】** に変更しました。")
    except Exception as e:
        await interaction.response.send_message(f"❌ 変更失敗: {e}")

# スラッシュコマンド: /reboot (ラズパイ再起動)
@client.tree.command(name="reboot", description="ラズパイ本体を再起動します")
async def reboot_command(interaction: discord.Interaction):
    await interaction.response.send_message("🔄 **ラズパイを再起動します...**")
    async def _do_reboot():
        await asyncio.sleep(2)
        subprocess.run(["sudo", "/sbin/reboot"])
    asyncio.create_task(_do_reboot())

# バックグラウンド監視ループ (約定の即時通知)
@tasks.loop(seconds=15)
async def check_new_executions():
    if not CHANNEL_ID:
        return
    channel = client.get_channel(CHANNEL_ID)
    if not channel:
        return

    status = load_status()
    if not status:
        return

    exec_history = status.get("execution_history", [])
    if not exec_history:
        return

    latest = exec_history[-1]
    if latest.get("time", "") > client.last_exec_time:
        if client.last_exec_time != "":
            pair = latest.get("pair", "")
            lot = latest.get("lot_diff", 0)
            is_buy = (latest.get("type") == "BuyFill")
            
            embed = discord.Embed(
                title=f"🎯 【約定通知】{pair} {'新規買い' if is_buy else '決済売'}",
                description=f"数量: `{abs(lot):g}Lot` @ `{latest.get('avg_price', 0):.3f}`\n時刻: {latest.get('time')}",
                color=discord.Color.blue() if is_buy else discord.Color.gold()
            )
            await channel.send(embed=embed)
        client.last_exec_time = latest.get("time", "")

@client.event()
async def on_ready():
    print(f"ログイン完了: {client.user}")
    await client.tree.sync()
    if not check_new_executions.is_running():
        check_new_executions.start()

if __name__ == "__main__":
    client.run(BOT_TOKEN)

# piユーザーに対して特定のsystemctlとrebootのみパスワード不要にする
pi ALL=(ALL) NOPASSWD: /bin/systemctl stop gmocoin-trader.service, /bin/systemctl start gmocoin-trader.service, /bin/systemctl restart gmocoin-trader.service, /bin/systemctl restart gmocoin-trader.service, /bin/systemctl is-active gmocoin-trader.service, /sbin/reboot, /sbin/shutdown