自动化日报生成与微信推送实践

请检查 GitHub 仓库 yuruchuan/agentAssistant，
读取仓库元数据、默认分支和根目录文件，
重点返回当前连接拥有的权限（admin, pull, push 等）。
不要修改任何文件。

请在目标仓库 main 分支创建：
reports/ai-creative/2026/09/2026-09-14-write-test.md
写入一段包含标题与日期的最小测试内容。
创建成功后返回 commit SHA，并立即执行 fetch_file 回读该文件，确认内容真实落地。

{
  "last_successful_run": "2026-09-14T09:00:00+08:00",
  "reported_projects": {
    "worldlabs-marble": {
      "first_reported": "2026-09-14",
      "url": "https://www.worldlabs.ai/"
    }
  }
}

你是一名专业的前沿 AI 科技主编兼系统架构师。
请通过自带的联网检索与工具，搜集全球最新的有创意、有实用价值的 AI 项目，生成结构化中文 Markdown 日报并提交至 GitHub。
排版风格严格遵循古典书卷印刷质感（严谨理性 · 零 Emoji 纯净规范）。

【强制排版纪律】
1. 零 Emoji 纯净准则：全篇严禁出现任何彩色 Emoji 表情符号，依靠文字层级、标点留白与三线表格传递专业美感。
2. 时间规范（仅限北京时间）：检索窗口与所有时间标识**一律只使用北京时间**（如 `> **检索窗口**：YYYY-MM-DD HH:mm ～ YYYY-MM-DD HH:mm（北京时间）`），**严禁出现东京时间（Asia/Tokyo）或其他任何时区**。
3. 标题与 Frontmatter 规范：
   - 主标题（title）：必须简明扼要（8~14 字以内，直击主题，严禁用冒号拼接长从句）；
   - 副标题（subtitle）：承载技术栈明细、背景展开或解决的具体问题；
   - 专栏名称（category）：固定为 "全球 AI 创意项目"；
   - 署名（author）：固定为 "全球 AI 创意项目助手"；
   - 导读摘要（description）：100~200 字精炼导读，概述核心看点与工程启示（此字段直接作为手机端推送卡片导读）。
4. 粗体规范：涉及括号的术语加粗，必须写为 **术语**（别名） 或 <strong>术语（别名）</strong>，防止 CommonMark CJK 渲染异常。
5. 表格规范：必须使用标准响应式三线表格进行多项目横向对比，项目名称必须带有语义超链接，严禁 ASCII 假文本框。
6. 文末收尾纪律（核心规范）：
   - 报告正文以“直接来源汇总”自然优雅收尾；
   - **绝对严禁在 Markdown 文件末尾添加任何“运行状态”、“归档仓库”、“推送通道”、“验证时间”、“提交 SHA”等工程元数据引用块**，保持出版物级别的纯净阅读体验。

【项目剖析维度】
每个收录项目必须包含：
- 项目定性与解决痛点（附官方仓库或官网语义超链接）；
- 核心技术架构或突破点（模型架构、推理加速、技术栈）；
- 商业价值或个人开发者可借鉴启示。

【标准章节结构】
1. 卷首导读：开门见山切入背景与痛点，拒绝“大家好”、“今天带来...”等空话套话。
2. ## 一、今日重点与总览
3. ## 二、按方向分类的详细项目分析（### 1, ### 2...）
4. ## 三、已收录项目的重要变化
5. ## 四、产品体验与工程复现排序及理由
6. ## 五、2—3 个可延伸的小产品构想（分析建议）
7. ## 六、风险、未核实事项和结论
8. ## 七、直接来源汇总（自然收尾，无末尾工程引用块）

【仓库写入指令】
目标仓库：yuruchuan/agentAssistant
目标分支：main
目标路径：reports/ai-creative/YYYY/MM/YYYY-MM-DD.md（使用当前年月日）

【执行流程】
1. 读取 reports/ai-creative/_state.json 进行项目去重。
2. 生成包含标准 Frontmatter 的 Markdown：
   ---
   title: "简明主标题"
   subtitle: "副标题说明"
   category: "全球 AI 创意项目"
   author: "全球 AI 创意项目助手"
   date: "YYYY-MM-DD"
   description: "精炼摘要导读（100~200字）"
   tags: ["标签1", "标签2"]
   timezone: "Asia/Shanghai"
   draft: false
   ---
3. 检查当天文件是否已存在：若不存在则调用 create_file；若已存在则增量合并，严禁覆盖人工修改。
4. 提交后必须重新读取该文件，验证 Commit SHA 与内容完整性。
5. 成功后同步更新 _state.json。
6. 严格限制只允许修改 reports/ai-creative/ 目录，禁止改动系统其他文件。

[60020]: not allow to access from your ip, from ip: 20.246.x.x

ERR_CONNECTION_RESET / 链接已重置

Content-Disposition: attachment; filename=response.txt

上传图文封面素材失败 [44001]: empty media data, from ip: 1.1xx.49.8

// 手动拼接精确的 Multipart 二进制 Buffer
const pngBuffer = Buffer.from(BANNER_BASE64, 'base64');
const boundary = '----WeComBoundary' + crypto.randomBytes(8).toString('hex');
const header = Buffer.from(
  `--${boundary}\r\nContent-Disposition: form-data; name="media"; filename="banner.png"\r\nContent-Type: image/png\r\n\r\n`
);
const footer = Buffer.from(`\r\n--${boundary}--\r\n`);
const bodyBuffer = Buffer.concat([header, pngBuffer, footer]);

