BruceSun
/
RuoYi-Vue
mirror of https://gitee.com/y_project/RuoYi-Vue.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

master：档口发布商品报错处理；

pull/1121/head
liujiang 2025-11-21 22:32:27 +08:00
parent 1ff3b43598
commit b70cf874c8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreProductServiceImpl.java
View File

@ -230,6 +230,10 @@ public class StoreProductServiceImpl implements IStoreProductService {
&& Objects.equals(storeProd.getListingWay(), ListingType.RIGHT_NOW.getValue())) {
// redis中的档口
Store store = this.redisCache.getCacheObject(CacheConstants.STORE_KEY + storeProd.getStoreId());
if (ObjectUtils.isEmpty(store)) {
store = Optional.ofNullable(this.storeMapper.selectById(storeProd.getStoreId()))
.orElseThrow(() -> new ServiceException("档口不存在，请联系管理员!", HttpStatus.ERROR));
}
// 向ES索引: product_info 创建文档
this.createESDoc(storeProd, createDTO, store.getStoreName());
// 搜图服务同步
@ -296,6 +300,10 @@ public class StoreProductServiceImpl implements IStoreProductService {
|| Objects.equals(storeProd.getProdStatus(), EProductStatus.TAIL_GOODS.getValue()))) {
// 从redis中获取store
Store store = this.redisCache.getCacheObject(CacheConstants.STORE_KEY + storeProd.getStoreId());
if (ObjectUtils.isEmpty(store)) {
store = Optional.ofNullable(this.storeMapper.selectById(storeProd.getStoreId()))
.orElseThrow(() -> new ServiceException("档口不存在，请联系管理员!", HttpStatus.ERROR));
}
// 更新索引: product_info 的文档
this.updateESDoc(storeProd, updateDTO, store.getStoreName());
// 搜图服务同步