网上书店--EBookStore

package com.service; import java.util.HashSet; import java.util.List; import java.util.Set; import org.hibernate.Hibernate; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import com.ORM.Book; import com.ORM.BookCar; import com.ORM.Car; import com.ORM.Customer; import com.mySession.HibernateSessionFactory; public class CarServiceImpl implements CarService { public boolean addCar(Customer customer,Book book, int number) throws Exception { boolean addcarok= false; Session session =HibernateSessionFactory.getSession(); Transaction tx = null; try{ tx = session.beginTransaction(); BookCar bookcar = null; //普通Book对会员进行打折 int discount=100; if((customer.getLeval().toString()).equals("黄金会员")) discount=90; if((customer.getLeval().toString()).equals("白金会员")) discount=80; if((customer.getLeval().toString()).equals("钻石会员")) discount=70; String hql="from Car as a where a.customerid=:customer and status=:status"; Query query = session.createQuery(hql); query.setString("status", "未确认"); query.setEntity("customer", customer); query.setMaxResults(1); Car car = (Car) query.uniqueResult(); if(null==car){//购物车为空 car = new Car(); car.setStatus("未确认"); car.setCustomerid(customer); if(book.getStatus().intValue()==1){ car.setTotalprice(Float.valueOf(book.getDiscountprice().floatValue())); } else { car.setTotalprice(Float.valueOf(book.getPrice().floatValue()*discount/100)); } car.getBooks().add(book); session.save(car); } else { //如果选购的是已经购过的商品，那么就增加商品的数量 hql = "select a from BookCar as a where a.bookid=:bookid and a.carid= :carid order by a.id desc"; query = session.createQuery(hql); query.setInteger("bookid", book.getBookid().intValue()); query.setInteger("carid", car.getCarid().intValue()); query.setMaxResults(1); bookcar = (BookCar) query.uniqueResult(); int total = number; if(bookcar!=null){//选购表中已经存在 total = number+bookcar.getNumber().intValue(); bookcar.setNumber(Integer.valueOf(total)); if(book.getStatus().intValue()==1) {//Book 有特价 bookcar.setPrice(book.getDiscountprice().floatValue()); bookcar.setTprice(total*book.getDiscountprice().floatValue()); } else {//非特价书 bookcar.setPrice((book.getPrice().floatValue())*discount/100); bookcar.setTprice((total*book.getPrice().floatValue())*discount/100); } session.update(bookcar); } //选购表中不存在时，把car中的书籍添加到选购表中 else { car.getBooks().add(book); } //对购物车进行修改 if (book.getStatus().intValue()==1){//特价商品 car.setTotalprice(Float.valueOf(car.getTotalprice().floatValue()+number*book.getDiscountprice().floatValue())); }else{//普通商品 car.setTotalprice(Float.valueOf(car.getTotalprice().floatValue()+number*book.getPrice().floatValue()*discount/100)); } session.update(car); } tx.commit(); //如果是尚未选购过的则要修改选购记录的有关字段 if(bookcar==null){ hql = "select a from BookCar as a where a.bookid=:bookid and a.carid= :carid order by a.id desc"; query = session.createQuery(hql); query.setInteger("bookid", book.getBookid().intValue()); query.setInteger("carid", car.getCarid().intValue()); query.setMaxResults(1); bookcar = (BookCar) query.uniqueResult(); if(bookcar!=null){//选购表中已经存在 bookcar.setNumber(Integer.valueOf(number)); if(book.getStatus().intValue()==1) {//Book 有特价 bookcar.setPrice(book.getDiscountprice().floatValue()); bookcar.setTprice(number*book.getDiscountprice().floatValue()); } else {//非特价书 bookcar.setPrice((book.getPrice().floatValue())*discount/100); bookcar.setTprice((number*book.getPrice().floatValue())*discount/100); } session.update(bookcar); } tx.commit(); } addcarok =true; }catch (Exception e) { e.printStackTrace(); } finally{ HibernateSessionFactory.closeSession(); } return addcarok; } public List browsecar(Customer customer) throws Exception { Integer carid =new Integer(0); List result = null; Session session = HibernateSessionFactory.getSession(); Transaction tx = null; try { String hql = "select a from Car as a where a.customerid=:customer and a.status=:status"; tx=session.beginTransaction(); Query query = session.createQuery(hql); query.setEntity("customer", customer); query.setString("status", "未确认"); query.setMaxResults(1); Car car = (Car)query.uniqueResult(); if (car!=null) { carid = car.getCarid(); } tx.commit(); //浏览商品选购中的所有书籍 hql ="from BookCar as a where a.carid=:carid order by a.id desc"; query = session.createQuery(hql); query.setInteger("carid", carid.intValue()); tx= session.beginTransaction(); result = query.list(); tx.commit(); if(Hibernate.isInitialized(result)){ Hibernate.initialize(result); } } catch (Exception e) { if(tx!=null) tx.rollback(); }finally{ HibernateSessionFactory.closeSession(); } return result; } public Car loadCar(Customer customer) throws Exception { Car car = null; Session session = HibernateSessionFactory.getSession(); Transaction tx = null; List list = null; try { String hqlString= "from Car as a where a.customerid=:customer and a.status=:status"; tx = session.beginTransaction(); Query query = session.createQuery(hqlString); query.setEntity("customer", customer); query.setString("status", "未确认"); query.setMaxResults(1); car = (Car)query.uniqueResult(); tx.commit(); if (Hibernate.isInitialized(car)) { Hibernate.initialize(car); } } catch (Exception e) { if (tx!=null) { tx.rollback(); } e.printStackTrace(); } return car; } public boolean delCarBook(int bookcarid) { int carid =0; float tprice=0; boolean delok=false; Session session = HibernateSessionFactory.getSession(); Transaction tx= null; try { tx= session.beginTransaction(); BookCar bookCar = (BookCar)session.get(BookCar.class, bookcarid); if (bookCar!=null) { carid = bookCar.getCarid(); tprice = bookCar.getTprice(); session.delete(bookCar); } tx.commit(); //修改购物车中的总价格 tx = session.beginTransaction(); Car car = (Car)session.get(Car.class, carid); float totalprice = car.getTotalprice().floatValue(); car.setTotalprice(totalprice-tprice); tx.commit(); delok = true; } catch (Exception e) { e.printStackTrace(); } finally{ HibernateSessionFactory.closeSession(); } return delok; } public boolean updateCar(String statusString,int carid){ Session session = HibernateSessionFactory.getSession(); Transaction tx= null; boolean updateok= false; try { tx= session.beginTransaction(); Car car = (Car)session.get(Car.class, carid); car.setStatus(statusString); session.update(car); tx.commit(); updateok = true; } catch (Exception e) { if(tx!=null) tx.rollback(); } finally{ HibernateSessionFactory.closeSession(); } return updateok; } p