feat:定时任务项目

谢茂盛
1 parent 62dd484b
Showing 57 changed files with 4804 additions and 0 deletions
job/Dockerfile
job/docker-compose.yml
job/pom.xml
job/src/main/java/com/canrd/shop/JobApplication.java
job/src/main/java/com/canrd/shop/common/Path.java
job/src/main/java/com/canrd/shop/common/constant/Constant.java
job/src/main/java/com/canrd/shop/common/constant/ServerResult.java
job/src/main/java/com/canrd/shop/common/constant/ServerResultCode.java
job/src/main/java/com/canrd/shop/common/exception/BadRequestException.java
job/src/main/java/com/canrd/shop/common/exception/BusinessException.java
job/src/main/java/com/canrd/shop/common/exception/BusinessExceptionHandlerAdvice.java
job/src/main/java/com/canrd/shop/common/exception/EntityExistException.java
job/src/main/java/com/canrd/shop/common/exception/EntityNotFoundException.java
job/src/main/java/com/canrd/shop/common/exception/ErrorInfo.java
job/src/main/java/com/canrd/shop/common/exception/handler/ApiError.java
job/src/main/java/com/canrd/shop/common/exception/handler/GlobalExceptionHandler.java
job/src/main/java/com/canrd/shop/common/jsr303/ListValueConstraintValidator.java
job/src/main/java/com/canrd/shop/common/jsr303/OperateGroup.java
job/src/main/java/com/canrd/shop/common/jsr303/annotation/ListIntValue.java
job/src/main/java/com/canrd/shop/common/utils/EncryptUtils.java
+# 使用官方 OpenJDK 8 映像作为基础镜像
+FROM openjdk:8-jdk-alpine
+
+# 将当前目录下的所有 jar 包复制到容器中的 /app 目录下
+COPY *.jar /app/
+
+# 设置容器启动时执行的命令
+CMD ["java", "-jar", "/app/job.services-1.0-SNAPSHOT.jar"]
+version: "3"
+
+services:
+  # 定义 Spring Boot 应用程序所需要的服务（容器）
+  shop:
+    # 构建镜像的路径。"." 表示 Dockerfile 文件所在的当前目录
+    build: ..
+    # 指定容器名称
+    container_name: job
+    # 容器所要使用的端口号
+    ports:
+      - "9000:9000"
 \ No newline at end of file
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>canrd-services</artifactId>
+        <groupId>com.canrd.shop</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>job</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <!--            <version>2.2.5.RELEASE</version>-->
+            <exclusions>
+                <exclusion>
+                    <groupId>org.springframework.boot</groupId>
+                    <artifactId>spring-boot-starter-logging</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <!-- Lombok 依赖-->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.12</version>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+        </dependency>
+        <!--        <dependency>-->
+        <!--            <groupId>com.baomidou</groupId>-->
+        <!--            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>-->
+        <!--        </dependency>-->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-log4j2</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-crypto</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+
+
+        <!--工具包-->
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>joda-time</groupId>
+            <artifactId>joda-time</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>job.services-1.0-SNAPSHOT</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-source-plugin</artifactId>
+            </plugin>
+
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <configuration>
+                    <executable>true</executable>
+                </configuration>
+            </plugin>
+
+        </plugins>
+    </build>
+</project>
 \ No newline at end of file
