ScsYxptApis.cs 58 KB

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