From cdc50bebf7c885ff67f498b18a98ad7643068648 Mon Sep 17 00:00:00 2001
From: xuxin <840198532@qq.com>
Date: Mon, 1 Dec 2025 14:33:29 +0800
Subject: [PATCH] =?UTF-8?q?=E8=8B=8D=E7=A9=B9=E5=A4=96=E5=8D=96--WebSocket?=
 =?UTF-8?q?-=E6=9D=A5=E5=8D=95=E6=8F=90=E7=A4=BA=E7=AE=A1=E7=90=86?=
 =?UTF-8?q?=E7=AB=AF=E5=8A=9F=E8=83=BD=E5=AE=9E=E7=8E=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/sky/service/impl/OrderServiceImpl.java  | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/sky-server/src/main/java/com/sky/service/impl/OrderServiceImpl.java b/sky-server/src/main/java/com/sky/service/impl/OrderServiceImpl.java
index eeaa7ca..b98b52b 100644
--- a/sky-server/src/main/java/com/sky/service/impl/OrderServiceImpl.java
+++ b/sky-server/src/main/java/com/sky/service/impl/OrderServiceImpl.java
@@ -1,5 +1,6 @@
 package com.sky.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
@@ -17,6 +18,7 @@ import com.sky.vo.OrderPaymentVO;
 import com.sky.vo.OrderStatisticsVO;
 import com.sky.vo.OrderSubmitVO;
 import com.sky.vo.OrderVO;
+import com.sky.websocket.WebSocketServer;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.annotation.Order;
@@ -27,7 +29,9 @@ import org.springframework.util.CollectionUtils;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 @Service
@@ -50,6 +54,9 @@ public class OrderServiceImpl implements OrderService {
 
     private Orders orders;//用来记录对应要支付的订单
 
+    @Autowired
+    private WebSocketServer webSocketServer;
+
     /**
      * 用户下单
      * @param ordersSubmitDTO
@@ -130,6 +137,16 @@ public class OrderServiceImpl implements OrderService {
         Integer OrderStatus = Orders.TO_BE_CONFIRMED; //订单状态，待接单
         LocalDateTime check_out_time = LocalDateTime.now(); //更新支付时间
         orderMapper.updateStatus(OrderStatus, OrderPaidStatus, check_out_time, this.orders.getId());
+
+        //这里支付成功了，那就要让服务器向客户端发送来单提示
+        Map map = new HashMap();
+        map.put("type", 1);
+        map.put("orderId", this.orders.getId());
+        map.put("content","订单号："+this.orders.getNumber());
+        //将java对象转为json字符串
+        String json = JSON.toJSONString(map);
+        webSocketServer.sendToAllClient(json);
+
         return vo;
     }