ScsYxptApis.cs 58 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018
  1. using Azure.Cosmos;
  2. using HTEXLib.COMM.Helpers;
  3. using Microsoft.Azure.Functions.Worker;
  4. using Microsoft.Azure.Functions.Worker.Http;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.IO;
  8. using System.Linq;
  9. using System.Net;
  10. using System.Text;
  11. using System.Text.Json;
  12. using System.Threading.Tasks;
  13. using TEAMModelOS.SDK;
  14. using TEAMModelOS.SDK.DI;
  15. using TEAMModelOS.SDK.Extension;
  16. using TEAMModelOS.SDK.Models;
  17. namespace TEAMModelOS.FunctionV4.HttpTrigger
  18. {
  19. public class ScsYxptApis
  20. {
  21. private readonly AzureCosmosFactory _azureCosmos;
  22. private readonly DingDing _dingDing;
  23. private readonly AzureStorageFactory _azureStorage;
  24. private readonly AzureRedisFactory _azureRedis;
  25. private readonly ThirdApisService _thirdApisService;
  26. public static string Code { get; set; }
  27. public static Dictionary<string, object> parameterMap = null;
  28. public ScsYxptApis(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, ThirdApisService thirdApisService
  29. , AzureRedisFactory azureRedis)
  30. {
  31. _azureCosmos = azureCosmos;
  32. _dingDing = dingDing;
  33. _azureStorage = azureStorage;
  34. _azureRedis = azureRedis;
  35. _thirdApisService = thirdApisService;
  36. }
  37. /// <summary>
  38. /// 5.3.1.1获取项目列表
  39. /// </summary>
  40. /// <param name="req"></param>
  41. /// <param name="log"></param>
  42. /// <returns></returns>
  43. [Function("GetProjectInfoByTrainComIDV2")]
  44. public async Task<HttpResponseData> GetProjectInfoByTrainComIDV2([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  45. {
  46. var response = req.CreateResponse(HttpStatusCode.OK);
  47. List<ScProject> projects = new List<ScProject>();
  48. string data = await new StreamReader(req.Body).ReadToEndAsync();
  49. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  50. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  51. string areaId = null;
  52. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  53. {
  54. areaId = $"{_areaId}";
  55. }
  56. Code = "GetProjectInfoByTrainComID";
  57. parameterMap = new Dictionary<string, object>();
  58. parameterMap.Add("TrainComID", config.trainComID);
  59. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.1获取项目列表" };
  60. try
  61. {
  62. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  63. if (result.result)
  64. {
  65. projects = result.content.ToObject<List<ScProject>>();
  66. }
  67. else
  68. {
  69. }
  70. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  71. return response;
  72. }
  73. catch (Exception ex)
  74. {
  75. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetProjectInfoByTrainComID\n{ex.Message}\n{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  76. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  77. return response;
  78. }
  79. }
  80. /// <summary>
  81. /// 5.3.1.1获取项目列表
  82. /// </summary>
  83. /// <param name="req"></param>
  84. /// <param name="log"></param>
  85. /// <returns></returns>
  86. [Function("GetProjectInfoByTrainComID")]
  87. public async Task<HttpResponseData> GetProjectInfoByTrainComID([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  88. {
  89. var response = req.CreateResponse(HttpStatusCode.OK);
  90. List<ScProject> projects = new List<ScProject>();
  91. string data = await new StreamReader(req.Body).ReadToEndAsync();
  92. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  93. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  94. string areaId = null;
  95. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  96. {
  97. areaId = $"{_areaId}";
  98. }
  99. Code = "GetProjectInfoByTrainComID";
  100. parameterMap = new Dictionary<string, object>();
  101. parameterMap.Add("TrainComID", config.trainComID);
  102. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.1获取项目列表" };
  103. try
  104. {
  105. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  106. if (result.result)
  107. {
  108. projects = result.content.ToObject<List<ScProject>>();
  109. }
  110. else
  111. {
  112. }
  113. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  114. return response;
  115. }
  116. catch (Exception ex)
  117. {
  118. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetProjectInfoByTrainComID\n{ex.Message}\n{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  119. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  120. return response;
  121. }
  122. }
  123. /// <summary>
  124. /// 5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表
  125. /// </summary>
  126. /// <param name="req"></param>
  127. /// <param name="log"></param>
  128. /// <returns></returns>
  129. [Function("GetSchoolList")]
  130. public async Task<HttpResponseData> GetSchoolList([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  131. {
  132. var response = req.CreateResponse(HttpStatusCode.OK);
  133. List<ScSchool> scSchools = new List<ScSchool>();
  134. string data = await new StreamReader(req.Body).ReadToEndAsync();
  135. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  136. string areaId = null;
  137. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  138. {
  139. areaId = $"{_areaId}";
  140. }
  141. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  142. Code = "GetSchoolList";
  143. parameterMap = new Dictionary<string, object>();
  144. parameterMap.Add("TrainComID", config.trainComID);
  145. List<ScsResult> results = new List<ScsResult>();
  146. try
  147. {
  148. if (config.p.IsNotEmpty())
  149. {
  150. foreach (var ps in config.p)
  151. {
  152. parameterMap["ProjectID"] = ps.pd;
  153. parameterMap["ProjectItemID"] = ps.pid;
  154. ScsResult result = new ScsResult { bizcode = Code, title = " 5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表" };
  155. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  156. if (result.result)
  157. {
  158. List<ScSchool> schools = result.content.ToObject<List<ScSchool>>();
  159. if (schools.IsNotEmpty())
  160. {
  161. schools.ForEach(x => { x.ProjectID = int.Parse(ps.pd); x.ProjectItemID = int.Parse(ps.pid); });
  162. scSchools.AddRange(schools);
  163. }
  164. }
  165. results.Add(result);
  166. }
  167. }
  168. await response.WriteAsJsonAsync(new { data = scSchools.ToJsonString() });
  169. return response;
  170. }
  171. catch (Exception ex)
  172. {
  173. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetSchoolList\n{ex.Message}\n{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  174. await response.WriteAsJsonAsync(new { data = scSchools.ToJsonString() });
  175. return response;
  176. }
  177. }
  178. /// <summary>
  179. /// 5.3.1.2获取学员名单
  180. /// </summary>
  181. /// <param name="req"></param>
  182. /// <param name="log"></param>
  183. /// <returns></returns>
  184. [Function("GetTeachersListByProject")]
  185. public async Task<HttpResponseData> GetTeachersListByProject([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  186. {
  187. var response = req.CreateResponse(HttpStatusCode.OK);
  188. List<ScTeacher> scTeachers = new List<ScTeacher>();
  189. string data = await new StreamReader(req.Body).ReadToEndAsync();
  190. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  191. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  192. string areaId = null;
  193. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  194. {
  195. areaId = $"{_areaId}";
  196. }
  197. Code = "GetTeachersListByProject";
  198. parameterMap = new Dictionary<string, object>();
  199. parameterMap.Add("TrainComID", config.trainComID);
  200. List<ScsResult> results = new List<ScsResult>();
  201. try
  202. {
  203. if (config.p.IsNotEmpty())
  204. {
  205. foreach (var ps in config.p)
  206. {
  207. parameterMap["ProjectID"] = ps.pd;
  208. parameterMap["ProjectItemID"] = ps.pid;
  209. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.2获取学员名单" };
  210. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  211. if (result.result)
  212. {
  213. List<ScTeacher> teachers = result.content.ToObject<List<ScTeacher>>();
  214. if (teachers.IsNotEmpty())
  215. {
  216. scTeachers.AddRange(teachers);
  217. }
  218. }
  219. results.Add(result);
  220. }
  221. }
  222. await response.WriteAsJsonAsync(new { data = scTeachers.ToJsonString() });
  223. return response;
  224. }
  225. catch (Exception ex)
  226. {
  227. await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetTeachersListByProject\n{ex.Message}\n{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  228. await response.WriteAsJsonAsync(new { data = scTeachers.ToJsonString() });
  229. return response;
  230. }
  231. }
  232. /// <summary>
  233. /// 5.3.1.20获取学校设置的可选能力点
  234. /// </summary>
  235. /// <param name="req"></param>
  236. /// <param name="log"></param>
  237. /// <returns></returns>
  238. [Function("GetSchoolDiagnosis")]
  239. public async Task<HttpResponseData> GetSchoolDiagnosis([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  240. {
  241. var response = req.CreateResponse(HttpStatusCode.OK);
  242. List<ScsProjectDiagnosis> projects = new List<ScsProjectDiagnosis>();
  243. string data = await new StreamReader(req.Body).ReadToEndAsync();
  244. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  245. JsonElement schoolCode = data.ToObject<JsonElement>().GetProperty("schoolCode");
  246. string areaId = null;
  247. if(data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  248. {
  249. areaId = $"{_areaId}";
  250. }
  251. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  252. Code = "GetSchoolDiagnosis";
  253. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  254. parameterMap = new Dictionary<string, object>();
  255. parameterMap.Add("TrainComID", config.trainComID);
  256. List<ScsResult> results = new List<ScsResult>();
  257. try
  258. {
  259. if (config.p.IsNotEmpty())
  260. {
  261. foreach (var ps in config.p)
  262. {
  263. parameterMap["ProjectID"] = ps.pd;
  264. parameterMap["ProjectItemID"] = ps.pid;
  265. parameterMap["SchoolID"] = $"{schoolCode}";
  266. parameterMap["School"] = $"{schoolCode}";
  267. ScsResult result = new ScsResult { bizcode = Code, title = " 5.3.1.20获取学校设置的可选能力点" };
  268. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  269. if (result.result)
  270. {
  271. List<ScPDiagnosis> diagnoses = result.content.ToObject<List<ScPDiagnosis>>();
  272. if (diagnoses.IsNotEmpty())
  273. {
  274. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = diagnoses, });
  275. await table.SaveOrUpdate<ScProjectDiagnosis>(new ScProjectDiagnosis {schoolCode=$"{schoolCode}",areaId= areaId,
  276. ProjectID=int.Parse(ps.pd),
  277. ProjectItemID=int.Parse(ps.pid),
  278. RowKey = $"{ps.pid}-{schoolCode}", PartitionKey = "ScSchoolDiagnosis", abilityNos = diagnoses.ToJsonString() });
  279. }
  280. }
  281. else
  282. {
  283. List<ScProjectDiagnosis> teacherDiagnoses = await table.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScSchoolDiagnosis" }, { "RowKey", $"{ps.pid}-{schoolCode}" } });
  284. if (teacherDiagnoses.IsNotEmpty())
  285. {
  286. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });
  287. }
  288. }
  289. results.Add(result);
  290. }
  291. }
  292. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  293. return response;
  294. }
  295. catch (Exception ex)
  296. {
  297. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetSchoolDiagnosis\n{ex.Message}\n{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  298. if (config.p.IsNotEmpty())
  299. {
  300. foreach (var ps in config.p)
  301. {
  302. List<ScProjectDiagnosis> teacherDiagnoses = await table.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScSchoolDiagnosis" }, { "RowKey", $"{ps.pid}-{schoolCode}" } });
  303. if (teacherDiagnoses.IsNotEmpty())
  304. {
  305. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });
  306. }
  307. }
  308. }
  309. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  310. return response;
  311. }
  312. }
  313. /// <summary>
  314. /// 5.3.1.19获取项目设置的可选能力点
  315. /// </summary>
  316. /// <param name="req"></param>
  317. /// <param name="log"></param>
  318. /// <returns></returns>
  319. [Function("GetProjectDiagnosis")]
  320. public async Task<HttpResponseData> GetProjectDiagnosis([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  321. {
  322. var response = req.CreateResponse(HttpStatusCode.OK);
  323. List<ScsProjectDiagnosis> projects = new List<ScsProjectDiagnosis>();
  324. string data = await new StreamReader(req.Body).ReadToEndAsync();
  325. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  326. string areaId = null;
  327. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  328. {
  329. areaId = $"{_areaId}";
  330. }
  331. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  332. Code = "GetProjectDiagnosis";
  333. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  334. parameterMap = new Dictionary<string, object>();
  335. parameterMap.Add("TrainComID", config.trainComID);
  336. List<ScsResult> results = new List<ScsResult>();
  337. try
  338. {
  339. if (config.p.IsNotEmpty())
  340. {
  341. foreach (var ps in config.p)
  342. {
  343. parameterMap["ProjectID"] = ps.pd;
  344. parameterMap["ProjectItemID"] = ps.pid;
  345. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.19获取项目设置的可选能力点" };
  346. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  347. if (result.result)
  348. {
  349. List<ScPDiagnosis> diagnoses = result.content.ToObject<List<ScPDiagnosis>>();
  350. if (diagnoses.IsNotEmpty())
  351. {
  352. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = diagnoses });
  353. await table.SaveOrUpdate<ScProjectDiagnosis>(new ScProjectDiagnosis { areaId=areaId, RowKey = $"{ps.pid}", PartitionKey = "ScProjectDiagnosis", abilityNos = diagnoses.ToJsonString() });
  354. }
  355. }
  356. else
  357. {
  358. List<ScProjectDiagnosis> teacherDiagnoses = await table.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScProjectDiagnosis" }, { "RowKey", $"{ps.pid}" } });
  359. if (teacherDiagnoses.IsNotEmpty())
  360. {
  361. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });
  362. }
  363. }
  364. results.Add(result);
  365. }
  366. }
  367. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  368. return response;
  369. }
  370. catch (Exception ex)
  371. {
  372. if (config.p.IsNotEmpty())
  373. {
  374. foreach (var ps in config.p)
  375. {
  376. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetProjectDiagnosis\n{ex.Message}\n{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  377. List<ScProjectDiagnosis> teacherDiagnoses = await table.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScProjectDiagnosis" }, { "RowKey", $"{ps.pid}" } });
  378. if (teacherDiagnoses.IsNotEmpty())
  379. {
  380. projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });
  381. }
  382. }
  383. }
  384. await response.WriteAsJsonAsync(new { data = projects.ToJsonString() });
  385. return response;
  386. }
  387. }
  388. /// <summary>
  389. /// 5.3.1.3通过项目编号获取学员测评能力项V2
  390. /// </summary>
  391. /// <param name="req"></param>
  392. /// <param name="log"></param>
  393. /// <returns></returns>
  394. [Function("GetDiagnosisListByProject_V2")]
  395. public async Task<HttpResponseData> GetDiagnosisListByProject_V2([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  396. {
  397. var response = req.CreateResponse(HttpStatusCode.OK);
  398. List<string> abilityNos = new List<string>();
  399. string data = await new StreamReader(req.Body).ReadToEndAsync();
  400. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  401. string areaId = null;
  402. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  403. {
  404. areaId = $"{_areaId}";
  405. }
  406. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  407. JsonElement pxid = data.ToObject<JsonElement>().GetProperty("pxid");
  408. JsonElement schoolCode = data.ToObject<JsonElement>().GetProperty("schoolCode");
  409. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  410. Code = "GetDiagnosisListByProject_V2";
  411. parameterMap = new Dictionary<string, object>();
  412. parameterMap.Add("TrainComID", config.trainComID);
  413. parameterMap.Add("PXID", pxid);
  414. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.3通过项目编号获取学员测评能力项V2" };
  415. try
  416. {
  417. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  418. if (result.result)
  419. {
  420. List<ScDiagnosis> diagnoses = result.content.ToObject<List<ScDiagnosis>>();
  421. if (diagnoses != null)
  422. {
  423. abilityNos = diagnoses.Select(x => x.DiagnosisDicNum).ToList();
  424. }
  425. if (abilityNos.IsNotEmpty())
  426. {
  427. await table.SaveOrUpdate<ScTeacherDiagnosis>(new ScTeacherDiagnosis {areaId = areaId,schoolCode=$"{schoolCode}", RowKey = $"{pxid}", PartitionKey = "ScTeacherDiagnosis", abilityNos = abilityNos.ToJsonString() });
  428. }
  429. }
  430. else
  431. {
  432. List<ScTeacherDiagnosis> teacherDiagnoses = await table.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" }, { "RowKey", $"{pxid}" } });
  433. if (teacherDiagnoses.IsNotEmpty())
  434. {
  435. abilityNos = teacherDiagnoses[0].abilityNos.ToObject<List<string>>();
  436. }
  437. }
  438. await response.WriteAsJsonAsync(new { data = abilityNos.ToJsonString() });
  439. return response;
  440. }
  441. catch (Exception ex)
  442. {
  443. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:getDiagnosisListByProject_V2\n{ex.Message}\n{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  444. List<ScTeacherDiagnosis> teacherDiagnoses = await table.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" }, { "RowKey", $"{pxid}" } });
  445. if (teacherDiagnoses.IsNotEmpty())
  446. {
  447. abilityNos = teacherDiagnoses[0].abilityNos.ToObject<List<string>>();
  448. }
  449. await response.WriteAsJsonAsync(new { data = abilityNos.ToJsonString() });
  450. return response;
  451. }
  452. }
  453. /// <summary>
  454. /// 5.3.1.11获取跳转学员信息,用于sso单点,后端验证。
  455. /// </summary>
  456. /// <param name="req"></param>
  457. /// <param name="log"></param>
  458. /// <returns></returns>
  459. [Function("GetSingleTeacherByProject")]
  460. public async Task<HttpResponseData> GetSingleTeacherByProject([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  461. {
  462. var response = req.CreateResponse(HttpStatusCode.OK);
  463. string teacher = null;
  464. string data = await new StreamReader(req.Body).ReadToEndAsync();
  465. JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  466. JsonElement pxid = data.ToObject<JsonElement>().GetProperty("pxid");
  467. JsonElement tid = data.ToObject<JsonElement>().GetProperty("tid");
  468. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  469. string areaId = null;
  470. if (data.ToObject<JsonElement>().TryGetProperty("areaId", out JsonElement _areaId))
  471. {
  472. areaId = $"{_areaId}";
  473. }
  474. Code = "GetSingleTeacherByProject";
  475. parameterMap = new Dictionary<string, object>();
  476. parameterMap.Add("TrainComID", config.trainComID);
  477. parameterMap.Add("Pxid", $"{pxid}");
  478. parameterMap.Add("Tid", $"{tid}");
  479. ScsResult result = new ScsResult { bizcode = Code, title = "5.3.1.11获取跳转学员信息,用于sso单点,后端验证。" };
  480. try
  481. {
  482. ///{“result”:true,”reason”:null,”content”:”{“PXID”:””,”TID”:””,”TeacherName”:””,”ProjectTitle”:””,”ProjectItemTitle”:””,”CityName”:””,
  483. ///”DisName”:””,”SchoolName”:””,”Sex”:””,”PXXK”:””,”PXXD”:””,”TeacherXK”:””,”TeacherXD”:””,”Email”:””}”,”pagecount”:1}
  484. result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
  485. if (result.result)
  486. {
  487. teacher = result.content;
  488. }
  489. await response.WriteAsJsonAsync(new { data = teacher });
  490. return response;
  491. }
  492. catch (Exception ex)
  493. {
  494. //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")},IES5.ScApisService:GetSingleTeacherByProject\n{ex.Message}\n{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.醍摩豆服務運維群組);
  495. await response.WriteAsJsonAsync(new { data = teacher });
  496. return response;
  497. }
  498. }
  499. /// <summary>
  500. /// 数据推送接口
  501. /// </summary>
  502. /// <param name="req"></param>
  503. /// <param name="log"></param>
  504. /// <returns></returns>
  505. [Function("SchoolDataPush")]
  506. public async Task<HttpResponseData> SchoolDataPush([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
  507. {
  508. var response = req.CreateResponse(HttpStatusCode.OK);
  509. var client = _azureCosmos.GetCosmosClient();
  510. string data = await new StreamReader(req.Body).ReadToEndAsync();
  511. JsonElement areaIdJson = data.ToObject<JsonElement>().GetProperty("areaId");
  512. AreaSetting areaSetting= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemAsync<AreaSetting>($"{areaIdJson}", new PartitionKey("AreaSetting"));
  513. ScAccessConfig config = areaSetting.accessConfig.ToObject<ScAccessConfig>();
  514. JsonElement school = data.ToObject<JsonElement>().GetProperty("school");
  515. List<string> pushTeachers = data.ToObject<JsonElement>().GetProperty("pushTeachers").ToObject<List<string>>();
  516. StringBuilder queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
  517. List<GroupList> yxtrain = new List<GroupList>();
  518. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: queryText.ToString(),
  519. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
  520. {
  521. yxtrain.Add(item);
  522. }
  523. List<TeacherTrain> trains = new List<TeacherTrain>();
  524. var members = yxtrain.SelectMany(x => x.members).ToList();
  525. //指定推送一部分的教师
  526. if (pushTeachers.IsNotEmpty()) {
  527. members= members.FindAll(x => pushTeachers.Contains(x.id));
  528. }
  529. if (members.IsNotEmpty())
  530. {
  531. queryText = new StringBuilder($"SELECT distinct value(c) FROM c where 1=1 " +
  532. $"and c.id in ({string.Join(",", members.Select(x => $"'{x.id}'"))}) ");
  533. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<TeacherTrain>(queryText: queryText.ToString(),
  534. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"TeacherTrain-{school}") }))
  535. {
  536. trains.Add(item);
  537. }
  538. }
  539. //string sql = $" SELECT value(c) FROM c join a in c.binds where ARRAY_LENGTH(c.binds)>0 and a.type='{config.config}' ";
  540. //List<Teacher> teachers = new List<Teacher>();
  541. //await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
  542. // requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  543. //{
  544. // teachers.Add(item);
  545. //}
  546. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  547. List<ScTeacher> scTeachers= await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" },{ "schoolCode",$"{school}" } });
  548. List<ScTeacherDiagnosis> scTeacherDiagnoses = await table.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" }, { "schoolCode", $"{school}" } });
  549. List<KeyValuePair<TeacherTrain, string>> trainsNO = new List<KeyValuePair<TeacherTrain, string>>();
  550. List<ScsResult> results = new List<ScsResult>();
  551. Dictionary<string, Dictionary<string, object>> pushDatas = new Dictionary<string, Dictionary<string, object>>();
  552. int pages = (trains.Count + 19) / 20; //pages = (total + max -1) / max;
  553. for (int i = 0; i < pages; i++) {
  554. List<TeacherTrain> lists = trains.Skip((i) * 20).Take(20).ToList();
  555. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  556. List<TeacherTrain> trains53112OK = new List<TeacherTrain>();
  557. ScsResult UpdateTeacherListSituation = null;
  558. Dictionary<string, object> parameterContent53112 = new Dictionary<string, object>();
  559. List<Dictionary<string, object>> list53112 = new List<Dictionary<string, object>>();
  560. parameterContent53112.Add("TrainComID", config.trainComID);
  561. parameterContent53112.Add("List", list53112);
  562. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis 300条限制
  563. List<TeacherTrain> trains53113OK = new List<TeacherTrain>();
  564. ScsResult UpdateTeacherListDiagnosis = null;
  565. Dictionary<string, object> parameterContent53113 = new Dictionary<string, object>();
  566. List<Dictionary<string, object>> list53113 = new List<Dictionary<string, object>>();
  567. parameterContent53113.Add("TrainComID", config.trainComID);
  568. parameterContent53113.Add("List", list53113);
  569. //5.3.1.17学员课堂实录批量回写-UploadKTSLList 300条限制
  570. List<TeacherTrain> trains53117OK = new List<TeacherTrain>();
  571. ScsResult UploadKTSLList = null;
  572. Dictionary<string, object> parameterContent53117 = new Dictionary<string, object>();
  573. List<Dictionary<string, object>> list53117 = new List<Dictionary<string, object>>();
  574. parameterContent53117.Add("TrainComID", config.trainComID);
  575. parameterContent53117.Add("List", list53117);
  576. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2 100条限制
  577. List<TeacherTrain> trains53122OK = new List<TeacherTrain>();
  578. ScsResult UploadSBTARPDFListV2 = null;
  579. Dictionary<string, object> parameterContent53122 = new Dictionary<string, object>();
  580. List<Dictionary<string, object>> list53122 = new List<Dictionary<string, object>>();
  581. parameterContent53122.Add("TrainComID", config.trainComID);
  582. parameterContent53122.Add("List", list53122);
  583. //装载数据
  584. foreach (var x in lists) {
  585. List<KeyValuePair<string, string>> msgs = new List<KeyValuePair<string, string>>();
  586. List<ScTeacher> teacher = scTeachers.FindAll(t => !string.IsNullOrWhiteSpace(t.tmdid) && t.tmdid.Equals(x.id));
  587. foreach (var t in teacher)
  588. {
  589. List<PushFail> fails = new List<PushFail>();
  590. Dictionary<string,object> pushData = new Dictionary<string, object>();
  591. string json = scTeacherDiagnoses.ToJsonString();
  592. ScTeacherDiagnosis diagnosis = scTeacherDiagnoses.Find(x => x.RowKey.Equals($"{t.PXID}"));
  593. (int t53112OK, List<KeyValuePair<string, string>> msgs53112) = check53112(x, msgs);
  594. (int t53113OK, List<KeyValuePair<string, string>> msgs53113, List<AbilitySub> abilitySubs) = await check53113(x, diagnosis, msgs);
  595. (int t53117OK, List<KeyValuePair<string, string>> msgs53117) = check53117(x, msgs);
  596. (int t53122OK, List<KeyValuePair<string, string>> msgs53122) = check53122(x, msgs);
  597. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  598. if (t53112OK == 1)
  599. {
  600. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  601. parameterMapData.Add("PXID", $"{t.PXID}");
  602. parameterMapData.Add("TID", $"{t.TID}");
  603. parameterMapData.Add("TeacherName", $"{t.TeacherName}");
  604. parameterMapData.Add("CourseHour", $"{x.totalTime}");
  605. parameterMapData.Add("ResearchText", $"{x.summary}");
  606. /// <summary>
  607. ///省上标准 最终结果 0未认定,1合格,2优秀,3不合格,4其他
  608. ///系统标准 -2 其他 -1 未认定,0不合格,1合格,2优秀
  609. /// </summary>
  610. string ComPassed = "0";
  611. switch (x.finalScore)
  612. {
  613. case -2:
  614. ComPassed = "4";
  615. break;
  616. case -1:
  617. ComPassed = "0";
  618. break;
  619. case 0:
  620. ComPassed = "3";
  621. break;
  622. case 1:
  623. ComPassed = "1";
  624. break;
  625. case 2:
  626. ComPassed = "2";
  627. break;
  628. default:
  629. ComPassed = "4";
  630. break;
  631. }
  632. parameterMapData.Add("ComPassed", ComPassed);//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  633. pushData.Add("success-UpdateTeacherListSituation", parameterMapData);
  634. list53112.Add(parameterMapData);
  635. }
  636. else
  637. {
  638. pushData.Add("fail-UpdateTeacherListSituation", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53112 });
  639. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53112 });
  640. }
  641. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
  642. if (t53113OK == 1)
  643. {
  644. List<Dictionary<string, object>> parameterMapDatas = new List<Dictionary<string, object>>();
  645. x.currency.teacherAilities.ForEach(a => {
  646. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  647. parameterMapData.Add("PXID", $"{t.PXID}");
  648. parameterMapData.Add("TID", $"{t.TID}");
  649. parameterMapData.Add("DiagnosisNum", $"{a.no}");
  650. //0"未认定", 1"合格", 2"优秀", 3"不合格"
  651. //系统 -1 未认定,0 不合格,1 合格,2 优秀
  652. string zpscore = "0";
  653. switch (a.zpscore)
  654. {
  655. case -1:
  656. zpscore = "0";
  657. break;
  658. case 0:
  659. zpscore = "3";
  660. break;
  661. case 1:
  662. zpscore = "1";
  663. break;
  664. case 2:
  665. zpscore = "2";
  666. break;
  667. default:
  668. zpscore = "0";
  669. break;
  670. }
  671. string hpscore = "0";
  672. switch (a.hpscore)
  673. {
  674. case -1:
  675. hpscore = "0";
  676. break;
  677. case 0:
  678. hpscore = "3";
  679. break;
  680. case 1:
  681. hpscore = "1";
  682. break;
  683. case 2:
  684. hpscore = "2";
  685. break;
  686. default:
  687. hpscore = "0";
  688. break;
  689. }
  690. string xzpresult = "0";
  691. switch (a.xzscore)
  692. {
  693. case -1:
  694. xzpresult = "0";
  695. break;
  696. case 0:
  697. xzpresult = "3";
  698. break;
  699. case 1:
  700. xzpresult = "1";
  701. break;
  702. case 2:
  703. xzpresult = "2";
  704. break;
  705. default:
  706. xzpresult = "0";
  707. break;
  708. }
  709. parameterMapData.Add("zpresult", zpscore);
  710. parameterMapData.Add("hpresult", hpscore);
  711. parameterMapData.Add("xzpresult", xzpresult);
  712. List<Dictionary<string, object>> pfiles = new List<Dictionary<string, object>>();
  713. parameterMapData.Add("pfiles", pfiles);
  714. AbilitySub abilitySub = abilitySubs.Find(sub => sub.id.Equals(a.id));
  715. if (abilitySub != null)
  716. {
  717. abilitySub.uploads.ForEach(upload => {
  718. upload.urls.ForEach(url => {
  719. Dictionary<string, object> pfileMap = new Dictionary<string, object>();
  720. pfileMap.Add("url", url.url);
  721. pfileMap.Add("fileName", url.name);
  722. pfileMap.Add("fileSize", url.size);
  723. pfileMap.Add("md5", url.hash);
  724. string fileext = url.url.Substring(url.url.LastIndexOf(".") > 0 ? url.url.LastIndexOf(".") + 1 : 0);
  725. pfileMap.Add("fileType", fileext);
  726. pfiles.Add(pfileMap);
  727. });
  728. });
  729. }
  730. list53113.Add(parameterMapData);
  731. parameterMapDatas.Add(parameterMapData);
  732. });
  733. pushData.Add("success-UpdateTeacherListDiagnosis", parameterMapDatas);
  734. }
  735. else
  736. {
  737. pushData.Add("fail-UpdateTeacherListDiagnosis", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53113 });
  738. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53113 });
  739. }
  740. //5.3.1.17学员课堂实录批量回写-UploadKTSLList
  741. if (t53117OK == 1)
  742. {
  743. List<Dictionary<string, object>> parameterMapDatas = new List<Dictionary<string, object>>();
  744. x.teacherClasses.ForEach(clss =>
  745. {
  746. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  747. parameterMapData.Add("PXID", $"{t.PXID}");
  748. parameterMapData.Add("TID", $"{t.TID}");
  749. parameterMapData.Add("url", clss.url);//添加访问授权
  750. parameterMapData.Add("url2", clss.url);
  751. parameterMapData.Add("fileName", clss.name);
  752. parameterMapData.Add("fileSize", clss.size);
  753. parameterMapData.Add("md5", clss.hash);
  754. string fileext = clss.url.Substring(clss.url.LastIndexOf(".") > 0 ? clss.url.LastIndexOf(".") + 1 : 0);
  755. parameterMapData.Add("fileType", fileext);
  756. list53117.Add(parameterMapData);
  757. parameterMapDatas.Add(parameterMapData);
  758. });
  759. pushData.Add("success-UploadKTSLList", parameterMapDatas);
  760. }
  761. else
  762. {
  763. pushData.Add("fail-UploadKTSLList", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53117 });
  764. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53117 });
  765. }
  766. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
  767. if (t53122OK == 1)
  768. {
  769. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  770. parameterMapData.Add("PXID", $"{t.PXID}");
  771. parameterMapData.Add("TID", $"{t.TID}");
  772. List<Dictionary<string, object>> files = new List<Dictionary<string, object>>();
  773. x.offlineRecords.ForEach(record => {
  774. if (!string.IsNullOrWhiteSpace(record.url)) {
  775. Dictionary<string, object> fileMap = new Dictionary<string, object>();
  776. fileMap.Add("url", record.url);
  777. fileMap.Add("fileName", record.name);
  778. fileMap.Add("fileSize", record.size);
  779. fileMap.Add("md5", record.hash);
  780. string fileext = record.url.Substring(record.url.LastIndexOf(".") > 0 ? record.url.LastIndexOf(".") + 1 : 0);
  781. fileMap.Add("fileType", fileext);
  782. files.Add(fileMap);
  783. }
  784. });
  785. parameterMapData.Add("files", files);
  786. list53122.Add(parameterMapData);
  787. pushData.Add("success-UploadSBTARPDFListV2", parameterMapData);
  788. }
  789. else
  790. {
  791. pushData.Add("fail-UploadSBTARPDFListV2", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53122 });
  792. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53122 });
  793. }
  794. pushDatas.Add(t.tmdid,pushData);
  795. }
  796. }
  797. //推送数据
  798. UpdateTeacherListSituation = await _thirdApisService.Post(config.url, "UpdateTeacherListSituation", config.passKey, config.privateKey, parameterContent53112);
  799. UpdateTeacherListSituation.bizcode = "UpdateTeacherListSituation";
  800. UpdateTeacherListSituation.title = "5.3.1.12学员培训基本情况批量回写";
  801. UpdateTeacherListDiagnosis = await _thirdApisService.Post(config.url, "UpdateTeacherListDiagnosis", config.passKey, config.privateKey, parameterContent53113);
  802. UpdateTeacherListDiagnosis.bizcode = "UpdateTeacherListDiagnosis";
  803. UpdateTeacherListDiagnosis.title = "5.3.1.13学员能力点测评结果批量回写";
  804. UploadKTSLList = await _thirdApisService.Post(config.url, "UploadKTSLList", config.passKey, config.privateKey, parameterContent53117);
  805. UploadKTSLList.bizcode = "UploadKTSLList";
  806. UploadKTSLList.title = "5.3.1.17学员课堂实录批量回写";
  807. UploadSBTARPDFListV2 = await _thirdApisService.Post(config.url, "UploadSBTARPDFListV2", config.passKey, config.privateKey, parameterContent53122);
  808. UploadSBTARPDFListV2.bizcode = "UploadSBTARPDFListV2";
  809. UploadSBTARPDFListV2.title = "5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写";
  810. results.Add(UpdateTeacherListSituation);
  811. results.Add(UpdateTeacherListDiagnosis);
  812. results.Add(UploadKTSLList);
  813. results.Add(UploadSBTARPDFListV2);
  814. }
  815. await response.WriteAsJsonAsync(new { data= new { results, pushDatas } });
  816. return response;
  817. }
  818. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
  819. public (int t53122OK, List<KeyValuePair<string, string>> msgs) check53122(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs) {
  820. int t53122OK = 1;
  821. if (teacherTrain.offlineRecords.Count<= 0)
  822. {
  823. msgs.Add(new KeyValuePair<string, string>("offlineRecord-count", $"文件个数为0"));
  824. }
  825. var hasUrl= teacherTrain.offlineRecords.Where(x => !string.IsNullOrWhiteSpace(x.url) && x.size > 0);
  826. if (!hasUrl.Any()) {
  827. msgs.Add(new KeyValuePair<string, string>("offlineRecord-url", $"需要上传的校本研修作业至少有一个。"));
  828. }
  829. //不需要检查每一个校本研修的文件记录。
  830. //teacherTrain.offlineRecords.ForEach(x => {
  831. // if (string.IsNullOrEmpty(x.url)) {
  832. // msgs.Add(new KeyValuePair<string, string>("offlineRecord-url", $"链接为空"));
  833. // }
  834. // if (x.size<=0)
  835. // {
  836. // msgs.Add(new KeyValuePair<string, string>("offlineRecord-size", $"文件大小"));
  837. // }
  838. //});
  839. return (t53122OK, msgs);
  840. }
  841. //5.3.1.17学员课堂实录批量回写-UploadKTSLList
  842. public (int t53117OK, List<KeyValuePair<string, string>> msgs) check53117(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs) {
  843. //校验 基本情况是否满足
  844. int t53117OK = 1;
  845. if (teacherTrain.classTime <= 0)
  846. {
  847. msgs.Add(new KeyValuePair<string, string>("classTime", $"未获得学时:{teacherTrain.classTime}"));
  848. t53117OK = 0;
  849. }
  850. if (teacherTrain.teacherClasses.Count() <= 0) {
  851. msgs.Add(new KeyValuePair<string, string>("teacherClasses", $"未上传课堂实录:{teacherTrain.teacherClasses.Count()}个视频"));
  852. t53117OK = 0;
  853. }
  854. teacherTrain.teacherClasses.ForEach(x =>{
  855. if (string.IsNullOrWhiteSpace(x.url)) {
  856. t53117OK = 0;
  857. msgs.Add(new KeyValuePair<string, string>("teacherClasses", $"课堂实录链接无效"));
  858. }
  859. });
  860. return (t53117OK, msgs);
  861. }
  862. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  863. public (int t53112OK, List<KeyValuePair<string, string>> msgs) check53112(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs)
  864. {
  865. //校验 基本情况是否满足
  866. int t53112OK = 1;
  867. if (teacherTrain.finalScore < 0)
  868. {
  869. //总体认定结果0、未认定 1、合格 2、优秀 3、不合格 4、其他
  870. msgs.Add(new KeyValuePair<string, string>("finalScore", $"最终评定结果参数:{teacherTrain.finalScore}"));
  871. t53112OK = 0;
  872. }
  873. //if (string.IsNullOrEmpty(teacherTrain.summary) || teacherTrain.summary.Length > 300)
  874. //{
  875. // string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
  876. // msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结:{msg}"));
  877. // t53112OK = 0;
  878. //}
  879. if (!string.IsNullOrEmpty(teacherTrain.summary) && teacherTrain.summary.Length > 300)
  880. {
  881. //string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
  882. msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结:字数超过300."));
  883. t53112OK = 0;
  884. }
  885. if (teacherTrain.totalTime <= 0)
  886. {
  887. msgs.Add(new KeyValuePair<string, string>("totalTime", $"未获得学时:{teacherTrain.totalTime}"));
  888. t53112OK = 0;
  889. }
  890. return (t53112OK, msgs);
  891. }
  892. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
  893. public async Task<(int t53113OK, List<KeyValuePair<string, string>> msgs, List<AbilitySub> abilitySubs)> check53113(TeacherTrain teacherTrain, ScTeacherDiagnosis diagnosis, List<KeyValuePair<string, string>> msgs)
  894. {
  895. //校验 基本情况是否满足
  896. int t53113OK = 1;
  897. List<AbilitySub> abilitySubs = new List<AbilitySub>();
  898. if (teacherTrain.currency.videoTime < 0)
  899. {
  900. msgs.Add(new KeyValuePair<string, string>("videoTime", $"视频学习时长:{teacherTrain.currency.videoTime}"));
  901. t53113OK = 0;
  902. }
  903. if (teacherTrain.currency.submitTime < 0)
  904. {
  905. msgs.Add(new KeyValuePair<string, string>("submitTime", $"认证材料学习:{teacherTrain.currency.submitTime}"));
  906. t53113OK = 0;
  907. }
  908. if (teacherTrain.currency.teacherAilities.Count <= 0 )
  909. {
  910. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"已学习能力点:0"));
  911. t53113OK = 0;
  912. }
  913. if (diagnosis != null)
  914. {
  915. if (!string.IsNullOrWhiteSpace(diagnosis.abilityNos))
  916. {
  917. List<string> nos = diagnosis.abilityNos.ToObject<List<string>>();
  918. if (nos.Count > 0 && teacherTrain.currency.teacherAilities.Count > 0)
  919. {
  920. var notin = nos.Except(teacherTrain.currency.teacherAilities.Select(x => x.no).Where(z=>!string.IsNullOrWhiteSpace(z)));
  921. if (notin.Any())
  922. {
  923. msgs.Add(new KeyValuePair<string, string>("diagnosisNos", $"省平台勾选的能力点编号为学习完成:省平台:{string.Join(",", nos.OrderBy(x => x))}" + $" ,已学习:{string.Join(",", teacherTrain.currency.teacherAilities.Select(x => x.no).OrderBy(x=>x))} "));
  924. t53113OK = 0;
  925. }
  926. else {
  927. string insql = "";
  928. if (teacherTrain.currency.teacherAilities.IsNotEmpty())
  929. {
  930. var abilites= teacherTrain.currency.teacherAilities.Where(c => !string.IsNullOrWhiteSpace(c.no) && nos.Contains(c.no));
  931. insql = $" where c.id in ({string.Join(",", abilites.Select(o => $"'{o.id}'"))})";
  932. }
  933. //认证材料
  934. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Teacher")
  935. .GetItemQueryIterator<AbilitySub>(queryText: $"select value(c) from c {insql}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilitySub-{teacherTrain.school}-{teacherTrain.id}") }))
  936. {
  937. abilitySubs.Add(item);
  938. }
  939. teacherTrain.currency.teacherAilities.ForEach(x => {
  940. var abilitySub = abilitySubs.Find(z => z.id.Equals(x.id));
  941. if (abilitySub == null || !abilitySub.uploads.Any())
  942. {
  943. t53113OK = 0;
  944. msgs.Add(new KeyValuePair<string, string>("uploads", $"未上传认证材料:{x.no},{x.name}"));
  945. }
  946. if (x.zpscore <= 0)
  947. {
  948. t53113OK = 0;
  949. msgs.Add(new KeyValuePair<string, string>("zpscore", $"认证材料,没有完成自评:{x.no},{x.name},{x.zpscore}"));
  950. }
  951. if (x.hpscore <= 0)
  952. {
  953. t53113OK = 0;
  954. msgs.Add(new KeyValuePair<string, string>("hpscore", $"认证材料,没有完成互评:{x.no},{x.name},{x.hpscore}"));
  955. }
  956. if (x.xzscore <= 0)
  957. {
  958. t53113OK = 0;
  959. msgs.Add(new KeyValuePair<string, string>("xzscore", $"认证材料,没有完成小组评:{x.no},{x.name},{x.xzscore}"));
  960. }
  961. });
  962. if (t53113OK != 1) {
  963. msgs.Add(new KeyValuePair<string, string>("diagnosisNos", $"省平台勾选的能力点编号为学习完成:省平台:{string.Join(",", nos.OrderBy(x=>x))}" + $" ,已学习:{string.Join(",", teacherTrain.currency.teacherAilities.Select(x => x.no).OrderBy(x => x))} "));
  964. }
  965. }
  966. }
  967. else {
  968. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  969. t53113OK = 0;
  970. }
  971. }
  972. else {
  973. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  974. t53113OK = 0;
  975. }
  976. }
  977. else {
  978. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  979. t53113OK = 0;
  980. }
  981. return (t53113OK, msgs, abilitySubs);
  982. }
  983. }
  984. }