黄金多周期趋势共振指标

//+------------------------------------------------------------------+
//|                                          XAUOF_MTF_Resonance.mq5 |
//|                                                     XAUOF 指标工坊 |
//+------------------------------------------------------------------+
#property copyright "XAUOF 指标工坊"
#property link      "https://www.xauof.com"
#property version   "1.00"
#property description "多周期趋势共振：日线/4小时/1小时 的 EMA20 与 EMA60 方向一致时给出共振提示"

#property indicator_chart_window
#property indicator_buffers 3
#property indicator_plots   2

//--- 图形1：多头共振出现的箭头（向上）
#property indicator_type1   DRAW_ARROW
#property indicator_color1  clrLimeGreen
#property indicator_width1  3
#property indicator_label1  "多头共振"
//--- 图形2：空头共振出现的箭头（向下）
#property indicator_type2   DRAW_ARROW
#property indicator_color2  clrTomato
#property indicator_width2  3
#property indicator_label2  "空头共振"

//+------------------------------------------------------------------+
//| 可调参数（全部集中在这里）                                          |
//+------------------------------------------------------------------+
input int              InpFastPeriod   = 20;                // 快线均线周期（默认 20，数字越小越灵敏）
input int              InpSlowPeriod   = 60;                // 慢线均线周期（默认 60，必须大于快线）
input ENUM_MA_METHOD   InpMethod       = MODE_EMA;          // 均线类型（推荐 MODE_EMA 指数均线）
input ENUM_APPLIED_PRICE InpPrice      = PRICE_CLOSE;       // 均线计算价格（推荐 PRICE_CLOSE 收盘价）

input ENUM_TIMEFRAMES  InpTF1          = PERIOD_D1;         // 第一周期（默认 日线，看大方向）
input ENUM_TIMEFRAMES  InpTF2          = PERIOD_H4;         // 第二周期（默认 4小时，看中期结构）
input ENUM_TIMEFRAMES  InpTF3          = PERIOD_H1;         // 第三周期（默认 1小时，看短期节奏）

input bool             InpUseClosedBar = true;              // 只用大周期已收盘K线（true=信号不重画，推荐）
input bool             InpShowArrow    = true;              // 是否在共振刚成立的K线画箭头
input int              InpArrowGapPoints = 100;             // 箭头与K线的距离（点，黄金建议 80-200）
input int              InpMaxBars      = 5000;              // 最多计算最近多少根K线（0=全部，越小越快）

input bool             InpShowPanel    = true;              // 是否显示右上角共振显示区
input ENUM_BASE_CORNER InpCorner       = CORNER_RIGHT_UPPER;// 显示区所在角落（默认右上角）
input int              InpXDistance    = 14;                // 显示区离边缘的横向距离（像素）
input int              InpYDistance    = 18;                // 显示区离边缘的纵向距离（像素）
input int              InpFontSize     = 9;                 // 正文字号（建议 9-11）
input string           InpFontName     = "Microsoft YaHei"; // 字体（中文建议 微软雅黑）

input color            InpBullColor    = clrLimeGreen;      // 多头颜色（浅绿，不要用深色）
input color            InpBearColor    = clrTomato;         // 空头颜色（浅红）
input color            InpNeutralColor = clrDarkGray;       // 震荡颜色（浅灰）
input color            InpTitleColor   = clrDimGray;        // 标题与文字颜色
input color            InpPanelBgColor = clrWhiteSmoke;     // 显示区底色（浅色）
input color            InpPanelBorder  = clrSilver;         // 显示区边框色

input bool             InpEnableAlert  = false;             // 共振状态变化时是否弹窗提醒

//+------------------------------------------------------------------+
//| 缓冲区与全局变量                                                   |
//+------------------------------------------------------------------+
#define TF_COUNT 3

double UpBuf[];      // 多头共振箭头
double DnBuf[];      // 空头共振箭头
double StateBuf[];   // 每根K线的共振状态：1=多头共振 -1=空头共振 0=震荡（不画图，只做计算）

int              g_hFast[TF_COUNT];   // 三个周期的快线句柄
int              g_hSlow[TF_COUNT];   // 三个周期的慢线句柄
ENUM_TIMEFRAMES  g_tf[TF_COUNT];      // 三个周期
string           g_tfName[TF_COUNT];  // 周期中文名
int              g_lastDir[TF_COUNT]; // 最新K线上各周期的方向：1 多 / -1 空 / 0 持平

