|
|
|
@ -1,15 +1,10 @@ |
|
|
|
package com.biutag.supervisiondata.service.impl; |
|
|
|
package com.biutag.supervisiondata.service.impl; |
|
|
|
|
|
|
|
|
|
|
|
import com.alibaba.fastjson2.JSON; |
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
|
import com.biutag.supervisiondata.pojo.constants.Default; |
|
|
|
import com.biutag.supervisiondata.pojo.constants.Default; |
|
|
|
import com.biutag.supervisiondata.pojo.domain.TaskParamDomain; |
|
|
|
import com.biutag.supervisiondata.pojo.domain.TaskParamDomain; |
|
|
|
import com.biutag.supervisiondata.pojo.entity.dwd.GBaseAJJBXX; |
|
|
|
|
|
|
|
import com.biutag.supervisiondata.pojo.entity.dwd.GBaseBAXX; |
|
|
|
|
|
|
|
import com.biutag.supervisiondata.pojo.entity.dwd.GBaseJJD; |
|
|
|
import com.biutag.supervisiondata.pojo.entity.dwd.GBaseJJD; |
|
|
|
import com.biutag.supervisiondata.pojo.entity.dwd.GBaseWFRXX; |
|
|
|
|
|
|
|
import com.biutag.supervisiondata.pojo.entity.mine.*; |
|
|
|
import com.biutag.supervisiondata.pojo.entity.mine.*; |
|
|
|
import com.biutag.supervisiondata.pojo.enums.Dispute; |
|
|
|
|
|
|
|
import com.biutag.supervisiondata.repository.GBaseJJDRepository; |
|
|
|
import com.biutag.supervisiondata.repository.GBaseJJDRepository; |
|
|
|
import com.biutag.supervisiondata.repository.RiskModelTaskClueRepository; |
|
|
|
import com.biutag.supervisiondata.repository.RiskModelTaskClueRepository; |
|
|
|
import com.biutag.supervisiondata.repository.RiskPersonalRepository; |
|
|
|
import com.biutag.supervisiondata.repository.RiskPersonalRepository; |
|
|
|
@ -41,12 +36,6 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
|
|
|
|
|
|
|
|
private final RiskModelTaskClueService riskModelTaskClueService; |
|
|
|
private final RiskModelTaskClueService riskModelTaskClueService; |
|
|
|
|
|
|
|
|
|
|
|
private final RiskPersonalTagService tagService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final RiskPersonalService riskPersonalService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final RiskPersonalControlRecordService controlRecordService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final RiskPersonalRepository riskPersonalRepository; |
|
|
|
private final RiskPersonalRepository riskPersonalRepository; |
|
|
|
|
|
|
|
|
|
|
|
private final RiskTaskRepository riskTaskRepository; |
|
|
|
private final RiskTaskRepository riskTaskRepository; |
|
|
|
@ -97,9 +86,7 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
Map<String, RiskPersonal> personMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (oldValue, newValue) -> newValue)); |
|
|
|
Map<String, RiskPersonal> personMap = domain.getPersons().stream().collect(Collectors.toMap(RiskPersonal::getIdCode, Function.identity(), (oldValue, newValue) -> newValue)); |
|
|
|
// ******* 数据操作 *******
|
|
|
|
// ******* 数据操作 *******
|
|
|
|
List<RiskModelTaskClue> toInsert = new ArrayList<>(); |
|
|
|
List<RiskModelTaskClue> toInsert = new ArrayList<>(); |
|
|
|
List<RiskPersonalControlRecord> controlRecords = new ArrayList<>(); |
|
|
|
|
|
|
|
List<RiskPersonal> toUpdatePerson = new ArrayList<>(); |
|
|
|
List<RiskPersonal> toUpdatePerson = new ArrayList<>(); |
|
|
|
// List<RiskPersonalTag> toInsertTags = new ArrayList<>();
|
|
|
|
|
|
|
|
// ******* 数据操作 *******
|
|
|
|
// ******* 数据操作 *******
|
|
|
|
// 开始
|
|
|
|
// 开始
|
|
|
|
for (GBaseJJD jjd : result) { |
|
|
|
for (GBaseJJD jjd : result) { |
|
|
|
@ -117,12 +104,9 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
} |
|
|
|
} |
|
|
|
if(insert) { |
|
|
|
if(insert) { |
|
|
|
toInsert.add(createClue(task, 1, person, jjd, "通过对近12个月的警情筛查，发现该人员涉及："+jjd.getJqxzmc()+"的警情，接警单编号为："+jjd.getJjdbh())); |
|
|
|
toInsert.add(createClue(task, 1, person, jjd, "通过对近12个月的警情筛查，发现该人员涉及："+jjd.getJqxzmc()+"的警情，接警单编号为："+jjd.getJjdbh())); |
|
|
|
RiskPersonalControlRecord tmpRecord = createControlRecord(person, jjd, toInsert.getLast().getRiskReason()); |
|
|
|
if(person.getControlTime() == null) { |
|
|
|
controlRecords.add(tmpRecord); |
|
|
|
RiskPersonal personToUpdate = getRiskPersonal(person); |
|
|
|
if(person.getControlTime() == null || tmpRecord.getControlTime().isAfter(person.getControlTime())) { |
|
|
|
|
|
|
|
RiskPersonal personToUpdate = getRiskPersonal(person, tmpRecord); |
|
|
|
|
|
|
|
toUpdatePerson.add(personToUpdate); |
|
|
|
toUpdatePerson.add(personToUpdate); |
|
|
|
// toInsertTags.add(createTag(Dispute.contains(jjd.getJqxzmc()), toInsert.getLast().getEventTime(), person));
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
@ -130,10 +114,6 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
log.info("新增线索：{}",toInsert.size()); |
|
|
|
log.info("新增线索：{}",toInsert.size()); |
|
|
|
riskModelTaskClueService.saveClues(toInsert, Default.TRUBO_IG); |
|
|
|
riskModelTaskClueService.saveClues(toInsert, Default.TRUBO_IG); |
|
|
|
} |
|
|
|
} |
|
|
|
if(!controlRecords.isEmpty()) { |
|
|
|
|
|
|
|
log.info("新增管控记录：{}",controlRecords.size()); |
|
|
|
|
|
|
|
controlRecordService.batchInsert(controlRecords); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if(!toUpdatePerson.isEmpty()) { |
|
|
|
if(!toUpdatePerson.isEmpty()) { |
|
|
|
log.info("修改风险人员：{}",toUpdatePerson.size()); |
|
|
|
log.info("修改风险人员：{}",toUpdatePerson.size()); |
|
|
|
riskPersonalRepository.updateBatchById(toUpdatePerson, 5000); |
|
|
|
riskPersonalRepository.updateBatchById(toUpdatePerson, 5000); |
|
|
|
@ -145,12 +125,9 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
riskTaskRepository.updateTask(task.getId(), toInsert.size(), toUpdatePerson.size()); |
|
|
|
riskTaskRepository.updateTask(task.getId(), toInsert.size(), toUpdatePerson.size()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private static RiskPersonal getRiskPersonal(RiskPersonal person, RiskPersonalControlRecord tmpRecord) { |
|
|
|
private static RiskPersonal getRiskPersonal(RiskPersonal person) { |
|
|
|
RiskPersonal personToUpdate = new RiskPersonal(); |
|
|
|
RiskPersonal personToUpdate = new RiskPersonal(); |
|
|
|
personToUpdate.setId(person.getId()); |
|
|
|
personToUpdate.setId(person.getId()); |
|
|
|
// personToUpdate.setControlTime(tmpRecord.getControlTime());
|
|
|
|
|
|
|
|
// personToUpdate.setControlDepartName(tmpRecord.getControlDepartName());
|
|
|
|
|
|
|
|
// personToUpdate.setControlDepartId(tmpRecord.getControlDepartId());
|
|
|
|
|
|
|
|
if(person.getTags().indexOf(Default.BIG_TAG_TRUBO) == -1) { |
|
|
|
if(person.getTags().indexOf(Default.BIG_TAG_TRUBO) == -1) { |
|
|
|
personToUpdate.setTags(person.getTags().concat(",".concat(Default.BIG_TAG_TRUBO))); |
|
|
|
personToUpdate.setTags(person.getTags().concat(",".concat(Default.BIG_TAG_TRUBO))); |
|
|
|
} |
|
|
|
} |
|
|
|
@ -172,32 +149,4 @@ public class PoliceServiceImpl implements PoliceService { |
|
|
|
clue.setCaseIds(BhUtil.jjdBh(jjd.getJjdbh())); |
|
|
|
clue.setCaseIds(BhUtil.jjdBh(jjd.getJjdbh())); |
|
|
|
return clue; |
|
|
|
return clue; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
RiskPersonalControlRecord createControlRecord(RiskPersonal person, GBaseJJD jjd, String tag) { |
|
|
|
|
|
|
|
RiskPersonalControlRecord controlRecord = new RiskPersonalControlRecord(); |
|
|
|
|
|
|
|
controlRecord.setName(person.getName()); |
|
|
|
|
|
|
|
controlRecord.setIdCode(person.getIdCode()); |
|
|
|
|
|
|
|
controlRecord.setCreateTime(LocalDateTime.now()); |
|
|
|
|
|
|
|
try { |
|
|
|
|
|
|
|
controlRecord.setControlTime(jjd.getBjsj().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime()); |
|
|
|
|
|
|
|
} catch (Exception e) { |
|
|
|
|
|
|
|
log.info("报警时间转换异常"); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
controlRecord.setControlDepartId(jjd.getGxdwdm()); |
|
|
|
|
|
|
|
controlRecord.setControlDepartName(jjd.getGxdwmc()); |
|
|
|
|
|
|
|
controlRecord.setControlTag(tag); |
|
|
|
|
|
|
|
controlRecord.setCaseId(BhUtil.jjdBh(jjd.getJjdbh())); |
|
|
|
|
|
|
|
return controlRecord; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
RiskPersonalTag createTag(String tag, LocalDateTime eventTime, RiskPersonal personal) { |
|
|
|
|
|
|
|
RiskPersonalTag personalTag = new RiskPersonalTag(); |
|
|
|
|
|
|
|
personalTag.setTagTime(eventTime); |
|
|
|
|
|
|
|
personalTag.setBigTag(Default.BIG_TAG_TRUBO); |
|
|
|
|
|
|
|
personalTag.setSmallTag(tag); |
|
|
|
|
|
|
|
personalTag.setIdCode(personal.getIdCode()); |
|
|
|
|
|
|
|
personalTag.setName(personal.getName()); |
|
|
|
|
|
|
|
personalTag.setCreateTime(LocalDateTime.now()); |
|
|
|
|
|
|
|
return personalTag; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
