D-Net

		System.out.println("\n\nAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA\n\n");

import org.springframework.beans.factory.annotation.Autowired;

	@Autowired

	@Autowired

package eu.dnetlib.msro.worker.ui;

import java.awt.BasicStroke;

import java.awt.Color;

import java.awt.Font;

import java.awt.Graphics2D;

import java.awt.RenderingHints;

import com.googlecode.sarasvati.JoinType;

import com.googlecode.sarasvati.Node;

import com.googlecode.sarasvati.NodeToken;

import com.googlecode.sarasvati.visual.common.NodeDrawConfig;

import com.googlecode.sarasvati.visual.icon.AbstractNodeIcon;

import com.googlecode.sarasvati.visual.util.FontUtil;

import eu.dnetlib.common.ifaces.ProgressProvider;

import eu.dnetlib.msro.worker.WorkflowConstants;

public class ProcessJobIcon extends AbstractNodeIcon {

	/**

	 * node token.

	 */

	private NodeToken token;

	/**

	 * Progress Bar color.

	 */

	private Color progressBarColor = Color.decode("#205fbc");

	/**

	 * Inaccurate Progress Bar color.

	 */

	private Color inaccurateProgressBarColor = Color.DARK_GRAY;

	/**

	 * Progress Bar background color.

	 */

	private Color progressBarBGColor = Color.LIGHT_GRAY;

	/**

	 * A progress provider to display

	 */

	private ProgressProvider progressProvider;

	/**

	 * corner radius.

	 */

	protected static final int ROUND_CORNER = 10;

	/**

	 * length of the space between dashes.

	 */

	protected static final int DASH_EMPTY = 4;

	/**

	 * length of the dash.

	 */

	protected static final int DASH_FULL = 8;

	/**

	 * font size.

	 */

	protected static final int FONT_SIZE = 10;

	/**

	 * node.

	 */

	private Node node;

	/**

	 * is join.

	 * 

	 */

	private boolean join;

	/**

	 * node label.

	 */

	private String label;

	/**

	 * node color.

	 */

	private Color color;

	/**

	 * dashes.

	 */

	private float[] dashes;

	/**

	 * true if terminal node.

	 */

	private boolean terminal;

	private boolean failed;

	public ProcessJobIcon(final Node node, final NodeToken token, final ProgressProvider progressProvider) {

		super();

		this.node = node;

		this.label = node.getAdaptor(String.class);

		if (label == null) {

			label = node.getName();

		}

		this.join = node.getJoinType() == null ? false : node.getJoinType() != JoinType.OR;

		this.color = Color.lightGray;

		if (join) {

			dashes = new float[] { DASH_FULL, DASH_EMPTY };

		}

		this.terminal = node.getGraph().getOutputArcs(node).size() == 0;

		this.token = token;

		this.progressProvider = progressProvider;

		setColor(NodeDrawConfig.getColor(token));

		if (token != null && token.getEnv() != null && "true".equals(token.getEnv().getAttribute(WorkflowConstants.SYSTEM_HAS_FAILED))) {

			setFailed(true);

			setColor(Color.RED);

		}

		if (isJoin()) {

			setDashes(new float[] { DASH_FULL, DASH_EMPTY });

		}

		setTerminal(node.getGraph().getOutputArcs(node).size() == 0);

		redrawImage();

	}

	public void resetGfx(final Graphics2D gfx) {

		gfx.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);

		gfx.setFont(Font.getFont(Font.MONOSPACED));

		if (isTerminal()) {

			gfx.setFont(gfx.getFont().deriveFont(Font.BOLD));

		}

