网络关系-线上数据明细

src/main/java/ieven/server/webapp/api/AlipayController.java

@@ -3,10 +3,12 @@ package ieven.server.webapp.api;
 import com.mongodb.client.MongoCursor;
 import ieven.server.webapp.domain.LineInput;
 import ieven.server.webapp.domain.ModelIdInput;
+import ieven.server.webapp.domain.StaticPageInput;
 import ieven.server.webapp.domain.alipay.TFromToFileIds;
 import ieven.server.webapp.domain.data.DataMap;
 import ieven.server.webapp.domain.data.DataService;
 import ieven.server.webapp.domain.data.Fields;
+import ieven.server.webapp.domain.data.StaticInput;
 import ieven.server.webapp.domain.exporter.Exporter;
 import ieven.server.webapp.domain.model.Model;
 import ieven.server.webapp.infrastructure.wrapper.Mapped;
@@ -93,6 +95,53 @@ public class AlipayController {
         }
     }
 
+    @PostMapping({"/staticDetailContent"})
+    public Mapped staticDetailContent(@RequestBody StaticPageInput input) {
+        String modelId = input.getModelId();
+        if (modelId == null) {
+            return Mapped.ERROR("没有选择模型!");
+        } else {
+            String fileId = input.getFileId();
+            String jythm = input.getJythm();
+            String jydszh = input.getJydszh();
+            int page = input.getPage();
+            int pageSize = input.getPageSize();
+            int skip = (page - 1) * pageSize;
+
+            Criteria criteria = Criteria.where("fileId")
+                    .is(fileId)
+                    .and("交易主体户名")
+                    .is(jythm)
+                    .and("交易对手账号")
+                    .is(jydszh);
+            if (criteria == null) {
+                return Mapped.ERROR("未查询到明细");
+            } else {
+                Future<Long> totalFuture = this.dataService.countTotalByQuery(new Query(criteria));
+
+                List<DataMap>  dataMaps =
+                        this.mongoTemplate.find(
+                                (new Query(criteria)).skip(skip).limit(pageSize), DataMap.class);
+                Long total;
+
+                try {
+                    total = totalFuture.get();
+                } catch (ExecutionException | InterruptedException var15) {
+                    var15.printStackTrace();
+                    return Mapped.ERROR("系统查询出错");
+                }
+                Mapped mapped = Mapped.OK();
+                mapped.put("result", dataMaps);
+                mapped.put("code", 200);
+                mapped.put("page", page);
+                mapped.put("total", total);
+                mapped.put("fileId", fileId);
+                mapped.put("pageSize", pageSize);
+                return mapped;
+            }
+        }
+    }
+
     @PostMapping({"/viewDetailHeaders"})
     public Mapped viewHeaders(@RequestBody LineInput input) {
         String modelId = input.getModelId();

src/main/java/ieven/server/webapp/domain/StaticPageInput.java

@@ -0,0 +1,13 @@
+package ieven.server.webapp.domain;
+
+import lombok.Data;
+
+@Data
+public class StaticPageInput {
+    private String modelId;
+    private String fileId;
+    private String jythm;
+    private String jydszh;
+    private Integer page;
+    private Integer pageSize;
+}

src/main/java/ieven/server/webapp/service/datastatic/DataStaticService.java

@@ -166,6 +166,7 @@ public class DataStaticService extends Ops {
 
         List<Map<String, Object>> partyDataList = new ArrayList<>();
         List<Map<String, Object>> relationshipGraphList = new ArrayList<>();
+        List<Map<String, Object>> relationshipGraphListnew = new ArrayList<>();
         List<DataMap> dataMapDetail = this.mongoTemplate.find(query, DataMap.class);
 
         List<String> userList = new ArrayList<>();
@@ -230,7 +231,8 @@ public class DataStaticService extends Ops {
                     userAllId = one + "-" + two;
                 }
 
-            } else if (jdlx.equals("贷")) {
+            }
+            else if (jdlx.equals("贷")) {
                 List<DataMap> dataMaps1 = personzhmcMap.get(jythm);
                 List<DataMap> dataMaps2 = personMap.get(jydszh);
                 if(CollectionUtils.isNotEmpty(dataMaps1)&&CollectionUtils.isNotEmpty(dataMaps2)){
@@ -259,19 +261,46 @@ public class DataStaticService extends Ops {
                     String jyje = String.valueOf(dataMap1.get("交易金额"));
                     sum.add(new BigDecimal(jyje));
                 }
-
+                relationData.put("modelId",modelId);
+                relationData.put("fileId",dateFileId);
+                relationData.put("jythm",jythm);
+                relationData.put("jydszh",jydszh);
                 relationData.put("jeTotal", sum);
                 relationData.put("sum", dataDetailList.size());
                 total.put("party1", party1);
                 total.put("party2", party2);
                 total.put("relationData", relationData);
-                total.put("relationships", dataDetailList);
+                total.put("userAllId", userAllId);
+                //total.put("relationships", dataDetailList);
                 relationshipGraphList.add(total);
                 userAllList.add(userAllId);
             }
         }
+
+        for (Map<String, Object> stringObjectMap : relationshipGraphList) {
+            Map<String, Object> party1 = (Map) stringObjectMap.get("party1");
+            Map<String, Object> party2 = (Map) stringObjectMap.get("party2");
+            String name1 = String.valueOf(party1.get("name"));
+            String name2 = String.valueOf(party2.get("name"));
+            String value1=name2+"-"+name1;
+            stringObjectMap.put("type",1);
+            for (Map<String, Object> objectMap : relationshipGraphList) {
+                Map<String, Object> party11 = (Map) objectMap.get("party1");
+                Map<String, Object> party21 = (Map) objectMap.get("party2");
+                String name11 = String.valueOf(party11.get("name"));
+                String name21 = String.valueOf(party21.get("name"));
+                String value11=name11+"-"+name21;
+                if(value1.equals(value11)){
+                    stringObjectMap.put("type",2);
+                    continue;
+                }
+            }
+            relationshipGraphListnew.add(stringObjectMap);
+
+        }
+
         dataMap.put("partyData", partyDataList);
-        dataMap.put("relationshipGraph", relationshipGraphList);
+        dataMap.put("relationshipGraph", relationshipGraphListnew);
         Mapped mapped = Mapped.OK();
         if(partyDataList.size()>300){
             return Mapped.ERROR("节点超过300个,请重新查询");