From d34bafba9846fd63d2baea225609ed35fb348301 Mon Sep 17 00:00:00 2001 From: lixiaolong <702156524@qq.com> Date: Mon, 15 Jun 2026 17:20:54 +0800 Subject: [PATCH] =?UTF-8?q?refactor(TeFlowiseController):=20=E4=BC=98?= =?UTF-8?q?=E5=8C=96flowise=E5=90=AF=E5=8A=A8=E5=8F=82=E6=95=B0=E6=9E=84?= =?UTF-8?q?=E5=BB=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 移除未使用的taskExecuteNormalVO对象初始化 - 重构runParams参数构建方式,使用更清晰的链式调用 - 确保TeTaskExecuteNormalVO通过builder模式正确构建并调用build()方法 - 保持原有的任务ID和终端ID设置逻辑不变 - 维持现有的任务实例停止功能 --- .../web/controller/test/TeFlowiseController.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/cmvr-iot-admin/src/main/java/com/cmvr/web/controller/test/TeFlowiseController.java b/cmvr-iot-admin/src/main/java/com/cmvr/web/controller/test/TeFlowiseController.java index 871492f..ef6f6b1 100644 --- a/cmvr-iot-admin/src/main/java/com/cmvr/web/controller/test/TeFlowiseController.java +++ b/cmvr-iot-admin/src/main/java/com/cmvr/web/controller/test/TeFlowiseController.java @@ -43,16 +43,16 @@ public class TeFlowiseController extends BaseController { @ApiOperation("调用flowise") @PostMapping("/start") public AjaxResult start(@RequestBody FlowiseStartRequestVO request) { - TeTaskExecuteNormalVO taskExecuteNormalVO = new TeTaskExecuteNormalVO(); - JSONObject runParams = new JSONObject(); - runParams.put("5bb26d52e1861c6936f3c3149eaf17e8", new JsonObject()); - runParams.getJSONObject("5bb26d52e1861c6936f3c3149eaf17e8").put("test", request.getQuestion()); - taskExecuteNormalVO.builder() + JSONObject runParams1 = new JSONObject(); + runParams1 + .put("test", request.getQuestion()); + runParams.put("5bb26d52e1861c6936f3c3149eaf17e8", runParams1); + TeTaskExecuteNormalVO taskExecuteNormalVO = TeTaskExecuteNormalVO.builder() .taskId("b6ab5ffff783d9b25d0dc34f13be222d") .terminalId("18749f257ff902643bc1ea6ab33f8b04") - .runParams(JSONObject.from(runParams)); + .runParams(JSONObject.from(runParams)).build(); if (!taskInstIdList.isEmpty()) { try { taskInstIdList.forEach(flowControlService::stop);