const uploadRes = await fetch(
  `https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token=${accessToken}&type=image`,
  {
    method: 'POST',
    headers: {
      'Content-Type': `multipart/form-data; boundary=${boundary}`,
      'Content-Length': String(bodyBuffer.length) // 显式提供精准字节数，根治 44001
    },
    body: bodyBuffer
  }
);

const crypto = require('crypto');
const https = require('https');
const url = require('url');

// 企业微信配置凭据（可在此内置或通过云函数环境变量注入）
const WECHAT_TOKEN = '29pm4';
const WECHAT_AES_KEY = '87B9xcydPGvOz03kjEmuD4QwYxL3LRRnY4uTO8MLHJt';

// 微信图文卡片备用封面图（精美深蓝渐变 300x160 PNG，约 760 字节，无需依赖外部图床）
const BANNER_BASE64 = 'iVBORw0KGgoAAAANSUhEUgAAASwAAACgCAIAAAA5GsY1AAACwklEQVR4nO3TVRaVBQCF0TMSpVEkVBoV7l+X1qGqtEFZtEVYtDoPh3Ee3GvtAXwvX95YfQoUpV4A/3N5c/UZUGRCKDMhlGXD6nOgyIRQZkIoy4bVOaAoG1fngCITQlk2rs4DRdm0Og8UmRDKsmm4ABRl83ABKDIhlGXzcBEoypbhIlBkQijLluESUGRCKMvW4RJQlK3DZaDIhFCWbcNloCjbhitAkQmhLNuHK0BRtg9fAEUmhDITQlneGr4EikwIZSaEsrw9fAUUmRDKTAhl2TF8DRSZEMqyY7wKFOWd8SpQZEIoyzvjNaDIhFCWneM1oCg7x+tAkQmhLLvG60BRdo03gCITQll2jzeAouwebwJFJoSy7BlvAkXZM34DFJkQykwIZXl3/BYoMiGUmRDK8t74HVBkQigzIZTl/fF7oMiEUGZCKMve6QegyIRQZkIoy97pFlCUfdMtoMiEUJZ9022gKPun20CRCaEs+6c7QFEOTHeAIhNCWQ5Md4GiHJzuAkUmhLIcnO4BRSaEshya7gFFOTTdB4pMCGU5PN0HinJ4egAUmRDKcmR6ABTlyPQjUGRCKDMhlOWD+SegyIRQZkIoy4fzz0CRCaHMhFCWj+ZfgCITQpkJoSxH51+BIhNCmQmhLEfnh0BRjs0PgSITQlmOzY+AoqzmR0CRCaEsq/kxUJRhfgwUmRDKMsxPgKKM8xOgyIRQlnH+DSgyIZRlWn4HikwIZSaEsszLH0CRCaHMhFCWZfkTKDIhlJkQyrJe/gKKTAhlJoSyrJenQFGOL0+BIhNCWY4vz4CinFieAUUmhLKcWJ4DRTm5PAeKTAhlObm8AIpMCGU5tbwAinJqeQkUmRDKcnp5CRTl9PoVUGRCKMuZ9SugKGfWr4EiE0JZzq5fA0U5u/4bKDIhlJkQyvLx+h+gyIRQZkIoyyfrf4Gi/wAJbMElOAnL1wAAAABJRU5ErkJggg==';

let cachedToken = null;
let tokenExpiresAt = 0;
let cachedMediaId = null;
let mediaExpiresAt = 0;

/**
 * 原生 HTTPS 请求封装（彻底摆脱不同 Node.js 版本全局 fetch 差异）
 */
function request(targetUrl, options = {}, bodyBuffer = null) {
  return new Promise((resolve, reject) => {
    const parsed = url.parse(targetUrl);
    const reqOptions = {
      hostname: parsed.hostname,
      port: parsed.port || 443,
      path: parsed.path,
      method: options.method || 'GET',
      headers: options.headers || {}
    };

    const req = https.request(reqOptions, (res) => {
      const chunks = [];
      res.on('data', (chunk) => chunks.push(chunk));
      res.on('end', () => {
        const resBody = Buffer.concat(chunks).toString('utf8');
        try {
          const json = JSON.parse(resBody);
          resolve(json);
        } catch {
          resolve(resBody);
        }
      });
    });

    req.on('error', (err) => reject(err));
    req.setTimeout(options.timeout || 15000, () => {
      req.destroy(new Error(`HTTPS 请求超时: ${targetUrl}`));
    });

    if (bodyBuffer) {
      req.write(bodyBuffer);
    }
    req.end();
  });
}

function sha1(str) {
  return crypto.createHash('sha1').update(str).digest('hex');
}

function verifySignature(token, timestamp, nonce, echostr, signature) {
  const sorted = [token, timestamp, nonce, echostr].sort().join('');
  return sha1(sorted) === signature;
}

function decryptEcho(echostr, encodingAESKey) {
  const aesKey = Buffer.from(encodingAESKey + '=', 'base64');
  const iv = aesKey.subarray(0, 16);
  const decipher = crypto.createDecipheriv('aes-256-cbc', aesKey, iv);
  decipher.setAutoPadding(false);
  const decrypted = Buffer.concat([decipher.update(Buffer.from(echostr, 'base64')), decipher.final()]);
  const pad = decrypted[decrypted.length - 1];
  const unpadded = decrypted.subarray(0, decrypted.length - pad);
  const msgLen = unpadded.readUInt32BE(16);
  return unpadded.subarray(20, 20 + msgLen).toString('utf8');
}

