//+------------------------------------------------------------------+
//| RenkoGPTBreakoutEA.mq5                                           |
//| Самостоятельный советник для торговли пробоев структуры Renko    |
//+------------------------------------------------------------------+
//
// НАЗНАЧЕНИЕ
// 1. Самостоятельно строит внутреннюю последовательность кирпичей Renko
//    по потоку котировок; внешний индикатор и подключаемый ресурс не требуются.
// 2. Отображает торговую панель с кнопками BUY/SELL, статусом торговли,
//    диагностикой, размером кирпича и предполагаемыми уровнями входа.
//
// РУЧНАЯ ПОДГОТОВКА ВХОДА
// 3. Нажатие BUY или SELL фиксирует цену пробоя и структурный Stop Loss
//    по доступной на этот момент структуре Renko. Уровни должны оставаться
//    неизменными, пока подготовка активна; новые экстремумы их не сдвигают.
// 4. BUY ожидает пробой фиксированной цены вверх; SELL — пробой фиксированной
//    цены вниз. На панели отображается именно сохранённая цена, а не новый
//    уровень, пересчитанный из текущего экстремума.
// 5. Если цена достигает/пересекает зафиксированный SL до входа, подготовка
//    соответствующего направления отменяется, кнопка выключается, а в ячейке
//    цены показывается «нет цены входа». Пользователь также может отменить
//    подготовку повторным нажатием активной кнопки.
// 6. Если цена входа уже пробита в момент нажатия кнопки, подготовка не должна
//    активироваться задним числом: требуется новое пересечение уровня.
//
// ОТКРЫТИЕ СДЕЛКИ И РИСКИ
// 7. После пересечения уровня советник проверяет разрешение торговли,
//    торговое время, спред и остальные предусмотренные ограничения. На счёте
//    Hedging открывает отдельную корзину позиций; неоднозначный ответ не вызывает
//    слепого повтора. Неполная корзина фиксируется в журнале.
// 8. Stop Loss основан на зафиксированном структурном уровне с буфером и общий
//    для корзины. Для каждой позиции TP рассчитывается от фактической цены сделки
//    с нарастающим шагом. Значения *_Points измеряются в points инструмента.
// 9. InpSignalMaxAgeSeconds — защитный максимальный срок жизни возникшего
//    сигнала после пробоя; он не заменяет событийную отмену подготовки до входа.
// 10. Часы торгового окна задаются по Москве. Проверьте соответствие часового
//     пояса и поведения закрытия позиций настройкам брокера и терминала.
//
// ДАННЫЕ, ДИАГНОСТИКА И ПРОВЕРКИ
// 11. Для восстановления структуры используется ограниченная история тиков
//     за InpHistoryDays; результат зависит от доступности истории у брокера.
// 12. Диагностические события записываются в журнал/CSV, если запись доступна.
//     В журнале ищите причины подготовки, отмены, попытки и результата ордера.
// 13. Кодовые статические проверки не заменяют компиляцию в MetaEditor,
//     визуальную проверку панели и тестирование в Strategy Tester/на демо-счёте.
//     До таких проверок нельзя считать исполнение и прибыльность подтверждёнными.
//
// ВАЖНО: советник может отправлять реальные торговые заявки при разрешённой
// торговле. Сначала проверяйте его на исторических данных и демо-счёте.
//+------------------------------------------------------------------+
// MQL4-директива #property strict в MQL5 не используется и удалена
#property version   "1.08"
#property description "Self-contained Renko breakout EA; no external indicator resource dependency"

#include <Trade/Trade.mqh>
//--- Константы истории, маржи и журнала
#define HISTORY_CHUNK_SECONDS   (6*3600)   // Размер чанка истории тиков
#define HISTORY_PROBE_SECONDS   (15*60)    // Проверка свежей истории перед пересборкой
#define HISTORY_INIT_BUDGET_MS  15000      // Бюджет первичной пересборки в OnInit
#define HISTORY_RETRY_MIN_MS    10000      // Минимальная пауза между попытками
#define HISTORY_RETRY_MAX_MS    60000      // Максимальная пауза между попытками
#define MARGIN_SAFETY_RATIO     1.20       // Запас свободной маржи к требуемой
#define PANEL_MIN_INTERVAL_MS   200        // Минимальный интервал обновления панели


input int      InpBrickPoints = 10;          // Размер кирпича Renko, points
input int      InpPositionsCount = 5;         // Количество отдельных позиций в корзине
input double   InpPositionLots = 0.01;        // Объём каждой позиции
input int      InpTakeProfitStepPoints = 500; // Шаг ступенчатого TP, points
input int      InpSLBufferPoints = 3;         // Буфер SL: BUY ниже минимума, SELL выше максимума, points
input int      InpRetrySeconds = 5;           // Интервал повторной попытки
input int      InpSignalMaxAgeSeconds = 120;   // Максимальный возраст сигнала; 0 не допускается
input int      InpMaxSpreadPoints = 30;       // Максимальный спред, points; 0 = без фильтра (по умолчанию фильтр включён)
input int      InpDeviationPoints = 20;       // Допустимое отклонение, points
input ulong    InpMagicNumber = 6211026;      // Magic Number
input string   InpInstanceId = "default";      // Постоянный уникальный ID настроек для этого символа/Magic
input int      InpHistoryDays = 7;            // История тиков для восстановления структуры, дней (30 — заметно медленнее старт)
input int      InpTradeStartHourMSK = 3;      // Начало торговли, Москва
input int      InpTradeEndHourMSK = 23;       // Конец торговли, Москва (не включая)
input bool     InpCloseAt23MSK = false;       // Включить автозакрытие по московскому времени
input int      InpCloseHourMSK = 23;               // Час автозакрытия по Москве: 0–23
input bool     InpCloseAllSymbolPositions = true;  // Совместимость настроек: при автозакрытии закрываются все позиции символа
input string   InpErrorLogFile = "RenkoGPTBreakoutEA_errors.csv";

input bool     InpBuyEnabledInitially = false;  // BUY-режим при запуске
input bool     InpSellEnabledInitially = false; // SELL-режим при запуске
input color    InpButtonActiveColor = clrForestGreen; // Цвет активных кнопок
input color    InpButtonInactiveColor = clrFireBrick;  // Цвет неактивных кнопок
input color    InpTradeOnColor = clrLimeGreen;            // Индикатор TRADE ON
input color    InpTradeOffColor = clrTomato;              // Индикатор TRADE OFF

int g_panelYOffset=0;
string g_instanceTag="", g_buyButton="", g_sellButton="", g_brickEdit="", g_brickApply="", g_positionsEdit="", g_lotsEdit="", g_basketApply="", g_fivePositionsButton="", g_positionsLabel="", g_lotsLabel="", g_statusLabel="", g_terminalTradeLabel="", g_terminalTradeDot="";
int g_runtimePositionsCount=5;
double g_runtimePositionLots=0.01;
string g_diagLabels[10];
string g_lastCloseInfo="Закрытие позиции: данных пока нет";
string g_lastDecision="Ожидание сигнала";
bool g_buyEnabled=false, g_sellEnabled=false;
int g_runtimeBrickPoints=0;
bool g_restoreBuyEnabled=false, g_restoreSellEnabled=false;
bool g_restoreModesPending=false;
bool g_persistenceReady=false;

struct Brick
{
   datetime time;
   double open;
   double high;
   double low;
   double close;
   int direction;
};

CTrade g_trade;
Brick g_bricks[];
int g_count=0;
double g_brickSize=0.0, g_lastClose=0.0, g_lastBid=0.0;
int g_direction=0;
bool g_haveAnchor=false, g_historyReady=false;
bool g_processBidGuardExceeded=false;
long g_lastTickMsc=0;
int g_ticksProcessedAtLastMsc=0; // Все записи на последней миллисекунде, включая записи без Bid.
bool g_liveTickRangePending=false;
datetime g_lastLiveTickRangeLog=0;
double g_lastSwingHigh=0.0, g_lastSwingLow=0.0;
double g_prevDownLow=0.0, g_latestDownLow=0.0;
double g_prevUpHigh=0.0, g_latestUpHigh=0.0;
double g_downHighs[], g_upLows[];
bool g_swingHighBreakoutTriggered=false, g_swingLowBreakoutTriggered=false;
double g_buyBreakLevel=0.0, g_sellBreakLevel=0.0;
double g_buyEntryLevel=0.0, g_sellEntryLevel=0.0;
double g_buySetupStop=0.0, g_sellSetupStop=0.0;
double g_pendingStopLevel=0.0; // Структурный уровень SL, зафиксированный при возникновении сигнала

//--- Восстановление истории: частичная готовность, задержка повторов, снимок состояния
bool     g_historyPartial=false;         // История собрана частично (часть чанков недоступна)
ulong    g_historyRetryDelayMs=10000;    // Текущая пауза между попытками пересборки

//--- Снимок состояния Renko: неудачная пересборка не должна стирать кирпичи и режимы
bool     g_snapshotValid=false;
Brick    g_snapshotBricks[];
int      g_snapshotCount=0;
double   g_snapshotBrickSize=0.0;
double   g_snapshotLastClose=0.0;
double   g_snapshotLastBid=0.0;
int      g_snapshotDirection=0;
bool     g_snapshotHaveAnchor=false;
long     g_snapshotLastTickMsc=0;
int      g_snapshotTicksAtLastMsc=0;
double   g_snapshotLastSwingHigh=0.0;
double   g_snapshotLastSwingLow=0.0;
double   g_snapshotPrevDownLow=0.0;
double   g_snapshotLatestDownLow=0.0;
double   g_snapshotPrevUpHigh=0.0;
double   g_snapshotLatestUpHigh=0.0;
bool     g_snapshotSwingHighTriggered=false;
bool     g_snapshotSwingLowTriggered=false;
double   g_snapshotBuyEntry=0.0;
double   g_snapshotSellEntry=0.0;
double   g_snapshotBuyStop=0.0;
double   g_snapshotSellStop=0.0;
bool     g_snapshotBuyEnabled=false;
bool     g_snapshotSellEnabled=false;
int      g_snapshotPendingSignal=0;
bool     g_snapshotHistoryReady=false;
bool     g_snapshotHistoryPartial=false;

//--- Журнал событий: файл держится открытым между записями
int      g_logHandle=INVALID_HANDLE;
datetime g_lastSignalTime=0, g_lastAttemptTime=0;
int g_attempts=0;
int g_pendingSignal=0; // 1 BUY, -1 SELL
datetime g_lastCloseCheckDay=0;
ulong g_lastCloseAttemptMs=0; // Монотонный таймер: не отправлять повторное закрытие каждый тик/секунду.
ulong g_emergencyCloseTicket=0;
ulong g_emergencyCloseLastAttemptMs=0;
ulong g_lastHistoryAttemptMs=0;
string g_logFile="";

string PersistentSettingKey(const string settingName)
{
   // Stable across chart timeframe changes and terminal restarts.
   // Two independent 32-bit hashes keep Global Variable names short.
   string identity=AccountInfoString(ACCOUNT_SERVER)+"|"+
                   IntegerToString((long)AccountInfoInteger(ACCOUNT_LOGIN))+"|"+
                   _Symbol+"|"+IntegerToString((long)InpMagicNumber)+"|"+InpInstanceId;
   uint hashA=2166136261;
   uint hashB=2246822519;
   for(int i=0;i<StringLen(identity);i++)
   {
      uint ch=(uint)StringGetCharacter(identity,i);
      hashA=(hashA^ch)*16777619;
      hashB=(hashB+ch)*3266489917;
      hashB^=(hashB>>13);
   }
   return StringFormat("RGPT.%u.%u.%s",hashA,hashB,settingName);
}

bool SavePersistentValue(const string settingName,const double value)
{
   string key=PersistentSettingKey(settingName);
   ResetLastError();
   datetime written=GlobalVariableSet(key,value);
   if(written==0)
   {
      LogEvent("SETTING_SAVE_FAILED",StringFormat("name=%s error=%d",settingName,GetLastError()));
      return false;
   }
   GlobalVariablesFlush();
   if(!GlobalVariableCheck(key))
   {
      LogEvent("SETTING_VERIFY_FAILED",StringFormat("name=%s reason=key_missing",settingName));
      return false;
   }
   double stored=GlobalVariableGet(key);
   if(stored!=value)
   {
      LogEvent("SETTING_VERIFY_FAILED",StringFormat("name=%s expected=%s actual=%s",settingName,DoubleToString(value,8),DoubleToString(stored,8)));
      return false;
   }
   return true;
}

bool LoadPersistentValue(const string settingName,double &value)
{
   string key=PersistentSettingKey(settingName);
   if(!GlobalVariableCheck(key)) return false;
   ResetLastError();
   double stored=GlobalVariableGet(key);
   int error=GetLastError();
   if(error!=0 || !MathIsValidNumber(stored))
   {
      LogEvent("SETTING_LOAD_INVALID",StringFormat("name=%s error=%d",settingName,error));
      return false;
   }
   value=stored;
   return true;
}

