当前位置：首页 > news >正文

苍穹外卖day10——订单状态定时处理（Spring Task）、来单提醒和客户催单(WebSocket)

news 2025/6/15 5:43:21

预期效果

对于超时没处理的需要定时程序处理。基于SpringTask实现。

来单提醒和客户催单。基于WebSocket实现。

Spring Task

介绍

Cron表达式

周几通常不能和日一起指定。

cron表达式在线生成器

在线Cron表达式生成器

入门案例

创建定时任务类

/*** 定义定时任务类*/
@Slf4j
@Component
public class MyTask {/*** 定时任务，每隔5秒触发一次*/@Scheduled(cron = "0/5 * * * * ?")public void executeTask(){log.info("定时任务开始执行:{}",new Date());}
}

订单状态定时处理——需求分析与设计

订单状态定时处理——代码开发

新建一个task包中一个类如下

/*** 定时任务类，定时处理订单状态*/
@Component
@Slf4j
public class OrderTask {@Autowiredprivate OrderMapper orderMapper;/*** 处理超时订单*/@Scheduled(cron = "0 * * * * ? ")//每分钟触发一次public void processTimeoutOrder(){log.info("定时处理超时订单：{}",LocalDateTime.now());LocalDateTime time = LocalDateTime.now().plusMinutes(-15);// select * from orders where status = ? and order_time < (当前时间-15分钟)List<Orders> list = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, time);if(list!=null&&list.size()>0){for (Orders orders : list) {orders.setStatus(Orders.CANCELLED);orders.setCancelReason("订单超时，自动取消");orders.setCancelTime(LocalDateTime.now()); //取消时间orderMapper.update(orders);}}}/*** 处理一直派送中的订单*/@Scheduled(cron = "0 0 1 * * ?")//每天凌晨一点public void processDeliveryOrder(){log.info("定时处理派送中的订单：{}",LocalDateTime.now());LocalDateTime time = LocalDateTime.now().plusMinutes(-60);List<Orders> list = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, time);if(list!=null&&list.size()>0){for (Orders orders : list) {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);

订单状态定时处理——功能测试

运行测试无误。

WebSocket——介绍

WebSocket——入门案例

导入提供的代码资料。

<!DOCTYPE HTML>
<html>
<head><meta charset="UTF-8"><title>WebSocket Demo</title>
</head>
<body><input id="text" type="text" /><button onclick="send()">发送消息</button><button onclick="closeWebSocket()">关闭连接</button><div id="message"></div>
</body>
<script type="text/javascript">var websocket = null;var clientId = Math.random().toString(36).substr(2);//判断当前浏览器是否支持WebSocketif('WebSocket' in window){//连接WebSocket节点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>
</html>

导入坐标

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency>

准备一个新的包创建如下的类

与Controller相似，通过路径进行匹配。

/*** WebSocket服务*/
@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {//存放会话对象private static Map<String, Session> sessionMap = new HashMap();/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session, @PathParam("sid") String sid) {System.out.println("客户端：" + sid + "建立连接");sessionMap.put(sid, session);}/*** 收到客户端消息后调用的方法** @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);}/*** 群发** @param message*/public void sendToAllClient(String message) {Collection<Session> sessions = sessionMap.values();for (Session session : sessions) {try {//服务器向客户端发送消息session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}}

准备一个配置类

/*** WebSocket配置类，用于注册WebSocket的Bean*/
@Configuration
public class WebSocketConfiguration {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}

准备一个定时任务类

@Component
public class WebSocketTask {@Autowiredprivate WebSocketServer webSocketServer;/*** 通过WebSocket每隔5秒向客户端发送消息*/@Scheduled(cron = "0/5 * * * * ?")public void sendMessageToClient() {webSocketServer.sendToAllClient("这是来自服务端的消息：" + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));}
}

来单提醒——需求分析与设计

设计

来单提醒——代码开发

这里不该资料的源码的话连接不上，加上:8080之后直接请求到后端了，没有走nginx去。

使用上面的代码

在OrderServiceImpl中

