Node.js Express 路由聚合：内部逻辑复用与高效数据整合

// services/alarmService.js
async function getAlarm1Data(options = {}) {
  // 模拟异步数据获取，可能需要根据 options（如 siteIds）进行过滤
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`Fetching Alarm 1 data for sites: ${options.siteIds ? options.siteIds.join(',') : 'all'}`);
      resolve({
        id: 'alarm-1',
        status: 'active',
        message: 'Smoke detected in Server Room A',
        timestamp: new Date().toISOString()
      });
    }, 100); // 模拟网络延迟
  });
}

async function getAlarm2Data(options = {}) {
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`Fetching Alarm 2 data for sites: ${options.siteIds ? options.siteIds.join(',') : 'all'}`);
      resolve({
        id: 'alarm-2',
        status: 'inactive',
        message: 'Temperature normal in Server Room B',
        timestamp: new Date().toISOString()
      });
    }, 150);
  });
}

async function getAlarm3Data(options = {}) {
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`Fetching Alarm 3 data for sites: ${options.siteIds ? options.siteIds.join(',') : 'all'}`);
      resolve({
        id: 'alarm-3',
        status: 'pending',
        message: 'Door sensor fault in Data Center C',
        timestamp: new Date().toISOString()
      });
    }, 80);
  });
}

module.exports = {
  getAlarm1Data,
  getAlarm2Data,
  getAlarm3Data,
  // ... 其他报警数据函数
};

// routes/alarmRoutes.js
const express = require('express');
const router = express.Router();
const { authenticateUser } = require('../middleware/auth/authenticateUser'); // 假设的认证中间件
const { getSiteIds } = require('../middleware/sites/getSiteIds'); // 假设的获取站点ID中间件
const alarmService = require('../services/alarmService');

// 应用中间件
router.use(authenticateUser);
router.use(getSiteIds); // 假设此中间件会将 siteIds 附加到 req.siteIds

// 单个报警路由：/alarm1
router.get('/alarm1', async (req, res) => {
  try {
    // 将中间件处理后的信息（如 req.siteIds）作为参数传递给业务逻辑函数
    const alarmData = await alarmService.getAlarm1Data({ siteIds: req.siteIds });
    res.json(alarmData);
  } catch (error) {
    console.error('Error fetching alarm 1:', error);
    res.status(500).json({ error: 'Failed to retrieve alarm 1 data.' });
  }
});

// 单个报警路由：/alarm2
router.get('/alarm2', async (req, res) => {
  try {
    const alarmData = await alarmService.getAlarm2Data({ siteIds: req.siteIds });
    res.json(alarmData);
  } catch (error) {
    console.error('Error fetching alarm 2:', error);
    res.status(500).json({ error: 'Failed to retrieve alarm 2 data.' });
  }
});

// ... 其他单个报警路由

// routes/alarmRoutes.js (续)

// 聚合报警路由：/all-alarms
router.get('/all-alarms', async (req, res) => {
  try {
    const options = { siteIds: req.siteIds };
    // 并行调用所有报警数据获取函数
    const [alarm1Data, alarm2Data, alarm3Data] = await Promise.all([
      alarmService.getAlarm1Data(options),
      alarmService.getAlarm2Data(options),
      alarmService.getAlarm3Data(options)
      // ... 添加更多报警数据函数的调用
    ]);

    // 整合结果并发送响应
    const aggregatedData = {
      alarm1: alarm1Data,
      alarm2: alarm2Data,
      alarm3: alarm3Data,
      // ... 整合其他数据
    };
    res.json(aggregatedData);
  } catch (error) {
    console.error('Error fetching all alarms:', error);
    res.status(500).json({ error: 'Failed to retrieve all alarms data.' });
  }
});

module.exports = router;

// app.js
const express = require('express');
const app = express();
const alarmRoutes = require('./routes/alarmRoutes'); // 导入报警路由

// 其他中间件...
app.use(express.json()); // 用于解析 JSON 请求体

// 挂载报警路由
app.use('/api/alarms', alarmRoutes); // 例如，所有报警相关路由都在 /api/alarms 下

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