|
|
|
@ -232,6 +232,7 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { |
|
|
|
List<WdpcGrjdZblx> zblxList = new ArrayList<>(); |
|
|
|
List<WdpcGrjdZblx> zblxList = new ArrayList<>(); |
|
|
|
LocalDateTime time = null; |
|
|
|
LocalDateTime time = null; |
|
|
|
StringBuilder sb = new StringBuilder(); |
|
|
|
StringBuilder sb = new StringBuilder(); |
|
|
|
|
|
|
|
int size = 0; |
|
|
|
for (GBaseWFRXX xx : wfxxList) { |
|
|
|
for (GBaseWFRXX xx : wfxxList) { |
|
|
|
WdpcGrjdZblx zblx = map.get(xx.getSxzmdm()); |
|
|
|
WdpcGrjdZblx zblx = map.get(xx.getSxzmdm()); |
|
|
|
if (zblx == null) { |
|
|
|
if (zblx == null) { |
|
|
|
@ -242,6 +243,7 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { |
|
|
|
continue; |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
|
sb.append(xx.getAjbh()).append(","); |
|
|
|
sb.append(xx.getAjbh()).append(","); |
|
|
|
|
|
|
|
size++; |
|
|
|
try { |
|
|
|
try { |
|
|
|
LocalDateTime tmp = xx.getLrsj().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime(); |
|
|
|
LocalDateTime tmp = xx.getLrsj().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime(); |
|
|
|
if(time == null) { |
|
|
|
if(time == null) { |
|
|
|
@ -273,7 +275,7 @@ public class GBaseSHRWFRServiceImpl implements GBaseSHRWFRService { |
|
|
|
.tags(tags) |
|
|
|
.tags(tags) |
|
|
|
.score(Math.min(5, score)) |
|
|
|
.score(Math.min(5, score)) |
|
|
|
.personId(person.getId()) |
|
|
|
.personId(person.getId()) |
|
|
|
.sourceData("发现该人员存在" + zblxList.size() + "起刑事处罚罪名:" + zm.substring(0, zm.length() - 1) + ",案件编号为:" + sb.substring(0, sb.length() - 1)) |
|
|
|
.sourceData("发现该人员存在" + size + "起刑事处罚,关键罪名有:" + zm.substring(0, zm.length() - 1) + ",案件编号分别为:" + sb.substring(0, sb.length() - 1)) |
|
|
|
.eventTime(time) |
|
|
|
.eventTime(time) |
|
|
|
.build(); |
|
|
|
.build(); |
|
|
|
toInsert.add(DataUtil.createClueData(task, data)); |
|
|
|
toInsert.add(DataUtil.createClueData(task, data)); |
|
|
|
|