無料スワップ表示ツール「swap_checker」の使い方・ソースコード

import MetaTrader5 as mt5
import time
from datetime import datetime
import sys
import tkinter as tk
from tkinter import ttk, messagebox
import threading
import traceback

# 実行中のMT5プロセスを検出するためにpsutilライブラリを使用します
try:
    import psutil
except ImportError:
    psutil = None

# tksheetライブラリをインポート
# 事前に `pip install tksheet` を実行してください
try:
    import tksheet
except ImportError:
    messagebox.showerror(
        "ライブラリ不足",
        "tksheetライブラリが見つかりません。\nコマンドプロンプトで `pip install tksheet` を実行してインストールしてください。"
    )
    sys.exit(1)


# --- MT5ターミナル選択部分は変更なし ---
def _discover_terminals() -> list[str]:
    paths = []
    if psutil:
        for p in psutil.process_iter(attrs=["name", "exe"]):
            if "terminal64.exe" in (p.info.get("name") or "").lower():
                exe_path = p.info.get("exe")
                if exe_path and exe_path not in paths:
                    paths.append(exe_path)
    return paths

def choose_terminal() -> str | None:
    if not psutil:
         messagebox.showerror(
            "ライブラリ不足",
            "psutilライブラリが見つかりません。\nコマンドプロンプトで `pip install psutil` を実行してインストールしてください。"
        )
         return None
    root = tk.Tk()
    root.withdraw()
    win = tk.Toplevel(root)
    win.title("接続するMT5ターミナルを選択")
    win.grab_set()
    message_label = None
    def on_close():
        win.destroy()
        root.destroy()
    win.protocol("WM_DELETE_WINDOW", on_close)
    def populate_tree():
        nonlocal message_label
        if message_label and message_label.winfo_exists():
            message_label.destroy()
            message_label = None
        for i in tree.get_children():
            tree.delete(i)
        found_terminals = _discover_terminals()
        if not found_terminals:
            tree.grid_remove()
            message_label = ttk.Label(win, text="実行中のMT5ターミナルが見つかりません。\nMT5を起動後、「再読込」を押してください。")
            message_label.grid(row=0, column=0, columnspan=3, padx=10, pady=10)
            use_button.config(state="disabled")
            return
        tree.grid()
        is_data_found = False
        for exe in found_terminals:
            try:
                if mt5.initialize(path=exe):
                    acc = mt5.account_info()
                    if acc:
                        tree.insert("", tk.END, values=(exe, acc.login, acc.server, f"{acc.balance:.2f} {acc.currency}", acc.name))
                        is_data_found = True
                    mt5.shutdown()
            except Exception as e:
                print(f"ターミナルへの接続エラー {exe}: {e}")
        if not is_data_found:
            tree.grid_remove()
            message_label = ttk.Label(win, text="MT5アカウント情報が取得できませんでした。\nログイン状態を確認してください。")
            message_label.grid(row=0, column=0, columnspan=3, padx=10, pady=10)
            use_button.config(state="disabled")
        else:
            if tree.get_children():
                tree.selection_set(tree.get_children()[0])
            use_button.config(state="normal")
    cols = ("exe", "login", "server", "balance", "name")
    tree = ttk.Treeview(win, columns=cols, show="headings", height=8)
    col_widths = {"exe": 340, "login": 80, "server": 170, "balance": 120, "name": 150}
    for c in cols:
        tree.heading(c, text=c.capitalize())
        tree.column(c, width=col_widths[c], anchor="w", stretch=tk.FALSE)
    tree.grid(row=0, column=0, columnspan=3, padx=6, pady=6)
    selected_path: dict[str, str | None] = {"path": None}
    def _use_selection() -> None:
        if tree.selection():
            selected_path["path"] = tree.item(tree.selection()[0], "values")[0]
        win.destroy()
    button_frame = ttk.Frame(win)
    button_frame.grid(row=1, column=0, columnspan=3, pady=(0, 6), padx=6, sticky="e")
    ttk.Button(button_frame, text="再読込", command=populate_tree).pack(side="left", padx=(0, 5))
    use_button = ttk.Button(button_frame, text="このターミナルを使用", command=_use_selection)
    use_button.pack(side="left")
    populate_tree()
    win.wait_window()
    root.destroy()
    return selected_path["path"]


