da

package org.jleaf.erp.sls.services;
import java.io.InputStream;

import org.jleaf.baseservices.AbstractService;
import org.jleaf.baseservices.AbstractServiceAppContext;
import org.jleaf.core.Dto;
import org.jleaf.core.GeneralConstants;
import org.jleaf.erp.master.MasterConstants;
import org.jleaf.erp.master.MasterProperties;
import org.jleaf.erp.sls.services.AbstractSalesService;
import org.jleaf.workflow.core.ApplicationContextProvider;
import org.jleaf.workflow.core.engine.Workflow;
import org.jleaf.workflow.core.engine.WorkflowExecutor;
import org.jleaf.workflow.core.engine.WorkflowFactory;
import org.jleaf.workflow.core.engine.WorkflowLoader;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.Resource;
import org.xml.sax.InputSource;


public abstract class AbstractSalesServiceForIndocom extends AbstractService {

    private static final Logger log = LoggerFactory.getLogger(AbstractSalesService.class);
    private Workflow workflow;
    private WorkflowExecutor executor;

    public void loadWorkflow(long tenantId) {
        AbstractServiceAppContext context = SalesServiceAppContext.getInstance();

        WorkflowLoader loader = (WorkflowLoader) context.getContext().getBean("workflowLoader");
        executor = (WorkflowExecutor) context.getContext().getBean("workflowExecutor");

        // Load workflow once
        // Locate workflow resource
        Resource res = ApplicationContextProvider.getApplicationContext().getResource("classpath:org/jleaf/erp/workflow-master.xml");
        InputStream is;

        log.info("Load resource finished..." + res);

        try {
            is = res.getInputStream();

            // Load xml to workflow object
            workflow = loader.load(tenantId, is);

            // Set executor to use specified workflow
            executor.setWorkflow(workflow);

            Workflow workflow = WorkflowFactory.getWorkflow();

            log.debug("schemeInputStream : "+ res);

            WorkflowFactory.loadSchemes(workflow, new InputSource(res.getInputStream()));


        } catch (Exception e) {
            log.error("Could not load workflow. Error message: " + e.getMessage());
            e.printStackTrace();
        }
    }

    @Override
    public final AbstractServiceAppContext getServiceAppContext() {
        AbstractServiceAppContext context = SalesServiceAppContext.getInstance();

        return context;
    }

    /**
     * Get workflow object
     *
     * @return the workflow
     */
    public Workflow getWorkflow() {
        return workflow;
    }

    /**
     * Get workflow executor
     *
     * @return the executor
     */
    public WorkflowExecutor getExecutor() {
        return executor;
    }

    public boolean isTransactionOk(Dto output) {
        if (output.getString("status").equals(GeneralConstants.FAIL)) {
            return false;
        }
        return true;
    }

    @Override
    public String getPassKey() {
        return MasterProperties.getProperties().getProperty(MasterConstants.PROP_PASS_KEY);
    }

}