queryaction.java

数学网

package math.users.query.controller;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

import math.users.query.dao.QueryDao;
import math.users.query.model.Query;
import math.users.query.model.QueryList;
import math.util.Pager;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionError;
import org.apache.struts.action.ActionErrors;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;


public class QueryAction extends Action {
  private DataSource ds=null;
  private Log __log=LogFactory.getFactory().
  getInstance(this.getClass());
  public ActionForward execute(ActionMapping actionMapping,
	       ActionForm actionForm,
	       HttpServletRequest httpServletRequest,
	       HttpServletResponse httpServletResponse) throws Exception {
	  ds=getDataSource(httpServletRequest);
	ActionForward myForward=null;
	String myaction=actionMapping.getParameter();
	if (isCancelled(httpServletRequest)) {
	      if (__log.isInfoEnabled()) {
		__log.info(" [Logon] " + actionMapping.getAttribute() +
			   " - action was cancelled");
	      }
	      return actionMapping.findForward("cancel");
	    }

	    if (__log.isInfoEnabled()) {
	      __log.info(" [Logon] action: " + myaction);
	    }
	 if("".equalsIgnoreCase(myaction))
		 myForward=actionMapping.findForward("failure");
	
	 else if("LIST".equalsIgnoreCase(myaction))
	 {myForward=performList(actionMapping,
		     actionForm,
		     httpServletRequest,
		     httpServletResponse);
	}
	 else if("DEL".equalsIgnoreCase(myaction))
	 {  myForward=performDel(actionMapping,
		     actionForm,
		     httpServletRequest,
		     httpServletResponse);
	}	
	 else if("SEL".equalsIgnoreCase(myaction))
	 {  myForward=performSel(actionMapping,
		     actionForm,
		     httpServletRequest,
		     httpServletResponse);
	}	
	 else if("UPDATE".equalsIgnoreCase(myaction))
	 {  myForward=performUpdate(actionMapping,
		     actionForm,
		     httpServletRequest,
		     httpServletResponse);
	}	
	 else if("FIND".equalsIgnoreCase(myaction))
	 {  myForward=performFind(actionMapping,
		     actionForm,
		     httpServletRequest,
		     httpServletResponse);
	}	
	 return myForward;
    }
	private ActionForward performFind(ActionMapping mapping,
		     ActionForm actionForm,
		     HttpServletRequest request,
		     HttpServletResponse response){
		try {
			QueryDao queryDao=new QueryDao(ds);
			QueryForm queryForm=(QueryForm)actionForm;
			String username=queryForm.getUsername();
		    int grade=queryForm.getUsers_grade();
			int offset;
		     int length = 3;
		     String pageOffset = request.getParameter("pager.offset");
		     if (pageOffset == null || pageOffset.equals("")) {
		         offset = 0;
		     } else {
		         offset = Integer.parseInt(pageOffset);
		     }
		     List findlist = queryDao.find(grade,username,offset,length);
		     String sql="";
		     if(grade==0)
		    	 sql="where users_grade>10 and users_grade<999";
		     else sql="where users_grade="+grade;
		     if(username==null||username.trim().length()==0)
		     {}
		     else{ sql=sql+" and username like '%"+username+"%'";}
		     int size = queryDao.getSize("users",sql);
		     String url = request.getContextPath() + mapping.getPath() + ".do";
		     String pagerHeader = Pager.generate(offset, size, length, url);
		     request.setAttribute("pagerHeader", pagerHeader);
		     request.setAttribute("LIST", findlist);

		     return mapping.findForward("success");
		 } catch (Exception e) {
		     generalError(request, e);
		     return mapping.findForward("failure");
		 }

	}
  private ActionForward performUpdate(ActionMapping mapping,
		     ActionForm actionForm,
		     HttpServletRequest request,
		     HttpServletResponse response){
		try {
			QueryDao queryDao=new QueryDao(ds);
			QueryForm qf= (QueryForm)actionForm;
			Query  ql=new Query();
			ql.setId(qf.getId());
			ql.setUsername(qf.getUsername());
			ql.setReal_name(qf.getReal_name());
			ql.setUsers_date(qf.getUsers_date());
			ql.setUsers_grade(qf.getUsers_grade());
			//BeanUtils.populate(ql,BeanUtils.describe(qf));
			queryDao.update(ql);
		     return mapping.findForward("success");
		 } catch (Exception e) {
		     generalError(request, e);
		     return mapping.findForward("failure");
		 }

	}
  private ActionForward performSel(ActionMapping mapping,
		     ActionForm actionForm,
		     HttpServletRequest request,
		     HttpServletResponse response){
		try {
			QueryDao queryDao=new QueryDao(ds);
			String id=request.getParameter("id");
			Query ql=queryDao.sel(id);
			QueryForm qf= new QueryForm();
              qf.setId(ql.getId());
              qf.setUsername(ql.getUsername());
              qf.setReal_name(ql.getReal_name());
              qf.setUsers_date(ql.getUsers_date());
              qf.setUsers_grade(ql.getUsers_grade());
			//BeanUtils.populate(ru, BeanUtils.describe(rf));
			//BeanUtils.populate(ql,BeanUtils.describe(qf));
            request.setAttribute("QueryForm",qf);
		     return mapping.findForward("success");
		 } catch (Exception e) {
		     generalError(request, e);
		     return mapping.findForward("failure");
		 }

	}
  private ActionForward performDel(ActionMapping mapping,
		     ActionForm actionForm,
		     HttpServletRequest request,
		     HttpServletResponse response){
		try {
			QueryDao queryDao=new QueryDao(ds);
			String id=request.getParameter("id");
			queryDao.del(id);

		     return mapping.findForward("success");
		 } catch (Exception e) {
		     generalError(request, e);
		     return mapping.findForward("failure");
		 }

	}
	private ActionForward performList(ActionMapping mapping,
		     ActionForm actionForm,
		     HttpServletRequest request,
		     HttpServletResponse response){
		try {
			QueryDao queryDao=new QueryDao(ds);
			
		     int offset;
		     int length = 3;
		     String pageOffset = request.getParameter("pager.offset");
		     if (pageOffset == null || pageOffset.equals("")) {
		         offset = 0;
		     } else {
		         offset = Integer.parseInt(pageOffset);
		     }
		     List userlist = queryDao.userlist(offset,length);
		     int size = queryDao.getSize("users","where users_grade>10 and users_grade<999");
		     String url = request.getContextPath() + mapping.getPath() + ".do";
		     String pagerHeader = Pager.generate(offset, size, length, url);
		     request.setAttribute("pagerHeader", pagerHeader);
		     request.setAttribute("LIST", userlist);

		     return mapping.findForward("success");
		 } catch (Exception e) {
		     generalError(request, e);
		     return mapping.findForward("failure");
		 }

	}
	private void sqlNullError(HttpServletRequest request, String objName) {
	    ActionErrors errors = new ActionErrors();
	    errors.add("user", new ActionError("error.user.null"));
	    saveErrors(request, errors);
	    if (__log.isErrorEnabled()) {
	      __log.error(" [User] has not found - " + objName);
	      }
	    }
	private void generalError(HttpServletRequest request, Exception e) {
	        ActionErrors aes = new ActionErrors();
	        aes.add(aes.GLOBAL_ERROR, new ActionError("error.general", e.getMessage()));
	        saveErrors(request, aes);
	        e.printStackTrace();
	        if (__log.isErrorEnabled()) {
	          __log.error(" [User] Error - " + e.getMessage());
	        }
	      }
}