add:增加二次分配代码逻辑

lms/nladmin-system/src/main/java/org/nl/modules/common/utils/RedisUtils.java

@@ -48,7 +48,6 @@ public class RedisUtils {
     private final ObjectMapper objectMapper = new ObjectMapper();
 
 
-
     public RedisUtils(RedisTemplate<Object, Object> redisTemplate) {
         this.redisTemplate = redisTemplate;
     }
@@ -716,6 +715,10 @@ public class RedisUtils {
         log.debug("--------------------------------------------");
     }
 
+
+    /**
+     * 队列新增
+     */
     public void pushToList(String key, Object value) {
         try {
             String valueJson = objectMapper.writeValueAsString(value);
@@ -725,6 +728,9 @@ public class RedisUtils {
         }
     }
 
+    /**
+     * 队列移除
+     */
     public Object popFromList(String key, Class<?> valueType) {
         String valueJson = (String) redisTemplate.opsForList().leftPop(key);
         if (valueJson != null) {
@@ -736,4 +742,39 @@ public class RedisUtils {
         }
         return null;
     }
+
+
+    /**
+     * 获取队列元素个数
+     */
+    public long getListSize(String key) {
+        Long size = redisTemplate.opsForList().size(key);
+        return (size != null) ? size : 0;
+    }
+
+
+    /**
+     * 获取队列元素
+     */
+    public List<Object> getListElements(String key) {
+        List<Object> elements = redisTemplate.opsForList().range(key, 0, -1);
+        return elements;
+    }
+
+    /**
+     * 删除队列中的某个元素
+     */
+    public void removeFromList(String key, Object value) {
+        redisTemplate.opsForList().remove(key, 1, value);
+    }
+
+
+    /**
+     * 删除队列中的所有元素
+     */
+    public void clearList(String key) {
+        redisTemplate.delete(key);
+    }
+
+
 }