Zap 代码还原画布 · Zapier MCP 复刻实验

工作流

智能体提交的代码

#全体频道新消息按是否含「123」选择收件人发邮件，并记录到 Google Sheets

样例

import { defineDurable } from "@zapier/zapier-durable";
import { createZapierSdk } from "@zapier/zapier-sdk";
import { z } from "zod";

const sdk = createZapierSdk();

const InputSchema = z
  .object({
    text: z.string().optional(),
    user: z.string().optional(),
    ts: z.string().optional(),
    permalink: z.string().optional(),
    channel: z.string().optional(),
  })
  .passthrough();

const RECIPIENT_WITH_123 = "35778231@qq.com";
const RECIPIENT_WITHOUT_123 = "35778232@qq.com";
const KEYWORD = "123";

// 从文本中提取电话:优先匹配国内手机号,其次匹配 8 位以上的数字串(可含空格、短横线)
function extractPhone(text: string): string {
  const mobile = text.match(/(?<!\d)(?:\+?86[\s-]?)?1[3-9]\d{9}(?!\d)/);
  if (mobile) return mobile[0].replace(/[\s-]/g, "");
  const generic = text.match(/\+?\d[\d\s-]{6,}\d/);
  return generic ? generic[0].replace(/[\s-]/g, "") : "";
}

export default defineDurable(
  "slack-to-gmail-forward",
  async (ctx, rawInput) => {
    const input = InputSchema.parse(rawInput);

const data = input as Record<string, unknown>;
    const userRaw = data["user"];
    const sender =
      (typeof data["user_name"] === "string" && data["user_name"]) ||
      (typeof userRaw === "string" ? userRaw : undefined) ||
      "未知用户";
    const text = input.text ?? "";

const hasKeyword = text.includes(KEYWORD);
    const recipient = hasKeyword ? RECIPIENT_WITH_123 : RECIPIENT_WITHOUT_123;
    const phone = extractPhone(text);

const subject = `Slack #全体 新消息:${text.slice(0, 50) || "(无文本)"}`;
    const body = [
      `频道:#全体`,
      `发送者:${sender}`,
      phone ? `电话:${phone}` : "",
      ``,
      text,
      ``,
      input.permalink ? `链接:${input.permalink}` : "",
    ]
      .join("\n")
      .trim();

const emailResult = await ctx.step("send-gmail-email", () =>
      sdk.runAction({
        app: "GoogleMailV2CLIAPI",
        action: "message",
        actionType: "write",
        connection: "gmail",
        inputs: {
          to: [recipient],
          subject,
          body_type: "plain",
          body,
        },
      }),
    );

const submittedAt = await ctx.step("get-record-time", async () =>
      new Date().toLocaleString("zh-CN", { timeZone: "Asia/Hong_Kong" }),
    );

await ctx.step("record-to-google-sheet", () =>
      sdk.runAction({
        app: "GoogleSheetsV2CLIAPI",
        action: "add_row",
        actionType: "write",
        connection: "sheets",
        inputs: {
          spreadsheet: "1rGnkKx_0Td0Dotphk9olVxCzLEfib_i4dEvJax5A1V4",
          worksheet: "0",
          COL$A: sender,
          COL$B: phone,
          COL$D: recipient,
          COL$H: submittedAt,
          COL$I: "Slack #全体",
          COL$J: text,
          COL$K: hasKeyword ? "包含123" : "不包含123",
        },
      }),
    );

return { recipient, hasKeyword, phone, emailResult };
  },
);

Zap 画布

选择左侧样例或粘贴代码，点击「AI 还原画布」

试运行

Vercel Workflow未运行

应用步骤经 Zapier / 集简云 MCP 真实执行，读取直接运行，写入需逐个确认；sdk.fetch 仍为模拟