const { Pool } = require('pg');
const pool = new Pool({
  host: '47.116.196.11',
  port: 15432,
  database: 'postgresql',
  user: 'postgresql',
  password: 'Jchl1528'
});

async function analyze() {
  try {
    // 1. 检查最近的手术安排及其关联的手术申请
    console.log('=== 分析手术安排与手术申请的关联 ===\n');
    
    const result = await pool.query(`
      SELECT 
        os.schedule_id,
        os.oper_code,
        os.apply_id,
        os.create_time,
        os.creator_id,
        cs.id as surgery_id,
        cs.surgery_no,
        cs.apply_dept_id,
        cs.apply_dept_name,
        cs.main_surgeon_id,
        cs.main_surgeon_name,
        cs.status_enum,
        CASE 
          WHEN cs.id IS NULL THEN '手术申请记录不存在'
          WHEN cs.apply_dept_name IS NULL THEN '申请科室名称为空'
          WHEN cs.main_surgeon_name IS NULL THEN '主刀医生名称为空'
          ELSE '正常'
        END as status
      FROM hisdev.op_schedule os
      LEFT JOIN hisdev.cli_surgery cs ON os.apply_id = cs.id
      WHERE os.delete_flag = '0'
      ORDER BY os.create_time DESC
      LIMIT 10
    `);
    
    console.table(result.rows);
    
    // 2. 检查手术申请本身的字段情况
    console.log('\n=== 最近创建的手术申请 ===');
    const surgeryResult = await pool.query(`
      SELECT 
        id,
        surgery_no,
        patient_name,
        apply_dept_id,
        apply_dept_name,
        main_surgeon_id,
        main_surgeon_name,
        status_enum,
        create_time,
        create_by
      FROM hisdev.cli_surgery
      WHERE delete_flag = '0'
      ORDER BY create_time DESC
      LIMIT 5
    `);
    
    console.table(surgeryResult.rows);
    
  } catch (err) {
    console.error('查询失败:', err.message);
  } finally {
    pool.end();
  }
}

analyze();