redis实现未支付时间超时就删除订单,并给前端反应一个已过期

ops/2025/3/4 1:23:46/

1.创建订单缓存,设置过期时间为一分钟

now 是一个表示当前时间的对象,offset 方法用于对当前时间进行偏移。
redisTemplate.expireAt(paymentKey, now.offset(DateField.SECOND, 60));

2.创建KeyExpiredListener类并且继承KeyExpirationEventMessageListener,用于监听Redis缓存过期。

在里面实现onMessage来实现键过期进行的回调函数

 

 @Override@Transactional//修改记录public void onMessage(Message message, byte[] pattern) {//获取过期数据的KeyString key = message.toString();//判断过期的数据是否为挂号单if (key.startsWith("registration_payment_")) {//从Key中提取挂号单流水号String outTradeNo = key.split("_")[2];//更新挂号支付订单状态为4medicalRegistrationDao.discardPayment(outTradeNo);//出诊计划已挂号人数减去1doctorWorkPlanDao.releaseNumByOutTradeNo(outTradeNo);//出诊时段已挂号人数减去1doctorWorkPlanScheduleDao.releaseNumByOutTradeNo(outTradeNo);//删除缓存中的已挂号人数//查询挂号单的workPlanId和scheduleIdHashMap map = medicalRegistrationDao.searchWorkPlanIdAndScheduleId(outTradeNo);int scheduleId = MapUtil.getInt(map, "doctorScheduleId");int workPlanId = MapUtil.getInt(map, "workPlanId");key = "doctor_schedule_" + scheduleId;//出诊时间段的缓存if (redisTemplate.hasKey(key)) {//存在没有过期//更新缓存中已挂号人数的数量减去1redisTemplate.opsForHash().increment(key, "num", -1);}}//super.onMessage(message, pattern);super.onMessage(message, pattern);}

上面是我写的代码,就是过期调用 DAO 层的方法,更新挂号支付订单状态为 4,表示订单已废弃。分别调用 DAO 层的方法,将对应的出诊计划和出诊时段的已挂号人数减去 1。因为我这个项目最多同一时段只能挂号三个人、


http://www.ppmy.cn/ops/15699.html

相关文章

架构师系列-消息中间件(九)- RocketMQ 进阶(三)-消费端消息保障

5.2 消费端保障 5.2.1 注意幂等性 应用程序在使用RocketMQ进行消息消费时必须支持幂等消费,即同一个消息被消费多次和消费一次的结果一样,这一点在使用RoketMQ或者分析RocketMQ源代码之前再怎么强调也不为过。 “至少一次送达”的消息交付策略&#xff…

【Web】HNCTF 2022 题解(全)

目录 Week1 Interesting_include 2048 easy_html What is Web Interesting_http easy_upload Week2 ez_SSTI easy_include ez_ssrf Canyource easy_unser easy_sql ohmywordpress Week3 ssssti Fun_php ez_phar QAQ_1inclu4e logjjjjlogjjjj …

综合练习

Oracle从入门到总裁:​​​​​​https://blog.csdn.net/weixin_67859959/article/details/135209645 下面我们通过一些实战练习加深对存储过程和函数的认识 以 scott 用户下 emp 数据表为基础,创建如下过程 (1)以部门编号为输入参数,查询该部门的平均…

使用TP8框架根据视频id查找所有评论和回复

在使用ThinkPHP 8(TP8)框架根据视频ID查找所有评论和回复时,你需要编写相应的控制器逻辑和模型方法来实现这一功能。下面是一个基本的示例,展示如何实现这个功能: 首先,确保你已经定义了Comment和Reply模型…

应对电网挑战!lonQ与橡树岭国家实验室利用量子技术改善关键基础设施

内容来源:量子前哨(ID:Qforepost) 文丨浪味仙 排版丨沛贤 深度好文:1800字丨6分钟阅读 摘要:美国电网正在面临需求增加和能源扩散的挑战,对能够应对优化和安全挑战的创新解决方案有着迫切需求…

Clickhouse离线安装教程

https://blog.51cto.com/u_15060531/4174350 1. 前置 1.1 检查服务器架构 服务器:Centos7.X 需要确保是否x86_64处理器构架、Linux并且支持SSE 4.2指令集 grep -q sse4_2 /proc/cpuinfo && echo "SSE 4.2 supported" || echo "SSE 4.2 …

AI绘画的算法原理:从生成模型到Diffusion

近年来,AI绘画技术引起了广泛关注,让我们深入探讨其背后的技术原理和发展历程。本文将以通俗易懂的方式,介绍AI绘画的核心算法,从生成模型到Diffusion。 1. 计算机如何生成图画? AI绘画的核心在于生成模型&#xff08…

Docker NetWork (网络)

Docker 为什么需要网络管理 容器的网络默认与宿主机及其他容器都是相互隔离的,但同时我们也要考虑下面的一些问题, 比如 多个容器之间是如何通信的容器和宿主机是如何通信的容器和外界主机是如何通信的容器中要运行一些网络应用(如 nginx、web 应用、数…