update

eight

2024-08-31 bb767d9be029935ee73b4a8e67b370a153f39c74

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

@@ -7,6 +7,7 @@
import javax.annotation.Resource;

import cn.lihu.jh.module.ecg.Utils;
import cn.lihu.jh.module.ecg.config.DynamicSchedulingConfig;
import cn.lihu.jh.module.ecg.dal.dataobject.room.RoomDO;
import cn.lihu.jh.module.ecg.service.room.RoomService;
import org.springframework.scheduling.config.CronTask;
@@ -51,14 +52,7 @@
    private ConfigApi configApi;

    @Resource
    private ScheduledTaskRegistrar taskRegistrar;

    @Resource
    private QueueService queueService;

    @Resource
    private RoomService roomService;


    @Resource
    private queueMapper queueMapper;
@@ -115,6 +109,7 @@
            e.printStackTrace();
        }

        System.out.println("startBedOpen ========");
        return ECG_INNER_ERROR;
    }

@@ -131,6 +126,7 @@
            e.printStackTrace();
        }

        System.out.println("startBedClose ========");
        return ECG_INNER_ERROR;
    }

@@ -149,6 +145,7 @@
            e.printStackTrace();
        }

        System.out.println("startBedDoctorPause ========");
        return ECG_INNER_ERROR;
    }

@@ -167,6 +164,7 @@
            e.printStackTrace();
        }

        System.out.println("startBedDoctorResume ========");
        return ECG_INNER_ERROR;
    }

@@ -185,6 +183,7 @@
            e.printStackTrace();
        }

        System.out.println("startBedDoctorOn ========");
        return ECG_INNER_ERROR;
    }

@@ -203,6 +202,26 @@
            e.printStackTrace();
        }

        System.out.println("startBedDoctorOff ========");
        return ECG_INNER_ERROR;
    }

    @Override
    public ErrorCode startNextPatient(Long roomId, String bedNo) {
        Future<ErrorCode> future = singleThreadExecutor.submit(
                new BedDoctorNextPatientCallable(this, roomId, bedNo)
        );

        try {
            ErrorCode ret = future.get();
            return ret;
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }

        System.out.println("startNextPatient ========");
        return ECG_INNER_ERROR;
    }

@@ -248,9 +267,6 @@
        if (bedQueueBO.getQueueNum().get() >0)
            return QUEUE_HAVE_PATIENT;

        mapBedVsQueue.remove(String.format("%09d%s", roomId, bedNo));
        priorityQueue.remove(bedQueueBO);

        // DB update
        List statusList = new ArrayList<BedStatusEnum>();
        statusList.add(BedStatusEnum.OPENING);
@@ -261,6 +277,8 @@
        if ( null==updateNum || 0 == updateNum )
            return ROOM_INVALID_STATUS;

        mapBedVsQueue.remove(String.format("%09d%s", roomId, bedNo));
        priorityQueue.remove(bedQueueBO);
        return SUCCESS;
    }

@@ -273,6 +291,7 @@

        RoomDO roomDO = roomMapper.getRoom(roomId, bedNo, docId);
        if (null == roomDO) {
            System.out.println("getRoom ========");
            return error(ECG_INNER_ERROR);
        }

@@ -286,17 +305,16 @@
        if (null == bedQueueBO)
            return QUEUE_BED_ABNORMAL;

        bedQueueBO.setStatusEnum(BedStatusEnum.PAUSE);
        priorityQueue.remove(bedQueueBO);

        // DB update
        List statusList = new ArrayList<BedStatusEnum>();
        statusList.add(BedStatusEnum.DOCTOR_ON);
        Integer updateNum = roomMapper.setBedDoctorPause(roomId, bedNo, docId, docName,
        Integer updateNum = roomMapper.setBedDoctorStatus(roomId, bedNo, docId,
                BedStatusEnum.PAUSE, statusList);
        if ( null==updateNum || 0 == updateNum )
            return ROOM_INVALID_STATUS;

        bedQueueBO.setStatusEnum(BedStatusEnum.PAUSE);
        priorityQueue.remove(bedQueueBO);
        return SUCCESS;
    }