		gfx.setColor(color);

	}

	public boolean isJoin() {

		return join;

	}

	public void setJoin(final boolean join) {

		this.join = join;

	}

	public String getLabel() {

		return label;

	}

	public void setLabel(final String label) {

		this.label = label;

	}

	public Color getColor() {

		return color;

	}

	public void setColor(final Color color) {

		this.color = color;

	}

	public float[] getDashes() {

		return dashes; // NOPMD

	}

	public void setDashes(final float[] dashes) { // NOPMD

		this.dashes = dashes;

	}

	public Node getNode() {

		return node;

	}

	public void setNode(final Node node) {

		this.node = node;

	}

	public boolean isTerminal() {

		return terminal;

	}

	public void setTerminal(final boolean terminal) {

		this.terminal = terminal;

	}

	public boolean isFailed() {

		return failed;

	}

	public void setFailed(final boolean failed) {

		this.failed = failed;

	}

	@Override

	public void redrawImage(final Graphics2D gfx) {

		resetGfx(gfx);

		gfx.fillRoundRect(0, 0, WIDTH - 1, HEIGHT - 1, ROUND_CORNER, ROUND_CORNER);

		gfx.setColor(NodeDrawConfig.NODE_BORDER);

		final BasicStroke stroke = new BasicStroke(2, BasicStroke.CAP_SQUARE, BasicStroke.JOIN_MITER, 10, getDashes(), 0);

		gfx.setStroke(stroke);

		gfx.drawRoundRect(0, 0, WIDTH - 1, HEIGHT - 1, ROUND_CORNER, ROUND_CORNER);

		gfx.setColor(Color.white);

		final int padding = 6;

		final int startX = padding;

		final int maxWidth = getIconWidth() - (padding << 1);

		FontUtil.setSizedFont(gfx, getLabel(), FONT_SIZE, maxWidth);

		final int strWidth = (int) Math.ceil(gfx.getFontMetrics().getStringBounds(getLabel(), gfx).getWidth());

		final int strHeight = gfx.getFontMetrics().getAscent();

		final int left = startX + (maxWidth - strWidth >> 1);

		final int top = getIconHeight() + strHeight >> 1;

		gfx.drawString(getLabel(), left, top);

		if (progressProvider != null && token != null && !token.isComplete()) {

			drawProgressBar(gfx);

		}

		resetGfx(gfx);

	}

	private void drawProgressBar(final Graphics2D gfx) {

		int total = progressProvider.getProgressTotal();

		int current = progressProvider.getProgressPosition();

		if (progressProvider.isProgressInaccurate() || current > total) {

			gfx.setColor(inaccurateProgressBarColor);

			final String text = Integer.toString(current);

			final int strWidth = (int) Math.ceil(gfx.getFontMetrics().getStringBounds(text, gfx).getWidth());

			gfx.drawString(text, getIconWidth() - strWidth - 7, getIconHeight() - 3);

		} else {

			int x = 6;

			int y = getIconHeight() - 6;

			int widthTot = getIconWidth() - x - x;

			int height = 2;

			gfx.setColor(progressBarBGColor);

			gfx.fillRect(x, y, widthTot, height);

			gfx.setColor(progressBarColor);

			int widthCurr = 0;

			if (total > 0) {

				widthCurr = Math.round(widthTot * current / total);

			}

			gfx.fillRect(x, y, widthCurr, height);

		}

	}

	public NodeToken getToken() {

		return token;

	}

	public void setToken(final NodeToken token) {

		this.token = token;

	}

	public Color getProgressBarColor() {

		return progressBarColor;

	}

	public void setProgressBarColor(final Color progressBarColor) {

		this.progressBarColor = progressBarColor;

	}

	public Color getProgressBarBGColor() {

		return progressBarBGColor;

	}

	public void setProgressBarBGColor(final Color progressBarBGColor) {

		this.progressBarBGColor = progressBarBGColor;

	}

	public Color getInaccurateProgressBarColor() {

		return inaccurateProgressBarColor;

	}

	public void setInaccurateProgressBarColor(final Color inaccurateProgressBarColor) {

		this.inaccurateProgressBarColor = inaccurateProgressBarColor;

	}

	public ProgressProvider getProgressProvider() {

		return progressProvider;

	}

	public void setProgressProvider(final ProgressProvider progressProvider) {

		this.progressProvider = progressProvider;

	}

}

package eu.dnetlib.msro.worker.ui;

import javax.swing.Icon;

import com.googlecode.sarasvati.Node;

import com.googlecode.sarasvati.visual.ProcessToImageMapAdapter;

import com.googlecode.sarasvati.visual.process.VisualProcessNode;

import eu.dnetlib.common.ifaces.ProgressProvider;

import eu.dnetlib.msro.worker.nodes.ProgressJobNode;

public class ProcessToImageMapHelper extends ProcessToImageMapAdapter {

	private String procId;

