OleOverlayActionServiceImpl

package org.kuali.ole.service.impl;

import org.apache.log4j.Logger;
import org.kuali.ole.BibliographicRecordHandler;
import org.kuali.ole.OLEConstants;
import org.kuali.ole.docstore.model.xmlpojo.work.instance.oleml.*;
import org.kuali.ole.describe.service.DocstoreHelperService;
import org.kuali.ole.factory.OverlayFileReaderFactory;
import org.kuali.ole.factory.OverlayOutputServiceFactory;
import org.kuali.ole.ingest.pojo.*;
import org.kuali.ole.pojo.OleOrderRecord;
import org.kuali.ole.pojo.bib.BibliographicRecord;
import org.kuali.ole.pojo.edi.LineItemOrder;
import org.kuali.ole.service.OleOverlayActionService;
import org.kuali.ole.service.OverlayFileReaderService;
import org.kuali.ole.service.OverlayHelperService;
import org.kuali.ole.service.OverlayOutputService;
import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
import org.kuali.rice.krad.service.KRADServiceLocator;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * Created with IntelliJ IDEA.
 * User: vivekb
 * Date: 3/2/13
 * Time: 4:52 PM
 * To change this template use File | Settings | File Templates.
 */
public class OleOverlayActionServiceImpl implements OleOverlayActionService {

