|
@@ -99,7 +99,7 @@ public class DataStaticService extends Ops {
|
|
|
|
|
|
public Mapped staticModel(StaticModelInput staticModelInput) {
|
|
public Mapped staticModel(StaticModelInput staticModelInput) {
|
|
long startTime = System.currentTimeMillis();
|
|
long startTime = System.currentTimeMillis();
|
|
- log.error("开始执行");
|
|
|
|
|
|
+ log.info("开始执行");
|
|
String modelId = staticModelInput.getModelId();
|
|
String modelId = staticModelInput.getModelId();
|
|
String dateFileId = getFileId("数据分析-主体信息汇总明细", modelId, mongoTemplate);
|
|
String dateFileId = getFileId("数据分析-主体信息汇总明细", modelId, mongoTemplate);
|
|
String dateFileIdUser = getFileId("数据分析-所有主体信息汇总", modelId, mongoTemplate);
|
|
String dateFileIdUser = getFileId("数据分析-所有主体信息汇总", modelId, mongoTemplate);
|
|
@@ -109,7 +109,7 @@ public class DataStaticService extends Ops {
|
|
return Mapped.ERROR("数据分析-主体信息汇总明细不存在");
|
|
return Mapped.ERROR("数据分析-主体信息汇总明细不存在");
|
|
}
|
|
}
|
|
long a = System.currentTimeMillis();
|
|
long a = System.currentTimeMillis();
|
|
- log.error("查询所需的数据" + (a - startTime));
|
|
|
|
|
|
+ log.info("查询所需的数据" + (a - startTime));
|
|
if (StringUtils.isBlank(dateFileIdUser)) {
|
|
if (StringUtils.isBlank(dateFileIdUser)) {
|
|
return Mapped.ERROR("数据分析-所有主体信息汇总");
|
|
return Mapped.ERROR("数据分析-所有主体信息汇总");
|
|
}
|
|
}
|
|
@@ -141,7 +141,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
long b = System.currentTimeMillis();
|
|
long b = System.currentTimeMillis();
|
|
- log.error("循环交易主体账号所需时间" + (b - a));
|
|
|
|
|
|
+ log.info("循环交易主体账号所需时间" + (b - a));
|
|
//查询所有的主体信息汇总
|
|
//查询所有的主体信息汇总
|
|
List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
Criteria.where("fileId")
|
|
Criteria.where("fileId")
|
|
@@ -158,7 +158,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
long c = System.currentTimeMillis();
|
|
long c = System.currentTimeMillis();
|
|
- log.error("循环交易对手账号所需时间" + (c - b));
|
|
|
|
|
|
+ log.info("循环交易对手账号所需时间" + (c - b));
|
|
//分两种情况,1:主体是否有数据如果有就按交易主体的计算
|
|
//分两种情况,1:主体是否有数据如果有就按交易主体的计算
|
|
|
|
|
|
Query query = new Query();
|
|
Query query = new Query();
|
|
@@ -232,7 +232,7 @@ public class DataStaticService extends Ops {
|
|
.cursor();
|
|
.cursor();
|
|
|
|
|
|
long d = System.currentTimeMillis();
|
|
long d = System.currentTimeMillis();
|
|
- log.error("查询所有数据所需时间" + (d - c));
|
|
|
|
|
|
+ log.info("查询所有数据所需时间" + (d - c));
|
|
//先去判断从是否有大于2的数据
|
|
//先去判断从是否有大于2的数据
|
|
Document originDoc;
|
|
Document originDoc;
|
|
Map<String, List<DataMap>> dsMap = new HashMap<>();
|
|
Map<String, List<DataMap>> dsMap = new HashMap<>();
|
|
@@ -260,7 +260,7 @@ public class DataStaticService extends Ops {
|
|
dataMaps1.add(map);
|
|
dataMaps1.add(map);
|
|
dsMap.put(jydszh, dataMaps1);
|
|
dsMap.put(jydszh, dataMaps1);
|
|
} catch (Exception exception) {
|
|
} catch (Exception exception) {
|
|
- log.error(exception.getMessage(), exception);
|
|
|
|
|
|
+ log.info(exception.getMessage(), exception);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -288,7 +288,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
|
|
|
|
long e = System.currentTimeMillis();
|
|
long e = System.currentTimeMillis();
|
|
- log.error("获取所有对手的交易主体账号所需时间" + (e-d));
|
|
|
|
|
|
+ log.info("获取所有对手的交易主体账号所需时间" + (e-d));
|
|
List<DataMap> newList = Lists.newArrayList();
|
|
List<DataMap> newList = Lists.newArrayList();
|
|
for (Map.Entry<String, Set<String>> entry : zh.entrySet()) {
|
|
for (Map.Entry<String, Set<String>> entry : zh.entrySet()) {
|
|
if (entry.getValue().size() >= staticModelInput.getStartNum() && entry.getValue().size() <= staticModelInput.getEndNum()) {
|
|
if (entry.getValue().size() >= staticModelInput.getStartNum() && entry.getValue().size() <= staticModelInput.getEndNum()) {
|
|
@@ -297,7 +297,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
long f = System.currentTimeMillis();
|
|
long f = System.currentTimeMillis();
|
|
- log.error("获取大于2的数据所需时间" + (f-e));
|
|
|
|
|
|
+ log.info("获取大于2的数据所需时间" + (f-e));
|
|
List<String> userList = new ArrayList<>();
|
|
List<String> userList = new ArrayList<>();
|
|
List<String> usermcList = new ArrayList<>();
|
|
List<String> usermcList = new ArrayList<>();
|
|
List<String> userAllList = new ArrayList<>();
|
|
List<String> userAllList = new ArrayList<>();
|
|
@@ -314,7 +314,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
String jdlx = String.valueOf(map.get("借贷类型"));
|
|
String jdlx = String.valueOf(map.get("借贷类型"));
|
|
if (!jdlx.equals("借") && !jdlx.equals("贷")) {
|
|
if (!jdlx.equals("借") && !jdlx.equals("贷")) {
|
|
- log.error("借贷类型有误");
|
|
|
|
|
|
+ log.info("借贷类型有误");
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -444,7 +444,7 @@ public class DataStaticService extends Ops {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
long g = System.currentTimeMillis();
|
|
long g = System.currentTimeMillis();
|
|
- log.error("获取所有的点和线的数据所需时间" + (g-f));
|
|
|
|
|
|
+ log.info("获取所有的点和线的数据所需时间" + (g-f));
|
|
for (Map<String, Object> stringObjectMap : relationshipGraphList) {
|
|
for (Map<String, Object> stringObjectMap : relationshipGraphList) {
|
|
Map<String, Object> party1 = (Map) stringObjectMap.get("party1");
|
|
Map<String, Object> party1 = (Map) stringObjectMap.get("party1");
|
|
Map<String, Object> party2 = (Map) stringObjectMap.get("party2");
|
|
Map<String, Object> party2 = (Map) stringObjectMap.get("party2");
|
|
@@ -467,8 +467,8 @@ public class DataStaticService extends Ops {
|
|
|
|
|
|
}
|
|
}
|
|
long h = System.currentTimeMillis();
|
|
long h = System.currentTimeMillis();
|
|
- log.error("判断线是否为双向箭头数据所需时间" + (h-g));
|
|
|
|
- log.error("网络关系图所需要的时间" + (h-startTime));
|
|
|
|
|
|
+ log.info("判断线是否为双向箭头数据所需时间" + (h-g));
|
|
|
|
+ log.info("网络关系图所需要的时间" + (h-startTime));
|
|
/* List<Map<String, Object>> partyDataListnew = new ArrayList<>();
|
|
/* List<Map<String, Object>> partyDataListnew = new ArrayList<>();
|
|
for (Map<String, Object> stringObjectMap : partyDataList) {
|
|
for (Map<String, Object> stringObjectMap : partyDataList) {
|
|
String id =String.valueOf(stringObjectMap.get("id"));
|
|
String id =String.valueOf(stringObjectMap.get("id"));
|