void LoadPersistentSettings()
{
   g_runtimeBrickPoints=InpBrickPoints;
   g_runtimePositionsCount=InpPositionsCount;
   g_runtimePositionLots=InpPositionLots;
   g_restoreBuyEnabled=InpBuyEnabledInitially;
   g_restoreSellEnabled=InpSellEnabledInitially;
   double value=0.0;
   if(LoadPersistentValue("BrickPoints",value))
   {
      if(value>=1.0 && value<=100000000.0 && MathFloor(value)==value)
         g_runtimeBrickPoints=(int)value;
      else
         LogEvent("SETTING_LOAD_INVALID","name=BrickPoints value="+DoubleToString(value,2));
   }
   if(LoadPersistentValue("PositionsCount",value))
   {
      if(value>=1.0 && value<=100.0 && MathFloor(value)==value) g_runtimePositionsCount=(int)value;
      else LogEvent("SETTING_LOAD_INVALID","name=PositionsCount value="+DoubleToString(value,2));
   }
   if(LoadPersistentValue("PositionLots",value))
   {
      double valid=ValidVolume(value);
      if(value>0.0 && valid>0.0 && MathAbs(valid-value)<1e-8) g_runtimePositionLots=valid;
      else LogEvent("SETTING_LOAD_INVALID","name=PositionLots value="+DoubleToString(value,4));
   }
   if(LoadPersistentValue("BuyEnabled",value))
   {
      if(value==0.0 || value==1.0) g_restoreBuyEnabled=(value==1.0);
      else LogEvent("SETTING_LOAD_INVALID","name=BuyEnabled value="+DoubleToString(value,2));
   }
   if(LoadPersistentValue("SellEnabled",value))
   {
      if(value==0.0 || value==1.0) g_restoreSellEnabled=(value==1.0);
      else LogEvent("SETTING_LOAD_INVALID","name=SellEnabled value="+DoubleToString(value,2));
   }
   g_brickSize=(double)g_runtimeBrickPoints*_Point;
}

bool PersistEmergencyCloseTicket()
{
   // Persist the pending retry so a terminal restart cannot silently drop it.
   // MT5 Global Variables store doubles; reject tickets outside exact integer range.
   if(g_emergencyCloseTicket>9007199254740991)
   {
      LogEvent("EMERGENCY_CLOSE_PERSIST_FAILED","ticket exceeds exact double integer range");
      return false;
   }
   return SavePersistentValue("EmergencyCloseTicket",(double)g_emergencyCloseTicket);
}

bool SavePersistentSettings()
{
   if(!g_persistenceReady) return false;
   // If history is temporarily unavailable, preserve the last persisted mode preferences
   // instead of overwriting them with the fail-closed runtime state.
   bool buyToSave=(g_historyReady && !g_restoreModesPending)?g_buyEnabled:g_restoreBuyEnabled;
   bool sellToSave=(g_historyReady && !g_restoreModesPending)?g_sellEnabled:g_restoreSellEnabled;
   bool brickOk=SavePersistentValue("BrickPoints",(double)g_runtimeBrickPoints);
   bool countOk=SavePersistentValue("PositionsCount",(double)g_runtimePositionsCount);
   bool lotsOk=SavePersistentValue("PositionLots",g_runtimePositionLots);
   bool buyOk=SavePersistentValue("BuyEnabled",buyToSave?1.0:0.0);
   bool sellOk=SavePersistentValue("SellEnabled",sellToSave?1.0:0.0);
   bool ok=brickOk && countOk && lotsOk && buyOk && sellOk;
   if(ok)
   {
      g_restoreBuyEnabled=buyToSave;
      g_restoreSellEnabled=sellToSave;
   }
   return ok;
}

void SetButtonStyle(const string name,const bool enabled)
{
   if(ObjectFind(0,name)<0) return;
   ObjectSetInteger(0,name,OBJPROP_BGCOLOR,enabled?InpButtonActiveColor:InpButtonInactiveColor);
   ObjectSetInteger(0,name,OBJPROP_COLOR,clrWhite);
   ObjectSetInteger(0,name,OBJPROP_BORDER_COLOR,enabled?InpButtonActiveColor:InpButtonInactiveColor);
   ObjectSetInteger(0,name,OBJPROP_STATE,false);
}

void UpdateTerminalTradeIndicator()
{
   bool allowed=(bool)TerminalInfoInteger(TERMINAL_TRADE_ALLOWED);
   if(ObjectFind(0,g_terminalTradeLabel)>=0)
   {
      ObjectSetString(0,g_terminalTradeLabel,OBJPROP_TEXT,allowed?"TRADE ON":"TRADE OFF");
      ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_COLOR,clrDimGray);
      ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_FONTSIZE,11);
      ObjectSetString(0,g_terminalTradeLabel,OBJPROP_FONT,"Arial Bold");
   }
   if(ObjectFind(0,g_terminalTradeDot)>=0)
   {
      ObjectSetString(0,g_terminalTradeDot,OBJPROP_TEXT,"●");
      ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_COLOR,allowed?InpTradeOnColor:InpTradeOffColor);
      ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_FONTSIZE,14);
      ObjectSetString(0,g_terminalTradeDot,OBJPROP_FONT,"Arial");
   }
}

void ClearEntrySetup(const int side)
{
   if(side>0)
   {
      g_buyEnabled=false; g_buyEntryLevel=0.0; g_buySetupStop=0.0;
      if(g_pendingSignal>0) { g_pendingSignal=0; g_pendingStopLevel=0.0; }
   }
   else
   {
      g_sellEnabled=false; g_sellEntryLevel=0.0; g_sellSetupStop=0.0;
      if(g_pendingSignal<0) { g_pendingSignal=0; g_pendingStopLevel=0.0; }
   }
}

bool ArmEntrySetup(const int side)
{
   if(!g_historyReady || g_liveTickRangePending)
   {
      g_lastDecision="Нельзя установить вход: история тиков не синхронизирована";
      return false;
   }
   MqlTick tick;
   if(!SymbolInfoTick(_Symbol,tick) || tick.bid<=0 || g_brickSize<=0)
   {
      g_lastDecision="Нельзя установить вход: нет актуальной котировки или размера Renko";
      return false;
   }
   if(side>0)
   {
      if(g_lastSwingHigh<=0 || g_lastSwingLow<=0)
      { g_lastDecision="BUY не активирован: нет подтверждённой вершины/впадины для входа и SL"; return false; }
      double entry=NormalizePrice(g_lastSwingHigh+g_brickSize);
      double stop=NormalizeStopLoss(g_lastSwingLow-InpSLBufferPoints*_Point,true);
      if(tick.bid>=entry)
      { g_lastDecision="BUY не активирован: цена входа уже пробита"; return false; }
      if(stop>=tick.bid)
      { g_lastDecision="BUY не активирован: цена уже достигла предполагаемого SL"; return false; }
      g_buyEntryLevel=entry; g_buySetupStop=stop; g_buyEnabled=true;
      g_lastDecision="BUY подготовлен: цена входа и SL зафиксированы";
      LogEvent("BUY_SETUP_ARMED",StringFormat("entry=%s sl=%s",DoubleToString(entry,_Digits),DoubleToString(stop,_Digits)));
      return true;
   }
   if(g_lastSwingLow<=0 || g_lastSwingHigh<=0)
   { g_lastDecision="SELL не активирован: нет подтверждённой впадины/вершины для входа и SL"; return false; }
   double entry=NormalizePrice(g_lastSwingLow-g_brickSize);
   double stop=NormalizeStopLoss(g_lastSwingHigh+InpSLBufferPoints*_Point,false);
   if(tick.bid<=entry)
   { g_lastDecision="SELL не активирован: цена входа уже пробита"; return false; }
   if(stop<=tick.bid)
   { g_lastDecision="SELL не активирован: цена уже достигла предполагаемого SL"; return false; }
   g_sellEntryLevel=entry; g_sellSetupStop=stop; g_sellEnabled=true;
   g_lastDecision="SELL подготовлен: цена входа и SL зафиксированы";
   LogEvent("SELL_SETUP_ARMED",StringFormat("entry=%s sl=%s",DoubleToString(entry,_Digits),DoubleToString(stop,_Digits)));
   return true;
}

void RestoreSavedModesIfReady()
{
   if(!g_restoreModesPending || !g_historyReady || g_liveTickRangePending)
      return;

   // Existing positions may be an incomplete basket left by a failed order or restart.
   // Never reactivate entry modes while this instance still owns an open position.
   g_restoreModesPending=false;
   if(HasOurPosition())
   {
      g_buyEnabled=false;
      g_sellEnabled=false;
      g_buyEntryLevel=0.0;
      g_sellEntryLevel=0.0;
      g_buySetupStop=0.0;
      g_sellSetupStop=0.0;
      g_restoreBuyEnabled=false;
      g_restoreSellEnabled=false;
      LogEvent("RESTORED_MODES_BLOCKED_POSITION_EXISTS",
               "saved entry modes cleared because an owned position already exists");
      SavePersistentSettings();
      return;
   }
   // Only restore after HISTORY → LIVE synchronization and a no-position check.
   if(g_restoreBuyEnabled && !ArmEntrySetup(1))
   {
      g_restoreBuyEnabled=false;
      LogEvent("RESTORED_BUY_SETUP_NOT_ARMED",g_lastDecision);
   }
   if(g_restoreSellEnabled && !ArmEntrySetup(-1))
   {
      g_restoreSellEnabled=false;
      LogEvent("RESTORED_SELL_SETUP_NOT_ARMED",g_lastDecision);
   }
   SavePersistentSettings();
   LogEvent("RESTORED_MODES_FINALIZED",StringFormat("buy=%s sell=%s",g_buyEnabled?"true":"false",g_sellEnabled?"true":"false"));
}

void UpdatePanel()
{
   // Троттлинг: панель не перерисовывается чаще PANEL_MIN_INTERVAL_MS.
   static ulong lastPanelMs=0;
   ulong nowPanelMs=GetTickCount64();
   if(lastPanelMs!=0 && nowPanelMs-lastPanelMs<PANEL_MIN_INTERVAL_MS) return;
   lastPanelMs=nowPanelMs;
   if(ObjectFind(0,g_buyButton)>=0)
   {
      ObjectSetString(0,g_buyButton,OBJPROP_TEXT,"BUY");
      SetButtonStyle(g_buyButton,g_buyEnabled);
   }
   if(ObjectFind(0,g_sellButton)>=0)
   {
      ObjectSetString(0,g_sellButton,OBJPROP_TEXT,"SELL");
      SetButtonStyle(g_sellButton,g_sellEnabled);
   }
   UpdateTerminalTradeIndicator();
   if(ObjectFind(0,g_brickEdit)>=0 && !ObjectGetInteger(0,g_brickEdit,OBJPROP_SELECTED))
      ObjectSetString(0,g_brickEdit,OBJPROP_TEXT,IntegerToString(g_runtimeBrickPoints));
   if(ObjectFind(0,g_positionsEdit)>=0 && !ObjectGetInteger(0,g_positionsEdit,OBJPROP_SELECTED))
      ObjectSetString(0,g_positionsEdit,OBJPROP_TEXT,IntegerToString(g_runtimePositionsCount));
   if(ObjectFind(0,g_lotsEdit)>=0 && !ObjectGetInteger(0,g_lotsEdit,OBJPROP_SELECTED))
      ObjectSetString(0,g_lotsEdit,OBJPROP_TEXT,DoubleToString(g_runtimePositionLots,4));
   if(ObjectFind(0,g_statusLabel)>=0)
      ObjectSetString(0,g_statusLabel,OBJPROP_TEXT,
         StringFormat("Renko EA | кирпич: %d points | BUY %s | SELL %s",
            g_runtimeBrickPoints,g_buyEnabled?"АКТИВЕН":"НЕАКТИВЕН",g_sellEnabled?"АКТИВЕН":"НЕАКТИВЕН"));
   string side=(g_pendingSignal>0?"BUY":(g_pendingSignal<0?"SELL":"нет"));
   string lines[10];
   lines[0]=StringFormat("Автоторговля терминала: %s | BUY: %s | SELL: %s",(bool)TerminalInfoInteger(TERMINAL_TRADE_ALLOWED)?"РАЗРЕШЕНА":"ЗАПРЕЩЕНА",g_buyEnabled?"АКТИВЕН":"НЕАКТИВЕН",g_sellEnabled?"АКТИВЕН":"НЕАКТИВЕН");
   lines[1]=StringFormat("Сигнал: %s | учтённых попыток: %d",side,g_attempts);
   datetime serverNow=TimeTradeServer();
   if(serverNow<=0) serverNow=TimeCurrent();
   lines[2]=StringFormat("Время терминала: %s | Москва: %s | окно: %s",
      TimeToString(serverNow,TIME_DATE|TIME_SECONDS),
      TimeToString(MoscowTime(),TIME_DATE|TIME_SECONDS),
      TradingHours()?"ОТКРЫТО":"ЗАКРЫТО");
   lines[3]=StringFormat("Позиция по символу: %s",HasAnyPositionOnSymbol()?"ЕСТЬ":"НЕТ");
   if(!g_historyReady)
      lines[4]="Решение: история тиков не готова; торговля и подготовка входа заблокированы";
   else if(g_liveTickRangePending)
      lines[4]="Решение: ожидание синхронизации тиков; исполнение сигналов заблокировано";
   else
      lines[4]="Решение: "+g_lastDecision;
   MqlTick diagTick; double spreadPoints=-1;
   if(SymbolInfoTick(_Symbol,diagTick) && diagTick.ask>0 && diagTick.bid>0) spreadPoints=(diagTick.ask-diagTick.bid)/_Point;
   lines[5]=StringFormat("Спред: %s | лимит: %s | SL-buffer: %d | корзина: %d x %s лота | шаг TP: %d | retry: %dс",spreadPoints<0?"нет котировки":DoubleToString(spreadPoints,1),InpMaxSpreadPoints>0?IntegerToString(InpMaxSpreadPoints):"без лимита",InpSLBufferPoints,g_runtimePositionsCount,DoubleToString(g_runtimePositionLots,4),InpTakeProfitStepPoints,InpRetrySeconds);
   lines[6]=StringFormat("Цена входа BUY: %s | SELL: %s",
      g_buyEntryLevel>0?DoubleToString(g_buyEntryLevel,_Digits):"нет цены входа",
      g_sellEntryLevel>0?DoubleToString(g_sellEntryLevel,_Digits):"нет цены входа");
   lines[7]=StringFormat("Последняя вершина: %s | последняя впадина: %s",
      g_lastSwingHigh>0?DoubleToString(g_lastSwingHigh,_Digits):"не определена",
      g_lastSwingLow>0?DoubleToString(g_lastSwingLow,_Digits):"не определена");
   lines[8]=StringFormat("Автозакрытие %02d:00 MSK: %s | охват: все позиции символа",
      InpCloseHourMSK,InpCloseAt23MSK?"ВКЛ":"ВЫКЛ");
   lines[9]=g_lastCloseInfo;
   for(int i=0;i<10;i++) if(ObjectFind(0,g_diagLabels[i])>=0) ObjectSetString(0,g_diagLabels[i],OBJPROP_TEXT,lines[i]);
   ChartRedraw(0);
}

