supervision
/
supervision-data
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

修改人员标签和风险项的入库逻辑

master
kami 1 year ago
parent
4730dfee27
commit
645da443d6
2 changed files with 19 additions and 21 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 30
      src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
  2. 10
      src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java

30
src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
Unescape View File

@ -112,7 +112,7 @@ public class ApplicationEvent {
// riskPersonalService.fixed(); // riskPersonalService.fixed();
// personalService.syncPerson(LocalDate.now()); // personalService.syncPerson(LocalDate.now());
// 32，33，34，39，41，51，53，43，63 // 32，33，34，39，41，51，53，43，63
// 36 60 61 62 44 45 48 52 59 // 36 60 61 62 44 45 48 52 59 64
// petitionService.petitionModelTask(initDomain(List.of(40))); // petitionService.petitionModelTask(initDomain(List.of(40)));
// riskTaskService.eduAndAreaModelTask(initDomain(List.of(34,41))); // riskTaskService.eduAndAreaModelTask(initDomain(List.of(34,41)));
// riskTaskService.infoModelTask(initDomain(List.of(32,33))); // riskTaskService.infoModelTask(initDomain(List.of(32,33)));
@ -129,7 +129,7 @@ public class ApplicationEvent {
// gBaseJJDService.pullPoliceInstance(LocalDateTime.of(2023, 12, 6, 0, 0, 0), end, initDomain(List.of(55,56,57,58))); // gBaseJJDService.pullPoliceInstance(LocalDateTime.of(2023, 12, 6, 0, 0, 0), end, initDomain(List.of(55,56,57,58)));
jsbryService.syncPys(initDomain(List.of(59))); jsbryService.syncPys(initDomain(List.of(59)));
// gBaseSHRWFRService.combatCrime(initDomain(List.of(63))); // gBaseSHRWFRService.combatCrime(initDomain(List.of(63)));
// gBaseJJDService.syncPoliceAttack(initDomain(List.of(64))); gBaseJJDService.syncPoliceAttack(initDomain(List.of(64)));
// gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66))); // gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66)));
// pointService.syncPointType(initDomain(List.of(67))); // pointService.syncPointType(initDomain(List.of(67)));
// gBaseSHRWFRService.hadWork(initDomain(List.of(68))); // gBaseSHRWFRService.hadWork(initDomain(List.of(68)));
@ -148,22 +148,22 @@ public class ApplicationEvent {
// pointService.syncParentsDivorce(initDomain(List.of(117))); // pointService.syncParentsDivorce(initDomain(List.of(117)));
// pointService.syncFamilyDie(initDomain(List.of(118))); // pointService.syncFamilyDie(initDomain(List.of(118)));
// pointService.syncFatherDie(initDomain(List.of(119))); // pointService.syncFatherDie(initDomain(List.of(119)));
pointService.syncMotherDie(initDomain(List.of(120))); // pointService.syncMotherDie(initDomain(List.of(120)));
pointService.syncChildNo(initDomain(List.of(121))); // pointService.syncChildNo(initDomain(List.of(121)));
pointService.syncXIDU(initDomain(List.of(122))); // pointService.syncXIDU(initDomain(List.of(122)));
pointService.syncFiliation(initDomain(List.of(123))); // pointService.syncFiliation(initDomain(List.of(123)));
// 必须在123后面 // 必须在123后面
// gBaseJJDService.syncOtherContradict(initDomain(List.of(75))); // gBaseJJDService.syncOtherContradict(initDomain(List.of(75)));
pointService.syncPetitionContent(initDomain(List.of(124))); // pointService.syncPetitionContent(initDomain(List.of(124)));
pointService.syncMedicalPressure(initDomain(List.of(125))); // pointService.syncMedicalPressure(initDomain(List.of(125)));
pointService.syncSeriousIllness(initDomain(List.of(126))); // pointService.syncSeriousIllness(initDomain(List.of(126)));
pointService.syncFamilySeriousIllness(initDomain(List.of(127))); // pointService.syncFamilySeriousIllness(initDomain(List.of(127)));
pointService.syncPetitionDissatisfied(initDomain(List.of(128))); // pointService.syncPetitionDissatisfied(initDomain(List.of(128)));
pointService.syncIsSpecialPeople(initDomain(List.of(129))); // pointService.syncIsSpecialPeople(initDomain(List.of(129)));
pointService.syncSpecialPeopleType(initDomain(List.of(130))); // pointService.syncSpecialPeopleType(initDomain(List.of(130)));
pointService.syncParentsRelationship(initDomain(List.of(131))); // pointService.syncParentsRelationship(initDomain(List.of(131)));
pointService.syncMentalDiseaseDriver(initDomain(List.of(132))); // pointService.syncMentalDiseaseDriver(initDomain(List.of(132)));
// *********暂时不要********** // *********暂时不要**********
// riskTaskService.heightFight(initDomain(List.of(42))); // riskTaskService.heightFight(initDomain(List.of(42)));
// pointService.syncKillSelf(initDomain(List.of(46))); // pointService.syncKillSelf(initDomain(List.of(46)));

10
src/main/java/com/biutag/supervisiondata/service/impl/GBaseJJDServiceImpl.java
Unescape View File

@ -21,10 +21,7 @@ import com.biutag.supervisiondata.repository.*;
import com.biutag.supervisiondata.service.GBaseJJDService; import com.biutag.supervisiondata.service.GBaseJJDService;
import com.biutag.supervisiondata.service.RiskModelTaskClueService; import com.biutag.supervisiondata.service.RiskModelTaskClueService;
import com.biutag.supervisiondata.service.RiskPersonalService; import com.biutag.supervisiondata.service.RiskPersonalService;
import com.biutag.supervisiondata.util.BhUtil; import com.biutag.supervisiondata.util.*;
import com.biutag.supervisiondata.util.IdCodeUtil;
import com.biutag.supervisiondata.util.OrgUtil;
import com.biutag.supervisiondata.util.PatternUtil;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -442,12 +439,13 @@ public class GBaseJJDServiceImpl implements GBaseJJDService {
.name(person.getName()) .name(person.getName())
.id("ptsjsj") .id("ptsjsj")
.idCode(person.getIdCode()) .idCode(person.getIdCode())
.tag("平台涉警事件") .tags(List.of("平台涉警事件"))
.sourceData(sb.substring(0, sb.length()-1)) .sourceData(sb.substring(0, sb.length()-1))
.eventTime(Optional.ofNullable(eventTime).orElse(LocalDateTime.now())) .eventTime(Optional.ofNullable(eventTime).orElse(LocalDateTime.now()))
.personId(person.getId()) .personId(person.getId())
.score(Math.min(5,jjdList.size()))
.build(); .build();
toInsert.add(createClue(task.getModelId(), 5, task.getId(), data)); toInsert.add(DataUtil.createClueData(task, data));
} }
log.info("保存袭警数据：{}", toInsert.size()); log.info("保存袭警数据：{}", toInsert.size());
if (!toInsert.isEmpty()) { if (!toInsert.isEmpty()) {

Write Preview
Loading…
Cancel
Save