const string     g_prefix = "XAUOF_MTFRES_";   // 面板对象名前缀

//+------------------------------------------------------------------+
//| 把周期枚举转成中文名                                               |
//+------------------------------------------------------------------+
string TFToName(const ENUM_TIMEFRAMES tf)
{
   switch(tf)
   {
      case PERIOD_M1:  return("1分钟 M1");
      case PERIOD_M5:  return("5分钟 M5");
      case PERIOD_M15: return("15分钟 M15");
      case PERIOD_M30: return("30分钟 M30");
      case PERIOD_H1:  return("1小时 H1");
      case PERIOD_H4:  return("4小时 H4");
      case PERIOD_D1:  return("日线 D1");
      case PERIOD_W1:  return("周线 W1");
      case PERIOD_MN1: return("月线 MN1");
      default:         return(EnumToString(tf));
   }
}

//+------------------------------------------------------------------+
//| 方向 -> 文字 / 颜色                                                |
//+------------------------------------------------------------------+
string DirToText(const int dir)
{
   if(dir > 0) return("多头 ↑");
   if(dir < 0) return("空头 ↓");
   return("持平 -");
}

color DirToColor(const int dir)
{
   if(dir > 0) return(InpBullColor);
   if(dir < 0) return(InpBearColor);
   return(InpNeutralColor);
}

//+------------------------------------------------------------------+
//| OnInit                                                           |
//+------------------------------------------------------------------+
int OnInit()
{
   //--- 参数基本校验，避免非法值导致句柄创建失败
   int fast = (InpFastPeriod < 1) ? 1 : InpFastPeriod;
   int slow = (InpSlowPeriod < 2) ? 2 : InpSlowPeriod;
   if(fast >= slow)
   {
      Print("参数提示：快线周期应小于慢线周期，当前 快=", fast, " 慢=", slow);
      return(INIT_PARAMETERS_INCORRECT);
   }

   //--- 绑定缓冲区（序号与 plot 序号一一对应）
   SetIndexBuffer(0, UpBuf,    INDICATOR_DATA);
   SetIndexBuffer(1, DnBuf,    INDICATOR_DATA);
   SetIndexBuffer(2, StateBuf, INDICATOR_CALCULATIONS);

   //--- 箭头样式：233 向上实心箭头，234 向下实心箭头
   PlotIndexSetInteger(0, PLOT_ARROW, 233);
   PlotIndexSetInteger(1, PLOT_ARROW, 234);
   //--- 空值只能是 EMPTY_VALUE，绝不能用 0
   PlotIndexSetDouble(0, PLOT_EMPTY_VALUE, EMPTY_VALUE);
   PlotIndexSetDouble(1, PLOT_EMPTY_VALUE, EMPTY_VALUE);
   //--- 让箭头颜色跟随参数
   PlotIndexSetInteger(0, PLOT_LINE_COLOR, InpBullColor);
   PlotIndexSetInteger(1, PLOT_LINE_COLOR, InpBearColor);
   PlotIndexSetString(0, PLOT_LABEL, "多头共振");
   PlotIndexSetString(1, PLOT_LABEL, "空头共振");

   //--- 整理三个周期（PERIOD_CURRENT 换成当前图表周期）
   g_tf[0] = (InpTF1 == PERIOD_CURRENT) ? (ENUM_TIMEFRAMES)Period() : InpTF1;
   g_tf[1] = (InpTF2 == PERIOD_CURRENT) ? (ENUM_TIMEFRAMES)Period() : InpTF2;
   g_tf[2] = (InpTF3 == PERIOD_CURRENT) ? (ENUM_TIMEFRAMES)Period() : InpTF3;

   //--- 创建 6 个均线句柄（3 个周期 × 快慢线），只在这里创建一次
   for(int k = 0; k < TF_COUNT; k++)
   {
      g_tfName[k]  = TFToName(g_tf[k]);
      g_lastDir[k] = 0;

      g_hFast[k] = iMA(_Symbol, g_tf[k], fast, 0, InpMethod, InpPrice);
      g_hSlow[k] = iMA(_Symbol, g_tf[k], slow, 0, InpMethod, InpPrice);

      if(g_hFast[k] == INVALID_HANDLE || g_hSlow[k] == INVALID_HANDLE)
      {
         Print("均线句柄创建失败，周期：", EnumToString(g_tf[k]));
         return(INIT_FAILED);
      }
   }

   IndicatorSetString(INDICATOR_SHORTNAME,
                      StringFormat("多周期趋势共振 EMA%d/EMA%d", fast, slow));
   IndicatorSetInteger(INDICATOR_DIGITS, _Digits);

   //--- 先把显示区底板画出来
   if(InpShowPanel)
      CreatePanelBackground();

   return(INIT_SUCCEEDED);
}

