|
|
@ -3,6 +3,7 @@ package com.supervision.service.impl;
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
import com.supervision.dto.DiseaseAncillaryDto;
|
|
|
|
import com.supervision.dto.DiseaseAncillaryDto;
|
|
|
|
import com.supervision.exception.BusinessException;
|
|
|
|
import com.supervision.exception.BusinessException;
|
|
|
|
import com.supervision.model.*;
|
|
|
|
import com.supervision.model.*;
|
|
|
@ -58,8 +59,8 @@ public class AskAncillaryServiceImpl implements AskAncillaryService {
|
|
|
|
.orElseThrow(() -> new BusinessException("流程ID不能为空")).getProcessId()))
|
|
|
|
.orElseThrow(() -> new BusinessException("流程ID不能为空")).getProcessId()))
|
|
|
|
.orElseThrow(() -> new BusinessException("未找到流程ID"));
|
|
|
|
.orElseThrow(() -> new BusinessException("未找到流程ID"));
|
|
|
|
for (AskAncillaryBatchReqVO item : reqVO) {
|
|
|
|
for (AskAncillaryBatchReqVO item : reqVO) {
|
|
|
|
// 执行并保存结果
|
|
|
|
// 执行并保存结果
|
|
|
|
execSaveDiagnosisAncillaryRecord(item.getAncillaryItemId(), item.getPrimaryId(), process);
|
|
|
|
execSaveDiagnosisAncillaryRecord(item.getAncillaryItemId(), item.getPrimaryId(), process);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -90,7 +91,7 @@ public class AskAncillaryServiceImpl implements AskAncillaryService {
|
|
|
|
record.setProcessId(process.getId());
|
|
|
|
record.setProcessId(process.getId());
|
|
|
|
record.setItemId(itemId);
|
|
|
|
record.setItemId(itemId);
|
|
|
|
record.setAncillaryId(diseaseAncillary.getId());
|
|
|
|
record.setAncillaryId(diseaseAncillary.getId());
|
|
|
|
record.setResult(diseaseAncillary.getResult());
|
|
|
|
record.setResult(StrUtil.isNotBlank(diseaseAncillary.getResult()) ? diseaseAncillary.getResult() : diseaseAncillary.getNormalResult());
|
|
|
|
record.setCreateUserId(UserUtil.getUser().getId());
|
|
|
|
record.setCreateUserId(UserUtil.getUser().getId());
|
|
|
|
record.setUpdateUserId(UserUtil.getUser().getId());
|
|
|
|
record.setUpdateUserId(UserUtil.getUser().getId());
|
|
|
|
record.setItemName(diseaseAncillary.getItemName());
|
|
|
|
record.setItemName(diseaseAncillary.getItemName());
|
|
|
@ -108,7 +109,6 @@ public class AskAncillaryServiceImpl implements AskAncillaryService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return record;
|
|
|
|
return record;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -134,11 +134,11 @@ public class AskAncillaryServiceImpl implements AskAncillaryService {
|
|
|
|
List<AskAncillaryHistoryResVO> value = entry.getValue();
|
|
|
|
List<AskAncillaryHistoryResVO> value = entry.getValue();
|
|
|
|
List<DiagnosisPrimaryVO> diagnosisPrimaryList = new ArrayList<>();
|
|
|
|
List<DiagnosisPrimaryVO> diagnosisPrimaryList = new ArrayList<>();
|
|
|
|
Optional<AskAncillaryHistoryResVO> any = value.stream().findAny();
|
|
|
|
Optional<AskAncillaryHistoryResVO> any = value.stream().findAny();
|
|
|
|
if (any.isPresent()){
|
|
|
|
if (any.isPresent()) {
|
|
|
|
AskAncillaryHistoryResVO bean = BeanUtil.toBean(any.get(), AskAncillaryHistoryResVO.class);
|
|
|
|
AskAncillaryHistoryResVO bean = BeanUtil.toBean(any.get(), AskAncillaryHistoryResVO.class);
|
|
|
|
for (AskAncillaryHistoryResVO node: value) {
|
|
|
|
for (AskAncillaryHistoryResVO node : value) {
|
|
|
|
DiagnosisPrimaryVO diagnosisPrimaryVO = primaryMap.get(node.getPrimaryId());
|
|
|
|
DiagnosisPrimaryVO diagnosisPrimaryVO = primaryMap.get(node.getPrimaryId());
|
|
|
|
if (ObjectUtil.isNotEmpty(diagnosisPrimaryVO)){
|
|
|
|
if (ObjectUtil.isNotEmpty(diagnosisPrimaryVO)) {
|
|
|
|
diagnosisPrimaryList.add(diagnosisPrimaryVO);
|
|
|
|
diagnosisPrimaryList.add(diagnosisPrimaryVO);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -154,7 +154,7 @@ public class AskAncillaryServiceImpl implements AskAncillaryService {
|
|
|
|
public void saveAncillaryAssessmentResult(SaveAncillaryAssessmentResultReqVO reqVO) {
|
|
|
|
public void saveAncillaryAssessmentResult(SaveAncillaryAssessmentResultReqVO reqVO) {
|
|
|
|
boolean update = diagnosisAncillaryRecordService.lambdaUpdate().set(DiagnosisAncillaryRecord::getAssessmentResult, reqVO.getResult())
|
|
|
|
boolean update = diagnosisAncillaryRecordService.lambdaUpdate().set(DiagnosisAncillaryRecord::getAssessmentResult, reqVO.getResult())
|
|
|
|
.eq(DiagnosisAncillaryRecord::getId, reqVO.getRecordId()).update();
|
|
|
|
.eq(DiagnosisAncillaryRecord::getId, reqVO.getRecordId()).update();
|
|
|
|
if (!update){
|
|
|
|
if (!update) {
|
|
|
|
throw new BusinessException("保存判读结果失败");
|
|
|
|
throw new BusinessException("保存判读结果失败");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|