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


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

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

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

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

     

    1. @Override
    2. @Transactional//修改记录
    3. public void onMessage(Message message, byte[] pattern) {
    4. //获取过期数据的Key
    5. String key = message.toString();
    6. //判断过期的数据是否为挂号单
    7. if (key.startsWith("registration_payment_")) {
    8. //从Key中提取挂号单流水号
    9. String outTradeNo = key.split("_")[2];
    10. //更新挂号支付订单状态为4
    11. medicalRegistrationDao.discardPayment(outTradeNo);
    12. //出诊计划已挂号人数减去1
    13. doctorWorkPlanDao.releaseNumByOutTradeNo(outTradeNo);
    14. //出诊时段已挂号人数减去1
    15. doctorWorkPlanScheduleDao.releaseNumByOutTradeNo(outTradeNo);
    16. //删除缓存中的已挂号人数
    17. //查询挂号单的workPlanId和scheduleId
    18. HashMap map = medicalRegistrationDao.searchWorkPlanIdAndScheduleId(outTradeNo);
    19. int scheduleId = MapUtil.getInt(map, "doctorScheduleId");
    20. int workPlanId = MapUtil.getInt(map, "workPlanId");
    21. key = "doctor_schedule_" + scheduleId;//出诊时间段的缓存
    22. if (redisTemplate.hasKey(key)) {//存在没有过期
    23. //更新缓存中已挂号人数的数量减去1
    24. redisTemplate.opsForHash().increment(key, "num", -1);
    25. }
    26. }
    27. //super.onMessage(message, pattern);
    28. super.onMessage(message, pattern);
    29. }

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

  • 相关阅读:
    Linux系统下祼机安装mysql8.0和docker mysql 8.0 性能差异对比~
    Python基于OpenCV的异常行为检测系统[源码&部署教程]
    日志(四)
    JavaScript基础——练习巩固题目(1)
    Ubuntu下查看资源占用情况
    iwebsec靶场 SQL注入漏洞通关笔记5- updatexml注入(报错型盲注)
    宝宝每天需要补充多少钙?宝宝睡觉出汗枕秃是缺钙吗?
    8软件工程环境
    win10可以安装CW_MCUs_V6_3吗?求指教
    Docker常用命令
  • 原文地址:https://blog.csdn.net/m0_74749208/article/details/138041146