class SwapViewerApp:
    def __init__(self, terminal_path: str):
        self.path = terminal_path
        self.root = tk.Tk()
        self.root.title("MT5 スワップチェッカー")
        self.root.geometry("1450x600")

        self.timer_id = None
        self.current_data = []
        self.last_sort_col = "swap_both_1d_jpy"
        self.last_sort_reverse = True

        if not self._connect_mt5():
            self.root.destroy()
            return
        
        self._setup_ui()
        self.update_data()
        self.root.protocol("WM_DELETE_WINDOW", self._on_closing)

    def _connect_mt5(self) -> bool:
        if not mt5.initialize(path=self.path):
            messagebox.showerror("MT5接続エラー", f"MT5の初期化に失敗しました: {mt5.last_error()}")
            return False
        self.account_info = mt5.account_info()
        if not self.account_info:
            messagebox.showerror("MT5接続エラー", f"アカウント情報の取得に失敗しました: {mt5.last_error()}")
            mt5.shutdown()
            return False
        if self.account_info.currency != "JPY":
            messagebox.showwarning("口座通貨の確認", f"このツールの円換算機能は、口座通貨がJPYの場合に最適化されています。\n現在の口座通貨: {self.account_info.currency}")
        return True

    def _setup_ui(self):
        main_frame = ttk.Frame(self.root, padding=10)
        main_frame.pack(fill=tk.BOTH, expand=True)
        top_frame = ttk.Frame(main_frame)
        top_frame.pack(fill=tk.X, pady=(0, 5))
        conn_text = f"接続先: {self.account_info.server} ({self.account_info.login})"
        ttk.Label(top_frame, text=conn_text, font=("Meiryo", 10)).pack(side=tk.LEFT)
        self.last_updated_var = tk.StringVar(value="最終更新: ----/--/-- --:--:--")
        ttk.Label(top_frame, textvariable=self.last_updated_var).pack(side=tk.RIGHT)
        
        sheet_frame = ttk.Frame(main_frame) 
        sheet_frame.pack(fill=tk.BOTH, expand=True)
        
        self.columns = {
            "symbol":           ("通貨ペア", 110, "w"),
            "swap_long_pts":    ("買いスワップ(Pts/%)", 150, "e"), "swap_short_pts": ("売りスワップ(Pts/%)", 150, "e"),
            "swap_long_jpy":    ("1Lot損益(買/円)", 140, "e"), "swap_short_jpy": ("1Lot損益(売/円)", 140, "e"),
            "swap_both_1d_jpy": ("1日両建て損益(円)", 160, "e"), "rollover_day": ("3倍デー適用曜日", 130, "center"),
            "swap_long_3d":     ("3倍デー(買/円)", 140, "e"), "swap_short_3d":     ("3倍デー(売/円)", 140, "e"),
            "swap_both_3d_jpy": ("3倍デー両建て損益(円)", 180, "e"),
        }
        
        self.sheet = tksheet.Sheet(sheet_frame,
                                   headers=[h for h, w, a in self.columns.values()],
                                   show_toolbar=False,
                                   show_top_left=False)
        self.sheet.pack(fill=tk.BOTH, expand=True)
        self.sheet.enable_bindings("single_select", "drag_select", "ctrl_select", "arrowkeys", "right_click_popup_menu", "rc_select")
        
        for i, (col_id, (header, width, anchor)) in enumerate(self.columns.items()):
            align = "w" if anchor == "w" else "e" if anchor == "e" else "center"
            self.sheet.column_width(column=i, width=width)
            self.sheet.align_columns(columns=i, align=align)

        
        # ヘッダークリックのイベント登録を削除
        
        # --- 下部コントロールパネル ---
        bottom_frame = ttk.Frame(main_frame)
        bottom_frame.pack(fill=tk.X, pady=(5, 0))
        
        # 更新ボタン
        self.update_button = ttk.Button(bottom_frame, text="手動更新", command=self.update_data)
        self.update_button.pack(side=tk.LEFT, padx=(0, 10))

        
        # 手動ソート機能のUIを追加
        sort_frame = ttk.Frame(bottom_frame)
        sort_frame.pack(side=tk.LEFT)
        
        ttk.Label(sort_frame, text="並べ替え:").pack(side=tk.LEFT, padx=(0, 5))

        # 表示名と内部IDの対応辞書を作成
        self.col_display_to_id = {v[0]: k for k, v in self.columns.items()}
        
        # ソート列選択のプルダウンメニュー
        self.sort_combo_var = tk.StringVar()
        self.sort_combo = ttk.Combobox(sort_frame, textvariable=self.sort_combo_var,
                                       values=[v[0] for v in self.columns.values()],
                                       state="readonly", width=25)
        self.sort_combo.set(self.columns[self.last_sort_col][0]) # 初期値を設定
        self.sort_combo.pack(side=tk.LEFT, padx=(0, 5))
        self.sort_combo.bind("<<ComboboxSelected>>", self._on_sort_combo_select)
        
        # 降順/昇順 切り替えボタン
        self.sort_order_button = ttk.Button(sort_frame, text="降順", command=self._on_sort_order_toggle, width=6)
        self.sort_order_button.pack(side=tk.LEFT)
        
        # ステータス表示
        self.status_var = tk.StringVar(value="準備完了")
        ttk.Label(bottom_frame, textvariable=self.status_var).pack(side=tk.LEFT, padx=20)
    
    
    # プルダウンメニューが選択された時の処理
    def _on_sort_combo_select(self, event=None):
        selected_display_name = self.sort_combo_var.get()
        new_sort_col = self.col_display_to_id[selected_display_name]
        self._sort_column(new_sort_col, keep_direction=True) # 並び順は維持したまま列を切り替え

    
    # 降順/昇順ボタンが押された時の処理
    def _on_sort_order_toggle(self, event=None):
        # 昇順/降順を反転させる
        self.last_sort_reverse = not self.last_sort_reverse
        # 現在選択されている列で再ソートを実行
        self._sort_column(self.last_sort_col, keep_direction=True)
        
    def _fetch_data_thread(self):
        
        try:
            all_symbols = mt5.symbols_get()
            if not all_symbols:
                self.root.after(0, self._update_gui_with_error, "エラー: 通貨ペアリストの取得に失敗。")
                return
            
            visible_symbols = [s for s in all_symbols if s.visible]
            if not visible_symbols:
                self.root.after(0, self._update_gui_with_error, "エラー: MT5の「気配値表示」に通貨ペアを追加してください。")
                return

            all_data = []
            weekdays = ["日", "月", "火", "水", "木", "金", "土"]

            for info in visible_symbols:
                tick = mt5.symbol_info_tick(info.name)
                if not tick or tick.bid == 0 or tick.ask == 0:
                    continue

                swap_long_jpy = 0.0
                swap_short_jpy = 0.0

                if info.swap_mode == mt5.SYMBOL_SWAP_MODE_POINTS:
                    tick_value = info.trade_tick_value
                    swap_long_jpy = info.swap_long * tick_value
                    swap_short_jpy = info.swap_short * tick_value
                elif info.swap_mode in [3, 5]:
                    swap_long_profit_ccy = 1.0 * info.trade_contract_size * tick.ask * (info.swap_long / 100) / 360
                    swap_short_profit_ccy = 1.0 * info.trade_contract_size * tick.bid * (info.swap_short / 100) / 360
                    if info.currency_profit != self.account_info.currency:
                        conversion_pair = info.currency_profit + self.account_info.currency
                        conversion_tick = mt5.symbol_info_tick(conversion_pair)
                        if conversion_tick and conversion_tick.bid > 0:
                            swap_long_jpy = swap_long_profit_ccy * conversion_tick.bid
                            swap_short_jpy = swap_short_profit_ccy * conversion_tick.bid
                        else:
                            continue
                    else:
                        swap_long_jpy = swap_long_profit_ccy
                        swap_short_jpy = swap_short_profit_ccy
                else:
                    continue
                
                all_data.append({
                    "symbol": info.name,
                    "swap_long_pts": info.swap_long, "swap_short_pts": info.swap_short,
                    "swap_long_jpy": swap_long_jpy, "swap_short_jpy": swap_short_jpy,
                    "swap_both_1d_jpy": swap_long_jpy + swap_short_jpy,
                    "rollover_day": weekdays[info.swap_rollover3days],
                    "swap_long_3d": swap_long_jpy * 3, "swap_short_3d": swap_short_jpy * 3,
                    "swap_both_3d_jpy": (swap_long_jpy + swap_short_jpy) * 3,
                    "swap_mode": info.swap_mode
                })
            
            self.root.after(0, self._update_gui, all_data)
        except Exception:
            traceback.print_exc()
            self.root.after(0, self._update_gui_with_error, "エラーが発生。詳細はコンソールを確認。")

    def _format_value(self, value, format_spec, is_jpy=False):
        unit = " 円" if is_jpy else ""
        if value == 0: return f"{value:{format_spec}}{unit}"
        return f"{value:+{format_spec}}{unit}"
    
    def _format_swap_points(self, value, mode):
        if mode in [3, 5]:
            return f"{value:+.3f} %"
        return f"{value:+.3f}"

    def _update_gui(self, data_list):
        self.current_data = data_list
        self._sort_column(self.last_sort_col, keep_direction=True)
        self.last_updated_var.set(f"最終更新: {datetime.now().strftime('%Y/%m/%d %H:%M:%S')}")
        self.status_var.set(f"データ取得完了。{len(data_list)}件の通貨ペアを表示中。")
        self.update_button.config(state="normal")

    def _redraw_view(self):
        
        if not self.current_data:
            self.sheet.set_sheet_data(data=[[]])
            return

        formatted_data = []
        for data in self.current_data:
            row = [
                data["symbol"],
                self._format_swap_points(data["swap_long_pts"], data["swap_mode"]),
                self._format_swap_points(data["swap_short_pts"], data["swap_mode"]),
                self._format_value(data["swap_long_jpy"], ",.2f", True),
                self._format_value(data["swap_short_jpy"], ",.2f", True),
                self._format_value(data["swap_both_1d_jpy"], ",.2f", True),
                data["rollover_day"],
                self._format_value(data["swap_long_3d"], ",.2f", True),
                self._format_value(data["swap_short_3d"], ",.2f", True),
                self._format_value(data["swap_both_3d_jpy"], ",.2f", True)
            ]
            formatted_data.append(row)

        self.sheet.set_sheet_data(data=formatted_data, redraw=False)

        color_target_cols = [
            "swap_long_pts", "swap_short_pts", "swap_long_jpy", "swap_short_jpy",
            "swap_both_1d_jpy", "swap_long_3d", "swap_short_3d", "swap_both_3d_jpy"
        ]
        
        col_id_to_index = {col_id: i for i, col_id in enumerate(self.columns.keys())}

        for r, data_row in enumerate(self.current_data):
            for col_id in color_target_cols:
                c = col_id_to_index[col_id]
                value = data_row[col_id]
                color = ""
                if value > 0:
                    color = "blue"
                elif value < 0:
                    color = "red"
                
                if color:
                    self.sheet.highlight_cells(row=r, column=c, fg=color)

        self.sheet.redraw()


    def _sort_column(self, col, keep_direction=False):
        if not self.current_data:
            return
        
        if not keep_direction:
            # この関数が直接呼ばれることはなくなったが念のため残す
            if self.last_sort_col == col:
                self.last_sort_reverse = not self.last_sort_reverse
            else:
                self.last_sort_reverse = True
        
        self.last_sort_col = col
        is_numeric = col not in ["symbol", "rollover_day"]
        
        key_func = (lambda d: d.get(col, 0)) if is_numeric else (lambda d: str(d.get(col, '')))
        self.current_data.sort(key=key_func, reverse=self.last_sort_reverse)
        
        # ソートボタンのテキストを現在の状態に合わせて更新
        self.sort_order_button.config(text="降順" if self.last_sort_reverse else "昇順")
        
        self._redraw_view()

    def _update_gui_with_error(self, message):
        self.sheet.set_sheet_data(data=[[]])
        self.status_var.set(message)
        self.update_button.config(state="normal")

    def update_data(self):
        self.status_var.set("データを取得中...")
        self.update_button.config(state="disabled")
        thread = threading.Thread(target=self._fetch_data_thread, daemon=True)
        thread.start()
        if self.timer_id: self.root.after_cancel(self.timer_id)
        self.timer_id = self.root.after(3600000, self.update_data)

    def _on_closing(self):
        if messagebox.askokcancel("終了確認", "アプリケーションを終了しますか？"):
            if self.timer_id: self.root.after_cancel(self.timer_id)
            mt5.shutdown()
            self.root.destroy()
            print("MT5との接続をシャットダウンしました。")

    def run(self):
        self.root.mainloop()

