From 6b53373bf1cc50b18b0a5d17d8e7e25118068640 Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期二, 13 一月 2026 14:23:52 +0800
Subject: [PATCH] rfid调试正常代码

---
 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