From 770d716304e32d4da8e74bb70c8907d7e0fd922b Mon Sep 17 00:00:00 2001 From: 野心家 <1051256694@qq.com> Date: 星期二, 24 十二月 2024 16:19:12 +0800 Subject: [PATCH] 完善wcs --- src/main/java/com/zy/core/ServerBootstrap.java | 31 ++++++++++++++++--------------- 1 files changed, 16 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java index a97d9a0..d7e9ccd 100644 --- a/src/main/java/com/zy/core/ServerBootstrap.java +++ b/src/main/java/com/zy/core/ServerBootstrap.java @@ -1,5 +1,6 @@ package com.zy.core; +import com.zy.common.utils.News; import com.zy.core.cache.MessageQueue; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.SlaveType; @@ -75,39 +76,39 @@ private void initThread(){ // 鍒濆鍖栧爢鍨涙満绾跨▼ - log.info("鍒濆鍖栧爢鍨涙満绾跨▼..................................................."); + News.info("鍒濆鍖栧爢鍨涙満绾跨▼..................................................."); for (CrnSlave crn : slaveProperties.getCrn()) { CrnThread crnThread = new SiemensCrnThread(crn); new Thread((Runnable) crnThread).start(); SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread); } // 鍒濆鍖栬緭閫佺嚎绾跨▼ - 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); } -// // 鍒濆鍖朙ED绾跨▼ -// log.info("鍒濆鍖朙ED绾跨▼..................................................."); -// for (LedSlave led : slaveProperties.getLed()) { -// LedThread ledThread = new LedThread(led); -// new Thread(ledThread).start(); -// SlaveConnection.put(SlaveType.Led, led.getId(), ledThread); -// } -// // 鍒濆鍖栫绉ょ嚎绋� -// log.info("鍒濆鍖栫绉ょ嚎绋�..................................................."); + // 鍒濆鍖朙ED绾跨▼ + News.info("鍒濆鍖朙ED绾跨▼..................................................."); + for (LedSlave led : slaveProperties.getLed()) { + LedThread ledThread = new LedThread(led); + new Thread(ledThread).start(); + SlaveConnection.put(SlaveType.Led, led.getId(), ledThread); + } + // 鍒濆鍖栫绉ょ嚎绋� +// News.info("鍒濆鍖栫绉ょ嚎绋�..................................................."); // for (Slave scale : slaveProperties.getScale()) { -// ScaleThread scaleThread = new ScaleThread(scale); -// new Thread(scaleThread).start(); -// SlaveConnection.put(SlaveType.Scale, scale.getId(), scaleThread); +// ScaleThread barcodeThread = new ScaleThread(scale); +// new Thread(barcodeThread).start(); +// SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread); // } } -- Gitblit v1.9.1