findlistimpl.java

实现了基本的oa功能：个人日志。。。

package oa.dailywork.data.impl;

import java.util.Iterator;
import java.util.List;
import java.util.Set;

import oa.dailywork.data.dao.FindListDAO;
import oa.dailywork.model.po.AcceptFile;
import oa.dailywork.model.po.AffixMessage;
import oa.dailywork.model.po.Process;
import oa.popedommanager.model.po.Employee;

import org.hibernate.Criteria;
import org.hibernate.Hibernate;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Expression;
import org.hibernate.criterion.Restrictions;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class FindListImpl extends HibernateDaoSupport implements FindListDAO {
	private int allrecord = 0;

	private int all = 0;

	// 查找记录
	public List findByAllDraft(String draftlist, int currentPage, int lineSize,
			Employee e) {
		// TODO Auto-generated method stub
		System.out.println(draftlist);
		System.out.println(currentPage);
		System.out.println(lineSize);
		Session session = getSession();
		Criteria crt = session.createCriteria(AcceptFile.class);
		if (!e.equals(null)) {
			Criteria employee = crt.createCriteria("employee");
			employee.add(Expression.eq("employeeId", e.getEmployeeId()));
		}
		// System.out.println("dsfsdfs"+draftlist);
		if (!draftlist.equals("null")) {
			crt.add(Restrictions.ilike("title", new String("%" + draftlist
					+ "%")));
		}
		allrecord = crt.list().size();
		List list = crt.setFirstResult((currentPage - 1) * lineSize)
				.setMaxResults(lineSize).list();
		for (int i = 0; i < list.size(); i++) {
			AcceptFile file = (AcceptFile) list.get(i);
			Hibernate.initialize(file.getEmployee());
		}
		session.close();
		return list;
	}

	public int findAllList() {
		return allrecord;
	}

	public int findlistnum() {
		return all;
	}

	public List findByAllDraft(String draftlist, int currentPage, int lineSize,
			Employee e, String action, String flag) {
		// TODO Auto-generated method stub
		Session session = this.getSession();
		Criteria process = session.createCriteria(Process.class);
		process.add(Expression.eq("action", action));
		if (flag == null) {
			process.add(Expression.isNull("tranResult"));
		}
		else{
			process.add(Expression.isNotNull("tranResult"));
		}
		
		if (!draftlist.equals("null")) {
			Criteria acceptfile = process.createCriteria("acceptfile");
			acceptfile.add(Restrictions.ilike("title", new String("'%"
					+ draftlist + "%'")));
		}
		if (!e.equals(null)) {
			Criteria employee = process.createCriteria("employee");
			employee.add(Expression.eq("employeeId", e.getEmployeeId()));
			System.out.println("--------------------------------------"+e.getEmployeeId());
		}
		all = process.list().size();
		List list = process.setFirstResult((currentPage - 1) * lineSize)
				.setMaxResults(lineSize).list();
		for (int i = 0; i < list.size(); i++) {
			Process p = (Process) list.get(i);
			Hibernate.initialize(p.getAcceptfile());
			Hibernate.initialize(p.getEmployee());
			
		}
		session.close();
		return list;
	}

	public Process findByFileMsg(Long no,String action) {
		// TODO Auto-generated method stub
		Session session = this.getSession();
		Criteria process = session.createCriteria(Process.class);
		process.add(Expression.eq("processId", no));
		process.add(Expression.eq("action", action));
		List list = process.list();
		Process pro =new Process();
		for (int i = 0; i < list.size(); i++) {
			pro = (Process)list.get(i);
			Hibernate.initialize(pro.getEmployee());
			Hibernate.initialize(pro.getAcceptfile());
			Hibernate.initialize(pro.getAcceptfile().getAffix());
		}
		
		session.close();
		return pro;
	}
	public void updateProcess(Process pro) {
		Session session = this.getSession();
		Transaction tran = session.beginTransaction();
		logger.debug("process"+pro.getTranComment());
		logger.debug("action"+pro.getAction());
		session.saveOrUpdate(pro);
		tran.commit();
		session.close();
	}

	public AcceptFile getAllMsg(Long no) {
		// TODO Auto-generated method stub
		Session session = this.getSession();
		Criteria acceptfile = session.createCriteria(AcceptFile.class);
		acceptfile.add(Expression.eq("acceptId", no));
//		List list = acceptfile.list();
		AcceptFile accept =(AcceptFile) acceptfile.uniqueResult();
		Hibernate.initialize(accept.getProcess());
		Hibernate.initialize(accept.getAffix());
		Set pro = accept.getProcess();
		for (Iterator iter = pro.iterator(); iter.hasNext();) {
			Process p = (Process) iter.next();
			Hibernate.initialize(p.getEmployee());
		}
//		System.out.println("--------------------------------"+accept.getProcess().size());
//		logger.debug(accept.getProcess()+"pro");
		session.close();
		return accept;
	}
}