@@ -306,16 +324,16 @@
        if (null == bedQueueBO)
            return QUEUE_BED_ABNORMAL;

        bedQueueBO.setStatusEnum(BedStatusEnum.DOCTOR_ON);
        priorityQueue.offer(bedQueueBO);

        // DB update
        List statusList = new ArrayList<BedStatusEnum>();
        statusList.add(BedStatusEnum.PAUSE);
        Integer updateNum = roomMapper.setBedDoctorPause(roomId, bedNo, docId, docName,
        Integer updateNum = roomMapper.setBedDoctorStatus(roomId, bedNo, docId,
                BedStatusEnum.DOCTOR_ON, statusList);
        if ( null==updateNum || 0 == updateNum )
            return ROOM_INVALID_STATUS;

        bedQueueBO.setStatusEnum(BedStatusEnum.DOCTOR_ON);
        priorityQueue.offer(bedQueueBO);

        hurryup();
        return SUCCESS;
@@ -349,7 +367,7 @@
        // DB update
        List statusList = new ArrayList<BedStatusEnum>();
        statusList.add(BedStatusEnum.DOCTOR_ON);
        Integer updateNum = roomMapper.setBedDoctorOff(roomId, bedNo, docId, docName,
        Integer updateNum = roomMapper.setBedDoctorOff(roomId, bedNo, docId,
                BedStatusEnum.OPENING, statusList);
        if ( null==updateNum || 0 == updateNum )
            return ROOM_INVALID_STATUS;
@@ -497,14 +515,15 @@
        startHurryUp();
    }

    private void nextPatient(Long roomId, String bedNo) {
    @Override
    public ErrorCode nextPatient(Long roomId, String bedNo) {
        // 从 DB 把 序号最小的 就诊准备中的人 设置为就诊中
        Integer updateNum = queueMapper.updateQueueStatus(roomId, bedNo,
                QueueStatusEnum.READY.getStatus(), QueueStatusEnum.ONSTAGE.getStatus());

        // 该工位 没有 就诊准备中 人员
        if (null == updateNum || 0 == updateNum) {
            return;
            return QUEUE_NOT_READY_PATIENT;
        }

        // 优先队列中 该工位 就诊准备中人的数量 减一
@@ -513,7 +532,8 @@
        priorityQueue.remove(bo);
        priorityQueue.offer(bo);

        startHurryUp();
        hurryup();
        return SUCCESS;
    }

    public void finishNextPatient(Long roomId, String bedNo) {
@@ -521,7 +541,7 @@
        Integer ret =  queueMapper.updateQueueStatus(roomId, bedNo,
                QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.FINISH.getStatus());

        nextPatient(roomId, bedNo);
        startNextPatient(roomId, bedNo);
    }

    public void passNextPatient(Long roomId, String bedNo) {
@@ -529,7 +549,7 @@
        Integer ret =  queueMapper.updateQueueStatus(roomId, bedNo,
                QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.PASSED.getStatus());

        nextPatient(roomId, bedNo);
        startNextPatient(roomId, bedNo);
    }

    public List<QueueDO> getDoctorQueueByStatus(Long roomId, String bedNo, List<Byte> statusList) {
@@ -582,8 +602,8 @@

    @Override
    public void resetScheduler() {
        Set<ScheduledTask> taskList = taskRegistrar.getScheduledTasks();
        taskList.forEach((task)->task.cancel());
        ScheduledTaskRegistrar taskRegistrar = DynamicSchedulingConfig.static_scheduledTaskRegistrar;
        taskRegistrar.getScheduledTasks().forEach(ScheduledTask::cancel);

        String strOpenCloseTime = configApi.getConfigValueByKey(ECG_OPENING_TIME_KEY);
        List<LocalTime> list = Utils.parseOpeningTime(strOpenCloseTime);
@@ -598,18 +618,20 @@

        taskRegistrar.scheduleCronTask(new CronTask(() -> {
            System.out.println("Opening Task executed at: " + System.currentTimeMillis());
            queueService.startBiz();
            startBiz();
        }, openCronExpression));

        taskRegistrar.scheduleCronTask(new CronTask(() -> {
            System.out.println("Close Task executed at: " + System.currentTimeMillis());
            queueService.closeBiz();
            closeBiz();
        }, closeCronExpression));

        taskRegistrar.scheduleCronTask(new CronTask(() -> {
            System.out.println("Room Reset Task executed at: " + System.currentTimeMillis());
            roomService.resetRoom();
        }, roomResetCronExpression));

        taskRegistrar.afterPropertiesSet();
    }

    @Override