From 5cfb8af9e49dd2b455e728dc560aab7ecf610a68 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E2=80=9Chsc=E2=80=9D?= <“huangsucan@kaiyili-lab.com”> Date: Mon, 3 Aug 2026 09:18:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=8E=AF=E5=A2=83=E7=AE=B1?= =?UTF-8?q?=E9=A9=B1=E5=8A=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DeviceCommand/Devices/RLT1000.cs | 199 +++++++++++++++++++++++++++++++ 1 file changed, 199 insertions(+) create mode 100644 DeviceCommand/Devices/RLT1000.cs diff --git a/DeviceCommand/Devices/RLT1000.cs b/DeviceCommand/Devices/RLT1000.cs new file mode 100644 index 0000000..4048ea7 --- /dev/null +++ b/DeviceCommand/Devices/RLT1000.cs @@ -0,0 +1,199 @@ +using Common.Attributes; +using DeviceCommand.Base; +using System; +using System.Threading; +using System.Threading.Tasks; + +namespace DeviceCommand.Devices +{ + [ACPCommand] + public class RLT1000 : ModbusTcp + { + private const byte SlaveId = 1; + + #region 读取 + + public async Task 读取状态监控(CancellationToken ct = default) + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 5, 1, ct); + return re[0]; + } + + public async Task 读取当前温度(CancellationToken ct = default) + { + try + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 10, 2, ct); + return ConvertToFloat(re); + } + catch (Exception) + { + return 0; + } + } + + public async Task 读取当前湿度(CancellationToken ct = default) + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 16, 2, ct); + return ConvertToFloat(re); + } + + public async Task 读取当前水温(CancellationToken ct = default) + { + try + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 22, 2, ct); + return ConvertToFloat(re); + } + catch (Exception) + { + return 0; + } + } + + public async Task 读取当前1号水流量值(CancellationToken ct = default) + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 28, 2, ct); + return ConvertToFloat(re); + } + + public async Task 读取当前2号水流量值(CancellationToken ct = default) + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 34, 2, ct); + return ConvertToFloat(re); + } + + public async Task 读取当前3号水流量值(CancellationToken ct = default) + { + ushort[] re = await ReadHoldingRegistersAsync(SlaveId, 40, 2, ct); + return ConvertToFloat(re); + } + + #endregion + + #region 读写（控制命令） + + public async Task 切换为本地模式(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 147, 0, ct); + } + + public async Task 切换为远程模式(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 147, 1, ct); + } + + public async Task 远程模式关机(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 148, 0, ct); + } + + public async Task 远程模式开机(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 148, 1, ct); + } + + public async Task 远程模式复位结束(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 149, 0, ct); + } + + public async Task 远程模式复位(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 149, 1, ct); + } + + public async Task 切换为程序模式(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 153, 0, ct); + } + + public async Task 切换为定值模式(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 153, 1, ct); + } + + public async Task 定值温度设定(float 温度, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(温度); + await WriteMultipleRegistersAsync(SlaveId, 154, tmp, ct); + } + + public async Task 定值湿度设定(float 湿度, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(湿度); + await WriteMultipleRegistersAsync(SlaveId, 158, tmp, ct); + } + + public async Task 定值水温设定(float 水温, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(水温); + await WriteMultipleRegistersAsync(SlaveId, 162, tmp, ct); + } + + public async Task 定值1号水流量设定(float 水流量, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(水流量); + await WriteMultipleRegistersAsync(SlaveId, 164, tmp, ct); + } + + public async Task 定值2号水流量设定(float 水流量, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(水流量); + await WriteMultipleRegistersAsync(SlaveId, 166, tmp, ct); + } + + public async Task 定值3号水流量设定(float 水流量, CancellationToken ct = default) + { + var tmp = ConvertFromFloat(水流量); + await WriteMultipleRegistersAsync(SlaveId, 168, tmp, ct); + } + + public async Task 水温模式不使用(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 1181, 0, ct); + } + + public async Task 水温模式使用(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 1181, 1, ct); + } + + public async Task 环境箱温度模式不使用(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 1182, 0, ct); + } + + public async Task 环境箱温度模式使用(CancellationToken ct = default) + { + await WriteSingleRegisterAsync(SlaveId, 1182, 1, ct); + } + + #endregion + + #region 数据转换助手方法 + + private float ConvertToFloat(ushort[] values) + { + if (values == null || values.Length < 2) return 0f; + + byte[] bytes = new byte[4]; + bytes[3] = (byte)(values[0] >> 8); + bytes[2] = (byte)(values[0] & 0xFF); + bytes[1] = (byte)(values[1] >> 8); + bytes[0] = (byte)(values[1] & 0xFF); + return BitConverter.ToSingle(bytes, 0); + } + + private ushort[] ConvertFromFloat(float value) + { + byte[] bytes = BitConverter.GetBytes(value); + ushort[] result = new ushort[2]; + result[0] = (ushort)((bytes[3] << 8) | bytes[2]); + result[1] = (ushort)((bytes[1] << 8) | bytes[0]); + return result; + } + + #endregion + } +} \ No newline at end of file