package cn.lihu.jh.module.ecg.service.devrent;
|
|
import cn.lihu.jh.framework.common.pojo.CommonResult;
|
import cn.lihu.jh.framework.common.pojo.PageResult;
|
import cn.lihu.jh.framework.common.util.object.BeanUtils;
|
import cn.lihu.jh.framework.security.core.util.SecurityFrameworkUtils;
|
import cn.lihu.jh.module.ecg.controller.admin.devrent.vo.*;
|
import cn.lihu.jh.module.ecg.controller.admin.jobrecord.vo.JobRecordSaveReqVO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.appointment.AppointmentDO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.devmanage.DeviceDO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.devrent.DevRentDO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.jobrecord.JobRecordDO;
|
import cn.lihu.jh.module.ecg.dal.dataobject.patient.PatDetails;
|
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
|
import cn.lihu.jh.module.ecg.dal.mysql.appointment.AppointmentMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.devmanage.DeviceMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.devrent.DevRentMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.jobrecord.JobRecordMapper;
|
import cn.lihu.jh.module.ecg.dal.mysql.queue.QueueMapper;
|
import cn.lihu.jh.module.ecg.enums.DevRentStateEnum;
|
import cn.lihu.jh.module.ecg.enums.DevStateEnum;
|
import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;
|
import cn.lihu.jh.module.ecg.feign.FeeConfirmFeignService;
|
import cn.lihu.jh.module.ecg.service.queue.QueueServiceTxFunctions;
|
import cn.lihu.jh.module.ecg.webservice.WebServiceClient;
|
import cn.lihu.jh.module.infra.dal.dataobject.config.ConfigDO;
|
import cn.lihu.jh.module.infra.dal.mysql.config.ConfigMapper;
|
import cn.lihu.jh.module.infra.service.config.ConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import static cn.lihu.jh.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*;
|
|
/**
|
* 装机拆机 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
@Slf4j
|
public class DevRentServiceImpl implements DevRentService {
|
|
@Resource
|
QueueServiceTxFunctions queueServiceTxFunctions;
|
|
@Resource
|
private FeeConfirmFeignService feeConfirmFeignService;
|
|
@Resource
|
private DevRentMapper devRentMapper;
|
|
@Resource
|
private JobRecordMapper jobRecordMapper;
|
|
@Resource
|
DeviceMapper deviceMapper;
|
|
@Resource
|
AppointmentMapper appointmentMapper;
|
|
@Resource
|
QueueMapper queueMapper;
|
|
@Resource
|
CheckTypeMapper checkTypeMapper;
|
|
@Resource
|
private ConfigService configService;
|
|
@Autowired
|
private WebServiceClient webServiceClient;
|
|
/** 【本需求】紧急加做的备注标记，便于在完成列表/报表里区分这类"不排队直接检查"的记录 */
|
private static final String EMERGENCY_REMARK = "紧急加做";
|
|
|
@Override
|
public CommonResult<Long> registerOperation(DevRentSaveReqVO createReqVO) {
|
Long rent_id = createDevRent(createReqVO);
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> routineFinishOperation(RoutineFinishReqVO routineFinishReqVO) {
|
DevRentSaveReqVO createReqVO = BeanUtils.toBean(routineFinishReqVO, DevRentSaveReqVO.class);
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
String userHisId = SecurityFrameworkUtils.getLoginUserHisId();
|
|
// 【本需求：紧急患者不排队直接检查】
|
// 正常患者的「待检查(0)」检查单是签到建队列时一起插的；紧急加做的患者没走签到，
|
// 因此这里先把这条单补出来，后续逻辑（写作业记录、更新队列、回写集成平台）完全复用。
|
if (Boolean.TRUE.equals(routineFinishReqVO.getEmergency())) {
|
prepareEmergencyDevRent(routineFinishReqVO, createReqVO);
|
}
|
|
// 在预约确认时 就进入 [dev_rent] 表了
|
Long rent_id = createReqVO.getId();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.ROUTINE_FINISH.getState());
|
jobTypeList.add(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState());
|
|
// 【本次修复】撤销后再次完成时的兜底：
|
// 若「待检查(0)」的单子不存在（撤销时没能回滚到 0、或历史数据），
|
// 不能再直接报「请先预约确认」，否则医生无法把误完成的患者重新完成。
|
// 这里复用**今日最近一条**「常规检查完成(60)/常规检查放弃(50)」的单；
|
// 且如果该单已经有完成记录，就走下面的"更新"分支，避免重复插入 job_record。
|
if (devRentDOList.isEmpty()) {
|
List<Integer> fallbackStateList = new ArrayList<>();
|
fallbackStateList.add(DevRentStateEnum.ROUTINE_FINISH.getState());
|
fallbackStateList.add(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
DevRentDO fallbackRent = devRentMapper.selectLatestByPatCheckTypeStates(
|
createReqVO.getPatId(), createReqVO.getCheckType(), fallbackStateList);
|
if (null == fallbackRent) {
|
throw exception(DEV_INSTALL_NOT_APPOINTMENT);
|
}
|
log.warn("[routineFinishOperation] 「待检查」单不存在，兜底复用最近一条已完成/已放弃单. "
|
+ "rentId={} patId={} checkType={}",
|
fallbackRent.getId(), createReqVO.getPatId(), createReqVO.getCheckType());
|
devRentDOList = new ArrayList<>(List.of(fallbackRent));
|
jobRecordDO = jobRecordMapper.selectByRentIdDocId(fallbackRent.getId(), userId, jobTypeList);
|
if (null != jobRecordDO) {
|
rent_id = fallbackRent.getId();
|
createReqVO.setId(rent_id);
|
}
|
}
|
|
if (null != jobRecordDO) {
|
// 兜底命中已有完成记录 → 落到下方"更新"分支（与 else 分支同样的处理）
|
} else {
|
if (devRentDOList.size() != 1) {
|
throw exception(DEV_INSTALL_EXCEPTION);
|
}
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.ROUTINE_FINISH.getState());
|
updateDevRent(createReqVO);
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(createReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.ROUTINE_FINISH.getState());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
}
|
}
|
if (null != jobRecordDO) {
|
// 撤销 放弃操作
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.ROUTINE_FINISH.getState());
|
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(createReqVO.getDevId());
|
jobRecordDO.setJobType(DevRentStateEnum.ROUTINE_FINISH.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
|
// 更新..队列状态
|
//queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(),
|
// QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.FINISH.getStatus());
|
|
// 【缺陷修复】原实现：
|
// QueueDO firstOnStageQueueItem = queueMapper.getBedFirstQueueItemByStatus(
|
// roomId, bedNo, ONSTAGE);
|
// firstOnStageQueueItem.setStatus(FINISH); // ← 取不到时为 null，直接 NPE
|
//
|
// 两个问题：
|
// 1) NPE：该工位当前没有"就诊中(30)"患者时返回 null（例如医生先点了"放弃检查"，
|
// cancelRoutineOperation 已把该患者置为 40），第 159 行空指针 → 整个事务回滚。
|
// 2) 误伤：只按"工位 + 状态取 seq_num 最小的一条"，若期间已叫了下一位患者，
|
// 会把**下一位患者**误置为"已就诊(40)"。
|
//
|
// 修复策略（按可靠性从高到低）：
|
// ① 优先按 patId + checkType 精确匹配（前端 submitForm 传的 formData 含这两个字段）；
|
// ② 退化到"工位 + 状态 + 今日"取 update_time 最新的一条（比 seq_num 最小更贴合当前患者）；
|
// ③ 仍取不到 → 记警告并**跳过队列更新**，而不是抛 NPE 让整个"检查完成"失败。
|
// 此时设备归还、作业记录等仍会正常保存（数据不丢），仅队列状态未变。
|
QueueDO onStageQueueItem = null;
|
|
// ① 精确定位（用 Spring 的 StringUtils，避免额外依赖；
|
// 本模块未引入 commons-lang3，勿用 org.apache.commons.lang3.StringUtils）
|
if (org.springframework.util.StringUtils.hasText(createReqVO.getPatId())
|
&& null != createReqVO.getCheckType()) {
|
onStageQueueItem = queueMapper.getBedQueueItemByPatAndStatus(
|
createReqVO.getRoomId(), createReqVO.getBedNo(),
|
createReqVO.getPatId(), createReqVO.getCheckType(),
|
QueueStatusEnum.ONSTAGE.getStatus());
|
}
|
|
// ② 退化：取该工位今日最近更新的一条"就诊中"
|
if (null == onStageQueueItem) {
|
onStageQueueItem = queueMapper.getBedLatestQueueItemByStatus(
|
createReqVO.getRoomId(), createReqVO.getBedNo(), QueueStatusEnum.ONSTAGE.getStatus());
|
if (null != onStageQueueItem) {
|
log.warn("[routineFinish] 未按 patId 命中，退化为按工位取最近就诊中患者. "
|
+ "roomId={} bedNo={} reqPatId={} reqCheckType={} 实际patId={} checkType={}",
|
createReqVO.getRoomId(), createReqVO.getBedNo(), createReqVO.getPatId(),
|
createReqVO.getCheckType(), onStageQueueItem.getPatId(),
|
onStageQueueItem.getBookCheckType());
|
}
|
}
|
|
// ③ 仍取不到：跳过队列更新，不抛异常（保证"检查完成"本身可用）
|
if (null == onStageQueueItem) {
|
log.warn("[routineFinish] 该工位无[就诊中]患者，跳过队列状态更新. roomId={} bedNo={} patId={} applyNo={}",
|
createReqVO.getRoomId(), createReqVO.getBedNo(),
|
createReqVO.getPatId(), createReqVO.getApplyNo());
|
} else {
|
// QueueStatusEnum.ONSTAGE => QueueStatusEnum.FINISH
|
onStageQueueItem.setStatus(QueueStatusEnum.FINISH.getStatus());
|
queueMapper.updateById(onStageQueueItem);
|
|
// 检查项目.亲和性 处理逻辑
|
CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem(onStageQueueItem.getBookCheckType());
|
if (null != checkTypeDO && null != checkTypeDO.getAffinityCheckTypes()
|
&& checkTypeDO.getAffinityCheckTypes().length > 0) {
|
procAffinityWhenRoutineFinish(onStageQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes());
|
}
|
}
|
|
//检查完成后，此时检查登记写成了，需要将这个回写给集成平台(线上环境才回写)
|
ConfigDO configDO = configService.getConfigByKey("ecg.back.data");
|
if (configDO.getValue().equals("1")) {
|
if (createReqVO.getCheckType() != 100 && createReqVO.getCheckType() != 1000 && createReqVO.getCheckType() != 1100 && createReqVO.getCheckType() != 1400 && createReqVO.getCheckType() != 1500) {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(createReqVO.getApplyNo());
|
ApplicationTemplate app = new ApplicationTemplate();
|
String action = "S0405";
|
String message = app.getXML(createReqVO.getApplyNo(), "3", "检查登记", createReqVO.getOperater(), appointmentDO.getPatDeptCode(), appointmentDO.getPatDeptDesc(), appointmentDO.getPatWardCode(), appointmentDO.getPatWardDesc(), appointmentDO.getPatBedNo(), appointmentDO.getEpisodeId(), "" + appointmentDO.getBookSrc(), appointmentDO.getPatId(), appointmentDO.getPatName());
|
String s = webServiceClient.callJHFWTYRK(action, "", message);
|
log.info("routineFinishWebServiceClient的返回值为：{}", s);
|
if (s.contains("更新成功")) {
|
//需要根据applyNo,将appiontment表里的status改成3
|
// 【诊断日志】同 AppointmentServiceImpl#handleAppointmentStatusUpdate：
|
// 打印日期对象类型与值，便于定位 register_date 被写成 00:00:00 的写入方。
|
java.util.Date regNow = new Date();
|
log.info("[devRentCreate][登记时间写入] applyNo={} 日期对象类型={} 值={}",
|
createReqVO.getApplyNo(), regNow.getClass().getName(),
|
new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(regNow));
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "3", regNow);
|
}
|
} else {
|
//检查类型是床边的或常规的，需要根据applyNo,将appiontment表里的status改成7
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "7", null);
|
}
|
}
|
|
return CommonResult.success(rent_id);
|
}
|
|
/**
|
* 【本需求：紧急患者不排队直接检查】为「紧急加做」的患者准备「待检查(0)」检查单。
|
*
|
* <h3>为什么需要它</h3>
|
* 正常患者的 {@code dev_rent(state=0)} 行是**签到建队列**时一起插入的（见
|
* {@code QueueServiceImpl#queue}）。紧急加做的患者不走签到/排队，所以完成时找不到这行，
|
* 原逻辑会直接抛 {@code DEV_INSTALL_NOT_APPOINTMENT}（"请先预约确认"）。
|
*
|
* <h3>做法</h3>
|
* <ol>
|
* <li>今天已有该患者 + 检查项目的「待检查」行 → 什么都不做（走正常流程）；</li>
|
* <li>否则按**预约单**（申请单号优先，其次患者编号 + 检查项目，近 ±30 天）补建一行；</li>
|
* <li>同时把备注补上「紧急加做」，便于在完成列表/报表里区分。</li>
|
* </ol>
|
* 预约单不存在或检查项目不匹配时**不补建**，让原逻辑照常报错，避免产生脏数据。
|
*/
|
private void prepareEmergencyDevRent(RoutineFinishReqVO req, DevRentSaveReqVO createReqVO) {
|
// 备注统一打标（原备注保留）
|
String remark = createReqVO.getRemark();
|
if (org.springframework.util.StringUtils.hasText(remark)) {
|
if (!remark.contains(EMERGENCY_REMARK)) {
|
createReqVO.setRemark(EMERGENCY_REMARK + "；" + remark);
|
}
|
} else {
|
createReqVO.setRemark(EMERGENCY_REMARK);
|
}
|
|
if (org.springframework.util.StringUtils.hasText(req.getPatId()) && null != req.getCheckType()) {
|
List<DevRentDO> existList = devRentMapper.selectByPatAndChecktypeAndState(
|
req.getPatId(), req.getCheckType(), DevRentStateEnum.FREE.getState());
|
if (!existList.isEmpty()) {
|
log.info("[prepareEmergencyDevRent] 今日已有待检查单，按正常流程完成. patId={} checkType={} 条数={}",
|
req.getPatId(), req.getCheckType(), existList.size());
|
return;
|
}
|
}
|
|
AppointmentDO appointment = findEmergencyAppointment(req);
|
if (null == appointment) {
|
log.warn("[prepareEmergencyDevRent] 未找到可用的预约单，跳过补建（原逻辑将报「请先预约确认」）. "
|
+ "applyNo={} patId={} checkType={}", req.getApplyNo(), req.getPatId(), req.getCheckType());
|
return;
|
}
|
|
DevRentDO devRent = new DevRentDO();
|
devRent.setApplyNo(nonBlank(appointment.getApplyNo(), req.getApplyNo()));
|
devRent.setEpisodeId(nonBlank(appointment.getEpisodeId(), req.getEpisodeId()));
|
devRent.setPatId(nonBlank(appointment.getPatId(), req.getPatId()));
|
devRent.setPatName(nonBlank(appointment.getPatName(), req.getPatName()));
|
devRent.setCheckType(appointment.getBookCheckType());
|
devRent.setPaid(appointment.getPaid());
|
devRent.setState(DevRentStateEnum.FREE.getState());
|
devRent.setRemark(createReqVO.getRemark());
|
devRentMapper.insert(devRent);
|
|
// 让后续「按患者 + 检查项目 + 今日 + 待检查」能正常定位到
|
createReqVO.setId(devRent.getId());
|
createReqVO.setApplyNo(devRent.getApplyNo());
|
createReqVO.setEpisodeId(devRent.getEpisodeId());
|
// 检查项目以预约单为准；预约单没写时才沿用请求里的值（避免把 checkType 置空导致后续报错）
|
if (null != devRent.getCheckType()) {
|
createReqVO.setCheckType(devRent.getCheckType());
|
}
|
if (null == createReqVO.getPaid()) {
|
createReqVO.setPaid(devRent.getPaid());
|
}
|
log.info("[prepareEmergencyDevRent] 紧急加做：已补建「待检查」检查单. rentId={} patId={} checkType={} applyNo={}",
|
devRent.getId(), devRent.getPatId(), devRent.getCheckType(), devRent.getApplyNo());
|
}
|
|
/** 紧急加做：定位要用哪张预约单（申请单号优先，其次患者编号 + 检查项目，近 ±30 天，取最近的） */
|
private AppointmentDO findEmergencyAppointment(RoutineFinishReqVO req) {
|
// ① 申请单号能直接命中
|
if (org.springframework.util.StringUtils.hasText(req.getApplyNo())) {
|
AppointmentDO byApplyNo = appointmentMapper.getByApplyNo(req.getApplyNo());
|
if (null != byApplyNo && matchesCheckType(byApplyNo, req.getCheckType())) {
|
return byApplyNo;
|
}
|
}
|
// ② 按患者编号 + 检查项目，取最近一张
|
if (org.springframework.util.StringUtils.hasText(req.getPatId()) && null != req.getCheckType()) {
|
List<Integer> one = new ArrayList<>();
|
one.add(req.getCheckType());
|
List<AppointmentDO> candidates = appointmentMapper.getEmergencyCandidates(req.getPatId(), one);
|
if (!candidates.isEmpty()) {
|
return candidates.get(0);
|
}
|
}
|
return null;
|
}
|
|
private boolean matchesCheckType(AppointmentDO appointment, Integer checkType) {
|
return null == checkType || null == appointment.getBookCheckType()
|
|| checkType.equals(appointment.getBookCheckType());
|
}
|
|
private String nonBlank(String first, String second) {
|
return org.springframework.util.StringUtils.hasText(first) ? first : second;
|
}
|
|
/**
|
* 领用完成 操作
|
*
|
* @param createReqVO 创建信息
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> readyOperation(DevRentSaveReqVO createReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 在预约确认时 就进入 [dev_rent] 表了
|
Long rent_id = createReqVO.getId(); // dev_rent 表的ID
|
|
// 标注设备 已领取
|
Integer ret = markDevRecieved(createReqVO.getDevId(), rent_id, createReqVO.getPatDetails());
|
if (null == ret || 0 == ret) {
|
throw exception(DEVICE_NOT_FREE);
|
}
|
|
//设备领取完成后，此时检查登记写成了，需要将这个回写给集成平台(线上环境才回写)
|
ConfigDO configDO = configService.getConfigByKey("ecg.back.data");
|
if (configDO.getValue().equals("1")) {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(createReqVO.getApplyNo());
|
ApplicationTemplate app = new ApplicationTemplate();
|
String action = "S0405";
|
String message = app.getXML(createReqVO.getApplyNo(), "3", "检查登记", createReqVO.getOperater(), appointmentDO.getPatDeptCode(), appointmentDO.getPatDeptDesc(), appointmentDO.getPatWardCode(), appointmentDO.getPatWardDesc(), appointmentDO.getPatBedNo(), appointmentDO.getEpisodeId(), "" + appointmentDO.getBookSrc(), appointmentDO.getPatId(), appointmentDO.getPatName());
|
String s = webServiceClient.callJHFWTYRK(action, "", message);
|
log.info("webservice的返回值为：{}", s);
|
if (s.contains("更新成功")) {
|
//需要根据applyNo,将appiontment表里的status改成3
|
// 【诊断日志】同上：打印日期对象类型与值
|
java.util.Date regNow2 = new Date();
|
log.info("[devRentOther][登记时间写入] applyNo={} 日期对象类型={} 值={}",
|
createReqVO.getApplyNo(), regNow2.getClass().getName(),
|
new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(regNow2));
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "3", regNow2);
|
}
|
}
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.RECEIVED.getState());
|
jobTypeList.add(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState());
|
if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_APPOINTMENT);
|
else if (devRentDOList.size() != 1) {
|
throw exception(DEV_INSTALL_EXCEPTION);
|
}
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.RECEIVED.getState());
|
updateDevRent(createReqVO);
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(createReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.RECEIVED.getState());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
// 撤销 放弃操作
|
createReqVO.setState(DevRentStateEnum.RECEIVED.getState());
|
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(createReqVO.getDevId());
|
jobRecordDO.setJobType(DevRentStateEnum.RECEIVED.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
|
// 更新..队列状态
|
//queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(),
|
// QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.RECEIVED.getStatus());
|
|
// QueueStatusEnum.ONSTAGE => QueueStatusEnum.RECEIVED
|
QueueDO bedOnStageQueueItem = queueMapper.getBedFirstQueueItemByStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), QueueStatusEnum.ONSTAGE.getStatus());
|
CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem(bedOnStageQueueItem.getBookCheckType());
|
bedOnStageQueueItem.setStatus(QueueStatusEnum.RECEIVED.getStatus()); // [已领用] 状态
|
bedOnStageQueueItem.setAffinityItem(0); // 亲和标记 清除，在安装阶段重新亲和
|
|
// 检查项目.亲和性 处理逻辑 , 更新 bedOnStageQueueItem
|
if (checkTypeDO.getAffinityCheckTypes().length > 0) {
|
procAffinityWhenReadyFinish(/*IN, OUT*/bedOnStageQueueItem, checkTypeDO.getAffinityCheckTypes());
|
}
|
|
queueMapper.updateById(bedOnStageQueueItem);
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> installOperation(DevRentSaveReqVO createReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
Long rent_id = createReqVO.getId();
|
|
DevRentDO devRentDO = getDevRent(rent_id);
|
|
// 对于已有领用，但是装机时使用的不是已领用设备，报错
|
if (null != devRentDO.getDevId() && !createReqVO.getDevId().equals(devRentDO.getDevId())) {
|
throw exception(DEVICE_NOT_PAT_RECEIVED);
|
}
|
|
// 设置设备 使用中
|
Integer ret = markDevInUse(createReqVO.getDevId(), rent_id);
|
if (null == ret || 0 == ret) {
|
throw exception(DEVICE_NOT_RECEIVED);
|
}
|
|
// 检查 job_record 用于确认是否是第一次安装操作
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.INSTALLED.getState());
|
jobTypeList.add(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
|
// 第一次 安装操作
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.RECEIVED.getState());
|
if (devRentDOList.size() == 0) throw exception(DEV_INSTALL_NOT_RECEIVED);
|
else if (devRentDOList.size() != 1) {
|
throw exception(DEV_INSTALL_EXCEPTION);
|
}
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.INSTALLED.getState());
|
updateDevRent(createReqVO);
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(createReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.INSTALLED.getState());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
// 撤销 放弃操作
|
createReqVO.setState(DevRentStateEnum.INSTALLED.getState());
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(createReqVO.getDevId());
|
jobRecordDO.setJobType(DevRentStateEnum.INSTALLED.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
|
// 更新..队列状态
|
//queueMapper.updateBedQueueStatus(createReqVO.getRoomId(), createReqVO.getBedNo(),
|
// QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.FINISH.getStatus());
|
|
// QueueStatusEnum.INSTALLING => QueueStatusEnum.FINISH
|
QueueDO bedInstallingQueueItem = queueMapper.getBedFirstQueueItemByStatus(createReqVO.getRoomId(), createReqVO.getBedNo(), QueueStatusEnum.INSTALLING.getStatus());
|
bedInstallingQueueItem.setStatus(QueueStatusEnum.FINISH.getStatus()); // 默认状态 设置
|
queueMapper.updateById(bedInstallingQueueItem);
|
|
// 检查项目.亲和性 处理逻辑
|
CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem(bedInstallingQueueItem.getBookCheckType());
|
if (checkTypeDO.getAffinityCheckTypes().length > 0) {
|
procAffinityWhenInstallFinish(bedInstallingQueueItem, checkTypeDO.getAffinityCheckTypes());
|
}
|
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long dismantleOperation(DevRentSaveReqVO updateReqVO) {
|
updateReqVO.setState(DevRentStateEnum.DISMANTLED.getState());
|
updateDevRent(updateReqVO);
|
Long rentId = updateReqVO.getId();
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
// 设备恢复到空闲
|
markDevFree(updateReqVO.getDevId(), rentId);
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.DISMANTLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList);
|
if (null == jobRecordDO) {
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(updateReqVO.getId());
|
jobRecordSaveReqVO.setDevId(updateReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(updateReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(updateReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(updateReqVO.getReturnTime());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.DISMANTLED.getState());
|
jobRecordSaveReqVO.setRemark(updateReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordSaveReqVO.setCheckType(updateReqVO.getCheckType());
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
jobRecordDO.setJobType(DevRentStateEnum.DISMANTLED.getState());
|
jobRecordDO.setJobTime(updateReqVO.getReturnTime());
|
jobRecordDO.setRemark(updateReqVO.getRemark());
|
jobRecordDO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
return updateReqVO.getId();
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long dataEntryOperation(DevRentSaveReqVO updateReqVO) {
|
updateReqVO.setState(DevRentStateEnum.DATAENTERED.getState());
|
updateDevRent(updateReqVO);
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.DATAENTERED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList);
|
if (null == jobRecordDO) {
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(updateReqVO.getId());
|
jobRecordSaveReqVO.setDevId(updateReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(updateReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(updateReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(updateReqVO.getEntryTime());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.DATAENTERED.getState());
|
jobRecordSaveReqVO.setRemark(updateReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordSaveReqVO.setCheckType(updateReqVO.getCheckType());
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
jobRecordDO.setJobType(DevRentStateEnum.DATAENTERED.getState());
|
jobRecordDO.setJobTime(updateReqVO.getEntryTime());
|
jobRecordDO.setRemark(updateReqVO.getRemark());
|
jobRecordDO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
return updateReqVO.getId();
|
}
|
|
// 常规检查 取消
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> cancelRoutineOperation(DevCancelReqVO cancelReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class);
|
createReqVO.setDevId(null);
|
createReqVO.setState(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
|
Long rent_id = createReqVO.getId();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.ROUTINE_FINISH.getState());
|
jobTypeList.add(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState());
|
if (devRentDOList.size() != 1) throw exception(ROUTINE_CHECK_EXIST);
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
updateDevRent(createReqVO);
|
|
ConfigDO configDO = configService.getConfigByKey("ecg.back.data");
|
if (configDO.getValue().equals("1")) {
|
if (cancelReqVO.getCheckType() != 100 && cancelReqVO.getCheckType() != 1000 && cancelReqVO.getCheckType() != 1100 && cancelReqVO.getCheckType() != 1400 && cancelReqVO.getCheckType() != 1500) {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(createReqVO.getApplyNo());
|
ApplicationTemplate app = new ApplicationTemplate();
|
String action = "S0405";
|
String message = app.getXML(createReqVO.getApplyNo(), "4", "取消检查", createReqVO.getOperater(), appointmentDO.getPatDeptCode(), appointmentDO.getPatDeptDesc(), appointmentDO.getPatWardCode(), appointmentDO.getPatWardDesc(), appointmentDO.getPatBedNo(), appointmentDO.getEpisodeId(), "" + appointmentDO.getBookSrc(), appointmentDO.getPatId(), appointmentDO.getPatName());
|
String s = webServiceClient.callJHFWTYRK(action, "", message);
|
log.info("routineFinishWebServiceClient的返回值为：{}", s);
|
if (s.contains("更新成功")) {
|
//需要根据applyNo,将appiontment表里的status改成3
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "4", null);
|
}
|
} else {
|
//检查类型是床边的或常规的，需要根据applyNo,将appiontment表里的status改成7
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "7", null);
|
}
|
}
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(null);
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(null);
|
jobRecordDO.setJobType(DevRentStateEnum.ROUTINE_CANCELLED.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
QueueDO firstOnStageQueueItem = queueMapper.getBedFirstQueueItemByApplyNo(createReqVO.getApplyNo(), QueueStatusEnum.ONSTAGE.getStatus());
|
// QueueStatusEnum.ONSTAGE => QueueStatusEnum.FINISH
|
firstOnStageQueueItem.setStatus(QueueStatusEnum.FINISH.getStatus()); // 默认状态 设置
|
firstOnStageQueueItem.setUpdateTime(LocalDateTime.now());
|
queueMapper.updateById(firstOnStageQueueItem);
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> cancelReadyOperation(DevCancelReqVO cancelReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
Long rentId = cancelReqVO.getId();
|
|
// 若从 装机 改为 取消装机，恢复设备状态
|
if (null != cancelReqVO.getDevId()) {
|
markDevFree(cancelReqVO.getDevId(), rentId);
|
}
|
|
DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class);
|
createReqVO.setDevId(null);
|
createReqVO.setState(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
|
Long rent_id = createReqVO.getId();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.RECEIVED.getState());
|
jobTypeList.add(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.FREE.getState());
|
if (devRentDOList.size() != 1) throw exception(DEV_INSTALL_EXIST);
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
updateDevRent(createReqVO);
|
|
ConfigDO configDO = configService.getConfigByKey("ecg.back.data");
|
if (configDO.getValue().equals("1")) {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(createReqVO.getApplyNo());
|
ApplicationTemplate app = new ApplicationTemplate();
|
String action = "S0405";
|
String message = app.getXML(createReqVO.getApplyNo(), "4", "取消检查", createReqVO.getOperater(), appointmentDO.getPatDeptCode(), appointmentDO.getPatDeptDesc(), appointmentDO.getPatWardCode(), appointmentDO.getPatWardDesc(), appointmentDO.getPatBedNo(), appointmentDO.getEpisodeId(), "" + appointmentDO.getBookSrc(), appointmentDO.getPatId(), appointmentDO.getPatName());
|
String s = webServiceClient.callJHFWTYRK(action, "", message);
|
log.info("routineFinishWebServiceClient的返回值为：{}", s);
|
if (s.contains("更新成功")) {
|
//需要根据applyNo,将appiontment表里的status改成3
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "4", null);
|
}
|
}
|
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(null);
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(null);
|
jobRecordDO.setJobType(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> cancelInstallOperation(DevCancelReqVO cancelReqVO) {
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
Long rentId = cancelReqVO.getId();
|
|
// 若从 装机 改为 取消装机，恢复设备状态
|
if (null != cancelReqVO.getDevId()) {
|
markDevFree(cancelReqVO.getDevId(), rentId);
|
}
|
|
DevRentSaveReqVO createReqVO = BeanUtils.toBean(cancelReqVO, DevRentSaveReqVO.class);
|
createReqVO.setDevId(null);
|
createReqVO.setState(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
|
Long rent_id = createReqVO.getId();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.INSTALLED.getState());
|
jobTypeList.add(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(rent_id, userId, jobTypeList);
|
if (null == jobRecordDO) {
|
List<DevRentDO> devRentDOList = devRentMapper.selectByPatAndChecktypeAndState(createReqVO.getPatId(), createReqVO.getCheckType(), DevRentStateEnum.RECEIVED.getState());
|
if (devRentDOList.size() != 1) throw exception(DEV_INSTALL_EXIST);
|
|
rent_id = devRentDOList.get(0).getId();
|
createReqVO.setId(rent_id);
|
createReqVO.setState(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
updateDevRent(createReqVO);
|
|
ConfigDO configDO = configService.getConfigByKey("ecg.back.data");
|
if (configDO.getValue().equals("1")) {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(createReqVO.getApplyNo());
|
ApplicationTemplate app = new ApplicationTemplate();
|
String action = "S0405";
|
String message = app.getXML(createReqVO.getApplyNo(), "4", "取消检查", createReqVO.getOperater(), appointmentDO.getPatDeptCode(), appointmentDO.getPatDeptDesc(), appointmentDO.getPatWardCode(), appointmentDO.getPatWardDesc(), appointmentDO.getPatBedNo(), appointmentDO.getEpisodeId(), "" + appointmentDO.getBookSrc(), appointmentDO.getPatId(), appointmentDO.getPatName());
|
String s = webServiceClient.callJHFWTYRK(action, "", message);
|
log.info("routineFinishWebServiceClient的返回值为：{}", s);
|
if (s.contains("更新成功")) {
|
//需要根据applyNo,将appiontment表里的status改成3
|
appointmentMapper.updateStatusByApplyNo(createReqVO.getApplyNo(), "4", null);
|
}
|
}
|
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(rent_id);
|
jobRecordSaveReqVO.setDevId(null);
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(createReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(createReqVO.getPatName());
|
jobRecordSaveReqVO.setJobType(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
jobRecordSaveReqVO.setJobTime(createReqVO.getRentTime());
|
jobRecordSaveReqVO.setRemark(createReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary("");
|
jobRecordSaveReqVO.setCheckType(createReqVO.getCheckType());
|
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
updateDevRent(createReqVO);
|
|
jobRecordDO.setDevId(null);
|
jobRecordDO.setJobType(DevRentStateEnum.INSTALL_CANCELLED.getState());
|
jobRecordDO.setJobTime(createReqVO.getRentTime());
|
jobRecordDO.setRemark(createReqVO.getRemark());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
return CommonResult.success(rent_id);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public CommonResult<Long> dismantleExceptionOperation(DevRentSaveReqVO updateReqVO) {
|
DevStateEnum devStateEnum = null;
|
DevRentStateEnum devRentStateEnum = null;
|
if (updateReqVO.getState() == DevStateEnum.DAMAGED.getState()) {
|
devStateEnum = DevStateEnum.DAMAGED;
|
devRentStateEnum = DevRentStateEnum.DAMAGED;
|
} else if (updateReqVO.getState() == DevStateEnum.LOST.getState()) {
|
devStateEnum = DevStateEnum.LOST;
|
devRentStateEnum = DevRentStateEnum.LOST;
|
} else throw exception(DEV_DISMANTLE_EXCEPTION);
|
|
// 设备遗失时, 标注遗失
|
markDevDismantleException(updateReqVO.getDevId(), updateReqVO.getId(), updateReqVO.getReturnTime().toLocalDate(), devStateEnum);
|
|
updateReqVO.setState(devRentStateEnum.getState());
|
updateDevRent(updateReqVO);
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
String userNickname = SecurityFrameworkUtils.getLoginUserNickname();
|
|
List<Integer> jobTypeList = new ArrayList<Integer>();
|
jobTypeList.add(DevRentStateEnum.DAMAGED.getState());
|
jobTypeList.add(DevRentStateEnum.LOST.getState());
|
JobRecordDO jobRecordDO = jobRecordMapper.selectByRentIdDocId(updateReqVO.getId(), userId, jobTypeList);
|
if (null == jobRecordDO) {
|
JobRecordSaveReqVO jobRecordSaveReqVO = new JobRecordSaveReqVO();
|
jobRecordSaveReqVO.setRentId(updateReqVO.getId());
|
jobRecordSaveReqVO.setDevId(updateReqVO.getDevId());
|
jobRecordSaveReqVO.setDocId(userId);
|
jobRecordSaveReqVO.setDocName(userNickname);
|
jobRecordSaveReqVO.setPatId(updateReqVO.getPatId());
|
jobRecordSaveReqVO.setPatName(updateReqVO.getPatName());
|
jobRecordSaveReqVO.setJobTime(updateReqVO.getReturnTime());
|
jobRecordSaveReqVO.setJobType(devRentStateEnum.getState());
|
jobRecordSaveReqVO.setRemark(updateReqVO.getRemark());
|
jobRecordSaveReqVO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordSaveReqVO.setCheckType(updateReqVO.getCheckType());
|
JobRecordDO jobRecord = BeanUtils.toBean(jobRecordSaveReqVO, JobRecordDO.class);
|
jobRecordMapper.insert(jobRecord);
|
} else {
|
jobRecordDO.setJobType(devRentStateEnum.getState());
|
jobRecordDO.setJobTime(updateReqVO.getReturnTime());
|
jobRecordDO.setRemark(updateReqVO.getRemark());
|
jobRecordDO.setSummary(updateReqVO.getInterference() + " " + updateReqVO.getBaseline() + " " + updateReqVO.getDetachment());
|
jobRecordDO.setUpdater(String.valueOf(userId));
|
jobRecordDO.setUpdateTime(LocalDateTime.now());
|
jobRecordMapper.updateById(jobRecordDO);
|
}
|
|
return CommonResult.success(updateReqVO.getId());
|
}
|
|
@Override
|
public Long createDevRent(DevRentSaveReqVO createReqVO) {
|
// 插入
|
DevRentDO devRent = BeanUtils.toBean(createReqVO, DevRentDO.class);
|
devRentMapper.insert(devRent);
|
// 返回
|
return devRent.getId();
|
}
|
|
@Override
|
public void updateDevRent(DevRentSaveReqVO updateReqVO) {
|
// 校验存在
|
validateDevRentExists(updateReqVO.getId());
|
// 更新
|
DevRentDO updateObj = BeanUtils.toBean(updateReqVO, DevRentDO.class);
|
devRentMapper.updateById(updateObj);
|
}
|
|
@Override
|
public void deleteDevRent(Long id) {
|
// 校验存在
|
validateDevRentExists(id);
|
// 删除
|
devRentMapper.deleteById(id);
|
}
|
|
private void validateDevRentExists(Long id) {
|
if (devRentMapper.selectById(id) == null) {
|
throw exception(DEV_INSTALL_NOT_EXISTS);
|
}
|
}
|
|
@Override
|
public DevRentDO getDevRent(Long id) {
|
DevRentDO devRentDO = devRentMapper.selectById(id);
|
fillPatientInfo(devRentDO);
|
return devRentDO;
|
}
|
|
@Override
|
public PageResult<DevRentDO> getDevRentPage(DevRentPageReqVO pageReqVO) {
|
pageReqVO.setState(0);
|
PageResult<DevRentDO> pageResult = devRentMapper.selectPage(pageReqVO);
|
fillPatientInfo(pageResult.getList());
|
return pageResult;
|
}
|
|
@Override
|
public DevRentDO getExistingRent(DevRentSearchReqVO searchReqVO) {
|
List<Integer> stateList = new ArrayList<>();
|
stateList.add(DevRentStateEnum.INSTALLED.getState());
|
stateList.add(DevRentStateEnum.RECEIVED.getState());
|
searchReqVO.setStateList(stateList);
|
DevRentDO devRentDO = devRentMapper.getRentByState(searchReqVO);
|
fillPatientInfo(devRentDO);
|
return devRentDO;
|
}
|
|
/**
|
* 撤销「检查完成」后的回滚：检查单 60(常规检查完成) → 0(待检查)，并取消确费。
|
*
|
* <p>【本次修复的根因】撤销原先只把队列行 40→20，`dev_rent` 仍是 60：
|
* 前端再次完成时 `getFreeRent`（只查 state=0）取不到单 → `formData.id` 为空
|
* → 后端 `routineFinishOperation` 按 (patId, checkType, state=0) 也找不到 → 报「请先预约确认」。
|
* 把状态回滚到 0 后，整条链路恢复正常。
|
*
|
* <p>失败策略：全程 try/catch，回滚/取消费失败都只记日志，**不影响"撤销"本身的结果**。
|
*/
|
@Override
|
public void rollbackRoutineFinish(String patId, Integer checkType) {
|
try {
|
List<Integer> finishedStateList = new ArrayList<>();
|
finishedStateList.add(DevRentStateEnum.ROUTINE_FINISH.getState());
|
DevRentDO rent = devRentMapper.selectLatestByPatCheckTypeStates(patId, checkType, finishedStateList);
|
if (null == rent) {
|
log.warn("[rollbackRoutineFinish] 未找到今日该患者的「常规检查完成」检查单，跳过回滚. patId={} checkType={}",
|
patId, checkType);
|
return;
|
}
|
|
// ① 状态回滚（只改 state，rent_time/return_time 保留，作为"做过一次"的痕迹）
|
DevRentDO updateObj = new DevRentDO();
|
updateObj.setId(rent.getId());
|
updateObj.setState(DevRentStateEnum.FREE.getState());
|
devRentMapper.updateById(updateObj);
|
log.info("[rollbackRoutineFinish] 检查单已回滚为[待检查]. rentId={} patId={} checkType={}",
|
rent.getId(), patId, checkType);
|
|
// ② 取消确费（第一次完成时控制器会自动确费；撤销后应回退，再次完成时重新确费）
|
Integer paid = rent.getPaid();
|
if (null != paid && 1 == paid) {
|
try {
|
String hisId = SecurityFrameworkUtils.getLoginUserHisId();
|
String nickname = SecurityFrameworkUtils.getLoginUserNickname();
|
Integer ret = feeConfirm(rent.getId(), hisId, nickname, false);
|
log.info("[rollbackRoutineFinish] 已取消确费. rentId={} 返回={}", rent.getId(), ret);
|
} catch (Exception e) {
|
log.error("[rollbackRoutineFinish] 取消确费失败（不影响撤销）. rentId={}", rent.getId(), e);
|
}
|
}
|
} catch (Exception e) {
|
log.error("[rollbackRoutineFinish] 回滚检查单失败（不影响撤销）. patId={} checkType={}", patId, checkType, e);
|
}
|
}
|
|
@Override
|
public DevRentDO getFreeRent(DevRentSearchReqVO searchReqVO) { List<Integer> stateList = new ArrayList<>();
|
stateList.add(DevRentStateEnum.FREE.getState());
|
searchReqVO.setStateList(stateList);
|
DevRentDO devRentDO = devRentMapper.getRentByState(searchReqVO);
|
fillPatientInfo(devRentDO);
|
return devRentDO;
|
}
|
|
@Override
|
public DevRentDO getReadyOrCancelledRent(DevRentSearchReqVO searchReqVO) {
|
List<Integer> stateList = new ArrayList<>();
|
stateList.add(DevRentStateEnum.RECEIVED.getState());
|
stateList.add(DevRentStateEnum.RECEIVED_CANCELLED.getState());
|
searchReqVO.setStateList(stateList);
|
DevRentDO devRentDO = devRentMapper.getRentByState(searchReqVO);
|
fillPatientInfo(devRentDO);
|
return devRentDO;
|
}
|
|
@Override
|
public DevRentDO getDismantledRent(DevRentSearchReqVO searchReqVO) {
|
List<Integer> stateList = new ArrayList<>();
|
stateList.add(DevRentStateEnum.DISMANTLED.getState());
|
searchReqVO.setStateList(stateList);
|
DevRentDO devRentDO = devRentMapper.getRentByState(searchReqVO);
|
fillPatientInfo(devRentDO);
|
return devRentDO;
|
}
|
|
// ==================== 需求1：回填患者信息 18 项 ====================
|
// dev_rent 表只存了 applyNo / patName / patDetails，
|
// 其余患者信息（性别、出生日期、病区、床号、电话、来源、就诊卡号、
|
// 登记时间、开单医师、开单日期、多耐药）都在 appointment 表。
|
//
|
// 参照 QueueServiceImpl#fillAppointmentInfo 的做法：查询后按 applyNo 回查预约单补齐。
|
// 这样领用/装机/拆机/数据录入/检查记录 5 个界面才能展示完整患者信息。
|
|
/**
|
* 回填单个对象的患者信息（对象为 null 或 applyNo 为空时安全跳过）。
|
*/
|
private void fillPatientInfo(DevRentDO devRentDO) {
|
if (null == devRentDO || !org.springframework.util.StringUtils.hasText(devRentDO.getApplyNo())) {
|
return;
|
}
|
AppointmentDO appointment = appointmentMapper.getByApplyNo(devRentDO.getApplyNo());
|
if (null == appointment) {
|
return;
|
}
|
applyAppointmentToDevRent(devRentDO, appointment);
|
}
|
|
/**
|
* 批量回填（避免 N+1 之外的额外开销由调用方控制；此处逐条回查，
|
* 与 QueueServiceImpl#fillAppointmentInfo 保持一致的做法）。
|
*/
|
private void fillPatientInfo(List<DevRentDO> devRentDOList) {
|
if (null == devRentDOList || devRentDOList.isEmpty()) {
|
return;
|
}
|
devRentDOList.forEach(this::fillPatientInfo);
|
}
|
|
/**
|
* 把预约单中的患者信息复制到 dev_rent 对象。
|
* <p>
|
* 注意：只覆盖**为空的**平铺字段？——不，这里直接覆盖：
|
* 这些字段均标记为 {@code @TableField(exist=false)}，不参与写库，
|
* 本次查询返回的就是最新数据，不存在"覆盖掉用户刚录入的值"的风险。
|
*/
|
private void applyAppointmentToDevRent(DevRentDO target, AppointmentDO source) {
|
target.setPatGender(source.getPatGender());
|
target.setPatBirthday(source.getPatBirthday());
|
target.setRegisterDate(source.getRegisterDate());
|
target.setDoctor(source.getDoctor());
|
target.setDoctorTime(source.getDoctorTime());
|
target.setPatSrc(source.getPatSrc());
|
target.setPatMobile(source.getPatMobile());
|
target.setPatPhone(source.getPatPhone());
|
target.setPatWardDesc(source.getPatWardDesc());
|
target.setPatBedNo(source.getPatBedNo());
|
target.setMedicalCard(source.getMedicalCard());
|
if (target.getDoctorAdviceNo() == null) target.setDoctorAdviceNo(source.getDoctorAdviceNo());
|
target.setOutpatientNo(source.getOutpatientNo());
|
target.setPatIdentityId(source.getPatIdentityId());
|
target.setTolerance(source.getTolerance());
|
}
|
|
// 确费处理
|
// 返回值: 0 成功 1 失败 2 不用确费
|
@Override
|
public Integer feeConfirm(Long rentId, String hisId, String userNickname, Boolean isFeeConfirmOrCancel) {
|
DevRentDO devRentDO = devRentMapper.selectById(rentId);
|
|
// 查询检查类型，确定是否需要确费
|
CheckTypeDO checkTypeDO = checkTypeMapper.getCheckTypeByValue(devRentDO.getCheckType());
|
if (0 == checkTypeDO.getExpenseRecognition()) {
|
return 2;
|
}
|
|
Integer returnValue = 1;
|
try {
|
AppointmentDO appointmentDO = appointmentMapper.getByApplyNo(devRentDO.getApplyNo());
|
returnValue = appointmentDO.getPaid() == 1 ? 0 : 1;
|
} catch (RuntimeException ex) {
|
returnValue = 1;
|
}
|
|
if (0 == returnValue) {
|
devRentMapper.setPaid(rentId, isFeeConfirmOrCancel ? 1 : 0);
|
}
|
return returnValue; // 0 成功 1 失败 2 不用确费
|
}
|
|
// 标记 设备已被领取
|
private Integer markDevRecieved(String devId, Long rentId, PatDetails patDetails) {
|
// 设备标注 已领取
|
DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviceDO && DevStateEnum.FREE.isEqual(deviceDO.getState())) {
|
deviceDO.setState(DevStateEnum.RECEIVED.getState());
|
deviceDO.setRentId(rentId);
|
deviceDO.setStateDate(LocalDate.now());
|
deviceDO.setPatDetails(patDetails);
|
return deviceMapper.updateById(deviceDO);
|
}
|
|
return 0;
|
}
|
|
// 标记 设备已被使用
|
private Integer markDevInUse(String devId, Long rentId) {
|
DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId);
|
if (null == deviceDO) return 0;
|
|
if (DevStateEnum.RECEIVED.isEqual(deviceDO.getState()) && rentId.equals(deviceDO.getRentId())) {
|
deviceDO.setState(DevStateEnum.INUSE.getState());
|
deviceDO.setStateDate(LocalDate.now());
|
return deviceMapper.updateById(deviceDO);
|
}
|
|
if (DevStateEnum.FREE.isEqual(deviceDO.getState())) {
|
deviceDO.setState(DevStateEnum.INUSE.getState());
|
deviceDO.setStateDate(LocalDate.now());
|
deviceDO.setRentId(rentId);
|
return deviceMapper.updateById(deviceDO);
|
}
|
|
return 0;
|
}
|
|
private Integer markDevDismantleException(String devId, Long rentId, LocalDate localDate, DevStateEnum devStateEnum) {
|
// 设备标注遗失
|
DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviceDO && DevStateEnum.INUSE.isEqual(deviceDO.getState()) && rentId.equals(deviceDO.getRentId())) {
|
deviceDO.setState(devStateEnum.getState());
|
deviceDO.setStateDate(localDate);
|
return deviceMapper.updateById(deviceDO);
|
}
|
|
return 0;
|
}
|
|
private Integer markDevFree(String devId, Long rentId) {
|
// 设备标注遗失 恢复为空闲
|
DeviceDO deviceDO = deviceMapper.getDeviceByDevId(devId);
|
if (null != deviceDO && rentId.equals(deviceDO.getRentId())) {
|
deviceDO.setState(DevStateEnum.FREE.getState());
|
deviceDO.setStateDate(LocalDate.now());
|
deviceDO.setRentId(null);
|
deviceDO.setPatDetails(null);
|
return deviceMapper.updateById(deviceDO);
|
}
|
|
return 0;
|
}
|
|
private void procAffinityWhenRoutineFinish(String patId, Integer[] affinityCheckTypes) {
|
// 如果存在 [亲和-排队] 亲和项，则选择 其中一个亲和项 接替其 处于 [就诊中]
|
List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus(patId, affinityCheckTypes, QueueStatusEnum.AFFINITY.getStatus());
|
if (!affinityAffinityWaitingItems.isEmpty()) {
|
QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0);
|
tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus());
|
queueMapper.updateById(tmpQueueDO);
|
}
|
}
|
|
/**
|
* 领用完成，主动寻求依附
|
*/
|
private void procAffinityWhenReadyFinish(/*IN,OUT*/QueueDO bedOnStageQueueItem, Integer[] affinityCheckTypes) {
|
// 如果存在 [安装中] [安装过号] [安装召回] 能被依附的检查项，则依附到其中一个检查项
|
List<QueueDO> affinityInstallingItems = queueMapper.getCurPatGivenCheckTypesAndStatusList(bedOnStageQueueItem.getPatId(), affinityCheckTypes, List.of(QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.PASSED_INSTALL.getStatus(), QueueStatusEnum.RECALLED_INSTALL.getStatus()));
|
if (!affinityInstallingItems.isEmpty()) {
|
QueueDO affinityInstallingItem = affinityInstallingItems.get(0);
|
bedOnStageQueueItem.setStatus(QueueStatusEnum.AFFINITY_INSTALL.getStatus()); // 亲和-领用
|
bedOnStageQueueItem.setAffinityItem(1);
|
bedOnStageQueueItem.setRoomId(affinityInstallingItem.getRoomId());
|
bedOnStageQueueItem.setBedNo(affinityInstallingItem.getBedNo()); // 领用 到 安装 可能会在不同工位
|
}
|
|
// 如果存在 [亲和-排队] 亲和项，则选择 其中一个亲和项 接替其 处于 [就诊中]
|
List<QueueDO> affinityAffinityWaitingItems = queueMapper.getCurPatGivenCheckTypesAndStatus(bedOnStageQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY.getStatus());
|
if (!affinityAffinityWaitingItems.isEmpty()) {
|
QueueDO tmpQueueDO = affinityAffinityWaitingItems.get(0);
|
tmpQueueDO.setStatus(QueueStatusEnum.ONSTAGE.getStatus());
|
queueMapper.updateById(tmpQueueDO);
|
}
|
}
|
|
// 如果存在 [亲和-领用] 亲和项，则选择 其中一个亲和项 接替其 处于 [安装中]
|
private void procAffinityWhenInstallFinish(QueueDO bedInstallingQueueItem, Integer[] affinityCheckTypes) {
|
List<QueueDO> affinityAffinityReceivedItems = queueMapper.getCurPatGivenCheckTypesAndStatus(bedInstallingQueueItem.getPatId(), affinityCheckTypes, QueueStatusEnum.AFFINITY_INSTALL.getStatus());
|
if (!affinityAffinityReceivedItems.isEmpty()) {
|
QueueDO tmpQueueDO = affinityAffinityReceivedItems.get(0);
|
tmpQueueDO.setStatus(QueueStatusEnum.INSTALLING.getStatus());
|
tmpQueueDO.setRoomId(bedInstallingQueueItem.getRoomId());
|
tmpQueueDO.setBedNo(bedInstallingQueueItem.getBedNo()); // 从 [领用] 到 [安装]， 可鞥在不同工位上操作
|
queueMapper.updateById(tmpQueueDO);
|
}
|
}
|
|
private String getHisCheckCode(Integer checkType) {
|
if (100 == checkType) return "691133607";
|
else if (200 == checkType) return "201605";
|
else if (300 == checkType) return "200327";
|
else if (400 == checkType) return "201652";
|
else if (500 == checkType) return "502490914";
|
else if (600 == checkType) return "419562119";
|
else if (700 == checkType) return "201604";
|
else if (800 == checkType) return "1202042";
|
else if (900 == checkType) return "1202058";
|
else if (1000 == checkType) return "1202065";
|
else if (1100 == checkType) return "559542128";
|
else if (1200 == checkType) return "590244511";
|
else if (1300 == checkType) return "666454217";
|
else if (1400 == checkType) return "720791490";
|
else if (1500 == checkType) return "720792077";
|
|
return "691133607";
|
}
|
|
String getPatientType(Integer patientSource) {
|
if (1 == patientSource || 2 == patientSource) return "01";
|
else if (3 == patientSource) return "03";
|
else if (4 == patientSource) return "04";
|
|
return "01";
|
}
|
}
|
