#!/usr/bin/env python3
"""
简单的API测试
"""
import sys
sys.path.append('backend')

import asyncio
from app.services.procurement_list_service_v2 import ProcurementListServiceV2
from app.core.database import get_db

async def test_service():
    """直接测试服务"""
    try:
        service = ProcurementListServiceV2()
        
        async for db in get_db():
            result = await service.get_product_aggregated_list(
                db=db,
                procurement_method="LA",
                page=1,
                page_size=3
            )
            
            print("=== 服务直接调用结果 ===")
            print("成功:", bool(result))
            print("items数量:", len(result.get('items', [])) if result else 0)
            
            if result and result.get('items'):
                items = result['items']
                print(f"\n前3个产品:")
                for i, item in enumerate(items[:3], 1):
                    print(f"\n第{i}个产品:")
                    print(f"  product_name: {item.get('product_name', 'N/A')[:60]}...")
                    print(f"  brand: '{item.get('brand', 'N/A')}'")
                    print(f"  procurement_method: {item.get('procurement_method', 'N/A')}")
                    
                    # 检查所有字段
                    print("  所有字段:", list(item.keys()))
                    
                    # 查找Tods产品
                    if 'Tods' in str(item.get('product_name', '')):
                        print(f"  🎯 这是Tods产品!")
            break
            
    except Exception as e:
        print(f"错误: {e}")
        import traceback
        traceback.print_exc()

if __name__ == "__main__":
    asyncio.run(test_service())