苍穹外卖项目DAY10

本文主要是介绍苍穹外卖项目DAY10，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

苍穹外卖项目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 {@Autowiredprivate 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: wxfe567bfd793a4a5bsecret: 18cc4d7532bce4366d15580d72f8532emchid: 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) {// 当前登录用户idLong 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 contentMap map = new HashMap<>();map.put("type", 1);//消息类型，1表示来单提醒 2表示客户催单map.put("orderID", ordersDB.getId());//订单idmap.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)

这篇关于苍穹外卖项目DAY10的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---