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

@@ -370,7 +370,7 @@ public class FindTask {
         Map<String, Object> req = new HashMap<>();
         req.put("recordId", jsonObject.get("groupId"));
         req.put("groupId", jsonObject.get("groupId"));
-        req.put("jobState", "success");
+        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 -> {
@@ -416,7 +416,7 @@ public class FindTask {
             case "bankAllAccountResult":
                 result = bankAllAccountResultTask(reqJson);
                 break;
-            case "thirdSubjectResult":
+            case "thirdOwnerResult":
                 result = thirdSubjectResultTask(reqJson);
                 break;
             default:
@@ -566,6 +566,11 @@ public class FindTask {
         return JSONUtil.toJsonStr(result);
     }
 
+    /**
+     * 第三方主体 回捞结果 数据
+     * @param reqJson
+     * @return
+     */
    public String thirdSubjectResultTask(Object reqJson){
         String thirdSubjectResult="    {\n" +
                 "     \n" +
@@ -615,13 +620,15 @@ public class FindTask {
        Map<String, Object> result = new HashMap<>();
        result.put("infoType", "result");
        result.put("postType", "python");
-       result.put("methodType", "thirdSubjectResult");
+       result.put("methodType", "thirdOwnerResult");
        Map<String, Object> req = new HashMap<>();
        req.put("applicationId", param.get("applicationid"));
-       req.put("status", "机构已反馈");
+       req.put("accountSearchType",param.get("accountSearchType"));
+       req.put("status", SPLIT_RESULT[RandomUtil.randomInt(0, 10)]);
        req.put("valueCount", RandomUtil.randomInt(0, 10000));
        JSONObject thirdSubject=JSONUtil.parseObj(thirdSubjectResult);
        thirdSubject.put("applicationid", param.get("applicationid"));
+       thirdSubject.put("data",param.get("data"));
        req.put("thirdSubjectResult",thirdSubject);
        result.put("reqJson", req);