#入库任务BUG修复

lsh

2024-06-06 ae0f47d70a1a4d539bf7cb0d69e0375d91ef3f7c

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -3,10 +3,7 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.model.LedSlave;
import com.zy.core.model.RgvSlave;
import com.zy.core.model.*;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.*;
import lombok.extern.slf4j.Slf4j;
@@ -60,7 +57,7 @@
        for (Slave crn : slaveProperties.getCrn()) {
            MessageQueue.init(SlaveType.Crn, crn);
        }
        // 初始化堆垛机mq
        // 初始化RGVmq
        for (Slave rgv : slaveProperties.getRgv()) {
            MessageQueue.init(SlaveType.Rgv, rgv);
        }
@@ -80,10 +77,18 @@
        for (Slave scale : slaveProperties.getScale()) {
            MessageQueue.init(SlaveType.Scale, scale);
        }
        // 初始化硫化罐mq
        for (Slave jar : slaveProperties.getJar()) {
            MessageQueue.init(SlaveType.Jar, jar);
        }
//        // 初始化台车mq
//        for (Slave car : slaveProperties.getCar()) {
//            MessageQueue.init(SlaveType.Car, car);
//        }
        // 初始化Stemq
        for (Slave ste : slaveProperties.getSte()) {
            MessageQueue.init(SlaveType.Ste, ste);
        }
    }

    private void initThread(){
@@ -125,6 +130,20 @@
            new Thread(ledThread).start();
            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
        }
        // 初始化jar线程
        log.info("初始化jar线程...................................................");
        for (JarSlave jar : slaveProperties.getJar()) {
            JarThread jarThread = new JarThread(jar);
            new Thread(jarThread).start();
            SlaveConnection.put(SlaveType.Jar, jar.getId(), jarThread);
        }
        // 初始化Ste线程
        log.info("初始化ste线程...................................................");
        for (SteSlave ste : slaveProperties.getSte()) {
            SteThread steThread = new SteThread(ste);
            new Thread(steThread).start();
            SlaveConnection.put(SlaveType.Ste, ste.getId(), steThread);
        }
        // 初始化磅秤线程
//        log.info("初始化磅秤线程...................................................");
//        for (Slave scale : slaveProperties.getScale()) {