diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..7944320
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,161 @@
+
+
+ 4.0.0
+
+
+
+
+ 1.0-SNAPSHOT
+ ../pom.xml
+
+
+
+ common-module
+ 0.0.1-SNAPSHOT
+ common-module
+ Demo project for Spring Boot
+
+
+ 8
+ 4.4.0
+ 1.2.78
+ 5.7.16
+ 33.2.1-jre
+ 4.1.0
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter
+
+
+ com.github.xiaoymin
+ knife4j-openapi3-spring-boot-starter
+ ${knife4j.version}
+
+
+ commons-lang3
+ org.apache.commons
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ org.projectlombok
+ lombok
+ true
+
+
+ org.apache.commons
+ commons-lang3
+ 3.12.0
+
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
+
+ io.lettuce
+ lettuce-core
+
+
+
+
+ redis.clients
+ jedis
+
+
+
+ cn.hutool
+ hutool-all
+ ${hutool.version}
+
+
+
+ com.auth0
+ java-jwt
+ ${jwt.version}
+
+
+ org.apache.httpcomponents
+ httpclient
+
+
+
+ com.alibaba
+ fastjson
+ ${fastjson.version}
+
+
+ commons-io
+ commons-io
+ 2.16.1
+ compile
+
+
+ com.google.guava
+ guava
+ ${guava.version}
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ 3.5.1
+
+
+ com.aostarit
+ smcrypto
+ 1.0
+ system
+ ${project.basedir}/src/main/resources/libs/aostarit.smcrypto-1.0.0.jar
+
+
+
+ com.alibaba
+ easyexcel
+ 2.2.8
+
+
+ com.fasterxml.jackson.core
+ jackson-annotations
+ 2.17.1
+
+
+
+ com.github.ulisesbocchio
+ jasypt-spring-boot-starter
+
+
+
+ commons-codec
+ commons-codec
+ 1.16.1
+
+
+ org.bouncycastle
+ bcprov-jdk15to18
+ 1.68
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+ true
+
+
+
+
+
+
diff --git a/utils/AESPKCS7PaddingUtils.java b/utils/AESPKCS7PaddingUtils.java
new file mode 100644
index 0000000..0aee4a0
--- /dev/null
+++ b/utils/AESPKCS7PaddingUtils.java
@@ -0,0 +1,127 @@
+package com.sgcc.utils;
+
+import ch.qos.logback.core.boolex.EvaluationException;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.binary.Base64;
+import org.bouncycastle.jce.provider.BouncyCastleProvider;
+
+import javax.crypto.Cipher;
+import javax.crypto.spec.IvParameterSpec;
+import javax.crypto.spec.SecretKeySpec;
+import java.security.Security;
+
+/**
+ * AES加密/解密工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/11/22 14:03
+ */
+@Slf4j
+public class AESPKCS7PaddingUtils {
+
+ /**
+ * 密钥算法
+ */
+ private static final String KEY_ALGORITHM = "AES";
+
+ /**
+ * 加密/解密算法 / 工作模式 / 填充方式
+ * Java 6支持PKCS5Padding填充方式
+ * Bouncy Castle支持PKCS7Padding填充方式
+ */
+ private static final String CIPHER_ALGORITHM = "AES/CBC/PKCS7Padding";
+
+ /**
+ * 偏移量，只有CBC模式才需要
+ */
+ private final static String ivParameter = "0000000000000000";
+
+ /**
+ * AES要求密钥长度为128位或192位或256位，java默认限制AES密钥长度最多128位
+ */
+ public static String secretKey = "";
+
+ /**
+ * 编码格式
+ */
+ public static final String ENCODING = "utf-8";
+
+ static {
+ //如果是PKCS7Padding填充方式，则必须加上下面这行
+ Security.addProvider(new BouncyCastleProvider());
+ }
+
+ /**
+ * AES加密
+ *
+ * @param source 源字符串
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/11/22 14:05
+ */
+ public static String encrypt(String source) {
+ try {
+ byte[] sourceBytes = source.getBytes(ENCODING);
+ byte[] keyBytes = secretKey.getBytes(ENCODING);
+ Cipher cipher = Cipher.getInstance(CIPHER_ALGORITHM, "BC");
+ IvParameterSpec iv = new IvParameterSpec(ivParameter.getBytes(ENCODING));
+ cipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(keyBytes, KEY_ALGORITHM),iv);
+ byte[] decrypted = cipher.doFinal(sourceBytes);
+ return Base64.encodeBase64String(decrypted);
+ } catch (Exception e) {
+ log.error(e.toString());
+ }
+ return null;
+ }
+
+ /**
+ * AES解密
+ *
+ * @param encryptStr 加密后的密文
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/11/22 14:05
+ */
+ public static String decrypt(String encryptStr) {
+ try {
+ byte[] sourceBytes = Base64.decodeBase64(encryptStr);
+ byte[] keyBytes = secretKey.getBytes(ENCODING);
+ Cipher cipher = Cipher.getInstance(CIPHER_ALGORITHM, "BC");
+ IvParameterSpec iv = new IvParameterSpec(ivParameter.getBytes(ENCODING));
+ cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(keyBytes, KEY_ALGORITHM),iv);
+ byte[] decoded = cipher.doFinal(sourceBytes);
+ return new String(decoded, ENCODING);
+ } catch (Exception e) {
+ log.error(e.toString());
+ }
+ return null;
+ }
+
+ /**
+ * 校验密码
+ *
+ * @param inputPassword 输入密码
+ * @param password 数据库存储密码
+ * @return boolean
+ * @author zhaoyuanyuan
+ * @date 2024/11/23 09:40
+ */
+ public static boolean validatePassword(String inputPassword, String password) {
+ if (decrypt(inputPassword).equals(decrypt(password))) {
+ return true;
+ }
+ return false;
+ }
+
+ public static void main(String[] args) throws Exception {
+ //加密
+ String enString = AESPKCS7PaddingUtils.encrypt("12345678");
+ System.out.println("加密后的字串是：" + enString);
+ // 解密
+ String DeString = AESPKCS7PaddingUtils.decrypt("wUpDBpZlm//omEBf20WCag==");
+ System.out.println("解密后的字串是：" + DeString);
+ }
+
+}
+
diff --git a/utils/BeanUtils.java b/utils/BeanUtils.java
new file mode 100644
index 0000000..e5504b5
--- /dev/null
+++ b/utils/BeanUtils.java
@@ -0,0 +1,514 @@
+package com.sgcc.utils;
+
+import com.google.common.collect.Maps;
+import java.beans.BeanInfo;
+import java.beans.IntrospectionException;
+import java.beans.Introspector;
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanWrapper;
+import org.springframework.beans.BeanWrapperImpl;
+import org.springframework.core.io.Resource;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.core.io.support.ResourcePatternResolver;
+import org.springframework.core.type.classreading.CachingMetadataReaderFactory;
+import org.springframework.core.type.classreading.MetadataReader;
+import org.springframework.core.type.classreading.MetadataReaderFactory;
+import org.springframework.util.Assert;
+import org.springframework.util.ReflectionUtils;
+
+/**
+ * 实体转化工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/24 17:35
+ */
+@Slf4j
+public class BeanUtils {
+
+ private static final String CLASS = "class";
+
+ private BeanUtils() {
+ throw new IllegalStateException("Utility class");
+ }
+
+ /**
+ * 判断对象是否为数字
+ *
+ * @param o
+ * @return
+ */
+ public static boolean isNumber(Object o) {
+ if (o == null) {
+ return false;
+ }
+ if (o instanceof Number) {
+ return true;
+ }
+ if (o instanceof String) {
+ try {
+ Double.parseDouble((String) o);
+ return true;
+ } catch (NumberFormatException e) {
+ return false;
+ }
+ }
+ return false;
+ }
+
+ /**
+ * 将bean转化为map
+ *
+ * @param clazz bean
+ * @param 泛型
+ * @return Map 返回对象
+ */
+ public static Map toMap(final T clazz) {
+ Map paramsMap = Maps.newHashMap();
+ try {
+ BeanInfo bi = Introspector.getBeanInfo(clazz.getClass());
+ PropertyDescriptor[] pd = bi.getPropertyDescriptors();
+ for (int i = 0; i < pd.length; i++) {
+ String name = pd[i].getName();
+ Method method = pd[i].getReadMethod();
+ Object value = method.invoke(clazz);
+ if (!CLASS.equals(name)) {
+ paramsMap.put(name, value);
+ }
+ }
+ } catch (IntrospectionException ie) {
+ log.error("IntrospectionException.className=" + clazz.getClass() + "BeanInfo error : ", ie);
+ } catch (Exception e) {
+ log.error("Exception.className=" + clazz.getClass() + "Method error :", e);
+ }
+ return paramsMap;
+ }
+
+ /**
+ * 获取到对象中属性为指定值的属性名
+ *
+ * @param source 要拷贝的对象
+ * @param values 指定的值数组
+ * @return
+ */
+ public static String[] getPropertyNamesWithValues(Object source, String... values) {
+ List valueList = (values != null ? Arrays.asList(values) : null);
+ final BeanWrapper src = new BeanWrapperImpl(source);
+ PropertyDescriptor[] pds = src.getPropertyDescriptors();
+ Set propertyNames = new HashSet<>();
+ for (PropertyDescriptor pd : pds) {
+ Object srcValue = src.getPropertyValue(pd.getName());
+ if (valueList == null && srcValue == null) {
+ propertyNames.add(pd.getName());
+ } else if (valueList != null && valueList.contains(srcValue)) {
+ propertyNames.add(pd.getName());
+ } else {
+ // DO NOTHING
+ }
+ }
+ String[] result = new String[propertyNames.size()];
+ return propertyNames.toArray(result);
+ }
+
+ /**
+ * 列表实体类属性拷贝，忽略null值
+ *
+ * @param fromList 待转换实体列数组
+ * @param tClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static List copyPropertiesIgnoreNull(List fromList, Class tClass) {
+ return copyPropertiesIgnoreValues(fromList, tClass, (String[]) null);
+ }
+
+ /**
+ * 实体类属性拷贝，忽略null值、空字符串""和"null"
+ *
+ * @param fromList 待转换实体列数组
+ * @param tClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static List copyPropertiesIgnoreEmpty(List fromList, Class tClass) {
+ return copyPropertiesIgnoreValues(fromList, tClass, null, "", "null");
+ }
+
+ /**
+ * 实体类列表属性拷贝，忽略指定值
+ * 将entityList转换成modelList
+ *
+ * @param fromList 待转换实体列数组
+ * @param tClass 目标类
+ * @param values 指定的值数组
+ * @param
+ * @param
+ * @return
+ */
+ public static List copyPropertiesIgnoreValues(List fromList, Class tClass, String... values) {
+ Assert.notNull(tClass, "tClass must not be null.");
+ List tList = new ArrayList<>();
+ if (fromList != null && !fromList.isEmpty()) {
+ for (F f : fromList) {
+ T t = copyPropertiesIgnoreValues(f, tClass, values);
+ tList.add(t);
+ }
+ }
+ return tList;
+ }
+
+ /**
+ * 实体类列表属性拷贝
+ * 将entityList转换成modelList
+ *
+ * @param fromList 待转换实体列数组
+ * @param tClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static List copyProperties(List fromList, Class tClass) {
+ Assert.notNull(tClass, "tClass must not be null.");
+ List tList = new ArrayList<>();
+ if (fromList != null && !fromList.isEmpty()) {
+ for (F f : fromList) {
+ T t = copyProperties(f, tClass);
+ tList.add(t);
+ }
+ }
+ return tList;
+ }
+
+ /**
+ * 实体类属性拷贝，忽略null值
+ *
+ * @param entity 实体类
+ * @param modelClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static T copyPropertiesIgnoreNull(F entity, Class modelClass) {
+ return copyPropertiesIgnoreValues(entity, modelClass, (String[]) null);
+ }
+
+ /**
+ * 实体类属性拷贝，忽略null值、空字符串""和"null"
+ *
+ * @param entity 实体类
+ * @param modelClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static T copyPropertiesIgnoreEmpty(F entity, Class modelClass) {
+ return copyPropertiesIgnoreValues(entity, modelClass, null, "", "null");
+ }
+
+ /**
+ * 实体类属性拷贝，忽略指定值
+ *
+ * @param entity 实体类
+ * @param modelClass 目标类
+ * @param values 指定的值数组
+ * @param
+ * @param
+ * @return
+ */
+ public static T copyPropertiesIgnoreValues(F entity, Class modelClass, String... values) {
+ return copyProperties(entity, modelClass, getPropertyNamesWithValues(entity, values));
+ }
+
+ /**
+ * 实体类属性拷贝
+ *
+ * @param entity 实体类
+ * @param modelClass 目标类
+ * @param
+ * @param
+ * @return
+ */
+ public static T copyProperties(F entity, Class modelClass) {
+ return copyProperties(entity, modelClass, (String[]) null);
+ }
+
+ /**
+ * 实体类属性拷贝
+ *
+ * @param entity 实体类
+ * @param modelClass 目标类
+ * @param ignoreProperties 忽略属性列表
+ * @param
+ * @param
+ * @return
+ */
+ public static T copyProperties(F entity, Class modelClass, String... ignoreProperties) {
+ Assert.notNull(modelClass, "modelClass must not be null.");
+ Object model = null;
+
+ try {
+ model = modelClass.newInstance();
+ } catch (InstantiationException e) {
+ log.error("copyProperties: InstantiationException", e);
+ } catch (IllegalAccessException e) {
+ log.error("copyProperties: IllegalAccessException", e);
+ }
+
+ if (entity != null) {
+ org.springframework.beans.BeanUtils.copyProperties(entity, model, ignoreProperties);
+ } else {
+ // DO NOTHING
+ }
+ return (T) model;
+ }
+
+ /**
+ * 将下划线大写方式命名的字符串转换为驼峰式。
+ * 如果转换前的下划线大写方式命名的字符串为空，则返回空字符串。
+ * 例如：hello_world->helloWorld
+ *
+ * @param name 转换前的下划线大写方式命名的字符串
+ * @return 转换后的驼峰式命名的字符串
+ */
+ public static String camelName(String name) {
+ StringBuilder result = new StringBuilder();
+ // 快速检查
+ if (name == null || name.isEmpty()) {
+ // 没必要转换
+ return "";
+ } else if (!name.contains("_")) {
+ // 不含下划线，仅将首字母小写
+ return name.substring(0, 1).toLowerCase() + name.substring(1).toLowerCase();
+ }
+ // 用下划线将原始字符串分割
+ String[] camels = name.split("_");
+ for (String camel : camels) {
+ // 跳过原始字符串中开头、结尾的下换线或双重下划线
+ if (camel.isEmpty()) {
+ continue;
+ }
+ // 处理真正的驼峰片段
+ if (result.length() == 0) {
+ // 第一个驼峰片段，全部字母都小写
+ result.append(camel.toLowerCase());
+ } else {
+ // 其他的驼峰片段，首字母大写
+ result.append(camel.substring(0, 1).toUpperCase());
+ result.append(camel.substring(1).toLowerCase());
+ }
+ }
+ return result.toString();
+ }
+
+ /**
+ * 将下划线大写方式命名的字符串转换为驼峰式。
+ * 如果转换前的下划线大写方式命名的字符串为空，则返回空字符串。
+ * 例如：hello_world,test_id->helloWorld,testId
+ *
+ * @param names 转换前的下划线大写方式命名的字符串
+ * @return 转换后的驼峰式命名的字符串
+ */
+ public static String camelNames(String names) {
+ if (names == null || names.equals("")) {
+ return null;
+ }
+ StringBuilder sb = new StringBuilder();
+ String[] fs = names.split(",");
+ for (String field : fs) {
+ field = camelName(field);
+ sb.append(field + ",");
+ }
+ String result = sb.toString();
+ return result.substring(0, result.length() - 1);
+ }
+
+ /**
+ * 将下划线大写方式命名的字符串转换为驼峰式。
+ * (首字母写) 如果转换前的下划线大写方式命名的字符串为空，
+ * 则返回空字符串。
+ * 例如：hello_world->HelloWorld
+ *
+ * @param name 转换前的下划线大写方式命名的字符串
+ * @return 转换后的驼峰式命名的字符串
+ */
+ public static String camelNameCapFirst(String name) {
+ // 转换为首字母小写的驼峰片段
+ String camel = camelName(name);
+ if (camel == null || camel.length() < 1) {
+ return name;
+ }
+ // 首字母大写
+ char[] charArray = camel.toCharArray();
+ charArray[0] -= 32;
+ return String.valueOf(charArray);
+ }
+
+ /**
+ * 将驼峰命名转化成下划线
+ *
+ * @param param
+ * @return
+ */
+ public static String camelToUnderline(String param) {
+ if (param == null) {
+ return null;
+ }
+ int paramLen = param.length();
+ if (paramLen < 3) {
+ return param.toLowerCase();
+ }
+ int wordCount = 0;
+ StringBuilder sb = new StringBuilder(param);
+ // 从第三个字符开始 避免命名不规范
+ for (int i = 2; i < paramLen; i++) {
+ if (Character.isUpperCase(param.charAt(i))) {
+ sb.insert(i + wordCount, "_");
+ wordCount += 1;
+ }
+ }
+ return sb.toString().toLowerCase();
+ }
+
+ /**
+ * 根据指定的类名判定指定的类是否存在。
+ *
+ * @param className
+ * @return
+ */
+ public static boolean validClass(String className) {
+ try {
+ Class.forName(className);
+ return true;
+ } catch (ClassNotFoundException e) {
+ return false;
+ }
+ }
+
+ /**
+ * 判定类是否继承自父类
+ *
+ * @param cls 子类
+ * @param parentClass 父类
+ * @return
+ */
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ public static boolean isInherit(Class cls, Class parentClass) {
+ return parentClass.isAssignableFrom(cls);
+ }
+
+ /**
+ * 输入基类包名，扫描其下的类，返回类的全路径
+ *
+ * @param basePackages 如：com.hotent
+ * @return
+ * @throws IllegalArgumentException
+ */
+ @SuppressWarnings("all")
+ public static List scanPackages(String basePackages)
+ throws IllegalArgumentException {
+ ResourcePatternResolver rl = new PathMatchingResourcePatternResolver();
+ MetadataReaderFactory metadataReaderFactory = new CachingMetadataReaderFactory(
+ rl);
+ List result = new ArrayList();
+ String[] arrayPackages = basePackages.split(",");
+ try {
+ for (int j = 0; j < arrayPackages.length; j++) {
+ String packageToScan = arrayPackages[j];
+ String packagePart = packageToScan.replace('.', '/');
+ String classPattern = "classpath*:/" + packagePart
+ + "/**/*.class";
+ Resource[] resources = rl.getResources(classPattern);
+ for (int i = 0; i < resources.length; i++) {
+ Resource resource = resources[i];
+ MetadataReader metadataReader = metadataReaderFactory
+ .getMetadataReader(resource);
+ String className = metadataReader.getClassMetadata()
+ .getClassName();
+ result.add(className);
+ }
+ }
+ } catch (Exception e) {
+ new IllegalArgumentException("scan pakcage class error,pakcages:"
+ + basePackages);
+ }
+
+ return result;
+ }
+
+ /**
+ * 将字符串数据按照指定的类型进行转换。
+ *
+ * @param typeName 实际的数据类型
+ * @param value 字符串值。
+ * @return Object
+ */
+ public static Object convertByActType(String typeName, String value) {
+ Object o = null;
+ if (typeName.equals("int")) {
+ o = Integer.parseInt(value);
+ } else if (typeName.equals("short")) {
+ o = Short.parseShort(value);
+ } else if (typeName.equals("long")) {
+ o = Long.parseLong(value);
+ } else if (typeName.equals("float")) {
+ o = Float.parseFloat(value);
+ } else if (typeName.equals("double")) {
+ o = Double.parseDouble(value);
+ } else if (typeName.equals("boolean")) {
+ o = Boolean.parseBoolean(value);
+ } else if (typeName.equals("java.lang.String")) {
+ o = value;
+ } else {
+ o = value;
+ }
+ return o;
+ }
+
+ /**
+ * 根据类和成员变量名称获取成员变量。
+ *
+ * @param thisClass
+ * @param fieldName
+ * @return
+ * @throws NoSuchFieldException Field
+ */
+ public static Field getField(Class thisClass, String fieldName)
+ throws NoSuchFieldException {
+
+ if (fieldName == null) {
+ throw new NoSuchFieldException("Error field !");
+ }
+
+ Field field = thisClass.getDeclaredField(fieldName);
+ return field;
+ }
+
+ /**
+ * 数据列表去重
+ *
+ * @param list
+ */
+ @SuppressWarnings({"rawtypes", "unchecked"})
+ public static void removeDuplicate(List list) {
+ HashSet h = new HashSet(list);
+ list.clear();
+ list.addAll(h);
+ }
+
+ private static void handleReflectionException(Exception e) {
+ ReflectionUtils.handleReflectionException(e);
+ }
+
+}
\ No newline at end of file
diff --git a/utils/ClassUtils.java b/utils/ClassUtils.java
new file mode 100644
index 0000000..06f1bd1
--- /dev/null
+++ b/utils/ClassUtils.java
@@ -0,0 +1,58 @@
+package com.sgcc.utils;
+
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Class反射工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/24 17:26
+ */
+public class ClassUtils {
+
+ /**
+ * 对象转化为Map
+ *
+ * @param obj
+ * @return {@code Map }
+ * @author zhaoyuanyuan
+ * @date 2024/06/24 17:26
+ */
+ public static Map objectToMap(Object obj) throws IllegalAccessException {
+ Map map = new HashMap<>();
+ if (obj == null){
+ return map;
+ }
+ Field[] fields = obj.getClass().getDeclaredFields();
+ for(Field field:fields){
+ field.setAccessible(true);
+ map.put(field.getName(), field.get(obj));
+ }
+ return map;
+ }
+
+ /**
+ * 类型转化，实体对象列表转Map列表
+ *
+ * @param objectList
+ * @return {@code List> }
+ * @author zhaoyuanyuan
+ * @date 2024/06/24 17:27
+ */
+ public static List> objectListToListMap(List objectList) throws IllegalAccessException {
+ List> resultList = new ArrayList<>();
+ if (objectList == null || objectList.isEmpty()){
+ return resultList;
+ }
+ for (T t : objectList) {
+ resultList.add(objectToMap(t));
+ }
+ return resultList;
+ }
+
+}
diff --git a/utils/CommonUtils.java b/utils/CommonUtils.java
new file mode 100644
index 0000000..a885cc3
--- /dev/null
+++ b/utils/CommonUtils.java
@@ -0,0 +1,200 @@
+package com.sgcc.utils;
+
+import com.alibaba.fastjson.JSON;
+import java.io.IOException;
+import java.io.InputStream;
+import java.math.RoundingMode;
+import java.security.SecureRandom;
+import java.text.DecimalFormat;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Random;
+import java.util.stream.Collectors;
+
+import com.sgcc.constant.Constants;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.io.IOUtils;
+
+/**
+ * 共通方法工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/24 17:18
+ */
+@Slf4j
+public class CommonUtils {
+
+ public static final String JSON_PATH = "classpath:json/";
+
+ /**
+ * ip和掩码分隔符
+ */
+ public static final String IP_MASK_CODE_SEPARATOR = "\\/";
+
+ /**
+ * 解析JSON值
+ *
+ * @param fileName 文件名
+ * @param clazz 实体类
+ * @param 泛型
+ * @return
+ */
+ public static T parseJson(String fileName, Class clazz) throws IOException {
+ return JSON.parseObject(readJsonFile(fileName), clazz);
+ }
+
+ /**
+ * 读取json格式文件
+ *
+ * @param fileName 文件名
+ * @return
+ */
+ public static String readJsonFile(String fileName) throws IOException {
+ return read(JSON_PATH + fileName);
+ }
+
+ /**
+ * 读取json格式文件
+ *
+ * @param path 文件路径
+ * @return
+ */
+ public static String read(String path) throws IOException {
+ String content = "";
+ InputStream stream = null;
+ try {
+ stream = CommonUtils.class.getClassLoader()
+ .getResourceAsStream(path.replace("classpath:", ""));
+ content = IOUtils.toString(stream, "UTF-8");
+ } catch (IOException e) {
+ log.error("read file[{}] catch IOException. {}", path, e.getMessage());
+ } finally {
+ stream.close();
+ }
+ return content;
+ }
+
+ /**
+ * 布尔值判断 true-0 false-1
+ *
+ * @param param
+ * @return {@code Integer }
+ * @author zhaoyuanyuan
+ * @date 2024/06/24 17:21
+ */
+ public static Integer booleanValueJudge(Boolean param) {
+ if (param == null) {
+ return null;
+ }
+ if (param) {
+ return Constants.IS_TRUE;
+ } else {
+ return Constants.IS_FALSE;
+ }
+ }
+
+ /**
+ * 获取IP地址
+ *
+ * @param ipAndMaskOffCode ip和屏蔽代码
+ * @return {@code String}
+ */
+ public static String getIp(String ipAndMaskOffCode) {
+ String ip = "";
+ if(StringUtils.isEmpty(ipAndMaskOffCode)){
+ return ip;
+ }
+ String[] ipAndMaskOffCodes = ipAndMaskOffCode.split(IP_MASK_CODE_SEPARATOR);
+ if (ipAndMaskOffCodes.length > 1) {
+ ip = ipAndMaskOffCodes[0];
+ }else {
+ ip =ipAndMaskOffCode;
+ }
+ return ip;
+ }
+
+ /**
+ * 获取掩码
+ *
+ * @param ipAndMaskOffCode ip和屏蔽代码
+ * @return {@code String}
+ */
+ public static String getMaskOffCode(String ipAndMaskOffCode) {
+ String maskOffCode = "";
+ if (StringUtils.isEmpty(ipAndMaskOffCode)){
+ return maskOffCode;
+ }
+ String[] ipAndMaskOffCodes = ipAndMaskOffCode.split(IP_MASK_CODE_SEPARATOR);
+ if (ipAndMaskOffCodes.length >= 2) {
+ maskOffCode = ipAndMaskOffCodes[1];
+ }
+ return maskOffCode;
+ }
+
+ /**
+ * 字符串形式的数组转换为List
+ *
+ * @param integerArrStr 数组字符串
+ * @return {@code List }
+ * @author zhaoyuanyuan
+ * @date 2024/07/11 09:43
+ */
+ public static List string2IntegerList(String integerArrStr) {
+ List tempList = Arrays.asList(integerArrStr.split(","));
+ List resultList = tempList.stream().map(Integer::valueOf).collect(Collectors.toList());
+ return resultList;
+ }
+
+ /**
+ * 随机获取列表中的某一个元素
+ *
+ * @param list 列表
+ * @return {@code T }
+ * @author zhaoyuanyuan
+ * @date 2024/07/18 16:16
+ */
+ public static T getRandomElement(List list) {
+ if (list == null || list.isEmpty()) {
+ throw new IllegalArgumentException("List cannot be null or empty");
+ }
+ SecureRandom random = new SecureRandom();
+ int index = random.nextInt(list.size());
+ return list.get(index);
+ }
+
+ /**
+ * Double类型数据保留两位小数
+ *
+ * @param value 值
+ * @return {@code Double }
+ * @author zhaoyuanyuan
+ * @date 2024/09/18 14:01
+ */
+ public static Double formatDouble(Double value) {
+ //格式化字符串,表示两位小数
+ DecimalFormat df = new DecimalFormat("#.00");
+ //设置格式化器
+ df.setRoundingMode(RoundingMode.HALF_UP);
+ //转换并输出
+ String formattedValue = df.format(value);
+ return Double.valueOf(formattedValue);
+ }
+
+ /**
+ * 身份证号脱敏处理
+ *
+ * @param idCard 身份证号
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/11/21 13:14
+ */
+ public static String desensitizedIdCard(String idCard) {
+ if (idCard == null || (idCard.length() != 18 && idCard.length() != 15)) {
+ return null;
+ }
+ return idCard.replaceAll("^(\\d{6})(\\d+)(\\d{4})$", "$1****$3");
+ }
+
+}
\ No newline at end of file
diff --git a/utils/DateUtils.java b/utils/DateUtils.java
new file mode 100644
index 0000000..042beeb
--- /dev/null
+++ b/utils/DateUtils.java
@@ -0,0 +1,300 @@
+package com.sgcc.utils;
+
+import java.lang.management.ManagementFactory;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.time.Duration;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.util.Date;
+import org.apache.commons.lang3.time.DateFormatUtils;
+
+/**
+ * 时间日期工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/07/23 14:24
+ */
+public class DateUtils extends org.apache.commons.lang3.time.DateUtils {
+
+ public static final String YYYY = "yyyy";
+
+ public static final String YYYY_MM = "yyyy-MM";
+
+ public static final String YYYY_MM_DD = "yyyy-MM-dd";
+
+ public static final String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
+
+ public static final String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
+
+ private static final String[] parsePatterns = {
+ "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
+ "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
+ "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM" };
+
+ /**
+ * 获取当前Date型日期
+ *
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:25
+ */
+ public static Date getNowDate() {
+ return new Date();
+ }
+
+ /**
+ * 获取当前Date型日期 YYYY_MM_DD
+ *
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:25
+ */
+ public static String getDate() {
+ return dateTimeNow(YYYY_MM_DD);
+ }
+
+ /**
+ * 获取当前Date型日期 YYYY_MM_DD_HH_MM_SS
+ *
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:25
+ */
+ public static final String getTime() {
+ return dateTimeNow(YYYY_MM_DD_HH_MM_SS);
+ }
+
+ /**
+ * 获取当前Date型日期 YYYYMMDDHHMMSS
+ *
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:25
+ */
+ public static final String dateTimeNow() {
+ return dateTimeNow(YYYYMMDDHHMMSS);
+ }
+
+ /**
+ * 获取当前Date型日期 format
+ *
+ * @param format 格式化类型
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:25
+ */
+ public static final String dateTimeNow(final String format) {
+ return parseDateToStr(format, new Date());
+ }
+
+ /**
+ * 获取Date型日期 YYYY_MM_DD
+ *
+ * @param date
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:26
+ */
+ public static final String dateTime(final Date date) {
+ return parseDateToStr(YYYY_MM_DD, date);
+ }
+
+ /**
+ * 将Date型日期转换为format型字符串
+ *
+ * @param format 格式化类型
+ * @param date 日期
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:26
+ */
+ public static final String parseDateToStr(final String format, final Date date) {
+ return new SimpleDateFormat(format).format(date);
+ }
+
+ /**
+ * 获取Date型日期 format
+ *
+ * @param format 格式化类型
+ * @param ts 日期字符串
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:27
+ */
+ public static final Date dateTime(final String format, final String ts) {
+ try {
+ return new SimpleDateFormat(format).parse(ts);
+ } catch (ParseException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 日期路径 即年/月/日 如2024/08/08
+ *
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:27
+ */
+ public static final String datePath() {
+ Date now = new Date();
+ return DateFormatUtils.format(now, "yyyy/MM/dd");
+ }
+
+ /**
+ * 日期路径 即年/月/日 如20240808
+ *
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:27
+ */
+ public static final String dateTime() {
+ Date now = new Date();
+ return DateFormatUtils.format(now, "yyyyMMdd");
+ }
+
+ /**
+ * 日期型字符串转化为日期格式
+ *
+ * @param str
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:28
+ */
+ public static Date parseDate(Object str) {
+ if (str == null) {
+ return null;
+ }
+ try {
+ return parseDate(str.toString(), parsePatterns);
+ } catch (ParseException e) {
+ return null;
+ }
+ }
+
+ /**
+ * 获取服务器启动时间
+ *
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:28
+ */
+ public static Date getServerStartDate() {
+ long time = ManagementFactory.getRuntimeMXBean().getStartTime();
+ return new Date(time);
+ }
+
+ /**
+ * 计算相差天数
+ *
+ * @param date1 开始日期
+ * @param date2 结束日期
+ * @return int
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:28
+ */
+ public static int differentDaysByMillisecond(Date date1, Date date2) {
+ return Math.abs((int) ((date2.getTime() - date1.getTime()) / (1000 * 3600 * 24)));
+ }
+
+ /**
+ * 计算两个时间差
+ *
+ * @param startDate 开始日期
+ * @param endDate 结束日期
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:30
+ */
+ public static String getDatePoor(Date startDate, Date endDate) {
+ long nd = 1000 * 24 * 60 * 60;
+ long nh = 1000 * 60 * 60;
+ long nm = 1000 * 60;
+ // long ns = 1000;
+ // 获得两个时间的毫秒时间差异
+ long diff = startDate.getTime() - endDate.getTime();
+ // 计算差多少天
+ long day = diff / nd;
+ // 计算差多少小时
+ long hour = diff % nd / nh;
+ // 计算差多少分钟
+ long min = diff % nd % nh / nm;
+ //输出结果
+ return day + "天" + hour + "小时" + min + "分钟";
+ }
+
+ /**
+ * 将 LocalDateTime 对象转换为 Date 对象
+ *
+ * @param temporalAccessor LocalDateTime 实例
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:30
+ */
+ public static Date toDate(LocalDateTime temporalAccessor) {
+ // 将 LocalDateTime 转换为系统默认时区的 ZonedDateTime
+ ZonedDateTime zdt = temporalAccessor.atZone(ZoneId.systemDefault());
+ // 使用 ZonedDateTime 的瞬时时间创建 Date 对象
+ return Date.from(zdt.toInstant());
+ }
+
+ /**
+ * 将 LocalDate 对象转换为 Date 对象
+ *
+ * @param temporalAccessor LocalDate 实例
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:30
+ */
+ public static Date toDate(LocalDate temporalAccessor) {
+ // 将 LocalDate 转换为 LocalDateTime，时间为 00:00:00
+ LocalDateTime localDateTime = LocalDateTime.of(temporalAccessor, LocalTime.of(0, 0, 0));
+ // 将 LocalDateTime 转换为系统默认时区的 ZonedDateTime
+ ZonedDateTime zdt = localDateTime.atZone(ZoneId.systemDefault());
+ // 使用 ZonedDateTime 的瞬时时间创建 Date 对象
+ return Date.from(zdt.toInstant());
+ }
+
+ /**
+ * 判断传入日期是否在系统当前日期之后
+ *
+ * @param date 日期
+ * @return boolean
+ * @author zhaoyuanyuan
+ * @date 2024/07/23 14:34
+ */
+ public static boolean isGreaterThanNow(Date date) {
+ Date nowDate = new Date();
+ int compareResult = date.compareTo(nowDate);
+ if (compareResult > 0) {
+ return true;
+ } else {
+ return false;
+ }
+ }
+
+ /**
+ * 获取指定日期特定分钟数后的日期
+ *
+ * @param date 指定日期
+ * @param minutes 分钟数
+ * @return {@code Date }
+ * @author zhaoyuanyuan
+ * @date 2024/07/31 16:50
+ */
+ public static Date getMinutesAfterDate(Date date, Integer minutes) {
+ Instant instant = date.toInstant();
+ //转换为LocalDateTime
+ LocalDateTime specifiedDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
+ //在指定日期基础上，增加指定分钟数
+ LocalDateTime newDateTime = specifiedDateTime.plus(Duration.ofMinutes(minutes));
+ return toDate(newDateTime);
+ }
+
+}
diff --git a/utils/EscUtils.java b/utils/EscUtils.java
new file mode 100644
index 0000000..6e750da
--- /dev/null
+++ b/utils/EscUtils.java
@@ -0,0 +1,28 @@
+package com.sgcc.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.jasypt.encryption.StringEncryptor;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * 配置加密工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/10/31 13:30
+ */
+@Slf4j
+public class EscUtils {
+
+ @Autowired
+ private StringEncryptor stringEncryptor;
+
+ public String test(String str) {
+ String encData = stringEncryptor.encrypt(str);
+ String decData = stringEncryptor.decrypt(encData);
+ log.info("加密数据:[{}]", encData);
+ log.info("解密数据:[{}]", decData);
+ return encData;
+ }
+
+}
diff --git a/utils/HttpsUtils.java b/utils/HttpsUtils.java
new file mode 100644
index 0000000..f0a0ff6
--- /dev/null
+++ b/utils/HttpsUtils.java
@@ -0,0 +1,164 @@
+package com.sgcc.utils;
+
+import cn.hutool.json.JSONObject;
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.DefaultHttpClient;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+
+/**
+ * Http请求工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/24 17:14
+ */
+@Slf4j
+public class HttpsUtils {
+
+ /**
+ * 字符编码utf-8
+ */
+ public static final String CHARSET_UTF8 = "UTF-8";
+ /**
+ * https请求url前缀
+ */
+ public static final String HTTPS_PREFIX = "https";
+ /**
+ * 认证信息
+ */
+ public static final String AUTHORIZATION = "Authorization";
+
+ /**
+ * post提交
+ *
+ * @param url url
+ * @param map 请求入参
+ * @param header 头信息
+ * @return {@code String}
+ */
+ public static String doPost(String url, Map map, Map header) {
+ return doPost(url, map, CHARSET_UTF8, header);
+ }
+
+ /**
+ * post请求
+ *
+ * @param url url
+ * @param map 请求入参
+ * @param charset 字符集
+ * @param header 头
+ * @return {@code String}
+ */
+ public static String doPost(String url, Map map, String charset, Map header) {
+ HttpClient httpClient = null;
+ HttpPost httpPost = null;
+ String result = null;
+ try {
+ httpClient = new DefaultHttpClient();
+ httpPost = new HttpPost(url);
+ //设置参数
+ List list = new ArrayList();
+ Iterator iterator = map.entrySet().iterator();
+ while (iterator.hasNext()) {
+ Map.Entry elem = (Map.Entry) iterator.next();
+ list.add(new BasicNameValuePair(elem.getKey(), elem.getValue()));
+ }
+ if (list.size() > 0) {
+ Map param = new HashMap<>();
+ param.putAll(map);
+ log.info("httpParam:{}", param);
+ StringEntity stringEntity = new StringEntity(new JSONObject(param).toString());
+ httpPost.setEntity(stringEntity);
+ }
+ if (header.size() > 0) {
+ //设置请求头
+ Iterator entryList = header.entrySet().iterator();
+ while (entryList.hasNext()) {
+ Map.Entry entry = (Map.Entry) entryList.next();
+ httpPost.setHeader(entry.getKey(), entry.getValue());
+ }
+ }
+ HttpResponse response = httpClient.execute(httpPost);
+ if (response != null) {
+ HttpEntity resEntity = response.getEntity();
+ if (resEntity != null) {
+ result = EntityUtils.toString(resEntity, charset);
+ }
+ }
+ } catch (Exception e) {
+ log.error("HttpsUtils doPost exception: {}", e.getMessage());
+ }
+ return result;
+ }
+
+ /**
+ * https Get 请求方式
+ *
+ * @param url 请求url
+ * @param header 请求头
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/06/24 17:16
+ */
+ public static String doGet(String url, Map header) {
+ return doGet(url, header, new HashMap<>());
+ }
+
+ /**
+ * https Get 请求方式
+ *
+ * @param url url
+ * @param header 请求头
+ * @param uriVariable 请求参数
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/06/24 17:16
+ */
+ public static String doGet(String url, Map header, Map uriVariable) {
+ HttpClient httpClient = null;
+ HttpGet httpGet = null;
+ String result = null;
+ try {
+ httpClient = new DefaultHttpClient();
+ URIBuilder uriBuilder = new URIBuilder(url);
+ // 请求参数
+ if (uriVariable != null) {
+ uriVariable.forEach(uriBuilder::addParameter);
+ }
+ URI uri = uriBuilder.build();
+ httpGet = new HttpGet(uri);
+ log.info("HttpsUtils doGet: {}", httpGet.getRequestLine().getUri());
+ // 请求头
+ if (header != null) {
+ header.forEach(httpGet::setHeader);
+ }
+ HttpResponse response = httpClient.execute(httpGet);
+ if (response != null) {
+ HttpEntity resEntity = response.getEntity();
+ log.info("HttpsUtils doGet response status: {}", response.getStatusLine().getStatusCode());
+ if (resEntity != null) {
+ result = EntityUtils.toString(resEntity, CHARSET_UTF8);
+ }
+ }
+ } catch (Exception e) {
+ log.error("HttpsUtils doGet exception: {}", e.getMessage());
+ }
+ return result;
+ }
+
+}
\ No newline at end of file
diff --git a/utils/JwtUtils.java b/utils/JwtUtils.java
new file mode 100644
index 0000000..2ae804a
--- /dev/null
+++ b/utils/JwtUtils.java
@@ -0,0 +1,113 @@
+package com.sgcc.utils;
+
+import com.auth0.jwt.JWT;
+import com.auth0.jwt.JWTCreator;
+import com.auth0.jwt.algorithms.Algorithm;
+import com.auth0.jwt.interfaces.DecodedJWT;
+import com.sgcc.entity.User;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * JWT工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/27 14:47
+ */
+@Slf4j
+public class JwtUtils {
+
+ /**
+ * JWT用户名
+ */
+ private static final String USER_NAME = "admin";
+
+ /**
+ * token有效时间
+ */
+ public static final int TOKEN_TIME_OUT = 1000 * 60 * 60;
+
+ /**
+ * 生成token
+ *
+ * @param user 用户信息
+ * @param key 用于签名加密的密钥
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/11/22 11:15
+ */
+ public static String getToken(User user, String key) {
+ //获取jwt生成器
+ JWTCreator.Builder jwtBuilder = JWT.create();
+ //该生成器设置Header的参数为一个的Map,
+ Map headers = new HashMap<>();
+ //设置token的type为jwt
+ headers.put("typ", "jwt");
+ //表明加密的算法为HS256
+ headers.put("alg", "hs256");
+ //开始生成token
+ String token = jwtBuilder.withHeader(headers)
+ //接下来为设置PayLoad,Claim中的键值对可自定义
+ //设置用户ID
+ .withClaim("userId", user.getId())
+ //设置用户角色ID
+ .withClaim("roleId", user.getRoleId())
+ //token失效时间，这里为一消失后失效
+ .withExpiresAt(new Date(System.currentTimeMillis() + TOKEN_TIME_OUT))
+ //设置该jwt的发行时间，一般为当前系统时间
+ .withIssuedAt(new Date(System.currentTimeMillis()))
+ //token的发行者（可自定义）
+ .withIssuer(USER_NAME)
+ //进行签名，选择加密算法，以一个字符串密钥为参数
+ .sign(Algorithm.HMAC256(key));
+ log.info("-------------Token={}-------------", token);
+ return token;
+ }
+
+ /**
+ * 验证Token
+ *
+ * @param token 凭证
+ * @return boolean
+ * @author zhaoyuanyuan
+ * @date 2024/06/27 14:55
+ */
+ public static boolean verify(String token) {
+ if (StringUtils.isBlank(token)) {
+ return false;
+ }
+ DecodedJWT decode = JWT.decode(token);
+ //若验证成功，就可获取其携带的信息进行其他操作
+ if (decode.getClaim("userId") == null) {
+ return false;
+ }
+ log.info("用户ID[{}]", decode.getClaim("userId").asInt());
+ log.info("用户角色ID[{}]", decode.getClaim("roleId").asInt());
+ //获取发送者，没有设置则为空
+ log.info("发送者[{}]", decode.getIssuer());
+ //获取过期时间
+ log.info("过期时间[{}]", String.valueOf(decode.getExpiresAt()));
+ //获取主题，没有设置则为空
+ log.info("主题[{}]", decode.getSubject());
+ return true;
+ }
+
+ /**
+ * 获取Token中的userId
+ *
+ * @param token 凭证
+ * @return {@code Integer }
+ * @author zhaoyuanyuan
+ * @date 2024/11/21 09:52
+ */
+ public static Integer getUserId(String token) {
+ DecodedJWT decode = JWT.decode(token);
+ return decode.getClaim("userId").asInt();
+ }
+
+}
diff --git a/utils/MD5Utils.java b/utils/MD5Utils.java
new file mode 100644
index 0000000..02faba1
--- /dev/null
+++ b/utils/MD5Utils.java
@@ -0,0 +1,67 @@
+package com.sgcc.utils;
+
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+/**
+ * 用户登录相关工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/26 17:24
+ */
+public class MD5Utils {
+
+ /**
+ * MD5转字符串
+ *
+ * @param bytes
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/06/26 17:25
+ */
+ public static String toHexString(byte[] bytes) {
+ StringBuilder hexString = new StringBuilder();
+ for (byte b : bytes) {
+ String hex = Integer.toHexString(0xff & b);
+ if (hex.length() == 1) {
+ hexString.append('0');
+ }
+ hexString.append(hex);
+ }
+ return hexString.toString();
+ }
+
+ /**
+ * 密码加密
+ *
+ * @param password 密码
+ * @return {@code String }
+ * @author zhaoyuanyuan
+ * @date 2024/06/26 17:25
+ */
+ public static String encryptPassword(String password) {
+ try {
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ md.update(password.getBytes());
+ byte[] digest = md.digest();
+ return toHexString(digest);
+ } catch (NoSuchAlgorithmException e) {
+ throw new RuntimeException("MD5 algorithm not found", e);
+ }
+ }
+
+ /**
+ * 密码验证
+ *
+ * @param inputPassword 表单输入密码
+ * @param storedPassword 数据库存储加密密码
+ * @return boolean
+ * @author zhaoyuanyuan
+ * @date 2024/06/26 17:27
+ */
+ public static boolean validatePassword(String inputPassword, String storedPassword) {
+ return encryptPassword(inputPassword).equals(storedPassword);
+ }
+
+}
diff --git a/utils/PageUtils.java b/utils/PageUtils.java
new file mode 100644
index 0000000..da4037c
--- /dev/null
+++ b/utils/PageUtils.java
@@ -0,0 +1,40 @@
+package com.sgcc.utils;
+
+/**
+ * 分页工具
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/06/24 16:05
+ */
+public class PageUtils {
+
+ /**
+ * 根据总数计算总页数
+ *
+ * @param totalCount 总数
+ * @param pageSize 每页数
+ * @return 总页数
+ */
+ public static int totalPage(int totalCount, int pageSize) {
+ if (pageSize == 0) {
+ return 0;
+ }
+ return totalCount % pageSize == 0 ? (totalCount / pageSize) : (totalCount / pageSize + 1);
+ }
+
+ /**
+ * 根据总数计算总页数
+ *
+ * @param totalCount 总数
+ * @param pageSize 每页数
+ * @return 总页数
+ */
+ public static long totalPage(long totalCount, long pageSize) {
+ if (pageSize == 0) {
+ return 0;
+ }
+ return totalCount % pageSize == 0 ? (totalCount / pageSize) : (totalCount / pageSize + 1);
+ }
+
+}
\ No newline at end of file
diff --git a/utils/RedisUtils.java b/utils/RedisUtils.java
new file mode 100644
index 0000000..876e5cc
--- /dev/null
+++ b/utils/RedisUtils.java
@@ -0,0 +1,704 @@
+package com.sgcc.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * Redis封装工具类
+ *
+ * @author zhaoyuanyuan
+ * @version 1.0.0
+ * @date 2024/07/03 11:30
+ */
+@Slf4j
+@Component
+public class RedisUtils {
+
+ @Resource
+ private RedisTemplate redisTemplate;
+
+ /**
+ * 指定缓存失效时间
+ *
+ * @param key 键
+ * @param time 时间(秒)
+ * @return
+ */
+ public boolean expire(String key, long time) {
+ try {
+ log.info("RedisCmd==================expire key:[{}]", key);
+ if (time > 0) {
+ //logger.debug("指定缓存失效时间key＝"+key + ",time=" + time);
+ redisTemplate.expire(key, time, TimeUnit.SECONDS);
+
+ }
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 根据key获取过期时间
+ *
+ * @param key 键 不能为null
+ * @return 时间(秒) 返回0代表为永久有效
+ */
+ public long getExpire(String key) {
+ log.info("RedisCmd==================getExpire key:[{}]", key);
+ return redisTemplate.getExpire(key, TimeUnit.SECONDS);
+ }
+
+ /**
+ * 判断key是否存在
+ *
+ * @param key 键
+ * @return true 存在 false不存在
+ */
+ public boolean hasKey(String key) {
+ try {
+ log.info("RedisCmd==================hasKey key:[{}]", key);
+ return redisTemplate.hasKey(key);
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 重名名key，如果newKey已经存在，则newKey的原值被覆盖
+ *
+ * @param oldKey 原key
+ * @param newKey 新key
+ */
+ public void renameKey(String oldKey, String newKey) {
+ try {
+ log.info("RedisCmd==================renameKey oldKey:[{}] newKey:[{}]", oldKey, newKey);
+ redisTemplate.rename(oldKey, newKey);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * newKey不存在时才重命名
+ *
+ * @param oldKey 原key
+ * @param newKey 新key
+ * @return 修改成功返回true
+ */
+ public boolean renameKeyNotExist(String oldKey, String newKey) {
+ try {
+ log.info("RedisCmd==================renameKeyNotExist oldKey:[{}] newKey:[{}]", oldKey, newKey);
+ return redisTemplate.renameIfAbsent(oldKey, newKey);
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 删除key
+ *
+ * @param key 键
+ */
+ public void deleteKey(String key) {
+ try {
+ log.info("RedisCmd==================deleteKey key:[{}]", key);
+ redisTemplate.delete(key);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * 删除多个key
+ *
+ * @param keys
+ */
+ public void deleteKeys(String... keys) {
+ try {
+ log.info("RedisCmd==================deleteKeys keys:[{}]", keys);
+ Set kSet = Stream.of(keys).map(k -> k).collect(Collectors.toSet());
+ redisTemplate.delete(kSet);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * 普通缓存获取
+ *
+ * @param key 键
+ * @return 值
+ */
+ public Set keys(String key) {
+ log.info("RedisCmd==================keys key:[{}]", key);
+ return key == null ? null : redisTemplate.keys(key);
+ }
+
+ // ============================String=============================
+
+ /**
+ * 普通缓存获取
+ *
+ * @param key 键
+ * @return 值
+ */
+ public Object get(String key) {
+ log.info("RedisCmd==================get key:[{}]", key);
+ return key == null ? null : redisTemplate.opsForValue().get(key);
+ }
+
+ /**
+ * 普通缓存放入
+ *
+ * @param key 键
+ * @param value 值
+ * @return true成功 false失败
+ */
+ public boolean set(String key, Object value) {
+ try {
+ log.info("RedisCmd==================set key:[{}]", key);
+ redisTemplate.opsForValue().set(key, value);
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 普通缓存放入并设置时间
+ *
+ * @param key 键
+ * @param value 值
+ * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
+ * @return true成功 false 失败
+ */
+ public boolean set(String key, Object value, long time) {
+ try {
+ log.info("RedisCmd==================set2 key:[{}]", key);
+ if (time > 0) {
+ redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
+ } else {
+ set(key, value);
+ }
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 递增
+ *
+ * @param key 键
+ * @param delta 步长
+ * @return
+ */
+ public long incr(String key, long delta) {
+ if (delta < 0) {
+ throw new RuntimeException("递增因子必须大于0");
+ }
+ log.info("RedisCmd==================incr key:[{}]", key);
+ return redisTemplate.opsForValue().increment(key, delta);
+ }
+
+ /**
+ * 递减
+ *
+ * @param key 键
+ * @param delta 步长
+ * @return
+ */
+ public long decr(String key, long delta) {
+ if (delta < 0) {
+ throw new RuntimeException("递减因子必须大于0");
+ }
+ log.info("RedisCmd==================decr key:[{}]", key);
+ return redisTemplate.opsForValue().increment(key, -delta);
+ }
+
+ // ================================Map=================================
+
+ /**
+ * HashGet
+ *
+ * @param key 键 不能为null
+ * @param item 项 不能为null
+ * @return 值
+ */
+ public Object hGet(String key, String item) {
+ log.info("RedisCmd==================hGet key:[{}]", key);
+ return redisTemplate.opsForHash().get(key, item);
+ }
+
+ /**
+ * 获取hashKey对应的所有键值
+ *
+ * @param key 键
+ * @return 对应的多个键值
+ */
+ public Map hmGet(String key) {
+ log.info("RedisCmd==================hmGet key:[{}]", key);
+ return redisTemplate.opsForHash().entries(key);
+ }
+
+ /**
+ * HashSet存储
+ *
+ * @param key 键
+ * @param map 对应多个键值
+ * @return true 成功 false 失败
+ */
+ public boolean hmSet(String key, Map map) {
+ try {
+ log.info("RedisCmd==================hmSet key:[{}]", key);
+ redisTemplate.opsForHash().putAll(key, map);
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * HashSet 并设置时间
+ *
+ * @param key 键
+ * @param map 对应多个键值
+ * @param time 时间(秒)
+ * @return true成功 false失败
+ */
+ public boolean hmSet(String key, Map map, long time) {
+ try {
+ log.info("RedisCmd==================hmSet2 key:[{}]", key);
+ redisTemplate.opsForHash().putAll(key, map);
+ if (time > 0) {
+ expire(key, time);
+ }
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 向一张hash表中放入数据,如果不存在将创建
+ *
+ * @param key 键
+ * @param item 项
+ * @param value 值
+ * @return true 成功 false失败
+ */
+ public boolean hSet(String key, String item, Object value) {
+ try {
+ log.info("RedisCmd==================hSet1 key:[{}]", key);
+ redisTemplate.opsForHash().put(key, item, value);
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 向一张hash表中放入数据,如果不存在将创建
+ *
+ * @param key 键
+ * @param item 项
+ * @param value 值
+ * @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
+ * @return true 成功 false失败
+ */
+ public boolean hSet(String key, String item, Object value, long time) {
+ try {
+ log.info("RedisCmd==================hSet2 key:[{}]", key);
+ redisTemplate.opsForHash().put(key, item, value);
+ if (time > 0) {
+ expire(key, time);
+ }
+ return true;
+ } catch (Exception e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ /**
+ * 删除hash表中的值
+ *
+ * @param key 键 不能为null
+ * @param item 项 可以使多个 不能为null
+ */
+ public void hDel(String key, Object... item) {
+ log.info("RedisCmd==================hDel key:[{}]", key);
+ redisTemplate.opsForHash().delete(key, item);
+ }
+
+ /**
+ * 判断hash表中是否有该项的值
+ *
+ * @param key 键 不能为null
+ * @param item 项 不能为null
+ * @return true 存在 false不存在
+ */
+ public boolean hHasKey(String key, String item) {
+ log.info("RedisCmd==================hHasKey key:[{}]", key);
+ return redisTemplate.opsForHash().hasKey(key, item);
+ }
+
+ /**
+ * hash递增 如果不存在,就会创建一个 并把新增后的值返回
+ *
+ * @param key 键
+ * @param item 项
+ * @param by 要增加几(大于0)
+ * @return
+ */
+ public double hIncr(String key, String item, double by) {
+ log.info("RedisCmd==================hIncr key:[{}]", key);
+ return redisTemplate.opsForHash().increment(key, item, by);
+ }
+
+ /**
+ * hash递减
+ *
+ * @param key 键
+ * @param item 项
+ * @param by 要减少记(小于0)
+ * @return
+ */
+ public double hDecr(String key, String item, double by) {
+ log.info("RedisCmd==================hDecr key:[{}]", key);
+ return redisTemplate.opsForHash().increment(key, item, -by);
+ }
+
+ // ============================set=============================
+
+ /**
+ * 根据key获取Set中的所有值
+ *
+ * @param key 键
+ * @return
+ */
+ public Set