| | |
| | | import com.zy.core.model.DevpSlave; |
| | | import com.zy.core.model.LedSlave; |
| | | import com.zy.core.properties.SlaveProperties; |
| | | import com.zy.core.thread.CarThread; |
| | | import com.zy.core.thread.CrnThread; |
| | | import com.zy.core.thread.DevpThread; |
| | | import com.zy.core.thread.LedThread; |
| | |
| | | for (Slave scale : slaveProperties.getScale()) { |
| | | MessageQueue.init(SlaveType.Scale, scale); |
| | | } |
| | | // 初始化台车mq |
| | | for (Slave car : slaveProperties.getCar()) { |
| | | MessageQueue.init(SlaveType.Car, car); |
| | | } |
| | | } |
| | | |
| | | private void initThread(){ |
| | |
| | | } |
| | | |
| | | // // 初始化条码扫描仪线程 |
| | | // log.info("初始化条码扫描仪线程..................................................."); |
| | | // for (Slave barcode : slaveProperties.getBarcode()) { |
| | | // BarcodeThread barcodeThread = new BarcodeThread(barcode); |
| | | // new Thread(barcodeThread).start(); |
| | |
| | | new Thread(ledThread).start(); |
| | | SlaveConnection.put(SlaveType.Led, led.getId(), ledThread); |
| | | } |
| | | |
| | | // 初始化台车线程 |
| | | log.info("初始化台车线程..................................................."); |
| | | for (Slave car : slaveProperties.getCar()) { |
| | | CarThread carThread = new CarThread(car); |
| | | new Thread(carThread).start(); |
| | | SlaveConnection.put(SlaveType.Car, car.getId(), carThread); |
| | | } |
| | | } |
| | | |
| | | |