fix(#644): 请修复 Bug #644：[住院护士站-医嘱校对] 医嘱执行后状态未同步更新为“已执行”，且允许退回已执行医嘱（校验缺失）
根因： - Issue 2 — 退回校验缺失**：`adviceReject` 方法仅校验了药品是否已发药（`DispenseStatus.COMPLETED`），但未校验医嘱是否已执行（`cli_procedure` 表中 `status_enum = COMPLETED` 的记录）。已执行的医嘱可以被直接退回。 修复： - | 文件 | 修改 | 说明 | - |------|------|------| - | `AdviceProcessAppServiceImpl.java:235-280` | 将执行记录计算逻辑移到 `if (exeStatus != null)` 之前，所有页签都计算 | 所有页签的医嘱都能获取执行记录 | - | `AdviceProcessAppServiceImpl.java:266-274` | 新增 `overallStatusText` 计算逻辑 | 有已执行记录→"已执行"，有取消记录→"已取消执行"，有停止记录→"已停止"，否则回退到请求状态文本 | - | `AdviceProcessAppServiceImpl.java:362-382` | `adviceReject` 方法新增已执行校验 | 查询 `cli_procedure` 中 `EventStatus.COMPLETED` + `ProcedureCategory.INPATIENT_ADVICE` 记录，存在则拒绝退回 | - | `InpatientAdviceDto.java` | 新增 `overallStatusText` 字段 | 前端可通过此字段展示综合执行状态 | - ### 全链路 6 环验证 - | 环节 | 状态 | 说明 | - |------|------|------| - | ①前端/页面 | ✅ 正常 | 新增 `overallStatusText` 字段，前端可直接绑定展示 | - | ②Controller | ✅ 正常 | `adviceReject` 参数 `List<PerformInfoDto>` 无需变更 | - | ③Service | 🔧 已修改 | `getInpatientAdvicePage` 重构执行记录计算；`adviceReject` 增加校验 | - | ④Mapper XML | ✅ 正常 | SQL 查询无需变更，执行记录通过 Java 代码计算 | - | ⑤DB | ✅ 正常 | `cli_procedure` 表已存储执行状态，无需变更 | - | ⑥关联模块 | ✅ 正常 | `adviceCancel`（取消执行）不受影响，取消后执行记录变为 CANCEL，退回校验自动放行 |
This commit is contained in:
@@ -232,38 +232,48 @@ public class AdviceProcessAppServiceImpl implements IAdviceProcessAppService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 手动处理前端传来的执行条件
|
// 为所有医嘱计算执行记录状态（所有页签都需要展示执行进度）
|
||||||
if (exeStatus != null) {
|
for (InpatientAdviceDto inpatientAdvice : inpatientAdviceList) {
|
||||||
// 处理执行记录状态
|
List<PerformRecordDto> performRecordList = procedureRecordGroup.get(inpatientAdvice.getRequestId());
|
||||||
for (InpatientAdviceDto inpatientAdvice : inpatientAdviceList) {
|
List<PerformRecordDto> exePerformRecordList = new ArrayList<>();
|
||||||
List<PerformRecordDto> performRecordList = procedureRecordGroup.get(inpatientAdvice.getRequestId());
|
List<PerformRecordDto> cancelPerformRecordList = new ArrayList<>();
|
||||||
List<PerformRecordDto> exePerformRecordList = new ArrayList<>();
|
List<PerformRecordDto> stopPerformRecordList = new ArrayList<>();
|
||||||
List<PerformRecordDto> cancelPerformRecordList = new ArrayList<>();
|
if (performRecordList != null && !performRecordList.isEmpty()) {
|
||||||
List<PerformRecordDto> stopPerformRecordList = new ArrayList<>();
|
// 按时间分组，处理每个时间点的多条记录
|
||||||
if (performRecordList != null && !performRecordList.isEmpty()) {
|
Map<String, List<PerformRecordDto>> recordsByTime = performRecordList.stream()
|
||||||
// 按时间分组，处理每个时间点的多条记录
|
.collect(Collectors.groupingBy(record -> record.getOccurrenceTime().toString()));
|
||||||
Map<String, List<PerformRecordDto>> recordsByTime = performRecordList.stream()
|
for (Map.Entry<String, List<PerformRecordDto>> entry : recordsByTime.entrySet()) {
|
||||||
.collect(Collectors.groupingBy(record -> record.getOccurrenceTime().toString()));
|
List<PerformRecordDto> records = entry.getValue();
|
||||||
for (Map.Entry<String, List<PerformRecordDto>> entry : recordsByTime.entrySet()) {
|
// 按操作顺序排序
|
||||||
List<PerformRecordDto> records = entry.getValue();
|
records.sort(Comparator.comparing(PerformRecordDto::getCreateTime));
|
||||||
// 按操作顺序排序
|
// 取最后一条记录,最终状态由最后一次操作决定
|
||||||
records.sort(Comparator.comparing(PerformRecordDto::getCreateTime));
|
PerformRecordDto lastRecord = records.get(records.size() - 1);
|
||||||
// 取最后一条记录,最终状态由最后一次操作决定
|
if (EventStatus.COMPLETED.getValue().equals(lastRecord.getStatusEnum())) {
|
||||||
PerformRecordDto lastRecord = records.get(records.size() - 1);
|
exePerformRecordList.add(lastRecord);
|
||||||
if (EventStatus.COMPLETED.getValue().equals(lastRecord.getStatusEnum())) {
|
} else if (EventStatus.CANCEL.getValue().equals(lastRecord.getStatusEnum())) {
|
||||||
exePerformRecordList.add(lastRecord);
|
cancelPerformRecordList.add(lastRecord);
|
||||||
} else if (EventStatus.CANCEL.getValue().equals(lastRecord.getStatusEnum())) {
|
} else if (EventStatus.STOPPED.getValue().equals(lastRecord.getStatusEnum())) {
|
||||||
cancelPerformRecordList.add(lastRecord);
|
stopPerformRecordList.add(lastRecord);
|
||||||
} else if (EventStatus.STOPPED.getValue().equals(lastRecord.getStatusEnum())) {
|
|
||||||
stopPerformRecordList.add(lastRecord);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
inpatientAdvice.setExePerformRecordList(exePerformRecordList)
|
|
||||||
.setCancelPerformRecordList(cancelPerformRecordList)
|
|
||||||
.setStopPerformRecordList(stopPerformRecordList);
|
|
||||||
}
|
}
|
||||||
|
inpatientAdvice.setExePerformRecordList(exePerformRecordList)
|
||||||
|
.setCancelPerformRecordList(cancelPerformRecordList)
|
||||||
|
.setStopPerformRecordList(stopPerformRecordList);
|
||||||
|
// 计算综合执行状态文本
|
||||||
|
if (!exePerformRecordList.isEmpty()) {
|
||||||
|
inpatientAdvice.setOverallStatusText("已执行");
|
||||||
|
} else if (!cancelPerformRecordList.isEmpty()) {
|
||||||
|
inpatientAdvice.setOverallStatusText("已取消执行");
|
||||||
|
} else if (!stopPerformRecordList.isEmpty()) {
|
||||||
|
inpatientAdvice.setOverallStatusText("已停止");
|
||||||
|
} else {
|
||||||
|
inpatientAdvice.setOverallStatusText(inpatientAdvice.getRequestStatus_enumText());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 手动处理前端传来的执行条件
|
||||||
|
if (exeStatus != null) {
|
||||||
// 根据执行状态过滤医嘱列表
|
// 根据执行状态过滤医嘱列表
|
||||||
List<InpatientAdviceDto> filteredList = new ArrayList<>();
|
List<InpatientAdviceDto> filteredList = new ArrayList<>();
|
||||||
if (EventStatus.COMPLETED.getValue().equals(exeStatus)) {
|
if (EventStatus.COMPLETED.getValue().equals(exeStatus)) {
|
||||||
@@ -359,6 +369,29 @@ public class AdviceProcessAppServiceImpl implements IAdviceProcessAppService {
|
|||||||
medRequestList.add(item);
|
medRequestList.add(item);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// 校验医嘱是否已执行，已执行的医嘱不允许退回
|
||||||
|
List<PerformInfoDto> allRequestList = new ArrayList<>();
|
||||||
|
allRequestList.addAll(serviceRequestList);
|
||||||
|
allRequestList.addAll(medRequestList);
|
||||||
|
if (!allRequestList.isEmpty()) {
|
||||||
|
// 按requestTable分组查询执行记录
|
||||||
|
Map<String, List<Long>> requestTableIdMap = allRequestList.stream()
|
||||||
|
.collect(Collectors.groupingBy(PerformInfoDto::getRequestTable,
|
||||||
|
Collectors.mapping(PerformInfoDto::getRequestId, Collectors.toList())));
|
||||||
|
for (Map.Entry<String, List<Long>> entry : requestTableIdMap.entrySet()) {
|
||||||
|
String requestTable = entry.getKey();
|
||||||
|
List<Long> requestIds = entry.getValue();
|
||||||
|
List<Procedure> executedProcedures = procedureService.list(
|
||||||
|
new LambdaQueryWrapper<Procedure>()
|
||||||
|
.in(Procedure::getRequestId, requestIds)
|
||||||
|
.eq(Procedure::getRequestTable, requestTable)
|
||||||
|
.eq(Procedure::getStatusEnum, EventStatus.COMPLETED.getValue())
|
||||||
|
.eq(Procedure::getCategoryEnum, ProcedureCategory.INPATIENT_ADVICE.getValue()));
|
||||||
|
if (!executedProcedures.isEmpty()) {
|
||||||
|
return R.fail("所选医嘱中存在已执行的医嘱，请先在【医嘱执行】界面取消执行后再退回");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
// 校验药品医嘱是否已发药，已发药的医嘱不允许退回
|
// 校验药品医嘱是否已发药，已发药的医嘱不允许退回
|
||||||
if (!medRequestList.isEmpty()) {
|
if (!medRequestList.isEmpty()) {
|
||||||
List<Long> medReqIds = medRequestList.stream().map(PerformInfoDto::getRequestId).toList();
|
List<Long> medReqIds = medRequestList.stream().map(PerformInfoDto::getRequestId).toList();
|
||||||
|
|||||||
@@ -101,6 +101,9 @@ public class InpatientAdviceDto {
|
|||||||
private Integer requestStatus;
|
private Integer requestStatus;
|
||||||
private String requestStatus_enumText;
|
private String requestStatus_enumText;
|
||||||
|
|
||||||
|
/** 综合执行状态（结合请求状态和执行记录计算） */
|
||||||
|
private String overallStatusText;
|
||||||
|
|
||||||
/** 是否皮试 */
|
/** 是否皮试 */
|
||||||
private Integer skinTestFlag;
|
private Integer skinTestFlag;
|
||||||
private String skinTestFlag_enumText;
|
private String skinTestFlag_enumText;
|
||||||
|
|||||||
Reference in New Issue
Block a user