map = new HashMap<>();
+ Class clazz = obj.getClass();
+ for (Field field : clazz.getDeclaredFields()) {
+ field.setAccessible(true);
+ String fieldName = field.getName();
+ Object value = field.get(obj);
+ map.put(fieldName, value);
+ }
+ return map;
+ }
+
+ /**
+ * 判断是否是JSON格式
+ *
+ * @param str JSON字符串
+ * @return
+ */
+ private boolean isJson(String str) {
+ try {
+ JSONObject jsonStr = JSONObject.parseObject(str);
+ return true;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+
+ /**
+ * MD5方法
+ *
+ * @param source
+ * @return
+ */
+ public static String md5(byte[] source) {
+ try {
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ md.update(source);
+ StringBuffer buf = new StringBuffer();
+ for (byte b : md.digest()) {
+ buf.append(String.format("%02x", b & 0xff));
+ }
+ return buf.toString();
+ } catch (Exception e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+ /**
+ * 密码加密
+ *
+ * @param password 密码
+ * @return
+ */
+ public static String password(String password) {
+ String md51 = md5(password.getBytes());
+ String pwd = md5((md51 + "IgtUdEQJyVevaCxQnY").getBytes());
+ return pwd;
+ }
+}
diff --git a/common/src/main/java/com/canvas/web/utils/ElAdminConstant.java b/common/src/main/java/com/canvas/web/utils/ElAdminConstant.java
new file mode 100644
index 0000000..e5a6a49
--- /dev/null
+++ b/common/src/main/java/com/canvas/web/utils/ElAdminConstant.java
@@ -0,0 +1,26 @@
+package com.canvas.web.utils;
+
+public class ElAdminConstant {
+
+ /**
+ * 用于IP定位转换
+ */
+ public static final String REGION = "内网IP|内网IP";
+ /**
+ * win 系统
+ */
+ public static final String WIN = "win";
+
+ /**
+ * mac 系统
+ */
+ public static final String MAC = "mac";
+
+ /**
+ * 常用接口
+ */
+ public static class Url {
+ // IP归属地查询
+ public static final String IP_URL = "http://whois.pconline.com.cn/ipJson.jsp?ip=%s&json=true";
+ }
+}
diff --git a/common/src/main/java/com/canvas/web/utils/ErrorCode.java b/common/src/main/java/com/canvas/web/utils/ErrorCode.java
new file mode 100644
index 0000000..0ec7d36
--- /dev/null
+++ b/common/src/main/java/com/canvas/web/utils/ErrorCode.java
@@ -0,0 +1,42 @@
+package com.canvas.web.utils;
+
+public enum ErrorCode {
+
+ FAILED(1, "操作失败"),
+ TOKEN_MISSING(300, "token丢失"),
+ TOKEN_ERROR(301, "token认证失败"),
+ PARAM_MISSING(400, "参数丢失"),
+ PARAM_ERROR(401, "参数错误"),
+ SYSTEM_ERROR(500, "系统错误"),
+ UNKNOWN_ERROR(501, "未知错误");
+
+ public static final Integer MESSAGE_PARAM_MISSING = 400;
+
+ /**
+ * 错误码
+ */
+ private Integer code;
+ /**
+ * 错误描述
+ */
+ private String msg;
+
+ public Integer getCode() {
+ return this.code;
+ }
+
+ public String getMsg() {
+ return this.msg;
+ }
+
+ /**
+ * 构造函数
+ *
+ * @param code
+ * @param msg
+ */
+ private ErrorCode(Integer code, String msg) {
+ this.code = code;
+ this.msg = msg;
+ }
+}
diff --git a/common/src/main/java/com/canvas/web/utils/FileUtil.java b/common/src/main/java/com/canvas/web/utils/FileUtil.java
new file mode 100644
index 0000000..5732b5f
--- /dev/null
+++ b/common/src/main/java/com/canvas/web/utils/FileUtil.java
@@ -0,0 +1,356 @@
+package com.canvas.web.utils;
+
+import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.poi.excel.BigExcelWriter;
+import cn.hutool.poi.excel.ExcelUtil;
+import com.canvas.web.exception.BaseException;
+import org.apache.poi.ss.usermodel.CellType;
+import org.apache.poi.util.IOUtils;
+import org.apache.poi.xssf.streaming.SXSSFCell;
+import org.apache.poi.xssf.streaming.SXSSFRow;
+import org.apache.poi.xssf.streaming.SXSSFSheet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.*;
+import java.security.MessageDigest;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+public class FileUtil extends cn.hutool.core.io.FileUtil{
+
+ private static final Logger log = LoggerFactory.getLogger(FileUtil.class);
+
+ /**
+ * 系统临时目录
+ *
+ * windows 包含路径分割符，但Linux 不包含,
+ * 在windows \\==\ 前提下，
+ * 为安全起见 同意拼装 路径分割符，
+ *
+ * java.io.tmpdir
+ * windows : C:\Users/xxx\AppData\Local\Temp\
+ * linux: /temp
+ *
+ */
+ public static final String SYS_TEM_DIR = System.getProperty("java.io.tmpdir") + File.separator;
+ /**
+ * 定义GB的计算常量
+ */
+ private static final int GB = 1024 * 1024 * 1024;
+ /**
+ * 定义MB的计算常量
+ */
+ private static final int MB = 1024 * 1024;
+ /**
+ * 定义KB的计算常量
+ */
+ private static final int KB = 1024;
+
+ /**
+ * 格式化小数
+ */
+ private static final DecimalFormat DF = new DecimalFormat("0.00");
+
+ public static final String IMAGE = "图片";
+ public static final String TXT = "文档";
+ public static final String MUSIC = "音乐";
+ public static final String VIDEO = "视频";
+ public static final String OTHER = "其他";
+
+
+ /**
+ * MultipartFile转File
+ */
+ public static File toFile(MultipartFile multipartFile) {
+ // 获取文件名
+ String fileName = multipartFile.getOriginalFilename();
+ // 获取文件后缀
+ String prefix = "." + getExtensionName(fileName);
+ File file = null;
+ try {
+ // 用uuid作为文件名，防止生成的临时文件重复
+ file = File.createTempFile(IdUtil.simpleUUID(), prefix);
+ // MultipartFile to File
+ multipartFile.transferTo(file);
+ } catch (IOException e) {
+ log.error(e.getMessage(), e);
+ }
+ return file;
+ }
+
+ /**
+ * 获取文件扩展名，不带 .
+ */
+ public static String getExtensionName(String filename) {
+ if ((filename != null) && (filename.length() > 0)) {
+ int dot = filename.lastIndexOf('.');
+ if ((dot > -1) && (dot < (filename.length() - 1))) {
+ return filename.substring(dot + 1);
+ }
+ }
+ return filename;
+ }
+
+ /**
+ * Java文件操作 获取不带扩展名的文件名
+ */
+ public static String getFileNameNoEx(String filename) {
+ if ((filename != null) && (filename.length() > 0)) {
+ int dot = filename.lastIndexOf('.');
+ if ((dot > -1) && (dot < (filename.length()))) {
+ return filename.substring(0, dot);
+ }
+ }
+ return filename;
+ }
+
+ /**
+ * 文件大小转换
+ */
+ public static String getSize(long size) {
+ String resultSize;
+ if (size / GB >= 1) {
+ //如果当前Byte的值大于等于1GB
+ resultSize = DF.format(size / (float) GB) + "GB ";
+ } else if (size / MB >= 1) {
+ //如果当前Byte的值大于等于1MB
+ resultSize = DF.format(size / (float) MB) + "MB ";
+ } else if (size / KB >= 1) {
+ //如果当前Byte的值大于等于1KB
+ resultSize = DF.format(size / (float) KB) + "KB ";
+ } else {
+ resultSize = size + "B ";
+ }
+ return resultSize;
+ }
+
+ /**
+ * inputStream 转 File
+ */
+ static File inputStreamToFile(InputStream ins, String name) throws Exception {
+ File file = new File(SYS_TEM_DIR + name);
+ if (file.exists()) {
+ return file;
+ }
+ OutputStream os = new FileOutputStream(file);
+ int bytesRead;
+ int len = 8192;
+ byte[] buffer = new byte[len];
+ while ((bytesRead = ins.read(buffer, 0, len)) != -1) {
+ os.write(buffer, 0, bytesRead);
+ }
+ os.close();
+ ins.close();
+ return file;
+ }
+
+ /**
+ * 将文件名解析成文件的上传路径
+ */
+ public static File upload(MultipartFile file, String filePath) {
+ Date date = new Date();
+ SimpleDateFormat format = new SimpleDateFormat("yyyyMMddhhmmssS");
+ String name = getFileNameNoEx(file.getOriginalFilename());
+ String suffix = getExtensionName(file.getOriginalFilename());
+ String nowStr = "-" + format.format(date);
+ try {
+ String fileName = name + nowStr + "." + suffix;
+ String path = filePath + fileName;
+ // getCanonicalFile 可解析正确各种路径
+ File dest = new File(path).getCanonicalFile();
+ // 检测是否存在目录
+ if (!dest.getParentFile().exists()) {
+ if (!dest.getParentFile().mkdirs()) {
+ System.out.println("was not successful.");
+ }
+ }
+ // 文件写入
+ file.transferTo(dest);
+ return dest;
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+ return null;
+ }
+
+ /**
+ * 导出excel
+ */
+ public static void downloadExcel(List> list, HttpServletResponse response) throws IOException {
+ String tempPath = SYS_TEM_DIR + IdUtil.fastSimpleUUID() + ".xlsx";
+ File file = new File(tempPath);
+ BigExcelWriter writer = ExcelUtil.getBigWriter(file);
+ // 一次性写出内容，使用默认样式，强制输出标题
+ writer.write(list, true);
+ SXSSFSheet sheet = (SXSSFSheet)writer.getSheet();
+ //上面需要强转SXSSFSheet 不然没有trackAllColumnsForAutoSizing方法
+ sheet.trackAllColumnsForAutoSizing();
+ //列宽自适应
+ writer.autoSizeColumnAll();
+ //列宽自适应支持中文单元格
+ sizeChineseColumn(sheet, writer);
+ //response为HttpServletResponse对象
+ response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet;charset=utf-8");
+ //test.xls是弹出下载对话框的文件名，不能为中文，中文请自行编码
+ response.setHeader("Content-Disposition", "attachment;filename=file.xlsx");
+ ServletOutputStream out = response.getOutputStream();
+ // 终止后删除临时文件
+ file.deleteOnExit();
+ writer.flush(out, true);
+ //此处记得关闭输出Servlet流
+ IoUtil.close(out);
+ }
+
+ /**
+ * 自适应宽度(中文支持)
+ */
+ private static void sizeChineseColumn(SXSSFSheet sheet, BigExcelWriter writer) {
+ for (int columnNum = 0; columnNum < writer.getColumnCount(); columnNum++) {
+ int columnWidth = sheet.getColumnWidth(columnNum) / 256;
+ for (int rowNum = 0; rowNum < sheet.getLastRowNum(); rowNum++) {
+ SXSSFRow currentRow;
+ if (sheet.getRow(rowNum) == null) {
+ currentRow = sheet.createRow(rowNum);
+ } else {
+ currentRow = sheet.getRow(rowNum);
+ }
+ if (currentRow.getCell(columnNum) != null) {
+ SXSSFCell currentCell = currentRow.getCell(columnNum);
+ if (currentCell.getCellTypeEnum() == CellType.STRING) {
+ int length = currentCell.getStringCellValue().getBytes().length;
+ if (columnWidth < length) {
+ columnWidth = length;
+ }
+ }
+ }
+ }
+ sheet.setColumnWidth(columnNum, columnWidth * 256);
+ }
+ }
+
+ public static String getFileType(String type) {
+ String documents = "txt doc pdf ppt pps xlsx xls docx";
+ String music = "mp3 wav wma mpa ram ra aac aif m4a";
+ String video = "avi mpg mpe mpeg asf wmv mov qt rm mp4 flv m4v webm ogv ogg";
+ String image = "bmp dib pcp dif wmf gif jpg tif eps psd cdr iff tga pcd mpt png jpeg";
+ if (image.contains(type)) {
+ return IMAGE;
+ } else if (documents.contains(type)) {
+ return TXT;
+ } else if (music.contains(type)) {
+ return MUSIC;
+ } else if (video.contains(type)) {
+ return VIDEO;
+ } else {
+ return OTHER;
+ }
+ }
+
+ public static void checkSize(long maxSize, long size) {
+ // 1M
+ int len = 1024 * 1024;
+ if (size > (maxSize * len)) {
+ throw new BaseException("文件超出规定大小");
+ }
+ }
+
+ /**
+ * 判断两个文件是否相同
+ */
+ public static boolean check(File file1, File file2) {
+ String img1Md5 = getMd5(file1);
+ String img2Md5 = getMd5(file2);
+ return img1Md5.equals(img2Md5);
+ }
+
+ /**
+ * 判断两个文件是否相同
+ */
+ public static boolean check(String file1Md5, String file2Md5) {
+ return file1Md5.equals(file2Md5);
+ }
+
+ private static byte[] getByte(File file) {
+ // 得到文件长度
+ byte[] b = new byte[(int) file.length()];
+ try {
+ InputStream in = new FileInputStream(file);
+ try {
+ System.out.println(in.read(b));
+ } catch (IOException e) {
+ log.error(e.getMessage(), e);
+ }
+ } catch (FileNotFoundException e) {
+ log.error(e.getMessage(), e);
+ return null;
+ }
+ return b;
+ }
+
+ private static String getMd5(byte[] bytes) {
+ // 16进制字符
+ char[] hexDigits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
+ try {
+ MessageDigest mdTemp = MessageDigest.getInstance("MD5");
+ mdTemp.update(bytes);
+ byte[] md = mdTemp.digest();
+ int j = md.length;
+ char[] str = new char[j * 2];
+ int k = 0;
+ // 移位 输出字符串
+ for (byte byte0 : md) {
+ str[k++] = hexDigits[byte0 >>> 4 & 0xf];
+ str[k++] = hexDigits[byte0 & 0xf];
+ }
+ return new String(str);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+ return null;
+ }
+
+ /**
+ * 下载文件
+ *
+ * @param request /
+ * @param response /
+ * @param file /
+ */
+ public static void downloadFile(HttpServletRequest request, HttpServletResponse response, File file, boolean deleteOnExit) {
+ response.setCharacterEncoding(request.getCharacterEncoding());
+ response.setContentType("application/octet-stream");
+ FileInputStream fis = null;
+ try {
+ fis = new FileInputStream(file);
+ response.setHeader("Content-Disposition", "attachment; filename=" + file.getName());
+ IOUtils.copy(fis, response.getOutputStream());
+ response.flushBuffer();
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ } finally {
+ if (fis != null) {
+ try {
+ fis.close();
+ if (deleteOnExit) {
+ file.deleteOnExit();
+ }
+ } catch (IOException e) {
+ log.error(e.getMessage(), e);
+ }
+ }
+ }
+ }
+
+ public static String getMd5(File file) {
+ return getMd5(getByte(file));
+ }
+}
diff --git a/common/src/main/java/com/canvas/web/utils/JsonResult.java b/common/src/main/java/com/canvas/web/utils/JsonResult.java
new file mode 100644
index 0000000..e70c36a
--- /dev/null
+++ b/common/src/main/java/com/canvas/web/utils/JsonResult.java
@@ -0,0 +1,112 @@
+package com.canvas.web.utils;
+
+import org.springframework.http.HttpStatus;
+
+import java.io.Serializable;
+
+public class JsonResult implements Serializable {
+
+ // 错误码
+ private Integer code= HttpStatus.OK.value();
+
+ //提示语
+ private String msg= "操作成功";
+
+ //返回对象
+ private Object data;
+
+ public Integer getCode() {
+ return this.code;
+ }
+
+ public void setCode(final Integer code) {
+ this.code = code;
+ }
+
+ public String getMsg() {
+ return this.msg;
+ }
+
+ public void setMsg(final String msg) {
+ this.msg = msg;
+ }
+
+ public Object getData() {
+ return this.data;
+ }
+
+ public void setData(final Object data) {
+ this.data = data;
+ }
+
+ /**
+ * 构造函数
+ */
+ public JsonResult() {
+ }
+
+ public JsonResult(String msg) {
+ this.msg = msg;
+ }
+
+ public JsonResult(Object data) {
+ this.data = data;
+ }
+
+ public JsonResult(Integer code, String msg) {
+ this.code = code;
+ this.msg = msg;
+ }
+
+ public JsonResult(Integer code, String msg, Object data) {
+ this.code = code;
+ this.msg = msg;
+ this.data = data;
+ }
+
+ public static JsonResult success() {
+ return new JsonResult();
+ }
+
+ public static JsonResult success(String msg) {
+ return new JsonResult(msg);
+ }
+
+ public JsonResult success(Object data) {
+ return new JsonResult(HttpStatus.OK.value(), msg, data);
+ }
+
+ public static JsonResult success(String msg, Object data) {
+ return new JsonResult(HttpStatus.OK.value(), msg, data);
+ }
+
+ public static JsonResult error() {
+ return new JsonResult(-1, "操作失败");
+ }
+
+ public static JsonResult error(String msg) {
+ return new JsonResult(-1, msg);
+ }
+
+ public static JsonResult error(Integer code, String msg) {
+ return new JsonResult(code, msg);
+ }
+
+ public static JsonResult error(Integer code, String msg, Object data) {
+ return new JsonResult(code, msg, data);
+ }
+
+ public static JsonResult error(ErrorCode errorCode) {
+ return new JsonResult(errorCode.getCode(), errorCode.getMsg());
+ }
+
+ public static JsonResult error(HttpStatus httpStatus, String msg, Object data) {
+ return new JsonResult(httpStatus.value(), msg, data);
+ }
+
+ public Object error(HttpStatus httpStatus, String msg) {
+ this.code = httpStatus.value();
+ this.msg = msg;
+ return this;
+ }
+}
diff --git a/common/src/main/java/com/canvas/web/utils/RedisUtils.java b/common/src/main/java/com/canvas/web/utils/RedisUtils.java
new file mode 100644
index 0000000..2570217
--- /dev/null
+++ b/common/src/main/java/com/canvas/web/utils/RedisUtils.java
@@ -0,0 +1,696 @@
+package com.canvas.web.utils;
+
+import com.google.common.collect.Lists;
+import com.google.common.collect.Sets;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.Cursor;
+import org.springframework.data.redis.core.RedisConnectionUtils;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+@Component
+public class RedisUtils {
+
+ private static final Logger log = LoggerFactory.getLogger(RedisUtils.class);
+ private RedisTemplate redisTemplate;
+ @Value("${jwt.online-key}")
+ private String onlineKey;
+
+ public RedisUtils(RedisTemplate redisTemplate) {
+ this.redisTemplate = redisTemplate;
+ }
+
+ /**
+ * 指定缓存失效时间
+ *
+ * @param key 键
+ * @param time 时间(秒)
+ */
+ public boolean expire(String key, long time) {
+ try {
+ if (time > 0) {
+ redisTemplate.expire(key, time, TimeUnit.SECONDS);
+ }
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ return false;
+ }
+ return true;
+ }
+
+ /**
+ * 指定缓存失效时间
+ *
+ * @param key 键
+ * @param time 时间(秒)
+ * @param timeUnit 单位
+ */
+ public boolean expire(String key, long time, TimeUnit timeUnit) {
+ try {
+ if (time > 0) {
+ redisTemplate.expire(key, time, timeUnit);
+ }
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ return false;
+ }
+ return true;
+ }
+
+ /**
+ * 根据 key 获取过期时间
+ *
+ * @param key 键 不能为null
+ * @return 时间(秒) 返回0代表为永久有效
+ */
+ public long getExpire(Object key) {
+ return redisTemplate.getExpire(key, TimeUnit.SECONDS);
+ }
+
+ /**
+ * 查找匹配key
+ *
+ * @param pattern key
+ * @return /
+ */
+ public List scan(String pattern) {
+ ScanOptions options = ScanOptions.scanOptions().match(pattern).build();
+ RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
+ RedisConnection rc = Objects.requireNonNull(factory).getConnection();
+ Cursor cursor = rc.scan(options);
+ List result = new ArrayList<>();
+ while (cursor.hasNext()) {
+ result.add(new String(cursor.next()));
+ }
+ try {
+ RedisConnectionUtils.releaseConnection(rc, factory);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+ return result;
+ }
+
+ /**
+ * 分页查询 key
+ *
+ * @param patternKey key
+ * @param page 页码
+ * @param size 每页数目
+ * @return /
+ */
+ public List findKeysForPage(String patternKey, int page, int size) {
+ ScanOptions options = ScanOptions.scanOptions().match(patternKey).build();
+ RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
+ RedisConnection rc = Objects.requireNonNull(factory).getConnection();
+ Cursor cursor = rc.scan(options);
+ List result = new ArrayList<>(size);
+ int tmpIndex = 0;
+ int fromIndex = page * size;
+ int toIndex = page * size + size;
+ while (cursor.hasNext()) {
+ if (tmpIndex >= fromIndex && tmpIndex < toIndex) {
+ result.add(new String(cursor.next()));
+ tmpIndex++;
+ continue;
+ }
+ // 获取到满足条件的数据后,就可以退出了
+ if (tmpIndex >= toIndex) {
+ break;
+ }
+ tmpIndex++;
+ cursor.next();
+ }
+ try {
+ RedisConnectionUtils.releaseConnection(rc, factory);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ }
+ return result;
+ }
+
+ /**
+ * 判断key是否存在
+ *
+ * @param key 键
+ * @return true 存在 false不存在
+ */
+ public boolean hasKey(String key) {
+ try {
+ return redisTemplate.hasKey(key);
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ return false;
+ }
+ }
+
+ /**
+ * 删除缓存
+ *
+ * @param keys 可以传一个值 或多个
+ */
+ public void del(String... keys) {
+ if (keys != null && keys.length > 0) {
+ if (keys.length == 1) {
+ boolean result = redisTemplate.delete(keys[0]);
+ log.debug("--------------------------------------------");
+ log.debug(new StringBuilder("删除缓存：").append(keys[0]).append("，结果：").append(result).toString());
+ log.debug("--------------------------------------------");
+ } else {
+ Set