From 75d6fbf4feaf67b9c2a0c7d054dfa835b4de181f Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期二, 26 十一月 2024 00:05:45 +0800
Subject: [PATCH] 就诊流水号
---
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queuesequence/QueueSequenceServiceImpl.java | 46 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 46 insertions(+), 0 deletions(-)
diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queuesequence/QueueSequenceServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queuesequence/QueueSequenceServiceImpl.java
index d99ebbd..1bf0bd2 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queuesequence/QueueSequenceServiceImpl.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queuesequence/QueueSequenceServiceImpl.java
@@ -48,6 +48,15 @@
private CheckTypeMapper checkTypeMapper;
@Override
+ public void initQueueSequenceTable() {
+ queueSequenceMapper.clearQueueSequenceTableNotCurrent();
+ Integer rowCount = queueSequenceMapper.getQueueSequenceTableRowCount();
+ if (null == rowCount || 0 == rowCount) {
+ resetQueueSequence();
+ }
+ }
+
+ @Override
public Integer createQueueSequence(QueueSequenceSaveReqVO createReqVO) {
// 鎻掑叆
QueueSequenceDO queueSequence = BeanUtils.toBean(createReqVO, QueueSequenceDO.class);
@@ -85,6 +94,11 @@
}
@Override
+ public List<QueueSequenceDO> selectGivenCheckTypeTimeslot(Integer checkType) {
+ return queueSequenceMapper.selectTimeslotByCheckType( checkType );
+ }
+
+ @Override
public PageResult<QueueSequenceDO> getQueueSequencePage(QueueSequencePageReqVO pageReqVO) {
return queueSequenceMapper.selectPage(pageReqVO);
}
@@ -119,5 +133,37 @@
});
}
+ @Override
+ @Transactional
+ public Integer distributeSeqNo(Integer checkType, Integer timeslot) {
+ Integer curSeqNo = queueSequenceMapper.selectQueueNoForUpdate(checkType, timeslot);
+ if (null == curSeqNo) {
+ throw exception(QUEUE_SEQUENCE_TIMESLOT_FULL);
+ }
+
+ Integer updateRowNum = queueSequenceMapper.updateGivenCheckTypeTimeslotSeqNo(checkType, timeslot, curSeqNo);
+ if (null == updateRowNum || updateRowNum == 0) {
+ throw exception(QUEUE_SEQUENCE_TIMESLOT_EXCEPTION);
+ }
+
+ return curSeqNo + 1;
+ }
+
+ @Override
+ @Transactional
+ public Integer distributeVipSeqNo(Integer checkType, Integer timeslot) {
+ Integer curVipSeqNo = queueSequenceMapper.selectQueueVipNoForUpdate(checkType, timeslot);
+ if (null == curVipSeqNo) {
+ throw exception(QUEUE_SEQUENCE_TIMESLOT_FULL);
+ }
+
+ Integer updateRowNum = queueSequenceMapper.updateGivenCheckTypeTimeslotVipSeqNo(checkType, timeslot, curVipSeqNo);
+ if (null == updateRowNum || updateRowNum == 0) {
+ throw exception(QUEUE_SEQUENCE_TIMESLOT_EXCEPTION);
+ }
+
+ return curVipSeqNo + 1;
+ }
+
}
--
Gitblit v1.9.3