From 45421c9b4c5d90e914191312945fdaafdf841162 Mon Sep 17 00:00:00 2001
From: wxd <123@qq.com>
Date: Wed, 22 May 2024 22:03:56 +0800
Subject: [PATCH] =?UTF-8?q?=E8=81=8C=E4=B8=9A=E7=97=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../OccupationalDiseaseAppService.cs          | 32 +++++++++++++++++--
 1 file changed, 30 insertions(+), 2 deletions(-)

diff --git a/src/Shentun.Peis.Application/OccupationalDiseases/OccupationalDiseaseAppService.cs b/src/Shentun.Peis.Application/OccupationalDiseases/OccupationalDiseaseAppService.cs
index 7881cf8..db503ff 100644
--- a/src/Shentun.Peis.Application/OccupationalDiseases/OccupationalDiseaseAppService.cs
+++ b/src/Shentun.Peis.Application/OccupationalDiseases/OccupationalDiseaseAppService.cs
@@ -117,13 +117,13 @@ namespace Shentun.Peis.OccupationalDiseases
             var patientOccupationalDiseaseEnt = await _patientOccupationalDiseaseRepository.FirstOrDefaultAsync(f => f.PatientRegisterId == input.PatientRegisterId);
             if (patientOccupationalDiseaseEnt == null)
             {
-               
+
                 var entity = _patientOccupationalDiseaseManager.CreateAsync(patientOccupationalDiseaseInput);
                 await _patientOccupationalDiseaseRepository.InsertAsync(entity, true);
             }
             else
             {
-                _patientOccupationalDiseaseManager.UpdateAsync(patientOccupationalDiseaseEnt, patientOccupationalDiseaseInput);
+                _patientOccupationalDiseaseManager.UpdateAsync(patientOccupationalDiseaseInput, patientOccupationalDiseaseEnt);
                 await _patientOccupationalDiseaseRepository.UpdateAsync(patientOccupationalDiseaseEnt, true);
             }
             #endregion
@@ -498,5 +498,33 @@ namespace Shentun.Peis.OccupationalDiseases
             return msg;
         }
 
+
+        /// <summary>
+        /// 删除职业病相关信息
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("api/app/OccupationalDisease/DeleteOccupationalDiseaseWithDetail")]
+        public async Task DeleteOccupationalDiseaseWithDetailAsync(PatientRegisterIdInputDto input)
+        {
+            if (input == null)
+            {
+                throw new UserFriendlyException("请求参数有误");
+            }
+
+            if (input.PatientRegisterId == Guid.Empty)
+                throw new UserFriendlyException("人员ID不正确");
+
+            await _patientOccupationalDiseaseRepository.DeleteAsync(d => d.PatientRegisterId == input.PatientRegisterId);
+
+            await _patientOccupationalHistoryRepository.DeleteAsync(d => d.PatientRegisterId == input.PatientRegisterId);
+
+            await _patientPoisonRepository.DeleteAsync(d => d.PatientRegisterId == input.PatientRegisterId);
+
+            await _patientSymptomRepository.DeleteAsync(d => d.PatientRegisterId == input.PatientRegisterId);
+
+
+        }
+
     }
 }