Update files: server/index.js

server/index.js

@@ -0,0 +1,28 @@
+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}`);
+});