From 900f2e86e31b45239cef7e3e46ee5c2541a9eb99 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期三, 22 四月 2026 21:55:55 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/1.0' into 1.0
---
xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java | 39 ++++++++-------------------------------
1 files changed, 8 insertions(+), 31 deletions(-)
diff --git a/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java b/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java
index f0b1447..6043071 100644
--- a/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java
+++ b/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java
@@ -165,23 +165,16 @@
if (appUserId != null) {
log.info("收到用户 {} 的业务消息: {}", appUserId, messageObj.toJSONString());
- businessMsgHandlers.get(messageObj.getString("type")).handle(appUserId, messageObj.getString("message"));
- //判断处理用户实时位置
- if ("location".equals(messageObj.getString("type"))) {
- log.info("收到用户 {} 的实时位置消息: {}", appUserId, messageObj.toJSONString());
- Double latitude = messageObj.getDouble("latitude");
- Double longitude = messageObj.getDouble("longitude");
- saveAppUserLocation(Long.parseLong(appUserId), latitude, longitude);
- }
+ businessMsgHandlers.get(messageObj.getString("type")).handle(appUserId, messageObj.toJSONString());
// 回复消息
- JSONObject response = new JSONObject();
- response.put("type", "message_response");
- response.put("appUserId", appUserId);
- response.put("originalMessage", messageObj);
- response.put("serverTime", LocalDateTime.now().toString());
-
- ctx.channel().writeAndFlush(new TextWebSocketFrame(response.toJSONString()));
+// JSONObject response = new JSONObject();
+// response.put("type", "message_response");
+// response.put("appUserId", appUserId);
+// response.put("originalMessage", messageObj);
+// response.put("serverTime", LocalDateTime.now().toString());
+//
+// ctx.channel().writeAndFlush(new TextWebSocketFrame(response.toJSONString()));
} else {
log.warn("收到未认证连接的业务消息: {}", messageObj.toJSONString());
@@ -224,20 +217,4 @@
ctx.channel().close();
}
-
-
- private void saveAppUserLocation(Long appUserId, Double latitude, Double longitude) {
- AppUserPosition userPosition = mongoTemplate.findOne(Query.query(Criteria.where("appUserId").is(appUserId)), AppUserPosition.class);
- GeoJsonPoint point = new GeoJsonPoint(longitude, latitude);
- if(null != userPosition){
- mongoTemplate.updateFirst(Query.query(Criteria.where("appUserId").is(appUserId)),
- Update.update("point", point).set("addTime", System.currentTimeMillis()), AppUserPosition.class);
- }else{
- userPosition = new AppUserPosition();
- userPosition.setAppUserId(appUserId);
- userPosition.setPoint(point);
- userPosition.setAddTime(System.currentTimeMillis());
- mongoTemplate.save(userPosition);
- }
- }
}
\ No newline at end of file
--
Gitblit v1.7.1