For Testing

eight

2024-08-22 db9d7abda795b8a24dc9972389cbe4ac5a8a036c

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java

@@ -35,6 +35,14 @@

    final static Integer MAX_QUEUE_NUM = 3;

    @Resource
    private queueMapper queueMapper;

    @Resource
    private RoomMapper roomMapper;

    AtomicInteger openingFlag = new AtomicInteger(0);

    AtomicInteger curSeqNum = new AtomicInteger(0);

    PriorityBlockingQueue<BedQueueBO> priorityQueue = new PriorityBlockingQueue<>();
@@ -42,11 +50,6 @@

    ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

    @Resource
    private queueMapper queueMapper;

    @Resource
    private RoomMapper roomMapper;

    @Override
    public Integer createqueue(QueueSaveReqVO createReqVO) {
@@ -91,7 +94,7 @@
    }

    /**
     * 系统重启时，从DB同步队列数据到 工位优先队列
     * 系统重启时，从DB同步工位的患者队列数据到 工位优先队列
     */
    public void initQueue() {
        priorityQueue.clear();
@@ -145,7 +148,7 @@
     * 等到取下一个 排队中人员 的逻辑完成后，再回来不错
     */
    public void hurryup() {
        while (true) {
        while (1 == openingFlag.get()) {
            BedQueueBO bedQueueBO = priorityQueue.peek();
            if (null == bedQueueBO)
                return;
@@ -190,6 +193,9 @@
        queueSaveReqVO.setStatus(QueueStatusEnum.WAITING.getStatus()); //排队中
        QueueDO queue = BeanUtils.toBean(queueSaveReqVO, QueueDO.class);
        queueMapper.insert(queue);

        if (0 == openingFlag.get())
            return;

        singleThreadExecutor.execute( () -> {
            hurryup();
@@ -259,4 +265,9 @@
        return patientStatisticVO;
    }

    public void startBiz() {
        openingFlag.set(1);
        hurryup();
    }

}