bool CreatePanel()
{
   string basePrefix=StringFormat("RenkoEA.%I64d.",ChartID());
   g_panelYOffset=0;
   int existingPanels=0;
   for(int objectIndex=ObjectsTotal(0,-1,-1)-1;objectIndex>=0;--objectIndex)
   {
      string existingName=ObjectName(0,objectIndex,-1,-1);
      if(StringFind(existingName,basePrefix)!=0 || StringLen(existingName)<7) continue;
      if(StringSubstr(existingName,StringLen(existingName)-7)==".Status")
         existingPanels++;
   }
   g_panelYOffset=existingPanels*270;
   string prefix=StringFormat("RenkoEA.%I64d.%s.",ChartID(),g_instanceTag);
   g_buyButton=prefix+"BUY";
   g_sellButton=prefix+"SELL";
   g_brickEdit=prefix+"BrickEdit";
   g_brickApply=prefix+"BrickApply";
   g_positionsEdit=prefix+"PositionsEdit";
   g_lotsEdit=prefix+"LotsEdit";
   g_basketApply=prefix+"BasketApply";
   g_fivePositionsButton=prefix+"FivePositions";
   g_positionsLabel=prefix+"PositionsLabel";
   g_lotsLabel=prefix+"LotsLabel";
   g_statusLabel=prefix+"Status";
   g_terminalTradeDot=prefix+"TerminalTradeDot";
   for(int i=0;i<10;i++) g_diagLabels[i]=prefix+"Diag"+IntegerToString(i);
   if(!ObjectCreate(0,g_buyButton,OBJ_BUTTON,0,0,0) &&
      ObjectFind(0,g_buyButton)<0) return false;
   if(!ObjectCreate(0,g_sellButton,OBJ_BUTTON,0,0,0) &&
      ObjectFind(0,g_sellButton)<0) return false;
   g_terminalTradeLabel=prefix+"TerminalTradeStatus";
   if(!ObjectCreate(0,g_terminalTradeLabel,OBJ_LABEL,0,0,0) && ObjectFind(0,g_terminalTradeLabel)<0) return false;
   if(!ObjectCreate(0,g_terminalTradeDot,OBJ_LABEL,0,0,0) && ObjectFind(0,g_terminalTradeDot)<0) return false;
   if(!ObjectCreate(0,g_brickEdit,OBJ_EDIT,0,0,0) &&
      ObjectFind(0,g_brickEdit)<0) return false;
   if(!ObjectCreate(0,g_brickApply,OBJ_BUTTON,0,0,0) &&
      ObjectFind(0,g_brickApply)<0) return false;
   if(!ObjectCreate(0,g_positionsEdit,OBJ_EDIT,0,0,0) && ObjectFind(0,g_positionsEdit)<0) return false;
   if(!ObjectCreate(0,g_lotsEdit,OBJ_EDIT,0,0,0) && ObjectFind(0,g_lotsEdit)<0) return false;
   if(!ObjectCreate(0,g_basketApply,OBJ_BUTTON,0,0,0) && ObjectFind(0,g_basketApply)<0) return false;
   if(!ObjectCreate(0,g_fivePositionsButton,OBJ_BUTTON,0,0,0) && ObjectFind(0,g_fivePositionsButton)<0) return false;
   if(!ObjectCreate(0,g_positionsLabel,OBJ_LABEL,0,0,0) && ObjectFind(0,g_positionsLabel)<0) return false;
   if(!ObjectCreate(0,g_lotsLabel,OBJ_LABEL,0,0,0) && ObjectFind(0,g_lotsLabel)<0) return false;
   if(!ObjectCreate(0,g_statusLabel,OBJ_LABEL,0,0,0) &&
      ObjectFind(0,g_statusLabel)<0) return false;

   ObjectSetInteger(0,g_buyButton,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_buyButton,OBJPROP_XDISTANCE,10);
   ObjectSetInteger(0,g_buyButton,OBJPROP_YDISTANCE,20+g_panelYOffset);
   ObjectSetInteger(0,g_buyButton,OBJPROP_XSIZE,100);
   ObjectSetInteger(0,g_buyButton,OBJPROP_YSIZE,26);
   ObjectSetInteger(0,g_buyButton,OBJPROP_FONTSIZE,10);

   ObjectSetInteger(0,g_sellButton,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_sellButton,OBJPROP_XDISTANCE,116);
   ObjectSetInteger(0,g_sellButton,OBJPROP_YDISTANCE,20+g_panelYOffset);
   ObjectSetInteger(0,g_sellButton,OBJPROP_XSIZE,100);
   ObjectSetInteger(0,g_sellButton,OBJPROP_YSIZE,26);
   ObjectSetInteger(0,g_sellButton,OBJPROP_FONTSIZE,10);

   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_XDISTANCE,430);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_YDISTANCE,25+g_panelYOffset);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_FONTSIZE,11);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_COLOR,clrDimGray);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_BACK,false);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_SELECTABLE,false);
   ObjectSetInteger(0,g_terminalTradeLabel,OBJPROP_HIDDEN,true);
   ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_XDISTANCE,410);
   ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_YDISTANCE,23+g_panelYOffset);
   ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_SELECTABLE,false);
   ObjectSetInteger(0,g_terminalTradeDot,OBJPROP_HIDDEN,true);

   ObjectSetInteger(0,g_brickEdit,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_XDISTANCE,222);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_YDISTANCE,20+g_panelYOffset);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_XSIZE,75);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_YSIZE,26);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_FONTSIZE,10);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_ALIGN,ALIGN_CENTER);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_COLOR,clrBlack);
   ObjectSetInteger(0,g_brickEdit,OBJPROP_BGCOLOR,clrWhite);

   ObjectSetInteger(0,g_brickApply,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_brickApply,OBJPROP_XDISTANCE,302);
   ObjectSetInteger(0,g_brickApply,OBJPROP_YDISTANCE,20+g_panelYOffset);
   ObjectSetInteger(0,g_brickApply,OBJPROP_XSIZE,90);
   ObjectSetInteger(0,g_brickApply,OBJPROP_YSIZE,26);
   ObjectSetInteger(0,g_brickApply,OBJPROP_FONTSIZE,9);
   ObjectSetString(0,g_brickApply,OBJPROP_TEXT,"Применить");

   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_XDISTANCE,10);
   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_YDISTANCE,52+g_panelYOffset);
   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_XSIZE,88);
   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_YSIZE,22);
   ObjectSetInteger(0,g_fivePositionsButton,OBJPROP_FONTSIZE,8);
   ObjectSetString(0,g_fivePositionsButton,OBJPROP_TEXT,"5 позиций");

   ObjectSetInteger(0,g_positionsLabel,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_positionsLabel,OBJPROP_XDISTANCE,105);
   ObjectSetInteger(0,g_positionsLabel,OBJPROP_YDISTANCE,57+g_panelYOffset);
   ObjectSetInteger(0,g_positionsLabel,OBJPROP_FONTSIZE,8);
   ObjectSetInteger(0,g_positionsLabel,OBJPROP_COLOR,clrDimGray);
   ObjectSetString(0,g_positionsLabel,OBJPROP_TEXT,"Позиций");
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_XDISTANCE,153);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_YDISTANCE,52+g_panelYOffset);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_XSIZE,42);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_YSIZE,22);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_FONTSIZE,9);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_ALIGN,ALIGN_CENTER);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_COLOR,clrBlack);
   ObjectSetInteger(0,g_positionsEdit,OBJPROP_BGCOLOR,clrWhite);
   ObjectSetString(0,g_positionsEdit,OBJPROP_TEXT,IntegerToString(g_runtimePositionsCount));

   ObjectSetInteger(0,g_lotsLabel,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_lotsLabel,OBJPROP_XDISTANCE,205);
   ObjectSetInteger(0,g_lotsLabel,OBJPROP_YDISTANCE,57+g_panelYOffset);
   ObjectSetInteger(0,g_lotsLabel,OBJPROP_FONTSIZE,8);
   ObjectSetInteger(0,g_lotsLabel,OBJPROP_COLOR,clrDimGray);
   ObjectSetString(0,g_lotsLabel,OBJPROP_TEXT,"Лот");
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_XDISTANCE,230);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_YDISTANCE,52+g_panelYOffset);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_XSIZE,62);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_YSIZE,22);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_FONTSIZE,9);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_ALIGN,ALIGN_CENTER);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_COLOR,clrBlack);
   ObjectSetInteger(0,g_lotsEdit,OBJPROP_BGCOLOR,clrWhite);
   ObjectSetString(0,g_lotsEdit,OBJPROP_TEXT,DoubleToString(g_runtimePositionLots,4));

   ObjectSetInteger(0,g_basketApply,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_basketApply,OBJPROP_XDISTANCE,300);
   ObjectSetInteger(0,g_basketApply,OBJPROP_YDISTANCE,52+g_panelYOffset);
   ObjectSetInteger(0,g_basketApply,OBJPROP_XSIZE,90);
   ObjectSetInteger(0,g_basketApply,OBJPROP_YSIZE,22);
   ObjectSetInteger(0,g_basketApply,OBJPROP_FONTSIZE,8);
   ObjectSetString(0,g_basketApply,OBJPROP_TEXT,"Применить");

   ObjectSetInteger(0,g_statusLabel,OBJPROP_CORNER,CORNER_LEFT_UPPER);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_XDISTANCE,10);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_YDISTANCE,76+g_panelYOffset);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_FONTSIZE,9);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_COLOR,clrDimGray);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_BACK,false);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_SELECTABLE,false);
   ObjectSetInteger(0,g_statusLabel,OBJPROP_HIDDEN,true);
   for(int i=0;i<10;i++)
   {
      if(!ObjectCreate(0,g_diagLabels[i],OBJ_LABEL,0,0,0) && ObjectFind(0,g_diagLabels[i])<0) return false;
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_CORNER,CORNER_LEFT_UPPER);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_XDISTANCE,10);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_YDISTANCE,96+g_panelYOffset+i*18);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_FONTSIZE,9);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_COLOR,clrDimGray);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_BACK,false);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_SELECTABLE,false);
      ObjectSetInteger(0,g_diagLabels[i],OBJPROP_HIDDEN,true);
   }
   UpdatePanel();
   return true;
}

void ApplyRuntimeBasketSettings()
{
   if(ObjectFind(0,g_positionsEdit)<0 || ObjectFind(0,g_lotsEdit)<0) return;
   string countText=ObjectGetString(0,g_positionsEdit,OBJPROP_TEXT);
   string lotsText=ObjectGetString(0,g_lotsEdit,OBJPROP_TEXT);
   StringTrimLeft(countText); StringTrimRight(countText);
   StringTrimLeft(lotsText); StringTrimRight(lotsText);
   StringReplace(lotsText,",",".");
   long countParsed=StringToInteger(countText);
   bool countValid=(countText!="" && countParsed>=1 && countParsed<=100);
   for(int i=0;i<StringLen(countText) && countValid;i++)
   {
      ushort ch=StringGetCharacter(countText,i);
      if(ch<'0' || ch>'9') countValid=false;
   }
   bool lotsValid=(lotsText!="" && StringToDouble(lotsText)>0.0);
   int decimalPoints=0;
   for(int i=0;i<StringLen(lotsText) && lotsValid;i++)
   {
      ushort ch=StringGetCharacter(lotsText,i);
      if(ch=='.') { decimalPoints++; if(decimalPoints>1) lotsValid=false; }
      else if(ch<'0' || ch>'9') lotsValid=false;
   }
   double parsedLots=StringToDouble(lotsText);
   double validLots=ValidVolume(parsedLots);
   if(!countValid || !lotsValid || validLots<=0.0 || MathAbs(validLots-parsedLots)>1e-8)
   {
      g_lastDecision="Параметры корзины не применены: проверьте число позиций и шаг лота брокера";
      LogEvent("INVALID_RUNTIME_BASKET_SETTINGS",StringFormat("count=%s lots=%s valid_count=%s valid_lots=%s",countText,lotsText,countValid?"true":"false",DoubleToString(validLots,4)));
      UpdatePanel();
      return;
   }
   g_runtimePositionsCount=(int)countParsed;
   g_runtimePositionLots=validLots;
   bool saved=SavePersistentSettings();
   g_lastDecision=StringFormat("Корзина применена: %d позиций x %s лота%s",g_runtimePositionsCount,DoubleToString(g_runtimePositionLots,4),saved?"":"; ошибка сохранения настроек");
   LogEvent("RUNTIME_BASKET_SETTINGS_APPLIED",StringFormat("count=%d lots=%s persisted=%s",g_runtimePositionsCount,DoubleToString(g_runtimePositionLots,4),saved?"true":"false"));
   UpdatePanel();
}

void ApplyFivePositionsPreset()
{
   g_runtimePositionsCount=5;
   if(ObjectFind(0,g_positionsEdit)>=0)
      ObjectSetString(0,g_positionsEdit,OBJPROP_TEXT,"5");
   bool saved=SavePersistentSettings();
   g_lastDecision=StringFormat("Установлено 5 позиций по %s лота%s",DoubleToString(g_runtimePositionLots,4),saved?"":"; ошибка сохранения настроек");
   LogEvent("RUNTIME_BASKET_PRESET_APPLIED",StringFormat("count=5 lots=%s persisted=%s",DoubleToString(g_runtimePositionLots,4),saved?"true":"false"));
   UpdatePanel();
}