//+------------------------------------------------------------------+
//| OnDeinit：清理面板与句柄                                           |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
{
   ObjectsDeleteAll(0, g_prefix);
   ChartRedraw();

   for(int k = 0; k < TF_COUNT; k++)
   {
      if(g_hFast[k] != INVALID_HANDLE) IndicatorRelease(g_hFast[k]);
      if(g_hSlow[k] != INVALID_HANDLE) IndicatorRelease(g_hSlow[k]);
   }
}

//+------------------------------------------------------------------+
//| 取出某个大周期的均线数据与对应的K线时间                              |
//| 说明：数组索引 0 = 最老，n-1 = 当前K线（不做 ArraySetAsSeries）      |
//+------------------------------------------------------------------+
bool LoadHTFData(const int k, const datetime fromTime,
                 double &fastArr[], double &slowArr[], datetime &timeArr[], int &n)
{
   n = 0;
   ENUM_TIMEFRAMES tf = g_tf[k];

   int secs = PeriodSeconds(tf);
   if(secs <= 0) return(false);   // 除法前先判断分母

   //--- 估算需要往前取多少根大周期K线（多给 8 根余量）
   long span = (long)(TimeCurrent() - fromTime);
   if(span < 0) span = 0;
   int need = (int)(span / secs) + 8;

   int availF = BarsCalculated(g_hFast[k]);
   int availS = BarsCalculated(g_hSlow[k]);
   if(availF <= InpSlowPeriod + 2 || availS <= InpSlowPeriod + 2)
      return(false);             // 大周期数据还没算完，等下一个 tick

   int avail = (availF < availS) ? availF : availS;
   int barsTF = Bars(_Symbol, tf);
   if(barsTF > 0 && barsTF < avail) avail = barsTF;
   if(need > avail) need = avail;
   if(need < 3) return(false);

   //--- 三份数据必须拷到同样长度，否则索引会错位，最多重试 3 次
   for(int attempt = 0; attempt < 3; attempt++)
   {
      int g1 = CopyBuffer(g_hFast[k], 0, 0, need, fastArr);
      int g2 = CopyBuffer(g_hSlow[k], 0, 0, need, slowArr);
      int g3 = CopyTime(_Symbol, tf, 0, need, timeArr);

      if(g1 <= 0 || g2 <= 0 || g3 <= 0) return(false);

      int m = (g1 < g2) ? g1 : g2;
      if(g3 < m) m = g3;

      if(g1 == m && g2 == m && g3 == m)
      {
         n = m;
         return(true);
      }
      need = m;
      if(need < 3) return(false);
   }
   return(false);
}

//+------------------------------------------------------------------+
//| 计算某个大周期在每一根当前周期K线上的方向                            |
//| dir[] 长度 = rates_total - start，1=快线在上 -1=快线在下 0=无效     |
//+------------------------------------------------------------------+
bool CalcTFDirection(const int k, const datetime &time[],
                     const int start, const int rates_total, int &dir[])
{
   int len = rates_total - start;
   if(len <= 0) return(false);
   if(ArrayResize(dir, len) != len) return(false);
   ArrayInitialize(dir, 0);

   double fastArr[], slowArr[];
   datetime timeArr[];
   int n = 0;
   if(!LoadHTFData(k, time[start], fastArr, slowArr, timeArr, n))
      return(false);

   int offset = (InpUseClosedBar ? 1 : 0);  // 取已收盘的上一根大周期K线
   int idx = 0;                             // 单向游标，随着 i 变大只往前走

   for(int i = start; i < rates_total; i++)
   {
      //--- 找到包含这根小周期K线的大周期K线
      while(idx + 1 < n && timeArr[idx + 1] <= time[i]) idx++;
      if(idx >= n) break;
      if(timeArr[idx] > time[i]) continue;   // 这根K线比大周期历史还老，跳过

      int u = idx - offset;
      if(u < 0 || u >= n) continue;

      double f = fastArr[u];
      double s = slowArr[u];
      if(f == EMPTY_VALUE || s == EMPTY_VALUE || f == 0.0 || s == 0.0) continue;

      int d = 0;
      if(f > s) d = 1;
      else if(f < s) d = -1;

      dir[i - start] = d;

      //--- 最新一根K线的方向单独记下来给右上角面板用
      if(i == rates_total - 1) g_lastDir[k] = d;
   }
   return(true);
}

