|
@@ -94,7 +94,7 @@ public class DataStaticAnalysisTotal extends Ops implements Runnable {
|
|
|
namesSet.add(alipayUsername);
|
|
|
}
|
|
|
//组装用户基本信息
|
|
|
- getDataAll(needToSaveall, origin, alipayIdsAll, newFileIdAll, dataMapUser);
|
|
|
+ getDataAll(needToSaveall, origin, alipayIdsAll, newFileIdAll, dataMapUser, idToData);
|
|
|
if (needToSaveall.size() >= 1000) {
|
|
|
List<DataMap> newDataList = new ArrayList<>();
|
|
|
for (DataMap map : needToSaveall) {
|
|
@@ -181,40 +181,44 @@ public class DataStaticAnalysisTotal extends Ops implements Runnable {
|
|
|
if ("财付通".equals(type)) {
|
|
|
//账户状态", "账号", "注册姓名", "注册时间", "注册身份证号", "绑定手机", "绑定状态", "开户行信息", "银行账号"
|
|
|
String dateFileId2 = getFileId(TenpayHeaders.getGeneratedName(3), modelId, mongoTemplate);
|
|
|
- List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
- Criteria.where("modelId")
|
|
|
- .is(modelId)
|
|
|
- .and("fileId")
|
|
|
- .is(dateFileId2)
|
|
|
- .and("账号")
|
|
|
- .is(account)
|
|
|
- .and("generated")
|
|
|
- .is(Boolean.TRUE))), DataMap.class);
|
|
|
- if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
- zjha = String.valueOf(dataMaps.get(0).get("注册身份证号"));
|
|
|
- bdyhkh = String.valueOf(dataMaps.get(0).get("银行账号"));
|
|
|
- khyhmc = String.valueOf(dataMaps.get(0).get("开户行信息"));
|
|
|
- bdsjh = String.valueOf(dataMaps.get(0).get("绑定手机"));
|
|
|
- zcsj = String.valueOf(dataMaps.get(0).get("注册时间"));
|
|
|
+ if (StringUtils.isNotBlank(dateFileId2)) {
|
|
|
+ List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
+ Criteria.where("modelId")
|
|
|
+ .is(modelId)
|
|
|
+ .and("fileId")
|
|
|
+ .is(dateFileId2)
|
|
|
+ .and("账号")
|
|
|
+ .is(account)
|
|
|
+ .and("generated")
|
|
|
+ .is(Boolean.TRUE))), DataMap.class);
|
|
|
+ if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
+ zjha = String.valueOf(dataMaps.get(0).get("注册身份证号"));
|
|
|
+ bdyhkh = String.valueOf(dataMaps.get(0).get("银行账号"));
|
|
|
+ khyhmc = String.valueOf(dataMaps.get(0).get("开户行信息"));
|
|
|
+ bdsjh = String.valueOf(dataMaps.get(0).get("绑定手机"));
|
|
|
+ zcsj = String.valueOf(dataMaps.get(0).get("注册时间"));
|
|
|
+ }
|
|
|
}
|
|
|
} else if ("五联单".equals(type)) {
|
|
|
// "用户ID", "登录邮箱", "登录手机", "账户名称", "证件类型", "证件号", "可用余额", "注册时间", "绑定手机", "绑定银行卡", "对应的协查数据"));
|
|
|
String dateFileId2 = getFileId(AlipayHeaders.getGeneratedName(2), modelId, mongoTemplate);
|
|
|
- List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
- Criteria.where("modelId")
|
|
|
- .is(modelId)
|
|
|
- .and("fileId")
|
|
|
- .is(dateFileId2)
|
|
|
- .and("用户ID")
|
|
|
- .is(account)
|
|
|
- .and("generated")
|
|
|
- .is(Boolean.TRUE))), DataMap.class);
|
|
|
- if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
- zjha = String.valueOf(dataMaps.get(0).get("证件号"));
|
|
|
- bdyhkh = String.valueOf(dataMaps.get(0).get("绑定银行卡"));
|
|
|
- khyhmc = String.valueOf(dataMaps.get(0).get("账户名称"));
|
|
|
- bdsjh = String.valueOf(dataMaps.get(0).get("登录手机"));
|
|
|
- zcsj = String.valueOf(dataMaps.get(0).get("注册时间"));
|
|
|
+ if (StringUtils.isNotBlank(dateFileId2)) {
|
|
|
+ List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
+ Criteria.where("modelId")
|
|
|
+ .is(modelId)
|
|
|
+ .and("fileId")
|
|
|
+ .is(dateFileId2)
|
|
|
+ .and("用户ID")
|
|
|
+ .is(account)
|
|
|
+ .and("generated")
|
|
|
+ .is(Boolean.TRUE))), DataMap.class);
|
|
|
+ if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
+ zjha = String.valueOf(dataMaps.get(0).get("证件号"));
|
|
|
+ bdyhkh = String.valueOf(dataMaps.get(0).get("绑定银行卡"));
|
|
|
+ khyhmc = String.valueOf(dataMaps.get(0).get("账户名称"));
|
|
|
+ bdsjh = String.valueOf(dataMaps.get(0).get("登录手机"));
|
|
|
+ zcsj = String.valueOf(dataMaps.get(0).get("注册时间"));
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
dataMap.put("证件号码", zjha);
|
|
@@ -224,7 +228,7 @@ public class DataStaticAnalysisTotal extends Ops implements Runnable {
|
|
|
dataMap.put("注册时间", zcsj);
|
|
|
}
|
|
|
|
|
|
- public void getDataAll(List<DataMap> needToSaveall, Document origin, Set<String> alipayIdsAll, String newFileIdAll, Map<String, Object> userMap) {
|
|
|
+ public void getDataAll(List<DataMap> needToSaveall, Document origin, Set<String> alipayIdsAll, String newFileIdAll, Map<String, Object> userMap, Map<String, DataMap> havedUser) {
|
|
|
String type = origin.getString("类型");
|
|
|
String account = String.valueOf(origin.getString("交易主体账号"));
|
|
|
String accounthm = String.valueOf(origin.getString("交易主体户名"));
|
|
@@ -258,39 +262,49 @@ public class DataStaticAnalysisTotal extends Ops implements Runnable {
|
|
|
return;
|
|
|
}
|
|
|
if ("财付通".equals(type)) {
|
|
|
+ List<DataMap> dataMaps = new ArrayList<>();
|
|
|
//账户状态", "账号", "注册姓名", "注册时间", "注册身份证号", "绑定手机", "绑定状态", "开户行信息", "银行账号"
|
|
|
- String dateFileId2 = getFileId(TenpayHeaders.getGeneratedName(3), modelId, mongoTemplate);
|
|
|
- List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
- Criteria.where("modelId")
|
|
|
- .is(modelId)
|
|
|
- .and("fileId")
|
|
|
- .is(dateFileId2)
|
|
|
- .and("账号")
|
|
|
- .in(accountList)
|
|
|
- .and("generated")
|
|
|
- .is(Boolean.TRUE))), DataMap.class);
|
|
|
- if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
- for (DataMap dataMap : dataMaps) {
|
|
|
- if (!alipayIdsAll.contains(String.valueOf(dataMap.get("账号")))) {
|
|
|
- DataMap newDataMap = new DataMap();
|
|
|
- newDataMap.put("fileId", newFileIdAll);
|
|
|
- newDataMap.put("证件号", String.valueOf(dataMap.get("注册身份证号")));
|
|
|
- newDataMap.put("账户名称", String.valueOf(dataMap.get("注册姓名")));
|
|
|
- newDataMap.put("账号", String.valueOf(dataMap.get("账号")));
|
|
|
- needToSaveall.add(newDataMap);
|
|
|
- alipayIdsAll.add(String.valueOf(dataMap.get("账号")));
|
|
|
+ if (CollectionUtils.isNotEmpty(accountList)) {
|
|
|
+ for (String s : accountList) {
|
|
|
+ DataMap dataMap = havedUser.get(s);
|
|
|
+ if (dataMap != null) {
|
|
|
+ dataMaps.add(dataMap);
|
|
|
+ } else {
|
|
|
+ String dateFileId2 = getFileId(TenpayHeaders.getGeneratedName(3), modelId, mongoTemplate);
|
|
|
+ if (StringUtils.isNotBlank(dateFileId2)) {
|
|
|
+ dataMaps = this.mongoTemplate.find((new Query(
|
|
|
+ Criteria.where("modelId")
|
|
|
+ .is(modelId)
|
|
|
+ .and("fileId")
|
|
|
+ .is(dateFileId2)
|
|
|
+ .and("账号")
|
|
|
+ .in(s))), DataMap.class);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
- } else {
|
|
|
- for (String s : accountList) {
|
|
|
- if (!alipayIdsAll.contains(s)) {
|
|
|
- DataMap newDataMap = new DataMap();
|
|
|
- newDataMap.put("fileId", newFileIdAll);
|
|
|
- newDataMap.put("证件号", "");
|
|
|
- newDataMap.put("账户名称", StringUtils.isBlank(String.valueOf(dataMaphm.get(s))) || "null".equals(String.valueOf(dataMaphm.get(s))) ? "" : String.valueOf(dataMaphm.get(s)));
|
|
|
- newDataMap.put("账号", s);
|
|
|
- needToSaveall.add(newDataMap);
|
|
|
- alipayIdsAll.add(s);
|
|
|
+ if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
+ for (DataMap dataMap : dataMaps) {
|
|
|
+ if (!alipayIdsAll.contains(String.valueOf(dataMap.get("账号")))) {
|
|
|
+ DataMap newDataMap = new DataMap();
|
|
|
+ newDataMap.put("fileId", newFileIdAll);
|
|
|
+ newDataMap.put("证件号", String.valueOf(dataMap.get("注册身份证号")));
|
|
|
+ newDataMap.put("账户名称", String.valueOf(dataMap.get("注册姓名")));
|
|
|
+ newDataMap.put("账号", String.valueOf(dataMap.get("账号")));
|
|
|
+ needToSaveall.add(newDataMap);
|
|
|
+ alipayIdsAll.add(String.valueOf(dataMap.get("账号")));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ for (String s : accountList) {
|
|
|
+ if (!alipayIdsAll.contains(s)) {
|
|
|
+ DataMap newDataMap = new DataMap();
|
|
|
+ newDataMap.put("fileId", newFileIdAll);
|
|
|
+ newDataMap.put("证件号", "");
|
|
|
+ newDataMap.put("账户名称", StringUtils.isBlank(String.valueOf(dataMaphm.get(s))) || "null".equals(String.valueOf(dataMaphm.get(s))) ? "" : String.valueOf(dataMaphm.get(s)));
|
|
|
+ newDataMap.put("账号", s);
|
|
|
+ needToSaveall.add(newDataMap);
|
|
|
+ alipayIdsAll.add(s);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -308,38 +322,49 @@ public class DataStaticAnalysisTotal extends Ops implements Runnable {
|
|
|
}
|
|
|
} else if ("五联单".equals(type)) {
|
|
|
// "用户ID", "登录邮箱", "登录手机", "账户名称", "证件类型", "证件号", "可用余额", "注册时间", "绑定手机", "绑定银行卡", "对应的协查数据"));
|
|
|
- String dateFileId2 = getFileId(AlipayHeaders.getGeneratedName(2), modelId, mongoTemplate);
|
|
|
- List<DataMap> dataMaps = this.mongoTemplate.find((new Query(
|
|
|
- Criteria.where("modelId")
|
|
|
- .is(modelId)
|
|
|
- .and("fileId")
|
|
|
- .is(dateFileId2)
|
|
|
- .and("用户ID")
|
|
|
- .in(accountList)
|
|
|
- .and("generated")
|
|
|
- .is(Boolean.TRUE))), DataMap.class);
|
|
|
- if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
- for (DataMap dataMap : dataMaps) {
|
|
|
- if (!alipayIdsAll.contains(String.valueOf(dataMap.get("用户ID")))) {
|
|
|
- DataMap newDataMap = new DataMap();
|
|
|
- newDataMap.put("fileId", newFileIdAll);
|
|
|
- newDataMap.put("证件号", String.valueOf(dataMap.get("证件号")));
|
|
|
- newDataMap.put("账户名称", String.valueOf(dataMap.get("账户名称")));
|
|
|
- newDataMap.put("账号", String.valueOf(dataMap.get("用户ID")));
|
|
|
- needToSaveall.add(newDataMap);
|
|
|
- alipayIdsAll.add(String.valueOf(dataMap.get("用户ID")));
|
|
|
+ List<DataMap> dataMaps = new ArrayList<>();
|
|
|
+ //账户状态", "账号", "注册姓名", "注册时间", "注册身份证号", "绑定手机", "绑定状态", "开户行信息", "银行账号"
|
|
|
+ if (CollectionUtils.isNotEmpty(accountList)) {
|
|
|
+ for (String s : accountList) {
|
|
|
+ DataMap dataMap = havedUser.get(s);
|
|
|
+ if (dataMap != null) {
|
|
|
+ dataMaps.add(dataMap);
|
|
|
+ } else {
|
|
|
+ String dateFileId2 = getFileId(AlipayHeaders.getGeneratedName(2), modelId, mongoTemplate);
|
|
|
+ if (StringUtils.isNotBlank(dateFileId2)) {
|
|
|
+ dataMaps = this.mongoTemplate.find((new Query(
|
|
|
+ Criteria.where("modelId")
|
|
|
+ .is(modelId)
|
|
|
+ .and("fileId")
|
|
|
+ .is(dateFileId2)
|
|
|
+ .and("用户ID")
|
|
|
+ .in(accountList))), DataMap.class);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
- } else {
|
|
|
- for (String s : accountList) {
|
|
|
- if (!alipayIdsAll.contains(s)) {
|
|
|
- DataMap newDataMap = new DataMap();
|
|
|
- newDataMap.put("fileId", newFileIdAll);
|
|
|
- newDataMap.put("证件号", "");
|
|
|
- newDataMap.put("账户名称", StringUtils.isBlank(String.valueOf(dataMaphm.get(s))) || "null".equals(String.valueOf(dataMaphm.get(s))) ? "" : String.valueOf(dataMaphm.get(s)));
|
|
|
- newDataMap.put("账号", s);
|
|
|
- needToSaveall.add(newDataMap);
|
|
|
- alipayIdsAll.add(s);
|
|
|
+ if (CollectionUtils.isNotEmpty(dataMaps)) {
|
|
|
+ for (DataMap dataMap : dataMaps) {
|
|
|
+ if (!alipayIdsAll.contains(String.valueOf(dataMap.get("用户ID")))) {
|
|
|
+ DataMap newDataMap = new DataMap();
|
|
|
+ newDataMap.put("fileId", newFileIdAll);
|
|
|
+ newDataMap.put("证件号", String.valueOf(dataMap.get("证件号")));
|
|
|
+ newDataMap.put("账户名称", String.valueOf(dataMap.get("账户名称")));
|
|
|
+ newDataMap.put("账号", String.valueOf(dataMap.get("用户ID")));
|
|
|
+ needToSaveall.add(newDataMap);
|
|
|
+ alipayIdsAll.add(String.valueOf(dataMap.get("用户ID")));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ for (String s : accountList) {
|
|
|
+ if (!alipayIdsAll.contains(s)) {
|
|
|
+ DataMap newDataMap = new DataMap();
|
|
|
+ newDataMap.put("fileId", newFileIdAll);
|
|
|
+ newDataMap.put("证件号", "");
|
|
|
+ newDataMap.put("账户名称", StringUtils.isBlank(String.valueOf(dataMaphm.get(s))) || "null".equals(String.valueOf(dataMaphm.get(s))) ? "" : String.valueOf(dataMaphm.get(s)));
|
|
|
+ newDataMap.put("账号", s);
|
|
|
+ needToSaveall.add(newDataMap);
|
|
|
+ alipayIdsAll.add(s);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|