D-Net

package eu.dnetlib.repo.manager.service.controllers;

import eu.dnetlib.api.functionality.ValidatorService;

import eu.dnetlib.api.functionality.ValidatorServiceException;

import eu.dnetlib.domain.functionality.validator.StoredJob;

import gr.uoa.di.driver.util.ServiceLocator;

import org.apache.log4j.Logger;

import org.json.JSONException;

import org.json.JSONObject;

import org.springframework.stereotype.Component;

import javax.annotation.Resource;

import java.util.List;

import java.util.Map;

@Component

public class MonitorApiImpl implements MonitorApi {

    @Resource(name = "validatorServiceLocator")

    private ServiceLocator<ValidatorService> validatorServiceLocator;

    private ValidatorService getValidationService() {

        return this.validatorServiceLocator.getService();

    }

    public ServiceLocator<ValidatorService> getValidatorServiceLocator() {

        return validatorServiceLocator;

    }

    public void setValidatorServiceLocator(ServiceLocator<ValidatorService> validatorServiceLocator) {

        this.validatorServiceLocator = validatorServiceLocator;

    }

    private static final Logger LOGGER = Logger

            .getLogger(MonitorApiImpl.class);

    @Override

    public List<StoredJob> getJobsOfUser(String user,

                                         String jobType,

                                         String offset,

                                         String limit,

                                         String dateFrom,

                                         String dateTo,

                                         String validationStatus) throws JSONException {

        LOGGER.debug("Params -> " + user);

        LOGGER.debug("Job type -> " + jobType);

        List<StoredJob> jobs = null;

        try {

            jobs = getValidationService().

                    getStoredJobsNew(user, jobType, Integer.parseInt(offset), Integer.parseInt(limit), dateFrom, dateTo, validationStatus);

        } catch (ValidatorServiceException e) {

            e.printStackTrace();

        }

        return jobs;

    }

    @Override

    public int getJobsOfUserPerValidationStatus(String user,

                                                String jobType,

                                                String validationStatus) throws JSONException {

        /*JSONObject json_params = new JSONObject(params);

        String user = json_params.getString("user");

        String jobType = json_params.getString("jobType");

        String validationStatus = json_params.getString("validationStatus");*/

        try {

            return getValidationService().getStoredJobsTotalNumberNew(user, jobType, validationStatus);

        } catch (ValidatorServiceException e) {

            e.printStackTrace();

        }

        return 0;

    }

    @Override

    public StoredJob getJobSummary(String jobId,

                                   String groupBy) throws JSONException {

        /*JSONObject json_params = new JSONObject(params);

        String jobId = json_params.getString("jobId");

        String groupBy = json_params.getString("groupBy");*/

        try {

            return getValidationService().getStoredJob(Integer.parseInt(jobId), groupBy);

        } catch (ValidatorServiceException e) {

            e.printStackTrace();

        }

        return null;

    }

}