更新

src/main/java/com/juxin/client/websocket/FindTask.java

@@ -370,19 +370,22 @@ public class FindTask {
         Map<String, Object> req = new HashMap<>();
         req.put("recordId", jsonObject.get("groupId"));
         req.put("groupId", jsonObject.get("groupId"));
-        req.put("jobState", status[RandomUtil.randomInt(0, 6)]);
-        List<Map<String, String>> split = new ArrayList<>();
-        List<Map<String, String>> list = jsonObject.get("list", List.class);
-        list.forEach(e -> {
-            Map<String, String> map = new HashMap<>();
-            map.put("applicationid", IdUtil.fastSimpleUUID());
-            map.put("data", e.get("accountNo"));
-            map.put("searchAgency", Objects.toString(jsonObject.get("searchAgency")));
-            map.put("result", "0000");
-            map.put("accountSearchType", e.get("accountSearchType"));
-            split.add(map);
-        });
-        req.put("thirdSubjectSplits", split);
+        String jobState = status[RandomUtil.randomInt(0, 6)];
+        if (Objects.equals(jobState, "success")) {
+            req.put("jobState", jobState);
+            List<Map<String, String>> split = new ArrayList<>();
+            List<Map<String, String>> list = jsonObject.get("list", List.class);
+            list.forEach(e -> {
+                Map<String, String> map = new HashMap<>();
+                map.put("applicationid", IdUtil.fastSimpleUUID());
+                map.put("data", e.get("accountNo"));
+                map.put("searchAgency", Objects.toString(jsonObject.get("searchAgency")));
+                map.put("result", "0000");
+                map.put("accountSearchType", e.get("accountSearchType"));
+                split.add(map);
+            });
+            req.put("thirdSubjectSplits", split);
+        }
         result.put("reqJson", req);
         return JSONUtil.toJsonStr(result);
     }