queryaction.java

基于SSH (struts+spring+hibernate)框架设计的 CRM客户关系管理系统

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package com.csu.crm.common.action;

import java.io.IOException;
import java.util.Iterator;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;

import com.csu.crm.common.dao.SingleObjectDAO;
import com.csu.crm.common.page.PageinationVO;
import com.csu.crm.common.vo.CrmAction;
import com.csu.crm.util.QueryUtil;

/**
 * 查询表单记录(分页查询)
 * 必须传入参数: target---目标持久化类名
 * 
 * 查询表单记录的流程
 * 0、 判断传入参数是否符合要求（是否有传入参数，及是否在数据库中存在）
 * 例:
 *	http://localhost:7076/3eCRM-SSH/query.do?target=CrmCustomer
 *
 * @author 3eCRM小组：曾东
 * @since 2007-9-30 下午04:06:33
 * @version 1.0 创建时间：2007-9-30 下午04:06:33,初始版本
 */
public class QueryAction extends Action {
	private QueryUtil queryUtil;	
	private SingleObjectDAO singleObjectDAO;
	public SingleObjectDAO getSingleObjectDAO() {
		return singleObjectDAO;
	}
	public void setSingleObjectDAO(SingleObjectDAO singleObjectDAO) {
		this.singleObjectDAO = singleObjectDAO;
	}
	public QueryUtil getQueryUtil() {
		return queryUtil;
	}
	public void setQueryUtil(QueryUtil queryUtil) {
		this.queryUtil = queryUtil;
	}


	/** 
	 * Method execute
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 */
	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) {
		/**
		 *  ######### 目标持久化类名 -- 主键名 --  session中保存选中对象的属性名 --- 调用的页面路径
		 */		
		//0
		//得到request参数
		String target = request.getParameter("target");
		
		//得到分页信息
		String currPage=(String)request.getParameter("currPage");
		String pageSize=(String)request.getParameter("pageSize");
		PageinationVO pageinationVO=new PageinationVO();		
		try{
			if(currPage!=null) Integer.parseInt(currPage);
			if(pageSize!=null)Integer.parseInt(pageSize);
		}catch(NumberFormatException e){
			System.out.println("传入的分页参数并不是整数,将进入错误页面");
			request.setAttribute("errorInfo", "传入的分页参数并不是整数,不能进行对应信息的查询操作");
			return mapping.findForward("fail");
		}
		
		if(currPage==null||Integer.parseInt(currPage)==0){
			currPage="1";
		}
		if(pageSize==null||Integer.parseInt(pageSize)==0){
			//默认每页页数
			pageSize="5";
		}
		
		pageinationVO.setNPageNo(Integer.parseInt(currPage));
		pageinationVO.setNPageRows(Integer.parseInt(pageSize));

		if(target == null) {
			System.out.println("未指出target,将进入错误页面");
			request.setAttribute("errorInfo", "必须传入参数: target---目标持久化类名 ,不能进行对应信息的查询操作");
			return mapping.findForward("fail");
		}	
		//到Action操作表中找到对应的一些String参数
		CrmAction crmAction = (CrmAction)singleObjectDAO.getObject("CrmAction", "className", target);		
		String path = crmAction.getQueryPath();		
		
		
		if(crmAction == null) {
			System.out.println("target输入错误");
			request.setAttribute("errorInfo", "传入参数错误: target---目标持久化类名,不能进行对应信息的查询操作");
			return mapping.findForward("fail");
		}
		
		//得到查询条件		
		Object strO = request.getAttribute("queryString");
		Object obj = request.getAttribute("queryObject");				
	
		//进入queryUtil进行分页查询		
		pageinationVO = queryUtil.query(target,obj,strO,pageinationVO);		
		
		List list = pageinationVO.getLs();
		System.out.println(list.size());
		Iterator iter =  list.iterator();
		while(iter.hasNext()) {
			System.out.println(iter.next());
		}
		request.setAttribute("pageinationVO", pageinationVO);	
		try {
			request.getRequestDispatcher(path).forward(request, response);
		} catch (ServletException e) {			
			e.printStackTrace();
		} catch (IOException e) {			
			e.printStackTrace();
		}
		return null;
	}
}