如何在nodejs中从多步表单中发布数据并将其表示为MongoDB？

const express = require('express');
const bodyParser = require('body-parser');
const MongoClient = require('mongodb').MongoClient;

const app = express();

// 解析请求体
app.use(bodyParser.urlencoded({ extended: true }));

// 创建一个MongoDB连接
const mongoUrl = 'mongodb://localhost:27017/mydb'; // 替换为你的MongoDB连接字符串
let db;

MongoClient.connect(mongoUrl, (err, client) => {
  if (err) {
    console.error(err);
    return;
  }
  console.log('Connected to MongoDB');
  db = client.db();
});

// 处理第一步表单
app.post('/step1', (req, res) => {
  // 保存第一步表单数据到服务器
  const step1Data = {
    name: req.body.name,
    email: req.body.email,
    // ...
  };
  req.session.step1Data = step1Data; // 假设使用session保存数据
  
  // 返回下一步表单页面
  res.redirect('/step2');
});

// 处理第二步表单
app.post('/step2', (req, res) => {
  // 获取第一步保存的数据
  const step1Data = req.session.step1Data;
  
  // 保存第二步表单数据到服务器
  const step2Data = {
    // ...
  };
  
  // 合并数据
  const completeData = { ...step1Data, ...step2Data };
  
  // 插入到MongoDB
  db.collection('mycollection').insertOne(completeData, (err, result) => {
    if (err) {
      console.error(err);
      res.status(500).send('Internal Server Error');
      return;
    }
    
    console.log('Data inserted:', result.ops);
    
    // 清除临时数据
    delete req.session.step1Data;
    
    // 返回成功页面或下一步表单页面
    res.send('Data submitted successfully');
  });
});

// 启动服务器
app.listen(3000, () => {
  console.log('Server started on port 3000');
});