// propertyMapper.js - 阿里云物模型数据映射 const logger = require('./logger'); const fs = require('fs'); const path = require('path'); class PropertyMapper { constructor() { // 从文件加载物模型，或使用内置配置 this.schema = this.loadSchema(); this.propertyMap = this.buildPropertyMap(); } /** * 加载物模型定义 */ loadSchema() { try { // 尝试从 schema.json 文件加载 const schemaPath = path.join(__dirname, 'schema.json'); if (fs.existsSync(schemaPath)) { const schemaContent = fs.readFileSync(schemaPath, 'utf8'); logger.info('✅ 已从 schema.json 加载物模型'); return JSON.parse(schemaContent); } } catch (err) { logger.warn(`加载 schema.json 失败: ${err.message}`); } // 返回默认配置 logger.info('ℹ️ 使用默认物模型配置'); return this.getDefaultSchema(); } /** * 获取默认物模型（完整版 - 与schema.json同步） */ getDefaultSchema() { return { properties: [ { identifier: 'A', name: '脱水目标量' }, { identifier: 'B', name: '脱水量' }, { identifier: 'C', name: '脱水速率' }, { identifier: 'D', name: '血液流速' }, { identifier: 'E', name: '肝素速率' }, { identifier: 'F', name: '透析液温度' }, { identifier: 'G', name: '透析液电导度' }, { identifier: 'H', name: '静脉压' }, { identifier: 'I', name: '透析液压' }, { identifier: 'J', name: '跨膜压' }, { identifier: 'K', name: '透析时间' }, { identifier: 'a', name: '透析液温度报警' }, { identifier: 'b', name: '电导度报警' }, { identifier: 'c', name: '静脉压报警' }, { identifier: 'd', name: '透析液压力报警' }, { identifier: 'e', name: '跨膜压警报' }, { identifier: 'f', name: '气泡侦测器警报' }, { identifier: 'g', name: '漏血报警' }, { identifier: 'h', name: '其他报警' }, { identifier: 'L', name: '透析液流速' }, { identifier: 'M', name: 'BPM监测时间' }, { identifier: 'N', name: 'BPM最高血压' }, { identifier: 'O', name: 'BPM最低血压' }, { identifier: 'P', name: 'BPM脉冲' }, { identifier: 'Q', name: '收缩压上限' }, { identifier: 'R', name: '收缩压下限' }, { identifier: 'S', name: 'BPM压脉带压力' }, { identifier: 'T', name: 'BPM检测间隔时间' }, { identifier: 'U', name: '血流总量' }, { identifier: 'V', name: '静脉压上限报警' }, { identifier: 'W', name: '静脉压下限报警' }, { identifier: 'X', name: '肝素总量' }, { identifier: 'Y', name: '透析液压上限报警' }, { identifier: 'Z', name: '透析液压下限警报' }, { identifier: 'i', name: '单补钠个性化程序' }, { identifier: 'j', name: '脱水个性化程序' }, { identifier: 'k', name: '透析液选择' }, { identifier: 'l', name: '电导度档位' }, { identifier: 'm', name: '数据通信状态' }, { identifier: 'n', name: '序列号' }, { identifier: 'o', name: '动脉压' }, { identifier: 'p', name: '动脉压警报' }, { identifier: 'q', name: '动脉压上限警报' }, { identifier: 'r', name: '动脉压下限警报' }, { identifier: 's', name: '跨膜压上限警报' }, { identifier: 't', name: '跨膜压下限警报' }, { identifier: 'u', name: '置换液速率' }, { identifier: 'v', name: '置换液目标量' }, { identifier: 'w', name: '置换液进程量' }, { identifier: 'x', name: '电导度个性化程序' }, { identifier: 'y', name: '血液流速个性化程序' }, { identifier: 'z', name: '肝素个性化程序' }, { identifier: 'C53', name: '透析液个性化程序' }, { identifier: 'C54', name: '透析液温度初始设置' }, { identifier: 'C55', name: '缺水2警报' }, { identifier: 'suedtime', name: '传输时间' }, { identifier: 'deviceType', name: 'deviceType' }, { identifier: 'IPAddress', name: 'IP地址' }, { identifier: 'deviceName', name: '设备名称' }, { identifier: 'warn', name: '警告' }, { identifier: 'ICCID', name: 'iccid' }, { identifier: 'mb', name: '脉搏-德朗' }, { identifier: 'szy', name: '舒张压-德朗' }, { identifier: 'ssy', name: '收缩压-德朗' }, { identifier: 'sysj', name: '剩余时间-德朗' }, { identifier: 'bjbh', name: '报警编号-德朗' }, { identifier: 'xlllsd', name: '血泵流量设定-德朗' } ] }; } /** * 构建属性映射表 (identifier -> name) */ buildPropertyMap() { const map = {}; if (this.schema.properties && Array.isArray(this.schema.properties)) { this.schema.properties.forEach(prop => { map[prop.identifier] = prop.name; }); } return map; } /** * 获取属性名称 * @param {string} identifier - 属性标识符 * @returns {string} 属性名称 */ getPropertyName(identifier) { return this.propertyMap[identifier] || identifier; } /** * 将原始数据转换为标准格式 * @param {object} rawData - 原始数据对象 * @returns {array} 转换后的数据数组 */ mapData(rawData) { if (!rawData || typeof rawData !== 'object') { logger.warn('输入数据无效'); return []; } const mappedData = []; for (const [key, value] of Object.entries(rawData)) { // 跳过内部字段 if (key.startsWith('_')) { continue; } // 获取属性名称 const name = this.getPropertyName(key); mappedData.push({ identifier: key, name: name, value: value }); } return mappedData; } /** * 将原始数据转换为 HTTP 响应格式 * @param {object} rawData - 原始数据 * @param {string} deviceNumber - 设备号 * @returns {array} 转换后的属性数组 */ transformForHTTP(rawData, deviceNumber) { const mappedData = this.mapData(rawData); return mappedData; } /** * 将原始数据转换为 MQTT 发布格式 * @param {object} rawData - 原始数据 * @param {string} deviceNumber - 设备号 * @returns {object} 转换后的数据 */ transformForMQTT(rawData, deviceNumber) { const mappedData = this.mapData(rawData); return { deviceNumber: deviceNumber, deviceId: deviceNumber, timestamp: new Date().toISOString(), data: mappedData }; } /** * 将原始数据转换为阿里云物联网平台格式 * @param {object} rawData - 原始数据 * @returns {object} 转换后的属性对象 */ transformForAliyun(rawData) { const props = {}; for (const [key, value] of Object.entries(rawData)) { // 跳过内部字段 if (key.startsWith('_')) { continue; } // 直接使用 identifier 作为属性 props[key] = value; } return props; } /** * 获取所有属性定义 */ getAllProperties() { return this.schema.properties || []; } /** * 获取属性定义 * @param {string} identifier - 属性标识符 * @returns {object} 属性定义 */ getPropertyDefinition(identifier) { if (!this.schema.properties) return null; return this.schema.properties.find(p => p.identifier === identifier); } /** * 统计属性信息 */ getPropertyStats() { const properties = this.schema.properties || []; const readOnlyCount = properties.filter(p => p.accessMode === 'r').length; const readWriteCount = properties.filter(p => p.accessMode === 'rw').length; // 统计数据类型分布 const dataTypeDistribution = new Map(); const dataTypes = new Set(); properties.forEach(prop => { dataTypes.add(prop.dataType); dataTypeDistribution.set( prop.dataType, (dataTypeDistribution.get(prop.dataType) || 0) + 1 ); }); return { totalProperties: properties.length, readOnlyCount: readOnlyCount, readWriteCount: readWriteCount, dataTypes: dataTypes, dataTypeDistribution: Array.from(dataTypeDistribution.entries()) }; } } // 导出单例 module.exports = new PropertyMapper();