inputinformaction.java

hibernate应用测试,初学hibernate 的会员可以看看.

package com.action;

import org.apache.struts.action.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.sql.SQLException;

import com.bean.InputInform;
import com.dao.InputInformDAO;
import java.util.Date;
import java.text.SimpleDateFormat;
import com.tool.pagetool.Page;
import javax.servlet.http.HttpSession;
import com.tool.QueryStrCreator;
import com.tool.pagetool.PageTool;
import com.tool.pagetool.PageToolBuilder;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2007</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class InputInformAction extends Action {
    public ActionForward execute(ActionMapping mapping,
                                 ActionForm form,
                                 HttpServletRequest request,
                                 HttpServletResponse response) throws Exception {
        request.setCharacterEncoding("gb2312");
        response.setContentType("text/html;charset=gb2312");

        InputInform inputInform=(InputInform)form;
        String flag = request.getParameter("flag");
        ActionErrors actionErrors = new ActionErrors();
        String target = null;

    if(flag.equals("forInsert")){
        try{
            InputInformDAO.startTransation();
            int lastId=InputInformDAO.getLastId();
            inputInform.setInInId(lastId+1);
            String sysDate=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); //获得系统当前时间
            inputInform.setInformDate(sysDate);
            inputInform.setInformState(0);
            inputInform.setDelFlag(0);
            InputInformDAO.insertInputInform(inputInform);
            InputInformDAO.updateInputApplyStateTo1(inputInform.getInApId()); //更改入库申报表里的对应记录状态
            InputInformDAO.commit();

            ActionError actionError = new ActionError("errors.addSuccese");
            actionErrors.add("addInputInformSuccess",actionError);
            saveErrors(request, actionErrors);
            request.setAttribute("inputInformCreated", inputInform);

            target="addSuccessed";
        }catch(SQLException e){
            e.printStackTrace();
            ActionError actionError = new ActionError("errors.generally.failed",e.getMessage());
            actionErrors.add("addInputInformFeiled", actionError);
            saveErrors(request, actionErrors);
            target = "addInputApply";
        }
    }else if(flag.equals("showNotifyDetail")){
        try {
           int inInId = Integer.parseInt(request.getParameter("inInId"));
           InputInform inputInm=InputInformDAO.selectInputInformByinInId(inInId);
           request.setAttribute("inputInformCreated", inputInm);
           request.setAttribute("fromFlag",request.getParameter("fromFlag"));
           target="addSuccessed";
       } catch (Exception e) {
           e.printStackTrace();
           ActionError actionError = new ActionError("errors.diplayInputInformFeiled");
           actionErrors.add("diplayInputInformFeiled", actionError);
           saveErrors(request, actionErrors);
           target = "listAll";
       }
    }else if(flag.equals("doCancle")){  //撤消通知
        int inInId = Integer.parseInt(request.getParameter("inInId"));
        int inIpID=Integer.parseInt(request.getParameter("inApID"));
        try{
            InputInformDAO.startTransation();
            InputInformDAO.updateInputInformCancled(inInId);
            InputInformDAO.updateInputApplyStateTo0(inIpID); //更改入库申报表里的对应记录状态
            InputInformDAO.commit();

            ActionError actionError = new ActionError("errors.deleteSuccese");
            actionErrors.add("CancledInformSuccess",actionError);
            saveErrors(request, actionErrors);

            initPage(request,"queryActive"); //初始化分页数据并放于request中
            target="listActive";
        }catch(Exception e){
            e.printStackTrace();
            ActionError actionError = new ActionError("errors.generally.failed",e.getMessage());
            actionErrors.add("CancleInputInformFeiled", actionError);
            saveErrors(request, actionErrors);
        }
    }else if(flag.equals("doActive")){  //激活通知
        int inInId = Integer.parseInt(request.getParameter("inInId"));
        int inIpID=Integer.parseInt(request.getParameter("inApID"));
        try{
            InputInformDAO.startTransation();
            InputInformDAO.updateInputInformActived(inInId);
            InputInformDAO.updateInputApplyStateTo1(inIpID); //更改入库申报表里的对应记录状态
            InputInformDAO.commit();

            ActionError actionError = new ActionError("errors.activeInputApplySuccese");
            actionErrors.add("ActivedInputInformSuccess",actionError);
            saveErrors(request, actionErrors);

            initPage(request,"queryCancle"); //初始化分页数据并放于request中
            target="listCancle";
        }catch(Exception e){
            e.printStackTrace();
            ActionError actionError = new ActionError("errors.generally.failed",e.getMessage());
            actionErrors.add("ActiveInputInformFeiled", actionError);
            saveErrors(request, actionErrors);
        }
    }else{
        initPage(request,flag);
        if(flag.equals("queryActive")){
            target="listActive";
        }else if(flag.equals("queryCancle")){
            target="listCancle";
        }else target="listAll";
       }
    return mapping.findForward(target);
    }

    //初始化并获得分页
    private Page initPage(HttpServletRequest request,String flag) {
        String currentPageStr = request.getParameter("currentPage");
        String queryStr = null;
        if(flag.equals("queryActive")){
            queryStr = QueryStrCreator.create("inputInformActive", request);
        }else if(flag.equals("queryCancle")){
            queryStr = QueryStrCreator.create("inputInformCancle", request);
        }
        int currentPage = 1; //当前页码
        int size = 20; //每页的记录数

        try { //防止从地址栏直接输入非法页码
            if (currentPageStr != null)
                currentPage = new Integer(
                        currentPageStr).intValue();
        } catch (Exception e) {
            e.printStackTrace();
        }

        //处理分页
        //会话中是否已有分页生成工具
        PageTool pageTool = null;
        HttpSession session = request.getSession();
        pageTool = (PageTool) session.getAttribute("inputInformPageTool"); //有，则直接拿来用
        if (pageTool == null) { //没有，则新建，并放进会话中，以备下次用
            pageTool = PageToolBuilder.builder(new InputInformDAO());
            session.setAttribute("inputInformPageTool", pageTool);
        }
        //由分页工具生成分页
        Page page = null;
        try {
            //String flag = request.getParameter("flag");
            if (flag.equals("queryActive") || flag.equals("queryCancle")) //查询时的分页
                page = pageTool.createPage(currentPage, size, queryStr);
            else //其它非查询的分页
                page = pageTool.createPage(currentPage, size);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        //将分页放进请求中，分发到下一个页面显示
        if(flag.equals("queryActive")){
            request.setAttribute("ActiveInputInformPage", page);
        }else if(flag.equals("queryCancle")){
            request.setAttribute("CancleInputInformPage", page);
        }else request.setAttribute("allInputInformPage", page);
        return page;
    }
}