TEAMModelOS/TEAMModelOS/Controllers/Both/GroupListController.cs

using Azure.Cosmos;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.Linq;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using Azure;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using Azure.Messaging.ServiceBus;
using Microsoft.Extensions.Configuration;
using TEAMModelOS.Filter;
using HTEXLib.COMM.Helpers;
using System.Text;
using TEAMModelOS.SDK.Models.Service;
using Microsoft.AspNetCore.Authorization;

namespace TEAMModelOS.Controllers
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]

    [Route("grouplist")]
    [ApiController]
    public class GroupListController : ControllerBase
    {
        private AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly AzureStorageFactory _azureStorage;
        private readonly NotificationService _notificationService;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private const string SummarySql = " c.id,c.code,c.name,c.no,c.periodId,c.scope,c.school,c.creatorId,c.type,c.year,c.tcount,c.scount,c.leader ,c.froms ,c.joinLock ";
        public IConfiguration _configuration { get; set; }
        public GroupListController(CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration, NotificationService notificationService)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _option = option?.Value;
            _serviceBus = serviceBus;
            _configuration = configuration;
            _azureStorage = azureStorage;
            _notificationService = notificationService;
            _coreAPIHttpService = coreAPIHttpService;
        }
        //学生获取自己已经加入的名单。
        [ProducesDefaultResponseType]
        [HttpPost("get-student-joined-grouplist")]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "admin,teacher,student")]
        public async Task<IActionResult> GetMyCourseAndGroupList(JsonElement json)
        {
            var (userid, _name, _picture,school) = HttpContext.GetAuthTokenInfo();
            var client = _azureCosmos.GetCosmosClient();
            object scope = null;  
            HttpContext?.Items.TryGetValue("Scope", out scope);
            int memberType =2;
            if ($"{scope}".Equals(Constant.ScopeStudent))
            {
                memberType = 2;
               // Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{school}"));
            }
            if ($"{scope}".Equals(Constant.ScopeTmdUser))
            {
                memberType = 1;
            }
            if ($"{scope}".Equals(Constant.ScopeTeacher))
            {
                memberType = 1;
            }
            List<GroupListGrp> groups=  await  GroupListService.GetMemberInGroupList(_coreAPIHttpService, client, _dingDing, userid, memberType, school, new List<string> { "class", "teach" });
            return Ok(new { groups = groups });
        }



        /// <summary>
        /// 扫码加入名单
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("scan-code-join-list")]
        public async Task<IActionResult> ScanCodeJoinList(JsonElement json)
        {
            if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
            json.TryGetProperty("school", out JsonElement school);
            var client = _azureCosmos.GetCosmosClient();
            json.TryGetProperty("id_token", out JsonElement id_token);
            var jwt = new JwtSecurityToken(id_token.GetString());
            var id = jwt.Payload.Sub;
            jwt.Payload.TryGetValue("name", out object name);
            jwt.Payload.TryGetValue("picture", out object picture);
            try
            {
                TmdUser tmduser = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<TmdUser>(id, new PartitionKey("Base"));
            }
            catch (CosmosException ex)
            {
                if (ex.Status == 404)
                {
                    //如果沒有，則初始化Teacher基本資料到Cosmos
                    TmdUser tmduser = new TmdUser
                    {
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        id = id,
                        pk = "Base",
                        code = "Base",
                        name = name?.ToString(),
                        picture = picture?.ToString(),
                        //创建账号并第一次登录IES5则默认赠送1G
                        defaultSchool = null,
                        schools = new List<TmdUser.School>(),
                    };
                    await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Student").CreateItemAsync<TmdUser>(tmduser, new PartitionKey("Base"));
                }
            }
            (int status, GroupList stuList,Member member) data = await GroupListService.CodeJoinList(client, $"{_stuListNo}", id, type: 1, $"{school}");
            //没有TmdUser时
            if (data.status == 0)
            {
                await GroupListService.UpsertList(data.stuList, _azureCosmos, _configuration, _serviceBus);

                List<string> ids = new List<string>();
                if (data.stuList.scope.Equals("private") && !string.IsNullOrEmpty(data.stuList.creatorId))
                {
                    ids.Add(data.stuList.creatorId);
                }
                else if (data.stuList.scope.Equals("school") && !string.IsNullOrEmpty(data.stuList.school))
                {
                    //通知管理员
                    string sql = "select distinct  value(c.id) from c where array_contains(c.roles,'admin')";
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<string>(queryText: sql,
                                    requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Teacher-{school}") }))
                    {
                        ids.Add(item);
                    }
                }
                if (ids.IsNotEmpty())
                {
                    string bizcode = "scan-join";
                    Notification notification = new Notification
                    {
                        hubName = "hita",
                        type = "msg",
                        from = $"ies5:{_option.Location}:private",
                        to = ids.Select(x => x).ToList(),
                        label = $"{bizcode}_groupList",
                        body = new { location = _option.Location, biz = bizcode, tmdid = id, tmdname = name, groupListName = $"{data.stuList.name}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
                        expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
                    };
                    var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
                    var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                    var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                    var location = _option.Location;
                    var code = await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);
                }
                return Ok(new { data.stuList, data.status });
            }
            else
            {
                return Ok(new { data.status });
            }

        }

        /// <summary>
        /// 根据邀请码加入名单
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "admin,teacher,student")]
        [HttpPost("input-code-join-list")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> InputCodeJoinList(JsonElement json)
        {
            if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
            var (userid, _name, _picture, school) = HttpContext.GetAuthTokenInfo();
            object scope = null;
            int type = 0;
            string no = null;
            var client = _azureCosmos.GetCosmosClient();
            HttpContext?.Items.TryGetValue("Scope", out scope);
            if ($"{scope}".Equals(Constant.ScopeStudent))
            {
                type = 2;
                Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{school}"));
                no = student.no;

            }
            if ($"{scope}".Equals(Constant.ScopeTmdUser))
            {
                type = 1;
            }
            if ($"{scope}".Equals(Constant.ScopeTeacher))
            {
                type = 1;
            }
            (int status, GroupList stuList, Member member) data = await GroupListService.CodeJoinList(client, $"{_stuListNo}", userid, type, school);
            if (data.status == 0)
            {

                await GroupListService.UpsertList(data.stuList, _azureCosmos, _configuration, _serviceBus);

                List<string> ids = new List<string>();
                if (data.stuList.scope.Equals("private") && !string.IsNullOrEmpty(data.stuList.creatorId))
                {
                    ids.Add(data.stuList.creatorId);
                }
                else if (data.stuList.scope.Equals("school") && !string.IsNullOrEmpty(data.stuList.school))
                {
                    //通知管理员
                    string sql = "select distinct  value(c.id) from c where array_contains(c.roles,'admin')";
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<string>(queryText: sql,
                                    requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Teacher-{school}") }))
                    {
                        ids.Add(item);
                    }
                }
                if (ids.IsNotEmpty())
                {
                    string bizcode = "scan-join";
                    Notification notification = new Notification
                    {
                        hubName = "hita",
                        type = "msg",
                        from = $"ies5:{_option.Location}:private",
                        to = ids.Select(x => x).ToList(),
                        label = $"{bizcode}_groupList",
                        body = new { location = _option.Location, biz = bizcode, tmdid = userid, tmdname = _name, groupListName = $"{data.stuList.name}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
                        expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
                    };
                    var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
                    var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                    var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                    var location = _option.Location;
                    var code = await _notificationService.SendNotification(clientID, clientSecret, location, url, notification);
                }
                return Ok(new { data.stuList, data.status });
            }
            else
            {
                return Ok(new { data.status });
            }

        }
        /// <summary>
        /// 获取名单的tags
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "admin,teacher,student")]
        [HttpPost("get-grouplist-tags")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetGrouplistTags(JsonElement json)
        {
            var client = _azureCosmos.GetCosmosClient();
            var (id, _, _, school) = HttpContext.GetAuthTokenInfo();
            object scope = null;
            StringBuilder sql = new StringBuilder($"SELECT  {SummarySql} ,A1.tag FROM c " +
                $" join A1 in  c. members where A1.id='{id}' and A1.tag<>null  ");
            HttpContext?.Items.TryGetValue("Scope", out scope);
            if (!string.IsNullOrEmpty(school) && $"{scope}".Equals(Constant.ScopeStudent))
            {
                sql.Append($" and  A1.code='{school}'");
            }
            List<dynamic> groupLists = new List<dynamic>();
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
                        GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
            {
                groupLists.Add(item);
            }
            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
                       GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList") }))
            {
                groupLists.Add(item);
            }
            return Ok(new { groupLists });
        }
        /// <summary>
        /// 获取发布活动的名单
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-activity-grouplist")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetActivityGrouplist(JsonElement json)
        {
            var client = _azureCosmos.GetCosmosClient();
            json.TryGetProperty("tmdid", out JsonElement tmdid);
            json.TryGetProperty("schoolId", out JsonElement schoolId);
            if (!json.TryGetProperty("opt", out JsonElement opt)) { return BadRequest(); }
            json.TryGetProperty("periodId", out JsonElement periodId);

            List<GroupListGrp> groupLists = new List<GroupListGrp>();
            switch (true)
            {
                //我管理的
                case bool when $"{opt}".Equals("manage", StringComparison.OrdinalIgnoreCase):
                    //包含，学校的行政班，教学班
                    json.TryGetProperty("type", out JsonElement _type);
                    List<string> types = null;
                    if (_type.ValueKind.Equals(JsonValueKind.Array))
                    {
                        types = _type.ToObject<List<string>>();
                    }
                    else if (_type.ValueKind.Equals(JsonValueKind.String))
                    {
                        types = new List<string> { $"{types}" };
                    }
                    if (types.IsEmpty() || types.Contains("class"))
                    {
                        StringBuilder classsql = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year  FROM c where   c.graduate = 0 or  IS_DEFINED(c.graduate) = false ");
                        if (!string.IsNullOrEmpty($"{periodId}"))
                        {
                            classsql.Append($" where  c.periodId='{periodId}' ");
                        }
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: classsql.ToString(),
                            requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{schoolId}") }))
                        {
                            HashSet<string> groupNames = new HashSet<string>();
                            string gpsql = $"SELECT distinct c.groupId,c.groupName FROM c where  c.classId='{item.id}'and c.groupName <>null";
                            await foreach (var gp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: gpsql,
                                requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{schoolId}") }))
                            {
                                groupNames.Add(gp.groupName);
                            }
                            ///行政班（学生搜寻classId动态返回）class
                            GroupListGrp group = new GroupListGrp
                            {
                                id = item.id,
                                code = $"GroupList-{schoolId}",
                                name = item.name,
                                periodId = item.periodId,
                                scope = "school",
                                school = $"{schoolId}",
                                type = "class",
                                year = item.year,
                                groupName = groupNames
                            };
                            groupLists.Add(group);
                        }
                    }

                    if (types.IsEmpty() || types.Contains("teach"))
                    {
                        //教学班
                        StringBuilder teachsql = new StringBuilder($" SELECT distinct value(c) FROM c  where c.type='teach'");
                        if (!string.IsNullOrEmpty($"{periodId}"))
                        {
                            teachsql.Append($" and c.periodId='{periodId}'");
                        }
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
                            GetItemQueryIterator<GroupList>(queryText: teachsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
                        {
                            HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
                            groupLists.Add(new GroupListGrp(item, groupName));
                        }
                    }

                    if (types.IsEmpty() || types.Contains("research"))
                    {
                        //教研组
                        StringBuilder researchsql = new StringBuilder($"SELECT distinct value(c) FROM c   where c.type='research'");
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
                            GetItemQueryIterator<GroupList>(queryText: researchsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
                        {
                            HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
                            groupLists.Add(new GroupListGrp(item, groupName));
                        }
                    }

                    if (types.IsEmpty() || types.Contains("yxtrain"))
                    {
                        //研修名单
                        StringBuilder yxtrainsql = new StringBuilder($"SELECT distinct value(c) FROM c    where c.type='yxtrain'");
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
                            GetItemQueryIterator<GroupList>(queryText: yxtrainsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
                        {
                            HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
                            groupLists.Add(new GroupListGrp(item, groupName));
                        }
                    }
                    return Ok(new { groupLists });
                case bool when $"{opt}".Equals("teach", StringComparison.OrdinalIgnoreCase):
                    //我执教的
                    //从学校的课程和个人课程搜寻与我相关的课程对应的名单。
                    List<TeachCourse> teachCourses = new List<TeachCourse>();
                    if (!string.IsNullOrEmpty($"{schoolId}"))
                    {
                        var schoolQuery = new StringBuilder($"select distinct c.name,c.id, c.scope,c.subject,c.period,A0 schedule  from c join A0 in c.schedule where A0.teacherId = '{tmdid}'");
                        if (!string.IsNullOrEmpty($"{periodId}"))
                        {
                            schoolQuery.Append($"   and c.period.id='{periodId}' ");
                        }
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
                           GetItemQueryIterator<TeachCourse>(queryText: schoolQuery.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{schoolId}") }))
                        {
                            teachCourses.Add(item);
                        }
                    }
                    var query = new StringBuilder($"select distinct c.name,c.id, c.scope,c.subject,c.period,A0 schedule  from c join A0 in c.schedule where A0.teacherId = '{tmdid}'");
                    await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
                     GetItemQueryIterator<TeachCourse>(queryText: query.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{tmdid}") }))
                    {
                        teachCourses.Add(item);
                    }
                    var classIds = teachCourses.Select(x => x.schedule).Where(y => !string.IsNullOrEmpty(y.classId)).Select(x => x.classId).Distinct().ToList();
                    var schedule = teachCourses.Where(y => !string.IsNullOrEmpty(y.schedule.stulist)).Distinct().ToList();
                    //var schedule = teachCourses.Select(x => new { schedule = x.schedule.Where(mm=>!string.IsNullOrEmpty(mm.stulist)), scope = x.scope }).ToList();
                    if (classIds.IsNotEmpty())
                    {
                        string insql = string.Join(",", classIds.Select(x => $"'{x}'"));
                        query = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year  FROM c where c.id in ({insql}) and ( c.graduate = 0 or  IS_DEFINED(c.graduate) = false) ");
                        ///行政班（学生搜寻classId动态返回）class
                        await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText:  query.ToString(),
                        requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{schoolId}") }))
                        {
                            HashSet<string> groupNames = new HashSet<string>();
                            string gpsql = $"SELECT distinct c.groupId,c.groupName FROM c where  c.classId='{item.id}'and c.groupName <>null";
                            await foreach (var gp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: gpsql,
                                requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{schoolId}") }))
                            {
                                groupNames.Add(gp.groupName);
                            }
                            GroupListGrp group = new GroupListGrp
                            {
                                id = item.id,
                                code = $"GroupList-{schoolId}",
                                name = item.name,
                                periodId = item.periodId,
                                scope = "school",
                                school = $"{schoolId}",
                                type = "class",
                                year = item.year,
                                groupName = groupNames
                            };
                            groupLists.Add(group);
                        }
                    }
                    if (schedule.IsNotEmpty())
                    {
                        var privateList = schedule.Where(x => x.scope.Equals("private")).Select(x => x.schedule.stulist).Distinct();
                        if (privateList.Count() > 0)
                        {
                            string insql = string.Join(",", privateList.Select(x => $"'{x}'"));
                            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupList>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql})",
                             requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
                            {
                                HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
                                groupLists.Add(new GroupListGrp(item, groupName));

                            }
                        }
                        var schoolList = schedule.Where(x => x.scope.Equals("school")).Select(x => x.schedule.stulist).Distinct();
                        if (schoolList.Count() > 0)
                        {
                            List<GroupListDto> groups = new List<GroupListDto>();
                            string insql = string.Join(",", schoolList.Select(x => $"'{x}'"));
                            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql})",
                            requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{schoolId}") }))
                            {
                                HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
                                groupLists.Add(new GroupListGrp(item, groupName));
                            }
                        }
                    }
                    List<CourseGroupList> courseGroups = new List<CourseGroupList>();
                    teachCourses.GroupBy(y => (y.id, y.name, y.scope, y.period.name, y.period.id, y.subject.name, y.subject.id)).ToList().ForEach(x => {
                        List<GroupListGrp> classIds = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.classId)).Select(b => b.schedule.classId).Contains(n.id)).ToList();
                        List<GroupListGrp> stulists = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.stulist)).Select(b => b.schedule.stulist).Contains(n.id)).ToList();
                        if (classIds == null)
                        {
                            classIds = new List<GroupListGrp>();
                        }
                        if (stulists != null)
                        {
                            classIds.AddRange(stulists);
                        }
                        CourseGroupList groupList = new CourseGroupList()
                        {
                            scope = x.Key.Item3,
                            subject = x.Key.Item6,
                            subjectId = x.Key.Item7,
                            period = x.Key.Item4,
                            periodId = x.Key.Item5,
                            id = x.Key.Item1,
                            name = x.Key.Item2,
                            groups = classIds
                        };
                        courseGroups.Add(groupList);
                    });
                    return Ok(new { groupLists = courseGroups });
                case bool when $"{opt}".Equals("private", StringComparison.OrdinalIgnoreCase):
                    //我个人的
                    break;
                default:
                    break;
            }
            return Ok(new { error = 1, msg = "参数异常" });
        }

        /// <summary>
        /// 根据任意名单id获取成员信息。
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-members-listids")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetMembersListids(JsonElement json)
        {
            var client = _azureCosmos.GetCosmosClient();
            if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
            json.TryGetProperty("schoolId", out JsonElement schoolId);
            json.TryGetProperty("groupNames", out JsonElement groupNames);
            List<Dictionary<string, List<string>>> groupLists = new List<Dictionary<string, List<string>>>();
            if (groupNames.ValueKind.Equals(JsonValueKind.Array))
            {
                groupLists = groupNames.ToObject<List<Dictionary<string, List<string>>>>();
            }
            List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
            if (groupLists.Count > 0)
            {
                foreach (var gp in groupLists)
                {
                    foreach (KeyValuePair<string, List<string>> pp in gp)
                    {
                        ps.Add((pp.Key, pp.Value));
                    }
                }
            }
            List<string> listids = ids.ToObject<List<string>>();
            (List<RMember> members, List<RGroupList> groups) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, listids, $"{schoolId}", ps);
            return Ok(new { groups, members });
        }
        /// <summary>
        /// 根据任意名单id获取名单摘要信息。
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-grouplist-listids")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetGroupListListids(JsonElement json)
        {
            var client = _azureCosmos.GetCosmosClient();
            if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
            json.TryGetProperty("schoolId", out JsonElement schoolId);
            List<string> listids = ids.ToObject<List<string>>();
            List<GroupListDto> groups = await GroupListService.GetGroupListByListids(client, _dingDing, listids, $"{schoolId}", SummarySql);
            return Ok(new { groups });
        }
        /// <summary>
        /// 获取名单和成员信息。
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-grouplists-members")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetGrouplistsMembers(JsonElement json)
        {
            try
            {
                var client = _azureCosmos.GetCosmosClient();
                json.TryGetProperty("tmdid", out JsonElement _tmdid);
                json.TryGetProperty("schoolId", out JsonElement _schoolId);
                if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
                if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
                json.TryGetProperty("periodId", out JsonElement periodId);
                json.TryGetProperty("no", out JsonElement no);
                StringBuilder sql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='{type}'");
                List<RGroupList> groups = new List<RGroupList>();
                string tbname = "Teacher";
                string code = $"GroupList";
                if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
                {
                    tbname = "School";
                    code = $"GroupList-{_schoolId}";
                    if (!string.IsNullOrEmpty($"{periodId}"))
                    {
                        sql.Append($" and c.periodId='{periodId}'");
                    }
                    if (!string.IsNullOrEmpty($"{no}"))
                    {
                        sql.Append($" and c.no='{no}'");
                    }
                }
                else
                {
                    sql.Append($" and c.creatorId='{_tmdid}'");
                }
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<RGroupList>(queryText: sql.ToString(),
                 requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
                {
                    groups.Add(item);
                }
                (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(_coreAPIHttpService, client, $"{type}", groups, tbname, _dingDing, $"{_schoolId}");
                return Ok(new { groups = groupsData, members });
            }
            catch (CosmosException ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplists-members()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplists-members()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
            }
            return Ok();
        }
        /// <summary>
        /// 获取名单列表
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-grouplists")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetGrouplists(JsonElement json)
        {
            try
            {
                var client = _azureCosmos.GetCosmosClient();
                json.TryGetProperty("tmdid", out JsonElement _tmdid);
                json.TryGetProperty("schoolId", out JsonElement _schoolId);
                if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
                if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
                json.TryGetProperty("periodId", out JsonElement periodId);
                json.TryGetProperty("no", out JsonElement no);
                StringBuilder sql = new StringBuilder($"SELECT distinct {SummarySql} FROM c where c.type='{type}'");

                List<GroupListDto> groups = new List<GroupListDto>();
                string tbname = "Teacher";
                string code = $"GroupList";
                if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
                {
                    tbname = "School";
                    code = $"GroupList-{_schoolId}";
                    if (!string.IsNullOrEmpty($"{periodId}"))
                    {
                        sql.Append($" and c.periodId='{periodId}'");
                    }
                    if (!string.IsNullOrEmpty($"{no}"))
                    {
                        sql.Append($" and c.no='{no}'");
                    }
                }
                else
                {
                    sql.Append($" and c.creatorId='{_tmdid}'");
                }
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<GroupListDto>(queryText: sql.ToString(),
                 requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
                {
                    groups.Add(item);
                }
                return Ok(new { groups });
            }
            catch (CosmosException ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplists()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplists()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
            }
            return Ok();
        }
        /// <summary>
        /// 根据id,code获取学校行政班信息和学生信息。用于维护学生基本信息。
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("get-classstudents-idcode")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetClassStudentsIdcode(JsonElement json)
        {
            if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
            if (!json.TryGetProperty("code", out JsonElement _code)) return BadRequest();
            try
            {
                var client = _azureCosmos.GetCosmosClient();
                Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"Class-{_code}"));
                List<Student> students = new List<Student>();
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
                    requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
                {
                    item.salt = null;
                    item.pw = null;
                    students.Add(item);
                }
                return Ok(new { classInfo = clazz, students = students });
            }
            catch (Exception ex)
            {
                return Ok(new { error = 404, msg = "班级不存在!" });
            }

        }
        //处理通用名单
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("get-grouplist-idcode")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> GetGrouplistIdcode(JsonElement json)
        {
            RGroupList groupList = null;
            try
            {
                var client = _azureCosmos.GetCosmosClient();
                json.TryGetProperty("type", out JsonElement _type);
                json.TryGetProperty("code", out JsonElement _code);
                if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
                if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
                string tbname = $"{scope}".Equals("private") ? "Teacher" : "School";
                string code = "";
                if (string.IsNullOrEmpty($"{_type}") || !$"{_type}".Equals("class"))
                {
                    if ($"{scope}".Equals("private"))
                    {
                        //私人名单
                        code = "GroupList";
                    }
                    else
                    {
                        //学校自定义名单
                        code = !code.StartsWith("GroupList-") ? $"GroupList-{_code}" : code;
                    }
                    groupList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<RGroupList>($"{id}", new PartitionKey($"{code}"));
                }
                else if ($"{_type}".Equals("class"))
                {
                    try
                    {
                        code = $"Class-{_code}";
                        Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"{code}"));
                        if (clazz != null)
                        {
                            List<Student> students = new List<Student>();
                            await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
                                requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
                            {
                                students.Add(item);
                            }
                            ///行政班（学生搜寻classId动态返回）class
                            List<RMember> smembers = students.Where(x => x.classId.Equals(clazz.id)).Select(y => new RMember { id = y.id, code = $"{_code}", name = y.name, type = 2, picture = y.picture, no = y.no, classId = y.classId, groupId = y.groupId, groupName = y.groupName }).ToList();
                            groupList = new RGroupList
                            {
                                id = clazz.id,
                                code = $"GroupList-{clazz.school}",
                                name = clazz.name,
                                periodId = clazz.periodId,
                                pk = "GroupList",
                                year = clazz.year,
                                school = clazz.school,
                                scope = "school",
                                type = "class",
                                scount = smembers.Count,
                                no = clazz.no,
                                leader = clazz.teacher?.id,
                                members = smembers,
                            };
                        }
                    }
                    catch (CosmosException ex)
                    {
                        await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                        return Ok(new { groupList });
                    }
                }
                (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(_coreAPIHttpService, client, $"{groupList.type}", new List<RGroupList> { groupList }, tbname, _dingDing, $"{_code}");
                groupList = groupsData.FirstOrDefault();
            }
            catch (CosmosException ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n {json}", GroupNames.醍摩豆服務運維群組);
                return Ok(new { groupList });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n{json}", GroupNames.醍摩豆服務運維群組);
            }
            return Ok(new { groupList });
        }

        /// <summary>
        /// 保存或更新通用名单
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("upsert-grouplist")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> UpsertGroupList(GroupList list)
        {
            try
            {
                var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
                if (string.IsNullOrEmpty(list.type))
                {
                    return BadRequest();
                }
                list.year = list.year > 0 ? list.year : DateTimeOffset.UtcNow.Year;
                list.ttl = -1;
                list.creatorId = userid;
                list.school = string.IsNullOrEmpty(list.school) ? school : list.school;
                list.pk = "GroupList";
                if (list.scope.Equals("private"))
                {
                    //私人名单
                    list.code = "GroupList";
                    list.school = null;
                }
                else
                {
                    //学校自定义名单
                    list.code = !list.code.StartsWith("GroupList-") ? $"GroupList-{list.code}" : list.code;
                }
                switch (true)
                {
                    //普通学生名单（包含学校教学班名单，个人课程名单），其中学生成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList-hbcn
                    case bool when $"{list.type}".Equals("teach", StringComparison.OrdinalIgnoreCase):
                        list.type = "teach";
                        list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
                        list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
                        break;
                    //教研组名单，只有加入学校的老师名单 成员账号类型是醍摩豆ID，保存在学校表，分区键为GroupList-hbcn
                    case bool when $"{list.type}".Equals("research", StringComparison.OrdinalIgnoreCase):
                        list.type = "research";
                        list.scope = "school";
                        list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
                        break;
                    //个人好友名单，成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList
                    case bool when $"{list.type}".Equals("friend", StringComparison.OrdinalIgnoreCase):
                        list.type = "friend";
                        list.scope = "private";
                        list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
                        break;
                    //社交群组类型（包含学校交流群组，个人交流群组），成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn 
                    case bool when $"{list.type}".Equals("group", StringComparison.OrdinalIgnoreCase):
                        list.type = "group";
                        list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
                        list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
                        break;
                    //社交群组类型（包含学校交流群组，个人交流群组），成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn 
                    case bool when $"{list.type}".Equals("yxtrain", StringComparison.OrdinalIgnoreCase):
                        list.type = "yxtrain";
                        list.scope = "school";
                        list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
                        break;
                    default:
                        return Ok(new { error = 400, msg = "参数错误！" });
                }
                return Ok(new { list });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/upsert-grouplist()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return BadRequest();
            }
        }

        //删除名单
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("delete-grouplist")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> DeleteGroupList(JsonElement json)
        {
            try
            {
                if (!json.TryGetProperty("code", out JsonElement code)) return BadRequest();
                if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
                if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
              
                string tbname = "";
                string datacode = "";
                if (scope.ToString().Equals("school", StringComparison.OrdinalIgnoreCase))
                {
                    tbname = "School";
                    datacode = $"GroupList-{code}";
                }
                else
                {
                    tbname = "Teacher";
                    datacode = $"GroupList";
                }
                try
                {
                    await GroupListService.DeleteGrouplistEvent($"{id}", datacode, tbname, client, _configuration, _serviceBus);
                }
                catch (Exception ex) {  }
                return Ok(new { id });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，grouplist/delete-grouplist()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return Ok(new { error = 400 });
            }
        }

        /// <summary>
        /// 保存或更新通用名单
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("upsert-group-member")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> UpsertGroupMember(JsonElement json)
        {
            if (!json.TryGetProperty("opt", out JsonElement _opt)) { return BadRequest(); }
            if (!json.TryGetProperty("scope", out JsonElement _scope)) { return BadRequest(); }
            if (!json.TryGetProperty("id", out JsonElement _id)) { return BadRequest(); }
            if (!json.TryGetProperty("code", out JsonElement _code)) { return BadRequest(); }
            if (!json.TryGetProperty("type", out JsonElement _type)) { return BadRequest(); }
            try
            {
                GroupList groupList = null;
                string tbname = $"{_scope}".Equals("private") ? "Teacher" : "School";
                string code = "";
                if (string.IsNullOrEmpty($"{_type}") || !$"{_type}".Equals("class"))
                {
                    if ($"{_scope}".Equals("private"))
                    {
                        //私人名单
                        code = "GroupList";
                    }
                    else
                    {
                        //学校自定义名单
                        code = !code.StartsWith("GroupList-") ? $"GroupList-{_code}" : code;
                    }
                    groupList = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<GroupList>($"{_id}", new PartitionKey($"{code}"));
                }
                switch (true)
                {
                    case bool when $"{_opt}".Equals("up-nickname", StringComparison.OrdinalIgnoreCase) && json.TryGetProperty("members", out JsonElement _members):
                        var members = _members.ToObject<List<Member>>();
                        List<Member> updateSuccess = new List<Member>();
                        List<Member> updateFailed = new List<Member>();
                        members.ForEach(x => {
                            var member = groupList.members.Find(z => z.type == x.type && z.id.Equals(x.id));
                            if (member != null)
                            {
                                member.nickname = x.nickname;
                                updateSuccess.Add(member);
                            }
                            else
                            {
                                updateFailed.Add(x);
                            }
                        });
                        await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<GroupList>(groupList, $"{_id}", new PartitionKey(code));
                        return Ok(new { updateSuccess, updateFailed });
                }
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{_option.Location},更新名单成员信息异常{ex.Message}\n{ex.StackTrace}\n", GroupNames.成都开发測試群組);
                return BadRequest();
            }

            return Ok();
        }
    }
}