未完成的代码

src/main/java/com/docus/server/report/entity/AfJobTime.java

@@ -0,0 +1,36 @@
+package com.docus.server.report.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 曾文和
+ * @since 2021-05-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value="AfJobTime对象", description="")
+public class AfJobTime implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "主键id")
+    private Long id;
+
+    @ApiModelProperty(value = "最新刷新时间")
+    private LocalDateTime updateTime;
+
+    @ApiModelProperty(value = "调度类型。")
+    private String jobType;
+
+
+}

src/main/java/com/docus/server/report/job/ReportJob.java

@@ -1,8 +1,12 @@
 package com.docus.server.report.job;
 
 import com.docus.core.util.Func;
+import com.docus.infrastructure.redis.service.IdService;
+import com.docus.server.collection.entity.TBasic;
 import com.docus.server.collection.mapper.TBasicMapper;
+import com.docus.server.report.entity.AfJobTime;
 import com.docus.server.report.entity.AfReportRecord;
+import com.docus.server.report.mapper.AfJobTimeMapper;
 import com.docus.server.report.mapper.AfReportRecordMapper;
 import com.docus.server.report.service.ReportService;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -10,6 +14,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -27,6 +32,64 @@ public class ReportJob {
     private AfReportRecordMapper afReportRecordMapper;
     @Resource
     private TBasicMapper tBasicMapper;
+    @Resource
+    private AfJobTimeMapper afJobTimeMapper;
+    @Resource
+    private IdService idService;
+
+    /**
+     * 检验报告查询，查询入院时间前 3天的检验报告
+     */
+    @XxlJob("LisReportQueryJob")
+    public void LisReportQueryJob() {
+        // 顺德人医 Lis 检验报告查询
+        final String jobType="SDryLisReport";
+        LocalDateTime now = LocalDateTime.now();
+        log.info("检验报告报告查询 任务开始了");
+        AfJobTime afJobTime=afJobTimeMapper.getAfJobTimeByJobType(jobType);
+
+        // 定义查基础数据 入院时间 开始结束
+        String queryBasicAdmissStartDate="1801-01-01 00:00:00";
+        if(afJobTime!=null && afJobTime.getUpdateTime() != null){
+            LocalDateTime updateTime = afJobTime.getUpdateTime();
+            queryBasicAdmissStartDate = updateTime.toString();
+        }
+        String queryBasicAdmissEndDate=now.toString();
+
+        int offset=0;
+        int size=50;
+
+        List<TBasic> basicList = tBasicMapper.selectBasicListByAdmissDate(queryBasicAdmissStartDate,queryBasicAdmissEndDate);
+        if(Func.isEmpty(basicList)){
+            log.warn("未查询到 入院时间 {} - {} 基础数据",queryBasicAdmissStartDate,queryBasicAdmissEndDate);
+        }
+
+        for (TBasic basic : basicList) {
+            // 获取顺德人医的业务系统的患者索引
+            String SDryIndex = tBasicMapper.getSdryReportIndex(basic.getPatientId());
+
+        }
+
+
+
+
+        try {
+            reportService.report(null);
+        } catch (Exception ex) {
+            log.error("检验报告报告查询 出错啦！",ex);
+        }
+        long id=0;
+
+        String lastTime=now.toString();
+
+        refreshTime(id,jobType,lastTime);
+        log.info("检验报告报告查询 任务结束了，本次查询出院时间段 {} - {}","","");
+    }
+
+    private void refreshTime(long id, String jobType, String lastTime) {
+
+    }
+
 
     /**
      * 补偿异常的报告

src/main/java/com/docus/server/report/mapper/AfJobTimeMapper.java

@@ -0,0 +1,8 @@
+package com.docus.server.report.mapper;
+
+/**
+ * job 记录时间
+ * @author wyb
+ */
+public interface AfJobTimeMapper {
+}

src/main/java/com/docus/server/report/service/impl/ReportServiceImpl.java

@@ -87,6 +87,11 @@ public class ReportServiceImpl implements ReportService {
         }
         // 都成功后发布下载事件
         applicationContext.publishEvent(new ReportDownEvent(this, afReportRecord.getTaskId()));
+        try {
+            TimeUnit.MILLISECONDS.sleep(50);
+        } catch (InterruptedException ex) {
+            log.error(ex.getMessage(), ex);
+        }
     }
 
     @Override