MT5-Chart v1.18: Trade-Marker, Liquiditaetszonen, Kurs oben rechts + Pfeil-Bugfix
Pfeil-Bugfix (User: "liquiditaetspfeile werden immer noch nicht angezeigt"):
(1) ANCHOR_LEFT ist fuer OBJ_ARROW UNGUELTIG (nur TOP/BOTTOM)
(2) Pfeile sitzen rechts neben der letzten Kerze -> ohne CHART_SHIFT kein
sichtbarer Bereich dort
Blink-Fix (User: "blinken nur manchmal auf"): hl_walls setzte den Cache bei jedem
Fehlschlag auf None -> LQ-Zeilen fehlten -> Indikator loeschte die Pfeile. Jetzt
letzter guter Stand 120s Grace.
Neu (alles reine Anzeige):
- TR;<O|C>;zeit -> Kerze der Eroeffnung HELLGRUEN, des Close DUNKELGRUEN umrandet
- EQ;<H|L>;lo;hi;zeit -> Equal Highs/Lows aus M30-Pivots als goldenes Band +
gestrichelte Kante (wie im User-Referenzbild). Als Signal gemessen verworfen.
- PX;bid -> aktueller Kurs fett oben rechts
- Beschriftung der Liquiditaets-Trendlinie per Default aus (v1.16)
Alles kompiliert und live in sr_levels.csv verifiziert.
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
Axel Hocks
co-authored by
Claude Opus 4.8
Claude Opus 4.8
parent
b75997d703
commit
03567adf6b
@@ -75,6 +75,8 @@ _SQUEEZE_REENTRY_COOLDOWN_S = 180.0 # nach JEDEM Close eines Trades (Notfall/SL
|
||||
# gegen die Open→Instant-Close-Kaskade bei zu engem Stop
|
||||
# (real 2026-07-27 15:39: −3-€-Stop killte Entry #1 in 16 s,
|
||||
# Squeeze noch aktiv → sofortiger Re-Entry; 2026-07-28)
|
||||
_TRADE_MARKS = 6 # so viele letzte Trades im MQL5-Chart markieren
|
||||
# (Kerze umranden: Eröffnung hellgrün, Close dunkelgrün)
|
||||
_STARTUP_GRACE_S = 60.0 # nach Bot-Start schließt der Bot 60 s lang KEINEN
|
||||
# laufenden Trade server-seitig (S/R-Close/Notfall/
|
||||
# Time-Stop/Reverse) — die Daten (Preis/ATR/P(break)/
|
||||
@@ -1984,6 +1986,45 @@ class TradingEngine:
|
||||
f"{'U' if tr.get('dir')=='up' else 'D'}")
|
||||
except Exception:
|
||||
pass
|
||||
# Liquiditätszonen (Equal Highs/Lows, M30): EQ;<H|L>;lo;hi;<broker_time>
|
||||
# → goldenes Band ab dem ersten Pivot, nach rechts verlängert.
|
||||
# ⚠ REINE ANZEIGE (als Signal gemessen verworfen, s. backtest_liquidity_sweep).
|
||||
try:
|
||||
zs = (self.wave.snapshot() or {}).get("liq_zones") or {}
|
||||
boff_z = self.trader._broker_offset_s()
|
||||
for key, tag in (("eqh", "H"), ("eql", "L")):
|
||||
z = zs.get(key)
|
||||
if z and z.get("lo") and z.get("hi"):
|
||||
# `t` ist ROHE Broker-Zeit aus copy_rates → NICHT nochmal
|
||||
# umrechnen (anders als die HL-Trendlinie, die lokal tickt).
|
||||
lines.append(f"EQ;{tag};{z['lo']};{z['hi']};{int(z['t'])}")
|
||||
except Exception:
|
||||
pass
|
||||
# Aktueller Kurs für die fette Anzeige oben rechts (User-Wunsch): PX;bid
|
||||
try:
|
||||
_bid = (self.data.snapshot() or {}).get("bid")
|
||||
if _bid:
|
||||
lines.append(f"PX;{_bid}")
|
||||
except Exception:
|
||||
pass
|
||||
# Trade-Marker: TR;<O|C>;<broker_time> → der Indikator umrandet die Kerze,
|
||||
# in der eröffnet (hellgrün) bzw. geschlossen (dunkelgrün) wurde
|
||||
# (User-Vorgabe 2026-07-30). Offene Position + die letzten Trades des Tages.
|
||||
try:
|
||||
boff = self.trader._broker_offset_s()
|
||||
marks: list[tuple[str, int]] = []
|
||||
ps = self.trader.snapshot()
|
||||
if ps.get("ticket") and ps.get("open_time"):
|
||||
marks.append(("O", int(float(ps["open_time"]) + boff)))
|
||||
for t in (self.history.last_closed_trades(_TRADE_MARKS) or []):
|
||||
if t.get("entry_time"):
|
||||
marks.append(("O", int(float(t["entry_time"]) + boff)))
|
||||
if t.get("exit_time"):
|
||||
marks.append(("C", int(float(t["exit_time"]) + boff)))
|
||||
for kind, ts in marks[:2 * _TRADE_MARKS + 1]:
|
||||
lines.append(f"TR;{kind};{ts}")
|
||||
except Exception:
|
||||
pass
|
||||
# Zonen NICHT mehr aus der (statischen) [zones]-Config — die dynamische
|
||||
# Handels-Range zeichnet der Indikator selbst aus den Chart-Kerzen (TF-genau).
|
||||
path = os.path.join(self._mql5_files_dir, "sr_levels.csv")
|
||||
|
||||
@@ -34,6 +34,8 @@ log = get_logger("hlwalls")
|
||||
_TIMEOUT_S = 2.0 # der MT5-Loop darf nicht am HTTP hängen
|
||||
_TTL_S = 10.0 # Cache — die Wände wandern langsamer als der Export-Takt (~5 s)
|
||||
_MAX_AGE_S = 60.0 # älter = HL-Feed steht → nicht mehr zeichnen
|
||||
_STALE_GRACE_S = 120.0 # nach einem Fehlschlag den letzten guten Stand so lange
|
||||
# weiterreichen (Blink-Fix — s. Kommentar in `walls()`)
|
||||
|
||||
|
||||
class HLWalls:
|
||||
@@ -85,6 +87,20 @@ class HLWalls:
|
||||
f"Liquiditätslinien (HL-Dashboard auf 8001 läuft nicht?)")
|
||||
self._fail_logged = True
|
||||
with self._lock:
|
||||
if data is not None:
|
||||
self._last_good = data
|
||||
self._last_good_ts = now
|
||||
elif (getattr(self, "_last_good", None) is not None
|
||||
and now - getattr(self, "_last_good_ts", 0.0) < _STALE_GRACE_S):
|
||||
# ⚠ BLINK-FIX (2026-07-30, User „die Liquidationspfeile blinken nur
|
||||
# manchmal auf"): ein einzelner Fehlschlag (HTTP-Timeout, HL-Server
|
||||
# kurz busy, Snapshot minimal zu alt) darf die Pfeile NICHT löschen.
|
||||
# Ohne den letzten guten Wert fehlen die LQ-Zeilen in der CSV → der
|
||||
# Indikator löscht beim Redraw alle Objekte und zeichnet sie nicht neu
|
||||
# → Pfeil weg, beim nächsten Erfolg wieder da = sichtbares Blinken.
|
||||
# Innerhalb der Grace wird der letzte gute Stand weitergereicht;
|
||||
# erst danach verschwinden die Pfeile wirklich (echter Ausfall).
|
||||
data = self._last_good
|
||||
self._cache = data
|
||||
self._cache_ts = now
|
||||
return data
|
||||
|
||||
@@ -80,6 +80,8 @@ _SQ_REFRESH_S = 5.0 # eigener, schneller M5-Fetch NUR für den Squeeze (entkoppe
|
||||
# raus (z. B. Short im M30-Aufwärtstrend). Nur für Basis-TF < M30 aktiv.
|
||||
_HTF = mt5.TIMEFRAME_M30
|
||||
_HTF_LABEL = "M30"
|
||||
_EQ_TOL_ATR = 0.15 # „gleich" für Equal Highs/Lows: beide Pivots innerhalb x×ATR
|
||||
_EQ_MIN_H_ATR = 0.10 # Mindest-Bandhöhe der Liquiditätszone (sonst unsichtbar dünn)
|
||||
_HTF_DEADBAND = 0.15 # |EMA12−EMA50| < x×ATR(M30) → HTF gilt als neutral
|
||||
|
||||
# Multi-TF-Konfluenz (nur Konfidenz/Anzeige): wenn M30 UND H1 die Richtung
|
||||
@@ -296,6 +298,10 @@ class WaveRecommender:
|
||||
if _lbl == "M5":
|
||||
self._m5_hl = (_h, _l)
|
||||
elif _lbl == "M30":
|
||||
# Bar-ZEITEN mit ablegen — die Liquiditätszonen (Equal
|
||||
# Highs/Lows) brauchen den Zeitpunkt der beiden Pivots,
|
||||
# um im Chart als Band gezeichnet werden zu können.
|
||||
self._m30_t = [int(b["time"]) for b in _tb]
|
||||
# M30-H/L für die S/R-LEVEL (Chart + P(break)-Auto-Close).
|
||||
# Gemessen 2026-07-30 (`backtest_level_tf.py`): M30-Level
|
||||
# schlagen M5 in BEIDEN Hälften (R-Ertrag ~2×, Level 1,95
|
||||
@@ -398,6 +404,35 @@ class WaveRecommender:
|
||||
pl30 = [round(_ls[j], 3) for j in range(_K, len(_ls) - _K)
|
||||
if _ls[j] == min(_ls[j - _K:j + _K + 1])]
|
||||
self._pb_levels30 = {"ph": ph30, "pl": pl30}
|
||||
# ── Liquiditätszonen: EQUAL HIGHS / EQUAL LOWS (SMC, User-Wunsch
|
||||
# 2026-07-30 „zeichne mir die Liquiditätszonen wie im Bild ein").
|
||||
# Zwei ~gleiche M30-Pivots (innerhalb _EQ_TOL×ATR, 2–40 Bars
|
||||
# auseinander) = Stop-Cluster. ⚠ REINE ANZEIGE — als SIGNAL gemessen
|
||||
# und verworfen (`backtest_liquidity_sweep.py`: Equal Highs/Lows
|
||||
# fallen in fast allen Varianten durch, der SMC-Exit sogar überall).
|
||||
_a30 = turn_data.get("M30", (None, None))[1] if turn_data else None
|
||||
_t30 = getattr(self, "_m30_t", None)
|
||||
if _a30 and _a30 > 0 and _t30 and len(_t30) >= len(_hs):
|
||||
_tol = _EQ_TOL_ATR * _a30
|
||||
_toff = len(_t30) - len(_hs) # Index-Versatz Fenster→Voll-Liste
|
||||
def _equal(vals, want_high):
|
||||
# jüngstes Paar zuerst suchen (rückwärts)
|
||||
idx = [j for j in range(_K, len(vals) - _K)
|
||||
if ((vals[j] == max(vals[j - _K:j + _K + 1])) if want_high
|
||||
else (vals[j] == min(vals[j - _K:j + _K + 1])))]
|
||||
for a in range(len(idx) - 1, 0, -1):
|
||||
for b in range(a - 1, -1, -1):
|
||||
gap = idx[a] - idx[b]
|
||||
if gap < 2: continue
|
||||
if gap > 40: break
|
||||
if abs(vals[idx[a]] - vals[idx[b]]) <= _tol:
|
||||
lo = min(vals[idx[a]], vals[idx[b]])
|
||||
hi = max(vals[idx[a]], vals[idx[b]])
|
||||
pad = max(0.0, (_EQ_MIN_H_ATR * _a30 - (hi - lo)) / 2)
|
||||
return {"lo": round(lo - pad, 3), "hi": round(hi + pad, 3),
|
||||
"t": int(_t30[idx[b] + _toff])}
|
||||
return None
|
||||
self._liq_zones = {"eqh": _equal(_hs, True), "eql": _equal(_ls, False)}
|
||||
# Multi-TF-Bounce: stärksten Status über M1/M5/M15/M30 wählen (H1 ist NUR
|
||||
# für die Ampel im turn_data, NICHT im gemessen-neutralen Bounce → skip).
|
||||
cands = []
|
||||
@@ -420,6 +455,8 @@ class WaveRecommender:
|
||||
# M30-Level = Quelle für Chart-Linien UND P(break)-Auto-Close (gemessen besser);
|
||||
# `pb_levels` (M5) bleibt für das Entry-Raum-Gate.
|
||||
snap["pb_levels30"] = dict(self._pb_levels30) if getattr(self, "_pb_levels30", None) else None
|
||||
# Liquiditätszonen (Equal Highs/Lows, M30) — REINE ANZEIGE (Signal verworfen)
|
||||
snap["liq_zones"] = dict(self._liq_zones) if getattr(self, "_liq_zones", None) else None
|
||||
snap["squeeze"] = dict(self._squeeze) if getattr(self, "_squeeze", None) else \
|
||||
{"state": None, "dir": None, "level": None, "box_atr": None}
|
||||
# ── Entry-Raum-Gate (gemessen `backtest_entryroom.py`, beide Hälften
|
||||
|
||||
Reference in New Issue
Block a user