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 || 'mongodb://localhost/member-attendance', { 
  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' });
});

// 添加一个简单的GET路由用于测试
app.get('/', (req, res) => {
  res.send('Member Attendance System API is running');
});

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