package gov.foia.service;

/*-
 * #%L
 * ACM Standard Application: Freedom of Information Act
 * %%
 * Copyright (C) 2014 - 2018 ArkCase LLC
 * %%
 * This file is part of the ArkCase software.
 *
 * If the software was purchased under a paid ArkCase license, the terms of
 * the paid license agreement will prevail.  Otherwise, the software is
 * provided under the following open source license terms:
 *
 * ArkCase is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * ArkCase is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with ArkCase. If not, see <http://www.gnu.org/licenses/>.
 * #L%
 */

import com.armedia.acm.auth.AuthenticationUtils;
import com.armedia.acm.core.exceptions.AcmCreateObjectFailedException;
import com.armedia.acm.core.exceptions.AcmListObjectsFailedException;
import com.armedia.acm.core.exceptions.AcmObjectNotFoundException;
import com.armedia.acm.core.exceptions.AcmUpdateObjectFailedException;
import com.armedia.acm.core.exceptions.AcmUserActionFailedException;
import com.armedia.acm.plugins.addressable.model.ContactMethod;
import com.armedia.acm.plugins.addressable.model.PostalAddress;
import com.armedia.acm.plugins.casefile.dao.CaseFileDao;
import com.armedia.acm.plugins.casefile.model.CaseFile;
import com.armedia.acm.plugins.casefile.service.SaveCaseService;
import com.armedia.acm.plugins.ecm.dao.EcmFileDao;
import com.armedia.acm.plugins.ecm.exception.AcmFolderException;
import com.armedia.acm.plugins.ecm.model.AcmContainer;
import com.armedia.acm.plugins.ecm.model.AcmFolder;
import com.armedia.acm.plugins.ecm.service.AcmFolderService;
import com.armedia.acm.plugins.ecm.service.EcmFileService;
import com.armedia.acm.plugins.objectassociation.model.ObjectAssociation;
import com.armedia.acm.plugins.objectassociation.service.ObjectAssociationService;
import com.armedia.acm.plugins.person.model.Person;
import com.armedia.acm.services.notification.service.NotificationSender;
import com.armedia.acm.services.pipeline.exception.PipelineProcessException;
import com.armedia.acm.services.search.service.ExecuteSolrQuery;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.security.core.Authentication;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import gov.foia.broker.FOIARequestFileBrokerClient;
import gov.foia.dao.FOIARequestDao;
import gov.foia.model.FOIAConstants;
import gov.foia.model.FOIARequest;
import gov.foia.model.FoiaConfig;

/**
 * @author sasko.tanaskoski
 */
public class FOIARequestService
{

    private final Logger log = LogManager.getLogger(getClass());
    private SaveCaseService saveCaseService;
    private ResponseFolderCompressorService responseFolderCompressorService;
    private FOIARequestFileBrokerClient foiaRequestFileBrokerClient;
    private FOIARequestDao foiaRequestDao;
    private CaseFileDao caseFileDao;
    private EcmFileDao ecmFileDao;
    private AcmFolderService acmFolderService;
    private EcmFileService ecmFileService;
    private NotificationSender notificationSender;
    private String originalRequestFolderNameFormat;
    private String appealTitleFormat;
    private QueuesTimeToCompleteService queuesTimeToCompleteService;
    private FoiaConfigurationService foiaConfigurationService;
    private ExecuteSolrQuery executeSolrQuery;
    private FoiaConfig foiaConfig;
    private ObjectAssociationService objectAssociationService;

