#include <TraderEdgAIFactor.mqh>
int g_h = 0;   // 因子句柄，全局保存

int OnInit() {
  g_h = TEA_FactorCreate(2);   // 2=HedgeRegime，可选 0/1/3
  if (g_h == 0) { Print("TEA: 因子创建失败"); return INIT_FAILED; }
  return INIT_SUCCEEDED;
}

void OnDeinit(int reason) {
  if (g_h != 0) { TEA_FactorDestroy(g_h); g_h = 0; }  // 仅对非 0 释放
}

void OnTick() {
  if (g_h == 0) return;

  // 准备 K 线：下标 0=最旧，n-1=最新，与 iOpen(..., bar) 顺序一致
  double o[], h[], l[], c[], v[];
  int n = 200;
  ArrayResize(o, n); ArrayResize(h, n); ArrayResize(l, n);
  ArrayResize(c, n); ArrayResize(v, n);
  for (int i = 0; i < n; i++) {
    int bar = n - 1 - i;
    o[i] = iOpen(Symbol(), PERIOD_CURRENT, bar);
    h[i] = iHigh(Symbol(), PERIOD_CURRENT, bar);
    l[i] = iLow(Symbol(), PERIOD_CURRENT, bar);
    c[i] = iClose(Symbol(), PERIOD_CURRENT, bar);
    v[i] = (double)iVolume(Symbol(), PERIOD_CURRENT, bar);
  }

  if (TEA_FactorProcess(g_h, o, h, l, c, v, n) != 1) return;  // 失败则不读信号

  double dir = TEA_FactorGetDirection(g_h);
  int act = TEA_FactorGetAction(g_h);
  int regime = TEA_FactorGetRegime(g_h);
  // 使用 dir / act / regime 做开平仓逻辑
}

#include <TraderEdgAIFactor.mqh>
int g_h = 0;   // factor handle, global

int OnInit() {
  g_h = TEA_FactorCreate(2);   // 2=HedgeRegime, or 0/1/3
  if (g_h == 0) { Print("TEA: factor create failed"); return INIT_FAILED; }
  return INIT_SUCCEEDED;
}

void OnDeinit(int reason) {
  if (g_h != 0) { TEA_FactorDestroy(g_h); g_h = 0; }  // only free non-zero
}

void OnTick() {
  if (g_h == 0) return;

  // OHLCV: index 0=oldest, n-1=newest, same order as iOpen(..., bar)
  double o[], h[], l[], c[], v[];
  int n = 200;
  ArrayResize(o, n); ArrayResize(h, n); ArrayResize(l, n);
  ArrayResize(c, n); ArrayResize(v, n);
  for (int i = 0; i < n; i++) {
    int bar = n - 1 - i;
    o[i] = iOpen(Symbol(), PERIOD_CURRENT, bar);
    h[i] = iHigh(Symbol(), PERIOD_CURRENT, bar);
    l[i] = iLow(Symbol(), PERIOD_CURRENT, bar);
    c[i] = iClose(Symbol(), PERIOD_CURRENT, bar);
    v[i] = (double)iVolume(Symbol(), PERIOD_CURRENT, bar);
  }

  if (TEA_FactorProcess(g_h, o, h, l, c, v, n) != 1) return;  // do not read signals on failure

  double dir = TEA_FactorGetDirection(g_h);
  int act = TEA_FactorGetAction(g_h);
  int regime = TEA_FactorGetRegime(g_h);
  // use dir / act / regime for open/close logic
}

#include <TraderEdgAIFactor.mqh>
int g_h = 0;

int OnInit() {
  g_h = TEA_FactorCreate(TEA_FACTOR_HEDGE_REGIME);  // 2
  if (g_h == 0) { Print("TEA: 因子创建失败"); return INIT_FAILED; }
  return INIT_SUCCEEDED;
}

void OnDeinit(const int reason) {
  if (g_h != 0) { TEA_FactorDestroy(g_h); g_h = 0; }
}

void OnTick() {
  if (g_h == 0) return;

  MqlRates rates[];
  int n = 200;
  if (CopyRates(_Symbol, PERIOD_CURRENT, 0, n, rates) != n) return;  // 0=最旧，n-1=最新

  double o[], h[], l[], c[], v[];
  ArrayResize(o, n); ArrayResize(h, n); ArrayResize(l, n); ArrayResize(c, n); ArrayResize(v, n);
  for (int i = 0; i < n; i++) {
    o[i] = rates[i].open;   h[i] = rates[i].high;
    l[i] = rates[i].low;    c[i] = rates[i].close;
    v[i] = (double)rates[i].tick_volume;
  }

  if (TEA_FactorProcess(g_h, o, h, l, c, v, n) != 1) return;

  double dir = TEA_FactorGetDirection(g_h);
  int act = TEA_FactorGetAction(g_h);
  int regime = TEA_FactorGetRegime(g_h);
}

