xinyilu/PostDischargePatientManage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

医共体数据添加

Browse Source
This commit is contained in:
zhangheng 2026-03-24 10:32:15 +08:00
parent 099b72a23e
commit 44572acc61
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
postdischarge-quartz/src/main/java/com/xinelu/quartz/task/MedicalConsortiumPlatformTask.java
View File

@ -19,6 +19,7 @@ import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import java.util.stream.Stream;
/** /**
* @description: 医共体数据导入定时任务 * @description: 医共体数据导入定时任务
@ -33,6 +34,7 @@ public class MedicalConsortiumPlatformTask {
private ExternalImportMapper externalImportMapper; private ExternalImportMapper externalImportMapper;
public void medicalConsortiumPlatformTask() throws Exception { public void medicalConsortiumPlatformTask() throws Exception {
log.info("开始获取医共体数据，时间：" + LocalDateTime.now());
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
List<TbFollowUp> list = new ArrayList<>(); List<TbFollowUp> list = new ArrayList<>();
//获取数据 //获取数据
@ -76,15 +78,17 @@ public class MedicalConsortiumPlatformTask {
e.printStackTrace(); e.printStackTrace();
} }
if (CollectionUtils.isEmpty(list) || list.size() == 0) { if (CollectionUtils.isEmpty(list) || list.size() == 0) {
log.info("获取医共体数据" + list.size() + "条");
return; return;
} }
List<String> collect = list.stream().filter(Objects::nonNull).map(TbFollowUp::getLYFS).collect(Collectors.toList()); List<String> collect = list.stream().filter(Objects::nonNull).map(TbFollowUp::getJZLSH).collect(Collectors.toList());
List<ExternalImport> dataExternalImports = externalImportMapper.selectExternalByPhone(collect); List<ExternalImport> dataExternalImports = externalImportMapper.selectExternalByPhone(collect);
list = list.stream().filter(Objects::nonNull).filter(item -> StringUtils.isNotBlank(item.getJZLSH()) && StringUtils.isNotBlank(item.getXM())).collect(Collectors.toList());
List<ExternalImport> externalImports = new ArrayList<>(); List<ExternalImport> externalImports = new ArrayList<>();
for (TbFollowUp tbFollowUp : list) { for (TbFollowUp tbFollowUp : list) {
//去除与数据库重复项 //去除与数据库重复项
ExternalImport identicalPhone = dataExternalImports.stream().filter(item -> tbFollowUp.getLYFS().equals(item.getPhone())).findFirst().orElse(new ExternalImport()); ExternalImport identicalVisitCode = dataExternalImports.stream().filter(item -> tbFollowUp.getJZLSH().equals(item.getVisitCode())).findFirst().orElse(new ExternalImport());
if (StringUtils.isNotBlank(identicalPhone.getPhone())) { if (StringUtils.isNotBlank(identicalVisitCode.getPhone())) {
continue; continue;
} }
ExternalImport externalImport = new ExternalImport(); ExternalImport externalImport = new ExternalImport();
@ -111,7 +115,9 @@ public class MedicalConsortiumPlatformTask {
if (Objects.nonNull(tbFollowUp.getSFSJ())) { if (Objects.nonNull(tbFollowUp.getSFSJ())) {
externalImport.setPlanFollowUp(LocalDateTime.parse(tbFollowUp.getSFSJ(), formatter)); externalImport.setPlanFollowUp(LocalDateTime.parse(tbFollowUp.getSFSJ(), formatter));
} }
externalImport.setFollowUpTemplate(Long.valueOf(tbFollowUp.getMBID())); if (StringUtils.isNotBlank(tbFollowUp.getMBID())){
externalImport.setFollowUpTemplate(Long.valueOf(tbFollowUp.getMBID()));
}
externalImport.setMainDiagnosis(tbFollowUp.getJZZDSM()); externalImport.setMainDiagnosis(tbFollowUp.getJZZDSM());
externalImport.setDataSource("医共体数据"); externalImport.setDataSource("医共体数据");
externalImport.setHealthState(tbFollowUp.getZLJG()); externalImport.setHealthState(tbFollowUp.getZLJG());
@ -120,5 +126,6 @@ public class MedicalConsortiumPlatformTask {
externalImports.add(externalImport); externalImports.add(externalImport);
} }
externalImportMapper.insertExternalImportList(externalImports); externalImportMapper.insertExternalImportList(externalImports);
log.info("结束获取医共体数据，共" + externalImports.size() + "条");
} }
} }