From 70f678506eec6a2b874116352b8ae3d203a00c89 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Sat, 14 Mar 2026 06:38:13 +0000 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=BB=BA=E7=AB=8B=E6=89=A7=E8=A1=8C?= =?UTF-8?q?=E5=B1=82=E7=8A=B6=E6=80=81=E5=90=8C=E6=AD=A5=E7=B3=BB=E7=BB=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 新增模块: - core/execution-sync: 执行层状态采集与同步 - docs/execution-layer-map.md: 执行层结构地图 - docs/execution-status.md: 执行层状态报告(自动生成) - .github/workflows/execution-sync.yml: 每日状态同步工作流 更新: - connectors/notion-sync: 新增 syncExecutionStatus 方法 - core/system-check: 新增 execution-sync 模块检查 - brain/master-brain.md: 新增执行同步模块入口 - brain/system-health.json: 新增 execution_sync 状态 - package.json: 新增 core:sync 脚本 Co-authored-by: qinfendebingshuo <207279273+qinfendebingshuo@users.noreply.github.com> --- .github/workflows/execution-sync.yml | 53 ++++++ brain/master-brain.md | 3 + brain/system-health.json | 4 +- connectors/notion-sync/index.js | 57 +++++- core/execution-sync/index.js | 267 +++++++++++++++++++++++++++ core/system-check/index.js | 2 + docs/execution-layer-map.md | 94 ++++++++++ docs/execution-status.md | 58 ++++++ package.json | 1 + 9 files changed, 537 insertions(+), 2 deletions(-) create mode 100644 .github/workflows/execution-sync.yml create mode 100644 core/execution-sync/index.js create mode 100644 docs/execution-layer-map.md create mode 100644 docs/execution-status.md diff --git a/.github/workflows/execution-sync.yml b/.github/workflows/execution-sync.yml new file mode 100644 index 00000000..d101a56f --- /dev/null +++ b/.github/workflows/execution-sync.yml @@ -0,0 +1,53 @@ +name: "📡 铸渊 · 执行层状态同步" + +on: + schedule: + - cron: '0 3 * * *' # 每日 UTC 03:00 (北京时间 11:00) + workflow_dispatch: + +permissions: + contents: write + +jobs: + execution-sync: + name: 执行层状态采集与同步 + runs-on: ubuntu-latest + + steps: + - name: Checkout repository + uses: actions/checkout@v4 + + - name: Setup Node.js + uses: actions/setup-node@v4 + with: + node-version: '20' + + # ── Step 1: 运行系统自检 ── + - name: 运行系统自检 + run: node core/system-check + + # ── Step 2: 生成执行状态报告 ── + - name: 生成执行状态报告 + run: node core/execution-sync report + + # ── Step 3: 同步到 Notion ── + - name: 同步执行状态到 Notion + if: ${{ secrets.NOTION_TOKEN != '' }} + env: + NOTION_TOKEN: ${{ secrets.NOTION_TOKEN }} + EXECUTION_LOG_DB_ID: ${{ secrets.EXECUTION_LOG_DB_ID }} + run: node core/execution-sync sync + + # ── Step 4: 提交状态报告 ── + - name: 提交状态报告 + run: | + git config user.name "铸渊 Execution Sync" + git config user.email "actions@guanghulab.com" + git add docs/execution-status.md + if git diff --cached --quiet; then + echo "📌 无变更需要提交" + else + git commit -m "📡 Execution Sync: 更新执行状态报告 [skip ci]" + git push + echo "✅ 已提交执行状态报告" + fi diff --git a/brain/master-brain.md b/brain/master-brain.md index 8c07f56b..6d82c41a 100644 --- a/brain/master-brain.md +++ b/brain/master-brain.md @@ -67,10 +67,13 @@ | 广播监听 | `core/broadcast-listener/index.js` | 广播监听与任务解析 | | 任务队列 | `core/task-queue/index.js` | 任务调度与执行 | | 系统自检 | `core/system-check/index.js` | 仓库自检系统 | +| 执行同步 | `core/execution-sync/index.js` | 执行层状态同步 | | Notion 同步 | `connectors/notion-sync/index.js` | 双向数据同步 | | 模型路由 | `connectors/model-router/index.js` | 模型调用路由 | | 结构地图 | `docs/repo-structure-map.md` | 仓库结构文档 | | 桥接地图 | `docs/notion-bridge-map.md` | Notion 桥接文档 | +| 执行层地图 | `docs/execution-layer-map.md` | 执行层结构文档 | +| 执行状态 | `docs/execution-status.md` | 执行层状态报告（自动生成） | --- diff --git a/brain/system-health.json b/brain/system-health.json index 6f18a249..c0fb4fc9 100644 --- a/brain/system-health.json +++ b/brain/system-health.json @@ -7,6 +7,7 @@ "system_health": "normal", "execution_layer_status": "stable", "notion_bridge": "active", + "execution_sync": "enabled", "task_queue": "running", "brain_integrity": { "complete": true, @@ -17,7 +18,8 @@ "core_modules": { "broadcast_listener": "enabled", "task_queue": "enabled", - "system_check": "enabled" + "system_check": "enabled", + "execution_sync": "enabled" }, "connectors": { "notion_sync": "enabled", diff --git a/connectors/notion-sync/index.js b/connectors/notion-sync/index.js index 4c8336e3..645c6af4 100644 --- a/connectors/notion-sync/index.js +++ b/connectors/notion-sync/index.js @@ -165,6 +165,61 @@ function writeLocalLog(logEntry) { console.log('📝 日志已写入本地'); } +/** + * 同步执行层状态到 Notion + */ +async function syncExecutionStatus(statusData) { + const dbId = process.env.EXECUTION_LOG_DB_ID; + if (!dbId) { + console.log('⚠️ EXECUTION_LOG_DB_ID 未设置，执行状态仅写入本地'); + writeLocalLog({ + task_id: `execution-status-${new Date().toISOString().slice(0, 10)}`, + status: statusData.execution_layer_status || 'stable', + type: 'execution_status', + data: statusData + }); + return; + } + + console.log('📡 同步执行层状态到 Notion...'); + + const summary = [ + `version: v${statusData.version || 'unknown'}`, + `modules: ${(statusData.core_modules || []).filter(m => m.status === 'enabled').length}/${(statusData.core_modules || []).length}`, + `connectors: ${(statusData.connectors || []).filter(c => c.status === 'enabled').length}/${(statusData.connectors || []).length}`, + `workflows: ${statusData.workflows?.count || 0}`, + `queue: ${statusData.task_queue?.total || 0} total / ${statusData.task_queue?.pending || 0} pending` + ].join(' | '); + + try { + await notionRequest('POST', 'pages', { + parent: { database_id: dbId }, + properties: { + Name: { title: [{ text: { content: `Execution Status · ${new Date().toISOString().slice(0, 10)}` } }] }, + Status: { select: { name: statusData.execution_layer_status || 'stable' } }, + Executor: { rich_text: [{ text: { content: 'zhuyuan' } }] }, + Timestamp: { rich_text: [{ text: { content: statusData.timestamp || new Date().toISOString() } }] } + }, + children: [{ + object: 'block', + type: 'paragraph', + paragraph: { + rich_text: [{ text: { content: summary } }] + } + }] + }); + console.log('✅ 执行层状态已同步到 Notion'); + } catch (err) { + console.error(`⚠️ Notion 同步失败，回退本地: ${err.message}`); + writeLocalLog({ + task_id: `execution-status-${new Date().toISOString().slice(0, 10)}`, + status: statusData.execution_layer_status || 'stable', + type: 'execution_status', + data: statusData + }); + } +} + /** * 检查 Notion 连接状态 */ @@ -206,4 +261,4 @@ if (require.main === module) { })(); } -module.exports = { pullBroadcasts, pushExecutionLog, writeLocalLog, checkStatus, notionRequest }; +module.exports = { pullBroadcasts, pushExecutionLog, syncExecutionStatus, writeLocalLog, checkStatus, notionRequest }; diff --git a/core/execution-sync/index.js b/core/execution-sync/index.js new file mode 100644 index 00000000..fa2b0c66 --- /dev/null +++ b/core/execution-sync/index.js @@ -0,0 +1,267 @@ +/** + * core/execution-sync — 执行层状态同步模块 + * + * 职责： + * - 扫描仓库结构，采集执行层状态 + * - 生成执行层状态报告（docs/execution-status.md） + * - 同步执行状态到 Notion 主脑 + * + * 执行逻辑： + * 扫描仓库 → 生成状态报告 → 同步到 Notion + * + * 调用方式： + * node core/execution-sync [report|sync|status] + */ + +const fs = require('fs'); +const path = require('path'); + +const ROOT = path.resolve(__dirname, '../..'); + +/** + * 采集核心模块状态 + */ +function collectCoreModules() { + const modules = [ + { name: 'broadcast-listener', path: 'core/broadcast-listener/index.js' }, + { name: 'task-queue', path: 'core/task-queue/index.js' }, + { name: 'system-check', path: 'core/system-check/index.js' }, + { name: 'execution-sync', path: 'core/execution-sync/index.js' } + ]; + + return modules.map(m => ({ + ...m, + status: fs.existsSync(path.join(ROOT, m.path)) ? 'enabled' : 'missing' + })); +} + +/** + * 采集连接器状态 + */ +function collectConnectors() { + const connectors = [ + { name: 'notion-sync', path: 'connectors/notion-sync/index.js' }, + { name: 'model-router', path: 'connectors/model-router/index.js' } + ]; + + return connectors.map(c => ({ + ...c, + status: fs.existsSync(path.join(ROOT, c.path)) ? 'enabled' : 'missing' + })); +} + +/** + * 采集自动化工作流状态 + */ +function collectWorkflows() { + const workflowDir = path.join(ROOT, '.github/workflows'); + if (!fs.existsSync(workflowDir)) return { count: 0, files: [] }; + + const files = fs.readdirSync(workflowDir).filter( + f => f.endsWith('.yml') || f.endsWith('.yaml') + ); + return { count: files.length, files }; +} + +/** + * 采集任务队列状态 + */ +function collectQueueStatus() { + const queuePath = path.join(ROOT, 'core/task-queue/queue.json'); + if (!fs.existsSync(queuePath)) { + return { total: 0, pending: 0, running: 0, completed: 0, failed: 0 }; + } + + try { + const queue = JSON.parse(fs.readFileSync(queuePath, 'utf-8')); + const tasks = queue.tasks || []; + return { + total: tasks.length, + pending: tasks.filter(t => t.status === 'pending').length, + running: tasks.filter(t => t.status === 'running').length, + completed: tasks.filter(t => t.status === 'completed').length, + failed: tasks.filter(t => t.status === 'failed').length + }; + } catch { + return { total: 0, pending: 0, running: 0, completed: 0, failed: 0 }; + } +} + +/** + * 读取系统版本 + */ +function getSystemVersion() { + const healthPath = path.join(ROOT, 'brain/system-health.json'); + if (!fs.existsSync(healthPath)) return 'unknown'; + + try { + const health = JSON.parse(fs.readFileSync(healthPath, 'utf-8')); + return health.version || 'unknown'; + } catch { + return 'unknown'; + } +} + +/** + * 生成完整的执行层状态快照 + */ +function collectStatus() { + const now = new Date(); + const beijingTime = new Date(now.getTime() + 8 * 60 * 60 * 1000) + .toISOString().replace('T', ' ').slice(0, 19) + '+08:00'; + + return { + timestamp: beijingTime, + version: getSystemVersion(), + core_modules: collectCoreModules(), + connectors: collectConnectors(), + workflows: collectWorkflows(), + task_queue: collectQueueStatus(), + execution_layer_status: 'stable', + notion_bridge: 'active', + execution_sync: 'enabled' + }; +} + +/** + * 生成 Markdown 状态报告 + */ +function generateReport(statusData) { + const s = statusData || collectStatus(); + + const coreTable = s.core_modules.map(m => + `| ${m.name} | \`${m.path}\` | ${m.status === 'enabled' ? '✅ Enabled' : '❌ Missing'} |` + ).join('\n'); + + const connTable = s.connectors.map(c => + `| ${c.name} | \`${c.path}\` | ${c.status === 'enabled' ? '✅ Enabled' : '❌ Missing'} |` + ).join('\n'); + + const q = s.task_queue; + + const md = `# 执行层状态报告 — execution-status.md + +> 铸渊执行层自动生成 · TCS-0002∞ +> 更新时间：${s.timestamp} + +--- + +## 系统概览 + +| 指标 | 状态 | +|------|------| +| 系统版本 | v${s.version} | +| 执行层状态 | ${s.execution_layer_status === 'stable' ? '✅ Stable' : '⚠️ ' + s.execution_layer_status} | +| Notion 桥接 | ${s.notion_bridge === 'active' ? '✅ Active' : '❌ Inactive'} | +| 执行同步 | ${s.execution_sync === 'enabled' ? '✅ Enabled' : '❌ Disabled'} | +| 工作流数量 | ${s.workflows.count} | + +--- + +## 核心模块状态 + +| 模块 | 路径 | 状态 | +|------|------|------| +${coreTable} + +--- + +## 连接器状态 + +| 连接器 | 路径 | 状态 | +|--------|------|------| +${connTable} + +--- + +## 任务队列状态 + +| 指标 | 数量 | +|------|------| +| 总计 | ${q.total} | +| 待处理 | ${q.pending} | +| 执行中 | ${q.running} | +| 已完成 | ${q.completed} | +| 失败 | ${q.failed} | + +--- + +## 执行闭环 + +\`\`\` +Notion 广播 → broadcast-listener → task-queue → 执行 + ↓ +execution-sync → notion-sync → Notion 主脑更新 +\`\`\` +`; + + return md; +} + +/** + * 写入状态报告文件 + */ +function writeReport() { + const statusData = collectStatus(); + const md = generateReport(statusData); + const reportPath = path.join(ROOT, 'docs/execution-status.md'); + fs.writeFileSync(reportPath, md, 'utf-8'); + console.log(`📝 执行状态报告已生成: docs/execution-status.md`); + return statusData; +} + +/** + * 同步执行状态到 Notion + */ +async function syncToNotion(statusData) { + let notionSync; + try { + notionSync = require('../../connectors/notion-sync'); + } catch { + console.log('⚠️ connectors/notion-sync 模块未找到，跳过 Notion 同步'); + return; + } + + console.log('📡 同步执行状态到 Notion...'); + await notionSync.pushExecutionLog({ + task_id: `execution-sync-${new Date().toISOString().slice(0, 10)}`, + status: statusData.execution_layer_status, + message: `v${statusData.version} | modules: ${statusData.core_modules.length} | workflows: ${statusData.workflows.count} | queue: ${statusData.task_queue.total}` + }); +} + +// CLI 入口 +if (require.main === module) { + const cmd = process.argv[2] || 'report'; + + switch (cmd) { + case 'report': { + writeReport(); + break; + } + case 'sync': { + const statusData = writeReport(); + syncToNotion(statusData).catch(err => { + console.error(`❌ Notion 同步失败: ${err.message}`); + }); + break; + } + case 'status': { + const s = collectStatus(); + console.log('📊 执行层状态:'); + console.log(` 版本: v${s.version}`); + console.log(` 执行层: ${s.execution_layer_status}`); + console.log(` Notion 桥接: ${s.notion_bridge}`); + console.log(` 执行同步: ${s.execution_sync}`); + console.log(` 核心模块: ${s.core_modules.filter(m => m.status === 'enabled').length}/${s.core_modules.length}`); + console.log(` 连接器: ${s.connectors.filter(c => c.status === 'enabled').length}/${s.connectors.length}`); + console.log(` 工作流: ${s.workflows.count}`); + console.log(` 任务队列: ${s.task_queue.total} 总 / ${s.task_queue.pending} 待处理`); + break; + } + default: + console.log('用法: node core/execution-sync [report|sync|status]'); + } +} + +module.exports = { collectStatus, generateReport, writeReport, syncToNotion }; diff --git a/core/system-check/index.js b/core/system-check/index.js index 926129b6..845d05f2 100644 --- a/core/system-check/index.js +++ b/core/system-check/index.js @@ -28,6 +28,7 @@ const REQUIRED_DIRS = [ 'core/broadcast-listener', 'core/task-queue', 'core/system-check', + 'core/execution-sync', 'connectors/notion-sync', 'connectors/model-router', '.github/workflows', @@ -112,6 +113,7 @@ function checkCoreModules() { { name: 'broadcast-listener', path: 'core/broadcast-listener/index.js' }, { name: 'task-queue', path: 'core/task-queue/index.js' }, { name: 'system-check', path: 'core/system-check/index.js' }, + { name: 'execution-sync', path: 'core/execution-sync/index.js' }, { name: 'notion-sync', path: 'connectors/notion-sync/index.js' }, { name: 'model-router', path: 'connectors/model-router/index.js' } ]; diff --git a/docs/execution-layer-map.md b/docs/execution-layer-map.md new file mode 100644 index 00000000..8b2e463f --- /dev/null +++ b/docs/execution-layer-map.md @@ -0,0 +1,94 @@ +# 执行层结构地图 — execution-layer-map.md + +> 铸渊执行层状态同步系统产物 · TCS-0002∞ +> 生成时间：2026-03-14 + +--- + +## 执行层系统结构 + +``` +零点原核（语言观察层） + ↓ +数字地球主控台（Notion 主脑 / 曜冥） + ↓ +系统广播 + ↓ +仓库执行层（铸渊） + ↓ +自动化执行系统 + ↓ +执行层状态同步 + ↓ +Notion 主脑更新 +``` + +--- + +## 核心执行模块 + +| 模块 | 路径 | 职责 | +|------|------|------| +| 广播监听 | `core/broadcast-listener/index.js` | 监听并解析 Notion 广播为可执行任务 | +| 任务队列 | `core/task-queue/index.js` | 任务入队、调度、优先级管理 | +| 系统自检 | `core/system-check/index.js` | 仓库结构完整性检查 | +| 执行同步 | `core/execution-sync/index.js` | 生成执行状态报告并同步到 Notion | + +--- + +## 自动化模块 + +| 工作流 | 触发方式 | 职责 | +|--------|----------|------| +| `daily-maintenance.yml` | cron `0 2 * * *` | 每日巡检与 system-health 更新 | +| `zhuyuan-daily-selfcheck.yml` | cron `0 0 * * *` | 铸渊每日自检 | +| `execution-sync.yml` | cron `0 3 * * *` | 执行层状态同步到 Notion | +| `notion-heartbeat.yml` | cron `*/5 * * * *` | 工单心跳监控 | +| `brain-sync.yml` | workflow_dispatch | 大脑数据同步 | + +--- + +## Notion 连接模块 + +| 模块 | 路径 | 方向 | 职责 | +|------|------|------|------| +| Notion 同步 | `connectors/notion-sync/index.js` | 双向 | 广播拉取 / 日志写回 / 状态同步 | +| 模型路由 | `connectors/model-router/index.js` | 出站 | 统一模型调用入口 | +| Notion 桥接 | `scripts/notion-bridge.js` | 上行 | SYSLOG 上报 / 变更同步 | +| 信号桥 | `scripts/notion-signal-bridge.js` | 下行 | 工单轮询 / 信号执行 | +| 心跳监控 | `scripts/notion-heartbeat.js` | 双向 | 超时检测 / 自动重试 | + +--- + +## 任务执行模块 + +| 脚本 | 职责 | +|------|------| +| `scripts/process-broadcasts.js` | 处理广播（JSON 规则 + MD 成长日志） | +| `scripts/daily-check.js` | 文件完整性 / HLI 覆盖率 / Schema 验证 | +| `scripts/zhuyuan-daily-selfcheck.js` | 大脑文件验证 / FAQ 去重 / 记忆修剪 | +| `scripts/distribute-broadcasts.js` | 广播分发 | +| `scripts/generate-repo-map.js` | 仓库结构索引生成 | +| `scripts/generate-system-health.js` | 系统健康报告生成 | + +--- + +## 执行闭环 + +``` +Notion 广播（主脑下发） + ↓ +broadcast-listener（广播监听） + ↓ +task-queue（任务排队） + ↓ +执行器运行 + ↓ +execution-sync（状态采集） + ↓ +connectors/notion-sync（状态回写） + ↓ +Notion 主脑更新 + ↓ +生成下一任务 +``` diff --git a/docs/execution-status.md b/docs/execution-status.md new file mode 100644 index 00000000..018c7aa5 --- /dev/null +++ b/docs/execution-status.md @@ -0,0 +1,58 @@ +# 执行层状态报告 — execution-status.md + +> 铸渊执行层自动生成 · TCS-0002∞ +> 更新时间：2026-03-14 14:37:53+08:00 + +--- + +## 系统概览 + +| 指标 | 状态 | +|------|------| +| 系统版本 | v5.0 | +| 执行层状态 | ✅ Stable | +| Notion 桥接 | ✅ Active | +| 执行同步 | ✅ Enabled | +| 工作流数量 | 43 | + +--- + +## 核心模块状态 + +| 模块 | 路径 | 状态 | +|------|------|------| +| broadcast-listener | `core/broadcast-listener/index.js` | ✅ Enabled | +| task-queue | `core/task-queue/index.js` | ✅ Enabled | +| system-check | `core/system-check/index.js` | ✅ Enabled | +| execution-sync | `core/execution-sync/index.js` | ✅ Enabled | + +--- + +## 连接器状态 + +| 连接器 | 路径 | 状态 | +|--------|------|------| +| notion-sync | `connectors/notion-sync/index.js` | ✅ Enabled | +| model-router | `connectors/model-router/index.js` | ✅ Enabled | + +--- + +## 任务队列状态 + +| 指标 | 数量 | +|------|------| +| 总计 | 0 | +| 待处理 | 0 | +| 执行中 | 0 | +| 已完成 | 0 | +| 失败 | 0 | + +--- + +## 执行闭环 + +``` +Notion 广播 → broadcast-listener → task-queue → 执行 + ↓ +execution-sync → notion-sync → Notion 主脑更新 +``` diff --git a/package.json b/package.json index c3d425dc..3e2d5e9b 100644 --- a/package.json +++ b/package.json @@ -34,6 +34,7 @@ "core:listen": "node core/broadcast-listener", "core:queue": "node core/task-queue status", "core:check": "node core/system-check", + "core:sync": "node core/execution-sync report", "connector:notion": "node connectors/notion-sync status", "connector:model": "node connectors/model-router" },