From 91b70d5ad2ada85cf00b25f7b9ecd9cf980bf138 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期一, 12 八月 2024 16:42:44 +0800
Subject: [PATCH] 优化：websocket接收消息
---
ard-work/src/main/java/com/ruoyi/app/position/service/impl/AppPositionPushService.java | 24 +++++++++++-------------
1 files changed, 11 insertions(+), 13 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/app/position/service/impl/AppPositionPushService.java b/ard-work/src/main/java/com/ruoyi/app/position/service/impl/AppPositionPushService.java
index d60f957..a993ad1 100644
--- a/ard-work/src/main/java/com/ruoyi/app/position/service/impl/AppPositionPushService.java
+++ b/ard-work/src/main/java/com/ruoyi/app/position/service/impl/AppPositionPushService.java
@@ -88,12 +88,12 @@
IArdAppPositionService ardAppPositionService = SpringUtils.getBean(IArdAppPositionService.class);
ArdAppPosition ardAppPosition = ardAppPositionService.selectLastArdAppPositionByUserId(sysUser.getUserId());
if (StringUtils.isNotNull(ardAppPosition)) {
- Map<String, Object> params=new HashMap<>();
- params.put("longitude",ardAppPosition.getLongitude());
- params.put("latitude",ardAppPosition.getLatitude());
- params.put("speed",ardAppPosition.getSpeed());
- params.put("bearing",ardAppPosition.getBearing());
- params.put("name",sysUser.getUserName());
+ Map<String, Object> params = new HashMap<>();
+ params.put("longitude", ardAppPosition.getLongitude());
+ params.put("latitude", ardAppPosition.getLatitude());
+ params.put("speed", ardAppPosition.getSpeed());
+ params.put("bearing", ardAppPosition.getBearing());
+ params.put("name", sysUser.getUserName());
ardAppPosition.setParams(params);
ArdAppPositions.add(ardAppPosition);
}
@@ -108,8 +108,8 @@
for (ArdAppPosition ardAppPosition : data) {
ISysUserService sysUserService = SpringUtils.getBean(ISysUserService.class);
SysUser sysUser = sysUserService.selectUserById(ardAppPosition.getUserId());
- if(StringUtils.isNotNull(sysUser)) {
- if(StringUtils.isNotNull(sysUser.getAppOnlineState())) {
+ if (StringUtils.isNotNull(sysUser)) {
+ if (StringUtils.isNotNull(sysUser.getAppOnlineState())) {
if (sysUser.getAppOnlineState().equals("1")) {
onlineList.add(ardAppPosition);
}
@@ -126,8 +126,7 @@
Map<String, Object> map = JSONObject.parseObject(message, Map.class);
if (map.size() > 0) {
Boolean enabled = (Boolean) map.get("enabled");
- if(enabled==null)
- {
+ if (enabled == null) {
return;
}
if (enabled) {
@@ -177,10 +176,9 @@
AppPositionPushService.tempDataMap.remove(userId);
}
}
- }
- catch (Exception ex)
- {
+ } catch (Exception ex) {
log.error(ex.getMessage());
+ WebSocketUtils.sendMessage(userId, "app浣嶇疆鎺ㄩ�佽В鏋愭秷鎭��" + message + "銆戝紓甯�:" + ex.getMessage());
}
}
--
Gitblit v1.9.3