|
|
@@ -33,317 +33,322 @@ namespace TEAMModelFunction
|
|
|
databaseName: "TEAMModelOS",
|
|
|
collectionName: "Common",
|
|
|
ConnectionStringSetting = "Azure:Cosmos:ConnectionString",
|
|
|
- LeaseCollectionName = "leases")]IReadOnlyList<Document> input, ILogger log)
|
|
|
+ LeaseCollectionName = "leases")]IReadOnlyList<Document> inputs, ILogger log)
|
|
|
{
|
|
|
- if (input != null && input.Count > 0)
|
|
|
- {
|
|
|
- log.LogInformation("Documents modified " + input.Count);
|
|
|
- log.LogInformation("First document Id " + input[0].Id);
|
|
|
- }
|
|
|
- string pk = input[0].GetPropertyValue<string>("pk");
|
|
|
- if (!string.IsNullOrEmpty(pk))
|
|
|
+ if (inputs != null && inputs.Count > 0)
|
|
|
{
|
|
|
+ log.LogInformation("Documents modified " + inputs.Count);
|
|
|
+ log.LogInformation("First document Id " + inputs[0].Id);
|
|
|
var client = _azureCosmos.GetCosmosClient();
|
|
|
- long stime = input[0].GetPropertyValue<long>("startTime");
|
|
|
- long etime = input[0].GetPropertyValue<long>("endTime");
|
|
|
- string school = input[0].GetPropertyValue<string>("school");
|
|
|
- string code = input[0].GetPropertyValue<string>("code");
|
|
|
- switch (pk)
|
|
|
+
|
|
|
+ foreach (var input in inputs)
|
|
|
{
|
|
|
- case "Exam":
|
|
|
- ExamInfo info = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ExamInfo>(input[0].Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
- List<ExamClassResult> examClassResults = new List<ExamClassResult>();
|
|
|
- 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}") }))
|
|
|
+ string pk = input.GetPropertyValue<string>("pk");
|
|
|
+ if (!string.IsNullOrWhiteSpace(pk))
|
|
|
+ {
|
|
|
+ long stime = input.GetPropertyValue<long>("startTime");
|
|
|
+ long etime = input.GetPropertyValue<long>("endTime");
|
|
|
+ string school = input.GetPropertyValue<string>("school");
|
|
|
+ string code = input.GetPropertyValue<string>("code");
|
|
|
+ switch (pk)
|
|
|
{
|
|
|
- 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())
|
|
|
+ case "Exam":
|
|
|
+ ExamInfo info = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ExamInfo>(input.Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
+ List<ExamClassResult> examClassResults = new List<ExamClassResult>();
|
|
|
+ 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}") }))
|
|
|
{
|
|
|
- examClassResults.Add(obj.ToObject<ExamClassResult>());
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- List<ChangeRecord> records = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input[0].Id }, { "PartitionKey", info.progress } });
|
|
|
- //ChangeRecord record = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input[0].Id, new Azure.Cosmos.PartitionKey($"{info.progress}"));
|
|
|
- switch (info.progress)
|
|
|
- {
|
|
|
- case "pending":
|
|
|
- var message = new ServiceBusMessage(new { id = input[0].Id, progress = "going", code = code }.ToJsonString());
|
|
|
- message.Properties.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
|
|
|
+ using var json = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
+ if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
|
|
|
{
|
|
|
- RowKey = input[0].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}"));
|
|
|
+ foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
|
|
|
+ {
|
|
|
+ examClassResults.Add(obj.ToObject<ExamClassResult>());
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
- break;
|
|
|
- case "going":
|
|
|
- if (examClassResults.Count < 0)
|
|
|
+
|
|
|
+ List<ChangeRecord> records = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input.Id }, { "PartitionKey", info.progress } });
|
|
|
+ //ChangeRecord record = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input.Id, new Azure.Cosmos.PartitionKey($"{info.progress}"));
|
|
|
+ switch (info.progress)
|
|
|
{
|
|
|
- for (int j = 0; j < info.subjects.Count; j++)
|
|
|
- {
|
|
|
- for (int k = 0; k < info.targetClassIds.Count; k++)
|
|
|
+ case "pending":
|
|
|
+ var message = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
|
+ message.Properties.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
|
|
|
{
|
|
|
- ExamClassResult result = new ExamClassResult();
|
|
|
- result.code = "ExamClassResult-" + info.school;
|
|
|
- result.examId = info.id;
|
|
|
- result.id = Guid.NewGuid().ToString();
|
|
|
- result.subjectId = info.subjects[j].id;
|
|
|
- result.year = info.year;
|
|
|
- result.ttl = -1;
|
|
|
- result.scope = info.scope;
|
|
|
- result.pk = typeof(ExamClassResult).Name;
|
|
|
- result.info.id = info.targetClassIds[k];
|
|
|
- var sresponse = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(info.targetClassIds[k], new Azure.Cosmos.PartitionKey($"Class-{info.school}"));
|
|
|
- if (sresponse.Status == 200)
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", message, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
{
|
|
|
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
|
|
|
- Classroom classroom = json.ToObject<Classroom>();
|
|
|
- result.info.name = classroom.name;
|
|
|
- List<List<string>> ans = new List<List<string>>();
|
|
|
- List<double> ansPoint = new List<double>();
|
|
|
- foreach (double p in info.papers[j].point)
|
|
|
+ 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":
|
|
|
+ if (examClassResults.Count < 0)
|
|
|
+ {
|
|
|
+ for (int j = 0; j < info.subjects.Count; j++)
|
|
|
+ {
|
|
|
+ for (int k = 0; k < info.targetClassIds.Count; k++)
|
|
|
{
|
|
|
- ans.Add(new List<string>());
|
|
|
- ansPoint.Add(-1);
|
|
|
+ ExamClassResult result = new ExamClassResult();
|
|
|
+ result.code = "ExamClassResult-" + info.school;
|
|
|
+ result.examId = info.id;
|
|
|
+ result.id = Guid.NewGuid().ToString();
|
|
|
+ result.subjectId = info.subjects[j].id;
|
|
|
+ result.year = info.year;
|
|
|
+ result.ttl = -1;
|
|
|
+ result.scope = info.scope;
|
|
|
+ result.pk = typeof(ExamClassResult).Name;
|
|
|
+ result.info.id = info.targetClassIds[k];
|
|
|
+ var sresponse = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(info.targetClassIds[k], new Azure.Cosmos.PartitionKey($"Class-{info.school}"));
|
|
|
+ if (sresponse.Status == 200)
|
|
|
+ {
|
|
|
+ using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
|
|
|
+ Classroom classroom = json.ToObject<Classroom>();
|
|
|
+ result.info.name = classroom.name;
|
|
|
+ List<List<string>> ans = new List<List<string>>();
|
|
|
+ List<double> ansPoint = new List<double>();
|
|
|
+ foreach (double p in info.papers[j].point)
|
|
|
+ {
|
|
|
+ ans.Add(new List<string>());
|
|
|
+ ansPoint.Add(-1);
|
|
|
+ }
|
|
|
+ foreach (StudentSimple stu in classroom.students)
|
|
|
+ {
|
|
|
+ result.studentIds.Add(stu.id);
|
|
|
+ result.studentAnswers.Add(ans);
|
|
|
+ result.studentScores.Add(ansPoint);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //result.progress = info.progress;
|
|
|
+ result.school = info.school;
|
|
|
+ await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(result, new Azure.Cosmos.PartitionKey($"{result.code}"));
|
|
|
+
|
|
|
}
|
|
|
- foreach (StudentSimple stu in classroom.students)
|
|
|
+ }
|
|
|
+ var messageEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
|
+ messageEnd.Properties.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
|
|
|
{
|
|
|
- result.studentIds.Add(stu.id);
|
|
|
- result.studentAnswers.Add(ans);
|
|
|
- result.studentScores.Add(ansPoint);
|
|
|
- }
|
|
|
+ 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}"));
|
|
|
}
|
|
|
- //result.progress = info.progress;
|
|
|
- result.school = info.school;
|
|
|
- await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(result, new Azure.Cosmos.PartitionKey($"{result.code}"));
|
|
|
-
|
|
|
}
|
|
|
- }
|
|
|
- var messageEnd = new ServiceBusMessage(new { id = input[0].Id, progress = "finish", code = code }.ToJsonString());
|
|
|
- messageEnd.Properties.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
|
|
|
+ break;
|
|
|
+ case "finish":
|
|
|
+ for (int j = 0; j < info.subjects.Count; j++)
|
|
|
{
|
|
|
- RowKey = input[0].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}"));
|
|
|
- }
|
|
|
- }
|
|
|
- break;
|
|
|
- case "finish":
|
|
|
- for (int j = 0; j < info.subjects.Count; j++)
|
|
|
- {
|
|
|
- if (info.subjects[j].classCount == info.targetClassIds.Count) {
|
|
|
- ExamResult result = new ExamResult();
|
|
|
- //人数总和
|
|
|
- int Count = 0;
|
|
|
- int m = 0;
|
|
|
- List<ClassRange> classRanges = new List<ClassRange>();
|
|
|
- foreach (ExamClassResult classResult in examClassResults)
|
|
|
- {
|
|
|
- if (classResult.subjectId.Equals(info.subjects[j].id))
|
|
|
+ if (info.subjects[j].classCount == info.targetClassIds.Count)
|
|
|
{
|
|
|
- foreach (List<double> scores in classResult.studentScores)
|
|
|
- {
|
|
|
- result.studentScores.Add(scores);
|
|
|
- }
|
|
|
- //处理班级信息
|
|
|
- ClassRange range = new ClassRange();
|
|
|
- range.id = classResult.info.id;
|
|
|
- range.name = classResult.info.name;
|
|
|
- List<int> ran = new List<int>();
|
|
|
- int stuCount = classResult.studentIds.Count;
|
|
|
- Count += stuCount;
|
|
|
- if (m == 0)
|
|
|
+ ExamResult result = new ExamResult();
|
|
|
+ //人数总和
|
|
|
+ int Count = 0;
|
|
|
+ int m = 0;
|
|
|
+ List<ClassRange> classRanges = new List<ClassRange>();
|
|
|
+ foreach (ExamClassResult classResult in examClassResults)
|
|
|
{
|
|
|
- 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);
|
|
|
+ if (classResult.subjectId.Equals(info.subjects[j].id))
|
|
|
+ {
|
|
|
+ foreach (List<double> scores in classResult.studentScores)
|
|
|
+ {
|
|
|
+ result.studentScores.Add(scores);
|
|
|
+ }
|
|
|
+ //处理班级信息
|
|
|
+ ClassRange range = new ClassRange();
|
|
|
+ range.id = classResult.info.id;
|
|
|
+ range.name = classResult.info.name;
|
|
|
+ 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);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
+ result.classes = classRanges;
|
|
|
+ result.ttl = -1;
|
|
|
+ result.pk = typeof(ExamResult).Name;
|
|
|
+ result.code = "ExamResult-" + info.id;
|
|
|
+ result.school = info.school;
|
|
|
+ result.id = info.subjects[j].id;
|
|
|
+ result.examId = info.id;
|
|
|
+ result.subjectId = info.subjects[j].id;
|
|
|
+ result.year = info.year;
|
|
|
+ result.paper = info.papers[j];
|
|
|
+ result.point = info.papers[j].point;
|
|
|
+ result.scope = info.scope;
|
|
|
+ result.name = info.name;
|
|
|
+ //result.time
|
|
|
+ await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Common").UpsertItemAsync(result, new Azure.Cosmos.PartitionKey($"ExamResult-{info.id}"));
|
|
|
}
|
|
|
}
|
|
|
- result.classes = classRanges;
|
|
|
- result.ttl = -1;
|
|
|
- result.pk = typeof(ExamResult).Name;
|
|
|
- result.code = "ExamResult-" + info.id;
|
|
|
- result.school = info.school;
|
|
|
- result.id = info.subjects[j].id;
|
|
|
- result.examId = info.id;
|
|
|
- result.subjectId = info.subjects[j].id;
|
|
|
- result.year = info.year;
|
|
|
- result.paper = info.papers[j];
|
|
|
- result.point = info.papers[j].point;
|
|
|
- result.scope = info.scope;
|
|
|
- result.name = info.name;
|
|
|
- //result.time
|
|
|
- await _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Common").UpsertItemAsync(result, new Azure.Cosmos.PartitionKey($"ExamResult-{info.id}"));
|
|
|
- }
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- break;
|
|
|
- case "Vote":
|
|
|
- Vote vote = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Vote>(input[0].Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
- List<ChangeRecord> voteRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input[0].Id }, { "PartitionKey", vote.progress } });
|
|
|
- //ChangeRecord voteRecord = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input[0].Id, new Azure.Cosmos.PartitionKey($"{vote.progress}"));
|
|
|
- switch (vote.progress)
|
|
|
- {
|
|
|
- case "pending":
|
|
|
- var messageVote = new ServiceBusMessage(new { id = input[0].Id, progress = "going", code = code }.ToJsonString());
|
|
|
- messageVote.Properties.Add("name", "Vote");
|
|
|
- if (voteRecords.Count > 0)
|
|
|
- {
|
|
|
- long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
- await _serviceBus.GetServiceBusClient().cancelMessage("active-task", voteRecords[0].sequenceNumber);
|
|
|
- voteRecords[0].sequenceNumber = start;
|
|
|
- await _azureStorage.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(voteRecord, voteRecord.id, new Azure.Cosmos.PartitionKey($"{voteRecord.code}"));
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
- ChangeRecord changeRecord = new ChangeRecord
|
|
|
- {
|
|
|
- RowKey = input[0].Id,
|
|
|
- PartitionKey = "pending",
|
|
|
- sequenceNumber = start,
|
|
|
- msgId = messageVote.MessageId
|
|
|
- };
|
|
|
- await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
- }
|
|
|
- break;
|
|
|
- case "going":
|
|
|
- var messageVoteEnd = new ServiceBusMessage(new { id = input[0].Id, progress = "finish", code = code }.ToJsonString());
|
|
|
- messageVoteEnd.Properties.Add("name", "Vote");
|
|
|
- if (voteRecords.Count > 0)
|
|
|
- {
|
|
|
- long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
- await _serviceBus.GetServiceBusClient().cancelMessage("active-task", voteRecords[0].sequenceNumber);
|
|
|
- voteRecords[0].sequenceNumber = end;
|
|
|
- await _azureStorage.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(voteRecord, voteRecord.id, new Azure.Cosmos.PartitionKey($"{voteRecord.code}"));
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
- ChangeRecord changeRecord = new ChangeRecord
|
|
|
- {
|
|
|
- RowKey = input[0].Id,
|
|
|
- PartitionKey = "going",
|
|
|
- sequenceNumber = end,
|
|
|
- msgId = messageVoteEnd.MessageId
|
|
|
- };
|
|
|
- await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ break;
|
|
|
}
|
|
|
break;
|
|
|
- }
|
|
|
- break;
|
|
|
- case "Survey":
|
|
|
- Survey survey = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Survey>(input[0].Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
- //messageSurvey.ScheduledEnqueueTime = DateTimeOffset.FromUnixTimeMilliseconds(stime);
|
|
|
- //string msgid = messageSurvey.MessageId;
|
|
|
- List<ChangeRecord> changeRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input[0].Id },{"PartitionKey", survey.progress} });
|
|
|
- //ChangeRecord surveyRecord = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input[0].Id, new Azure.Cosmos.PartitionKey($"{survey.progress}"));
|
|
|
- switch (survey.progress)
|
|
|
- {
|
|
|
- case "pending":
|
|
|
- var messageSurvey = new ServiceBusMessage(new { id = input[0].Id, progress = "going", code = code }.ToJsonString());
|
|
|
- messageSurvey.Properties.Add("name", "Survey");
|
|
|
- if (changeRecords.Count > 0)
|
|
|
- {
|
|
|
- await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
|
- long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurvey, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
- changeRecords[0].sequenceNumber = start;
|
|
|
- await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(surveyRecord, surveyRecord.id, new Azure.Cosmos.PartitionKey($"{surveyRecord.code}"));
|
|
|
- }
|
|
|
- else
|
|
|
+ case "Vote":
|
|
|
+ Vote vote = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Vote>(input.Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
+ List<ChangeRecord> voteRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input.Id }, { "PartitionKey", vote.progress } });
|
|
|
+ //ChangeRecord voteRecord = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input.Id, new Azure.Cosmos.PartitionKey($"{vote.progress}"));
|
|
|
+ switch (vote.progress)
|
|
|
{
|
|
|
- long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurvey, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
- ChangeRecord changeRecord = new ChangeRecord
|
|
|
- {
|
|
|
- RowKey = input[0].Id,
|
|
|
- PartitionKey = "pending",
|
|
|
- sequenceNumber = start,
|
|
|
- msgId = messageSurvey.MessageId
|
|
|
- };
|
|
|
- await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ case "pending":
|
|
|
+ var messageVote = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
|
+ messageVote.Properties.Add("name", "Vote");
|
|
|
+ if (voteRecords.Count > 0)
|
|
|
+ {
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", voteRecords[0].sequenceNumber);
|
|
|
+ voteRecords[0].sequenceNumber = start;
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(voteRecord, voteRecord.id, new Azure.Cosmos.PartitionKey($"{voteRecord.code}"));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
+ {
|
|
|
+ RowKey = input.Id,
|
|
|
+ PartitionKey = "pending",
|
|
|
+ sequenceNumber = start,
|
|
|
+ msgId = messageVote.MessageId
|
|
|
+ };
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "going":
|
|
|
+ var messageVoteEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
|
+ messageVoteEnd.Properties.Add("name", "Vote");
|
|
|
+ if (voteRecords.Count > 0)
|
|
|
+ {
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", voteRecords[0].sequenceNumber);
|
|
|
+ voteRecords[0].sequenceNumber = end;
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(voteRecords[0]);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(voteRecord, voteRecord.id, new Azure.Cosmos.PartitionKey($"{voteRecord.code}"));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
+ {
|
|
|
+ RowKey = input.Id,
|
|
|
+ PartitionKey = "going",
|
|
|
+ sequenceNumber = end,
|
|
|
+ msgId = messageVoteEnd.MessageId
|
|
|
+ };
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ }
|
|
|
+ break;
|
|
|
}
|
|
|
break;
|
|
|
- case "going":
|
|
|
- var messageSurveyEnd = new ServiceBusMessage(new { id = input[0].Id, progress = "finish", code = code }.ToJsonString());
|
|
|
- messageSurveyEnd.Properties.Add("name", "Survey");
|
|
|
- if (changeRecords.Count > 0)
|
|
|
+ case "Survey":
|
|
|
+ Survey survey = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Survey>(input.Id, new Azure.Cosmos.PartitionKey($"{code}"));
|
|
|
+ //messageSurvey.ScheduledEnqueueTime = DateTimeOffset.FromUnixTimeMilliseconds(stime);
|
|
|
+ //string msgid = messageSurvey.MessageId;
|
|
|
+ List<ChangeRecord> changeRecords = await _azureStorage.FindListByDict<ChangeRecord>(new Dictionary<string, object>() { { "RowKey", input.Id }, { "PartitionKey", survey.progress } });
|
|
|
+ //ChangeRecord surveyRecord = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<ChangeRecord>(input.Id, new Azure.Cosmos.PartitionKey($"{survey.progress}"));
|
|
|
+ switch (survey.progress)
|
|
|
{
|
|
|
- long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
- await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
|
- changeRecords[0].sequenceNumber = end;
|
|
|
- await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
- ChangeRecord changeRecord = new ChangeRecord
|
|
|
- {
|
|
|
- RowKey = input[0].Id,
|
|
|
- PartitionKey = "going",
|
|
|
- sequenceNumber = end,
|
|
|
- msgId = messageSurveyEnd.MessageId
|
|
|
- };
|
|
|
- await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
- //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ case "pending":
|
|
|
+ var messageSurvey = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
|
+ messageSurvey.Properties.Add("name", "Survey");
|
|
|
+ if (changeRecords.Count > 0)
|
|
|
+ {
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurvey, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
+ changeRecords[0].sequenceNumber = start;
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(surveyRecord, surveyRecord.id, new Azure.Cosmos.PartitionKey($"{surveyRecord.code}"));
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurvey, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
+ {
|
|
|
+ RowKey = input.Id,
|
|
|
+ PartitionKey = "pending",
|
|
|
+ sequenceNumber = start,
|
|
|
+ msgId = messageSurvey.MessageId
|
|
|
+ };
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ case "going":
|
|
|
+ var messageSurveyEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
|
+ messageSurveyEnd.Properties.Add("name", "Survey");
|
|
|
+ if (changeRecords.Count > 0)
|
|
|
+ {
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
+ await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
|
+ changeRecords[0].sequenceNumber = end;
|
|
|
+ await _azureStorage.SaveOrUpdate<ChangeRecord>(changeRecords[0]);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
|
+ ChangeRecord changeRecord = new ChangeRecord
|
|
|
+ {
|
|
|
+ RowKey = input.Id,
|
|
|
+ PartitionKey = "going",
|
|
|
+ sequenceNumber = end,
|
|
|
+ msgId = messageSurveyEnd.MessageId
|
|
|
+ };
|
|
|
+ await _azureStorage.Save<ChangeRecord>(changeRecord);
|
|
|
+ //await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(changeRecord, new Azure.Cosmos.PartitionKey($"{changeRecord.code}"));
|
|
|
+ }
|
|
|
+ break;
|
|
|
}
|
|
|
break;
|
|
|
- }
|
|
|
- break;
|
|
|
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
JAELYS