|
|
|
@ -29,6 +29,7 @@ import com.docus.server.report.util.XmlUtil;
|
|
|
|
|
import com.docus.server.report.validate.CollectTaskValidation;
|
|
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
import org.w3c.dom.Node;
|
|
|
|
|
|
|
|
|
@ -72,6 +73,8 @@ public class ReportJob {
|
|
|
|
|
private ShunDePeopleBusinessService shunDePeopleBusinessService;
|
|
|
|
|
@Resource
|
|
|
|
|
RedisOps redisOps;
|
|
|
|
|
@Value("${docus.report.waittime}")
|
|
|
|
|
private int waittime;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 输血报告采集
|
|
|
|
@ -272,7 +275,7 @@ public class ReportJob {
|
|
|
|
|
log.info("住院号:{},住院次数{},护理采集文件: {} 条", inpatientNo, admissTimes, collectFileCount);
|
|
|
|
|
// 设置一个redisKey,过期被监听处理
|
|
|
|
|
String redisKey = String.format(ReportDownloadWait.REPORT_DOWNLOAD_WAIT_KEY, reportQueryNurseInsertSugarCollectorId, patientId);
|
|
|
|
|
redisOps.setEx(redisKey, "0", ReportDownloadWait.REPORT_DOWNLOAD_WAIT_TIME);
|
|
|
|
|
redisOps.setEx(redisKey, "0", waittime*60);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|