Service/ModbusTcpPlcService.cs

@@ -1,7 +1,8 @@
-using System;
+using Modbus.Device;
+using System;
+using System.Net;
 using System.Net.Sockets;
 using System.Threading.Tasks;
-using Modbus.Device;
 
 namespace MembranePoreTester.Communication
 {
@@ -30,31 +31,19 @@ namespace MembranePoreTester.Communication
         private async Task<float> ReadFloatAsync(ushort startAddress)
         {
             await EnsureConnectedAsync();
-
-            // 读取两个寄存器（从站地址由配置指定）
-            ushort[] registers = await _master.ReadHoldingRegistersAsync(_config.SlaveId, startAddress, 2);
-
-            // 将两个16位寄存器合并为32位浮点数（大端）
-            byte[] bytes = new byte[4];
-            bytes[0] = (byte)(registers[0] >> 8);
-            bytes[1] = (byte)(registers[0] & 0xFF);
-            bytes[2] = (byte)(registers[1] >> 8);
-            bytes[3] = (byte)(registers[1] & 0xFF);
-
-            if (BitConverter.IsLittleEndian)
-                Array.Reverse(bytes); // 如果系统是小端，需要反转字节顺序
-
-            return BitConverter.ToSingle(bytes, 0);
+            var registers = await ReadHoldingRegistersAsync(startAddress, 2);
+            return UshortToFloat(registers[1], registers[0]);
         }
 
+
         public async Task<float> ReadPressureAsync() =>
-            await ReadFloatAsync(_config.PressureRegister) * (float)_config.PressureFactor;
+            await ReadFloatAsync(_config.PressureRegister);
 
         public async Task<float> ReadWetFlowAsync() =>
-            await ReadFloatAsync(_config.WetFlowRegister) * (float)_config.WetFlowFactor;
+            await ReadFloatAsync(_config.WetFlowRegister);
 
         public async Task<float> ReadDryFlowAsync() =>
-            await ReadFloatAsync(_config.DryFlowRegister) * (float)_config.DryFlowFactor;
+            await ReadFloatAsync(_config.DryFlowRegister);
 
 
         public async Task WriteCoilAsync(ushort coilAddress, bool value)
@@ -73,7 +62,7 @@ namespace MembranePoreTester.Communication
         public async Task<bool> ReadCoilAsync(ushort coilAddress)
         {
             await EnsureConnectedAsync();
-            bool[] result = await _master.ReadCoilsAsync(_config.SlaveId, coilAddress, 1);
+            bool[] result = await _master?.ReadCoilsAsync(_config.SlaveId, coilAddress, 1);
             return result[0];
         }
 
@@ -87,9 +76,65 @@ namespace MembranePoreTester.Communication
         public async Task WriteSingleRegisterAsync(ushort registerAddress, ushort value)
         {
             await EnsureConnectedAsync();
-            await _master.WriteSingleRegisterAsync(_config.SlaveId, registerAddress, value);
+            int val = (int)value;
+            await _master.WriteMultipleRegistersAsync(1, registerAddress, intToushorts(val));
         }
 
+        public async Task WriteMultipleRegistersAsync(ushort registerAddress, float value)
+        {
+            await EnsureConnectedAsync();
+            await _master.WriteMultipleRegistersAsync(_config.SlaveId, registerAddress, SplitFloatToUShortArray((float)value));
+        }
+
+        /// <summary>
+        /// Int转为ushort数组发送
+        /// </summary>
+        /// <param name="res"></param>
+        /// <returns>返回ushort数组</returns>
+        private ushort[] intToushorts(int res)
+        {
+            ushort ust1 = (ushort)(res >> 16);
+            ushort ust2 = (ushort)res;
+            return new ushort[] { ust2, ust1 };
+        }
+
+
+        /// <summary>
+        /// Float转为Ushort数组发送
+        /// </summary>
+        /// <param name="value"></param>
+        /// <returns>返回ushort数组</returns>
+        public ushort[] SplitFloatToUShortArray(float value)
+        {
+            byte[] floatBytes = BitConverter.GetBytes(value);
+            ushort[] ushortArray = new ushort[floatBytes.Length / 2];
+
+            for (int i = 0, j = 0; i < floatBytes.Length; i += 2, j++)
+            {
+                ushortArray[j] = BitConverter.ToUInt16(floatBytes, i);
+            }
+
+            return ushortArray;
+        }
+
+        /// <summary>
+        /// ushort转为float类型
+        /// </summary>
+        /// <param name="P1"></param>
+        /// <param name="P2"></param>
+        /// <returns>float型数据</returns>
+        public float UshortToFloat(ushort P1, ushort P2)
+        {
+            int intSign, intSignRest, intExponent, intExponentRest;
+            float faResult, faDigit;
+            intSign = P1 / 32768;
+            intSignRest = P1 % 32768;
+            intExponent = intSignRest / 128;
+            intExponentRest = intSignRest % 128;
+            faDigit = (float)(intExponentRest * 65536 + P2) / 8388608;
+            faResult = (float)Math.Pow(-1, intSign) * (float)Math.Pow(2, intExponent - 127) * (faDigit + 1);
+            return faResult;
+        }
 
         // 新增读取压力（根据工位）
         public async Task<float> ReadPressureAsync(int stationId)