JavaProject/sky-take-out
JavaProject
/
sky-take-out
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: JavaProject:d0f34716a661a0003bde4ace690a5d672500604e
Branches Tags
JavaProject:master
JavaProject:dev-serve-redis
JavaProject:dev-sky-serve-v1
JavaProject:dev-serve-normal
JavaProject:dev-init
JavaProject:sky-admin
JavaProject:wx-web
JavaProject:admin
...
compare: JavaProject:5f927f2e5a72881e936c7b29f8ca647e765ffe33
Branches Tags
JavaProject:dev-serve-redis
JavaProject:dev-sky-serve-v1
JavaProject:master
JavaProject:dev-serve-normal
JavaProject:dev-init
JavaProject:sky-admin
JavaProject:wx-web
JavaProject:admin

3 Commits
d0f34716a6 ... 5f927f2e5a

Author SHA1 Message Date
bunny 5f927f2e5a perf(修改): 使用Redis登录、修改Redis存入和未找到用户提示 2024-03-18 21:00:53 +08:00
bunny 46c5eade72 perf(修改): 使用Redis登录、修改Redis存入和未找到用户提示 2024-03-18 20:48:39 +08:00
bunny 1354d10622 perf(修改): 使用Redis验证登录 2024-03-18 18:45:35 +08:00
43 changed files with 1584 additions and 86 deletions
Show Stats Expand all files Collapse all files

1
.idea/compiler.xml
View File

@ -2,6 +2,7 @@
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />

3
.idea/misc.xml
View File

@ -7,9 +7,8 @@
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
<option name="workspaceImportForciblyTurnedOn" value="true" />
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_19" default="true" project-jdk-name="19" project-jdk-type="JavaSDK">
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="corretto-17" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" />
</component>
</project>

168
logs/dev-sky-serve-redis/spring.log Normal file
View File

@ -0,0 +1,168 @@
20:07:50:028 INFO 4012 --- [main] com.sky.SkyApplication : Starting SkyApplication using Java 17.0.9 on bunny with PID 4012 (G:\File\Java\sky\dev-sky-serve-redis\sky-server\target\classes started by 13199 in G:\File\Java\sky\dev-sky-serve-redis)
20:07:50:028 INFO 4012 --- [main] com.sky.SkyApplication : The following 1 profile is active: "dev"
20:07:50:397 INFO 4012 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
20:07:50:398 INFO 4012 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data Redis repositories in DEFAULT mode.
20:07:50:413 INFO 4012 --- [main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 8 ms. Found 0 Redis repository interfaces.
20:07:50:728 INFO 4012 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat initialized with port(s): 8080 (http)
20:07:50:732 INFO 4012 --- [main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
20:07:50:732 INFO 4012 --- [main] org.apache.catalina.core.StandardEngine : Starting Servlet engine: [Apache Tomcat/9.0.65]
20:07:50:786 INFO 4012 --- [main] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
20:07:50:787 INFO 4012 --- [main] w.s.c.ServletWebServerApplicationContext : Root WebApplicationContext: initialization completed in 738 ms
20:07:50:842 INFO 4012 --- [main] c.a.d.s.b.a.DruidDataSourceAutoConfigure : Init DruidDataSource
20:07:50:892 INFO 4012 --- [main] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} inited
20:07:51:289 INFO 4012 --- [main] c.s.c.config.RestTemplateConfiguration : 注入restTemplate
20:07:51:370 INFO 4012 --- [main] c.sky.common.config.WebMvcConfiguration : 开始注册自定义拦截器...
20:07:51:415 INFO 4012 --- [main] c.s.common.config.Knife4jConfiguration : A管理端接口
20:07:51:417 INFO 4012 --- [main] c.s.common.config.Knife4jConfiguration : B用户端接口
20:07:51:418 INFO 4012 --- [main] c.s.common.config.Knife4jConfiguration : Pay支付接口
20:07:51:438 INFO 4012 --- [main] c.sky.common.config.WebMvcConfiguration : 扩展消息转换器...
20:07:51:441 INFO 4012 --- [main] c.s.common.config.ResourceConfiguration : 设置静态资源映射
20:07:51:482 INFO 4012 --- [main] c.s.c.config.WebSocketConfiguration : WebSocket配置类，用于注册WebSocket的Bean
20:07:51:647 INFO 4012 --- [main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''
20:07:51:909 INFO 4012 --- [main] com.sky.SkyApplication : Started SkyApplication in 2.064 seconds (JVM running for 4.815)
20:08:00:005 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:08:00.005316300
20:08:00:217 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:08:00:228 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:53:00.006335900(LocalDateTime)
20:08:00:257 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:09:00:011 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:09:00.011285800
20:09:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:09:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:54:00.011285800(LocalDateTime)
20:09:00:030 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:10:00:012 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:10:00.012449100
20:10:00:012 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:10:00:012 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:55:00.012449100(LocalDateTime)
20:10:00:031 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:11:00:011 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:11:00.011231700
20:11:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:11:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:56:00.011231700(LocalDateTime)
20:11:00:029 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:12:00:007 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:12:00.007093300
20:12:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:12:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:57:00.007093300(LocalDateTime)
20:12:00:025 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:13:00:005 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:13:00.005966400
20:13:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:13:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:58:00.005966400(LocalDateTime)
20:13:00:024 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:14:00:015 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:14:00.015365500
20:14:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:14:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T19:59:00.015365500(LocalDateTime)
20:14:00:034 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:15:00:008 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:15:00.008461900
20:15:00:008 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:15:00:008 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:00:00.008461900(LocalDateTime)
20:15:00:027 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:16:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:16:00.009138
20:16:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:16:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:01:00.009138(LocalDateTime)
20:16:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:17:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:17:00.009477200
20:17:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:17:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:02:00.009477200(LocalDateTime)
20:17:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:18:00:010 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:18:00.010387100
20:18:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:18:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:03:00.010387100(LocalDateTime)
20:18:00:029 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:19:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:19:00.009303
20:19:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:19:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:04:00.009303(LocalDateTime)
20:19:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:20:00:010 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:20:00.010432700
20:20:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:20:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:05:00.010432700(LocalDateTime)
20:20:00:029 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:21:00:007 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:21:00.007943700
20:21:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:21:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:06:00.007943700(LocalDateTime)
20:21:00:026 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:22:00:010 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:22:00.010535
20:22:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:22:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:07:00.010535(LocalDateTime)
20:22:00:029 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:23:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:23:00.009473500
20:23:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:23:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:08:00.009473500(LocalDateTime)
20:23:00:030 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:24:00:013 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:24:00.013380300
20:24:00:013 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:24:00:013 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:09:00.013380300(LocalDateTime)
20:24:00:032 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:25:00:011 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:25:00.011129600
20:25:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:25:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:10:00.011129600(LocalDateTime)
20:25:00:031 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:26:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:26:00.009704600
20:26:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:26:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:11:00.009704600(LocalDateTime)
20:26:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:27:00:007 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:27:00.007626700
20:27:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:27:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:12:00.007626700(LocalDateTime)
20:27:00:025 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:28:00:011 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:28:00.011912600
20:28:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:28:00:011 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:13:00.011912600(LocalDateTime)
20:28:00:031 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:29:00:010 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:29:00.010434600
20:29:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:29:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:14:00.010434600(LocalDateTime)
20:29:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:30:00:009 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:30:00.009411800
20:30:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:30:00:009 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:15:00.009411800(LocalDateTime)
20:30:00:028 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:31:00:007 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:31:00.007487200
20:31:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:31:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:16:00.007487200(LocalDateTime)
20:31:00:026 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:32:00:006 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:32:00.006591100
20:32:00:006 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:32:00:007 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:17:00.006591100(LocalDateTime)
20:32:00:027 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:33:00:010 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:33:00.010864700
20:33:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:33:00:010 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:18:00.010864700(LocalDateTime)
20:33:00:029 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:34:00:005 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:34:00.005313700
20:34:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:34:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:19:00.005313700(LocalDateTime)
20:34:00:024 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:35:00:015 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:35:00.015687700
20:35:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:35:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:20:00.015687700(LocalDateTime)
20:35:00:034 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:36:00:003 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:36:00.003420100
20:36:00:003 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:36:00:003 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:21:00.003420100(LocalDateTime)
20:36:00:022 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:37:00:008 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:37:00.008997600
20:37:00:008 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:37:00:008 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:22:00.008997600(LocalDateTime)
20:37:00:027 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:38:00:015 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:38:00.015576700
20:38:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:38:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:23:00.015576700(LocalDateTime)
20:38:00:033 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:39:00:001 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:39:00.001910700
20:39:00:001 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:39:00:001 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:24:00.001910700(LocalDateTime)
20:39:00:019 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:40:00:013 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:40:00.013081700
20:40:00:013 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:40:00:013 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:25:00.013081700(LocalDateTime)
20:40:00:048 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:41:00:005 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:41:00.005481400
20:41:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:41:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:26:00.005481400(LocalDateTime)
20:41:00:024 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:42:00:015 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:42:00.015343500
20:42:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:42:00:015 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:27:00.015343500(LocalDateTime)
20:42:00:034 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:43:00:005 INFO 4012 --- [scheduling-1] com.sky.task.OrderTask : 定时处理超时订单：2024-03-18T20:43:00.005726200
20:43:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Preparing: select * from orders where status = ? and order_time < ?;
20:43:00:005 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : ==> Parameters: 1(Integer), 2024-03-18T20:28:00.005726200(LocalDateTime)
20:43:00:024 DEBUG 4012 --- [scheduling-1] c.s.m.O.getByStatusAndOrderTime : <== Total: 0
20:43:27:844 INFO 4012 --- [SpringApplicationShutdownHook] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} closing ...
20:43:27:847 INFO 4012 --- [SpringApplicationShutdownHook] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} closed

