#property copyright "Copyright (C) 2025 NAYA +237674724684"
#property link      "NAYA +237674724684"
#property version   "1.0"
#property strict

#include <Forexsb.com/Indicator.mqh>
#include <Forexsb.com/Enumerations.mqh>

class AdvancedSessionVWAPCrossoverStepped : public Indicator
{
public:
    AdvancedSessionVWAPCrossoverStepped(SlotTypes slotType);
    virtual void Calculate(DataSet &dataSet);
    
private:
    void CalculateAdvancedVWAP(int anchorPeriodIndex, int anchorHour, int anchorMinute, int resetPeriod, double &vwap[]);
    datetime GetAnchorStartTime(datetime currentTime, int anchorType);
    datetime GetLastResetTimeStepped(datetime currentTime, int anchorHour, int anchorMinute, int resetPeriod);
    int TimeDayCount(const MqlDateTime &dt);
};

AdvancedSessionVWAPCrossoverStepped::AdvancedSessionVWAPCrossoverStepped(SlotTypes slotType)
{
    SlotType = slotType;
    IndicatorName = "AdvancedSessionVWAPCrossoverStepped";
    WarningMessage = "Crossover between two SessionVWAP lines (Fast vs. Slow) with stepped parameters.";
    IsAllowLTF = true;
    ExecTime = ExecutionTime_DuringTheBar;
    IsSeparateChart = false;
    IsDiscreteValues = false;
    IsDefaultGroupAll = false;
}

