diff --git a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/optimizeplan/OptimizePlanServiceImpl.java b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/optimizeplan/OptimizePlanServiceImpl.java
index c28a76d6c..37bc1e372 100644
--- a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/optimizeplan/OptimizePlanServiceImpl.java
+++ b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/optimizeplan/OptimizePlanServiceImpl.java
@@ -1160,6 +1160,46 @@ public class OptimizePlanServiceImpl implements OptimizePlanService {
 
 
 
+    @Override
+    public void updateProcessSchemeConfig(PlanSchemeConfigReqVO reqVO) {
+
+
+        try {
+
+            UpdateByQueryRequest.Builder builder = new UpdateByQueryRequest.Builder();
+
+            builder.index(PLAN_PROCESS_SCHEME_CONFIG)
+                    .query(qb -> qb.bool(bq -> bq
+                            .must(mq -> mq.term(t->t.field(FIELD_PLAN_ID).value(reqVO.getPlanId())))
+                            .must(mq -> mq.match(mtq -> mtq.field(FIELD_PLAN_CONFIG_ID).query(reqVO.getPlanConfigId())))
+                    ))
+                    .script(s -> s.inline(i -> i
+                            .source("""
+                                ctx._source.processLineConfig = params.processLineConfig;
+                                ctx._source.optimizationConfig = params.optimizationConfig;
+                                ctx._source.analyzer = params.analyzer;
+                                """)
+                            .params("processLineConfig", JsonData.of(reqVO.getProcessLineConfig()))
+                            .params("optimizationConfig", JsonData.of(reqVO.getOptimizationConfig()))
+                            .params("analyzer", JsonData.of(reqVO.getAnalyzer()))
+                    ));
+
+            UpdateByQueryRequest request = builder.build();
+
+            // 执行更新操作
+            elasticsearchClient.updateByQuery(request);
+
+        }catch (Exception e){
+            log.error(e.getMessage());
+            throw new ServiceException(ES_DATA_ERROR);
+
+        }
+
+    }
+
+
+
+
     @Override
     public PageResult<OrderGoodsResp> getGoodsPlateDataFilter(FilterDataPageReqVO pageReqVO) {