/modules/dnet-modular-uis/trunk/src/main/java/eu/dnetlib/functionality/modular/ui/workflows/objects/ProcessInfo.java - Annotate - D-Net - D-Net project tracking tool

dnet50/modules/dnet-modular-uis/trunk/src/main/java/eu/dnetlib/functionality/modular/ui/workflows/objects/ProcessInfo.java @ 43063

-            michele.ar
+package eu.dnetlib.functionality.modular.ui.workflows.objects;
-            michele.ar
+import java.util.ArrayList;
-            michele.ar
+import java.util.List;
-            michele.ar
+import java.util.Map;
             michele.ar
-            michele.ar
+import org.apache.commons.lang3.math.NumberUtils;
 import eu.dnetlib.msro.logging.LogMessage;
-            michele.ar
+import eu.dnetlib.msro.workflows.graph.Graph;
-            michele.ar
+import eu.dnetlib.msro.workflows.procs.Token;
-            michele.ar
+import eu.dnetlib.msro.workflows.procs.WorkflowProcess;
-            michele.ar
+import eu.dnetlib.msro.workflows.util.WorkflowsConstants;
             michele.ar
 /**
  * Created by michele on 09/11/15.
  */
 public class ProcessInfo {
-            michele.ar
+	public class ProcessNode {
 		private final String id;
 		private final String name;
 		private final long startDate;
 		private final long endDate;
-            michele.ar
+		private final String status;
-            michele.ar
+		private final String progress;
-            michele.ar
+		private final Map<String, Object> params;
 		private final Map<String, Object> envParams;
             michele.ar
-            michele.ar
+		public ProcessNode(final Token t, final Graph graph) {
-            michele.ar
+			this.id = t.getId();
 			this.name = t.getNodeName();
 			this.startDate = t.getStartDate();
 			this.endDate = t.getEndDate();
-            michele.ar
+			this.status = t.isActive() ? "active" : t.isFailed() ? "failed" : "done";
-            michele.ar
+			this.progress = t.getProgressProvider() != null ? t.getProgressProvider().getProgressDescription() : "-";
-            michele.ar
+			this.envParams = t.getEnv().getAttributes();
-            michele.ar
+			this.params = graph.getNode(t.getNodeName()).resolveParams(t.getEnv());
             michele.ar
 		public String getId() {
 			return this.id;
+		}
 		public String getName() {
 			return this.name;
+		}
 		public long getStartDate() {
 			return this.startDate;
+		}
 		public long getEndDate() {
 			return this.endDate;
+		}
-            michele.ar
+		public String getStatus() {
 			return this.status;
+		}
-            michele.ar
+		public String getProgress() {
 			return this.progress;
+		}
-            michele.ar
+		public Map<String, Object> getParams() {
 			return this.params;
+		}
 		public Map<String, Object> getEnvParams() {
 			return this.envParams;
+		}
             michele.ar
-            michele.ar
+	private String procId;
-            michele.ar
+	private String wfId;
 	private String name;
-            michele.ar
+	private String family;
 	private String status = "CREATED";
 	private String datasource;
 	private long date = Long.MAX_VALUE;
-            michele.ar
+	private long startDate = 0;
 	private long endDate = 0;
-            michele.ar
+	private List<EnvParam> outputParams = new ArrayList<>();
-            michele.ar
+	private List<ProcessNode> processNodes = new ArrayList<>();
             michele.ar
-            michele.ar
+	public ProcessInfo() {}
             michele.ar
-            michele.ar
+	public ProcessInfo(final String procId) {
 		this.procId = procId;
             michele.ar
-            michele.ar
+	public ProcessInfo(final WorkflowProcess process) {
-            michele.ar
+		this.procId = process.getId();
-            michele.ar
+		this.wfId = process.getProfileId();
-            michele.ar
+		this.name = process.getName();
-            michele.ar
+		this.family = process.getFamily();
 		this.status = process.getStatus().toString();
 		this.datasource = process.getDsName();
 		this.date = process.getLastActivityDate();
-            michele.ar
+		this.startDate = process.getStartDate();
 		this.endDate = process.getEndDate();
-            michele.ar
+		process.getTokens().stream().map(t -> new ProcessNode(t, process.getGraph())).forEach(this.processNodes::add);
             michele.ar
-            michele.ar
+	public ProcessInfo(final Map<String, String> logs) {
 		if (logs == null || logs.isEmpty()) { return; }
 		this.procId = logs.get(WorkflowsConstants.LOG_WF_PROCESS_ID);
 		this.wfId = logs.containsKey(WorkflowsConstants.LOG_WF_PROFILE_ID)
 				? logs.get(WorkflowsConstants.LOG_WF_PROFILE_ID)
 				: logs.get(WorkflowsConstants.LOG_WF_PROFILE_TEMPLATE_ID);
 		this.name = logs.get(WorkflowsConstants.LOG_WF_NAME);
 		this.family = logs.get(WorkflowsConstants.LOG_WF_FAMILY);
 		this.status = logs.get(WorkflowsConstants.LOG_WF_PROCESS_STATUS);
 		this.datasource = logs.get(WorkflowsConstants.LOG_DATASOURCE_NAME);
 		this.date = NumberUtils.toLong(logs.get(LogMessage.LOG_DATE_FIELD), Long.MAX_VALUE);
 		this.startDate = NumberUtils.toLong(logs.get(WorkflowsConstants.LOG_WF_PROCESS_START_DATE), Long.MAX_VALUE);
 		this.endDate = NumberUtils.toLong(logs.get(WorkflowsConstants.LOG_WF_PROCESS_END_DATE), Long.MAX_VALUE);
+	}
-            michele.ar
+	public String getProcId() {
-            michele.ar
+		return this.procId;
             michele.ar
-            michele.ar
+	public void setProcId(final String processId) {
 		this.procId = processId;
+	}
-            michele.ar
+	public String getWfId() {
-            michele.ar
+		return this.wfId;
             michele.ar
 	public void setWfId(final String wfId) {
 		this.wfId = wfId;
+	}
 	public String getName() {
-            michele.ar
+		return this.name;
             michele.ar
 	public void setName(final String name) {
 		this.name = name;
+	}
-            michele.ar
+	public String getFamily() {
-            michele.ar
+		return this.family;
             michele.ar
 	public void setFamily(final String family) {
 		this.family = family;
+	}
-            michele.ar
+	public String getStatus() {
-            michele.ar
+		return this.status;
             michele.ar
 	public void setStatus(final String status) {
 		this.status = status;
+	}
 	public long getStartDate() {
-            michele.ar
+		return this.startDate;
             michele.ar
 	public void setStartDate(final long startDate) {
 		this.startDate = startDate;
+	}
 	public long getEndDate() {
-            michele.ar
+		return this.endDate;
             michele.ar
 	public void setEndDate(final long endDate) {
 		this.endDate = endDate;
+	}
-            michele.ar
+	public String getDatasource() {
-            michele.ar
+		return this.datasource;
             michele.ar
 	public void setDatasource(final String datasource) {
 		this.datasource = datasource;
+	}
 	public long getDate() {
-            michele.ar
+		return this.date;
             michele.ar
 	public void setDate(final long date) {
 		this.date = date;
+	}
-            michele.ar
+	public List<EnvParam> getOutputParams() {
 		return this.outputParams;
             michele.ar
-            michele.ar
+	public void setOutputParams(final List<EnvParam> outputParams) {
 		this.outputParams = outputParams;
             michele.ar
             michele.ar
-            michele.ar
+	public List<ProcessNode> getProcessNodes() {
 		return this.processNodes;
+	}
 	public void setProcessNodes(final List<ProcessNode> processNodes) {
 		this.processNodes = processNodes;
+	}
             michele.ar

Project

General

Profile

D-Net