“龙虾”跨端打工记：让 WorkBuddy 联动企微与 CloudBase，一句话完成任务的自动分发

// taskDispatcher/index.js
// 依赖：@cloudbase/node-sdk（CloudBase 云函数运行环境内置，无需额外安装）

const app = require('@cloudbase/node-sdk').init({
  // 不传 env，使用当前函数所在环境（即 lobster-ops-d5gm47l217e50bea8）
});

/**
 * 从文本中解析"任务内容"和"负责人"
 * 规则：
 *   1. 支持"@xxx 负责..."、"由 xxx 负责..."、"交给 xxx"、"xxx 来做"等口语表达
 *   2. 未匹配到负责人时，owner 默认为 "待认领"
 */
function parseMessage(text) {
  let owner = '待认领';
  let task = text.trim();

  // 匹配模式：@某人、由某人负责、交给某人、某人来做/处理、负责人：某人
  const ownerPatterns = [
    /负责人[：:]\s*(.+?)(?:[，,。\s]|$)/,      // 负责人：张三
    /由\s*(.+?)\s*负责/,                        // 由张三负责
    /交给\s*(.+?)(?:[，,。\s去来]|$)/,          // 交给张三
    /@([^\s，,。、]+)/,                          // @张三
    /(.+?)\s*来[做处理跟进]/,                   // 张三来处理
  ];

  for (const pattern of ownerPatterns) {
    const match = text.match(pattern);
    if (match && match[1]) {
      owner = match[1].trim();
      break;
    }
  }

  // 从 task 文本中剔除负责人相关片段，保留核心任务描述
  if (owner !== '待认领') {
    task = text
      .replace(/负责人[：:]\s*.+?(?=[，,。\s]|$)/, '')
      .replace(/由\s*.+?\s*负责/, '')
      .replace(/交给\s*.+?(?=[，,。\s去来]|$)/, '')
      .replace(/@[^\s，,。、]+/, '')
      .replace(/.+?\s*来[做处理跟进]/, '')
      .trim()
      .replace(/^[，,。、\s]+|[，,。、\s]+$/g, ''); // 清理首尾标点
  }

  // 如果清理后 task 为空，则回退到原始文本
  if (!task) {
    task = text.trim();
  }

  return { task, owner };
}

exports.main = async (event) => {
  const { messageText } = event;

  // 参数校验
  if (!messageText || typeof messageText !== 'string' || !messageText.trim()) {
    return {
      success: false,
      message: '参数 messageText 不能为空',
    };
  }

  // 解析任务内容和负责人
  const { task, owner } = parseMessage(messageText);

  // 获取数据库引用（通过 app.database()，不使用 init 方法）
  const db = app.database();

  try {
    // 写入 task_board 集合
    await db.collection('task_board').add({
      task: task,
      owner: owner,
      deadline: null,
      status: '待处理',
      source: '企微机器人',
      createdAt: new Date().toISOString(),
    });

    return {
      success: true,
      message: '任务创建成功',
      task: task,
    };
  } catch (err) {
    console.error('[taskDispatcher] 写入数据库失败：', err);
    return {
      success: false,
      message: '写入数据库失败：' + (err.message || String(err)),
    };
  }
};

{
  "messageText": "请小李在周五前完成用户反馈分析报告"
}

{"success":true,"message":"任务创建成功","task":"请小李在周五前完成用户反馈分析报告"}