From 3e8b76452f155f77c4ad934782af1973c8a5120a Mon Sep 17 00:00:00 2001 From: maojian <550076202@qq.com> Date: Tue, 3 Jun 2025 14:10:46 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=81=8D=E5=8E=86=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/bfd/function/entity/Constants.java | 2 ++ src/main/java/com/bfd/function/process/FunctionAchievePorcess.java | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/src/main/java/com/bfd/function/entity/Constants.java b/src/main/java/com/bfd/function/entity/Constants.java index 16be4d9..514866e 100644 --- a/src/main/java/com/bfd/function/entity/Constants.java +++ b/src/main/java/com/bfd/function/entity/Constants.java @@ -189,5 +189,7 @@ public class Constants { public static final String TRACE = "trace"; public static final String ISLAST = "isLast"; + public static final String LIST_SIZE = "list_size"; + public static final String DATA_SUBSCRIPT = "data_subscript"; public static final String IS_DIFFUSION = "is_diffusion"; } diff --git a/src/main/java/com/bfd/function/process/FunctionAchievePorcess.java b/src/main/java/com/bfd/function/process/FunctionAchievePorcess.java index a2c5710..734fcde 100644 --- a/src/main/java/com/bfd/function/process/FunctionAchievePorcess.java +++ b/src/main/java/com/bfd/function/process/FunctionAchievePorcess.java @@ -123,6 +123,10 @@ public class FunctionAchievePorcess implements Runnable { if (i == (fieldValues.size()-1)){ results.put(Constants.ISLAST, 1); } + //新增长度字段 + results.put(Constants.LIST_SIZE, fieldValues.size()); + //数据下标 + results.put(Constants.DATA_SUBSCRIPT, i); //遍历入库返回结果，拼接响应内容 result.put(Constants.RESULTS, JSONObject.toJSONString(results)); task.put(Constants.RESULT, result);