getParam() {
+ return paramUpdateSet;
+ }
+
+ @Override
+ protected void renameByParamName() {
+
+ }
+}
diff --git a/common/src/main/java/com/qmrz/mybatis/sql/statement/WhereBlock.java b/common/src/main/java/com/qmrz/mybatis/sql/statement/WhereBlock.java
new file mode 100644
index 0000000..d9550d9
--- /dev/null
+++ b/common/src/main/java/com/qmrz/mybatis/sql/statement/WhereBlock.java
@@ -0,0 +1,18 @@
+package com.qmrz.mybatis.sql.statement;
+
+import com.qmrz.mybatis.sql.BaseWrapper;
+import com.qmrz.mybatis.sql.ConditionCount;
+
+/**
+ * sql: 无，只包装作用
+ */
+public class WhereBlock extends BaseWrapper {
+ /**
+ * @param isConditionAnd
+ * @param index 嵌套时，序号继承到新块
+ */
+ public WhereBlock(boolean isConditionAnd, ConditionCount index, Class classPO) {
+ super(0, 0, isConditionAnd ? 1 : 2, classPO);
+ this.setConditionsCount(index);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/CacheUtil.java b/common/src/main/java/com/qmrz/utils/CacheUtil.java
new file mode 100644
index 0000000..aba448a
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/CacheUtil.java
@@ -0,0 +1,27 @@
+package com.qmrz.utils;
+
+import net.sf.ehcache.Cache;
+import net.sf.ehcache.CacheManager;
+import net.sf.ehcache.Element;
+import java.io.Serializable;
+
+public class CacheUtil {
+ public static Cache getCache() {
+ CacheManager cacheManager = SpringContextUtil.getBean(CacheManager.class);
+ Cache cache = cacheManager.getCache("userCache");
+// CacheConfiguration config = cache.getCacheConfiguration();
+// config.setTimeToIdleSeconds(60);
+// config.setTimeToLiveSeconds(timeToLiveSeconds);
+ return cache;
+ }
+
+ public static Element get(String name) {
+ return getCache().get(name);
+ }
+
+ public static void put(String name, Serializable value, int timeToLive) {
+ Element el = new Element(name, value);
+ el.setTimeToLive(timeToLive);
+ getCache().put(el);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ConvertUtil.java b/common/src/main/java/com/qmrz/utils/ConvertUtil.java
new file mode 100644
index 0000000..6fb3444
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ConvertUtil.java
@@ -0,0 +1,334 @@
+package com.qmrz.utils;
+
+import org.apache.commons.codec.DecoderException;
+import org.apache.commons.codec.binary.Base64;
+import org.apache.commons.codec.binary.Hex;
+
+import java.io.*;
+import java.util.Collection;
+import java.util.Map;
+
+/**
+ * 功能：转换编码
+ *
+ * @author xiongliang
+ *
+ * mobile enterprise application platform
+ * Version 0.1
+ */
+public class ConvertUtil {
+ public static final String LINE_SEPARATOR = System.getProperty("line.separator");
+ private static final char[] BASE62 = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz".toCharArray();
+ /**
+ * 7位ASCII字符，也叫作ISO646-US、Unicode字符集的基本拉丁块
+ */
+ public static final String US_ASCII = "US-ASCII";
+ /**
+ * ISO 拉丁字母表 No.1，也叫作 ISO-LATIN-1
+ */
+ public static final String ISO_8859_1 = "ISO-8859-1";
+ /**
+ * 8 位 UCS 转换格式
+ */
+ public static final String UTF_8 = "UTF-8";
+ /**
+ * 16 位 UCS 转换格式，Big Endian（最低地址存放高位字节）字节顺序
+ */
+ public static final String UTF_16BE = "UTF-16BE";
+ /**
+ * 16 位 UCS 转换格式，Little-endian（最高地址存放低位字节）字节顺序
+ */
+ public static final String UTF_16LE = "UTF-16LE";
+ /**
+ * 16 位 UCS 转换格式，字节顺序由可选的字节顺序标记来标识
+ */
+ public static final String UTF_16 = "UTF-16";
+ /**
+ * 中文超大字符集
+ */
+ public static final String GBK = "GBK";
+ /**
+ * 繁体中文
+ */
+ public static final String BIG_5 = "BIG5";
+
+ /**
+ * 是否是null
+ *
+ * @param term
+ * @return
+ */
+ public static boolean isNull(String term) {
+ return !isNotNull(term);
+ }
+
+ /**
+ * 是否是非null
+ *
+ * @param term
+ * @return
+ */
+ public static boolean isNotNull(String term) {
+ if (term == null) return false;
+ if (term.trim().length() < 1) return false;
+ return true;
+ }
+
+ /**
+ * 字符串编码转换的实现方法
+ *
+ * @param strIn
+ * @param sourceCharset
+ * @param targetCharset
+ * @return
+ */
+ public static String convertCharset(String strIn, String sourceCharset, String targetCharset) {
+ if (isNull(strIn))
+ return strIn;
+ String strOut = null;
+ try {
+ byte[] c = strIn.getBytes(sourceCharset);
+ strOut = new String(c, targetCharset);
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+ return strOut;
+ }
+
+ /**
+ * 获得UTF8编码的字符串
+ *
+ * @param gbkStr
+ * @return
+ */
+ public static String convertGbkToUft8(String gbkStr) {
+ try {
+ return new String(convertGbkToUtf8Bytes(gbkStr), UTF_8);
+ } catch (UnsupportedEncodingException e) {
+ throw new InternalError();
+ }
+ }
+ /**
+ * GBK转UTF-8编码
+ * @param text
+ * @return
+ */
+ /*public static String convertGbkToUft8(String text){
+ String utf = null;
+ try {
+ String iso = new String(text.getBytes(UTF_8),ISO_8859_1);
+ utf = new String(iso.getBytes(ISO_8859_1),UTF_8);
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+ return utf;
+ }*/
+
+ /**
+ * 获得UTF8编码的字节数组
+ *
+ * @param gbkStr
+ * @return
+ */
+ public static byte[] convertGbkToUtf8Bytes(String gbkStr) {
+ int n = gbkStr.length();
+ byte[] utfBytes = new byte[3 * n];
+ int k = 0;
+ for (int i = 0; i < n; i++) {
+ int m = gbkStr.charAt(i);
+ if (m < 128 && m >= 0) {
+ utfBytes[k++] = (byte) m;
+ continue;
+ }
+ utfBytes[k++] = (byte) (0xe0 | (m >> 12));
+ utfBytes[k++] = (byte) (0x80 | ((m >> 6) & 0x3f));
+ utfBytes[k++] = (byte) (0x80 | (m & 0x3f));
+ }
+ if (k < utfBytes.length) {
+ byte[] tmp = new byte[k];
+ System.arraycopy(utfBytes, 0, tmp, 0, k);
+ return tmp;
+ }
+ return utfBytes;
+ }
+
+ /**
+ * 输入流转字符串
+ *
+ * @param is
+ * @return
+ */
+ public static String convertStreamToString(InputStream is) {
+ BufferedReader reader = new BufferedReader(new InputStreamReader(is));
+ StringBuilder sb = new StringBuilder();
+ String line = null;
+ try {
+ while ((line = reader.readLine()) != null) {
+ sb.append(line + LINE_SEPARATOR);
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ is.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ return sb.toString();
+ }
+
+ /**
+ * 半角转换成全角
+ *
+ * @param input
+ * @return
+ */
+ public static String convertSBC(String input) {
+ // 半角转全角
+ char[] c = input.toCharArray();
+ for (int i = 0; i < c.length; i++) {
+ if (c[i] == 32) {
+ c[i] = (char) 12288;
+ continue;
+ }
+ if (c[i] < 127)
+ c[i] = (char) (c[i] + 65248);
+ }
+ return new String(c);
+ }
+
+ /**
+ * 全角转换成半角
+ *
+ * @param input
+ * @return
+ */
+ public static String convertDBC(String input) {
+ // 全角转 半角
+ char[] c = input.toCharArray();
+ for (int i = 0; i < c.length; i++) {
+ if (c[i] == 12288) {
+ c[i] = (char) 32;
+ continue;
+ }
+ if (c[i] > 65280 && c[i] < 65375)
+ c[i] = (char) (c[i] - 65248);
+ }
+ return new String(c);
+ }
+
+ /**
+ * Hex编码.
+ */
+ public static String convertEncodeHex(byte[] input) {
+ return Hex.encodeHexString(input);
+ }
+
+ /**
+ * Hex解码.
+ */
+ public static byte[] convertDecodeHex(String input) {
+ try {
+ return Hex.decodeHex(input.toCharArray());
+ } catch (DecoderException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * Base64编码.
+ */
+ public static String convertEncodeBase64(byte[] input) {
+ return Base64.encodeBase64String(input);
+ }
+
+ /**
+ * Base64编码, URL安全(将Base64中的URL非法字符'+'和'/'转为'-'和'_', 见RFC3548).
+ */
+ public static String convertEncodeUrlSafeBase64(byte[] input) {
+ return Base64.encodeBase64URLSafeString(input);
+ }
+
+ /**
+ * Base64解码.
+ */
+ public static byte[] convertDecodeBase64(String input) {
+ return Base64.decodeBase64(input);
+ }
+
+ /**
+ * Base62编码。
+ */
+ public static String convertEncodeBase62(byte[] input) {
+ char[] chars = new char[input.length];
+ for (int i = 0; i < input.length; i++) {
+ chars[i] = BASE62[((input[i] & 0xFF) % BASE62.length)];
+ }
+ return new String(chars);
+ }
+
+ /**
+ * 输入或读取数据库之前的转换
+ * @param src
+ * @return
+ */
+ public static String toReadStr(Object src) {
+ String s = ""; //$NON-NLS-1$
+ if (src != null) {
+ // 读字符编码转换
+ s = src.toString().trim();
+ s = s.replaceAll("<", "<"); //$NON-NLS-1$ //$NON-NLS-2$
+ s = s.replaceAll(">", ">"); //$NON-NLS-1$ //$NON-NLS-2$
+ s = s.replaceAll("\"", "“"); //$NON-NLS-1$ //$NON-NLS-2$
+ }
+ return s;
+ }
+ /**
+ * 字符串转换成整形
+ * @param src
+ * @return
+ */
+ public static Integer toInteger(Object src) {
+ String s = toReadStr(src);
+ Integer i = 0;
+ if (!"".equals(s)) { //$NON-NLS-1$
+ try {
+ i = Integer.parseInt(s);
+ } catch (NumberFormatException e) {
+ i = 0;
+ }
+ }
+ return i;
+ }
+ public static boolean isEmpty(Object pObj) {
+ if (pObj == null)
+ return true;
+ if (pObj.equals(""))
+ return true;
+ if (pObj instanceof String) {
+ if (((String) pObj).length() == 0) {
+ return true;
+ }
+ } else if (pObj instanceof Collection) {
+ if (((Collection) pObj).size() == 0) {
+ return true;
+ }
+ } else if (pObj instanceof Map) {
+ if (((Map) pObj).size() == 0) {
+ return true;
+ }
+ }
+ return false;
+ }
+
+ public static boolean isEmptyError(Map map,final String... headers) {
+ for (int i = 0; i < headers.length; i++) {
+ if (isEmpty(map.get(headers[i]))) {
+ return true;
+ }
+ }
+ return false;
+ }
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/DBHelper.java b/common/src/main/java/com/qmrz/utils/DBHelper.java
new file mode 100644
index 0000000..d60b598
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/DBHelper.java
@@ -0,0 +1,184 @@
+package com.qmrz.utils;
+
+import org.apache.ibatis.cursor.Cursor;
+import org.apache.ibatis.executor.BatchResult;
+import org.apache.ibatis.session.Configuration;
+import org.apache.ibatis.session.ResultHandler;
+import org.apache.ibatis.session.RowBounds;
+import org.apache.ibatis.session.SqlSession;
+import org.mybatis.spring.SqlSessionTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.sql.Connection;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 基于mybatis的数据库操作类，无需mapper接口，直接调用xml的sql
+ */
+@Component
+public class DBHelper implements SqlSession {
+ SqlSessionTemplate sql;
+ private static final String statementPrefix = "com.qmrz.domain.mapper.";
+
+ public String getStatement(String id) {
+ return statementPrefix + id;
+ }
+
+ @Autowired
+ public DBHelper(SqlSessionTemplate sqlSessionTemplate) {
+ this.sql = sqlSessionTemplate;
+ }
+
+ @Override
+ public T selectOne(String statement) {
+ return sql.selectOne(getStatement(statement));
+ }
+
+ @Override
+ public T selectOne(String statement, Object parameter) {
+ return sql.selectOne(getStatement(statement), parameter);
+ }
+
+ @Override
+ public List selectList(String statement) {
+ return sql.selectList(getStatement(statement));
+ }
+
+ @Override
+ public List selectList(String statement, Object parameter) {
+ return sql.selectList(getStatement(statement), parameter);
+ }
+
+ @Override
+ public List selectList(String statement, Object parameter, RowBounds rowBounds) {
+ return sql.selectList(getStatement(statement), parameter, rowBounds);
+ }
+
+ @Override
+ public Map selectMap(String statement, String mapKey) {
+ return sql.selectMap(getStatement(statement), mapKey);
+ }
+
+ @Override
+ public Map selectMap(String statement, Object parameter, String mapKey) {
+ return sql.selectMap(getStatement(statement), parameter, mapKey);
+ }
+
+ @Override
+ public Map selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds) {
+ return sql.selectMap(getStatement(statement), parameter, mapKey, rowBounds);
+ }
+
+ @Override
+ public Cursor selectCursor(String statement) {
+ return sql.selectCursor(getStatement(statement));
+ }
+
+ @Override
+ public Cursor selectCursor(String statement, Object parameter) {
+ return sql.selectCursor(getStatement(statement), parameter);
+ }
+
+ @Override
+ public Cursor selectCursor(String statement, Object parameter, RowBounds rowBounds) {
+ return sql.selectCursor(getStatement(statement), parameter, rowBounds);
+ }
+
+ @Override
+ public void select(String statement, Object parameter, ResultHandler handler) {
+ sql.select(getStatement(statement), parameter, handler);
+ }
+
+ @Override
+ public void select(String statement, ResultHandler handler) {
+ sql.select(getStatement(statement), handler);
+ }
+
+ @Override
+ public void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
+ sql.select(getStatement(statement), parameter, rowBounds, handler);
+ }
+
+ @Override
+ public int insert(String statement) {
+ return sql.insert(getStatement(statement));
+ }
+
+ @Override
+ public int insert(String statement, Object parameter) {
+ return sql.insert(getStatement(statement), parameter);
+ }
+
+ @Override
+ public int update(String statement) {
+ return sql.update(getStatement(statement));
+ }
+
+ @Override
+ public int update(String statement, Object parameter) {
+ return sql.update(getStatement(statement), parameter);
+ }
+
+ @Override
+ public int delete(String statement) {
+ return sql.delete(getStatement(statement));
+ }
+
+ @Override
+ public int delete(String statement, Object parameter) {
+ return sql.delete(getStatement(statement), parameter);
+ }
+
+ @Override
+ public void commit() {
+ sql.commit();
+ }
+
+ @Override
+ public void commit(boolean force) {
+ sql.commit(force);
+ }
+
+ @Override
+ public void rollback() {
+ sql.rollback();
+ }
+
+ @Override
+ public void rollback(boolean force) {
+ sql.rollback(force);
+ }
+
+ @Override
+ public List flushStatements() {
+ return sql.flushStatements();
+ }
+
+ @Override
+ public void close() {
+ sql.close();
+ }
+
+ @Override
+ public void clearCache() {
+ sql.clearCache();
+ }
+
+ @Override
+ public Configuration getConfiguration() {
+ return sql.getConfiguration();
+ }
+
+ @Override
+ public T getMapper(Class type) {
+ return sql.getMapper(type);
+ }
+
+ @Override
+ public Connection getConnection() {
+ return sql.getConnection();
+ }
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/DateTimeUtil.java b/common/src/main/java/com/qmrz/utils/DateTimeUtil.java
new file mode 100644
index 0000000..94a0b12
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/DateTimeUtil.java
@@ -0,0 +1,145 @@
+package com.qmrz.utils;
+
+import java.text.SimpleDateFormat;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.TemporalAccessor;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Locale;
+import java.util.TimeZone;
+
+public class DateTimeUtil {
+ private static final DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ private static final DateTimeFormatter dtfDate = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+ private static ThreadLocal ThreadDateTime = new ThreadLocal();
+
+ //日期时间类型格式
+ private static final String DATETIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
+
+ private static final DateTimeFormatter dtfGMT = DateTimeFormatter.ofPattern("EEE, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH)
+ .withZone(TimeZone.getTimeZone("GMT").toZoneId());
+
+ public static String format(TemporalAccessor dateTime) {
+ return dtf.format(dateTime);
+ }
+
+ public static String format(TemporalAccessor dateTime, String format) {
+ return DateTimeFormatter.ofPattern(format).format(dateTime);
+ }
+
+ public static String formatDate(TemporalAccessor dateTime) {
+ return dtfDate.format(dateTime);
+ }
+
+ public static String datePlus(String date,int days){
+ //结束日期需要加一天，api同步时不包含结束日期
+ DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ LocalDateTime local = LocalDateTime.from(dtf.parse(date+" 00:00:00")).plusDays(days);
+ return formatDate(local);
+ }
+
+// public static String formatBySecond(long second) {
+// return dtf.format(LocalDateTime.ofEpochSecond(second, 0, ZoneOffset.ofHours(8)));
+// }
+//
+// public static String formatDataBySecond(long second) {
+// return dtfDate.format(LocalDateTime.ofEpochSecond(second, 0, ZoneOffset.ofHours(8)));
+// }
+
+ public static String formatGMTBySecond(long second) {
+ return dtfGMT.format(LocalDateTime.ofEpochSecond(second, 0
+ , ZoneOffset.ofHours(0)));
+ }
+
+ /**
+ * 获取当前日期 毫秒
+ *
+ * @return
+ */
+ public static long getTimeInMillis() {
+ Calendar now = Calendar.getInstance();
+
+ return now.getTimeInMillis();
+ }
+
+ /**
+ * 时间字符串 解析为 时间戳（毫秒）
+ *
+ * @param time 时间，如：2018-08-06 04:52:50 127
+ * @param format 时间格式，如：yyyy-MM-dd HH:mm:ss SSS
+ * @param zone 时区，如：ZoneOffset.ofHours(8)
+ * @return
+ */
+ public static Long getTimeInMillis(String time, String format, ZoneOffset zone) {
+ Instant instant = getInstant(time, format, zone);
+ return instant.toEpochMilli();
+ }
+
+ /**
+ * 获取当前日期 秒
+ *
+ * @return
+ */
+ public static long getTimeInSeconds() {
+ return getTimeInMillis() / 1000L;
+ }
+
+ /**
+ * 时间字符串 解析为 时间戳（秒）
+ *
+ * @param time 时间，如：2018-08-06 04:52:50 127
+ * @param format 时间格式，如：yyyy-MM-dd HH:mm:ss SSS
+ * @param zone 时区，如：ZoneOffset.ofHours(8)
+ * @return
+ */
+ public static Long getTimeInSeconds(String time, String format, ZoneOffset zone) {
+ Instant instant = getInstant(time, format, zone);
+ return instant.getEpochSecond();
+ }
+
+ /**
+ * 时间字符串 解析为 时刻对象
+ *
+ * @param time
+ * @param format
+ * @param zone
+ * @return
+ */
+ public static Instant getInstant(String time, String format, ZoneOffset zone) {
+ DateTimeFormatter df = DateTimeFormatter.ofPattern(format);
+ Instant instant = LocalDateTime.parse(time, df).atZone(zone).toInstant();
+ return instant;
+ }
+
+ /**
+ * 获取时刻 时间戳 转 时刻
+ *
+ * @param timestamp
+ * @return
+ */
+ public static Instant getInstant(long timestamp) {
+ return Instant.ofEpochSecond(timestamp);
+ }
+
+ /**
+ * 获取当前日期时间
+ *
+ * @return 返回当前时间的字符串值
+ */
+ public static String currentDateTime() {
+ return DateTimeInstance().format(new Date());
+ }
+
+ private static SimpleDateFormat DateTimeInstance() {
+ SimpleDateFormat df = ThreadDateTime.get();
+ if (df == null) {
+ df = new SimpleDateFormat(DATETIME_FORMAT);
+ ThreadDateTime.set(df);
+ }
+ return df;
+ }
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/ExportPOIUtils.java b/common/src/main/java/com/qmrz/utils/ExportPOIUtils.java
new file mode 100644
index 0000000..4c0b2ad
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ExportPOIUtils.java
@@ -0,0 +1,191 @@
+package com.qmrz.utils;
+import java.awt.image.BufferedImage;
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.Method;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.imageio.ImageIO;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.ibatis.reflection.MetaObject;
+import org.apache.ibatis.reflection.SystemMetaObject;
+import org.apache.poi.hssf.usermodel.HSSFClientAnchor;
+import org.apache.poi.hssf.usermodel.HSSFPatriarch;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.CellStyle;
+import org.apache.poi.ss.usermodel.Font;
+import org.apache.poi.ss.usermodel.IndexedColors;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+
+
+public class ExportPOIUtils {
+ //参数说明: fileName：文件名 projects：对象集合 columnNames： 列名 keys： map中的key
+ public static void start_download(HttpServletResponse response, String fileName, List projects,
+ String[] columnNames, String[] keys) throws IOException {
+
+ //将集合中对象的属性 对应到 List>
+ List> list=createExcelRecord(projects, keys);
+
+ ByteArrayOutputStream os = new ByteArrayOutputStream();
+ try {
+ //将转换成的Workbook对象通过流形式下载
+ createWorkBook(list,keys,columnNames).write(os);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ byte[] content = os.toByteArray();
+ InputStream is = new ByteArrayInputStream(content);
+ // 设置response参数，可以打开下载页面
+ response.reset();
+ response.setContentType("application/vnd.ms-excel;charset=utf-8");
+ response.setHeader("Content-Disposition", "attachment;filename="+ new String((fileName + ".xls").getBytes(), "utf-8"));
+ ServletOutputStream out = response.getOutputStream();
+ BufferedInputStream bis = null;
+ BufferedOutputStream bos = null;
+ try {
+ bis = new BufferedInputStream(is);
+ bos = new BufferedOutputStream(out);
+ byte[] buff = new byte[2048];
+ int bytesRead;
+ while (-1 != (bytesRead = bis.read(buff, 0, buff.length))) {
+ bos.write(buff, 0, bytesRead);
+ }
+
+ } catch (final IOException e) {
+ throw e;
+ } finally {
+ if (bis != null)
+ bis.close();
+ if (bos != null)
+ bos.close();
+ }
+ }
+
+ private static List> createExcelRecord(List projects, String[] keys) {
+ List> listmap = new ArrayList>();
+ Map map = new HashMap();
+ map.put("sheetName", "sheet");
+ listmap.add(map);
+ Object project=null;
+ for (int j = 0; j < projects.size(); j++) {
+ project=projects.get(j);
+ Map mapValue = new HashMap();
+ for(int i=0; i> list,String []keys,String columnNames[]) {
+ // 创建excel工作簿
+ Workbook wb = new HSSFWorkbook();
+ // 创建第一个sheet（页），并命名
+ Sheet sheet = wb.createSheet(list.get(0).get("sheetName").toString());
+ // 手动设置列宽。第一个参数表示要为第几列设；，第二个参数表示列的宽度，n为列高的像素数。
+ for(int i=0;i 0) || (len < value.length())) ? value.substring(st, len) : value;
+ }
+
+ /**
+ * 是否来自ajax请求
+ *
+ * @param requestContent
+ * @return
+ */
+ public static Boolean requestIsAjax(String requestContent) {
+ if (requestContent == null || requestContent.length() == 0) {
+ return false;
+ }
+ JSONObject o = null;
+ try {
+ o = Json.toObject(requestContent);
+ } catch (Throwable e) {
+ return false;
+ }
+
+ if (!o.containsKey("ajax")) {
+ return false;
+ }
+ return new Integer("1").equals(o.get("ajax"));
+ }
+
+ /**
+ * 是否来自ajax请求
+ *
+ * @param inputStream
+ * @return
+ */
+ public static Boolean requestIsAjax(InputStream inputStream) {
+ String input = StreamUtil.inputToString(inputStream).toString();
+ return requestIsAjax(input);
+ }
+
+ public static String urlEnodeUTF8(String str) {
+ String result = str;
+ try {
+ result = URLEncoder.encode(str, "UTF-8");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return result;
+ }
+
+ /**
+ * 获取一定长度的随机字符串
+ *
+ * @param length 指定字符串长度
+ * @return 一定长度的字符串
+ */
+ public static String getRandomString(int length) {
+ String base = "abcdefghijklmnopqrstuvwxyz0123456789";
+ Random random = new Random();
+ StringBuffer sb = new StringBuffer();
+ for (int i = 0; i < length; i++) {
+ int number = random.nextInt(base.length());
+ sb.append(base.charAt(number));
+ }
+ return sb.toString();
+ }
+
+ /**
+ * 生成指定位数数字
+ *
+ * @param length
+ * @return
+ */
+ public static String getRandomNumber(int length) {
+ // 生成随机n位码
+ String s = "";
+ while (s.length() < 4) {
+ s += (int) (Math.random() * 10);
+ }
+ return s;
+ }
+
+ /**
+ * 生成唯一字符串，去除横杆
+ *
+ * @return
+ */
+ public static String getUUID() {
+ return UUID.randomUUID().toString().replace("-", "");
+ }
+
+ /**
+ * 对象序列化为字符串
+ *
+ * @return
+ */
+ public static String objectSerialize(Object obj) {
+ ByteArrayOutputStream byteOutput = new ByteArrayOutputStream();
+ try {
+ ObjectOutputStream outputStream = new ObjectOutputStream(byteOutput);
+ outputStream.writeObject(obj);
+ String str = byteOutput.toString("ISO-8859-1");
+
+ return str;
+ } catch (IOException e) {
+ e.printStackTrace();
+ return "error:" + e.getMessage();
+ }
+ }
+
+ /**
+ * 字符串反序列化为对象
+ *
+ * @param str
+ * @return
+ */
+ public static Object objectDeserialize(String str) {
+ try {
+ ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(str.getBytes("ISO-8859-1"));
+ ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);
+ Object obj = objectInputStream.readObject();
+ return obj;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return "error:" + e.getMessage();
+ }
+ }
+
+ /**
+ * 首字母大写
+ *
+ * @param str
+ * @return
+ */
+ public static String firstUpperCase(String str) {
+ if (str == null) {
+ return null;
+ }
+ if (0 == str.length()) {
+ return "";
+ }
+
+ return str.substring(0, 1).toUpperCase() + str.substring(1);
+ }
+
+ /**
+ * 首字母大写（高性能，待验证）
+ *
+ * @param str
+ * @return
+ */
+ public static String firstUpperCase2(String str) {
+ if (str == null) {
+ return null;
+ }
+ if (0 == str.length()) {
+ return "";
+ }
+
+ char[] arr = str.toCharArray();
+ arr[0] -= 32;
+ return String.valueOf(arr);
+ }
+
+ /**
+ * 手动metaspace扩容，以便即时触发，释放OC内存（非回收）
+ *
+ * @param cou 扩容数量
+ * @param sleepSecond sleepSecond 秒后执行
+ */
+ public static void addMetaspace(int cou, long sleepSecond) {
+ log.info("准备metaspace扩容：" + cou + "个");
+ try {
+ //5秒后发生
+ Thread.sleep(sleepSecond * 1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ StringBuffer sb = new StringBuffer();
+ sb.append("package com.qmrz.utils.classload;\n");
+ sb.append("public class MetaspaceEmptyCapacityExpansion");
+
+ StringBuffer sb2 = new StringBuffer();
+ sb2.append(" {\n");
+ sb2.append("private static String str = String.valueOf(System.currentTimeMillis());\n");
+ sb2.append("public void test(){}\n");
+ for (int i = 0; i < 1000; i++) {
+ sb2.append("public void test" + String.valueOf(i) + "(){}\n");
+ }
+ sb2.append("}");
+
+ List> claList = new ArrayList<>();
+ JavaStringCompiler compiler = new JavaStringCompiler();
+ for (int i = 0; i < cou; i++) {
+ String strI = String.valueOf(i);
+ StringBuffer tmp = new StringBuffer();
+ tmp.append(sb);
+ tmp.append(strI);
+ tmp.append(sb2);
+
+ Map results = null;
+ try {
+ results = compiler.compile("MetaspaceEmptyCapacityExpansion" + strI + ".java", tmp.toString());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+
+ try {
+ Class clazz = compiler.loadClass("com.qmrz.utils.classload.MetaspaceEmptyCapacityExpansion" + strI, results);
+ claList.add(clazz);
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ tmp = null;
+ log.info("忽略警告 " + i);
+ }
+
+ claList.clear();
+ claList = null;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/FreemarkerExceptionHandler.java b/common/src/main/java/com/qmrz/utils/FreemarkerExceptionHandler.java
new file mode 100644
index 0000000..e1cb729
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/FreemarkerExceptionHandler.java
@@ -0,0 +1,14 @@
+package com.qmrz.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+public class FreemarkerExceptionHandler {
+// @Bean
+// freemarker.template.Configuration freeMarkerConfig() {
+// return
+// }
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/Identities.java b/common/src/main/java/com/qmrz/utils/Identities.java
new file mode 100644
index 0000000..f875dba
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/Identities.java
@@ -0,0 +1,80 @@
+package com.qmrz.utils;
+
+import java.security.SecureRandom;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Random;
+import java.util.UUID;
+import java.util.concurrent.atomic.AtomicLong;
+
+public class Identities {
+ private static SecureRandom random = new SecureRandom();
+ private static AtomicLong atomicLongID = new AtomicLong(10000L);
+
+ public static String uuid() {
+ return UUID.randomUUID().toString();
+ }
+
+ public static String uuid2() {
+ return UUID.randomUUID().toString().replaceAll("-", "");
+ }
+
+ public static long randomLong() {
+ return Math.abs(random.nextLong());
+ }
+
+ public static String randomBase62(int length) {
+ byte[] randomBytes = new byte[length];
+ random.nextBytes(randomBytes);
+ return ConvertUtil.convertEncodeBase62(randomBytes);
+ }
+
+ /**
+ * 连接对象
+ * @param objs
+ * @return
+ */
+ public static String concat(Object...objs) {
+
+ if(objs==null || objs.length<1)return "";
+ StringBuffer sb = new StringBuffer();
+ for(Object obj : objs){
+ sb.append(obj==null?"":obj.toString());
+ }
+ return sb.toString();
+ }
+
+ // 将date类型转换为字符串yyyy年MM月dd日
+ public static String changeDateTOStr5(Date date,String pattern) {
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日");
+ return getDateToStr(date, sdf);
+ }
+ private static String getDateToStr(Date date, SimpleDateFormat sdf) {
+ String dateStr = null;
+ try {
+ dateStr = sdf.format(date);
+ return dateStr;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+ public static String getTimeMillisSequence() {
+ long nanoTime = System.nanoTime();
+ String preFix = null;
+ if (nanoTime < 0L) {
+ preFix = "A";
+ nanoTime = nanoTime + 9223372036854775807L + 1L;
+ } else {
+ preFix = "Z";
+ }
+ String nanoTimeStr = String.valueOf(nanoTime);
+ int difBit = String.valueOf(9223372036854775807L).length() - nanoTimeStr.length();
+ for (int i = 0; i < difBit; i++) {
+ preFix = concat(new Object[]{preFix, "0"});
+ }
+ long last = atomicLongID.getAndIncrement() % 10000L + 10000L;
+ return concat(new Object[]{changeDateTOStr5(new Date(), "yyyyMMddHHmmssSSS"), preFix, nanoTimeStr, Long.valueOf(last)});
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ImageUtil.java b/common/src/main/java/com/qmrz/utils/ImageUtil.java
new file mode 100644
index 0000000..17b76d0
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ImageUtil.java
@@ -0,0 +1,39 @@
+package com.qmrz.utils;
+
+import javax.swing.*;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+
+public class ImageUtil {
+ public static BufferedImage toBufferedImage(Image image) {
+ if (image instanceof BufferedImage) {
+ return (BufferedImage) image;
+ }
+ // This code ensures that all the pixels in the image are loaded
+ image = new ImageIcon(image).getImage();
+ BufferedImage bimage = null;
+ GraphicsEnvironment ge = GraphicsEnvironment
+ .getLocalGraphicsEnvironment();
+ try {
+ int transparency = Transparency.OPAQUE;
+ GraphicsDevice gs = ge.getDefaultScreenDevice();
+ GraphicsConfiguration gc = gs.getDefaultConfiguration();
+ bimage = gc.createCompatibleImage(image.getWidth(null),
+ image.getHeight(null), transparency);
+ } catch (HeadlessException e) {
+ // The system does not have a screen
+ }
+ if (bimage == null) {
+ // Create a buffered image using the default color model
+ int type = BufferedImage.TYPE_INT_RGB;
+ bimage = new BufferedImage(image.getWidth(null),
+ image.getHeight(null), type);
+ }
+ // Copy image to buffered image
+ Graphics g = bimage.createGraphics();
+ // Paint the image onto the buffered image
+ g.drawImage(image, 0, 0, null);
+ g.dispose();
+ return bimage;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/JWTUtil.java b/common/src/main/java/com/qmrz/utils/JWTUtil.java
new file mode 100644
index 0000000..559aacc
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/JWTUtil.java
@@ -0,0 +1,38 @@
+package com.qmrz.utils;
+
+import com.auth0.jwt.JWT;
+import com.auth0.jwt.JWTVerifier;
+import com.auth0.jwt.algorithms.Algorithm;
+import com.auth0.jwt.interfaces.DecodedJWT;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+public class JWTUtil {
+ public static String sign(String userName, String userID, String secret, long expireTime) {
+ Date date = new Date(System.currentTimeMillis() + expireTime);
+ Algorithm algorithm = Algorithm.HMAC256(secret);
+ Map header = new HashMap<>();
+ header.put("type", "jwt");
+ header.put("alg", "HS256");
+
+ String result = JWT.create().withHeader(header)
+ .withClaim("loginName", userName)
+ .withClaim("userID", userID)
+ .withExpiresAt(date)
+ .sign(algorithm);
+ return result;
+ }
+
+ public static boolean verify(String secret, String token) {
+ Algorithm algorithm = Algorithm.HMAC256(secret);
+ JWTVerifier verifier = JWT.require(algorithm).build();
+ try {
+ DecodedJWT decodedJWT = verifier.verify(token);
+ return true;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/Json.java b/common/src/main/java/com/qmrz/utils/Json.java
new file mode 100644
index 0000000..ffc8392
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/Json.java
@@ -0,0 +1,23 @@
+package com.qmrz.utils;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+
+public class Json {
+ public static JSONObject toObject(String str){
+ return JSON.parseObject(str);
+ }
+
+ public static JSONArray toArray(String str){
+ return JSON.parseArray(str);
+ }
+
+ public static Object parse(String str){
+ return JSON.parse(str);
+ }
+
+ public static String toString(Object obj){
+ return JSON.toJSONString(obj);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ListPageUtil.java b/common/src/main/java/com/qmrz/utils/ListPageUtil.java
new file mode 100644
index 0000000..a08623e
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ListPageUtil.java
@@ -0,0 +1,45 @@
+package com.qmrz.utils;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
+
+/**
+ * 集合分页
+ */
+@Slf4j
+public class ListPageUtil {
+ private List data;
+ private int pageSize;
+
+ private int pageCount;
+ private int rowCount;
+
+ public int getPageCount() {
+ return pageCount;
+ }
+
+ public ListPageUtil(List data, int pageSize){
+ this.data = data;
+ this.rowCount = data.size();
+ this.pageSize = pageSize;
+ this.pageCount = this.rowCount / pageSize;
+ if (this.rowCount % pageSize != 0) {
+ this.pageCount++;
+ }
+ }
+
+ public List start(int pageIndex) {
+ int fromIndex = this.pageSize * (pageIndex - 1);
+ int toIndex = fromIndex + this.pageSize;
+ if (toIndex > this.rowCount) {
+ toIndex = this.rowCount;
+ }
+ if (pageIndex > this.pageCount) {
+ fromIndex = 0;
+ toIndex = 0;
+ }
+ log.info("pageIndex="+pageIndex+", fromIndex="+fromIndex+", toIndex="+toIndex+",");
+ return this.data.subList(fromIndex, toIndex);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/MD5Util.java b/common/src/main/java/com/qmrz/utils/MD5Util.java
new file mode 100644
index 0000000..902ad78
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/MD5Util.java
@@ -0,0 +1,55 @@
+package com.qmrz.utils;
+
+
+import java.security.MessageDigest;
+
+public class MD5Util {
+
+ private static String byteArrayToHexString(byte b[]) {
+ StringBuffer resultSb = new StringBuffer();
+ for (int i = 0; i < b.length; i++)
+ resultSb.append(byteToHexString(b[i]));
+
+ return resultSb.toString();
+ }
+
+ private static String byteToHexString(byte b) {
+ int n = b;
+ if (n < 0)
+ n += 256;
+ int d1 = n / 16;
+ int d2 = n % 16;
+ return hexDigits[d1] + hexDigits[d2];
+ }
+
+ public static String md5Encode(String origin, String charsetname) {
+ String resultString = null;
+ try {
+ resultString = new String(origin);
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ if (charsetname == null || "".equals(charsetname))
+ resultString = byteArrayToHexString(md.digest(resultString
+ .getBytes()));
+ else
+ resultString = byteArrayToHexString(md.digest(resultString
+ .getBytes(charsetname)));
+ } catch (Exception exception) {
+ }
+ return resultString;
+ }
+
+ public static String getMD5Code(String origin) {
+ String resultString = null;
+ try {
+ resultString = new String(origin);
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ resultString = byteArrayToHexString(md.digest(resultString
+ .getBytes("utf-8")));
+ } catch (Exception exception) {
+ }
+ return resultString;
+ }
+ private static final String hexDigits[] = { "0", "1", "2", "3", "4", "5",
+ "6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/MapChain.java b/common/src/main/java/com/qmrz/utils/MapChain.java
new file mode 100644
index 0000000..a5f9c39
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/MapChain.java
@@ -0,0 +1,37 @@
+package com.qmrz.utils;
+
+import java.util.Map;
+
+/**
+ * Map 链式快速使用
+ * @param
+ * @param
+ */
+public class MapChain {
+ private Map map;
+
+ public MapChain(Map map) {
+ this.map = map;
+ }
+
+ /**
+ * 可链式使用put
+ * 如 put(k,v).put(k,v).put(k,v).put(k,v).put(k,v).getMap()
+ * @param k
+ * @param v
+ * @return
+ */
+ @SuppressWarnings("unchecked")
+ public MapChain put(Object k, Object v) {
+ map.put((K)k, (V)v);
+ return this;
+ }
+
+ /**
+ * 快速获取当前map
+ * @return
+ */
+ public Map getMap() {
+ return map;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/MapUtil.java b/common/src/main/java/com/qmrz/utils/MapUtil.java
new file mode 100644
index 0000000..d72d1bb
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/MapUtil.java
@@ -0,0 +1,50 @@
+package com.qmrz.utils;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public class MapUtil {
+ /**
+ * 快速创建Map
+ * 转http提交的参数形式
+ *
+ * @param map
+ * @return
+ */
+ public static StringBuffer toParam(Map map) {
+ StringBuffer strParam = new StringBuffer();
+ if (map == null) {
+ return strParam;
+ }
+ int i = 0;
+ for (String key : map.keySet()) {
+ i++;
+ if (i == 1) {
+ strParam.append(key + "=" + map.get(key));
+ } else {
+ strParam.append("&" + key + "=" + map.get(key));
+ }
+ }
+ return strParam;
+ }
+
+ /**
+ * 快速创建map
+ * @return
+ */
+ public static MapChain newMap() {
+ return new MapChain<>(new LinkedHashMap());
+ }
+
+ /**
+ * 快速创建map，并初始化
+ * @param map
+ * @return
+ */
+ public static MapChain newMap(Map map) {
+ if (map == null) {
+ return new MapChain<>(new LinkedHashMap());
+ }
+ return new MapChain<>(map);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/MetaspaceEmptyCapacityExpansion.java b/common/src/main/java/com/qmrz/utils/MetaspaceEmptyCapacityExpansion.java
new file mode 100644
index 0000000..c872de0
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/MetaspaceEmptyCapacityExpansion.java
@@ -0,0 +1,11 @@
+package com.qmrz.utils;
+
+/**
+ * metaspace手动时扩容专用
+ */
+public class MetaspaceEmptyCapacityExpansion {
+
+ public void test(){
+
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/MoneyUtil.java b/common/src/main/java/com/qmrz/utils/MoneyUtil.java
new file mode 100644
index 0000000..c8a9008
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/MoneyUtil.java
@@ -0,0 +1,38 @@
+package com.qmrz.utils;
+
+import java.math.BigDecimal;
+
+public class MoneyUtil {
+ /**
+ * 解析金额
+ * 1、金额保留两位小数点后
+ * 2、单元转分
+ * @param payMoney
+ * @return 返回分的无符号长整数类型
+ */
+ public static Long parsePayMoney(BigDecimal payMoney){
+ float tmpMoney = payMoney.floatValue();
+ //保留两位小数后去除小数点
+ String strMoney = String.format("%.2f", tmpMoney).replace(".", "");
+ return Long.parseUnsignedLong(strMoney);
+ }
+
+ /**
+ * 分转元
+ * @param payMoney
+ * @return
+ */
+ public static BigDecimal parseFenToYuan(Long payMoney){
+ return new BigDecimal(payMoney).divide(new BigDecimal(100));
+ }
+
+ /**
+ * 转成标准金额，保留两位小数
+ * @param payMoney
+ * @return
+ */
+ public static BigDecimal parseStandardPay(BigDecimal payMoney){
+ String strMoney = String.format("%.2f", payMoney.floatValue());
+ return new BigDecimal(strMoney);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/PackageUtil.java b/common/src/main/java/com/qmrz/utils/PackageUtil.java
new file mode 100644
index 0000000..f29795d
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/PackageUtil.java
@@ -0,0 +1,142 @@
+package com.qmrz.utils;
+
+import java.io.File;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.jar.JarEntry;
+import java.util.jar.JarFile;
+
+public class PackageUtil {
+ /**
+ * 获取某包下（包括该包的所有子包）所有类
+ * @param packageName 包名
+ * @return 类的完整名称
+ */
+// public static List getClassName(String packageName) {
+// return getClassName(packageName, true);
+// }
+
+ /**
+ * 获取某包下所有类
+ * @param packageName 包名
+ * @param childPackage 是否遍历子包
+ * @return 类的完整名称
+ */
+ public static List getClassName(String packageName, boolean childPackage) {
+ List fileNames = null;
+ ClassLoader loader = Thread.currentThread().getContextClassLoader();
+ String packagePath = packageName.replace(".", "/");
+ URL url = loader.getResource(packagePath);
+ if (url != null) {
+ String type = url.getProtocol();
+ if (type.equals("file")) {
+ fileNames = getClassNameByFile(url.getPath(), null, childPackage);
+ } else if (type.equals("jar")) {
+ fileNames = getClassNameByJar(url.getPath(), childPackage);
+ }
+ } else {
+ fileNames = getClassNameByJars(((URLClassLoader) loader).getURLs(), packagePath, childPackage);
+ }
+ return fileNames;
+ }
+
+ /**
+ * 从项目文件获取某包下所有类
+ * @param filePath 文件路径
+ * @param className 类名集合
+ * @param childPackage 是否遍历子包
+ * @return 类的完整名称
+ */
+ private static List getClassNameByFile(String filePath, List className, boolean childPackage) {
+ List myClassName = new ArrayList();
+ File file = new File(filePath);
+ File[] childFiles = file.listFiles();
+ for (File childFile : childFiles) {
+ if (childFile.isDirectory()) {
+ if (childPackage) {
+ myClassName.addAll(getClassNameByFile(childFile.getPath(), myClassName, childPackage));
+ }
+ } else {
+ String childFilePath = childFile.getPath();
+ if (childFilePath.endsWith(".class")) {
+ childFilePath = childFilePath.substring(childFilePath.indexOf("\\classes") + 9, childFilePath.lastIndexOf("."));
+ childFilePath = childFilePath.replace("\\", ".");
+ myClassName.add(childFilePath);
+ }
+ }
+ }
+
+ return myClassName;
+ }
+
+ /**
+ * 从jar获取某包下所有类
+ * @param jarPath jar文件路径
+ * @param childPackage 是否遍历子包
+ * @return 类的完整名称
+ */
+ private static List getClassNameByJar(String jarPath, boolean childPackage) {
+ List myClassName = new ArrayList();
+ String[] jarInfo = jarPath.split("!");
+ String jarFilePath = jarInfo[0].substring(jarInfo[0].indexOf("/"));
+ String packagePath = jarInfo[1].substring(1);
+ try {
+ JarFile jarFile = new JarFile(jarFilePath);
+ Enumeration entrys = jarFile.entries();
+ while (entrys.hasMoreElements()) {
+ JarEntry jarEntry = entrys.nextElement();
+ String entryName = jarEntry.getName();
+ if (entryName.endsWith(".class")) {
+ if (childPackage) {
+ if (entryName.startsWith(packagePath)) {
+ entryName = entryName.replace("/", ".").substring(0, entryName.lastIndexOf("."));
+ myClassName.add(entryName);
+ }
+ } else {
+ int index = entryName.lastIndexOf("/");
+ String myPackagePath;
+ if (index != -1) {
+ myPackagePath = entryName.substring(0, index);
+ } else {
+ myPackagePath = entryName;
+ }
+ if (myPackagePath.equals(packagePath)) {
+ entryName = entryName.replace("/", ".").substring(0, entryName.lastIndexOf("."));
+ myClassName.add(entryName);
+ }
+ }
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return myClassName;
+ }
+
+ /**
+ * 从所有jar中搜索该包，并获取该包下所有类
+ * @param urls URL集合
+ * @param packagePath 包路径
+ * @param childPackage 是否遍历子包
+ * @return 类的完整名称
+ */
+ private static List getClassNameByJars(URL[] urls, String packagePath, boolean childPackage) {
+ List myClassName = new ArrayList();
+ if (urls != null) {
+ for (int i = 0; i < urls.length; i++) {
+ URL url = urls[i];
+ String urlPath = url.getPath();
+ // 不必搜索classes文件夹
+ if (urlPath.endsWith("classes/")) {
+ continue;
+ }
+ String jarPath = urlPath + "!/" + packagePath;
+ myClassName.addAll(getClassNameByJar(jarPath, childPackage));
+ }
+ }
+ return myClassName;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/PageData.java b/common/src/main/java/com/qmrz/utils/PageData.java
new file mode 100644
index 0000000..52666e4
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/PageData.java
@@ -0,0 +1,49 @@
+package com.qmrz.utils;
+
+import com.github.pagehelper.Page;
+
+import java.util.List;
+
+public class PageData {
+ private Page data;
+ private int pageIndex;
+ private int pageSize;
+ private int pageCount;
+ private long rowCount;
+
+ public PageData(List page) {
+ this.data = (Page) page;
+ this.pageIndex = data.getPageNum();
+ this.pageSize = data.getPageSize();
+ this.pageCount = data.getPages();
+ this.rowCount = data.getTotal();
+ }
+
+ public static PageData newobj(Page page) {
+ return new PageData(page);
+ }
+
+ public static PageData newobj(List page) {
+ return new PageData(page);
+ }
+
+ public int getPageIndex() {
+ return this.pageIndex;
+ }
+
+ public int getPageSize() {
+ return this.pageSize;
+ }
+
+ public int getPageCount() {
+ return this.pageCount;
+ }
+
+ public long getRowCount() {
+ return this.rowCount;
+ }
+
+ public Page getData() {
+ return data;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ParamUtil.java b/common/src/main/java/com/qmrz/utils/ParamUtil.java
new file mode 100644
index 0000000..ace5a63
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ParamUtil.java
@@ -0,0 +1,5 @@
+package com.qmrz.utils;
+
+public class ParamUtil {
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/RD.java b/common/src/main/java/com/qmrz/utils/RD.java
new file mode 100644
index 0000000..9322ddf
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/RD.java
@@ -0,0 +1,119 @@
+package com.qmrz.utils;
+
+import lombok.ToString;
+
+/**
+ * 统一数据响应格式
+ * json格式：{"status":10200,"msg":"success","data":任何数据}
+ */
+@ToString
+public class RD {
+ private int status;
+ private String msg;
+ private Object data;
+
+ public RD(RDCode status, String msg, Object data) {
+ this.status = status.getState();
+ this.msg = msg;
+ this.data = data;
+ }
+
+ public static RD create(RDCode state, String msg, Object data) {
+ return new RD(state, msg, data);
+ }
+
+ public static RD create(RDCode state,Object data) {
+ return new RD(state, state.getMessage(), data);
+ }
+
+ public static RD create(RDCode state) {
+ return new RD(state, state.getMessage(), "");
+ }
+
+ public static RD notfound() {
+ return create(RDCode.notfound, "");
+ }
+
+ public static RD notlogin() {
+ return create(RDCode.notlogin, "");
+ }
+
+ public static RD usernotlogin(){
+ return create(RDCode.usernotlogin, "");
+ }
+
+ public static RD exception(String msg) {
+ return create(RDCode.exception, msg, "");
+ }
+
+ public static RD notpermission() {
+ return create(RDCode.nopermission, "");
+ }
+
+ //失败
+ public static RD failure() {
+ return create(RDCode.failure, "");
+ }
+
+ public static RD failure(String msg) {
+ return create(RDCode.failure, msg, "");
+ }
+
+ public static RD failure(String msg, Object data) {
+ return create(RDCode.failure, msg, data);
+ }
+
+ public static RD failureByForm(String msg, Object data) {
+ return create(RDCode.failureByForm, msg, data);
+ }
+
+ //成功
+ public static RD success() {
+ return create(RDCode.success, "");
+ }
+
+ public static RD success(Object data) {
+ return create(RDCode.success, data);
+ }
+
+ public static RD success(String msg, Object data) {
+ return create(RDCode.success, msg, data);
+ }
+
+ //快速
+ public static RD quick(boolean b) {
+ if (b) {
+ return success();
+ } else {
+ return failure();
+ }
+ }
+
+ /**
+ * 成功：返回数据，失败：返回失败信息
+ *
+ * @param b
+ * @param failureMsg 失败时返回失败信息
+ * @param successdata 成功时返回数据
+ * @return
+ */
+ public static RD quick(boolean b, String failureMsg, Object successdata) {
+ if (b) {
+ return success(successdata);
+ } else {
+ return failure(failureMsg);
+ }
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public Object getData() {
+ return data;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/RDCode.java b/common/src/main/java/com/qmrz/utils/RDCode.java
new file mode 100644
index 0000000..fa9beb4
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/RDCode.java
@@ -0,0 +1,45 @@
+package com.qmrz.utils;
+
+/**
+ * 统一数据响应状态值
+ * 10200 成功
+ * 10555 失败
+ * 10556 失败，并返回具体错误信息（主要用于后台表单验证时一次性输出失败原因）
+ * 10404 找不到地址
+ * 10500 服务端异常
+ * 10401 管理员未登录或超时
+ * 10402 用户未登录或超时
+ */
+public enum RDCode {
+ success(10200, "success"),
+ failure(10555, "failure"),
+ failureByForm(10556, "failureByForm"),
+ notfound(10404, "请求地址不存在"),
+ exception(10500, "服务端异常"),
+ nopermission(10403, "无访问权限"),
+ notlogin(10401, "未登录或超时"),
+ usernotlogin(10402, "用户未登录或超时"),
+ subuserlimit(10405, "子帐号不超过3个"),
+ userexist(10406,"用户已存在"),
+ nobindphone(10407,"未绑定手机号码"),
+ notauthorization(10408, "用户未授权或超时"),
+ exception_dida(20500, "迪达接口异常"),
+ notqrcode(20409, "没有扫二维码"),
+ exception_equip(30500, "设备接口异常");
+
+ private int state = 0;
+ private String message = "";
+
+ private RDCode(int value, String message) {
+ this.state = value;
+ this.message = message;
+ }
+
+ public int getState() {
+ return state;
+ }
+
+ public String getMessage() {
+ return message;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ReStreamInput.java b/common/src/main/java/com/qmrz/utils/ReStreamInput.java
new file mode 100644
index 0000000..cf2b68c
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ReStreamInput.java
@@ -0,0 +1,26 @@
+package com.qmrz.utils;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * 支持InputStream可重复读
+ */
+public class ReStreamInput {
+ ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
+
+ public ReStreamInput(InputStream inputStream) throws IOException {
+ byte[] buffer = new byte[1024];
+ int len;
+ while ((len = inputStream.read(buffer)) > -1) {
+ byteArrayOutputStream.write(buffer, 0, len);
+ }
+ byteArrayOutputStream.flush();
+ }
+
+ public InputStream getInputStream(){
+ return new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/Session.java b/common/src/main/java/com/qmrz/utils/Session.java
new file mode 100644
index 0000000..0352d5e
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/Session.java
@@ -0,0 +1,22 @@
+package com.qmrz.utils;
+
+import javax.servlet.http.HttpSession;
+
+public class Session {
+ public static void removeSession(String key){
+ getSession().removeAttribute(key);
+ }
+
+ public static void setSession(String key,Object val){
+ getSession().setAttribute(key, val);
+ }
+
+ @SuppressWarnings("unchecked")
+ public static T getSession(String key) {
+ return (T) getSession().getAttribute(key);
+ }
+
+ public static HttpSession getSession() {
+ return Web.getRequest().getSession();
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/SpringContextUtil.java b/common/src/main/java/com/qmrz/utils/SpringContextUtil.java
new file mode 100644
index 0000000..74810c4
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/SpringContextUtil.java
@@ -0,0 +1,37 @@
+package com.qmrz.utils;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SpringContextUtil implements ApplicationContextAware {
+ private static ApplicationContext ac;
+
+ @Override
+ public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+ ac = applicationContext;
+ }
+
+ /**
+ * 通过name获取 Bean.
+ *
+ * @param name
+ * @return
+ */
+ public static Object getBean(String name) {
+ return ac.getBean(name);
+ }
+
+ /**
+ * 通过class获取Bean.
+ *
+ * @param clazz
+ * @param
+ * @return
+ */
+ public static T getBean(Class clazz) {
+ return ac.getBean(clazz);
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/StreamUtil.java b/common/src/main/java/com/qmrz/utils/StreamUtil.java
new file mode 100644
index 0000000..2cba79c
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/StreamUtil.java
@@ -0,0 +1,35 @@
+package com.qmrz.utils;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+
+public class StreamUtil {
+ public static StringBuffer inputToString(InputStream inputStream) {
+ BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
+ StringBuffer sb = new StringBuffer();
+ String tmp = null;
+
+ try {
+ while (true) {
+ tmp = reader.readLine();
+ if (tmp == null) {
+ break;
+ }
+ sb.append(tmp);
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }finally {
+ try {
+ reader.close();
+ inputStream.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ return sb;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/ValidateUtil.java b/common/src/main/java/com/qmrz/utils/ValidateUtil.java
new file mode 100644
index 0000000..d8db045
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/ValidateUtil.java
@@ -0,0 +1,6 @@
+package com.qmrz.utils;
+
+public class ValidateUtil {
+
+
+}
diff --git a/common/src/main/java/com/qmrz/utils/VerifyCodeUtil.java b/common/src/main/java/com/qmrz/utils/VerifyCodeUtil.java
new file mode 100644
index 0000000..95b30a2
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/VerifyCodeUtil.java
@@ -0,0 +1,299 @@
+package com.qmrz.utils;
+
+import javax.imageio.ImageIO;
+import javax.servlet.http.HttpServletResponse;
+import java.awt.*;
+import java.awt.geom.AffineTransform;
+import java.awt.image.BufferedImage;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.Arrays;
+import java.util.Random;
+
+public class VerifyCodeUtil {
+ //使用到Algerian字体，系统里没有的话需要安装字体，字体只显示大写，去掉了1,0,i,o几个容易混淆的字符
+ public static final String VERIFY_CODES = "23456789ABCDEFGHJKLMNPQRSTUVWXYZ";
+ private static Random random = new Random();
+
+ public static void renderCode(String verifyCodeName, String customerDir, int num) throws IOException {
+ HttpServletResponse response = Web.getResponse();
+ response.setHeader("Pragma", "No-cache");
+ response.setHeader("Cache-Control", "no-cache");
+ response.setDateHeader("Expires", 0);
+ response.setContentType("image/jpeg");
+
+ // 生成随机字串
+ String verifyCode = VerifyCodeUtil.generateVerifyCode(num);
+
+ String name = "verifycode:" + verifyCodeName + ":" + customerDir;//验证码名称
+
+ Session.setSession(name, verifyCode);
+
+ // 存入会话session
+ //HttpSession session = request.getSession(true);
+ // 删除以前的
+// session.removeAttribute("verCode");
+// session.removeAttribute("codeTime");
+// session.setAttribute("verCode", verifyCode.toLowerCase());
+// session.setAttribute("codeTime", LocalDateTime.now());
+ // 生成图片
+ int w = 100, h = 32;
+ VerifyCodeUtil.outputImage(w, h, response.getOutputStream(), verifyCode);
+ }
+
+ public static boolean checkCode(String verifyCodeName, String customerDir, String code) {
+ String name = "verifycode:" + verifyCodeName + ":" + customerDir;//验证码名称
+ String val = Session.getSession(name);
+ if (val == null) {
+ return false;
+ }
+ val = val.toLowerCase();
+ boolean b = code.toLowerCase().equals(val);
+ Session.removeSession(name);
+ return b;
+ }
+
+ /**
+ * 使用系统默认字符源生成验证码
+ *
+ * @param verifySize 验证码长度
+ * @return
+ */
+ public static String generateVerifyCode(int verifySize) {
+ return generateVerifyCode(verifySize, VERIFY_CODES);
+ }
+
+ /**
+ * 使用指定源生成验证码
+ *
+ * @param verifySize 验证码长度
+ * @param sources 验证码字符源
+ * @return
+ */
+ public static String generateVerifyCode(int verifySize, String sources) {
+ if (sources == null || sources.length() == 0) {
+ sources = VERIFY_CODES;
+ }
+ int codesLen = sources.length();
+ Random rand = new Random(System.currentTimeMillis());
+ StringBuilder verifyCode = new StringBuilder(verifySize);
+ for (int i = 0; i < verifySize; i++) {
+ verifyCode.append(sources.charAt(rand.nextInt(codesLen - 1)));
+ }
+ return verifyCode.toString();
+ }
+
+ /**
+ * 生成随机验证码文件,并返回验证码值
+ *
+ * @param w
+ * @param h
+ * @param outputFile
+ * @param verifySize
+ * @return
+ * @throws IOException
+ */
+ public static String outputVerifyImage(int w, int h, File outputFile, int verifySize) throws IOException {
+ String verifyCode = generateVerifyCode(verifySize);
+ outputImage(w, h, outputFile, verifyCode);
+ return verifyCode;
+ }
+
+ /**
+ * 输出随机验证码图片流,并返回验证码值
+ *
+ * @param w
+ * @param h
+ * @param os
+ * @param verifySize
+ * @return
+ * @throws IOException
+ */
+ public static String outputVerifyImage(int w, int h, OutputStream os, int verifySize) throws IOException {
+ String verifyCode = generateVerifyCode(verifySize);
+ outputImage(w, h, os, verifyCode);
+ return verifyCode;
+ }
+
+ /**
+ * 生成指定验证码图像文件
+ *
+ * @param w
+ * @param h
+ * @param outputFile
+ * @param code
+ * @throws IOException
+ */
+ public static void outputImage(int w, int h, File outputFile, String code) throws IOException {
+ if (outputFile == null) {
+ return;
+ }
+ File dir = outputFile.getParentFile();
+ if (!dir.exists()) {
+ dir.mkdirs();
+ }
+ try {
+ outputFile.createNewFile();
+ FileOutputStream fos = new FileOutputStream(outputFile);
+ outputImage(w, h, fos, code);
+ fos.close();
+ } catch (IOException e) {
+ throw e;
+ }
+ }
+
+ /**
+ * 输出指定验证码图片流
+ *
+ * @param w
+ * @param h
+ * @param os
+ * @param code
+ * @throws IOException
+ */
+ public static void outputImage(int w, int h, OutputStream os, String code) throws IOException {
+ int verifySize = code.length();
+ BufferedImage image = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
+ Random rand = new Random();
+ Graphics2D g2 = image.createGraphics();
+ g2.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
+ Color[] colors = new Color[5];
+ Color[] colorSpaces = new Color[]{Color.WHITE, Color.CYAN,
+ Color.GRAY, Color.LIGHT_GRAY, Color.MAGENTA, Color.ORANGE,
+ Color.PINK, Color.YELLOW};
+ float[] fractions = new float[colors.length];
+ for (int i = 0; i < colors.length; i++) {
+ colors[i] = colorSpaces[rand.nextInt(colorSpaces.length)];
+ fractions[i] = rand.nextFloat();
+ }
+ Arrays.sort(fractions);
+
+ g2.setColor(Color.GRAY);// 设置边框色
+ g2.fillRect(0, 0, w, h);
+
+ Color c = getRandColor(200, 250);
+ g2.setColor(c);// 设置背景色
+ g2.fillRect(0, 2, w, h - 4);
+
+ //绘制干扰线
+ Random random = new Random();
+ g2.setColor(getRandColor(160, 200));// 设置线条的颜色
+ for (int i = 0; i < 20; i++) {
+ int x = random.nextInt(w - 1);
+ int y = random.nextInt(h - 1);
+ int xl = random.nextInt(6) + 1;
+ int yl = random.nextInt(12) + 1;
+ g2.drawLine(x, y, x + xl + 40, y + yl + 20);
+ }
+
+ // 添加噪点
+ float yawpRate = 0.05f;// 噪声率
+ int area = (int) (yawpRate * w * h);
+ for (int i = 0; i < area; i++) {
+ int x = random.nextInt(w);
+ int y = random.nextInt(h);
+ int rgb = getRandomIntColor();
+ image.setRGB(x, y, rgb);
+ }
+
+ shear(g2, w, h, c);// 使图片扭曲
+
+ g2.setColor(getRandColor(100, 160));
+ int fontSize = h - 4;
+ Font font = new Font("Algerian", Font.ITALIC, fontSize);
+ g2.setFont(font);
+ char[] chars = code.toCharArray();
+ for (int i = 0; i < verifySize; i++) {
+ AffineTransform affine = new AffineTransform();
+ affine.setToRotation(Math.PI / 4 * rand.nextDouble() * (rand.nextBoolean() ? 1 : -1), (w / verifySize) * i + fontSize / 2, h / 2);
+ g2.setTransform(affine);
+ g2.drawChars(chars, i, 1, ((w - 10) / verifySize) * i + 5, h / 2 + fontSize / 2 - 10);
+ }
+
+ g2.dispose();
+ ImageIO.write(image, "jpg", os);
+ }
+
+ private static Color getRandColor(int fc, int bc) {
+ if (fc > 255)
+ fc = 255;
+ if (bc > 255)
+ bc = 255;
+ int r = fc + random.nextInt(bc - fc);
+ int g = fc + random.nextInt(bc - fc);
+ int b = fc + random.nextInt(bc - fc);
+ return new Color(r, g, b);
+ }
+
+ private static int getRandomIntColor() {
+ int[] rgb = getRandomRgb();
+ int color = 0;
+ for (int c : rgb) {
+ color = color << 8;
+ color = color | c;
+ }
+ return color;
+ }
+
+ private static int[] getRandomRgb() {
+ int[] rgb = new int[3];
+ for (int i = 0; i < 3; i++) {
+ rgb[i] = random.nextInt(255);
+ }
+ return rgb;
+ }
+
+ private static void shear(Graphics g, int w1, int h1, Color color) {
+ shearX(g, w1, h1, color);
+ shearY(g, w1, h1, color);
+ }
+
+ private static void shearX(Graphics g, int w1, int h1, Color color) {
+
+ int period = random.nextInt(2);
+
+ boolean borderGap = true;
+ int frames = 1;
+ int phase = random.nextInt(2);
+
+ for (int i = 0; i < h1; i++) {
+ double d = (double) (period >> 1)
+ * Math.sin((double) i / (double) period
+ + (6.2831853071795862D * (double) phase)
+ / (double) frames);
+ g.copyArea(0, i, w1, 1, (int) d, 0);
+ if (borderGap) {
+ g.setColor(color);
+ g.drawLine((int) d, i, 0, i);
+ g.drawLine((int) d + w1, i, w1, i);
+ }
+ }
+
+ }
+
+ private static void shearY(Graphics g, int w1, int h1, Color color) {
+
+ int period = random.nextInt(40) + 10; // 50;
+
+ boolean borderGap = true;
+ int frames = 20;
+ int phase = 7;
+ for (int i = 0; i < w1; i++) {
+ double d = (double) (period >> 1)
+ * Math.sin((double) i / (double) period
+ + (6.2831853071795862D * (double) phase)
+ / (double) frames);
+ g.copyArea(i, 0, 1, h1, 0, (int) d);
+ if (borderGap) {
+ g.setColor(color);
+ g.drawLine(i, (int) d, i, 0);
+ g.drawLine(i, (int) d + h1, i, h1);
+ }
+
+ }
+
+ }
+}
+
diff --git a/common/src/main/java/com/qmrz/utils/Web.java b/common/src/main/java/com/qmrz/utils/Web.java
new file mode 100644
index 0000000..d7b42fd
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/Web.java
@@ -0,0 +1,215 @@
+package com.qmrz.utils;
+
+import com.qmrz.exception.ABException;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.imageio.ImageIO;
+import javax.servlet.ServletResponse;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.*;
+import java.util.Calendar;
+
+@Slf4j
+public class Web {
+ public static void redirect(String path) throws IOException {
+ getResponse().sendRedirect(path);
+ }
+
+ public static void setNoCache() {
+ getResponse().addHeader("Cache-Control", "no-cache");
+ }
+
+ public static void setCache() {
+ HttpServletResponse response = getResponse();
+ response.setHeader("Cache-Control", "max-age=315360000");
+
+ Calendar now = Calendar.getInstance();
+ now.add(Calendar.YEAR, 10);
+ response.setHeader("Expires", DateTimeUtil.formatGMTBySecond(now.getTimeInMillis() / 1000L));
+ }
+
+ public static HttpServletResponse getResponse() {
+ return getRequestAttributes().getResponse();
+ }
+
+ public static HttpServletRequest getRequest() {
+ return getRequestAttributes().getRequest();
+ }
+
+ public static ServletRequestAttributes getRequestAttributes() {
+ return (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+ }
+
+ public static String getRequestBody() {
+ String line = "";
+ String result = null;
+ HttpServletRequest request = Web.getRequest();
+ try {
+ BufferedReader reader = request.getReader();
+ StringBuffer inputString = new StringBuffer();
+ while ((line = reader.readLine()) != null) {
+ inputString.append(line);
+ }
+ result = inputString.toString();
+ request.getReader().close();
+ } catch (IOException e) {
+ String msg = "获取请求内容时异常：" + e.getMessage();
+ log.info(msg);
+ throw new ABException(msg);
+ }
+ return result;
+ }
+
+ public static void printRD(ServletResponse response, RD rd) {
+ //response.setHeader("Cache-Control","no-cache");
+ response.setContentType("application/json;charset=UTF-8");
+
+ try {
+ response.getWriter().print(JSONObject.toJSONString(rd));
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void responseImage(String fileName) {
+ Web.getResponse().setContentType("image/jpeg");
+
+ File file = new File(fileName);
+
+ FileInputStream inputStream = null;
+ try {
+ inputStream = new FileInputStream(file);
+ byte[] data = new byte[(int) file.length()];
+ int length = inputStream.read(data);
+ inputStream.close();
+ OutputStream stream = Web.getResponse().getOutputStream();
+ stream.write(data);
+ stream.flush();
+ stream.close();
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * InputStream转数组
+ * @param input
+ * @return
+ * @throws IOException
+ */
+ private static byte[] toByteArray(InputStream input) throws IOException {
+ ByteArrayOutputStream output = new ByteArrayOutputStream();
+ byte[] buffer = new byte[4096];
+ int n = 0;
+ while (-1 != (n = input.read(buffer))) {
+ output.write(buffer, 0, n);
+ }
+ return output.toByteArray();
+ }
+
+ /**
+ * 响应InputStream
+ * @param inputStream
+ */
+ public static void responseInputStream(InputStream inputStream) {
+ try {
+ byte[] data = toByteArray(inputStream);
+ inputStream.close();
+ OutputStream stream = Web.getResponse().getOutputStream();
+ stream.write(data);
+ stream.flush();
+ stream.close();
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void responseImage2(String fileName) {
+ HttpServletResponse response = Web.getResponse();
+ response.setContentType("image/jpeg");
+ response.setHeader("Cache-Control", "max-age=315360000");
+
+ Calendar now = Calendar.getInstance();
+ now.add(Calendar.YEAR, 10);
+ response.setHeader("Expires", DateTimeUtil.formatGMTBySecond(now.getTimeInMillis() / 1000L));
+
+// response.setHeader("Accept-Ranges", "bytes");
+ Image image2 = Toolkit.getDefaultToolkit().getImage(fileName);
+ log.info(fileName);
+ try {
+ BufferedImage image3 = ImageUtil.toBufferedImage(image2);
+ ImageIO.write(image3, "jpg", Web.getResponse().getOutputStream());
+ } catch (Exception e) {
+ log.error(e.getMessage());
+ }
+ }
+
+// public static void responseImage2(InputStream inputStream,int streamLength) {
+// HttpServletResponse response = Web.getResponse();
+// response.setContentType("image/jpeg");
+// response.setHeader("Cache-Control", "max-age=315360000");
+//
+// Calendar now = Calendar.getInstance();
+// now.add(Calendar.YEAR, 10);
+// response.setHeader("Expires", DateTimeUtil.formatGMTBySecond(now.getTimeInMillis() / 1000L));
+//
+//// response.setHeader("Accept-Ranges", "bytes");
+// Image image2 = Toolkit.getDefaultToolkit().getImage(fileName);
+// Toolkit.getDefaultToolkit().getImage()
+// System.out.println(fileName);
+// try {
+// BufferedImage image3 = ImageUtil.toBufferedImage(image2);
+// ImageIO.write(image3, "jpg", Web.getResponse().getOutputStream());
+// } catch (Exception e) {
+// log.error(e.getMessage());
+// }
+// }
+
+ public static void responseText(String content) {
+ if (content == null) {
+ content = "";
+ }
+ Web.getResponse().setContentType("text/plain");
+ PrintWriter writer = null;
+ try {
+ writer = Web.getResponse().getWriter();
+ writer.write(content);
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ if (writer != null) {
+ writer.flush();
+ writer.close();
+ }
+ }
+ }
+
+ public static void responseText(String content, String contentType) {
+ if (content == null) {
+ content = "";
+ }
+ Web.getResponse().setContentType(contentType);
+ PrintWriter writer = null;
+ try {
+ writer = Web.getResponse().getWriter();
+ writer.write(content);
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ if (writer != null) {
+ writer.flush();
+ writer.close();
+ }
+ }
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/XMLUtil.java b/common/src/main/java/com/qmrz/utils/XMLUtil.java
new file mode 100644
index 0000000..7bb2ae0
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/XMLUtil.java
@@ -0,0 +1,113 @@
+package com.qmrz.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.dom4j.DocumentHelper;
+import org.dom4j.Element;
+
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBException;
+import javax.xml.bind.Marshaller;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.transform.OutputKeys;
+import javax.xml.transform.Transformer;
+import javax.xml.transform.TransformerFactory;
+import javax.xml.transform.dom.DOMSource;
+import javax.xml.transform.stream.StreamResult;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.StringWriter;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+public class XMLUtil {
+ /**
+ * 解析xml,返回第一级元素键值对。如果第一级元素有子节点，则此节点的值是子节点的xml数据。
+ * 解决：2字节的UTF-8序列的字节2无效的错误
+ * @param strxml
+ * @return
+ * @throws Exception
+ * @throws IOException
+ */
+ public static Map doXMLParseByDom4j(String strxml) throws Exception {
+ Map map = new HashMap();
+ org.dom4j.Document doc = null;
+ try {
+ // 将字符串转为XML
+ doc = DocumentHelper.parseText(strxml);
+ // 获取根节点
+ org.dom4j.Element rootElt = doc.getRootElement();
+ // 拿到根节点的名称
+ log.info("根节点：" + rootElt.getName());
+
+ List iList = rootElt.elements();
+
+ for(int i=0;i data) throws Exception {
+ DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
+ DocumentBuilder documentBuilder= documentBuilderFactory.newDocumentBuilder();
+ org.w3c.dom.Document document = documentBuilder.newDocument();
+ org.w3c.dom.Element root = document.createElement("xml");
+ document.appendChild(root);
+ for (String key: data.keySet()) {
+ String value = data.get(key);
+ if (value == null) {
+ value = "";
+ }
+ value = value.trim();
+ org.w3c.dom.Element filed = document.createElement(key);
+ filed.appendChild(document.createTextNode(value));
+ root.appendChild(filed);
+ }
+ TransformerFactory tf = TransformerFactory.newInstance();
+ Transformer transformer = tf.newTransformer();
+ DOMSource source = new DOMSource(document);
+ transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
+ transformer.setOutputProperty(OutputKeys.INDENT, "yes");
+ StringWriter writer = new StringWriter();
+ StreamResult result = new StreamResult(writer);
+ transformer.transform(source, result);
+ String output = writer.getBuffer().toString(); //.replaceAll("\n|\r", "");
+ try {
+ writer.close();
+ }
+ catch (Exception ex) {
+ }
+ return output;
+ }
+}
diff --git a/common/src/main/java/com/qmrz/utils/classload/JavaStringCompiler.java b/common/src/main/java/com/qmrz/utils/classload/JavaStringCompiler.java
new file mode 100644
index 0000000..0717fd7
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/classload/JavaStringCompiler.java
@@ -0,0 +1,71 @@
+package com.qmrz.utils.classload;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Map;
+
+import javax.tools.JavaCompiler;
+import javax.tools.JavaFileObject;
+import javax.tools.StandardJavaFileManager;
+import javax.tools.ToolProvider;
+import javax.tools.JavaCompiler.CompilationTask;
+
+/**
+ * In-memory compile Java source code as String.
+ *
+ * @author michael
+ */
+public class JavaStringCompiler {
+
+ JavaCompiler compiler;
+ StandardJavaFileManager stdManager;
+
+ public JavaStringCompiler() {
+ this.compiler = ToolProvider.getSystemJavaCompiler();
+ this.stdManager = compiler.getStandardFileManager(null, null, null);
+ }
+
+ /**
+ * Compile a Java source file in memory.
+ *
+ * @param fileName
+ * Java file name, e.g. "Test.java"
+ * @param source
+ * The source code as String.
+ * @return The compiled results as Map that contains class name as key,
+ * class binary as value.
+ * @throws IOException
+ * If compile error.
+ */
+ public Map compile(String fileName, String source) throws IOException {
+ try (MemoryJavaFileManager manager = new MemoryJavaFileManager(stdManager)) {
+ JavaFileObject javaFileObject = manager.makeStringSource(fileName, source);
+ CompilationTask task = compiler.getTask(null, manager, null, null, null, Arrays.asList(javaFileObject));
+
+ Boolean result = task.call();
+ if (result == null || !result.booleanValue()) {
+ throw new RuntimeException("Compilation failed.");
+ }
+ return manager.getClassBytes();
+ }
+ }
+
+ /**
+ * Load class from compiled classes.
+ *
+ * @param name
+ * Full class name.
+ * @param classBytes
+ * Compiled results as a Map.
+ * @return The Class instance.
+ * @throws ClassNotFoundException
+ * If class not found.
+ * @throws IOException
+ * If load error.
+ */
+ public Class loadClass(String name, Map classBytes) throws ClassNotFoundException, IOException {
+ try (MemoryClassLoader classLoader = new MemoryClassLoader(classBytes)) {
+ return classLoader.loadClass(name);
+ }
+ }
+}
\ No newline at end of file
diff --git a/common/src/main/java/com/qmrz/utils/classload/MemoryClassLoader.java b/common/src/main/java/com/qmrz/utils/classload/MemoryClassLoader.java
new file mode 100644
index 0000000..2d464d1
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/classload/MemoryClassLoader.java
@@ -0,0 +1,32 @@
+package com.qmrz.utils.classload;
+
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * class加载到内存
+ */
+public class MemoryClassLoader extends URLClassLoader {
+
+ // class name to class bytes:
+ Map classBytes = new HashMap<>();
+
+ public MemoryClassLoader(Map classBytes) {
+ super(new URL[0], MemoryClassLoader.class.getClassLoader());
+ this.classBytes.putAll(classBytes);
+ }
+
+ @Override
+ protected Class findClass(String name) throws ClassNotFoundException {
+ byte[] buf = classBytes.get(name);
+ if (buf == null) {
+ return super.findClass(name);
+ }
+ classBytes.remove(name);
+
+ return defineClass(name, buf, 0, buf.length);
+ }
+
+}
\ No newline at end of file
diff --git a/common/src/main/java/com/qmrz/utils/classload/MemoryJavaFileManager.java b/common/src/main/java/com/qmrz/utils/classload/MemoryJavaFileManager.java
new file mode 100644
index 0000000..ca2f43a
--- /dev/null
+++ b/common/src/main/java/com/qmrz/utils/classload/MemoryJavaFileManager.java
@@ -0,0 +1,84 @@
+package com.qmrz.utils.classload;
+
+import javax.tools.*;
+import java.io.ByteArrayOutputStream;
+import java.io.FilterOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.URI;
+import java.nio.CharBuffer;
+import java.util.HashMap;
+import java.util.Map;
+
+public class MemoryJavaFileManager extends ForwardingJavaFileManager