void AdvancedSessionVWAPCrossoverStepped::Calculate(DataSet &dataSet)
{
    Data = GetPointer(dataSet);

    // Read parameters
    int fastAnchorPeriodIndex = (int)ListParam[1].Index;
    int fastResetPeriod = (int)StringToInteger(ListParam[2].Text);
    int slowAnchorPeriodIndex = (int)ListParam[3].Index;
    int slowResetPeriod = (int)StringToInteger(ListParam[4].Text);

    int fastAnchorHour = (int)NumParam[0].Value;
    int fastAnchorMinute = (int)NumParam[1].Value;
    int slowAnchorHour = (int)NumParam[2].Value;
    int slowAnchorMinute = (int)NumParam[3].Value;

    int previous = CheckParam[0].Checked ? 1 : 0;

    // Compute VWAPs
    double fastVWAP[];
    CalculateAdvancedVWAP(fastAnchorPeriodIndex, fastAnchorHour, fastAnchorMinute, fastResetPeriod, fastVWAP);

    double slowVWAP[];
    CalculateAdvancedVWAP(slowAnchorPeriodIndex, slowAnchorHour, slowAnchorMinute, slowResetPeriod, slowVWAP);

    // Build oscillator
    int firstBar = 3 + previous + 2;

    double oscillator[];
    ArrayResize(oscillator, Data.Bars);
    ArrayInitialize(oscillator, 0.0);

    for(int bar = firstBar; bar < Data.Bars; bar++)
    {
        oscillator[bar] = fastVWAP[bar] - slowVWAP[bar];
    }

    // Create components
    Component[0].CompName = "Fast VWAP";
    Component[0].DataType = IndComponentType_IndicatorValue;
    Component[0].FirstBar = firstBar;
    ArrayResize(Component[0].Value, Data.Bars);
    ArrayCopy(Component[0].Value, fastVWAP);

    Component[1].CompName = "Slow VWAP";
    Component[1].DataType = IndComponentType_IndicatorValue;
    Component[1].FirstBar = firstBar;
    ArrayResize(Component[1].Value, Data.Bars);
    ArrayCopy(Component[1].Value, slowVWAP);

    ArrayResize(Component[2].Value, Data.Bars);
    ArrayInitialize(Component[2].Value, 0.0);
    Component[2].FirstBar = firstBar;
    
    ArrayResize(Component[3].Value, Data.Bars);
    ArrayInitialize(Component[3].Value, 0.0);
    Component[3].FirstBar = firstBar;

    // Set component types based on slot
    if(SlotType == SlotTypes_OpenFilter)
    {
        Component[2].DataType = IndComponentType_AllowOpenLong;
        Component[2].CompName = "Is long entry allowed";
        Component[3].DataType = IndComponentType_AllowOpenShort;
        Component[3].CompName = "Is short entry allowed";
    }
    else if(SlotType == SlotTypes_CloseFilter)
    {
        Component[2].DataType = IndComponentType_ForceCloseLong;
        Component[2].CompName = "Close out long position";
        Component[3].DataType = IndComponentType_ForceCloseShort;
        Component[3].CompName = "Close out short position";
    }

    // Apply logic
    string logicText = ListParam[0].Text;
    for(int bar = firstBar + previous; bar < Data.Bars; bar++)
    {
        double fastCurrent = fastVWAP[bar - previous];
        double fastPrevious = fastVWAP[bar - previous - 1];
        double slowCurrent = slowVWAP[bar - previous];
        double slowPrevious = slowVWAP[bar - previous - 1];
        double oscCurrent = oscillator[bar - previous];
        double oscPrevious = oscillator[bar - previous - 1];

        if(logicText == "Fast SessionVWAP crosses Slow SessionVWAP upward")
        {
            Component[2].Value[bar] = (oscCurrent > 0 && oscPrevious <= 0) ? 1.0 : 0.0;
            Component[3].Value[bar] = (oscCurrent < 0 && oscPrevious >= 0) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP crosses Slow SessionVWAP downward")
        {
            Component[2].Value[bar] = (oscCurrent < 0 && oscPrevious >= 0) ? 1.0 : 0.0;
            Component[3].Value[bar] = (oscCurrent > 0 && oscPrevious <= 0) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP is higher than Slow SessionVWAP")
        {
            Component[2].Value[bar] = (oscCurrent > 0) ? 1.0 : 0.0;
            Component[3].Value[bar] = (oscCurrent < 0) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP is lower than Slow SessionVWAP")
        {
            Component[2].Value[bar] = (oscCurrent < 0) ? 1.0 : 0.0;
            Component[3].Value[bar] = (oscCurrent > 0) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP rises, Slow SessionVWAP falls")
        {
            Component[2].Value[bar] = (fastCurrent > fastPrevious + Sigma() && 
                                      slowCurrent < slowPrevious - Sigma()) ? 1.0 : 0.0;
            Component[3].Value[bar] = (fastCurrent < fastPrevious - Sigma() && 
                                      slowCurrent > slowPrevious + Sigma()) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP falls, Slow SessionVWAP rises")
        {
            Component[2].Value[bar] = (fastCurrent < fastPrevious - Sigma() && 
                                      slowCurrent > slowPrevious + Sigma()) ? 1.0 : 0.0;
            Component[3].Value[bar] = (fastCurrent > fastPrevious + Sigma() && 
                                      slowCurrent < slowPrevious - Sigma()) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP rises, Slow SessionVWAP rises")
        {
            Component[2].Value[bar] = (fastCurrent > fastPrevious + Sigma() && 
                                      slowCurrent > slowPrevious + Sigma()) ? 1.0 : 0.0;
            Component[3].Value[bar] = (fastCurrent < fastPrevious - Sigma() && 
                                      slowCurrent < slowPrevious - Sigma()) ? 1.0 : 0.0;
        }
        else if(logicText == "Fast SessionVWAP falls, Slow SessionVWAP falls")
        {
            Component[2].Value[bar] = (fastCurrent < fastPrevious - Sigma() && 
                                      slowCurrent < slowPrevious - Sigma()) ? 1.0 : 0.0;
            Component[3].Value[bar] = (fastCurrent > fastPrevious + Sigma() && 
                                      slowCurrent > slowPrevious + Sigma()) ? 1.0 : 0.0;
        }
    }
}

void AdvancedSessionVWAPCrossoverStepped::CalculateAdvancedVWAP(int anchorPeriodIndex, int anchorHour, int anchorMinute, int resetPeriod, double &vwap[])
{
    int bars = Data.Bars;
    ArrayResize(vwap, bars);
    ArrayInitialize(vwap, 0.0);
    
    double cumPV = 0.0;
    double cumV = 0.0;
    datetime currentPeriodTime = 0;

    for(int iBar = 3; iBar < bars; iBar++)
    {
        datetime barTime = Data.Time[iBar];
        datetime barEndTime = barTime + (Period() * 60); // Bar end time
        datetime periodStart;

        if(anchorPeriodIndex < 3) // Daily, Weekly, Monthly
        {
            periodStart = GetAnchorStartTime(barEndTime, anchorPeriodIndex + 1);
        }
        else // Session
        {
            periodStart = GetLastResetTimeStepped(barEndTime, anchorHour, anchorMinute, resetPeriod);
        }

        if(periodStart != currentPeriodTime)
        {
            cumPV = 0.0;
            cumV = 0.0;
            currentPeriodTime = periodStart;
        }

        double typicalPrice = (Data.Open[iBar] + Data.High[iBar] + Data.Low[iBar] + Data.Close[iBar]) / 4.0;
        double volume = Data.Volume[iBar];

        cumPV += typicalPrice * volume;
        cumV += volume;

        vwap[iBar] = (cumV > 0.0) ? (cumPV / cumV) : 0.0;
    }
}

datetime AdvancedSessionVWAPCrossoverStepped::GetAnchorStartTime(datetime currentTime, int anchorType)
{
    MqlDateTime s;
    TimeToStruct(currentTime, s);

    switch(anchorType)
    {
        case 1: // Daily
            s.hour = s.min = s.sec = 0;
            break;
        case 2: // Weekly (Monday)
            while(s.day_of_week != 1) // Monday==1
            {
                currentTime -= 86400;
                TimeToStruct(currentTime, s);
            }
            s.hour = s.min = s.sec = 0;
            break;
        case 3: // Monthly
            s.day = 1;
            s.hour = s.min = s.sec = 0;
            break;
        default:
            s.hour = s.min = s.sec = 0;
            break;
    }
    return StructToTime(s);
}

datetime AdvancedSessionVWAPCrossoverStepped::GetLastResetTimeStepped(datetime currentTime, int anchorHour, int anchorMinute, int resetPeriod)
{
    MqlDateTime currentMqlTime;
    TimeToStruct(currentTime, currentMqlTime);
    
    // Create today's anchor time
    MqlDateTime anchorToday = currentMqlTime;
    anchorToday.hour = anchorHour;
    anchorToday.min = anchorMinute;
    anchorToday.sec = 0;
    datetime anchorTimeToday = StructToTime(anchorToday);
    
    if(currentTime >= anchorTimeToday)
    {
        // Calculate how many full reset periods have passed
        int minutesSinceAnchor = (int)((currentTime - anchorTimeToday) / 60);
        int periods = minutesSinceAnchor / resetPeriod;
        return anchorTimeToday + (periods * resetPeriod * 60);
    }
    else
    {
        // Use yesterday's anchor time
        datetime anchorYesterday = anchorTimeToday - 86400;
        int minutesSinceAnchor = (int)((currentTime - anchorYesterday) / 60);
        int periods = minutesSinceAnchor / resetPeriod;
        return anchorYesterday + (periods * resetPeriod * 60);
    }
}

int AdvancedSessionVWAPCrossoverStepped::TimeDayCount(const MqlDateTime &dt)
{
    if(dt.mon == 2)
    {
        // February
        if((dt.year % 4 == 0 && dt.year % 100 != 0) || dt.year % 400 == 0)
            return 29; // Leap year
        else
            return 28;
    }
    else if(dt.mon == 4 || dt.mon == 6 || dt.mon == 9 || dt.mon == 11)
    {
        return 30;
    }
    return 31;
}