def main():
    terminal_path = choose_terminal()
    if not terminal_path:
        print("MT5ターミナルが選択されませんでした。プログラムを終了します。")
        sys.exit(0)
    app = SwapViewerApp(terminal_path)
    app.run()

if __name__ == "__main__":
    main()

import MetaTrader5 as mt5
import time
from datetime import datetime
import sys
import tkinter as tk
from tkinter import ttk, messagebox, filedialog # <<< 変更/追加: filedialogを追加
import threading
import traceback
import csv # <<< 追加: CSVライブラリをインポート

# 実行中のMT5プロセスを検出するためにpsutilライブラリを使用します
try:
    import psutil
except ImportError:
    psutil = None

# tksheetライブラリをインポート
# 事前に `pip install tksheet` を実行してください
try:
    import tksheet
except ImportError:
    messagebox.showerror(
        "ライブラリ不足",
        "tksheetライブラリが見つかりません。\nコマンドプロンプトで `pip install tksheet` を実行してインストールしてください。"
    )
    sys.exit(1)


# --- MT5ターミナル選択部分は変更なし ---
def _discover_terminals() -> list[str]:
    paths = []
    if psutil:
        for p in psutil.process_iter(attrs=["name", "exe"]):
            if "terminal64.exe" in (p.info.get("name") or "").lower():
                exe_path = p.info.get("exe")
                if exe_path and exe_path not in paths:
                    paths.append(exe_path)
    return paths

