src/main/java/com/zy/core/ServerBootstrap.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/core/properties/SlaveProperties.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/core/ServerBootstrap.java
@@ -2,6 +2,7 @@ import com.core.common.Cools; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.SlaveType; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.CrnThread; import com.zy.core.thread.DevpThread; @@ -32,20 +33,16 @@ private void initThread(){ // 初始化堆垛机线程 if (!Cools.isEmpty(slaveProperties.getCrn())) { for (Slave crn : slaveProperties.getCrn()) { CrnThread crnThread = new CrnThread(crn); new Thread(crnThread).start(); SlaveConnection.put(ThreadHandler.CRN_PREFIX + crn.getId(), crnThread); } for (Slave crn : slaveProperties.getCrn()) { CrnThread crnThread = new CrnThread(crn); new Thread(crnThread).start(); SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread); } // 初始化站点线程 if (!Cools.isEmpty(slaveProperties.getDevp())) { for (Slave devo : slaveProperties.getDevp()) { DevpThread devpThread = new DevpThread(devo); new Thread(devpThread).start(); } for (Slave devo : slaveProperties.getDevp()) { DevpThread devpThread = new DevpThread(devo); new Thread(devpThread).start(); } } src/main/java/com/zy/core/properties/SlaveProperties.java
@@ -5,6 +5,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Configuration; import java.util.ArrayList; import java.util.List; /** @@ -15,14 +16,14 @@ @ConfigurationProperties(prefix = "wcs-slave") public class SlaveProperties { private List<Slave> crn; private List<Slave> crn = new ArrayList<>(); private List<Slave> devp; private List<Slave> devp = new ArrayList<>(); private List<Slave> barcode; private List<Slave> barcode = new ArrayList<>(); private List<Slave> led; private List<Slave> led = new ArrayList<>(); private List<Slave> scale; private List<Slave> scale = new ArrayList<>(); }