diff --git a/virtual-patient-web/src/main/java/com/supervision/service/impl/AskProcessServiceImpl.java b/virtual-patient-web/src/main/java/com/supervision/service/impl/AskProcessServiceImpl.java index 09d7c9a9..8cf82773 100644 --- a/virtual-patient-web/src/main/java/com/supervision/service/impl/AskProcessServiceImpl.java +++ b/virtual-patient-web/src/main/java/com/supervision/service/impl/AskProcessServiceImpl.java @@ -4,13 +4,16 @@ import cn.hutool.core.lang.Assert; import com.supervision.exception.BusinessException; import com.supervision.model.MedicalRec; import com.supervision.model.Process; +import com.supervision.model.ProcessMedical; import com.supervision.model.User; import com.supervision.service.AskProcessService; import com.supervision.service.MedicalRecService; +import com.supervision.service.ProcessMedicalService; import com.supervision.service.ProcessService; import com.supervision.util.SequenceUtil; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.util.List; import java.util.Optional; @@ -23,7 +26,10 @@ public class AskProcessServiceImpl implements AskProcessService { private final MedicalRecService medicalRecService; + private final ProcessMedicalService processMedicalService; + @Override + @Transactional(rollbackFor = Exception.class) public Process creatDiagnosisProcess(String patientId,String medicalId, User user) { MedicalRec medicalRec = Optional.ofNullable(medicalRecService.getById(medicalId)).orElseThrow(() -> new BusinessException("未找到病历")); Process process = new Process(); @@ -37,6 +43,15 @@ public class AskProcessServiceImpl implements AskProcessService { process.setProcessType(0);//默认学习类型 process.setProcessNo(SequenceUtil.getProcessNo()); processService.save(process); + // 还需要生成一个vp_process_medical + ProcessMedical processMedical = new ProcessMedical(); + processMedical.setProcessId(process.getId()); + processMedical.setMedicalRecId(medicalId); + processMedical.setPatientId(patientId); + processMedical.setDiseaseId(process.getDiseaseId()); + processMedical.setCreateUserId(user.getId()); + processMedical.setUpdateUserId(user.getId()); + processMedicalService.save(processMedical); return process; }