使用MQL5和Python集成经纪商API与智能交易系统·进阶篇

class="kw">import json
class="kw">import websocket
class="kw">import time
class="kw">import os
# Configuration
API_URL = "wss:class=class="str">"cmt">//ws.binaryws.com/websockets/v3?app_id= Your app ID"   class="macro">#Replace with your App ID created in Deriv API dashboard
API_TOKEN = "Your API token"   class="macro">#Replace with your actual token
# File paths(Replace YourComputerName with the actual name of your computer)
MQL5_TO_PYTHON = "C:/Users/YourComputerName/AppData/Roaming/MetaQuotes/Terminal/Common/Files/mql5_to_python.txt"
PYTHON_TO_MQL5 = "C:/Users/YourComputerName/AppData/Roaming/MetaQuotes/Terminal/Common/Files/python_to_mql5.txt"
def connect_to_deriv():
    """Connects to Deriv&class="macro">#x27;s WebSocket API."""
    try:
        ws.connect(API_URL)
        ws.send(json.dumps({"authorize": API_TOKEN}))
        response = json.loads(ws.recv())
        print(f"Authorization Response: {response}")
        if response.get("error"):
            print("Authorization failed:", response["error"]["message"])
            class="kw">return False
        class="kw">return True
    except Exception as e:
        print(f"Error during authorization: {e}")
        class="kw">return False
def process_command(command):
    """Processes a command from MQL5."""
    try:
        command_data = json.loads(command)  # Parse the JSON command
        if "mt5_deposit" in command_data:
            class="kw">return mt5_deposit(

def mt5_deposit(amount, from_binary, to_mt5):
    """Performs a deposit operation to the MT5 account."""
    try:
        ws.send(json.dumps({
            "mt5_deposit": class="num">1,
            "amount": amount,
            "from_binary": from_binary,
            "to_mt5": to_mt5
        }))
        response = ws.recv()
        class="kw">return json.loads(response)
    except Exception as e:
        class="kw">return {"error": f"Error during deposit operation: {e}"}

def read_command():
    """Reads a command from the MQL5 file and deletes the file after reading."""
    print(f"Checking for command file at: {MQL5_TO_PYTHON}")
    if os.path.exists(MQL5_TO_PYTHON):
        print(f"Command file found: {MQL5_TO_PYTHON}")
        with open(MQL5_TO_PYTHON, "r", encoding="utf-class="num">8") as file:
            command = file.read().strip()
        print(f"Raw Command read: {repr(command)}")
        # Strip potential BOM and whitespace
        if command.startswith("\ufeff"):
            command = command[class="num">1:]
        print(f"Processed Command: {repr(command)}")
        os.remove(MQL5_TO_PYTHON)  # Remove file after reading
        class="kw">return command
    print(f"Command file not found at: {MQL5_TO_PYTHON}")
    class="kw">return None

def write_response(response):
    """Writes a response to the MQL5 file."""
    with open(PYTHON_TO_MQL5, "w", encoding="utf-class="num">8") as file:
        file.write(json.dumps(response))

    class="kw">while True:
        try:
            command = read_command()
            if command:
                print(f"Processing command: {command}")
                response = process_command(command)
                print(f"Response: {response}")
                write_response(response)
                print("Response written. Exiting loop.")
                break  # Exit the loop after processing one command
            else:
                print("No command file found. Exiting.")
                break  # Exit the loop if the command file is not found
        except Exception as e:
            print(f"Error in main loop: {e}")
            break  # Exit the loop on unexpected error

class=class="str">"cmt">//+------------------------------------------------------------------+
class=class="str">"cmt">//|                                                                 Fund Manager EA.mq5  |
class=class="str">"cmt">//|                     Copyright class="num">2024, Clemence Benjamin |
class=class="str">"cmt">//|     [MQL5官方文档] |
class=class="str">"cmt">//+------------------------------------------------------------------+
class="macro">#class="kw">property copyright "Copyright class="num">2024, Clemence Benjamin"
class="macro">#class="kw">property link      "[MQL5官方文档]
class="macro">#class="kw">property version   "class="num">1.01"
class="macro">#class="kw">property description "Deposit and Withdraw funds between broker and trading account within the EA"
class="macro">#class="kw">import "shell32.dll"
class="type">int ShellExecuteW(class="type">int hwnd, class="type">class="kw">string lpOperation, class="type">class="kw">string lpFile, class="type">class="kw">string lpParameters, class="type">class="kw">string lpDirectory, class="type">int nShowCmd);
class="macro">#class="kw">import

input class="type">class="kw">double balance_threshold = class="num">100000.0;   class=class="str">"cmt">// Threshold balance for top-up
input class="type">class="kw">double top_up_amount = class="num">100000.0;       class=class="str">"cmt">// Amount to top-up if balance is below threshold
input class="type">class="kw">string from_binary = "CR0000000";      class=class="str">"cmt">// Binary account ID to withdraw funds from. Replace zero with real one
input class="type">class="kw">string to_mt5 = "MTRReplace";      class=class="str">"cmt">// MT5 account ID to deposit funds into. Replace with your MT5 acc from Deriv Broker
input class="type">class="kw">string python_script_path = "C:\Users\YourComputerName\PathTo\deriv_api_handler.py"; class=class="str">"cmt">// Python script path
input class="type">class="kw">string python_exe = "python";          class=class="str">"cmt">// Python executable command(ensure Python is in PATH)
class="type">int OnInit()
  {
   class="type">class="kw">double current_balance = AccountInfoDouble(ACCOUNT_BALANCE);
   Print("Current Account Balance: ", current_balance);
   if(current_balance < balance_threshold)
     {
      Print("Balance is below the threshold. Attempting a deposit...");
class="type">class="kw">string command_file = "mql5_to_python.txt";
class="type">class="kw">string command_path = TerminalInfoString(TERMINAL_COMMONDATA_PATH) + "\Files\" + command_file;
class="type">int handle = FileOpen(command_file, FILE_WRITE | FILE_COMMON | FILE_TXT | FILE_ANSI);

class="type">class="kw">string deposit_command = StringFormat("{\"mt5_deposit\": class="num">1, \"amount\": %.2f, \"from_binary\": \"%s\", \"req_id\": class="num">1, \"to_mt5\": \"%s\"}", top_up_amount, from_binary, to_mt5);
FileWrite(handle, deposit_command);
FileClose(handle);
Print("Deposit command written to file: ", command_path);
class="type">int result = ShellExecuteW(class="num">0, "open", python_exe, python_script_path, NULL, class="num">1);
if(result <= class="num">32)
  {
   Print("Failed to launch Python script. Error code: ", result);
   class="kw">return(INIT_FAILED);
  }
else
  {
   Print("Python script launched successfully.");
  }
class="type">class="kw">string response_file = "python_to_mql5.txt";
if(FileIsExist(response_file, FILE_COMMON))
  {
   handle = FileOpen(response_file, FILE_READ | FILE_COMMON | FILE_TXT | FILE_ANSI);
   class="type">class="kw">string response = FileReadString(handle);
   FileClose(handle);
   Print("Response from Python: ", response);
   if(StringFind(response, "\"status\":\"success\"") >= class="num">0)
     {
      Print("Deposit was successful.");
     }
   else
     {
      Print("Deposit failed. Response: ", response);
     }
  }
else
  {
   Print("Response file not found. Ensure the Python script is running and processing the command.");
  }
else
  {
   Print("Balance is above the threshold. No deposit attempt needed.");
  }
class="kw">return(INIT_SUCCEEDED);
class="type">void OnDeinit(const class="type">int reason)
  {
   Print("Expert deinitialized.");
  }