From c1d4849a2cc28cc50c5405f2382a5e4bf008b891 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期二, 12 八月 2025 10:16:45 +0800
Subject: [PATCH] update
---
MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
index 0e6ac87..0513409 100644
--- a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
@@ -78,10 +78,12 @@
if (method.equals(Method.ping)) {
String token = jsonCon.getString("token");
String userId1 = jsonCon.getString("userId");
+ String businessType = jsonCon.getString("businessType");//1：打车，2=代驾
+ String business = "2".equals(businessType) ? "daijia" : "dache";
if (StringUtil.isNotEmpty(userId1)) {
//确保账号在单个设备上登录
if (StringUtil.isNotEmpty(token)) {
- String token_ = redisUtil.getValue("USER_Applets_" + userId1);//获取缓存中最新的数据
+ String token_ = redisUtil.getValue(business + ":USER_Applets_" + userId1);//获取缓存中最新的数据
if (StringUtil.isNotEmpty(token_) && !token.equals(token_)) {//不在同一设备上登录，向其他设备发送数据
ChannelHandlerContext data_ = NettyChannelMap.getData_(token_.substring(token_.length() - 16));
JSONObject msg_ = new JSONObject();
@@ -98,13 +100,13 @@
}, 5000);
}
NettyChannelMap.update_(token.substring(token.length() - 16), ctx);//存储单点登录的通道
- NettyChannelMap.update("Applets" + userId1, ctx);
- redisUtil.setStrValue("USER_Applets_" + userId1, token);
+ NettyChannelMap.update(business + ":Applets" + userId1, ctx);
+ redisUtil.setStrValue(business + ":USER_Applets_" + userId1, token);
}
//存储业务使用的通道
if (null != ctx && ctx.channel().isActive()) {
- NettyChannelMap.update("Applets" + userId1, ctx);
+ NettyChannelMap.update(business + ":Applets" + userId1, ctx);
}
}
--
Gitblit v1.7.1