|
@@ -1338,15 +1338,19 @@ namespace TEAMModelOS.FunctionV4.ServiceBus
|
|
case "up-base":
|
|
case "up-base":
|
|
|
|
|
|
//读取TimeLine.json
|
|
//读取TimeLine.json
|
|
|
|
+ List<string> PickupMemberIds = new List<string>();
|
|
try
|
|
try
|
|
{
|
|
{
|
|
BlobDownloadResult timeLineBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/TimeLine.json").DownloadContentAsync();
|
|
BlobDownloadResult timeLineBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/TimeLine.json").DownloadContentAsync();
|
|
TimeLineData timeLineData = timeLineBlobDownload.Content.ToObjectFromJson<TimeLineData>();
|
|
TimeLineData timeLineData = timeLineBlobDownload.Content.ToObjectFromJson<TimeLineData>();
|
|
lessonRecord.hitaClientCmpCount = timeLineData.events.Where(z => !string.IsNullOrWhiteSpace(z.WrkCmpSrcType) && z.WrkCmpSrcType.Equals("HitaClientCmp")).Count();
|
|
lessonRecord.hitaClientCmpCount = timeLineData.events.Where(z => !string.IsNullOrWhiteSpace(z.WrkCmpSrcType) && z.WrkCmpSrcType.Equals("HitaClientCmp")).Count();
|
|
//lessonRecord.collateTaskCount = lessonRecord.hitaClientCmpCount;
|
|
//lessonRecord.collateTaskCount = lessonRecord.hitaClientCmpCount;
|
|
- List<TimeLineEvent> timeLineEvents= timeLineData.events.FindAll(z => !string.IsNullOrWhiteSpace(z.Event) && z.Event.Equals("PickupResult"));
|
|
|
|
- if (timeLineEvents.IsNotEmpty()) {
|
|
|
|
-
|
|
|
|
|
|
+ List<TimeLineEvent> timeLineEvents = timeLineData.events.FindAll(z => !string.IsNullOrWhiteSpace(z.Event) && z.Event.Equals("PickupResult"));
|
|
|
|
+ if (timeLineEvents.IsNotEmpty()) {
|
|
|
|
+ foreach (var timeLineEvent in timeLineEvents) {
|
|
|
|
+ var memberIds= timeLineEvent.PickupMemberId.ToObject<List<string>>();
|
|
|
|
+ PickupMemberIds.AddRange(memberIds);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
@@ -1357,11 +1361,11 @@ namespace TEAMModelOS.FunctionV4.ServiceBus
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//读取Task.json
|
|
//读取Task.json
|
|
|
|
+ List<TaskData> taskDatas = new List<TaskData>();
|
|
try
|
|
try
|
|
{
|
|
{
|
|
BlobDownloadResult taskBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/Task.json").DownloadContentAsync();
|
|
BlobDownloadResult taskBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/Task.json").DownloadContentAsync();
|
|
- List<TaskData> timeLineData = taskBlobDownload.Content.ToObjectFromJson<List<TaskData>>();
|
|
|
|
-
|
|
|
|
|
|
+ taskDatas = taskBlobDownload.Content.ToObjectFromJson<List<TaskData>>();
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
{
|
|
{
|
|
@@ -1371,10 +1375,11 @@ namespace TEAMModelOS.FunctionV4.ServiceBus
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//读取IRS.json
|
|
//读取IRS.json
|
|
|
|
+ List<IRSData> iRSDatas = new List<IRSData>();
|
|
try
|
|
try
|
|
{
|
|
{
|
|
BlobDownloadResult irsBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/IRS.json").DownloadContentAsync();
|
|
BlobDownloadResult irsBlobDownload = await _azureStorage.GetBlobContainerClient(blobname).GetBlobClient($"/records/{_lessonId}/IES/IRS.json").DownloadContentAsync();
|
|
- List<IRSData> iRSDatas = irsBlobDownload.Content.ToObjectFromJson<List<IRSData>>();
|
|
|
|
|
|
+ iRSDatas = irsBlobDownload.Content.ToObjectFromJson<List<IRSData>>();
|
|
|
|
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
@@ -1536,7 +1541,7 @@ namespace TEAMModelOS.FunctionV4.ServiceBus
|
|
//await _dingDing.SendBotMsg($"{_option.Location},课堂id:{_lessonId} blob刷新完成!", GroupNames.醍摩豆服務運維群組);
|
|
//await _dingDing.SendBotMsg($"{_option.Location},课堂id:{_lessonId} blob刷新完成!", GroupNames.醍摩豆服務運維群組);
|
|
await BlobService.RefreshBlobRoot(new BlobRefreshMessage { progress = "update", root = "records", name = $"{blobname}" }, _serviceBus, _configuration, _azureRedis);
|
|
await BlobService.RefreshBlobRoot(new BlobRefreshMessage { progress = "update", root = "records", name = $"{blobname}" }, _serviceBus, _configuration, _azureRedis);
|
|
msgs.Add(update);
|
|
msgs.Add(update);
|
|
- DoLessonStudentRecord(_dingDing, _snowflakeId, lessonRecord, scope, client, school, tmdid, teacher, _serviceBus, _azureStorage, _configuration, lessonBase,_azureRedis);
|
|
|
|
|
|
+ DoLessonStudentRecord(_dingDing, _snowflakeId, lessonRecord, scope, client, school, tmdid, teacher, _serviceBus, _azureStorage, _configuration, lessonBase,_azureRedis ,PickupMemberIds ,taskDatas,iRSDatas );
|
|
|
|
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|