5
pom.xml
View File

@ -17,12 +17,11 @@
<module>sky-common</module>
<module>sky-pojo</module>
<module>sky-server</module>
<module>sky-server</module>
</modules>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<mybatis.spring>2.2.0</mybatis.spring>
<lombok>1.18.20</lombok>
<fastjson>1.2.76</fastjson>

55
sky-common/src/main/java/com/sky/common/config/Knife4jConfiguration.java Normal file
View File

@ -0,0 +1,55 @@
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管理端接口");
// 添加作者
springfox.documentation.service.Contact contact = new Contact("Bunny", "1319900154@qq.com", "1319900154@qq.com");
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();
}
}

95
sky-common/src/main/java/com/sky/common/config/RedisConfiguration.java Normal file
View File

@ -0,0 +1,95 @@
package com.sky.common.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@Configuration
@Slf4j
public class RedisConfiguration {
/**
* 使用StringRedisSerializer序列化为字符串
*/
@Bean
public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(connectionFactory);
// 设置key序列化为string
redisTemplate.setKeySerializer(new StringRedisSerializer());
// 设置value序列化为JSON，使用GenericJackson2JsonRedisSerializer替换默认序列化
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
return redisTemplate;
}
/**
* 解决cache(@Cacheable)把数据缓存到redis中的value是乱码问题
*/
@Bean
@SuppressWarnings("all")
public CacheManager cacheManager(RedisConnectionFactory factory) {
StringRedisSerializer redisSerializer = new StringRedisSerializer();
// json序列化
Jackson2JsonRedisSerializer<Object> serializer = jsonRedisSerializer();
// 配置序列化
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
RedisCacheConfiguration redisCacheConfiguration = config
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(serializer));
RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
.cacheDefaults(redisCacheConfiguration).build();
return cacheManager;
}
/**
* 指定的日期模式
*/
public Jackson2JsonRedisSerializer<Object> jsonRedisSerializer() {
Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
ObjectMapper mapper = new ObjectMapper();
// 设置ObjectMapper访问权限
mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
// 记录序列化之后的数据类型，方便反序列化
mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
// LocalDatetime序列化，默认不兼容jdk8日期序列化
JavaTimeModule timeModule = new JavaTimeModule();
timeModule.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
timeModule.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
timeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
timeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
// 关闭默认的日期格式化方式，默认UTC日期格式 yyyy-MM-dd’T’HH:mm:ss.SSS
mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
mapper.registerModule(timeModule);
serializer.setObjectMapper(mapper);
return serializer;
}
}