    @Autowiredprivate WebSocketServer webSocketServer;/*** 支付成功，修改订单状态** @param outTradeNo*/public void paySuccess(String outTradeNo) {XXXXXXXXXX//通过webSocket向客户端浏览器推送消息 type orderId contentMap map=new HashMap();map.put("type",1);//1表示来单提醒map.put("orderId",ordersDB.getId());map.put("content","订单号:"+outTradeNo);String json = JSON.toJSONString(map);webSocketServer.sendToAllClient(json);}

来单提醒——功能测试

懒得模拟支付，就这样吧

客户催单——需求分析与设计

设计

接口设计

客户催单——代码开发

Controller中

    /*** 客户催单* @param id* @return*/@GetMapping("/reminder/{id}")@ApiOperation("客户催单")public Result reminder(@PathVariable("id") Long id){orderService.reminder(id);return Result.success();}

Service中

    /*** 客户催单* @param id*/@Overridepublic 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());String json = JSON.toJSONString(map);webSocketServer.sendToAllClient(json);}

客户催单——功能测试

成功催单

苍穹外卖day10——订单状态定时处理（Spring Task）、来单提醒和客户催单(WebSocket)

预期效果对于超时没处理的需要定时程序处理。基于SpringTask实现。来单提醒和客户催单。基于WebSocket实现。 Spring Task 介绍 Cron表达式周几通常不能和日一起指定。 cron表达式在线生成器在线Cron表达式生成器入门案例创建定时任务类 /*** 定义定时任务类*/ Slf4j…...

编程日记 2023/8/4 19:04:03

【多线程初阶】多线程案例之单例模式

文章目录前言1. 什么是单例模式2. 饿汉模式3. 懒汉模式 --- 单线程版4. 懒汉模式 --- 多线程版5. 懒汉模式 --- 多线程改进版总结前言本文主要给大家讲解多线程的一个重要案例 — 单例模式. 关注收藏, 开始学习吧🧐 1. 什么是单例模式单例模式是一种很经典的…...

编程日记 2023/8/4 19:03:00

跨境选品怎么选？建议独立站卖家收下这份利基产品查找攻略！

跨境电商平台现在可谓是火热发展中，独立站出海风口，其实选择的机会还真不少，相比国内电商的发展势头，看得出来，未来跨境电商的大门，对你而言，敞开着。选品这事儿，就像你上战场前挑选…...

编程日记 2023/8/4 19:01:58

[C++项目] Boost文档站内搜索引擎(1): 项目背景介绍、相关技术栈、相关概念介绍...

项目背景 Boost库是C中一个非常重要的开源库. 它实现了许多C标准库中没有涉及的特性和功能, 一度成为了C标准库的拓展库. C新标准的内容, 很大一部分脱胎于Boost库中. Boost库的高质量代码以及提供了更多实用方便的C组件, 使得Boost库在C开发中会被高频使用为方便开发者学…...

编程日记 2023/8/4 19:00:58

opencv-32 图像平滑处理-高斯滤波cv2.GaussianBlur()

在进行均值滤波和方框滤波时，其邻域内每个像素的权重是相等的。在高斯滤波中，会将中心点的权重值加大，远离中心点的权重值减小，在此基础上计算邻域内各个像素值不同权重的和。基本原理在高斯滤波中，卷积核中的值不…...

编程日记 2023/8/4 18:59:56

Windows 环境Kubernetes安装

目录前言安装 Docker 安装 Kubernetes Windows 安装 kubectl 介绍安装开启 Kubernetes 前言 Docker作为当前最流行的容器化平台，为Kubernetes提供了强大的容器化技术基础。Kubernetes与Docker的结合，使得容器化应用程序在大规模集群中得以简…...

编程日记 2023/8/4 18:58:54

自建类ChatGPT服务：本地化部署与远程访问教程

🌷🍁 博主猫头虎带您 Go to New World.✨🍁 🦄 博客首页——猫头虎的博客🎐 🐳《面试题大全专栏》文章图文并茂🦕生动形象🦖简单易学！欢迎大家来踩踩~🌺 &a…...

编程日记 2023/8/4 18:57:53

常用SQL语句总结

