From 6daf900a09adcca981f620744bf89851654d88e0 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期二, 05 八月 2025 09:58:08 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/utils/DeviceMsgUtils.java | 8 ++++++-- 1 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/core/utils/DeviceMsgUtils.java b/src/main/java/com/zy/core/utils/DeviceMsgUtils.java index 7a4f8b3..dd78cef 100644 --- a/src/main/java/com/zy/core/utils/DeviceMsgUtils.java +++ b/src/main/java/com/zy/core/utils/DeviceMsgUtils.java @@ -78,14 +78,14 @@ public String sendDeviceMsg(SlaveType deviceType, Integer deviceId, DeviceMsgModel deviceMsgModel) { String key = parseDeviceMsgKey(deviceType, deviceId) + System.currentTimeMillis(); - redisUtil.set(key, deviceMsgModel, 60 * 60 * 24); + redisUtil.set(key, deviceMsgModel, 60 * 60); return key; } public String sendDeviceCommand(SlaveType deviceType, Integer deviceId, DeviceCommandMsgModel command) { String key = parseDeviceCommandMsgKey(deviceType, deviceId) + System.currentTimeMillis(); command.setResultKey(key); - redisUtil.set(key, command, 60 * 60 * 24); + redisUtil.set(key, command, 60 * 60); return key; } @@ -130,6 +130,8 @@ return RedisKeyType.DEVICE_SHUTTLE_MSG_KEY_.key + deviceId + "_"; } else if (deviceType.equals(SlaveType.ForkLift)) { return RedisKeyType.DEVICE_FORK_LIFT_MSG_KEY_.key + deviceId + "_"; + } else if (deviceType.equals(SlaveType.Lift)) { + return RedisKeyType.DEVICE_LIFT_MSG_KEY_.key + deviceId + "_"; }else { throw new CoolException("璁惧绫诲瀷鏈畾涔�"); } @@ -144,6 +146,8 @@ return RedisKeyType.DEVICE_SHUTTLE_COMMAND_MSG_KEY.key + deviceId + "_"; } else if (deviceType.equals(SlaveType.ForkLift)) { return RedisKeyType.DEVICE_FORK_LIFT_COMMAND_MSG_KEY.key + deviceId + "_"; + } else if (deviceType.equals(SlaveType.Lift)) { + return RedisKeyType.DEVICE_LIFT_COMMAND_MSG_KEY.key + deviceId + "_"; }else { throw new CoolException("璁惧绫诲瀷鏈畾涔�"); } -- Gitblit v1.9.1