✨ 添加集合类型校验validator

Author: ccoderJava

summer-validator/src/main/java/com/dianpoint/summer/validator/ValidationRules.java

@@ -1,5 +1,7 @@
 package com.dianpoint.summer.validator;
 
+import java.util.*;
+
 /**
  * @author: congccoder
  * @email: congccoder@gmail.com | <a href="https://github.com/ccoderJava">github-homepage</a>
@@ -42,4 +44,45 @@ public static ValidationRule<Integer> max(int value) {
                 ValidationResult.failure("不能大于" + value, "integer");
     }
 
+    //设置collections相关的校验规则
+    public static <C extends Collection<?>> ValidationRule<C> minsize(int min) {
+        return collection -> collection != null && collection.size() >= min ?
+                ValidationResult.success() :
+                ValidationResult.failure("集合大小不能小于" + min, "collection");
+    }
+
+    public static <C extends Collection<?>> ValidationRule<C> maxSize(int max) {
+        return collection -> collection != null && collection.size() <= max ?
+                ValidationResult.success() :
+                ValidationResult.failure("集合大小不能大于" + max, "collection");
+    }
+
+    public static <C extends Collection<?>> ValidationRule<C> range(int min, int max) {
+        return collection -> collection != null && collection.size() >= min && collection.size() <= max ?
+                ValidationResult.success() :
+                ValidationResult.failure(String.format("集合大小必须在[%s,%s]之间", min, max), "collection");
+    }
+
+    public static <E, C extends Collection<E>> ValidationRule<C> uniqueElements() {
+        return collection -> {
+            if (collection == null) {
+                return ValidationResult.success();
+            }
+            Set<E> uniqueSet = new LinkedHashSet<>();
+            List<E> duplicates = new ArrayList<>();
+
+            for (E element : collection) {
+                if (!uniqueSet.add(element)) {
+                    //set中添加失败代表元素element已经存在
+                    duplicates.add(element);
+                }
+            }
+            return duplicates.isEmpty() ?
+                    ValidationResult.success() :
+                    ValidationResult.failure("集合中包含重复元素" + duplicates, "collection");
+
+        };
+    }
+
+
 }

summer-validator/src/main/java/com/dianpoint/summer/validator/Validators.java

@@ -3,7 +3,11 @@
 import com.dianpoint.summer.validator.validator.AnnotationValidatorAdapter;
 import com.dianpoint.summer.validator.validator.GenericValidator;
 import com.dianpoint.summer.validator.validator.Validator;
+import com.dianpoint.summer.validator.validator.collection.CollectionValidator;
+import com.dianpoint.summer.validator.validator.collection.DefaultCollectionValidator;
 
+import java.util.Collection;
+import java.util.List;
 import java.util.Objects;
 import java.util.function.Predicate;
 
@@ -44,5 +48,12 @@ public static <T> Validator<T> annotated(Class<T> targetClass) {
         return AnnotationValidatorAdapter.create(targetClass);
     }
 
+    //针对collection创建校验器
+
+    public static <E, C extends Collection<E>> CollectionValidator<E, C> collection(Class<C> collectionType, Class<E> elementType) {
+        return new DefaultCollectionValidator<>(collectionType, elementType);
+    }
+
+    //重载一下list 和set两种collection的校验器
 
 }

summer-validator/src/main/java/com/dianpoint/summer/validator/validator/collection/CollectionValidator.java

@@ -0,0 +1,44 @@
+package com.dianpoint.summer.validator.validator.collection;
+
+import com.dianpoint.summer.validator.ValidationRule;
+import com.dianpoint.summer.validator.validator.Validator;
+
+import java.util.Collection;
+import java.util.function.Predicate;
+
+/**
+ * @author: congccoder
+ * @email: congccoder@gmail.com | <a href="https://github.com/ccoderJava">github-homepage</a>
+ * @date: 2025/5/24 14:59
+ */
+
+public interface CollectionValidator<E, C extends Collection<E>> extends Validator<C> {
+
+
+    /**
+     * 集合校验接口 用于对集合及其元素进行校验
+     *
+     * @param rule 元素校验器规则
+     * @return 集合类型必须是Collection<E> 的子类
+     */
+    CollectionValidator<E, C> elementRule(ValidationRule<E> rule);
+
+
+    /**
+     * 为集合中每个元素添加基于predicate的校验规则
+     *
+     * @param condition    校验条件
+     * @param errorMessage 校验失败时的错误提示信息
+     * @return 集合校验器实例 支持链式调用
+     */
+    CollectionValidator<E, C> elementRule(Predicate<E> condition, String errorMessage);
+
+    /**
+     * 为集合中每个元素添加一个校验器
+     *
+     * @param validator 元素校验器
+     * @return 当前校验器实例 支持链式调用
+     */
+    CollectionValidator<E, C> elementValidator(Validator<E> validator);
+
+}

summer-validator/src/main/java/com/dianpoint/summer/validator/validator/collection/DefaultCollectionValidator.java

@@ -0,0 +1,75 @@
+package com.dianpoint.summer.validator.validator.collection;
+
+import com.dianpoint.summer.validator.ValidationResult;
+import com.dianpoint.summer.validator.ValidationRule;
+import com.dianpoint.summer.validator.Validators;
+import com.dianpoint.summer.validator.validator.AbstractValidator;
+import com.dianpoint.summer.validator.validator.Validator;
+
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+import java.util.function.Predicate;
+
+/**
+ * @author: congccoder
+ * @email: congccoder@gmail.com | <a href="https://github.com/ccoderJava">github-homepage</a>
+ * @date: 2025/5/24 15:05
+ */
+
+public class DefaultCollectionValidator<E, C extends Collection<E>> extends AbstractValidator<C> implements CollectionValidator<E, C> {
+
+    private Validator<E> elementValidator;
+
+    public DefaultCollectionValidator(Class<C> collectionType, Class<E> elementType) {
+        addRule(Objects::nonNull, "集合不能为null", "collection");
+    }
+
+
+    @Override
+    public CollectionValidator<E, C> elementRule(ValidationRule<E> rule) {
+        if (elementValidator == null) {
+            //初始化元素校验器
+            elementValidator = Validators.generic();
+        }
+        elementValidator.addRule(rule);
+        return this;
+    }
+
+    @Override
+    public CollectionValidator<E, C> elementRule(Predicate<E> condition, String errorMessage) {
+        return elementRule(target -> condition.test(target) ? ValidationResult.success() : ValidationResult.failure(errorMessage));
+    }
+
+    @Override
+    public CollectionValidator<E, C> elementValidator(Validator<E> validator) {
+        elementValidator = validator;
+        return this;
+    }
+
+
+    @Override
+    public List<ValidationResult> validate(C collection) {
+        List<ValidationResult> results = super.validate(collection);
+        if (collection == null || collection.isEmpty()) {
+            return results;
+        }
+
+        if (elementValidator == null) {
+            return results;
+        }
+        int index = 0;
+        for (E element : collection) {
+            List<ValidationResult> elementResults = elementValidator.validate(element);
+            for (ValidationResult elementResult : elementResults) {
+                if (elementResult.isFailure()) {
+                    results.add(ValidationResult.failure(String.format("元素[%s]:%s collection[%s]", index
+                            , elementResult.getErrorMessage(), index)));
+                }
+            }
+            index++;
+        }
+        return results;
+    }
+}

summer-validator/src/test/java/com/dianpoint/summer/validator/test/ValidatorDemo.java

@@ -6,6 +6,7 @@
 import com.dianpoint.summer.validator.Validators;
 import com.dianpoint.summer.validator.test.cases.User;
 
+import java.util.Arrays;
 import java.util.List;
 
 /**
@@ -22,7 +23,9 @@ public static void main(String[] args) {
 //        validateAge(16);
 //        validateAge(21);
 
-        validateObject();
+//        validateObject();
+
+        validateCollectionString();
     }
 
     static void validateEmail(String email) {
@@ -54,6 +57,20 @@ static void validateObject() {
     }
 
 
+    static void validateCollectionString() {
+        List<String> strList = Arrays.asList("张三", "李四", "", null, "王五", "小王");
+        List<ValidationResult> validationResults = Validators.collection(List.class, String.class)
+                .elementRule(str -> str != null, "元素不等为null")
+                .elementRule(str -> str.isEmpty(), "元素不能为空字符串")
+                .addRule(ValidationRules.minsize(1))
+                .addRule(ValidationRules.maxSize(10))
+                .addRule(ValidationRules.range(3, 5))
+                .validate(strList);
+
+        printResults(validationResults);
+    }
+
+
     static void printResults(List<ValidationResult> validateResult) {
         for (ValidationResult result : validateResult) {
             System.out.println(result.getFieldName() + "校验结果:" + result.getErrorMessage());