SmartBench/CMVR-IOT
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 获取当前循环对象和下标

Browse Source
This commit is contained in:
stream 2026-03-18 09:23:16 +08:00
parent 264eb3e5ad
commit 596d8ceb29
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cmvr-iot-test/src/main/java/com/cmvr/test/flow/runtime/dispatcher/FlowGetCurrentObjNodeHandler.java
View File

@ -19,16 +19,17 @@ public class FlowGetCurrentObjNodeHandler implements FlowNodeTypeHandler {
public TaskNodeExecuteResult handle(TaskNodeExecuteMessage message) { public TaskNodeExecuteResult handle(TaskNodeExecuteMessage message) {
try { try {
JSONObject inputParams = message.getInputParams(); JSONObject inputParams = message.getInputParams();
JSONArray jsonArray = inputParams.getJSONArray("array"); JSONArray jsonArray = inputParams.getJSONArray("array");
List<Integer> iterations = message.getIterations(); List<Integer> iterations = message.getIterations();
int last = CollUtil.getLast(iterations) - 1; int last = CollUtil.getLast(iterations) - 1;
Object o = jsonArray.get(last);
JSONObject output = new JSONObject(); JSONObject output = new JSONObject();
output.put("index", last); output.put("index", last);
output.put("object", o);
if (CollUtil.isNotEmpty(jsonArray) && last >= 0) {
output.put("object", jsonArray.get(last));
}
return TaskNodeExecuteResult.success(output); return TaskNodeExecuteResult.success(output);