修复测点映射失效bug

Author: 600888

src/device/core/data/data_reader.py

@@ -56,12 +56,12 @@ def _log(self):
     def _get_change_source(self) -> ChangeSource:
         """根据协议处理器类型获取变更来源
 
-        服务端设备：外部客户端通过协议写入，属于协议远程修改
-        客户端设备：从远程服务器读取数据变化，属于客户端读取
+        服务端设备：get_slave_values 是从自己的内存寄存器读取值，
+                  不是远程修改，应使用 INTERNAL。
+                  真正的远程客户端写入通过 _on_modbus_client_write 回调处理。
+        客户端设备：从远程服务器读取数据变化，属于客户端读取。
         """
-        if isinstance(self._handler, ServerHandler):
-            return ChangeSource.PROTOCOL
-        elif isinstance(self._handler, ClientHandler):
+        if isinstance(self._handler, ClientHandler):
             return ChangeSource.CLIENT_READ
         return ChangeSource.INTERNAL
 

src/device/protocol/modbus_handler.py

@@ -134,7 +134,7 @@ def write_value(self, point: BasePoint, value: Any) -> bool:
             self._server.setValueByAddress(
                 point.func_code, slave_id, point.address, write_val, point.decode
             )
-            self._log.info(f"Modbus 客户端写入测点 {point.code} 成功: value={write_val}")
+            self._log.info(f"写入测点 {point.code} 成功: value={write_val}")
             return True
 
         return False

src/device_controller.py

@@ -188,18 +188,6 @@ async def import_device_from_db(self):
                 )
                 general_device.name = channel_name
 
-                # 仅服务端自动启动数据更新线程（用于同步内存变更）
-                # 客户端需要手动开启或点击自动读取，避免自动轮询外部设备
-                is_client = channel_protocol_type in [
-                    ProtocolType.ModbusTcpClient,
-                    ProtocolType.Iec104Client,
-                    ProtocolType.Dlt645Client,
-                    ProtocolType.Iec61850Client,
-                ]
-                
-                if not is_client:
-                    general_device.data_update_thread.start()
-                
                 self.device_list.append(general_device)
                 self.device_map[general_device.name] = general_device
 

src/proto/pyModbus/server/modbus_server.py

@@ -556,8 +556,11 @@ def setValueByAddress(
                 registers[0] = ((registers[0] & 0xFF) << 8) | ((registers[0] >> 8) & 0xFF)
 
         # 设置寄存器值
-        if func_code == 10:
-            func_code = 6
+        # 遥测点 func_code=3 (读保持寄存器) 写入时需要转为 func_code=6 (写单寄存器)
+        # 遥调点 func_code=6 (写单寄存器) 直接使用
+        # func_code=10/16 (写多寄存器) 转为 func_code=3
+        if func_code in (3, 10, 16):
+            func_code = 3
 
         slave_ctx = self.slaves[rtu_addr]
         if isinstance(slave_ctx, CallbackDeviceContext):

src/web/channel/channel_controller.py

@@ -392,7 +392,17 @@ async def create_and_start_device(req: CreateAndStartDeviceRequest, request: Req
             is_start=True,
         )
         general_device.name = channel_name
-        general_device.data_update_thread.start()
+        
+        # 仅客户端设备启动数据更新线程（从远程服务器读取数据）
+        # 服务端设备不需要，因为数据由用户手动设置或远程客户端写入
+        is_client = channel_protocol_type in [
+            ProtocolType.ModbusTcpClient,
+            ProtocolType.Iec104Client,
+            ProtocolType.Dlt645Client,
+            ProtocolType.Iec61850Client,
+        ]
+        if is_client:
+            general_device.data_update_thread.start()
 
         # 添加到设备控制器
         device_controller = request.app.state.device_controller
@@ -598,7 +608,14 @@ async def _reload_device_instance(device_controller, channel_id: int, is_start:
     )
     new_device.name = device_name
 
-    if is_start:
+    # 仅客户端设备启动数据更新线程
+    is_client = channel_protocol_type in [
+        ProtocolType.ModbusTcpClient,
+        ProtocolType.Iec104Client,
+        ProtocolType.Dlt645Client,
+        ProtocolType.Iec61850Client,
+    ]
+    if is_start and is_client:
         new_device.data_update_thread.start()
 
     device_controller.device_list.append(new_device)