智能对话机器人特惠活动

// 引入必要的库
const express = require('express');
const bodyParser = require('body-parser');
const { dialogflow } = require('@google-cloud/dialogflow');

// 创建Express应用
const app = express();
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());

// 设置Dialogflow客户端
const dialogflowSessionsClient = new dialogflow.SessionsClient();
const projectId = 'your-project-id'; // 替换为你的Dialogflow项目ID

// 处理对话请求
app.post('/chat', async (req, res) => {
  const { message } = req.body;
  const sessionId = 'unique-session-id'; // 确保每次对话有唯一的session ID

  const sessionPath = dialogflowSessionsClient.projectAgentSessionPath(projectId, sessionId);
  const request = {
    session: sessionPath,
    queryInput: {
      text: {
        text: message,
        languageCode: 'zh-CN',
      },
    },
  };

  try {
    const responses = await dialogflowSessionsClient.detectIntent(request);
    const result = responses[0].queryResult;
    res.json({ response: result.fulfillmentText });
  } catch (error) {
    console.error('Dialogflow API error:', error);
    res.status(500).json({ error: 'Internal Server Error' });
  }
});

// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => console.log(`Server running on port ${PORT}`));