15
sky-common/src/main/java/com/sky/common/config/ResourceConfiguration.java Normal file
View File

@ -0,0 +1,15 @@
package com.sky.common.config;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry;
@Configuration
@Slf4j
public class ResourceConfiguration extends WebMvcConfiguration {
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/");
}
}

16
sky-common/src/main/java/com/sky/common/config/RestTemplateConfiguration.java Normal file
View File

@ -0,0 +1,16 @@
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();
}
}

52
sky-common/src/main/java/com/sky/common/config/WebMvcConfiguration.java Normal file
View File

@ -0,0 +1,52 @@
package com.sky.common.config;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.sky.common.interceptor.JwtTokenUserInterceptor;
import com.sky.common.interceptor.RedisTokenAdminInterceptor;
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.WebMvcConfigurationSupport;
import java.util.List;
@Configuration
@Slf4j
public class WebMvcConfiguration extends WebMvcConfigurationSupport {
@Autowired
RedisTokenAdminInterceptor adminInterceptor;
@Autowired
JwtTokenUserInterceptor userInterceptor;
/**
* 注册自定义拦截器
*
* @param registry InterceptorRegistry
*/
protected void addInterceptors(InterceptorRegistry registry) {
log.info("开始注册自定义拦截器...");
registry.addInterceptor(adminInterceptor).addPathPatterns("/admin/**")
.excludePathPatterns("/admin/employee/login");
registry.addInterceptor(userInterceptor).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 ObjectMapper());
// 将自己的消息转化器加入容器中
converters.add(0, converter);
}
}

19
sky-common/src/main/java/com/sky/common/config/WebSocketConfiguration.java Normal file
View File

@ -0,0 +1,19 @@
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.socket.server.standard.ServerEndpointExporter;
/**
* WebSocket配置类，用于注册WebSocket的Bean
*/
@Configuration
@Slf4j
public class WebSocketConfiguration {
@Bean
public ServerEndpointExporter serverEndpointExporter() {
log.info("WebSocket配置类，用于注册WebSocket的Bean");
return new ServerEndpointExporter();
}
}

1
sky-common/src/main/java/com/sky/common/constant/MessageConstant.java
View File

@ -11,6 +11,7 @@ public class MessageConstant {
public static final String ACCOUNT_LOCKED = "账号被锁定";
public static final String UNKNOWN_ERROR = "未知错误";
public static final String USER_NOT_LOGIN = "用户未登录";
public static final String USER_TOKEN_OUT_OF_DATE = "用户登录过期";
public static final String CATEGORY_BE_RELATED_BY_SETMEAL = "当前分类关联了套餐,不能删除";
public static final String CATEGORY_BE_RELATED_BY_DISH = "当前分类关联了菜品,不能删除";
public static final String SHOPPING_CART_IS_NULL = "购物车数据为空，不能下单";

30
sky-common/src/main/java/com/sky/common/context/BaseContext.java Normal file
View File

@ -0,0 +1,30 @@
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();
}
}

36
sky-common/src/main/java/com/sky/common/handler/GlobalExceptionHandler.java Normal file
View File

@ -0,0 +1,36 @@
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);
}
}
}

45
sky-common/src/main/java/com/sky/common/interceptor/JwtTokenUserInterceptor.java Normal file
View File

@ -0,0 +1,45 @@
package com.sky.common.interceptor;
import com.sky.common.constant.JwtClaimsConstant;
import com.sky.common.context.BaseContext;
import com.sky.common.properties.RedisTokenProperties;
import com.sky.common.utils.JwtUtil;
import io.jsonwebtoken.Claims;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpStatus;
import org.checkerframework.checker.nullness.qual.NonNull;
import org.springframework.beans.factory.annotation.Autowired;
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
@Slf4j
public class JwtTokenUserInterceptor implements HandlerInterceptor {
@Autowired
RedisTokenProperties redisTokenProperties;
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(redisTokenProperties.getUserTokenName());
// 2. 校验令牌
log.info("jwt校验：{}", token);
try {
Claims claims = JwtUtil.parseJWT(redisTokenProperties.getUserSecretKey(), token);
Long userId = Long.valueOf(claims.get(JwtClaimsConstant.USER_ID).toString());
BaseContext.setUserId(userId);
return true;
} catch (Exception exception) {
response.setStatus(HttpStatus.SC_UNAUTHORIZED);
return false;
}
}
}

54
sky-common/src/main/java/com/sky/common/interceptor/RedisTokenAdminInterceptor.java Normal file
View File

@ -0,0 +1,54 @@
package com.sky.common.interceptor;
import com.sky.common.constant.MessageConstant;
import com.sky.common.context.BaseContext;
import com.sky.common.properties.RedisTokenProperties;
import com.sky.common.utils.InterceptorUtil;
import lombok.extern.slf4j.Slf4j;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
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;
import java.io.IOException;
@Component
@Slf4j
public class RedisTokenAdminInterceptor implements HandlerInterceptor {
@Autowired
private RedisTokenProperties redisTokenProperties;
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public boolean preHandle(@NotNull HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull Object handler) throws IOException {
// 判断当前兰街道的是Controller的方法还是其它资源 拦截到的不是动态方法，直接放行
if (!(handler instanceof HandlerMethod)) return true;
// 1. 从请求头中获取令牌
String token = request.getHeader(redisTokenProperties.getAdminTokenName());
log.info("jwt校验：{}", token);
if (token == null) {
InterceptorUtil.unLoginInterceptor(response);
return false;
}
try {
Object empId = redisTemplate.opsForValue().get(token);
log.info("当前员工ID：{}", empId);
if (empId == null) {
InterceptorUtil.customLoginInterceptor(response, MessageConstant.USER_TOKEN_OUT_OF_DATE, "");
return false;
}
// 3. 通过放行
BaseContext.setUserId(Long.valueOf(empId.toString()));
return true;
} catch (Exception exception) {
InterceptorUtil.customLoginInterceptor(response, exception.getMessage(), "");
return false;
}
}
}

