xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/station' into station

Browse Source
This commit is contained in:
nieziyan 2023-10-23 10:50:17 +08:00
commit aeb4b3ceb6
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
View File

@ -1,6 +1,7 @@
package org.jeecg.modules.message.handle; package org.jeecg.modules.message.handle;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.jeecg.common.base.BaseMap; import org.jeecg.common.base.BaseMap;
import org.jeecg.common.constant.WebSocketHandlerConst; import org.jeecg.common.constant.WebSocketHandlerConst;
import org.jeecg.common.modules.redis.listener.JeecgRedisListener; import org.jeecg.common.modules.redis.listener.JeecgRedisListener;
@ -24,6 +25,9 @@ public class AnalysisHandler implements JeecgRedisListener {
@Override @Override
public void onMessage(BaseMap message) { public void onMessage(BaseMap message) {
if (ObjectUtils.isEmpty(message.get("userId"))) {
return;
}
webSocket.sendMessage(message.get("userId").toString(), message.get("message")); webSocket.sendMessage(message.get("userId").toString(), message.get("message"));
} }