From 1740200255e5eac1f4816331b424c29a5d345d87 Mon Sep 17 00:00:00 2001
From: zhou zhou <3272660260@qq.com>
Date: 星期二, 13 一月 2026 14:35:58 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/ServerBootstrap.java |   19 +++++++++++++++++++
 1 files changed, 19 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index b37b6b3..4660033 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -6,9 +6,11 @@
 import com.zy.core.model.CrnSlave;
 import com.zy.core.model.DevpSlave;
 import com.zy.core.model.LedSlave;
+import com.zy.core.model.RFIDSlave;
 import com.zy.core.properties.SlaveProperties;
 import com.zy.core.thread.BarcodeThread;
 import com.zy.core.thread.LedThread;
+import com.zy.core.thread.RFIDThread;
 import com.zy.core.thread.SiemensCrnThread;
 import com.zy.core.thread.SiemensDevpThread;
 import com.zy.utils.News;
@@ -75,6 +77,10 @@
         for (Slave led : slaveProperties.getLed()) {
             MessageQueue.init(SlaveType.Led, led);
         }
+        // 鍒濆鍖朢FID璇诲啓鍣╩q
+        for (Slave rfid : slaveProperties.getRfid()) {
+            MessageQueue.init(SlaveType.Rfid, rfid);
+        }
         // 鍒濆鍖栫绉癿q
 //        for (Slave scale : slaveProperties.getScale()) {
 //            MessageQueue.init(SlaveType.Scale, scale);
@@ -121,6 +127,19 @@
             new Thread(ledThread).start();
             SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
         }
+        // 鍒濆鍖朢FID璇诲啓鍣ㄧ嚎绋�
+        // 娉ㄦ剰锛氬鏋淩FID璁惧閰嶇疆浜哸utoConnect=true锛屽皢鐢盧FIDAutoConnectService绠$悊锛岃繖閲岃烦杩�
+        News.info("鍒濆鍖朢FID璇诲啓鍣ㄧ嚎绋�...................................................");
+        for (RFIDSlave rfid : slaveProperties.getRfid()) {
+            // 濡傛灉鍚敤浜嗚嚜鍔ㄨ繛鎺ワ紝璺宠繃RFIDThread鐨勫垱寤猴紙鐢盧FIDAutoConnectService绠$悊锛�
+            if (rfid.getAutoConnect() != null && rfid.getAutoConnect()) {
+                News.info("RFID璁惧[{}]宸插惎鐢ㄨ嚜鍔ㄨ繛鎺ワ紝璺宠繃RFIDThread鍒濆鍖�", rfid.getId());
+                continue;
+            }
+            RFIDThread rfidThread = new RFIDThread(rfid);
+            new Thread(rfidThread).start();
+            SlaveConnection.put(SlaveType.Rfid, rfid.getId(), rfidThread);
+        }
         // 鍒濆鍖栫绉ょ嚎绋�
 //        News.info("鍒濆鍖栫绉ょ嚎绋�...................................................");
 //        for (Slave scale : slaveProperties.getScale()) {

--
Gitblit v1.9.1