Compare commits

..

No commits in common. "dev-sky-serve-v1" and "master" have entirely different histories.

199 changed files with 3969 additions and 3653 deletions

15
pom.xml
View File

@ -9,19 +9,15 @@
<version>2.7.3</version> <version>2.7.3</version>
</parent> </parent>
<groupId>com.sky</groupId> <groupId>com.sky</groupId>
<artifactId>dev-sky-serve-v1</artifactId> <artifactId>sky-take-out</artifactId>
<packaging>pom</packaging> <packaging>pom</packaging>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<modules> <modules>
<module>sky-common</module> <module>sky-common</module>
<module>sky-pojo</module> <module>sky-pojo</module>
<module>sky-server</module> <module>sky-server</module>
</modules> </modules>
<properties> <properties>
<maven.compiler.source>18</maven.compiler.source>
<maven.compiler.target>18</maven.compiler.target>
<mybatis.spring>2.2.0</mybatis.spring> <mybatis.spring>2.2.0</mybatis.spring>
<lombok>1.18.20</lombok> <lombok>1.18.20</lombok>
<fastjson>1.2.76</fastjson> <fastjson>1.2.76</fastjson>
@ -29,12 +25,11 @@
<druid>1.2.1</druid> <druid>1.2.1</druid>
<pagehelper>1.3.0</pagehelper> <pagehelper>1.3.0</pagehelper>
<aliyun.sdk.oss>3.10.2</aliyun.sdk.oss> <aliyun.sdk.oss>3.10.2</aliyun.sdk.oss>
<knife4j>3.0.3</knife4j> <knife4j>3.0.2</knife4j>
<aspectj>1.9.4</aspectj> <aspectj>1.9.4</aspectj>
<jjwt>0.9.1</jjwt> <jjwt>0.9.1</jjwt>
<jaxb-api>2.3.1</jaxb-api> <jaxb-api>2.3.1</jaxb-api>
<poi>3.16</poi> <poi>3.16</poi>
<minio>8.4.3</minio>
</properties> </properties>
<dependencyManagement> <dependencyManagement>
<dependencies> <dependencies>
@ -127,12 +122,6 @@
<artifactId>wechatpay-apache-httpclient</artifactId> <artifactId>wechatpay-apache-httpclient</artifactId>
<version>0.4.8</version> <version>0.4.8</version>
</dependency> </dependency>
<!-- minio -->
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>${minio}</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>
</project> </project>

View File

@ -1,22 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>sky-take-out</artifactId>
<groupId>com.sky</groupId> <groupId>com.sky</groupId>
<artifactId>dev-sky-serve-v1</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>sky-common</artifactId> <artifactId>sky-common</artifactId>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.projectlombok</groupId> <groupId>org.projectlombok</groupId>
@ -38,11 +30,6 @@
<groupId>io.jsonwebtoken</groupId> <groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt</artifactId> <artifactId>jjwt</artifactId>
</dependency> </dependency>
<!-- redis -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--支持配置属性类yml文件中可以提示配置项--> <!--支持配置属性类yml文件中可以提示配置项-->
<dependency> <dependency>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
@ -62,20 +49,5 @@
<groupId>com.github.wechatpay-apiv3</groupId> <groupId>com.github.wechatpay-apiv3</groupId>
<artifactId>wechatpay-apache-httpclient</artifactId> <artifactId>wechatpay-apache-httpclient</artifactId>
</dependency> </dependency>
<!-- minio -->
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
</dependency>
<!-- websocket -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<!-- knife4j -->
<dependency>
<groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-spring-boot-starter</artifactId>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -1,57 +0,0 @@
package com.sky.common.config;
import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
@Configuration
@Slf4j
@EnableKnife4j
public class Knife4jConfiguration {
/**
* 通过knife4j生成接口文档
* 管理端接口
*
* @return Docket
*/
@Bean
public Docket docketAdmin() {
log.info("A管理端接口");
// 添加作者
Contact contact = new Contact("Bunny", "1319900154@qq.com", "1319900154@qq.com");
// API文档
ApiInfo apiInfo = new ApiInfoBuilder().title("苍穹外卖项目接口文档").version("2.0").description("苍穹外卖项目接口文档").contact(contact).build();
return new Docket(DocumentationType.SWAGGER_2).groupName("A管理端接口")
.apiInfo(apiInfo).select().apis(RequestHandlerSelectors.basePackage("com.sky.controller.admin"))
.paths(PathSelectors.any()).build();
}
@Bean
public Docket docketUser() {
log.info("B用户端接口");
ApiInfo apiInfo = new ApiInfoBuilder().title("苍穹外卖项目接口文档").version("2.0").description("苍穹外卖项目接口文档").build();
return new Docket(DocumentationType.SWAGGER_2).groupName("B用户端接口")
.apiInfo(apiInfo).select().apis(RequestHandlerSelectors.basePackage("com.sky.controller.user"))
.paths(PathSelectors.any()).build();
}
@Bean
public Docket docketNotify() {
log.info("Pay支付接口");
ApiInfo apiInfo = new ApiInfoBuilder().title("苍穹外卖项目接口文档").version("2.0").description("苍穹外卖项目接口文档").build();
return new Docket(DocumentationType.SWAGGER_2).groupName("Pay支付接口")
.apiInfo(apiInfo).select().apis(RequestHandlerSelectors.basePackage("com.sky.controller.notify"))
.paths(PathSelectors.any()).build();
}
}

View File

@ -1,16 +0,0 @@
package com.sky.common.config;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
@Slf4j
public class RestTemplateConfiguration {
@Bean
public RestTemplate restTemplate() {
log.info("注入restTemplate");
return new RestTemplate();
}
}

View File

@ -1,66 +0,0 @@
package com.sky.common.config;
import com.sky.common.interceptor.JwtTokenAdminInterceptor;
import com.sky.common.interceptor.JwtTokenUserInterceptor;
import com.sky.common.json.JacksonObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
import java.util.List;
@Configuration
@Slf4j
public class WebMvcConfiguration extends WebMvcConfigurationSupport {
@Autowired
private JwtTokenAdminInterceptor jwtTokenAdminInterceptor;
@Autowired
private JwtTokenUserInterceptor jwtTokenUserInterceptor;
/**
* 注册自定义拦截器
*
* @param registry InterceptorRegistry
*/
protected void addInterceptors(InterceptorRegistry registry) {
log.info("开始注册自定义拦截器...");
registry.addInterceptor(jwtTokenAdminInterceptor).addPathPatterns("/admin/**")
.excludePathPatterns("/admin/employee/login");
registry.addInterceptor(jwtTokenUserInterceptor).addPathPatterns("/user/**")
.excludePathPatterns("/user/user/login")
.excludePathPatterns("/user/shop/status");
}
/**
* 扩展Spring MVC框架的消息转化器
*
* @param converters 转换器
*/
protected void extendMessageConverters(List<HttpMessageConverter<?>> converters) {
log.info("扩展消息转换器...");
// 创建一个消息转换器对象
MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();
// 需要为消息转换器设置一个对象转换器对象转换器可以将Java对象序列化为json数据
converter.setObjectMapper(new JacksonObjectMapper());
// 将自己的消息转化器加入容器中
converters.add(0, converter);
}
/**
* 设置静态资源映射
*
* @param registry ResourceHandlerRegistry
*/
protected void addResourceHandlers(ResourceHandlerRegistry registry) {
log.info("设置静态资源映射");
registry.addResourceHandler("/doc.html").addResourceLocations("classpath:/META-INF/resources/");
registry.addResourceHandler("/webjars/**").addResourceLocations("classpath:/META-INF/resources/webjars/");
}
}

