D-Net

package eu.dnetlib.goldoa.service;

import eu.dnetlib.goldoa.domain.*;

import eu.dnetlib.goldoa.service.dao.RequestDAO;

import eu.dnetlib.goldoa.service.utils.EmailUtils;

import org.apache.commons.codec.digest.DigestUtils;

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

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.RowMapper;

import org.springframework.transaction.annotation.Transactional;

import javax.mail.MessagingException;

import javax.sql.DataSource;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Types;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.concurrent.ExecutorService;

/**

 * Created by antleb on 3/10/15.

 */

@Transactional

public class RequestManagerImpl implements RequestManager {

    @Autowired

    private RequestDAO requestDAO;

    @Autowired

    private PersonManager personManager;

    @Autowired

    private OrganizationManager organizationManager;

    @Autowired

    private ProjectManager projectManager;

    @Autowired

    private PublicationManager publicationManager;

    @Autowired

    private InvoiceManager invoiceManager;

    @Autowired

    private EligibilityManager eligibilityManager;

    @Autowired

    private EmailUtils emailUtils;

    @Autowired

    private ExecutorService executorService;

	@Override

	public Request saveRequest(final Request request) {

		if (request.getId() == null) {

			request.setId(new SimpleDateFormat("yyyyMMdd-").format(new Date()) + requestDAO.getRequestId());

		}

        if (request.getInvoice() != null)

            request.addStatus(Request.RequestStatus.INVOICE_UPLOADED);

        requestDAO.saveRequest(request);

		return request;

	}

	@Override

	public RequestInfo getById(String requestId) {

        try {

            return this.getRequestInfo(requestDAO.getRequest(requestId));

        } catch (PersonManagerException e) {

            e.printStackTrace();

        }

        return null;

	}

    @Override

    public List<RequestInfo> getForUser(String personId, Date from, Date to, RequestSort requestSortBy, RequestSortOrder order, RequestFilter requestFilter, String term, Request.RequestStatus statusFilter) {

        List<Request> requests = requestDAO.getForUser(personId, from, to, requestSortBy, order, requestFilter, term, statusFilter, 0, 0);

        List<RequestInfo> res = new ArrayList<RequestInfo>();

        for (Request request:requests) {

            try {

                RequestInfo req = getShortRequestInfo(request);

                res.add(req);

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

        return res;

    }

	@Override

	public List<Request> getForProject(String projectId) {

		return requestDAO.getForProject(projectId);

	}

    @Override

    public List<RequestInfo> getRequests(Date from, Date to, RequestSort requestSortBy, RequestSortOrder order, RequestFilter requestFilter, String term, Request.RequestStatus statusFilter) {

        List<Request> requests = requestDAO.getRequests(from, to, requestSortBy, order, requestFilter, term, statusFilter, 0, 0);

        List<RequestInfo> res = new ArrayList<RequestInfo>();

        for (Request request:requests) {

            try {

                RequestInfo req = getShortRequestInfo(request);

                res.add(req);

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

        return res;

    }

    @Override

    public Request submitRequest(Request request) throws PersonManagerException {

        request.addStatus(Request.RequestStatus.SUBMITTED);

        saveRequest(request);

        // TODO offline

        RequestInfo requestInfo = this.getRequestInfo(request);

        try {

            switch (requestInfo.getEligibility().getStatus()) {

                case OK:

                    emailUtils.sendRequesterOKEmail(requestInfo);

                    for (Person person : personManager.getModerators())

                        emailUtils.sendModeratorOKEmail(requestInfo, person);

                    break;

                case IFFY:

                    emailUtils.sendRequesterIFFYEmail(requestInfo);

                    for (Person person : personManager.getModerators())

                        emailUtils.sendModeratorIFFYEmail(requestInfo, person);

                    break;

                case NONO:

                    break;

            }

        } catch (MessagingException e) {

            e.printStackTrace();

        }

        return request;

    }

    @Override

    public void approveRequest(String requestId, String comment) {

        requestDAO.approveRequest(requestId, comment);

        RequestInfo requestInfo = getById(requestId);

        try {

            emailUtils.sendRequesterApprovedEmail(requestInfo);

        } catch (MessagingException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void rejectRequest(String requestId, String comment) {

        requestDAO.rejectRequest(requestId, comment);

        RequestInfo requestInfo = getById(requestId);

        try {

            emailUtils.sendRequesterRejectedEmail(requestInfo);

        } catch (MessagingException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void invoiceUploaded(String requestId) {

        requestDAO.invoiceUploaded(requestId);

    }

    private Request.RequestStatus getStatus(Request request) {

        if (request.getStatus(Request.RequestStatus.SUBMITTED)) {

            if (request.getStatus(Request.RequestStatus.APPROVED))

                return  Request.RequestStatus.APPROVED;

            else if (request.getStatus(Request.RequestStatus.REJECTED))

                return Request.RequestStatus.REJECTED;

            else

                return Request.RequestStatus.SUBMITTED;

        }

        else

            return Request.RequestStatus.INCOMPLETE;

    }

    private RequestInfo getRequestInfo(Request request) throws PersonManagerException {

        RequestInfo req = new RequestInfo();

        // TODO add missing fields

        req.setId(request.getId());

        req.setUser(personManager.getById(request.getUser()));

        req.setDate(request.getDate());

        req.setResearcher(personManager.getById(request.getResearcher()));

        req.setProject(projectManager.getById(request.getProject()));

        req.setPublication(publicationManager.getPublication(request.getPublication()));

        req.setProjectParticipation(request.getProjectParticipation());

        req.setFundingRequested(request.getFundingRequested());

        req.setEligibility(eligibilityManager.validate(request));

        req.setStatus(getStatus(request));

        return req;

    }

    private RequestInfo getShortRequestInfo(Request request) throws PersonManagerException {

        RequestInfo req = new RequestInfo();

        // TODO add missing fields

        req.setId(request.getId());

        req.setDate(request.getDate());

        req.setPublication(publicationManager.getPublication(request.getPublication()));

        req.setProjectParticipation(request.getProjectParticipation());

        req.setFundingRequested(request.getFundingRequested());

        req.setStatus(getStatus(request));

        return req;

    }

}