diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBiz22222222Controller.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBiz22222222Controller.java
index 3144211e1..f30592010 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBiz22222222Controller.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBiz22222222Controller.java
@@ -38,6 +38,7 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -84,6 +85,8 @@ public class GtAndFhbBiz22222222Controller extends BaseController {
     final IPictureService pictureService;
     final FsNotice fsNotice;
     final SysDictDataMapper dictDataMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     // 系统枚举 鞋面内里材质
     private static final String DICT_TYPE_SHOE_UPPER_LINING_MATERIAL = "shoe_upper_lining_material";
@@ -533,13 +536,13 @@ public class GtAndFhbBiz22222222Controller extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("批量新增到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBizController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBizController.java
index c8e058843..09363128f 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBizController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndFhbBizController.java
@@ -38,6 +38,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -84,6 +85,9 @@ public class GtAndFhbBizController extends BaseController {
     final IPictureService pictureService;
     final FsNotice fsNotice;
     final SysDictDataMapper dictDataMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
+
 
     // 系统枚举 鞋面内里材质
     private static final String DICT_TYPE_SHOE_UPPER_LINING_MATERIAL = "shoe_upper_lining_material";
@@ -497,7 +501,7 @@ public class GtAndFhbBizController extends BaseController {
         }
         // 2025.10.16 增加一重保险，客户优惠必须是大于0的；且必须滤重
         fhbCusDiscCacheList = fhbCusDiscCacheList.stream().filter(x -> x.getDiscount() > 0).distinct().collect(Collectors.toList());
-        
+
         List<FhbProdStockVO.SMPSRecordVO> fhbStockCacheList = redisCache
                 .getCacheObject(CacheConstants.MIGRATION_SUPPLIER_PROD_STOCK_KEY + initVO.getSupplierId());
         if (CollectionUtils.isEmpty(fhbStockCacheList)) {
@@ -598,13 +602,13 @@ public class GtAndFhbBizController extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("批量新增到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBiz222222Controller.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBiz222222Controller.java
index 8ce39e2c4..c9029c458 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBiz222222Controller.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBiz222222Controller.java
@@ -37,6 +37,7 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -79,6 +80,8 @@ public class GtAndTyBiz222222Controller extends BaseController {
     final EsClientWrapper esClientWrapper;
     final FsNotice fsNotice;
     final SysDictDataMapper dictDataMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     // 系统枚举 鞋面内里材质
     private static final String DICT_TYPE_SHOE_UPPER_LINING_MATERIAL = "shoe_upper_lining_material";
@@ -541,13 +544,13 @@ public class GtAndTyBiz222222Controller extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("批量新增到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBizController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBizController.java
index e8e9f4913..312d79d57 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBizController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtAndTyBizController.java
@@ -37,6 +37,7 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -79,6 +80,8 @@ public class GtAndTyBizController extends BaseController {
     final EsClientWrapper esClientWrapper;
     final FsNotice fsNotice;
     final SysDictDataMapper dictDataMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     // 系统枚举 鞋面内里材质
     private static final String DICT_TYPE_SHOE_UPPER_LINING_MATERIAL = "shoe_upper_lining_material";
@@ -583,13 +586,13 @@ public class GtAndTyBizController extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("批量新增到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOnlyBizController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOnlyBizController.java
index 643cedb78..d9fa99d20 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOnlyBizController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOnlyBizController.java
@@ -30,6 +30,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -67,6 +68,8 @@ public class GtOnlyBizController extends BaseController {
     final EsClientWrapper esClientWrapper;
     final IPictureService pictureService;
     final FsNotice fsNotice;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
 
     /**
@@ -293,13 +296,13 @@ public class GtOnlyBizController extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("批量新增到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
@@ -441,6 +444,7 @@ public class GtOnlyBizController extends BaseController {
 
     /**
      * 获取GT商品的内里属性
+     *
      * @param userId
      * @param gtProdSkuVO
      * @return
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOtherBizAfterController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOtherBizAfterController.java
index d3fd3527a..dab20afb7 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOtherBizAfterController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/xkt/migartion/GtOtherBizAfterController.java
@@ -31,6 +31,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -72,7 +73,8 @@ public class GtOtherBizAfterController extends BaseController {
     final EsClientWrapper esClientWrapper;
     final IPictureService pictureService;
     final FsNotice fsNotice;
-
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     /**
      * step1
@@ -325,13 +327,13 @@ public class GtOtherBizAfterController extends BaseController {
         List<BulkOperation> bulkOperations = new ArrayList<>();
         for (ESProductDTO esProductDTO : esProductDTOList) {
             BulkOperation bulkOperation = new BulkOperation.Builder()
-                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(Constants.ES_IDX_PRODUCT_INFO).document(esProductDTO))
+                    .index(i -> i.id(esProductDTO.getStoreProdId()).index(ES_INDEX_NAME).document(esProductDTO))
                     .build();
             bulkOperations.add(bulkOperation);
         }
         // 执行批量插入
         try {
-            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse response = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("单独处理GT货号到 ES 成功的 id列表: {}", response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = response.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
diff --git a/ruoyi-admin/src/main/resources/application-dev.yml b/ruoyi-admin/src/main/resources/application-dev.yml
index 208327729..9a9731924 100644
--- a/ruoyi-admin/src/main/resources/application-dev.yml
+++ b/ruoyi-admin/src/main/resources/application-dev.yml
@@ -59,6 +59,7 @@ es:
   password: wXd3iRUcqHzxZPtKsDRn
   maxConnTotal: 4
   maxConnPerRoute: 2
+  indexName: dev_product_info
 # 开发环境配置
 server:
   # 服务器的HTTP端口，默认为9310
diff --git a/ruoyi-admin/src/main/resources/application-local.yml b/ruoyi-admin/src/main/resources/application-local.yml
index c9bd6f6e4..34af175db 100644
--- a/ruoyi-admin/src/main/resources/application-local.yml
+++ b/ruoyi-admin/src/main/resources/application-local.yml
@@ -59,6 +59,7 @@ es:
   password: 0tP&3!GZZDMrglBm&kWJyw
   maxConnTotal: 4
   maxConnPerRoute: 2
+  indexName: dev_product_info
 # 开发环境配置
 server:
   # 服务器的HTTP端口，默认为9310
diff --git a/ruoyi-admin/src/main/resources/application-prod.yml b/ruoyi-admin/src/main/resources/application-prod.yml
index 9934097eb..f4b2c6f3d 100644
--- a/ruoyi-admin/src/main/resources/application-prod.yml
+++ b/ruoyi-admin/src/main/resources/application-prod.yml
@@ -59,6 +59,7 @@ es:
   password: 0tP&3!GZZDMrglBm&kWJyw
   maxConnTotal: 100
   maxConnPerRoute: 50
+  indexName: product_info
 # 开发环境配置
 server:
   # 服务器的HTTP端口，默认为9310
diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java b/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java
index c79be3057..e2866aeff 100644
--- a/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java
+++ b/ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java
@@ -8,11 +8,10 @@ import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * 通用常量信息
- * 
+ *
  * @author ruoyi
  */
-public class Constants
-{
+public class Constants {
     /**
      * UTF-8 字符集
      */
@@ -161,18 +160,18 @@ public class Constants
     /**
      * 自动识别json对象白名单配置（仅允许解析的包名，范围越小越安全）
      */
-    public static final String[] JSON_WHITELIST_STR = { "org.springframework", "com.ruoyi" };
+    public static final String[] JSON_WHITELIST_STR = {"org.springframework", "com.ruoyi"};
 
     /**
      * 定时任务白名单配置（仅允许访问的包名，如其他需要可以自行添加）
      */
-    public static final String[] JOB_WHITELIST_STR = { "com.ruoyi.quartz.task" };
+    public static final String[] JOB_WHITELIST_STR = {"com.ruoyi.quartz.task"};
 
     /**
      * 定时任务违规的字符
      */
-    public static final String[] JOB_ERROR_STR = { "java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml",
-            "org.springframework", "org.apache", "com.ruoyi.common.utils.file", "com.ruoyi.common.config", "com.ruoyi.generator" };
+    public static final String[] JOB_ERROR_STR = {"java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml",
+            "org.springframework", "org.apache", "com.ruoyi.common.utils.file", "com.ruoyi.common.config", "com.ruoyi.generator"};
 
     public static final String UNDELETED = "0";
     public static final String DELETED = "2";
@@ -278,10 +277,6 @@ public class Constants
      * 上市季节年份
      */
     public static final String RELEASE_YEAR_SEASON_DICT = "release_year_season";
-    /**
-     * ES 索引 product_info
-     */
-    public static final String ES_IDX_PRODUCT_INFO = "product_info";
     /**
      * 最顶层商品分类ID
      */
@@ -334,8 +329,8 @@ public class Constants
 
     public static final BigDecimal ALI_SERVICE_FEE_RATE = BigDecimal.valueOf(0.006);
 
-    public static final String  INNER_MATERIAL = "内里材质";
-    public static final String  OUTER_MATERIAL = "里料材质";
+    public static final String INNER_MATERIAL = "内里材质";
+    public static final String OUTER_MATERIAL = "里料材质";
 
     public static final String UPPER_MATERIAL = "upperMaterial";
     public static final String UPPER_MATERIAL_NAME = "帮面材质";
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/XktTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/XktTask.java
index db292584d..38f07a717 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/XktTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/XktTask.java
@@ -57,6 +57,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -130,6 +131,8 @@ public class XktTask {
     final IWebsitePCNewProdService websitePCNewProdService;
     final IWebsitePCStoreService websitePCStoreService;
     final IWebsiteAPPService websiteAPPService;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     /**
      * 每天执行定时任务
@@ -824,12 +827,12 @@ public class XktTask {
                                 put("storeWeight", ObjectUtils.defaultIfNull(storeWeightMap.get(storeProd.getStoreId()), Constants.WEIGHT_DEFAULT_ZERO));
                             }}))
                             .id(String.valueOf(storeProd.getId()))
-                            .index(Constants.ES_IDX_PRODUCT_INFO))
+                            .index(ES_INDEX_NAME))
                     .build());
         });
         try {
             // 调用bulk方法执行批量更新操作
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
             log.info("定时任务，批量更新档口权重到 ES 成功的 id列表: {}", bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
@@ -1052,7 +1055,7 @@ public class XktTask {
                             // 使用商品ID作为文档ID
                             .id(String.valueOf(product.getId()))
                             // 索引名称
-                            .index(Constants.ES_IDX_PRODUCT_INFO)
+                            .index(ES_INDEX_NAME)
                             // 插入的数据
                             .document(esProductDTO))
                     .build();
@@ -1061,7 +1064,7 @@ public class XktTask {
         }
         // 执行批量插入
         try {
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(b -> b.index(Constants.ES_IDX_PRODUCT_INFO).operations(bulkOperations));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(b -> b.index(ES_INDEX_NAME).operations(bulkOperations));
             log.info("定时发布商品，批量新增商品到 ES 成功的 id列表: {}", bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
@@ -1693,12 +1696,12 @@ public class XktTask {
                                 put("tags", updateTags);
                             }}))
                             .id(String.valueOf(storeProdId))
-                            .index(Constants.ES_IDX_PRODUCT_INFO))
+                            .index(ES_INDEX_NAME))
                     .build());
         });
         try {
             // 调用bulk方法执行批量更新操作
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
             log.info("批量更新商品标签到 ES 成功的 id列表: {}", bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList()));
             // 有哪些没执行成功的，需要发飞书通知
             List<String> successIdList = bulkResponse.items().stream().map(BulkResponseItem::id).collect(Collectors.toList());
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 4446ed010..f150099b4 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
@@ -57,6 +57,7 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -109,6 +110,8 @@ public class StoreProductServiceImpl implements IStoreProductService {
     final OSSClientWrapper ossClient;
     final TencentAuthManager tencentAuthManager;
     final FsNotice fsNotice;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
 
     /**
@@ -1127,7 +1130,7 @@ public class StoreProductServiceImpl implements IStoreProductService {
         ESProductDTO esProductDTO = this.getESDTO(storeProd, storeProdDTO, storeName);
         try {
             // 向索引中添加数据
-            CreateResponse createResponse = esClientWrapper.getEsClient().create(e -> e.index(Constants.ES_IDX_PRODUCT_INFO)
+            CreateResponse createResponse = esClientWrapper.getEsClient().create(e -> e.index(ES_INDEX_NAME)
                     .id(storeProd.getId().toString()).document(esProductDTO));
             log.info("createResponse.result() = {}", createResponse.result());
         } catch (Exception e) {
@@ -1147,7 +1150,7 @@ public class StoreProductServiceImpl implements IStoreProductService {
         ESProductDTO esProductDTO = this.getESDTO(storeProd, updateDTO, storeName);
         try {
             UpdateResponse<ESProductDTO> updateResponse = esClientWrapper.getEsClient().update(u -> u
-                    .index(Constants.ES_IDX_PRODUCT_INFO).doc(esProductDTO).id(storeProd.getId().toString()), ESProductDTO.class);
+                    .index(ES_INDEX_NAME).doc(esProductDTO).id(storeProd.getId().toString()), ESProductDTO.class);
             log.info("updateResponse.result() = {}", updateResponse.result());
         } catch (Exception e) {
             fsNotice.sendMsg2DefaultChat("更新商品，同步到ES 失败", "storeProdId: " + storeProd.getId());
@@ -1206,9 +1209,9 @@ public class StoreProductServiceImpl implements IStoreProductService {
         try {
             // 删除ES索引文档
             List<BulkOperation> list = storeProdIdList.stream().map(x -> new BulkOperation.Builder().delete(
-                    d -> d.id(String.valueOf(x)).index(Constants.ES_IDX_PRODUCT_INFO)).build()).collect(Collectors.toList());
+                    d -> d.id(String.valueOf(x)).index(ES_INDEX_NAME)).build()).collect(Collectors.toList());
             // 调用bulk方法执行批量插入操作
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
             log.info("bulkResponse.items() = {}", bulkResponse.items());
         } catch (IOException | RuntimeException e) {
             // 记录日志并抛出或处理异常
@@ -1238,10 +1241,10 @@ public class StoreProductServiceImpl implements IStoreProductService {
                     .setParCateId(esDTO.getParCateId()).setParCateName(esDTO.getParCateName()).setProdPrice(esDTO.getProdPrice()).setStoreName(esDTO.getStoreName())
                     .setSeason(esDTO.getSeason()).setStyle(esDTO.getStyle()).setCreateTime(createTime);
             return new BulkOperation.Builder().create(d -> d.document(esProductDTO).id(String.valueOf(x.getId()))
-                    .index(Constants.ES_IDX_PRODUCT_INFO)).build();
+                    .index(ES_INDEX_NAME)).build();
         }).collect(Collectors.toList());
         // 调用bulk方法执行批量插入操作
-        BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+        BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
         System.out.println("bulkResponse.items() = " + bulkResponse.items());
     }
 
@@ -1421,12 +1424,12 @@ public class StoreProductServiceImpl implements IStoreProductService {
                                 put("prodStatus", prodStatus);
                             }}))
                             .id(String.valueOf(storeProdId))
-                            .index(Constants.ES_IDX_PRODUCT_INFO))
+                            .index(ES_INDEX_NAME))
                     .build());
         });
         try {
             // 调用bulk方法执行批量更新操作
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
             log.info("bulkResponse.result() = {}", bulkResponse.items());
         } catch (IOException | RuntimeException e) {
             // 记录日志并抛出或处理异常
diff --git a/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreServiceImpl.java b/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreServiceImpl.java
index 794ae9d20..d6add1018 100644
--- a/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreServiceImpl.java
+++ b/xkt/src/main/java/com/ruoyi/xkt/service/impl/StoreServiceImpl.java
@@ -34,6 +34,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -80,6 +81,8 @@ public class StoreServiceImpl implements IStoreService {
     final StoreCustomerMapper storeCusMapper;
     final StoreFactoryMapper storeFactoryMapper;
     final IStoreProductDemandTemplateService storeTemplateService;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     /**
      * 档口分页数据
@@ -445,9 +448,9 @@ public class StoreServiceImpl implements IStoreService {
 
     /**
      * 获取档口到期信息
-     *  1. 试用期 未购买 正式版 未购买会员   返回足额的正式版金额  足额会员金额
-     *  2. 正式使用  未购买会员 [正式使用 会员过期（未购买会员）]   返回足够的正式版金额 返回会员金额差价
-     *  3. 正式使用  已购买会员  返回足额的正式版会员 返回会员金额差价
+     * 1. 试用期 未购买 正式版 未购买会员   返回足额的正式版金额  足额会员金额
+     * 2. 正式使用  未购买会员 [正式使用 会员过期（未购买会员）]   返回足够的正式版金额 返回会员金额差价
+     * 3. 正式使用  已购买会员  返回足额的正式版会员 返回会员金额差价
      *
      * @param storeId 档口ID
      * @return StoreExpireResDTO
@@ -762,12 +765,12 @@ public class StoreServiceImpl implements IStoreService {
                                 put("storeWeight", storeWeight);
                             }}))
                             .id(String.valueOf(storeProd.getId()))
-                            .index(Constants.ES_IDX_PRODUCT_INFO))
+                            .index(ES_INDEX_NAME))
                     .build());
         });
         try {
             // 调用bulk方法执行批量更新操作
-            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(Constants.ES_IDX_PRODUCT_INFO).operations(list));
+            BulkResponse bulkResponse = esClientWrapper.getEsClient().bulk(e -> e.index(ES_INDEX_NAME).operations(list));
             log.info("bulkResponse.result() = {}", bulkResponse.items());
         } catch (IOException | RuntimeException e) {
             // 记录日志并抛出或处理异常
diff --git a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java
index 4f2a2347f..2dcae019e 100644
--- a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java
+++ b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java
@@ -44,6 +44,7 @@ import lombok.RequiredArgsConstructor;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -78,6 +79,8 @@ public class WebsiteAPPServiceImpl implements IWebsiteAPPService {
     final UserSubscriptionsMapper userSubMapper;
     final UserFavoritesMapper userFavMapper;
     final StoreMemberMapper storeMemberMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
 
     /**
      * APP 首页热卖精选列表
@@ -1119,7 +1122,7 @@ public class WebsiteAPPServiceImpl implements IWebsiteAPPService {
         Query query = new Query.Builder().bool(boolQuery.build()).build();
         // 执行搜索
         SearchResponse<ESProductDTO> resList = esClientWrapper.getEsClient()
-                .search(s -> s.index(Constants.ES_IDX_PRODUCT_INFO)
+                .search(s -> s.index(ES_INDEX_NAME)
                                 .query(query)
                                 .from((searchDTO.getPageNum() - 1) * searchDTO.getPageSize())
                                 .size(searchDTO.getPageSize())
diff --git a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsitePCServiceImpl.java b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsitePCServiceImpl.java
index 1a0ca2483..3f97defab 100644
--- a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsitePCServiceImpl.java
+++ b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsitePCServiceImpl.java
@@ -48,6 +48,7 @@ import lombok.RequiredArgsConstructor;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -86,6 +87,9 @@ public class WebsitePCServiceImpl implements IWebsitePCService {
     final IPictureService pictureService;
     final UserSubscriptionsMapper userSubsMapper;
     final SysProductCategoryMapper prodCateMapper;
+    @Value("${es.indexName}")
+    private String ES_INDEX_NAME;
+
 
     /**
      * PC 首页 为你推荐
@@ -916,7 +920,7 @@ public class WebsitePCServiceImpl implements IWebsitePCService {
         Query query = new Query.Builder().bool(boolQuery.build()).build();
         // 执行搜索
         SearchResponse<ESProductDTO> resList = esClientWrapper.getEsClient()
-                .search(s -> s.index(Constants.ES_IDX_PRODUCT_INFO)
+                .search(s -> s.index(ES_INDEX_NAME)
                                 .query(query)
                                 .from((searchDTO.getPageNum() - 1) * searchDTO.getPageSize())
                                 .size(searchDTO.getPageSize())