|  |  |  | 
|---|
|  |  |  | for (Slave devp : slaveProperties.getDevp()) { | 
|---|
|  |  |  | MessageQueue.init(SlaveType.Devp, devp); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (Slave devp2 : slaveProperties.getDevp2()) { | 
|---|
|  |  |  | MessageQueue.init(SlaveType.Devp2, devp2); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 初始化条码扫描仪mq | 
|---|
|  |  |  | for (Slave barcode : slaveProperties.getBarcode()) { | 
|---|
|  |  |  | MessageQueue.init(SlaveType.Barcode, barcode); | 
|---|
|  |  |  | 
|---|
|  |  |  | new Thread((Runnable) devpThread).start(); | 
|---|
|  |  |  | SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (Devp2Slave devp2 : slaveProperties.getDevp2()) { | 
|---|
|  |  |  | SiemensDevpThread2 siemensDevpThread2 = new SiemensDevpThread2(devp2); | 
|---|
|  |  |  | new Thread(siemensDevpThread2).start(); | 
|---|
|  |  |  | SlaveConnection.put(SlaveType.Devp2, devp2.getId(), siemensDevpThread2); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 初始化提升机 | 
|---|
|  |  |  | News.info("初始化提升机........................................................"); | 
|---|
|  |  |  | for (LiftSlave liftSlave : slaveProperties.getLift()) { | 
|---|
|  |  |  | 
|---|
|  |  |  | // 初始化四向穿梭车 | 
|---|
|  |  |  | News.info("初始化四向穿梭车......................................................"); | 
|---|
|  |  |  | for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) { | 
|---|
|  |  |  | ShuttleThread shuttleThread = new ShuttleThread(shuttleSlave,redisUtil); | 
|---|
|  |  |  | NyShuttleThread shuttleThread = new NyShuttleThread(shuttleSlave,redisUtil); | 
|---|
|  |  |  | new Thread(shuttleThread).start(); | 
|---|
|  |  |  | SlaveConnection.put(SlaveType.Shuttle, shuttleSlave.getId(), shuttleThread); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | News.info("初始化条码扫描仪线程..................................................."); | 
|---|
|  |  |  | for (Slave barcode : slaveProperties.getBarcode()) { | 
|---|
|  |  |  | BarcodeThread barcodeThread = new BarcodeThread(barcode); | 
|---|
|  |  |  | new Thread(barcodeThread).start(); | 
|---|
|  |  |  | if (barcode.getId() >= 11) { | 
|---|
|  |  |  | new Thread(barcodeThread).start(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 初始化LED线程 | 
|---|