BaseAction 和继承类的应用
import java.io.IOException;import java.io.PrintWriter;import java.lang.reflect.Method;import java.util.List;import java.util.Map;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import org.apache.commons.lang.StringUtils;import org.apache.struts2.interceptor.ServletRequestAware;import org.apache.struts2.interceptor.ServletResponseAware;import org.apache.struts2.interceptor.SessionAware;import org.displaytag.tags.TableTagParameters;import org.displaytag.util.ParamEncoder;import com.autocreate.service.BaseService;import com.autocreate.util.JBeanClass;import com.autocreate.util.Log;import com.opensymphony.xwork2.ActionSupport;/** * BaseAction * @author Administrator */public abstract class BaseAction extends ActionSupport implements ServletRequestAware, ServletResponseAware, SessionAware{private static final long serialVersionUID = -2252914695328460450L;/** * 添加失败 */public static final String ADDFAILED = "addfailed";/** * 添加成功 */public static final String ADDSUCCESS = "addsuccess";/** * 每页列表，即每页显示的记录数 */@SuppressWarnings("unchecked")private List list;/** * 当前页码，即当前第几页 */private int pageNumber = 1;/** * 每页记录数，即一页显示多少条 */private int pageSize = 20;/** * 总记录数 */private int fullListSize = 0;/** * 页面传递删除的记录集合 */private String[] serial;/** * 响应URL */private String url;/** * 响应内容 */private String msg;/** * HttpSession */@SuppressWarnings("unchecked")public Map session;/** * HttpServletRequest */public HttpServletRequest request;/** * HttpServletResponse */public HttpServletResponse response;/** * 跳转到添加页面 * @return */public String add(){return SUCCESS;}/** * 查询 * @return */public abstract String find();/** * 查询集合 * @return */public abstract String list();/** * 添加 * @return */public abstract String insert() throws Exception;/** * 修改 * @return */public abstract String modify() throws Exception;/** * 删除 * @return */public abstract String delete() throws Exception;/** * 根据对象和页面删传递过来的删除数组，反射删除数据库 * @param serial * @param entityClass * @return * @throws Exception */@SuppressWarnings("unchecked")protected boolean deleteByStrings(Class entityClass) throws Exception{if (null != serial && serial.length > 0){BaseService baseService = new BaseService();Object obj = entityClass.newInstance(); // 创建实例Method method = entityClass.getMethod("getTablePrimaryKey"); // 执行指定方法String primaryKey = method.invoke(obj).toString();for (String str : serial){obj = JBeanClass.setPropertyValueFromString(obj, primaryKey, str);baseService.delete(obj);}}return false;}/** * 查询一页数据 * @param clazz * @param tableName * @param map * @throws Exception */@SuppressWarnings("unchecked")protected void queryPageList(String tableName, Class serviceClass, Class entityClass, Map<String, String> map){try{String pageIndexName = new ParamEncoder("element").encodeParameterName(TableTagParameters.PARAMETER_PAGE); // 页数的参数名String value = request.getParameter(pageIndexName);pageNumber = StringUtils.isEmpty(value) ? 1 : Integer.parseInt(value); // 当前页数Class classType = serviceClass;Object obj = serviceClass.newInstance(); // 创建实例Method method = classType.getMethod("getCount", new Class[] { String.class, Map.class }); // 执行指定方法fullListSize = Integer.parseInt(method.invoke(obj, new Object[] { tableName, map }).toString());Method method2 = classType.getMethod("queryPageList", new Class[] { String.class, Class.class, Map.class, int.class, int.class }); // 执行指定方法list = (List) method2.invoke(obj, new Object[] { tableName, entityClass, map, pageNumber, pageSize });}catch (Exception e){Log.getLogger().error("queryPageList error...", e);}}/** * 输入HTML响应内容用于AJAX * @param value 要写的值 */public void writerHtml(String value){writer(value, 1);}/** * 输入XML响应内容用于AJAX * @param value 要写的值 */public void writerXml(String value){writer(value, 2);}/** * 输入响应内容用于AJAX * @param value * @param type */private void writer(String value, int type){PrintWriter out = null;try{out = response.getWriter();response.setCharacterEncoding("UTF-8");switch (type){case 1:response.setContentType("text/html;charset=UTF-8");break;case 2:response.setContentType("text/xml;charset=UTF-8");break;}out.write(value);out.flush();}catch (IOException e){Log.getLogger().error("Out Writer Error...", e);}finally{out.close();}}public String getUrl(){return url;}public void setUrl(String url){this.url = url;}public String getMsg(){return msg;}public void setMsg(String msg){this.msg = msg;}@SuppressWarnings("unchecked")public void setSession(Map session){this.session = session;}public void setServletRequest(HttpServletRequest request){this.request = request;}public void setServletResponse(HttpServletResponse response){this.response = response;}@SuppressWarnings("unchecked")public List getList(){return list;}@SuppressWarnings("unchecked")public void setList(List list){this.list = list;}public int getPageNumber(){return pageNumber;}public void setPageNumber(int pageNumber){this.pageNumber = pageNumber;}public int getPageSize(){return pageSize;}public void setPageSize(int pageSize){this.pageSize = pageSize;}public int getFullListSize(){return fullListSize;}public void setFullListSize(int fullListSize){this.fullListSize = fullListSize;}public String[] getSerial(){return serial;}public void setSerial(String[] serial){this.serial = serial;}}import java.util.HashMap;import java.util.Map;import com.auto.entity.Roleinfo;import com.auto.service.BaseService;public class RoleinfoAction extends BaseAction{private static final long serialVersionUID = -128991403689032079L;private Roleinfo info;public String find(){if(null != info){info = new BaseService<Roleinfo>().query(info);}return SUCCESS;}@SuppressWarnings("unchecked")public String list(){ Map map = null; if (null != info) { map = new HashMap(); map.put("Operatorid", info.getOperatorid()); }queryPageList("Roleinfo", BaseService.class, Roleinfo.class, map);return SUCCESS;}public String insert() throws Exception{try { return new BaseService<Roleinfo>().insert(info) ? ADDSUCCESS : ADDFAILED; } catch (Exception e) { throw e; }}public String modify() throws Exception{ try { if (null != info) { new BaseService<Roleinfo>().update(info); } return ADDSUCCESS; } catch (Exception e) { throw e; }}public String delete() throws Exception { try { deleteByStrings(Roleinfo.class); return ADDSUCCESS;} catch (Exception e) { throw e; } }public Roleinfo getInfo() { return info; } public void setInfo(Roleinfo info) { this.info = info; }}
页:
[1]