123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320 |
- using Azure.Cosmos;
- using System;
- using System.Collections.Generic;
- using System.Threading.Tasks;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models.Cosmos.Common;
- using HTEXLib.COMM.Helpers;
- using System.Linq;
- using System.Text;
- using System.Text.Json;
- using TEAMModelOS.Models;
- using Azure.Messaging.ServiceBus;
- using Microsoft.Extensions.Configuration;
- using TEAMModelOS.SDK.Models.Service;
- using System.Text.RegularExpressions;
- using TEAMModelOS.SDK.Models;
- using System.Net.Http;
- namespace TEAMModelOS.SDK
- {
- public class GroupListService
- {
- public static async Task DeleteGrouplistEvent(string id , string code,string tbname ,CosmosClient client, IConfiguration _configuration, AzureServiceBusFactory _serviceBus)
- {
- GroupChange change = new GroupChange();
- GroupList groupList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<GroupList>(id.ToString(), new PartitionKey(code));
- var tleave = groupList.members.FindAll(x => x.type == 1);
- if (tleave.IsNotEmpty())
- {
- if (groupList.type.Equals("research") || groupList.type.Equals("yxtrain"))
- {
- change.tchleave.AddRange(tleave);
- }
- else
- {
- change.tmdleave.AddRange(tleave);
- }
- }
- var sleave = groupList.members.FindAll(x => x.type == 2);
- if (sleave.IsNotEmpty())
- {
- change.stuleave.AddRange(sleave);
- }
- change.listid = groupList.id;
- change.scope = groupList.scope;
- change.originCode = $"{code}";
- change.school = groupList.school;
- change.creatorId = groupList.creatorId;
- change.type = groupList.type;
- change.status = "delete";
- if (change.tmdleave.IsNotEmpty() || change.tchleave.IsNotEmpty() || change.stuleave.IsNotEmpty())
- {
- var messageChange = new ServiceBusMessage(change.ToJsonString());
- messageChange.ApplicationProperties.Add("name", "GroupChange");
- var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
- await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
- }
- await client.GetContainer(Constant.TEAMModelOS, tbname).DeleteItemStreamAsync(id.ToString(), new PartitionKey(code));
- }
- /// <summary>
- /// 查询名单成员所在的名单列表,
- /// </summary>
- /// <param name="_coreAPIHttpService"></param>
- /// <param name="client"></param>
- /// <param name="_dingDing"></param>
- /// <param name="memberId">成员id </param>
- /// <param name="memberType">成员类型</param>
- /// <param name="school">成员所在的学校 ,可为空</param>
- /// <param name="groupTypes">过滤名单的类型集合,不传则是全部</param>
- /// <param name="graduate">毕业类型0在校,1毕业 , -1查全部。</param>
- /// <returns></returns>
- public static async Task<List<GroupListGrp>> GetMemberInGroupList(CoreAPIHttpService _coreAPIHttpService, CosmosClient client, DingDing _dingDing, string memberId, int memberType, string school,List<string> groupTypes,int graduate =-1) {
- List<GroupListGrp> groupLists = new List<GroupListGrp>();
- if (groupTypes.IsEmpty() || groupTypes.Contains("class")) {
- if (!string.IsNullOrWhiteSpace(school) && memberType == 2)
- {
- Student student = null;
- try
- {
- student = await client.GetContainer(Constant.TEAMModelOS, Constant.Student).ReadItemAsync<Student>(memberId, new PartitionKey($"Base-{school}"));
- }
- catch (CosmosException ex) when (ex.Status == 404)
- {
- return null;
- }
- if (!string.IsNullOrWhiteSpace(student.classId))
- {
- try
- {
- Class clazz = await client.GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<Class>(student.classId, new PartitionKey($"Class-{school}"));
- GroupListGrp groupList = new GroupListGrp
- {
- 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",
- no = clazz.no,
- leader = clazz.teacher?.id,
- graduate=clazz.graduate,
- };
- //graduate传入的状态>=0 表示指定状态查询,且传入的状态与数据库的状态一致。
- if (graduate >= 0 )
- {
- if (groupList.graduate == graduate) {
- groupLists.Add(groupList);
- }
- }
- //全部。
- else if(graduate == -1)
- {
- groupLists.Add(groupList);
- }
- }
- catch (CosmosException ex) when (ex.Status == 404)
- {
- }
- }
- }
- }
- 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 ";
- if (groupTypes.IsEmpty() || groupTypes.Contains("teach")) {
- //教学班
- string teachsql="";
- if (!string.IsNullOrWhiteSpace(school) && memberType == 2) {
- teachsql= $"SELECT distinct {SummarySql} FROM c join m in c.members where c.type='teach' and m.id='{memberId}' and m.code='{school}' and m.type=2 ";
- }
- if (memberType == 1)
- {
- teachsql=$"SELECT distinct {SummarySql} FROM c join m in c.members where c.type='teach' and m.id='{memberId}' and m.type=1 ";
- }
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
- GetItemQueryIterator<GroupList>(queryText: teachsql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
- {
- HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
- groupLists.Add(new GroupListGrp(item, groupName));
- }
- //个人名单
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).
- GetItemQueryIterator<GroupList>(queryText: teachsql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList") }))
- {
- HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
- groupLists.Add(new GroupListGrp(item, groupName));
- }
- }
- if (!string.IsNullOrWhiteSpace(school) && (groupTypes.IsEmpty() || groupTypes.Contains("research")))
- {
- //教研组
- string teachsql = $"SELECT distinct {SummarySql} FROM c join m in c.members where c.type='research' and m.id='{memberId}' and m.type=1 ";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
- GetItemQueryIterator<GroupList>(queryText: teachsql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
- {
- HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
- groupLists.Add(new GroupListGrp(item, groupName));
- }
- }
- if (!string.IsNullOrWhiteSpace(school) && (groupTypes.IsEmpty() || groupTypes.Contains("yxtrain")))
- {
- //研修名单
- string teachsql = $"SELECT distinct {SummarySql} FROM c join m in c.members where c.type='yxtrain' and m.id='{memberId}' and m.type=1 ";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
- GetItemQueryIterator<GroupList>(queryText: teachsql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
- {
- HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
- groupLists.Add(new GroupListGrp(item, groupName));
- }
- }
- return groupLists;
- }
- /// <summary>
- ///-1状态异常,0加入成功, 1加入学生或醍摩豆ID为空,2重复加入 ,3不允许跨校加入名单, 4表示个人名单未开放加入
- /// </summary>
- /// <param name="client"></param>
- /// <param name="_stuListNo"></param>
- /// <param name="userid"></param>
- /// <param name="type"></param>
- /// <param name="school"></param>
- /// <returns></returns>
- public static async Task<(int status, GroupList stuList,Member member)> CodeJoinList(CosmosClient client, string _stuListNo, string userid, int type, string school)
- {
- var queryNo = $"SELECT value(c) FROM c where c.no ='{_stuListNo}'";
- (int status, GroupList stuList,Member member) data = (-1, null,null);
- if (!string.IsNullOrEmpty(school))
- {
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: queryNo,
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
- {
- data = JoinList(item, userid, type, school);
- break;
- }
- }
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupList>(queryText: queryNo,
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
- {
- if (item.joinLock == 0) {
- //状态=4 表示未开放加入。
- return (4, item, null) ;
- }
- data = JoinList(item, userid, type, school);
- break;
- }
- return data;
- }
- public static (int status, GroupList stuList, Member member) JoinList(GroupList stuList, string userid, int type, string school)
- {
- int status = -1;
- if (!string.IsNullOrWhiteSpace(stuList.school) && !string.IsNullOrWhiteSpace(school))
- {
- if (!stuList.school.Equals(school))
- {
- status = 3;//不允许跨校加入名单
- return (status, stuList,null);
- }
- }
- string irs = string.Empty;
- List<string> irsOrder = stuList.members.Select(x => x.irs)?.Where(y => !string.IsNullOrEmpty(y) && Regex.IsMatch(y, @"^\d*$")).OrderBy(x => int.Parse(x)).ToList();
- if (!irsOrder.Contains("0"))
- {
- irsOrder.Insert(0, "0");
- }
- if (irsOrder != null)
- {
- if (!irsOrder.Contains("0"))
- {
- irsOrder.Insert(0, "0");
- }
- }
- else { irsOrder = new List<string>() { "0" }; }
- for (int i = 0; i < irsOrder.Count; i++)
- {
- irs = $"{int.Parse(irsOrder[i]) + 1}";
- int index = i + 1;
- if (index <= irsOrder.Count - 1)
- {
- if (!irs.Equals(irsOrder[index]))
- {
- break;
- }
- }
- }
- Member member = null;
- if (string.IsNullOrEmpty($"{userid}"))
- {
- //加入学生或醍摩豆ID为空
- status = 1;
- }
- else
- {
- if (type == 1)
- {
- member = stuList.members.Find(x => x.type == 1 && x.id.Equals(userid));
- if (member != null)
- {
- //重复加入
- status = 2;
- }
- else
- {
- //加入成功
- status = 0;
- member = new Member { id = userid, type = type, irs = irs, no = irs };
- stuList.members.Add(member);
- }
- }
- else if (type == 2)
- {
- member = stuList.members.Find(x => x.type == 2 && x.id.Equals(userid) && x.code.Equals(school));
- if (member != null)
- {
- //重复加入
- status = 2;
- }
- else
- {
- status = 0;
- member = new Member { id = userid, code = school, type = type, irs = irs, no = irs };
- stuList.members.Add(member);
- }
- }
- }
- return (status, stuList, member);
- }
- public static async Task<GroupList> UpsertList(GroupList list, AzureCosmosFactory _azureCosmos, IConfiguration _configuration, AzureServiceBusFactory _serviceBus)
- {
- bool isnew = false;
- var client = _azureCosmos.GetCosmosClient();
- if (string.IsNullOrEmpty(list.id))
- {
- list.id = Guid.NewGuid().ToString();
- isnew = true;
- }
- string tbname = list.scope.Equals("private") ? "Teacher" : "School";
- var tmembers = list.members.Where(x => x.type == 1);
- var smembers = list.members.Where(x => x.type == 2);
- list.scount = smembers.Count();
- list.tcount = tmembers.Count();
- //if (smembers.Count() > 0 && smembers.Select(x => x.code).ToHashSet().Count()>=2) {
- // //处理移除多个学校的名单,只保留一个学校的。
- // if (string.IsNullOrWhiteSpace(list.school))
- // {
- // HashSet<string> codes = smembers.Select(x => x.code).ToHashSet();
- // list.school = codes.First();
- // codes.Remove(codes.First());
- // list.members.RemoveAll(x => codes.Contains(x.code));
- // }
- // else {
- // list.members.RemoveAll(x => !x.code.Equals(list.school));
- // }
- //}
- if (string.IsNullOrWhiteSpace(list.school) && smembers.Count() >= 1)
- {
- list.school = smembers.First().code;
- }
- if (!string.IsNullOrWhiteSpace(list.school) && smembers.Count() == 0 && list.scope.Equals("private"))
- {
- list.school = null;
- }
- //学生名单,教研组会触发活动中间表刷新
- if (list.type.Equals("teach") || list.type.Equals("research") || list.type.Equals("yxtrain") || list.type.Equals("activity"))
- {
- GroupChange change = new GroupChange()
- {
- type = list.type,
- listid = list.id,
- scope = list.scope,
- originCode = list.school,
- school = list.school,
- creatorId = list.creatorId
- };
- GroupList oldList = null;
- if (!isnew)
- {
- try
- {
- oldList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<GroupList>(list.id, new PartitionKey(list.code));
- }
- catch (CosmosException)
- {
- oldList = null;
- }
- }
- if (list.members.IsNotEmpty() && (oldList == null || !oldList.members.IsNotEmpty()))
- {
- //加入的
- var tmdids = list.members.FindAll(x => x.type == 1);
- if (tmdids.IsNotEmpty())
- {
- if (list.type.Equals("research") || list.type.Equals("yxtrain"))
- {
- change.tchjoin.AddRange(tmdids);
- }
- else
- {
- change.tmdjoin.AddRange(tmdids);
- }
- }
- var stuids = list.members.FindAll(x => x.type == 2);
- if (stuids.IsNotEmpty())
- {
- change.stujoin.AddRange(stuids);
- }
- }
- else
- {
- if (list.members.IsNotEmpty())
- {
- var tmdids = list.members.FindAll(x => x.type == 1);
- var oldtmdids = oldList.members.FindAll(x => x.type == 1);
- //取各自的差集
- //新=》旧差集,表示新增
- var jointmdid = tmdids.Select(x => x.id).Except(oldtmdids.Select(y => y.id)).ToList();
- //旧=》新差集,表示离开
- var leavetmdid = oldtmdids.Select(x => x.id).Except(tmdids.Select(y => y.id)).ToList();
- if (list.type.Equals("research") || list.type.Equals("yxtrain"))
- {
- change.tchjoin.AddRange(tmdids.Where(x => jointmdid.Exists(y => y.Equals(x.id))));
- change.tchleave.AddRange(oldtmdids.Where(x => leavetmdid.Exists(y => y.Equals(x.id))));
- }
- else
- {
- change.tmdjoin.AddRange(tmdids.Where(x => jointmdid.Exists(y => y.Equals(x.id))));
- change.tmdleave.AddRange(oldtmdids.Where(x => leavetmdid.Exists(y => y.Equals(x.id))));
- }
- var stuids = list.members.FindAll(x => x.type == 2);
- var oldstuids = oldList.members.FindAll(x => x.type == 2);
- var joinstudent = stuids.Select(x => (x.id, x.code)).Except(oldstuids.Select(y => (y.id, y.code)), new CompareIdCode()).ToList();
- var leavestudent = oldstuids.Select(x => (x.id, x.code)).Except(stuids.Select(y => (y.id, y.code)), new CompareIdCode()).ToList();
- change.stujoin.AddRange(stuids.Where(x => joinstudent.Exists(y => y.id.Equals(x.id) && y.code.Equals(x.code))));
- change.stuleave.AddRange(oldstuids.Where(x => leavestudent.Exists(y => y.id.Equals(x.id) && y.code.Equals(x.code))));
- }
- else
- {
- //离开的
- if (oldList != null)
- {
- var tmdids = oldList.members.FindAll(x => x.type == 1);
- if (tmdids.IsNotEmpty())
- {
- if (list.type.Equals("research") || list.type.Equals("yxtrain"))
- {
- change.tchleave.AddRange(tmdids);
- }
- else
- {
- change.tmdleave.AddRange(tmdids);
- }
- }
- var stuids = oldList.members.FindAll(x => x.type == 2);
- if (stuids.IsNotEmpty())
- {
- change.stuleave.AddRange(stuids);
- }
- }
- }
- }
- if (change.tmdjoin.Count != 0 || change.tmdleave.Count != 0 || change.stujoin.Count != 0 || change.stuleave.Count != 0
- || change.tchjoin.Count != 0 || change.tchleave.Count != 0)
- {
- var messageChange = new ServiceBusMessage(change.ToJsonString());
- messageChange.ApplicationProperties.Add("name", "GroupChange");
- var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
- await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
- }
- }
- await client.GetContainer(Constant.TEAMModelOS, tbname).UpsertItemAsync(list, new PartitionKey(list.code));
- return list;
- }
- public static async Task<GroupList> CheckListNo(GroupList list, AzureCosmosFactory _azureCosmos, DingDing _dingDing, Option _option)
- {
- try
- {
- var client = _azureCosmos.GetCosmosClient();
- if (string.IsNullOrEmpty(list.no))
- {
- list.no = $"{Utils.CreatSaltString(6, "123456789")}";
- for (int i = 0; i < 10; i++)
- {
- List<string> noStus = new List<string>();
- var queryNo = $"SELECT c.no FROM c where c.no ='{list.no}'";
- if (list.scope.Equals("school"))
- {
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIterator(queryText: queryNo,
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"{list.code}") }))
- {
- using var jsonNo = await JsonDocument.ParseAsync(item.ContentStream);
- if (jsonNo.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = jsonNo.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- noStus.Add(account.GetProperty("no").GetString());
- }
- }
- }
- }
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryStreamIterator(queryText: queryNo,
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey("GroupList") }))
- {
- using var jsonNo = await JsonDocument.ParseAsync(item.ContentStream);
- if (jsonNo.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = jsonNo.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- noStus.Add(account.GetProperty("no").GetString());
- }
- }
- }
- if (noStus.Count == 0)
- {
- break;
- }
- else
- {
- if (i == 9)
- {
- string msg = $"OS,{_option.Location},school/course/upsert-list()\n 编号生成异常,重复生成次数超过10次";
- await _dingDing.SendBotMsg(msg, GroupNames.醍摩豆服務運維群組);
- throw new Exception(msg);
- }
- else
- {
- list.no = $"{Utils.CreatSaltString(6, "123456789")}";
- }
- }
- }
- }
- }
- catch (Exception ex)
- {
- }
- return list;
- }
- /// <summary>
- ///根据任意名单id获取名单摘要信息。
- /// </summary>
- /// <param name="client"></param>
- /// <param name="_dingDing"></param>
- /// <param name="classes"></param>
- /// <param name="school"></param>
- /// <param name="SummarySql"></param>
- /// <param name="graduate">毕业类型0在校,1毕业 , -1查全部。</param>
- /// <returns></returns>
- public static async Task<List<GroupListDto>> GetGroupListByListids(CosmosClient client, DingDing _dingDing, List<string> classes, string school,
- 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 " ,int graduate = -1)
- {
- classes.RemoveAll(x => x == null);
- if (!classes.IsNotEmpty()) {
- return null;
- }
- List<GroupListDto> groupLists = null;
- if (classes.Count == 1 && classes.First().Equals("TeacherAll") && !string.IsNullOrEmpty(school))
- {
- //默认的教研组
- GroupListDto groupList = new GroupListDto
- {
- id = "TeacherAll",
- name = "TeacherAll",
- code = $"GroupList-{school}",
- school = school,
- scope = "school",
- type = "yxtrain",
- };
- groupLists = new List<GroupListDto> { groupList };
- }
- else
- {
- Dictionary<string, List<GroupListDto>> groups = new Dictionary<string, List<GroupListDto>>();
- //List<Student> students = new List<Student>();
- string sql = string.Join(",", classes.Select(x => $"'{x}'"));
- if (!string.IsNullOrEmpty(school))
- {
- List<GroupListDto> schoolList = new List<GroupListDto>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupListDto>(queryText: $"select {SummarySql} from c where c.id in ({sql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
- {
- schoolList.Add(item);
- }
- if (schoolList.IsNotEmpty())
- {
- groups.Add("School", schoolList);
- }
- //取差集,减少二次搜寻
- classes = classes.Except(schoolList.Select(y => y.id)).ToList();
- if (classes.IsNotEmpty())
- {
- if (!groupLists.IsNotEmpty())
- {
- groupLists = new List<GroupListDto>();
- }
- string insql = string.Join(",", classes.Select(x => $"'{x}'"));
- //搜寻没有关联学生的行政班
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupListDto>(queryText:
- $"select 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.teacher.id as leader ,c.graduate from c where c.id in ({insql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{school}") }))
- {
- ///行政班(学生搜寻classId动态返回)class
- GroupListDto group = new GroupListDto
- {
- id = item.id,
- code = $"GroupList-{school}",
- name = item.name,
- periodId = item.periodId,
- scope = "school",
- school = school,
- type = "class",
- year = item.year,
- leader = item.leader,
- no = item.no,
- pk = "GroupList",
- graduate = item.graduate
- };
- //graduate传入的状态>=0 表示指定状态查询,且传入的状态与数据库的状态一致。
- if (graduate >= 0)
- {
- if (group.graduate == graduate)
- {
- groupLists.Add(group);
- }
- }
- //全部。
- else
- {
- groupLists.Add(group);
- }
- // groupLists.Add(group);
- }
- //取差集,减少二次搜寻
- classes = classes.Except(groupLists.Select(y => y.id)).ToList();
- }
- }
- if (classes.IsNotEmpty())
- {
- List<GroupListDto> privateList = new List<GroupListDto>();
- sql = string.Join(",", classes.Select(x => $"'{x}'"));
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupListDto>(queryText: $"select {SummarySql} from c where c.id in ({sql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
- {
- privateList.Add(item);
- //if (string.IsNullOrWhiteSpace(school))
- //{
- // privateList.Add(item);
- //}
- //else
- //{
- // if (!string.IsNullOrWhiteSpace(item.school))
- // {
- // if (item.school.Equals(school))
- // {
- // privateList.Add(item);
- // }
- // }
- // else
- // {
- // privateList.Add(item);
- // }
- //}
- }
- if (privateList.IsNotEmpty())
- {
- groups.Add("Teacher", privateList);
- }
- }
- if (groups.Count != 0)
- {
- if (groupLists.IsNotEmpty())
- {
- groupLists.AddRange(groups.SelectMany(x => x.Value).ToList());
- }
- else
- {
- groupLists = groups.SelectMany(x => x.Value).ToList();
- }
- }
- }
- return groupLists;
- }
- /// <summary>
- /// 根据任意名单id获取成员信息。rmembers是去重的信息,groups是名单及人员信息,同一个人可能在不同的名单内。
- /// </summary>
- /// <param name="_coreAPIHttpService"></param>
- /// <param name="client"></param>
- /// <param name="_dingDing"></param>
- /// <param name="classes"></param>
- /// <param name="school"></param>
- /// <param name="groupids"></param>
- /// <param name="graduate">毕业类型0在校,1毕业 , -1查全部。</param>
- /// <returns></returns>
- public static async Task<(List<RMember>rmembers, List<RGroupList> groups)> GetMemberByListids(CoreAPIHttpService _coreAPIHttpService, CosmosClient client, DingDing _dingDing,
- List<string> classes, string school, List<(string, List<string>)> groupids = null, int graduate = -1)
- {
- List<RMember> members = new List<RMember>();
- List<RGroupList> groupLists = new List<RGroupList>();
- if (classes != null)
- {
- classes.RemoveAll(x => x == null);
- }
- if (classes == null || classes.Count <= 0)
- {
- return (members, groupLists);
- }
- if (classes.Count == 1 && classes.First().Equals("TeacherAll") && !string.IsNullOrEmpty(school))
- {
- //默认的教研组
- members = new List<RMember>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
- GetItemQueryIterator<TmdInfo>(queryText: $"SELECT c.id,c.name,c.picture FROM c ",
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school}") }))
- {
- RMember member = new RMember
- {
- id = item.id,
- name = item.name,
- picture = item.picture,
- type = 1,
- // nickname=item.name,
- };
- members.Add(member);
- }
- RGroupList groupList = new RGroupList
- {
- id = "TeacherAll",
- name = "TeacherAll",
- code = $"GroupList-{school}",
- school = school,
- scope = "school",
- type = "TeacherAll",
- members = members
- };
- groupLists = new List<RGroupList> { groupList };
- }
- else
- {
- Dictionary<string, List<RGroupList>> groups = new Dictionary<string, List<RGroupList>>();
- List<Student> students = new List<Student>();
- string sql = string.Join(",", classes.Select(x => $"'{x}'"));
- if (!string.IsNullOrEmpty(school))
- {
- List<RGroupList> schoolList = new List<RGroupList>();
- string queryText = $"select value(c) from c where c.id in ({sql})";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<RGroupList>(queryText: queryText,
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
- {
- schoolList.Add(item);
- }
- if (schoolList.IsNotEmpty())
- {
- groups.Add("School", schoolList);
- }
- //取差集,减少二次搜寻
- classes = classes.Except(schoolList.Select(y => y.id)).ToList();
- if (classes.IsNotEmpty())
- {
- sql = string.Join(",", classes.Select(x => $"'{x}'"));
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId in ({sql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{school}") }))
- {
- //graduate传入的状态>=0 表示指定状态查询,且传入的状态与数据库的状态一致。
- if (graduate >= 0)
- {
- if (item.graduate == graduate)
- {
- students.Add(item);
- }
- }
- //全部。
- else
- {
- students.Add(item);
- }
- // students.Add(item);
- }
- //取差集,减少二次搜寻
- classes = classes.Except(students.Select(y => y.classId)).ToList();
- }
- if (classes.IsNotEmpty())
- {
- string insql = string.Join(",", classes.Select(x => $"'{x}'"));
- //搜寻没有关联学生的行政班
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School")
- .GetItemQueryIterator<RGroupList>(queryText: $"select 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.teacher.id as leader ,c.graduate from c where c.id in ({insql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{school}") }))
- {
- ///行政班(学生搜寻classId动态返回)class
- List<RMember> smembers = new List<RMember>();
- RGroupList group = new RGroupList
- {
- id = item.id,
- code = $"GroupList-{school}",
- name = item.name,
- periodId = item.periodId,
- scope = "school",
- school = school,
- type = "class",
- year = item.year,
- members = smembers,
- scount = smembers.Count,
- pk = "GroupList",
- leader = item.leader,
- no = item.no,
- graduate = item.graduate
- };
- //graduate传入的状态>=0 表示指定状态查询,且传入的状态与数据库的状态一致。
- if (graduate >= 0)
- {
- if (group.graduate == graduate)
- {
- groupLists.Add(group);
- }
- }
- //全部。
- else
- {
- groupLists.Add(group);
- }
- //groupLists.Add(group);
- }
- //取差集,减少二次搜寻
- classes = classes.Except(groupLists.Select(y => y.id)).ToList();
- }
- }
- if (classes.IsNotEmpty())
- {
- List<RGroupList> privateList = new List<RGroupList>();
- sql = string.Join(",", classes.Select(x => $"'{x}'"));
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<RGroupList>(queryText: $"select value(c) from c where c.id in ({sql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
- {
- privateList.Add(item);
- //if (string.IsNullOrWhiteSpace(school))
- //{
- // privateList.Add(item);
- //}
- //else
- //{
- // if (!string.IsNullOrWhiteSpace(item.school))
- // {
- // if (item.school.Equals(school))
- // {
- // privateList.Add(item);
- // }
- // }
- // else
- // {
- // privateList.Add(item);
- // }
- //}
- }
- if (privateList.IsNotEmpty())
- {
- groups.Add("Teacher", privateList);
- }
- }
- foreach (var item in groups)
- {
- var list = item.Value.GroupBy(x => x.type).Select(y => new { key = y.Key, list = y.ToList() });
- foreach (var group in list)
- {
- (List<RGroupList> rgroups, List<RMember> rmembers) = await GetGroupListMemberInfo(_coreAPIHttpService, client, group.key, group.list, item.Key, _dingDing, school,graduate);
- members.AddRange(rmembers);
- }
- }
- groupLists.AddRange(groups.SelectMany(x => x.Value).ToList());
- if (students.IsNotEmpty())
- {
- List<string> sqlList = students.Select(x => x.classId).ToList();
- string insql = string.Join(",", sqlList.Select(x => $"'{x}'"));
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
- GetItemQueryIterator<RGroupList>(queryText: $"select 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.teacher.id as leader ,c.graduate from c where c.id in ({insql})",
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{school}") }))
- {
- ///行政班(学生搜寻classId动态返回)class
- List<RMember> smembers = students.Where(x => x.classId.Equals(item.id))
- .Select(y => new RMember
- {
- id = y.id,
- code = school,
- name = y.name,
- //nickname = y.name,
- type = 2,
- picture = y.picture,
- no = y.no,
- classId = y.classId,
- //groupId=y.groupId,
- groupName = y.groupName,
- irs = y.irs,
- graduate = y.graduate,
- }).ToList();
- members.AddRange(smembers);
- RGroupList group = new RGroupList
- {
- id = item.id,
- code = $"GroupList-{school}",
- name = item.name,
- periodId = item.periodId,
- scope = "school",
- school = school,
- type = "class",
- year = item.year,
- members = smembers,
- scount = smembers.Count,
- no = item.no,
- leader = item.leader,
- pk = "GroupList",
- graduate = item.graduate
- };
- //graduate传入的状态>=0 表示指定状态查询,且传入的状态与数据库的状态一致。
- if (graduate >= 0)
- {
- if (group.graduate == graduate)
- {
- groupLists.Add(group);
- }
- }
- //全部。
- else
- {
- groupLists.Add(group);
- }
- // groupLists.Add(group);
- }
- //去重。
- members = members.FindAll(x => x.type == 2).Where((x, i) => members.FindAll(x => x.type == 2).FindIndex(n => n.id.Equals(x.id) && n.code.Equals(x.code)) == i).ToList();
- }
- }
- if (groupids.IsNotEmpty())
- {
- List<RMember> rmembers = new List<RMember>();
- groupLists.ForEach(y => {
- (string id, List<string> grpids) = groupids.Find(x => x.Item1.Equals(y.id));
- var gpmember = y.members.FindAll(x => !string.IsNullOrEmpty(x.groupName) && grpids.Contains(x.groupName));
- if (grpids.Contains("default"))
- {
- var gpmemberdft = y.members.FindAll(x => string.IsNullOrWhiteSpace(x.groupName));
- if (gpmember.IsNotEmpty())
- {
- gpmember.AddRange(gpmemberdft);
- }
- else
- {
- gpmember = gpmemberdft;
- }
- }
- y.members = gpmember;
- });
- var gpgpmembers = groupLists.SelectMany(x => x.members).ToList();
- List<RMember> tmdids = gpgpmembers.FindAll(x => x.type == 1).Where((x, i) => gpgpmembers.FindAll(x => x.type == 1).FindIndex(n => n.id.Equals(x.id)) == i).ToList();
- List<RMember> students = gpgpmembers.FindAll(x => x.type == 2).Where((x, i) => gpgpmembers.FindAll(x => x.type == 2).FindIndex(n => n.id.Equals(x.id) && n.code.Equals(x.code)) == i).ToList();
- if (tmdids.IsNotEmpty())
- {
- rmembers.AddRange(tmdids);
- }
- if (students.IsNotEmpty())
- {
- rmembers.AddRange(students);
- }
- return (rmembers, groupLists);
- }
- else
- {
- return (members, groupLists);
- }
- }
- /// <summary>
- /// 根据名单类型获取名单及成员信息。
- /// </summary>
- /// <param name="_coreAPIHttpService"></param>
- /// <param name="client"></param>
- /// <param name="type"></param>
- /// <param name="scopes"></param>
- /// <param name="school"></param>
- /// <param name="_dingDing"></param>
- /// <param name="graduate">毕业类型0在校,1毕业 , -1查全部。</param>
- /// <returns></returns>
- public static async Task<List<RGroupList>> GetGroupListMemberByType(CoreAPIHttpService _coreAPIHttpService, CosmosClient client, string type, List<string> scopes, string school, DingDing _dingDing, int graduate = -1)
- {
- StringBuilder sql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='{type}'");
- Dictionary<string, List<RGroupList>> groups = new Dictionary<string, List<RGroupList>>();
- if (scopes.Contains("school"))
- {
- if (!string.IsNullOrEmpty(school))
- {
- List<RGroupList> groupLists = new List<RGroupList>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<RGroupList>(queryText: sql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
- {
- groupLists.Add(item);
- }
- groups.Add("School", groupLists);
- }
- }
- else if (scopes.Contains("private"))
- {
- List<RGroupList> groupLists = new List<RGroupList>();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<RGroupList>(queryText: sql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
- {
- groupLists.Add(item);
- //if (string.IsNullOrWhiteSpace(school))
- //{
- // groupLists.Add(item);
- //}
- //else
- //{
- // if (!string.IsNullOrWhiteSpace(item.school))
- // {
- // if (item.school.Equals(school))
- // {
- // groupLists.Add(item);
- // }
- // }
- // else {
- // groupLists.Add(item);
- // }
- //}
- }
- groups.Add("Teacher", groupLists);
- }
- foreach (var item in groups)
- {
- var list = item.Value.GroupBy(x => x.type).Select(y => new { key = y.Key, list = y.ToList() });
- foreach (var group in list)
- {
- (List<RGroupList> rgroups, List<RMember> rmembers) = await GetGroupListMemberInfo(_coreAPIHttpService, client, group.key, group.list, item.Key, _dingDing, school,graduate);
- }
- }
- var lists = groups.SelectMany(x => x.Value).ToList();
- return lists;
- }
- /// <summary>
- /// 根据名单类型,名单分组信息获取成员信息, rmembers是去重的信息,groups是名单及人员信息,同一个人可能在不同的名单内。
- /// </summary>
- /// <param name="_coreAPIHttpService"></param>
- /// <param name="client"></param>
- /// <param name="type"></param>
- /// <param name="groups"></param>
- /// <param name="groupTbname"></param>
- /// <param name="_dingDing"></param>
- /// <param name="school"></param>
- /// <param name="graduate">毕业类型0在校,1毕业 , -1查全部。</param>
- /// <returns></returns>
- public static async Task<(List<RGroupList> groups, List<RMember> members)> GetGroupListMemberInfo(CoreAPIHttpService _coreAPIHttpService, CosmosClient client,
- string type, List<RGroupList> groups, string groupTbname, DingDing _dingDing, string school, int graduate = -1)
- {
- try
- {
- HashSet<RGroupList> changes = new HashSet<RGroupList>();
- var members = groups.SelectMany(y => y.members).ToList();
- //去重
- List<RMember> tmdids = members.FindAll(x => x.type == 1).Where((x, i) => members.FindAll(x => x.type == 1).FindIndex(n => n.id.Equals(x.id)) == i).ToList();
- List<RMember> students = members.FindAll(x => x.type == 2).Where((x, i) => members.FindAll(x => x.type == 2).FindIndex(n => n.id.Equals(x.id) && n.code.Equals(x.code)) == i).ToList();
- var stu = students.GroupBy(x => x.code).Select(y => new { key = y.Key, list = y.ToList() });
- List<Student> studentsData = new List<Student>();
- if (stu != null)
- {
- foreach (var item in stu)
- {
- var ids = item.list.Select(x => x.id).ToList();
- if (ids.IsNotEmpty())
- {
- StringBuilder stuSql = new StringBuilder($"SELECT distinct c.name,c.id,c.code,c.picture,c.no,c.irs,c.classId ,c.graduate FROM c ");
- string insql = string.Join(",", ids.Select(x => $"'{x}'"));
- stuSql.Append($"where c.id in ({insql})");
- await foreach (var student in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: stuSql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-{item.key}") }))
- {
- student.schoolId = item.key;
- studentsData.Add(student);
- }
- }
- }
- var unexist_student = students.Select(x => (x.id, x.code)).Except(studentsData.Select(y => (y.id, y.schoolId)), new CompareIdCode()).ToList();
- groups.ForEach(x =>
- {
- int item = x.members.RemoveAll(y => y.type == 2 && unexist_student.Exists(x => x.id.Equals(y.id) && x.Item2.Equals(y.code)));
- if (item > 0)
- {
- changes.Add(x);
- }
- });
- }
- List<TmdUser> tmdsData = new List<TmdUser>();
- if (tmdids.IsNotEmpty())
- {
- string memberTbname = "";
- if ($"{type}".Equals("activity"))
- {
- var mbers = groups.SelectMany(x => x.members).Where(z => !string.IsNullOrEmpty(z.code));
- var schoolTeachers = mbers.GroupBy(y => y.code).Select(m => new { key = m.Key, list = m.ToList() });
- foreach (var schoolTeacher in schoolTeachers)
- {
- StringBuilder tmdidSql = new StringBuilder($"SELECT distinct c.name,c.id,c.picture FROM c ");
- string insql = string.Join(",", schoolTeacher.list.Select(x => $"'{x.id}'"));
- tmdidSql.Append($" where c.id in ({insql})");
- await foreach (var tmd in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<TmdUser>(queryText: tmdidSql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{schoolTeacher.key}") }))
- {
- tmdsData.Add(tmd);
- }
- }
- var unexist_teachers = mbers.Select(x => (x.id, x.code)).Except(tmdsData.Select(y => (y.id, y.code)), new CompareIdCode()).ToList();
- groups.ForEach(x =>
- {
- int item = x.members.RemoveAll(y => y.type == 2 && unexist_teachers.Exists(x => x.id.Equals(y.id) && x.Item2.Equals(y.code)));
- if (item > 0)
- {
- changes.Add(x);
- }
- });
- }
- else
- {
- //处理研修名单,如果是学校老师的,则需要检查SchoolTeacher
- //处理 学校教研组,学校管理人员,学校任课教师,学校研修名单。
- if (!string.IsNullOrEmpty(school) && ($"{type}".Equals("yxtrain") || $"{type}".Equals("research") || $"{type}".Equals("manage") || $"{type}".Equals("subject")))
- {
- StringBuilder tmdidSql = new StringBuilder($"SELECT distinct c.name,c.id,c.picture FROM c ");
- string insql = string.Join(",", tmdids.Select(x => $"'{x.id}'"));
- tmdidSql.Append($" where c.id in ({insql})");
- await foreach (var tmd in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<TmdUser>(queryText: tmdidSql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{school}") }))
- {
- tmdsData.Add(tmd);
- }
- }
- else
- {
- {
- StringBuilder tmdidSql = new StringBuilder($"SELECT distinct c.name,c.id,c.picture FROM c ");
- string insql = string.Join(",", tmdids.Select(x => $"'{x.id}'"));
- tmdidSql.Append($" where c.id in ({insql})");
- memberTbname = "Teacher";
- await foreach (var tmd in client.GetContainer(Constant.TEAMModelOS, memberTbname).GetItemQueryIterator<TmdUser>(queryText: tmdidSql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
- {
- tmdsData.Add(tmd);
- }
- }
- {
- //取差集,减少二次搜寻
- var tmdidexp = tmdids.Select(x => x.id).Except(tmdsData.Select(y => y.id)).ToList();
- if (tmdidexp.IsNotEmpty())
- {
- StringBuilder tmdidSql = new StringBuilder($"SELECT distinct c.name,c.id,c.picture FROM c ");
- string insql = string.Join(",", tmdidexp.Select(x => $"'{x}'"));
- tmdidSql.Append($" where c.id in ({insql})");
- memberTbname = "Student";
- await foreach (var tmd in client.GetContainer(Constant.TEAMModelOS, memberTbname).GetItemQueryIterator<TmdUser>(queryText: tmdidSql.ToString(),
- requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
- {
- tmdsData.Add(tmd);
- }
- }
- }
- }
- tmdsData = tmdsData.Where((x, i) => tmdsData.FindIndex(n => n.id.Equals(x.id)) == i).ToList();
- var unexist_tmdid = tmdids.Select(x => x.id).Except(tmdsData.Select(y => y.id)).ToList();
- groups.ForEach(x =>
- {
- int item = x.members.RemoveAll(y => unexist_tmdid.Contains(y.id) && y.type == 1);
- if (item > 0)
- {
- changes.Add(x);
- }
- });
- }
- }
- if (tmdids.IsNotEmpty() && _coreAPIHttpService.check) {
- ///获取真实的名称
- var content = new StringContent(tmdids.Select(x => x.id).ToHashSet().ToJsonString(), Encoding.UTF8, "application/json");
- string json = null;
- try
- {
- json = await _coreAPIHttpService.GetUserInfos(content);
- if (!string.IsNullOrWhiteSpace(json))
- {
- List<TmdInfo> tmdInfos = json.ToObject<List<TmdInfo>>();
- if (tmdInfos.IsNotEmpty())
- {
- tmdsData.ForEach(y =>
- {
- var tmd = tmdInfos.Find(x => x.id.Equals(y.id));
- if (tmd != null)
- {
- y.name = tmd?.name;
- y.picture = tmd?.picture;
- }
- else
- {
- groups.ForEach(x =>
- {
- int item = x.members.RemoveAll(z => z.id.Equals(y.id) && z.type == 1);
- if (item > 0)
- {
- changes.Add(x);
- }
- });
- }
- });
- }
- }
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"{_coreAPIHttpService.options.Get("Default").location}用户转换失败:{_coreAPIHttpService.options.Get("Default").url}{json}\n {ex.Message}\n{ex.StackTrace}{tmdids.Select(x => x.id).ToJsonString()}", GroupNames.醍摩豆服務運維群組);
- }
- }
-
- tmdids.ForEach(x =>
- {
- var user = tmdsData.Find(y => y.id.Equals(x.id));
- x.name = user?.name;
- // x.nickname = string.IsNullOrWhiteSpace(x.nickname) ? user?.name : x.nickname;
- x.picture = user?.picture;
- });
- students.ForEach(x =>
- {
- var student = studentsData.Find(y => y.id.Equals(x.id) && y.schoolId.Equals(x.code));
- x.name = student?.name;
- // x.nickname = string.IsNullOrWhiteSpace(x.nickname) ? student?.name:x.nickname;
- x.picture = student?.picture;
- x.classId = student?.classId;
- x.graduate = student.graduate;
- });
- var mbs = tmdids;
- mbs.AddRange(students);
- if (changes.Count > 0 && !string.IsNullOrEmpty(groupTbname))
- {
- foreach (var change in changes)
- {
- change.tcount = change.members.Where(x => x.type == 1).Count();
- change.scount = change.members.Where(x => x.type == 2).Count();
- GroupList group = change.ToJsonString().ToObject<GroupList>();
- await client.GetContainer(Constant.TEAMModelOS, groupTbname).ReplaceItemAsync(group, group.id, new PartitionKey(group.code));
- }
- }
- groups.ForEach(x => x.members.ForEach(y => {
- if (y.type == 1)
- {
- var tmd = tmdids.Find(t => t.id.Equals(y.id));
- y.name = tmd?.name;
- //y.nickname = string.IsNullOrWhiteSpace(y.nickname) ? tmd?.nickname : y.nickname;
- y.picture = tmd?.picture;
- }
- if (y.type == 2)
- {
- var student = students.Find(t => t.id.Equals(y.id) && t.code.Equals(y.code));
- y.name = student?.name;
- // y.nickname = string.IsNullOrWhiteSpace(y.nickname) ? student?.nickname : y.nickname;
- y.picture = student?.picture;
- y.classId = student?.classId;
- y.graduate = student.graduate;
- }
- }));
- HashSet<string> schoolCodes = groups.SelectMany(x => x.members).Where(y => !string.IsNullOrEmpty(y.code)).Select(z => z.code).ToHashSet();
- if (schoolCodes != null && schoolCodes.Count > 0)
- {
- List<School> schools = new List<School>();
- string insql = $"select c.name,c.id from c where c.id in ({string.Join(",", schoolCodes.Select(x => $"'{x}'"))})";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: insql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
- {
- schools.Add(item);
- }
- if (schools.IsNotEmpty())
- {
- groups.SelectMany(x => x.members).Where(y => !string.IsNullOrEmpty(y.code)).ToList().ForEach(z => {
- var school = schools.Find(j => j.id.Equals(z.code));
- z.schoolName = school?.name;
- });
- }
- }
- if (graduate >= 0)
- {
- groups= groups.FindAll(x => x.graduate == graduate);
- if (groups != null) {
- groups.ForEach(x =>
- {
- x.members.RemoveAll(y => y.graduate != graduate);
- });
- }
- mbs.RemoveAll(z => z.graduate != graduate);
- }
- //直接返回
- else {
- return (groups, mbs);
- }
-
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"{_coreAPIHttpService.options.Get("Default").location},GetGroupListMemberInfo()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
- }
- return (null, null);
- }
- }
- public class CompareIdCode : IEqualityComparer<(string id, string code)>
- {
- public bool Equals((string id, string code) x, (string id, string code) y)
- {
- return x.id.Equals(y.id) && x.code.Equals(y.code);
- }
- public int GetHashCode((string id, string code) obj)
- {
- if (obj.id != null && obj.code != null)
- {
- return 1;
- }
- else
- {
- return 0;
- }
- }
- }
- }
|