如何使用mvc在nodejs中通过schema将excel表格数据插入mongodb

const mongoose = require('mongoose');

const excelSchema = new mongoose.Schema({
  // 定义Excel表格中的字段，以及其数据类型
  field1: { type: String, required: true },
  field2: { type: Number, required: true },
  // ...
});

const ExcelModel = mongoose.model('Excel', excelSchema);

module.exports = ExcelModel;

const ExcelModel = require('../models/excelSchema');
const xlsx = require('xlsx');

// 处理Excel文件上传和数据插入的函数
const insertExcelData = (req, res) => {
  // 通过multer中间件处理上传的Excel文件
  // 可以通过req.file获取上传的文件对象
  const filePath = req.file.path;
  
  // 读取Excel文件
  const workbook = xlsx.readFile(filePath);
  // 假设Excel中只有一个Sheet
  const sheet = workbook.Sheets[workbook.SheetNames[0]];
  
  // 将Excel数据解析成JSON对象
  const jsonData = xlsx.utils.sheet_to_json(sheet, { header: 1 });
  
  // 遍历解析后的JSON数据，并将其插入到数据库中
  jsonData.forEach((data) => {
    const excelData = new ExcelModel({
      field1: data[0],
      field2: data[1],
      // ...
    });

    excelData.save((err, savedData) => {
      if (err) {
        console.log(err);
        return res.status(500).json({ error: 'Error inserting data' });
      }
      console.log(savedData);
      // 可以根据需要返回插入成功的数据或其他信息
      return res.status(200).json({ message: 'Data inserted successfully' });
    });
  });
};

module.exports = { insertExcelData };

const express = require('express');
const router = express.Router();
const multer = require('multer');
const { insertExcelData } = require('../controllers/excelController');

// 使用multer中间件处理Excel文件上传
const upload = multer({ dest: 'uploads/' });

// 创建POST路由处理上传的Excel文件和数据插入请求
router.post('/upload', upload.single('excelFile'), insertExcelData);

module.exports = router;

const express = require('express');
const mongoose = require('mongoose');
const routes = require('./views/routes');

const app = express();

// 连接到MongoDB数据库
mongoose.connect('mongodb://localhost/your_database_name', { useNewUrlParser: true, useUnifiedTopology: true })
  .then(() => console.log('MongoDB Connected'))
  .catch((err) => console.log(err));

// 设置应用程序使用的中间件
app.use(express.json());
app.use(express.urlencoded({ extended: false }));

// 添加路由中间件
app.use('/', routes);

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