using System.Text; using GSModbus.Config; namespace GSModbus.Config { /// /// Modbus数据解析器 - 根据配置将原始寄存器数据解析为具体类型 /// public static class ModbusDataParser { #region 主要解析方法 /// /// 根据字段配置解析寄存器数据 /// /// 原始寄存器数据 /// 字段配置 /// 解析后的数据对象 public static object? ParseFieldData(int[] registers, DataField fieldConfig) { if (fieldConfig == null) { Console.WriteLine("[PARSER-ERROR] 字段配置为null"); return null; } if (registers == null || registers.Length == 0) { Console.WriteLine($"[PARSER-ERROR] 字段 '{fieldConfig.DisplayName}' 的寄存器数据为空"); return GetDefaultValue(fieldConfig.DataType); } if (string.IsNullOrEmpty(fieldConfig.DataType)) { Console.WriteLine($"[PARSER-ERROR] 字段 '{fieldConfig.DisplayName}' 的数据类型未定义"); return null; } try { return fieldConfig.DataType.ToLower() switch { "byte" => ParseByte(registers, fieldConfig), "integer" => ParseInteger(registers, fieldConfig), "string" => ParseString(registers, fieldConfig), "timestamp" => ParseTimestamp(registers, fieldConfig), "float" => ParseFloat(registers, fieldConfig), "boolean" => ParseBoolean(registers, fieldConfig), _ => throw new NotSupportedException($"不支持的数据类型: {fieldConfig.DataType}") }; } catch (Exception ex) { Console.WriteLine($"[PARSER-ERROR] 解析字段 '{fieldConfig.DisplayName}' 时发生错误: {ex.Message}"); Console.WriteLine($"[PARSER-ERROR] 堆栈跟踪: {ex.StackTrace}"); return GetDefaultValue(fieldConfig.DataType); } } #endregion #region 具体类型解析方法 /// /// 解析字节数据 /// private static byte ParseByte(int[] registers, DataField config) { if (registers.Length == 0) return 0; // 取第一个寄存器的低字节 var value = registers[0] & 0xFF; return (byte)value; } /// /// 解析整数数据(支持多寄存器和缩放) /// private static object ParseInteger(int[] registers, DataField config) { if (registers.Length == 0) return 0; long value = 0; if (config.Length == 1) { // 单寄存器 value = registers[0]; } else if (config.Length == 2) { // 双寄存器,根据字节序组合 if (config.Encoding?.ToLower() == "littleendian") { // 小端:低位在前 value = (registers[0] & 0xFFFF) | ((long)(registers[1] & 0xFFFF) << 16); } else { // 大端:高位在前(默认) value = ((long)(registers[0] & 0xFFFF) << 16) | (registers[1] & 0xFFFF); } // 检查是否为无效数据标识(如负值组合) if (value == 0xE2400001 || value > 0x7FFFFFFF) { // 可能是无效数据,返回0或使用特殊标识 return 0; } } else { // 多寄存器:按大端顺序组合 for (int i = 0; i < Math.Min(registers.Length, config.Length); i++) { value = (value << 16) | (registers[i] & 0xFFFF); } } // 应用缩放因子 if (config.Scale != 1.0 && config.Scale != 0.0) { var scaledValue = value * config.Scale; return Math.Round(scaledValue, config.DecimalPlaces); } return value; } /// /// 解析字符串数据 /// private static string ParseString(int[] registers, DataField config) { if (registers.Length == 0) return string.Empty; var bytes = new List(); foreach (var register in registers.Take(config.Length)) { if (config.Encoding?.ToLower() == "littleendian") { // 小端:低字节在前 bytes.Add((byte)(register & 0xFF)); bytes.Add((byte)((register >> 8) & 0xFF)); } else { // 大端:高字节在前(默认) // 注意:根据实际PLC数据,字节顺序是反的 var highByte = (byte)((register >> 8) & 0xFF); var lowByte = (byte)(register & 0xFF); // 先添加低字节,再添加高字节(适应PLC的字节序) if (lowByte != 0) bytes.Add(lowByte); if (highByte != 0) bytes.Add(highByte); } } // 移除尾部的空字符 while (bytes.Count > 0 && bytes[bytes.Count - 1] == 0) { bytes.RemoveAt(bytes.Count - 1); } return Encoding.ASCII.GetString(bytes.ToArray()); } /// /// 解析时间戳数据 /// private static DateTime ParseTimestamp(int[] registers, DataField config) { if (registers.Length == 0) return DateTime.MinValue; try { // 时间戳数据需要特殊解析(数字字符) var timestampString = ParseTimestampString(registers, config); if (string.IsNullOrEmpty(timestampString)) { return DateTime.MinValue; } // 根据格式解析时间戳 var format = config.Format ?? "YYYYMMDDHHMMSS"; return format.ToUpper() switch { "YYYYMMDDHHMMSS" => ParseTimestampYYYYMMDDHHMMSS(timestampString), "YYYYMMDDHHMM" => ParseTimestampYYYYMMDDHHMM(timestampString), "YYMMDDHHMMSS" => ParseTimestampYYMMDDHHMMSS(timestampString), _ => DateTime.TryParse(timestampString, out var dt) ? dt : DateTime.MinValue }; } catch (Exception ex) { Console.WriteLine($"[PARSER-ERROR] 解析时间戳失败: {ex.Message}"); return DateTime.MinValue; } } /// /// 解析浮点数数据 /// private static float ParseFloat(int[] registers, DataField config) { if (registers.Length < 2) return 0.0f; // IEEE 754单精度浮点数需要2个寄存器(32位) uint value; if (config.Encoding?.ToLower() == "littleendian") { value = (uint)(registers[0] | (registers[1] << 16)); } else { value = (uint)((registers[0] << 16) | registers[1]); } // 将32位整数转换为浮点数 return BitConverter.ToSingle(BitConverter.GetBytes(value), 0); } /// /// 解析布尔数据 /// private static bool ParseBoolean(int[] registers, DataField config) { if (registers.Length == 0) return false; // 非零值视为true return registers[0] != 0; } #endregion #region 时间戳解析辅助方法 /// /// 解析时间戳字符串(针对数字字符数据) /// private static string ParseTimestampString(int[] registers, DataField config) { if (registers.Length == 0) return string.Empty; var chars = new List(); foreach (var register in registers.Take(config.Length)) { if (register == 0) break; // 遇到0寄存器停止 // 提取高字节和低字节 var highByte = (byte)((register >> 8) & 0xFF); var lowByte = (byte)(register & 0xFF); // 按PLC数据格式添加字符(先低字节,后高字节) // 检查是否为数字字符(ASCII 48-57, '0'-'9') if (lowByte >= 48 && lowByte <= 57) { chars.Add((char)lowByte); } if (highByte >= 48 && highByte <= 57) { chars.Add((char)highByte); } } var result = new string(chars.ToArray()); return result; } /// /// 解析YYYYMMDDHHMMSS格式的时间戳 /// private static DateTime ParseTimestampYYYYMMDDHHMMSS(string timestampString) { if (timestampString.Length < 14) return DateTime.MinValue; var year = int.Parse(timestampString.Substring(0, 4)); var month = int.Parse(timestampString.Substring(4, 2)); var day = int.Parse(timestampString.Substring(6, 2)); var hour = int.Parse(timestampString.Substring(8, 2)); var minute = int.Parse(timestampString.Substring(10, 2)); var second = int.Parse(timestampString.Substring(12, 2)); return new DateTime(year, month, day, hour, minute, second); } /// /// 解析YYYYMMDDHHMM格式的时间戳 /// private static DateTime ParseTimestampYYYYMMDDHHMM(string timestampString) { if (timestampString.Length < 12) return DateTime.MinValue; var year = int.Parse(timestampString.Substring(0, 4)); var month = int.Parse(timestampString.Substring(4, 2)); var day = int.Parse(timestampString.Substring(6, 2)); var hour = int.Parse(timestampString.Substring(8, 2)); var minute = int.Parse(timestampString.Substring(10, 2)); return new DateTime(year, month, day, hour, minute, 0); } /// /// 解析YYMMDDHHMMSS格式的时间戳 /// private static DateTime ParseTimestampYYMMDDHHMMSS(string timestampString) { if (timestampString.Length < 12) return DateTime.MinValue; var year = 2000 + int.Parse(timestampString.Substring(0, 2)); // 假设是21世纪 var month = int.Parse(timestampString.Substring(2, 2)); var day = int.Parse(timestampString.Substring(4, 2)); var hour = int.Parse(timestampString.Substring(6, 2)); var minute = int.Parse(timestampString.Substring(8, 2)); var second = int.Parse(timestampString.Substring(10, 2)); return new DateTime(year, month, day, hour, minute, second); } #endregion #region 工具方法 /// /// 获取数据类型的默认值 /// /// 数据类型字符串 /// 默认值对象 private static object? GetDefaultValue(string? dataType) { if (string.IsNullOrEmpty(dataType)) return null; return dataType.ToLower() switch { "byte" => (byte)0, "integer" => 0, "string" => string.Empty, "timestamp" => DateTime.MinValue, "float" => 0.0f, "boolean" => false, _ => null }; } /// /// 格式化显示值(应用值映射和单位) /// /// 原始值 /// 字段配置 /// 格式化后的显示字符串 public static string FormatDisplayValue(object? value, DataField config) { if (value == null) { return "N/A"; } // 检查是否有值映射 if (config.ValueMap != null && config.ValueMap.Count > 0) { var key = value.ToString() ?? ""; if (config.ValueMap.TryGetValue(key, out var mappedValue)) { return mappedValue; } } // 格式化数值类型 var formattedValue = value switch { double d => d.ToString($"F{config.DecimalPlaces}"), float f => f.ToString($"F{config.DecimalPlaces}"), DateTime dt => dt.ToString("yyyy-MM-dd HH:mm:ss"), _ => value.ToString() }; // 添加单位 if (!string.IsNullOrEmpty(config.Unit)) { formattedValue += $" {config.Unit}"; } return formattedValue ?? ""; } /// /// 验证寄存器数据长度是否符合配置要求 /// /// 寄存器数据 /// 字段配置 /// 验证结果 public static bool ValidateRegisterLength(int[] registers, DataField config) { return registers != null && registers.Length >= config.Length; } #endregion } }