基于javaweb的在线投票系统

/** * */ package cn.com.dao.impl; import java.sql.SQLException; import java.util.List; /* import org.slf4j.Logger; import org.slf4j.LoggerFactory;*/ import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.Session; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.HibernateTemplate; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import com.opensymphony.xwork2.util.logging.Logger; import com.opensymphony.xwork2.util.logging.LoggerFactory; import cn.com.bean.Page; import cn.com.bean.VoteItem; import cn.com.bean.VoteOption; import cn.com.bean.VoteSubject; import cn.com.bean.VoteUser; import cn.com.dao.VoteDao; /** * @author Administrator * */ public class VoteDaoImpl extends HibernateDaoSupport implements VoteDao { // private Log4JLogger logger = (Log4JLogger) LogFactory // .getLog(VoteDaoImpl.class); private static final Logger logger = LoggerFactory .getLogger(VoteDaoImpl.class); /* * 查询所有的投票 */ public Page allVote(final String hql,String hql1,Page page) { logger.debug("find allVote start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); //获取记录总条数 int totalCount = 0; List list1 = temp.find(hql1); for (int i = 0; i < list1.size(); i++) { totalCount = Integer.parseInt(list1.get(i).toString()); } int curPage1=page.getCurPage(); final int pageSize=page.getPageSize(); int pageCount=totalCount/pageSize; int leftCount=totalCount%pageSize; int maxPage=0;//记录最大页数 if(leftCount!=0){ maxPage=pageCount+1; }else{ maxPage=pageCount; } if(curPage1>maxPage){ curPage1=maxPage; }else if(curPage1<1){ curPage1=1; } final int curPage=curPage1; //获取某一页的数据 List list = getHibernateTemplate().executeFind(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Query query = session.createQuery(hql); query.setFirstResult((curPage-1)*pageSize); query.setMaxResults(pageSize); List list = query.list(); return list; } }); page.setCurPage(curPage);//封装当前页的页码 page.setMaxPage(maxPage);//封装最大页的页码 page.setList(list);//封装查到的本页数据 return page; } /* * 发布新投票 */ public int addVote(VoteSubject vs, List<VoteOption> voList) { logger.info("add new vote start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); int count = (Integer) temp.save(vs); int count1 = 0; for (int i = 0; i < voList.size(); i++) { VoteOption vo = voList.get(i); count1 = (Integer) temp.save(vo); temp.flush(); if (count1 == 0) break; } if (count != 0 && count1 != 0) { logger.info("add new vote success!"); return 1; } else{ logger.info("add new vote fail!"); return -1; } } /* * 获取投票内容 */ public List<VoteOption> findVote(String hql) { logger.info("find vote start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); List<VoteOption> list = temp.find(hql); for (int i = 0; i < list.size(); i++) { VoteOption vo = list.get(i); } logger.info("find vote success !"); return list; } /* * 保存投票 */ public int saveVote(VoteUser user, VoteSubject vs, List<VoteOption> lvo) { logger.info("save vote start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); int count = 0; for (int i = 0; i < lvo.size(); i++) { VoteOption vo = lvo.get(i); VoteItem vi = new VoteItem(); vi.setvUser(user); vi.setvSubject(vs); vi.setvOption(vo); count = (Integer) temp.save(vi); temp.flush(); if (count == 0) break; } if (count != 0) { logger.info("save vote success!"); return 1; } else{ logger.info("save vote fail!"); return -1; } } /* * 获取某标题投票的总数 */ public double totalCount(String hql) { logger.info("find totalCount start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); double totalCount = 0; List list = temp.find(hql); for (int i = 0; i < list.size(); i++) { totalCount = Integer.parseInt(list.get(i).toString()); } logger.info("find totalCount success !"); return totalCount; } /* * 获取某选项投票的总数 */ public int voCount(String hql) { logger.info("find voCount start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); int voCount = 0; List list = temp.find(hql); for (int i = 0; i < list.size(); i++) { voCount = Integer.parseInt(list.get(i).toString()); } logger.info("find voCount success !"); return voCount; } /* * 修改投票 */ public int updateVote(String hql,String hql1, String hql2,VoteSubject vs, List<VoteOption> list) { logger.info("update vote start ... ..."); HibernateTemplate temp = this.getHibernateTemplate(); int count = 0; // 删除对应标题的原有选项，包括vote_subject表，vote_option表和vote_item表中的相应相应信息---vs_id==vsId的记录 try { List<VoteItem> lvi = temp.find(hql2); temp.deleteAll(lvi); List<VoteOption> lvo = temp.find(hql1); temp.deleteAll(lvo); List<VoteSubject> lvs=temp.find(hql); temp.deleteAll(lvs); logger.debug("delete success !"); } catch (RuntimeException re) { logger.error("delete failed", re); throw re; } // 更新vote_subject表的字段（title、type） int count1=(Integer) temp.save(vs); // 向vote_option表中加入新的选项 for (int i = 0; i < list.size(); i++) { VoteOption vo = (VoteOption) list.get(i); count = (Integer) temp.save(vo); } temp.flush(); if(count!=0&&count1!=0){ logger.info("update vote success !"); return 1; }else{ logger.info("update vote fail !"); return -1; } } }