productdao.java

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

package com.gensou.dao.sheji.product;

import java.text.DateFormat;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;

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

import com.gensou.hibernate.model.Changpinxinxi;
import com.gensou.hibernate.model.Peijianxinxi;
import com.gensou.hibernate.model.Pejianmiddle;
import com.gensou.hibernate.model.Sucaituzi;
import com.gensou.hibernate.model.Sucaixinxi;
import com.gensou.hibernate.model.Sucaixinxiguanlian;
import com.gensou.hibernate.model.Zuzhuangtuzi;
import com.gensou.hibernate.util.HibernateSessionFactory;
import com.gensou.logic.sheji.peijian.QueryPeijianService;
import com.gensou.logic.sheji.product.AddProductService;
import com.gensou.logic.sheji.product.QueryPpeijianService;
import com.gensou.logic.sheji.product.QueryProductService;
import com.gensou.logic.sheji.product.QueryPsucaigl;
import com.gensou.logic.sheji.product.UpdateProduct;
import com.gensou.logic.sheji.product.UpdateproductService;
import com.gensou.util.Pagination;

public class ProductDao {
  
	public QueryProductService addproduct(AddProductService addproduct){
		List list;
		QueryProductService queryP=null;
		Session session=HibernateSessionFactory.getSession();
		Transaction tx=session.beginTransaction();
		Query query;
		query=session.createQuery("from Changpinxinxi where changpinxinxiId=?");
		query.setString(0, addproduct.getChangpinxinxiId());
		try{
		list=query.list();
		if(list==null||list.isEmpty()){
			query=session.createQuery("from Changpinxinxi where model=?");
			query.setString(0, addproduct.getModel());
			list=query.list();
			if(list==null||list.isEmpty()){
				Zuzhuangtuzi zuzhuang=(Zuzhuangtuzi) session.load(Zuzhuangtuzi.class, addproduct.getZid());
				Sucaituzi sucai=(Sucaituzi) session.load(Sucaituzi.class, addproduct.getSid());
				Changpinxinxi product=new Changpinxinxi();
				product.setBeizhu(addproduct.getBeizhu());
				product.setBuyer(addproduct.getBuyer());
				product.setChangpinxinxiId(addproduct.getChangpinxinxiId());
				product.setModel(addproduct.getModel());
				product.setSucaituzi(sucai);
				product.setZaizhongliang(addproduct.getZaizhongliang());
				product.setZhizuoriqi(addproduct.getZhizuoriqi());
				product.setZuzhuangtuzi(zuzhuang);
				session.save(product);
				session.flush();
				tx.commit();
				session.close();
				ProductDao productdao=new ProductDao();
				queryP=productdao.queryway(addproduct.getChangpinxinxiId());
				return queryP;
			}else{
				session.flush();
				session.close();
				return queryP;
			}
		}else{
			session.flush();
			session.close();
			return queryP;
		}
		}catch(Exception e){
			tx.rollback();
			session.close();
			e.printStackTrace();
			return queryP;
		}
	}
	public QueryProductService queryway(String pid){
		Session session=HibernateSessionFactory.getSession();
		Query query;
		List l;
		QueryProductService queryP=null;
		query=session.createQuery("from Changpinxinxi where changpinxinxiId=?");
		query.setString(0,pid);
		l=query.list();
		if(l.isEmpty()||l==null){
			session.flush();
			session.close();
			return queryP;
		}else{
			queryP=new QueryProductService((Changpinxinxi)l.get(0));
			session.flush();
			session.close();
			return queryP;
			
		}
	}
	public List addPpeijian(Integer proid,Integer pid,Integer number){
		Session session=HibernateSessionFactory.getSession();
		Query query;
		List list=new ArrayList();
		Transaction tx=session.beginTransaction();
		try{
		Changpinxinxi product=(Changpinxinxi)session.load(Changpinxinxi.class, proid);
		Peijianxinxi peijian=(Peijianxinxi)session.load(Peijianxinxi.class, pid);
		Pejianmiddle peijianmiddle=new Pejianmiddle();
		peijianmiddle.setChangpinxinxi(product);
		peijianmiddle.setPeijianxinxi(peijian);
		peijianmiddle.setNumber(number);
		session.save(peijianmiddle);
		session.flush();
		tx.commit();
		session.close();
		ProductDao priduct=new ProductDao();
		list=priduct.queryPpeijian(proid);
		}catch(Exception e){
			tx.rollback();
			session.flush();
			session.close();
			return list;
		}
		return list;
	}
	public List queryPpeijian(Integer proid){
		Session session=HibernateSessionFactory.getSession();
		Query query;
		List l;
		List list=new ArrayList();
		Changpinxinxi product=(Changpinxinxi)session.load(Changpinxinxi.class, proid);
		query=session.createQuery("from Pejianmiddle where changpinxinxi=?");
		l=query.setEntity(0,product).list();
		if(!l.isEmpty()){
			for(int i=0;i<l.size();i++){
				QueryPpeijianService queryPS=new QueryPpeijianService((Pejianmiddle)l.get(i));
				list.add(queryPS);
			}
			session.flush();
			session.close();
			return list;
		}else{
			session.flush();
			session.close();
		   return list;
		}
	}
	public QueryProductService queryProductid(Integer id){
		QueryProductService product=null;
		Session session=HibernateSessionFactory.getSession();
		Changpinxinxi chanpin=(Changpinxinxi)session.load(Changpinxinxi.class, id);
		product=new QueryProductService(chanpin);
		return product;
	}
	
