AreaController.cs 164 KB

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