View File

@ -1,29 +0,0 @@
package com.sky.common.context;
public class BaseContext {
public static ThreadLocal<Long> threadLocal = new ThreadLocal<>();
/**
* 获取当前用户id
*
* @return 用户id
*/
public static Long getUserId() {
return threadLocal.get();
}
/**
* 设置用户id
* @param userId 用户id
*/
public static void setUserId(Long userId) {
threadLocal.set(userId);
}
/**
* 移出当前id
*/
public static void removeCurrentId() {
threadLocal.remove();
}
}

View File

@ -1,10 +0,0 @@
package com.sky.common.enumeration;
/**
* 数据库操作类型
* 使用AutoFill面向切面设置枚举量
*/
public enum OperationType {
UPDATE,// 更新操作
INSERT// 插入操作
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 账号被锁定异常
*/
@Slf4j
public class AccountLockedException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public AccountLockedException() {
}
public AccountLockedException(String message) {
super(message);
log.error("账号被锁定异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 账号不存在异常
*/
@Slf4j
public class AccountNotFoundException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public AccountNotFoundException() {
}
public AccountNotFoundException(String message) {
super(message);
log.error("账号不存在异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 地址信息异常
*/
@Slf4j
public class AddressBookBusinessException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public AddressBookBusinessException() {
}
public AddressBookBusinessException(String message) {
super(message);
log.error("账号不存在异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 业务异常
*/
@Slf4j
public class BaseException extends RuntimeException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public BaseException() {
}
public BaseException(String message) {
super(message);
log.error("业务异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 不允许删除异常
*/
@Slf4j
public class DeletionNotAllowedException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public DeletionNotAllowedException() {
}
public DeletionNotAllowedException(String message) {
super(message);
log.error("不允许删除异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 登录失败
*/
@Slf4j
public class LoginFailedException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public LoginFailedException() {
}
public LoginFailedException(String message) {
super(message);
log.error("登录失败:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 订单业务异常
*/
@Slf4j
public class OrderBusinessException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public OrderBusinessException() {
}
public OrderBusinessException(String message) {
super(message);
log.error("订单业务异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 密码修改失败异常
*/
@Slf4j
public class PasswordEditFailedException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public PasswordEditFailedException() {
}
public PasswordEditFailedException(String message) {
super(message);
log.error("密码修改失败异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 密码错误异常
*/
@Slf4j
public class PasswordErrorException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public PasswordErrorException() {
}
public PasswordErrorException(String message) {
super(message);
log.error("密码错误异常:{}", message);
}
}

View File

@ -1,17 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* RestTemplateException异常
*/
@Slf4j
public class RestTemplateException extends BaseException {
public RestTemplateException() {
}
public RestTemplateException(String message) {
super(message);
log.error("RestTemplateException异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 套餐启用失败异常
*/
@Slf4j
public class SetMealEnableFailedException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public SetMealEnableFailedException() {
}
public SetMealEnableFailedException(String message) {
super(message);
log.error("套餐启用失败异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 购物车异常
*/
@Slf4j
public class ShoppingCartBusinessException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public ShoppingCartBusinessException() {
}
public ShoppingCartBusinessException(String message) {
super(message);
log.error("购物车异常:{}", message);
}
}

View File

@ -1,22 +0,0 @@
package com.sky.common.exception;
import lombok.extern.slf4j.Slf4j;
/**
* 用户未登录异常
*/
@Slf4j
public class UserNotLoginException extends BaseException {
/**
* Constructs a new runtime exception with {@code null} as its
* detail message. The cause is not initialized, and may subsequently be
* initialized by a call to {@link #initCause}.
*/
public UserNotLoginException() {
}
public UserNotLoginException(String message) {
super(message);
log.error("用户未登录异常:{}", message);
}
}

View File

@ -1,37 +0,0 @@
package com.sky.common.handler;
import com.sky.common.constant.MessageConstant;
import com.sky.common.exception.BaseException;
import com.sky.common.result.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import java.sql.SQLIntegrityConstraintViolationException;
@RestControllerAdvice
@Slf4j
public class GlobalExceptionHandler {
// 捕获业务异常
@ExceptionHandler
public Result<String> exceptionHandler(BaseException exception) {
log.error("异常信息:{}", exception.getMessage());
return Result.error(exception.getMessage());
}
// 处理SQL异常
public Result<String> exceptionHandler(SQLIntegrityConstraintViolationException exception) {
log.error("处理SQL异常:{}", exception.getMessage());
String message = exception.getMessage();
if (message.contains("Duplicate entry")) {
// 截取用户名
String username = message.split(" ")[2];
// 错误信息
String errorMessage = username + MessageConstant.ALREADY_EXISTS;
return Result.error(errorMessage);
} else {
return Result.error(MessageConstant.UNKNOWN_ERROR);
}
}
}

View File

@ -1,51 +0,0 @@
package com.sky.common.interceptor;
import com.sky.common.constant.JwtClaimsConstant;
import com.sky.common.context.BaseContext;
import com.sky.common.properties.JwtProperties;
import com.sky.common.utils.JwtUtil;
import io.jsonwebtoken.Claims;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Component;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.HandlerInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* 管理端用户判断
*/
@Component
@RequiredArgsConstructor
@Slf4j
public class JwtTokenAdminInterceptor implements HandlerInterceptor {
private final JwtProperties jwtProperties;
public boolean preHandle(@NotNull HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull Object handler) {
// 判断当前兰街道的是Controller的方法还是其它资源
if (!(handler instanceof HandlerMethod)) {
// 拦截到的不是动态方法直接放行
return true;
}
// 1. 从请求头中获取令牌
String token = request.getHeader(jwtProperties.getAdminTokenName());
// 2. 拦截令牌
log.info("jwt校验{}", token);
try {
Claims claims = JwtUtil.parseJWT(jwtProperties.getAdminSecretKey(), token);
Long empId = Long.valueOf(claims.get(JwtClaimsConstant.EMP_ID).toString());
log.info("当前员工ID{}", empId);
// 3. 通过放行
BaseContext.setUserId(empId);
return true;
} catch (Exception exception) {
response.setStatus(401);
return false;
}
}
}

View File

@ -1,48 +0,0 @@
package com.sky.common.interceptor;
import com.sky.common.constant.JwtClaimsConstant;
import com.sky.common.context.BaseContext;
import com.sky.common.properties.JwtProperties;
import com.sky.common.utils.JwtUtil;
import io.jsonwebtoken.Claims;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.HandlerInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* 客户端登录判断
*/
@Component
@RequiredArgsConstructor
@Slf4j
public class JwtTokenUserInterceptor implements HandlerInterceptor {
private final JwtProperties jwtProperties;
public boolean preHandle(@NonNull HttpServletRequest request, @NonNull HttpServletResponse response, @NonNull Object handler) throws Exception {
// 判断当前拦截到的是Controller方法还是其它资源
if (!(handler instanceof HandlerMethod)) {
// 当前拦截到的不是动态方法直接放行
return true;
}
// 1. 从请求头中获取令牌
String token = request.getHeader(jwtProperties.getUserTokenName());
// 2. 校验令牌
log.info("jwt校验{}", token);
try {
Claims claims = JwtUtil.parseJWT(jwtProperties.getUserSecretKey(), token);
Long userId = Long.valueOf(claims.get(JwtClaimsConstant.USER_ID).toString());
BaseContext.setUserId(userId);
// 放行
return true;
} catch (Exception exception) {
response.setStatus(401);
return false;
}
}
}

View File

@ -1,20 +0,0 @@
package com.sky.common.properties;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "sky.wechat")
@Data
public class WeChatProperties {
private String appid; // 小程序的appid
private String secret; // 小程序的秘钥
private String mchid; // 商户号
private String mchSerialNo; // 商户API证书的证书序列号
private String privateKeyFilePath; // 商户私钥文件
private String apiV3Key; // 证书解密的密钥
private String weChatPayCertFilePath; // 平台证书
private String notifyUrl; // 支付成功的回调地址
private String refundNotifyUrl; // 退款成功的回调地址
}

View File

@ -1,40 +0,0 @@
package com.sky.common.result;
import lombok.Data;
import java.io.Serializable;
/**
* 后端统一返回结果
*
* @param <T>
*/
@Data
public class Result<T> implements Serializable {
private Integer code; // 编码1成功0和其它数字为失败
private String message; // 错误信息
private T data; // 数据
// 成功
public static <T> Result<T> success() {
Result<T> result = new Result<>();
result.code = 1;
return result;
}
// 有数据返回
public static <T> Result<T> success(T object) {
Result<T> result = new Result<>();
result.data = object;
result.code = 1;
return result;
}
// 错误返回
public static <T> Result<T> error(String message) {
Result<T> result = new Result<>();
result.message = message;
result.code = 0;
return result;
}
}

View File

@ -1,34 +0,0 @@
package com.sky.common.utils;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
public final class MD5 {
public static String encrypt(String strSrc) {
try {
char[] hexChars = {'0', '1', '2', '3', '4', '5', '6', '7', '8',
'9', 'a', 'b', 'c', 'd', 'e', 'f'};
byte[] bytes = strSrc.getBytes();
MessageDigest md = MessageDigest.getInstance("MD5");
md.update(bytes);
bytes = md.digest();
int j = bytes.length;
char[] chars = new char[j * 2];
int k = 0;
for (byte b : bytes) {
chars[k++] = hexChars[b >>> 4 & 0xf];
chars[k++] = hexChars[b & 0xf];
}
return new String(chars);
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
throw new RuntimeException("MD5加密出错+" + e);
}
}
public static void main(String[] args) {
System.out.println(MD5.encrypt("111111"));
}
}

View File

@ -1,20 +0,0 @@
package com.sky.common.utils;
import lombok.RequiredArgsConstructor;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.Set;
@Component
@RequiredArgsConstructor
public class RedisUtil {
private static final RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
public static void cleanCache(String key) {
Set<Object> keys = redisTemplate.keys(key);
if (keys != null) {
redisTemplate.delete(keys);
}
}
}

View File

@ -1,27 +0,0 @@
package com.sky.common.utils;
import lombok.RequiredArgsConstructor;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.*;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import java.io.Serializable;
@Component
@RequiredArgsConstructor
public class RestTemplateUtil<T> implements Serializable {
private final RestTemplate restTemplate;
public ResponseEntity<?> requestGet(String url, T t) {
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<T> entity = new HttpEntity<T>(t, headers);
ResponseEntity<?> response = restTemplate.exchange(url, HttpMethod.GET, entity, new ParameterizedTypeReference<T>() {
});
return response.getStatusCode().is2xxSuccessful() ? response : null;
}
}

View File

@ -1,9 +1,12 @@
package com.sky.common.constant; package com.sky.constant;
/** /**
* 公共字段自动填充相关常量 * 公共字段自动填充相关常量
*/ */
public class AutoFillConstant { public class AutoFillConstant {
/**
* 实体类中的方法名称
*/
public static final String SET_CREATE_TIME = "setCreateTime"; public static final String SET_CREATE_TIME = "setCreateTime";
public static final String SET_UPDATE_TIME = "setUpdateTime"; public static final String SET_UPDATE_TIME = "setUpdateTime";
public static final String SET_CREATE_USER = "setCreateUser"; public static final String SET_CREATE_USER = "setCreateUser";

View File

@ -1,9 +1,11 @@
package com.sky.common.constant; package com.sky.constant;
public class JwtClaimsConstant { public class JwtClaimsConstant {
public static final String EMP_ID = "empId"; public static final String EMP_ID = "empId";
public static final String USER_ID = "userId"; public static final String USER_ID = "userId";
public static final String PHONE = "phone"; public static final String PHONE = "phone";
public static final String USERNAME = "username"; public static final String USERNAME = "username";
public static final String NAME = "name"; public static final String NAME = "name";
} }

View File

@ -1,12 +1,11 @@
package com.sky.common.constant; package com.sky.constant;
/** /**
* 信息提示常量类 * 信息提示常量类
*/ */
public class MessageConstant { public class MessageConstant {
public static final String PASSWORD_ERROR = "密码错误"; public static final String PASSWORD_ERROR = "密码错误";
public static final String OLD_PASSWORD_ERROR = "旧密码不匹配";
public static final String OLD_PASSWORD_SAME_NEW_PASSWORD = "旧密码与新密码相同";
public static final String ACCOUNT_NOT_FOUND = "账号不存在"; public static final String ACCOUNT_NOT_FOUND = "账号不存在";
public static final String ACCOUNT_LOCKED = "账号被锁定"; public static final String ACCOUNT_LOCKED = "账号被锁定";
public static final String UNKNOWN_ERROR = "未知错误"; public static final String UNKNOWN_ERROR = "未知错误";
@ -23,9 +22,7 @@ public class MessageConstant {
public static final String SETMEAL_ON_SALE = "起售中的套餐不能删除"; public static final String SETMEAL_ON_SALE = "起售中的套餐不能删除";
public static final String DISH_BE_RELATED_BY_SETMEAL = "当前菜品关联了套餐,不能删除"; public static final String DISH_BE_RELATED_BY_SETMEAL = "当前菜品关联了套餐,不能删除";
public static final String ORDER_STATUS_ERROR = "订单状态错误"; public static final String ORDER_STATUS_ERROR = "订单状态错误";
public static final String ORDER_STATUS_NOT_OP = "订单已被接单或已制作";
public static final String ORDER_NOT_FOUND = "订单不存在"; public static final String ORDER_NOT_FOUND = "订单不存在";
public static final String ALREADY_EXISTS = "已存在";
public static final String NOT_SET_STATUS = "请先设置营业状态"; public static final String ALREADY_EXISTS = "已存在了";
public static final String REQUEST_NOT_EMPTY = "请求不为空";
} }

View File

@ -1,9 +1,10 @@
package com.sky.common.constant; package com.sky.constant;
/** /**
* 密码常量 * 密码常量
*/ */
public class PasswordConstant { public class PasswordConstant {
// 默认密码
public static final String DEFAULT_PASSWORD = "123456"; public static final String DEFAULT_PASSWORD = "123456";
} }

View File

@ -1,11 +1,13 @@
package com.sky.common.constant; package com.sky.constant;
/** /**
* 状态常量启用或者禁用 * 状态常量启用或者禁用
*/ */
public class StatusConstant { public class StatusConstant {
//启用为1
//启用
public static final Integer ENABLE = 1; public static final Integer ENABLE = 1;
//禁用为0
//禁用
public static final Integer DISABLE = 0; public static final Integer DISABLE = 0;
} }

View File

@ -0,0 +1,19 @@
package com.sky.context;
public class BaseContext {
public static ThreadLocal<Long> threadLocal = new ThreadLocal<>();
public static void setCurrentId(Long id) {
threadLocal.set(id);
}
public static Long getCurrentId() {
return threadLocal.get();
}
public static void removeCurrentId() {
threadLocal.remove();
}
}

View File

@ -0,0 +1,18 @@
package com.sky.enumeration;
/**
* 数据库操作类型
*/
public enum OperationType {
/**
* 更新操作
*/
UPDATE,
/**
* 插入操作
*/
INSERT
}

View File

@ -0,0 +1,15 @@
package com.sky.exception;
/**
* 账号被锁定异常
*/
public class AccountLockedException extends BaseException {
public AccountLockedException() {
}
public AccountLockedException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,15 @@
package com.sky.exception;
/**
* 账号不存在异常
*/
public class AccountNotFoundException extends BaseException {
public AccountNotFoundException() {
}
public AccountNotFoundException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,9 @@
package com.sky.exception;
public class AddressBookBusinessException extends BaseException {
public AddressBookBusinessException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,15 @@
package com.sky.exception;
/**
* 业务异常
*/
public class BaseException extends RuntimeException {
public BaseException() {
}
public BaseException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,9 @@
package com.sky.exception;
public class DeletionNotAllowedException extends BaseException {
public DeletionNotAllowedException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,10 @@
package com.sky.exception;
/**
* 登录失败
*/
public class LoginFailedException extends BaseException{
public LoginFailedException(String msg){
super(msg);
}
}

View File

@ -0,0 +1,9 @@
package com.sky.exception;
public class OrderBusinessException extends BaseException {
public OrderBusinessException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,12 @@
package com.sky.exception;
/**
* 密码修改失败异常
*/
public class PasswordEditFailedException extends BaseException{
public PasswordEditFailedException(String msg){
super(msg);
}
}

View File

@ -0,0 +1,15 @@
package com.sky.exception;
/**
* 密码错误异常
*/
public class PasswordErrorException extends BaseException {
public PasswordErrorException() {
}
public PasswordErrorException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,13 @@
package com.sky.exception;
/**
* 套餐启用失败异常
*/
public class SetmealEnableFailedException extends BaseException {
public SetmealEnableFailedException(){}
public SetmealEnableFailedException(String msg){
super(msg);
}
}

View File

@ -0,0 +1,9 @@
package com.sky.exception;
public class ShoppingCartBusinessException extends BaseException {
public ShoppingCartBusinessException(String msg) {
super(msg);
}
}

View File

@ -0,0 +1,12 @@
package com.sky.exception;
public class UserNotLoginException extends BaseException {
public UserNotLoginException() {
}
public UserNotLoginException(String msg) {
super(msg);
}
}

View File

@ -1,5 +1,6 @@
package com.sky.common.json; package com.sky.json;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule; import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer; import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
@ -17,11 +18,12 @@ import java.time.format.DateTimeFormatter;
import static com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES; import static com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES;
/** /**
* 对象映射器基于Jackson将Java对象转为JSON或者将JSON转为Java对象 * 对象映射器:基于jackson将Java对象转为json或者将json转为Java对象
* 将JSON转为Java对象过程--JSON反序列化Java对象 * 将JSON解析为Java对象的过程称为 [从JSON反序列化Java对象]
* 将Java对象转为JSON--序列化Java对象到JSON * 从Java对象生成JSON的过程称为 [序列化Java对象到JSON]
*/ */
public class JacksonObjectMapper extends ObjectMapper { public class JacksonObjectMapper extends ObjectMapper {
public static final String DEFAULT_DATE_FORMAT = "yyyy-MM-dd"; public static final String DEFAULT_DATE_FORMAT = "yyyy-MM-dd";
//public static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss"; //public static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
public static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm"; public static final String DEFAULT_DATE_TIME_FORMAT = "yyyy-MM-dd HH:mm";
@ -31,16 +33,18 @@ public class JacksonObjectMapper extends ObjectMapper {
super(); super();
//收到未知属性时不报异常 //收到未知属性时不报异常
this.configure(FAIL_ON_UNKNOWN_PROPERTIES, false); this.configure(FAIL_ON_UNKNOWN_PROPERTIES, false);
// 反序列化时属性不存在的兼容处理
this.getDeserializationConfig().withoutFeatures(FAIL_ON_UNKNOWN_PROPERTIES);
SimpleModule simpleModule = new SimpleModule(); //反序列化时属性不存在的兼容处理
simpleModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT))) this.getDeserializationConfig().withoutFeatures(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
SimpleModule simpleModule = new SimpleModule()
.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)))
.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT))) .addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))
.addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT))) .addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)))
.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT))) .addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)))
.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT))) .addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))
.addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT))); .addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)));
//注册功能模块 例如可以添加自定义序列化器和反序列化器 //注册功能模块 例如可以添加自定义序列化器和反序列化器
this.registerModule(simpleModule); this.registerModule(simpleModule);
} }

