package cn.lihu.jh.module.ecg.service.callingscreen;
|
|
import cn.lihu.jh.framework.common.pojo.PageResult;
|
import cn.lihu.jh.module.ecg.controller.admin.checktype.vo.CheckTypePageReqVO;
|
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.room.RoomDO;
|
import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.queue.QueueMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.room.RoomMapper;
|
import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
import org.springframework.validation.annotation.Validated;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 排队 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
@Slf4j
|
public class CallingScreenServiceImpl implements CallingScreenService {
|
|
@Resource
|
private QueueMapper queueMapper;
|
|
@Resource
|
private RoomMapper roomMapper;
|
|
/**
|
* 需求1：用于回填患者信息（性别/出生日期/病区/床号/电话/来源/开单医师等）。
|
* <p>
|
* 下列屏幕查询是**直接查 queueMapper** 的，不经过 QueueService 的查询方法，
|
* 因此必须显式调用 fillAppointmentInfo 补齐；否则大屏/诊间屏只有姓名。
|
*/
|
@Resource
|
private cn.lihu.jh.module.ecg.service.queue.QueueService queueService;
|
|
@Resource
|
private CheckTypeMapper checkTypeMapper;
|
|
BigScreenConfig bigScreenConfig;
|
|
Map<Integer, Integer> mapCheckTypeVsDisplayColumn = null;
|
|
Integer waitingFrom = 0;
|
Integer passedFrom = 0;
|
|
@Override
|
public void setBigScreenConfig(BigScreenConfig bigScreenConfig) {
|
this.bigScreenConfig = bigScreenConfig;
|
}
|
|
|
@Override
|
public Map<Integer, List<String>> getDisplayColInfo() {
|
CheckTypePageReqVO checkTypePageReqVO = new CheckTypePageReqVO();
|
checkTypePageReqVO.setPageSize(-1);
|
checkTypePageReqVO.setCallingColumn(-1); // 列号 -1 的不显示
|
PageResult<CheckTypeDO> pageResult = checkTypeMapper.selectPageForCallingScreen(checkTypePageReqVO);
|
|
// 显示列 包含的检查类型列表
|
Map<Integer, List<CheckTypeDO>> mapDisplayColName = pageResult.getList().stream().
|
collect(
|
Collectors.groupingBy(
|
CheckTypeDO::getCallingColumn,
|
Collectors.collectingAndThen(
|
Collectors.toList(),
|
list -> list.stream().sorted(Comparator.comparing(CheckTypeDO::getId)).toList()
|
)
|
)
|
);
|
|
// 检查类型 对应的显示列
|
mapCheckTypeVsDisplayColumn = pageResult.getList().stream().collect(Collectors.toMap(CheckTypeDO::getValue, item -> item.getCallingColumn()));
|
|
// 显示列 对应的检查类型名列表
|
Map<Integer, List<String>> _map = new HashMap<>();
|
mapDisplayColName.keySet().forEach(key -> {
|
List<String> displayColNameList = mapDisplayColName.get(key).stream().map(item->item.getName()+item.getSeqPrefix()).toList();
|
_map.put(key, displayColNameList);
|
});
|
return _map;
|
}
|
|
/**
|
* 大屏显示的患者信息
|
* 不会有安装相关的患者信息
|
*/
|
@Override
|
public Map<Integer, List<QueueDO>> getBigScreenPatient() {
|
Map<Integer, List<QueueDO>> mapDisplayColQueue = new HashMap<>();
|
|
// 【修复 NPE】按**真实 calling_column 值**建键，而不是 0..count-1。
|
//
|
// 原实现：
|
// int displayColCnt = distinct().count(); // 例如 = 5
|
// for (i = 0; i < displayColCnt; i++) put(i, ...); // 建键 0,1,2,3,4
|
// 但下面取值用的是**真实 calling_column**（如 0,1,3,4,-1），
|
// 其中 -1（表示"不在大屏显示"）永远不会被建键 → get(-1) 返回 null → NPE，
|
// 导致**整个大屏接口 500、整屏空白**。实测 check_type 中有 7 个类型的
|
// calling_column = -1（700/800/900/1200/1300/1400/1500），只要这些类型有患者
|
// 在排队，就会触发（大屏 SQL 无 check_type 过滤，必然被捞出）。
|
//
|
// 修复后：只为**有效的显示列**（>=0）建键；-1 的类型在大屏不显示，
|
// 由下方 col 判定跳过，不再产生 NPE。
|
//
|
// 【健壮性】mapCheckTypeVsDisplayColumn 仅在 getDisplayColInfo() 中赋值
|
// （声明处为 null）。正常启动流程由 MySpringEventListener 调用该方法初始化，
|
// 但若启动阶段该调用未成功（例如 CheckTypeMapper 查询异常），
|
// 这里会直接 NPE → 大屏再次 500。故先判空并惰性初始化。
|
if (null == mapCheckTypeVsDisplayColumn) {
|
log.warn("[getBigScreenPatient] 显示列映射尚未初始化，尝试惰性初始化");
|
try {
|
getDisplayColInfo();
|
} catch (Exception e) {
|
log.error("[getBigScreenPatient] 显示列映射初始化失败，返回空结果", e);
|
return mapDisplayColQueue; // 返回空 map，前端展示空屏而非 500
|
}
|
}
|
mapCheckTypeVsDisplayColumn.values().stream()
|
.filter(col -> col != null && col >= 0)
|
.distinct()
|
.forEach(col -> mapDisplayColQueue.put(col, new ArrayList<>()));
|
|
List<Integer> queueStatusList = new ArrayList<>();
|
queueStatusList.add(QueueStatusEnum.READY.getStatus());
|
queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
|
queueStatusList.add(QueueStatusEnum.WAITING.getStatus());
|
queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());
|
queueStatusList.add(QueueStatusEnum.PASSED.getStatus());
|
queueStatusList.add(QueueStatusEnum.PASSED_WAITING.getStatus());
|
queueStatusList.add(QueueStatusEnum.AFFINITY.getStatus());
|
List<QueueDO> queueDOList = queueMapper.getBigScreenQueueByStatus( queueStatusList );
|
// 需求1：回填患者信息（性别/出生日期/病区/床号/电话/来源/开单医师等）
|
queueService.fillAppointmentInfo(queueDOList);
|
queueDOList.forEach(queueDO -> {
|
Integer col = mapCheckTypeVsDisplayColumn.get(queueDO.getBookCheckType());
|
// 双重防御：映射缺失或列为 -1（不显示）时跳过，避免 NPE
|
if (col == null || col < 0) {
|
return;
|
}
|
List<QueueDO> columnQueueData = mapDisplayColQueue.get(col);
|
if (columnQueueData == null) {
|
log.warn("[getBigScreenPatient][显示列未初始化，已跳过] checkType={} callingColumn={}",
|
queueDO.getBookCheckType(), col);
|
return;
|
}
|
columnQueueData.add( queueDO );
|
});
|
|
mapDisplayColQueue.values().forEach( _queueDOList -> {
|
//把 [亲和的] 挪到主项后面
|
List<QueueDO> affinityWaitingList = new ArrayList<>();
|
ListIterator<QueueDO> iterator = _queueDOList.listIterator();
|
while (iterator.hasNext()) {
|
QueueDO item = iterator.next();
|
if (item.getStatus() == QueueStatusEnum.AFFINITY.getStatus()) {
|
iterator.remove();
|
affinityWaitingList.add(item);
|
}
|
}
|
affinityWaitingList.forEach( affinityWaitingItem -> {
|
for (int i = _queueDOList.size()-1; i >= 0; i--) {
|
if ( affinityWaitingItem.getSeqNum() == _queueDOList.get(i).getSeqNum() ) {
|
_queueDOList.add(i + 1, affinityWaitingItem);
|
break;
|
}
|
}
|
});
|
});
|
|
return mapDisplayColQueue;
|
}
|
|
@Override
|
public List<QueueDO> getRoomCheckRelatedPatient(String ip, Long roomId) {
|
if (null == roomId) {
|
List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
|
Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
|
if (!optionalQueueDO.isPresent()) {
|
return new ArrayList<QueueDO>();
|
}
|
roomId = optionalQueueDO.get().getRoomId();
|
}
|
|
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());
|
// 【需求8 修复】补上「已过号-排队」(3)。
|
//
|
// 需求原文：「过号患者应出现在**大屏和诊间屏**」，且「过号与等待中排在一起、按序号升序」。
|
// 大屏的 getBigScreenPatient 已含 PASSED_WAITING(3)，但本方法（诊间屏）**漏了**，
|
// 导致 status=3 的患者在大屏可见、在诊间屏不可见。
|
//
|
// 实测复现（构造 seq 1~5 共 5 位患者，含 status=3 与 5）：
|
// 大屏返回 5 位 ✅ ；诊间屏返回 4 位（缺 status=3 那位）🔴
|
//
|
// 排序无需额外处理：getRoomQueueByStatus 的 order by 已把 status in (3,5) 归为同一组
|
// （排在就诊中之后、候诊之前），组内再按 seq_num、book_timeslot 升序 —— 正合需求。
|
queueStatusList.add(QueueStatusEnum.PASSED_WAITING.getStatus());
|
queueStatusList.add(QueueStatusEnum.AFFINITY.getStatus());
|
List<QueueDO> queueDOList = queueMapper.getRoomQueueByStatus(roomId, queueStatusList);
|
// 需求1：回填患者信息（诊间屏-检查队列）
|
queueService.fillAppointmentInfo(queueDOList);
|
|
//把 [亲和的] 挪到主项后面
|
List<QueueDO> affinityWaitingList = new ArrayList<>();
|
ListIterator<QueueDO> iterator = queueDOList.listIterator();
|
while (iterator.hasNext()) {
|
QueueDO item = iterator.next();
|
if (item.getStatus() == QueueStatusEnum.AFFINITY.getStatus()) {
|
iterator.remove();
|
affinityWaitingList.add(item);
|
}
|
}
|
affinityWaitingList.forEach( affinityWaitingItem -> {
|
for (int i = queueDOList.size()-1; i >= 0; i--) {
|
if ( affinityWaitingItem.getSeqNum() == queueDOList.get(i).getSeqNum() ) {
|
queueDOList.add(i + 1, affinityWaitingItem);
|
break;
|
}
|
}
|
});
|
|
return queueDOList;
|
}
|
|
/**
|
* 诊间屏 安装患者列表
|
*/
|
@Override
|
public List<QueueDO> getRoomInstallRelatedPatient(String ip, Long roomId) {
|
if (null == roomId) {
|
List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
|
Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
|
if (!optionalQueueDO.isPresent()) {
|
return new ArrayList<QueueDO>();
|
}
|
|
roomId = optionalQueueDO.get().getRoomId();
|
}
|
|
List<Integer> queueStatusList = new ArrayList<>();
|
queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus());
|
queueStatusList.add(QueueStatusEnum.PASSED_INSTALL.getStatus());
|
queueStatusList.add(QueueStatusEnum.AFFINITY_INSTALL.getStatus());
|
queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus());
|
queueStatusList.add(QueueStatusEnum.RECALLED_INSTALL.getStatus());
|
List<QueueDO> queueDOList = queueMapper.getRoomQueueByStatus(roomId, queueStatusList);
|
// 需求1：回填患者信息（诊间屏-装机队列）
|
queueService.fillAppointmentInfo(queueDOList);
|
|
//把 [亲和的] 挪到主项后面
|
List<QueueDO> affinityReceivedList = new ArrayList<>();
|
ListIterator<QueueDO> iterator = queueDOList.listIterator();
|
while (iterator.hasNext()) {
|
QueueDO item = iterator.next();
|
if (item.getStatus() == QueueStatusEnum.AFFINITY_INSTALL.getStatus()) {
|
iterator.remove();
|
affinityReceivedList.add(item);
|
}
|
}
|
affinityReceivedList.forEach( affinityReceivedItem -> {
|
for (int i = queueDOList.size()-1; i >= 0; i--) {
|
if ( affinityReceivedItem.getSeqNum() == queueDOList.get(i).getSeqNum() ) {
|
queueDOList.add(i + 1, affinityReceivedItem);
|
break;
|
}
|
}
|
});
|
|
return queueDOList;
|
}
|
|
}
|
