| | |
| | | import com.zy.core.enums.SlaveType; |
| | | import com.zy.core.model.CrnSlave; |
| | | import com.zy.core.model.DevpSlave; |
| | | import com.zy.core.model.LedSlave; |
| | | import com.zy.core.properties.SlaveProperties; |
| | | import com.zy.core.thread.*; |
| | | import com.zy.core.thread.BarcodeThread; |
| | | import com.zy.core.thread.SiemensCrnThread; |
| | | import com.zy.core.thread.SiemensDevpThread; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Async; |
| | |
| | | private SlaveProperties slaveProperties; |
| | | @Autowired |
| | | private MainProcess mainProcess; |
| | | @Autowired |
| | | private CPMainProcess cpMainProcess; |
| | | |
| | | |
| | | /** |
| | | * PostConstruct会在加载servlet的时候运行一次 |
| | |
| | | initThread(); |
| | | // 开始主流程进程 |
| | | mainProcess.start(); |
| | | cpMainProcess.start(); |
| | | |
| | | log.info("核心控制层已启动..............................................."); |
| | | } |
| | | |
| | | private void initMq(){ |
| | | private void initMq() { |
| | | // 初始化堆垛机mq |
| | | for (Slave crn : slaveProperties.getCrn()) { |
| | | MessageQueue.init(SlaveType.Crn, crn); |
| | |
| | | // } |
| | | } |
| | | |
| | | private void initThread(){ |
| | | private void initThread() { |
| | | // 初始化堆垛机线程 |
| | | log.info("初始化堆垛机线程..................................................."); |
| | | for (CrnSlave crn : slaveProperties.getCrn()) { |