feat:模型调整
This commit is contained in:
@@ -63,6 +63,11 @@ public class FixedScheduleDO implements Serializable {
|
||||
*/
|
||||
private Integer totalSeats;
|
||||
|
||||
/**
|
||||
* 已售座位数
|
||||
*/
|
||||
private Integer soldSeats;
|
||||
|
||||
/**
|
||||
* 可用座位数
|
||||
*/
|
||||
|
||||
@@ -44,6 +44,11 @@ public class InventoryDO implements Serializable {
|
||||
*/
|
||||
private Integer totalStock;
|
||||
|
||||
/**
|
||||
* 已售座位数
|
||||
*/
|
||||
private Integer soldStock;
|
||||
|
||||
/**
|
||||
* 剩余库存
|
||||
*/
|
||||
|
||||
@@ -47,16 +47,21 @@ public class RollingScheduleDO implements Serializable {
|
||||
* 状态:1-运营中,0-已停运
|
||||
*/
|
||||
private Integer status;
|
||||
|
||||
|
||||
/**
|
||||
* 可用座位数
|
||||
* 总座位数
|
||||
*/
|
||||
private Integer availableSeats;
|
||||
|
||||
private Integer totalSeats;
|
||||
|
||||
/**
|
||||
* 已售座位数
|
||||
*/
|
||||
private Integer soldSeats;
|
||||
|
||||
/**
|
||||
* 可用座位数
|
||||
*/
|
||||
private Integer availableSeats;
|
||||
|
||||
/**
|
||||
* 创建时间
|
||||
|
||||
@@ -16,9 +16,7 @@ import java.time.LocalTime;
|
||||
@Data
|
||||
@TableName("route")
|
||||
public class RouteDO implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
/**
|
||||
* 主键ID
|
||||
*/
|
||||
|
||||
@@ -56,6 +56,11 @@ public class FixedSchedule implements Serializable {
|
||||
*/
|
||||
private Integer totalSeats;
|
||||
|
||||
/**
|
||||
* 已售座位数
|
||||
*/
|
||||
private Integer soldSeats;
|
||||
|
||||
/**
|
||||
* 可用座位数
|
||||
*/
|
||||
|
||||
@@ -33,6 +33,11 @@ public class Inventory implements Serializable {
|
||||
*/
|
||||
private Integer totalStock;
|
||||
|
||||
/**
|
||||
* 已售座位数
|
||||
*/
|
||||
private Integer soldStock;
|
||||
|
||||
/**
|
||||
* 剩余库存
|
||||
*/
|
||||
|
||||
@@ -40,6 +40,11 @@ public class RollingSchedule implements Serializable {
|
||||
*/
|
||||
private Integer status;
|
||||
|
||||
/**
|
||||
* 总座位数
|
||||
*/
|
||||
private Integer totalSeats;
|
||||
|
||||
/**
|
||||
* 可用座位数
|
||||
*/
|
||||
|
||||
@@ -101,13 +101,11 @@ public class RouteServiceImpl implements RouteService {
|
||||
|
||||
Integer beforeQty = schedule.getAvailableSeats();
|
||||
|
||||
// 乐观锁扣减可用库存
|
||||
// 扣减可用库存
|
||||
boolean success = fixedScheduleRepository.update(
|
||||
Wrappers.lambdaUpdate(FixedScheduleDO.class)
|
||||
.eq(FixedScheduleDO::getScheduleCode, dto.getScheduleCode())
|
||||
.eq(FixedScheduleDO::getVersion, schedule.getVersion())
|
||||
.setSql("available_seats = available_seats - " + dto.getQuantity())
|
||||
.set(FixedScheduleDO::getVersion, schedule.getVersion() + 1)
|
||||
.ge(FixedScheduleDO::getAvailableSeats, dto.getQuantity())
|
||||
);
|
||||
|
||||
@@ -221,9 +219,7 @@ public class RouteServiceImpl implements RouteService {
|
||||
boolean success = rollingScheduleRepository.update(
|
||||
Wrappers.lambdaUpdate(RollingScheduleDO.class)
|
||||
.eq(RollingScheduleDO::getRollingScheduleCode, dto.getRollingScheduleCode())
|
||||
.eq(RollingScheduleDO::getVersion, schedule.getVersion())
|
||||
.setSql("available_seats = available_seats - " + dto.getQuantity())
|
||||
.set(RollingScheduleDO::getVersion, schedule.getVersion() + 1)
|
||||
.ge(RollingScheduleDO::getAvailableSeats, dto.getQuantity())
|
||||
);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user