refactor(TeFlowiseController): 优化flowise启动参数构建逻辑

- 移除未使用的taskExecuteNormalVO对象初始化
- 重构runParams参数构建方式,使用更清晰的链式调用
- 确保TeTaskExecuteNormalVO通过builder模式正确构建并调用build()方法
- 保持原有的任务ID和终端ID设置逻辑不变
- 维持现有的任务实例停止功能
This commit is contained in:
lixiaolong 2026-06-15 17:20:54 +08:00
parent b17ade54a1
commit d34bafba98

View File

@ -43,16 +43,16 @@ public class TeFlowiseController extends BaseController {
@ApiOperation("调用flowise") @ApiOperation("调用flowise")
@PostMapping("/start") @PostMapping("/start")
public AjaxResult start(@RequestBody FlowiseStartRequestVO request) { public AjaxResult start(@RequestBody FlowiseStartRequestVO request) {
TeTaskExecuteNormalVO taskExecuteNormalVO = new TeTaskExecuteNormalVO();
JSONObject runParams = new JSONObject(); 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") .taskId("b6ab5ffff783d9b25d0dc34f13be222d")
.terminalId("18749f257ff902643bc1ea6ab33f8b04") .terminalId("18749f257ff902643bc1ea6ab33f8b04")
.runParams(JSONObject.from(runParams)); .runParams(JSONObject.from(runParams)).build();
if (!taskInstIdList.isEmpty()) { if (!taskInstIdList.isEmpty()) {
try { try {
taskInstIdList.forEach(flowControlService::stop); taskInstIdList.forEach(flowControlService::stop);