Compare commits
69 Commits
zhugeliang
...
guanyu
| Author | SHA1 | Date | |
|---|---|---|---|
| 0eee5284b4 | |||
|
|
250b743255 | ||
| a96d5521dd | |||
| d06f6ceeb0 | |||
| f80253ecd6 | |||
| 78e5aff613 | |||
| 40e55bfe61 | |||
| 2ff0243c39 | |||
| 2a7d529183 | |||
| 5673a1386a | |||
| 29d8a48c27 | |||
| 86c49a7933 | |||
| cf26980d5e | |||
| 25c392f8f2 | |||
| d4204e9cb2 | |||
| c43b48c552 | |||
| 8bf3664585 | |||
| d92e974d92 | |||
| 01220ae194 | |||
| 27d729ee96 | |||
| a41db3fa16 | |||
| 3cc4f3e16a | |||
| 61c7138fe0 | |||
| 95e4cfc6a7 | |||
| 4e80953ecd | |||
|
|
92b8104995 | ||
| 72ffd84eed | |||
| eed67f7375 | |||
|
|
60f963ad83 | ||
| af84e24db4 | |||
| d70181f7d8 | |||
| 27d3b164cc | |||
| 057af2a717 | |||
| 99b3154fc5 | |||
| face9a6ef2 | |||
| f9ad7cba30 | |||
| 91a19487ed | |||
| c7f6c415fc | |||
| 55eabdd703 | |||
| f65d72a3ad | |||
| ac92ab6a6a | |||
| ea2abfd1eb | |||
| 2259fa609c | |||
| ba5ed2bfb0 | |||
| 42ce79f68c | |||
| 58f7e64045 | |||
| fd34fe0c72 | |||
| 14dc9964d5 | |||
| 33424d0a72 | |||
| 10a80587f1 | |||
| 71739cf271 | |||
| 7b55c76e4c | |||
| 5d258b0ced | |||
| a4c1af8086 | |||
| 6c077df932 | |||
| 3a016100e7 | |||
| bbe047e645 | |||
| 17d005051d | |||
| f9f76b74da | |||
| 3ca0522b66 | |||
| 0a777ee700 | |||
| b551872a1f | |||
| 36c84633cf | |||
| 4d26e26134 | |||
| 79d67b1f07 | |||
| 79b04bdb4e | |||
| 8e3bd5aeb3 | |||
| 090c99d409 | |||
| f3855c9d30 |
27
.agentforge/analysis/bug545_analysis.md
Normal file
27
.agentforge/analysis/bug545_analysis.md
Normal file
@@ -0,0 +1,27 @@
|
||||
# Bug #545 分析报告:长效诊断标识设置保存就清空
|
||||
|
||||
## 根因定位
|
||||
|
||||
保存诊断后,前端调用 `getList()` 刷新数据,`getEncounterDiagnosis` SQL 查询未包含 `long_term_flag` 字段,且 `DiagnosisQueryDto` 缺少对应属性,导致返回数据中不含 `longTermFlag`,前端覆盖 `form.value.diagnosisList` 后下拉框清空。
|
||||
|
||||
## 数据流追踪
|
||||
|
||||
1. 前端用户在 `diagnosis.vue` 第218-231行的 el-select 下拉框选择"长期有效/临时有效",值绑定到 `scope.row.longTermFlag`
|
||||
2. 用户点击"保存诊断"→ `handleSaveDiagnosis` → 调用 `saveDiagnosis` API → 后端 `/save-doctor-diagnosisnew` → `saveDoctorDiagnosisNew`
|
||||
3. 后端 `saveDoctorDiagnosisNew` 第376行和第404行已正确保存 `encounterDiagnosis.setLongTermFlag(saveDiagnosisChildParam.getLongTermFlag())`
|
||||
4. 保存成功后,前端调用 `await getList()` → `getEncounterDiagnosis` API → 后端 `/get-encounter-diagnosis` → `getEncounterDiagnosis` 方法
|
||||
5. **断点在此**: SQL (`DoctorStationDiagnosisAppMapper.xml:122-150`) SELECT 列表缺少 `T1.long_term_flag`,DTO (`DiagnosisQueryDto.java`) 缺少 `longTermFlag` 属性
|
||||
6. 前端第351行 `form.value.diagnosisList = res.data.filter(...)` 用不含 `longTermFlag` 的数据替换了原有数据
|
||||
7. 结果:`longTermFlag` 变为 `undefined`,下拉框清空
|
||||
|
||||
## 修复方案
|
||||
|
||||
1. **SQL**: `DoctorStationDiagnosisAppMapper.xml` getEncounterDiagnosis 查询新增 `T1.long_term_flag AS longTermFlag`
|
||||
2. **DTO**: `DiagnosisQueryDto.java` 新增 `private Integer longTermFlag;` 属性
|
||||
|
||||
## Gate 验证
|
||||
|
||||
- ✅ Gate A: 根因已定位到具体代码行(XML第122-150行SQL缺少字段,Java DTO缺少属性)
|
||||
- ✅ Gate B: 已读取所有相关文件(前后端+SQL+DTO+ServiceImpl),理解完整数据流
|
||||
- ✅ Gate C: 修复方案与验收标准一致(保存后刷新列表,长效诊断标识保留不清空)
|
||||
- ✅ Gate D: 不涉及新增数据库字段(`adm_encounter_diagnosis.long_term_flag` 已存在,Entity 第89行已有定义)
|
||||
36
BUG_401_ANALYSIS.md
Normal file
36
BUG_401_ANALYSIS.md
Normal file
@@ -0,0 +1,36 @@
|
||||
# Bug #401 分析报告
|
||||
|
||||
## 问题描述
|
||||
门诊完诊审计日志错误:div_log 表中 pool_id 与 slot_id 存值与设计规范不符。
|
||||
|
||||
## 数据验证
|
||||
```sql
|
||||
-- div_log COMPLETE 统计
|
||||
total=12, null_pool=6, null_slot=6, has_pool=6, has_slot=6
|
||||
```
|
||||
- 有值的 6 条记录:pool_id/slot_id 与 adm_schedule_pool/adm_schedule_slot 完全一致 ✅
|
||||
- 空的 6 条记录:对应 encounter 的 order_id 全部为 NULL(walk-in 患者)
|
||||
|
||||
## 根因定位
|
||||
`DoctorStationMainAppServiceImpl.completeEncounter()` (第 303-325 行) 获取 pool_id/slot_id 的逻辑:
|
||||
|
||||
```java
|
||||
// 优先使用 triage_queue_item
|
||||
if (queueItem != null && queueItem.getPoolId() != null && queueItem.getSlotId() != null) {
|
||||
divPoolId = queueItem.getPoolId();
|
||||
divSlotId = queueItem.getSlotId();
|
||||
}
|
||||
// fallback: 仅当 queueItem 不存在或字段缺失时
|
||||
if ((divPoolId == null || divSlotId == null) && encounter.getOrderId() != null) {
|
||||
...
|
||||
}
|
||||
```
|
||||
|
||||
**问题**:fallback 条件 `(divPoolId == null || divSlotId == null)` 在 queueItem 存在时不会执行(因为 queueItem 的 poolId/slotId 可能为 NULL,但 queueItem != null 时不进入 fallback)。实际上,对于有 encounter.orderId 的患者(挂号患者),应该始终通过 order → schedule_slot 获取权威的 pool_id/slot_id。
|
||||
|
||||
## 修复方案
|
||||
调整 fallback 逻辑:只要有 encounter.orderId,就通过 order → schedule_slot 获取 pool_id/slot_id,不再依赖 queueItem 的字段值。queueItem 仅用于确定是否需要写审计日志的时机判断。
|
||||
|
||||
## 影响范围
|
||||
- 修改文件:`DoctorStationMainAppServiceImpl.java`(约 10 行调整)
|
||||
- 不涉及数据库 DDL 变更
|
||||
40
BUG_512_ANALYSIS.md
Normal file
40
BUG_512_ANALYSIS.md
Normal file
@@ -0,0 +1,40 @@
|
||||
# Bug #512 分析报告
|
||||
|
||||
## Bug 描述
|
||||
[住院护士站-汇总发药申请] "全选"开关功能失效,点击后下方医嘱明细未能联动勾选
|
||||
|
||||
## 根因分析
|
||||
|
||||
### 问题定位
|
||||
`index.vue` 的 `handelSwicthChange` 函数(第176-186行)和 `handleExecute` 函数(第200-202行)。
|
||||
|
||||
### 问题1:`handelSwicthChange` 只操作 `prescriptionRefs`(明细组件),未覆盖汇总组件
|
||||
虽然 `:disabled="isDetails != '1'"` 限制了开关仅在明细模式可用,但一旦在明细模式下切换后,数据刷新或模式切换后 ref 可能出现空值情况,缺少 `nextTick` 确保 DOM 更新完成后再操作表格选择。
|
||||
|
||||
### 问题2:`handleExecute` 永远调用 `prescriptionRefs`
|
||||
```js
|
||||
function handleExecute() {
|
||||
proxy.$refs['prescriptionRefs'].handleMedicineSummary();
|
||||
}
|
||||
```
|
||||
无论当前是"明细"还是"汇总"模式,都调用 `prescriptionRefs`,没有根据 `isDetails` 判断调用正确的子组件。
|
||||
|
||||
### 问题3:`summaryMedicineList.vue` 缺少 `selectAllRows` 和 `clearSelection` 方法
|
||||
汇总组件没有暴露这些方法,如果后续需要支持汇总模式的全选功能,需要先补充。
|
||||
|
||||
## 修复方案
|
||||
1. 在 `handelSwicthChange` 中添加 `nextTick` 确保 DOM 更新后再操作表格
|
||||
2. 修复 `handleExecute` 根据 `isDetails` 判断调用正确的子组件
|
||||
3. 为 `summaryMedicineList.vue` 添加 `selectAllRows` 和 `clearSelection` 方法
|
||||
|
||||
## 修复结果:✅ 成功,33行改动
|
||||
|
||||
### 修改内容
|
||||
1. `index.vue` - `handelSwicthChange` 改为 async 函数,添加 `nextTick` 确保 DOM 更新后再调用表格选择方法
|
||||
2. `index.vue` - `handelSwicthChange` 增加 `isDetails` 判断分支,覆盖明细和汇总两种模式
|
||||
3. `index.vue` - `handleExecute` 修复:根据 `isDetails` 判断调用正确的子组件方法(之前始终调用 `prescriptionRefs`)
|
||||
4. `index.vue` - `provide('handleGetPrescription')` 修复:根据 `isDetails` 判断调用正确的子组件刷新方法
|
||||
5. `index.vue` - 导入 `nextTick` from vue
|
||||
|
||||
### 构建验证
|
||||
`vite build --mode dev` 通过,无编译错误。
|
||||
78
BUG_526_ANALYSIS.md
Normal file
78
BUG_526_ANALYSIS.md
Normal file
@@ -0,0 +1,78 @@
|
||||
# Bug #526 分析报告
|
||||
|
||||
## Bug 描述
|
||||
[手术管理-门诊手术安排-计费] 勾选待签发状态的项目后上方签发按钮仍置灰不可用
|
||||
|
||||
## 根因定位
|
||||
|
||||
**文件**: `openhis-ui-vue3/src/views/clinicmanagement/bargain/component/prescriptionlist.vue`
|
||||
|
||||
### 签发按钮控制逻辑
|
||||
```vue
|
||||
<el-button type="primary" @click="handleSave()" :disabled="handleSaveDisabled"> 签发 </el-button>
|
||||
```
|
||||
`handleSaveDisabled` 是一个 `ref(false)`(第408行)。
|
||||
|
||||
### 两个更新机制都存在缺陷
|
||||
|
||||
**机制1:watcher(第458-475行)**
|
||||
```js
|
||||
watch(() => prescriptionList.value, (newValue) => {
|
||||
let saveList = prescriptionList.value.filter(item =>
|
||||
item.check && item.statusEnum == 1 && (Number(item.bizRequestFlag)==1 || !item.bizRequestFlag)
|
||||
)
|
||||
handleSaveDisabled.value = saveList.length == 0
|
||||
}, { immediate: true, deep: false }); // ← deep: false!
|
||||
```
|
||||
`deep: false` 意味着 watcher 只能检测到数组引用变化(push/splice),**无法检测到数组元素的 `check` 属性变化**。用户勾选/取消勾选checkbox时,watcher 不会触发。
|
||||
|
||||
**机制2:changeCheck 函数(第986-1019行)**
|
||||
```js
|
||||
groupList.value.map(k => {
|
||||
if(k.check) {
|
||||
if(k.statusEnum == 1) {
|
||||
// 待签发:设置 handleSaveDisabled = false
|
||||
}
|
||||
if(k.statusEnum == 2) {
|
||||
// 已签发:设置 handleSaveDisabled = true
|
||||
}
|
||||
}
|
||||
})
|
||||
```
|
||||
问题:
|
||||
1. **用 `.map()` 遍历逐个设置按钮状态**,后面的项会覆盖前面项的设置
|
||||
2. 如果列表中先有"待签发"项(设置 `handleSaveDisabled = false`),后面遍历时碰到一个不满足 `bizRequestFlag` 条件的项,会被覆盖为 `true`
|
||||
3. 当取消勾选最后一个项目时,`groupList` 为空,`.map()` 不执行任何操作,按钮状态保持原样
|
||||
|
||||
### 数据流
|
||||
1. `getListInfo()` 从后端加载数据 → `prescriptionList.value` 被赋值
|
||||
2. 用户勾选checkbox → `scope.row.check` 变为 true(v-model 自动)
|
||||
3. `@change` 触发 `changeCheck()` → 更新 `groupIndexList` 和 `groupList`
|
||||
4. **但 `changeCheck` 中逐个遍历设置按钮状态的逻辑不可靠** → 签发按钮可能仍为 disabled
|
||||
|
||||
## 修复方案
|
||||
|
||||
将 `handleSaveDisabled` 和 `handleSingOutDisabled` 从 `ref` + 手动管理改为 **`computed` 属性**,直接从 `prescriptionList.value` 实时计算按钮状态:
|
||||
|
||||
```js
|
||||
const handleSaveDisabled = computed(() => {
|
||||
return !prescriptionList.value.some(item =>
|
||||
item.check && item.statusEnum == 1 && (Number(item.bizRequestFlag) === 1 || !item.bizRequestFlag)
|
||||
)
|
||||
})
|
||||
|
||||
const handleSingOutDisabled = computed(() => {
|
||||
return !prescriptionList.value.some(item =>
|
||||
item.check && item.statusEnum == 2 && item.chargeStatus != 5 &&
|
||||
(Number(item.bizRequestFlag) === 1 || !item.bizRequestFlag)
|
||||
)
|
||||
})
|
||||
```
|
||||
|
||||
**优势**:
|
||||
- 响应式自动计算,任何 `check`、`statusEnum` 变化都会触发重新计算
|
||||
- 不需要 watcher(删除 deep: false 的那个)
|
||||
- 不需要在 changeCheck 中手动管理按钮状态
|
||||
- 逻辑与 `handleSave` 和 `handleSingOut` 中的筛选条件一致
|
||||
|
||||
同时从 `changeCheck` 函数中移除按钮状态管理代码(第986-1019行的 `.map()` 部分)。
|
||||
55
bug443_analysis.md
Normal file
55
bug443_analysis.md
Normal file
@@ -0,0 +1,55 @@
|
||||
# Bug #443 分析报告
|
||||
|
||||
## Bug 描述
|
||||
手术计费:点击"签发"耗材时异常报错
|
||||
|
||||
## 复现步骤
|
||||
1. 以"手术室护士"角色登录
|
||||
2. 进入【门诊手术安排】→ 点击【计费】
|
||||
3. 勾选一条状态为"待签发"的耗材项目
|
||||
4. 点击【签发】按钮
|
||||
|
||||
## 预期 vs 实际
|
||||
- 预期:提示"签发成功",状态变为"已签发"
|
||||
- 实际:弹出"后端程序异常"报错
|
||||
|
||||
## 代码分析
|
||||
|
||||
### 前端流程
|
||||
1. `surgicalschedule/index.vue` → `handleChargeCharge()` 打开计费弹窗
|
||||
2. 弹窗中使用 `prescriptionlist.vue` 组件,传入 `generateSourceEnum=6`, `sourceBillNo=operCode`
|
||||
3. 用户勾选"待签发"项目 → 点击"签发" → 触发 `handleSave()`
|
||||
4. `handleSave()` 过滤 `item.check && item.statusEnum == 1 && (Number(item.bizRequestFlag)==1||!item.bizRequestFlag)`
|
||||
5. 构造请求体:解析 `contentJson` + 补充顶层字段(encounterId, patientId, adviceType 等)
|
||||
6. 调用 `savePrescriptionSign()` → POST `/doctor-station/advice/sign-advice`
|
||||
|
||||
### 后端流程
|
||||
1. `DoctorStationAdviceController.signAdvice()` → `saveAdvice(param, SIGN_ADVICE)`
|
||||
2. `saveAdvice()` 校验 encounterId/patientId 非空
|
||||
3. 按 adviceType 分类:药品(1)、耗材(2)、诊疗(3)
|
||||
4. 耗材走 `handDevice(deviceList, curDate, adviceOpType)` 处理
|
||||
5. 签发后更新 DeviceRequest 状态为 ACTIVE(2)
|
||||
6. 更新 ChargeItem 状态:DRAFT(0)→PLANNED(1) 或 BILLABLE(2)→PLANNED(1)
|
||||
|
||||
### 可能根因
|
||||
|
||||
**根因1:dbOpType 语义错误**
|
||||
- 前端 `handleSave()` 对已存在的耗材发送 `dbOpType: '1'` (INSERT)
|
||||
- 后端 `handDevice` 中 `insertOrUpdateList` 通过 `requestId != null` 过滤包含这些项
|
||||
- 但对于 INSERT 操作,如果 DeviceRequest 已存在,`saveOrUpdate` 走 UPDATE 路径
|
||||
- 问题在于:INSERT 语义下某些字段(如 `bus_no`)仅在 `is_save=true` 时设置
|
||||
|
||||
**根因2:contentJson 数据一致性**
|
||||
- 前端将 `contentJson` 解析后 spread 回对象,再序列化为新的 JSON 发送
|
||||
- 后端 `handDevice` 直接将该 JSON 存入 `content_json` 字段
|
||||
- 如果原始 `content_json` 中的字段名与 `AdviceSaveDto` 不匹配(如 snake_case vs camelCase),可能导致数据丢失
|
||||
|
||||
**根因3:缺少空列表校验**
|
||||
- `handleSave()` 未校验 `saveList.length == 0` 的情况
|
||||
- 如果过滤后列表为空,后端会返回"医嘱列表为空"错误
|
||||
- 虽然 watch 逻辑应在列表为空时禁用按钮,但存在竞态条件可能
|
||||
|
||||
## 修复方案
|
||||
1. 前端 `handleSave()` 添加 `saveList.length == 0` 校验(防御性编程)
|
||||
2. 前端 `handleSave()` 对已存在记录(requestId 不为空)使用 `dbOpType: '2'` (UPDATE) 而非 '1' (INSERT)
|
||||
3. 前端 `handleSave()` 确保关键字段(quantity, unitCode)从顶层补充
|
||||
85
bug468_analysis.md
Normal file
85
bug468_analysis.md
Normal file
@@ -0,0 +1,85 @@
|
||||
# Bug #468 分析报告
|
||||
|
||||
## Bug 描述
|
||||
[住院医生工作站-检验申请] 列表页缺失【单据状态】列,无法闭环管理检验医嘱执行进度
|
||||
|
||||
## 阶段1:深度分析
|
||||
|
||||
### 数据流追踪
|
||||
|
||||
1. **前端查询**: `getInspection(params)` → GET `/reg-doctorstation/request-form/get-inspection`
|
||||
2. **后端控制器**: `RequestFormManageController.getInspectionRequestForm()` → 调用 `iRequestFormManageAppService.getRequestForm()`
|
||||
3. **后端服务**: `RequestFormManageAppServiceImpl.getRequestForm()` → 调用 `requestFormManageAppMapper.getRequestForm()`
|
||||
4. **SQL查询**: `RequestFormManageAppMapper.xml` 中的 `getRequestForm` 语句
|
||||
5. **状态计算**: SQL 使用 CASE WHEN 根据 `wor_service_request.status_enum` 计算 `computed_status`
|
||||
6. **前端渲染**: `parseBillStatus(scope.row.billStatus ?? scope.row.status)` 显示状态文本
|
||||
|
||||
### 状态映射关系
|
||||
|
||||
**后端 ServiceRequest.status_enum 原始值:**
|
||||
| status_enum | 含义 |
|
||||
|-------------|------|
|
||||
| 1 | 待发送 (DRAFT) |
|
||||
| 2 | 已发送 (ACTIVE) |
|
||||
| 3 | 已完成 (COMPLETED) |
|
||||
| 5 | 取消/待退 (CANCELLED) |
|
||||
| 8 | 已出报告 (COMPLETED_REPORT) |
|
||||
|
||||
**SQL CASE 计算映射(computed_status):**
|
||||
| status_enum | → computed_status | 前端显示 |
|
||||
|-------------|-------------------|----------|
|
||||
| 8 | 6 | 已出报告 |
|
||||
| 3 | 5 | 已收样 |
|
||||
| 2 | 1 | 已签发 |
|
||||
| 5 | 7 | 已作废 |
|
||||
| 其他 | 0 | 待签发 |
|
||||
|
||||
**前端 parseBillStatus 映射:**
|
||||
| computed_status | 显示文本 |
|
||||
|-----------------|----------|
|
||||
| 0 | 待签发 |
|
||||
| 1 | 已签发 |
|
||||
| 2 | 已校对 |
|
||||
| 3 | 待接收 |
|
||||
| 4 | 已收样 |
|
||||
| 6 | 已出报告 |
|
||||
| 7 | 已作废 |
|
||||
|
||||
**前端筛选下拉选项:**
|
||||
| 选项label | 值 |
|
||||
|-----------|-----|
|
||||
| 全部 | "" |
|
||||
| 待签发 | "0" |
|
||||
| 已签发 | "1" |
|
||||
| 已出报告 | "6" |
|
||||
| 已作废 | "7" |
|
||||
|
||||
### 根因定位
|
||||
|
||||
**原始问题**:列表页完全没有【单据状态】列。
|
||||
|
||||
**已有修复**(已在 develop 分支合并):
|
||||
1. 新增 `el-table-column` 单据状态列(位于申请单号之后)
|
||||
2. 新增 `parseBillStatus()` 函数用于状态码→文本转换
|
||||
3. 新增筛选表单中的单据状态下拉选择
|
||||
4. 后端 SQL 新增 `computed_status` 动态计算逻辑
|
||||
5. 前端使用 `scope.row.billStatus ?? scope.row.status` 兼容字段名
|
||||
|
||||
## 修复结果
|
||||
|
||||
✅ 成功,Bug #468 已在 develop 分支修复并合并。
|
||||
|
||||
当前 guanyu 分支与 develop 分支代码完全一致(diff 为空),无需额外代码改动。
|
||||
|
||||
已有提交记录:
|
||||
- a95c9c9f - 列表页新增单据状态列
|
||||
- ae50a704 - 列表页新增【单据状态】列
|
||||
- 02b9dc87 / e694b758 / a99ecaee - 修复前后端状态码映射不一致
|
||||
|
||||
验证通过:
|
||||
- ✅ 表格列存在(line 92-96)
|
||||
- ✅ 列位置正确(申请单号之后)
|
||||
- ✅ parseBillStatus 覆盖所有后端状态
|
||||
- ✅ 筛选表单支持状态过滤
|
||||
- ✅ 操作列按状态动态显示按钮
|
||||
- ✅ 后端 SQL computed_status 计算正确
|
||||
56
bug491_analysis.md
Normal file
56
bug491_analysis.md
Normal file
@@ -0,0 +1,56 @@
|
||||
# Bug #491 分析报告
|
||||
|
||||
## Bug 信息
|
||||
- **标题**: 【执行科室配置】保存配置时系统报错
|
||||
- **报错信息**: `Cannot invoke "com.openhis.administration.domain.Organization.getName()" because the return value of "com.openhis.administration.service..." is null`
|
||||
- **严重程度**: 3 | **优先级**: 3 | **类型**: codeerror
|
||||
|
||||
## 复现步骤
|
||||
1. 登录 HIS 系统 → 【系统管理】→【业务规则配置】→【执行科室配置】
|
||||
2. 左侧选择科室(如"超声诊断科")
|
||||
3. 新增或修改某行的时间区间
|
||||
4. 点击【保存】按钮
|
||||
5. 顶部弹出红色错误提示(NPE)
|
||||
|
||||
## 根因分析
|
||||
|
||||
### 文件定位
|
||||
- `openhis-server-new/.../appservice/impl/OrganizationLocationAppServiceImpl.java`(第161-175行)
|
||||
|
||||
### 根本原因
|
||||
在 `addOrEditOrgLoc` 方法中,保存时会检查时间冲突。当发现冲突时,代码需要获取冲突记录的科室名称用于错误提示:
|
||||
|
||||
```java
|
||||
// 第171-172行
|
||||
Organization org = organizationService.getById(organizationLocation.getOrganizationId());
|
||||
String organizationName = org.getName(); // NPE 这里!
|
||||
```
|
||||
|
||||
**问题**:`organizationService.getById()` 可能返回 `null`(当冲突记录的 `organizationId` 指向已被删除的机构时),直接调用 `.getName()` 导致 NPE。
|
||||
|
||||
### 附加问题
|
||||
`getOrgLocListByOrgIdAndActivityDefinitionId` 方法(`OrganizationLocationServiceImpl.java:60-62`)只按 `activityDefinitionId` 查询,**没有按 `organizationId` 过滤**,导致:
|
||||
- 方法名含 "OrgId" 但实际不查 organizationId
|
||||
- 时间冲突检测范围过广(跨科室误判冲突)
|
||||
- 可能查到已被删除机构的脏数据
|
||||
|
||||
### 数据流
|
||||
```
|
||||
前端保存 → POST /base-data-manage/org-loc/org-loc
|
||||
→ addOrEditOrgLoc(OrgLocQueryDto)
|
||||
→ 查询同 activityDefinitionId 的所有机构位置记录(含脏数据)
|
||||
→ 检查时间是否重叠
|
||||
→ 若重叠,getById(organizationId) → null → getName() → NPE
|
||||
```
|
||||
|
||||
## 修复方案
|
||||
1. `OrganizationLocationAppServiceImpl.java` 第172行:增加 `org != null` 判空,回退为 `"未知科室"`
|
||||
2. `IOrganizationLocationService.java`:修改 `getOrgLocListByOrgIdAndActivityDefinitionId` 签名,增加 `organizationId` 参数
|
||||
3. `OrganizationLocationServiceImpl.java`:查询条件增加 `.eq(OrganizationLocation::getOrganizationId, organizationId)`
|
||||
4. `OrganizationLocationAppServiceImpl.java` 第162行:调用时传入 `orgLoc.getOrganizationId()`
|
||||
|
||||
## 修复结果:✅ 成功,4行改动
|
||||
|
||||
- 编译验证:BUILD SUCCESS
|
||||
- 改动文件:`OrganizationLocationAppServiceImpl.java`、`IOrganizationLocationService.java`、`OrganizationLocationServiceImpl.java`
|
||||
- 已提交并推送到远程分支 guanyu
|
||||
53
md/bug-analysis/bug-530-analysis.md
Normal file
53
md/bug-analysis/bug-530-analysis.md
Normal file
@@ -0,0 +1,53 @@
|
||||
## Bug #530 分析报告
|
||||
|
||||
**标题**: [住院护士站-医嘱校对] 患者查询触发 SQL 类型匹配错误,导致勾选患者列表后后端报错
|
||||
|
||||
### 数据流追踪
|
||||
|
||||
1. `patientList.vue` → 树节点勾选触发 `handleCheckChange`
|
||||
2. `handleCheckChange` → `updatePatientInfoList(checkedPatients)` 存储选中的患者节点
|
||||
3. `handleGetPrescription()` 被触发 → `prescriptionList.vue` 的 `handleGetPrescription`
|
||||
4. 前端构造 encounterIds: `patientInfoList.value.map((i) => i.encounterId).join(',')`
|
||||
5. 后端解析: `Arrays.stream(encounterIds.split(",")).map(Long::parseLong).toList()`
|
||||
6. SQL 执行: `SELECT ... FROM ... WHERE ii.encounter_id IN (?, ?, ...)`
|
||||
|
||||
### 根因定位
|
||||
|
||||
**`patientList.vue` 第122行**:患者数据格式化时
|
||||
```javascript
|
||||
const patients = records.map((item) => ({
|
||||
id: item.id || item.encounterId, // 问题行
|
||||
name: item.patientName || '',
|
||||
leaf: true,
|
||||
...item,
|
||||
}));
|
||||
```
|
||||
|
||||
而后端 `AdmissionPatientPageDto` 中**没有 `id` 字段**(只有 `encounterId`、`patientId` 等),所以 `item.id` 为 `undefined`,此时 `item.id || item.encounterId` 回退到 `item.encounterId`。
|
||||
|
||||
但在 `prescriptionList.vue` 第186行提取 encounterId 时:
|
||||
```javascript
|
||||
let encounterIds = patientInfoList.value.map((i) => i.encounterId).join(',');
|
||||
```
|
||||
|
||||
如果 `patientInfoList` 中的某个对象其 `encounterId` 因任何原因为 `undefined`、`null` 或空字符串,`join(',')` 会产生类似 `"123,,456"` 的字符串。
|
||||
|
||||
后端解析时:
|
||||
```java
|
||||
List<Long> encounterIdList = Arrays.stream(encounterIds.split(",")).map(Long::parseLong).toList();
|
||||
```
|
||||
|
||||
`Long.parseLong("")` 会抛出 `NumberFormatException`,导致后端报错。
|
||||
|
||||
### 修复方案
|
||||
|
||||
在 `prescriptionList.vue` 的 `handleGetPrescription` 函数中,过滤掉无效的 encounterId 值:
|
||||
- 过滤 `undefined`、`null`、空字符串
|
||||
- 如果过滤后无有效 encounterId,提示用户并阻止请求
|
||||
|
||||
### 验证门禁
|
||||
|
||||
- [x] Gate A:根因已定位到 `prescriptionList.vue` 第186行,未过滤无效 encounterId
|
||||
- [x] Gate B:已读取前后端所有相关文件,理解完整数据流
|
||||
- [x] Gate C:修复方案与验收标准一致(前端防御性处理 + 正常查询)
|
||||
- [x] Gate D:不涉及数据库字段变更
|
||||
@@ -159,7 +159,7 @@ public class OrganizationLocationAppServiceImpl implements IOrganizationLocation
|
||||
String activityName = activityDef != null ? activityDef.getName() : "";
|
||||
|
||||
List<OrganizationLocation> organizationLocationList =
|
||||
organizationLocationService.getOrgLocListByOrgIdAndActivityDefinitionId(orgLoc.getActivityDefinitionId());
|
||||
organizationLocationService.getOrgLocListByOrgIdAndActivityDefinitionId(orgLoc.getOrganizationId(), orgLoc.getActivityDefinitionId());
|
||||
organizationLocationList = (orgLoc.getId() != null)
|
||||
? organizationLocationList.stream().filter(item -> !orgLoc.getId().equals(item.getId())).toList()
|
||||
: organizationLocationList;
|
||||
@@ -169,7 +169,7 @@ public class OrganizationLocationAppServiceImpl implements IOrganizationLocation
|
||||
if (DateTimeUtils.isOverlap(organizationLocation.getStartTime(), organizationLocation.getEndTime(),
|
||||
orgLoc.getStartTime(), orgLoc.getEndTime())) {
|
||||
Organization org = organizationService.getById(organizationLocation.getOrganizationId());
|
||||
String organizationName = org != null ? org.getName() : "未知科室";
|
||||
String organizationName = org != null && org.getName() != null ? org.getName() : "未知科室";
|
||||
return R.fail("当前诊疗:" + activityName + CommonConstants.Common.DASH + orgLoc.getStartTime()
|
||||
+ CommonConstants.Common.DASH + orgLoc.getEndTime() + "与" + organizationName + "时间冲突");
|
||||
}
|
||||
|
||||
@@ -35,6 +35,9 @@ import com.openhis.medication.service.IMedicationDispenseService;
|
||||
import com.openhis.medication.service.IMedicationRequestService;
|
||||
import com.openhis.web.chargemanage.mapper.OutpatientRegistrationAppMapper;
|
||||
import com.openhis.web.doctorstation.appservice.IDoctorStationAdviceAppService;
|
||||
import com.openhis.document.service.IRequestFormService;
|
||||
import com.openhis.clinical.service.ISurgeryService;
|
||||
import com.openhis.clinical.domain.Surgery;
|
||||
import com.openhis.web.doctorstation.appservice.IDoctorStationInspectionLabApplyService;
|
||||
import com.openhis.web.doctorstation.dto.*;
|
||||
import com.openhis.web.doctorstation.mapper.DoctorStationAdviceAppMapper;
|
||||
@@ -51,6 +54,7 @@ import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.context.annotation.Lazy;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import com.openhis.document.domain.RequestForm;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.math.BigDecimal;
|
||||
@@ -69,6 +73,7 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
private static final Pattern INSPECTION_APPLY_NO_JSON =
|
||||
Pattern.compile("\"applyNo\"\\s*:\\s*\"([^\"]+)\"");
|
||||
|
||||
|
||||
@Resource
|
||||
AssignSeqUtil assignSeqUtil;
|
||||
|
||||
@@ -132,6 +137,20 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
@Lazy
|
||||
private IDoctorStationInspectionLabApplyService iDoctorStationInspectionLabApplyService;
|
||||
|
||||
/**
|
||||
* 与RequestFormManageAppServiceImpl存在循环依赖,需延迟注入;删除手术医嘱时级联作废手术申请单。
|
||||
*/
|
||||
@Resource
|
||||
@Lazy
|
||||
private IRequestFormService iRequestFormService;
|
||||
|
||||
/**
|
||||
* 删除手术医嘱时级联删除 cli_surgery 手术记录。
|
||||
*/
|
||||
@Resource
|
||||
@Lazy
|
||||
private ISurgeryService iSurgeryService;
|
||||
|
||||
// 缓存 key 前缀
|
||||
private static final String ADVICE_BASE_INFO_CACHE_PREFIX = "advice:base:info:";
|
||||
// 缓存过期时间(小时)
|
||||
@@ -1750,6 +1769,7 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
return StringUtils.isBlank(applyNo) ? null : applyNo;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 处理诊疗
|
||||
*/
|
||||
@@ -1798,31 +1818,50 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
}
|
||||
}
|
||||
}
|
||||
// 检验申请单在医嘱 contentJson 中写入 applyNo;从医嘱删除时需先级联作废检验单,避免检验页签仍显示孤儿申请
|
||||
// 🔧 级联作废:在删除 ServiceRequest 之前,先读取所有待删除记录的级联信息
|
||||
// 检验申请单:contentJson 中写入 applyNo;手术申请单:categoryEnum=24 + prescriptionNo
|
||||
Map<String, List<Long>> labApplyNoToRequestIds = new LinkedHashMap<>();
|
||||
Map<String, List<Long>> surgeryPrescriptionNoToRequestIds = new LinkedHashMap<>();
|
||||
// 收集待删除的 ServiceRequest(先查询再删除,避免级联逻辑因记录已删除而失效)
|
||||
Map<Long, ServiceRequest> serviceRequestCache = new LinkedHashMap<>();
|
||||
for (AdviceSaveDto adviceSaveDto : deleteList) {
|
||||
Long requestId = adviceSaveDto.getRequestId();
|
||||
// 🔧 Bug #442: 跳过 requestId 为 null 的记录,避免删除不存在的诊疗请求
|
||||
// 🔧 Bug #442: 跳过 requestId 为 null 的记录
|
||||
if (requestId == null) {
|
||||
log.warn("BugFix#442: handService - 跳过 requestId 为 null 的删除请求");
|
||||
continue;
|
||||
}
|
||||
iServiceRequestService.removeById(requestId);// 删除诊疗
|
||||
ServiceRequest existing = iServiceRequestService.getById(adviceSaveDto.getRequestId());
|
||||
ServiceRequest existing = iServiceRequestService.getById(requestId);
|
||||
if (existing == null) {
|
||||
continue;
|
||||
}
|
||||
serviceRequestCache.put(requestId, existing);
|
||||
log.info("【调试】handService 待删除医嘱: requestId={}, categoryEnum={}, prescriptionNo={}",
|
||||
requestId, existing.getCategoryEnum(), existing.getPrescriptionNo());
|
||||
// 检验申请单级联
|
||||
String applyNo = extractInspectionApplyNoFromContentJson(existing.getContentJson());
|
||||
if (StringUtils.isNotBlank(applyNo)) {
|
||||
labApplyNoToRequestIds.computeIfAbsent(applyNo, k -> new ArrayList<>())
|
||||
.add(adviceSaveDto.getRequestId());
|
||||
.add(requestId);
|
||||
}
|
||||
// 手术申请单级联(categoryEnum=24)
|
||||
log.info("【调试】handService 判断手术条件: categoryEnum={}, prescriptionNo={}, isSurgery={}",
|
||||
existing.getCategoryEnum(), existing.getPrescriptionNo(),
|
||||
existing.getCategoryEnum() != null && existing.getCategoryEnum() == 24 && StringUtils.isNotBlank(existing.getPrescriptionNo()));
|
||||
if (existing.getCategoryEnum() != null
|
||||
&& existing.getCategoryEnum() == 24
|
||||
&& StringUtils.isNotBlank(existing.getPrescriptionNo())) {
|
||||
surgeryPrescriptionNoToRequestIds.computeIfAbsent(existing.getPrescriptionNo(), k -> new ArrayList<>())
|
||||
.add(requestId);
|
||||
log.info("【调试】handService 加入手术级联列表: prescriptionNo={}", existing.getPrescriptionNo());
|
||||
}
|
||||
}
|
||||
Set<Long> labCascadeSkippedRequestIds = new HashSet<>();
|
||||
// 执行检验申请单级联作废
|
||||
Set<Long> cascadeSkippedRequestIds = new HashSet<>();
|
||||
for (Map.Entry<String, List<Long>> e : labApplyNoToRequestIds.entrySet()) {
|
||||
R<?> delLab = iDoctorStationInspectionLabApplyService.deleteInspectionLabApply(e.getKey());
|
||||
if (delLab != null && R.isSuccess(delLab)) {
|
||||
labCascadeSkippedRequestIds.addAll(e.getValue());
|
||||
cascadeSkippedRequestIds.addAll(e.getValue());
|
||||
log.info("handService - 级联作废检验申请单 applyNo={},已跳过重复删除的医嘱 requestIds={}",
|
||||
e.getKey(), e.getValue());
|
||||
} else {
|
||||
@@ -1831,8 +1870,41 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
e.getKey(), msg);
|
||||
}
|
||||
}
|
||||
// 🔧 手术申请单级联作废:删除手术医嘱时同步作废关联的手术申请单
|
||||
for (Map.Entry<String, List<Long>> e : surgeryPrescriptionNoToRequestIds.entrySet()) {
|
||||
String prescriptionNo = e.getKey();
|
||||
try {
|
||||
List<RequestForm> requestForms = iRequestFormService.list(
|
||||
new LambdaQueryWrapper<RequestForm>()
|
||||
.eq(RequestForm::getPrescriptionNo, prescriptionNo)
|
||||
.in(RequestForm::getTypeCode, ActivityDefCategory.PROCEDURE.getCode().toString(), "SURGERY")
|
||||
.and(w -> w.isNull(RequestForm::getDeleteFlag).or().eq(RequestForm::getDeleteFlag, "0")));
|
||||
log.info("【调试】handService 查询手术申请单: prescriptionNo={}, 查到{}条", prescriptionNo, requestForms != null ? requestForms.size() : 0);
|
||||
if (requestForms != null && !requestForms.isEmpty()) {
|
||||
for (RequestForm requestForm : requestForms) {
|
||||
iRequestFormService.removeById(requestForm.getId());
|
||||
}
|
||||
// 同步删除 cli_surgery 手术记录(prescriptionNo = surgeryNo)
|
||||
Surgery surgery = iSurgeryService.getOne(
|
||||
new LambdaQueryWrapper<Surgery>()
|
||||
.eq(Surgery::getSurgeryNo, prescriptionNo)
|
||||
.and(w -> w.isNull(Surgery::getDeleteFlag).or().eq(Surgery::getDeleteFlag, "0")));
|
||||
if (surgery != null) {
|
||||
iSurgeryService.removeById(surgery.getId());
|
||||
log.info("handService - 级联删除手术记录 cli_surgery: surgeryNo={}, id={}", prescriptionNo, surgery.getId());
|
||||
}
|
||||
cascadeSkippedRequestIds.addAll(e.getValue());
|
||||
log.info("handService - 级联作废手术申请单 prescriptionNo={}", prescriptionNo);
|
||||
} else {
|
||||
log.info("handService - 未找到手术申请单 prescriptionNo={}", prescriptionNo);
|
||||
}
|
||||
} catch (Exception ex) {
|
||||
log.warn("handService - 级联作废手术申请单失败 prescriptionNo={} msg={}", prescriptionNo, ex.getMessage());
|
||||
}
|
||||
}
|
||||
// 级联作废完成后,统一删除 ServiceRequest 及其子项、费用项
|
||||
for (AdviceSaveDto adviceSaveDto : deleteList) {
|
||||
if (labCascadeSkippedRequestIds.contains(adviceSaveDto.getRequestId())) {
|
||||
if (cascadeSkippedRequestIds.contains(adviceSaveDto.getRequestId())) {
|
||||
continue;
|
||||
}
|
||||
Long requestId = adviceSaveDto.getRequestId();
|
||||
@@ -1842,7 +1914,6 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
requestId));// 删除诊疗套餐对应的子项
|
||||
// 🔧 Bug Fix #219: 删除费用项
|
||||
String serviceTable = CommonConstants.TableName.WOR_SERVICE_REQUEST;
|
||||
// 直接删除费用项
|
||||
iChargeItemService.deleteByServiceTableAndId(serviceTable, requestId);
|
||||
log.info("BugFix#219: 诊疗医嘱删除完成, requestId={}, serviceTable={}", requestId, serviceTable);
|
||||
}
|
||||
@@ -2481,21 +2552,17 @@ public class DoctorStationAdviceAppServiceImpl implements IDoctorStationAdviceAp
|
||||
}
|
||||
}
|
||||
|
||||
// 使用直接 LIMIT 查询,不触发 MyBatis Plus 的 COUNT 开销
|
||||
List<SurgeryItemDto> records = doctorStationAdviceAppMapper.getSurgeryPage(
|
||||
// 使用 MyBatis Plus 分页查询
|
||||
IPage<SurgeryItemDto> result = doctorStationAdviceAppMapper.getSurgeryPage(
|
||||
new Page<>(pageNo, pageSize),
|
||||
PublicationStatus.ACTIVE.getValue(),
|
||||
organizationId,
|
||||
searchKey);
|
||||
|
||||
// 手动构造 Page 对象,total 设为 records.size()(前端 el-transfer 不需要精确的 total 总数)
|
||||
IPage<SurgeryItemDto> result = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<>(pageNo, pageSize);
|
||||
result.setRecords(records);
|
||||
result.setTotal(records.size());
|
||||
log.info("getSurgeryPage 完成: {}ms, total={}, records={}", System.currentTimeMillis() - start, result.getTotal(), result.getRecords().size());
|
||||
|
||||
// 无搜索时将结果写入缓存
|
||||
if (useCache) {
|
||||
if (useCache && result instanceof com.baomidou.mybatisplus.extension.plugins.pagination.Page) {
|
||||
redisCache.setCacheObject(cacheKey, result, (int) CACHE_EXPIRE_HOURS, java.util.concurrent.TimeUnit.HOURS);
|
||||
log.info("缓存手术项目, key: {}, 过期时间: {} 小时", cacheKey, CACHE_EXPIRE_HOURS);
|
||||
}
|
||||
|
||||
@@ -96,6 +96,11 @@ public class DiagnosisQueryDto {
|
||||
*/
|
||||
private String diagnosisDoctor;
|
||||
|
||||
/**
|
||||
* 长效诊断标识
|
||||
*/
|
||||
private Integer longTermFlag;
|
||||
|
||||
/**
|
||||
* 是否已有传染病报卡(0-无,1-有)
|
||||
*/
|
||||
|
||||
@@ -195,7 +195,7 @@ public interface DoctorStationAdviceAppMapper {
|
||||
* @param searchKey 模糊查询关键字(可选)
|
||||
* @return 手术项目分页数据
|
||||
*/
|
||||
List<SurgeryItemDto> getSurgeryPage(@Param("page") Page<SurgeryItemDto> page,
|
||||
IPage<SurgeryItemDto> getSurgeryPage(@Param("page") Page<SurgeryItemDto> page,
|
||||
@Param("statusEnum") Integer statusEnum,
|
||||
@Param("organizationId") Long organizationId,
|
||||
@Param("searchKey") String searchKey);
|
||||
|
||||
@@ -32,6 +32,7 @@ import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import java.math.BigDecimal;
|
||||
import java.util.*;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
@@ -202,62 +203,70 @@ public class ProductTransferAppServiceImpl implements IProductTransferAppService
|
||||
@Override
|
||||
public R<?> addOrEditBatchTransferReceipt(List<ProductTransferDto> productTransferDtoList, Boolean flag) {
|
||||
|
||||
// 校验调拨数量:必须 > 0 且不超过源库存数量(从数据库查实时库存)
|
||||
Integer tenantId = SecurityUtils.getLoginUser().getTenantId();
|
||||
for (ProductTransferDto dto : productTransferDtoList) {
|
||||
if (dto.getItemQuantity() == null || dto.getItemQuantity().compareTo(java.math.BigDecimal.ZERO) <= 0) {
|
||||
return R.fail("调拨数量必须大于0");
|
||||
}
|
||||
// 查询该药品在源仓库的实时库存总量
|
||||
List<InventoryItem> inventoryList = inventoryItemService.selectInventoryByItemId(
|
||||
dto.getItemId(), dto.getLotNumber(), dto.getSourceLocationId(), tenantId);
|
||||
java.math.BigDecimal actualStock = inventoryList.stream()
|
||||
.map(InventoryItem::getQuantity)
|
||||
.reduce(java.math.BigDecimal.ZERO, java.math.BigDecimal::add);
|
||||
if (dto.getItemQuantity().compareTo(actualStock) > 0) {
|
||||
return R.fail("调拨数量不可超出源库存数量(当前库存:" + actualStock + ")");
|
||||
}
|
||||
}
|
||||
Date now = DateUtils.getNowDate();
|
||||
|
||||
List<String> idList = new ArrayList<>();
|
||||
if (flag) {
|
||||
// 批量保存按钮
|
||||
// 单据号取得
|
||||
List<String> busNoList = productTransferDtoList.stream().map(ProductTransferDto::getBusNo).toList();
|
||||
// 请求id取得
|
||||
List<SupplyRequest> requestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||
if (!requestList.isEmpty()) {
|
||||
List<Long> requestIdList = requestList.stream().map(SupplyRequest::getId).collect(Collectors.toList());
|
||||
// 单据信息删除
|
||||
supplyRequestService.removeByIds(requestIdList);
|
||||
// 保存前:获取旧记录用于恢复预划扣库存
|
||||
List<SupplyRequest> oldRequestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||
if (!oldRequestList.isEmpty()) {
|
||||
// 恢复旧记录已预划扣的库存
|
||||
for (SupplyRequest oldReq : oldRequestList) {
|
||||
if (oldReq.getItemId() != null && oldReq.getLotNumber() != null
|
||||
&& oldReq.getSourceLocationId() != null && oldReq.getItemQuantity() != null) {
|
||||
List<InventoryItem> invList = inventoryItemService.selectInventoryByItemId(
|
||||
oldReq.getItemId(), oldReq.getLotNumber(), oldReq.getSourceLocationId(), tenantId);
|
||||
if (!invList.isEmpty()) {
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
invList.get(0).getId(),
|
||||
invList.get(0).getQuantity().add(oldReq.getItemQuantity()), now);
|
||||
}
|
||||
}
|
||||
}
|
||||
List<Long> oldIdList = oldRequestList.stream().map(SupplyRequest::getId).collect(Collectors.toList());
|
||||
supplyRequestService.removeByIds(oldIdList);
|
||||
}
|
||||
|
||||
// 校验 + 预划扣新记录
|
||||
for (ProductTransferDto dto : productTransferDtoList) {
|
||||
if (dto.getItemQuantity() == null || dto.getItemQuantity().compareTo(BigDecimal.ZERO) <= 0) {
|
||||
return R.fail("调拨数量必须大于0");
|
||||
}
|
||||
List<InventoryItem> inventoryList = inventoryItemService.selectInventoryByItemId(
|
||||
dto.getItemId(), dto.getLotNumber(), dto.getSourceLocationId(), tenantId);
|
||||
BigDecimal actualStock = inventoryList.stream()
|
||||
.map(InventoryItem::getQuantity)
|
||||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||||
if (dto.getItemQuantity().compareTo(actualStock) > 0) {
|
||||
return R.fail("调拨数量不可超出源库存数量(当前库存:" + actualStock + ")");
|
||||
}
|
||||
// 预划扣源仓库库存
|
||||
if (!inventoryList.isEmpty()) {
|
||||
InventoryItem inv = inventoryList.get(0);
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
inv.getId(), inv.getQuantity().subtract(dto.getItemQuantity()), now);
|
||||
}
|
||||
}
|
||||
|
||||
// 生成批量调拨单据
|
||||
List<SupplyRequest> supplyRequestList = new ArrayList<>();
|
||||
for (ProductTransferDto productTransferDto : productTransferDtoList) {
|
||||
// 初始化单据信息
|
||||
SupplyRequest supplyRequest = new SupplyRequest();
|
||||
BeanUtils.copyProperties(productTransferDto, supplyRequest);
|
||||
// 生成商品批量调拨单据
|
||||
supplyRequest
|
||||
// id
|
||||
.setId(null)
|
||||
// 单据分类:库存供应
|
||||
.setCategoryEnum(SupplyCategory.STOCK_SUPPLY.getValue())
|
||||
// 单据类型:商品批量调拨
|
||||
.setTypeEnum(SupplyType.PRODUCT_BATCH_TRANSFER.getValue())
|
||||
// 制单人
|
||||
.setApplicantId(SecurityUtils.getLoginUser().getPractitionerId())
|
||||
// 申请时间
|
||||
.setApplyTime(DateUtils.getNowDate())
|
||||
// 源库存数量
|
||||
.setTotalQuantity(productTransferDto.getTotalSourceQuantity());
|
||||
supplyRequestList.add(supplyRequest);
|
||||
}
|
||||
supplyRequestService.saveOrUpdateBatch(supplyRequestList);
|
||||
// 请求id取得
|
||||
List<SupplyRequest> supplyRequestIdList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||
// 返回请求id列表
|
||||
List<Long> requestIdList = supplyRequestIdList.stream().map(SupplyRequest::getId).toList();
|
||||
for (Long list : requestIdList) {
|
||||
idList.add(list.toString());
|
||||
@@ -265,33 +274,58 @@ public class ProductTransferAppServiceImpl implements IProductTransferAppService
|
||||
} else {
|
||||
// 单独保存按钮
|
||||
for (ProductTransferDto productTransferDto : productTransferDtoList) {
|
||||
// 初始化单据信息
|
||||
// 更新已有记录:先恢复旧预划扣,再扣新的
|
||||
if (productTransferDto.getId() != null) {
|
||||
SupplyRequest oldReq = supplyRequestService.getById(productTransferDto.getId());
|
||||
if (oldReq != null && oldReq.getItemId() != null && oldReq.getLotNumber() != null
|
||||
&& oldReq.getSourceLocationId() != null && oldReq.getItemQuantity() != null) {
|
||||
List<InventoryItem> invList = inventoryItemService.selectInventoryByItemId(
|
||||
oldReq.getItemId(), oldReq.getLotNumber(), oldReq.getSourceLocationId(), tenantId);
|
||||
if (!invList.isEmpty()) {
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
invList.get(0).getId(),
|
||||
invList.get(0).getQuantity().add(oldReq.getItemQuantity()), now);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// 校验 + 预划扣
|
||||
if (productTransferDto.getItemQuantity() == null
|
||||
|| productTransferDto.getItemQuantity().compareTo(BigDecimal.ZERO) <= 0) {
|
||||
return R.fail("调拨数量必须大于0");
|
||||
}
|
||||
List<InventoryItem> inventoryList = inventoryItemService.selectInventoryByItemId(
|
||||
productTransferDto.getItemId(), productTransferDto.getLotNumber(),
|
||||
productTransferDto.getSourceLocationId(), tenantId);
|
||||
BigDecimal actualStock = inventoryList.stream()
|
||||
.map(InventoryItem::getQuantity)
|
||||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||||
if (productTransferDto.getItemQuantity().compareTo(actualStock) > 0) {
|
||||
return R.fail("调拨数量不可超出源库存数量(当前库存:" + actualStock + ")");
|
||||
}
|
||||
if (!inventoryList.isEmpty()) {
|
||||
InventoryItem inv = inventoryList.get(0);
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
inv.getId(), inv.getQuantity().subtract(productTransferDto.getItemQuantity()), now);
|
||||
}
|
||||
|
||||
SupplyRequest supplyRequest = new SupplyRequest();
|
||||
BeanUtils.copyProperties(productTransferDto, supplyRequest);
|
||||
|
||||
supplyRequest.setTotalQuantity(productTransferDto.getTotalSourceQuantity());
|
||||
|
||||
if (productTransferDto.getId() != null) {
|
||||
// 更新单据信息
|
||||
supplyRequestService.updateById(supplyRequest);
|
||||
} else {
|
||||
// 生成商品批量调拨单据
|
||||
supplyRequest
|
||||
// 单据分类:库存供应
|
||||
.setCategoryEnum(SupplyCategory.STOCK_SUPPLY.getValue())
|
||||
// 单据类型:商品批量调拨
|
||||
.setTypeEnum(SupplyType.PRODUCT_BATCH_TRANSFER.getValue())
|
||||
// 制单人
|
||||
.setApplicantId(SecurityUtils.getLoginUser().getPractitionerId())
|
||||
// 申请时间
|
||||
.setApplyTime(DateUtils.getNowDate());
|
||||
supplyRequestService.save(supplyRequest);
|
||||
}
|
||||
// 返回单据id
|
||||
return R.ok(supplyRequest.getId().toString(), null);
|
||||
}
|
||||
}
|
||||
// 返回单据id
|
||||
return R.ok(idList, null);
|
||||
}
|
||||
|
||||
@@ -332,33 +366,63 @@ public class ProductTransferAppServiceImpl implements IProductTransferAppService
|
||||
@Override
|
||||
public R<?> addOrEditTransferReceipt(List<ProductTransferDto> productTransferDtoList) {
|
||||
|
||||
// 校验调拨数量:必须 > 0 且不超过源库存数量(从数据库查实时库存)
|
||||
Integer tenantId = SecurityUtils.getLoginUser().getTenantId();
|
||||
for (ProductTransferDto dto : productTransferDtoList) {
|
||||
if (dto.getItemQuantity() == null || dto.getItemQuantity().compareTo(java.math.BigDecimal.ZERO) <= 0) {
|
||||
return R.fail("调拨数量必须大于0");
|
||||
}
|
||||
List<InventoryItem> inventoryList = inventoryItemService.selectInventoryByItemId(
|
||||
dto.getItemId(), dto.getLotNumber(), dto.getSourceLocationId(), tenantId);
|
||||
java.math.BigDecimal actualStock = inventoryList.stream()
|
||||
.map(InventoryItem::getQuantity)
|
||||
.reduce(java.math.BigDecimal.ZERO, java.math.BigDecimal::add);
|
||||
if (dto.getItemQuantity().compareTo(actualStock) > 0) {
|
||||
return R.fail("调拨数量不可超出源库存数量(当前库存:" + actualStock + ")");
|
||||
}
|
||||
}
|
||||
Date now = DateUtils.getNowDate();
|
||||
|
||||
List<String> idList = new ArrayList<>();
|
||||
|
||||
// 单据号取得
|
||||
List<String> busNoList = productTransferDtoList.stream().map(ProductTransferDto::getBusNo).toList();
|
||||
// 请求数据取得
|
||||
List<SupplyRequest> requestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||
if (!requestList.isEmpty()) {
|
||||
// 请求id取得
|
||||
List<Long> requestIdList = requestList.stream().map(SupplyRequest::getId).collect(Collectors.toList());
|
||||
// 单据信息删除
|
||||
supplyRequestService.removeByIds(requestIdList);
|
||||
// 保存前:获取旧记录用于恢复预划扣库存
|
||||
List<SupplyRequest> oldRequestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||
Map<String, BigDecimal> oldDeductionMap = new HashMap<>();
|
||||
if (!oldRequestList.isEmpty()) {
|
||||
for (SupplyRequest oldReq : oldRequestList) {
|
||||
if (oldReq.getItemId() != null && oldReq.getLotNumber() != null && oldReq.getSourceLocationId() != null
|
||||
&& oldReq.getItemQuantity() != null) {
|
||||
String key = oldReq.getItemId() + "_" + oldReq.getLotNumber() + "_" + oldReq.getSourceLocationId();
|
||||
oldDeductionMap.merge(key, oldReq.getItemQuantity(), BigDecimal::add);
|
||||
}
|
||||
}
|
||||
// 恢复旧记录已预划扣的库存
|
||||
for (Map.Entry<String, BigDecimal> entry : oldDeductionMap.entrySet()) {
|
||||
String[] parts = entry.getKey().split("_");
|
||||
Long itemId = Long.parseLong(parts[0]);
|
||||
String lotNumber = parts[1];
|
||||
Long sourceLocationId = Long.parseLong(parts[2]);
|
||||
BigDecimal restoreQty = entry.getValue();
|
||||
List<InventoryItem> invList = inventoryItemService.selectInventoryByItemId(
|
||||
itemId, lotNumber, sourceLocationId, tenantId);
|
||||
if (!invList.isEmpty()) {
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
invList.get(0).getId(), invList.get(0).getQuantity().add(restoreQty), now);
|
||||
}
|
||||
}
|
||||
// 删除旧记录
|
||||
List<Long> oldIdList = oldRequestList.stream().map(SupplyRequest::getId).collect(Collectors.toList());
|
||||
supplyRequestService.removeByIds(oldIdList);
|
||||
}
|
||||
|
||||
// 校验 + 预划扣新记录
|
||||
Map<String, BigDecimal> newDeductionMap = new HashMap<>();
|
||||
for (ProductTransferDto dto : productTransferDtoList) {
|
||||
if (dto.getItemQuantity() == null || dto.getItemQuantity().compareTo(BigDecimal.ZERO) <= 0) {
|
||||
return R.fail("调拨数量必须大于0");
|
||||
}
|
||||
List<InventoryItem> inventoryList = inventoryItemService.selectInventoryByItemId(
|
||||
dto.getItemId(), dto.getLotNumber(), dto.getSourceLocationId(), tenantId);
|
||||
BigDecimal actualStock = inventoryList.stream()
|
||||
.map(InventoryItem::getQuantity)
|
||||
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||||
if (dto.getItemQuantity().compareTo(actualStock) > 0) {
|
||||
return R.fail("调拨数量不可超出源库存数量(当前库存:" + actualStock + ")");
|
||||
}
|
||||
// 预划扣:扣减源仓库库存
|
||||
if (!inventoryList.isEmpty()) {
|
||||
InventoryItem inv = inventoryList.get(0);
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
inv.getId(), inv.getQuantity().subtract(dto.getItemQuantity()), now);
|
||||
}
|
||||
}
|
||||
|
||||
List<SupplyRequest> supplyRequestList = new ArrayList<>();
|
||||
@@ -405,6 +469,22 @@ public class ProductTransferAppServiceImpl implements IProductTransferAppService
|
||||
*/
|
||||
@Override
|
||||
public R<?> deleteReceipt(List<Long> supplyRequestIds) {
|
||||
// 删除前恢复预划扣的库存
|
||||
Integer tenantId = SecurityUtils.getLoginUser().getTenantId();
|
||||
Date now = DateUtils.getNowDate();
|
||||
for (Long reqId : supplyRequestIds) {
|
||||
SupplyRequest sr = supplyRequestService.getById(reqId);
|
||||
if (sr != null && sr.getItemId() != null && sr.getSourceLocationId() != null
|
||||
&& sr.getItemQuantity() != null && sr.getLotNumber() != null) {
|
||||
List<InventoryItem> invList = inventoryItemService.selectInventoryByItemId(
|
||||
sr.getItemId(), sr.getLotNumber(), sr.getSourceLocationId(), tenantId);
|
||||
if (!invList.isEmpty()) {
|
||||
InventoryItem inv = invList.get(0);
|
||||
inventoryItemService.updateInventoryQuantity(
|
||||
inv.getId(), inv.getQuantity().add(sr.getItemQuantity()), now);
|
||||
}
|
||||
}
|
||||
}
|
||||
// 删除单据
|
||||
boolean result = supplyRequestService.removeByIds(supplyRequestIds);
|
||||
return result ? R.ok(null, MessageUtils.createMessage(PromptMsgConstant.Common.M00004, null))
|
||||
|
||||
@@ -519,58 +519,8 @@ public class ReceiptApprovalAppServiceImpl implements IReceiptApprovalAppService
|
||||
// 暂时先取出全部的库存,循环查库存同一会有问题,后续优化
|
||||
List<InventoryItem> inventoryItems = inventoryItemService.selectAllInventory();
|
||||
for (SupplyItemDetailDto supplyItemDetailDto : supplyItemDetailList) {
|
||||
// 根据项目id,产品批号,源仓库id 查询源仓库库存表信息
|
||||
// List<InventoryItem> inventoryItemSourceList = inventoryItemService.selectInventoryByItemId(
|
||||
// supplyItemDetailDto.getItemId(), supplyItemDetailDto.getLotNumber(),
|
||||
// supplyItemDetailDto.getSourceLocationId(), SecurityUtils.getLoginUser().getTenantId());
|
||||
List<InventoryItem> filteredInventoryItems = inventoryItems.stream()
|
||||
.filter(item -> item.getItemId().equals(supplyItemDetailDto.getItemId())
|
||||
&& item.getLotNumber().equals(supplyItemDetailDto.getLotNumber())
|
||||
&& item.getLocationId().equals(supplyItemDetailDto.getSourceLocationId()))
|
||||
.collect(Collectors.toList());
|
||||
|
||||
InventoryItem inventoryItemSource = new InventoryItem();
|
||||
if (!filteredInventoryItems.isEmpty()) {
|
||||
inventoryItemSource = filteredInventoryItems.get(0);
|
||||
// 最小数量(最小单位库存数量)
|
||||
BigDecimal minQuantity = inventoryItemSource.getQuantity();
|
||||
|
||||
// // 计算调拨后库存数量,结果取小单位
|
||||
// // 供应申请的物品计量单位与包装单位相同
|
||||
// if (supplyItemDetailDto.getItemUnit().equals(supplyItemDetailDto.getUnitCode())) {
|
||||
// if
|
||||
// (minQuantity.compareTo(supplyItemDetailDto.getItemQuantity().multiply(supplyItemDetailDto.getPartPercent()))
|
||||
// < 0) {
|
||||
// // 库存数量不足
|
||||
// throw new ServiceException("操作失败,库存数量不足");
|
||||
// } else {
|
||||
// // 源仓库库存-(调拨数量*拆零比)
|
||||
// minQuantity = minQuantity.subtract(
|
||||
// supplyItemDetailDto.getPartPercent().multiply(supplyItemDetailDto.getItemQuantity()));
|
||||
// }
|
||||
// } else if (supplyItemDetailDto.getItemUnit().equals(supplyItemDetailDto.getMinUnitCode())) {
|
||||
// 直接扣减库存
|
||||
if (minQuantity.compareTo(supplyItemDetailDto.getItemQuantity()) < 0) {
|
||||
// 库存数量不足
|
||||
throw new ServiceException("操作失败,库存数量不足");
|
||||
} else {
|
||||
// 供应申请的物品计量单位与最小单位相同
|
||||
// 源仓库库存-调拨数量
|
||||
minQuantity = minQuantity.subtract(supplyItemDetailDto.getItemQuantity());
|
||||
}
|
||||
// }
|
||||
// 更新源仓库库存数量
|
||||
Boolean aBoolean
|
||||
= inventoryItemService.updateInventoryQuantity(inventoryItemSource.getId(), minQuantity, now);
|
||||
if (!aBoolean) {
|
||||
throw new ServiceException("系统异常,请稍后重试");
|
||||
}
|
||||
|
||||
// 添加到出库列表
|
||||
outList.add(supplyItemDetailDto);
|
||||
} else {
|
||||
return R.fail(MessageUtils.createMessage(PromptMsgConstant.Common.M00007, null));
|
||||
}
|
||||
// 🔧 源仓库库存已在保存时预划扣,审批通过时不再重复扣减
|
||||
outList.add(supplyItemDetailDto);
|
||||
|
||||
// 根据项目id,产品批号,目的仓库id 查询目的仓库库存表信息
|
||||
List<InventoryItem> inventoryItemPurposeList = inventoryItemService.selectInventoryByItemId(
|
||||
|
||||
@@ -36,6 +36,8 @@ import com.openhis.workflow.domain.ActivityDefinition;
|
||||
import com.openhis.workflow.service.IDeviceDispenseService;
|
||||
import com.openhis.workflow.service.IDeviceRequestService;
|
||||
import com.openhis.workflow.service.IServiceRequestService;
|
||||
import com.openhis.document.domain.RequestForm;
|
||||
import com.openhis.document.service.IRequestFormService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@@ -85,6 +87,9 @@ public class AdviceManageAppServiceImpl implements IAdviceManageAppService {
|
||||
@Resource
|
||||
IDeviceDispenseService iDeviceDispenseService;
|
||||
|
||||
@Resource
|
||||
IRequestFormService iRequestFormService;
|
||||
|
||||
/**
|
||||
* 查询住院患者信息
|
||||
*
|
||||
@@ -266,6 +271,38 @@ public class AdviceManageAppServiceImpl implements IAdviceManageAppService {
|
||||
|
||||
log.info("开始处理删除操作,共 {} 条记录", deleteList.size());
|
||||
|
||||
// 🔧 手术申请单级联作废:删除手术医嘱(categoryEnum=24)时同步作废关联的手术申请单
|
||||
Map<String, List<Long>> surgeryPrescriptionNoToRequestIds = new LinkedHashMap<>();
|
||||
for (RegAdviceSaveDto adviceDto : deleteList) {
|
||||
if (adviceDto.getRequestId() == null) continue;
|
||||
ServiceRequest existing = iServiceRequestService.getById(adviceDto.getRequestId());
|
||||
if (existing == null) continue;
|
||||
if (existing.getCategoryEnum() != null
|
||||
&& existing.getCategoryEnum() == 24
|
||||
&& existing.getPrescriptionNo() != null && !existing.getPrescriptionNo().isEmpty()) {
|
||||
surgeryPrescriptionNoToRequestIds.computeIfAbsent(existing.getPrescriptionNo(), k -> new ArrayList<>())
|
||||
.add(adviceDto.getRequestId());
|
||||
}
|
||||
}
|
||||
for (Map.Entry<String, List<Long>> e : surgeryPrescriptionNoToRequestIds.entrySet()) {
|
||||
String prescriptionNo = e.getKey();
|
||||
try {
|
||||
List<RequestForm> requestForms = iRequestFormService.list(
|
||||
new LambdaQueryWrapper<RequestForm>()
|
||||
.eq(RequestForm::getPrescriptionNo, prescriptionNo)
|
||||
.eq(RequestForm::getTypeCode, ActivityDefCategory.PROCEDURE.getCode())
|
||||
.and(w -> w.isNull(RequestForm::getDeleteFlag).or().eq(RequestForm::getDeleteFlag, "0")));
|
||||
for (RequestForm requestForm : requestForms) {
|
||||
iRequestFormService.removeById(requestForm.getId());
|
||||
}
|
||||
if (!requestForms.isEmpty()) {
|
||||
log.info("级联作废手术申请单 prescriptionNo={}, 共{}条", prescriptionNo, requestForms.size());
|
||||
}
|
||||
} catch (Exception ex) {
|
||||
log.warn("级联作废手术申请单失败 prescriptionNo={}", prescriptionNo, ex);
|
||||
}
|
||||
}
|
||||
|
||||
for (RegAdviceSaveDto adviceDto : deleteList) {
|
||||
Integer adviceType = adviceDto.getAdviceType();
|
||||
Long requestId = adviceDto.getRequestId();
|
||||
|
||||
@@ -81,16 +81,7 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
Long requestFormId = requestFormSaveDto.getRequestFormId();
|
||||
boolean isEdit = requestFormId != null && requestFormId != 0L;
|
||||
|
||||
// 诊疗执行科室配置校验(必须在任何数据库操作之前)
|
||||
List<ActivityOrganizationConfigDto> activityOrganizationConfig =
|
||||
requestFormManageAppMapper.getActivityOrganizationConfig(typeCode);
|
||||
if (activityOrganizationConfig.isEmpty()) {
|
||||
throw new ServiceException("请先配置当前时间段的执行科室");
|
||||
}
|
||||
|
||||
// 逐个校验activityList中的项目是否都配置了执行科室,并收集positionId供后续使用
|
||||
// 必须在任何数据库操作之前完成全部校验,避免部分保存后异常导致脏数据
|
||||
// 🔧 Bug #516: 优先使用前端传入的positionId(用户手动选择的发往科室),仅在未选择时使用配置的执行科室
|
||||
// 🔧 手术/检查申请单:优先使用前端传入的positionId(用户手动选择的发往科室),跳过执行科室配置校验
|
||||
List<ActivitySaveDto> activityList = requestFormSaveDto.getActivityList();
|
||||
// 缓存校验结果,避免主循环中重复查询和可能出现的数据不一致
|
||||
java.util.Map<Long, Long> activityIdToPositionIdMap = new java.util.HashMap<>();
|
||||
@@ -102,14 +93,15 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), frontendPositionId);
|
||||
continue;
|
||||
}
|
||||
// 前端未传入时,使用配置的执行科室
|
||||
// 前端未传入时,查询配置的执行科室(暂不校验,仅用于兼容无前端传入的场景)
|
||||
List<ActivityOrganizationConfigDto> activityOrganizationConfig =
|
||||
requestFormManageAppMapper.getActivityOrganizationConfig(typeCode);
|
||||
Long configPositionId = activityOrganizationConfig.stream()
|
||||
.filter(dto -> activitySaveDto.getAdviceDefinitionId().equals(dto.getActivityDefinitionId()))
|
||||
.map(ActivityOrganizationConfigDto::getOrganizationId).findFirst().orElse(null);
|
||||
if (configPositionId == null) {
|
||||
throw new ServiceException(activitySaveDto.getAdviceDefinitionName() + "未配置当前时间段的执行科室");
|
||||
if (configPositionId != null) {
|
||||
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), configPositionId);
|
||||
}
|
||||
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), configPositionId);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -176,73 +168,77 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
ChargeItem chargeItem;
|
||||
log.info("保存申请单,typeCode={}, activityListSize={}, encounterId={}", typeCode, activityList != null ? activityList.size() : 0, encounterId);
|
||||
|
||||
for (ActivitySaveDto activitySaveDto : activityList) {
|
||||
serviceRequest = new ServiceRequest();
|
||||
serviceRequest.setStatusEnum(RequestStatus.DRAFT.getValue());
|
||||
serviceRequest.setBusNo(assignSeqUtil.getSeqByDay(AssignSeqEnum.SERVICE_RES_NO.getPrefix(), 4));
|
||||
serviceRequest.setGenerateSourceEnum(GenerateSource.DOCTOR_PRESCRIPTION.getValue()); // 生成来源
|
||||
serviceRequest.setPrescriptionNo(prescriptionNo);
|
||||
serviceRequest.setTherapyEnum(TherapyTimeType.TEMPORARY.getValue());// 治疗类型
|
||||
serviceRequest.setQuantity(activitySaveDto.getQuantity()); // 请求数量
|
||||
serviceRequest.setUnitCode(activitySaveDto.getUnitCode()); // 请求单位编码
|
||||
serviceRequest.setCategoryEnum(categoryEnum); // 请求类型
|
||||
serviceRequest.setActivityId(activitySaveDto.getAdviceDefinitionId());// 诊疗定义id
|
||||
serviceRequest.setPatientId(patientId); // 患者
|
||||
serviceRequest.setRequesterId(practitionerId); // 开方医生
|
||||
serviceRequest.setEncounterId(encounterId); // 就诊id
|
||||
serviceRequest.setAuthoredTime(curDate); // 请求签发时间
|
||||
// 🔧 手术申请单:跳过普通医嘱生成,只由 isProcedure 块生成手术医嘱,避免重复
|
||||
boolean isSurgeryRequest = ActivityDefCategory.PROCEDURE.getCode().equals(typeCode);
|
||||
if (!isSurgeryRequest) {
|
||||
for (ActivitySaveDto activitySaveDto : activityList) {
|
||||
serviceRequest = new ServiceRequest();
|
||||
serviceRequest.setStatusEnum(RequestStatus.DRAFT.getValue());
|
||||
serviceRequest.setBusNo(assignSeqUtil.getSeqByDay(AssignSeqEnum.SERVICE_RES_NO.getPrefix(), 4));
|
||||
serviceRequest.setGenerateSourceEnum(GenerateSource.DOCTOR_PRESCRIPTION.getValue()); // 生成来源
|
||||
serviceRequest.setPrescriptionNo(prescriptionNo);
|
||||
serviceRequest.setTherapyEnum(TherapyTimeType.TEMPORARY.getValue());// 治疗类型
|
||||
serviceRequest.setQuantity(activitySaveDto.getQuantity()); // 请求数量
|
||||
serviceRequest.setUnitCode(activitySaveDto.getUnitCode()); // 请求单位编码
|
||||
serviceRequest.setCategoryEnum(categoryEnum); // 请求类型
|
||||
serviceRequest.setActivityId(activitySaveDto.getAdviceDefinitionId());// 诊疗定义id
|
||||
serviceRequest.setPatientId(patientId); // 患者
|
||||
serviceRequest.setRequesterId(practitionerId); // 开方医生
|
||||
serviceRequest.setEncounterId(encounterId); // 就诊id
|
||||
serviceRequest.setAuthoredTime(curDate); // 请求签发时间
|
||||
|
||||
Long positionId = activityIdToPositionIdMap.get(activitySaveDto.getAdviceDefinitionId());
|
||||
if (positionId == null) {
|
||||
throw new ServiceException(activitySaveDto.getAdviceDefinitionName() + "未配置当前时间段的执行科室");
|
||||
}
|
||||
serviceRequest.setOrgId(positionId); // 执行科室
|
||||
Long positionId = activityIdToPositionIdMap.get(activitySaveDto.getAdviceDefinitionId());
|
||||
if (positionId == null) {
|
||||
throw new ServiceException(activitySaveDto.getAdviceDefinitionName() + "未配置当前时间段的执行科室");
|
||||
}
|
||||
serviceRequest.setOrgId(positionId); // 执行科室
|
||||
|
||||
serviceRequest.setYbClassEnum(activitySaveDto.getYbClassEnum());// 类别医保编码
|
||||
serviceRequest.setConditionId(activitySaveDto.getConditionId()); // 诊断id
|
||||
serviceRequest.setEncounterDiagnosisId(activitySaveDto.getEncounterDiagnosisId()); // 就诊诊断id
|
||||
iServiceRequestService.save(serviceRequest);
|
||||
serviceRequest.setYbClassEnum(activitySaveDto.getYbClassEnum());// 类别医保编码
|
||||
serviceRequest.setConditionId(activitySaveDto.getConditionId()); // 诊断id
|
||||
serviceRequest.setEncounterDiagnosisId(activitySaveDto.getEncounterDiagnosisId()); // 就诊诊断id
|
||||
iServiceRequestService.save(serviceRequest);
|
||||
|
||||
chargeItem = new ChargeItem();
|
||||
chargeItem.setStatusEnum(ChargeItemStatus.DRAFT.getValue()); // 收费状态
|
||||
chargeItem.setBusNo(AssignSeqEnum.CHARGE_ITEM_NO.getPrefix().concat(serviceRequest.getBusNo()));
|
||||
chargeItem.setGenerateSourceEnum(GenerateSource.DOCTOR_PRESCRIPTION.getValue()); // 生成来源
|
||||
chargeItem.setPatientId(patientId); // 患者
|
||||
chargeItem.setContextEnum(activitySaveDto.getAdviceType()); // 类型
|
||||
chargeItem.setEncounterId(encounterId); // 就诊id
|
||||
chargeItem.setDefinitionId(activitySaveDto.getDefinitionId()); // 费用定价ID
|
||||
chargeItem.setDefDetailId(activitySaveDto.getDefinitionDetailId()); // 定价子表主键
|
||||
chargeItem.setEntererId(practitionerId);// 开立人ID
|
||||
chargeItem.setEnteredDate(curDate); // 开立时间
|
||||
chargeItem.setServiceTable(CommonConstants.TableName.WOR_SERVICE_REQUEST);// 医疗服务类型
|
||||
chargeItem.setServiceId(serviceRequest.getId()); // 医疗服务ID
|
||||
chargeItem.setProductTable(CommonConstants.TableName.WOR_ACTIVITY_DEFINITION);// 产品所在表
|
||||
chargeItem.setProductId(activitySaveDto.getAdviceDefinitionId());// 收费项id
|
||||
chargeItem.setAccountId(activitySaveDto.getAccountId());// 关联账户ID
|
||||
chargeItem.setRequestingOrgId(orgId); // 开立科室
|
||||
chargeItem.setConditionId(activitySaveDto.getConditionId()); // 诊断id
|
||||
chargeItem.setEncounterDiagnosisId(activitySaveDto.getEncounterDiagnosisId()); // 就诊诊断id
|
||||
chargeItem.setQuantityValue(activitySaveDto.getQuantity()); // 数量
|
||||
chargeItem.setQuantityUnit(activitySaveDto.getUnitCode()); // 单位
|
||||
chargeItem.setUnitPrice(activitySaveDto.getUnitPrice()); // 单价
|
||||
chargeItem.setTotalPrice(activitySaveDto.getTotalPrice()); // 总价
|
||||
iChargeItemService.save(chargeItem);
|
||||
chargeItem = new ChargeItem();
|
||||
chargeItem.setStatusEnum(ChargeItemStatus.DRAFT.getValue()); // 收费状态
|
||||
chargeItem.setBusNo(AssignSeqEnum.CHARGE_ITEM_NO.getPrefix().concat(serviceRequest.getBusNo()));
|
||||
chargeItem.setGenerateSourceEnum(GenerateSource.DOCTOR_PRESCRIPTION.getValue()); // 生成来源
|
||||
chargeItem.setPatientId(patientId); // 患者
|
||||
chargeItem.setContextEnum(activitySaveDto.getAdviceType()); // 类型
|
||||
chargeItem.setEncounterId(encounterId); // 就诊id
|
||||
chargeItem.setDefinitionId(activitySaveDto.getDefinitionId()); // 费用定价ID
|
||||
chargeItem.setDefDetailId(activitySaveDto.getDefinitionDetailId()); // 定价子表主键
|
||||
chargeItem.setEntererId(practitionerId);// 开立人ID
|
||||
chargeItem.setEnteredDate(curDate); // 开立时间
|
||||
chargeItem.setServiceTable(CommonConstants.TableName.WOR_SERVICE_REQUEST);// 医疗服务类型
|
||||
chargeItem.setServiceId(serviceRequest.getId()); // 医疗服务ID
|
||||
chargeItem.setProductTable(CommonConstants.TableName.WOR_ACTIVITY_DEFINITION);// 产品所在表
|
||||
chargeItem.setProductId(activitySaveDto.getAdviceDefinitionId());// 收费项id
|
||||
chargeItem.setAccountId(activitySaveDto.getAccountId());// 关联账户ID
|
||||
chargeItem.setRequestingOrgId(orgId); // 开立科室
|
||||
chargeItem.setConditionId(activitySaveDto.getConditionId()); // 诊断id
|
||||
chargeItem.setEncounterDiagnosisId(activitySaveDto.getEncounterDiagnosisId()); // 就诊诊断id
|
||||
chargeItem.setQuantityValue(activitySaveDto.getQuantity()); // 数量
|
||||
chargeItem.setQuantityUnit(activitySaveDto.getUnitCode()); // 单位
|
||||
chargeItem.setUnitPrice(activitySaveDto.getUnitPrice()); // 单价
|
||||
chargeItem.setTotalPrice(activitySaveDto.getTotalPrice()); // 总价
|
||||
iChargeItemService.save(chargeItem);
|
||||
|
||||
// 处理诊疗套餐的子项信息
|
||||
ActivityDefinition activityDefinition =
|
||||
iActivityDefinitionService.getById(activitySaveDto.getAdviceDefinitionId());
|
||||
String childrenJson = activityDefinition.getChildrenJson();
|
||||
if (childrenJson != null) {
|
||||
// 诊疗子项参数类
|
||||
ActivityChildrenJsonParams activityChildrenJsonParams = new ActivityChildrenJsonParams();
|
||||
activityChildrenJsonParams.setTherapyEnum(TherapyTimeType.TEMPORARY.getValue()); // 治疗类型
|
||||
activityChildrenJsonParams.setPatientId(serviceRequest.getPatientId()); // 患者
|
||||
activityChildrenJsonParams.setEncounterId(serviceRequest.getEncounterId()); // 就诊id
|
||||
activityChildrenJsonParams.setAccountId(chargeItem.getAccountId()); // 账户id
|
||||
activityChildrenJsonParams.setChargeItemId(chargeItem.getId()); // 费用项id
|
||||
activityChildrenJsonParams.setParentId(serviceRequest.getId());// 子项诊疗的父id
|
||||
activityChildrenJsonParams.setEncounterDiagnosisId(serviceRequest.getEncounterDiagnosisId());
|
||||
adviceUtils.handleActivityChild(childrenJson, organizationId, activityChildrenJsonParams);
|
||||
// 处理诊疗套餐的子项信息
|
||||
ActivityDefinition activityDefinition =
|
||||
iActivityDefinitionService.getById(activitySaveDto.getAdviceDefinitionId());
|
||||
String childrenJson = activityDefinition.getChildrenJson();
|
||||
if (childrenJson != null) {
|
||||
// 诊疗子项参数类
|
||||
ActivityChildrenJsonParams activityChildrenJsonParams = new ActivityChildrenJsonParams();
|
||||
activityChildrenJsonParams.setTherapyEnum(TherapyTimeType.TEMPORARY.getValue()); // 治疗类型
|
||||
activityChildrenJsonParams.setPatientId(serviceRequest.getPatientId()); // 患者
|
||||
activityChildrenJsonParams.setEncounterId(serviceRequest.getEncounterId()); // 就诊id
|
||||
activityChildrenJsonParams.setAccountId(chargeItem.getAccountId()); // 账户id
|
||||
activityChildrenJsonParams.setChargeItemId(chargeItem.getId()); // 费用项id
|
||||
activityChildrenJsonParams.setParentId(serviceRequest.getId());// 子项诊疗的父id
|
||||
activityChildrenJsonParams.setEncounterDiagnosisId(serviceRequest.getEncounterDiagnosisId());
|
||||
adviceUtils.handleActivityChild(childrenJson, organizationId, activityChildrenJsonParams);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -326,6 +322,13 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
} else if (surgeryName != null && !surgeryName.isEmpty()) {
|
||||
contentMap.put("surgeryName", surgeryName);
|
||||
}
|
||||
// 🔧 手术申请单级联删除:contentJson 中记录 requestFormId 和 prescriptionNo,删除医嘱时可定位并作废申请单
|
||||
if (requestForm.getId() != null) {
|
||||
contentMap.put("requestFormId", String.valueOf(requestForm.getId()));
|
||||
}
|
||||
if (prescriptionNo != null && !prescriptionNo.isEmpty()) {
|
||||
contentMap.put("prescriptionNo", prescriptionNo);
|
||||
}
|
||||
if (surgeryCode != null && !surgeryCode.isEmpty()) {
|
||||
contentMap.put("surgeryCode", surgeryCode);
|
||||
}
|
||||
@@ -368,9 +371,10 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
surgeryChargeItem.setServiceTable(CommonConstants.TableName.WOR_SERVICE_REQUEST);
|
||||
surgeryChargeItem.setServiceId(surgeryServiceRequest.getId());
|
||||
surgeryChargeItem.setProductTable(CommonConstants.TableName.WOR_ACTIVITY_DEFINITION);
|
||||
// 优先从 activityList 获取 productId
|
||||
// 优先从 activityList 获取 productId 和 definitionId
|
||||
if (activityList != null && !activityList.isEmpty()) {
|
||||
surgeryChargeItem.setProductId(activityList.get(0).getAdviceDefinitionId());
|
||||
surgeryChargeItem.setDefinitionId(activityList.get(0).getDefinitionId());
|
||||
surgeryChargeItem.setAccountId(activityList.get(0).getAccountId());
|
||||
}
|
||||
surgeryChargeItem.setRequestingOrgId(orgId);
|
||||
@@ -409,6 +413,10 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
anesthesiaChargeItem.setServiceTable(CommonConstants.TableName.WOR_SERVICE_REQUEST);
|
||||
anesthesiaChargeItem.setServiceId(surgeryServiceRequest.getId());
|
||||
anesthesiaChargeItem.setProductTable(CommonConstants.TableName.WOR_ACTIVITY_DEFINITION);
|
||||
// 从 activityList 获取 definitionId
|
||||
if (activityList != null && !activityList.isEmpty()) {
|
||||
anesthesiaChargeItem.setDefinitionId(activityList.get(0).getDefinitionId());
|
||||
}
|
||||
anesthesiaChargeItem.setRequestingOrgId(orgId);
|
||||
anesthesiaChargeItem.setQuantityValue(BigDecimal.valueOf(1));
|
||||
anesthesiaChargeItem.setQuantityUnit("次");
|
||||
@@ -425,6 +433,18 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
||||
log.error("生成手术医嘱过程中发生异常", e);
|
||||
throw e;
|
||||
}
|
||||
// 将手术项目名称写入申请单name字段,确保医嘱删除后申请单仍保留正确名称
|
||||
if (activityList != null && !activityList.isEmpty()) {
|
||||
String surgeryDisplayName = activityList.stream()
|
||||
.map(ActivitySaveDto::getAdviceDefinitionName)
|
||||
.filter(name -> name != null && !name.isEmpty())
|
||||
.distinct()
|
||||
.collect(Collectors.joining("、"));
|
||||
if (!surgeryDisplayName.isEmpty()) {
|
||||
requestForm.setName(surgeryDisplayName);
|
||||
iRequestFormService.updateById(requestForm);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
log.info("不是手术申请单,跳过手术医嘱生成,typeCode={}", typeCode);
|
||||
}
|
||||
|
||||
@@ -13,6 +13,11 @@ import java.math.BigDecimal;
|
||||
@Accessors(chain = true)
|
||||
public class RequestFormDetailQueryDto {
|
||||
|
||||
/**
|
||||
* 诊疗活动定义ID(wor_service_request.activity_id,与开立检验时项目字典的 id / adviceDefinitionId 一致,用于编辑回显)
|
||||
*/
|
||||
private Long activityId;
|
||||
|
||||
/** 医嘱名称 */
|
||||
private String adviceName;
|
||||
|
||||
|
||||
@@ -117,7 +117,7 @@
|
||||
)
|
||||
</if>
|
||||
<if test="searchKey != null and searchKey != ''">
|
||||
AND (t1.name ILIKE '%' || #{searchKey} || '%' OR t1.py_str ILIKE '%' || #{searchKey} || '%')
|
||||
AND (t1.name ILIKE '%' || '${searchKey}' || '%' OR t1.py_str ILIKE '%' || '${searchKey}' || '%')
|
||||
</if>
|
||||
<if test="adviceDefinitionIdParamList != null and !adviceDefinitionIdParamList.isEmpty()">
|
||||
AND t1.id IN
|
||||
@@ -181,7 +181,7 @@
|
||||
WHERE t1.delete_flag = '0'
|
||||
AND t1.status_enum = #{statusEnum}
|
||||
<if test="searchKey != null and searchKey != ''">
|
||||
AND (t1.name ILIKE '%' || #{searchKey} || '%' OR t1.py_str ILIKE '%' || #{searchKey} || '%')
|
||||
AND (t1.name ILIKE '%' || '${searchKey}' || '%' OR t1.py_str ILIKE '%' || '${searchKey}' || '%')
|
||||
</if>
|
||||
<if test="categoryCode != null and categoryCode != ''">
|
||||
AND t1.category_code = #{categoryCode}
|
||||
@@ -278,7 +278,7 @@
|
||||
AND T1.category_code != '手术' AND T1.category_code != '24'
|
||||
</if>
|
||||
<if test="searchKey != null and searchKey != ''">
|
||||
AND (t1.name ILIKE '%' || #{searchKey} || '%' OR t1.py_str ILIKE '%' || #{searchKey} || '%')
|
||||
AND (t1.name ILIKE '%' || '${searchKey}' || '%' OR t1.py_str ILIKE '%' || '${searchKey}' || '%')
|
||||
</if>
|
||||
<if test="categoryCode != null and categoryCode != ''">
|
||||
AND t1.category_code = #{categoryCode}
|
||||
@@ -893,7 +893,6 @@
|
||||
AND (t1.name ILIKE '%' || #{searchKey} || '%' OR t1.py_str ILIKE '%' || #{searchKey} || '%')
|
||||
</if>
|
||||
ORDER BY t1.ID, t1.name ASC, t2.ID ASC
|
||||
LIMIT #{page.size} OFFSET ${(page.current - 1) * page.size}
|
||||
</select>
|
||||
|
||||
<!-- 检查项目专用分页查询:仅查检查(23) + 定价,无库存/草稿库存/取药科室等无关逻辑 -->
|
||||
|
||||
@@ -135,6 +135,7 @@
|
||||
T1.onset_date AS onsetDate,
|
||||
T1.diagnosis_time AS diagnosisTime,
|
||||
T1.doctor AS diagnosisDoctor,
|
||||
T1.long_term_flag AS longTermFlag,
|
||||
CASE WHEN EXISTS (
|
||||
SELECT 1 FROM infectious_card T4
|
||||
WHERE T4.diag_id = T2.id AND T4.delete_flag = '0' AND T4.status >= 1
|
||||
|
||||
@@ -36,6 +36,6 @@ public interface IOrganizationLocationService extends IService<OrganizationLocat
|
||||
* @param activityDefinitionId 诊疗定义id
|
||||
* @return 诊疗的执行科室列表
|
||||
*/
|
||||
List<OrganizationLocation> getOrgLocListByOrgIdAndActivityDefinitionId(Long activityDefinitionId);
|
||||
List<OrganizationLocation> getOrgLocListByOrgIdAndActivityDefinitionId(Long organizationId, Long activityDefinitionId);
|
||||
|
||||
}
|
||||
@@ -53,12 +53,14 @@ public class OrganizationLocationServiceImpl extends ServiceImpl<OrganizationLoc
|
||||
/**
|
||||
* 查询诊疗的执行科室列表
|
||||
*
|
||||
* @param organizationId 机构id
|
||||
* @param activityDefinitionId 诊疗定义id
|
||||
* @return 诊疗的执行科室列表
|
||||
*/
|
||||
@Override
|
||||
public List<OrganizationLocation> getOrgLocListByOrgIdAndActivityDefinitionId(Long activityDefinitionId) {
|
||||
public List<OrganizationLocation> getOrgLocListByOrgIdAndActivityDefinitionId(Long organizationId, Long activityDefinitionId) {
|
||||
return baseMapper.selectList(new LambdaQueryWrapper<OrganizationLocation>()
|
||||
.eq(OrganizationLocation::getOrganizationId, organizationId)
|
||||
.eq(OrganizationLocation::getActivityDefinitionId, activityDefinitionId));
|
||||
}
|
||||
|
||||
|
||||
@@ -461,6 +461,10 @@ watch(
|
||||
console.log(prescriptionList.value,"prescriptionList.value")
|
||||
if(newValue&&newValue.length>0){
|
||||
let saveList = prescriptionList.value.filter((item) => {
|
||||
// 手术计费场景(generateSourceEnum=6)不限制 bizRequestFlag
|
||||
if (isSurgeryChargeBillingContext()) {
|
||||
return item.check && item.statusEnum == 1
|
||||
}
|
||||
return item.check && item.statusEnum == 1&&(Number(item.bizRequestFlag)==1||!item.bizRequestFlag)
|
||||
})
|
||||
console.log(saveList,"prescriptionList.value")
|
||||
@@ -1025,7 +1029,9 @@ function changeCheck(value,index,row){
|
||||
groupList.value.map(k=>{
|
||||
if(k.check){
|
||||
if(k.statusEnum == 1){//待签发
|
||||
if(Number(k.bizRequestFlag)==1||!k.bizRequestFlag){
|
||||
// 手术计费场景(generateSourceEnum=6)不限制 bizRequestFlag
|
||||
const bizAllowed = isSurgeryChargeBillingContext() || Number(k.bizRequestFlag)==1||!k.bizRequestFlag
|
||||
if(bizAllowed){
|
||||
if(handleSaveDisabled.value&&!handleSingOutDisabled.value&&groupList.value.length>1){
|
||||
proxy.$modal.msgWarning('请选择相同的状态的项目进行操作')
|
||||
return
|
||||
@@ -1040,7 +1046,9 @@ function changeCheck(value,index,row){
|
||||
}
|
||||
}
|
||||
if(k.statusEnum == 2){ //已签发
|
||||
if(Number(k.bizRequestFlag)==1||!k.bizRequestFlag){
|
||||
// 手术计费场景(generateSourceEnum=6)不限制 bizRequestFlag
|
||||
const bizAllowed = isSurgeryChargeBillingContext() || Number(k.bizRequestFlag)==1||!k.bizRequestFlag
|
||||
if(bizAllowed){
|
||||
if(!handleSaveDisabled.value&&handleSingOutDisabled.value&&groupList.value.length>1){
|
||||
proxy.$modal.msgWarning('请选择相同的状态的项目进行操作')
|
||||
return
|
||||
@@ -1067,28 +1075,28 @@ function handleSave() {
|
||||
return;
|
||||
}
|
||||
let saveList = prescriptionList.value.filter((item) => {
|
||||
// 手术计费场景(generateSourceEnum=6)不限制 bizRequestFlag,允许任何授权用户签发
|
||||
// 门诊划价场景保留 bizRequestFlag 限制,只能操作本人开立的医嘱
|
||||
if (isSurgeryChargeBillingContext()) {
|
||||
return item.check && item.statusEnum == 1
|
||||
}
|
||||
return item.check && item.statusEnum == 1&&(Number(item.bizRequestFlag)==1||!item.bizRequestFlag)
|
||||
});
|
||||
// let saveList = prescriptionList.value
|
||||
// .filter((item) => {
|
||||
// return item.check;
|
||||
// }).filter((item) => {
|
||||
// return item.statusEnum == 1&&item.bizRequestFlag==1
|
||||
// })
|
||||
|
||||
// if (saveList.length == 0) {
|
||||
// proxy.$modal.msgWarning('当前无可签发处方');
|
||||
// return;
|
||||
// }
|
||||
// 无可签发项目时提前返回,避免后端报"医嘱列表为空"
|
||||
if (saveList.length == 0) {
|
||||
proxy.$modal.msgWarning('当前无可签发处方');
|
||||
return;
|
||||
}
|
||||
// 此处签发处方和单行保存处方传参相同,后台已经将传参存为JSON字符串,此处直接转换为JSON即可
|
||||
let list = saveList.map((item) => {
|
||||
const parsedContent = item.contentJson ? JSON.parse(item.contentJson) : {};
|
||||
return {
|
||||
...parsedContent,
|
||||
requestId: item.requestId,
|
||||
dbOpType: '1',
|
||||
// 已有 requestId 的记录走 UPDATE 路径,新记录走 INSERT 路径
|
||||
dbOpType: item.requestId ? '2' : '1',
|
||||
groupId: item.groupId,
|
||||
// 🔧 Bug #443: 补充顶层关键字段(这些不在 contentJson 中,需从 API 响应顶层提取)
|
||||
// 补充顶层关键字段(这些可能不在 contentJson 中,需从 API 响应顶层提取)
|
||||
encounterId: item.encounterId,
|
||||
patientId: item.patientId,
|
||||
locationId: item.positionId,
|
||||
@@ -1096,9 +1104,14 @@ function handleSave() {
|
||||
adviceTableName: item.adviceTableName,
|
||||
adviceDefinitionId: item.adviceDefinitionId,
|
||||
chargeItemId: item.chargeItemId,
|
||||
// 🔧 Bug Fix: 签发时显式设置手术计费关键字段,避免后端 prescription_no / generateSourceEnum 回退为默认值导致查询无法匹配
|
||||
generateSourceEnum: props.generateSourceEnum ?? parsedContent.generateSourceEnum,
|
||||
sourceBillNo: props.sourceBillNo ?? parsedContent.sourceBillNo,
|
||||
// 补充数量、单位、批号等字段(后端 handDevice 需要这些字段)
|
||||
quantity: item.quantity,
|
||||
unitCode: item.unitCode,
|
||||
lotNumber: item.lotNumber,
|
||||
categoryEnum: item.categoryEnum,
|
||||
// 签发时显式设置手术计费关键字段,后端 generateSourceEnum 回退为默认值导致查询无法匹配
|
||||
generateSourceEnum: props.generateSourceEnum ?? parsedContent.generateSourceEnum ?? item.generateSourceEnum,
|
||||
sourceBillNo: props.sourceBillNo ?? parsedContent.sourceBillNo ?? item.sourceBillNo,
|
||||
};
|
||||
});
|
||||
// 确保 organizationId 不为 undefined(手术计费场景下可能缺失 orgId)
|
||||
@@ -1185,6 +1198,10 @@ function handleSingOut() {
|
||||
return item.check;
|
||||
})
|
||||
.filter((item) => {
|
||||
// 手术计费场景(generateSourceEnum=6)不限制 bizRequestFlag
|
||||
if (isSurgeryChargeBillingContext()) {
|
||||
return item.statusEnum == 2 && item.chargeStatus != 5
|
||||
}
|
||||
return item.statusEnum == 2 && item.chargeStatus != 5 && (Number(item.bizRequestFlag)==1||!item.bizRequestFlag)
|
||||
})
|
||||
.map((item) => {
|
||||
|
||||
@@ -354,6 +354,11 @@ async function getList() {
|
||||
if (!item.classification) {
|
||||
item.classification = '西医';
|
||||
}
|
||||
// 转换 longTermFlag 为字符串,以匹配 useDict 返回的字典值类型(字符串)
|
||||
// 避免 el-select 因类型不匹配(整数 1 vs 字符串 "1")导致下拉框清空
|
||||
if (item.longTermFlag != null) {
|
||||
item.longTermFlag = String(item.longTermFlag);
|
||||
}
|
||||
// 如果ybNo(诊断编码)符合传染病编码格式,添加到selectedDiseases
|
||||
if (item.ybNo && /^(01|02|03)/.test(item.ybNo)) {
|
||||
item.selectedDiseases = [item.ybNo];
|
||||
|
||||
@@ -116,7 +116,7 @@ import {computed, getCurrentInstance, ref, watch} from 'vue';
|
||||
import {Refresh} from '@element-plus/icons-vue';
|
||||
import {patientInfo} from '../../store/patient.js';
|
||||
import {getSurgery} from './api';
|
||||
import {getOrgList} from '@/views/doctorstation/components/api.js';
|
||||
import {getDepartmentList} from '@/api/public.js';
|
||||
|
||||
const { proxy } = getCurrentInstance();
|
||||
|
||||
@@ -182,25 +182,32 @@ const hasMatchedFields = computed(() => {
|
||||
|
||||
/** 查询科室 */
|
||||
const getLocationInfo = async () => {
|
||||
const res = await getOrgList();
|
||||
orgOptions.value = res.data.records;
|
||||
const res = await getDepartmentList();
|
||||
orgOptions.value = res.data || [];
|
||||
};
|
||||
|
||||
const recursionFun = (targetDepartment) => {
|
||||
if (!targetDepartment || !orgOptions.value || orgOptions.value.length === 0) {
|
||||
return '';
|
||||
}
|
||||
let name = '';
|
||||
for (let index = 0; index < orgOptions.value.length; index++) {
|
||||
const obj = orgOptions.value[index];
|
||||
if (obj.id == targetDepartment) {
|
||||
name = obj.name;
|
||||
}
|
||||
const subObjArray = obj['children'];
|
||||
for (let index = 0; index < subObjArray.length; index++) {
|
||||
const item = subObjArray[index];
|
||||
if (item.id == targetDepartment) {
|
||||
name = item.name;
|
||||
// 统一处理:扁平列表和树形结构都适用
|
||||
const findInList = (list) => {
|
||||
for (const node of list) {
|
||||
if (String(node.id) === String(targetDepartment)) {
|
||||
name = node.name;
|
||||
return true;
|
||||
}
|
||||
// 树形结构:递归查找 children
|
||||
if (node.children && node.children.length > 0) {
|
||||
if (findInList(node.children)) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return false;
|
||||
};
|
||||
findInList(orgOptions.value);
|
||||
return name;
|
||||
};
|
||||
|
||||
|
||||
@@ -207,6 +207,8 @@ const loadAllData = async () => {
|
||||
}
|
||||
applicationListAll.value = res.data?.records || [];
|
||||
totalCount.value = res.data?.total || 0;
|
||||
// 检验项目列表为异步加载,编辑回显必须在数据就绪后执行,否则已选区一直为空
|
||||
applyEditTransferSelection()
|
||||
} catch (e) {
|
||||
proxy.$message.error('获取检验项目列表失败');
|
||||
applicationListAll.value = [];
|
||||
@@ -343,43 +345,70 @@ watch(
|
||||
}
|
||||
);
|
||||
|
||||
// 编辑模式下,回显已有数据
|
||||
/** 编辑弹窗:根据申请单明细把右侧「已选择」与 transferValue 对齐(依赖 applicationListAll 已加载) */
|
||||
const applyEditTransferSelection = () => {
|
||||
const newData = props.editData
|
||||
if (!newData?.requestFormId || !newData.requestFormDetailList?.length) {
|
||||
return
|
||||
}
|
||||
if (!applicationListAll.value.length) {
|
||||
return
|
||||
}
|
||||
const selectedIds = []
|
||||
for (const detail of newData.requestFormDetailList) {
|
||||
const idFromDetail = detail.activityId ?? detail.adviceDefinitionId
|
||||
let matched = null
|
||||
if (idFromDetail != null && idFromDetail !== '') {
|
||||
matched = applicationListAll.value.find(
|
||||
(item) => String(item.adviceDefinitionId) === String(idFromDetail)
|
||||
)
|
||||
}
|
||||
if (!matched && detail.adviceName) {
|
||||
matched = applicationListAll.value.find((item) => item.adviceName === detail.adviceName)
|
||||
}
|
||||
if (!matched && detail.adviceName) {
|
||||
const norm = (s) => String(s || '').trim()
|
||||
matched = applicationListAll.value.find(
|
||||
(item) => norm(item.adviceName) === norm(detail.adviceName)
|
||||
)
|
||||
}
|
||||
if (matched) {
|
||||
selectedIds.push(matched.adviceDefinitionId)
|
||||
}
|
||||
}
|
||||
const uniq = [...new Set(selectedIds)]
|
||||
transferValue.value = uniq
|
||||
if (newData.requestFormDetailList.length && uniq.length === 0) {
|
||||
console.warn(
|
||||
'[LaboratoryTests] 申请单明细未能在项目字典中匹配到项,请核对 activityId / 项目名称',
|
||||
newData.requestFormDetailList
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
// 编辑模式下,回显已有数据(表单来自 descJson;项目选择在字典加载后由 applyEditTransferSelection 完成)
|
||||
watch(
|
||||
() => props.editData,
|
||||
(newData) => {
|
||||
if (!newData || !newData.requestFormId) return;
|
||||
if (!newData || !newData.requestFormId) return
|
||||
|
||||
// 解析 descJson 回填表单
|
||||
if (newData.descJson) {
|
||||
try {
|
||||
const obj = JSON.parse(newData.descJson);
|
||||
const obj = JSON.parse(newData.descJson)
|
||||
Object.keys(form).forEach((key) => {
|
||||
if (obj[key] !== undefined) {
|
||||
form[key] = obj[key];
|
||||
form[key] = obj[key]
|
||||
}
|
||||
});
|
||||
})
|
||||
} catch (e) {
|
||||
console.error('解析 descJson 失败:', e);
|
||||
console.error('解析 descJson 失败:', e)
|
||||
}
|
||||
}
|
||||
|
||||
// 回填已选项目
|
||||
if (newData.requestFormDetailList && newData.requestFormDetailList.length > 0) {
|
||||
// 从全部数据中匹配已选项目
|
||||
const selectedIds = [];
|
||||
newData.requestFormDetailList.forEach((detail) => {
|
||||
const matched = applicationListAll.value.find(
|
||||
(item) => item.adviceName === detail.adviceName
|
||||
);
|
||||
if (matched) {
|
||||
selectedIds.push(matched.adviceDefinitionId);
|
||||
}
|
||||
});
|
||||
transferValue.value = selectedIds;
|
||||
}
|
||||
applyEditTransferSelection()
|
||||
},
|
||||
{ immediate: true }
|
||||
);
|
||||
{ immediate: true, deep: true }
|
||||
)
|
||||
|
||||
// 编辑模式下,applicationListAll 加载完成后重新回显已选项目
|
||||
watch(
|
||||
|
||||
@@ -232,64 +232,21 @@ onMounted(() => {
|
||||
* type(1:watch监听类型 2:点击保存类型)
|
||||
* selectProjectIds(选中项目的id数组)
|
||||
* */
|
||||
const projectWithDepartment = (selectProjectIds, type) => {
|
||||
//1.获取选中的项目 2.判断项目的执行科室是否相同 3.判断执行科室是否配置 4.将项目的执行科室复值到执行科室下拉选位置
|
||||
let isRelease = true;
|
||||
// 选中项目的数组
|
||||
const arr = [];
|
||||
// 根据选中的项目id查找对应的项目
|
||||
selectProjectIds.forEach((element) => {
|
||||
const searchData = applicationList.value.find((item) => {
|
||||
return element == item.adviceDefinitionId;
|
||||
});
|
||||
arr.push(searchData);
|
||||
});
|
||||
// 清空科室
|
||||
form.targetDepartment = '';
|
||||
if (arr.length > 0) {
|
||||
const obj = arr[0];
|
||||
// 判断科室是否相同
|
||||
const isCompare = arr.every((item) => {
|
||||
return item.orgId == obj.orgId;
|
||||
});
|
||||
if (!isCompare) {
|
||||
ElMessage({
|
||||
type: 'error',
|
||||
message: '执行科室不同',
|
||||
});
|
||||
isRelease = false;
|
||||
}
|
||||
// 选中项目中的执行科室id与全部科室数据做匹配
|
||||
const findItem = findTreeItem(orgOptions.value, obj.orgId);
|
||||
|
||||
if (!findItem) {
|
||||
isRelease = false;
|
||||
ElMessage({
|
||||
type: 'error',
|
||||
message: '未找到项目执行的科室',
|
||||
});
|
||||
}
|
||||
if (type == 1) {
|
||||
if (isRelease) {
|
||||
form.targetDepartment = findItem.id;
|
||||
}
|
||||
}
|
||||
const projectWithDepartment = (selectProjectIds) => {
|
||||
if (!selectProjectIds || selectProjectIds.length === 0) {
|
||||
form.targetDepartment = '';
|
||||
}
|
||||
return isRelease;
|
||||
};
|
||||
// 监听选择项目变化
|
||||
watch(
|
||||
() => transferValue.value,
|
||||
(newValue) => {
|
||||
projectWithDepartment(newValue, 1);
|
||||
}
|
||||
);
|
||||
watch(() => transferValue.value, (newValue) => {
|
||||
projectWithDepartment(newValue);
|
||||
});
|
||||
const submit = () => {
|
||||
if (transferValue.value.length == 0) {
|
||||
return proxy.$message.error('请选择申请单');
|
||||
return proxy.$message.error('请选择手术项目');
|
||||
}
|
||||
if (!projectWithDepartment(transferValue.value, 2)) {
|
||||
return;
|
||||
if (!form.targetDepartment) {
|
||||
return proxy.$message.error('请选择发往科室');
|
||||
}
|
||||
let applicationListAllFilter = applicationListAll.value.filter((item) => {
|
||||
return transferValue.value.includes(item.adviceDefinitionId);
|
||||
@@ -302,7 +259,7 @@ const submit = () => {
|
||||
unitCode: item.unitCode,
|
||||
unitPrice: item.price,
|
||||
totalPrice: item.price,
|
||||
positionId: item.positionId,
|
||||
positionId: form.targetDepartment || item.positionId, // 用户手动选择的发往科室优先于项目默认执行科室
|
||||
definitionId: item.chargeItemDefinitionId,
|
||||
accountId: patientInfo.value.accountId,
|
||||
};
|
||||
|
||||
@@ -1195,7 +1195,7 @@ function handleSave() {
|
||||
// 此处签发处方和单行保存处方传参相同,后台已经将传参存为JSON字符串,此处直接转换为JSON即可
|
||||
loading.value = true;
|
||||
let list = saveList.map((item) => {
|
||||
const parsedContent = JSON.parse(item.contentJson);
|
||||
const parsedContent = item.contentJson ? JSON.parse(item.contentJson) : {};
|
||||
return {
|
||||
...parsedContent,
|
||||
adviceType: item.adviceType,
|
||||
|
||||
@@ -373,7 +373,8 @@ const filterKeywords = ref({});
|
||||
const queryParams = ref({
|
||||
pageSize: 100,
|
||||
pageNum: 1,
|
||||
adviceTypes: '2,3',
|
||||
// 默认加载全部类型(药品1+耗材2+诊疗3)
|
||||
adviceTypes: [1, 2, 3],
|
||||
});
|
||||
/**
|
||||
* 医嘱提交数据模型
|
||||
@@ -555,12 +556,26 @@ function loadDepartmentOptions() {
|
||||
function getAdviceBaseInfos() {
|
||||
adviceLoading.value = true;
|
||||
queryParams.value.searchKey = searchText.value;
|
||||
queryParams.value.adviceTypes = adviceType.value;
|
||||
// 字典值(3=诊疗,4=耗材)映射为后端adviceType(2=耗材,3=诊疗)
|
||||
if (adviceType.value === 4) {
|
||||
queryParams.value.adviceTypes = [2];
|
||||
} else if (adviceType.value === 3) {
|
||||
queryParams.value.adviceTypes = [3];
|
||||
} else {
|
||||
queryParams.value.adviceTypes = [1, 2, 3];
|
||||
}
|
||||
queryParams.value.organizationId = orgId.value;
|
||||
queryParams.value.pricingFlag = 1; // 划价标记
|
||||
getAdviceBaseInfo(queryParams.value)
|
||||
.then((res) => {
|
||||
AdviceBaseInfoList.value = res.data?.records || [];
|
||||
const list = res.data?.records || [];
|
||||
// 药品(1)和耗材(2)必须有库存才能展示,诊疗(3)无库存概念不过滤
|
||||
AdviceBaseInfoList.value = list.filter(item => {
|
||||
if (item.adviceType === 1 || item.adviceType === 2) {
|
||||
return item.inventoryList && item.inventoryList.length > 0;
|
||||
}
|
||||
return true;
|
||||
});
|
||||
})
|
||||
.finally(() => {
|
||||
adviceLoading.value = false;
|
||||
|
||||
@@ -386,7 +386,7 @@
|
||||
:disabled="viewStatus == 'view'"
|
||||
v-model="scope.row.itemQuantityDisplay"
|
||||
placeholder=""
|
||||
@change="(value) => handleItemQuantityChange(scope.row, value)"
|
||||
@input="(value) => handleItemQuantityChange(scope.row, value)"
|
||||
:class="{ 'error-border': scope.row.error }"
|
||||
/>
|
||||
</div>
|
||||
@@ -971,6 +971,10 @@ function handleItemQuantityChange(row, value) {
|
||||
quantityTemp = value;
|
||||
}
|
||||
row.totalPrice = ((row.price * quantityTemp) / row.partPercent).toFixed(2);
|
||||
// 数量变更后重置保存标记,允许重新提交
|
||||
row.isSave = false;
|
||||
// 同步更新底部合计金额
|
||||
handleTotalAmount();
|
||||
}
|
||||
|
||||
function handelApply() {
|
||||
@@ -1262,128 +1266,108 @@ function editBatchTransfer(index) {
|
||||
}
|
||||
|
||||
function handleSave(row, index) {
|
||||
rowList.value = [];
|
||||
if (route.query.supplyBusNo) {
|
||||
// 编辑
|
||||
forms.purchaseinventoryList.map((row, index) => {
|
||||
if (row) {
|
||||
proxy.$refs['receiptHeaderRef'].validate((valid) => {
|
||||
if (valid) {
|
||||
proxy.$refs['formRef'].validate((valid) => {
|
||||
if (valid) {
|
||||
if (row.unitCode == row.unitList.minUnitCode) {
|
||||
row.itemQuantity = forms.purchaseinventoryList[index].olditemQuantity
|
||||
? forms.purchaseinventoryList[index].olditemQuantity
|
||||
: forms.purchaseinventoryList[index].itemQuantity;
|
||||
} else {
|
||||
row.itemQuantity = forms.purchaseinventoryList[index].itemMaxQuantity
|
||||
? forms.purchaseinventoryList[index].itemMaxQuantity
|
||||
: forms.purchaseinventoryList[index].itemQuantity;
|
||||
}
|
||||
// let rows = JSON.parse(JSON.stringify(row))
|
||||
// delete rows.itemMaxQuantity
|
||||
|
||||
if (row.unitCode == row.unitCode_dictText) {
|
||||
if (row.unitCode_dictText == row.unitList.minUnitCode_dictText) {
|
||||
row.unitCode = row.unitList.minUnitCode;
|
||||
} else {
|
||||
row.unitCode = row.unitList.unitCode;
|
||||
row.unitCode_dictText = row.unitList.unitCode_dictText;
|
||||
}
|
||||
}
|
||||
if (row.unitCode == row.unitList.unitCode) {
|
||||
row.unitCode_dictText = row.unitList.unitCode_dictText;
|
||||
} else if (row.unitCode == row.unitList.minUnitCode) {
|
||||
row.unitCode_dictText = row.unitList.minUnitCode_dictText;
|
||||
}
|
||||
if (!forms.purchaseinventoryList[index].price || forms.purchaseinventoryList[index].price <= 0) {
|
||||
proxy.$message.warning('调拨单价不能为空或为0,请检查!');
|
||||
return;
|
||||
}
|
||||
forms.purchaseinventoryList[index].totalPrice =
|
||||
forms.purchaseinventoryList[index].price * forms.purchaseinventoryList[index].itemQuantity;
|
||||
rowList.value.push(JSON.parse(JSON.stringify(row)));
|
||||
if (
|
||||
rowList._rawValue &&
|
||||
rowList._rawValue.length == forms.purchaseinventoryList.length
|
||||
) {
|
||||
addTransferProducts(rowList._rawValue);
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
} else {
|
||||
//新增
|
||||
form.purchaseinventoryList.map((row, index) => {
|
||||
if (row) {
|
||||
proxy.$refs['receiptHeaderRef'].validate((valid) => {
|
||||
if (valid) {
|
||||
proxy.$refs['formRef'].validate((valid) => {
|
||||
if (valid) {
|
||||
let rows = JSON.parse(JSON.stringify(row));
|
||||
delete rows.itemMaxQuantity;
|
||||
if (rows.unitCode == rows.unitList.minUnitCode) {
|
||||
rows.itemQuantity = form.purchaseinventoryList[index].olditemQuantity
|
||||
? form.purchaseinventoryList[index].olditemQuantity
|
||||
: form.purchaseinventoryList[index].itemQuantity;
|
||||
} else {
|
||||
rows.itemQuantity = form.purchaseinventoryList[index].itemMaxQuantity
|
||||
? form.purchaseinventoryList[index].itemMaxQuantity
|
||||
: form.purchaseinventoryList[index].itemQuantity;
|
||||
}
|
||||
if (rows.unitCode == rows.unitCode_dictText) {
|
||||
if (rows.unitCode_dictText == rows.unitList.minUnitCode_dictText) {
|
||||
rows.unitCode = rows.unitList.minUnitCode;
|
||||
} else {
|
||||
rows.unitCode = rows.unitList.unitCode;
|
||||
rows.unitCode_dictText = rows.unitList.unitCode_dictText;
|
||||
}
|
||||
}
|
||||
if (rows.unitCode == rows.unitList.unitCode) {
|
||||
rows.unitCode_dictText = rows.unitList.unitCode_dictText;
|
||||
} else if (rows.unitCode == rows.unitList.minUnitCode) {
|
||||
rows.unitCode_dictText = rows.unitList.minUnitCode_dictText;
|
||||
}
|
||||
if (!form.purchaseinventoryList[index].price || form.purchaseinventoryList[index].price <= 0) {
|
||||
proxy.$message.warning('调拨单价不能为空或为0,请检查!');
|
||||
return;
|
||||
}
|
||||
form.purchaseinventoryList[index].totalPrice =
|
||||
form.purchaseinventoryList[index].price * form.purchaseinventoryList[index].itemQuantity;
|
||||
rowList.value.push(JSON.parse(JSON.stringify(rows)));
|
||||
if (
|
||||
rowList._rawValue &&
|
||||
rowList._rawValue.length == form.purchaseinventoryList.length
|
||||
) {
|
||||
addTransferProducts(rowList._rawValue);
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
});
|
||||
// 过滤出未保存的行,已保存的行不重复提交
|
||||
const listToCheck = route.query.supplyBusNo
|
||||
? forms.purchaseinventoryList
|
||||
: form.purchaseinventoryList;
|
||||
const unsavedList = listToCheck.filter(item => !item.isSave);
|
||||
if (unsavedList.length === 0) {
|
||||
proxy.$modal.msgWarning('所有行均已保存,无需重复提交');
|
||||
return;
|
||||
}
|
||||
|
||||
// 先校验表头
|
||||
proxy.$refs['receiptHeaderRef'].validate((headerValid) => {
|
||||
if (!headerValid) return;
|
||||
|
||||
// 逐行校验(避免异步回调导致重复提交)
|
||||
const rowsToSave = [];
|
||||
for (let i = 0; i < form.purchaseinventoryList.length; i++) {
|
||||
const r = form.purchaseinventoryList[i];
|
||||
if (!r) continue;
|
||||
|
||||
// 跳过已保存的行,避免重复提交导致预扣减库存叠加
|
||||
if (r.isSave) continue;
|
||||
|
||||
// 校验当前行的必填字段
|
||||
let rowValid = true;
|
||||
for (const prop of ['name', 'unitCode']) {
|
||||
const formRef = proxy.$refs['formRef'];
|
||||
if (formRef && formRef.validateField) {
|
||||
formRef.validateField(`purchaseinventoryList.${i}.${prop}`, (valid) => {
|
||||
if (valid) rowValid = false;
|
||||
});
|
||||
}
|
||||
}
|
||||
if (!rowValid) {
|
||||
proxy.$modal.msgWarning('第' + (i + 1) + '行数据不完整,请检查');
|
||||
return;
|
||||
}
|
||||
|
||||
// 单价校验
|
||||
if (!r.price || r.price <= 0) {
|
||||
proxy.$modal.msgWarning('第' + (i + 1) + '行调拨单价不能为空或为0');
|
||||
return;
|
||||
}
|
||||
|
||||
// 单位处理
|
||||
const rowData = route.query.supplyBusNo
|
||||
? JSON.parse(JSON.stringify(forms.purchaseinventoryList[i]))
|
||||
: JSON.parse(JSON.stringify(r));
|
||||
delete rowData.itemMaxQuantity;
|
||||
|
||||
if (rowData.unitCode == rowData.unitList?.minUnitCode) {
|
||||
rowData.itemQuantity = r.olditemQuantity || r.itemQuantity;
|
||||
} else {
|
||||
rowData.itemQuantity = r.itemMaxQuantity || r.itemQuantity;
|
||||
}
|
||||
|
||||
if (rowData.unitCode == rowData.unitCode_dictText) {
|
||||
if (rowData.unitCode_dictText == rowData.unitList?.minUnitCode_dictText) {
|
||||
rowData.unitCode = rowData.unitList.minUnitCode;
|
||||
} else {
|
||||
rowData.unitCode = rowData.unitList.unitCode;
|
||||
rowData.unitCode_dictText = rowData.unitList.unitCode_dictText;
|
||||
}
|
||||
}
|
||||
if (rowData.unitCode == rowData.unitList?.unitCode) {
|
||||
rowData.unitCode_dictText = rowData.unitList.unitCode_dictText;
|
||||
} else if (rowData.unitCode == rowData.unitList?.minUnitCode) {
|
||||
rowData.unitCode_dictText = rowData.unitList.minUnitCode_dictText;
|
||||
}
|
||||
|
||||
// 计算总价
|
||||
r.totalPrice = r.price * rowData.itemQuantity;
|
||||
rowsToSave.push(rowData);
|
||||
}
|
||||
|
||||
// 所有行校验通过,一次性提交
|
||||
if (rowsToSave.length > 0) {
|
||||
addTransferProducts(rowsToSave);
|
||||
}
|
||||
});
|
||||
}
|
||||
function addTransferProducts(rowList) {
|
||||
addTransferProduct(JSON.parse(JSON.stringify(rowList))).then((res) => {
|
||||
// 当前行没有id视为首次新增
|
||||
// if (!row.id) {
|
||||
// data.isAdding = false; // 允许新增下一行
|
||||
// }
|
||||
if (res.data) {
|
||||
proxy.$message.success('保存成功!');
|
||||
let newIdIndex = 0;
|
||||
form.purchaseinventoryList.map((row, index) => {
|
||||
form.purchaseinventoryList[index].id = res.data[index];
|
||||
// 只有未保存的行才会拿到新 id(和提交顺序一致)
|
||||
if (!row.isSave && res.data[newIdIndex]) {
|
||||
form.purchaseinventoryList[index].id = res.data[newIdIndex];
|
||||
newIdIndex++;
|
||||
}
|
||||
form.purchaseinventoryList[index].isSave = true;
|
||||
});
|
||||
if (route.query.supplyBusNo) {
|
||||
// 编辑
|
||||
let newIdIdx = 0;
|
||||
forms.purchaseinventoryList.map((row, index) => {
|
||||
forms.purchaseinventoryList[index].id = res.data[index];
|
||||
if (!row.isSave && res.data[newIdIdx]) {
|
||||
forms.purchaseinventoryList[index].id = res.data[newIdIdx];
|
||||
newIdIdx++;
|
||||
}
|
||||
forms.purchaseinventoryList[index].isSave = true;
|
||||
});
|
||||
}
|
||||
|
||||
@@ -1565,7 +1565,7 @@ function handleMedicalAdvice(row) {
|
||||
temporaryMedicalLoading.value = true // 🔧 新增:开始加载
|
||||
|
||||
// 调用计费接口获取数据
|
||||
getPrescriptionList(row.visitId).then((res) => {
|
||||
getPrescriptionList(row.visitId, 6, row.operCode).then((res) => {
|
||||
console.log('=== 拉取计费数据返回结果 ===', res)
|
||||
if (res.code === 200 && res.data) {
|
||||
// 🔧 修复:显示所有药品请求数据,不管有没有计费项目
|
||||
@@ -1702,9 +1702,14 @@ function handleMedicalAdvice(row) {
|
||||
usageLabel: usageLabel, // 🔧 新增:保存显示名称
|
||||
frequency: '临时',
|
||||
executeTime: new Date().toLocaleString('zh-CN'),
|
||||
// 🔧 关键修复:确保 originalMedicine 中包含 encounterId,以便后续判断是否为同一患者
|
||||
// 🔧 关键修复:确保 originalMedicine 中包含 encounterId 和匹配字段
|
||||
// medicineName/specification/quantity 用于 handleTemporaryMedicalSubmit 中的
|
||||
// 已提交项目匹配过滤(Bug #445),缺少这些字段会导致过滤失效
|
||||
originalMedicine: {
|
||||
...medicine,
|
||||
medicineName: medicine.medicineName,
|
||||
specification: medicine.specification,
|
||||
quantity: medicine.quantity,
|
||||
encounterId: row.visitId // 添加 encounterId 字段
|
||||
}
|
||||
}
|
||||
@@ -1963,9 +1968,13 @@ function handleQuoteBilling() {
|
||||
usageLabel: usageLabel, // 🔧 新增:保存显示名称
|
||||
frequency: '临时',
|
||||
executeTime: new Date().toLocaleString('zh-CN'),
|
||||
// 🔧 关键修复:确保 originalMedicine 中包含 encounterId,以便后续判断是否为同一患者
|
||||
// 🔧 关键修复:确保 originalMedicine 中包含 encounterId 和匹配字段
|
||||
// medicineName/specification/quantity 用于已提交项目匹配过滤(Bug #445)
|
||||
originalMedicine: {
|
||||
...medicine,
|
||||
medicineName: medicine.medicineName,
|
||||
specification: medicine.specification,
|
||||
quantity: medicine.quantity,
|
||||
encounterId: temporaryPatientInfo.value.visitId // 添加 encounterId 字段
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user