【プログラミング初心者でも安心！】TradingViewのシグナルでMT4を動かす自動売買システム構築ガイド

graph TD
    A[TradingViewでシグナル発生] -->|Webhookで通知| B(Cloud Functions);
    B -->|命令を書き込む| C(Firestore);
    D(MT4のEAが定期的に見にくる) -->|命令を読み取る| C;
    D -->|読み取った命令を実行| E[MT4で売買実行！];

from google.cloud import firestore
import json

def hello_world(request):
    """
    TradingViewからのWebhook受信とMT4への注文情報提供

    この関数は2つの役割を持っています:
    1. TradingViewからの注文を受け取り、Firestoreに保存する
    2. MT4からの問い合わせに対して、Firestoreから注文情報を取得して返す
    """
    request_json = request.get_json()
    order = ""
    symbol = ""

    # JSONからパラメータ取得
    if request_json and 'order' in request_json:
        order = request_json['order']
    if request_json and 'symbol' in request_json:
        symbol = request_json['symbol']

    print(f"受信したJSON: order={order}, symbol={symbol}")

    if order == "":
        # MT4からの注文情報取得リクエスト
        # （orderが空 = 「今の注文状態を教えて」という問い合わせ）
        state = load_order(symbol)
        return {"order": state}
    else:
        # TradingViewからの注文保存リクエスト
        # （orderがある = 「この注文を保存して」という依頼）
        update_order(symbol, order)
        return {"res": "ok"}

def update_order(symbol, order):
    """
    注文情報をFirestoreに保存

    TradingViewから「買い」「売り」などの注文が来たら、
    この関数でFirestoreに記録します。
    """
    if symbol and order:
        db = firestore.Client()
        doc_ref = db.collection("TradingView").document(symbol)
        doc_ref.set({
            "order": order,
            "timestamp": firestore.SERVER_TIMESTAMP
        })
        print(f"注文保存: {symbol} - {order}")

def load_order(symbol):
    """
    Firestoreから注文情報を取得

    MT4が「今どんな注文が来てる？」と聞いてきたら、
    この関数でFirestoreから最新の注文情報を返します。
    """
    if symbol:
        db = firestore.Client()
        doc = db.collection("TradingView").document(symbol).get()

        if doc.exists:
            data = doc.to_dict()
            return data.get("order", "none")
        else:
            return "none"

    return "none"

google-cloud-firestore
functions-framework

//@version=5
strategy("GCF連携戦略", overlay=true)

// パラメータ
rsi_period = input.int(14, "RSI期間")
rsi_oversold = input.int(30, "RSI買われすぎ")
rsi_overbought = input.int(70, "RSI売られすぎ")

// インジケータ計算
rsi = ta.rsi(close, rsi_period)

// エントリー条件
long_condition = rsi < rsi_oversold
short_condition = rsi > rsi_overbought

// 注文実行
if long_condition
    strategy.entry("Long", strategy.long, comment="buy")
    
if short_condition
    strategy.entry("Short", strategy.short, comment="sell")

// 決済条件
if strategy.position_size > 0 and rsi > rsi_overbought
    strategy.close("Long", comment="buy_close")
    
if strategy.position_size < 0 and rsi < rsi_oversold
    strategy.close("Short", comment="sell_close")

// 使用する注文コメント
comment = "buy"        // ロングエントリー
comment = "buy_close"  // ロング決済
comment = "sell"       // ショートエントリー
comment = "sell_close" // ショート決済

//+------------------------------------------------------------------+
//| GCF TradingView連携EA                                            |
//+------------------------------------------------------------------+
#property strict

// パラメータ
input string web_hook_url = "https://your-project.cloudfunctions.net/webhook";
input string input_symbol = ""; // 通貨ペア（空白の場合は自動）
input int magic_number = 124455;
input double qty = 0.1; // ロット数
input int input_spread = 30; // スプレッド制限
input int input_slippage = 20; // スリッページ制限

