From 2009009296eb4ebeb05c456c29124319f3731922 Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Mon, 28 Jul 2025 10:08:17 +0800 Subject: [PATCH] =?UTF-8?q?redis=E6=B7=BB=E5=8A=A0=E5=AD=97=E7=AC=A6?= =?UTF-8?q?=E4=B8=B2=E5=AD=98=E5=82=A8=E7=B1=BB=E5=9E=8B=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/njcn/redis/utils/RedisUtil.java | 15 +++++++++++++++ .../majornetwork/Impl/AreaInfoServiceImpl.java | 2 +- 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java b/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java index e8d8fed36..4adf91345 100644 --- a/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java +++ b/pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java @@ -2,10 +2,12 @@ package com.njcn.redis.utils; import lombok.RequiredArgsConstructor; import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; +import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; +import java.nio.charset.StandardCharsets; import java.util.*; import java.util.concurrent.TimeUnit; @@ -351,4 +353,17 @@ public class RedisUtil { return database; } + + /** + * 获取value为字符串的 + * @param key + * @return + */ + public String getRawValue(String key) { + return redisTemplate.execute((RedisCallback) connection -> { + byte[] data = connection.get(key.getBytes()); + return data == null ? null : new String(data, StandardCharsets.UTF_8); + }); + } + } diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java index 6b8d8ea03..de845b808 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java @@ -55,7 +55,7 @@ public class AreaInfoServiceImpl implements AreaInfoService { } }else{ - List generalDeviceDTOList = generalDeviceInfoClient.getPracticalRunDeviceInfo(deviceInfoParam).getData(); + List generalDeviceDTOList = generalDeviceInfoClient.getPracticalAllDeviceInfo(deviceInfoParam).getData(); lineIds.addAll(generalDeviceDTOList.stream().flatMap(dto -> dto.getLineIndexes().stream()).collect(Collectors.toList())); }