async function getAccessToken(corpId, corpSecret) {
  const now = Date.now();
  if (cachedToken && now < tokenExpiresAt - 300 * 1000) {
    return cachedToken;
  }
  const tokenUrl = `https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=${encodeURIComponent(corpId)}&corpsecret=${encodeURIComponent(corpSecret)}`;
  const data = await request(tokenUrl, { method: 'GET' });
  if (!data || data.errcode !== 0) {
    throw new Error(`获取企业微信 access_token 失败 [${data?.errcode}]: ${data?.errmsg}`);
  }
  cachedToken = data.access_token;
  tokenExpiresAt = now + data.expires_in * 1000;
  return cachedToken;
}

async function uploadMediaBuffer(accessToken, buffer, filename = 'banner.png') {
  const boundary = '----WeComBoundary' + crypto.randomBytes(8).toString('hex');
  const header = Buffer.from(
    `--${boundary}\r\nContent-Disposition: form-data; name="media"; filename="${filename}"\r\nContent-Type: image/png\r\n\r\n`
  );
  const footer = Buffer.from(`\r\n--${boundary}--\r\n`);
  const bodyBuffer = Buffer.concat([header, buffer, footer]);

  const uploadUrl = `https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token=${encodeURIComponent(accessToken)}&type=image`;
  const uploadData = await request(uploadUrl, {
    method: 'POST',
    headers: {
      'Content-Type': `multipart/form-data; boundary=${boundary}`,
      'Content-Length': String(bodyBuffer.length) // 显式精准字节头，彻底避免微信 44001
    }
  }, bodyBuffer);

  if (!uploadData || uploadData.errcode !== 0 || !uploadData.media_id) {
    throw new Error(`上传图文封面素材失败 [${uploadData?.errcode}]: ${uploadData?.errmsg}`);
  }
  return uploadData.media_id;
}

async function getThumbMediaId(accessToken, customBase64 = null) {
  // 若上游传入了动态生成的文章封面图，则优先上传动态图
  if (customBase64) {
    try {
      const customBuffer = Buffer.from(customBase64, 'base64');
      const mediaId = await uploadMediaBuffer(accessToken, customBuffer, 'custom_banner.png');
      return mediaId;
    } catch (err) {
      console.warn('动态封面上传失败，自动平滑回退为默认封面:', err.message);
    }
  }

  // 否则使用本地缓存的默认封面素材
  const now = Date.now();
  if (cachedMediaId && now < mediaExpiresAt) {
    return cachedMediaId;
  }
  const fallbackBuffer = Buffer.from(BANNER_BASE64, 'base64');
  cachedMediaId = await uploadMediaBuffer(accessToken, fallbackBuffer, 'default_banner.png');
  mediaExpiresAt = now + 60 * 3600 * 1000; // 缓存 60 小时
  return cachedMediaId;
}

exports.main_handler = async (event, context) => {
  const method = ((event && event.httpMethod) || 'GET').toUpperCase();

  // 1. GET 请求：用于企业微信自建应用后台接收消息服务器 URL 验证握手 / 探活
  if (method === 'GET') {
    const query = (event && event.queryString) || {};
    const { msg_signature, timestamp, nonce, echostr } = query;
    if (echostr && verifySignature(WECHAT_TOKEN, timestamp, nonce, echostr, msg_signature)) {
      try {
        const reply = decryptEcho(echostr, WECHAT_AES_KEY);
        return {
          statusCode: 200,
          headers: { 'Content-Type': 'text/plain' },
          body: reply
        };
      } catch (err) {
        return { statusCode: 500, body: 'Decrypt failed: ' + err.message };
      }
    }
    return {
      statusCode: 200,
      headers: { 'Content-Type': 'text/plain; charset=utf-8' },
      body: 'WeCom Proxy Active (CommonJS Universal Version)'
    };
  }

  // 2. POST 请求：GitHub Actions 代理转发，携带固定 IP 推送企业微信
  let body = {};
  if (event && event.body) {
    try {
      if (typeof event.body === 'object') {
        body = event.body;
      } else {
        const raw = event.isBase64Encoded ? Buffer.from(event.body, 'base64').toString('utf8') : event.body;
        body = JSON.parse(raw);
      }
    } catch (e) {
      console.error('Failed to parse event.body:', e);
    }
  }

  const corpId = body.corpId || process.env.WECHAT_CORP_ID;
  const corpSecret = body.corpSecret || process.env.WECHAT_CORP_SECRET;
  const agentId = body.agentId || process.env.WECHAT_AGENT_ID;

  if (!corpId || !corpSecret || !agentId) {
    return {
      statusCode: 400,
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ errcode: 400, errmsg: 'Missing corpId, corpSecret or agentId' })
    };
  }

  const {
    title = '任务报告已就绪',
    content = '',
    digest = '',
    toUser = '@all',
    msgtype = 'mpnews',
    bannerBase64 = null
  } = body;

  try {
    const accessToken = await getAccessToken(corpId, corpSecret);
    let pushPayload;

    if (msgtype === 'text') {
      pushPayload = {
        touser: toUser,
        msgtype: 'text',
        agentid: parseInt(agentId, 10),
        text: { content: (content || '').slice(0, 2040) }
      };
    } else if (msgtype === 'textcard' || body.description) {
      pushPayload = {
        touser: toUser,
        msgtype: 'textcard',
        agentid: parseInt(agentId, 10),
        textcard: {
          title: (title || '').slice(0, 120),
          description: (body.description || '').slice(0, 480),
          url: body.url || '',
          btntxt: body.btnText || '详情'
        }
      };
    } else {
      // 方案 A：微信官方原生图文 (mpnews)，点击直接在微信官方原生阅读器中全屏优雅展示
      const mediaId = await getThumbMediaId(accessToken, bannerBase64);
      pushPayload = {
        touser: toUser,
        msgtype: 'mpnews',
        agentid: parseInt(agentId, 10),
        mpnews: {
          articles: [
            {
              title: title.slice(0, 120),
              thumb_media_id: mediaId,
              author: 'Codex 报告助手',
              content: content,
              digest: (digest || '').slice(0, 120)
            }
          ]
        }
      };
    }

    const sendUrl = `https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=${encodeURIComponent(accessToken)}`;
    const pushBody = Buffer.from(JSON.stringify(pushPayload), 'utf8');
    const pushData = await request(sendUrl, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json; charset=utf-8',
        'Content-Length': String(pushBody.length)
      }
    }, pushBody);

    return {
      statusCode: 200,
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(pushData)
    };
  } catch (err) {
    return {
      statusCode: 500,
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ errcode: 500, errmsg: err.message, error: err.message })
    };
  }
};