void ApplyRuntimeBrickSize()
{
   if(ObjectFind(0,g_brickEdit)<0) return;
   string value=ObjectGetString(0,g_brickEdit,OBJPROP_TEXT);
   StringTrimLeft(value); StringTrimRight(value);
   long parsed=StringToInteger(value);
   bool valid=(value!="" && parsed>=1 && parsed<=100000000);
   for(int i=0;i<StringLen(value) && valid;i++)
   {
      ushort ch=StringGetCharacter(value,i);
      if(ch<'0'||ch>'9') valid=false;
   }
   if(!valid)
   {
      LogEvent("INVALID_BRICK_SIZE","value="+value);
      UpdatePanel();
      return;
   }
   // Сохраняем рабочие параметры до попытки перестройки: при сбое
   // новый размер не должен расходиться со старой Renko-структурой.
   int previousRuntimeBrickPoints=g_runtimeBrickPoints;
   double previousBrickSize=g_brickSize;
   bool previousBuyEnabled=g_buyEnabled;
   bool previousSellEnabled=g_sellEnabled;
   bool previousRestoreBuyEnabled=g_restoreBuyEnabled;
   bool previousRestoreSellEnabled=g_restoreSellEnabled;
   bool previousRestoreModesPending=g_restoreModesPending;
   double previousBuyEntryLevel=g_buyEntryLevel;
   double previousSellEntryLevel=g_sellEntryLevel;
   double previousBuySetupStop=g_buySetupStop;
   double previousSellSetupStop=g_sellSetupStop;
   int requestedBrickPoints=(int)parsed;
   g_runtimeBrickPoints=requestedBrickPoints;
   g_brickSize=(double)g_runtimeBrickPoints*_Point;
   // После успешной перестройки повторно активируем только те режимы,
   // которые были включены до изменения размера; уровни входа будут рассчитаны заново.
   g_restoreBuyEnabled=previousBuyEnabled || previousRestoreBuyEnabled;
   g_restoreSellEnabled=previousSellEnabled || previousRestoreSellEnabled;
   g_restoreModesPending=(g_restoreBuyEnabled || g_restoreSellEnabled);
   ClearEntrySetup(1); ClearEntrySetup(-1);
   g_pendingSignal=0; g_pendingStopLevel=0.0;
   RebuildHistory();
   if(!g_historyReady || g_historyPartial || g_snapshotValid)
   {
      g_runtimeBrickPoints=previousRuntimeBrickPoints;
      g_brickSize=previousBrickSize;
      g_buyEnabled=previousBuyEnabled;
      g_sellEnabled=previousSellEnabled;
      g_restoreBuyEnabled=previousRestoreBuyEnabled;
      g_restoreSellEnabled=previousRestoreSellEnabled;
      g_restoreModesPending=previousRestoreModesPending;
      g_buyEntryLevel=previousBuyEntryLevel;
      g_sellEntryLevel=previousSellEntryLevel;
      g_buySetupStop=previousBuySetupStop;
      g_sellSetupStop=previousSellSetupStop;
      g_lastDecision="Размер Renko не применён: история не перестроена полностью";
      LogEvent("BRICK_SIZE_CHANGE_ROLLED_BACK",StringFormat("requested=%d restored=%d history_ready=%s partial=%s",
               requestedBrickPoints,previousRuntimeBrickPoints,g_historyReady?"true":"false",g_historyPartial?"true":"false"));
      UpdatePanel();
      return;
   }
   RestoreSavedModesIfReady();
   UpdatePanel();
   bool saved=SavePersistentSettings();
   if(saved)
      LogEvent("BRICK_SIZE_CHANGED",IntegerToString(g_runtimeBrickPoints));
   else
      LogEvent("BRICK_SIZE_PERSIST_FAILED",IntegerToString(g_runtimeBrickPoints));
}

datetime MoscowTime()
{
   // Москва UTC+3 без сезонного перевода времени.
   return (datetime)(TimeGMT()+3*3600);
}

datetime MoscowDayStart(datetime t)
{
   MqlDateTime d;
   if(!TimeToStruct(t,d)) return 0;
   d.hour=0; d.min=0; d.sec=0;
   return StructToTime(d);
}

bool EnsureLogHandle()
{
   if(g_logHandle!=INVALID_HANDLE) return true;
   g_logHandle=FileOpen(g_logFile,FILE_READ|FILE_WRITE|FILE_CSV|FILE_ANSI|FILE_SHARE_READ|FILE_SHARE_WRITE,',');
   if(g_logHandle==INVALID_HANDLE) return false;
   if(FileSize(g_logHandle)==0)
      FileWrite(g_logHandle,"server_time","symbol","event","details");
   FileSeek(g_logHandle,0,SEEK_END);
   return true;
}

void CloseLogHandle()
{
   if(g_logHandle==INVALID_HANDLE) return;
   FileFlush(g_logHandle);
   FileClose(g_logHandle);
   g_logHandle=INVALID_HANDLE;
}

// Журнал держит файл открытым: открытие на каждое событие давало лишний I/O.
void LogEvent(string eventName,string details="")
{
   string line=TimeToString(TimeCurrent(),TIME_DATE|TIME_SECONDS)+","+_Symbol+","+eventName+","+details;
   Print("RenkoGPTBreakoutEA: ",line);
   if(!EnsureLogHandle())
   {
      static ulong lastOpenFailMs=0;
      ulong nowMs=GetTickCount64();
      if(lastOpenFailMs==0 || nowMs-lastOpenFailMs>=60000)
      {
         Print("RenkoGPTBreakoutEA: не удалось открыть CSV-журнал; error=",GetLastError());
         lastOpenFailMs=nowMs;
      }
      return;
   }
   int h=g_logHandle;
   if(h==INVALID_HANDLE)
   {
      Print("RenkoGPTBreakoutEA: не удалось открыть CSV-журнал; error=",GetLastError());
      return;
   }
   if(FileSize(h)==0) FileWrite(h,"server_time","symbol","event","details");
   FileSeek(h,0,SEEK_END);
   FileWrite(h,TimeToString(TimeCurrent(),TIME_DATE|TIME_SECONDS),_Symbol,eventName,details);
   // Файл остаётся открытым; закрытие выполняется в CloseLogHandle().
}

double NormalizePrice(double price)
{
   double tickSize=SymbolInfoDouble(_Symbol,SYMBOL_TRADE_TICK_SIZE);
   if(tickSize<=0) tickSize=_Point;
   return NormalizeDouble(MathRound(price/tickSize)*tickSize,_Digits);
}

// Для защитного SL округляем только наружу от структурного экстремума:
// BUY — вниз, SELL — вверх. Округление к ближайшему тику могло уменьшать
// фактический буфер InpSLBufferPoints.
double NormalizeStopLoss(const double price,const bool isBuy)
{
   double tickSize=SymbolInfoDouble(_Symbol,SYMBOL_TRADE_TICK_SIZE);
   if(tickSize<=0) tickSize=_Point;
   double ticks=price/tickSize;
   double rounded=(isBuy ? MathFloor(ticks+1e-10) : MathCeil(ticks-1e-10))*tickSize;
   return NormalizeDouble(rounded,_Digits);
}

bool HasOurPosition()
{
   for(int i=PositionsTotal()-1;i>=0;--i)
   {
      ulong ticket=PositionGetTicket(i);
      if(ticket==0) continue;
      if(PositionGetString(POSITION_SYMBOL)==_Symbol &&
         (ulong)PositionGetInteger(POSITION_MAGIC)==InpMagicNumber)
         return true;
   }
   return false;
}

bool HasAnyPositionOnSymbol()
{
   for(int i=PositionsTotal()-1;i>=0;--i)
   {
      ulong ticket=PositionGetTicket(i);
      if(ticket==0) continue;
      if(PositionGetString(POSITION_SYMBOL)==_Symbol)
         return true;
   }
   return false;
}

bool TradingHours()
{
   MqlDateTime d;
   if(!TimeToStruct(MoscowTime(),d)) return false;
   return (d.hour>=InpTradeStartHourMSK && d.hour<InpTradeEndHourMSK);
}

void CloseAtTimeIfRequired()
{
   if(!InpCloseAt23MSK) return;
   MqlDateTime d;
   datetime now=MoscowTime();
   if(!TimeToStruct(now,d) || d.hour<InpCloseHourMSK) return;
   datetime day=MoscowDayStart(now);
   if(day==g_lastCloseCheckDay) return;

   // CloseAtTimeIfRequired вызывается и из OnTick, и из OnTimer.
   // Ограничиваем повторы после отказа, не отменяя повторное закрытие открытых позиций.
   ulong attemptMs=GetTickCount64();
   if(g_lastCloseAttemptMs>0 && attemptMs-g_lastCloseAttemptMs<5000)
      return;
   g_lastCloseAttemptMs=attemptMs;

   for(int i=PositionsTotal()-1;i>=0;--i)
   {
      ulong ticket=PositionGetTicket(i);
      // По инварианту автозакрытие охватывает все позиции текущего символа,
      // независимо от Magic Number.
      if(ticket==0 || PositionGetString(POSITION_SYMBOL)!=_Symbol) continue;
      ResetLastError();
      bool closeSent=g_trade.PositionClose(ticket);
      uint closeRc=g_trade.ResultRetcode();
      if(!closeSent || (closeRc!=TRADE_RETCODE_DONE && closeRc!=TRADE_RETCODE_DONE_PARTIAL))
         LogEvent("CLOSE_23_FAILED",StringFormat("ticket=%I64u sent=%s retcode=%u %s error=%d",
                  ticket,closeSent?"true":"false",closeRc,g_trade.ResultRetcodeDescription(),GetLastError()));
      else
      {
         bool stillOpen=PositionSelectByTicket(ticket);
         LogEvent(stillOpen?"CLOSE_23_NOT_CONFIRMED":"CLOSE_23_CONFIRMED",
                  StringFormat("ticket=%I64u retcode=%u still_open=%s",ticket,closeRc,stillOpen?"true":"false"));
      }
   }

   // Не считаем закрытие за день завершённым, пока на символе остаётся
   // любая позиция — независимо от Magic Number и источника открытия.
   // При временном отказе следующий OnTimer/OnTick повторит попытку.
   bool closeTargetRemaining=HasAnyPositionOnSymbol();
   if(!closeTargetRemaining)
      g_lastCloseCheckDay=day;
}

void AddLevel(double &arr[],double value)
{
   int n=ArraySize(arr);
   if(ArrayResize(arr,n+1,32)==n+1) arr[n]=value;
}

bool AddBrick(datetime t,double o,double c,int dir)
{
   // Для торговой структуры достаточно последних кирпичей и агрегированных swings.
   // Ограничиваем логическую длину массива, чтобы длинная работа EA не росла бесконечно.
   const int MAX_RETAINED_BRICKS=5000;
   if(g_count>=MAX_RETAINED_BRICKS)
   {
      for(int i=1;i<g_count;i++) g_bricks[i-1]=g_bricks[i];
      g_count--;
   }
   // Сначала резервируем память. При ошибке нельзя обновлять swing-состояние
   // без соответствующего кирпича: это создало бы фиктивный торговый уровень.
   int n=g_count+1;
   if(ArrayResize(g_bricks,n,512)!=n)
   {
      LogEvent("MEMORY_ERROR","brick array resize failed");
      return false;
   }
   bool confirmedHigh=false, confirmedLow=false;
   double swingHigh=0.0, swingLow=0.0;
   if(g_count>0)
   {
      Brick prev=g_bricks[g_count-1];
      if(prev.direction>0 && dir<0) { confirmedHigh=true; swingHigh=prev.high; }
      else if(prev.direction<0 && dir>0) { confirmedLow=true; swingLow=prev.low; }
   }
   g_bricks[g_count].time=t;
   g_bricks[g_count].open=o;
   g_bricks[g_count].high=MathMax(o,c);
   g_bricks[g_count].low=MathMin(o,c);
   g_bricks[g_count].close=c;
   g_bricks[g_count].direction=dir;
   g_count=n;
   if(confirmedHigh)
   {
      g_lastSwingHigh=swingHigh;
      g_latestUpHigh=swingHigh;
      g_swingHighBreakoutTriggered=false;
      g_prevUpHigh=g_latestUpHigh;
   }
   else if(confirmedLow)
   {
      g_lastSwingLow=swingLow;
      g_latestDownLow=swingLow;
      g_swingLowBreakoutTriggered=false;
      g_prevDownLow=g_latestDownLow;
   }
   return true;
}

