1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115 |
- 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";
- 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 (response.Status == 200)
- {
- ExamInfo data = JsonDocument.Parse(response.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);
- 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; }
- }
- }
- }
|