just refactopr 工位信息维护 分流队列维护

eight

2025-04-08 d88aeadb43f3aa1ce9fe6a358c5466e721a53038

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

@@ -584,19 +584,19 @@
    }

    /**
     * 获取 指定工位 待检查|待领用的人
     * 获取 指定工位  【检查|领用】相关的患者
     * @param roomId
     * @param bedNo
     * @return
     */
    @Override
    public List<QueueDO> getToBeCheckedPatient(Long roomId, String bedNo) {
    public List<QueueDO> getCheckRelatedPatient(Long roomId, String bedNo) {
        List<Integer> queueStatusList = new ArrayList<>();
        queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());
        queueStatusList.add(QueueStatusEnum.READY.getStatus());
        queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
        queueStatusList.add(QueueStatusEnum.PASSED.getStatus());
        queueStatusList.add(QueueStatusEnum.AFFINITY_WAITING.getStatus());
        queueStatusList.add(QueueStatusEnum.AFFINITY.getStatus());
        List<QueueDO> queueDOList = getBedQueueByStatus(roomId, bedNo, queueStatusList);

        //把 [亲和的] 挪到主项后面
@@ -604,7 +604,7 @@
        ListIterator<QueueDO> iterator = queueDOList.listIterator();
        while (iterator.hasNext()) {
            QueueDO item = iterator.next();
            if (item.getStatus() == QueueStatusEnum.AFFINITY_WAITING.getStatus()) {
            if (item.getStatus() == QueueStatusEnum.AFFINITY.getStatus()) {
                iterator.remove();
                affinityWaitingList.add(item);
            }
@@ -621,25 +621,31 @@
        return queueDOList;
    }

    /**
     * 获取 指定工位  【安装】相关的患者
     * @param roomId
     * @param bedNo
     * @return
     */
    @Override
    public List<QueueDO> getToBeInstalledPatient(Long roomId, String bedNo) {
    public List<QueueDO> getInstallRelatedPatient(Long roomId, String bedNo) {
        List<Integer> queueStatusList = new ArrayList<>();
        queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus());
        queueStatusList.add(QueueStatusEnum.PASSED_INSTALL.getStatus());
        queueStatusList.add(QueueStatusEnum.AFFINITY_RECEIVED.getStatus());
        List<QueueDO> queueDOList = getRoomQueueByStatus(roomId, queueStatusList);
        queueStatusList.add(QueueStatusEnum.AFFINITY_INSTALL.getStatus());
        List<QueueDO> queueDOList = getRoomQueueByStatus(roomId, queueStatusList); // 可以看到本诊室 待安装的患者

        queueStatusList.clear();
        queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus());
        queueStatusList.add(QueueStatusEnum.RECALLED_INSTALL.getStatus());
        queueDOList.addAll(0, getBedQueueByStatus(roomId, bedNo, queueStatusList) );
        queueDOList.addAll(0, getBedQueueByStatus(roomId, bedNo, queueStatusList) ); // 当前工位的

        //把 [亲和的] 挪到主项后面
        List<QueueDO> affinityReceivedList = new ArrayList<>();
        ListIterator<QueueDO> iterator = queueDOList.listIterator();
        while (iterator.hasNext()) {
            QueueDO item = iterator.next();
            if (item.getStatus() == QueueStatusEnum.AFFINITY_RECEIVED.getStatus()) {
            if (item.getStatus() == QueueStatusEnum.AFFINITY_INSTALL.getStatus()) {
                iterator.remove();
                affinityReceivedList.add(item);
            }
@@ -669,7 +675,7 @@
     */
    private void procAffinityWhenInstallRecall(String patId, Integer[] affinityCheckTypes, Long roomId_operator, String bedNo_operator) {
        List<QueueDO> affinityItems = queueMapper.getCurPatGivenCheckTypesAndStatus(
                        patId, affinityCheckTypes, QueueStatusEnum.AFFINITY_RECEIVED.getStatus());
                        patId, affinityCheckTypes, QueueStatusEnum.AFFINITY_INSTALL.getStatus());
        for (int i = 0; i < affinityItems.size(); i++) {
            QueueDO queueItem = affinityItems.get(i);
            queueItem.setRoomId( roomId_operator );
@@ -683,14 +689,14 @@
     * 预约确认后，主动寻求依附
     */
    private void procAffinityWhenQueue(/*IN, OUT*/QueueSaveReqVO queueSaveReqVO, Integer[] affinityCheckTypes) {
        // 如果存在 [就诊准备] [就诊中] [过号] [已召回] 能被依附的检查项，则依附到其中一个
        // 如果存在 [候诊中] [就诊中] [过号] [已召回] 能被依附的检查项，则依附到其中一个
        List<QueueDO> affinityItems = queueMapper.getCurPatGivenCheckTypesAndStatusList(
                queueSaveReqVO.getPatId(), affinityCheckTypes,
                List.of(QueueStatusEnum.READY.getStatus(), QueueStatusEnum.ONSTAGE.getStatus(),
                        QueueStatusEnum.PASSED.getStatus(), QueueStatusEnum.RECALLED.getStatus()));
        if (!affinityItems.isEmpty()) {
            QueueDO queueItem = affinityItems.get(0);
            queueSaveReqVO.setStatus(QueueStatusEnum.AFFINITY_WAITING.getStatus()); // [亲和-排队] 状态
            queueSaveReqVO.setStatus(QueueStatusEnum.AFFINITY.getStatus()); // [亲和-排队] 状态
            queueSaveReqVO.setAffinityItem( 1 );
            queueSaveReqVO.setRoomId(queueItem.getRoomId());
            queueSaveReqVO.setRoomName(queueItem.getRoomName());