GroupListController.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772
  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 TEAMModelOS.SDK.Models.Service;
  24. namespace TEAMModelOS.Controllers
  25. {
  26. [ProducesResponseType(StatusCodes.Status200OK)]
  27. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  28. //[Authorize(Roles = "IES5")]
  29. [Route("grouplist")]
  30. [ApiController]
  31. public class GroupListController : ControllerBase
  32. {
  33. private AzureCosmosFactory _azureCosmos;
  34. private readonly DingDing _dingDing;
  35. private readonly Option _option;
  36. private readonly AzureServiceBusFactory _serviceBus;
  37. private readonly AzureStorageFactory _azureStorage;
  38. 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 ";
  39. public IConfiguration _configuration { get; set; }
  40. public GroupListController(AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration)
  41. {
  42. _azureCosmos = azureCosmos;
  43. _dingDing = dingDing;
  44. _option = option?.Value;
  45. _serviceBus = serviceBus;
  46. _configuration = configuration;
  47. _azureStorage = azureStorage;
  48. }
  49. //学生获取自己已经加入的名单和课程。
  50. [ProducesDefaultResponseType]
  51. [HttpPost("get-my-course-grouplist")]
  52. public async Task<IActionResult> GetMyCourseAndGroupList(JsonElement json)
  53. {
  54. var (userid, _name, _picture, _) = HttpContext.GetAuthTokenInfo();
  55. if (!json.TryGetProperty("schoolId", out JsonElement _schoolId)) return BadRequest();
  56. var client = _azureCosmos.GetCosmosClient();
  57. object scope = null; ;
  58. HttpContext?.Items.TryGetValue("Scope", out scope);
  59. if ($"{scope}".Equals(Constant.ScopeStudent))
  60. {
  61. Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{_schoolId}"));
  62. }
  63. if ($"{scope}".Equals(Constant.ScopeTmdUser))
  64. {
  65. }
  66. if ($"{scope}".Equals(Constant.ScopeTeacher))
  67. {
  68. }
  69. return Ok();
  70. }
  71. /// <summary>
  72. /// 扫码加入名单
  73. /// </summary>
  74. /// <param name="json"></param>
  75. /// <returns></returns>
  76. [ProducesDefaultResponseType]
  77. [HttpPost("scan-code-join-list")]
  78. public async Task<IActionResult> ScanCodeJoinList(JsonElement json)
  79. {
  80. if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
  81. json.TryGetProperty("school", out JsonElement school);
  82. var client = _azureCosmos.GetCosmosClient();
  83. json.TryGetProperty("id_token", out JsonElement id_token);
  84. var jwt = new JwtSecurityToken(id_token.GetString());
  85. var id = jwt.Payload.Sub;
  86. jwt.Payload.TryGetValue("name", out object name);
  87. jwt.Payload.TryGetValue("picture", out object picture);
  88. try
  89. {
  90. TmdUser tmduser = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<TmdUser>(id, new PartitionKey("Base"));
  91. }
  92. catch (CosmosException ex)
  93. {
  94. if (ex.Status == 404)
  95. {
  96. //如果沒有,則初始化Teacher基本資料到Cosmos
  97. TmdUser tmduser = new TmdUser
  98. {
  99. id = id,
  100. pk = "Base",
  101. code = "Base",
  102. name = name?.ToString(),
  103. picture = picture?.ToString(),
  104. //创建账号并第一次登录IES5则默认赠送1G
  105. defaultSchool = null,
  106. schools = new List<TmdUser.School>(),
  107. };
  108. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Student").CreateItemAsync<TmdUser>(tmduser, new PartitionKey("Base"));
  109. }
  110. }
  111. (int status, GroupList stuList) data = await GroupListService.CodeJoinList(client, $"{_stuListNo}", id, type: 1, $"{school}");
  112. //没有TmdUser时
  113. if (data.status == 0)
  114. {
  115. await GroupListService.UpsertList(data.stuList, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  116. return Ok(new { data.stuList, data.status });
  117. }
  118. else
  119. {
  120. return Ok(new { data.status });
  121. }
  122. }
  123. /// <summary>
  124. /// 根据邀请码加入名单
  125. /// </summary>
  126. /// <param name="json"></param>
  127. /// <returns></returns>
  128. [ProducesDefaultResponseType]
  129. [AuthToken(Roles = "admin,teacher,student")]
  130. [HttpPost("input-code-join-list")]
  131. public async Task<IActionResult> InputCodeJoinList(JsonElement json)
  132. {
  133. if (!json.TryGetProperty("stuListNo", out JsonElement _stuListNo)) return BadRequest();
  134. var (userid, _name, _picture, school) = HttpContext.GetAuthTokenInfo();
  135. object scope = null;
  136. int type = 0;
  137. string no = null;
  138. var client = _azureCosmos.GetCosmosClient();
  139. HttpContext?.Items.TryGetValue("Scope", out scope);
  140. if ($"{scope}".Equals(Constant.ScopeStudent))
  141. {
  142. type = 2;
  143. Student student = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>(userid, new PartitionKey($"Base-{school}"));
  144. no = student.no;
  145. }
  146. if ($"{scope}".Equals(Constant.ScopeTmdUser))
  147. {
  148. type = 1;
  149. }
  150. if ($"{scope}".Equals(Constant.ScopeTeacher))
  151. {
  152. type = 1;
  153. }
  154. (int status, GroupList stuList) data = await GroupListService.CodeJoinList(client, $"{_stuListNo}", userid, type, school);
  155. if (data.status == 0)
  156. {
  157. await GroupListService.UpsertList(data.stuList, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  158. return Ok(new { data.stuList, data.status });
  159. }
  160. else
  161. {
  162. return Ok(new { data.status });
  163. }
  164. }
  165. /// <summary>
  166. /// 获取名单的tags
  167. /// </summary>
  168. /// <param name="json"></param>
  169. /// <returns></returns>
  170. [ProducesDefaultResponseType]
  171. [AuthToken(Roles = "admin,teacher,student")]
  172. [HttpPost("get-grouplist-tags")]
  173. public async Task<IActionResult> GetGrouplistTags(JsonElement json)
  174. {
  175. var client = _azureCosmos.GetCosmosClient();
  176. var (id, _, _, school) = HttpContext.GetAuthTokenInfo();
  177. object scope = null;
  178. StringBuilder sql = new StringBuilder($"SELECT {SummarySql} ,A1.tag FROM c " +
  179. $" join A1 in c. members where A1.id='{id}' and A1.tag<>null ");
  180. HttpContext?.Items.TryGetValue("Scope", out scope);
  181. if (!string.IsNullOrEmpty(school)&& $"{scope}".Equals(Constant.ScopeStudent)) {
  182. sql.Append($" and A1.code='{school}'");
  183. }
  184. List<dynamic> groupLists = new List<dynamic>();
  185. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  186. GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{school}") }))
  187. {
  188. groupLists.Add(item);
  189. }
  190. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
  191. GetItemQueryIterator<dynamic>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList") }))
  192. {
  193. groupLists.Add(item);
  194. }
  195. return Ok(new { groupLists });
  196. }
  197. /// <summary>
  198. /// 获取发布活动的名单
  199. /// </summary>
  200. /// <param name="json"></param>
  201. /// <returns></returns>
  202. [ProducesDefaultResponseType]
  203. [AuthToken(Roles = "teacher,admin,student")]
  204. [HttpPost("get-activity-grouplist")]
  205. public async Task<IActionResult> GetActivityGrouplist(JsonElement json)
  206. {
  207. var client = _azureCosmos.GetCosmosClient();
  208. json.TryGetProperty("tmdid", out JsonElement tmdid);
  209. json.TryGetProperty("schoolId", out JsonElement schoolId);
  210. if (!json.TryGetProperty("opt", out JsonElement opt)) { return BadRequest(); }
  211. json.TryGetProperty("periodId", out JsonElement periodId);
  212. List<GroupListDto> groupLists = new List<GroupListDto>();
  213. switch (true)
  214. {
  215. //我管理的
  216. case bool when $"{opt}".Equals("manage", StringComparison.OrdinalIgnoreCase):
  217. //包含,学校的行政班,教学班
  218. StringBuilder sql = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year FROM c ");
  219. if (!string.IsNullOrEmpty($"{periodId}"))
  220. {
  221. sql.Append($" where c.periodId='{periodId}' ");
  222. }
  223. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: sql.ToString(),
  224. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Class-{schoolId}") }))
  225. {
  226. ///行政班(学生搜寻classId动态返回)class
  227. GroupListDto group = new GroupListDto
  228. {
  229. id = item.id,
  230. code = $"GroupList-{schoolId}",
  231. name = item.name,
  232. periodId = item.periodId,
  233. scope = "school",
  234. school = $"{schoolId}",
  235. type = "class",
  236. year = item.year
  237. };
  238. groupLists.Add(group);
  239. }
  240. string sqls = $"SELECT distinct {SummarySql} FROM c ";
  241. //教学班
  242. sql = new StringBuilder($"{sqls} where c.type='teach'");
  243. if (!string.IsNullOrEmpty($"{periodId}"))
  244. {
  245. sql.Append($" and c.periodId='{periodId}'");
  246. }
  247. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  248. GetItemQueryIterator<GroupListDto>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
  249. {
  250. groupLists.Add(item);
  251. }
  252. //教研组
  253. sql = new StringBuilder($"{sqls} where c.type='research'");
  254. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  255. GetItemQueryIterator<GroupListDto>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{schoolId}") }))
  256. {
  257. groupLists.Add(item);
  258. }
  259. return Ok(new { groupLists });
  260. case bool when $"{opt}".Equals("teach", StringComparison.OrdinalIgnoreCase):
  261. //我执教的
  262. //从学校的课程和个人课程搜寻与我相关的课程对应的名单。
  263. List<TeachCourse> teachCourses = new List<TeachCourse>();
  264. if (!string.IsNullOrEmpty($"{schoolId}"))
  265. {
  266. 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}'");
  267. if (!string.IsNullOrEmpty($"{periodId}"))
  268. {
  269. schoolQuery.Append($" and c.period.id='{periodId}' ");
  270. }
  271. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").
  272. GetItemQueryIterator<TeachCourse>(queryText: schoolQuery.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{schoolId}") }))
  273. {
  274. teachCourses.Add(item);
  275. }
  276. }
  277. 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}'");
  278. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").
  279. GetItemQueryIterator<TeachCourse>(queryText: query.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Course-{tmdid}") }))
  280. {
  281. teachCourses.Add(item);
  282. }
  283. var classIds = teachCourses.Select(x => x.schedule).Where(y => !string.IsNullOrEmpty(y.classId)).Select(x => x.classId).Distinct().ToList();
  284. var schedule = teachCourses.Where(y => !string.IsNullOrEmpty(y.schedule.stulist)).Distinct().ToList();
  285. //var schedule = teachCourses.Select(x => new { schedule = x.schedule.Where(mm=>!string.IsNullOrEmpty(mm.stulist)), scope = x.scope }).ToList();
  286. if (classIds.IsNotEmpty())
  287. {
  288. string insql = string.Join(",", classIds.Select(x => $"'{x}'"));
  289. query = new StringBuilder($"SELECT c.id,c.name,c.periodId ,c.year FROM c where c.id in ({insql}) ");
  290. ///行政班(学生搜寻classId动态返回)class
  291. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ClassInfo>(queryText: $"select c.id,c.name ,c.periodId ,c.year from c where c.id in ({insql})",
  292. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Class-{schoolId}") }))
  293. {
  294. GroupListDto group = new GroupListDto
  295. {
  296. id = item.id,
  297. code = $"GroupList-{schoolId}",
  298. name = item.name,
  299. periodId = item.periodId,
  300. scope = "school",
  301. school = $"{schoolId}",
  302. type = "class",
  303. year = item.year
  304. };
  305. groupLists.Add(group);
  306. }
  307. }
  308. if (schedule.IsNotEmpty())
  309. {
  310. var privateList = schedule.Where(x => x.scope.Equals("private")).Select(x => x.schedule.stulist).Distinct();
  311. if (privateList.Count() > 0)
  312. {
  313. string insql = string.Join(",", privateList.Select(x => $"'{x}'"));
  314. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<GroupListDto>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql})",
  315. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList") }))
  316. {
  317. groupLists.Add(item);
  318. }
  319. }
  320. var schoolList = schedule.Where(x => x.scope.Equals("school")).Select(x => x.schedule.stulist).Distinct();
  321. if (schoolList.Count() > 0)
  322. {
  323. List<GroupListDto> groups = new List<GroupListDto>();
  324. string insql = string.Join(",", schoolList.Select(x => $"'{x}'"));
  325. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupListDto>(queryText: $"select distinct {SummarySql} from c where c.id in ({insql})",
  326. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{schoolId}") }))
  327. {
  328. groupLists.Add(item);
  329. }
  330. }
  331. }
  332. List<CourseGroupList> courseGroups = new List<CourseGroupList>();
  333. teachCourses.GroupBy(y => (y.id, y.name, y.scope, y.period.name, y.period.id, y.subject.name, y.subject.id)).ToList().ForEach(x => {
  334. List<GroupListDto> classIds = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.classId)).Select(b=>b.schedule.classId).Contains(n.id)).ToList();
  335. List<GroupListDto> stulists = groupLists.Where(n => x.Where(m => !string.IsNullOrEmpty(m.schedule.stulist)).Select(b => b.schedule.stulist).Contains(n.id)).ToList();
  336. if (classIds == null)
  337. {
  338. classIds = new List<GroupListDto>();
  339. }
  340. if (stulists != null)
  341. {
  342. classIds.AddRange(stulists);
  343. }
  344. CourseGroupList groupList = new CourseGroupList()
  345. {
  346. scope = x.Key.Item3,
  347. subject = x.Key.Item6,
  348. period = x.Key.Item4,
  349. id = x.Key.Item1,
  350. name = x.Key.Item2,
  351. groups = classIds
  352. };
  353. courseGroups.Add(groupList);
  354. });
  355. return Ok(new { groupLists = courseGroups });
  356. case bool when $"{opt}".Equals("private", StringComparison.OrdinalIgnoreCase):
  357. //我个人的
  358. break;
  359. default:
  360. break;
  361. }
  362. return Ok(new { error = 1, msg = "参数异常" });
  363. }
  364. /// <summary>
  365. /// 根据任意名单id获取成员信息。
  366. /// </summary>
  367. /// <param name="json"></param>
  368. /// <returns></returns>
  369. [ProducesDefaultResponseType]
  370. [AuthToken(Roles = "teacher,admin,student")]
  371. [HttpPost("get-members-listids")]
  372. public async Task<IActionResult> GetMembersListids(JsonElement json)
  373. {
  374. var client = _azureCosmos.GetCosmosClient();
  375. if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
  376. json.TryGetProperty("schoolId", out JsonElement schoolId);
  377. List<string> listids = ids.ToObject<List<string>>();
  378. (List < RMember > members,List < RGroupList > groups) = await GroupListService.GetStutmdidListids(client, _dingDing, listids, $"{schoolId}");
  379. return Ok(new { groups, members });
  380. }
  381. /// <summary>
  382. /// 根据任意名单id获取名单摘要信息。
  383. /// </summary>
  384. /// <param name="json"></param>
  385. /// <returns></returns>
  386. [ProducesDefaultResponseType]
  387. [AuthToken(Roles = "teacher,admin,student")]
  388. [HttpPost("get-grouplist-listids")]
  389. public async Task<IActionResult> GetGroupListListids(JsonElement json)
  390. {
  391. var client = _azureCosmos.GetCosmosClient();
  392. if (!json.TryGetProperty("ids", out JsonElement ids)) return BadRequest();
  393. json.TryGetProperty("schoolId", out JsonElement schoolId);
  394. List<string> listids = ids.ToObject<List<string>>();
  395. List<GroupListDto> groups = await GroupListService.GetGroupListListids(client, _dingDing, listids, $"{schoolId}", SummarySql);
  396. return Ok(new { groups });
  397. }
  398. /// <summary>
  399. /// 获取名单和成员信息。
  400. /// </summary>
  401. /// <param name="json"></param>
  402. /// <returns></returns>
  403. [ProducesDefaultResponseType]
  404. [AuthToken(Roles = "teacher,admin,student")]
  405. [HttpPost("get-grouplists-members")]
  406. public async Task<IActionResult> GetGrouplistsMembers(JsonElement json)
  407. {
  408. try
  409. {
  410. var client = _azureCosmos.GetCosmosClient();
  411. json.TryGetProperty("tmdid", out JsonElement _tmdid);
  412. json.TryGetProperty("schoolId", out JsonElement _schoolId);
  413. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  414. if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
  415. json.TryGetProperty("periodId", out JsonElement periodId);
  416. json.TryGetProperty("no", out JsonElement no);
  417. StringBuilder sql = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='{type}'");
  418. List<RGroupList> groups = new List<RGroupList>();
  419. string tbname = "Teacher";
  420. string code = $"GroupList";
  421. if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
  422. {
  423. tbname = "School";
  424. code = $"GroupList-{_schoolId}";
  425. if (!string.IsNullOrEmpty($"{periodId}"))
  426. {
  427. sql.Append($" and c.periodId='{periodId}'");
  428. }
  429. if (!string.IsNullOrEmpty($"{no}"))
  430. {
  431. sql.Append($" and c.no='{no}'");
  432. }
  433. }
  434. else
  435. {
  436. sql.Append($" and c.creatorId='{_tmdid}'");
  437. }
  438. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<RGroupList>(queryText: sql.ToString(),
  439. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
  440. {
  441. groups.Add(item);
  442. }
  443. (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(client, $"{type}", groups, tbname,_dingDing);
  444. return Ok(new { groups = groupsData, members });
  445. }
  446. catch (CosmosException ex)
  447. {
  448. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  449. }
  450. catch (Exception ex)
  451. {
  452. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  453. }
  454. return Ok();
  455. }
  456. /// <summary>
  457. /// 获取名单列表
  458. /// </summary>
  459. /// <param name="json"></param>
  460. /// <returns></returns>
  461. [ProducesDefaultResponseType]
  462. [AuthToken(Roles = "teacher,admin,student")]
  463. [HttpPost("get-grouplists")]
  464. public async Task<IActionResult> GetGrouplists(JsonElement json)
  465. {
  466. try
  467. {
  468. var client = _azureCosmos.GetCosmosClient();
  469. json.TryGetProperty("tmdid", out JsonElement _tmdid);
  470. json.TryGetProperty("schoolId", out JsonElement _schoolId);
  471. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  472. if (!json.TryGetProperty("type", out JsonElement type)) return BadRequest();
  473. json.TryGetProperty("periodId", out JsonElement periodId);
  474. json.TryGetProperty("no", out JsonElement no);
  475. StringBuilder sql = new StringBuilder($"SELECT distinct {SummarySql} FROM c where c.type='{type}'");
  476. List<GroupListDto> groups = new List<GroupListDto>();
  477. string tbname = "Teacher";
  478. string code = $"GroupList";
  479. if ($"{scope}".Equals("school", StringComparison.OrdinalIgnoreCase))
  480. {
  481. tbname = "School";
  482. code = $"GroupList-{_schoolId}";
  483. if (!string.IsNullOrEmpty($"{periodId}"))
  484. {
  485. sql.Append($" and c.periodId='{periodId}'");
  486. }
  487. if (!string.IsNullOrEmpty($"{no}"))
  488. {
  489. sql.Append($" and c.no='{no}'");
  490. }
  491. }
  492. else
  493. {
  494. sql.Append($" and c.creatorId='{_tmdid}'");
  495. }
  496. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, tbname).GetItemQueryIterator<GroupListDto>(queryText: sql.ToString(),
  497. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey(code) }))
  498. {
  499. groups.Add(item);
  500. }
  501. return Ok(new { groups });
  502. }
  503. catch (CosmosException ex)
  504. {
  505. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  506. }
  507. catch (Exception ex)
  508. {
  509. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  510. }
  511. return Ok();
  512. }
  513. /// <summary>
  514. /// 根据id,code获取学校行政班信息和学生信息。用于维护学生基本信息。
  515. /// </summary>
  516. /// <param name="json"></param>
  517. /// <returns></returns>
  518. [ProducesDefaultResponseType]
  519. [AuthToken(Roles = "teacher,admin")]
  520. [HttpPost("get-classstudents-idcode")]
  521. public async Task<IActionResult> GetClassStudentsIdcode(JsonElement json) {
  522. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  523. if (!json.TryGetProperty("code", out JsonElement _code)) return BadRequest();
  524. try {
  525. var client = _azureCosmos.GetCosmosClient();
  526. Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"Class-{_code}"));
  527. List<Student> students = new List<Student>();
  528. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
  529. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
  530. {
  531. item.salt = null;
  532. item.pw = null;
  533. students.Add(item);
  534. }
  535. return Ok(new { classInfo= clazz, students= students });
  536. } catch (Exception ex) {
  537. return Ok(new { error = 404,msg="班级不存在!" });
  538. }
  539. }
  540. //处理通用名单
  541. [ProducesDefaultResponseType]
  542. [AuthToken(Roles = "teacher,admin,student")]
  543. [HttpPost("get-grouplist-idcode")]
  544. public async Task<IActionResult> GetGrouplistIdcode(JsonElement json)
  545. {
  546. RGroupList groupList = null;
  547. try
  548. {
  549. var client = _azureCosmos.GetCosmosClient();
  550. json.TryGetProperty("type", out JsonElement _type);
  551. json.TryGetProperty("code", out JsonElement _code);
  552. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  553. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  554. string tbname = $"{scope}".Equals("private") ? "Teacher" : "School";
  555. string code = "";
  556. if (string.IsNullOrEmpty($"{_type}") || !$"{_type}".Equals("class"))
  557. {
  558. if ($"{scope}".Equals("private"))
  559. {
  560. //私人名单
  561. code = "GroupList";
  562. }
  563. else
  564. {
  565. //学校自定义名单
  566. code = !code.StartsWith("GroupList-") ? $"GroupList-{_code}" : code;
  567. }
  568. groupList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<RGroupList>($"{id}", new PartitionKey($"{code}"));
  569. }
  570. else if($"{_type}".Equals("class")) {
  571. try {
  572. code = $"Class-{_code}";
  573. Class clazz = await client.GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<Class>($"{id}", new PartitionKey($"{code}"));
  574. if (clazz != null) {
  575. List<Student> students = new List<Student>();
  576. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Student").GetItemQueryIterator<Student>(queryText: $"select value(c) from c where c.classId = '{clazz.id}'",
  577. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"Base-{_code}") }))
  578. {
  579. students.Add(item);
  580. }
  581. ///行政班(学生搜寻classId动态返回)class
  582. 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();
  583. groupList = new RGroupList
  584. {
  585. id=clazz.id,
  586. code=$"GroupList-{clazz.school}",
  587. name=clazz.name,
  588. periodId=clazz.periodId,
  589. pk= "GroupList",
  590. year=clazz.year,
  591. school=clazz.school ,
  592. scope = "school",
  593. type = "class",
  594. scount = smembers.Count,
  595. no=clazz.no,
  596. leader=clazz.teacher?.id,
  597. members= smembers,
  598. };
  599. }
  600. }catch (CosmosException ex) {
  601. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  602. return Ok(new { groupList });
  603. }
  604. }
  605. (List<RGroupList> groupsData, List<RMember> members) = await GroupListService.GetGroupListMemberInfo(client, $"{groupList.type}", new List<RGroupList> { groupList }, tbname,_dingDing);
  606. groupList = groupsData.FirstOrDefault();
  607. }
  608. catch (CosmosException ex)
  609. {
  610. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  611. return Ok(new { groupList });
  612. }
  613. catch (Exception ex)
  614. {
  615. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/get-grouplist-idcode()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  616. }
  617. return Ok(new { groupList });
  618. }
  619. /// <summary>
  620. /// 保存或更新通用名单
  621. /// </summary>
  622. /// <param name="json"></param>
  623. /// <returns></returns>
  624. [ProducesDefaultResponseType]
  625. [AuthToken(Roles = "teacher,admin")]
  626. [HttpPost("upsert-grouplist")]
  627. public async Task<IActionResult> UpsertGroupList(GroupList list)
  628. {
  629. try
  630. {
  631. var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
  632. if (string.IsNullOrEmpty(list.type))
  633. {
  634. return BadRequest();
  635. }
  636. list.year = list.year > 0 ? list.year : DateTimeOffset.UtcNow.Year;
  637. list.ttl = -1;
  638. list.creatorId = userid;
  639. list.school = string.IsNullOrEmpty(list.school) ? school : list.school;
  640. list.pk = "GroupList";
  641. if (list.scope.Equals("private"))
  642. {
  643. //私人名单
  644. list.code = "GroupList";
  645. list.school = null;
  646. }
  647. else
  648. {
  649. //学校自定义名单
  650. list.code = !list.code.StartsWith("GroupList-") ? $"GroupList-{list.code}" : list.code;
  651. }
  652. switch (true)
  653. {
  654. //普通学生名单(包含学校教学班名单,个人课程名单),其中学生成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList-hbcn
  655. case bool when $"{list.type}".Equals("teach", StringComparison.OrdinalIgnoreCase):
  656. list.type = "teach";
  657. list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
  658. list = await GroupListService.UpsertList(list, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  659. break;
  660. //教研组名单,只有加入学校的老师名单 成员账号类型是醍摩豆ID,保存在学校表,分区键为GroupList-hbcn
  661. case bool when $"{list.type}".Equals("research", StringComparison.OrdinalIgnoreCase):
  662. list.type = "research";
  663. list.scope = "school";
  664. list = await GroupListService.UpsertList(list, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  665. break;
  666. //个人好友名单,成员账号类型可以是学校学生账号和醍摩豆ID,分区键为GroupList
  667. case bool when $"{list.type}".Equals("friend", StringComparison.OrdinalIgnoreCase):
  668. list.type = "friend";
  669. list.scope = "private";
  670. list = await GroupListService.UpsertList(list, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  671. break;
  672. //社交群组类型(包含学校交流群组,个人交流群组),成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn
  673. case bool when $"{list.type}".Equals("group", StringComparison.OrdinalIgnoreCase):
  674. list.type = "group";
  675. list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
  676. list = await GroupListService.UpsertList(list, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  677. break;
  678. //社交群组类型(包含学校交流群组,个人交流群组),成员账号类型可以是学校学生账号和醍摩豆ID,,分区键为GroupList-hbcn
  679. case bool when $"{list.type}".Equals("yxtrain", StringComparison.OrdinalIgnoreCase):
  680. list.type = "yxtrain";
  681. list.scope = "school";
  682. list = await GroupListService.UpsertList(list, _azureCosmos, _azureStorage, _configuration, _serviceBus);
  683. break;
  684. default:
  685. return Ok(new { error = 400, msg = "参数错误!" });
  686. }
  687. return Ok(new { list });
  688. }
  689. catch (Exception ex)
  690. {
  691. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/upsert-grouplist()\n{ex.Message}{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
  692. return BadRequest();
  693. }
  694. }
  695. //删除名单
  696. [ProducesDefaultResponseType]
  697. [AuthToken(Roles = "teacher,admin")]
  698. [HttpPost("delete-grouplist")]
  699. public async Task<IActionResult> DeleteGroupList(JsonElement json)
  700. {
  701. try
  702. {
  703. if (!json.TryGetProperty("code", out JsonElement code)) return BadRequest();
  704. if (!json.TryGetProperty("scope", out JsonElement scope)) return BadRequest();
  705. if (!json.TryGetProperty("id", out JsonElement id)) return BadRequest();
  706. var client = _azureCosmos.GetCosmosClient();
  707. GroupChange change = new GroupChange();
  708. string tbname = "";
  709. string datacode = "";
  710. if (scope.ToString().Equals("school", StringComparison.OrdinalIgnoreCase))
  711. {
  712. tbname = "School";
  713. datacode = $"GroupList-{code}";
  714. }
  715. else
  716. {
  717. tbname = "Teacher";
  718. datacode = $"GroupList";
  719. }
  720. GroupList groupList = await client.GetContainer(Constant.TEAMModelOS, tbname).ReadItemAsync<GroupList>(id.ToString(), new PartitionKey(datacode));
  721. var tleave = groupList.members.FindAll(x => x.type == 1);
  722. if (tleave.IsNotEmpty())
  723. {
  724. if (groupList.type.Equals("research")||groupList.type.Equals("yxtrain"))
  725. {
  726. change.tchleave.AddRange(tleave);
  727. }
  728. else
  729. {
  730. change.tmdleave.AddRange(tleave);
  731. }
  732. }
  733. var sleave = groupList.members.FindAll(x => x.type == 2);
  734. if (sleave.IsNotEmpty())
  735. {
  736. change.stuleave.AddRange(sleave);
  737. }
  738. change.listid = groupList.id;
  739. change.scope = groupList.scope;
  740. change.originCode = $"{code}";
  741. change.school = groupList.school;
  742. change.creatorId = groupList.creatorId;
  743. change.type = groupList.type;
  744. if (change.tmdleave.IsNotEmpty() || change.tchleave.IsNotEmpty() || change.stuleave.IsNotEmpty()) {
  745. var messageChange = new ServiceBusMessage(change.ToJsonString());
  746. messageChange.ApplicationProperties.Add("name", "GroupChange");
  747. var ActiveTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
  748. await _serviceBus.GetServiceBusClient().SendMessageAsync(ActiveTask, messageChange);
  749. }
  750. await client.GetContainer(Constant.TEAMModelOS, tbname).DeleteItemStreamAsync(id.ToString(), new PartitionKey(datacode));
  751. return Ok(new { id });
  752. }
  753. catch (Exception ex)
  754. {
  755. await _dingDing.SendBotMsg($"OS,{_option.Location},grouplist/delete-grouplist()\n{ex.Message}", GroupNames.醍摩豆服務運維群組);
  756. return Ok(new { error=400 });
  757. }
  758. }
  759. }
  760. }