GroupListController.cs 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615
  1. using Azure.Cosmos;
  2. using Microsoft.AspNetCore.Http;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Extensions.Options;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.IdentityModel.Tokens.Jwt;
  8. using System.Linq;
  9. using System.Text.Json;
  10. using System.Threading.Tasks;
  11. using TEAMModelOS.Models;
  12. using TEAMModelOS.SDK.Models;
  13. using TEAMModelOS.SDK;
  14. using TEAMModelOS.SDK.DI;
  15. using TEAMModelOS.SDK.Extension;
  16. using Azure;
  17. using TEAMModelOS.SDK.Models.Cosmos.Common;
  18. using Azure.Messaging.ServiceBus;
  19. using Microsoft.Extensions.Configuration;
  20. using TEAMModelOS.Filter;
  21. using HTEXLib.COMM.Helpers;
  22. using System.Text;
  23. using Microsoft.AspNetCore.Authorization;
  24. using Microsoft.Extensions.Hosting;
  25. using OpenXmlPowerTools;
  26. using TEAMModelOS.SDK.Models.Dtos;
  27. using Microsoft.AspNetCore.Hosting;
  28. using Azure.Core;
  29. using static TEAMModelOS.SDK.Services.ActivityStudentService;
  30. using static TEAMModelOS.SDK.GroupListService;
  31. using TEAMModelOS.Controllers.Both;
  32. using CourseDto = TEAMModelOS.Controllers.Both.CourseDto;
  33. namespace TEAMModelOS.Controllers
  34. {
  35. [ProducesResponseType(StatusCodes.Status200OK)]
  36. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  37. [Route("grouplist")]
  38. [ApiController]
  39. public class GroupListController : ControllerBase
  40. {
  41. private AzureCosmosFactory _azureCosmos;
  42. private readonly DingDing _dingDing;
  43. private readonly Option _option;
  44. private readonly AzureServiceBusFactory _serviceBus;
  45. private readonly AzureRedisFactory _azureRedis;
  46. private readonly AzureStorageFactory _azureStorage;
  47. private readonly CoreAPIHttpService _coreAPIHttpService;
  48. private readonly IWebHostEnvironment _environment;
  49. 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 ,c.review,c.limitCount ,c.expire,c.qrcodeExpire,c.qrcodeDays ,c.grades ";
  50. public IConfiguration _configuration { get; set; }
  51. public GroupListController(IWebHostEnvironment environment, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option,
  52. AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration, AzureRedisFactory azureRedis)
  53. {
  54. _azureCosmos = azureCosmos;
  55. _dingDing = dingDing;
  56. _option = option?.Value;
  57. _serviceBus = serviceBus;
  58. _configuration = configuration;
  59. _azureStorage = azureStorage;
  60. _coreAPIHttpService = coreAPIHttpService;
  61. _environment = environment;
  62. _azureRedis=azureRedis;
  63. }
  64. //学生获取自己已经加入的名单。
  65. [ProducesDefaultResponseType]
  66. [HttpPost("get-student-joined-grouplist")]
  67. [Authorize(Roles = "IES")]
  68. [AuthToken(Roles = "admin,teacher,student")]
  69. public async Task<IActionResult> GetMyCourseAndGroupList(JsonElement json)
  70. {
  71. var (userid, _name, _picture, school) = HttpContext.GetAuthTokenInfo();
  72. var client = _azureCosmos.GetCosmosClient();
  73. object scope = null;
  74. HttpContext?.Items.TryGetValue("Scope", out scope);
  75. int memberType = 2;
  76. if ($"{scope}".Equals(Constant.ScopeStudent))
  77. {
  78. memberType = 2;
  79. // Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{school}"));
  80. }
  81. if ($"{scope}".Equals(Constant.ScopeTmdUser))
  82. {
  83. memberType = 1;
  84. }
  85. if ($"{scope}".Equals(Constant.ScopeTeacher))
  86. {
  87. memberType = 1;
  88. }
  89. List<GroupListGrp> groups = await GroupListService.GetMemberInGroupList(_coreAPIHttpService, client, _dingDing, userid, memberType, school, new List<string> { "class", "teach" });
  90. return Ok(new { groups = groups });
  91. }
  92. /// <summary>
  93. /// 扫码加入名单
  94. /// </summary>
  95. /// <param name="json"></param>
  96. /// <returns></returns>
  97. [ProducesDefaultResponseType]
  98. [HttpPost("scan-code-join-list")]
  99. public async Task<IActionResult> ScanCodeJoinList(JsonElement json)
  100. {
  101. if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
  102. json.TryGetProperty("school", out JsonElement school);
  103. json.TryGetProperty("courseId", out JsonElement _courseId);
  104. var client = _azureCosmos.GetCosmosClient();
  105. json.TryGetProperty("id_token", out JsonElement id_token);
  106. var jwt = new JwtSecurityToken(id_token.GetString());
  107. var id = jwt.Payload.Sub;
  108. jwt.Payload.TryGetValue("name", out object name);
  109. jwt.Payload.TryGetValue("lang", out object lang);
  110. jwt.Payload.TryGetValue("picture", out object picture);
  111. try
  112. {
  113. TmdUser tmduser = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<TmdUser>(id, new PartitionKey("Base"));
  114. }
  115. catch (CosmosException ex)
  116. {
  117. if (ex.Status == 404)
  118. {
  119. //如果沒有,則初始化Teacher基本資料到Cosmos
  120. TmdUser tmduser = new TmdUser
  121. {
  122. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  123. id = id,
  124. pk = "Base",
  125. code = "Base",
  126. name = name?.ToString(),
  127. picture = picture?.ToString(),
  128. //创建账号并第一次登录IES5则默认赠送1G
  129. defaultSchool = null,
  130. schools = new List<TmdUser.School>(),
  131. lang= lang?.ToString(),
  132. };
  133. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Student").CreateItemAsync<TmdUser>(tmduser, new PartitionKey("Base"));
  134. }
  135. }
  136. int year = DateTimeOffset.UtcNow.Year;
  137. (int status, GroupList stuList, Member member) data = await GroupListService.CodeJoinList(client, _azureRedis, $"{_stuListNo}", id, type: 1, $"{school}", year, $"{name}", $"{picture}", $"{lang}",$"{_courseId}");
  138. //没有TmdUser时
  139. if (data.status == 0)
  140. {
  141. await GroupListService.UpsertList(data.stuList, _azureCosmos, _configuration, _serviceBus);
  142. List<string> ids = new List<string>();
  143. if (data.stuList.scope.Equals("private") && !string.IsNullOrEmpty(data.stuList.creatorId))
  144. {
  145. ids.Add(data.stuList.creatorId);
  146. }
  147. else if (data.stuList.scope.Equals("school") && !string.IsNullOrEmpty(data.stuList.school))
  148. {
  149. //通知管理员
  150. string sql = "select distinct value(c.id) from c where array_contains(c.roles,'admin')";
  151. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<string>(queryText: sql,
  152. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Teacher-{school}") }))
  153. {
  154. ids.Add(item);
  155. }
  156. }
  157. if (ids.IsNotEmpty())
  158. {
  159. string bizcode = "scan-join";
  160. string sql = $"select c.id, c.name ,c.lang as code from c where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})";
  161. List<IdNameCode> idNameCodes = new List<IdNameCode>();
  162. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  163. .GetItemQueryIterator<IdNameCode>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  164. {
  165. idNameCodes.Add(item);
  166. }
  167. // _coreAPIHttpService.PushNotify(idNameCodes, $"scan-join_groupList", Constant.NotifyType_IES5_Course, new Dictionary<string, object> { { "tmdid", id }, { "tmdname", name }, { "groupListName", data.stuList.name }, { "groupListId", data.stuList.id } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  168. }
  169. return Ok(new { data.stuList, data.status });
  170. }
  171. else
  172. {
  173. return Ok(new { data.status });
  174. }
  175. }
  176. /// <summary>
  177. /// 根据邀请码加入名单
  178. /// </summary>
  179. /// <param name="json"></param>
  180. /// <returns></returns>
  181. [ProducesDefaultResponseType]
  182. [AuthToken(Roles = "admin,teacher,student")]
  183. [HttpPost("input-code-join-list")]
  184. [Authorize(Roles = "IES")]
  185. public async Task<IActionResult> InputCodeJoinList(JsonElement json)
  186. {
  187. string head_lang = _option.Location.Contains("China") ? "zh-cn" : "zh-tw";
  188. if (HttpContext.Request.Headers.TryGetValue("lang", out var _lang))
  189. {
  190. head_lang = $"{_lang}";
  191. }
  192. if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
  193. var (userid, _name, _picture, school) = HttpContext.GetAuthTokenInfo();
  194. object scope = null;
  195. int type = 0;
  196. string no = null;
  197. var client = _azureCosmos.GetCosmosClient();
  198. HttpContext?.Items.TryGetValue("Scope", out scope);
  199. int year = DateTimeOffset.UtcNow.Year;
  200. if ($"{scope}".Equals(Constant.ScopeStudent))
  201. {
  202. type = 2;
  203. Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{school}"));
  204. no = student.no;
  205. year = student.year;
  206. }
  207. if ($"{scope}".Equals(Constant.ScopeTmdUser))
  208. {
  209. type = 1;
  210. }
  211. if ($"{scope}".Equals(Constant.ScopeTeacher))
  212. {
  213. type = 1;
  214. }
  215. (int status, GroupList stuList, Member member) data = await GroupListService.CodeJoinList(client, _azureRedis, $"{_stuListNo}", userid, type, school, year, _name, _picture, head_lang);
  216. if (data.status == 0)
  217. {
  218. await GroupListService.UpsertList(data.stuList, _azureCosmos, _configuration, _serviceBus);
  219. List<string> ids = new List<string>();
  220. if (data.stuList.scope.Equals("private") && !string.IsNullOrEmpty(data.stuList.creatorId))
  221. {
  222. ids.Add(data.stuList.creatorId);
  223. }
  224. else if (data.stuList.scope.Equals("school") && !string.IsNullOrEmpty(data.stuList.school))
  225. {
  226. //通知管理员
  227. string sql = "select distinct value(c.id) from c where array_contains(c.roles,'admin')";
  228. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<string>(queryText: sql,
  229. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Teacher-{school}") }))
  230. {
  231. ids.Add(item);
  232. }
  233. }
  234. if (ids.IsNotEmpty())
  235. {
  236. string bizcode = "scan-join";
  237. string sql = $"select c.id, c.name ,c.lang as code from c where c.id in ({string.Join(",", ids.Select(x => $"'{x}'"))})";
  238. List<IdNameCode> idNameCodes = new List<IdNameCode>();
  239. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher)
  240. .GetItemQueryIterator<IdNameCode>(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  241. {
  242. idNameCodes.Add(item);
  243. }
  244. _coreAPIHttpService.PushNotify(idNameCodes, $"{bizcode}_school", Constant.NotifyType_IES5_Course,
  245. new Dictionary<string, object> { { "tmdid", userid }, { "tmdname", _name }, { "groupListName", data.stuList.name }, { "groupListId", data.stuList.id } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  246. }
  247. return Ok(new { data.stuList, data.status });
  248. }
  249. else
  250. {
  251. return Ok(new { data.status });
  252. }
  253. }
  254. /// <summary>
  255. /// 获取名单的tags
  256. /// </summary>
  257. /// <param name="json"></param>
  258. /// <returns></returns>
  259. [ProducesDefaultResponseType]
  260. [AuthToken(Roles = "admin,teacher,student")]
  261. [HttpPost("get-grouplist-tags")]
  262. [Authorize(Roles = "IES")]
  263. public async Task<IActionResult> GetGrouplistTags(JsonElement json)
  264. {
  265. var client = _azureCosmos.GetCosmosClient();
  266. var (id, _, _, school) = HttpContext.GetAuthTokenInfo();
  267. object scope = null;
  268. StringBuilder sql = new StringBuilder($"SELECT {SummarySql} ,A1.tag FROM c " +
  269. $" join A1 in c. members where A1.id='{id}' and A1.tag<>null ");
  270. HttpContext?.Items.TryGetValue("Scope", out scope);
  271. if (!string.IsNullOrEmpty(school) && $"{scope}".Equals(Constant.ScopeStudent))
  272. {
  273. sql.Append($" and A1.code='{school}'");
  274. }
  275. List<dynamic> groupLists = new List<dynamic>();
  276. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  277. GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
  278. {
  279. groupLists.Add(item);
  280. }
  281. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
  282. GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList") }))
  283. {
  284. groupLists.Add(item);
  285. }
  286. return Ok(new { groupLists });
  287. }
  288. /// <summary>
  289. /// 获取发布活动的名单
  290. /// </summary>
  291. /// <param name="json"></param>
  292. /// <returns></returns>
  293. [ProducesDefaultResponseType]
  294. [HttpPost("activity-grouplist")]
  295. #if !DEBUG
  296. [AuthToken(Roles = "teacher,admin,student")]
  297. [Authorize(Roles = "IES")]
  298. #endif
  299. public async Task<IActionResult> GetActivityGrouplist(JsonElement json)
  300. {
  301. var client = _azureCosmos.GetCosmosClient();
  302. json.TryGetProperty("tmdid", out JsonElement tmdid);
  303. json.TryGetProperty("schoolId", out JsonElement schoolId);
  304. if (!json.TryGetProperty("opt", out JsonElement opt)) { return BadRequest(); }
  305. json.TryGetProperty("periodId", out JsonElement periodId);
  306. long nowtime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  307. List<GroupListGrp> groupLists = new List<GroupListGrp>();
  308. switch (true)
  309. {
  310. //我管理的
  311. case bool when $"{opt}".Equals("manage", StringComparison.OrdinalIgnoreCase):
  312. //包含,学校的行政班,教学班
  313. json.TryGetProperty("type", out JsonElement _type);
  314. List<string> types = null;
  315. if (_type.ValueKind.Equals(JsonValueKind.Array))
  316. {
  317. types = _type.ToObject<List<string>>();
  318. }
  319. else if (_type.ValueKind.Equals(JsonValueKind.String))
  320. {
  321. types = new List<string> { $"{_type}" };
  322. }
  323. if (types.IsEmpty() || types.Contains("class"))
  324. {
  325. StringBuilder classsql = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year,c.no FROM c where ( c.graduate = 0 or IS_DEFINED(c.graduate) = false )");
  326. if (!string.IsNullOrEmpty($"{periodId}"))
  327. {
  328. classsql.Append($" and c.periodId='{periodId}' ");
  329. }
  330. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: classsql.ToString(),
  331. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{schoolId}") }))
  332. {
  333. int scount = 0;
  334. HashSet<string> groupNames = new HashSet<string>();
  335. string gpsql = $"SELECT distinct c.id, c.groupId,c.groupName FROM c where c.classId='{item.id}' ";
  336. await foreach (var gp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: gpsql,
  337. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{schoolId}") }))
  338. {
  339. if (!string.IsNullOrWhiteSpace(gp.groupName))
  340. {
  341. groupNames.Add(gp.groupName);
  342. }
  343. scount += 1;
  344. }
  345. ///行政班(学生搜寻classId动态返回)class
  346. GroupListGrp group = new GroupListGrp
  347. {
  348. id = item.id,
  349. code = $"GroupList-{schoolId}",
  350. name = item.name,
  351. periodId = item.periodId,
  352. scope = "school",
  353. school = $"{schoolId}",
  354. type = "class",
  355. year = item.year,
  356. expire=0,
  357. groupName = groupNames,
  358. scount= scount
  359. };
  360. groupLists.Add(group);
  361. }
  362. }
  363. if (types.IsEmpty() || types.Contains("teach"))
  364. {
  365. //教学班
  366. StringBuilder teachsql = new StringBuilder($" SELECT distinct value(c) FROM c where c.type='teach' and ( c.expire = 0 or IS_DEFINED(c.expire) = false or c.expire >={nowtime} ) ");
  367. if (!string.IsNullOrEmpty($"{periodId}"))
  368. {
  369. teachsql.Append($" and c.periodId='{periodId}'");
  370. }
  371. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  372. GetItemQueryIterator<GroupList>(queryText: teachsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
  373. {
  374. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  375. groupLists.Add(new GroupListGrp(item, groupName));
  376. }
  377. }
  378. if (types.IsEmpty() || types.Contains("research"))
  379. {
  380. //教研组
  381. StringBuilder researchsql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='research'");
  382. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  383. GetItemQueryIterator<GroupList>(queryText: researchsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
  384. {
  385. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  386. groupLists.Add(new GroupListGrp(item, groupName));
  387. }
  388. }
  389. if (types.IsEmpty() || types.Contains("yxtrain"))
  390. {
  391. //研修名单
  392. StringBuilder yxtrainsql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
  393. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  394. GetItemQueryIterator<GroupList>(queryText: yxtrainsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
  395. {
  396. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  397. groupLists.Add(new GroupListGrp(item, groupName));
  398. }
  399. }
  400. return Ok(new { groupLists });
  401. case bool when $"{opt}".Equals("teach", StringComparison.OrdinalIgnoreCase):
  402. //我执教的
  403. //从学校的课程和个人课程搜寻与我相关的课程对应的名单。
  404. List<TeachCourse> teachCourses = new List<TeachCourse>();
  405. if (!string.IsNullOrEmpty($"{schoolId}"))
  406. {
  407. 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}'");
  408. if (!string.IsNullOrEmpty($"{periodId}"))
  409. {
  410. schoolQuery.Append($" and c.period.id='{periodId}' ");
  411. }
  412. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  413. GetItemQueryIterator<TeachCourse>(queryText: schoolQuery.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{schoolId}") }))
  414. {
  415. teachCourses.Add(item);
  416. }
  417. }
  418. 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}'");
  419. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
  420. GetItemQueryIterator<TeachCourse>(queryText: query.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{tmdid}") }))
  421. {
  422. teachCourses.Add(item);
  423. }
  424. var classIds = teachCourses.Select(x => x.schedule).Where(y => !string.IsNullOrEmpty(y.classId)).Select(x => x.classId).Distinct().ToList();
  425. var schedule = teachCourses.Where(y => !string.IsNullOrEmpty(y.schedule.stulist)).Distinct().ToList();
  426. //var schedule = teachCourses.Select(x => new { schedule = x.schedule.Where(mm=>!string.IsNullOrEmpty(mm.stulist)), scope = x.scope }).ToList();
  427. if (classIds.IsNotEmpty())
  428. {
  429. string insql = string.Join(",", classIds.Select(x => $"'{x}'"));
  430. 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) ");
  431. ///行政班(学生搜寻classId动态返回)class
  432. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: query.ToString(),
  433. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{schoolId}") }))
  434. {
  435. HashSet<string> groupNames = new HashSet<string>();
  436. string gpsql = $"SELECT distinct c.groupId,c.groupName FROM c where c.classId='{item.id}'and c.groupName <>null";
  437. await foreach (var gp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: gpsql,
  438. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{schoolId}") }))
  439. {
  440. groupNames.Add(gp.groupName);
  441. }
  442. GroupListGrp group = new GroupListGrp
  443. {
  444. id = item.id,
  445. code = $"GroupList-{schoolId}",
  446. name = item.name,
  447. periodId = item.periodId,
  448. scope = "school",
  449. school = $"{schoolId}",
  450. type = "class",
  451. expire=0,
  452. year = item.year,
  453. groupName = groupNames
  454. };
  455. groupLists.Add(group);
  456. }
  457. }
  458. if (schedule.IsNotEmpty())
  459. {
  460. var privateList = schedule.Where(x => x.scope.Equals("private")).Select(x => x.schedule.stulist).Distinct();
  461. if (privateList.Count() > 0)
  462. {
  463. string insql = string.Join(",", privateList.Select(x => $"'{x}'"));
  464. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupList>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql})",
  465. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
  466. {
  467. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  468. groupLists.Add(new GroupListGrp(item, groupName));
  469. }
  470. }
  471. var schoolList = schedule.Where(x => x.scope.Equals("school")).Select(x => x.schedule.stulist).Distinct();
  472. if (schoolList.Count() > 0)
  473. {
  474. List<GroupListDto> groups = new List<GroupListDto>();
  475. string insql = string.Join(",", schoolList.Select(x => $"'{x}'"));
  476. //我教的学校教学班,如果有过期的教学班则不返回
  477. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql}) and ( c.expire = 0 or IS_DEFINED(c.expire) = false or c.expire >={nowtime} ) ",
  478. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{schoolId}") }))
  479. {
  480. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  481. groupLists.Add(new GroupListGrp(item, groupName));
  482. }
  483. }
  484. }
  485. List<CourseGroupList> courseGroups = new List<CourseGroupList>();
  486. teachCourses.GroupBy(y => (y.id, y.name, y.scope, y.period.name, y.period.id, y.subject.name, y.subject.id)).ToList().ForEach(x =>
  487. {
  488. List<GroupListGrp> classIds = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.classId)).Select(b => b.schedule.classId).Contains(n.id)).ToList();
  489. List<GroupListGrp> stulists = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.stulist)).Select(b => b.schedule.stulist).Contains(n.id)).ToList();
  490. if (classIds == null)
  491. {
  492. classIds = new List<GroupListGrp>();
  493. }
  494. if (stulists != null)
  495. {
  496. classIds.AddRange(stulists);
  497. }
  498. CourseGroupList groupList = new CourseGroupList()
  499. {
  500. scope = x.Key.Item3,
  501. subject = x.Key.Item6,
  502. subjectId = x.Key.Item7,
  503. period = x.Key.Item4,
  504. periodId = x.Key.Item5,
  505. id = x.Key.Item1,
  506. name = x.Key.Item2,
  507. groups = classIds
  508. };
  509. courseGroups.Add(groupList);
  510. });
  511. return Ok(new { groupLists = courseGroups });
  512. case bool when $"{opt}".Equals("private", StringComparison.OrdinalIgnoreCase):
  513. //我个人的
  514. break;
  515. default:
  516. break;
  517. }
  518. return Ok(new { error = 1, msg = "参数异常" });
  519. }
  520. /// <summary>
  521. ///
  522. /// </summary>
  523. /// <param name="request"></param>
  524. /// <returns></returns>
  525. [ProducesDefaultResponseType]
  526. [AuthToken(Roles = "teacher,admin")]
  527. [HttpPost("get-activity-grouplist")]
  528. #if !DEBUG
  529. [Authorize(Roles = "IES")]
  530. #endif
  531. public async Task<IActionResult> ActivityGrouplist(JsonElement json)
  532. {
  533. (string tmdid, _, _, string school) = HttpContext.GetAuthTokenInfo();
  534. var client = _azureCosmos.GetCosmosClient();
  535. if (!json.TryGetProperty("opt", out JsonElement opt)) { return BadRequest(); }
  536. json.TryGetProperty("periodId", out JsonElement periodId);
  537. long nowtime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  538. switch (true)
  539. {
  540. //我管理的
  541. case bool when $"{opt}".Equals("manage", StringComparison.OrdinalIgnoreCase):
  542. {
  543. List<GroupListGrp> groupLists = new List<GroupListGrp>();
  544. //包含,学校的行政班,教学班
  545. json.TryGetProperty("type", out JsonElement _type);
  546. List<string> types = null;
  547. if (_type.ValueKind.Equals(JsonValueKind.Array))
  548. {
  549. types = _type.ToObject<List<string>>();
  550. }
  551. else if (_type.ValueKind.Equals(JsonValueKind.String))
  552. {
  553. types = new List<string> { $"{_type}" };
  554. }
  555. if (types.IsEmpty() || types.Contains("class"))
  556. {
  557. StringBuilder classsql = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year,c.no FROM c where ( c.graduate = 0 or IS_DEFINED(c.graduate) = false )");
  558. if (!string.IsNullOrEmpty($"{periodId}"))
  559. {
  560. classsql.Append($" and c.periodId='{periodId}' ");
  561. }
  562. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: classsql.ToString(),
  563. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{school}") }))
  564. {
  565. int scount = 0;
  566. HashSet<string> groupNames = new HashSet<string>();
  567. string gpsql = $"SELECT distinct c.id, c.groupId,c.groupName FROM c where c.classId='{item.id}' ";
  568. await foreach (var gp in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: gpsql,
  569. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{school}") }))
  570. {
  571. if (!string.IsNullOrWhiteSpace(gp.groupName))
  572. {
  573. groupNames.Add(gp.groupName);
  574. }
  575. scount += 1;
  576. }
  577. ///行政班(学生搜寻classId动态返回)class
  578. GroupListGrp group = new GroupListGrp
  579. {
  580. id = item.id,
  581. code = $"GroupList-{school}",
  582. name = item.name,
  583. periodId = item.periodId,
  584. scope = "school",
  585. school = $"{school}",
  586. type = "class",
  587. year = item.year,
  588. expire=0,
  589. groupName = groupNames,
  590. scount= scount
  591. };
  592. groupLists.Add(group);
  593. }
  594. }
  595. if (types.IsEmpty() || types.Contains("teach"))
  596. {
  597. //教学班
  598. StringBuilder teachsql = new StringBuilder($" SELECT distinct value(c) FROM c where c.type='teach' and ( c.expire = 0 or IS_DEFINED(c.expire) = false or c.expire >={nowtime} ) ");
  599. if (!string.IsNullOrEmpty($"{periodId}"))
  600. {
  601. teachsql.Append($" and c.periodId='{periodId}'");
  602. }
  603. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  604. GetItemQueryIterator<GroupList>(queryText: teachsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
  605. {
  606. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  607. groupLists.Add(new GroupListGrp(item, groupName));
  608. }
  609. }
  610. if (types.IsEmpty() || types.Contains("research"))
  611. {
  612. //教研组
  613. StringBuilder researchsql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='research'");
  614. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  615. GetItemQueryIterator<GroupList>(queryText: researchsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
  616. {
  617. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  618. groupLists.Add(new GroupListGrp(item, groupName));
  619. }
  620. }
  621. if (types.IsEmpty() || types.Contains("yxtrain"))
  622. {
  623. //研修名单
  624. StringBuilder yxtrainsql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
  625. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  626. GetItemQueryIterator<GroupList>(queryText: yxtrainsql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
  627. {
  628. HashSet<string> groupName = item.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  629. groupLists.Add(new GroupListGrp(item, groupName));
  630. }
  631. }
  632. return Ok(new { groupLists });
  633. }
  634. case bool when $"{opt}".Equals("teach", StringComparison.OrdinalIgnoreCase):
  635. {
  636. string sql = $"SELECT distinct value c FROM c join b in c.schedules where c.pk='CourseTask' and (ARRAY_CONTAINS(b.assistants,'{tmdid}')or b.teacherId ='{tmdid}' )";
  637. List<KeyValuePair<string,CourseTask >> schoolTeacherTask = new List<KeyValuePair<string, CourseTask>>();
  638. List<KeyValuePair<string,CourseTask >> schoolAssistantTask = new List<KeyValuePair<string,CourseTask >>();
  639. List<KeyValuePair<string,CourseTask >> privateTeacherTask = new List<KeyValuePair<string,CourseTask >>();
  640. List<KeyValuePair<string,CourseTask >> privateAssistantTask = new List<KeyValuePair<string,CourseTask >>();
  641. List<CourseDto> schoolCourses = new List<CourseDto>();
  642. List<CourseDto> teahcerCourses = new List<CourseDto>();
  643. List<string> groupIds = new List<string>();
  644. if (!string.IsNullOrWhiteSpace(school))
  645. {
  646. School schoolBase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
  647. JsonElement _year = default, _semesterId = default, _periodId = default;
  648. if (!json.TryGetProperty("periodId", out _periodId)) return BadRequest();
  649. if (!json.TryGetProperty("year", out _year))
  650. {
  651. return BadRequest();
  652. }
  653. if (!json.TryGetProperty("semesterId", out _semesterId))
  654. {
  655. return BadRequest();
  656. }
  657. var period = schoolBase.period.Find(x => x.id.Equals($"{_periodId}"));
  658. //string date = SchoolService.GetOpensByStudyYearAndSemester(period.semesters, int.Parse($"{_year}"), $"{_semesterId}");
  659. sql = $"{sql} and c.year={_year} and c.semesterId='{_semesterId}'";
  660. HashSet<string> courseIds = new HashSet<string>();
  661. var resultSchool= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).GetList<CourseTask>(sql, $"CourseTask-{school}");
  662. if (resultSchool.list.IsNotEmpty()) {
  663. resultSchool.list.ForEach(x => {
  664. var schedulesTeacher = x.schedules.Where(z =>!string.IsNullOrWhiteSpace(z.teacherId) && z.teacherId.Equals(tmdid));
  665. if (schedulesTeacher.Any())
  666. {
  667. courseIds.Add(x.courseId);
  668. CourseTask courseTask = x.ToJsonString().ToObject<CourseTask>();
  669. courseTask.schedules=schedulesTeacher.ToList();
  670. schoolTeacherTask.Add(new KeyValuePair<string,CourseTask >(x.courseId, courseTask));
  671. //groupIds.AddRange(schedulesTeacher.Where(z => !string.IsNullOrWhiteSpace(z.groupId)).Select(x => x.groupId));
  672. }
  673. var schedulesAssistant = x.schedules.Where(z => z.assistants.Contains(tmdid) );
  674. if (schedulesAssistant.Any())
  675. {
  676. courseIds.Add(x.courseId);
  677. CourseTask courseTask = x.ToJsonString().ToObject<CourseTask>();
  678. courseTask.schedules=schedulesAssistant.ToList();
  679. schoolAssistantTask.Add(new KeyValuePair<string, CourseTask>(x.courseId, courseTask));
  680. //groupIds.AddRange(schedulesAssistant.Where(z => !string.IsNullOrWhiteSpace(z.groupId)).Select(x => x.groupId));
  681. }
  682. });
  683. }
  684. if (courseIds.Any()) {
  685. string sqlCourse = $"select value c from c where c.id in ({string.Join(",",courseIds.Select(b=>$"'{b}'"))})";
  686. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).GetList<CourseBase>(sqlCourse, $"CourseBase-{school}");
  687. if (result.list.IsNotEmpty())
  688. {
  689. foreach (var item in result.list)
  690. {
  691. List<CourseTaskDto> courseTaskDtos = new List<CourseTaskDto>();
  692. var teacher = schoolTeacherTask.Where(x => x.Key.Equals(item.id)).Select(z => new CourseTaskDto { courseTask=z.Value, type="teacher" });
  693. if (teacher.Any()) {
  694. courseTaskDtos.AddRange(teacher.ToList());
  695. }
  696. var assistant= schoolAssistantTask.Where(x => x.Key.Equals(item.id)).Select(z => new CourseTaskDto { courseTask=z.Value, type="assistant" });
  697. if (assistant.Any()) {
  698. courseTaskDtos.AddRange(assistant.ToList());
  699. }
  700. schoolCourses.Add(new CourseDto { courseBase=item, courseTasks=courseTaskDtos });
  701. }
  702. }
  703. }
  704. }
  705. {
  706. HashSet<string> courseIds = new HashSet<string>();
  707. string sqlCoursePrivate = $"select value c.id from c where c.creatorId='{tmdid}'";
  708. var resultCourseBasePrivate = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<string>(sqlCoursePrivate, $"CourseBase");
  709. if (resultCourseBasePrivate.list.IsNotEmpty())
  710. {
  711. courseIds=new HashSet<string>(resultCourseBasePrivate.list);
  712. }
  713. string sqlprivate = $"SELECT distinct value c FROM c join b in c.schedules where c.pk='CourseTask' and (ARRAY_CONTAINS(b.assistants,'{tmdid}')or b.teacherId ='{tmdid}' )";
  714. var resultTeacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<CourseTask>(sqlprivate, $"CourseTask");
  715. if (resultTeacher.list.IsNotEmpty())
  716. {
  717. resultTeacher.list.ForEach(x => {
  718. var schedulesTeacher = x.schedules.Where(z => !string.IsNullOrWhiteSpace(z.teacherId) && z.teacherId.Equals(tmdid));
  719. if (schedulesTeacher.Any())
  720. {
  721. courseIds.Add(x.courseId);
  722. CourseTask courseTask = x.ToJsonString().ToObject<CourseTask>();
  723. courseTask.schedules=schedulesTeacher.ToList();
  724. privateTeacherTask.Add(new KeyValuePair<string, CourseTask>(x.courseId, courseTask));
  725. groupIds.AddRange(schedulesTeacher.Where(z => !string.IsNullOrWhiteSpace(z.groupId)).Select(x => x.groupId));
  726. }
  727. var schedulesAssistant = x.schedules.Where(z => z.assistants.Contains(tmdid));
  728. if (schedulesAssistant.Any())
  729. {
  730. courseIds.Add(x.courseId);
  731. CourseTask courseTask = x.ToJsonString().ToObject<CourseTask>();
  732. courseTask.schedules=schedulesAssistant.ToList();
  733. privateAssistantTask.Add(new KeyValuePair<string, CourseTask>(x.courseId, courseTask));
  734. groupIds.AddRange(schedulesAssistant.Where(z=>!string.IsNullOrWhiteSpace(z.groupId)).Select(x => x.groupId));
  735. }
  736. });
  737. }
  738. if (courseIds.Any())
  739. {
  740. string sqlCourse = $"select value c from c where c.creatorId='{tmdid}' and c.id in ({string.Join(",", courseIds.Select(b => $"'{b}'"))})";
  741. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<CourseBase>(sqlCourse, $"CourseBase");
  742. if (result.list.IsNotEmpty())
  743. {
  744. foreach (var item in result.list)
  745. {
  746. List<CourseTaskDto> courseTaskDtos = new List<CourseTaskDto>();
  747. var teacher = privateTeacherTask.Where(x => x.Key.Equals(item.id)).Select(z => new CourseTaskDto { courseTask=z.Value, type="teacher" });
  748. if (teacher.Any())
  749. {
  750. courseTaskDtos.AddRange(teacher.ToList());
  751. }
  752. var assistant = privateAssistantTask.Where(x => x.Key.Equals(item.id)).Select(z => new CourseTaskDto { courseTask=z.Value, type="assistant" });
  753. if (assistant.Any())
  754. {
  755. courseTaskDtos.AddRange(assistant.ToList());
  756. }
  757. teahcerCourses.Add(new CourseDto { courseBase=item, courseTasks=courseTaskDtos });
  758. }
  759. }
  760. }
  761. List<CourseGroupList> courseGroupLists = new List<CourseGroupList>();
  762. foreach (var z in teahcerCourses)
  763. {
  764. CourseGroupList courseGroupList= new CourseGroupList
  765. {
  766. scope="private",
  767. id=z.courseBase.id,
  768. name=z.courseBase.name,
  769. periodId=z.courseBase.period.id,
  770. period=z.courseBase.period.name,
  771. subject=z.courseBase.subject.name,
  772. subjectId= z.courseBase.subject.id
  773. };
  774. foreach (var x in z.courseTasks) {
  775. var groupListDatas = await GroupListService.GetMemberByListids(_coreAPIHttpService,_azureCosmos.GetCosmosClient(),_dingDing, x.courseTask.schedules.Select(v => v.groupId).ToList(),school) ;
  776. foreach (var data in groupListDatas.groups) {
  777. HashSet<string> groupName = data.members.Where(x => !string.IsNullOrEmpty(x.groupName)).Select(y => y.groupName).ToHashSet();
  778. GroupListGrp groupListGrp = new GroupListGrp(data, groupName);
  779. groupListGrp.teachType=x.type;
  780. courseGroupList.groups.Add(groupListGrp);
  781. }
  782. }
  783. }
  784. return Ok(new { groupLists = courseGroupLists });
  785. }
  786. }
  787. }
  788. return Ok();
  789. }
  790. /// <summary>
  791. /// 根据任意名单id获取成员信息。
  792. /// </summary>
  793. /// <param name="json"></param>
  794. /// <returns></returns>
  795. [ProducesDefaultResponseType]
  796. [HttpPost("get-members-listids")]
  797. #if !DEBUG
  798. [AuthToken(Roles = "teacher,admin,student")]
  799. [Authorize(Roles = "IES")]
  800. #endif
  801. public async Task<IActionResult> GetMembersListids(JsonElement json)
  802. {
  803. var client = _azureCosmos.GetCosmosClient();
  804. if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
  805. json.TryGetProperty("schoolId", out JsonElement schoolId);
  806. json.TryGetProperty("groupNames", out JsonElement groupNames);
  807. List<Dictionary<string, List<string>>> groupLists = new List<Dictionary<string, List<string>>>();
  808. if (groupNames.ValueKind.Equals(JsonValueKind.Array))
  809. {
  810. groupLists = groupNames.ToObject<List<Dictionary<string, List<string>>>>();
  811. }
  812. List<(string pId, List<string> gid)> ps = new List<(string pId, List<string> gid)>();
  813. if (groupLists.Count > 0)
  814. {
  815. foreach (var gp in groupLists)
  816. {
  817. foreach (KeyValuePair<string, List<string>> pp in gp)
  818. {
  819. ps.Add((pp.Key, pp.Value));
  820. }
  821. }
  822. }
  823. List<string> listids = ids.ToObject<List<string>>();
  824. (List<RMember> members, List<RGroupList> groups) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, listids, $"{schoolId}", ps);
  825. return Ok(new { groups, members });
  826. }
  827. /// <summary>
  828. /// 根据任意名单id获取名单摘要信息。
  829. /// </summary>
  830. /// <param name="json"></param>
  831. /// <returns></returns>
  832. [ProducesDefaultResponseType]
  833. [HttpPost("get-grouplist-listids")]
  834. #if !DEBUG
  835. [AuthToken(Roles = "teacher,admin,student")]
  836. [Authorize(Roles = "IES")]
  837. #endif
  838. public async Task<IActionResult> GetGroupListListids(JsonElement json)
  839. {
  840. var client = _azureCosmos.GetCosmosClient();
  841. if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
  842. json.TryGetProperty("schoolId", out JsonElement schoolId);
  843. List<string> listids = ids.ToObject<List<string>>();
  844. List<GroupListDto> groups = await GroupListService.GetGroupListByListids(client, _dingDing, listids, $"{schoolId}", SummarySql);
  845. return Ok(new { groups });
  846. }
  847. /// <summary>
  848. /// 获取名单和成员信息。
  849. /// </summary>
  850. /// <param name="json"></param>
  851. /// <returns></returns>
  852. [ProducesDefaultResponseType]
  853. [AuthToken(Roles = "teacher,admin,student")]
  854. [HttpPost("get-grouplists-members")]
  855. [Authorize(Roles = "IES")]
  856. public async Task<IActionResult> GetGrouplistsMembers(JsonElement json)
  857. {
  858. try
  859. {
  860. var client = _azureCosmos.GetCosmosClient();
  861. json.TryGetProperty("tmdid", out JsonElement _tmdid);
  862. json.TryGetProperty("schoolId", out JsonElement _schoolId);
  863. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  864. if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
  865. json.TryGetProperty("periodId", out JsonElement periodId);
  866. json.TryGetProperty("no", out JsonElement no);
  867. StringBuilder sql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='{type}'");
  868. List<RGroupList> groups = new List<RGroupList>();
  869. string tbname = "Teacher";
  870. string code = $"GroupList";
  871. if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
  872. {
  873. tbname = "School";
  874. code = $"GroupList-{_schoolId}";
  875. if (!string.IsNullOrEmpty($"{periodId}"))
  876. {
  877. sql.Append($" and c.periodId='{periodId}'");
  878. }
  879. if (!string.IsNullOrEmpty($"{no}"))
  880. {
  881. sql.Append($" and c.no='{no}'");
  882. }
  883. }
  884. else
  885. {
  886. sql.Append($" and c.creatorId='{_tmdid}'");
  887. }
  888. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<RGroupList>(queryText: sql.ToString(),
  889. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
  890. {
  891. groups.Add(item);
  892. }
  893. (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(_coreAPIHttpService, client, $"{type}", groups, tbname, _dingDing, $"{_schoolId}");
  894. return Ok(new { groups = groupsData, members });
  895. }
  896. catch (CosmosException ex)
  897. {
  898. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplists-members()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  899. }
  900. catch (Exception ex)
  901. {
  902. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplists-members()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  903. }
  904. return Ok();
  905. }
  906. /// <summary>
  907. /// 获取名单列表
  908. /// </summary>
  909. /// <param name="json"></param>
  910. /// <returns></returns>
  911. [ProducesDefaultResponseType]
  912. [AuthToken(Roles = "teacher,admin,student")]
  913. [HttpPost("get-grouplists")]
  914. [Authorize(Roles = "IES")]
  915. public async Task<IActionResult> GetGrouplists(JsonElement json)
  916. {
  917. try
  918. {
  919. var client = _azureCosmos.GetCosmosClient();
  920. json.TryGetProperty("tmdid", out JsonElement _tmdid);
  921. json.TryGetProperty("schoolId", out JsonElement _schoolId);
  922. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  923. if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
  924. json.TryGetProperty("periodId", out JsonElement periodId);
  925. json.TryGetProperty("no", out JsonElement no);
  926. StringBuilder sql = new StringBuilder($"SELECT distinct {SummarySql} FROM c where c.type='{type}'");
  927. List<GroupListDto> groups = new List<GroupListDto>();
  928. string tbname = "Teacher";
  929. string code = $"GroupList";
  930. if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
  931. {
  932. tbname = "School";
  933. code = $"GroupList-{_schoolId}";
  934. if (!string.IsNullOrEmpty($"{periodId}"))
  935. {
  936. sql.Append($" and c.periodId='{periodId}'");
  937. }
  938. if (!string.IsNullOrEmpty($"{no}"))
  939. {
  940. sql.Append($" and c.no='{no}'");
  941. }
  942. }
  943. else
  944. {
  945. sql.Append($" and c.creatorId='{_tmdid}'");
  946. }
  947. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<GroupListDto>(queryText: sql.ToString(),
  948. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
  949. {
  950. groups.Add(item);
  951. }
  952. return Ok(new { groups });
  953. }
  954. catch (CosmosException ex)
  955. {
  956. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplists()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  957. }
  958. catch (Exception ex)
  959. {
  960. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplists()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  961. }
  962. return Ok();
  963. }
  964. /// <summary>
  965. /// 根据id,code获取学校行政班信息和学生信息。用于维护学生基本信息。
  966. /// </summary>
  967. /// <param name="json"></param>
  968. /// <returns></returns>
  969. [ProducesDefaultResponseType]
  970. [AuthToken(Roles = "teacher,admin")]
  971. [HttpPost("get-classstudents-idcode")]
  972. [Authorize(Roles = "IES")]
  973. public async Task<IActionResult> GetClassStudentsIdcode(JsonElement json)
  974. {
  975. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  976. if (!json.TryGetProperty("code", out JsonElement _code)) return BadRequest();
  977. try
  978. {
  979. var client = _azureCosmos.GetCosmosClient();
  980. Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"Class-{_code}"));
  981. List<Student> students = new List<Student>();
  982. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
  983. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
  984. {
  985. item.salt = null;
  986. item.pw = null;
  987. students.Add(item);
  988. }
  989. return Ok(new { classInfo = clazz, students = students });
  990. }
  991. catch (Exception ex)
  992. {
  993. return Ok(new { error = 404, msg = "班级不存在!" });
  994. }
  995. }
  996. //处理通用名单
  997. [ProducesDefaultResponseType]
  998. [AuthToken(Roles = "teacher,admin,student")]
  999. [HttpPost("get-grouplist-idcode")]
  1000. [Authorize(Roles = "IES")]
  1001. public async Task<IActionResult> GetGrouplistIdcode(JsonElement json)
  1002. {
  1003. RGroupList groupList = null;
  1004. try
  1005. {
  1006. var client = _azureCosmos.GetCosmosClient();
  1007. json.TryGetProperty("type", out JsonElement _type);
  1008. json.TryGetProperty("code", out JsonElement _code);
  1009. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  1010. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  1011. string tbname = $"{scope}".Equals("private") ? "Teacher" : "School";
  1012. string code = "";
  1013. if (string.IsNullOrEmpty($"{_type}") || !$"{_type}".Equals("class"))
  1014. {
  1015. if ($"{scope}".Equals("private"))
  1016. {
  1017. //私人名单
  1018. code = "GroupList";
  1019. }
  1020. else
  1021. {
  1022. //学校自定义名单
  1023. code = !code.StartsWith("GroupList-") ? $"GroupList-{_code}" : code;
  1024. }
  1025. groupList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<RGroupList>($"{id}", new PartitionKey($"{code}"));
  1026. }
  1027. else if ($"{_type}".Equals("class"))
  1028. {
  1029. try
  1030. {
  1031. code = $"Class-{_code}";
  1032. Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"{code}"));
  1033. if (clazz != null)
  1034. {
  1035. List<Student> students = new List<Student>();
  1036. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
  1037. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
  1038. {
  1039. students.Add(item);
  1040. }
  1041. ///行政班(学生搜寻classId动态返回)class
  1042. 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();
  1043. groupList = new RGroupList
  1044. {
  1045. id = clazz.id,
  1046. code = $"GroupList-{clazz.school}",
  1047. name = clazz.name,
  1048. periodId = clazz.periodId,
  1049. pk = "GroupList",
  1050. year = clazz.year,
  1051. expire = 0,
  1052. school = clazz.school,
  1053. scope = "school",
  1054. type = "class",
  1055. scount = smembers.Count,
  1056. no = clazz.no,
  1057. leader = clazz.teacher?.id,
  1058. members = smembers,
  1059. };
  1060. }
  1061. }
  1062. catch (CosmosException ex)
  1063. {
  1064. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  1065. return Ok(new { groupList });
  1066. }
  1067. }
  1068. (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(_coreAPIHttpService, client, $"{groupList.type}", new List<RGroupList> { groupList }, tbname, _dingDing, $"{_code}");
  1069. groupList = groupsData.FirstOrDefault();
  1070. }
  1071. catch (CosmosException ex)
  1072. {
  1073. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n {json}", GroupNames.醍摩豆服務運維群組);
  1074. return Ok(new { groupList });
  1075. }
  1076. catch (Exception ex)
  1077. {
  1078. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}\n{ex.StackTrace}\n{json}", GroupNames.醍摩豆服務運維群組);
  1079. }
  1080. return Ok(new { groupList });
  1081. }
  1082. /// <summary>
  1083. /// 保存或更新通用名单
  1084. /// </summary>
  1085. /// <param name="json"></param>
  1086. /// <returns></returns>
  1087. [ProducesDefaultResponseType]
  1088. [AuthToken(Roles = "teacher,admin")]
  1089. [HttpPost("upsert-grouplist")]
  1090. #if !DEBUG
  1091. [Authorize(Roles = "IES")]
  1092. #endif
  1093. public async Task<IActionResult> UpsertGroupList(JsonElement json)
  1094. {
  1095. GroupList list = json.ToObject<GroupList>();
  1096. try
  1097. {
  1098. var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
  1099. if (string.IsNullOrEmpty(list.type))
  1100. {
  1101. return BadRequest();
  1102. }
  1103. list.year = list.year > 0 ? list.year : DateTimeOffset.UtcNow.Year;
  1104. list.ttl = -1;
  1105. list.creatorId = userid;
  1106. list.school = string.IsNullOrEmpty(list.school) ? school : list.school;
  1107. list.pk = "GroupList";
  1108. if (list.scope.Equals("private"))
  1109. {
  1110. //私人名单
  1111. list.code = "GroupList";
  1112. list.school = null;
  1113. //只有开启审核,且设置天数大于零,且之前没有设置过期时间的时候才会重新设置过期时间。
  1114. GroupList dblist = null;
  1115. if (!string.IsNullOrWhiteSpace(list.id))
  1116. {
  1117. var response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(list.id, new PartitionKey(list.code));
  1118. if (response.Status==200)
  1119. {
  1120. dblist = JsonDocument.Parse(response.Content).RootElement.ToObject<GroupList>();
  1121. }
  1122. }
  1123. if (list.review==1)
  1124. {
  1125. if (list.qrcodeDays>0)
  1126. {
  1127. if (dblist!=null)
  1128. {
  1129. //更新过期时间
  1130. if (dblist.qrcodeDays!=list.qrcodeDays)
  1131. {
  1132. list.qrcodeExpire= DateTimeOffset.UtcNow.AddDays(list.qrcodeDays).ToUnixTimeMilliseconds();
  1133. string key = $"GroupList:GroupWaitingList:{list.scope}:{list.id}";
  1134. await _azureRedis.GetRedisClient(8).KeyExpireAsync(key, expiry: DateTimeOffset.FromUnixTimeMilliseconds(list.qrcodeExpire).UtcDateTime);
  1135. }
  1136. else
  1137. {
  1138. //相同
  1139. if (dblist.review==0 && list.review==1)
  1140. {
  1141. list.qrcodeExpire= DateTimeOffset.UtcNow.AddDays(list.qrcodeDays).ToUnixTimeMilliseconds();
  1142. string key = $"GroupList:GroupWaitingList:{list.scope}:{list.id}";
  1143. await _azureRedis.GetRedisClient(8).KeyExpireAsync(key, expiry: DateTimeOffset.FromUnixTimeMilliseconds(list.qrcodeExpire).UtcDateTime);
  1144. }
  1145. else
  1146. {
  1147. list.qrcodeExpire=dblist.qrcodeExpire;
  1148. }
  1149. }
  1150. }
  1151. else
  1152. {
  1153. if (list.qrcodeExpire<=0)
  1154. {
  1155. list.qrcodeExpire= DateTimeOffset.UtcNow.AddDays(list.qrcodeDays).ToUnixTimeMilliseconds();
  1156. }
  1157. }
  1158. }
  1159. else
  1160. {
  1161. return Ok(new { error = 400, msg = "必须设置二维码过期天数!" });
  1162. }
  1163. }
  1164. else
  1165. {
  1166. if (dblist!=null && dblist.review==1) {
  1167. list.qrcodeDays = 1;
  1168. list.qrcodeExpire = 0;
  1169. string key = $"GroupList:GroupWaitingList:{list.scope}:{list.id}";
  1170. var datas = await _azureRedis.GetRedisClient(8).HashGetAllAsync(key);
  1171. List<GroupWaitingList> groupWaitingLists = new List<GroupWaitingList>();
  1172. foreach (var rcd in datas)
  1173. {
  1174. var value = rcd.Value.ToString().ToObject<GroupWaitingList>();
  1175. if (value!=null) { groupWaitingLists.Add(value); }
  1176. }
  1177. if (groupWaitingLists.IsNotEmpty()) {
  1178. var takeCount = list.limitCount-dblist.members.Count;
  1179. if (takeCount>0)
  1180. {
  1181. var takes = groupWaitingLists.OrderBy(x => x.applyTime).Take(takeCount);
  1182. if (takes!=null && takes.Count()>0)
  1183. {
  1184. foreach (var t in takes)
  1185. {
  1186. GroupListService.JoinList(list, t.userid, t.type, t.school, t.year);
  1187. string stuKey = !string.IsNullOrWhiteSpace(school) ? $"GroupList:StudentWaitinglist:{school}_{t.userid}" : $"GroupList:StudentWaitinglist:{t.userid}";
  1188. string stuFiled = $"{list.scope}:{list.id}";
  1189. var data = await _azureRedis.GetRedisClient(8).HashGetAsync(stuKey, stuFiled);
  1190. if (data != default && !data.IsNullOrEmpty)
  1191. {
  1192. var value = data.ToString().ToObject<GroupWaitingList>();
  1193. value.status=0;
  1194. await _azureRedis.GetRedisClient(8).HashSetAsync(stuKey, stuFiled, value.ToJsonString());
  1195. }
  1196. }
  1197. //未自动加入的,直接拒绝
  1198. var untakes = groupWaitingLists.Except(takes);
  1199. if (untakes!=null && untakes.Count()>0)
  1200. {
  1201. foreach (var t in takes)
  1202. {
  1203. string stuKey = !string.IsNullOrWhiteSpace(school) ? $"GroupList:StudentWaitinglist:{school}_{t.userid}" : $"GroupList:StudentWaitinglist:{t.userid}";
  1204. string stuFiled = $"{list.scope}:{list.id}";
  1205. var data = await _azureRedis.GetRedisClient(8).HashGetAsync(stuKey, stuFiled);
  1206. if (data != default && !data.IsNullOrEmpty)
  1207. {
  1208. var value = data.ToString().ToObject<GroupWaitingList>();
  1209. value.status=1;
  1210. await _azureRedis.GetRedisClient(8).HashSetAsync(stuKey, stuFiled, value.ToJsonString());
  1211. }
  1212. }
  1213. }
  1214. }
  1215. }
  1216. else
  1217. {
  1218. //已经加满,删除候选
  1219. foreach (var t in groupWaitingLists)
  1220. {
  1221. string stuKey = !string.IsNullOrWhiteSpace(school) ? $"GroupList:StudentWaitinglist:{school}_{t.userid}" : $"GroupList:StudentWaitinglist:{t.userid}";
  1222. string stuFiled = $"{list.scope}:{list.id}";
  1223. var data = await _azureRedis.GetRedisClient(8).HashGetAsync(stuKey, stuFiled);
  1224. if (data != default && !data.IsNullOrEmpty)
  1225. {
  1226. var value = data.ToString().ToObject<GroupWaitingList>();
  1227. value.status=1;
  1228. await _azureRedis.GetRedisClient(8).HashSetAsync(stuKey, stuFiled, value.ToJsonString());
  1229. }
  1230. }
  1231. }
  1232. }
  1233. await _azureRedis.GetRedisClient(8).KeyDeleteAsync(key);
  1234. }
  1235. }
  1236. }
  1237. else
  1238. {
  1239. //学校自定义名单
  1240. list.code = !list.code.StartsWith("GroupList-") ? $"GroupList-{list.code}" : list.code;
  1241. }
  1242. switch (true)
  1243. {
  1244. //普通学生名单(包含学校教学班名单,个人课程名单),其中学生成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList-hbcn
  1245. case bool when $"{list.type}".Equals("teach", StringComparison.OrdinalIgnoreCase):
  1246. list.type = "teach";
  1247. list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
  1248. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  1249. break;
  1250. //教研组名单,只有加入学校的老师名单 成员账号类型是醍摩豆ID,保存在学校表,分区键为GroupList-hbcn
  1251. case bool when $"{list.type}".Equals("research", StringComparison.OrdinalIgnoreCase):
  1252. list.type = "research";
  1253. list.scope = "school";
  1254. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  1255. break;
  1256. //个人好友名单,成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList
  1257. case bool when $"{list.type}".Equals("friend", StringComparison.OrdinalIgnoreCase):
  1258. list.type = "friend";
  1259. list.scope = "private";
  1260. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  1261. break;
  1262. //社交群组类型(包含学校交流群组,个人交流群组),成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn
  1263. case bool when $"{list.type}".Equals("group", StringComparison.OrdinalIgnoreCase):
  1264. list.type = "group";
  1265. list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
  1266. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  1267. break;
  1268. //研修类型成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn
  1269. case bool when $"{list.type}".Equals("yxtrain", StringComparison.OrdinalIgnoreCase):
  1270. list.type = "yxtrain";
  1271. list.scope = "school";
  1272. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  1273. break;
  1274. default:
  1275. return Ok(new { error = 400, msg = "参数错误!" });
  1276. }
  1277. return Ok(new { list });
  1278. }
  1279. catch (Exception ex)
  1280. {
  1281. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  1282. return BadRequest();
  1283. }
  1284. }
  1285. //删除名单
  1286. [ProducesDefaultResponseType]
  1287. [AuthToken(Roles = "teacher,admin")]
  1288. [HttpPost("delete-grouplist")]
  1289. [Authorize(Roles = "IES")]
  1290. public async Task<IActionResult> DeleteGroupList(JsonElement json)
  1291. {
  1292. try
  1293. {
  1294. if (!json.TryGetProperty("code", out JsonElement code)) return BadRequest();
  1295. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  1296. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  1297. var client = _azureCosmos.GetCosmosClient();
  1298. string tbname = "";
  1299. string datacode = "";
  1300. if (scope.ToString().Equals("school", StringComparison.OrdinalIgnoreCase))
  1301. {
  1302. tbname = "School";
  1303. datacode = $"GroupList-{code}";
  1304. }
  1305. else
  1306. {
  1307. tbname = "Teacher";
  1308. datacode = $"GroupList";
  1309. }
  1310. try
  1311. {
  1312. await GroupListService.DeleteGrouplistEvent($"{id}", datacode, tbname, client, _configuration, _serviceBus);
  1313. }
  1314. catch (Exception ex) { }
  1315. return Ok(new { id });
  1316. }
  1317. catch (Exception ex)
  1318. {
  1319. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/delete-grouplist()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  1320. return Ok(new { error = 400 });
  1321. }
  1322. }
  1323. /// <summary>
  1324. /// 保存或更新通用名单
  1325. /// </summary>
  1326. /// <param name="json"></param>
  1327. /// <returns></returns>
  1328. [ProducesDefaultResponseType]
  1329. [AuthToken(Roles = "teacher,admin,student")]
  1330. [HttpPost("upsert-group-member")]
  1331. [Authorize(Roles = "IES")]
  1332. public async Task<IActionResult> UpsertGroupMember(JsonElement json)
  1333. {
  1334. if (!json.TryGetProperty("opt", out JsonElement _opt)) { return BadRequest(); }
  1335. if (!json.TryGetProperty("scope", out JsonElement _scope)) { return BadRequest(); }
  1336. if (!json.TryGetProperty("id", out JsonElement _id)) { return BadRequest(); }
  1337. if (!json.TryGetProperty("code", out JsonElement _code)) { return BadRequest(); }
  1338. if (!json.TryGetProperty("type", out JsonElement _type)) { return BadRequest(); }
  1339. try
  1340. {
  1341. GroupList groupList = null;
  1342. string tbname = $"{_scope}".Equals("private") ? "Teacher" : "School";
  1343. string code = "";
  1344. if (string.IsNullOrEmpty($"{_type}") || !$"{_type}".Equals("class"))
  1345. {
  1346. if ($"{_scope}".Equals("private"))
  1347. {
  1348. //私人名单
  1349. code = "GroupList";
  1350. }
  1351. else
  1352. {
  1353. //学校自定义名单
  1354. code = !code.StartsWith("GroupList-") ? $"GroupList-{_code}" : code;
  1355. }
  1356. groupList = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<GroupList>($"{_id}", new PartitionKey($"{code}"));
  1357. }
  1358. switch (true)
  1359. {
  1360. case bool when $"{_opt}".Equals("up-nickname", StringComparison.OrdinalIgnoreCase) && json.TryGetProperty("members", out JsonElement _members):
  1361. var members = _members.ToObject<List<Member>>();
  1362. List<Member> updateSuccess = new List<Member>();
  1363. List<Member> updateFailed = new List<Member>();
  1364. members.ForEach(x =>
  1365. {
  1366. var member = groupList.members.Find(z => z.type == x.type && z.id.Equals(x.id));
  1367. if (member != null)
  1368. {
  1369. member.nickname = x.nickname;
  1370. updateSuccess.Add(member);
  1371. }
  1372. else
  1373. {
  1374. updateFailed.Add(x);
  1375. }
  1376. });
  1377. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReplaceItemAsync<GroupList>(groupList, $"{_id}", new PartitionKey(code));
  1378. return Ok(new { updateSuccess, updateFailed });
  1379. }
  1380. }
  1381. catch (Exception ex)
  1382. {
  1383. await _dingDing.SendBotMsg($"{_option.Location},更新名单成员信息异常{ex.Message}\n{ex.StackTrace}\n", GroupNames.成都开发測試群組);
  1384. return BadRequest();
  1385. }
  1386. return Ok();
  1387. }
  1388. /// <
  1389. /// summary>
  1390. /// 处理名单审核
  1391. /// </summary>
  1392. /// <param name="json"></param>
  1393. /// <returns></returns>
  1394. [ProducesDefaultResponseType]
  1395. [AuthToken(Roles = "teacher,admin,student")]
  1396. [HttpPost("review")]
  1397. #if !DEBUG
  1398. [Authorize(Roles = "IES")]
  1399. #endif
  1400. public async Task<IActionResult> review(JsonElement request)
  1401. {
  1402. (string userId, _, _, string school) = HttpContext.GetAuthTokenInfo();
  1403. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  1404. var client = _azureCosmos.GetCosmosClient();
  1405. switch (true)
  1406. {
  1407. //待加入列表
  1408. case bool when $"{grant_type}".Equals("waitlist", StringComparison.OrdinalIgnoreCase):
  1409. {
  1410. if (!request.TryGetProperty("id", out JsonElement _id)) return BadRequest();
  1411. if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
  1412. //string tbname = ($"{_scope}".Equals("school")) ? Constant.School : Constant.Teacher;
  1413. //string code = $"";
  1414. string key = $"GroupList:GroupWaitingList:{_scope}:{_id}";
  1415. var datas = await _azureRedis.GetRedisClient(8).HashGetAllAsync(key);
  1416. List<GroupWaitingList> waitingLists = new List<GroupWaitingList>();
  1417. if (datas!=null && datas.Length>0)
  1418. {
  1419. foreach (var data in datas)
  1420. {
  1421. var group = data.Value.ToString().ToObject<GroupWaitingList>();
  1422. if (group!=null)
  1423. {
  1424. waitingLists.Add(group);
  1425. }
  1426. }
  1427. }
  1428. return Ok(new { waitingLists });
  1429. }
  1430. //处理审核
  1431. case bool when $"{grant_type}".Equals("process", StringComparison.OrdinalIgnoreCase):
  1432. {
  1433. if (!request.TryGetProperty("id", out JsonElement _id)) return BadRequest();
  1434. if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
  1435. if (!request.TryGetProperty("pass", out JsonElement _pass)) return BadRequest();
  1436. if (!request.TryGetProperty("members", out JsonElement _members)) return BadRequest();
  1437. var members = _members.ToObject<List<Member>>();
  1438. string tbname = $"{_scope}".Equals("school") ? Constant.School : Constant.Teacher;
  1439. string code = $"{_scope}".Equals("school") ?$"GroupList-{school}" : "GroupList";
  1440. string key = $"GroupList:GroupWaitingList:{_scope}:{_id}";
  1441. List<GroupWaitingList> waitingLists = new List<GroupWaitingList>();
  1442. if (members.IsNotEmpty()) {
  1443. Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, tbname).ReadItemStreamAsync(_id.ToString(), new PartitionKey(code));
  1444. if (response.Status==200)
  1445. {
  1446. GroupList groupList = JsonDocument.Parse(response.Content).RootElement.ToObject<GroupList>();
  1447. bool add=false;
  1448. foreach (var member in members)
  1449. {
  1450. string filed = $"{member.type}".Equals("2") ? $"{school}_{member.id}" : member.id;
  1451. var data = await _azureRedis.GetRedisClient(8).HashGetAsync(key, filed);
  1452. if (data != default && !data.IsNullOrEmpty)
  1453. {
  1454. var value = data.ToString().ToObject<GroupWaitingList>();
  1455. string stuKey = !string.IsNullOrWhiteSpace(school) ? $"GroupList:StudentWaitinglist:{school}_{member.id}" : $"GroupList:StudentWaitinglist:{member.id}";
  1456. string sutFiled = $"{_scope}:{_id}";
  1457. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1458. if ($"{_pass}".Equals("0"))
  1459. {
  1460. //通过
  1461. if (now>value.qrcodeExpire)
  1462. {
  1463. value.status=2;
  1464. }
  1465. else
  1466. {
  1467. if (groupList!=null)
  1468. {
  1469. var mb = groupList.members.Find(x => x.type==value.type && x.id.Equals(value.userid));
  1470. if (mb== null)
  1471. {
  1472. var joindata = GroupListService.JoinList(groupList, value.userid, value.type, value.school, value.year);
  1473. if (joindata.status==0) {
  1474. add=true;
  1475. }
  1476. }
  1477. }
  1478. value.status=0;
  1479. }
  1480. await _azureRedis.GetRedisClient(8).HashDeleteAsync(key, filed);
  1481. await _azureRedis.GetRedisClient(8).HashSetAsync(stuKey, sutFiled, value.ToJsonString());
  1482. waitingLists.Add(value);
  1483. }
  1484. else if ($"{_pass}".Equals("1"))
  1485. {
  1486. //拒绝
  1487. value.status=1;
  1488. await _azureRedis.GetRedisClient(8).HashDeleteAsync(key, filed);
  1489. await _azureRedis.GetRedisClient(8).HashSetAsync(stuKey, sutFiled, value.ToJsonString());
  1490. waitingLists.Add(value);
  1491. }
  1492. else
  1493. {
  1494. return BadRequest(new { code = 1, msg = "参数错误" });
  1495. }
  1496. }
  1497. }
  1498. if (add)
  1499. {
  1500. await GroupListService.UpsertList(groupList, _azureCosmos, _configuration, _serviceBus);
  1501. }
  1502. }
  1503. }
  1504. return Ok(new { waitingLists });
  1505. }
  1506. //审核结果,学生端获取到被拒绝的,或者过期的自动删除,未被审核的保存
  1507. case bool when $"{grant_type}".Equals("result", StringComparison.OrdinalIgnoreCase):
  1508. {
  1509. string stuKey = !string.IsNullOrWhiteSpace(school) ? $"GroupList:StudentWaitinglist:{school}_{userId}" : $"GroupList:StudentWaitinglist:{userId}";
  1510. var datas = await _azureRedis.GetRedisClient(8).HashGetAllAsync(stuKey);
  1511. List<GroupWaitingList> waitingLists = new List<GroupWaitingList>();
  1512. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1513. if (datas!=null && datas.Length>0)
  1514. {
  1515. foreach (var data in datas)
  1516. {
  1517. var group = data.Value.ToString().ToObject<GroupWaitingList>();
  1518. if (group!=null)
  1519. {
  1520. waitingLists.Add(group);
  1521. if (group.status!=-1)
  1522. {
  1523. await _azureRedis.GetRedisClient(8).HashDeleteAsync(stuKey, $"{group.groupScope}:{group.groupId}");
  1524. }
  1525. else
  1526. {
  1527. if (now>group.qrcodeExpire)
  1528. {
  1529. group.status=2;
  1530. await _azureRedis.GetRedisClient(8).HashDeleteAsync(stuKey, $"{group.groupScope}:{group.groupId}");
  1531. }
  1532. }
  1533. }
  1534. }
  1535. }
  1536. return Ok(new { waitingLists });
  1537. }
  1538. }
  1539. return BadRequest();
  1540. }
  1541. /// <
  1542. /// summary>
  1543. /// 处理名单审核
  1544. /// </summary>
  1545. /// <param name="json"></param>
  1546. /// <returns></returns>
  1547. [ProducesDefaultResponseType]
  1548. [AuthToken(Roles = "teacher,admin")]
  1549. [HttpPost("backups")]
  1550. #if !DEBUG
  1551. [Authorize(Roles = "IES")]
  1552. #endif
  1553. public async Task<IActionResult> Backups(JsonElement json) {
  1554. if (!json.TryGetProperty("semesterId", out JsonElement semesterId)) { return BadRequest(); }
  1555. if (!json.TryGetProperty("studyYear", out JsonElement studyYear)) { return BadRequest(); }
  1556. if (!json.TryGetProperty("periodId", out JsonElement periodId)) { return BadRequest(); }
  1557. var (userid, _, _, schoolId) = HttpContext.GetAuthTokenInfo();
  1558. School school = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(schoolId, new PartitionKey("Base"));
  1559. var period= school.period.Find(z => z.id.Equals($"{periodId}"));
  1560. if (period!=null) {
  1561. var a = SchoolService.GetSemester(period,DateTimeOffset.UtcNow.ToUnixTimeMilliseconds());
  1562. }
  1563. return Ok();
  1564. }
  1565. }
  1566. }