增加了上料斗变送器读取，显示到界面，更新间隔为5秒

controller/main_controller.py

@@ -33,17 +33,18 @@ class MainController:
     def _onTimer(self):
         # 定时任务逻辑
         # 变送器是 192.168.250.63，端口 502
-        loc_tra=TransmitterController(RelayController(host="192.168.250.63", port=502))
-        upper_weight=loc_tra.read_data(1)
-        lower_weight=loc_tra.read_data(2)
-        if upper_weight is None:
-            upper_weight=0
-        
-        if lower_weight is None:
-            lower_weight=0
-            
+        loc_tra=TransmitterController(RelayController())
+        upper_weight=loc_tra.read_data(1) # 目前只有上料斗安装了变送器
+        # lower_weight=loc_tra.read_data(2)
+        if upper_weight is not None:
+            # upper_weight=0
             self.main_window.hopper_widget.setUpperHopperWeight(upper_weight)
-        self.main_window.hopper_widget.setLowerHopperWeight(lower_weight)
+        
+        # if lower_weight is None:
+        #     lower_weight=0
+            
+        # self.main_window.hopper_widget.setUpperHopperWeight(upper_weight)
+        # self.main_window.hopper_widget.setLowerHopperWeight(lower_weight)
         # 重新启动定时器以实现重复执行
         self.timer = threading.Timer(5.0, self._onTimer)
         self.timer.start()

hardware/transmitter.py

@@ -20,7 +20,7 @@ class TransmitterController:
             }
         }
 
-    def read_data(self, transmitter_id):
+    def read_data_back(self, transmitter_id):
         """读取变送器数据"""
         try:
             if transmitter_id not in self.config:
@@ -67,3 +67,53 @@ class TransmitterController:
             return None
         finally:
             self.relay_controller.modbus_client.close()
+
+    # 直接读取 变送器返回的数据
+    def read_data(self, transmitter_id):
+        """
+            Args: transmitter_id 为1 表示上料斗, 为2 表示下料斗
+            return: 读取成功返回重量 weight: int, 失败返回 None
+        """
+        if transmitter_id == 1:
+            # 上料斗变送器的信息：
+            IP = "192.168.250.63"
+            PORT = 502
+            TIMEOUT = 5 # 超时时间为 5秒
+            weight = None
+
+            import socket
+            with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+                try:
+                    s.settimeout(TIMEOUT)
+                    s.connect((IP, PORT))
+                    print(f"✅ 连接 {IP}:{PORT} 成功")
+                    
+                    # 接收数据（变送器主动推送，单次recv即可获取一条完整数据）
+                    data = s.recv(1024)
+                    if data:
+                        # print(f"收到原始数据：{data}")
+                        weight = self.parse_weight(data)
+                    else:
+                        print("❌ 未收到设备数据")
+                
+                except ConnectionRefusedError:
+                    print(f"❌ 连接失败：{IP}:{PORT} 拒绝连接（设备离线/端口错误）")
+                except socket.timeout:
+                    print(f"❌ 超时：{TIMEOUT}秒内未收到数据")
+                except Exception as e:
+                    print(f"❌ 读取异常：{e}")
+            
+            # 成功返回重量（int），失败返回None
+            return weight  
+
+    def parse_weight(raw_data):
+        """解析函数：提取重量数值（如从 b'ST,NT,+0000175\r\n' 中提取 175)"""
+        try:
+            data_str = raw_data.decode('utf-8').strip()
+            parts = data_str.split(',')
+            weight_part = parts[2].strip()
+            return int(''.join(filter(str.isdigit, weight_part)))
+        except (IndexError, ValueError, UnicodeDecodeError) as e:
+            # print(f"数据解析失败：{e}，原始数据：{raw_data}")
+            # 注意：可能会出现解析失败的情况，此时返回None，界面不用更新数据就行
+            return None