//+------------------------------------------------------------------+
//|                                                     PinbarSignal |
//|                                            Copyright 2025, You  |
//|                                                       mql5.com  |
//+------------------------------------------------------------------+
#property copyright "Copyright 2025"
#property link      "https://www.mql5.com"
#property version   "1.00"

//+------------------------------------------------------------------+
//| 输入参数                                                          |
//+------------------------------------------------------------------+
input group "=====信号与运行参数======" 
input string SymbolsList      = "XAUUSD,EURUSD,GBPUSD,BTCUSD,ETHUSD,XRPUSD,DOGEUSD,BNBUSD,SOLUSD,LTCUSD,LINKUSD,AAVEUSD,DOTUSD";     // 多品种，英文逗号分割
input string TimeframesList   = "M15,M30,H1,H4";      // 多周期，示例: "H1, M30, H4"
input string SymbolSuffix     = "";                   // 品种后缀
input bool EnableEmail        = true;                 // 启用邮件通知
input string MailSubjectPrefix= "信号提醒";           // 邮件标题前缀

input group "=====Pinbar识别参数====="
input double BodyToRangeMax   = 0.3;                  // 实体占总长度最大比例（越小越像针）
input double WickDominanceMin = 0.6;                  // 主影线占总长度最小比例
input double NoseToTailRatio  = 2.0;                  // 主影线/次影线 最小倍数

input group "=====调试====="
input bool DebugSendTestOnStart = false;              // 启用后，EA启动即发送测试邮件
input bool EnableChartArrows     = true;              // 符合Pinbar时在图表上标记箭头（仅当前图表品种）

// 全局/静态变量
datetime lastCheckedTimes[];                          // 每个周期的上次处理收线时间（以首个品种为基准）
string symbols[];                                     // 解析后的品种数组
ENUM_TIMEFRAMES timeframes[];                         // 解析后的周期数组

//+------------------------------------------------------------------+
//| 工具函数：去除字符串首尾空格                                     |
//+------------------------------------------------------------------+
string Trim(const string text) {
    string s = text;
    while(StringLen(s)>0 && (ushort)StringGetCharacter(s,0)<=32) s = StringSubstr(s,1);
    while(StringLen(s)>0 && (ushort)StringGetCharacter(s,StringLen(s)-1)<=32) s = StringSubstr(s,0,StringLen(s)-1);
    return s;
}

//+------------------------------------------------------------------+
//| 解析SymbolsList到数组                                            |
//+------------------------------------------------------------------+
int ParseSymbols() {
    ArrayFree(symbols);
    string parts[];
    int n = StringSplit(SymbolsList, ',', parts);
    for(int i=0;i<n;i++) {
        string sym = Trim(parts[i]);
        if(SymbolSuffix!="") sym += SymbolSuffix;
        if(sym!="") {
            int sz = ArraySize(symbols);
            ArrayResize(symbols, sz+1);
            symbols[sz] = sym;
        }
    }
    if(ArraySize(symbols)==0) {
        ArrayResize(symbols,1);
        symbols[0] = _Symbol; // 兜底
    }
    return ArraySize(symbols);
}

//+------------------------------------------------------------------+
//| 解析 TimeframesList 到周期数组                                     |
//+------------------------------------------------------------------+
bool ParseTimeframes() {
    ArrayFree(timeframes);
    string parts[];
    int n = StringSplit(TimeframesList, ',', parts);
    for(int i=0;i<n;i++) {
        string tok = Trim(parts[i]);
        StringToUpper(tok); // MQL5 方法式：原位大写化，返回bool
        ENUM_TIMEFRAMES tf = PERIOD_CURRENT;
        if(tok=="M1") tf = PERIOD_M1;
        else if(tok=="M2") tf = PERIOD_M2;
        else if(tok=="M3") tf = PERIOD_M3;
        else if(tok=="M4") tf = PERIOD_M4;
        else if(tok=="M5") tf = PERIOD_M5;
        else if(tok=="M6") tf = PERIOD_M6;
        else if(tok=="M10") tf = PERIOD_M10;
        else if(tok=="M12") tf = PERIOD_M12;
        else if(tok=="M15") tf = PERIOD_M15;
        else if(tok=="M20") tf = PERIOD_M20;
        else if(tok=="M30") tf = PERIOD_M30;
        else if(tok=="H1") tf = PERIOD_H1;
        else if(tok=="H2") tf = PERIOD_H2;
        else if(tok=="H3") tf = PERIOD_H3;
        else if(tok=="H4") tf = PERIOD_H4;
        else if(tok=="H6") tf = PERIOD_H6;
        else if(tok=="H8") tf = PERIOD_H8;
        else if(tok=="H12") tf = PERIOD_H12;
        else if(tok=="D1") tf = PERIOD_D1;
        else if(tok=="W1") tf = PERIOD_W1;
        else if(tok=="MN1") tf = PERIOD_MN1;
        else continue;
        int sz = ArraySize(timeframes);
        ArrayResize(timeframes, sz+1);
        timeframes[sz] = tf;
    }
    if(ArraySize(timeframes)==0) {
        ArrayResize(timeframes, 2);
        timeframes[0] = PERIOD_H1;
        timeframes[1] = PERIOD_M30;
    }
    ArrayResize(lastCheckedTimes, ArraySize(timeframes));
    for(int k=0;k<ArraySize(lastCheckedTimes);k++) lastCheckedTimes[k]=0;
    return(ArraySize(timeframes)>0);
}

