From 449db9bb6318f41f596c73dcf5fd82c302f000c8 Mon Sep 17 00:00:00 2001 From: sjh Date: Mon, 16 Dec 2024 16:35:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=89=80=E6=9C=89=E4=B8=AA?= =?UTF-8?q?=E4=BA=BA=E6=9E=81=E7=AB=AF=E6=A8=A1=E5=9E=8B=E7=9A=84=E7=94=9F?= =?UTF-8?q?=E6=88=90=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/PointServiceImpl.java | 161 +++++++++++------- 1 file changed, 96 insertions(+), 65 deletions(-) diff --git a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java index c4d1cc4..4b0ab0e 100644 --- a/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java +++ b/src/main/java/com/biutag/supervisiondata/service/impl/PointServiceImpl.java @@ -357,12 +357,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("受到行政处罚") + .tags(List.of("受到" + wfrwfxxList.size() + "个行政处罚")) + .score(score) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员涉及" + wfrwfxxList.size() + "个行政处罚，案件编号为：“" + context + "”") .build(); - toInsert.add(createClue(task.getModelId(), score, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.ADMINISTRATIVEPUNISHMENT); @@ -405,12 +406,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("受到刑事处罚") + .tags(List.of("受到" + wfrwfxxList.size() + "个刑事处罚")) + .score(score) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员涉及" + wfrwfxxList.size() + "个刑事案件，案件编号为：“" + context + "”") .build(); - toInsert.add(createClue(task.getModelId(), score, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.CRIMINALPUNISHMENT); @@ -447,12 +449,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("父母婚姻变故") + .tags(List.of("父母离婚")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员父母离婚") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.PARENTSDIVORCE); @@ -509,12 +512,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("父亲是否健在") + .tags(List.of("父亲死亡")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员父亲死亡") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FATHERDIE); @@ -571,12 +575,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("母亲是否健在") + .tags(List.of("母亲死亡")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员母亲死亡") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.MOTHERDIE); @@ -624,12 +629,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("家人患严重疾病") + .tags(List.of("家人患严重疾病")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员的家人有重大疾病") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FAMILYSERIOUSILLNESS); @@ -666,12 +672,13 @@ public class PointServiceImpl implements PointService { .name(person.getName()) .id(person.getId().toString()) .idCode(person.getIdCode()) - .tag("本人患严重疾病") + .tags(List.of("患严重疾病")) + .score(5) .eventTime(LocalDateTime.now()) .personId(person.getId()) .sourceData("发现该人员有过就诊记录，诊断病名为“" + idMap.get(person.getIdCode()).getDiseaseName() + "”，该人员患严重疾病") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.SERIOUSILLNESS); @@ -695,7 +702,6 @@ public class PointServiceImpl implements PointService { log.info("模型129开始查询"); List list1 = jsbryRepository.getBaseMapper().selectByIdNos(); List list2 = jZJLBRepository.getBaseMapper().selectForModel129(); - ; List list3 = xdryRepository.getBaseMapper().selectXIDU(); List list4 = sqjzryRepository.getBaseMapper().selectByIdNos(); List list5 = xmsfryRepository.getBaseMapper().selectByIdNos(); @@ -714,12 +720,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("是否特殊人群") + .tags(List.of("特殊人群")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为精神障碍患者，是特殊人群") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcJZJLB domicileType : list2) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -733,12 +740,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("是否特殊人群") + .tags(List.of("特殊人群")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为艾滋人员，是特殊人群") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXdry domicileType : list3) { RiskPersonal personal = personalMap.get(domicileType.getSfzh()); @@ -752,12 +760,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("是否特殊人群") + .tags(List.of("特殊人群")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为吸毒人员，是特殊人群") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcSqjzry domicileType : list4) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -771,12 +780,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("是否特殊人群") + .tags(List.of("特殊人群")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为社区矫正人员，是特殊人群") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXmsfry domicileType : list5) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -790,12 +800,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("是否特殊人群") + .tags(List.of("特殊人群")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为刑释解教人员，是特殊人群") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.ISSPECIALPEOPLE); @@ -838,13 +849,14 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("特殊人群类型") + .tags(List.of("精神障碍患者")) + .score(1) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员于" + getDateString(domicileType.getActualTime()) + "确诊为为“" + domicileType.getActualId() + "”精神障碍患者") .build(); - toInsert.add(createClue(task.getModelId(), 1, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcJZJLB domicileType : list2) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -858,12 +870,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("特殊人群类型") + .tags(List.of("艾滋人员")) + .score(2) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为艾滋人员") .build(); - toInsert.add(createClue(task.getModelId(), 2, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXdry domicileType : list3) { RiskPersonal personal = personalMap.get(domicileType.getSfzh()); @@ -877,12 +890,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("特殊人群类型") + .tags(List.of("吸毒人员")) + .score(3) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为吸毒人员") .build(); - toInsert.add(createClue(task.getModelId(), 3, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcSqjzry domicileType : list4) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -912,12 +926,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("特殊人群类型") + .tags(List.of("社区矫正人员")) + .score(4) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为社区矫正人员" + context) .build(); - toInsert.add(createClue(task.getModelId(), 4, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXmsfry domicileType : list5) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -947,12 +962,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("特殊人群类型") + .tags(List.of("刑释解教人员")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为刑释解教人员" + context) .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.SPECIALPEOPLETYPE); @@ -1002,14 +1018,15 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("精神疾病患者驾照未注销") + .tags(List.of("未注销驾照的精神疾病患者")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员为精神疾病患者，但驾照未注销" + context + "，驾照有效期为“" + getDateString(domicileType.getYxqs()) + "至" + getDateString(domicileType.getYxqz()) + "”") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.MENTALDISEASEDRIVER); @@ -1048,12 +1065,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("父母关系状况") + .tags(List.of("父母关系不佳")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员父母关系状况不佳，关联接警单单号为" + domicileType.get("jjdbh")) .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.PARENTSRELATIONSHIP); @@ -1112,12 +1130,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("吸食毒品") + .tags(List.of("吸毒")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员吸食毒品" + dataString) .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.DRUG); @@ -1152,12 +1171,13 @@ public class PointServiceImpl implements PointService { .name(person.getName()) .id(person.getId().toString()) .idCode(person.getIdCode()) - .tag("医疗压力") + .tags(List.of("有医疗压力")) + .score(5) .eventTime(LocalDateTime.now()) .personId(person.getId()) .sourceData("发现该人员近三年没有医保缴纳信息，存在医疗压力") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.MEDICALPRESSURE); @@ -1196,14 +1216,15 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("上访诉求内容") + .tags(List.of("上访" + domicileType.getCountNum() + "次")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员上访过" + domicileType.getCountNum() + "次，上访内容为" + domicileType.getDetail() + "，为涉退、涉迁、涉军等重点管控群体") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXfsjCsDetail domicileType : list3) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -1216,14 +1237,15 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("上访诉求内容") + .tags(List.of("上访" + domicileType.getCountNum() + "次")) + .score(3) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员上访过" + domicileType.getCountNum() + "次，上访内容为" + domicileType.getDetail() + "，为投诉、举报等诉求") .build(); - toInsert.add(createClue(task.getModelId(), 3, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } for (WdpcXfsjCsDetail domicileType : list2) { RiskPersonal personal = personalMap.get(domicileType.getIdCode()); @@ -1236,14 +1258,15 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("上访诉求内容") + .tags(List.of("上访" + domicileType.getCountNum() + "次")) + .score(2) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员上访过" + domicileType.getCountNum() + "次，上访内容为" + domicileType.getDetail() + "，为待遇不公、房屋交房等诉求") .build(); - toInsert.add(createClue(task.getModelId(), 2, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.PETITIONCONTENT); @@ -1287,13 +1310,14 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("与子女关系") + .tags(List.of("与子女关系不和")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员于" + getDateMinuteString(domicileType.getBjsj()) + "报警，关联接警单单号" + domicileType.getJjdbh() + content) .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FILIATION); @@ -1341,12 +1365,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("行为人子女数") + .tags(List.of(domicileType.getScore() + "个子女")) + .score(realScore) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员子女数为" + domicileType.getScore()) .build(); - toInsert.add(createClue(task.getModelId(), realScore, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.CHILDNO); @@ -1403,12 +1428,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("亲近家人死亡") + .tags(List.of("亲近家人死亡")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员亲近家人死亡") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FAMILYDIE); @@ -1450,12 +1476,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("户籍类型") + .tags(List.of("非城镇户籍")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员户籍类型为" + domicileType.getHlxmc()) .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.DOMICILETYPE); @@ -1492,12 +1519,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("父亲文化程度") + .tags(List.of("父亲文化程度低")) + .score(eduScore) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员父亲文化程度为" + fatherEducation.getFatherEducation()) .build(); - toInsert.add(createClue(task.getModelId(), eduScore, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.FATHER_EDUCATION); @@ -1534,12 +1562,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("母亲文化程度") + .tags(List.of("母亲文化程度低")) + .score(eduScore) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员母亲文化程度为" + motherEducation.getMotherEducation()) .build(); - toInsert.add(createClue(task.getModelId(), eduScore, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.MOTHER_EDUCATION); @@ -1596,12 +1625,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("上访是否满意解决") + .tags(List.of("上访未满意解决")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员有过上访经历，且上访没有满意解决") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.PETITIONDISSATISFIED); @@ -1639,12 +1669,13 @@ public class PointServiceImpl implements PointService { .name(personal.getName()) .id(personal.getId().toString()) .idCode(personal.getIdCode()) - .tag("上访人员") + .tags(List.of("有上访经历")) + .score(5) .eventTime(LocalDateTime.now()) .personId(personal.getId()) .sourceData("发现该人员有过上访经历") .build(); - toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); + toInsert.add(DataUtil.createClueData(task, data)); } if (!toInsert.isEmpty()) { modelTaskClueService.saveClues(toInsert, Default.IS_PETITION);