just refactor - rename

eight

2025-04-09 160ae352de2d3d6cab01203ce2ae8b104b900afd

just refactor - rename

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

@@ -7,7 +7,6 @@
import cn.lihu.jh.module.ecg.controller.admin.room.vo.MonitorInfoVO;
import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO;
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueStatisticDO;
import cn.lihu.jh.module.ecg.dal.dataobject.room.RoomDO;
import cn.lihu.jh.module.ecg.dal.mysql.call.CallMapper;
import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper;
@@ -148,7 +147,7 @@
        }

        mapOpeningBed.remove( Utils.formatRoomBed(roomId, bedNo) );
        removeRoutingQueue(bedBO);
        removeBedFromRoutingQueue(bedBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -169,7 +168,7 @@
        }

        bedBO.setStatus(BedStatusEnum.DOCTOR_PAUSE.getStatus());
        removeRoutingQueue(bedBO);
        removeBedFromRoutingQueue(bedBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -191,7 +190,7 @@
        }

        bedBO.setStatus(BedStatusEnum.DOCTOR_ON.getStatus());
        addRoutingQueue(bedBO);
        addBedToRoutingQueue(bedBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -212,7 +211,7 @@
        }

        bedBO.setStatus(BedStatusEnum.DOCTOR_ON.getStatus());
        addRoutingQueue(bedBO);
        addBedToRoutingQueue(bedBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -233,7 +232,7 @@
            return ROOM_INVALID_STATUS;
        }

        removeRoutingQueue(bedBO);
        removeBedFromRoutingQueue(bedBO);

        bedBO.setStatus(BedStatusEnum.OPENING.getStatus());
        return GlobalErrorCodeConstants.SUCCESS;
@@ -275,7 +274,7 @@
        BedBO bo = mapOpeningBed.get( Utils.formatRoomBed( roomId, bedNo ) );
        bo.readyPatNum.getAndDecrement(); // 可能已经【并发的】在 hurry-up 中改变了值

        refreshRoutingQueue(bo);
        refreshBedPriorityLevelInRoutingQueue(bo);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -331,7 +330,7 @@
        bedBOList.forEach(item -> {
            mapOpeningBed.put( Utils.formatRoomBed(item.roomId, item.bedNo), item);
            if (BedStatusEnum.DOCTOR_ON.getStatus() == item.getStatus()) {
                addRoutingQueue(item);
                addBedToRoutingQueue(item);
            }
        });

@@ -399,7 +398,7 @@
            bedBO.readyPatNum.incrementAndGet();

            // 可能已经【并发的】在 nextPatient 中改变了分流队列顺序
            refreshRoutingQueue(bedBO);
            refreshBedPriorityLevelInRoutingQueue(bedBO);
        }

        // 处理 排队中 患者
@@ -460,7 +459,7 @@
            bedBO.readyPatNum.incrementAndGet();

            // 可能已经【并发的】在 nextPatient 中改变了分流队列顺序
            refreshRoutingQueue(bedBO);
            refreshBedPriorityLevelInRoutingQueue(bedBO);
        }
    }

@@ -530,7 +529,7 @@
        }

        // 改变了分流队列顺序
        refreshRoutingQueue(bedBO);
        refreshBedPriorityLevelInRoutingQueue(bedBO);
    }

    /**
@@ -575,7 +574,7 @@
        return ret;
    }

    private void addRoutingQueue(BedBO bedBO) {
    private void addBedToRoutingQueue(BedBO bedBO) {
        // 装机工位 不进 分流队列，不接收 【排队中】患者分流
        if (Objects.equals(BedOpTypeEnum.OP_INSTALL.getOpType(), bedBO.getOpType()))
            return;
@@ -604,7 +603,7 @@
        });
    }

    private void removeRoutingQueue(BedBO bedBO) {
    private void removeBedFromRoutingQueue(BedBO bedBO) {
        // 装机工位 不进 分流队列，不接收 【排队中】患者分流
        if (Objects.equals(BedOpTypeEnum.OP_INSTALL.getOpType(), bedBO.getOpType()))
            return;
@@ -617,7 +616,7 @@
        });
    }

    private void refreshRoutingQueue(BedBO bedBO) {
    private void refreshBedPriorityLevelInRoutingQueue(BedBO bedBO) {
        // 装机工位 不进 分流队列，不接收 【排队中】患者分流
        if (Objects.equals(BedOpTypeEnum.OP_INSTALL.getOpType(), bedBO.getOpType()))
            return;