    @Transactional
    public CaseFile saveRequest(CaseFile in, Map<String, List<MultipartFile>> filesMap, Authentication auth, String ipAddress)
            throws AcmCreateObjectFailedException
    {
        log.trace("Saving FOIARequest with Request Number: [{}], Request title: [{}], Request ID: [{}]", in.getCaseNumber(), in.getTitle(),
                in.getId());

        // explicitly set modifier and modified to trigger transformer to reindex data
        // fixes problem when some child objects are changed (e.g participants) and solr document is not updated
        in.setModifier(AuthenticationUtils.getUsername());
        in.setModified(new Date());
        try
        {
            CaseFile saved = null;

            if (in != null && in instanceof FOIARequest)
            {
                FOIARequest foiaRequest = (FOIARequest) in;

                if (in.getTitle() == null || in.getTitle().length() == 0)
                {
                    if (foiaRequest.getRequestType().equals(FOIAConstants.NEW_REQUEST_TYPE))
                    {
                        in.setTitle(FOIAConstants.NEW_REQUEST_TITLE);
                    }
                    else
                    {
                        in.setTitle("Appeal of " + foiaRequest.getOriginalRequestNumber());
                    }
                }

                if (foiaRequest.getReceivedDate() == null)
                {
                    foiaRequest.setReceivedDate(LocalDateTime.now());
                }

                // On new Appeal, set DueDate and PerfectedDate.
                // No need to do this on existing one, because received date and perfected date can be set only once and
                // Appeals are not following misdirect functionality.
                if (foiaRequest.getId() == null && foiaRequest.getRequestType().equals(FOIAConstants.APPEAL_REQUEST_TYPE))
                {
                    foiaRequest.setPerfectedDate(getQueuesTimeToCompleteService().getHolidayConfigurationService()
                            .getFirstWorkingDateWithBusinessHoursCalculation(foiaRequest.getReceivedDate()));
                    foiaRequest.setDueDate(getQueuesTimeToCompleteService().addWorkingDaysToDate(
                            Date.from(foiaRequest.getPerfectedDate().atZone(ZoneId.systemDefault()).toInstant()),
                            foiaRequest.getRequestType()));
                }

                if (foiaRequest.getPaidFlag() == null || foiaRequest.getLitigationFlag() == null)
                {
                    if (foiaRequest.getRequestType().equals(FOIAConstants.APPEAL_REQUEST_TYPE))
                    {
                        foiaRequest.setPaidFlag(foiaConfig.getFeeWaivedAppealsEnabled());
                        foiaRequest.setLitigationFlag(foiaConfig.getLitigationAppealsEnabled());
                    }
                    else
                    {
                        foiaRequest.setPaidFlag(foiaConfig.getFeeWaivedRequestsEnabled());
                        foiaRequest.setLitigationFlag(foiaConfig.getLitigationRequestsEnabled());
                    }
                }

                if (in.getId() == null && foiaRequest.getRequestType().equals(FOIAConstants.APPEAL_REQUEST_TYPE)
                        && foiaRequest.getOriginalRequestNumber() != null
                        && !foiaRequest.getOriginalRequestNumber().isEmpty())
                {
                    FOIARequest originalRequest = (FOIARequest) getCaseFileDao()
                            .findByCaseNumber(foiaRequest.getOriginalRequestNumber());
                    if (originalRequest != null && !originalRequest.getRequestType().equals(FOIAConstants.APPEAL_REQUEST_TYPE)
                            && originalRequest.getQueue().getName().toUpperCase().equals("RELEASE"))
                    {
                        in = populateAppealFromOriginalRequest(in, originalRequest);
                        in = createReference(in, originalRequest);
                        saved = getSaveCaseService().saveCase(in, filesMap, auth, ipAddress);
                        copyOriginalRequestFiles(saved, originalRequest);
                        createLoopReference(saved, originalRequest);
                    }
                }
                else
                {
                    setDefaultPhoneAndEmailIfAny(in);
                    setDefaultAddressType(in);
                    saved = getSaveCaseService().saveCase(in, filesMap, auth, ipAddress);
                }
            }
            return saved;
        }
        catch (PipelineProcessException | AcmUserActionFailedException | AcmObjectNotFoundException
                | AcmUpdateObjectFailedException | IOException | AcmFolderException e)
        {
            throw new AcmCreateObjectFailedException("FOIARequest", e.getMessage(), e);
        }
    }

    public Map<String, Long> getNextAvailableRequestsInQueue(Long queueId, String requestCreatedDate) throws ParseException
    {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
        Date createdDate = sdf.parse(requestCreatedDate);
        List<FOIARequest> nextRequests = getFoiaRequestDao().getNextAvailableRequestInQueue(queueId, createdDate);
        Map<String, Long> nextRequestAndRequestNumInfo = new HashMap<>();
        if (nextRequests == null || nextRequests.size() == 0)
        {
            nextRequestAndRequestNumInfo.put("availableRequests", 0L);
            return nextRequestAndRequestNumInfo;
        }
        Long fileId = getEcmFileService()
                .findOldestFileByContainerAndFileType(nextRequests.get(0).getContainer().getId(),
                        nextRequests.get(0).getRequestType().equals(FOIAConstants.NEW_REQUEST_TYPE) ? "Request Form" : "Appeal Form")
                .getId();
        nextRequestAndRequestNumInfo.put("requestId", nextRequests.get(0).getId());
        nextRequestAndRequestNumInfo.put("requestFormId", fileId);
        nextRequestAndRequestNumInfo.put("availableRequests", (long) nextRequests.size());
        return nextRequestAndRequestNumInfo;
    }