void OnTick() {
    string order = "";
    static datetime prev_time = iTime(NULL, 0, 0);
    
    // スプレッドチェック
    if(Ask - Bid <= input_spread * _Point) {
        
        // 1分足の更新時のみ実行
        if(prev_time == iTime(NULL, 0, 0)) {
            return;
        }
        
        // 秒数制限（サーバー負荷対策）
        if(Seconds() < 2) {
            return;
        }
        
        prev_time = iTime(NULL, 0, 0);
        order = web_request();
    }
    
    // ポジション管理
    if(position_count(OP_BUY) > 0) {
        if(order == "buy_close") {
            position_close(OP_BUY);
        }
    }
    
    if(position_count(OP_SELL) > 0) {
        if(order == "sell_close") {
            position_close(OP_SELL);
        }
    }
    
    // エントリー処理
    if(order == "buy") {
        position_entry(OP_BUY);
    }
    if(order == "sell") {
        position_entry(OP_SELL);
    }
}

string web_request() {
    static string prev_state = "";
    string url = web_hook_url;
    string headers;
    string data;
    char post[], result[];
    
    // 通貨ペア設定
    string symbol = Symbol();
    if(input_symbol != "") {
        symbol = input_symbol;
    }
    
    // リクエスト作成
    headers = "Content-Type: application/json\r\n";
    data = "{\"symbol\":\"" + symbol + "\"}";
    
    ArrayResize(post, StringToCharArray(data, post, 0, WHOLE_ARRAY, CP_UTF8) - 1);
    
    // HTTP POST実行
    int rest = WebRequest("POST", url, headers, 5000, post, result, headers);
    
    string order = CharArrayToString(result);
    StringReplace(order, "\"", "");
    
    if(rest != 200) {
        Print(Symbol(), " エラー: ", CharArrayToString(result));
        return "";
    } else {
        // 同じ状態の重複実行防止
        if(prev_state == CharArrayToString(result)) {
            return "";
        }
        
        if(prev_state == "") {
            prev_state = CharArrayToString(result);
            return "";
        }
        
        prev_state = CharArrayToString(result);
        
        if(order == "buy" || order == "buy_close" || 
           order == "sell" || order == "sell_close") {
            Print(Symbol(), " 注文受信: ", CharArrayToString(result));
            return order;
        }
    }
    
    return "";
}

int position_count(int side) {
    int count = 0;
    for(int i = OrdersTotal() - 1; i >= 0; i--) {
        if(OrderSelect(i, SELECT_BY_POS, MODE_TRADES)) {
            if(OrderType() == side && 
               OrderSymbol() == Symbol() && 
               OrderMagicNumber() == magic_number) {
                count++;
            }
        }
    }
    return count;
}

void position_entry(int side) {
    if(side == OP_BUY) {
        OrderSend(NULL, side, qty, Ask, 0, 0, 0, NULL, magic_number, 0, clrGreen);
    }
    if(side == OP_SELL) {
        OrderSend(NULL, side, qty, Bid, 0, 0, 0, NULL, magic_number, 0, clrRed);
    }
}

void position_close(int side) {
    for(int i = OrdersTotal() - 1; i >= 0; i--) {
        if(OrderSelect(i, SELECT_BY_POS, MODE_TRADES)) {
            if(OrderType() == side && 
               OrderSymbol() == Symbol() && 
               OrderMagicNumber() == magic_number) {
                OrderClose(OrderTicket(), OrderLots(), OrderClosePrice(), 0, clrBlue);
            }
        }
    }
}

def hello_world(request):
    # ... (前略)
    order = request_json.get('order', '')
    symbol = request_json.get('symbol', '')

    # --- MT4からの確認か、TradingViewからの新規注文かで処理を分ける ---
    # ... (後略)

def hello_world(request):
    # ... (前略)
    order = request_json.get('order', '')
    symbol = request_json.get('symbol', '')

    # ---ここから追加---
    # 対応する通貨ペアと注文の種類をあらかじめ決めておく
    VALID_SYMBOLS = ["USDJPY", "EURJPY", "GBPJPY", "BTCUSD"]
    VALID_ORDERS = ["buy", "sell", "buy_close", "sell_close"]

    # もし注文(order)があり、かつそれが許可された注文リストに含まれていない場合はエラー
    if order and order not in VALID_ORDERS:
        print(f"エラー:許可されていない注文です: {order}")
        return {"error": "Invalid order type"}, 400

    # もし通貨ペア(symbol)があり、かつそれが許可された通貨ペアリストに含まれていない場合はエラー
    if symbol and symbol not in VALID_SYMBOLS:
        print(f"エラー:許可されていない通貨ペアです: {symbol}")
        return {"error": "Invalid symbol type"}, 400
    # ---ここまで追加---

    # --- MT4からの確認か、TradingViewからの新規注文かで処理を分ける ---
    # ... (後略)