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.json.JSONException;

import org.json.JSONObject;

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

import org.springframework.stereotype.Component;

import java.util.List;

@Component

public class MonitorApiImpl implements MonitorApi {

    @Autowired

    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;

    }

    @Override

    public List<StoredJob> getJobsOfUser(String params) throws JSONException {

        JSONObject json_params = new JSONObject(params);

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

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

        Integer offset = Integer.parseInt(json_params.getString("offset"));

        Integer limit = Integer.parseInt(json_params.getString("limit"));

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

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

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

        List<StoredJob> jobs = null;

        try {

            jobs = getValidationService().

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

        } catch (ValidatorServiceException e) {

            e.printStackTrace();

        }

        return jobs;

    }

    @Override

    public int getJobsOfUserPerValidationStatus(String params) 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 params) 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;

    }

}