View File

@ -0,0 +1,17 @@
package com.sky.properties;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "sky.alioss")
@Data
public class AliOssProperties {
private String endpoint;
private String accessKeyId;
private String accessKeySecret;
private String bucketName;
}

View File

@ -1,4 +1,4 @@
package com.sky.common.properties; package com.sky.properties;
import lombok.Data; import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
@ -8,6 +8,7 @@ import org.springframework.stereotype.Component;
@ConfigurationProperties(prefix = "sky.jwt") @ConfigurationProperties(prefix = "sky.jwt")
@Data @Data
public class JwtProperties { public class JwtProperties {
/** /**
* 管理端员工生成jwt令牌相关配置 * 管理端员工生成jwt令牌相关配置
*/ */
@ -21,4 +22,5 @@ public class JwtProperties {
private String userSecretKey; private String userSecretKey;
private long userTtl; private long userTtl;
private String userTokenName; private String userTokenName;
} }

View File

@ -0,0 +1,23 @@
package com.sky.properties;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "sky.wechat")
@Data
public class WeChatProperties {
private String appid; //小程序的appid
private String secret; //小程序的秘钥
private String mchid; //商户号
private String mchSerialNo; //商户API证书的证书序列号
private String privateKeyFilePath; //商户私钥文件
private String apiV3Key; //证书解密的密钥
private String weChatPayCertFilePath; //平台证书
private String notifyUrl; //支付成功的回调地址
private String refundNotifyUrl; //退款成功的回调地址
}

