商品删除时 删除库存缓存

This commit is contained in:
2024-03-12 14:04:27 +08:00
parent 17e606cbb9
commit 0e1833fe32
2 changed files with 11 additions and 6 deletions

View File

@@ -715,17 +715,22 @@ public class RedisUtils {
log.debug("--------------------------------------------"); log.debug("--------------------------------------------");
} }
/**
* 根据 prefix+id 删除key 不做模糊匹配
* @param prefix 前缀
* @param ids id
*/
public void delByIntKey(String prefix, Set<Integer> ids) { public void delByIntKey(String prefix, Set<Integer> ids) {
Set<Object> keys = new HashSet<>(); Set<Object> keys = new HashSet<>();
for (Integer id : ids) { for (Integer id : ids) {
keys.addAll(redisTemplate.keys(new StringBuffer(prefix).append(id).toString())); keys.add(prefix + id);
} }
long count = redisTemplate.delete(keys); long count = redisTemplate.delete(keys);
// 此处提示可自行删除 // 此处提示可自行删除
log.debug("--------------------------------------------"); log.info("--------------------------------------------");
log.debug("成功删除缓存:" + keys.toString()); log.info("成功删除缓存:" + keys.toString());
log.debug("缓存删除数量:" + count + ""); log.info("缓存删除数量:" + count + "");
log.debug("--------------------------------------------"); log.info("--------------------------------------------");
} }
/** /**
* redis 库存操作 * redis 库存操作

View File

@@ -349,7 +349,7 @@ public class TbProductServiceImpl implements TbProductService {
List<TbProductSku> tbProductSkus = tbProductSkuRepository.searchSku(productId.toString()); List<TbProductSku> tbProductSkus = tbProductSkuRepository.searchSku(productId.toString());
Map<Integer, Double> idStockMap = tbProductSkus.stream() Map<Integer, Double> idStockMap = tbProductSkus.stream()
.collect(Collectors.toMap(TbProductSku::getId, TbProductSku::getStockNumber)); .collect(Collectors.toMap(TbProductSku::getId, TbProductSku::getStockNumber));
redisUtils.redisUp(2,productId.toString(),idStockMap); redisUtils.redisUp(2,tbProductSkus.get(0).getShopId(),idStockMap);
}); });
} }