	public List deleteProductP(Integer proid,Integer promid){
		Session session=HibernateSessionFactory.getSession();
		Transaction tx=session.beginTransaction();
		List list=new ArrayList();
		try{
		Pejianmiddle peijianm=(Pejianmiddle)session.load(Pejianmiddle.class, promid);
		session.delete(peijianm); 
		tx.commit();
		session.flush();
		session.close();
		}catch(Exception e){
			tx.rollback();
			e.printStackTrace();
			session.flush();
			session.close();
		}
		list=queryPpeijian(proid);
		return list;
	}
	public List queryPsucai(Integer proid){
		Session session=HibernateSessionFactory.getSession();
		Query query;
		List l;
		List list=new ArrayList();
		Changpinxinxi product=(Changpinxinxi)session.load(Changpinxinxi.class, proid);
		query=session.createQuery("from Sucaixinxiguanlian where changpinxinxi=?");
		l=query.setEntity(0,product).list();
		if(!l.isEmpty()){
			for(int i=0;i<l.size();i++){
				QueryPsucaigl querygl=new QueryPsucaigl((Sucaixinxiguanlian)l.get(i));
				list.add(querygl);
			}
			session.clear();
			session.close();
			return list;
		}else{
			session.clear();
			session.close();
		   return list;
		}
	}
	
	public List addPsucai(Integer proid,Integer sid,String qufen){
		Session session=HibernateSessionFactory.getSession();
		List list=new ArrayList();
		Transaction tx=session.beginTransaction();
		try{
		Changpinxinxi product=(Changpinxinxi)session.load(Changpinxinxi.class, proid);
		Sucaixinxi sucai=(Sucaixinxi)session.load(Sucaixinxi.class, sid);
		Sucaixinxiguanlian sucaigl=new Sucaixinxiguanlian();
		sucaigl.setChangpinxinxi(product);
		sucaigl.setSucaixinxi(sucai);
		sucaigl.setQufen(qufen);
		session.save(sucaigl);
		session.flush();
		tx.commit();
		session.clear();
		session.close();
		list=queryPsucai(proid);
		}catch(Exception e){
			e.printStackTrace();
			tx.rollback();
			session.clear();
			session.close();
			
			return list;
		}
		return list;
	}
	
	public List deletePsucai(Integer sglid,Integer proid){
		List list;
		Session session=HibernateSessionFactory.getSession();
		Transaction tx=session.beginTransaction();
		session.clear();
		Sucaixinxiguanlian sucaigl=(Sucaixinxiguanlian)session.load(Sucaixinxiguanlian.class, sglid);
		session.delete(sucaigl);
		tx.commit();
		session.flush();
		session.close();
		list=queryPsucai(proid);
		return list;
	}
	
	public List queryproductall(String way,String term, int pages,int maxpages){
		List product_info = new ArrayList();
		Session session=HibernateSessionFactory.getSession();
		Query query;
		String ways;
		String terms;
		List list=new ArrayList();
		try{
			ways=way;
			terms=term;
			if(way==null||way.equals("")||terms==null||terms.equals("")){
				
				query = (Query) session.createQuery("from Changpinxinxi");
				Pagination pagination=new Pagination();
				product_info=pagination.getNowlist(query,pages,maxpages);
				if(!product_info.isEmpty()){
				for(int i=0;i<product_info.size();i++){
					QueryProductService product=new QueryProductService((Changpinxinxi)product_info.get(i));
					list.add(product);
				}
				}
			    
			}else{
				String name="%"+term+"%";
				query = (Query) session.createQuery("from Changpinxinxi where "+ways+" like ?");
				query.setString(0,name);
				Pagination pagination=new Pagination();
				product_info=pagination.getNowlist(query,pages,maxpages);
				if(!product_info.isEmpty()){
				for(int i=0;i<product_info.size();i++){
					QueryProductService product=new QueryProductService((Changpinxinxi)product_info.get(i));
					list.add(product);
				}
				}
			}
		}catch(NullPointerException e){}
		session.flush();
    	session.close();
		return list; 
		 }
		
	public UpdateProduct updateProductid(Integer id){
		UpdateProduct product=null;
		Session session=HibernateSessionFactory.getSession();
		Changpinxinxi chanpin=(Changpinxinxi)session.load(Changpinxinxi.class, id);
		product=new UpdateProduct(chanpin);
		return product;
	}
	
	public boolean updateproduct(UpdateproductService productService){
		boolean bool=false;
		Session session=HibernateSessionFactory.getSession();
		Transaction tx=session.beginTransaction();
		Changpinxinxi product=(Changpinxinxi)session.load(Changpinxinxi.class,productService.getId());
		Zuzhuangtuzi zuzhuang=(Zuzhuangtuzi)session.load(Zuzhuangtuzi.class,productService.getZid());
		Sucaituzi sucai=(Sucaituzi)session.load(Sucaituzi.class,productService.getSid());
		product.setBeizhu(productService.getBeizhu());
		product.setBuyer(productService.getBuyer());
		product.setModel(productService.getModel());
		product.setSucaituzi(sucai);
		product.setZaizhongliang(productService.getZaizhongliang());
		product.setZhizuoriqi(productService.getZhizuoriqi());
		product.setZuzhuangtuzi(zuzhuang);
		try{
		session.update(product);
		tx.commit();
		session.flush();
		session.close();
		bool=true;
		}catch(Exception e){
			tx.rollback();
			session.flush();
			session.close();
		}
		return bool;
	}
}