| | |
| | | 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.properties.SlaveProperties; |
| | | import com.zy.core.thread.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | for (Slave barcode : slaveProperties.getBarcode()) { |
| | | MessageQueue.init(SlaveType.Barcode, barcode); |
| | | } |
| | | // 初始化Rgv mq |
| | | for (Slave rgv : slaveProperties.getRgv()) { |
| | | MessageQueue.init(SlaveType.Rgv, rgv); |
| | | } |
| | | // // 初始化Led灯mq |
| | | // for (Slave led : slaveProperties.getLed()) { |
| | | // MessageQueue.init(SlaveType.Led, led); |
| | |
| | | // new Thread(barcodeThread).start(); |
| | | SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread); |
| | | } |
| | | // 初始化穿梭车线程 |
| | | log.info("初始化RGV线程..................................................."); |
| | | for (RgvSlave rgv : slaveProperties.getRgv()) { |
| | | RgvThread rgvThread = new RgvThread(rgv); |
| | | new Thread((Runnable) rgvThread).start(); |
| | | SlaveConnection.put(SlaveType.Rgv, rgv.getId(), rgvThread); |
| | | } |
| | | // // 初始化LED线程 |
| | | // log.info("初始化LED线程..................................................."); |
| | | // for (LedSlave led : slaveProperties.getLed()) { |