47
sky-common/src/main/java/com/sky/common/json/JacksonObjectMapper.java Normal file
View File

@ -0,0 +1,47 @@
package com.sky.common.json;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalTimeDeserializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalTimeSerializer;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import static com.fasterxml.jackson.databind.DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES;
/**
* 对象映射器，基于Jackson将Java对象转为JSON，或者将JSON转为Java对象
* 将JSON转为Java对象过程--JSON反序列化Java对象
* 将Java对象转为JSON--序列化Java对象到JSON
*/
public class JacksonObjectMapper extends ObjectMapper {
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";
public static final String DEFAULT_TIME_FORMAT = "HH:mm:ss";
public JacksonObjectMapper() {
super();
// 收到未知属性时不报异常
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)))
.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))
.addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)))
.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_TIME_FORMAT)))
.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern(DEFAULT_DATE_FORMAT)))
.addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern(DEFAULT_TIME_FORMAT)));
// 注册功能模块 例如，可以添加自定义序列化器和反序列化器
this.registerModule(simpleModule);
}
}

4
sky-common/src/main/java/com/sky/common/properties/JwtProperties.java → sky-common/src/main/java/com/sky/common/properties/RedisTokenProperties.java
View File

@ -5,9 +5,9 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "sky.jwt")
@ConfigurationProperties(prefix = "sky.redis-token")
@Data
public class JwtProperties {
public class RedisTokenProperties {
/**
* 管理端员工生成jwt令牌相关配置
*/

19
sky-common/src/main/java/com/sky/common/result/PageResult.java Normal file
View File

@ -0,0 +1,19 @@
package com.sky.common.result;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.List;
/**
* 封装分页查询结果
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PageResult<T> implements Serializable {
private long total; // 总记录数
private List<T> records; // 当前页数据集合
}

40
sky-common/src/main/java/com/sky/common/result/Result.java Normal file
View File

@ -0,0 +1,40 @@
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.code = 1;
result.data = object;
return result;
}
// 错误返回
public static <T> Result<T> error(String message) {
Result<T> result = new Result<>();
result.code = 0;
result.message = message;
return result;
}
}

168
sky-common/src/main/java/com/sky/common/utils/HttpClientUtil.java Normal file
View File

@ -0,0 +1,168 @@
package com.sky.common.utils;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import java.io.IOException;
import java.net.URI;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* Http工具类
*/
public class HttpClientUtil {
static final int TIMEOUT_MSEC = 5 * 1000;
/**
* 发送GET方式请求
*/
public static String doGet(String url, Map<String, String> paramMap) {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
String result = "";
CloseableHttpResponse response = null;
try {
URIBuilder builder = new URIBuilder(url);
if (paramMap != null) {
for (String key : paramMap.keySet()) {
builder.addParameter(key, paramMap.get(key));
}
}
URI uri = builder.build();
// 创建GET请求
HttpGet httpGet = new HttpGet(uri);
// 发送请求
response = httpClient.execute(httpGet);
// 判断响应状态
if (response.getStatusLine().getStatusCode() == 200) {
result = EntityUtils.toString(response.getEntity(), "UTF-8");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
response.close();
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}
/**
* 发送POST方式请求
*/
public static String doPost(String url, Map<String, String> paramMap) throws IOException {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (paramMap != null) {
List<NameValuePair> paramList = new ArrayList();
for (Map.Entry<String, String> param : paramMap.entrySet()) {
paramList.add(new BasicNameValuePair(param.getKey(), param.getValue()));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
httpPost.setEntity(entity);
}
httpPost.setConfig(builderRequestConfig());
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
} catch (Exception e) {
throw e;
} finally {
try {
response.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return resultString;
}
/**
* 发送POST方式请求
*/
public static String doPost4Json(String url, Map<String, String> paramMap) throws IOException {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
if (paramMap != null) {
// 构造json格式数据
JSONObject jsonObject = new JSONObject();
for (Map.Entry<String, String> param : paramMap.entrySet()) {
jsonObject.put(param.getKey(), param.getValue());
}
StringEntity entity = new StringEntity(jsonObject.toString(), "utf-8");
// 设置请求编码
entity.setContentEncoding("utf-8");
// 设置数据类型
entity.setContentType("application/json");
httpPost.setEntity(entity);
}
httpPost.setConfig(builderRequestConfig());
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
} catch (Exception e) {
throw e;
} finally {
try {
response.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return resultString;
}
private static RequestConfig builderRequestConfig() {
return RequestConfig.custom()
.setConnectTimeout(TIMEOUT_MSEC)
.setConnectionRequestTimeout(TIMEOUT_MSEC)
.setSocketTimeout(TIMEOUT_MSEC).build();
}
}

41
sky-common/src/main/java/com/sky/common/utils/InterceptorUtil.java Normal file
View File

@ -0,0 +1,41 @@
package com.sky.common.utils;
import com.alibaba.fastjson.JSON;
import com.sky.common.constant.MessageConstant;
import com.sky.common.result.Result;
import lombok.extern.slf4j.Slf4j;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
@Slf4j
public class InterceptorUtil {
/**
* 用户未登录返回响应
*
* @param response 返回体
*/
public static void unLoginInterceptor(HttpServletResponse response) throws IOException {
log.info("用户未登录");
customLoginInterceptor(response, MessageConstant.USER_NOT_LOGIN, "");
}
/**
* 构建用户登录失败
*
* @param response HttpServletResponse
* @param message 消息
* @param data 内容
*/
public static void customLoginInterceptor(HttpServletResponse response, String message, String data) throws IOException {
response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
response.setContentType("application/json");
response.setCharacterEncoding("UTF-8");
Result<String> result = new Result<>();
result.setCode(HttpServletResponse.SC_UNAUTHORIZED);
result.setData(data);
result.setMessage(message);
// 将消息写入响应体
response.getWriter().write(JSON.toJSONString(result));
}
}

53
sky-common/src/main/java/com/sky/common/utils/JwtUtil.java Normal file
View File

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

34
sky-common/src/main/java/com/sky/common/utils/MD5.java Normal file
View File

@ -0,0 +1,34 @@
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"));
}
}

112
sky-common/src/main/java/com/sky/common/utils/MinioUtils.java Normal file
View File

@ -0,0 +1,112 @@
package com.sky.common.utils;
import com.sky.common.properties.MinioProperties;
import io.minio.*;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.io.InputStream;
@Component
@RequiredArgsConstructor
@Slf4j
public class MinioUtils {
private final MinioClient minioClient;
private final MinioProperties minioProperties;
/**
* 判断桶是否存在
*
* @param bucketName String
* @return found
*/
public boolean bucketExists(String bucketName) {
boolean found = false;
try {
found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
e.printStackTrace();
}
return found;
}
/**
* 如果桶不存在就新建
*
* @param bucketName String
*/
public void bucketCreate(String bucketName) {
boolean exists = bucketExists(bucketName);
if (!exists) {
try {
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 上传文件
*
* @param fileName 文件名
* @param inputStream 输入流
* @param size 文件大小
*/
public String uploadFile(String bucketName, String fileName, InputStream inputStream, Long size) {
try {
minioClient.putObject(PutObjectArgs.builder()
.bucket(bucketName)
.object(fileName)
.stream(inputStream, size, -1)
.build());
return minioProperties.getEndpointUrl() + "/" + bucketName + "/" + fileName;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 上传文件
*
* @param fileName 文件名
* @param inputStream 输入流
* @param size 文件大小
* @param contentType 文件类型
*/
public String uploadFile(String bucketName, String fileName, InputStream inputStream, Long size, String contentType) {
try {
minioClient.putObject(PutObjectArgs.builder()
.bucket(bucketName)
.object(fileName)
.stream(inputStream, size, -1)
.contentType(contentType)
.build());
return minioProperties.getEndpointUrl() + "/" + bucketName + "/" + fileName;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 获取文件
*
* @param bucketName 桶名称
* @param fileName 对象名称
*/
public InputStream getFile(String bucketName, String fileName) {
try {
return minioClient.getObject(GetObjectArgs.builder()
.bucket(bucketName)
.object(fileName)
.build());
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}

20
sky-common/src/main/java/com/sky/common/utils/RedisUtil.java Normal file
View File

@ -0,0 +1,20 @@
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);
}
}
}

27
sky-common/src/main/java/com/sky/common/utils/RestTemplateUtil.java Normal file
View File

@ -0,0 +1,27 @@
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;
}
}

225
sky-common/src/main/java/com/sky/common/utils/WeChatPayUtil.java Normal file
View File

@ -0,0 +1,225 @@
package com.sky.common.utils;
import com.alibaba.fastjson.JSONObject;
import com.sky.common.context.BaseContext;
import com.sky.common.properties.WeChatProperties;
import com.wechat.pay.contrib.apache.httpclient.WechatPayHttpClientBuilder;
import com.wechat.pay.contrib.apache.httpclient.util.PemUtil;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang.RandomStringUtils;
import org.apache.http.HttpHeaders;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Component;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.PrivateKey;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.UUID;
/**
* 微信支付工具类
*/
@Component
@RequiredArgsConstructor
public class WeChatPayUtil {
// 微信支付下单接口地址
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";
private final WeChatProperties weChatProperties;
/**
* 获取调用微信接口的客户端工具对象
*/
private CloseableHttpClient getClient() {
PrivateKey merchantPrivateKey = null;
try {
// merchantPrivateKey商户API私钥，如何加载商户API私钥请看常见问题
merchantPrivateKey = PemUtil.loadPrivateKey(new FileInputStream(new File(weChatProperties.getPrivateKeyFilePath())));
// 加载平台证书文件
X509Certificate x509Certificate = PemUtil.loadCertificate(new FileInputStream(new File(weChatProperties.getWeChatPayCertFilePath())));
// wechatPayCertificates微信支付平台证书列表。你也可以使用后面章节提到的“定时更新平台证书功能”，而不需要关心平台证书的来龙去脉
List<X509Certificate> wechatPayCertificates = Collections.singletonList(x509Certificate);
WechatPayHttpClientBuilder builder = WechatPayHttpClientBuilder.create()
.withMerchant(weChatProperties.getMchid(), weChatProperties.getMchSerialNo(), merchantPrivateKey)
.withWechatPay(wechatPayCertificates);
// 通过WechatPayHttpClientBuilder构造的HttpClient，会自动的处理签名和验签
CloseableHttpClient httpClient = builder.build();
return httpClient;
} catch (FileNotFoundException e) {
e.printStackTrace();
return null;
}
}
/**
* 发送post方式请求
*
* @param url
* @param body
* @return
*/
private String post(String url, String body) throws Exception {
CloseableHttpClient httpClient = getClient();
HttpPost httpPost = new HttpPost(url);
httpPost.addHeader(HttpHeaders.ACCEPT, ContentType.APPLICATION_JSON.toString());
httpPost.addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.toString());
httpPost.addHeader("Wechatpay-Serial", weChatProperties.getMchSerialNo());
httpPost.setEntity(new StringEntity(body, "UTF-8"));
CloseableHttpResponse response = httpClient.execute(httpPost);
try {
return EntityUtils.toString(response.getEntity());
} finally {
httpClient.close();
response.close();
}
}
/**
* 发送get方式请求
*
* @param url
* @return
*/
private String get(String url) throws Exception {
CloseableHttpClient httpClient = getClient();
HttpGet httpGet = new HttpGet(url);
httpGet.addHeader(HttpHeaders.ACCEPT, ContentType.APPLICATION_JSON.toString());
httpGet.addHeader(HttpHeaders.CONTENT_TYPE, ContentType.APPLICATION_JSON.toString());
httpGet.addHeader("Wechatpay-Serial", weChatProperties.getMchSerialNo());
CloseableHttpResponse response = httpClient.execute(httpGet);
try {
return EntityUtils.toString(response.getEntity());
} finally {
httpClient.close();
response.close();
}
}
/**
* jsapi下单
*
* @param orderNum 商户订单号
* @param total 总金额
* @param description 商品描述
* @param openid 微信用户的openid
*/
private String jsapi(String orderNum, BigDecimal total, String description, String openid) throws Exception {
JSONObject jsonObject = new JSONObject();
jsonObject.put("appid", weChatProperties.getAppid());
jsonObject.put("mchid", weChatProperties.getMchid());
jsonObject.put("description", description);
jsonObject.put("out_trade_no", orderNum);
jsonObject.put("notify_url", weChatProperties.getNotifyUrl());
JSONObject amount = new JSONObject();
amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue());
amount.put("currency", "CNY");
jsonObject.put("amount", amount);
JSONObject payer = new JSONObject();
payer.put("openid", openid);
jsonObject.put("payer", payer);
String body = jsonObject.toJSONString();
return post(JSAPI, body);
}
/**
* 小程序支付
*
* @param orderNum 商户订单号
* @param total 金额，单位 元
* @param description 商品描述
* @param openid 微信用户的openid
* @return
*/
public JSONObject pay(String orderNum, BigDecimal total, String description, String openid) throws Exception {
// 统一下单，生成预支付交易单
// String bodyAsString = jsapi(orderNum, total, description, openid);
// 解析返回结果
// JSONObject jsonObject = JSON.parseObject(bodyAsString);
// String prepayId = jsonObject.getString("prepay_id");
String prepayId = "bunny-" + UUID.randomUUID();
String timeStamp = String.valueOf(System.currentTimeMillis() / 1000);
String nonceStr = RandomStringUtils.randomNumeric(32);
ArrayList<Object> list = new ArrayList<>();
list.add(weChatProperties.getAppid());
list.add(timeStamp);
list.add(nonceStr);
list.add("prepay_id=" + prepayId);
// 二次签名，调起支付需要重新签名
// StringBuilder stringBuilder = new StringBuilder();
// for (Object o : list) {
// stringBuilder.append(o).append("\n");
// }
// String signMessage = stringBuilder.toString();
// byte[] message = signMessage.getBytes();
// Signature signature = Signature.getInstance("SHA256withRSA");
// signature.initSign(PemUtil.loadPrivateKey(Files.newInputStream(new File(weChatProperties.getPrivateKeyFilePath()).toPath())));
// signature.update(message);
// String packageSign = Base64.getEncoder().encodeToString(signature.sign());
// 构造数据给微信小程序，用于调起微信支付
JSONObject jo = new JSONObject();
jo.put("timeStamp", timeStamp);
jo.put("nonceStr", nonceStr);
jo.put("package", "prepay_id=" + prepayId);
jo.put("signType", "RSA");
jo.put("paySign", BaseContext.getUserId() + "-" + prepayId);
return jo;
// return jsonObject;
}
/**
* 申请退款
*
* @param outTradeNo 商户订单号
* @param outRefundNo 商户退款单号
* @param refund 退款金额
* @param total 原订单金额
* @return
*/
public String refund(String outTradeNo, String outRefundNo, BigDecimal refund, BigDecimal total) throws Exception {
JSONObject jsonObject = new JSONObject();
jsonObject.put("out_trade_no", outTradeNo);
jsonObject.put("out_refund_no", outRefundNo);
JSONObject amount = new JSONObject();
amount.put("refund", refund.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue());
amount.put("total", total.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP).intValue());
amount.put("currency", "CNY");
jsonObject.put("amount", amount);
jsonObject.put("notify_url", weChatProperties.getRefundNotifyUrl());
String body = jsonObject.toJSONString();
// 调用申请退款接口
return post(REFUNDS, body);
}
}

6
sky-pojo/pom.xml
View File

@ -1,4 +1,4 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
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>
<parent>
@ -22,5 +22,9 @@
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-spring-boot-starter</artifactId>
</dependency>
</dependencies>
</project>

51
sky-server/pom.xml
View File

@ -1,6 +1,9 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
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>
<parent>
<groupId>com.sky</groupId>
<artifactId>dev-sky-serve-v1</artifactId>
@ -9,26 +12,10 @@
<artifactId>sky-server</artifactId>
<packaging>jar</packaging>
<name>sky-server</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.sky</groupId>
<artifactId>sky-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.sky</groupId>
<artifactId>sky-pojo</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
@ -131,22 +118,16 @@
<artifactId>junit</artifactId>
<version>4.13.1</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>15</source>
<target>15</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
<dependency>
<groupId>com.sky</groupId>
<artifactId>sky-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.sky</groupId>
<artifactId>sky-pojo</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>

2
sky-server/src/main/java/com/sky/SkyApplication.java
View File

@ -14,6 +14,6 @@ import org.springframework.transaction.annotation.EnableTransactionManagement;
@Slf4j
public class SkyApplication {
public static void main(String[] args) {
SpringApplication.run(SkyApplication.class);
SpringApplication.run(SkyApplication.class, args);
}
}

14
sky-server/src/main/java/com/sky/annotation/AutoFill.java Normal file
View File

@ -0,0 +1,14 @@
package com.sky.annotation;
import com.sky.common.enumeration.OperationType;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface AutoFill {
OperationType value();
}

13
sky-server/src/main/java/com/sky/aspect/AutoFillAspect.java Normal file
View File

@ -0,0 +1,13 @@
package com.sky.aspect;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;
/**
* 自定义切面，实现公共字段自动填充处理逻辑
*/
@Aspect
@Component
@Slf4j
public class AutoFillAspect {
}

25
sky-server/src/main/java/com/sky/controller/admin/EmployeeController.java
View File

@ -1,10 +1,7 @@
package com.sky.controller.admin;
import com.sky.common.constant.JwtClaimsConstant;
import com.sky.common.properties.JwtProperties;
import com.sky.common.result.PageResult;
import com.sky.common.result.Result;
import com.sky.common.utils.JwtUtil;
import com.sky.pojo.dto.EmployeeDTO;
import com.sky.pojo.dto.EmployeeLoginDTO;
import com.sky.pojo.dto.EmployeePageQueryDTO;
@ -18,9 +15,6 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.HashMap;
import java.util.Map;
/**
* 员工管理
*/
@ -29,31 +23,14 @@ import java.util.Map;
@Slf4j
@Api(tags = "员工相关接口")
public class EmployeeController {
@Autowired
private EmployeeService employeeService;
@Autowired
private JwtProperties jwtProperties;
@PostMapping("/login")
@ApiOperation(value = "登录接口")
public Result<EmployeeLoginVO> login(@RequestBody EmployeeLoginDTO employeeLoginDTO) {
log.info("员工登录：{}", employeeLoginDTO);
Employee employee = employeeService.login(employeeLoginDTO);
// 登录成功后，生成jwt令牌
Map<String, Object> claims = new HashMap<>();
claims.put(JwtClaimsConstant.EMP_ID, employee.getId());
String token = JwtUtil.createJWT(jwtProperties.getAdminSecretKey(), jwtProperties.getAdminTtl(), claims);
EmployeeLoginVO employeeLoginVO = EmployeeLoginVO.builder()
.id(employee.getId())
.userName(employee.getUsername())
.name(employee.getName())
.token(token).build();
return Result.success(employeeLoginVO);
return Result.success(employeeService.login(employeeLoginDTO));
}
@PostMapping("/logout")

6
sky-server/src/main/java/com/sky/controller/admin/ShopController.java
View File

@ -4,19 +4,19 @@ import com.sky.common.constant.MessageConstant;
import com.sky.common.result.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
@RestController("adminShopController")
@RequiredArgsConstructor
@RequestMapping("/admin/shop")
@Api(tags = "店铺相关接口")
@Slf4j
public class ShopController {
public static final String KEY = "SHOP_STATUS";
private final RedisTemplate<Object, Object> redisTemplate;
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@PutMapping("/{status}")
@ApiOperation("设置店铺的营业状态")

5
sky-server/src/main/java/com/sky/controller/user/DishController.java
View File

@ -24,7 +24,7 @@ import java.util.concurrent.TimeUnit;
@Slf4j
@Api(tags = "C端-菜品浏览接口")
public class DishController {
private final RedisTemplate<Object, Object> redisTemplate;
private final RedisTemplate redisTemplate;
DishService dishService;
@GetMapping("/list")
@ -33,7 +33,8 @@ public class DishController {
// 构造redis中的key，规则dish_分类id
String key = "dish_" + categoryId;
// 查询redis中是否存在菜品数据
List<DishVO> list = (List<DishVO>) redisTemplate.opsForValue().get(key);
String object = redisTemplate.opsForValue().get(key) + "";
List<DishVO> list = JSON.parseArray(object, DishVO.class);
// 如果存在返回，无需查询数据库
if (list != null && !list.isEmpty()) {
return Result.success(list);

6
sky-server/src/main/java/com/sky/controller/user/UserController.java
View File

@ -1,7 +1,7 @@
package com.sky.controller.user;
import com.sky.common.constant.JwtClaimsConstant;
import com.sky.common.properties.JwtProperties;
import com.sky.common.properties.RedisTokenProperties;
import com.sky.common.result.Result;
import com.sky.common.utils.JwtUtil;
import com.sky.pojo.dto.UserLoginDTO;
@ -28,7 +28,7 @@ public class UserController {
@Autowired
private UserService userService;
@Autowired
private JwtProperties jwtProperties;
private RedisTokenProperties redisTokenProperties;
@PostMapping("/login")
@ApiOperation("微信登录")
@ -41,7 +41,7 @@ public class UserController {
// 为微信用户生成jwt令牌
Map<String, Object> claims = new HashMap<>();
claims.put(JwtClaimsConstant.USER_ID, user.getId());
String token = JwtUtil.createJWT(jwtProperties.getUserSecretKey(), jwtProperties.getUserTtl(), claims);
String token = JwtUtil.createJWT(redisTokenProperties.getUserSecretKey(), redisTokenProperties.getUserTtl(), claims);
UserLoginVO userLoginVO = UserLoginVO.builder()
.id(user.getId())

3
sky-server/src/main/java/com/sky/service/EmployeeService.java
View File

@ -7,6 +7,7 @@ import com.sky.pojo.dto.EmployeeLoginDTO;
import com.sky.pojo.dto.EmployeePageQueryDTO;
import com.sky.pojo.dto.PasswordEditDTO;
import com.sky.pojo.entity.Employee;
import com.sky.pojo.vo.EmployeeLoginVO;
public interface EmployeeService {
@ -16,7 +17,7 @@ public interface EmployeeService {
* @param employeeLoginDTO 员工等了信息
* @return 员工信息
*/
Employee login(EmployeeLoginDTO employeeLoginDTO);
EmployeeLoginVO login(EmployeeLoginDTO employeeLoginDTO);
/**
* 新增员工

21
sky-server/src/main/java/com/sky/service/impl/EmployeeServiceImpl.java
View File

@ -16,21 +16,26 @@ import com.sky.pojo.dto.EmployeeLoginDTO;
import com.sky.pojo.dto.EmployeePageQueryDTO;
import com.sky.pojo.dto.PasswordEditDTO;
import com.sky.pojo.entity.Employee;
import com.sky.pojo.vo.EmployeeLoginVO;
import com.sky.service.EmployeeService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.DigestUtils;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@Service
public class EmployeeServiceImpl implements EmployeeService {
@Autowired
private EmployeeMapper employeeMapper;
@Autowired
private RedisTemplate<String, Object> redisTemplate;
/**
* 员工登录
@ -38,9 +43,10 @@ public class EmployeeServiceImpl implements EmployeeService {
* @param employeeLoginDTO 员工登录时传递的数据模型
* @return 员工信息
*/
public Employee login(EmployeeLoginDTO employeeLoginDTO) {
public EmployeeLoginVO login(EmployeeLoginDTO employeeLoginDTO) {
String username = employeeLoginDTO.getUsername();
String password = employeeLoginDTO.getPassword();
String token = UUID.randomUUID().toString();
// 1、根据用户名查询数据库中的数据
Employee employee = employeeMapper.getByUsername(username);
@ -50,7 +56,6 @@ public class EmployeeServiceImpl implements EmployeeService {
// 账号不存在
throw new AccountNotFoundException(MessageConstant.ACCOUNT_NOT_FOUND);
}
// 密码比对
// 后期需要进行md5加密，然后再进行比对
password = DigestUtils.md5DigestAsHex(password.getBytes());
@ -58,14 +63,18 @@ public class EmployeeServiceImpl implements EmployeeService {
// 密码错误
throw new PasswordErrorException(MessageConstant.PASSWORD_ERROR);
}
// 账号被锁定
if (Objects.equals(employee.getStatus(), StatusConstant.DISABLE)) {
throw new AccountLockedException(MessageConstant.ACCOUNT_LOCKED);
}
// 使用userId存入登录信息
redisTemplate.opsForValue().set(token, employee.getId(), 7, TimeUnit.DAYS);
// 3、返回实体对象
return employee;
return EmployeeLoginVO.builder()
.id(employee.getId())
.userName(employee.getUsername())
.name(employee.getName())
.token(token).build();
}
/**

54
sky-server/src/main/java/com/sky/task/OrderTask.java Normal file
View File

@ -0,0 +1,54 @@
package com.sky.task;
import com.sky.mapper.OrderMapper;
import com.sky.pojo.entity.Orders;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
@Component
@Slf4j
public class OrderTask {
@Resource
private OrderMapper orderMapper;
/**
* 处理超时订单
*/
@Scheduled(cron = "0 * * * * ?")
// @Scheduled(cron = "0/5 * * * * ?")
public void processTImeOrder() {
log.info("定时处理超时订单：{}", LocalDateTime.now());
LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
List<Orders> list = orderMapper.getByStatusAndOrderTime(Orders.PENDING_PAYMENT, time);
if (list != null && !list.isEmpty()) {
for (Orders orders : list) {
orders.setStatus(Orders.CANCELLED);
orders.setCancelReason("订单超时，自动取消");
orders.setCancelTime(LocalDateTime.now());
orderMapper.update(orders);
}
}
}
/**
* 处理一直派送中的订单
*/
@Scheduled(cron = "0 0 1 * * ?")
// @Scheduled(cron = "0/5 * * * * ?")
public void processDeliveryOrder() {
log.info("定时处理处于派送中的订单：{}", LocalDateTime.now());
LocalDateTime time = LocalDateTime.now().plusMinutes(-60);
List<Orders> list = orderMapper.getByStatusAndOrderTime(Orders.DELIVERY_IN_PROGRESS, time);
if (list != null && !list.isEmpty()) {
for (Orders orders : list) {
orders.setStatus(Orders.COMPLETED);
orderMapper.update(orders);
}
}
}
}

20
sky-server/src/main/java/com/sky/task/WebSocketTask.java Normal file
View File

@ -0,0 +1,20 @@
package com.sky.task;
import com.sky.websocket.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@Component
public class WebSocketTask {
@Autowired
WebSocketServer webSocketServer;
@Scheduled(cron = "0/2 * * * * ?")
public void sendMessageToClient() {
webSocketServer.sendToAllClient("这是来自服务端消息" + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));
}
}

47
sky-server/src/main/java/com/sky/websocket/WebSocketServer.java Normal file
View File

@ -0,0 +1,47 @@
package com.sky.websocket;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
@Component
@ServerEndpoint("/ws/{sid}")
@Slf4j
public class WebSocketServer {
// 存放会话对象
private static final Map<String, Session> sessionMap = new HashMap<>();
// 连接建立成功调用的方法
@OnOpen
public void onOpen(Session session, @PathParam("sid") String sid) {
log.info("客户端：{}--->建立连接", sid);
sessionMap.put(sid, session);
}
// 收到客户端消息后调用的方法
@OnMessage
public void onMessage(String message, @PathParam("sid") String sid) {
log.info("收到来自客户端：{}；信息为：{}", sid, message);
}
// 群发
public void sendToAllClient(String message) {
Collection<Session> sessions = sessionMap.values();
for (Session session : sessions) {
try {
// 服务器向客户端发送消息
session.getBasicRemote().sendText(message);
} catch (Exception exception) {
exception.printStackTrace();
}
}
}
}

2
sky-server/src/main/resources/application-dev.yml
View File

@ -15,7 +15,7 @@ sky:
redis:
host: 106.15.251.123
port: 6378
port: 6379
password: "02120212"
database: 10

10
sky-server/src/main/resources/application.yml
View File

@ -2,6 +2,8 @@ server:
port: 8080
spring:
application:
name: dev-sky-serve-redis
profiles:
active: dev
# mvc:
@ -35,11 +37,15 @@ logging:
mapper: debug
service: info
controller: info
pattern:
dateformat: HH:mm:ss:SSS
file:
path: "logs/${spring.application.name}"
sky:
jwt:
redisToken:
# 设置jwt签名加密时使用的秘钥
admin-secret-key: itcast
admin-secret-key: bunny
# 设置jwt过期时间
admin-ttl: 7200000
# 设置前端传递过来的令牌名称