AI会话任务修复：P1 review状态独立映射+前端待确认提示，P2 移除next_run_at列+删除firePrompt死代码

project/短视频脚本创作/V1.0/mcn-work-shop/public/app.js

@@ -38,6 +38,7 @@ async function executeTask(opts) {
   const restore = () => { if (btn) { btn.disabled = false; btn.innerHTML = oldText; btn.classList.remove('btn-busy'); } };
   if (btn) { btn.disabled = true; btn.innerHTML = '执行中…'; btn.classList.add('btn-busy'); }
   let taskId = null;
+  let finished = false;
   try {
     const d = await api('/api/run', {
       method: 'POST',
@@ -58,12 +59,14 @@ async function executeTask(opts) {
     await new Promise((r) => setTimeout(r, 5000));
     let s = null;
     try { s = await api('/api/run/status?id=' + encodeURIComponent(taskId)); } catch (e) { continue; }
-    if (!s || s.state === 'notfound') break;
-    if (s.state === 'done') { showToast('✅ 任务执行完成，页面已自动刷新'); refreshCurrentPage(); break; }
-    if (s.state === 'error') { showToast('❌ 任务执行失败' + (s.error ? '：' + s.error : '')); break; }
+    if (!s || s.state === 'notfound') { finished = true; break; }
+    if (s.state === 'done') { finished = true; showToast('✅ 任务执行完成，页面已自动刷新'); refreshCurrentPage(); break; }
+    if (s.state === 'error') { finished = true; showToast('❌ 任务执行失败' + (s.error ? '：' + s.error : '')); break; }
+    if (s.state === 'review') { finished = true; showToast('⏸ 任务待确认，请到左侧会话栏确认执行'); break; }
     // queued / pending / running → 继续等待
   }
   restore();
+  if (!finished) showToast('⏳ 任务仍在执行，请到左侧会话栏查看进度');
 }
 
 // 通用确认弹窗：确认后执行 AI 任务（opts: title/desc/target/url/prompt/label/btn/afterText）

project/短视频脚本创作/V1.0/mcn-work-shop/public/data-pages.js

@@ -44,26 +44,6 @@ function bindBack(container) {
   }));
 }
 
-/* 触发 AI 任务：提交 WorkBuddy Automation 一次性任务，WorkBuddy 自动执行，左侧会话栏可见 */
-let _lastFireTs = 0;
-async function firePrompt(prompt, label) {
-  const nowTs = Date.now();
-  if (nowTs - _lastFireTs < 5000) { showToast('⏳ 任务刚提交，请在左侧会话栏查看执行'); return false; }
-  _lastFireTs = nowTs;
-  try {
-    const d = await api('/api/run', {
-      method: 'POST',
-      headers: { 'Content-Type': 'application/json' },
-      body: JSON.stringify({ prompt, name: label || '工作台任务' }),
-    });
-    showToast('✅ ' + (d.message || '任务已提交，请在左侧会话栏查看执行'));
-    return true;
-  } catch (e) {
-    showToast('❌ 任务提交失败: ' + e.message);
-    return false;
-  }
-}
-
 /* AI写脚本 确认弹窗：按账号是否有设定动态文案；选题输入区（手输 / AI 结合人设生成）→ 确认后执行创作任务 */
 async function confirmAiScript(accountName, btn) {
   // 判断账号是否有有效设定（persona 非空且非测试占位）：有 →「基于当前账号设定」，无 →「先进行账号设定分析」

project/短视频脚本创作/V1.0/mcn-work-shop/server.js

@@ -371,9 +371,9 @@ const server = http.createServer((req, res) => {
         const scheduledAt = `${d.getFullYear()}-${pad(d.getMonth() + 1)}-${pad(d.getDate())}T${pad(d.getHours())}:${pad(d.getMinutes())}`;
         const uidRow = db.prepare("SELECT user_id FROM sessions WHERE user_id IS NOT NULL AND user_id <> '' ORDER BY created_at DESC LIMIT 1").get();
         const ownerUserId = uidRow ? uidRow.user_id : '';
-        db.prepare(`INSERT INTO automations (id,name,prompt,status,schedule_type,next_run_at,scheduled_at,rrule,cwds,created_at,updated_at,skills_json,connector_ids_json,model_id,permission_mode,owner_user_id,owner_status)
-          VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`)
-          .run(id, name || '工作台任务', prompt.trim(), 'ACTIVE', 'once', now, scheduledAt, '', JSON.stringify([cwd]), now, now, '[]', '[]', 'deepseek-v4-flash', 'fullAccess', ownerUserId, 'confirmed');
+        db.prepare(`INSERT INTO automations (id,name,prompt,status,schedule_type,scheduled_at,rrule,cwds,created_at,updated_at,skills_json,connector_ids_json,model_id,permission_mode,owner_user_id,owner_status)
+          VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`)
+          .run(id, name || '工作台任务', prompt.trim(), 'ACTIVE', 'once', scheduledAt, '', JSON.stringify([cwd]), now, now, '[]', '[]', 'deepseek-v4-flash', 'fullAccess', ownerUserId, 'confirmed');
         db.close();
         log('已提交 AI 任务: ' + id + (name ? ' (' + name + ')' : ''));
         return sendJSON(200, { ok: true, id, message: '任务已提交，请在左侧会话栏查看执行' });
@@ -401,10 +401,10 @@ const server = http.createServer((req, res) => {
       else if (runs) {
         const s = String(runs.status || '').toUpperCase();
         if (s === 'IN_PROGRESS') state = 'running';
-        else if (s === 'PENDING_REVIEW') state = 'pending';
+        else if (s === 'PENDING_REVIEW') state = 'review'; // 任务停在「待用户确认/已中断」，前端应提示而非假装执行中
         else if (['DONE', 'COMPLETED', 'SUCCESS', 'FINISHED'].includes(s)) state = 'done';
         else if (['ERROR', 'CANCELLED', 'FAILED', 'INTERRUPTED'].includes(s)) state = 'error';
-        else state = 'pending';
+        else state = 'pending'; // ACCEPTED / QUEUED / PENDING 等 = 排队等待执行
       }
       return sendJSON(200, { ok: true, id, state, error: (st && st.last_error) || null });
     } catch (e) {