mini-starter/test-delay-scheduler.js

import { DataSource } from 'typeorm';
import { DelaySchedulerService } from './packages/feie-printer-module-mt/src/services/delay-scheduler.service.js';

async function testDelayScheduler() {
  try {
    console.log('开始测试延迟调度器...');

    // 创建数据源连接
    const dataSource = new DataSource({
      type: 'postgres',
      host: '127.0.0.1',
      port: 5432,
      username: 'postgres',
      password: '',
      database: 'postgres',
      synchronize: false,
      logging: false,
      entities: [
        './packages/feie-printer-module-mt/src/entities/*.entity.ts'
      ]
    });

    await dataSource.initialize();
    console.log('数据库连接成功');

    // 飞鹅配置
    const feieConfig = {
      user: '2638601246@qq.com',
      ukey: 'tAwVmIEv48zcIu2Y',
      baseUrl: 'https://api.feieyun.cn/Api/Open/',
      timeout: 10000,
      maxRetries: 3
    };

    // 创建延迟调度器
    const delayScheduler = new DelaySchedulerService(dataSource, feieConfig, 1);

    // 手动触发处理
    console.log('手动触发延迟任务处理...');
    const result = await delayScheduler.triggerManualProcess(1);

    console.log('处理结果:', result);

    // 检查任务状态
    const task = await dataSource.query(
      "SELECT * FROM feie_print_task_mt WHERE task_id = 'TEST_123456'"
    );

    console.log('任务状态:', task[0]);

    await dataSource.destroy();
    console.log('测试完成');

  } catch (error) {
    console.error('测试失败:', error);
  }
}

testDelayScheduler();