const mysql = require('mysql2');

async function verifyData() {
  const connection = mysql.createConnection({
    host: process.env.DB_HOST || 'nj-cdb-3pwh2kz1.sql.tencentcdb.com',
    port: process.env.DB_PORT || 20784,
    user: process.env.DB_USER || 'jiebanke',
    password: process.env.DB_PASSWORD || 'aiot741$12346',
    database: process.env.DB_NAME || 'niumall'
  });

  try {
    console.log('验证测试数据...');

    // 检查供应商数据
    const [suppliers] = await connection.promise().query('SELECT COUNT(*) as count FROM suppliers WHERE id < 1000');
    console.log(`供应商测试数据: ${suppliers[0].count} 条`);

    // 检查司机数据
    const [drivers] = await connection.promise().query('SELECT COUNT(*) as count FROM drivers WHERE id < 1000');
    console.log(`司机测试数据: ${drivers[0].count} 条`);

    // 检查订单数据
    const [orders] = await connection.promise().query('SELECT COUNT(*) as count FROM orders WHERE id < 1000');
    console.log(`订单测试数据: ${orders[0].count} 条`);

    // 显示部分数据详情
    console.log('\n数据详情:');
    
    const [supplierList] = await connection.promise().query('SELECT id, name, contact_person, contact_phone FROM suppliers WHERE id < 1000 LIMIT 3');
    console.log('供应商:');
    supplierList.forEach(supplier => {
      console.log(`  ${supplier.id}: ${supplier.name} (${supplier.contact_person}, ${supplier.contact_phone})`);
    });

    const [driverList] = await connection.promise().query('SELECT id, name, phone, license_type FROM drivers WHERE id < 1000 LIMIT 3');
    console.log('司机:');
    driverList.forEach(driver => {
      console.log(`  ${driver.id}: ${driver.name} (${driver.phone}, ${driver.license_type})`);
    });

    const [orderList] = await connection.promise().query('SELECT id, orderNo, supplierName, cattleBreed, cattleCount FROM orders WHERE id < 1000 LIMIT 3');
    console.log('订单:');
    orderList.forEach(order => {
      console.log(`  ${order.id}: ${order.orderNo} - ${order.supplierName} (${order.cattleBreed} x${order.cattleCount})`);
    });

  } catch (error) {
    console.error('验证错误:', error.message);
  } finally {
    await connection.end();
  }
}

verifyData();