    private static final Logger LOG = Logger.getLogger(OleOverlayActionServiceImpl.class);
    private DocstoreHelperService docstoreHelperService;
    private OverlayOutputService overlayDocstoreOutputService;
    private OverlayOutputService overlayTransactionOutputService;
    private OverlayOutputServiceFactory overlayOutputServiceFactory;
    private   OverlayFileReaderFactory overlayFileReaderFactory;
    private BibliographicRecordHandler bibliographicRecordHandler;
    private OverlayHelperService overlayHelperService;
    @Override
    public String performOverlayLookupAction(String profileName, HashMap<String, Object> objects, String instanceUUID, OleOrderRecord oleOrderRecord) throws Exception {
        String updatedResponse = null;
        InstanceCollection oldInstanceCollection = getDocstoreHelperService().getInstanceCollection(instanceUUID);
        List<Instance> oldInstanceList = oldInstanceCollection.getInstance();
        Instance instance = oldInstanceList.iterator().next();
        OleHoldings oleHoldings = instance.getOleHoldings();
        Items items = instance.getItems();
        List<Item> itemList = items.getItem();
        HashMap<String,Boolean> persistMap =  new HashMap<String, Boolean>();
        HashMap<String,String> actionMap = new HashMap<String, String>();
        OverlayOutputService overlayOutputService = null;
        overlayDocstoreOutputService = getOverlayDocstoreOutputService();
        overlayTransactionOutputService = getOverlayTransactionOutputService();
        actionMap.put("profileName",profileName);
        List<OleOverlayAction> oleOverlayActions = (List<OleOverlayAction>) KRADServiceLocator.getBusinessObjectService().findMatching(OleOverlayAction.class,actionMap);
        for(OleOverlayAction oleOverlayAction : oleOverlayActions){
            OverlayFileReaderService overlayFileReaderService = null;
            boolean isValid=true;
            for(OleMappingField oleMappingField : oleOverlayAction.getOleMappingFields()){
                overlayFileReaderService = getOverlayFileReaderFactory().getOverlayFileReaderService(oleMappingField.getFileFormat(),objects);
                String incomingFieldValue=null;
                    if(oleMappingField.getIncomingField()!=null){
                        String incomingFieldFromProfile =oleMappingField.getIncomingField();
                        incomingFieldValue = overlayFileReaderService.getInputFieldValue(incomingFieldFromProfile);
                        LOG.info("###incomingFieldValue####"+incomingFieldValue);
                        isValid &= incomingFieldValue.equalsIgnoreCase(oleMappingField.getIncomingFieldValue());
                    }
            }
            if(isValid){
                for(OleOutputFieldMapping oleOutputFieldMapping : oleOverlayAction.getOleOutputFieldMappings()){
                    String targetField = getTargetField(oleOutputFieldMapping);
                    String targetFieldValue = oleOutputFieldMapping.getFieldValue();
                    if(oleOutputFieldMapping.isLookUp() && overlayFileReaderService!=null){
                        StringBuffer finalValueSB = new StringBuffer();
                        List<String> dataFieldSubFieldKeyList = getDataFieldSubFieldKeyList(oleOutputFieldMapping.getFieldValue());
                        for(String dataFieldSubField : dataFieldSubFieldKeyList){
                            finalValueSB.append(overlayFileReaderService.getInputFieldValue(dataFieldSubField));
                        }
                        targetFieldValue = finalValueSB.toString();
                    }
                    performOutputMappingField(persistMap,oleOutputFieldMapping,instance,oleHoldings,itemList,oleOrderRecord,targetField,targetFieldValue)  ;
                }
            }
        }
        overlayOutputService = getOverlayOutputServiceFactory().getOverlayOutputServiceFactory(OLEConstants.OVERLAY_DOCSTORE_OUTPUT_TARGET_OBJECT);
        if(persistMap.get(OLEConstants.OVERLAY_INSTANCE) !=null && persistMap.get(OLEConstants.OVERLAY_INSTANCE)){
            overlayOutputService.persist(oldInstanceCollection);
        }
        if(persistMap.get(OLEConstants.OVERLAY_OLE_HOLDINGS)!=null && persistMap.get(OLEConstants.OVERLAY_OLE_HOLDINGS)){
            overlayOutputService.persist(oleHoldings);
        }
        if(persistMap.get(OLEConstants.OVERLAY_ITEM)!=null && persistMap.get(OLEConstants.OVERLAY_ITEM)){
            overlayOutputService.persist(items);
        }
        return updatedResponse;
    }
    @Override
    public String updateRecordExcludingGPF(HashMap<String, String> uuids, BibliographicRecord oldBibliographicRecord, BibliographicRecord newBibliographicRecord,LineItemOrder lineItemOrder, List<String> gpfFieldList, List<OverlayOption> overlayOptionList, String profileName)throws Exception{
        String bibUUID = uuids.get(OLEConstants.BIBlIOGRAPHICUUID);
        String instanceUUID = uuids.get(OLEConstants.OVERLAY_INSTANCEUUID);
        String updatedResponse = null;
        BibliographicRecord updateBibliographicRecord = null;
        HashMap<String,Object> objects = new HashMap<String, Object>();
        objects.put(OLEConstants.MRC,newBibliographicRecord);
        objects.put(OLEConstants.EDI,lineItemOrder);
        oldBibliographicRecord = getDocstoreHelperService().getBibliographicRecord(bibUUID);
        updateBibliographicRecord = getOverlayHelperService().updateBibliographicRecordExcludingGPF(oldBibliographicRecord, newBibliographicRecord,gpfFieldList,overlayOptionList);
        String updatedRecordContent = getBibliographicRecordHandler().generateXML(updateBibliographicRecord);
        updatedResponse = getDocstoreHelperService().persistToDocstoreForEditor(updatedRecordContent, bibUUID, "marc");
        updatedResponse =performOverlayLookupAction(profileName, objects, instanceUUID, null);
        return updatedResponse;
    }
    @Override
    public String updateRecordIncludingGPF(HashMap<String,String> uuids,BibliographicRecord oldBibliographicRecord,BibliographicRecord newBibliographicRecord,LineItemOrder lineItemOrder,List<String> gpfFieldList,List<OverlayOption> overlayOptionList,String profileName)throws Exception{
        String bibUUID = uuids.get(OLEConstants.BIBlIOGRAPHICUUID);
        String instanceUUID = uuids.get(OLEConstants.OVERLAY_INSTANCEUUID);
        String updatedResponse = null;
        HashMap<String,Object> objects = new HashMap<String, Object>();
        objects.put(OLEConstants.MRC,newBibliographicRecord);
        objects.put(OLEConstants.EDI,lineItemOrder);
        BibliographicRecord updateBibliographicRecord = null;
        oldBibliographicRecord = getDocstoreHelperService().getBibliographicRecord(bibUUID);
        updateBibliographicRecord = getOverlayHelperService().updateBibliographicRecordIncludingGPF(oldBibliographicRecord, newBibliographicRecord, gpfFieldList, overlayOptionList);
        String updatedRecordContent = getBibliographicRecordHandler().generateXML(updateBibliographicRecord);
        updatedResponse = getDocstoreHelperService().persistToDocstoreForEditor(updatedRecordContent, bibUUID, "marc");
        updatedResponse = performOverlayLookupAction(profileName,objects,instanceUUID,null);
        return updatedResponse;
    }

