From c80d68ee7d5ceb5f93289220a410737da3a7bf9f Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期二, 23 四月 2024 08:44:47 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/ssdwcs' into ssdwcs --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 29 ++++++++++++++++++++++++----- 1 files changed, 24 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index c4ae583..af46969 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -29,13 +29,11 @@ import com.zy.core.model.command.LedCommand; import com.zy.core.model.command.RgvCommand; import com.zy.core.model.protocol.CrnProtocol; +import com.zy.core.model.protocol.ExtProtocol; import com.zy.core.model.protocol.RgvProtocol; import com.zy.core.model.protocol.StaProtocol; import com.zy.core.properties.SlaveProperties; -import com.zy.core.thread.BarcodeThread; -import com.zy.core.thread.LedThread; -import com.zy.core.thread.SiemensDevpThread; -import com.zy.core.thread.SiemensRgvThread; +import com.zy.core.thread.*; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -87,7 +85,6 @@ for (RgvSlave rgv : slaveProperties.getRgv()) { if (!rgv.getDemo()){ continue; - } SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId()); StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo()); @@ -361,6 +358,28 @@ } } + public synchronized void ExtTaskAndPut() throws InterruptedException { + for (ExtSlave extSlave : slaveProperties.getExt()) { +// if (!rgv.getDemo()) { +// continue; +// } + MelsecExtThread extThread = (MelsecExtThread) SlaveConnection.get(SlaveType.Ext, extSlave.getId()); + ExtProtocol extProtocol = extThread.getExtProtocol(); + if (extProtocol == null) { + continue; + } +// else { +// extProtocol = extProtocol.clone(); +// } + if (extProtocol.isTake()){//鍏佽鍙� + + }else if (extProtocol.isPut()){//鍏佽鏀� + + } + + } + } + } -- Gitblit v1.9.1