mirror of
https://github.com/silencesdg/mt5_python_ea_suite.git
synced 2026-07-27 18:57:44 +00:00
silencesdg
e1691c3c41
- 新增适应度门槛: min_backtest_fitness=95, 适应度<95暂停开仓 - 新增 SwingPointRetest 策略替代 Turtle - 新增 monday_reset.py 周重置脚本 - exit_rules: 拖尾止损相对回撤模式 - market_state: 趋势检测优化 - position: 一票制并发锁+合约规格缓存 - optimize: Optuna 替代 DEAP 遗传算法 - realtime_trader: 适应度门槛+同向递增 - weights: 动态权重管理 - cron_optimize: PYTHONPATH 修复 - .gitignore: 排除生成文件
76 lines
2.7 KiB
Python
76 lines
2.7 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
"""实时交易入口 — 支持远程/本地两种数据源"""
|
|
|
|
import sys
|
|
import os
|
|
import fcntl
|
|
from datetime import datetime
|
|
|
|
sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
|
|
|
|
from execution.realtime_trader import RealtimeTrader
|
|
from core.data import LiveDataProvider, DryRunDataProvider, RemoteDataProvider
|
|
from config import (
|
|
REALTIME_CONFIG, INITIAL_CAPITAL,
|
|
REMOTE_SERVER_HOST, REMOTE_SERVER_PORT, DATA_PROVIDER_MODE,
|
|
)
|
|
from logger import setup_logger
|
|
|
|
LOCK_FILE = os.path.join(os.path.dirname(os.path.dirname(os.path.abspath(__file__))), '.ea.lock')
|
|
|
|
|
|
def main():
|
|
# ★ 进程锁：防止多实例同时运行
|
|
lock_fd = os.open(LOCK_FILE, os.O_CREAT | os.O_RDWR, 0o644)
|
|
try:
|
|
fcntl.flock(lock_fd, fcntl.LOCK_EX | fcntl.LOCK_NB)
|
|
except BlockingIOError:
|
|
print("❌ 已有 EA 实例在运行，退出")
|
|
os.close(lock_fd)
|
|
return
|
|
log_level = REALTIME_CONFIG.get('logging_level', 'INFO')
|
|
setup_logger(log_level)
|
|
|
|
is_dry_run = REALTIME_CONFIG.get('dry_run', True)
|
|
|
|
print("=" * 60)
|
|
print("MT5 智能交易系统 - 实时交易")
|
|
print(f"启动时间: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
|
|
print(f"数据源: {DATA_PROVIDER_MODE.upper()}")
|
|
print(f"运行模式: {'模拟运行' if is_dry_run else '实盘交易'}")
|
|
print("=" * 60)
|
|
|
|
if DATA_PROVIDER_MODE == "remote":
|
|
data_provider = RemoteDataProvider(host=REMOTE_SERVER_HOST, port=REMOTE_SERVER_PORT)
|
|
if not data_provider.initialize():
|
|
print("❌ 远程 MT5 API 连接失败，请检查 Windows 端服务是否运行")
|
|
return
|
|
print(f"✅ 已连接远程 MT5 {REMOTE_SERVER_HOST}:{REMOTE_SERVER_PORT}")
|
|
acct = data_provider.get_account_info()
|
|
if acct:
|
|
print(f" 账号: {acct.get('login','?')} 余额: ${acct.get('balance','?'):.2f}")
|
|
elif is_dry_run:
|
|
data_provider = DryRunDataProvider(initial_equity=INITIAL_CAPITAL)
|
|
else:
|
|
print("WARNING: 即将启动实盘交易模式！")
|
|
confirm = input("确认启动实盘交易？(输入 'YES' 继续): ")
|
|
if confirm != 'YES':
|
|
print("已取消启动。")
|
|
return
|
|
data_provider = LiveDataProvider()
|
|
|
|
trader = RealtimeTrader(data_provider, update_interval=REALTIME_CONFIG['update_interval'])
|
|
print("\n正在启动交易系统... (按 Ctrl+C 可安全停止)")
|
|
|
|
# 写入 PID 文件供重启脚本使用
|
|
pid_file = os.path.join(os.path.dirname(os.path.dirname(os.path.abspath(__file__))), '.ea_pid')
|
|
with open(pid_file, 'w') as f:
|
|
f.write(str(os.getpid()))
|
|
|
|
trader.start()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|