Desktop.razor.cs 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672
  1. using HyperCube.Models;
  2. using Microsoft.AspNetCore.Components;
  3. using Microsoft.AspNetCore.Components.Authorization;
  4. using Microsoft.AspNetCore.Components.Forms;
  5. using Microsoft.AspNetCore.Identity;
  6. using Microsoft.JSInterop;
  7. using Pullenti.Unitext;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.ComponentModel.DataAnnotations;
  11. using System.IO;
  12. using System.Linq;
  13. using System.Reflection;
  14. using System.Security.Cryptography;
  15. using System.Text;
  16. using System.Threading.Tasks;
  17. using System.Xml;
  18. using Console = HyperCube.Utils.AdvConsole;
  19. namespace HyperCube.Pages
  20. {
  21. public partial class Desktop : ComponentBase
  22. {
  23. //[Parameter]
  24. //public int DocID { get; set; }
  25. [Inject]
  26. NavigationManager NavigationManager { get; set; }
  27. [Inject]
  28. AuthenticationStateProvider AuthenticationStateProvider { get; set; }
  29. [Inject]
  30. UserManager<IdentityUser> UserManager { get; set; }
  31. [Inject]
  32. AppData AppData { get; set; }
  33. [Inject]
  34. public IJSRuntime JsRuntime { get; set; }
  35. const string STORAGE_FOLDER_NAME = "articles_storage";
  36. const long MAX_FILE_SIZE = 5120000; //bytes
  37. const string ACTIVE_BUTTON_CLASS = "btn_white tab-button active";
  38. const string ACTIVE_TAB_CLASS = "second-block__form visible";
  39. const string BUTTON_CLASS = "btn_white tab-button";
  40. const string TAB_CLASS = "second-block__form";
  41. string _uploadButtonClass = ACTIVE_BUTTON_CLASS;
  42. string _uploadTabClass = ACTIVE_TAB_CLASS;
  43. string _verifyButtonClass = BUTTON_CLASS;
  44. string _verifyTabClass = TAB_CLASS;
  45. string _otherButtonClass = BUTTON_CLASS;
  46. string _otherTabClass = TAB_CLASS;
  47. int _counter = 1;
  48. //string _event = "";
  49. string _status;
  50. string _articleDropdownOption = "";
  51. //string _storageFolderPath;
  52. MemoryStream _memoryStream;
  53. ModalInfo _modalInfo_error { get; set; }
  54. ModalLoading _modalLoading { get; set; }
  55. ArticleModel _articleClone;
  56. ArticleModel _article;
  57. ReportModel _report = new();
  58. UnitextDocument _document;
  59. AccountModel _currentAccount;
  60. VerificationPoint _verificationPoint = new();
  61. protected override async Task OnInitializedAsync()
  62. {
  63. ///tmp
  64. await AppData.LoadArticles();
  65. _article = AppData.CurrentArticle ?? (new());
  66. _articleClone = AppData.CurrentArticleClone ?? (new());
  67. _currentAccount = (AppData.CurrentAccount != null) ? AppData.CurrentAccount : await GetCurrentAcc();
  68. Console.WriteLine($"Desktop OnInitializedAsync, CurrentAccount: {_currentAccount.Name}");
  69. }
  70. protected override void OnAfterRender(bool firstRender) => _counter = 1;
  71. void SwitchDesktopTab(int tabIndex)
  72. {
  73. switch(tabIndex)
  74. {
  75. case 0:
  76. _uploadButtonClass = ACTIVE_BUTTON_CLASS;
  77. _uploadTabClass = ACTIVE_TAB_CLASS;
  78. _verifyButtonClass = BUTTON_CLASS;
  79. _verifyTabClass = TAB_CLASS;
  80. _otherButtonClass = BUTTON_CLASS;
  81. _otherTabClass = TAB_CLASS;
  82. break;
  83. case 1:
  84. _uploadButtonClass = BUTTON_CLASS;
  85. _uploadTabClass = TAB_CLASS;
  86. _verifyButtonClass = ACTIVE_BUTTON_CLASS;
  87. _verifyTabClass = ACTIVE_TAB_CLASS;
  88. _otherButtonClass = BUTTON_CLASS;
  89. _otherTabClass = TAB_CLASS;
  90. break;
  91. case 2:
  92. _uploadButtonClass = BUTTON_CLASS;
  93. _uploadTabClass = TAB_CLASS;
  94. _verifyButtonClass = BUTTON_CLASS;
  95. _verifyTabClass = TAB_CLASS;
  96. _otherButtonClass = ACTIVE_BUTTON_CLASS;
  97. _otherTabClass = ACTIVE_TAB_CLASS;
  98. break;
  99. }
  100. }
  101. async Task WidgetMenuClick(string menuname, string elementid)
  102. {
  103. await JsRuntime.InvokeVoidAsync("WidgetMenuClick", menuname, elementid);
  104. _counter = 1;
  105. }
  106. async Task HandleUpload(InputFileChangeEventArgs e)
  107. {
  108. _modalLoading.Open();
  109. IBrowserFile file = e.File;
  110. if (file != null)
  111. {
  112. Stream stream = file.OpenReadStream(MAX_FILE_SIZE);
  113. _memoryStream = new();
  114. await stream.CopyToAsync(_memoryStream);
  115. _status = $"Finished loading {_memoryStream.Length} bytes from {file.Name}";
  116. Console.WriteLine(_status);
  117. /// calculating hash
  118. string hash = await CalculateHashSum(_memoryStream);
  119. Console.WriteLine($"Hash: {hash}");
  120. /// checking hash
  121. MySQLConnector dbCon = MySQLConnector.Instance();
  122. string stringSQL;
  123. stringSQL = $"SELECT COUNT(*) FROM articles WHERE file_hash='{hash}'";
  124. int count = await dbCon.SQLSelectCount(stringSQL);
  125. if (count < 1)
  126. {
  127. _report = new();
  128. _report.FileName = file.Name;
  129. _report.FileSize = _memoryStream.Length.ToString();
  130. _memoryStream.Position = 0;
  131. byte[] content = _memoryStream.ToArray();
  132. _document = UnitextService.CreateDocument(null, content, null);
  133. if (_document.ErrorMessage != null)
  134. {
  135. // скорее всего, этот формат не поддерживается на данный момент
  136. Console.WriteLine($"error, sorry: {_document.ErrorMessage}");
  137. _memoryStream.Close();
  138. stream.Close();
  139. _modalLoading.Close();
  140. _modalInfo_error.Open("Не удается прочитать документ, формат не поддерживается или файл поврежден.");
  141. return;
  142. }
  143. // восстанавливаем имя исходного файла, извлечённого из ресурсов
  144. _document.SourceFileName = file.Name;
  145. for (int i = file.Name.Length - 7; i > 0; i--)
  146. {
  147. if (file.Name[i] == '.')
  148. {
  149. _document.SourceFileName = file.Name.Substring(i + 1);
  150. break;
  151. }
  152. }
  153. //// записываем результат в XML
  154. //using (FileStream fs = new(doc.SourceFileName + ".xml", FileMode.Create, FileAccess.Write))
  155. //{
  156. // XmlWriterSettings xmlParams = new();
  157. // xmlParams.Encoding = Encoding.UTF8;
  158. // xmlParams.Indent = true;
  159. // xmlParams.IndentChars = " ";
  160. // using (XmlWriter xml = XmlWriter.Create(fs, xmlParams))
  161. // {
  162. // xml.WriteStartDocument();
  163. // doc.GetXml(xml);
  164. // xml.WriteEndDocument();
  165. // }
  166. //}
  167. //Console.WriteLine("XML write done");
  168. // получаем плоский текст
  169. string plainText = _document.GetPlaintextString(null);
  170. if (plainText == null)
  171. plainText = "Текст не выделен";
  172. /// todo обработка, если статус != новый
  173. _articleClone = DocParse.GetBaseProperties(plainText);
  174. _articleClone.Filename = file.Name;
  175. _articleClone.HashSum = hash;
  176. _article = (ArticleModel)_articleClone.Clone();
  177. ///tmp
  178. AppData.CurrentArticle = _article;
  179. Console.WriteLine($"Initializing SDK Pullenti ver {Pullenti.Sdk.Version} ({Pullenti.Sdk.VersionDate})... ");
  180. Pullenti.Sdk.InitializeAll();
  181. //Console.WriteLine($"OK (by ... ms), version {Pullenti.Ner.ProcessorService.Version}");
  182. List<string> npt_tokens = new();
  183. // запускаем обработку на пустом процессоре (без анализаторов NER)
  184. Pullenti.Ner.AnalysisResult are = Pullenti.Ner.ProcessorService.EmptyProcessor.Process(new Pullenti.Ner.SourceOfAnalysis(plainText), null, null);
  185. //System.Console.Write("Noun groups: ");
  186. // перебираем токены
  187. for (Pullenti.Ner.Token t = are.FirstToken; t != null; t = t.Next)
  188. {
  189. // выделяем именную группу с текущего токена
  190. Pullenti.Ner.Core.NounPhraseToken npt = Pullenti.Ner.Core.NounPhraseHelper.TryParse(t, Pullenti.Ner.Core.NounPhraseParseAttr.No, 0, null);
  191. // не получилось
  192. if (npt == null)
  193. continue;
  194. // получилось, выводим в нормализованном виде
  195. //System.Console.Write($"[{npt.GetSourceText()}=>{npt.GetNormalCaseText(null, Pullenti.Morph.MorphNumber.Singular, Pullenti.Morph.MorphGender.Undefined, false)}] ");
  196. //_report.NounGroups += $"[{npt.GetSourceText()}=>{npt.GetNormalCaseText(null, Pullenti.Morph.MorphNumber.Singular, Pullenti.Morph.MorphGender.Undefined, false)}] ";
  197. _article.NounGroups += $"[{npt.GetSourceText()}=>{npt.GetNormalCaseText(null, Pullenti.Morph.MorphNumber.Singular, Pullenti.Morph.MorphGender.Undefined, false)}] ";
  198. npt_tokens.Add(npt.GetNormalCaseText(null, Pullenti.Morph.MorphNumber.Singular, Pullenti.Morph.MorphGender.Undefined, false));
  199. // указатель на последний токен именной группы
  200. t = npt.EndToken;
  201. }
  202. using (Pullenti.Ner.Processor proc = Pullenti.Ner.ProcessorService.CreateProcessor())
  203. {
  204. // анализируем текст
  205. Pullenti.Ner.AnalysisResult ar = proc.Process(new Pullenti.Ner.SourceOfAnalysis(plainText), null, null);
  206. // результирующие сущности
  207. //Console.WriteLine("\r\n==========================================\r\nEntities: ");
  208. foreach (Pullenti.Ner.Referent en in ar.Entities)
  209. {
  210. //Console.WriteLine($"{en.TypeName}: {en}");
  211. //_report.Entities += $"{en.TypeName}: {en}\r\n";
  212. _article.Entities += $"{en.TypeName}: {en}\r\n";
  213. foreach (Pullenti.Ner.Slot s in en.Slots)
  214. {
  215. //Console.WriteLine($" {s.TypeName}: {s.Value}");
  216. //_report.Entities += $" {s.TypeName}: {s.Value}<br>";
  217. _article.Entities += $" {s.TypeName}: {s.Value}<br>";
  218. }
  219. }
  220. // пример выделения именных групп
  221. //Console.WriteLine("\r\n==========================================\r\nNoun groups: ");
  222. for (Pullenti.Ner.Token t = ar.FirstToken; t != null; t = t.Next)
  223. {
  224. // токены с сущностями игнорируем
  225. if (t.GetReferent() != null)
  226. continue;
  227. // пробуем создать именную группу
  228. Pullenti.Ner.Core.NounPhraseToken npt = Pullenti.Ner.Core.NounPhraseHelper.TryParse(t, Pullenti.Ner.Core.NounPhraseParseAttr.AdjectiveCanBeLast, 0, null);
  229. // не получилось
  230. if (npt == null)
  231. continue;
  232. //Console.WriteLine(npt.ToString());
  233. //_report.EntitiesNounGroups += $"{npt}<br>";
  234. _article.Morph += $"{npt}<br>";
  235. // указатель перемещаем на последний токен группы
  236. t = npt.EndToken;
  237. }
  238. }
  239. using (Pullenti.Ner.Processor proc = Pullenti.Ner.ProcessorService.CreateSpecificProcessor(Pullenti.Ner.Keyword.KeywordAnalyzer.ANALYZER_NAME))
  240. {
  241. Pullenti.Ner.AnalysisResult ar = proc.Process(new Pullenti.Ner.SourceOfAnalysis(plainText), null, null);
  242. //Console.WriteLine("\r\n==========================================\r\nKeywords1: ");
  243. foreach (Pullenti.Ner.Referent en in ar.Entities)
  244. {
  245. if (en is Pullenti.Ner.Keyword.KeywordReferent)
  246. //Console.WriteLine(en.ToString());
  247. //_report.Keywords1 += $"{en}<br>";
  248. _article.Keywords1 += $"{en}<br>";
  249. }
  250. //Console.WriteLine("\r\n==========================================\r\nKeywords2: ");
  251. for (Pullenti.Ner.Token t = ar.FirstToken; t != null; t = t.Next)
  252. {
  253. if (t is Pullenti.Ner.ReferentToken)
  254. {
  255. Pullenti.Ner.Keyword.KeywordReferent kw = t.GetReferent() as Pullenti.Ner.Keyword.KeywordReferent;
  256. if (kw == null)
  257. continue;
  258. string kwstr = Pullenti.Ner.Core.MiscHelper.GetTextValueOfMetaToken(t as Pullenti.Ner.ReferentToken, Pullenti.Ner.Core.GetTextAttr.FirstNounGroupToNominativeSingle | Pullenti.Ner.Core.GetTextAttr.KeepRegister);
  259. //Console.WriteLine($"{kwstr} = {kw}");
  260. //_report.Keywords2 += $"{kwstr} = {kw}<br>";
  261. _article.Keywords2 += $"{kwstr} = {kw}<br>";
  262. }
  263. }
  264. }
  265. int res = (from x in npt_tokens
  266. select x).Distinct().Count();
  267. Console.WriteLine($"npt_tokens.count={npt_tokens.Count}, distinct.Count={res}");
  268. Console.WriteLine("Analysis is over!");
  269. var query = from x in npt_tokens
  270. group x by x into g
  271. let count1 = g.Count()
  272. orderby count1 descending
  273. select new { Name = g.Key, Count = count1 };
  274. foreach (var result in query)
  275. {
  276. _report.NounGroupsSorted += $"{result.Name}, Count: {result.Count}<br>";
  277. //Console.WriteLine($"Name: {result.Name}, Count: {result.Count}");
  278. }
  279. //AppData.Report = _report;
  280. }
  281. else
  282. {
  283. _status = $"File duplicate founded, hash: {hash}.";
  284. Console.WriteLine(_status);
  285. _article = new();
  286. _articleClone = new();
  287. _document = null;
  288. _memoryStream.Close();
  289. _modalInfo_error.Open("Загрузка не удалась, такой документ уже есть в системе.");
  290. }
  291. file = null;
  292. stream.Close();
  293. }
  294. _modalLoading.Close();
  295. }
  296. void NewDocument()
  297. {
  298. _article = new();
  299. _articleClone = new();
  300. _document = null;
  301. _memoryStream = null;
  302. _status = "Blank document created";
  303. }
  304. async Task SaveDocument_OnClick(ArticleStatus articleNewStatus)
  305. {
  306. Console.WriteLine($"SaveDocument_OnClick. DocID: {_article.ID}, Status: {_article.Status}");
  307. if (_article.Name == null || _article.Name.Length == 0)
  308. {
  309. Console.WriteLine($"SaveDocument, empty article name. DocID: {_article.ID}, Status: {_article.Status}, filename: {_article.Filename}");
  310. _modalInfo_error.Open($"Для сохранения документа необходимо ввести название.");
  311. return;
  312. }
  313. if (_article.Status == ArticleStatus.New && _memoryStream == null)
  314. {
  315. Console.WriteLine($"SaveDocument, empty source file. DocID: {_article.ID}, Status: {_article.Status}, filename: {_article.Filename}");
  316. _modalInfo_error.Open($"Для сохранения документа необходимо прикрепить исходный файл.");
  317. return;
  318. }
  319. if (_article.Status == ArticleStatus.New && articleNewStatus == ArticleStatus.Verifying
  320. || _article.Status == ArticleStatus.AwatingVerify && articleNewStatus == ArticleStatus.Saved
  321. || _article.Status == ArticleStatus.Verifying && articleNewStatus == ArticleStatus.Saved
  322. || _article.Status == ArticleStatus.Verified && articleNewStatus == ArticleStatus.Saved
  323. || _article.Status == ArticleStatus.Verified && articleNewStatus == ArticleStatus.Verifying)
  324. {
  325. Console.WriteLine($"SaveDocument, wrong status. DocID: {_article.ID}, Status: {_article.Status}");
  326. _modalInfo_error.Open($"Текущий статус документа не позволяет сохранение.<br>DocID: {_article.ID}, Status: {GetDisplayName(_article.Status)}");
  327. }
  328. else
  329. {
  330. /// all is fine, continue
  331. MySQLConnector dbCon = MySQLConnector.Instance();
  332. long id;
  333. string stringSQL;
  334. if (_article.Status == ArticleStatus.New)
  335. {
  336. _modalLoading.Open();
  337. stringSQL = $"INSERT INTO articles (filename, article_name, authors, date_publish, annotation, keywords, file_hash, " +
  338. $"doc_noungroups, doc_entities, doc_morph, doc_keywords1, doc_keywords2) " +
  339. $"VALUES ('{_article.Filename}', '{_article.Name}', '{_article.Authors}', '{_article.PublishDate:yyyy-MM-dd}'," +
  340. $"'{_article.Annotation}', '{_article.Keywords}', '{_article.HashSum}'," +
  341. $"'{_article.NounGroups}', '{_article.Entities}', '{_article.Morph}', '{_article.Keywords1}', '{_article.Keywords2}' )";
  342. id = await dbCon.SQLInsert(stringSQL);
  343. _article.ID = (int)id;
  344. ///todo добавлять новый док в массив AppData.Articles
  345. stringSQL = $"INSERT INTO actions_history (article_id, action_type, acc_id) " +
  346. $"VALUES ('{id}', '{(int)articleNewStatus}', '{_currentAccount.UUID}')";
  347. await dbCon.SQLInsert(stringSQL);
  348. await SaveFiles((int)id);
  349. _article.Status = ArticleStatus.Saved;
  350. _articleClone = (ArticleModel)_article.Clone();
  351. /// reloading articles
  352. await AppData.LoadArticles();
  353. _counter = 1;
  354. _modalLoading.Close();
  355. _modalInfo_error.Open("Документ успешно создан.");
  356. }
  357. else
  358. {
  359. await UpdateDocument(articleNewStatus);
  360. //await SaveFiles(_article.ID);
  361. if (_article.Status == ArticleStatus.AwatingVerify || _article.Status == ArticleStatus.Verifying)
  362. await _article.SaveLastVerificationPoint(_verificationPoint, _currentAccount.UUID);
  363. }
  364. }
  365. }
  366. async Task LoadDocument(int docid)
  367. {
  368. ///todo загружать из массива AppData.Articles
  369. Console.WriteLine($"LoadDocument, docid: {docid}.");
  370. _modalLoading.Open();
  371. if (docid > 0)
  372. {
  373. MySQLConnector dbCon = MySQLConnector.Instance();
  374. string stringSQL = $"SELECT articles.id, filename, article_name, authors, date_publish, annotation, keywords, action_type, rating, file_hash, " +
  375. $"doc_noungroups, doc_entities, doc_morph, doc_keywords1, doc_keywords2 " +
  376. $"FROM articles " +
  377. $"JOIN actions_history ON actions_history.article_id = articles.id " +
  378. $"WHERE articles.id={docid} " +
  379. $"ORDER BY actions_history.id DESC LiMIT 1";
  380. AppData.CurrentArticleClone = await dbCon.SQLSelectArticle(stringSQL);
  381. await AppData.CurrentArticleClone.GetVerificationHistory(_currentAccount.UUID);
  382. if (AppData.CurrentArticleClone.VerificationHistory.Count > 0)
  383. _verificationPoint = AppData.CurrentArticleClone.VerificationHistory.Values.Last();
  384. else
  385. _verificationPoint = new();
  386. AppData.CurrentArticle = (ArticleModel)AppData.CurrentArticleClone.Clone();
  387. //string initiator = await _article.GetInitiatorUUID();
  388. //initiatorAcc = AccountModel.Find(initiator);
  389. //_status = $"Article ID={DocID} loaded, status: {_article.Status}, initiator: {initiatorAcc.Name}";
  390. _status = $"Article ID={docid} loaded, status: {AppData.CurrentArticle.Status}.";
  391. _article = AppData.CurrentArticle ?? (new());
  392. _articleClone = AppData.CurrentArticleClone ?? (new());
  393. }
  394. _modalLoading.Close();
  395. }
  396. async Task SendToVerify_OnClick()
  397. {
  398. if (_article.Status == ArticleStatus.New || _article.Status == ArticleStatus.Saved)
  399. {
  400. Console.WriteLine($"SendToVerify, DocID: {_article.ID}, Status: {_article.Status}");
  401. _modalLoading.Open();
  402. /// form validation
  403. List<string> errorFields = ValidateForm<ArticleModel>(_article);
  404. if (errorFields.Count > 0)
  405. {
  406. _modalLoading.Close();
  407. string invalid_fields = string.Join(", ", errorFields);
  408. _modalInfo_error.Open($"Не заполнены поля: {invalid_fields}");
  409. Console.WriteLine($"SendToVerify. Required fields: '{invalid_fields}' is not filled.");
  410. return;
  411. }
  412. await UpdateDocument(ArticleStatus.AwatingVerify);
  413. _modalLoading.Close();
  414. }
  415. else
  416. {
  417. Console.WriteLine($"SendToVerify, wrong status. DocID: {_article.ID}, Status: {_article.Status}");
  418. _modalInfo_error.Open($"Документ не может быть отправлен на верификацию.<br>DocID: {_article.ID}, Status: {GetDisplayName(_article.Status)}");
  419. }
  420. }
  421. async Task Verify_OnClick()
  422. {
  423. if (_article.Status == ArticleStatus.AwatingVerify || _article.Status == ArticleStatus.Verifying)
  424. {
  425. Console.WriteLine($"Verify, DocID: {_article.ID}, Status: {_article.Status}");
  426. _modalLoading.Open();
  427. /// form validation
  428. List<string> errorFields = ValidateForm<ArticleModel>(_article);
  429. if (errorFields.Count > 0)
  430. {
  431. _modalLoading.Close();
  432. string invalid_fields = string.Join(", ", errorFields);
  433. _modalInfo_error.Open($"Не заполнены поля: {invalid_fields}");
  434. Console.WriteLine($"Verify. Required fields: '{invalid_fields}' is not filled.");
  435. return;
  436. }
  437. await UpdateDocument(ArticleStatus.Verified);
  438. _modalLoading.Close();
  439. }
  440. else
  441. {
  442. Console.WriteLine($"Verify, wrong status. DocID: {_article.ID}, Status: {_article.Status}");
  443. _modalInfo_error.Open($"Документ не может быть верифицирован.<br>DocID: {_article.ID}, Status: {GetDisplayName(_article.Status)}");
  444. }
  445. }
  446. async Task UpdateDocument(ArticleStatus articleStatus)
  447. {
  448. _modalLoading.Open();
  449. MySQLConnector dbCon = MySQLConnector.Instance();
  450. string stringSQL;
  451. string rating = (_article.Rating == null) ? "NULL" : _article.Rating.ToString();
  452. stringSQL = $"UPDATE articles " +
  453. $"SET filename='{_article.Filename}', article_name='{_article.Name}', authors='{_article.Authors}', " +
  454. $"date_publish='{_article.PublishDate:yyyy-MM-dd}', annotation='{_article.Annotation}', " +
  455. $"keywords='{_article.Keywords}', rating={rating}, file_hash='{_article.HashSum}' " +
  456. $"WHERE id={_article.ID}";
  457. await dbCon.SQLInsert(stringSQL);
  458. ///todo обновлять док в массиве AppData.Articles
  459. stringSQL = $"INSERT INTO actions_history (article_id, action_type, acc_id) " +
  460. $"VALUES ('{_article.ID}', '{(int)articleStatus}', '{_currentAccount.UUID}')";
  461. await dbCon.SQLInsert(stringSQL);
  462. ///если нужно фиксировать изменение статуса в поле (табл articles_edit_log)
  463. //_article.Status = articleStatus;
  464. Dictionary<string, PropertyInfo> propDict = Compare.SimpleCompare<ArticleModel>(_article, _articleClone);
  465. foreach (KeyValuePair<string, PropertyInfo> prop in propDict)
  466. {
  467. //Console.WriteLine($"property name: {prop.Key}, value: {prop.Value.GetValue(articleModel, null)}");
  468. stringSQL = $"INSERT INTO articles_edit_log (article_id, acc_id, field_name, field_prevvalue, field_newvalue) " +
  469. $"VALUES ('{_article.ID}', '{_currentAccount.UUID}', '{prop.Key}', '{prop.Value.GetValue(_articleClone, null)}', '{prop.Value.GetValue(_article, null)}')";
  470. await dbCon.SQLInsert(stringSQL);
  471. }
  472. _article.Status = articleStatus;
  473. _articleClone = (ArticleModel)_article.Clone();
  474. /// reloading articles
  475. await AppData.LoadArticles();
  476. _modalLoading.Close();
  477. string message = propDict.Count > 0 ? "Все изменения успешно сохранены." : "Изменений не найдено.";
  478. _modalInfo_error.Open(message);
  479. }
  480. async Task DocSelect_OnChange(ChangeEventArgs e)
  481. {
  482. int docid = int.Parse(e.Value.ToString());
  483. Console.WriteLine($"DocSelect_OnChange. docid: {docid}");
  484. await LoadDocument(docid);
  485. }
  486. async Task SaveFiles(int docid)
  487. {
  488. if (_document != null )
  489. {
  490. /// получаем html, сохраняем файлы
  491. GetHtmlParam htmlParams = new();
  492. htmlParams.OutHtmlAndBodyTags = true;
  493. string html = _document.GetHtmlString(htmlParams);
  494. string fullpath;
  495. string htmldirectorypath;
  496. string docdirectorypath;
  497. #if DEBUG
  498. htmldirectorypath = Path.Combine(Environment.CurrentDirectory, "wwwroot", STORAGE_FOLDER_NAME, "html");
  499. docdirectorypath = Path.Combine(Environment.CurrentDirectory, "wwwroot", STORAGE_FOLDER_NAME, "source");
  500. #else
  501. htmldirectorypath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", STORAGE_FOLDER_NAME, "html");
  502. docdirectorypath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot", STORAGE_FOLDER_NAME, "source");
  503. #endif
  504. ///html
  505. fullpath = Path.Combine(htmldirectorypath, $"{docid}_{_document.SourceFileName}.html");
  506. Console.WriteLine($"Saving file [{fullpath}]");
  507. Directory.CreateDirectory(htmldirectorypath);
  508. File.WriteAllBytes(fullpath, Encoding.UTF8.GetBytes(html));
  509. ///original files
  510. fullpath = Path.Combine(docdirectorypath, $"{docid}_{_article.Filename}");
  511. Console.WriteLine($"Saving file [{fullpath}]");
  512. Directory.CreateDirectory(docdirectorypath);
  513. FileStream fs = new(fullpath, FileMode.Create, FileAccess.Write);
  514. _memoryStream.Position = 0;
  515. await _memoryStream.CopyToAsync(fs);
  516. _status = $"User has saved new article data: [{docid}_{_article.Filename}], memory size:{_memoryStream.Length}b, file size: {fs.Length}b";
  517. Console.WriteLine(_status);
  518. _memoryStream.Close();
  519. fs.Close();
  520. _document = null;
  521. }
  522. }
  523. async Task<string> CalculateHashSum(MemoryStream ms)
  524. {
  525. MD5CryptoServiceProvider md5Provider = new();
  526. ms.Position = 0;
  527. byte[] hash = await md5Provider.ComputeHashAsync(ms);
  528. return Convert.ToBase64String(hash);
  529. }
  530. List<string> ValidateForm<T>(T obj)
  531. {
  532. var props = typeof(T).GetProperties().Where(pi => Attribute.IsDefined(pi, typeof(RequiredAttribute)));
  533. List<string> result = new();
  534. foreach (var prop in props)
  535. {
  536. var val = prop.GetValue(obj, null);
  537. if (val == null || val?.ToString().Length == 0)
  538. result.Add(prop.Name);
  539. //Console.WriteLine($"Required field '{prop.Name}' is not filled.");
  540. }
  541. return result;
  542. }
  543. static string GetDisplayName(Enum enumValue)
  544. {
  545. return enumValue.GetType()
  546. .GetMember(enumValue.ToString())
  547. .First()
  548. .GetCustomAttribute<DisplayAttribute>()
  549. .GetName();
  550. }
  551. async Task<AccountModel> GetCurrentAcc()
  552. {
  553. Console.WriteLine($"Desktop GetCurrentAcc");
  554. if (_currentAccount == null)
  555. {
  556. var authState = await AuthenticationStateProvider.GetAuthenticationStateAsync();
  557. var user = authState.User;
  558. if (user.Identity.IsAuthenticated)
  559. {
  560. ///tmp
  561. Dictionary<string, AccountModel> accounts = await MySQLConnector.Instance().SQLSelectASPUsers();
  562. var currentUser = await UserManager.GetUserAsync(user);
  563. if (accounts.ContainsKey(currentUser.Id))
  564. _currentAccount = accounts[currentUser.Id];
  565. }
  566. }
  567. return _currentAccount;
  568. }
  569. }
  570. }