ThirdService.cs 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285
  1. using Azure.Cosmos;
  2. using HTEXLib.COMM.Helpers;
  3. using Microsoft.Extensions.Configuration;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Text.Json;
  9. using System.Threading.Tasks;
  10. using TEAMModelOS.SDK.DI;
  11. using TEAMModelOS.SDK.Extension;
  12. using static TEAMModelOS.SDK.Models.Teacher;
  13. namespace TEAMModelOS.SDK.Models
  14. {
  15. public static class ThirdService
  16. {
  17. //自动加入学校,加入培训名单,并根据学科进行分组
  18. public static async Task<ScTeacher> GetScTeacher(ScBindData scBind, Teacher teacher, AzureStorageFactory _azureStorage, AzureCosmosFactory _azureCosmos, AzureServiceBusFactory _serviceBus, IConfiguration _configuration, DingDing _dingDing)
  19. {
  20. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  21. List<ScSchool> schools = await table.FindListByDict<ScSchool>(new Dictionary<string, object> { { "PartitionKey", "ScSchool" }, { "RowKey", scBind.sid } });
  22. List<ScTeacher> scTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" }, { "TID", scBind.userid }, { "RowKey", $"{scBind.pxid}" } });
  23. if (schools.IsNotEmpty())
  24. {
  25. ScSchool scSchool = schools[0];
  26. if (!string.IsNullOrEmpty(scSchool.schoolCode))
  27. {
  28. try
  29. {
  30. School school = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<School>(scSchool.schoolCode, new PartitionKey("Base"));
  31. if (school != null)
  32. {
  33. if (scTeachers.IsNotEmpty())
  34. {
  35. if (string.IsNullOrEmpty(scTeachers[0].tmdid))
  36. {
  37. scTeachers[0].tmdid = teacher.id;
  38. scTeachers[0].schoolCode = scSchool.schoolCode;
  39. scTeachers[0].areaId = school.areaId;
  40. await table.SaveOrUpdate<ScTeacher>(scTeachers[0]);
  41. }
  42. }
  43. var sc = teacher.schools.Find(x => x.schoolId.Equals(scSchool.schoolCode));
  44. if (sc != null)
  45. {
  46. if (string.IsNullOrEmpty(sc.status) || !sc.status.Equals("join"))
  47. {
  48. sc.status = "join";
  49. try
  50. {
  51. SchoolTeacher schoolTeacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemAsync<SchoolTeacher>(teacher.id, new PartitionKey($"Teacher-{school.id}"));
  52. if (schoolTeacher != null)
  53. {
  54. if (schoolTeacher.roles.IsEmpty() || !schoolTeacher.roles.Contains("teacher"))
  55. {
  56. schoolTeacher.roles = new List<string> { "teacher" };
  57. }
  58. schoolTeacher.status = "join";
  59. schoolTeacher.pk = "Teacher";
  60. schoolTeacher.name = teacher.name;
  61. schoolTeacher.picture = teacher.picture;
  62. schoolTeacher.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  63. schoolTeacher.ttl = -1;
  64. schoolTeacher.permissions = schoolTeacher.permissions.IsNotEmpty() ? schoolTeacher.permissions : new List<string>();
  65. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").UpsertItemAsync(schoolTeacher);
  66. }
  67. }
  68. catch (CosmosException)
  69. {
  70. SchoolTeacher schoolTeacher = new SchoolTeacher
  71. {
  72. id = teacher.id,
  73. code = $"Teacher-{school.id}",
  74. roles = new List<string> { "teacher" },
  75. permissions = new List<string>(),
  76. pk = "Teacher",
  77. name = teacher.name,
  78. picture = teacher.picture,
  79. status = "join",
  80. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
  81. ttl = -1
  82. };
  83. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").UpsertItemAsync(schoolTeacher);
  84. }
  85. }
  86. }
  87. else
  88. {
  89. teacher.schools.Add(new Teacher.TeacherSchool { schoolId = school.id, name = school.name, areaId = school.areaId, picture = school.picture, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(), status = "join" });
  90. SchoolTeacher schoolTeacher = new SchoolTeacher
  91. {
  92. id = teacher.id,
  93. code = $"Teacher-{school.id}",
  94. roles = new List<string> { "teacher" },
  95. permissions = new List<string>(),
  96. pk = "Teacher",
  97. name = teacher.name,
  98. picture = teacher.picture,
  99. status = "join",
  100. createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
  101. };
  102. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").UpsertItemAsync(schoolTeacher);
  103. }
  104. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync(teacher, teacher.id, new PartitionKey("Base"));
  105. //处理培训名单
  106. StringBuilder queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
  107. List<GroupList> yxtrain = new List<GroupList>();
  108. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: queryText.ToString(),
  109. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{scSchool.schoolCode}") }))
  110. {
  111. yxtrain.Add(item);
  112. }
  113. if (yxtrain.IsNotEmpty())
  114. {
  115. string groupName = null;
  116. string groupId = Guid.NewGuid().ToString();
  117. if (scTeachers.IsNotEmpty())
  118. {
  119. groupName = scTeachers[0].TeacherXK;
  120. if (!string.IsNullOrEmpty(groupName))
  121. {
  122. var mebers = yxtrain.SelectMany(x => x.members).Where(y => !string.IsNullOrEmpty(y.groupName) && y.groupName.Equals(groupName));
  123. if (mebers != null && mebers.Count() > 0)
  124. {
  125. groupId = mebers.First().groupId;
  126. }
  127. }
  128. else { groupId = null; }
  129. }
  130. else { groupId = null; }
  131. var meber = yxtrain.SelectMany(x => x.members).Where(y => y.id.Equals(teacher.id));
  132. //不在研修名单
  133. if (meber == null || !meber.Any())
  134. {
  135. yxtrain[0].members.Add(new Member { id = teacher.id, type = 1, groupId = groupId, groupName = groupName });
  136. await GroupListService.UpsertList(yxtrain[0], _azureCosmos, _configuration, _serviceBus);
  137. }
  138. else
  139. {
  140. if (string.IsNullOrEmpty(meber.First().groupId) || string.IsNullOrEmpty(meber.First().groupName))
  141. {
  142. meber.ToList().ForEach(x => { x.groupId = groupId; x.groupName = groupName; });
  143. await GroupListService.UpsertList(yxtrain[0], _azureCosmos, _configuration, _serviceBus);
  144. }
  145. }
  146. }
  147. else
  148. {
  149. string groupName = null;
  150. if (scTeachers.IsNotEmpty())
  151. {
  152. groupName = scTeachers[0].TeacherXK;
  153. }
  154. string groupId = null;
  155. if (!string.IsNullOrEmpty(groupName))
  156. {
  157. groupId = Guid.NewGuid().ToString();
  158. }
  159. GroupList groupList = new()
  160. {
  161. id = Guid.NewGuid().ToString(),
  162. code = $"GroupList-{scSchool.schoolCode}",
  163. creatorId = teacher.id,
  164. type = "yxtrain",
  165. year = DateTimeOffset.UtcNow.Year,
  166. members = new List<Member> { new Member { id = teacher.id, type = 1, groupId = groupId, groupName = groupName } },
  167. scope = "school",
  168. school = scSchool.schoolCode,
  169. name = "研修名单",
  170. pk = "GroupList",
  171. ttl = -1
  172. };
  173. await GroupListService.UpsertList(groupList, _azureCosmos, _configuration, _serviceBus);
  174. }
  175. }
  176. }
  177. catch (Exception ex)
  178. {
  179. await _dingDing.SendBotMsg($"OS\n自动加入学校,加入研修名单出现异常:{ex.StackTrace},{ex.Message}GetScTeacher", GroupNames.成都开发測試群組);
  180. }
  181. }
  182. }
  183. return null;
  184. }
  185. public static async Task<(string accessConfig, Area area, AreaSetting setting)> GetAccessConfig(CosmosClient client, string standard)
  186. {
  187. Area area = null;
  188. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Normal").
  189. GetItemQueryIterator<Area>($"select value(c) from c where c.standard='{standard}'", requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base-Area") }))
  190. {
  191. area = item;
  192. break;
  193. }
  194. AreaSetting setting = null;
  195. if (area != null)
  196. {
  197. try
  198. {
  199. setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(area.id, new PartitionKey("AreaSetting"));
  200. }
  201. catch (CosmosException)
  202. {
  203. setting = null;
  204. }
  205. }
  206. if (setting == null || string.IsNullOrEmpty(setting.accessConfig))
  207. {
  208. return (null, null, null);
  209. }
  210. else
  211. {
  212. return (setting.accessConfig, area, setting);
  213. }
  214. }
  215. public static async Task<List<Ability>> GetDiagnosisList(CosmosClient client, string standard, DingDing dingDing, AreaSetting setting, HttpTrigger httpTrigger, Teacher teacher, TEAMModelOS.Models.Option _option, AzureStorageFactory _azureStorage)
  216. {
  217. List<string> abilityNos = new();
  218. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  219. setting.accessConfig.ToObject<JsonElement>().TryGetProperty("config", out JsonElement _config);
  220. if ($"{_config}".Equals("scsyxpt"))
  221. {
  222. var binds = teacher.binds.FindAll(x => x.type.Equals("scsyxpt"));
  223. var datas = binds.SelectMany(x => x.data).Where(y => y.Contains("scsyxpt"));
  224. HashSet<string> pxids = new();
  225. if (datas != null)
  226. {
  227. datas.ToList().ForEach(x =>
  228. {
  229. var data = x.ToObject<ScBindData>();
  230. if (!string.IsNullOrEmpty(data?.pxid))
  231. {
  232. pxids.Add(data.pxid);
  233. }
  234. });
  235. }
  236. foreach (var pxid in pxids)
  237. {
  238. List<ScTeacher> teachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" }, { "PXID", pxid } });
  239. Dictionary<string, object> dict = new();
  240. if (teachers.IsNotEmpty())
  241. {
  242. dict = new Dictionary<string, object>() { { "accessConfig", setting.accessConfig }, { "pxid", pxid }, { "areaId", setting.id }, { "schoolCode", teachers[0].schoolCode } };
  243. }
  244. else
  245. {
  246. dict = new Dictionary<string, object>() { { "accessConfig", setting.accessConfig }, { "pxid", pxid }, { "areaId", setting.id } };
  247. }
  248. (int status, string json) = await httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetDiagnosisListByProject_V2");
  249. if (status == 200)
  250. {
  251. List<string> nos = json.ToObject<List<string>>();
  252. if (nos.IsNotEmpty())
  253. {
  254. abilityNos.AddRange(nos);
  255. }
  256. }
  257. }
  258. }
  259. //获取能力点
  260. List<Ability> abilities = null;
  261. if (abilityNos.IsNotEmpty())
  262. {
  263. abilities = new List<Ability>();
  264. StringBuilder sql = new StringBuilder($"select value(c) from c where c.no in ({string.Join(",", abilityNos.Select(x => $"'{x}'"))})");
  265. await foreach (var item in client.GetContainer("TEAMModelOS", "Normal")
  266. .GetItemQueryIterator<Ability>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{standard}") }))
  267. {
  268. abilities.Add(item);
  269. }
  270. }
  271. return abilities;
  272. }
  273. }
  274. }