    private List<String> getDataFieldSubFieldKeyList(String dataFieldSubfield){
        String[] dataFieldSubfieldSplitArray = dataFieldSubfield.split("\\$");
        List<String> dataFieldSubfieldKeyList = new ArrayList<String>();
        StringBuffer dataFieldSubfieldKeySB = new StringBuffer();
        String tagName = dataFieldSubfieldSplitArray[0];
        for(int splitCount = 1;splitCount <dataFieldSubfieldSplitArray.length;splitCount++){
            dataFieldSubfieldKeySB.append(tagName).append(OLEConstants.DELIMITER_DOLLAR).append(dataFieldSubfieldSplitArray[splitCount]);
            dataFieldSubfieldKeyList.add(dataFieldSubfieldKeySB.toString());
            dataFieldSubfieldKeySB = new StringBuffer();
        }
        return dataFieldSubfieldKeyList;
    }
    private String getTargetField(OleOutputFieldMapping outputFieldMapping){
        String outputMappingTargeField = outputFieldMapping.getTargetField();
        String[] splittedOutputMappingTargeFieldArray = outputMappingTargeField.split("\\.");
        int splittedOutputMappingTargeFieldArrayLength = splittedOutputMappingTargeFieldArray.length;
        outputFieldMapping.setTargetObject(splittedOutputMappingTargeFieldArrayLength>1?splittedOutputMappingTargeFieldArray[0]:null);
        outputFieldMapping.setDetailedTargetObject(splittedOutputMappingTargeFieldArrayLength>2?splittedOutputMappingTargeFieldArray[splittedOutputMappingTargeFieldArrayLength-2]:null);
        String targetField = splittedOutputMappingTargeFieldArrayLength>0?splittedOutputMappingTargeFieldArray[splittedOutputMappingTargeFieldArrayLength-1]:null;
        return targetField;
    }
    private void performOutputMappingField(HashMap<String,Boolean> persistMap,OleOutputFieldMapping outputFieldMapping,Instance instance ,OleHoldings oleHoldings,List<Item> itemList, OleOrderRecord oleOrderRecord,String targetField,String targetFieldValue){
        if(outputFieldMapping.getTargetObject().equalsIgnoreCase(OLEConstants.OVERLAY_DOCSTORE_OUTPUT_TARGET_OBJECT)){
            if(outputFieldMapping.getDetailedTargetObject().equals(OLEConstants.OVERLAY_INSTANCE)){
                overlayDocstoreOutputService.setOutPutValue(targetField,targetFieldValue,instance);
                persistMap.put(OLEConstants.OVERLAY_INSTANCE,true);
            }else if(outputFieldMapping.getDetailedTargetObject().equals(OLEConstants.OVERLAY_OLE_HOLDINGS)){
                overlayDocstoreOutputService.setOutPutValue(targetField,targetFieldValue,oleHoldings);
                persistMap.put(OLEConstants.OVERLAY_OLE_HOLDINGS,true);
            }else if(outputFieldMapping.getDetailedTargetObject().equals(OLEConstants.OVERLAY_ITEM)){
                for(Item item : itemList){
                    overlayDocstoreOutputService.setOutPutValue(targetField,targetFieldValue,item);
                }
                persistMap.put(OLEConstants.OVERLAY_ITEM,true);
            }
        }else if(outputFieldMapping.getTargetObject().equalsIgnoreCase(OLEConstants.OVERLAY_ORDERRECORD) && oleOrderRecord!=null){
            if(outputFieldMapping.getDetailedTargetObject().equalsIgnoreCase(OLEConstants.OVERLAY_TX_RECORD))     {
                overlayTransactionOutputService.setOutPutValue(targetField,targetFieldValue,oleOrderRecord.getOleTxRecord());
            }
        }
    }

    public DocstoreHelperService getDocstoreHelperService(){
        if (docstoreHelperService == null) {
            docstoreHelperService = GlobalResourceLoader.getService(OLEConstants.DOCSTORE_HELPER_SERVICE);
        }
        return docstoreHelperService;
    }
    public OverlayOutputService getOverlayDocstoreOutputService() {
        if(overlayDocstoreOutputService==null){
           overlayDocstoreOutputService = getOverlayOutputServiceFactory().getOverlayOutputServiceFactory(OLEConstants.OVERLAY_DOCSTORE_OUTPUT_TARGET_OBJECT);
        }
        return overlayDocstoreOutputService;
    }

    public OverlayOutputService getOverlayTransactionOutputService() {
        if(overlayTransactionOutputService == null){
           overlayTransactionOutputService = getOverlayOutputServiceFactory().getOverlayOutputServiceFactory(OLEConstants.OVERLAY_ORDERRECORD);
        }
        return overlayTransactionOutputService;
    }

    public OverlayOutputServiceFactory getOverlayOutputServiceFactory() {
        if(overlayOutputServiceFactory == null){
            overlayOutputServiceFactory =GlobalResourceLoader.getService(OLEConstants.OVERLAY_OUTPUTSERVICE_FACTORY);
        }
        return overlayOutputServiceFactory;
    }

    public OverlayFileReaderFactory getOverlayFileReaderFactory() {
        if(overlayFileReaderFactory == null){
            overlayFileReaderFactory =GlobalResourceLoader.getService(OLEConstants.OVERLAY_FILE_READER_FACTORY);
        }
        return overlayFileReaderFactory;
    }
    private BibliographicRecordHandler getBibliographicRecordHandler(){
        if(bibliographicRecordHandler == null){
            bibliographicRecordHandler = new BibliographicRecordHandler();
        }
        return bibliographicRecordHandler;
    }
    public OverlayHelperService getOverlayHelperService() {
        if(overlayHelperService == null){
            overlayHelperService = GlobalResourceLoader.getService(OLEConstants.OVERLAY_HELPER_SERVICE);
        }
        return overlayHelperService;
    }

}