布林中轨穿越多周期马丁EA(任意周期版)

// 基于 XAUOF 社区作品 #46《布林中轨穿越多周期马丁EA》（作者 litongxue）二次创作
// 改动说明：
// 1. 将原来写死的 M5/M15/M30/H1/H4 改为 input 参数，用户可在任意周期组合下运行
// 2. 增加图表周期自动适配逻辑，确保挂在任何周期的图表上都能正确读取目标周期数据
// 3. 保留原有马丁加仓、止盈止损、历史恢复等全部核心逻辑不变
// 4. 修复上一版 UpdateStats 函数中 Print 语句误用变量 i 导致 undeclared identifier 的编译错误

#property copyright "XAUOF 指标工坊"
#property version   "1.02"
#property strict

#include <Trade\Trade.mqh>

//==================== 可调参数 ====================
input ENUM_TIMEFRAMES InpTF1          = PERIOD_M5;   // 第1个监控周期（推荐 M5）
input ENUM_TIMEFRAMES InpTF2          = PERIOD_M15;  // 第2个监控周期（推荐 M15）
input ENUM_TIMEFRAMES InpTF3          = PERIOD_M30;  // 第3个监控周期（推荐 M30）
input ENUM_TIMEFRAMES InpTF4          = PERIOD_H1;   // 第4个监控周期（推荐 H1）
input ENUM_TIMEFRAMES InpTF5          = PERIOD_H4;   // 第5个监控周期（推荐 H4）

input long   InpBaseMagic             = 20250001;    // 魔术号基数（5个周期自动用 基数+0~4，互不冲突）
input double InpBaseLot               = 0.01;        // 初始手数（推荐 0.01）
input double InpLotStep               = 0.01;        // 每次止损后加仓的手数（推荐 0.01）
input double InpMaxLot                = 0.10;        // 单周期最大手数保护（推荐 0.05~0.10，防止马丁失控）
input int    InpStopLossPts           = 600;         // 止损点数（XAU 2位小数报价下 600点=6.00美元，推荐 400~800）
input int    InpTakeProfitPts         = 1200;        // 止盈点数（推荐为止损的 1.5~2 倍）
input int    InpBollPeriod            = 20;          // 布林带周期（推荐 20）
input int    InpBollDev               = 2;           // 布林带标准差倍数（推荐 2）
//==================================================

#define TF_COUNT 5

// 每个周期的独立状态
struct TFState
{
   ENUM_TIMEFRAMES tf;       // 周期
   int    handle;            // 布林带指标句柄
   double lot;               // 当前应开的手数
   double totalLoss;         // 本周期累计止损金额（正数）
   double totalProfit;       // 本周期累计盈利金额
   datetime lastBar;         // 上一根已处理的K线时间（用于判断新K线）
};

CTrade   g_trade;
TFState  g_tf[TF_COUNT];

//------------------------------------------------------------------
// 初始化
//------------------------------------------------------------------
int OnInit()
{
   // 将用户选择的 5 个周期存入数组
   ENUM_TIMEFRAMES tfs[TF_COUNT] = {InpTF1, InpTF2, InpTF3, InpTF4, InpTF5};

   for(int i = 0; i < TF_COUNT; i++)
   {
      g_tf[i].tf          = tfs[i];
      g_tf[i].lot         = InpBaseLot;
      g_tf[i].totalLoss   = 0.0;
      g_tf[i].totalProfit = 0.0;
      g_tf[i].lastBar     = 0;

      // 创建布林带句柄（只用中轨做信号，上下轨参数仍按标准布林设置）
      // 注意：这里传入的是 g_tf[i].tf，所以无论图表是什么周期，都能正确取到目标周期的布林带
      g_tf[i].handle = iBands(_Symbol, g_tf[i].tf, InpBollPeriod, 0, InpBollDev, PRICE_CLOSE);
      if(g_tf[i].handle == INVALID_HANDLE)
      {
         Print("布林带句柄创建失败，周期索引 ", i, " 周期 ", EnumToString(g_tf[i].tf));
         return INIT_FAILED;
      }
   }

   g_trade.SetDeviationInPoints(30);        // 允许 30 点滑点
   g_trade.SetTypeFillingBySymbol(_Symbol); // 按品种自动选择成交模式

   // 重启 EA 后，从历史成交里恢复每个周期的手数与盈亏统计
   RestoreStatsFromHistory();

   return INIT_SUCCEEDED;
}

//------------------------------------------------------------------
// 反初始化：释放句柄
//------------------------------------------------------------------
void OnDeinit(const int reason)
{
   for(int i = 0; i < TF_COUNT; i++)
   {
      if(g_tf[i].handle != INVALID_HANDLE)
         IndicatorRelease(g_tf[i].handle);
   }
   Comment("");
}

