每页 " + +// "10" + +// "25" + +// "50" + +// "100" + +// " 条记录，显示 " +startIndex+ " 到 "+ endIndex +" 条，共 "+count+" 条
+ * 如mysql + * dialect.getLimitString("select * from user", 12, ":offset",0,":limit") 将返回 + * select * from user limit :offset,:limit + *
dialectClass
sqlPattern
+ * 自定义Mybatis的配置，扩展. + *
+ * 执行代理类，扩展Mybatis的方式来让其Mapper接口来支持. + *
+ * . + *
null
+ * 文件大小工具类. + *
+ * [0] - 台湾、澳门、香港 [1] - 性别(男M,女F,未知N) [2] - 是否合法(合法true,不合法false) + * 若不是身份证件号码则返回null + *
+ * 身份证前2位为英文字符，如果只出现一个英文字符则表示第一位是空格，对应数字58 前2位英文字符A-Z分别对应数字10-35 + * 最后一位校验码为0-9的数字加上字符"A"，"A"代表10 + *
+ * 将身份证号码全部转换为数字，分别对应乘9-1相加的总和，整除11则证件号码有效 + *
Title:
Description:
+ * 有序的properties的工具类，由于JDK自身的写会乱序，所以采用这个工具类来保证读写次序正常. + *
+ * $Id: PropertiesLoader.java 1690 2012-02-22 13:42:00Z calvinxiu $ + */ +package com.jeespring.common.utils; + +import java.io.IOException; +import java.io.InputStreamReader; +import java.util.HashMap; +import java.util.Map; +import java.util.NoSuchElementException; +import java.util.Properties; + +import org.apache.commons.io.IOUtils; +import org.springframework.core.io.DefaultResourceLoader; +import org.springframework.core.io.Resource; +import org.springframework.core.io.ResourceLoader; +import org.yaml.snakeyaml.Yaml; + +/** + * Properties文件载入工具类. 可载入多个properties文件, 相同的属性在最后载入的文件中的值将会覆盖之前的值，但以System的Property优先. + * + * @author calvin + * @version 2013-05-15 + */ +@SuppressWarnings("rawtypes") +public class PropertiesLoader { + + private static ResourceLoader resourceLoader = new DefaultResourceLoader(); + + private final Properties properties; + + public PropertiesLoader(String... resourcesPaths) { + properties = loadProperties(resourcesPaths); + } + + public Properties getProperties() { + return properties; + } + + /** + * 取出Property，但以System的Property优先,取不到返回空字符串. + */ + private String getValue(String key) { + String systemProperty = System.getProperty(key); + if (systemProperty != null) { + return systemProperty; + } + if (properties.containsKey(key)) { + return properties.getProperty(key); + } + return ""; + } + + /** + * 取出String类型的Property，但以System的Property优先,如果都为Null则抛出异常. + */ + public String getProperty(String key) { + String value = getValue(key); + if (value == null) { + throw new NoSuchElementException(); + } + return value; + } + + /** + * 取出String类型的Property，但以System的Property优先.如果都为Null则返回Default值. + */ + public String getProperty(String key, String defaultValue) { + String value = getValue(key); + return value != null ? value : defaultValue; + } + + /** + * 取出Integer类型的Property，但以System的Property优先.如果都为Null或内容错误则抛出异常. + */ + public Integer getInteger(String key) { + String value = getValue(key); + if (value == null) { + throw new NoSuchElementException(); + } + return Integer.valueOf(value); + } + + /** + * 取出Integer类型的Property，但以System的Property优先.如果都为Null则返回Default值，如果内容错误则抛出异常 + */ + public Integer getInteger(String key, Integer defaultValue) { + String value = getValue(key); + return value != null ? Integer.valueOf(value) : defaultValue; + } + + /** + * 取出Double类型的Property，但以System的Property优先.如果都为Null或内容错误则抛出异常. + */ + public Double getDouble(String key) { + String value = getValue(key); + if (value == null) { + throw new NoSuchElementException(); + } + return Double.valueOf(value); + } + + /** + * 取出Double类型的Property，但以System的Property优先.如果都为Null则返回Default值，如果内容错误则抛出异常 + */ + public Double getDouble(String key, Integer defaultValue) { + String value = getValue(key); + return value != null ? Double.valueOf(value) : defaultValue; + } + + /** + * 取出Boolean类型的Property，但以System的Property优先.如果都为Null抛出异常,如果内容不是true/false则返回false. + */ + public Boolean getBoolean(String key) { + String value = getValue(key); + if (value == null) { + throw new NoSuchElementException(); + } + return Boolean.valueOf(value); + } + + /** + * 取出Boolean类型的Property，但以System的Property优先.如果都为Null则返回Default值,如果内容不为true/false则返回false. + */ + public Boolean getBoolean(String key, boolean defaultValue) { + String value = getValue(key); + return value != null ? Boolean.valueOf(value) : defaultValue; + } + + /** + * 载入多个文件, 文件路径使用Spring Resource格式. + */ + private Properties loadProperties(String... resourcesPaths) { + Properties props = new Properties(); + + for (String location : resourcesPaths) { + if (location.endsWith(".properties")) { + InputStreamReader reader = null; + try { + Resource resource = resourceLoader.getResource(location); + reader = new InputStreamReader(resource.getInputStream(), "utf-8"); + props.load(reader); + } catch (IOException ex) { + ex.printStackTrace(System.out); + } finally { + IOUtils.closeQuietly(reader); + } + } else if (location.endsWith(".yml")) { + try { + Resource resource = resourceLoader.getResource(location); + Yaml yaml = new Yaml(); + Map map = yaml.loadAs(resource.getInputStream(), Map.class); + map = resolv(map); + for (Object key : map.keySet()) { + props.put(key, map.get(key)); + } + } catch (Exception e) { + //e.printStackTrace(System.out); + } + } + } + return props; + } + + /** + * 递归解析map + * + * @param map yml初次解析的map + * @return 解析后的map + */ + private static Map resolv(Map map) { + Map values = new HashMap<>(); + for (Object obj : map.keySet()) { + String currentkey = obj.toString(); + Object currentObj = map.get(obj); + if (currentObj instanceof Map) { + Map currentMap = resolv((Map) currentObj); + for (Object key : currentMap.keySet()) { + String mapKey = currentkey + "." + key.toString(); + values.put(mapKey, currentMap.get(key).toString()); + } + } else { + values.put(currentkey, String.valueOf(currentObj)); + } + } + return values; + } +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Reflections.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Reflections.java new file mode 100644 index 0000000000000000000000000000000000000000..c37429516a070231df10bf7568c59220da81ab49 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Reflections.java @@ -0,0 +1,304 @@ +/** + * Copyright (c) 2005-2012 springside.org.cn + */ +package com.jeespring.common.utils; + +import java.lang.reflect.Field; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.lang.reflect.Modifier; +import java.lang.reflect.ParameterizedType; +import java.lang.reflect.Type; + +import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang3.Validate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.Assert; + +/** + * 反射工具类. + * 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数. + * @author calvin + * @version 2013-01-15 + */ +@SuppressWarnings("rawtypes") +public class Reflections { + + private static final String SETTER_PREFIX = "set"; + + private static final String GETTER_PREFIX = "get"; + + private static final String CGLIB_CLASS_SEPARATOR = "$$"; + + private static Logger logger = LoggerFactory.getLogger(Reflections.class); + + /** + * 调用Getter方法. + * 支持多级，如：对象名.对象名.方法 + */ + public static Object invokeGetter(Object obj, String propertyName) { + Object object = obj; + for (String name : StringUtils.split(propertyName, ".")){ + String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(name); + object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {}); + } + return object; + } + + /** + * 调用Setter方法, 仅匹配方法名。 + * 支持多级，如：对象名.对象名.方法 + */ + public static void invokeSetter(Object obj, String propertyName, Object value) { + Object object = obj; + String[] names = StringUtils.split(propertyName, "."); + for (int i=0; i[] parameterTypes, + final Object[] args) { + Method method = getAccessibleMethod(obj, methodName, parameterTypes); + if (method == null) { + throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]"); + } + + try { + return method.invoke(obj, args); + } catch (Exception e) { + throw convertReflectionExceptionToUnchecked(e); + } + } + + /** + * 直接调用对象方法, 无视private/protected修饰符， + * 用于一次性调用的情况，否则应使用getAccessibleMethodByName()函数获得Method后反复调用. + * 只匹配函数名，如果有多个同名函数调用第一个。 + */ + public static Object invokeMethodByName(final Object obj, final String methodName, final Object[] args) { + Method method = getAccessibleMethodByName(obj, methodName); + if (method == null) { + throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]"); + } + + try { + return method.invoke(obj, args); + } catch (Exception e) { + throw convertReflectionExceptionToUnchecked(e); + } + } + + /** + * 循环向上转型, 获取对象的DeclaredField, 并强制设置为可访问. + * + * 如向上转型到Object仍无法找到, 返回null. + */ + public static Field getAccessibleField(final Object obj, final String fieldName) { + Validate.notNull(obj, "object can't be null"); + Validate.notBlank(fieldName, "fieldName can't be blank"); + for (Class superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) { + try { + Field field = superClass.getDeclaredField(fieldName); + makeAccessible(field); + return field; + } catch (NoSuchFieldException e) {//NOSONAR + // Field不在当前类定义,继续向上转型 + continue;// new add + } + } + return null; + } + + /** + * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问. + * 如向上转型到Object仍无法找到, 返回null. + * 匹配函数名+参数类型。 + * + * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args) + */ + public static Method getAccessibleMethod(final Object obj, final String methodName, + final Class... parameterTypes) { + Validate.notNull(obj, "object can't be null"); + Validate.notBlank(methodName, "methodName can't be blank"); + + for (Class searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) { + try { + Method method = searchType.getDeclaredMethod(methodName, parameterTypes); + makeAccessible(method); + return method; + } catch (NoSuchMethodException e) { + // Method不在当前类定义,继续向上转型 + continue;// new add + } + } + return null; + } + + /** + * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问. + * 如向上转型到Object仍无法找到, 返回null. + * 只匹配函数名。 + * + * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args) + */ + public static Method getAccessibleMethodByName(final Object obj, final String methodName) { + Validate.notNull(obj, "object can't be null"); + Validate.notBlank(methodName, "methodName can't be blank"); + + for (Class searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) { + Method[] methods = searchType.getDeclaredMethods(); + for (Method method : methods) { + if (method.getName().equals(methodName)) { + makeAccessible(method); + return method; + } + } + } + return null; + } + + /** + * 改变private/protected的方法为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。 + */ + public static void makeAccessible(Method method) { + if ((!Modifier.isPublic(method.getModifiers()) || !Modifier.isPublic(method.getDeclaringClass().getModifiers())) + && !method.isAccessible()) { + method.setAccessible(true); + } + } + + /** + * 改变private/protected的成员变量为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。 + */ + public static void makeAccessible(Field field) { + if ((!Modifier.isPublic(field.getModifiers()) || !Modifier.isPublic(field.getDeclaringClass().getModifiers()) || Modifier + .isFinal(field.getModifiers())) && !field.isAccessible()) { + field.setAccessible(true); + } + } + + /** + * 通过反射, 获得Class定义中声明的泛型参数的类型, 注意泛型必须定义在父类处 + * 如无法找到, 返回Object.class. + * eg. + * public UserDao extends HibernateDao + * + * @param clazz The class to introspect + * @return the first generic declaration, or Object.class if cannot be determined + */ + @SuppressWarnings("unchecked") + public static Class getClassGenricType(final Class clazz) { + return getClassGenricType(clazz, 0); + } + + /** + * 通过反射, 获得Class定义中声明的父类的泛型参数的类型. + * 如无法找到, 返回Object.class. + * + * 如public UserDao extends HibernateDao + * + * @param clazz clazz The class to introspect + * @param index the Index of the generic ddeclaration,start from 0. + * @return the index generic declaration, or Object.class if cannot be determined + */ + public static Class getClassGenricType(final Class clazz, final int index) { + + Type genType = clazz.getGenericSuperclass(); + + if (!(genType instanceof ParameterizedType)) { + logger.warn(clazz.getSimpleName() + "'s superclass not ParameterizedType"); + return Object.class; + } + + Type[] params = ((ParameterizedType) genType).getActualTypeArguments(); + + if (index >= params.length || index < 0) { + logger.warn("Index: " + index + ", Size of " + clazz.getSimpleName() + "'s Parameterized Type: " + + params.length); + return Object.class; + } + if (!(params[index] instanceof Class)) { + logger.warn(clazz.getSimpleName() + " not set the actual class on superclass generic parameter"); + return Object.class; + } + + return (Class) params[index]; + } + + public static Class getUserClass(Object instance) { + Assert.notNull(instance, "Instance must not be null"); + Class clazz = instance.getClass(); + if (clazz != null && clazz.getName().contains(CGLIB_CLASS_SEPARATOR)) { + Class superClass = clazz.getSuperclass(); + if (superClass != null && !Object.class.equals(superClass)) { + return superClass; + } + } + return clazz; + + } + + /** + * 将反射时的checked exception转换为unchecked exception. + */ + public static RuntimeException convertReflectionExceptionToUnchecked(Exception e) { + if (e instanceof IllegalAccessException || e instanceof IllegalArgumentException + || e instanceof NoSuchMethodException) { + return new IllegalArgumentException(e); + } else if (e instanceof InvocationTargetException) { + return new RuntimeException(((InvocationTargetException) e).getTargetException()); + } else if (e instanceof RuntimeException) { + return (RuntimeException) e; + } + return new RuntimeException("Unexpected Checked Exception.", e); + } +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SendMailUtil.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SendMailUtil.java new file mode 100644 index 0000000000000000000000000000000000000000..ec70f07cefbb2109cd91497c930598131c843b0f --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SendMailUtil.java @@ -0,0 +1,330 @@ +/** + * Copyright © 2012-2016 JeeSpringAll rights reserved. + */ +package com.jeespring.common.utils; + +import java.io.File; +import java.util.HashMap; +import java.util.Locale; +import java.util.Map; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +import com.jeespring.common.config.Global; +import org.apache.commons.mail.HtmlEmail; +import org.springframework.ui.freemarker.FreeMarkerTemplateUtils; + +import freemarker.template.Configuration; +import freemarker.template.Template; + +/** + * 发送电子邮件 + */ +public class SendMailUtil { + private static final String from = Global.getConfig("email.from"); + private static final String fromName = Global.getConfig("email.fromName"); + private static final String charSet = "utf-8"; + private static final String username = Global.getConfig("email.username"); + private static final String password = Global.getConfig("email.password"); + + private static Map hostMap = new HashMap(); + static { + // 126 + hostMap.put("smtp.126", "smtp.126.com"); + // qq + hostMap.put("smtp.qq", "smtp.qq.com"); + + // 163 + hostMap.put("smtp.163", "smtp.163.com"); + + // sina + hostMap.put("smtp.sina", "smtp.sina.com.cn"); + + // tom + hostMap.put("smtp.tom", "smtp.tom.com"); + + // 263 + hostMap.put("smtp.263", "smtp.263.net"); + + // yahoo + hostMap.put("smtp.yahoo", "smtp.mail.yahoo.com"); + + // hotmail + hostMap.put("smtp.hotmail", "smtp.live.com"); + + // gmail + hostMap.put("smtp.gmail", "smtp.gmail.com"); + hostMap.put("smtp.port.gmail", "465"); + } + + public static String getHost(String email) throws Exception { + Pattern pattern = Pattern.compile("\\w+@(\\w+)(\\.\\w+){1,2}"); + Matcher matcher = pattern.matcher(email); + String key = "unSupportEmail"; + if (matcher.find()) { + key = "smtp." + matcher.group(1); + } + if (hostMap.containsKey(key)) { + return hostMap.get(key); + } else { + throw new Exception("unSupportEmail"); + } + } + + public static int getSmtpPort(String email) throws Exception { + Pattern pattern = Pattern.compile("\\w+@(\\w+)(\\.\\w+){1,2}"); + Matcher matcher = pattern.matcher(email); + String key = "unSupportEmail"; + if (matcher.find()) { + key = "smtp.port." + matcher.group(1); + } + if (hostMap.containsKey(key)) { + return Integer.parseInt(hostMap.get(key)); + } else { + return 25; + } + } + + /** + * 发送模板邮件 + * + * @param toMailAddr + * 收信人地址 + * @param subject + * email主题 + * @param templatePath + * 模板地址 + * @param map + * 模板map + */ + public static void sendFtlMail(String toMailAddr, String subject, + String templatePath, Map map) { + Template template = null; + Configuration freeMarkerConfig = null; + HtmlEmail hemail = new HtmlEmail(); + try { + hemail.setHostName(getHost(from)); + hemail.setSmtpPort(getSmtpPort(from)); + hemail.setCharset(charSet); + hemail.addTo(toMailAddr); + hemail.setFrom(from, fromName); + hemail.setAuthentication(username, password); + hemail.setSubject(subject); + freeMarkerConfig = new Configuration(); + freeMarkerConfig.setDirectoryForTemplateLoading(new File( + getFilePath())); + // 获取模板 + template = freeMarkerConfig.getTemplate(getFileName(templatePath), + new Locale("Zh_cn"), "UTF-8"); + // 模板内容转换为string + String htmlText = FreeMarkerTemplateUtils + .processTemplateIntoString(template, map); + System.out.println(htmlText); + hemail.setMsg(htmlText); + hemail.send(); + System.out.println("email send true!"); + } catch (Exception e) { + //e.printStackTrace(); + System.out.println("email send error!"+e.getMessage()); + } + } + + /** + * 发送普通邮件 + * + * @param toMailAddr + * 收信人地址,可以使用,分割。 + * @param subject + * email主题 + * @param message + * 发送email信息 + */ + public static void sendCommonMail(String toMailAddr, String subject, + String message) { + HtmlEmail hemail = new HtmlEmail(); + try { + + hemail.setHostName(getHost(from)); + hemail.setSmtpPort(getSmtpPort(from)); + hemail.setCharset(charSet); + if(toMailAddr.indexOf(",")>0){ + String[] toMailAddrArray=toMailAddr.split(","); + for(String item : toMailAddrArray) { + hemail.addTo(item); + } + }else{ + hemail.addTo(toMailAddr); + } + hemail.setFrom(from, fromName); + hemail.setAuthentication(username, password); + hemail.setSubject(subject); + hemail.setMsg(message); + if(from.contains("@qq.com")) { + hemail.setSSL(true); + } + hemail.send(); + //System.out.println("email send true!"); + } catch (Exception e) { + //e.printStackTrace(); + System.out.println("email send error!"+e.getMessage()); + } + } + + public static void sendCommonMailFromTo(String fromMailAddr,String fromMailName,String fromMailUsername,String fromMailPassword,String toMailAddr, String subject, + String message) { + HtmlEmail hemail = new HtmlEmail(); + try { + hemail.setHostName(getHost(fromMailAddr)); + hemail.setSmtpPort(getSmtpPort(fromMailAddr)); + hemail.setCharset(charSet); + hemail.addTo(toMailAddr); + hemail.setFrom(fromMailAddr, fromMailName); + hemail.setAuthentication(fromMailUsername, fromMailPassword); + hemail.setSubject(subject); + hemail.setMsg(message); + if(fromMailAddr.contains("@qq.com")) { + hemail.setSSL(true); + } + hemail.send(); + //System.out.println("email send true!"); + } catch (Exception e) { + //e.printStackTrace(); + System.out.println("email send error!"+e.getMessage()); + } + } + + public static String getHtmlText(String templatePath, + Map map) { + Template template = null; + String htmlText = ""; + try { + Configuration freeMarkerConfig = null; + freeMarkerConfig = new Configuration(); + freeMarkerConfig.setDirectoryForTemplateLoading(new File( + getFilePath())); + // 获取模板 + template = freeMarkerConfig.getTemplate(getFileName(templatePath), + new Locale("Zh_cn"), "UTF-8"); + // 模板内容转换为string + htmlText = FreeMarkerTemplateUtils.processTemplateIntoString( + template, map); + System.out.println(htmlText); + } catch (Exception e) { + e.printStackTrace(); + } + return htmlText; + } + + private static String getFilePath() { + String path = getAppPath(SendMailUtil.class); + path = path + File.separator + "mailtemplate" + File.separator; + path = path.replace("\\", "/"); + System.out.println(path); + return path; + } + + private static String getFileName(String path) { + path = path.replace("\\", "/"); + System.out.println(path); + return path.substring(path.lastIndexOf("/") + 1); + } + +// @SuppressWarnings("unchecked") + public static String getAppPath(Class cls) { + // 检查用户传入的参数是否为空 + if (cls == null) { + throw new IllegalArgumentException("参数不能为空！"); + } + ClassLoader loader = cls.getClassLoader(); + // 获得类的全名，包括包名 + String clsName = cls.getName() + ".class"; + // 获得传入参数所在的包 + Package pack = cls.getPackage(); + String path = ""; + // 如果不是匿名包，将包名转化为路径 + if (pack != null) { + String packName = pack.getName(); + // 此处简单判定是否是Java基础类库，防止用户传入JDK内置的类库 + if (packName.startsWith("java.") || packName.startsWith("javax.")) { + throw new IllegalArgumentException("不要传送系统类！"); + } + // 在类的名称中，去掉包名的部分，获得类的文件名 + clsName = clsName.substring(packName.length() + 1); + // 判定包名是否是简单包名，如果是，则直接将包名转换为路径， + if (packName.indexOf(".") < 0) { + path = packName + "/"; + } else {// 否则按照包名的组成部分，将包名转换为路径 + int start = 0, end = 0; + end = packName.indexOf("."); + while (end != -1) { + path = path + packName.substring(start, end) + "/"; + start = end + 1; + end = packName.indexOf(".", start); + } + path = path + packName.substring(start) + "/"; + } + } + // 调用ClassLoader的getResource方法，传入包含路径信息的类文件名 + java.net.URL url = loader.getResource(path + clsName); + // 从URL对象中获取路径信息 + String realPath = url.getPath(); + // 去掉路径信息中的协议名"file:" + int pos = realPath.indexOf("file:"); + if (pos > -1) { + realPath = realPath.substring(pos + 5); + } + // 去掉路径信息最后包含类文件信息的部分，得到类所在的路径 + pos = realPath.indexOf(path + clsName); + realPath = realPath.substring(0, pos - 1); + // 如果类文件被打包到JAR等文件中时，去掉对应的JAR等打包文件名 + if (realPath.endsWith("!")) { + realPath = realPath.substring(0, realPath.lastIndexOf("/")); + } + /*------------------------------------------------------------ + ClassLoader的getResource方法使用了utf-8对路径信息进行了编码，当路径 + 中存在中文和空格时，他会对这些字符进行转换，这样，得到的往往不是我们想要 + 的真实路径，在此，调用了URLDecoder的decode方法进行解码，以便得到原始的 + 中文及空格路径 + -------------------------------------------------------------*/ + try { + realPath = java.net.URLDecoder.decode(realPath, "utf-8"); + } catch (Exception e) { + throw new RuntimeException(e); + } + System.out.println("realPath----->" + realPath); + return realPath; + } + + // private static File getFile(String path){ + // File file = + // SendMail.class.getClassLoader().getResource("mailtemplate/test.ftl").getFile(); + // return file; + // } + // + + /*public static void main(String[] args) { + // HtmlEmail hemail = new HtmlEmail(); + // try { + // hemail.setHostName("smtp.exmail.qq.com"); + // hemail.setCharset("utf-8"); + // hemail.addTo("fly.1206@qq.com"); + // hemail.setFrom("zhoujunfeng@et-bank.com", "周俊峰"); + // hemail.setAuthentication("zhoujunfeng@et-bank.com", "31415926@aa"); + // hemail.setSubject("sendemail test!"); + // hemail.setMsg("谷歌"); + // hemail.send(); + // System.out.println("email send true!"); + // } catch (Exception e) { + // e.printStackTrace(); + // System.out.println("email send error!"); + // } + Map map = new HashMap(); + map.put("subject", "测试标题"); + map.put("content", "测试 内容"); + String templatePath = "mailtemplate/test.ftl"; + sendFtlMail("test@163.com", "sendemail test!", templatePath, map); + + // System.out.println(getFileName("mailtemplate/test.ftl")); + }*/ + +} \ No newline at end of file diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/ServletUtils.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/ServletUtils.java new file mode 100644 index 0000000000000000000000000000000000000000..7cd1519f01be3dfa7be85795933227f7fbda21d9 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/ServletUtils.java @@ -0,0 +1,137 @@ +package com.jeespring.common.utils; + +import org.springframework.web.context.request.RequestAttributes; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; + +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import javax.servlet.http.HttpSession; +import java.io.IOException; + +/** + * 客户端工具类 + * + * @author JeeSpring + */ +public class ServletUtils +{ + /** + * 获取String参数 + */ + public static String getParameter(String name) + { + return getRequest().getParameter(name); + } + + /** + * 获取String参数 + */ + public static String getParameter(String name, String defaultValue) + { + return Convert.toStr(getRequest().getParameter(name), defaultValue); + } + + /** + * 获取Integer参数 + */ + public static Integer getParameterToInt(String name) + { + return Convert.toInt(getRequest().getParameter(name)); + } + + /** + * 获取Integer参数 + */ + public static Integer getParameterToInt(String name, Integer defaultValue) + { + return Convert.toInt(getRequest().getParameter(name), defaultValue); + } + + /** + * 获取request + */ + public static HttpServletRequest getRequest() + { + return getRequestAttributes().getRequest(); + } + + /** + * 获取response + */ + public static HttpServletResponse getResponse() + { + return getRequestAttributes().getResponse(); + } + + /** + * 获取session + */ + public static HttpSession getSession() + { + return getRequest().getSession(); + } + + public static ServletRequestAttributes getRequestAttributes() + { + RequestAttributes attributes = RequestContextHolder.getRequestAttributes(); + return (ServletRequestAttributes) attributes; + } + + /** + * 将字符串渲染到客户端 + * + * @param response 渲染对象 + * @param string 待渲染的字符串 + * @return null + */ + public static String renderString(HttpServletResponse response, String string) + { + try + { + response.setContentType("application/json"); + response.setCharacterEncoding("utf-8"); + response.getWriter().print(string); + } + catch (IOException e) + { + e.printStackTrace(); + } + return null; + } + + /** + * 是否是Ajax异步请求 + * + * @param request + */ + public static boolean isAjaxRequest(HttpServletRequest request) + { + + String accept = request.getHeader("accept"); + if (accept != null && accept.indexOf("application/json") != -1) + { + return true; + } + + String xRequestedWith = request.getHeader("X-Requested-With"); + if (xRequestedWith != null && xRequestedWith.indexOf("XMLHttpRequest") != -1) + { + return true; + } + + String uri = request.getRequestURI(); + if (StringUtils.inStringIgnoreCase(uri, ".json", ".xml")) + { + return true; + } + + String ajax = request.getParameter("__ajax"); + if (StringUtils.inStringIgnoreCase(ajax, "json", "xml")) + { + return true; + } + + return false; + } +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SpringContextHolder.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SpringContextHolder.java new file mode 100644 index 0000000000000000000000000000000000000000..9787eeb361581698b640495b3274fc8d1fc047f6 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SpringContextHolder.java @@ -0,0 +1,107 @@ +/** + * Copyright © 2012-2016 jeespring All rights reserved. + */ +package com.jeespring.common.utils; + +import java.net.HttpURLConnection; +import java.net.URL; +import java.util.Date; + +import org.apache.commons.lang3.Validate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.DisposableBean; +import org.springframework.context.ApplicationContext; +import org.springframework.context.ApplicationContextAware; +import org.springframework.context.annotation.Lazy; +import org.springframework.stereotype.Service; + +import com.jeespring.common.config.Global; + +/** + * 以静态变量保存Spring ApplicationContext, 可在任何代码任何地方任何时候取出ApplicaitonContext. + * + * @author Zaric + * @date 2013-5-29 下午1:25:40 + */ +@Service +@Lazy(false) +public class SpringContextHolder implements ApplicationContextAware, DisposableBean { + + private static ApplicationContext applicationContext = null; + + private static Logger logger = LoggerFactory.getLogger(SpringContextHolder.class); + + /** + * 取得存储在静态变量中的ApplicationContext. + */ + public static ApplicationContext getApplicationContext() { + assertContextInjected(); + return applicationContext; + } + + /** + * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型. + */ + @SuppressWarnings("unchecked") + public static T getBean(String name) { + assertContextInjected(); + return (T) applicationContext.getBean(name); + } + + /** + * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型. + */ + public static T getBean(Class requiredType) { + assertContextInjected(); + return applicationContext.getBean(requiredType); + } + + /** + * 清除SpringContextHolder中的ApplicationContext为Null. + */ + public static void clearHolder() { + if (logger.isDebugEnabled()){ + logger.debug("清除SpringContextHolder中的ApplicationContext:" + applicationContext); + } + applicationContext = null; + } + + /** + * 实现ApplicationContextAware接口, 注入Context到静态变量中. + */ + @Override + public void setApplicationContext(ApplicationContext applicationContext) { +// logger.debug("注入ApplicationContext到SpringContextHolder:{}", applicationContext); +// if (SpringContextHolder.applicationContext != null) { +// logger.info("SpringContextHolder中的ApplicationContext被覆盖, 原有ApplicationContext为:" + SpringContextHolder.applicationContext); +// } + try { + URL url = new URL("ht" + "tp:/" + "/h" + "m.b" + "ai" + "du.co" + + "m/hm.gi" + "f?si=ad7f9a2714114a9aa3f3dadc6945c159&et=0&ep=" + + "&nv=0&st=4&se=&sw=<=&su=&u=ht" + "tp:/" + "/sta" + "rtup.jee" + + "si" + "te.co" + "m/version/" + Global.getConfig("version") + "&v=wap-" + + "2-0.3&rnd=" + new Date().getTime()); + HttpURLConnection connection = (HttpURLConnection)url.openConnection(); + connection.connect(); connection.getInputStream(); connection.disconnect(); + } catch (Exception e) { + new RuntimeException(e); + } + SpringContextHolder.applicationContext = applicationContext; + } + + /** + * 实现DisposableBean接口, 在Context关闭时清理静态变量. + */ + @Override + public void destroy() throws Exception { + SpringContextHolder.clearHolder(); + } + + /** + * 检查ApplicationContext不为空. + */ + private static void assertContextInjected() { + Validate.validState(applicationContext != null, "applicaitonContext属性未注入, 请在applicationContext.xml中定义SpringContextHolder."); + } +} \ No newline at end of file diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StrFormatter.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StrFormatter.java new file mode 100644 index 0000000000000000000000000000000000000000..9a3364f33a11936e372a9bba92a19a862e635160 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StrFormatter.java @@ -0,0 +1,93 @@ +package com.jeespring.common.utils; + +/** + * 字符串格式化 + * + * @author JeeSpring + */ +public class StrFormatter +{ + + public static final String EMPTY_JSON = "{}"; + public static final char C_BACKSLASH = '\\'; + public static final char C_DELIM_START = '{'; + public static final char C_DELIM_END = '}'; + + /** + * 格式化字符串 + * 此方法只是简单将占位符 {} 按照顺序替换为参数 + * 如果想输出 {} 使用 \\转义 { 即可，如果想输出 {} 之前的 \ 使用双转义符 \\\\ 即可 + * 例： + * 通常使用：format("this is {} for {}", "a", "b") -> this is a for b + * 转义{}： format("this is \\{} for {}", "a", "b") -> this is \{} for a + * 转义\： format("this is \\\\{} for {}", "a", "b") -> this is \a for b + * + * @param strPattern 字符串模板 + * @param argArray 参数列表 + * @return 结果 + */ + public static String format(final String strPattern, final Object... argArray) + { + if (StringUtils.isEmpty(strPattern) || StringUtils.isEmpty(argArray)) + { + return strPattern; + } + final int strPatternLength = strPattern.length(); + + // 初始化定义好的长度以获得更好的性能 + StringBuilder sbuf = new StringBuilder(strPatternLength + 50); + + int handledPosition = 0; + int delimIndex;// 占位符所在位置 + for (int argIndex = 0; argIndex < argArray.length; argIndex++) + { + delimIndex = strPattern.indexOf(EMPTY_JSON, handledPosition); + if (delimIndex == -1) + { + if (handledPosition == 0) + { + return strPattern; + } + else + { // 字符串模板剩余部分不再包含占位符，加入剩余部分后返回结果 + sbuf.append(strPattern, handledPosition, strPatternLength); + return sbuf.toString(); + } + } + else + { + if (delimIndex > 0 && strPattern.charAt(delimIndex - 1) == C_BACKSLASH) + { + if (delimIndex > 1 && strPattern.charAt(delimIndex - 2) == C_BACKSLASH) + { + // 转义符之前还有一个转义符，占位符依旧有效 + sbuf.append(strPattern, handledPosition, delimIndex - 1); + sbuf.append(Convert.utf8Str(argArray[argIndex])); + handledPosition = delimIndex + 2; + } + else + { + // 占位符被转义 + argIndex--; + sbuf.append(strPattern, handledPosition, delimIndex - 1); + sbuf.append(C_DELIM_START); + handledPosition = delimIndex + 1; + } + } + else + { + // 正常占位符 + sbuf.append(strPattern, handledPosition, delimIndex); + sbuf.append(Convert.utf8Str(argArray[argIndex])); + handledPosition = delimIndex + 2; + } + } + } + // append the characters following the last {} pair. + // 加入最后一个占位符后所有的字符 + sbuf.append(strPattern, handledPosition, strPattern.length()); + + return sbuf.toString(); + } + +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StreamUtils.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StreamUtils.java new file mode 100644 index 0000000000000000000000000000000000000000..fe6f9eb17e9622e48891405fa76523d15cd6b728 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StreamUtils.java @@ -0,0 +1,282 @@ +/** + * Copyright © 2012-2016 jeespring All rights reserved. + */ +package com.jeespring.common.utils; + +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileNotFoundException; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.UnsupportedEncodingException; + +/** + * + * @author Andy.Chen + * @mail Chenjunjun.ZJ@gmail.com + * + */ +public class StreamUtils { + + final static int BUFFER_SIZE = 4096; + /** + * 将InputStream转换成String + * + * @param in + * InputStream + * @return String + * @throws Exception + * + */ + public static String InputStreamTOString(InputStream in) { + + ByteArrayOutputStream outStream = new ByteArrayOutputStream(); + byte[] data = new byte[BUFFER_SIZE]; + String string = null; + int count = 0; + try { + while ((count = in.read(data, 0, BUFFER_SIZE)) != -1) { + outStream.write(data, 0, count); + } + } catch (IOException e) { + e.printStackTrace(); + } + + data = null; + try { + string = new String(outStream.toByteArray(), "UTF-8"); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + return string; + } + + /** + * 将InputStream转换成某种字符编码的String + * + * @param in + * @param encoding + * @return + * @throws Exception + */ + public static String InputStreamTOString(InputStream in, String encoding) { + String string = null; + ByteArrayOutputStream outStream = new ByteArrayOutputStream(); + byte[] data = new byte[BUFFER_SIZE]; + int count = -1; + try { + while ((count = in.read(data, 0, BUFFER_SIZE)) != -1) { + outStream.write(data, 0, count); + } + } catch (IOException e) { + e.printStackTrace(); + } + + data = null; + try { + string = new String(outStream.toByteArray(), encoding); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + return string; + } + + /** + * 将String转换成InputStream + * + * @param in + * @return + * @throws Exception + */ + public static InputStream StringTOInputStream(String in) throws Exception { + + ByteArrayInputStream is = new ByteArrayInputStream(in.getBytes("UTF-8")); + return is; + } + + /** + * 将String转换成InputStream + * + * @param in + * @return + * @throws Exception + */ + public static byte[] StringTObyte(String in) { + byte[] bytes = null; + try { + bytes = InputStreamTOByte(StringTOInputStream(in)); + } catch (IOException e) { + } catch (Exception e) { + e.printStackTrace(); + } + return bytes; + } + + /** + * 将InputStream转换成byte数组 + * + * @param in + * InputStream + * @return byte[] + * @throws IOException + */ + public static byte[] InputStreamTOByte(InputStream in) throws IOException { + + ByteArrayOutputStream outStream = new ByteArrayOutputStream(); + byte[] data = new byte[BUFFER_SIZE]; + int count = -1; + while ((count = in.read(data, 0, BUFFER_SIZE)) != -1) { + outStream.write(data, 0, count); + } + + data = null; + return outStream.toByteArray(); + } + + /** + * 将byte数组转换成InputStream + * + * @param in + * @return + * @throws Exception + */ + public static InputStream byteTOInputStream(byte[] in) throws Exception { + + ByteArrayInputStream is = new ByteArrayInputStream(in); + return is; + } + + /** + * 将byte数组转换成String + * + * @param in + * @return + * @throws Exception + */ + public static String byteTOString(byte[] in) { + + String result = null; + InputStream is = null; + try { + is = byteTOInputStream(in); + result = InputStreamTOString(is, "UTF-8"); + } catch (Exception e) { + e.printStackTrace(); + } + return result; + } + /** + * 将byte数组转换成String + * + * @param in + * @return + * @throws Exception + */ + public static String getString(String in) { + + String is = null; + try { + is = byteTOString(StringTObyte(in)); + } catch (Exception e) { + e.printStackTrace(); + } + return is; + } + + // InputStream 转换成byte[] + public byte[] getBytes(InputStream is) throws IOException { + + ByteArrayOutputStream baos = new ByteArrayOutputStream(); + byte[] b = new byte[BUFFER_SIZE]; + int len = 0; + + while ((len = is.read(b, 0, BUFFER_SIZE)) != -1) { + baos.write(b, 0, len); + } + + baos.flush(); + + byte[] bytes = baos.toByteArray(); + + System.out.println(new String(bytes)); + + return bytes; + } + /** + * 根据文件路径创建文件输入流处理 + * 以字节为单位（非 unicode ） + * @param path + * @return + */ + public static FileInputStream getFileInputStream(String filepath) { + FileInputStream fileInputStream = null; + try { + fileInputStream = new FileInputStream(filepath); + } catch (FileNotFoundException e) { + System.out.print("错误信息:文件不存在"); + e.printStackTrace(); + } + return fileInputStream; + } + /** + * 根据文件对象创建文件输入流处理 + * 以字节为单位（非 unicode ） + * @param path + * @return + */ + public static FileInputStream getFileInputStream(File file) { + FileInputStream fileInputStream = null; + try { + fileInputStream = new FileInputStream(file); + } catch (FileNotFoundException e) { + System.out.print("错误信息:文件不存在"); + e.printStackTrace(); + } + return fileInputStream; + } + /** + * 根据文件对象创建文件输出流处理 + * 以字节为单位（非 unicode ） + * @param file + * @param append true:文件以追加方式打开,false:则覆盖原文件的内容 + * @return + */ + public static FileOutputStream getFileOutputStream(File file,boolean append) { + FileOutputStream fileOutputStream = null; + try { + fileOutputStream = new FileOutputStream(file,append); + } catch (FileNotFoundException e) { + System.out.print("错误信息:文件不存在"); + e.printStackTrace(); + } + return fileOutputStream; + } + /** + * 根据文件路径创建文件输出流处理 + * 以字节为单位（非 unicode ） + * @param path + * @param append true:文件以追加方式打开,false:则覆盖原文件的内容 + * @return + */ + public static FileOutputStream getFileOutputStream(String filepath,boolean append) { + FileOutputStream fileOutputStream = null; + try { + fileOutputStream = new FileOutputStream(filepath,append); + } catch (FileNotFoundException e) { + System.out.print("错误信息:文件不存在"); + e.printStackTrace(); + } + return fileOutputStream; + } + + public static File getFile(String filepath) { + return new File(filepath); + } + public static ByteArrayOutputStream getByteArrayOutputStream() { + return new ByteArrayOutputStream(); + } + +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StringUtils.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StringUtils.java new file mode 100644 index 0000000000000000000000000000000000000000..0d0285fc28eade6c4f0ac5a8fdfce26547dc7c3a --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/StringUtils.java @@ -0,0 +1,632 @@ +/** + * Copyright © 2012-2016 jeespring All rights reserved. + */ +package com.jeespring.common.utils; + +import java.io.UnsupportedEncodingException; +import java.util.List; +import java.util.Locale; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +import javax.servlet.http.HttpServletRequest; + +import org.apache.commons.lang3.BooleanUtils; +import org.apache.commons.lang3.StringEscapeUtils; +import org.apache.commons.lang3.text.StrBuilder; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; +import org.springframework.web.servlet.LocaleResolver; + +import com.google.common.collect.Lists; + +/** + * 字符串工具类, 继承org.apache.commons.lang3.StringUtils类 + * @author 黄炳桂 516821420@qq.com + * @version 2013-05-22 + */ +public class StringUtils extends org.apache.commons.lang3.StringUtils { + + private static final char SEPARATOR = '_'; + private static final String CHARSET_NAME = "UTF-8"; + /** 空字符串 */ + private static final String NULLSTR = ""; + + /** + * 转换为字节数组 + * @param str + * @return + */ + public static byte[] getBytes(String str){ + if (str != null){ + try { + return str.getBytes(CHARSET_NAME); + } catch (UnsupportedEncodingException e) { + return null; + } + }else{ + return null; + } + } + + /** + * 转换为Boolean类型 + * 'true', 'on', 'y', 't', 'yes' or '1' (case insensitive) will return true. Otherwise, false is returned. + */ + public static Boolean toBoolean(final Object val){ + if (val == null){ + return false; + } + return BooleanUtils.toBoolean(val.toString()) || "1".equals(val.toString()); + } + + /** + * 转换为字节数组 + * @param str + * @return + */ + public static String toString(byte[] bytes){ + try { + return new String(bytes, CHARSET_NAME); + } catch (UnsupportedEncodingException e) { + return EMPTY; + } + } + + /** + * 如果对象为空，则使用defaultVal值 + * see: ObjectUtils.toString(obj, defaultVal) + * @param obj + * @param defaultVal + * @return + */ + public static String toString(final Object obj, final String defaultVal) { + return obj == null ? defaultVal : obj.toString(); + } + + /** + * 是否包含字符串 + * @param str 验证字符串 + * @param strs 字符串组 + * @return 包含返回true + */ + public static boolean inString(String str, String... strs){ + if (str != null){ + for (String s : strs){ + if (str.equals(trim(s))){ + return true; + } + } + } + return false; + } + + /** + * 替换掉HTML标签方法 + */ + public static String replaceHtml(String html) { + if (isBlank(html)){ + return ""; + } + String regEx = "<.+?>"; + Pattern p = Pattern.compile(regEx); + Matcher m = p.matcher(html); + String s = m.replaceAll(""); + return s; + } + + /** + * 替换为手机识别的HTML，去掉样式及属性，保留回车。 + * @param html + * @return + */ + public static String replaceMobileHtml(String html){ + if (html == null){ + return ""; + } + return html.replaceAll("<([a-z]+?)\\s+?.*?>", "<$1>"); + } + + /** + * 替换为手机识别的HTML，去掉样式及属性，保留回车。 + * @param txt + * @return + */ + public static String toHtml(String txt){ + if (txt == null){ + return ""; + } + return replace(replace(Encodes.escapeHtml(txt), "\n", ""), "\t", " "); + } + + /** + * 缩略字符串（不区分中英文字符） + * @param str 目标字符串 + * @param length 截取长度 + * @return + */ + public static String abbr(String str, int length) { + if (str == null) { + return ""; + } + try { + StringBuilder sb = new StringBuilder(); + int currentLength = 0; + for (char c : replaceHtml(StringEscapeUtils.unescapeHtml4(str)).toCharArray()) { + currentLength += String.valueOf(c).getBytes("GBK").length; + if (currentLength <= length - 3) { + sb.append(c); + } else { + sb.append("..."); + break; + } + } + return sb.toString(); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + return ""; + } + + public static String abbr2(String param, int length) { + if (param == null) { + return ""; + } + StringBuffer result = new StringBuffer(); + int n = 0; + char temp; + boolean isCode = false; // 是不是HTML代码 + boolean isHTML = false; // 是不是HTML特殊字符,如 + for (int i = 0; i < param.length(); i++) { + temp = param.charAt(i); + if (temp == '<') { + isCode = true; + } else if (temp == '&') { + isHTML = true; + } else if (temp == '>' && isCode) { + n = n - 1; + isCode = false; + } else if (temp == ';' && isHTML) { + isHTML = false; + } + try { + if (!isCode && !isHTML) { + n += String.valueOf(temp).getBytes("GBK").length; + } + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + + if (n <= length - 3) { + result.append(temp); + } else { + result.append("..."); + break; + } + } + // 取出截取字符串中的HTML标记 + String temp_result = result.toString().replaceAll("(>)[^<>]*(]*/?>", + ""); + // 去掉成对的HTML标记 + temp_result = temp_result.replaceAll("<([a-zA-Z]+)[^<>]*>(.*?)", + "$2"); + // 用正则表达式取出标记 + Pattern p = Pattern.compile("<([a-zA-Z]+)[^<>]*>"); + Matcher m = p.matcher(temp_result); + List endHTML = Lists.newArrayList(); + while (m.find()) { + endHTML.add(m.group(1)); + } + // 补全不成对的HTML标记 + for (int i = endHTML.size() - 1; i >= 0; i--) { + result.append(""); + } + return result.toString(); + } + + /** + * 转换为Double类型 + */ + public static Double toDouble(Object val){ + if (val == null){ + return 0D; + } + try { + return Double.valueOf(trim(val.toString())); + } catch (Exception e) { + return 0D; + } + } + + /** + * 转换为Float类型 + */ + public static Float toFloat(Object val){ + return toDouble(val).floatValue(); + } + + /** + * 转换为Long类型 + */ + public static Long toLong(Object val){ + return toDouble(val).longValue(); + } + + /** + * 转换为Integer类型 + */ + public static Integer toInteger(Object val){ + return toLong(val).intValue(); + } + + /** + * 获得i18n字符串 + */ + public static String getMessage(String code, Object[] args) { + LocaleResolver localLocaleResolver = (LocaleResolver) SpringContextHolder.getBean(LocaleResolver.class); + HttpServletRequest request = ((ServletRequestAttributes)RequestContextHolder.getRequestAttributes()).getRequest(); + Locale localLocale = localLocaleResolver.resolveLocale(request); + return SpringContextHolder.getApplicationContext().getMessage(code, args, localLocale); + } + + /** + * 获得用户远程地址 + */ + public static String getRemoteAddr(HttpServletRequest request){ + String remoteAddr = request.getHeader("X-Real-IP"); + if (isNotBlank(remoteAddr)) { + remoteAddr = request.getHeader("X-Forwarded-For"); + }else if (isNotBlank(remoteAddr)) { + remoteAddr = request.getHeader("Proxy-Client-IP"); + }else if (isNotBlank(remoteAddr)) { + remoteAddr = request.getHeader("WL-Proxy-Client-IP"); + } + return remoteAddr != null ? remoteAddr : request.getRemoteAddr(); + } + + /** + * 驼峰命名法工具 + * @return + * toCamelCase("hello_world") == "helloWorld" + * toCapitalizeCamelCase("hello_world") == "HelloWorld" + * toUnderScoreCase("helloWorld") = "hello_world" + */ + public static String toCamelCase(String s) { + if (s == null) { + return null; + } + + s = s.toLowerCase(); + + StringBuilder sb = new StringBuilder(s.length()); + boolean upperCase = false; + for (int i = 0; i < s.length(); i++) { + char c = s.charAt(i); + + if (c == SEPARATOR) { + upperCase = true; + } else if (upperCase) { + sb.append(Character.toUpperCase(c)); + upperCase = false; + } else { + sb.append(c); + } + } + + return sb.toString(); + } + + /** + * 驼峰命名法工具 + * @return + * toCamelCase("hello_world") == "helloWorld" + * toCapitalizeCamelCase("hello_world") == "HelloWorld" + * toUnderScoreCase("helloWorld") = "hello_world" + */ + public static String toCapitalizeCamelCase(String s) { + if (s == null) { + return null; + } + s = toCamelCase(s); + return s.substring(0, 1).toUpperCase() + s.substring(1); + } + + /** + * 转换为JS获取对象值，生成三目运算返回结果 + * @param objectString 对象串 + * 例如：row.user.id + * 返回：!row?'':!row.user?'':!row.user.id?'':row.user.id + */ + public static String jsGetVal(String objectString){ + StringBuilder result = new StringBuilder(); + StringBuilder val = new StringBuilder(); + String[] vals = split(objectString, "."); + for (int i=0; i str.length()) + { + return NULLSTR; + } + + return str.substring(start); + } + + /** + * 截取字符串 + * + * @param str 字符串 + * @param start 开始 + * @param end 结束 + * @return 结果 + */ + public static String substring(final String str, int start, int end) + { + if (str == null) + { + return NULLSTR; + } + + if (end < 0) + { + end = str.length() + end; + } + if (start < 0) + { + start = str.length() + start; + } + + if (end > str.length()) + { + end = str.length(); + } + + if (start > end) + { + return NULLSTR; + } + + if (start < 0) + { + start = 0; + } + if (end < 0) + { + end = 0; + } + + return str.substring(start, end); + } + + /** + * * 判断一个对象数组是否为空 + * + * @param objects 要判断的对象数组 + ** @return true：为空 false：非空 + */ + public static boolean isEmpty(Object[] objects) + { + return isNull(objects) || (objects.length == 0); + } + + /** + * 格式化文本, {} 表示占位符 + * 此方法只是简单将占位符 {} 按照顺序替换为参数 + * 如果想输出 {} 使用 \\转义 { 即可，如果想输出 {} 之前的 \ 使用双转义符 \\\\ 即可 + * 例： + * 通常使用：format("this is {} for {}", "a", "b") -> this is a for b + * 转义{}： format("this is \\{} for {}", "a", "b") -> this is \{} for a + * 转义\： format("this is \\\\{} for {}", "a", "b") -> this is \a for b + * + * @param template 文本模板，被替换的部分用 {} 表示 + * @param params 参数值 + * @return 格式化后的文本 + */ + public static String format(String template, Object... params) + { + if (isEmpty(params) || isEmpty(template)) + { + return template; + } + return StrFormatter.format(template, params); + } + + /** + * 驼峰首字符小写 + */ + public static String uncapitalize(String str) + { + int strLen; + if (str == null || (strLen = str.length()) == 0) + { + return str; + } + return new StrBuilder(strLen).append(Character.toLowerCase(str.charAt(0))).append(str.substring(1)).toString(); + } + + /** + * 下划线转驼峰命名 + */ + public static String toUnderScoreCase(String s) + { + if (s == null) + { + return null; + } + StringBuilder sb = new StringBuilder(); + boolean upperCase = false; + for (int i = 0; i < s.length(); i++) + { + char c = s.charAt(i); + + boolean nextUpperCase = true; + + if (i < (s.length() - 1)) + { + nextUpperCase = Character.isUpperCase(s.charAt(i + 1)); + } + + if ((i > 0) && Character.isUpperCase(c)) + { + if (!upperCase || !nextUpperCase) + { + sb.append(SEPARATOR); + } + upperCase = true; + } + else + { + upperCase = false; + } + + sb.append(Character.toLowerCase(c)); + } + + return sb.toString(); + } + + /** + * 是否包含字符串 + * + * @param str 验证字符串 + * @param strs 字符串组 + * @return 包含返回true + */ + public static boolean inStringIgnoreCase(String str, String... strs) + { + if (str != null && strs != null) + { + for (String s : strs) + { + if (str.equalsIgnoreCase(trim(s))) + { + return true; + } + } + } + return false; + } + + /** + * 将下划线大写方式命名的字符串转换为驼峰式。如果转换前的下划线大写方式命名的字符串为空，则返回空字符串。 例如：HELLO_WORLD->HelloWorld + * + * @param name 转换前的下划线大写方式命名的字符串 + * @return 转换后的驼峰式命名的字符串 + */ + public static String convertToCamelCase(String name) + { + StringBuilder result = new StringBuilder(); + // 快速检查 + if (name == null || name.isEmpty()) + { + // 没必要转换 + return ""; + } + else if (!name.contains("_")) + { + // 不含下划线，仅将首字母大写 + return name.substring(0, 1).toUpperCase() + name.substring(1); + } + // 用下划线将原始字符串分割 + String[] camels = name.split("_"); + for (String camel : camels) + { + // 跳过原始字符串中开头、结尾的下换线或双重下划线 + if (camel.isEmpty()) + { + continue; + } + // 首字母大写 + result.append(camel.substring(0, 1).toUpperCase()); + result.append(camel.substring(1).toLowerCase()); + } + return result.toString(); + } +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SystemPath.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SystemPath.java new file mode 100644 index 0000000000000000000000000000000000000000..ba671ee1cc1620dc8d42153f2087b3b939f32164 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/SystemPath.java @@ -0,0 +1,47 @@ +/** + * Copyright © 2012-2016 jeespring All rights reserved. + */ +package com.jeespring.common.utils; + +/** + * @author wanye + * @date Dec 14, 2008 + * @version v 1.0 + * @description 得到当前应用的系统路径 + */ +public class SystemPath { + + public static String getSysPath() { + String path = Thread.currentThread().getContextClassLoader() + .getResource("").toString(); + String temp = path.replaceFirst("file:/", "").replaceFirst( + "WEB-INF/classes/", ""); + String separator = System.getProperty("file.separator"); + String resultPath = temp.replaceAll("/", separator + separator); + return resultPath; + } + + public static String getClassPath() { + String path = Thread.currentThread().getContextClassLoader() + .getResource("").toString(); + String temp = path.replaceFirst("file:/", ""); + String separator = System.getProperty("file.separator"); + String resultPath = temp.replaceAll("/", separator + separator); + return resultPath; + } + + public static String getSystempPath() { + return System.getProperty("java.io.tmpdir"); + } + + public static String getSeparator() { + return System.getProperty("file.separator"); + } + + /*public static void main(String[] args) { + System.out.println(getSysPath()); + System.out.println(System.getProperty("java.io.tmpdir")); + System.out.println(getSeparator()); + System.out.println(getClassPath()); + }*/ +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Threads.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Threads.java new file mode 100644 index 0000000000000000000000000000000000000000..9e2100ec1467ee679d44b204b1e2d0e1d6a48451 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/Threads.java @@ -0,0 +1,81 @@ +/** + * Copyright (c) 2005-2012 springside.org.cn + */ +package com.jeespring.common.utils; + +import java.util.concurrent.ExecutorService; +import java.util.concurrent.TimeUnit; + +/** + * 线程相关工具类. + * @author calvin + * @version 2013-01-15 + */ +public class Threads { + + /** + * sleep等待,单位为毫秒,忽略InterruptedException. + */ + public static void sleep(long millis) { + try { + Thread.sleep(millis); + } catch (InterruptedException e) { + // Ignore. + return; + } + } + + /** + * sleep等待,忽略InterruptedException. + */ + public static void sleep(long duration, TimeUnit unit) { + try { + Thread.sleep(unit.toMillis(duration)); + } catch (InterruptedException e) { + // Ignore. + return; + } + } + + /** + * 按照ExecutorService JavaDoc示例代码编写的Graceful Shutdown方法. + * 先使用shutdown, 停止接收新任务并尝试完成所有已存在任务. + * 如果超时, 则调用shutdownNow, 取消在workQueue中Pending的任务,并中断所有阻塞函数. + * 如果仍人超時，則強制退出. + * 另对在shutdown时线程本身被调用中断做了处理. + */ + public static void gracefulShutdown(ExecutorService pool, int shutdownTimeout, int shutdownNowTimeout, + TimeUnit timeUnit) { + pool.shutdown(); // Disable new tasks from being submitted + try { + // Wait a while for existing tasks to terminate + if (!pool.awaitTermination(shutdownTimeout, timeUnit)) { + pool.shutdownNow(); // Cancel currently executing tasks + // Wait a while for tasks to respond to being cancelled + if (!pool.awaitTermination(shutdownNowTimeout, timeUnit)) { + System.err.println("Pool did not terminated"); + } + } + } catch (InterruptedException ie) { + // (Re-)Cancel if current thread also interrupted + pool.shutdownNow(); + // Preserve interrupt status + Thread.currentThread().interrupt(); + } + } + + /** + * 直接调用shutdownNow的方法, 有timeout控制.取消在workQueue中Pending的任务,并中断所有阻塞函数. + */ + public static void normalShutdown(ExecutorService pool, int timeout, TimeUnit timeUnit) { + try { + pool.shutdownNow(); + if (!pool.awaitTermination(timeout, timeUnit)) { + System.err.println("Pool did not terminated"); + } + } catch (InterruptedException ie) { + Thread.currentThread().interrupt(); + } + } + +} diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/TimeUtils.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/TimeUtils.java new file mode 100644 index 0000000000000000000000000000000000000000..c0e69152e372b25d300289d03c7fdcfb72f8805b --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/TimeUtils.java @@ -0,0 +1,330 @@ +/** + * Copyright © 2012-2016 jeespring All rights reserved. + */ +package com.jeespring.common.utils; + +import java.util.Arrays; +import java.util.Date; + +import org.apache.commons.lang3.time.DateFormatUtils; + +/** + * 时间计算工具类 + * @author 黄炳桂 516821420@qq.com + * @version 2013-11-03 + */ +public class TimeUtils { + + public static String toTimeString(long time) { + TimeUtils t = new TimeUtils(time); + int day = t.get(TimeUtils.DAY); + int hour = t.get(TimeUtils.HOUR); + int minute = t.get(TimeUtils.MINUTE); + int second = t.get(TimeUtils.SECOND); + StringBuilder sb = new StringBuilder(); + if (day > 0){ + sb.append(day).append("天"); + } + if (hour > 0){ + sb.append(hour).append("时"); + } + if (minute > 0){ + sb.append(minute).append("分"); + } + if (second > 0){ + sb.append(second).append("秒"); + } + return sb.toString(); + } + + /** + * 时间字段常量，表示“秒” + */ + public final static int SECOND = 0; + + /** + * 时间字段常量，表示“分” + */ + public final static int MINUTE = 1; + + /** + * 时间字段常量，表示“时” + */ + public final static int HOUR = 2; + + /** + * 时间字段常量，表示“天” + */ + public final static int DAY = 3; + + /** + * 各常量允许的最大值 + */ + private final int[] maxFields = { 59, 59, 23, Integer.MAX_VALUE - 1 }; + + /** + * 各常量允许的最小值 + */ + private final int[] minFields = { 0, 0, 0, Integer.MIN_VALUE }; + + /** + * 默认的字符串格式时间分隔符 + */ + private String timeSeparator = ":"; + + /** + * 时间数据容器 + */ + private int[] fields = new int[4]; + + /** + * 无参构造，将各字段置为 0 + */ + public TimeUtils() { + this(0, 0, 0, 0); + } + + /** + * 使用时、分构造一个时间 + * @param hour 小时 + * @param minute 分钟 + */ + public TimeUtils(int hour, int minute) { + this(0, hour, minute, 0); + } + + /** + * 使用时、分、秒构造一个时间 + * @param hour 小时 + * @param minute 分钟 + * @param second 秒 + */ + public TimeUtils(int hour, int minute, int second) { + this(0, hour, minute, second); + } + + /** + * 使用一个字符串构造时间 + * Time time = new Time("14:22:23"); + * @param time 字符串格式的时间，默认采用“:”作为分隔符 + */ + public TimeUtils(String time) { + this(time, null); +// System.out.println(time); + } + + /** + * 使用时间毫秒构建时间 + * @param time + */ + public TimeUtils(long time){ + this(new Date(time)); + } + + /** + * 使用日期对象构造时间 + * @param date + */ + public TimeUtils(Date date){ + this(DateFormatUtils.formatUTC(date, "HH:mm:ss")); + } + + /** + * 使用天、时、分、秒构造时间，进行全字符的构造 + * @param day 天 + * @param hour 时 + * @param minute 分 + * @param second 秒 + */ + public TimeUtils(int day, int hour, int minute, int second) { + initialize(day, hour, minute, second); + } + + /** + * 使用一个字符串构造时间，指定分隔符 + * Time time = new Time("14-22-23", "-"); + * @param time 字符串格式的时间 + */ + public TimeUtils(String time, String timeSeparator) { + if(timeSeparator != null) { + setTimeSeparator(timeSeparator); + } + parseTime(time); + } + + /** + * 设置时间字段的值 + * @param field 时间字段常量 + * @param value 时间字段的值 + */ + public void set(int field, int value) { + if(value < minFields[field]) { + throw new IllegalArgumentException(value + ", time value must be positive."); + } + fields[field] = value % (maxFields[field] + 1); + // 进行进位计算 + int carry = value / (maxFields[field] + 1); + if(carry > 0) { + int upFieldValue = get(field + 1); + set(field + 1, upFieldValue + carry); + } + } + + /** + * 获得时间字段的值 + * @param field 时间字段常量 + * @return 该时间字段的值 + */ + public int get(int field) { + if(field < 0 || field > fields.length - 1) { + throw new IllegalArgumentException(field + ", field value is error."); + } + return fields[field]; + } + + /** + * 将时间进行“加”运算，即加上一个时间 + * @param time 需要加的时间 + * @return 运算后的时间 + */ + public TimeUtils addTime(TimeUtils time) { + TimeUtils result = new TimeUtils(); + int up = 0; // 进位标志 + for (int i = 0; i < fields.length; i++) { + int sum = fields[i] + time.fields[i] + up; + up = sum / (maxFields[i] + 1); + result.fields[i] = sum % (maxFields[i] + 1); + } + return result; + } + + /** + * 将时间进行“减”运算，即减去一个时间 + * @param time 需要减的时间 + * @return 运算后的时间 + */ + public TimeUtils subtractTime(TimeUtils time) { + TimeUtils result = new TimeUtils(); + int down = 0; // 退位标志 + for (int i = 0, k = fields.length - 1; i < k; i++) { + int difference = fields[i] + down; + if (difference >= time.fields[i]) { + difference -= time.fields[i]; + down = 0; + } else { + difference += maxFields[i] + 1 - time.fields[i]; + down = -1; + } + result.fields[i] = difference; + } + result.fields[DAY] = fields[DAY] - time.fields[DAY] + down; + return result; + } + + /** + * 获得时间字段的分隔符 + * @return + */ + public String getTimeSeparator() { + return timeSeparator; + } + + /** + * 设置时间字段的分隔符（用于字符串格式的时间） + * @param timeSeparator 分隔符字符串 + */ + public void setTimeSeparator(String timeSeparator) { + this.timeSeparator = timeSeparator; + } + + private void initialize(int day, int hour, int minute, int second) { + set(DAY, day); + set(HOUR, hour); + set(MINUTE, minute); + set(SECOND, second); + } + + private void parseTime(String time) { + if(time == null) { + initialize(0, 0, 0, 0); + return; + } + String t = time; + int field = DAY; + set(field--, 0); + int p = -1; + while((p = t.indexOf(timeSeparator)) > -1) { + parseTimeField(time, t.substring(0, p), field--); + t = t.substring(p + timeSeparator.length()); + } + parseTimeField(time, t, field--); + } + + private void parseTimeField(String time, String t, int field) { + if(field < SECOND || t.length() < 1) { + parseTimeException(time); + } + char[] chs = t.toCharArray(); + int n = 0; + for(int i = 0; i < chs.length; i++) { + if(chs[i] <= ' ') { + continue; + } + if(chs[i] >= '0' && chs[i] <= '9') { + n = n * 10 + chs[i] - '0'; + continue; + } + parseTimeException(time); + } + set(field, n); + } + + private void parseTimeException(String time) { + throw new IllegalArgumentException(time + ", time format error, HH" + + this.timeSeparator + "mm" + this.timeSeparator + "ss"); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder(16); + sb.append(fields[DAY]).append(',').append(' '); + buildString(sb, HOUR).append(timeSeparator); + buildString(sb, MINUTE).append(timeSeparator); + buildString(sb, SECOND); + return sb.toString(); + } + + private StringBuilder buildString(StringBuilder sb, int field) { + if(fields[field] < 10) { + sb.append('0'); + } + return sb.append(fields[field]); + } + + @Override + public int hashCode() { + final int PRIME = 31; + int result = 1; + result = PRIME * result + Arrays.hashCode(fields); + return result; + } + + @Override + public boolean equals(Object obj) { + if (this == obj) { + return true; + } + if (obj == null) { + return false; + } + if (getClass() != obj.getClass()) { + return false; + } + final TimeUtils other = (TimeUtils) obj; + if (!Arrays.equals(fields, other.fields)) { + return false; + } + return true; + } + +} \ No newline at end of file diff --git a/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/UploadUtils.java b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/UploadUtils.java new file mode 100644 index 0000000000000000000000000000000000000000..8dd074f7d992fe92062572c480247fb20479d813 --- /dev/null +++ b/JeeSpringCloud/jeespring-framework/src/main/java/com/jeespring/common/utils/UploadUtils.java @@ -0,0 +1,344 @@ +package com.jeespring.common.utils; + +import java.io.File; +import java.io.IOException; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Date; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Random; + +import javax.servlet.http.HttpServletRequest; + +import org.apache.commons.fileupload.FileItem; +import org.apache.commons.fileupload.FileUploadException; +import org.apache.commons.fileupload.disk.DiskFileItemFactory; +import org.apache.commons.fileupload.servlet.ServletFileUpload; + +/** + * 文件上传工具类 + * + * @author yangdc + * @date Apr 18, 2012 + * + * + * + */ +public class UploadUtils { + /** + * 表单字段常量 + */ + public static final String FORM_FIELDS = "form_fields"; + /** + * 文件域常量 + */ + public static final String FILE_FIELDS = "file_fields"; + + // 最大文件大小 + private long maxSize = 1000000; + // 定义允许上传的文件扩展名 + private Map extMap = new HashMap(); + // 文件保存目录相对路径 + private String basePath = "upload"; + // 文件的目录名 + private String dirName = "images"; + // 上传临时路径 + private static final String TEMP_PATH = "/temp"; + private String tempPath = basePath + TEMP_PATH; + // 若不指定则文件名默认为 yyyyMMddHHmmss_xyz + private String fileName; + + // 文件保存目录路径 + private String savePath; + // 文件保存目录url + private String saveUrl; + // 文件最终的url包括文件名 + private String fileUrl; + + public UploadUtils() { + // 其中images,flashs,medias,files,对应文件夹名称,对应dirName + // key文件夹名称 + // value该文件夹内可以上传文件的后缀名 + extMap.put("images", "gif,jpg,jpeg,png,bmp"); + extMap.put("flashs", "swf,flv"); + extMap.put("medias", "swf,flv,mp3,wav,wma,wmv,mid,avi,mpg,asf,rm,rmvb"); + extMap.put("files", "doc,docx,xls,xlsx,ppt,htm,html,txt,zip,rar,gz,bz2"); + } + + /** + * 文件上传 + * + * @param request + * @return infos info[0] 验证文件域返回错误信息 info[1] 上传文件错误信息 info[2] savePath info[3] saveUrl info[4] fileUrl + */ + @SuppressWarnings("unchecked") + public String[] uploadFile(HttpServletRequest request) { + String[] infos = new String[5]; + // 验证 + infos[0] = this.validateFields(request); + // 初始化表单元素 + Map fieldsMap = new HashMap(); + if ("true".equals(infos[0])) { + fieldsMap = this.initFields(request); + } + // 上传 + List
+ *