expbilldefi.java

OBPM是一个开源

package cn.myapps.core.expimp.exp.ejb;

import java.util.Collection;
import java.util.LinkedHashMap;
import java.util.Map;

import cn.myapps.core.expimp.exp.util.SQLPackage;
import cn.myapps.core.workflow.storage.definition.ejb.BillDefiProcess;
import cn.myapps.core.workflow.storage.definition.ejb.BillDefiVO;
import cn.myapps.util.ProcessFactory;

public class ExpBillDefi extends ExpElement {
	public ExpBillDefi(boolean expAll) {
		super(expAll);
	}

	public final static String NAME = "T_BILLDEFI";

	private boolean flowRetAct = true; // 是否导出billdefi相关的activitys

	public Map exportSQLS(String[] ids, Collection ignoreIds) throws Exception {
		Map rtn = new LinkedHashMap();
		StringBuffer query = new StringBuffer();

		BillDefiProcess process = (BillDefiProcess) ProcessFactory
				.createProcess((BillDefiProcess.class));

		for (int i = 0; i < ids.length; i++) {
			if (ignoreIds.contains(ids[i]))
				continue;

			ignoreIds.add(ids[i]);

			query.append("SELECT * FROM ");
			query.append(NAME + " ");
			query.append("WHERE id ='");

			query.append(ids[i] + "'");

			SQLPackage values = new SQLPackage(NAME, query.toString());
			if (!isExpAll()) {
				values.addRestColumn(FOREINGKEY_COLUMN_MODULE);
			}
			rtn.put(ids[i], values);

			query = new StringBuffer();

			BillDefiVO flow = (BillDefiVO) process.doView(ids[i]);
			// 获取相关联的activity
			if (!isFlowRetAct()) {
				String[] actIds = getIdsFromValueObjectColles(flow
						.getRelatedActivitys());
				Map actSQLs = new ExpActivity(isExpAll()).exportSQLS(actIds,
						ignoreIds);

				rtn.putAll(actSQLs);
			}
		}
		return rtn;
	}

	/**
	 * @hibernate.property column="flowRetAct"
	 */
	public boolean isFlowRetAct() {
		return flowRetAct;
	}

	public void setFlowRetAct(boolean flowRetAct) {
		this.flowRetAct = flowRetAct;
	}

	public String getName() {
		return NAME;
	}

}