package com.armedia.acm.plugins.complaint.service;

/*-
 * #%L
 * ACM Default Plugin: Complaints
 * %%
 * 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.AcmAuthentication;
import com.armedia.acm.core.exceptions.AcmCreateObjectFailedException;
import com.armedia.acm.core.exceptions.AcmListObjectsFailedException;
import com.armedia.acm.core.exceptions.AcmUserActionFailedException;
import com.armedia.acm.plugins.casefile.dao.CaseFileDao;
import com.armedia.acm.plugins.casefile.model.CaseFile;
import com.armedia.acm.plugins.casefile.model.Disposition;
import com.armedia.acm.plugins.casefile.model.SaveCaseServiceCaller;
import com.armedia.acm.plugins.casefile.service.SaveCaseService;
import com.armedia.acm.plugins.casefile.utility.CaseFileEventUtility;
import com.armedia.acm.plugins.complaint.dao.CloseComplaintRequestDao;
import com.armedia.acm.plugins.complaint.dao.ComplaintDao;
import com.armedia.acm.plugins.complaint.model.CloseComplaintRequest;
import com.armedia.acm.plugins.complaint.model.Complaint;
import com.armedia.acm.plugins.ecm.dao.EcmFileDao;
import com.armedia.acm.plugins.ecm.model.AcmCmisObject;
import com.armedia.acm.plugins.ecm.model.AcmCmisObjectList;
import com.armedia.acm.plugins.ecm.model.AcmContainer;
import com.armedia.acm.plugins.ecm.model.EcmFile;
import com.armedia.acm.plugins.ecm.model.EcmFileConstants;
import com.armedia.acm.plugins.ecm.service.EcmFileService;
import com.armedia.acm.plugins.objectassociation.model.ObjectAssociation;
import com.armedia.acm.plugins.person.model.OrganizationAssociation;
import com.armedia.acm.plugins.person.model.PersonAssociation;
import com.armedia.acm.services.participants.model.AcmParticipant;
import com.armedia.acm.services.participants.model.ParticipantTypes;
import com.armedia.acm.services.pipeline.exception.PipelineProcessException;

import org.apache.commons.lang3.StringEscapeUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager;
import org.springframework.security.core.Authentication;
import org.springframework.transaction.annotation.Transactional;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * Created by armdev on 11/13/14.
 */
public class CloseComplaintRequestService
{
    private final Logger log = LogManager.getLogger(getClass());
    private ComplaintDao complaintDao;
    private CloseComplaintRequestDao closeComplaintRequestDao;
    private ComplaintEventPublisher complaintEventPublisher;
    private SaveCaseService saveCaseService;
    private CaseFileDao caseFileDao;
    private EcmFileDao ecmFileDao;
    private EcmFileService ecmFileService;
    private String complaintFolderNameFormat;
    private String caseFileDetailsFormat;
    private String complaintDetailsFormat;
    private CaseFileEventUtility caseFileEventUtility;
    @PersistenceContext
    private EntityManager entityManager;

    @Transactional
    public void handleCloseComplaintRequestApproved(Long complaintId, Long closeComplaintRequestId, String user, Date approvalDate,
            String ipAddress) throws PipelineProcessException
    {
        CloseComplaintRequest updatedRequest = updateCloseComplaintRequestStatus(closeComplaintRequestId);

        Complaint updatedComplaint = updateComplaintStatus(complaintId, updatedRequest.getDisposition());

        boolean shouldFullInvestigationBeOpened = shallWeOpenAFullInvestigation(updatedRequest);
        log.debug("Open a new investigation? {}", shouldFullInvestigationBeOpened);

        if (shouldFullInvestigationBeOpened)
        {
            CaseFile fullInvestigation = openFullInvestigation(updatedComplaint, user, null, updatedComplaint.getObjectType(), ipAddress);
            log.debug("Opened a full investigation: {}", fullInvestigation.getCaseNumber());

            // Add CaseFile as Reference to the Complaint
            addReferenceToComplaint(updatedComplaint, fullInvestigation, fullInvestigation.getObjectType());
        }

        boolean shouldComplaintBeAddedToExistingCase = shallWeAddComplaintToExistingCase(updatedRequest);
        log.debug("Add to existing case file? [{}]", shouldComplaintBeAddedToExistingCase);

        if (shouldComplaintBeAddedToExistingCase)
        {
            CaseFile updatedCaseFile = addToExistingCaseFile(updatedRequest, updatedComplaint, user, ipAddress);
            if (updatedCaseFile != null)
            {
                log.debug("Added complaint to existing case file: {}", updatedCaseFile.getCaseNumber());

                // Add CaseFile as Reference to the Complaint
                addReferenceToComplaint(updatedComplaint, updatedCaseFile, updatedCaseFile.getObjectType());
            }
        }

        updatedComplaint = getComplaintDao().save(updatedComplaint);

        // get the entity manager to flush any outstanding SQL, so if there are any SQL exceptions, they get
        // raised here; the resulting exception will ensure we don't raise the complaint closed event.
        entityManager.flush();

        // only raise the completed event if we get here, e.g. everything has happened and no exception has been
        // raised.
        getComplaintEventPublisher().publishComplaintClosedEvent(updatedComplaint, user, true, approvalDate);

        getComplaintEventPublisher().publishComplaintUpdated(updatedComplaint, user);
    }

