TEAMModelOS/TEAMModelOS/Controllers/Both/LessonRecordController.cs

using Microsoft.Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Cors;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Text.Json;
using System.Text.Json.Nodes;
using System.Threading.Tasks;
using TEAMModelOS.Filter;
using TEAMModelOS.Models;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Models.Cosmos.OpenEntity;
using TEAMModelOS.SDK.Models.Service;
using Azure.Storage.Sas;
using TEAMModelOS.SDK.Models.Dtos;


namespace TEAMModelOS.Controllers
{
    /// <summary>
    /// 课堂记录
    /// </summary>
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    [Route("common/lesson-record")]
    [ApiController]
    
    public class LessonRecordController : ControllerBase
    {

       
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly SnowflakeId _snowflakeId;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        public IConfiguration _configuration { get; set; }
        public LessonRecordController(AzureCosmosFactory azureCosmos, AzureServiceBusFactory serviceBus, SnowflakeId snowflakeId, DingDing dingDing,
           IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, IConfiguration configuration)
        {
            _azureCosmos = azureCosmos;
            _serviceBus = serviceBus;
            _snowflakeId = snowflakeId;
            _dingDing = dingDing;
            _option = option?.Value;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _configuration = configuration;
        }
        /// <summary>
        /// 更新课堂记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("update-lesson-baseinfo")]


#if !DEBUG
        [AuthToken(Roles = "teacher,admin")]
        [Authorize(Roles = "IES")]
#endif
        public async Task<IActionResult> UpdateLessonBaseInfo(JsonElement request)
        {
            var client = _azureCosmos.GetCosmosClient();
            if (!request.TryGetProperty("lesson_id", out JsonElement _lessonId)) return BadRequest();
            if (!request.TryGetProperty("tmdid", out JsonElement _tmdid)) return BadRequest();
            request.TryGetProperty("school", out JsonElement _school);
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            if (!request.TryGetProperty("grant_types", out JsonElement _grant_types)) return BadRequest();
            string tbname ;
            string code ;

            if (_scope.GetString().Equals("school") && !string.IsNullOrWhiteSpace(_school.GetString()))
            {
                code = $"LessonRecord-{_school}";
                tbname = "School";
            }
            else if ($"{_scope}".Equals("private"))
            {

                code = $"LessonRecord";
                tbname = "Teacher";
            }
            else
            {
                return BadRequest();
            }
            try
            {
                Dictionary<string, object> dict = new Dictionary<string, object>();
                if (_grant_types.ValueKind.Equals(JsonValueKind.Array)) {
                    LessonRecord lessonRecord = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<LessonRecord>($"{_lessonId}", new PartitionKey(code));
                    List<LessonUpdate> updates = _grant_types.ToObject<List<LessonUpdate>>();
                    foreach (var item in updates) {
                        if (item.grant_type.Equals("up-baseinfo")) {
                            JsonElement element = item.data.ToJsonString().ToObject<JsonElement>();
                            element.TryGetProperty("name", out JsonElement _name);
                            element.TryGetProperty("subjectId", out JsonElement _subjectId);
                            element.TryGetProperty("grade", out JsonElement _grade);
                            element.TryGetProperty("category", out JsonElement _category);
                            element.TryGetProperty("show", out JsonElement _show);
                            if (_name.ValueKind.Equals(JsonValueKind.String) && !string.IsNullOrWhiteSpace($"{_name}"))
                            {
                                lessonRecord.name = $"{_name}";
                            }
                            if (_subjectId.ValueKind.Equals(JsonValueKind.String) && !string.IsNullOrWhiteSpace($"{_subjectId}"))
                            {
                                lessonRecord.subjectId = $"{_subjectId}";
                            }
                            if (_grade.ValueKind.Equals(JsonValueKind.Array))
                            {
                                lessonRecord.grade = _grade.ToObject<List<string>>();
                            }
                            if (_category.ValueKind.Equals(JsonValueKind.Array))
                            {
                                lessonRecord.category = _category.ToObject<List<string>>();
                            }
                            if (_show.ValueKind.Equals(JsonValueKind.Array))
                            {
                                lessonRecord.show = _show.ToObject<List<string>>();
                            }
                            await client.GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<LessonRecord>(lessonRecord, $"{_lessonId}", new PartitionKey(code));
                            dict["up-baseinfo"] = new { status= 1 ,code="ok"};
                        }
                        if (item.grant_type.Equals("up-expire")) {
                            if (_scope.GetString().Equals("private"))
                            {
                                Teacher teacher = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>($"{_tmdid}", new PartitionKey("Base"));
                                HashSet<string> ids = new HashSet<string>();
                                //未定义的 以及过期时间小于等于0 的 课例
                                string private_count_sql = $"select value(c.id) from  c where  ( c.expire<=0 or IS_DEFINED(c.expire) = false  ) and c.tmdid='{_tmdid}'  ";
                                await foreach (var lid in client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetItemQueryIteratorSql<string>(
                                    queryText: private_count_sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey(code) }))
                                {

                                    ids.Add(lid);
                                }
                                //包含收藏的本人的个人课例
                                string favorite_count_sql = $"select value(c.id) from  c where c.type='LessonRecord' and c.owner='{_tmdid}'   and c.scope='private' ";
                                await foreach (var lid in client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetItemQueryIteratorSql<string>(
                                    queryText: favorite_count_sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Favorite-{_tmdid}") }))
                                {
                                    ids.Add(lid);
                                }
                                //教师个人预设的，可以通过设置的方式增加
                                int limit = teacher.lessonLimit;
                                if (teacher.lessonLimit == 0)
                                {
                                    //未设置的的采用系统设置的默认值50
                                    limit = Constant.private_lesson_limit;
                                }
                                if (ids.Count < limit)
                                {
                                    lessonRecord.expire = -1;
                                    await client.GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<LessonRecord>(lessonRecord, $"{_lessonId}", new PartitionKey(code));
                                    dict["up-expire"] = new { status = 1, code = "ok" };
                                }
                                else
                                {
                                    dict["up-expire"] = new { status = 0, code = "lessonLimit", data = limit };
                                }
                            }
                            else if (_scope.GetString().Equals("school")) {
                                lessonRecord.expire = -1;
                                await client.GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<LessonRecord>(lessonRecord, $"{_lessonId}", new PartitionKey(code));
                                dict["up-expire"] = new { status = 1, code = "ok" };
                            }
                        }
                    }
                    var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                    var messageChange = new ServiceBusMessage(request.ToJsonString());
                    messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                    await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                    return Ok(new { status = 200,updateInfo= dict });
                }
                return BadRequest();
            }
            catch (CosmosException ex) when (ex.StatusCode == HttpStatusCode.NotFound)
            {
                return BadRequest("课堂记录不存在");
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        /*
        {
            "scope":"school/private",
            "tmdid":"1595321354", 
            "delete_id":"asdeeeqq-adfghnlr-pfkcmsss-ssadffgtre",
            "opt":"delete",
            "school":"hbcn" //如果scope=school  这 school字段必须有值
        }
         */

        /// <summary>
        /// 删除课堂记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("delete-lesson-record")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher")]
        public async Task<IActionResult> DeleteLessonRecord(JsonElement request)
        {
            
            string school;
            string tbname;
            string code;
            if (request.TryGetProperty("delete_id", out JsonElement _delete_id) && !string.IsNullOrEmpty($"{_delete_id}")
                           // && request.TryGetProperty("tmdid", out JsonElement _dtmdid) && !string.IsNullOrEmpty($"{_dtmdid}")
                            && request.TryGetProperty("scope", out JsonElement _dscope) && !string.IsNullOrEmpty($"{_dscope}")
                            && request.TryGetProperty("opt", out JsonElement _opt) && !string.IsNullOrEmpty($"{_opt}"))
            {
                request.TryGetProperty("school", out JsonElement _dschool);
                school = $"{_dschool}";
                var client = _azureCosmos.GetCosmosClient();
                if ($"{_opt}".Equals("delete"))
                {
                    if ($"{_dscope}".Equals("school") && !string.IsNullOrEmpty($"{school}"))
                    {
                        code = $"LessonRecord-{school}";
                        tbname = "School";
                    }
                    else if ($"{_dscope}".Equals("private"))
                    {
                        code = $"LessonRecord";
                        tbname = "Teacher";
                    }
                    else
                    {
                        return BadRequest() ;
                    }
                    List<string> lessonIds = new List<string>();
                    //string   lessonId = $"{_delete_id}";
                    if (_delete_id.ValueKind.Equals(JsonValueKind.Array))
                    {
                        lessonIds.AddRange(_delete_id.ToObject<List<string>>());
                    }
                    else {
                        lessonIds.Add($"{_delete_id}");
                    }
                    if (lessonIds.IsNotEmpty())
                    {
                        foreach (var lessonId in lessonIds) {
                            ResponseMessage response = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemStreamAsync(lessonId, new PartitionKey(code));
                            if (response.StatusCode==System.Net.HttpStatusCode.OK)
                            {
                                LessonRecord lessonRecord;
                                var doc = JsonDocument.Parse(response.Content);
                                lessonRecord = doc.RootElement.ToObject<LessonRecord>();
                                lessonRecord.status = 404;
                                await client.GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync(lessonRecord, lessonRecord.id, new PartitionKey(lessonRecord.code));
                                var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                                var messageChange = new ServiceBusMessage(request.ToJsonString());
                                messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                                await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                                
                            }
                        }
                        return Ok(new { status = 200 });
                    }
                    else { return BadRequest(); }
                }
                else { return BadRequest() ; }
            }
            else
            {
                return BadRequest();
            }
        }


        /// <summary>
        /// 获取开课记录 (c.status<>404 or IS_DEFINED(c.status)=false )
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        //[AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-lesson-record-count")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetLessonRecordCont(JsonElement request)
        {
            object _roles = null;
            HttpContext?.Items.TryGetValue("Roles", out _roles);
            List<string> roles = new List<string>();
            if (_roles != null)
            {
                roles = _roles.ToJsonString().ToObject<List<string>>();
            }
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            request.TryGetProperty("managePage", out JsonElement _managePage);
            bool managePage = false;
            if (_managePage.ValueKind.Equals(JsonValueKind.True)) {
                managePage = true;
            }
            StringBuilder sql = new StringBuilder();
            sql.Append("select c.id,c.groupIds,c.courseId from c   ");
            Dictionary<string ,object> dict = LessonService.GetLessonCond(request);
            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql);
            string tbname = "";
            string code = "";
            string school = null;
            List<string> autoTch = new List<string>();
            string sqlPrivate = "";
            if (_scope.GetString().Equals("school"))
            {
                if (!request.TryGetProperty("school", out JsonElement _school)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    school = $"{_school}";
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                    List<string> ids = new List<string>();
                    //只查询某个老师的课例
                    if (request.TryGetProperty("tmdid", out JsonElement tmdid) && !string.IsNullOrWhiteSpace($"{tmdid}"))
                    {
                        ids.Add($"{tmdid}");
                    }
                    else
                    {
                        string sqltch = "select distinct value(c.id) from c ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School)
                            .GetItemQueryIteratorSql<string>(queryText: sqltch, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{_school}") }))
                        {
                            ids.Add(item);
                        }
                    }
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else {
                    return BadRequest();
                }
               
            }
            else if ($"{_scope}".Equals("private"))
            {
                code = $"LessonRecord";
                tbname = "Teacher";
                request.TryGetProperty("tmdid", out JsonElement _tmdid);
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                   
                    sqlPrivate = $" and c.tmdid='{_tmdid}'";
                    List<string> ids = new List<string>();
                    ids.Add($"{_tmdid}");
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else
                {
                    //如果不传tmdid， 则必须传递，课程id或者名单列表
                    // 如果不传递tmdid
                    if (!request.TryGetProperty("groupIds", out JsonElement groupIds))
                    {
                        return BadRequest("个人课例不传醍摩豆id则必传 groupIds");
                    }
                }
            }
            else
            {
                return BadRequest();
            }
            int count=0;

            string sqlShow = "";
            if (roles.Count == 1 && roles.Contains("student"))
            {
                string autoSql = "";
                if (autoTch.Any())
                {
                    autoSql = $" or c.tmdid in ({string.Join(",", autoTch.Select(x => $"'{x}'"))})";
                }
                sqlShow = $" and (array_contains(c.show,'student') or array_contains(c.show,'all')  {autoSql} ) ";
            }
            long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
            string sql_status_managePage = " (c.status<>404 or IS_DEFINED(c.status) = false  ) and   ";
            if (managePage) {
                sql_status_managePage = "";
            }
            //cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where {sql_status_managePage} array_length(c.groupIds)>0 {sqlPrivate} {sqlShow}  and  ");
            cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where {sql_status_managePage} 1=1 {sqlPrivate} {sqlShow}  and  ");
            if (request.TryGetProperty("singleGreen", out JsonElement doubleGreen) && doubleGreen.GetBoolean())
            {
                cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  ((c.tLevel=2 and c.pLevel<2 )or(c.tLevel<2 and c.pLevel=2 )) and   ");
            }
            if (request.TryGetProperty("expire", out JsonElement expire) && expire.ValueKind.Equals(JsonValueKind.True))
            {
                cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where c.expire>{now} and   ");
            }
            List<LessonRecord> records = new List<LessonRecord>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIteratorQuery<LessonRecord>(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
            {
                records.Add(item);
            }
            if (records.Any()) {
                var groupIds= records.SelectMany(x => x.groupIds).ToHashSet();
                if (groupIds.Any()) {
                    var groups = await GroupListService.GetGroupListByListids(_azureCosmos.GetCosmosClient(), _dingDing, groupIds.ToList(), school," c.id ");
                    //获取已经被删除的名单。
                    var idsExp =  groupIds.Except(groups.Select(x => x.id));
                    if (idsExp.Any()) {
                        foreach(var item in records)
                        {
                            int countRmv = item.groupIds.RemoveAll(x => idsExp.Contains(x));
                            if (countRmv > 0)
                            {
                                try {
                                    LessonRecord record = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<LessonRecord>(item.id, new PartitionKey(code));
                                    record.groupIds = item.groupIds;
                                    await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<LessonRecord>(record, item.id, new PartitionKey(code));
                                } catch (CosmosException ex) when (ex.StatusCode == HttpStatusCode.NotFound) {
                                    continue;
                                }
                            }
                        }
                    }
                }
            }
            count = records.Count;
            return Ok(new { count=count, records });
        }
        /// <summary>
        /// 获取开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-lesson-record-schorpvt")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetLessonRecordSchOrPvt(JsonElement request) {
            object _roles = null;
            HttpContext?.Items.TryGetValue("Roles", out _roles);
            List<string> roles = new List<string>();
            if (_roles != null)
            {
                roles = _roles.ToJsonString().ToObject<List<string>>();
            }
            StringBuilder sql = new StringBuilder();
            sql.Append("select   value(c) from c ");
            
            Dictionary<string, object> dict = LessonService.GetLessonCond(request);
             
            if (request.TryGetProperty("DESC", out JsonElement desc))
            {
                dict.Add("@DESC", desc.ToString());
            }
            if (request.TryGetProperty("ASC", out JsonElement asc))
            {
                dict.Add("@ASC", asc.ToString());
            }
             
            string school = null;
            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql);
            List<LessonRecord> lessonRecords = new List<LessonRecord>();
            //获取学校的
            {
                string tbname = "School";
                string code = "";
                
                string sqlPrivate = "";
                List<string> autoTch = new List<string>();
                request.TryGetProperty("school", out JsonElement _school);
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                    school = $"{_school}";
                    List<string> ids = new List<string>();
                    //只查询某个老师的课例
                    if (request.TryGetProperty("tmdid", out JsonElement tmdid) && !string.IsNullOrWhiteSpace($"{tmdid}"))
                    {
                        ids.Add($"{tmdid}");
                    }
                    else
                    {
                        string sqltch = "select distinct value(c.id) from c ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School)
                            .GetItemQueryIteratorSql<string>(queryText: sqltch, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{_school}") }))
                        {
                            ids.Add(item);
                        }
                    }
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                            .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }

                    string sqlShow = "";
                    if (roles.Count == 1 && roles.Contains("student"))
                    {
                        string autoSql = "";
                        if (autoTch.Any())
                        {
                            autoSql = $" or c.tmdid in ({string.Join(",", autoTch.Select(x => $"'{x}'"))})";
                        }
                        sqlShow = $" and (array_contains(c.show,'student') or array_contains(c.show,'all')  {autoSql} ) ";
                    }
                    //cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false ) and  array_length(c.groupIds)>0 {sqlPrivate}  {sqlShow} and  ");
                    cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false ) and  1=1 {sqlPrivate}  {sqlShow} and  ");
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname)
                       .GetItemQueryStreamIteratorQuery(queryDefinition: cosmosDbQuery.CosmosQueryDefinition,   
                       requestOptions: new QueryRequestOptions() {  PartitionKey = new PartitionKey(code) }))
                    {
                        using var json = await JsonDocument.ParseAsync(item.Content);
                        if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                        {
                            foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                            {
                                lessonRecords.Add(obj.ToObject<LessonRecord>());
                            }
                            break;
                        }
                    }
                }
            }
            //获取个人的 
            {
                string code = $"LessonRecord";
                string tbname = "Teacher";
                List<string> autoTch = new List<string>();
                request.TryGetProperty("tmdid", out JsonElement _tmdid);
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                    string  sqlPrivate = $" and c.tmdid='{_tmdid}'";
                    List<string> ids = new List<string>();
                    ids.Add($"{_tmdid}");
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }

