fix(1c): normalize problematic company fields from clickhouse

2026-05-22 15:01:20 +03:00
parent d70f121b5a
commit 68a82a95ee
1 changed files with 7 additions and 1 deletions
@@ -587,7 +587,13 @@ def problematic_companies(days: int = 7, limit: int = 50) -> list[dict[str, Any]
    ORDER BY r.max_score DESC, r.signals_total DESC, p.amount_30d DESC, p.counterparty
    LIMIT {int(limit)}
    """
-    return rows_to_dict(client.query(sql))
+    items = rows_to_dict(client.query(sql))
+    for item in items:
+        if "infobase" not in item and "p.infobase" in item:
+            item["infobase"] = item["p.infobase"]
+        if "counterparty" not in item and "p.counterparty" in item:
+            item["counterparty"] = item["p.counterparty"]
+    return items


 def render_brief_history_html(items: list[dict[str, Any]]) -> str: