AreaController.cs 164 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115
  1. using Azure.Core;
  2. using Azure.Cosmos;
  3. using Azure.Storage.Sas;
  4. using ClouDASLibx;
  5. using DocumentFormat.OpenXml.Drawing.Charts;
  6. using DocumentFormat.OpenXml.Office2010.Excel;
  7. using DocumentFormat.OpenXml.Spreadsheet;
  8. using DocumentFormat.OpenXml.Wordprocessing;
  9. using HTEXLib.COMM.Helpers;
  10. using Microsoft.AspNetCore.Authorization;
  11. using Microsoft.AspNetCore.Http;
  12. using Microsoft.AspNetCore.Mvc;
  13. using Microsoft.Extensions.Configuration;
  14. using Microsoft.Extensions.Options;
  15. using OfficeOpenXml.Style;
  16. using OpenXmlPowerTools;
  17. using System;
  18. using System.Collections.Generic;
  19. using System.Linq;
  20. using System.Net;
  21. using System.Text;
  22. using System.Text.Json;
  23. using System.Threading.Tasks;
  24. using TEAMModelOS.Controllers.Analysis;
  25. using TEAMModelOS.Controllers.Core;
  26. using TEAMModelOS.Filter;
  27. using TEAMModelOS.Models;
  28. using TEAMModelOS.SDK;
  29. using TEAMModelOS.SDK.DI;
  30. using TEAMModelOS.SDK.Extension;
  31. using TEAMModelOS.SDK.Models;
  32. using TEAMModelOS.SDK.Models.Cosmos.Common;
  33. using TEAMModelOS.SDK.Models.Cosmos.Student;
  34. using TEAMModelOS.SDK.Models.Service;
  35. using static SKIT.FlurlHttpClient.Wechat.TenpayV3.Models.CreateApplyForSubjectApplymentRequest.Types;
  36. using static TEAMModelOS.SDK.Models.Cosmos.Student.StudentAnalysis;
  37. using Period = TEAMModelOS.SDK.Models.Period;
  38. namespace TEAMModelOS.Controllers
  39. {
  40. [ProducesResponseType(StatusCodes.Status200OK)]
  41. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  42. [Route("school/area")]
  43. [ApiController]
  44. public class AreaController : ControllerBase
  45. {
  46. private readonly AzureCosmosFactory _azureCosmos;
  47. private readonly SnowflakeId _snowflakeId;
  48. private readonly AzureServiceBusFactory _serviceBus;
  49. private readonly DingDing _dingDing;
  50. private readonly Option _option;
  51. private readonly AzureStorageFactory _azureStorage;
  52. private readonly AzureRedisFactory _azureRedis;
  53. private readonly CoreAPIHttpService _coreAPIHttpService;
  54. public IConfiguration _configuration { get; set; }
  55. public AreaController(CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureServiceBusFactory serviceBus, SnowflakeId snowflakeId, DingDing dingDing,
  56. IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, IConfiguration configuration)
  57. {
  58. _azureCosmos = azureCosmos;
  59. _serviceBus = serviceBus;
  60. _snowflakeId = snowflakeId;
  61. _dingDing = dingDing;
  62. _option = option?.Value;
  63. _azureStorage = azureStorage;
  64. _azureRedis = azureRedis;
  65. _configuration = configuration;
  66. _coreAPIHttpService = coreAPIHttpService;
  67. }
  68. /// <param name="request"></param>
  69. /// <returns></returns>
  70. [ProducesDefaultResponseType]
  71. [AuthToken(Roles = "teacher,admin")]
  72. #if !DEBUG
  73. [Authorize(Roles = "IES")]
  74. #endif
  75. [HttpPost("find-group")]
  76. public async Task<IActionResult> Find(JsonElement request)
  77. {
  78. try
  79. {
  80. //区级Id
  81. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  82. var client = _azureCosmos.GetCosmosClient();
  83. //获取区级以下所有学校编码和基础信息
  84. List<string> baseIds = new();
  85. List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
  86. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name,c.picture from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  87. {
  88. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  89. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  90. {
  91. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  92. while (accounts.MoveNext())
  93. {
  94. JsonElement account = accounts.Current;
  95. baseIds.Add(account.GetProperty("id").GetString());
  96. scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
  97. }
  98. }
  99. }
  100. List<(string id, List<string> gId, List<string> name)> groups = new List<(string id, List<string> gId, List<string> name)>();
  101. foreach (string sId in baseIds)
  102. {
  103. List<(string id, string name)> group = new();
  104. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"SELECT c.id, c.name FROM c where c.type='research' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"GroupList-{sId}") }))
  105. {
  106. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  107. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  108. {
  109. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  110. while (accounts.MoveNext())
  111. {
  112. JsonElement account = accounts.Current;
  113. group.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
  114. //group.Add();
  115. }
  116. }
  117. }
  118. group = group.Where(g => !string.IsNullOrEmpty(g.id)).ToList();
  119. groups.Add((sId, group.Select(s => s.id).ToList(), group.Select(s => s.name).ToList()));
  120. }
  121. //var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS("hbcn", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  122. var gr = groups.Select(o => new
  123. {
  124. o.id,
  125. o.gId,
  126. uri = _azureStorage.GetBlobContainerSAS(o.id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List).uri,
  127. sas = _azureStorage.GetBlobContainerSAS(o.id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List).sas,
  128. sname = scInfos.FirstOrDefault(c => c.id == o.id).name,
  129. o.name
  130. });
  131. return Ok(new { gr });
  132. }
  133. catch (Exception e)
  134. {
  135. await _dingDing.SendBotMsg($"OS,{_option.Location},school/area/find-group()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  136. return BadRequest(new { msg = e.Message });
  137. }
  138. }
  139. [ProducesDefaultResponseType]
  140. [AuthToken(Roles = "teacher,admin,student")]
  141. #if !DEBUG
  142. [Authorize(Roles = "IES")]
  143. #endif
  144. [HttpPost("find")]
  145. public async Task<IActionResult> FindGroup(JsonElement request)
  146. {
  147. try
  148. {
  149. //区级Id
  150. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  151. var client = _azureCosmos.GetCosmosClient();
  152. //获取区级以下所有学校编码和基础信息
  153. List<string> baseIds = new();
  154. List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
  155. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name,c.picture from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  156. {
  157. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  158. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  159. {
  160. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  161. while (accounts.MoveNext())
  162. {
  163. JsonElement account = accounts.Current;
  164. baseIds.Add(account.GetProperty("id").GetString());
  165. scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
  166. }
  167. }
  168. }
  169. //获取所有学校人数
  170. List<(string id, int count)> scCount = new List<(string id, int count)>();
  171. foreach (string sId in baseIds)
  172. {
  173. List<string> tIds = new();
  174. await foreach (var item in client.GetContainer("TEAMModelOS", "Teacher").GetItemQueryStreamIterator(queryText: $"select c.id from c join A0 in c.schools where A0.schoolId = '{sId}' ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  175. {
  176. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  177. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  178. {
  179. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  180. while (accounts.MoveNext())
  181. {
  182. JsonElement account = accounts.Current;
  183. tIds.Add(account.GetProperty("id").GetString());
  184. }
  185. }
  186. }
  187. scCount.Add((sId, tIds.Count));
  188. }
  189. var info = scInfos.Select(o =>
  190. new
  191. {
  192. o.id,
  193. o.name,
  194. o.picture,
  195. areaId = id,
  196. count = scCount.FirstOrDefault(c => c.id == o.id).count,
  197. }
  198. );
  199. return Ok(new { info });
  200. }
  201. catch (Exception e)
  202. {
  203. await _dingDing.SendBotMsg($"OS,{_option.Location},school/area/find()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  204. return BadRequest();
  205. }
  206. }
  207. /// <summary>
  208. /// 保存研修信息
  209. /// </summary>
  210. /// <param name="request"></param>
  211. /// <returns></returns>
  212. [ProducesDefaultResponseType]
  213. //[AuthToken(Roles = "teacher,admin")]
  214. [HttpPost("save-study")]
  215. [AuthToken(Roles = "teacher,admin")]
  216. #if !DEBUG
  217. [Authorize(Roles = "IES")]
  218. #endif
  219. public async Task<IActionResult> SaveStudy(JsonElement request)
  220. {
  221. try
  222. {
  223. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  224. //if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
  225. if (!request.TryGetProperty("study", out JsonElement stu)) return BadRequest();
  226. //List<parameter> parameters = para.ToObject<List<parameter>>();
  227. var client = _azureCosmos.GetCosmosClient();
  228. var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
  229. //获取区级以下所有学校编码和基础信息
  230. List<string> baseIds = new();
  231. //List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
  232. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  233. {
  234. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  235. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  236. {
  237. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  238. while (accounts.MoveNext())
  239. {
  240. JsonElement account = accounts.Current;
  241. baseIds.Add(account.GetProperty("id").GetString());
  242. //scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
  243. }
  244. }
  245. }
  246. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  247. List<Study> studies = new();
  248. Study areaStudy = stu.ToObject<Study>();
  249. areaStudy.owner = "area";
  250. areaStudy.ttl = -1;
  251. areaStudy.scope = "school";
  252. areaStudy.code = "Study-" + id.GetString();
  253. areaStudy.createTime = now;
  254. areaStudy.creatorId = userid;
  255. if (areaStudy.startTime > now)
  256. {
  257. areaStudy.progress = "pending";
  258. }
  259. else
  260. {
  261. areaStudy.progress = "going";
  262. }
  263. if (string.IsNullOrEmpty(areaStudy.id))
  264. {
  265. areaStudy.id = Guid.NewGuid().ToString();
  266. }
  267. //创建区级名单
  268. GroupList list = new();
  269. list.type = "activity";
  270. list.year = list.year > 0 ? list.year : DateTimeOffset.UtcNow.Year;
  271. list.ttl = -1;
  272. list.expire = 0;
  273. list.creatorId = userid;
  274. list.code = "GroupList";
  275. list.scope = "private";
  276. list.pk = "GroupList";
  277. list.name = areaStudy.name;
  278. list.school = null;
  279. list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
  280. list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
  281. areaStudy.tchLists.Add(list.id);
  282. foreach (string scId in baseIds)
  283. {
  284. Study study = stu.ToObject<Study>();
  285. study.areaId = id.GetString();
  286. study.school = scId;
  287. study.owner = "area";
  288. study.ttl = -1;
  289. study.code = "Study-" + scId;
  290. study.createTime = now;
  291. study.creatorId = userid;
  292. study.publish = 1;
  293. study.progress = "pending";
  294. study.pId = areaStudy.id;
  295. study.scope = "school";
  296. study.targetType = "research";
  297. study.tchLists.Add(list.id);
  298. foreach (string setting in study.settings)
  299. {
  300. if (setting.Equals("exam"))
  301. {
  302. if (!request.TryGetProperty("exam", out JsonElement exam)) return BadRequest();
  303. ExamLite trExam = exam.ToObject<ExamLite>();
  304. trExam.owner = "area";
  305. trExam.school = scId;
  306. trExam.areaId = id.GetString();
  307. trExam.creatorId = userid;
  308. trExam.targetType = "research";
  309. trExam.publish = 1;
  310. trExam.tchLists.Add(list.id);
  311. trExam.blob = $"/{trExam.areaId}/exam/{study.pId}/index.json";
  312. //处理发布对象
  313. //await getMoreExam(pa, trExam);
  314. //保存更多得评测信息
  315. string eId = await ExamService.saveMoreAsync(client, _dingDing, trExam);
  316. if (string.IsNullOrEmpty(eId))
  317. {
  318. return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "评测信息异常" });
  319. }
  320. else
  321. {
  322. study.examId = eId;
  323. }
  324. }
  325. if (setting.Equals("survey"))
  326. {
  327. if (!request.TryGetProperty("survey", out JsonElement survey)) return BadRequest();
  328. Survey trSurvey = survey.ToObject<Survey>();
  329. trSurvey.owner = "area";
  330. trSurvey.school = scId;
  331. trSurvey.areaId = id.GetString();
  332. //trSurvey.tchLists = pa.gId;
  333. trSurvey.scope = "school";
  334. trSurvey.creatorId = userid;
  335. trSurvey.publish = 1;
  336. trSurvey.targetType = "research";
  337. trSurvey.tchLists.Add(list.id);
  338. trSurvey.blob = $"/{trSurvey.areaId}/survey/{study.pId}/index.json";
  339. //await getMoreSurvey(pa, trSurvey);
  340. string surveyId = await SurveyService.saveMoreAsync(client, _dingDing, trSurvey);
  341. if (string.IsNullOrEmpty(surveyId))
  342. {
  343. return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "问卷信息异常" });
  344. }
  345. else
  346. {
  347. study.surveyId = surveyId;
  348. }
  349. }
  350. if (setting.Equals("hw"))
  351. {
  352. if (!request.TryGetProperty("work", out JsonElement work)) return BadRequest();
  353. Homework homework = work.ToObject<Homework>();
  354. homework.owner = "area";
  355. homework.school = scId;
  356. homework.areaId = id.GetString();
  357. //homework.tchLists = pa.gId;
  358. homework.scope = "school";
  359. homework.creatorId = userid;
  360. homework.publish = 1;
  361. homework.targetType = "research";
  362. homework.tchLists.Add(list.id);
  363. //homework.blob = $"/{homework.areaId}/survey/{study.pId}/index.json";
  364. //await getMoreWork(pa, homework);
  365. string workId = await HomeworkService.saveMoreAsync(client, _dingDing, homework, _serviceBus, _azureStorage, _configuration, _azureRedis);
  366. if (string.IsNullOrEmpty(workId))
  367. {
  368. return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "作业活动异常" });
  369. }
  370. else
  371. {
  372. study.workId = workId;
  373. }
  374. }
  375. }
  376. if (string.IsNullOrEmpty(study.id))
  377. {
  378. study.id = Guid.NewGuid().ToString();
  379. await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(study, new PartitionKey($"{study.code}"));
  380. }
  381. else
  382. {
  383. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(study, new PartitionKey($"{study.code}"));
  384. }
  385. studies.Add(study);
  386. }
  387. //areaStudy.targets = allName;
  388. /* var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
  389. areaStudy.targets = atn;*/
  390. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaStudy, new PartitionKey($"{areaStudy.code}"));
  391. var ids = studies.Select(s => new { s.id, s.school, s.examId, s.surveyId });
  392. return Ok(new { id, ids, code = (int)HttpStatusCode.OK, acId = areaStudy.id });
  393. }
  394. catch (Exception ex)
  395. {
  396. await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-study()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  397. return BadRequest();
  398. }
  399. }
  400. [ProducesDefaultResponseType]
  401. //[AuthToken(Roles = "teacher,admin")]
  402. [HttpPost("save-art")]
  403. [AuthToken(Roles = "teacher,admin")]
  404. #if !DEBUG
  405. [Authorize(Roles = "IES")]
  406. #endif
  407. public async Task<IActionResult> SaveArt(JsonElement request)
  408. {
  409. try
  410. {
  411. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  412. if (!request.TryGetProperty("art", out JsonElement art)) return BadRequest();
  413. if (!request.TryGetProperty("artExam", out JsonElement artExam)) return BadRequest();
  414. var client = _azureCosmos.GetCosmosClient();
  415. var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
  416. List<string> baseIds = new();
  417. if (request.TryGetProperty("schoolId", out JsonElement schoolId))
  418. {
  419. baseIds = schoolId.ToObject<List<string>>();
  420. }
  421. else
  422. {
  423. //获取区级以下所有学校编码和基础信息
  424. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  425. {
  426. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  427. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  428. {
  429. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  430. while (accounts.MoveNext())
  431. {
  432. JsonElement account = accounts.Current;
  433. baseIds.Add(account.GetProperty("id").GetString());
  434. }
  435. }
  436. }
  437. }
  438. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  439. List<ArtEvaluation> arts = new();
  440. ArtEvaluation areaArt = art.ToObject<ArtEvaluation>();
  441. areaArt.owner = "area";
  442. areaArt.ttl = -1;
  443. areaArt.scope = "school";
  444. areaArt.code = "Art-" + id.GetString();
  445. areaArt.createTime = now;
  446. areaArt.creatorId = userid;
  447. areaArt.progress = "pending";
  448. if (string.IsNullOrEmpty(areaArt.id))
  449. {
  450. areaArt.id = Guid.NewGuid().ToString();
  451. }
  452. //智音部分内容 区级部分关联 id 校级pId
  453. if (request.TryGetProperty("ArtMusic", out JsonElement music))
  454. {
  455. ArtMusic artMusic = music.ToObject<ArtMusic>();
  456. artMusic.code = "ArtMusic";
  457. artMusic.ttl = -1;
  458. artMusic.id = areaArt.id;
  459. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(artMusic, new PartitionKey("ArtMusic"));
  460. };
  461. //调整了区级模块发布活动时,内部评测部分数据关联 activityId 作为唯一主键(之前的历史数据无效)
  462. ArtExam aExam = new()
  463. {
  464. id = areaArt.id,
  465. ttl = -1,
  466. code = "ArtExam",
  467. JsonElement = artExam
  468. };
  469. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(aExam, new PartitionKey("ArtExam"));
  470. foreach (string scId in baseIds)
  471. {
  472. ArtEvaluation ae = art.ToObject<ArtEvaluation>();
  473. ae.areaId = id.GetString();
  474. ae.school = scId;
  475. ae.owner = "area";
  476. ae.ttl = -1;
  477. ae.code = "Art-" + scId;
  478. ae.createTime = now;
  479. ae.creatorId = userid;
  480. ae.publish = 1;
  481. ae.progress = "pending";
  482. ae.pId = areaArt.id;
  483. ae.scope = "school";
  484. if (string.IsNullOrEmpty(ae.id))
  485. {
  486. ae.id = Guid.NewGuid().ToString();
  487. await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(ae, new PartitionKey($"{ae.code}"));
  488. }
  489. else
  490. {
  491. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(ae, new PartitionKey($"{ae.code}"));
  492. }
  493. arts.Add(ae);
  494. }
  495. //areaStudy.targets = allName;
  496. /* var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
  497. areaStudy.targets = atn;*/
  498. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaArt, new PartitionKey($"{areaArt.code}"));
  499. //var ids = studies.Select(s => new { s.id, s.school, s.examId, s.surveyId });
  500. return Ok(new { code = (int)HttpStatusCode.OK, arts });
  501. }
  502. catch (Exception ex)
  503. {
  504. await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-art()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  505. return BadRequest();
  506. }
  507. }
  508. [ProducesDefaultResponseType]
  509. //[AuthToken(Roles = "teacher,admin")]
  510. [HttpPost("find-school")]
  511. [AuthToken(Roles = "teacher,admin,student")]
  512. #if !DEBUG
  513. [Authorize(Roles = "IES")]
  514. #endif
  515. public async Task<IActionResult> findSchool(JsonElement request)
  516. {
  517. try
  518. {
  519. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  520. var client = _azureCosmos.GetCosmosClient();
  521. var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
  522. //获取区级以下所有学校编码和基础信息
  523. List<(string id, string name, string type)> baseIds = new();
  524. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name ,A0.periodType as type FROM c join A0 in c.period where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  525. {
  526. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  527. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  528. {
  529. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  530. while (accounts.MoveNext())
  531. {
  532. JsonElement account = accounts.Current;
  533. if (account.TryGetProperty("type", out JsonElement pType))
  534. {
  535. baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), pType.GetString()));
  536. }
  537. else
  538. {
  539. baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), ""));
  540. }
  541. }
  542. }
  543. }
  544. var sc = baseIds.GroupBy(c => (c.id, c.name)).Select(x => new
  545. {
  546. x.Key.id,
  547. x.Key.name,
  548. period = x.ToList().Where(p => !string.IsNullOrWhiteSpace(p.type)).Select(z => z.type)
  549. });
  550. return Ok(new { code = (int)HttpStatusCode.OK, sc });
  551. }
  552. catch (Exception ex)
  553. {
  554. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-school()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  555. return BadRequest();
  556. }
  557. }
  558. /// <param name="request"></param>
  559. /// <returns></returns>
  560. [ProducesDefaultResponseType]
  561. [AuthToken(Roles = "teacher,admin,student")]
  562. #if !DEBUG
  563. [Authorize(Roles = "IES")]
  564. #endif
  565. [HttpPost("find-all-study")]
  566. public async Task<IActionResult> FindAllStudy(JsonElement request)
  567. {
  568. try
  569. {
  570. //区级Id
  571. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  572. var client = _azureCosmos.GetCosmosClient();
  573. // List<string> baseIds = await getId(client, id.GetString());
  574. List<object> studies = new();
  575. var query = $"select c.id,c.img,c.name,c.type,c.startTime,c.endTime,c.presenter,c.topic,c.address,c.owner,c.school from c ";
  576. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{id}") }))
  577. {
  578. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  579. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  580. {
  581. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  582. {
  583. studies.Add(obj.ToObject<object>());
  584. }
  585. }
  586. }
  587. return Ok(new { studies });
  588. }
  589. catch (Exception e)
  590. {
  591. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-study()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  592. return BadRequest();
  593. }
  594. }
  595. [ProducesDefaultResponseType]
  596. [Authorize(Roles = "IES")]
  597. [AuthToken(Roles = "teacher,admin")]
  598. [HttpPost("find-all-art")]
  599. public async Task<IActionResult> FindAllArt(JsonElement request)
  600. {
  601. try
  602. {
  603. //区级Id
  604. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  605. var client = _azureCosmos.GetCosmosClient();
  606. // List<string> baseIds = await getId(client, id.GetString());
  607. List<(string id, string name, long stime, long etime)> artMore = new();
  608. List<string> pIds = new();
  609. List<(string id, string code, string pd)> artsSchools = new();
  610. var query = $"select c.id,c.name,c.startTime,c.endTime from c order by c.createTime desc";
  611. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{id}") }))
  612. {
  613. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  614. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  615. {
  616. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  617. {
  618. artMore.Add((obj.GetProperty("id").ToString(), obj.GetProperty("name").ToString(), obj.GetProperty("startTime").GetInt64(), obj.GetProperty("endTime").GetInt64()));
  619. pIds.Add(obj.GetProperty("id").ToString());
  620. }
  621. }
  622. }
  623. if (pIds.Any())
  624. {
  625. var querySchool = $"select c.id,c.school,c.pId from c where c.pk = 'Art' and c.pId in ({string.Join(",", pIds.Select(o => $"'{o}'"))})";
  626. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: querySchool))
  627. {
  628. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  629. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  630. {
  631. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  632. {
  633. artsSchools.Add((obj.GetProperty("id").ToString(), obj.GetProperty("school").ToString(), obj.GetProperty("pId").ToString()));
  634. }
  635. }
  636. }
  637. var artSc = artsSchools.Select(x => new
  638. {
  639. x.id,
  640. x.code,
  641. x.pd
  642. });
  643. var arts = artMore.Select(x => new
  644. {
  645. x.id,
  646. x.name,
  647. startTime = x.stime,
  648. endTime = x.etime,
  649. sc = artSc.Where(c => c.pd.Equals(x.id)).Select(p => new { p.id, p.code })
  650. });
  651. return Ok(new { arts });
  652. }
  653. else
  654. {
  655. return Ok(new { arts = new List<dynamic> { } });
  656. }
  657. }
  658. catch (Exception e)
  659. {
  660. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  661. return BadRequest();
  662. }
  663. }
  664. [ProducesDefaultResponseType]
  665. [Authorize(Roles = "IES")]
  666. [AuthToken(Roles = "teacher,admin")]
  667. [HttpPost("find-area-art")]
  668. public async Task<IActionResult> FindArt(JsonElement request)
  669. {
  670. //区级Id
  671. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  672. if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
  673. try
  674. {
  675. var client = _azureCosmos.GetCosmosClient();
  676. List<ArtEvaluation> arts = new();
  677. //SELECT top 1 * FROM c order by c.createTime desc
  678. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<ArtEvaluation>(queryText: $"SELECT value(c) FROM c where c.periodType = '{periodType}' order by c.createTime desc", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{id}") }))
  679. {
  680. arts.Add(item);
  681. }
  682. return Ok(arts);
  683. }
  684. catch (Exception e)
  685. {
  686. return BadRequest(new { code = 500 });
  687. }
  688. }
  689. [ProducesDefaultResponseType]
  690. [Authorize(Roles = "IES")]
  691. [AuthToken(Roles = "teacher,admin")]
  692. [HttpPost("analysis-area-art")]
  693. public async Task<IActionResult> FindAreaArt(JsonElement request)
  694. {
  695. try
  696. {
  697. //区级Id
  698. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  699. if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
  700. if (!request.TryGetProperty("art", out JsonElement artInfo)) return BadRequest();
  701. var client = _azureCosmos.GetCosmosClient();
  702. ArtEvaluation art = artInfo.ToObject<ArtEvaluation>();
  703. List<(string id, string name,string picture, List<Period> periods)> baseInfo = new();
  704. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name,c.period,c.picture from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  705. {
  706. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  707. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  708. {
  709. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  710. while (accounts.MoveNext())
  711. {
  712. JsonElement account = accounts.Current;
  713. List<Period> pd = account.GetProperty("period").ToObject<List<Period>>();
  714. baseInfo.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString(), pd));
  715. }
  716. }
  717. }
  718. ArtSetting setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<ArtSetting>($"{id}", partitionKey: new PartitionKey("ArtSetting"));
  719. //SELECT top 1 * FROM c order by c.createTime desc
  720. //await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<ArtEvaluation>(queryText: $"SELECT top 1 * FROM c where c.periodType = '{periodType}' order by c.createTime desc", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{id}") }))
  721. //{
  722. // arts.Add(item);
  723. //}
  724. List<(string id, string code, List<string> classes, List<Tasks> settings)> artSchools = new();
  725. if (art != null)
  726. {
  727. string ql = $"select c.id,c.school,c.settings,c.classes from c where c.pk = 'Art' and c.pId = '{art.id}'";
  728. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: ql))
  729. {
  730. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  731. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  732. {
  733. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  734. while (accounts.MoveNext())
  735. {
  736. JsonElement account = accounts.Current;
  737. List<Tasks> settings = account.GetProperty("settings").ToObject<List<Tasks>>();
  738. List<string> classIds = account.GetProperty("classes").ToObject<List<string>>();
  739. artSchools.Add((account.GetProperty("id").GetString(), account.GetProperty("school").GetString(), classIds, settings));
  740. }
  741. }
  742. }
  743. }
  744. else
  745. {
  746. return Ok(new { msg = "暂无数据", code = 400 });
  747. }
  748. var ped = baseInfo.Select(x => x.periods).ToList();
  749. var scode = baseInfo.MaxBy(x => x.periods.Count);
  750. List<string> perxId = new();
  751. List<string> percId = new();
  752. List<(string ptype, string pId, string name)> perInfos = new();
  753. foreach (var scpd in ped)
  754. {
  755. foreach (var per in scpd)
  756. {
  757. if (null != per.periodType && per.periodType.Equals(periodType.GetString()))
  758. {
  759. perInfos.Add((per.periodType, per.id, per.name));
  760. }
  761. }
  762. }
  763. var periods = perInfos.GroupBy(g => g.ptype).Select(x => new { key = x.Key, list = x.Select(z => z.pId).ToList() }).Where(c => !string.IsNullOrWhiteSpace(c.key));
  764. List<(string ptype, List<string> scs, string type)> baseMore = new();
  765. List<(string ptype, int scCount, int classCount, int subjectCount, int stuCount)> pCount = new();
  766. List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> kno = new();
  767. List<(string perName, double stuCount, double realCount, double lostCount)> stuCounts = new();
  768. foreach (var ps in periods)
  769. {
  770. //各个学校 学段学生人数
  771. List<string> stus = await getStudentsAsync(ps.list, client, "Base", "Student");
  772. //班级总数
  773. List<string> classes = await getStudentsAsync(ps.list, client, "Class", "School");
  774. baseMore.Add((ps.key, stus, "Student"));
  775. baseMore.Add((ps.key, classes, "Class"));
  776. pCount.Add((ps.key, ps.list.Count, classes.Count, 2, stus.Count));
  777. /* //先获取不同学段和科目的知识占比
  778. foreach (var artSubject in art.subjects)
  779. {
  780. kno.Add(await getKnowledge(ps.key, "hbcn", client, artSubject.id, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
  781. }*/
  782. }
  783. //全校通用一套试卷时
  784. //先获取不同学段和科目的知识占比
  785. string pId = perInfos.Where(c => c.ptype.Equals(periodType.GetString()))?.FirstOrDefault().pId;
  786. foreach (var artSubject in art.subjects)
  787. {
  788. kno.Add(await getKnowledge(periodType.GetString(), "hbcn", client, artSubject.id, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
  789. }
  790. var areaSchool = pCount.Select(x => new
  791. {
  792. x.ptype,
  793. x.scCount,
  794. x.classCount,
  795. x.subjectCount,
  796. x.stuCount
  797. }).FirstOrDefault();
  798. List<(string code, string perName, string subjectId, List<(string name, double score, List<string> dim)> blocks, List<(string name, double score, List<string> kno)> knos, double stand)> blocks = new();
  799. List<(List<string> classes, string classId, string code, string artId, string examId, List<ArtSubjectScore> ac)> subjecScore = new();
  800. List<(string perName, string subject, Dictionary<int, int> keys)> pairs = new();
  801. List<ExamResult> exams = new();
  802. await foreach (var ss in schoolTask(artSchools, client, baseInfo, art, setting, kno))
  803. {
  804. subjecScore.AddRange(ss.subjecScore);
  805. blocks.AddRange(ss.blocks);
  806. pairs.AddRange(ss.opt);
  807. stuCounts.AddRange(ss.stuCounts);
  808. //exams.AddRange(ss.exams);
  809. }
  810. List<(dynamic key1, dynamic key2)> periodInfos = new();
  811. var bm = baseMore.Where(c => c.type.Equals("Class"));
  812. int scCount = 0;
  813. foreach (var (ptype, scs, type) in bm)
  814. {
  815. var psc = subjecScore.Where(c => scs.Contains(c.classId)).Select(x => new { x.classes, x.code, x.artId, x.examId, x.ac });
  816. if (!psc.Any())
  817. {
  818. continue;
  819. }
  820. var pScore = psc.SelectMany(z => z.ac).GroupBy(x => x.subjectId).Select(c => new { subjectId = c.Key, scores = c.ToList().Select(a => a.score) });
  821. var psubjectSchool = pScore.GroupBy(g => g.subjectId).Select(x => new
  822. {
  823. x.Key,
  824. score = x.ToList().SelectMany(c => c.scores).ToList().Where(c => c > 0),
  825. count = x.ToList().SelectMany(c => c.scores).Where(c => c > 0).Count()
  826. });
  827. var psubject = psubjectSchool.Select(x => new
  828. {
  829. perName = ptype,
  830. name = x.Key,
  831. max = x.score.Any() ? x.score.Max(s => s) : 0,
  832. min = x.score.Any() ? x.score.Min(s => s) : 0,
  833. excellent = x.score.Any() ? Math.Round(x.score.Where(s => s >= 80).Count() * 1.0 / x.count, 2) : 0,
  834. pass = x.score.Any() ? Math.Round(x.score.Where(s => s >= 60).Count() * 1.0 / x.count, 2) : 0,
  835. average = x.score.Any() ? Math.Round(x.score.Sum() * 1.0 / x.count, 2) : 0
  836. });
  837. var pschoolScore = psc.GroupBy(g => (g.code, g.artId, g.examId, g.classes)).Select(x => new
  838. {
  839. perName = ptype,
  840. perCname = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z => null != z.periodType && z.periodType.Equals(ptype)).FirstOrDefault()?.name,
  841. baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().name,
  842. baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().picture,
  843. x.Key.artId,
  844. x.Key.examId,
  845. x.Key.code,
  846. x.Key.classes,
  847. perId = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z => null != z.periodType && z.periodType.Equals(ptype)).FirstOrDefault()?.id,
  848. semester = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z =>
  849. null != z.periodType && z.periodType.Equals(ptype)).Select(z => z.semesters).ToList(),
  850. time = art.createTime,
  851. scores = x.ToList().SelectMany(z => z.ac).GroupBy(x => x.subjectId).Select(c => new
  852. {
  853. subjectId = c.Key,
  854. scores = c.ToList().Select(a => a.score).Where(c => c > 0)
  855. }).GroupBy(g => g.subjectId).Select(n => new
  856. {
  857. subjectId = n.Key,
  858. max = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? n.ToList().SelectMany(c => c.scores).ToList().Max(s => s) : 0,
  859. min = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? n.ToList().SelectMany(c => c.scores).ToList().Min(s => s) : 0,
  860. excellent = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(n.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 80).Count() * 1.0 / n.ToList().SelectMany(c => c.scores).ToList().Count, 2) : 0,
  861. pass = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(n.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 60).Count() * 1.0 / n.ToList().SelectMany(c => c.scores).ToList().Count, 2): 0,
  862. average = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(n.ToList().SelectMany(c => c.scores).ToList().Sum() * 1.0 / n.ToList().SelectMany(c => c.scores).ToList().Count, 2) : 0
  863. })
  864. });
  865. scCount = pschoolScore.Count();
  866. periodInfos.Add((psubject, pschoolScore));
  867. }
  868. var periodAll = periodInfos.Select(x => new
  869. {
  870. subject = x.key1,
  871. schoolScore = x.key2
  872. }).FirstOrDefault();
  873. var block = blocks.GroupBy(c => c.perName).Select(x => new
  874. {
  875. school = x.Key,
  876. list = x.ToList().Select(b => new
  877. {
  878. b.code,
  879. b.subjectId,
  880. blk = b.blocks.Select(k => new
  881. {
  882. k.name,
  883. k.score,
  884. k.dim
  885. }),
  886. kn = b.knos.Select(n => new { n.name, n.score, n.kno }),
  887. b.stand
  888. })
  889. });
  890. var allBlock = block.Select(x => new
  891. {
  892. x.school,
  893. sub = x.list.GroupBy(c => c.subjectId).Select(z => new
  894. {
  895. z.Key,
  896. blk = z.ToList().Select(b => b.blk).ToList()[0],
  897. sl = z.ToList().Select(v => v.kn).SelectMany(r => r).GroupBy(a => a.name).Select(t => new
  898. {
  899. t.Key,
  900. kno = t.ToList().Select(k => k.kno).ToList()[0],
  901. scores = Math.Round(t.ToList().Select(l => l.score).ToList().Sum() * 1.0 / scCount, 2)
  902. }),
  903. stand = Math.Round(z.ToList().Sum(c => c.stand) * 1.0 / scCount, 2)
  904. })
  905. }).FirstOrDefault();
  906. var keys = pairs.Select(x => x.keys).ToList();
  907. bool flag = false;
  908. foreach (var op in keys)
  909. {
  910. if (op.Count > 0)
  911. {
  912. flag = true;
  913. break;
  914. }
  915. }
  916. var opt = pairs.GroupBy(p => p.perName).Select(s => new
  917. {
  918. per = s.Key,
  919. subject = s.ToList().Select(m => new { m.subject, m.keys }).GroupBy(c => c.subject).Select(z => new
  920. {
  921. sub = z.Key,
  922. key = flag ? z.ToList().Select(y => y.keys) : null
  923. //key = z.ToList().Select(y => y.keys)
  924. })
  925. }).FirstOrDefault();
  926. /*var perStuCounts = stuCounts.Select(x => new {
  927. x.perName,
  928. x.stuCount,
  929. x.realCount,
  930. x.lostCount
  931. });*/
  932. var perStuCounts = stuCounts.GroupBy(x => x.perName).Select(c => new { per = c.Key, stuCount = c.Sum(z => z.stuCount), realCount = c.Sum(n => n.realCount), lostCount = c.Sum(q => q.lostCount) });
  933. var classCount = artSchools.SelectMany(c => c.classes).ToList().Count;
  934. //var pow = exams.GroupBy(x => x.subjectId).Select(z => new { sub = z.Key,students = z.SelectMany(c => c.studentScores)});
  935. return Ok(new { areaSchool, allBlock, opt, periodAll, perStuCounts, classCount });
  936. }
  937. catch (Exception e)
  938. {
  939. await _dingDing.SendBotMsg($"OS,{_option.Location},area/analysis-area-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  940. return BadRequest();
  941. }
  942. }
  943. private async IAsyncEnumerable<(string code, List<(List<string> classes, string classId, string code, string artId, string fId, List<ArtSubjectScore> ac)> subjecScore,
  944. List<(string code, string perName, string subjectId, List<(string name, double score, List<string> dim)> blocks, List<(string name, double score, List<string> kno)> knos, double stand)> blocks,
  945. List<(string perName, string subject, Dictionary<int, int> keys)> opt, List<(string perName, double stuCount, double realCount, double lostCount)> stuCounts)> schoolTask(List<(string id, string code, List<string> classes,
  946. List<Tasks> settings)> artSchools, CosmosClient client, List<(string id, string name, string pic,List<Period> periods)> baseInfo, ArtEvaluation art, ArtSetting setting,
  947. List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> spId)
  948. {
  949. long time = art.startTime;
  950. var stime = DateTimeOffset.FromUnixTimeMilliseconds(time);
  951. int month = stime.Month;
  952. int day = stime.Day;
  953. List<ExamResult> exams = new();
  954. foreach (var (id, code, classes, settings) in artSchools)
  955. {
  956. string fId = settings.SelectMany(s => s.task).Where(a => a.type == 1).FirstOrDefault().acId;
  957. string queryScore = $" select c.studentId,c.classIds,c.totalScore,c.artId,c.subjectScores,c.results from c ";
  958. List<(List<string> classIds, string classId, string code, string artId, string fId, List<ArtSubjectScore> ac)> As = new();
  959. List<List<ArtQuotaResult>> results = new();
  960. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIterator
  961. (queryText: queryScore, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"ArtResult-{id}") }))
  962. {
  963. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  964. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  965. {
  966. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  967. {
  968. if (obj.TryGetProperty("subjectScores", out JsonElement subScore))
  969. {
  970. string sId = obj.GetProperty("studentId").GetString();
  971. string artId = obj.GetProperty("artId").GetString();
  972. string classId = obj.GetProperty("classIds").ToObject<List<string>>()[0];
  973. List<ArtSubjectScore> sc = subScore.ToObject<List<ArtSubjectScore>>();
  974. As.Add((classes, classId, code, artId, fId, sc));
  975. }
  976. else
  977. {
  978. As.Add((new List<string>(), "", code, "", fId, new List<ArtSubjectScore>()));
  979. }
  980. results.Add(obj.GetProperty("results").ToObject<List<ArtQuotaResult>>());
  981. }
  982. }
  983. }
  984. /* var sbScore = As.GroupBy(x => x.subjectId).Select(c => new { subjectId = c.Key, list = c.ToList().Select(a => a.score) });
  985. List<(string suject,string code, List<double> scores)> scs = new();
  986. foreach (var subjectScore in sbScore)
  987. {
  988. scs.Add((subjectScore.subjectId, code,subjectScore.list.ToList()));
  989. }*/
  990. //List<(string subId, List<(string name, List<string> kno)> values)> bk = new();
  991. var pers = baseInfo.Where(x => x.id.Equals(code)).FirstOrDefault().periods;
  992. List<(string sb, string pId)> pn = new();
  993. List<(string code, string perName, string subjectId, List<(string name, double score, List<string> dim)> blocks, List<(string name, double score, List<string> kno)> knos, double stand)> perMore = new();
  994. List<(string perName, string subject, Dictionary<int, int> keys)> opt = new();
  995. List<(string perName, double stuCount, double realCount, double lostCount)> stuCounts = new();
  996. foreach (var perId in pers)
  997. {
  998. List<ExamResult> resultAll = new();
  999. if (null != perId.periodType && !perId.periodType.Equals(art.periodType)) continue;
  1000. foreach (var sj in art.subjects)
  1001. {
  1002. List<(string name, List<string> kno)> knos = new();
  1003. knos = spId.Where(s => s.subId.Equals(sj.id) && s.ptype.Equals(perId.periodType)).FirstOrDefault().knos;
  1004. if (null == knos || !knos.Any()) { continue; }
  1005. else
  1006. {
  1007. var examId = settings.SelectMany(s => s.task).Where(a => a.type == 1 && a.subject.Equals(sj.id)).FirstOrDefault().acId;
  1008. if (string.IsNullOrWhiteSpace(examId)) { continue; }
  1009. List<ExamResult> examResults = new();
  1010. List<KeyValuePair<string, List<(string name, double score)>>> pointPersent = new();
  1011. ExamInfo info = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemAsync<ExamInfo>(examId.ToString(), new PartitionKey($"Exam-{code}"));
  1012. var query = $"select c.id,c.name,c.subjectId,c.studentScores,c.studentIds,c.paper,c.classes,c.sRate,c.average,c.standard,c.lostStus,c.record,c.phc,c.plc from c where c.examId = '{examId}' and c.subjectId = '{sj.id}' ";
  1013. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<ExamResult>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ExamResult-{examId}") }))
  1014. {
  1015. resultAll.Add(item);
  1016. examResults.Add(item);
  1017. //exams.Add(item);
  1018. }
  1019. if (!examResults.Any())
  1020. {
  1021. continue;
  1022. }
  1023. (KeyValuePair<string, List<string>> key1, KeyValuePair<string, List<string>> key2, KeyValuePair<string, List<(string name, double score)>> key3, KeyValuePair<string, List<(string name, double score)>> key4) = DoKnowledgePoint(examResults[0]);
  1024. pointPersent.Add(key3);
  1025. List<(string name, double score)> blockScore = new();
  1026. foreach (var block in knos)
  1027. {
  1028. double sc = 0;
  1029. foreach (var no in pointPersent)
  1030. {
  1031. foreach (var (name, score) in no.Value)
  1032. {
  1033. if (null != block.kno && block.kno.Contains(name))
  1034. {
  1035. sc += score;
  1036. }
  1037. }
  1038. }
  1039. blockScore.Add((block.name, sc));
  1040. }
  1041. var blk = blockScore.Select(x => new
  1042. {
  1043. x.name,
  1044. x.score,
  1045. dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
  1046. });
  1047. List<(string name, double score, List<string> dim)> blocks = new();
  1048. foreach (var bk in blk)
  1049. {
  1050. blocks.Add((bk.name, bk.score, bk.dimension.ToList()));
  1051. }
  1052. var kno = key4.Value.Select(x => new
  1053. {
  1054. x.name,
  1055. x.score,
  1056. block = knos.Where(v => null != v.kno && v.kno.Contains(x.name)).Select(x => x.name)
  1057. });
  1058. List<(string name, double score, List<string> dim)> knoMore = new();
  1059. foreach (var bk in kno)
  1060. {
  1061. knoMore.Add((bk.name, bk.score, bk.block.ToList()));
  1062. }
  1063. perMore.Add((code, perId.periodType, sj.id, blocks, knoMore, examResults[0].standard));
  1064. }
  1065. //获奖次数
  1066. List<ArtAttachment> artAttachments = new();
  1067. string sqlTask = $"select value(c) from c where c.artId = '{id}' and c.subjectId = '{sj.id}'";
  1068. await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Student).
  1069. GetItemQueryIterator<ArtAttachment>(queryText: sqlTask, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"ArtAttachment-{code}") }))
  1070. {
  1071. artAttachments.Add(item);
  1072. }
  1073. List<List<string>> tag = new();
  1074. List<int> level = artAttachments.Where(z => z.level > -1).Select(c => c.level).ToList();
  1075. /* artAttachments.ForEach(r =>
  1076. {
  1077. if (r.files.Count > 0)
  1078. {
  1079. tag.AddRange(r.files.Select(c => c.tag).ToList());
  1080. }
  1081. });
  1082. List<string> newTag = new();
  1083. tag.ForEach(t =>
  1084. {
  1085. if (t.Count > 0)
  1086. {
  1087. newTag.AddRange(t);
  1088. }
  1089. });*/
  1090. Dictionary<int, int> optCount = new();
  1091. foreach (var s in level)
  1092. {
  1093. if (optCount.ContainsKey(s))
  1094. {
  1095. optCount[s] = optCount[s] + 1;
  1096. }
  1097. else
  1098. {
  1099. optCount[s] = 1;
  1100. }
  1101. }
  1102. opt.Add((perId.periodType, sj.id, optCount));
  1103. }
  1104. var all = resultAll.SelectMany(x => x.studentIds).ToList();
  1105. var lost = resultAll.SelectMany(x => x.lostStus).ToList();
  1106. var AllCount = all.Where((x, i) => all.FindIndex(z => z == x) == i).ToList().Count;
  1107. //缺考去重
  1108. var lostCount = lost.Where((x, i) => lost.FindIndex(z => z == x) == i).ToList().Count;
  1109. var realLost = lost.Count - lostCount;
  1110. stuCounts.Add((perId.periodType, AllCount, AllCount - realLost, realLost));
  1111. }
  1112. yield return (code, As, perMore, opt, stuCounts);
  1113. }
  1114. }
  1115. [ProducesDefaultResponseType]
  1116. [Authorize(Roles = "IES")]
  1117. [AuthToken(Roles = "teacher,admin")]
  1118. [HttpPost("get-all-knowledge")]
  1119. public async Task<IActionResult> getAllClassKnowledge(JsonElement request)
  1120. {
  1121. //区级ID
  1122. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  1123. //学段类型
  1124. if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
  1125. var client = _azureCosmos.GetCosmosClient();
  1126. //TODO 这里目前根据时间查询同一批次的考试内容,需要换成其他条件
  1127. string sql = "SELECT c.id FROM c where c.pk = 'Art' and (c.startTime = 1678978800000 or c.startTime = 1678982400000) and c.endTime = 1684382400000";
  1128. List<string> superIds = new();
  1129. ArtSetting setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<ArtSetting>($"{id}", partitionKey: new PartitionKey("ArtSetting"));
  1130. //获取区级本次发布任务获得所有活动ID集合
  1131. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Common).GetItemQueryStreamIterator(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Art-{id}") }))
  1132. {
  1133. using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
  1134. if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1135. {
  1136. foreach (var obj in sjson.RootElement.GetProperty("Documents").EnumerateArray())
  1137. {
  1138. if (obj.TryGetProperty("id", out JsonElement superId))
  1139. {
  1140. string sId = superId.GetString();
  1141. superIds.Add(sId);
  1142. }
  1143. }
  1144. }
  1145. }
  1146. if (superIds.Count > 0) {
  1147. //改版内容
  1148. //获取区级下面所有的学校信息
  1149. List<(string code, string name, List<Period> pd)> schoolBase = new();
  1150. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.School).GetItemQueryStreamIterator(queryText: $"select c.id,c.name,c.period from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Base") }))
  1151. {
  1152. using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
  1153. if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1154. {
  1155. foreach (var obj in sjson.RootElement.GetProperty("Documents").EnumerateArray())
  1156. {
  1157. if (obj.TryGetProperty("id", out JsonElement scId) && obj.TryGetProperty("name", out JsonElement scname))
  1158. {
  1159. List<Period> pd = obj.GetProperty("period").ToObject<List<Period>>();
  1160. schoolBase.Add((scId.GetString(), scname.GetString(), pd));
  1161. }
  1162. }
  1163. }
  1164. }
  1165. /* var ped = schoolBase.Select(x => x.pd).ToList();
  1166. List<(string ptype, string pId, string name)> perInfos = new();
  1167. foreach (var scpd in ped)
  1168. {
  1169. foreach (var per in scpd)
  1170. {
  1171. if (null != per.periodType && per.periodType.Equals(periodType.GetString()))
  1172. {
  1173. perInfos.Add((per.periodType, per.id, per.name));
  1174. }
  1175. }
  1176. }*/
  1177. //var periods = perInfos.GroupBy(g => g.ptype).Select(x => new { key = x.Key, list = x.Select(z => z.pId).ToList() }).Where(c => !string.IsNullOrWhiteSpace(c.key));
  1178. List<(string ptype, List<string> scs, string type)> baseMore = new();
  1179. List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> knoledge = new();
  1180. List<string> subs = new List<string> { "subject_painting", "subject_music" };
  1181. foreach (var ss in subs)
  1182. {
  1183. knoledge.Add(await getKnowledge(periodType.GetString(), "hbcn", client, ss, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
  1184. }
  1185. //获取当前学段的知识点关系
  1186. //List<(string name, List<string> kno)> knos = new();
  1187. var knos = knoledge.Where(s => s.ptype.Equals(periodType.GetString())).SelectMany(c => c.knos).ToList();
  1188. //获取区级下面所有活动发布后的活动信息
  1189. List<ArtEvaluation> arts = new();
  1190. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Common).GetItemQueryIterator<ArtEvaluation>(queryText: $"select value(c) from c where c.pk = 'Art' and c.periodType = '{periodType}' and c.pId in ({string.Join(",", superIds.Select(o => $"'{o}'"))})"))
  1191. {
  1192. arts.Add(item);
  1193. }
  1194. var examIds = arts.SelectMany(c => c.settings).Where(z => z.id.Equals("quota_21")).SelectMany(x => x.task).Select(d => d.acId).ToList();
  1195. //获取区级本次发布任务获得所有活动结算结果表
  1196. List<ExamResult> results = new();
  1197. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Common).GetItemQueryIterator<ExamResult>(queryText: $"select value(c) from c where c.pk = 'ExamResult' and c.examId in ({string.Join(",", examIds.Select(o => $"'{o}'"))})"))
  1198. {
  1199. results.Add(item);
  1200. }
  1201. var artIds = arts.Select(x => x.id).ToList();
  1202. //获取本次活动全区的得分数据ArtResult
  1203. string queryScore = $" select c.studentId,c.classIds,c.school,c.totalScore,c.artId,c.subjectScores,c.results from c where c.pk = 'ArtResult' and c.artId in ({string.Join(",", artIds.Select(o => $"'{o}'"))}) ";
  1204. List<(string classId, string code, string artId, List<ArtSubjectScore> ac)> As = new();
  1205. List<(List<ArtSubjectScore> scs, string sIds, string cd, string code)> stus = new();
  1206. List<(List<ArtQuotaResult> artQuotas, string code)> artQuotaResults = new();
  1207. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIterator
  1208. (queryText: queryScore))
  1209. {
  1210. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  1211. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1212. {
  1213. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  1214. {
  1215. string schoolCode = obj.GetProperty("school").GetString();
  1216. string sId = obj.GetProperty("studentId").GetString();
  1217. string artId = obj.GetProperty("artId").GetString();
  1218. string classId = obj.GetProperty("classIds").ToObject<List<string>>()[0];
  1219. if (obj.TryGetProperty("subjectScores", out JsonElement subScore))
  1220. {
  1221. List<ArtSubjectScore> sc = subScore.ToObject<List<ArtSubjectScore>>();
  1222. As.Add((classId, schoolCode, artId, sc));
  1223. stus.Add((sc, sId, classId, schoolCode));
  1224. }
  1225. else
  1226. {
  1227. As.Add(("", "", "", new List<ArtSubjectScore>()));
  1228. }
  1229. artQuotaResults.Add((obj.GetProperty("results").ToObject<List<ArtQuotaResult>>(), schoolCode));
  1230. }
  1231. }
  1232. }
  1233. /*//学生信息
  1234. var students = stus.Select(s => new
  1235. {
  1236. id = s.sIds,
  1237. s.scs.FirstOrDefault(x => !string.IsNullOrWhiteSpace(x.subjectId) && x.subjectId.Equals(subjectId.GetString()))?.score,
  1238. tchList.Where(t => t.id.Equals(s.sIds)).FirstOrDefault()?.name,
  1239. classId = s.cd,
  1240. className = examResults[0].classes.Where(c => c.id.Equals(s.cd)).FirstOrDefault()?.name,
  1241. examResults[0].classes.Where(c => c.id.Equals(s.cd)).FirstOrDefault()?.gradeId,
  1242. key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().sta,
  1243. key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().pass,
  1244. key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().stu,
  1245. });*/
  1246. //预处理全区考试结果数据分科目结算
  1247. var subjectScores = As.SelectMany(x => x.ac).GroupBy(c => c.subjectId).Select(c => new
  1248. {
  1249. subjectId = c.Key,
  1250. scores = c.ToList().Select(a => a.score).Where(c => c > 0)
  1251. }).GroupBy(g => g.subjectId).Select(z => new
  1252. {
  1253. name = z.Key,
  1254. max = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? z.ToList().SelectMany(c => c.scores).ToList().Max(s => s) : 0,
  1255. min = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? z.ToList().SelectMany(c => c.scores).ToList().Min(s => s) : 0,
  1256. excellent = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 80).Count() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2) : 0,
  1257. pass = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 60).Count() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2) : 0,
  1258. average = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Sum() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2) : 0,
  1259. perName = periodType.GetString()
  1260. });
  1261. //预处理全区学生落点数据
  1262. List<(string code, string subject, List<(string id, double sta, double pass, string stu)> values)> stuInfos = new();
  1263. foreach (var re in results)
  1264. {
  1265. KeyValuePair<string, List<(string id, double sta, double pass, string stu)>> key = DoSubjectScatter(re);
  1266. stuInfos.Add((re.school, re.subjectId, key.Value));
  1267. }
  1268. List<(string code, List<RMember> tchList, List<RGroupList> classLists)> students = new();
  1269. List<(string code, Dictionary<string, int> optCount)> opt = new();
  1270. List<(string code, List<(string gid, List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc)> gradesc)> gradeScore = new();
  1271. /*foreach (var scBase in schoolBase)
  1272. {
  1273. List<string> classIds = new();
  1274. classIds = As.Where(c => c.code.Equals(scBase.code)).Select(z => z.classId).ToList();
  1275. classIds = classIds.Where((x, i) => classIds.FindIndex(z => z == x) == i).ToList();
  1276. (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, classIds, scBase.code, null);
  1277. students.Add((scBase.code, tchList, classLists));
  1278. List<List<string>> tag = new();
  1279. artQuotaResults.Where(c => c.code.Equals(scBase.code)).Select(z => z.artQuotas).ToList().ForEach(r =>
  1280. {
  1281. tag.AddRange(r.Where(x => null != x.files).SelectMany(f => f.files).Select(c => c.tag).ToList());
  1282. });
  1283. List<string> newTag = new();
  1284. tag.ForEach(t =>
  1285. {
  1286. if (t.Count > 0)
  1287. {
  1288. newTag.AddRange(t);
  1289. }
  1290. });
  1291. //List<Dictionary<string, int>> recorde = new List<Dictionary<string, int>>();
  1292. Dictionary<string, int> optCount = new Dictionary<string, int>();
  1293. foreach (var s in newTag)
  1294. {
  1295. if (optCount.ContainsKey(s))
  1296. {
  1297. optCount[s] = optCount[s] + 1;
  1298. }
  1299. else
  1300. {
  1301. optCount[s] = 1;
  1302. }
  1303. }
  1304. opt.Add((scBase.code, optCount));
  1305. var scStus = stus.Where(c => c.code.Equals(scBase.code)).Select(k => new
  1306. {
  1307. id = k.sIds,
  1308. score = k.scs.GroupBy(z => z.subjectId).Select(p => new
  1309. {
  1310. p.Key,
  1311. p.ToList().FirstOrDefault().score
  1312. }),
  1313. results.SelectMany(a => a.classes).Where(j => j.id.Equals(k.cd)).FirstOrDefault().gradeId
  1314. });
  1315. var scGrades = scStus.GroupBy(c => c.gradeId).Select(x => new {
  1316. gradeId = x.Key,
  1317. score = x.ToList().SelectMany(v => v.score).GroupBy(z => z.Key).Select(p => new {
  1318. p.Key,
  1319. score = Math.Round((double)(p.ToList().Sum(y => y.score) / p.ToList().Where(q => q.score > 0).Count()), 2),
  1320. max = p.ToList().Where(q => q.score > 0).Max(s => Math.Abs((double)s.score)),
  1321. min = p.ToList().Where(q => q.score > 0).Min(s => Math.Abs((double)s.score)),
  1322. excellent = Math.Round(p.ToList().Where(s => s.score >= 80).Count() * 1.0 / p.ToList().Where(q => q.score > 0).Count(), 2),
  1323. pass = Math.Round(p.ToList().Where(s => s.score >= 60).Count() * 1.0 / p.ToList().Where(q => q.score > 0).Count(), 2)
  1324. })
  1325. });
  1326. List<(string gid, List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc)> gradesc = new();
  1327. foreach (var gg in scGrades) {
  1328. List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc = new();
  1329. foreach (var sub in gg.score) {
  1330. subsc.Add((sub.Key,sub.score,sub.max,sub.min,sub.excellent,sub.pass));
  1331. }
  1332. gradesc.Add((gg.gradeId, subsc));
  1333. }
  1334. gradeScore.Add((scBase.code, gradesc));
  1335. }*/
  1336. //处理全区班级
  1337. /*List<(string code, List<(string cId, string name, List<(string subjectId, double sc, double max, double min, double excle, double pass, double ex, double pa, List<double> scs, double average)> subjectMores)> cls)> classInfos = new();
  1338. foreach (var (code, tchList, classLists) in students)
  1339. {
  1340. List<(string cId, string name, List<(string subjectId, double sc, double max, double min, double excle, double pass, double ex, double pa, List<double> scs, double average)> subjectMores)> clsInfo = new();
  1341. foreach (var cls in classLists)
  1342. {
  1343. List<ArtSubjectScore> scores = new();
  1344. foreach (var member in cls.members)
  1345. {
  1346. var sc = stus.Where(c => c.sIds.Equals(member.id))?.FirstOrDefault().scs.ToList();
  1347. scores.AddRange(sc);
  1348. }
  1349. var subjectScore = scores.GroupBy(c => c.subjectId).Select(z => new
  1350. {
  1351. z.Key,
  1352. sc = z.ToList().Sum(a => a.score),
  1353. maxc = z.ToList().Where(p => p.score > 0).Max(s => Math.Abs(s.score)),
  1354. minc = z.ToList().Where(p => p.score > 0).Min(s => Math.Abs(s.score)),
  1355. excellentc = z.ToList().Where(p => p.score > 0).Where(s => s.score >= 80).ToList().Count,
  1356. passc = z.ToList().Where(p => p.score > 0).Where(s => s.score >= 60).ToList().Count,
  1357. ex = Math.Round(z.ToList().Where(p => p.score > 0).Where(s => s.score >= 80).ToList().Count * 1.0 / z.ToList().Where(p => p.score > 0).ToList().Count, 2),
  1358. pa = Math.Round(z.ToList().Where(p => p.score > 0).Where(s => s.score >= 60).ToList().Count * 1.0 / z.ToList().Where(p => p.score > 0).ToList().Count, 2),
  1359. scs = z.ToList().Where(p => p.score > 0).Select(j => j.score).ToList(),
  1360. average = Math.Round(z.ToList().Sum(a => a.score) * 1.0 / z.ToList().Where(p => p.score > 0).ToList().Count, 2)
  1361. });
  1362. List<(string subjectId, double sc, double max, double min, double excle, double pass, double ex, double pa, List<double> scs, double average)> subjectMores = new();
  1363. foreach (var uu in subjectScore)
  1364. {
  1365. subjectMores.Add((uu.Key, uu.sc, uu.maxc, uu.minc, uu.excellentc, uu.passc, uu.ex, uu.pa, uu.scs, uu.average));
  1366. }
  1367. clsInfo.Add((cls.id, cls.name, subjectMores));
  1368. classInfos.Add((code, clsInfo));
  1369. }
  1370. }*/
  1371. List<(List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> values, string subjectId, string examId, string code)> classKnowledge = new();
  1372. await foreach (var persents in DoKnowledgePoint(results, knoledge, setting, periodType.GetString()))
  1373. {
  1374. classKnowledge.Add(persents);
  1375. }
  1376. //区级按学段结算知识点占比
  1377. var areaSubjectPersent = classKnowledge.GroupBy(x => x.subjectId).Select(z => new
  1378. {
  1379. subjectId = z.Key,
  1380. psersent = z.ToList().SelectMany(b => b.values).GroupBy(f => f.knowledgeName).Select(k => new
  1381. {
  1382. know = k.Key,
  1383. block = knos.Where(v => null != v.kno && v.kno.Contains(k.Key)).Select(x => x.name),
  1384. score = Math.Round(k.ToList().Sum(p => p.score) / k.ToList().Count, 2),
  1385. //tscore = k.ToList().Sum(p => p.tscore),
  1386. /*blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
  1387. dim = c.Key,
  1388. score = c.ToList().Sum(o => o.score)
  1389. })*/
  1390. })
  1391. });
  1392. var schoolSubjectPersent = classKnowledge.GroupBy(x => x.code).Select(z => new
  1393. {
  1394. school = z.Key,
  1395. schoolName = schoolBase.Where(c => c.code.Equals(z.Key)).FirstOrDefault().name,
  1396. subject = z.ToList().GroupBy(v => v.subjectId).Select(p => new
  1397. {
  1398. subjectId = p.Key,
  1399. psersent = p.ToList().SelectMany(b => b.values).GroupBy(f => f.knowledgeName).Select(k => new
  1400. {
  1401. know = k.Key,
  1402. block = knos.Where(v => null != v.kno && v.kno.Contains(k.Key)).Select(x => x.name),
  1403. score = Math.Round(k.ToList().Sum(d => d.score) / k.ToList().Count, 2),
  1404. //tscore = k.ToList().Sum(p => p.tscore),
  1405. /*blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
  1406. dim = c.Key,
  1407. score = c.ToList().Sum(o => o.score)
  1408. })*/
  1409. })
  1410. })
  1411. }); ;
  1412. List<(string gid, string gname)> grades = new() { ("1", "八年级"), ("4", "五年级") };
  1413. var gradeSubjectPersent = classKnowledge.GroupBy(x => x.subjectId).Select(z => new
  1414. {
  1415. subjectId = z.Key,
  1416. psersent = z.ToList().SelectMany(b => b.values).GroupBy(f => f.gradeId).Select(k => new
  1417. {
  1418. grade = k.Key,
  1419. gradeName = grades.Where(c => c.gid.Equals(k.Key)).FirstOrDefault().gname,
  1420. knowledge = k.ToList().GroupBy(q => q.knowledgeName).Select(h => new
  1421. {
  1422. know = h.Key,
  1423. block = knos.Where(v => null != v.kno && v.kno.Contains(h.Key)).Select(x => x.name),
  1424. score = Math.Round(h.ToList().Sum(d => d.score) / h.ToList().Count, 2),
  1425. //tscore = k.ToList().Sum(p => p.tscore),
  1426. /* blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
  1427. dim = c.Key,
  1428. score = c.ToList().Sum(o => o.score)
  1429. })*/
  1430. })
  1431. })
  1432. });
  1433. var classPersent = classKnowledge.Select(x => new
  1434. {
  1435. x.subjectId,
  1436. x.examId,
  1437. school = x.code,
  1438. schoolName = schoolBase.Where(c => c.code.Equals(x.code)).FirstOrDefault().name,
  1439. know = x.values.Select(z => new
  1440. {
  1441. z.classId,
  1442. z.className,
  1443. z.knowledgeName,
  1444. block = knos.Where(v => null != v.kno && v.kno.Contains(z.knowledgeName)).Select(x => x.name),
  1445. z.gradeId,
  1446. gradeName = grades.Where(c => c.gid.Equals(z.gradeId)).FirstOrDefault().gname,
  1447. z.score,
  1448. //z.tscore,
  1449. /*blocks = z.blocks.Select(f => new {
  1450. f.name,
  1451. f.score,
  1452. f.dim
  1453. })*/
  1454. })
  1455. });
  1456. var paperIds = results.Select(x => x.paper.id).ToList();
  1457. var pids = paperIds.Where((x, i) => paperIds.FindIndex(z => z == x) == i).ToList();
  1458. List<ExamResult> examResults = new();
  1459. foreach (var p in pids)
  1460. {
  1461. examResults.Add(results.Where(x => x.paper.id.Equals(p)).FirstOrDefault());
  1462. }
  1463. List<(string name, double score, string subject)> blockScore = new();
  1464. foreach (var exam in examResults)
  1465. {
  1466. HashSet<string> knowledge = new HashSet<string>();
  1467. List<double> point = new List<double>();
  1468. List<List<double>> result = new List<List<double>>();
  1469. List<ClassRange> classes = new List<ClassRange>();
  1470. //求单个知识点所占分数
  1471. List<string> per = new List<string>();
  1472. if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
  1473. {
  1474. exam.paper.knowledge.ForEach(k =>
  1475. {
  1476. k.ForEach(e =>
  1477. {
  1478. knowledge.Add(e);
  1479. });
  1480. });
  1481. }
  1482. point = exam.paper.point;
  1483. List<string> knowledgeName = new List<string>();
  1484. foreach (string cla in knowledge)
  1485. {
  1486. knowledgeName.Add(cla);
  1487. }
  1488. for (int k = 0; k < knowledgeName.Count; k++)
  1489. {
  1490. if (null == knowledgeName[k])
  1491. {
  1492. knowledgeName.Remove(knowledgeName[k]);
  1493. }
  1494. }
  1495. List<double> Score = new List<double>();
  1496. List<(string name, double score, string subject)> pointScore = new();
  1497. for (int k = 0; k < knowledgeName.Count; k++)
  1498. {
  1499. double OnePoint = 0;
  1500. List<string> itemNo = new List<string>();
  1501. int n = 0;
  1502. //double scores = 0;
  1503. exam.paper.knowledge.ForEach(kno =>
  1504. {
  1505. if (kno.Contains(knowledgeName[k]))
  1506. {
  1507. var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
  1508. OnePoint += point[n] * itemPersent;
  1509. /*foreach (string id in exam.studentIds)
  1510. {
  1511. int index = exam.studentIds.IndexOf(id);
  1512. if (exam.studentScores[index][n] > 0)
  1513. {
  1514. scores += exam.studentScores[index][n] * itemPersent;
  1515. }
  1516. }*/
  1517. }
  1518. n++;
  1519. });
  1520. blockScore.Add((knowledgeName[k], OnePoint, exam.subjectId));
  1521. //blockScore.AddRange(pointScore);
  1522. }
  1523. }
  1524. var bls = blockScore.GroupBy(x => x.subject).Select(v => new
  1525. {
  1526. subjectId = v.Key,
  1527. knoScore = v.ToList().GroupBy(k => k.name).Select(z => new
  1528. {
  1529. knoName = z.Key,
  1530. score = z.ToList().Sum(j => j.score)
  1531. })
  1532. });
  1533. /*var dimensions = setting.dimensions.Select(x => new
  1534. {
  1535. x.dimension,
  1536. x.blocks,
  1537. x.subjectBind
  1538. });*/
  1539. var subjectKnow = knoledge.Where(c => c.ptype.Equals(periodType.GetString())).Select(x => new { x.subId, x.knos }).ToList();
  1540. List<(string subjectId, List<(string name, double score, List<string> dim)> bks)> bs = new();
  1541. foreach (var bb in subjectKnow)
  1542. {
  1543. var kno1 = bls.Where(c => c.subjectId.Equals(bb.subId)).SelectMany(x => x.knoScore).ToList();
  1544. //var kno2 = dimensions.Where(c => c.subjectBind.Equals(bb.subId)).Select(x => new { x.dimension,x.blocks}).ToList();
  1545. List<(string name, double score)> blockScores = new();
  1546. foreach (var k2 in bb.knos)
  1547. {
  1548. double bsc = 0;
  1549. foreach (var k3 in kno1)
  1550. {
  1551. if (null != k2.kno && k2.kno.Contains(k3.knoName))
  1552. {
  1553. bsc += k3.score;
  1554. }
  1555. }
  1556. blockScores.Add((k2.name, bsc));
  1557. }
  1558. var blk = blockScores.Select(x => new
  1559. {
  1560. x.name,
  1561. x.score,
  1562. dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
  1563. });
  1564. List<(string name, double score, List<string> dim)> bks = new();
  1565. foreach (var bk in blk)
  1566. {
  1567. bks.Add((bk.name, bk.score, bk.dimension.ToList()));
  1568. }
  1569. bs.Add((bb.subId, bks));
  1570. }
  1571. var blocks = bs.Select(x => new
  1572. {
  1573. x.subjectId,
  1574. dim = x.bks.Select(z => new
  1575. {
  1576. z.name,
  1577. z.score,
  1578. z.dim
  1579. })
  1580. });
  1581. //处理区级学校数据
  1582. /* var schoolScore = schoolBase.Select(x => new
  1583. {
  1584. x.code,
  1585. x.name,
  1586. perCname = x.pd.Where(c => c.periodType.Equals(periodType.GetString())).FirstOrDefault()?.name,
  1587. perId = x.pd.Where(c => c.periodType.Equals(periodType.GetString())).FirstOrDefault()?.id,
  1588. perName = periodType.GetString(),
  1589. scores = As.Where(q => q.code.Equals(x.code)).SelectMany(z => z.ac).GroupBy(c => c.subjectId).Select(c => new
  1590. {
  1591. subjectId = c.Key,
  1592. total = c.ToList().Count,
  1593. scores = c.ToList().Select(a => a.score).Where(c => c > 0)
  1594. }).GroupBy(g => g.subjectId).Select(z => new
  1595. {
  1596. count = z.ToList().Select(m => m.total)?.FirstOrDefault(),
  1597. scount = z.ToList().Count,
  1598. blk = blocks.Where(a => a.subjectId.Equals(z.Key))?.FirstOrDefault().dim,
  1599. kno = schoolSubjectPersent.Where(a => a.school.Equals(x.code)).SelectMany(z => z.subject).Where(p => p.subjectId.Equals(z.Key))?.FirstOrDefault().psersent,
  1600. name = z.Key,
  1601. pow = Math.Round(results.Where(c => c.school.Equals(x.code) && c.subjectId.Equals(z.Key)).Sum(z => z.standard) / results.Where(c => c.school.Equals(x.code) && c.subjectId.Equals(z.Key)).ToList().Count, 2),
  1602. max = z.ToList().SelectMany(c => c.scores).ToList().Max(s => s),
  1603. min = z.ToList().SelectMany(c => c.scores).ToList().Min(s => s),
  1604. excellent = Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 80).Count() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2),
  1605. pass = Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Where(s => s >= 60).Count() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2),
  1606. average = Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Sum() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2),
  1607. students = stuInfos.Where(c => c.code.Equals(x.code) && c.subject.Equals(z.Key)).SelectMany(n => n.values).Select(b => new
  1608. {
  1609. b.id,
  1610. classId = stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().cd,
  1611. className = students.Where(k => k.code.Equals(x.code))?.FirstOrDefault().classLists.Where(j => j.id.Equals(stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().cd))?.FirstOrDefault().name,
  1612. students.Where(k => k.code.Equals(x.code))?.FirstOrDefault().tchList.Where(j => j.id.Equals(b.id))?.FirstOrDefault().name,
  1613. stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().scs.Where(j => j.subjectId.Equals(z.Key)).FirstOrDefault().score,
  1614. b.pass,
  1615. b.sta,
  1616. b.stu,
  1617. results.SelectMany(k => k.classes).Where(j => j.id.Equals(stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().cd)).FirstOrDefault().gradeId
  1618. }),
  1619. cInfo = classInfos.Where(c => c.code.Equals(x.code)).FirstOrDefault().cls.Select(k => new
  1620. {
  1621. id = k.cId,
  1622. k.name,
  1623. score = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().average,
  1624. max = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().max,
  1625. min = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().min,
  1626. excellent = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().excle,
  1627. pass = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().pass,
  1628. results.SelectMany(k => k.classes).Where(j => j.id.Equals(k.cId)).FirstOrDefault().gradeId
  1629. }),
  1630. optCount = opt.Where(k => k.code.Equals(x.code))?.FirstOrDefault().optCount,
  1631. grade = gradeScore.Where(k => k.code.Equals(x.code))?.FirstOrDefault().gradesc.Select(e => new {
  1632. e.gid,
  1633. e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().max,
  1634. e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().min,
  1635. e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().pass,
  1636. e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().score,
  1637. e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().excellent,
  1638. })
  1639. })
  1640. });
  1641. try
  1642. {
  1643. foreach (var sc in schoolScore)
  1644. {
  1645. await _azureRedis.GetRedisClient(8).HashSetAsync($"ArtSchool:{sc.code}", $"1684382400000", sc.ToJsonString());
  1646. }
  1647. }
  1648. catch (Exception e)
  1649. {
  1650. await _dingDing.SendBotMsg($"OS,{_option.Location},artSchool/save()\n{e.Message}\n{e.StackTrace}", GroupNames.成都开发測試群組);
  1651. }*/
  1652. return Ok(new { areaSubjectPersent, schoolSubjectPersent, gradeSubjectPersent, classPersent, blocks });
  1653. }
  1654. return Ok(new { code = 404 ,msg = "赞无有效数据"});
  1655. }
  1656. private KeyValuePair<string, List<(string id, double sta, double pass, string stu)>> DoSubjectScatter(ExamResult e)
  1657. {
  1658. double[] point = StringHelper.ListTodouble(e.paper.point);
  1659. double[,] result = StringHelper.ListToDouble(e.studentScores);
  1660. try
  1661. {
  1662. var cdm = new ClouDASMatrix(result, point);
  1663. //学生通过率
  1664. List<double> pass = cdm.ScoringRate;
  1665. //学生稳定度
  1666. List<double> sta = cdm.StabilityRate;
  1667. //落点区域
  1668. List<string> stu = cdm.StuFallArea;
  1669. int i = 0;
  1670. List<(string id, double sta, double pass, string stu)> stus = new();
  1671. e.studentIds.ForEach(s =>
  1672. {
  1673. var stuSta = sta[i] > 1 ? 1 : sta[i];
  1674. stus.Add((s, stuSta, pass[i] * 0.01, stu[i]));
  1675. i++;
  1676. });
  1677. return new KeyValuePair<string, List<(string id, double sta, double pass, string stu)>>(e.subjectId, stus);
  1678. }
  1679. catch (Exception ex)
  1680. {
  1681. BadRequest(ex.Message + ex.StackTrace);
  1682. }
  1683. return default;
  1684. }
  1685. private async IAsyncEnumerable<(List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> values, string subjectId, string examId, string school)> DoKnowledgePoint(List<ExamResult> exams,
  1686. List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> knoledge, ArtSetting setting, string type)
  1687. {
  1688. foreach (var exam in exams)
  1689. {
  1690. HashSet<string> knowledge = new HashSet<string>();
  1691. List<double> point = new List<double>();
  1692. List<List<double>> result = new List<List<double>>();
  1693. List<ClassRange> classes = new List<ClassRange>();
  1694. //求单个知识点所占分数
  1695. List<string> per = new List<string>();
  1696. if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
  1697. {
  1698. exam.paper.knowledge.ForEach(k =>
  1699. {
  1700. k.ForEach(e =>
  1701. {
  1702. knowledge.Add(e);
  1703. });
  1704. });
  1705. }
  1706. point = exam.paper.point;
  1707. result = exam.studentScores;
  1708. classes = exam.classes;
  1709. List<string> knowledgeName = new List<string>();
  1710. foreach (string cla in knowledge)
  1711. {
  1712. if (knowledgeName.Contains(cla.Trim()))
  1713. {
  1714. continue;
  1715. }
  1716. knowledgeName.Add(cla.Trim());
  1717. }
  1718. for (int k = 0; k < knowledgeName.Count; k++)
  1719. {
  1720. if (null == knowledgeName[k])
  1721. {
  1722. knowledgeName.Remove(knowledgeName[k]);
  1723. }
  1724. }
  1725. //初始化年级总分
  1726. double total = 0;
  1727. //处理年级单个知识点得分率
  1728. foreach (List<double> grade in result)
  1729. {
  1730. total += grade.Sum();
  1731. }
  1732. //试卷总分
  1733. /* double TotalPoint = point.Sum();
  1734. List<double> knowScore = new List<double>();*/
  1735. //学生得分情况
  1736. List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> pScore = new();
  1737. for (int k = 0; k < knowledgeName.Count; k++)
  1738. {
  1739. foreach (var cInfo in exam.classes)
  1740. {
  1741. List<(string name, double score)> pointScore = new();
  1742. List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> pointTScore = new();
  1743. int n = 0;
  1744. double OnePoint = 0;
  1745. List<string> itemNo = new List<string>();
  1746. double scores = 0;
  1747. exam.paper.knowledge.ForEach(kno =>
  1748. {
  1749. if (kno.Contains(knowledgeName[k]))
  1750. {
  1751. var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
  1752. OnePoint += point[n] * itemPersent;
  1753. for (int i = cInfo.range[0]; i <= cInfo.range[1]; i++)
  1754. {
  1755. if (exam.studentScores[i][n] > 0)
  1756. {
  1757. scores += exam.studentScores[i][n] * itemPersent;
  1758. }
  1759. }
  1760. }
  1761. n++;
  1762. });
  1763. //该知识点平均得分
  1764. double sc = exam.studentIds.Count > 0 ? Math.Round(scores * 1.0 / (cInfo.range[1] - cInfo.range[0] + 1), 2) : 0;
  1765. double average = sc * 1.5;
  1766. if (average > OnePoint)
  1767. {
  1768. average = sc;
  1769. }
  1770. //知识点班级得分率
  1771. double persent = Math.Round(OnePoint > 0 ? average / OnePoint : 0, 2);
  1772. pointScore.Add((knowledgeName[k], OnePoint));
  1773. /*var kno = knoledge.Where(s => s.subId.Equals(exam.subjectId) && s.ptype.Equals(type)).FirstOrDefault().knos;
  1774. List<(string name, double score)> blockScore = new();
  1775. foreach (var block in kno)
  1776. {
  1777. double bsc = 0;
  1778. foreach (var (name, score) in pointScore)
  1779. {
  1780. if (null != block.kno && block.kno.Contains(name))
  1781. {
  1782. bsc += score;
  1783. }
  1784. }
  1785. blockScore.Add((block.name, bsc));
  1786. }
  1787. var blk = blockScore.Select(x => new
  1788. {
  1789. x.name,
  1790. x.score,
  1791. dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
  1792. });
  1793. List<(string name, double score, List<string> dim)> blocks = new();
  1794. foreach (var bk in blk)
  1795. {
  1796. blocks.Add((bk.name, bk.score, bk.dimension.ToList()));
  1797. }*/
  1798. List<(string name, double score, List<string> dim)> blocks = new();
  1799. pointTScore.Add((knowledgeName[k], cInfo.gradeId, cInfo.id, cInfo.name, persent, OnePoint, blocks));
  1800. pScore.AddRange(pointTScore);
  1801. }
  1802. }
  1803. yield return (pScore, exam.subjectId, exam.examId, exam.school);
  1804. }
  1805. }
  1806. private static async Task<(string key, string subId, List<(string name, List<string> kno)>)> getKnowledge(string key, string school, CosmosClient client, string subjectBid, string pId)
  1807. {
  1808. try
  1809. {
  1810. var response = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(school, new PartitionKey($"Base"));
  1811. string subjectId = string.Empty;
  1812. List<Knowledge> knowledges = new();
  1813. List<(string name, List<string> kno)> blocks = new();
  1814. if (response.Status == 200)
  1815. {
  1816. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  1817. School sc = json.ToObject<School>();
  1818. var subjects = sc.period.Where(p => p.id.Equals(pId)).Select(x => x.subjects);
  1819. foreach (var sj in subjects)
  1820. {
  1821. foreach (var s in sj)
  1822. {
  1823. if (!string.IsNullOrWhiteSpace(s.bindId) && s.bindId.Equals(subjectBid))
  1824. {
  1825. subjectId = s.id;
  1826. }
  1827. }
  1828. }
  1829. string code = $"Knowledge-{school}-{subjectId}";
  1830. StringBuilder sql = new StringBuilder($"select value(c) from c");
  1831. if (string.IsNullOrWhiteSpace(pId))
  1832. {
  1833. sql.Append($" where c.periodId = '{pId}'");
  1834. }
  1835. await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Knowledge>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{code}") }))
  1836. {
  1837. knowledges.Add(item);
  1838. }
  1839. }
  1840. foreach (var know in knowledges)
  1841. {
  1842. foreach (var block in know.blocks)
  1843. {
  1844. blocks.Add((block.name, block.points));
  1845. }
  1846. }
  1847. return (key, subjectBid, blocks);
  1848. }
  1849. catch (Exception e)
  1850. {
  1851. return (null, null, null);
  1852. }
  1853. }
  1854. private static (KeyValuePair<string, List<string>>, KeyValuePair<string, List<string>>, KeyValuePair<string, List<(string name, double score)>>, KeyValuePair<string, List<(string name, double score)>>) DoKnowledgePoint(ExamResult exam)
  1855. {
  1856. HashSet<string> knowledge = new HashSet<string>();
  1857. List<double> point = new List<double>();
  1858. List<List<double>> result = new List<List<double>>();
  1859. List<ClassRange> classes = new List<ClassRange>();
  1860. //求单个知识点所占分数
  1861. List<string> per = new List<string>();
  1862. if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
  1863. {
  1864. exam.paper.knowledge.ForEach(k =>
  1865. {
  1866. k.ForEach(e =>
  1867. {
  1868. knowledge.Add(e);
  1869. });
  1870. });
  1871. }
  1872. else
  1873. {
  1874. return (default, default, default, default);
  1875. }
  1876. point = exam.paper.point;
  1877. List<string> knowledgeName = new List<string>();
  1878. foreach (string cla in knowledge)
  1879. {
  1880. if (knowledgeName.Contains(cla.Trim()))
  1881. {
  1882. continue;
  1883. }
  1884. knowledgeName.Add(cla.Trim());
  1885. }
  1886. for (int k = 0; k < knowledgeName.Count; k++)
  1887. {
  1888. if (null == knowledgeName[k])
  1889. {
  1890. knowledgeName.Remove(knowledgeName[k]);
  1891. }
  1892. }
  1893. //初始化年级总分
  1894. double total = 0;
  1895. //处理年级单个知识点得分率
  1896. foreach (List<double> grade in result)
  1897. {
  1898. total += grade.Sum();
  1899. }
  1900. //试卷总分
  1901. double TotalPoint = point.Sum();
  1902. List<double> knowScore = new List<double>();
  1903. //学生得分情况
  1904. List<double> Score = new List<double>();
  1905. List<(string name, double score)> pointScore = new();
  1906. List<(string name, double score)> pointTScore = new();
  1907. for (int k = 0; k < knowledgeName.Count; k++)
  1908. {
  1909. double OnePoint = 0;
  1910. List<string> itemNo = new List<string>();
  1911. int n = 0;
  1912. double scores = 0;
  1913. exam.paper.knowledge.ForEach(kno =>
  1914. {
  1915. if (kno.Contains(knowledgeName[k]))
  1916. {
  1917. var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
  1918. OnePoint += point[n] * itemPersent;
  1919. foreach (string id in exam.studentIds)
  1920. {
  1921. int index = exam.studentIds.IndexOf(id);
  1922. if (exam.studentScores[index][n] > 0)
  1923. {
  1924. scores += exam.studentScores[index][n] * itemPersent;
  1925. }
  1926. }
  1927. }
  1928. n++;
  1929. });
  1930. Score.Add(scores);
  1931. //单个知识点的配分
  1932. pointScore.Add((knowledgeName[k], OnePoint));
  1933. //该知识点平均得分
  1934. double sc = exam.studentIds.Count > 0 ? Math.Round(scores * 1.0 / exam.studentIds.Count, 2) : 0;
  1935. double average = sc * 1.5;
  1936. if (average > OnePoint)
  1937. {
  1938. average = sc;
  1939. }
  1940. //知识点占比
  1941. double persent = Math.Round(OnePoint > 0 ? average / OnePoint : 0, 2);
  1942. per.Add(persent.ToString("0.00"));
  1943. //单个知识点所有学生得分率
  1944. pointTScore.Add((knowledgeName[k], persent));
  1945. }
  1946. KeyValuePair<string, List<string>> key1 = new(exam.subjectId, knowledgeName);
  1947. KeyValuePair<string, List<string>> key2 = new(exam.subjectId, per);
  1948. KeyValuePair<string, List<(string name, double score)>> key3 = new(exam.subjectId, pointScore);
  1949. KeyValuePair<string, List<(string name, double score)>> key4 = new(exam.subjectId, pointTScore);
  1950. //KeyValuePair<string, List<double>> key3 = new KeyValuePair<string, List<double>>(exam.subjectId, allPer);
  1951. return (key1, key2, key3, key4);
  1952. }
  1953. private async Task<List<string>> getStudentsAsync(List<string> ids, CosmosClient client, string pk, string source)
  1954. {
  1955. try
  1956. {
  1957. List<string> sIds = new();
  1958. await foreach (var item in client.GetContainer("TEAMModelOS", source).GetItemQueryStreamIterator(queryText: $"select c.id from c where c.pk = '{pk}' and c.periodId in ({string.Join(",", ids.Select(o => $"'{o}'"))})"))
  1959. {
  1960. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  1961. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1962. {
  1963. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  1964. while (accounts.MoveNext())
  1965. {
  1966. JsonElement account = accounts.Current;
  1967. sIds.Add(account.GetProperty("id").GetString());
  1968. }
  1969. }
  1970. }
  1971. return sIds;
  1972. }
  1973. catch (Exception e)
  1974. {
  1975. await _dingDing.SendBotMsg($"OS,{_option.Location},area/get-students()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  1976. return new List<string>();
  1977. }
  1978. }
  1979. [ProducesDefaultResponseType]
  1980. [HttpPost("delete-art")]
  1981. [AuthToken(Roles = "teacher,admin")]
  1982. #if !DEBUG
  1983. [Authorize(Roles = "IES")]
  1984. #endif
  1985. public async Task<IActionResult> DeleteArt(JsonElement request)
  1986. {
  1987. try
  1988. {
  1989. //区级活动Id
  1990. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  1991. //区级id
  1992. if (!request.TryGetProperty("areaId", out JsonElement code)) return BadRequest();
  1993. var client = _azureCosmos.GetCosmosClient();
  1994. List<string> ide = new();
  1995. var response = await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey($"Art-{code}"));
  1996. /*await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select c.id,c.code from c where c.activityId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ArtExam") }))
  1997. {
  1998. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  1999. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2000. {
  2001. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  2002. while (accounts.MoveNext())
  2003. {
  2004. JsonElement account = accounts.Current;
  2005. ide.Add(account.GetProperty("id").GetString());
  2006. }
  2007. }
  2008. }*/
  2009. await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey("ArtExam"));
  2010. // await client.GetContainer("TEAMModelOS", "Common").DeleteItemsAsync<ArtExam>(ide, "ArtExam");
  2011. List<(string id, string name)> bascId = await getId(client, code.GetString());
  2012. List<(string id, string name)> ids = new();
  2013. foreach ((string sId, string name) in bascId)
  2014. {
  2015. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select c.id,c.code from c where c.pId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{sId}") }))
  2016. {
  2017. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2018. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2019. {
  2020. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  2021. while (accounts.MoveNext())
  2022. {
  2023. JsonElement account = accounts.Current;
  2024. ids.Add((account.GetProperty("id").GetString(), account.GetProperty("code").GetString()));
  2025. }
  2026. }
  2027. }
  2028. }
  2029. if (ids.Count > 0)
  2030. {
  2031. foreach ((string s, string c) in ids)
  2032. {
  2033. var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
  2034. if (sresponse.Status == 200)
  2035. {
  2036. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  2037. ArtEvaluation art = json.ToObject<ArtEvaluation>();
  2038. art.status = 404;
  2039. foreach (var info in art.settings)
  2040. {
  2041. foreach (var acs in info.task)
  2042. {
  2043. if (!string.IsNullOrEmpty(acs.acId))
  2044. {
  2045. if (acs.type == 1)
  2046. {
  2047. Azure.Response eresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(acs.acId, new PartitionKey($"Exam-{art.school}"));
  2048. if (response.Status == 200)
  2049. {
  2050. ExamInfo data = JsonDocument.Parse(response.Content).RootElement.Deserialize<ExamInfo>();
  2051. data.status = 404;
  2052. await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"{data.code}"));
  2053. }
  2054. }
  2055. }
  2056. }
  2057. }
  2058. await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync(art, art.id, new PartitionKey($"{art.code}"));
  2059. }
  2060. }
  2061. }
  2062. return Ok(new { id, code = response.Status });
  2063. }
  2064. catch (Exception e)
  2065. {
  2066. await _dingDing.SendBotMsg($"OS,{_option.Location},area/delete-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2067. return BadRequest();
  2068. }
  2069. }
  2070. [ProducesDefaultResponseType]
  2071. [AuthToken(Roles = "teacher,admin,student")]
  2072. #if !DEBUG
  2073. [Authorize(Roles = "IES")]
  2074. #endif
  2075. [HttpPost("find-all-study-teachers")]
  2076. public async Task<IActionResult> FindAllStudyTeacher(JsonElement request)
  2077. {
  2078. try
  2079. {
  2080. //区级活动Id
  2081. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2082. if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  2083. var client = _azureCosmos.GetCosmosClient();
  2084. List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
  2085. List<Study> studies = new();
  2086. List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
  2087. //List<string> aName = new();
  2088. List<Survey> trSurveys = new();
  2089. List<ExamLite> trExams = new();
  2090. List<Study> moreInfo = new();
  2091. List<Homework> works = new();
  2092. //提取研修相关老师活动记录
  2093. List<StudyRecord> records = new();
  2094. List<RMember> teac = new();
  2095. var aresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(id.ToString(), new PartitionKey($"Study-{areaId}"));
  2096. if (aresponse.Status == (int)HttpStatusCode.OK)
  2097. {
  2098. var sJson = await JsonDocument.ParseAsync(aresponse.ContentStream);
  2099. Study study = sJson.ToObject<Study>();
  2100. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, study.tchLists, study.school);
  2101. teac = tchList;
  2102. var query = $"select value(c) from c where c.pId = '{id}'";
  2103. foreach ((string code, string name) in baseIds)
  2104. {
  2105. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<Study>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{code}") }))
  2106. {
  2107. studies.Add(item);
  2108. }
  2109. }
  2110. foreach (Study stu in studies)
  2111. {
  2112. if (!string.IsNullOrEmpty(stu.surveyId))
  2113. {
  2114. var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.surveyId, new PartitionKey($"Survey-{stu.school}"));
  2115. if (sresponse.Status == 200)
  2116. {
  2117. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  2118. Survey surs = json.ToObject<Survey>();
  2119. trSurveys.Add(surs);
  2120. }
  2121. }
  2122. if (!string.IsNullOrEmpty(stu.examId))
  2123. {
  2124. var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.examId, new PartitionKey($"ExamLite-{stu.school}"));
  2125. if (sresponse.Status == 200)
  2126. {
  2127. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  2128. ExamLite lite = json.ToObject<ExamLite>();
  2129. trExams.Add(lite);
  2130. }
  2131. }
  2132. if (!string.IsNullOrEmpty(stu.workId))
  2133. {
  2134. var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.workId, new PartitionKey($"Homework-{stu.school}"));
  2135. if (sresponse.Status == 200)
  2136. {
  2137. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  2138. Homework work = json.ToObject<Homework>();
  2139. works.Add(work);
  2140. }
  2141. }
  2142. };
  2143. moreInfo.Add(study);
  2144. foreach (var member in tchList)
  2145. {
  2146. var response = await client.GetContainer("TEAMModelOS", "Teacher").ReadItemStreamAsync(id.ToString(), new PartitionKey($"StudyRecord-{member.id}"));
  2147. if (response.Status == (int)HttpStatusCode.OK)
  2148. {
  2149. var json = await JsonDocument.ParseAsync(response.ContentStream);
  2150. StudyRecord record = json.ToObject<StudyRecord>();
  2151. records.Add(record);
  2152. }
  2153. }
  2154. }
  2155. var survey = trSurveys.Select(s => new
  2156. {
  2157. ansCount = s.answers.Count,
  2158. });
  2159. var twork = works.Select(s => new
  2160. {
  2161. ansCount = s.teachers.Where(h => !string.IsNullOrEmpty(h.hw)).ToList().Count,
  2162. });
  2163. var exam = trExams.Select(s => new
  2164. {
  2165. ansCount = s.teachers.Where(h => h.answer.Count > 0).ToList().Count,
  2166. });
  2167. var info = new
  2168. {
  2169. signCount = records.Where(h => h.signTime > 0).ToList().Count,
  2170. lateCount = records.Where(h => !string.IsNullOrEmpty(h.sign) && h.sign.Equals("2")).ToList().Count,
  2171. //acount = records.Where(h => h.aTime > 0).ToList().Count
  2172. };
  2173. return Ok(new { survey, work = twork, exam, info, studies = moreInfo.Select(m => m), teac });
  2174. }
  2175. catch (Exception e)
  2176. {
  2177. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-study-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2178. return BadRequest();
  2179. }
  2180. }
  2181. [ProducesDefaultResponseType]
  2182. [AuthToken(Roles = "teacher,admin,student")]
  2183. #if !DEBUG
  2184. [Authorize(Roles = "IES")]
  2185. #endif
  2186. [HttpPost("find-all-vote")]
  2187. public async Task<IActionResult> FindAllVote(JsonElement request)
  2188. {
  2189. try
  2190. {
  2191. //区级Id
  2192. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2193. var client = _azureCosmos.GetCosmosClient();
  2194. //List<string> baseIds = await getId(client, id.GetString());
  2195. List<object> votes = new();
  2196. //List<string> aName = new();
  2197. var query = $"select c.id,c.name,c.startTime,c.progress,c.owner,c.school from c ";
  2198. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Vote-{id}") }))
  2199. {
  2200. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2201. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2202. {
  2203. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  2204. {
  2205. votes.Add(obj.ToObject<object>());
  2206. }
  2207. }
  2208. }
  2209. return Ok(new { votes });
  2210. }
  2211. catch (Exception e)
  2212. {
  2213. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-vote()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2214. return BadRequest();
  2215. }
  2216. }
  2217. [ProducesDefaultResponseType]
  2218. [AuthToken(Roles = "teacher,admin,student")]
  2219. #if !DEBUG
  2220. [Authorize(Roles = "IES")]
  2221. #endif
  2222. [HttpPost("find-vote-id")]
  2223. public async Task<IActionResult> FindAllVoteTeacher(JsonElement request)
  2224. {
  2225. try
  2226. {
  2227. //区级活动Id
  2228. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2229. if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  2230. var client = _azureCosmos.GetCosmosClient();
  2231. List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
  2232. //List<object> votes = new();
  2233. List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
  2234. //List<string> aName = new();
  2235. List<Vote> votes = new List<Vote>();
  2236. Vote vote = null;
  2237. List<(string code, string name, string url, int count)> recordUrl = new List<(string code, string name, string url, int count)>();
  2238. var response = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync(id.GetString(), new PartitionKey($"Vote-{areaId}"));
  2239. if (response.Status == 200)
  2240. {
  2241. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  2242. vote = json.ToObject<Vote>();
  2243. var query = $"select c.tchLists,c.recordUrl from c where c.pId = '{id}'";
  2244. foreach ((string code, string name) in baseIds)
  2245. {
  2246. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Vote-{code}") }))
  2247. {
  2248. using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
  2249. if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2250. {
  2251. var accounts = sjson.RootElement.GetProperty("Documents").EnumerateArray();
  2252. while (accounts.MoveNext())
  2253. {
  2254. JsonElement account = accounts.Current;
  2255. List<string> tcs = account.GetProperty("tchLists").ToObject<List<string>>();
  2256. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, tcs, code);
  2257. // (List<TmdInfo> tmdInfos, List<ClassListInfo> classInfos) = await TriggerStuActivity.GetTchList(client, _dingDing, ids, $"{school}");
  2258. //(List<TmdInfo> tchList, _) = await TriggerStuActivity.GetTchList(client, _dingDing, tcs, code);
  2259. recordUrl.Add((code, name, account.GetProperty("recordUrl").GetString(), tchList.Count));
  2260. }
  2261. }
  2262. }
  2263. }
  2264. }
  2265. //var info = ps.Select(p => new { p.id, p.name });
  2266. return Ok(new { vote, code = recordUrl.Select(r => new { r.code, r.name, r.url, r.count }) });
  2267. }
  2268. catch (Exception e)
  2269. {
  2270. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-vote-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2271. return BadRequest();
  2272. }
  2273. }
  2274. [ProducesDefaultResponseType]
  2275. [AuthToken(Roles = "teacher,admin,student")]
  2276. #if !DEBUG
  2277. [Authorize(Roles = "IES")]
  2278. #endif
  2279. [HttpPost("find-all-survey")]
  2280. public async Task<IActionResult> FindAllSurvey(JsonElement request)
  2281. {
  2282. try
  2283. {
  2284. //区级Id
  2285. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2286. var client = _azureCosmos.GetCosmosClient();
  2287. //List<string> baseIds = await getId(client, id.GetString());
  2288. List<object> surveys = new();
  2289. // List<string> aName = new();
  2290. var query = $"select c.id,c.name,c.startTime,c.progress,c.sType,c.owner,c.school from c ";
  2291. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Survey-{id}") }))
  2292. {
  2293. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2294. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2295. {
  2296. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  2297. {
  2298. surveys.Add(obj.ToObject<object>());
  2299. }
  2300. }
  2301. }
  2302. return Ok(new { surveys });
  2303. }
  2304. catch (Exception e)
  2305. {
  2306. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-survey()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2307. return BadRequest();
  2308. }
  2309. }
  2310. [ProducesDefaultResponseType]
  2311. [AuthToken(Roles = "teacher,admin,student")]
  2312. #if !DEBUG
  2313. [Authorize(Roles = "IES")]
  2314. #endif
  2315. [HttpPost("find-survey-id")]
  2316. public async Task<IActionResult> FindAllSurveyTeacher(JsonElement request)
  2317. {
  2318. try
  2319. {
  2320. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2321. if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  2322. var client = _azureCosmos.GetCosmosClient();
  2323. List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
  2324. List<object> surveys = new();
  2325. Survey survey = null;
  2326. List<(string code, string name, string url, int count)> recordUrl = new List<(string code, string name, string url, int count)>();
  2327. var response = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync(id.GetString(), new PartitionKey($"Survey-{areaId}"));
  2328. if (response.Status == 200)
  2329. {
  2330. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  2331. survey = json.ToObject<Survey>();
  2332. var query = $"select c.tchLists,c.recordUrl from c where c.pId = '{id}'";
  2333. foreach ((string code, string name) in baseIds)
  2334. {
  2335. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Survey-{code}") }))
  2336. {
  2337. using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
  2338. if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2339. {
  2340. var accounts = sjson.RootElement.GetProperty("Documents").EnumerateArray();
  2341. while (accounts.MoveNext())
  2342. {
  2343. JsonElement account = accounts.Current;
  2344. List<string> tcs = account.GetProperty("tchLists").ToObject<List<string>>();
  2345. (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, tcs, code);
  2346. // (List<TmdInfo> tmdInfos, List<ClassListInfo> classInfos) = await TriggerStuActivity.GetTchList(client, _dingDing, ids, $"{school}");
  2347. //(List<TmdInfo> tchList, _) = await TriggerStuActivity.GetTchList(client, _dingDing, tcs, code);
  2348. recordUrl.Add((code, name, account.GetProperty("recordUrl").GetString(), tchList.Count));
  2349. }
  2350. }
  2351. }
  2352. }
  2353. }
  2354. //var info = ps.Select(p => new { p.id, p.name });
  2355. return Ok(new { survey, code = recordUrl.Select(r => new { r.code, r.name, r.url, r.count }) });
  2356. }
  2357. catch (Exception e)
  2358. {
  2359. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-survey-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2360. return BadRequest();
  2361. }
  2362. }
  2363. [ProducesDefaultResponseType]
  2364. [AuthToken(Roles = "teacher,admin,student")]
  2365. #if !DEBUG
  2366. [Authorize(Roles = "IES")]
  2367. #endif
  2368. [HttpPost("find-all-Exam")]
  2369. public async Task<IActionResult> FindAllExam(JsonElement request)
  2370. {
  2371. try
  2372. {
  2373. //区级Id
  2374. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2375. var client = _azureCosmos.GetCosmosClient();
  2376. //List<string> baseIds = await getId(client, id.GetString());
  2377. List<object> exams = new();
  2378. // List<string> aName = new();
  2379. var query = $"select c.id,c.name,c.createTime,c.sType,c.owner,c.school from c ";
  2380. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ExamLite-{id}") }))
  2381. {
  2382. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2383. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2384. {
  2385. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  2386. {
  2387. exams.Add(obj.ToObject<object>());
  2388. }
  2389. }
  2390. }
  2391. return Ok(new { exams });
  2392. }
  2393. catch (Exception e)
  2394. {
  2395. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-exam()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2396. return BadRequest();
  2397. }
  2398. }
  2399. [ProducesDefaultResponseType]
  2400. [AuthToken(Roles = "teacher,admin,student")]
  2401. #if !DEBUG
  2402. [Authorize(Roles = "IES")]
  2403. #endif
  2404. [HttpPost("find-all-exam-teachers")]
  2405. public async Task<IActionResult> FindAllExamTeacher(JsonElement request)
  2406. {
  2407. try
  2408. {
  2409. //区级活动Id
  2410. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2411. if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
  2412. var client = _azureCosmos.GetCosmosClient();
  2413. List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
  2414. List<object> exams = new();
  2415. List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
  2416. //List<string> aName = new();
  2417. var query = $"select c.school,c.teachers from c where c.acId = '{id}'";
  2418. foreach ((string code, string name) in baseIds)
  2419. {
  2420. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"TrExam-{code}") }))
  2421. {
  2422. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2423. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2424. {
  2425. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  2426. {
  2427. exams.Add(obj.ToObject<object>());
  2428. }
  2429. }
  2430. }
  2431. }
  2432. var info = ps.Select(p => new { p.id, p.name });
  2433. return Ok(new { info, exams });
  2434. }
  2435. catch (Exception e)
  2436. {
  2437. await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-exam-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2438. return BadRequest();
  2439. }
  2440. }
  2441. /// <summary>
  2442. /// 保存投票信息
  2443. /// </summary>
  2444. /// <param name="request"></param>
  2445. /// <returns></returns>
  2446. [ProducesDefaultResponseType]
  2447. //[AuthToken(Roles = "teacher,admin")]
  2448. [HttpPost("save-vote")]
  2449. [AuthToken(Roles = "teacher,admin")]
  2450. #if !DEBUG
  2451. [Authorize(Roles = "IES")]
  2452. #endif
  2453. public async Task<IActionResult> SaveVote(JsonElement request)
  2454. {
  2455. try
  2456. {
  2457. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2458. if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
  2459. if (!request.TryGetProperty("vote", out JsonElement vote)) return BadRequest();
  2460. List<parameter> parameters = para.ToObject<List<parameter>>();
  2461. List<Vote> votes = new();
  2462. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  2463. var client = _azureCosmos.GetCosmosClient();
  2464. Vote areaVote = vote.ToObject<Vote>();
  2465. areaVote.owner = "area";
  2466. areaVote.ttl = -1;
  2467. areaVote.code = "Vote-" + id.GetString();
  2468. areaVote.createTime = now;
  2469. if (areaVote.startTime <= 0)
  2470. {
  2471. areaVote.startTime = now;
  2472. }
  2473. if (areaVote.startTime > now)
  2474. {
  2475. areaVote.progress = "pending";
  2476. }
  2477. else
  2478. {
  2479. areaVote.progress = "going";
  2480. }
  2481. if (string.IsNullOrEmpty(areaVote.id))
  2482. {
  2483. areaVote.id = Guid.NewGuid().ToString();
  2484. }
  2485. List<string> allName = new();
  2486. foreach (parameter pa in parameters)
  2487. {
  2488. Vote trVote = vote.ToObject<Vote>();
  2489. string code = pa.sId;
  2490. trVote.school = code;
  2491. trVote.ttl = -1;
  2492. trVote.code = "Vote-" + code;
  2493. trVote.createTime = now;
  2494. trVote.areaId = id.GetString();
  2495. trVote.owner = "area";
  2496. trVote.pId = areaVote.id;
  2497. trVote.tchLists = pa.gId;
  2498. trVote.targetType = "research";
  2499. trVote.publish = 1;
  2500. trVote.progress = "pending";
  2501. /*if (pa.gName.Count == 0)
  2502. {
  2503. string sName = pa.sName + "-" + "所有老师(未分组)";
  2504. allName.Add(sName);
  2505. string json = "所有老师(未分组)";
  2506. //var json = new { name = "所有老师(未分组)" };
  2507. trVote.targets.Add(json.ToJsonString().ToObject<JsonElement>());
  2508. }
  2509. else
  2510. {
  2511. var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
  2512. trVote.targets = tn;
  2513. foreach (string name in pa.gName)
  2514. {
  2515. //处理区级target
  2516. string sName = pa.sName + "-" + name;
  2517. allName.Add(sName);
  2518. }
  2519. }*/
  2520. if (string.IsNullOrEmpty(trVote.id))
  2521. {
  2522. trVote.id = Guid.NewGuid().ToString();
  2523. string url = $"/vote/{trVote.id}/record.json";
  2524. trVote.recordUrl = url;
  2525. await _azureStorage.GetBlobContainerClient(code).UploadFileByContainer(new { options = new List<string>(), records = new List<VoteRecord>() }.ToJsonString(), "vote", $"{trVote.id}/record.json");
  2526. await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(trVote, new PartitionKey($"{trVote.code}"));
  2527. }
  2528. else
  2529. {
  2530. await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(trVote, trVote.id, new PartitionKey($"{trVote.code}"));
  2531. }
  2532. votes.Add(trVote);
  2533. }
  2534. var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
  2535. /*List<JsonElement> atn = new List<JsonElement>();
  2536. foreach (string agn in allName)
  2537. {
  2538. atn.Add(agn.ToObject<JsonElement>());
  2539. }*/
  2540. areaVote.targets = atn;
  2541. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaVote, new PartitionKey($"{areaVote.code}"));
  2542. var ids = votes.Select(s => new { s.id, s.school });
  2543. return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
  2544. }
  2545. catch (Exception ex)
  2546. {
  2547. await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-vote()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2548. return BadRequest();
  2549. }
  2550. }
  2551. [ProducesDefaultResponseType]
  2552. //[AuthToken(Roles = "teacher,admin")]
  2553. [HttpPost("delete")]
  2554. [AuthToken(Roles = "teacher,admin")]
  2555. #if !DEBUG
  2556. [Authorize(Roles = "IES")]
  2557. #endif
  2558. public async Task<IActionResult> Delete(JsonElement request)
  2559. {
  2560. try
  2561. {
  2562. //区级活动Id
  2563. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2564. //区级id
  2565. if (!request.TryGetProperty("areaId", out JsonElement code)) return BadRequest();
  2566. if (!request.TryGetProperty("pk", out JsonElement pk)) return BadRequest();
  2567. var client = _azureCosmos.GetCosmosClient();
  2568. var aresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(id.ToString(), new PartitionKey($"{pk}-{code}"));
  2569. if (aresponse.Status == 200)
  2570. {
  2571. using var json = await JsonDocument.ParseAsync(aresponse.ContentStream);
  2572. Study study = json.ToObject<Study>();
  2573. if (study.tchLists.Count > 0)
  2574. {
  2575. foreach (var list in study.tchLists)
  2576. {
  2577. await client.GetContainer("TEAMModelOS", "Teacher").DeleteItemStreamAsync(list, new PartitionKey($"GroupList-{code}"));
  2578. }
  2579. }
  2580. }
  2581. var response = await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey($"{pk}-{code}"));
  2582. List<(string id, string name)> bascId = await getId(client, code.GetString());
  2583. List<(string id, string name)> ids = new();
  2584. foreach ((string sId, string name) in bascId)
  2585. {
  2586. await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select c.id,c.code from c where c.pId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{pk}-{sId}") }))
  2587. {
  2588. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2589. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2590. {
  2591. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  2592. while (accounts.MoveNext())
  2593. {
  2594. JsonElement account = accounts.Current;
  2595. ids.Add((account.GetProperty("id").GetString(), account.GetProperty("code").GetString()));
  2596. }
  2597. }
  2598. }
  2599. }
  2600. if (ids.Count > 0)
  2601. {
  2602. foreach ((string s, string c) in ids)
  2603. {
  2604. if (c.Contains("Study"))
  2605. {
  2606. var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
  2607. if (sresponse.Status == 200)
  2608. {
  2609. using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
  2610. Study study = json.ToObject<Study>();
  2611. if (!string.IsNullOrEmpty(study.examId))
  2612. {
  2613. await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.examId, new PartitionKey($"ExamLite-{study.school}"));
  2614. }
  2615. if (!string.IsNullOrEmpty(study.surveyId))
  2616. {
  2617. await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.surveyId, new PartitionKey($"Survey-{study.school}"));
  2618. }
  2619. if (!string.IsNullOrEmpty(study.workId))
  2620. {
  2621. await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.workId, new PartitionKey($"Homework-{study.school}"));
  2622. }
  2623. }
  2624. }
  2625. await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
  2626. }
  2627. }
  2628. return Ok(new { id, code = response.Status });
  2629. }
  2630. catch (Exception e)
  2631. {
  2632. await _dingDing.SendBotMsg($"OS,{_option.Location},area/delete()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2633. return BadRequest();
  2634. }
  2635. }
  2636. /// <summary>
  2637. /// 保存问卷信息
  2638. /// </summary>
  2639. /// <param name="request"></param>
  2640. /// <returns></returns>
  2641. [ProducesDefaultResponseType]
  2642. //[AuthToken(Roles = "teacher,admin")]
  2643. [HttpPost("save-survey")]
  2644. [AuthToken(Roles = "teacher,admin")]
  2645. #if !DEBUG
  2646. [Authorize(Roles = "IES")]
  2647. #endif
  2648. public async Task<IActionResult> SaveSurvey(JsonElement request)
  2649. {
  2650. try
  2651. {
  2652. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2653. if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
  2654. if (!request.TryGetProperty("survey", out JsonElement survey)) return BadRequest();
  2655. List<parameter> parameters = para.ToObject<List<parameter>>();
  2656. List<Survey> surveys = new();
  2657. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  2658. var client = _azureCosmos.GetCosmosClient();
  2659. Survey areaSurvey = survey.ToObject<Survey>();
  2660. areaSurvey.owner = "area";
  2661. areaSurvey.ttl = -1;
  2662. areaSurvey.code = "Survey-" + id.GetString();
  2663. areaSurvey.createTime = now;
  2664. if (areaSurvey.startTime <= 0)
  2665. {
  2666. areaSurvey.startTime = now;
  2667. }
  2668. if (areaSurvey.startTime > now)
  2669. {
  2670. areaSurvey.progress = "pending";
  2671. }
  2672. else
  2673. {
  2674. areaSurvey.progress = "going";
  2675. }
  2676. if (string.IsNullOrEmpty(areaSurvey.id))
  2677. {
  2678. areaSurvey.id = Guid.NewGuid().ToString();
  2679. }
  2680. List<string> allName = new();
  2681. foreach (parameter pa in parameters)
  2682. {
  2683. Survey trSurvey = survey.ToObject<Survey>();
  2684. string code = pa.sId;
  2685. trSurvey.ttl = -1;
  2686. trSurvey.school = code;
  2687. trSurvey.code = "Survey-" + code;
  2688. trSurvey.createTime = now;
  2689. trSurvey.areaId = id.GetString();
  2690. trSurvey.owner = "area";
  2691. trSurvey.tchLists = pa.gId;
  2692. trSurvey.pId = areaSurvey.id;
  2693. trSurvey.targetType = "research";
  2694. trSurvey.publish = 1;
  2695. trSurvey.progress = "pending";
  2696. /*if (pa.gName.Count == 0)
  2697. {
  2698. string sName = pa.sName + "-" + "所有老师(未分组)";
  2699. allName.Add(sName);
  2700. string json = "所有老师(未分组)";
  2701. trSurvey.targets.Add(json.ToJsonString().ToObject<JsonElement>());
  2702. }
  2703. else
  2704. {
  2705. var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
  2706. trSurvey.targets = tn;
  2707. foreach (string name in pa.gName)
  2708. {
  2709. //处理区级target
  2710. string sName = pa.sName + "-" + name;
  2711. allName.Add(sName);
  2712. }
  2713. }*/
  2714. //await getMoreSurvey(pa, trSurvey);
  2715. trSurvey.id = Guid.NewGuid().ToString();
  2716. trSurvey.recordUrl = $"/survey/{trSurvey.id}/record.json";
  2717. var cods = new { records = new List<string>(), userids = new List<string>(), question = new List<QuestionRecord>() };
  2718. await _azureStorage.GetBlobContainerClient(code).UploadFileByContainer(cods.ToJsonString(), "survey", $"{trSurvey.id}/record.json");
  2719. // trSurvey.blob = SurveyService.getBlob(trSurvey.id);
  2720. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(trSurvey, new PartitionKey($"{trSurvey.code}"));
  2721. surveys.Add(trSurvey);
  2722. }
  2723. //areaSurvey.targets = allName;
  2724. var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
  2725. areaSurvey.targets = atn;
  2726. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaSurvey, new PartitionKey($"{areaSurvey.code}"));
  2727. var ids = surveys.Select(s => new { s.id, s.school });
  2728. return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
  2729. }
  2730. catch (Exception ex)
  2731. {
  2732. await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-survey()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2733. return BadRequest();
  2734. }
  2735. }
  2736. /// <summary>
  2737. /// 保存评测信息
  2738. /// </summary>
  2739. /// <param name="request"></param>
  2740. /// <returns></returns>
  2741. [ProducesDefaultResponseType]
  2742. //[AuthToken(Roles = "teacher,admin")]
  2743. [HttpPost("save-exam")]
  2744. [AuthToken(Roles = "teacher,admin")]
  2745. #if !DEBUG
  2746. [Authorize(Roles = "IES")]
  2747. #endif
  2748. public async Task<IActionResult> SaveExam(JsonElement request)
  2749. {
  2750. try
  2751. {
  2752. if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
  2753. if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
  2754. if (!request.TryGetProperty("exam", out JsonElement exam)) return BadRequest();
  2755. List<parameter> parameters = para.ToObject<List<parameter>>();
  2756. List<ExamLite> exams = new();
  2757. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  2758. var client = _azureCosmos.GetCosmosClient();
  2759. ExamLite areaExam = exam.ToObject<ExamLite>();
  2760. areaExam.owner = "area";
  2761. areaExam.ttl = -1;
  2762. areaExam.code = "TrExam-" + id.GetString();
  2763. areaExam.createTime = now;
  2764. if (string.IsNullOrEmpty(areaExam.id))
  2765. {
  2766. areaExam.id = Guid.NewGuid().ToString();
  2767. }
  2768. List<string> allName = new();
  2769. if (areaExam.startTime > now)
  2770. {
  2771. areaExam.progress = "pending";
  2772. }
  2773. else
  2774. {
  2775. areaExam.progress = "going";
  2776. }
  2777. foreach (parameter pa in parameters)
  2778. {
  2779. ExamLite trExam = exam.ToObject<ExamLite>();
  2780. string code = pa.sId;
  2781. trExam.ttl = -1;
  2782. trExam.school = code;
  2783. trExam.code = "TrExam-" + code;
  2784. trExam.createTime = now;
  2785. trExam.areaId = id.GetString();
  2786. trExam.owner = "area";
  2787. trExam.pId = areaExam.id;
  2788. trExam.targetType = "research";
  2789. trExam.progress = "pending";
  2790. trExam.publish = 1;
  2791. /*if (pa.gName.Count == 0)
  2792. {
  2793. string sName = pa.sName + "-" + "所有老师(未分组)";
  2794. allName.Add(sName);
  2795. }
  2796. else
  2797. {
  2798. foreach (string name in pa.gName)
  2799. {
  2800. //处理区级target
  2801. string sName = pa.sName + "-" + name;
  2802. allName.Add(sName);
  2803. }
  2804. }*/
  2805. //await getMoreExam(pa, trExam);
  2806. if (string.IsNullOrEmpty(trExam.id))
  2807. {
  2808. trExam.id = Guid.NewGuid().ToString();
  2809. // trExam.blob = ExamService.getBlob(trExam.id);
  2810. await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(trExam, new PartitionKey($"{trExam.code}"));
  2811. }
  2812. else
  2813. {
  2814. //trExam.blob = ExamService.getBlob(trExam.id);
  2815. await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(trExam, trExam.id, new PartitionKey($"{trExam.code}"));
  2816. }
  2817. exams.Add(trExam);
  2818. }
  2819. //areaExam.targets = allName;
  2820. await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaExam, new PartitionKey($"{areaExam.code}"));
  2821. var ids = exams.Select(s => new { s.id, s.school });
  2822. return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
  2823. }
  2824. catch (Exception ex)
  2825. {
  2826. await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-exam()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
  2827. return BadRequest();
  2828. }
  2829. }
  2830. private async Task<List<(string id, string name)>> getId(CosmosClient client, string id)
  2831. {
  2832. //获取区级以下所有学校编码和基础信息
  2833. List<(string id, string name)> baseIds = new();
  2834. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  2835. {
  2836. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2837. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2838. {
  2839. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  2840. while (accounts.MoveNext())
  2841. {
  2842. JsonElement account = accounts.Current;
  2843. baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
  2844. }
  2845. }
  2846. }
  2847. return baseIds;
  2848. }
  2849. private async Task<List<teacherInfo>> GetTeacherAll(string name, string code)
  2850. {
  2851. var client = _azureCosmos.GetCosmosClient();
  2852. string query = string.Empty;
  2853. List<teacherInfo> teachers = new List<teacherInfo>();
  2854. if (string.IsNullOrEmpty(name))
  2855. {
  2856. query = $"SELECT c.id, c.name, c.groupName FROM c ";
  2857. }
  2858. else
  2859. {
  2860. query = $"SELECT c.id, c.name, c.groupName FROM c where c.groupName = '{name}'";
  2861. }
  2862. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<teacherInfo>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{code}") }))
  2863. {
  2864. teachers.Add(item);
  2865. }
  2866. return teachers;
  2867. }
  2868. private Task<ExamLite> getMoreExam(parameter pa, ExamLite trExam)
  2869. {
  2870. if (pa.gName.Count == 0)
  2871. {
  2872. string json = "所有老师(未分组)";
  2873. trExam.targets.Add(json.ToJsonString().ToObject<JsonElement>());
  2874. }
  2875. else
  2876. {
  2877. var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
  2878. trExam.targets = tn;
  2879. }
  2880. return Task.FromResult(trExam);
  2881. }
  2882. private Task<Survey> getMoreSurvey(parameter pa, Survey trSurvey)
  2883. {
  2884. if (pa.gName.Count == 0)
  2885. {
  2886. //trSurvey.targets.Add("所有老师(未分组)");
  2887. string json = "所有老师(未分组)";
  2888. trSurvey.targets.Add(json.ToJsonString().ToObject<JsonElement>());
  2889. }
  2890. else
  2891. {
  2892. var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
  2893. trSurvey.targets = tn;
  2894. }
  2895. return Task.FromResult(trSurvey);
  2896. }
  2897. private Task<Homework> getMoreWork(parameter pa, Homework work)
  2898. {
  2899. if (pa.gName.Count == 0)
  2900. {
  2901. //trSurvey.targets.Add("所有老师(未分组)");
  2902. string json = "所有老师(未分组)";
  2903. work.targets.Add(json.ToJsonString().ToObject<JsonElement>());
  2904. }
  2905. else
  2906. {
  2907. var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
  2908. work.targets = tn;
  2909. }
  2910. return Task.FromResult(work);
  2911. }
  2912. private async Task<List<(string id, string name)>> getInfo(CosmosClient client, string id)
  2913. {
  2914. List<(string id, string name)> scInfos = new List<(string id, string name)>();
  2915. await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"select c.id,c.name from c where c.areaId = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
  2916. {
  2917. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  2918. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  2919. {
  2920. var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
  2921. while (accounts.MoveNext())
  2922. {
  2923. JsonElement account = accounts.Current;
  2924. scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
  2925. }
  2926. }
  2927. }
  2928. return scInfos;
  2929. }
  2930. public class parameter
  2931. {
  2932. public string sId { get; set; }
  2933. public string sName { get; set; }
  2934. public List<string> gName { get; set; }
  2935. public List<string> gId { get; set; }
  2936. }
  2937. public class teacherInfo
  2938. {
  2939. public string id { get; set; }
  2940. public string name { get; set; }
  2941. public string groupName { get; set; }
  2942. }
  2943. }
  2944. }