    private CaseFile addToExistingCaseFile(CloseComplaintRequest updatedRequest, Complaint updatedComplaint, String userId,
            String ipAddress) throws PipelineProcessException
    {
        String caseNumber = updatedRequest.getDisposition().getExistingCaseNumber();

        if (caseNumber == null)
        {
            log.error("Can not add complaint to existing case file since there is no case number!");
            return null;
        }

        CaseFile existingCaseFile = getCaseFileDao().findByCaseNumber(caseNumber);
        if (existingCaseFile == null)
        {
            log.error("Can not add complaint to existing case file since there is no case file with number '{}'!", caseNumber);
            return null;
        }

        // since we are adding the complaint to an existing case, which already has its own details, we do
        // not update the case file's details. User can read the complaint details via the link to the
        // complaint from the references table.

        ObjectAssociation originalComplaint = makeObjectAssociation(updatedComplaint.getComplaintId(),
                updatedComplaint.getComplaintNumber(), "COMPLAINT", updatedComplaint.getComplaintTitle());
        originalComplaint.setStatus("CLOSED");
        existingCaseFile.addChildObject(originalComplaint);

        addPersonsToCaseFile(updatedComplaint.getPersonAssociations(), existingCaseFile);
        addOrganizationsToCaseFile(updatedComplaint.getOrganizationAssociations(), existingCaseFile);

        // here we need a full Authentication object
        Authentication auth = new AcmAuthentication(new ArrayList<>(), userId, userId, true, userId);
        existingCaseFile = getSaveCaseService().saveCase(existingCaseFile, auth, null);

        addChildObjectsToCaseFile(updatedComplaint, existingCaseFile, auth);

        getCaseFileEventUtility()
                .raiseCustomEvent(
                        existingCaseFile, "updatedFromComplaint", "Case Updated from Closed Complaint "
                                + updatedComplaint.getComplaintNumber() + " approval by " + getClosedComplaintApprovers(updatedComplaint),
                        new Date(), ipAddress, userId, auth);

        return existingCaseFile;

    }

    private void addChildObjectsToCaseFile(Complaint updatedComplaint, CaseFile existingCaseFile, Authentication auth)
    {
        if (updatedComplaint == null || existingCaseFile == null)
        {
            return;
        }

        try
        {
            AcmContainer container = getEcmFileService().getOrCreateContainer(updatedComplaint.getObjectType(), updatedComplaint.getId());
            AcmCmisObjectList files = getEcmFileService().allFilesForContainer(auth, container);

            AcmContainer containerCaseFile = getEcmFileService().getOrCreateContainer(existingCaseFile.getObjectType(),
                    existingCaseFile.getId());

            String complaintFolderName = String.format(getComplaintFolderNameFormat(),
                    updatedComplaint.getComplaintNumber());

            container.getFolder().setParentFolder(containerCaseFile.getFolder());
            container.getFolder().setName(complaintFolderName);

            if (files != null && files.getChildren() != null)
            {
                for (AcmCmisObject file : files.getChildren())
                {
                    EcmFile ecmFile = getEcmFileService().findById(file.getObjectId());
                    ecmFile.setContainer(containerCaseFile);
                    ecmFile.setStatus(EcmFileConstants.RECORD);

                    getEcmFileDao().save(ecmFile);
                }
            }
        }
        catch (AcmListObjectsFailedException | AcmCreateObjectFailedException | AcmUserActionFailedException e)
        {
            log.error("Cannot save files.", e);
        }
    }

    private void addPersonsToCaseFile(List<PersonAssociation> personAssociations, CaseFile existingCaseFile)
    {
        if (personAssociations == null)
        {
            return;
        }

        for (PersonAssociation pa : personAssociations)
        {
            PersonAssociation paCopy = new PersonAssociation();
            paCopy.setPersonType(pa.getPersonType());
            paCopy.setPerson(pa.getPerson());
            paCopy.setPersonDescription(pa.getPersonDescription());
            paCopy.setNotes(pa.getNotes());
            paCopy.setTags(pa.getTags());
            paCopy.setParentId(existingCaseFile.getId());
            paCopy.setParentType(existingCaseFile.getObjectType());

            existingCaseFile.getPersonAssociations().add(paCopy);
        }
    }

