苍穹外卖项目DAY10
1、Spring Task
1.1、介绍
Spring Task是Spring框架提供的任务调度工具，可以按照约定的时间自动执行某个代码逻辑
定位：定时任务框架
作用：定时自动执行某段Java代码
只要是需要定时处理的场景都可以使用Spring Task
1.2、cron表达式
cron表示式其实就是一个字符串，通过cron表达式可以定义任务触发时间
构成规则：分为6或7个域，由空格分隔开，每个域代表一个含义
每个域的含义分别我：秒、分钟、小时、日、月、周、年（可选）
cron表达式生成器https://cron.qqe2.com/
1.3、入门案例
1、导入maven坐标spring-context（已存在）
2、启动类添加注解@EnableScheduling开启任务调度
3、自定义定时任务类
/**
* 自定义定时任务类
*/
@Component
@Slf4j
public class MyTask {
/**
* 定时任务，每五秒触发一次
*/
@Scheduled(cron = "0/5 * * * * ?")
public void executeTask(){
log.info("定时任务开始执行：{}",new Date());
}
}
2、订单状态定时处理
2.1、需求分析
用户下单后可能存在的情况：
- 下单后未支付，订单一直处于“待支付”状态
- 用户收货后管理端未点击完成按钮，订单一直处于“派送中”状态
对于上面两种情况需要通过定时任务来修改订单状态，具体逻辑为：
- 通过定时任务每分钟检查一次是否存在支付超时订单（下单后超过15分钟仍未支付则判定为支付超时订单），如果存在则修改订单状态为“。已取消”
- 通过定时任务每天凌晨一点检查一次是否存在“派送中”的订单，如果存在则修改订单状态为“已完成”
2.2、代码开发
OrderTask
**
* 定时任务类，定时处理订单状态
*/
@Component
@Slf4j
public class OrderTask {
@Autowired
private OrderMapper orderMapper;
/**
* 处理超时订单的方法
*/
@Scheduled(cron = "1/5 * * * * ? ") //每分钟触发一次
public void processTimeoutOrder(){
log.info("定时处理超时订单:{}", LocalDateTime.now());
LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT,time);
if (ordersList != null && ordersList.size() >0){
for (Orders orders : ordersList) {
orders.setStatus(Orders.CANCELLED);
orders.setCancelReason("订单超时，自动取消");
orders.setCancelTime(LocalDateTime.now());
orderMapper.update(orders);
}
}
}
/**
* 处理一直处于派送中状态的订单
*/
@Scheduled(cron = "0/5 0 1 * * ?")
public void processDeliveryOrder(){ //每天凌晨1点触发一次
log.info("定时处理处于派送中的订单",LocalDateTime.now());
LocalDateTime time = LocalDateTime.now().plusMinutes(-60);
List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS,time);
if (ordersList != null && ordersList.size() >0){
for (Orders orders : ordersList) {
orders.setStatus(Orders.COMPLETED);
orderMapper.update(orders);
}
}
}
}
OrderMapper
/**
* 根据订单状态和下单时间查询
* @param status
* @param orderTime
* @return
*/
@Select("select * from orders where status = #{status} and order_time < #{orderTime}")
List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);
2.3、功能测试
3、WebSocket
3.1、介绍
WebSocket是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工通信—浏览器和服务器只需要完成一次握手，两者之间就可以创建持久性的连接，并进行双向数据传输
应用场景：
- 视频弹幕
- 网页聊天
- 体育实况更新
- 股票基金报价实时更新
3.2、入门案例
实现步骤：
1、直接使用websocket.html页面作为WebSocket客户端
2、导入WebSocket的maven坐标
3、导入WebSocket服务端组件WebSocketServer，用于和客户端通信
4、导入配置类WebSocketConfiguration，注册WebSocket的服务端组件
5、导入定时人物类WebSocketTask，定时向客户端推送数据
4、来单提醒
4.1、需求分析和设计
用户下单并且支付成功后，需要第一时间通知外卖商家。通知的形式有如下两种：
- 语音播报
- 弹出提示框
设计：
- 通过WebSocket实现管理端页面和服务端保持长连接状态
- 当客户支付后，调用WebSocket的相关API实现服务端向客户端推送消息
- 客户端浏览器解析服务端推送的消息，判断是来单提醒还是客户催单，进行响应的消息提示和语音播报
- 约定服务端发送给客户端浏览器的数据格式为JSON，字段包括type，orderId，content
- type 为消息类型， 1为来单提醒 2为客户催单
- orderId为订单id
- content为消息内容
4.2、代码开发
application-dev.yaml
wechat:
appid: wxfe567bfd793a4a5b
secret: 18cc4d7532bce4366d15580d72f8532e
mchid: 1561414331 #传智播客申请的商户号
mchSerialNo: 4B3B3DC35414AD50B1B755BAF8DE9CC7CF407606 #证书的序列号
privateKeyFilePath: D:\apiclient_key.pem #私钥文件（不是企业 没有）
apiV3Key: CZBK51236435wxpay435434323FFDuv3 #解密的秘钥（商户平台设置 一般公司提供好不用自己手动配置）
weChatPayCertFilePath: D:\wechatpay_166D96F876F45C7D07CE98952A96EC980368ACFC.pem #平台证书文件
notifyUrl: https://1d7a543c.r26.cpolar.top/notify/paySuccess #支付成功的回调（域名地址+controller的访问路径）
refundNotifyUrl: https://1d7a543c.r26.cpolar.top/notify/refundSuccess #退款成功的回调
# 使用内网穿透工具每次获取到的临时域名都不一样，注意替换为自己最新的临时域名
OrderServiceImpl
/**
* 支付成功，修改订单状态
*
* @param outTradeNo
*/
public void paySuccess(String outTradeNo) {
// 当前登录用户id
Long userId = BaseContext.getCurrentId();
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);
//通过WebSocket实现来单提醒 type orderId content
Map map = new HashMap<>();
map.put("type", 1);//消息类型，1表示来单提醒 2表示客户催单
map.put("orderID", ordersDB.getId());//订单id
map.put("content", "订单号：" + outTradeNo);
//通过websocket向客户端浏览器推送消息
String json = JSON.toJSONString(map);
webSocketServer.sendToAllClient(json);
}
4.3、功能测试
支付成功后，后台收到来电提醒，并有语音播报
5、客户催单
5.1、需求分析和设计
用户在小程序点击催单按钮后，需要第一时间通知外卖商家。通知的形式有如下两种：
- 语音播单
- 弹出提示框
设计：
- 通过WebSocket实现管理端页面和服务端保持长连接状态
- 当用户点击催单按钮后，调用WebSocket的相关API实现服务端向客户端推送消息
- 客户端浏览器解析服务端推送的消息，判断是来单提醒还是客户催单，进行相应的消息提示和语音播报
- 约定服务端发送给客户端浏览器的数据格式为JSON，
- 字段包括type，orderId，content
- type 为消息类型， 1为来单提醒 2为客户催单
- orderId为订单id
- content为消息内容
接口设计：
5.2、代码开发
OrderController
/**
* 客户催单
* @param id
* @return
*/
@GetMapping("/reminder/{id}")
@ApiOperation("客户催单")
public Result reminder(@PathVariable("id") Long id){
orderService.reminder(id);
return Result.success();
}
OrderService
/**
* 客户催单
* @param id
*/
void reminder(Long id);
OrderServiceImpl
/**
* 客户催单
* @param id
*/
@Override
public void reminder(Long id) {
//根据id查询订单
Orders ordersDB = orderMapper.getById(id);
//校验订单是否存在
if (ordersDB == null){
throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
}
Map map = new HashMap<>();
map.put("type",2); //1代表来单提醒 2代表客户催单
map.put("orderId",id);
map.put("content","订单号:" + ordersDB.getNumber());
//通过websocket向客户端浏览器推送消息
webSocketServer.sendToAllClient(JSON.toJSONString(map));
}
### 5.3、功能测试
![\[外链图片转存中...(img-JYKK44mt-1724585920417)\]](https://i-blog.csdnimg.cn/direct/43d5d6e89cb24b2bb075e3107129cf14.png)