	public ProcessToImageMapHelper(final String procId) {

		super();

		this.procId = procId;

	}

	@Override

	public String hrefForNode(final VisualProcessNode node) {

		return "javascript:getScope('map').getProcessNodeDetails('" + procId + "', '" + node.getNode().getId() + "')";

	}

	@Override

	public String hoverForNode(final VisualProcessNode vnode) {

		final Node node = vnode.getNode();

		if (node instanceof ProgressJobNode) {

			final ProgressProvider progress = ((ProgressJobNode) node).getProgressProvider();

			if (progress == null) {

				return "Processed: -";

			} else if (progress.isProgressInaccurate()) {

				return "Processed: " + progress.getProgressPosition();

			} else {

				return "Processed: " + progress.getProgressPosition() + " - Total: " + progress.getProgressTotal();

			}

		} else {

			return "Name: " + node.getName();

		}

	}

	@Override

	public Icon iconForNode(final VisualProcessNode vnode) {

		final Node node = vnode.getNode();

		final ProgressProvider progressProvider = node instanceof ProgressJobNode ? ((ProgressJobNode) node).getProgressProvider() : null;

		return new ProcessJobIcon(node, vnode.getToken(), progressProvider);

	}

}

package eu.dnetlib.msro.worker.ui;

import java.awt.image.BufferedImage;

import java.io.IOException;

import java.io.OutputStream;

import javax.imageio.ImageIO;

import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.ResponseBody;

import com.googlecode.sarasvati.GraphProcess;

import com.googlecode.sarasvati.visual.ProcessImageMapCreator;

import eu.dnetlib.msro.worker.WorkflowRegistry;

@Controller

@RequestMapping("/msro/process")

public class WorkflowStatusController {

	@Autowired

	private WorkflowRegistry registry;

	@RequestMapping(value = "/{procId}/image", method = RequestMethod.GET)

	public void getProcessImage(final HttpServletResponse response, @PathVariable final String procId) throws IOException {

		final OutputStream out = response.getOutputStream();

		response.setContentType("image/png");

		final GraphProcess proc = registry.findProcess(procId);

		if (proc != null) {

			try {

				final ProcessImageMapCreator imageMapCreator = new ProcessImageMapCreator(proc, new ProcessToImageMapHelper(procId));

				final BufferedImage image = imageMapCreator.getImage();

				ImageIO.write(image, "png", out);

			} catch (Throwable e) {

				IOUtils.copy(getClass().getResourceAsStream("/eu/dnetlib/msro/worker/ui/wf_problem.png"), out);

			}

		} else {

			IOUtils.copy(getClass().getResourceAsStream("/eu/dnetlib/msro/worker/ui/wf_not_found.png"), out);

		}

		out.flush();

		out.close();

	}

	@RequestMapping(value = "/{procId}/map", method = RequestMethod.GET)

	public @ResponseBody

	String getProcessImageMap(@PathVariable final String procId) throws Exception {

		final GraphProcess proc = registry.findProcess(procId);

		if (proc != null) {

			try {

				final ProcessImageMapCreator imageMapCreator = new ProcessImageMapCreator(proc, new ProcessToImageMapHelper(procId));

				return imageMapCreator.getMapContents();

			} catch (Throwable e) {}

		}

		return "";

	}

}

dnet.msro.launch.wfs.startDelay           = 35000