//------------------------------------------------------------------
// 主循环：每个周期独立判断信号
//------------------------------------------------------------------
void OnTick()
{
   for(int i = 0; i < TF_COUNT; i++)
   {
      // ---- 1. 判断该周期是否出现新K线（只在K线收盘后判断一次，避免盘中反复触发）----
      // 关键点：iTime 第二个参数传的是 g_tf[i].tf，而不是 PERIOD_CURRENT
      // 这样即使你挂在 M1 图表上，也能准确获取 H4 的新K线时间
      datetime curBar = iTime(_Symbol, g_tf[i].tf, 0);
      if(curBar == 0 || curBar == g_tf[i].lastBar)
         continue;
      g_tf[i].lastBar = curBar;

      // ---- 2. 该周期已有持仓则跳过（每个周期最多同时 1 单）----
      if(HasPosition(i))
         continue;

      // ---- 3. 等指标计算完毕，取中轨数值 ----
      // mid[0] = 前前根K线(shift 2)的中轨，mid[1] = 刚收盘那根(shift 1)的中轨
      double mid[2];
      double close[2];
      if(BarsCalculated(g_tf[i].handle) < InpBollPeriod + 2)
         continue;
      if(CopyBuffer(g_tf[i].handle, BASE_LINE, 1, 2, mid) < 2)
         continue;
      
      // CopyClose 同样指定了 g_tf[i].tf，保证取到的是目标周期的收盘价
      if(CopyClose(_Symbol, g_tf[i].tf, 1, 2, close) < 2)
         continue;

      // ---- 4. 判断穿越信号：收盘价从下方上穿中轨 → 做多；从上方下穿中轨 → 做空 ----
      bool buySignal  = (close[1] > mid[1] && close[0] <= mid[0]);
      bool sellSignal = (close[1] < mid[1] && close[0] >= mid[0]);

      if(!buySignal && !sellSignal)
         continue;

      // ---- 5. 按当前手数开仓（止损过就自动用加仓后的手数）----
      double lot = NormalizeLot(g_tf[i].lot);
      double ask = SymbolInfoDouble(_Symbol, SYMBOL_ASK);
      double bid = SymbolInfoDouble(_Symbol, SYMBOL_BID);
      if(ask <= 0 || bid <= 0)
         continue;

      double sl = 0;
      double tp = 0;
      if(buySignal)
      {
         if(InpStopLossPts   > 0) sl = ask - InpStopLossPts   * _Point;
         if(InpTakeProfitPts > 0) tp = ask + InpTakeProfitPts * _Point;
      }
      else
      {
         if(InpStopLossPts   > 0) sl = bid + InpStopLossPts   * _Point;
         if(InpTakeProfitPts > 0) tp = bid - InpTakeProfitPts * _Point;
      }

      g_trade.SetExpertMagicNumber(InpBaseMagic + i); // 每个周期独立魔术号
      string cmt = "BollMid-" + EnumToString(g_tf[i].tf);

      bool ok = false;
      if(buySignal)
         ok = g_trade.Buy(lot, _Symbol, 0, sl, tp, cmt);
      else
         ok = g_trade.Sell(lot, _Symbol, 0, sl, tp, cmt);

      if(ok)
      {
         Print(cmt, " 开仓 ", DoubleToString(lot, 2), " 手 ",
               (buySignal ? "多" : "空"),
               " | 累计止损 ", DoubleToString(g_tf[i].totalLoss, 2),
               " 累计盈利 ", DoubleToString(g_tf[i].totalProfit, 2));
      }
      else
      {
         Print(cmt, " 开仓失败: ", g_trade.ResultRetcodeDescription());
      }
   }

   UpdateChartComment();
}

//------------------------------------------------------------------
// 该周期是否已有持仓（按魔术号区分，5 个周期互不干扰）
//------------------------------------------------------------------
bool HasPosition(int idx)
{
   long magic = InpBaseMagic + idx;
   for(int p = PositionsTotal() - 1; p >= 0; p--)
   {
      ulong ticket = PositionGetTicket(p);
      if(ticket == 0) continue;
      if(PositionGetString(POSITION_SYMBOL) != _Symbol) continue;
      if(PositionGetInteger(POSITION_MAGIC) != magic)   continue;
      return true;
   }
   return false;
}

//------------------------------------------------------------------
// 手数规范化：按最小手数/步长/最大手数取整
//------------------------------------------------------------------
double NormalizeLot(double lot)
{
   double minLot = SymbolInfoDouble(_Symbol, SYMBOL_VOLUME_MIN);
   double maxLot = SymbolInfoDouble(_Symbol, SYMBOL_VOLUME_MAX);
   double step   = SymbolInfoDouble(_Symbol, SYMBOL_VOLUME_STEP);

   if(step > 0)
      lot = MathFloor(lot / step + 0.5) * step; // 四舍五入到步长
   if(lot < minLot) lot = minLot;
   if(lot > maxLot) lot = maxLot;
   if(lot > InpMaxLot) lot = InpMaxLot; // 马丁保护上限
   return lot;
}

