Browse Source

fix redis byte[]

tags/B.2.2.0.6_20231012_base
yk 2 years ago
parent
commit
ddec547ce5
2 changed files with 3 additions and 3 deletions
  1. +2
    -2
      xueyi-common/xueyi-common-redis/src/main/java/com/xueyi/common/redis/utils/RedisUtil.java
  2. +1
    -1
      xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/resource/controller/DmResourcesController.java

+ 2
- 2
xueyi-common/xueyi-common-redis/src/main/java/com/xueyi/common/redis/utils/RedisUtil.java View File

@@ -40,9 +40,9 @@ public class RedisUtil {
return redisTemplate.opsForList().range(key, 0, -1).stream().map(json-> JSONObject.parseObject(json.toString())).collect(Collectors.toList());
}

public static List<byte[]> getBytesList(String key) {
public static List<String> getBytesList(String key) {
List<Serializable> sers = redisTemplate.opsForList().range(key, 0, -1);
return sers.stream().map(ser-> (byte[]) ser).collect(Collectors.toList());
return sers.stream().map(ser-> (String) ser).collect(Collectors.toList());
}

public static void setBytesList(String key, byte[] bytes) {


+ 1
- 1
xueyi-modules/xueyi-system/src/main/java/com/xueyi/system/resource/controller/DmResourcesController.java View File

@@ -159,7 +159,7 @@ public class DmResourcesController extends BaseController<DmResourcesQuery, DmRe
List<byte[]> bytesList = new ArrayList<>();
String key = "saas:upload:chunks:" + uuid;
if (RedisUtil.existed(key)){
bytesList = RedisUtil.getBytesList(key);
bytesList = RedisUtil.getBytesList(key).stream().map(ss->ss.getBytes()).collect(Collectors.toList());
}

logger.info("第{}/{}块上传成功", chunkIndex + 1, totalChunks);


Loading…
Cancel
Save