feat(market_watch): 接入messenger——温区更新走broadcast通道
This commit is contained in:
@@ -17,6 +17,7 @@ from datetime import datetime
|
|||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
from mofin_db import get_conn, init_all_tables, write_market_snapshot
|
from mofin_db import get_conn, init_all_tables, write_market_snapshot
|
||||||
|
from messenger import send as messenger_send
|
||||||
|
|
||||||
DATA_DIR = Path(__file__).parent.parent / "data"
|
DATA_DIR = Path(__file__).parent.parent / "data"
|
||||||
|
|
||||||
@@ -256,6 +257,10 @@ def main():
|
|||||||
_regime = _mr.compute_regime()
|
_regime = _mr.compute_regime()
|
||||||
if _regime:
|
if _regime:
|
||||||
_mr.save_regime(_regime)
|
_mr.save_regime(_regime)
|
||||||
|
try:
|
||||||
|
messenger_send(title="MoFin温区更新", content=f"市场温度: {_regime['regime']} (above_ma20={_regime['above_ma20']} adx={_regime['adx']})", source="market_watch.py")
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
print(f"[regime] {_regime['date']} → {_regime['regime']} "
|
print(f"[regime] {_regime['date']} → {_regime['regime']} "
|
||||||
f"(above_ma20={_regime['above_ma20']} adx={_regime['adx']})", flush=True)
|
f"(above_ma20={_regime['above_ma20']} adx={_regime['adx']})", flush=True)
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user