123 lines
3.8 KiB
TypeScript
123 lines
3.8 KiB
TypeScript
/**
|
||
* 检查任务状态脚本
|
||
* 用于诊断卡住的任务：查看任务状态、进度、创建时间等
|
||
*
|
||
* 使用方法：
|
||
* npx ts-node scripts/check-task-status.ts [taskId]
|
||
* 如果不提供 taskId，则显示所有进行中的任务
|
||
*/
|
||
|
||
import { PrismaClient } from '@prisma/client';
|
||
import dotenv from 'dotenv';
|
||
|
||
dotenv.config();
|
||
|
||
const prisma = new PrismaClient();
|
||
|
||
async function checkTaskStatus(taskId?: string) {
|
||
try {
|
||
if (taskId) {
|
||
// 查询指定任务
|
||
const task = await prisma.courseGenerationTask.findUnique({
|
||
where: { id: taskId },
|
||
include: {
|
||
course: {
|
||
select: {
|
||
id: true,
|
||
title: true,
|
||
status: true,
|
||
},
|
||
},
|
||
user: {
|
||
select: {
|
||
id: true,
|
||
phone: true,
|
||
nickname: true,
|
||
},
|
||
},
|
||
},
|
||
});
|
||
|
||
if (!task) {
|
||
console.log(`❌ 任务不存在: ${taskId}`);
|
||
return;
|
||
}
|
||
|
||
console.log('\n=== 任务详情 ===');
|
||
console.log(`任务ID: ${task.id}`);
|
||
console.log(`课程ID: ${task.courseId}`);
|
||
console.log(`课程标题: ${task.course.title}`);
|
||
console.log(`用户ID: ${task.userId}`);
|
||
console.log(`用户: ${task.user.nickname || task.user.phone || 'N/A'}`);
|
||
console.log(`状态: ${task.status}`);
|
||
console.log(`进度: ${task.progress}%`);
|
||
console.log(`当前步骤: ${task.currentStep || 'N/A'}`);
|
||
console.log(`错误信息: ${task.errorMessage || 'N/A'}`);
|
||
console.log(`来源类型: ${task.sourceType || 'N/A'}`);
|
||
console.log(`导师类型: ${task.persona || 'N/A'}`);
|
||
console.log(`创建时间: ${task.createdAt}`);
|
||
console.log(`更新时间: ${task.updatedAt}`);
|
||
console.log(`运行时长: ${Math.floor((Date.now() - task.createdAt.getTime()) / 1000 / 60)} 分钟`);
|
||
|
||
if (task.status !== 'completed' && task.status !== 'failed') {
|
||
const minutesSinceUpdate = Math.floor((Date.now() - task.updatedAt.getTime()) / 1000 / 60);
|
||
if (minutesSinceUpdate > 5) {
|
||
console.log(`⚠️ 警告: 任务已 ${minutesSinceUpdate} 分钟未更新，可能已卡住`);
|
||
}
|
||
}
|
||
} else {
|
||
// 查询所有进行中的任务
|
||
const tasks = await prisma.courseGenerationTask.findMany({
|
||
where: {
|
||
status: {
|
||
notIn: ['completed', 'failed'],
|
||
},
|
||
},
|
||
include: {
|
||
course: {
|
||
select: {
|
||
id: true,
|
||
title: true,
|
||
},
|
||
},
|
||
},
|
||
orderBy: {
|
||
createdAt: 'desc',
|
||
},
|
||
});
|
||
|
||
if (tasks.length === 0) {
|
||
console.log('✅ 没有进行中的任务');
|
||
return;
|
||
}
|
||
|
||
console.log(`\n=== 进行中的任务 (共 ${tasks.length} 个) ===\n`);
|
||
|
||
for (const task of tasks) {
|
||
const minutesSinceUpdate = Math.floor((Date.now() - task.updatedAt.getTime()) / 1000 / 60);
|
||
const minutesSinceCreate = Math.floor((Date.now() - task.createdAt.getTime()) / 1000 / 60);
|
||
|
||
console.log(`任务ID: ${task.id}`);
|
||
console.log(`课程: ${task.course.title} (${task.courseId})`);
|
||
console.log(`状态: ${task.status} | 进度: ${task.progress}%`);
|
||
console.log(`创建时间: ${task.createdAt} (${minutesSinceCreate} 分钟前)`);
|
||
console.log(`更新时间: ${task.updatedAt} (${minutesSinceUpdate} 分钟前)`);
|
||
|
||
if (minutesSinceUpdate > 5) {
|
||
console.log(`⚠️ 警告: 已 ${minutesSinceUpdate} 分钟未更新，可能已卡住`);
|
||
}
|
||
console.log('---');
|
||
}
|
||
}
|
||
} catch (error: any) {
|
||
console.error('❌ 查询失败:', error.message);
|
||
} finally {
|
||
await prisma.$disconnect();
|
||
}
|
||
}
|
||
|
||
// 从命令行参数获取 taskId
|
||
const taskId = process.argv[2];
|
||
|
||
checkTaskStatus(taskId);
|