hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增悲观锁

Browse Source
This commit is contained in:
tianfeng 2025-09-19 18:52:49 +08:00
parent 31e7b3239f
commit 41fa4726ad
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/impl/FragmentsBackpackServiceImpl.java
View File

@ -63,7 +63,8 @@ public class FragmentsBackpackServiceImpl extends
.setSql("quantity=quantity-" + quantity)
.in(FragmentsBackpack::getFragmentsId, fragmentsIds)
.eq(FragmentsBackpack::getUserId, userId)
.last(PageConstant.formatLimit(fragmentsIds.size()))
.ge(FragmentsBackpack::getQuantity, quantity)
.last(PageConstant.formatLimit(fragmentsIds.size()) + " FOR UPDATE")
.execute();
}