优化异常处理以及级联设备状态查询

648540858

2023-03-17 c3ce2bc5d069ba57309567aee4ae418bc0cf75ed

 src/main/java/com/genersoft/iot/vmp/utils/redis/RedisUtil.java

@@ -1,12 +1,12 @@
package com.genersoft.iot.vmp.utils.redis;



import java.util.*;

import java.util.concurrent.TimeUnit;



import com.alibaba.fastjson.JSONObject;

import com.alibaba.fastjson2.JSONObject;

import com.genersoft.iot.vmp.utils.SpringBeanFactory;

import org.springframework.data.redis.core.*;

import org.springframework.util.CollectionUtils;



import java.util.*;

import java.util.concurrent.TimeUnit;



/**    

 * Redis工具类

@@ -38,7 +38,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -66,7 +66,7 @@
        try {

            return redisTemplate.hasKey(key);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -91,7 +91,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -124,7 +124,7 @@
            redisTemplate.opsForValue().set(key, value);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -148,7 +148,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -226,7 +226,7 @@
            redisTemplate.opsForHash().putAll(key, map);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -238,7 +238,7 @@
     * @param time 时间

     * @return true / false

     */

    public static boolean hmset(String key, Map<Object, Object> map, long time) {

    public static boolean hmset(String key, Map<?, ?> map, long time) {

        if (redisTemplate == null) {

            redisTemplate = SpringBeanFactory.getBean("redisTemplate");

        }

@@ -249,7 +249,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -269,7 +269,7 @@
            redisTemplate.opsForHash().put(key, item, value);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -293,7 +293,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -365,7 +365,7 @@
        try {

            return redisTemplate.opsForSet().members(key);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return null;

        }

    }

@@ -383,7 +383,7 @@
        try {

            return redisTemplate.opsForSet().isMember(key, value);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -401,7 +401,7 @@
        try {

            return redisTemplate.opsForSet().add(key, values);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -424,7 +424,7 @@
            }

            return count;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -441,7 +441,7 @@
        try {

            return redisTemplate.opsForSet().size(key);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -459,7 +459,7 @@
        try {

            return redisTemplate.opsForSet().remove(key, values);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -625,7 +625,7 @@
        try {

            return redisTemplate.opsForList().range(key, start, end);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return null;

        }

    }

@@ -642,7 +642,7 @@
        try {

            return redisTemplate.opsForList().size(key);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -662,7 +662,7 @@
        try {

            return redisTemplate.opsForList().index(key, index);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return null;

        }

    }

@@ -681,7 +681,7 @@
            redisTemplate.opsForList().rightPush(key, value);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -704,7 +704,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -723,7 +723,7 @@
            redisTemplate.opsForList().rightPushAll(key, values);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -746,7 +746,7 @@
            }

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -766,7 +766,7 @@
            redisTemplate.opsForList().set(key, index, value);

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return false;

        }

    }

@@ -787,7 +787,7 @@
        try {

            return redisTemplate.opsForList().remove(key, count, value);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return 0;

        }

    }

@@ -829,7 +829,7 @@
            Set<String> set = redisTemplate.keys(key);

            return new ArrayList<>(set);

        } catch (Exception e) {

            e.printStackTrace();

            logger.error("未处理的异常 ", e);

            return null;

        }

    }

@@ -854,7 +854,7 @@
//            //关闭cursor

//            cursor.close();

//        } catch (Exception e) {

//            e.printStackTrace();

//            logger.error("未处理的异常 ", e);

//        }

//        return result;

//    }

@@ -881,7 +881,13 @@


        return new ArrayList<>(resultKeys);

    }



    public static List<Object> scan2(String query) {

        if (redisTemplate == null) {

            redisTemplate = SpringBeanFactory.getBean("redisTemplate");

        }

        Set<String> keys = redisTemplate.keys(query);

        return new ArrayList<>(keys);

    }

    //    ============================== 消息发送与订阅 ==============================

    public static void convertAndSend(String channel, JSONObject msg) {

        if (redisTemplate == null) {