动态心电装拆管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
eight
2024-11-07 e36c1e2363e36a69a3cc8ccbc00d28b16f926abd 
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java


@@ -16,6 +16,7 @@


import cn.lihu.jh.module.ecg.dal.mysql.room.RoomMapper;


import cn.lihu.jh.module.ecg.enums.BedStatusEnum;


import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;


import cn.lihu.jh.module.infra.api.config.ConfigApi;


import cn.lihu.jh.module.system.api.oauth2.OAuth2TokenApi;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Component;


@@ -29,6 +30,7 @@




import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception;


import static cn.lihu.jh.framework.common.pojo.CommonResult.error;


import static cn.lihu.jh.module.ecg.Constants.*;


import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;




/**


@@ -40,6 +42,9 @@


@Validated


@Slf4j


public class QueueServiceTxFunctions {




    @Resource


    private ConfigApi configApi;




    @Resource


    private OAuth2TokenApi oAuth2TokenApi;


@@ -95,7 +100,7 @@


            return ROOM_INVALID_STATUS;


        }




        List<Byte> queueStatusList = new ArrayList<>();


        List<Integer> queueStatusList = new ArrayList<>();


        queueStatusList.add(QueueStatusEnum.READY.getStatus());


        List<QueueDO> queueDOList = queueMapper.getBedQueueByStatus(roomId, bedNo, queueStatusList);




@@ -126,7 +131,7 @@


        // 除了判断 准备候诊中 的人数，还需要 判断 过号的人数


        //if (bedQueueBO.getQueueNum().get() >0)


        //    return QUEUE_HAVE_PATIENT;


        List<Byte> queueStatusList = new ArrayList<>();


        List<Integer> queueStatusList = new ArrayList<>();


        queueStatusList.add(QueueStatusEnum.READY.getStatus());


        queueStatusList.add(QueueStatusEnum.PASSED.getStatus());


        queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());


@@ -240,7 +245,7 @@




    // 常规 或者 领用 时 医生 取下一位患者


    public ErrorCode nextPatient(Long roomId, String bedNo) {


        // 从 DB 把 序号最小的 [就诊准备中] 的人 设置为 [就诊中] (或领用中)


        // 从 DB 把该工位.序号最小的 [就诊准备中] 的人 设置为 [就诊中] (或领用中)


        Integer updateNum = queueMapper.updateBedQueueStatus(roomId, bedNo,


                QueueStatusEnum.READY.getStatus(), QueueStatusEnum.ONSTAGE.getStatus());


        // 该工位 没有 [就诊准备中] 人员


@@ -298,7 +303,7 @@


        List<BedQueueBO> bedQueueBOList = roomDOList.stream().map(item -> BeanUtils.toBean(item, BedQueueBO.class)).toList();




        // 从DB 获取 队列中 就诊准备中人员统计 列表


        List<Byte> queueStatusList = new ArrayList<>();


        List<Integer> queueStatusList = new ArrayList<>();


        queueStatusList.add(QueueStatusEnum.READY.getStatus());


        List<QueueStatisticDO> queueStatisticDOList = queueMapper.queueStatistic(queueStatusList);