乐观锁解决库存超卖问题

public BaseResult creatOneOrder(FlightOrderServiceImpl orderService, List<Map<String, String>> passengers,Map<String, String> selectFlightMap,String account) throws Exception {//如果是单程//判断座位数是否>=1//是的话就直接减库存//不是就return 201，库存不够int k=0;FlightSeat seat = seatService.getById(selectFlightMap.get("seatId"));if(seat.getRestNum()<1){return new BaseResult(201,"库存不够了");}seat.setRestNum(seat.getRestNum()-1);boolean updateResult = seatService.updateById(seat);if(!updateResult){//如果更新失败//说明在更新前有其他人已经对该行剩余量进行了修改//就再试一次，先判断库存int maxRetries = 5; //最大重试次数int retryCount = 0;while (retryCount < maxRetries) {// 获取最新的座位信息FlightSeat updatedSeat = seatService.getById(selectFlightMap.get("seatId"));// 检查座位是否仍然可用if (updatedSeat.getRestNum() < 1) {return new BaseResult(201, "库存不够了");}// 尝试更新座位信息updatedSeat.setRestNum(updatedSeat.getRestNum() - 1);boolean retryUpdateResult = seatService.updateById(updatedSeat);// 检查更新操作的结果if (retryUpdateResult) {// 成功更新，生成订单，跳出循环k=1;break;} else {// 增加重试计数并进行下一次尝试retryCount++;}if (retryCount == maxRetries) {return new BaseResult(202, "更新失败，重试次数已达上限");}}}else {k =1;}if(k==1){//k=1说明库存成功减少了FlightOrder Order = new FlightOrder();// 获取当前时间LocalDateTime currentTime = LocalDateTime.now();// 如果你想以特定格式输出当前时间，可以使用 DateTimeFormatterDateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");String formattedCurrentTime = currentTime.format(formatter);Order.setDate(formattedCurrentTime);// 设置超时时间为当前时间的15分钟后LocalDateTime timeoutTime = currentTime.plusMinutes(15);String formattedTimeoutTime = timeoutTime.format(formatter);Order.setTimeout(formattedTimeoutTime);Order.setOrderId(String.valueOf(new SnowUtil(0,0).getId()));//                redisTemplate.opsForValue().set(Order.getOrderId(), Order.getOrderId(), 15, TimeUnit.MINUTES);redisTemplate.opsForValue().set(Order.getOrderId(), Order.getOrderId(), 15, TimeUnit.MINUTES);Flight flight = new Flight();flight = flightService.getById(selectFlightMap.get("flightId"));Order.setFlightCode(flight.getFlightCode());Order.setStage("待支付");Order.setWay("单程");Order.setUserId(account);Air air = airService.getById(flight.getAirId());Order.setPrice(seat.getPrice());Order.setAllPrice(seat.getPrice());Order.setSeatType(seat.getSeatType());Order.setDepCity(flight.getDepCity());Order.setDepDate(flight.getDepDate());Order.setDepTime(flight.getDepTime());Order.setArrCity(flight.getArrCity());Order.setArrDate(flight.getArrDate());Order.setArrTime(flight.getArrTime());Order.setDepAirport(flight.getDepAirport());Order.setArrAirport(flight.getArrAirport());Order.setAirlineName(flight.getAirlineName());Order.setAirType(air.getType());orderService.save(Order);for (Map<String, String> pas : passengers) {FlightPassenger passenger = new FlightPassenger();passenger.setOrderId(Order.getOrderId());passenger.setName(pas.get("name"));passenger.setIdentityId(pas.get("sfz"));passenger.setPhone(pas.get("phone"));passengerService.save(passenger);}return new BaseResult(200,"支付成功",Order.getOrderId());}else return new BaseResult(202,"库存不够或者重试次数达到上限");}

往返票

 @Transactionalpublic BaseResult creatTwoOrder(FlightOrderServiceImpl orderService,List<Map<String, String>> passengers,Map<String, String> selectFlightMap,String account) throws Exception {//            座位int k1=0,k2=0;FlightSeat seat = seatService.getById(selectFlightMap.get("goSeatId"));FlightSeat seatback = seatService.getById(selectFlightMap.get("backSeatId"));//先判断库存if(seat.getRestNum()<1||seatback.getRestNum()<1){return new BaseResult(201,"库存不够了");}//如果库存都够seat.setRestNum(seat.getRestNum()-1);boolean updateResult = seatService.updateById(seat);if(!updateResult){//如果更新失败int max =5;int cnt=0;while(cnt<max){//先判断库存FlightSeat newSeat = seatService.getById(selectFlightMap.get("goSeatId"));if(newSeat.getRestNum()<1){return new BaseResult(201,"库存不够了");}//如果库存足够newSeat.setRestNum(newSeat.getRestNum()-1);boolean updateSeatResult = seatService.updateById(newSeat);if(updateSeatResult){//成功k1 =1;break;}else {//修改库存又失败了，有其他线程已经将这行记录的值进行了修改cnt++;}if(cnt==max){return new BaseResult(202,"重试次数已经达到上限");}}}else {//一次成功k1 =1;}//到这里的话就说明去程的票减库存已经成功了//开始买返程的票seatback.setRestNum(seatback.getRestNum()-1);boolean backSeatResult = seatService.updateById(seatback);if(!backSeatResult){//如果更新失败int max1 =5;int cnt1 =0;while (cnt1<max1){FlightSeat newSeatback = seatService.getById(selectFlightMap.get("backSeatId"));if(newSeatback.getRestNum()<1){//回滚去程的票数TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return new BaseResult(202,"库存不够了");}//如果库存足够boolean result = seatService.updateById(newSeatback);if(result){k2=1;break;}else {cnt1++;}if(cnt1==max1){//首先要回滚去程的库存TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return new BaseResult(202,"达到尝试上限");}}}else {k2=1;}if(k1==1&&k2==1){FlightOrder Order = new FlightOrder();// 获取当前时间LocalDateTime currentTime = LocalDateTime.now();// 如果你想以特定格式输出当前时间，可以使用 DateTimeFormatterDateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");String formattedCurrentTime = currentTime.format(formatter);Order.setDate(formattedCurrentTime);// 设置超时时间为当前时间的15分钟后LocalDateTime timeoutTime = currentTime.plusMinutes(15);String formattedTimeoutTime = timeoutTime.format(formatter);Order.setTimeout(formattedTimeoutTime);Order.setOrderId(String.valueOf(new SnowUtil(0,0).getId()));redisTemplate.opsForValue().set(Order.getOrderId(), Order.getOrderId(), 15, TimeUnit.MINUTES);//            获取数据Flight flight1 = flightService.getById(selectFlightMap.get("goId"));Air air1 = airService.getById(flight1.getAirId());Order.setDepCity(flight1.getDepCity());Order.setDepDate(flight1.getDepDate());Order.setDepTime(flight1.getDepTime());Order.setArrCity(flight1.getArrCity());Order.setArrDate(flight1.getArrDate());Order.setArrTime(flight1.getArrTime());Order.setDepAirport(flight1.getDepAirport());Order.setArrAirport(flight1.getArrAirport());Order.setAirlineName(flight1.getAirlineName());Order.setAirType(air1.getType());//            订单对象Order.setFlightCode(flight1.getFlightCode());Order.setStage("待支付");Order.setWay("往返");Order.setUserId(account);Order.setPrice(seat.getPrice());Order.setSeatType(seat.getSeatType());Flight flight2 = flightService.getById(selectFlightMap.get("backId"));Air air2 = airService.getById(flight2.getAirId());Order.setBackDepCity(flight2.getDepCity());Order.setBackDepDate(flight2.getDepDate());Order.setBackDepTime(flight2.getDepTime());Order.setBackArrCity(flight2.getArrCity());Order.setBackArrDate(flight2.getArrDate());Order.setBackArrTime(flight2.getArrTime());Order.setBackDepAirport(flight2.getDepAirport());Order.setBackArrAirport(flight2.getArrAirport());Order.setBackAirlineName(flight2.getAirlineName());Order.setBackAirType(air2.getType());Order.setBackPrice(seatback.getPrice());Order.setAllPrice(seat.getPrice()+seatback.getPrice());Order.setBackFlightCode(flight2.getFlightCode());Order.setBackSeatType(seatback.getSeatType());orderService.save(Order);for (Map<String, String> pas : passengers) {FlightPassenger passenger = new FlightPassenger();passenger.setOrderId(Order.getOrderId());passenger.setName(pas.get("name"));passenger.setIdentityId(pas.get("sfz"));passenger.setPhone(pas.get("phone"));passengerService.save(passenger);}return new BaseResult(200,"支付成功",Order.getOrderId());}else {TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();return new BaseResult(202, "库存不够或者达到重试次数上限");}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/172272.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

excel表中慎用合并单元格，多用跨列居中

excel表中慎用合并单元格，多用跨列居中

如下一个excel例表&#xff1a; 要将首行居中&#xff0c;最好的办法如下&#xff1a; 1、选中首行单元格 2、按下ctrl1&#xff0c;调出“设置单元格格式”&#xff0c;选中“对齐”&#xff0c;在“水平对齐”中选择“跨列居中” 3、完成任务 这样居中的好处是&#xff1a;可…
阅读更多...
【NeRF】3、MobileR2L | 移动端实时的神经光场（CVPR2023）

【NeRF】3、MobileR2L | 移动端实时的神经光场（CVPR2023）

论文&#xff1a;Real-Time Neural Light Field on Mobile Devices 代码&#xff1a;https://github.com/snap-research/MobileR2L 出处&#xff1a;CVPR2023 贡献&#xff1a; 设计了一套移动端实时的 R2L 网络结构 MobileR2L&#xff0c;在 iphone13 上渲染一张 1008x756…
阅读更多...
RC-MVSNet：无监督的多视角立体视觉与神经渲染--论文笔记（2022年）

RC-MVSNet：无监督的多视角立体视觉与神经渲染--论文笔记（2022年）

RC-MVSNet&#xff1a;无监督的多视角立体视觉与神经渲染--论文笔记&#xff08;2022年&#xff09; 摘要1 引言2 相关工作2.1 基于监督的MVS2.2 无监督和自监督MVS2.3 多视图神经渲染 3 实现方法3.1 无监督的MVS网络 Chang, D. et al. (2022). RC-MVSNet: Unsupervised Multi-…
阅读更多...
帮管客CRM SQL注入漏洞复现

帮管客CRM SQL注入漏洞复现

0x01 产品简介 帮管客CRM是一款集客户档案、销售记录、业务往来等功能于一体的客户管理系统。帮管客CRM客户管理系统&#xff0c;客户管理&#xff0c;从未如此简单&#xff0c;一个平台满足企业全方位的销售跟进、智能化服务管理、高效的沟通协同、图表化数据分析帮管客颠覆传…
阅读更多...
【深度学习实验】图像处理（二）：PIL 和 PyTorch（transforms）中的图像处理与随机图片增强

【深度学习实验】图像处理（二）：PIL 和 PyTorch（transforms）中的图像处理与随机图片增强

文章目录 一、实验介绍二、实验环境1. 配置虚拟环境2. 库版本介绍 三、实验内容0. 导入需要的工具包1. PIL图像处理a. 生成绿色和蓝色图像b. 缩放和合成图像c 在合成图像上添加文字d. 展示并保存图像 2. PIL随机图像增强a. 定义随机图像增强函数b. 实验结果展示 3. PyTorch&…
阅读更多...
redis实现消息延迟队列

redis实现消息延迟队列

业务场景 在很多软件系统功能中都会出现定时任务的业务场景,比如提前点单,比如定时发布动态,文章等而出现这样的的定时的任务为延迟队任务 代码模块 任务的持久化一般都需要建立一个任务表和任务日志表,避免宕机导致任务失效,先新建立一个数据库,创建基本的任务表和任务日志表…
阅读更多...
leetcode 打家劫舍

leetcode 打家劫舍

打家劫舍 (a) 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都藏有一定的现金&#xff0c;影响你偷窃的唯一制约因素就是相邻的房屋装有相互连通的防盗系统&#xff0c;如果两间相邻的房屋在同一晚上被小偷闯入&#xff0c;系统会自动报警。 给定一个代表每个…
阅读更多...
CodeTON Round 7 (Div. 1 + Div. 2, Rated, Prizes!), E题 --- 题解

CodeTON Round 7 (Div. 1 + Div. 2, Rated, Prizes!), E题 --- 题解

目录 题目大意&#xff1a; 思路解析&#xff1a; 代码&#xff1a; Problem - E - Codeforces 题目大意&#xff1a; 现在给你一个排列&#xff0c;排列的定义是如果排列长度为n&#xff0c;则他应该出现1-n的每个数字一次&#xff0c;但是顺序是无序的&#xff0c;现在问…
阅读更多...
【MOJO】Modular语言安装和测试

【MOJO】Modular语言安装和测试

目录 一、Mojo介绍 Linux​ Mac 二、安装Mojo SDK 三、mojo代码测试 3.1、在 REPL 中运行代码​ 3.2、构建并运行 Mojo 源文件​ 运行mojo文件​ 构建可执行二进制文件​ 四、VSCode安装 一、Mojo介绍 在学习Rust语言的过程中无意发现了Modular语言&#xff0c;语言…
阅读更多...
Docker部署Nacos

Docker部署Nacos

此篇文章使用的nacos为2.2.1版本 拉取Nacos镜像 docker pull nacos/nacos-server:v2.2.1先将容器启动起来 docker run -d \ --name nacos \ -p 8848:8848 \ -p 9848:9848 \ -p 9849:9849 \ --privilegedtrue \ -e JVM_XMS256m \ -e JVM_XMX256m \ -e MODEstandalone \ -e NA…
阅读更多...
nginx基础篇学习

nginx基础篇学习

一、nginx编译安装 1、前往nginx官网获取安装包 下载安装包 2、解压 3、安装 进入安装包 安装准备&#xff1a;nginx的rewrite module重写模块依赖于pcre、pcre-devel、zlib和zlib-devel库&#xff0c;要先安装这些库 安装&#xff1a; 编译&#xff1a; 启动&#xff…
阅读更多...
web前端之vue和echarts的堆叠柱状图顶部显示总数、鼠标悬浮工具提示、设置图例的显示与隐藏、label、legend、tooltip

web前端之vue和echarts的堆叠柱状图顶部显示总数、鼠标悬浮工具提示、设置图例的显示与隐藏、label、legend、tooltip

MENU 效果图htmlJavaScripstyle解析 效果图 html <template><div><div><div id"idStackedColumnChart" style"width: 100%; height: 680px"></div></div></div> </template>JavaScrip export default {…
阅读更多...
python-opencv轮廓检测（外轮廓检测和全部轮廓检测，计算轮廓面积和周长）

python-opencv轮廓检测（外轮廓检测和全部轮廓检测，计算轮廓面积和周长）

python-opencv轮廓检测&#xff08;外轮廓检测和全部轮廓检测&#xff0c;计算轮廓面积和周长&#xff09; 通过cv2.findContours&#xff0c;我们可以进行轮廓检测&#xff0c;当然也有很多检测模式&#xff0c;我们可以通过选择检测模式&#xff0c;进行外轮廓检测&#xff…
阅读更多...
通过ros系统中websocket中发送sensor_msgs::Image数据给web端显示(二)

通过ros系统中websocket中发送sensor_msgs::Image数据给web端显示(二)

通过ros系统中websocket中发送sensor_msgs::Image数据给web端显示(二) mp4媒体流数据 #include <ros/ros.h> #include <signal.h> #include <sensor_msgs/Image.h> #include <message_filters/subscriber.h> #include <message_filters/synchroniz…
阅读更多...
从零开始学习管道：管道程序的优化和文件描述符继承问题

从零开始学习管道：管道程序的优化和文件描述符继承问题

&#x1f4df;作者主页&#xff1a;慢热的陕西人 &#x1f334;专栏链接&#xff1a;Linux &#x1f4e3;欢迎各位大佬&#x1f44d;点赞&#x1f525;关注&#x1f693;收藏&#xff0c;&#x1f349;留言 本博客主要内容管道后续的完善&#xff0c;以及解决管道继承多个文件描…
阅读更多...
精进Beautiful Soup 小技巧(三)---综合提供效率(缓存/error/多线程/异步)

精进Beautiful Soup 小技巧(三)---综合提供效率(缓存/error/多线程/异步)

前言: 提高抓取和解析效率的根本还是在于发送请求;如何从这个方面进行效率提升呢? 深入使用requests.Session() 深入使用requests.Session() 1.持久连接&#xff1a; 当使用 requests.Session() 时&#xff0c;连接会话中所有的请求将优先使用一个TCP连接&#xff0c;即“…
阅读更多...
点击url如何唤起nativescript应用程序？

点击url如何唤起nativescript应用程序？

1、低于ios 9.0的版本 可以使用 nativescript-urlhandler&#xff0c;通过在app.component.ts中添加handleOpenURL来实现。 2、高于ios 9.0的版本 可以使用 nativescript-community/universal-links来实现 https://github.com/nativescript-community/universal-links 安装&a…
阅读更多...
【Amazon】基于Amazon提供的托管式EKS通过eksctl命令部署Kubernetes集群

【Amazon】基于Amazon提供的托管式EKS通过eksctl命令部署Kubernetes集群

文章目录 一、使用CloudFormation创建堡垒机二、安装AWS CLI命令行工具三、安装eksctl命令行工具四、创建集群角色4.1 集群服务角色创建4.2 集群节点组角色创建 五、创建 EKS集群六、登录EKS控制台七、参考链接 一、使用CloudFormation创建堡垒机 导航至CloudFormation&#xf…
阅读更多...
Kafka（二）在WSL搭建Schema Registry

Kafka（二）在WSL搭建Schema Registry

目录 1 Avro与Schema Registry2 搭建Schema Registry2.1 下载Confluent并解压2.2 设置环境变量2.3 修改配置2.4 启动服务 3 API列表 1 Avro与Schema Registry Apache Avro 是一种高效的数据序列化系统&#xff0c;用于在不同的应用程序和平台之间传输和存储数据。它提供了一种…
阅读更多...
AI智能客服搭建教程附带免费源码

AI智能客服搭建教程附带免费源码

*名称* *版本要求* 服务器 CPU 2核心 ↑运存 4G ↑宽带 5M ↑ 服务器操作系统 Linux Centos7 运行环境 Nginx 1.18 PHP 7.3 MYSQL 5.6 服务器配置及环境要求 PHP设置 一、安装PHP扩展插件：fileinfo、redis、 sg11 二、删除PHP对应版本中的 pcntl_signal 、pcntl_signal_dis…
阅读更多...
最新文章

Copyright @ 2022~2023