View File

@ -1,4 +1,4 @@
package com.sky.common.result; package com.sky.result;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
@ -13,7 +13,10 @@ import java.util.List;
@Data @Data
@AllArgsConstructor @AllArgsConstructor
@NoArgsConstructor @NoArgsConstructor
public class PageResult<T> implements Serializable { public class PageResult implements Serializable {
private long total; //总记录数 private long total; //总记录数
private List<T> records; // 当前页数据集合
private List records; //当前页数据集合
} }

View File

@ -0,0 +1,38 @@
package com.sky.result;
import lombok.Data;
import java.io.Serializable;
/**
* 后端统一返回结果
* @param <T>
*/
@Data
public class Result<T> implements Serializable {
private Integer code; //编码1成功0和其它数字为失败
private String msg; //错误信息
private T data; //数据
public static <T> Result<T> success() {
Result<T> result = new Result<T>();
result.code = 1;
return result;
}
public static <T> Result<T> success(T object) {
Result<T> result = new Result<T>();
result.data = object;
result.code = 1;
return result;
}
public static <T> Result<T> error(String msg) {
Result result = new Result();
result.msg = msg;
result.code = 0;
return result;
}
}

View File

@ -0,0 +1,68 @@
package com.sky.utils;
import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import java.io.ByteArrayInputStream;
@Data
@AllArgsConstructor
@Slf4j
public class AliOssUtil {
private String endpoint;
private String accessKeyId;
private String accessKeySecret;
private String bucketName;
/**
* 文件上传
*
* @param bytes
* @param objectName
* @return
*/
public String upload(byte[] bytes, String objectName) {
// 创建OSSClient实例
OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
try {
// 创建PutObject请求
ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));
} catch (OSSException oe) {
System.out.println("Caught an OSSException, which means your request made it to OSS, "
+ "but was rejected with an error response for some reason.");
System.out.println("Error Message:" + oe.getErrorMessage());
System.out.println("Error Code:" + oe.getErrorCode());
System.out.println("Request ID:" + oe.getRequestId());
System.out.println("Host ID:" + oe.getHostId());
} catch (ClientException ce) {
System.out.println("Caught an ClientException, which means the client encountered "
+ "a serious internal problem while trying to communicate with OSS, "
+ "such as not being able to access the network.");
System.out.println("Error Message:" + ce.getMessage());
} finally {
if (ossClient != null) {
ossClient.shutdown();
}
}
//文件访问路径规则 https://BucketName.Endpoint/ObjectName
StringBuilder stringBuilder = new StringBuilder("https://");
stringBuilder
.append(bucketName)
.append(".")
.append(endpoint)
.append("/")
.append(objectName);
log.info("文件上传到:{}", stringBuilder.toString());
return stringBuilder.toString();
}
}

