apiRest = message(ex.getCode(), ex.getMsg(), null);
+ return apiRest;
+ }
+
+ /**
+ * 响应返回结果
+ *
+ * @param rows 影响行数
+ * @return 操作结果
+ */
+ protected AjaxResult toAjax(int rows) {
+ return rows > 0 ? AjaxResult.success() : AjaxResult.error();
+ }
+}
diff --git a/src/main/java/org/example/core/api/dto/BaseDTO.java b/src/main/java/org/example/core/api/dto/BaseDTO.java
new file mode 100644
index 0000000..099a8b9
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/BaseDTO.java
@@ -0,0 +1,14 @@
+package org.example.core.api.dto;
+
+import java.io.Serializable;
+import lombok.Data;
+
+/**
+ * 请求和响应的基础类，用于处理序列化
+ * @author dav
+ * @date 2019/3/16 15:56
+ */
+@Data
+public class BaseDTO implements Serializable {
+
+}
diff --git a/src/main/java/org/example/core/api/dto/BaseIdReqDTO.java b/src/main/java/org/example/core/api/dto/BaseIdReqDTO.java
new file mode 100644
index 0000000..b996953
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/BaseIdReqDTO.java
@@ -0,0 +1,27 @@
+package org.example.core.api.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ *
+ * 主键通用请求类，用于根据ID查询
+ *
+ *
+ * @author 聪明笨狗
+ * @since 2019-04-20 12:15
+ */
+@Data
+@ApiModel(value="主键通用请求类", description="主键通用请求类")
+public class BaseIdReqDTO extends BaseDTO {
+
+
+ @ApiModelProperty(value = "主键ID", required=true)
+ private String id;
+
+ @JsonIgnore
+ private String userId;
+
+}
diff --git a/src/main/java/org/example/core/api/dto/BaseIdRespDTO.java b/src/main/java/org/example/core/api/dto/BaseIdRespDTO.java
new file mode 100644
index 0000000..04cfbc6
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/BaseIdRespDTO.java
@@ -0,0 +1,25 @@
+package org.example.core.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ *
+ * 主键通用响应类，用于添加后返回内容
+ *
+ *
+ * @author 聪明笨狗
+ * @since 2019-04-20 12:15
+ */
+@Data
+@ApiModel(value="主键通用响应类", description="主键通用响应类")
+@AllArgsConstructor
+@NoArgsConstructor
+public class BaseIdRespDTO extends BaseDTO {
+
+ @ApiModelProperty(value = "主键ID", required=true)
+ private String id;
+}
diff --git a/src/main/java/org/example/core/api/dto/BaseIdsReqDTO.java b/src/main/java/org/example/core/api/dto/BaseIdsReqDTO.java
new file mode 100644
index 0000000..9db5f97
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/BaseIdsReqDTO.java
@@ -0,0 +1,24 @@
+package org.example.core.api.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.List;
+import lombok.Data;
+
+/**
+ * 通用ID列表类操作，用于批量删除、修改状态等
+ * @author bool
+ * @date 2019-08-01 19:07
+ */
+@Data
+@ApiModel(value="删除参数", description="删除参数")
+public class BaseIdsReqDTO extends BaseDTO {
+
+
+ @JsonIgnore
+ private String userId;
+
+ @ApiModelProperty(value = "要删除的ID列表", required = true)
+ private List ids;
+}
diff --git a/src/main/java/org/example/core/api/dto/BaseStateReqDTO.java b/src/main/java/org/example/core/api/dto/BaseStateReqDTO.java
new file mode 100644
index 0000000..3038ea0
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/BaseStateReqDTO.java
@@ -0,0 +1,30 @@
+package org.example.core.api.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ *
+ * 通用状态请求类，用于修改状态什么的
+ *
+ *
+ * @author 聪明笨狗
+ * @since 2019-04-20 12:15
+ */
+@Data
+@ApiModel(value="通用状态请求类", description="通用状态请求类")
+@AllArgsConstructor
+@NoArgsConstructor
+public class BaseStateReqDTO extends BaseDTO {
+
+
+ @ApiModelProperty(value = "要修改对象的ID列表", required=true)
+ private List ids;
+
+ @ApiModelProperty(value = "通用状态，0为正常，1为禁用", required=true)
+ private Integer state;
+}
diff --git a/src/main/java/org/example/core/api/dto/PagingReqDTO.java b/src/main/java/org/example/core/api/dto/PagingReqDTO.java
new file mode 100644
index 0000000..7de79b9
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/PagingReqDTO.java
@@ -0,0 +1,47 @@
+package org.example.core.api.dto;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 分页查询类
+ * @param
+ * @author bool
+ */
+@ApiModel(value="分页参数", description="分页参数")
+@Data
+public class PagingReqDTO {
+
+
+ @ApiModelProperty(value = "当前页码", required = true, example = "1")
+ private Integer current;
+
+ @ApiModelProperty(value = "每页数量", required = true, example = "10")
+ private Integer size;
+
+ @ApiModelProperty(value = "查询参数")
+ private T params;
+
+ @ApiModelProperty(value = "排序字符")
+ private String orderBy;
+
+ @JsonIgnore
+ @ApiModelProperty(value = "当前用户的ID")
+ private String userId;
+
+ /**
+ * 转换成MyBatis的简单分页对象
+ * @return
+ */
+ public Page toPage(){
+ Page page = new Page();
+ page.setCurrent(this.current);
+ page.setSize(this.size);
+ return page;
+ }
+
+
+}
diff --git a/src/main/java/org/example/core/api/dto/PagingRespDTO.java b/src/main/java/org/example/core/api/dto/PagingRespDTO.java
new file mode 100644
index 0000000..df9a994
--- /dev/null
+++ b/src/main/java/org/example/core/api/dto/PagingRespDTO.java
@@ -0,0 +1,30 @@
+package org.example.core.api.dto;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+/**
+ * 分页响应类
+ * @author bool
+ * @date 2019-07-20 15:17
+ * @param
+ */
+public class PagingRespDTO extends Page {
+
+ /**
+ * 获取页面总数量
+ * @return
+ */
+ @Override
+ public long getPages() {
+ if (this.getSize() == 0L) {
+ return 0L;
+ } else {
+ long pages = this.getTotal() / this.getSize();
+ if (this.getTotal() % this.getSize() != 0L) {
+ ++pages;
+ }
+ return pages;
+ }
+ }
+
+}
diff --git a/src/main/java/org/example/core/api/utils/JsonConverter.java b/src/main/java/org/example/core/api/utils/JsonConverter.java
new file mode 100644
index 0000000..cead204
--- /dev/null
+++ b/src/main/java/org/example/core/api/utils/JsonConverter.java
@@ -0,0 +1,47 @@
+package org.example.core.api.utils;
+
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.alibaba.fastjson.support.config.FastJsonConfig;
+import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.List;
+import org.springframework.http.MediaType;
+import org.springframework.http.converter.HttpMessageConverter;
+
+/**
+ * JSON数据转换器，用于转换返回消息的格式
+ * @author dav
+ * @date 2018/9/11 19:30
+ */
+public class JsonConverter {
+
+ /**
+ * FastJson消息转换器
+ *
+ * @return
+ */
+ public static HttpMessageConverter fastConverter() {
+ // 定义一个convert转换消息的对象
+ FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
+ // 添加FastJson的配置信息
+ FastJsonConfig fastJsonConfig = new FastJsonConfig();
+ // 默认转换器
+ fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat,
+ SerializerFeature.WriteNullNumberAsZero,
+ SerializerFeature.MapSortField,
+ SerializerFeature.WriteNullStringAsEmpty,
+ SerializerFeature.DisableCircularReferenceDetect,
+ SerializerFeature.WriteDateUseDateFormat,
+ SerializerFeature.WriteNullListAsEmpty);
+ fastJsonConfig.setCharset(Charset.forName("UTF-8"));
+ // 处理中文乱码问题
+ List fastMediaTypes = new ArrayList<>();
+ fastMediaTypes.add(MediaType.APPLICATION_JSON_UTF8);
+ fastConverter.setSupportedMediaTypes(fastMediaTypes);
+ // 在convert中添加配置信息
+ fastConverter.setFastJsonConfig(fastJsonConfig);
+
+ return fastConverter;
+ }
+}
diff --git a/src/main/java/org/example/core/domain/AjaxResult.java b/src/main/java/org/example/core/domain/AjaxResult.java
new file mode 100644
index 0000000..867df3d
--- /dev/null
+++ b/src/main/java/org/example/core/domain/AjaxResult.java
@@ -0,0 +1,165 @@
+package org.example.core.domain;
+
+import java.util.HashMap;
+
+/**
+ * 操作消息提醒
+ *
+ * @author xinyilu
+ */
+public class AjaxResult extends HashMap {
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 状态码
+ */
+ public static final String CODE_TAG = "code";
+
+ /**
+ * 返回内容
+ */
+ public static final String MSG_TAG = "msg";
+
+ /**
+ * 数据对象
+ */
+ public static final String DATA_TAG = "data";
+
+ /**
+ * 成功默认消息
+ */
+ private static final Integer CODE_SUCCESS = 0;
+ private static final String MSG_SUCCESS = "操作成功！";
+
+ /**
+ * 失败默认消息
+ */
+ private static final Integer CODE_FAILURE = 1;
+ private static final String MSG_FAILURE = "请求失败！";
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
+ */
+ public AjaxResult() {
+ }
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ */
+ public AjaxResult(int code, String msg) {
+ super.put(CODE_TAG, code);
+ super.put(MSG_TAG, msg);
+ }
+
+ /**
+ * 初始化一个新创建的 AjaxResult 对象
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ * @param data 数据对象
+ */
+ public AjaxResult(int code, String msg, Object data) {
+ super.put(CODE_TAG, code);
+ super.put(MSG_TAG, msg);
+ if (!(data == null)) {
+ super.put(DATA_TAG, data);
+ }
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @return 成功消息
+ */
+ public static AjaxResult success() {
+ return AjaxResult.success("操作成功");
+ }
+
+ /**
+ * 返回成功数据
+ *
+ * @return 成功消息
+ */
+ public static AjaxResult success(Object data) {
+ return AjaxResult.success("操作成功", data);
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @param msg 返回内容
+ * @return 成功消息
+ */
+ public static AjaxResult success(String msg) {
+ return AjaxResult.success(msg, null);
+ }
+
+ /**
+ * 返回成功消息
+ *
+ * @param msg 返回内容
+ * @param data 数据对象
+ * @return 成功消息
+ */
+ public static AjaxResult success(String msg, Object data) {
+ return new AjaxResult(CODE_SUCCESS, msg, data);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @return
+ */
+ public static AjaxResult error() {
+ return AjaxResult.error("操作失败");
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param msg 返回内容
+ * @return 警告消息
+ */
+ public static AjaxResult error(String msg) {
+ return AjaxResult.error(msg, null);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param msg 返回内容
+ * @param data 数据对象
+ * @return 警告消息
+ */
+ public static AjaxResult error(String msg, Object data) {
+ return new AjaxResult(CODE_FAILURE, msg, data);
+ }
+
+ /**
+ * 返回错误消息
+ *
+ * @param code 状态码
+ * @param msg 返回内容
+ * @return 警告消息
+ */
+ public static AjaxResult error(int code, String msg) {
+ return new AjaxResult(code, msg, null);
+ }
+
+ /**
+ * 方便链式调用
+ *
+ * @param key 键
+ * @param value 值
+ * @return 数据对象
+ */
+ @Override
+ public AjaxResult put(String key, Object value) {
+ super.put(key, value);
+ return this;
+ }
+
+}
diff --git a/src/main/java/org/example/core/enums/CommonState.java b/src/main/java/org/example/core/enums/CommonState.java
new file mode 100644
index 0000000..8d177c1
--- /dev/null
+++ b/src/main/java/org/example/core/enums/CommonState.java
@@ -0,0 +1,19 @@
+package org.example.core.enums;
+
+/**
+ * 通用的状态枚举信息
+ *
+ * @author bool
+ * @date 2019-09-17 17:57
+ */
+public interface CommonState {
+
+ /**
+ * 普通状态，正常的
+ */
+ Integer NORMAL = 0;
+ /**
+ * 非正常状态，禁用，下架等
+ */
+ Integer ABNORMAL = 1;
+}
diff --git a/src/main/java/org/example/core/enums/ConfirmRefundStatusEnum.java b/src/main/java/org/example/core/enums/ConfirmRefundStatusEnum.java
new file mode 100644
index 0000000..9273eb0
--- /dev/null
+++ b/src/main/java/org/example/core/enums/ConfirmRefundStatusEnum.java
@@ -0,0 +1,29 @@
+package org.example.core.enums;
+
+import lombok.Getter;
+
+/**
+ * @Description 确认退款状态枚举
+ * @Author 纪寒
+ * @Date 2022-10-26 11:15:21
+ * @Version 1.0
+ */
+@Getter
+public enum ConfirmRefundStatusEnum {
+
+ /**
+ * 未确认
+ */
+ NOT_CONFIRM("NOT_CONFIRM"),
+
+ /**
+ * 已确认
+ */
+ CONFIRMED("CONFIRMED"),
+ ;
+ final private String info;
+
+ ConfirmRefundStatusEnum(String info) {
+ this.info = info;
+ }
+}
diff --git a/src/main/java/org/example/core/enums/GooodsOrderStatusEnum.java b/src/main/java/org/example/core/enums/GooodsOrderStatusEnum.java
new file mode 100644
index 0000000..2dd2df7
--- /dev/null
+++ b/src/main/java/org/example/core/enums/GooodsOrderStatusEnum.java
@@ -0,0 +1,69 @@
+package org.example.core.enums;
+
+import lombok.Getter;
+
+/**
+ * @Description 商品订单状态枚举
+ * @Author 纪寒
+ * @Date 2022-10-19 09:15:38
+ * @Version 1.0
+ */
+@Getter
+public enum GooodsOrderStatusEnum {
+
+ /**
+ * 待付款
+ */
+ WAIT_PAY("WAIT_PAY"),
+
+ /**
+ * 已付款
+ */
+ PAY("PAY"),
+
+ /**
+ * 已取消
+ */
+ CANCEL("CANCEL"),
+
+ /**
+ * 待收货
+ */
+ WAIT_RECEIVED_GOODS("WAIT_RECEIVED_GOODS"),
+
+ /**
+ * 已收货
+ */
+ RECEIVED_GOODS("RECEIVED_GOODS"),
+
+ /**
+ * 退款中
+ */
+ WAIT_REFUND("WAIT_REFUND"),
+
+ /**
+ * 已退款
+ */
+ REFUNDED("REFUNDED"),
+
+ /**
+ * 待退货
+ */
+ WAIT_RETURNED_GOODS("WAIT_RETURNED_GOODS"),
+
+ /**
+ * 已退货
+ */
+ RETURNED_GOODS("RETURNED_GOODS"),
+
+ /**
+ * 已评价
+ */
+ EVALUATED("EVALUATED"),
+ ;
+ final private String info;
+
+ GooodsOrderStatusEnum(String info) {
+ this.info = info;
+ }
+}
diff --git a/src/main/java/org/example/core/enums/OpenType.java b/src/main/java/org/example/core/enums/OpenType.java
new file mode 100644
index 0000000..504661c
--- /dev/null
+++ b/src/main/java/org/example/core/enums/OpenType.java
@@ -0,0 +1,18 @@
+package org.example.core.enums;
+
+/**
+ * 开放方式
+ * @author bool
+ */
+public interface OpenType {
+
+ /**
+ * 完全开放
+ */
+ Integer OPEN = 1;
+
+ /**
+ * 部门开放
+ */
+ Integer DEPT_OPEN = 2;
+}
diff --git a/src/main/java/org/example/core/enums/PayTypeEnum.java b/src/main/java/org/example/core/enums/PayTypeEnum.java
new file mode 100644
index 0000000..71e629e
--- /dev/null
+++ b/src/main/java/org/example/core/enums/PayTypeEnum.java
@@ -0,0 +1,30 @@
+package org.example.core.enums;
+
+import lombok.Getter;
+
+/**
+ * @Description 支付了类型枚举
+ * @Author 纪寒
+ * @Date 2022-10-18 15:16:02
+ * @Version 1.0
+ */
+@Getter
+public enum PayTypeEnum {
+
+ /**
+ * 微信
+ */
+ WECHAT_PAY("WECHAT_PAY"),
+
+ /**
+ * 支付宝
+ */
+ ALI_PAY("ALI_PAY"),
+ ;
+
+ final private String info;
+
+ PayTypeEnum(String info) {
+ this.info = info;
+ }
+}
diff --git a/src/main/java/org/example/core/enums/RefundStatusEnum.java b/src/main/java/org/example/core/enums/RefundStatusEnum.java
new file mode 100644
index 0000000..c75e93d
--- /dev/null
+++ b/src/main/java/org/example/core/enums/RefundStatusEnum.java
@@ -0,0 +1,41 @@
+package org.example.core.enums;
+
+import lombok.Getter;
+
+/**
+ * @Description 微信退款通知枚举
+ * @Author 纪寒
+ * @Date 2022-10-25 13:12:03
+ * @Version 1.0
+ */
+@Getter
+public enum RefundStatusEnum {
+ /**
+ * 退款成功
+ */
+ SUCCESS("SUCCESS"),
+
+ /**
+ * 退款关闭
+ */
+ CLOSED("CLOSED"),
+
+ /**
+ * 退款处理中
+ */
+ PROCESSING("PROCESSING"),
+
+ /**
+ * 退款异常，退款到银行发现用户的卡作废或者冻结了，
+ * 导致原路退款银行卡失败，可前往【商户平台—>交易中心】，手动处理此笔退款
+ */
+ ABNORMAL("ABNORMAL"),
+
+ ;
+
+ final private String info;
+
+ RefundStatusEnum(String info) {
+ this.info = info;
+ }
+}
diff --git a/src/main/java/org/example/core/enums/WeChatTradeStateEnum.java b/src/main/java/org/example/core/enums/WeChatTradeStateEnum.java
new file mode 100644
index 0000000..b68ec6e
--- /dev/null
+++ b/src/main/java/org/example/core/enums/WeChatTradeStateEnum.java
@@ -0,0 +1,52 @@
+package org.example.core.enums;
+
+import lombok.Getter;
+
+/**
+ * 微信支付回调通知状态
+ */
+@Getter
+public enum WeChatTradeStateEnum {
+
+ /**
+ * 支付成功
+ */
+ SUCCESS("SUCCESS"),
+
+ /**
+ * 未支付
+ */
+ NOTPAY("NOTPAY"),
+
+ /**
+ * 已关闭
+ */
+ CLOSED("CLOSED"),
+
+ /**
+ * 转入退款
+ */
+ REFUND("REFUND"),
+
+ /**
+ * 已撤销（付款码支付）
+ */
+ REVOKED("REVOKED"),
+
+ /**
+ * 用户支付中（付款码支付）
+ */
+ USERPAYING("USERPAYING"),
+
+ /**
+ * 支付失败(其他原因，如银行返回失败)
+ */
+ PAYERROR("PAYERROR")
+ ;
+
+ final private String info;
+
+ WeChatTradeStateEnum(String info) {
+ this.info = info;
+ }
+}
diff --git a/src/main/java/org/example/core/exception/ServiceException.java b/src/main/java/org/example/core/exception/ServiceException.java
new file mode 100644
index 0000000..6f11b6f
--- /dev/null
+++ b/src/main/java/org/example/core/exception/ServiceException.java
@@ -0,0 +1,51 @@
+package org.example.core.exception;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.example.core.api.ApiError;
+import org.example.core.api.ApiRest;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class ServiceException extends RuntimeException{
+
+ /**
+ * 错误码
+ */
+ private Integer code;
+
+ /**
+ * 错误消息
+ */
+ private String msg;
+
+ /**
+ * 从结果初始化
+ * @param apiRest
+ */
+ public ServiceException(ApiRest apiRest){
+ this.code = apiRest.getCode();
+ this.msg = apiRest.getMsg();
+ }
+
+ /**
+ * 从枚举中获取参数
+ * @param apiError
+ */
+ public ServiceException(ApiError apiError){
+ this.code = apiError.getCode();
+ this.msg = apiError.msg;
+ }
+
+ /**
+ * 异常构造
+ * @param msg
+ */
+ public ServiceException(String msg){
+ this.code = 1;
+ this.msg = msg;
+ }
+
+}
diff --git a/src/main/java/org/example/core/exception/ServiceExceptionHandler.java b/src/main/java/org/example/core/exception/ServiceExceptionHandler.java
new file mode 100644
index 0000000..9a23eef
--- /dev/null
+++ b/src/main/java/org/example/core/exception/ServiceExceptionHandler.java
@@ -0,0 +1,50 @@
+package org.example.core.exception;
+
+import org.example.core.api.ApiRest;
+import org.springframework.http.HttpStatus;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.WebDataBinder;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.InitBinder;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+/**
+ * 统一异常处理类
+ * @author bool
+ * @date 2019-06-21 19:27
+ */
+@RestControllerAdvice
+public class ServiceExceptionHandler {
+
+ /**
+ * 应用到所有@RequestMapping注解方法，在其执行之前初始化数据绑定器
+ * @param binder
+ */
+ @InitBinder
+ public void initWebBinder(WebDataBinder binder){
+
+ }
+
+ /**
+ * 把值绑定到Model中，使全局@RequestMapping可以获取到该值
+ * @param model
+ */
+ @ModelAttribute
+ public void addAttribute(Model model) {
+
+ }
+
+ /**
+ * 捕获ServiceException
+ * @param e
+ * @return
+ */
+ @ExceptionHandler({org.example.core.exception.ServiceException.class})
+ @ResponseStatus(HttpStatus.OK)
+ public ApiRest serviceExceptionHandler(ServiceException e) {
+ return new ApiRest(e);
+ }
+
+}
\ No newline at end of file
diff --git a/src/main/java/org/example/core/utils/BeanMapper.java b/src/main/java/org/example/core/utils/BeanMapper.java
new file mode 100644
index 0000000..79ab6b9
--- /dev/null
+++ b/src/main/java/org/example/core/utils/BeanMapper.java
@@ -0,0 +1,58 @@
+package org.example.core.utils;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import org.dozer.DozerBeanMapper;
+
+
+/**
+ * 简单封装Dozer, 实现深度转换Bean<->Bean的Mapper.实现:
+ *
+ * 1. 持有Mapper的单例.
+ * 2. 返回值类型转换.
+ * 3. 批量转换Collection中的所有对象.
+ * 4. 区分创建新的B对象与将对象A值复制到已存在的B对象两种函数.
+ *
+ */
+public class BeanMapper {
+
+ /**
+ * 持有Dozer单例, 避免重复创建DozerMapper消耗资源.
+ */
+ private static DozerBeanMapper dozerBeanMapper = new DozerBeanMapper();
+
+ /**
+ * 基于Dozer转换对象的类型.
+ */
+ public static T map(Object source, Class destinationClass) {
+ return dozerBeanMapper.map(source, destinationClass);
+ }
+
+ /**
+ * 基于Dozer转换Collection中对象的类型.
+ */
+ public static List mapList(Iterable sourceList, Class destinationClass) {
+ List destinationList = new ArrayList();
+ for (Object sourceObject : sourceList) {
+ T destinationObject = dozerBeanMapper.map(sourceObject, destinationClass);
+ destinationList.add(destinationObject);
+ }
+ return destinationList;
+ }
+
+ /**
+ * 基于Dozer将对象A的值拷贝到对象B中.
+ */
+ public static void copy(Object source, Object destinationObject) {
+ if(source!=null) {
+ dozerBeanMapper.map(source, destinationObject);
+ }
+ }
+
+ public static List mapList(Collection source, Function mapper) {
+ return source.stream().map(mapper).collect(Collectors.toList());
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/org/example/core/utils/CronUtils.java b/src/main/java/org/example/core/utils/CronUtils.java
new file mode 100644
index 0000000..f99b21d
--- /dev/null
+++ b/src/main/java/org/example/core/utils/CronUtils.java
@@ -0,0 +1,31 @@
+package org.example.core.utils;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * 时间转换quartz表达式
+ * @author bool
+ * @date 2020/11/29 下午3:00
+ */
+public class CronUtils {
+
+ /**
+ * 格式化数据
+ */
+ private static final String DATE_FORMAT = "ss mm HH dd MM ? yyyy";
+
+ /**
+ * 准确的时间点到表达式
+ * @param date
+ * @return
+ */
+ public static String dateToCron(final Date date){
+ SimpleDateFormat fmt = new SimpleDateFormat(DATE_FORMAT);
+ String formatTimeStr = "";
+ if (date != null) {
+ formatTimeStr = fmt.format(date);
+ }
+ return formatTimeStr;
+ }
+}
diff --git a/src/main/java/org/example/core/utils/DateUtils.java b/src/main/java/org/example/core/utils/DateUtils.java
new file mode 100644
index 0000000..6439dab
--- /dev/null
+++ b/src/main/java/org/example/core/utils/DateUtils.java
@@ -0,0 +1,103 @@
+package org.example.core.utils;
+
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.GregorianCalendar;
+
+/**
+ * 日期处理工具类
+ * ClassName: DateUtils
+ * date: 2018年12月13日 下午6:34:02
+ *
+ * @author Bool
+ * @version
+ */
+public class DateUtils {
+
+ /**
+ *
+ * calcExpDays:计算某个日期与当前日期相差的天数，如果计算的日期大于现在时间，将返回负数；否则返回正数
+ * @author Bool
+ * @param userCreateTime
+ * @return
+ * @since JDK 1.6
+ */
+ public static int calcExpDays(Date userCreateTime){
+
+ Calendar start = Calendar.getInstance();
+ start.setTime(userCreateTime);
+
+ Calendar now = Calendar.getInstance();
+ now.setTime(new Date());
+
+ long l = now.getTimeInMillis() - start.getTimeInMillis();
+ int days = new Long(l / (1000 * 60 * 60 * 24)).intValue();
+ return days;
+ }
+
+
+ /**
+ *
+ * dateNow:获取当前时间的字符串格式，根据传入的格式化来展示.
+ * @author Bool
+ * @param format 日期格式化
+ * @return
+ */
+ public static String dateNow(String format) {
+ SimpleDateFormat fmt = new SimpleDateFormat(format);
+ Calendar c = new GregorianCalendar();
+ return fmt.format(c.getTime());
+ }
+
+ /**
+ * formatDate:格式化日期，返回指定的格式
+ * @author Bool
+ * @param time
+ * @param format
+ * @return
+ */
+ public static String formatDate(Date time, String format) {
+ SimpleDateFormat fmt = new SimpleDateFormat(format);
+ return fmt.format(time.getTime());
+ }
+
+
+
+ /**
+ * parseDate:将字符串转换成日期，使用：yyyy-MM-dd HH:mm:ss 来格式化
+ * @author Bool
+ * @param date
+ * @return
+ */
+ public static Date parseDate(String date) {
+ return parseDate(date, "yyyy-MM-dd HH:mm:ss");
+ }
+
+
+ /**
+ *
+ * parseDate:将字符串转换成日期，使用指定格式化来格式化
+ * @author Bool
+ * @param date
+ * @param pattern
+ * @return
+ */
+ public static Date parseDate(String date, String pattern) {
+
+ if (pattern==null) {
+ pattern = "yyyy-MM-dd HH:mm:ss";
+ }
+
+ SimpleDateFormat fmt = new SimpleDateFormat(pattern);
+
+ try {
+
+ return fmt.parse(date);
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ }
+ return null;
+
+ }
+}
diff --git a/src/main/java/org/example/core/utils/IpUtils.java b/src/main/java/org/example/core/utils/IpUtils.java
new file mode 100644
index 0000000..ce346e3
--- /dev/null
+++ b/src/main/java/org/example/core/utils/IpUtils.java
@@ -0,0 +1,65 @@
+package org.example.core.utils;
+
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * IP获取工具类，用户获取网络请求过来的真实IP
+ * ClassName: IpUtils
+ * date: 2018年2月13日 下午7:27:52
+ *
+ * @author Bool
+ * @version
+ */
+public class IpUtils {
+
+
+ /**
+ *
+ * getClientIp:通过请求获取客户端的真实IP地址
+ * @author Bool
+ * @param request
+ * @return
+ */
+ public static String extractClientIp(HttpServletRequest request) {
+
+ String ip = null;
+
+ //X-Forwarded-For：Squid 服务代理
+ String ipAddresses = request.getHeader("X-Forwarded-For");
+
+ if (ipAddresses == null || ipAddresses.length() == 0 || "unknown".equalsIgnoreCase(ipAddresses)) {
+ //Proxy-Client-IP：apache 服务代理
+ ipAddresses = request.getHeader("Proxy-Client-IP");
+ }
+
+ if (ipAddresses == null || ipAddresses.length() == 0 || "unknown".equalsIgnoreCase(ipAddresses)) {
+ //WL-Proxy-Client-IP：weblogic 服务代理
+ ipAddresses = request.getHeader("WL-Proxy-Client-IP");
+ }
+
+ if (ipAddresses == null || ipAddresses.length() == 0 || "unknown".equalsIgnoreCase(ipAddresses)) {
+ //HTTP_CLIENT_IP：有些代理服务器
+ ipAddresses = request.getHeader("HTTP_CLIENT_IP");
+ }
+
+ if (ipAddresses == null || ipAddresses.length() == 0 || "unknown".equalsIgnoreCase(ipAddresses)) {
+ //X-Real-IP：nginx服务代理
+ ipAddresses = request.getHeader("X-Real-IP");
+ }
+
+ //有些网络通过多层代理，那么获取到的ip就会有多个，一般都是通过逗号（,）分割开来，并且第一个ip为客户端的真实IP
+ if (ipAddresses != null && ipAddresses.length() != 0) {
+ ip = ipAddresses.split(",")[0];
+ }
+
+ //还是不能获取到，最后再通过request.getRemoteAddr();获取
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ipAddresses)) {
+ ip = request.getRemoteAddr();
+ }
+
+ return ip;
+ }
+
+
+}
diff --git a/src/main/java/org/example/core/utils/Reflections.java b/src/main/java/org/example/core/utils/Reflections.java
new file mode 100644
index 0000000..d05d74c
--- /dev/null
+++ b/src/main/java/org/example/core/utils/Reflections.java
@@ -0,0 +1,323 @@
+/**
+ * Copyright (c) 2005-2012 springside.org.cn
+ */
+package org.example.core.utils;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import lombok.extern.log4j.Log4j2;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.Validate;
+import org.springframework.util.Assert;
+
+/**
+ * 反射工具类.
+ * 提供调用getter/setter方法, 访问私有变量, 调用私有方法, 获取泛型类型Class, 被AOP过的真实类等工具函数.
+ * @author calvin
+ * @version 2016-01-15
+ */
+@Log4j2
+public class Reflections {
+
+ private static final String SETTER_PREFIX = "set";
+
+ private static final String GETTER_PREFIX = "get";
+
+ private static final String CGLIB_CLASS_SEPARATOR = "$$";
+
+
+ /**
+ * 获取类的所有属性，包括父类
+ *
+ * @param object
+ * @return
+ */
+ public static Field[] getAllFields(Object object) {
+ Class clazz = object.getClass();
+ List fieldList = new ArrayList<>();
+ while (clazz != null) {
+ fieldList.addAll(new ArrayList<>(Arrays.asList(clazz.getDeclaredFields())));
+ clazz = clazz.getSuperclass();
+ }
+ Field[] fields = new Field[fieldList.size()];
+ fieldList.toArray(fields);
+ return fields;
+ }
+
+
+ /**
+ * 调用Getter方法.
+ * 支持多级，如：对象名.对象名.方法
+ */
+ public static Object invokeGetter(Object obj, String propertyName) {
+ Object object = obj;
+ for (String name : StringUtils.split(propertyName, ".")){
+ String getterMethodName = GETTER_PREFIX + StringUtils.capitalize(name);
+ object = invokeMethod(object, getterMethodName, new Class[] {}, new Object[] {});
+ }
+ return object;
+ }
+
+ /**
+ * 调用Setter方法, 仅匹配方法名。
+ * 支持多级，如：对象名.对象名.方法
+ */
+ public static void invokeSetter(Object obj, String propertyName, Object value) {
+ Object object = obj;
+ String[] names = StringUtils.split(propertyName, ".");
+ for (int i=0; i[] parameterTypes,
+ final Object[] args) {
+ Method method = getAccessibleMethod(obj, methodName, parameterTypes);
+ if (method == null) {
+ throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]");
+ }
+
+ try {
+ return method.invoke(obj, args);
+ } catch (Exception e) {
+ throw convertReflectionExceptionToUnchecked(e);
+ }
+ }
+
+ /**
+ * 直接调用对象方法, 无视private/protected修饰符，
+ * 用于一次性调用的情况，否则应使用getAccessibleMethodByName()函数获得Method后反复调用.
+ * 只匹配函数名，如果有多个同名函数调用第一个。
+ */
+ public static Object invokeMethodByName(final Object obj, final String methodName, final Object[] args) {
+ Method method = getAccessibleMethodByName(obj, methodName);
+ if (method == null) {
+ throw new IllegalArgumentException("Could not find method [" + methodName + "] on target [" + obj + "]");
+ }
+
+ try {
+ return method.invoke(obj, args);
+ } catch (Exception e) {
+ throw convertReflectionExceptionToUnchecked(e);
+ }
+ }
+
+ /**
+ * 循环向上转型, 获取对象的DeclaredField, 并强制设置为可访问.
+ *
+ * 如向上转型到Object仍无法找到, 返回null.
+ */
+ public static Field getAccessibleField(final Object obj, final String fieldName) {
+ Validate.notNull(obj, "object can't be null");
+ Validate.notBlank(fieldName, "fieldName can't be blank");
+ for (Class superClass = obj.getClass(); superClass != Object.class; superClass = superClass.getSuperclass()) {
+ try {
+ Field field = superClass.getDeclaredField(fieldName);
+ makeAccessible(field);
+ return field;
+ } catch (NoSuchFieldException e) {//NOSONAR
+ // Field不在当前类定义,继续向上转型
+ continue;// new add
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问.
+ * 如向上转型到Object仍无法找到, 返回null.
+ * 匹配函数名+参数类型。
+ *
+ * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args)
+ */
+ public static Method getAccessibleMethod(final Object obj, final String methodName,
+ final Class... parameterTypes) {
+ Validate.notNull(obj, "object can't be null");
+ Validate.notBlank(methodName, "methodName can't be blank");
+
+ for (Class searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
+ try {
+ Method method = searchType.getDeclaredMethod(methodName, parameterTypes);
+ makeAccessible(method);
+ return method;
+ } catch (NoSuchMethodException e) {
+ // Method不在当前类定义,继续向上转型
+ continue;// new add
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 循环向上转型, 获取对象的DeclaredMethod,并强制设置为可访问.
+ * 如向上转型到Object仍无法找到, 返回null.
+ * 只匹配函数名。
+ *
+ * 用于方法需要被多次调用的情况. 先使用本函数先取得Method,然后调用Method.invoke(Object obj, Object... args)
+ */
+ public static Method getAccessibleMethodByName(final Object obj, final String methodName) {
+ Validate.notNull(obj, "object can't be null");
+ Validate.notBlank(methodName, "methodName can't be blank");
+
+ for (Class searchType = obj.getClass(); searchType != Object.class; searchType = searchType.getSuperclass()) {
+ Method[] methods = searchType.getDeclaredMethods();
+ for (Method method : methods) {
+ if (method.getName().equals(methodName)) {
+ makeAccessible(method);
+ return method;
+ }
+ }
+ }
+ return null;
+ }
+
+ /**
+ * 改变private/protected的方法为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。
+ */
+ public static void makeAccessible(Method method) {
+ if ((!Modifier.isPublic(method.getModifiers()) || !Modifier.isPublic(method.getDeclaringClass().getModifiers()))
+ && !method.isAccessible()) {
+ method.setAccessible(true);
+ }
+ }
+
+ /**
+ * 改变private/protected的成员变量为public，尽量不调用实际改动的语句，避免JDK的SecurityManager抱怨。
+ */
+ public static void makeAccessible(Field field) {
+ if ((!Modifier.isPublic(field.getModifiers()) || !Modifier.isPublic(field.getDeclaringClass().getModifiers()) || Modifier
+ .isFinal(field.getModifiers())) && !field.isAccessible()) {
+ field.setAccessible(true);
+ }
+ }
+
+ /**
+ * 通过反射, 获得Class定义中声明的泛型参数的类型, 注意泛型必须定义在父类处
+ * 如无法找到, 返回Object.class.
+ * eg.
+ * public UserDao extends HibernateDao
+ *
+ * @param clazz The class to introspect
+ * @return the first generic declaration, or Object.class if cannot be determined
+ */
+ @SuppressWarnings("unchecked")
+ public static Class getClassGenricType(final Class clazz) {
+ return getClassGenricType(clazz, 0);
+ }
+
+ /**
+ * 通过反射, 获得Class定义中声明的父类的泛型参数的类型.
+ * 如无法找到, 返回Object.class.
+ *
+ * 如public UserDao extends HibernateDao
+ *
+ * @param clazz clazz The class to introspect
+ * @param index the Index of the generic ddeclaration,start from 0.
+ * @return the index generic declaration, or Object.class if cannot be determined
+ */
+ public static Class getClassGenricType(final Class clazz, final int index) {
+
+ Type genType = clazz.getGenericSuperclass();
+
+ if (!(genType instanceof ParameterizedType)) {
+ log.warn(clazz.getSimpleName() + "'s superclass not ParameterizedType");
+ return Object.class;
+ }
+
+ Type[] params = ((ParameterizedType) genType).getActualTypeArguments();
+
+ if (index >= params.length || index < 0) {
+ log.warn("Index: " + index + ", Size of " + clazz.getSimpleName() + "'s Parameterized Type: "
+ + params.length);
+ return Object.class;
+ }
+ if (!(params[index] instanceof Class)) {
+ log.warn(clazz.getSimpleName() + " not set the actual class on superclass generic parameter");
+ return Object.class;
+ }
+
+ return (Class) params[index];
+ }
+
+ public static Class getUserClass(Object instance) {
+ Assert.notNull(instance, "Instance must not be null");
+ Class clazz = instance.getClass();
+ if (clazz != null && clazz.getName().contains(CGLIB_CLASS_SEPARATOR)) {
+ Class superClass = clazz.getSuperclass();
+ if (superClass != null && !Object.class.equals(superClass)) {
+ return superClass;
+ }
+ }
+ return clazz;
+
+ }
+
+ /**
+ * 将反射时的checked exception转换为unchecked exception.
+ */
+ public static RuntimeException convertReflectionExceptionToUnchecked(Exception e) {
+ if (e instanceof IllegalAccessException || e instanceof IllegalArgumentException
+ || e instanceof NoSuchMethodException) {
+ return new IllegalArgumentException(e);
+ } else if (e instanceof InvocationTargetException) {
+ return new RuntimeException(((InvocationTargetException) e).getTargetException());
+ } else if (e instanceof RuntimeException) {
+ return (RuntimeException) e;
+ }
+ return new RuntimeException("Unexpected Checked Exception.", e);
+ }
+}
diff --git a/src/main/java/org/example/core/utils/SpringUtils.java b/src/main/java/org/example/core/utils/SpringUtils.java
new file mode 100644
index 0000000..b659ecb
--- /dev/null
+++ b/src/main/java/org/example/core/utils/SpringUtils.java
@@ -0,0 +1,32 @@
+package org.example.core.utils;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+/**
+ * Spring获取工具
+ *
+ * @author bool
+ * @date 2019-12-09 15:55
+ */
+@Component
+public class SpringUtils implements ApplicationContextAware {
+
+ private static ApplicationContext applicationContext;
+
+ @Override
+ public void setApplicationContext(ApplicationContext context) throws BeansException {
+ applicationContext = context;
+ }
+
+ public static T getBean(Class tClass) {
+ return applicationContext.getBean(tClass);
+ }
+
+ public static T getBean(String name, Class type) {
+ return applicationContext.getBean(name, type);
+ }
+
+}
diff --git a/src/main/java/org/example/core/utils/StringUtils.java b/src/main/java/org/example/core/utils/StringUtils.java
new file mode 100644
index 0000000..20ec321
--- /dev/null
+++ b/src/main/java/org/example/core/utils/StringUtils.java
@@ -0,0 +1,39 @@
+package org.example.core.utils;
+
+import java.util.Map;
+
+/**
+ * 字符串常用工具类
+ * @author bool
+ * @date 2019-05-15 11:40
+ */
+public class StringUtils {
+
+ /**
+ * 判断是否为空字符
+ * @param str
+ * @return
+ */
+ public static boolean isBlank(String str){
+ return str==null || "".equals(str);
+ }
+
+
+ /**
+ * 将MAP转换成一个xml格式，格式为value...
+ * @param params
+ * @return
+ */
+ public static String mapToXml(Map params){
+ StringBuffer sb = new StringBuffer("");
+ for(String key:params.keySet()){
+ sb.append("<")
+ .append(key).append(">")
+ .append(params.get(key))
+ .append("");
+ }
+
+ sb.append("");
+ return sb.toString();
+ }
+}
diff --git a/src/main/java/org/example/core/utils/excel/ExportExcel.java b/src/main/java/org/example/core/utils/excel/ExportExcel.java
new file mode 100644
index 0000000..c2ddba5
--- /dev/null
+++ b/src/main/java/org/example/core/utils/excel/ExportExcel.java
@@ -0,0 +1,401 @@
+/**
+ * Copyright © 2015-2020 JeePlus All rights reserved.
+ */
+package org.example.core.utils.excel;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.net.URLEncoder;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import javax.servlet.http.HttpServletResponse;
+import org.apache.commons.compress.utils.Lists;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.CellStyle;
+import org.apache.poi.ss.usermodel.Comment;
+import org.apache.poi.ss.usermodel.DataFormat;
+import org.apache.poi.ss.usermodel.Font;
+import org.apache.poi.ss.usermodel.IndexedColors;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.ss.util.CellRangeAddress;
+import org.apache.poi.xssf.streaming.SXSSFWorkbook;
+import org.apache.poi.xssf.usermodel.XSSFClientAnchor;
+import org.apache.poi.xssf.usermodel.XSSFRichTextString;
+import org.example.core.utils.Reflections;
+import org.example.core.utils.excel.annotation.ExcelField;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 导出Excel文件（导出“XLSX”格式，支持大数据量导出 @see org.apache.poi.ss.SpreadsheetVersion）
+ * @author jeeplus
+ * @version 2016-04-21
+ */
+public class ExportExcel {
+
+ private static Logger log = LoggerFactory.getLogger(ExportExcel.class);
+
+ /**
+ * 工作薄对象
+ */
+ private SXSSFWorkbook wb;
+
+ /**
+ * 工作表对象
+ */
+ private Sheet sheet;
+
+ /**
+ * 样式列表
+ */
+ private Map styles;
+
+ /**
+ * 当前行号
+ */
+ private int rownum;
+
+ /**
+ * 注解列表（Object[]{ ExcelField, Field/Method }）
+ */
+ List annotationList = Lists.newArrayList();
+
+ /**
+ * 构造函数
+ * @param title 表格标题，传“空值”，表示无标题
+ * @param cls 实体对象，通过annotation.ExportField获取标题
+ */
+ public ExportExcel(String title, Class cls){
+ this(title, cls, 1);
+ }
+
+ /**
+ * 构造函数
+ * @param title 表格标题，传“空值”，表示无标题
+ * @param cls 实体对象，通过annotation.ExportField获取标题
+ * @param type 导出类型（1:导出数据；2：导出模板）
+ * @param groups 导入分组
+ */
+ public ExportExcel(String title, Class cls, int type, int... groups){
+ // Get annotation field
+ Field[] fs = cls.getDeclaredFields();
+ for (Field f : fs){
+ ExcelField ef = f.getAnnotation(ExcelField.class);
+ if (ef != null && (ef.type()==0 || ef.type()==type)){
+ if (groups!=null && groups.length>0){
+ boolean inGroup = false;
+ for (int g : groups){
+ if (inGroup){
+ break;
+ }
+ for (int efg : ef.groups()){
+ if (g == efg){
+ inGroup = true;
+ annotationList.add(new Object[]{ef, f});
+ break;
+ }
+ }
+ }
+ }else{
+ annotationList.add(new Object[]{ef, f});
+ }
+ }
+ }
+ // Get annotation method
+ Method[] ms = cls.getDeclaredMethods();
+ for (Method m : ms){
+ ExcelField ef = m.getAnnotation(ExcelField.class);
+ if (ef != null && (ef.type()==0 || ef.type()==type)){
+ if (groups!=null && groups.length>0){
+ boolean inGroup = false;
+ for (int g : groups){
+ if (inGroup){
+ break;
+ }
+ for (int efg : ef.groups()){
+ if (g == efg){
+ inGroup = true;
+ annotationList.add(new Object[]{ef, m});
+ break;
+ }
+ }
+ }
+ }else{
+ annotationList.add(new Object[]{ef, m});
+ }
+ }
+ }
+ // Field sorting
+ Collections.sort(annotationList, new Comparator() {
+ @Override
+ public int compare(Object[] o1, Object[] o2) {
+ return new Integer(((ExcelField)o1[0]).sort()).compareTo(
+ new Integer(((ExcelField)o2[0]).sort()));
+ }
+ });
+ // Initialize
+ List headerList = Lists.newArrayList();
+ for (Object[] os : annotationList){
+ String t = ((ExcelField)os[0]).title();
+ // 如果是导出，则去掉注释
+ if (type==1){
+ String[] ss = StringUtils.split(t, "**", 2);
+ if (ss.length==2){
+ t = ss[0];
+ }
+ }
+ headerList.add(t);
+ }
+ initialize(title, headerList);
+ }
+ /**
+ * 初始化函数
+ * @param title 表格标题，传“空值”，表示无标题
+ * @param headerList 表头列表
+ */
+ private void initialize(String title, List headerList) {
+ this.wb = new SXSSFWorkbook(500);
+ this.sheet = wb.createSheet("Export");
+ this.styles = createStyles(wb);
+ // Create title
+ if (StringUtils.isNotBlank(title)){
+ Row titleRow = sheet.createRow(rownum++);
+ titleRow.setHeightInPoints(30);
+ Cell titleCell = titleRow.createCell(0);
+ titleCell.setCellStyle(styles.get("title"));
+ titleCell.setCellValue(title);
+ sheet.addMergedRegion(new CellRangeAddress(titleRow.getRowNum(),
+ titleRow.getRowNum(), titleRow.getRowNum(), headerList.size()-1));
+ }
+ // Create header
+ if (headerList == null){
+ throw new RuntimeException("headerList not null!");
+ }
+ Row headerRow = sheet.createRow(rownum++);
+ headerRow.setHeightInPoints(16);
+ for (int i = 0; i < headerList.size(); i++) {
+ Cell cell = headerRow.createCell(i);
+ cell.setCellStyle(styles.get("header"));
+ String[] ss = StringUtils.split(headerList.get(i), "**", 2);
+ if (ss.length==2){
+ cell.setCellValue(ss[0]);
+ Comment comment = this.sheet.createDrawingPatriarch().createCellComment(
+ new XSSFClientAnchor(0, 0, 0, 0, (short) 3, 3, (short) 5, 6));
+ comment.setString(new XSSFRichTextString(ss[1]));
+ cell.setCellComment(comment);
+ }else{
+ cell.setCellValue(headerList.get(i));
+ }
+ sheet.autoSizeColumn(i);
+ }
+ for (int i = 0; i < headerList.size(); i++) {
+ int colWidth = sheet.getColumnWidth(i)*2;
+ sheet.setColumnWidth(i, colWidth < 3000 ? 3000 : colWidth);
+ }
+ log.debug("Initialize success.");
+ }
+
+ /**
+ * 创建表格样式
+ * @param wb 工作薄对象
+ * @return 样式列表
+ */
+ private Map createStyles(Workbook wb) {
+ Map styles = new HashMap<>(16);
+
+ CellStyle style = wb.createCellStyle();
+ style.setAlignment(CellStyle.ALIGN_CENTER);
+ style.setVerticalAlignment(CellStyle.VERTICAL_CENTER);
+ Font titleFont = wb.createFont();
+ titleFont.setFontName("Arial");
+ titleFont.setFontHeightInPoints((short) 16);
+ titleFont.setBoldweight(Font.BOLDWEIGHT_BOLD);
+ style.setFont(titleFont);
+ styles.put("title", style);
+
+ style = wb.createCellStyle();
+ style.setVerticalAlignment(CellStyle.VERTICAL_CENTER);
+ style.setBorderRight(CellStyle.BORDER_THIN);
+ style.setRightBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
+ style.setBorderLeft(CellStyle.BORDER_THIN);
+ style.setLeftBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
+ style.setBorderTop(CellStyle.BORDER_THIN);
+ style.setTopBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
+ style.setBorderBottom(CellStyle.BORDER_THIN);
+ style.setBottomBorderColor(IndexedColors.GREY_50_PERCENT.getIndex());
+ Font dataFont = wb.createFont();
+ dataFont.setFontName("Arial");
+ dataFont.setFontHeightInPoints((short) 10);
+ style.setFont(dataFont);
+ styles.put("data", style);
+
+ style = wb.createCellStyle();
+ style.cloneStyleFrom(styles.get("data"));
+ style.setAlignment(CellStyle.ALIGN_LEFT);
+ styles.put("data1", style);
+
+ style = wb.createCellStyle();
+ style.cloneStyleFrom(styles.get("data"));
+ style.setAlignment(CellStyle.ALIGN_CENTER);
+ styles.put("data2", style);
+
+ style = wb.createCellStyle();
+ style.cloneStyleFrom(styles.get("data"));
+ style.setAlignment(CellStyle.ALIGN_RIGHT);
+ styles.put("data3", style);
+
+ style = wb.createCellStyle();
+ style.cloneStyleFrom(styles.get("data"));
+// style.setWrapText(true);
+ style.setAlignment(CellStyle.ALIGN_CENTER);
+ style.setFillForegroundColor(IndexedColors.GREY_50_PERCENT.getIndex());
+ style.setFillPattern(CellStyle.SOLID_FOREGROUND);
+ Font headerFont = wb.createFont();
+ headerFont.setFontName("Arial");
+ headerFont.setFontHeightInPoints((short) 10);
+ headerFont.setBoldweight(Font.BOLDWEIGHT_BOLD);
+ headerFont.setColor(IndexedColors.WHITE.getIndex());
+ style.setFont(headerFont);
+ styles.put("header", style);
+
+ return styles;
+ }
+
+ /**
+ * 添加一行
+ * @return 行对象
+ */
+ public Row addRow(){
+ return sheet.createRow(rownum++);
+ }
+
+
+ /**
+ * 添加一个单元格
+ * @param row 添加的行
+ * @param column 添加列号
+ * @param val 添加值
+ * @return 单元格对象
+ */
+ public Cell addCell(Row row, int column, Object val){
+ return this.addCell(row, column, val, 0, Class.class);
+ }
+
+ /**
+ * 添加一个单元格
+ * @param row 添加的行
+ * @param column 添加列号
+ * @param val 添加值
+ * @param align 对齐方式（1：靠左；2：居中；3：靠右）
+ * @return 单元格对象
+ */
+ public Cell addCell(Row row, int column, Object val, int align, Class fieldType){
+ Cell cell = row.createCell(column);
+ CellStyle style = styles.get("data"+(align>=1&&align<=3?align:""));
+ try {
+ if (val == null){
+ cell.setCellValue("");
+ } else if (val instanceof String) {
+ cell.setCellValue((String) val);
+ } else if (val instanceof Integer) {
+ cell.setCellValue((Integer) val);
+ } else if (val instanceof Long) {
+ cell.setCellValue((Long) val);
+ } else if (val instanceof Double) {
+ cell.setCellValue((Double) val);
+ } else if (val instanceof Float) {
+ cell.setCellValue((Float) val);
+ } else if (val instanceof Date) {
+ DataFormat format = wb.createDataFormat();
+ style.setDataFormat(format.getFormat("yyyy-MM-dd"));
+ cell.setCellValue((Date) val);
+ } else {
+ if (fieldType != Class.class){
+ cell.setCellValue((String)fieldType.getMethod("setValue", Object.class).invoke(null, val));
+ }else{
+ cell.setCellValue((String)Class.forName(this.getClass().getName().replaceAll(this.getClass().getSimpleName(),
+ "fieldtype."+val.getClass().getSimpleName()+"Type")).getMethod("setValue", Object.class).invoke(null, val));
+ }
+ }
+ } catch (Exception ex) {
+ log.info("Set cell value ["+row.getRowNum()+","+column+"] error: " + ex.toString());
+ cell.setCellValue(val.toString());
+ }
+ cell.setCellStyle(style);
+ return cell;
+ }
+
+ /**
+ * 添加数据（通过annotation.ExportField添加数据）
+ * @return list 数据列表
+ */
+ public ExportExcel setDataList(List list){
+ for (E e : list){
+ int colunm = 0;
+ Row row = this.addRow();
+ StringBuilder sb = new StringBuilder();
+ for (Object[] os : annotationList){
+ ExcelField ef = (ExcelField)os[0];
+ Object val = null;
+ try{
+ if (StringUtils.isNotBlank(ef.value())){
+ val = Reflections.invokeGetter(e, ef.value());
+ }else{
+ if (os[1] instanceof Field){
+ val = Reflections.invokeGetter(e, ((Field)os[1]).getName());
+ }else if (os[1] instanceof Method){
+ val = Reflections.invokeMethod(e, ((Method)os[1]).getName(), new Class[] {}, new Object[] {});
+ }
+ }
+ }catch(Exception ex) {
+ log.info(ex.toString());
+ val = "";
+ }
+ this.addCell(row, colunm++, val, ef.align(), ef.fieldType());
+ sb.append(val + ", ");
+ }
+ log.debug("Write success: ["+row.getRowNum()+"] "+sb.toString());
+ }
+ return this;
+ }
+
+ /**
+ * 输出数据流
+ * @param os 输出数据流
+ */
+ public ExportExcel write(OutputStream os) throws IOException{
+ wb.write(os);
+ return this;
+ }
+
+ /**
+ * 输出到客户端
+ * @param fileName 输出文件名
+ */
+ public ExportExcel write(HttpServletResponse response, String fileName) throws IOException{
+ response.reset();
+ response.setHeader("Access-Control-Allow-Origin", "*");
+ response.setContentType("application/octet-stream; charset=utf-8");
+ response.addHeader("Content-Disposition", "attachment; filename="+ URLEncoder.encode(fileName, "utf-8"));
+ write(response.getOutputStream());
+ return this;
+ }
+
+ /**
+ * 清理临时文件
+ */
+ public ExportExcel dispose(){
+ wb.dispose();
+ return this;
+ }
+
+}
diff --git a/src/main/java/org/example/core/utils/excel/ImportExcel.java b/src/main/java/org/example/core/utils/excel/ImportExcel.java
new file mode 100644
index 0000000..d6a4f3e
--- /dev/null
+++ b/src/main/java/org/example/core/utils/excel/ImportExcel.java
@@ -0,0 +1,302 @@
+/**
+ * Copyright © 2015-2020 JeePlus All rights reserved.
+ */
+package org.example.core.utils.excel;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.text.NumberFormat;
+import java.text.SimpleDateFormat;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.List;
+import org.apache.commons.compress.utils.Lists;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.hssf.usermodel.HSSFDateUtil;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.example.core.utils.Reflections;
+import org.example.core.utils.excel.annotation.ExcelField;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * 导入Excel文件（支持“XLS”和“XLSX”格式）
+ * @author jeeplus
+ * @version 2016-03-10
+ */
+public class ImportExcel {
+
+ private static Logger log = LoggerFactory.getLogger(ImportExcel.class);
+
+ /**
+ * 工作薄对象
+ */
+ private Workbook wb;
+
+ /**
+ * 工作表对象
+ */
+ private Sheet sheet;
+
+ /**
+ * 标题行号
+ */
+ private int headerNum;
+
+
+
+ /**
+ * 构造函数
+ * @param multipartFile 导入文件对象
+ * @param headerNum 标题行号，数据行号=标题行号+1
+ * @param sheetIndex 工作表编号
+ * @throws InvalidFormatException
+ * @throws IOException
+ */
+ public ImportExcel(MultipartFile multipartFile, int headerNum, int sheetIndex)
+ throws InvalidFormatException, IOException {
+ this(multipartFile.getOriginalFilename(), multipartFile.getInputStream(), headerNum, sheetIndex);
+ }
+
+ /**
+ * 构造函数
+ * @param is 导入文件对象
+ * @param headerNum 标题行号，数据行号=标题行号+1
+ * @param sheetIndex 工作表编号
+ * @throws InvalidFormatException
+ * @throws IOException
+ */
+ public ImportExcel(String fileName, InputStream is, int headerNum, int sheetIndex)
+ throws IOException {
+ if (StringUtils.isBlank(fileName)){
+ throw new RuntimeException("导入文档为空!");
+ }else if(fileName.toLowerCase().endsWith("xls")){
+ this.wb = new HSSFWorkbook(is);
+ }else if(fileName.toLowerCase().endsWith("xlsx")){
+ this.wb = new XSSFWorkbook(is);
+ }else{
+ throw new RuntimeException("文档格式不正确!");
+ }
+ if (this.wb.getNumberOfSheets() List getDataList(Class cls, int... groups) throws InstantiationException, IllegalAccessException{
+ List annotationList = Lists.newArrayList();
+ // Get annotation field
+ Field[] fs = cls.getDeclaredFields();
+ for (Field f : fs){
+ ExcelField ef = f.getAnnotation(ExcelField.class);
+ if (ef != null && (ef.type()==0 || ef.type()==2)){
+ if (groups!=null && groups.length>0){
+ boolean inGroup = false;
+ for (int g : groups){
+ if (inGroup){
+ break;
+ }
+ for (int efg : ef.groups()){
+ if (g == efg){
+ inGroup = true;
+ annotationList.add(new Object[]{ef, f});
+ break;
+ }
+ }
+ }
+ }else{
+ annotationList.add(new Object[]{ef, f});
+ }
+ }
+ }
+ // Get annotation method
+ Method[] ms = cls.getDeclaredMethods();
+ for (Method m : ms){
+ ExcelField ef = m.getAnnotation(ExcelField.class);
+ if (ef != null && (ef.type()==0 || ef.type()==2)){
+ if (groups!=null && groups.length>0){
+ boolean inGroup = false;
+ for (int g : groups){
+ if (inGroup){
+ break;
+ }
+ for (int efg : ef.groups()){
+ if (g == efg){
+ inGroup = true;
+ annotationList.add(new Object[]{ef, m});
+ break;
+ }
+ }
+ }
+ }else{
+ annotationList.add(new Object[]{ef, m});
+ }
+ }
+ }
+ // Field sorting
+ Collections.sort(annotationList, new Comparator() {
+ @Override
+ public int compare(Object[] o1, Object[] o2) {
+ return new Integer(((ExcelField)o1[0]).sort()).compareTo(
+ new Integer(((ExcelField)o2[0]).sort()));
+ }
+ });
+ // Get excel data
+ List dataList = Lists.newArrayList();
+ for (int i = this.getDataRowNum(); i < this.getLastDataRowNum(); i++) {
+ E e = (E)cls.newInstance();
+ int column = 0;
+ Row row = this.getRow(i);
+ StringBuilder sb = new StringBuilder();
+ for (Object[] os : annotationList){
+ Object val = this.getCellValue(row, column++);
+ if (val != null){
+ ExcelField ef = (ExcelField)os[0];
+ // Get param type and type cast
+ Class valType = Class.class;
+ if (os[1] instanceof Field){
+ valType = ((Field)os[1]).getType();
+ }else if (os[1] instanceof Method){
+ Method method = ((Method)os[1]);
+ if ("get".equals(method.getName().substring(0, 3))){
+ valType = method.getReturnType();
+ }else if("set".equals(method.getName().substring(0, 3))){
+ valType = ((Method)os[1]).getParameterTypes()[0];
+ }
+ }
+ //log.debug("Import value type: ["+i+","+column+"] " + valType);
+ try {
+ //如果导入的java对象，需要在这里自己进行变换。
+ if (valType == String.class){
+ String s = String.valueOf(val.toString());
+ if(StringUtils.endsWith(s, ".0")){
+ val = StringUtils.substringBefore(s, ".0");
+ }else{
+ val = String.valueOf(val.toString());
+ }
+ }else if (valType == Integer.class){
+ val = Double.valueOf(val.toString()).intValue();
+ }else if (valType == Long.class){
+ val = Double.valueOf(val.toString()).longValue();
+ }else if (valType == Double.class){
+ val = Double.valueOf(val.toString());
+ }else if (valType == Float.class){
+ val = Float.valueOf(val.toString());
+ }else if (valType == Date.class){
+ SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
+ val=sdf.parse(val.toString());
+ }else{
+ if (ef.fieldType() != Class.class){
+ val = ef.fieldType().getMethod("getValue", String.class).invoke(null, val.toString());
+ }else{
+ val = Class.forName(this.getClass().getName().replaceAll(this.getClass().getSimpleName(),
+ "fieldtype."+valType.getSimpleName()+"Type")).getMethod("getValue", String.class).invoke(null, val.toString());
+ }
+ }
+ } catch (Exception ex) {
+ log.info("Get cell value ["+i+","+column+"] error: " + ex.toString());
+ val = null;
+ }
+ // set entity value
+ if (os[1] instanceof Field){
+ Reflections.invokeSetter(e, ((Field)os[1]).getName(), val);
+ }else if (os[1] instanceof Method){
+ String mthodName = ((Method)os[1]).getName();
+ if ("get".equals(mthodName.substring(0, 3))){
+ mthodName = "set"+StringUtils.substringAfter(mthodName, "get");
+ }
+ Reflections.invokeMethod(e, mthodName, new Class[] {valType}, new Object[] {val});
+ }
+ }
+ sb.append(val+", ");
+ }
+ dataList.add(e);
+ log.debug("Read success: ["+i+"] "+sb.toString());
+ }
+ return dataList;
+ }
+
+}
diff --git a/src/main/java/org/example/core/utils/excel/annotation/ExcelField.java b/src/main/java/org/example/core/utils/excel/annotation/ExcelField.java
new file mode 100644
index 0000000..d553f23
--- /dev/null
+++ b/src/main/java/org/example/core/utils/excel/annotation/ExcelField.java
@@ -0,0 +1,59 @@
+/**
+ * Copyright © 2015-2020 JeePlus All rights reserved.
+ */
+package org.example.core.utils.excel.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Excel注解定义
+ * @author jeeplus
+ * @version 2016-03-10
+ */
+@Target({ElementType.METHOD, ElementType.FIELD, ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface ExcelField {
+
+ /**
+ * 导出字段名（默认调用当前字段的“get”方法，如指定导出字段为对象，请填写“对象名.对象属性”，例：“area.name”、“office.name”）
+ */
+ String value() default "";
+
+ /**
+ * 导出字段标题（需要添加批注请用“**”分隔，标题**批注，仅对导出模板有效）
+ */
+ String title();
+
+ /**
+ * 字段类型（0：导出导入；1：仅导出；2：仅导入）
+ */
+ int type() default 0;
+
+ /**
+ * 导出字段对齐方式（0：自动；1：靠左；2：居中；3：靠右）
+ */
+ int align() default 0;
+
+ /**
+ * 导出字段字段排序（升序）
+ */
+ int sort() default 0;
+
+ /**
+ * 如果是字典类型，请设置字典的type值
+ */
+ String dictType() default "";
+
+ /**
+ * 反射类型
+ */
+ Class fieldType() default Class.class;
+
+ /**
+ * 字段归属组（根据分组导出导入）
+ */
+ int[] groups() default {};
+}
diff --git a/src/main/java/org/example/core/utils/excel/fieldtype/ListType.java b/src/main/java/org/example/core/utils/excel/fieldtype/ListType.java
new file mode 100644
index 0000000..864356c
--- /dev/null
+++ b/src/main/java/org/example/core/utils/excel/fieldtype/ListType.java
@@ -0,0 +1,55 @@
+/**
+ * Copyright © 2015-2020 JeePlus All rights reserved.
+ */
+package org.example.core.utils.excel.fieldtype;
+
+import java.util.List;
+import org.apache.commons.compress.utils.Lists;
+import org.apache.commons.lang3.StringUtils;
+
+/**
+ * 字段类型转换
+ * @author jeeplus
+ * @version 2016-5-29
+ */
+public class ListType {
+
+ /**
+ * 获取对象值（导入）
+ */
+ public static Object getValue(String val) {
+ List list = Lists.newArrayList();
+ if(!StringUtils.isBlank(val)) {
+ for (String s : val.split(",")) {
+ list.add(s);
+ }
+ }
+ return list;
+ }
+
+ /**
+ * 设置对象值（导出）
+ */
+ public static String setValue(Object val) {
+ if (val != null){
+ List list = (List)val;
+ StringBuffer sb = null;
+ for (String item: list){
+ if(StringUtils.isBlank(item)){
+ continue;
+ }
+ if(sb == null){
+ sb = new StringBuffer(item);
+ }else{
+ sb.append(",").append(item);
+ }
+ }
+
+ if(sb!=null) {
+ return sb.toString().replace("[]", "");
+ }
+ }
+ return "";
+ }
+
+}
diff --git a/src/main/java/org/example/core/utils/file/Md5Util.java b/src/main/java/org/example/core/utils/file/Md5Util.java
new file mode 100644
index 0000000..6a48103
--- /dev/null
+++ b/src/main/java/org/example/core/utils/file/Md5Util.java
@@ -0,0 +1,37 @@
+package org.example.core.utils.file;
+
+import java.security.MessageDigest;
+
+
+/**
+ * MD5工具类
+ * ClassName: MD5Util
+ * date: 2018年1月13日 下午6:54:53
+ *
+ * @author Bool
+ * @version
+ */
+public class Md5Util {
+
+
+ /**
+ * 简单MD5
+ * @param str
+ * @return
+ */
+ public static String md5(String str) {
+
+ try {
+ MessageDigest md = MessageDigest.getInstance("MD5");
+ byte[] array = md.digest(str.getBytes("UTF-8"));
+ StringBuilder sb = new StringBuilder();
+ for (byte item : array) {
+ sb.append(Integer.toHexString((item & 0xFF) | 0x100).substring(1, 3));
+ }
+ return sb.toString();
+ }catch(Exception e) {
+ return null;
+ }
+ }
+
+}
diff --git a/src/main/java/org/example/core/utils/jackson/JsonHelper.java b/src/main/java/org/example/core/utils/jackson/JsonHelper.java
new file mode 100644
index 0000000..539699a
--- /dev/null
+++ b/src/main/java/org/example/core/utils/jackson/JsonHelper.java
@@ -0,0 +1,116 @@
+package org.example.core.utils.jackson;
+
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.databind.exc.InvalidFormatException;
+import java.io.IOException;
+import java.util.TimeZone;
+import org.example.core.exception.ServiceException;
+
+/**
+ * JSON工具类
+ * @author van
+ */
+public class JsonHelper {
+
+ /**
+ * 转换为字符串
+ * @param obj
+ * @return
+ */
+ public static String toJson(Object obj) {
+
+ ObjectMapper mapper = getMapper();
+
+ try {
+ return mapper.writeValueAsString(obj);
+ } catch (JsonProcessingException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 将字符转换为java对象
+ * @param json
+ * @param clazz
+ * @return
+ */
+ public static T parseObject(String json, Class clazz) {
+ ObjectMapper mapper = getMapper();
+ try {
+ return mapper.readValue(json, clazz);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 将对象转换为另外一个对象
+ * @param object
+ * @param clazz
+ * @return
+ */
+ public static T parseObject(Object object, Class clazz) {
+ ObjectMapper mapper = getMapper();
+ try {
+ return mapper.readValue(toJson(object), clazz);
+ } catch (InvalidFormatException e){
+ throw new ServiceException("数据格式存在错误！");
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 复杂对象的转换
+ * @param object
+ * @param typeReference
+ * @return
+ * @param
+ */
+ public static T parseObject(Object object, TypeReference typeReference) {
+ ObjectMapper mapper = getMapper();
+ try {
+ return mapper.readValue(toJson(object), typeReference);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 复杂对象的转换
+ * @param json
+ * @param typeReference
+ * @return
+ * @param
+ */
+ public static T parseObject(String json, TypeReference typeReference) {
+ ObjectMapper mapper = getMapper();
+ try {
+ return mapper.readValue(json, typeReference);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 获取转换配置
+ * @return
+ */
+ public static ObjectMapper getMapper(){
+ ObjectMapper mapper = new ObjectMapper();
+ mapper.setDateFormat(new MyDateFormat());
+ mapper.setTimeZone(TimeZone.getTimeZone("GMT+8"));
+
+ mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+ mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+ mapper.configure(JsonParser.Feature.ALLOW_UNQUOTED_CONTROL_CHARS, true);
+ mapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true);
+ mapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
+ return mapper;
+ }
+}
diff --git a/src/main/java/org/example/core/utils/jackson/MyDateFormat.java b/src/main/java/org/example/core/utils/jackson/MyDateFormat.java
new file mode 100644
index 0000000..eab1902
--- /dev/null
+++ b/src/main/java/org/example/core/utils/jackson/MyDateFormat.java
@@ -0,0 +1,36 @@
+package org.example.core.utils.jackson;
+
+import com.fasterxml.jackson.databind.util.StdDateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * JSON时间格式类，用于兼容不同类型日期
+ * @author van
+ */
+public class MyDateFormat extends SimpleDateFormat {
+
+ private StdDateFormat stdDateFormat = new StdDateFormat();
+
+ public MyDateFormat() {
+ // 设置默认的日期格式
+ super("yyyy-MM-dd HH:mm:ss");
+ }
+
+ @Override
+ public Date parse(String dateStr) throws ParseException {
+ if (dateStr != null && !dateStr.contains("T")) {
+ return super.parse(dateStr);
+ }
+ return stdDateFormat.parse(dateStr);
+ }
+
+ @Override
+ public Object clone() {
+ MyDateFormat other = (MyDateFormat)super.clone();
+ other.stdDateFormat = new StdDateFormat();
+ return other;
+ }
+
+}
diff --git a/src/main/java/org/example/dto/TaskCallbackDataDto.java b/src/main/java/org/example/dto/TaskCallbackDataDto.java
new file mode 100644
index 0000000..7641210
--- /dev/null
+++ b/src/main/java/org/example/dto/TaskCallbackDataDto.java
@@ -0,0 +1,169 @@
+package org.example.dto;
+
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
+import java.util.List;
+import lombok.Data;
+
+/**
+ * @description: 任务单通电话回调传输data
+ * @author: haown
+ * @create: 2024-08-29 09:36
+ **/
+@Data
+public class TaskCallbackDataDto {
+
+ /**
+ * 通话唯一标识
+ */
+ private String sessionId;
+
+ /**
+ * 租户唯一标识
+ */
+ private Long tenantId;
+
+ /**
+ * 任务标识
+ */
+ private String taskId;
+
+ /**
+ * 任务名称
+ */
+ private String taskName;
+
+ /**
+ * 机器人ID
+ */
+ private String robotId;
+
+ /**
+ * 外呼机器人名称
+ */
+ private String robotName;
+
+ /**
+ * 号码组唯一标识，导入名单后，返回的名单号码组对应标识
+ */
+ private Long memberId;
+
+ /**
+ * 被叫号码
+ */
+ private String mobile;
+
+ /**
+ * 拨打次数
+ */
+ private Integer callTimes;
+
+ /**
+ * 主叫号码
+ */
+ private String callerNum;
+
+ /**
+ * 接通状态，1-已接通 0-未接通
+ */
+ private Integer endType;
+ /**
+ * 呼叫类型，0-首次呼叫；1-重试；2-预约呼叫；3-实时呼叫
+ */
+ private Integer callType;
+
+ /**
+ * 未接通原因
+ */
+ private String endTypeReason;
+
+ /**
+ * 生成通话录音唯一标识,可通过该标识，获取录音
+ */
+ private String contactUUID;
+
+ /**
+ * 文件id，名单导入任务时生成的文件ID
+ */
+ private Long field;
+
+ /**
+ * 信息收集内容
+ */
+ private JSONObject collectInfo;
+
+ /**
+ * 会话还原记录
+ */
+ private JSONArray record;
+
+ /**
+ * 拨号总时长，单位为秒
+ */
+ private Integer durationTimeLen;
+
+ /**
+ * 振铃时长，单位为秒
+ */
+ private Integer ringingTimeLen;
+
+ /**
+ * 对话时长，单位为秒
+ */
+ private Integer talkingTimeLen;
+
+ /**
+ * 呼叫开始时间-Unix时间戳(单位:毫秒)
+ */
+ private Long startTime;
+
+ /**
+ * 振铃开始时间-Unix时间戳(单位:毫秒)
+ */
+ private Long ringStartTime;
+
+ /**
+ * 通话开始时间-Unix时间戳(单位:毫秒)，未接通显示'-'，已接通会有值
+ */
+ private Long talkingStartTime;
+
+ /**
+ * 呼叫结束时间-Unix时间戳(单位:毫秒)
+ */
+ private Long endTime;
+
+ /**
+ * 意向，在外呼机器人-流程节点-信息收集，配置key为「意向」，对应的value值
+ */
+ private String intent;
+
+ /**
+ * 动作，HUNGUP：挂机
+ */
+ private List action;
+
+ /**
+ * 是否机器人主动挂机
+ */
+ private Boolean isRobotHangup;
+
+ /**
+ * 变量，导入名单的变量
+ */
+ private JSONObject dialogVar;
+
+ /**
+ * 短信变量
+ */
+ private JSONObject smsVar;
+
+ /**
+ * 来自导入信息
+ */
+ private String extJson;
+
+ /**
+ * 转接结果,字段为空或值为0未发起，1成功，-1失败
+ */
+ private Integer transResult;
+}
diff --git a/src/main/java/org/example/dto/TaskCallbackDto.java b/src/main/java/org/example/dto/TaskCallbackDto.java
new file mode 100644
index 0000000..96617af
--- /dev/null
+++ b/src/main/java/org/example/dto/TaskCallbackDto.java
@@ -0,0 +1,22 @@
+package org.example.dto;
+
+import lombok.Data;
+
+/**
+ * @description: 任务单通电话回调传输对象
+ * @author: haown
+ * @create: 2024-08-29 14:06
+ **/
+@Data
+public class TaskCallbackDto {
+
+ /**
+ * 回调数据类型， 0-任务呼叫单通电话回调 1-号码组终态回调 2-任务状态变更回调 3-实时呼叫单通电话回调
+ */
+ private Integer callbackType;
+
+ /**
+ * 任务单通电话回调传输data
+ */
+ private TaskCallbackDataDto data;
+}
diff --git a/src/main/java/org/example/entity/AIOBCallbackEntity.java b/src/main/java/org/example/entity/AIOBCallbackEntity.java
new file mode 100644
index 0000000..739f28d
--- /dev/null
+++ b/src/main/java/org/example/entity/AIOBCallbackEntity.java
@@ -0,0 +1,49 @@
+package org.example.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * @description: 百度外呼回调传输对象
+ * @author: haown
+ * @create: 2025-12-22 15:11
+ **/
+@Data
+@TableName("aiob_callback_data")
+public class AIOBCallbackEntity extends Model {
+
+ /**
+ * 主键
+ */
+ @TableId(value = "id", type = IdType.AUTO)
+ private Integer id;
+
+ /**
+ * 回调数据类型， 0-任务呼叫单通电话回调 1-号码组终态回调 2-任务状态变更回调 3-实时呼叫单通电话回调
+ */
+ private Integer callbackType;
+
+ /**
+ * 回调数据
+ */
+ private String callbackData;
+
+ /**
+ * 已读状态，0：未读，1：已读
+ */
+ private Integer readState;
+
+ /**
+ * 创建时间
+ */
+ private Date createDate;
+
+ /**
+ * 修改时间
+ */
+ private Date updateDate;
+}
diff --git a/src/main/java/org/example/mapper/AIOBCallbackMapper.java b/src/main/java/org/example/mapper/AIOBCallbackMapper.java
new file mode 100644
index 0000000..3ba5836
--- /dev/null
+++ b/src/main/java/org/example/mapper/AIOBCallbackMapper.java
@@ -0,0 +1,8 @@
+package org.example.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.example.entity.AIOBCallbackEntity;
+
+public interface AIOBCallbackMapper extends BaseMapper {
+
+}
diff --git a/src/main/java/org/example/service/IAIOBCallbackService.java b/src/main/java/org/example/service/IAIOBCallbackService.java
new file mode 100644
index 0000000..c528b7c
--- /dev/null
+++ b/src/main/java/org/example/service/IAIOBCallbackService.java
@@ -0,0 +1,16 @@
+package org.example.service;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.extension.service.IService;
+import org.example.dto.TaskCallbackDataDto;
+import org.example.entity.AIOBCallbackEntity;
+
+/**
+ * @description: 百度外呼回调service
+ * @author: haown
+ * @create: 2025-12-22 15:11
+ **/
+public interface IAIOBCallbackService extends IService {
+
+ JSONObject taskCallBack(Integer callbackType, TaskCallbackDataDto data);
+}
diff --git a/src/main/java/org/example/service/impl/AIOBCallbackServiceImpl.java b/src/main/java/org/example/service/impl/AIOBCallbackServiceImpl.java
new file mode 100644
index 0000000..bdadea8
--- /dev/null
+++ b/src/main/java/org/example/service/impl/AIOBCallbackServiceImpl.java
@@ -0,0 +1,39 @@
+package org.example.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import java.util.Date;
+import javax.annotation.Resource;
+import org.example.dto.TaskCallbackDataDto;
+import org.example.entity.AIOBCallbackEntity;
+import org.example.mapper.AIOBCallbackMapper;
+import org.example.service.IAIOBCallbackService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @description: 百度外呼回调service实现类
+ * @author: haown
+ * @create: 2025-12-22 15:22
+ **/
+@Service
+public class AIOBCallbackServiceImpl extends ServiceImpl implements IAIOBCallbackService {
+
+ @Resource
+ private AIOBCallbackMapper aiobCallbackMapper;
+
+ @Override public JSONObject taskCallBack(Integer callbackType, TaskCallbackDataDto data) {
+ JSONObject retObj = new JSONObject();
+ retObj.fluentPut("code", 200).fluentPut("msg", "success");
+ if (callbackType == 0 || callbackType == 3) {
+ // 保存
+ AIOBCallbackEntity aiobCallbackEntity = new AIOBCallbackEntity();
+ aiobCallbackEntity.setCallbackType(callbackType);
+ aiobCallbackEntity.setCallbackData(JSON.toJSONString(data));
+ aiobCallbackEntity.setReadState(0);
+ aiobCallbackEntity.setCreateDate(new Date());
+ aiobCallbackMapper.insert(aiobCallbackEntity);
+ }
+ return retObj;
+ }
+}
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
new file mode 100644
index 0000000..ee330e2
--- /dev/null
+++ b/src/main/resources/application-dev.yml
@@ -0,0 +1,36 @@
+# 开发环境配置文件
+spring:
+ # 数据库配置
+ datasource:
+ type: com.alibaba.druid.pool.DruidDataSource
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ url: jdbc:mysql://8.131.93.145:54081/aiob_callback?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
+ username: root
+ password: 1qaz!@#$
+ # druid相关配置
+ druid:
+ max-active: 5000
+ initial-size: 20
+ min-idle: 5
+ async-init: true
+ # 监控统计
+ filters: stat,wall
+ filter:
+ stat:
+ log-slow-sql: true
+ slow-sql-millis: 5000
+ wall:
+ config:
+ create-table-allow: false
+ alter-table-allow: false
+ drop-table-allow: false
+ truncate-allow: false
+
+# 开启文档
+swagger:
+ enable: true
+
+logging:
+ level:
+ root: debug
+ path: logs/${spring.application.name}/
diff --git a/src/main/resources/application-local.yml b/src/main/resources/application-local.yml
new file mode 100644
index 0000000..c8befae
--- /dev/null
+++ b/src/main/resources/application-local.yml
@@ -0,0 +1,93 @@
+# 独立配置文件，可以拿到jar外面跑
+spring:
+ application:
+ name: yf-exam-lite
+ profiles:
+ active: dev
+ main:
+ allow-bean-definition-overriding: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ default-property-inclusion: non_null
+ deserialization:
+ fail_on_unknown_properties: false
+ parser:
+ # 允许出现特殊字符和转义符
+ allow_unquoted_control_chars: true
+ #允许出现单引号
+ allow_single_quotes: true
+ serialization:
+ fail-on-empty-beans: false
+ mapper:
+ # 支持类型转换
+ allow-coercion-of-scalars: true
+
+ # 数据库配置
+ datasource:
+ type: com.alibaba.druid.pool.DruidDataSource
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ url: jdbc:mysql://localhost:3306/yf_exam_lite?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
+ username: root
+ password: root
+ # druid相关配置
+ druid:
+ max-active: 5000
+ initial-size: 20
+ min-idle: 5
+ async-init: true
+ # 监控统计
+ filters: stat,wall
+ filter:
+ stat:
+ log-slow-sql: true
+ slow-sql-millis: 5000
+ wall:
+ config:
+ create-table-allow: false
+ alter-table-allow: false
+ drop-table-allow: false
+ truncate-allow: false
+
+server:
+ port: 8101
+ # 启用服务端压缩
+ compression:
+ enabled: true
+ min-response-size: 10
+ mime-types: application/json,application/xml,text/html,text/xml,text/plain,application/javascript,text/css
+
+# 文件上传配置
+conf:
+ upload:
+ # 物理文件存储位置，以/结束，windows已正斜杠，如：d:/exam-upload/
+ dir: /data/upload/
+ # 访问地址，注意不要去除/upload/file/，此节点为虚拟标识符
+ # 如：http://localhost:8101/upload/file/exam.jpg，对应物理文件为：/data/upload/exam.jpg
+ url: http://8.131.93.145:54012/upload/file/
+ # 允许上传的文件后缀
+ allow-extensions: jpg,jpeg,png
+ folder:
+ # 身份证正面存储文件夹名称
+ card_front_url: cardfront/
+ # 身份证背面存储文件夹名称
+ card_back_url: cardback/
+ # 身份证正反面复印件
+ card_copy_url: cardcopy/
+ # 证件照
+ photo_url: photo/
+ # 学历证明
+ certificate_url: certificate/
+ # 体检报告
+ physical_report_url: physicalreport/
+ # 签名图片
+ sign_picture_url: signpicture/
+
+# 开启文档
+swagger:
+ enable: true
+
+logging:
+ level:
+ root: debug
+ path: logs/${spring.application.name}/
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
new file mode 100644
index 0000000..ef4e30b
--- /dev/null
+++ b/src/main/resources/application.yml
@@ -0,0 +1,33 @@
+spring:
+ application:
+ name: aiob-callback
+ profiles:
+ active: dev
+ main:
+ allow-bean-definition-overriding: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ default-property-inclusion: non_null
+ deserialization:
+ fail_on_unknown_properties: false
+ parser:
+ # 允许出现特殊字符和转义符
+ allow_unquoted_control_chars: true
+ #允许出现单引号
+ allow_single_quotes: true
+ serialization:
+ fail-on-empty-beans: false
+ mapper:
+ # 支持类型转换
+ allow-coercion-of-scalars: true
+server:
+ port: 8101
+ servlet:
+ # 应用的访问路径
+ context-path: /
+ # 启用服务端压缩
+ compression:
+ enabled: true
+ min-response-size: 10
+ mime-types: application/json,application/xml,text/html,text/xml,text/plain,application/javascript,text/css
diff --git a/src/main/resources/mapper/AIOBCallbackMapper.xml b/src/main/resources/mapper/AIOBCallbackMapper.xml
new file mode 100644
index 0000000..7af00e4
--- /dev/null
+++ b/src/main/resources/mapper/AIOBCallbackMapper.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ id, callback_type, callback_data, read_state, create_date, update_date
+
+
+
diff --git a/target/classes/application-dev.yml b/target/classes/application-dev.yml
new file mode 100644
index 0000000..ee330e2
--- /dev/null
+++ b/target/classes/application-dev.yml
@@ -0,0 +1,36 @@
+# 开发环境配置文件
+spring:
+ # 数据库配置
+ datasource:
+ type: com.alibaba.druid.pool.DruidDataSource
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ url: jdbc:mysql://8.131.93.145:54081/aiob_callback?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
+ username: root
+ password: 1qaz!@#$
+ # druid相关配置
+ druid:
+ max-active: 5000
+ initial-size: 20
+ min-idle: 5
+ async-init: true
+ # 监控统计
+ filters: stat,wall
+ filter:
+ stat:
+ log-slow-sql: true
+ slow-sql-millis: 5000
+ wall:
+ config:
+ create-table-allow: false
+ alter-table-allow: false
+ drop-table-allow: false
+ truncate-allow: false
+
+# 开启文档
+swagger:
+ enable: true
+
+logging:
+ level:
+ root: debug
+ path: logs/${spring.application.name}/
diff --git a/target/classes/application-local.yml b/target/classes/application-local.yml
new file mode 100644
index 0000000..c8befae
--- /dev/null
+++ b/target/classes/application-local.yml
@@ -0,0 +1,93 @@
+# 独立配置文件，可以拿到jar外面跑
+spring:
+ application:
+ name: yf-exam-lite
+ profiles:
+ active: dev
+ main:
+ allow-bean-definition-overriding: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ default-property-inclusion: non_null
+ deserialization:
+ fail_on_unknown_properties: false
+ parser:
+ # 允许出现特殊字符和转义符
+ allow_unquoted_control_chars: true
+ #允许出现单引号
+ allow_single_quotes: true
+ serialization:
+ fail-on-empty-beans: false
+ mapper:
+ # 支持类型转换
+ allow-coercion-of-scalars: true
+
+ # 数据库配置
+ datasource:
+ type: com.alibaba.druid.pool.DruidDataSource
+ driver-class-name: com.mysql.cj.jdbc.Driver
+ url: jdbc:mysql://localhost:3306/yf_exam_lite?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
+ username: root
+ password: root
+ # druid相关配置
+ druid:
+ max-active: 5000
+ initial-size: 20
+ min-idle: 5
+ async-init: true
+ # 监控统计
+ filters: stat,wall
+ filter:
+ stat:
+ log-slow-sql: true
+ slow-sql-millis: 5000
+ wall:
+ config:
+ create-table-allow: false
+ alter-table-allow: false
+ drop-table-allow: false
+ truncate-allow: false
+
+server:
+ port: 8101
+ # 启用服务端压缩
+ compression:
+ enabled: true
+ min-response-size: 10
+ mime-types: application/json,application/xml,text/html,text/xml,text/plain,application/javascript,text/css
+
+# 文件上传配置
+conf:
+ upload:
+ # 物理文件存储位置，以/结束，windows已正斜杠，如：d:/exam-upload/
+ dir: /data/upload/
+ # 访问地址，注意不要去除/upload/file/，此节点为虚拟标识符
+ # 如：http://localhost:8101/upload/file/exam.jpg，对应物理文件为：/data/upload/exam.jpg
+ url: http://8.131.93.145:54012/upload/file/
+ # 允许上传的文件后缀
+ allow-extensions: jpg,jpeg,png
+ folder:
+ # 身份证正面存储文件夹名称
+ card_front_url: cardfront/
+ # 身份证背面存储文件夹名称
+ card_back_url: cardback/
+ # 身份证正反面复印件
+ card_copy_url: cardcopy/
+ # 证件照
+ photo_url: photo/
+ # 学历证明
+ certificate_url: certificate/
+ # 体检报告
+ physical_report_url: physicalreport/
+ # 签名图片
+ sign_picture_url: signpicture/
+
+# 开启文档
+swagger:
+ enable: true
+
+logging:
+ level:
+ root: debug
+ path: logs/${spring.application.name}/
diff --git a/target/classes/application.yml b/target/classes/application.yml
new file mode 100644
index 0000000..ef4e30b
--- /dev/null
+++ b/target/classes/application.yml
@@ -0,0 +1,33 @@
+spring:
+ application:
+ name: aiob-callback
+ profiles:
+ active: dev
+ main:
+ allow-bean-definition-overriding: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ default-property-inclusion: non_null
+ deserialization:
+ fail_on_unknown_properties: false
+ parser:
+ # 允许出现特殊字符和转义符
+ allow_unquoted_control_chars: true
+ #允许出现单引号
+ allow_single_quotes: true
+ serialization:
+ fail-on-empty-beans: false
+ mapper:
+ # 支持类型转换
+ allow-coercion-of-scalars: true
+server:
+ port: 8101
+ servlet:
+ # 应用的访问路径
+ context-path: /
+ # 启用服务端压缩
+ compression:
+ enabled: true
+ min-response-size: 10
+ mime-types: application/json,application/xml,text/html,text/xml,text/plain,application/javascript,text/css
diff --git a/target/classes/mapper/AIOBCallbackMapper.xml b/target/classes/mapper/AIOBCallbackMapper.xml
new file mode 100644
index 0000000..7af00e4
--- /dev/null
+++ b/target/classes/mapper/AIOBCallbackMapper.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ id, callback_type, callback_data, read_state, create_date, update_date
+
+
+
diff --git a/target/classes/org/example/AIOBCallbackApplication.class b/target/classes/org/example/AIOBCallbackApplication.class
new file mode 100644
index 0000000..91e1035
Binary files /dev/null and b/target/classes/org/example/AIOBCallbackApplication.class differ
diff --git a/target/classes/org/example/ability/shiro/CNFilterFactoryBean.class b/target/classes/org/example/ability/shiro/CNFilterFactoryBean.class
new file mode 100644
index 0000000..3504f16
Binary files /dev/null and b/target/classes/org/example/ability/shiro/CNFilterFactoryBean.class differ
diff --git a/target/classes/org/example/ability/shiro/ShiroRealm.class b/target/classes/org/example/ability/shiro/ShiroRealm.class
new file mode 100644
index 0000000..2a04ae6
Binary files /dev/null and b/target/classes/org/example/ability/shiro/ShiroRealm.class differ
diff --git a/target/classes/org/example/ability/shiro/aop/JwtFilter.class b/target/classes/org/example/ability/shiro/aop/JwtFilter.class
new file mode 100644
index 0000000..f3bdd1c
Binary files /dev/null and b/target/classes/org/example/ability/shiro/aop/JwtFilter.class differ
diff --git a/target/classes/org/example/ability/shiro/jwt/JwtToken.class b/target/classes/org/example/ability/shiro/jwt/JwtToken.class
new file mode 100644
index 0000000..9851eb6
Binary files /dev/null and b/target/classes/org/example/ability/shiro/jwt/JwtToken.class differ
diff --git a/target/classes/org/example/ability/shiro/jwt/JwtUtils.class b/target/classes/org/example/ability/shiro/jwt/JwtUtils.class
new file mode 100644
index 0000000..5aaf1b6
Binary files /dev/null and b/target/classes/org/example/ability/shiro/jwt/JwtUtils.class differ
diff --git a/target/classes/org/example/aspect/mybatis/QueryInterceptor.class b/target/classes/org/example/aspect/mybatis/QueryInterceptor.class
new file mode 100644
index 0000000..b682a5a
Binary files /dev/null and b/target/classes/org/example/aspect/mybatis/QueryInterceptor.class differ
diff --git a/target/classes/org/example/aspect/mybatis/UpdateInterceptor.class b/target/classes/org/example/aspect/mybatis/UpdateInterceptor.class
new file mode 100644
index 0000000..6f1be67
Binary files /dev/null and b/target/classes/org/example/aspect/mybatis/UpdateInterceptor.class differ
diff --git a/target/classes/org/example/aspect/utils/InjectUtils.class b/target/classes/org/example/aspect/utils/InjectUtils.class
new file mode 100644
index 0000000..d4a809a
Binary files /dev/null and b/target/classes/org/example/aspect/utils/InjectUtils.class differ
diff --git a/target/classes/org/example/config/CorsConfig.class b/target/classes/org/example/config/CorsConfig.class
new file mode 100644
index 0000000..cb6021a
Binary files /dev/null and b/target/classes/org/example/config/CorsConfig.class differ
diff --git a/target/classes/org/example/config/MultipartConfig.class b/target/classes/org/example/config/MultipartConfig.class
new file mode 100644
index 0000000..00a1dbe
Binary files /dev/null and b/target/classes/org/example/config/MultipartConfig.class differ
diff --git a/target/classes/org/example/config/MybatisConfig.class b/target/classes/org/example/config/MybatisConfig.class
new file mode 100644
index 0000000..b448818
Binary files /dev/null and b/target/classes/org/example/config/MybatisConfig.class differ
diff --git a/target/classes/org/example/config/ScheduledConfig.class b/target/classes/org/example/config/ScheduledConfig.class
new file mode 100644
index 0000000..9cca7e5
Binary files /dev/null and b/target/classes/org/example/config/ScheduledConfig.class differ
diff --git a/target/classes/org/example/config/ShiroConfig.class b/target/classes/org/example/config/ShiroConfig.class
new file mode 100644
index 0000000..1a6a1e3
Binary files /dev/null and b/target/classes/org/example/config/ShiroConfig.class differ
diff --git a/target/classes/org/example/config/SwaggerConfig.class b/target/classes/org/example/config/SwaggerConfig.class
new file mode 100644
index 0000000..d6a94b1
Binary files /dev/null and b/target/classes/org/example/config/SwaggerConfig.class differ
diff --git a/target/classes/org/example/config/jackson/JacksonConfig.class b/target/classes/org/example/config/jackson/JacksonConfig.class
new file mode 100644
index 0000000..2caec8d
Binary files /dev/null and b/target/classes/org/example/config/jackson/JacksonConfig.class differ
diff --git a/target/classes/org/example/config/jackson/XssEscapeJsonDeserializer.class b/target/classes/org/example/config/jackson/XssEscapeJsonDeserializer.class
new file mode 100644
index 0000000..af6e8ab
Binary files /dev/null and b/target/classes/org/example/config/jackson/XssEscapeJsonDeserializer.class differ
diff --git a/target/classes/org/example/controller/AIOBCallbackController.class b/target/classes/org/example/controller/AIOBCallbackController.class
new file mode 100644
index 0000000..df20782
Binary files /dev/null and b/target/classes/org/example/controller/AIOBCallbackController.class differ
diff --git a/target/classes/org/example/core/annon/Dict.class b/target/classes/org/example/core/annon/Dict.class
new file mode 100644
index 0000000..5ae69f0
Binary files /dev/null and b/target/classes/org/example/core/annon/Dict.class differ
diff --git a/target/classes/org/example/core/api/ApiError.class b/target/classes/org/example/core/api/ApiError.class
new file mode 100644
index 0000000..fa791db
Binary files /dev/null and b/target/classes/org/example/core/api/ApiError.class differ
diff --git a/target/classes/org/example/core/api/ApiRest.class b/target/classes/org/example/core/api/ApiRest.class
new file mode 100644
index 0000000..7f9e5dc
Binary files /dev/null and b/target/classes/org/example/core/api/ApiRest.class differ
diff --git a/target/classes/org/example/core/api/controller/BaseController.class b/target/classes/org/example/core/api/controller/BaseController.class
new file mode 100644
index 0000000..f04f7c3
Binary files /dev/null and b/target/classes/org/example/core/api/controller/BaseController.class differ
diff --git a/target/classes/org/example/core/api/dto/BaseDTO.class b/target/classes/org/example/core/api/dto/BaseDTO.class
new file mode 100644
index 0000000..d3c75cb
Binary files /dev/null and b/target/classes/org/example/core/api/dto/BaseDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/BaseIdReqDTO.class b/target/classes/org/example/core/api/dto/BaseIdReqDTO.class
new file mode 100644
index 0000000..9355eec
Binary files /dev/null and b/target/classes/org/example/core/api/dto/BaseIdReqDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/BaseIdRespDTO.class b/target/classes/org/example/core/api/dto/BaseIdRespDTO.class
new file mode 100644
index 0000000..df99ba0
Binary files /dev/null and b/target/classes/org/example/core/api/dto/BaseIdRespDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/BaseIdsReqDTO.class b/target/classes/org/example/core/api/dto/BaseIdsReqDTO.class
new file mode 100644
index 0000000..7e1c6b4
Binary files /dev/null and b/target/classes/org/example/core/api/dto/BaseIdsReqDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/BaseStateReqDTO.class b/target/classes/org/example/core/api/dto/BaseStateReqDTO.class
new file mode 100644
index 0000000..1847c43
Binary files /dev/null and b/target/classes/org/example/core/api/dto/BaseStateReqDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/PagingReqDTO.class b/target/classes/org/example/core/api/dto/PagingReqDTO.class
new file mode 100644
index 0000000..16ea15b
Binary files /dev/null and b/target/classes/org/example/core/api/dto/PagingReqDTO.class differ
diff --git a/target/classes/org/example/core/api/dto/PagingRespDTO.class b/target/classes/org/example/core/api/dto/PagingRespDTO.class
new file mode 100644
index 0000000..9f3b368
Binary files /dev/null and b/target/classes/org/example/core/api/dto/PagingRespDTO.class differ
diff --git a/target/classes/org/example/core/api/utils/JsonConverter.class b/target/classes/org/example/core/api/utils/JsonConverter.class
new file mode 100644
index 0000000..e6fb999
Binary files /dev/null and b/target/classes/org/example/core/api/utils/JsonConverter.class differ
diff --git a/target/classes/org/example/core/domain/AjaxResult.class b/target/classes/org/example/core/domain/AjaxResult.class
new file mode 100644
index 0000000..4fd5172
Binary files /dev/null and b/target/classes/org/example/core/domain/AjaxResult.class differ
diff --git a/target/classes/org/example/core/enums/CommonState.class b/target/classes/org/example/core/enums/CommonState.class
new file mode 100644
index 0000000..65b3d23
Binary files /dev/null and b/target/classes/org/example/core/enums/CommonState.class differ
diff --git a/target/classes/org/example/core/enums/ConfirmRefundStatusEnum.class b/target/classes/org/example/core/enums/ConfirmRefundStatusEnum.class
new file mode 100644
index 0000000..2041b82
Binary files /dev/null and b/target/classes/org/example/core/enums/ConfirmRefundStatusEnum.class differ
diff --git a/target/classes/org/example/core/enums/GooodsOrderStatusEnum.class b/target/classes/org/example/core/enums/GooodsOrderStatusEnum.class
new file mode 100644
index 0000000..30c88ae
Binary files /dev/null and b/target/classes/org/example/core/enums/GooodsOrderStatusEnum.class differ
diff --git a/target/classes/org/example/core/enums/OpenType.class b/target/classes/org/example/core/enums/OpenType.class
new file mode 100644
index 0000000..3f30661
Binary files /dev/null and b/target/classes/org/example/core/enums/OpenType.class differ
diff --git a/target/classes/org/example/core/enums/PayTypeEnum.class b/target/classes/org/example/core/enums/PayTypeEnum.class
new file mode 100644
index 0000000..e583d05
Binary files /dev/null and b/target/classes/org/example/core/enums/PayTypeEnum.class differ
diff --git a/target/classes/org/example/core/enums/RefundStatusEnum.class b/target/classes/org/example/core/enums/RefundStatusEnum.class
new file mode 100644
index 0000000..68f4e3f
Binary files /dev/null and b/target/classes/org/example/core/enums/RefundStatusEnum.class differ
diff --git a/target/classes/org/example/core/enums/WeChatTradeStateEnum.class b/target/classes/org/example/core/enums/WeChatTradeStateEnum.class
new file mode 100644
index 0000000..d33bee2
Binary files /dev/null and b/target/classes/org/example/core/enums/WeChatTradeStateEnum.class differ
diff --git a/target/classes/org/example/core/exception/ServiceException.class b/target/classes/org/example/core/exception/ServiceException.class
new file mode 100644
index 0000000..7b55bfc
Binary files /dev/null and b/target/classes/org/example/core/exception/ServiceException.class differ
diff --git a/target/classes/org/example/core/exception/ServiceExceptionHandler.class b/target/classes/org/example/core/exception/ServiceExceptionHandler.class
new file mode 100644
index 0000000..38ccbfd
Binary files /dev/null and b/target/classes/org/example/core/exception/ServiceExceptionHandler.class differ
diff --git a/target/classes/org/example/core/utils/BeanMapper.class b/target/classes/org/example/core/utils/BeanMapper.class
new file mode 100644
index 0000000..e4a6818
Binary files /dev/null and b/target/classes/org/example/core/utils/BeanMapper.class differ
diff --git a/target/classes/org/example/core/utils/CronUtils.class b/target/classes/org/example/core/utils/CronUtils.class
new file mode 100644
index 0000000..5b0fe9f
Binary files /dev/null and b/target/classes/org/example/core/utils/CronUtils.class differ
diff --git a/target/classes/org/example/core/utils/DateUtils.class b/target/classes/org/example/core/utils/DateUtils.class
new file mode 100644
index 0000000..5c1f2ce
Binary files /dev/null and b/target/classes/org/example/core/utils/DateUtils.class differ
diff --git a/target/classes/org/example/core/utils/IpUtils.class b/target/classes/org/example/core/utils/IpUtils.class
new file mode 100644
index 0000000..2c6f7da
Binary files /dev/null and b/target/classes/org/example/core/utils/IpUtils.class differ
diff --git a/target/classes/org/example/core/utils/Reflections.class b/target/classes/org/example/core/utils/Reflections.class
new file mode 100644
index 0000000..e8e166d
Binary files /dev/null and b/target/classes/org/example/core/utils/Reflections.class differ
diff --git a/target/classes/org/example/core/utils/SpringUtils.class b/target/classes/org/example/core/utils/SpringUtils.class
new file mode 100644
index 0000000..4a9b5ef
Binary files /dev/null and b/target/classes/org/example/core/utils/SpringUtils.class differ
diff --git a/target/classes/org/example/core/utils/StringUtils.class b/target/classes/org/example/core/utils/StringUtils.class
new file mode 100644
index 0000000..06a7429
Binary files /dev/null and b/target/classes/org/example/core/utils/StringUtils.class differ
diff --git a/target/classes/org/example/core/utils/excel/ExportExcel$1.class b/target/classes/org/example/core/utils/excel/ExportExcel$1.class
new file mode 100644
index 0000000..bf36393
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/ExportExcel$1.class differ
diff --git a/target/classes/org/example/core/utils/excel/ExportExcel.class b/target/classes/org/example/core/utils/excel/ExportExcel.class
new file mode 100644
index 0000000..138e13f
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/ExportExcel.class differ
diff --git a/target/classes/org/example/core/utils/excel/ImportExcel$1.class b/target/classes/org/example/core/utils/excel/ImportExcel$1.class
new file mode 100644
index 0000000..a15bec7
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/ImportExcel$1.class differ
diff --git a/target/classes/org/example/core/utils/excel/ImportExcel.class b/target/classes/org/example/core/utils/excel/ImportExcel.class
new file mode 100644
index 0000000..b68827a
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/ImportExcel.class differ
diff --git a/target/classes/org/example/core/utils/excel/annotation/ExcelField.class b/target/classes/org/example/core/utils/excel/annotation/ExcelField.class
new file mode 100644
index 0000000..49080fc
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/annotation/ExcelField.class differ
diff --git a/target/classes/org/example/core/utils/excel/fieldtype/ListType.class b/target/classes/org/example/core/utils/excel/fieldtype/ListType.class
new file mode 100644
index 0000000..a67b8a3
Binary files /dev/null and b/target/classes/org/example/core/utils/excel/fieldtype/ListType.class differ
diff --git a/target/classes/org/example/core/utils/file/Md5Util.class b/target/classes/org/example/core/utils/file/Md5Util.class
new file mode 100644
index 0000000..54f10fc
Binary files /dev/null and b/target/classes/org/example/core/utils/file/Md5Util.class differ
diff --git a/target/classes/org/example/core/utils/jackson/JsonHelper.class b/target/classes/org/example/core/utils/jackson/JsonHelper.class
new file mode 100644
index 0000000..d285ac4
Binary files /dev/null and b/target/classes/org/example/core/utils/jackson/JsonHelper.class differ
diff --git a/target/classes/org/example/core/utils/jackson/MyDateFormat.class b/target/classes/org/example/core/utils/jackson/MyDateFormat.class
new file mode 100644
index 0000000..e32b8e3
Binary files /dev/null and b/target/classes/org/example/core/utils/jackson/MyDateFormat.class differ
diff --git a/target/classes/org/example/dto/TaskCallbackDataDto.class b/target/classes/org/example/dto/TaskCallbackDataDto.class
new file mode 100644
index 0000000..818b0e3
Binary files /dev/null and b/target/classes/org/example/dto/TaskCallbackDataDto.class differ
diff --git a/target/classes/org/example/dto/TaskCallbackDto.class b/target/classes/org/example/dto/TaskCallbackDto.class
new file mode 100644
index 0000000..731a56b
Binary files /dev/null and b/target/classes/org/example/dto/TaskCallbackDto.class differ
diff --git a/target/classes/org/example/entity/AIOBCallbackEntity.class b/target/classes/org/example/entity/AIOBCallbackEntity.class
new file mode 100644
index 0000000..1ffaa62
Binary files /dev/null and b/target/classes/org/example/entity/AIOBCallbackEntity.class differ
diff --git a/target/classes/org/example/mapper/AIOBCallbackMapper.class b/target/classes/org/example/mapper/AIOBCallbackMapper.class
new file mode 100644
index 0000000..65c01da
Binary files /dev/null and b/target/classes/org/example/mapper/AIOBCallbackMapper.class differ
diff --git a/target/classes/org/example/service/IAIOBCallbackService.class b/target/classes/org/example/service/IAIOBCallbackService.class
new file mode 100644
index 0000000..51da580
Binary files /dev/null and b/target/classes/org/example/service/IAIOBCallbackService.class differ
diff --git a/target/classes/org/example/service/impl/AIOBCallbackServiceImpl.class b/target/classes/org/example/service/impl/AIOBCallbackServiceImpl.class
new file mode 100644
index 0000000..1a42c12
Binary files /dev/null and b/target/classes/org/example/service/impl/AIOBCallbackServiceImpl.class differ