def choose_terminal() -> str | None:
    if not psutil:
         messagebox.showerror(
            "ライブラリ不足",
            "psutilライブラリが見つかりません。\nコマンドプロンプトで `pip install psutil` を実行してインストールしてください。"
        )
         return None
    root = tk.Tk()
    root.withdraw()
    win = tk.Toplevel(root)
    win.title("接続するMT5ターミナルを選択")
    win.grab_set()
    message_label = None
    def on_close():
        win.destroy()
        root.destroy()
    win.protocol("WM_DELETE_WINDOW", on_close)
    def populate_tree():
        nonlocal message_label
        if message_label and message_label.winfo_exists():
            message_label.destroy()
            message_label = None
        for i in tree.get_children():
            tree.delete(i)
        found_terminals = _discover_terminals()
        if not found_terminals:
            tree.grid_remove()
            message_label = ttk.Label(win, text="実行中のMT5ターミナルが見つかりません。\nMT5を起動後、「再読込」を押してください。")
            message_label.grid(row=0, column=0, columnspan=3, padx=10, pady=10)
            use_button.config(state="disabled")
            return
        tree.grid()
        is_data_found = False
        for exe in found_terminals:
            try:
                if mt5.initialize(path=exe):
                    acc = mt5.account_info()
                    if acc:
                        tree.insert("", tk.END, values=(exe, acc.login, acc.server, f"{acc.balance:.2f} {acc.currency}", acc.name))
                        is_data_found = True
                    mt5.shutdown()
            except Exception as e:
                print(f"ターミナルへの接続エラー {exe}: {e}")
        if not is_data_found:
            tree.grid_remove()
            message_label = ttk.Label(win, text="MT5アカウント情報が取得できませんでした。\nログイン状態を確認してください。")
            message_label.grid(row=0, column=0, columnspan=3, padx=10, pady=10)
            use_button.config(state="disabled")
        else:
            if tree.get_children():
                tree.selection_set(tree.get_children()[0])
            use_button.config(state="normal")
    cols = ("exe", "login", "server", "balance", "name")
    tree = ttk.Treeview(win, columns=cols, show="headings", height=8)
    col_widths = {"exe": 340, "login": 80, "server": 170, "balance": 120, "name": 150}
    for c in cols:
        tree.heading(c, text=c.capitalize())
        tree.column(c, width=col_widths[c], anchor="w", stretch=tk.FALSE)
    tree.grid(row=0, column=0, columnspan=3, padx=6, pady=6)
    selected_path: dict[str, str | None] = {"path": None}
    def _use_selection() -> None:
        if tree.selection():
            selected_path["path"] = tree.item(tree.selection()[0], "values")[0]
        win.destroy()
    button_frame = ttk.Frame(win)
    button_frame.grid(row=1, column=0, columnspan=3, pady=(0, 6), padx=6, sticky="e")
    ttk.Button(button_frame, text="再読込", command=populate_tree).pack(side="left", padx=(0, 5))
    use_button = ttk.Button(button_frame, text="このターミナルを使用", command=_use_selection)
    use_button.pack(side="left")
    populate_tree()
    win.wait_window()
    root.destroy()
    return selected_path["path"]


