缓存bug修复
This commit is contained in:
parent
974b00ecbb
commit
6df79916bd
|
|
@ -65,13 +65,15 @@ public class ProductController {
|
||||||
public CzgResult<List<ProductDTO>> getProductList(ProductDTO param) {
|
public CzgResult<List<ProductDTO>> getProductList(ProductDTO param) {
|
||||||
Long shopId = StpKit.USER.getShopId(0L);
|
Long shopId = StpKit.USER.getShopId(0L);
|
||||||
param.setShopId(shopId);
|
param.setShopId(shopId);
|
||||||
List<ProductDTO> data = getProductCacheList(param);
|
ProductDTO cacheParam = new ProductDTO();
|
||||||
|
cacheParam.setShopId(shopId);
|
||||||
|
List<ProductDTO> data = getProductCacheList(cacheParam, param);
|
||||||
productService.refreshProductStock(param, data);
|
productService.refreshProductStock(param, data);
|
||||||
return CzgResult.success(data);
|
return CzgResult.success(data);
|
||||||
}
|
}
|
||||||
|
|
||||||
private List<ProductDTO> getProductCacheList(ProductDTO param) {
|
private List<ProductDTO> getProductCacheList(ProductDTO cacheParam, ProductDTO param) {
|
||||||
List<ProductDTO> productList = productService.getProductList(param);
|
List<ProductDTO> productList = productService.getProductList(cacheParam);
|
||||||
if (StrUtil.isNotEmpty(param.getName())) {
|
if (StrUtil.isNotEmpty(param.getName())) {
|
||||||
productList = productList.stream().filter(obj -> StrUtil.contains(obj.getName(), param.getName())).toList();
|
productList = productList.stream().filter(obj -> StrUtil.contains(obj.getName(), param.getName())).toList();
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue