import asyncio
from sqlalchemy import select
from app.core.database import AsyncSessionLocal
from app.models.models import Customer

async def main():
    async with AsyncSessionLocal() as db:
        rows = (await db.execute(select(Customer).order_by(Customer.id.desc()).limit(3))).scalars().all()
        print(f"recent_customer_count={len(rows)}")
        for item in rows:
            print(f"customer_id={item.id}|code={item.customer_code or 'pending'}|status={item.status}|olt_assigned={bool(item.olt_device_id)}|ont_sn_assigned={bool(item.ont_sn)}|onu_mode={item.onu_id_mode}|onu_id={'assigned' if item.onu_id is not None else 'pending'}")

asyncio.run(main())