| File was renamed from src/main/java/com/zy/core/thread/CrnThread.java |
| | |
|---|
| | | import com.core.common.SpringUtils; |
|---|
| | | import com.zy.asrs.entity.BasCrnp; |
|---|
| | | import com.zy.asrs.service.BasCrnpService; |
|---|
| | | import com.zy.core.ThreadHandler; |
|---|
| | | import com.zy.core.CrnThread; |
|---|
| | | import com.zy.core.cache.MessageQueue; |
|---|
| | | import com.zy.core.cache.OutputQueue; |
|---|
| | | import com.zy.core.enums.CrnStatusType; |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Data |
|---|
| | | @Slf4j |
|---|
| | | public class CrnThread implements Runnable, ThreadHandler { |
|---|
| | | public class SiemensCrnThread implements Runnable, CrnThread { |
|---|
| | | |
|---|
| | | private SiemensS7Net siemensNet; |
|---|
| | | private CrnSlave slave; |
|---|
| | | private CrnProtocol crnProtocol; |
|---|
| | | private boolean resetFlag = false; |
|---|
| | | |
|---|
| | | public CrnThread(CrnSlave slave) { |
|---|
| | | public SiemensCrnThread(CrnSlave slave) { |
|---|
| | | this.slave = slave; |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | slave.setIp("192.168.6.9"); |
|---|
| | | slave.setRack(0); |
|---|
| | | slave.setSlot(0); |
|---|
| | | CrnThread crnThread = new CrnThread(slave); |
|---|
| | | SiemensCrnThread crnThread = new SiemensCrnThread(slave); |
|---|
| | | crnThread.connect(); |
|---|
| | | crnThread.readStatus(); |
|---|
| | | System.out.println(JSON.toJSONString(crnThread.crnProtocol)); |
|---|
