From fcb71b8fc63f74cd00d3faa76c73f4c5566ee352 Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期三, 07 五月 2025 23:23:09 +0800
Subject: [PATCH] 解决提升机在本层，而没有锁提升机的问题
---
src/main/java/com/zy/core/ServerBootstrap.java | 26 ++++++++++----------------
1 files changed, 10 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java
index e93b49b..c824e07 100644
--- a/src/main/java/com/zy/core/ServerBootstrap.java
+++ b/src/main/java/com/zy/core/ServerBootstrap.java
@@ -5,10 +5,7 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
-import com.zy.core.model.DevpSlave;
-import com.zy.core.model.ForkLiftSlave;
-import com.zy.core.model.LiftSlave;
-import com.zy.core.model.ShuttleSlave;
+import com.zy.core.model.*;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.impl.*;
import lombok.extern.slf4j.Slf4j;
@@ -60,6 +57,10 @@
// 鍒濆鍖栧洓鍚戠┛姊溅mq
for (Slave shuttle : slaveProperties.getShuttle()) {
MessageQueue.init(SlaveType.Shuttle, shuttle);
+ }
+ // 鍒濆鍖栬緭閫佺嚎mq
+ for (Slave devp : slaveProperties.getDevp()) {
+ MessageQueue.init(SlaveType.Devp, devp);
}
}
@@ -122,7 +123,7 @@
SlaveConnection.put(SlaveType.Shuttle, shuttleSlave.getId(), thread);
}
// 鍒濆鍖栬緭閫佺嚎
- for (DevpSlave devpSlave : slaveProperties.getDevpSlave()) {
+ for (DevpSlave devpSlave : slaveProperties.getDevp()) {
News.info("鍒濆鍖栬緭閫佺嚎......................................................");
ThreadHandler thread = null;
if (devpSlave.getThreadImpl().equals("FyDevpThread")) {
@@ -130,23 +131,16 @@
} else {
throw new CoolException("鏈煡鐨勭嚎绋嬪疄鐜�");
}
-
new Thread(thread).start();
- SlaveConnection.put(SlaveType.Shuttle, devpSlave.getId(), thread);
+ SlaveConnection.put(SlaveType.Devp, devpSlave.getId(), thread);
}
// 鍒濆鍖栫數瑙嗘満
- for (DevpSlave devpSlave : slaveProperties.getL()) {
+ for (LedSlave ledSlave : slaveProperties.getLed()) {
News.info("鍒濆鍖栫數瑙嗘満......................................................");
- ThreadHandler thread = null;
- if (devpSlave.getThreadImpl().equals("FyDevpThread")) {
- thread = new FyDevpThread(devpSlave);
- } else {
- throw new CoolException("鏈煡鐨勭嚎绋嬪疄鐜�");
- }
-
+ ThreadHandler thread = new NormalLedThread(ledSlave);
new Thread(thread).start();
- SlaveConnection.put(SlaveType.Shuttle, devpSlave.getId(), thread);
+ SlaveConnection.put(SlaveType.Led, ledSlave.getId(), thread);
}
}
--
Gitblit v1.9.1