#include <TraderEdgAIFactor.mqh>
int g_h = 0;

int OnInit() {
  g_h = TEA_FactorCreate(TEA_FACTOR_HEDGE_REGIME);  // 2
  if (g_h == 0) { Print("TEA: factor create failed"); return INIT_FAILED; }
  return INIT_SUCCEEDED;
}

void OnDeinit(const int reason) {
  if (g_h != 0) { TEA_FactorDestroy(g_h); g_h = 0; }
}

void OnTick() {
  if (g_h == 0) return;

  MqlRates rates[];
  int n = 200;
  if (CopyRates(_Symbol, PERIOD_CURRENT, 0, n, rates) != n) return;  // 0=oldest, n-1=newest

  double o[], h[], l[], c[], v[];
  ArrayResize(o, n); ArrayResize(h, n); ArrayResize(l, n); ArrayResize(c, n); ArrayResize(v, n);
  for (int i = 0; i < n; i++) {
    o[i] = rates[i].open;   h[i] = rates[i].high;
    l[i] = rates[i].low;    c[i] = rates[i].close;
    v[i] = (double)rates[i].tick_volume;
  }

  if (TEA_FactorProcess(g_h, o, h, l, c, v, n) != 1) return;

  double dir = TEA_FactorGetDirection(g_h);
  int act = TEA_FactorGetAction(g_h);
  int regime = TEA_FactorGetRegime(g_h);
}

// 1. 准备多空两侧数组：按开仓时间升序填充 profit_buy[], lots_buy[], open_time_buy[] 与 sell 侧
// 2. 取得 regime、confidence（例如从 TEA_FactorGetRegime/GetConfidence）
int regime = 1;
double confidence = 0.7;

// 3. 声明所有出参变量（MQ4 中通过引用传回）
int out_act, out_side, out_loss_idx, out_profit_start, out_profit_cnt;
int out_seg_side, out_cross_side, out_strategy;
double out_net, out_potential, out_float_red;

// 4. 调用（数组与 count 必须对应）
int hasRec = TEA_ReductionRecommend(
  profit_buy, lots_buy, open_time_buy, count_buy,
  profit_sell, lots_sell, open_time_sell, count_sell,
  regime, confidence, 0.0, 3, 0.0, 1, 0,
  out_act, out_side, out_loss_idx, out_profit_start, out_profit_cnt,
  out_seg_side, out_cross_side,
  out_net, out_potential, out_float_red, out_strategy
);

if (hasRec == 1) {
  // 有推荐：先平盈利段（从 out_profit_start 起共 out_profit_cnt 笔），再平亏损单
  // 根据 out_act/out_side 判断是单侧还是跨侧
}

// 1. Prepare buy/sell arrays: fill profit_buy[], lots_buy[], open_time_buy[] and sell side, ascending by open time
// 2. Get regime, confidence (e.g. from TEA_FactorGetRegime/GetConfidence)
int regime = 1;
double confidence = 0.7;

// 3. Declare all output vars (MQ4 passes by reference)
int out_act, out_side, out_loss_idx, out_profit_start, out_profit_cnt;
int out_seg_side, out_cross_side, out_strategy;
double out_net, out_potential, out_float_red;

// 4. Call (array lengths must match count)
int hasRec = TEA_ReductionRecommend(
  profit_buy, lots_buy, open_time_buy, count_buy,
  profit_sell, lots_sell, open_time_sell, count_sell,
  regime, confidence, 0.0, 3, 0.0, 1, 0,
  out_act, out_side, out_loss_idx, out_profit_start, out_profit_cnt,
  out_seg_side, out_cross_side,
  out_net, out_potential, out_float_red, out_strategy
);

if (hasRec == 1) {
  // Has recommendation: close profit segment first (from out_profit_start, out_profit_cnt bars), then loss
  // Use out_act/out_side to tell single-side vs cross-side
}

double closes[];
int n = 100;
ArrayResize(closes, n);
CopyClose(Symbol(), PERIOD_CURRENT, 0, n, closes);  // 0=最旧，n-1=最新
double r2 = TEA_RSquared(closes, n);
// r2 在 0～1，可用于过滤或仓位权重

double closes[];
int n = 100;
ArrayResize(closes, n);
CopyClose(Symbol(), PERIOD_CURRENT, 0, n, closes);  // 0=oldest, n-1=newest
double r2 = TEA_RSquared(closes, n);
// r2 in 0~1; use for filter or position weight

double closes[];
int n = 100;
if (CopyClose(_Symbol, PERIOD_CURRENT, 0, n, closes) != n) return;
double r2 = TEA_RSquared(closes, n);

double closes[];
int n = 100;
if (CopyClose(_Symbol, PERIOD_CURRENT, 0, n, closes) != n) return;
double r2 = TEA_RSquared(closes, n);