zhizhi/scripts/neural/track-work-orders.js

// scripts/neural/track-work-orders.js
// 🧬 工单追踪器
// 铸渊每次唤醒时运行，追踪所有活跃工单状态
// 检查超时、匹配回执、更新状态、生成追踪报告

const fs = require('fs');
const path = require('path');

var WORK_ORDER_DIR = 'data/neural-reports/work-orders';
var COMPLETED_DIR = 'data/deploy-queue/completed';
var TRACKER_DIR = 'data/neural-reports/work-orders';
var TERMINAL_STATUSES = ['CLOSED', 'ESCALATED', 'VERIFIED'];

function loadJSON(p) {
  try { return JSON.parse(fs.readFileSync(p, 'utf8')); }
  catch (e) { return null; }
}

function getActiveWorkOrders() {
  if (!fs.existsSync(WORK_ORDER_DIR)) return [];

  var allOrders = [];
  var files = fs.readdirSync(WORK_ORDER_DIR)
    .filter(function(f) { return f.startsWith('work-orders-') && f.endsWith('.json'); });

  for (var i = 0; i < files.length; i++) {
    var data = loadJSON(path.join(WORK_ORDER_DIR, files[i]));
    if (data && data.work_orders) {
      for (var j = 0; j < data.work_orders.length; j++) {
        allOrders.push(data.work_orders[j]);
      }
    }
  }

  return allOrders.filter(function(wo) {
    return TERMINAL_STATUSES.indexOf(wo.status) === -1;
  });
}

function getCompletedReceipts() {
  if (!fs.existsSync(COMPLETED_DIR)) return {};

  var receipts = {};
  var files = fs.readdirSync(COMPLETED_DIR)
    .filter(function(f) { return f.endsWith('.json'); });

  for (var i = 0; i < files.length; i++) {
    var receipt = loadJSON(path.join(COMPLETED_DIR, files[i]));
    if (receipt && receipt.command_id) {
      receipts[receipt.command_id] = receipt;
    }
  }
  return receipts;
}

function checkTimeout(workOrder) {
  var timeout = workOrder.timeout_hours || 24;
  var created = new Date(workOrder.created);
  var now = new Date();
  var elapsed = (now - created) / (1000 * 60 * 60);
  return elapsed > timeout;
}

function trackWorkOrders() {
  console.log('\n━━━ 🧬 工单追踪器启动 ━━━\n');

  var activeOrders = getActiveWorkOrders();
  var receipts = getCompletedReceipts();

  console.log('活跃工单: ' + activeOrders.length + ' 个');

  var stats = {
    total_active: activeOrders.length,
    by_status: {},
    timed_out: 0,
    matched_receipts: 0,
    escalated: 0
  };

  for (var i = 0; i < activeOrders.length; i++) {
    var wo = activeOrders[i];
    var status = wo.status || 'pending';

    // 统计状态分布
    if (!stats.by_status[status]) stats.by_status[status] = 0;
    stats.by_status[status]++;

    // 检查超时
    if (checkTimeout(wo)) {
      stats.timed_out++;
      console.log('  ⏰ 超时: ' + wo.id + ' (' + wo.title + ')');

      // 检查是否需要升级
      var maxRetries = (wo.constraints && wo.constraints.max_retries) || 2;
      if (wo.retry_count >= maxRetries) {
        wo.status = 'ESCALATED';
        stats.escalated++;
        console.log('  🔺 升级到人类: ' + wo.id);
      }
    }

    // 检查回执匹配
    if (wo.command_id && receipts[wo.command_id]) {
      var receipt = receipts[wo.command_id];
      stats.matched_receipts++;

      if (receipt.result && receipt.result.status === 'success') {
        wo.status = 'VERIFIED';
        console.log('  ✅ 已验证: ' + wo.id + ' (回执成功)');
      } else if (receipt.result && receipt.result.status === 'failure') {
        wo.status = 'pending';
        wo.retry_count = (wo.retry_count || 0) + 1;
        console.log('  ❌ 失败: ' + wo.id + ' (重试 ' + wo.retry_count + ')');
      }
    }
  }

  // 生成追踪报告
  var now = new Date();
  var cstTime = new Date(now.getTime() + 8 * 60 * 60 * 1000);
  var dateStr = cstTime.toISOString().split('T')[0];

  var trackerReport = {
    tracker_id: 'TRACKER-' + dateStr,
    timestamp: now.toISOString(),
    stats: stats,
    active_orders: activeOrders.map(function(wo) {
      return {
        id: wo.id,
        severity: wo.severity,
        title: wo.title,
        status: wo.status,
        created: wo.created,
        timed_out: checkTimeout(wo)
      };
    })
  };

  fs.mkdirSync(TRACKER_DIR, { recursive: true });
  fs.writeFileSync(
    path.join(TRACKER_DIR, 'tracker-' + dateStr + '.json'),
    JSON.stringify(trackerReport, null, 2)
  );

  console.log('\n📊 追踪报告:');
  console.log('  活跃: ' + stats.total_active);
  console.log('  超时: ' + stats.timed_out);
  console.log('  回执匹配: ' + stats.matched_receipts);
  console.log('  升级: ' + stats.escalated);
  console.log('  状态分布: ' + JSON.stringify(stats.by_status));
  console.log('\n━━━ 追踪完成 ━━━\n');

  return trackerReport;
}

if (require.main === module) {
  trackWorkOrders();
}

module.exports = { trackWorkOrders };