tjpcms国产java类cms.zip

package com.tjpcms.common; import java.io.File; import java.io.IOException; import java.io.PrintWriter; import java.lang.reflect.Method; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.regex.Pattern; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import net.sf.json.JSONObject; import org.apache.commons.beanutils.ConvertUtils; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.ArrayUtils; import org.apache.commons.lang.StringUtils; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.servlet.ModelAndView; import com.tjpcms.common.Crud.Crud; import com.tjpcms.common.Crud.Retrieve; import com.tjpcms.spring.mapper.EntMapper; public class Hanshu { public static void flushResponse(HttpServletResponse response, Object responseContent) { response.setCharacterEncoding("UTF-8"); response.setContentType("text/html; charset=UTF-8"); PrintWriter writer = null; try { writer = response.getWriter(); writer.write(ConvertUtils.convert(responseContent)); } catch (IOException e) { } finally { writer.flush(); writer.close(); } } public static void setGlobal(Map<String,Object> m) { m.put("WZMC", CL.WZMC); m.put("GGY", CL.GGY); m.put("GGY2", CL.GGY2); m.put("YUMING", CL.YUMING); } public static void ajaxupload(MultipartFile file, HttpServletRequest request, HttpServletResponse response, EntMapper entMapper) throws IllegalStateException, IOException{ Map<String, Object> m = new HashMap<String, Object>(); if (file==null){ m.put("ret","请先选择文件！"); Hanshu.flushResponse(response, JSONObject.fromObject(m)); return; } String oriName= file.getOriginalFilename(); String prefix=oriName.substring(oriName.lastIndexOf("."));//如 .png if (!".jpg".equalsIgnoreCase(prefix) && !".png".equalsIgnoreCase(prefix) && !".gif".equalsIgnoreCase(prefix) && !".jpeg".equalsIgnoreCase(prefix)){ m.put("ret","请选择jpg、jpeg、png或gif格式！"); Hanshu.flushResponse(response, JSONObject.fromObject(m)); return; } String path = request.getServletContext().getRealPath("")+"\\upload\\pic\\"; File mulu = new File(path); if (!mulu.exists()){ mulu.mkdirs(); } Date date = new Date(); SimpleDateFormat fmt = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String uid = UUID.randomUUID().toString(); String picSrc = fmt.format(date).substring(0,14)+uid.substring(3, 6)+fmt.format(date).substring(14,17)+uid.substring(9, 12)+uid.substring(19, 23)+prefix; File bcFile = new File(path+picSrc); file.transferTo(bcFile); m.put("ret","0"); m.put("src",picSrc); Hanshu.flushResponse(response, JSONObject.fromObject(m)); } public static void delete(HttpServletRequest request, HttpServletResponse response, EntMapper entMapper){ Crud o = (Crud)request.getSession(false).getAttribute(request.getParameter("u")); if (o==null){ Hanshu.flushResponse(response, "-1"); return; } String ids = request.getParameter("ids"); if (StringUtils.isEmpty(ids)){ Hanshu.flushResponse(response, "-1"); return; } String arr[] = ids.split(","); if (arr == null || arr.length<=0){ Hanshu.flushResponse(response, "-1"); return; } //删除前钩子 if (StringUtils.isNotEmpty(o.getD().getHook_befdel())) { Object ret = execHook(o.getD().getHook_befdel(), request, o); if (ret==null || !"0".equals(ret.toString())){ flushResponse(response,ret.toString()); return; } } String batdel = StringUtils.isNotEmpty(o.getD().getZdysql()) ? Hanshu.zdydel(o, arr) : Hanshu.batdel(o.getMp(), o.getTb(), arr); if (!"0".equals(batdel)){ flushResponse(response,batdel); return; } //删除后钩子 if (StringUtils.isNotEmpty(o.getD().getHook_aftdel())) { Object ret = execHook(o.getD().getHook_aftdel(), request, o);//如果有更新前钩子，执行一下 if (ret==null || !"0".equals(ret.toString())){ flushResponse(response,"-1"); return; } } request.getSession().setAttribute("listtipmsg", "删除成功！"); Hanshu.flushResponse(response, "0"); } public static void unique(HttpServletRequest request, HttpServletResponse response, EntMapper entMapper){ Map<String, Object> map = new HashMap<String, Object>(); map.put("getdata", "false"); Crud o = (Crud)request.getSession(false).getAttribute(request.getParameter("u")); String id = request.getParameter("id"); String lx = request.getParameter("lx"); String val = request.getParameter("val"); String zdm = request.getParameter("zdm"); if (o==null ||StringUtils.isEmpty(val)||StringUtils.isEmpty(zdm) || !("0".equals(lx) || "1".equals(lx)) || ("1".equals(lx) && StringUtils.isEmpty(id))){ Hanshu.flushResponse(response, JSONObject.fromObject(map)); return; } String ex = ""; String filter = request.getParameter("___extfilter"); if (StringUtils.isNotEmpty(filter)) { ex += " and "+filter+" "; } ex += " and ("+zdm+" = '"+val+"') "; if ("1".equals(lx)) {//编辑 ex += " and (id!='"+id+"') "; } map.put("getdata", String.valueOf(Hanshu.cnt(o.getMp(), o.getTb(), ex)<=0)); flushResponse(response, JSONObject.fromObject(map)); } private static Object execHook(String hook, HttpServletRequest request, Crud o){ if (StringUtils.isNotEmpty(hook) && request!=null && o!=null){ int dtIndx = hook.lastIndexOf("."); if (dtIndx != -1) { String clsnm = hook.substring(0, dtIndx); String metd = hook.substring(dtIndx+1, hook.length()); if (StringUtils.isNotEmpty(clsnm) && StringUtils.isNotEmpty(metd)) { try{ Class<?> classT = Class.forName(clsnm);//获取对应类 Method methodT = classT.getMethod(metd, Object.class, Object.class, Object.class); Object obj = classT.newInstance();//创建类对象 return methodT.invoke(obj, (Object)request, (Object)o, (Object)null); }catch(Exception e){ e.printStackTrace(); return null; } } } } return null; } //栏目那边通用的新增保存功能 public static void addedit(HttpServletRequest request, HttpServletResponse response, EntMapper entMapper){ Crud o = (Crud)request.getSession(false).getAttribute(request.getParameter("u")); if (o==null){ flushResponse(response,"-1"); return; } String id = request.getParameter("id"); if (StringUtils.isNotEmpty(id) && StringUtils.isNotEmpty(o.getAev().getHook_befgx())) { Object ret = execHook(o.getAev().getHook_befgx(), request, o);//如果有更新前钩子，执行一下 if (ret==null || !"0".equals(ret.toString())){ flushResponse(response,"-1"); return; } } String addedit = addedit(o.getMp(),o.getTb(),request, o.getLsttbZd()); if (!"0".equals(addedit)){ flushResponse(response,addedit); return; } if (StringUtils.isNotEmpty(id) && StringUtils.isNotEmpty(o.getAev().getHook_aftgx())) { Object ret = execHook(o.getAev().getHook_aftgx(), request, o);//如果有更新后钩子，执行一下 if (ret==null || !"0".equals(ret.toString())){ flushResponse(response,"-1"); return; } } flushResponse(response,"0"); } public static ModelAndView aev(HttpServletRequest request, EntMapper entMapper){ String t = request.getParameter("t"); String id = request.getParameter("id"); Crud o = (Crud)request.getSession(false).getAttribute(request.getParameter("u")); if ((!"0".equals(t) && !"1".equals(t) && !"2".equals(t)) || o==null || (!"0".equals(t) && StringUtils.isEmpty