package org.kuali.ole.batch.bo;

import org.apache.log4j.Logger;
import org.kuali.ole.OLEConstants;
import org.kuali.ole.batch.document.OLEBatchProcessDefinitionDocument;
import org.kuali.ole.batch.form.OLEBatchProcessJobDetailsForm;
import org.kuali.ole.batch.helper.OLEBatchProcessDataHelper;
import org.kuali.rice.coreservice.impl.parameter.ParameterBo;
import org.kuali.rice.krad.document.TransactionalDocumentBase;
import org.kuali.rice.krad.service.KRADServiceLocator;

import java.io.File;
import java.nio.file.FileSystems;
import java.sql.Timestamp;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * Created with IntelliJ IDEA.
 * User: krishnamohanv
 * Date: 7/11/13
 * Time: 6:53 PM
 * To change this template use File | Settings | File Templates.
 */
public class OLEBatchProcessJobDetailsBo extends TransactionalDocumentBase {


    private String sNo;
    private String jobId;
    private String jobIdNum;
    private String jobName;
    private String userName;
    private Timestamp startTime = new Timestamp(new Date().getTime()); //default value
    private String timeSpent="0:0:0";
    private String recordsExported;
    private String perCompleted = "0.0%"; //default value
    private String status;
    private String batchProfileName;
    private String uploadFileName;
    private Timestamp createTime = new Timestamp(new Date().getTime()); //default value
    private Timestamp endTime;
    private String statusDesc;
    private String oleBatchPrcsScheduleId;
    private String batchProcessId;
    private String batchProcessType;
    private String totalNoOfRecords="0";
    private String noOfRecordsProcessed="0";
    private String noOfSuccessRecords="0";
    private String noOfFailureRecords="0";
    private String noOfDeletedRecords="0";
    private boolean failureAttachmentFlag;
    private boolean errorAttachmentFlag;

    private boolean fileCreatedWithOutLinkFlag;
    private boolean fileCreatedWithMoreThanOneLinkFlag;

    private boolean failureCSVAttachmentFlag;
    private String bibErrorPath;
    private String batchDeletePath;

    private String serialCSVErrorPath;
    private String hstrySucceesCount="0";
    private String hstryFailureCount="0";
    private String typeSuccessCount="0";
    private String typeFailureCount="0";
    private boolean documentFlag;
    private boolean historyFlag;
    private boolean typeFlag;
    private boolean inputCSVFormatFlag;
    private Integer orderImportSuccessCount;
    private Integer orderImportFailureCount;
    private Integer createBibCount;
    private Integer updateBibCount;
    private Integer createHoldingsCount;
    private Integer updateHoldingsCount;

    private Integer noOfEinstanceAdded;
    private Integer noOfEinstanceDeleted;
    private Integer noOfEinstanceCreatedWithOutLink;
    private Integer noOfbibsHaveMoreThanOneEinstance;
    private boolean bibsDeletedForExportFlag;

    private OLEBatchProcessScheduleBo oleBatchProcessScheduleBo;
    private List<OLEBatchProcessScheduleBo> oleBatchProcessScheduleBoList;

    private OLEBatchProcessDefinitionDocument oLEBatchProcessDefinitionDocument;
    public OLEBatchProcessJobDetailsForm form;

    private OrderImportHelperBo orderImportHelperBo = new OrderImportHelperBo();

    private static final Logger LOG = Logger.getLogger(OLEBatchProcessJobDetailsBo.class);


    public boolean isFailureAttachmentFlag() {
        File file = new File(getBatchProcessFilePath(this.getBatchProcessType(), this.getJobId()) + this.getJobId() + "_FailureRecord" + "_" + this.getUploadFileName());
        if (file.exists()) {
            return true;
        } else if ((this.getBatchProcessType() != null && !this.getBatchProcessType().equals(OLEConstants.OLEBatchProcess.ORDER_RECORD_IMPORT)) && isFileCreatedWithMoreThanOneLinkFlag()) {
            return true;
        } else if ((this.getBatchProcessType() != null && !this.getBatchProcessType().equals(OLEConstants.OLEBatchProcess.ORDER_RECORD_IMPORT)) && isFileCreatedWithOutLinkFlag()) {
            return true;
        }
        return false;
    }

