mappingconfigaction.java

OBPM是一个开源

package cn.myapps.core.dynaform.dts.exp.mappingconfig.action;

import java.util.Collection;
import java.util.Iterator;

import cn.myapps.base.action.BaseAction;
import cn.myapps.core.deploy.application.ejb.ApplicationProcess;
import cn.myapps.core.deploy.application.ejb.ApplicationVO;
import cn.myapps.core.deploy.module.ejb.ModuleProcess;
import cn.myapps.core.deploy.module.ejb.ModuleVO;
import cn.myapps.core.dynaform.dts.datasource.ejb.DataSource;
import cn.myapps.core.dynaform.dts.datasource.ejb.DataSourceProcess;
import cn.myapps.core.dynaform.dts.exp.mappingconfig.ejb.MappingConfig;
import cn.myapps.core.dynaform.dts.exp.mappingconfig.ejb.MappingConfigProcess;
import cn.myapps.util.ProcessFactory;
import cn.myapps.core.dynaform.dts.exp.Export;
import cn.myapps.core.style.repository.ejb.StyleRepositoryVO;

public class MappingConfigAction extends BaseAction {

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	public MappingConfigAction() throws ClassNotFoundException {
		super(ProcessFactory.createProcess(MappingConfigProcess.class),
				new MappingConfig());
	}

	private String _ds;

	private String _moduleid;

	private String exportDocsNum = null;

	static int docsnum = -1;

	public String get_ds() {
		MappingConfig mc = (MappingConfig) getContent();
		if (mc.getDatasource() != null)
			return mc.getDatasource().getId();
		else
			return null;
	}

	public void set_ds(String _ds) {
		this._ds = _ds;
	}

	public String doSave() throws Exception {
		MappingConfig mc = (MappingConfig) getContent();

		if (_ds == null || _ds.trim().length() < 1) {
			this.addFieldError("1", "please choose datesource");
			return SUCCESS;
		}
		DataSourceProcess dp = (DataSourceProcess) ProcessFactory
				.createProcess((DataSourceProcess.class));
		DataSource ds = (DataSource) dp.doView(_ds);
		if (ds != null) {
			mc.setDatasource(ds);
		} else {
			mc.setDatasource(null);
		}

		boolean flag = true;

		// 查找是否有想同的表名
		Collection repeatName = ((MappingConfigProcess) proxy)
				.getMCByTableName(mc.getTablename(), getApplication());

		// 如果表名相同，又在同一个datasource则不允许新建，反之则可以新建
		for (Iterator iter = repeatName.iterator(); iter.hasNext();) {
			MappingConfig temp = (MappingConfig) iter.next();

			if (temp.getId() != null
					&& temp.getDatasource() != null
					&& temp.getDatasource().getId().equals(
							mc.getDatasource().getId())
					&& !temp.getId().equals(mc.getId())) {
				this
						.addFieldError("2",
								"The same mappingconfig has exist,please check another");
				flag = false;
			}
		}

	

		if (get_moduleid() != null && !get_moduleid().equals("")) {
			ModuleProcess mp = (ModuleProcess) ProcessFactory
					.createProcess(ModuleProcess.class);
			ModuleVO mv = (ModuleVO) mp.doView(this.get_moduleid());
			mc.setModule(mv);
		}
		if (flag) {
			return super.doSave();
		} else {
			return SUCCESS;
		}
	}

	public String exportAllDocument() throws Exception {
		if (_selects != null && _selects.length > 0) {
			for (int i = 0; i < _selects.length; i++) {
				String id = _selects[i];
				MappingConfig mc = (MappingConfig) this.proxy.doView(id);
				String result = Export.exprotDocument(mc, false, getApplication()); // false
																					// 时导出全部Document,true
																					// 按时间增量导出
				if (result != null && !result.equals(Export._ERROR_TYPE_02)
						&& !result.equals(Export._ERROR_TYPE_03)
						&& !result.equals(Export._ERROR_TYPE_04)) {
					docsnum += Integer.parseInt(result);
				} else
					this.addActionError(result);
			}
			if (docsnum > -1)
				docsnum += 1;
		}
		return SUCCESS;
	}

	public String IncrementExportDocument() throws Exception {
		if (_selects != null && _selects.length > 0) {
			for (int i = 0; i < _selects.length; i++) {
				String id = _selects[i];
				MappingConfig mc = (MappingConfig) this.proxy.doView(id);
				String result = Export.exprotDocument(mc, true, getApplication());
				if (result != null && !result.equals(Export._ERROR_TYPE_02)
						&& !result.equals(Export._ERROR_TYPE_03)
						&& !result.equals(Export._ERROR_TYPE_04)) {
					docsnum += Integer.parseInt(result);
				}
				this.addActionError(result);
			}
			if (docsnum > -1)
				docsnum += 1;
		}
		return SUCCESS;
	}

	public String getExportDocsNum() {
		if (docsnum > -1) {
			this.exportDocsNum = String.valueOf(docsnum);
			docsnum = -1;
		}
		return this.exportDocsNum;

	}

	public void setExportDocsNum(String exportDocsNum) {
		this.exportDocsNum = exportDocsNum;
	}

	public String get_moduleid() {
		MappingConfig mc = (MappingConfig) getContent();
		if (mc.getModule() != null) {
			_moduleid = mc.getModule().getId();
		}

		return _moduleid;
	}

	public void set_moduleid(String _moduleid) {
		this._moduleid = _moduleid;
	}

}