ApiStreamService.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359
  1. 
  2. using Aip.Service.Aip.Models;
  3. using Aip.Service.Aip.Serivces;
  4. using Aip.Service.Models.App;
  5. using Aip.Service.Models.Request;
  6. using Aip.Service.Models.Response;
  7. using Aip.Service.Services.Interfaces;
  8. using Aip.Service.Utils;
  9. namespace Aip.Service.Services;
  10. public class ApiStreamService : BaseService, IApiStreamService
  11. {
  12. private readonly ILogger<ApiStreamService> _log;
  13. protected readonly AipFileService _aipFileService;
  14. public ApiStreamService(ILogger<ApiStreamService> log, IApiConfigService aipConfigService, AipFileService aipFileService)
  15. : base(aipConfigService)
  16. {
  17. _log = log;
  18. _aipFileService = aipFileService;
  19. }
  20. public async Task<ResponseInfo> GetInfo(RequestStreamInfo req)
  21. {
  22. //string tempOrgFileName = _aipFileService.GetRequestFileName(req.apiGuid + FileUtils.GetExtension(req.dispFileName));
  23. string actualFileName = _aipConfigService.GetActualFileName(req.apiGuid + FileUtils.GetExtension(req.stream.dispFileName));
  24. try
  25. {
  26. string? newFileExt = _aipConfigService.GetSupportedFileType(req.stream.dispFileName);
  27. if (newFileExt == null)
  28. {
  29. return new ResponseInfo
  30. {
  31. errorCode = 102,
  32. errorMessage = "지원하지 않는 파일형식 입니다.",
  33. };
  34. }
  35. var task = Task.Run(() =>
  36. {
  37. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  38. {
  39. return ResponseGetFileInfo(_aipFileService.GetFileInfo(stream, actualFileName), req.stream.dispFileName);
  40. }
  41. });
  42. ResponseInfo result = await task;
  43. return result;
  44. }
  45. catch (Exception e)
  46. {
  47. return ResponseInfoException(e);
  48. }
  49. finally
  50. {
  51. FileUtils.DeleteFile(actualFileName);
  52. }
  53. }
  54. public async Task<ResponseStream> SetLabel(RequestStreamSet req)
  55. {
  56. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  57. if (check.errorCode != 0)
  58. {
  59. return new ResponseStream
  60. {
  61. errorCode = check.errorCode,
  62. errorMessage = check.errorMessage,
  63. dispFileName = check.dispFileName,
  64. };
  65. }
  66. try
  67. {
  68. var task = Task.Run(() =>
  69. {
  70. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  71. {
  72. SetFileInfo fileInfo = _aipFileService.SetLabel(stream, check.actualFileName, req.email, req.aipGuid, "", req.comment);
  73. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  74. }
  75. });
  76. ResponseStream result = await task;
  77. return result;
  78. }
  79. catch (Exception e)
  80. {
  81. return ResponseStreamException(e, req.stream.dispFileName);
  82. }
  83. finally
  84. {
  85. FileUtils.DeleteFile(check.actualFileName);
  86. }
  87. }
  88. public async Task<ResponseStream> DelLabel(RequestStreamDel req)
  89. {
  90. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  91. if (check.errorCode != 0)
  92. {
  93. return new ResponseStream
  94. {
  95. errorCode = check.errorCode,
  96. errorMessage = check.errorMessage,
  97. dispFileName = check.dispFileName,
  98. };
  99. }
  100. try
  101. {
  102. var task = Task.Run(() =>
  103. {
  104. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  105. {
  106. SetFileInfo fileInfo = _aipFileService.DeleteLabel(stream, check.actualFileName, req.email, req.comment, false);
  107. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  108. }
  109. });
  110. ResponseStream result = await task;
  111. return result;
  112. }
  113. catch (Exception e)
  114. {
  115. return ResponseStreamException(e, req.stream.dispFileName);
  116. }
  117. finally
  118. {
  119. FileUtils.DeleteFile(check.actualFileName);
  120. }
  121. }
  122. public async Task<ResponseStream> SetProtection(RequestStreamSet req)
  123. {
  124. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  125. if (check.errorCode != 0)
  126. {
  127. return new ResponseStream
  128. {
  129. errorCode = check.errorCode,
  130. errorMessage = check.errorMessage,
  131. dispFileName = check.dispFileName,
  132. };
  133. }
  134. try
  135. {
  136. var task = Task.Run(() =>
  137. {
  138. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  139. {
  140. SetFileInfo fileInfo = _aipFileService.SetProtection(stream, check.actualFileName, req.email, req.aipGuid, req.comment);
  141. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  142. }
  143. });
  144. ResponseStream result = await task;
  145. return result;
  146. }
  147. catch (Exception e)
  148. {
  149. return ResponseStreamException(e, req.stream.dispFileName);
  150. }
  151. finally
  152. {
  153. FileUtils.DeleteFile(check.actualFileName);
  154. }
  155. }
  156. public async Task<ResponseStream> RemoveProtection(RequestStreamDel req)
  157. {
  158. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  159. if (check.errorCode != 0)
  160. {
  161. return new ResponseStream
  162. {
  163. errorCode = check.errorCode,
  164. errorMessage = check.errorMessage,
  165. dispFileName = check.dispFileName,
  166. };
  167. }
  168. try
  169. {
  170. var task = Task.Run(() =>
  171. {
  172. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  173. {
  174. SetFileInfo fileInfo = _aipFileService.DeleteLabel(stream, check.actualFileName, req.email, req.comment, true);
  175. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  176. }
  177. });
  178. ResponseStream result = await task;
  179. return result;
  180. }
  181. catch (Exception e)
  182. {
  183. return ResponseStreamException(e, req.stream.dispFileName);
  184. }
  185. finally
  186. {
  187. FileUtils.DeleteFile(check.actualFileName);
  188. }
  189. }
  190. public async Task<ResponseStream> SetLabelProtection(RequestStreamAllSet req)
  191. {
  192. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  193. if (check.errorCode != 0)
  194. {
  195. return new ResponseStream
  196. {
  197. errorCode = check.errorCode,
  198. errorMessage = check.errorMessage,
  199. dispFileName = check.dispFileName,
  200. };
  201. }
  202. try
  203. {
  204. var task = Task.Run(() =>
  205. {
  206. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  207. {
  208. SetFileInfo fileInfo = _aipFileService.SetLabel(stream, check.actualFileName, req.email, req.aipGuid, req.templateGuid, req.comment);
  209. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  210. }
  211. });
  212. ResponseStream result = await task;
  213. return result;
  214. }
  215. catch (Exception e)
  216. {
  217. return ResponseStreamException(e, req.stream.dispFileName);
  218. }
  219. finally
  220. {
  221. FileUtils.DeleteFile(check.actualFileName);
  222. }
  223. }
  224. public async Task<ResponseStream> RemoveLabelProtection(RequestStreamDel req)
  225. {
  226. CheckAip check = CheckAipRequest(req.apiGuid, req.stream.dispFileName, "", true);
  227. if (check.errorCode != 0)
  228. {
  229. return new ResponseStream
  230. {
  231. errorCode = check.errorCode,
  232. errorMessage = check.errorMessage,
  233. dispFileName = check.dispFileName,
  234. };
  235. }
  236. try
  237. {
  238. var task = Task.Run(() =>
  239. {
  240. using (var stream = new MemoryStream(Convert.FromBase64String(req.stream.fileData)))
  241. {
  242. SetFileInfo fileInfo = _aipFileService.DeleteLabel(stream, check.actualFileName, req.email, req.comment, true);
  243. return ResponseSetStream(fileInfo, req.stream.dispFileName, Path.GetFileName(fileInfo.newFileName));
  244. }
  245. });
  246. ResponseStream result = await task;
  247. return result;
  248. }
  249. catch (Exception e)
  250. {
  251. return ResponseStreamException(e, req.stream.dispFileName);
  252. }
  253. finally
  254. {
  255. FileUtils.DeleteFile(check.actualFileName);
  256. }
  257. }
  258. public async Task<ResponseStream> EncryptFile(IFormFile file, RequestBase baseReq)
  259. {
  260. CheckMultipartFile check = ValidateMultipartFile(file, baseReq.apiGuid);
  261. try
  262. {
  263. if (check.errorCode != 0)
  264. {
  265. return new ResponseStream
  266. {
  267. errorCode = check.errorCode,
  268. errorMessage = check.errorMessage,
  269. dispFileName = check.dispFileName,
  270. };
  271. }
  272. string savedFileName = _aipConfigService.GetRequestFileName(check.saveFileName);
  273. RequestStreamSet req = new RequestStreamSet
  274. {
  275. apiKey = baseReq.apiKey,
  276. email = baseReq.email,
  277. apiGuid = baseReq.apiGuid,
  278. decryptKey = string.Empty,
  279. stream = new RequestStream
  280. {
  281. dispFileName = check.dispFileName,
  282. fileData = FileUtils.GetFileData(savedFileName),
  283. },
  284. aipGuid = _aipConfigService.aipSetting.SetLabelId,
  285. comment = "EncryptFile"
  286. };
  287. ResponseStream result = await SetLabel(req);
  288. return result;
  289. }
  290. catch (Exception e)
  291. {
  292. return ResponseStreamException(e, file.FileName);
  293. }
  294. finally
  295. {
  296. FileUtils.DeleteFile(_aipConfigService.GetRequestFileName(check.saveFileName));
  297. }
  298. }
  299. public async Task<ResponseStream> DecryptFile(IFormFile file, RequestBase baseReq)
  300. {
  301. CheckMultipartFile check = ValidateMultipartFile(file, baseReq.apiGuid);
  302. try
  303. {
  304. if (check.errorCode != 0)
  305. {
  306. return new ResponseStream
  307. {
  308. errorCode = check.errorCode,
  309. errorMessage = check.errorMessage,
  310. dispFileName = check.dispFileName,
  311. };
  312. }
  313. string savedFileName = _aipConfigService.GetRequestFileName(check.saveFileName);
  314. RequestStreamDel req = new RequestStreamDel
  315. {
  316. apiKey = baseReq.apiKey,
  317. email = baseReq.email,
  318. apiGuid = baseReq.apiGuid,
  319. decryptKey = string.Empty,
  320. stream = new RequestStream
  321. {
  322. dispFileName = check.dispFileName,
  323. fileData = FileUtils.GetFileData(savedFileName),
  324. },
  325. comment = "DecryptFile"
  326. };
  327. ResponseStream result = await DelLabel(req);
  328. return result;
  329. }
  330. catch (Exception e)
  331. {
  332. return ResponseStreamException(e, file.FileName);
  333. }
  334. finally
  335. {
  336. FileUtils.DeleteFile(_aipConfigService.GetRequestFileName(check.saveFileName));
  337. }
  338. }
  339. }