From b70cf874c81a19fedc20f47ee88d730556b6113b Mon Sep 17 00:00:00 2001
From: liujiang <569804566@qq.com>
Date: Fri, 21 Nov 2025 22:32:27 +0800
Subject: [PATCH] =?UTF-8?q?master=EF=BC=9A=E6=A1=A3=E5=8F=A3=E5=8F=91?=
 =?UTF-8?q?=E5=B8=83=E5=95=86=E5=93=81=E6=8A=A5=E9=94=99=E5=A4=84=E7=90=86?=
 =?UTF-8?q?=EF=BC=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ruoyi/xkt/service/impl/StoreProductServiceImpl.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreProductServiceImpl.java b/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreProductServiceImpl.java
index fe460a914..3b15bf95d 100644
--- a/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreProductServiceImpl.java
+++ b/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreProductServiceImpl.java
@@ -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());
             // 搜图服务同步