    public boolean isErrorAttachmentFlag() {
        String uploadFileName = this.getUploadFileName();
        String errorFileName = null;
        String[] fileNames = uploadFileName.split(",");
        errorFileName = fileNames.length == 2 ? fileNames[0]:uploadFileName;
        if(errorFileName.endsWith(".mrc")){
            errorFileName = errorFileName.replace(".mrc",".txt");
        }
        else if(errorFileName.endsWith(".INV")){
            errorFileName = errorFileName.replace(".INV",".txt");
        }
        else if(errorFileName.endsWith(".edi")){
            errorFileName = errorFileName.replace(".edi",".txt");
        }
        File file = new File(getBatchProcessFilePath(this.getBatchProcessType() , this.getJobId())+this.getJobId()+ "_FailureRecord" + "_" + errorFileName);
        if(file.exists())
            return true;
        return false;
    }

    public void setErrorAttachmentFlag(boolean errorAttachmentFlag) {
        this.errorAttachmentFlag= errorAttachmentFlag;
    }

    public boolean isFileCreatedWithOutLinkFlag() {
        File file = new File(getBatchProcessFilePath(this.getBatchProcessType() , this.getJobId())+ this.getJobId() + OLEConstants.OLEBatchProcess.RECORDS_CREATED_WITHOUT_LINK  + this.getUploadFileName());
        if(file.exists())
            return true;
        return false;
    }

    public void setFileCreatedWithOutLinkFlag(boolean fileCreatedWithOutLinkFlag) {
        this.fileCreatedWithOutLinkFlag = fileCreatedWithOutLinkFlag;
    }

    public boolean isFileCreatedWithMoreThanOneLinkFlag() {
        File file = new File(getBatchProcessFilePath(this.getBatchProcessType() , this.getJobId()) +  this.getJobId()  + OLEConstants.OLEBatchProcess.RECORDS_CREATED_WITH_MORE_THAN_ONE_LINK + this.getUploadFileName());
        if(file.exists())
            return true;
        return false;
    }

    public void setFileCreatedWithMoreThanOneLinkFlag(boolean fileCreatedWithMoreThanOneLinkFlag) {
        this.fileCreatedWithMoreThanOneLinkFlag = fileCreatedWithMoreThanOneLinkFlag;
    }

    public boolean isBibsDeletedForExportFlag() {
        File file = new File(getBatchProcessFilePath(this.getBatchProcessType(), this.getJobId()) + this.getJobId() + OLEConstants.OLEBatchProcess.DELETED_BIB_IDS_FILE_NAME);
        if (file.exists()) {
            return true;
        }
        return false;
    }

    public void setBibsDeletedForExportFlag(boolean bibsDeletedForExportFlag) {
        this.bibsDeletedForExportFlag = bibsDeletedForExportFlag;
    }

    public Integer getNoOfEinstanceAdded() {
        return noOfEinstanceAdded;
    }

    public void setNoOfEinstanceAdded(Integer noOfEinstanceAdded) {
        this.noOfEinstanceAdded = noOfEinstanceAdded;
    }

    public Integer getNoOfEinstanceDeleted() {
        return noOfEinstanceDeleted;
    }

    public void setNoOfEinstanceDeleted(Integer noOfEinstanceDeleted) {
        this.noOfEinstanceDeleted = noOfEinstanceDeleted;
    }

    public Integer getNoOfEinstanceCreatedWithOutLink() {
        return noOfEinstanceCreatedWithOutLink;
    }

    public void setNoOfEinstanceCreatedWithOutLink(Integer noOfEinstanceCreatedWithOutLink) {
        this.noOfEinstanceCreatedWithOutLink = noOfEinstanceCreatedWithOutLink;
    }

    public Integer getNoOfbibsHaveMoreThanOneEinstance() {
        return noOfbibsHaveMoreThanOneEinstance;
    }

    public void setNoOfbibsHaveMoreThanOneEinstance(Integer noOfbibsHaveMoreThanOneEinstance) {
        this.noOfbibsHaveMoreThanOneEinstance = noOfbibsHaveMoreThanOneEinstance;
    }

    public void setFailureAttachmentFlag(boolean failureAttachmentFlag) {
        this.failureAttachmentFlag = failureAttachmentFlag;
    }

