解决提升机在本层，而没有锁提升机的问题

zc

2025-05-07 fcb71b8fc63f74cd00d3faa76c73f4c5566ee352

 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);
        }
    }