dataprepareaction.java

OBPM是一个开源

package cn.myapps.core.report.dataprepare.action;

import com.opensymphony.webwork.ServletActionContext;

import cn.myapps.base.action.BaseAction;
import cn.myapps.core.dynaform.dts.datasource.ejb.DataSource;
import cn.myapps.core.dynaform.dts.datasource.ejb.DataSourceProcess;
import cn.myapps.core.report.dataprepare.ExecuteDataPrepare;
import cn.myapps.core.report.dataprepare.ejb.DataPrepare;
import cn.myapps.core.report.dataprepare.ejb.DataPrepareProcess;
import cn.myapps.util.ProcessFactory;

public class DataPrepareAction extends BaseAction {

	
	public String _dts;

	public DataPrepareAction() throws Exception {
		super(ProcessFactory.createProcess(DataPrepareProcess.class),
				new DataPrepare());
	}

	public String doSave() throws Exception{
		DataPrepare vo=(DataPrepare)getContent();
		if(_dts!=null&&_dts.trim().length()>0){
			DataSourceProcess dp = (DataSourceProcess) (ProcessFactory
					.createProcess(DataSourceProcess.class));
			DataSource dt=(DataSource)dp.doView(this._dts);
		    vo.setDataSource(dt);    
		}
		if(vo.getId()!=null&&vo.getId().trim().length()>0){
			DataPrepare po=(DataPrepare)proxy.doView(vo.getId());
			vo.setSqlSentences(po.getSqlSentences());
		}
		vo.setApplicationid(getApplication());
		super.doSave();
		return SUCCESS;
	}

	public String get_dts() {
		DataPrepare vo=(DataPrepare)getContent();
		return (vo!=null&&vo.getDataSource()!=null)?vo.getDataSource().getId():null;
	}

	public void set_dts(String _dts) {
		this._dts = _dts;
	}
	
	public String  produceData()throws Exception{
		if (_selects != null){
			String message=null;
			DataPrepareProcess dp = (DataPrepareProcess) (ProcessFactory
					.createProcess(DataPrepareProcess.class));
			for (int i = 0; i < _selects.length; i++) {
				 String id=_selects[i];
				 DataPrepare vo=(DataPrepare)dp.doView(id);
				 message=ExecuteDataPrepare.execute(vo);
			}
			ServletActionContext.getRequest().setAttribute("message",message);
		}
		return SUCCESS;
	}
	
	public String  clearData()throws Exception{
		if (_selects != null){
			String message=null;
			DataPrepareProcess dp = (DataPrepareProcess) (ProcessFactory
					.createProcess(DataPrepareProcess.class));
			for (int i = 0; i < _selects.length; i++) {
				 String id=_selects[i];
				 DataPrepare vo=(DataPrepare)dp.doView(id);
				 message=ExecuteDataPrepare.clearTempData(vo);
			}
			ServletActionContext.getRequest().setAttribute("message",message);
		}
		
		return SUCCESS;
	}
	
	
}