重庆站外推广网站,义乌网站建设郭,上海网站制作网络推广,宣传推广文案苍穹外卖-day10
课程内容
Spring Task订单状态定时处理WebSocket来单提醒客户催单
功能实现#xff1a;订单状态定时处理、来单提醒和客户催单
订单状态定时处理#xff1a; 来单提醒#xff1a; 客户催单#xff1a; 1. Spring Task
1.1 介绍
Spring Task 是Spring框…苍穹外卖-day10
课程内容
Spring Task订单状态定时处理WebSocket来单提醒客户催单
功能实现订单状态定时处理、来单提醒和客户催单
订单状态定时处理 来单提醒 客户催单 1. Spring Task
1.1 介绍
Spring Task 是Spring框架提供的任务调度工具可以按照约定的时间自动执行某个代码逻辑。
定位定时任务框架
作用定时自动执行某段Java代码
为什么要在Java程序中使用Spring Task
应用场景
1). 信用卡每月还款提醒 2). 银行贷款每月还款提醒 3). 火车票售票系统处理未支付订单 4). 入职纪念日为用户发送通知 强调只要是需要定时处理的场景都可以使用Spring Task
1.2 cron表达式
cron表达式其实就是一个字符串通过cron表达式可以定义任务触发的时间
构成规则分为6或7个域由空格分隔开每个域代表一个含义
每个域的含义分别为秒、分钟、小时、日、月、周、年(可选)
举例
2022年10月12日上午9点整 对应的cron表达式为0 0 9 12 10 ? 2022 说明一般日和周的值不同时设置其中一个设置另一个用表示。
比如描述2月份的最后一天最后一天具体是几号呢可能是28号也有可能是29号所以就不能写具体数字。
为了描述这些信息提供一些特殊的字符。这些具体的细节我们就不用自己去手写因为这个cron表达式它其实有在线生成器。
cron表达式在线生成器https://cron.qqe2.com/ 特殊1每月几号最近的那个工作日
比如每月10号最近的那个工作日周一到周五称为工作日如果10号正好是周一到周五那么它匹配的正好是10号。如果10号正好是周六那么离周六最近的一个工作日是周五9号这一天。如果10号正好是周日那么离周日最近的一个工作日是周一11号这一天。
特殊2本月最后一天
需要看具体月份是如何设置的如果匹配到的是10月份那么最后一天就是31号。如果匹配到的是9月份那么最后一天就是30号。
可以直接在这个网站上面只要根据自己的要求去生成corn表达式即可。所以一般就不用自己去编写这个表达式。
通配符
* 表示所有值
? 表示未说明的值即不关心它为何值
- 表示一个指定的范围
, 表示附加一个可能值
/ 符号前表示开始时间符号后表示每次递增的值
cron表达式案例
*/5 * * * * ? 每隔5秒执行一次
0 */1 * * * ? 每隔1分钟执行一次
0 0 5-15 * * ? 每天5-15点整点触发
0 0/3 * * * ? 每三分钟触发一次
0 0-5 14 * * ? 在每天下午2点到下午2:05期间的每1分钟触发
0 0/5 14 * * ? 在每天下午2点到下午2:55期间的每5分钟触发
0 0/5 14,18 * * ? 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
0 0/30 9-17 * * ? 朝九晚五工作时间内每半小时
0 0 10,14,16 * * ? 每天上午10点下午2点4点
1.3 入门案例
1.3.1 Spring Task使用步骤
1). 导入maven坐标 spring-context已存在 2). 启动类添加注解 EnableScheduling 开启任务调度
3). 自定义定时任务类
1.3.2 代码开发
编写定时任务类
进入sky-server模块中 package com.sky.task;import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;import java.util.Date;/*** 自定义定时任务类*/
Component //需要交给Spring容器去管理
Slf4j
public class MyTask {/*** 定时任务 每隔5秒触发一次* 定时任务具体处理的业务逻辑需要写在这个方法里面* Scheduled(cron 0/5 * * * * ?)通过此注解指定方法什么时候触发* 从第0秒开始每隔5秒开始触发。* 方法返回值类型是void方法名任意。*/Scheduled(cron 0/5 * * * * ?)public void executeTask(){log.info(定时任务开始执行{},new Date());}
}
开启任务调度
启动类添加注解 EnableScheduling
package com.sky;import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.transaction.annotation.EnableTransactionManagement;SpringBootApplication
Slf4j
EnableTransactionManagement //开启注解方式的事务管理
EnableCaching //开启缓存注解功能
EnableScheduling //开启任务调度
public class SkyApplication {public static void main(String[] args) {SpringApplication.run(SkyApplication.class, args);log.info(server started);}
}
1.3.3 功能测试
启动服务查看日志 每隔5秒执行一次。
2.订单状态定时处理
2.1 需求分析
用户下单后可能存在的情况
下单后未支付订单一直处于待支付状态用户收货后管理端未点击完成按钮订单一直处于派送中状态 对于上面两种情况需要通过定时任务来修改订单状态具体逻辑为
通过定时任务每分钟检查一次是否存在支付超时订单下单后超过15分钟仍未支付则判定为支付超时订单如果存在则修改订单状态为“已取消”通过定时任务每天凌晨1点检查一次是否存在“派送中”的订单如果存在则修改订单状态为“已完成”
注意这个地方就不需要做接口设计了这里是通过定时任务自动执行的并不需要前端发送http请求来触发所以这个地方就没有接口这个概念了。
2.2 代码开发
问题对于这两类订单支付超时订单、派送中的订单的处理是不是要编写2个定时任务类呢
答写一个定时任务类 类里面写2个方法 或者 写2个定时任务类 每个类里面写一个方法都可以。
1). 自定义定时任务类OrderTask待完善
package com.sky.task;/*** 自定义定时任务实现订单状态定时处理*/
Component
Slf4j
public class OrderTask {Autowiredprivate OrderMapper orderMapper;/*** 处理支付超时订单*/Scheduled(cron 0 * * * * ?)public void processTimeoutOrder(){log.info(处理支付超时订单{}, new Date());}/*** 处理“派送中”状态的订单*/Scheduled(cron 0 0 1 * * ?)public void processDeliveryOrder(){log.info(处理派送中订单{}, new Date());}}2). 完善定时任务类的processTimeoutOrder方法 /*** 处理支付超时订单的方法*/Scheduled(cron 0 * * * * ?)//每分钟触发一次public void processTimeoutOrder(){log.info(处理支付超时订单{}, new Date());/*** 查询订单表中的那些订单是超时了查询需要那些条件呢* 1.首先订单状态需要处于“待付款”状态。* 2.下单的时间超过了15分钟下单时间 当前时间-15分钟* select * from orders where status 1 and order_time 当前时间-15分钟** LocalDateTime.now():当前时间 新的时间日期API* plusMinutes(xx)加xxx分钟* plusMinutes(-15)加上一个负的就是减15分钟*/LocalDateTime time LocalDateTime.now().plusMinutes(-15);//计算出下单时间//查询到的超时订单集合ListOrders ordersList orderMapper.getByStatusAndOrdertimeLT(Orders.PENDING_PAYMENT, time);//判断是否或取到超时订单集合if(ordersList ! null ordersList.size() 0) {//遍历订单集合之后修改每个订单的状态for (Orders orders : ordersList) { //快捷键ordersList.fororders.setStatus(Orders.CANCELLED); //订单状态6已取消orders.setCancelReason(支付超时自动取消);//取消原因orders.setCancelTime(LocalDateTime.now());//订单取消时间orderMapper.update(orders); //之前实现过了}}}3). 完善定时任务类的processDeliveryOrder方法 /*** 处理一直处于“派送中”状态的订单*/Scheduled(cron 0 0 1 * * ?)//每天凌晨1点触发一次public void processDeliveryOrder(){log.info(处理派送中订单{}, new Date());/*** select * from orders where status 4 and order_time 当前时间-1小时* 和上面那个方法的业务逻辑相同只不过是查询的条件不同* 1.首先订单状态需要处于“派送中”状态。* 2.查询的时间是上一个工作日的下单时间 当前时间每天凌晨1点-1小时*/LocalDateTime time LocalDateTime.now().plusMinutes(-60);//计算出下单时间//查询到的超时订单集合ListOrders ordersList orderMapper.getByStatusAndOrdertimeLT(Orders.DELIVERY_IN_PROGRESS, time);//判断是否或取到超时订单集合if(ordersList ! null ordersList.size() 0){//遍历订单集合之后修改每个订单的状态for (Orders orders : ordersList) {orders.setStatus(Orders.CANCELLED); //订单状态5已完成orderMapper.update(orders); //之前实现过了}}}4). 在OrderMapper接口中扩展方法: /*** 根据状态和下单时间查询订单* param status* param orderTime*/Select(select * from orders where status #{status} and order_time #{orderTime})ListOrders getByStatusAndOrdertimeLT(Integer status, LocalDateTime orderTime);2.3 功能测试
可以通过如下方式进行测试
查看控制台sql查看数据库中数据变化
支付超时的订单测试
1). 查看订单表
有一条订单状态为1。订单状态 1待付款 2待接单 3已接单 4派送中 5已完成 6已取消 2). 开启定时任务
启动服务观察控制台日志。处理支付超时订单任务每隔1分钟执行一次。 3). 再次查看订单表
状态已更改为6已取消。 证明定时任务已生效。
处理“派送中”状态的订单任务测试自已完成测试步骤和上述一致。可适当修改cron表达式改变任务执行频率方便测试。
2.4 代码提交 3. WebSocket
3.1 介绍
WebSocket 是基于 TCP 的一种新的网络协议。它实现了浏览器与服务器全双工通信——浏览器和服务器只需要完成一次握手两者之间就可以创建持久性的连接 并进行双向数据传输。
HTTP协议和WebSocket协议对比
HTTP是短连接WebSocket是长连接HTTP通信是单向的基于请求响应模式浏览器发送请求给服务器WebSocket支持双向通信HTTP和WebSocket底层都是TCP连接 思考既然WebSocket支持双向通信功能看似比HTTP强大那么我们是不是可以基于WebSocket开发所有的业务功能
WebSocket缺点
服务器长期维护长连接需要一定的成本 各个浏览器支持程度不一 WebSocket 是长连接受网络限制比较大需要处理好重连
结论WebSocket并不能完全取代HTTP它只适合在特定的场景下使用
WebSocket应用场景
1). 视频弹幕 2). 网页聊天 3). 体育实况更新 4). 股票基金报价实时更新 3.2 入门案例
3.2.1 案例分析
需求实现浏览器与服务器全双工通信。浏览器既可以向服务器发送消息服务器也可主动向浏览器推送消息。
效果展示 实现步骤
1). 直接使用websocket.html页面作为WebSocket客户端
2). 导入WebSocket的maven坐标
3). 导入WebSocket服务端组件WebSocketServer用于和客户端通信
4). 导入配置类WebSocketConfiguration注册WebSocket的服务端组件让组件生效
5). 导入定时任务类WebSocketTask定时向客户端推送数据
说明websocket这一块主要是了解程序的执行流程具体的代码并不作为重点所以说入门案例相对比较简单这里直接导入课前资料中的代码即可。 3.2.2 代码开发
1). 定义websocket.html页面(资料中已提供)
!DOCTYPE HTML
html
headmeta charsetUTF-8titleWebSocket Demo/title
/head
bodyinput idtext typetext /button onclicksend()发送消息/buttonbutton onclickcloseWebSocket()关闭连接/buttondiv idmessage/div
/body
script typetext/javascriptvar websocket null;var clientId Math.random().toString(36).substr(2);//判断当前浏览器是否支持WebSocketif(WebSocket in window){//连接WebSocket节点 注意现在是ws协议//这其实就是一个握手的请求如果请求成功了客户端和服务端就建立了一个长连接// 之后就可以双向通信了。websocket new WebSocket(ws://localhost:8080/ws/clientId);}else{alert(Not support websocket)}//连接发生错误的回调方法websocket.onerror function(){setMessageInnerHTML(error);};//连接成功建立的回调方法websocket.onopen function(){setMessageInnerHTML(连接成功);}//接收到消息的回调方法websocket.onmessage function(event){setMessageInnerHTML(event.data);}//连接关闭的回调方法websocket.onclose function(){setMessageInnerHTML(close);}//监听窗口关闭事件当窗口关闭时主动去关闭websocket连接防止连接还没断开就关闭窗口server端会抛异常。window.onbeforeunload function(){websocket.close();}//将消息显示在网页上function setMessageInnerHTML(innerHTML){document.getElementById(message).innerHTML innerHTML br/;}//发送消息客户端向服务端发送消息function send(){var message document.getElementById(text).value;websocket.send(message);}//关闭连接function closeWebSocket() {websocket.close();}
/script
/html2). 导入maven坐标
在sky-server模块pom.xml中已定义
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-websocket/artifactId
/dependency3). 定义WebSocket服务端组件(资料中已提供)
直接导入到sky-server模块即可
package com.sky.websocket;import org.springframework.stereotype.Component;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;/*** WebSocket服务用于和客户端通信*/
Component
//类似于controller方法中的路径只不过用的注解不同对应之前页面上的地址
ServerEndpoint(/ws/{sid})
public class WebSocketServer {//存放会话对象客户端和服务端要建立一个连接本质上就是一个会话建立好会话之后双方之间就可以进行双向通信了private static MapString, Session sessionMap new HashMap();/*** 连接建立成功调用的方法* 这个过程不用我们管而是由websocket这个小框架自己来调客户端可能有多个所以要区分不同的客户端* 具体是通过sid来区分不同的客户端sid是页面传递过来的clientIdclientId是页面生成的一个随机数* PathParam路径参数获取*/OnOpenpublic void onOpen(Session session, PathParam(sid) String sid) {System.out.println(客户端 sid 建立连接);sessionMap.put(sid, session);}/*** 收到客户端消息后调用的方法类似于controller中的方法** param message 客户端发送过来的消息*/OnMessagepublic void onMessage(String message, PathParam(sid) String sid) {System.out.println(收到来自客户端 sid 的信息: message);}/*** 连接关闭调用的方法** param sid*/OnClosepublic void onClose(PathParam(sid) String sid) {System.out.println(连接断开: sid);sessionMap.remove(sid);}/*** 群发把map中的session都给遍历出来了这就相当于是群发的一个效果因为客户端可能* 有多个都连接到了这个服务端现在把这些session都遍历出来 然后都给这些* 客户端发送消息这就是一个群发的效果。* 注意这个是普通方法需要自己手动调用* param message*/public void sendToAllClient(String message) {CollectionSession sessions sessionMap.values();//把sessionMap集合中的session都遍历出来for (Session session : sessions) {try {//服务器向客户端发送消息session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}}
4). 定义配置类注册WebSocket的服务端组件(从资料中直接导入即可)
package com.sky.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** WebSocket配置类用于注册WebSocket的Bean让组件生效*/
Configuration
public class WebSocketConfiguration {Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}5). 定义定时任务类定时向客户端推送数据(从资料中直接导入即可)
package com.sky.task;import com.sky.websocket.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;Component
public class WebSocketTask {Autowiredprivate WebSocketServer webSocketServer;/*** 通过WebSocket每隔5秒向客户端发送消息*/Scheduled(cron 0/5 * * * * ?)public void sendMessageToClient() {//调用WebSocketServer类中群发的方法webSocketServer.sendToAllClient(这是来自服务端的消息 DateTimeFormatter.ofPattern(HH:mm:ss).format(LocalDateTime.now()));}
}3.2.3 功能测试
启动服务打开websocket.html页面
浏览器向服务器发送数据 服务器向浏览器间隔5秒推送数据 4. 来单提醒WebSocket的应用
4.1 需求分析和设计
用户下单并且支付成功后需要第一时间通知外卖商家。通知的形式有如下两种 语音播报 弹出提示框 设计思路
通过WebSocket实现管理端页面和服务端保持长连接状态当客户支付后调用WebSocket的相关API实现服务端向客户端推送消息客户端浏览器解析服务端推送的消息判断是来单提醒还是客户催单进行相应的消息提示和语音播报约定服务端发送给客户端浏览器的数据格式为JSON字段包括typeorderIdcontent type 为消息类型1为来单提醒 2为客户催单orderId 为订单id 不管是来单提醒还是客户催单那这一次提醒实际上都对应一个订单是你下了某个单之后或者或者是你催促某个订单这个时候他才会给你相应的提醒具体你提醒的是哪个订单呢所以需要把这个订单id给提交过来。 content 为消息内容 提示框显示的内容
4.2 代码开发
4.2.1 WebSocketServer组件和配置类
使用入门案例中的WebSocketServer组件和配置类通过这个组件和和客户端进行通信的。
4.2.2 前端代码
前端代码已经提供好了里面已经写好WebSocketServer的客户端代码说白了就是一些js代码。 启动项目清空控制台方便观察 在登录页面打开开发者工具点击登录查看请求 查看控制台发现服务端和客户端已经建立长连接了。
注意
问题这次请求的url地址ws://localhost/ws/nhxkyfec7m并没有写8080(tomact服务器端口号)那么它是如何请求到后台的tomact服务器呢 答先请求到nginx然后在通过nginx反向代理转发到后端tomact服务器。
4.2.3 以前
说明用户下单并且支付成功之后基于WebSocketServer像客户端推送消息我们在WebSocketServer中已经创建好了群发的方法所以只需要调用这个群发的方法即可。
在OrderServiceImpl中注入WebSocketServer对象修改paySuccess方法加入如下代码 Autowiredprivate WebSocketServer webSocketServer;/*** 支付成功修改订单状态* param outTradeNo*/Overridepublic void paySuccess(String outTradeNo) {// 根据订单号查询订单Orders ordersDB orderMapper.getByNumber(outTradeNo);// 根据订单id更新订单的状态、支付方式、支付状态、结账时间Orders orders Orders.builder().id(ordersDB.getId()).status(Orders.TO_BE_CONFIRMED).payStatus(Orders.PAID).checkoutTime(LocalDateTime.now()).build();orderMapper.update(orders);//通过webSocketServer向客户端浏览器推送消息//要求推送的消息格式是json类型并且包含3个字段type、orderId、contentMap map new HashMap();map.put(type, 1);//消息类型1表示来单提醒map.put(orderId, orders.getId()); //订单的idmap.put(content, 订单号 outTradeNo);//订单号//转化为json格式String json JSON.toJSONString(map);//通过WebSocket实现来单提醒向客户端浏览器推送消息(调用WebSocketServer类中群发的方法)webSocketServer.sendToAllClient(json);}4.2.4 现在
因为之前跳过了支付功能没有商户号自己写了一个新的更新功能点击支付后所以这部分代码写在自己写的更新功能之后。 完整代码 Autowiredprivate WebSocketServer webSocketServer;/*** 订单支付** param ordersPaymentDTO* return*/Overridepublic OrderPaymentVO payment(OrdersPaymentDTO ordersPaymentDTO) throws Exception {//1.获取当前登录用户id之后根据id查询数据库把用户数据查询出来Long userId BaseContext.getCurrentId();User user userMapper.getById(userId);/* //2.调用微信支付接口工具类生成预支付交易单对应第5步JSONObject jsonObject weChatPayUtil.pay(ordersPaymentDTO.getOrderNumber(), //商户订单号new BigDecimal(0.01), //支付金额单位 元苍穹外卖订单, //商品描述user.getOpenid() //微信用户的openid);if (jsonObject.getString(code) ! null jsonObject.getString(code).equals(ORDERPAID)) {throw new OrderBusinessException(该订单已支付);}//3.转化为vo对象在返回给controllerOrderPaymentVO vo jsonObject.toJavaObject(OrderPaymentVO.class);vo.setPackageStr(jsonObject.getString(package));*/JSONObject jsonObject new JSONObject();jsonObject.put(code,ORDERPAID);OrderPaymentVO vo jsonObject.toJavaObject(OrderPaymentVO.class);vo.setPackageStr(jsonObject.getString(package));Integer OrderPaidStatus Orders.PAID;//支付状态已支付Integer OrderStatus Orders.TO_BE_CONFIRMED; //订单状态待接单LocalDateTime check_out_time LocalDateTime.now();//更新支付时间//获得的是String类型需要的是Long类型所以需要进行转化String orderidS ordersPaymentDTO.getOrderNumber();Long orderidL Long.parseLong(orderidS);//获取订单号orderMapper.updateStatus(OrderStatus, OrderPaidStatus, check_out_time,orderidL );// 根据订单号查询订单Orders ordersDB orderMapper.getByNumber(orderidS);//通过webSocketServer向客户端浏览器推送消息//要求推送的消息格式是json类型并且包含3个字段type、orderId、contentMap map new HashMap();map.put(type, 1);//消息类型1表示来单提醒map.put(orderId, ordersDB.getId()); //订单的idmap.put(content, 订单号 orderidL);//订单号//转化为json格式String json JSON.toJSONString(map);//通过WebSocket实现来单提醒向客户端浏览器推送消息(调用WebSocketServer类中群发的方法)webSocketServer.sendToAllClient(json);return vo;}注意提示音一直响不停是因为设置了5秒钟重复发送的缘故只需要把注解注释掉即可
4.3 功能测试
可以通过如下方式进行测试
查看浏览器调试工具数据交互过程前后端联调
1). 登录管理端后台
登录成功后浏览器与服务器建立长连接 查看控制台日志 2). 小程序端下单支付
修改回调地址利用内网穿透获取域名 下单支付 3). 查看来单提醒
支付成功后后台收到来单提醒并有语音播报 4.4 代码提交 后续步骤和其它功能代码提交一致不再赘述。
5. 客户催单WebSocket的应用
5.1 需求分析和设计
用户付完款后商家一直没有接单用户在小程序中点击催单按钮后需要第一时间通知外卖商家。通知的形式有如下两种 语音播报 弹出提示框 设计思路
通过WebSocket实现管理端页面和服务端保持长连接状态当用户点击催单按钮后调用WebSocket的相关API实现服务端向客户端推送消息客户端浏览器解析服务端推送的消息判断是来单提醒还是客户催单进行相应的消息提示和语音播报 约定服务端发送给客户端浏览器的数据格式为JSON字段包括typeorderIdcontent type 为消息类型1为来单提醒 2为客户催单orderId 为订单idcontent 为消息内容
当用户点击催单按钮时向服务端发送请求。
说明客户催单和来电提醒的区别
来电提醒的消息类型为来电提醒客户催单的消息类型为客户催单客户催单是由客户点击催单按钮主动触发的所以这个地方会涉及到一个接口用户点击催单按钮后它会发起一次请求 请求这个服务端。
接口设计(催单)
催单催的是哪一个订单所以需要把这个订单的标识订单的id作为参数传递进来。
5.2 代码开发
5.2.1 Controller层
根据用户催单的接口定义在user/OrderController中创建催单方法 /*** 用户催单** param id* return*/GetMapping(/reminder/{id})ApiOperation(用户催单)public Result reminder(PathVariable(id) Long id) {orderService.reminder(id);return Result.success();}5.2.2 Service层接口
在OrderService接口中声明reminder方法 /*** 用户催单* param id*/void reminder(Long id);5.2.3 Service层实现类
在OrderServiceImpl中实现reminder方法 /*** 用户催单** param id*/public void reminder(Long id) {// 根据id查询订单Orders ordersDB orderMapper.getById(id);// 校验订单是否存在if (ordersDB null ) {throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);}//基于WebSocket实现催单Map map new HashMap();map.put(type, 2);//1表示来电提醒 2代表用户催单map.put(orderId, id);//订单的idmap.put(content, 订单号 ordersDB.getNumber());//订单号//参数需要json类型所以需要进行转化(调用WebSocketServer组件中群发的方法)webSocketServer.sendToAllClient(JSON.toJSONString(map));}5.2.4 Mapper层
在OrderMapper中添加getById /*** 根据id查询订单* param id*/Select(select * from orders where id#{id})Orders getById(Long id);5.3 功能测试
可以通过如下方式进行测试
查看浏览器调试工具数据交互过程前后端联调
1). 登录管理端后台
登录成功后浏览器与服务器建立长连接 查看控制台日志 2). 用户进行催单
用户可在订单列表或者订单详情进行催单 3). 查看催单提醒
既有催单弹窗同时语音播报 5.4 代码提交 后续步骤和其它功能代码提交一致不再赘述。
