diarydao.java

个人Blog java编写的Blog可以直接使用！

				q.setInteger("catalog", cat_id);
			if(!site.isOwner(user)){
				q.setInteger("type", CatalogBean.TYPE_OWNER);
				if(user != null)
					q.setInteger("user", user.getId());
			}
			q.setMaxResults(1);
			return (DiaryOutlineBean)q.uniqueResult();
		}finally{
			hql = null;
		}
	}
	
	/**
	 * 添加日记
	 * @param journal
	 * @param add_bookmark
	 * @throws HibernateException
	 * @throws SQLException 
	 */
	public static void create(DiaryBean journal, boolean add_bookmark){
		try{
			Session ssn = getSession();
			beginTransaction();
			if(journal.getStatus()==DiaryBean.STATUS_NORMAL){
				journal.getCatalog().incArticleCount(1);
				journal.getOwner().getCount().incArticleCount(1);
			}
			ssn.save(journal);	
			if(journal.getCatalog().getType()==CatalogBean.TYPE_GENERAL){
				//只有公开分类中的日记才可以设置标签
				List tags = journal.getKeywords();
				if(tags!=null && tags.size()>0){
					int tag_count = 0;
					for(int i=0;i<tags.size();i++){
						if(tag_count>=MAX_TAG_COUNT)
							break;
						String tag_name = (String)tags.get(i);
						if(tag_name.getBytes().length > MAX_TAG_LENGTH)
							continue;
						TagBean tag = new TagBean();
						tag.setSite(journal.getSite());
						tag.setRefId(journal.getId());
						tag.setRefType(DiaryBean.TYPE_DIARY);
						tag.setName(tag_name);
						ssn.save(tag);
						tag_count ++;
					}
				}
			}
			if(add_bookmark){
				BookmarkBean bmb = new BookmarkBean();
				bmb.setOwner(journal.getOwner());
				bmb.setSite(journal.getSite());
				bmb.setCreateTime(new Date());
				bmb.setParentId(journal.getId());
				bmb.setParentType(_BeanBase.TYPE_DIARY);
				bmb.setTitle(journal.getTitle());
				journal.getOwner().getCount().incBookmarkCount(1);
				ssn.save(bmb);
			}
			commit();
		}catch(HibernateException e){
			rollback();
			throw e;
		}
	}
	
	/**
	 * 修改日记
	 * @param diary
	 */
	public static void update(DiaryBean diary, boolean updateTags){
		try{
			beginTransaction();			
			if(updateTags){				
				TagDAO.deleteTagByRefId(diary.getId(), DiaryBean.TYPE_DIARY);	
				if(diary.getCatalog().getType()==CatalogBean.TYPE_GENERAL){
					List tags = diary.getKeywords();
					if(tags!=null && tags.size()>0){
						int tag_count = 0;
						for(int i=0;i<tags.size();i++){
							if(tag_count>=MAX_TAG_COUNT)
								break;
							String tag_name = (String)tags.get(i);
							if(tag_name.getBytes().length > MAX_TAG_LENGTH)
								continue;
							TagBean tag = new TagBean();
							tag.setSite(diary.getSite());
							tag.setRefId(diary.getId());
							tag.setRefType(DiaryBean.TYPE_DIARY);
							tag.setName((String)tags.get(i));
							diary.getTags().add(tag);
							tag_count ++;
						}
					}
				}
			}
			commit();
		}catch(HibernateException e){
			rollback();
			throw e;
		}
	}
	
	/**
	 * 根据日记的编号获取日记详细信息
	 * @param article_id
	 * @return
	 */
	public static DiaryBean getDiaryByID(int article_id){
		if(article_id < 0)
			return null;
		return (DiaryBean)getBean(DiaryBean.class, article_id);
	}

	/**
	 * 根据日记的编号获取日记概要信息
	 * @param article_id
	 * @return
	 */
	public static DiaryOutlineBean getDiaryOutlineByID(int article_id){
		if(article_id < 0)
			return null;
		return (DiaryOutlineBean)getBean(DiaryOutlineBean.class, article_id);
	}
	
	/**
	 * 获取日记所在的分类
	 * @param log_id
	 * @return
	 */
	public static CatalogBean getCatalogByDiary(int log_id){
		if(log_id < 0)
			return null;
		return (CatalogBean)namedUniqueResult("CATALOG_OF_DIARY", log_id);
	}
	
	/**
	 * 获取所有日记数，不包括隐藏的
	 * @return
	 */
	public static int getPublicDiaryCount(){
		return executeNamedStat("PUBLIC_DIARY_COUNT", DiaryBean.STATUS_NORMAL, CatalogBean.TYPE_OWNER).intValue();
	}
	
	/**
	 * 获取指定网站指定分类的日记数
	 * @param site
	 * @param user
	 * @param catalog_id
	 * @param year
	 * @param month
	 * @param date
	 * @return
	 */
	public static int getDiaryCount(SiteBean site, SessionUserObject user, int catalog_id, int year, int month, int date){
		StringBuffer hql = new StringBuffer("SELECT COUNT(*) FROM DiaryBean AS a WHERE a.status=:status AND a.site.id=:site");
		if(!site.isOwner(user)){
			//排除用户没有权限访问的分类
			hql.append(" AND (a.catalog.type<>:cat_type");
			if(user != null)
				hql.append(" OR (a.catalog.type=:cat_type AND a.catalog.id IN (SELECT p.key.catalog FROM CatalogPermBean AS p WHERE p.key.user=:user))");
			hql.append(')');
		}
		if (catalog_id > 0)
			hql.append(" AND a.catalog.id=:catalog");
		if(year > 0 || month > 0 || date > 0){
			hql.append(" AND a.writeTime >= :beginTime AND a.writeTime < :endTime");
		}
		try {
			Session ssn = getSession();
			Query q = ssn.createQuery(hql.toString());
			q.setInteger("status", DiaryBean.STATUS_NORMAL);
			q.setInteger("site", site.getId());
			if(!site.isOwner(user)){
				q.setInteger("cat_type", CatalogBean.TYPE_OWNER);
				if(user != null){
					q.setInteger("user", user.getId());
				}
			}
			if (catalog_id > 0) {
				q.setInteger("catalog", catalog_id);
			}
			if(year > 0 || month > 0 || date > 0){
				Calendar[] cals = genTimeParams(year,month,date);
				q.setTimestamp("beginTime", cals[0].getTime());
				q.setTimestamp("endTime", cals[1].getTime());
			}
			return ((Number) q.uniqueResult()).intValue();
		} finally {
			hql = null;
		}
	}
	
	/**
	 * 获取时间段的前后两个时间点
	 * @param year
	 * @param month
	 * @param date
	 * @return
	 */
	protected static Calendar[] genTimeParams(int year, int month, int date){
		Calendar[] params = new Calendar[2];
		if(year>0&&month>0&&date>0){//查询某天
			params[0] = DateUtils.getDateBegin(year,month,date);
			params[1] = (Calendar)params[0].clone();
			params[1].add(Calendar.DATE,1);
		}
		else
		if(year>0&&month>0){//查询某月
			params[0] = DateUtils.getDateBegin(year,month,1);			
			params[1] = (Calendar)params[0].clone();
			params[1].add(Calendar.MONTH,1);
		}
		else
		if(year>0){//查询某年
			params[0] = DateUtils.getDateBegin(year,1,1);			
			params[1] = (Calendar)params[0].clone();
			params[1].add(Calendar.YEAR,1);
		}	
		return params;
	}

	/**
	 * 获取指定网站指定分类的日记
	 * @param site
	 * @param user
	 * @param catalog_id
	 * @param year
	 * @param month
	 * @param date
	 * @param fromIdx
	 * @param count
	 * @return
	 */
	public static List listDiary(int year,int month,int date,int fromIdx, int count, boolean withContent){
		StringBuffer hql = new StringBuffer("FROM ");		
		hql.append(withContent?"DiaryBean":"DiaryOutlineBean");
		hql.append(" AS a WHERE a.status=:status");
		//排除访问受限的分类
		hql.append(" AND (a.catalog.type<>:cat_type)");
		if(year > 0 || month > 0 || date > 0){
			hql.append(" AND a.writeTime >= :beginTime AND a.writeTime < :endTime");
		}
		hql.append(" ORDER BY a.id DESC");
		try {
			Session ssn = getSession();
			Query q = ssn.createQuery(hql.toString());
			q.setInteger("status", DiaryBean.STATUS_NORMAL);
			q.setInteger("cat_type", CatalogBean.TYPE_OWNER);
			if(year > 0 || month > 0 || date > 0){
				Calendar[] cals = genTimeParams(year,month,date);
				q.setTimestamp("beginTime", cals[0].getTime());
				q.setTimestamp("endTime", cals[1].getTime());
			}
			if(fromIdx>0)
				q.setFirstResult(fromIdx);
			if(count>0)
				q.setMaxResults(count);
			return q.list();
		} finally {
			hql = null;
		}
	}

	/**
	 * 获取指定网站指定分类的日记
	 * @param site
	 * @param user
	 * @param catalog_id
	 * @param year
	 * @param month
	 * @param date
	 * @param fromIdx
	 * @param count
	 * @return
	 */
	public static List listDiary(SiteBean site, SessionUserObject user, int catalog_id, int year,int month,int date,
			int fromIdx, int count, boolean withContent){
		StringBuffer hql = new StringBuffer("FROM ");		
		hql.append(withContent?"DiaryBean":"DiaryOutlineBean");
		hql.append(" AS a WHERE a.status=:status AND a.site.id=:site");
		//超级管理员也不能看其他人网站的隐藏目录(2006-5-22 by Winter Lau)
		if(user==null || site.getOwner().getId() != user.getId()){
			//排除用户没有权限访问的分类
			hql.append(" AND (a.catalog.type<>:cat_type");
			if(user != null)
				hql.append(" OR (a.catalog.type=:cat_type AND a.catalog.id IN (SELECT p.key.catalog FROM CatalogPermBean AS p WHERE p.key.user=:user))");
			hql.append(')');
		}
		if (catalog_id > 0)
			hql.append(" AND a.catalog.id=:catalog");
		if(year > 0 || month > 0 || date > 0){
			hql.append(" AND a.writeTime >= :beginTime AND a.writeTime < :endTime");
		}
		hql.append(" ORDER BY a.id DESC");
		try {
			Session ssn = getSession();
			Query q = ssn.createQuery(hql.toString());
			q.setInteger("status", DiaryBean.STATUS_NORMAL);
			q.setInteger("site", site.getId());
			if(user==null || site.getOwner().getId() != user.getId()){
				q.setInteger("cat_type", CatalogBean.TYPE_OWNER);
				if(user != null){
					q.setInteger("user", user.getId());
				}
			}
			if (catalog_id > 0) {
				q.setInteger("catalog", catalog_id);
			}
			if(year > 0 || month > 0 || date > 0){
				Calendar[] cals = genTimeParams(year,month,date);
				q.setTimestamp("beginTime", cals[0].getTime());
				q.setTimestamp("endTime", cals[1].getTime());
			}
			if(fromIdx>0)
				q.setFirstResult(fromIdx);
			if(count>0)
				q.setMaxResults(count);
			return q.list();
		} finally {
			hql = null;
		}
	}

	/**
	 * 读取某个时间点以后的所有正常的日记(SearchEnginePlugIn::buildLogIndex)
	 * @param date
	 * @param max_count
	 * @return
	 * @throws Exception
	 */
	public static List listDiaryAfter(Date date, int max_count){
		return executeNamedQuery("LIST_DIARY_AFTER", 0, max_count, new Object[]{date,
				DiaryBean.I_STATUS_NORMAL, new Integer(CatalogBean.TYPE_OWNER)});
	}

	/**
	 * 增加文章的引用数
	 * @param catalog_id
	 * @param incCount
	 * @return
	 * @throws SQLException
	 */
	static int incTrackBackCount(Session ssn, int log_id, int incCount){
		Query q = ssn.getNamedQuery("INC_DIARY_TB_COUNT");
		q.setInteger(0, incCount);
		q.setInteger(1, log_id);
		return q.executeUpdate();
	}

	/* (non-Javadoc)
	 * @see com.liusoft.dlog4j.search.SearchDataProvider#fetchAfter(java.util.Date)
	 */
	public List fetchAfter(Date beginTime) throws Exception {
		return DiaryDAO.listDiaryAfter(beginTime, -1);
	}

	/**
	 * 列出最新日记评论
	 * @param site
	 * @param user
	 * @param fromIdx
	 * @param count
	 * @return
	 */
	public static List listDiaryReplies(SiteBean site, int fromIdx, int count, SessionUserObject user){
		StringBuffer hql = new StringBuffer("FROM DiaryReplyBean AS r WHERE r.status=:status AND r.site.id=:site AND r.diary.status=:diary_status");
		if(!site.isOwner(user)){
			//排除用户没有权限访问的分类
			hql.append(" AND (r.diary.catalog.type<>:cat_type");
			if(user != null)
				hql.append(" OR (r.diary.catalog.type=:cat_type AND r.diary.catalog.id IN (SELECT p.key.catalog FROM CatalogPermBean AS p WHERE p.key.user=:userid))");
			hql.append(')');
			hql.append(" AND (r.ownerOnly = 0 OR r.user.id = :userid)");
		}
		hql.append(" ORDER BY r.id DESC");
		Session ssn = getSession();
		Query q = ssn.createQuery(hql.toString());
		q.setInteger("status", DiaryReplyBean.STATUS_NORMAL);
		q.setInteger("site", site.getId());
		q.setInteger("diary_status", DiaryOutlineBean.STATUS_NORMAL);
		if(!site.isOwner(user)){
			q.setInteger("cat_type", CatalogBean.TYPE_OWNER);
			q.setInteger("userid", (user!=null)?user.getId():-1);
		}
		if(fromIdx>0)
			q.setFirstResult(fromIdx);
		if(count>0)
			q.setMaxResults(count);
		return q.list();
	}

	/**
	 * 分页列出某篇日记的评论
	 * @param log_id
	 * @param fromIdx
	 * @param count
	 * @return
	 */
	public static List listDiaryReplies(int log_id, int fromIdx, int count, boolean reverse){
		String hql_name = reverse?"LIST_REPLIES_OF_DIARY":"LIST_REPLIES_OF_DIARY2";
		return executeNamedQuery(hql_name, fromIdx, count, log_id);
	}

	/**
	 * 读取某个时间点以后的所有正常的评论(SearchEnginePlugIn::buildReplyIndex)
	 * @param date
	 * @return
	 * @throws Exception
	 */
	public static List listDiaryRepliesAfter(Date date){
		return findNamedAll("LIST_DIARY_REPLIES", new Object[]{date, _ReplyBean.I_STATUS_NORMAL, CatalogBean.I_TYPE_OWNER});
	}

	/**
	 * 获取评论总数(j_replies.vm)
	 * @param site
	 * @param user
	 * @return
	 */
	public static int getDiaryReplyCount(SiteBean site, SessionUserObject user){
		StringBuffer hql = new StringBuffer("SELECT COUNT(*) FROM DiaryReplyBean AS r WHERE r.status=? AND r.site.id=?");
		if(!site.isOwner(user)){
			//排除用户没有权限访问的分类
			hql.append(" AND (r.diary.catalog.type<>?");
			if(user != null)
				hql.append(" OR (r.diary.catalog.type=? AND r.diary.catalog.id IN (SELECT p.key.catalog FROM CatalogPermBean AS p WHERE p.key.user=?))");
			hql.append(')');
		}
		Session ssn = getSession();
		Query q = ssn.createQuery(hql.toString());
		q.setInteger(0, DiaryReplyBean.STATUS_NORMAL);
		q.setInteger(1, site.getId());
		if(!site.isOwner(user)){
			q.setInteger(2, CatalogBean.TYPE_OWNER);
			if(user != null){
				q.setInteger(3, CatalogBean.TYPE_OWNER);
				q.setInteger(4, user.getId());
			}
		}
		return ((Number)q.uniqueResult()).intValue();
	}

	/**
	 * 返回指定站点的日记评论总数
	 * @param site
	 * @return
	 */
	public static int getDiaryReplyCount(int site){
		String hql = "SELECT COUNT(*) FROM DiaryReplyBean AS d WHERE d.status=?";
		if(site>0){
			hql += " AND d.site.id=?";
			return executeStatAsInt(hql, DiaryReplyBean.STATUS_NORMAL, site);
		}
		return executeStatAsInt(hql, DiaryReplyBean.STATUS_NORMAL);
	}

	/**
	 * 删除日记评论,自动减少对应日记的评论数
	 * @param reply
	 */
	public static void deleteDiaryReply(DiaryReplyBean reply){
		Session ssn = getSession();
		try{
			beginTransaction();
			if(reply.getDiary()!=null)
				reply.getDiary().incReplyCount(-1);
			if(reply.getUser()!=null)
				reply.getUser().getCount().incArticleReply(-1);
			ssn.delete(reply);
			commit();
		}catch(HibernateException e){
			rollback();
		}
	}

	/**
	 * 创建日记评论,自动更新对应日记的评论数
	 * 当评论数超过最大的允许评论数后自动锁贴
	 * @param reply
	 */
	public static void createDiaryReply(DiaryReplyBean reply){
		try{
			Session ssn = getSession();
			int max_reply_count = ConfigDAO.getMaxReplyCount(reply.getSite().getId());
			beginTransaction();	
			reply.getDiary().incReplyCount(1);
			if(reply.getDiary().getReplyCount()>=max_reply_count && max_reply_count > 0)
				reply.getDiary().setLock(1);
			reply.getDiary().setLastReplyTime(new Date());
			if(reply.getUser()!=null)
				reply.getUser().getCount().incArticleReply(1);
			ssn.save(reply);
			commit();
		}catch(HibernateException e){
			rollback();
			throw e;
		}
	}	
}