View File

@ -1,4 +1,4 @@
package com.sky.common.utils; package com.sky.utils;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import org.apache.http.NameValuePair; import org.apache.http.NameValuePair;
@ -29,6 +29,9 @@ public class HttpClientUtil {
/** /**
* 发送GET方式请求 * 发送GET方式请求
* @param url
* @param paramMap
* @return
*/ */
public static String doGet(String url,Map<String,String> paramMap){ public static String doGet(String url,Map<String,String> paramMap){
// 创建Httpclient对象 // 创建Httpclient对象
@ -72,6 +75,10 @@ public class HttpClientUtil {
/** /**
* 发送POST方式请求 * 发送POST方式请求
* @param url
* @param paramMap
* @return
* @throws IOException
*/ */
public static String doPost(String url, Map<String, String> paramMap) throws IOException { public static String doPost(String url, Map<String, String> paramMap) throws IOException {
// 创建Httpclient对象 // 创建Httpclient对象
@ -115,6 +122,10 @@ public class HttpClientUtil {
/** /**
* 发送POST方式请求 * 发送POST方式请求
* @param url
* @param paramMap
* @return
* @throws IOException
*/ */
public static String doPost4Json(String url, Map<String, String> paramMap) throws IOException { public static String doPost4Json(String url, Map<String, String> paramMap) throws IOException {
// 创建Httpclient对象 // 创建Httpclient对象
@ -158,11 +169,11 @@ public class HttpClientUtil {
return resultString; return resultString;
} }
private static RequestConfig builderRequestConfig() { private static RequestConfig builderRequestConfig() {
return RequestConfig.custom() return RequestConfig.custom()
.setConnectTimeout(TIMEOUT_MSEC) .setConnectTimeout(TIMEOUT_MSEC)
.setConnectionRequestTimeout(TIMEOUT_MSEC) .setConnectionRequestTimeout(TIMEOUT_MSEC)
.setSocketTimeout(TIMEOUT_MSEC).build(); .setSocketTimeout(TIMEOUT_MSEC).build();
} }
} }

View File

@ -1,52 +1,58 @@
package com.sky.common.utils; package com.sky.utils;
import io.jsonwebtoken.Claims; import io.jsonwebtoken.Claims;
import io.jsonwebtoken.JwtBuilder; import io.jsonwebtoken.JwtBuilder;
import io.jsonwebtoken.Jwts; import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm; import io.jsonwebtoken.SignatureAlgorithm;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.Date; import java.util.Date;
import java.util.Map; import java.util.Map;
public class JwtUtil { public class JwtUtil {
/** /**
* 生成JWT * 生成jwt
* 使用Hs256算法, 私匙使用固定秘钥 * 使用Hs256算法, 私匙使用固定秘钥
*
* @param secretKey jwt秘钥 * @param secretKey jwt秘钥
* @param ttlMillis jwt过期时间(毫秒) * @param ttlMillis jwt过期时间(毫秒)
* @param claims 设置的信息 * @param claims 设置的信息
* @return 加密后JWT * @return
*/ */
public static String createJWT(String secretKey, long ttlMillis, Map<String, Object> claims) { public static String createJWT(String secretKey, long ttlMillis, Map<String, Object> claims) {
// 指定签名的时候使用的签名算法也就是header那部分 // 指定签名的时候使用的签名算法也就是header那部分
SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256; SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256;
// 生成JWT的时间 // 生成JWT的时间
long expMillis = System.currentTimeMillis() + ttlMillis; long expMillis = System.currentTimeMillis() + ttlMillis;
Date date = new Date(expMillis); Date exp = new Date(expMillis);
// 设置jwt的body
JwtBuilder builder = Jwts.builder() JwtBuilder builder = Jwts.builder()
// 如果有私有声明一定要先设置这个自己创建的私有的声明这个是给builder的claim赋值一旦写在标准的声明赋值之后就是覆盖了那些标准的声明的 // 如果有私有声明一定要先设置这个自己创建的私有的声明这个是给builder的claim赋值一旦写在标准的声明赋值之后就是覆盖了那些标准的声明的
.setClaims(claims) .setClaims(claims)
// 设置签名使用的签名算法和签名使用的秘钥 // 设置签名使用的签名算法和签名使用的秘钥
.signWith(signatureAlgorithm, secretKey.getBytes(StandardCharsets.UTF_8)) .signWith(signatureAlgorithm, secretKey.getBytes(StandardCharsets.UTF_8))
// 设置过期时间 // 设置过期时间
.setExpiration(date); .setExpiration(exp);
return builder.compact(); return builder.compact();
} }
/** /**
* Token解密 * Token解密
* @param secretKey jwt秘钥 *
* @param token token * @param secretKey jwt秘钥 此秘钥一定要保留好在服务端, 不能暴露出去, 否则sign就可以被伪造, 如果对接多个客户端建议改造成多个
* @return 解密后数据 * @param token 加密后的token
* @return
*/ */
public static Claims parseJWT(String secretKey, String token) { public static Claims parseJWT(String secretKey, String token) {
// 得到DefaultJwtParser // 得到DefaultJwtParser
return Jwts.parser() Claims claims = Jwts.parser()
// 设置签名的秘钥 // 设置签名的秘钥
.setSigningKey(secretKey.getBytes(StandardCharsets.UTF_8)) .setSigningKey(secretKey.getBytes(StandardCharsets.UTF_8))
// 设置需要解析的jwt // 设置需要解析的jwt
.parseClaimsJwt(token).getBody(); .parseClaimsJws(token).getBody();
return claims;
} }
} }

View File

@ -1,11 +1,10 @@
package com.sky.common.utils; package com.sky.utils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.sky.common.context.BaseContext; import com.sky.properties.WeChatProperties;
import com.sky.common.properties.WeChatProperties;
import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder; import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder;
import com.wechat.pay.contrib.apache.httpclient.util.PemUtil; import com.wechat.pay.contrib.apache.httpclient.util.PemUtil;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang.RandomStringUtils; import org.apache.commons.lang.RandomStringUtils;
import org.apache.http.HttpHeaders; import org.apache.http.HttpHeaders;
import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.CloseableHttpResponse;
@ -15,34 +14,40 @@ import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity; import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.util.EntityUtils; import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.File; import java.io.File;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.FileNotFoundException; import java.io.FileNotFoundException;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.PrivateKey; import java.security.PrivateKey;
import java.security.Signature;
import java.security.cert.X509Certificate; import java.security.cert.X509Certificate;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Arrays;
import java.util.Base64;
import java.util.List; import java.util.List;
import java.util.UUID;
/** /**
* 微信支付工具类 * 微信支付工具类
*/ */
@Component @Component
@RequiredArgsConstructor
public class WeChatPayUtil { public class WeChatPayUtil {
//微信支付下单接口地址 //微信支付下单接口地址
public static final String JSAPI = "https://api.mch.weixin.qq.com/v3/pay/transactions/jsapi"; public static final String JSAPI = "https://api.mch.weixin.qq.com/v3/pay/transactions/jsapi";
//申请退款接口地址 //申请退款接口地址
public static final String REFUNDS = "https://api.mch.weixin.qq.com/v3/refund/domestic/refunds"; public static final String REFUNDS = "https://api.mch.weixin.qq.com/v3/refund/domestic/refunds";
private final WeChatProperties weChatProperties;
@Autowired
private WeChatProperties weChatProperties;
/** /**
* 获取调用微信接口的客户端工具对象 * 获取调用微信接口的客户端工具对象
*
* @return
*/ */
private CloseableHttpClient getClient() { private CloseableHttpClient getClient() {
PrivateKey merchantPrivateKey = null; PrivateKey merchantPrivateKey = null;
@ -52,7 +57,7 @@ public class WeChatPayUtil {
//加载平台证书文件 //加载平台证书文件
X509Certificate x509Certificate = PemUtil.loadCertificate(new FileInputStream(new File(weChatProperties.getWeChatPayCertFilePath()))); X509Certificate x509Certificate = PemUtil.loadCertificate(new FileInputStream(new File(weChatProperties.getWeChatPayCertFilePath())));
//wechatPayCertificates微信支付平台证书列表你也可以使用后面章节提到的定时更新平台证书功能而不需要关心平台证书的来龙去脉 //wechatPayCertificates微信支付平台证书列表你也可以使用后面章节提到的定时更新平台证书功能而不需要关心平台证书的来龙去脉
List<X509Certificate> wechatPayCertificates = Collections.singletonList(x509Certificate); List<X509Certificate> wechatPayCertificates = Arrays.asList(x509Certificate);
WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create() WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create()
.withMerchant(weChatProperties.getMchid(), weChatProperties.getMchSerialNo(), merchantPrivateKey) .withMerchant(weChatProperties.getMchid(), weChatProperties.getMchSerialNo(), merchantPrivateKey)
@ -85,7 +90,8 @@ public class WeChatPayUtil {
CloseableHttpResponse response = httpClient.execute(httpPost); CloseableHttpResponse response = httpClient.execute(httpPost);
try { try {
return EntityUtils.toString(response.getEntity()); String bodyAsString = EntityUtils.toString(response.getEntity());
return bodyAsString;
} finally { } finally {
httpClient.close(); httpClient.close();
response.close(); response.close();
@ -108,7 +114,8 @@ public class WeChatPayUtil {
CloseableHttpResponse response = httpClient.execute(httpGet); CloseableHttpResponse response = httpClient.execute(httpGet);
try { try {
return EntityUtils.toString(response.getEntity()); String bodyAsString = EntityUtils.toString(response.getEntity());
return bodyAsString;
} finally { } finally {
httpClient.close(); httpClient.close();
response.close(); response.close();
@ -122,6 +129,7 @@ public class WeChatPayUtil {
* @param total 总金额 * @param total 总金额
* @param description 商品描述 * @param description 商品描述
* @param openid 微信用户的openid * @param openid 微信用户的openid
* @return
*/ */
private String jsapi(String orderNum, BigDecimal total, String description, String openid) throws Exception { private String jsapi(String orderNum, BigDecimal total, String description, String openid) throws Exception {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
@ -132,7 +140,7 @@ public class WeChatPayUtil {
jsonObject.put("notify_url", weChatProperties.getNotifyUrl()); jsonObject.put("notify_url", weChatProperties.getNotifyUrl());
JSONObject amount = new JSONObject(); JSONObject amount = new JSONObject();
amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue()); amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_UP).intValue());
amount.put("currency", "CNY"); amount.put("currency", "CNY");
jsonObject.put("amount", amount); jsonObject.put("amount", amount);
@ -157,12 +165,13 @@ public class WeChatPayUtil {
*/ */
public JSONObject pay(String orderNum, BigDecimal total, String description, String openid) throws Exception { public JSONObject pay(String orderNum, BigDecimal total, String description, String openid) throws Exception {
//统一下单生成预支付交易单 //统一下单生成预支付交易单
// String bodyAsString = jsapi(orderNum, total, description, openid); String bodyAsString = jsapi(orderNum, total, description, openid);
//解析返回结果 //解析返回结果
// JSONObject jsonObject = JSON.parseObject(bodyAsString); JSONObject jsonObject = JSON.parseObject(bodyAsString);
System.out.println(jsonObject);
// String prepayId = jsonObject.getString("prepay_id"); String prepayId = jsonObject.getString("prepay_id");
String prepayId = "bunny-" + UUID.randomUUID(); if (prepayId != null) {
String timeStamp = String.valueOf(System.currentTimeMillis() / 1000); String timeStamp = String.valueOf(System.currentTimeMillis() / 1000);
String nonceStr = RandomStringUtils.randomNumeric(32); String nonceStr = RandomStringUtils.randomNumeric(32);
ArrayList<Object> list = new ArrayList<>(); ArrayList<Object> list = new ArrayList<>();
@ -171,17 +180,17 @@ public class WeChatPayUtil {
list.add(nonceStr); list.add(nonceStr);
list.add("prepay_id=" + prepayId); list.add("prepay_id=" + prepayId);
//二次签名调起支付需要重新签名 //二次签名调起支付需要重新签名
// StringBuilder stringBuilder = new StringBuilder(); StringBuilder stringBuilder = new StringBuilder();
// for (Object o : list) { for (Object o : list) {
// stringBuilder.append(o).append("\n"); stringBuilder.append(o).append("\n");
// } }
// String signMessage = stringBuilder.toString(); String signMessage = stringBuilder.toString();
// byte[] message = signMessage.getBytes(); byte[] message = signMessage.getBytes();
// Signature signature = Signature.getInstance("SHA256withRSA"); Signature signature = Signature.getInstance("SHA256withRSA");
// signature.initSign(PemUtil.loadPrivateKey(Files.newInputStream(new File(weChatProperties.getPrivateKeyFilePath()).toPath()))); signature.initSign(PemUtil.loadPrivateKey(new FileInputStream(new File(weChatProperties.getPrivateKeyFilePath()))));
// signature.update(message); signature.update(message);
// String packageSign = Base64.getEncoder().encodeToString(signature.sign()); String packageSign = Base64.getEncoder().encodeToString(signature.sign());
//构造数据给微信小程序用于调起微信支付 //构造数据给微信小程序用于调起微信支付
JSONObject jo = new JSONObject(); JSONObject jo = new JSONObject();
@ -189,10 +198,11 @@ public class WeChatPayUtil {
jo.put("nonceStr", nonceStr); jo.put("nonceStr", nonceStr);
jo.put("package", "prepay_id=" + prepayId); jo.put("package", "prepay_id=" + prepayId);
jo.put("signType", "RSA"); jo.put("signType", "RSA");
jo.put("paySign", BaseContext.getUserId() + "-" + prepayId); jo.put("paySign", packageSign);
return jo; return jo;
// return jsonObject; }
return jsonObject;
} }
/** /**
@ -210,8 +220,8 @@ public class WeChatPayUtil {
jsonObject.put("out_refund_no", outRefundNo); jsonObject.put("out_refund_no", outRefundNo);
JSONObject amount = new JSONObject(); JSONObject amount = new JSONObject();
amount.put("refund", refund.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue()); amount.put("refund", refund.multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_UP).intValue());
amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue()); amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, BigDecimal.ROUND_HALF_UP).intValue());
amount.put("currency", "CNY"); amount.put("currency", "CNY");
jsonObject.put("amount", amount); jsonObject.put("amount", amount);

View File

@ -1,22 +1,14 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<packaging>jar</packaging>
<parent> <parent>
<artifactId>sky-take-out</artifactId>
<groupId>com.sky</groupId> <groupId>com.sky</groupId>
<artifactId>dev-sky-serve-v1</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</parent> </parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>sky-pojo</artifactId> <artifactId>sky-pojo</artifactId>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.projectlombok</groupId> <groupId>org.projectlombok</groupId>
@ -25,7 +17,7 @@
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>jackson-databind</artifactId>
<version>2.16.1</version> <version>2.14.0-rc2</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.github.xiaoymin</groupId> <groupId>com.github.xiaoymin</groupId>

View File

@ -0,0 +1,22 @@
package com.sky.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class CategoryDTO implements Serializable {
//主键
private Long id;
//类型 1 菜品分类 2 套餐分类
private Integer type;
//分类名称
private String name;
//排序
private Integer sort;
}

View File

@ -0,0 +1,13 @@
package com.sky.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class CategoryPageQueryDTO implements Serializable {
private int page;// 页码
private int pageSize;// 每页记录数
private String name;// 分类名称
private Integer type;//分类类型 1菜品分类 2套餐分类
}

View File

@ -1,4 +1,4 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;
@ -13,6 +13,9 @@ import java.time.LocalDateTime;
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
public class DataOverViewQueryDTO implements Serializable { public class DataOverViewQueryDTO implements Serializable {
private LocalDateTime begin; private LocalDateTime begin;
private LocalDateTime end; private LocalDateTime end;
} }

View File

@ -1,19 +1,15 @@
package com.sky.pojo.dto; package com.sky.dto;
import com.sky.pojo.entity.DishFlavor; import com.sky.entity.DishFlavor;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class DishDTO implements Serializable { public class DishDTO implements Serializable {
private Long id; private Long id;
//菜品名称 //菜品名称
private String name; private String name;
@ -29,4 +25,5 @@ public class DishDTO implements Serializable {
private Integer status; private Integer status;
//口味 //口味
private List<DishFlavor> flavors = new ArrayList<>(); private List<DishFlavor> flavors = new ArrayList<>();
} }

View File

@ -1,20 +1,22 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class DishPageQueryDTO implements Serializable { public class DishPageQueryDTO implements Serializable {
private int page; private int page;
private int pageSize; private int pageSize;
private String name; private String name;
//分类id //分类id
private Integer categoryId; private Integer categoryId;
//状态 0表示禁用 1表示启用 //状态 0表示禁用 1表示启用
private Integer status; private Integer status;
} }

View File

@ -1,19 +1,22 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class EmployeeDTO implements Serializable { public class EmployeeDTO implements Serializable {
private Long id; private Long id;
private String username; private String username;
private String name; private String name;
private String phone; private String phone;
private String sex; private String sex;
private String idNumber; private String idNumber;
} }

View File

@ -1,16 +1,12 @@
package com.sky.pojo.dto; package com.sky.dto;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
@ApiModel(description = "员工登录时传递的数据模型") @ApiModel(description = "员工登录时传递的数据模型")
public class EmployeeLoginDTO implements Serializable { public class EmployeeLoginDTO implements Serializable {
@ -19,4 +15,5 @@ public class EmployeeLoginDTO implements Serializable {
@ApiModelProperty("密码") @ApiModelProperty("密码")
private String password; private String password;
} }

View File

@ -0,0 +1,19 @@
package com.sky.dto;
import com.sky.entity.Employee;
import lombok.Data;
import java.io.Serializable;
@Data
public class EmployeePageQueryDTO implements Serializable {
//员工姓名
private String name;
//页码
private int page;
//每页显示记录数
private int pageSize;
}

View File

@ -1,4 +1,4 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,16 +1,14 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersCancelDTO implements Serializable { public class OrdersCancelDTO implements Serializable {
private Long id; private Long id;
//订单取消原因 //订单取消原因
private String cancelReason; private String cancelReason;
} }

View File

@ -0,0 +1,14 @@
package com.sky.dto;
import lombok.Data;
import java.io.Serializable;
@Data
public class OrdersConfirmDTO implements Serializable {
private Long id;
//订单状态 1待付款 2待接单 3 已接单 4 派送中 5 已完成 6 已取消 7 退款
private Integer status;
}

View File

@ -1,45 +1,56 @@
package com.sky.pojo.dto; package com.sky.dto;
import com.sky.pojo.entity.OrderDetail; import com.sky.entity.OrderDetail;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List; import java.util.List;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersDTO implements Serializable { public class OrdersDTO implements Serializable {
private Long id; private Long id;
//订单号 //订单号
private String number; private String number;
//订单状态 1待付款2待派送3已派送4已完成5已取消 //订单状态 1待付款2待派送3已派送4已完成5已取消
private Integer status; private Integer status;
//下单用户id //下单用户id
private Long userId; private Long userId;
//地址id //地址id
private Long addressBookId; private Long addressBookId;
//下单时间 //下单时间
private LocalDateTime orderTime; private LocalDateTime orderTime;
//结账时间 //结账时间
private LocalDateTime checkoutTime; private LocalDateTime checkoutTime;
//支付方式 1微信2支付宝 //支付方式 1微信2支付宝
private Integer payMethod; private Integer payMethod;
//实收金额 //实收金额
private BigDecimal amount; private BigDecimal amount;
//备注 //备注
private String remark; private String remark;
//用户名 //用户名
private String userName; private String userName;
//手机号 //手机号
private String phone; private String phone;
//地址 //地址
private String address; private String address;
//收货人 //收货人
private String consignee; private String consignee;
private List<OrderDetail> orderDetails; private List<OrderDetail> orderDetails;
} }

View File

@ -1,25 +1,30 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat; import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable; import java.io.Serializable;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersPageQueryDTO implements Serializable { public class OrdersPageQueryDTO implements Serializable {
private int page; private int page;
private int pageSize; private int pageSize;
private String number; private String number;
private String phone; private String phone;
private Integer status; private Integer status;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime beginTime; private LocalDateTime beginTime;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime endTime; private LocalDateTime endTime;
private Long userId; private Long userId;
} }

View File

@ -1,17 +1,14 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersPaymentDTO implements Serializable { public class OrdersPaymentDTO implements Serializable {
//订单号 //订单号
private String orderNumber; private String orderNumber;
//付款方式 //付款方式
private Integer payMethod; private Integer payMethod;
} }

View File

@ -1,16 +1,15 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersRejectionDTO implements Serializable { public class OrdersRejectionDTO implements Serializable {
private Long id; private Long id;
//订单拒绝原因 //订单拒绝原因
private String rejectionReason; private String rejectionReason;
} }

View File

@ -1,17 +1,13 @@
package com.sky.pojo.dto; package com.sky.dto;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class OrdersSubmitDTO implements Serializable { public class OrdersSubmitDTO implements Serializable {
//地址簿id //地址簿id
private Long addressBookId; private Long addressBookId;

View File

@ -1,19 +1,19 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class PasswordEditDTO implements Serializable { public class PasswordEditDTO implements Serializable {
//员工id //员工id
private Long empId; private Long empId;
//旧密码 //旧密码
private String oldPassword; private String oldPassword;
//新密码 //新密码
private String newPassword; private String newPassword;
} }

View File

@ -1,9 +1,7 @@
package com.sky.pojo.dto; package com.sky.dto;
import com.sky.pojo.entity.SetmealDish; import com.sky.entity.SetmealDish;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.math.BigDecimal; import java.math.BigDecimal;
@ -11,9 +9,8 @@ import java.util.ArrayList;
import java.util.List; import java.util.List;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class SetmealDTO implements Serializable { public class SetmealDTO implements Serializable {
private Long id; private Long id;
// 分类id // 分类id
private Long categoryId; private Long categoryId;
@ -29,4 +26,5 @@ public class SetmealDTO implements Serializable {
private String image; private String image;
// 套餐菜品关系 // 套餐菜品关系
private List<SetmealDish> setmealDishes = new ArrayList<>(); private List<SetmealDish> setmealDishes = new ArrayList<>();
} }

View File

@ -1,20 +1,22 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class SetmealPageQueryDTO implements Serializable { public class SetmealPageQueryDTO implements Serializable {
private int page; private int page;
private int pageSize; private int pageSize;
private String name; private String name;
//分类id //分类id
private Integer categoryId; private Integer categoryId;
//状态 0表示禁用 1表示启用 //状态 0表示禁用 1表示启用
private Integer status; private Integer status;
} }

View File

@ -1,16 +1,13 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class ShoppingCartDTO implements Serializable { public class ShoppingCartDTO implements Serializable {
private Long dishId; private Long dishId;
private Long setmealId; private Long setmealId;
private String dishFlavor; private String dishFlavor;
} }

View File

@ -1,8 +1,6 @@
package com.sky.pojo.dto; package com.sky.dto;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
@ -10,8 +8,8 @@ import java.io.Serializable;
* C端用户登录 * C端用户登录
*/ */
@Data @Data
@AllArgsConstructor
@NoArgsConstructor
public class UserLoginDTO implements Serializable { public class UserLoginDTO implements Serializable {
private String code; private String code;
} }

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,9 +1,7 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Builder; import lombok.*;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@ -32,7 +30,7 @@ public class Employee implements Serializable {
private Integer status; private Integer status;
//@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy年MM月dd日 HH:mm:ss")
private LocalDateTime createTime; private LocalDateTime createTime;
//@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") //@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
@ -41,6 +39,4 @@ public class Employee implements Serializable {
private Long createUser; private Long createUser;
private Long updateUser; private Long updateUser;
private String shopAddress;
private String employeeAddress;
} }

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.entity; package com.sky.entity;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,21 +0,0 @@
package com.sky.pojo.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class CategoryDTO implements Serializable {
// 主键
private Long id;
// 类型 1 菜品分类 2 套餐分类
private Integer type;
// 分类名称
private String name;
// 排序
private Integer sort;
}

View File

@ -1,21 +0,0 @@
package com.sky.pojo.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class CategoryPageQueryDTO implements Serializable {
// 页码
private int page;
// 每页记录数
private int pageSize;
// 分类名称
private String name;
// 分类类型 1菜品分类 2套餐分类
private Integer type;
}

View File

@ -1,19 +0,0 @@
package com.sky.pojo.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class EmployeePageQueryDTO implements Serializable {
// 员工姓名
private String name;
// 页码
private int page;
// 每页显示记录数
private int pageSize;
}

View File

@ -1,16 +0,0 @@
package com.sky.pojo.dto;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class OrdersConfirmDTO implements Serializable {
private Long id;
// 订单状态 1待付款 2待接单 3 已接单 4 派送中 5 已完成 6 已取消 7 退款
private Integer status;
}

View File

@ -1,10 +0,0 @@
package com.sky.pojo.entity;
import lombok.Data;
@Data
public class BaiduMap {
private String address;
private String output;
private String ak;
}

View File

@ -1,4 +1,4 @@
package com.sky.pojo.vo; package com.sky.vo;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.vo; package com.sky.vo;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.vo; package com.sky.vo;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;

View File

@ -1,6 +1,6 @@
package com.sky.pojo.vo; package com.sky.vo;
import com.sky.pojo.entity.DishFlavor; import com.sky.entity.DishFlavor;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;
import lombok.Data; import lombok.Data;

View File

@ -1,4 +1,4 @@
package com.sky.pojo.vo; package com.sky.vo;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;

Some files were not shown because too many files have changed in this diff Show More