Compare commits
No commits in common. "feature/scenario_impl" and "master" have entirely different histories.
feature/sc
...
master
4
.gitignore
vendored
4
.gitignore
vendored
@ -1,4 +0,0 @@
|
|||||||
.idea
|
|
||||||
target
|
|
||||||
|
|
||||||
*.idb
|
|
||||||
Binary file not shown.
Binary file not shown.
@ -1,2 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<module type="JAVA_MODULE" version="4" />
|
|
||||||
23
pom.xml
23
pom.xml
@ -1,23 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
|
||||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
|
||||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
|
||||||
|
|
||||||
<groupId>cz.cvut.fel.sit.omo.foodchain</groupId>
|
|
||||||
<artifactId>FoodChain</artifactId>
|
|
||||||
<version>1.0-SNAPSHOT</version>
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>javax.money</groupId>
|
|
||||||
<artifactId>money-api</artifactId>
|
|
||||||
<version>1.0</version>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
|
|
||||||
<properties>
|
|
||||||
<maven.compiler.target>12</maven.compiler.target>
|
|
||||||
<maven.compiler.source>12</maven.compiler.source>
|
|
||||||
</properties>
|
|
||||||
|
|
||||||
</project>
|
|
||||||
@ -1,16 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.factory.FactoryManager;
|
|
||||||
|
|
||||||
public class FoodChain {
|
|
||||||
|
|
||||||
private static FactoryManager factoryManager = new FactoryManager();
|
|
||||||
|
|
||||||
public static void main(String[] args) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public static FactoryManager getFactoryManager() {
|
|
||||||
return factoryManager;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,89 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.channel;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.util.ChannelObserver;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.util.Observable;
|
|
||||||
|
|
||||||
import java.util.PriorityQueue;
|
|
||||||
import java.util.Queue;
|
|
||||||
import java.util.Set;
|
|
||||||
|
|
||||||
public abstract class ChannelBase implements Observable {
|
|
||||||
protected ProductType productType;
|
|
||||||
protected Queue<Requirement> requirements;
|
|
||||||
protected Queue<Transaction> transactions;
|
|
||||||
|
|
||||||
private Set<ChannelObserver> subscribers;
|
|
||||||
|
|
||||||
public ChannelBase(ProductType type)
|
|
||||||
{
|
|
||||||
this.requirements = new PriorityQueue<>();
|
|
||||||
this.transactions = new PriorityQueue<>();
|
|
||||||
this.productType = type;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ChannelBase()
|
|
||||||
{
|
|
||||||
this.requirements = new PriorityQueue<>();
|
|
||||||
this.transactions = new PriorityQueue<>();
|
|
||||||
this.productType = ProductType.OTHER;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Queue<Transaction> getTransactions()
|
|
||||||
{
|
|
||||||
return this.transactions;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Queue<Requirement> getCurrentRequirements()
|
|
||||||
{
|
|
||||||
return this.requirements;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Adds new requirement to the requirement Queue
|
|
||||||
* @param requirement requirement
|
|
||||||
*/
|
|
||||||
public void addRequirement(Requirement requirement)
|
|
||||||
{
|
|
||||||
this.requirements.add(requirement);
|
|
||||||
notifyAllObservers();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void notifyAllObservers(){
|
|
||||||
subscribers.forEach(subscriber -> subscriber.update(requirements.peek()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void attach(ChannelObserver observer){
|
|
||||||
subscribers.add(observer);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void detach(ChannelObserver observer){
|
|
||||||
subscribers.remove(observer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Adds new transaction to the transaction Queue
|
|
||||||
* @param transaction transaction
|
|
||||||
*/
|
|
||||||
public void addTransaction(Transaction transaction)
|
|
||||||
{
|
|
||||||
this.transactions.add(transaction);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Clears all requirements from this channel
|
|
||||||
*/
|
|
||||||
public void clearRequirements()
|
|
||||||
{
|
|
||||||
this.requirements.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductType getProductType() {
|
|
||||||
return productType;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.channel;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class FruitChannel extends ChannelBase
|
|
||||||
{
|
|
||||||
public FruitChannel()
|
|
||||||
{
|
|
||||||
super(ProductType.FRUIT);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.channel;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class MeatChannel extends ChannelBase
|
|
||||||
{
|
|
||||||
public MeatChannel()
|
|
||||||
{
|
|
||||||
super(ProductType.MEAT);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.channel;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class OtherChannel extends ChannelBase
|
|
||||||
{
|
|
||||||
public OtherChannel()
|
|
||||||
{
|
|
||||||
super();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.channel;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class VegetableChannel extends ChannelBase
|
|
||||||
{
|
|
||||||
public VegetableChannel()
|
|
||||||
{
|
|
||||||
super(ProductType.VEGETABLE);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.factory;
|
|
||||||
|
|
||||||
public class ChannelFactory {
|
|
||||||
}
|
|
||||||
@ -1,55 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.factory;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.pool.PoolDatabase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.util.Singleton;
|
|
||||||
|
|
||||||
import java.lang.reflect.InvocationTargetException;
|
|
||||||
|
|
||||||
public class FactoryManager {
|
|
||||||
|
|
||||||
public NodeFactory getNodeFactoryInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(NodeFactory.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ChannelFactory getChannelFactoryInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ChannelFactory.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ScenarioFactory getScenarioFactoryInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ScenarioFactory.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductFactory getProductFactoryInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ProductFactory.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public PoolDatabase getPoolDatabaseInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(PoolDatabase.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.factory;
|
|
||||||
|
|
||||||
public class NodeFactory {
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.factory;
|
|
||||||
|
|
||||||
public class ProductFactory {
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.factory;
|
|
||||||
|
|
||||||
public class ScenarioFactory {
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class BuyerNodeBase extends NodeBase implements IBuyerNode {
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void buyProduct(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import java.util.Random;
|
|
||||||
|
|
||||||
public class Customer extends BuyerNodeBase {
|
|
||||||
|
|
||||||
public void consumeProduct() {
|
|
||||||
int i = new Random().nextInt(getStorage().size());
|
|
||||||
getStorage().remove(i);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
public class Distributor extends RetailerNodeBase {
|
|
||||||
}
|
|
||||||
@ -1,12 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.TransactionType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class Farmer extends SellerNodeBase {
|
|
||||||
|
|
||||||
public void generateProduct(Product product) {
|
|
||||||
storeProduct(product);
|
|
||||||
createRequirement(TransactionType.SALE, product.getProductType(), product.getName());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,8 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public interface IBuyerNode {
|
|
||||||
|
|
||||||
void buyProduct(Product product);
|
|
||||||
}
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public interface ISellerNode {
|
|
||||||
|
|
||||||
void sellProduct(Product product);
|
|
||||||
|
|
||||||
void addMargin(Product product);
|
|
||||||
}
|
|
||||||
@ -1,135 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.*;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.signature.Signature;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.signature.SignatureManager;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.util.ChannelObserver;
|
|
||||||
|
|
||||||
import javax.money.MonetaryAmount;
|
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
|
|
||||||
public class NodeBase implements ChannelObserver {
|
|
||||||
private final List<ChannelBase> subscribedChannels;
|
|
||||||
private final List<Product> products;
|
|
||||||
private MonetaryAmount money;
|
|
||||||
|
|
||||||
private final List<Transaction> refusedTranslations;
|
|
||||||
|
|
||||||
public NodeBase() {
|
|
||||||
subscribedChannels = new LinkedList<>();
|
|
||||||
products = new LinkedList<>();
|
|
||||||
refusedTranslations = new LinkedList<>();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void sendTransaction(Product product, NodeBase node) {
|
|
||||||
Transaction transaction = new ProductTransaction(this, node, TransactionType.SALE, product);
|
|
||||||
|
|
||||||
subscribedChannels.stream()
|
|
||||||
.filter(ch -> ch.getProductType().equals(product.getProductType()))
|
|
||||||
.findAny().ifPresent(channel -> channel.addTransaction(transaction));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void sendTransaction(MonetaryAmount amount, NodeBase node, ProductTransaction prevTransaction) {
|
|
||||||
Transaction transaction = new FinancialTransaction(this, node, TransactionType.PURCHASE, amount, prevTransaction);
|
|
||||||
|
|
||||||
subscribedChannels.stream()
|
|
||||||
.filter(ch -> ch.getProductType().equals(prevTransaction.getProduct().getProductType()))
|
|
||||||
.findAny().ifPresent(channel -> channel.addTransaction(transaction));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void receiveTransaction(ProductTransaction transaction) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void receiveTransaction(FinancialTransaction transaction) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void refuseTransaction(Transaction transaction) {
|
|
||||||
transaction.endTransaction();
|
|
||||||
refusedTranslations.add(transaction); //TODO maybe need more work on it
|
|
||||||
}
|
|
||||||
|
|
||||||
public Transaction readNextTransaction(ChannelBase channel) {
|
|
||||||
|
|
||||||
|
|
||||||
return channel.getNextTransaction();
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void createRequirement(TransactionType tType, ProductType pType, String pName) {
|
|
||||||
Requirement req = new Requirement(this, tType, pType, pName);
|
|
||||||
subscribedChannels.stream()
|
|
||||||
.filter(ch -> ch.getProductType().equals(pType))
|
|
||||||
.findAny().ifPresent(channel -> channel.addRequirement(req));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void acceptRequirement(Requirement requirement) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void subscribeToChannel(ChannelBase channel) {
|
|
||||||
subscribedChannels.add(channel);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void unsubscribeFromChannel(ChannelBase channel) {
|
|
||||||
subscribedChannels.remove(channel);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void doAction(ProductOperationType action, Product product) {
|
|
||||||
Action actionProcess = new Action(this, product, action);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void doAction(ProductOperationType action) {
|
|
||||||
//create new action
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void storeProduct(Product product) {
|
|
||||||
this.products.add(product);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void storeProducts(List<Product> products) {
|
|
||||||
this.products.addAll(products);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public Product getProductFromStorage(String name, ProductType type) {
|
|
||||||
return products.stream().filter(ch -> ch.getProductType() == type && ch.getName().equals(name)).findFirst().orElse(null);
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<Product> getStorage() {
|
|
||||||
return products;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Signature generateSignature(Transaction transaction) {
|
|
||||||
return SignatureManager.signTransaction(transaction);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public boolean validateSignature(Transaction transaction) {
|
|
||||||
return SignatureManager.validateSignature(transaction);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void update(Requirement requirement) {
|
|
||||||
if (!requirement.getCreator().equals(this))
|
|
||||||
acceptRequirement(requirement);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
public class Processor extends RetailerNodeBase {
|
|
||||||
}
|
|
||||||
@ -1,20 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class RetailerNodeBase extends NodeBase implements IBuyerNode, ISellerNode {
|
|
||||||
@Override
|
|
||||||
public void sellProduct(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void addMargin(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void buyProduct(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
public class Seller extends RetailerNodeBase {
|
|
||||||
}
|
|
||||||
@ -1,15 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.node;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class SellerNodeBase extends NodeBase implements ISellerNode {
|
|
||||||
@Override
|
|
||||||
public void sellProduct(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void addMargin(Product product) {
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,44 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class Action extends OperationBase {
|
|
||||||
|
|
||||||
private final OperationBase lastOperation;
|
|
||||||
private final Product product;
|
|
||||||
private final ProductOperationType type;
|
|
||||||
private int duration;
|
|
||||||
|
|
||||||
public Action(NodeBase node, Product product, ProductOperationType type) {
|
|
||||||
super(node);
|
|
||||||
this.product = product;
|
|
||||||
this.type = type;
|
|
||||||
lastOperation = product.getCurrentOperation();
|
|
||||||
duration = type.getDuration();
|
|
||||||
product.setCurrentOperation(this);
|
|
||||||
product.setStateToReadyForDispatch();
|
|
||||||
}
|
|
||||||
|
|
||||||
private void endAction() {
|
|
||||||
this.setTimeEnd();
|
|
||||||
product.setStateToAvailable();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void tick() {
|
|
||||||
if (duration == 0) endAction();
|
|
||||||
else duration--;
|
|
||||||
}
|
|
||||||
|
|
||||||
public OperationBase getLastOperation() {
|
|
||||||
return lastOperation;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Product getProduct() {
|
|
||||||
return product;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductOperationType getType() {
|
|
||||||
return type;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,25 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
|
|
||||||
import javax.money.MonetaryAmount;
|
|
||||||
|
|
||||||
public class FinancialTransaction extends Transaction {
|
|
||||||
|
|
||||||
private final MonetaryAmount amount;
|
|
||||||
private final ProductTransaction transactionPaid;
|
|
||||||
|
|
||||||
public FinancialTransaction(NodeBase creator, NodeBase receiver, TransactionType type, MonetaryAmount amount, ProductTransaction transactionPaid) {
|
|
||||||
super(creator, receiver, type);
|
|
||||||
this.amount = amount;
|
|
||||||
this.transactionPaid = transactionPaid;
|
|
||||||
}
|
|
||||||
|
|
||||||
public MonetaryAmount getAmount() {
|
|
||||||
return amount;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductTransaction getTransactionPaid() {
|
|
||||||
return transactionPaid;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,34 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
|
|
||||||
public class OperationBase {
|
|
||||||
|
|
||||||
private final LocalDateTime timeStart;
|
|
||||||
private LocalDateTime timeEnd;
|
|
||||||
|
|
||||||
private final NodeBase nodeCreator;
|
|
||||||
|
|
||||||
OperationBase(NodeBase node) {
|
|
||||||
nodeCreator = node;
|
|
||||||
timeStart = LocalDateTime.now();
|
|
||||||
}
|
|
||||||
|
|
||||||
public LocalDateTime getTimeStart() {
|
|
||||||
return timeStart;
|
|
||||||
}
|
|
||||||
|
|
||||||
public LocalDateTime getTimeEnd() {
|
|
||||||
return timeEnd;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setTimeEnd() {
|
|
||||||
this.timeEnd = LocalDateTime.now();
|
|
||||||
}
|
|
||||||
|
|
||||||
public NodeBase getNodeCreator() {
|
|
||||||
return nodeCreator;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,22 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
public enum ProductOperationType {
|
|
||||||
|
|
||||||
STORE_MEAT(10, -8);
|
|
||||||
|
|
||||||
private final int duration;
|
|
||||||
private final int temperature;
|
|
||||||
|
|
||||||
ProductOperationType(int duration, int temperature) {
|
|
||||||
this.duration = duration;
|
|
||||||
this.temperature = temperature;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getDuration() {
|
|
||||||
return duration;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getTemperature() {
|
|
||||||
return temperature;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,38 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class ProductTransaction extends Transaction {
|
|
||||||
|
|
||||||
private final OperationBase lastOperation;
|
|
||||||
private final Product product;
|
|
||||||
private final ProductOperationType type;
|
|
||||||
|
|
||||||
public ProductTransaction(NodeBase creator, NodeBase receiver, TransactionType transactionType, Product product) {
|
|
||||||
super(creator, receiver, transactionType);
|
|
||||||
this.product = product;
|
|
||||||
type = null;
|
|
||||||
lastOperation = product.getCurrentOperation();
|
|
||||||
product.setCurrentOperation(this);
|
|
||||||
product.setStateToReadyForDispatch();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void endTransaction() {
|
|
||||||
super.endTransaction();
|
|
||||||
product.setStateToAvailable();
|
|
||||||
}
|
|
||||||
|
|
||||||
public OperationBase getLastOperation() {
|
|
||||||
return lastOperation;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Product getProduct() {
|
|
||||||
return product;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductOperationType getType() {
|
|
||||||
return type;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,35 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.signature.Signature;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.signature.SignatureManager;
|
|
||||||
|
|
||||||
public abstract class Transaction extends OperationBase {
|
|
||||||
|
|
||||||
private final TransactionType transactionType;
|
|
||||||
private final Signature signature;
|
|
||||||
private final NodeBase nodeReceiver;
|
|
||||||
|
|
||||||
Transaction(NodeBase creator, NodeBase receiver, TransactionType type) {
|
|
||||||
super(creator);
|
|
||||||
transactionType = type;
|
|
||||||
nodeReceiver = receiver;
|
|
||||||
signature = SignatureManager.signTransaction(this);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void endTransaction() {
|
|
||||||
this.setTimeEnd();
|
|
||||||
}
|
|
||||||
|
|
||||||
public TransactionType getTransactionType() {
|
|
||||||
return transactionType;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Signature getSignature() {
|
|
||||||
return signature;
|
|
||||||
}
|
|
||||||
|
|
||||||
public NodeBase getNodeReceiver() {
|
|
||||||
return nodeReceiver;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.operation;
|
|
||||||
|
|
||||||
public enum TransactionType {
|
|
||||||
|
|
||||||
SALE, PURCHASE
|
|
||||||
}
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.parser;
|
|
||||||
|
|
||||||
import org.w3c.dom.Document;
|
|
||||||
import org.w3c.dom.Node;
|
|
||||||
import org.w3c.dom.NodeList;
|
|
||||||
import org.xml.sax.SAXException;
|
|
||||||
|
|
||||||
import javax.xml.parsers.DocumentBuilder;
|
|
||||||
import javax.xml.parsers.DocumentBuilderFactory;
|
|
||||||
import javax.xml.parsers.ParserConfigurationException;
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.IOException;
|
|
||||||
|
|
||||||
public class ConfigurationParser {
|
|
||||||
|
|
||||||
private static Document activeDocument;
|
|
||||||
|
|
||||||
public static void parseDocument(String name) throws ParserConfigurationException, IOException, SAXException {
|
|
||||||
DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
|
|
||||||
factory.setValidating(true);
|
|
||||||
factory.setIgnoringElementContentWhitespace(true);
|
|
||||||
DocumentBuilder builder = factory.newDocumentBuilder();
|
|
||||||
File file = new File(name);
|
|
||||||
activeDocument = builder.parse(file);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static ParserResult getElements(String tag) {
|
|
||||||
NodeList elements = activeDocument.getElementsByTagName(tag);
|
|
||||||
ParserResult resultList = new ParserResult();
|
|
||||||
for (int i = 0; i < elements.getLength(); i++) {
|
|
||||||
Node tmpNode = elements.item(i);
|
|
||||||
ParserResultElement element = new ParserResultElement();
|
|
||||||
for (int j = 0; j < tmpNode.getAttributes().getLength(); j++) {
|
|
||||||
element.addAttribute(tmpNode.getAttributes().item(i).getNodeName(), tmpNode.getAttributes().item(i).getTextContent());
|
|
||||||
}
|
|
||||||
for (int j = 0; j < tmpNode.getChildNodes().getLength(); j++) {
|
|
||||||
element.addChild(tmpNode.getChildNodes().item(i).getNodeName(), tmpNode.getChildNodes().item(i).getTextContent());
|
|
||||||
}
|
|
||||||
resultList.addElement(element);
|
|
||||||
}
|
|
||||||
return resultList;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.parser;
|
|
||||||
|
|
||||||
public class ConsoleParser {
|
|
||||||
}
|
|
||||||
@ -1,22 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.parser;
|
|
||||||
|
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public class ParserResult {
|
|
||||||
|
|
||||||
private final List<ParserResultElement> elements;
|
|
||||||
|
|
||||||
public ParserResult() {
|
|
||||||
elements = new LinkedList<>();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void addElement(ParserResultElement element) {
|
|
||||||
elements.add(element);
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<ParserResultElement> getElements() {
|
|
||||||
return elements;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,56 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.parser;
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
public class ParserResultElement {
|
|
||||||
|
|
||||||
private String name;
|
|
||||||
private Map<String, String> attributes;
|
|
||||||
private Map<String, String> children;
|
|
||||||
|
|
||||||
public ParserResultElement() {
|
|
||||||
attributes = new HashMap<>();
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getName() {
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setName(String name) {
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Map<String, String> getAttributes() {
|
|
||||||
return attributes;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setAttributes(Map<String, String> attributes) {
|
|
||||||
this.attributes = attributes;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void addAttribute(String key, String value) {
|
|
||||||
attributes.put(key, value);
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getAttribute(String key) {
|
|
||||||
return attributes.get(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
public Map<String, String> getChildren() {
|
|
||||||
return children;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setChildren(Map<String, String> children) {
|
|
||||||
this.children = children;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void addChild(String key, String value) {
|
|
||||||
children.put(key, value);
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getChild(String key) {
|
|
||||||
return children.get(key);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class ChannelPool extends PoolListBase<ChannelBase> {
|
|
||||||
|
|
||||||
public ChannelBase findByType(ProductType type) {
|
|
||||||
return findAll().stream().filter(ch -> ch.getProductType().equals(type)).findFirst().orElse(null);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,7 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
|
|
||||||
public class NodePool extends PoolListBase<NodeBase> {
|
|
||||||
//TODO Tomas Angelo
|
|
||||||
}
|
|
||||||
@ -1,44 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.util.Singleton;
|
|
||||||
|
|
||||||
import java.lang.reflect.InvocationTargetException;
|
|
||||||
|
|
||||||
public class PoolDatabase {
|
|
||||||
|
|
||||||
public ChannelPool getChannelPoolInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ChannelPool.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public NodePool getNodePoolInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(NodePool.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductPool getProductPoolInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ProductPool.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ScenarioPool getScenarioPoolInstance() {
|
|
||||||
try {
|
|
||||||
return Singleton.getInstance(ScenarioPool.class);
|
|
||||||
} catch (IllegalAccessException | InstantiationException | NoSuchMethodException | InvocationTargetException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,32 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public abstract class PoolListBase<T> {
|
|
||||||
List<T> pool;
|
|
||||||
|
|
||||||
public PoolListBase() {
|
|
||||||
pool = new LinkedList<T>();
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<T> findAll() {
|
|
||||||
return pool;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void add(T element) {
|
|
||||||
pool.add(element);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void remove(T element) {
|
|
||||||
pool.remove(element);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void clear() {
|
|
||||||
pool.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean contains(T element) {
|
|
||||||
return pool.contains(element);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class ProductPool extends PoolListBase<Product> {
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.pool;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.scenario.Scenario;
|
|
||||||
|
|
||||||
public class ScenarioPool extends PoolListBase<Scenario> {
|
|
||||||
}
|
|
||||||
@ -1,124 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.product;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.OperationBase;
|
|
||||||
|
|
||||||
public class Product
|
|
||||||
{
|
|
||||||
private ProductState productState;
|
|
||||||
private ProductType productType;
|
|
||||||
private OperationBase currentOperation;
|
|
||||||
|
|
||||||
private String name;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Creates Product with default state AVAILABLE
|
|
||||||
* @param name name of product
|
|
||||||
* @param productType type of product
|
|
||||||
*/
|
|
||||||
public Product(String name, ProductType productType)
|
|
||||||
{
|
|
||||||
this.name = name;
|
|
||||||
this.productType = productType;
|
|
||||||
this.productState = ProductState.AVAILABLE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Creates Product
|
|
||||||
* @param name name of product
|
|
||||||
* @param productType type of product
|
|
||||||
* @param productState state of product
|
|
||||||
*/
|
|
||||||
public Product(String name, ProductType productType, ProductState productState)
|
|
||||||
{
|
|
||||||
this.name = name;
|
|
||||||
this.productType = productType;
|
|
||||||
this.productState = productState;
|
|
||||||
}
|
|
||||||
|
|
||||||
// "State machine methods"
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Set current product state to AVAILABLE
|
|
||||||
*/
|
|
||||||
public void setStateToAvailable()
|
|
||||||
{
|
|
||||||
this.productState = ProductState.AVAILABLE;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Set current product state to READY_FOR_DISPATCH. Throws IllegalStateException if the product is not AVAILABLE.
|
|
||||||
*/
|
|
||||||
public void setStateToReadyForDispatch()
|
|
||||||
{
|
|
||||||
if(this.productState.equals(ProductState.AVAILABLE))
|
|
||||||
this.productState = ProductState.READY_FOR_DISPATCH;
|
|
||||||
else
|
|
||||||
throw new IllegalStateException("Cannot set state READY_FOR_DISPATCH. Product is not AVAILABLE!");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Set current product state to IN_TRANSIT. Throws IllegalStateException if the product is not READY_FOR_DISPATCH.
|
|
||||||
*/
|
|
||||||
public void setStateToInTransit()
|
|
||||||
{
|
|
||||||
if(this.productState.equals(ProductState.READY_FOR_DISPATCH))
|
|
||||||
this.productState = ProductState.IN_TRANSIT;
|
|
||||||
else
|
|
||||||
throw new IllegalStateException("Cannot set state IN_TRANSIT. Product is not READY_FOR_DISPATCH!");
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Set current product state to READY_FOR_RECEPTION. Throws IllegalStateException if the product is not READY_FOR_RECEPTION.
|
|
||||||
*/
|
|
||||||
public void setStateToReadyForReception()
|
|
||||||
{
|
|
||||||
if(this.productState.equals(ProductState.IN_TRANSIT))
|
|
||||||
this.productState = ProductState.READY_FOR_RECEPTION;
|
|
||||||
else
|
|
||||||
throw new IllegalStateException("Cannot set state READY_FOR_RECEPTION. Product has not been in transit!");
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
public void setProductState(ProductState productState)
|
|
||||||
{
|
|
||||||
this.productState = productState;
|
|
||||||
}*/
|
|
||||||
|
|
||||||
|
|
||||||
//Getters & Setters
|
|
||||||
|
|
||||||
public ProductState getProductState()
|
|
||||||
{
|
|
||||||
return productState;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductType getProductType()
|
|
||||||
{
|
|
||||||
return productType;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setProductType(ProductType productType)
|
|
||||||
{
|
|
||||||
this.productType = productType;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getName()
|
|
||||||
{
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setName(String name)
|
|
||||||
{
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public OperationBase getCurrentOperation()
|
|
||||||
{
|
|
||||||
return currentOperation;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setCurrentOperation(OperationBase currentOperation)
|
|
||||||
{
|
|
||||||
this.currentOperation = currentOperation;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.product;
|
|
||||||
|
|
||||||
public enum ProductState
|
|
||||||
{
|
|
||||||
AVAILABLE, READY_FOR_DISPATCH, IN_TRANSIT, READY_FOR_RECEPTION;
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.product;
|
|
||||||
|
|
||||||
public enum ProductType
|
|
||||||
{
|
|
||||||
MEAT, FRUIT, VEGETABLE, OTHER;
|
|
||||||
}
|
|
||||||
@ -1,19 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.reporting;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.channel.ChannelBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.OperationBase;
|
|
||||||
|
|
||||||
public class ReportTextFileVisitor {
|
|
||||||
public void visit(NodeBase node){
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public void visit(OperationBase operationBase){
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public void visit(ChannelBase channel){
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,4 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.reporting;
|
|
||||||
|
|
||||||
public class ReportingManager {
|
|
||||||
}
|
|
||||||
@ -1,46 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.requirement;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.TransactionType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class Requirement {
|
|
||||||
|
|
||||||
private final NodeBase creator;
|
|
||||||
private final TransactionType transactionType;
|
|
||||||
private final ProductType productType;
|
|
||||||
private final String productName;
|
|
||||||
private int TTL;
|
|
||||||
|
|
||||||
public Requirement(NodeBase creator, TransactionType transactionType, ProductType productType, String productName) {
|
|
||||||
this.creator = creator;
|
|
||||||
this.transactionType = transactionType;
|
|
||||||
this.productType = productType;
|
|
||||||
this.productName = productName;
|
|
||||||
TTL = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void tick() {
|
|
||||||
TTL--;
|
|
||||||
}
|
|
||||||
|
|
||||||
public NodeBase getCreator() {
|
|
||||||
return creator;
|
|
||||||
}
|
|
||||||
|
|
||||||
public TransactionType getTransactionType() {
|
|
||||||
return transactionType;
|
|
||||||
}
|
|
||||||
|
|
||||||
public ProductType getProductType() {
|
|
||||||
return productType;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getProductName() {
|
|
||||||
return productName;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getTTL() {
|
|
||||||
return TTL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.Customer;
|
|
||||||
|
|
||||||
public class ConsumeProductStep extends ScenarioStep {
|
|
||||||
|
|
||||||
private Customer node;
|
|
||||||
|
|
||||||
public ConsumeProductStep(Customer node) {
|
|
||||||
this.node = node;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
void execute() {
|
|
||||||
node.consumeProduct();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,32 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.ProductOperationType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class DoActionStep extends ScenarioStep {
|
|
||||||
private final NodeBase nodeBase;
|
|
||||||
private final ProductOperationType productOperationType;
|
|
||||||
private final Product product;
|
|
||||||
|
|
||||||
public DoActionStep(NodeBase node, ProductOperationType productOperationType, Product product){
|
|
||||||
this.nodeBase = node;
|
|
||||||
this.productOperationType = productOperationType;
|
|
||||||
this.product = product;
|
|
||||||
}
|
|
||||||
|
|
||||||
public DoActionStep(NodeBase node, ProductOperationType productOperationType){
|
|
||||||
this(node, productOperationType, null);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
void execute() {
|
|
||||||
if (product != null){
|
|
||||||
nodeBase.doAction(productOperationType, product);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
nodeBase.doAction(productOperationType);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,24 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.FoodChain;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.Farmer;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.Product;
|
|
||||||
|
|
||||||
public class GenerateProductStep extends ScenarioStep {
|
|
||||||
|
|
||||||
private Farmer node;
|
|
||||||
private Product product;
|
|
||||||
|
|
||||||
public GenerateProductStep(Farmer node) {
|
|
||||||
this.node = node;
|
|
||||||
product = FoodChain.getFactoryManager().getPoolDatabaseInstance().getProductPoolInstance().findAll()
|
|
||||||
.stream().findFirst().orElse(null);
|
|
||||||
FoodChain.getFactoryManager().getPoolDatabaseInstance().getProductPoolInstance().remove(product);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
void execute() {
|
|
||||||
node.generateProduct(product);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
import java.util.Iterator;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public class Scenario {
|
|
||||||
List<ScenarioStep> steps;
|
|
||||||
Iterator<ScenarioStep> stepIterator;
|
|
||||||
|
|
||||||
public Scenario() {
|
|
||||||
//steps = //TODO init
|
|
||||||
stepIterator = steps.listIterator(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
public Scenario(List<ScenarioStep> steps) {
|
|
||||||
this.steps = steps;
|
|
||||||
stepIterator = steps.listIterator(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
void execute() {
|
|
||||||
if (!stepIterator.hasNext()) {
|
|
||||||
stepIterator = steps.listIterator(0);
|
|
||||||
}
|
|
||||||
stepIterator.next().execute();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,5 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
public abstract class ScenarioStep {
|
|
||||||
abstract void execute();
|
|
||||||
}
|
|
||||||
@ -1,24 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.scenario;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.node.NodeBase;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.TransactionType;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.product.ProductType;
|
|
||||||
|
|
||||||
public class SendRequirementStep extends ScenarioStep {
|
|
||||||
private final NodeBase node;
|
|
||||||
private final TransactionType tType;
|
|
||||||
private final ProductType pType;
|
|
||||||
private final String pName;
|
|
||||||
|
|
||||||
public SendRequirementStep(NodeBase node, TransactionType tType, ProductType pType, String pName) {
|
|
||||||
this.node = node;
|
|
||||||
this.tType = tType;
|
|
||||||
this.pType = pType;
|
|
||||||
this.pName = pName;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
void execute() {
|
|
||||||
node.createRequirement(tType, pType, pName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.signature;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.util.UUID;
|
|
||||||
|
|
||||||
public class Signature {
|
|
||||||
|
|
||||||
private final String managerCode;
|
|
||||||
private final Transaction transaction;
|
|
||||||
private final LocalDateTime signedDate;
|
|
||||||
private final UUID uuid;
|
|
||||||
|
|
||||||
public Signature(String code, Transaction transaction) {
|
|
||||||
managerCode = code;
|
|
||||||
this.transaction = transaction;
|
|
||||||
signedDate = LocalDateTime.now();
|
|
||||||
uuid = UUID.randomUUID();
|
|
||||||
}
|
|
||||||
|
|
||||||
public Transaction getTransaction(String code) {
|
|
||||||
if (code.equals(managerCode))
|
|
||||||
return transaction;
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public LocalDateTime getSignedDate(String code) {
|
|
||||||
if (code.equals(managerCode))
|
|
||||||
return signedDate;
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public UUID getUuid(String code) {
|
|
||||||
if (code.equals(managerCode))
|
|
||||||
return uuid;
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.signature;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.operation.Transaction;
|
|
||||||
|
|
||||||
public class SignatureManager {
|
|
||||||
|
|
||||||
private static final String MANAGER_CODE = "iW91AJWNOCmX1pbpLlW0";
|
|
||||||
|
|
||||||
public static Signature signTransaction(Transaction transaction) {
|
|
||||||
return new Signature(MANAGER_CODE, transaction);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static boolean validateSignature(Transaction transaction) {
|
|
||||||
return transaction.equals(transaction.getSignature().getTransaction(MANAGER_CODE))
|
|
||||||
&& transaction.getSignature().getUuid(MANAGER_CODE).equals(transaction.getSignature().getTransaction(MANAGER_CODE).getSignature().getUuid(MANAGER_CODE));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,7 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.util;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.requirement.Requirement;
|
|
||||||
|
|
||||||
public interface ChannelObserver {
|
|
||||||
void update(Requirement requirement);
|
|
||||||
}
|
|
||||||
@ -1,7 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.util;
|
|
||||||
|
|
||||||
public interface Observable {
|
|
||||||
void attach(ChannelObserver channelObserver);
|
|
||||||
void detach(ChannelObserver channelObserver);
|
|
||||||
void notifyAllObservers();
|
|
||||||
}
|
|
||||||
@ -1,27 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.util;
|
|
||||||
|
|
||||||
import java.lang.reflect.Constructor;
|
|
||||||
import java.lang.reflect.InvocationTargetException;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
public class Singleton {
|
|
||||||
|
|
||||||
private static final Singleton instance = new Singleton();
|
|
||||||
|
|
||||||
@SuppressWarnings("rawtypes")
|
|
||||||
private final Map<Class, Object> mapHolder = new HashMap<>();
|
|
||||||
|
|
||||||
private Singleton() {
|
|
||||||
}
|
|
||||||
|
|
||||||
public static <T> T getInstance(Class<T> tClass) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException, InstantiationException {
|
|
||||||
if (!instance.mapHolder.containsKey(tClass)) {
|
|
||||||
Constructor<T> cons = tClass.getConstructor();
|
|
||||||
Object object = cons.newInstance();
|
|
||||||
instance.mapHolder.put(tClass, object);
|
|
||||||
}
|
|
||||||
|
|
||||||
return (T) instance.mapHolder.get(tClass);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
package cz.cvut.fel.sit.omo.foodchain.util;
|
|
||||||
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.FoodChain;
|
|
||||||
import cz.cvut.fel.sit.omo.foodchain.pool.PoolDatabase;
|
|
||||||
|
|
||||||
import javax.swing.*;
|
|
||||||
|
|
||||||
public class Ticker {
|
|
||||||
|
|
||||||
private static Timer timer;
|
|
||||||
|
|
||||||
public static void start() {
|
|
||||||
timer = new Timer(500, actionEvent -> {
|
|
||||||
PoolDatabase db = FoodChain.getFactoryManager().getPoolDatabaseInstance();
|
|
||||||
db.getChannelPoolInstance().findAll().forEach(ch -> ch.tick()); // change TTL of requirements
|
|
||||||
db.getNodePoolInstance().findAll().forEach(ch -> ch.tick()); // do next step in scenario
|
|
||||||
db.getProductPoolInstance().findAll().forEach(ch -> ch.tick()); // change duration of action
|
|
||||||
db.getScenarioPoolInstance().findAll().forEach(ch -> ch.tick()); // maybe unnecessary
|
|
||||||
});
|
|
||||||
timer.start();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void stop() {
|
|
||||||
timer.stop();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
x
Reference in New Issue
Block a user