From c61293fa498f17973a3bd72b58b8c2992863144c Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 23 三月 2026 21:44:37 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/network/real/ZyStationV4RealConnect.java | 112 +++++++++++++++++++++++++++++++++++++++++---------------
1 files changed, 82 insertions(+), 30 deletions(-)
diff --git a/src/main/java/com/zy/core/network/real/ZyStationV4RealConnect.java b/src/main/java/com/zy/core/network/real/ZyStationV4RealConnect.java
index 971f8e6..87d62e9 100644
--- a/src/main/java/com/zy/core/network/real/ZyStationV4RealConnect.java
+++ b/src/main/java/com/zy/core/network/real/ZyStationV4RealConnect.java
@@ -6,7 +6,7 @@
import HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.core.common.DateUtils;
import com.core.common.SpringUtils;
import com.zy.asrs.entity.BasDevp;
@@ -33,6 +33,10 @@
*/
@Slf4j
public class ZyStationV4RealConnect implements ZyStationConnectApi {
+
+ private static final int TASK_AREA_LENGTH = 48;
+ private static final int TASK_AREA_SLOT_SIZE = 12;
+ private static final int TASK_AREA_SLOT_COUNT = 3;
private List<ZyStationStatusEntity> statusList;
private List<StationObjModel> barcodeOriginList;
@@ -83,7 +87,7 @@
}
BasDevp basDevp = basDevpService
- .selectOne(new EntityWrapper<BasDevp>().eq("devp_no", deviceConfig.getDeviceNo()));
+ .getOne(new QueryWrapper<BasDevp>().eq("devp_no", deviceConfig.getDeviceNo()));
if (basDevp == null) {
return Collections.emptyList();
}
@@ -116,6 +120,7 @@
boolean[] status2 = siemensNet.getByteTransform().TransBool(result.Content, i * 10 + 7, 1);
statusEntity.setEnableIn(status2[1]);//鍚姩鍏ュ簱
+ statusEntity.setRunBlock(status2[2]);//閲嶆柊瑙勫垝璺嚎
Integer palletHeight = null;
if (status[7]) {
@@ -220,19 +225,44 @@
return commandResponse;
}
- int taskWriteIdx = getTaskWriteIdx(command.getStationId());
- if (taskWriteIdx == -1) {
+ getStatus(deviceNo);
+
+ int stationIdx = findIndex(command.getStationId());
+ if (stationIdx == -1) {
+ commandResponse.setMessage("鍛戒护涓嬪彂澶辫触锛屾湭鎵惧埌绔欑偣鐘舵��");
+ return commandResponse;
+ }
+
+ ZyStationStatusEntity statusEntity = statusList.get(stationIdx);
+ Integer taskWriteIdx = statusEntity == null ? null : statusEntity.getTaskWriteIdx();
+ if (taskWriteIdx == null || taskWriteIdx <= 0) {
+ commandResponse.setMessage("鍛戒护涓嬪彂澶辫触锛屽綋鍓嶆棤鍙敤浠诲姟鍐欏叆鍖�");
+ return commandResponse;
+ }
+
+ if (isDuplicateStationCommand(statusEntity, command)) {
+ log.info("杈撻�佺嚎鍛戒护閲嶅锛屽凡璺宠繃褰撳墠绔欑偣鍛戒护銆備换鍔″彿={}锛岀珯鐐瑰彿={}锛岀洰鏍囩珯={}",
+ command.getTaskNo(), command.getStationId(), command.getTargetStaNo());
+ commandResponse.setResult(true);
+ commandResponse.setMessage("鍛戒护閲嶅锛屽凡璺宠繃涓嬪彂");
+ return commandResponse;
+ }
+
+ if (existsDuplicateTaskAreaCommand(stationIdx, command)) {
+ log.info("杈撻�佺嚎鍛戒护閲嶅锛屽凡璺宠繃浠诲姟鍐欏叆鍖洪噸澶嶅懡浠ゃ�備换鍔″彿={}锛岀珯鐐瑰彿={}锛岀洰鏍囩珯={}",
+ command.getTaskNo(), command.getStationId(), command.getTargetStaNo());
+ commandResponse.setResult(true);
+ commandResponse.setMessage("浠诲姟鍖哄凡鏈夌浉鍚屽懡浠わ紝宸茶烦杩囦笅鍙�");
+ return commandResponse;
+ }
+
+ int useTaskWriteIdx = getTaskWriteIdx(stationIdx, taskWriteIdx);
+ if (useTaskWriteIdx == -1) {
commandResponse.setMessage("鍛戒护涓嬪彂瓒呮椂锛屾棤娉曟壘鍒板彲鐢ㄤ笅鍙戝尯鍩�");
return commandResponse;
}
- int stationIdx = findIndex(command.getStationId());
-
- short[] data = new short[2];
- data[0] = (short) 0;
- data[1] = command.getTargetStaNo().shortValue();
-
- OperateResult writeTaskNo = siemensNet.Write("DB13." + (stationIdx * 48 + (taskWriteIdx * 12)), command.getTaskNo());
+ OperateResult writeTaskNo = siemensNet.Write("DB13." + (stationIdx * TASK_AREA_LENGTH + (useTaskWriteIdx * TASK_AREA_SLOT_SIZE)), command.getTaskNo());
if (!writeTaskNo.IsSuccess) {
log.error("鍐欏叆杈撻�佺嚎鍛戒护澶辫触銆傜珯鐐圭紪鍙�={}锛岀珯鐐规暟鎹�={}", command.getTaskNo(), JSON.toJSON(command));
commandResponse.setResult(false);
@@ -240,7 +270,7 @@
return commandResponse;
}
- OperateResult writeData = siemensNet.Write("DB13." + (stationIdx * 48 + (taskWriteIdx * 12 + 4)), data);
+ OperateResult writeData = siemensNet.Write("DB13." + (stationIdx * TASK_AREA_LENGTH + (useTaskWriteIdx * TASK_AREA_SLOT_SIZE + 4)), command.getTargetStaNo().shortValue());
if (!writeData.IsSuccess) {
log.error("鍐欏叆杈撻�佺嚎鍛戒护澶辫触銆傜珯鐐圭紪鍙�={}锛岀珯鐐规暟鎹�={}", command.getTaskNo(), JSON.toJSON(command));
commandResponse.setResult(false);
@@ -298,30 +328,52 @@
return null;
}
- private int getTaskWriteIdx(int stationId) {
+ private int getTaskWriteIdx(int stationIdx, Integer taskWriteIdx) {
int useIdx = -1;
-
- int stationIdx = findIndex(stationId);
- if (stationIdx != -1) {
- ZyStationStatusEntity statusEntity = statusList.get(stationIdx);
-
- Integer taskWriteIdx = statusEntity.getTaskWriteIdx();
- if (taskWriteIdx > 0) {
- OperateResultExOne<byte[]> resultTask = siemensNet.Read("DB13." + (stationId * 48), (short) 48);
- if (resultTask.IsSuccess) {
- int taskNo = siemensNet.getByteTransform().TransInt32(resultTask.Content, taskWriteIdx * 12);
- int startPoint = siemensNet.getByteTransform().TransInt16(resultTask.Content, taskWriteIdx * 12 + 4);
- int targetPoint = siemensNet.getByteTransform().TransInt16(resultTask.Content, taskWriteIdx * 12 + 6);
- if (taskNo == 0 && startPoint == 0 && targetPoint == 0) {
- useIdx = taskWriteIdx;
- }
- }
+ if (stationIdx < 0 || taskWriteIdx == null || taskWriteIdx <= 0) {
+ return useIdx;
+ }
+ OperateResultExOne<byte[]> resultTask = siemensNet.Read("DB13." + (stationIdx * TASK_AREA_LENGTH), (short) TASK_AREA_LENGTH);
+ if (resultTask.IsSuccess) {
+ int taskNo = siemensNet.getByteTransform().TransInt32(resultTask.Content, taskWriteIdx * TASK_AREA_SLOT_SIZE);
+ int startPoint = siemensNet.getByteTransform().TransInt16(resultTask.Content, taskWriteIdx * TASK_AREA_SLOT_SIZE + 4);
+ int targetPoint = siemensNet.getByteTransform().TransInt16(resultTask.Content, taskWriteIdx * TASK_AREA_SLOT_SIZE + 6);
+ if (taskNo == 0 && startPoint == 0 && targetPoint == 0) {
+ useIdx = taskWriteIdx;
}
}
-
return useIdx;
}
+ private boolean isDuplicateStationCommand(ZyStationStatusEntity statusEntity, StationCommand command) {
+ if (statusEntity == null || command == null) {
+ return false;
+ }
+ return command.getTaskNo() != null
+ && command.getTargetStaNo() != null
+ && command.getTaskNo().equals(statusEntity.getTaskNo())
+ && command.getTargetStaNo().equals(statusEntity.getTargetStaNo());
+ }
+
+ private boolean existsDuplicateTaskAreaCommand(int stationIdx, StationCommand command) {
+ if (stationIdx < 0 || command == null || command.getTaskNo() == null || command.getTargetStaNo() == null) {
+ return false;
+ }
+ OperateResultExOne<byte[]> resultTask = siemensNet.Read("DB13." + (stationIdx * TASK_AREA_LENGTH), (short) TASK_AREA_LENGTH);
+ if (!resultTask.IsSuccess || resultTask.Content == null) {
+ return false;
+ }
+ for (int slotIdx = 1; slotIdx <= TASK_AREA_SLOT_COUNT; slotIdx++) {
+ int offset = slotIdx * TASK_AREA_SLOT_SIZE;
+ int taskNo = siemensNet.getByteTransform().TransInt32(resultTask.Content, offset);
+ int targetPoint = siemensNet.getByteTransform().TransInt16(resultTask.Content, offset + 6);
+ if (command.getTaskNo().equals(taskNo) && command.getTargetStaNo().equals(targetPoint)) {
+ return true;
+ }
+ }
+ return false;
+ }
+
private int findIndex(Integer stationId) {
for (int i = 0; i < statusList.size(); i++) {
ZyStationStatusEntity statusEntity = statusList.get(i);
--
Gitblit v1.9.1