EvaluationSyncInfoService.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559
  1. using Azure.Storage.Blobs.Models;
  2. using IES.ExamLibrary.Models;
  3. using IES.ExamServer.Models;
  4. using Microsoft.Azure.Cosmos;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.IO;
  8. using System.Linq;
  9. using System.Net.Http;
  10. using System.Text;
  11. using System.Text.Json;
  12. using System.Threading.Tasks;
  13. using TEAMModelOS.SDK.DI;
  14. using TEAMModelOS.SDK.Extension;
  15. using TEAMModelOS.SDK.Models.Cosmos;
  16. using TEAMModelOS.SDK.Models.Cosmos.Normal;
  17. namespace TEAMModelOS.SDK.Models.Service
  18. {
  19. public sealed class EvaluationSyncInfoService
  20. {
  21. /// <summary>
  22. /// 重新对名单的hash值计算,1因为可能会存在临时将学生加入名单,而没有修改评测信息的情况。
  23. /// </summary>
  24. /// <param name="evaluationSyncInfo"></param>
  25. /// <param name="_coreAPIHttpService"></param>
  26. /// <param name="_azureCosmos"></param>
  27. /// <param name="_dingDing"></param>
  28. /// <returns></returns>
  29. public static async Task<(EvaluationSyncInfo evaluation, bool change,string newGrouplistHash, List<RMember> members, List<RGroupList> groupLists)> CheckEvaluationGroupList(EvaluationSyncInfo evaluationSyncInfo, CoreAPIHttpService _coreAPIHttpService, AzureCosmosFactory _azureCosmos, DingDing _dingDing)
  30. {
  31. var listInfo = await GroupListService.GetMemberByListids(_coreAPIHttpService, _azureCosmos.GetCosmosClient(), _dingDing, evaluationSyncInfo.grouplist.Select(x=>x.id).ToList(), evaluationSyncInfo.ownerId);
  32. //计算数据的hash值
  33. StringBuilder groupListData = new StringBuilder();
  34. //名单的hash值
  35. var orderList = listInfo.groups.OrderBy(x => x.id);
  36. foreach (var item in orderList)
  37. {
  38. groupListData.Append($"{item.id}-{item.name}");
  39. var orderMembers = item.members.OrderBy(x => x.id);
  40. foreach (var member in orderMembers)
  41. {
  42. groupListData.Append($"{member.id}-{member.name}");
  43. }
  44. }
  45. bool change = false;
  46. string grouplistHash = ShaHashHelper.GetSHA1(groupListData.ToString());
  47. if (!evaluationSyncInfo.grouplistHash .Equals(grouplistHash))
  48. {
  49. evaluationSyncInfo.grouplistHash = grouplistHash;
  50. change = true;
  51. }
  52. return (evaluationSyncInfo,change, grouplistHash,listInfo.rmembers, listInfo.groups);
  53. }
  54. /// <summary>
  55. /// 活动数据打包
  56. /// </summary>
  57. /// <param name="id"></param>
  58. /// <param name="scope"></param>
  59. /// <param name="owner"></param>
  60. /// <param name="type"></param>
  61. /// <param name="azureCosmos"></param>
  62. /// <param name="azureStorage"></param>
  63. public static async Task<EvaluationSyncInfo> PackageEvaluation( string id,string scope, string ownerId, string type, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage,
  64. CoreAPIHttpService _coreAPIHttpService, DingDing _dingDing, IHttpClientFactory _httpClientFactory)
  65. {
  66. EvaluationSource evaluationSource = new EvaluationSource() { type=type,id=id};
  67. EvaluationSyncInfo evaluationSyncInfo= null;
  68. EvaluationClient evaluationClient = null;
  69. List<EvaluationExam> evaluationExams = new List<EvaluationExam>();
  70. long? dataTime = 0;
  71. long stime = 0;
  72. long etime = 0;
  73. string? ownerName=string.Empty;
  74. string? ownerPicture = string.Empty;
  75. string schoolCode = null;
  76. if (scope.Equals("school"))
  77. {
  78. try {
  79. School school = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(ownerId, new PartitionKey("Base"));
  80. schoolCode= ownerId;
  81. evaluationSource.school = school;
  82. ownerName = school.name;
  83. ownerPicture = school.picture;
  84. //if (!string.IsNullOrWhiteSpace(ownerPicture))
  85. //{
  86. // //学校logo 下载到本地、
  87. // HttpResponseMessage message = await _httpClientFactory.CreateClient().GetAsync(ownerPicture);
  88. // if (message.IsSuccessStatusCode)
  89. // {
  90. // string base64Prefix = "data:image/jpeg;base64,";
  91. // byte[] fileBytes = await message.Content.ReadAsByteArrayAsync();
  92. // ownerPicture =$"{base64Prefix}{Convert.ToBase64String(fileBytes)}";
  93. // }
  94. //}
  95. }
  96. catch (Exception ex) {
  97. await _dingDing.SendBotMsg($"打包评测数据,获取学校信息报错,{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  98. return null;
  99. }
  100. }
  101. else
  102. {
  103. try {
  104. Teacher teacher = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>(ownerId, new PartitionKey("Base"));
  105. evaluationSource.teacher = teacher;
  106. ownerName = teacher.name;
  107. ownerPicture = teacher.picture;
  108. //if (!string.IsNullOrWhiteSpace(ownerPicture))
  109. //{
  110. // //学校logo 下载到本地、
  111. // HttpResponseMessage message = await _httpClientFactory.CreateClient().GetAsync(ownerPicture);
  112. // if (message.IsSuccessStatusCode)
  113. // {
  114. // string base64Prefix = "data:image/jpeg;base64,";
  115. // byte[] fileBytes = await message.Content.ReadAsByteArrayAsync();
  116. // ownerPicture =$"{base64Prefix}{Convert.ToBase64String(fileBytes)}";
  117. // }
  118. //}
  119. }
  120. catch (Exception ex) {
  121. await _dingDing.SendBotMsg($"打包评测数据,获取教师信息报错,{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  122. return null;
  123. }
  124. }
  125. var responseEvaluationSyncInfo = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(id, new PartitionKey("EvaluationSyncInfo"));
  126. if (responseEvaluationSyncInfo.IsSuccessStatusCode)
  127. {
  128. evaluationSyncInfo= JsonDocument.Parse(responseEvaluationSyncInfo.Content).RootElement.Deserialize<EvaluationSyncInfo>();
  129. }
  130. else {
  131. evaluationSyncInfo=new EvaluationSyncInfo {
  132. id = id,
  133. scope = scope,
  134. type = type,
  135. pk="EvaluationSyncInfo",
  136. code="EvaluationSyncInfo",
  137. ownerId = ownerId,
  138. ownerPicture = ownerPicture,
  139. ownerName = ownerName,
  140. };
  141. }
  142. switch (true)
  143. {
  144. case bool when (type == "Exam"):
  145. {
  146. string code = $"Exam-{ownerId}";
  147. var response = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(id, new PartitionKey(code));
  148. if (response.IsSuccessStatusCode)
  149. {
  150. ExamInfo exam= JsonDocument.Parse(response.Content).RootElement.Deserialize<ExamInfo>();
  151. dataTime = exam._ts*1000;
  152. evaluationSyncInfo.name=exam.name;
  153. evaluationSyncInfo.subjects = exam.subjects?.Select(x=>new IES.ExamServer.Models.SubjectExam { subjectId=x.id,subjectName=x.name,examId=id,examName=exam.name}).ToList();
  154. evaluationSyncInfo.dataTime= DateTimeOffset.Now.ToUnixTimeMilliseconds();
  155. evaluationSyncInfo.scode=exam.code;
  156. evaluationSyncInfo.owner=exam.owner;
  157. stime=exam.startTime;
  158. etime=exam.endTime;
  159. HashSet<string> grouplist = new HashSet<string>();
  160. if (exam.classes.IsNotEmpty()) {
  161. exam.classes.ForEach(x => { grouplist.Add(x); });
  162. }
  163. if (exam.stuLists.IsNotEmpty())
  164. {
  165. exam.stuLists.ForEach(x => { grouplist.Add(x); });
  166. }
  167. evaluationSyncInfo.grouplist=grouplist.Select(x=> new EvaluationGroupListDto { id=x}).ToList() ;
  168. evaluationSyncInfo.paperCount=exam.papers.IsNotEmpty()? exam.papers.Count():0;
  169. foreach (var group in exam.papers.GroupBy(x=>x.subjectId).Select(x=>new { key = x.Key,list= x.ToList()}))
  170. {
  171. var subject= exam.subjects.Find(x => x.id.Equals(group.key));
  172. if (subject!=null)
  173. {
  174. evaluationSyncInfo.subjects.Add(new IES.ExamServer.Models.SubjectExam {
  175. subjectId=subject.id,
  176. subjectName=subject.name,
  177. examId=id,
  178. examName=exam.name,
  179. papers= group.list.Select(x=>new SubjectExamPaper {paperId= x.id,paperName=x.name, questionCount=x.answers.IsNotEmpty()?x.answers.Count():0, blob=x.blob, local=$"package/{evaluationSyncInfo.id}/papers/{x.id}" }).ToList(),
  180. } );
  181. EvaluationExam evaluationExam = new EvaluationExam()
  182. {
  183. examId=exam.id,
  184. evaluationId=evaluationSyncInfo.id,
  185. examName=evaluationSyncInfo.name,
  186. subjectId=subject.id,
  187. subjectName=subject.name,
  188. classes= evaluationSyncInfo.grouplist,
  189. owner=exam.owner,
  190. scope=scope,
  191. stime=stime,
  192. etime=etime,
  193. papers= group.list.Select(x => new EvaluationPaper { paperId= x.id, paperName=x.name, questionCount=x.answers.IsNotEmpty() ? x.answers.Count() : 0, blob=x.blob, local=$"package/{evaluationSyncInfo.id}/papers/{x.id}", point=x.point,knowledge=x.knowledge,type=x.type,field=x.field }).ToList(),
  194. };
  195. evaluationExams.Add(evaluationExam);
  196. }
  197. }
  198. evaluationSource.exam=exam;
  199. }
  200. break;
  201. }
  202. case bool when (type == "Art"):
  203. {
  204. string code = $"Art-{ownerId}";
  205. var response = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(id, new PartitionKey(code));
  206. if (response.IsSuccessStatusCode)
  207. {
  208. ArtEvaluation art = JsonDocument.Parse(response.Content).RootElement.Deserialize<ArtEvaluation>();
  209. // evaluationSyncInfo.subjects = art.subjects?.Select(x => new IES.ExamServer.Models.SubjectExam { id=x.id, name=x.name, examId=id }).ToList();
  210. evaluationSyncInfo.name = art.name;
  211. evaluationSyncInfo.pid= art.pId;
  212. evaluationSyncInfo.scode=art.code;
  213. evaluationSyncInfo.dataTime = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  214. evaluationSyncInfo.owner=art.owner;
  215. HashSet<string> grouplist = new HashSet<string>();
  216. if (art.classes.IsNotEmpty())
  217. {
  218. art.classes.ForEach(x => { grouplist.Add(x); });
  219. }
  220. if (art.stuLists.IsNotEmpty())
  221. {
  222. art.stuLists.ForEach(x => { grouplist.Add(x); });
  223. }
  224. if (art.tchLists.IsNotEmpty())
  225. {
  226. art.tchLists.ForEach(x => { grouplist.Add(x); });
  227. }
  228. evaluationSyncInfo.grouplist=grouplist.Select(x => new EvaluationGroupListDto { id = x }).ToList();
  229. evaluationSource.art=art;
  230. dataTime= art._ts*1000;
  231. stime=art.startTime;
  232. etime=art.endTime;
  233. var quota_21 = art.settings.Find(x => x.id.Equals("quota_21"));
  234. foreach (var item in quota_21.task)
  235. {
  236. if (!string.IsNullOrWhiteSpace(item.acId))
  237. {
  238. // item.isOrder=>disorder
  239. var subject = art.subjects.Find(x => x.id.Equals(item.subject));
  240. var examResponse= await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(item.acId, new PartitionKey($"Exam-{ownerId}"));
  241. if (examResponse.IsSuccessStatusCode)
  242. {
  243. ExamInfo exam = JsonDocument.Parse(examResponse.Content).RootElement.Deserialize<ExamInfo>() ;
  244. var papers = exam.papers.FindAll(x => x.subjectId.Equals(item.subject));
  245. var subjectSync = evaluationSyncInfo.subjects.Find(x => x.examId.Equals(item.acId) && x.subjectId.Equals(item.subject));
  246. if (subjectSync!=null)
  247. {
  248. subjectSync.papers= papers?.Select(x => new SubjectExamPaper { paperId=x.id, paperName=x.name, questionCount=x.answers.IsNotEmpty() ? x.answers.Count() : 0, blob=x.blob, local=$"package/{evaluationSyncInfo.id}/papers/{x.id}" }).ToList();
  249. subjectSync.subjectName=subject.name;
  250. }
  251. else {
  252. evaluationSyncInfo.subjects.Add(new IES.ExamServer.Models.SubjectExam
  253. {
  254. subjectId=item.subject,
  255. subjectName=subject.name,
  256. examId=item.acId,
  257. examName=exam.name,
  258. disorder=item.isOrder.HasValue ? item.isOrder.Value : 0,
  259. papers = papers?.Select(x => new SubjectExamPaper { paperId=x.id, paperName=x.name, questionCount=x.answers.IsNotEmpty() ? x.answers.Count() : 0, blob=x.blob, local=$"package/{evaluationSyncInfo.id}/papers/{x.id}" }).ToList()
  260. });
  261. }
  262. dataTime= dataTime<exam._ts*1000 ? exam._ts*1000 : dataTime;
  263. evaluationSource.artExams.Add(exam);
  264. EvaluationExam evaluationExam = new EvaluationExam()
  265. {
  266. examId=exam.id,
  267. evaluationId=evaluationSyncInfo.id,
  268. examName=evaluationSyncInfo.name,
  269. subjectId=subject.id,
  270. subjectName=subject.name,
  271. classes= evaluationSyncInfo.grouplist,
  272. owner=exam.owner,
  273. scope=scope,
  274. stime=stime,
  275. etime=etime,
  276. disorder=item.isOrder.HasValue?item.isOrder.Value:0,
  277. papers= papers.Select(x => new EvaluationPaper { paperId= x.id, paperName=x.name, blob=x.blob, questionCount=x.answers.IsNotEmpty() ? x.answers.Count() : 0, local=$"package/{evaluationSyncInfo.id}/papers/{x.id}", point=x.point, knowledge=x.knowledge, type=x.type, field=x.field }).ToList(),
  278. };
  279. evaluationExams.Add(evaluationExam);
  280. }
  281. }
  282. }
  283. var quota_22 = art.settings.Find(x => x.id.Equals("quota_22"));
  284. if (quota_22!=null)
  285. {
  286. foreach (var item in quota_22.task)
  287. {
  288. //获取基本技能(智音音乐曲目)
  289. if (item.subject.Equals("subject_music"))
  290. {
  291. string AIMuiscId = string.Empty;
  292. if (!string.IsNullOrWhiteSpace(art.pId))
  293. {
  294. AIMuiscId=art.pId;
  295. }
  296. else {
  297. AIMuiscId=art.id;
  298. }
  299. var artMusicResponse = await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(AIMuiscId, new PartitionKey("ArtMusic"));
  300. if (artMusicResponse.IsSuccessStatusCode)
  301. {
  302. ArtMusic artMusic = JsonDocument.Parse(artMusicResponse.Content).RootElement.Deserialize<ArtMusic>() ;
  303. if (artMusic!=null)
  304. {
  305. evaluationSyncInfo.music= new MusicAI()
  306. {
  307. taskId=item.acId,
  308. examId= art.id,
  309. examName= art.name,
  310. pid=art.pId,
  311. questionId=artMusic.questionId,
  312. questionName=artMusic.questionName,
  313. mustSong=artMusic.mustSong?.Select(x=>new AISong { songId=x.songId,songName=x.songName}).ToList(),
  314. optionSong=artMusic.optionSong?.Select(x => new AISong { songId=x.songId, songName=x.songName }).ToList(),
  315. };
  316. }
  317. }
  318. }
  319. }
  320. }
  321. }
  322. }
  323. break;
  324. default:
  325. break;
  326. }
  327. if (evaluationSyncInfo.subjects.IsNotEmpty() && evaluationSyncInfo.grouplist.IsNotEmpty())
  328. {
  329. long blobTime =-1;
  330. long blobSize = 0;
  331. long blobCount = 0;
  332. if (string.IsNullOrWhiteSpace(evaluationSyncInfo.shortCode))
  333. {
  334. evaluationSyncInfo.shortCode = $"{MurmurHash3.Hash32(evaluationSyncInfo.id)}";
  335. }
  336. if (string.IsNullOrWhiteSpace(evaluationSyncInfo.openCode))
  337. {
  338. StringBuilder builder = new StringBuilder();
  339. for (var i = 0; i < 6; i++)
  340. {
  341. var chars = ExamConstant.AZ_19NI1O0[Random.Shared.Next(0, ExamConstant.AZ_19NI1O0.Length)];
  342. builder.Append(chars);
  343. }
  344. evaluationSyncInfo.openCode = builder.ToString();
  345. }
  346. var listInfo = await GroupListService.GetMemberByListids(_coreAPIHttpService, azureCosmos.GetCosmosClient(), _dingDing, evaluationSyncInfo.grouplist.Select(x=>x.id).ToList(), schoolCode);
  347. foreach (var item in evaluationSyncInfo.grouplist)
  348. {
  349. item.name=listInfo.groups.Find(x => x.id.Equals(item.id))?.name;
  350. }
  351. evaluationSyncInfo.studentCount = listInfo.rmembers.Count();
  352. evaluationSyncInfo.paperCount =evaluationSyncInfo.subjects.SelectMany(x => x.papers).Count();
  353. var client = azureStorage.GetBlobContainerClient(ownerId);
  354. foreach (var subject in evaluationSyncInfo.subjects)
  355. {
  356. var evaluationExam = evaluationExams.FindAll(x => x.subjectId.Equals(subject.subjectId)).FirstOrDefault();
  357. foreach (var paper in subject.papers)
  358. {
  359. EvaluationPaper evaluationPaper = null;
  360. List<BlobHashInfo> blobs = new List<BlobHashInfo>();
  361. try
  362. {
  363. await foreach (BlobItem blobItem in client.GetBlobsAsync(BlobTraits.None, BlobStates.None, !string.IsNullOrWhiteSpace(paper.blob)&& paper.blob.StartsWith("/")?paper.blob.Substring(1):paper.blob ))
  364. {
  365. var lastModified = blobItem.Properties.LastModified;
  366. if (lastModified.HasValue)
  367. {
  368. lastModified.Value.ToUnixTimeMilliseconds();
  369. }
  370. var hash = blobItem.Properties.ContentHash;
  371. var path = blobItem.Name;
  372. var ext = Path.GetExtension(path);
  373. string fileName = Path.GetFileName(path);
  374. if (ext.ToUpper().Equals(ext))
  375. {
  376. string fileNameWithoutExtension = Path.GetFileNameWithoutExtension(path);
  377. fileName= $"{fileNameWithoutExtension!}_1{ext}";
  378. }
  379. var size = blobItem.Properties.ContentLength;
  380. blobs.Add(new BlobHashInfo
  381. {
  382. hash = Md5Hash.GetbyteToString(hash),
  383. last = lastModified.HasValue ? lastModified.Value.ToUnixTimeMilliseconds() : 0 ,
  384. path = path,
  385. size = size.HasValue ? size.Value : 0,
  386. local=$"package/{evaluationSyncInfo.id}/papers/{paper.paperId}/{fileName}"
  387. });
  388. };
  389. evaluationPaper = evaluationExam.papers.Find(x => x.paperId.Equals(paper.paperId));
  390. evaluationPaper.blobs=blobs;
  391. }
  392. catch
  393. {
  394. }
  395. long lastTime = blobs.Max(x => x.last);
  396. blobTime= lastTime>blobTime?lastTime:blobTime;
  397. if (blobs.IsNotEmpty())
  398. {
  399. blobSize+=blobs.Sum(x => x.size);
  400. blobCount+=blobs.Count;
  401. var order = blobs.OrderBy(x => $"{x.path}-{x.hash}-{x.size}-{x.last}");
  402. string blobStr = string.Join(",", order.Select(x=> $"{x.path}-{x.hash}-{x.size}-{x.last}"));
  403. // 计算hash,校准路径,文件hash,文件大小,最后修改时间
  404. string paperHash = ShaHashHelper.GetSHA1(blobStr);
  405. paper.paperHash= paperHash;
  406. evaluationPaper.paperHash= paperHash;
  407. }
  408. }
  409. }
  410. evaluationSyncInfo.blobTime = blobTime> evaluationSyncInfo.blobTime ? blobTime : evaluationSyncInfo.blobTime;
  411. evaluationSyncInfo.blobSize = blobSize;
  412. evaluationSyncInfo.blobCount = blobCount;
  413. evaluationSyncInfo.blobLastHash = evaluationSyncInfo.blobHash;
  414. evaluationSyncInfo.blobHash = ShaHashHelper.GetSHA1(string.Join("-", evaluationSyncInfo.subjects.SelectMany(x => x.papers).Select(x => x.paperHash).OrderBy(x=>x)));
  415. evaluationSyncInfo.dataTime = dataTime.Value;
  416. evaluationSource.updateTime = dataTime.Value;
  417. var groupList = new { members = listInfo.rmembers, groupList = listInfo.groups };
  418. {
  419. //计算数据的hash值
  420. StringBuilder groupListData = new StringBuilder();
  421. //名单的hash值
  422. var orderList = listInfo.groups.OrderBy(x => x.id);
  423. foreach (var item in orderList)
  424. {
  425. groupListData.Append($"{item.id}-{item.name}");
  426. var orderMembers = item.members.OrderBy(x => x.id);
  427. foreach (var member in orderMembers)
  428. {
  429. groupListData.Append($"{member.id}-{member.name}");
  430. }
  431. }
  432. evaluationSyncInfo.grouplistHash= ShaHashHelper.GetSHA1(groupListData.ToString());
  433. var order= evaluationSyncInfo.subjects.OrderBy(x => x.subjectId);
  434. StringBuilder dataStr = new StringBuilder();
  435. dataStr.Append(evaluationSyncInfo.id);
  436. dataStr.Append(evaluationSyncInfo.name);
  437. dataStr.Append(evaluationSyncInfo.type);
  438. dataStr.Append(evaluationSyncInfo.owner);
  439. dataStr.Append(evaluationSyncInfo.ownerId);
  440. dataStr.Append(evaluationSyncInfo.scode);
  441. dataStr.Append(evaluationSyncInfo.scope);
  442. dataStr.Append(evaluationSyncInfo.grouplistHash);
  443. dataStr.Append(evaluationSyncInfo.blobHash);
  444. dataStr.Append(evaluationSyncInfo.shortCode);
  445. dataStr.Append(evaluationSyncInfo.openCode);
  446. dataStr.Append($"{stime}{etime}");
  447. dataStr.Append(string.Join("", order.Select(x=>x.subjectId).OrderBy(x=>x)));
  448. if (evaluationSyncInfo.music!=null)
  449. {
  450. dataStr.Append($"{evaluationSyncInfo.music.questionId}{string.Join("", evaluationSyncInfo.music.mustSong?.Select(x=>x.songId).OrderBy(x=>x))}{string.Join("",evaluationSyncInfo.music.optionSong?.Select(x=>x.songId).OrderBy(x=>x))}");
  451. }
  452. //计算dataHash
  453. evaluationSyncInfo.dataHash = ShaHashHelper.GetSHA1(dataStr.ToString());
  454. }
  455. evaluationClient= new EvaluationClient
  456. {
  457. id = evaluationSyncInfo.id,
  458. pid = evaluationSyncInfo.pid,
  459. name = evaluationSyncInfo.name,
  460. type = evaluationSyncInfo.type,
  461. owner = evaluationSyncInfo.owner,
  462. scode = evaluationSyncInfo.scode,
  463. scope = evaluationSyncInfo.scope,
  464. subjects = evaluationSyncInfo.subjects,
  465. dataTime = evaluationSyncInfo.dataTime,
  466. dataSize = evaluationSyncInfo.dataSize,
  467. blobTime = evaluationSyncInfo.blobTime,
  468. blobSize = evaluationSyncInfo.blobSize,
  469. blobCount = evaluationSyncInfo.blobCount,
  470. blobHash = evaluationSyncInfo.blobHash,
  471. blobLastHash = evaluationSyncInfo.blobLastHash,
  472. //webviewCount = evaluationSyncInfo.webviewCount,
  473. //webviewPath = evaluationSyncInfo.webviewPath,
  474. //webviewSize = evaluationSyncInfo.webviewSize,
  475. //webviewTime = evaluationSyncInfo.webviewTime,
  476. studentCount = evaluationSyncInfo.studentCount,
  477. paperCount = evaluationSyncInfo.paperCount,
  478. grouplist = evaluationSyncInfo.grouplist,
  479. shortCode = evaluationSyncInfo.shortCode,
  480. openCode = evaluationSyncInfo.openCode,
  481. stime=stime,
  482. etime=etime,
  483. dataHash = evaluationSyncInfo.dataHash,
  484. grouplistHash = evaluationSyncInfo.grouplistHash,
  485. ownerId = evaluationSyncInfo.ownerId,
  486. ownerPicture =evaluationSyncInfo.ownerPicture,
  487. ownerName = evaluationSyncInfo.ownerName,
  488. music = evaluationSyncInfo.music,
  489. //password = evaluationSyncInfo.password,
  490. //recordUrl = evaluationSyncInfo.recordUrl
  491. };
  492. if (!string.IsNullOrWhiteSpace(ownerPicture))
  493. {
  494. //教师头像或学校logo 下载转为Base64
  495. HttpResponseMessage message = await _httpClientFactory.CreateClient().GetAsync(ownerPicture);
  496. if (message.IsSuccessStatusCode)
  497. {
  498. string base64Prefix = "data:image/jpeg;base64,";
  499. byte[] fileBytes = await message.Content.ReadAsByteArrayAsync();
  500. ownerPicture =$"{base64Prefix}{Convert.ToBase64String(fileBytes)}";
  501. evaluationClient.ownerPicture = ownerPicture;
  502. }
  503. }
  504. long dataSize = 0;
  505. string sourceJson = evaluationSource.ToJsonString();
  506. dataSize+= Encoding.UTF8.GetByteCount(sourceJson);
  507. string groupListJson = groupList.ToJsonString();
  508. dataSize+= Encoding.UTF8.GetByteCount(groupListJson);
  509. string evaluationJson = new { evaluationClient, evaluationExams }.ToJsonString().ToJsonString();
  510. dataSize+= Encoding.UTF8.GetByteCount(evaluationJson);
  511. string evaluationSyncInfoSJson = evaluationSyncInfo.ToJsonString();
  512. dataSize+= Encoding.UTF8.GetByteCount(evaluationSyncInfoSJson);
  513. evaluationClient.dataSize = dataSize;
  514. //重组blob路径,使之适配局域网端读取。
  515. //evaluationClient.subjects.ForEach(x => {
  516. // x.papers.ForEach(y => {
  517. // y.blob=$"package/{evaluationClient.id}/papers/{y.paperId}";
  518. // });
  519. //});
  520. //evaluationExams.ForEach(x => {
  521. // x.papers.ForEach(y => {
  522. // y.blob=$"package/{evaluationClient.id}/papers/{y.paperId}";
  523. // });
  524. //});
  525. //evaluationSyncInfo.subjects.ForEach(x => {
  526. // x.papers.ForEach(y => {
  527. // y.blob=$"package/{evaluationClient.id}/papers/{y.paperId}";
  528. // });
  529. //});
  530. await azureStorage.GetBlobContainerClient(ownerId).UploadFileByContainer(sourceJson, $"package/{id}/data", "source.json");
  531. await azureStorage.GetBlobContainerClient(ownerId).UploadFileByContainer(groupListJson, $"package/{id}/data", "grouplist.json");
  532. await azureStorage.GetBlobContainerClient(ownerId).UploadFileByContainer(new { evaluationClient, evaluationExams }.ToJsonString(), $"package/{id}/data", "evaluation.json");
  533. evaluationSyncInfo.dataSize = dataSize;
  534. await azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync<EvaluationSyncInfo>(evaluationSyncInfo, new PartitionKey("EvaluationSyncInfo"));
  535. // await azureStorage.GetBlobContainerClient(owner).UploadFileByContainer(evaluationSyncInfo.ToJsonString(), $"package/{id}", "syncinfo.json");
  536. }
  537. return evaluationSyncInfo;
  538. }
  539. }
  540. }