This commit is contained in:
dekun
2026-05-24 08:41:31 +08:00
parent eebb658dc5
commit 8b0607d83f
6 changed files with 293 additions and 98 deletions
+17 -2
View File
@@ -167,17 +167,32 @@ def register_hub_routes(app):
"SELECT * FROM trend_pullback_plans WHERE status='active' ORDER BY id DESC"
).fetchall():
trends.append(_row_to_dict(row))
rolls = []
try:
for row in conn.execute(
"SELECT * FROM roll_groups WHERE status='active' ORDER BY id DESC"
).fetchall():
rolls.append(_row_to_dict(row))
except Exception:
pass
conn.close()
enrich = c.get("enrich_monitor")
if callable(enrich):
try:
payload = enrich(keys=keys, orders=orders, trends=trends)
payload = enrich(keys=keys, orders=orders, trends=trends, rolls=rolls)
if isinstance(payload, dict):
return jsonify({"ok": True, **payload})
except Exception as e:
return jsonify({"ok": False, "msg": str(e)}), 500
return jsonify(
{"ok": True, "keys": keys, "orders": orders, "trends": trends, "key_prices": []}
{
"ok": True,
"keys": keys,
"orders": orders,
"trends": trends,
"rolls": rolls,
"key_prices": [],
}
)
@app.route("/api/hub/add_order", methods=["POST"])