    private void addOrganizationsToCaseFile(List<OrganizationAssociation> organizationAssociations, CaseFile caseFile)
    {
        if (organizationAssociations == null)
        {
            return;
        }

        for (OrganizationAssociation oa : organizationAssociations)
        {
            OrganizationAssociation oaCopy = new OrganizationAssociation();
            oaCopy.setAssociationType(oa.getAssociationType());
            oaCopy.setOrganization(oa.getOrganization());
            oaCopy.setParentId(caseFile.getId());
            oaCopy.setParentType(caseFile.getObjectType());
            oaCopy.setParentTitle(caseFile.getCaseNumber());
            oaCopy.setDescription(oa.getDescription());

            if (caseFile.getOrganizationAssociations() == null)
            {
                caseFile.setOrganizationAssociations(new ArrayList<>());
            }

            caseFile.getOrganizationAssociations().add(oaCopy);
        }
    }

    private boolean shallWeAddComplaintToExistingCase(CloseComplaintRequest updatedRequest)
    {
        if (updatedRequest.getDisposition() == null)
        {
            log.debug("No disposition for request ID '{}'", updatedRequest.getId());
            return false;
        }

        return "add_existing_case".equals(updatedRequest.getDisposition().getDispositionType());
    }

    public CaseFile openFullInvestigation(Complaint updatedComplaint, String userId, CaseFile caseFile, String objectType, String ipAddress)
            throws PipelineProcessException
    {
        if (caseFile == null)
        {
            caseFile = new CaseFile();
        }

        caseFile.setStatus("ACTIVE");
        caseFile.setCaseType(updatedComplaint.getComplaintType());

        String details = formatCaseDetails(updatedComplaint);

        caseFile.setDetails(details);
        caseFile.setPriority(updatedComplaint.getPriority());
        caseFile.setTitle(updatedComplaint.getComplaintTitle());
        caseFile.setIncidentDate(updatedComplaint.getIncidentDate());
        ObjectAssociation originalComplaint = makeObjectAssociation(updatedComplaint.getComplaintId(),
                updatedComplaint.getComplaintNumber(), objectType, updatedComplaint.getComplaintTitle());
        originalComplaint.setStatus("CLOSED");
        log.debug("reference object title: {}", originalComplaint.getTargetTitle());
        caseFile.addChildObject(originalComplaint);

        addPersonsToCaseFile(updatedComplaint.getPersonAssociations(), caseFile);
        addOrganizationsToCaseFile(updatedComplaint.getOrganizationAssociations(), caseFile);

        log.debug("About to save Case File from opened investigation on Complaint: [{}]", updatedComplaint.getComplaintId());

        // here we need a full Authentication object
        Authentication auth = new AcmAuthentication(new ArrayList<>(), userId, userId, true, userId);
        CaseFile fullInvestigation = getSaveCaseService().saveCase(caseFile, auth, null, SaveCaseServiceCaller.CLOSE_COMPLAINT);

        addChildObjectsToCaseFile(updatedComplaint, fullInvestigation, auth);

        getCaseFileEventUtility().raiseCustomEvent(fullInvestigation, "createdFromComplaint", "Case Created from Complaint "
                + updatedComplaint.getComplaintNumber() + " approval by " + getClosedComplaintApprovers(updatedComplaint), new Date(),
                ipAddress, userId, auth);

        return fullInvestigation;
    }

    private String getClosedComplaintApprovers(Complaint closingComplaint)
    {
        List<String> approvers = new ArrayList<>();
        List<AcmParticipant> acmParticipants = getCloseComplaintRequestDao().findByComplaintId(closingComplaint.getComplaintId())
                .getParticipants();
        if (!acmParticipants.isEmpty())
        {
            for (AcmParticipant acmParticipant : acmParticipants)
            {
                if (ParticipantTypes.APPROVER.equals(acmParticipant.getParticipantType()))
                {
                    approvers.add(acmParticipant.getParticipantLdapId());
                }
            }
        }
        String approversString = approvers.stream().collect(Collectors.joining(","));
        return approversString;
    }

    private String formatCaseDetails(Complaint updatedComplaint)
    {
        String complaintDetails = "";
        if (StringUtils.isNotEmpty(updatedComplaint.getDetails()))
        {
            complaintDetails = String.format(getComplaintDetailsFormat(), updatedComplaint.getComplaintNumber(),
                    updatedComplaint.getDetails());
        }

        String details = String.format(getCaseFileDetailsFormat(), updatedComplaint.getComplaintNumber(), complaintDetails);
        details = StringEscapeUtils.unescapeHtml4(details);

        return details;
    }

