useradminhandler.java~9~

一个自己做的公司网站和办公职员管理系统。

package ws.woa.handler;

import java.io.PrintWriter;
import java.sql.Connection;

import ws.woa.core.AbstractModuleHandler;
import ws.woa.core.ApplicationException;
import ws.woa.core.Constants;
import ws.woa.core.UserDBAccessor;
import ws.woa.core.UserInfo;
import ws.woa.core.GroupDBAccessor;
import ws.woa.core.GroupInfo;
import ws.woa.core.Request;
import ws.woa.core.Response;
import ws.woa.util.ValidatorSet;
import ws.woa.util.DefaultValidator;

/**
 * 儐乕僓娗棟婡擻偺僴儞僪儔.
 *
 * @author Wang
 */
public class UserAdminHandler extends AbstractModuleHandler {

    /**
     * @see ws.woa.core.ModuleHandler#doProcess(Request, Response)
     */
    public void doProcess(Request request, Response response) throws Exception {

        PrintWriter out = response.getWriter();
        out.println("<H2>儐乕僓娗棟</H2>");

        if(request.getParameter("INSERT_FORM")!=null){
            insertForm(request,response);
            return;
        } else if(request.getParameter("UPDATE_FORM")!=null){
            updateForm(request,response);
            return;
        } else if(request.getParameter("INSERT_EXEC")!=null){
            insertExec(request,response);
        } else if(request.getParameter("UPDATE_EXEC")!=null){
            updateExec(request,response);
        }
        listUser(request,response);
    }

    /**
     * 儐乕僓堦棗
     */
    private void listUser(Request request, Response response) throws Exception {
        Connection conn = getSystemContext().getConnection();
        try {
            UserInfo[] users = UserDBAccessor.getAllUserInfo(conn);
            request.setAttribute("users",users);
            includeJSP(Constants.JSP_USERLIST,request,response);
        } catch(Exception ex){
            throw ex;
        } finally {
            //conn.close();
            getSystemContext().releaseConnection(conn);
        }
    }

    /**
     * 捛壛僼僅乕儉
     */
    private void insertForm(Request request, Response response) throws Exception {
        UserInfo user = new UserInfo();
        request.setAttribute("user",user);

        // 僐儞儃傪昞帵偡傞偨傔偺僌儖乕僾忣曬傪庢摼
        Connection conn = getSystemContext().getConnection();
        try {
            GroupInfo[] groups = GroupDBAccessor.getAllGroupInfo(conn);
            request.setAttribute("groups",groups);
        } catch(Exception ex){
            throw ex;
        } finally {
            //conn.close();
            getSystemContext().releaseConnection(conn);
        }

        // JSP傪僀儞僋儖乕僪
        includeJSP(Constants.JSP_USERFORM,request,response);
    }

    /**
     * 峏怴僼僅乕儉
     */
    private void updateForm(Request request, Response response) throws Exception {

        ValidatorSet validator = new ValidatorSet();
        validator.add(new DefaultValidator(DefaultValidator.NUMERIC,10,true),
                      request.getParameter("UPDATE_FORM"));
        validator.doValidate();

        Connection conn = getSystemContext().getConnection();
        try {
            long userID = Long.parseLong(request.getParameter("UPDATE_FORM"));
            UserInfo user = UserDBAccessor.getUserInfo(conn,userID);
            request.setAttribute("user",user);

            GroupInfo[] groups = GroupDBAccessor.getAllGroupInfo(conn);
            request.setAttribute("groups",groups);

            includeJSP(Constants.JSP_USERFORM,request,response);
        } catch(Exception ex){
            throw ex;
        } finally {
            //conn.close();
            getSystemContext().releaseConnection(conn);
        }
    }

    /**
     * 儐乕僓搊榐/峏怴僼僅乕儉偺擖椡僠僃僢僋丅
     */
    private void inputCheck(Request request) throws ApplicationException {

        String userID   = request.getParameter("UserID");
        String account  = request.getParameter("Account");
        String groupID  = request.getParameter("GroupID");
        String password = request.getParameter("Password");
        String name     = request.getParameter("Name");
        String mail     = request.getParameter("Mail");
        String tel      = request.getParameter("Tel");
        String address  = request.getParameter("Address");
        String useFlag  = request.getParameter("UseFlag");

        // 擖椡僠僃僢僋
        ValidatorSet validator = new ValidatorSet();
        if(request.getParameter("UPDATE_EXEC")!=null){
            validator.add(new DefaultValidator(DefaultValidator.NUMERIC,10,true),userID);
        }
        validator.add(new DefaultValidator(DefaultValidator.ALPHA_NUMERIC, 20, true),account);
        validator.add(new DefaultValidator(DefaultValidator.ALPHA_NUMERIC, 20, true),password);
        validator.add(new DefaultValidator(DefaultValidator.STRING ,100, true),name);
        validator.add(new DefaultValidator(DefaultValidator.STRING ,100,false),mail);
        validator.add(new DefaultValidator(DefaultValidator.STRING , 20,false),tel);
        validator.add(new DefaultValidator(DefaultValidator.STRING ,200,false),address);
        validator.add(new DefaultValidator(DefaultValidator.NUMERIC,  1, true),useFlag);
        validator.add(new DefaultValidator(DefaultValidator.NUMERIC, 10, true),groupID);

        validator.doValidate();
    }

    /**
     * 儐乕僓捛壛幚峴
     */
    private void insertExec(Request request, Response response) throws Exception {

        // 擖椡僠僃僢僋
        inputCheck(request);

        // 僷儔儊乕僞偺庢摼
        String account  = request.getParameter("Account");
        String groupID  = request.getParameter("GroupID");
        String password = request.getParameter("Password");
        String name     = request.getParameter("Name");
        String mail     = request.getParameter("Mail");
        String tel      = request.getParameter("Tel");
        String address  = request.getParameter("Address");
        int    use      = Integer.parseInt(request.getParameter("UseFlag"));

        boolean useFlag = false;
        if(use==1){ useFlag = true; }

        // DB傊偺搊榐
        Connection conn = getSystemContext().getConnection();
        try {
            UserDBAccessor.insertUser(conn,account,password,name,groupID,mail,tel,address,useFlag);
        } catch(Exception ex){
            throw ex;
        } finally {
            //conn.close();
            getSystemContext().releaseConnection(conn);
        }
    }

    /**
     * 儐乕僓忣曬峏怴幚峴
     */
    private void updateExec(Request request, Response response) throws Exception {

        // 擖椡僠僃僢僋
        inputCheck(request);

        // 僷儔儊乕僞偺庢摼
        long   userID   = Long.parseLong(request.getParameter("UserID"));
        String account  = request.getParameter("Account");
        long   groupID  = Long.parseLong(request.getParameter("GroupID"));
        String password = request.getParameter("Password");
        String name     = request.getParameter("Name");
        String mail     = request.getParameter("Mail");
        String tel      = request.getParameter("Tel");
        String address  = request.getParameter("Address");
        int    use      = Integer.parseInt(request.getParameter("UseFlag"));

        boolean useFlag = false;
        if(use==1){ useFlag = true; }

        // DB傊偺搊榐
        Connection conn = getSystemContext().getConnection();
        try {
            UserDBAccessor.updateUser(conn,userID,account,password,name,groupID,
                                  mail,tel,address,useFlag);
        } catch(Exception ex){
            throw ex;
        } finally {
            //conn.close();
            getSystemContext().releaseConnection(conn);
        }
    }

}