dive4elements/river: flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/FixingsOverview.java comparison

comparison flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/FixingsOverview.java @ 2563:59c920e73d8a

FixingsOverview: Added a filter mechanism for generating output. flys-artifacts/trunk@4089 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Mon, 20 Feb 2012 16:41:45 +0000
parents	ba35dfb7c09a
children	3f038d54bc87

comparison

equal deleted inserted replaced

-:ba35dfb7c09a
+:59c920e73d8a
 public int compare(Column a, Column b) {
 return a.startTime.compareTo(b.startTime);
 }
 };
+public interface Filter {
+boolean accept(Column column);
+} // interface Filter
 public class Column extends Range {
 protected int    columnId;
 protected Date   startTime;
 protected String name;
 this.name      = name;
 sectors = new ArrayList<SectorRange>();
 }
+public int getId() {
+return columnId;
+}
 public Fixing getFixing() {
 return Fixing.this;
 }
+public Date getStartTime() {
+return startTime;
+}
+public String getName() {
+return name;
+}
 public List<SectorRange> getSectors() {
 return sectors;
+}
+public List<SectorRange> getSectors(Range range) {
+List<SectorRange> result =
+new ArrayList<SectorRange>(sectors.size());
+for (SectorRange src: sectors) {
+SectorRange dst = new SectorRange(src);
+if (dst.clip(range)) {
+result.add(dst);
+}
+}
+return result;
 }
 public void buildSectors(GaugeRange gauge, List<QRange> qRanges) {
 for (QRange qRange: qRanges) {
 protected List<Column> columns;
 public Fixing() {
 }
+public int getId() {
+return wstId;
+}
+public String getDescription() {
+return description;
+}
 public Fixing(int wstId, String description) {
 this.wstId       = wstId;
 this.description = description;
 columns = new ArrayList<Column>();
 }
 for (Column column: columns) {
 column.loadQRanges(query, gaugeFinder);
 }
 }
-public void addAllColumns(List<Column> allColumns, Range range) {
+public void addAllColumns(
+List<Column> allColumns,
+Range        range,
+Filter       filter
+) {
 for (Column column: columns) {
-if (column.intersects(range)) {
+if (column.intersects(range) && filter.accept(column)) {
 allColumns.add(column);
 }
 }
 }
 } // class Fixing
 loadFixingsColumnsQRanges(session, gaugeFinder);
 return true;
 }
-private static final Range FULL_EXTENT =
+public static final Range FULL_EXTENT =
 new Range(-Double.MAX_VALUE, Double.MAX_VALUE);
+public static final Fixing.Filter ACCEPT = new Fixing.Filter() {
+@Override
+public boolean accept(Fixing.Column column) {
+return true;
+}
+};
+public static class NotFilter implements Fixing.Filter {
+protected Fixing.Filter child;
+public NotFilter(Fixing.Filter child) {
+this.child = child;
+}
+@Override
+public boolean accept(Fixing.Column column) {
+return !child.accept(column);
+}
+} // class NotFilter
+public static abstract class ComponentFilter implements Fixing.Filter {
+protected List<Fixing.Filter> children;
+public ComponentFilter(List<Fixing.Filter> children) {
+this.children = children;
+}
+} // class ComponentFilter
+public static class OrFilter extends ComponentFilter {
+public OrFilter(List<Fixing.Filter> children) {
+super(children);
+}
+@Override
+public boolean accept(Fixing.Column column) {
+for (Fixing.Filter child: children) {
+if (child.accept(column)) {
+return true;
+}
+}
+return false;
+}
+} // class OrFilter
+public static class AndFilter extends ComponentFilter {
+public AndFilter(List<Fixing.Filter> children) {
+super(children);
+}
+@Override
+public boolean accept(Fixing.Column column) {
+for (Fixing.Filter child: children) {
+if (!child.accept(column)) {
+return false;
+}
+}
+return true;
+}
+} // class AndFilter
+public static class IdFilter implements Fixing.Filter {
+protected int columnId;
+public IdFilter(int columnId) {
+this.columnId = columnId;
+}
+@Override
+public boolean accept(Fixing.Column column) {
+return column.getId() == columnId;
+}
+} // class IdFilter
+public static class DateFilter implements Fixing.Filter {
+protected Date date;
+public DateFilter(Date date) {
+this.date = date;
+}
+@Override
+public boolean accept(Fixing.Column column) {
+return date.equals(column.getStartTime());
+}
+} // class DateFilter
+public static class DateRangeFilter implements Fixing.Filter {
+protected Date start;
+protected Date end;
+public DateRangeFilter(Date start, Date end) {
+this.start = start;
+this.end   = end;
+}
+@Override
+public boolean accept(Fixing.Column column) {
+Date date = column.getStartTime();
+return start.compareTo(date) <= 0 && end.compareTo(date) >= 0;
+}
+} // class DateRangeFilter
+public static class SectorRangeFilter implements Fixing.Filter {
+protected int min;
+protected int max;
+public SectorRangeFilter(int min, int max) {
+this.min = Math.min(min, max);
+this.max = Math.max(min, max);
+}
+@Override
+public boolean accept(Fixing.Column column) {
+for (SectorRange s: column.getSectors()) {
+int v = s.getSector();
+if (v >= min && v <= max) {
+return true;
+}
+}
+return false;
+}
+} // class SectorRangeFilter
 public void generateOverview(Document document) {
-generateOverview(document, FULL_EXTENT);
+generateOverview(document, FULL_EXTENT, ACCEPT);
 }
-public void generateOverview(Document document, Range range) {
+public void generateOverview(
+Document      document,
+Range         range,
+Fixing.Filter filter
+) {
 List<Fixing.Column> allColumns = new ArrayList<Fixing.Column>();
 for (Fixing fixing: fixings) {
-fixing.addAllColumns(allColumns, range);
+fixing.addAllColumns(allColumns, range, filter);
 }
 Collections.sort(allColumns, Fixing.DATE_CMP);
 Element fixingsElement = document.createElement("fixings");
 Element esE = document.createElement("events");
 for (Fixing.Column column: allColumns) {
-// TODO: Apply additional filters here.
+List<SectorRange> sectors = column.getSectors(range);
-List<SectorRange> sectors = column.getSectors();
 if (!sectors.isEmpty()) {
 Element eE = document.createElement("event");
 eE.setAttribute("name",
 String.valueOf(column.getFixing().description));

Mercurial > dive4elements > river

comparison flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/FixingsOverview.java @ 2563:59c920e73d8a