Tenlion/cm-cloud
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加了通知中的service字段

Browse Source
This commit is contained in:
wanggeng 2021-07-22 22:59:45 +08:00
parent 1455a07772
commit ab58ad626e
2 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cloud-common-websocket/src/main/java/com/cm/websocket/pojo/AppSocketMessage.java
View File

@ -219,6 +219,7 @@ public class AppSocketMessage {
private String title; private String title;
private String msg; private String msg;
private String target; private String target;
private String serviceId;
public NoticeBody() { public NoticeBody() {
} }
@ -234,6 +235,13 @@ public class AppSocketMessage {
this.target = target; this.target = target;
} }
public NoticeBody(String title, String msg, String target, String serviceId) {
this.title = title;
this.msg = msg;
this.target = target;
this.serviceId = serviceId;
}
public String getTitle() { public String getTitle() {
return title == null ? "" : title; return title == null ? "" : title;
} }
@ -257,6 +265,14 @@ public class AppSocketMessage {
public void setTarget(String target) { public void setTarget(String target) {
this.target = target; this.target = target;
} }
public String getServiceId() {
return serviceId;
}
public void setServiceId(String serviceId) {
this.serviceId = serviceId;
}
} }
public static class CountNeedToDealWithBody { public static class CountNeedToDealWithBody {

2
cloud-common-websocket/src/main/java/com/cm/websocket/service/impl/MessageServiceImpl.java
View File

@ -102,7 +102,7 @@ public class MessageServiceImpl extends AbstractService implements IMessageServi
scheduledExecutorService.schedule(() -> { scheduledExecutorService.schedule(() -> {
for (AppSocketSession appSocketSession : appSocketSessions) { for (AppSocketSession appSocketSession : appSocketSessions) {
Session session = appSocketSession.getSession(); Session session = appSocketSession.getSession();
AppSocketMessage.NoticeBody noticeBody = new AppSocketMessage.NoticeBody(notice.getTitle(), notice.getMsg(), notice.getTarget()); AppSocketMessage.NoticeBody noticeBody = new AppSocketMessage.NoticeBody(notice.getTitle(), notice.getMsg(), notice.getTarget(), notice.getServiceId());
AppSocketMessage appSocketMessage = new AppSocketMessage(AppSocketTypeEnum.NOTICE_TARGET_MESSAGE.getValue(), AppSocketMessage appSocketMessage = new AppSocketMessage(AppSocketTypeEnum.NOTICE_TARGET_MESSAGE.getValue(),
true, true,
AppSocketSessionManager.FORM_SYSTEM, AppSocketSessionManager.FORM_SYSTEM,