苍穹外卖项目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)