使用LINE Bot与OpenAI API发送文本和贴图的完整教程

// 原始代码片段 (存在问题)
async function handleEvent(event) {
  // ... 省略 OpenAI API 调用和文本回复逻辑 ...
  await client.replyMessage(event.replyToken, {
    type: 'text',
    text: reply
  });

  // 尝试发送贴图，但此时replyToken可能已失效
  await sendStickerMessage(event.replyToken);
}

async function sendStickerMessage(replyToken) {
  try {
    await client.replyMessage(replyToken, {
      type: 'sticker',
      packageId: '446',
      stickerId: '2027'
    });
    console.log('Sticker message sent');
  } catch (error) {
    console.error('Error sending sticker message:', error); // 会在这里捕获到400错误
  }
}

'use strict';

// ########################################
//               Initialization and Configuration
// ########################################

// 载入模块
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客户端
const client = new line.Client(config);

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

const makeCompletion = async (userMessage) => {
  const prompt = {
    role: 'system',
    content: '你是一位技艺高超的鬼故事讲述者。请根据用户提供的关键词写一个鬼故事。' // 定义系统提示
  };

  userMessage.unshift(prompt); // 将系统提示添加到消息列表开头
  console.log(userMessage);
  return await gpt.createChatCompletion({
    model: 'gpt-3.5-turbo',
    messages: userMessage,
    temperature: 0.2, // 调整温度以控制生成文本的创造性
    n: 1
  });
};

// 发送文本和贴图消息
async function sendStickerMessage(replyToken, reply) {
  try {
    const stickerMessage = {
      type: 'sticker',
      packageId: '446', // 替换为你的贴图包ID
      stickerId: '2027' // 替换为你的贴图ID
    };
    const textMessage = {
      type: 'text',
      text: reply
    };
    // 将文本和贴图消息作为数组发送
    return client.replyMessage(replyToken, [textMessage, stickerMessage]);
  } catch (error) {
    console.error('发送贴图消息错误:', error.response ? error.response.data : error.message);
  }
}

// 处理消息事件
async function handleEvent(event) {
  // 忽略非文本消息类型
  if (event.type !== 'message' || event.message.type !== 'text') {
    return Promise.resolve(null);
  }

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

  // 发送请求到ChatGPT API
  try {
    const completion = await makeCompletion(userMessage);
    // 获取响应
    const reply = completion.data.choices[0].message.content;
    // 使用新的函数一次性发送文本和贴图
    return sendStickerMessage(event.replyToken, reply);
  } catch (error) {
    // 如果发生错误，将错误输出到日志
    console.error('发送消息错误:', error);
    return Promise.resolve(null);
  }
}

const app = express();
app.get('/', (req, res) => res.send('Hello LINE BOT! (HTTP GET)'));
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') {
        // 如果需要处理贴图消息，可以定义handleMessageEvent
        // return handleMessageEvent(event);
        return null; // 这里简单地忽略贴图消息，根据需求调整
      } else {
        return null;
      }
    })
  ).then((result) => res.json(result));
});

app.listen(PORT);
console.log(`Express 服务器运行在端口 ${PORT}...`);