    private ObjectAssociation makeObjectAssociation(Long id, String number, String type, String title)
    {
        ObjectAssociation oa = new ObjectAssociation();

        oa.setTargetId(id);
        oa.setTargetName(number);
        oa.setTargetType(type);
        oa.setTargetTitle(title);
        oa.setAssociationType("REFERENCE");

        return oa;
    }

    private boolean shallWeOpenAFullInvestigation(CloseComplaintRequest updatedRequest)
    {
        if (updatedRequest.getDisposition() == null)
        {
            log.debug("No disposition for request ID '{}'", updatedRequest.getId());
            return false;
        }

        return "open_investigation".equals(updatedRequest.getDisposition().getDispositionType());
    }

    private CloseComplaintRequest updateCloseComplaintRequestStatus(Long closeComplaintRequestId)
    {
        CloseComplaintRequest ccr = getCloseComplaintRequestDao().find(closeComplaintRequestId);
        ccr.setStatus("APPROVED");
        CloseComplaintRequest updated = getCloseComplaintRequestDao().save(ccr);
        return updated;
    }

    private Complaint updateComplaintStatus(Long complaintId, Disposition disposition)
    {
        Complaint c = getComplaintDao().find(complaintId);
        c.setStatus("CLOSED");
        c.setDisposition(disposition);
        return c;
    }

    public void addReferenceToComplaint(Complaint complaint, CaseFile caseFile, String objectType)
    {
        if (complaint != null && caseFile != null)
        {
            ObjectAssociation caseFileObjectAssociation = makeObjectAssociation(caseFile.getId(), caseFile.getCaseNumber(), objectType,
                    caseFile.getTitle());
            caseFileObjectAssociation.setStatus(caseFile.getStatus());
            complaint.addChildObject(caseFileObjectAssociation);
            getComplaintDao().save(complaint);
        }
    }

    public ComplaintDao getComplaintDao()
    {
        return complaintDao;
    }

    public void setComplaintDao(ComplaintDao complaintDao)
    {
        this.complaintDao = complaintDao;
    }

    public CloseComplaintRequestDao getCloseComplaintRequestDao()
    {
        return closeComplaintRequestDao;
    }

    public void setCloseComplaintRequestDao(CloseComplaintRequestDao closeComplaintRequestDao)
    {
        this.closeComplaintRequestDao = closeComplaintRequestDao;
    }

    public ComplaintEventPublisher getComplaintEventPublisher()
    {
        return complaintEventPublisher;
    }

    public void setComplaintEventPublisher(ComplaintEventPublisher complaintEventPublisher)
    {
        this.complaintEventPublisher = complaintEventPublisher;
    }

    public SaveCaseService getSaveCaseService()
    {
        return saveCaseService;
    }

    public void setSaveCaseService(SaveCaseService saveCaseService)
    {
        this.saveCaseService = saveCaseService;
    }

    public CaseFileDao getCaseFileDao()
    {
        return caseFileDao;
    }

    public void setCaseFileDao(CaseFileDao caseFileDao)
    {
        this.caseFileDao = caseFileDao;
    }

    public EcmFileDao getEcmFileDao()
    {
        return ecmFileDao;
    }

    public void setEcmFileDao(EcmFileDao ecmFileDao)
    {
        this.ecmFileDao = ecmFileDao;
    }

    public EcmFileService getEcmFileService()
    {
        return ecmFileService;
    }

    public void setEcmFileService(EcmFileService ecmFileService)
    {
        this.ecmFileService = ecmFileService;
    }

    public String getComplaintFolderNameFormat()
    {
        return complaintFolderNameFormat;
    }

    public void setComplaintFolderNameFormat(String complaintFolderNameFormat)
    {
        this.complaintFolderNameFormat = complaintFolderNameFormat;
    }

    public String getCaseFileDetailsFormat()
    {
        return caseFileDetailsFormat;
    }

    public void setCaseFileDetailsFormat(String caseFileDetailsFormat)
    {
        this.caseFileDetailsFormat = caseFileDetailsFormat;
    }

    public String getComplaintDetailsFormat()
    {
        return complaintDetailsFormat;
    }

    public void setComplaintDetailsFormat(String complaintDetailsFormat)
    {
        this.complaintDetailsFormat = complaintDetailsFormat;
    }

    public CaseFileEventUtility getCaseFileEventUtility()
    {
        return caseFileEventUtility;
    }

    public void setCaseFileEventUtility(CaseFileEventUtility caseFileEventUtility)
    {
        this.caseFileEventUtility = caseFileEventUtility;
    }

}