LINE Bot 多消息类型回复：文本与贴图的组合发送指南

await client.replyMessage(event.replyToken, {
  type: 'text',
  text: reply
});

await sendStickerMessage(event.replyToken);

'use strict';

// ########################################
//               初始化与配置
// ########################################

// 加载所需模块
const line = require('@line/bot-sdk');
const openai = require('openai');
const express = require('express');

const PORT = process.env.PORT || 3000;

// LINE Bot 配置
const config = {
    channelSecret: process.env.LINE_CHANNEL_SECRET || 'YOUR_CHANNEL_SECRET', // 建议从环境变量获取
    channelAccessToken: process.env.LINE_CHANNEL_ACCESS_TOKEN || 'YOUR_CHANNEL_ACCESS_TOKEN' // 建议从环境变量获取
};

// 创建 LINE Bot 客户端
const client = new line.Client(config);

// OpenAI GPT 配置
const gptConfig = new openai.Configuration({
    organization: process.env.OPENAI_ORGANIZATION_ID || "YOUR_ORGANIZATION_ID", // 建议从环境变量获取
    apiKey: process.env.OPENAI_API_KEY || 'YOUR_API_KEY', // 建议从环境变量获取
});
const gpt = new openai.OpenAIApi(gptConfig);

/**
 * 调用 OpenAI API 生成聊天回复
 * @param {Array<Object>} userMessages 用户消息数组，包含角色和内容
 * @returns {Promise<Object>} OpenAI API 的完成结果
 */
const makeCompletion = async (userMessages) => {
  const prompt = {
    role: 'system',
    content: '你是一位技艺精湛的鬼故事讲述者。请根据用户提供的关键词创作一个鬼故事。'
  };

  userMessages.unshift(prompt); // 将系统提示添加到消息列表的开头
  console.log('发送给 OpenAI 的消息:', userMessages);
  return await gpt.createChatCompletion({
    model: 'gpt-3.5-turbo',
    messages: userMessages,
    temperature: 0.2, // 降低温度以获得更稳定的故事
    n: 1
  });
};

/**
 * 处理 LINE 消息事件
 * @param {Object} event LINE Webhook 事件对象
 * @returns {Promise<null>}
 */
async function handleEvent(event) {
  // 忽略非文本消息类型
  if (event.type !== 'message' || event.message.type !== 'text') {
    return Promise.resolve(null);
  }

  const userMessage = [
    {
      role: 'user',
      content: event.message.text
    }
  ];

  try {
    // 调用 ChatGPT API 生成回复
    const completion = await makeCompletion(userMessage);
    const replyText = completion.data.choices[0].message.content;

    // 使用 sendCombinedMessages 函数发送文本和贴图
    return sendCombinedMessages(event.replyToken, replyText);
  } catch (error) {
    console.error('处理消息时发生错误:', error);
    // 可以在这里发送一个错误提示给用户
    return Promise.resolve(null);
  }
}

/**
 * 发送组合消息（文本和贴图）
 * @param {string} replyToken 用于回复的令牌
 * @param {string} text 要发送的文本内容
 * @returns {Promise<Object>} LINE API 的回复结果
 */
async function sendCombinedMessages(replyToken, text) {
  try {
    const textMessage = {
      type: 'text',
      text: text
    };

    const stickerMessage = {
      type: 'sticker',
      packageId: '446', // 替换为你的贴图包 ID
      stickerId: '2027' // 替换为你的贴图 ID
    };

    // 将文本消息和贴图消息放入一个数组中，一次性发送
    return client.replyMessage(replyToken, [textMessage, stickerMessage]);
  } catch (error) {
    console.error('发送组合消息时发生错误:', error.message);
    if (error.response) {
      console.error('LINE API 错误详情:', error.response.data);
    }
    // 可以在这里根据错误类型进行更细致的处理
  }
}

// ########################################
//               Express 服务器设置
// ########################################

const app = express();

// 根路径 GET 请求，用于健康检查或简单提示
app.get('/', (req, res) => res.send('Hello LINE BOT! (HTTP GET)'));

// Webhook POST 请求处理
app.post('/webhook', line.middleware(config), (req, res) => {
  if (req.body.events.length === 0) {
    res.send('Hello LINE BOT! (HTTP POST)');
    console.log('收到验证事件！');
    return;
  } else {
    console.log('收到事件:', req.body.events);
  }

  // 并行处理所有事件
  Promise.all(
    req.body.events.map((event) => {
      if (event.type === 'message' && event.message.type === 'text') {
        return handleEvent(event);
      }
      // 如果需要处理其他消息类型（如贴图消息），可以在这里添加逻辑
      // else if (event.type === 'message' && event.message.type === 'sticker') {
      //   return handleMessageEvent(event); // 假设有处理贴图消息的函数
      // }
      else {
        return null;
      }
    })
  ).then((result) => res.json(result));
});

// 启动 Express 服务器
app.listen(PORT, () => {
  console.log(`Express 服务器正在端口 ${PORT} 上运行...`);
});