Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
W
wecloud_im_server
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
wecloud_im_server
Commits
27a6a890
Commit
27a6a890
authored
Jun 28, 2021
by
giaogiao
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修复拉黑还能发消息bug;
parent
9fa325fa
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
15 additions
and
16 deletions
+15
-16
common/src/main/java/com/wecloud/im/tillo/app_ws/strategy/concrete/ImConcreteReceiveStrategy.java
+15
-16
No files found.
common/src/main/java/com/wecloud/im/tillo/app_ws/strategy/concrete/ImConcreteReceiveStrategy.java
View file @
27a6a890
...
@@ -104,20 +104,6 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
...
@@ -104,20 +104,6 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
e
.
printStackTrace
();
e
.
printStackTrace
();
}
}
// 保存消息
ImMessage
imMessage
=
new
ImMessage
();
imMessage
.
setId
(
messageId
);
imMessage
.
setCreateTime
(
new
Date
());
imMessage
.
setFkAppid
(
imApplication
.
getId
());
imMessage
.
setSender
(
imClientSender
.
getId
());
imMessage
.
setContent
(
content
);
imMessage
.
setWithdraw
(
false
);
imMessage
.
setEvent
(
false
);
imMessage
.
setSystem
(
false
);
imMessage
.
setSendStatus
(
2
);
imMessage
.
setFkConversationId
(
toConversationId
);
imMessageService
.
save
(
imMessage
);
// 查询该会话所有成员
// 查询该会话所有成员
List
<
ImConversationMembers
>
membersList
=
imConversationMembersService
.
list
(
List
<
ImConversationMembers
>
membersList
=
imConversationMembersService
.
list
(
new
QueryWrapper
<
ImConversationMembers
>().
lambda
()
new
QueryWrapper
<
ImConversationMembers
>().
lambda
()
...
@@ -143,11 +129,9 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
...
@@ -143,11 +129,9 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
responseModel
.
setCmd
(
ResponseModel
.
RES
);
responseModel
.
setCmd
(
ResponseModel
.
RES
);
responseModel
.
setCode
(
result
.
getCode
());
responseModel
.
setCode
(
result
.
getCode
());
responseModel
.
setMsg
(
result
.
getMessage
());
responseModel
.
setMsg
(
result
.
getMessage
());
responseModel
.
setReqId
(
receiveModel
.
getReqId
());
responseModel
.
setReqId
(
receiveModel
.
getReqId
());
writeDataService
.
write
(
responseModel
,
appKey
,
clientUniId
);
writeDataService
.
write
(
responseModel
,
appKey
,
clientUniId
);
return
;
return
;
}
}
// 是否把对方拉黑
// 是否把对方拉黑
...
@@ -166,6 +150,21 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
...
@@ -166,6 +150,21 @@ public class ImConcreteReceiveStrategy extends AbstractReceiveStrategy {
}
}
}
}
// 保存消息
ImMessage
imMessage
=
new
ImMessage
();
imMessage
.
setId
(
messageId
);
imMessage
.
setCreateTime
(
new
Date
());
imMessage
.
setFkAppid
(
imApplication
.
getId
());
imMessage
.
setSender
(
imClientSender
.
getId
());
imMessage
.
setContent
(
content
);
imMessage
.
setWithdraw
(
false
);
imMessage
.
setEvent
(
false
);
imMessage
.
setSystem
(
false
);
imMessage
.
setSendStatus
(
2
);
imMessage
.
setFkConversationId
(
toConversationId
);
imMessageService
.
save
(
imMessage
);
// 封装响应的实体
// 封装响应的实体
ImMessageOnlineSend
imMessageOnlineSend
=
new
ImMessageOnlineSend
();
ImMessageOnlineSend
imMessageOnlineSend
=
new
ImMessageOnlineSend
();
BeanUtils
.
copyProperties
(
imMessage
,
imMessageOnlineSend
);
BeanUtils
.
copyProperties
(
imMessage
,
imMessageOnlineSend
);
...
...
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