From 8972018b65acadd37a021db38b6478673e3f3bd1 Mon Sep 17 00:00:00 2001 From: xuxin <840198532@qq.com> Date: Mon, 1 Dec 2025 15:04:53 +0800 Subject: [PATCH] =?UTF-8?q?=E8=8B=8D=E7=A9=B9=E5=A4=96=E5=8D=96--WebSocket?= =?UTF-8?q?-=E5=AE=A2=E6=88=B7=E5=82=AC=E5=8D=95=E5=8A=9F=E8=83=BD?= =?UTF-8?q?=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sky/controller/user/OrderController.java | 14 +++++++++++ .../java/com/sky/service/OrderService.java | 7 ++++++ .../sky/service/impl/OrderServiceImpl.java | 24 +++++++++++++++++++ 3 files changed, 45 insertions(+) diff --git a/sky-server/src/main/java/com/sky/controller/user/OrderController.java b/sky-server/src/main/java/com/sky/controller/user/OrderController.java index c5ba471..1beef9c 100644 --- a/sky-server/src/main/java/com/sky/controller/user/OrderController.java +++ b/sky-server/src/main/java/com/sky/controller/user/OrderController.java @@ -104,4 +104,18 @@ public class OrderController { return Result.success(); } + /** + * 客户端催单 + * @param id + * @return + */ + @GetMapping("/reminder/{id}") + @ApiOperation("客户端催单") + public Result reminder(@PathVariable Long id) { + + //调用业务层催单功能 + orderService.reminder(id); + return Result.success(); + } + } diff --git a/sky-server/src/main/java/com/sky/service/OrderService.java b/sky-server/src/main/java/com/sky/service/OrderService.java index e7d7bd8..5d75fdf 100644 --- a/sky-server/src/main/java/com/sky/service/OrderService.java +++ b/sky-server/src/main/java/com/sky/service/OrderService.java @@ -99,4 +99,11 @@ public interface OrderService { * @param id */ void complete(Long id); + + /** + * 客户催单 + * @param id + */ + void reminder(Long id); + } 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 b98b52b..5b6b664 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 @@ -446,4 +446,28 @@ public class OrderServiceImpl implements OrderService { orderMapper.update(orders); } + + /** + * 客户催单 + * @param id + */ + @Override + public void reminder(Long id) { + //根据主键id查询订单信息 + Orders order = orderMapper.getById(id); + //校验订单是否存在 + if (order == null) { + throw new OrderBusinessException(MessageConstant.ORDER_NOT_FOUND); + } + + //这里催单了,那就要让服务器向管理端发送催单提示 + Map map = new HashMap(); + map.put("type", 2); + map.put("orderId", order.getId()); + map.put("content","订单号:"+order.getNumber()); + //将java对象转为json字符串 + String json = JSON.toJSONString(map); + webSocketServer.sendToAllClient(json); + + } }