|
|
|
|
@ -1,9 +1,13 @@
|
|
|
|
|
package com.supervision.service.impl;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
|
import com.supervision.exception.BusinessException;
|
|
|
|
|
import com.supervision.model.*;
|
|
|
|
|
import com.supervision.model.Process;
|
|
|
|
|
import com.supervision.pojo.vo.DiagnosticBasisForPrimaryReqVO;
|
|
|
|
|
import com.supervision.pojo.vo.SaveDiagnosisPrimaryReqVO;
|
|
|
|
|
import com.supervision.vo.ask.DiagnosticBasisForPrimaryResVO;
|
|
|
|
|
import com.supervision.service.*;
|
|
|
|
|
import com.supervision.util.UserUtil;
|
|
|
|
|
@ -13,7 +17,8 @@ import lombok.RequiredArgsConstructor;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.*;
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
@Service
|
|
|
|
|
@RequiredArgsConstructor
|
|
|
|
|
@ -31,6 +36,8 @@ public class AskPrimaryServiceImpl implements AskPrimaryService {
|
|
|
|
|
|
|
|
|
|
private final ProcessService processService;
|
|
|
|
|
|
|
|
|
|
private final DiagnosisPrimaryRelationService diagnosisPrimaryRelationService;
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public List<DiagnosisPrimaryVO> queryAskPrimaryList(String processId) {
|
|
|
|
|
return diagnosisPrimaryService.queryAskPrimaryList(processId);
|
|
|
|
|
@ -49,17 +56,22 @@ public class AskPrimaryServiceImpl implements AskPrimaryService {
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public void savePrimary(DiagnosisPrimary reqVO) {
|
|
|
|
|
reqVO.setExcludeFlag(null);
|
|
|
|
|
reqVO.setCreateUserId(UserUtil.getUser().getId());
|
|
|
|
|
diagnosisPrimaryService.save(reqVO);
|
|
|
|
|
public void savePrimary(SaveDiagnosisPrimaryReqVO reqVO) {
|
|
|
|
|
DiagnosisPrimary diagnosisPrimary = BeanUtil.toBean(reqVO, DiagnosisPrimary.class);
|
|
|
|
|
diagnosisPrimary.setExcludeFlag(null);
|
|
|
|
|
diagnosisPrimary.setCreateUserId(UserUtil.getUser().getId());
|
|
|
|
|
diagnosisPrimaryService.save(diagnosisPrimary);
|
|
|
|
|
// 然后开始保存初步诊断关键的诊断
|
|
|
|
|
List<DiagnosisPrimaryRelation> primaryRecordList = reqVO.getPrimaryRecordList();
|
|
|
|
|
primaryRecordList.forEach(e -> e.setPrimaryId(diagnosisPrimary.getId()));
|
|
|
|
|
diagnosisPrimaryRelationService.saveBatch(primaryRecordList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void updatePrimaryByConfirm(DiagnosisPrimary reqVO) {
|
|
|
|
|
diagnosisPrimaryService.lambdaUpdate().set(DiagnosisPrimary::getExcludeFlag,reqVO.getExcludeFlag())
|
|
|
|
|
.set(DiagnosisPrimary::getPatientDiseaseInfo,reqVO.getPatientDiseaseInfo())
|
|
|
|
|
.eq(DiagnosisPrimary::getId,reqVO.getId()).update();
|
|
|
|
|
diagnosisPrimaryService.lambdaUpdate().set(DiagnosisPrimary::getExcludeFlag, reqVO.getExcludeFlag())
|
|
|
|
|
.set(DiagnosisPrimary::getPatientDiseaseInfo, reqVO.getPatientDiseaseInfo())
|
|
|
|
|
.eq(DiagnosisPrimary::getId, reqVO.getId()).update();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
@ -79,37 +91,62 @@ public class AskPrimaryServiceImpl implements AskPrimaryService {
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 确诊页面,初步诊断填写初步诊断依据
|
|
|
|
|
*
|
|
|
|
|
* @param processId 流程ID
|
|
|
|
|
* @return 结果
|
|
|
|
|
*/
|
|
|
|
|
@Override
|
|
|
|
|
public List<DiagnosticBasisForPrimaryResVO> queryDiagnosticBasisListForPrimary(String processId) {
|
|
|
|
|
return diagnosisPrimaryService.queryDiagnosticBasisListForPrimary(processId);
|
|
|
|
|
List<DiagnosticBasisForPrimaryResVO> resList = diagnosisPrimaryService.queryDiagnosticBasisListForPrimary(processId);
|
|
|
|
|
if (CollUtil.isEmpty(resList)) {
|
|
|
|
|
return resList;
|
|
|
|
|
}
|
|
|
|
|
// 找到process对应的所有的初步诊断
|
|
|
|
|
List<DiagnosisPrimaryVO> diagnosisPrimaryVOS = diagnosisPrimaryService.queryAskPrimaryList(processId);
|
|
|
|
|
Map<String, String> diseaseNameMap = diagnosisPrimaryVOS.stream().collect(Collectors.toMap(DiagnosisPrimaryVO::getId, DiagnosisPrimaryVO::getPrimaryDiseaseName));
|
|
|
|
|
// 首先根据诊断记录,找到对应的关联关系
|
|
|
|
|
Set<String> relationIdSet = resList.stream().map(DiagnosticBasisForPrimaryResVO::getId).collect(Collectors.toSet());
|
|
|
|
|
List<DiagnosisPrimaryRelation> relationList = diagnosisPrimaryRelationService.lambdaQuery().in(DiagnosisPrimaryRelation::getRelationId, relationIdSet).list();
|
|
|
|
|
// 根据relationId进行分组
|
|
|
|
|
Map<String, List<DiagnosisPrimaryRelation>> relationMap = relationList.stream().collect(Collectors.groupingBy(DiagnosisPrimaryRelation::getRelationId));
|
|
|
|
|
for (DiagnosticBasisForPrimaryResVO node : resList) {
|
|
|
|
|
List<DiagnosisPrimaryRelation> relationPrimaryList = relationMap.get(node.getId());
|
|
|
|
|
Set<String> primarySet = relationPrimaryList.stream().map(DiagnosisPrimaryRelation::getPrimaryId).collect(Collectors.toSet());
|
|
|
|
|
if (CollUtil.isNotEmpty(primarySet)) {
|
|
|
|
|
List<String> diseaseNameList = new ArrayList<>();
|
|
|
|
|
primarySet.forEach(e -> diseaseNameList.add(diseaseNameMap.get(e)));
|
|
|
|
|
node.setPrimaryIdList(new ArrayList<>(primarySet));
|
|
|
|
|
node.setPrimaryName(StrUtil.join(";", diseaseNameList));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return resList;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void saveDiagnosticBasis(List<DiagnosticBasisForPrimaryReqVO> reqVO) {
|
|
|
|
|
for (DiagnosticBasisForPrimaryReqVO node : reqVO) {
|
|
|
|
|
if (1 == node.getType()){
|
|
|
|
|
diagnosisQaRecordService.lambdaUpdate().set(DiagnosisQaRecord::getBasisConfirmFlag,node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisQaRecord::getBasisIdentificationFlag,node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisQaRecord::getId,node.getId()).update();
|
|
|
|
|
if (1 == node.getType()) {
|
|
|
|
|
diagnosisQaRecordService.lambdaUpdate().set(DiagnosisQaRecord::getBasisConfirmFlag, node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisQaRecord::getBasisIdentificationFlag, node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisQaRecord::getId, node.getId()).update();
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
if (2 == node.getType()){
|
|
|
|
|
diagnosisPhysicalRecordService.lambdaUpdate().set(DiagnosisPhysicalRecord::getBasisConfirmFlag,node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisPhysicalRecord::getBasisIdentificationFlag,node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisPhysicalRecord::getId,node.getId()).update();
|
|
|
|
|
if (2 == node.getType()) {
|
|
|
|
|
diagnosisPhysicalRecordService.lambdaUpdate().set(DiagnosisPhysicalRecord::getBasisConfirmFlag, node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisPhysicalRecord::getBasisIdentificationFlag, node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisPhysicalRecord::getId, node.getId()).update();
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
if (3 == node.getType()){
|
|
|
|
|
diagnosisAncillaryRecordService.lambdaUpdate().set(DiagnosisAncillaryRecord::getBasisConfirmFlag,node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisAncillaryRecord::getBasisIdentificationFlag,node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisAncillaryRecord::getId,node.getId()).update();
|
|
|
|
|
if (3 == node.getType()) {
|
|
|
|
|
diagnosisAncillaryRecordService.lambdaUpdate().set(DiagnosisAncillaryRecord::getBasisConfirmFlag, node.getBasisConfirmFlag())
|
|
|
|
|
.set(DiagnosisAncillaryRecord::getBasisIdentificationFlag, node.getBasisIdentificationFlag())
|
|
|
|
|
.eq(DiagnosisAncillaryRecord::getId, node.getId()).update();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
// 然后将process的状态改为诊毕
|
|
|
|
|
processService.lambdaUpdate().set(Process::getStatus,1).update();
|
|
|
|
|
processService.lambdaUpdate().set(Process::getStatus, 1).update();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
liu
1 year ago