ScController.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689
  1. using Microsoft.AspNetCore.Mvc;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Threading.Tasks;
  6. using TEAMModelOS.Models;
  7. using TEAMModelOS.SDK.DI;
  8. using System.Text.Json;
  9. using TEAMModelOS.SDK.Models;
  10. using Microsoft.AspNetCore.Http;
  11. using TEAMModelOS.SDK.Extension;
  12. using Azure.Cosmos;
  13. using System.Text;
  14. using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
  15. using Microsoft.Extensions.Options;
  16. using Azure.Messaging.ServiceBus;
  17. using Microsoft.Extensions.Configuration;
  18. using TEAMModelOS.Services.Common;
  19. using HTEXLib.COMM.Helpers;
  20. using TEAMModelOS.SDK;
  21. using System.IdentityModel.Tokens.Jwt;
  22. using TEAMModelOS.Services;
  23. using TEAMModelOS.SDK.Models.Service;
  24. using System.IO;
  25. using System.Dynamic;
  26. using Microsoft.AspNetCore.Authorization;
  27. using Azure.Storage.Blobs.Models;
  28. namespace TEAMModelOS.Controllers.Third
  29. {
  30. /// <summary>
  31. ///
  32. /// </summary>
  33. ///
  34. [ProducesResponseType(StatusCodes.Status200OK)]
  35. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  36. //[Authorize(Roles = "IES5")]
  37. [Route("sc")]
  38. //[Route("api/[controller]")]
  39. [ApiController]
  40. public class ScController : ControllerBase
  41. {
  42. private readonly SnowflakeId _snowflakeId;
  43. private readonly AzureCosmosFactory _azureCosmos;
  44. private readonly DingDing _dingDing;
  45. private readonly Option _option;
  46. private readonly AzureStorageFactory _azureStorage;
  47. private readonly AzureServiceBusFactory _serviceBus;
  48. private readonly AzureRedisFactory _azureRedis;
  49. private readonly CoreAPIHttpService _accountHttpService;
  50. private readonly ScsApisService _scsApisService;
  51. public readonly string type = "scsyxpt";
  52. /// <summary>
  53. /// 机构安全码
  54. /// </summary>
  55. public string _sc_passKey;
  56. /// <summary>
  57. /// 机构ID
  58. /// </summary>
  59. public string _sc_trainComID;
  60. /// <summary>
  61. /// 机构 AES 密钥
  62. /// </summary>
  63. public string _sc_privateKey;
  64. /// <summary>
  65. /// 访问地址
  66. /// </summary>
  67. public string _sc_url;
  68. public IConfiguration _configuration { get; set; }
  69. public ScController(AzureCosmosFactory azureCosmos, SnowflakeId snowflakeId, DingDing dingDing, IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage,
  70. AzureRedisFactory azureRedis, AzureServiceBusFactory serviceBus, IConfiguration configuration, CoreAPIHttpService accountHttpService, ScsApisService scsApisService)
  71. {
  72. _azureCosmos = azureCosmos;
  73. _snowflakeId = snowflakeId;
  74. _dingDing = dingDing;
  75. _option = option?.Value;
  76. _azureStorage = azureStorage;
  77. _serviceBus = serviceBus;
  78. _configuration = configuration;
  79. _azureRedis = azureRedis;
  80. _accountHttpService = accountHttpService;
  81. _scsApisService = scsApisService;
  82. _sc_passKey = _configuration.GetValue<string>("Third:scsyxpt:passKey");
  83. _sc_trainComID = _configuration.GetValue<string>("Third:scsyxpt:trainComID");
  84. _sc_privateKey = _configuration.GetValue<string>("Third:scsyxpt:privateKey");
  85. _sc_url = _configuration.GetValue<string>("Third:scsyxpt:url");
  86. }
  87. /// <summary>
  88. ///
  89. /// </summary>
  90. /// <param name="json"></param>
  91. /// <returns></returns>
  92. [ProducesDefaultResponseType]
  93. [HttpPost("get-list")]
  94. [AllowAnonymous]
  95. public async Task<IActionResult> GetProjectList(JsonElement json) {
  96. // 5.3.1.1获取项目列表
  97. string trainComID = _sc_trainComID;
  98. string Code = "GetProjectInfoByTrainComID";
  99. Dictionary<string, object> parameterMap = new Dictionary<string, object>();
  100. parameterMap.Add("TrainComID", _sc_trainComID);
  101. ScsResult GetProjectInfoByTrainComID = await _scsApisService.Post(_sc_url, Code, _sc_passKey,_sc_privateKey, parameterMap);
  102. // 5.3.1.2获取学员名单
  103. Code = "GetTeachersListByProject";
  104. parameterMap = new Dictionary<string, object>();
  105. parameterMap.Add("TrainComID", trainComID);
  106. parameterMap.Add("ProjectID", "22");
  107. parameterMap.Add("ProjectItemID", "23");
  108. ScsResult GetTeachersListByProject = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  109. // 5.3.1.3通过项目编号获取学员测评能力项
  110. Code = "GetDiagnosisListByProject";
  111. parameterMap = new Dictionary<string, object>();
  112. parameterMap.Add("TrainComID", trainComID);
  113. parameterMap.Add("ProjectID", "22");
  114. parameterMap.Add("ProjectItemID", "22");
  115. parameterMap.Add("PXID", "28496");
  116. ScsResult GetDiagnosisListByProject = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  117. // 补充
  118. // 5.3.1.20获取学校设置的可选能力点
  119. Code = "GetDiagnosisListByProject_V2";
  120. parameterMap = new Dictionary<string, object>();
  121. parameterMap.Add("TrainComID", trainComID);
  122. //parameterMap.Add("ProjectID", "22");
  123. //parameterMap.Add("ProjectItemID", "22");
  124. parameterMap.Add("PXID", "28496");
  125. ScsResult GetDiagnosisListByProject_V2 = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  126. // 5.3.1.4学员培训基本情况回写
  127. Code = "UpdateTeacherSituation";
  128. parameterMap = new Dictionary<string, object>();
  129. parameterMap.Add("TrainComID", trainComID);
  130. parameterMap.Add("PXID", "23");
  131. parameterMap.Add("TID", "145504");
  132. parameterMap.Add("TeacherName", "柏成伟");
  133. parameterMap.Add("CourseHour", "50");
  134. parameterMap.Add("ResearchText", "学习成果描述,字符长度<=300");
  135. parameterMap.Add("ComPassed", "2");//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  136. ScsResult UpdateTeacherSituation = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  137. // 5.3.1.5学员能力点测评结果回写
  138. Code = "UpdateTeacherDiagnosis";
  139. parameterMap = new Dictionary<string, object>();
  140. parameterMap.Add("TrainComID", trainComID);
  141. parameterMap.Add("PXID", "65314");
  142. parameterMap.Add("TID", "17542");
  143. parameterMap.Add("DiagnosisNum", "A3");
  144. //0"未认定", 1"合格", 2"优秀", 3"不合格"
  145. parameterMap.Add("zpresult", "1");
  146. parameterMap.Add("hpresult", "1");
  147. parameterMap.Add("xzpresult", "1");
  148. List<Dictionary<string, string>> pfilesA = new List<Dictionary<string, string>>();
  149. parameterMap.Add("pfiles", pfilesA);
  150. Dictionary<string, string> pfileMapA = new Dictionary<string, string>();
  151. pfileMapA.Add("url", "https://scnltsfiles.scedu.com.cn/upload/infofj/202104011628463774.pdf");
  152. pfileMapA.Add("fileName", "XXX.pdf");
  153. pfileMapA.Add("fileSize", "247767");
  154. pfileMapA.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  155. pfileMapA.Add("fileType", "pdf");
  156. pfilesA.Add(pfileMapA);
  157. ScsResult UpdateTeacherDiagnosis = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  158. // 5.3.1.6获取能力测评体系字典值数据
  159. Code = "GetDiagnosisDic";
  160. parameterMap = new Dictionary<string, object>();
  161. parameterMap.Add("TrainComID", trainComID);
  162. ScsResult GetDiagnosisDic = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  163. // 5.3.1.7获取能力测评评价类型字典值数据
  164. Code = "GetDiagnosisItemDic";
  165. parameterMap = new Dictionary<string, object>();
  166. parameterMap.Add("TrainComID", trainComID);
  167. parameterMap.Add("DiagnosisDicID", "3");
  168. ScsResult GetDiagnosisItemDic = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  169. // 5.3.1.8获取能力测评评价类型细则字典值数据
  170. Code = "GetchoiceDic";
  171. parameterMap = new Dictionary<string, object>();
  172. parameterMap.Add("TrainComID", trainComID);
  173. parameterMap.Add("DiagnosisItemID", "4");
  174. ScsResult GetchoiceDic = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  175. // 5.3.1.9根据培训ID与机构ID获取老师信息
  176. Code = "GetTeacherInfoByPXID";
  177. parameterMap = new Dictionary<string, object>();
  178. parameterMap.Add("TrainComID", trainComID);
  179. parameterMap.Add("PXID", "55024");
  180. ScsResult GetTeacherInfoByPXID = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  181. // 5.3.1.10根据培训项目ID与学校ID获取学校方案
  182. Code = "GetSchoolPlanBySchoolID";
  183. parameterMap = new Dictionary<string, object>();
  184. parameterMap.Add("TrainComID", trainComID);
  185. parameterMap.Add("ProjectItemID", "3");
  186. parameterMap.Add("SchoolID", "220913");
  187. parameterMap.Add("Type", "0");
  188. ScsResult GetSchoolPlanBySchoolID = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  189. // 5.3.1.11获取跳转学员信息
  190. Code = "GetSingleTeacherByProject";
  191. parameterMap = new Dictionary<string, object>();
  192. parameterMap.Add("TrainComID", trainComID);
  193. parameterMap.Add("Pxid", "55024");
  194. parameterMap.Add("Tid", "38616");
  195. ScsResult GetSingleTeacherByProject = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  196. // 5.3.1.12学员培训基本情况批量回写
  197. Code = "UpdateTeacherListSituation";
  198. Dictionary<string, object> parameterContent = new Dictionary<string, object>();
  199. List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
  200. parameterContent.Add("TrainComID", trainComID);
  201. parameterContent.Add("List", list);
  202. // {"TrainComID":"39","List":[{"ResearchText":"","ComPassed":1,"PXID":"35455","CourseHour":"50.0","TID":"411105","TeacherName":"付绍令"}]}
  203. {
  204. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  205. parameterMapData.Add("PXID", "23");
  206. parameterMapData.Add("TID", "145504");
  207. parameterMapData.Add("TeacherName", "柏成伟");
  208. parameterMapData.Add("CourseHour", "50");
  209. parameterMapData.Add("ResearchText", "学习成果描述,字符长度<=300");
  210. parameterMapData.Add("ComPassed", "2");//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  211. list.Add(parameterMapData);
  212. parameterMapData = new Dictionary<string, object>();
  213. parameterMapData.Add("PXID", "23");
  214. parameterMapData.Add("TID", "145504");
  215. parameterMapData.Add("TeacherName", "柏成伟");
  216. parameterMapData.Add("CourseHour", "50");
  217. parameterMapData.Add("ResearchText", "学习成果描述,字符长度<=300");
  218. parameterMapData.Add("ComPassed", "2");//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  219. list.Add(parameterMapData);
  220. parameterMapData = new Dictionary<string, object>();
  221. parameterMapData.Add("PXID", "22");
  222. parameterMapData.Add("TID", "21348");
  223. parameterMapData.Add("TeacherName", "邓泽燕");
  224. parameterMapData.Add("CourseHour", "50");
  225. parameterMapData.Add("ResearchText", "学习成果描述,字符长度<=300");
  226. parameterMapData.Add("ComPassed", "2");//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  227. list.Add(parameterMapData);
  228. parameterMapData = new Dictionary<string, object>();
  229. parameterMapData.Add("PXID", "35546");
  230. parameterMapData.Add("TID", "411182");
  231. parameterMapData.Add("TeacherName", "刘晓莉");
  232. parameterMapData.Add("CourseHour", "50");
  233. parameterMapData.Add("ResearchText", "");
  234. parameterMapData.Add("ComPassed", "1");//0、未认定 1、合格 2、优秀 3、不合格 4、其他
  235. list.Add(parameterMapData);
  236. }
  237. ScsResult UpdateTeacherListSituation = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterContent);
  238. // 5.3.1.13学员能力点测评结果批量回写
  239. Code = "UpdateTeacherListDiagnosis";
  240. parameterContent = new Dictionary<string, object>();
  241. list = new List<Dictionary<string, object>>();
  242. parameterContent.Add("TrainComID", trainComID);
  243. parameterContent.Add("List", list);
  244. {
  245. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  246. parameterMapData.Add("PXID", "3079");
  247. parameterMapData.Add("TID", "14597");
  248. parameterMapData.Add("DiagnosisNum", "A6");
  249. //0"未认定", 1"合格", 2"优秀", 3"不合格"
  250. parameterMapData.Add("zpresult", "1");
  251. parameterMapData.Add("hpresult", "2");
  252. parameterMapData.Add("xzpresult", "2");
  253. List<Dictionary<string, object>> pfiles = new List<Dictionary<string, object>>();
  254. parameterMapData.Add("pfiles", pfiles);
  255. Dictionary<string, object> pfileMap = new Dictionary<string, object>();
  256. pfileMap.Add("url", "https://srt-read-online.3ren.cn/basebusiness/material/20210422/1619055398463iE97VWe36i001.mp4");
  257. pfileMap.Add("fileName", "697a58c2375f7a031456c893e1e1860c.mp4");
  258. pfileMap.Add("fileSize", "17036168");
  259. pfileMap.Add("md5", "");
  260. pfileMap.Add("fileType", "video");
  261. pfiles.Add(pfileMap);
  262. list.Add(parameterMapData);
  263. pfileMap = new Dictionary<string, object>();
  264. pfileMap.Add("url", "https://srt-read-online.3ren.cn/basebusiness/material/20210422/1619055446704gbKuNF8eas001.pdf");
  265. pfileMap.Add("fileName", "A6技术支持的课堂反思.pdf");
  266. pfileMap.Add("fileSize", "32192");
  267. pfileMap.Add("md5", "");
  268. pfileMap.Add("fileType", "pdf");
  269. pfiles.Add(pfileMap);
  270. list.Add(parameterMapData);
  271. }
  272. {
  273. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  274. parameterMapData.Add("PXID", "3062");
  275. parameterMapData.Add("TID", "401268");
  276. parameterMapData.Add("DiagnosisNum", "A1");
  277. //0"未认定", 1"合格", 2"优秀", 3"不合格"
  278. parameterMapData.Add("zpresult", "1");
  279. parameterMapData.Add("hpresult", "2");
  280. parameterMapData.Add("xzpresult", "2");
  281. List<Dictionary<string, object>> pfiles = new List<Dictionary<string, object>>();
  282. parameterMapData.Add("pfiles", pfiles);
  283. Dictionary<string, object> pfileMap = new Dictionary<string, object>();
  284. pfileMap.Add("url", "https://srt-read-online.3ren.cn/basebusiness/material/20210422/1619058650000bphKFbDVSa001.pdf");
  285. pfileMap.Add("fileName", "学情分析.pdf");
  286. pfileMap.Add("fileSize", "94926");
  287. pfileMap.Add("md5", "");
  288. pfileMap.Add("fileType", "pdf");
  289. pfiles.Add(pfileMap);
  290. list.Add(parameterMapData);
  291. pfileMap = new Dictionary<string, object>();
  292. pfileMap.Add("url", "https://srt-read-online.3ren.cn/basebusiness/material/20210422/1619058698452gF19jmiuML001.mp4");
  293. pfileMap.Add("fileName", "种子萌发学情分析.mp4");
  294. pfileMap.Add("fileSize", "12692368");
  295. pfileMap.Add("md5", "");
  296. pfileMap.Add("fileType", "video");
  297. pfiles.Add(pfileMap);
  298. list.Add(parameterMapData);
  299. }
  300. ScsResult UpdateTeacherListDiagnosis = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterContent);
  301. // 5.3.1.14学员校本研修PDF回写
  302. Code = "UploadSBTARPDF";
  303. parameterMap = new Dictionary<string, object>();
  304. parameterMap.Add("TrainComID", trainComID);
  305. parameterMap.Add("PXID", "16");
  306. parameterMap.Add("TID", "16");
  307. parameterMap.Add("url", "http://image1.cersp.com.cn/scpx/images/article/file/20190318/upload__51f98fc8_1697695ae73__7ffe_00001297.pdf");
  308. parameterMap.Add("fileName", "XXX.pdf");
  309. parameterMap.Add("fileSize", "247767");
  310. parameterMap.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  311. parameterMap.Add("fileType", "pdf");
  312. ScsResult UploadSBTARPDF = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  313. // 5.3.1.15学员校本教研PDF批量回写
  314. Code = "UploadSBTARPDFList";
  315. parameterContent = new Dictionary<string, object>();
  316. list = new List<Dictionary<string, object>>();
  317. parameterContent.Add("TrainComID", trainComID);
  318. parameterContent.Add("List", list);
  319. {
  320. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  321. parameterMapData.Add("PXID", "65309");
  322. parameterMapData.Add("TID", "253940");
  323. parameterMapData.Add("url", "https://scnltsfiles.scedu.com.cn/upload/infofj/202104011628463774.pdf");
  324. parameterMapData.Add("fileName", "XXX.pdf");
  325. parameterMapData.Add("fileSize", "247767");
  326. parameterMapData.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  327. parameterMapData.Add("fileType", "pdf");
  328. list.Add(parameterMapData);
  329. }
  330. {
  331. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  332. parameterMapData.Add("PXID", "65306");
  333. parameterMapData.Add("TID", "32393");
  334. parameterMapData.Add("url", "https://scnltsfiles.scedu.com.cn/upload/infofj/202104011628463774.pdf");
  335. parameterMapData.Add("fileName", "XXX.pdf");
  336. parameterMapData.Add("fileSize", "247767");
  337. parameterMapData.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  338. parameterMapData.Add("fileType", "pdf");
  339. list.Add(parameterMapData);
  340. }
  341. ScsResult UploadSBTARPDFList = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterContent);
  342. // 5.3.1.16学员课堂实录回写
  343. Code = "UploadKTSL";
  344. parameterMap = new Dictionary<string, object>();
  345. parameterMap.Add("TrainComID", trainComID);
  346. parameterMap.Add("PXID", "16");
  347. parameterMap.Add("TID", "16");
  348. parameterMap.Add("url", "https://xxx.mp4");
  349. parameterMap.Add("url2", "https://xxx.mp4");
  350. parameterMap.Add("fileName", "XXX.mp4");
  351. parameterMap.Add("fileSize", "247767");
  352. parameterMap.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  353. parameterMap.Add("fileType", "mp4");
  354. ScsResult UploadKTSL = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  355. // 5.3.1.17学员课堂实录批量回写
  356. Code = "UploadKTSLList";
  357. parameterContent = new Dictionary<string, object>();
  358. list = new List<Dictionary<string, object>>();
  359. parameterContent.Add("TrainComID", trainComID);
  360. parameterContent.Add("List", list);
  361. {
  362. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  363. parameterMapData.Add("PXID", "16");
  364. parameterMapData.Add("TID", "16");
  365. parameterMapData.Add("url", "https://xxx.mp4");
  366. parameterMapData.Add("url2", "https://xxx.mp4");
  367. parameterMapData.Add("fileName", "XXX.mp4");
  368. parameterMapData.Add("fileSize", "247767");
  369. parameterMapData.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  370. parameterMapData.Add("fileType", "mp4");
  371. list.Add(parameterMapData);
  372. }
  373. {
  374. Dictionary<string, object> parameterMapData = new Dictionary<string, object>();
  375. parameterMapData.Add("PXID", "16");
  376. parameterMapData.Add("TID", "16");
  377. parameterMapData.Add("url", "https://xxx.mp4");
  378. parameterMapData.Add("url2", "https://xxx.mp4");
  379. parameterMapData.Add("fileName", "XXX.mp4");
  380. parameterMapData.Add("fileSize", "247767");
  381. parameterMapData.Add("md5", "9c3da8c5c07c2c660cd73c01f56d7fca");
  382. parameterMapData.Add("fileType", "mp4");
  383. list.Add(parameterMapData);
  384. }
  385. ScsResult UploadKTSLList = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterContent);
  386. // 5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表
  387. Code = "GetSchoolList";
  388. parameterMap = new Dictionary<string, object>();
  389. parameterMap.Add("TrainComID", trainComID);
  390. parameterMap.Add("ProjectID", "22");
  391. parameterMap.Add("ProjectItemID", "21");
  392. ScsResult GetSchoolList = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  393. // 5.3.1.19获取项目设置的可选能力点
  394. Code = "GetProjectDiagnosis";
  395. parameterMap = new Dictionary<string, object>();
  396. parameterMap.Add("TrainComID", trainComID);
  397. parameterMap.Add("ProjectID", "22");
  398. parameterMap.Add("ProjectItemID", "21");
  399. ScsResult GetProjectDiagnosis = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  400. // 5.3.1.20获取学校设置的可选能力点
  401. Code = "GetSchoolDiagnosis";
  402. parameterMap = new Dictionary<string, object>();
  403. parameterMap.Add("TrainComID", trainComID);
  404. parameterMap.Add("ProjectID", "22");
  405. parameterMap.Add("SchoolID", "200001");
  406. ScsResult GetSchoolDiagnosis = await _scsApisService.Post(_sc_url, Code, _sc_passKey, _sc_privateKey, parameterMap);
  407. return Ok(new
  408. {
  409. GetProjectInfoByTrainComID,
  410. GetTeachersListByProject,
  411. GetDiagnosisListByProject,
  412. GetDiagnosisListByProject_V2,
  413. UpdateTeacherSituation,
  414. UpdateTeacherDiagnosis,
  415. GetDiagnosisDic,
  416. GetDiagnosisItemDic,
  417. GetchoiceDic,
  418. GetTeacherInfoByPXID,
  419. GetSchoolPlanBySchoolID,
  420. GetSingleTeacherByProject,
  421. UpdateTeacherListSituation,
  422. UpdateTeacherListDiagnosis,
  423. UploadSBTARPDF,
  424. UploadSBTARPDFList,
  425. UploadKTSL,
  426. UploadKTSLList,
  427. GetSchoolList,
  428. GetProjectDiagnosis,
  429. GetSchoolDiagnosis
  430. });
  431. }
  432. public class ScsResult {
  433. public bool result { get; set; }
  434. public string reason { get; set; }
  435. public string content { get; set; }
  436. }
  437. /// <summary>
  438. ///
  439. /// </summary>
  440. /// <param name="request"></param>
  441. /// <returns></returns>
  442. [ProducesDefaultResponseType]
  443. [HttpPost("bind")]
  444. [AllowAnonymous]
  445. public async Task<IActionResult> Bind(SSO sso) {
  446. var rurl = new StringBuilder($"https://{_option.HostName}/sso");
  447. try
  448. {
  449. Teacher teacher = null;
  450. if (string.IsNullOrEmpty(sso.id_token)) {
  451. return Redirect(rurl.Append($"?status=1").ToString());
  452. }
  453. var jwt = new JwtSecurityToken(sso.id_token);
  454. if (!jwt.Payload.Iss.Equals("account.teammodel", StringComparison.OrdinalIgnoreCase)) return BadRequest();
  455. var id = jwt.Payload.Sub;
  456. jwt.Payload.TryGetValue("name", out object name);
  457. jwt.Payload.TryGetValue("picture", out object picture);
  458. var client = _azureCosmos.GetCosmosClient();
  459. teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
  460. //先检查绑定的平台是否已经被绑定
  461. //四川研训平台跳转隐式登录/或者绑定IES平台接入规范
  462. ScSSO scsso= sso.param.ToObject<ScSSO>();
  463. string sql = $"SELECT distinct value(c) FROM c join A1 in c.binds where A1.webid='{scsso.Webid}' and A1.tid='{scsso.tid}'";
  464. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
  465. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  466. {
  467. teacher = item;
  468. break;
  469. }
  470. if (teacher != null)
  471. {
  472. if (teacher.id.Equals(id))
  473. {
  474. var bind = teacher.binds.Find(x => x.source.Equals($"{scsso.Webid}") && x.userid.Equals($"{scsso.tid}"));
  475. if (bind == null)
  476. {
  477. teacher.binds=new List<Teacher.ThirdBind> { new Teacher.ThirdBind { pxid = new HashSet<string> { $"{scsso.Pxid}" }, userid = $"{scsso.tid}", source = $"{scsso.Webid}", type = type } };
  478. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  479. }
  480. else
  481. {
  482. if (bind.pxid != null)
  483. {
  484. if (bind.pxid.Add(scsso.Pxid))
  485. {
  486. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  487. }
  488. }
  489. else {
  490. bind.pxid = new HashSet<string> { scsso.Pxid };
  491. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  492. }
  493. }
  494. }
  495. else {
  496. return Ok(new
  497. {
  498. location = _option.Location,
  499. //账号已被别的醍摩豆id绑定
  500. status = 3,
  501. tmdid = teacher.id,
  502. name=teacher.name,
  503. tid = scsso.tid
  504. }) ;
  505. }
  506. }
  507. else {
  508. teacher = new Teacher
  509. {
  510. id = id,
  511. pk = "Base",
  512. code = "Base",
  513. name = name?.ToString(),
  514. picture = picture?.ToString(),
  515. //创建账号并第一次登录IES5则默认赠送1G
  516. size = 1,
  517. defaultSchool = null,
  518. schools = new List<Teacher.TeacherSchool>(),
  519. binds= new List<Teacher.ThirdBind> { new Teacher.ThirdBind { pxid = new HashSet<string> { $"{scsso.Pxid}" }, userid = $"{scsso.tid}", source = $"{scsso.Webid}", type = type } }
  520. };
  521. var container = _azureStorage.GetBlobContainerClient(id);
  522. await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建Teacher私有容器,如存在則不做任何事,保障容器一定存在
  523. teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));
  524. }
  525. return Ok(new
  526. {
  527. location = _option.Location,
  528. status = 200,
  529. });
  530. } catch (Exception ) {
  531. return Ok(new
  532. {
  533. location = _option.Location,
  534. status = 2,
  535. });
  536. }
  537. }
  538. /// <summary>
  539. ///
  540. /// </summary>
  541. /// <param name="request"></param>
  542. /// <returns></returns>
  543. [HttpGet("sso")]
  544. [AllowAnonymous]
  545. public async Task<IActionResult> Sso([FromQuery] ScSSO sso)
  546. {
  547. var rurl = new StringBuilder($"https://{_option.HostName}/sso");
  548. string parmas = $"Pxid={sso.Pxid}&Webid={sso.Webid}&tid={sso.tid}&time={sso.time}";
  549. if (Md5Hash.GetMd5String(parmas).Equals($"{sso.Encrypt}"))
  550. {
  551. //四川研训平台跳转隐式登录/或者绑定IES平台接入规范
  552. long ssotime = long.Parse($"{sso.time}");
  553. long nowtime = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
  554. if (nowtime - ssotime > 60 * 10)//10分钟有效期
  555. {
  556. // return Ok(new { status = 2, msg = "登录超时!" });
  557. }
  558. }
  559. else
  560. {
  561. return Redirect(rurl.Append($"?status=1").ToString());
  562. }
  563. Teacher teacher = null;
  564. //四川研训平台跳转隐式登录/或者绑定IES平台接入规范
  565. //string sql = $"SELECT distinct value(c) FROM c join A1 in c.binds where A1.pxid='{sso.Pxid}' and A1.webid='{sso.Webid}' and A1.tid='{sso.tid}'";
  566. string sql = $"SELECT distinct value(c) FROM c join A1 in c.binds where A1.source='{sso.Webid}' and A1.userid='{sso.tid}'";
  567. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
  568. requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  569. {
  570. teacher = item;
  571. break;
  572. }
  573. if (teacher == null)
  574. {
  575. return Redirect(rurl.Append($"?status=4&param={sso.ToJsonString()}&type={type}&bindurl=sc/bind").ToString());
  576. }
  577. else
  578. {
  579. var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
  580. var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  581. var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
  582. var location = _option.Location;
  583. (int code, string content) = await _accountHttpService.Implicit(clientID, clientSecret, location, $"{url}/oauth2/implicit",
  584. new Dictionary<string, string>()
  585. {
  586. { "grant_type", "implicit" },
  587. { "client_id",clientID },
  588. { "account",teacher.id },
  589. { "nonce",Guid.NewGuid().ToString()}
  590. });
  591. TmdidImplicit implicit_token = new TmdidImplicit();
  592. if (!string.IsNullOrEmpty(content) && code==200)
  593. {
  594. implicit_token = content.ToObject<TmdidImplicit>();
  595. var bind = teacher.binds.Find(x => x.userid.Equals(sso.tid) && x.source.Equals(sso.Webid));
  596. if (bind != null) {
  597. if (bind.pxid != null)
  598. {
  599. if (bind.pxid.Add(sso.Pxid))
  600. {
  601. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  602. }
  603. }
  604. else {
  605. bind.pxid = new HashSet<string> { sso.Pxid };
  606. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
  607. }
  608. }
  609. return Redirect(rurl.Append($"?status=200&id_token={implicit_token.id_token}&access_token={implicit_token.access_token}&expires_in={implicit_token.expires_in}&token_type={implicit_token.token_type}").ToString());
  610. }
  611. else {
  612. //绑定失效
  613. if (teacher.binds.IsNotEmpty()) {
  614. teacher.binds.RemoveAll(x => x.userid.Equals(sso.tid) && x.source.Equals(sso.Webid));
  615. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher,teacher.id,new PartitionKey(teacher.code));
  616. }
  617. return Redirect(rurl.Append($"?status=4&param={sso.ToJsonString()}&type={type}&bindurl=sc/bind").ToString());
  618. }
  619. }
  620. }
  621. public record ScSSO{
  622. public string Webid { get; set; }
  623. public string Pxid { get; set; }
  624. public string tid { get; set; }
  625. public string time { get; set; }
  626. public string Encrypt { get; set; }
  627. }
  628. public record SSO
  629. {
  630. public string type { get; set; }
  631. public string param { get; set; }
  632. public string id_token { get; set; }
  633. }
  634. public record TmdidImplicit {
  635. public string id_token { get; set; }
  636. public string access_token { get; set; }
  637. public string expires_in { get; set; }
  638. public string token_type { get; set; }
  639. }
  640. }
  641. }