From aec246c3ca04f824e73377d31cc0838dc6c024ac Mon Sep 17 00:00:00 2001 From: wyb <1977763549@qq.com> Date: Thu, 5 Sep 2024 11:42:10 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E8=8B=B1=E5=BE=B7=E4=B8=AD=E5=8C=BB?= =?UTF-8?q?=E9=99=A2=E6=B7=BB=E5=8A=A0pacs=E8=A1=A5=E5=81=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/archive/mapper/TBasicMapper.java | 4 +++ .../server/ydzyy/job/PacsCollectJob.java | 25 +++++++++++++++++++ src/main/resources/mapper/TBasicMapper.xml | 24 ++++++++++++++++++ 3 files changed, 53 insertions(+) diff --git a/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java b/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java index 410c40f..b14e541 100644 --- a/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java +++ b/src/main/java/com/docus/server/archive/mapper/TBasicMapper.java @@ -16,6 +16,8 @@ public interface TBasicMapper { List getTbasicByReportTimeAndInpNoOrIdCard(@Param("sendDateStr") String sendDateStr,@Param("idCard") String idCard,@Param("inpatientNo") String inpatientNo); + List getTbasicByPatientIds(@Param("patientIds") List patientIds); + int deleteTaskByPatAndSource(@Param("patientId")String patientId, @Param("collectorId")String collectorId); @@ -28,4 +30,6 @@ public interface TBasicMapper { int insertCollectTask(@Param("task") AfCollectTask task); int updateTaskById(@Param("task") AfCollectTask task); + + List findFailedTaskPatId(@Param("collectorId") String collectorId,@Param("startDate") String startDateStr); } diff --git a/src/main/java/com/docus/server/ydzyy/job/PacsCollectJob.java b/src/main/java/com/docus/server/ydzyy/job/PacsCollectJob.java index abf4158..4eaf651 100644 --- a/src/main/java/com/docus/server/ydzyy/job/PacsCollectJob.java +++ b/src/main/java/com/docus/server/ydzyy/job/PacsCollectJob.java @@ -20,6 +20,7 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import javax.annotation.Resource; +import java.time.LocalDate; import java.time.LocalDateTime; import java.util.*; import java.util.function.Function; @@ -115,6 +116,30 @@ public class PacsCollectJob { log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>英德中医院pacs视图采集job,结束任务!"); } + @XxlJob("Ydzyy-CollectPacsByFailedTask") + public void collectPacsByFailedTask() { + + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>英德中医院pacs任务补偿job,开始任务!"); + try { + LocalDate startDate = LocalDate.now().plusMonths(-3); + String startDateStr = startDate + " 00:00:00"; + String collectorId = "3"; + List patientIds = tBasicMapper.findFailedTaskPatId(collectorId, startDateStr); + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>英德中医院pacs任务补偿job,查询创建时间>={} 失败的任务患者数量:{} 个。", startDateStr, patientIds); + if (Func.isEmpty(patientIds)) { + return; + } + List tBasicList = tBasicMapper.getTbasicByPatientIds(patientIds); + for (TBasic tBasic : tBasicList) { + collectPacs(tBasic); + } + } catch (Exception ex) { + log.error(">>>>>>>>>>>>>>>>>>>>>>>>>>>英德中医院pacs任务补偿job出现异常,结束任务!" + ex.getMessage(), ex); + } + + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>英德中医院pacs任务补偿job,结束任务!"); + } + public static void main(String[] args) { System.out.println(Func.formatDateTime(new Date()).substring(0, 10)); } diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml index 0d77f65..457080c 100644 --- a/src/main/resources/mapper/TBasicMapper.xml +++ b/src/main/resources/mapper/TBasicMapper.xml @@ -49,4 +49,28 @@ + + +