---

### 5.2 动态封面图排版生成器（`scripts/lib/banner-generator.mjs`）

在 GitHub Actions 中执行，基于纯代码动态生成古典书卷质感的 900x383 矢量卡片，并使用 Rust 原生引擎 `@resvg/resvg-js` 毫秒级栅格化为 PNG：

```javascript
import { Resvg } from '@resvg/resvg-js';

function escapeXml(unsafe) {
  if (!unsafe) return '';
  return String(unsafe)
    .replace(/&/g, '&amp;')
    .replace(/</g, '&lt;')
    .replace(/>/g, '&gt;')
    .replace(/"/g, '&quot;')
    .replace(/'/g, '&apos;');
}

function getCharWidth(char) {
  const code = char.charCodeAt(0);
  if ((code >= 0x4e00 && code <= 0x9fa5) || (code >= 0xff00 && code <= 0xffef) || code > 0x2000) {
    return 1.0;
  }
  return 0.55;
}

function wrapText(text, maxUnitsPerLine, maxLines = 2) {
  if (!text) return [];
  const lines = [];
  let currentLine = '';
  let currentUnits = 0;

  for (const char of text) {
    const w = getCharWidth(char);
    if (currentUnits + w > maxUnitsPerLine) {
      if (lines.length + 1 === maxLines) {
        if (currentLine.length > 2) currentLine = currentLine.slice(0, -1) + '...';
        lines.push(currentLine);
        return lines;
      }
      lines.push(currentLine);
      currentLine = char;
      currentUnits = w;
    } else {
      currentLine += char;
      currentUnits += w;
    }
  }
  if (currentLine) lines.push(currentLine);
  return lines.slice(0, maxLines);
}

export function generateBannerSvg({ title = 'Codex 任务报告', subtitle = '', category = '全球 AI 创意项目', date = '', tags = [] } = {}) {
  const titleLines = wrapText(title, 19, 2);
  const subtitleLines = wrapText(subtitle, 38, 1);
  const safeSubtitle = subtitleLines[0] || '';
  const tagList = Array.isArray(tags) ? tags : [];
  const tagText = tagList.slice(0, 4).map(t => `#${t}`).join('    ');

  const isMultiLine = titleLines.length > 1;
  const titleStartY = isMultiLine ? 148 : 172;
  const subtitleY = isMultiLine ? 254 : 228;

  const titleSvg = titleLines.map((line, idx) => {
    const y = titleStartY + idx * 46;
    return `<text x="56" y="${y}" font-family="-apple-system, BlinkMacSystemFont, 'Segoe UI', 'PingFang SC', sans-serif" font-size="34" font-weight="700" fill="#f5f3ee">${escapeXml(line)}</text>`;
  }).join('\n');

  return `
<svg width="900" height="383" viewBox="0 0 900 383" xmlns="http://www.w3.org/2000/svg">
  <defs>
    <linearGradient id="bgGradient" x1="0%" y1="0%" x2="100%" y2="100%">
      <stop offset="0%" stop-color="#232220"/>
      <stop offset="50%" stop-color="#181716"/>
      <stop offset="100%" stop-color="#121110"/>
    </linearGradient>
    <linearGradient id="goldGlow" x1="0%" y1="0%" x2="100%" y2="0%">
      <stop offset="0%" stop-color="#c99f68" stop-opacity="0.9"/>
      <stop offset="60%" stop-color="#a37e4c" stop-opacity="0.4"/>
      <stop offset="100%" stop-color="#8a6d45" stop-opacity="0.0"/>
    </linearGradient>
  </defs>

  <rect width="900" height="383" fill="url(#bgGradient)"/>
  <rect x="24" y="24" width="852" height="335" rx="6" fill="none" stroke="#ffffff" stroke-width="1" stroke-opacity="0.07"/>
  <rect x="28" y="28" width="844" height="327" rx="4" fill="none" stroke="#ffffff" stroke-width="0.5" stroke-opacity="0.03"/>

  <g transform="translate(56, 62)">
    <circle cx="5" cy="11" r="3.5" fill="#c99f68"/>
    <text x="18" y="15" font-family="-apple-system, BlinkMacSystemFont, sans-serif" font-size="13" font-weight="600" fill="#a8a49c" letter-spacing="1.5">
      ${escapeXml(category.toUpperCase())}${date ? '  ·  ' + escapeXml(date) : ''}
    </text>
  </g>

  <rect x="56" y="96" width="788" height="1.5" fill="url(#goldGlow)"/>
  ${titleSvg}
  ${safeSubtitle ? `<text x="56" y="${subtitleY}" font-family="-apple-system, BlinkMacSystemFont, sans-serif" font-size="17" fill="#9e9b94">${escapeXml(safeSubtitle)}</text>` : ''}

  <g transform="translate(56, 310)">
    ${tagText ? `<text x="0" y="14" font-family="-apple-system, BlinkMacSystemFont, sans-serif" font-size="13" fill="#c99f68">${escapeXml(tagText)}</text>` : ''}
    <text x="788" y="14" text-anchor="end" font-family="Consolas, monospace" font-size="11" fill="#5a5751">
      CODEX REPORT ENGINE · VERIFIED
    </text>
  </g>
</svg>
  `.trim();
}

