itemaction.java~1~

一个基于Java的新闻发布系统

package com.hope.itissue.sys_info.action;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.util.HashMap;
import java.util.Date;
import java.text.SimpleDateFormat;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.validator.DynaValidatorForm;
import com.hope.common.exception.BaseException;
import com.hope.common.util.db.DBConfig;
import com.hope.common.util.MyFileUpload;
import com.hope.itissue.shared.BaseAction;
import java.util.ArrayList;
import com.hope.itissue.sys_info.bean.ItemDTO;
import com.hope.itissue.sys_info.bean.MenuDTO;
import com.hope.itissue.sys_info.dao.ItemDAO;
import com.hope.itissue.sys_info.dao.MenuDAO;
import com.hope.itissue.sys_info.dao.DAOFactory;
import com.hope.itissue.shared.Pager;

public class ItemAction extends BaseAction {
    private MyFileUpload upload = null;
    private static int PAGESIZE = 12;
    Log log = LogFactory.getLog(ItemAction.class);

    public ActionForward dolist(ActionMapping mapping, ActionForm form,
                                  HttpServletRequest request,
                                  HttpServletResponse response) throws
            BaseException {
        //判断session是否有效
        if (!this.isValid(request)) {
            this.setSysMessage(request, "error.session.invalid",
                               "btn.value.relogin", "index.do");
            return mapping.findForward("error");
        }
        //获取对数据库操作的DAO对象
        String menuid = request.getParameter("menuid");
        ItemDAO itemDAO = DAOFactory.getDAOFactory(DBConfig.
                getDataBaseName()).getItemDAO();
        String menuName = "";
        if (!menuid.equals("99999")) {
            MenuDAO menuDAO = DAOFactory.getDAOFactory(DBConfig.
                getDataBaseName()).getMenuDAO();
            MenuDTO menuDTO = menuDAO.getMenuDTO(menuid);
            menuName = menuDTO.getMenuName();
        } else {
            menuName = "顶级栏目";
        }
        /////////////////////////////////////////////
        String queryString = request.getQueryString();
        Pager page = new Pager(PAGESIZE, queryString);
        page.setTotalRecord(itemDAO.getItemNum(menuid));
        page.setTotalPage();
        String toPage = page.getQueryParameter("toPage");
        page.setCurrentPage(toPage);
        request.setAttribute("page", page);
        /////////////////////////////////////////////
        ArrayList itemList = itemDAO.getItemList(menuid, PAGESIZE, page);

        request.setAttribute("itemList", itemList);
        request.setAttribute("menuid", menuid);
        request.setAttribute("menuName", menuName);
        return mapping.findForward("list");
    }


//    public ActionForward doadd(ActionMapping mapping, ActionForm form,
//                                 HttpServletRequest request,
//                                 HttpServletResponse response) throws
//            BaseException {
//        //判断session是否有效
//        if (!this.isValid(request)) {
//            this.setSysMessage(request, "error.session.invalid",
//                               "btn.value.relogin", "index.do");
//            return mapping.findForward("error");
//        }
//        String menuid = (String)request.getParameter("menuid");
//        //接收显示层传来的数据，并将其封装进DTO中
//        String DnetName = ((DynaValidatorForm) form).getString("DnetName");
//        String DnetContent = ((String) request.getParameter("DnetContent"));
//        String DnetDate = ((String) request.getParameter("DnetDate"));
//        String DnetImage = ((String) request.getParameter("DnetImage"));
//        String IsUse = ((String) request.getParameter("IsUse"));
//
//        ItemDAO itemDAO = (ItemDAO) DAOFactory.getDAOFactory(
//                DBConfig.getDataBaseName()).getItemDAO();
//
//        ItemDTO itemDTO = new ItemDTO();
//        itemDTO.setParentID(menuid);
//        itemDTO.setDnetName(DnetName);
//        itemDTO.setDnetContent(DnetContent);
//        itemDTO.setDnetDate(DnetDate);
//        itemDTO.setDnetImage(DnetImage);
//        itemDTO.setIsUse(IsUse);
//
//        //获取对数据库操作的DAO对象
//        itemDAO.addItem(itemDTO);
//
//        //转向竣工资料模板列表页面
//        try {
//            response.sendRedirect("ItemAction.do?act=dolist&menuid="+menuid);
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//        return null;
//    }

