|  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private MainProcess mainProcess; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * PostConstruct会在加载servlet的时候运行一次 | 
|---|
|  |  |  | * @throws InterruptedException | 
|---|
|  |  |  | 
|---|
|  |  |  | initThread(); | 
|---|
|  |  |  | // 开始主流程进程 | 
|---|
|  |  |  | mainProcess.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()) { | 
|---|