void ProcessBid(datetime t,double bid,bool allowSignal)
{
   if(bid<=0 || g_brickSize<=0) return;
   if(!g_haveAnchor)
   {
      g_lastClose=NormalizePrice(bid);
      g_lastBid=bid;
      g_haveAnchor=true;
      return;
   }
   double previousBid=g_lastBid;
   bool changed=true;
   int guard=0;
   while(changed && guard++<10000)
   {
      changed=false;
      if(g_direction==0)
      {
         if(bid>=g_lastClose+g_brickSize)
         {
            double c=g_lastClose+g_brickSize; if(!AddBrick(t,g_lastClose,c,1)) return;
            g_lastClose=c; g_direction=1; changed=true;
         }
         else if(bid<=g_lastClose-g_brickSize)
         {
            double c=g_lastClose-g_brickSize; if(!AddBrick(t,g_lastClose,c,-1)) return;
            g_lastClose=c; g_direction=-1; changed=true;
         }
      }
      else if(g_direction>0)
      {
         if(bid>=g_lastClose+g_brickSize)
         {
            double c=g_lastClose+g_brickSize; if(!AddBrick(t,g_lastClose,c,1)) return;
            g_lastClose=c; changed=true;
         }
         else if(bid<=g_lastClose-2.0*g_brickSize)
         {
            double o=g_lastClose-g_brickSize, c=g_lastClose-2.0*g_brickSize;
            if(!AddBrick(t,o,c,-1)) return;
            g_lastClose=c; g_direction=-1; changed=true;
         }
      }
      else
      {
         if(bid<=g_lastClose-g_brickSize)
         {
            double c=g_lastClose-g_brickSize; if(!AddBrick(t,g_lastClose,c,-1)) return;
            g_lastClose=c; changed=true;
         }
         else if(bid>=g_lastClose+2.0*g_brickSize)
         {
            double o=g_lastClose+g_brickSize, c=g_lastClose+2.0*g_brickSize;
            if(!AddBrick(t,o,c,1)) return;
            g_lastClose=c; g_direction=1; changed=true;
         }
      }
   }

   if(changed)
   {
      g_processBidGuardExceeded=true;
      LogEvent("RENKO_PROCESS_GUARD_EXCEEDED",StringFormat("guard=%d bid=%s last_close=%s brick_size=%s allow_signal=%s",guard,DoubleToString(bid,_Digits),DoubleToString(g_lastClose,_Digits),DoubleToString(g_brickSize,_Digits),allowSignal?"true":"false"));
      return;
   }

   // Уровни входа и SL фиксируются при нажатии кнопки и не следуют за новыми swings.
   if(allowSignal && previousBid>0)
   {
      if(g_buyEnabled && g_buyEntryLevel>0 && bid<=g_buySetupStop)
      {
         LogEvent("BUY_SETUP_CANCELLED_SL",StringFormat("bid=%s entry=%s sl=%s",DoubleToString(bid,_Digits),DoubleToString(g_buyEntryLevel,_Digits),DoubleToString(g_buySetupStop,_Digits)));
         ClearEntrySetup(1);
         g_lastDecision="BUY отменён: цена пробила предполагаемый SL до входа";
         UpdatePanel();
      }
      if(g_sellEnabled && g_sellEntryLevel>0 && bid>=g_sellSetupStop)
      {
         LogEvent("SELL_SETUP_CANCELLED_SL",StringFormat("bid=%s entry=%s sl=%s",DoubleToString(bid,_Digits),DoubleToString(g_sellEntryLevel,_Digits),DoubleToString(g_sellSetupStop,_Digits)));
         ClearEntrySetup(-1);
         g_lastDecision="SELL отменён: цена пробила предполагаемый SL до входа";
         UpdatePanel();
      }
      if(g_pendingSignal==0 && g_buyEnabled && g_buyEntryLevel>0 && previousBid<g_buyEntryLevel && bid>=g_buyEntryLevel)
      {
         g_buyBreakLevel=g_buyEntryLevel; g_pendingSignal=1;
         g_lastDecision="BUY-пробой зафиксированной цены входа; проверка условий открытия";
         g_lastSignalTime=TimeCurrent(); g_pendingStopLevel=g_buySetupStop; // SL фиксируется в момент сигнала
         g_lastAttemptTime=0; g_attempts=0; g_swingHighBreakoutTriggered=true;
         LogEvent("BUY_SIGNAL",StringFormat("entry=%s sl=%s",DoubleToString(g_buyEntryLevel,_Digits),DoubleToString(g_buySetupStop,_Digits)));
         UpdatePanel();
      }
      if(g_pendingSignal==0 && g_sellEnabled && g_sellEntryLevel>0 && previousBid>g_sellEntryLevel && bid<=g_sellEntryLevel)
      {
         g_sellBreakLevel=g_sellEntryLevel; g_pendingSignal=-1;
         g_lastDecision="SELL-пробой зафиксированной цены входа; проверка условий открытия";
         g_lastSignalTime=TimeCurrent(); g_pendingStopLevel=g_sellSetupStop; // SL фиксируется в момент сигнала
         g_lastAttemptTime=0; g_attempts=0; g_swingLowBreakoutTriggered=true;
         LogEvent("SELL_SIGNAL",StringFormat("entry=%s sl=%s",DoubleToString(g_sellEntryLevel,_Digits),DoubleToString(g_sellSetupStop,_Digits)));
         UpdatePanel();
      }
   }
   g_lastBid=bid;
}

double ValidVolume(double volume)
{
   double minv=SymbolInfoDouble(_Symbol,SYMBOL_VOLUME_MIN);
   double maxv=SymbolInfoDouble(_Symbol,SYMBOL_VOLUME_MAX);
   double step=SymbolInfoDouble(_Symbol,SYMBOL_VOLUME_STEP);
   if(step<=0 || volume<minv || volume>maxv) return 0.0;
   // Не подгоняем пользовательский объём вниз: несовместимый шаг
   // должен приводить к отказу, а не к скрытому уменьшению позиции.
   double steps=volume/step;
   double nearestSteps=MathRound(steps);
   double v=nearestSteps*step;
   if(MathAbs(volume-v)>MathMax(1e-8,step*1e-7)) return 0.0;
   if(v<minv || v>maxv) return 0.0;
   int digits=2;
   if(step<0.01) digits=3;
   if(step<0.001) digits=4;
   return NormalizeDouble(v,digits);
}

