From f3a8ace95bb141026b694b70df4d41bf284c6a7d Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期三, 11 三月 2026 21:50:11 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi
---
xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java | 34 ++++++++++++++++++++++++++++++++++
1 files changed, 34 insertions(+), 0 deletions(-)
diff --git a/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java b/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java
index 4ff5ebb..3094adc 100644
--- a/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java
+++ b/xp-robotaxi-push-message-boot/src/main/java/com/xiaopeng/pushMessage/webSocket/controller/WebSocketController.java
@@ -157,6 +157,40 @@
}
/**
+ * 发送是否开启倒计时
+ * {
+ * "appUserId":"-1",
+ * {"type":"OPEN_TRUNK","content":"{\"orderId\":\"1983875114637811713\",\"isOpen\":1}","timestamp":"176569945845456"}
+ * }
+ *
+ * @param dto 消息实体
+ * @return 操作结果
+ */
+ @ApiOperation(value = "发送是否开启倒计时")
+ @PostMapping("/inner/websocket/order/sendOpenTrunk")
+ public R<String> sendOpenTrunk(@RequestBody SendMessageDTO dto) {
+ try {
+ String message = dto.getMessage();
+ if (message.trim().isEmpty()) {
+ return R.fail("消息内容不能为空");
+ }
+ String appUserId = dto.getAppUserId();
+ if (appUserId.trim().isEmpty()) {
+ return R.fail("用户id不能为空");
+ }
+ int deviceCount = webSocketUserService.sendMessageToUser(appUserId, message);
+ if (deviceCount > 0) {
+ return R.ok("消息发送成功，发送到 " + deviceCount + " 个设备");
+ } else {
+ return R.fail("用户不在线或发送失败");
+ }
+ } catch (Exception e) {
+ log.error("向用户发送消息失败", e);
+ return R.fail("发送消息失败: " + e.getMessage());
+ }
+ }
+
+ /**
* 向指定用户发送JSON格式消息
* @param appUserId 用户ID
* @param request 请求参数
--
Gitblit v1.7.1