ScsYxptApis.cs 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017
  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 { code = 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}{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 { code = 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}{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 { code = 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}{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 { code = 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}{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 { code = 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}{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 { code = 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}{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 { code = 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}{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 { code = 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}{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 accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
  512. ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
  513. JsonElement school = data.ToObject<JsonElement>().GetProperty("school");
  514. List<string> pushTeachers = data.ToObject<JsonElement>().GetProperty("pushTeachers").ToObject<List<string>>();
  515. StringBuilder queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
  516. List<GroupList> yxtrain = new List<GroupList>();
  517. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: queryText.ToString(),
  518. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
  519. {
  520. yxtrain.Add(item);
  521. }
  522. List<TeacherTrain> trains = new List<TeacherTrain>();
  523. var members = yxtrain.SelectMany(x => x.members).ToList();
  524. //指定推送一部分的教师
  525. if (pushTeachers.IsNotEmpty()) {
  526. members= members.FindAll(x => pushTeachers.Contains(x.id));
  527. }
  528. if (members.IsNotEmpty())
  529. {
  530. queryText = new StringBuilder($"SELECT distinct value(c) FROM c where 1=1 " +
  531. $"and c.id in ({string.Join(",", members.Select(x => $"'{x.id}'"))}) ");
  532. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<TeacherTrain>(queryText: queryText.ToString(),
  533. requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"TeacherTrain-{school}") }))
  534. {
  535. trains.Add(item);
  536. }
  537. }
  538. //string sql = $" SELECT value(c) FROM c join a in c.binds where ARRAY_LENGTH(c.binds)>0 and a.type='{config.config}' ";
  539. //List<Teacher> teachers = new List<Teacher>();
  540. //await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
  541. // requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  542. //{
  543. // teachers.Add(item);
  544. //}
  545. var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
  546. List<ScTeacher> scTeachers= await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" },{ "schoolCode",$"{school}" } });
  547. List<ScTeacherDiagnosis> scTeacherDiagnoses = await table.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" }, { "schoolCode", $"{school}" } });
  548. List<KeyValuePair<TeacherTrain, string>> trainsNO = new List<KeyValuePair<TeacherTrain, string>>();
  549. List<ScsResult> results = new List<ScsResult>();
  550. Dictionary<string, Dictionary<string, object>> pushDatas = new Dictionary<string, Dictionary<string, object>>();
  551. int pages = (trains.Count + 19) / 20; //pages = (total + max -1) / max;
  552. for (int i = 0; i < pages; i++) {
  553. List<TeacherTrain> lists = trains.Skip((i) * 20).Take(20).ToList();
  554. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  555. List<TeacherTrain> trains53112OK = new List<TeacherTrain>();
  556. ScsResult UpdateTeacherListSituation = null;
  557. Dictionary<string, object> parameterContent53112 = new Dictionary<string, object>();
  558. List<Dictionary<string, object>> list53112 = new List<Dictionary<string, object>>();
  559. parameterContent53112.Add("TrainComID", config.trainComID);
  560. parameterContent53112.Add("List", list53112);
  561. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis 300条限制
  562. List<TeacherTrain> trains53113OK = new List<TeacherTrain>();
  563. ScsResult UpdateTeacherListDiagnosis = null;
  564. Dictionary<string, object> parameterContent53113 = new Dictionary<string, object>();
  565. List<Dictionary<string, object>> list53113 = new List<Dictionary<string, object>>();
  566. parameterContent53113.Add("TrainComID", config.trainComID);
  567. parameterContent53113.Add("List", list53113);
  568. //5.3.1.17学员课堂实录批量回写-UploadKTSLList 300条限制
  569. List<TeacherTrain> trains53117OK = new List<TeacherTrain>();
  570. ScsResult UploadKTSLList = null;
  571. Dictionary<string, object> parameterContent53117 = new Dictionary<string, object>();
  572. List<Dictionary<string, object>> list53117 = new List<Dictionary<string, object>>();
  573. parameterContent53117.Add("TrainComID", config.trainComID);
  574. parameterContent53117.Add("List", list53117);
  575. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2 100条限制
  576. List<TeacherTrain> trains53122OK = new List<TeacherTrain>();
  577. ScsResult UploadSBTARPDFListV2 = null;
  578. Dictionary<string, object> parameterContent53122 = new Dictionary<string, object>();
  579. List<Dictionary<string, object>> list53122 = new List<Dictionary<string, object>>();
  580. parameterContent53122.Add("TrainComID", config.trainComID);
  581. parameterContent53122.Add("List", list53122);
  582. //装载数据
  583. foreach (var x in lists) {
  584. List<KeyValuePair<string, string>> msgs = new List<KeyValuePair<string, string>>();
  585. List<ScTeacher> teacher = scTeachers.FindAll(t => !string.IsNullOrWhiteSpace(t.tmdid) && t.tmdid.Equals(x.id));
  586. foreach (var t in teacher)
  587. {
  588. List<PushFail> fails = new List<PushFail>();
  589. Dictionary<string,object> pushData = new Dictionary<string, object>();
  590. string json = scTeacherDiagnoses.ToJsonString();
  591. ScTeacherDiagnosis diagnosis = scTeacherDiagnoses.Find(x => x.RowKey.Equals($"{t.PXID}"));
  592. (int t53112OK, List<KeyValuePair<string, string>> msgs53112) = check53112(x, msgs);
  593. (int t53113OK, List<KeyValuePair<string, string>> msgs53113, List<AbilitySub> abilitySubs) = await check53113(x, diagnosis, msgs);
  594. (int t53117OK, List<KeyValuePair<string, string>> msgs53117) = check53117(x, msgs);
  595. (int t53122OK, List<KeyValuePair<string, string>> msgs53122) = check53122(x, msgs);
  596. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  597. if (t53112OK == 1)
  598. {
  599. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  600. parameterMapData.Add("PXID", $"{t.PXID}");
  601. parameterMapData.Add("TID", $"{t.TID}");
  602. parameterMapData.Add("TeacherName", $"{t.TeacherName}");
  603. parameterMapData.Add("CourseHour", $"{x.totalTime}");
  604. parameterMapData.Add("ResearchText", $"{x.summary}");
  605. /// <summary>
  606. ///省上标准 最终结果 0未认定,1合格,2优秀,3不合格,4其他
  607. ///系统标准 -2 其他 -1 未认定,0不合格,1合格,2优秀
  608. /// </summary>
  609. string ComPassed = "0";
  610. switch (x.finalScore)
  611. {
  612. case -2:
  613. ComPassed = "4";
  614. break;
  615. case -1:
  616. ComPassed = "0";
  617. break;
  618. case 0:
  619. ComPassed = "3";
  620. break;
  621. case 1:
  622. ComPassed = "1";
  623. break;
  624. case 2:
  625. ComPassed = "2";
  626. break;
  627. default:
  628. ComPassed = "4";
  629. break;
  630. }
  631. parameterMapData.Add("ComPassed", ComPassed);//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  632. pushData.Add("success-UpdateTeacherListSituation", parameterMapData);
  633. list53112.Add(parameterMapData);
  634. }
  635. else
  636. {
  637. pushData.Add("fail-UpdateTeacherListSituation", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53112 });
  638. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53112 });
  639. }
  640. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
  641. if (t53113OK == 1)
  642. {
  643. List<Dictionary<string, object>> parameterMapDatas = new List<Dictionary<string, object>>();
  644. x.currency.teacherAilities.ForEach(a => {
  645. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  646. parameterMapData.Add("PXID", $"{t.PXID}");
  647. parameterMapData.Add("TID", $"{t.TID}");
  648. parameterMapData.Add("DiagnosisNum", $"{a.no}");
  649. //0"未认定", 1"合格", 2"优秀", 3"不合格"
  650. //系统 -1 未认定,0 不合格,1 合格,2 优秀
  651. string zpscore = "0";
  652. switch (a.zpscore)
  653. {
  654. case -1:
  655. zpscore = "0";
  656. break;
  657. case 0:
  658. zpscore = "3";
  659. break;
  660. case 1:
  661. zpscore = "1";
  662. break;
  663. case 2:
  664. zpscore = "2";
  665. break;
  666. default:
  667. zpscore = "0";
  668. break;
  669. }
  670. string hpscore = "0";
  671. switch (a.hpscore)
  672. {
  673. case -1:
  674. hpscore = "0";
  675. break;
  676. case 0:
  677. hpscore = "3";
  678. break;
  679. case 1:
  680. hpscore = "1";
  681. break;
  682. case 2:
  683. hpscore = "2";
  684. break;
  685. default:
  686. hpscore = "0";
  687. break;
  688. }
  689. string xzpresult = "0";
  690. switch (a.xzscore)
  691. {
  692. case -1:
  693. xzpresult = "0";
  694. break;
  695. case 0:
  696. xzpresult = "3";
  697. break;
  698. case 1:
  699. xzpresult = "1";
  700. break;
  701. case 2:
  702. xzpresult = "2";
  703. break;
  704. default:
  705. xzpresult = "0";
  706. break;
  707. }
  708. parameterMapData.Add("zpresult", zpscore);
  709. parameterMapData.Add("hpresult", hpscore);
  710. parameterMapData.Add("xzpresult", xzpresult);
  711. List<Dictionary<string, object>> pfiles = new List<Dictionary<string, object>>();
  712. parameterMapData.Add("pfiles", pfiles);
  713. AbilitySub abilitySub = abilitySubs.Find(sub => sub.id.Equals(a.id));
  714. if (abilitySub != null)
  715. {
  716. abilitySub.uploads.ForEach(upload => {
  717. upload.urls.ForEach(url => {
  718. Dictionary<string, object> pfileMap = new Dictionary<string, object>();
  719. pfileMap.Add("url", url.url);
  720. pfileMap.Add("fileName", url.name);
  721. pfileMap.Add("fileSize", url.size);
  722. pfileMap.Add("md5", url.hash);
  723. string fileext = url.url.Substring(url.url.LastIndexOf(".") > 0 ? url.url.LastIndexOf(".") + 1 : 0);
  724. pfileMap.Add("fileType", fileext);
  725. pfiles.Add(pfileMap);
  726. });
  727. });
  728. }
  729. list53113.Add(parameterMapData);
  730. parameterMapDatas.Add(parameterMapData);
  731. });
  732. pushData.Add("success-UpdateTeacherListDiagnosis", parameterMapDatas);
  733. }
  734. else
  735. {
  736. pushData.Add("fail-UpdateTeacherListDiagnosis", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53113 });
  737. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53113 });
  738. }
  739. //5.3.1.17学员课堂实录批量回写-UploadKTSLList
  740. if (t53117OK == 1)
  741. {
  742. List<Dictionary<string, object>> parameterMapDatas = new List<Dictionary<string, object>>();
  743. x.teacherClasses.ForEach(clss =>
  744. {
  745. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  746. parameterMapData.Add("PXID", $"{t.PXID}");
  747. parameterMapData.Add("TID", $"{t.TID}");
  748. parameterMapData.Add("url", clss.url);//添加访问授权
  749. parameterMapData.Add("url2", clss.url);
  750. parameterMapData.Add("fileName", clss.name);
  751. parameterMapData.Add("fileSize", clss.size);
  752. parameterMapData.Add("md5", clss.hash);
  753. string fileext = clss.url.Substring(clss.url.LastIndexOf(".") > 0 ? clss.url.LastIndexOf(".") + 1 : 0);
  754. parameterMapData.Add("fileType", fileext);
  755. list53117.Add(parameterMapData);
  756. parameterMapDatas.Add(parameterMapData);
  757. });
  758. pushData.Add("success-UploadKTSLList", parameterMapDatas);
  759. }
  760. else
  761. {
  762. pushData.Add("fail-UploadKTSLList", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53117 });
  763. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53117 });
  764. }
  765. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
  766. if (t53122OK == 1)
  767. {
  768. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  769. parameterMapData.Add("PXID", $"{t.PXID}");
  770. parameterMapData.Add("TID", $"{t.TID}");
  771. List<Dictionary<string, object>> files = new List<Dictionary<string, object>>();
  772. x.offlineRecords.ForEach(record => {
  773. if (!string.IsNullOrWhiteSpace(record.url)) {
  774. Dictionary<string, object> fileMap = new Dictionary<string, object>();
  775. fileMap.Add("url", record.url);
  776. fileMap.Add("fileName", record.name);
  777. fileMap.Add("fileSize", record.size);
  778. fileMap.Add("md5", record.hash);
  779. string fileext = record.url.Substring(record.url.LastIndexOf(".") > 0 ? record.url.LastIndexOf(".") + 1 : 0);
  780. fileMap.Add("fileType", fileext);
  781. files.Add(fileMap);
  782. }
  783. });
  784. parameterMapData.Add("files", files);
  785. list53122.Add(parameterMapData);
  786. pushData.Add("success-UploadSBTARPDFListV2", parameterMapData);
  787. }
  788. else
  789. {
  790. pushData.Add("fail-UploadSBTARPDFListV2", new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53122 });
  791. fails.Add(new PushFail { tmdid = t.tmdid, name = t.TeacherName, msgs = msgs53122 });
  792. }
  793. pushDatas.Add(t.tmdid,pushData);
  794. }
  795. }
  796. //推送数据
  797. UpdateTeacherListSituation = await _thirdApisService.Post(config.url, "UpdateTeacherListSituation", config.passKey, config.privateKey, parameterContent53112);
  798. UpdateTeacherListSituation.code = "UpdateTeacherListSituation";
  799. UpdateTeacherListSituation.title = "5.3.1.12学员培训基本情况批量回写";
  800. UpdateTeacherListDiagnosis = await _thirdApisService.Post(config.url, "UpdateTeacherListDiagnosis", config.passKey, config.privateKey, parameterContent53113);
  801. UpdateTeacherListDiagnosis.code = "UpdateTeacherListDiagnosis";
  802. UpdateTeacherListDiagnosis.title = "5.3.1.13学员能力点测评结果批量回写";
  803. UploadKTSLList = await _thirdApisService.Post(config.url, "UploadKTSLList", config.passKey, config.privateKey, parameterContent53117);
  804. UploadKTSLList.code = "UploadKTSLList";
  805. UploadKTSLList.title = "5.3.1.17学员课堂实录批量回写";
  806. UploadSBTARPDFListV2 = await _thirdApisService.Post(config.url, "UploadSBTARPDFListV2", config.passKey, config.privateKey, parameterContent53122);
  807. UploadSBTARPDFListV2.code = "UploadSBTARPDFListV2";
  808. UploadSBTARPDFListV2.title = "5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写";
  809. results.Add(UpdateTeacherListSituation);
  810. results.Add(UpdateTeacherListDiagnosis);
  811. results.Add(UploadKTSLList);
  812. results.Add(UploadSBTARPDFListV2);
  813. }
  814. await response.WriteAsJsonAsync(new { data= new { results, pushDatas } });
  815. return response;
  816. }
  817. //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
  818. public (int t53122OK, List<KeyValuePair<string, string>> msgs) check53122(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs) {
  819. int t53122OK = 1;
  820. if (teacherTrain.offlineRecords.Count<= 0)
  821. {
  822. msgs.Add(new KeyValuePair<string, string>("offlineRecord-count", $"文件个数为0"));
  823. }
  824. var hasUrl= teacherTrain.offlineRecords.Where(x => !string.IsNullOrWhiteSpace(x.url) && x.size > 0);
  825. if (!hasUrl.Any()) {
  826. msgs.Add(new KeyValuePair<string, string>("offlineRecord-url", $"需要上传的校本研修作业至少有一个。"));
  827. }
  828. //不需要检查每一个校本研修的文件记录。
  829. //teacherTrain.offlineRecords.ForEach(x => {
  830. // if (string.IsNullOrEmpty(x.url)) {
  831. // msgs.Add(new KeyValuePair<string, string>("offlineRecord-url", $"链接为空"));
  832. // }
  833. // if (x.size<=0)
  834. // {
  835. // msgs.Add(new KeyValuePair<string, string>("offlineRecord-size", $"文件大小"));
  836. // }
  837. //});
  838. return (t53122OK, msgs);
  839. }
  840. //5.3.1.17学员课堂实录批量回写-UploadKTSLList
  841. public (int t53117OK, List<KeyValuePair<string, string>> msgs) check53117(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs) {
  842. //校验 基本情况是否满足
  843. int t53117OK = 1;
  844. if (teacherTrain.classTime <= 0)
  845. {
  846. msgs.Add(new KeyValuePair<string, string>("classTime", $"未获得学时:{teacherTrain.classTime}"));
  847. t53117OK = 0;
  848. }
  849. if (teacherTrain.teacherClasses.Count() <= 0) {
  850. msgs.Add(new KeyValuePair<string, string>("teacherClasses", $"未上传课堂实录:{teacherTrain.teacherClasses.Count()}个视频"));
  851. t53117OK = 0;
  852. }
  853. teacherTrain.teacherClasses.ForEach(x =>{
  854. if (string.IsNullOrWhiteSpace(x.url)) {
  855. t53117OK = 0;
  856. msgs.Add(new KeyValuePair<string, string>("teacherClasses", $"课堂实录链接无效"));
  857. }
  858. });
  859. return (t53117OK, msgs);
  860. }
  861. //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
  862. public (int t53112OK, List<KeyValuePair<string, string>> msgs) check53112(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs)
  863. {
  864. //校验 基本情况是否满足
  865. int t53112OK = 1;
  866. if (teacherTrain.finalScore < 0)
  867. {
  868. //总体认定结果0、未认定 1、合格 2、优秀 3、不合格 4、其他
  869. msgs.Add(new KeyValuePair<string, string>("finalScore", $"最终评定结果参数:{teacherTrain.finalScore}"));
  870. t53112OK = 0;
  871. }
  872. //if (string.IsNullOrEmpty(teacherTrain.summary) || teacherTrain.summary.Length > 300)
  873. //{
  874. // string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
  875. // msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结:{msg}"));
  876. // t53112OK = 0;
  877. //}
  878. if (!string.IsNullOrEmpty(teacherTrain.summary) && teacherTrain.summary.Length > 300)
  879. {
  880. //string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
  881. msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结:字数超过300."));
  882. t53112OK = 0;
  883. }
  884. if (teacherTrain.totalTime <= 0)
  885. {
  886. msgs.Add(new KeyValuePair<string, string>("totalTime", $"未获得学时:{teacherTrain.totalTime}"));
  887. t53112OK = 0;
  888. }
  889. return (t53112OK, msgs);
  890. }
  891. //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
  892. public async Task<(int t53113OK, List<KeyValuePair<string, string>> msgs, List<AbilitySub> abilitySubs)> check53113(TeacherTrain teacherTrain, ScTeacherDiagnosis diagnosis, List<KeyValuePair<string, string>> msgs)
  893. {
  894. //校验 基本情况是否满足
  895. int t53113OK = 1;
  896. List<AbilitySub> abilitySubs = new List<AbilitySub>();
  897. if (teacherTrain.currency.videoTime < 0)
  898. {
  899. msgs.Add(new KeyValuePair<string, string>("videoTime", $"视频学习时长:{teacherTrain.currency.videoTime}"));
  900. t53113OK = 0;
  901. }
  902. if (teacherTrain.currency.submitTime < 0)
  903. {
  904. msgs.Add(new KeyValuePair<string, string>("submitTime", $"认证材料学习:{teacherTrain.currency.submitTime}"));
  905. t53113OK = 0;
  906. }
  907. if (teacherTrain.currency.teacherAilities.Count <= 0 )
  908. {
  909. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"已学习能力点:0"));
  910. t53113OK = 0;
  911. }
  912. if (diagnosis != null)
  913. {
  914. if (!string.IsNullOrWhiteSpace(diagnosis.abilityNos))
  915. {
  916. List<string> nos = diagnosis.abilityNos.ToObject<List<string>>();
  917. if (nos.Count > 0 && teacherTrain.currency.teacherAilities.Count > 0)
  918. {
  919. var notin = nos.Except(teacherTrain.currency.teacherAilities.Select(x => x.no).Where(z=>!string.IsNullOrWhiteSpace(z)));
  920. if (notin.Any())
  921. {
  922. 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))} "));
  923. t53113OK = 0;
  924. }
  925. else {
  926. string insql = "";
  927. if (teacherTrain.currency.teacherAilities.IsNotEmpty())
  928. {
  929. var abilites= teacherTrain.currency.teacherAilities.Where(c => !string.IsNullOrWhiteSpace(c.no) && nos.Contains(c.no));
  930. insql = $" where c.id in ({string.Join(",", abilites.Select(o => $"'{o.id}'"))})";
  931. }
  932. //认证材料
  933. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer("TEAMModelOS", "Teacher")
  934. .GetItemQueryIterator<AbilitySub>(queryText: $"select value(c) from c {insql}", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilitySub-{teacherTrain.school}-{teacherTrain.id}") }))
  935. {
  936. abilitySubs.Add(item);
  937. }
  938. teacherTrain.currency.teacherAilities.ForEach(x => {
  939. var abilitySub = abilitySubs.Find(z => z.id.Equals(x.id));
  940. if (abilitySub == null || !abilitySub.uploads.Any())
  941. {
  942. t53113OK = 0;
  943. msgs.Add(new KeyValuePair<string, string>("uploads", $"未上传认证材料:{x.no},{x.name}"));
  944. }
  945. if (x.zpscore <= 0)
  946. {
  947. t53113OK = 0;
  948. msgs.Add(new KeyValuePair<string, string>("zpscore", $"认证材料,没有完成自评:{x.no},{x.name},{x.zpscore}"));
  949. }
  950. if (x.hpscore <= 0)
  951. {
  952. t53113OK = 0;
  953. msgs.Add(new KeyValuePair<string, string>("hpscore", $"认证材料,没有完成互评:{x.no},{x.name},{x.hpscore}"));
  954. }
  955. if (x.xzscore <= 0)
  956. {
  957. t53113OK = 0;
  958. msgs.Add(new KeyValuePair<string, string>("xzscore", $"认证材料,没有完成小组评:{x.no},{x.name},{x.xzscore}"));
  959. }
  960. });
  961. if (t53113OK != 1) {
  962. 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))} "));
  963. }
  964. }
  965. }
  966. else {
  967. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  968. t53113OK = 0;
  969. }
  970. }
  971. else {
  972. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  973. t53113OK = 0;
  974. }
  975. }
  976. else {
  977. msgs.Add(new KeyValuePair<string, string>("teacherAilities", $"未同步省平台挑选的能力点"));
  978. t53113OK = 0;
  979. }
  980. return (t53113OK, msgs, abilitySubs);
  981. }
  982. }
  983. }