schedulerdatasource.java

Eclipse RCP下编写的工作管理软件代码

package net.sf.pim.scheduler;

import java.util.ArrayList;
import java.util.List;

import net.sf.util.persistence.DMFactory;
import net.sf.util.persistence.DataException;
import net.sf.util.persistence.IDataManager;

import org.jcrontab.data.CrontabEntryBean;
import org.jcrontab.data.DataNotFoundException;
import org.jcrontab.data.DataSource;

import sun.reflect.generics.reflectiveObjects.NotImplementedException;

/**
 * 一个IData到jconrtab的Datasource的wrap类
 * @author levin
 */
public class SchedulerDataSource implements DataSource {
	
	private IDataManager idm = null;
	
	
	public SchedulerDataSource() {
		super();
		try {
			idm=DMFactory.getDataManager(Scheduler.class);
		} catch (DataException e) {
			e.printStackTrace();
		}
	}

	public CrontabEntryBean find(CrontabEntryBean ceb) throws Exception {
		throw new NotImplementedException();
	}

	public CrontabEntryBean[] findAll() throws Exception {
		List list=idm.readList();
		//优化一下
		if(list.isEmpty())return new CrontabEntryBean[0];
		ArrayList<CrontabEntryBean> al=new ArrayList<CrontabEntryBean>();
		for(Object o:list){
			Scheduler s=(Scheduler)o;
			if(s.suspend.equals("是") || s.suspend.equals("Y"))
				continue;
			CrontabEntryBean ceb=new CrontabEntryBean(s.minute+" "+s.hour+" "+s.day+" "+s.month+" "+s.week+" "+s.command+" "+s.param);
			al.add(ceb);
		}
		return al.toArray(new CrontabEntryBean[0]);
	}

	public void remove(CrontabEntryBean[] ceb) throws Exception {
		throw new NotImplementedException();
	}

	public void store(CrontabEntryBean ceb) throws Exception,
			DataNotFoundException {
		throw new NotImplementedException();
	}

	public void store(CrontabEntryBean[] ceb) throws Exception,
			DataNotFoundException {
		throw new NotImplementedException();
	}
}