ofbizworkflow.java

来自「Java编译osworkflow工作流系统的安装和源代码」· Java 代码 · 共 90 行

/*
 * Copyright (c) 2002-2003 by OpenSymphony
 * All rights reserved.
 */
/*
 * Created by IntelliJ IDEA.
 * User: plightbo
 * Date: Apr 29, 2002
 * Time: 11:22:48 PM
 */
package com.opensymphony.workflow.ofbiz;

import com.opensymphony.workflow.*;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.ofbiz.core.entity.GenericTransactionException;
import org.ofbiz.core.entity.TransactionUtil;

import java.util.Map;


/**
 * Ofbiz aware workflow implementation
 */
public class OfbizWorkflow extends AbstractWorkflow {
    //~ Static fields/initializers /////////////////////////////////////////////

    private static final Log log = LogFactory.getLog(OfbizWorkflow.class);

    //~ Constructors ///////////////////////////////////////////////////////////

    public OfbizWorkflow(String caller) {
        super.context = new OfbizWorkflowContext(caller);
    }

    //~ Methods ////////////////////////////////////////////////////////////////

    public void changeEntryState(long id, int newState) throws WorkflowException {
        try {
            TransactionUtil.begin();
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }

        super.changeEntryState(id, newState);

        try {
            TransactionUtil.commit();
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }
    }

    public void doAction(long id, int actionId, Map inputs) throws WorkflowException {
        try {
            TransactionUtil.begin();
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }

        super.doAction(id, actionId, inputs);

        try {
            TransactionUtil.commit();
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }
    }

    public long initialize(String workflowName, int initialState, Map inputs) throws WorkflowException {
        try {
            TransactionUtil.begin();
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }

        long id = super.initialize(workflowName, initialState, inputs);

        try {
            TransactionUtil.commit();

            return id;
        } catch (GenericTransactionException e) {
            throw new WorkflowException(e);
        }
    }
}