boardaction.java

java编写的简易留言本

package anni.gbook;

import java.io.UnsupportedEncodingException;

import java.util.Date;
import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import anni.tools.Log;
import anni.tools.ServiceSupport;


/**
 *  转发消息的action类.
 *
 * @author Lingo
 * @version 1.0
 * @since 2006-01-02 23:24
 */
public class BoardAction extends ServiceSupport {
    /**
     * 每页显示信息数.
     */
    public static final int PAGE_SIZE = 6;

    /**
     * dao类.
     */
    private IBoardDAO dao;

    /**
     * 构造方法.
     */
    public BoardAction() {
        /*
         *dao = FileDAO.getInstance();
         */
        dao = AccessDAO.getInstance();
    }

    /////////////////////////////////////////////////////////////////////////////////////////////

    /**
     * 显示所有的留言.
     * @since 2006-01-01 21:42
     * @author Lingo
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String browse(final HttpServletRequest request) {
        List all = dao.findAll();
        request.setAttribute("all", all);

        int count = all.size();

        String currentPage0 = request.getParameter("currentPage");

        //System.out.println(currentPage0);
        int currentPage = 0;

        try {
            currentPage = Integer.parseInt(currentPage0);
        } catch (NumberFormatException ex) {
            //System.out.println(currentPage+"");
            //System.out.println("ex : "+ex.getMessage());
            //System.out.println(currentPage+"");
            ex.printStackTrace();
        }

        if ((currentPage < 0) || (currentPage > (count / PAGE_SIZE))) {
            currentPage = 0;
        }

        request.setAttribute("currentPage", currentPage + "");

        //System.out.println(currentPage+"");

        //System.out.println("test");
        return "/browse.jsp";
    }

    /**
     * 添加一条信息.
     * 对重复提交进行了简单的处理，就是在jsp里生成一次性的标志
     * 判断，如果不是重复提交就进行处理，如果是重复提交，就跳转到错误页面
     * @author Lingo
     * @since 2006-01-02 20:11
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String add(final HttpServletRequest request) {
        //首先需要检测token，判断是否重复提交
        String token1 = request.getParameter("token");
        HttpSession session = request.getSession();
        String token2 = (String) session.getAttribute("token");

        if (!token1.equals(token2)) {
            //发生了重复提交
            return "/token_error.jsp";
        } else {
            //没有发生重复提交
            //首先处理判断重复提交的标志
            session.setAttribute("token", "");
        }

        //先从form中取出各个字段的值
        //
        String name = request.getParameter("newname");
        String email = request.getParameter("newemail");
        String pageName = request.getParameter("newpagename");
        String pageUrl = request.getParameter("newpageurl");
        String sex0 = request.getParameter("sex"); //0-boy,1-girl
        String img = request.getParameter("img");
        String content = request.getParameter("newtext");

        //客户留言者IP
        String ip = request.getRemoteAddr();

        //对字段进行处理
        //
        if (pageName == null) {
            pageName = "";
        }

        if ((pageUrl == null) || pageUrl.equals("http://")) {
            pageUrl = "";
        } else {
            if (pageName.equals("")) {
                pageName = "homePage";
            }
        }

        try {
            name = new String(name.getBytes("ISO-8859-1"), "GB2312");
            pageName = new String(pageName.getBytes("ISO-8859-1"), "GB2312");
            content = new String(content.getBytes("ISO-8859-1"), "GB2312");
        } catch (UnsupportedEncodingException ex) {
            ex.printStackTrace();
        }

        int sex = 0;

        try {
            sex = Integer.parseInt(sex0);
        } catch (NumberFormatException ex) {
            sex = 0;
        }

        //添加记录
        //
        BoardInfo info = new BoardInfo();
        info.setName(name);
        info.setEmail(email);
        info.setPageName(pageName);
        info.setPageUrl(pageUrl);
        info.setSex(sex);
        info.setImg(img);
        info.setContent(content);
        info.setIp(ip);
        info.setDateTime(new Date());
        info.setReply("");

        dao.insert(info);

        return "/index.jsp";
    }

    /**
     * 删除一条数据.
     * 不过里边没有判断id对应的数据是否存在
     * 如果你不是在浏览的时候手工修改了文件的数据的话，是不会出现这种情况的
     * @author Lingo
     * @since2006-01-02 21:43
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String delete(final HttpServletRequest request) {
        String inpass = request.getParameter("inpass");
        HttpSession session = request.getSession();
        String pass = (String) session.getAttribute("pass");

        if ((pass == null) || !pass.equals(inpass)) {
            return "/delete_pass_invalid.jsp";
        }

        String id0 = request.getParameter("id");

        //Log.info(id0);
        int id;

        try {
            id = Integer.parseInt(id0);
        } catch (NumberFormatException ex) {
            Log.info(ex.getMessage());
            id = 0;
        }

        //Log.info(id+"");
        if (dao.findById(id) == null) {
            return "/delete_id_error.jsp";
        }

        dao.delete(id);

        return "/delete_success.jsp";
    }

    /**
     * 根据id查找相应用户的ip.
     * @author Lingo
     * @since 2006-01-02 21:51
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String viewIp(final HttpServletRequest request) {
        String inpass = request.getParameter("inpass");
        HttpSession session = request.getSession();
        String pass = (String) session.getAttribute("pass");

        if ((pass == null) || !pass.equals(inpass)) {
            return "/viewip_pass_invalid.jsp";
        }

        String id0 = request.getParameter("id");

        //Log.info(id0);
        int id;

        try {
            id = Integer.parseInt(id0);
        } catch (NumberFormatException ex) {
            Log.info(ex.getMessage());
            id = 0;
        }

        //Log.info(id+"");
        BoardInfo info = dao.findById(id);

        if (info == null) {
            return "/viewip_id_error.jsp";
        }

        request.setAttribute("id", String.valueOf(info.getId()));
        request.setAttribute("ip", info.getIp());

        return "/viewip_success.jsp";
    }

    /**
     * 根据id查找相应用户的reply.
     * @author Lingo
     * @since 2006-01-02 21:51
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String viewReply(final HttpServletRequest request) {
        String id0 = request.getParameter("id");

        //Log.info(id0);
        int id;

        try {
            id = Integer.parseInt(id0);
        } catch (NumberFormatException ex) {
            Log.info(ex.getMessage());
            id = 0;
        }

        //Log.info(id+"");
        BoardInfo info = dao.findById(id);

        if (info == null) {
            return "/reply_id_error.jsp";
        }

        String reply = info.getReply();

        request.setAttribute("id", String.valueOf(info.getId()));
        request.setAttribute("reply", reply);

        //如果回复信息中存在html标签，就说明上次没有对html标签进行转换
        //把上次对html设置的方式也保留到request中
        if (reply.indexOf("<") != -1) {
            request.setAttribute("html", "no");
        }

        return "/reply.jsp";
    }

    /**
     * 根据id回复相应用户的留言.
     * @author Lingo
     * @since 2006-01-02 23:00
     * @param request 请求
     * @return String 返回跳转的url
     */
    public final String reply(final HttpServletRequest request) {
        String inpass = request.getParameter("inpass");
        HttpSession session = request.getSession();
        String pass = (String) session.getAttribute("pass");

        if ((pass == null) || !pass.equals(inpass)) {
            return "/reply_pass_invalid.jsp";
        }

        String id0 = request.getParameter("id");

        //Log.info(id0);
        int id;

        try {
            id = Integer.parseInt(id0);
        } catch (NumberFormatException ex) {
            Log.info(ex.getMessage());
            id = 0;
        }

        //Log.info(id+"");
        BoardInfo info = dao.findById(id);

        if (info == null) {
            return "/reply_id_error.jsp";
        }

        String reply = request.getParameter("reply");

        try {
            reply = new String(reply.getBytes("ISO-8859-1"), "GB2312");
        } catch (UnsupportedEncodingException ex) {
            ex.printStackTrace();
        }

        String html = request.getParameter("html");

        if (html.equals("yes")) {
            reply = reply.replaceAll("<", "&lt;");
            reply = reply.replaceAll(">", "&gt;");
            reply = reply.replaceAll(" ", "&nbsp;");
            reply = reply.replaceAll("\r\n", "<br>");
        }

        info.setReply(reply);

        dao.update(info);

        return "/reply_success.jsp";
    }
}