EvaluationSyncInfoService.cs 31 KB

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