//------------------------------------------------------------------
// 根据一笔平仓盈亏更新某周期的统计：
// 亏损 → 累计止损金额增加，下次开仓手数 +InpLotStep
// 盈利 → 累计盈利增加；若盈利总额覆盖了止损总额，手数复位为初始手数
//------------------------------------------------------------------
void UpdateStats(int idx, double profit)
{
   if(idx < 0 || idx >= TF_COUNT) return;

   if(profit < 0)
   {
      g_tf[idx].totalLoss += -profit;      // 累计止损金额
      g_tf[idx].lot       += InpLotStep;   // 下次开仓加仓
   }
   else
   {
      g_tf[idx].totalProfit += profit;     // 累计盈利金额
      if(g_tf[idx].totalLoss > 0 &&
         g_tf[idx].totalProfit >= g_tf[idx].totalLoss)
      {
         // 盈利总和覆盖了过去的止损总和 → 复位
         Print(EnumToString(g_tf[idx].tf),
               " 盈利 ", DoubleToString(g_tf[idx].totalProfit, 2),
               " 已覆盖止损 ", DoubleToString(g_tf[idx].totalLoss, 2),
               "，手数复位为 ", DoubleToString(InpBaseLot, 2));
         g_tf[idx].lot         = InpBaseLot;
         g_tf[idx].totalLoss   = 0.0;
         g_tf[idx].totalProfit = 0.0;
      }
   }

   if(g_tf[idx].lot > InpMaxLot)
      g_tf[idx].lot = InpMaxLot;           // 保护上限
}

//------------------------------------------------------------------
// 魔术号 → 周期索引（不属于本 EA 的返回 -1）
//------------------------------------------------------------------
int MagicToIndex(long magic)
{
   long diff = magic - InpBaseMagic;
   if(diff < 0 || diff >= TF_COUNT) return -1;
   return (int)diff;
}

//------------------------------------------------------------------
// 实时捕捉平仓事件（EA 运行中更新统计）
//------------------------------------------------------------------
void OnTradeTransaction(const MqlTradeTransaction &trans,
                        const MqlTradeRequest &request,
                        const MqlTradeResult &result)
{
   if(trans.type != TRADE_TRANSACTION_DEAL_ADD) return;

   ulong ticket = trans.deal;
   if(ticket == 0 || !HistoryDealSelect(ticket)) return;

   if(HistoryDealGetString(ticket, DEAL_SYMBOL) != _Symbol) return;

   long entry = HistoryDealGetInteger(ticket, DEAL_ENTRY);
   if(entry != DEAL_ENTRY_OUT && entry != DEAL_ENTRY_OUT_BY) return; // 只看平仓单

   int idx = MagicToIndex(HistoryDealGetInteger(ticket, DEAL_MAGIC));
   if(idx < 0) return;

   // 平仓净盈亏 = 盈亏 + 库存费 + 手续费
   double profit = HistoryDealGetDouble(ticket, DEAL_PROFIT)
                 + HistoryDealGetDouble(ticket, DEAL_SWAP)
                 + HistoryDealGetDouble(ticket, DEAL_COMMISSION);

   UpdateStats(idx, profit);
}

//------------------------------------------------------------------
// 重启后从历史成交恢复统计（按时间顺序重放每笔平仓）
//------------------------------------------------------------------
void RestoreStatsFromHistory()
{
   if(!HistorySelect(0, TimeCurrent())) return;

   int total = HistoryDealsTotal();
   for(int i = 0; i < total; i++)
   {
      ulong ticket = HistoryDealGetTicket(i);
      if(ticket == 0) continue;
      if(HistoryDealGetString(ticket, DEAL_SYMBOL) != _Symbol) continue;

      long entry = HistoryDealGetInteger(ticket, DEAL_ENTRY);
      if(entry != DEAL_ENTRY_OUT && entry != DEAL_ENTRY_OUT_BY) continue;

      int idx = MagicToIndex(HistoryDealGetInteger(ticket, DEAL_MAGIC));
      if(idx < 0) continue;

      double profit = HistoryDealGetDouble(ticket, DEAL_PROFIT)
                    + HistoryDealGetDouble(ticket, DEAL_SWAP)
                    + HistoryDealGetDouble(ticket, DEAL_COMMISSION);

      UpdateStats(idx, profit);
   }
}

//------------------------------------------------------------------
// 图表左上角显示各周期状态
//------------------------------------------------------------------
void UpdateChartComment()
{
   string s = "=== 布林中轨穿越多周期马丁EA ===\n";
   for(int i = 0; i < TF_COUNT; i++)
   {
      s += EnumToString(g_tf[i].tf)
         + " | 手数 " + DoubleToString(g_tf[i].lot, 2)
         + " | 累计止损 " + DoubleToString(g_tf[i].totalLoss, 2)
         + " | 累计盈利 " + DoubleToString(g_tf[i].totalProfit, 2)
         + (HasPosition(i) ? " | 持仓中" : " | 空仓")
         + "\n";
   }
   Comment(s);
}