//+------------------------------------------------------------------+
//| 读取指定品种与周期的上一根K线（已收线）                           |
//+------------------------------------------------------------------+
bool GetPrevBar(const string sym, const ENUM_TIMEFRAMES tf, MqlRates &bar) {
    // 明确请求上一根已收线K（shift=1，count=1），避免数组顺序或未收线K的歧义
    MqlRates rates[1];
    int copied = CopyRates(sym, tf, 1, 1, rates);
    if(copied<1) return false;
    bar = rates[0];
    return true;
}

//+------------------------------------------------------------------+
//| 判定Pinbar（返回：0=否, 1=看涨Pinbar, -1=看跌Pinbar）              |
//+------------------------------------------------------------------+
int IsPinbar(const MqlRates &b, const int digits) {
    double point = SymbolInfoDouble(_Symbol, SYMBOL_POINT);
    // 总长度（高低）
    double range = b.high - b.low;
    if(range <= 0) return 0;

    // 实体与影线
    double body = MathAbs(b.close - b.open);
    double upperWick = b.high - MathMax(b.open, b.close);
    double lowerWick = MathMin(b.open, b.close) - b.low;

    double bodyRatio  = body / range;
    if(bodyRatio > BodyToRangeMax) return 0;

    // 判断主影线与方向
    if(upperWick > lowerWick) {
        double dominance = upperWick / range; // 上影占比
        double ratio = (lowerWick <= 0 ? 9999.0 : upperWick / lowerWick);
        if(dominance >= WickDominanceMin && ratio >= NoseToTailRatio)
            return -1; // 看跌Pinbar（长上影）
    } else if(lowerWick > upperWick) {
        double dominance = lowerWick / range; // 下影占比
        double ratio = (upperWick <= 0 ? 9999.0 : lowerWick / upperWick);
        if(dominance >= WickDominanceMin && ratio >= NoseToTailRatio)
            return 1; // 看涨Pinbar（长下影）
    }
    return 0;
}

//+------------------------------------------------------------------+
//| 将周期枚举转为短标签（M1/H1/D1等）                                 |
//+------------------------------------------------------------------+
string TfToLabel(const ENUM_TIMEFRAMES tf) {
    switch(tf) {
        case PERIOD_M1:  return "M1";
        case PERIOD_M2:  return "M2";
        case PERIOD_M3:  return "M3";
        case PERIOD_M4:  return "M4";
        case PERIOD_M5:  return "M5";
        case PERIOD_M6:  return "M6";
        case PERIOD_M10: return "M10";
        case PERIOD_M12: return "M12";
        case PERIOD_M15: return "M15";
        case PERIOD_M20: return "M20";
        case PERIOD_M30: return "M30";
        case PERIOD_H1:  return "H1";
        case PERIOD_H2:  return "H2";
        case PERIOD_H3:  return "H3";
        case PERIOD_H4:  return "H4";
        case PERIOD_H6:  return "H6";
        case PERIOD_H8:  return "H8";
        case PERIOD_H12: return "H12";
        case PERIOD_D1:  return "D1";
        case PERIOD_W1:  return "W1";
        case PERIOD_MN1: return "MN1";
        default:         return EnumToString(tf);
    }
}

