From 8f96d6c9c414bbaa5fd29cc14042482a625468d2 Mon Sep 17 00:00:00 2001
From: Bunny <1319900154@qq.com>
Date: Wed, 10 Jan 2024 16:13:32 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9D=A5=E5=8D=95=E6=8F=90=E9=86=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../{user => nofity}/PayNotifyController.java         |  3 ++-
 .../java/com/sky/service/impl/OrderServiceImpl.java   | 11 +++++++++++
 2 files changed, 13 insertions(+), 1 deletion(-)
 rename sky-server/src/main/java/com/sky/controller/{user => nofity}/PayNotifyController.java (99%)

diff --git a/sky-server/src/main/java/com/sky/controller/user/PayNotifyController.java b/sky-server/src/main/java/com/sky/controller/nofity/PayNotifyController.java
similarity index 99%
rename from sky-server/src/main/java/com/sky/controller/user/PayNotifyController.java
rename to sky-server/src/main/java/com/sky/controller/nofity/PayNotifyController.java
index 0c93d21..a7d6d22 100644
--- a/sky-server/src/main/java/com/sky/controller/user/PayNotifyController.java
+++ b/sky-server/src/main/java/com/sky/controller/nofity/PayNotifyController.java
@@ -1,4 +1,4 @@
-package com.sky.controller.user;
+package com.sky.controller.nofity;
 
 import com.alibaba.druid.support.json.JSONUtils;
 import com.alibaba.fastjson.JSON;
@@ -30,6 +30,7 @@ public class PayNotifyController {
     @Resource
     private WeChatProperties weChatProperties;
 
+
     /**
      * 支付成功回调
      *
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 f22dec1..cea816e 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
@@ -14,6 +14,7 @@ import com.sky.service.OrderService;
 import com.sky.utils.WeChatPayUtil;
 import com.sky.vo.OrderPaymentVO;
 import com.sky.vo.OrderSubmitVO;
+import com.sky.websocket.WebSocketServer;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -22,6 +23,7 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 
 @Service
@@ -38,6 +40,8 @@ public class OrderServiceImpl implements OrderService {
     private UserMapper userMapper;
     @Resource
     private WeChatPayUtil weChatPayUtil;
+    @Resource
+    private WebSocketServer webSocketServer;
 
     /**
      * 用户下单
@@ -143,6 +147,13 @@ public class OrderServiceImpl implements OrderService {
                 .build();
 
         orderMapper.update(orders);
+
+        HashMap map = new HashMap<>();
+        map.put("type", 1);
+        map.put("orderId", ordersDB.getId());
+        map.put("content", "订单号" + outTradeNo);
+        String jsonString = JSONObject.toJSONString(map);
+        webSocketServer.sendToAllClient(jsonString);
     }
 }