member-attendance-system-njWOfO-I/server/index.js

const express = require('express');
const cors = require('cors');
const mongoose = require('mongoose');
const dotenv = require('dotenv');
const { publishPersonInfo } = require('./mqtt-handler');

dotenv.config();

const app = express();
app.use(cors());
app.use(express.json());

// 连接到MongoDB数据库
mongoose.connect(process.env.MONGODB_URI, { useNewUrlParser: true, useUnifiedTopology: true })
  .then(() => console.log('Connected to MongoDB'))
  .catch(err => console.error('Could not connect to MongoDB:', err));

// 示例路由：下发人员信息
app.post('/api/publish-person-info', (req, res) => {
  const personInfo = req.body;
  publishPersonInfo(personInfo);
  res.json({ message: 'Person info published to MQTT' });
});

const PORT = process.env.PORT || 5000;
app.listen(PORT, () => {
  console.log(`Server running on port ${PORT}`);
});