|
@@ -0,0 +1,580 @@
|
|
|
|
+using Azure.Cosmos;
|
|
|
|
+using Azure.Messaging.ServiceBus;
|
|
|
|
+using Microsoft.Azure.Documents;
|
|
|
|
+using System;
|
|
|
|
+using System.Collections.Generic;
|
|
|
|
+using System.Linq;
|
|
|
|
+using System.Text;
|
|
|
|
+using System.Text.Json;
|
|
|
|
+using System.Threading.Tasks;
|
|
|
|
+using TEAMModelOS.SDK.DI;
|
|
|
|
+using TEAMModelOS.SDK.Extension;
|
|
|
|
+using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
|
|
|
|
+using TEAMModelOS.SDK.Models;
|
|
|
|
+using TEAMModelOS.SDK.Models.Cosmos;
|
|
|
|
+using TEAMModelOS.SDK.Models.Cosmos.Common;
|
|
|
|
+
|
|
|
|
+namespace TEAMModelFunction
|
|
|
|
+{
|
|
|
|
+ public class TriggerExam
|
|
|
|
+ {
|
|
|
|
+ public static async void Trigger(AzureCosmosFactory _azureCosmos, AzureServiceBusFactory _serviceBus, AzureStorageFactory _azureStorage, DingDing _dingDing,
|
|
|
|
+ CosmosClient client, Document input ,string code,long stime,long etime, string school)
|
|
|
|
+ {
|
|
|
|
+ ExamInfo info = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ExamInfo>(input.Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
|
+ List<ExamClassResult> examClassResults = new List<ExamClassResult>();
|
|
|
|
+ List<ExamSubject> examSubjects = new List<ExamSubject>();
|
|
|
|
+ if (info.scope.Equals("teacher", StringComparison.OrdinalIgnoreCase) || info.scope.Equals("private", StringComparison.OrdinalIgnoreCase))
|
|
|
|
+ {
|
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select value(c) from c where c.examId = '{info.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamClassResult-{info.creatorId}") }))
|
|
|
|
+ {
|
|
|
|
+ using var json = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
|
+ if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
|
|
|
|
+ {
|
|
|
|
+ foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
|
|
|
|
+ {
|
|
|
|
+ examClassResults.Add(obj.ToObject<ExamClassResult>());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select value(c) from c where c.examId = '{info.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamClassResult-{school}") }))
|
|
|
|
+ {
|
|
|
|
+ using var json = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
|
+ if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
|
|
|
|
+ {
|
|
|
|
+ foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
|
|
|
|
+ {
|
|
|
|
+ examClassResults.Add(obj.ToObject<ExamClassResult>());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ List<ChangeRecord> records = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input.Id }, { "PartitionKey", info.progress } });
|
|
|
|
+ //处理科目信息
|
|
|
|
+ List<string> sub = new List<string>();
|
|
|
|
+ foreach (ExamSubject subject in info.subjects)
|
|
|
|
+ {
|
|
|
|
+ sub.Add(subject.id);
|
|
|
|
+ }
|
|
|
|
+ //ChangeRecord record = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input.Id, new Azure.Cosmos.PartitionKey($"{info.progress}"));
|
|
|
|
+ switch (info.progress)
|
|
|
|
+ {
|
|
|
|
+ case "pending":
|
|
|
|
+ var message = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
|
|
+ message.ApplicationProperties.Add("name", "Exam");
|
|
|
|
+ if (records.Count > 0)
|
|
|
|
+ {
|
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", records[0].sequenceNumber);
|
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", message, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
|
+ records[0].sequenceNumber = start;
|
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(records[0]);
|
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(record, record.id, new Azure.Cosmos.PartitionKey($"{record.code}"));
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", message, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
|
+ {
|
|
|
|
+ RowKey = input.Id,
|
|
|
|
+ PartitionKey = "pending",
|
|
|
|
+ sequenceNumber = start,
|
|
|
|
+ msgId = message.MessageId
|
|
|
|
+ };
|
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ case "going":
|
|
|
|
+ //ActivityData data;
|
|
|
|
+ //if (info.scope == "school")
|
|
|
|
+ //{
|
|
|
|
+ // data = new ActivityData
|
|
|
|
+ // {
|
|
|
|
+ // id = info.id,
|
|
|
|
+ // code = $"Activity-{info.school}",
|
|
|
|
+ // type = "exam",
|
|
|
|
+ // name = info.name,
|
|
|
|
+ // startTime = info.startTime,
|
|
|
|
+ // endTime = info.endTime,
|
|
|
|
+ // scode = info.code,
|
|
|
|
+ // scope = info.scope,
|
|
|
|
+ // classes = info.classes.IsNotEmpty() ? info.classes : new List<string> { "" },
|
|
|
|
+ // tmdids = new List<string> { "" },
|
|
|
|
+ // progress = "going",
|
|
|
|
+ // subjects = sub
|
|
|
|
+ // };
|
|
|
|
+ // await client.GetContainer("TEAMModelOS", "School").UpsertItemAsync<ActivityData>(data, new Azure.Cosmos.PartitionKey(data.code));
|
|
|
|
+ //}
|
|
|
|
+ //else if (info.scope == "private")
|
|
|
|
+ //{
|
|
|
|
+ // data = new ActivityData
|
|
|
|
+ // {
|
|
|
|
+ // id = info.id,
|
|
|
|
+ // code = $"Activity-Common",
|
|
|
|
+ // type = "exam",
|
|
|
|
+ // name = info.name,
|
|
|
|
+ // startTime = info.startTime,
|
|
|
|
+ // endTime = info.endTime,
|
|
|
|
+ // scode = info.code,
|
|
|
|
+ // scope = info.scope,
|
|
|
|
+ // progress = "going",
|
|
|
|
+ // classes = info.classes.IsNotEmpty() ? info.classes : new List<string> { "" },
|
|
|
|
+ // tmdids = new List<string> { "" },
|
|
|
|
+ // subjects = sub
|
|
|
|
+ // };
|
|
|
|
+ // await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync<ActivityData>(data, new Azure.Cosmos.PartitionKey(data.code));
|
|
|
|
+ //}
|
|
|
|
+ (List<string> tmdids, List<Students> studentss) = await TriggerStuActivity.GetStuList(client, info.classes, info.school);
|
|
|
|
+ List<StuActivity> stuActivities = new List<StuActivity>();
|
|
|
|
+ List<StuActivity> tmdActivities = new List<StuActivity>();
|
|
|
|
+ if (tmdids.IsNotEmpty())
|
|
|
|
+ {
|
|
|
|
+ tmdids.ForEach(x => {
|
|
|
|
+ tmdActivities.Add(new StuActivity
|
|
|
|
+ {
|
|
|
|
+ pk = "Activity",
|
|
|
|
+ id = info.id,
|
|
|
|
+ code = $"Activity-{x}",
|
|
|
|
+ type = "exam",
|
|
|
|
+ name = info.name,
|
|
|
|
+ startTime = info.startTime,
|
|
|
|
+ endTime = info.endTime,
|
|
|
|
+ scode = info.code,
|
|
|
|
+ scope = info.scope,
|
|
|
|
+ school = info.school,
|
|
|
|
+ creatorId = info.creatorId,
|
|
|
|
+ subjects = sub,
|
|
|
|
+ blob = null
|
|
|
|
+
|
|
|
|
+ });
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+ if (studentss.IsNotEmpty())
|
|
|
|
+ {
|
|
|
|
+ studentss.ForEach(x => {
|
|
|
|
+ stuActivities.Add(new StuActivity
|
|
|
|
+ {
|
|
|
|
+ pk = "Activity",
|
|
|
|
+ id = info.id,
|
|
|
|
+ code = $"Activity-{info.school}-{x.id}",
|
|
|
|
+ type = "exam",
|
|
|
|
+ name = info.name,
|
|
|
|
+ startTime = info.startTime,
|
|
|
|
+ endTime = info.endTime,
|
|
|
|
+ scode = info.code,
|
|
|
|
+ scope = info.scope,
|
|
|
|
+ school = info.school,
|
|
|
|
+ creatorId = info.creatorId,
|
|
|
|
+ subjects = sub,
|
|
|
|
+ blob = null
|
|
|
|
+ });
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+ await TriggerStuActivity.SaveStuActivity(client, stuActivities, tmdActivities);
|
|
|
|
+ if (examClassResults.Count == 0)
|
|
|
|
+ {
|
|
|
|
+ foreach (string cla in info.classes)
|
|
|
|
+ {
|
|
|
|
+ int m = 0;
|
|
|
|
+ foreach (ExamSubject subject in info.subjects)
|
|
|
|
+ {
|
|
|
|
+ string classCode = "";
|
|
|
|
+ if (string.IsNullOrEmpty(info.school) || !info.scope.Equals("school",StringComparison.OrdinalIgnoreCase))
|
|
|
|
+ {
|
|
|
|
+ classCode = "ExamClassResult-" + info.creatorId;
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ classCode = "ExamClassResult-" + info.school;
|
|
|
|
+ }
|
|
|
|
+ ExamClassResult result = new ExamClassResult
|
|
|
|
+ {
|
|
|
|
+ code = classCode,
|
|
|
|
+ examId = info.id,
|
|
|
|
+ id = Guid.NewGuid().ToString(),
|
|
|
|
+ subjectId = subject.id,
|
|
|
|
+ year = info.year,
|
|
|
|
+ scope = info.scope
|
|
|
|
+ };
|
|
|
|
+ result.info.id = cla;
|
|
|
|
+ List<string> ans = new List<string>();
|
|
|
|
+ List<double> ansPoint = new List<double>();
|
|
|
|
+ List<string> ids = new List<string>();
|
|
|
|
+ foreach (double p in info.papers[m].point)
|
|
|
|
+ {
|
|
|
|
+ //ans.Add(new List<string>());
|
|
|
|
+ ansPoint.Add(-1);
|
|
|
|
+ }
|
|
|
|
+ var sresponse = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(cla, new Azure.Cosmos.PartitionKey($"Class-{info.school}"));
|
|
|
|
+ if (sresponse.Status == 200)
|
|
|
|
+ {
|
|
|
|
+ using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
|
|
|
|
+ Class classroom = json.ToObject<Class>();
|
|
|
|
+ //result.info.id = classroom.id;
|
|
|
|
+ result.info.name = classroom.name;
|
|
|
|
+ result.gradeId = classroom.gradeId;
|
|
|
|
+ //处理班级人数
|
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Student").GetItemQueryStreamIterator(queryText: $"select c.id from c where c.classId = '{classroom.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{info.school}") }))
|
|
|
|
+ {
|
|
|
|
+ using var json_stu = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
|
+ if (json_stu.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
|
|
|
|
+ {
|
|
|
|
+ var accounts = json_stu.RootElement.GetProperty("Documents").EnumerateArray();
|
|
|
|
+ while (accounts.MoveNext())
|
|
|
|
+ {
|
|
|
|
+ JsonElement account = accounts.Current;
|
|
|
|
+ ids.Add(account.GetProperty("id").GetString());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (info.scope.Equals("private", StringComparison.OrdinalIgnoreCase))
|
|
|
|
+ {
|
|
|
|
+ var stuResponse = await client.GetContainer("TEAMModelOS", "Teacher").ReadItemStreamAsync(cla, new Azure.Cosmos.PartitionKey($"StuList"));
|
|
|
|
+ if (stuResponse.Status == 200) {
|
|
|
|
+ using var json = await JsonDocument.ParseAsync(stuResponse.ContentStream);
|
|
|
|
+ StuList stuList = json.ToObject<StuList>();
|
|
|
|
+ //result.info.id = stuList.id;
|
|
|
|
+ result.info.name = stuList.name;
|
|
|
|
+ //处理发布对象为自选名单(个人)
|
|
|
|
+
|
|
|
|
+ foreach (Students stus in stuList.students)
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+ ids.Add(stus.id);
|
|
|
|
+ }
|
|
|
|
+ if (stuList.tmids.Count > 0)
|
|
|
|
+ {
|
|
|
|
+ foreach (string tid in stuList.tmids)
|
|
|
|
+ {
|
|
|
|
+ ids.Add(tid);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ var stuResponse = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(cla, new Azure.Cosmos.PartitionKey($"StuList-{info.school}"));
|
|
|
|
+ if (stuResponse.Status == 200)
|
|
|
|
+ {
|
|
|
|
+ using var json = await JsonDocument.ParseAsync(stuResponse.ContentStream);
|
|
|
|
+ StuList stuList = json.ToObject<StuList>();
|
|
|
|
+ //result.info.id = stuList.id;
|
|
|
|
+ result.info.name = stuList.name;
|
|
|
|
+ //处理发布对象为自选名单(校本)
|
|
|
|
+ foreach (Students stus in stuList.students)
|
|
|
|
+ {
|
|
|
|
+ ids.Add(stus.id);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ foreach (string stu in ids)
|
|
|
|
+ {
|
|
|
|
+ result.mark.Add("");
|
|
|
|
+ result.studentIds.Add(stu);
|
|
|
|
+ result.studentAnswers.Add(ans);
|
|
|
|
+ result.studentScores.Add(ansPoint);
|
|
|
|
+ result.sum.Add(0);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //result.progress = info.progress;
|
|
|
|
+ result.school = info.school;
|
|
|
|
+ m++;
|
|
|
|
+ await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(result, new Azure.Cosmos.PartitionKey($"{result.code}"));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ // 发送信息通知
|
|
|
|
+ var messageEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
|
|
+ messageEnd.ApplicationProperties.Add("name", "Exam");
|
|
|
|
+ if (records.Count > 0)
|
|
|
|
+ {
|
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", records[0].sequenceNumber);
|
|
|
|
+ records[0].sequenceNumber = end;
|
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(records[0]);
|
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(record, record.id, new Azure.Cosmos.PartitionKey($"{record.code}"));
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
|
+ {
|
|
|
|
+ RowKey = input.Id,
|
|
|
|
+ PartitionKey = "going",
|
|
|
|
+ sequenceNumber = end,
|
|
|
|
+ msgId = messageEnd.MessageId
|
|
|
|
+ };
|
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ //处理单科结算时科目与试卷信息匹配的问题
|
|
|
|
+ int gno = 0;
|
|
|
|
+ foreach (ExamSubject subject in info.subjects)
|
|
|
|
+ {
|
|
|
|
+ if (subject.classCount == info.classes.Count)
|
|
|
|
+ {
|
|
|
|
+ await createClassResultAsync(info, examClassResults, subject, gno,_azureCosmos, _dingDing, _azureStorage);
|
|
|
|
+ }
|
|
|
|
+ gno++;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ case "finish":
|
|
|
|
+ int fno = 0;
|
|
|
|
+ foreach (ExamSubject subject in info.subjects)
|
|
|
|
+ {
|
|
|
|
+ await createClassResultAsync(info, examClassResults, subject, fno, _azureCosmos, _dingDing, _azureStorage);
|
|
|
|
+ fno++;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //计算单次考试简易统计信息
|
|
|
|
+ List<ExamResult> examResults = new List<ExamResult>();
|
|
|
|
+ await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<ExamResult>(
|
|
|
|
+ queryText: $"select value(c) from c where c.examId = '{info.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"ExamResult-{info.id}") }))
|
|
|
|
+ {
|
|
|
|
+ examResults.Add(item);
|
|
|
|
+ }
|
|
|
|
+ //结算单科单班的标准差和平均分
|
|
|
|
+ foreach (ExamClassResult classResult in examClassResults) {
|
|
|
|
+ //标记单科单班总得分
|
|
|
|
+ double subScore = 0;
|
|
|
|
+ //标准差
|
|
|
|
+ double sPowSum = 0;
|
|
|
|
+ var scount = classResult.studentIds.Count;
|
|
|
|
+ foreach (List<double> sc in classResult.studentScores)
|
|
|
|
+ {
|
|
|
|
+ subScore += sc.Sum();
|
|
|
|
+ }
|
|
|
|
+ foreach (string sid in classResult.studentIds)
|
|
|
|
+ {
|
|
|
|
+ double ssc = classResult.studentScores[classResult.studentIds.IndexOf(sid)].Sum();
|
|
|
|
+ sPowSum += Math.Pow(ssc - scount > 0 ? Math.Round(subScore * 1.0 / scount, 2) : 0, 2);
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ classResult.standard = Math.Round(scount > 0 ? Math.Pow(sPowSum / scount, 0.5) : 0, 2);
|
|
|
|
+ classResult.average = scount > 0 ? Math.Round(subScore / scount, 2) : 0;
|
|
|
|
+ await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(classResult, classResult.id, new Azure.Cosmos.PartitionKey($"{classResult.code}"));
|
|
|
|
+ }
|
|
|
|
+ //记录某次考试所有学生得分总分
|
|
|
|
+ double score = 0;
|
|
|
|
+ double allScore = 0;
|
|
|
|
+ int stuCount = 0;
|
|
|
|
+ //整体平均分
|
|
|
|
+ double average = 0;
|
|
|
|
+ //标准差
|
|
|
|
+ double powSum = 0;
|
|
|
|
+ List<string> losStu = new List<string>();
|
|
|
|
+ //先与第一个值取并集
|
|
|
|
+ if (examResults.Count >0 ) {
|
|
|
|
+ losStu.Union(examResults[0].lostStus);
|
|
|
|
+ foreach (ExamResult examResult in examResults)
|
|
|
|
+ {
|
|
|
|
+ if (info.id == examResult.examId)
|
|
|
|
+ {
|
|
|
|
+ foreach (List<double> sc in examResult.studentScores)
|
|
|
|
+ {
|
|
|
|
+ score += sc.Sum();
|
|
|
|
+ }
|
|
|
|
+ stuCount = examResult.studentIds.Count;
|
|
|
|
+ }
|
|
|
|
+ //powSum += Math.Pow(score - examResult.studentIds.Count > 0 ? Math.Round(score * 1.0 / examResult.studentIds.Count, 2) : 0, 2);
|
|
|
|
+ //取交集
|
|
|
|
+ losStu = losStu.Intersect(examResult.lostStus).ToList();
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ double NewsRateScore = stuCount > 0 ? Math.Round(score * 1.0 / stuCount, 2) : 0;
|
|
|
|
+ foreach (PaperSimple simple in info.papers)
|
|
|
|
+ {
|
|
|
|
+ allScore += simple.point.Sum();
|
|
|
|
+ }
|
|
|
|
+ //计算全科标准差
|
|
|
|
+ foreach (string id in examResults[0].studentIds) {
|
|
|
|
+ double sc = 0;
|
|
|
|
+ foreach (ExamResult result in examResults) {
|
|
|
|
+ sc += result.studentScores[result.studentIds.IndexOf(id)].Sum();
|
|
|
|
+ }
|
|
|
|
+ powSum += Math.Pow(sc - NewsRateScore , 2);
|
|
|
|
+ }
|
|
|
|
+ info.standard = Math.Round(examResults[0].studentIds.Count > 0 ? Math.Pow(powSum / examResults[0].studentIds.Count, 0.5) : 0,2);
|
|
|
|
+ double NewsRate= allScore > 0 ? Math.Round(NewsRateScore / allScore * 100,2) : 0;
|
|
|
|
+ info.lostStu = losStu;
|
|
|
|
+ //判断均分是否发生变化,便于实时的更新评测基本信息
|
|
|
|
+ if (info.sRate != NewsRate || info.average != NewsRateScore) {
|
|
|
|
+ info.sRate = NewsRate;
|
|
|
|
+ info.average = NewsRateScore;
|
|
|
|
+ await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync<ExamInfo>(info, info.id, new Azure.Cosmos.PartitionKey(info.code));
|
|
|
|
+ }
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ public static async Task examRecordCount(ExamInfo info, ExamSubject subject, DingDing _dingDing, int no,AzureStorageFactory _azureStorage,ExamResult result) {
|
|
|
|
+ try
|
|
|
|
+ {
|
|
|
|
+ string blobcntr = "";
|
|
|
|
+ if (info.scope.Equals("school"))
|
|
|
|
+ {
|
|
|
|
+ blobcntr = info.school;
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ blobcntr = info.creatorId;
|
|
|
|
+ }
|
|
|
|
+ var ContainerClient = _azureStorage.GetBlobContainerClient(blobcntr);
|
|
|
|
+ List<string> items = await ContainerClient.List($"exam/{info.id}/{subject.id}");
|
|
|
|
+ List<List<List<string>>> ansList = new List<List<List<string>>>();
|
|
|
|
+ foreach (string item in items)
|
|
|
|
+ {
|
|
|
|
+ var Download = await _azureStorage.GetBlobContainerClient(blobcntr).GetBlobClient(item).DownloadAsync();
|
|
|
|
+ var json = await JsonDocument.ParseAsync(Download.Value.Content);
|
|
|
|
+ var Record = json.RootElement.ToObject<List<List<string>>>();
|
|
|
|
+ ansList.Add(Record);
|
|
|
|
+ }
|
|
|
|
+ /*foreach (List<string> str in info.papers[no].answers) {
|
|
|
|
+
|
|
|
|
+ }*/
|
|
|
|
+ List<Dictionary<string, int>> recorde = new List<Dictionary<string, int>>();
|
|
|
|
+ for (int i = 0;i< info.papers[no].answers.Count;i++) {
|
|
|
|
+ if (info.papers[no].answers[i].Count <= 0) {
|
|
|
|
+ recorde.Add(new Dictionary<string, int>());
|
|
|
|
+ continue;
|
|
|
|
+ }
|
|
|
|
+ Dictionary<string, int> optCount = new Dictionary<string, int>();
|
|
|
|
+ foreach (List<List<string>> stu in ansList) {
|
|
|
|
+ if (stu.Count == info.papers[no].answers.Count) {
|
|
|
|
+
|
|
|
|
+ var item = stu[i];
|
|
|
|
+ foreach (string opt in item) {
|
|
|
|
+ if (optCount.ContainsKey(opt))
|
|
|
|
+ {
|
|
|
|
+ optCount[opt] = optCount[opt] + 1;
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ optCount[opt] = 1;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ recorde.Add(optCount);
|
|
|
|
+ }
|
|
|
|
+ result.record = recorde;
|
|
|
|
+ }
|
|
|
|
+ catch (Exception ex)
|
|
|
|
+ {
|
|
|
|
+ await _dingDing.SendBotMsg($"评测作答记录结算异常{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ public static async Task createClassResultAsync(ExamInfo info, List<ExamClassResult> examClassResults, ExamSubject subject, int no, AzureCosmosFactory _azureCosmos, DingDing _dingDing, AzureStorageFactory _azureStorage)
|
|
|
|
+ {
|
|
|
|
+ //保证试卷信息与科目信息同步
|
|
|
|
+ ExamResult result = new ExamResult();
|
|
|
|
+ //人数总和
|
|
|
|
+ int Count = 0;
|
|
|
|
+ int m = 0;
|
|
|
|
+ double score = 0;
|
|
|
|
+ //标准差
|
|
|
|
+ double powSum = 0;
|
|
|
|
+ double allScore = info.papers[no].point.Sum();
|
|
|
|
+ List<ClassRange> classRanges = new List<ClassRange>();
|
|
|
|
+ List<string> lostStu = new List<string>();
|
|
|
|
+ List<double> csRate = new List<double>();
|
|
|
|
+ foreach (ExamClassResult classResult in examClassResults)
|
|
|
|
+ {
|
|
|
|
+ double classSrate = 0;
|
|
|
|
+ if (classResult.subjectId.Equals(subject.id))
|
|
|
|
+ {
|
|
|
|
+ //记录缺考学生索引位置
|
|
|
|
+ int index = 0;
|
|
|
|
+ foreach (List<double> scores in classResult.studentScores)
|
|
|
|
+ {
|
|
|
|
+ List<double> newScores = new List<double>();
|
|
|
|
+ int count = 0;
|
|
|
|
+ foreach (double sc in scores) {
|
|
|
|
+ newScores.Add(sc > -1 ? sc : 0);
|
|
|
|
+ if(sc == -1) {
|
|
|
|
+ count++;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (count == scores.Count) {
|
|
|
|
+ lostStu.Add(classResult.studentIds[index]);
|
|
|
|
+ //mcount++;
|
|
|
|
+ }
|
|
|
|
+ classSrate += newScores.Sum();
|
|
|
|
+ score += newScores.Sum();
|
|
|
|
+ result.studentScores.Add(newScores);
|
|
|
|
+ index++;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //处理班级信息
|
|
|
|
+ ClassRange range = new ClassRange();
|
|
|
|
+ range.id = classResult.info.id;
|
|
|
|
+ range.name = classResult.info.name;
|
|
|
|
+ range.gradeId = classResult.gradeId;
|
|
|
|
+ List<int> ran = new List<int>();
|
|
|
|
+ int stuCount = classResult.studentIds.Count;
|
|
|
|
+ Count += stuCount;
|
|
|
|
+ if (m == 0)
|
|
|
|
+ {
|
|
|
|
+ ran.Add(0);
|
|
|
|
+ ran.Add(stuCount - 1);
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ ran.Add(Count - stuCount);
|
|
|
|
+ ran.Add(Count - 1);
|
|
|
|
+ }
|
|
|
|
+ m++;
|
|
|
|
+ range.range = ran;
|
|
|
|
+ classRanges.Add(range);
|
|
|
|
+ //处理学生ID
|
|
|
|
+ foreach (string id in classResult.studentIds)
|
|
|
|
+ {
|
|
|
|
+ result.studentIds.Add(id);
|
|
|
|
+ }
|
|
|
|
+ csRate.Add(result.studentIds.Count > 0 ? Math.Round(classSrate * 1.0 / classResult.studentIds.Count, 2) : 0 / allScore);
|
|
|
|
+ //powSum += Math.Pow(classSrate - result.average, 2);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ result.average = result.studentIds.Count > 0 ? Math.Round(score * 1.0 / result.studentIds.Count, 2) : 0;
|
|
|
|
+ foreach (ExamClassResult classResult in examClassResults) {
|
|
|
|
+
|
|
|
|
+ //double classSrate = 0;
|
|
|
|
+ if (classResult.subjectId.Equals(subject.id))
|
|
|
|
+ {
|
|
|
|
+ foreach (string id in classResult.studentIds)
|
|
|
|
+ {
|
|
|
|
+ double sc = classResult.studentScores[classResult.studentIds.IndexOf(id)].Sum();
|
|
|
|
+ powSum += Math.Pow(sc - result.average, 2);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ //处理选项计数内容
|
|
|
|
+ await examRecordCount(info, subject, _dingDing, no, _azureStorage, result);
|
|
|
|
+ result.standard = Math.Round(result.studentIds.Count > 0 ? Math.Pow(powSum / result.studentIds.Count, 0.5) : 0,2);
|
|
|
|
+ result.csRate = csRate;
|
|
|
|
+ result.lostStus = lostStu;
|
|
|
|
+
|
|
|
|
+ result.sRate = Math.Round(result.average / allScore * 100, 2);
|
|
|
|
+ result.classes = classRanges;
|
|
|
|
+ result.code = "ExamResult-" + info.id;
|
|
|
|
+ result.school = info.school;
|
|
|
|
+ result.id = subject.id;
|
|
|
|
+ result.examId = info.id;
|
|
|
|
+ result.subjectId = subject.id;
|
|
|
|
+ result.year = info.year;
|
|
|
|
+ result.paper = info.papers[no];
|
|
|
|
+ //result.point = info.papers[j].point;
|
|
|
|
+ result.scope = info.scope;
|
|
|
|
+ result.name = info.name;
|
|
|
|
+ result.time = info.startTime;
|
|
|
|
+
|
|
|
|
+ await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Common").UpsertItemAsync(result, new Azure.Cosmos.PartitionKey($"ExamResult-{info.id}"));
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+}
|