package foundation.action;
|
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
|
import foundation.dao.DataPackage;
|
import foundation.dao.DataReader;
|
import foundation.dao.DataWriter;
|
import foundation.handler.ResultPool;
|
import foundation.json.IJSONProvider;
|
import foundation.json.IJSONWriter;
|
import foundation.util.ContentBuilder;
|
|
public class WorkFlowRuntime implements IWorkflowRuntime, Iterable<ActionContext>, IJSONProvider {
|
|
private String dataName;
|
private String operator;
|
private DataPackage dataPackage;
|
private StateContext stateContext;
|
private ContextBucket workFlowContexts;
|
private List<ActionContext> actionContexts;
|
private double transactionScore;
|
private boolean terminated;
|
private DataReader dataReader;
|
private DataWriter dataWriter;
|
|
|
public WorkFlowRuntime(DataReader dataReader, DataWriter dataWriter, IWorkStep... steps) throws Exception {
|
//1.
|
this.dataReader = dataReader;
|
this.dataWriter = dataWriter;
|
|
transactionScore = 0;
|
terminated = false;
|
actionContexts = new ArrayList<ActionContext>();
|
|
stateContext = new StateContext();
|
workFlowContexts = new ContextBucket();
|
workFlowContexts.addOne(stateContext);
|
|
//2.
|
if (steps == null || steps.length == 0) {
|
return;
|
}
|
|
for (IWorkStep step: steps) {
|
if (step == null) {
|
continue;
|
}
|
|
ActionContext actionContext = new ActionContext(stateContext, this, step);
|
loadOne(actionContext);
|
}
|
}
|
|
public void loadMainSteps(String dataName, String operator, String event, WorkflowBuckets workflowBuckets) throws Exception {
|
this.dataName = dataName;
|
this.operator = operator;
|
|
List<WorkStep> stepList = workflowBuckets.getWorkflow(dataName, operator, event);
|
|
if (stepList == null) {
|
return;
|
}
|
|
for (WorkStep step: stepList) {
|
ActionContext actionContext = new ActionContext(stateContext, this, step);
|
loadOne(actionContext);
|
}
|
}
|
|
public void loadReferToSteps(DataPackage dataPackage, Moment moment, String event, WorkflowBuckets workflowBuckets) {
|
String dataName = dataPackage.getName();
|
List<WorkStep> steps = workflowBuckets.getWorkflow(dataName, moment, event);
|
|
if (steps == null) {
|
return;
|
}
|
|
for (WorkStep step: steps) {
|
ActionContext actionContext = new ActionContext(stateContext, this, step);
|
actionContext.setDataPackage(dataPackage);
|
loadOne(actionContext);
|
}
|
}
|
|
public void loadOne(ActionContext action) {
|
actionContexts.add(action);
|
transactionScore = transactionScore + action.getTransactionScore();
|
}
|
|
public int getActionLength() {
|
return actionContexts.size();
|
}
|
|
public boolean nesessaryTransaction() {
|
return transactionScore >= 1;
|
}
|
|
@Override
|
public Iterator<ActionContext> iterator() {
|
return actionContexts.iterator();
|
}
|
|
public String getDataName() {
|
return dataName;
|
}
|
|
public void terminate() {
|
terminated = true;
|
}
|
|
public boolean isTerminated() {
|
return terminated;
|
}
|
|
public void setDataPackage(DataPackage dataPackage) {
|
this.dataPackage = dataPackage;
|
}
|
|
public DataReader getDataReader() {
|
return dataReader;
|
}
|
|
public void setDataReader(DataReader dataReader) {
|
this.dataReader = dataReader;
|
}
|
|
public DataWriter getDataWriter() {
|
return dataWriter;
|
}
|
|
public void setDataWriter(DataWriter dataWriter) {
|
this.dataWriter = dataWriter;
|
}
|
|
public ResultPool getResultPool() {
|
return dataWriter.getResultPool();
|
}
|
|
public DataPackage getDataPackage() {
|
return dataPackage;
|
}
|
|
public <T> T getContext(Class<?> clazz) {
|
return workFlowContexts.getOne(clazz);
|
}
|
|
public void addContext(Object context) {
|
workFlowContexts.addOne(context);
|
}
|
|
public StateContext getStateContext() {
|
return stateContext;
|
}
|
|
@Override
|
public String toString() {
|
String title = "[" + dataName + "-" + operator + "]: ";
|
ContentBuilder result = new ContentBuilder(title, ", ");
|
|
for (ActionContext action: actionContexts) {
|
action.toString(result);
|
}
|
|
return result.toString();
|
}
|
|
@Override
|
public void writeJSON(IJSONWriter writer) {
|
writer.beginObject();
|
|
writer.write("data_name", dataName);
|
writer.write("operator", operator);
|
writer.write("transaction_score", transactionScore);
|
|
writer.beginArray("actions");
|
for (ActionContext action: actionContexts) {
|
writer.write(action.getDescription());
|
}
|
writer.endArray();
|
|
writer.endObject();
|
}
|
|
}
|