class SwapViewerApp:
    def __init__(self, terminal_path: str):
        self.path = terminal_path
        self.root = tk.Tk()
        self.root.title("MT5 スワップチェッカー")
        self.root.geometry("1450x600")

        self.timer_id = None
        self.current_data = []
        self.last_sort_col = "swap_both_1d_jpy"
        self.last_sort_reverse = True

        if not self._connect_mt5():
            self.root.destroy()
            return

        self._setup_ui()
        self.update_data()
        self.root.protocol("WM_DELETE_WINDOW", self._on_closing)

    def _connect_mt5(self) -> bool:
        if not mt5.initialize(path=self.path):
            messagebox.showerror("MT5接続エラー", f"MT5の初期化に失敗しました: {mt5.last_error()}")
            return False
        self.account_info = mt5.account_info()
        if not self.account_info:
            messagebox.showerror("MT5接続エラー", f"アカウント情報の取得に失敗しました: {mt5.last_error()}")
            mt5.shutdown()
            return False
        if self.account_info.currency != "JPY":
            messagebox.showwarning("口座通貨の確認", f"このツールの円換算機能は、口座通貨がJPYの場合に最適化されています。\n現在の口座通貨: {self.account_info.currency}")
        return True

    def _setup_ui(self):
        main_frame = ttk.Frame(self.root, padding=10)
        main_frame.pack(fill=tk.BOTH, expand=True)
        top_frame = ttk.Frame(main_frame)
        top_frame.pack(fill=tk.X, pady=(0, 5))
        conn_text = f"接続先: {self.account_info.server} ({self.account_info.login})"
        ttk.Label(top_frame, text=conn_text, font=("Meiryo", 10)).pack(side=tk.LEFT)
        self.last_updated_var = tk.StringVar(value="最終更新: ----/--/-- --:--:--")
        ttk.Label(top_frame, textvariable=self.last_updated_var).pack(side=tk.RIGHT)

        sheet_frame = ttk.Frame(main_frame) 
        sheet_frame.pack(fill=tk.BOTH, expand=True)

        self.columns = {
            "symbol":           ("通貨ペア", 110, "w"),
            "swap_long_pts":    ("買いスワップ(Pts/%)", 150, "e"), "swap_short_pts": ("売りスワップ(Pts/%)", 150, "e"),
            "swap_long_jpy":    ("1Lot損益(買/円)", 140, "e"), "swap_short_jpy": ("1Lot損益(売/円)", 140, "e"),
            "swap_both_1d_jpy": ("1日両建て損益(円)", 160, "e"), "rollover_day": ("3倍デー適用曜日", 130, "center"),
            "swap_long_3d":     ("3倍デー(買/円)", 140, "e"), "swap_short_3d":     ("3倍デー(売/円)", 140, "e"),
            "swap_both_3d_jpy": ("3倍デー両建て損益(円)", 180, "e"),
        }

        self.sheet = tksheet.Sheet(sheet_frame,
                                   headers=[h for h, w, a in self.columns.values()],
                                   show_toolbar=False,
                                   show_top_left=False)
        self.sheet.pack(fill=tk.BOTH, expand=True)
        self.sheet.enable_bindings("single_select", "drag_select", "ctrl_select", "arrowkeys", "right_click_popup_menu", "rc_select")

        for i, (col_id, (header, width, anchor)) in enumerate(self.columns.items()):
            align = "w" if anchor == "w" else "e" if anchor == "e" else "center"
            self.sheet.column_width(column=i, width=width)
            self.sheet.align_columns(columns=i, align=align)


        # --- 下部コントロールパネル ---
        bottom_frame = ttk.Frame(main_frame)
        bottom_frame.pack(fill=tk.X, pady=(5, 0))

        # 更新ボタン
        self.update_button = ttk.Button(bottom_frame, text="手動更新", command=self.update_data)
        self.update_button.pack(side=tk.LEFT, padx=(0, 10))

        # <<< 追加: CSV出力ボタン >>>
        self.export_button = ttk.Button(bottom_frame, text="CSV出力", command=self._export_to_csv)
        self.export_button.pack(side=tk.LEFT, padx=(0, 20))

        # 手動ソート機能のUIを追加
        sort_frame = ttk.Frame(bottom_frame)
        sort_frame.pack(side=tk.LEFT)

        ttk.Label(sort_frame, text="並べ替え:").pack(side=tk.LEFT, padx=(0, 5))

        self.col_display_to_id = {v[0]: k for k, v in self.columns.items()}

        self.sort_combo_var = tk.StringVar()
        self.sort_combo = ttk.Combobox(sort_frame, textvariable=self.sort_combo_var,
                                       values=[v[0] for v in self.columns.values()],
                                       state="readonly", width=25)
        self.sort_combo.set(self.columns[self.last_sort_col][0])
        self.sort_combo.pack(side=tk.LEFT, padx=(0, 5))
        self.sort_combo.bind("<<ComboboxSelected>>", self._on_sort_combo_select)

        self.sort_order_button = ttk.Button(sort_frame, text="降順", command=self._on_sort_order_toggle, width=6)
        self.sort_order_button.pack(side=tk.LEFT)

        self.status_var = tk.StringVar(value="準備完了")
        ttk.Label(bottom_frame, textvariable=self.status_var).pack(side=tk.LEFT, padx=20)

    # <<< 追加: CSV出力機能のメソッド >>>
    def _export_to_csv(self):
        # データがなければ処理を中断
        if not self.current_data:
            messagebox.showwarning("CSV出力", "出力するデータがありません。")
            return

        # ファイル保存ダイアログを表示
        try:
            filepath = filedialog.asksaveasfilename(
                defaultextension=".csv",
                filetypes=[("CSVファイル", "*.csv"), ("すべてのファイル", "*.*")],
                title="CSVファイルとして保存",
                # デフォルトのファイル名に現在日時を入れる
                initialfile=f"swap_data_{datetime.now().strftime('%Y%m%d_%H%M%S')}.csv"
            )
        except tk.TclError:
            print("ファイルダイアログを開けませんでした。")
            return

        # ユーザーがダイアログをキャンセルした場合は何もしない
        if not filepath:
            return

        try:
            # CSVに出力する列のID（キー）のリストを定義
            field_ids = list(self.columns.keys())

            # CSVのヘッダー行（日本語）を作成
            headers = [self.columns[col_id][0] for col_id in field_ids]

            # ファイルを書き込みモードで開く
            # encoding='utf-8-sig' はExcelで日本語が文字化けするのを防ぐ
            # newline='' は余分な改行が入るのを防ぐ
            with open(filepath, 'w', newline='', encoding='utf-8-sig') as csvfile:
                writer = csv.writer(csvfile)

                # 1行目: ヘッダーを書き込む
                writer.writerow(headers)

                # 2行目以降: データを1行ずつ書き込む
                for row_data in self.current_data:
                    # field_idsの順序で辞書から値を取り出し、リストを作成
                    row_to_write = [row_data.get(key, '') for key in field_ids]
                    writer.writerow(row_to_write)

            messagebox.showinfo("CSV出力完了", f"データをCSVファイルに出力しました。\nパス: {filepath}")

        except Exception as e:
            messagebox.showerror("書き込みエラー", f"CSVファイルの書き込み中にエラーが発生しました:\n{e}")
            traceback.print_exc() # コンソールに詳細なエラー情報を出力

    def _on_sort_combo_select(self, event=None):
        selected_display_name = self.sort_combo_var.get()
        new_sort_col = self.col_display_to_id[selected_display_name]
        self._sort_column(new_sort_col, keep_direction=True)

    def _on_sort_order_toggle(self, event=None):
        self.last_sort_reverse = not self.last_sort_reverse
        self._sort_column(self.last_sort_col, keep_direction=True)

    def _fetch_data_thread(self):
        try:
            all_symbols = mt5.symbols_get()
            if not all_symbols:
                self.root.after(0, self._update_gui_with_error, "エラー: 通貨ペアリストの取得に失敗。")
                return

            visible_symbols = [s for s in all_symbols if s.visible]
            if not visible_symbols:
                self.root.after(0, self._update_gui_with_error, "エラー: MT5の「気配値表示」に通貨ペアを追加してください。")
                return

            all_data = []
            weekdays = ["日", "月", "火", "水", "木", "金", "土"]

            for info in visible_symbols:
                tick = mt5.symbol_info_tick(info.name)
                if not tick or tick.bid == 0 or tick.ask == 0:
                    continue

                swap_long_jpy = 0.0
                swap_short_jpy = 0.0

                if info.swap_mode == mt5.SYMBOL_SWAP_MODE_POINTS:
                    tick_value = info.trade_tick_value
                    swap_long_jpy = info.swap_long * tick_value
                    swap_short_jpy = info.swap_short * tick_value
                elif info.swap_mode in [3, 5]: # %指定、もしくは%指定（オープン価格ベース）
                    swap_long_profit_ccy = 1.0 * info.trade_contract_size * tick.ask * (info.swap_long / 100) / 360
                    swap_short_profit_ccy = 1.0 * info.trade_contract_size * tick.bid * (info.swap_short / 100) / 360
                    if info.currency_profit != self.account_info.currency:
                        conversion_pair = info.currency_profit + self.account_info.currency
                        conversion_tick = mt5.symbol_info_tick(conversion_pair)
                        if conversion_tick and conversion_tick.bid > 0:
                            swap_long_jpy = swap_long_profit_ccy * conversion_tick.bid
                            swap_short_jpy = swap_short_profit_ccy * conversion_tick.bid
                        else:
                            continue
                    else:
                        swap_long_jpy = swap_long_profit_ccy
                        swap_short_jpy = swap_short_profit_ccy
                else:
                    continue

                all_data.append({
                    "symbol": info.name,
                    "swap_long_pts": info.swap_long, "swap_short_pts": info.swap_short,
                    "swap_long_jpy": swap_long_jpy, "swap_short_jpy": swap_short_jpy,
                    "swap_both_1d_jpy": swap_long_jpy + swap_short_jpy,
                    "rollover_day": weekdays[info.swap_rollover3days],
                    "swap_long_3d": swap_long_jpy * 3, "swap_short_3d": swap_short_jpy * 3,
                    "swap_both_3d_jpy": (swap_long_jpy + swap_short_jpy) * 3,
                    "swap_mode": info.swap_mode
                })

            self.root.after(0, self._update_gui, all_data)
        except Exception:
            traceback.print_exc()
            self.root.after(0, self._update_gui_with_error, "エラーが発生。詳細はコンソールを確認。")

    def _format_value(self, value, format_spec, is_jpy=False):
        unit = " 円" if is_jpy else ""
        if value == 0: return f"{value:{format_spec}}{unit}"
        return f"{value:+{format_spec}}{unit}"

    def _format_swap_points(self, value, mode):
        if mode in [3, 5]:
            return f"{value:+.3f} %"
        return f"{value:+.3f}"

    def _update_gui(self, data_list):
        self.current_data = data_list
        self._sort_column(self.last_sort_col, keep_direction=True)
        self.last_updated_var.set(f"最終更新: {datetime.now().strftime('%Y/%m/%d %H:%M:%S')}")
        self.status_var.set(f"データ取得完了。{len(data_list)}件の通貨ペアを表示中。")
        self.update_button.config(state="normal")

    def _redraw_view(self):
        if not self.current_data:
            self.sheet.set_sheet_data(data=[[]])
            return

        formatted_data = []
        for data in self.current_data:
            row = [
                data["symbol"],
                self._format_swap_points(data["swap_long_pts"], data["swap_mode"]),
                self._format_swap_points(data["swap_short_pts"], data["swap_mode"]),
                self._format_value(data["swap_long_jpy"], ",.2f", True),
                self._format_value(data["swap_short_jpy"], ",.2f", True),
                self._format_value(data["swap_both_1d_jpy"], ",.2f", True),
                data["rollover_day"],
                self._format_value(data["swap_long_3d"], ",.2f", True),
                self._format_value(data["swap_short_3d"], ",.2f", True),
                self._format_value(data["swap_both_3d_jpy"], ",.2f", True)
            ]
            formatted_data.append(row)

        self.sheet.set_sheet_data(data=formatted_data, redraw=False)

        color_target_cols = [
            "swap_long_pts", "swap_short_pts", "swap_long_jpy", "swap_short_jpy",
            "swap_both_1d_jpy", "swap_long_3d", "swap_short_3d", "swap_both_3d_jpy"
        ]

        col_id_to_index = {col_id: i for i, col_id in enumerate(self.columns.keys())}

        for r, data_row in enumerate(self.current_data):
            for col_id in color_target_cols:
                c = col_id_to_index[col_id]
                value = data_row[col_id]
                color = ""
                if value > 0:
                    color = "blue"
                elif value < 0:
                    color = "red"

                if color:
                    self.sheet.highlight_cells(row=r, column=c, fg=color)

        self.sheet.redraw()

    def _sort_column(self, col, keep_direction=False):
        if not self.current_data:
            return

        if not keep_direction:
            if self.last_sort_col == col:
                self.last_sort_reverse = not self.last_sort_reverse
            else:
                self.last_sort_reverse = True

        self.last_sort_col = col
        is_numeric = col not in ["symbol", "rollover_day"]

        key_func = (lambda d: d.get(col, 0)) if is_numeric else (lambda d: str(d.get(col, '')))
        self.current_data.sort(key=key_func, reverse=self.last_sort_reverse)

        self.sort_order_button.config(text="降順" if self.last_sort_reverse else "昇順")

        self._redraw_view()

    def _update_gui_with_error(self, message):
        self.sheet.set_sheet_data(data=[[]])
        self.status_var.set(message)
        self.update_button.config(state="normal")

    def update_data(self):
        self.status_var.set("データを取得中...")
        self.update_button.config(state="disabled")
        thread = threading.Thread(target=self._fetch_data_thread, daemon=True)
        thread.start()
        if self.timer_id: self.root.after_cancel(self.timer_id)
        self.timer_id = self.root.after(3600000, self.update_data)

    def _on_closing(self):
        if messagebox.askokcancel("終了確認", "アプリケーションを終了しますか？"):
            if self.timer_id: self.root.after_cancel(self.timer_id)
            mt5.shutdown()
            self.root.destroy()
            print("MT5との接続をシャットダウンしました。")

    def run(self):
        self.root.mainloop()

def main():
    terminal_path = choose_terminal()
    if not terminal_path:
        print("MT5ターミナルが選択されませんでした。プログラムを終了します。")
        sys.exit(0)
    app = SwapViewerApp(terminal_path)
    app.run()

if __name__ == "__main__":
    main()