From 6f5c384b7f838f35e3da4db129a57c76cd54d508 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期一, 04 十一月 2024 10:51:51 +0800 Subject: [PATCH] # --- zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 17 +++++++++++++---- 1 files changed, 13 insertions(+), 4 deletions(-) diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java index ba7f2b2..cb6fd28 100644 --- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java +++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java @@ -3,9 +3,6 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.zy.acs.framework.common.Cools; -import com.zy.acs.framework.common.SnowflakeIdWorker; -import com.zy.acs.framework.exception.CoolException; import com.zy.acs.common.domain.AgvAction; import com.zy.acs.common.domain.AgvActionItem; import com.zy.acs.common.domain.AgvProtocol; @@ -14,8 +11,15 @@ import com.zy.acs.common.domain.protocol.AGV_70_UP; import com.zy.acs.common.domain.protocol.IMessageBody; import com.zy.acs.common.domain.protocol.action.*; -import com.zy.acs.common.enums.*; +import com.zy.acs.common.enums.AgvBackpackType; +import com.zy.acs.common.enums.AgvCompleteType; +import com.zy.acs.common.enums.AgvDirectionType; +import com.zy.acs.common.enums.AgvSpeedType; +import com.zy.acs.common.utils.RedisSupport; import com.zy.acs.common.utils.Utils; +import com.zy.acs.framework.common.Cools; +import com.zy.acs.framework.common.SnowflakeIdWorker; +import com.zy.acs.framework.exception.CoolException; import com.zy.acs.manager.common.domain.TaskDto; import com.zy.acs.manager.common.exception.BusinessException; import com.zy.acs.manager.common.utils.CommonUtil; @@ -46,6 +50,7 @@ @Component("mainService") public class MainService { + private final RedisSupport redis = RedisSupport.defaultRedisSupport; private static final int LOCK_TIMEOUT = 5; private final ReentrantLock lock = new ReentrantLock(Boolean.TRUE); @@ -650,6 +655,10 @@ break; } +// if (taskType.equals(TaskTypeType.TO_STANDBY)) { +// redis.setObject(RedisConstant.AGV_TO_STANDBY_FLAG, agv.getUuid(), false); +// } + return true; } catch (Exception e) { log.error("mainService.buildMinorTask[task]", e); -- Gitblit v1.9.1