D-Net

package eu.dnetlib.msro.workflows.nodes.collect;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;

import javax.annotation.Resource;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import eu.dnetlib.msro.logging.DnetLogger;

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

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

import eu.dnetlib.msro.workflows.procs.Env;

import eu.dnetlib.msro.workflows.procs.ProcessAware;

import eu.dnetlib.msro.workflows.procs.WorkflowProcess;

public class FindDateRangeForIncrementalHarvestingJobNode extends SimpleJobNode implements ProcessAware {

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

	private String fromDateParam;

	private String untilDateParam;

	private static final long ONE_DAY = 1000 * 60 * 60 * 24;

	private WorkflowProcess process;

	@Resource(name = "msroWorkflowLogger")

	private DnetLogger dnetLogger;

	@Override

	protected String execute(final Env env) throws Exception {

		final String fromDate = calculateFromDate();

		final String untilDate = null;

		log.info("Incremental Harv Details - from: " + fromDate + " - until: " + untilDate);

		if (fromDate != null) {

			env.setAttribute(getFromDateParam(), fromDate);

		}

		// if (untilDate != null) {

		// env.setAttribute(getUntilDateParam(), untilDate);

		// }

		return Arc.DEFAULT_ARC;

	}

	private String calculateFromDate() {

		final long d = findLastSuccessStartDate();

		return (d > 0) ? (new SimpleDateFormat("yyyy-MM-dd")).format(new Date(d - ONE_DAY)) : null;

	}

	private long findLastSuccessStartDate() {

		final long res = -1;

		// TODO find the right condition to obtain the list of the previous executions

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

		query.put("", "");

		/*

		 * final Iterator<Map<String, String>> iter = this.dnetLogger.find(query); while (iter.hasNext()) { final Map<String, String> map =

		 * iter.next(); if ("true".equalsIgnoreCase(map.get(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY))) { final long curr =

		 * NumberUtils.toLong(map.get(WorkflowsConstants.SYSTEM_START_DATE), -1); if (curr > res) { res = curr; } } }

		 */

		return res;

	}

	public String getFromDateParam() {

		return this.fromDateParam;

	}

	public void setFromDateParam(final String fromDateParam) {

		this.fromDateParam = fromDateParam;

	}

	public String getUntilDateParam() {

		return this.untilDateParam;

	}

	public void setUntilDateParam(final String untilDateParam) {

		this.untilDateParam = untilDateParam;

	}

	public WorkflowProcess getProcess() {

		return this.process;

	}

	@Override

	public void setProcess(final WorkflowProcess process) {

		this.process = process;

	}

}