package cn.lihu.jh.module.ecg.service.queue;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
import javax.annotation.PreDestroy;
|
import javax.annotation.Resource;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ScheduledExecutorService;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* 「自动补人」周期兜底任务。
|
*
|
* <h3>为什么需要它</h3>
|
* 分流（{@code 排队中(10) → 候诊中(20)}）原本是**纯事件驱动**的，只在下面这些时机跑一次：
|
* <ul>
|
* <li>签到时 —— {@code AppointmentServiceImpl#appoitmentConfirm} → {@code queue()} → {@code startHurryUpOneCheckType}</li>
|
* <li>医生入座 / 恢复接诊 / 手动开诊 / 叫号 / 检查完成 —— 各自 {@code startHurryUpOneBed}</li>
|
* <li>开诊 · 服务重启 · 诊室重置 —— {@code startBedReload} 里的 {@code hurryupAllBed}</li>
|
* </ul>
|
* 一旦某次触发没有跑到（事务未提交就查库、执行器异常、服务刚好在重启、
|
* 工位当时还没进分流队列……），患者就会**永远**停在「排队中(未分配工位)」，
|
* 只能由医生在工作台手工点「拉入」。
|
*
|
* <p>现场反馈：运动试验签到后出现该现象（低频检查项目，执行器空闲 ⇒
|
* 分流任务必然跑在事务提交之前，见 {@code QueueServiceImpl#runAfterCommit}）。
|
*
|
* <h3>做了什么</h3>
|
* 每 {@value #INTERVAL_SECONDS} 秒对**所有开诊工位**触发一次自动补人。
|
* 只是"多跑一次幂等的补人"，门闸（未开诊 / 停止候诊 / 候诊区已满）全部保持不变，
|
* 因此不会改变既有业务规则，只把"漏网的排队患者"在 1 分钟内补上。
|
*
|
* <p>用独立的单线程守护调度器，**不占用** {@code DynamicSchedulingConfig} 里
|
* 那个只有 1 个线程的 cron 池（避免影响开诊/闭诊/每日重置任务）。
|
*/
|
@Component
|
@Slf4j
|
public class QueueAutoRefillJob {
|
|
/** 补人间隔（秒） */
|
private static final long INTERVAL_SECONDS = 60L;
|
|
/** 启动后首次延迟（秒）：避开启动阶段（此时还没开诊、工位也没装载完） */
|
private static final long INITIAL_DELAY_SECONDS = 60L;
|
|
@Resource
|
private QueueService queueService;
|
|
private ScheduledExecutorService scheduler;
|
|
@PostConstruct
|
public void start() {
|
scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
|
Thread t = new Thread(r, "ecg-queue-auto-refill");
|
t.setDaemon(true);
|
return t;
|
});
|
scheduler.scheduleWithFixedDelay(() -> {
|
try {
|
// 异步投递到 QueueServiceImpl 的串行执行器；这里只负责"按时踹一脚"
|
queueService.startHurryUpAll();
|
} catch (Exception e) {
|
log.error("[QueueAutoRefillJob] 周期补人触发异常（下一轮继续）", e);
|
}
|
}, INITIAL_DELAY_SECONDS, INTERVAL_SECONDS, TimeUnit.SECONDS);
|
|
log.info("[QueueAutoRefillJob] 已启动：每 {} 秒兜底触发一次「全体工位自动补人」"
|
+ "（门闸不变：未开诊/停止候诊/候诊区已满 时不会补人）", INTERVAL_SECONDS);
|
}
|
|
@PreDestroy
|
public void stop() {
|
if (null != scheduler) {
|
scheduler.shutdownNow();
|
scheduler = null;
|
}
|
}
|
}
|