    private void setDefaultPhoneAndEmailIfAny(CaseFile saved)
    {
        Person person = saved.getOriginator().getPerson();
        for (int i = 0; i < person.getContactMethods().size(); i++)
        {
            ContactMethod contact = person.getContactMethods().get(i);
            if (contact != null)
            {
                if (contact.getType() == null)
                {
                    if (i == 0)
                    {
                        contact.setType("phone");
                    }
                    else if (i == 1)
                    {
                        contact.setType("fax");
                    }
                    else
                    {
                        contact.setType("email");
                    }
                }
                String type = contact.getType();
                String value = contact.getValue();
                if (type.toLowerCase().equals("phone") && value != null && !value.isEmpty())
                {
                    person.setDefaultPhone(contact);
                }
                else if (type.toLowerCase().equals("email") && value != null)
                {
                    person.setDefaultEmail(contact);
                }
            }
        }
    }

    private void setDefaultAddressType(CaseFile saved)
    {
        Person person = saved.getOriginator().getPerson();
        if (person.getAddresses().size() != 0)
        {
            PostalAddress address = person.getAddresses().get(0);
            if (address.getType() == null)
            {
                address.setType("Business");
            }
        }
    }

    private CaseFile populateAppealFromOriginalRequest(CaseFile in, CaseFile originalRequest)
    {

        in.getOriginator().setPerson(originalRequest.getOriginator().getPerson());

        if (in.getTitle() == null || in.getTitle().isEmpty() || in.getTitle().equals(originalRequest.getTitle()))
        {
            in.setTitle(originalRequest.getTitle() + String.format(getAppealTitleFormat(), originalRequest.getCaseNumber()));
        }

        return in;

    }

    public CaseFile createReference(CaseFile in, CaseFile originalRequest)
    {
        ObjectAssociation oa = new ObjectAssociation();
        oa.setTargetId(originalRequest.getId());
        oa.setTargetName(originalRequest.getCaseNumber());
        oa.setTargetType(originalRequest.getObjectType());
        oa.setTargetTitle(originalRequest.getTitle());
        oa.setAssociationType("REFERENCE");
        oa.setStatus("ACTIVE");

        in.addChildObject(oa);

        return in;
    }

    public void createLoopReference(CaseFile saved, CaseFile originalRequest)
    {
        ObjectAssociation oa = new ObjectAssociation();
        oa.setTargetId(saved.getId());
        oa.setTargetName(saved.getCaseNumber());
        oa.setTargetType(saved.getObjectType());
        oa.setTargetTitle(saved.getTitle());
        oa.setAssociationType("REFERENCE");
        oa.setStatus("ACTIVE");
        oa.setParentId(originalRequest.getId());
        oa.setParentName(originalRequest.getCaseNumber());
        oa.setParentType(originalRequest.getObjectType());

        objectAssociationService.saveObjectAssociation(oa);
    }

    private void copyOriginalRequestFiles(CaseFile saved, CaseFile originalRequest)
            throws AcmUserActionFailedException, AcmObjectNotFoundException, AcmFolderException {

        AcmContainer originalRequestContainer = originalRequest.getContainer();
        AcmFolder originalRequestRootFolder = originalRequestContainer.getFolder();

        AcmContainer newRequestContainer = saved.getContainer();
        AcmFolder newRequestRootFolder = newRequestContainer.getFolder();

        String originalRequestFolderName = String.format(getOriginalRequestFolderNameFormat(),
                originalRequest.getCaseNumber());

        acmFolderService.copyFolderAsLink(originalRequestRootFolder, newRequestRootFolder,
                newRequestContainer.getContainerObjectId(), newRequestContainer.getContainerObjectType(),
                originalRequestFolderName);
    }

    /**
     * @return the saveCaseService
     */
    public SaveCaseService getSaveCaseService()
    {
        return saveCaseService;
    }

    /**
     * @param saveCaseService
     *            the saveCaseService to set
     */
    public void setSaveCaseService(SaveCaseService saveCaseService)
    {
        this.saveCaseService = saveCaseService;
    }

    /**
     * @return the responseFolderCompressorService
     */
    public ResponseFolderCompressorService getResponseFolderCompressorService()
    {
        return responseFolderCompressorService;
    }

    /**
     * @param responseFolderCompressorService
     *            the responseFolderCompressorService to set
     */
    public void setResponseFolderCompressorService(ResponseFolderCompressorService responseFolderCompressorService)
    {
        this.responseFolderCompressorService = responseFolderCompressorService;
    }

    /**
     * @return the foiaRequestFileBrokerClient
     */
    public FOIARequestFileBrokerClient getFoiaRequestFileBrokerClient()
    {
        return foiaRequestFileBrokerClient;
    }

