from sqlalchemy import text
from backend.models.database import SessionLocal

db = SessionLocal()
threshold = db.execute(text("""
    SELECT datalink FROM dim_products WHERE datalink IS NOT NULL
    ORDER BY datalink DESC OFFSET 9999 LIMIT 1
""")).scalar()
print(f"new_listing threshold (top-10k by datalink): {threshold}")
print()

for r in db.execute(text("""
    SELECT sku, datalink, name FROM dim_products
    WHERE sku = ANY(:s) ORDER BY datalink DESC NULLS LAST
"""), {"s": ["POL12928", "POL12929", "POL12910", "POL12830", "POL09753"]}).mappings():
    is_new = r["datalink"] is not None and r["datalink"] >= threshold
    flag = "← NEW" if is_new else ""
    print(f"  {r['sku']}  datalink={r['datalink']:>6}  {flag}  name={(r['name'] or '')[:50]}")
db.close()