export async function renderBannerPng(options = {}) {
  const svg = generateBannerSvg(options);
  const resvg = new Resvg(svg, { fitTo: { mode: 'width', value: 900 } });
  const pngData = resvg.render();
  return pngData.asPng();
}

import fs from 'node:fs';
import path from 'node:path';
import { execSync } from 'node:child_process';
import { renderBannerPng } from './lib/banner-generator.mjs';

function getChangedReportFiles() {
  try {
    const diffOutput = execSync('git diff --name-only HEAD~1 HEAD', { credentials: 'omit' })
      .toString()
      .trim();
    if (!diffOutput) return [];
    return diffOutput
      .split('\n')
      .map(file => file.trim().replace(/\\/g, '/'))
      .filter(file => file.startsWith('reports/') && file.endsWith('.md'));
  } catch (err) {
    console.warn('回退为扫描最新文件:', err.message);
    const dir = 'reports/ai-creative';
    if (!fs.existsSync(dir)) return [];
    const files = fs.readdirSync(dir).filter(f => f.endsWith('.md'));
    return files.map(f => `${dir}/${f}`);
  }
}

function formatMarkdownForCard(rawContent, maxLength = 120) {
  if (!rawContent) return '';
  let text = rawContent.replace(/^\uFEFF/, '').trim();
  text = text.replace(/^---[\r\n]+[\s\S]*?[\r\n]+---\s*/, '');
  text = text.replace(/^#\s+[^\n\r]+[\n\r]*/m, '');
  text = text.replace(/\n---[\s\S]*$/, '');
  text = text.replace(/^>\s*(运行状态|归档仓库|推送通道|生成时间|验证时间)[^\n\r]*[\n\r]*/gim, '');
  text = text.replace(/\[\u{1F449}?\s*(?:点击)?查看[^\]]*\]\([^)]+\)/gu, '');
  text = text.replace(/\[([^\]]+)\]\([^)]+\)/g, '$1');
  text = text.replace(/\$\\to\$/g, '→');
  text = text.replace(/->/g, '→');
  text = text.replace(/[\u{1F300}-\u{1FAFF}\u{2600}-\u{27BF}]/gu, '');
  text = text.replace(/^#{2,4}\s*(.+)$/gm, '\n$1');
  text = text.replace(/^[ \t]*[-*+][ \t]+/gm, '• ');
  text = text.replace(/\*\*([^*]+)\*\*/g, '$1');
  text = text.replace(/\*([^*]+)\*/g, '$1');
  text = text.replace(/_([^_]+)_/g, '$1');
  text = text.replace(/`([^`]+)`/g, '$1');
  text = text.replace(/^>[ \t]*/gm, '');
  text = text.replace(/[\r\n]{2,}/g, ' ').trim();
  if (text.length > maxLength) {
    text = text.slice(0, maxLength) + '...';
  }
  return text;
}

function markdownToWechatArticleHtml(rawContent, {
  title = '',
  subtitle = '',
  description = '',
  category = '',
  tags = [],
  statusBadge = 'SUCCESS',
  dateStr = ''
} = {}) {
  let md = rawContent.replace(/^\uFEFF/, '').trim();
  md = md.replace(/^---[\r\n]+[\s\S]*?[\r\n]+---\s*/, '');
  md = md.replace(/^#\s+[^\n\r]+[\n\r]*/m, '');
  md = md.replace(/\n---[\s\S]*$/, '');
  md = md.replace(/^>\s*(运行状态|归档仓库|推送通道|生成时间|验证时间)[^\n\r]*[\n\r]*/gim, '');
  md = md.replace(/[\u{1F300}-\u{1FAFF}\u{2600}-\u{27BF}]/gu, '');

  const codeBlocks = [];
  md = md.replace(/```([\w-]*)\r?\n([\s\S]*?)```/g, (match, lang, code) => {
    const escaped = code.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;');
    const idx = codeBlocks.length;
    codeBlocks.push(
      `<pre style="background-color: #1a1918; color: #dcdad5; padding: 12px 14px; border-radius: 6px; font-family: Consolas, Monaco, monospace; font-size: 12.5px; line-height: 1.55; overflow-x: auto; margin: 16px 0; word-break: break-all; white-space: pre-wrap; border: 1px solid #2d2b29;"><code>${escaped}</code></pre>`
    );
    return `<!--CODE_BLOCK_${idx}-->`;
  });

  function inlineFormat(str) {
    let res = str;
    res = res.replace(/!\[([^\]]*)\]\(([^)]+)\)/g, '<img src="$2" alt="$1" style="max-width: 100%; border-radius: 6px; margin: 12px 0;" />');
    res = res.replace(/\[([^\]]+)\]\(([^)]+)\)/g, '<a href="$2" style="color: #2b5797; text-decoration: underline;">$1</a>');
    res = res.replace(/\*\*([^*]+)\*\*/g, '<strong style="color: #141312; font-weight: 600;">$1</strong>');
    res = res.replace(/\*([^*]+)\*/g, '<em style="color: #4a4742;">$1</em>');
    res = res.replace(/`([^`]+)`/g, '<code style="background-color: #f2f0ea; color: #8a3b34; padding: 2px 5px; border-radius: 3px; font-size: 13px; font-family: Consolas, monospace;">$1</code>');
    res = res.replace(/\$\\to\$/g, '→');
    res = res.replace(/->/g, '→');
    return res;
  }

  const lines = md.split(/\r?\n/);
  const htmlParts = [];
  let listType = null;
  let inQuote = false;
  let quoteLines = [];
  let inTable = false;
  let tableRows = [];

  const flushQuote = () => {
    if (inQuote && quoteLines.length > 0) {
      const qText = quoteLines.join('<br>');
      htmlParts.push(`<blockquote style="margin: 16px 0; padding: 12px 16px; background: #f7f6f2; border-left: 3px solid #a8a49c; color: #5a5751; font-size: 14px; line-height: 1.7; border-radius: 0 4px 4px 0;">${qText}</blockquote>`);
      quoteLines = [];
      inQuote = false;
    }
  };

  const flushList = () => {
    if (listType === 'ul') { htmlParts.push(`</ul>`); listType = null; }
    else if (listType === 'ol') { htmlParts.push(`</ol>`); listType = null; }
  };

  const flushTable = () => {
    if (inTable && tableRows.length > 0) {
      let headerCells = [];
      let bodyRows = [];
      let separatorFound = false;

      for (let r = 0; r < tableRows.length; r++) {
        const rowStr = tableRows[r].trim();
        const cells = rowStr.replace(/^\|/, '').replace(/\|$/, '').split('|').map(c => c.trim());
        if (r === 0) {
          headerCells = cells;
        } else if (!separatorFound && cells.every(c => /^:?-+:?$/.test(c))) {
          separatorFound = true;
        } else {
          bodyRows.push(cells);
        }
      }

      if (headerCells.length > 0) {
        let tHtml = `<div style="overflow-x: auto; margin: 18px 0;"><table style="width: 100%; border-collapse: collapse; font-size: 13.5px; line-height: 1.6; border-top: 2px solid #2c2a29; border-bottom: 2px solid #2c2a29;">`;
        tHtml += `<thead><tr style="background-color: #f7f6f2; border-bottom: 1px solid #d0ceca;">`;
        for (const hc of headerCells) {
          tHtml += `<th style="padding: 8px 10px; text-align: left; font-weight: 600; color: #2c2a29;">${inlineFormat(hc)}</th>`;
        }
        tHtml += `</tr></thead><tbody>`;
        for (const br of bodyRows) {
          tHtml += `<tr style="border-bottom: 1px solid #e5e4e0;">`;
          for (let c = 0; c < headerCells.length; c++) {
            const val = br[c] || '';
            tHtml += `<td style="padding: 8px 10px; color: #333333;">${inlineFormat(val)}</td>`;
          }
          tHtml += `</tr>`;
        }
        tHtml += `</tbody></table></div>`;
        htmlParts.push(tHtml);
      }
      tableRows = [];
      inTable = false;
    }
  };

  for (let i = 0; i < lines.length; i++) {
    let line = lines[i].trimEnd();
    if (line.includes('<!--CODE_BLOCK_')) { flushQuote(); flushList(); flushTable(); htmlParts.push(line); continue; }
    if (/^\s*\|.*\|\s*$/.test(line)) { flushQuote(); flushList(); inTable = true; tableRows.push(line); continue; } else { flushTable(); }
    if (line.startsWith('>')) { flushList(); inQuote = true; quoteLines.push(inlineFormat(line.replace(/^>[ \t]*/, ''))); continue; } else { flushQuote(); }
    if (/^(\*{3,}|-{3,}|_{3,})$/.test(line.trim())) { flushList(); htmlParts.push(`<hr style="border: none; border-top: 1px solid #e2e0db; margin: 24px 0;" />`); continue; }
    const hMatch = line.match(/^(#{2,4})\s+(.+)$/);
    if (hMatch) {
      flushList();
      const level = hMatch[1].length;
      const hText = inlineFormat(hMatch[2].trim());
      if (level === 2) {
        htmlParts.push(`<h2 style="font-size: 17px; font-weight: 700; color: #1f1e1d; margin: 28px 0 14px; padding-bottom: 6px; border-bottom: 1px solid #e5e3dd; letter-spacing: 0.3px;">${hText}</h2>`);
      } else {
        htmlParts.push(`<h3 style="font-size: 15px; font-weight: 600; color: #2c2a29; margin: 22px 0 10px; border-left: 3px solid #6b6760; padding-left: 9px; line-height: 1.4;">${hText}</h3>`);
      }
      continue;
    }
    const olMatch = line.match(/^(\s*)\d+\.\s+(.+)$/);
    if (olMatch) {
      if (listType !== 'ol') { flushList(); htmlParts.push(`<ol style="margin: 12px 0; padding-left: 22px; line-height: 1.8; font-size: 14.5px;">`); listType = 'ol'; }
      htmlParts.push(`<li style="margin: 6px 0;">${inlineFormat(olMatch[2].trim())}</li>`);
      continue;
    }
    const ulMatch = line.match(/^(\s*)[-*+]\s+(.+)$/);
    if (ulMatch) {
      if (listType !== 'ul') { flushList(); htmlParts.push(`<ul style="margin: 12px 0; padding-left: 20px; line-height: 1.8; font-size: 14.5px;">`); listType = 'ul'; }
      htmlParts.push(`<li style="margin: 6px 0;">${inlineFormat(ulMatch[2].trim())}</li>`);
      continue;
    }
    flushList();
    if (!line.trim()) continue;
    // 普通段落：不设硬编码偏色，深浅模式完全自适应（白底黑字、黑底白字）
    htmlParts.push(`<p style="font-size: 15px; line-height: 1.8; margin: 14px 0; word-break: break-word; text-align: justify;">${inlineFormat(line.trim())}</p>`);
  }

  flushQuote();
  flushList();
  flushTable();

  let bodyHtml = htmlParts.join('\n');
  for (let idx = 0; idx < codeBlocks.length; idx++) {
    bodyHtml = bodyHtml.replace(`<!--CODE_BLOCK_${idx}-->`, codeBlocks[idx]);
  }

  const tagHtml = tags.map(t => `<span style="display: inline-block; background-color: rgba(128, 128, 128, 0.1); opacity: 0.8; font-size: 11.5px; padding: 2px 8px; border-radius: 3px; margin-right: 6px; margin-bottom: 6px;"># ${t}</span>`).join('');

  return `
<div style="font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, 'Helvetica Neue', Arial, sans-serif; max-width: 100%; line-height: 1.8;">
  <style>
    :root { color-scheme: light dark; }
    @media (prefers-color-scheme: dark) {
      body { background-color: #111111 !important; color: rgba(255, 255, 255, 0.88) !important; }
    }
  </style>

  <div style="background-color: rgba(128, 128, 128, 0.06); border: 1px solid rgba(128, 128, 128, 0.18); border-radius: 8px; padding: 18px 20px; margin-bottom: 22px;">
    <div style="font-size: 12px; opacity: 0.65; margin-bottom: 8px; display: flex; justify-content: space-between; align-items: center; letter-spacing: 0.5px;">
      <span>${category || '技术报告'} · ${dateStr}</span>
      <span style="font-family: monospace; font-size: 11px; background-color: rgba(128, 128, 128, 0.12); padding: 2px 6px; border-radius: 3px;">${statusBadge}</span>
    </div>
    <div style="font-size: 20px; font-weight: 700; line-height: 1.4; letter-spacing: 0.2px;">${title}</div>
    ${subtitle ? `<div style="font-size: 13.5px; opacity: 0.75; font-style: italic; margin-top: 6px; line-height: 1.5;">${subtitle}</div>` : ''}
    ${description ? `<div style="margin-top: 12px; padding-top: 10px; border-top: 1px dashed rgba(128, 128, 128, 0.22); font-size: 13.5px; opacity: 0.85; line-height: 1.7;">${description}</div>` : ''}
  </div>

  ${tagHtml ? `<div style="margin-bottom: 14px;">${tagHtml}</div>` : ''}

  <div style="font-size: 15px; line-height: 1.8;">
    ${bodyHtml}
  </div>

  <div style="margin-top: 36px; padding: 14px 16px; background-color: rgba(128, 128, 128, 0.05); border-radius: 6px; border: 1px solid rgba(128, 128, 128, 0.15); font-size: 12px; opacity: 0.65; line-height: 1.8;">
    <div>归档状态：已存证于 GitOps 仓库（yuruchuan/agentAssistant）</div>
    <div>分发渠道：企业微信微工作台（原生图文引擎）</div>
    <div>排版标准：依据《个人网站文章撰写与排版风格指南》古典书卷规范（深浅模式自适应）</div>
  </div>
</div>
`.trim();
}

function parseReportContent(content, filePath = '') {
  let title = 'Codex 任务报告已就绪';
  const fmTitleMatch = content.match(/^title:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmTitleMatch) title = fmTitleMatch[1].trim();

  let subtitle = '';
  const fmSubMatch = content.match(/^subtitle:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmSubMatch) subtitle = fmSubMatch[1].trim();

  let description = '';
  const fmDescMatch = content.match(/^description:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmDescMatch) description = fmDescMatch[1].trim();

  let tags = [];
  const fmTagsMatch = content.match(/^tags:\s*\[(.*?)\]/m);
  if (fmTagsMatch) {
    tags = fmTagsMatch[1].split(',').map(t => t.replace(/["'\s]/g, '').trim()).filter(Boolean);
  }

  let category = '';
  const fmCatMatch = content.match(/^category:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmCatMatch) {
    category = fmCatMatch[1].trim();
  } else if (filePath.includes('reports/ai-creative/')) {
    category = '全球 AI 创意项目';
  } else {
    const parts = filePath.split('/');
    if (parts.length > 2 && parts[1] !== 'template.md') category = parts[1];
  }

  let author = '';
  const fmAuthorMatch = content.match(/^author:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmAuthorMatch) author = fmAuthorMatch[1].trim();

  let toUser = '@all';
  const fmToUserMatch = content.match(/^toUser:\s*["']?([^"'\n\r]+)["']?/m);
  if (fmToUserMatch) toUser = fmToUserMatch[1].trim();

  let statusBadge = 'SUCCESS';
  if (/FAIL|ERROR|失败|报错|异常/i.test(content)) statusBadge = 'FAILED';
  else if (/WARN|警告|注意|阻塞/i.test(content)) statusBadge = 'WARNING';

  const formattedCardContent = formatMarkdownForCard(content, 1600);
  return { title, subtitle, description, category, author, toUser, tags, statusBadge, formattedCardContent };
}

async function main() {
  const proxyUrl = process.env.WECHAT_PROXY_URL;
  const corpId = process.env.WECHAT_CORP_ID;
  const corpSecret = process.env.WECHAT_CORP_SECRET;
  const agentId = process.env.WECHAT_AGENT_ID;

  if (!proxyUrl || !corpId || !corpSecret || !agentId) {
    console.error('环境变量缺失，请检查 Actions Secrets 配置。');
    process.exit(1);
  }

  const changedFiles = getChangedReportFiles();
  if (changedFiles.length === 0) {
    console.log('无报告变更，结束任务。');
    return;
  }

  const dateStr = new Date().toLocaleString('zh-CN', { timeZone: 'Asia/Shanghai' });

  for (const file of changedFiles) {
    if (!fs.existsSync(file)) continue;
    const content = fs.readFileSync(file, 'utf-8');

    const { title, subtitle, description, category, author, toUser, tags, statusBadge } = parseReportContent(content, file);
    const html = markdownToWechatArticleHtml(content, { title, subtitle, description, category, author, tags, statusBadge, dateStr });
    const digest = description || formatMarkdownForCard(content, 120);

    // 动态生成高清封面图
    let bannerBase64 = null;
    try {
      const pngBuffer = await renderBannerPng({
        title,
        subtitle,
        category: category || '任务报告',
        date: dateStr.split(' ')[0],
        tags
      });
      bannerBase64 = pngBuffer.toString('base64');
    } catch (e) {
      console.warn('动态封面生成失败，将使用默认封面:', e.message);
    }

    console.log(`正在向微信推送原生图文: ${title}`);
    const res = await fetch(proxyUrl, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ corpId, corpSecret, agentId, title, digest, content: html, toUser, bannerBase64 })
    });
    const result = await res.json();
    console.log('推送完成，响应结果:', result);
  }
}

main().catch(err => {
  console.error('执行失败:', err);
  process.exit(1);
});

name: Notify Codex Report to WeChat

on:
  push:
    paths:
      - 'reports/**'
      - 'reports/**/*.md'
      - 'reports/**.md'
    branches:
      - main
  workflow_dispatch:

permissions:
  contents: read

jobs:
  notify:
    runs-on: ubuntu-latest
    steps:
      - name: Checkout Code with Commit Depth
        uses: actions/checkout@v4
        with:
          fetch-depth: 2

      - name: Setup Node.js Runtime
        uses: actions/setup-node@v4
        with:
          node-version: "22"

      - name: Install CJK Fonts
        run: |
          sudo apt-get update -qq
          sudo apt-get install -y --no-install-recommends fonts-wqy-microhei

      - name: Install Dependencies
        run: npm install

      - name: Run Report Dispatcher
        env:
          WECHAT_CORP_ID: ${{ secrets.WECHAT_CORP_ID }}
          WECHAT_CORP_SECRET: ${{ secrets.WECHAT_CORP_SECRET }}
          WECHAT_AGENT_ID: ${{ secrets.WECHAT_AGENT_ID }}
          WECHAT_PROXY_URL: ${{ secrets.WECHAT_PROXY_URL }}
        run: |
          node scripts/notify-report.mjs

{
  "name": "codex-wechat-notifier",
  "version": "1.0.0",
  "private": true,
  "type": "module",
  "scripts": {
    "test:push": "node scripts/notify-report.mjs"
  },
  "engines": {
    "node": ">=20.0.0"
  },
  "dependencies": {
    "@resvg/resvg-js": "^2.6.2"
  }
}

reports/<专栏英文名>/YYYY/MM/YYYY-MM-DD.md

你是一名国家级气象分析专家与防灾减灾应急研判助手。
请通过联网检索各权威气象中心、应急管理部门及卫星遥感数据，分析最新极端天气与气象过程，生成专业 Markdown 分析报告并归档至 GitHub。

【强制排版纪律】
1. 零 Emoji：全篇严禁彩色 Emoji，依靠排版留白与三线表格展现古典理性美感。
2. 仅限北京时间：检索窗口与所有时间标识一律只使用北京时间（Asia/Shanghai / UTC+8）。
3. 卷首 Frontmatter 必须规范：
   ---
   title: "气象与灾害预警简报｜YYYY-MM-DD"
   subtitle: "极端天气过程机理、演变路径与防御指引（30~50字）"
   category: "气象与灾害预警"
   author: "气象感知智能体"
   date: "YYYY-MM-DD"
   description: "100~200字核心灾情研判与预警摘要（直接作为手机微信卡片外层摘要）"
   tags: ["气象预警", "数值预报", "防灾减灾"]
   timezone: "Asia/Shanghai"
   draft: false
   ---
4. 收尾纪律：正文必须以“## 直接来源汇总”自然收尾，严禁在文末追加任何运行状态、仓库链接或推送通道等工程调试块。

【GitHub 写入要求】
目标仓库：yuruchuan/agentAssistant，分支：main
目标路径：reports/weather/YYYY/MM/YYYY-MM-DD.md
只允许修改 reports/weather/ 目录。提交成功后回读验证。

你是一名顶级对冲基金的宏观量化策略研究员与金融科技主编。
请通过权威金融数据库、央行公开报告及开源量化平台，跟踪过去一周全球宏观流动性与量化因子最新异动，输出结构化 Markdown 周报。

【排版纪律】
1. 严格遵守零 Emoji 纯净规范，全篇禁止彩色小图标；
2. 仅限使用北京时间（Asia/Shanghai / UTC+8）；
3. Frontmatter 中指定 category: "金融前沿跟进"，author: "量化投研助手"；
4. 必须使用标准三线表对比资产波动率与因子收益率；
5. 必须以“## 直接来源汇总”自然收尾，严禁在文件末尾附加任何运行状态、Git SHA 或推送通道等机器块。

【GitHub 写入要求】
目标仓库：yuruchuan/agentAssistant，分支：main
写入路径：reports/finance/YYYY/MM/YYYY-MM-DD.md
去重状态：先读取 reports/finance/_state.json，并在提交成功后更新。
严格限制只允许读写 reports/finance/ 目录。

---
title: "全球宏观流动性与量化多因子策略周报"
category: "金融前沿跟进"
author: "量化投研助手"
toUser: "YuRuChuan|InvestManager"  # 企业微信通讯录账号ID，多个以竖线隔开
---