心电图

ThirdPlugIns/Shentun.Peis.PlugIns.Gem/ImportElectrocardiogramResults/Mdks/ImportElectrocardiogramResultPlugInsMdks.cs

@@ -0,0 +1,140 @@
+using Newtonsoft.Json.Converters;
+using Newtonsoft.Json;
+using Shentun.Peis.ImportPacsResults;
+using Shentun.Peis.PlugIns.Extensions.ImportPacsResults.Hzcy;
+using Shentun.Peis.PlugIns.ImportPacsResults;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http.Headers;
+using System.Text;
+
+namespace Shentun.Peis.PlugIns.Extensions.ImportElectrocardiogramResults.Mdks
+{
+
+    public class ImportElectrocardiogramResultPlugInsMdks : ImportPacsResultPlugInsBase
+    {
+        public ImportElectrocardiogramResultPlugInsMdks(Guid thirdInterfaceId) : base(thirdInterfaceId)
+        {
+        }
+        public ImportElectrocardiogramResultPlugInsMdks(string parmValue) : base(parmValue)
+        {
+        }
+
+        public override async Task<ImportPacsResultPlugInsOut> ImportResultByPatientRegisterIdAsync(Guid patientRegisterId)
+        {
+            //if (DepartmentColumnReferenceId == null || DepartmentColumnReferenceId == Guid.Empty)
+            //{
+            //    throw new Exception("没有设置科室编码对照");
+            //}
+            var pacsRequests = await GetPacsRequestForImportResultPlugInssAsync(patientRegisterId);
+
+            var beginTime = DateTime.Now.Date.AddDays(-30);
+            foreach (var pacsRequest in pacsRequests)
+            {
+                if (string.IsNullOrWhiteSpace(pacsRequest.CheckRequestNo))
+                {
+                    continue;
+                }
+                var interfaceInpu = new ImportPacsResultInterfaceInput()
+                {
+                    tjNum = pacsRequest.CheckRequestNo,
+                    organizeCode = "1",
+                    patientType = "3",
+                    ////requestId = pacsRequest.CheckRequestNo,
+                    //beginTime = beginTime.ToString("yyyy-MM-dd HH:mm:ss"),
+                    //endTime=DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
+                    pageNo = 1,
+                    pageSize = 20
+                };
+                //if(interfaceInpu.tjNum == "2405112185")
+                //{
+                //    ;
+                //}
+                var apiResult = await CallInterfaceServiceAsync<ImportPacsResultInterfaceInput,
+                       ImportPacsResultInterfaceOut>(interfaceInpu);
+                if (apiResult == null || !apiResult.data.Any())
+                {
+                    continue;
+                }
+                var firstData = apiResult.data[0];
+                if (!DateTime.TryParse(firstData.reportDateTime, out var checkDate))
+                {
+                    throw new Exception("报告时间格式不正确");
+                }
+                var createImportPacsResultDto = new CreateImportPacsResultDto()
+                {
+                    CheckRequestNo = pacsRequest.CheckRequestNo,
+                    PatientName = pacsRequest.PatientName,
+                    Result = firstData.examDescript,
+                    Summary = firstData.examDiagnosis,
+                    Suggestion = firstData.suggestion,
+                    CheckDate = checkDate,
+                    CheckDoctorName = firstData.reportDoctorName,
+                    Files = new List<CreateImportPacsResultPictureDto>()
+                    {
+                        new CreateImportPacsResultPictureDto()
+                        {
+                            IsPrint = 'Y',
+                            FileTransMode = "1",//0-json，1-url
+                            FileName = firstData.reportUrl,
+                            FileFormat = "1",//0-图片，1-pdf
+                            FileUrl = firstData.reportUrl,
+                            //FileBase64 = Shentun.Utilities.FileHelper.ToBase64(firstData.reportUrl)
+                        },
+
+                    }
+                };
+
+
+                var callResult = await CallAppServiceAsync<CreateImportPacsResultDto, object>("api/app/Electrocardiogram/ImportElectrocardiogramResult", createImportPacsResultDto);
+
+            }
+            var result = new ImportPacsResultPlugInsOut();
+            return result;
+        }
+
+
+        public async Task<TOut> CallInterfaceServiceAsync<TInput, TOut>(TInput data)
+        {
+            string baseAddress = InterfaceWebApiUrl;
+            using (var httpClientHandler = new HttpClientHandler())
+            {
+                using (var httpClient = new HttpClient(httpClientHandler))
+                {
+                    httpClient.BaseAddress = new Uri(baseAddress);
+
+                    httpClient.DefaultRequestHeaders.Accept.Add(
+                      new MediaTypeWithQualityHeaderValue("application/json"));//设置accept标头，告诉JSON是可接受的响应类型
+                    //httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", _accesToken);
+                    IsoDateTimeConverter timeFormat = new IsoDateTimeConverter();
+                    timeFormat.DateTimeFormat = "yyyy-MM-dd HH:mm:ss";
+                    var sendData = JsonConvert.SerializeObject(data, Formatting.Indented, timeFormat);
+                    using (HttpContent httpContent = new StringContent(sendData))
+                    {
+                        httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
+                        HttpResponseMessage response = await httpClient.PostAsync("", httpContent);
+                        string result;
+                        if (!response.IsSuccessStatusCode)
+                        {
+                            result = response.Content.ReadAsStringAsync().Result;
+                            throw new Exception("http通信错误:" + response.StatusCode + ",结果:" + result);
+                        }
+                        result = await response.Content.ReadAsStringAsync();
+
+                        dynamic resultDto = JsonConvert.DeserializeObject<TOut>(result);
+                        if (resultDto != null)
+                        {
+                            if (resultDto.code != "200")
+                            {
+                                throw new Exception($"调用WebApi失败，返回错误,消息:" + resultDto.code + resultDto.msg);
+                            }
+                        }
+                        return resultDto;
+                    }
+
+                }
+            }
+        }
+    }
+}