    public boolean isFailureCSVAttachmentFlag() {
        String[] fileNames=this.getUploadFileName().split(",");
        for (String fileName:fileNames){
            if (fileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_RECORD_NAME))){
                File file = new File(getBatchProcessFilePath(this.getBatchProcessType(), jobId) + this.getJobId() + "_FailureRecord" + "_" + fileName.replace("csv","xml"));
                if(file.exists())
                    return true;
            }
            else if (fileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_HISTORY_NAME))){
                File file = new File(getBatchProcessFilePath(this.getBatchProcessType(),jobId) + this.getJobId() + "_FailureRecord" + "_" + fileName.replace("csv","xml"));
                if(file.exists())
                    return true;
            } else if (fileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_TYPE_NAME))){
                File file = new File(getBatchProcessFilePath(this.getBatchProcessType(),jobId) + this.getJobId() + "_FailureRecord" + "_" + fileName.replace("csv","xml"));
                if(file.exists())
                    return true;
            }
        }
        return false;
    }

    public void setFailureCSVAttachmentFlag(boolean failureCSVAttachmentFlag) {
        this.failureCSVAttachmentFlag = failureCSVAttachmentFlag;
    }

    public void getJobDisplay(){
        LOG.info("get Report.....");
    }


    public String getTotalNoOfRecords() {
        return totalNoOfRecords;
    }

    public void setTotalNoOfRecords(String totalNoOfRecords) {
        this.totalNoOfRecords = totalNoOfRecords;
    }

    public String getNoOfRecordsProcessed() {
        return noOfRecordsProcessed;
    }

    public void setNoOfRecordsProcessed(String noOfRecordsProcessed) {
        this.noOfRecordsProcessed = noOfRecordsProcessed;
    }

    public OLEBatchProcessJobDetailsForm getForm() {
        return form;
    }

    public void setForm(OLEBatchProcessJobDetailsForm form) {
        this.form = form;
    }

    public String getsNo() {
        return sNo;
    }

    public void setsNo(String sNo) {
        this.sNo = sNo;
    }

    public String getJobId() {
        return jobId;
    }

    public void setJobId(String jobId) {
        this.jobId = jobId;
    }

    public String getJobName() {
        return jobName;
    }

    public void setJobName(String jobName) {
        this.jobName = jobName;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getRecordsExported() {
        return recordsExported;
    }

    public void setRecordsExported(String recordsExported) {
        this.recordsExported = recordsExported;
    }

    public String getPerCompleted() {
        return perCompleted;
    }

    public void setPerCompleted(String perCompleted) {
        this.perCompleted = perCompleted;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }

    public String getBatchProfileName() {
        return batchProfileName;
    }

    public void setBatchProfileName(String batchProfileName) {
        this.batchProfileName = batchProfileName;
    }


    public String getUploadFileName() {
        return uploadFileName;
    }

    public void setUploadFileName(String uploadFileName) {
        this.uploadFileName = uploadFileName;
    }


    public Timestamp getStartTime() {
        return startTime;
    }

    public void setStartTime(Timestamp startTime) {
        this.startTime = startTime;
    }


    public Timestamp getEndTime() {
        return endTime;
    }

    public void setEndTime(Timestamp endTime) {
        this.endTime = endTime;
    }

    public String getStatusDesc() {
        return statusDesc;
    }

    public void setStatusDesc(String statusDesc) {
        this.statusDesc = statusDesc;
    }

    public String getOleBatchPrcsScheduleId() {
        return oleBatchPrcsScheduleId;
    }

    public void setOleBatchPrcsScheduleId(String oleBatchPrcsScheduleId) {
        this.oleBatchPrcsScheduleId = oleBatchPrcsScheduleId;
    }

    public String getBatchProcessId() {
        return batchProcessId;
    }

    public Timestamp getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Timestamp createTime) {
        this.createTime = createTime;
    }

    public void setBatchProcessId(String batchProcessId) {
        this.batchProcessId = batchProcessId;
    }

    public OLEBatchProcessScheduleBo getOleBatchProcessScheduleBo() {
        return oleBatchProcessScheduleBo;
    }

    public void setOleBatchProcessScheduleBo(OLEBatchProcessScheduleBo oleBatchProcessScheduleBo) {
        this.oleBatchProcessScheduleBo = oleBatchProcessScheduleBo;
    }

    public List<OLEBatchProcessScheduleBo> getOleBatchProcessScheduleBoList() {
        return oleBatchProcessScheduleBoList;
    }

    public void setOleBatchProcessScheduleBoList(List<OLEBatchProcessScheduleBo> oleBatchProcessScheduleBoList) {
        this.oleBatchProcessScheduleBoList = oleBatchProcessScheduleBoList;
    }

    public String getBatchProcessType() {
        return batchProcessType;
    }

    public void setBatchProcessType(String batchProcessType) {
        this.batchProcessType = batchProcessType;
    }

    public OLEBatchProcessDefinitionDocument getOLEBatchProcessDefinitionDocument() {
        return oLEBatchProcessDefinitionDocument;
    }

    public void setOLEBatchProcessDefinitionDocument(OLEBatchProcessDefinitionDocument oLEBatchProcessDefinitionDocument) {
        this.oLEBatchProcessDefinitionDocument = oLEBatchProcessDefinitionDocument;
    }

    public String getTimeSpent() {
        return timeSpent;
    }

    public void setTimeSpent(String timeSpent) {
        this.timeSpent = timeSpent;
    }

    public String getNoOfSuccessRecords() {
        return noOfSuccessRecords;
    }

    public void setNoOfSuccessRecords(String noOfSuccessRecords) {
        this.noOfSuccessRecords = noOfSuccessRecords;
    }

    public String getNoOfFailureRecords() {
        return noOfFailureRecords;
    }

    public void setNoOfFailureRecords(String noOfFailureRecords) {
        this.noOfFailureRecords = noOfFailureRecords;
    }

    public String getNoOfDeletedRecords() {
        return noOfDeletedRecords;
    }

    public void setNoOfDeletedRecords(String noOfDeletedRecords) {
        this.noOfDeletedRecords = noOfDeletedRecords;
    }

    private String getBatchProcessFilePath(String batchProceesType) {
        String batchProcessLocation =  OLEBatchProcessDataHelper.getInstance().getBatchProcessFilePath(batchProceesType);
        return batchProcessLocation;
    }
    private String getBatchProcessFilePath(String batchProceesType,String jobId) {
        String batchProcessLocation =  OLEBatchProcessDataHelper.getInstance().getBatchProcessFilePath(batchProceesType,jobId);
        return batchProcessLocation;
    }

    public String getBibErrorPath() {
        return bibErrorPath;
    }

    public void setBibErrorPath(String bibErrorPath) {
        this.bibErrorPath = bibErrorPath;
    }

    public String getBatchDeletePath() {
        return batchDeletePath;
    }

    public void setBatchDeletePath(String batchDeletePath) {
        this.batchDeletePath = batchDeletePath;
    }

    public void setJobIdNum(String jobIdNum) {
        this.jobIdNum = jobIdNum;
    }

    public String getJobIdNum() {
        return String.format("%08d", Integer.parseInt(jobId)) ;
    }

    public String getHstrySucceesCount() {
        return hstrySucceesCount;
    }

    public void setHstrySucceesCount(String hstrySucceesCount) {
        this.hstrySucceesCount = hstrySucceesCount;
    }

    public String getHstryFailureCount() {
        return hstryFailureCount;
    }

    public void setHstryFailureCount(String hstryFailureCount) {
        this.hstryFailureCount = hstryFailureCount;
    }

    public String getTypeSuccessCount() {
        return typeSuccessCount;
    }

    public void setTypeSuccessCount(String typeSuccessCount) {
        this.typeSuccessCount = typeSuccessCount;
    }

    public String getTypeFailureCount() {
        return typeFailureCount;
    }

    public void setTypeFailureCount(String typeFailureCount) {
        this.typeFailureCount = typeFailureCount;
    }

    public boolean isDocumentFlag() {
        if (uploadFileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_RECORD_NAME)+".csv")){
            return true;
        }
        return false;
    }

    public void setDocumentFlag(boolean documentFlag) {
        this.documentFlag = documentFlag;
    }

    public boolean isHistoryFlag() {
        if (uploadFileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_HISTORY_NAME)+".csv")){
            return true;
        }
        return false;
    }

    public void setHistoryFlag(boolean historyFlag) {
        this.historyFlag = historyFlag;
    }

    public boolean isTypeFlag() {
        if (uploadFileName.contains(getParameter(OLEConstants.OLEBatchProcess.SERIAL_TYPE_NAME)+".csv")){
            return true;
        }
        return false;
    }

    public void setTypeFlag(boolean typeFlag) {
        this.typeFlag = typeFlag;
    }
    private String getParameter(String name) {
        String parameter = "";
        try {
            Map<String, String> criteriaMap = new HashMap<String, String>();
            criteriaMap.put("namespaceCode", OLEConstants.SYS_NMSPC);
            criteriaMap.put("componentCode", OLEConstants.BATCH_CMPNT);
            criteriaMap.put("name", name);
            List<ParameterBo> parametersList = (List<ParameterBo>) KRADServiceLocator.getBusinessObjectService().findMatching(ParameterBo.class, criteriaMap);
            for (ParameterBo parameterBo : parametersList) {
                parameter = parameterBo.getValue();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return parameter;
    }

    public String getSerialCSVErrorPath() {
        return serialCSVErrorPath;
    }

    public void setSerialCSVErrorPath(String serialCSVErrorPath) {
        this.serialCSVErrorPath = serialCSVErrorPath;
    }

    public boolean isInputCSVFormatFlag() {
        if (uploadFileName.contains(".csv")) {
            return true;
        }
        return false;
    }

    public void setInputCSVFormatFlag(boolean inputCSVFormatFlag) {
        this.inputCSVFormatFlag = inputCSVFormatFlag;
    }

    public Integer getOrderImportSuccessCount() {
        return orderImportSuccessCount;
    }

    public void setOrderImportSuccessCount(Integer orderImportSuccessCount) {
        this.orderImportSuccessCount = orderImportSuccessCount;
    }

    public Integer getOrderImportFailureCount() {
        return orderImportFailureCount;
    }

    public void setOrderImportFailureCount(Integer orderImportFailureCount) {
        this.orderImportFailureCount = orderImportFailureCount;
    }

    public Integer getCreateBibCount() {
        return createBibCount;
    }

    public void setCreateBibCount(Integer createBibCount) {
        this.createBibCount = createBibCount;
    }

    public Integer getUpdateBibCount() {
        return updateBibCount;
    }

    public void setUpdateBibCount(Integer updateBibCount) {
        this.updateBibCount = updateBibCount;
    }

    public Integer getCreateHoldingsCount() {
        return createHoldingsCount;
    }

    public void setCreateHoldingsCount(Integer createHoldingsCount) {
        this.createHoldingsCount = createHoldingsCount;
    }

    public OrderImportHelperBo getOrderImportHelperBo() {
        return orderImportHelperBo;
    }

    public void setOrderImportHelperBo(OrderImportHelperBo orderImportHelperBo) {
        this.orderImportHelperBo = orderImportHelperBo;
    }

    public Integer getUpdateHoldingsCount() {
        return updateHoldingsCount;
    }

    public void setUpdateHoldingsCount(Integer updateHoldingsCount) {
        this.updateHoldingsCount = updateHoldingsCount;
    }

    public void setJobstatistics(OLEBatchBibImportStatistics bibImportStatistics) {
        setNoOfRecordsProcessed(Integer.parseInt(noOfRecordsProcessed) + bibImportStatistics.getTotalCount() + "");
        setNoOfSuccessRecords(bibImportStatistics.getSuccessRecord() + "");
        setNoOfFailureRecords((bibImportStatistics.getMismatchRecordList().size()) + "");
        setNoOfEinstanceAdded(bibImportStatistics.getNoOfEinstanceAdded());
        setNoOfEinstanceDeleted(bibImportStatistics.getNoOfEinstanceDeleted());
        setNoOfEinstanceCreatedWithOutLink(bibImportStatistics.getNoOfEinstanceCreatedWithOutLink());
        setNoOfbibsHaveMoreThanOneEinstance(bibImportStatistics.getNoOfbibsHaveMoreThanOneEinstance());

    }
    
    
    public void setIntailJob(OLEBatchBibImportStatistics bibImportStatistics){
       setNoOfSuccessRecords("0");
       setNoOfFailureRecords("0");
       setNoOfRecordsProcessed("0");
       setNoOfEinstanceAdded(0);
       setNoOfEinstanceDeleted(0);
       setNoOfEinstanceCreatedWithOutLink(0);
       setNoOfbibsHaveMoreThanOneEinstance(0);
       setTotalNoOfRecords(bibImportStatistics.getBibMarcRecordList().size()+"");
    }

}