D-Net

import java.io.StringReader;

import java.lang.reflect.Type;

import java.util.HashMap;

import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.lang.StringEscapeUtils;

import org.apache.commons.lang.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.dom4j.Document;

import org.dom4j.Element;

import org.dom4j.Node;

import org.dom4j.io.SAXReader;

import com.google.gson.Gson;

import com.google.gson.reflect.TypeToken;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;

import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;

import eu.dnetlib.enabling.locators.UniqueServiceLocator;

import eu.dnetlib.msro.rmi.MSROException;

import eu.dnetlib.msro.workflows.graph.Arc;

import eu.dnetlib.msro.workflows.util.WorkflowsConstants;

	private String envParamsJson;

	private String simpleParamsJson;

	@Resource

	private UniqueServiceLocator serviceLocator;

	private static final Log log = LogFactory.getLog(UpdateWfParametersJobNode.class);

		final Gson gson = new Gson();

		final Map<String, Object> params = new HashMap<String, Object>();

		final Type type = new TypeToken<Map<String, Object>>() {}.getType();

		if (StringUtils.isNotBlank(this.simpleParamsJson)) {

			final Map<String, Object> map = gson.fromJson(this.simpleParamsJson, type);

			for (final Map.Entry<String, Object> e : map.entrySet()) {

				params.put(e.getKey(), e.getValue());

			}

		}

		if (StringUtils.isNotBlank(this.envParamsJson)) {

			final Map<String, Object> map = gson.fromJson(this.envParamsJson, type);

			for (final Map.Entry<String, Object> e : map.entrySet()) {

				params.put(e.getKey(), env.getAttribute(e.getValue().toString()));

			}

		}

		if (!params.isEmpty()) {

			final String profId = env.getAttribute("repoWfId", String.class);

			final String profile = this.serviceLocator.getService(ISLookUpService.class).getResourceProfile(profId);

			final Document doc = new SAXReader().read(new StringReader(profile));

			final Node paramsNode = doc.selectSingleNode("//CONFIGURATION/PARAMETERS");

			for (final Map.Entry<String, Object> e : params.entrySet()) {

				final Element node = (Element) paramsNode.selectSingleNode("./PARAM[@name = '" + StringEscapeUtils.escapeXml(e.getKey()) + "']");

				if (node != null) {

					node.setText("" + e.getValue());

					log.debug(String.format("Workflow %s, param %s = %s", profId, e.getKey(), "" + e.getValue()));

				} else {

					log.error(String.format("Invalid param %s for %s", e.getKey(), profId));

					throw new MSROException(String.format("Invalid param %s for %s", e.getKey(), profId));

				}

			}

			if (paramsNode.selectNodes("//PARAM[@managedBy='system' and @required='true' and not(text())]").size() > 0) {

				((Element) doc.selectSingleNode("//CONFIGURATION")).addAttribute("status", WorkflowsConstants.WorkflowStatus.WAIT_SYS_SETTINGS.toString());

				throw new MSROException("Error: some system parameters are empty");

			} else if (paramsNode.selectNodes("//PARAM[@managedBy='user' and @required='true' and not(text())]").size() > 0) {

				((Element) doc.selectSingleNode("//CONFIGURATION")).addAttribute("status", WorkflowsConstants.WorkflowStatus.WAIT_USER_SETTINGS.toString());

			} else {

				((Element) doc.selectSingleNode("//CONFIGURATION")).addAttribute("status", WorkflowsConstants.WorkflowStatus.EXECUTABLE.toString());

			}

			this.serviceLocator.getService(ISRegistryService.class).updateProfile(profId, doc.asXML(), doc.valueOf("//RESOURCE_TYPE/@value"));

		}

		return Arc.DEFAULT_ARC;

	public String getEnvParamsJson() {

		return this.envParamsJson;

	}

	public void setEnvParamsJson(final String envParamsJson) {

		this.envParamsJson = envParamsJson;

	}

	public String getSimpleParamsJson() {

		return this.simpleParamsJson;

	}

	public void setSimpleParamsJson(final String simpleParamsJson) {

		this.simpleParamsJson = simpleParamsJson;

	}