src/Shentun.Peis.Application/ImportPacsResults/ImportPacsResultAppService.cs

@@ -345,6 +345,215 @@ namespace Shentun.Peis.ImportPacsResults
             }
         }
 
+
+
+
+        /// <summary>
+        /// 导入心电图结果
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        /// <exception cref="UserFriendlyException"></exception>
+        [HttpPost("api/app/Electrocardiogram/ImportElectrocardiogramResult")]
+        public async Task ImportElectrocardiogramResult(CreateImportPacsResultDto input)
+        {
+            if (input == null)
+            {
+                throw new UserFriendlyException("input参数不能为空");
+
+            }
+            if (string.IsNullOrWhiteSpace(input.CheckRequestNo))
+            {
+                throw new UserFriendlyException("CheckRequestNo不能为空");
+            }
+            //设置结果
+
+            var list = (from patientRegister in await _patientRegisterRepository.GetQueryableAsync()
+                        join registerCheck in await _registerCheckRepository.GetQueryableAsync()
+                        on patientRegister.Id equals registerCheck.PatientRegisterId
+                        join registerCheckItem in await _registerCheckItemRepository.GetQueryableAsync()
+                        on registerCheck.Id equals registerCheckItem.RegisterCheckId
+                        join item in await _itemRepository.GetQueryableAsync()
+                        on registerCheckItem.ItemId equals item.Id
+                        where registerCheck.CheckRequestNo == input.CheckRequestNo
+                        select new
+                        {
+                            patientRegister,
+                            registerCheck,
+                            registerCheckItem,
+                            item,
+                        }).ToList();
+            if (!list.Any())
+            {
+                return;
+            }
+            var firstEntity = list.First();
+
+            if (string.IsNullOrWhiteSpace(input.Result))
+            {
+                return;
+            }
+            if (string.IsNullOrWhiteSpace(input.CheckDoctorName))
+            {
+                throw new UserFriendlyException("检查医生不能为空");
+            }
+            if (string.IsNullOrWhiteSpace(input.PatientName))
+            {
+                throw new UserFriendlyException("姓名不能为空");
+            }
+            if (input.PatientName != firstEntity.patientRegister.PatientName)
+            {
+                throw new UserFriendlyException($"Pacs姓名{input.PatientName}和体检系统姓名{firstEntity.patientRegister.PatientName}不一致");
+            }
+            var updateCheckResultDto = new UpdateCheckResultDto()
+            {
+                RegisterCheckId = firstEntity.registerCheck.Id,
+                CheckDoctorId = input.CheckDoctorName,
+                CheckDate = input.CheckDate,
+                ExecOrganizationUnitId = input.ExecOrganizationUnitId,
+                RegisterCheckItems = list
+                     .Select(o => new UpdateRegisterCheckItemDetail()
+                     {
+                         ItemId = o.registerCheckItem.ItemId,
+                         Result = input.Result,
+
+                     }).ToList()
+
+            };
+
+
+            //生成小结
+            updateCheckResultDto.Summarys.Add(new UpdateRegisterCheckSummaryDetail()
+            {
+                Summary = input.Summary,
+                SummaryFlag = '0'
+            });
+            //保存明细结果和小结
+            await _registerCheckAppService.UpdateCheckResult(updateCheckResultDto);
+            //保存图片
+            string absolutePath = _configuration.GetValue<string>("VirtualPath:RealPath");
+            //删除以前的图片
+            var registerCheckPictures = await _registerCheckPictureRepository.GetListAsync(o => o.RegisterCheckId == firstEntity.registerCheck.Id);
+            await _registerCheckPictureRepository.DeleteManyAsync(registerCheckPictures);
+            //插入新图片
+            string pictureUrl;
+            foreach (var file in input.Files)
+            {
+                if (string.IsNullOrWhiteSpace(file.FileTransMode))
+                {
+                    throw new UserFriendlyException("文件传输模式不能为空");
+                }
+                if (string.IsNullOrWhiteSpace(file.FileFormat))
+                {
+                    throw new UserFriendlyException("文件格式不能为空");
+                }
+                if (file.FileTransMode != "0" && file.FileTransMode != "1")
+                {
+                    throw new UserFriendlyException("文件传输模式不正确");
+                }
+                if (file.FileFormat != "0" && file.FileFormat != "1")
+                {
+                    throw new UserFriendlyException("文件格式不正确");
+                }
+                string fileName;
+                if (string.IsNullOrWhiteSpace(file.FileName))
+                {
+                    fileName = Guid.NewGuid().ToString();
+                }
+                else
+                {
+                    fileName = Path.GetFileNameWithoutExtension(file.FileName);
+                }
+                if (file.FileTransMode == "1")
+                {
+                    if (string.IsNullOrWhiteSpace(file.FileUrl))
+                    {
+                        throw new UserFriendlyException("文件URL不能为空");
+                    }
+                    if (!string.IsNullOrWhiteSpace(file.FileBase64))
+                    {
+                        throw new UserFriendlyException("文件Base64不能传值");
+                    }
+                    file.FileBase64 = Shentun.Utilities.FileHelper.ToBase64str(file.FileUrl);
+                }
+                else
+                {
+                    if (string.IsNullOrWhiteSpace(file.FileBase64))
+                    {
+                        throw new UserFriendlyException("文件Base64不能为空");
+                    }
+                }
+                //0-图片，1-PDF
+                if (file.FileFormat == "0")
+                {
+                    pictureUrl = ImageHelper.Base64ToImageUseAbsolutePath(absolutePath, fileName, file.FileBase64, firstEntity.patientRegister.Id.ToString(),
+                   firstEntity.registerCheck.Id.ToString());
+
+                }
+                else if (file.FileFormat == "1")
+                {
+
+                    byte[] pdfBytes = Convert.FromBase64String(file.FileBase64);
+                    var tempFilePath = DirectoryHelper.GetAppDirectory() + "\\temp-files";
+                    if (!Directory.Exists(tempFilePath))
+                    {
+                        Directory.CreateDirectory(tempFilePath);
+                    }
+
+                    string tempPdf = tempFilePath + "\\temp.pdf";
+                    using (System.IO.FileStream stream = new System.IO.FileStream(tempPdf, System.IO.FileMode.Create))
+                    {
+                        //通过流的方式写入
+                        using (System.IO.BinaryWriter writer = new System.IO.BinaryWriter(stream))
+                        {
+                            writer.Write(pdfBytes, 0, pdfBytes.Length);
+                            writer.Close();
+                        }
+
+                    }
+
+                    string hostName = file.FileUrl.Replace("http://", "").Replace("https://", "");
+                    if (hostName.IndexOf(":") > 0)
+                    {
+                        hostName = hostName.Substring(0, hostName.IndexOf(":"));
+                    }
+                    else
+                    {
+                        hostName = hostName.Substring(0, hostName.IndexOf("/"));
+                    }
+
+                    string tempImageName = "tempImage" + hostName;
+                    PDFHelper.ConvertPdfToImage(tempPdf, tempFilePath, tempImageName);
+
+                    pictureUrl = ImageHelper.SavePacsFile(absolutePath, tempFilePath + "\\" + tempImageName + "_0.jpg", firstEntity.patientRegister.Id.ToString(),
+                   firstEntity.registerCheck.Id.ToString(), fileName);
+                }
+                else
+                {
+                    throw new UserFriendlyException("不支持的文件类型");
+                }
+
+
+
+                if (string.IsNullOrWhiteSpace(pictureUrl))
+                {
+                    throw new UserFriendlyException("pictureUrl不能是空值");
+                }
+                var registerCheckPicture = new RegisterCheckPicture
+                {
+                    DisplayOrder = input.Files.IndexOf(file) + 1,
+                    IsPrint = file.IsPrint,
+                    PictureFilename = pictureUrl,
+                    RegisterCheckId = firstEntity.registerCheck.Id,
+                };
+
+                await _registerCheckPictureRepository.InsertAsync(registerCheckPicture);
+            }
+
+
+
+        }
+
         /// <summary>
         /// 导入心电图
         /// </summary>

