AreaController.cs 172 KB

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