+package com.canrd.shop;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
+import com.canrd.shop.common.Path;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+/**
+ * @author: xms
+ * @description: 管理后台启动
+ * @date: 2023/3/29 18:00
+ * @version: 1.0
+ */
+@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class}, scanBasePackages = {"com.canrd.shop"})
+@MapperScan("com.canrd.shop.**.mapper")
+@EnableScheduling
+@EnableTransactionManagement
+public class JobApplication {
+
+    private static void setLogPath() {
+        String appPath = Path.getAppPath(JobApplication.class);
+        System.setProperty("logging.path", appPath);
+    }
+
+    public static void main(String[] args) {
+        setLogPath();
+        SpringApplication.run(JobApplication.class, args);
+    }
+
+    /**
+     * 分页插件
+     *
+     * @return
+     */
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
+        return interceptor;
+    }
+}
+package com.canrd.shop.common;
+
+
+import com.canrd.shop.common.constant.Constant;
+
+/**
+ * @author xms
+ */
+public class Path {
+    /**
+     * 获取程序启动路径
+     *
+     * @param cls,建议直接传 ServiceApplication.class
+     * @return 应用启动路径
+     */
+    public static String getAppPath(Class cls) {
+        String path = cls.getResource(Constant.SLASH_MARK_CHARACTER).getPath();
+        String os = System.getProperty("os.name").toLowerCase();
+        final String OSWINDOW = "windows";
+        if (os.indexOf(OSWINDOW) != -1 && path.length() > 1) {
+            //windows路径样例: /D:/work/code/shop-services/online-shop-oss/target/classes/
+            return path.substring(1);
+        }
+
+        //linux 路径样例 file:/opt/target/online-shop-oss-SNAPSHOT.jar!/BOOT-INF/classes!/";
+        final String FILE = "file:";
+        if (path.indexOf(FILE) != -1) {
+            path = path.substring(FILE.length());
+        }
+
+        int pos = -1;
+        if ((pos = path.indexOf(Constant.EXCLAMATION_MARK_CHARACTER)) != -1) {
+            if (-1 != (pos = path.lastIndexOf(Constant.SLASH_MARK_CHARACTER, pos))) {
+                path = path.substring(0, pos + 1);
+            }
+        }
+
+        return path;
+    }
+}
+package com.canrd.shop.common.constant;
+
+import java.util.Arrays;
+import java.util.List;
+
+public class Constant {
+    /**
+     * 分隔符英文的横杠
+     */
+    public static final String CROSS_BAR_CHARACTER = "-";
+    /**
+     * 英文的 .
+     */
+    public static final String POINT_BAR_CHARACTER = ".";
+    /**
+     * 英文的 ！
+     */
+    public static final String EXCLAMATION_MARK_CHARACTER = "!";
+    /**
+     * 英文的 /
+     */
+    public static final String SLASH_MARK_CHARACTER = "/";
+    /**
+     * 英文的 :
+     */
+    public static final String COLON_CHARACTER = ":";
+
+    /**
+     * 英文的 ;
+     */
+    public static final String SEMICOLON_CHARACTER = ";";
+
+    /**
+     * 英文的逗号
+     */
+    public static final String COMMA_CHARACTER = ",";
+    /**
+     * 英文的*号
+     */
+    public static final String START_CHARACTER = "*";
+    /**
+     * 分隔符
+     */
+    public static final String SPLIT_SYMBOL = ",|，";
+
+    /**
+     * 特殊分隔符 _
+     */
+    public static final String SPECIAL_KEY = "_";
+
+
+    /**
+     * 括号
+     */
+    public static final String BRACKETS_RIGHT = "]";
+    /**
+     * 括号
+     */
+    public static final String BRACKETS_LEFT = "[";
+
+    /**
+     * 手机号码正则校验
+     */
+    public static final String PHONE_REGEXP = "^[1][3,4,5,6,7,8,9][0-9]{9}$";
+
+    /**
+     * 脱敏手机号
+     */
+    public static final String PHONE_DESENSITIZATION_REGEXP = "^[1][3,4,5,6,7,8,9][0-9][*]{4}[0-9]{4}$";
+
+    /**
+     * 邮箱
+     */
+    public static final String EMAIL_REGEXP = "^\\s*\\w+(?:\\.{0,1}[\\w-]+)*@[a-zA-Z0-9]+(?:[-.][a-zA-Z0-9]+)*\\.[a-zA-Z]+\\s*$";
+
+    /**
+     * 三位数字
+     */
+    public static final String THREE_DIGITS_REGEXP = "\\d{3}";
+
+    /**
+     * 中文 英文 数字
+     */
+    public static final String CHI_EN_NUM_REGEXP = "^[A-z0-9\\u4e00-\\u9fa5]*$";
+
+
+    /**
+     * 仅包含英文和数字
+     */
+    public static final String EN_REGEXP = "^[a-zA-Z]+$";
+
+    public static final String EN_NUM_REGEXP = "^[a-z0-9A-Z]+$";
+
+    public static final String LINE_EN_NUM_REGEXP = "^[a-z0-9A-Z\\-]+$";
+
+    /**
+     * 仅包含英文和中文
+     */
+    public static final String CHI_EN_REGEXP = "^[A-z\\u4e00-\\u9fa5]*$";
+
+    /**
+     * 纯数字
+     */
+    public static final String NUMERIC_REGEXP = "^\\d+$";
+    /**
+     * 纯中文
+     */
+    public static final String CHI_REGEXP = "^[\u4e00-\u9fa5]+$";
+    /**
+     * 不超过两位小数
+     */
+    public static final String DICMAL_REGEXP = "^(([1-9]{1}\\d*)|([0]{1}))(\\.(\\d){0,3})?$";
+
+    /**
+     * 默认空字符串
+     */
+    public static final String EMPTY_STRING = "";
+
+    /**
+     * 统一返回data的key
+     */
+    public static final String RESULT_CHARACTER = "result";
+
+    /**
+     * 统一返回data的key
+     */
+    public static final String SUCCESS_RESULT_CHARACTER = "success";
+
+    /**
+     * 返回的默认结果集
+     */
+    public static final String RESULT_FAIL = null;
+
+    /**
+     * ENABLE_FLAG
+     */
+    public static final String ENABLE_FLAG = "enable_flag";
+
+    /**
+     * 是否可用 10-可用 20-删除
+     */
+    public static final int ENABLE_TEN = 10;
+    /**
+     * 是否可用 10-可用 20-删除
+     */
+    public static final int UNABLE_TWENTY = 20;
+
+    public static final int ONE = 1;
+
+    public static final Integer INTEGER_ONE = 1;
+
+    public static final int TWO = 2;
+
+    public static final int THREE = 3;
+
+    public static final int FOUR = 4;
+
+    public static final int FIVE = 5;
+
+    public static final int SIX = 6;
+
+    public static final int SEVEN = 7;
+
+    public static final int THIRTY = 30;
+
+    public static final int NINETEEN = 19;
+
+    public static final int THOUSAND = 1000;
+
+    public static final String DATE_TIME = "yyyy-MM-dd HH:mm:ss";
+
+    public static final int ZERO = 0;
+
+    public static final String STRING_ZERO = "0";
+
+    public static final String ZERO_STRING = "0";
+
+    public static final String THOUSAND_STRING = "1000";
+
+    public static final String SYSTEM_USER = "System";
+
+    public static final String percent50 = "0.5";
+
+    public static final String DELETE_SUCCESS_RESULT_CHARACTER = "删除成功";
+
+
+    /**
+     * token rediskey
+     */
+    public static final String TOKEN_FLAG = "token:";
+    /**
+     * token 限制api请求
+     */
+    public static final String PERMISSION_API_LIMIT = "token_api_limit:";
+
+    /**
+     * token过期时间
+     */
+    public static final Integer TOKEN_EXPIRE_HOURS = 1;
+    /**
+     * 密码3次错误锁定
+     */
+    public static final int LOCK_ERROR_TIMES = 3;
+
+    /**
+     * session字段
+     */
+    public static final String HEAD_TOKEN = "Authorization";
+    public static final String ACCESS_TOKEN = "token";
+    public static final String REQUEST_ORIGIN = "source";
+    public static final String REQUEST_IP = "ip";
+    public static final String USER_INFO = "userInfo";
+    public static final String FILED_ID = "id";
+    public static final String FILED_USER_NAME = "username";
+    public static final String FILED_DEVICE_NUM = "deviceNum";
+
+    /**
+     * 请求来源
+     */
+    public static final String ORIGIN_WEB = "WEB";
+    public static final String ORIGIN_PDA = "PDA";
+
+    /**
+     * 1001 参数校验不通过
+     * 1002 签名验证不通过
+     */
+    public static final List<String> ERROR_CODE_LIST = Arrays.asList("1001", "1002");
+
+    /**
+     * 分布式锁超时时间
+     */
+    public static final long REDIS_LOCK_DEFAULT_TIME_OUT_MILLIS = 3000;
+    public static final long REDIS_LOCK_FIVE_SECONDS_TIME_OUT_MILLIS = 5000;
+
+    /**
+     * 系统来源WMS
+     */
+    public static final String SYS_ORIGIN_WMS = "WMS";
+
+    public static final String STRING_ONE = "1";
+
+
+    public static final String STRING_TWO = "2";
+
+    public static final String STRING_THREE = "3";
+
+    public static final String STRING_FOUR = "4";
+
+    public static final String STRING_FIVE = "5";
+
+    public static final String STRING_SIX = "6";
+
+    public static final String STRING_SEVEN = "7";
+
+    public static final String STRING_EIGHT = "8";
+
+    public static final String STRING_NINE = "9";
+
+    public static final String STRING_TEN = "10";
+
+    public static final String STRING_ELEVEN = "11";
+
+    public static final String STRING_TWELVE = "12";
+
+    /**
+     * 异常延时队列后缀
+     */
+    public static final String ERROR_DELAY_QUEUE_SUFFIX = "error";
+
+    /**
+     * 推送出库数据延时队列 redis key prefix
+     */
+    public static final String OUTBOUND_NOTIFY_DELAY_QUEUE_PREFIX = "outbound:notify:";
+
+    /**
+     * 同步MES库存队列 redis key prefix
+     */
+    public static final String MES_STOCK_SYNC_QUEUE_PREFIX = "mes:stock_sync:";
+
+    /**
+     * 分拣详情 错误码: 157205   返回值段
+     */
+    public static final String SEPARATE_PICK_QUERY_RETURN_FIELD = "separatePickQuery";
+    /**
+     * 限制上限值
+     */
+    public static final Integer LIMIT_999 = 999;
+
+    /**
+     * 东八区
+     */
+    public static final String GMT_8 = "GMT+8";
+
+    /**
+     * 英文的 "
+     */
+    public static final String QUOTATION_MARK_CHARACTER = "\"";
+
+
+    /**
+     * 英文的 \"
+     */
+    public static final String QUOTATION_SLASH_MARK_CHARACTER = "\\\"";
+
+    public static final String SUCCESS_VALUE = "success";
+
+
+    public static final String TRUE = "true";
+
+    public static final String ROOT_PARENT_ID = "0";
+
+    public static final Long ROOT_PARENT_ID_LONG = 0L;
+
+
+    /**
+     * 短信验证码 redis key
+     */
+    public static final String SMS_AUTH_CODE_PREFIX = "sms:auth:code:";
+
+    public static final String DEFAULT_PASSWORD = "JBXT123456";
+
+    /**
+     * 账号在线队列 redis key
+     */
+    public static final String ACCOUNT_ONLINE_LIST = "account:online:";
+
+    /**
+     * 缓存导入excel错误信息 redis key
+     */
+    public static final String EXCEL_IMPORT_ERROR_PREFIX = "excel:import:error:";
+
+}
+package com.canrd.shop.common.constant;
+
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author : dengbin
+ * @Date: 2020/9/5
+ * 统一的返回结果实体
+ */
+public class ServerResult<T> implements Serializable {
+    /**
+     * 序列化ID
+     */
+    private static final long serialVersionUID = -5809782578272943999L;
+    /**
+     * 返回的状态码
+     */
+    private int result = ServerResultCode.SUCCESS.getErrorCode();
+    /**
+     * 返回的消息
+     */
+    private String message = ServerResultCode.SUCCESS.getErrorDesc();
+    /**
+     * 返回的数据实体
+     */
+    private T data = null;
+    /**
+     *
+     */
+    final int INIT_SIZE = 128;
+
+    /**
+     *
+     */
+    public ServerResult() {
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder buffer = new StringBuilder(INIT_SIZE);
+        buffer.append("{\"result\":").append(this.result);
+        buffer.append(",\"message\":\"").append(this.message != null ? message : "").append("\"");
+        buffer.append(",\"data\":").append(data).append("}");
+        return buffer.toString();
+    }
+
+    public int getResult() {
+        return result;
+    }
+
+    public ServerResult setResult(int result) {
+        this.result = result;
+        return this;
+    }
+
+    public ServerResult setResult(ServerResultCode serverResultCode) {
+        this.result = serverResultCode.getErrorCode();
+        this.message = serverResultCode.getErrorDesc();
+        return this;
+    }
+
+    public ServerResult setResult(int errorCode, String errorDesc) {
+        this.result = errorCode;
+        this.message = errorDesc;
+        return this;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public ServerResult<T> setMessage(String message) {
+        this.message = message;
+        return this;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public ServerResult setData(T data) {
+        this.data = data;
+        return this;
+    }
+
+    public static <T> ServerResult<T> success() {
+        return new ServerResult()
+                .setResult(ServerResultCode.SUCCESS)
+                .setMessage(ServerResultCode.SUCCESS.getErrorDesc())
+                .setData(defaultResult(ServerResultCode.SUCCESS));
+    }
+
+    public static <T> ServerResult<T> success(T data) {
+        return new ServerResult()
+                .setResult(ServerResultCode.SUCCESS)
+                .setMessage(ServerResultCode.SUCCESS.getErrorDesc())
+                .setData(data);
+    }
+
+    public static <T> ServerResult<T> success(T data, String message) {
+        return new ServerResult()
+                .setResult(ServerResultCode.SUCCESS)
+                .setMessage(message)
+                .setData(data);
+    }
+
+    /**
+     * @description 错误码使用系统错误 1000 错误类型自定义
+     * @author dengbin
+     * @date 2020/9/12
+     */
+    public static <T> ServerResult<T> fail(String message) {
+        return new ServerResult()
+                .setResult(ServerResultCode.FAIL)
+                .setMessage(message)
+                .setData(defaultResult(Constant.RESULT_FAIL));
+    }
+
+    /**
+     * 错误时需要返回相关数据时使用
+     *
+     * @param data
+     * @param <T>
+     * @return
+     */
+    public static <T> ServerResult<T> fail(T data, ServerResultCode serverResultCode) {
+        return new ServerResult()
+                .setData(data)
+                .setResult(serverResultCode)
+                .setMessage(serverResultCode.getErrorDesc());
+    }
+
+    /**
+     * 错误时需要返回相关数据时使用(不设值 data)
+     *
+     * @param sr
+     * @param
+     * @return
+     */
+    public static <T> ServerResult<T> fail(ServerResult<?> sr) {
+        return new ServerResult<>()
+                .setMessage(sr.getMessage())
+                .setResult(sr.getResult());
+
+    }
+
+    /**
+     * @description 错误码使用上面的枚举定义的，错误信息重新定义
+     * @author dengbin
+     * @date 2020/9/12
+     */
+    public static <T> ServerResult<T> fail(ServerResultCode serverResultCode, String msg) {
+        return new ServerResult()
+                .setResult(serverResultCode)
+                .setMessage(msg)
+                .setData(defaultResult(Constant.RESULT_FAIL));
+    }
+
+    /**
+     * @return
+     * @description 直接选用上面的枚举错误码，输出定义的错误信息
+     * @author dengbin
+     * @date 2020/9/12
+     */
+    public static <T> ServerResult<T> fail(ServerResultCode serverResultCode) {
+        return new ServerResult()
+                .setResult(serverResultCode)
+                .setMessage(serverResultCode.getErrorDesc())
+                .setData(defaultResult(Constant.RESULT_FAIL));
+    }
+
+    /**
+     * 错误时需要返回相关数据时使用
+     *
+     * @param data
+     * @param <T>
+     * @return
+     */
+    public static <T> ServerResult<T> fail(T data, int errorCode, String errorDesc) {
+        return new ServerResult()
+                .setData(data)
+                .setResult(errorCode, errorDesc);
+    }
+
+
+    public static <T> ServerResult<T> fail() {
+        return new ServerResult()
+                .setResult(ServerResultCode.FAIL.getErrorCode())
+                .setMessage(ServerResultCode.FAIL.getErrorDesc())
+                .setData(defaultResult(Constant.RESULT_FAIL));
+    }
+
+
+    /**
+     * @description 直接选用上面的枚举错误码，输出定义的错误信息
+     * @author dengbin
+     * @date 2020/9/12
+     */
+    public ServerResult failEnum(ServerResultCode serverResultCode) {
+        setResult(serverResultCode);
+        setMessage(serverResultCode.getErrorDesc());
+        return this;
+    }
+
+    public static <T> ServerResult<T> fail(int errorCode, String errorDesc) {
+        return new ServerResult()
+                .setResult(errorCode, errorDesc)
+                .setData(defaultResult(Constant.RESULT_FAIL));
+
+    }
+
+    /**
+     * 判断当前的状态码是否是SUCCESS
+     *
+     * @return 结果 ture or false
+     */
+    public boolean checkSuccess() {
+        return result == ServerResultCode.SUCCESS.getErrorCode();
+    }
+
+    public boolean checkNotSuccess() {
+        return !checkSuccess();
+    }
+
+    private static Map<String, Object> defaultResult(Object object) {
+        Map<String, Object> map = new HashMap<>(Constant.ONE);
+        map.put(Constant.RESULT_CHARACTER, null);
+        return map;
+    }
+}
+package com.canrd.shop.common.constant;
+
+
+import com.canrd.shop.common.exception.ErrorInfo;
+import lombok.Setter;
+
+
+/**
+ * 请求成功 返回 0
+ */
+public enum ServerResultCode implements ErrorInfo {
+    //成功 "0"
+    SUCCESS(0, "成功"),
+    FAIL(1000, "系统内部错误,请联系业务系统运维管理员"),
+    FIlE_UPLOAD_TOO_LARGE(1051, "上传文件太大,图片文件一般小于2兆"),
+
+    //空指针异常
+    NULL_POINT(1001, "空指针异常"),
+
+    //校验异常
+    RUN_ERROR(1002, "程序运行报错"),
+    ILLEGAL_ARGUMENT(1003, "参数非法"),
+    FILED_ERROR(1004, "传入参数错误"),
+    PARAM_ERROR(1005, "入参为空"),
+    EMPTY_RESULT(1006, "数据不存在"),
+    EMPTY_LIST(1007, "查询结果为空"),
+
+    //认证授权异常
+    UNAUTHENTICATION(401, "未登录"),
+
+
+    //用户
+    USER_NOT_EXIT(20001, "用户不存在"),
+
+
+    // 公司
+    COMPANY_NOT_EXIT(30001, "公司不存在"),
+    ;
+
+
+    ServerResultCode(Integer errorCode, String errorDesc) {
+        this.errorCode = errorCode;
+        this.errorDesc = errorDesc;
+    }
+
+    @Setter
+    private Integer errorCode;
+    @Setter
+    private String errorDesc;
+
+    @Override
+    public Integer getErrorCode() {
+        return this.errorCode;
+    }
+
+    @Override
+    public String getErrorDesc() {
+        return this.errorDesc;
+    }
+
+    /**
+     * 根据errorCode获得枚举
+     *
+     * @param errorCode
+     * @return
+     */
+    public static String getDescByCode(Integer errorCode) {
+        if (errorCode == null) {
+            return null;
+        }
+        ServerResultCode[] serverResults = values();
+        for (ServerResultCode serverResult : serverResults) {
+            if (serverResult.getErrorCode().equals(errorCode)) {
+                return serverResult.getErrorDesc();
+            }
+        }
+        return null;
+    }
+
+}
 \ No newline at end of file
+package com.canrd.shop.common.exception;
+
+import lombok.Getter;
+import org.springframework.http.HttpStatus;
+
+import static org.springframework.http.HttpStatus.BAD_REQUEST;
+
+/**
+ *
+ * @date 2018-11-23
+ * 统一异常处理
+ */
+@Getter
+public class BadRequestException extends RuntimeException {
+
+    private Integer status = BAD_REQUEST.value();
+
+    public BadRequestException(String msg) {
+        super(msg);
+    }
+
+    public BadRequestException(HttpStatus status, String msg) {
+        super(msg);
+        this.status = status.value();
+    }
+}
+package com.canrd.shop.common.exception;
+
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.common.constant.ServerResultCode;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * <p>基础异常类，所有自定义异常类都需要继承本类</p>
+ *
+ * @author A80076
+ * @date 2021/1/11
+ */
+@Slf4j
+public class BusinessException extends RuntimeException {
+
+    private static final long serialVersionUID = 3152549963899218489L;
+    @Setter
+    @Getter
+    private String errorDesc;
+    @Setter
+    @Getter
+    private Integer errorCode;
+    @Setter
+    @Getter
+    private Object data;
+
+    public BusinessException() {
+        super(ServerResultCode.FAIL.getErrorDesc());
+        this.errorCode = ServerResultCode.FAIL.getErrorCode();
+        this.errorDesc = ServerResultCode.FAIL.getErrorDesc();
+    }
+
+    public BusinessException(int errorCode, String errorDesc) {
+        super(errorDesc);
+        this.errorCode = errorCode;
+        this.errorDesc = errorDesc;
+    }
+
+    public BusinessException(ServerResultCode serverResultCode) {
+        super(serverResultCode.getErrorDesc());
+        this.errorCode = serverResultCode.getErrorCode();
+        this.errorDesc = serverResultCode.getErrorDesc();
+        log.error("业务异常: ", this);
+    }
+
+    public BusinessException(ErrorInfo errorInfo) {
+        super(errorInfo.getErrorDesc());
+        this.errorCode = errorInfo.getErrorCode();
+        this.errorDesc = errorInfo.getErrorDesc();
+        log.error("业务异常: ", this);
+    }
+
+    public BusinessException(ServerResult<?> serverResult) {
+        super(serverResult == null ? ServerResultCode.FAIL.getErrorDesc() : serverResult.getMessage());
+        if (serverResult == null) {
+            this.errorCode = ServerResultCode.FAIL.getErrorCode();
+            this.errorDesc = ServerResultCode.FAIL.getErrorDesc();
+        } else {
+            this.errorCode = serverResult.getResult();
+            this.errorDesc = serverResult.getMessage();
+            this.data = serverResult.getData();
+        }
+        log.error("业务异常: ", this);
+    }
+
+    public BusinessException(String message) {
+        super(message);
+    }
+
+    public BusinessException(Throwable cause) {
+        super(cause);
+        log.error("业务异常: ", this);
+    }
+
+    public BusinessException(String message, Throwable cause) {
+        super(message, cause);
+        log.error("业务异常: ", this);
+    }
+}
+package com.canrd.shop.common.exception;
+
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.common.constant.ServerResultCode;
+import org.springframework.core.annotation.Order;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+import java.util.Optional;
+
+/**
+ * 业务异常统一处理类
+ *
+ * @author A80076
+ * @date 2021/1/11
+ */
+@ControllerAdvice
+@Order(5)
+public class BusinessExceptionHandlerAdvice {
+
+
+    @ExceptionHandler(value = {BusinessException.class})
+    @ResponseStatus(value = HttpStatus.OK)
+    public ResponseEntity<Object> handleException(BusinessException exception) throws Exception {
+        return new ResponseEntity<Object>(handleBusinessException(exception), HttpStatus.OK);
+    }
+
+    private ServerResult handleBusinessException(BusinessException exception) {
+        Integer code = Optional.ofNullable(exception.getErrorCode()).orElse(ServerResultCode.FAIL.getErrorCode());
+        String msg = Optional.ofNullable(exception.getMessage()).orElse(ServerResultCode.FAIL.getErrorDesc());
+        Object data = Optional.ofNullable(exception.getData()).orElse(null);
+        return ServerResult.fail(data, code, msg);
+    }
+}
+package com.canrd.shop.common.exception;
+
+import org.springframework.util.StringUtils;
+
+/**
+ *
+ * @date 2018-11-23
+ */
+public class EntityExistException extends RuntimeException {
+
+    public EntityExistException(Class clazz, String field, String val) {
+        super(EntityExistException.generateMessage(clazz.getSimpleName(), field, val));
+    }
+
+    private static String generateMessage(String entity, String field, String val) {
+        return StringUtils.capitalize(entity)
+                + " with " + field + " " + val + " existed";
+    }
+}
 \ No newline at end of file
+package com.canrd.shop.common.exception;
+
+import org.springframework.util.StringUtils;
+
+/**
+ *
+ * @date 2018-11-23
+ */
+public class EntityNotFoundException extends RuntimeException {
+
+    public EntityNotFoundException(Class clazz, String field, String val) {
+        super(EntityNotFoundException.generateMessage(clazz.getSimpleName(), field, val));
+    }
+
+    private static String generateMessage(String entity, String field, String val) {
+        return StringUtils.capitalize(entity)
+                + " with " + field + " " + val + " does not exist";
+    }
+}
 \ No newline at end of file
+package com.canrd.shop.common.exception;
+
+/**
+ * @author fanzhenyu
+ * @date 2023-01-12
+ */
+public interface ErrorInfo {
+
+    Integer getErrorCode();
+
+    String getErrorDesc();
+}
+package com.canrd.shop.common.exception.handler;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ *
+ * @date 2018-11-23
+ */
+@Data
+class ApiError {
+
+    private Integer status = 200;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime timestamp;
+    private String message;
+    private String errorCode;
+
+    private ApiError() {
+        timestamp = LocalDateTime.now();
+    }
+
+    public static ApiError error(String message){
+        ApiError apiError = new ApiError();
+        apiError.setMessage(message);
+        return apiError;
+    }
+
+    public static ApiError error(Integer status, String message){
+        ApiError apiError = new ApiError();
+        apiError.setStatus(status);
+        apiError.setMessage(message);
+        return apiError;
+    }
+}
+
+
+package com.canrd.shop.common.exception.handler;
+
+
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.common.constant.ServerResultCode;
+import com.canrd.shop.common.exception.BadRequestException;
+import com.canrd.shop.common.exception.BusinessException;
+import com.canrd.shop.common.exception.EntityExistException;
+import com.canrd.shop.common.exception.EntityNotFoundException;
+import com.canrd.shop.common.utils.ThrowableUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.multipart.MaxUploadSizeExceededException;
+
+import java.util.Objects;
+
+/**
+ * @date 2018-11-23
+ */
+@Slf4j
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+    /**
+     * @param exception
+     * @return
+     * @throws Exception
+     */
+    @ExceptionHandler(value = RuntimeException.class)
+    public ResponseEntity<Object> handleServiceException(Exception exception) throws Exception {
+        return new ResponseEntity(translateException(exception), HttpStatus.OK);
+    }
+
+    /**
+     * @param exception
+     * @return
+     * @throws Exception
+     */
+    @ExceptionHandler(value = Exception.class)
+    @ResponseStatus(value = HttpStatus.INTERNAL_SERVER_ERROR)
+    public ResponseEntity<Object> handleException(Exception exception) throws Exception {
+        return new ResponseEntity<Object>(translateException(exception), HttpStatus.OK);
+    }
+
+
+    /**
+     * 处理所有接口数据验证异常
+     *
+     * @param e
+     * @return
+     */
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public ResponseEntity<ServerResult> handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
+        // 打印堆栈信息
+        log.error(ThrowableUtil.getStackTrace(e));
+        String[] str = Objects.requireNonNull(e.getBindingResult().getAllErrors().get(0).getCodes())[1].split("\\.");
+        String message = e.getBindingResult().getAllErrors().get(0).getDefaultMessage();
+        String msg = "不能为空";
+        if (msg.equals(message)) {
+            message = str[1] + ":" + message;
+        }
+        return buildResponseEntity(ServerResult.fail(message));
+    }
+
+    /**
+     * 处理自定义异常
+     *
+     * @param e
+     * @return
+     */
+    @ExceptionHandler(value = BadRequestException.class)
+    public ResponseEntity<ServerResult> badRequestException(BadRequestException e) {
+        // 打印堆栈信息
+        log.error(ThrowableUtil.getStackTrace(e));
+        return buildResponseEntity(ServerResult.fail(e.getStatus(), e.getMessage()));
+    }
+
+    /**
+     * 处理 EntityExist
+     */
+    @ExceptionHandler(value = EntityExistException.class)
+    public ResponseEntity<ServerResult> entityExistException(EntityExistException e) {
+        // 打印堆栈信息
+        log.error(ThrowableUtil.getStackTrace(e));
+        return buildResponseEntity(ServerResult.fail(e.getMessage()));
+    }
+
+    /**
+     * 处理 EntityNotFound
+     *
+     * @param e
+     * @return
+     */
+    @ExceptionHandler(value = EntityNotFoundException.class)
+    public ResponseEntity<ServerResult> entityNotFoundException(EntityNotFoundException e) {
+        // 打印堆栈信息
+        log.error(ThrowableUtil.getStackTrace(e));
+        return buildResponseEntity(ServerResult.fail(HttpStatus.NOT_FOUND.value(), e.getMessage()));
+    }
+
+    /**
+     * @param serverResult
+     * @return
+     */
+    private ResponseEntity<ServerResult> buildResponseEntity(ServerResult serverResult) {
+        return new ResponseEntity<>(serverResult, HttpStatus.valueOf(200));
+    }
+
+    /**
+     * @param e
+     * @return
+     * @throws Exception
+     */
+    private Object translateException(Exception e) throws Exception {
+        ServerResult serverResult = null;
+        if (e instanceof NullPointerException) {
+            serverResult = ServerResult.fail(ServerResultCode.NULL_POINT);
+        } else if (e instanceof IllegalArgumentException) {
+            serverResult = ServerResult.fail(ServerResultCode.FAIL);
+        } else if (e instanceof MaxUploadSizeExceededException) {
+            serverResult = ServerResult.fail(ServerResultCode.FIlE_UPLOAD_TOO_LARGE);
+        } else if (e instanceof BusinessException) {
+            serverResult = ServerResult.fail(((BusinessException) e).getErrorCode(), ((BusinessException) e).getErrorDesc());
+        } else {
+            serverResult = ServerResult.fail(ServerResultCode.FAIL);
+            serverResult.setMessage(serverResult.getMessage() + "|,业务异常:" + e.getMessage());
+        }
+
+        log.error("业务异常", e);
+        return serverResult;
+    }
+}
+package com.canrd.shop.common.jsr303;
+
+
+import com.canrd.shop.common.jsr303.annotation.ListIntValue;
+
+import javax.validation.ConstraintValidator;
+import javax.validation.ConstraintValidatorContext;
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ * 自定义校验注解 -枚举值校验
+ *
+ * @author fanzhenyu
+ * @date 2023-01-15
+ */
+public class ListValueConstraintValidator implements ConstraintValidator<ListIntValue, Integer> {
+    private Set<Integer> set = new HashSet<>();
+    // 是否必填
+    private boolean require;
+
+    @Override
+    public void initialize(ListIntValue constraintAnnotation) {
+        for (int i : constraintAnnotation.enumValue()) {
+            set.add(i);
+        }
+        require = constraintAnnotation.require();
+    }
+
+    /**
+     * 判断是否通过校验
+     *
+     * @param value   传入的值
+     * @param context
+     * @return
+     */
+    @Override
+    public boolean isValid(Integer value, ConstraintValidatorContext context) {
+        if (!require && value == null) {
+            return true;
+        }
+        return set.contains(value);
+    }
+
+}
+package com.canrd.shop.common.jsr303;
+
+
+public class OperateGroup {
+    /**
+     * 新增校验
+     */
+    public interface Save {
+    }
+
+    /**
+     * 删除校验
+     */
+    public interface Delete {
+    }
+
+    /**
+     * 修改校验
+     */
+    public interface Update {
+    }
+
+    /**
+     * 查询列表
+     */
+    public interface List {
+    }
+
+    /**
+     * 分页查询
+     */
+    public interface Page {
+    }
+
+    /**
+     * 长度校验
+     */
+    public interface Length {
+    }
+
+    /**
+     * 格式校验
+     */
+    public interface Format {
+    }
+
+    /**
+     * 详情
+     */
+    public interface Detail {
+    }
+
+    /**
+     * 单条
+     */
+    public interface One {
+    }
+
+
+    public interface Trace {
+
+    }
+
+    /**
+     * 批量查询
+     */
+    public interface BatchQuery {
+    }
+
+
+    /**
+     * 导出
+     */
+    public interface Export {
+    }
+
+}
+package com.canrd.shop.common.jsr303.annotation;
+
+
+import com.canrd.shop.common.jsr303.ListValueConstraintValidator;
+
+import javax.validation.Constraint;
+import javax.validation.Payload;
+import java.lang.annotation.*;
+
+/**
+ * @author fanzhenyu
+ * @date 2023-01-15
+ */
+@Constraint(validatedBy = {ListValueConstraintValidator.class})
+@Documented
+@Target({ElementType.METHOD, ElementType.FIELD, ElementType.ANNOTATION_TYPE, ElementType.CONSTRUCTOR, ElementType.PARAMETER, ElementType.TYPE_USE})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface ListIntValue {
+
+
+    // 配置文件中错误提示信息的名称
+    String message() default "非法的类型";
+
+    Class<?>[] groups() default {};
+
+    Class<? extends Payload>[] payload() default {};
+
+    // 自定义值的类型
+    int[] enumValue() default {};
+
+    // 是否必填，默认允许为空
+    boolean require() default false;
+}
+package com.canrd.shop.common.utils;
+
+import javax.crypto.Cipher;
+import javax.crypto.SecretKey;
+import javax.crypto.SecretKeyFactory;
+import javax.crypto.spec.DESKeySpec;
+import javax.crypto.spec.IvParameterSpec;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * 加密
+ *
+ * @date 2018-11-23
+ */
+public class EncryptUtils {
+
+    private static String strParam = "Passw0rd";
+
+    private static Cipher cipher;
+
+    private static IvParameterSpec iv = new IvParameterSpec(strParam.getBytes(StandardCharsets.UTF_8));
+
+    private static DESKeySpec getDesKeySpec(String source) throws Exception {
+        if (source == null || source.length() == 0) {
+            return null;
+        }
+        cipher = Cipher.getInstance("DES/CBC/PKCS5Padding");
+        String strKey = "Passw0rd";
+        return new DESKeySpec(strKey.getBytes(StandardCharsets.UTF_8));
+    }
+
+    /**
+     * 对称加密
+     */
+    public static String desEncrypt(String source) throws Exception {
+        DESKeySpec desKeySpec = getDesKeySpec(source);
+        SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("DES");
+        SecretKey secretKey = keyFactory.generateSecret(desKeySpec);
+        cipher.init(Cipher.ENCRYPT_MODE, secretKey, iv);
+        return byte2hex(
+                cipher.doFinal(source.getBytes(StandardCharsets.UTF_8))).toUpperCase();
+    }
+
+    /**
+     * 对称解密
+     */
+    public static String desDecrypt(String source) throws Exception {
+        byte[] src = hex2byte(source.getBytes());
+        DESKeySpec desKeySpec = getDesKeySpec(source);
+        SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("DES");
+        SecretKey secretKey = keyFactory.generateSecret(desKeySpec);
+        cipher.init(Cipher.DECRYPT_MODE, secretKey, iv);
+        byte[] retByte = cipher.doFinal(src);
+        return new String(retByte);
+    }
+
+    private static String byte2hex(byte[] inStr) {
+        String stmp;
+        StringBuilder out = new StringBuilder(inStr.length * 2);
+        for (byte b : inStr) {
+            stmp = Integer.toHexString(b & 0xFF);
+            if (stmp.length() == 1) {
+                // 如果是0至F的单位字符串，则添加0
+                out.append("0").append(stmp);
+            } else {
+                out.append(stmp);
+            }
+        }
+        return out.toString();
+    }
+
+    private static byte[] hex2byte(byte[] b) {
+        int size = 2;
+        if ((b.length % size) != 0) {
+            throw new IllegalArgumentException("长度不是偶数");
+        }
+        byte[] b2 = new byte[b.length / 2];
+        for (int n = 0; n < b.length; n += size) {
+            String item = new String(b, n, 2);
+            b2[n / 2] = (byte) Integer.parseInt(item, 16);
+        }
+        return b2;
+    }
+}
+package com.canrd.shop.common.utils;
+
+
+import com.alibaba.fastjson.JSONException;
+import com.alibaba.fastjson.JSONObject;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.*;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.IOException;
+
+/**
+ *
+ * @author achims
+ * @date 2019/11/4
+ * 用于转换成json字符串以及解析成对象
+ */
+@Slf4j
+public class JsonUtil {
+
+    private static ObjectMapper mapper = new ObjectMapper();
+
+    static {
+        log.info("注册jackson-datatype-jsr310的java8时间处理模块");
+        mapper.findAndRegisterModules();
+        mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        mapper.getSerializerProvider().setNullValueSerializer(new JsonSerializer<Object>() {
+            @Override
+            public void serialize(Object paramT, JsonGenerator paramJsonGenerator,
+                                  SerializerProvider paramSerializerProvider) throws IOException {
+                //设置返回null转为 空字符串""
+                paramJsonGenerator.writeString("");
+            }
+        });
+    }
+
+
+
+
+    /**
+     * Create empty json node
+     *
+     * @return
+     */
+    public static ObjectNode createJsonNode() {
+        return mapper.createObjectNode();
+    }
+
+    /**
+     * Create empty json Array
+     *
+     * @return
+     */
+    public static ArrayNode createJsonArray() {
+        return mapper.createArrayNode();
+
+    }
+
+    /**
+     * Convert the object to corresponding json string
+     *
+     * @param obj
+     * @return
+     */
+    public static String toJsonString(Object obj) {
+        try {
+            mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+            return mapper.writeValueAsString(obj);
+        } catch (JsonProcessingException e) {
+            return null;
+        }
+    }
+
+    /**
+     * 转成格式化后的json，便于调试排错
+     * @param obj
+     * @return
+     */
+    public static String toJsonStringWithDefaultPretty(Object obj) {
+        try {
+            mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+            return mapper.writerWithDefaultPrettyPrinter().writeValueAsString(obj);
+        } catch (JsonProcessingException e) {
+
+            return null;
+        }
+    }
+
+    public static <T> T jsonToEntity(String json, Class<T> clazz) {
+        if (StringUtils.isEmpty(json)) return null;
+        try {
+            return mapper.readValue(json, clazz);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 借助json做中转，实体类转实体类
+     * @param obj 实体
+     * @param clazz 目标类型
+     * @param <T> 目标泛型
+     * @return 结果
+     */
+    public static <T> T entityConvert(Object obj, Class<T> clazz) {
+        return jsonToEntity(toJsonString(obj), clazz);
+    }
+
+    /**
+     * 带泛型返回不告警
+     * @param json json字符
+     * @param typeReference TypeReference
+     * @param <R> 返回类型
+     * @param <T> 转换的类型
+     * @return 转换结果
+     * @author 刘迪榕
+     * @version Date 2022-08-26
+     */
+    public static <R, T extends R> R jsonToEntity(String json, TypeReference<T> typeReference) {
+        if (StringUtils.isEmpty(json)) return null;
+        try {
+            return mapper.readValue(json, typeReference);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    public static JsonNode readStringAsJsonNode(String json) {
+        try {
+            return mapper.readValue(json, JsonNode.class);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    public static JsonNode valueToTree(Object value) {
+        return mapper.valueToTree(value);
+    }
+
+    public static  <T> T  treeToValue(JsonNode jsonNode, Class<T> clazz) {
+        try {
+            return mapper.treeToValue(jsonNode, clazz);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 是否爲json格式的數據
+     *
+     * @param test
+     * @return
+     */
+    public final static boolean isJSONValid(String test) {
+        try {
+            JSONObject.parseObject(test);
+        } catch (JSONException ex) {
+            try {
+                JSONObject.parseArray(test);
+            } catch (JSONException ex1) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    public <T> T paraseJsonTOClass(String json, Class<T> cla) {
+        try {
+            return JSONObject.parseObject(json, cla);
+        } catch (JSONException ex) {
+            return null;
+        }
+    }
+}
+package com.canrd.shop.common.utils;
+
+import org.joda.time.DateTime;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author: xms
+ * @description: TODO
+ * @date: 2023/1/16 16:35
+ * @version: 1.0
+ */
+public class LocalDateTimeUtil {
+
+    /**
+     * @param dateTime
+     * @return
+     */
+    public static LocalDateTime toLocalDateTime(DateTime dateTime) {
+        return LocalDateTime.of(dateTime.getYear(), dateTime.getMonthOfYear(),
+                dateTime.getDayOfMonth(), dateTime.getHourOfDay(),
+                dateTime.getMinuteOfHour(), dateTime.getSecondOfMinute());
+    }
+
+    /**
+     *
+     * @param localDateTime
+     * @return
+     */
+    public static DateTime toDateTime(LocalDateTime localDateTime) {
+        return new DateTime().withYear(localDateTime.getYear()).withMonthOfYear(localDateTime.getMonthValue())
+                .withDayOfMonth(localDateTime.getDayOfMonth()).withHourOfDay(localDateTime.getHour())
+                .withMinuteOfHour(localDateTime.getMinute()).withSecondOfMinute(localDateTime.getSecond());
+    }
+}
+package com.canrd.shop.common.utils;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.canrd.shop.module.vo.BasePageVO;
+import org.springframework.util.CollectionUtils;
+
+import java.io.Serializable;
+import java.util.*;
+
+/**
+ * @Author: dengbin
+ * @Date: 2020/9/11
+ * 分页工具类
+ */
+
+public class PageUtils implements Serializable {
+    private static final long serialVersionUID = 4359709211352400087L;
+    private static final String PAGE_INDEX = "pageNo";
+    private static final String PAGE_SIZE = "pageSize";
+    private static final String TOTAL_ROWS = "total";
+    private static final String TOTAL_PAGES = "pages";
+    private static final String RECORDS = "records";
+
+    private static final int DEFAULT_PAGE_INDEX = 1;
+    private static final int DEFAULT_PAGE_SIZE = 10;
+    private static final int DEFAULT_MAP_CAPACITY = 5;
+
+    /**
+     * 统一分页返回对象
+     *
+     * @param list
+     * @return
+     */
+    public static Map<String, Object> getUnifiedPageReturn(IPage list) {
+        if (list == null) {
+            return getUnifiedEmptyPage(DEFAULT_PAGE_INDEX, DEFAULT_PAGE_SIZE);
+        }
+
+        Map<String, Object> resultMap = new HashMap<>(DEFAULT_MAP_CAPACITY);
+        resultMap.put(PAGE_INDEX, list.getCurrent());
+        resultMap.put(PAGE_SIZE, list.getSize());
+        resultMap.put(RECORDS, list.getRecords());
+        resultMap.put(TOTAL_PAGES, list.getPages());
+        resultMap.put(TOTAL_ROWS, list.getTotal());
+
+        return resultMap;
+    }
+
+    /**
+     * 返回空分页信息给前端
+     * 返回空或其他字段不满足前端要求，会报错
+     *
+     * @return
+     */
+    public static Map<String, Object> getUnifiedEmptyPage(int pageIndex, int pageSize) {
+        Map<String, Object> resultMap = new HashMap<>(DEFAULT_MAP_CAPACITY);
+        resultMap.put(PAGE_INDEX, pageIndex);
+        resultMap.put(PAGE_SIZE, pageSize);
+        resultMap.put(RECORDS, new ArrayList<>());
+        resultMap.put(TOTAL_PAGES, 0);
+        resultMap.put(TOTAL_ROWS, 0);
+        return resultMap;
+    }
+
+    public static Map<String, Object> getUnifiedEmptyPage(BasePageVO pageVO) {
+        return getUnifiedEmptyPage(pageVO.getPageNo(), pageVO.getPageSize());
+    }
+
+
+    /**
+     * 将旧的分页转换成新的分页对象
+     *
+     * @param oldPage 旧的分页对象，例如：xxDo的分页对象
+     * @param records 新的分页对象，例如：xxVo的分页对象
+     * @param <T>     新的分页对象的类型
+     * @return 统一的返回的分页对象
+     */
+    public static <T> Map<String, Object> transferPage(IPage<?> oldPage, List<T> records) {
+        Page<T> newPage = new Page<>();
+        newPage.setCurrent(oldPage.getCurrent());
+        newPage.setSize(oldPage.getSize());
+        newPage.setRecords(records);
+        newPage.setPages(oldPage.getPages());
+        newPage.setTotal(oldPage.getTotal());
+        return getUnifiedPageReturn(newPage);
+    }
+
+    /**
+     * 统一分页返回对象
+     *
+     * @param records 分页数据
+     * @param pageVO  分页参数
+     * @return
+     */
+    public static Map<String, Object> getPageReturn(List records, BasePageVO pageVO) {
+        if (records == null) {
+            return getUnifiedEmptyPage(DEFAULT_PAGE_INDEX, DEFAULT_PAGE_SIZE);
+        }
+        if (CollectionUtils.isEmpty(records)) {
+            return getUnifiedEmptyPage(Math.toIntExact(pageVO.getPageNo()), Math.toIntExact(pageVO.getPageSize()));
+        }
+        Map<String, Object> resultMap = new HashMap<>(DEFAULT_MAP_CAPACITY);
+        resultMap.put(PAGE_INDEX, pageVO.getPageNo());
+        resultMap.put(PAGE_SIZE, pageVO.getPageSize());
+        resultMap.put(RECORDS, records);
+        resultMap.put(TOTAL_PAGES, (pageVO.getTotal() + pageVO.getPageSize() - 1) / pageVO.getPageSize());
+        resultMap.put(TOTAL_ROWS, pageVO.getTotal());
+
+        return resultMap;
+    }
+
+    public static <T> Page<T> getRAMPageReturn(Integer current, Integer size, List<T> records) {
+        if (Objects.isNull(current)) {
+            current = 1;
+        }
+        if (Objects.isNull(size)) {
+            size = 10;
+        }
+        int startIndex = (current - 1) * size;
+        int endIndex = Math.min(current * size, records.size());
+        if (startIndex > endIndex) {
+            startIndex = endIndex;
+        }
+        Page<T> page = new Page<>();
+        page.setCurrent(current);
+        page.setSize(size);
+        page.setRecords(records.subList(startIndex, endIndex));
+        int totalPages = size == 0 ? 0 : records.size() % size == 0 ? (records.size() / size) : (records.size() / size + 1);
+        page.setPages(totalPages);
+        page.setTotal(records.size());
+        return page;
+    }
+
+
+}
+package com.canrd.shop.common.utils;
+
+import org.springframework.web.context.ContextLoader;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.ServletContext;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+
+
+public class RequestContextUtil {
+
+    public static HttpServletRequest getRequest() {
+        return getRequestAttributes().getRequest();
+    }
+
+    public static HttpServletResponse getResponse() {
+        return getRequestAttributes().getResponse();
+    }
+
+    public static HttpSession getSession() {
+        return getRequest().getSession();
+    }
+
+    public static ServletRequestAttributes getRequestAttributes() {
+        return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes());
+    }
+
+    public static ServletContext getServletContext() {
+        return ContextLoader.getCurrentWebApplicationContext().getServletContext();
+    }
+
+}
+package com.canrd.shop.common.utils;
+
+import com.canrd.shop.common.constant.ServerResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * @date 2023-02-02
+ */
+@Slf4j
+public class ServletUtils {
+
+
+    public static void renderServerResult(HttpServletResponse response, ServerResult serverResult, HttpStatus httpStatus)
+    {
+        try
+        {
+            response.setStatus(httpStatus.value());
+            response.setContentType("application/json");
+            response.setCharacterEncoding("utf-8");
+            response.getWriter().print(JsonUtil.toJsonString(serverResult));
+        }
+        catch (IOException e)
+        {
+            log.error("ServletUtils#renderServerResult:",e);
+        }
+    }
+
+
+    public static void renderExcelFileNotFound(HttpServletResponse response){
+        try {
+            response.setStatus(404);
+            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet;charset=utf-8");
+            //test.xls是弹出下载对话框的文件名，不能为中文，中文请自行编码
+            response.setHeader("Content-Disposition", "attachment;filename=file.xlsx");
+            response.sendError(HttpStatus.NOT_FOUND.value(),"下载失败，资源不存在");
+        }catch (IOException e){
+            log.error("ServletUtils#renderWithResourceNotFound:",e);
+        }
+    }
+}
+package com.canrd.shop.common.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+
+/**
+ * @author Jie
+ * @date 2019-01-07
+ */
+@Slf4j
+public class SpringContextHolder implements ApplicationContextAware, DisposableBean {
+
+    private static ApplicationContext applicationContext = null;
+
+    /**
+     * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
+     */
+    @SuppressWarnings("unchecked")
+    public static <T> T getBean(String name) {
+        assertContextInjected();
+        return (T) applicationContext.getBean(name);
+    }
+
+    /**
+     * 从静态变量applicationContext中取得Bean, 自动转型为所赋值对象的类型.
+     */
+    public static <T> T getBean(Class<T> requiredType) {
+        assertContextInjected();
+        return applicationContext.getBean(requiredType);
+    }
+
+    /**
+     * 检查ApplicationContext不为空.
+     */
+    private static void assertContextInjected() {
+        if (applicationContext == null) {
+            throw new IllegalStateException("applicaitonContext属性未注入, 请在applicationContext" +
+                    ".xml中定义SpringContextHolder或在SpringBoot启动类中注册SpringContextHolder.");
+        }
+    }
+
+    /**
+     * 清除SpringContextHolder中的ApplicationContext为Null.
+     */
+    private static void clearHolder() {
+        log.debug("清除SpringContextHolder中的ApplicationContext:"
+                + applicationContext);
+        applicationContext = null;
+    }
+
+    @Override
+    public void destroy() {
+        SpringContextHolder.clearHolder();
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        if (SpringContextHolder.applicationContext != null) {
+            log.warn("SpringContextHolder中的ApplicationContext被覆盖, 原有ApplicationContext为:" + SpringContextHolder.applicationContext);
+        }
+        SpringContextHolder.applicationContext = applicationContext;
+    }
+}
+package com.canrd.shop.common.utils;
+
+import com.canrd.shop.common.constant.Constant;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.CollectionUtils;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
+import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.regex.PatternSyntaxException;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+import java.util.zip.GZIPInputStream;
+import java.util.zip.GZIPOutputStream;
+
+/**
+ * @param
+ * @author 邓彬
+ * @version 0.1.0
+ * @Description
+ * @return
+ * @date 2021/4/16 17:44
+ * @since 0.1.0
+ */
+@Slf4j
+public class StringUtils {
+    /**
+     * 首字母变小写
+     *
+     * @param str
+     * @return
+     */
+    public static String firstCharToLowerCase(String str) {
+        char firstChar = str.charAt(0);
+        if (firstChar >= 'A' && firstChar <= 'Z') {
+            char[] arr = str.toCharArray();
+            arr[0] += ('a' - 'A');
+            return new String(arr);
+        }
+        return str;
+    }
+
+    /**
+     * 首字母变大写
+     *
+     * @param str
+     * @return
+     */
+    public static String firstCharToUpperCase(String str) {
+        char firstChar = str.charAt(0);
+        if (firstChar >= 'a' && firstChar <= 'z') {
+            char[] arr = str.toCharArray();
+            arr[0] -= ('a' - 'A');
+            return new String(arr);
+        }
+        return str;
+    }
+
+    /**
+     * 判断是否为空
+     *
+     * @param str
+     * @return
+     */
+    public static boolean isEmpty(final String str) {
+        return (str == null) || (str.length() == 0);
+    }
+
+    /**
+     * 判断是否不为空
+     *
+     * @param str
+     * @return
+     */
+    public static boolean isNotEmpty(final String str) {
+        return !isEmpty(str);
+    }
+
+    /**
+     * 判断是否空白
+     *
+     * @param str
+     * @return
+     */
+    public static boolean isBlank(final String str) {
+        int strLen;
+        if ((str == null) || ((strLen = str.length()) == 0)) {
+            return true;
+        }
+        for (int i = 0; i < strLen; i++) {
+            if (!Character.isWhitespace(str.charAt(i))) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 判断是否不是空白
+     *
+     * @param str
+     * @return
+     */
+    public static boolean isNotBlank(final String str) {
+        return !isBlank(str);
+    }
+
+    /**
+     * 判断多个字符串全部是否为空
+     *
+     * @param strings
+     * @return
+     */
+    public static boolean isAllEmpty(String... strings) {
+        if (strings == null) {
+            return true;
+        }
+        for (String str : strings) {
+            if (isNotEmpty(str)) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 判断多个字符串其中任意一个是否为空
+     *
+     * @param strings
+     * @return
+     */
+    public static boolean isHasEmpty(String... strings) {
+        if (strings == null) {
+            return true;
+        }
+        for (String str : strings) {
+            if (isEmpty(str)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 判断多个字符串是否都为blank
+     *
+     * @param strings
+     * @return
+     */
+    public static boolean isAllBlank(String... strings) {
+        if (strings == null) {
+            return true;
+        }
+        for (String str : strings) {
+            if (isNotBlank(str)) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * checkValue为 null 或者为 "" 时返回 defaultValue
+     *
+     * @param checkValue
+     * @param defaultValue
+     * @return
+     */
+    public static String isEmpty(String checkValue, String defaultValue) {
+        return isEmpty(checkValue) ? defaultValue : checkValue;
+    }
+
+    /**
+     * 字符串不为 null 而且不为 "" 并且等于other
+     *
+     * @param str
+     * @param other
+     * @return
+     */
+    public static boolean isNotEmptyAndEqualsOther(String str, String other) {
+        return !isEmpty(str) && str.equals(other);
+    }
+
+    /**
+     * 字符串不为 null 而且不为 "" 并且不等于other
+     *
+     * @param str
+     * @param other
+     * @return
+     */
+    public static boolean isNotEmptyAndNotEqualsOther(String str, String... other) {
+        if (isEmpty(str)) {
+            return false;
+        }
+        for (String s : other) {
+            if (str.equals(s)) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 字符串不等于other
+     *
+     * @param str
+     * @param other
+     * @return
+     */
+    public static boolean isNotEqualsOther(String str, String... other) {
+        for (String s : other) {
+            if (s.equals(str)) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 判断字符串不为空
+     *
+     * @param strings
+     * @return
+     */
+    public static boolean isNotEmpty(String... strings) {
+        if (strings == null || strings.length == 0) {
+            return false;
+        }
+        for (String str : strings) {
+            if (str == null || "".equals(str.trim())) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 比较字符相等
+     *
+     * @param value
+     * @param equals
+     * @return
+     */
+    public static boolean equals(String value, String equals) {
+        if (isAllEmpty(value, equals)) {
+            return true;
+        }
+        //进一步判断value是不是空，如果是空，要直接equals会报NPE异常
+        if (value == null) {
+            return false;
+        }
+        return value.equals(equals);
+    }
+
+    /**
+     * @description 将字符串转换为数字数组
+     * @author 黄楷涵
+     * @date 2020/9/15
+     */
+    public static int[] stringParseToInt(String str, String regex) {
+        return stringParseToInt(str.split(regex));
+    }
+
+    /**
+     * @description 将字符串数组转换为数字数组
+     * @author dengbin
+     * @date 2020/9/15
+     */
+    public static int[] stringParseToInt(String[] str) {
+        int[] num = new int[str.length];
+        for (int i = 0; i < str.length; i++) {
+            num[i] = Integer.parseInt(str[i]);
+        }
+        return num;
+    }
+
+    /**
+     * 比较字符串不相等
+     *
+     * @param value
+     * @param equals
+     * @return
+     */
+    public static boolean isNotEquals(String value, String equals) {
+        return !equals(value, equals);
+    }
+
+    public static String[] split(String content, String separatorChars) {
+        return splitWorker(content, separatorChars, -1, false);
+    }
+
+    public static String[] split(String str, String separatorChars, int max) {
+        return splitWorker(str, separatorChars, max, false);
+    }
+
+    public static final String[] EMPTY_STRING_ARRAY = new String[0];
+
+    private static String[] splitWorker(String str, String separatorChars, int max, boolean preserveAllTokens) {
+        if (str == null) {
+            return null;
+        }
+        int len = str.length();
+        if (len == 0) {
+            return EMPTY_STRING_ARRAY;
+        }
+        List<String> list = new ArrayList<String>();
+        int sizePlus1 = 1;
+        int i = 0, start = 0;
+        boolean match = false;
+        boolean lastMatch = false;
+        if (separatorChars == null) {
+            while (i < len) {
+                if (Character.isWhitespace(str.charAt(i))) {
+                    if (match || preserveAllTokens) {
+                        lastMatch = true;
+                        if (sizePlus1++ == max) {
+                            i = len;
+                            lastMatch = false;
+                        }
+                        list.add(str.substring(start, i));
+                        match = false;
+                    }
+                    start = ++i;
+                    continue;
+                }
+                lastMatch = false;
+                match = true;
+                i++;
+            }
+        } else if (separatorChars.length() == 1) {
+            char sep = separatorChars.charAt(0);
+            while (i < len) {
+                if (str.charAt(i) == sep) {
+                    if (match || preserveAllTokens) {
+                        lastMatch = true;
+                        if (sizePlus1++ == max) {
+                            i = len;
+                            lastMatch = false;
+                        }
+                        list.add(str.substring(start, i));
+                        match = false;
+                    }
+                    start = ++i;
+                    continue;
+                }
+                lastMatch = false;
+                match = true;
+                i++;
+            }
+        } else {
+            while (i < len) {
+                if (separatorChars.indexOf(str.charAt(i)) >= 0) {
+                    if (match || preserveAllTokens) {
+                        lastMatch = true;
+                        if (sizePlus1++ == max) {
+                            i = len;
+                            lastMatch = false;
+                        }
+                        list.add(str.substring(start, i));
+                        match = false;
+                    }
+                    start = ++i;
+                    continue;
+                }
+                lastMatch = false;
+                match = true;
+                i++;
+            }
+        }
+        if (match || (preserveAllTokens && lastMatch)) {
+            list.add(str.substring(start, i));
+        }
+        return list.toArray(EMPTY_STRING_ARRAY);
+    }
+
+    /**
+     * 消除转义字符
+     *
+     * @param str
+     * @return
+     */
+    public static String escapeXml(String str) {
+        if (str == null) {
+            return "";
+        }
+        StringBuilder sb = new StringBuilder();
+        for (int i = 0; i < str.length(); ++i) {
+            char c = str.charAt(i);
+            switch (c) {
+                case '\u00FF':
+                case '\u0024':
+                    break;
+                case '&':
+                    sb.append("&amp;");
+                    break;
+                case '<':
+                    sb.append("&lt;");
+                    break;
+                case '>':
+                    sb.append("&gt;");
+                    break;
+                case '\"':
+                    sb.append("&quot;");
+                    break;
+                case '\'':
+                    sb.append("&apos;");
+                    break;
+                default:
+                    if (c <= '\u001F') {
+                        break;
+                    }
+                    if (c >= '\uE000' && c <= '\uF8FF') {
+                        break;
+                    }
+                    if (c >= '\uFFF0') {
+                        break;
+                    }
+                    sb.append(c);
+                    break;
+            }
+        }
+        return sb.toString();
+    }
+
+    /**
+     * 将字符串中特定模式的字符转换成map中对应的值
+     *
+     * @param s   需要转换的字符串
+     * @param map 转换所需的键值对集合
+     * @return 转换后的字符串
+     */
+    public static String replace(String s, Map<String, Object> map) {
+        StringBuilder ret = new StringBuilder((int) (s.length() * 1.5));
+        int cursor = 0;
+        for (int start, end; (start = s.indexOf("${", cursor)) != -1 && (end = s.indexOf("}", start)) != -1; ) {
+            ret.append(s.substring(cursor, start)).append(map.get(s.substring(start + 2, end)));
+            cursor = end + 1;
+        }
+        ret.append(s.substring(cursor, s.length()));
+        return ret.toString();
+    }
+
+    public static String replace(String s, Object... objs) {
+        if (objs == null || objs.length == 0) {
+            return s;
+        }
+        if (!s.contains("{}")) {
+            return s;
+        }
+        StringBuilder ret = new StringBuilder((int) (s.length() * 1.5));
+        int cursor = 0;
+        int index = 0;
+        for (int start; (start = s.indexOf("{}", cursor)) != -1; ) {
+            ret.append(s.substring(cursor, start));
+            if (index < objs.length) {
+                ret.append(objs[index]);
+            } else {
+                ret.append("{}");
+            }
+            cursor = start + 2;
+            index++;
+        }
+        ret.append(s.substring(cursor, s.length()));
+        return ret.toString();
+    }
+
+
+    /**
+     * 转换为字节数组
+     *
+     * @param bytes
+     * @return
+     */
+    public static String toString(byte[] bytes) {
+        return new String(bytes, StandardCharsets.UTF_8);
+    }
+
+    /**
+     * 转换为字节数组
+     *
+     * @param str
+     * @return
+     */
+    public static byte[] getBytes(String str) {
+        return str != null ? str.getBytes(StandardCharsets.UTF_8) : null;
+    }
+
+    public static boolean isNumeric(String cs) {
+        if (isEmpty(cs)) {
+            return false;
+        }
+        for (int i = 0, sz = cs.length(); i < sz; ++i) {
+            if (!Character.isDigit(cs.charAt(i))) {
+                return false;
+            }
+        }
+        return true;
+
+    }
+
+    /**
+     * 手机号脱敏
+     *
+     * @param phoneNumber
+     * @return
+     */
+    public static String desensitizedPhoneNumber(String phoneNumber) {
+        if (StringUtils.isNotEmpty(phoneNumber)) {
+            phoneNumber = phoneNumber.replaceAll("(\\w{3})\\w*(\\w{4})", "$1****$2");
+        }
+        return phoneNumber;
+    }
+
+    /**
+     * 校验3位小数
+     *
+     * @param str
+     * @return
+     */
+    public static boolean checkDecimal(String str) {
+        return Pattern.compile(Constant.DICMAL_REGEXP).matcher(str).find();
+    }
+
+    /**
+     * 校验11位国内手机号
+     * <p>规则: 11位数，首位必须为1，第二位可以是3-9；其他位数不限制
+     *
+     * @param phone 手机号
+     * @return 格式正确则返回false; 反之为true
+     * @author A80080
+     * @createDate 2020/12/19
+     */
+    public static boolean checkPhoneNum(String phone) {
+        return StringUtils.isEmpty(phone) || !Pattern.compile("^1([3-9])[0-9]{9}$").matcher(phone).find();
+    }
+
+    /**
+     * @param str
+     * @return boolean
+     * @Description 判断字符串是否含有空格
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/13 18:10
+     * @since 0.1.0
+     */
+    public static boolean checkStringContainEmpty(String str) {
+        return !StringUtils.isEmpty(str) && str.contains(" ");
+    }
+
+    /**
+     * 字符串切分
+     *
+     * @param splitStr
+     * @param splitFlag
+     * @return
+     */
+    public static List<String> splitTag(String splitStr, String splitFlag) {
+        return StringUtils.isBlank(splitStr) || StringUtils.isBlank(splitFlag) ?
+                new ArrayList<>() :
+                Arrays.stream(splitStr.split(splitFlag)).collect(Collectors.toList());
+    }
+
+    /**
+     * @param name
+     * @return true代表全是汉字
+     * @Description 校验String是否全是中文
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/18 19:54
+     * @since 0.1.0
+     */
+    public static boolean checkNameChina(String name) {
+        boolean res = true;
+        char[] cTemp = name.toCharArray();
+        for (int i = 0; i < name.length(); i++) {
+            if (!isChinese(cTemp[i])) {
+                res = false;
+                break;
+            }
+        }
+        return res;
+    }
+
+    /**
+     * @param c
+     * @return true代表是汉字
+     * @Description 判定输入的是否是汉字
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/18 19:53
+     * @since 0.1.0
+     */
+    public static boolean isChinese(char c) {
+        Character.UnicodeBlock ub = Character.UnicodeBlock.of(c);
+        if (ub == Character.UnicodeBlock.CJK_UNIFIED_IDEOGRAPHS
+                || ub == Character.UnicodeBlock.CJK_COMPATIBILITY_IDEOGRAPHS
+                || ub == Character.UnicodeBlock.CJK_UNIFIED_IDEOGRAPHS_EXTENSION_A
+                || ub == Character.UnicodeBlock.GENERAL_PUNCTUATION
+                || ub == Character.UnicodeBlock.CJK_SYMBOLS_AND_PUNCTUATION
+                || ub == Character.UnicodeBlock.HALFWIDTH_AND_FULLWIDTH_FORMS) {
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * @param c
+     * @return true代表符合条件
+     * @Description 校验某个字符是否是a-z、A-Z、_、0-9
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/18 19:56
+     * @since 0.1.0
+     */
+    public static boolean isWord(char c) {
+        return Pattern.compile("[\\w]").matcher("" + c).matches();
+    }
+
+    /**
+     * @param str
+     * @return boolean
+     * @Description 字符串是否仅包含数字和字母
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/18 20:00
+     * @since 0.1.0
+     */
+    public static boolean isLetterDigit(String str) {
+        return str.matches("^[a-z0-9A-Z]+$");
+    }
+
+    /**
+     * @param str
+     * @return boolean
+     * @Description 判断是否是纯数字
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/1/23 16:33
+     * @since 0.1.0
+     */
+    public static boolean isDigit(String str) {
+        return str.matches("^[0-9]+$");
+    }
+
+    /**
+     * 是否合法手机号
+     *
+     * @param phone
+     * @return
+     */
+    public static boolean isMobilePhone(String phone) {
+        return Pattern.compile(Constant.PHONE_REGEXP).matcher(phone).matches();
+    }
+
+    /**
+     * 是否脱敏手机号
+     *
+     * @param phone
+     * @return
+     */
+    public static boolean isDesensitizationMobilePhone(String phone) {
+        return Pattern.compile(Constant.PHONE_DESENSITIZATION_REGEXP).matcher(phone).matches();
+    }
+
+    /**
+     * 判断String是否是整数<br>
+     * 支持10进制
+     *
+     * @param s String
+     * @return 是否为整数
+     */
+    public static boolean isInteger(String s) {
+        try {
+            Integer.parseInt(s);
+        } catch (NumberFormatException e) {
+            return false;
+        }
+        return true;
+    }
+
+    /**
+     * 判断对象能否转
+     *
+     * @param o Object
+     * @return 是否为Integer
+     */
+    public static boolean isInteger(Object o) {
+        try {
+            Integer.parseInt(String.valueOf(o));
+            return true;
+        } catch (NumberFormatException e) {
+            return false;
+        }
+    }
+
+    public static String escapeCharacter(String str) {
+        if (!isEmpty(str)) {
+            if (str.contains("\\")) {
+                str = str.replaceAll("\\\\", "\\\\\\\\");
+            }
+        }
+        return str;
+    }
+
+    /**
+     * @param str
+     * @return boolean
+     * @Description 匹配字符串是，数字、26个英文字母、下划线组成的8-16位的字符串组合
+     * @version 0.1.0
+     * @author A80077-刘始达
+     * @date 2021/04/06
+     * @since 0.1.0
+     */
+    public static boolean checkPWD(String str) {
+        return str.matches("^(?=.*([a-zA-Z].*))(?=.*[0-9].*)[a-zA-Z0-9-_]{8,16}+$");
+    }
+
+    /**
+     * 判断是否包含特殊字符
+     *
+     * @param str
+     * @return
+     */
+    public static boolean checkSpecificSymbol(String str) {
+        String regEx = "[ _`~!@#$%^&*()+=|{}':;',\\[\\].<>/?~！@#￥%……&*（）——+|{}【】‘；：”“’。，、？]|\n|\r|\t";
+        Pattern p = Pattern.compile(regEx);
+        Matcher m = p.matcher(str);
+        return m.find();
+    }
+
+    /**
+     * 拼接图片标签url
+     *
+     * @param str
+     * @param ossDomain
+     * @return
+     */
+    public static String replaceHtmlTag(String str, String ossDomain) {
+        if (StringUtils.isEmpty(str)) {
+            return "";
+        }
+        if (StringUtils.isEmpty(ossDomain)) {
+            return str;
+        }
+        return replaceHtmlTag(str, "img", "src", "src=\"" + ossDomain, "\"");
+    }
+
+    /**
+     * html格式处理：替换指定标签的属性和值
+     *
+     * @param str       需要处理的字符串
+     * @param tag       标签名称
+     * @param tagAttrib 要替换的标签属性值
+     * @param startTag  新标签开始标记
+     * @param endTag    新标签结束标记
+     * @return
+     */
+    public static String replaceHtmlTag(String str, String tag, String tagAttrib, String startTag, String endTag) {
+        String regxpForTag = "<\\s*" + tag + "\\s+([^>]*)\\s*";
+        String regxpForTagAttrib = tagAttrib + "=\\s*\"([^\"]+)\"";
+        Pattern patternForTag = Pattern.compile(regxpForTag, Pattern.CASE_INSENSITIVE);
+        Pattern patternForAttrib = Pattern.compile(regxpForTagAttrib, Pattern.CASE_INSENSITIVE);
+        Matcher matcherForTag = patternForTag.matcher(str);
+        StringBuffer sb = new StringBuffer();
+        boolean result = matcherForTag.find();
+        while (result) {
+            StringBuffer stringBuffer = new StringBuffer("<" + tag + " ");
+            Matcher matcherForAttrib = patternForAttrib.matcher(matcherForTag.group(1));
+            if (matcherForAttrib.find()) {
+                String attributeStr = matcherForAttrib.group(1);
+                if (!attributeStr.contains("https") && !attributeStr.contains("http")) {
+                    matcherForAttrib.appendReplacement(stringBuffer, startTag + attributeStr + endTag);
+                }
+            }
+            matcherForAttrib.appendTail(stringBuffer);
+            matcherForTag.appendReplacement(sb, stringBuffer.toString());
+            result = matcherForTag.find();
+        }
+        matcherForTag.appendTail(sb);
+        return sb.toString();
+    }
+
+    /**
+     * @param str
+     * @return java.util.Map<String, List < String>>
+     * @Description 字符串的连续切割 返回中文词组 数字和字母的集合
+     * @version 0.1.0
+     * @author 邓彬
+     * @date 2021/4/15 13:53
+     * @since 0.1.0
+     */
+    public static Map<String, List<String>> convertStrToChineseList(String str) {
+        if (StringUtils.isEmpty(str)) {
+            return null;
+        }
+        Map<String, List<String>> resultMap = new HashMap<>();
+        List<String> chineseList;
+        List<String> charList;
+        char[] list = str.toCharArray();
+        StringBuilder chineseStr = new StringBuilder();
+        StringBuilder charStr = new StringBuilder();
+        for (char c : list) {
+            if (StringUtils.isChinese(c)) {
+                chineseStr.append(c);
+                charStr.append(Constant.SLASH_MARK_CHARACTER);
+            } else if (Character.isLetterOrDigit(c)) {
+                charStr.append(c);
+                chineseStr.append(Constant.SLASH_MARK_CHARACTER);
+            } else {
+                charStr.append(Constant.SLASH_MARK_CHARACTER);
+                chineseStr.append(Constant.SLASH_MARK_CHARACTER);
+            }
+
+        }
+        chineseList = Arrays.stream(chineseStr.toString()
+                .split(Constant.SLASH_MARK_CHARACTER))
+                .filter(StringUtils::isNotEmpty).collect(Collectors.toList());
+        charList = Arrays.stream(charStr.toString()
+                .split(Constant.SLASH_MARK_CHARACTER))
+                .filter(StringUtils::isNotEmpty).map(String::toLowerCase).collect(Collectors.toList());
+
+        resultMap.put("chineseKey", chineseList);
+        resultMap.put("charKey", charList);
+        return resultMap;
+    }
+
+    /**
+     * 单个字符转换为小写
+     *
+     * @param c
+     * @return
+     */
+    public static char singleCharToLowerCase(char c) {
+        if (c >= 'A' && c <= 'Z') {
+            c += ('a' - 'A');
+            return c;
+        }
+        return c;
+    }
+
+    public static boolean isLong(String shopId) {
+        try {
+            Long.parseLong(shopId);
+        } catch (NumberFormatException e) {
+            return false;
+        }
+        return true;
+    }
+
+    public static String priceFormatting(String price) {
+        if (StringUtils.isEmpty(price)) {
+            return Constant.EMPTY_STRING;
+        }
+
+        String newPrice = "";
+        // 价格不存在小数点，则直接返回，无需处理
+        if (!price.contains(Constant.POINT_BAR_CHARACTER)) {
+            newPrice = price;
+            return newPrice;
+        }
+
+        // 有小数点，则分割字符串
+        String[] s = price.split("\\.");
+
+        // 小数位数大于0 且小于2 且存在非0字符
+        if (s[1].length() > 0 && s[1].length() <= 2 && !judgeIsNumeric(s[1])) {
+            BigDecimal bigDecimal = new BigDecimal(price).setScale(2, BigDecimal.ROUND_HALF_UP);
+            newPrice = bigDecimal.toPlainString();
+        }
+        // 【保留这个else if】小数位数大于0 且大于2 且存在非0字符，理论上不会存在，因为新增商品时已经限定最多输入2个小数点
+        else if (s[1].length() > 0 && s[1].length() > 2 && !judgeIsNumeric(s[1])) {
+            BigDecimal bigDecimal = new BigDecimal(price).setScale(2, BigDecimal.ROUND_HALF_UP);
+            String[] split = bigDecimal.toPlainString().split("\\.");
+            if (split[1].length() > 0 && judgeIsNumeric(split[1])) {
+                newPrice = new BigDecimal(bigDecimal.toPlainString()).setScale(0, BigDecimal.ROUND_HALF_UP).toPlainString();
+            } else {
+                newPrice = bigDecimal.toPlainString();
+            }
+        } else {
+            // 小数位数大于0 且小于2 且小数点都是0
+            newPrice = new BigDecimal(price).setScale(0, BigDecimal.ROUND_HALF_UP).toPlainString();
+        }
+        return newPrice;
+    }
+
+    /**
+     * 判断字符串是否只包含0
+     *
+     * @param str
+     * @return
+     */
+    private static boolean judgeIsNumeric(String str) {
+        return Pattern.compile("[0]*").matcher(str).matches();
+    }
+
+    /**
+     * 字符串以","分隔后转为String[]
+     *
+     * @param s
+     * @return
+     */
+    public static String[] string2ArraySplitByComma(String s) {
+        if (s == null || s.length() == 0) {
+            return new String[]{};
+        }
+        return s.split(Constant.COMMA_CHARACTER);
+    }
+
+    public static boolean isStringArrayContainsSpecifiedValue(String[] strings, String value) {
+        if (null == strings || strings.length <= 0 || value == null || value.length() == 0) {
+            return false;
+        }
+        boolean isContainsSpecifiedValue = false;
+        for (String s : strings) {
+            if (s.equals(value)) {
+                isContainsSpecifiedValue = true;
+                break;
+            }
+        }
+        return isContainsSpecifiedValue;
+    }
+
+    /**
+     * 字符串以","分隔后转为list
+     *
+     * @param s
+     * @return
+     */
+    public static List<String> string2ListSplitByComma(String s) {
+        List<String> stringList = new ArrayList<>();
+        if (s == null || s.length() == 0) {
+            return stringList;
+        }
+        String[] strArray = string2ArraySplitByComma(s);
+
+        for (String st : strArray) {
+            if (null != st && st.trim() != null || st.trim().length() != 0) {
+                stringList.add(st.trim());
+            }
+        }
+
+        return stringList;
+    }
+
+    /**
+     * 字符串按照特殊符号
+     * ".*[`~!@#$%^&*()+=|{}':;',\\[\\].<>/?~！@#￥%……&*()——+|{}【】‘；：”“’。，、？\\\\]+.*"
+     * 截取转成字符串集合
+     *
+     * @param str
+     * @return
+     */
+    public static List<String> splitStringBySpecificSymbol(String str) throws PatternSyntaxException {
+        String regEx = "[`~!@#$%^&*()\\-+=|{}':;,\\[\\].<>/?！￥…（）—【】‘；：”“’。，、？\\\\]";
+        Pattern p = Pattern.compile(regEx);
+        Matcher m = p.matcher(str);
+        return Stream.of(m.replaceAll("_").split("_")).map(String::trim).filter(StringUtils::isNotBlank).collect(Collectors.toList());
+    }
+
+    /**
+     * 使用gzip压缩字符串
+     *
+     * @param str 要压缩的字符串
+     * @return 压缩后的字符串
+     */
+    public static String compressByGZip(String str) {
+        if (str == null || str.length() == 0) {
+            return str;
+        }
+        ByteArrayOutputStream out = new ByteArrayOutputStream();
+        GZIPOutputStream gzip = null;
+        try {
+            gzip = new GZIPOutputStream(out);
+            gzip.write(str.getBytes(StandardCharsets.UTF_8));
+        } catch (IOException e) {
+            log.error("compressByGZip error: {}", e);
+        } finally {
+            if (gzip != null) {
+                try {
+                    gzip.close();
+                } catch (IOException e) {
+                    log.error("compressByGZip gzip close error: {}", e);
+                }
+            }
+        }
+        // 必须在关闭gzip流之后再读取
+        try {
+            return new sun.misc.BASE64Encoder().encode(out.toByteArray());
+        } catch (Exception e) {
+            log.error("compressByGZip BASE64Encoder error:{}", e);
+        }
+        return str;
+    }
+
+    /**
+     * 使用gzip解压缩
+     *
+     * @param compressedStr 已压缩的字符串
+     * @return 解压之后的字符串
+     */
+    public static String uncompressByGZip(String compressedStr) {
+        if (compressedStr == null || compressedStr.length() == 0) {
+            return compressedStr;
+        }
+
+        String decompressed;
+        try (
+                ByteArrayOutputStream out = new ByteArrayOutputStream();
+                ByteArrayInputStream in = new ByteArrayInputStream(new sun.misc.BASE64Decoder().decodeBuffer(compressedStr));
+                GZIPInputStream ginzip = new GZIPInputStream(in);
+        ) {
+            byte[] buffer = new byte[1024];
+            int offset;
+            while ((offset = ginzip.read(buffer)) != -1) {
+                out.write(buffer, 0, offset);
+            }
+            decompressed = out.toString();
+        } catch (IOException e) {
+            log.error("uncompressByGZip error:{}", e);
+            return compressedStr;
+        }
+        return decompressed;
+    }
+
+    /**
+     * 将list转为字符串，用逗号隔开
+     *
+     * @param list
+     * @return
+     */
+    public static String listTransToStr(List<String> list) {
+        if (CollectionUtils.isEmpty(list)) return null;
+        StringBuilder sb = new StringBuilder();
+        list.forEach(x -> {
+            sb.append(x);
+            sb.append(",");
+        });
+        String str = sb.toString();
+        return str.substring(0, str.length() - 1);
+    }
+
+    /**
+     * 是否包含中英文
+     *
+     * @param str
+     * @return
+     */
+    public static boolean checkCnAndEn(String str) {
+        String regEx = Constant.CHI_EN_REGEXP;
+        Pattern p = Pattern.compile(regEx);
+        Matcher m = p.matcher(str);
+        return m.find();
+    }
+
+
+    /**
+     * @param code 要隐藏显示的字符串
+     * @param head 前面保留的位数
+     * @param tail 后面保留的位数
+     * @return 处理后的字符串
+     */
+    public static String getEncryptCode(String code, int head, int tail) {
+        int body = code.length() - head - tail;
+        String regexVar = "(\\w{%d})(\\w{%d})(\\w{%d})";
+        String regex = String.format(regexVar, head, body, tail);
+        String bodyPart = code.replaceAll(regex, "$2");
+        String bodyEncrypt = bodyPart.replaceAll("\\w", "*");
+        String replacement = String.format("$1%s$3", bodyEncrypt);
+        return code.replaceAll(regex, replacement);
+    }
+}
+package com.canrd.shop.common.utils;
+
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ *
+ * 消息模板占位符替换工具
+ *
+ * @author fanzhenyu
+ * @date 2022-04-20
+ */
+public class TemplateFormatUtils {
+
+
+    /**
+     * 正则 匹配 { + "多个任意字符" + }
+     */
+    private static final String DEFAULT_REG = "\\{[\\w]+\\}";
+
+    /**
+     *
+     * @param text 原模板 占位符格式必须为:{fieldName}
+     * @param map 模板参数
+     * @return
+     */
+    public static String replaceTemplateContent(String text, Map<String, String> map){
+        return replaceTemplateContent(text,map,DEFAULT_REG);
+    }
+
+    /**
+     *
+     * @param text 原模板 占位符格式必须为:{fieldName}
+     * @param map 模板参数
+     * @param reg 自定义占位符样式 - 正则匹配
+     * @return
+     */
+    public static String replaceTemplateContent(String text,Map<String,String> map,String reg){
+
+        if(StringUtils.isBlank(reg)){
+            reg = DEFAULT_REG;
+        }
+
+        Pattern pattern = Pattern.compile(reg);
+        Matcher m = pattern.matcher(text);
+        while(m.find()){
+            String currentGroup = m.group();
+            String currentPattern = currentGroup.replaceAll("^\\{", "").replaceAll("\\}$", "").trim();
+            String mapValue = map.get(currentPattern);
+            if (mapValue != null){
+                text = text.replace(currentGroup, mapValue);
+            }
+        }
+        return text;
+    }
+}
+package com.canrd.shop.common.utils;
+
+
+import com.canrd.shop.common.exception.BadRequestException;
+
+import javax.validation.ConstraintViolationException;
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+/**
+ * 异常工具 2019-01-06
+ */
+public class ThrowableUtil {
+
+    /**
+     * 获取堆栈信息
+     */
+    public static String getStackTrace(Throwable throwable) {
+        StringWriter sw = new StringWriter();
+        try (PrintWriter pw = new PrintWriter(sw)) {
+            throwable.printStackTrace(pw);
+            return sw.toString();
+        }
+    }
+
+    public static void throwForeignKeyException(Throwable e, String msg) {
+        Throwable t = e.getCause();
+        while ((t != null) && !(t instanceof ConstraintViolationException)) {
+            t = t.getCause();
+        }
+        if (t != null) {
+            throw new BadRequestException(msg);
+        }
+        assert false;
+        throw new BadRequestException("删除失败：" + t.getMessage());
+    }
+}
+package com.canrd.shop.common.utils;
+
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.function.Supplier;
+
+/**
+ * @author:
+ * @date: 2021/12/21
+ */
+@Component
+public class TransactionHelper {
+
+    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
+    public <T> T run(Supplier<T> command) {
+        return command.get();
+    }
+
+    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
+    public void run(Runnable command) {
+        command.run();
+    }
+
+
+}
+package com.canrd.shop.config;
+
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class MybatisPlusConfig {
+
+}
+package com.canrd.shop.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.ClientHttpRequestFactory;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.web.client.RestTemplate;
+
+
+@Configuration
+public class RestTemplateConfig {
+
+    @Bean
+    public RestTemplate restTemplate(ClientHttpRequestFactory factory) {
+        return new RestTemplate(factory);
+    }
+
+    @Bean
+    public ClientHttpRequestFactory simpleClientHttpRequestFactory() {
+        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
+        factory.setReadTimeout(3000);
+        factory.setConnectTimeout(5000);
+        return factory;
+    }
+
+}
+package com.canrd.shop.config;
+
+import com.alibaba.fastjson.support.config.FastJsonConfig;
+import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.MediaType;
+import org.springframework.http.converter.HttpMessageConverter;
+import org.springframework.http.converter.StringHttpMessageConverter;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+
+@Slf4j
+@Configuration
+public class WebConfig implements WebMvcConfigurer {
+
+
+    @Override
+    public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
+        FastJsonHttpMessageConverter fastConverter = getFastJsonHttpMessageConverter();
+
+        StringHttpMessageConverter stringHttpMessageConverter = getStringHttpMessageConverter();
+
+        /**
+         * 添加StringHttpMessageConverter ，让其转化String。注意顺序，StringHttpMessageConverter 要在FastJsonHttpMessageConverter 之前。
+         *
+         * https://www.cnblogs.com/slankka/p/11437034.html
+         */
+        converters.add(0, fastConverter);
+        converters.add(0, stringHttpMessageConverter);
+        log.info("HttpMessageConverter顺序\n{}", converters.stream().map(c -> c.getClass().getName()).collect(Collectors.joining("\n")));
+    }
+
+    private static StringHttpMessageConverter getStringHttpMessageConverter() {
+        StringHttpMessageConverter stringHttpMessageConverter = new StringHttpMessageConverter();
+        stringHttpMessageConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));
+        return stringHttpMessageConverter;
+    }
+
+    private static FastJsonHttpMessageConverter getFastJsonHttpMessageConverter() {
+        FastJsonConfig fastJsonConfig = new FastJsonConfig();
+        //解决空值序列化的问题,改为不序列化
+        /*fastJsonConfig.setSerializeFilters(new PropertyFilter() {
+            @Override
+            public boolean apply(Object source,String name, Object value) {
+                //if(value.getClass().isPrimitive() == null){
+                if(value == null){
+                    return false;
+                }
+                return true;
+            }
+        });*/
+        fastJsonConfig.setCharset(StandardCharsets.UTF_8);
+        FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
+        List<MediaType> supportedMediaTypes = new ArrayList<>();
+        supportedMediaTypes.add(MediaType.APPLICATION_JSON);
+        supportedMediaTypes.add(MediaType.APPLICATION_JSON_UTF8);
+        supportedMediaTypes.add(MediaType.APPLICATION_ATOM_XML);
+//        supportedMediaTypes.add(MediaType.APPLICATION_FORM_URLENCODED);
+        supportedMediaTypes.add(MediaType.APPLICATION_OCTET_STREAM);
+        supportedMediaTypes.add(MediaType.APPLICATION_PDF);
+        supportedMediaTypes.add(MediaType.APPLICATION_RSS_XML);
+        supportedMediaTypes.add(MediaType.APPLICATION_XHTML_XML);
+//        supportedMediaTypes.add(MediaType.APPLICATION_XML);
+        supportedMediaTypes.add(MediaType.IMAGE_GIF);
+        supportedMediaTypes.add(MediaType.IMAGE_JPEG);
+        supportedMediaTypes.add(MediaType.IMAGE_PNG);
+        supportedMediaTypes.add(MediaType.TEXT_EVENT_STREAM);
+        supportedMediaTypes.add(MediaType.TEXT_HTML);
+        supportedMediaTypes.add(MediaType.TEXT_MARKDOWN);
+        supportedMediaTypes.add(MediaType.TEXT_PLAIN);
+//        supportedMediaTypes.add(MediaType.TEXT_XML);
+        fastConverter.setSupportedMediaTypes(supportedMediaTypes);
+        fastConverter.setFastJsonConfig(fastJsonConfig);
+        fastConverter.setDefaultCharset(StandardCharsets.UTF_8);
+        return fastConverter;
+    }
+}
+package com.canrd.shop.controller;
+
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.common.jsr303.OperateGroup;
+import com.canrd.shop.module.vo.ProductQueryVO;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * (Product)表控制层
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:33
+ */
+@RestController
+@RequestMapping("/canrd/job")
+public class HelloController {
+
+    /**
+     * 分页查询
+     *
+     * @param productQueryVO 查询条件
+     * @return 查询结果
+     */
+    @PostMapping("/list")
+    public ServerResult hello(@RequestBody @Validated({OperateGroup.List.class}) ProductQueryVO productQueryVO) {
+        return ServerResult.success("hello world!");
+    }
+
+}
+
+package com.canrd.shop.job;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.canrd.shop.common.constant.Constant;
+import com.canrd.shop.module.dto.OrdersDO;
+import com.canrd.shop.service.OrdersService;
+import lombok.extern.slf4j.Slf4j;
+import org.joda.time.DateTime;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * @author: xms
+ * @description: TODO
+ * @date: 2023/6/25 10:35
+ * @version: 1.0
+ */
+@Slf4j
+@Component
+public class OrderOverTimeJob {
+
+    @Resource
+    private OrdersService ordersService;
+
+    /**
+     * 每隔5分执行一次
+     */
+    @Scheduled(cron = "0 */5 * * * ?")
+//    @Scheduled(cron = "*/5 * * * * ?")
+    public void payOverTimeExecute() {
+        log.info("执行开始时间：{}", DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
+        LambdaQueryWrapper<OrdersDO> queryWrapper = new LambdaQueryWrapper<OrdersDO>()
+                .in(OrdersDO::getPaymentstatus, Arrays.asList(0, 1));
+        List<OrdersDO> ordersDOS = ordersService.list(queryWrapper);
+
+        if (!CollectionUtils.isEmpty(ordersDOS)) {
+            List<OrdersDO> updateOrdersList = new ArrayList<>();
+            ordersDOS.forEach(ordersDO -> {
+                DateTime createTime = new DateTime(ordersDO.getCreatedate());
+                if (DateTime.now().isAfter(createTime.plusDays(Constant.ONE))) {
+                    ordersDO.setOrderstatus(-1);
+                    ordersDO.setPaymentstatus(-1);
+                    ordersDO.setModifydate(DateTime.now().toDate());
+                    updateOrdersList.add(ordersDO);
+                }
+
+            });
+            if (!CollectionUtils.isEmpty(updateOrdersList)) {
+                ordersService.updateBatchById(ordersDOS);
+            }
+
+        }
+        log.info("执行结束时间：{}", DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
+    }
+
+}
+package com.canrd.shop.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.canrd.shop.module.dto.OrdersDO;
+
+/**
+ * (Orders)表数据库访问层
+ *
+ * @author makejava
+ * @since 2023-06-25 10:43:07
+ */
+public interface OrdersMapper extends BaseMapper<OrdersDO> {
+
+
+}
+
+package com.canrd.shop.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.canrd.shop.module.dto.ProductDO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * (Product)表数据库访问层
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:34
+ */
+@Mapper
+public interface ProductMapper extends BaseMapper<ProductDO> {
+
+
+}
+
+package com.canrd.shop.module.dto;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * (Orders)实体类
+ *
+ * @author makejava
+ * @since 2023-06-25 10:42:58
+ */
+@TableName("orders")
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class OrdersDO implements Serializable {
+    private static final long serialVersionUID = -34170173982796273L;
+
+    private String id;
+
+    private Date createdate;
+
+    private Date modifydate;
+
+    private Double deliveryfee;
+
+    private String deliverytypename;
+
+    private String memo;
+
+    private String ordersn;
+
+    private Integer orderstatus;
+
+    private Double paidamount;
+
+    private String paymentconfigname;
+
+    private Double paymentfee;
+
+    private Integer paymentstatus;
+
+    private Double producttotalprice;
+
+    private Integer producttotalquantity;
+
+    private Double productweight;
+
+    private Integer productweightunit;
+
+    private String shipaddress;
+
+    private String shiparea;
+
+    private String shipareapath;
+
+    private String shipmobile;
+
+    private String shipname;
+
+    private String shipphone;
+
+    private String shipzipcode;
+
+    private String invoice;
+
+    private String tax;
+
+    private String invoiceId;
+
+    private String invoiceType;
+
+    private Integer shippingstatus;
+
+    private Double totalamount;
+
+    private String memberId;
+
+    private String deliverytypeId;
+
+    private String paymentconfigId;
+
+    private String school;
+
+    private String college;
+
+    private String teacher;
+
+    private String teacherphone;
+
+}
+package com.canrd.shop.module.dto;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * (Product)实体类
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:32
+ */
+@TableName("product")
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class ProductDO implements Serializable {
+
+    private String id;
+
+    private Date createdate;
+
+    private Date modifydate;
+
+    private String description;
+
+    private Integer freezestore;
+
+    private String htmlfilepath;
+
+    private Byte isbest;
+
+    private Byte ishot;
+    /**
+     * 是否上架
+     */
+    private Byte ismarketable;
+
+    private Byte isnew;
+
+    private Double marketprice;
+
+    private String metadescription;
+
+    private String metakeywords;
+
+    private String name;
+
+    private String englishname;
+
+    private String model;
+
+    private String exterior;
+
+    private String basecore1;
+
+    private String basename2;
+
+    private String basecore2;
+
+    private String basename3;
+
+    private String basecore3;
+
+    private String basename4;
+
+    private String basecore4;
+
+    private String basename5;
+
+    private String basecore5;
+
+    private String basename6;
+
+    private String basecore6;
+
+    private String basename7;
+
+    private String basecore7;
+
+    private String basename8;
+
+    private String basecore8;
+
+    private String basename1;
+
+    private Integer point;
+
+    private Double price;
+
+    private String productimageliststore;
+
+    private String productsn;
+
+    private Integer store;
+
+    private Double weight;
+
+    private Integer weightunit;
+
+    private String brandId;
+
+    private String productcategoryId;
+
+    private String productcategoryName;
+
+    private String producttypeId;
+
+    private String producttypeName;
+
+    private String introduction;
+
+    private String storage;
+
+    private String physicalproperty;
+
+    private String advantage;
+
+    private String wiki;
+
+}
+package com.canrd.shop.module.vo;
+
+import com.canrd.shop.common.constant.Constant;
+import com.canrd.shop.common.jsr303.OperateGroup;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+import javax.validation.constraints.NotNull;
+
+
+@SuperBuilder(toBuilder = true)
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class BasePageVO {
+
+    /**
+     * 页码
+     */
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    @NotNull(message = "页码不能为空", groups = {OperateGroup.List.class})
+    @Min(value = Constant.ONE, message = "页码不能小于1", groups = {OperateGroup.List.class})
+    private Integer pageNo = 1;
+    /**
+     * 页
+     */
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    @NotNull(message = "每页大小不能为空", groups = {OperateGroup.List.class})
+    @Min(value = 1, message = "每页大小不能小于1", groups = {OperateGroup.List.class})
+    @Max(value = 5000, message = "每页大小不能大于5000", groups = {OperateGroup.List.class})
+    private Integer pageSize = 10;
+
+    /**
+     * 总数
+     */
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    private Integer total;
+}
+package com.canrd.shop.module.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * (Orders)实体类
+ *
+ * @author makejava
+ * @since 2023-06-25 10:43:07
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class OrdersQueryVO extends BasePageVO implements Serializable {
+
+    private List<Long> ids;
+
+
+    private String id;
+
+    private Date createdate;
+
+    private Date modifydate;
+
+    private Double deliveryfee;
+
+    private String deliverytypename;
+
+    private String memo;
+
+    private String ordersn;
+
+    private Integer orderstatus;
+
+    private Double paidamount;
+
+    private String paymentconfigname;
+
+    private Double paymentfee;
+
+    private Integer paymentstatus;
+
+    private Double producttotalprice;
+
+    private Integer producttotalquantity;
+
+    private Double productweight;
+
+    private Integer productweightunit;
+
+    private String shipaddress;
+
+    private String shiparea;
+
+    private String shipareapath;
+
+    private String shipmobile;
+
+    private String shipname;
+
+    private String shipphone;
+
+    private String shipzipcode;
+
+    private String invoice;
+
+    private String tax;
+
+    private String invoiceId;
+
+    private String invoiceType;
+
+    private Integer shippingstatus;
+
+    private Double totalamount;
+
+    private String memberId;
+
+    private String deliverytypeId;
+
+    private String paymentconfigId;
+
+    private String school;
+
+    private String college;
+
+    private String teacher;
+
+    private String teacherphone;
+
+
+}
+
+package com.canrd.shop.module.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * (Orders)实体类
+ *
+ * @author makejava
+ * @since 2023-06-25 10:43:04
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class OrdersVO implements Serializable {
+    private static final long serialVersionUID = -82673229208636654L;
+
+    private String id;
+
+    private Date createdate;
+
+    private Date modifydate;
+
+    private Double deliveryfee;
+
+    private String deliverytypename;
+
+    private String memo;
+
+    private String ordersn;
+
+    private Integer orderstatus;
+
+    private Double paidamount;
+
+    private String paymentconfigname;
+
+    private Double paymentfee;
+
+    private Integer paymentstatus;
+
+    private Double producttotalprice;
+
+    private Integer producttotalquantity;
+
+    private Double productweight;
+
+    private Integer productweightunit;
+
+    private String shipaddress;
+
+    private String shiparea;
+
+    private String shipareapath;
+
+    private String shipmobile;
+
+    private String shipname;
+
+    private String shipphone;
+
+    private String shipzipcode;
+
+    private String invoice;
+
+    private String tax;
+
+    private String invoiceId;
+
+    private String invoiceType;
+
+    private Integer shippingstatus;
+
+    private Double totalamount;
+
+    private String memberId;
+
+    private String deliverytypeId;
+
+    private String paymentconfigId;
+
+    private String school;
+
+    private String college;
+
+    private String teacher;
+
+    private String teacherphone;
+
+
+}
+package com.canrd.shop.module.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * (Product)实体类
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:33
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class ProductQueryVO extends BasePageVO implements Serializable {
+    private static final long serialVersionUID = 108846000631816096L;
+
+    private List<Long> ids;
+
+
+    private String id;
+
+
+}
+
+package com.canrd.shop.module.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * (Product)实体类
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:33
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class ProductVO implements Serializable {
+    private static final long serialVersionUID = -82998374747158271L;
+
+    private String id;
+
+    private Date createdate;
+
+    private Date modifydate;
+
+    private String description;
+
+    private Integer freezestore;
+
+    private String htmlfilepath;
+
+    private Byte isbest;
+
+    private Byte ishot;
+    /**
+     * 是否上架
+     */
+    private Byte ismarketable;
+
+    private Byte isnew;
+
+    private Double marketprice;
+
+    private String metadescription;
+
+    private String metakeywords;
+
+    private String name;
+
+    private String englishname;
+
+    private String model;
+
+    private String exterior;
+
+    private String basecore1;
+
+    private String basename2;
+
+    private String basecore2;
+
+    private String basename3;
+
+    private String basecore3;
+
+    private String basename4;
+
+    private String basecore4;
+
+    private String basename5;
+
+    private String basecore5;
+
+    private String basename6;
+
+    private String basecore6;
+
+    private String basename7;
+
+    private String basecore7;
+
+    private String basename8;
+
+    private String basecore8;
+
+    private String basename1;
+
+    private Integer point;
+
+    private Double price;
+
+    private String productimageliststore;
+
+    private String productsn;
+
+    private Integer store;
+
+    private Double weight;
+
+    private Integer weightunit;
+
+    private String brandId;
+
+    private String productcategoryId;
+
+    private String productcategoryName;
+
+    private String producttypeId;
+
+    private String producttypeName;
+
+    private String introduction;
+
+    private String storage;
+
+    private String physicalproperty;
+
+    private String advantage;
+
+    private String wiki;
+
+
+}
+package com.canrd.shop.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.module.dto.OrdersDO;
+import com.canrd.shop.module.vo.OrdersQueryVO;
+import com.canrd.shop.module.vo.OrdersVO;
+
+/**
+ * (Orders)表服务接口
+ *
+ * @author makejava
+ * @since 2023-06-25 10:43:08
+ */
+public interface OrdersService extends IService<OrdersDO> {
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param ordersQueryVO 主键
+     * @return 实例对象
+     */
+    ServerResult queryById(OrdersQueryVO ordersQueryVO);
+
+    /**
+     * 分页查询
+     *
+     * @param ordersQueryVO 筛选条件
+     * @return 查询结果
+     */
+    ServerResult list(OrdersQueryVO ordersQueryVO);
+
+    /**
+     * 新增数据
+     *
+     * @param ordersVO 数据VO
+     * @return 新增结果
+     */
+    ServerResult add(OrdersVO ordersVO);
+
+    /**
+     * 修改数据
+     *
+     * @param ordersVO 数据VO
+     * @return 编辑结果
+     */
+    ServerResult edit(OrdersVO ordersVO);
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param ordersQueryVO 筛选条件
+     * @return 是否成功
+     */
+    ServerResult deleteById(OrdersQueryVO ordersQueryVO);
+
+}
+package com.canrd.shop.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.module.dto.ProductDO;
+import com.canrd.shop.module.vo.ProductQueryVO;
+import com.canrd.shop.module.vo.ProductVO;
+
+/**
+ * (Product)表服务接口
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:34
+ */
+public interface ProductService extends IService<ProductDO> {
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param productQueryVO 主键
+     * @return 实例对象
+     */
+    ServerResult queryById(ProductQueryVO productQueryVO);
+
+    /**
+     * 分页查询
+     *
+     * @param productQueryVO 筛选条件
+     * @return 查询结果
+     */
+    ServerResult list(ProductQueryVO productQueryVO);
+
+    /**
+     * 新增数据
+     *
+     * @param productVO 数据VO
+     * @return 新增结果
+     */
+    ServerResult add(ProductVO productVO);
+
+    /**
+     * 修改数据
+     *
+     * @param productVO 数据VO
+     * @return 编辑结果
+     */
+    ServerResult edit(ProductVO productVO);
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param productQueryVO 筛选条件
+     * @return 是否成功
+     */
+    ServerResult deleteById(ProductQueryVO productQueryVO);
+
+}
+package com.canrd.shop.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.mapper.OrdersMapper;
+import com.canrd.shop.module.dto.OrdersDO;
+import com.canrd.shop.module.vo.OrdersQueryVO;
+import com.canrd.shop.module.vo.OrdersVO;
+import com.canrd.shop.service.OrdersService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+/**
+ * (Orders)表服务实现类
+ *
+ * @author makejava
+ * @since 2023-06-25 10:43:09
+ */
+@Slf4j
+@Service
+public class OrdersServiceImpl extends ServiceImpl<OrdersMapper, OrdersDO> implements OrdersService {
+
+
+    /**
+     * 通过ID查询单条数据
+     * <p>
+     * ordersQueryVO 主键
+     *
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult queryById(OrdersQueryVO ordersQueryVO) {
+        if (Objects.isNull(ordersQueryVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        OrdersDO OrdersDo = getById(ordersQueryVO.getId());
+        if (Objects.isNull(OrdersDo)) {
+            return ServerResult.success(null);
+        }
+        return ServerResult.success(BeanUtil.copyProperties(OrdersDo, OrdersVO.class));
+    }
+
+    /**
+     * 分页查询
+     *
+     * @param ordersQueryVO 筛选条件
+     * @return 查询结果
+     */
+    @Override
+    public ServerResult list(OrdersQueryVO ordersQueryVO) {
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 新增数据
+     *
+     * @param ordersVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult add(OrdersVO ordersVO) {
+        //todo 校验
+        if (Objects.nonNull(ordersVO.getId())) {
+            ordersVO.setId(null);
+        }
+        OrdersDO ordersDo = BeanUtil.copyProperties(ordersVO, OrdersDO.class);
+
+        save(ordersDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 修改数据
+     *
+     * @param ordersVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult edit(OrdersVO ordersVO) {
+        //todo 校验
+        if (Objects.isNull(ordersVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        OrdersDO ordersDo = BeanUtil.copyProperties(ordersVO, OrdersDO.class);
+
+        updateById(ordersDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param ordersQueryVO 筛选条件
+     * @return 是否成功
+     */
+    @Override
+    public ServerResult deleteById(OrdersQueryVO ordersQueryVO) {
+        return ServerResult.success();
+    }
+}
+package com.canrd.shop.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.canrd.shop.common.constant.ServerResult;
+import com.canrd.shop.common.utils.PageUtils;
+import com.canrd.shop.mapper.ProductMapper;
+import com.canrd.shop.module.dto.ProductDO;
+import com.canrd.shop.module.vo.ProductQueryVO;
+import com.canrd.shop.module.vo.ProductVO;
+import com.canrd.shop.service.ProductService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * (Product)表服务实现类
+ *
+ * @author makejava
+ * @since 2023-05-29 11:43:35
+ */
+@Slf4j
+@Service
+public class ProductServiceImpl extends ServiceImpl<ProductMapper, ProductDO> implements ProductService {
+
+
+    /**
+     * 通过ID查询单条数据
+     * <p>
+     * productQueryVO 主键
+     *
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult queryById(ProductQueryVO productQueryVO) {
+        if (Objects.isNull(productQueryVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        ProductDO ProductDo = getById(productQueryVO.getId());
+        if (Objects.isNull(ProductDo)) {
+            return ServerResult.success(null);
+        }
+        return ServerResult.success(BeanUtil.copyProperties(ProductDo, ProductVO.class));
+    }
+
+    /**
+     * 分页查询
+     *
+     * @param productQueryVO 筛选条件
+     * @return 查询结果
+     */
+    @Override
+    public ServerResult list(ProductQueryVO productQueryVO) {
+
+        LambdaQueryWrapper<ProductDO> queryWapper = new LambdaQueryWrapper<ProductDO>()
+                .orderByDesc(ProductDO::getId);
+        Page page = new Page<>(productQueryVO.getPageNo(), productQueryVO.getPageSize());
+        IPage<ProductDO> iPage = page(page, queryWapper);
+        productQueryVO.setTotal(Long.valueOf(iPage.getTotal()).intValue());
+
+        return ServerResult.success(PageUtils.getPageReturn(iPage.getRecords(), productQueryVO));
+    }
+
+    /**
+     * 新增数据
+     *
+     * @param productVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult add(ProductVO productVO) {
+        //todo 校验
+        if (Objects.nonNull(productVO.getId())) {
+            productVO.setId(null);
+        }
+        ProductDO productDo = BeanUtil.copyProperties(productVO, ProductDO.class);
+
+        save(productDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 修改数据
+     *
+     * @param productVO 实例对象
+     * @return 实例对象
+     */
+    @Override
+    public ServerResult edit(ProductVO productVO) {
+        //todo 校验
+        if (Objects.isNull(productVO.getId())) {
+            return ServerResult.fail("id 不能为空");
+        }
+        ProductDO productDo = BeanUtil.copyProperties(productVO, ProductDO.class);
+
+        updateById(productDo);
+
+        return ServerResult.success();
+    }
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param productQueryVO 筛选条件
+     * @return 是否成功
+     */
+    @Override
+    public ServerResult deleteById(ProductQueryVO productQueryVO) {
+        List<Long> ids = productQueryVO.getIds();
+        if (CollUtil.isEmpty(ids)) {
+            return ServerResult.fail("ids 参数不能为空");
+        }
+        List<ProductDO> productList = listByIds(ids);
+        if (CollUtil.isEmpty(productList)) {
+            return ServerResult.success();
+        }
+        //todo 校验是否可以逻辑删除
+        LambdaUpdateWrapper<ProductDO> updateWrapper = new LambdaUpdateWrapper<ProductDO>()
+                .in(ProductDO::getId, ids);
+        update(updateWrapper);
+        return ServerResult.success();
+    }
+}
+mybatis-plus:
+  configuration:
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: 'null'
+    map-underscore-to-camel-case: true
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      capital-mode: false
+      field-strategy: NOT_NULL
+      id-type: AUTO
+      logic-delete-field: enable_flag
+      logic-delete-value: 20
+      logic-not-delete-value: 10
+  mapper-locations: classpath:/mapper/**.xml
+  type-aliases-package: com.canrd.shop.**.dto
+#spring:
+#  datasource:
+#    dynamic:
+#      primary: overtime #设置默认的数据源或者数据源组,默认值即为master
+#      strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
+#      datasource:
+#        wms_warehouse:
+#          url: jdbc:mysql://127.0.0.1:3306/overtime?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true&rewriteBatchedStatements=true
+#          username: root
+#          password: root
+#          driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
+#          druid:
+#            initial-size: 5
+#            max-active: 20
+#            max-evictable-idle-time-millis: 300000
+#            max-wait: 60000
+#            min-evictable-idle-time-millis: 300000
+#            min-idle: 5
+#            time-between-eviction-runs-millis: 60000
+#    type: com.alibaba.druid.pool.DruidDataSource
+spring:
+  servlet:
+    multipart:
+      enabled: true
+      max-file-size: 100MB
+      max-request-size: 20MB
+      file-size-threshold: 20MB
+  datasource:
+    db-type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    initial-size: 5
+    max-active: 30
+    max-wait: 30000
+    min-idle: 5
+    #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
+    timeBetweenEvictionRunsMillis: 30000
+    #配置一个连接在池中最小生存的时间，单位是毫秒，30000=30s
+    minEvictableIdleTimeMillis: 30000
+    validationQuery: SELECT 'x'
+    testWhileIdle: true
+    testOnBorrow: true
+    testOnReturn: true
+    password: 123456
+    time-between-eviction-runs-millis: 1000
+    url: jdbc:mysql://39.108.227.113:3306/jfinalshop?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true
+    username: root
+
+
+logging:
+  config: classpath:log4j2-dev.xml
 \ No newline at end of file
+mybatis-plus:
+  configuration:
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: 'null'
+    map-underscore-to-camel-case: true
+    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
+  global-config:
+    db-config:
+      capital-mode: false
+      field-strategy: NOT_NULL
+      id-type: AUTO
+      logic-delete-field: enable_flag
+      logic-delete-value: 20
+      logic-not-delete-value: 10
+  mapper-locations: classpath:/mapper/**.xml
+  type-aliases-package: com.canrd.shop.**.dto
+#spring:
+#  datasource:
+#    dynamic:
+#      primary: overtime #设置默认的数据源或者数据源组,默认值即为master
+#      strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
+#      datasource:
+#        wms_warehouse:
+#          url: jdbc:mysql://127.0.0.1:3306/overtime?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true&rewriteBatchedStatements=true
+#          username: root
+#          password: root
+#          driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
+#          druid:
+#            initial-size: 5
+#            max-active: 20
+#            max-evictable-idle-time-millis: 300000
+#            max-wait: 60000
+#            min-evictable-idle-time-millis: 300000
+#            min-idle: 5
+#            time-between-eviction-runs-millis: 60000
+#    type: com.alibaba.druid.pool.DruidDataSource
+spring:
+  servlet:
+    multipart:
+      enabled: true
+      max-file-size: 100MB
+      max-request-size: 20MB
+      file-size-threshold: 20MB
+  datasource:
+    db-type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    initial-size: 5
+    max-active: 30
+    max-wait: 30000
+    min-idle: 5
+    #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
+    timeBetweenEvictionRunsMillis: 30000
+    #配置一个连接在池中最小生存的时间，单位是毫秒，30000=30s
+    minEvictableIdleTimeMillis: 30000
+    validationQuery: SELECT 'x'
+    testWhileIdle: true
+    testOnBorrow: true
+    testOnReturn: true
+    password: 123456
+    time-between-eviction-runs-millis: 1000
+    url: jdbc:mysql://39.108.227.113:3306/jfinalshop?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true
+    username: root
+
+
+logging:
+  config: classpath:log4j2-prod.xml
+mybatis-plus:
+  configuration:
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: 'null'
+    map-underscore-to-camel-case: true
+    log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl
+  global-config:
+    db-config:
+      capital-mode: false
+      field-strategy: NOT_NULL
+      id-type: AUTO
+      logic-delete-field: enable_flag
+      logic-delete-value: 20
+      logic-not-delete-value: 10
+  mapper-locations: classpath:/mapper/**.xml
+  type-aliases-package: com.canrd.shop.**.dto
+#spring:
+#  datasource:
+#    dynamic:
+#      primary: overtime #设置默认的数据源或者数据源组,默认值即为master
+#      strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
+#      datasource:
+#        wms_warehouse:
+#          url: jdbc:mysql://127.0.0.1:3306/overtime?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true&rewriteBatchedStatements=true
+#          username: root
+#          password: root
+#          driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
+#          druid:
+#            initial-size: 5
+#            max-active: 20
+#            max-evictable-idle-time-millis: 300000
+#            max-wait: 60000
+#            min-evictable-idle-time-millis: 300000
+#            min-idle: 5
+#            time-between-eviction-runs-millis: 60000
+#    type: com.alibaba.druid.pool.DruidDataSource
+spring:
+  servlet:
+    multipart:
+      enabled: true
+      max-file-size: 100MB
+      max-request-size: 20MB
+      file-size-threshold: 20MB
+  datasource:
+    db-type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    initial-size: 5
+    max-active: 30
+    max-wait: 30000
+    min-idle: 5
+    #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
+    timeBetweenEvictionRunsMillis: 30000
+    #配置一个连接在池中最小生存的时间，单位是毫秒，30000=30s
+    minEvictableIdleTimeMillis: 30000
+    validationQuery: SELECT 'x'
+    testWhileIdle: true
+    testOnBorrow: true
+    testOnReturn: true
+    password: 123456
+    time-between-eviction-runs-millis: 1000
+    url: jdbc:mysql://39.108.227.113:3306/jfinalshop?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai&useSSL=false&autoReconnect=true&failOverReadOnly=false&maxReconnects=10&allowMultiQueries=true&useAffectedRows=true&autoReconnectForPools=true
+    username: root
+
+
+logging:
+  config: classpath:log4j2-dev.xml
 \ No newline at end of file
+server:
+  port: 9000
+
+spring:
+  # 不占用端口启动
+  main:
+    allow-bean-definition-overriding: true
+    web-application-type: none
+  profiles:
+    active: local
 \ No newline at end of file
+<?xml version="1.0" encoding="UTF-8"?>
+<!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
+<!--Configuration后面的status，这个用于设置log4j2自身内部的信息输出，可以不设置，当设置成trace时，你会看到log4j2内部各种详细输出 -->
+<!--monitorInterval：Log4j能够自动检测修改配置 文件和重新配置本身，设置间隔秒数 -->
+<configuration status="debug" monitorInterval="30">
+    <!--<contextName>log4j2</contextName>-->
+    <properties>
+        <!--${sys:catalina.home}表示linux中环境变量中的tomcat根目录 用户主目录-->
+        <!--原来用logback时候在统一配置中心也配置一个logging.path=/opt/tomcat-log/${spring.application.name}   LOG_PATH是内置变量-->
+        <!--${sys:user.home}  用户主目录-->
+       <!-- <Property name="log_path">${sys:user.home}/logs</Property>-->
+<!--        <Property name="log_path" value="./logs/" />-->
+        <property name="console_log_pattern">%d|%t|%traceId|%-5level|%F:%L|%M|%m%n</property>
+        <!-- 保留日志天数 D H M S 分别对应天 小时 分钟 秒 -->
+        <property name="KEEP_LOG_DAY">60D</property>
+        <!-- 日志切割的最小单位 -->
+        <property name="EVERY_FILE_SIZE">100M</property>
+    </properties>
+    <!--先定义所有的appender -->
+    <appenders>
+        <console name="Console" target="SYSTEM_OUT">
+            <!--输出日志的格式 -->
+            <PatternLayout  charset="UTF-8" pattern="${console_log_pattern}"/>
+            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY" />
+        </console>
+        <!--这个输出控制台的配置 -->
+        <!--<console name="Console" target="SYSTEM_OUT" follow="false">-->
+        <!--&lt;!&ndash;输出日志的格式 &ndash;&gt;-->
+        <!--<PatternLayout pattern="%date{yyyy-MM-dd HH:mm:ss.SSS} %level [%thread][%file:%line] - %msg%n" />-->
+        <!--</console>-->
+
+        <!-- 这个会打印出所有的info及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档 -->
+        <RollingFile name="RollingFileInfo" fileName="${sys:logging.path}/logs/overtime.log" filePattern="${sys:logging.path}/logs/$${date:yyyy-MM-dd}/info-%d{yyyy-MM-dd}-%i.log">
+            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch） -->
+            <ThresholdFilter level="debug" onMatch="ACCEPT" onMismatch="DENY" />
+            <!--<Filters>-->
+            <!--<ThresholdFilter level="INFO"/>-->
+            <!--<ThresholdFilter level="WARN" onMatch="DENY"-->
+            <!--onMismatch="NEUTRAL"/>-->
+            <!--</Filters>-->
+            <PatternLayout  charset="UTF-8" pattern="${console_log_pattern}"/>
+            <Policies>
+                <!-- 归档每天的文件 -->
+                <!--<TimeBasedTriggeringPolicy interval="1" modulate="true"/>-->
+                <TimeBasedTriggeringPolicy />
+                <!-- 限制单个文件大小 -->
+                <SizeBasedTriggeringPolicy size="${EVERY_FILE_SIZE}"/>
+            </Policies>
+            <!-- 限制每天文件个数 --> <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件，这里设置了100 -->
+            <DefaultRolloverStrategy  max="256">
+                <Delete basePath="${sys:logging.path}/logs/" maxDepth="3">
+                    <IfFileName glob="*/*info*.log"/>
+                    <IfLastModified age="${KEEP_LOG_DAY}"/>
+                </Delete>
+            </DefaultRolloverStrategy>
+        </RollingFile>
+    </appenders>
+    <!--然后定义logger，只有定义了logger并引入的appender，appender才会生效 -->
+    <loggers>
+        <!--过滤掉spring和mybatis的一些无用的DEBUG信息 -->
+        <logger name="org.springframework" level="debug" >
+            <ThresholdFilter level="debug"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+        <logger name="org.mybatis" level="DEBUG" >
+            <ThresholdFilter level="debug"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+        <logger name="com.canrd.shop" level="DEBUG" >
+            <ThresholdFilter level="debug"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+        <!--<root level="all">-->
+        <root level="debug">
+            <appender-ref ref="Console" />
+        </root>
+    </loggers>
+</configuration>
+<?xml version="1.0" encoding="UTF-8"?>
+<!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
+<!--Configuration后面的status，这个用于设置log4j2自身内部的信息输出，可以不设置，当设置成trace时，你会看到log4j2内部各种详细输出 -->
+<!--monitorInterval：Log4j能够自动检测修改配置 文件和重新配置本身，设置间隔秒数 -->
+<configuration status="INFO" monitorInterval="30">
+    <!--<contextName>log4j2</contextName>-->
+    <properties>
+        <!--${sys:catalina.home}表示linux中环境变量中的tomcat根目录 用户主目录-->
+        <!--原来用logback时候在统一配置中心也配置一个logging.path=/opt/tomcat-log/${spring.application.name}   LOG_PATH是内置变量-->
+        <!--${sys:user.home}  用户主目录-->
+       <!-- <Property name="log_path">${sys:user.home}/logs</Property>-->
+<!--        <Property name="log_path" value="./logs/" />-->
+        <property name="console_log_pattern">%d|%t|%traceId|%-5level|%F:%L|%M|%m%n</property>
+        <!-- 保留日志天数 D H M S 分别对应天 小时 分钟 秒 -->
+        <property name="KEEP_LOG_DAY">60D</property>
+        <!-- 日志切割的最小单位 -->
+        <property name="EVERY_FILE_SIZE">100M</property>
+    </properties>
+    <!--先定义所有的appender -->
+    <appenders>
+        <console name="Console" target="SYSTEM_OUT">
+            <!--输出日志的格式 -->
+            <PatternLayout  charset="UTF-8" pattern="${console_log_pattern}"/>
+            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY" />
+        </console>
+        <!--这个输出控制台的配置 -->
+        <!--<console name="Console" target="SYSTEM_OUT" follow="false">-->
+        <!--&lt;!&ndash;输出日志的格式 &ndash;&gt;-->
+        <!--<PatternLayout pattern="%date{yyyy-MM-dd HH:mm:ss.SSS} %level [%thread][%file:%line] - %msg%n" />-->
+        <!--</console>-->
+
+        <!-- 这个会打印出所有的info及以下级别的信息，每次大小超过size，则这size大小的日志会自动存入按年份-月份建立的文件夹下面并进行压缩，作为存档 -->
+        <RollingFile name="RollingFileInfo" fileName="${sys:logging.path}/logs/overtime.log" filePattern="${sys:logging.path}/logs/$${date:yyyy-MM-dd}/info-%d{yyyy-MM-dd}-%i.log">
+            <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch） -->
+            <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY" />
+            <!--<Filters>-->
+            <!--<ThresholdFilter level="INFO"/>-->
+            <!--<ThresholdFilter level="WARN" onMatch="DENY"-->
+            <!--onMismatch="NEUTRAL"/>-->
+            <!--</Filters>-->
+            <PatternLayout  charset="UTF-8" pattern="${console_log_pattern}"/>
+            <Policies>
+                <!-- 归档每天的文件 -->
+                <!--<TimeBasedTriggeringPolicy interval="1" modulate="true"/>-->
+                <TimeBasedTriggeringPolicy />
+                <!-- 限制单个文件大小 -->
+                <SizeBasedTriggeringPolicy size="${EVERY_FILE_SIZE}"/>
+            </Policies>
+            <!-- 限制每天文件个数 --> <!-- DefaultRolloverStrategy属性如不设置，则默认为最多同一文件夹下7个文件，这里设置了100 -->
+            <DefaultRolloverStrategy  max="256">
+                <Delete basePath="${sys:logging.path}/logs/" maxDepth="3">
+                    <IfFileName glob="*/*info*.log"/>
+                    <IfLastModified age="${KEEP_LOG_DAY}"/>
+                </Delete>
+            </DefaultRolloverStrategy>
+        </RollingFile>
+    </appenders>
+    <!--然后定义logger，只有定义了logger并引入的appender，appender才会生效 -->
+    <loggers>
+        <logger name="org.springframework" level="info" >
+            <ThresholdFilter level="info"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+        <logger name="org.mybatis" level="info" >
+            <ThresholdFilter level="info"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+        <logger name="com.canrd.shop" level="info" >
+            <ThresholdFilter level="info"/>
+            <appender-ref ref="RollingFileInfo" />
+        </logger>
+    </loggers>
+</configuration>
+package com.canrd.shop;
+
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * @author fanzhenyu
+ * @date 2023-01-15
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = JobApplication.class)
+//主动回滚测试产生的数据
+@Transactional
+public class BaseTest {
+
+
+}
+package com.canrd.shop.test;
+
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.junit.Test;
+
+/**
+ * @author: xms
+ * @description: TODO
+ * @date: 2023/2/10 14:09
+ * @version: 1.0
+ */
+public class DateTimeUtilTest {
+
+    @Test
+    public void test() {
+        DateTimeFormatter fmt = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm");
+        System.out.println(fmt.parseDateTime("2023-02-10 12:00").isBefore(fmt.parseDateTime("2023-02-10 13:30")));
+        System.out.println(fmt.parseDateTime("2023-02-10 12:00").isBeforeNow());
+    }
+}
@@ -11,6 +11,7 @@
     <modules>
         <module>admin</module>
         <module>shop</module>
+        <module>job</module>
     </modules>
  
     <parent>