From 71f939168a7c5d15d8c9cece6df963dbd8556572 Mon Sep 17 00:00:00 2001
From: liuzhaotian <liu2655477224@163.com>
Date: Thu, 17 Apr 2025 16:25:45 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=BA=E5=B0=91=E6=96=B9=E6=B3=95=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../optimizeplan/OptimizePlanServiceImpl.java | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)

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) {