diaryaction.java

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

				diaryForm.getSid()).getPath();
		return msgbox(mapping, form, request, response, msg, uri);
	}

	/**
	 * 彻底删除日记
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doDeleteFromTrash(ActionMapping mapping,
			ActionForm form, HttpServletRequest request,
			HttpServletResponse response) throws Exception {
		DiaryForm diaryForm = (DiaryForm) form;
		UserBean loginUser = super.getLoginUser(request, response);
		String msg = null;
		if (loginUser == null) {
			msg = getMessage(request, null, "error.user_not_login");
		} else {
			DiaryBean diary = DiaryDAO.getDiaryByID(diaryForm.getId());
			if (diary == null) {
				msg = getMessage(request, null, "error.diary_not_exists");
			} else if (!DiaryDAO.canUserEditDiary(loginUser, diary)) {
				msg = getMessage(request, null, "error.access_deny");
			} else {
				try {
					DiaryDAO.forceDelete(diaryForm.getId());
					//msg = getMessage(request, null, "diary.force_deleted");
				} catch (Exception e) {
					context().log("delete diary failed.", e);
					msg = getMessage(request, null, "error.database", e
							.getMessage());
				}
			}
		}
		
		String fromPage = diaryForm.getFromPage();
		
		if (StringUtils.isNotEmpty(fromPage))
			return msgbox(mapping, form, request, response, msg, fromPage);
		
		return makeForward(mapping.findForward("trash"), diaryForm.getSid());
	}

	/**
	 * 锁定日记
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doLock(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		DiaryForm diaryForm = (DiaryForm) form;
		UserBean loginUser = super.getLoginUser(request, response);
		String msg = null;
		if (loginUser == null) {
			msg = getMessage(request, null, "error.user_not_login");
		} else {
			DiaryBean diary = DiaryDAO.getDiaryByID(diaryForm.getId());
			if (diary == null) {
				msg = getMessage(request, null, "error.diary_not_exists");
			} else if (!DiaryDAO.canUserEditDiary(loginUser, diary)) {
				msg = getMessage(request, null, "error.access_deny");
			} else {
				try {
					DiaryDAO.lock(diaryForm.getId());
					msg = getMessage(request, null, "diary.locked");
				} catch (Exception e) {
					context().log("delete diary failed.", e);
					msg = getMessage(request, null, "error.database", e
							.getMessage());
				}
			}
		}
		
		String fromPage = diaryForm.getFromPage();
		
		if (StringUtils.isNotEmpty(fromPage))
			return msgbox(mapping, form, request, response, msg, fromPage);
		return makeForward(mapping.findForward("diary"), diaryForm.getSid());
	}

	/**
	 * 日记解锁
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doUnLock(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		DiaryForm diaryForm = (DiaryForm) form;
		UserBean loginUser = super.getLoginUser(request, response);
		String msg = null;
		if (loginUser == null) {
			msg = getMessage(request, null, "error.user_not_login");
		} else {
			DiaryBean diary = DiaryDAO.getDiaryByID(diaryForm.getId());
			if (diary == null) {
				msg = getMessage(request, null, "error.diary_not_exists");
			} else if (!DiaryDAO.canUserEditDiary(loginUser, diary)) {
				msg = getMessage(request, null, "error.access_deny");
			} else {
				try {
					DiaryDAO.unlock(diaryForm.getId());
					msg = getMessage(request, null, "diary.unlocked");
				} catch (Exception e) {
					context().log("delete diary failed.", e);
					msg = getMessage(request, null, "error.database", e
							.getMessage());
				}
			}
		}

		String fromPage = diaryForm.getFromPage();
		
		if (StringUtils.isNotEmpty(fromPage))
			return msgbox(mapping, form, request, response, msg, fromPage);
		return makeForward(mapping.findForward("diary"), diaryForm.getSid());
	}

	/**
	 * 删除日记
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doDelete(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {
		DiaryForm diaryForm = (DiaryForm) form;
		UserBean loginUser = super.getLoginUser(request, response);
		String msg = null;
		if (loginUser == null) {
			msg = getMessage(request, null, "error.user_not_login");
		} else {
			DiaryBean diary = DiaryDAO.getDiaryByID(diaryForm.getId());
			if (diary == null) {
				msg = getMessage(request, null, "error.diary_not_exists");
			} else if (!DiaryDAO.canUserEditDiary(loginUser, diary)) {
				msg = getMessage(request, null, "error.access_deny");
			} else {
				try {
					DiaryDAO.delete(diary);
					SearchProxy.remove(diary);
					TextCacheManager.deleteTextContent(DiaryBean.TYPE_DIARY, diary.getId());
					msg = getMessage(request, null, "diary.deleted");
				} catch (Exception e) {
					context().log("delete diary failed.", e);
					msg = getMessage(request, null, "error.database", e
							.getMessage());
				}
			}
		}
		
		String fromPage = diaryForm.getFromPage();
		
		if (StringUtils.isNotEmpty(fromPage))
			return msgbox(mapping, form, request, response, msg, fromPage);
		return makeForward(mapping.findForward("diary"), diaryForm.getSid());
	}

	/**
	 * 删除附件
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doDeleteAttachement(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response, String s_file_id)
			throws Exception {
		int file_id = Integer.parseInt(s_file_id);
		UserBean loginUser = super.getLoginUser(request, response);
		if (loginUser != null) {
			String ssn_id = RequestUtils.getDlogSessionId(request);
			FCKUploadFileDAO.deleteFileById(loginUser.getId(), ssn_id, file_id);
		}

		DiaryForm diaryForm = (DiaryForm) form;
		return makeForward(mapping.findForward("addlog"), diaryForm.getSid());
	}

	/**
	 * 发表日记
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @param identity 如果该值为WML则表示来自WML页面
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doPublishLog(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response, String identity)
			throws Exception {
		ActionMessages msgs = new ActionMessages();
		DiaryForm log = (DiaryForm) form;
		//super.validateClientId(request, log);
		while (true) {
			// 检测日记表单域的值
			if (StringUtils.isEmpty(log.getTitle())) {
				msgs.add("title", new ActionMessage("error.empty_not_allowed"));
				break;
			}
			if (StringUtils.isEmpty(log.getContent())) {
				msgs.add("content",
						new ActionMessage("error.empty_not_allowed"));
				break;
			}
			UserBean loginUser = super.getLoginUser(request, response);
			if (loginUser == null) {
				msgs.add("log", new ActionMessage("error.user_not_login"));
				break;
			}
			if (loginUser.getStatus() != UserBean.STATUS_NORMAL) {
				msgs.add("log", new ActionMessage("error.user_not_available"));
				break;
			}
			SiteBean site = super.getSiteByID(log.getSid());
			if (site == null) {
				msgs.add("log", new ActionMessage("error.site_not_available"));
				break;
			}
			boolean catalog_can_access = false;
			CatalogBean catalog = null;
			// 站长可以访问站内的任何分类
			if (site.isOwner(loginUser)) {
				catalog = CatalogDAO.getCatalogByID(log.getCatalogId());
				if (catalog!=null && catalog.getSite().getId() == site.getId())
					catalog_can_access = true;
			} else {
				// 列出用户在该站点可访问的日记分类
				List catalogs = CatalogDAO.listCatalogs(site, loginUser, true);
				for (int i = 0; catalogs != null && i < catalogs.size(); i++) {
					CatalogBean t_catalog = (CatalogBean) catalogs.get(i);
					if (t_catalog.getId() == log.getCatalogId()) {
						catalog = t_catalog;
						catalog_can_access = true;
						break;
					}
				}
			}
			if (!catalog_can_access) {
				msgs.add("log", new ActionMessage("error.catalog_deny",
						new Integer(log.getCatalogId())));
				break;
			}
			// 用户欲操作的日记分类被允许
			if (StringUtils.isEmpty(log.getWeather()))
				log.setWeather(DEFAULT_WEATHER);
			if (StringUtils.isEmpty(log.getAuthor()))
				log.setAuthor(loginUser.getNickname());
			if (StringUtils.isEmpty(log.getTags()))
				log.setTags(null);
			if (StringUtils.isEmpty(log.getAuthorUrl()))
				log.setAuthorUrl(null);
			if (StringUtils.isEmpty(log.getRefUrl()))
				log.setRefUrl(null);
			// 创建JournalBean
			DiaryBean journal = new DiaryBean();
			journal.setOwner(loginUser);
			journal.setSite(site);
			journal.setAuthor(super.autoFiltrate(site, log.getAuthor()));
			journal.setAuthorUrl(log.getAuthorUrl());
			journal.setCatalog(catalog);
			journal.setClient(new ClientInfo(request, log.getClientType()));
			// 根据网站的安全标志决定是否对内容进行敏感字词过滤

			String ssn_id = RequestUtils.getDlogSessionId(request);
			boolean wml = WML_IDENTITY.equalsIgnoreCase(identity);
			String content = autoCompileContent(request, site, log.getContent(), loginUser.getId(), ssn_id, wml);
			journal.setContent(content);
			journal.setSize(content.getBytes().length);
			journal.setTitle(super.autoFiltrate(site, log.getTitle()));
			journal.setKeyword(super.autoFiltrate(site, log.getTags()));
			
			journal.setMoodLevel(log.getMoodLevel());
			journal.setRefUrl(log.getRefUrl());
			journal.setReplyNotify(log.getNotify());
			journal.setStatus(DiaryBean.STATUS_NORMAL);
			journal.setWeather(log.getWeather());
			journal.setWriteTime(DateUtils.mergeDateTime(log.getWriteDate(), log.getWriteTime()).getTime());
			Date curTime = new Date();
			if(journal.getWriteTime().after(curTime))
				journal.setWriteTime(curTime);
			// 检查背景音乐是否有效
			MusicBean song = MusicDAO.getMusicByID(log.getBgSound());
			if (song != null && song.getSite().getId() == site.getId()) {
				journal.setBgSound(song);
			}
			DiaryDAO.create(journal, log.getBookmark() == 1);
			// 检索上传的信息
			pickupUploadFileItems(request, response, loginUser.getId(), site, journal
					.getId(), DiaryBean.TYPE_DIARY);

			if (log.getRefUrl() != null) {
				trackBack(journal, log.getRefUrl());
			}
			break;
		}
		if (!msgs.isEmpty()) {
			saveMessages(request, msgs);
			return mapping.findForward("addlog");
		}
		return makeForward(mapping.findForward("diary"), log.getSid());
	}

	/**
	 * 直接发表草稿
	 * 
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return
	 * @throws Exception
	 */
	protected ActionForward doPublishDraftDirectly(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws Exception {