bool ExecutePendingSignal()
{
   if(!g_historyReady || g_liveTickRangePending) return false;
   if(g_pendingSignal==0) return false;
   bool isBuy=(g_pendingSignal>0);
   datetime signalNow=TimeCurrent();
   if(g_lastSignalTime<=0 || signalNow-g_lastSignalTime>=InpSignalMaxAgeSeconds)
   {
      LogEvent("SIGNAL_EXPIRED",StringFormat("side=%s age_seconds=%I64d max_age=%d",
               isBuy?"BUY":"SELL",g_lastSignalTime>0?(long)(signalNow-g_lastSignalTime):-1,InpSignalMaxAgeSeconds));
      ClearEntrySetup(isBuy?1:-1);
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      g_lastDecision="Сигнал отменён: истёк срок действия";
      UpdatePanel();
      return false;
   }
   if(!TerminalInfoInteger(TERMINAL_CONNECTED)) { g_lastDecision="БЛОК: нет соединения с торговым сервером"; UpdatePanel(); return false; }
   if(!TerminalInfoInteger(TERMINAL_TRADE_ALLOWED)) { g_lastDecision="БЛОК: автоторговля терминала MT5 выключена"; UpdatePanel(); return false; }
   if(!MQLInfoInteger(MQL_TRADE_ALLOWED)) { g_lastDecision="БЛОК: торговля запрещена для этого советника"; UpdatePanel(); return false; }
   if(!AccountInfoInteger(ACCOUNT_TRADE_ALLOWED)) { g_lastDecision="БЛОК: торговля запрещена для счёта или соединение недоступно"; UpdatePanel(); return false; }
   if(!AccountInfoInteger(ACCOUNT_TRADE_EXPERT)) { g_lastDecision="БЛОК: сервер запрещает торговлю советниками на этом счёте"; UpdatePanel(); return false; }
   if(g_pendingSignal>0 && !g_buyEnabled)
   {
      g_lastDecision="BUY-сигнал отменён: BUY-режим выключен";
      LogEvent("SIGNAL_CANCELLED_MODE_OFF","BUY");
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      UpdatePanel();
      return false;
   }
   if(g_pendingSignal<0 && !g_sellEnabled)
   {
      g_lastDecision="SELL-сигнал отменён: SELL-режим выключен";
      LogEvent("SIGNAL_CANCELLED_MODE_OFF","SELL");
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      UpdatePanel();
      return false;
   }
   if(!TradingHours())
   {
      g_lastDecision="Сигнал отменён: вне торгового окна по Москве";
      LogEvent("SIGNAL_CANCELLED_OUTSIDE_HOURS",g_pendingSignal>0?"BUY":"SELL");
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      UpdatePanel();
      return false;
   }
   // Повторный вход блокирует только позиция, принадлежащая этому EA
   // (совпадают символ и InpMagicNumber), независимо от направления.
   if(HasOurPosition())
   {
      g_lastDecision="Сигнал отменён: у RenkoGPTBreakoutEA уже есть собственная позиция по символу";
      LogEvent("SIGNAL_CANCELLED_POSITION_EXISTS",isBuy?"BUY":"SELL");
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      UpdatePanel();
      return false;
   }
   datetime now=TimeCurrent();
   if(g_lastAttemptTime>0 && now-g_lastAttemptTime<InpRetrySeconds) { g_lastDecision="Ожидание интервала между попытками"; UpdatePanel(); return false; }
   if(InpMaxSpreadPoints>0)
   {
      MqlTick tick;
      if(!SymbolInfoTick(_Symbol,tick)) { g_lastDecision="БЛОК: котировка недоступна"; UpdatePanel(); return false; }
      if((tick.ask-tick.bid)/_Point>InpMaxSpreadPoints) { g_lastDecision=StringFormat("БЛОК: спред %.1f > лимита %d points",(tick.ask-tick.bid)/_Point,InpMaxSpreadPoints); UpdatePanel(); return false; }
   }
   double volume=ValidVolume(g_runtimePositionLots);
   if(g_runtimePositionsCount<1 || g_runtimePositionsCount>100 || volume<=0)
   {
      g_lastDecision="ОТКАЗ: количество позиций или объём не соответствует ограничениям";
      LogEvent("INVALID_BASKET_PARAMETERS",StringFormat("count=%d lots=%s",g_runtimePositionsCount,DoubleToString(g_runtimePositionLots,4)));
      g_pendingSignal=0; g_pendingStopLevel=0.0; UpdatePanel(); return false;
   }
   if((ENUM_ACCOUNT_MARGIN_MODE)AccountInfoInteger(ACCOUNT_MARGIN_MODE)!=ACCOUNT_MARGIN_MODE_RETAIL_HEDGING)
   {
      g_lastDecision="БЛОК: для отдельных позиций нужен счёт MT5 Hedging";
      LogEvent("BASKET_BLOCKED_ACCOUNT_MODE",IntegerToString((int)AccountInfoInteger(ACCOUNT_MARGIN_MODE)));
      g_pendingSignal=0; UpdatePanel(); return false;
   }

   MqlTick tick;
   if(!SymbolInfoTick(_Symbol,tick) || tick.bid<=0 || tick.ask<=0) { g_lastDecision="БЛОК: котировка не получена перед отправкой"; UpdatePanel(); return false; }
   double sl=0.0;
   if(isBuy)
   {
      if(g_buySetupStop<=0) { g_lastDecision="BUY отменён: сохранённый SL отсутствует"; LogEvent("NO_SNAPSHOT_LOW","BUY cancelled"); ClearEntrySetup(1); g_pendingSignal=0; UpdatePanel(); return false; }
      sl=(g_pendingStopLevel>0.0)?g_pendingStopLevel:g_buySetupStop; // SL, зафиксированный при сигнале
   }
   else
   {
      if(g_sellSetupStop<=0) { g_lastDecision="SELL отменён: сохранённый SL отсутствует"; LogEvent("NO_STRUCTURAL_HIGH","SELL cancelled"); ClearEntrySetup(-1); g_pendingSignal=0; UpdatePanel(); return false; }
      sl=(g_pendingStopLevel>0.0)?g_pendingStopLevel:g_sellSetupStop; // SL, зафиксированный при сигнале
   }

   long stops=SymbolInfoInteger(_Symbol,SYMBOL_TRADE_STOPS_LEVEL);
   long freeze=SymbolInfoInteger(_Symbol,SYMBOL_TRADE_FREEZE_LEVEL);
   // Freeze level запрещает правку SL/TP вблизи рынка: берём консервативный максимум.
   double minDistance=(double)MathMax(stops,freeze)*_Point;
   // minDistance рассчитан выше как максимум из stops level и freeze level.
   double basePrice=isBuy?tick.ask:tick.bid;
   double firstTp=NormalizePrice(basePrice+(isBuy?1.0:-1.0)*InpTakeProfitStepPoints*_Point);
   if((isBuy && (sl>=tick.bid || tick.bid-sl<minDistance || firstTp<=tick.ask || firstTp-tick.ask<minDistance)) ||
      (!isBuy && (sl<=tick.ask || sl-tick.ask<minDistance || firstTp>=tick.bid || tick.bid-firstTp<minDistance)))
   {
      g_lastDecision=StringFormat("ОТКАЗ: недопустимы SL/TP; SL=%s первый TP=%s stops=%d",DoubleToString(sl,_Digits),DoubleToString(firstTp,_Digits),(int)stops);
      LogEvent("INVALID_SL_TP",StringFormat("side=%s sl=%s first_tp=%s stops=%d",isBuy?"BUY":"SELL",DoubleToString(sl,_Digits),DoubleToString(firstTp,_Digits),(int)stops));
      g_lastAttemptTime=now; g_attempts++;
      if(g_attempts>=10) { g_pendingSignal=0; LogEvent("SIGNAL_ABANDONED","invalid SL/TP after 10 attempts"); }
      UpdatePanel(); return false;
   }

   g_trade.SetExpertMagicNumber(InpMagicNumber);
   g_trade.SetDeviationInPoints(InpDeviationPoints);
   // Маржа: проверяем всю корзину до первой заявки, иначе позиции откроются частично.
   ENUM_ORDER_TYPE marginType=isBuy?ORDER_TYPE_BUY:ORDER_TYPE_SELL;
   double basketVolume=volume*(double)g_runtimePositionsCount;
   double basketMargin=0.0;
   if(!OrderCalcMargin(marginType,_Symbol,basketVolume,basePrice,basketMargin) || basketMargin<=0.0)
   {
      g_lastDecision="БЛОК: не удалось оценить требуемую маржу";
      LogEvent("MARGIN_CALC_FAILED",StringFormat("volume=%s price=%s error=%d",DoubleToString(basketVolume,4),DoubleToString(basePrice,_Digits),GetLastError()));
      // Ограничиваем повторные расчёты интервалом InpRetrySeconds.
      g_lastAttemptTime=now;
      g_attempts++;
      UpdatePanel(); return false;
   }
   double freeMarginNow=AccountInfoDouble(ACCOUNT_MARGIN_FREE);
   double marginNeeded=basketMargin*MARGIN_SAFETY_RATIO;
   if(freeMarginNow<marginNeeded)
   {
      g_lastDecision=StringFormat("БЛОК: свободной маржи %s меньше требуемой %s (корзина %d x %s лота)",
                                   DoubleToString(freeMarginNow,2),DoubleToString(marginNeeded,2),
                                   g_runtimePositionsCount,DoubleToString(volume,4));
      LogEvent("MARGIN_INSUFFICIENT",StringFormat("free=%s required=%s volume=%s count=%d",
               DoubleToString(freeMarginNow,2),DoubleToString(marginNeeded,2),
               DoubleToString(basketVolume,4),g_runtimePositionsCount));
      g_lastAttemptTime=now; g_attempts++;
      UpdatePanel(); return false;
   }
   g_trade.SetTypeFillingBySymbol(_Symbol);
   int opened=0;
   bool basketComplete=true;
   for(int basketIndex=0;basketIndex<g_runtimePositionsCount;basketIndex++)
   {
      if(!SymbolInfoTick(_Symbol,tick) || tick.bid<=0 || tick.ask<=0)
      {
         basketComplete=false;
         LogEvent("BASKET_STOPPED_NO_QUOTE",StringFormat("opened=%d requested=%d",opened,g_runtimePositionsCount));
         break;
      }
      // Повторная проверка маржи: свободная маржа может измениться между заявками.
      double provisionalMarketPrice=isBuy?tick.ask:tick.bid;
      double orderMargin=0.0;
      if(!OrderCalcMargin(marginType,_Symbol,volume,provisionalMarketPrice,orderMargin) || orderMargin<=0.0 ||
         AccountInfoDouble(ACCOUNT_MARGIN_FREE)<orderMargin*MARGIN_SAFETY_RATIO)
      {
         basketComplete=false;
         LogEvent("BASKET_STOPPED_MARGIN",StringFormat("opened=%d requested=%d free=%s order_margin=%s",
                  opened,g_runtimePositionsCount,DoubleToString(AccountInfoDouble(ACCOUNT_MARGIN_FREE),2),DoubleToString(orderMargin,2)));
         break;
      }
      double provisionalPrice=isBuy?tick.ask:tick.bid;
      double provisionalTp=NormalizePrice(provisionalPrice+(isBuy?1.0:-1.0)*InpTakeProfitStepPoints*(basketIndex+1)*_Point);
      ResetLastError();
      bool sent=isBuy ? g_trade.Buy(volume,_Symbol,0.0,sl,provisionalTp,"RenkoGPTBreakoutEA BUY")
                      : g_trade.Sell(volume,_Symbol,0.0,sl,provisionalTp,"RenkoGPTBreakoutEA SELL");
      uint rc=g_trade.ResultRetcode();
      g_lastAttemptTime=TimeCurrent();
      g_attempts++;
      if(!sent || (rc!=TRADE_RETCODE_DONE && rc!=TRADE_RETCODE_DONE_PARTIAL))
      {
         LogEvent("BASKET_ORDER_UNCONFIRMED",StringFormat("index=%d requested=%d sent=%s retcode=%u order=%I64u deal=%I64u description=%s error=%d",
                  basketIndex+1,g_runtimePositionsCount,sent?"true":"false",rc,g_trade.ResultOrder(),g_trade.ResultDeal(),g_trade.ResultRetcodeDescription(),GetLastError()));
         basketComplete=false;
         break; // Не повторяем заявку вслепую при неоднозначном результате.
      }

      ulong deal=g_trade.ResultDeal();
      double fillPrice=g_trade.ResultPrice();
      double filledVolume=g_trade.ResultVolume();
      ulong positionId=0;
      if(deal>0 && HistoryDealSelect(deal))
         positionId=(ulong)HistoryDealGetInteger(deal,DEAL_POSITION_ID);
      ulong positionTicket=0;
      for(int p=PositionsTotal()-1;p>=0;--p)
      {
         ulong candidate=PositionGetTicket(p);
         if(candidate==0) continue;
         if(PositionGetString(POSITION_SYMBOL)==_Symbol &&
            (ulong)PositionGetInteger(POSITION_MAGIC)==InpMagicNumber &&
            (ulong)PositionGetInteger(POSITION_IDENTIFIER)==positionId)
         { positionTicket=candidate; break; }
      }
      if(fillPrice<=0.0 || positionId==0 || positionTicket==0)
      {
         LogEvent("BASKET_FILL_RECONCILE_REQUIRED",StringFormat("index=%d deal=%I64u position_id=%I64u ticket=%I64u fill=%s",
                  basketIndex+1,deal,positionId,positionTicket,DoubleToString(fillPrice,_Digits)));
         basketComplete=false;
         break;
      }
      double actualTp=NormalizePrice(fillPrice+(isBuy?1.0:-1.0)*InpTakeProfitStepPoints*(basketIndex+1)*_Point);
      bool modifyRequired=true;
      double freezeDistance=(double)freeze*_Point;
      double currentMarket=isBuy?SymbolInfoDouble(_Symbol,SYMBOL_BID):SymbolInfoDouble(_Symbol,SYMBOL_ASK);
      if(freezeDistance>0.0 && currentMarket>0.0 && MathAbs(actualTp-currentMarket)<freezeDistance)
      {
         // Freeze level запрещает правку TP вблизи рынка: оставляем TP, выставленный
         // вместе с позицией, вместо рискованного принудительного закрытия.
         modifyRequired=false;
         LogEvent("BASKET_TP_MODIFY_SKIPPED_FREEZE",StringFormat("index=%d ticket=%I64u tp=%s market=%s freeze=%d",
                  basketIndex+1,positionTicket,DoubleToString(actualTp,_Digits),DoubleToString(currentMarket,_Digits),(int)freeze));
      }
      ResetLastError();
      if(modifyRequired &&
         ((!g_trade.PositionModify(positionTicket,sl,actualTp) &&
           g_trade.ResultRetcode()!=TRADE_RETCODE_NO_CHANGES) ||
          (g_trade.ResultRetcode()!=TRADE_RETCODE_DONE &&
           g_trade.ResultRetcode()!=TRADE_RETCODE_NO_CHANGES)))
      {
         LogEvent("BASKET_TP_MODIFY_FAILED",StringFormat("index=%d ticket=%I64u fill=%s tp=%s retcode=%u description=%s",
                  basketIndex+1,positionTicket,DoubleToString(fillPrice,_Digits),DoubleToString(actualTp,_Digits),g_trade.ResultRetcode(),g_trade.ResultRetcodeDescription()));
         // Не оставляем позицию с предварительным TP намеренно: пытаемся закрыть её.
         ResetLastError();
         bool emergencyCloseSent=g_trade.PositionClose(positionTicket);
         uint emergencyCloseRc=g_trade.ResultRetcode();
          bool emergencyStillOpen=PositionSelectByTicket(positionTicket);
          LogEvent("BASKET_TP_MODIFY_EMERGENCY_CLOSE",StringFormat("ticket=%I64u sent=%s retcode=%u description=%s still_open=%s",
                   positionTicket,emergencyCloseSent?"true":"false",emergencyCloseRc,g_trade.ResultRetcodeDescription(),
                   emergencyStillOpen?"true":"false"));
          if(emergencyStillOpen && PositionGetString(POSITION_SYMBOL)==_Symbol &&
             (ulong)PositionGetInteger(POSITION_MAGIC)==InpMagicNumber)
          {
             g_emergencyCloseTicket=positionTicket;
             g_emergencyCloseLastAttemptMs=GetTickCount64();
             PersistEmergencyCloseTicket();
             LogEvent("EMERGENCY_CLOSE_QUEUED",StringFormat("ticket=%I64u retry_interval_ms=5000",positionTicket));
          }
          basketComplete=false;
         break;
      }
      // Подтверждение retcode не гарантирует, что сервер сохранил защитные SL и TP.
      bool protectionOk=false;
      double confirmedSl=0.0, confirmedTp=0.0;
      if(PositionSelectByTicket(positionTicket))
      {
         confirmedSl=PositionGetDouble(POSITION_SL);
         confirmedTp=PositionGetDouble(POSITION_TP);
         double tickSize=SymbolInfoDouble(_Symbol,SYMBOL_TRADE_TICK_SIZE);
         if(tickSize<=0.0) tickSize=_Point;
         bool slOk=(confirmedSl>0.0 && MathAbs(confirmedSl-sl)<=tickSize*0.51);
         bool tpOk=(confirmedTp>0.0 && (!modifyRequired || MathAbs(confirmedTp-actualTp)<=tickSize*0.51));
         protectionOk=(slOk && tpOk);
      }
      if(!protectionOk)
      {
         LogEvent("BASKET_PROTECTION_VERIFY_FAILED",StringFormat("index=%d ticket=%I64u expected_sl=%s actual_sl=%s expected_tp=%s actual_tp=%s modify_required=%s",
                  basketIndex+1,positionTicket,DoubleToString(sl,_Digits),DoubleToString(confirmedSl,_Digits),
                  DoubleToString(actualTp,_Digits),DoubleToString(confirmedTp,_Digits),modifyRequired?"true":"false"));
         ResetLastError();
         bool closeSent=g_trade.PositionClose(positionTicket);
         uint closeRc=g_trade.ResultRetcode();
         bool stillOpen=PositionSelectByTicket(positionTicket);
         LogEvent("BASKET_PROTECTION_EMERGENCY_CLOSE",StringFormat("ticket=%I64u sent=%s retcode=%u still_open=%s",
                  positionTicket,closeSent?"true":"false",closeRc,stillOpen?"true":"false"));
         if(stillOpen && PositionGetString(POSITION_SYMBOL)==_Symbol &&
            (ulong)PositionGetInteger(POSITION_MAGIC)==InpMagicNumber)
         {
            g_emergencyCloseTicket=positionTicket;
            g_emergencyCloseLastAttemptMs=GetTickCount64();
            PersistEmergencyCloseTicket();
            LogEvent("EMERGENCY_CLOSE_QUEUED",StringFormat("ticket=%I64u reason=protection_verify_failed retry_interval_ms=5000",positionTicket));
         }
         basketComplete=false;
         break;
      }
      opened++;
      LogEvent("BASKET_POSITION_OPENED",StringFormat("index=%d/%d ticket=%I64u deal=%I64u volume=%s fill=%s sl=%s tp=%s retcode=%u",
               basketIndex+1,g_runtimePositionsCount,positionTicket,deal,DoubleToString(filledVolume,4),
               DoubleToString(fillPrice,_Digits),DoubleToString(sl,_Digits),DoubleToString(actualTp,_Digits),rc));
      if(rc==TRADE_RETCODE_DONE_PARTIAL || filledVolume+1e-8<volume)
      {
         basketComplete=false;
         LogEvent("BASKET_PARTIAL_FILL",StringFormat("index=%d requested_volume=%s actual_volume=%s; further orders stopped",
                  basketIndex+1,DoubleToString(volume,4),DoubleToString(filledVolume,4)));
         break;
      }
   }

   g_lastDecision=StringFormat("%s: открыто %d из %d отдельных позиций%s",
                               isBuy?"BUY":"SELL",opened,g_runtimePositionsCount,basketComplete?"":"; корзина неполная, автоматический повтор запрещён");
   LogEvent(basketComplete?"BASKET_OPENED":"BASKET_INCOMPLETE",StringFormat("side=%s opened=%d requested=%d",isBuy?"BUY":"SELL",opened,g_runtimePositionsCount));
   ClearEntrySetup(isBuy?1:-1);
   g_pendingSignal=0;
   g_pendingStopLevel=0.0;
   UpdatePanel();
   return opened>0;
}

//+------------------------------------------------------------------+
//| Снимок и откат состояния Renko                                   |
//| Неудачная пересборка истории не должна стирать уже построенные    |
//| кирпичи, уровни и активные режимы BUY/SELL.                       |
//+------------------------------------------------------------------+
void SaveHistorySnapshot()
{
   g_snapshotValid=false;
   g_snapshotCount=g_count;
   if(g_count>0 && ArrayResize(g_snapshotBricks,g_count,512)!=g_count)
   {
      LogEvent("SNAPSHOT_FAILED","bricks array resize failed");
      g_snapshotCount=0;
      return;
   }
   for(int i=0;i<g_count;i++) g_snapshotBricks[i]=g_bricks[i];
   g_snapshotBrickSize=g_brickSize;
   g_snapshotLastClose=g_lastClose;
   g_snapshotLastBid=g_lastBid;
   g_snapshotDirection=g_direction;
   g_snapshotHaveAnchor=g_haveAnchor;
   g_snapshotLastTickMsc=g_lastTickMsc;
   g_snapshotTicksAtLastMsc=g_ticksProcessedAtLastMsc;
   g_snapshotLastSwingHigh=g_lastSwingHigh;
   g_snapshotLastSwingLow=g_lastSwingLow;
   g_snapshotPrevDownLow=g_prevDownLow;
   g_snapshotLatestDownLow=g_latestDownLow;
   g_snapshotPrevUpHigh=g_prevUpHigh;
   g_snapshotLatestUpHigh=g_latestUpHigh;
   g_snapshotSwingHighTriggered=g_swingHighBreakoutTriggered;
   g_snapshotSwingLowTriggered=g_swingLowBreakoutTriggered;
   g_snapshotBuyEntry=g_buyEntryLevel;
   g_snapshotSellEntry=g_sellEntryLevel;
   g_snapshotBuyStop=g_buySetupStop;
   g_snapshotSellStop=g_sellSetupStop;
   g_snapshotBuyEnabled=g_buyEnabled;
   g_snapshotSellEnabled=g_sellEnabled;
   g_snapshotPendingSignal=g_pendingSignal;
   g_snapshotHistoryReady=g_historyReady;
   g_snapshotHistoryPartial=g_historyPartial;
   g_snapshotValid=true;
}

