调整数据存储

yaowanxin

6 天以前 645e5448919612d5772d74d29fb2f2bb2f9bf951

调整数据存储

 cnas-device/src/main/java/com/ruoyi/device/controller/WeightController.java

@@ -39,7 +39,15 @@
//            return ResponseEntity.internalServerError().body("数据处理失败: " + e.getMessage());
//        }
        if(Objects.nonNull(weightRequest) && CollectionUtil.isNotEmpty(weightRequest.getWeights())){
            RedisUtil.lSet(WeightRequestDto.DENSITY,weightRequest.getWeights());
            List<?> objectList = RedisUtil.lGet(WeightRequestDto.DENSITY, 0, -1);
            if(CollectionUtil.isNotEmpty(objectList)){
                // 删除 Redis 中旧的列表数据
                RedisUtil.del(WeightRequestDto.DENSITY);
                // 存入新的数据
                RedisUtil.lSet(WeightRequestDto.DENSITY, weightRequest.getWeights());
            }else {
                RedisUtil.lSet(WeightRequestDto.DENSITY,weightRequest.getWeights());
            }
            return Result.success(null,"保存成功");
        }
        return Result.fail();

 cnas-device/src/main/java/com/ruoyi/device/utils/DataAcquisition.java

@@ -190,7 +190,8 @@
                    numberOfDataEntries.addAndGet(1);
                }else {
                    // 从 Redis 中获取列表数据
                    List<Object> objectList = RedisUtil.lGet(refery, 0, -1);
//                    List<Object> objectList = RedisUtil.lGet(refery, 0, -1);
                    List<?> objectList = RedisUtil.lGet(refery, 0, -1);
                    for (Object item : objectList) {
//                        System.out.println(item);
                        String[] split = item.toString().replace("[","").replace("]","").split(",");

 ruoyi-common/src/main/java/com/ruoyi/common/utils/RedisUtil.java

@@ -471,7 +471,7 @@
     * @param start 开始
     * @param end   结束 0 到 -1代表所有值
     */
    public static List<Object> lGet(String key, long start, long end) {
    public static List<?> lGet(String key, long start, long end) {
        try {
            return redisTemplate.opsForList().range(key, start, end);
        } catch (Exception e) {
@@ -557,7 +557,7 @@
     * @param value 值
     * @return true 存放成功 false存放失败
     */
    public static boolean lSet(String key, List<Object> value) {
    public static boolean lSet(String key, List<?> value) {
        try {
            redisTemplate.opsForList().rightPushAll(key, value);
            return true;