SQL语句文章目录 SQL语句1 SQL语句简介2 DQL（数据查询语句）3 DML（数据操纵语句）4 DDL（数据定义语句）5 DCL（数据控制语句）6 TCL（事务控制语句） 1 SQL语句简介…...

编程日记 2023/8/4 18:56:52

arm交叉编译lmbench

一、下载lmbench www.bitmover.com/lmbench 官网下载，http://www.bitmover.com/lmbench/lmbench3.tar.gz 我没有下载下来，找的别人的百度云下载链接: https://pan.baidu.com/s/1tGo1clCqY-jQPN8G1eWSsg 提取码: f6jd 二、修改makefile 修改三个文件…...

编程日记 2023/8/4 18:55:50

ExtJs 7.7.0 下载方法与去除trial水印

背景最近发现Sencha ExtJs发布了ExtJs7.7.0版本，立刻下载了SDK包，许多朋友不知如何下载，如何去除右上角的trial水印。本文讲下相关下载技巧与方法。下载SDK 首先需要申请试用，申请地址如下，需要注意可能需要梯子&…...

编程日记 2023/8/4 18:54:49

Android11开发规划

文章目录规划总结规划提示：这里可以添加本文要记录的大概内容：从本文开始，会介绍如何移植瑞芯微提供的Android11源码到自己的RK3568的板子上下面是整个Android开发的规划：包括以下部分： … 一、移植部分下载编译瑞芯微提供的源码瑞芯微原厂源码目录介绍...

编程日记 2023/8/4 18:53:48

活动隔断在现在酒店运用的方式

活动隔断是一种在酒店内部划分空间的方式，用于实现不同活动的隔离和隐私。现代酒店常用的活动隔断方式有以下几种： 1. 固定隔断：使用墙体、固定屏风或者板材等材料，将空间划分为不同的房间或区域。这种方式常用于划分客房、会议室…...

编程日记 2023/8/4 18:52:45

Jenkins工具系列 —— 插件钉钉发送消息

文章目录安装插件 Ding TalkJenkins 配置钉钉机器人钉钉APP配置项目中启动钉钉通知功能安装插件 Ding Talk 点击左侧的 Manage Jenkins —> Plugins ——> 左侧的 Available plugins Jenkins 配置钉钉机器人点击左侧的 Manage Jenkins ，拉到最后钉…...

编程日记 2023/8/4 18:51:44

LeetCode 26 题：删除有序数组的重复项

思路在写这一个题时，我突然想到了Python中的 set（）函数可能会有大用处，便选择了用Python写。 set（）函数可以将列表转化为集合，集合会保证元素的单一性，所以会自动删去相同字符。 …...

编程日记 2023/8/4 18:50:42

优雅地切换node版本（windows）

文章目录 1、下载并安装nvm2、nvm的使用3、处理npm版本与nodejs版本不匹配问题（通常不会有这个问题） 1、下载并安装nvm 卸载已安装的node：控制面板-程序-找到node并卸载通常在控制面板中卸载后，nodejs目录、环境变量、注册表就自…...

编程日记 2023/8/4 18:49:41

反诈：吴明军、黄亮领导的WIN生活资金盘，大家警惕防范此类诈骗

消息已经证实！“米粒”无法变现，数以万计的会员深套“315万民商城”，维权艰难，血汗钱无法讨回。其实这一点笔者并不感到太意外，因为万民商城资金传销盘的定性之前就已经发文揭露过，并反复提醒大家小心警惕…...

编程日记 2023/8/4 18:48:39

shell、bash的关系及bash的特性（一）

一、概念 shell是壳，是运行在终端中的文本互动程序。Shell相当于是一个翻译，把我们在计算机上的操作命令，翻译为计算机可识别的二进制命令，传递给内核，以便调用计算机硬件执行相关的操作；同时，计…...

编程日记 2023/8/4 18:47:38

ubuntu 14.04源更新(sources.list) deb http://mirrors.aliyun.com/ubuntu/ trusty main restricted universe multiverse deb http://mirrors.aliyun.com/ubuntu/ trusty-security main restricted universe multiverse deb http://mirrors.aliyun.com/ubuntu/ trusty-update…...

编程日记 2023/8/4 18:46:36