#

lsh

2023-03-07 204e15023a4443ac2849f732763ee41ee2918f06

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

@@ -33,7 +33,7 @@
    @PostConstruct
    @Async
    public void init() throws InterruptedException {
        log.info("核心控制层开始初始化...............................................");
        News.info("核心控制层开始初始化...............................................");
        Thread.sleep(2000);
        // 初始化消息队列
        initMq();
@@ -41,7 +41,7 @@
        initThread();
        // 开始主流程进程
        mainProcess.start();
        log.info("核心控制层已启动...............................................");
        News.info("核心控制层已启动...............................................");
    }

    private void initMq(){
@@ -77,42 +77,42 @@

    private void initThread(){
        // 初始化堆垛机线程
        log.info("初始化堆垛机线程...................................................");
        News.info("初始化堆垛机线程...................................................");
        for (CrnSlave crn : slaveProperties.getCrn()) {
            CrnThread crnThread = new MelsecCrnThread(crn);
            CrnThread crnThread = new SiemensCrnThread(crn);
            new Thread((Runnable) crnThread).start();
            SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread);
        }
        // 初始化穿梭车线程
        log.info("初始化穿梭车线程...................................................");
        for (SteSlave crn : slaveProperties.getSte()) {
            SteThread steThread = new SteThread(crn);
            new Thread((Runnable) steThread).start();
            SlaveConnection.put(SlaveType.Ste, crn.getId(), steThread);
        News.info("初始化穿梭车线程...................................................");
        for (SteSlave ste : slaveProperties.getSte()) {
            SteThread steThread = new SteThread(ste);
            new Thread(steThread).start();
            SlaveConnection.put(SlaveType.Ste, ste.getId(), steThread);
        }
        // 初始化输送线线程
        log.info("初始化输送线线程...................................................");
        News.info("初始化输送线线程...................................................");
        for (DevpSlave devp : slaveProperties.getDevp()) {
            DevpThread devpThread = new SiemensDevpThread(devp);
            new Thread((Runnable) devpThread).start();
            SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread);
        }
        // 初始化条码扫描仪线程
        log.info("初始化条码扫描仪线程...................................................");
        News.info("初始化条码扫描仪线程...................................................");
        for (Slave barcode : slaveProperties.getBarcode()) {
            BarcodeThread barcodeThread = new BarcodeThread(barcode);
            new Thread(barcodeThread).start();
            SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread);
        }
        // 初始化LED线程
        log.info("初始化LED线程...................................................");
        News.info("初始化LED线程...................................................");
        for (LedSlave led : slaveProperties.getLed()) {
            LedThread ledThread = new LedThread(led);
            new Thread(ledThread).start();
            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
        }
        // 初始化磅秤线程
//        log.info("初始化磅秤线程...................................................");
//        News.info("初始化磅秤线程...................................................");
//        for (Slave scale : slaveProperties.getScale()) {
//            ScaleThread barcodeThread = new ScaleThread(scale);
//            new Thread(barcodeThread).start();