缺少方法增加

2026-08-12 21:02:08 +08:00 · 2025-04-17 16:25:45 +08:00
parent 7c7e56ad33
commit 71f939168a
1 changed files with 40 additions and 0 deletions
@@ -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) {