已完成设备管理页面的基本功能，包括设备导入导出，字段自定义，字段是否显示等功能，目前处于资产管理已基本完善

2025-12-18 19:11:56 +08:00
parent 2ec02fb057
commit 072b3d593e
10 changed files with 1063 additions and 63 deletions
@@ -9,7 +9,11 @@
      "version": "1.0.0",
      "dependencies": {
        "cors": "^2.8.5",
+        "csv-parser": "^3.2.0",
+        "csv-writer": "^1.6.0",
        "express": "^4.18.2",
+        "express-fileupload": "^1.5.2",
+        "iconv-lite": "^0.6.3",
        "sequelize": "^6.32.1",
        "sqlite3": "^5.1.6"
      },
@@ -311,6 +315,18 @@
        "npm": "1.2.8000 || >= 1.4.16"
      }
    },
+    "node_modules/body-parser/node_modules/iconv-lite": {
+      "version": "0.4.24",
+      "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz",
+      "integrity": "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==",
+      "license": "MIT",
+      "dependencies": {
+        "safer-buffer": ">= 2.1.2 < 3"
+      },
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
    "node_modules/brace-expansion": {
      "version": "1.1.12",
      "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-1.1.12.tgz",
@@ -359,6 +375,17 @@
        "ieee754": "^1.1.13"
      }
    },
+    "node_modules/busboy": {
+      "version": "1.6.0",
+      "resolved": "https://registry.npmjs.org/busboy/-/busboy-1.6.0.tgz",
+      "integrity": "sha512-8SFQbg/0hQ9xy3UNTB0YEnsNBbWfhf7RtnzpL7TkBiTBRfrQ9Fxcnz7VJsleJpyp6rVLvXiuORqjlHi5q+PYuA==",
+      "dependencies": {
+        "streamsearch": "^1.1.0"
+      },
+      "engines": {
+        "node": ">=10.16.0"
+      }
+    },
    "node_modules/bytes": {
      "version": "3.1.2",
      "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
@@ -544,6 +571,24 @@
        "node": ">= 0.10"
      }
    },
+    "node_modules/csv-parser": {
+      "version": "3.2.0",
+      "resolved": "https://registry.npmjs.org/csv-parser/-/csv-parser-3.2.0.tgz",
+      "integrity": "sha512-fgKbp+AJbn1h2dcAHKIdKNSSjfp43BZZykXsCjzALjKy80VXQNHPFJ6T9Afwdzoj24aMkq8GwDS7KGcDPpejrA==",
+      "license": "MIT",
+      "bin": {
+        "csv-parser": "bin/csv-parser"
+      },
+      "engines": {
+        "node": ">= 10"
+      }
+    },
+    "node_modules/csv-writer": {
+      "version": "1.6.0",
+      "resolved": "https://registry.npmjs.org/csv-writer/-/csv-writer-1.6.0.tgz",
+      "integrity": "sha512-NOx7YDFWEsM/fTRAJjRpPp8t+MKRVvniAg9wQlUKx20MFrPs73WLJhFf5iteqrxNYnsy924K3Iroh3yNHeYd2g==",
+      "license": "MIT"
+    },
    "node_modules/debug": {
      "version": "2.6.9",
      "resolved": "https://registry.npmjs.org/debug/-/debug-2.6.9.tgz",
@@ -664,19 +709,6 @@
        "iconv-lite": "^0.6.2"
      }
    },
-    "node_modules/encoding/node_modules/iconv-lite": {
-      "version": "0.6.3",
-      "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.6.3.tgz",
-      "integrity": "sha512-4fCk79wshMdzMp2rH06qWrJE4iolqLhCUH+OiuIgU++RB0+94NlDL81atO7GX55uUKueo0txHNtvEyI6D7WdMw==",
-      "license": "MIT",
-      "optional": true,
-      "dependencies": {
-        "safer-buffer": ">= 2.1.2 < 3.0.0"
-      },
-      "engines": {
-        "node": ">=0.10.0"
-      }
-    },
    "node_modules/end-of-stream": {
      "version": "1.4.5",
      "resolved": "https://registry.npmjs.org/end-of-stream/-/end-of-stream-1.4.5.tgz",
@@ -803,6 +835,18 @@
        "url": "https://opencollective.com/express"
      }
    },
