From 746517aca9d0b7ae334c70b3041a9b1de795addb Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期三, 22 四月 2026 11:08:37 +0800
Subject: [PATCH] Merge branch '1.0' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi into 1.0
---
xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/handler/WebSocketTextFrameHandler.java | 31 +++++++++++++++++++++++++++++--
1 files changed, 29 insertions(+), 2 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 7bc7714..f0b1447 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
@@ -2,6 +2,8 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
+import com.xiaopeng.api.vo.automaticPilot.AppUserPosition;
+import com.xiaopeng.common.redis.service.RedisService;
import com.xiaopeng.pushMessage.webSocket.service.WebSocketUserConnectionManager;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
@@ -9,9 +11,15 @@
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.geo.GeoJsonPoint;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
+import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.*;
import java.util.function.Function;
@@ -33,6 +41,9 @@
@Autowired
private WebSocketAuthHandler authHandler;
+
+ @Resource
+ private MongoTemplate mongoTemplate;
Map<String, BusinessMsgHandler> businessMsgHandlers;
@@ -160,8 +171,7 @@
log.info("收到用户 {} 的实时位置消息: {}", appUserId, messageObj.toJSONString());
Double latitude = messageObj.getDouble("latitude");
Double longitude = messageObj.getDouble("longitude");
- String timestamp = messageObj.getString("timestamp");
-
+ saveAppUserLocation(Long.parseLong(appUserId), latitude, longitude);
}
// 回复消息
@@ -213,4 +223,21 @@
log.error("WebSocket连接异常: {}", cause.getMessage(), cause);
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