    public ActionForward doadd(ActionMapping mapping, ActionForm form,
                                   HttpServletRequest request,
                                   HttpServletResponse response) throws
            BaseException {
        //判断session是否有效
        if (!this.isValid(request)) {
            this.setSysMessage(request, "error.session.invalid",
                               "btn.value.relogin", "index.do");
            return mapping.findForward("error");
        }
        String fileName = "";
        String saveName = "";
        HashMap forms = null;
        long fileMaxSize = 5 * 1024 * 1024;
        String saveDir = request.getSession().getServletContext().getRealPath(
                "/") + "files\\upload\\";
        String tmpDir = request.getSession().getServletContext().getRealPath(
                "/") + "files\\tmp\\";
        try {
            upload = new MyFileUpload(request, response, fileMaxSize,
                                      saveDir, tmpDir);
            upload.upload();
        } catch (org.apache.commons.fileupload.FileUploadBase.
                 SizeLimitExceededException e) {
            upload = null;
            log.error("error.UploadFile.SizeLimit", e);
            throw new BaseException("error.UploadFile.SizeLimit");
        } catch (org.apache.commons.fileupload.FileUploadException e) {
            upload = null;
            log.error("error.UploadFile.UploadFailure", e);
            throw new BaseException(
                    "error.UploadFile.UploadFailure");
        } catch (Exception e) {
            log.error("error.UploadFile.UploadFailure", e);
            throw new BaseException(
                    "error.UploadFile.UploadFailure");
        }

        if (upload != null) {
            forms = upload.getForms();
            fileName = (String) upload.getFileName().get(0);
            saveName = (String) upload.getFileSaveName().get(0);
            if (saveName.equalsIgnoreCase("no_match")) {
                log.error("error.UploadFile.NoMatch");
                throw new BaseException("error.UploadFile.NoMatch");
            }
        }
        String menuid = (String) forms.get("menuid");
        //接收显示层传来的数据，并将其封装进DTO中
        ItemDAO itemDAO = (ItemDAO) DAOFactory.getDAOFactory(
                DBConfig.getDataBaseName()).getItemDAO();

        ItemDTO itemDTO = new ItemDTO();
        itemDTO.setParentID(menuid);
        itemDTO.setDnetName((String) forms.get("DnetName"));
        itemDTO.setDnetContent((String) forms.get("DnetContent"));

        itemDTO.setIsUse("1");//添加文章时，默认为是可用的。

        Date date = new Date();
        SimpleDateFormat df = new SimpleDateFormat();
        df.applyPattern("yyyy-MM-dd HH:mm:ss");
        itemDTO.setDnetDate(df.format(date));

        String Slave = "";
        itemDTO.setDnetImage(Slave);
        if ((fileName != null && fileName.length() != 0) &&
            (saveName != null && !saveName.equalsIgnoreCase("no_file") &&
             !saveName.equalsIgnoreCase("no_match"))) {
            Slave = fileName + ":" + saveName;
            itemDTO.setDnetImage(Slave);
        }

        itemDAO.addItem(itemDTO);
        try {
            response.sendRedirect("ItemAction.do?act=dolist&menuid="+menuid);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;

    }

    public ActionForward doedit(ActionMapping mapping, ActionForm form,
                                    HttpServletRequest request,
                                    HttpServletResponse response) throws
            BaseException {
        //判断session是否有效
        if (!this.isValid(request)) {
            this.setSysMessage(request, "error.session.invalid",
                               "btn.value.relogin", "index.do");
            return mapping.findForward("error");
        }

        String fileName = "";
        String saveName = "";
        HashMap forms = null;
        long fileMaxSize = 5 * 1024 * 1024;
        String saveDir = request.getSession().getServletContext().getRealPath(
                "/") + "files\\upload\\";
        String tmpDir = request.getSession().getServletContext().getRealPath(
                "/") + "files\\tmp\\";
        try {
            upload = new MyFileUpload(request, response, fileMaxSize,
                                      saveDir, tmpDir);
            upload.upload();
        } catch (org.apache.commons.fileupload.FileUploadBase.
                 SizeLimitExceededException e) {
            upload = null;
            log.error("error.UploadFile.SizeLimit", e);
            throw new BaseException("error.UploadFile.SizeLimit");
        } catch (org.apache.commons.fileupload.FileUploadException e) {
            upload = null;
            log.error("error.UploadFile.UploadFailure", e);
            throw new BaseException(
                    "error.UploadFile.UploadFailure");
        } catch (Exception e) {
            log.error("error.UploadFile.UploadFailure", e);
            throw new BaseException(
                    "error.UploadFile.UploadFailure");
        }
        if (upload != null) {