+    "node_modules/express-fileupload": {
+      "version": "1.5.2",
+      "resolved": "https://registry.npmjs.org/express-fileupload/-/express-fileupload-1.5.2.tgz",
+      "integrity": "sha512-wxUJn2vTHvj/kZCVmc5/bJO15C7aSMyHeuXYY3geKpeKibaAoQGcEv5+sM6nHS2T7VF+QHS4hTWPiY2mKofEdg==",
+      "license": "MIT",
+      "dependencies": {
+        "busboy": "^1.6.0"
+      },
+      "engines": {
+        "node": ">=12.0.0"
+      }
+    },
    "node_modules/file-uri-to-path": {
      "version": "1.0.0",
      "resolved": "https://registry.npmjs.org/file-uri-to-path/-/file-uri-to-path-1.0.0.tgz",
@@ -1183,12 +1227,12 @@
      }
    },
    "node_modules/iconv-lite": {
-      "version": "0.4.24",
-      "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz",
-      "integrity": "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==",
+      "version": "0.6.3",
+      "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.6.3.tgz",
+      "integrity": "sha512-4fCk79wshMdzMp2rH06qWrJE4iolqLhCUH+OiuIgU++RB0+94NlDL81atO7GX55uUKueo0txHNtvEyI6D7WdMw==",
      "license": "MIT",
      "dependencies": {
-        "safer-buffer": ">= 2.1.2 < 3"
+        "safer-buffer": ">= 2.1.2 < 3.0.0"
      },
      "engines": {
        "node": ">=0.10.0"
@@ -2033,6 +2077,18 @@
        "node": ">= 0.8"
      }
    },
+    "node_modules/raw-body/node_modules/iconv-lite": {
+      "version": "0.4.24",
+      "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz",
+      "integrity": "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==",
+      "license": "MIT",
+      "dependencies": {
+        "safer-buffer": ">= 2.1.2 < 3"
+      },
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
    "node_modules/rc": {
      "version": "1.2.8",
      "resolved": "https://registry.npmjs.org/rc/-/rc-1.2.8.tgz",
@@ -2547,6 +2603,14 @@
        "node": ">= 0.8"
      }
    },
+    "node_modules/streamsearch": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/streamsearch/-/streamsearch-1.1.0.tgz",
+      "integrity": "sha512-Mcc5wHehp9aXz1ax6bZUyY5afg9u2rv5cqQI3mRrYkGC8rW2hM02jWuwjtL++LS5qinSyhj2QfLyNsuc+VsExg==",
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
    "node_modules/string_decoder": {
      "version": "1.3.0",
      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
@@ -7,12 +7,16 @@
    "dev": "nodemon server.js"
  },
  "dependencies": {
+    "cors": "^2.8.5",
+    "csv-parser": "^3.2.0",
+    "csv-writer": "^1.6.0",
    "express": "^4.18.2",
+    "express-fileupload": "^1.5.2",
+    "iconv-lite": "^0.6.3",
    "sequelize": "^6.32.1",
-    "sqlite3": "^5.1.6",
-    "cors": "^2.8.5"
+    "sqlite3": "^5.1.6"
  },
  "devDependencies": {
    "nodemon": "^3.0.1"
  }
-}
+}
@@ -70,4 +70,35 @@ router.delete('/:fieldId', async (req, res) => {
  }
 });

