threadrepository.java

非常有影响的 j道 论 坛 源码 国外很有明的专家编写的 ....对java爱好者很有参考价值

package com.jdon.jivejdon.repository;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.apache.log4j.Logger;

import com.jdon.controller.model.PageIterator;
import com.jdon.jivejdon.Constants;
import com.jdon.jivejdon.dao.MessageDaoFacade;
import com.jdon.jivejdon.model.Forum;
import com.jdon.jivejdon.model.ForumMessage;
import com.jdon.jivejdon.model.ForumThread;

public class ThreadRepository {
	private final static Logger logger = Logger
			.getLogger(ThreadRepository.class);

	protected MessageDaoFacade messageDaoFacade;
	

	public ThreadRepository(MessageDaoFacade messageDaoFacade) {
		this.messageDaoFacade = messageDaoFacade;
	}

	/**
	 * create a new Thread, this is for topic message
	 * @param rootForumMessage
	 * @return
	 * @throws Exception
	 */
	public ForumThread createThread(ForumMessage rootForumMessage)
			throws Exception {
		logger.debug(" createThread");
		ForumThread forumThread = new ForumThread(rootForumMessage);
		try {
			Long tIDInt = messageDaoFacade.getSequenceDao().getNextId(
					Constants.THREAD);

			forumThread.setThreadId(tIDInt);
			forumThread.setForum(rootForumMessage.getForum());			
			forumThread.setName(rootForumMessage.getSubject());
			messageDaoFacade.getMessageDao().createThread(forumThread);
		} catch (SQLException e) {
			logger.error(e);
			throw new Exception(e);

		}
		return forumThread;
	}

	public void updateThread(ForumThread thread) throws Exception {
		messageDaoFacade.getMessageDao().updateThread(thread);
		//thread.setModified(true);		
	}
	

	public void deleteThread(ForumThread thread) throws Exception {
		messageDaoFacade.getMessageDao().deleteThread(thread.getThreadId());
		
	}

	
	/* (non-Javadoc)
	 * @see com.jdon.jivejdon.service.ForumMessageService#getThreadsPrevNext(java.lang.String, int)
	 */
	public List getThreadsPrevNext(Long forumId, Long currentThreadId) {
		List resultObject = new ArrayList();
		if (messageDaoFacade.getMessageDao().getThread(currentThreadId) == null) {// if not this currentThreadId
			logger.error("not found this currentThreadId:" + currentThreadId);
			return resultObject;
		}
		return messageDaoFacade.getMessageQueryDao().getThreadsPrevNext(
				forumId, currentThreadId);
	}

}