popedomdao.java

gensou.rar为某渔具厂的一个简单ERP系统。为比较基础的工程

package com.gensou.dao.mange.popedom;

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

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;


import com.gensou.hibernate.model.Qianxianmidden;
import com.gensou.hibernate.model.Quanxianbiao;
import com.gensou.hibernate.model.Quanxianzubiao;
import com.gensou.hibernate.util.HibernateSessionFactory;
import com.gensou.logic.manage.popedom.AddPopedomSerivce;
import com.gensou.logic.manage.popedom.QueryPopedomSerivce;
import com.gensou.logic.manage.popedom.QueryPopedomsSerivce;
import com.gensou.logic.manage.popedom.QuerySerivce;
import com.gensou.util.Pagination;

public class PopedomDao {
/**
 *  用于对权限组的操作
 ***/
	//添加权限组
	public AddPopedomSerivce addPopedom (AddPopedomSerivce aps)throws Exception{
		Query query = null;
		AddPopedomSerivce aps1 = null;
		String num = aps.getNum();
		String name = aps.getName();
		Session session = HibernateSessionFactory.getSession();
		Quanxianzubiao qxz = new Quanxianzubiao();
		Transaction tx = session.beginTransaction();
		query = session.createQuery("from Quanxianzubiao where quanxianzuId=?");
		query.setString(0,num);
		List l = new ArrayList(); 
		l =	query.list();
		if(l == null || l.isEmpty()){
			query = session.createQuery("from Quanxianzubiao where quanxianzuName=?");
			query.setString(0,name);
			List li = new ArrayList();
			li = query.list();
			if(li == null || li.isEmpty()){
				qxz.setQuanxianzuId(aps.getNum());
				qxz.setQuanxianzuName(aps.getName());
				qxz.setBeizhu(aps.getBeizhu());
				session.save(qxz);
				session.flush();
				tx.commit();
				aps1 = queryQuanxianzu(aps.getNum());
				session.close();
				return aps1;
			}else{
				session.flush();
				session.close();
			    return aps1;	
			}
		}else{
			session.flush();
			session.close();
			return aps1;
		}
	}
	//查询权限组
	public AddPopedomSerivce queryQuanxianzu (String num) throws Exception{
		Session session = HibernateSessionFactory.getSession();
		List list = new ArrayList();
		Query query = session.createQuery("from Quanxianzubiao where quanxianzuId = ?");
		query.setString(0,num);
		list = query.list();
		Quanxianzubiao qxz = (Quanxianzubiao) list.get(0);
		AddPopedomSerivce aps = new AddPopedomSerivce();
		aps.setId(qxz.getId());
		aps.setName(qxz.getQuanxianzuName());
		aps.setNum(qxz.getQuanxianzuId());
		aps.setBeizhu(qxz.getBeizhu());
		session.flush();
		session.close();
		return aps;
	}
	//查询权限组
	public List queryPopedom (String name,int pag,int max)throws Exception {
		Query query = null;
		List l = new ArrayList();
		List list = new ArrayList();
		Session session = HibernateSessionFactory.getSession();
		if(name==null || name.equals("")){
			query = session.createQuery("from Quanxianzubiao");
			Pagination pagination=new Pagination();
			l=pagination.getNowlist(query,pag,max);
		}else{
			String way="%"+name+"%";
			query = session.createQuery("from Quanxianzubiao where quanxianzuName like ?");
			query.setString(0,way);
			Pagination pagination=new Pagination();
			l=pagination.getNowlist(query,pag,max);
		}
		try{	
			for(int i=0;i<l.size();i++){
				Quanxianzubiao qxz = (Quanxianzubiao) l.get(i);
				QueryPopedomSerivce qps = new QueryPopedomSerivce();
				qps.setId(qxz.getId());
				qps.setQuanxianzuId(qxz.getQuanxianzuId());
				qps.setQuanxianzuName(qxz.getQuanxianzuName());
				qps.setBeizhu(qxz.getBeizhu());
				list.add(qps);
		        }
		}catch(Exception e){
			e.printStackTrace();
			session.flush();
			session.close();
		}
		session.flush();
		session.close();
		return list;  
	}
	//查询权限
	public List queryPopedoms (int id) throws Exception {
		Query query = null;
		List list = new ArrayList();
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		Quanxianzubiao qxz = (Quanxianzubiao)session.get(Quanxianzubiao.class,new Integer(id));
		query = session.createQuery("from Qianxianmidden where quanxianzubiao=?");
		query.setEntity(0,qxz);
		List l = query.list();
		for(int i=0;i<l.size();i++){
			Qianxianmidden qxm = (Qianxianmidden)l.get(i);
			QueryPopedomsSerivce qps = new QueryPopedomsSerivce();
			qps.setId(qxm.getId());
			qps.setQuanxianNum(qxm.getQuanxianbiao().getQuanxianId());
			qps.setQuanxianName(qxm.getQuanxianbiao().getQuanxianName());
			qps.setBeizhu(qxm.getQuanxianbiao().getBeizhu());
			list.add(qps);
		}
		tx.commit();
		session.flush();
		session.close();
		return list;
	}
//	添加权限时查询权限
	public List query (String name,int pag,int max) throws Exception {
		Query query = null;
		List l = new ArrayList();
        List list = new ArrayList();
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		if(name==null || name.equals("")){
			query = session.createQuery("from Quanxianbiao");
			Pagination pagination=new Pagination();
			l=pagination.getNowlist(query,pag,max);
		}else{
			String way="%"+name+"%";
			query = session.createQuery("from Quanxianbiao where quanxianName like ?");
			query.setString(0,way);
			l=query.list();
		}
		try{
			for(int i=0;i<l.size();i++){
				Pagination pagination=new Pagination();
				l=pagination.getNowlist(query,pag,max);
				Quanxianbiao qx = (Quanxianbiao) l.get(i);
				QuerySerivce qs = new QuerySerivce();
				qs.setId(qx.getId());
				qs.setNum(qx.getQuanxianId());
				qs.setName(qx.getQuanxianName());
				qs.setBeizhu(qx.getBeizhu());
				list.add(qs);
			}
		}catch(Exception e){
			e.printStackTrace();
			session.flush();
			session.close();
		}
		tx.commit();
		session.flush();
		session.close();
		return list;  
	}
	//添加权限
	public List addPopedoms (int qxzId,String num)throws Exception{
		Query query = null;
		Quanxianzubiao qxz = null;
		Quanxianbiao qxb = null;
		List list = new ArrayList();
		Qianxianmidden qxm = new Qianxianmidden();
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		qxz = (Quanxianzubiao)session.get(Quanxianzubiao.class,new Integer(qxzId));
		try{
		    query = session.createQuery("from Quanxianbiao where quanxianId = ?");
		    query.setString(0,num);
		    List li = query.list();
		    qxb = (Quanxianbiao) li.get(0);
	        Query q = session.createQuery("from Qianxianmidden where quanxianbiao=? and quanxianzubiao=?");
	        q.setEntity(0,qxb);
	        q.setEntity(1,qxz);
	        List l = new ArrayList ();
	        l = q.list();
	        if(l == null || l.isEmpty()){
	        	qxm.setQuanxianbiao(qxb);
	    	    qxm.setQuanxianzubiao(qxz);
	    	    session.save(qxm);
	    	    session.flush();
	    	    tx.commit();
	    	    session.flush();
	    		session.close();
	    	    list = queryQuanxian(qxzId);
	    		return list;
	        }else{
	        	list = queryQuanxian(qxzId);
	            session.flush();
	    		session.close();
	            return list;
	        }
		}catch(NullPointerException e){
			tx.commit();
			session.flush();
			session.close();
			return list;
		}
	}
	//通过权限组主键查询权限内容
	public AddPopedomSerivce queryQuanxianzu (int id) throws Exception{
		Session session = HibernateSessionFactory.getSession();
		Quanxianzubiao qxz = (Quanxianzubiao) session.get(Quanxianzubiao.class,new Integer(id));
		AddPopedomSerivce aps = new AddPopedomSerivce();
		aps.setId(qxz.getId());
		aps.setName(qxz.getQuanxianzuName());
		aps.setNum(qxz.getQuanxianzuId());
		aps.setBeizhu(qxz.getBeizhu());
		session.flush();
		session.close();
		return aps;
	}
	//通过权限组主键查询权限
	public List queryQuanxian (int id)throws Exception{
		List list = new ArrayList();
		Query query = null;
		Session session = HibernateSessionFactory.getSession();
		Transaction tx = session.beginTransaction();
		Quanxianzubiao qxb = (Quanxianzubiao)session.get(Quanxianzubiao.class,new Integer(id));
		query = session.createQuery("from Qianxianmidden where quanxianzubiao = ?");
		query.setEntity(0,qxb);
		List li = query.list();
		for(int i=0;i<li.size();i++){
			Qianxianmidden qxm = (Qianxianmidden) li.get(i);
			QueryPopedomsSerivce qps = new QueryPopedomsSerivce();
			qps.setId(qxm.getId());
			qps.setQuanxianId(qxm.getQuanxianbiao().getId());
			qps.setQuanxianNum(qxm.getQuanxianbiao().getQuanxianId());
			qps.setQuanxianName(qxm.getQuanxianbiao().getQuanxianName());
			list.add(qps);
		}
		session.flush();
		session.close();
		return list;
	}
	//删除权限
	public List delete(int id) throws Exception{
		List list = new ArrayList();
		Session session = HibernateSessionFactory.getSession()	;
		Transaction tx = session.beginTransaction();
		Qianxianmidden qxm = (Qianxianmidden)session.get(Qianxianmidden.class,new Integer(id));
		session.delete(qxm);
		tx.commit();
		session.flush();
		session.close();
		int quanxianzuId = qxm.getQuanxianzubiao().getId().intValue();
		list = queryQuanxian(quanxianzuId);
		return list;
	}
}