|
What this is
Other links
The source code
/*
* $Header: /cvsroot/mvnforum/mvnforum/src/com/mvnforum/user/ThreadWebHandler.java,v 1.46 2005/01/18 11:52:24 minhnn Exp $
* $Author: minhnn $
* $Revision: 1.46 $
* $Date: 2005/01/18 11:52:24 $
*
* ====================================================================
*
* Copyright (C) 2002-2005 by MyVietnam.net
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or any later version.
*
* All copyright notices regarding mvnForum MUST remain intact
* in the scripts and in the outputted HTML.
* The "powered by" text/logo with a link back to
* http://www.mvnForum.com and http://www.MyVietnam.net in the
* footer of the pages MUST remain visible when the pages
* are viewed on the internet or intranet.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* Support can be obtained from support forums at:
* http://www.mvnForum.com/mvnforum/index
*
* Correspondence and Marketing Questions can be sent to:
* info@MyVietnam.net
*
* @author: Minh Nguyen minhnn@MyVietnam.net
* @author: Mai Nguyen mai.nh@MyVietnam.net
*/
package com.mvnforum.user;
import java.sql.Timestamp;
import java.util.*;
import javax.servlet.http.HttpServletRequest;
import com.mvnforum.*;
import com.mvnforum.auth.*;
import com.mvnforum.common.StatisticsUtil;
import com.mvnforum.db.*;
import com.mvnforum.search.post.DeletePostIndexTask;
import com.mvnforum.search.post.PostIndexer;
import net.myvietnam.mvncore.exception.*;
import net.myvietnam.mvncore.util.*;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class ThreadWebHandler {
private static Log log = LogFactory.getLog(ThreadWebHandler.class);
private OnlineUserManager onlineUserManager = OnlineUserManager.getInstance();
public ThreadWebHandler() {
}
void prepareDelete(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
Locale locale = I18nUtil.getLocaleInRequest(request);
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
int numberOfPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inThread(threadID);
// check constraint
int forumID = threadBean.getForumID();
try {
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.forumid_not_exists", new Object[] {new Integer(forumID)});
throw new ObjectNotFoundException(localizedMessage);
}
int logonMemberID = onlineUser.getMemberID();
String authorName = threadBean.getMemberName();
int authorID = 0;
try {
authorID = DAOFactory.getMemberDAO().getMemberIDFromMemberName(authorName);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.membername_not_exists", new Object[] {authorName});
throw new ObjectNotFoundException(localizedMessage);
}
if (permission.canDeletePost(forumID)) {
// have permission, just do nothing, that is dont check the max day contraint
} else if (logonMemberID == authorID) {// same author
// check date here, usually must not older than 7 days
Timestamp now = DateUtil.getCurrentGMTTimestamp();
Timestamp postDate = threadBean.getThreadCreationDate();
int maxDays = MVNForumConfig.getMaxDeleteDays();
if ( (now.getTime() - postDate.getTime()) > (DateUtil.DAY * maxDays) ) {
/** @todo choose a better Exception here */
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.cannot_delete.post_is_too_old", new Object[] {new Integer(maxDays)});
throw new BadInputException(localizedMessage);
//throw new BadInputException("You cannot delete a post which is older than " + maxDays + " days.");
}
//Check to make sure that "no reply" for this post
if (numberOfPosts > 1) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.cannot_delete.thread_has_reply");
throw new BadInputException(localizedMessage);
//throw new BadInputException("Cannot delete a thread that has reply!");
}
/** @todo check status of this thread */
/*
if (postBean.getPostStatus() == ?) {
throw new BadInputException("Cannot delete message which is disable.");
}*/
} else {//not an author, so this user must have Edit Permission
permission.ensureCanDeletePost(forumID);// this method ALWAYS throws AuthenticationException
}
int numberOfPendingPosts = DAOFactory.getPostDAO().getNumberOfDisablePosts_inThread(threadID);
request.setAttribute("ThreadBean", threadBean);
request.setAttribute("NumberOfPosts", new Integer(numberOfPosts));
request.setAttribute("NumberOfPendingPosts", new Integer(numberOfPendingPosts));
}
void processDelete(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
// primary key column(s)
Locale locale = I18nUtil.getLocaleInRequest(request);
int threadID = ParamUtil.getParameterInt(request, "thread");
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
ForumCache.getInstance().getBean(threadBean.getForumID()).ensureNotDisabledForum();
// now check the password
MyUtil.ensureCorrectCurrentPassword(request);
deleteThread(request, threadBean);
//now, update the statistics in the forum and member
int forumID = threadBean.getForumID();
StatisticsUtil.updateForumStatistics(forumID);
request.setAttribute("ForumID", String.valueOf(forumID));
}
// Note that this method does not update the forum statistics
// The caller must call method to update the forum statistics
void deleteThread(HttpServletRequest request, ThreadBean threadBean)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can delete
permission.ensureIsAuthenticated();
// primary key column(s)
int threadID = threadBean.getThreadID();
Locale locale = I18nUtil.getLocaleInRequest(request);
// now, check the permission
int forumID = threadBean.getForumID();
int logonMemberID = onlineUser.getMemberID();
String authorName = threadBean.getMemberName();
int authorID = 0;
try {
authorID = DAOFactory.getMemberDAO().getMemberIDFromMemberName(authorName);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.membername_not_exists", new Object[] {authorName});
throw new ObjectNotFoundException(localizedMessage);
}
if (permission.canDeletePost(forumID)) {
// have permission, just do nothing, that is dont check the max day contraint
} else if (logonMemberID == authorID) {// same author
// check date here, usually must not older than 7 days
Timestamp now = DateUtil.getCurrentGMTTimestamp();
Timestamp postDate = threadBean.getThreadCreationDate();
int maxDays = MVNForumConfig.getMaxDeleteDays();
if ( (now.getTime() - postDate.getTime()) > (DateUtil.DAY * maxDays) ) {
/** @todo choose a better Exception here */
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.cannot_delete.post_is_too_old", new Object[] {new Integer(maxDays)});
throw new BadInputException(localizedMessage);
//throw new BadInputException("You cannot delete a post which is older than " + maxDays + " days.");
}
//Check to make sure that "no reply" for this post
int numberOfPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inThread(threadID);
if (numberOfPosts > 1) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.cannot_delete.thread_has_reply");
throw new BadInputException(localizedMessage);
//throw new BadInputException("Cannot delete a thread that has reply!");
}
if (threadBean.getThreadStatus() == ThreadBean.THREAD_STATUS_DISABLED) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.cannot_delete_your_own_disabled_thread");
throw new BadInputException(localizedMessage);
//throw new BadInputException("Cannot delete your own disabled thread.");
}
} else {//not an author, so this user must have Edit Permission
permission.ensureCanDeletePost(forumID);// this method ALWAYS throws AuthenticationException
}
// Delete all attachments in this thread,
// we must call this before any attempt to delete the thread
// That is, the order when delete is VERY IMPORTANT
AttachmentWebHandler.deleteAttachments_inThread(threadID);
DAOFactory.getFavoriteThreadDAO().delete_inThread(threadID);
DAOFactory.getWatchDAO().delete_inThread(threadID);
DAOFactory.getPostDAO().delete_inThread(threadID);
// now delete the thread, note that we delete it after delete all child objects
DAOFactory.getThreadDAO().delete(threadID);
// now update the search index
// @todo : what if the above methods throw exception, then no thread is deleted from index ???
PostIndexer.scheduleDeletePostTask(threadID, DeletePostIndexTask.OBJECT_TYPE_THREAD);
//now, update the statistics in the member
StatisticsUtil.updateMemberStatistics(authorID);
}
void prepareMoveThread(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
ForumCache.getInstance().getBean(threadBean.getForumID()).ensureNotDisabledForum();
// now, check the permission
// @todo: is it the correct permission ???
permission.ensureCanDeletePost(threadBean.getForumID());
int numberOfPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inThread(threadID);
request.setAttribute("ThreadBean", threadBean);
request.setAttribute("NumberOfPosts", new Integer(numberOfPosts));
}
void processMoveThread(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
ForeignKeyNotFoundException, AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can delete
permission.ensureIsAuthenticated();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
// now, check the permission
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
int forumID = threadBean.getForumID();
permission.ensureCanDeletePost(forumID);
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
// now check the password
MyUtil.ensureCorrectCurrentPassword(request);
int destForumID = ParamUtil.getParameterInt(request, "destforum");
// make sure that we dont move to the same forum (meaningless)
if (destForumID == forumID) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.AssertionException.cannot_move_thread_to_the_same_forum");
throw new BadInputException(localizedMessage);
//throw new AssertionException("Cannot move thread to the same forum.");
}
// now make sure that the dest forum is existed
ForumCache.getInstance().getBean(destForumID);
DAOFactory.getThreadDAO().updateForumID(threadID, destForumID);
DAOFactory.getPostDAO().update_ForumID_inThread(threadID, destForumID);
DAOFactory.getFavoriteThreadDAO().update_ForumID_inThread(threadID, destForumID);
//now, update the statistics in the source forum and dest forum
StatisticsUtil.updateForumStatistics(forumID);
StatisticsUtil.updateForumStatistics(destForumID);
// now update the search index
// @todo : what if the above methods throw exception, then no thread is deleted from index ???
PostIndexer.scheduleUpdateThreadTask(threadID);
request.setAttribute("ForumID", String.valueOf(forumID));
}
void prepareEditThreadStatus(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
ForumCache.getInstance().getBean(threadBean.getForumID()).ensureNotDisabledForum();
// now, check the permission
permission.ensureCanModerateThread(threadBean.getForumID());
int numberOfPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inThread(threadID);
int numberOfPendingPosts = DAOFactory.getPostDAO().getNumberOfDisablePosts_inThread(threadID);
request.setAttribute("ThreadBean", threadBean);
request.setAttribute("NumberOfPosts", new Integer(numberOfPosts));
request.setAttribute("NumberOfPendingPosts", new Integer(numberOfPendingPosts));
}
void processEditThreadStatus(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can edit thread status
permission.ensureIsAuthenticated();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
// now, check the permission
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
int forumID = threadBean.getForumID();
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
permission.ensureCanModerateThread(forumID);
// now check the password
MyUtil.ensureCorrectCurrentPassword(request);
int threadStatus = ParamUtil.getParameterInt(request, "ThreadStatus");
ThreadBean.validateThreadStatus(threadStatus);
// now if change from Disable to Enable, update the lastpostdate so
// that the Watch will see this thread as a new thread
if ((threadBean.getThreadStatus() == ThreadBean.THREAD_STATUS_DISABLED) &&
(threadStatus != ThreadBean.THREAD_STATUS_DISABLED)) {
Timestamp now = DateUtil.getCurrentGMTTimestamp();
DAOFactory.getThreadDAO().updateLastPostDate(threadID, now);
}
DAOFactory.getThreadDAO().updateThreadStatus(threadID, threadStatus);
StatisticsUtil.updateForumStatistics(forumID);
//@todo: should update other info ???
request.setAttribute("ThreadID", String.valueOf(threadID));
request.setAttribute("ForumID", String.valueOf(forumID));
}
void prepareEditThreadType(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
ForumCache.getInstance().getBean(threadBean.getForumID()).ensureNotDisabledForum();
// now, check the permission
permission.ensureCanModerateThread(threadBean.getForumID());
int numberOfPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inThread(threadID);
int numberOfPendingPosts = DAOFactory.getPostDAO().getNumberOfDisablePosts_inThread(threadID);
request.setAttribute("ThreadBean", threadBean);
request.setAttribute("NumberOfPosts", new Integer(numberOfPosts));
request.setAttribute("NumberOfPendingPosts", new Integer(numberOfPendingPosts));
}
void processEditThreadType(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AuthenticationException, AssertionException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can edit thread status
permission.ensureIsAuthenticated();
Locale locale = I18nUtil.getLocaleInRequest(request);
// primary key column(s)
int threadID = ParamUtil.getParameterInt(request, "thread");
int threadType = ParamUtil.getParameterUnsignedInt(request, "ThreadType", ThreadBean.THREAD_TYPE_DEFAULT);
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
int forumID = threadBean.getForumID();
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
if (threadType > ThreadBean.THREAD_TYPE_GLOBAL_ANNOUNCEMENT /* 3 */) {
throw new BadInputException("Not support this thread type");
}
if ((threadType == ThreadBean.THREAD_TYPE_GLOBAL_ANNOUNCEMENT) ||
(threadBean.getThreadType() == ThreadBean.THREAD_TYPE_GLOBAL_ANNOUNCEMENT)) {
permission.ensureCanAdminSystem();
} else {
permission.ensureCanModerateThread(forumID);
}
// now check the password
MyUtil.ensureCorrectCurrentPassword(request);
DAOFactory.getThreadDAO().updateThreadType(threadID, threadType);
//@todo: should update other info ???
request.setAttribute("ThreadID", String.valueOf(threadID));
request.setAttribute("ForumID", String.valueOf(forumID));
}
void prepareList_limit(HttpServletRequest request)
throws BadInputException, ObjectNotFoundException, DatabaseException,
AssertionException, AuthenticationException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
Locale locale = I18nUtil.getLocaleInRequest(request);
int forumID = ParamUtil.getParameterInt(request, "forum");
// make sure there is the forum
// will throw an BadInputException if there is not this forum
ForumBean forumBean = ForumCache.getInstance().getBean(forumID);
forumBean.ensureNotDisabledForum();
// make sure user can read post in this forum
permission.ensureCanReadPost(forumID);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfEnableThreads_inForum(forumID);
int totalNormalThreads = DAOFactory.getThreadDAO().getNumberOfNormalEnableThreads_inForum(forumID);
if (offset > totalNormalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getNormalEnableThreads_inForum_withSortSupport_limit(forumID, offset, postsPerPage, sort, order);
// the correct value is the enable posts - disable threads, so we could get directly from the ForumBean
//int totalPosts = DAOFactory.getPostDAO().getNumberOfEnablePosts_inForum(forumID);
int totalPosts = forumBean.getForumPostCount();
int pendingThreadCount = 0;
int threadsWithPendingPostsCount = 0;
if (permission.canModerateThread(forumID)) {
pendingThreadCount = DAOFactory.getThreadDAO().getNumberOfDisableThreads_inForum(forumID);
threadsWithPendingPostsCount = DAOFactory.getThreadDAO().getNumberOfEnableThreadsWithPendingPosts_inForum(forumID);
}
Collection allThreadBeans = new ArrayList();
Collection globalAnnounces = DAOFactory.getThreadDAO().getEnableGlobalAnnouncements();
allThreadBeans.addAll(globalAnnounces);
Collection announcements = DAOFactory.getThreadDAO().getEnableForumAnnouncements_inForum(forumID);
allThreadBeans.addAll(announcements);
if (offset == 0) {
Collection stickies = DAOFactory.getThreadDAO().getEnableStickies_inForum(forumID);
allThreadBeans.addAll(stickies);
}
allThreadBeans.addAll(threadBeans);
request.setAttribute("ThreadBeans", allThreadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
request.setAttribute("TotalNormalThreads", new Integer(totalNormalThreads));
request.setAttribute("TotalPosts", new Integer(totalPosts));
request.setAttribute("PendingThreadCount", new Integer(pendingThreadCount));
request.setAttribute("ThreadsWithPendingPostsCount", new Integer(threadsWithPendingPostsCount));
}
public void prepareListRecentThreads_limit(HttpServletRequest request)
throws DatabaseException, AssertionException, BadInputException,
AuthenticationException, ObjectNotFoundException, DatabaseException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
Locale locale = I18nUtil.getLocaleInRequest(request);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfEnableThreads();
if (offset > totalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getEnableThreads_withSortSupport_limit(offset, postsPerPage, sort, order);
// now remove thread that current user does not have permission
for (Iterator iterator = threadBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
int currentForumID = threadBean.getForumID();
if (permission.canReadPost(currentForumID) == false) {
iterator.remove();
} else if (ForumCache.getInstance().getBean(currentForumID).getForumStatus() == ForumBean.FORUM_STATUS_DISABLED) {
iterator.remove();
}
}
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
}
void prepareListRecentDisabledThreads_limit(HttpServletRequest request)
throws DatabaseException, AssertionException, BadInputException, AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view pending/disabled threads
permission.ensureIsAuthenticated();
permission.ensureCanModerateThreadInAnyForum();
Locale locale = I18nUtil.getLocaleInRequest(request);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfDisableThreads();
if (offset > totalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getDisableBeans_withSortSupport_limit(offset, postsPerPage, sort, order);
// now remove thread that current user does not have permission
for (Iterator iterator = threadBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
int currentForumID = threadBean.getForumID();
if (permission.canModerateThread(currentForumID) == false) {
iterator.remove();
} else if (ForumCache.getInstance().getBean(currentForumID).getForumStatus() == ForumBean.FORUM_STATUS_DISABLED) {
iterator.remove();
}
}
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
}
void prepareListDisabledThreads_limit_xml(HttpServletRequest request)
throws DatabaseException, AssertionException, AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view pending/disabled threads
permission.ensureIsAuthenticated();
permission.ensureCanModerateThreadInAnyForum();
Collection pendingThreadBeans = DAOFactory.getThreadDAO().getDisableBeans_withSortSupport_limit(0, 10000, "ThreadLastPostDate", "DESC");
// now remove thread that current user does not have permission
for (Iterator iterator = pendingThreadBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
if (permission.canModerateThread(threadBean.getForumID()) == false) {
iterator.remove();
}
}
Collection threadWithPendingPostsBeans = DAOFactory.getThreadDAO().getEnableThreadsWithPendingPosts_withSortSupport_limit(0, 10000, "ForumID", "DESC");
for (Iterator iterator = threadWithPendingPostsBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
if (permission.canModerateThread(threadBean.getForumID()) == false) {
iterator.remove();
} else {
Collection pendingPosts = DAOFactory.getPostDAO().getDisablePosts_inThread_limit(threadBean.getThreadID(), 0, 10000);
threadBean.setPendingPosts(pendingPosts);
}
}
request.setAttribute("PendingThreadBeans", pendingThreadBeans);
request.setAttribute("ThreadWithPendingPostsBeans", threadWithPendingPostsBeans);
}
void prepareListRecentEnableThreadsWithPendingPosts_limit(HttpServletRequest request)
throws DatabaseException, AssertionException, BadInputException, AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view enable threads with pending posts
permission.ensureIsAuthenticated();
permission.ensureCanModerateThreadInAnyForum();
Locale locale = I18nUtil.getLocaleInRequest(request);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfEnableThreadsWithPendingPosts();
if (offset > totalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getEnableThreadsWithPendingPosts_withSortSupport_limit(offset, postsPerPage, sort, order);
// now remove thread that current user does not have permission
for (Iterator iterator = threadBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
int currentForumID = threadBean.getForumID();
if (permission.canModerateThread(currentForumID) == false) {
iterator.remove();
} else if (ForumCache.getInstance().getBean(currentForumID).getForumStatus() == ForumBean.FORUM_STATUS_DISABLED) {
iterator.remove();
}
}
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
}
void prepareListEnableThreadsWithPendingPosts_inForum_limit(HttpServletRequest request)
throws DatabaseException, AssertionException, BadInputException, AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view enable threads with pending posts
permission.ensureIsAuthenticated();
int forumID = ParamUtil.getParameterInt(request, "forum");
permission.ensureCanModerateThread(forumID);
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
Locale locale = I18nUtil.getLocaleInRequest(request);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfEnableThreadsWithPendingPosts_inForum(forumID);
if (offset > totalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getEnableThreadsWithPendingPosts_inForum_withSortSupport_limit(forumID, offset, postsPerPage, sort, order);
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
}
void prepareModerationControlPanel(HttpServletRequest request)
throws DatabaseException, DatabaseException, AssertionException, DatabaseException, AuthenticationException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view enable threads with pending posts
permission.ensureIsAuthenticated();
permission.ensureCanModerateThreadInAnyForum();
Collection forumBeans = ForumCache.getInstance().getBeans();
for (Iterator iter = forumBeans.iterator(); iter.hasNext(); ) {
ForumBean forumBean = (ForumBean)iter.next();
int forumID = forumBean.getForumID();
int pendingThreadCount = 0;
int threadsWithPendingPostsCount = 0;
int pendingPostCount = 0;
if (permission.canModerateThread(forumID) && (forumBean.getForumStatus() != ForumBean.FORUM_STATUS_DISABLED) ) {
pendingThreadCount = DAOFactory.getThreadDAO().getNumberOfDisableThreads_inForum(forumID);
threadsWithPendingPostsCount = DAOFactory.getThreadDAO().getNumberOfEnableThreadsWithPendingPosts_inForum(forumID);
pendingPostCount = DAOFactory.getPostDAO().getNumberOfDisablePosts_inForum(forumID);
}
// note that if user does not have permission on this forum, then the value is 0
forumBean.setPendingThreadCount(pendingThreadCount);
forumBean.setThreadsWithPendingPostsCount(threadsWithPendingPostsCount);
forumBean.setPendingPostCount(pendingPostCount);
}
int pendingThreadCount = DAOFactory.getThreadDAO().getNumberOfDisableThreads();
int threadsWithPendingPostsCount = DAOFactory.getThreadDAO().getNumberOfEnableThreadsWithPendingPosts();
// Note that because this forumBeans is a new instance
// we have to put it in session instead of get it again from the ForumCache
request.setAttribute("ForumBeans", forumBeans);
request.setAttribute("PendingThreadCount", new Integer(pendingThreadCount));
request.setAttribute("ThreadsWithPendingPostsCount", new Integer(threadsWithPendingPostsCount));
}
void prepareModeratePendingThreads_inForum_limit(HttpServletRequest request)
throws AssertionException, DatabaseException, AuthenticationException, BadInputException,
DatabaseException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can view pending/disabled threads
permission.ensureIsAuthenticated();
int forumID = ParamUtil.getParameterInt(request, "forum");
// make sure there is the forum
// will throw an BadInputException if there is not this forum
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
permission.ensureCanModerateThread(forumID);
Locale locale = I18nUtil.getLocaleInRequest(request);
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int postsPerPage = onlineUser.getPostsPerPage();
int offset = 0;
try {
offset = ParamUtil.getParameterInt(request, "offset");
} catch (BadInputException e) {
// do nothing
}
int totalThreads = DAOFactory.getThreadDAO().getNumberOfDisableThreads_inForum(forumID);
if (offset > totalThreads) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.BadInputException.offset_greater_than_total_rows");
throw new BadInputException(localizedMessage);
//throw new BadInputException("The offset is not allowed to be greater than total rows.");
}
Collection threadBeans = DAOFactory.getThreadDAO().getDisableThreads_inForum_withSortSupport_limit(forumID, offset, postsPerPage, sort, order);
Collection firstPostBeans = new ArrayList();
for (Iterator iterator = threadBeans.iterator(); iterator.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iterator.next();
PostBean postBean = DAOFactory.getPostDAO().getFirstPost_inThread(threadBean.getThreadID());
firstPostBeans.add(postBean);
// very slow here
/** @todo find a better solution */
MemberBean memberBean = null;
if (postBean.getMemberID() != 0 && postBean.getMemberID() != MVNForumConstant.MEMBER_ID_OF_GUEST) {
memberBean = DAOFactory.getMemberDAO().getMember_forPublic(postBean.getMemberID());
}
postBean.setMemberBean(memberBean);
int postAttachCount = postBean.getPostAttachCount();
if ((postAttachCount > 0) && MVNForumConfig.getEnableAttachment()) {
int postID = postBean.getPostID();
Collection attachBeans = DAOFactory.getAttachmentDAO().getAttachments_inPost(postID);
int actualAttachCount = attachBeans.size();
// now check if the attachCount in talbe Post equals to the actual attachCount in table Attachment
if (postAttachCount != actualAttachCount) {
if (actualAttachCount != DAOFactory.getAttachmentDAO().getNumberOfAttachments_inPost(postID)) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.AssertionException.serious_error.cannot_process_attachment_count");
throw new AssertionException(localizedMessage);
//throw new AssertionException("AssertionException: Serious error: cannot process Attachment Count in table Attachment");
}
log.warn("The attachment count in table Post and Attachment are not synchronized. In table Post = " +
postAttachCount + " and in table Attachment = " + actualAttachCount + ". Synchronize to " + actualAttachCount);
DAOFactory.getPostDAO().updateAttachCount(postID, actualAttachCount);
}
if (actualAttachCount > 0) {
postBean.setAttachmentBeans(attachBeans);
}
}
}
request.setAttribute("FirstPostBeans", firstPostBeans);
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("TotalThreads", new Integer(totalThreads));
}
void processModeratePendingThreads(HttpServletRequest request)
throws AssertionException, DatabaseException, AuthenticationException,
BadInputException, DatabaseException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// user must have been authenticated before he can moderate pending/disabled threads
permission.ensureIsAuthenticated();
Locale locale = I18nUtil.getLocaleInRequest(request);
// check normal permission, note that we dont check
// permission on a forumID because we allow moderate posts
// in multiple forums even if the web interface does not support it
int forumID = -1;
try {
forumID = ParamUtil.getParameterInt(request, "forum");
ForumCache.getInstance().getBean(forumID);// check valid forumID
permission.ensureCanModerateThread(forumID);
ForumCache.getInstance().getBean(forumID).ensureNotDisabledForum();
} catch (BadInputException ex) {
// just ignore, in case of use customized client
}
permission.ensureCanModerateThreadInAnyForum();
try {
String prefix = "modthreadaction_";
for (Enumeration enumeration = request.getParameterNames(); enumeration.hasMoreElements(); ) {
String param = (String) enumeration.nextElement();
if (param.startsWith(prefix)) {
String modValue = ParamUtil.getParameter(request, param, true);
String strThreadID = param.substring(prefix.length());
int threadID = Integer.parseInt(strThreadID);
if (modValue.equals("approve")) {
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
int currentForumID = threadBean.getForumID();
permission.ensureCanModerateThread(currentForumID);
DAOFactory.getThreadDAO().updateThreadStatus(threadID, ThreadBean.THREAD_STATUS_DEFAULT);
// now if change from Disable to Enable, update the lastpostdate so
// that the Watch will see this thread as a new thread
if (threadBean.getThreadStatus() == ThreadBean.THREAD_STATUS_DISABLED ) {
Timestamp now = DateUtil.getCurrentGMTTimestamp();
DAOFactory.getThreadDAO().updateLastPostDate(threadID, now);
}
} else if (modValue.equals("delete")) {
ThreadBean threadBean = null;
try {
threadBean = DAOFactory.getThreadDAO().getThread(threadID);
} catch (ObjectNotFoundException e) {
String localizedMessage = MVNForumResourceBundle.getString(locale, "mvncore.exception.ObjectNotFoundException.threadid_not_exists", new Object[] {new Integer(threadID)});
throw new ObjectNotFoundException(localizedMessage);
}
deleteThread(request, threadBean);
} else {
// it means ignore, do nothing
}
}
}
} finally {
// now update the forum statistics
if (forumID != -1) {
StatisticsUtil.updateForumStatistics(forumID);
}
}
request.setAttribute("ForumID", String.valueOf(forumID));
}
void prepareList_inFavorite(HttpServletRequest request)
throws DatabaseException, AssertionException, AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
permission.ensureIsAuthenticated();
int memberID = onlineUser.getMemberID();
Collection threadBeans = DAOFactory.getThreadDAO().getThreads_inFavorite_inMember(memberID);
//remove threads that current user dont have permission
for (Iterator iter = threadBeans.iterator(); iter.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iter.next();
int currentForumID = threadBean.getForumID();
if (permission.canReadPost(currentForumID) == false) {
iter.remove();
} else if (threadBean.getThreadStatus() == ThreadBean.THREAD_STATUS_DISABLED) {
if (permission.canModerateThread(currentForumID) == false) {
iter.remove();
}
} else if (ForumCache.getInstance().getBean(currentForumID).getForumStatus() == ForumBean.FORUM_STATUS_DISABLED) {
iter.remove();
}
}
int max = MVNForumConfig.getMaxFavoriteThread();
int favoriteThreadCount = threadBeans.size();
double ratio = 0;
if (max == 0) {
ratio = 1.0;
} else {
ratio = (double)favoriteThreadCount / max;
}
request.setAttribute("QuotaRatio", new Double(ratio * 100));
request.setAttribute("ThreadBeans", threadBeans);
}
void prepareRSSSummary(HttpServletRequest request)
throws DatabaseException {
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
// call this to check the parameter sort and order
DAOFactory.getThreadDAO().getEnableThreads_withSortSupport_limit(0/*offset*/, 1/*rows*/, sort, order);
}
void prepareListRSS(HttpServletRequest request)
throws DatabaseException, AssertionException,
AuthenticationException, ObjectNotFoundException {
OnlineUser onlineUser = onlineUserManager.getOnlineUser(request);
MVNForumPermission permission = onlineUser.getPermission();
// for sort and order stuff
String sort = ParamUtil.getParameter(request, "sort");
String order = ParamUtil.getParameter(request, "order");
if (sort.length() == 0) sort = "ThreadLastPostDate";
if (order.length()== 0) order = "DESC";
int offset = 0;// offset MUST always equals 0, please dont change !!!
int rows = MVNForumConfig.getRowsPerRSS();
try {
rows = ParamUtil.getParameterInt(request, "rows");
if (rows <= 0) rows = MVNForumConfig.getRowsPerRSS();
} catch (Exception ex) {
//just ignore
}
// now find that user want global/category/forum RSS
int forumID = -1;
int categoryID = -1;
try {
forumID = ParamUtil.getParameterInt(request, "forum");
} catch (Exception ex) {
try {
categoryID = ParamUtil.getParameterInt(request, "category");
} catch (Exception ex1) { }
}
Collection threadBeans = null;
if (forumID > 0) {
if (permission.canReadPost(forumID)) {
threadBeans = DAOFactory.getThreadDAO().getAllEnableThreads_inForum_withSortSupport_limit(forumID, offset, rows, sort, order);
} else {
// dont have permission on this forum, just create empty Collection
threadBeans = new ArrayList();
}
} else if (categoryID > 0) {
//@todo implement later
} else {// global RSS
threadBeans = DAOFactory.getThreadDAO().getEnableThreads_withSortSupport_limit(offset, rows, sort, order);
//remove threads that current user dont have permission
for (Iterator iter = threadBeans.iterator(); iter.hasNext(); ) {
ThreadBean threadBean = (ThreadBean)iter.next();
int currentForumID = threadBean.getForumID();
if (permission.canReadPost(currentForumID) == false) {
iter.remove();
} else if (ForumCache.getInstance().getBean(currentForumID).getForumStatus() == ForumBean.FORUM_STATUS_DISABLED) {
iter.remove();
}
}
}
request.setAttribute("ThreadBeans", threadBeans);
request.setAttribute("ForumID", new Integer(forumID));
request.setAttribute("CategoryID", new Integer(categoryID));
}
}
|
| ... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.