商品修改回滚

This commit is contained in:
2024-08-01 18:15:27 +08:00
parent 9fcc5df6b9
commit d2a18664ea

View File

@@ -491,28 +491,13 @@ public class TbProductServiceImpl implements TbProductService {
// } // }
// } // }
if ("sku".equals(save.getTypeEnum())) { if ("sku".equals(save.getTypeEnum())) {
// List<Integer> collect = resources.getSkuList().stream().map(TbProductSku::getId).collect(Collectors.toList()); List<Integer> collect = resources.getSkuList().stream().map(TbProductSku::getId).collect(Collectors.toList());
List<TbProductSku> tbProductSkus = tbProductSkuRepository.searchSku(resources.getId().toString()); List<TbProductSku> tbProductSkus = tbProductSkuRepository.searchSku(resources.getId().toString());
List<Integer> collect = tbProductSkus.stream().map(TbProductSku::getId).collect(Collectors.toList());
HashMap<String, TbProductSku> skuInfo = new HashMap<>();
for (TbProductSku productSkus : tbProductSkus) { for (TbProductSku productSkus : tbProductSkus) {
skuInfo.put(productSkus.getId().toString(), productSkus); if (!collect.contains(productSkus.getId())) {
} tbProductSkuRepository.deleteBySkuId(productSkus.getId());
for (TbProductSku tbProductSku : resources.getSkuList()) {
if (!collect.contains(tbProductSku.getId())) {
tbProductSkuRepository.deleteBySkuId(tbProductSku.getId());
}else {
TbProductSku productSku = skuInfo.get(tbProductSku.getId().toString());
if (productSku != null) {
tbProductSku.setIsGrounding(productSku.getIsGrounding());
}
} }
} }
// for (TbProductSku productSkus : tbProductSkus) {
// if (!collect.contains(productSkus.getId())) {
// tbProductSkuRepository.deleteBySkuId(productSkus.getId());
// }
// }
} }
tbProductSkuRepository.saveAll(resources.getSkuList()); tbProductSkuRepository.saveAll(resources.getSkuList());
} }