AIDiagnosisService.URM.cs 93 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618
  1. using WingServerCommon.Service;
  2. using WingInterfaceLibrary.Interface;
  3. using WingInterfaceLibrary.Request.RemedicalAISelected;
  4. using System.Threading.Tasks;
  5. using System.Linq;
  6. // using WingServerCommon.Log;
  7. using System.IO;
  8. using System;
  9. using System.Net.Http;
  10. using System.Net;
  11. using System.Collections.Generic;
  12. using WingInterfaceLibrary.Request.Examine;
  13. using Vinno.IUS.Common.Media.FFmpeg.Video;
  14. using Vinno.IUS.Common.Media.FFmpeg.Video.Codecs;
  15. using SkiaSharp;
  16. using Vinno.IUS.Common.Media.FFmpeg.Settings;
  17. using System.Diagnostics;
  18. using Logger = WingServerCommon.Log.Logger;
  19. using System.Text;
  20. using Newtonsoft.Json;
  21. using WingAIDiagnosisService.URMManage;
  22. using WingInterfaceLibrary.Result.Record;
  23. using Vinno.DataTypes;
  24. using WingInterfaceLibrary.DTO.Record;
  25. using static WingAIDiagnosisService.URMManage.UrmProcessRequest;
  26. using SixLabors.ImageSharp;
  27. using SixLabors.ImageSharp.Processing;
  28. using Microsoft.VisualBasic;
  29. using WingInterfaceLibrary.Request.AIDiagnosis;
  30. using Vinno.Enums;
  31. using Vinno.vCloud.Common.Vid2;
  32. using WingInterfaceLibrary.Notifications;
  33. namespace WingAIDiagnosisService.Service
  34. {
  35. /// <summary>
  36. /// URM分析服务
  37. /// </summary>
  38. public partial class AIDiagnosisService : JsonRpcService, IAIDiagnosisService
  39. {
  40. private readonly string _urmTempFolder = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "URMTemp");
  41. private URMAnalysisManager _urmAnalysisManager;
  42. //银杏叶logo
  43. private static string _logoBase64 = "iVBORw0KGgoAAAANSUhEUgAAAGQAAABTCAYAAABpnaJBAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAAadEVYdFNvZnR3YXJlAFBhaW50Lk5FVCB2My41LjEwMPRyoQAABn9JREFUeF7tnXtsU1UYwEk0JhoTE2M0GBMTYkxM0PgH+8tEYQKbbDym2YCNYQJOgQxFdOEVpxgR1Cl06x5l6TY2NscY27pABgzW59qyB+vK3iQGEk0M+IfBRxSJ9TvzK9luv66P++i53fklvz92ex7fOd/uPee2690CgSBqKuyrSmo9uYEy6/LAsZ7XQiy3pweqHKsDtZ6N7OeSE95NJVhVoDQm59qQBERjqfX1gNG2sgKbESgBNdGxanKuC9R781/EJgXxYHKuqaYmN14NPcsC1a6sF7B5QbTAOmGBy8yf1KTKla0x2I1ASo17/S6YpO5q15uB4651gTLbCnISlRY2B0swhKi4NPH1kovjh7vRD/FwclFqTX2fmiwtbOzb6sMwwgIT/yxc4nxUfSa7/MFZ7MLi+ifc1lUrMYywGKM8W+EXi22338Jq+qTeu/k2NTgttU4dW4ThhNA8sO06VWcu230fj2F1/oG1IguCvsEssyX2zAh6sm8LudvqGj34OFU+Gi3+fbewGX6pdW/4lQqeA8mEwPEnJOViEi5hqdgUH/RMfvt8U1/BHQjujgGur9KAOTJMQpZSZWMSdmWvYHOJA3Yd/1DBcWxIQkzOtY8Q5WLW3Jt9D5vUngtjh8mgdGBIQnomj1Ll4rJtaHdM9zqKUOvJ+4MKRieGJESJy1XQTv9+bd8RMNrSfqEC0ZFEQshycYvNqk9j3zs/UgHoyRr3xuRISGPf1ueozvVmh2/PrIScGdpNlpMjNq0u0NEP0o71aPf4kVkJocrIFZtWjzbfRy9THetRHNJ9qDJyZO9gY9PqAR31SzvWqzik+1Bl5Ph9/3vqJ6TCsYrsXG+yt85xSNO0+4oyqXJyrPfma3KGkJ3rTfZBGA5pmkpH5u9UObli8+pBdapHpdd3uCH8iyonV3Nv9gHsQh2oTvWo9HN1qoxSGqypn3QMFz2MXSlHy2ChnepQr+Kw2LhuUa8rKVuz4Gwpwi7lcX7si+wT3vzrrFGqM70K4ymtcGQUK/n+VSThplr+umJyrj1DNS6Mz1Jr6l2c2vjo9O8XCVFYA5yVlydKPsUpjh2qUaFcl/6G0xsbdZ48cYaoZLktbRynOTKVjox3y6zLb1INCZUTp3tuoGCBtKJQHWGRH8BpD49Wf2MrnP7+yh2c9vBQFYXqidMeHqqSUD1x2sNDVRKqI/tIA6c9PFRFoWpGXtTZt1mJikJ1jJwQQ8+yMqKiUCVbhz7oxqkPD1VRqJ7s/S2cehqLf684SxJgtSvrIUwBjcm55m+qolAda9wbIu+6Gvu2noR1RZXPnYWhnhrcbsKpnxtYfNqgwpS0AaGy1ns3Rz5LpLQMFtqg8rC0MaF8jba02BMyk0sT33ihIS9c1oYS/XXnZBGnVjlaBndaoWFrlXM12aFwbnEa1cM6dSy9zpN7DjqbttKRQQYi/F+ctsTQOby/tdye3mruzb6dbH9uFI8RbxK1ptaT26Dl30vxptmdM4VTwQ8W/94j7DeFCngeGN19iNbAmnOICHY+yGdCGEbbyrtEwEmtybnmCg6fP7pGD+6jgk52cfh8QgWc7MKO8ygOnz+ogOeB/CZknt5E8puQ7vEjVMDJLr8JuTz5HXsiHRV00lrjzuE3IQwq6GS10pHJ9y6LQQUeq+wJosddWTBgvtckuA/h98YwCBV4ONmjBZv6CyrKbWkp58cOpWATJGW2FSntviJVnqIdj+beHP7PjrPXiq9RwUttHth+uuHK24uxWswYepYtbriyhWxbCyvsq9gXQ5/BcPildWgXOYCgVY7VF+o8uU9icdm0DBYuOn11J9mXyj6FIfBNuM9I2P8GMbtzFmIxxTk3UrzQaEtbR/WttM3926zYLf9QA4CFL2Dx730Ui6hKtSvrQXNv9iYqDiWs8+S5sSt9IB0A7JYm8CVNOTfy2QMdw3t2SOOR46mBHVexeX1wYexL6ZN6buJLCcdoW3lPEltMYjP6Yub6AdvZf/EwV3QMFxnY987BqB4mDfdBN7CqvoDr9qxH0eJh7oHNgKXcns4eajNL9qAbLKI/6r35T7MkBO0a/Twh64YAgST8FEwGe6sDDwsSQb1386xH0eJhQSJoHtj+0sxkXBz/yosvCRIBJGEymIyovjIsUI86z6aRYDKYTf0Fj+FLAq2BhfvVmcno9B84iy8JEgXs3X9mySi3vyEuVbxQ415/C3ZZIf9KQiAQCKQsWPAfVXjcqZiVuhgAAAAASUVORK5CYII=";
  44. //视频默认urm colorbar
  45. private static string _urmColorbarBase64 = "iVBORw0KGgoAAAANSUhEUgAAAAoAAACACAIAAAC9e29UAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAH/SURBVFhHpZchSJwBGIa/9z8GQ4tFGFiuDAQZCCLI0pWBmCyCmK4MjMZFm3FJhJVLY2AxiWC5NAYWkwxWrpgsK7qwhc8vvOE///feC3v4wId7uONHXg5F5iRm0/DnDOrdP6mKyj+oispXVEXlb1RF5TOqovIJVVH5E1VR+ZCqqLxPVVTepioqb1EVlVepispvqIrKr6kK5F+aBPmbJkHe0yTIXzQJ8pYmQX6nSZDXNAnygiZBfqVJkF9okiaewlwTf8Lc/70b+ZFPIUEe0CTIXZoE+YEmQb6nSZDrNAnyLU2CXKFJkEs0CfIVTQI784CdecDOPGBnHrAzD9iZB+zMA3bmATvzgJ15NJ1xTl3TGefU9epb7d/s6210Xmpf713npfb16jvxxUvtg515wM48YGcesDMP2JkH7MwDdubzQMQiVVF5maqo3KcqKq9RFZU3qYrKA6qi8g5VUXmPqqg8pCrq75YFc5Xrtzbz5ueXH9i+erRTPoai8oiqqHxOVVS+pCoqj6mKyjdUReU7qqLyhKqo/EBVVH6kKionVYFY9HnZ577Paz5v+jzwecfnPZ+HLjed9U1d09nu1M3NnQ9sH+LUP/nI53OfL30e+3zj853PE58ffH70OW1e8rnv87rPA593fR76fOTzsc+ffR75fOHz2Odbnyc2z/kX2eaIZwFK+NjQuHI3AAAAAElFTkSuQmCC";
  46. //灌注colorbar
  47. private static string _perfusionColorbarBase64 = "iVBORw0KGgoAAAANSUhEUgAAAAoAAACACAIAAAC9e29UAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAFRSURBVFhHzZWhrsJQEERnmiYgkEgkshKJRPJXfBISiaxEVlZWYiCIfWYNZHPsu5MVkxyzSe/Z+iJKt5Zg/hP7mjvW8S1LHd+z1PGYpY4fWep4ylLHc5Y6XrLU8TNLHX+y1HH02co4NtnKOLbZyjh22co49tnKOIZsZRyHbGUcx2xlHKdsZRznbGW638f3PU3jlWAa3tyBgjtQcAcK7kDBHSi4AwV3oOAOFNyBgjtQcH9QcD9RcC8ouGcU3BMK7gcK7hEF9x0F9w0F9xUF715aw7SM31rBNLy5zyi4Tyi4jyi4Dyi4BxTcexTcOxTcWxTcGxTcPQpufSJrFevJeGE8M54YPxiPjO+Mb4yvhDu9BNM0fgum4c2tM3+xE+Mj4wPjgfGe8Y7xlvGGcc9YrL/weEh4eiQ8XBKePQmPpoQnV8KDLeG5l+hn0f0+vu9pFuv1B8jHoVpzbDgNAAAAAElFTkSuQmCC";
  48. //angle colorbar
  49. private static string _angleColorbarBase64 = "iVBORw0KGgoAAAANSUhEUgAAACgAAAAoCAIAAAADnC86AAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAATySURBVFhHxZfBap1VEMfnyC0k0IIpJBAX9QGy6MKFQgVdKCjowr5BdaePoAtfoIu6U/AF9AEUzCILAy51kYUFA43QQgJmodALDRx/Z/7nzDf35t6mu/4ZTub77sz8zpzvfOfe2MtS6X9fQHeq3bDJrq/y33rheq/0v+u1Xe1Wtb1qFzZZ1szsmo/Yn9UeV/un9o+eoyvAs2pzJz1bRHIpAZOCjW2a1avY68F11+rWhc1gBFVOUKXgZTbzradWHylkhdaA657PmwqbdCwL9mUFj5yWRtxTjwb/e49Z0ipwvWO2MYrgbFAEnkplC56MUI0tlJkyulN/Ud0FXQLXT3x7Np47DQ8jOpZlscJhRLePRf3XHR/rD4qdtAiunzqP9GD3GWj2WDxvKZ5rhDaSNxrU3ve3yuha6rgxRqNiy99gl6kUJrYU1LYyXEcQyKCGn5TA9evADHywm5GrTkRlpF0EWDnMrjOCFI7j65ee4Brg+mAwdApp3DK7mc6lDVWQSepVo6o3O0/jf2lkwT9X3tTx1JkbSDlQg71FrqcvPGNltnYv8+IyjGRXgAPTAGMM2zF71WfQ2VAwPWBlNgB2NpwwojXGVFwOrj8tUnEyddtHsbfntqEKbLGgzrgGGdQlPAmMg13fC/BElWUqPMC7bq+5v3PqRdQxadxqpMc+PnHDISizScjWvxbbsaanpiWMd5Xdov2kJilAyb/MHt6ys3fNPjBj3IV0ZHYyGiWQ8EjN9TCHlKMOpta415QD8TNbrcE55ITjuPmIkANmMjoOqpC5DMLxsZx0MOviN7oiSneiBlXFpruDN+zwe7Pb+8xhtKvPFUsSko9UEvllOe9gRYUiCikPqYYWgPKg7tf9Q/vGXW5wmw8VJa0s4yo03f4+W/zWzkF5pjImCeZvswfWwHY/kflYcCkclGcBde5g/VRZio8K0QrFeX48Fqi/tkVmqVlwf8hXrrVG1GZQ7MzBj/wHFYpRJBkVtLqY9hZb6cA+vrB7Zmwxf8hsNzY3k9IeVE6ugqFGxS927OCjOu4MUwq5maq3id6O2ivEi/Sh2TtmvFo+l+Px8mY2Y66INUyxPxz8m3ec54cfVEZKUZCyIKh/bLfbItubPuLP2nR4AHql9C7n/CjanWKHfnKpIU0UIzGMOhgFVdNPJY4qDiyOLWoQzu1xwHG06YzDx/IJmE9GTEfm+2Via7pL7HBO27GsVIE1Ww7wQWIGMYYRrhG7XuznAUYCy2BoBtkGXtn6hcXaYUpKmOdRfWwaYJ6FCqgFGOHH5Xn70iWP7mhXoulIdQClsUzSzaC2XwxogL/gnR4FwgavXz6dfmwwSrGFsPGbIHiBD9ssnDuuAUZfldaiyoCRL6Qb7YqqdvWMESOBik2MPAlN9UYxftZ1JTAiW8urRnC4VDvzlq0CIGOp9YqMEHw+0fSCja9F5nLSIvi70ngUEFWO+yTJKKydJUHVFlMgNhhYb1ROsc88o2sRjH50tqiM+N4IqeJh0a4EO8xjEeFqtLOL3fXYSZfAaN83mubvjhrVmC0jMVG9aWIxUdlQb3vdBa0CI47SUYZ//TT/4F2WwFpw8rCRAZV/PFdoDRid+HfXfOJpkVcutR6z8LpklxW7WdohulrrwV0l9wpVCjYYKVPp+Jp+YqzXlWDOj/LEykMrgQ+qlHvds/K6lZ2rqC9PZv8D5k++tFb2OZQAAAAASUVORK5CYII=";
  50. private URMAnalysisManager URMAnalysisManager
  51. {
  52. get
  53. {
  54. if (_urmAnalysisManager == null)
  55. {
  56. _urmAnalysisManager = new URMAnalysisManager(SendDiskSpaceFullNotification);
  57. }
  58. return _urmAnalysisManager;
  59. }
  60. }
  61. /// <summary>
  62. /// URM分析
  63. /// </summary>
  64. /// <param name="request">URM分析请求实体</param>
  65. /// <returns>URM分析分析结果</returns>
  66. /// <value></value>
  67. /// <errorCodes></errorCodes>
  68. public async Task<URMAnalysisResult> URMAnalysisAsync(URMAnalysisRequest request)
  69. {
  70. return null;
  71. }
  72. /// <summary>
  73. /// URM分析V2
  74. /// </summary>
  75. /// <param name="request">URM分析V2请求实体</param>
  76. /// <returns>URM分析分析结果V2</returns>
  77. /// <value></value>
  78. /// <errorCodes></errorCodes>
  79. public async Task<URMAnalysisV2Result> URMAnalysisV2Async(URMAnalysisV2Request request)
  80. {
  81. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  82. var remedicalCode = request.RemedicalCode;
  83. var customizedStartFrame = request.CustomizedStartFrame != null ? request.CustomizedStartFrame.ToString() : string.Empty;
  84. var customizedEndFrame = request.CustomizedEndFrame != null ? request.CustomizedEndFrame.ToString() : string.Empty;
  85. var x = (int)request.X;
  86. var y = (int)request.Y;
  87. var width = (int)request.Width;
  88. var height = (int)request.Height;
  89. var currentFolder = string.Empty;
  90. var resultData = new URMAnalysisV2Result { URMAnalysisDetails = new List<ImgItem>() };
  91. try
  92. {
  93. if (!string.IsNullOrWhiteSpace(remedicalCode))
  94. {
  95. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  96. var origialRemedicalInfo = remedical?.ImgList?.FirstOrDefault(x => x.ImgType == 0);
  97. var fileToken = origialRemedicalInfo?.FileToken ?? string.Empty;
  98. var converImageUrl = remedical?.TerminalImages?.CoverImageUrl;
  99. if (!string.IsNullOrWhiteSpace(fileToken) && !string.IsNullOrWhiteSpace(converImageUrl))
  100. {
  101. Logger.WriteLineInfo($"AIDiagnosisService URMAnalysisV2Async, remedicalCode:{remedicalCode}, fileToken:{fileToken}, converImageUrl:{converImageUrl}");
  102. currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  103. if (!Directory.Exists(currentFolder))
  104. {
  105. Directory.CreateDirectory(currentFolder);
  106. }
  107. var origialName = Path.GetFileName(fileToken);
  108. var origialFile = Path.Combine(currentFolder, origialName);
  109. if (!File.Exists(origialFile))
  110. {
  111. await DownloadToLocalAsync(fileToken, origialFile, request.NotifyUserCode, remedicalCode);
  112. }
  113. var coverInfo = await SaveCoverImageInfo(remedical, request.CustomizedStartFrame ?? 0, currentFolder, request.NotifyUserCode);
  114. var coverVidFile = coverInfo.Item1;
  115. var converFile = coverInfo.Item2;
  116. var vidImageCount = coverInfo.Item3;
  117. DeleteTempFiles(currentFolder, new List<string> { origialFile, coverVidFile, converFile });
  118. var readmePath = Path.Combine(currentFolder, "readme.txt");
  119. try
  120. {
  121. File.WriteAllText(readmePath, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  122. }
  123. catch { }
  124. if (File.Exists(origialFile) && File.Exists(coverVidFile) && File.Exists(converFile))
  125. {
  126. Logger.WriteLineInfo($"AIDiagnosisService URMAnalysisV2Async download success, remedicalCode:{remedicalCode}, fileToken:{fileToken}, localFile:{origialFile}");
  127. var urmParamers = remedical.UrmParameters;
  128. if (urmParamers != null && urmParamers.Any())
  129. {
  130. Logger.WriteLineInfo($"AIDiagnosisService URMAnalysisV2Async URMAnalysisProcess start, remedicalCode:{remedicalCode}");
  131. urmParamers.TryAdd("startX", x.ToString());
  132. urmParamers.TryAdd("startY", y.ToString());
  133. urmParamers.TryAdd("width", width.ToString());
  134. urmParamers.TryAdd("height", height.ToString());
  135. urmParamers.TryAdd("CustomizedStartFrame", request.CustomizedStartFrame == null ? "" : request.CustomizedStartFrame.ToString());
  136. urmParamers.TryAdd("CustomizedEndFrame", request.CustomizedEndFrame == null ? "" : request.CustomizedEndFrame.ToString());
  137. urmParamers.TryAdd("RoiXPercent", request.RoiXPercent.ToString());
  138. urmParamers.TryAdd("RoiYPercent", request.RoiYPercent.ToString());
  139. urmParamers.TryAdd("RoiWPercent", request.RoiWPercent.ToString());
  140. urmParamers.TryAdd("RoiHPercent", request.RoiHPercent.ToString());
  141. foreach (var k in urmParamers.Keys)
  142. {
  143. if (k.ToLower() == "section")
  144. {
  145. var section = urmParamers[k];
  146. if (!string.IsNullOrWhiteSpace(section) && !section.Contains("URMAnalysisParam:Level"))
  147. {
  148. urmParamers[k] = $"URMAnalysisParam:Level{section}";
  149. }
  150. }
  151. }
  152. // 开始URM分析
  153. var result = DoURMAnalysisV2(remedicalCode, origialFile, converFile, currentFolder, urmParamers, request.NotifyUserCode);
  154. if (result != null)
  155. {
  156. var pos = $"{x},{y},{width},{height},{customizedStartFrame},{customizedEndFrame},{vidImageCount}";
  157. Logger.WriteLineInfo($"AIDiagnosisService URMAnalysisV2Async start, remedicalCode:{remedicalCode}, Pos:{pos}");
  158. resultData.IsSuccess = true;
  159. resultData.UrmPosition = pos;
  160. resultData.URMSrcWidth = result.URMSrcWidth;
  161. resultData.URMSrcHeight = result.URMSrcHeight;
  162. resultData.URMRes = result.URMRes;
  163. resultData.URMScaleOfPixel_x = result.URMScaleOfPixel_x;
  164. resultData.URMScaleOfPixel_y = result.URMScaleOfPixel_y;
  165. await InitUrmVidDetails(resultData, coverVidFile, converFile);
  166. await InitURMAnalysisDetails(resultData, fileToken, currentFolder, origialRemedicalInfo, result.ConverImageUrl);
  167. }
  168. }
  169. }
  170. else
  171. {
  172. Logger.WriteLineWarn($"AIDiagnosisService URMAnalysisV2Async failed, remedicalCode:{remedicalCode}, origialFile not existed");
  173. }
  174. }
  175. }
  176. }
  177. catch (Exception ex)
  178. {
  179. Logger.WriteLineWarn($"AIDiagnosisService URMAnalysisV2Async error, remedicalCode:{remedicalCode}, ex:{ex}");
  180. }
  181. finally
  182. {
  183. try
  184. {
  185. if (Directory.Exists(currentFolder))
  186. {
  187. Directory.Delete(currentFolder, true);
  188. }
  189. }
  190. catch { }
  191. }
  192. Logger.WriteLineInfo($"AIDiagnosisService URMAnalysisV2Async finished, remedicalCode:{remedicalCode}, result:{resultData.IsSuccess}");
  193. return resultData;
  194. }
  195. /// <summary>
  196. /// URM后处理-预加载
  197. /// </summary>
  198. /// <param name="request">URM后处理请求实体</param>
  199. /// <returns>URM后处理结果</returns>
  200. /// <value></value>
  201. /// <errorCodes></errorCodes>
  202. public async Task<bool> LoadURMProcessAsync(URMProcessRequest request)
  203. {
  204. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  205. var remedicalCode = request.RemedicalCode;
  206. try
  207. {
  208. if (!string.IsNullOrWhiteSpace(remedicalCode))
  209. {
  210. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  211. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  212. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  213. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  214. {
  215. Logger.WriteLineInfo($"AIDiagnosisService LoadURMProcessAsync start, remedicalCode:{remedicalCode}");
  216. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  217. if (!Directory.Exists(currentFolder))
  218. {
  219. Directory.CreateDirectory(currentFolder);
  220. }
  221. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, "", remedicalCode);
  222. try
  223. {
  224. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  225. }
  226. catch
  227. {
  228. }
  229. Logger.WriteLineInfo($"AIDiagnosisService LoadURMProcessAsync InitURMProcessor start, remedicalCode:{remedicalCode}");
  230. var urmProcessRequest = ConvertToUrmRequest<URMProcessRequest, UrmProcessRequest>(request, remedical, currentFolder);
  231. urmProcessRequest.RemedicalCode = remedicalCode;
  232. urmProcessRequest.Token = request.Token;
  233. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  234. URMAnalysisManager.InitURMProcessor(urmProcessRequest);
  235. Logger.WriteLineInfo($"AIDiagnosisService LoadURMProcessAsync InitURMProcessor end, remedicalCode:{remedicalCode}");
  236. return true;
  237. }
  238. }
  239. }
  240. catch (Exception ex)
  241. {
  242. Logger.WriteLineWarn($"AIDiagnosisService LoadURMProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  243. }
  244. finally
  245. {
  246. Logger.WriteLineInfo($"AIDiagnosisService LoadURMProcessAsync finally, remedicalCode:{remedicalCode}");
  247. }
  248. return false;
  249. }
  250. /// <summary>
  251. /// URM后处理
  252. /// </summary>
  253. /// <param name="request">URM后处理请求实体</param>
  254. /// <returns>URM后处理结果</returns>
  255. /// <value></value>
  256. /// <errorCodes></errorCodes>
  257. public async Task<URMProcessResult> URMProcessAsync(URMProcessRequest request)
  258. {
  259. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  260. var remedicalCode = request.RemedicalCode;
  261. try
  262. {
  263. if (!string.IsNullOrWhiteSpace(remedicalCode))
  264. {
  265. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  266. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  267. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  268. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  269. {
  270. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync start, remedicalCode:{remedicalCode}");
  271. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  272. if (!Directory.Exists(currentFolder))
  273. {
  274. Directory.CreateDirectory(currentFolder);
  275. }
  276. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, "", remedicalCode);
  277. try
  278. {
  279. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  280. }
  281. catch
  282. {
  283. }
  284. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync DoUrmProcess start, remedicalCode:{remedicalCode}");
  285. var urmProcessRequest = ConvertToUrmRequest<URMProcessRequest, UrmProcessRequest>(request, remedical, currentFolder);
  286. urmProcessRequest.RemedicalCode = remedicalCode;
  287. urmProcessRequest.Token = request.Token;
  288. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  289. double urmMinVal = 0;
  290. double urmMaxVal = 0;
  291. var base64String = URMAnalysisManager.DoUrmProcess(urmProcessRequest, ref urmMinVal, ref urmMaxVal);
  292. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync DoUrmProcess end, remedicalCode:{remedicalCode}, base64String-Length:{base64String.Length}");
  293. return new URMProcessResult
  294. {
  295. Base64String = base64String,
  296. UrmMinVal = urmMinVal,
  297. UrmMaxVal = urmMaxVal,
  298. };
  299. }
  300. }
  301. }
  302. catch (Exception ex)
  303. {
  304. Logger.WriteLineWarn($"AIDiagnosisService URMProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  305. }
  306. finally
  307. {
  308. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync finally, remedicalCode:{remedicalCode}");
  309. }
  310. return new URMProcessResult();
  311. }
  312. /// <summary>
  313. /// 获取URMColorbar
  314. /// </summary>
  315. /// <param name="request"></param>
  316. /// <returns></returns>
  317. public async Task<URMColorbarResult> GetURMColorbarAsync(URMColorbarRequest request)
  318. {
  319. var result = new URMColorbarResult();
  320. result.LogoBase64 = _logoBase64;
  321. if (request.ProcessType == 0)
  322. {
  323. result.ColorbarBase64 = _urmColorbarBase64;
  324. }
  325. else if (request.ProcessType == 1)//URM后处理
  326. {
  327. if (request.UrmImageType == URMType.Angle.ToString("D"))
  328. {
  329. result.ColorbarBase64 = _angleColorbarBase64;
  330. }
  331. else
  332. {
  333. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  334. var remedicalCode = request.RemedicalCode;
  335. try
  336. {
  337. if (!string.IsNullOrWhiteSpace(remedicalCode))
  338. {
  339. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  340. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  341. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  342. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  343. {
  344. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync start, remedicalCode:{remedicalCode}");
  345. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  346. if (!Directory.Exists(currentFolder))
  347. {
  348. Directory.CreateDirectory(currentFolder);
  349. }
  350. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, "", remedicalCode);
  351. try
  352. {
  353. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  354. }
  355. catch
  356. {
  357. }
  358. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync DoUrmProcess start, remedicalCode:{remedicalCode}");
  359. var urmProcessRequest = ConvertToUrmRequest<URMProcessRequest, UrmProcessRequest>(request, remedical, currentFolder);
  360. urmProcessRequest.RemedicalCode = remedicalCode;
  361. urmProcessRequest.Token = request.Token;
  362. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  363. var base64String = URMAnalysisManager.CreateUrmColorbarImage(urmProcessRequest);
  364. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync DoUrmProcess end, remedicalCode:{remedicalCode}, base64String-Length:{base64String.Length}");
  365. result.ColorbarBase64 = base64String;
  366. }
  367. }
  368. }
  369. catch (Exception ex)
  370. {
  371. Logger.WriteLineWarn($"AIDiagnosisService URMProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  372. }
  373. finally
  374. {
  375. Logger.WriteLineInfo($"AIDiagnosisService URMProcessAsync finally, remedicalCode:{remedicalCode}");
  376. }
  377. }
  378. }
  379. else if (request.ProcessType == 2)//灌注图
  380. {
  381. result.ColorbarBase64 = _perfusionColorbarBase64;
  382. }
  383. return result;
  384. }
  385. private async Task DownloadUrmBinFiles(string currentFolder, List<ImgItem> imgList, string userCode, string remedicalCode)
  386. {
  387. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  388. foreach (var imgItem in imgList)
  389. {
  390. if (imgItem.ImgType != 0 && !string.IsNullOrWhiteSpace(imgItem.FileToken))
  391. {
  392. var fileName = Path.GetFileName(imgItem.FileToken);
  393. if (imgItem.ImgType == 10)
  394. {
  395. fileName = "srcDenArray.bin";
  396. }
  397. else if (imgItem.ImgType == 11)
  398. {
  399. fileName = "srcDirArray.bin";
  400. }
  401. else if (imgItem.ImgType == 12)
  402. {
  403. fileName = "srcVelArray.bin";
  404. }
  405. else if (imgItem.ImgType == 13)
  406. {
  407. fileName = "srcAngleArray.bin";
  408. }
  409. else if (imgItem.ImgType == 14)
  410. {
  411. fileName = "srcMaskArray.bin";
  412. }
  413. else if (imgItem.ImgType == 15)
  414. {
  415. fileName = "URMPoints.bin";
  416. }
  417. else if (imgItem.ImgType == 16)
  418. {
  419. fileName = "URMPointNums.bin";
  420. }
  421. var localFilePath = Path.Combine(currentFolder, fileName);
  422. if (!File.Exists(localFilePath))
  423. {
  424. await DownloadToLocalAsync(imgItem.FileToken, localFilePath, userCode, remedicalCode);
  425. }
  426. }
  427. }
  428. }
  429. /// <summary>
  430. /// URM视频后处理-预加载
  431. /// </summary>
  432. /// <param name="request">URM视频后处理请求实体</param>
  433. /// <returns>URM视频后处理结果</returns>
  434. /// <value></value>
  435. /// <errorCodes></errorCodes>
  436. public async Task<bool> LoadURMVideoProcessAsync(URMVideoProcessRequest request)
  437. {
  438. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  439. var remedicalCode = request.RemedicalCode;
  440. try
  441. {
  442. if (!string.IsNullOrWhiteSpace(remedicalCode))
  443. {
  444. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  445. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  446. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  447. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  448. {
  449. Logger.WriteLineInfo($"AIDiagnosisService LoadURMVideoProcessAsync start, remedicalCode:{remedicalCode}");
  450. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  451. if (!Directory.Exists(currentFolder))
  452. {
  453. Directory.CreateDirectory(currentFolder);
  454. }
  455. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, request.NotifyUserCode, remedicalCode);
  456. try
  457. {
  458. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  459. }
  460. catch { }
  461. var urmProcessRequest = ConvertToUrmRequest<URMVideoProcessRequest, DoUrmVideoProcessRequest>(request, remedical, currentFolder);
  462. urmProcessRequest.VideoFrame = request.VideoFrame;
  463. urmProcessRequest.URMVideoScaler = request.URMVideoScaler;
  464. urmProcessRequest.URMVideoParameter = request.URMVideoParameter;
  465. urmProcessRequest.URMVideoType = request.URMVideoType;
  466. var pointsPath = Path.Combine(currentFolder, "URMPoints.bin");
  467. var pointNumsPath = Path.Combine(currentFolder, "URMPointNums.bin");
  468. urmProcessRequest.PointsDataPath = File.Exists(pointsPath) ? pointsPath : string.Empty;
  469. urmProcessRequest.PointNumsDataPath = File.Exists(pointNumsPath) ? pointNumsPath : string.Empty;
  470. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  471. Logger.WriteLineInfo($"AIDiagnosisService LoadURMVideoProcessAsync InitVideoProcessor start, remedicalCode:{remedicalCode}");
  472. URMAnalysisManager.InitVideoProcessor(urmProcessRequest);
  473. Logger.WriteLineInfo($"AIDiagnosisService LoadURMVideoProcessAsync InitVideoProcessor end, remedicalCode:{remedicalCode}");
  474. return true;
  475. }
  476. }
  477. }
  478. catch (Exception ex)
  479. {
  480. Logger.WriteLineWarn($"AIDiagnosisService LoadURMVideoProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  481. }
  482. finally
  483. {
  484. Logger.WriteLineInfo($"AIDiagnosisService LoadURMVideoProcessAsync finally, remedicalCode:{remedicalCode}");
  485. }
  486. return false;
  487. }
  488. /// <summary>
  489. /// URM视频后处理
  490. /// </summary>
  491. /// <param name="request">URM视频后处理请求实体</param>
  492. /// <returns>URM视频后处理结果</returns>
  493. /// <value></value>
  494. /// <errorCodes></errorCodes>
  495. public async Task<URMVideoProcessResult> URMVideoProcessAsync(URMVideoProcessRequest request)
  496. {
  497. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  498. var remedicalCode = request.RemedicalCode;
  499. try
  500. {
  501. if (!string.IsNullOrWhiteSpace(remedicalCode))
  502. {
  503. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  504. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  505. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  506. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  507. {
  508. Logger.WriteLineInfo($"AIDiagnosisService URMVideoProcessAsync start, remedicalCode:{remedicalCode}");
  509. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  510. if (!Directory.Exists(currentFolder))
  511. {
  512. Directory.CreateDirectory(currentFolder);
  513. }
  514. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, request.NotifyUserCode, remedicalCode);
  515. try
  516. {
  517. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  518. }
  519. catch { }
  520. var urmProcessRequest = ConvertToUrmRequest<URMVideoProcessRequest, DoUrmVideoProcessRequest>(request, remedical, currentFolder);
  521. urmProcessRequest.VideoFrame = request.VideoFrame;
  522. urmProcessRequest.URMVideoScaler = request.URMVideoScaler;
  523. urmProcessRequest.URMVideoParameter = request.URMVideoParameter;
  524. urmProcessRequest.URMVideoType = request.URMVideoType;
  525. var pointsPath = Path.Combine(currentFolder, "URMPoints.bin");
  526. var pointNumsPath = Path.Combine(currentFolder, "URMPointNums.bin");
  527. urmProcessRequest.PointsDataPath = File.Exists(pointsPath) ? pointsPath : string.Empty;
  528. urmProcessRequest.PointNumsDataPath = File.Exists(pointNumsPath) ? pointNumsPath : string.Empty;
  529. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  530. // 预加载其它Process
  531. LoadVideoProcessInfos(urmProcessRequest);
  532. Logger.WriteLineInfo($"AIDiagnosisService URMVideoProcessAsync DoUrmVideoProcess start, remedicalCode:{remedicalCode}");
  533. Logger.WriteLineInfo($"urmProcessRequest:{JsonConvert.SerializeObject(urmProcessRequest)}");
  534. double urmMinVal = 0;
  535. double urmMaxVal = 0;
  536. var base64String = URMAnalysisManager.DoUrmVideoProcess(urmProcessRequest, ref urmMinVal, ref urmMaxVal);
  537. Logger.WriteLineInfo($"AIDiagnosisService URMVideoProcessAsync DoUrmVideoProcess end, remedicalCode:{remedicalCode}, base64String-Length:{base64String.Length}");
  538. return new URMVideoProcessResult
  539. {
  540. Base64String = base64String,
  541. UrmMinVal = urmMinVal,
  542. UrmMaxVal = urmMaxVal,
  543. };
  544. }
  545. }
  546. }
  547. catch (Exception ex)
  548. {
  549. Logger.WriteLineWarn($"AIDiagnosisService URMVideoProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  550. }
  551. finally
  552. {
  553. Logger.WriteLineInfo($"AIDiagnosisService URMVideoProcessAsync finally, remedicalCode:{remedicalCode}");
  554. }
  555. return new URMVideoProcessResult();
  556. }
  557. private void LoadVideoProcessInfos(DoUrmVideoProcessRequest videoProcessProcess)
  558. {
  559. Task.Run(() =>
  560. {
  561. try
  562. {
  563. var videoParameterInfos = new List<float> { 1, 2, 3 };
  564. var videoTypeInfos = new List<float> { 0, 1, 2 };
  565. var videoProcessProcessNew = JsonConvert.DeserializeObject<DoUrmVideoProcessRequest>(JsonConvert.SerializeObject(videoProcessProcess));
  566. foreach (var videoParameter in videoParameterInfos)
  567. {
  568. foreach (var videoType in videoTypeInfos)
  569. {
  570. if (videoParameter != videoProcessProcess.URMVideoParameter || videoType != videoProcessProcess.URMVideoType)
  571. {
  572. videoProcessProcessNew.URMVideoParameter = videoParameter;
  573. videoProcessProcessNew.URMVideoType = videoType;
  574. videoProcessProcessNew.GUID = videoProcessProcessNew.GetUniqueCode();
  575. URMAnalysisManager.InitVideoProcessor(videoProcessProcessNew);
  576. }
  577. }
  578. }
  579. }
  580. catch (Exception ex)
  581. {
  582. Logger.WriteLineWarn($"AIDiagnosisService LoadVideoProcessInfos error, remedicalCode:{videoProcessProcess.RemedicalCode}, ex:{ex}");
  583. }
  584. });
  585. }
  586. /// <summary>
  587. /// URM测量-预加载
  588. /// </summary>
  589. /// <param name="request">URM测量后处理测量请求实体</param>
  590. /// <returns>URM测量后处理结果</returns>
  591. /// <value></value>
  592. /// <errorCodes></errorCodes>
  593. public async Task<bool> LoadURMMeasureProcessAsync(URMMeasureProcessRequest request)
  594. {
  595. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  596. var remedicalCode = request.RemedicalCode;
  597. try
  598. {
  599. if (!string.IsNullOrWhiteSpace(remedicalCode))
  600. {
  601. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  602. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  603. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  604. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  605. {
  606. Logger.WriteLineInfo($"AIDiagnosisService LoadURMMeasureProcessAsync start, remedicalCode:{remedicalCode}");
  607. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  608. if (!Directory.Exists(currentFolder))
  609. {
  610. Directory.CreateDirectory(currentFolder);
  611. }
  612. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, "", remedicalCode);
  613. try
  614. {
  615. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  616. }
  617. catch { }
  618. var urmProcessRequest = ConvertToUrmRequest<URMMeasureProcessRequest, UrmMeasureProcessRequest>(request, remedical, currentFolder);
  619. urmProcessRequest.UrmMeasureType = (URMMeasureType)request.UrmMeasureType;
  620. if (request.SrcDPoints?.Any() ?? false)
  621. {
  622. urmProcessRequest.SrcDPoints = request.SrcDPoints?.Select(p => new DPoint { X = p.X, Y = p.Y })?.ToList() ?? new List<DPoint>();
  623. }
  624. else
  625. {
  626. urmProcessRequest.SrcDPoints = new List<DPoint>
  627. {
  628. new DPoint { X = 0, Y = 0 },
  629. new DPoint { X = 0, Y = 0 },
  630. };
  631. }
  632. urmProcessRequest.CMlength = request.CMlength;
  633. urmProcessRequest.Phywidth = request.Phywidth;
  634. urmProcessRequest.ROIType = (URMROIType)request.ROIType;
  635. urmProcessRequest.ShellWidth = request.ShellWidth;
  636. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  637. Logger.WriteLineInfo($"AIDiagnosisService LoadURMMeasureProcessAsync InitURMMeasureProcessor start, remedicalCode:{remedicalCode}, Guid:{urmProcessRequest.GUID}");
  638. double urmMinVal = 0;
  639. double urmMaxVal = 0;
  640. var output = URMAnalysisManager.MeasureProcess(remedicalCode, urmProcessRequest, out string perfusionImgBase64, ref urmMinVal, ref urmMaxVal);
  641. Logger.WriteLineInfo($"AIDiagnosisService LoadURMMeasureProcessAsync InitURMMeasureProcessor end, remedicalCode:{remedicalCode}");
  642. return true;
  643. }
  644. }
  645. }
  646. catch (Exception ex)
  647. {
  648. Logger.WriteLineWarn($"AIDiagnosisService LoadURMMeasureProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  649. }
  650. finally
  651. {
  652. Logger.WriteLineInfo($"AIDiagnosisService LoadURMMeasureProcessAsync finally, remedicalCode:{remedicalCode}");
  653. }
  654. return false;
  655. }
  656. /// <summary>
  657. /// URM测量
  658. /// </summary>
  659. /// <param name="request">URM测量后处理测量请求实体</param>
  660. /// <returns>URM测量后处理结果</returns>
  661. /// <value></value>
  662. /// <errorCodes></errorCodes>
  663. public async Task<URMMeasureProcessResult> URMMeasureProcessAsync(URMMeasureProcessRequest request)
  664. {
  665. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  666. var remedicalCode = request.RemedicalCode;
  667. try
  668. {
  669. if (!string.IsNullOrWhiteSpace(remedicalCode))
  670. {
  671. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  672. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  673. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  674. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  675. {
  676. Logger.WriteLineInfo($"AIDiagnosisService URMMeasureProcessAsync start, remedicalCode:{remedicalCode}");
  677. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  678. if (!Directory.Exists(currentFolder))
  679. {
  680. Directory.CreateDirectory(currentFolder);
  681. }
  682. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, "", remedicalCode);
  683. try
  684. {
  685. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  686. }
  687. catch { }
  688. var urmProcessRequest = ConvertToUrmRequest<URMMeasureProcessRequest, UrmMeasureProcessRequest>(request, remedical, currentFolder);
  689. urmProcessRequest.UrmMeasureType = (URMMeasureType)request.UrmMeasureType;
  690. urmProcessRequest.SrcDPoints = request.SrcDPoints?.Select(p => new DPoint { X = p.X, Y = p.Y })?.ToList() ?? new List<DPoint>();
  691. urmProcessRequest.CMlength = request.CMlength;
  692. urmProcessRequest.Phywidth = request.Phywidth;
  693. urmProcessRequest.ROIType = (URMROIType)request.ROIType;
  694. urmProcessRequest.ShellWidth = request.ShellWidth;
  695. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  696. Logger.WriteLineInfo($"AIDiagnosisService URMMeasureProcessAsync MeasureProcess start, remedicalCode:{remedicalCode}, Guid:{urmProcessRequest.GUID}");
  697. double urmMinVal = 0;
  698. double urmMaxVal = 0;
  699. var output = URMAnalysisManager.MeasureProcess(remedicalCode, urmProcessRequest, out string perfusionImgBase64, ref urmMinVal, ref urmMaxVal);
  700. Logger.WriteLineInfo($"AIDiagnosisService URMMeasureProcessAsync MeasureProcess end, remedicalCode:{remedicalCode}, ResultFlag: {output?.ResultFlag}");
  701. if (output != null)
  702. {
  703. var result = JsonConvert.DeserializeObject<URMMeasureProcessResult>(JsonConvert.SerializeObject(output));
  704. result.PerfusionImgBase64 = perfusionImgBase64;
  705. result.UrmMinVal = urmMinVal;
  706. result.UrmMaxVal = urmMaxVal;
  707. return result;
  708. }
  709. }
  710. }
  711. }
  712. catch (Exception ex)
  713. {
  714. Logger.WriteLineWarn($"AIDiagnosisService URMMeasureProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  715. }
  716. finally
  717. {
  718. Logger.WriteLineInfo($"AIDiagnosisService URMMeasureProcessAsync finally, remedicalCode:{remedicalCode}");
  719. }
  720. return new URMMeasureProcessResult();
  721. }
  722. /// <summary>
  723. /// URM生成后处理视频
  724. /// </summary>
  725. /// <param name="request">URM生成后处理视频请求实体</param>
  726. /// <returns>URM生成后处理视频结果</returns>
  727. /// <value></value>
  728. /// <errorCodes></errorCodes>
  729. public async Task<URMGenerateVideoResult> URMGenerateVideoAsync(URMGenerateVideoRequest request)
  730. {
  731. DeleteExpiredFolders(DateTime.Now.AddDays(-1));
  732. var remedicalCode = request.RemedicalCode;
  733. try
  734. {
  735. if (!string.IsNullOrWhiteSpace(remedicalCode))
  736. {
  737. var remedical = await _remedicalDBService.GetRemedicalByCodeAsync(remedicalCode, false);
  738. // 10-srcDenArray.bin,11-srcDirArray.bin,12-srcVelArray.bin,13-srcAngleArray.bin,14-srcMaskArray.bin,15-URMPoints.bin,16-URMPointNums.bin
  739. if (remedical != null && remedical.ImgList != null && remedical.ImgList.Any() && remedical.ImgList.Any(x => x.ImgType != 0)
  740. && remedical.UrmParameters != null && remedical.UrmParameters.Any())
  741. {
  742. Logger.WriteLineInfo($"AIDiagnosisService URMGenerateVideoAsync start, remedicalCode:{remedicalCode}");
  743. var currentFolder = Path.Combine(_urmTempFolder, remedicalCode);
  744. if (!Directory.Exists(currentFolder))
  745. {
  746. Directory.CreateDirectory(currentFolder);
  747. }
  748. await DownloadUrmBinFiles(currentFolder, remedical.ImgList, request.NotifyUserCode, remedicalCode);
  749. try
  750. {
  751. File.WriteAllText(Path.Combine(currentFolder, "readme.txt"), DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
  752. }
  753. catch { }
  754. var urmProcessRequest = ConvertToUrmRequest<URMVideoProcessRequest, DoUrmVideoProcessRequest>(request, remedical, currentFolder);
  755. urmProcessRequest.URMVideoScaler = request.URMVideoScaler;
  756. urmProcessRequest.URMVideoParameter = request.URMVideoParameter;
  757. urmProcessRequest.URMVideoType = request.URMVideoType;
  758. var pointsPath = Path.Combine(currentFolder, "URMPoints.bin");
  759. var pointNumsPath = Path.Combine(currentFolder, "URMPointNums.bin");
  760. urmProcessRequest.PointsDataPath = File.Exists(pointsPath) ? pointsPath : string.Empty;
  761. urmProcessRequest.PointNumsDataPath = File.Exists(pointNumsPath) ? pointNumsPath : string.Empty;
  762. if (!string.IsNullOrWhiteSpace(request.BackgroundImage))
  763. {
  764. var bgImgPath = Path.Combine(currentFolder, $"{Guid.NewGuid()}.png");
  765. var coverImageWidth = 0;
  766. var coverImageHeight = 0;
  767. byte[] bgImageBytes = Convert.FromBase64String(request.BackgroundImage);
  768. using (FileStream fs = new FileStream(bgImgPath, FileMode.Create))
  769. {
  770. fs.Write(bgImageBytes, 0, bgImageBytes.Length);
  771. }
  772. using (var image = Image.Load(bgImgPath))
  773. {
  774. coverImageWidth = image.Width;
  775. coverImageHeight = image.Height;
  776. }
  777. urmProcessRequest.Roix = (int)(coverImageWidth * request.RoiXPercent);
  778. urmProcessRequest.Roiy = (int)(coverImageHeight * request.RoiYPercent);
  779. urmProcessRequest.Roiwidth = (int)(coverImageWidth * request.RoiWPercent);
  780. urmProcessRequest.Roiheight = (int)(coverImageHeight * request.RoiHPercent);
  781. urmProcessRequest.ScreenWidth = coverImageWidth;
  782. urmProcessRequest.ScreenHeight = coverImageHeight;
  783. }
  784. urmProcessRequest.GUID = urmProcessRequest.GetUniqueCode();
  785. var imgList = MergeUrmImages(remedicalCode, currentFolder, request.BackgroundImage, urmProcessRequest, request);
  786. Logger.WriteLineInfo($"AIDiagnosisService URMGenerateVideoAsync DoUrmVideoProcess, remedicalCode:{remedicalCode}, imgCount:{imgList.Count}");
  787. if (imgList.Count >= 150)
  788. {
  789. var videoInfo = ImagesToMp4(remedicalCode, currentFolder, imgList);
  790. var coverImgUrl = string.Empty;
  791. var videoUrl = string.Empty;
  792. long videoSize = 0;
  793. await Task.Delay(1000 * 2);
  794. if (!string.IsNullOrWhiteSpace(videoInfo.Item1))
  795. {
  796. var fileName = Path.GetFileName(videoInfo.Item1);
  797. var fileInfo = await UploadFileWithSizeAsync(videoInfo.Item1, fileName);
  798. coverImgUrl = fileInfo.Item1;
  799. }
  800. if (!string.IsNullOrWhiteSpace(videoInfo.Item2))
  801. {
  802. var fileName = Path.GetFileName(videoInfo.Item2);
  803. var fileInfo = await UploadFileWithSizeAsync(videoInfo.Item2, fileName);
  804. videoUrl = fileInfo.Item1;
  805. videoSize = fileInfo.Item2;
  806. }
  807. var resultData = new URMGenerateVideoResult
  808. {
  809. VideoUrl = videoUrl,
  810. CoverImgUrl = coverImgUrl,
  811. VideoSize = videoSize,
  812. };
  813. Logger.WriteLineInfo($"AIDiagnosisService URMGenerateVideoAsync end, remedicalCode:{remedicalCode}, resultData:{JsonConvert.SerializeObject(resultData)}");
  814. return resultData;
  815. }
  816. }
  817. }
  818. }
  819. catch (Exception ex)
  820. {
  821. Logger.WriteLineWarn($"AIDiagnosisService URMVideoProcessAsync error, remedicalCode:{remedicalCode}, ex:{ex}");
  822. }
  823. finally
  824. {
  825. Logger.WriteLineInfo($"AIDiagnosisService URMVideoProcessAsync finally, remedicalCode:{remedicalCode}");
  826. }
  827. return new URMGenerateVideoResult();
  828. }
  829. private List<string> MergeUrmImages(string remedicalCode, string currentFolder, string backgroundImageBase64, DoUrmVideoProcessRequest urmProcessRequest, URMGenerateVideoRequest request)
  830. {
  831. var leftLogoX = (int)(request.LeftImgTopLeftCornerXPercent * urmProcessRequest.ScreenWidth) - 30;
  832. var leftLogoY = (int)(request.LeftImgTopLeftCornerYPercent * urmProcessRequest.ScreenHeight);
  833. var rightLogoX = (int)(request.RightImgTopLeftCornerXPercent * urmProcessRequest.ScreenWidth) - 30;
  834. var rightLogoY = (int)(request.RightImgTopLeftCornerYPercent * urmProcessRequest.ScreenHeight);
  835. var colorBarX = (int)(request.ColorBarXPercent * urmProcessRequest.ScreenWidth);
  836. var colorBarY = (int)(request.ColorBarYPercent * urmProcessRequest.ScreenHeight);
  837. // var leftLogoX = (int)(0.15 * urmProcessRequest.ScreenWidth) - 30;
  838. // var leftLogoY = (int)(0.15 * urmProcessRequest.ScreenHeight) - 20;
  839. // var rightLogoX = (int)(0.55 * urmProcessRequest.ScreenWidth) - 30;
  840. // var rightLogoY = (int)(0.15 * urmProcessRequest.ScreenHeight) - 20;
  841. // var colorBarX = (int)(0.95 * urmProcessRequest.ScreenWidth);
  842. // var colorBarY = (int)(0.15 * urmProcessRequest.ScreenHeight);
  843. //colorbar的数值和单位
  844. var unit = "mm/s";
  845. var top = "36.0";
  846. var bottom = "-36.0";
  847. var imgList = new List<string>();
  848. for (var i = 0; i < 200; i++)
  849. {
  850. try
  851. {
  852. urmProcessRequest.VideoFrame = i;
  853. double urmMinVal = 0;
  854. double urmMaxVal = 0;
  855. var base64String = URMAnalysisManager.DoUrmVideoProcess(urmProcessRequest, ref urmMinVal, ref urmMaxVal);
  856. if (!string.IsNullOrWhiteSpace(base64String))
  857. {
  858. if (string.IsNullOrWhiteSpace(backgroundImageBase64))
  859. {
  860. base64String = AddLogAndColorBar(base64String);
  861. imgList.Add(base64String);
  862. }
  863. else
  864. {
  865. byte[] bgImageBytes = Convert.FromBase64String(backgroundImageBase64);
  866. byte[] currImageBytes = Convert.FromBase64String(base64String);
  867. byte[] logoImageBytes = Convert.FromBase64String(_logoBase64);
  868. byte[] colorbarImageBytes = Convert.FromBase64String(_urmColorbarBase64);
  869. using (MemoryStream streamBg = new MemoryStream(bgImageBytes))
  870. using (SKBitmap bitmapBg = SKBitmap.Decode(streamBg))
  871. using (MemoryStream stream2 = new MemoryStream(currImageBytes))
  872. using (SKBitmap bitmap2 = SKBitmap.Decode(stream2))
  873. using (MemoryStream streamLogo = new MemoryStream(logoImageBytes))
  874. using (SKBitmap bitmapLogo = SKBitmap.Decode(streamLogo))
  875. using (MemoryStream streamColorbar = new MemoryStream(colorbarImageBytes))
  876. using (SKBitmap bitmapColorbar = SKBitmap.Decode(streamColorbar))
  877. {
  878. // 设置额外图片的目标大小
  879. int targetWidth = 30;
  880. int targetHeight = 20;
  881. var bitmapLogoSmall = bitmapLogo.Resize(new SKImageInfo(targetWidth, targetHeight), SKFilterQuality.High);
  882. using (var canvas = new SKCanvas(bitmapBg))
  883. {
  884. canvas.DrawBitmap(bitmap2, new SKPoint(0, 0));
  885. canvas.DrawBitmap(bitmapLogoSmall, new SKPoint(leftLogoX, leftLogoY));
  886. canvas.DrawBitmap(bitmapLogoSmall, new SKPoint(rightLogoX, rightLogoY));
  887. canvas.DrawBitmap(bitmapColorbar, new SKPoint(colorBarX, colorBarY + 10));
  888. // 添加上方的黄色文字
  889. using (var paint = new SKPaint())
  890. {
  891. paint.Color = SKColors.Yellow;
  892. paint.TextSize = 14;
  893. canvas.DrawText(top, colorBarX - 8, colorBarY, paint);
  894. }
  895. // 添加下方的黄色文字
  896. using (var paint = new SKPaint())
  897. {
  898. paint.Color = SKColors.Yellow;
  899. paint.TextSize = 14;
  900. canvas.DrawText(bottom, colorBarX - 11, colorBarY + 15 + bitmapColorbar.Height + 25, paint);
  901. canvas.DrawText(unit, colorBarX - 11, colorBarY + 15 + bitmapColorbar.Height + 42, paint);
  902. }
  903. canvas.ResetMatrix(); // 重置变换矩
  904. }
  905. if (bitmapBg.Width % 2 == 0 && bitmapBg.Height % 2 == 0)
  906. {
  907. using (MemoryStream ms = new MemoryStream())
  908. {
  909. bitmapBg.Encode(SKEncodedImageFormat.Png, 100).SaveTo(ms);
  910. byte[] imageBytes = ms.ToArray();
  911. var newPng = Convert.ToBase64String(imageBytes);
  912. if (!string.IsNullOrWhiteSpace(newPng))
  913. {
  914. imgList.Add(newPng);
  915. }
  916. }
  917. }
  918. else
  919. {
  920. int newWidth = bitmapBg.Width % 2 == 0 ? bitmapBg.Width : bitmapBg.Width + 1;
  921. int newHeight = bitmapBg.Height % 2 == 0 ? bitmapBg.Height : bitmapBg.Height + 1;
  922. var bitmapBgSmall = bitmapBg.Resize(new SKImageInfo(newWidth, newHeight), SKFilterQuality.High);
  923. // 保存处理后的图像为PNG格式并转换为base64字符串
  924. using (MemoryStream ms = new MemoryStream())
  925. {
  926. bitmapBgSmall.Encode(SKEncodedImageFormat.Png, 100).SaveTo(ms);
  927. byte[] imageBytes = ms.ToArray();
  928. var newPng = Convert.ToBase64String(imageBytes);
  929. if (!string.IsNullOrWhiteSpace(newPng))
  930. {
  931. imgList.Add(newPng);
  932. }
  933. }
  934. }
  935. }
  936. }
  937. }
  938. }
  939. catch (Exception ex)
  940. {
  941. Logger.WriteLineInfo($"AIDiagnosisService URMGenerateVideoAsync DoUrmVideoProcess fail, remedicalCode:{remedicalCode}, frameRate:{i}, ex:{ex}");
  942. }
  943. }
  944. return imgList;
  945. }
  946. private string AddLogAndColorBar(string base64String)
  947. {
  948. try
  949. {
  950. //银杏叶logo
  951. var logoBase64 = "iVBORw0KGgoAAAANSUhEUgAAAGQAAABTCAYAAABpnaJBAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAAadEVYdFNvZnR3YXJlAFBhaW50Lk5FVCB2My41LjEwMPRyoQAABn9JREFUeF7tnXtsU1UYwEk0JhoTE2M0GBMTYkxM0PgH+8tEYQKbbDym2YCNYQJOgQxFdOEVpxgR1Cl06x5l6TY2NscY27pABgzW59qyB+vK3iQGEk0M+IfBRxSJ9TvzK9luv66P++i53fklvz92ex7fOd/uPee2690CgSBqKuyrSmo9uYEy6/LAsZ7XQiy3pweqHKsDtZ6N7OeSE95NJVhVoDQm59qQBERjqfX1gNG2sgKbESgBNdGxanKuC9R781/EJgXxYHKuqaYmN14NPcsC1a6sF7B5QbTAOmGBy8yf1KTKla0x2I1ASo17/S6YpO5q15uB4651gTLbCnISlRY2B0swhKi4NPH1kovjh7vRD/FwclFqTX2fmiwtbOzb6sMwwgIT/yxc4nxUfSa7/MFZ7MLi+ifc1lUrMYywGKM8W+EXi22338Jq+qTeu/k2NTgttU4dW4ThhNA8sO06VWcu230fj2F1/oG1IguCvsEssyX2zAh6sm8LudvqGj34OFU+Gi3+fbewGX6pdW/4lQqeA8mEwPEnJOViEi5hqdgUH/RMfvt8U1/BHQjujgGur9KAOTJMQpZSZWMSdmWvYHOJA3Yd/1DBcWxIQkzOtY8Q5WLW3Jt9D5vUngtjh8mgdGBIQnomj1Ll4rJtaHdM9zqKUOvJ+4MKRieGJESJy1XQTv9+bd8RMNrSfqEC0ZFEQshycYvNqk9j3zs/UgHoyRr3xuRISGPf1ueozvVmh2/PrIScGdpNlpMjNq0u0NEP0o71aPf4kVkJocrIFZtWjzbfRy9THetRHNJ9qDJyZO9gY9PqAR31SzvWqzik+1Bl5Ph9/3vqJ6TCsYrsXG+yt85xSNO0+4oyqXJyrPfma3KGkJ3rTfZBGA5pmkpH5u9UObli8+pBdapHpdd3uCH8iyonV3Nv9gHsQh2oTvWo9HN1qoxSGqypn3QMFz2MXSlHy2ChnepQr+Kw2LhuUa8rKVuz4Gwpwi7lcX7si+wT3vzrrFGqM70K4ymtcGQUK/n+VSThplr+umJyrj1DNS6Mz1Jr6l2c2vjo9O8XCVFYA5yVlydKPsUpjh2qUaFcl/6G0xsbdZ48cYaoZLktbRynOTKVjox3y6zLb1INCZUTp3tuoGCBtKJQHWGRH8BpD49Wf2MrnP7+yh2c9vBQFYXqidMeHqqSUD1x2sNDVRKqI/tIA6c9PFRFoWpGXtTZt1mJikJ1jJwQQ8+yMqKiUCVbhz7oxqkPD1VRqJ7s/S2cehqLf684SxJgtSvrIUwBjcm55m+qolAda9wbIu+6Gvu2noR1RZXPnYWhnhrcbsKpnxtYfNqgwpS0AaGy1ns3Rz5LpLQMFtqg8rC0MaF8jba02BMyk0sT33ihIS9c1oYS/XXnZBGnVjlaBndaoWFrlXM12aFwbnEa1cM6dSy9zpN7DjqbttKRQQYi/F+ctsTQOby/tdye3mruzb6dbH9uFI8RbxK1ptaT26Dl30vxptmdM4VTwQ8W/94j7DeFCngeGN19iNbAmnOICHY+yGdCGEbbyrtEwEmtybnmCg6fP7pGD+6jgk52cfh8QgWc7MKO8ygOnz+ogOeB/CZknt5E8puQ7vEjVMDJLr8JuTz5HXsiHRV00lrjzuE3IQwq6GS10pHJ9y6LQQUeq+wJosddWTBgvtckuA/h98YwCBV4ONmjBZv6CyrKbWkp58cOpWATJGW2FSntviJVnqIdj+beHP7PjrPXiq9RwUttHth+uuHK24uxWswYepYtbriyhWxbCyvsq9gXQ5/BcPildWgXOYCgVY7VF+o8uU9icdm0DBYuOn11J9mXyj6FIfBNuM9I2P8GMbtzFmIxxTk3UrzQaEtbR/WttM3926zYLf9QA4CFL2Dx730Ui6hKtSvrQXNv9iYqDiWs8+S5sSt9IB0A7JYm8CVNOTfy2QMdw3t2SOOR46mBHVexeX1wYexL6ZN6buJLCcdoW3lPEltMYjP6Yub6AdvZf/EwV3QMFxnY987BqB4mDfdBN7CqvoDr9qxH0eJh7oHNgKXcns4eajNL9qAbLKI/6r35T7MkBO0a/Twh64YAgST8FEwGe6sDDwsSQb1386xH0eJhQSJoHtj+0sxkXBz/yosvCRIBJGEymIyovjIsUI86z6aRYDKYTf0Fj+FLAq2BhfvVmcno9B84iy8JEgXs3X9mySi3vyEuVbxQ415/C3ZZIf9KQiAQCKQsWPAfVXjcqZiVuhgAAAAASUVORK5CYII=";
  952. //colorbar
  953. var colorbarbase64 = "iVBORw0KGgoAAAANSUhEUgAAAAoAAACACAIAAAC9e29UAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsMAAA7DAcdvqGQAAAH/SURBVFhHpZchSJwBGIa/9z8GQ4tFGFiuDAQZCCLI0pWBmCyCmK4MjMZFm3FJhJVLY2AxiWC5NAYWkwxWrpgsK7qwhc8vvOE///feC3v4wId7uONHXg5F5iRm0/DnDOrdP6mKyj+oispXVEXlb1RF5TOqovIJVVH5E1VR+ZCqqLxPVVTepioqb1EVlVepispvqIrKr6kK5F+aBPmbJkHe0yTIXzQJ8pYmQX6nSZDXNAnygiZBfqVJkF9okiaewlwTf8Lc/70b+ZFPIUEe0CTIXZoE+YEmQb6nSZDrNAnyLU2CXKFJkEs0CfIVTQI784CdecDOPGBnHrAzD9iZB+zMA3bmATvzgJ15NJ1xTl3TGefU9epb7d/s6210Xmpf713npfb16jvxxUvtg515wM48YGcesDMP2JkH7MwDdubzQMQiVVF5maqo3KcqKq9RFZU3qYrKA6qi8g5VUXmPqqg8pCrq75YFc5Xrtzbz5ueXH9i+erRTPoai8oiqqHxOVVS+pCoqj6mKyjdUReU7qqLyhKqo/EBVVH6kKionVYFY9HnZ577Paz5v+jzwecfnPZ+HLjed9U1d09nu1M3NnQ9sH+LUP/nI53OfL30e+3zj853PE58ffH70OW1e8rnv87rPA593fR76fOTzsc+ffR75fOHz2Odbnyc2z/kX2eaIZwFK+NjQuHI3AAAAAElFTkSuQmCC";
  954. //colorbar的数值和单位
  955. var unit = "mm/s";
  956. var top = "36.0";
  957. var bottom = "-36.0";
  958. byte[] bytes1 = Convert.FromBase64String(base64String);
  959. byte[] bytes2 = Convert.FromBase64String(colorbarbase64);
  960. byte[] bytesExtra = Convert.FromBase64String(logoBase64);
  961. using (MemoryStream stream1 = new MemoryStream(bytes1))
  962. using (SKBitmap bitmap1 = SKBitmap.Decode(stream1))
  963. using (MemoryStream stream2 = new MemoryStream(bytes2))
  964. using (SKBitmap bitmap2 = SKBitmap.Decode(stream2))
  965. using (MemoryStream streamExtra = new MemoryStream(bytesExtra))
  966. using (SKBitmap originalBitmapExtra = SKBitmap.Decode(streamExtra))
  967. {
  968. // 设置额外图片的目标大小
  969. int targetWidth = 30;
  970. int targetHeight = 20;
  971. SKBitmap bitmapExtra = new SKBitmap(targetWidth, targetHeight);
  972. using (SKCanvas canvasExtra = new SKCanvas(bitmapExtra))
  973. {
  974. // 缩放额外图片到目标大小
  975. canvasExtra.DrawBitmap(originalBitmapExtra, new SKRect(0, 0, targetWidth, targetHeight));
  976. }
  977. int spacing = 20; // 设置间距
  978. int downShift = 35; // 往下移动的距离
  979. int width = bitmap1.Width + bitmap2.Width + spacing + 100;
  980. int height = Math.Max(bitmap1.Height, bitmap2.Height);
  981. using (SKBitmap resultBitmap = new SKBitmap(width, height))
  982. {
  983. using (SKCanvas canvas = new SKCanvas(resultBitmap))
  984. {
  985. //logo
  986. canvas.DrawBitmap(bitmapExtra, 0, 0);
  987. //原图
  988. canvas.DrawBitmap(bitmap1, bitmapExtra.Width, 0);
  989. //colorbar
  990. canvas.DrawBitmap(bitmap2, bitmapExtra.Width + bitmap1.Width + spacing, downShift);
  991. // 添加上方的黄色文字
  992. using (var paint = new SKPaint())
  993. {
  994. paint.Color = SKColors.Yellow;
  995. paint.TextSize = 18;
  996. canvas.DrawText(top, bitmapExtra.Width + bitmap1.Width + spacing - 8, downShift - 5, paint);
  997. }
  998. // 添加下方的黄色文字
  999. using (var paint = new SKPaint())
  1000. {
  1001. paint.Color = SKColors.Yellow;
  1002. paint.TextSize = 18;
  1003. canvas.DrawText(bottom, bitmapExtra.Width + bitmap1.Width + spacing - 9, downShift + bitmap2.Height + 15, paint);
  1004. canvas.DrawText(unit, bitmapExtra.Width + bitmap1.Width + spacing - 9, downShift + bitmap2.Height + 33, paint);
  1005. }
  1006. }
  1007. if (resultBitmap.Width % 2 == 0 && resultBitmap.Height % 2 == 0)
  1008. {
  1009. // 将拼接后的图片转换为 base64 编码字符串
  1010. using (SKImage image = SKImage.FromBitmap(resultBitmap))
  1011. using (MemoryStream outputStream = new MemoryStream())
  1012. {
  1013. image.Encode(SKEncodedImageFormat.Png, 100).SaveTo(outputStream);
  1014. byte[] resultBytes = outputStream.ToArray();
  1015. string base64ResultImage = Convert.ToBase64String(resultBytes);
  1016. return base64ResultImage;
  1017. }
  1018. }
  1019. else
  1020. {
  1021. int newWidth = resultBitmap.Width % 2 == 0 ? resultBitmap.Width : resultBitmap.Width - 1;
  1022. int newHeight = resultBitmap.Height % 2 == 0 ? resultBitmap.Height : resultBitmap.Height - 1;
  1023. var resultBitmapSmall = resultBitmap.Resize(new SKImageInfo(newWidth, newHeight), SKFilterQuality.High);
  1024. // 将拼接后的图片转换为 base64 编码字符串
  1025. using (SKImage image = SKImage.FromBitmap(resultBitmapSmall))
  1026. using (MemoryStream outputStream = new MemoryStream())
  1027. {
  1028. image.Encode(SKEncodedImageFormat.Png, 100).SaveTo(outputStream);
  1029. byte[] resultBytes = outputStream.ToArray();
  1030. string base64ResultImage = Convert.ToBase64String(resultBytes);
  1031. return base64ResultImage;
  1032. }
  1033. }
  1034. }
  1035. }
  1036. }
  1037. catch (Exception ex)
  1038. {
  1039. Logger.WriteLineError($"AddLogAndColorBar error:{ex}");
  1040. return base64String;
  1041. }
  1042. }
  1043. private Tuple<string, string> ImagesToMp4(string remedicalCode, string currentFolder, List<string> imgList)
  1044. {
  1045. try
  1046. {
  1047. var mp4Path = Path.Combine(currentFolder, $"{Guid.NewGuid()}.mp4");
  1048. var firstFrame = imgList.FirstOrDefault();
  1049. var width = 0;
  1050. var height = 0;
  1051. var coverImgPath = Path.Combine(currentFolder, $"{Guid.NewGuid()}.png");
  1052. byte[] coverImageBytes = Convert.FromBase64String(firstFrame);
  1053. using (FileStream fs = new FileStream(coverImgPath, FileMode.Create))
  1054. {
  1055. fs.Write(coverImageBytes, 0, coverImageBytes.Length);
  1056. }
  1057. using (var image = Image.Load(coverImgPath))
  1058. {
  1059. width = image.Width;
  1060. height = image.Height;
  1061. }
  1062. var frameRate = 30;
  1063. var setting = new FFmpegSettings();
  1064. var writeArgs = new FFmpegVideoWriterArgs(mp4Path, width, height)
  1065. {
  1066. FrameRate = frameRate,
  1067. VideoCodec = FFmpegVideoCodec.X264
  1068. };
  1069. using (var videoWriter = new FFmpegVideoWriter(writeArgs, setting, null))
  1070. {
  1071. foreach (var base64String in imgList)
  1072. {
  1073. byte[] imageBytes = Convert.FromBase64String(base64String);
  1074. using (var stream = new MemoryStream(imageBytes))
  1075. {
  1076. using (SKBitmap bitmap = SKBitmap.Decode(stream))
  1077. {
  1078. if (bitmap != null)
  1079. {
  1080. try
  1081. {
  1082. if (bitmap.Bytes != null && bitmap.Bytes.Length > 0 && bitmap.Width > 0 && bitmap.Height > 0)
  1083. {
  1084. var frame = new BitmapFrame(bitmap.Width, bitmap.Height, bitmap.Bytes);
  1085. videoWriter.WriteFrame(frame);
  1086. }
  1087. }
  1088. catch (Exception exception)
  1089. {
  1090. Logger.WriteLineWarn($"AIDiagnosisService ImagesToMP4 WriteFrame ex:{exception}");
  1091. }
  1092. }
  1093. }
  1094. }
  1095. }
  1096. }
  1097. return new Tuple<string, string>(coverImgPath, mp4Path);
  1098. }
  1099. catch (Exception ex)
  1100. {
  1101. Logger.WriteLineWarn($"AIDiagnosisService ImagesToMP4 ex:{ex}");
  1102. }
  1103. return new Tuple<string, string>("", "");
  1104. }
  1105. private URMAnalysisV2Result DoURMAnalysisV2(string remedicalCode, string origialFile, string converFile, string outputFolder, Dictionary<string, string> urmParamers, string userCode)
  1106. {
  1107. try
  1108. {
  1109. var arguments = new List<string>();
  1110. arguments.Add($"{origialFile}");
  1111. arguments.Add($"{GetValue(urmParamers, "familyName")}");
  1112. arguments.Add($"{GetValue(urmParamers, "typeInfo")}");
  1113. arguments.Add($"{GetValue(urmParamers, "nativeId")}");
  1114. arguments.Add($"{GetValue(urmParamers, "VecLens")}");
  1115. arguments.Add($"{GetValue(urmParamers, "Mlas")}");
  1116. arguments.Add($"{GetValue(urmParamers, "FramesGot")}");
  1117. arguments.Add($"{GetValue(urmParamers, "CenterFrequencyMhz")}");
  1118. arguments.Add($"{GetValue(urmParamers, "SupersonicSpeed")}");
  1119. arguments.Add($"{GetValue(urmParamers, "FrequencyMin")}");
  1120. arguments.Add($"{GetValue(urmParamers, "FrameRateDisplay")}");
  1121. arguments.Add($"{GetValue(urmParamers, "Depth")}");
  1122. arguments.Add($"{GetValue(urmParamers, "X0")}");
  1123. arguments.Add($"{GetValue(urmParamers, "Z0")}");
  1124. arguments.Add($"{GetValue(urmParamers, "ProbeType")}");
  1125. arguments.Add($"{GetValue(urmParamers, "ScaleOfPixel_x")}");
  1126. arguments.Add($"{GetValue(urmParamers, "ScaleOfPixel_y")}");
  1127. arguments.Add($"{GetValue(urmParamers, "section")}");
  1128. arguments.Add($"{GetValue(urmParamers, "MOCOYN")}");
  1129. arguments.Add($"{GetValue(urmParamers, "MidProc_DeciFactor")}");
  1130. arguments.Add($"{GetValue(urmParamers, "VectorStartForMid")}");
  1131. arguments.Add($"{GetValue(urmParamers, "isliner")}");
  1132. arguments.Add($"{GetValue(urmParamers, "startX")}");
  1133. arguments.Add($"{GetValue(urmParamers, "startY")}");
  1134. arguments.Add($"{GetValue(urmParamers, "width")}");
  1135. arguments.Add($"{GetValue(urmParamers, "height")}");
  1136. arguments.Add($"{GetValue(urmParamers, "CustomizedStartFrame")}");
  1137. arguments.Add($"{GetValue(urmParamers, "CustomizedEndFrame")}");
  1138. arguments.Add($"{GetValue(urmParamers, "RoiXPercent")}");
  1139. arguments.Add($"{GetValue(urmParamers, "RoiYPercent")}");
  1140. arguments.Add($"{GetValue(urmParamers, "RoiWPercent")}");
  1141. arguments.Add($"{GetValue(urmParamers, "RoiHPercent")}");
  1142. Logger.WriteLineInfo($"AIDiagnosisService DoURMAnalysisV2 arguments:{string.Join(";", arguments)}");
  1143. return URMAnalysisManager.DoURMAnalysis(remedicalCode, arguments, outputFolder, converFile, userCode);
  1144. }
  1145. catch (Exception ex)
  1146. {
  1147. Logger.WriteLineWarn($"AIDiagnosisService DoURMAnalysisV2 error, remedicalCode:{remedicalCode}, ex:{ex}");
  1148. }
  1149. return default;
  1150. }
  1151. private string GetValue(Dictionary<string, string> urmParamers, string key)
  1152. {
  1153. foreach (var k in urmParamers.Keys)
  1154. {
  1155. if (k.ToLower() == key.ToLower())
  1156. {
  1157. var value = urmParamers[k];
  1158. return string.IsNullOrWhiteSpace(value) ? "" : value;
  1159. }
  1160. }
  1161. return "";
  1162. }
  1163. private async Task<Tuple<string, string, int>> SaveCoverImageInfo(RemedicalInfoDTO remedical, int frameIndex, string currentFolder, string userCode)
  1164. {
  1165. var width = 0;
  1166. var height = 0;
  1167. var coverImageFile = Path.Combine(currentFolder, $"{Guid.NewGuid():N}.png");
  1168. var coverVidFile = Path.Combine(currentFolder, $"{Guid.NewGuid():N}.vid");
  1169. var vidImageCount = 0;
  1170. try
  1171. {
  1172. var vidImageUrl = remedical.TerminalImages.OriginImageUrl;
  1173. var vidImageName = Path.GetFileName(vidImageUrl);
  1174. var vidImageFile = Path.Combine(currentFolder, vidImageName);
  1175. if (!File.Exists(vidImageFile))
  1176. {
  1177. await DownloadToLocalAsync(vidImageUrl, vidImageFile, userCode, remedical.RemedicalCode);
  1178. await Task.Delay(1000 * 2);
  1179. }
  1180. using (var imageData = new VinnoImageData(vidImageFile, OperationMode.Open))
  1181. {
  1182. vidImageCount = imageData.ImageCount;
  1183. if (imageData.ImageCount <= frameIndex)
  1184. {
  1185. frameIndex = 0;
  1186. }
  1187. var frameImage = imageData.GetImage(frameIndex);
  1188. var isCbiImage = frameImage?.Visuals?.SelectMany(x => x.Modes)?.Any(x => x.Name?.ToUpper() == "URMCBI") ?? false;
  1189. if (isCbiImage)
  1190. {
  1191. using (var image = Image.Load(frameImage.ImageData))
  1192. {
  1193. int imgWidth = image.Width / 2; // 获取图片宽度的一半
  1194. // 将图像左右等分
  1195. using (Image leftImage = image.Clone(x => x.Crop(imgWidth, image.Height)))
  1196. {
  1197. // 复制左边的部分并粘贴到右边
  1198. image.Mutate(x => x.DrawImage(leftImage, new Point(imgWidth, 0), 1f));
  1199. }
  1200. image.Save(coverImageFile); // 保存生成的新图片
  1201. width = image.Width;
  1202. height = image.Height;
  1203. if (File.Exists(coverImageFile))
  1204. {
  1205. var imageBytes = File.ReadAllBytes(coverImageFile);
  1206. var vinnoImageTemp = new VinnoImage(0, width, height, imageBytes);
  1207. vinnoImageTemp.Visuals = frameImage.Visuals;
  1208. var vinnoImageData = new VinnoImageData(coverVidFile, OperationMode.Create);
  1209. vinnoImageData.AddImage(vinnoImageTemp);
  1210. vinnoImageData.AddProbe(imageData.Probe);
  1211. vinnoImageData.AddExtendedData(imageData.ExtendedData);
  1212. vinnoImageData.Dispose();
  1213. }
  1214. }
  1215. }
  1216. else
  1217. {
  1218. using (var image = Image.Load(frameImage.ImageData))
  1219. {
  1220. image.Save(coverImageFile); // 保存生成的新图片
  1221. }
  1222. var vinnoImageTemp = frameImage;
  1223. vinnoImageTemp.Visuals = frameImage.Visuals;
  1224. var vinnoImageData = new VinnoImageData(coverVidFile, OperationMode.Create);
  1225. vinnoImageData.AddImage(vinnoImageTemp);
  1226. vinnoImageData.AddProbe(imageData.Probe);
  1227. vinnoImageData.AddExtendedData(imageData.ExtendedData);
  1228. vinnoImageData.Dispose();
  1229. }
  1230. }
  1231. }
  1232. catch (Exception ex)
  1233. {
  1234. Logger.WriteLineWarn($"AIDiagnosisService SaveCoverImageInfo error, remedicalCode:{remedical?.RemedicalCode}, ex:{ex}");
  1235. }
  1236. return new Tuple<string, string, int>(coverVidFile, coverImageFile, vidImageCount);
  1237. }
  1238. private async Task InitUrmVidDetails(URMAnalysisV2Result resultData, string coverVidFile, string converFile)
  1239. {
  1240. if (File.Exists(coverVidFile))
  1241. {
  1242. var coverVid = new ImgItem
  1243. {
  1244. ImgType = 5,
  1245. };
  1246. var fileName = Path.GetFileName(coverVidFile);
  1247. var fileInfo = await UploadFileWithSizeAsync(coverVidFile, fileName);
  1248. coverVid.FileToken = fileInfo.Item1;
  1249. coverVid.FileSize = fileInfo.Item2;
  1250. if (File.Exists(converFile))
  1251. {
  1252. var fileName2 = Path.GetFileName(converFile);
  1253. var fileInfo2 = await UploadFileWithSizeAsync(converFile, fileName2);
  1254. coverVid.CoverImgUrl = fileInfo2.Item1;
  1255. coverVid.PreviewFileUrl = fileInfo2.Item1;
  1256. }
  1257. resultData.URMAnalysisDetails.Add(coverVid);
  1258. }
  1259. }
  1260. private async Task InitURMAnalysisDetails(URMAnalysisV2Result resultData, string originalUrl, string currentFolder, ImgItem originalRemedicalInfo, string converImagePath)
  1261. {
  1262. var orginal = new ImgItem
  1263. {
  1264. ImgType = 0,
  1265. FileToken = originalUrl,
  1266. FileSize = originalRemedicalInfo.FileSize,
  1267. CoverImgUrl = originalRemedicalInfo.CoverImgUrl,
  1268. PreviewFileUrl = originalRemedicalInfo.PreviewFileUrl,
  1269. };
  1270. if (File.Exists(converImagePath))
  1271. {
  1272. var fileName = Path.GetFileName(converImagePath);
  1273. var fileInfo = await UploadFileWithSizeAsync(converImagePath, fileName);
  1274. orginal.CoverImgUrl = fileInfo.Item1;
  1275. orginal.PreviewFileUrl = fileInfo.Item1;
  1276. }
  1277. resultData.URMAnalysisDetails.Add(orginal);
  1278. var files = Directory.GetFiles(currentFolder);
  1279. foreach (var file in files)
  1280. {
  1281. var fileName = Path.GetFileName(file);
  1282. if (fileName.Contains(".bin"))
  1283. {
  1284. var imgType = 0;
  1285. if (fileName.Contains("srcDenArray.bin"))
  1286. {
  1287. imgType = 10;
  1288. }
  1289. else if (fileName.Contains("srcDirArray.bin"))
  1290. {
  1291. imgType = 11;
  1292. }
  1293. else if (fileName.Contains("srcVelArray.bin"))
  1294. {
  1295. imgType = 12;
  1296. }
  1297. else if (fileName.Contains("srcAngleArray.bin"))
  1298. {
  1299. imgType = 13;
  1300. }
  1301. else if (fileName.Contains("srcMaskArray.bin"))
  1302. {
  1303. imgType = 14;
  1304. }
  1305. else if (fileName.Contains("URMPoints.bin"))
  1306. {
  1307. imgType = 15;
  1308. }
  1309. else if (fileName.Contains("URMPointNums.bin"))
  1310. {
  1311. imgType = 16;
  1312. }
  1313. else
  1314. {
  1315. continue;
  1316. }
  1317. var fileInfo = await UploadFileWithSizeAsync(file, fileName);
  1318. resultData.URMAnalysisDetails.Add(new ImgItem
  1319. {
  1320. ImgType = imgType,
  1321. FileToken = fileInfo.Item1,
  1322. FileSize = fileInfo.Item2,
  1323. });
  1324. }
  1325. }
  1326. }
  1327. private async Task<bool> DownloadToLocalAsync(string fileUrl, string localFile, string userCode, string remedicalCode)
  1328. {
  1329. try
  1330. {
  1331. if (fileUrl.Contains("FlyinsonoStorage"))
  1332. {
  1333. // 自建存储
  1334. var infos = fileUrl.Split("FlyinsonoStorage");
  1335. var sourceFilePath = Path.Combine(_storageDirectory, infos[1].Trim('/'));
  1336. if (File.Exists(sourceFilePath))
  1337. {
  1338. File.Copy(sourceFilePath, localFile);
  1339. return true;
  1340. }
  1341. }
  1342. long fileSize = 0;
  1343. using (var request = new HttpRequestMessage())
  1344. {
  1345. request.RequestUri = new Uri(fileUrl);
  1346. request.Method = HttpMethod.Get;
  1347. var response = await _httpClient.SendAsync(request);
  1348. if (response != null && response.StatusCode == HttpStatusCode.OK)
  1349. {
  1350. var contentLength = response.Content.Headers.ContentLength;
  1351. fileSize = contentLength == null ? 0 : contentLength.Value;
  1352. }
  1353. }
  1354. if (fileSize > 0)
  1355. {
  1356. byte[] bytes = await _httpClient.GetByteArrayAsync(fileUrl);
  1357. File.WriteAllBytes(localFile, bytes);
  1358. return true;
  1359. }
  1360. }
  1361. catch (Exception ex)
  1362. {
  1363. if (ex.Message.Contains("磁盘空间不足"))
  1364. {
  1365. Logger.WriteLineError($"AIDiagnosisService URMAnalysisAsync, fileToken:{fileUrl}, ex:{ex}");
  1366. SendDiskSpaceFullNotification(userCode, remedicalCode, ex.Message);
  1367. }
  1368. else
  1369. {
  1370. Logger.WriteLineWarn($"AIDiagnosisService URMAnalysisAsync, fileToken:{fileUrl}, ex:{ex}");
  1371. }
  1372. }
  1373. return false;
  1374. }
  1375. private void SendDiskSpaceFullNotification(string userCode, string remedicalCode, string exMessage)
  1376. {
  1377. try
  1378. {
  1379. var diskName = "";
  1380. var currentPath = AppDomain.CurrentDomain.BaseDirectory;
  1381. if (!string.IsNullOrWhiteSpace(currentPath))
  1382. {
  1383. var pathParts = currentPath.Split('\\');
  1384. if (pathParts.Length >= 2)
  1385. {
  1386. diskName = pathParts[0];
  1387. }
  1388. }
  1389. var message = new DiskSpaceFullNotification
  1390. {
  1391. DiskName = diskName,
  1392. };
  1393. var result = SendNotification(message, userCode, remedicalCode).Result;
  1394. }
  1395. catch (Exception ex)
  1396. {
  1397. Logger.WriteLineWarn($"AIDiagnosisService SendDiskSpaceFullNotification failed, ex:{ex}");
  1398. }
  1399. }
  1400. private void DeleteExpiredFolders(DateTime time)
  1401. {
  1402. try
  1403. {
  1404. if (Directory.Exists(_urmTempFolder))
  1405. {
  1406. DirectoryInfo theFolder = new DirectoryInfo(_urmTempFolder);
  1407. DirectoryInfo[] dics = theFolder.GetDirectories();
  1408. foreach (var item in dics)
  1409. {
  1410. var readmePath = Path.Combine(item.FullName, "readme.txt");
  1411. if (File.Exists(readmePath))
  1412. {
  1413. if (File.GetLastWriteTime(readmePath) < time)
  1414. {
  1415. try
  1416. {
  1417. Directory.Delete(item.FullName, true);
  1418. }
  1419. catch { }
  1420. }
  1421. }
  1422. else if (item.CreationTime < time)
  1423. {
  1424. try
  1425. {
  1426. Directory.Delete(item.FullName, true);
  1427. }
  1428. catch { }
  1429. }
  1430. }
  1431. }
  1432. }
  1433. catch (Exception ex)
  1434. {
  1435. Logger.WriteLineWarn($"AIDiagnosisService DeleteExpiredFolders failed, ex:{ex}");
  1436. }
  1437. }
  1438. private void DeleteTempFiles(string currentFolder, List<string> expectFiles)
  1439. {
  1440. try
  1441. {
  1442. var files = Directory.GetFiles(currentFolder);
  1443. if (files?.Any() ?? false)
  1444. {
  1445. foreach (var file in files)
  1446. {
  1447. if (expectFiles == null || !expectFiles.Any(x => x == file))
  1448. {
  1449. File.Delete(file);
  1450. }
  1451. }
  1452. }
  1453. var aviFolder = Path.Combine(currentFolder, "avi");
  1454. if (Directory.Exists(aviFolder))
  1455. {
  1456. Directory.Delete(aviFolder, true);
  1457. }
  1458. }
  1459. catch (Exception ex)
  1460. {
  1461. Logger.WriteLineWarn($"AIDiagnosisService DeleteTempFiles failed, currentFolder:{currentFolder}, ex:{ex}");
  1462. }
  1463. }
  1464. private double ConvertToDouble(string value)
  1465. {
  1466. if (string.IsNullOrWhiteSpace(value))
  1467. {
  1468. return 0;
  1469. }
  1470. if (double.TryParse(value, out double x))
  1471. {
  1472. return x;
  1473. }
  1474. return 0;
  1475. }
  1476. private URMRequest ConvertToUrmRequest<WingRequest, URMRequest>(WingRequest request, RemedicalInfoDTO remedical, string currentFolder)
  1477. where WingRequest : URMProcessRequest, new()
  1478. where URMRequest : UrmProcessRequest, new()
  1479. {
  1480. var denPath = Path.Combine(currentFolder, "srcDenArray.bin");
  1481. var dirPath = Path.Combine(currentFolder, "srcDirArray.bin");
  1482. var velPath = Path.Combine(currentFolder, "srcVelArray.bin");
  1483. var angelPath = Path.Combine(currentFolder, "srcAngleArray.bin");
  1484. var maskPath = Path.Combine(currentFolder, "srcMaskArray.bin");
  1485. var urmProcessRequest = new URMRequest
  1486. {
  1487. FamilyName = GetValue(remedical.UrmParameters, "familyName"),
  1488. TypeInfo = GetValue(remedical.UrmParameters, "typeInfo"),
  1489. NativeId = GetValue(remedical.UrmParameters, "nativeId"),
  1490. Isliner = GetValue(remedical.UrmParameters, "isliner").ToLower() == "true",
  1491. ScaleOfPixel_x = ConvertToDouble(GetValue(remedical.UrmParameters, "ScaleOfPixel_x")),
  1492. ScaleOfPixel_y = ConvertToDouble(GetValue(remedical.UrmParameters, "ScaleOfPixel_y")),
  1493. Urmsrcwidth = remedical.URMSrcWidth,
  1494. Urmsrcheight = remedical.URMSrcHeight,
  1495. DenDataPath = File.Exists(denPath) ? denPath : string.Empty,
  1496. DirDataPath = File.Exists(dirPath) ? dirPath : string.Empty,
  1497. VelDataPath = File.Exists(velPath) ? velPath : string.Empty,
  1498. AngleDataPath = File.Exists(angelPath) ? angelPath : string.Empty,
  1499. MaskDataPath = File.Exists(maskPath) ? maskPath : string.Empty,
  1500. Res = remedical.URMRes,
  1501. UrmImageType = request.UrmImageType,
  1502. UrmBlend = request.UrmBlend,
  1503. DownsampleIndex = request.DownsampleIndex,
  1504. IntPowerDen = request.IntPowerDen,
  1505. IntPowerDir = request.IntPowerDir,
  1506. SigmaGauss = request.SigmaGauss,
  1507. VessScale = request.VessScale,
  1508. VelMaxScaler = request.VelMaxScaler,
  1509. VelMinScaler = request.VelMinScaler,
  1510. Iterations = request.Iterations,
  1511. ImgProcessVer = request.ImgProcessVer,
  1512. ZoomOn = request.ZoomOn,
  1513. ZoomRoix = request.ZoomRoix,
  1514. ZoomRoiy = request.ZoomRoiy,
  1515. ZoomRoiwidth = request.ZoomRoiwidth,
  1516. ZoomRoiheight = request.ZoomRoiheight,
  1517. LeftRight = request.LeftRight,
  1518. UpDown = request.UpDown,
  1519. UrmTraceDPoints = request.UrmTraceDPoints?.Select(p => new DPoint { X = p.X, Y = p.Y })?.ToArray(),
  1520. Roix = request.Roix,
  1521. Roiy = request.Roiy,
  1522. Roiwidth = request.Roiwidth,
  1523. Roiheight = request.Roiheight,
  1524. ScreenWidth = request.ScreenWidth,
  1525. ScreenHeight = request.ScreenHeight,
  1526. };
  1527. var scaleOfPixel_x = GetValue(remedical.UrmParameters, "URMScaleOfPixel_x");
  1528. if (!string.IsNullOrWhiteSpace(scaleOfPixel_x))
  1529. {
  1530. urmProcessRequest.ScaleOfPixel_x = ConvertToDouble(scaleOfPixel_x);
  1531. }
  1532. var scaleOfPixel_y = GetValue(remedical.UrmParameters, "URMScaleOfPixel_y");
  1533. if (!string.IsNullOrWhiteSpace(scaleOfPixel_y))
  1534. {
  1535. urmProcessRequest.ScaleOfPixel_y = ConvertToDouble(scaleOfPixel_y);
  1536. }
  1537. return urmProcessRequest;
  1538. }
  1539. /// <summary>
  1540. /// 发送通知
  1541. /// </summary>
  1542. private async Task<bool> SendNotification(DiskSpaceFullNotification notification, string userCode, string remedicalCode)
  1543. {
  1544. if (!string.IsNullOrWhiteSpace(userCode))
  1545. {
  1546. var broadcastNotificationRequest = new WingInterfaceLibrary.Internal.Request.BroadcastNotificationRequest()
  1547. {
  1548. ClientIds = new List<string> { userCode },
  1549. Message = notification,
  1550. JsonMessage = JsonConvert.SerializeObject(notification),
  1551. NotificationType = notification.NotificationType,
  1552. TransactionType = WingInterfaceLibrary.Enum.TransactionTypeEnum.Lab,
  1553. ReceiverType = WingInterfaceLibrary.Enum.ApplicantTypeEnum.Client,
  1554. RelevanceCode = remedicalCode
  1555. };
  1556. return await _notificationService.BroadcastMessageAsync(broadcastNotificationRequest);
  1557. }
  1558. return false;
  1559. }
  1560. }
  1561. }