Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in
Toggle navigation
O
on-site-service
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
external
on-site-service
Commits
13a5020e
Commit
13a5020e
authored
Jul 07, 2022
by
shangtx
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
chore: 管理端websocket
parent
afe3ec29
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
32 additions
and
27 deletions
+32
-27
OrderListener.java
.../java/com/onsiteservice/admin/listener/OrderListener.java
+28
-0
application.yaml
admin/src/main/resources/application.yaml
+2
-2
OrderListenerTest.java
...a/com/onsiteservice/admin/listener/OrderListenerTest.java
+0
-0
pom.xml
common/pom.xml
+0
-24
SysConstants.java
...ava/com/onsiteservice/constant/constant/SysConstants.java
+2
-1
No files found.
admin/src/main/java/com/onsiteservice/admin/listener/OrderListener.java
0 → 100644
View file @
13a5020e
package
com
.
onsiteservice
.
admin
.
listener
;
import
com.onsiteservice.common.socket.SocketHandler
;
import
com.onsiteservice.constant.constant.SysConstants
;
import
org.springframework.amqp.rabbit.annotation.Queue
;
import
org.springframework.amqp.rabbit.annotation.RabbitHandler
;
import
org.springframework.amqp.rabbit.annotation.RabbitListener
;
import
org.springframework.stereotype.Component
;
import
org.springframework.web.socket.TextMessage
;
import
javax.annotation.Resource
;
/**
* 管理端事件通知
*/
@Component
@RabbitListener
(
queuesToDeclare
=
@Queue
(
SysConstants
.
Queue
.
ADMIN_ORDER
))
public
class
OrderListener
{
@Resource
private
SocketHandler
socketHandler
;
@RabbitHandler
public
void
notice
(
Integer
type
)
{
socketHandler
.
sendMessageToAll
(
new
TextMessage
(
"有新订单"
));
}
}
admin/src/main/resources/application.yaml
View file @
13a5020e
...
@@ -6,8 +6,8 @@ server:
...
@@ -6,8 +6,8 @@ server:
project
:
project
:
swagger
:
swagger
:
enabled
:
true
enabled
:
true
title
:
房屋线上修缮
Web管理端${spring.profiles.active}环境
title
:
城市匠人
Web管理端${spring.profiles.active}环境
description
:
房屋线上修缮
Web管理端API文档
description
:
城市匠人
Web管理端API文档
base-package
:
com.onsiteservice.admin.controller,com.onsiteservice.common.business.controller
base-package
:
com.onsiteservice.admin.controller,com.onsiteservice.common.business.controller
jwt
:
jwt
:
enabled
:
true
# 是否开启jwt拦截
enabled
:
true
# 是否开启jwt拦截
...
...
admin/src/test/java/com/onsiteservice/admin/listener/OrderListenerTest.java
0 → 100644
View file @
13a5020e
common/pom.xml
View file @
13a5020e
...
@@ -95,13 +95,6 @@
...
@@ -95,13 +95,6 @@
<version>
4.3.0
</version>
<version>
4.3.0
</version>
</dependency>
</dependency>
<!-- 极光推送服务端SDK -->
<dependency>
<groupId>
cn.jpush.api
</groupId>
<artifactId>
jpush-client
</artifactId>
<version>
3.4.8
</version>
</dependency>
<!-- Java 操作二维码生成与解析 -->
<!-- Java 操作二维码生成与解析 -->
<dependency>
<dependency>
<groupId>
com.google.zxing
</groupId>
<groupId>
com.google.zxing
</groupId>
...
@@ -141,23 +134,6 @@
...
@@ -141,23 +134,6 @@
<version>
0.1.19
</version>
<version>
0.1.19
</version>
</dependency>
</dependency>
<!-- 微信小程序 starter配合yaml配置需要在各自的模块中 -->
<!-- <dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>wx-java-miniapp-spring-boot-starter</artifactId>
</dependency>-->
<!--微信公众号-->
<!-- <dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>wx-java-mp-spring-boot-starter</artifactId>
</dependency>-->
<!--微信支付-->
<dependency>
<groupId>
com.github.binarywang
</groupId>
<artifactId>
wx-java-pay-spring-boot-starter
</artifactId>
</dependency>
<!-- Spring Boot监控 -->
<!-- Spring Boot监控 -->
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
org.springframework.boot
</groupId>
...
...
constant/src/main/java/com/onsiteservice/constant/constant/SysConstants.java
View file @
13a5020e
...
@@ -18,7 +18,8 @@ public class SysConstants {
...
@@ -18,7 +18,8 @@ public class SysConstants {
* 消息队列定义
* 消息队列定义
*/
*/
public
class
Queue
{
public
class
Queue
{
public
static
final
String
MESSAGE
=
"msg"
;
// 管理端订单
public
static
final
String
ADMIN_ORDER
=
"admin-order"
;
public
static
final
String
SMS
=
"sms"
;
public
static
final
String
SMS
=
"sms"
;
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment