ecsidefilter.java

ecside jsp前途分页的标签 实现ajax 增删改查等

/*
 * Copyright 2006-2007 original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.ecside.filter;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.URL;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.ecside.common.log.LogHandler;
import org.ecside.core.ECSideConstants;
import org.ecside.core.ECSideContext;
import org.ecside.core.Preferences;
import org.ecside.core.TableConstants;
import org.ecside.core.TableModelUtils;
import org.ecside.core.context.ContextUtils;
import org.ecside.core.context.HttpServletRequestContext;
import org.ecside.core.context.ServletInitContext;
import org.ecside.core.context.WebContext;
import org.ecside.easyda.DataAccessModel;
import org.ecside.easyda.DataExportModel;
import org.ecside.easylist.AbstractEasyListModel;
import org.ecside.easylist.EasyDataAccessHandler;
import org.ecside.preferences.PreferencesConstants;
import org.ecside.preferences.TableProperties;
import org.ecside.resource.MimeUtils;
import org.ecside.util.ECSideUtils;
import org.ecside.util.ExceptionUtils;
import org.ecside.util.RequestUtils;
import org.ecside.view.ViewResolver;



/**
 * @author Wei Zijun
 *
 */

public class ECSideFilter implements Filter {

	protected static Log logger = LogFactory.getLog(ECSideFilter.class);

	protected static String encoding = ECSideConstants.DEFAULT_ENCODING;
	protected static boolean useEncoding = true;
	protected static boolean useEasyDataAccess = true;
	protected static boolean responseHeadersSetBeforeDoFilter=true;

		
	public String servletRealPath;
	public ServletContext servletContext;
	
	protected FilterConfig filterConfig = null;
	protected EasyDataAccessHandler easyDataAccessHandler;

    public void init(FilterConfig filterConfig) throws ServletException {
		this.filterConfig = filterConfig;
    	servletContext=filterConfig.getServletContext();
    	servletRealPath=servletContext.getRealPath("/");

    	initEncoding();
    	initEasyList();
    	initProperties();

        
    	String responseHeadersSetBeforeDoFilter = filterConfig.getInitParameter("responseHeadersSetBeforeDoFilter");
        if (StringUtils.isNotBlank(responseHeadersSetBeforeDoFilter)) {
        	ECSideFilter.responseHeadersSetBeforeDoFilter = Boolean.valueOf(responseHeadersSetBeforeDoFilter).booleanValue();
        }

    }
    public void initProperties() throws ServletException {
    	WebContext context=new ServletInitContext(servletContext);
        Preferences preferences = new TableProperties();
        preferences.init(context, TableModelUtils.getPreferencesLocation(context));
        
        ECSideContext.DEFAULT_PAGE_SIZE = new Integer(preferences.getPreference(PreferencesConstants.TABLE_ROWS_DISPLAYED)).intValue();
        
    }
    public void initEasyList() throws ServletException {
    	useEasyDataAccess=true;
    	String useEasyDataAccessC = filterConfig.getInitParameter("useEasyDataAccess");
    	if ("off".equalsIgnoreCase(useEasyDataAccessC)||"false".equalsIgnoreCase(useEasyDataAccessC)
    			|| "no".equals(useEasyDataAccessC)|| "0".equals(useEasyDataAccessC) ){
    		useEasyDataAccess=false;
    	}
    	easyDataAccessHandler=new EasyDataAccessHandler();
    }
    
   
	public void initEncoding() throws ServletException {
		String encodingValue = filterConfig.getInitParameter("encoding");
		String useEncodingC = filterConfig.getInitParameter("useEncoding");
			
		if (encodingValue!=null && encodingValue.length()>0){
			encoding=encodingValue; 
		}
		if (useEncodingC == null|| useEncodingC.equalsIgnoreCase("true") 
				|| useEncodingC.equalsIgnoreCase("yes") || useEncodingC.equalsIgnoreCase("on")
				||useEncodingC.equalsIgnoreCase("1")){
			useEncoding = true;
		}else{ 
			useEncoding = false;
		}
		
		ECSideContext.ENCODING=encoding;

	}
    
	public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain chain) throws IOException, ServletException {
        
        HttpServletRequest request = (HttpServletRequest) servletRequest;
        HttpServletResponse response = (HttpServletResponse) servletResponse;

        if (RequestUtils.isAJAXRequest(request)) {
        	doAjaxFilter(request,response,chain);
	        return;
		}

        doEncoding(request, response);
        
        String easyListName=getEasyList(request);
        String easyDataAccessName=getEasyDataAccess(request);
        String easyDataExport=getEasyDataExport(request);
		
		WebContext context = new HttpServletRequestContext(request);
		boolean isExported = ExportFilterUtils.isExported(context);
		

		if (isExported) {
			doExportFilter(request,response,chain,context);
			context=null;
			return;
		}
		
		if (StringUtils.isNotBlank(easyDataExport)){
			String sqlName=getSqlName(request);
			String fileName=getExportFileName(request);
			String type=fileName.substring(fileName.indexOf('.')+1);
			try {
			 setResponseHeaders(request,response, fileName);

//				response.setBufferSize(8192);
				easyDataAccessHandler.exportList(getDataExportModelBean(request,easyDataExport), sqlName,type, request, response);
//				response.flushBuffer();
				response.getOutputStream().flush();
	            response.getOutputStream().close();
			}catch(Exception e){
				LogHandler.errorLog(logger,e);				
			}
			return;
		}
		
		if (StringUtils.isNotBlank(easyListName)){
			easyDataAccessHandler.easyList(request,response,getEasyListModelBean(request,easyListName));
		}else if (StringUtils.isNotBlank(easyDataAccessName)){
			String sqlName=getSqlName(request);
			easyDataAccessHandler.dataAccess(getDataAccessModelBean(request,easyDataAccessName), sqlName, request, response);
		}
		chain.doFilter(request, response);

    }
    
	
	public void doEncoding(ServletRequest request, ServletResponse response) throws IOException, ServletException {
		if (useEncoding || (request.getCharacterEncoding() == null)) {
			if (encoding != null)
				//Set the same character encoding for the request and the response  
				request.setCharacterEncoding(encoding);
//				response.setCharacterEncoding(encoding);
		}
	}
	
    
    public void doAjaxFilter(HttpServletRequest request,HttpServletResponse response,FilterChain chain)throws IOException, ServletException{
    	
		request.setCharacterEncoding("UTF-8");
//		response.setCharacterEncoding("UTF-8");
		
        String easyListName=getEasyList(request);
        String easyDataAccessName=getEasyDataAccess(request);

		String findAjaxZoneAtClient=request.getParameter(TableConstants.AJAX_FINDZONE_CLIENT);
		if (findAjaxZoneAtClient!=null && ("false".equalsIgnoreCase(findAjaxZoneAtClient)||"0".equals(findAjaxZoneAtClient))) {
			ECSideAjaxResponseWrapper bufferResponseWrapper = new ECSideAjaxResponseWrapper(response);
			try {

				String ectableId = request.getParameter(TableConstants.EXTREME_COMPONENTS_INSTANCE);
				if (easyListName!=null){
					easyDataAccessHandler.easyList(request,bufferResponseWrapper,getEasyListModelBean(request,easyListName));
				}else if (easyDataAccessName!=null){
					String sqlName=getSqlName(request);
					easyDataAccessHandler.dataAccess(getDataAccessModelBean(request,easyDataAccessName), sqlName, request, response);