From 7020a74ae60374f202e804bb972ee977dacb66f8 Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期二, 07 四月 2026 09:33:50 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/fake/FakeProcessor.java | 20 +++++++++++++++++++-
1 files changed, 19 insertions(+), 1 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/fake/FakeProcessor.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/fake/FakeProcessor.java
index 0457ea7..40eff9a 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/fake/FakeProcessor.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/fake/FakeProcessor.java
@@ -5,10 +5,13 @@
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.domain.protocol.AGV_01_DOWN;
import com.zy.acs.common.domain.protocol.AGV_01_UP;
+import com.zy.acs.common.hk.order.HkOrderDown;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.framework.common.Cools;
+import com.zy.acs.manager.common.config.HikOrderProperties;
import com.zy.acs.manager.core.service.MainService;
import com.zy.acs.manager.core.service.MapService;
+import com.zy.acs.manager.core.service.hik.HikOrderPublishService;
import com.zy.acs.manager.manager.entity.Action;
import com.zy.acs.manager.manager.entity.Agv;
import com.zy.acs.manager.manager.enums.ActionStsType;
@@ -68,6 +71,10 @@
private JamService jamService;
@Autowired
private MainService mainService;
+ @Autowired
+ private HikOrderPublishService hikOrderPublishService;
+ @Autowired
+ private HikOrderProperties hikOrderProperties;
@PostConstruct
public void init() {
@@ -141,6 +148,7 @@
, mapService
, jamService
, mainService
+ , hikOrderProperties
, actionList
));
} else {
@@ -164,7 +172,11 @@
private void processOnline() {
for (Agv agv : this.getAgvList()) {
- redis.setObject(RedisConstant.AGV_ONLINE_FLAG, agv.getUuid(), 1, 30);
+ if (hikOrderPublishService.support(agvModelService.getByAgvId(agv.getId()))) {
+ redis.setObject(RedisConstant.HK_AGV_ONLINE_FLAG, agv.getUuid(), 1, 30);
+ } else {
+ redis.setObject(RedisConstant.AGV_ONLINE_FLAG, agv.getUuid(), 1, 30);
+ }
}
}
@@ -180,6 +192,12 @@
, protocol.getAgvNo() + "_" + agv_01_up.getSerialNo()
, agv_01_up);
}
+
+ HkOrderDown hkOrderDown = redis.pop(RedisConstant.HK_AGV_PATH_DOWN_FLAG);
+ if (hkOrderDown != null) {
+ log.info("fake receive hik order, agvNo={}, actionGroupId={}",
+ hkOrderDown.getAgvNo(), hkOrderDown.getActionGroupId());
+ }
}
public List<Agv> getAgvList() {
--
Gitblit v1.9.1