//+------------------------------------------------------------------+
//| 在图表上标记Pinbar箭头（仅当前图表与主窗口）                       |
//+------------------------------------------------------------------+
void MarkPinbarOnChart(const string sym, const ENUM_TIMEFRAMES tf, const MqlRates &b, const int dir) {
	if(!EnableChartArrows) return;
	if(sym != _Symbol) return; // 仅在当前图表品种上绘制

	// 生成唯一对象名：Pinbar_<TF>_<time>_<dir>
	string name = StringFormat("Pinbar_%s_%I64d_%d", EnumToString(tf), (long)b.time, dir);
	// 价格位置：看涨放在低点下方一点，看跌放在高点上方一点
	double point = SymbolInfoDouble(sym, SYMBOL_POINT);
	double price = (dir>0 ? b.low - 2.0*point : b.high + 2.0*point);
	ENUM_OBJECT type = (dir>0 ? OBJ_ARROW_BUY : OBJ_ARROW_SELL);

	// 若已存在同名对象则先删除
	if(ObjectFind(0, name) >= 0) ObjectDelete(0, name);
	bool created = ObjectCreate(0, name, type, 0, b.time, price);
	if(!created) {
		Print("[Pinbar] 创建箭头对象失败:", name, ", err=", GetLastError());
		return;
	}
	ObjectSetInteger(0, name, OBJPROP_WIDTH, 1);
	ObjectSetInteger(0, name, OBJPROP_BACK, false);
	ObjectSetInteger(0, name, OBJPROP_HIDDEN, false);
	ObjectSetInteger(0, name, OBJPROP_SELECTABLE, false);
	ObjectSetInteger(0, name, OBJPROP_ANCHOR, ANCHOR_CENTER);
	// 颜色区分方向
	color clr = (dir>0 ? clrLime : clrRed);
	ObjectSetInteger(0, name, OBJPROP_COLOR, clr);
}

//+------------------------------------------------------------------+
//| 在收线时扫描所有品种，返回汇总文本                                |
//+------------------------------------------------------------------+
string ScanAllSymbolsAndSummarize(const ENUM_TIMEFRAMES tf, const datetime barTime) {
    string lines = "";
    for(int i=0;i<ArraySize(symbols);i++) {
        string sym = symbols[i];
        MqlRates b;
        if(!GetPrevBar(sym, tf, b)) {
            continue;
        }
        // 只在同一收线时间的bar上做判断（不同品种会偶发不同步，这里放宽不强制相等）
        int digits = (int)SymbolInfoInteger(sym, SYMBOL_DIGITS);
        int pinbarType = IsPinbar(b, digits);
        if(pinbarType != 0) {
            string type = (pinbarType > 0 ? "Bullish" : "Bearish");
            // 实时打印每次检测到的Pinbar
            Print(StringFormat("[Pinbar] %s | %s | %s", sym, type, TimeToString(b.time, TIME_DATE|TIME_MINUTES)));
            // 在当前图表上做箭头标记（仅当前图表品种）
            MarkPinbarOnChart(sym, tf, b, pinbarType);
            // 邮件正文：<品种><周期>出现↑/↓Pinbar
            string arrow = (pinbarType > 0 ? "↑" : "↓");
            lines += StringFormat("%s %s 出现%sPinbar\n", sym, TfToLabel(tf), arrow);
        }
    }
    return lines;
}

//+------------------------------------------------------------------+
//| 发送测试邮件                                                     |
//+------------------------------------------------------------------+
void SendTestEmailOnStart() {
    string subject = MailSubjectPrefix;
    string body = "这是一封来自 PinbarSignal 的测试邮件，用于验证终端邮件配置是否正常。";
    if(EnableEmail) {
        bool ok = SendMail(subject, body);
        if(!ok) {
            Print("[Pinbar] 测试邮件发送失败，请检查终端邮件设置。");
        } else {
            Print("[Pinbar] 测试邮件已发送: ", subject);
            Print("[Pinbar] 邮件内容:", body);
        }
    } else {
        Print("[Pinbar] 未启用终端邮件，测试主题: ", subject);
        Print("[Pinbar] 未启用终端邮件，测试内容:\n", body);
    }
}

