|
@@ -365,7 +365,7 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods> implement
|
|
|
@Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED)
|
|
|
public void increaseStock(List<GoodsBatchNoDto> goodsBatchNoDtos, List<Integer> goodsIdsList, AccountType accountType) {
|
|
|
Set<Integer> goodsIds = goodsBatchNoDtos.stream().map(GoodsBatchNoDto::getGoodsId).collect(Collectors.toSet());
|
|
|
- List<Goods> goodsList = goodsDao.getGoodies(new ArrayList<>(goodsIds));
|
|
|
+ List<Goods> goodsList = goodsDao.lockGoods(new ArrayList<>(goodsIds));
|
|
|
Map<Integer, Goods> idGoodsMap = goodsList.stream().collect(Collectors.toMap(Goods::getId, g -> g));
|
|
|
for (GoodsBatchNoDto goodsBatchNoDto : goodsBatchNoDtos) {
|
|
|
Goods goods = idGoodsMap.get(goodsBatchNoDto.getGoodsId());
|