src/Shentun.Utilities/FileHelper.cs

@@ -48,5 +48,46 @@ namespace Shentun.Utilities
             }
          
         }
+
+        public static string ToBase64str(string filename)
+        {
+            Stream stream;
+            string fileBase64;
+            if (filename.StartsWith("http"))
+            {
+                using (var httpClientHandler = new HttpClientHandler())
+                {
+                    using (var httpClient = new HttpClient(httpClientHandler))
+                    {
+                        var response = httpClient.GetAsync(filename).Result;
+                        if (response.IsSuccessStatusCode)
+                        {
+                            var contentStream = response.Content.ReadAsStreamAsync().Result;
+                            using var memoryStream = new MemoryStream();
+                            contentStream.CopyTo(memoryStream);
+                            var fileBytes = memoryStream.ToArray();
+                            return Convert.ToBase64String(fileBytes);
+                        }
+                        else
+                        {
+                            throw new Exception("转换base64时，返回错误:" + response.StatusCode);
+                        }
+                    }
+                }
+
+            }
+            else
+            {
+                using (stream = new FileStream(filename, FileMode.Open, FileAccess.Read))
+                {
+                    byte[] byteData = new byte[stream.Length];
+                    stream.Read(byteData, 0, byteData.Length);
+                    fileBase64 = Convert.ToBase64String(byteData);
+                    stream.Close();
+                }
+                return fileBase64;
+            }
+
+        }
     }
 }