//+------------------------------------------------------------------+
//| 在新的收线时触发：汇总并发送邮件                                  |
//+------------------------------------------------------------------+
void OnNewClosedBar(const ENUM_TIMEFRAMES tf, const datetime newBarTime) {
    string result = ScanAllSymbolsAndSummarize(tf, newBarTime);
    if(result=="") {
        Print("[Pinbar] 本次收线未检测到信号。");
        return;
    }
    string subject = MailSubjectPrefix;
    string body = result;
    if(EnableEmail) {
        bool ok = SendMail(subject, body);
        if(!ok) {
            Print("[Pinbar] 发送邮件失败，请检查终端邮件设置。");
        } else {
            Print("[Pinbar] 邮件已发送: ", subject);
            Print("[Pinbar] 邮件内容:", body);
        }
    } else {
        Print("[Pinbar] 邮件未启用，主题: ", subject);
        Print("[Pinbar] 邮件未启用，结果:\n", body);
    }
}

//+------------------------------------------------------------------+
//| 计时器：每秒检查一次是否出现新收线                                |
//+------------------------------------------------------------------+
void CheckNewBarEvent() {
    if(ArraySize(symbols)==0) return;
    string base = symbols[0];
    // 收集触发的(时间, 周期)
    ENUM_TIMEFRAMES triggers_tf[];
    datetime triggers_time[];
    for(int t=0; t<ArraySize(timeframes); t++) {
        ENUM_TIMEFRAMES tf = timeframes[t];
        datetime times[2];
        int copied = CopyTime(base, tf, 0, 2, times);
        if(copied<2) continue;
        datetime prevClosedTime = times[1];
        if(prevClosedTime<=0) continue;

        if(lastCheckedTimes[t] == 0) {
            lastCheckedTimes[t] = prevClosedTime;
            continue;
        }
        if(prevClosedTime != lastCheckedTimes[t]) {
            lastCheckedTimes[t] = prevClosedTime;
            int sz = ArraySize(triggers_tf);
            ArrayResize(triggers_tf, sz+1);
            ArrayResize(triggers_time, sz+1);
            triggers_tf[sz] = tf;
            triggers_time[sz] = prevClosedTime;
        }
    }

    // 将同一时间的所有周期合并为一次发送
    for(int i=0;i<ArraySize(triggers_time);i++) {
        if(triggers_time[i]==0) continue; // 已处理
        datetime tkey = triggers_time[i];
        string combined = "";
        // 包含当前索引
        combined += ScanAllSymbolsAndSummarize(triggers_tf[i], tkey);
        // 收集同一时间的其余周期
        for(int j=i+1;j<ArraySize(triggers_time);j++) {
            if(triggers_time[j]==tkey) {
                combined += ScanAllSymbolsAndSummarize(triggers_tf[j], tkey);
                triggers_time[j] = 0; // 标记已并入
            }
        }
        // 发送一次（若有结果）
        if(combined!="") {
            string subject = MailSubjectPrefix;
            string body = combined;
            if(EnableEmail) {
                bool ok = SendMail(subject, body);
                if(!ok) {
                    Print("[Pinbar] 发送邮件失败，请检查终端邮件设置。");
                } else {
                    Print("[Pinbar] 邮件已发送: ", subject);
                    Print("[Pinbar] 邮件内容:", body);
                }
            } else {
                Print("[Pinbar] 邮件未启用，主题: ", subject);
                Print("[Pinbar] 邮件未启用，结果:\n", body);
            }
        } else {
            Print("[Pinbar] 本次收线未检测到信号。");
        }
        triggers_time[i] = 0; // 标记自身
    }
}

//+------------------------------------------------------------------+
//| Expert initialization                                             |
//+------------------------------------------------------------------+
int OnInit() {
    ParseSymbols();
    ParseTimeframes();
    EventSetTimer(1); // 每秒检查一次
    Print("=== PinbarSignal 初始化 ===");
    string tfs = "";
    for(int i=0;i<ArraySize(timeframes);i++) {
        if(i>0) tfs += ", ";
        tfs += EnumToString(timeframes[i]);
    }
    Print("监控周期:", tfs);
    Print("监控品种:", SymbolsList);
    if(DebugSendTestOnStart) {
        SendTestEmailOnStart();
    }
    return(INIT_SUCCEEDED);
}

//+------------------------------------------------------------------+
//| Expert deinitialization                                           |
//+------------------------------------------------------------------+
void OnDeinit(const int reason) {
    EventKillTimer();
}

//+------------------------------------------------------------------+
//| OnTick 保持轻量（主要逻辑在OnTimer）                               |
//+------------------------------------------------------------------+
void OnTick() {
    // 仅保证活性，不做重逻辑
}

//+------------------------------------------------------------------+
//| OnTimer：定时检查                                                 |
//+------------------------------------------------------------------+
void OnTimer() {
    CheckNewBarEvent();
}

//+------------------------------------------------------------------+