    /**
     * @param foiaRequestFileBrokerClient
     *            the foiaRequestFileBrokerClient to set
     */
    public void setFoiaRequestFileBrokerClient(FOIARequestFileBrokerClient foiaRequestFileBrokerClient)
    {
        this.foiaRequestFileBrokerClient = foiaRequestFileBrokerClient;
    }

    /**
     * @return the foiaRequestDao
     */
    public FOIARequestDao getFoiaRequestDao()
    {
        return foiaRequestDao;
    }

    /**
     * @param foiaRequestDao
     *            the foiaRequestDao to set
     */
    public void setFoiaRequestDao(FOIARequestDao foiaRequestDao)
    {
        this.foiaRequestDao = foiaRequestDao;
    }

    /**
     * @return the caseFileDao
     */
    public CaseFileDao getCaseFileDao()
    {
        return caseFileDao;
    }

    /**
     * @param caseFileDao
     *            the caseFileDao to set
     */
    public void setCaseFileDao(CaseFileDao caseFileDao)
    {
        this.caseFileDao = caseFileDao;
    }

    /**
     * @return the ecmFileDao
     */
    public EcmFileDao getEcmFileDao()
    {
        return ecmFileDao;
    }

    /**
     * @param ecmFileDao
     *            the ecmFileDao to set
     */
    public void setEcmFileDao(EcmFileDao ecmFileDao)
    {
        this.ecmFileDao = ecmFileDao;
    }

    /**
     * @return the ecmFileService
     */
    public EcmFileService getEcmFileService()
    {
        return ecmFileService;
    }

    /**
     * @param ecmFileService
     *            the ecmFileService to set
     */
    public void setEcmFileService(EcmFileService ecmFileService)
    {
        this.ecmFileService = ecmFileService;
    }

    /**
     * @return the originalRequestFolderNameFormat
     */
    public String getOriginalRequestFolderNameFormat()
    {
        return originalRequestFolderNameFormat;
    }

    /**
     * @param originalRequestFolderNameFormat
     *            the originalRequestFolderNameFormat to set
     */
    public void setOriginalRequestFolderNameFormat(String originalRequestFolderNameFormat)
    {
        this.originalRequestFolderNameFormat = originalRequestFolderNameFormat;
    }

    /**
     * @return the notificationSender
     */
    public NotificationSender getNotificationSender()
    {
        return notificationSender;
    }

    /**
     * @param notificationSender
     *            the notificationSender to set
     */
    public void setNotificationSender(NotificationSender notificationSender)
    {
        this.notificationSender = notificationSender;
    }

    /**
     * @return the appealTitleFormat
     */
    public String getAppealTitleFormat()
    {
        return appealTitleFormat;
    }

    /**
     * @param appealTitleFormat
     *            the appealTitleFormat to set
     */
    public void setAppealTitleFormat(String appealTitleFormat)
    {
        this.appealTitleFormat = appealTitleFormat;
    }

    public void setQueuesTimeToCompleteService(QueuesTimeToCompleteService queuesTimeToCompleteService)
    {
        this.queuesTimeToCompleteService = queuesTimeToCompleteService;
    }

    public QueuesTimeToCompleteService getQueuesTimeToCompleteService()
    {
        return queuesTimeToCompleteService;
    }

    public FoiaConfigurationService getFoiaConfigurationService()
    {
        return foiaConfigurationService;
    }

    public void setFoiaConfigurationService(FoiaConfigurationService foiaConfigurationService)
    {
        this.foiaConfigurationService = foiaConfigurationService;
    }

    public FOIARequest getFoiaRequestById(Long requestId)
    {
        return foiaRequestDao.find(requestId);
    }

    public ExecuteSolrQuery getExecuteSolrQuery()
    {
        return executeSolrQuery;
    }

    public void setExecuteSolrQuery(ExecuteSolrQuery executeSolrQuery)
    {
        this.executeSolrQuery = executeSolrQuery;
    }

    public void setFoiaConfig(FoiaConfig foiaConfig)
    {
        this.foiaConfig = foiaConfig;
    }

    public ObjectAssociationService getObjectAssociationService()
    {
        return objectAssociationService;
    }

    public void setObjectAssociationService(ObjectAssociationService objectAssociationService)
    {
        this.objectAssociationService = objectAssociationService;
    }

    public AcmFolderService getAcmFolderService()
    {
        return acmFolderService;
    }

    public void setAcmFolderService(AcmFolderService acmFolderService)
    {
        this.acmFolderService = acmFolderService;
    }
}