Compare commits
14 Commits
9a665b7caf
...
bugfix/518
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ae8f0bc06b | ||
|
|
bb3e1e300d | ||
|
|
46358ea03d | ||
| b5c308d9cb | |||
|
|
adfeb8f5e5 | ||
|
|
fd9309f125 | ||
|
|
46affb424e | ||
|
|
6dcee26b54 | ||
|
|
a282234bb0 | ||
|
|
52fc64c71d | ||
|
|
0bd1277307 | ||
|
|
e0e4c2bcc6 | ||
|
|
41bea23116 | ||
|
|
12382503f4 |
@@ -96,9 +96,4 @@ public class DiagnosisQueryDto {
|
|||||||
*/
|
*/
|
||||||
private String diagnosisDoctor;
|
private String diagnosisDoctor;
|
||||||
|
|
||||||
/**
|
|
||||||
* 是否已有传染病报卡(0-无,1-有)
|
|
||||||
*/
|
|
||||||
private Integer hasInfectiousReport;
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,38 +3,29 @@
|
|||||||
*/
|
*/
|
||||||
package com.openhis.web.inventorymanage.appservice.impl;
|
package com.openhis.web.inventorymanage.appservice.impl;
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
import com.core.common.core.domain.R;
|
import com.core.common.core.domain.R;
|
||||||
import com.core.common.exception.ServiceException;
|
|
||||||
import com.core.common.utils.*;
|
import com.core.common.utils.*;
|
||||||
import com.core.common.utils.bean.BeanUtils;
|
import com.core.common.utils.bean.BeanUtils;
|
||||||
import com.openhis.administration.domain.DeviceDefinition;
|
|
||||||
import com.openhis.administration.domain.Practitioner;
|
import com.openhis.administration.domain.Practitioner;
|
||||||
import com.openhis.administration.service.IDeviceDefinitionService;
|
|
||||||
import com.openhis.administration.service.IPractitionerService;
|
import com.openhis.administration.service.IPractitionerService;
|
||||||
import com.openhis.common.constant.CommonConstants;
|
import com.openhis.common.constant.CommonConstants;
|
||||||
import com.openhis.common.constant.PromptMsgConstant;
|
import com.openhis.common.constant.PromptMsgConstant;
|
||||||
import com.openhis.common.enums.*;
|
import com.openhis.common.enums.*;
|
||||||
import com.openhis.common.utils.EnumUtils;
|
import com.openhis.common.utils.EnumUtils;
|
||||||
import com.openhis.common.utils.HisQueryUtils;
|
import com.openhis.common.utils.HisQueryUtils;
|
||||||
import com.openhis.medication.domain.MedicationDefinition;
|
|
||||||
import com.openhis.medication.service.IMedicationDefinitionService;
|
|
||||||
import com.openhis.web.common.dto.UnitDto;
|
import com.openhis.web.common.dto.UnitDto;
|
||||||
import com.openhis.web.inventorymanage.appservice.IRequisitionIssueAppService;
|
import com.openhis.web.inventorymanage.appservice.IRequisitionIssueAppService;
|
||||||
import com.openhis.web.inventorymanage.dto.*;
|
import com.openhis.web.inventorymanage.dto.*;
|
||||||
import com.openhis.web.inventorymanage.mapper.RequisitionIssueMapper;
|
import com.openhis.web.inventorymanage.mapper.RequisitionIssueMapper;
|
||||||
import com.openhis.workflow.domain.InventoryItem;
|
|
||||||
import com.openhis.workflow.domain.SupplyRequest;
|
import com.openhis.workflow.domain.SupplyRequest;
|
||||||
import com.openhis.workflow.service.IInventoryItemService;
|
|
||||||
import com.openhis.workflow.service.ISupplyRequestService;
|
import com.openhis.workflow.service.ISupplyRequestService;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletRequest;
|
||||||
import javax.servlet.http.HttpServletResponse;
|
import javax.servlet.http.HttpServletResponse;
|
||||||
import java.math.BigDecimal;
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
import java.util.stream.Stream;
|
import java.util.stream.Stream;
|
||||||
@@ -57,15 +48,6 @@ public class RequisitionIssueAppServiceImpl implements IRequisitionIssueAppServi
|
|||||||
@Autowired
|
@Autowired
|
||||||
private IPractitionerService practitionerService;
|
private IPractitionerService practitionerService;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private IInventoryItemService inventoryItemService;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private IMedicationDefinitionService medicationDefinitionService;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private IDeviceDefinitionService deviceDefinitionService;
|
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private AssignSeqUtil assignSeqUtil;
|
private AssignSeqUtil assignSeqUtil;
|
||||||
|
|
||||||
@@ -185,10 +167,6 @@ public class RequisitionIssueAppServiceImpl implements IRequisitionIssueAppServi
|
|||||||
|
|
||||||
// 单据号取得
|
// 单据号取得
|
||||||
List<String> busNoList = requisitionIssueDtoList.stream().map(IssueDto::getBusNo).collect(Collectors.toList());
|
List<String> busNoList = requisitionIssueDtoList.stream().map(IssueDto::getBusNo).collect(Collectors.toList());
|
||||||
|
|
||||||
// 库存校验:领用数量不能超过源仓库实际库存
|
|
||||||
this.validateRequisitionStock(requisitionIssueDtoList);
|
|
||||||
|
|
||||||
// 请求数据取得
|
// 请求数据取得
|
||||||
List<SupplyRequest> requestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
List<SupplyRequest> requestList = supplyRequestService.getSupplyByBusNo(busNoList.get(0));
|
||||||
if (!requestList.isEmpty()) {
|
if (!requestList.isEmpty()) {
|
||||||
@@ -350,73 +328,4 @@ public class RequisitionIssueAppServiceImpl implements IRequisitionIssueAppServi
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 校验领用数量是否超过源仓库实际库存
|
|
||||||
*
|
|
||||||
* @param requisitionIssueDtoList 领用出库单据列表
|
|
||||||
*/
|
|
||||||
private void validateRequisitionStock(List<IssueDto> requisitionIssueDtoList) {
|
|
||||||
Integer tenantId = SecurityUtils.getLoginUser().getTenantId();
|
|
||||||
for (IssueDto issueDto : requisitionIssueDtoList) {
|
|
||||||
Long itemId = issueDto.getItemId();
|
|
||||||
String lotNumber = issueDto.getLotNumber();
|
|
||||||
Long sourceLocationId = issueDto.getSourceLocationId();
|
|
||||||
BigDecimal reqQuantity = issueDto.getItemQuantity();
|
|
||||||
String itemUnit = issueDto.getUnitCode();
|
|
||||||
String itemTable = issueDto.getItemTable();
|
|
||||||
|
|
||||||
// 根据物品类型查询定义信息(拆零比、常规单位、最小单位)
|
|
||||||
BigDecimal partPercent = BigDecimal.ONE;
|
|
||||||
String unitCode = itemUnit;
|
|
||||||
String minUnitCode = itemUnit;
|
|
||||||
|
|
||||||
if (CommonConstants.TableName.MED_MEDICATION_DEFINITION.equals(itemTable)) {
|
|
||||||
MedicationDefinition medDef = medicationDefinitionService.getById(itemId);
|
|
||||||
if (medDef != null) {
|
|
||||||
unitCode = medDef.getUnitCode();
|
|
||||||
minUnitCode = medDef.getMinUnitCode();
|
|
||||||
if (medDef.getPartPercent() != null) {
|
|
||||||
partPercent = medDef.getPartPercent();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else if (CommonConstants.TableName.ADM_DEVICE_DEFINITION.equals(itemTable)) {
|
|
||||||
DeviceDefinition devDef = deviceDefinitionService.getById(itemId);
|
|
||||||
if (devDef != null) {
|
|
||||||
unitCode = devDef.getUnitCode();
|
|
||||||
minUnitCode = devDef.getMinUnitCode();
|
|
||||||
if (devDef.getPartPercent() != null) {
|
|
||||||
partPercent = devDef.getPartPercent();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 计算领用数量折合最小单位的值
|
|
||||||
BigDecimal reqQuantityInMinUnit;
|
|
||||||
if (itemUnit.equals(unitCode)) {
|
|
||||||
// 领用单位 = 包装单位,需乘以拆零比
|
|
||||||
reqQuantityInMinUnit = reqQuantity.multiply(partPercent);
|
|
||||||
} else {
|
|
||||||
// 领用单位 = 最小单位,无需换算
|
|
||||||
reqQuantityInMinUnit = reqQuantity;
|
|
||||||
}
|
|
||||||
|
|
||||||
// 查询源仓库实际库存(按物品编号、批号、仓库匹配)
|
|
||||||
List<InventoryItem> inventoryItemList = inventoryItemService.selectInventoryByItemId(
|
|
||||||
itemId, lotNumber, sourceLocationId, tenantId);
|
|
||||||
|
|
||||||
// 累加匹配批号的总库存(库存表quantity字段为最小单位)
|
|
||||||
BigDecimal totalStock = BigDecimal.ZERO;
|
|
||||||
for (InventoryItem inventoryItem : inventoryItemList) {
|
|
||||||
if (inventoryItem.getLocationId().equals(sourceLocationId)) {
|
|
||||||
totalStock = totalStock.add(inventoryItem.getQuantity());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 比较领用数量与库存
|
|
||||||
if (reqQuantityInMinUnit.compareTo(totalStock) > 0) {
|
|
||||||
throw new ServiceException("操作失败,库存数量不足");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -90,26 +90,18 @@ public class RequestFormManageAppServiceImpl implements IRequestFormManageAppSer
|
|||||||
|
|
||||||
// 逐个校验activityList中的项目是否都配置了执行科室,并收集positionId供后续使用
|
// 逐个校验activityList中的项目是否都配置了执行科室,并收集positionId供后续使用
|
||||||
// 必须在任何数据库操作之前完成全部校验,避免部分保存后异常导致脏数据
|
// 必须在任何数据库操作之前完成全部校验,避免部分保存后异常导致脏数据
|
||||||
// 🔧 Bug #516: 优先使用前端传入的positionId(用户手动选择的发往科室),仅在未选择时使用配置的执行科室
|
|
||||||
List<ActivitySaveDto> activityList = requestFormSaveDto.getActivityList();
|
List<ActivitySaveDto> activityList = requestFormSaveDto.getActivityList();
|
||||||
// 缓存校验结果,避免主循环中重复查询和可能出现的数据不一致
|
// 缓存校验结果,避免主循环中重复查询和可能出现的数据不一致
|
||||||
java.util.Map<Long, Long> activityIdToPositionIdMap = new java.util.HashMap<>();
|
java.util.Map<Long, Long> activityIdToPositionIdMap = new java.util.HashMap<>();
|
||||||
if (activityList != null && !activityList.isEmpty()) {
|
if (activityList != null && !activityList.isEmpty()) {
|
||||||
for (ActivitySaveDto activitySaveDto : activityList) {
|
for (ActivitySaveDto activitySaveDto : activityList) {
|
||||||
// 优先使用前端传入的positionId(用户手动选择的科室)
|
Long positionId = activityOrganizationConfig.stream()
|
||||||
Long frontendPositionId = activitySaveDto.getPositionId();
|
|
||||||
if (frontendPositionId != null) {
|
|
||||||
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), frontendPositionId);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
// 前端未传入时,使用配置的执行科室
|
|
||||||
Long configPositionId = activityOrganizationConfig.stream()
|
|
||||||
.filter(dto -> activitySaveDto.getAdviceDefinitionId().equals(dto.getActivityDefinitionId()))
|
.filter(dto -> activitySaveDto.getAdviceDefinitionId().equals(dto.getActivityDefinitionId()))
|
||||||
.map(ActivityOrganizationConfigDto::getOrganizationId).findFirst().orElse(null);
|
.map(ActivityOrganizationConfigDto::getOrganizationId).findFirst().orElse(null);
|
||||||
if (configPositionId == null) {
|
if (positionId == null) {
|
||||||
throw new ServiceException(activitySaveDto.getAdviceDefinitionName() + "未配置当前时间段的执行科室");
|
throw new ServiceException(activitySaveDto.getAdviceDefinitionName() + "未配置当前时间段的执行科室");
|
||||||
}
|
}
|
||||||
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), configPositionId);
|
activityIdToPositionIdMap.put(activitySaveDto.getAdviceDefinitionId(), positionId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -134,11 +134,7 @@
|
|||||||
T2.yb_no,
|
T2.yb_no,
|
||||||
T1.onset_date AS onsetDate,
|
T1.onset_date AS onsetDate,
|
||||||
T1.diagnosis_time AS diagnosisTime,
|
T1.diagnosis_time AS diagnosisTime,
|
||||||
T1.doctor AS diagnosisDoctor,
|
T1.doctor AS diagnosisDoctor
|
||||||
CASE WHEN EXISTS (
|
|
||||||
SELECT 1 FROM infectious_card T4
|
|
||||||
WHERE T4.diag_id = T2.id AND T4.delete_flag = '0' AND T4.status >= 1
|
|
||||||
) THEN 1 ELSE 0 END AS hasInfectiousReport
|
|
||||||
FROM adm_encounter_diagnosis AS T1
|
FROM adm_encounter_diagnosis AS T1
|
||||||
LEFT JOIN cli_condition AS T2 ON T2.ID = T1.condition_id
|
LEFT JOIN cli_condition AS T2 ON T2.ID = T1.condition_id
|
||||||
AND T2.delete_flag = '0' AND T2.tcm_flag = 0
|
AND T2.delete_flag = '0' AND T2.tcm_flag = 0
|
||||||
|
|||||||
@@ -692,7 +692,6 @@ async function handleFoodDiseasesCheck() {
|
|||||||
/**
|
/**
|
||||||
* 传染病报告卡处理
|
* 传染病报告卡处理
|
||||||
* 通过诊断名称自动识别并勾选传染病报告卡中的疾病
|
* 通过诊断名称自动识别并勾选传染病报告卡中的疾病
|
||||||
* 修复 Bug #519:跳过已有已提交报卡的诊断
|
|
||||||
*/
|
*/
|
||||||
function handleInfectiousDiseaseReport() {
|
function handleInfectiousDiseaseReport() {
|
||||||
// 疾病名称到报卡编码的映射(根据传染病报告卡弹窗中的疾病列表)
|
// 疾病名称到报卡编码的映射(根据传染病报告卡弹窗中的疾病列表)
|
||||||
@@ -744,9 +743,8 @@ function handleInfectiousDiseaseReport() {
|
|||||||
'手足口病': '0311',
|
'手足口病': '0311',
|
||||||
};
|
};
|
||||||
|
|
||||||
// 获取所有诊断名称对应的报卡编码,但跳过已有已提交报卡的诊断
|
// 获取所有诊断名称对应的报卡编码
|
||||||
const allSelectedDiseases = form.value.diagnosisList
|
const allSelectedDiseases = form.value.diagnosisList
|
||||||
.filter(d => d.name && d.hasInfectiousReport !== 1)
|
|
||||||
.map(d => diseaseNameToCode[d.name] || null)
|
.map(d => diseaseNameToCode[d.name] || null)
|
||||||
.filter(code => code);
|
.filter(code => code);
|
||||||
|
|
||||||
@@ -754,9 +752,9 @@ function handleInfectiousDiseaseReport() {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 优先使用主诊断(同样跳过已有报卡的)
|
// 优先使用主诊断
|
||||||
const mainDiagnosis = form.value.diagnosisList.find(d => d.maindiseFlag === 1 && d.hasInfectiousReport !== 1);
|
const mainDiagnosis = form.value.diagnosisList.find(d => d.maindiseFlag === 1);
|
||||||
const firstDiagnosis = form.value.diagnosisList.find(d => d.hasInfectiousReport !== 1) || form.value.diagnosisList[0];
|
const firstDiagnosis = form.value.diagnosisList[0];
|
||||||
|
|
||||||
const diagnosisToShow = {
|
const diagnosisToShow = {
|
||||||
...(mainDiagnosis || firstDiagnosis),
|
...(mainDiagnosis || firstDiagnosis),
|
||||||
|
|||||||
@@ -1057,8 +1057,8 @@ function confirmCharge() {
|
|||||||
params.recordingDate = formData.value.recordingDate || moment(new Date()).format('YYYY-MM-DD');
|
params.recordingDate = formData.value.recordingDate || moment(new Date()).format('YYYY-MM-DD');
|
||||||
|
|
||||||
addVitalSigns(params).then(res => {
|
addVitalSigns(params).then(res => {
|
||||||
|
console.log('保存成功:', res);
|
||||||
if (res.code === 200) {
|
if (res.code === 200) {
|
||||||
proxy.msgSuccess('保存成功');
|
|
||||||
// 保存成功后刷新列表
|
// 保存成功后刷新列表
|
||||||
getPatientList();
|
getPatientList();
|
||||||
// 清空表单
|
// 清空表单
|
||||||
@@ -1087,6 +1087,8 @@ function confirmCharge() {
|
|||||||
urineVolume: '',
|
urineVolume: '',
|
||||||
stoolVolume: '',
|
stoolVolume: '',
|
||||||
};
|
};
|
||||||
|
// 保存成功后关闭弹窗
|
||||||
|
closeDialog();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user