+// 批量更新字段配置
+router.post('/config', async (req, res) => {
+  try {
+    const fieldConfigs = req.body;
+    
+    // 验证输入
+    if (!Array.isArray(fieldConfigs)) {
+      return res.status(400).json({ error: '输入必须是数组' });
+    }
+    
+    // 批量更新字段配置
+    const updatedFields = [];
+    for (const config of fieldConfigs) {
+      // 使用fieldName作为更新条件，因为这是唯一的
+      const [updated] = await DeviceField.update(
+        { visible: config.visible },
+        { where: { fieldName: config.fieldName } }
+      );
+      
+      if (updated) {
+        const updatedField = await DeviceField.findOne({ where: { fieldName: config.fieldName } });
+        updatedFields.push(updatedField);
+      }
+    }
+    
+    res.json(updatedFields);
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+});
+
 module.exports = router;
@@ -1,8 +1,15 @@
 const express = require('express');
 const router = express.Router();
 const { Op } = require('sequelize');
+const fs = require('fs');
+const path = require('path');
+const csv = require('csv-parser');
+const { createObjectCsvWriter } = require('csv-writer');
+const iconv = require('iconv-lite');
 const Device = require('../models/Device');
 const Rack = require('../models/Rack');
+const Room = require('../models/Room');
+const DeviceField = require('../models/DeviceField');

 // 获取所有设备（支持搜索和筛选）
 router.get('/', async (req, res) => {
@@ -41,7 +48,12 @@ router.get('/', async (req, res) => {
    const { count, rows } = await Device.findAndCountAll({
      where,
      include: [
-        { model: Rack }
+        {
+          model: Rack,
+          include: [
+            { model: Room }
+          ]
+        }
      ],
      offset,
      limit: parseInt(pageSize)
@@ -58,23 +70,6 @@ router.get('/', async (req, res) => {
  }
 });

-// 获取单个设备
-router.get('/:deviceId', async (req, res) => {
-  try {
-    const device = await Device.findByPk(req.params.deviceId, {
-      include: [
-        { model: Rack }
-      ]
-    });
-    if (!device) {
-      return res.status(404).json({ error: '设备不存在' });
-    }
-    res.json(device);
-  } catch (error) {
-    res.status(500).json({ error: error.message });
-  }
-});
-
 // 创建设备
 router.post('/', async (req, res) => {
  try {
@@ -94,6 +89,458 @@ router.post('/', async (req, res) => {
  }
 });

+// 设备导入模板下载
+router.get('/import-template', async (req, res) => {
+  try {
+    // 查询设备字段配置
+    const deviceFields = await DeviceField.findAll({
+      order: [['order', 'ASC']]
+    });
+    
+    // 准备模板数据
+    const templateData = [
+      {
+        '设备ID': 'DEV001',
+        '设备名称': '测试服务器001',
+        '设备类型': 'server',
+        '型号': 'DELL R740',
+        '序列号': 'SN1234567890',
+        '所在机柜ID': 'A01',
+        '位置(U)': '1',
+        '高度(U)': '2',
+        '功率(W)': '500',
+        '状态': 'running',
+        '购买日期': '2023-01-01',
+        '保修到期': '2026-12-31',
+        'IP地址': '192.168.1.100',
+        '描述': '测试用服务器'
+      }
+    ];
+    
+    // 设置基础CSV标题（包含格式说明）
+    const baseHeaders = [
+      { id: '设备ID', title: '设备ID' },
+      { id: '设备名称', title: '设备名称' },
+      { id: '设备类型', title: '设备类型(server/switch/router/storage)' },
+      { id: '型号', title: '型号' },
+      { id: '序列号', title: '序列号' },
+      { id: '所在机柜ID', title: '所在机柜ID' },
+      { id: '位置(U)', title: '位置(U)' },
+      { id: '高度(U)', title: '高度(U)' },
+      { id: '功率(W)', title: '功率(W)' },
+      { id: '状态', title: '状态(running/maintenance/offline/fault)' },
+      { id: '购买日期', title: '购买日期(YYYY-MM-DD)' },
+      { id: '保修到期', title: '保修到期(YYYY-MM-DD)' },
+      { id: 'IP地址', title: 'IP地址(可选)' },
+      { id: '描述', title: '描述(可选)' }
+    ];
+    
+    // 添加自定义字段标题（排除与基础字段重复的字段）
+    const baseFieldTitles = baseHeaders.map(header => header.id);
+    const customHeaders = deviceFields
+      .filter(field => field.visible && !baseFieldTitles.includes(field.displayName))
+      .map(field => ({ 
+        id: field.displayName, 
+        title: `${field.displayName}(${field.required ? '必填' : '可选'})` 
+      }));
+    
+    const csvWriter = createObjectCsvWriter({
+      path: path.join(__dirname, '../temp/import_template.csv'),
+      header: [...baseHeaders, ...customHeaders]
+    });
+    
+    // 写入CSV文件
+    await csvWriter.writeRecords(templateData);
+    
+    // 设置响应头
+    res.setHeader('Content-Type', 'text/csv; charset=gbk');
+    res.setHeader('Content-Disposition', `attachment; filename*=UTF-8''${encodeURIComponent('设备导入模板.csv')}`);
+    
+    // 发送文件
+    const fileStream = fs.createReadStream(path.join(__dirname, '../temp/import_template.csv'));
+    fileStream.pipe(res);
+    
+    // 删除临时文件
+    fileStream.on('end', () => {
+      fs.unlinkSync(path.join(__dirname, '../temp/import_template.csv'));
+    });
+    
+  } catch (error) {
+    console.error('生成导入模板失败:', error);
+    res.status(500).json({ error: '生成导入模板失败' });
+  }
+});
+
+// 导出设备数据为CSV
+router.get('/export', async (req, res) => {
+  try {
+    const { deviceIds } = req.query;
+    
+    // 查询条件
+    const where = {};
+    if (deviceIds) {
+      // 支持多个设备ID，使用数组格式
+      const ids = Array.isArray(deviceIds) ? deviceIds : [deviceIds];
+      where.deviceId = { [Op.in]: ids };
+    }
+    
+    // 查询设备字段配置
+    const deviceFields = await DeviceField.findAll({
+      order: [['order', 'ASC']]
+    });
+    
+    // 查询设备数据
+    const devices = await Device.findAll({
+      where,
+      include: [
+        {
+          model: Rack,
+          include: [
+            { model: Room }
+          ]
+        }
+      ]
+    });
+    
+    // 如果没有找到设备
+    if (devices.length === 0) {
+      return res.status(404).json({ error: '未找到指定的设备' });
+    }
+    
+    // 准备CSV数据
+    const csvData = devices.map(device => {
+      // 创建基础数据对象
+      const deviceData = {
+        '设备ID': device.deviceId,
+        '设备名称': device.name,
+        '设备类型': device.type,
+        '型号': device.model,
+        '序列号': device.serialNumber,
+        '所在机房ID': device.Rack?.Room?.roomId || '',
+        '所在机房名称': device.Rack?.Room?.name || '',
+        '所在机柜ID': device.rackId,
+        '所在机柜名称': device.Rack?.name || '',
+        '位置(U)': device.position,
+        '高度(U)': device.height,
+        '功率(W)': device.powerConsumption,
+        'IP地址': device.ipAddress,
+        '状态': device.status,
+        '购买日期': device.purchaseDate ? new Date(device.purchaseDate).toLocaleDateString() : '',
+        '保修到期': device.warrantyExpiry ? new Date(device.warrantyExpiry).toLocaleDateString() : '',
+        '描述': device.description,
+        '创建时间': device.createdAt ? new Date(device.createdAt).toLocaleString() : ''
+      };
+      
+      // 添加自定义字段（排除基础字段）
+      if (device.customFields) {
+        // 定义基础字段的显示名称
+        const baseFieldDisplayNames = [
+          '设备ID', '设备名称', '设备类型', '型号', '序列号', 
+          '所在机房ID', '所在机房名称', '所在机柜ID', '所在机柜名称', '位置(U)', '高度(U)', 
+          '功率(W)', 'IP地址', '状态', '购买日期', '保修到期', '描述', '创建时间'
+        ];
+        
+        deviceFields.forEach(field => {
+          // 只添加未在基础字段中出现的自定义字段
+          if (field.visible && 
+              device.customFields[field.fieldName] && 
+              !baseFieldDisplayNames.includes(field.displayName)) {
+            deviceData[field.displayName] = device.customFields[field.fieldName];
+          }
+        });
+      }
+      
+      return deviceData;
+    });
+    
+    // 设置CSV标题（包含自定义字段）
+    const baseHeaders = [
+      { id: '设备ID', title: '设备ID' },
+      { id: '设备名称', title: '设备名称' },
+      { id: '设备类型', title: '设备类型' },
+      { id: '型号', title: '型号' },
+      { id: '序列号', title: '序列号' },
+      { id: '所在机房ID', title: '所在机房ID' },
+      { id: '所在机房名称', title: '所在机房名称' },
+      { id: '所在机柜ID', title: '所在机柜ID' },
+      { id: '所在机柜名称', title: '所在机柜名称' },
+      { id: '位置(U)', title: '位置(U)' },
+      { id: '高度(U)', title: '高度(U)' },
+      { id: '功率(W)', title: '功率(W)' },
+      { id: 'IP地址', title: 'IP地址' },
+      { id: '状态', title: '状态' },
+      { id: '购买日期', title: '购买日期' },
+      { id: '保修到期', title: '保修到期' },
+      { id: '描述', title: '描述' },
+      { id: '创建时间', title: '创建时间' }
+    ];
+    
+    // 添加自定义字段标题（排除与基础字段重复的字段）
+    const baseFieldTitles = baseHeaders.map(header => header.id);
+    const customHeaders = deviceFields
+      .filter(field => field.visible && !baseFieldTitles.includes(field.displayName))
+      .map(field => ({ id: field.displayName, title: field.displayName }));
+    
+    const csvWriter = createObjectCsvWriter({
+      path: path.join(__dirname, '../temp/devices.csv'),
+      header: [...baseHeaders, ...customHeaders],
+      encoding: 'utf8'
+    });
+    
+    // 确保temp目录存在
+    if (!fs.existsSync(path.join(__dirname, '../temp'))) {
+      fs.mkdirSync(path.join(__dirname, '../temp'));
+    }
+    
+    // 写入CSV文件
+    await csvWriter.writeRecords(csvData);
+    
+    // 读取文件并转换为GBK编码
+    const csvContent = fs.readFileSync(path.join(__dirname, '../temp/devices.csv'), 'utf8');
+    const gbkContent = iconv.encode(csvContent, 'gbk');
+    
+    // 设置响应头
+    res.setHeader('Content-Type', 'text/csv');
+    res.setHeader('Content-Disposition', 'attachment; filename=devices.csv');
+    
+    // 发送CSV数据
+    res.send(gbkContent);
+    
+    // 删除临时文件
+    fs.unlinkSync(path.join(__dirname, '../temp/devices.csv'));
+  } catch (error) {
+    console.error('导出设备数据失败:', error);
+    res.status(500).json({ error: '导出设备数据失败' });
+  }
+});
+
+// 导入设备数据从CSV
+router.post('/import', async (req, res) => {
+  try {
+    if (!req.files || !req.files.csvFile) {
+      return res.status(400).json({ error: '请上传CSV文件' });
+    }
+    
+    const csvFile = req.files.csvFile;
+    const stats = { total: 0, success: 0, failed: 0, errors: [] };
+    
+    // 确保temp目录存在
+    if (!fs.existsSync(path.join(__dirname, '../temp'))) {
+      fs.mkdirSync(path.join(__dirname, '../temp'));
+    }
+    
+    // 保存上传的文件
+    const filePath = path.join(__dirname, '../temp', csvFile.name);
+    await csvFile.mv(filePath);
+    
+    // 读取并解析CSV文件（GBK编码）
+    const results = [];
+    const stream = fs.createReadStream(filePath)
+      .pipe(iconv.decodeStream('gbk'))
+      .pipe(csv());
+    
+    await new Promise((resolve, reject) => {
+      stream.on('data', (data) => {
+        stats.total++;
+        results.push(data);
+      })
+      .on('end', resolve)
+      .on('error', reject);
+    });
+    
+    // 获取所有机柜信息用于验证
+    const racks = await Rack.findAll();
+    const rackIds = racks.map(rack => rack.rackId);
+    
+    // 获取所有机房信息，用于自动创建机柜时的默认机房
+    let rooms = await Room.findAll();
+    let defaultRoomId;
+    
+    // 如果没有机房，创建一个默认机房
+    if (rooms.length === 0) {
+      const defaultRoom = await Room.create({
+        roomId: 'ROOM001',
+        name: '默认机房',
+        location: '默认位置',
+        area: 100,
+        capacity: 100
+      });
+      defaultRoomId = defaultRoom.roomId;
+    } else {
+      // 使用第一个机房作为默认机房
+      defaultRoomId = rooms[0].roomId;
+    }
+    
+    // 获取设备字段配置
+    const deviceFields = await DeviceField.findAll();
+    
+    // 创建字段映射：displayName -> fieldName
+    const fieldMapping = {};
+    deviceFields.forEach(field => {
+      fieldMapping[field.displayName] = field;
+    });
+    
+    // 处理导入数据
+    for (let i = 0; i < results.length; i++) {
+      const row = results[i];
+      const rowNum = i + 2; // CSV行号（第一行是标题）
+      
+      // 辅助函数：从带格式说明的字段名中提取原始字段名（如从"设备类型(server/switch/router/storage)"提取"设备类型"）
+      const extractFieldName = (fieldNameWithFormat) => {
+        const match = fieldNameWithFormat.match(/^([^\(]+)/);
+        return match ? match[1].trim() : fieldNameWithFormat;
+      };
+      
+      // 创建一个映射，将原始字段名映射到CSV中的值
+      const fieldValueMap = {};
+      Object.entries(row).forEach(([displayName, value]) => {
+        const originalFieldName = extractFieldName(displayName);
+        fieldValueMap[originalFieldName] = value;
+        // 同时保留原始字段名的映射，以便兼容不同格式
+        fieldValueMap[displayName] = value;
+      });
+      
+      try {
+        // 验证必填字段
+        if (!fieldValueMap['设备ID'] || !fieldValueMap['设备名称'] || !fieldValueMap['设备类型'] || !fieldValueMap['型号'] || !fieldValueMap['序列号'] || !fieldValueMap['所在机柜ID'] || !fieldValueMap['位置(U)'] || !fieldValueMap['高度(U)'] || !fieldValueMap['功率(W)'] || !fieldValueMap['状态'] || !fieldValueMap['购买日期'] || !fieldValueMap['保修到期']) {
+          throw new Error('缺少必填字段');
+        }
+        
+        // 验证设备ID是否已存在
+        const existingDevice = await Device.findByPk(fieldValueMap['设备ID']);
+        if (existingDevice) {
+          throw new Error('设备ID已存在');
+        }
+        
+        // 验证机柜是否存在，如果不存在则自动创建
+        if (!rackIds.includes(fieldValueMap['所在机柜ID'])) {
+          // 自动创建机柜
+          const newRack = await Rack.create({
+            rackId: fieldValueMap['所在机柜ID'],
+            name: fieldValueMap['所在机柜ID'], // 使用机柜ID作为默认名称
+            height: 42, // 默认42U高度
+            maxPower: 10000, // 默认最大功耗10000W
+            currentPower: 0,
+            status: 'active',
+            roomId: defaultRoomId
+          });
+          
+          // 更新机柜列表和ID列表
+          racks.push(newRack);
+          rackIds.push(newRack.rackId);
+        }
+        
+        // 验证状态值
+        const validStatus = ['running', 'maintenance', 'offline', 'fault'];
+        if (!validStatus.includes(fieldValueMap['状态'])) {
+          throw new Error('状态值无效，有效值为：running, maintenance, offline, fault');
+        }
+        
+        // 验证日期格式并解析日期
+        const purchaseDate = new Date(fieldValueMap['购买日期']);
+        const warrantyExpiry = new Date(fieldValueMap['保修到期']);
+        if (isNaN(purchaseDate.getTime()) || isNaN(warrantyExpiry.getTime())) {
+          throw new Error('日期格式无效，请使用有效的日期格式');
+        }
+        
+        // 构建设备数据
+        const deviceData = {
+          deviceId: fieldValueMap['设备ID'],
+          name: fieldValueMap['设备名称'],
+          type: fieldValueMap['设备类型'],
+          model: fieldValueMap['型号'],
+          serialNumber: fieldValueMap['序列号'],
+          rackId: fieldValueMap['所在机柜ID'],
+          position: parseInt(fieldValueMap['位置(U)']),
+          height: parseInt(fieldValueMap['高度(U)']),
+          powerConsumption: parseFloat(fieldValueMap['功率(W)']),
+          ipAddress: fieldValueMap['IP地址'] || '',
+          status: fieldValueMap['状态'],
+          purchaseDate: purchaseDate,
+          warrantyExpiry: warrantyExpiry,
+          description: fieldValueMap['描述'] || ''
+        };
+        
+        // 处理自定义字段
+        const customFields = {};
+        Object.entries(row).forEach(([displayName, value]) => {
+          // 跳过基础字段
+          const originalFieldName = extractFieldName(displayName);
+          const baseFields = ['设备ID', '设备名称', '设备类型', '型号', '序列号', '所在机柜ID', '位置(U)', '高度(U)', '功率(W)', '状态', '购买日期', '保修到期', 'IP地址', '描述'];
+          if (!baseFields.includes(originalFieldName)) {
+            // 查找对应的字段配置（同时尝试原始字段名和带格式的字段名）
+            const fieldConfig = fieldMapping[displayName] || fieldMapping[originalFieldName];
+            if (fieldConfig) {
+              // 根据字段类型处理值
+              let processedValue = value;
+              if (fieldConfig.fieldType === 'number') {
+                processedValue = parseFloat(value);
+              } else if (fieldConfig.fieldType === 'boolean') {
+                processedValue = value.toLowerCase() === 'true' || value === '1' || value.toLowerCase() === '是';
+              } else if (fieldConfig.fieldType === 'date') {
+                processedValue = new Date(value);
+              }
+              
+              customFields[fieldConfig.fieldName] = processedValue;
+            }
+          }
+        });
+        
+        // 如果有自定义字段，添加到设备数据中
+        if (Object.keys(customFields).length > 0) {
+          deviceData.customFields = customFields;
+        }
+        
+        // 创建设备
+        const device = await Device.create(deviceData);
+        
+        // 更新机柜当前功率
+        const rack = await Rack.findByPk(row['所在机柜ID']);
+        if (rack) {
+          await rack.update({
+            currentPower: rack.currentPower + device.powerConsumption
+          });
+        }
+        
+        stats.success++;
+      } catch (error) {
+        stats.failed++;
+        stats.errors.push({ row: rowNum, error: error.message, data: row });
+      }
+    }
+    
+    // 删除临时文件
+    fs.unlinkSync(filePath);
+    
+    res.json({ statistics: stats });
+  } catch (error) {
+    console.error('导入设备数据失败:', error);
+    res.status(500).json({ error: '导入设备数据失败' });
+  }
+});
+
+// 获取单个设备
+router.get('/:deviceId', async (req, res) => {
+  try {
+    const device = await Device.findByPk(req.params.deviceId, {
+      include: [
+        {
+          model: Rack,
+          include: [
+            { model: Room }
+          ]
+        }
+      ]
+    });
+    if (!device) {
+      return res.status(404).json({ error: '设备不存在' });
+    }
+    res.json(device);
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+});
+
 // 更新设备
 router.put('/:deviceId', async (req, res) => {
  try {
@@ -119,7 +566,12 @@ router.put('/:deviceId', async (req, res) => {
      
      const updatedDevice = await Device.findByPk(req.params.deviceId, {
        include: [
-          { model: Rack }
+          {
+            model: Rack,
+            include: [
+              { model: Room }
+            ]
+          }
        ]
      });
      res.json(updatedDevice);
@@ -131,6 +583,62 @@ router.put('/:deviceId', async (req, res) => {
  }
 });

+// 批量下线设备
+router.put('/batch-offline', async (req, res) => {
+  try {
+    const { deviceIds } = req.body;
+    
+    if (!deviceIds || !Array.isArray(deviceIds)) {
+      return res.status(400).json({ error: '无效的设备ID列表' });
+    }
+    
+    // 更新设备状态为离线
+    const updated = await Device.update(
+      { status: 'offline' },
+      { where: { deviceId: deviceIds } }
+    );
+    
+    res.json({ message: `成功下线 ${updated[0]} 个设备` });
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+});
+
+// 批量删除设备
+router.delete('/batch-delete', async (req, res) => {
+  try {
+    const { deviceIds } = req.body;
+    
+    if (!deviceIds || !Array.isArray(deviceIds)) {
+      return res.status(400).json({ error: '无效的设备ID列表' });
+    }
+    
+    // 先获取所有设备的功率信息
+    const devices = await Device.findAll({
+      where: { deviceId: deviceIds }
+    });
+    
+    // 更新机柜功率
+    for (const device of devices) {
+      const rack = await Rack.findByPk(device.rackId);
+      if (rack) {
+        await rack.update({
+          currentPower: Math.max(0, rack.currentPower - device.powerConsumption)
+        });
+      }
+    }
+    
+    // 删除设备
+    const deleted = await Device.destroy({
+      where: { deviceId: deviceIds }
+    });
+    
+    res.json({ message: `成功删除 ${deleted} 个设备` });
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+});
+
 // 删除设备
 router.delete('/:deviceId', async (req, res) => {
  try {
@@ -91,4 +91,5 @@ router.delete('/:rackId', async (req, res) => {
  }
 });

+
 module.exports = router;
@@ -1,5 +1,6 @@
 const express = require('express');
 const cors = require('cors');
+const fileUpload = require('express-fileupload');
 const { sequelize } = require('./db');

 // 创建Express应用
@@ -9,6 +10,8 @@ const PORT = process.env.PORT || 3001;
 // 中间件
 app.use(cors());
 app.use(express.json());
+app.use(fileUpload({ limits: { fileSize: 50 * 1024 * 1024 } }));
+app.use('/temp', express.static('temp'));

 // 数据库连接已从db.js导入