void RestoreHistorySnapshot()
{
   if(!g_snapshotValid) return;
   if(g_snapshotCount>0 && ArrayResize(g_bricks,g_snapshotCount,512)!=g_snapshotCount)
   {
      LogEvent("SNAPSHOT_RESTORE_FAILED","bricks array resize failed");
      return;
   }
   for(int i=0;i<g_snapshotCount;i++) g_bricks[i]=g_snapshotBricks[i];
   g_count=g_snapshotCount;
   g_brickSize=g_snapshotBrickSize;
   g_lastClose=g_snapshotLastClose;
   g_lastBid=g_snapshotLastBid;
   g_direction=g_snapshotDirection;
   g_haveAnchor=g_snapshotHaveAnchor;
   g_lastTickMsc=g_snapshotLastTickMsc;
   g_ticksProcessedAtLastMsc=g_snapshotTicksAtLastMsc;
   g_lastSwingHigh=g_snapshotLastSwingHigh;
   g_lastSwingLow=g_snapshotLastSwingLow;
   g_prevDownLow=g_snapshotPrevDownLow;
   g_latestDownLow=g_snapshotLatestDownLow;
   g_prevUpHigh=g_snapshotPrevUpHigh;
   g_latestUpHigh=g_snapshotLatestUpHigh;
   g_swingHighBreakoutTriggered=g_snapshotSwingHighTriggered;
   g_swingLowBreakoutTriggered=g_snapshotSwingLowTriggered;
   g_buyEntryLevel=g_snapshotBuyEntry;
   g_sellEntryLevel=g_snapshotSellEntry;
   g_buySetupStop=g_snapshotBuyStop;
   g_sellSetupStop=g_snapshotSellStop;
   g_buyEnabled=g_snapshotBuyEnabled;
   g_sellEnabled=g_snapshotSellEnabled;
   g_pendingSignal=g_snapshotPendingSignal;
   g_historyReady=g_snapshotHistoryReady;
   g_historyPartial=g_snapshotHistoryPartial;
   g_liveTickRangePending=false;
   LogEvent("HISTORY_SNAPSHOT_RESTORED",StringFormat("bricks=%d ready=%s",g_count,g_historyReady?"true":"false"));
}

// Проверка свежей истории до разрушения текущего состояния:
// если терминал ещё не синхронизировал тики (4403), пересборку откладываем.
bool ProbeRecentTickHistory()
{
   datetime probeEnd=TimeCurrent();
   if(probeEnd<=0) probeEnd=TimeTradeServer();
   datetime probeFrom=probeEnd-HISTORY_PROBE_SECONDS;
   MqlTick probe[];
   ResetLastError();
   int copied=CopyTicksRange(_Symbol,probe,COPY_TICKS_INFO,(ulong)probeFrom*1000,(ulong)probeEnd*1000);
   int error=GetLastError();
   if(copied<0 || error!=0)
   {
      LogEvent(error==4403?"HISTORY_PROBE_TIMEOUT":"HISTORY_PROBE_FAILED",
               StringFormat("from=%s to=%s copied=%d error=%d",
               TimeToString(probeFrom,TIME_DATE|TIME_MINUTES),
               TimeToString(probeEnd,TIME_DATE|TIME_MINUTES),copied,error));
      return false;
   }
   return true;
}

void RebuildHistory()
{
   g_lastHistoryAttemptMs=GetTickCount64();
   g_processBidGuardExceeded=false;
   // 1) Снимок текущего состояния: при неудаче откатываемся, а не теряем кирпичи и режимы.
   SaveHistorySnapshot();
   // 2) Проверка свежей истории до разрушения состояния: терминал может отдавать 4403.
   if(!ProbeRecentTickHistory())
   {
      RestoreHistorySnapshot();
      g_historyRetryDelayMs=(ulong)MathMin((ulong)HISTORY_RETRY_MAX_MS,g_historyRetryDelayMs+g_historyRetryDelayMs);
      g_lastDecision="История тиков ещё не синхронизирована; торговля заблокирована, повтор позже";
      return;
   }
   // Fail closed: после начала перестроения старая готовность и курсор тиков недействительны.
   g_historyReady=false;
   g_liveTickRangePending=false;
   g_lastTickMsc=0;
   g_ticksProcessedAtLastMsc=0;
   g_lastBid=0.0;
   ArrayResize(g_bricks,0); g_count=0;
   g_lastClose=0; g_lastBid=0; g_direction=0; g_haveAnchor=false;
   g_lastSwingHigh=0; g_lastSwingLow=0; g_prevDownLow=0; g_latestDownLow=0;
   g_prevUpHigh=0; g_latestUpHigh=0;
   ArrayResize(g_downHighs,0); ArrayResize(g_upLows,0);
   g_swingHighBreakoutTriggered=false; g_swingLowBreakoutTriggered=false;
   g_buyEnabled=false; g_sellEnabled=false;
   g_buyEntryLevel=0.0; g_sellEntryLevel=0.0;
   g_buySetupStop=0.0; g_sellSetupStop=0.0;
   g_pendingSignal=0; g_pendingStopLevel=0.0;
   int days=MathMax(1,MathMin(InpHistoryDays,365));
   int chunkSeconds=(int)HISTORY_CHUNK_SECONDS;
   int chunks=(int)(((long)days*86400+chunkSeconds-1)/chunkSeconds);
   ulong buildStartedMs=GetTickCount64();
   bool budgetExhausted=false;
   datetime historyEnd=TimeCurrent();
   int totalTicksCopied=0;
   int failedChunks=0;
   // Загружаем историю по одному дню, а не одним массивом на 365 дней:
   // это ограничивает пиковое потребление памяти.
   for(int day=chunks-1;day>=0;--day)   // чанки по HISTORY_CHUNK_SECONDS, от старых к новым
   {
      // Защита OnInit от слишком долгой пересборки истории.
      if(IsStopped() || GetTickCount64()-buildStartedMs>=HISTORY_INIT_BUDGET_MS)
      {
         budgetExhausted=true;
         LogEvent("HISTORY_BUILD_BUDGET","rebuild stopped by time budget; will retry later");
         break;
      }
      datetime from=historyEnd-(datetime)((day+1)*chunkSeconds);
      datetime to=from+chunkSeconds;
      if(to>historyEnd) to=historyEnd;
      MqlTick ticks[];
      ResetLastError();
      int copied=CopyTicksRange(_Symbol,ticks,COPY_TICKS_INFO,
                                (ulong)from*1000,(ulong)to*1000-1);
      int error=GetLastError();
      // Любой код ошибки означает, что полнота диапазона не подтверждена.
      // При 4403 API может вернуть доступную часть; её нельзя считать полным днём.
      if(copied<0 || error!=0)
      {
         LogEvent(error==4403 ? "HISTORY_RANGE_TIMEOUT" : "HISTORY_RANGE_FAILED",
                  StringFormat("from=%s to=%s copied=%d error=%d",
                  TimeToString(from,TIME_DATE|TIME_MINUTES),
                  TimeToString(to,TIME_DATE|TIME_MINUTES),copied,error));
         // Не подтверждаем готовность истории, если хотя бы один диапазон
         // не был получен полностью. Повторное восстановление начнётся с нуля.
         failedChunks++;
         continue;
      }
      totalTicksCopied+=copied;
      for(int i=0;i<copied;i++)
      {
         if(ticks[i].time_msc>g_lastTickMsc)
         {
            g_lastTickMsc=ticks[i].time_msc;
            g_ticksProcessedAtLastMsc=1;
         }
         else if(ticks[i].time_msc==g_lastTickMsc)
            g_ticksProcessedAtLastMsc++;
         if(ticks[i].bid<=0) continue;
         ProcessBid((datetime)ticks[i].time,ticks[i].bid,false);
         if(g_processBidGuardExceeded)
         {
            failedChunks++;
            // Не используем общий budget-rollback: он мог бы восстановить
            // старый флаг historyReady и разрешить торговлю на неполной структуре.
            LogEvent("HISTORY_BUILD_RENKO_GUARD","history rebuild aborted because one tick exceeded the brick processing guard");
            break;
         }
      }
      if(g_processBidGuardExceeded) break;
   }
   if(totalTicksCopied<=0 || budgetExhausted)
   {
      LogEvent("HISTORY_UNAVAILABLE",StringFormat("ticks=%d failed_chunks=%d budget_exhausted=%s",totalTicksCopied,failedChunks,budgetExhausted?"true":"false"));
      // Откат: ранее построенная структура и режимы сохраняются, торговля остаётся заблокированной.
      RestoreHistorySnapshot();
      g_historyRetryDelayMs=(ulong)MathMin((ulong)HISTORY_RETRY_MAX_MS,g_historyRetryDelayMs+g_historyRetryDelayMs);
      g_lastDecision="История тиков недоступна или неполна; торговля заблокирована, повтор позже";
      return;
   }
   // Неполная история не является готовой: не разрешаем торговлю и
   // повторяем полную загрузку по таймеру, сохраняя желаемые режимы отдельно.
   if(failedChunks>0)
   {
      g_historyReady=false;
      g_historyPartial=true;
      g_buyEnabled=false;
      g_sellEnabled=false;
      g_pendingSignal=0;
      g_pendingStopLevel=0.0;
      g_historyRetryDelayMs=(ulong)HISTORY_RETRY_MIN_MS;
      g_lastDecision="История неполна; торговля заблокирована до полной пересборки";
      LogEvent("HISTORY_REBUILT_PARTIAL",
               StringFormat("ticks=%d bricks=%d failed_chunks=%d; trading blocked",totalTicksCopied,g_count,failedChunks));
      return;
   }
   // Сигналы из истории не торгуются: оставляем последний исторический Bid
   // как предыдущую котировку, чтобы не создавать искусственный переход через ноль.
   g_historyReady=true;
   g_historyPartial=false;
   g_historyRetryDelayMs=(ulong)HISTORY_RETRY_MIN_MS;
   LogEvent("HISTORY_REBUILT",
            StringFormat("ticks=%d bricks=%d failed_chunks=0",totalTicksCopied,g_count));
   g_snapshotValid=false; // Пересборка успешна: откат больше не нужен.
}

int OnInit()
{
   if(InpBrickPoints<1 || InpPositionsCount<1 || InpPositionsCount>100 || InpPositionLots<=0 || InpTakeProfitStepPoints<1 || InpSLBufferPoints<0 ||
      InpRetrySeconds<1 || InpSignalMaxAgeSeconds<1 || InpHistoryDays<1 || InpDeviationPoints<0 || InpMaxSpreadPoints<0 || InpTradeStartHourMSK<0 ||
      InpTradeStartHourMSK>23 || InpTradeEndHourMSK<1 || InpTradeEndHourMSK>24 ||
      InpCloseHourMSK<0 || InpCloseHourMSK>23 || InpTradeStartHourMSK>=InpTradeEndHourMSK)
      return INIT_PARAMETERS_INCORRECT;
   g_runtimeBrickPoints=InpBrickPoints;
   g_brickSize=g_runtimeBrickPoints*_Point;
   // Сначала восстановить структуру Renko; режим нельзя включать без валидных уровней.
   g_buyEnabled=false;
   g_sellEnabled=false;
   g_instanceTag=StringFormat("%I64d",(long)GetMicrosecondCount());
   g_logFile=InpErrorLogFile;
   if(StringLen(InpInstanceId)<1 || StringLen(InpInstanceId)>32)
   {
      Print("RenkoGPTBreakoutEA: InpInstanceId должен содержать от 1 до 32 символов");
      return INIT_PARAMETERS_INCORRECT;
   }
   LoadPersistentSettings();
   double emergencyTicketValue=0.0;
   if(LoadPersistentValue("EmergencyCloseTicket",emergencyTicketValue) &&
      emergencyTicketValue>=0.0 && emergencyTicketValue<=9007199254740991.0 &&
      MathFloor(emergencyTicketValue)==emergencyTicketValue)
   {
      g_emergencyCloseTicket=(ulong)emergencyTicketValue;
      if(g_emergencyCloseTicket>0)
         LogEvent("EMERGENCY_CLOSE_RESTORED",StringFormat("ticket=%I64u",g_emergencyCloseTicket));
   }
   else if(emergencyTicketValue!=0.0)
      LogEvent("EMERGENCY_CLOSE_PERSIST_INVALID",DoubleToString(emergencyTicketValue,0));
   g_restoreModesPending=true;
   g_persistenceReady=true;
   g_trade.SetExpertMagicNumber(InpMagicNumber);
   g_trade.SetDeviationInPoints(InpDeviationPoints);
   ResetLastError();
   if(!EventSetTimer(1))
   {
      LogEvent("TIMER_START_FAILED",StringFormat("error=%d",GetLastError()));
      return INIT_FAILED;
   }
   if(!CreatePanel())
      LogEvent("PANEL_CREATE_FAILED","one or more chart controls could not be created");
   RebuildHistory();
   if(g_historyReady)
   {
      MqlTick initialTick;
      if(SymbolInfoTick(_Symbol,initialTick) && initialTick.bid>0 && ProcessLiveTickRange(initialTick))
         RestoreSavedModesIfReady();
   }
   if((ENUM_ACCOUNT_MARGIN_MODE)AccountInfoInteger(ACCOUNT_MARGIN_MODE)!=ACCOUNT_MARGIN_MODE_RETAIL_HEDGING)
      LogEvent("ACCOUNT_MODE_WARNING","Для корзины из отдельных позиций требуется режим MT5 Hedging");
   LogEvent("EA_BUILD_INFO","version=1.08; renko_engine=self-contained; basket_positions=enabled; hedging_required=true; stepped_tp_from_fill=true; external_indicator=not-used; history_chunked=true; history_snapshot_rollback=true; margin_and_freeze_checks=true; close_scope=all_symbol_positions");
   LogEvent("EA_INITIALIZED",StringFormat("brick_points=%d terminal_trade=%s",InpBrickPoints,(bool)TerminalInfoInteger(TERMINAL_TRADE_ALLOWED)?"ON":"OFF"));
   return INIT_SUCCEEDED;
}

