Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
S
SiEn
Overview
Overview
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
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
hewei
SiEn
Commits
46255ed1
Commit
46255ed1
authored
Nov 02, 2020
by
zhangjw
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
1:修改POM依赖 独立客服模块
parent
c41cfb42
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
27 additions
and
30 deletions
+27
-30
customer-service/pom.xml
+24
-28
customer-service/src/main/java/com/ym/im/mq/Receiver.java
+3
-2
No files found.
customer-service/pom.xml
View file @
46255ed1
...
@@ -2,10 +2,12 @@
...
@@ -2,10 +2,12 @@
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
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"
>
<parent>
<parent>
<groupId>
io.geekidea.springbootplus
</groupId>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
parent
</artifactId>
<artifactId>
spring-boot-starter-parent
</artifactId>
<version>
2.0
</version>
<version>
2.2.5.RELEASE
</version>
<relativePath/>
</parent>
</parent>
<modelVersion>
4.0.0
</modelVersion>
<modelVersion>
4.0.0
</modelVersion>
...
@@ -47,30 +49,23 @@
...
@@ -47,30 +49,23 @@
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.apache.httpcomponents
</groupId>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
httpclient
</artifactId>
<artifactId>
spring-boot-starter-data-redis
</artifactId>
</dependency>
<dependency>
<groupId>
org.apache.httpcomponents
</groupId>
<artifactId>
httpmime
</artifactId>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-configuration-processor
</artifactId>
<artifactId>
spring-boot-starter-amqp
</artifactId>
<optional>
true
</optional>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
org.apache.httpcomponents
</groupId>
<artifactId>
spring-boot-starter-test
</artifactId>
<artifactId>
httpclient
</artifactId>
<scope>
test
</scope>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.
springframework.boot
</groupId>
<groupId>
org.
apache.httpcomponents
</groupId>
<artifactId>
spring-boot-starter-amqp
</artifactId>
<artifactId>
httpmime
</artifactId>
</dependency>
</dependency>
<dependency>
<dependency>
...
@@ -81,6 +76,7 @@
...
@@ -81,6 +76,7 @@
<dependency>
<dependency>
<groupId>
com.alibaba
</groupId>
<groupId>
com.alibaba
</groupId>
<artifactId>
druid-spring-boot-starter
</artifactId>
<artifactId>
druid-spring-boot-starter
</artifactId>
<version>
1.1.10
</version>
</dependency>
</dependency>
<dependency>
<dependency>
...
@@ -92,39 +88,39 @@
...
@@ -92,39 +88,39 @@
<dependency>
<dependency>
<groupId>
com.github.pagehelper
</groupId>
<groupId>
com.github.pagehelper
</groupId>
<artifactId>
pagehelper-spring-boot-starter
</artifactId>
<artifactId>
pagehelper-spring-boot-starter
</artifactId>
<version>
1.2.3
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.mybatis.spring.boot
</groupId>
<groupId>
org.mybatis.spring.boot
</groupId>
<artifactId>
mybatis-spring-boot-starter
</artifactId>
<artifactId>
mybatis-spring-boot-starter
</artifactId>
<version>
2.0.1
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
com.baomidou
</groupId>
<artifactId>
spring-boot-starter-data-redis
</artifactId>
<artifactId>
mybatis-plus-boot-starter
</artifactId>
<version>
3.3.1
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
io.springfox
</groupId>
<groupId>
io.springfox
</groupId>
<artifactId>
springfox-swagger2
</artifactId>
<artifactId>
springfox-swagger2
</artifactId>
<version>
2.9.2
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
io.springfox
</groupId>
<groupId>
io.springfox
</groupId>
<artifactId>
springfox-swagger-ui
</artifactId>
<artifactId>
springfox-swagger-ui
</artifactId>
<version>
2.9.2
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.
springframework.boot
</groupId>
<groupId>
org.
projectlombok
</groupId>
<artifactId>
spring-boot-devtools
</artifactId>
<artifactId>
lombok
</artifactId>
<
optional>
true
</optional
>
<
version>
1.18.12
</version
>
</dependency>
</dependency>
<dependency>
<groupId>
com.baomidou
</groupId>
<artifactId>
mybatis-plus-boot-starter
</artifactId>
</dependency>
</dependencies>
</dependencies>
<build>
<build>
...
...
customer-service/src/main/java/com/ym/im/mq/Receiver.java
View file @
46255ed1
package
com
.
ym
.
im
.
mq
;
package
com
.
ym
.
im
.
mq
;
import
com.alibaba.fastjson.JSON
;
import
com.ym.im.entity.ChatRecord
;
import
com.ym.im.entity.ChatRecord
;
import
com.ym.im.entity.MsgBody
;
import
com.ym.im.entity.MsgBody
;
import
com.ym.im.entity.StaffSocketInfo
;
import
com.ym.im.entity.StaffSocketInfo
;
...
@@ -12,6 +11,7 @@ import com.ym.im.entity.model.OrderModel;
...
@@ -12,6 +11,7 @@ import com.ym.im.entity.model.OrderModel;
import
com.ym.im.handler.ChannelGroupHandler
;
import
com.ym.im.handler.ChannelGroupHandler
;
import
com.ym.im.service.StaffService
;
import
com.ym.im.service.StaffService
;
import
com.ym.im.util.JsonUtils
;
import
com.ym.im.util.JsonUtils
;
import
lombok.SneakyThrows
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.amqp.rabbit.annotation.RabbitListener
;
import
org.springframework.amqp.rabbit.annotation.RabbitListener
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
@@ -105,10 +105,11 @@ public class Receiver {
...
@@ -105,10 +105,11 @@ public class Receiver {
*
*
* @param orderModel
* @param orderModel
*/
*/
@SneakyThrows
@RabbitListener
(
queues
=
ORDER_QUEUE_NAME
)
@RabbitListener
(
queues
=
ORDER_QUEUE_NAME
)
public
void
orderHandler
(
OrderModel
orderModel
)
{
public
void
orderHandler
(
OrderModel
orderModel
)
{
log
.
info
(
"Constants.ORDER_QUEUE_NAME: "
+
J
SON
.
toJSONString
(
orderModel
));
log
.
info
(
"Constants.ORDER_QUEUE_NAME: "
+
J
sonUtils
.
obj2Json
(
orderModel
));
final
UserSocketInfo
userSocketInfo
=
channelGroup
.
USER_GROUP
.
get
(
Long
.
valueOf
(
orderModel
.
getUserId
()));
final
UserSocketInfo
userSocketInfo
=
channelGroup
.
USER_GROUP
.
get
(
Long
.
valueOf
(
orderModel
.
getUserId
()));
if
(
userSocketInfo
==
null
)
{
if
(
userSocketInfo
==
null
)
{
...
...
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