//+------------------------------------------------------------------+
//| OnCalculate                                                      |
//+------------------------------------------------------------------+
int OnCalculate(const int rates_total,
                const int prev_calculated,
                const datetime &time[],
                const double &open[],
                const double &high[],
                const double &low[],
                const double &close[],
                const long &tick_volume[],
                const long &volume[],
                const int &spread[])
{
   if(rates_total < 10) return(0);

   //--- 第一次计算先把箭头缓冲区全部清成 EMPTY_VALUE
   if(prev_calculated == 0)
   {
      ArrayInitialize(UpBuf, EMPTY_VALUE);
      ArrayInitialize(DnBuf, EMPTY_VALUE);
      ArrayInitialize(StateBuf, 0.0);
   }

   //--- 计算起点：索引 0 = 最老K线，rates_total-1 = 当前K线
   int firstAllowed = 1;
   if(InpMaxBars > 0 && rates_total > InpMaxBars)
      firstAllowed = rates_total - InpMaxBars;
   if(firstAllowed < 1) firstAllowed = 1;

   int start = (prev_calculated > 0) ? prev_calculated - 1 : firstAllowed;
   if(start < firstAllowed) start = firstAllowed;
   if(start > rates_total - 1) start = rates_total - 1;

   //--- 逐周期取方向；任何一个周期数据没准备好就返回 0，下次重算
   int dirD1[], dirH4[], dirH1[];
   if(!CalcTFDirection(0, time, start, rates_total, dirD1)) return(0);
   if(!CalcTFDirection(1, time, start, rates_total, dirH4)) return(0);
   if(!CalcTFDirection(2, time, start, rates_total, dirH1)) return(0);

   double gap = InpArrowGapPoints * _Point;
   if(gap < 0) gap = 0;

   for(int i = start; i < rates_total && !IsStopped(); i++)
   {
      //--- 每根K线先清空，保证只有共振成立那一根才有箭头
      UpBuf[i] = EMPTY_VALUE;
      DnBuf[i] = EMPTY_VALUE;

      int p = i - start;
      if(p < 0 || p >= ArraySize(dirD1) || p >= ArraySize(dirH4) || p >= ArraySize(dirH1))
         continue;

      int a = dirD1[p];   // 日线方向
      int b = dirH4[p];   // 4小时方向
      int c = dirH1[p];   // 1小时方向

      //--- 三个周期全部向上 = 多头共振；全部向下 = 空头共振；否则震荡
      int st = 0;
      if(a == 1 && b == 1 && c == 1) st = 1;
      else if(a == -1 && b == -1 && c == -1) st = -1;

      StateBuf[i] = (double)st;

      if(i < 1) continue;
      int prevSt = (int)StateBuf[i - 1];

      //--- 第一根计算的K线没有可靠的“前一根”，不画箭头，避免假信号
      bool firstCalcBar = (i == start && prev_calculated == 0);

      if(InpShowArrow && !firstCalcBar)
      {
         if(st == 1 && prevSt != 1)  UpBuf[i] = low[i]  - gap;   // 多头共振刚成立
         if(st == -1 && prevSt != -1) DnBuf[i] = high[i] + gap;  // 空头共振刚成立
      }
   }

   //--- 更新右上角共振显示区（用最新一根K线的状态）
   int nowState = (int)StateBuf[rates_total - 1];
   if(InpShowPanel) UpdatePanel(nowState);

   //--- 状态变化提醒
   if(InpEnableAlert)
   {
      static int lastAlertState = -99;
      if(lastAlertState != -99 && nowState != lastAlertState && nowState != 0)
         Alert(_Symbol, " 多周期共振：", (nowState > 0 ? "多头共振" : "空头共振"));
      lastAlertState = nowState;
   }

   return(rates_total);
}

//+------------------------------------------------------------------+
//| 创建显示区底板                                                     |
//+------------------------------------------------------------------+
void CreatePanelBackground()
{
   string name = g_prefix + "BG";
   if(ObjectFind(0, name) < 0)
      ObjectCreate(0, name, OBJ_RECTANGLE_LABEL, 0, 0, 0);

   ObjectSetInteger(0, name, OBJPROP_CORNER,     InpCorner);
   ObjectSetInteger(0, name, OBJPROP_XDISTANCE,  InpXDistance);
   ObjectSetInteger(0, name, OBJPROP_YDISTANCE,  InpYDistance);
   ObjectSetInteger(0, name, OBJPROP_XSIZE,      182);
   ObjectSetInteger(0, name, OBJPROP_YSIZE,      140);
   ObjectSetInteger(0, name, OBJPROP_BGCOLOR,    InpPanelBgColor);
   ObjectSetInteger(0, name, OBJPROP_BORDER_TYPE, BORDER_FLAT);
   ObjectSetInteger(0, name, OBJPROP_COLOR,      InpPanelBorder);
   ObjectSetInteger(0, name, OBJPROP_WIDTH,      1);
   ObjectSetInteger(0, name, OBJPROP_BACK,       false);
   ObjectSetInteger(0, name, OBJPROP_SELECTABLE, false);
   ObjectSetInteger(0, name, OBJPROP_SELECTED,   false);
   ObjectSetInteger(0, name, OBJPROP_HIDDEN,     true);
   ObjectSetInteger(0, name, OBJPROP_ZORDER,     0);
}

//+------------------------------------------------------------------+
//| 创建/更新一行文字                                                  |
//+------------------------------------------------------------------+
void SetTextLine(const string suffix, const int x, const int y,
                 const string text, const color clr, const int fontSize)
{
   string name = g_prefix + suffix;
   if(ObjectFind(0, name) < 0)
      ObjectCreate(0, name, OBJ_LABEL, 0, 0, 0);

   ObjectSetInteger(0, name, OBJPROP_CORNER,     InpCorner);
   ObjectSetInteger(0, name, OBJPROP_ANCHOR,     ANCHOR_LEFT_UPPER);
   ObjectSetInteger(0, name, OBJPROP_XDISTANCE,  x);
   ObjectSetInteger(0, name, OBJPROP_YDISTANCE,  y);
   ObjectSetInteger(0, name, OBJPROP_COLOR,      clr);
   ObjectSetInteger(0, name, OBJPROP_FONTSIZE,   fontSize);
   ObjectSetString(0,  name, OBJPROP_FONT,       InpFontName);
   ObjectSetString(0,  name, OBJPROP_TEXT,       text);
   ObjectSetInteger(0, name, OBJPROP_BACK,       false);
   ObjectSetInteger(0, name, OBJPROP_SELECTABLE, false);
   ObjectSetInteger(0, name, OBJPROP_SELECTED,   false);
   ObjectSetInteger(0, name, OBJPROP_HIDDEN,     true);
   ObjectSetInteger(0, name, OBJPROP_ZORDER,     1);
}

//+------------------------------------------------------------------+
//| 刷新右上角共振显示区                                                |
//+------------------------------------------------------------------+
void UpdatePanel(const int state)
{
   CreatePanelBackground();

   //--- 文字从底板左侧 10 像素处开始排版
   int xText = InpXDistance + 182 - 10;
   int fs    = (InpFontSize < 7) ? 7 : InpFontSize;

   //--- 标题
   SetTextLine("T0", xText, InpYDistance + 8,
               "多周期趋势共振", InpTitleColor, fs + 1);

   //--- 均线说明
   SetTextLine("T1", xText, InpYDistance + 30,
               StringFormat("均线：EMA%d / EMA%d", InpFastPeriod, InpSlowPeriod),
               InpNeutralColor, fs - 1);

   //--- 三个周期明细
   for(int k = 0; k < TF_COUNT; k++)
   {
      SetTextLine(StringFormat("R%d", k),
                  xText, InpYDistance + 50 + k * 18,
                  g_tfName[k] + " ： " + DirToText(g_lastDir[k]),
                  DirToColor(g_lastDir[k]), fs);
   }

   //--- 共振结论
   string stText;
   color  stColor;
   if(state > 0)      { stText = "多头共振"; stColor = InpBullColor; }
   else if(state < 0) { stText = "空头共振"; stColor = InpBearColor; }
   else               { stText = "震荡";     stColor = InpNeutralColor; }

   SetTextLine("ST", xText, InpYDistance + 110, "结论： " + stText, stColor, fs + 2);

   //--- 边框跟着状态换色，一眼能看出当前处于什么状态
   ObjectSetInteger(0, g_prefix + "BG", OBJPROP_COLOR, stColor);

   ChartRedraw();
}
//+------------------------------------------------------------------+