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); } }