From dcc528dae89242366a86e8b3709479621b95b0c0 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期六, 22 六月 2024 13:48:09 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java | 38 ++++++++++++++++++++++++++++++++++++++
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SuopaiSiemensDevpThread.java | 12 +++++++-----
zy-asrs-flow/src/pages/device/conveyor/index.jsx | 2 --
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SiemensDevpThread.java | 2 +-
4 files changed, 46 insertions(+), 8 deletions(-)
diff --git a/zy-asrs-flow/src/pages/device/conveyor/index.jsx b/zy-asrs-flow/src/pages/device/conveyor/index.jsx
index 8c902d8..b3268ce 100644
--- a/zy-asrs-flow/src/pages/device/conveyor/index.jsx
+++ b/zy-asrs-flow/src/pages/device/conveyor/index.jsx
@@ -17,7 +17,6 @@
const [staNo, setStaNo] = useState(null);
useEffect(() => {
- console.log('yes');
connect();
return () => {
@@ -28,7 +27,6 @@
}, [])
useEffect(() => {
- console.log('yes');
if (ws) {
ws.onopen = function () {
console.log("open");
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
index 13cf97a..43aae13 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
@@ -3,11 +3,13 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zy.asrs.framework.common.Cools;
import com.zy.asrs.wcs.core.domain.dto.MotionDto;
+import com.zy.asrs.wcs.core.entity.BasConveyorPath;
import com.zy.asrs.wcs.core.entity.ShuttleStandby;
import com.zy.asrs.wcs.core.entity.Task;
import com.zy.asrs.wcs.core.model.enums.DeviceCtgType;
import com.zy.asrs.wcs.core.model.enums.MotionCtgType;
import com.zy.asrs.wcs.core.model.enums.TaskStsType;
+import com.zy.asrs.wcs.core.service.BasConveyorPathService;
import com.zy.asrs.wcs.core.service.ShuttleStandbyService;
import com.zy.asrs.wcs.core.service.TaskService;
import com.zy.asrs.wcs.core.utils.ConveyorDispatcher;
@@ -53,6 +55,8 @@
private DeviceService deviceService;
@Autowired
private ShuttleStandbyService shuttleStandbyService;
+ @Autowired
+ private BasConveyorPathService basConveyorPathService;
public List<Motion> generateMotion(Task task) {
List<Motion> motionList = new ArrayList<>();
@@ -492,6 +496,14 @@
//绌挎杞﹀嚭鎻愬崌鏈哄悗灏忚溅寰呮満浣�
String shuttleFromLiftStandbyLoc = shuttleStandbyFrom.getStandbyLoc();
+ //鑾峰彇杈撻�佺嚎璺緞
+ BasConveyorPath basConveyorPath = basConveyorPathService.getOne(new LambdaQueryWrapper<BasConveyorPath>()
+ .eq(BasConveyorPath::getDeviceStn, task.getOriginSite())
+ .eq(BasConveyorPath::getDeviceNo, liftProtocol.getLiftNo()));
+ if (basConveyorPath == null) {
+ return motionList;
+ }
+
/**
* 鍑哄簱
* 涓�銆佸嚭搴撹捣濮嬪眰鏈夌┛姊溅
@@ -630,6 +642,19 @@
dto.setLocNo(shuttleFromLiftStandbyLoc);
})),
MotionCtgType.SHUTTLE_MOVE
+ ));
+
+ // 杈撻�佺嚎杩愯緭鑷冲嚭搴撳彛
+ motionList.addAll(kernelService.conveyorOutbound(
+ MotionDto.build((dto -> {
+ dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+ dto.setStaNo(basConveyorPath.getDeviceStn());
+ })),
+ MotionDto.build((dto -> {
+ dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+ dto.setStaNo(basConveyorPath.getStnNo());
+ })),
+ MotionCtgType.CONVEYOR_OUTBOUND
));
/**
@@ -877,6 +902,19 @@
MotionCtgType.SHUTTLE_MOVE
));
+ // 杈撻�佺嚎杩愯緭鑷冲嚭搴撳彛
+ motionList.addAll(kernelService.conveyorOutbound(
+ MotionDto.build((dto -> {
+ dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+ dto.setStaNo(basConveyorPath.getDeviceStn());
+ })),
+ MotionDto.build((dto -> {
+ dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+ dto.setStaNo(basConveyorPath.getStnNo());
+ })),
+ MotionCtgType.CONVEYOR_OUTBOUND
+ ));
+
}
}
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SiemensDevpThread.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SiemensDevpThread.java
index 19a8a14..e4f79c6 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SiemensDevpThread.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SiemensDevpThread.java
@@ -251,7 +251,7 @@
}
@Override
- public boolean writeWorkSta(int siteId, short staNo, short workNo) {
+ public boolean writeWorkSta(int siteId, short workNo, short staNo) {
int index = findStaNosIndex(siteId);
OperateResult write1 = siemensS7Net.Write("DB100." + index*6, workNo); // 宸ヤ綔鍙�
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SuopaiSiemensDevpThread.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SuopaiSiemensDevpThread.java
index 811346c..63f85b3 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SuopaiSiemensDevpThread.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/SuopaiSiemensDevpThread.java
@@ -192,7 +192,7 @@
public boolean writeWorkNo(int siteId, short workNo) {
int index = findStaNosIndex(siteId);
- OperateResult write = siemensS7Net.Write("DB100." + index*6, workNo); // 宸ヤ綔鍙�
+ OperateResult write = siemensS7Net.Write("DB1001." + (index * 20 + 100 + 2), workNo); // 宸ヤ綔鍙�
if (!write.IsSuccess) {
StaProtocol staProtocol = station.get(siteId);
@@ -213,7 +213,7 @@
public boolean writeStaNo(int siteId,short staNo) {
int index = findStaNosIndex(siteId);
- OperateResult write = siemensS7Net.Write("DB100." + (index*6+4), staNo); // 鐩爣绔�
+ OperateResult write = siemensS7Net.Write("DB1001." + (index * 20 + 100 + 4), staNo); // 鐩爣绔�
if (!write.IsSuccess) {
StaProtocol staProtocol = station.get(siteId);
@@ -231,11 +231,13 @@
}
@Override
- public boolean writeWorkSta(int siteId, short staNo, short workNo) {
+ public boolean writeWorkSta(int siteId, short workNo, short staNo) {
int index = findStaNosIndex(siteId);
- OperateResult write1 = siemensS7Net.Write("DB100." + index*6, workNo); // 宸ヤ綔鍙�
- OperateResult write2 = siemensS7Net.Write("DB100." + (index*6+4), staNo); // 鐩爣绔�
+ String workNoAddress = "DB1001." + (index * 20 + 100 + 2);
+ String staNoAddress = "DB1001." + (index * 20 + 100 + 4);
+ OperateResult write1 = siemensS7Net.Write(workNoAddress, workNo); // 宸ヤ綔鍙�
+ OperateResult write2 = siemensS7Net.Write(staNoAddress, staNo); // 鐩爣绔�
if (!(write1.IsSuccess && write2.IsSuccess)) {
StaProtocol staProtocol = station.get(siteId);
--
Gitblit v1.9.1