praktikum-holons/src/holeg/ui/model/DecoratedGroupNode.java

package holeg.ui.model;

import java.util.ArrayList;
import java.util.stream.Stream;

import holeg.model.Edge;
import holeg.model.Flexibility;
import holeg.model.GroupNode;
import holeg.model.HolonElement;
import holeg.model.Node;
import holeg.ui.model.DecoratedHolonObject.HolonObjectState;
import jdk.jfr.Unsigned;

/**
 * For the @VisualRepresentationalState only.
 * 
 * @author Tom
 *
 */
public class DecoratedGroupNode {
	private GroupNode model;
	private ArrayList<Supplier> supplierList= new ArrayList<>(); 
	private ArrayList<Passiv> passivList= new ArrayList<>(); 
	private ArrayList<Consumer> consumerList= new ArrayList<>(); 
	private ArrayList<Node> nodeList= new ArrayList<>(); 
	/**
	 * Cables that only exist on that group node. From a object in that group node
	 * to a object in that group Node. Not exit the group node (a layer down).
	 */
	private ArrayList<Edge> internCableList= new ArrayList<>(); 
	/**
	 * Cables that exit this group node (a Layer Up). From a object in this group
	 * node to a object in a upper layer.
	 */
	private ArrayList<ExitCable> exitCableList= new ArrayList<>(); 
	private ArrayList<DecoratedSwitch> switchList= new ArrayList<>(); 
	private ArrayList<DecoratedGroupNode> groupNodeList= new ArrayList<>(); 

	public DecoratedGroupNode(GroupNode model) {
		this.model = model;
	}

	public GroupNode getModel() {
		return model;
	}

	public ArrayList<Supplier> getSupplierList() {
		return supplierList;
	}

	public ArrayList<Passiv> getPassivList() {
		return passivList;
	}

	public ArrayList<Consumer> getConsumerList() {
		return consumerList;
	}

	public ArrayList<Node> getNodeList() {
		return nodeList;
	}

	public ArrayList<Edge> getInternCableList() {
		return internCableList;
	}

	public ArrayList<ExitCable> getExitCableList() {
		return exitCableList;
	}

	public ArrayList<DecoratedSwitch> getSwitchList() {
		return switchList;
	}

	public ArrayList<DecoratedGroupNode> getGroupNodeList() {
		return groupNodeList;
	}

	// Returns the amount of holons and count himself
	public int getAmountOfGroupNodes() {
		return 1 + groupNodeList.stream().map(groupNode -> groupNode.getAmountOfGroupNodes()).reduce(0, Integer::sum);
	}

	public Stream<Flexibility> getFlexibilitiesStream() {

		Stream<Flexibility> flexInChildGorupNode = this.groupNodeList.stream()
				.flatMap(groupNode -> groupNode.getFlexibilitiesStream());

		Stream<Flexibility> flexInThisGorupNode = objectStream()
				.flatMap(object -> object.getModel().getElements().flatMap(ele -> ele.flexList.stream()));

		return Stream.concat(flexInChildGorupNode, flexInThisGorupNode);
	}

	public Stream<DecoratedHolonObject> objectStream() {
		return Stream.concat(Stream.concat(this.consumerList.stream(), this.supplierList.stream()),
				this.passivList.stream());
	}

	// Gather Informations:
	public int getAmountOfSupplier() {
		return supplierList.size()
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfSupplier()).reduce(0, Integer::sum);
	}

	public int getAmountOfConsumer() {
		return consumerList.size()
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfConsumer()).reduce(0, Integer::sum);
	}

	public int getAmountOfPassiv() {
		return passivList.size()
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfPassiv()).reduce(0, Integer::sum);
	}

	public int getAmountOfConsumerWithState(HolonObjectState state) {
		return ((int) consumerList.stream().map(con -> con.getState()).filter(rightState -> (rightState == state))
				.count())
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfConsumerWithState(state)).reduce(0,
						Integer::sum);
	}

	public int getAmountOfElemntsFromHolonObjects() {
		return objectStream().map(object -> (int)object.getModel().getElements().count()).reduce(0, Integer::sum)
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfElemntsFromHolonObjects()).reduce(0,
						Integer::sum);
	}

	public PriorityCounts getPriorityCounts() {
		PriorityCounts priority = new PriorityCounts();
		objectStream().forEach(object -> object.getModel().getElements().forEach(ele -> priority.Count(ele)));
		groupNodeList.stream().forEach(groupNode -> priority.Add(groupNode.getPriorityCounts()));
		return priority;
	}

	public class PriorityCounts {
		@Unsigned
		public int low, medium, high, essential;

		public void Add(PriorityCounts other) {
			low += other.low;
			medium += other.medium;
			high += other.high;
			essential += other.essential;
		}

		public void Count(HolonElement element) {
			switch (element.getPriority()) {
			case Essential:
				essential++;
				break;
			case High:
				high++;
				break;
			case Medium:
				medium++;
				break;
			case Low:
				low++;
				break;
			default:
				break;

			}
		}
	}

	public int getAmountOfAktiveElemntsFromHolonObjects() {
		return objectStream().map(object -> object.getModel().getNumberOfActiveElements()).reduce(0,
						Integer::sum)
				+ groupNodeList.stream().map(groupNode -> groupNode.getAmountOfAktiveElemntsFromHolonObjects())
						.reduce(0, Integer::sum);
	}

	public float getConsumptionFromConsumer() {
		return consumerList.stream().map(con -> con.getEnergyNeededFromNetwork()).reduce(0.f, Float::sum)
				+ groupNodeList.stream().map(groupNode -> groupNode.getConsumptionFromConsumer()).reduce(0.f,
						Float::sum);
	}

	public float getProductionFromSupplier() {
		return supplierList.stream().map(sup -> sup.getEnergyToSupplyNetwork()).reduce(0.f, Float::sum) + groupNodeList
				.stream().map(groupNode -> groupNode.getProductionFromSupplier()).reduce(0.f, Float::sum);
	}

	public float getAverageConsumption() {
		return getConsumptionFromConsumer() / (float) getAmountOfGroupNodes();
	}

	public float getAverageProduction() {
		return getProductionFromSupplier() / (float) getAmountOfGroupNodes();
	}

	public String toString() {
		return "GroupNode" + model.getId() + " with [Supplier:" + getAmountOfSupplier() + ", NotSupplied:"
				+ getAmountOfConsumerWithState(HolonObjectState.NOT_SUPPLIED) + ", PartiallySupplied:"
				+ getAmountOfConsumerWithState(HolonObjectState.PARTIALLY_SUPPLIED) + ", Supplied:"
				+ getAmountOfConsumerWithState(HolonObjectState.SUPPLIED) + ", OverSupplied:"
				+ getAmountOfConsumerWithState(HolonObjectState.OVER_SUPPLIED) + ", Passiv:" + getAmountOfPassiv()
				+ "]";
	}
}