12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116 |
- using Azure.Core;
- using Azure.Cosmos;
- using Azure.Storage.Sas;
- using ClouDASLibx;
- using DocumentFormat.OpenXml.Drawing.Charts;
- using DocumentFormat.OpenXml.Office2010.Excel;
- using DocumentFormat.OpenXml.Spreadsheet;
- using DocumentFormat.OpenXml.Wordprocessing;
- using HTEXLib.COMM.Helpers;
- using Microsoft.AspNetCore.Authorization;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Configuration;
- using Microsoft.Extensions.Options;
- using OfficeOpenXml.Style;
- using OpenXmlPowerTools;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Net;
- using System.Text;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelOS.Controllers.Analysis;
- using TEAMModelOS.Controllers.Core;
- using TEAMModelOS.Filter;
- using TEAMModelOS.Models;
- using TEAMModelOS.SDK;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models;
- using TEAMModelOS.SDK.Models.Cosmos.Common;
- using TEAMModelOS.SDK.Models.Cosmos.Student;
- using TEAMModelOS.SDK.Models.Service;
- using static SKIT.FlurlHttpClient.Wechat.TenpayV3.Models.CreateApplyForSubjectApplymentRequest.Types;
- using static TEAMModelOS.SDK.Models.Cosmos.Student.StudentAnalysis;
- using Period = TEAMModelOS.SDK.Models.Period;
- namespace TEAMModelOS.Controllers
- {
- [ProducesResponseType(StatusCodes.Status200OK)]
- [ProducesResponseType(StatusCodes.Status400BadRequest)]
- [Route("school/area")]
- [ApiController]
- public class AreaController : ControllerBase
- {
- private readonly AzureCosmosFactory _azureCosmos;
- private readonly SnowflakeId _snowflakeId;
- private readonly AzureServiceBusFactory _serviceBus;
- private readonly DingDing _dingDing;
- private readonly Option _option;
- private readonly AzureStorageFactory _azureStorage;
- private readonly AzureRedisFactory _azureRedis;
- private readonly CoreAPIHttpService _coreAPIHttpService;
- public IConfiguration _configuration { get; set; }
- public AreaController(CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureServiceBusFactory serviceBus, SnowflakeId snowflakeId, DingDing dingDing,
- IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, IConfiguration configuration)
- {
- _azureCosmos = azureCosmos;
- _serviceBus = serviceBus;
- _snowflakeId = snowflakeId;
- _dingDing = dingDing;
- _option = option?.Value;
- _azureStorage = azureStorage;
- _azureRedis = azureRedis;
- _configuration = configuration;
- _coreAPIHttpService = coreAPIHttpService;
- }
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-group")]
- public async Task<IActionResult> Find(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //获取区级以下所有学校编码和基础信息
- List<string> baseIds = new();
- List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- baseIds.Add(account.GetProperty("id").GetString());
- scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
- }
- }
- }
- List<(string id, List<string> gId, List<string> name)> groups = new List<(string id, List<string> gId, List<string> name)>();
- foreach (string sId in baseIds)
- {
- List<(string id, string name)> group = new();
- 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}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- group.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
- //group.Add();
- }
- }
- }
- group = group.Where(g => !string.IsNullOrEmpty(g.id)).ToList();
- groups.Add((sId, group.Select(s => s.id).ToList(), group.Select(s => s.name).ToList()));
- }
- //var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS("hbcn", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
- var gr = groups.Select(o => new
- {
- o.id,
- o.gId,
- uri = _azureStorage.GetBlobContainerSAS(o.id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List).uri,
- sas = _azureStorage.GetBlobContainerSAS(o.id, BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List).sas,
- sname = scInfos.FirstOrDefault(c => c.id == o.id).name,
- o.name
- });
- return Ok(new { gr });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},school/area/find-group()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest(new { msg = e.Message });
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find")]
- public async Task<IActionResult> FindGroup(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //获取区级以下所有学校编码和基础信息
- List<string> baseIds = new();
- List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- baseIds.Add(account.GetProperty("id").GetString());
- scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
- }
- }
- }
- //获取所有学校人数
- List<(string id, int count)> scCount = new List<(string id, int count)>();
- foreach (string sId in baseIds)
- {
- List<string> tIds = new();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- tIds.Add(account.GetProperty("id").GetString());
- }
- }
- }
- scCount.Add((sId, tIds.Count));
- }
- var info = scInfos.Select(o =>
- new
- {
- o.id,
- o.name,
- o.picture,
- areaId = id,
- count = scCount.FirstOrDefault(c => c.id == o.id).count,
- }
- );
- return Ok(new { info });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},school/area/find()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 保存研修信息
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("save-study")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> SaveStudy(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- //if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
- if (!request.TryGetProperty("study", out JsonElement stu)) return BadRequest();
- //List<parameter> parameters = para.ToObject<List<parameter>>();
- var client = _azureCosmos.GetCosmosClient();
- var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
- //获取区级以下所有学校编码和基础信息
- List<string> baseIds = new();
- //List<(string id, string name, string picture)> scInfos = new List<(string id, string name, string picture)>();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- baseIds.Add(account.GetProperty("id").GetString());
- //scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString()));
- }
- }
- }
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- List<Study> studies = new();
- Study areaStudy = stu.ToObject<Study>();
- areaStudy.owner = "area";
- areaStudy.ttl = -1;
- areaStudy.scope = "school";
- areaStudy.code = "Study-" + id.GetString();
- areaStudy.createTime = now;
- areaStudy.creatorId = userid;
- if (areaStudy.startTime > now)
- {
- areaStudy.progress = "pending";
- }
- else
- {
- areaStudy.progress = "going";
- }
- if (string.IsNullOrEmpty(areaStudy.id))
- {
- areaStudy.id = Guid.NewGuid().ToString();
- }
- //创建区级名单
- GroupList list = new();
- list.type = "activity";
- list.year = list.year > 0 ? list.year : DateTimeOffset.UtcNow.Year;
- list.ttl = -1;
- list.expire = 0;
- list.creatorId = userid;
- list.code = "GroupList";
- list.scope = "private";
- list.pk = "GroupList";
- list.name = areaStudy.name;
- list.school = null;
- list = await GroupListService.CheckListNo(list, _azureCosmos, _dingDing, _option);
- list = await GroupListService.UpsertList(list, _azureCosmos, _configuration, _serviceBus);
- areaStudy.tchLists.Add(list.id);
- foreach (string scId in baseIds)
- {
- Study study = stu.ToObject<Study>();
- study.areaId = id.GetString();
- study.school = scId;
- study.owner = "area";
- study.ttl = -1;
- study.code = "Study-" + scId;
- study.createTime = now;
- study.creatorId = userid;
- study.publish = 1;
- study.progress = "pending";
- study.pId = areaStudy.id;
- study.scope = "school";
- study.targetType = "research";
- study.tchLists.Add(list.id);
- foreach (string setting in study.settings)
- {
- if (setting.Equals("exam"))
- {
- if (!request.TryGetProperty("exam", out JsonElement exam)) return BadRequest();
- ExamLite trExam = exam.ToObject<ExamLite>();
- trExam.owner = "area";
- trExam.school = scId;
- trExam.areaId = id.GetString();
- trExam.creatorId = userid;
- trExam.targetType = "research";
- trExam.publish = 1;
- trExam.tchLists.Add(list.id);
- trExam.blob = $"/{trExam.areaId}/exam/{study.pId}/index.json";
- //处理发布对象
- //await getMoreExam(pa, trExam);
- //保存更多得评测信息
- string eId = await ExamService.saveMoreAsync(client, _dingDing, trExam);
- if (string.IsNullOrEmpty(eId))
- {
- return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "评测信息异常" });
- }
- else
- {
- study.examId = eId;
- }
- }
- if (setting.Equals("survey"))
- {
- if (!request.TryGetProperty("survey", out JsonElement survey)) return BadRequest();
- Survey trSurvey = survey.ToObject<Survey>();
- trSurvey.owner = "area";
- trSurvey.school = scId;
- trSurvey.areaId = id.GetString();
- //trSurvey.tchLists = pa.gId;
- trSurvey.scope = "school";
- trSurvey.creatorId = userid;
- trSurvey.publish = 1;
- trSurvey.targetType = "research";
- trSurvey.tchLists.Add(list.id);
- trSurvey.blob = $"/{trSurvey.areaId}/survey/{study.pId}/index.json";
- //await getMoreSurvey(pa, trSurvey);
- string surveyId = await SurveyService.saveMoreAsync(client, _dingDing, trSurvey);
- if (string.IsNullOrEmpty(surveyId))
- {
- return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "问卷信息异常" });
- }
- else
- {
- study.surveyId = surveyId;
- }
- }
- if (setting.Equals("hw"))
- {
- if (!request.TryGetProperty("work", out JsonElement work)) return BadRequest();
- Homework homework = work.ToObject<Homework>();
- homework.owner = "area";
- homework.school = scId;
- homework.areaId = id.GetString();
- //homework.tchLists = pa.gId;
- homework.scope = "school";
- homework.creatorId = userid;
- homework.publish = 1;
- homework.targetType = "research";
- homework.tchLists.Add(list.id);
- //homework.blob = $"/{homework.areaId}/survey/{study.pId}/index.json";
- //await getMoreWork(pa, homework);
- string workId = await HomeworkService.saveMoreAsync(client, _dingDing, homework, _serviceBus, _azureStorage, _configuration, _azureRedis);
- if (string.IsNullOrEmpty(workId))
- {
- return Ok(new { code = (int)HttpStatusCode.BadRequest, msg = "作业活动异常" });
- }
- else
- {
- study.workId = workId;
- }
- }
- }
- if (string.IsNullOrEmpty(study.id))
- {
- study.id = Guid.NewGuid().ToString();
- await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(study, new PartitionKey($"{study.code}"));
- }
- else
- {
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(study, new PartitionKey($"{study.code}"));
- }
- studies.Add(study);
- }
- //areaStudy.targets = allName;
- /* var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
- areaStudy.targets = atn;*/
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaStudy, new PartitionKey($"{areaStudy.code}"));
- var ids = studies.Select(s => new { s.id, s.school, s.examId, s.surveyId });
- return Ok(new { id, ids, code = (int)HttpStatusCode.OK, acId = areaStudy.id });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-study()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("save-art")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> SaveArt(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("art", out JsonElement art)) return BadRequest();
- if (!request.TryGetProperty("artExam", out JsonElement artExam)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
- List<string> baseIds = new();
- if (request.TryGetProperty("schoolId", out JsonElement schoolId))
- {
- baseIds = schoolId.ToObject<List<string>>();
- }
- else
- {
- //获取区级以下所有学校编码和基础信息
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- baseIds.Add(account.GetProperty("id").GetString());
- }
- }
- }
- }
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- List<ArtEvaluation> arts = new();
- ArtEvaluation areaArt = art.ToObject<ArtEvaluation>();
- areaArt.owner = "area";
- areaArt.ttl = -1;
- areaArt.scope = "school";
- areaArt.code = "Art-" + id.GetString();
- areaArt.createTime = now;
- areaArt.creatorId = userid;
- areaArt.progress = "pending";
- if (string.IsNullOrEmpty(areaArt.id))
- {
- areaArt.id = Guid.NewGuid().ToString();
- }
- //智音部分内容 区级部分关联 id 校级pId
- if (request.TryGetProperty("ArtMusic", out JsonElement music))
- {
- ArtMusic artMusic = music.ToObject<ArtMusic>();
- artMusic.code = "ArtMusic";
- artMusic.ttl = -1;
- artMusic.id = areaArt.id;
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(artMusic, new PartitionKey("ArtMusic"));
- };
- //调整了区级模块发布活动时,内部评测部分数据关联 activityId 作为唯一主键(之前的历史数据无效)
- ArtExam aExam = new()
- {
- id = areaArt.id,
- ttl = -1,
- code = "ArtExam",
- JsonElement = artExam
- };
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(aExam, new PartitionKey("ArtExam"));
- foreach (string scId in baseIds)
- {
- ArtEvaluation ae = art.ToObject<ArtEvaluation>();
- ae.areaId = id.GetString();
- ae.school = scId;
- ae.owner = "area";
- ae.ttl = -1;
- ae.code = "Art-" + scId;
- ae.createTime = now;
- ae.creatorId = userid;
- ae.publish = 1;
- ae.progress = "pending";
- ae.pId = areaArt.id;
- ae.scope = "school";
- if (string.IsNullOrEmpty(ae.id))
- {
- ae.id = Guid.NewGuid().ToString();
- await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(ae, new PartitionKey($"{ae.code}"));
- }
- else
- {
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(ae, new PartitionKey($"{ae.code}"));
- }
- arts.Add(ae);
- }
- //areaStudy.targets = allName;
- /* var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
- areaStudy.targets = atn;*/
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaArt, new PartitionKey($"{areaArt.code}"));
- //var ids = studies.Select(s => new { s.id, s.school, s.examId, s.surveyId });
- return Ok(new { code = (int)HttpStatusCode.OK, arts });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-art()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("find-school")]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> findSchool(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
- //获取区级以下所有学校编码和基础信息
- List<(string id, string name, string type)> baseIds = new();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- if (account.TryGetProperty("type", out JsonElement pType))
- {
- baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), pType.GetString()));
- }
- else
- {
- baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), ""));
- }
- }
- }
- }
- var sc = baseIds.GroupBy(c => (c.id, c.name)).Select(x => new
- {
- x.Key.id,
- x.Key.name,
- period = x.ToList().Where(p => !string.IsNullOrWhiteSpace(p.type)).Select(z => z.type)
- });
- return Ok(new { code = (int)HttpStatusCode.OK, sc });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-school()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-study")]
- public async Task<IActionResult> FindAllStudy(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- // List<string> baseIds = await getId(client, id.GetString());
- List<object> studies = new();
- 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 ";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- studies.Add(obj.ToObject<object>());
- }
- }
- }
- return Ok(new { studies });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-study()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [Authorize(Roles = "IES")]
- [AuthToken(Roles = "teacher,admin")]
- [HttpPost("find-all-art")]
- public async Task<IActionResult> FindAllArt(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- // List<string> baseIds = await getId(client, id.GetString());
- List<(string id, string name, long stime, long etime)> artMore = new();
- List<string> pIds = new();
- List<(string id, string code, string pd)> artsSchools = new();
- var query = $"select c.id,c.name,c.startTime,c.endTime from c order by c.createTime desc";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- artMore.Add((obj.GetProperty("id").ToString(), obj.GetProperty("name").ToString(), obj.GetProperty("startTime").GetInt64(), obj.GetProperty("endTime").GetInt64()));
- pIds.Add(obj.GetProperty("id").ToString());
- }
- }
- }
- if (pIds.Any())
- {
- 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}'"))})";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: querySchool))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- artsSchools.Add((obj.GetProperty("id").ToString(), obj.GetProperty("school").ToString(), obj.GetProperty("pId").ToString()));
- }
- }
- }
- var artSc = artsSchools.Select(x => new
- {
- x.id,
- x.code,
- x.pd
- });
- var arts = artMore.Select(x => new
- {
- x.id,
- x.name,
- startTime = x.stime,
- endTime = x.etime,
- sc = artSc.Where(c => c.pd.Equals(x.id)).Select(p => new { p.id, p.code })
- });
- return Ok(new { arts });
- }
- else
- {
- return Ok(new { arts = new List<dynamic> { } });
- }
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [Authorize(Roles = "IES")]
- [AuthToken(Roles = "teacher,admin")]
- [HttpPost("find-area-art")]
- public async Task<IActionResult> FindArt(JsonElement request)
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
- try
- {
- var client = _azureCosmos.GetCosmosClient();
- List<ArtEvaluation> arts = new();
- //SELECT top 1 * FROM c order by c.createTime desc
- 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}") }))
- {
- arts.Add(item);
- }
- return Ok(arts);
- }
- catch (Exception e)
- {
- return BadRequest(new { code = 500 });
- }
- }
- [ProducesDefaultResponseType]
- [Authorize(Roles = "IES")]
- [AuthToken(Roles = "teacher,admin")]
- [HttpPost("analysis-area-art")]
- public async Task<IActionResult> FindAreaArt(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
- if (!request.TryGetProperty("art", out JsonElement artInfo)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- ArtEvaluation art = artInfo.ToObject<ArtEvaluation>();
- List<(string id, string name,string picture, List<Period> periods)> baseInfo = new();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- List<Period> pd = account.GetProperty("period").ToObject<List<Period>>();
- baseInfo.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString(), account.GetProperty("picture").GetString(), pd));
- }
- }
- }
- ArtSetting setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<ArtSetting>($"{id}", partitionKey: new PartitionKey("ArtSetting"));
- //SELECT top 1 * FROM c order by c.createTime desc
- //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}") }))
- //{
- // arts.Add(item);
- //}
- List<(string id, string code, List<string> classes, List<Tasks> settings)> artSchools = new();
- if (art != null)
- {
- string ql = $"select c.id,c.school,c.settings,c.classes from c where c.pk = 'Art' and c.pId = '{art.id}'";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: ql))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- List<Tasks> settings = account.GetProperty("settings").ToObject<List<Tasks>>();
- List<string> classIds = account.GetProperty("classes").ToObject<List<string>>();
- artSchools.Add((account.GetProperty("id").GetString(), account.GetProperty("school").GetString(), classIds, settings));
- }
- }
- }
- }
- else
- {
- return Ok(new { msg = "暂无数据", code = 400 });
- }
- var ped = baseInfo.Select(x => x.periods).ToList();
- var scode = baseInfo.MaxBy(x => x.periods.Count);
- List<string> perxId = new();
- List<string> percId = new();
- List<(string ptype, string pId, string name)> perInfos = new();
- foreach (var scpd in ped)
- {
- foreach (var per in scpd)
- {
- if (null != per.periodType && per.periodType.Equals(periodType.GetString()))
- {
- perInfos.Add((per.periodType, per.id, per.name));
- }
- }
- }
- 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));
- List<(string ptype, List<string> scs, string type)> baseMore = new();
- List<(string ptype, int scCount, int classCount, int subjectCount, int stuCount)> pCount = new();
- List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> kno = new();
- List<(string perName, double stuCount, double realCount, double lostCount)> stuCounts = new();
- foreach (var ps in periods)
- {
- //各个学校 学段学生人数
- List<string> stus = await getStudentsAsync(ps.list, client, "Base", "Student");
- //班级总数
- List<string> classes = await getStudentsAsync(ps.list, client, "Class", "School");
- baseMore.Add((ps.key, stus, "Student"));
- baseMore.Add((ps.key, classes, "Class"));
- pCount.Add((ps.key, ps.list.Count, classes.Count, 2, stus.Count));
- /* //先获取不同学段和科目的知识占比
- foreach (var artSubject in art.subjects)
- {
- kno.Add(await getKnowledge(ps.key, "hbcn", client, artSubject.id, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
- }*/
- }
- //全校通用一套试卷时
- //先获取不同学段和科目的知识占比
- string pId = perInfos.Where(c => c.ptype.Equals(periodType.GetString()))?.FirstOrDefault().pId;
- foreach (var artSubject in art.subjects)
- {
- kno.Add(await getKnowledge(periodType.GetString(), "hbcn", client, artSubject.id, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
- }
- var areaSchool = pCount.Select(x => new
- {
- x.ptype,
- x.scCount,
- x.classCount,
- x.subjectCount,
- x.stuCount
- }).FirstOrDefault();
- 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();
- List<(List<string> classes, string classId, string code, string artId, string examId, List<ArtSubjectScore> ac)> subjecScore = new();
- List<(string perName, string subject, Dictionary<int, int> keys)> pairs = new();
- List<ExamResult> exams = new();
- await foreach (var ss in schoolTask(artSchools, client, baseInfo, art, setting, kno))
- {
- subjecScore.AddRange(ss.subjecScore);
- blocks.AddRange(ss.blocks);
- pairs.AddRange(ss.opt);
- stuCounts.AddRange(ss.stuCounts);
- //exams.AddRange(ss.exams);
- }
- List<(dynamic key1, dynamic key2)> periodInfos = new();
- var bm = baseMore.Where(c => c.type.Equals("Class"));
- int scCount = 0;
- foreach (var (ptype, scs, type) in bm)
- {
- var psc = subjecScore.Where(c => scs.Contains(c.classId)).Select(x => new { x.classes, x.code, x.artId, x.examId, x.ac });
- if (!psc.Any())
- {
- continue;
- }
- var pScore = psc.SelectMany(z => z.ac).GroupBy(x => x.subjectId).Select(c => new { subjectId = c.Key, scores = c.ToList().Select(a => a.score) });
- var psubjectSchool = pScore.GroupBy(g => g.subjectId).Select(x => new
- {
- x.Key,
- score = x.ToList().SelectMany(c => c.scores).ToList().Where(c => c > 0),
- count = x.ToList().SelectMany(c => c.scores).Where(c => c > 0).Count()
- });
- var psubject = psubjectSchool.Select(x => new
- {
- perName = ptype,
- name = x.Key,
- max = x.score.Any() ? x.score.Max(s => s) : 0,
- min = x.score.Any() ? x.score.Min(s => s) : 0,
- excellent = x.score.Any() ? Math.Round(x.score.Where(s => s >= 80).Count() * 1.0 / x.count, 2) : 0,
- pass = x.score.Any() ? Math.Round(x.score.Where(s => s >= 60).Count() * 1.0 / x.count, 2) : 0,
- average = x.score.Any() ? Math.Round(x.score.Sum() * 1.0 / x.count, 2) : 0
- });
- var pschoolScore = psc.GroupBy(g => (g.code, g.artId, g.examId, g.classes)).Select(x => new
- {
- perName = ptype,
- perCname = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z => null != z.periodType && z.periodType.Equals(ptype)).FirstOrDefault()?.name,
- baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().name,
- baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().picture,
- x.Key.artId,
- x.Key.examId,
- x.Key.code,
- x.Key.classes,
- perId = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z => null != z.periodType && z.periodType.Equals(ptype)).FirstOrDefault()?.id,
- semester = baseInfo.Where(c => c.id.Equals(x.Key.code)).FirstOrDefault().periods.Where(z =>
- null != z.periodType && z.periodType.Equals(ptype)).Select(z => z.semesters).ToList(),
- time = art.createTime,
- scores = x.ToList().SelectMany(z => z.ac).GroupBy(x => x.subjectId).Select(c => new
- {
- subjectId = c.Key,
- scores = c.ToList().Select(a => a.score).Where(c => c > 0)
- }).GroupBy(g => g.subjectId).Select(n => new
- {
- subjectId = n.Key,
- max = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? n.ToList().SelectMany(c => c.scores).ToList().Max(s => s) : 0,
- min = n.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? n.ToList().SelectMany(c => c.scores).ToList().Min(s => s) : 0,
- 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,
- 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,
- 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
- })
- });
- scCount = pschoolScore.Count();
- periodInfos.Add((psubject, pschoolScore));
- }
- var periodAll = periodInfos.Select(x => new
- {
- subject = x.key1,
- schoolScore = x.key2
- }).FirstOrDefault();
- var block = blocks.GroupBy(c => c.perName).Select(x => new
- {
- school = x.Key,
- list = x.ToList().Select(b => new
- {
- b.code,
- b.subjectId,
- blk = b.blocks.Select(k => new
- {
- k.name,
- k.score,
- k.dim
- }),
- kn = b.knos.Select(n => new { n.name, n.score, n.kno }),
- b.stand
- })
- });
- var allBlock = block.Select(x => new
- {
- x.school,
- sub = x.list.GroupBy(c => c.subjectId).Select(z => new
- {
- z.Key,
- blk = z.ToList().Select(b => b.blk).ToList()[0],
- sl = z.ToList().Select(v => v.kn).SelectMany(r => r).GroupBy(a => a.name).Select(t => new
- {
- t.Key,
- kno = t.ToList().Select(k => k.kno).ToList()[0],
- scores = Math.Round(t.ToList().Select(l => l.score).ToList().Sum() * 1.0 / scCount, 2)
- }),
- stand = Math.Round(z.ToList().Sum(c => c.stand) * 1.0 / scCount, 2)
- })
- }).FirstOrDefault();
- var keys = pairs.Select(x => x.keys).ToList();
- bool flag = false;
- foreach (var op in keys)
- {
- if (op.Count > 0)
- {
- flag = true;
- break;
- }
- }
- var opt = pairs.GroupBy(p => p.perName).Select(s => new
- {
- per = s.Key,
- subject = s.ToList().Select(m => new { m.subject, m.keys }).GroupBy(c => c.subject).Select(z => new
- {
- sub = z.Key,
- key = flag ? z.ToList().Select(y => y.keys) : null
- //key = z.ToList().Select(y => y.keys)
- })
- }).FirstOrDefault();
- /*var perStuCounts = stuCounts.Select(x => new {
- x.perName,
- x.stuCount,
- x.realCount,
- x.lostCount
- });*/
- 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) });
- var classCount = artSchools.SelectMany(c => c.classes).ToList().Count;
- //var pow = exams.GroupBy(x => x.subjectId).Select(z => new { sub = z.Key,students = z.SelectMany(c => c.studentScores)});
- return Ok(new { areaSchool, allBlock, opt, periodAll, perStuCounts, classCount });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/analysis-area-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- private async IAsyncEnumerable<(string code, List<(List<string> classes, string classId, string code, string artId, string fId, List<ArtSubjectScore> ac)> subjecScore,
- 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,
- 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,
- List<Tasks> settings)> artSchools, CosmosClient client, List<(string id, string name, string pic,List<Period> periods)> baseInfo, ArtEvaluation art, ArtSetting setting,
- List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> spId)
- {
- long time = art.startTime;
- var stime = DateTimeOffset.FromUnixTimeMilliseconds(time);
- int month = stime.Month;
- int day = stime.Day;
- List<ExamResult> exams = new();
- foreach (var (id, code, classes, settings) in artSchools)
- {
- string fId = settings.SelectMany(s => s.task).Where(a => a.type == 1).FirstOrDefault().acId;
- string queryScore = $" select c.studentId,c.classIds,c.totalScore,c.artId,c.subjectScores,c.results from c ";
- List<(List<string> classIds, string classId, string code, string artId, string fId, List<ArtSubjectScore> ac)> As = new();
- List<List<ArtQuotaResult>> results = new();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIterator
- (queryText: queryScore, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"ArtResult-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- if (obj.TryGetProperty("subjectScores", out JsonElement subScore))
- {
- string sId = obj.GetProperty("studentId").GetString();
- string artId = obj.GetProperty("artId").GetString();
- string classId = obj.GetProperty("classIds").ToObject<List<string>>()[0];
- List<ArtSubjectScore> sc = subScore.ToObject<List<ArtSubjectScore>>();
- As.Add((classes, classId, code, artId, fId, sc));
- }
- else
- {
- As.Add((new List<string>(), "", code, "", fId, new List<ArtSubjectScore>()));
- }
- results.Add(obj.GetProperty("results").ToObject<List<ArtQuotaResult>>());
- }
- }
- }
- /* var sbScore = As.GroupBy(x => x.subjectId).Select(c => new { subjectId = c.Key, list = c.ToList().Select(a => a.score) });
- List<(string suject,string code, List<double> scores)> scs = new();
- foreach (var subjectScore in sbScore)
- {
- scs.Add((subjectScore.subjectId, code,subjectScore.list.ToList()));
- }*/
- //List<(string subId, List<(string name, List<string> kno)> values)> bk = new();
- var pers = baseInfo.Where(x => x.id.Equals(code)).FirstOrDefault().periods;
- List<(string sb, string pId)> pn = new();
- 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();
- List<(string perName, string subject, Dictionary<int, int> keys)> opt = new();
- List<(string perName, double stuCount, double realCount, double lostCount)> stuCounts = new();
- foreach (var perId in pers)
- {
- List<ExamResult> resultAll = new();
- if (null != perId.periodType && !perId.periodType.Equals(art.periodType)) continue;
- foreach (var sj in art.subjects)
- {
- List<(string name, List<string> kno)> knos = new();
- knos = spId.Where(s => s.subId.Equals(sj.id) && s.ptype.Equals(perId.periodType)).FirstOrDefault().knos;
- if (null == knos || !knos.Any()) { continue; }
- else
- {
- var examId = settings.SelectMany(s => s.task).Where(a => a.type == 1 && a.subject.Equals(sj.id)).FirstOrDefault().acId;
- if (string.IsNullOrWhiteSpace(examId)) { continue; }
- List<ExamResult> examResults = new();
- List<KeyValuePair<string, List<(string name, double score)>>> pointPersent = new();
- ExamInfo info = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemAsync<ExamInfo>(examId.ToString(), new PartitionKey($"Exam-{code}"));
- 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}' ";
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "Common").GetItemQueryIterator<ExamResult>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ExamResult-{examId}") }))
- {
- resultAll.Add(item);
- examResults.Add(item);
- //exams.Add(item);
- }
- if (!examResults.Any())
- {
- continue;
- }
- (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]);
- pointPersent.Add(key3);
- List<(string name, double score)> blockScore = new();
- foreach (var block in knos)
- {
- double sc = 0;
- foreach (var no in pointPersent)
- {
- foreach (var (name, score) in no.Value)
- {
- if (null != block.kno && block.kno.Contains(name))
- {
- sc += score;
- }
- }
- }
- blockScore.Add((block.name, sc));
- }
- var blk = blockScore.Select(x => new
- {
- x.name,
- x.score,
- dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
- });
- List<(string name, double score, List<string> dim)> blocks = new();
- foreach (var bk in blk)
- {
- blocks.Add((bk.name, bk.score, bk.dimension.ToList()));
- }
- var kno = key4.Value.Select(x => new
- {
- x.name,
- x.score,
- block = knos.Where(v => null != v.kno && v.kno.Contains(x.name)).Select(x => x.name)
- });
- List<(string name, double score, List<string> dim)> knoMore = new();
- foreach (var bk in kno)
- {
- knoMore.Add((bk.name, bk.score, bk.block.ToList()));
- }
- perMore.Add((code, perId.periodType, sj.id, blocks, knoMore, examResults[0].standard));
- }
- //获奖次数
- List<ArtAttachment> artAttachments = new();
- string sqlTask = $"select value(c) from c where c.artId = '{id}' and c.subjectId = '{sj.id}'";
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Student).
- GetItemQueryIterator<ArtAttachment>(queryText: sqlTask, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"ArtAttachment-{code}") }))
- {
- artAttachments.Add(item);
- }
- List<List<string>> tag = new();
- List<int> level = artAttachments.Where(z => z.level > -1).Select(c => c.level).ToList();
- /* artAttachments.ForEach(r =>
- {
- if (r.files.Count > 0)
- {
- tag.AddRange(r.files.Select(c => c.tag).ToList());
- }
- });
- List<string> newTag = new();
- tag.ForEach(t =>
- {
- if (t.Count > 0)
- {
- newTag.AddRange(t);
- }
- });*/
- Dictionary<int, int> optCount = new();
- foreach (var s in level)
- {
- if (optCount.ContainsKey(s))
- {
- optCount[s] = optCount[s] + 1;
- }
- else
- {
- optCount[s] = 1;
- }
- }
- opt.Add((perId.periodType, sj.id, optCount));
- }
- var all = resultAll.SelectMany(x => x.studentIds).ToList();
- var lost = resultAll.SelectMany(x => x.lostStus).ToList();
- var AllCount = all.Where((x, i) => all.FindIndex(z => z == x) == i).ToList().Count;
- //缺考去重
- var lostCount = lost.Where((x, i) => lost.FindIndex(z => z == x) == i).ToList().Count;
- var realLost = lost.Count - lostCount;
- stuCounts.Add((perId.periodType, AllCount, AllCount - realLost, realLost));
- }
- yield return (code, As, perMore, opt, stuCounts);
- }
- }
- [ProducesDefaultResponseType]
- [Authorize(Roles = "IES")]
- [AuthToken(Roles = "teacher,admin")]
- [HttpPost("get-all-knowledge")]
- public async Task<IActionResult> getAllClassKnowledge(JsonElement request)
- {
- //区级ID
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- //学段类型
- if (!request.TryGetProperty("periodType", out JsonElement periodType)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //TODO 这里目前根据时间查询同一批次的考试内容,需要换成其他条件
- //string sql = "SELECT c.id FROM c where c.pk = 'Art' and (c.startTime = 1678978800000 or c.startTime = 1678982400000) and c.endTime = 1684382400000";
- string sql = "select * from c where c.pk = 'Art' and c.id in ('2f74d38e-80c1-4c55-9dd0-de0d8f6fdf6d','306fa576-7ae4-4baa-ac24-0b5ad4dd1bc2')";
- List<string> superIds = new();
- ArtSetting setting = await client.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<ArtSetting>($"{id}", partitionKey: new PartitionKey("ArtSetting"));
- //获取区级本次发布任务获得所有活动ID集合
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Common).GetItemQueryStreamIterator(queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Art-{id}") }))
- {
- using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
- if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in sjson.RootElement.GetProperty("Documents").EnumerateArray())
- {
- if (obj.TryGetProperty("id", out JsonElement superId))
- {
- string sId = superId.GetString();
- superIds.Add(sId);
- }
- }
- }
- }
- if (superIds.Count > 0) {
- //改版内容
- //获取区级下面所有的学校信息
- List<(string code, string name, List<Period> pd)> schoolBase = new();
- 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") }))
- {
- using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
- if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in sjson.RootElement.GetProperty("Documents").EnumerateArray())
- {
- if (obj.TryGetProperty("id", out JsonElement scId) && obj.TryGetProperty("name", out JsonElement scname))
- {
- List<Period> pd = obj.GetProperty("period").ToObject<List<Period>>();
- schoolBase.Add((scId.GetString(), scname.GetString(), pd));
- }
- }
- }
- }
- /* var ped = schoolBase.Select(x => x.pd).ToList();
- List<(string ptype, string pId, string name)> perInfos = new();
- foreach (var scpd in ped)
- {
- foreach (var per in scpd)
- {
- if (null != per.periodType && per.periodType.Equals(periodType.GetString()))
- {
- perInfos.Add((per.periodType, per.id, per.name));
- }
- }
- }*/
- //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));
- List<(string ptype, List<string> scs, string type)> baseMore = new();
- List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> knoledge = new();
- List<string> subs = new List<string> { "subject_painting", "subject_music" };
- foreach (var ss in subs)
- {
- knoledge.Add(await getKnowledge(periodType.GetString(), "hbcn", client, ss, "be32942d-97a9-52ba-45d6-2e5b722583f5"));
- }
- //获取当前学段的知识点关系
- //List<(string name, List<string> kno)> knos = new();
- var knos = knoledge.Where(s => s.ptype.Equals(periodType.GetString())).SelectMany(c => c.knos).ToList();
- //获取区级下面所有活动发布后的活动信息
- List<ArtEvaluation> arts = new();
- 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}'"))})"))
- {
- arts.Add(item);
- }
- var examIds = arts.SelectMany(c => c.settings).Where(z => z.id.Equals("quota_21")).SelectMany(x => x.task).Select(d => d.acId).ToList();
- //获取区级本次发布任务获得所有活动结算结果表
- List<ExamResult> results = new();
- 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}'"))})"))
- {
- results.Add(item);
- }
- var artIds = arts.Select(x => x.id).ToList();
- //获取本次活动全区的得分数据ArtResult
- 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}'"))}) ";
- List<(string classId, string code, string artId, List<ArtSubjectScore> ac)> As = new();
- List<(List<ArtSubjectScore> scs, string sIds, string cd, string code)> stus = new();
- List<(List<ArtQuotaResult> artQuotas, string code)> artQuotaResults = new();
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIterator
- (queryText: queryScore))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- string schoolCode = obj.GetProperty("school").GetString();
- string sId = obj.GetProperty("studentId").GetString();
- string artId = obj.GetProperty("artId").GetString();
- string classId = obj.GetProperty("classIds").ToObject<List<string>>()[0];
- if (obj.TryGetProperty("subjectScores", out JsonElement subScore))
- {
- List<ArtSubjectScore> sc = subScore.ToObject<List<ArtSubjectScore>>();
- As.Add((classId, schoolCode, artId, sc));
- stus.Add((sc, sId, classId, schoolCode));
- }
- else
- {
- As.Add(("", "", "", new List<ArtSubjectScore>()));
- }
- artQuotaResults.Add((obj.GetProperty("results").ToObject<List<ArtQuotaResult>>(), schoolCode));
- }
- }
- }
- /*//学生信息
- var students = stus.Select(s => new
- {
- id = s.sIds,
- s.scs.FirstOrDefault(x => !string.IsNullOrWhiteSpace(x.subjectId) && x.subjectId.Equals(subjectId.GetString()))?.score,
- tchList.Where(t => t.id.Equals(s.sIds)).FirstOrDefault()?.name,
- classId = s.cd,
- className = examResults[0].classes.Where(c => c.id.Equals(s.cd)).FirstOrDefault()?.name,
- examResults[0].classes.Where(c => c.id.Equals(s.cd)).FirstOrDefault()?.gradeId,
- key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().sta,
- key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().pass,
- key.Value.Where(c => c.id.Equals(s.sIds)).FirstOrDefault().stu,
- });*/
- //预处理全区考试结果数据分科目结算
- var subjectScores = As.SelectMany(x => x.ac).GroupBy(c => c.subjectId).Select(c => new
- {
- subjectId = c.Key,
- scores = c.ToList().Select(a => a.score).Where(c => c > 0)
- }).GroupBy(g => g.subjectId).Select(z => new
- {
- name = z.Key,
- max = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? z.ToList().SelectMany(c => c.scores).ToList().Max(s => s) : 0,
- min = z.ToList().SelectMany(c => c.scores).ToList().Count > 0 ? z.ToList().SelectMany(c => c.scores).ToList().Min(s => s) : 0,
- 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,
- 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,
- 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,
- perName = periodType.GetString()
- });
- //预处理全区学生落点数据
- List<(string code, string subject, List<(string id, double sta, double pass, string stu)> values)> stuInfos = new();
- foreach (var re in results)
- {
- KeyValuePair<string, List<(string id, double sta, double pass, string stu)>> key = DoSubjectScatter(re);
- stuInfos.Add((re.school, re.subjectId, key.Value));
- }
- List<(string code, List<RMember> tchList, List<RGroupList> classLists)> students = new();
- List<(string code, Dictionary<string, int> optCount)> opt = new();
- List<(string code, List<(string gid, List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc)> gradesc)> gradeScore = new();
- /*foreach (var scBase in schoolBase)
- {
- List<string> classIds = new();
- classIds = As.Where(c => c.code.Equals(scBase.code)).Select(z => z.classId).ToList();
- classIds = classIds.Where((x, i) => classIds.FindIndex(z => z == x) == i).ToList();
- (List<RMember> tchList, List<RGroupList> classLists) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, classIds, scBase.code, null);
- students.Add((scBase.code, tchList, classLists));
- List<List<string>> tag = new();
- artQuotaResults.Where(c => c.code.Equals(scBase.code)).Select(z => z.artQuotas).ToList().ForEach(r =>
- {
- tag.AddRange(r.Where(x => null != x.files).SelectMany(f => f.files).Select(c => c.tag).ToList());
- });
- List<string> newTag = new();
- tag.ForEach(t =>
- {
- if (t.Count > 0)
- {
- newTag.AddRange(t);
- }
- });
- //List<Dictionary<string, int>> recorde = new List<Dictionary<string, int>>();
- Dictionary<string, int> optCount = new Dictionary<string, int>();
- foreach (var s in newTag)
- {
- if (optCount.ContainsKey(s))
- {
- optCount[s] = optCount[s] + 1;
- }
- else
- {
- optCount[s] = 1;
- }
- }
- opt.Add((scBase.code, optCount));
- var scStus = stus.Where(c => c.code.Equals(scBase.code)).Select(k => new
- {
- id = k.sIds,
- score = k.scs.GroupBy(z => z.subjectId).Select(p => new
- {
- p.Key,
- p.ToList().FirstOrDefault().score
- }),
- results.SelectMany(a => a.classes).Where(j => j.id.Equals(k.cd)).FirstOrDefault().gradeId
- });
- var scGrades = scStus.GroupBy(c => c.gradeId).Select(x => new {
- gradeId = x.Key,
- score = x.ToList().SelectMany(v => v.score).GroupBy(z => z.Key).Select(p => new {
- p.Key,
- score = Math.Round((double)(p.ToList().Sum(y => y.score) / p.ToList().Where(q => q.score > 0).Count()), 2),
- max = p.ToList().Where(q => q.score > 0).Max(s => Math.Abs((double)s.score)),
- min = p.ToList().Where(q => q.score > 0).Min(s => Math.Abs((double)s.score)),
- excellent = Math.Round(p.ToList().Where(s => s.score >= 80).Count() * 1.0 / p.ToList().Where(q => q.score > 0).Count(), 2),
- pass = Math.Round(p.ToList().Where(s => s.score >= 60).Count() * 1.0 / p.ToList().Where(q => q.score > 0).Count(), 2)
- })
- });
- List<(string gid, List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc)> gradesc = new();
- foreach (var gg in scGrades) {
- List<(string subjectId, double score, double max, double min, double excellent, double pass)> subsc = new();
- foreach (var sub in gg.score) {
- subsc.Add((sub.Key,sub.score,sub.max,sub.min,sub.excellent,sub.pass));
- }
- gradesc.Add((gg.gradeId, subsc));
- }
- gradeScore.Add((scBase.code, gradesc));
- }*/
- //处理全区班级
- /*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();
- foreach (var (code, tchList, classLists) in students)
- {
- 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();
- foreach (var cls in classLists)
- {
- List<ArtSubjectScore> scores = new();
- foreach (var member in cls.members)
- {
- var sc = stus.Where(c => c.sIds.Equals(member.id))?.FirstOrDefault().scs.ToList();
- scores.AddRange(sc);
- }
- var subjectScore = scores.GroupBy(c => c.subjectId).Select(z => new
- {
- z.Key,
- sc = z.ToList().Sum(a => a.score),
- maxc = z.ToList().Where(p => p.score > 0).Max(s => Math.Abs(s.score)),
- minc = z.ToList().Where(p => p.score > 0).Min(s => Math.Abs(s.score)),
- excellentc = z.ToList().Where(p => p.score > 0).Where(s => s.score >= 80).ToList().Count,
- passc = z.ToList().Where(p => p.score > 0).Where(s => s.score >= 60).ToList().Count,
- 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),
- 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),
- scs = z.ToList().Where(p => p.score > 0).Select(j => j.score).ToList(),
- average = Math.Round(z.ToList().Sum(a => a.score) * 1.0 / z.ToList().Where(p => p.score > 0).ToList().Count, 2)
- });
- List<(string subjectId, double sc, double max, double min, double excle, double pass, double ex, double pa, List<double> scs, double average)> subjectMores = new();
- foreach (var uu in subjectScore)
- {
- subjectMores.Add((uu.Key, uu.sc, uu.maxc, uu.minc, uu.excellentc, uu.passc, uu.ex, uu.pa, uu.scs, uu.average));
- }
- clsInfo.Add((cls.id, cls.name, subjectMores));
- classInfos.Add((code, clsInfo));
- }
- }*/
- 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();
- await foreach (var persents in DoKnowledgePoint(results, knoledge, setting, periodType.GetString()))
- {
- classKnowledge.Add(persents);
- }
- //区级按学段结算知识点占比
- var areaSubjectPersent = classKnowledge.GroupBy(x => x.subjectId).Select(z => new
- {
- subjectId = z.Key,
- psersent = z.ToList().SelectMany(b => b.values).GroupBy(f => f.knowledgeName).Select(k => new
- {
- know = k.Key,
- block = knos.Where(v => null != v.kno && v.kno.Contains(k.Key)).Select(x => x.name),
- score = Math.Round(k.ToList().Sum(p => p.score) / k.ToList().Count, 2),
- //tscore = k.ToList().Sum(p => p.tscore),
- /*blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
- dim = c.Key,
- score = c.ToList().Sum(o => o.score)
- })*/
- })
- });
- var schoolSubjectPersent = classKnowledge.GroupBy(x => x.code).Select(z => new
- {
- school = z.Key,
- schoolName = schoolBase.Where(c => c.code.Equals(z.Key)).FirstOrDefault().name,
- subject = z.ToList().GroupBy(v => v.subjectId).Select(p => new
- {
- subjectId = p.Key,
- psersent = p.ToList().SelectMany(b => b.values).GroupBy(f => f.knowledgeName).Select(k => new
- {
- know = k.Key,
- block = knos.Where(v => null != v.kno && v.kno.Contains(k.Key)).Select(x => x.name),
- score = Math.Round(k.ToList().Sum(d => d.score) / k.ToList().Count, 2),
- //tscore = k.ToList().Sum(p => p.tscore),
- /*blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
- dim = c.Key,
- score = c.ToList().Sum(o => o.score)
- })*/
- })
- })
- }); ;
- List<(string gid, string gname)> grades = new() { ("1", "八年级"), ("4", "五年级") };
- var gradeSubjectPersent = classKnowledge.GroupBy(x => x.subjectId).Select(z => new
- {
- subjectId = z.Key,
- psersent = z.ToList().SelectMany(b => b.values).GroupBy(f => f.gradeId).Select(k => new
- {
- grade = k.Key,
- gradeName = grades.Where(c => c.gid.Equals(k.Key)).FirstOrDefault().gname,
- knowledge = k.ToList().GroupBy(q => q.knowledgeName).Select(h => new
- {
- know = h.Key,
- block = knos.Where(v => null != v.kno && v.kno.Contains(h.Key)).Select(x => x.name),
- score = Math.Round(h.ToList().Sum(d => d.score) / h.ToList().Count, 2),
- //tscore = k.ToList().Sum(p => p.tscore),
- /* blocks = k.ToList().SelectMany(x => x.blocks).GroupBy(y => y.dim).Select(c => new {
- dim = c.Key,
- score = c.ToList().Sum(o => o.score)
- })*/
- })
- })
- });
- var classPersent = classKnowledge.Select(x => new
- {
- x.subjectId,
- x.examId,
- school = x.code,
- schoolName = schoolBase.Where(c => c.code.Equals(x.code)).FirstOrDefault().name,
- know = x.values.Select(z => new
- {
- z.classId,
- z.className,
- z.knowledgeName,
- block = knos.Where(v => null != v.kno && v.kno.Contains(z.knowledgeName)).Select(x => x.name),
- z.gradeId,
- gradeName = grades.Where(c => c.gid.Equals(z.gradeId)).FirstOrDefault().gname,
- z.score,
- //z.tscore,
- /*blocks = z.blocks.Select(f => new {
- f.name,
- f.score,
- f.dim
- })*/
- })
- });
- var paperIds = results.Select(x => x.paper.id).ToList();
- var pids = paperIds.Where((x, i) => paperIds.FindIndex(z => z == x) == i).ToList();
- List<ExamResult> examResults = new();
- foreach (var p in pids)
- {
- examResults.Add(results.Where(x => x.paper.id.Equals(p)).FirstOrDefault());
- }
- List<(string name, double score, string subject)> blockScore = new();
- foreach (var exam in examResults)
- {
- HashSet<string> knowledge = new HashSet<string>();
- List<double> point = new List<double>();
- List<List<double>> result = new List<List<double>>();
- List<ClassRange> classes = new List<ClassRange>();
- //求单个知识点所占分数
- List<string> per = new List<string>();
- if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
- {
- exam.paper.knowledge.ForEach(k =>
- {
- k.ForEach(e =>
- {
- knowledge.Add(e);
- });
- });
- }
- point = exam.paper.point;
- List<string> knowledgeName = new List<string>();
- foreach (string cla in knowledge)
- {
- knowledgeName.Add(cla);
- }
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- if (null == knowledgeName[k])
- {
- knowledgeName.Remove(knowledgeName[k]);
- }
- }
- List<double> Score = new List<double>();
- List<(string name, double score, string subject)> pointScore = new();
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- double OnePoint = 0;
- List<string> itemNo = new List<string>();
- int n = 0;
- //double scores = 0;
- exam.paper.knowledge.ForEach(kno =>
- {
- if (kno.Contains(knowledgeName[k]))
- {
- var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
- OnePoint += point[n] * itemPersent;
- /*foreach (string id in exam.studentIds)
- {
- int index = exam.studentIds.IndexOf(id);
- if (exam.studentScores[index][n] > 0)
- {
- scores += exam.studentScores[index][n] * itemPersent;
- }
- }*/
- }
- n++;
- });
- blockScore.Add((knowledgeName[k], OnePoint, exam.subjectId));
- //blockScore.AddRange(pointScore);
- }
- }
- var bls = blockScore.GroupBy(x => x.subject).Select(v => new
- {
- subjectId = v.Key,
- knoScore = v.ToList().GroupBy(k => k.name).Select(z => new
- {
- knoName = z.Key,
- score = z.ToList().Sum(j => j.score)
- })
- });
- /*var dimensions = setting.dimensions.Select(x => new
- {
- x.dimension,
- x.blocks,
- x.subjectBind
- });*/
- var subjectKnow = knoledge.Where(c => c.ptype.Equals(periodType.GetString())).Select(x => new { x.subId, x.knos }).ToList();
- List<(string subjectId, List<(string name, double score, List<string> dim)> bks)> bs = new();
- foreach (var bb in subjectKnow)
- {
- var kno1 = bls.Where(c => c.subjectId.Equals(bb.subId)).SelectMany(x => x.knoScore).ToList();
- //var kno2 = dimensions.Where(c => c.subjectBind.Equals(bb.subId)).Select(x => new { x.dimension,x.blocks}).ToList();
- List<(string name, double score)> blockScores = new();
- foreach (var k2 in bb.knos)
- {
- double bsc = 0;
- foreach (var k3 in kno1)
- {
- if (null != k2.kno && k2.kno.Contains(k3.knoName))
- {
- bsc += k3.score;
- }
- }
- blockScores.Add((k2.name, bsc));
- }
- var blk = blockScores.Select(x => new
- {
- x.name,
- x.score,
- dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
- });
- List<(string name, double score, List<string> dim)> bks = new();
- foreach (var bk in blk)
- {
- bks.Add((bk.name, bk.score, bk.dimension.ToList()));
- }
- bs.Add((bb.subId, bks));
- }
- var blocks = bs.Select(x => new
- {
- x.subjectId,
- dim = x.bks.Select(z => new
- {
- z.name,
- z.score,
- z.dim
- })
- });
- //处理区级学校数据
- /* var schoolScore = schoolBase.Select(x => new
- {
- x.code,
- x.name,
- perCname = x.pd.Where(c => c.periodType.Equals(periodType.GetString())).FirstOrDefault()?.name,
- perId = x.pd.Where(c => c.periodType.Equals(periodType.GetString())).FirstOrDefault()?.id,
- perName = periodType.GetString(),
- scores = As.Where(q => q.code.Equals(x.code)).SelectMany(z => z.ac).GroupBy(c => c.subjectId).Select(c => new
- {
- subjectId = c.Key,
- total = c.ToList().Count,
- scores = c.ToList().Select(a => a.score).Where(c => c > 0)
- }).GroupBy(g => g.subjectId).Select(z => new
- {
- count = z.ToList().Select(m => m.total)?.FirstOrDefault(),
- scount = z.ToList().Count,
- blk = blocks.Where(a => a.subjectId.Equals(z.Key))?.FirstOrDefault().dim,
- kno = schoolSubjectPersent.Where(a => a.school.Equals(x.code)).SelectMany(z => z.subject).Where(p => p.subjectId.Equals(z.Key))?.FirstOrDefault().psersent,
- name = z.Key,
- 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),
- max = z.ToList().SelectMany(c => c.scores).ToList().Max(s => s),
- min = z.ToList().SelectMany(c => c.scores).ToList().Min(s => s),
- 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),
- 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),
- average = Math.Round(z.ToList().SelectMany(c => c.scores).ToList().Sum() * 1.0 / z.ToList().SelectMany(c => c.scores).ToList().Count, 2),
- students = stuInfos.Where(c => c.code.Equals(x.code) && c.subject.Equals(z.Key)).SelectMany(n => n.values).Select(b => new
- {
- b.id,
- classId = stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().cd,
- 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,
- students.Where(k => k.code.Equals(x.code))?.FirstOrDefault().tchList.Where(j => j.id.Equals(b.id))?.FirstOrDefault().name,
- stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().scs.Where(j => j.subjectId.Equals(z.Key)).FirstOrDefault().score,
- b.pass,
- b.sta,
- b.stu,
- results.SelectMany(k => k.classes).Where(j => j.id.Equals(stus.Where(k => k.sIds.Equals(b.id))?.FirstOrDefault().cd)).FirstOrDefault().gradeId
- }),
- cInfo = classInfos.Where(c => c.code.Equals(x.code)).FirstOrDefault().cls.Select(k => new
- {
- id = k.cId,
- k.name,
- score = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().average,
- max = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().max,
- min = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().min,
- excellent = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().excle,
- pass = k.subjectMores.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().pass,
- results.SelectMany(k => k.classes).Where(j => j.id.Equals(k.cId)).FirstOrDefault().gradeId
- }),
- optCount = opt.Where(k => k.code.Equals(x.code))?.FirstOrDefault().optCount,
- grade = gradeScore.Where(k => k.code.Equals(x.code))?.FirstOrDefault().gradesc.Select(e => new {
- e.gid,
- e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().max,
- e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().min,
- e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().pass,
- e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().score,
- e.subsc.Where(s => s.subjectId.Equals(z.Key))?.FirstOrDefault().excellent,
- })
- })
- });
- try
- {
- foreach (var sc in schoolScore)
- {
- await _azureRedis.GetRedisClient(8).HashSetAsync($"ArtSchool:{sc.code}", $"1684382400000", sc.ToJsonString());
- }
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},artSchool/save()\n{e.Message}\n{e.StackTrace}", GroupNames.成都开发測試群組);
- }*/
- return Ok(new { areaSubjectPersent, schoolSubjectPersent, gradeSubjectPersent, classPersent, blocks });
- }
- return Ok(new { code = 404 ,msg = "赞无有效数据"});
- }
- private KeyValuePair<string, List<(string id, double sta, double pass, string stu)>> DoSubjectScatter(ExamResult e)
- {
- double[] point = StringHelper.ListTodouble(e.paper.point);
- double[,] result = StringHelper.ListToDouble(e.studentScores);
- try
- {
- var cdm = new ClouDASMatrix(result, point);
- //学生通过率
- List<double> pass = cdm.ScoringRate;
- //学生稳定度
- List<double> sta = cdm.StabilityRate;
- //落点区域
- List<string> stu = cdm.StuFallArea;
- int i = 0;
- List<(string id, double sta, double pass, string stu)> stus = new();
- e.studentIds.ForEach(s =>
- {
- var stuSta = sta[i] > 1 ? 1 : sta[i];
- stus.Add((s, stuSta, pass[i] * 0.01, stu[i]));
- i++;
- });
- return new KeyValuePair<string, List<(string id, double sta, double pass, string stu)>>(e.subjectId, stus);
- }
- catch (Exception ex)
- {
- BadRequest(ex.Message + ex.StackTrace);
- }
- return default;
- }
- 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,
- List<(string ptype, string subId, List<(string name, List<string> kno)> knos)> knoledge, ArtSetting setting, string type)
- {
- foreach (var exam in exams)
- {
- HashSet<string> knowledge = new HashSet<string>();
- List<double> point = new List<double>();
- List<List<double>> result = new List<List<double>>();
- List<ClassRange> classes = new List<ClassRange>();
- //求单个知识点所占分数
- List<string> per = new List<string>();
- if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
- {
- exam.paper.knowledge.ForEach(k =>
- {
- k.ForEach(e =>
- {
- knowledge.Add(e);
- });
- });
- }
- point = exam.paper.point;
- result = exam.studentScores;
- classes = exam.classes;
- List<string> knowledgeName = new List<string>();
- foreach (string cla in knowledge)
- {
- if (knowledgeName.Contains(cla.Trim()))
- {
- continue;
- }
- knowledgeName.Add(cla.Trim());
- }
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- if (null == knowledgeName[k])
- {
- knowledgeName.Remove(knowledgeName[k]);
- }
- }
- //初始化年级总分
- double total = 0;
- //处理年级单个知识点得分率
- foreach (List<double> grade in result)
- {
- total += grade.Sum();
- }
- //试卷总分
- /* double TotalPoint = point.Sum();
- List<double> knowScore = new List<double>();*/
- //学生得分情况
- List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> pScore = new();
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- foreach (var cInfo in exam.classes)
- {
- List<(string name, double score)> pointScore = new();
- List<(string knowledgeName, string gradeId, string classId, string className, double score, double tscore, List<(string name, double score, List<string> dim)> blocks)> pointTScore = new();
- int n = 0;
- double OnePoint = 0;
- List<string> itemNo = new List<string>();
- double scores = 0;
- exam.paper.knowledge.ForEach(kno =>
- {
- if (kno.Contains(knowledgeName[k]))
- {
- var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
- OnePoint += point[n] * itemPersent;
- for (int i = cInfo.range[0]; i <= cInfo.range[1]; i++)
- {
- if (exam.studentScores[i][n] > 0)
- {
- scores += exam.studentScores[i][n] * itemPersent;
- }
- }
- }
- n++;
- });
- //该知识点平均得分
- double sc = exam.studentIds.Count > 0 ? Math.Round(scores * 1.0 / (cInfo.range[1] - cInfo.range[0] + 1), 2) : 0;
- double average = sc * 1.5;
- if (average > OnePoint)
- {
- average = sc;
- }
- //知识点班级得分率
- double persent = Math.Round(OnePoint > 0 ? average / OnePoint : 0, 2);
- pointScore.Add((knowledgeName[k], OnePoint));
- /*var kno = knoledge.Where(s => s.subId.Equals(exam.subjectId) && s.ptype.Equals(type)).FirstOrDefault().knos;
- List<(string name, double score)> blockScore = new();
- foreach (var block in kno)
- {
- double bsc = 0;
- foreach (var (name, score) in pointScore)
- {
- if (null != block.kno && block.kno.Contains(name))
- {
- bsc += score;
- }
- }
- blockScore.Add((block.name, bsc));
- }
- var blk = blockScore.Select(x => new
- {
- x.name,
- x.score,
- dimension = setting.dimensions.Where(s => s.blocks.Contains(x.name)).Select(x => x.dimension)
- });
- List<(string name, double score, List<string> dim)> blocks = new();
- foreach (var bk in blk)
- {
- blocks.Add((bk.name, bk.score, bk.dimension.ToList()));
- }*/
- List<(string name, double score, List<string> dim)> blocks = new();
- pointTScore.Add((knowledgeName[k], cInfo.gradeId, cInfo.id, cInfo.name, persent, OnePoint, blocks));
- pScore.AddRange(pointTScore);
- }
- }
- yield return (pScore, exam.subjectId, exam.examId, exam.school);
- }
- }
- 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)
- {
- try
- {
- var response = await client.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(school, new PartitionKey($"Base"));
- string subjectId = string.Empty;
- List<Knowledge> knowledges = new();
- List<(string name, List<string> kno)> blocks = new();
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- School sc = json.ToObject<School>();
- var subjects = sc.period.Where(p => p.id.Equals(pId)).Select(x => x.subjects);
- foreach (var sj in subjects)
- {
- foreach (var s in sj)
- {
- if (!string.IsNullOrWhiteSpace(s.bindId) && s.bindId.Equals(subjectBid))
- {
- subjectId = s.id;
- }
- }
- }
- string code = $"Knowledge-{school}-{subjectId}";
- StringBuilder sql = new StringBuilder($"select value(c) from c");
- if (string.IsNullOrWhiteSpace(pId))
- {
- sql.Append($" where c.periodId = '{pId}'");
- }
- await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<Knowledge>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"{code}") }))
- {
- knowledges.Add(item);
- }
- }
- foreach (var know in knowledges)
- {
- foreach (var block in know.blocks)
- {
- blocks.Add((block.name, block.points));
- }
- }
- return (key, subjectBid, blocks);
- }
- catch (Exception e)
- {
- return (null, null, null);
- }
- }
- 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)
- {
- HashSet<string> knowledge = new HashSet<string>();
- List<double> point = new List<double>();
- List<List<double>> result = new List<List<double>>();
- List<ClassRange> classes = new List<ClassRange>();
- //求单个知识点所占分数
- List<string> per = new List<string>();
- if (exam.paper.knowledge != null && exam.paper.knowledge.Count > 0)
- {
- exam.paper.knowledge.ForEach(k =>
- {
- k.ForEach(e =>
- {
- knowledge.Add(e);
- });
- });
- }
- else
- {
- return (default, default, default, default);
- }
- point = exam.paper.point;
- List<string> knowledgeName = new List<string>();
- foreach (string cla in knowledge)
- {
- if (knowledgeName.Contains(cla.Trim()))
- {
- continue;
- }
- knowledgeName.Add(cla.Trim());
- }
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- if (null == knowledgeName[k])
- {
- knowledgeName.Remove(knowledgeName[k]);
- }
- }
- //初始化年级总分
- double total = 0;
- //处理年级单个知识点得分率
- foreach (List<double> grade in result)
- {
- total += grade.Sum();
- }
- //试卷总分
- double TotalPoint = point.Sum();
- List<double> knowScore = new List<double>();
- //学生得分情况
- List<double> Score = new List<double>();
- List<(string name, double score)> pointScore = new();
- List<(string name, double score)> pointTScore = new();
- for (int k = 0; k < knowledgeName.Count; k++)
- {
- double OnePoint = 0;
- List<string> itemNo = new List<string>();
- int n = 0;
- double scores = 0;
- exam.paper.knowledge.ForEach(kno =>
- {
- if (kno.Contains(knowledgeName[k]))
- {
- var itemPersent = kno.Count > 0 ? 1 / Convert.ToDouble(kno.Count) : 0;
- OnePoint += point[n] * itemPersent;
- foreach (string id in exam.studentIds)
- {
- int index = exam.studentIds.IndexOf(id);
- if (exam.studentScores[index][n] > 0)
- {
- scores += exam.studentScores[index][n] * itemPersent;
- }
- }
- }
- n++;
- });
- Score.Add(scores);
- //单个知识点的配分
- pointScore.Add((knowledgeName[k], OnePoint));
- //该知识点平均得分
- double sc = exam.studentIds.Count > 0 ? Math.Round(scores * 1.0 / exam.studentIds.Count, 2) : 0;
- double average = sc * 1.5;
- if (average > OnePoint)
- {
- average = sc;
- }
- //知识点占比
- double persent = Math.Round(OnePoint > 0 ? average / OnePoint : 0, 2);
- per.Add(persent.ToString("0.00"));
- //单个知识点所有学生得分率
- pointTScore.Add((knowledgeName[k], persent));
- }
- KeyValuePair<string, List<string>> key1 = new(exam.subjectId, knowledgeName);
- KeyValuePair<string, List<string>> key2 = new(exam.subjectId, per);
- KeyValuePair<string, List<(string name, double score)>> key3 = new(exam.subjectId, pointScore);
- KeyValuePair<string, List<(string name, double score)>> key4 = new(exam.subjectId, pointTScore);
- //KeyValuePair<string, List<double>> key3 = new KeyValuePair<string, List<double>>(exam.subjectId, allPer);
- return (key1, key2, key3, key4);
- }
- private async Task<List<string>> getStudentsAsync(List<string> ids, CosmosClient client, string pk, string source)
- {
- try
- {
- List<string> sIds = new();
- 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}'"))})"))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- sIds.Add(account.GetProperty("id").GetString());
- }
- }
- }
- return sIds;
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/get-students()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return new List<string>();
- }
- }
- [ProducesDefaultResponseType]
- [HttpPost("delete-art")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> DeleteArt(JsonElement request)
- {
- try
- {
- //区级活动Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- //区级id
- if (!request.TryGetProperty("areaId", out JsonElement code)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- List<string> ide = new();
- var response = await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey($"Art-{code}"));
- /*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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- ide.Add(account.GetProperty("id").GetString());
- }
- }
- }*/
- await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey("ArtExam"));
- // await client.GetContainer("TEAMModelOS", "Common").DeleteItemsAsync<ArtExam>(ide, "ArtExam");
- List<(string id, string name)> bascId = await getId(client, code.GetString());
- List<(string id, string name)> ids = new();
- foreach ((string sId, string name) in bascId)
- {
- 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}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- ids.Add((account.GetProperty("id").GetString(), account.GetProperty("code").GetString()));
- }
- }
- }
- }
- if (ids.Count > 0)
- {
- foreach ((string s, string c) in ids)
- {
- var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- ArtEvaluation art = json.ToObject<ArtEvaluation>();
- art.status = 404;
- foreach (var info in art.settings)
- {
- foreach (var acs in info.task)
- {
- if (!string.IsNullOrEmpty(acs.acId))
- {
- if (acs.type == 1)
- {
- Azure.Response eresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(acs.acId, new PartitionKey($"Exam-{art.school}"));
- if (eresponse.Status == 200)
- {
- ExamInfo data = JsonDocument.Parse(eresponse.Content).RootElement.Deserialize<ExamInfo>();
- data.status = 404;
- await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"{data.code}"));
- }
- }
- }
- }
- }
- await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync(art, art.id, new PartitionKey($"{art.code}"));
- }
- }
- }
- return Ok(new { id, code = response.Status });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/delete-art()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-study-teachers")]
- public async Task<IActionResult> FindAllStudyTeacher(JsonElement request)
- {
- try
- {
- //区级活动Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
- List<Study> studies = new();
- List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
- //List<string> aName = new();
- List<Survey> trSurveys = new();
- List<ExamLite> trExams = new();
- List<Study> moreInfo = new();
- List<Homework> works = new();
- //提取研修相关老师活动记录
- List<StudyRecord> records = new();
- List<RMember> teac = new();
- var aresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(id.ToString(), new PartitionKey($"Study-{areaId}"));
- if (aresponse.Status == (int)HttpStatusCode.OK)
- {
- var sJson = await JsonDocument.ParseAsync(aresponse.ContentStream);
- Study study = sJson.ToObject<Study>();
- (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, study.tchLists, study.school,null,-1,study.startTime);
- teac = tchList;
- var query = $"select value(c) from c where c.pId = '{id}'";
- foreach ((string code, string name) in baseIds)
- {
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryIterator<Study>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Study-{code}") }))
- {
- studies.Add(item);
- }
- }
- foreach (Study stu in studies)
- {
- if (!string.IsNullOrEmpty(stu.surveyId))
- {
- var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.surveyId, new PartitionKey($"Survey-{stu.school}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- Survey surs = json.ToObject<Survey>();
- trSurveys.Add(surs);
- }
- }
- if (!string.IsNullOrEmpty(stu.examId))
- {
- var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.examId, new PartitionKey($"ExamLite-{stu.school}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- ExamLite lite = json.ToObject<ExamLite>();
- trExams.Add(lite);
- }
- }
- if (!string.IsNullOrEmpty(stu.workId))
- {
- var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(stu.workId, new PartitionKey($"Homework-{stu.school}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- Homework work = json.ToObject<Homework>();
- works.Add(work);
- }
- }
- };
- moreInfo.Add(study);
- foreach (var member in tchList)
- {
- var response = await client.GetContainer("TEAMModelOS", "Teacher").ReadItemStreamAsync(id.ToString(), new PartitionKey($"StudyRecord-{member.id}"));
- if (response.Status == (int)HttpStatusCode.OK)
- {
- var json = await JsonDocument.ParseAsync(response.ContentStream);
- StudyRecord record = json.ToObject<StudyRecord>();
- records.Add(record);
- }
- }
- }
- var survey = trSurveys.Select(s => new
- {
- ansCount = s.answers.Count,
- });
- var twork = works.Select(s => new
- {
- ansCount = s.teachers.Where(h => !string.IsNullOrEmpty(h.hw)).ToList().Count,
- });
- var exam = trExams.Select(s => new
- {
- ansCount = s.teachers.Where(h => h.answer.Count > 0).ToList().Count,
- });
- var info = new
- {
- signCount = records.Where(h => h.signTime > 0).ToList().Count,
- lateCount = records.Where(h => !string.IsNullOrEmpty(h.sign) && h.sign.Equals("2")).ToList().Count,
- //acount = records.Where(h => h.aTime > 0).ToList().Count
- };
- return Ok(new { survey, work = twork, exam, info, studies = moreInfo.Select(m => m), teac });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-study-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-vote")]
- public async Task<IActionResult> FindAllVote(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //List<string> baseIds = await getId(client, id.GetString());
- List<object> votes = new();
- //List<string> aName = new();
- var query = $"select c.id,c.name,c.startTime,c.progress,c.owner,c.school from c ";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Vote-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- votes.Add(obj.ToObject<object>());
- }
- }
- }
- return Ok(new { votes });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-vote()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-vote-id")]
- public async Task<IActionResult> FindAllVoteTeacher(JsonElement request)
- {
- try
- {
- //区级活动Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
- //List<object> votes = new();
- List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
- //List<string> aName = new();
- List<Vote> votes = new List<Vote>();
- Vote vote = null;
- List<(string code, string name, string url, int count)> recordUrl = new List<(string code, string name, string url, int count)>();
- var response = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync(id.GetString(), new PartitionKey($"Vote-{areaId}"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- vote = json.ToObject<Vote>();
- var query = $"select c.tchLists,c.recordUrl from c where c.pId = '{id}'";
- foreach ((string code, string name) in baseIds)
- {
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Vote-{code}") }))
- {
- using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
- if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = sjson.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- List<string> tcs = account.GetProperty("tchLists").ToObject<List<string>>();
- (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, tcs, code);
- // (List<TmdInfo> tmdInfos, List<ClassListInfo> classInfos) = await TriggerStuActivity.GetTchList(client, _dingDing, ids, $"{school}");
- //(List<TmdInfo> tchList, _) = await TriggerStuActivity.GetTchList(client, _dingDing, tcs, code);
- recordUrl.Add((code, name, account.GetProperty("recordUrl").GetString(), tchList.Count));
- }
- }
- }
- }
- }
- //var info = ps.Select(p => new { p.id, p.name });
- return Ok(new { vote, code = recordUrl.Select(r => new { r.code, r.name, r.url, r.count }) });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-vote-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-survey")]
- public async Task<IActionResult> FindAllSurvey(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //List<string> baseIds = await getId(client, id.GetString());
- List<object> surveys = new();
- // List<string> aName = new();
- var query = $"select c.id,c.name,c.startTime,c.progress,c.sType,c.owner,c.school from c ";
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Survey-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- surveys.Add(obj.ToObject<object>());
- }
- }
- }
- return Ok(new { surveys });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-survey()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-survey-id")]
- public async Task<IActionResult> FindAllSurveyTeacher(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
- List<object> surveys = new();
- Survey survey = null;
- List<(string code, string name, string url, int count)> recordUrl = new List<(string code, string name, string url, int count)>();
- var response = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemStreamAsync(id.GetString(), new PartitionKey($"Survey-{areaId}"));
- if (response.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(response.ContentStream);
- survey = json.ToObject<Survey>();
- var query = $"select c.tchLists,c.recordUrl from c where c.pId = '{id}'";
- foreach ((string code, string name) in baseIds)
- {
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Survey-{code}") }))
- {
- using var sjson = await JsonDocument.ParseAsync(item.ContentStream);
- if (sjson.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = sjson.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- List<string> tcs = account.GetProperty("tchLists").ToObject<List<string>>();
- (List<RMember> tchList, List<RGroupList> classInfos) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, tcs, code);
- // (List<TmdInfo> tmdInfos, List<ClassListInfo> classInfos) = await TriggerStuActivity.GetTchList(client, _dingDing, ids, $"{school}");
- //(List<TmdInfo> tchList, _) = await TriggerStuActivity.GetTchList(client, _dingDing, tcs, code);
- recordUrl.Add((code, name, account.GetProperty("recordUrl").GetString(), tchList.Count));
- }
- }
- }
- }
- }
- //var info = ps.Select(p => new { p.id, p.name });
- return Ok(new { survey, code = recordUrl.Select(r => new { r.code, r.name, r.url, r.count }) });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-survey-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-Exam")]
- public async Task<IActionResult> FindAllExam(JsonElement request)
- {
- try
- {
- //区级Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- //List<string> baseIds = await getId(client, id.GetString());
- List<object> exams = new();
- // List<string> aName = new();
- var query = $"select c.id,c.name,c.createTime,c.sType,c.owner,c.school from c ";
- await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ExamLite-{id}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- exams.Add(obj.ToObject<object>());
- }
- }
- }
- return Ok(new { exams });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-exam()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- [AuthToken(Roles = "teacher,admin,student")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- [HttpPost("find-all-exam-teachers")]
- public async Task<IActionResult> FindAllExamTeacher(JsonElement request)
- {
- try
- {
- //区级活动Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- List<(string id, string name)> baseIds = await getId(client, areaId.GetString());
- List<object> exams = new();
- List<(string id, string name)> ps = await getInfo(client, areaId.GetString());
- //List<string> aName = new();
- var query = $"select c.school,c.teachers from c where c.acId = '{id}'";
- foreach ((string code, string name) in baseIds)
- {
- await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"TrExam-{code}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
- {
- exams.Add(obj.ToObject<object>());
- }
- }
- }
- }
- var info = ps.Select(p => new { p.id, p.name });
- return Ok(new { info, exams });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/find-all-exam-teachers()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 保存投票信息
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("save-vote")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> SaveVote(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
- if (!request.TryGetProperty("vote", out JsonElement vote)) return BadRequest();
- List<parameter> parameters = para.ToObject<List<parameter>>();
- List<Vote> votes = new();
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var client = _azureCosmos.GetCosmosClient();
- Vote areaVote = vote.ToObject<Vote>();
- areaVote.owner = "area";
- areaVote.ttl = -1;
- areaVote.code = "Vote-" + id.GetString();
- areaVote.createTime = now;
- if (areaVote.startTime <= 0)
- {
- areaVote.startTime = now;
- }
- if (areaVote.startTime > now)
- {
- areaVote.progress = "pending";
- }
- else
- {
- areaVote.progress = "going";
- }
- if (string.IsNullOrEmpty(areaVote.id))
- {
- areaVote.id = Guid.NewGuid().ToString();
- }
- List<string> allName = new();
- foreach (parameter pa in parameters)
- {
- Vote trVote = vote.ToObject<Vote>();
- string code = pa.sId;
- trVote.school = code;
- trVote.ttl = -1;
- trVote.code = "Vote-" + code;
- trVote.createTime = now;
- trVote.areaId = id.GetString();
- trVote.owner = "area";
- trVote.pId = areaVote.id;
- trVote.tchLists = pa.gId;
- trVote.targetType = "research";
- trVote.publish = 1;
- trVote.progress = "pending";
- /*if (pa.gName.Count == 0)
- {
- string sName = pa.sName + "-" + "所有老师(未分组)";
- allName.Add(sName);
- string json = "所有老师(未分组)";
- //var json = new { name = "所有老师(未分组)" };
- trVote.targets.Add(json.ToJsonString().ToObject<JsonElement>());
- }
- else
- {
- var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
- trVote.targets = tn;
- foreach (string name in pa.gName)
- {
- //处理区级target
- string sName = pa.sName + "-" + name;
- allName.Add(sName);
- }
- }*/
- if (string.IsNullOrEmpty(trVote.id))
- {
- trVote.id = Guid.NewGuid().ToString();
- string url = $"/vote/{trVote.id}/record.json";
- trVote.recordUrl = url;
- await _azureStorage.GetBlobContainerClient(code).UploadFileByContainer(new { options = new List<string>(), records = new List<VoteRecord>() }.ToJsonString(), "vote", $"{trVote.id}/record.json");
- await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(trVote, new PartitionKey($"{trVote.code}"));
- }
- else
- {
- await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(trVote, trVote.id, new PartitionKey($"{trVote.code}"));
- }
- votes.Add(trVote);
- }
- var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
- /*List<JsonElement> atn = new List<JsonElement>();
- foreach (string agn in allName)
- {
- atn.Add(agn.ToObject<JsonElement>());
- }*/
- areaVote.targets = atn;
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaVote, new PartitionKey($"{areaVote.code}"));
- var ids = votes.Select(s => new { s.id, s.school });
- return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-vote()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("delete")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> Delete(JsonElement request)
- {
- try
- {
- //区级活动Id
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- //区级id
- if (!request.TryGetProperty("areaId", out JsonElement code)) return BadRequest();
- if (!request.TryGetProperty("pk", out JsonElement pk)) return BadRequest();
- var client = _azureCosmos.GetCosmosClient();
- var aresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(id.ToString(), new PartitionKey($"{pk}-{code}"));
- if (aresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(aresponse.ContentStream);
- Study study = json.ToObject<Study>();
- if (study.tchLists.Count > 0)
- {
- foreach (var list in study.tchLists)
- {
- await client.GetContainer("TEAMModelOS", "Teacher").DeleteItemStreamAsync(list, new PartitionKey($"GroupList-{code}"));
- }
- }
- }
- var response = await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(id.ToString(), new PartitionKey($"{pk}-{code}"));
- List<(string id, string name)> bascId = await getId(client, code.GetString());
- List<(string id, string name)> ids = new();
- foreach ((string sId, string name) in bascId)
- {
- 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}") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- ids.Add((account.GetProperty("id").GetString(), account.GetProperty("code").GetString()));
- }
- }
- }
- }
- if (ids.Count > 0)
- {
- foreach ((string s, string c) in ids)
- {
- if (c.Contains("Study"))
- {
- var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
- if (sresponse.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
- Study study = json.ToObject<Study>();
- if (!string.IsNullOrEmpty(study.examId))
- {
- await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.examId, new PartitionKey($"ExamLite-{study.school}"));
- }
- if (!string.IsNullOrEmpty(study.surveyId))
- {
- await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.surveyId, new PartitionKey($"Survey-{study.school}"));
- }
- if (!string.IsNullOrEmpty(study.workId))
- {
- await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(study.workId, new PartitionKey($"Homework-{study.school}"));
- }
- }
- }
- await client.GetContainer("TEAMModelOS", "Common").DeleteItemStreamAsync(s.ToString(), new PartitionKey($"{c}"));
- }
- }
- return Ok(new { id, code = response.Status });
- }
- catch (Exception e)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/delete()\n{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 保存问卷信息
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("save-survey")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> SaveSurvey(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
- if (!request.TryGetProperty("survey", out JsonElement survey)) return BadRequest();
- List<parameter> parameters = para.ToObject<List<parameter>>();
- List<Survey> surveys = new();
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var client = _azureCosmos.GetCosmosClient();
- Survey areaSurvey = survey.ToObject<Survey>();
- areaSurvey.owner = "area";
- areaSurvey.ttl = -1;
- areaSurvey.code = "Survey-" + id.GetString();
- areaSurvey.createTime = now;
- if (areaSurvey.startTime <= 0)
- {
- areaSurvey.startTime = now;
- }
- if (areaSurvey.startTime > now)
- {
- areaSurvey.progress = "pending";
- }
- else
- {
- areaSurvey.progress = "going";
- }
- if (string.IsNullOrEmpty(areaSurvey.id))
- {
- areaSurvey.id = Guid.NewGuid().ToString();
- }
- List<string> allName = new();
- foreach (parameter pa in parameters)
- {
- Survey trSurvey = survey.ToObject<Survey>();
- string code = pa.sId;
- trSurvey.ttl = -1;
- trSurvey.school = code;
- trSurvey.code = "Survey-" + code;
- trSurvey.createTime = now;
- trSurvey.areaId = id.GetString();
- trSurvey.owner = "area";
- trSurvey.tchLists = pa.gId;
- trSurvey.pId = areaSurvey.id;
- trSurvey.targetType = "research";
- trSurvey.publish = 1;
- trSurvey.progress = "pending";
- /*if (pa.gName.Count == 0)
- {
- string sName = pa.sName + "-" + "所有老师(未分组)";
- allName.Add(sName);
- string json = "所有老师(未分组)";
- trSurvey.targets.Add(json.ToJsonString().ToObject<JsonElement>());
- }
- else
- {
- var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
- trSurvey.targets = tn;
- foreach (string name in pa.gName)
- {
- //处理区级target
- string sName = pa.sName + "-" + name;
- allName.Add(sName);
- }
- }*/
- //await getMoreSurvey(pa, trSurvey);
- trSurvey.id = Guid.NewGuid().ToString();
- trSurvey.recordUrl = $"/survey/{trSurvey.id}/record.json";
- var cods = new { records = new List<string>(), userids = new List<string>(), question = new List<QuestionRecord>() };
- await _azureStorage.GetBlobContainerClient(code).UploadFileByContainer(cods.ToJsonString(), "survey", $"{trSurvey.id}/record.json");
- // trSurvey.blob = SurveyService.getBlob(trSurvey.id);
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(trSurvey, new PartitionKey($"{trSurvey.code}"));
- surveys.Add(trSurvey);
- }
- //areaSurvey.targets = allName;
- var atn = allName.ToJsonString().ToObject<List<JsonElement>>();
- areaSurvey.targets = atn;
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaSurvey, new PartitionKey($"{areaSurvey.code}"));
- var ids = surveys.Select(s => new { s.id, s.school });
- return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-survey()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 保存评测信息
- /// </summary>
- /// <param name="request"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- //[AuthToken(Roles = "teacher,admin")]
- [HttpPost("save-exam")]
- [AuthToken(Roles = "teacher,admin")]
- #if !DEBUG
- [Authorize(Roles = "IES")]
- #endif
- public async Task<IActionResult> SaveExam(JsonElement request)
- {
- try
- {
- if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
- if (!request.TryGetProperty("para", out JsonElement para)) return BadRequest();
- if (!request.TryGetProperty("exam", out JsonElement exam)) return BadRequest();
- List<parameter> parameters = para.ToObject<List<parameter>>();
- List<ExamLite> exams = new();
- long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
- var client = _azureCosmos.GetCosmosClient();
- ExamLite areaExam = exam.ToObject<ExamLite>();
- areaExam.owner = "area";
- areaExam.ttl = -1;
- areaExam.code = "TrExam-" + id.GetString();
- areaExam.createTime = now;
- if (string.IsNullOrEmpty(areaExam.id))
- {
- areaExam.id = Guid.NewGuid().ToString();
- }
- List<string> allName = new();
- if (areaExam.startTime > now)
- {
- areaExam.progress = "pending";
- }
- else
- {
- areaExam.progress = "going";
- }
- foreach (parameter pa in parameters)
- {
- ExamLite trExam = exam.ToObject<ExamLite>();
- string code = pa.sId;
- trExam.ttl = -1;
- trExam.school = code;
- trExam.code = "TrExam-" + code;
- trExam.createTime = now;
- trExam.areaId = id.GetString();
- trExam.owner = "area";
- trExam.pId = areaExam.id;
- trExam.targetType = "research";
- trExam.progress = "pending";
- trExam.publish = 1;
- /*if (pa.gName.Count == 0)
- {
- string sName = pa.sName + "-" + "所有老师(未分组)";
- allName.Add(sName);
- }
- else
- {
- foreach (string name in pa.gName)
- {
- //处理区级target
- string sName = pa.sName + "-" + name;
- allName.Add(sName);
- }
- }*/
- //await getMoreExam(pa, trExam);
- if (string.IsNullOrEmpty(trExam.id))
- {
- trExam.id = Guid.NewGuid().ToString();
- // trExam.blob = ExamService.getBlob(trExam.id);
- await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(trExam, new PartitionKey($"{trExam.code}"));
- }
- else
- {
- //trExam.blob = ExamService.getBlob(trExam.id);
- await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(trExam, trExam.id, new PartitionKey($"{trExam.code}"));
- }
- exams.Add(trExam);
- }
- //areaExam.targets = allName;
- await client.GetContainer("TEAMModelOS", "Common").UpsertItemAsync(areaExam, new PartitionKey($"{areaExam.code}"));
- var ids = exams.Select(s => new { s.id, s.school });
- return Ok(new { id, ids, code = (int)HttpStatusCode.OK });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"OS,{_option.Location},area/save-exam()\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
- return BadRequest();
- }
- }
- private async Task<List<(string id, string name)>> getId(CosmosClient client, string id)
- {
- //获取区级以下所有学校编码和基础信息
- List<(string id, string name)> baseIds = new();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- baseIds.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
- }
- }
- }
- return baseIds;
- }
- private async Task<List<teacherInfo>> GetTeacherAll(string name, string code)
- {
- var client = _azureCosmos.GetCosmosClient();
- string query = string.Empty;
- List<teacherInfo> teachers = new List<teacherInfo>();
- if (string.IsNullOrEmpty(name))
- {
- query = $"SELECT c.id, c.name, c.groupName FROM c ";
- }
- else
- {
- query = $"SELECT c.id, c.name, c.groupName FROM c where c.groupName = '{name}'";
- }
- await foreach (var item in client.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<teacherInfo>(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Teacher-{code}") }))
- {
- teachers.Add(item);
- }
- return teachers;
- }
- private Task<ExamLite> getMoreExam(parameter pa, ExamLite trExam)
- {
- if (pa.gName.Count == 0)
- {
- string json = "所有老师(未分组)";
- trExam.targets.Add(json.ToJsonString().ToObject<JsonElement>());
- }
- else
- {
- var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
- trExam.targets = tn;
- }
- return Task.FromResult(trExam);
- }
- private Task<Survey> getMoreSurvey(parameter pa, Survey trSurvey)
- {
- if (pa.gName.Count == 0)
- {
- //trSurvey.targets.Add("所有老师(未分组)");
- string json = "所有老师(未分组)";
- trSurvey.targets.Add(json.ToJsonString().ToObject<JsonElement>());
- }
- else
- {
- var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
- trSurvey.targets = tn;
- }
- return Task.FromResult(trSurvey);
- }
- private Task<Homework> getMoreWork(parameter pa, Homework work)
- {
- if (pa.gName.Count == 0)
- {
- //trSurvey.targets.Add("所有老师(未分组)");
- string json = "所有老师(未分组)";
- work.targets.Add(json.ToJsonString().ToObject<JsonElement>());
- }
- else
- {
- var tn = pa.gName.ToJsonString().ToObject<List<JsonElement>>();
- work.targets = tn;
- }
- return Task.FromResult(work);
- }
- private async Task<List<(string id, string name)>> getInfo(CosmosClient client, string id)
- {
- List<(string id, string name)> scInfos = new List<(string id, string name)>();
- 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") }))
- {
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
- {
- var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
- while (accounts.MoveNext())
- {
- JsonElement account = accounts.Current;
- scInfos.Add((account.GetProperty("id").GetString(), account.GetProperty("name").GetString()));
- }
- }
- }
- return scInfos;
- }
- public class parameter
- {
- public string sId { get; set; }
- public string sName { get; set; }
- public List<string> gName { get; set; }
- public List<string> gId { get; set; }
- }
- public class teacherInfo
- {
- public string id { get; set; }
- public string name { get; set; }
- public string groupName { get; set; }
- }
- }
- }
|