V10.553 瘦身 current 比價結果查詢

tests/test_competitor_intel_cache.py

@@ -56,6 +56,9 @@ def test_competitor_ppt_results_keep_pending_diagnostics_in_export():
 def test_competitor_ppt_results_use_history_for_dated_reports():
     source = (ROOT / "services" / "competitor_intel_repository.py").read_text(encoding="utf-8")
     route_source = (ROOT / "routes" / "openclaw_bot_routes.py").read_text(encoding="utf-8")
+    comparison_source = source.split("def fetch_competitor_comparison_results", 1)[1].split(
+        "def build_competitor_intel_payload", 1
+    )[0]
 
     assert "requested_historical_prices" in source
     assert "use_history_prices" in source
@@ -63,6 +66,11 @@ def test_competitor_ppt_results_use_history_for_dated_reports():
     assert "cph.crawled_at >= DATE(:start_date)" in source
     assert "cph.crawled_at < DATE(:end_date) + INTERVAL '1 day'" in source
     assert "pr.timestamp < DATE(:end_date) + INTERVAL '1 day'" in source
+    assert "FROM products p\n            JOIN LATERAL" in comparison_source
+    assert "WHERE pr.product_id = p.id" in comparison_source
+    assert "ORDER BY pr.timestamp DESC, pr.id DESC" in comparison_source
+    assert "ROW_NUMBER() OVER (PARTITION BY p.id" not in comparison_source
+    assert "WHERE lm.rn = 1" not in comparison_source
     assert "'competitor_price_history' AS competitor_source" in source
     assert "\"competitor_source\"" in source
     assert "\"pc_crawled_at\"" in source