Date comparing rule.

Author: jonpereiradev

src/main/java/com/jonpereiradev/jfile/reader/file/JFileLine.java

@@ -5,6 +5,7 @@
 import java.util.SortedSet;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
+import java.util.stream.Stream;
 
 public class JFileLine implements Comparable<JFileLine> {
 
@@ -40,7 +41,9 @@ public int hashCode() {
 
     public JFileColumn getColumn(int position) {
         if (!columnsByPosition.containsKey(position)) {
-            columnsByPosition.put(position, getColumns().stream().filter(o -> o.getPosition() == position).findFirst().orElse(null));
+            Stream<JFileColumn> stream = getColumns().stream().filter(o -> o.getPosition() == position);
+            JFileColumn column = stream.findFirst().orElseThrow(() -> new IllegalArgumentException("Position doesn't exists in line."));
+            columnsByPosition.put(position, column);
         }
 
         return columnsByPosition.get(position);

src/main/java/com/jonpereiradev/jfile/reader/rule/column/AbstractColumnRule.java

@@ -1,13 +1,15 @@
 package com.jonpereiradev.jfile.reader.rule.column;
 
 import com.jonpereiradev.jfile.reader.file.JFileColumn;
+import com.jonpereiradev.jfile.reader.file.JFileLine;
 import com.jonpereiradev.jfile.reader.rule.RuleNode;
 import org.apache.commons.lang3.StringUtils;
 
 public abstract class AbstractColumnRule implements ColumnRule {
 
     private final int position;
 
+    private JFileLine fileLine;
     private RuleNode<ColumnRule> ruleNode;
 
     public AbstractColumnRule(int position) {
@@ -24,6 +26,16 @@ public int getPosition() {
         return position;
     }
 
+    @Override
+    public JFileLine getFileLine() {
+        return fileLine;
+    }
+
+    @Override
+    public void setFileLine(JFileLine fileLine) {
+        this.fileLine = fileLine;
+    }
+
     @Override
     public RuleNode<ColumnRule> getRuleNode() {
         return ruleNode;

src/main/java/com/jonpereiradev/jfile/reader/rule/column/AbstractRefRule.java

@@ -1,13 +1,15 @@
 package com.jonpereiradev.jfile.reader.rule.column;
 
 import com.jonpereiradev.jfile.reader.file.JFileColumn;
+import com.jonpereiradev.jfile.reader.file.JFileLine;
 import com.jonpereiradev.jfile.reader.rule.RuleNode;
 
 public abstract class AbstractRefRule implements RefRule {
 
     private final int refPosition;
     private final int position;
 
+    private JFileLine fileLine;
     private RuleNode<ColumnRule> ruleNode;
 
     public AbstractRefRule(int refPosition, int position) {
@@ -30,6 +32,16 @@ public int getPosition() {
         return position;
     }
 
+    @Override
+    public JFileLine getFileLine() {
+        return fileLine;
+    }
+
+    @Override
+    public void setFileLine(JFileLine fileLine) {
+        this.fileLine = fileLine;
+    }
+
     @Override
     public RuleNode<ColumnRule> getRuleNode() {
         return ruleNode;

src/main/java/com/jonpereiradev/jfile/reader/rule/column/ColumnRule.java

@@ -1,6 +1,7 @@
 package com.jonpereiradev.jfile.reader.rule.column;
 
 import com.jonpereiradev.jfile.reader.file.JFileColumn;
+import com.jonpereiradev.jfile.reader.file.JFileLine;
 import com.jonpereiradev.jfile.reader.rule.Rule;
 import com.jonpereiradev.jfile.reader.rule.RuleNode;
 import org.apache.commons.lang3.StringUtils;
@@ -17,6 +18,10 @@ default boolean canValidate(JFileColumn fileColumn) {
 
     int getPosition();
 
+    JFileLine getFileLine();
+
+    void setFileLine(JFileLine fileLine);
+
     RuleNode<ColumnRule> getRuleNode();
 
     void setRuleNode(RuleNode<ColumnRule> ruleNode);

src/main/java/com/jonpereiradev/jfile/reader/rule/column/CpfRule.java

@@ -2,8 +2,24 @@
 
 import com.jonpereiradev.jfile.reader.file.JFileColumn;
 
+import java.util.Arrays;
+import java.util.List;
+
 public class CpfRule extends AbstractColumnRule {
 
+    private static final List<String> INVALID_CPFS = Arrays.asList(
+        "00000000000",
+        "11111111111",
+        "22222222222",
+        "33333333333",
+        "44444444444",
+        "55555555555",
+        "66666666666",
+        "77777777777",
+        "88888888888",
+        "99999999999"
+    );
+
     public CpfRule(int position) {
         super(position);
     }
@@ -12,7 +28,7 @@ public CpfRule(int position) {
     public boolean isValid(JFileColumn fileColumn) {
         String cpf = fileColumn.getText();
 
-        if (cpf.equals("00000000000") || cpf.length() != 11) {
+        if (cpf.length() != 11 || INVALID_CPFS.contains(cpf)) {
             return false;
         }
 

src/main/java/com/jonpereiradev/jfile/reader/rule/column/DateAfterRule.java

@@ -0,0 +1,41 @@
+package com.jonpereiradev.jfile.reader.rule.column;
+
+import com.jonpereiradev.jfile.reader.file.JFileColumn;
+
+import java.text.DateFormat;
+import java.util.Date;
+
+public class DateAfterRule extends AbstractColumnRule {
+
+    private final DateFormat dateFormat;
+    private final Date min;
+    private final int columnPosition;
+
+    public DateAfterRule(int position, DateFormat dateFormat, Date min) {
+        super(position);
+        this.dateFormat = dateFormat;
+        this.min = min;
+        this.columnPosition = -1;
+    }
+
+    public DateAfterRule(int position, DateFormat dateFormat, int columnPosition) {
+        super(position);
+        this.dateFormat = dateFormat;
+        this.min = null;
+        this.columnPosition = columnPosition;
+    }
+
+    @Override
+    public boolean isValid(JFileColumn fileColumn) {
+        Date date = fileColumn.getDate(dateFormat);
+        return date.compareTo(getComparingDate()) > 0;
+    }
+
+    private Date getComparingDate() {
+        if (columnPosition == -1) {
+            return min;
+        }
+
+        return getFileLine().getColumn(columnPosition).getDate(dateFormat);
+    }
+}

src/main/java/com/jonpereiradev/jfile/reader/rule/column/DateBeforeRule.java

@@ -0,0 +1,41 @@
+package com.jonpereiradev.jfile.reader.rule.column;
+
+import com.jonpereiradev.jfile.reader.file.JFileColumn;
+
+import java.text.DateFormat;
+import java.util.Date;
+
+public class DateBeforeRule extends AbstractColumnRule {
+
+    private final DateFormat dateFormat;
+    private final Date max;
+    private final int columnPosition;
+
+    public DateBeforeRule(int position, DateFormat dateFormat, Date max) {
+        super(position);
+        this.dateFormat = dateFormat;
+        this.max = max;
+        this.columnPosition = -1;
+    }
+
+    public DateBeforeRule(Integer position, DateFormat dateFormat, int columnPosition) {
+        super(position);
+        this.dateFormat = dateFormat;
+        this.max = null;
+        this.columnPosition = columnPosition;
+    }
+
+    @Override
+    public boolean isValid(JFileColumn fileColumn) {
+        Date date = fileColumn.getDate(dateFormat);
+        return date.compareTo(getComparingDate()) < 0;
+    }
+
+    private Date getComparingDate() {
+        if (columnPosition == -1) {
+            return max;
+        }
+
+        return getFileLine().getColumn(columnPosition).getDate(dateFormat);
+    }
+}

src/main/java/com/jonpereiradev/jfile/reader/rule/column/DateMaxRule.java

@@ -27,11 +27,21 @@ public interface DateTypeConfigurator extends TypedRuleConfigurator<DateTypeConf
     /**
      * defines a min date rule validation.
      */
-    DateTypeConfigurator min(Date min);
+    DateTypeConfigurator after(Date min);
 
     /**
      * defines a max date rule validation.
      */
-    DateTypeConfigurator max(Date max);
+    DateTypeConfigurator before(Date max);
+
+    /**
+     * defines a min date rule validation comparing to another column.
+     */
+    DateTypeConfigurator after(int columnPosition);
+
+    /**
+     * defines a max date rule validation comparing to another column.
+     */
+    DateTypeConfigurator before(int columnPosition);
 
 }

src/main/java/com/jonpereiradev/jfile/reader/rule/column/DateMinRule.java

@@ -37,12 +37,22 @@ public DateTypeConfigurator pastOrPresent() {
     }
 
     @Override
-    public DateTypeConfigurator min(Date min) {
-        return rule(position -> new DateMinRule(position, dateFormat, min));
+    public DateTypeConfigurator after(Date min) {
+        return rule(position -> new DateAfterRule(position, dateFormat, min));
     }
 
     @Override
-    public DateTypeConfigurator max(Date max) {
-        return rule(position -> new DateMaxRule(position, dateFormat, max));
+    public DateTypeConfigurator after(int columnPosition) {
+        return rule(position -> new DateAfterRule(position, dateFormat, columnPosition));
+    }
+
+    @Override
+    public DateTypeConfigurator before(Date max) {
+        return rule(position -> new DateBeforeRule(position, dateFormat, max));
+    }
+
+    @Override
+    public DateTypeConfigurator before(int columnPosition) {
+        return rule(position -> new DateBeforeRule(position, dateFormat, columnPosition));
     }
 }

src/main/java/com/jonpereiradev/jfile/reader/rule/configurator/DateTypeConfigurator.java

@@ -61,19 +61,21 @@ private void checkColumnRuleViolation(JFileLine line, List<RuleViolation> violat
         });
     }
 
-    private List<RuleViolation> validateColumnRules(JFileLine line, JFileColumn column, RuleNode<ColumnRule> node) {
+    private List<RuleViolation> validateColumnRules(JFileLine fileLine, JFileColumn column, RuleNode<ColumnRule> node) {
         Stream<ColumnRule> stream = node.getChildrens().stream();
         List<ColumnRule> filtered = stream.filter(o -> o.getPosition() == column.getPosition()).collect(Collectors.toList());
         List<RuleViolation> violations = new ArrayList<>();
 
         for (ColumnRule rule : filtered) {
-            JFileColumn fileColumn = isRefRule(rule) ? getDependsColumn(line, (RefRule) rule) : column;
+            JFileColumn fileColumn = isRefRule(rule) ? getDependsColumn(fileLine, (RefRule) rule) : column;
+
+            rule.setFileLine(fileLine);
 
             if (rule instanceof ArrayOfTypeRule) {
                 ArrayOfTypeRule arrayOf = (ArrayOfTypeRule) rule;
-                arrayOf.split(column).forEach(o -> violations.addAll(validateColumnRules(line, o, rule.getRuleNode())));
+                arrayOf.split(column).forEach(o -> violations.addAll(validateColumnRules(fileLine, o, rule.getRuleNode())));
             } else if (rule.canValidate(fileColumn)) {
-                recursivelyValidate(line, column, rule, violations);
+                recursivelyValidate(fileLine, column, rule, violations);
             }
 
             if (!violations.isEmpty()) {