dnet.msro.launch.wfs.repeatInterval       = 10000

				<bean class="org.springframework.scheduling.quartz.SimpleTriggerBean"

					p:startDelay="${dnet.msro.launch.wfs.startDelay}"

					p:repeatInterval="${dnet.msro.launch.wfs.repeatInterval}">

					<property name="jobDetail">

						<bean class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"

							p:targetObject-ref="workflowLauncher" p:targetMethod="startsWfsInQueue" />

					</property>

				</bean>

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"

	xmlns:sec="http://cxf.apache.org/configuration/security" xmlns:wsa="http://cxf.apache.org/ws/addressing"

	xmlns:p="http://www.springframework.org/schema/p" xmlns:http="http://cxf.apache.org/transports/http/configuration"

	xmlns:t="http://dnetlib.eu/springbeans/t" xmlns:template="http://dnetlib.eu/springbeans/template"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

                                    http://cxf.apache.org/ws/addressing http://cxf.apache.org/schemas/ws-addr-conf.xsd

                                    http://cxf.apache.org/configuration/security http://cxf.apache.org/schemas/configuration/security.xsd

                                    http://cxf.apache.org/transports/http/configuration http://cxf.apache.org/schemas/configuration/http-conf.xsd

                            http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd

                            http://dnetlib.eu/springbeans/template http://dnetlib.eu/springbeans/template.xsd">

	<!-- System nodes -->

	<bean id="wfNodeSuccess" class="eu.dnetlib.msro.worker.nodes.SuccessFailureNode" p:success="true" scope="prototype" />

	<bean id="wfNodeFailure" class="eu.dnetlib.msro.worker.nodes.SuccessFailureNode" p:success="false" scope="prototype" />

	<!-- Simple nodes -->

	<bean id="wfNodeSelection" class="eu.dnetlib.msro.worker.nodes.sel.SelectiveNode"

		scope="prototype" />

	<!-- Datasources -->

	<bean id="wfNodeSetProviderInfo"

		class="eu.dnetlib.msro.worker.nodes.info.SetProviderInfoJobNode"

		scope="prototype" />

	<bean id="wfNodeValidateDatasource"

		class="eu.dnetlib.msro.worker.nodes.repohi.ValidateDatasourceJobNode"

		scope="prototype" />

	<bean id="wfNodeVerifyDatasource"

		class="eu.dnetlib.msro.worker.nodes.repohi.VerifyDatasourceJobNode"

		scope="prototype" />

	<!-- Unpack -->

	<bean id="wfNodeUnpack" class="eu.dnetlib.msro.worker.nodes.unpack.UnpackJobNode"

		scope="prototype" />

	<!-- ObjectStore -->

	<bean id="wfNodeCreateObjectStore"

		class="eu.dnetlib.msro.worker.nodes.objectStore.CreateObjectStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeDeleteObjectStore"

		class="eu.dnetlib.msro.worker.nodes.objectStore.DeleteObjectStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeRetrieveURLS"

		class="eu.dnetlib.msro.worker.nodes.objectStore.RetrieveURLSJobNode"

		p:xpathMetadataId="${msro.wf.nodes.download.xpathMetadataId}" scope="prototype" />

	<!-- Download Service -->

	<bean id="wfNodeRetrieveMdStoreId"

		class="eu.dnetlib.msro.worker.nodes.objectStore.RetrieveMdStoreId"

		p:metadataFormat="${msro.wf.nodes.mdstoreSearch.format}"

		p:interpretation="${msro.wf.nodes.mdstoreSearch.interpretation}" />

	<bean id="wfNodeDownloadFromMetadata"

		class="eu.dnetlib.msro.worker.nodes.download.DownloadFromMetadataJobNode"

		scope="prototype" />

	<bean id="wfNodeUpdateObjectStoreSize"

		class="eu.dnetlib.msro.worker.nodes.objectStore.UpdateObjectStoreSizeJobNode"

		scope="prototype" />

	<!-- Collector service -->

	<bean id="wfNodeCollectRecords"

		class="eu.dnetlib.msro.worker.nodes.collect.CollectRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeDateRangeCollectRecords"

		class="eu.dnetlib.msro.worker.nodes.collect.DateRangeCollectRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeFindDateRangeForIncrementalHarvesting"

		class="eu.dnetlib.msro.worker.nodes.collect.FindDateRangeForIncrementalHarvestingJobNode"

		scope="prototype" />

	<bean id="wfNodeMdBuilder"

		class="eu.dnetlib.msro.worker.nodes.transform.MdBuilderJobNode"

		p:mdBuilderTemplateXslt="${msro.wf.nodes.mdbuilder.xslt.template}"

		scope="prototype" />

	<!-- Transform -->

	<bean id="wfNodeTransform"

		class="eu.dnetlib.msro.worker.nodes.transform.TransformJobNode"

		scope="prototype" />

	<bean id="wfNodeApplyXslt"

		class="eu.dnetlib.msro.worker.nodes.transform.ApplyXsltJobNode"

		scope="prototype" />

	<bean id="wfNodeGroovy" class="eu.dnetlib.msro.worker.nodes.transform.GroovyJobNode"

		scope="prototype" />

	<bean id="wfNodeClean" class="eu.dnetlib.msro.worker.nodes.transform.CleanJobNode"

		scope="prototype" />

	<!-- Index -->

	<bean id="wfNodeUpdateIndex"

		class="eu.dnetlib.msro.worker.nodes.index.UpdateIndexJobNode"

		scope="prototype"

		p:layoutToRecordStylesheet="classpath:/eu/dnetlib/msro/workflows/xslt/layoutToRecordStylesheet.xsl"

		p:defaultIndexId="${msro.wf.nodes.index.defaultIndex}" />

	<bean id="wfNodeCreateIndex"

		class="eu.dnetlib.msro.worker.nodes.index.CreateIndexJobNode"

		scope="prototype" p:defaultBackendId="${msro.wf.nodes.index.defaultIndex}" />

	<bean id="wfNodeDeleteIndex"

		class="eu.dnetlib.msro.worker.nodes.index.DeleteIndexJobNode"

		scope="prototype" p:defaultIndexId="${msro.wf.nodes.index.defaultIndex}" />

	<bean id="wfNodePrepareCreateIndex"

		class="eu.dnetlib.msro.worker.nodes.index.PrepareCreateIndexJobNode"

		scope="prototype" />

	<!-- Database -->

	<bean id="wfNodeUpdateDb" class="eu.dnetlib.msro.worker.nodes.db.UpdateDbJobNode"

		scope="prototype" />

	<bean id="wfNodeQueryDb" class="eu.dnetlib.msro.worker.nodes.db.QueryDbJobNode"

		scope="prototype" />

	<bean id="wfNodeExecuteSql" class="eu.dnetlib.msro.worker.nodes.db.ExecuteSqlJobNode"

		scope="prototype" />

	<!-- MDStore -->

	<bean id="wfNodeCreateMDStore"

		class="eu.dnetlib.msro.worker.nodes.mdstore.CreateMDStoreJobNode"

		scope="prototype" />

	<bean id="wfNodeStoreMDStoreRecords"

		class="eu.dnetlib.msro.worker.nodes.mdstore.StoreMDStoreRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeFetchMDStoreRecords"

		class="eu.dnetlib.msro.worker.nodes.mdstore.FetchMDStoreRecordsJobNode"

		scope="prototype" />

	<bean id="wfNodeFetchMultipleMDStoreRecords"

		class="eu.dnetlib.msro.worker.nodes.mdstore.FetchMultipleMDStores"

		scope="prototype" />

	<bean id="wfNodeMDStoreToApiExtraField"

		class="eu.dnetlib.msro.worker.nodes.info.MDStoreToApiExtraFieldJobNode"

		scope="prototype" />

	<bean id="wfNodeObjectStoreToApiExtraField"

		class="eu.dnetlib.msro.worker.nodes.info.ObjectStoreToApiExtraFieldJobNode"

		scope="prototype" />

	<bean id="wfNodeRemoveApiExtraFields"

		class="eu.dnetlib.msro.worker.nodes.info.RemoveApiExtraFieldsJobNode"

		scope="prototype" />

	<bean id="wfNodeSetFormatInfo" class="eu.dnetlib.msro.worker.nodes.SetFormatInfoJobNode"

		scope="prototype" />

	<bean id="wfNodeSetEnvParameter" class="eu.dnetlib.msro.worker.nodes.SetEnvParameterJobNode"

		scope="prototype" />

</beans>

msro.wf.nodes.index.defaultIndex          = solr

msro.wf.nodes.download.xpathMetadataId    = //*[local-name()='objIdentifier']

msro.wf.nodes.mdstoreSearch.format        = DMF

msro.wf.nodes.mdstoreSearch.interprettion = cleaned

msro.wf.nodes.mdbuilder.xslt.template     = classpath:/eu/dnetlib/msro/workflows/xslt/mdBuilder.xslt.st

		<config>src/main/resources/eu/dnetlib/msro/worker/applicationContext-manager-wf-nodes.xml</config>

		<dependency>

			<groupId>javax.servlet</groupId>

			<artifactId>javax.servlet-api</artifactId>

			<version>${javax.servlet.version}</version>

			<scope>provided</scope>

		</dependency>