                    string sqlShow = "";
                    if (roles.Count == 1 && roles.Contains("student"))
                    {
                        string autoSql = "";
                        if (autoTch.Any())
                        {
                            autoSql = $" or c.tmdid in ({string.Join(",", autoTch.Select(x => $"'{x}'"))})";
                        }
                        sqlShow = $" and (array_contains(c.show,'student') or array_contains(c.show,'all')  {autoSql} ) ";
                    }
                    //cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false ) and  array_length(c.groupIds)>0 {sqlPrivate}  {sqlShow} and  ");
                    cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false ) and  1=1  {sqlPrivate}  {sqlShow} and  ");
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname)
                       .GetItemQueryStreamIteratorQuery(queryDefinition: cosmosDbQuery.CosmosQueryDefinition,  
                       requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
                    {
                        using var json = await JsonDocument.ParseAsync(item.Content);
                        if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                        {
                            foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                            {
                                lessonRecords.Add(obj.ToObject<LessonRecord>());
                            }
                            break;
                        }
                    }
                }
            }
            var tmdids = lessonRecords.Select(x => x.tmdid).ToHashSet();
            if (tmdids != null && tmdids.Count > 0)
            {
                List<IdNameCode> codes = new List<IdNameCode>();
                string sqltmd = $"select c.id,c.name,c.picture from c where c.id in ({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<IdNameCode>(queryText: sqltmd, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
                {
                    codes.Add(item);
                }
                if (codes.IsNotEmpty())
                {
                    lessonRecords.ForEach(x => {
                        var tmd = codes.Find(z => z.id.Equals(x.tmdid));
                        if (tmd != null)
                        {
                            x.tmdname = tmd.name;
                            x.tmdpicture = tmd.picture;
                        }
                    });
                }
            }
            var groupIds = lessonRecords.SelectMany(x => x.groupIds);
            if (groupIds.Any())
            {
                List<GroupListDto> groupLists = await GroupListService.GetGroupListByListids(_azureCosmos.GetCosmosClient(), _dingDing, groupIds.ToList(), school);
                lessonRecords.ForEach(x => {
                    List<string> groupNmae = new List<string>();
                    x.groupIds.ForEach(y => {
                        var dto = groupLists.Find(z => z.id.Equals(y));
                        string name = dto != null ? dto.name : "-";
                        groupNmae.Add(name);
                    });
                    x.groupNames = groupNmae;
                });
            }
            if(request.TryGetProperty("top", out JsonElement _top) && lessonRecords.Any())
            {
               var rcords= lessonRecords.OrderByDescending(x => x.startTime).Take(int.Parse($"{_top}"));
                return Ok(new { currCount =rcords.Count(), lessonRecords =rcords});
            }
            return Ok(new { currCount = lessonRecords.Count,  lessonRecords });
        }
        /// <summary>
        /// 获取开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-lesson-record")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles ="admin,teacher,student")]
        public async Task<IActionResult> GetLessonRecord(JsonElement request)
        {
            object _roles = null;
            HttpContext?.Items.TryGetValue("Roles", out   _roles);
            List<string> roles = new List<string>();
            if (_roles != null) {
                roles = _roles.ToJsonString().ToObject<List<string>>();
            }
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            request.TryGetProperty("managePage", out JsonElement _managePage);
            bool managePage = false;
            if (_managePage.ValueKind.Equals(JsonValueKind.True))
            {
                managePage = true;
            }
            StringBuilder sql = new StringBuilder();
            sql.Append("select   value(c) from c ");
            int pageCount = 10;
            Dictionary<string, object> dict = LessonService.GetLessonCond(request);
            if (request.TryGetProperty("pageCount", out JsonElement _pageCount))
            {
                int.TryParse($"{_pageCount}", out int pcount);
                if (pcount > 0)
                {
                    pageCount = pcount;
                }
            }
            if (request.TryGetProperty("DESC", out JsonElement desc))
            {
                dict.Add("@DESC", desc.ToString());
            }
            if (request.TryGetProperty("ASC", out JsonElement asc))
            {
                dict.Add("@ASC", asc.ToString());
            }
            string continuationToken = null;
            if (request.TryGetProperty("continuationToken", out JsonElement _continuationToken))
            {
                if (!string.IsNullOrEmpty($"{_continuationToken}"))
                {
                    continuationToken = $"{_continuationToken}";
                }
            }
            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql);
            cosmosDbQuery.QueryText=cosmosDbQuery.QueryText.Replace("distinct", "");
            string tbname = "";
            string code = "";
            string school = null;
            string sqlPrivate = "";
            List<string> autoTch = new List<string>();
            if (_scope.GetString().Equals("school"))
            {
                if (!request.TryGetProperty("school", out JsonElement _school)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                    school = $"{_school}";
                    List<string> ids = new List<string>();
                    //只查询某个老师的课例
                    if (request.TryGetProperty("tmdid", out JsonElement tmdid) && !string.IsNullOrWhiteSpace($"{tmdid}"))
                    {
                        ids.Add($"{tmdid}");
                    }
                    else {
                        string sqltch = "select distinct value(c.id) from c ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School)
                            .GetItemQueryIteratorSql<string>(queryText: sqltch, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{_school}") }))
                        {
                            ids.Add(item);
                        }
                    }
                    if (ids.Any()) {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else
                {
                    return BadRequest();
                }
            }
            else if ($"{_scope}".Equals("private"))
            {
                code = $"LessonRecord";
                tbname = "Teacher";
                request.TryGetProperty("tmdid", out JsonElement _tmdid);
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                    sqlPrivate = $" and c.tmdid='{_tmdid}'";
                    List<string> ids = new List<string>();
                    ids.Add($"{_tmdid}");
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else
                { 
                    //如果不传tmdid， 则必须传递，课程id或者名单列表
                    // 如果不传递tmdid
                    if (!request.TryGetProperty("groupIds", out JsonElement groupIds)) {
                        return BadRequest("个人课例不传醍摩豆id则必传 groupIds");
                    }
                }
            }
            else
            {
                return BadRequest();
            }
            List<LessonRecord> lessonRecords = new List<LessonRecord>();
            try
            {
                string sqlShow = "";
                if (roles.Count == 1 && roles.Contains("student"))
                {
                    string autoSql = "";
                    if (autoTch.Any()) {
                        autoSql = $" or c.tmdid in ({string.Join(",",autoTch.Select(x=>$"'{x}'"))})";
                    }
                    sqlShow = $" and (array_contains(c.show,'student') or array_contains(c.show,'all')  {autoSql} ) ";
                }

                string sql_status_managePage = "(c.status<>404 or IS_DEFINED(c.status) = false ) and  ";
                if (managePage)
                {
                    sql_status_managePage = "";
                }
                //cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  {sql_status_managePage}  array_length(c.groupIds)>0 {sqlPrivate}  {sqlShow} and  ");
                cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  {sql_status_managePage}  1=1 {sqlPrivate}  {sqlShow} and  ");
                if (request.TryGetProperty("singleGreen", out JsonElement doubleGreen) && doubleGreen.GetBoolean())
                {
                    cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  ((c.tLevel=2 and c.pLevel<2 )or(c.tLevel<2 and c.pLevel=2 )) and   ");
                }
                //if (request.TryGetProperty("name", out JsonElement _name) && !string.IsNullOrWhiteSpace($"{_name}"))
                //{

                //}

                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname)
                .GetItemQueryStreamIteratorQuery(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, continuationToken: continuationToken,
                requestOptions: new QueryRequestOptions() { MaxItemCount = pageCount, PartitionKey = new PartitionKey(code) }))
                {
                    using var json = await JsonDocument.ParseAsync(item.Content);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            var rcd = obj.ToObject<LessonRecord>();
                            if (rcd.hitaClientCmpCount <= 0 && rcd.collateTaskCount > 0) {
                                rcd.hitaClientCmpCount= rcd.collateTaskCount;
                            }
                            if (rcd.learningCategory == null)
                            {

                                rcd.learningCategory = new LearningCategory();
                            }
                            if (rcd.hitaClientCmpCount > 0)
                            {

                                rcd.learningCategory.cooperation = 1;
                            }
                            if (!lessonRecords.Exists(x => x.id.Equals(rcd.id))) 
                            { lessonRecords.Add(rcd); }
                            
                        }
                        continuationToken = item.ContinuationToken;
                        break;
                    }
                }
                long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                //查询时处理已经过期的课例。防止ServiceBus未触发的。
                var expireRecords= lessonRecords.Where(x=> x.expire > 0 && now > x.expire);
                try {
                    foreach (var item in expireRecords)
                    {
                        //item.status = 404;
                        //await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
                        var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                        var messageChange = new ServiceBusMessage(new { delete_id = item.id, tmdid = item.tmdid, scope = item.scope, opt = "delete", school = item.school }.ToJsonString());
                        messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                        await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                    }
                } catch (Exception ex) {
                    await  _dingDing.SendBotMsg($"{_option.Location},ServiceBus ,LessonRecordEvent 发送消息失败，检查是否配置正常。", GroupNames.成都开发測試群組);
                }
                var tmdids = lessonRecords.Select(x => x.tmdid).ToHashSet();
                if (tmdids != null && tmdids.Count > 0)
                {
                    List<IdNameCode> codes = new List<IdNameCode>();
                    string sqltmd = $"select c.id,c.name,c.picture from c where c.id in ({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<IdNameCode>(queryText: sqltmd, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
                    {
                        codes.Add(item);
                    }
                    if (codes.IsNotEmpty())
                    {
                        lessonRecords.ForEach(x => {
                            var tmd = codes.Find(z => z.id.Equals(x.tmdid));
                            if (tmd != null)
                            {
                                x.tmdname = tmd.name;
                                x.tmdpicture = tmd.picture;
                            }
                        });
                    }
                }
                var groupIds = lessonRecords.SelectMany(x => x.groupIds);
                if (groupIds.Any()) {
                   List<GroupListDto> groupLists= await GroupListService.GetGroupListByListids(_azureCosmos.GetCosmosClient(), _dingDing, groupIds.ToList(), school);
                    lessonRecords.ForEach(x => {
                        List<string> groupNmae = new List<string>();
                        x.groupIds.ForEach(y => {
                           var dto= groupLists.Find(z => z.id.Equals(y));
                           string name  = dto != null ? dto.name : "-";
                            groupNmae.Add(name);
                        });
                        x.groupNames = groupNmae;
                    });
                }
                //已经过期的处理掉垃圾数据
                List<LessonRecord> lessonRecords404 = new List<LessonRecord>();
                foreach (var item in lessonRecords)
                {
                    if (item.scope.Equals("school"))
                    {
                        if (item.expire>0  && item.expire<now  && item.status!=404)
                        {
                            item.status=404;
                            await _azureStorage.GetBlobServiceClient().DeleteBlobs(_dingDing, item.school, new List<string> { $"records/{item.id}" });
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).DeleteItemStreamAsync(item.id, new PartitionKey($"Bloblog-{item.school}"));
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
                            lessonRecords404.Add(item);
                        }
                    }
                }
                if (lessonRecords404.IsNotEmpty()) {
                    foreach (var item in lessonRecords404) {
                        lessonRecords.Remove(item);
                    }
                }
                return Ok(new { currCount = lessonRecords.Count, continuationToken, lessonRecords });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                continuationToken = null;
                return Ok(new { currCount = 0, continuationToken = continuationToken, lessonRecords });
            }
        }

        /// <summary>
        /// 获取开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-lesson-record-report")]
        //[Authorize(Roles = "IES")]
        //[AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetLessonRecordReport(JsonElement request) 
        {
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            StringBuilder sql = new StringBuilder();
            sql.Append("select   value(c) from c ");
            int pageCount = 10;
            Dictionary<string, object> dict = LessonService.GetLessonCond(request);
            if (request.TryGetProperty("pageCount", out JsonElement _pageCount))
            {
                int.TryParse($"{_pageCount}", out int pcount);
                if (pcount > 0)
                {
                    pageCount = pcount;
                }
            }
            if (request.TryGetProperty("DESC", out JsonElement desc))
            {
                dict.Add("@DESC", desc.ToString());
            }
            if (request.TryGetProperty("ASC", out JsonElement asc))
            {
                dict.Add("@ASC", asc.ToString());
            }
            
            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql);
            string tbname = "";
            string code = "";
            string school = null;
            string sqlPrivate = "";
            List<string> autoTch = new List<string>();
            string sas = string.Empty;
            string uri = string.Empty;
            if (_scope.GetString().Equals("school"))
            {
                if (!request.TryGetProperty("school", out JsonElement _school)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    var sasInfo = _azureStorage.GetBlobContainerSAS($"{_school}", BlobContainerSasPermissions.List|BlobContainerSasPermissions.Read);
                    sas=sasInfo.sas;
                    uri= sasInfo.uri;
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                    school = $"{_school}";
                    List<string> ids = new List<string>();
                    //只查询某个老师的课例
                    if (request.TryGetProperty("tmdid", out JsonElement tmdid) && !string.IsNullOrWhiteSpace($"{tmdid}"))
                    {
                        ids.Add($"{tmdid}");
                    }
                    else {
                        string sqltch = "select distinct value(c.id) from c ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School)
                            .GetItemQueryIteratorSql<string>(queryText: sqltch, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{_school}") }))
                        {
                            ids.Add(item);
                        }
                    }
                    if (ids.Any()) {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else
                {
                    return BadRequest();
                }
            }
            else if ($"{_scope}".Equals("private"))
            {
                code = $"LessonRecord";
                tbname = "Teacher";
                request.TryGetProperty("tmdid", out JsonElement _tmdid);
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                    var sasInfo = _azureStorage.GetBlobContainerSAS($"{_tmdid}", BlobContainerSasPermissions.List|BlobContainerSasPermissions.Read);
                    sas=sasInfo.sas;
                    uri= sasInfo.uri;
                    sqlPrivate = $" and c.tmdid='{_tmdid}'";
                    List<string> ids = new List<string>();
                    ids.Add($"{_tmdid}");
                    if (ids.Any())
                    {
                        string sqlTechbase = $"select distinct value(c.id) from c  where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})  and (array_contains(c.lessonShow,'student') or array_contains(c.lessonShow,'all')) ";
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
                           .GetItemQueryIteratorSql<string>(queryText: sqlTechbase, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
                        {
                            autoTch.Add(item);
                        }
                    }
                }
                else
                { 
                    //如果不传tmdid， 则必须传递，课程id或者名单列表
                    // 如果不传递tmdid
                    if (!request.TryGetProperty("groupIds", out JsonElement groupIds)) {
                        return BadRequest("个人课例不传醍摩豆id则必传 groupIds");
                    }
                }
            }
            else
            {
                return BadRequest();
            }
            List<LessonRecord> lessonRecords = new List<LessonRecord>();
            try
            {
                string sql_status_managePage = "(c.status<>404 or IS_DEFINED(c.status) = false ) and  ";
                // cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  {sql_status_managePage}  array_length(c.groupIds)>0 {sqlPrivate}   and  ");
                cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  {sql_status_managePage}  1=1 {sqlPrivate}   and  ");
                if (request.TryGetProperty("singleGreen", out JsonElement doubleGreen) && doubleGreen.GetBoolean())
                {
                    cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where  ((c.tLevel=2 and c.pLevel<2 )or(c.tLevel<2 and c.pLevel=2 )) and   ");
                }
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname)
                .GetItemQueryStreamIteratorQuery(queryDefinition: cosmosDbQuery.CosmosQueryDefinition, 
                requestOptions: new QueryRequestOptions() {   PartitionKey = new PartitionKey(code) }))
                {
                    using var json = await JsonDocument.ParseAsync(item.Content);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            var rcd = obj.ToObject<LessonRecord>();
                            if (rcd.hitaClientCmpCount <= 0 && rcd.collateTaskCount > 0) {
                                rcd.hitaClientCmpCount= rcd.collateTaskCount;
                            }
                            if (rcd.learningCategory == null)
                            {

                                rcd.learningCategory = new LearningCategory();
                            }
                            if (rcd.hitaClientCmpCount > 0)
                            {

                                rcd.learningCategory.cooperation = 1;
                            }
                            lessonRecords.Add(rcd);
                        }
                       // continuationToken = item.ContinuationToken;
                        break;
                    }
                }
                long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                //查询时处理已经过期的课例。防止ServiceBus未触发的。
                var expireRecords= lessonRecords.Where(x=> x.expire > 0 && now > x.expire);
                try {
                    foreach (var item in expireRecords)
                    {
                        //item.status = 404;
                        //await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
                        var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                        var messageChange = new ServiceBusMessage(new { delete_id = item.id, tmdid = item.tmdid, scope = item.scope, opt = "delete", school = item.school }.ToJsonString());
                        messageChange.ApplicationProperties.Add("name", "LessonRecordEvent");
                        await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
                    }
                } catch (Exception ex) {
                    await  _dingDing.SendBotMsg($"{_option.Location},ServiceBus ,LessonRecordEvent 发送消息失败，检查是否配置正常。", GroupNames.成都开发測試群組);
                }
                var tmdids = lessonRecords.Select(x => x.tmdid).ToHashSet();
                if (tmdids != null && tmdids.Count > 0)
                {
                    List<IdNameCode> codes = new List<IdNameCode>();
                    string sqltmd = $"select c.id,c.name,c.picture from c where c.id in ({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<IdNameCode>(queryText: sqltmd, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
                    {
                        codes.Add(item);
                    }
                    if (codes.IsNotEmpty())
                    {
                        lessonRecords.ForEach(x => {
                            var tmd = codes.Find(z => z.id.Equals(x.tmdid));
                            if (tmd != null)
                            {
                                x.tmdname = tmd.name;
                                x.tmdpicture = tmd.picture;
                            }
                        });
                    }
                }
                var groupIds = lessonRecords.SelectMany(x => x.groupIds);
                if (groupIds.Any()) {
                   List<GroupListDto> groupLists= await GroupListService.GetGroupListByListids(_azureCosmos.GetCosmosClient(), _dingDing, groupIds.ToList(), school);
                    lessonRecords.ForEach(x => {
                        List<string> groupNmae = new List<string>();
                        x.groupIds.ForEach(y => {
                           var dto= groupLists.Find(z => z.id.Equals(y));
                           string name  = dto != null ? dto.name : "-";
                            groupNmae.Add(name);
                        });
                        x.groupNames = groupNmae;
                    });
                }
                //已经过期的处理掉垃圾数据
                List<LessonRecord> lessonRecords404 = new List<LessonRecord>();
                foreach (var item in lessonRecords)
                {
                    if (item.scope.Equals("school"))
                    {
                        if (item.expire>0  && item.expire<now  && item.status!=404)
                        {
                            item.status=404;
                            await _azureStorage.GetBlobServiceClient().DeleteBlobs(_dingDing, item.school, new List<string> { $"records/{item.id}" });
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).DeleteItemStreamAsync(item.id, new PartitionKey($"Bloblog-{item.school}"));
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
                            lessonRecords404.Add(item);
                        }
                    }
                }
                if (lessonRecords404.IsNotEmpty()) {
                    foreach (var item in lessonRecords404) {
                        lessonRecords.Remove(item);
                    }
                }
                List<GroupListDto> grps = new List<GroupListDto>();
                var groups= lessonRecords.Where(x=>x.groupIds.IsNotEmpty()).SelectMany(x => x.groupIds);
                if (groups!= null && groups.Count()>0) 
                {
                    grps=  await GroupListService.GetGroupListByListids(_azureCosmos.GetCosmosClient(), _dingDing, groups.ToList(), school);
                }
                var tmds = lessonRecords.Where(x =>!string.IsNullOrWhiteSpace(x.tmdid)).Select(x => x.tmdid);
                Teacher teacher = null;
                if (tmds!=null && tmds.Count()>0) 
                {
                    teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>(tmds.First(), new PartitionKey("Base"));
                }
                var courseIds = lessonRecords.Where(x => !string.IsNullOrWhiteSpace(x.courseId)).Select(x => x.courseId);
                CourseBase course = null;
                if (courseIds!=null && courseIds.Count()>0)
                {
                    ResponseMessage response = null;
                    if ($"{_scope}".Equals("school"))
                    {
                        response= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync(courseIds.First(), new PartitionKey($"CourseBase-{school}"));
                    }
                    else {
                        response= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(courseIds.First(), new PartitionKey("CourseBase"));
                    }
                    if (response.StatusCode==HttpStatusCode.OK) 
                    {
                        course= JsonDocument.Parse(response.Content).RootElement.ToObject<CourseBase>();
                    }
                }
                return Ok(new { currCount = lessonRecords.Count, lessonRecords,sas,uri , groupLists= grps, teacher, course});
            }
            catch (Exception  ex )
            {
                await _dingDing.SendBotMsg($"课例报告查询报错：{ex.StackTrace},{ex.Message}", GroupNames.成都开发測試群組);
                return Ok(new { currCount = 0 , lessonRecords });
            }

        }

        /// <summary>
        /// 获取开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-lesson-record-id")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetLessonRecordId(JsonElement request)
        {
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            if (!request.TryGetProperty("id", out JsonElement _id)) return BadRequest();
            string tbname = "";
            string code = "";
            if (_scope.GetString().Equals("school"))
            {
                if (!request.TryGetProperty("school", out JsonElement _school)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                }
                else
                {
                    return BadRequest();
                }
            }
            else if ($"{_scope}".Equals("private"))
            {
                if (!request.TryGetProperty("tmdid", out JsonElement _tmdid)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                    code = $"LessonRecord";
                    tbname = "Teacher";
                }
                else
                {
                    return BadRequest();
                }
            }
            else
            {
                return BadRequest();
            }
            try
            {
                LessonRecord lessonRecord = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<LessonRecord>($"{_id}", new PartitionKey(code));
                return Ok(new { lessonRecord });
            }
            catch (CosmosException ex) when (ex.StatusCode == HttpStatusCode.NotFound)
            {
                return Ok(new { status = 404 });
            }
        }
        /// <summary>
        /// 获取开课记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
       // [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-other-lesson-record")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetOtherLessonRecord(JsonElement request)
        {
            if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
            string tbname = "";
            string code = "";
            string sqlPrivate = "";
            if (_scope.GetString().Equals("school") )
            {
                if (!request.TryGetProperty("school", out JsonElement _school)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_school}"))
                {
                    code = $"LessonRecord-{_school}";
                    tbname = "School";
                }
                else
                {
                    return BadRequest();
                }
            }
            else if ($"{_scope}".Equals("private"))
            {
                if (!request.TryGetProperty("tmdid", out JsonElement _tmdid)) return BadRequest();
                if (!string.IsNullOrEmpty($"{_tmdid}"))
                {
                    sqlPrivate = $" and c.tmdid='{_tmdid}'";
                    code = $"LessonRecord";
                    tbname = "Teacher";
                }
                else {
                    return BadRequest();
                }
            }
            else
            {
                return BadRequest();
            }
            request.TryGetProperty("periodId", out JsonElement _periodId);
            request.TryGetProperty("stime", out JsonElement _stime);
            request.TryGetProperty("etime", out JsonElement _etime);
            //优质课程
            var excellent = new JsonObject
            {
                ["excellent"] = true,
                ["periodId"] = $"{_periodId}",
                ["stime"] = $"{_stime}",
                ["etime"] = $"{_etime}",
            }.ToJsonString().ToObject<JsonElement>();
            //专家好客
            var doubleGreen = new JsonObject
            {
                ["doubleGreen"] = true,
                ["periodId"] = $"{_periodId}",
                ["stime"] = $"{_stime}",
                ["etime"] = $"{_etime}",
            }.ToJsonString().ToObject<JsonElement>();
            //今日课程
            var today = new JsonObject
            {
                ["today"] = true,
                ["periodId"] = $"{_periodId}",
            }.ToJsonString().ToObject<JsonElement>();
         
            List<LessonRecord> excellentRcd =await GetOtherLessonCond(excellent,   code,   tbname, sqlPrivate);
            List<LessonRecord> doubleGreenRcd = await GetOtherLessonCond(doubleGreen, code, tbname, sqlPrivate);
            List<LessonRecord> todayRcd = await GetOtherLessonCond(today, code, tbname, sqlPrivate);
            try {
                var tmdids_excellent = excellentRcd.Select(x => x.tmdid);
                var tmdids_doubleGreen = excellentRcd.Select(x => x.tmdid);
                var tmdids_today = excellentRcd.Select(x => x.tmdid);
                List<string> tmdids=new List<string>();
                tmdids.AddRange(tmdids_excellent);
                tmdids.AddRange(tmdids_doubleGreen);
                tmdids.AddRange(tmdids_today);
                if (tmdids != null && tmdids.Count > 0) {
                    List< IdNameCode > codes= new List<IdNameCode> ();  
                    string sqltmd = $"select c.id,c.name,c.picture from c where c.id in ({string.Join(",", tmdids.Select(x => $"'{x}'"))})";
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<IdNameCode>(queryText:sqltmd,requestOptions:new QueryRequestOptions { PartitionKey=new PartitionKey("Base") })){
                        codes.Add(item);
                    }
                    if (codes.IsNotEmpty()) {
                        excellentRcd.ForEach(x => {
                            var tmd=  codes.Find(z => z.id.Equals(x.tmdid));
                            if (tmd != null) {
                                x.tmdname = tmd.name;
                                x.tmdpicture= tmd.picture;
                            }
                        });
                        doubleGreenRcd.ForEach(x => {
                            var tmd = codes.Find(z => z.id.Equals(x.tmdid));
                            if (tmd != null)
                            {
                                x.tmdname = tmd.name;
                                x.tmdpicture = tmd.picture;
                            }
                        });
                        todayRcd.ForEach(x => {
                            var tmd = codes.Find(z => z.id.Equals(x.tmdid));
                            if (tmd != null)
                            {
                                x.tmdname = tmd.name;
                                x.tmdpicture = tmd.picture;
                            }
                        });
                    }
                }
                return Ok(new { excellentRcd , doubleGreenRcd, todayRcd });
            } catch (Exception ex) {
                return Ok(new { excellentRcd, doubleGreenRcd, todayRcd });
            }
        }

        private async Task<List<LessonRecord>> GetOtherLessonCond(JsonElement request,string code ,string tbname,string sqlPrivate) {
            StringBuilder sql = new StringBuilder();
            sql.Append("select value(c) from c ");
            Dictionary<string, object> dict = LessonService.GetLessonCond(request);
            AzureCosmosQuery cosmosDbQuery = SQLHelper.GetSQL(dict, sql);
            List<LessonRecord> lessonRecords = new List<LessonRecord>();
            // cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false )  and  array_length(c.groupIds)>0 {sqlPrivate}  and  ");
            cosmosDbQuery.QueryText = cosmosDbQuery.QueryText.Replace("where", $" where (c.status<>404 or IS_DEFINED(c.status) = false )  and  1=1 {sqlPrivate}  and  ");
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname)
               .GetItemQueryStreamIteratorQuery(queryDefinition: cosmosDbQuery.CosmosQueryDefinition,
               requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
            {
                using var json = await JsonDocument.ParseAsync(item.Content);
                if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                {
                    foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                    {
                        lessonRecords.Add(obj.ToObject<LessonRecord>());
                    }
                }
            }
            return lessonRecords;
        }

        /// <summary>
        /// 验证IES课例
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpGet("lesson-record-verify")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher")]
        [EnableCors("AllowSpecificOrigin")]//跨域
        public async Task<IActionResult> LessonRecordVerify([FromQuery] string id , [FromQuery]  string owner, [FromQuery] string scope, [FromQuery] string token  ) 
        {
            (string tmdid, _, _, string school) = HttpContext.GetAuthTokenInfo();
            if (!string.IsNullOrWhiteSpace(id)) { return Ok(new { code=4001,msg="id不能为空" }); }
            if (!string.IsNullOrWhiteSpace(scope)) { return Ok(new { code = 4002, msg = "scope不能为空" }); }
            if (!string.IsNullOrWhiteSpace(owner)) { return Ok(new { code = 4003, msg = "owner不能为空" }); }
            if (!string.IsNullOrWhiteSpace(token)) { return Ok(new { code = 4004, msg = "token不能为空" }); }
            string tbname;
            string code;

            if (scope.Equals("school") && !string.IsNullOrWhiteSpace(owner))
            {
                code = $"LessonRecord-{owner}";
                tbname = "School";
            }
            else if ($"{scope}".Equals("private") && owner.Equals(tmdid))
            {
                code = $"LessonRecord";
                tbname = "Teacher";
            }
            else
            {
                { return Ok(new { code = 400, msg = "参数错误" }); }
            }

            ResponseMessage response =  await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemStreamAsync(id, new PartitionKey(code));
            if (response.StatusCode==System.Net.HttpStatusCode.OK)
            {
                LessonRecord lessonRecord = JsonDocument.Parse(response.Content).RootElement.ToObject<LessonRecord>();
                if (lessonRecord.scope.Equals("school"))
                {
                    if (lessonRecord.school.Equals(school))
                    {
                        if (lessonRecord.tmdid.Equals(tmdid))
                        {
                            return Ok(new { code = 200, lessonRecord });
                        }
                        else
                        {
                            ///不是本人的课例
                            ///(非授权信息） 服务器已成功处理了请求，但返回的信息可能来自另一来源。
                            return Ok(new { code = 2031, lessonRecord });
                        }
                    }
                    else
                    {
                        //不是同一个学校的课例
                        ///(非授权信息） 服务器已成功处理了请求，但返回的信息可能来自另一来源。
                        return Ok(new { code = 2032, lessonRecord });
                    }
                }
                else {
                    if (lessonRecord.tmdid.Equals(tmdid))
                    {
                        return Ok(new { code = 200, lessonRecord });
                    }
                    else
                    {
                        ///不是本人的课例
                        ///(非授权信息） 服务器已成功处理了请求，但返回的信息可能来自另一来源。
                        return Ok(new { code = 2031, lessonRecord });
                    }
                }
            }
            else {
                return Ok(new { code = 404, msg = "课例不存在" });
            }
        }
    }
}