void OnDeinit(const int reason)
{
   SavePersistentSettings();
   EventKillTimer();
   ObjectDelete(0,g_buyButton); ObjectDelete(0,g_sellButton); ObjectDelete(0,g_terminalTradeLabel); ObjectDelete(0,g_terminalTradeDot);
   ObjectDelete(0,g_brickEdit); ObjectDelete(0,g_brickApply); ObjectDelete(0,g_positionsEdit); ObjectDelete(0,g_lotsEdit); ObjectDelete(0,g_basketApply); ObjectDelete(0,g_fivePositionsButton); ObjectDelete(0,g_positionsLabel); ObjectDelete(0,g_lotsLabel); ObjectDelete(0,g_statusLabel);
   for(int i=0;i<10;i++) ObjectDelete(0,g_diagLabels[i]);
   LogEvent("EA_STOPPED",StringFormat("reason=%d",reason));
   CloseLogHandle();
}

void OnChartEvent(const int id,const long &lparam,const double &dparam,const string &sparam)
{
   if(id!=CHARTEVENT_OBJECT_CLICK) return;
   if(sparam==g_buyButton)
   {
      if(g_buyEnabled) { ClearEntrySetup(1); g_lastDecision="BUY-подготовка отменена пользователем"; LogEvent("BUY_SETUP_CANCELLED_USER","manual button click"); }
      else if(!ArmEntrySetup(1)) g_buyEnabled=false;
      SavePersistentSettings();
      UpdatePanel();
   }
   else if(sparam==g_sellButton)
   {
      if(g_sellEnabled) { ClearEntrySetup(-1); g_lastDecision="SELL-подготовка отменена пользователем"; LogEvent("SELL_SETUP_CANCELLED_USER","manual button click"); }
      else if(!ArmEntrySetup(-1)) g_sellEnabled=false;
      SavePersistentSettings();
      UpdatePanel();
   }
   else if(sparam==g_brickApply) ApplyRuntimeBrickSize();
   else if(sparam==g_basketApply) ApplyRuntimeBasketSettings();
   else if(sparam==g_fivePositionsButton) ApplyFivePositionsPreset();
}

bool ProcessLiveTickRange(const MqlTick &tick)
{
   bool wasPending=g_liveTickRangePending;
   if(g_lastTickMsc<=0)
   {
      g_liveTickRangePending=true;
      return false;
   }

   // Читаем курсорную миллисекунду включительно: в ней могут быть разные Bid.
   // Пропускается только префикс, уже обработанный ранее.
   ulong fromMsc=(ulong)g_lastTickMsc;
   ulong toMsc=tick.time_msc;
   if(fromMsc>toMsc)
   {
      g_liveTickRangePending=true;
      datetime now=TimeCurrent();
      if(g_lastLiveTickRangeLog==0 || now-g_lastLiveTickRangeLog>=5)
      {
         LogEvent("LIVE_TICK_CURSOR_MISMATCH",StringFormat("from_msc=%I64u to_msc=%I64u last_tick_msc=%I64d current_bid=%s last_bid=%s pending=true",
                  fromMsc,toMsc,g_lastTickMsc,DoubleToString(tick.bid,_Digits),DoubleToString(g_lastBid,_Digits)));
         g_lastLiveTickRangeLog=now;
      }
      return false;
   }

   MqlTick newTicks[];
   ResetLastError();
   int copied=CopyTicksRange(_Symbol,newTicks,COPY_TICKS_INFO,fromMsc,toMsc);
   int error=GetLastError();

   // При любом коде ошибки непрерывность диапазона не подтверждена.
   // Не обрабатываем возможный частичный ответ и не двигаем курсор.
   if(copied<0 || error!=0)
   {
      g_liveTickRangePending=true;
      datetime now=TimeCurrent();
      if(g_lastLiveTickRangeLog==0 || now-g_lastLiveTickRangeLog>=5)
      {
         LogEvent("LIVE_TICK_RANGE_UNAVAILABLE",StringFormat("from_msc=%I64u to_msc=%I64u copied=%d error=%d current_tick_msc=%I64u current_bid=%s last_tick_msc=%I64d last_bid=%s pending=true",
                  fromMsc,toMsc,copied,error,tick.time_msc,DoubleToString(tick.bid,_Digits),g_lastTickMsc,DoubleToString(g_lastBid,_Digits)));
         g_lastLiveTickRangeLog=now;
      }
      return false;
   }

   if(copied==0)
   {
      if(wasPending || tick.bid!=g_lastBid || tick.time_msc>g_lastTickMsc)
      {
         g_liveTickRangePending=true;
         datetime now=TimeCurrent();
         if(g_lastLiveTickRangeLog==0 || now-g_lastLiveTickRangeLog>=5)
         {
            LogEvent("LIVE_TICK_RANGE_UNAVAILABLE",StringFormat("from_msc=%I64u to_msc=%I64u copied=0 error=%d current_tick_msc=%I64u current_bid=%s last_tick_msc=%I64d last_bid=%s pending=true",
                     fromMsc,toMsc,error,tick.time_msc,DoubleToString(tick.bid,_Digits),g_lastTickMsc,DoubleToString(g_lastBid,_Digits)));
            g_lastLiveTickRangeLog=now;
         }
         return false;
      }
      return true;
   }

   g_processBidGuardExceeded=false;
   int seenAtCursorMsc=0;
   int processedAtCursorMsc=g_ticksProcessedAtLastMsc;
   for(int i=0;i<copied;i++)
   {
      long tickMsc=(long)newTicks[i].time_msc;
      if(tickMsc<g_lastTickMsc)
         continue;

      if(tickMsc==g_lastTickMsc)
      {
         ++seenAtCursorMsc;
         if(seenAtCursorMsc<=processedAtCursorMsc)
            continue;
         ++g_ticksProcessedAtLastMsc;
      }
      else
      {
         g_lastTickMsc=tickMsc;
         g_ticksProcessedAtLastMsc=1;
         seenAtCursorMsc=0;
         processedAtCursorMsc=0;
      }

      // Тик без Bid учитывается курсором, но не создаёт кирпич или сигнал.
      if(newTicks[i].bid<=0)
         continue;
      ProcessBid((datetime)newTicks[i].time,newTicks[i].bid,true);
      if(g_processBidGuardExceeded)
      {
         g_historyReady=false;
         g_historyPartial=true;
         g_buyEnabled=false;
         g_sellEnabled=false;
         g_pendingSignal=0;
         g_pendingStopLevel=0.0;
         g_liveTickRangePending=true;
         g_historyRetryDelayMs=(ulong)HISTORY_RETRY_MIN_MS;
         LogEvent("LIVE_RENKO_GUARD_RECOVERY","live Renko processing exceeded guard; trading disabled until full history rebuild");
         g_lastDecision="Превышен предел обработки Renko; торговля заблокирована до пересборки истории";
         return false;
      }
   }

   if(tick.bid!=g_lastBid)
   {
      g_liveTickRangePending=true;
      datetime now=TimeCurrent();
      if(g_lastLiveTickRangeLog==0 || now-g_lastLiveTickRangeLog>=5)
      {
         LogEvent("LIVE_TICK_RANGE_UNAVAILABLE",StringFormat("from_msc=%I64u to_msc=%I64u copied=%d error=%d current_tick_msc=%I64u current_bid=%s last_tick_msc=%I64d last_bid=%s pending=true reason=bid_not_reconciled",
                  fromMsc,toMsc,copied,error,tick.time_msc,DoubleToString(tick.bid,_Digits),g_lastTickMsc,DoubleToString(g_lastBid,_Digits)));
         g_lastLiveTickRangeLog=now;
      }
      return false;
   }

   g_liveTickRangePending=false;
   if(wasPending)
      LogEvent("LIVE_TICK_RANGE_RECOVERED",StringFormat("copied=%d current_tick_msc=%I64u cursor_msc=%I64d bid=%s",
               copied,tick.time_msc,g_lastTickMsc,DoubleToString(g_lastBid,_Digits)));
   return true;
}
void OnTick()
{
   CloseAtTimeIfRequired();
   MqlTick tick;
   if(!SymbolInfoTick(_Symbol,tick) || tick.bid<=0) return;
   if(!g_historyReady)
   {
      if(g_lastHistoryAttemptMs==0 || GetTickCount64()-g_lastHistoryAttemptMs>=g_historyRetryDelayMs)
         RebuildHistory();
      return;
   }
   if(!ProcessLiveTickRange(tick))
   {
      UpdatePanel();
      return;
   }
   RestoreSavedModesIfReady();
   ExecutePendingSignal();
}

void RetryEmergencyClose()
{
   if(g_emergencyCloseTicket==0) return;
   ulong nowMs=GetTickCount64();
   if(g_emergencyCloseLastAttemptMs>0 && nowMs-g_emergencyCloseLastAttemptMs<5000) return;
   ulong ticket=g_emergencyCloseTicket;
   if(!PositionSelectByTicket(ticket))
   {
      LogEvent("EMERGENCY_CLOSE_RESOLVED",StringFormat("ticket=%I64u reason=position_not_open",ticket));
      g_emergencyCloseTicket=0;
      g_emergencyCloseLastAttemptMs=0;
      PersistEmergencyCloseTicket();
      return;
   }
   if(PositionGetString(POSITION_SYMBOL)!=_Symbol ||
      (ulong)PositionGetInteger(POSITION_MAGIC)!=InpMagicNumber)
   {
      LogEvent("EMERGENCY_CLOSE_CANCELLED",StringFormat("ticket=%I64u reason=position_identity_changed",ticket));
      g_emergencyCloseTicket=0;
      g_emergencyCloseLastAttemptMs=0;
      PersistEmergencyCloseTicket();
      return;
   }
   g_emergencyCloseLastAttemptMs=nowMs;
   ResetLastError();
   bool sent=g_trade.PositionClose(ticket);
   uint rc=g_trade.ResultRetcode();
   bool stillOpen=PositionSelectByTicket(ticket);
   LogEvent("EMERGENCY_CLOSE_RETRY",StringFormat("ticket=%I64u sent=%s retcode=%u description=%s still_open=%s error=%d",
            ticket,sent?"true":"false",rc,g_trade.ResultRetcodeDescription(),stillOpen?"true":"false",GetLastError()));
   if(!stillOpen)
   {
      g_emergencyCloseTicket=0;
      g_emergencyCloseLastAttemptMs=0;
      PersistEmergencyCloseTicket();
   }
}

void OnTimer()
{
   UpdatePanel(); // Обновляем время, вершины/впадины и статус каждую секунду, даже без новых тиков.
   CloseAtTimeIfRequired();
   RetryEmergencyClose();
   if(!g_historyReady && (g_lastHistoryAttemptMs==0 || GetTickCount64()-g_lastHistoryAttemptMs>=g_historyRetryDelayMs))
      RebuildHistory();
   if(g_historyReady)
   {
      MqlTick tick;
      if(!SymbolInfoTick(_Symbol,tick) || tick.bid<=0)
      {
         UpdatePanel();
         return;
      }
      if(!ProcessLiveTickRange(tick))
      {
         UpdatePanel();
         return;
      }
      RestoreSavedModesIfReady();
   }
   ExecutePendingSignal();
   UpdatePanel();
}

void OnTradeTransaction(const MqlTradeTransaction &trans,
                        const MqlTradeRequest &request,
                        const MqlTradeResult &result)
{
   if(trans.type==TRADE_TRANSACTION_DEAL_ADD && trans.deal>0 && HistoryDealSelect(trans.deal))
   {
      string dealSymbol=HistoryDealGetString(trans.deal,DEAL_SYMBOL);
      long dealMagic=HistoryDealGetInteger(trans.deal,DEAL_MAGIC);
      ENUM_DEAL_ENTRY entry=(ENUM_DEAL_ENTRY)HistoryDealGetInteger(trans.deal,DEAL_ENTRY);
      if(dealSymbol==_Symbol && (ulong)dealMagic==InpMagicNumber &&
         (entry==DEAL_ENTRY_OUT || entry==DEAL_ENTRY_OUT_BY || entry==DEAL_ENTRY_INOUT))
      {
         datetime closeTime=(datetime)HistoryDealGetInteger(trans.deal,DEAL_TIME);
         long serverToUtcOffset=(long)TimeGMT()-(long)TimeCurrent();
         datetime closeMsk=(datetime)((long)closeTime+serverToUtcOffset+3*3600);
         double closePrice=HistoryDealGetDouble(trans.deal,DEAL_PRICE);
         double closeVolume=HistoryDealGetDouble(trans.deal,DEAL_VOLUME);
         long closeReason=HistoryDealGetInteger(trans.deal,DEAL_REASON);
         g_lastCloseInfo=StringFormat("Последнее закрытие: сервер %s | MSK %s | %s | объём %.2f | цена %s",
            TimeToString(closeTime,TIME_DATE|TIME_MINUTES),TimeToString(closeMsk,TIME_DATE|TIME_MINUTES),
            closeReason==DEAL_REASON_TP?"TP":(closeReason==DEAL_REASON_SL?"SL":(closeReason==DEAL_REASON_CLIENT?"вручную":"прочее")),
            closeVolume,DoubleToString(closePrice,_Digits));
         UpdatePanel();
         LogEvent("POSITION_CLOSED",StringFormat("deal=%I64u server=%s msk=%s volume=%.2f price=%s reason=%d",
            trans.deal,TimeToString(closeTime,TIME_DATE|TIME_SECONDS),TimeToString(closeMsk,TIME_DATE|TIME_SECONDS),
            closeVolume,DoubleToString(closePrice,_Digits),(int)closeReason));
      }
   }
   if(trans.symbol!=_Symbol) return;
   if(result.retcode!=0 && result.retcode!=TRADE_RETCODE_DONE &&
      result.retcode!=TRADE_RETCODE_DONE_PARTIAL && result.retcode!=TRADE_RETCODE_PLACED)
      LogEvent("TRADE_TRANSACTION_ERROR",StringFormat("type=%d retcode=%u comment=%s order=%I64u deal=%I64u",
               (int)trans.type,result.retcode,result.comment,result.order,result.deal));
}