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);