ActivityController.cs 310 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426
  1. using Microsoft.Azure.Cosmos;
  2. using Microsoft.AspNetCore.Http;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Extensions.Options;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Linq;
  8. using System.Text;
  9. using System.Text.Json;
  10. using System.Threading.Tasks;
  11. using TEAMModelOS.Models;
  12. using TEAMModelOS.SDK.Models;
  13. using TEAMModelOS.SDK.DI;
  14. using TEAMModelOS.SDK.Extension;
  15. using Azure;
  16. using Microsoft.Extensions.Configuration;
  17. using TEAMModelOS.Filter;
  18. using TEAMModelOS.SDK;
  19. using StackExchange.Redis;
  20. using System.IdentityModel.Tokens.Jwt;
  21. using Microsoft.AspNetCore.Routing;
  22. using Pipelines.Sockets.Unofficial.Arenas;
  23. using static TEAMModelOS.SDK.CoreAPIHttpService;
  24. using System.Net;
  25. using TEAMModelOS.SDK.Models.Service;
  26. using TEAMModelOS.Services;
  27. using Azure.Storage.Sas;
  28. using Microsoft.IdentityModel.Tokens;
  29. using System.Net.Http;
  30. using IHttpClientFactory = System.Net.Http.IHttpClientFactory;
  31. using SDK.Helpers;
  32. namespace TEAMModelOS.Controllers
  33. {
  34. [ProducesResponseType(StatusCodes.Status200OK)]
  35. [ProducesResponseType(StatusCodes.Status400BadRequest)]
  36. [Route("activity")]
  37. [ApiController]
  38. public class ActivityController : ControllerBase
  39. {
  40. private AzureCosmosFactory _azureCosmos;
  41. private readonly DingDing _dingDing;
  42. private readonly CoreAPIHttpService _coreAPIHttpService;
  43. private readonly Option _option;
  44. private readonly AzureServiceBusFactory _serviceBus;
  45. private readonly AzureStorageFactory _azureStorage;
  46. private readonly AzureRedisFactory _azureRedis;
  47. private readonly HttpTrigger _httpTrigger;
  48. private readonly IPSearcher _searcher;
  49. public IConfiguration _configuration { get; set; }
  50. private IHttpClientFactory _httpClientFactory;
  51. public ActivityController(AzureRedisFactory azureRedis, AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, CoreAPIHttpService coreAPIHttpService, AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration, HttpTrigger httpTrigger, IPSearcher searcher, IHttpClientFactory httpClientFactory)
  52. {
  53. _azureCosmos = azureCosmos;
  54. _dingDing = dingDing;
  55. _option = option?.Value;
  56. _serviceBus = serviceBus;
  57. _configuration = configuration;
  58. _azureStorage = azureStorage;
  59. _azureRedis = azureRedis;
  60. _coreAPIHttpService = coreAPIHttpService;
  61. _httpTrigger=httpTrigger;
  62. _searcher=searcher;
  63. _httpClientFactory=httpClientFactory;
  64. }
  65. /// <summary>
  66. /// 分站管理
  67. /// </summary>
  68. /// <param name="request"></param>
  69. /// <returns></returns>
  70. [ProducesDefaultResponseType]
  71. [AuthToken(Roles = "admin,area")]
  72. [HttpPost("website-manage")]
  73. #if !DEBUG
  74. [Authorize(Roles = "IES")]
  75. #endif
  76. public async Task<IActionResult> WebsiteManage(JsonElement request)
  77. {
  78. (string tmdid, _, _, string school) = HttpContext.GetAuthTokenInfo();
  79. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  80. {
  81. switch (true)
  82. {
  83. case bool when $"{grant_type}".Equals("update", StringComparison.OrdinalIgnoreCase):
  84. {
  85. request.TryGetProperty("areaId", out JsonElement _areaId);
  86. if (!request.TryGetProperty("website", out JsonElement _website)) return BadRequest();
  87. ActivityWebsite website = _website.ToObject<ActivityWebsite>();
  88. ResponseMessage teammodelResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(website.id, new PartitionKey("ActivityWebsite"));
  89. if (teammodelResponse.StatusCode==System.Net.HttpStatusCode.OK)
  90. {
  91. ActivityWebsite activityWebsite = JsonDocument.Parse(teammodelResponse.Content).RootElement.ToObject<ActivityWebsite>();
  92. website.route=activityWebsite.route;
  93. website.pk=activityWebsite.pk;
  94. website.code=activityWebsite.code;
  95. website.scope=activityWebsite.scope;
  96. //不是醍摩豆学区的,不能修改是否有公开办活动权限
  97. if (!(string.IsNullOrWhiteSpace($"{_areaId}")&& _areaId.Equals("02944f32-f534-3397-ea56-e6f1fc6c3714")))
  98. {
  99. website.allowPublic=activityWebsite.allowPublic;
  100. }
  101. }
  102. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(website, new PartitionKey("ActivityWebsite"));
  103. return Ok(new { website, code = 200 });
  104. }
  105. case bool when $"{grant_type}".Equals("list", StringComparison.OrdinalIgnoreCase):
  106. {
  107. List<ActivityWebsite> websites = new List<ActivityWebsite>();
  108. if (!request.TryGetProperty("websiteId", out JsonElement _websiteId)) return BadRequest();
  109. string websiteId = _websiteId.GetString();
  110. if (websiteId.Equals("02944f32-f534-3397-ea56-e6f1fc6c3714", StringComparison.OrdinalIgnoreCase))
  111. {
  112. ResponseMessage teammodelResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync("teammodel", new PartitionKey("ActivityWebsite"));
  113. if (teammodelResponse.StatusCode==System.Net.HttpStatusCode.OK)
  114. {
  115. ActivityWebsite activityWebsite = JsonDocument.Parse(teammodelResponse.Content).RootElement.ToObject<ActivityWebsite>();
  116. websites.Add(activityWebsite);
  117. }
  118. else
  119. {
  120. ActivityWebsite website = new ActivityWebsite
  121. {
  122. id="teammodel",
  123. pk="ActivityWebsite",
  124. code="ActivityWebsite",
  125. route="teammodel",
  126. scope="public",
  127. allowPublic=1,
  128. };
  129. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(website, new PartitionKey(website.code));
  130. websites.Add(website);
  131. }
  132. //返回其他区的。
  133. string sqlArea = "select value c from c ";
  134. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<Area>(sqlArea, "Base-Area");
  135. if (result.list.IsNotEmpty())
  136. {
  137. string sqlWebsite = $"select value c from c where c.id in ({string.Join(",", result.list.Select(z => $"'{z.id}'"))})";
  138. var resultWebsite = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ActivityWebsite>(sqlWebsite, "ActivityWebsite");
  139. foreach (var item in result.list)
  140. {
  141. var website = resultWebsite.list.Find(z => z.id.Equals(item.id));
  142. if (website!=null)
  143. {
  144. if (!string.IsNullOrWhiteSpace(item.shortCode))
  145. {
  146. bool change = false;
  147. if (string.IsNullOrWhiteSpace(website.route))
  148. {
  149. website.route=item.shortCode;
  150. change = true;
  151. }
  152. else
  153. {
  154. if (!website.route.Equals(item.shortCode))
  155. {
  156. website.route=item.shortCode;
  157. change = true;
  158. }
  159. }
  160. if (change)
  161. {
  162. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(website, new PartitionKey(website.code));
  163. }
  164. }
  165. }
  166. else
  167. {
  168. website= new ActivityWebsite
  169. {
  170. id= item.id,
  171. code="ActivityWebsite",
  172. pk="ActivityWebsite",
  173. route=item.shortCode,
  174. scope="area",
  175. allowPublic=0,
  176. };
  177. }
  178. websites.Add(website);
  179. }
  180. }
  181. }
  182. else
  183. {
  184. ResponseMessage activityWebsiteResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(websiteId, new PartitionKey("ActivityWebsite"));
  185. if (activityWebsiteResponse.StatusCode==System.Net.HttpStatusCode.OK)
  186. {
  187. ActivityWebsite activityWebsite = JsonDocument.Parse(activityWebsiteResponse.Content).RootElement.ToObject<ActivityWebsite>();
  188. Area area = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemAsync<Area>(websiteId, new PartitionKey("Base-Area"));
  189. if (!string.IsNullOrWhiteSpace(area.shortCode))
  190. {
  191. bool change = false;
  192. if (string.IsNullOrWhiteSpace(activityWebsite.route))
  193. {
  194. activityWebsite.route=area.shortCode;
  195. change = true;
  196. }
  197. else
  198. {
  199. if (!activityWebsite.route.Equals(area.shortCode))
  200. {
  201. activityWebsite.route=area.shortCode;
  202. change = true;
  203. }
  204. }
  205. if (change)
  206. {
  207. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(activityWebsite, new PartitionKey(activityWebsite.code));
  208. }
  209. }
  210. websites.Add(activityWebsite);
  211. }
  212. else
  213. {
  214. string route = string.Empty;
  215. string scope = string.Empty;
  216. ResponseMessage responseArea = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(websiteId, new PartitionKey("Base-Area"));
  217. if (responseArea.StatusCode==System.Net.HttpStatusCode.OK)
  218. {
  219. Area area = JsonDocument.Parse(responseArea.Content).RootElement.ToObject<Area>();
  220. if (!string.IsNullOrWhiteSpace(area.shortCode))
  221. {
  222. route=area.shortCode;
  223. }
  224. scope="area";
  225. }
  226. if (!string.IsNullOrWhiteSpace(scope))
  227. {
  228. ResponseMessage responseSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync(websiteId, new PartitionKey("Base"));
  229. if (responseSchool.StatusCode==System.Net.HttpStatusCode.OK)
  230. {
  231. scope="school";
  232. route = websiteId;
  233. }
  234. }
  235. if (!string.IsNullOrWhiteSpace(scope))
  236. {
  237. if (!string.IsNullOrWhiteSpace(route))
  238. {
  239. ActivityWebsite website = new ActivityWebsite
  240. {
  241. id=websiteId,
  242. pk="ActivityWebsite",
  243. code="ActivityWebsite",
  244. route=route,
  245. scope=scope,
  246. allowPublic=0
  247. };
  248. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(website, new PartitionKey(website.code));
  249. websites.Add(website);
  250. }
  251. else
  252. {
  253. ActivityWebsite website = new ActivityWebsite
  254. {
  255. id=websiteId,
  256. pk="ActivityWebsite",
  257. code="ActivityWebsite",
  258. route=route,
  259. scope=scope,
  260. allowPublic=0
  261. };
  262. websites.Add(website);
  263. }
  264. }
  265. }
  266. }
  267. return Ok(new { code = 200, websites });
  268. }
  269. }
  270. }
  271. return Ok();
  272. }
  273. /// <summary>
  274. /// 添加活动参与对象,学校,教师
  275. /// </summary>
  276. /// <param name="request"></param>
  277. /// <returns></returns>
  278. [ProducesDefaultResponseType]
  279. [AuthToken(Roles = "admin,area")]
  280. [HttpPost("invite-target")]
  281. #if !DEBUG
  282. [Authorize(Roles = "IES")]
  283. #endif
  284. public async Task<IActionResult> InviteTarget(JsonElement request)
  285. {
  286. (string tmdid, _, _, string school) = HttpContext.GetAuthTokenInfo();
  287. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  288. switch (true)
  289. {
  290. case bool when $"{grant_type}".Equals("schools", StringComparison.OrdinalIgnoreCase):
  291. {
  292. if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
  293. if (!request.TryGetProperty("areaId", out JsonElement _areaId)) return BadRequest();
  294. string sql = string.Empty;
  295. int allowPublic = 0;
  296. if (_scope.GetString().Equals("public", StringComparison.OrdinalIgnoreCase))
  297. {
  298. if (_areaId.GetString().Equals("02944f32-f534-3397-ea56-e6f1fc6c3714"))
  299. {
  300. allowPublic=1;
  301. }
  302. else
  303. {
  304. ResponseMessage activityWebsiteResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_areaId.GetString(), new PartitionKey("ActivityWebsite"));
  305. if (activityWebsiteResponse.StatusCode==System.Net.HttpStatusCode.OK)
  306. {
  307. ActivityWebsite website = JsonDocument.Parse(activityWebsiteResponse.Content).RootElement.ToObject<ActivityWebsite>();
  308. allowPublic=website.allowPublic;
  309. }
  310. }
  311. }
  312. if (allowPublic==1)
  313. {
  314. sql = "select c.id,c.name ,c.picture,c.region,c.province,c.city,c.areaId from c where c.code='Base' ";
  315. }
  316. else
  317. {
  318. sql = $"select c.id,c.name ,c.picture,c.region,c.province,c.city,c.areaId from c where c.code='Base' and c.areaId='{_areaId}' ";
  319. }
  320. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).GetList<School>(sql, "Base");
  321. var sc = result.list.FindAll(z => !string.IsNullOrWhiteSpace(z.areaId));
  322. List<dynamic> schools = new List<dynamic>();
  323. if (sc.IsNotEmpty())
  324. {
  325. string areaSql = $"select value c from c where c.id in ({string.Join(",", sc.Select(z => $"'{z.areaId}'").ToHashSet())})";
  326. var areaResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<Area>(areaSql, "Base-Area");
  327. if (areaResult.list.IsNotEmpty())
  328. {
  329. foreach (var item in result.list)
  330. {
  331. if (!string.IsNullOrWhiteSpace(item.areaId))
  332. {
  333. var area = areaResult.list.Find(z => z.id.Equals(item.areaId));
  334. schools.Add(new { item.id, item.name, item.picture, item.region, item.province, item.city, item.areaId, areaName = area?.name });
  335. }
  336. else
  337. {
  338. schools.Add(new { item.id, item.name, item.picture, item.region, item.province, item.city, item.areaId, areaName = string.Empty });
  339. }
  340. }
  341. }
  342. }
  343. return Ok(new { code = 200, schools });
  344. }
  345. case bool when $"{grant_type}".Equals("teachers", StringComparison.OrdinalIgnoreCase):
  346. {
  347. if (!string.IsNullOrWhiteSpace(school))
  348. {
  349. School schoolbase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
  350. string sql = $"select c.id,c.name ,c.picture from c where c.code='Teacher-{school}' ";
  351. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).GetList<SchoolTeacher>(sql, $"Teacher-{school}");
  352. return Ok(new { code = 200, teachers = result.list.Select(z => new { z.id, z.name, z.picture, school, schooName = schoolbase.name }) });
  353. }
  354. else
  355. {
  356. return Ok(new { code = 1, msg = "没有学校信息" });
  357. }
  358. }
  359. }
  360. return Ok(new { code = 400 });
  361. }
  362. /// <summary>
  363. /// 管理
  364. /// </summary>
  365. /// <param name="request"></param>
  366. /// <returns></returns>
  367. [ProducesDefaultResponseType]
  368. [AuthToken(Roles = "teacher,admin,area,expert")]
  369. [HttpPost("manage")]
  370. #if !DEBUG
  371. [Authorize(Roles = "IES")]
  372. #endif
  373. public async Task<IActionResult> Manage(JsonElement request)
  374. {
  375. try
  376. {
  377. (string tmdid, _, _, string school) = HttpContext.GetAuthTokenInfo();
  378. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  379. var client = _azureCosmos.GetCosmosClient();
  380. switch (true)
  381. {
  382. //修改赛课活动信息
  383. case bool when $"{grant_type}".Equals("update-contest-base", StringComparison.OrdinalIgnoreCase):
  384. {
  385. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  386. if (!request.TryGetProperty("contestUpdate", out JsonElement _contestUpdate)) return BadRequest();
  387. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  388. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  389. {
  390. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  391. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  392. ContestUpdate contestUpdate = new ContestUpdate() {
  393. signStime= contest.sign?.stime,
  394. signEtime= contest.sign?.etime,
  395. uploadStime= contest.upload?.stime,
  396. uploadEtime= contest.upload?.etime,
  397. reviewStime= contest.review?.stime,
  398. reviewEtime= contest.review?.etime,
  399. scoreStime= contest.score?.stime,
  400. scoreEtime= contest.score?.etime,
  401. };
  402. if (_contestUpdate.TryGetProperty("signStime", out JsonElement signStime) && signStime.ValueKind.Equals(JsonValueKind.Number)) {
  403. contestUpdate.signStime=signStime.GetInt64();
  404. }
  405. if (_contestUpdate.TryGetProperty("signEtime", out JsonElement signEtime) && signEtime.ValueKind.Equals(JsonValueKind.Number))
  406. {
  407. contestUpdate.signEtime=signEtime.GetInt64();
  408. }
  409. if (_contestUpdate.TryGetProperty("uploadStime", out JsonElement uploadStime) && uploadStime.ValueKind.Equals(JsonValueKind.Number))
  410. {
  411. contestUpdate.uploadStime=uploadStime.GetInt64();
  412. }
  413. if (_contestUpdate.TryGetProperty("uploadEtime", out JsonElement uploadEtime) && uploadEtime.ValueKind.Equals(JsonValueKind.Number))
  414. {
  415. contestUpdate.uploadEtime=uploadEtime.GetInt64();
  416. }
  417. if (_contestUpdate.TryGetProperty("reviewStime", out JsonElement reviewStime) && reviewStime.ValueKind.Equals(JsonValueKind.Number))
  418. {
  419. contestUpdate.reviewStime=reviewStime.GetInt64();
  420. }
  421. if (_contestUpdate.TryGetProperty("reviewEtime", out JsonElement reviewEtime) && reviewEtime.ValueKind.Equals(JsonValueKind.Number))
  422. {
  423. contestUpdate.reviewEtime=reviewEtime.GetInt64();
  424. }
  425. if (_contestUpdate.TryGetProperty("scoreStime", out JsonElement scoreStime) && scoreStime.ValueKind.Equals(JsonValueKind.Number))
  426. {
  427. contestUpdate.scoreStime=scoreStime.GetInt64();
  428. }
  429. if (_contestUpdate.TryGetProperty("scoreEtime", out JsonElement scoreEtime) && scoreEtime.ValueKind.Equals(JsonValueKind.Number))
  430. {
  431. contestUpdate.scoreEtime=scoreEtime.GetInt64();
  432. }
  433. if (_contestUpdate.TryGetProperty("addModules", out JsonElement addModules) && addModules.ValueKind.Equals(JsonValueKind.Array))
  434. {
  435. contestUpdate.addModules = addModules.ToObject<List<string>>();
  436. }
  437. if (contest.modules.Contains("sign") && contest.sign!= null )
  438. {
  439. if (contestUpdate.signStime.HasValue &&contestUpdate.signEtime.HasValue) {
  440. if (contestUpdate.reviewStime.HasValue)
  441. {
  442. if (contestUpdate.signEtime.Value<contestUpdate.reviewStime.Value)
  443. {
  444. contest.sign.etime=contestUpdate.signEtime.Value;
  445. }
  446. else
  447. {
  448. return Ok(new { code = 1, msg = "报名结束时间不能晚于评审开始时间!" });
  449. }
  450. }
  451. else
  452. {
  453. contest.sign.etime=contestUpdate.signEtime.Value;
  454. }
  455. if (contestUpdate.signEtime.Value> contestUpdate.signStime.Value)
  456. {
  457. contest.sign.stime=contestUpdate.signStime.Value;
  458. }
  459. else {
  460. return Ok(new { code = 2, msg = "报名开始时间不能早于报名结束时间!" });
  461. }
  462. }
  463. if (_contestUpdate.TryGetProperty("limit", out JsonElement limit) && limit.ValueKind.Equals(JsonValueKind.Number))
  464. {
  465. contest.sign.limit=limit.GetInt32();
  466. }
  467. }
  468. if (contest.modules.Contains("upload") && contest.upload!= null)
  469. {
  470. if (contestUpdate.uploadStime.HasValue &&contestUpdate.uploadEtime.HasValue)
  471. {
  472. if (contestUpdate.reviewStime.HasValue)
  473. {
  474. if (contestUpdate.uploadEtime.Value<contestUpdate.reviewStime.Value)
  475. {
  476. contest.upload.etime=contestUpdate.uploadEtime.Value;
  477. }
  478. else
  479. {
  480. return Ok(new { code =3, msg = "报名结束时间不能晚于评审开始时间!" });
  481. }
  482. }
  483. else
  484. {
  485. contest.upload.etime=contestUpdate.uploadEtime.Value;
  486. }
  487. if (contestUpdate.uploadEtime.Value> contestUpdate.uploadStime.Value)
  488. {
  489. contest.upload.stime=contestUpdate.uploadStime.Value;
  490. }
  491. else
  492. {
  493. return Ok(new { code = 4, msg = "报名开始时间不能早于报名结束时间!" });
  494. }
  495. }
  496. if (_contestUpdate.TryGetProperty("updateDesc", out JsonElement desc) && desc.ValueKind.Equals(JsonValueKind.String))
  497. {
  498. contest.upload.desc=desc.GetString();
  499. }
  500. if (_contestUpdate.TryGetProperty("fileType", out JsonElement fileType) && fileType.ValueKind.Equals(JsonValueKind.Array))
  501. {
  502. if (contest.upload.fileType.IsNotEmpty())
  503. {
  504. contest.upload.fileType=fileType.ToObject<List<string>>();
  505. }
  506. }
  507. }
  508. if (contest.modules.Contains("review") && contest.review!= null)
  509. {
  510. if (contestUpdate.reviewStime.HasValue &&contestUpdate.reviewEtime.HasValue)
  511. {
  512. if (contestUpdate.scoreStime.HasValue)
  513. {
  514. if (contestUpdate.reviewEtime.Value<contestUpdate.scoreStime.Value)
  515. {
  516. contest.review.etime=contestUpdate.reviewEtime.Value;
  517. }
  518. else
  519. {
  520. return Ok(new { code = 5, msg = "评审结束时间不能晚于成绩公布开始时间!" });
  521. }
  522. }
  523. else
  524. {
  525. contest.review.etime=contestUpdate.reviewEtime.Value;
  526. }
  527. if (contestUpdate.reviewEtime.Value> contestUpdate.reviewStime.Value)
  528. {
  529. contest.review.stime=contestUpdate.reviewStime.Value;
  530. }
  531. else
  532. {
  533. return Ok(new { code = 6, msg = "评审开始时间不能早于评审结束时间!" });
  534. }
  535. }
  536. }
  537. if (contest.modules.Contains("score") && contest.score!= null)
  538. {
  539. if (contestUpdate.scoreStime.HasValue &&contestUpdate.scoreEtime.HasValue)
  540. {
  541. if (contestUpdate.reviewEtime.HasValue)
  542. {
  543. if (contestUpdate.reviewEtime.Value<contestUpdate.scoreStime.Value)
  544. {
  545. contest.score.stime=contestUpdate.scoreStime.Value;
  546. }
  547. else
  548. {
  549. return Ok(new { code = 7, msg = "成绩公布开始时间不能早于评审结束时间!" });
  550. }
  551. }
  552. else
  553. {
  554. contest.score.stime=contestUpdate.scoreStime.Value;
  555. }
  556. if (contestUpdate.scoreEtime.Value> contestUpdate.scoreStime.Value)
  557. {
  558. contest.score.etime=contestUpdate.scoreEtime.Value;
  559. }
  560. else
  561. {
  562. return Ok(new { code = 8, msg = "成绩公布结束时间不能晚于成绩公布开始时间!" });
  563. }
  564. }
  565. }
  566. else {
  567. //增加公示成绩模块
  568. if (contestUpdate.addModules.Contains("score") )
  569. {
  570. if (contestUpdate.scoreStime.HasValue &&contestUpdate.scoreEtime.HasValue)
  571. {
  572. if (!contest.modules.Contains("score"))
  573. {
  574. contest.modules.Add("score");
  575. }
  576. if (contest.score==null)
  577. {
  578. contest.score= new ContestScore
  579. {
  580. scoreStatus=0,
  581. showType=0,
  582. showDetail=0,
  583. levelType=0,
  584. top=-1
  585. };
  586. }
  587. if (contestUpdate.reviewEtime.HasValue)
  588. {
  589. if (contestUpdate.reviewEtime.Value<contestUpdate.scoreStime.Value)
  590. {
  591. contest.score.stime=contestUpdate.scoreStime.Value;
  592. }
  593. else
  594. {
  595. return Ok(new { code = 7, msg = "成绩公布开始时间不能早于评审结束时间!" });
  596. }
  597. }
  598. else
  599. {
  600. contest.score.stime=contestUpdate.scoreStime.Value;
  601. }
  602. if (contestUpdate.scoreEtime.Value> contestUpdate.scoreStime.Value)
  603. {
  604. contest.score.etime=contestUpdate.scoreEtime.Value;
  605. }
  606. else
  607. {
  608. return Ok(new { code = 8, msg = "成绩公布结束时间不能晚于成绩公布开始时间!" });
  609. }
  610. }
  611. }
  612. }
  613. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(contest, new PartitionKey("Contest"));
  614. return Ok(new { code = 200, contest });
  615. }
  616. else
  617. {
  618. return Ok(new { code = 9, msg = "赛课模块信息未完善!" });
  619. }
  620. }
  621. //修改活动基本信息
  622. case bool when $"{grant_type}".Equals("update-activity-base", StringComparison.OrdinalIgnoreCase):
  623. {
  624. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  625. if (!request.TryGetProperty("activityUpdate", out JsonElement _activityUpdate)) return BadRequest();
  626. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  627. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  628. {
  629. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  630. _activityUpdate.CopyToSameProperty<ActivityUpdate, Activity>(activity,
  631. filter: new List<string>() { "name", "subject", "description", "address", "stime", "etime", "poster", "attachment", "zb", "cb", "mzsm" });
  632. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(activity, new PartitionKey("Activity"));
  633. return Ok(new { activity, code = 200 });
  634. }
  635. else
  636. {
  637. return Ok(new { code = 1, msg = "活动不存在!" });
  638. }
  639. }
  640. //创建活动
  641. case bool when $"{grant_type}".Equals("create", StringComparison.OrdinalIgnoreCase):
  642. {
  643. if (!request.TryGetProperty("Activity", out JsonElement _activity)) return Ok(new { code = 1, msg = "活动信息参数错误" });
  644. Activity activity = _activity.ToObject<Activity>();
  645. activity.id=!string.IsNullOrWhiteSpace(activity.id) ? activity.id : Guid.NewGuid().ToString();
  646. activity.code="Activity";
  647. activity.pk="Activity";
  648. //如果是区级活动,enroll报名制,则学校的确认状态默认为1 。
  649. //if (activity.scope.Equals("area", StringComparison.OrdinalIgnoreCase) && activity.joinMode.Equals("enroll", StringComparison.OrdinalIgnoreCase))
  650. //{
  651. // activity.schools.ForEach(z => z.status=1);
  652. //}
  653. ActivityWebsite website = null;
  654. {
  655. string websiteId = activity.owner;
  656. string route = string.Empty;
  657. if (activity.owner.Equals("02944f32-f534-3397-ea56-e6f1fc6c3714", StringComparison.OrdinalIgnoreCase) && activity.scope.Equals("public", StringComparison.OrdinalIgnoreCase))
  658. {
  659. websiteId="teammodel";
  660. route="teammodel";
  661. }
  662. ResponseMessage activityWebsiteResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(websiteId, new PartitionKey("ActivityWebsite"));
  663. if (activityWebsiteResponse.Status!=200)
  664. {
  665. if (activity.scope.Equals("area", StringComparison.OrdinalIgnoreCase))
  666. {
  667. Area area = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemAsync<Area>(activity.owner, new PartitionKey("Base-Area"));
  668. if (!string.IsNullOrWhiteSpace(area.shortCode))
  669. {
  670. route=area.shortCode;
  671. }
  672. }
  673. if (activity.scope.Equals("school", StringComparison.OrdinalIgnoreCase))
  674. {
  675. route=activity.owner;
  676. }
  677. if (!string.IsNullOrWhiteSpace(route))
  678. {
  679. website = new ActivityWebsite
  680. {
  681. id=websiteId,
  682. pk="ActivityWebsite",
  683. code="ActivityWebsite",
  684. route=route,
  685. scope=activity.scope,
  686. };
  687. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(website, new PartitionKey(website.code));
  688. }
  689. }
  690. else
  691. {
  692. website =JsonDocument.Parse(activityWebsiteResponse.Content).RootElement.ToObject<ActivityWebsite>();
  693. }
  694. }
  695. //醍摩豆智慧学区
  696. if (activity.scope.Equals("public", StringComparison.OrdinalIgnoreCase))
  697. {
  698. if (website.allowPublic==0)
  699. {
  700. return Ok(new { code = 2, msg = "暂无创建公开活动权限!" });
  701. }
  702. }
  703. Contest contest = null;
  704. ValidResult validResult = activity.Valid();
  705. if (validResult.isVaild)
  706. {
  707. activity.creatorId=tmdid;
  708. activity.createTime= DateTimeOffset.Now.ToUnixTimeMilliseconds();
  709. activity.year=DateTimeOffset.Now.Year;
  710. foreach (var module in activity.modules)
  711. {
  712. switch (true)
  713. {
  714. //赛课
  715. case bool when module.Equals("Contest"):
  716. {
  717. if (!request.TryGetProperty("Contest", out JsonElement _contest))
  718. {
  719. return Ok(new { code = 3, msg = "赛课信息参数错误" });
  720. }
  721. contest = _contest.ToObject<Contest>();
  722. if (contest!=null)
  723. {
  724. contest.id=activity.id;
  725. contest.code="Contest";
  726. contest.pk="Contest";
  727. ValidResult validResultContest = contest.Valid();
  728. if (validResultContest.isVaild)
  729. {
  730. if (contest.modules.Contains("review"))
  731. {
  732. if (!request.TryGetProperty("reviewConfig", out JsonElement _reviewConfig))
  733. {
  734. return Ok(new { code = 4, msg = "评审未配置" });
  735. }
  736. if (contest.review== null)
  737. {
  738. return Ok(new { code = 4, msg = "评审未配置" });
  739. }
  740. ReviewRuleTree ruleTree = _reviewConfig.ToObject<ReviewRuleTree>();
  741. var reviewRuleResult = await ActivityService.UpsertReviewRule(ruleTree, activity, contest, _azureCosmos);
  742. if (reviewRuleResult.invalidCode!=200)
  743. {
  744. return Ok(new { code = reviewRuleResult.invalidCode, msg = reviewRuleResult.msg });
  745. }
  746. contest.review.ruleId =reviewRuleResult.reviewRule.id;
  747. contest.review.ruleName = reviewRuleResult.reviewRule.name;
  748. }
  749. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(contest, new PartitionKey(contest.code));
  750. break;
  751. }
  752. else
  753. {
  754. return Ok(validResult);
  755. }
  756. }
  757. else
  758. {
  759. return Ok(validResult);
  760. }
  761. }
  762. //培训
  763. case bool when module.Equals("Training"):
  764. {
  765. break;
  766. }
  767. //教研
  768. case bool when module.Equals("Research"):
  769. {
  770. break;
  771. }
  772. }
  773. }
  774. //保存活动基础信息
  775. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(activity, new PartitionKey(activity.code));
  776. return Ok(new { activity, contest, code = 200 });
  777. }
  778. else
  779. {
  780. return Ok(validResult);
  781. }
  782. }
  783. //删除活动
  784. case bool when $"{grant_type}".Equals("delete", StringComparison.OrdinalIgnoreCase):
  785. {
  786. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  787. if (!request.TryGetProperty("owner", out JsonElement _owner)) return BadRequest();
  788. if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();
  789. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  790. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  791. {
  792. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  793. if (_scope.GetString().Equals("school") && _owner.GetString().Equals(school))
  794. {
  795. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Activity"));
  796. await ActivityService.DeleteActivityRelated(_azureCosmos, activity);
  797. return Ok(new { code = 201, activity }); //删除成功
  798. }
  799. else
  800. {
  801. if ((_scope.GetString().Equals("area") || _scope.GetString().Equals("public")) && !_owner.GetString().Equals(school))
  802. {
  803. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).DeleteItemStreamAsync(activity.id, new PartitionKey("Activity"));
  804. await ActivityService.DeleteActivityRelated(_azureCosmos, activity);
  805. return Ok(new { code = 201, activity });//删除成功
  806. }
  807. }
  808. return Ok(new { code = 200, activity });//未删除掉
  809. }
  810. else
  811. {
  812. return Ok(new { code = 1, msg = "活动不存在" });
  813. }
  814. }
  815. //区级活动列表
  816. case bool when $"{grant_type}".Equals("list-area", StringComparison.OrdinalIgnoreCase):
  817. {
  818. if (!request.TryGetProperty("areaId", out JsonElement _areaId)) return BadRequest();
  819. var activities = await ActivityService.AreaActivityList(_azureCosmos, _azureStorage, request, _areaId.GetString());
  820. return Ok(new { activities = activities });
  821. }
  822. //校级活动列表
  823. case bool when $"{grant_type}".Equals("list-school", StringComparison.OrdinalIgnoreCase):
  824. {
  825. if (!string.IsNullOrWhiteSpace(school))
  826. {
  827. var activities = await ActivityService.SchoolActivityList(_azureCosmos, _azureStorage, request, school);
  828. return Ok(new { code = 200, activities = activities.OrderByDescending(z => z.stime) });
  829. }
  830. else
  831. {
  832. return Ok(new { code = 1, msg = "没有学校信息" });
  833. }
  834. }
  835. //教师活动列表
  836. case bool when $"{grant_type}".Equals("list-teacher", StringComparison.OrdinalIgnoreCase):
  837. {
  838. List<TeacherActivityDto> activities = await ActivityService.TeacherActivityList(_azureCosmos, _azureStorage, request, tmdid);
  839. return Ok(new { activities = activities.OrderByDescending(z => z.stime) });
  840. }
  841. case bool when $"{grant_type}".Equals("list-year", StringComparison.OrdinalIgnoreCase):
  842. {
  843. if (!request.TryGetProperty("type", out JsonElement _type)) return BadRequest();
  844. if (!request.TryGetProperty("ownerId", out JsonElement ownerId)) return BadRequest();
  845. if ($"{_type}".Equals("teacher"))
  846. {
  847. var data = await ActivityService.TeacherActivityList(_azureCosmos, _azureStorage, request, ownerId.GetString(),1);
  848. var countYear = data.GroupBy(z => z.year).Select(z => new { year = z.Key, count = z.ToList().Count() });
  849. return Ok(new { code = 200, countYear });
  850. }
  851. else if ($"{_type}".Equals("school"))
  852. {
  853. var data = await ActivityService.SchoolActivityList(_azureCosmos, _azureStorage, request, ownerId.GetString(),1);
  854. var countYear = data.GroupBy(z => z.year).Select(z => new { year = z.Key, count = z.ToList().Count() });
  855. return Ok(new { code = 200, countYear });
  856. }
  857. else if ($"{_type}".Equals("area"))
  858. {
  859. var data = await ActivityService.AreaActivityList(_azureCosmos, _azureStorage, request, ownerId.GetString(), 1);
  860. var countYear = data.GroupBy(z => z.year).Select(z => new { year = z.Key, count = z.ToList().Count() });
  861. return Ok(new { code = 200, countYear });
  862. }
  863. else
  864. {
  865. return BadRequest("类型错误!");
  866. }
  867. }
  868. case bool when $"{grant_type}".Equals("read-activity", StringComparison.OrdinalIgnoreCase):
  869. {
  870. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  871. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  872. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  873. {
  874. ActivityDto activity = JsonDocument.Parse(response.Content).RootElement.ToObject<ActivityDto>();
  875. Contest contest = null;
  876. ReviewRuleTree reviewRule = null;
  877. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  878. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  879. {
  880. contest= JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  881. if (contest.modules.Contains("review"))
  882. {
  883. ResponseMessage reviewRuleResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("ReviewRule-disposable"));
  884. if (reviewRuleResponse.StatusCode==System.Net.HttpStatusCode.OK)
  885. {
  886. ReviewRule reviewRuleDB = JsonDocument.Parse(reviewRuleResponse.Content).RootElement.ToObject<ReviewRule>();
  887. var tree = ActivityService.ListToTree(reviewRuleDB.configs);
  888. reviewRule=new ReviewRuleTree
  889. {
  890. id=reviewRuleDB.id,
  891. name= reviewRuleDB.name,
  892. owner= reviewRuleDB.owner,
  893. sourceName= reviewRuleDB.sourceName,
  894. trees=tree,
  895. desc=reviewRuleDB.desc,
  896. scoreDetail=reviewRuleDB.scoreDetail,
  897. scoreRule=reviewRuleDB.scoreRule,
  898. distribute=reviewRuleDB.distribute,
  899. taskCount=reviewRuleDB.taskCount,
  900. };
  901. }
  902. }
  903. }
  904. Training training = null;
  905. TEAMModelOS.SDK.Models.Research research = null;
  906. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(activity.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  907. activity.sas=blob_sas;
  908. activity.url=blob_uri;
  909. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  910. activity.publish=now>activity.etime ? 2 : activity.publish;
  911. return Ok(new { code = 200, activity, contest, reviewRule, training, research });
  912. }
  913. else
  914. {
  915. return Ok(new { code = 2, msg = "活动不存在" });
  916. }
  917. }
  918. //读取优课评选模块及评审规则
  919. case bool when $"{grant_type}".Equals("read-Contest", StringComparison.OrdinalIgnoreCase):
  920. {
  921. Contest contest = null;
  922. ReviewRuleTree reviewRule = null;
  923. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  924. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  925. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  926. {
  927. contest= JsonDocument.Parse(response.Content).RootElement.ToObject<Contest>();
  928. if (contest.modules.Contains("review"))
  929. {
  930. ResponseMessage reviewRuleResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("ReviewRule-disposable"));
  931. if (reviewRuleResponse.StatusCode==System.Net.HttpStatusCode.OK)
  932. {
  933. ReviewRule reviewRuleDB = JsonDocument.Parse(reviewRuleResponse.Content).RootElement.ToObject<ReviewRule>();
  934. var tree = ActivityService.ListToTree(reviewRuleDB.configs);
  935. reviewRule= new ReviewRuleTree
  936. {
  937. id=reviewRuleDB.id,
  938. name= reviewRuleDB.name,
  939. owner= reviewRuleDB.owner,
  940. sourceName= reviewRuleDB.sourceName,
  941. trees=tree,
  942. desc=reviewRuleDB.desc,
  943. distribute=reviewRuleDB.distribute,
  944. taskCount=reviewRuleDB.taskCount,
  945. scoreDetail=reviewRuleDB.scoreDetail,
  946. scoreRule=reviewRuleDB.scoreRule,
  947. };
  948. }
  949. }
  950. }
  951. return Ok(new { code = 200, contest, reviewRule });
  952. }
  953. //获取评审的模板列表
  954. case bool when $"{grant_type}".Equals("rule-list", StringComparison.OrdinalIgnoreCase):
  955. {
  956. if (!request.TryGetProperty("owner", out JsonElement _owner)) return BadRequest();
  957. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ReviewRule>($"select value c from c where c.owner='{_owner}'", "ReviewRule-template");
  958. List<ReviewRuleTree> reviewRules = new List<ReviewRuleTree>();
  959. foreach (var item in result.list)
  960. {
  961. var tree = ActivityService.ListToTree(item.configs);
  962. ReviewRuleTree reviewRule = new ReviewRuleTree
  963. {
  964. id=item.id,
  965. desc=item.desc,
  966. name= item.name,
  967. owner= item.owner,
  968. sourceName= item.sourceName,
  969. trees=tree,
  970. upsertAsTemplate=1,
  971. taskCount=item.taskCount,
  972. scoreRule=item.scoreRule,
  973. distribute=item.distribute,
  974. scoreDetail=item.scoreDetail
  975. };
  976. reviewRules.Add(reviewRule);
  977. }
  978. return Ok(new { reviewRules });
  979. }
  980. //编辑当前活动评审规则
  981. case bool when $"{grant_type}".Equals("rule-update", StringComparison.OrdinalIgnoreCase):
  982. {
  983. if (!request.TryGetProperty("reviewConfig", out JsonElement _reviewConfig))
  984. {
  985. return Ok(new { code = 4, msg = "评审未配置" });
  986. }
  987. ReviewRuleTree ruleTree = _reviewConfig.ToObject<ReviewRuleTree>();
  988. if (!string.IsNullOrWhiteSpace(ruleTree.id))
  989. {
  990. Activity activity = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemAsync<Activity>(ruleTree.id, new PartitionKey("Activity"));
  991. Contest contest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemAsync<Contest>(ruleTree.id, new PartitionKey("Contest"));
  992. var reviewRuleResult = await ActivityService.UpsertReviewRule(ruleTree, activity, contest, _azureCosmos);
  993. if (reviewRuleResult.invalidCode!=200)
  994. {
  995. return Ok(new { code = reviewRuleResult.invalidCode, msg = reviewRuleResult.msg });
  996. }
  997. var tree = ActivityService.ListToTree(reviewRuleResult.reviewRule.configs);
  998. var reviewRule = new ReviewRuleTree
  999. {
  1000. id=reviewRuleResult.reviewRule.id,
  1001. name= reviewRuleResult.reviewRule.name,
  1002. owner= reviewRuleResult.reviewRule.owner,
  1003. sourceName= reviewRuleResult.reviewRule.sourceName,
  1004. trees=tree,
  1005. desc=reviewRuleResult.reviewRule.desc,
  1006. distribute=reviewRuleResult.reviewRule.distribute,
  1007. scoreDetail=reviewRuleResult.reviewRule.scoreDetail,
  1008. scoreRule=reviewRuleResult.reviewRule.scoreRule,
  1009. taskCount=reviewRuleResult.reviewRule.taskCount,
  1010. };
  1011. return Ok(new { reviewRule });
  1012. }
  1013. else
  1014. {
  1015. return Ok(new { code = 5, msg = "规则不存在" });
  1016. }
  1017. }
  1018. //删除评审规则模板
  1019. case bool when $"{grant_type}".Equals("rule-delete", StringComparison.OrdinalIgnoreCase):
  1020. {
  1021. if (!request.TryGetProperty("ruleId", out JsonElement _ruleId))
  1022. {
  1023. return BadRequest();
  1024. }
  1025. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).DeleteItemStreamAsync(_ruleId.GetString(), new PartitionKey("ReviewRule-template"));
  1026. return Ok(new { code = 200 });
  1027. }
  1028. case bool when $"{grant_type}".Equals("invite-remove-school", StringComparison.OrdinalIgnoreCase):
  1029. {
  1030. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1031. if (!request.TryGetProperty("invitedSchools", out JsonElement _invitedSchools)) return BadRequest();
  1032. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  1033. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1034. {
  1035. List<ActivityInvitedSchool> invitedSchools = _invitedSchools.ToObject<List<ActivityInvitedSchool>>();
  1036. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  1037. foreach (var invitedSchool in invitedSchools)
  1038. {
  1039. if (!activity.invitedSchools.Exists(z => z.id.Equals(invitedSchool.id)))
  1040. {
  1041. activity.invitedSchools.Add(invitedSchool);
  1042. }
  1043. }
  1044. return Ok(new { code = 200, activity });
  1045. }
  1046. else
  1047. {
  1048. return Ok(new { code = 1, msg = "活动不存在" });
  1049. }
  1050. }
  1051. //学校确认参加本次活动
  1052. case bool when $"{grant_type}".Equals("school-confirm", StringComparison.OrdinalIgnoreCase):
  1053. {
  1054. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1055. if (!request.TryGetProperty("confirm", out JsonElement _confirm)) return BadRequest();
  1056. if (!string.IsNullOrWhiteSpace(school))
  1057. {
  1058. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  1059. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1060. {
  1061. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  1062. if (_confirm.GetInt32()==1 ||_confirm.GetInt32()==0)
  1063. {
  1064. var invitedSchool = activity.invitedSchools.Find(z => z.id.Equals(school));
  1065. if (invitedSchool!=null ||
  1066. //如果是区级,且没选择学校,也需要确认
  1067. (activity.scope.Equals("area") && !activity.invitedSchools.IsNotEmpty()))
  1068. {
  1069. var confirmedSchool = activity.confirmedSchools.Find(z => z.id.Equals(school));
  1070. if (confirmedSchool!=null)
  1071. {
  1072. confirmedSchool.status=_confirm.GetInt32();
  1073. }
  1074. else
  1075. {
  1076. School schoolbase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(school, new PartitionKey("Base"));
  1077. if (activity.scope.Equals("area"))
  1078. {
  1079. if (string.IsNullOrWhiteSpace(schoolbase.areaId) || !schoolbase.areaId.Equals(activity.owner))
  1080. {
  1081. return Ok(new { code = 5, msg = "学校的区级与活动所属区级不一致!" });
  1082. }
  1083. }
  1084. activity.confirmedSchools= new List<ActivityConfirmedSchool>() { new ActivityConfirmedSchool { id=school, status=_confirm.GetInt32(), name=schoolbase.name, picture= schoolbase.picture } };
  1085. }
  1086. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(activity, new PartitionKey("Activity"));
  1087. return Ok(new { code = 200, activity });
  1088. }
  1089. else
  1090. {
  1091. return Ok(new { code = 1, msg = "该学校未被邀请!" });
  1092. }
  1093. }
  1094. else
  1095. {
  1096. return Ok(new { code = 2, msg = "活动发布状态错误!" });
  1097. }
  1098. }
  1099. else
  1100. {
  1101. return Ok(new { code = 4, msg = "活动不存在!" });
  1102. }
  1103. }
  1104. else
  1105. {
  1106. return Ok(new { code = 3, msg = "没有学校信息!" });
  1107. }
  1108. }
  1109. //发布或取消发布活动
  1110. case bool when $"{grant_type}".Equals("update-publish", StringComparison.OrdinalIgnoreCase):
  1111. {
  1112. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1113. if (!request.TryGetProperty("publish", out JsonElement _publish)) return BadRequest();
  1114. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  1115. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1116. {
  1117. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  1118. if (_publish.GetInt32()==1 ||_publish.GetInt32()==0)
  1119. {
  1120. activity.publish=_publish.GetInt32();
  1121. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(activity, new PartitionKey("Activity"));
  1122. return Ok(new { code = 200, activity });
  1123. }
  1124. else
  1125. {
  1126. return Ok(new { code = 2, msg = "活动发布状态错误!" });
  1127. }
  1128. }
  1129. else
  1130. {
  1131. return Ok(new { code = 1, msg = "活动不存在" });
  1132. }
  1133. }
  1134. //邀请教师参加本次活动或移除教师参加活动
  1135. case bool when $"{grant_type}".Equals("invite-remove-teachers", StringComparison.OrdinalIgnoreCase):
  1136. {
  1137. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1138. request.TryGetProperty("invite", out JsonElement _invite);
  1139. request.TryGetProperty("remove", out JsonElement _remove);
  1140. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  1141. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1142. {
  1143. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  1144. if (activity.joinMode.Equals("invite"))
  1145. {
  1146. var confirmedSchool = activity.confirmedSchools.Find(z => z.id.Equals(school) && z.status==1);
  1147. if (confirmedSchool!= null || activity.scope.Equals("school", StringComparison.OrdinalIgnoreCase))
  1148. {
  1149. List<InviteTeachers> inviteTeachersInvalid = new List<InviteTeachers>();
  1150. List<InviteTeachers> removeTeachersInvalid = new List<InviteTeachers>();
  1151. ActivityTeacher activityTeacher = null;
  1152. ResponseMessage activityTeacherResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(school, new PartitionKey($"ActivityTeacher-{activity.id}"));
  1153. if (activityTeacherResponse.StatusCode==System.Net.HttpStatusCode.OK)
  1154. {
  1155. activityTeacher = JsonDocument.Parse(activityTeacherResponse.Content).RootElement.ToObject<ActivityTeacher>();
  1156. }
  1157. if (activityTeacher==null)
  1158. {
  1159. activityTeacher= new ActivityTeacher() { activityId=_activityId.GetString(), schoolName= activity.scope.Equals("school") && confirmedSchool== null ? activity.ownerName : confirmedSchool.name, id=school, code=$"ActivityTeacher-{_activityId}", pk="ActivityTeacher" };
  1160. }
  1161. if (_invite.ValueKind.Equals(JsonValueKind.Array))
  1162. {
  1163. List<InviteTeachers> inviteTeachers = _invite.ToObject<List<InviteTeachers>>();
  1164. foreach (var invite in inviteTeachers)
  1165. {
  1166. if (string.IsNullOrWhiteSpace(invite.school) || !invite.school.Equals(school))
  1167. {
  1168. inviteTeachersInvalid.Add(invite);
  1169. continue;
  1170. }
  1171. var inviteTeacher = activityTeacher.inviteTeachers.Find(z => z.id.Equals(invite.id));
  1172. if (inviteTeacher==null)
  1173. {
  1174. activityTeacher.inviteTeachers.Add(invite);
  1175. }
  1176. else
  1177. {
  1178. inviteTeacher=invite;
  1179. }
  1180. }
  1181. }
  1182. if (_remove.ValueKind.Equals(JsonValueKind.Array))
  1183. {
  1184. List<InviteTeachers> removeTeachers = _remove.ToObject<List<InviteTeachers>>();
  1185. foreach (var remove in removeTeachers)
  1186. {
  1187. if (string.IsNullOrWhiteSpace(remove.school) || !remove.school.Equals(school))
  1188. {
  1189. removeTeachersInvalid.Add(remove);
  1190. continue;
  1191. }
  1192. activityTeacher.inviteTeachers.RemoveAll(z => remove.id.Equals(z.id));
  1193. }
  1194. }
  1195. var teachers = activityTeacher.inviteTeachers.FindAll(z => z.school.Equals(school));
  1196. activityTeacher.activityId=$"{_activityId}";
  1197. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityTeacher, new PartitionKey($"ActivityTeacher-{_activityId}"));
  1198. return Ok(new { inviteTeachers = teachers, inviteTeachersInvalid, removeTeachersInvalid });
  1199. }
  1200. else
  1201. {
  1202. return Ok(new { code = 2, msg = "学校未确认,暂不能邀请教师" });
  1203. }
  1204. }
  1205. else
  1206. {
  1207. return Ok(new { code = 3, msg = "活动不是邀请制。" });
  1208. }
  1209. }
  1210. else
  1211. {
  1212. return Ok(new { code = 1, msg = "活动不存在" });
  1213. }
  1214. }
  1215. //获取单个教师的报名数据
  1216. case bool when $"{grant_type}".Equals("get-teacher-enroll", StringComparison.OrdinalIgnoreCase):
  1217. {
  1218. if (!request.TryGetProperty("teacherId", out JsonElement _teacherId)) return BadRequest();
  1219. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1220. ActivityEnroll enroll = null;
  1221. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync($"{_teacherId}", new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  1222. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  1223. {
  1224. enroll= JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  1225. return Ok(new { code = 200, enroll });
  1226. }
  1227. return Ok(new { code = 1, msg = "暂无报名数据!", });
  1228. }
  1229. //获取邀请的教师列表
  1230. case bool when $"{grant_type}".Equals("invited-teachers", StringComparison.OrdinalIgnoreCase)
  1231. || $"{grant_type}".Equals("invited-and-enroll-teachers", StringComparison.OrdinalIgnoreCase):
  1232. {
  1233. string owner = string.Empty;
  1234. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1235. request.TryGetProperty("activityOwner", out JsonElement _activityOwner);
  1236. if (string.IsNullOrWhiteSpace($"{_activityOwner}"))
  1237. {
  1238. if (!string.IsNullOrWhiteSpace(school))
  1239. {
  1240. owner=school;
  1241. }
  1242. }
  1243. else
  1244. {
  1245. owner=$"{_activityOwner}";
  1246. }
  1247. Activity activity = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemAsync<Activity>(_activityId.GetString(), new PartitionKey("Activity"));
  1248. int isAll = 0;
  1249. if (!string.IsNullOrWhiteSpace(owner))
  1250. {
  1251. if (activity.owner.Equals(owner))
  1252. {
  1253. isAll = 1;
  1254. }
  1255. }
  1256. List<InviteTeachers> inviteTeachers = new List<InviteTeachers>();
  1257. string activityTeacherSQL = $"select value c from c where c.pk='ActivityTeacher'";
  1258. if (isAll!=1 && !string.IsNullOrWhiteSpace(school))
  1259. {
  1260. activityTeacherSQL=$"{activityTeacherSQL} and c.id='{school}'";
  1261. }
  1262. var activityTeacherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityTeacher>(activityTeacherSQL, $"ActivityTeacher-{_activityId}");
  1263. foreach (var activityTeacher in activityTeacherResult.list)
  1264. {
  1265. inviteTeachers.AddRange(activityTeacher.inviteTeachers);
  1266. }
  1267. if ($"{grant_type}".Equals("invited-and-enroll-teachers", StringComparison.OrdinalIgnoreCase))
  1268. {
  1269. string enrollSQL = $"select value c from c where c.activityId='{_activityId.GetString()}' ";
  1270. //不是自己的,且学校不为空,则查询指定学校的,否则获取所有报名的数据
  1271. if (isAll!=1 && !string.IsNullOrWhiteSpace(school))
  1272. {
  1273. enrollSQL=$"{enrollSQL} and c.schoolId='{school}'";
  1274. }
  1275. var enrollResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{_activityId}");
  1276. List<InviteEnrollTeacherDto> inviteEnrollTeachers = new List<InviteEnrollTeacherDto>();
  1277. Contest contest = null;
  1278. ResponseMessage contestResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  1279. if (contestResponse.StatusCode==System.Net.HttpStatusCode.OK)
  1280. {
  1281. contest = JsonDocument.Parse(contestResponse.Content).RootElement.ToObject<Contest>();
  1282. }
  1283. long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
  1284. int uploadStatus = -1;
  1285. int contestStatus = -1;
  1286. if (contest?.sign!=null)
  1287. {
  1288. if (contest?.sign.stime>now)
  1289. {
  1290. contestStatus=-2;
  1291. }
  1292. else
  1293. {
  1294. contestStatus = 0;
  1295. }
  1296. }
  1297. if (contest?.upload!=null)
  1298. {
  1299. if (contest?.upload.stime>now)
  1300. {
  1301. uploadStatus=-2;
  1302. }
  1303. else
  1304. {
  1305. uploadStatus=0;
  1306. }
  1307. }
  1308. foreach (var inviteTeacher in inviteTeachers)
  1309. {
  1310. inviteEnrollTeachers.Add(new InviteEnrollTeacherDto
  1311. {
  1312. id= inviteTeacher.id,
  1313. name= inviteTeacher.name,
  1314. picture= inviteTeacher.picture,
  1315. school= inviteTeacher.school,
  1316. schoolName=inviteTeacher.schoolName,
  1317. inviteStatus=inviteTeacher.status,
  1318. signContestStatus=contestStatus,
  1319. uploadContestStatus=uploadStatus
  1320. });
  1321. }
  1322. foreach (var activityEnroll in enrollResult.list)
  1323. {
  1324. var inviteEnrollTeacher = inviteEnrollTeachers.Find(z => z.id.Equals(activityEnroll.id) && !string.IsNullOrWhiteSpace(z.school) && !string.IsNullOrEmpty(activityEnroll.schoolId) && z.school.Equals(activityEnroll.schoolId));
  1325. if (inviteEnrollTeacher==null)
  1326. {
  1327. inviteEnrollTeacher= new InviteEnrollTeacherDto
  1328. {
  1329. id= activityEnroll.id,
  1330. name= activityEnroll.tmdName,
  1331. picture= activityEnroll.tmdPicture,
  1332. school= activityEnroll.schoolId,
  1333. schoolName=activityEnroll.schoolName,
  1334. signContestStatus=contestStatus,
  1335. uploadContestStatus=uploadStatus
  1336. };
  1337. inviteEnrollTeachers.Add(inviteEnrollTeacher);
  1338. }
  1339. if (activityEnroll.contest!= null)
  1340. {
  1341. inviteEnrollTeacher.signContestStatus = 1;
  1342. inviteEnrollTeacher.signContestTime = activityEnroll.contest.enrollTime;
  1343. inviteEnrollTeacher.signContestType = activityEnroll.contest.type;
  1344. inviteEnrollTeacher.teamCipherContest=activityEnroll.contest.cipher;
  1345. inviteEnrollTeacher.teamLeaderContest=activityEnroll.contest.leader;
  1346. inviteEnrollTeacher.teamNameContest=activityEnroll.contest.teamName;
  1347. }
  1348. if (activityEnroll.upload!=null)
  1349. {
  1350. inviteEnrollTeacher.uploadContestId=activityEnroll.upload.uploadId;
  1351. //inviteEnrollTeacher.uploadContestType=activityEnroll.upload.type;
  1352. inviteEnrollTeacher.uploadContestTypes= activityEnroll.upload.uploadType;
  1353. inviteEnrollTeacher.uploadContestStatus=1;
  1354. inviteEnrollTeacher.uploadContestTime= activityEnroll.upload.uploadTime;
  1355. inviteEnrollTeacher.uploadContestScore=activityEnroll.upload.score;
  1356. }
  1357. }
  1358. //进入评审环节
  1359. if (contest.review!= null && now > contest.review.stime)
  1360. {
  1361. HashSet<string> uploadContestIds = inviteEnrollTeachers.Where(x => !string.IsNullOrWhiteSpace(x.uploadContestId)).Select(z => z.uploadContestId).ToHashSet();
  1362. if (uploadContestIds!= null && uploadContestIds.Count>0)
  1363. {
  1364. // List<ActivityExpertTask> expertTasks = new List<ActivityExpertTask>();
  1365. string taskSQL = $"select distinct value c from c join s in c.contestTasks where c.pk='ActivityExpertTask' and s.uploadId in ({string.Join(",", uploadContestIds.Select(z => $"'{z}'"))})";
  1366. List<ExpertContestTaskDto> worksDB = new List<ExpertContestTaskDto>();
  1367. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{_activityId}");
  1368. if (result.list.IsNotEmpty())
  1369. {
  1370. List<ActivityExpertTask> change = new List<ActivityExpertTask>();
  1371. var experts = await ActivityService.ListExperts(_azureCosmos, _coreAPIHttpService, _dingDing, _option, $"{_activityId}");
  1372. foreach (var item in result.list)
  1373. {
  1374. var expert= experts.Find(x => !string.IsNullOrWhiteSpace(x.id) && x.id.Equals(item.id));
  1375. if (expert!=null)
  1376. {
  1377. foreach (var task in item.contestTasks)
  1378. {
  1379. var teachers = inviteEnrollTeachers.FindAll(z => !string.IsNullOrWhiteSpace(z.uploadContestId) && z.uploadContestId.Equals(task.uploadId));
  1380. if (teachers!=null)
  1381. {
  1382. teachers.ForEach(z => {
  1383. z.reviewContestAssignCount+=1;
  1384. z.reviewContestExperts.Add(new ExpertUploadScore
  1385. {
  1386. score=task.score,
  1387. detailScore=task.detailScore,
  1388. id= item.id,
  1389. comment=task.comment,
  1390. name=item.name,
  1391. nickname=item.tmdname,
  1392. picture=item.picture
  1393. });
  1394. });
  1395. }
  1396. }
  1397. }
  1398. else
  1399. {
  1400. change.Add(item);
  1401. }
  1402. }
  1403. if (change.IsNotEmpty()) {
  1404. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemsAsync<ActivityExpertTask>(change.Select(x=>x.id).ToList(),$"ActivityExpertTask-{_activityId}");
  1405. }
  1406. }
  1407. }
  1408. }
  1409. return Ok(new { code = 200, inviteEnrollTeachers });
  1410. }
  1411. else
  1412. {
  1413. return Ok(new { code = 200, inviteTeachers });
  1414. }
  1415. }
  1416. //导入评审专家
  1417. case bool when $"{grant_type}".Equals("add-remove-experts", StringComparison.OrdinalIgnoreCase):
  1418. {
  1419. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1420. List<Expert> upsert_experts = new List<Expert>();
  1421. List<Expert> remove_experts = new List<Expert>();
  1422. if (request.TryGetProperty("upsert_experts", out JsonElement _upsert_experts) && _upsert_experts.ValueKind.Equals(JsonValueKind.Array))
  1423. {
  1424. upsert_experts = _upsert_experts.ToObject<List<Expert>>();
  1425. }
  1426. if (request.TryGetProperty("remove_experts", out JsonElement _remove_experts) && _remove_experts.ValueKind.Equals(JsonValueKind.Array))
  1427. {
  1428. remove_experts = _remove_experts.ToObject<List<Expert>>();
  1429. }
  1430. ActivityExpert activityExpert = null;
  1431. if (upsert_experts.IsNotEmpty())
  1432. {
  1433. var tmdids = upsert_experts.Where(x => !string.IsNullOrWhiteSpace(x.tmdid)).Select(z => z.tmdid);
  1434. var phones = upsert_experts.Where(x => !string.IsNullOrWhiteSpace(x.mobile)).Select(z => z.mobile);
  1435. var emails = upsert_experts.Where(x => !string.IsNullOrWhiteSpace(x.email)).Select(z => z.email);
  1436. List<string> keys = new List<string>();
  1437. if (tmdids.Any())
  1438. {
  1439. keys.AddRange(tmdids);
  1440. }
  1441. if (phones.Any())
  1442. {
  1443. keys.AddRange(phones);
  1444. }
  1445. if (emails.Any())
  1446. {
  1447. keys.AddRange(emails);
  1448. }
  1449. upsert_experts.ForEach(x => { x.status = 0; x.iname = x.name; x.name = null; });
  1450. List<CoreUser> coreUsers = new List<CoreUser>();
  1451. if (keys.Any())
  1452. {
  1453. try
  1454. {
  1455. var content = new StringContent(keys.ToJsonString(), Encoding.UTF8, "application/json");
  1456. string json = await _coreAPIHttpService.GetUserInfos(content);
  1457. if (!string.IsNullOrWhiteSpace(json))
  1458. {
  1459. coreUsers = json.ToObject<List<CoreUser>>();
  1460. }
  1461. }
  1462. catch (Exception ex)
  1463. {
  1464. await _dingDing.SendBotMsg($"{_option.Location},导入名单时,查验key信息错误{ex.Message}\n{ex.StackTrace}\n\n{keys.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
  1465. }
  1466. }
  1467. if (coreUsers.IsNotEmpty())
  1468. {
  1469. foreach (var t in upsert_experts)
  1470. {
  1471. if (!string.IsNullOrWhiteSpace(t.tmdid))
  1472. {
  1473. CoreUser coreUser = coreUsers.Find(x => x.id.Equals(t.tmdid));
  1474. if (coreUser != null)
  1475. {
  1476. t.id = coreUser.id;
  1477. t.name = coreUser.name;
  1478. t.picture = coreUser.picture;
  1479. t.tmdid = coreUser.id;
  1480. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  1481. {
  1482. t.mobile = coreUser.mobile;
  1483. }
  1484. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  1485. {
  1486. t.email = coreUser.mail;
  1487. }
  1488. }
  1489. }
  1490. if (string.IsNullOrWhiteSpace(t.id))
  1491. {
  1492. if (!string.IsNullOrWhiteSpace(t.mobile))
  1493. {
  1494. CoreUser coreUser = coreUsers.Find(x => !string.IsNullOrWhiteSpace(x.mobile) && x.mobile.Equals(t.mobile));
  1495. if (coreUser != null)
  1496. {
  1497. t.id = coreUser.id;
  1498. t.name = coreUser.name;
  1499. t.picture = coreUser.picture;
  1500. t.tmdid = coreUser.id;
  1501. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  1502. {
  1503. t.mobile = coreUser.mobile;
  1504. }
  1505. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  1506. {
  1507. t.email = coreUser.mail;
  1508. }
  1509. }
  1510. }
  1511. }
  1512. if (string.IsNullOrWhiteSpace(t.id))
  1513. {
  1514. if (!string.IsNullOrWhiteSpace(t.email))
  1515. {
  1516. CoreUser coreUser = coreUsers.Find(x => !string.IsNullOrWhiteSpace(x.mail) && x.mail.Equals(t.email));
  1517. if (coreUser != null)
  1518. {
  1519. t.id = coreUser.id;
  1520. t.name = coreUser.name;
  1521. t.picture = coreUser.picture;
  1522. t.tmdid = coreUser.id;
  1523. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  1524. {
  1525. t.mobile = coreUser.mobile;
  1526. }
  1527. if (!string.IsNullOrWhiteSpace(coreUser.mail))
  1528. {
  1529. t.email = coreUser.mail;
  1530. }
  1531. }
  1532. }
  1533. }
  1534. }
  1535. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync($"{_activityId}", new PartitionKey("ActivityExpert"));
  1536. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1537. {
  1538. activityExpert = JsonDocument.Parse(response.Content).RootElement.Deserialize<ActivityExpert>();
  1539. upsert_experts.ForEach(x =>
  1540. {
  1541. Expert tch = null;
  1542. if (string.IsNullOrWhiteSpace(x.id))
  1543. {
  1544. tch = activityExpert.experts.Find(t => !string.IsNullOrWhiteSpace(t.iname) && t.iname.Equals(x.iname));
  1545. }
  1546. else
  1547. {
  1548. tch = activityExpert.experts.Find(t => !string.IsNullOrWhiteSpace(x.id) && !string.IsNullOrWhiteSpace(t.id) && t.id.Equals(x.id));
  1549. }
  1550. if (tch != null)
  1551. {
  1552. tch.status = x.status;
  1553. tch.name = x.name;
  1554. tch.iname = x.iname;
  1555. tch.picture = x.picture;
  1556. tch.mobile = x.mobile;
  1557. tch.tmdid = x.tmdid;
  1558. tch.email = x.email;
  1559. tch.id = x.id;
  1560. tch.school = x.school;
  1561. //直接替换更新
  1562. tch.modules=x.modules;
  1563. tch.subjects=x.subjects;
  1564. // x.modules.ForEach(y => {
  1565. // if (!tch.modules.Contains(y))
  1566. // {
  1567. // tch.modules.Add(y);
  1568. // }
  1569. // });
  1570. // x.subjects.ForEach(r => {
  1571. // if (!string.IsNullOrWhiteSpace(r.subject) && !string.IsNullOrWhiteSpace(r.period))
  1572. // {
  1573. // var sub = tch.subjects.Find(x => !string.IsNullOrWhiteSpace(x.subject) && !string.IsNullOrWhiteSpace(x.period) && x.subject.Equals(r.subject) && x.period.Equals(r.period));
  1574. // if (sub == null)
  1575. // {
  1576. // tch.subjects.Add(r);
  1577. // }
  1578. // }
  1579. // if (!string.IsNullOrWhiteSpace(r.subject) && string.IsNullOrWhiteSpace(r.period))
  1580. // {
  1581. // var sub = tch.subjects.Find(a => !string.IsNullOrWhiteSpace(a.subject) && string.IsNullOrWhiteSpace(a.period) && a.subject.Equals(r.subject));
  1582. // if (sub == null)
  1583. // {
  1584. // tch.subjects.Add(r);
  1585. // }
  1586. // }
  1587. // });
  1588. }
  1589. else
  1590. {
  1591. activityExpert.experts.Add(new Expert
  1592. {
  1593. status = x.status,
  1594. name = x.name,
  1595. iname = x.iname,
  1596. picture = x.picture,
  1597. mobile = x.mobile,
  1598. tmdid = x.tmdid,
  1599. email = x.email,
  1600. id = x.id,
  1601. title = x.title,
  1602. subjects = x.subjects,
  1603. modules = x.modules,
  1604. school=x.school,
  1605. });
  1606. }
  1607. });
  1608. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityExpert, new PartitionKey("ActivityExpert"));
  1609. }
  1610. else
  1611. {
  1612. activityExpert = new ActivityExpert { id = $"{_activityId}", code = "ActivityExpert", pk = "ActivityExpert", experts = upsert_experts };
  1613. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityExpert, new PartitionKey("ActivityExpert"));
  1614. }
  1615. }
  1616. else
  1617. {
  1618. activityExpert = new ActivityExpert { id = $"{_activityId}", code = "ActivityExpert", pk = "ActivityExpert", experts = upsert_experts };
  1619. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityExpert, new PartitionKey("ActivityExpert"));
  1620. }
  1621. }
  1622. if (remove_experts.IsNotEmpty())
  1623. {
  1624. if (activityExpert == null)
  1625. {
  1626. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync($"{_activityId}", new PartitionKey("ActivityExpert"));
  1627. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  1628. {
  1629. activityExpert = JsonDocument.Parse(response.Content).RootElement.Deserialize<ActivityExpert>();
  1630. }
  1631. }
  1632. if (activityExpert!=null)
  1633. {
  1634. remove_experts.ForEach(z => {
  1635. if (!string.IsNullOrWhiteSpace(z.id))
  1636. {
  1637. activityExpert.experts.RemoveAll(x => !string.IsNullOrWhiteSpace(x.id) && x.id.Equals(z.id));
  1638. }
  1639. else
  1640. {
  1641. if (!string.IsNullOrWhiteSpace(z.mobile))
  1642. {
  1643. activityExpert.experts.RemoveAll(x => !string.IsNullOrWhiteSpace(x.mobile) && x.mobile.Equals(z.mobile));
  1644. }
  1645. if (!string.IsNullOrWhiteSpace(z.email))
  1646. {
  1647. activityExpert.experts.RemoveAll(x => !string.IsNullOrWhiteSpace(x.email) && x.email.Equals(z.email));
  1648. }
  1649. if (!string.IsNullOrWhiteSpace(z.tmdid))
  1650. {
  1651. activityExpert.experts.RemoveAll(x => !string.IsNullOrWhiteSpace(x.tmdid) && x.tmdid.Equals(z.tmdid));
  1652. }
  1653. }
  1654. });
  1655. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityExpert, new PartitionKey("ActivityExpert"));
  1656. }
  1657. }
  1658. return Ok(new { activityExpert, code = 200 });
  1659. }
  1660. //评审专家列表
  1661. case bool when $"{grant_type}".Equals("list-experts", StringComparison.OrdinalIgnoreCase):
  1662. {
  1663. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1664. var expertTasks = await ActivityService.ListExperts(_azureCosmos, _coreAPIHttpService, _dingDing, _option, $"{_activityId}");
  1665. return Ok(new { expertTasks, code = 200 });
  1666. }
  1667. case bool when $"{grant_type}".Equals("update-reviewStatus", StringComparison.OrdinalIgnoreCase):
  1668. {
  1669. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1670. if (!request.TryGetProperty("reviewStatus", out JsonElement _reviewStatus)) return BadRequest();
  1671. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  1672. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  1673. {
  1674. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  1675. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  1676. if (contest.modules.Contains("review") && contest.review != null)
  1677. {
  1678. //只有开启评审的时候才去检查评审时间, 取消评审不用检查。
  1679. if ($"{_reviewStatus}".Equals("1") && (now < contest.review.stime || now > contest.review.etime))
  1680. {
  1681. return Ok(new { code = 1, msg = "不在评审时间范围内!" });
  1682. }
  1683. }
  1684. else
  1685. {
  1686. return Ok(new { code = 2, msg = "未配置评审模块!" });
  1687. }
  1688. if (int.TryParse($"{_reviewStatus}", out int reviewStatus))
  1689. {
  1690. contest.review.reviewStatus = reviewStatus;
  1691. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(contest, new PartitionKey("Contest"));
  1692. return Ok(new { code = 200, msg = "操作成功!" });
  1693. }
  1694. else
  1695. {
  1696. return Ok(new { code = 4, msg = "评审参数错误!" });
  1697. }
  1698. }
  1699. else {
  1700. return Ok(new { code = 3, msg = "活动不存在!" });
  1701. }
  1702. }
  1703. //分配评审作品任务-检查,自动分配
  1704. case bool when $"{grant_type}".Equals("allocation-task-auto-assign", StringComparison.OrdinalIgnoreCase):
  1705. {
  1706. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1707. ResponseMessage responseReviewRule = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("ReviewRule-disposable"));
  1708. if (responseReviewRule.StatusCode==System.Net.HttpStatusCode.OK)
  1709. {
  1710. ReviewRule reviewRule = JsonDocument.Parse(responseReviewRule.Content).RootElement.ToObject<ReviewRule>();
  1711. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  1712. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  1713. {
  1714. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  1715. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  1716. if (contest.modules.Contains("review") && contest.review != null)
  1717. {
  1718. if (now < contest.review.stime || now > contest.review.etime)
  1719. {
  1720. return Ok(new { code = 12, msg = "不在评审时间范围内!" });
  1721. }
  1722. }
  1723. else
  1724. {
  1725. return Ok(new { code = 11, msg = "未配置评审模块!" });
  1726. }
  1727. var result = ActivityService.CheckReviewRule(reviewRule, contest);
  1728. if (result.invalidCode == 200)
  1729. {
  1730. ResponseMessage responseActivityExpert = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync($"{_activityId}", new PartitionKey("ActivityExpert"));
  1731. if (responseActivityExpert.StatusCode==System.Net.HttpStatusCode.OK)
  1732. {
  1733. ActivityExpert activityExpert = JsonDocument.Parse(responseActivityExpert.Content).RootElement.ToObject<ActivityExpert>();
  1734. HashSet<string> periodSubjectKey = new HashSet<string>();
  1735. List<dynamic> distributeInvalid = new List<dynamic>();
  1736. string allocationTaskKey = $"Contest:Allocation:{_activityId}";
  1737. switch (reviewRule.distribute)
  1738. {
  1739. case "period":
  1740. {
  1741. List<ExpertPeriodSubjectDto> expertPeriodSubjects = new List<ExpertPeriodSubjectDto>();
  1742. var fieldPeriod = contest.sign.fields.Find(z => z.field.Equals("period"));
  1743. if (fieldPeriod == null)
  1744. {
  1745. return Ok(new { code = 5, msg = "评审规则匹配学段,但赛课表单未配置学段。" });
  1746. }
  1747. else
  1748. {
  1749. foreach (string item in fieldPeriod.item)
  1750. {
  1751. periodSubjectKey.Add($"{item}-");
  1752. var periodExperts = activityExpert.experts.Where(z => z.modules.Contains("Contest") && z.subjects != null && z.subjects.Where(v => !string.IsNullOrWhiteSpace(v.period)).Select(c => c.period).Contains(item));
  1753. if (periodExperts.Count() < reviewRule.taskCount)
  1754. {
  1755. distributeInvalid.Add(new { name = item, expertCount = periodExperts.Count(), needCount = reviewRule.taskCount });
  1756. }
  1757. expertPeriodSubjects.AddRange(periodExperts.Select(z => new ExpertPeriodSubjectDto { expertId = z.id, periodSubjects = z.subjects.Select(x => $"{x.period}-")?.ToList() }));
  1758. }
  1759. }
  1760. if (distributeInvalid.Count > 0)
  1761. {
  1762. return Ok(new { code = 6, msg = "学段匹配的专家数量不足。", distributeInvalid });
  1763. }
  1764. else
  1765. {
  1766. IEnumerable<ExpertPeriodSubjectDto> experts = activityExpert.experts.Where(z => !string.IsNullOrWhiteSpace(z.id))//处理
  1767. .Select(z => new ExpertPeriodSubjectDto { expertId = z.id, expertName=z.iname, expertPicture=z.picture, expertTmdname=z.name, periodSubjects = z.subjects.Select(v => $"{v.period}-") });
  1768. var allocationResult = await ActivityService.AllocationTask(_azureCosmos, experts, contest, periodSubjectKey, reviewRule.distribute, reviewRule.taskCount);
  1769. if (allocationResult.expertContestTasks.IsNotEmpty())
  1770. {
  1771. await _azureRedis.GetRedisClient(8).StringSetAsync(allocationTaskKey, allocationResult.expertContestTasks.ToJsonString(), expiry: new TimeSpan(0, 5, 0));
  1772. }
  1773. else
  1774. {
  1775. allocationTaskKey = string.Empty;
  1776. }
  1777. return Ok(new { taskKey = allocationTaskKey, code = 200, tasksDb = allocationResult.expertContestTasksDB, tasksAdd = allocationResult.expertContestTasks, invalid = allocationResult.activityEnrollsInvalid });
  1778. }
  1779. }
  1780. case "subject":
  1781. {
  1782. List<ExpertPeriodSubjectDto> expertPeriodSubjects = new List<ExpertPeriodSubjectDto>();
  1783. var fieldSubject = contest.sign.fields.Find(z => z.field.Equals("subject"));
  1784. if (fieldSubject == null)
  1785. {
  1786. return Ok(new { code = 7, msg = "评审规则匹配学科,但赛课表单未配置学科。" });
  1787. }
  1788. else
  1789. {
  1790. foreach (string item in fieldSubject.item)
  1791. {
  1792. periodSubjectKey.Add($"-{item}");
  1793. var subjectExperts = activityExpert.experts.Where(z => z.modules.Contains("Contest") && z.subjects != null && z.subjects.Where(v => !string.IsNullOrWhiteSpace(v.subject)).Select(c => c.subject).Contains(item));
  1794. if (subjectExperts.Count() < reviewRule.taskCount)
  1795. {
  1796. distributeInvalid.Add(new { name = item, expertCount = subjectExperts.Count(), needCount = reviewRule.taskCount });
  1797. }
  1798. expertPeriodSubjects.AddRange(subjectExperts.Select(z => new ExpertPeriodSubjectDto { expertId = z.id, periodSubjects = z.subjects.Select(x => $"-{x.subject}")?.ToList() }));
  1799. }
  1800. }
  1801. if (distributeInvalid.Count > 0)
  1802. {
  1803. return Ok(new { code = 8, msg = "学科匹配的专家数量不足。", distributeInvalid });
  1804. }
  1805. else
  1806. {
  1807. IEnumerable<ExpertPeriodSubjectDto> experts = activityExpert.experts.Where(z => !string.IsNullOrWhiteSpace(z.id))//处理
  1808. .Select(z => new ExpertPeriodSubjectDto { expertId = z.id, expertName=z.iname, expertPicture=z.picture, expertTmdname=z.name, periodSubjects = z.subjects.Select(v => $"-{v.subject}") });
  1809. var allocationResult = await ActivityService.AllocationTask(_azureCosmos, experts, contest, periodSubjectKey, reviewRule.distribute, reviewRule.taskCount);
  1810. if (allocationResult.expertContestTasks.IsNotEmpty())
  1811. {
  1812. await _azureRedis.GetRedisClient(8).StringSetAsync(allocationTaskKey, allocationResult.expertContestTasks.ToJsonString(), expiry: new TimeSpan(0, 5, 0));
  1813. }
  1814. else
  1815. {
  1816. allocationTaskKey = string.Empty;
  1817. }
  1818. return Ok(new { taskKey = allocationTaskKey, code = 200, tasksDb = allocationResult.expertContestTasksDB, tasksAdd = allocationResult.expertContestTasks, invalid = allocationResult.activityEnrollsInvalid });
  1819. }
  1820. }
  1821. case "periodAndSubject":
  1822. {
  1823. List<ExpertPeriodSubjectDto> expertPeriodSubjects = new List<ExpertPeriodSubjectDto>();
  1824. var fieldPeriod = contest.sign.fields.Find(z => z.field.Equals("period"));
  1825. if (fieldPeriod == null)
  1826. {
  1827. return Ok(new { code = 9, msg = "评审规则匹配学段和学科,但赛课表单未配置学段。" });
  1828. }
  1829. var fieldSubject = contest.sign.fields.Find(z => z.field.Equals("subject"));
  1830. if (fieldSubject == null)
  1831. {
  1832. return Ok(new { code = 10, msg = "评审规则匹配学段和学科,但赛课表单未配置学科。" });
  1833. }
  1834. foreach (var period in fieldPeriod.item)
  1835. {
  1836. foreach (var subject in fieldSubject.item)
  1837. {
  1838. periodSubjectKey.Add($"{period}-{subject}");
  1839. var periodSubjectExperts = activityExpert.experts.FindAll(z => z.modules.Contains("Contest") && z.subjects != null && z.subjects.Where(v => !string.IsNullOrWhiteSpace(v.period) && !string.IsNullOrWhiteSpace(v.subject))
  1840. .Select(c => $"{c.period}-{c.subject}").Contains($"{period}-{subject}"));
  1841. if (periodSubjectExperts.Count() < reviewRule.taskCount)
  1842. {
  1843. distributeInvalid.Add(new { name = $"{period}-{subject}", expertCount = periodSubjectExperts.Count(), needCount = reviewRule.taskCount });
  1844. }
  1845. expertPeriodSubjects.AddRange(periodSubjectExperts.Select(z => new ExpertPeriodSubjectDto { expertId = z.id, periodSubjects = z.subjects.Select(x => $"{x.period}-{x.subject}")?.ToList() }));
  1846. }
  1847. }
  1848. if (distributeInvalid.Count > 0)
  1849. {
  1850. return Ok(new { code = 13, msg = "学段和学科匹配的专家数量不足。", distributeInvalid });
  1851. }
  1852. else
  1853. {
  1854. IEnumerable<ExpertPeriodSubjectDto> experts = activityExpert.experts.Where(z => !string.IsNullOrWhiteSpace(z.id))//处理
  1855. .Select(z => new ExpertPeriodSubjectDto { expertId = z.id, expertName=z.iname, expertPicture=z.picture, expertTmdname=z.name, periodSubjects = z.subjects.Select(v => $"{v.period}-{v.subject}") });
  1856. var allocationResult = await ActivityService.AllocationTask(_azureCosmos, experts, contest, periodSubjectKey, reviewRule.distribute, reviewRule.taskCount);
  1857. if (allocationResult.expertContestTasks.IsNotEmpty())
  1858. {
  1859. await _azureRedis.GetRedisClient(8).StringSetAsync(allocationTaskKey, allocationResult.expertContestTasks.ToJsonString(), expiry: new TimeSpan(0, 5, 0));
  1860. }
  1861. else
  1862. {
  1863. allocationTaskKey = string.Empty;
  1864. }
  1865. return Ok(new { taskKey = allocationTaskKey, code = 200, tasksDb = allocationResult.expertContestTasksDB, tasksAdd = allocationResult.expertContestTasks, invalid = allocationResult.activityEnrollsInvalid });
  1866. }
  1867. }
  1868. default:
  1869. //distribute=none
  1870. {
  1871. if (activityExpert.experts.Count() >= reviewRule.taskCount)
  1872. {
  1873. periodSubjectKey.Add($"-"); IEnumerable<ExpertPeriodSubjectDto> experts = activityExpert.experts.Where(z => !string.IsNullOrWhiteSpace(z.id))//处理
  1874. .Select(z => new ExpertPeriodSubjectDto { expertId = z.id, expertName=z.iname, expertPicture=z.picture, expertTmdname=z.name, periodSubjects = z.subjects.Select(v => $"-") });
  1875. var allocationResult = await ActivityService.AllocationTask(_azureCosmos, experts, contest, periodSubjectKey, reviewRule.distribute, reviewRule.taskCount);
  1876. if (allocationResult.expertContestTasks.IsNotEmpty())
  1877. {
  1878. await _azureRedis.GetRedisClient(8).StringSetAsync(allocationTaskKey, allocationResult.expertContestTasks.ToJsonString(), expiry: new TimeSpan(0, 5, 0));
  1879. }
  1880. else
  1881. {
  1882. allocationTaskKey = string.Empty;
  1883. }
  1884. return Ok(new { taskKey = allocationTaskKey, code = 200, tasksDb = allocationResult.expertContestTasksDB, tasksAdd = allocationResult.expertContestTasks, invalid = allocationResult.activityEnrollsInvalid });
  1885. }
  1886. else
  1887. {
  1888. return Ok(new { code = 4, msg = "评审专家人数不应少于作品分配次数。" });
  1889. }
  1890. }
  1891. }
  1892. }
  1893. else
  1894. {
  1895. return Ok(new { code = 3, msg = "未配置评审专家!" });
  1896. }
  1897. }
  1898. else
  1899. {
  1900. return Ok(new { code = result.invalidCode, msg = result.msg });
  1901. }
  1902. }
  1903. else
  1904. {
  1905. return Ok(new { code = 2, msg = "没有赛课模块!" });
  1906. }
  1907. //专家人数>=每个作品分配次数,同一作品才不会多次被分配到分配给同一个专家。
  1908. }
  1909. else
  1910. {
  1911. return Ok(new { code = 1, msg = "未配置评审规则!" });
  1912. }
  1913. }
  1914. //分配评审作品任务-自动
  1915. case bool when $"{grant_type}".Equals("allocation-task-auto-save", StringComparison.OrdinalIgnoreCase):
  1916. {
  1917. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  1918. if (!request.TryGetProperty("taskKey", out JsonElement _taskKey)) return BadRequest();
  1919. var value = await _azureRedis.GetRedisClient(8).StringGetAsync(_taskKey.GetString());
  1920. if (value.HasValue)
  1921. {
  1922. List<ExpertContestTaskDto> contestTasks = value.ToString().ToObject<List<ExpertContestTaskDto>>();
  1923. List<ActivityExpertTask> expertTasks = new List<ActivityExpertTask>();
  1924. var expertIds = contestTasks.Where(x => !string.IsNullOrWhiteSpace(x.expertId)).Select(z => z.expertId).ToHashSet();
  1925. if (expertIds != null && expertIds.Count > 0)
  1926. {
  1927. string taskSQL = $"select value c from c where c.pk='ActivityExpertTask' and c.id in ({string.Join(",", expertIds.Select(z => $"'{z}'"))})";
  1928. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{_activityId}");
  1929. if (result.list.IsNotEmpty())
  1930. {
  1931. expertTasks.AddRange(result.list);
  1932. }
  1933. }
  1934. HashSet<ActivityExpertTask> expertTasksChange = new HashSet<ActivityExpertTask>();
  1935. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  1936. Contest contest = null;
  1937. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  1938. {
  1939. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  1940. contest= JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  1941. if (contest.modules.Contains("review") && contest.review != null)
  1942. {
  1943. if (now < contest.review.stime || now > contest.review.etime)
  1944. {
  1945. return Ok(new { code = 12, msg = "不在评审时间范围内!" });
  1946. }
  1947. }
  1948. }
  1949. foreach (var contestTask in contestTasks)
  1950. {
  1951. ExpertContestTask expertContestTask = contestTask.ToJsonString().ToObject<ExpertContestTask>();
  1952. var expertTask = expertTasks.Find(z => z.id.Equals(contestTask.expertId));
  1953. if (expertTask != null)
  1954. {
  1955. var task = expertTask.contestTasks.Find(z => z.uploadId.Equals(contestTask.uploadId));
  1956. if (task == null)
  1957. {
  1958. expertTask.contestTasks.Add(expertContestTask);
  1959. expertTasksChange.Add(expertTask);
  1960. }
  1961. }
  1962. else
  1963. {
  1964. ActivityExpertTask activityExpertTask = new ActivityExpertTask()
  1965. {
  1966. id = contestTask.expertId,
  1967. code = $"ActivityExpertTask-{_activityId}",
  1968. pk = "ActivityExpertTask",
  1969. activityId=_activityId.GetString(),
  1970. picture=contestTask.expertPicture,
  1971. name=contestTask.expertName,
  1972. tmdname=contestTask.expertTmdname,
  1973. contestTasks = new List<ExpertContestTask> { expertContestTask }
  1974. };
  1975. expertTasksChange.Add(activityExpertTask);
  1976. expertTasks.Add(activityExpertTask);
  1977. }
  1978. }
  1979. List<Task<ItemResponse<ActivityExpertTask>>> responses = new List<Task<ItemResponse<ActivityExpertTask>>>();
  1980. foreach (var contestTask in expertTasksChange)
  1981. {
  1982. responses.Add(_azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(contestTask, new PartitionKey($"ActivityExpertTask-{_activityId}")));
  1983. }
  1984. if (responses.IsNotEmpty())
  1985. {
  1986. await responses.TaskPage(10);
  1987. //await Task.WhenAll(responses);
  1988. }
  1989. await _azureRedis.GetRedisClient(8).KeyDeleteAsync(_taskKey.GetString());
  1990. List<ExpertContestTaskDto> tasksDb = new List<ExpertContestTaskDto>();
  1991. foreach (var item in expertTasks)
  1992. {
  1993. tasksDb.AddRange(item.contestTasks.Select(z =>
  1994. new ExpertContestTaskDto
  1995. {
  1996. expertName=item.name,
  1997. expertPicture=item.picture,
  1998. expertTmdname=item.tmdname,
  1999. expertId = item.id,
  2000. available = 1,
  2001. uploadId = z.uploadId,
  2002. name = z.name,
  2003. uploadTypes = z.uploadTypes,
  2004. count = z.count,
  2005. cipher=z.cipher,
  2006. type=z.type,
  2007. leader=z.leader,
  2008. members=z.members,
  2009. tmdid=z.tmdid,
  2010. score=z.score,
  2011. status=z.status,
  2012. detailScore=z.detailScore,
  2013. activityId=_activityId.GetString()
  2014. }));
  2015. }
  2016. return Ok(new { code = 200, tasksDb = tasksDb });
  2017. }
  2018. else { return Ok(new { code = 1, msg = "作品分配Token异常!" }); }
  2019. }
  2020. //分配评审作品任务-手动
  2021. case bool when $"{grant_type}".Equals("allocation-task-manual-save", StringComparison.OrdinalIgnoreCase):
  2022. {
  2023. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2024. if (!request.TryGetProperty("uploadId", out JsonElement _uploadId)) return BadRequest();
  2025. if (!request.TryGetProperty("expertId", out JsonElement _expertId)) return BadRequest();
  2026. request.TryGetProperty("expertIdOld", out JsonElement _expertIdOld);
  2027. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2028. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK) {
  2029. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2030. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2031. if (contest.modules.Contains("review") && contest.review != null)
  2032. {
  2033. if (now < contest.review.stime || now > contest.review.etime)
  2034. {
  2035. return Ok(new { code = 12, msg = "不在评审时间范围内!" });
  2036. }
  2037. }
  2038. else
  2039. {
  2040. return Ok(new { code = 11, msg = "未配置评审模块!" });
  2041. }
  2042. }
  2043. else
  2044. {
  2045. return Ok(new { code = 13, msg = "没有赛课模块!" });
  2046. }
  2047. string sql = $"select value c from c where c.upload.uploadId='{_uploadId}' and c.pk='ActivityEnroll'";
  2048. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql, $"ActivityEnroll-{_activityId}");
  2049. if (result.list.IsNotEmpty())
  2050. {
  2051. ActivityExpertTask expertTask = null;
  2052. ExpertContestTask contestTask = new ExpertContestTask
  2053. {
  2054. uploadId=_uploadId.GetString(),
  2055. };
  2056. string name = string.Empty;
  2057. int count = 0;
  2058. if (result.list.Count>1)
  2059. {
  2060. var leaders = result.list.FindAll(z => z.contest.leader == 1);
  2061. var leader = leaders?.First();
  2062. if (leader!=null)
  2063. {
  2064. name = leader?.contest?.teamName;
  2065. if (string.IsNullOrEmpty(name))
  2066. {
  2067. name = $"{leader?.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val}({result.list.Count})";
  2068. }
  2069. if (leader?.upload != null && leader.upload.sokrates.IsNotEmpty())
  2070. {
  2071. count += leader.upload.sokrates.Count;
  2072. }
  2073. if (leader?.upload != null && leader.upload.files.IsNotEmpty())
  2074. {
  2075. count += leader.upload.files.Count;
  2076. }
  2077. if (leader?.upload != null && leader.upload.lessons.IsNotEmpty())
  2078. {
  2079. count += leader.upload.lessons.Count;
  2080. }
  2081. if (leader?.upload!=null && leader.upload.complexes.IsNotEmpty())
  2082. {
  2083. count+= leader.upload.complexes.Count();
  2084. }
  2085. List<IdNameCode> members = result.list.Select(z => new IdNameCode { id = z.id, code = z.schoolId, picture = z.tmdPicture, nickname = z.tmdName, name = z.contest?.enrollInfos?.Find(e => e.code.Equals("name")).val }).ToList();
  2086. var period = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
  2087. var subject = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
  2088. contestTask.name= $"{leader?.schoolName}-{name}";
  2089. //contestTask.uploadTypes=new List<string> { leader.upload?.type };
  2090. contestTask.uploadTypes =leader.upload.uploadType;
  2091. contestTask.count=count;
  2092. contestTask.cipher=leader.contest?.cipher;
  2093. contestTask.type=leader.contest.type;
  2094. contestTask.leader=leader.contest.leader;
  2095. contestTask.members= members;
  2096. contestTask.tmdid=leader.id;
  2097. contestTask.period=period?.val;
  2098. contestTask.subject=subject?.val;
  2099. }
  2100. else
  2101. {
  2102. return Ok(new { code = 3, msg = "该队伍没有队长!" });
  2103. }
  2104. }
  2105. else if (result.list.Count==1)
  2106. {
  2107. var leader = result.list[0];
  2108. name = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("name"))?.val;
  2109. if (leader?.upload != null && leader.upload.sokrates.IsNotEmpty())
  2110. {
  2111. count += leader.upload.sokrates.Count;
  2112. }
  2113. if (leader?.upload != null && leader.upload.files.IsNotEmpty())
  2114. {
  2115. count += leader.upload.files.Count;
  2116. }
  2117. if (leader?.upload != null && leader.upload.lessons.IsNotEmpty())
  2118. {
  2119. count += leader.upload.lessons.Count;
  2120. }
  2121. var period = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("period"));
  2122. var subject = leader?.contest?.enrollInfos?.Find(z => z.code.Equals("subject"));
  2123. contestTask.name= $"{leader?.schoolName}-{name}";
  2124. contestTask.uploadTypes= leader.upload.uploadType;
  2125. contestTask.count=count;
  2126. contestTask.type=leader.contest.type;
  2127. contestTask.tmdid=leader.id;
  2128. contestTask.period=period?.val;
  2129. contestTask.subject=subject?.val;
  2130. }
  2131. ActivityExpert activityExpert = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<ActivityExpert>(_activityId.GetString(), new PartitionKey("ActivityExpert"));
  2132. Expert expert= activityExpert.experts.Find(z => !string.IsNullOrWhiteSpace(z.id) && z.id.Equals(_expertId.GetString()));
  2133. if (expert!=null) {
  2134. //作品是否有分配过
  2135. string taskSQL = $"select value c from c join b in c.contestTasks where b.uploadId='{_uploadId}' and c.pk='ActivityExpertTask' " ;
  2136. var resultTask = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(taskSQL, $"ActivityExpertTask-{_activityId}");
  2137. if (resultTask.list.IsNotEmpty())
  2138. {
  2139. if (!string.IsNullOrWhiteSpace($"{_expertIdOld}")) {
  2140. if (!expert.id.Equals(_expertIdOld.GetString()))
  2141. {
  2142. //从旧的分配中移除
  2143. var oldTaskExpert = resultTask.list.Find(z => z.id.Equals(_expertIdOld.GetString()));
  2144. if (oldTaskExpert!=null)
  2145. {
  2146. var changeCount = oldTaskExpert.contestTasks.RemoveAll(z => z.uploadId.Equals(_uploadId.GetString()));
  2147. if (changeCount>0)
  2148. {
  2149. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(oldTaskExpert, new PartitionKey(oldTaskExpert.code));
  2150. }
  2151. }
  2152. else
  2153. {
  2154. return Ok(new { code = 2, msg = "未找到该作品已经分配的专家!" });
  2155. }
  2156. }
  2157. else {
  2158. return Ok(new { code = 4, msg = "作品变更评审专家,调整后的专家不能与已分配的专家相同!" });
  2159. }
  2160. }
  2161. // 除去被调整的专家(oldExpert),(resultTask)可能还有别的专家已分配的,但是不影响该作品继续被分配到新的专家, 可以理解为,作品分配次数+1,
  2162. //作品未被分配的情况、
  2163. string expTaskSQL = $"select value c from c where c.id='{expert.id}' and c.pk='ActivityExpertTask' ";
  2164. var resultExpTask = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(expTaskSQL, $"ActivityExpertTask-{_activityId}");
  2165. if (resultExpTask.list.IsNotEmpty())
  2166. {
  2167. var task = resultExpTask.list[0].contestTasks.Find(z => z.uploadId.Equals(_uploadId.GetString()));
  2168. if (task!=null)
  2169. {
  2170. task=contestTask;
  2171. }
  2172. else
  2173. {
  2174. resultExpTask.list[0].contestTasks.Add(contestTask);
  2175. }
  2176. expertTask=resultExpTask.list[0];
  2177. expertTask.activityId=_activityId.GetString();
  2178. }
  2179. else
  2180. {
  2181. //专家没有任何被分配的作品
  2182. expertTask = new ActivityExpertTask()
  2183. {
  2184. id= expert.id,
  2185. code=$"ActivityExpertTask-{_activityId}",
  2186. pk="ActivityExpertTask",
  2187. ttl=-1,
  2188. activityId=_activityId.GetString(),
  2189. name=expert.iname,
  2190. tmdname=expert.name,
  2191. picture=expert.picture,
  2192. contestTasks= new List<ExpertContestTask> { contestTask }
  2193. };
  2194. }
  2195. if (expertTask!=null) {
  2196. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(expertTask, new PartitionKey(expertTask.code));
  2197. }
  2198. }
  2199. else {
  2200. //旧专家,和作品没有匹配的情况,未分配过,不能调整。
  2201. if (!string.IsNullOrWhiteSpace($"{_expertIdOld}"))
  2202. {
  2203. return Ok(new { code = 2, msg = "未找到该作品已经分配的专家!" });
  2204. }
  2205. //作品未被分配的情况、
  2206. string expTaskSQL = $"select value c from c where c.id='{expert.id}' and c.pk='ActivityExpertTask' ";
  2207. var resultExpTask = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(expTaskSQL, $"ActivityExpertTask-{_activityId}");
  2208. if (resultExpTask.list.IsNotEmpty())
  2209. {
  2210. var task = resultExpTask.list[0].contestTasks.Find(z => z.uploadId.Equals(_uploadId.GetString()));
  2211. if (task!=null)
  2212. {
  2213. task=contestTask;
  2214. }
  2215. else {
  2216. resultExpTask.list[0].contestTasks.Add(contestTask);
  2217. }
  2218. expertTask=resultExpTask.list[0];
  2219. expertTask.activityId=_activityId.GetString();
  2220. }
  2221. else {
  2222. //专家没有任何被分配的作品
  2223. expertTask = new ActivityExpertTask()
  2224. {
  2225. id= expert.id,
  2226. code=$"ActivityExpertTask-{_activityId}",
  2227. pk="ActivityExpertTask",
  2228. ttl=-1,
  2229. activityId=_activityId.GetString(),
  2230. name=expert.iname,
  2231. tmdname=expert.name,
  2232. picture=expert.picture,
  2233. contestTasks= new List<ExpertContestTask> { contestTask }
  2234. };
  2235. }
  2236. if (expertTask!=null)
  2237. {
  2238. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(expertTask, new PartitionKey(expertTask.code));
  2239. }
  2240. }
  2241. }
  2242. return Ok(new { code = 200, expertTask });
  2243. }
  2244. else {
  2245. return Ok(new { code=1,msg ="作品不存在!"});
  2246. }
  2247. }
  2248. //修改活动成绩公示状态
  2249. case bool when $"{grant_type}".Equals("update-scoreStatus", StringComparison.OrdinalIgnoreCase):
  2250. {
  2251. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2252. if (!request.TryGetProperty("scoreStatus", out JsonElement _scoreStatus)) return BadRequest();
  2253. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2254. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  2255. {
  2256. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2257. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2258. if (contest.modules.Contains("score") && contest.score != null)
  2259. {
  2260. if (now < contest.score.stime || now > contest.score.etime)
  2261. {
  2262. return Ok(new { code = 1, msg = "不在成绩公布时间范围内!" });
  2263. }
  2264. }
  2265. else
  2266. {
  2267. return Ok(new { code = 2, msg = "未配置成绩公布模块!" });
  2268. }
  2269. if (int.TryParse($"{_scoreStatus}", out int scoreStatus))
  2270. {
  2271. contest.score.scoreStatus = scoreStatus;
  2272. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(contest, new PartitionKey("Contest"));
  2273. return Ok(new { code = 200, msg = "操作成功!" });
  2274. }
  2275. else
  2276. {
  2277. return Ok(new { code = 4, msg = "成绩公布参数错误!" });
  2278. }
  2279. }
  2280. else
  2281. {
  2282. return Ok(new { code = 3, msg = "活动不存在!" });
  2283. }
  2284. }
  2285. //修改活动成绩公布类型或等级
  2286. case bool when $"{grant_type}".Equals("update-scoreShowTypeOrLevel", StringComparison.OrdinalIgnoreCase):
  2287. {
  2288. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2289. if (!request.TryGetProperty("showType", out JsonElement _showType)) return BadRequest();
  2290. request.TryGetProperty("attention", out JsonElement _attention);
  2291. request.TryGetProperty("top", out JsonElement _top);
  2292. request.TryGetProperty("showDetail", out JsonElement _showDetail);
  2293. List<ScoreLevel> scoreLevels = new List<ScoreLevel>();
  2294. bool ok = true;
  2295. string msg = string.Empty;
  2296. int code = 200;
  2297. //全部
  2298. int showDetail = 0;
  2299. int top = -1;
  2300. int levelType = -1;
  2301. if (int.TryParse($"{_top}", out int topReq) && topReq>0)
  2302. {
  2303. top=topReq;
  2304. }
  2305. if (int.TryParse($"{_showDetail}", out int showDetailReq))
  2306. {
  2307. showDetail=showDetailReq;
  2308. }
  2309. if (int.TryParse($"{_showType}", out int showType))
  2310. {
  2311. if (showType==1)
  2312. {
  2313. // int levelType = 0;
  2314. if (!request.TryGetProperty("levelType", out JsonElement _levelType) ||!int.TryParse($"{_levelType}", out levelType)||!(levelType==0 ||levelType==1))
  2315. {
  2316. code=7;
  2317. ok = false;
  2318. msg="等级类型参数错误";
  2319. }
  2320. else {
  2321. if (!request.TryGetProperty("scoreLevels", out JsonElement _scoreLevels))
  2322. {
  2323. code=1;
  2324. ok = false;
  2325. msg="等级设置参数错误";
  2326. }
  2327. else
  2328. {
  2329. scoreLevels= _scoreLevels.ToObject<List<ScoreLevel>>();
  2330. if (scoreLevels.IsNotEmpty())
  2331. {
  2332. scoreLevels= scoreLevels.OrderBy(z => z.min).ToList();
  2333. double max = scoreLevels.First().min;
  2334. foreach (ScoreLevel scoreLevel in scoreLevels)
  2335. {
  2336. if (levelType==0)
  2337. {
  2338. //检查当前值最大大于最小
  2339. if (scoreLevel.max>scoreLevel.min)
  2340. { //当前最小大于上一轮的最大值
  2341. if (scoreLevel.min==max)
  2342. {
  2343. max = scoreLevel.max;
  2344. }
  2345. else
  2346. {
  2347. ok=false;
  2348. code=3;
  2349. msg=$"相邻等级的分数设置错误";
  2350. break;
  2351. }
  2352. }
  2353. else
  2354. {
  2355. ok=false;
  2356. code=4;
  2357. msg=$"等级的最大值小于最小值";
  2358. break;
  2359. }
  2360. }
  2361. else {
  2362. if (scoreLevel.top<=0) {
  2363. ok=false;
  2364. code=8;
  2365. msg=$"等级人数必须大于0";
  2366. break;
  2367. }
  2368. }
  2369. }
  2370. }
  2371. else
  2372. {
  2373. code=2;
  2374. ok = false;
  2375. msg="分数等级未设置!";
  2376. }
  2377. }
  2378. }
  2379. }
  2380. else if (showType==0)
  2381. {
  2382. ok=true;
  2383. code=200;
  2384. }
  2385. else
  2386. {
  2387. code=1;
  2388. ok = false;
  2389. msg="参数错误";
  2390. }
  2391. }
  2392. else
  2393. {
  2394. code=1;
  2395. ok = false;
  2396. msg="参数错误";
  2397. }
  2398. if (code==200 && ok==true)
  2399. {
  2400. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2401. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  2402. {
  2403. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2404. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2405. if (contest.modules.Contains("score") && contest.score != null)
  2406. {
  2407. contest.score.showType=showType;
  2408. contest.score.scoreLevels=scoreLevels;
  2409. contest.score.attention=$"{_attention}";
  2410. contest.score.top=top;
  2411. contest.score.levelType=levelType;
  2412. contest.score.showDetail=showDetail;
  2413. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).UpsertItemAsync(contest, new PartitionKey("Contest"));
  2414. return Ok(new { code = 200, msg = "操作成功" });
  2415. }
  2416. else
  2417. {
  2418. return Ok(new { code = 5, msg = "未配置成绩公布模块!" });
  2419. }
  2420. }
  2421. else
  2422. {
  2423. return Ok(new { code = 6, msg = "活动不存在!" });
  2424. }
  2425. }
  2426. else {
  2427. return Ok(new { code, msg });
  2428. }
  2429. }
  2430. //修改分数,在作品公布环节才能调整
  2431. case bool when $"{grant_type}".Equals("update-maskScore", StringComparison.OrdinalIgnoreCase):
  2432. {
  2433. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2434. if (!request.TryGetProperty("maskScoreDatas", out JsonElement _maskScoreDatas)) return BadRequest();
  2435. List<MaskScoreDto> maskScores = _maskScoreDatas.ToObject<List<MaskScoreDto>>();
  2436. if (maskScores.IsNotEmpty())
  2437. {
  2438. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2439. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  2440. {
  2441. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2442. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2443. if (contest.score?.stime<now && contest.score?.etime>now)
  2444. {
  2445. string sql = $"select value c from c where c.upload.uploadId in ({string.Join(",", maskScores.Select(z => $"'{z.uploadId}'"))}) and c.pk='ActivityEnroll' ";
  2446. var reslut = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql, $"ActivityEnroll-{_activityId}");
  2447. foreach (var item in maskScores)
  2448. {
  2449. var enrolls = reslut.list.FindAll(z => z.upload.uploadId.Equals(item.uploadId));
  2450. if (enrolls.IsNotEmpty())
  2451. {
  2452. foreach (var enroll in enrolls)
  2453. {
  2454. if (item.showScore==1 && item.maskScore>=0)
  2455. {
  2456. enroll.upload.showScore=item.showScore;
  2457. enroll.upload.maskScore=item.maskScore;
  2458. }
  2459. else
  2460. {
  2461. enroll.upload.showScore=0;
  2462. }
  2463. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enroll, new PartitionKey(enroll.code));
  2464. }
  2465. item.hasError=0;
  2466. }
  2467. else
  2468. {
  2469. item.hasError=1;
  2470. }
  2471. }
  2472. }
  2473. else
  2474. {
  2475. return Ok(new { code = 1, msg = "不在作品公布时间范围内!" });
  2476. }
  2477. }
  2478. else
  2479. {
  2480. return Ok(new { code = 2, msg = "活动不存在!" });
  2481. }
  2482. }
  2483. else {
  2484. return Ok(new { code = 2, msg = "活动不存在!" });
  2485. }
  2486. return Ok(new { code = 200, maskScores });
  2487. }
  2488. case bool when $"{grant_type}".Equals("get-scores", StringComparison.OrdinalIgnoreCase):
  2489. {
  2490. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2491. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2492. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  2493. {
  2494. List<ActivityTeacherScoreMask> teacherScores = new List<ActivityTeacherScoreMask>();
  2495. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2496. Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2497. if (contest.score?.stime<now)
  2498. {
  2499. string sql = $"select value c from c where c.pk='ActivityEnroll' ";
  2500. var reslut = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(sql, $"ActivityEnroll-{_activityId}");
  2501. if (contest.sign.type==1)
  2502. {
  2503. var teams = reslut.list.Where(x => !string.IsNullOrEmpty(x.contest?.cipher)).GroupBy(z => z.contest.cipher);
  2504. foreach (var team in teams)
  2505. {
  2506. var members = team.ToList();
  2507. var leader = members.FindAll(z => z.contest.leader==1)?.FirstOrDefault();
  2508. if (leader==null)
  2509. {
  2510. leader=members.First();
  2511. }
  2512. teacherScores.Add(new ActivityTeacherScoreMask
  2513. {
  2514. uploadId=leader.upload?.uploadId,
  2515. uploadName=!string.IsNullOrWhiteSpace(leader.upload?.name) ? leader.upload?.name : $"{leader.contest.teamName}",
  2516. score=leader.upload?.score??-1,
  2517. maskScore=leader.upload?.maskScore??-1,
  2518. showScore=leader.upload?.showScore??0,
  2519. tmdid=leader.id,
  2520. nickname=leader.tmdName,
  2521. name=leader.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val,
  2522. picture=leader.tmdPicture,
  2523. school=leader.schoolId,
  2524. schoolName=leader.schoolName,
  2525. schoolPicture=leader.schoolPicture,
  2526. cipher=leader.contest.cipher,
  2527. teamName=leader.contest.teamName,
  2528. type=leader.contest.type,
  2529. members=members.Select(z => new IdNameCode { id=z.id, name=z.contest.enrollInfos.Find(x => x.code.Equals("name"))?.val, picture=z.tmdPicture, nickname=z.tmdName }).ToList(),
  2530. });
  2531. }
  2532. }
  2533. else
  2534. {
  2535. ///个人组
  2536. foreach (var item in reslut.list)
  2537. {
  2538. teacherScores.Add(new ActivityTeacherScoreMask
  2539. {
  2540. uploadId=item.upload?.uploadId,
  2541. uploadName=!string.IsNullOrWhiteSpace(item.upload?.name) ? item.upload?.name : $"{item.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val}",
  2542. score=item.upload?.score??-1,
  2543. maskScore=item.upload?.maskScore??-1,
  2544. showScore=item.upload?.showScore??0,
  2545. tmdid=item.id,
  2546. nickname=item.tmdName,
  2547. name=item.contest.enrollInfos.Find(z => z.code.Equals("name"))?.val,
  2548. picture=item.tmdPicture,
  2549. school=item.schoolId,
  2550. schoolName=item.schoolName,
  2551. schoolPicture=item.schoolPicture,
  2552. type=item.contest.type,
  2553. });
  2554. }
  2555. }
  2556. }
  2557. return Ok(new { code = 200, teacherScores });
  2558. }
  2559. else {
  2560. return Ok(new { code = 1, msg = "活动不存在" });
  2561. }
  2562. }
  2563. case bool when $"{grant_type}".Equals("preview-scores", StringComparison.OrdinalIgnoreCase):
  2564. {
  2565. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2566. List<ActivityScoreLevel> contestScores = await ActivityService.ActivityScores(_azureCosmos,_activityId);
  2567. return Ok(new { code = 200, contestScores });
  2568. }
  2569. }
  2570. }
  2571. catch (Exception ex)
  2572. {
  2573. await _dingDing.SendBotMsg($"{ex.Message}\n{ex.StackTrace}\n{request.ToJsonString()}", GroupNames.成都开发測試群組);
  2574. return Ok(new { code = 500, msg = ex.Message });
  2575. }
  2576. return Ok();
  2577. }
  2578. /// <summary>
  2579. /// portal站的
  2580. /// </summary>
  2581. /// <param name="request"></param>
  2582. /// <returns></returns>
  2583. [ProducesDefaultResponseType]
  2584. [HttpPost("login-portal")]
  2585. public async Task<IActionResult> LoginPortal(JsonElement request)
  2586. {
  2587. int timezone = 8;
  2588. if (HttpContext.Request.Headers.TryGetValue("Time-Zone", out var Time_Zone) && int.TryParse(Time_Zone, out int tz))
  2589. {
  2590. timezone=tz;
  2591. }
  2592. string tmdid = null;
  2593. if (!request.TryGetProperty("route", out JsonElement _route)) return BadRequest();
  2594. request.TryGetProperty("ticket", out JsonElement _ticket);
  2595. request.TryGetProperty("token", out JsonElement _token);
  2596. TeacherInfo teacherInfo = null;
  2597. object name = null, picture = null;
  2598. string head_lang = "";
  2599. (string ip, string region) = await LoginService.LoginIp(HttpContext, _searcher);
  2600. if (!string.IsNullOrWhiteSpace($"{_ticket}"))
  2601. {
  2602. var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  2603. (HttpStatusCode statusCode, CoreAPIToken token) = await _coreAPIHttpService.GetCoreAPIoAuth2Token(
  2604. new Dictionary<string, object> { { "client_id", clientID }, { "grant_type", "authorization_code" }, { "code", _ticket.GetString() } }, _option.Location, _configuration, _dingDing);
  2605. if (statusCode.Equals(HttpStatusCode.OK))
  2606. {
  2607. var jwt = new JwtSecurityToken(token.id_token);
  2608. tmdid = jwt.Payload.Sub;
  2609. if (HttpContext.Request.Headers.TryGetValue("lang", out var _lang))
  2610. {
  2611. head_lang = $"{_lang}";
  2612. }
  2613. jwt.Payload.TryGetValue("name", out name);
  2614. jwt.Payload.TryGetValue("picture", out picture);
  2615. jwt.Payload.TryGetValue("lang", out object _jwtlang);
  2616. head_lang = !string.IsNullOrWhiteSpace($"{_jwtlang}") ? $"{_jwtlang}" : head_lang;
  2617. }
  2618. }
  2619. if (tmdid == null)
  2620. {
  2621. if (!string.IsNullOrWhiteSpace($"{_token}"))
  2622. {
  2623. var jwt = new JwtSecurityToken(_token.GetString());
  2624. if (JwtAuthExtension.ValidateAuthTokenRefresh(_token.GetString(), _option.JwtSecretKey))
  2625. {
  2626. tmdid = jwt.Payload.Sub;
  2627. if (HttpContext.Request.Headers.TryGetValue("lang", out var _lang))
  2628. {
  2629. head_lang = $"{_lang}";
  2630. }
  2631. jwt.Payload.TryGetValue("name", out name);
  2632. jwt.Payload.TryGetValue("picture", out picture);
  2633. jwt.Payload.TryGetValue("lang", out object _jwtlang);
  2634. head_lang = !string.IsNullOrWhiteSpace($"{_jwtlang}") ? $"{_jwtlang}" : head_lang;
  2635. }
  2636. else { return Ok(new { code = 2, msg = "Token验证失败" }); }
  2637. }
  2638. else { return Ok(new { code = 3, msg = "凭证验证失败" }); }
  2639. }
  2640. teacherInfo = await TeacherService.TeacherInfoLite(_azureCosmos, $"{name}", $"{picture}", tmdid, _azureStorage, _option, _azureRedis, ip, _httpTrigger, head_lang,timezone);
  2641. string sql = $"select value c from c where c.route='{_route}'";
  2642. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ActivityWebsite>(sql, "ActivityWebsite");
  2643. ActivityWebsite website = null;
  2644. if (result.list.Count>1)
  2645. {
  2646. return Ok(new { code = 1, msg = "路由匹配多个区校" });
  2647. }
  2648. else
  2649. {
  2650. if (result.list.Count==1)
  2651. {
  2652. website= result.list[0];
  2653. }
  2654. }
  2655. List<string> roles = new List<string>() { "teacher" };
  2656. CoreUser coreUser = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", teacherInfo.teacher.id } }, _option.Location, _configuration);
  2657. string sqlExpert = $"select value c from c join e in c.experts where e.id='{teacherInfo.teacher.id}'";
  2658. if (!string.IsNullOrWhiteSpace(coreUser.mobile))
  2659. {
  2660. sqlExpert=$" {sqlExpert} or e.mobile='{coreUser.mobile}' ";
  2661. }
  2662. var resultActivityExpert = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpert>(sqlExpert, "ActivityExpert", pageSize: 1);
  2663. if (resultActivityExpert.list.IsNotEmpty())
  2664. {
  2665. roles.Add("expert");
  2666. }
  2667. var payload = new JwtPayload {
  2668. { JwtRegisteredClaimNames.Iss, _option.HostName }, //發行者
  2669. { JwtRegisteredClaimNames.Sub, teacherInfo.teacher.id }, // 用戶ID
  2670. { JwtRegisteredClaimNames.Exp,DateTimeOffset.UtcNow.AddHours(2).ToUnixTimeSeconds()}, // 到期的時間,必須為數字
  2671. { "name",name}, // 用戶的顯示名稱
  2672. { "picture",picture}, // 用戶頭像
  2673. { "roles", roles.ToArray()}, // 登入者的角色,角色類型 (Admin、Teacher、Student)
  2674. { JwtRegisteredClaimNames.Website,website?.route},
  2675. };
  2676. var securityKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_option.JwtSecretKey));
  2677. //var signingCredentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256Signature);
  2678. var signingCredentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256);
  2679. var header = new JwtHeader(signingCredentials);
  2680. var secToken = new JwtSecurityToken(header, payload);
  2681. // 產出所需要的 JWT securityToken 物件,並取得序列化後的 Token 結果(字串格式)
  2682. var tokenHandler = new JwtSecurityTokenHandler();
  2683. var serializeToken = tokenHandler.WriteToken(secToken);
  2684. var core_clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  2685. var core_clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
  2686. string location = _option.Location;
  2687. if (location.Contains("China"))
  2688. {
  2689. location = "China";
  2690. }
  2691. else if (location.Contains("Global"))
  2692. {
  2693. location = "Global";
  2694. }
  2695. var access_token = await CoreTokenExtensions.CreateAccessToken(core_clientID, core_clientSecret, location);
  2696. return Ok(new { auth_token = new { access_token = access_token.AccessToken, token_type = access_token.TokenType, expires_in = access_token.ExpiresOn }, code = 200, token = serializeToken, schools = teacherInfo.teacher.schools.Where(z => z.status.Equals("join")) });
  2697. }
  2698. [ProducesDefaultResponseType]
  2699. [HttpPost("get-website")]
  2700. public async Task<IActionResult> GetWebsite(JsonElement request)
  2701. {
  2702. if (!request.TryGetProperty("route", out JsonElement _route)) return BadRequest();
  2703. string sql = $"select value c from c where c.route='{_route}'";
  2704. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ActivityWebsiteDto>(sql, "ActivityWebsite");
  2705. ActivityWebsiteDto website = null;
  2706. if (result.list.Count>1)
  2707. {
  2708. return Ok(new { code = 1, msg = "路由匹配多个区校" });
  2709. }
  2710. else
  2711. {
  2712. if (result.list.Count==1)
  2713. {
  2714. website= result.list[0];
  2715. }
  2716. if (result.list.Count==0) {
  2717. try {
  2718. ResponseMessage responseSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemStreamAsync($"{_route}", new PartitionKey("Base"));
  2719. if (responseSchool.StatusCode==System.Net.HttpStatusCode.OK)
  2720. {
  2721. ActivityWebsite websiteDB = new ActivityWebsite
  2722. {
  2723. id=$"{_route}",
  2724. pk="ActivityWebsite",
  2725. code="ActivityWebsite",
  2726. route=$"{_route}",
  2727. scope="school",
  2728. allowPublic=0,
  2729. };
  2730. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).UpsertItemAsync(websiteDB, new PartitionKey(websiteDB.code));
  2731. website=new ActivityWebsiteDto(websiteDB);
  2732. }
  2733. } catch (Exception ex ) { }
  2734. }
  2735. }
  2736. if (website!= null)
  2737. {
  2738. List<ActivityWebsiteDto> websites = new List<ActivityWebsiteDto>();
  2739. if (website.route.Equals("teammodel"))
  2740. {
  2741. string sqlAll = $"select value c from c where IS_DEFINED(c.route) = true and c.route<> null and c.route<>'' ";
  2742. var resultAll = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ActivityWebsiteDto>(sqlAll, "ActivityWebsite");
  2743. websites=resultAll.list;
  2744. }
  2745. websites.ForEach(z => {
  2746. string cnt = z.id;
  2747. if (z.id.Equals("teammodel"))
  2748. {
  2749. cnt="02944f32-f534-3397-ea56-e6f1fc6c3714";
  2750. }
  2751. var it = _azureStorage.GetBlobContainerSAS(cnt, BlobContainerSasPermissions.Read);
  2752. z.sas= it.sas;
  2753. z.url=it.uri;
  2754. });
  2755. string cnt = website.id;
  2756. if (website.id.Equals("teammodel"))
  2757. {
  2758. cnt="02944f32-f534-3397-ea56-e6f1fc6c3714";
  2759. }
  2760. var blob = _azureStorage.GetBlobContainerSAS(cnt, BlobContainerSasPermissions.Read);
  2761. website.sas= blob.sas;
  2762. website.url=blob.uri;
  2763. string blobUrl = blob.uri;
  2764. return Ok(new { code = 200, website, websites, blobUrl });
  2765. }
  2766. else
  2767. {
  2768. return Ok(new { code = 2, msg = "未匹配分站" });
  2769. }
  2770. }
  2771. /// <summary>
  2772. ///
  2773. /// </summary>
  2774. /// <param name="request"></param>
  2775. /// <returns></returns>
  2776. [ProducesDefaultResponseType]
  2777. [HttpPost("read-activity")]
  2778. public async Task<IActionResult> ReadActivity(JsonElement request)
  2779. {
  2780. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2781. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  2782. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  2783. {
  2784. ActivityDto activity = JsonDocument.Parse(response.Content).RootElement.ToObject<ActivityDto>();
  2785. if (activity.publish!=1 && activity.publish!=2)
  2786. {
  2787. return Ok(new { code = 1, msg = "活动未发布!" });
  2788. }
  2789. Contest contest = null;
  2790. ReviewRuleTree reviewRule = null;
  2791. ResponseMessage responseContest = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2792. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  2793. {
  2794. contest= JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  2795. if (contest.modules.Contains("review"))
  2796. {
  2797. ResponseMessage reviewRuleResponse = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("ReviewRule-disposable"));
  2798. if (reviewRuleResponse.StatusCode==System.Net.HttpStatusCode.OK)
  2799. {
  2800. ReviewRule reviewRuleDB = JsonDocument.Parse(reviewRuleResponse.Content).RootElement.ToObject<ReviewRule>();
  2801. var tree = ActivityService.ListToTree(reviewRuleDB.configs);
  2802. reviewRule=new ReviewRuleTree
  2803. {
  2804. id=reviewRuleDB.id,
  2805. name= reviewRuleDB.name,
  2806. owner= reviewRuleDB.owner,
  2807. sourceName= reviewRuleDB.sourceName,
  2808. trees=tree,
  2809. desc=reviewRuleDB.desc,
  2810. scoreDetail=reviewRuleDB.scoreDetail,
  2811. scoreRule=reviewRuleDB.scoreRule,
  2812. distribute=reviewRuleDB.distribute,
  2813. taskCount=reviewRuleDB.taskCount,
  2814. };
  2815. }
  2816. }
  2817. }
  2818. Training training = null;
  2819. TEAMModelOS.SDK.Models.Research research = null;
  2820. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(activity.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  2821. activity.sas=blob_sas;
  2822. activity.url=blob_uri;
  2823. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2824. activity.publish=now>activity.etime ? 2 : activity.publish;
  2825. List<ActivityScoreLevel> contestScores = null;
  2826. if (contest.score!=null && contest.score.scoreStatus==1 && now>contest.score?.stime && now<contest.score.etime)
  2827. {
  2828. contestScores = await ActivityService.ActivityScores(_azureCosmos, _activityId);
  2829. }
  2830. return Ok(new { code = 200, activity, contest, reviewRule, training, research, contestScores });
  2831. }
  2832. else
  2833. {
  2834. return Ok(new { code = 2, msg = "活动不存在" });
  2835. }
  2836. }
  2837. /// <summary>
  2838. /// 获取活动的站点
  2839. /// </summary>
  2840. /// <param name="request"></param>
  2841. /// <returns></returns>
  2842. [ProducesDefaultResponseType]
  2843. [HttpPost("get-activity-website")]
  2844. public async Task<IActionResult> GetActivityWebsite(JsonElement request)
  2845. {
  2846. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2847. ResponseMessage response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  2848. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  2849. {
  2850. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  2851. if (activity.publish!=1 && activity.publish!=2)
  2852. {
  2853. return Ok(new { code = 1, msg = "活动未发布!" });
  2854. }
  2855. string routeId = "";
  2856. if (activity.scope.Equals("public"))
  2857. {
  2858. routeId="";
  2859. }
  2860. else
  2861. {
  2862. routeId=activity.owner;
  2863. }
  2864. ResponseMessage responseActivityWebsite = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(routeId, new PartitionKey("ActivityWebsite"));
  2865. ActivityWebsiteDto website = null;
  2866. if (responseActivityWebsite.StatusCode==System.Net.HttpStatusCode.OK)
  2867. {
  2868. website=JsonDocument.Parse(responseActivityWebsite.Content).RootElement.ToObject<ActivityWebsiteDto>();
  2869. }
  2870. if (website!= null)
  2871. {
  2872. string cnt = website.id;
  2873. if (website.id.Equals("teammodel"))
  2874. {
  2875. cnt="02944f32-f534-3397-ea56-e6f1fc6c3714";
  2876. }
  2877. var blob = _azureStorage.GetBlobContainerSAS(cnt, BlobContainerSasPermissions.Read);
  2878. website.sas= blob.sas;
  2879. website.url=blob.uri;
  2880. return Ok(new { code = 200, website });
  2881. }
  2882. else
  2883. {
  2884. return Ok(new { code = 2, msg = "未匹配分站" });
  2885. }
  2886. }
  2887. else
  2888. {
  2889. return Ok(new { code = 3, msg = "活动不存在" });
  2890. }
  2891. }
  2892. /// <summary>
  2893. /// 教师在赛课模块的操作
  2894. /// </summary>
  2895. /// <param name="request"></param>
  2896. /// <returns></returns>
  2897. [ProducesDefaultResponseType]
  2898. [HttpPost("expert-contest")]
  2899. [AuthToken(Roles = "expert")]
  2900. #if !DEBUG
  2901. [Authorize(Roles = "IES")]
  2902. #endif
  2903. public async Task<IActionResult> ExpertContest(JsonElement request)
  2904. {
  2905. (string tmdid, string name, string picture, _) = HttpContext.GetAuthTokenInfo();
  2906. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  2907. var client = _azureCosmos.GetCosmosClient();
  2908. switch (true)
  2909. { //获取分配的任务
  2910. case bool when $"{grant_type}".Equals("get-enroll-by-uploadId", StringComparison.OrdinalIgnoreCase):
  2911. {
  2912. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2913. if (!request.TryGetProperty("uploadId", out JsonElement _uploadId)) return BadRequest();
  2914. string enrollSQL = $"select value c from c where c.activityId='{_activityId.GetString()}' and c.upload.uploadId='{_uploadId}' ";
  2915. //不是自己的,且学校不为空,则查询指定学校的,否则获取所有报名的数据
  2916. var enrollResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{_activityId}");
  2917. EnrollUpload upload = null;
  2918. if (enrollResult.list.IsNotEmpty()) {
  2919. upload= enrollResult.list[0].upload;
  2920. }
  2921. return Ok(new { upload });
  2922. }
  2923. //获取分配的任务
  2924. case bool when $"{grant_type}".Equals("list-task", StringComparison.OrdinalIgnoreCase):
  2925. {
  2926. List<ActivityExpertDto> activities = new List<ActivityExpertDto>();
  2927. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2928. //在时间内正在进入评审阶段的活动。
  2929. string contestSQL = $"select value c from c where c.review.stime<={now} and c.review.etime>={now} and c.review.reviewStatus=1";
  2930. var contestResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<Contest>(contestSQL, "Contest");
  2931. if (contestResult.list.IsNotEmpty())
  2932. {
  2933. string baseSQL = $"select value c from c where c.id in ({string.Join(",", contestResult.list.Select(z => $"'{z.id}'"))}) ";
  2934. var activityResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<Activity>(baseSQL, "Activity");
  2935. string sql = $"select value c from c where c.activityId in ({string.Join(",", contestResult.list.Select(z => $"'{z.id}'"))}) and c.id='{tmdid}' and c.pk='ActivityExpertTask'";
  2936. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(sql);
  2937. foreach (var item in result.list)
  2938. {
  2939. var contest = contestResult.list.Find(z => z.id.Equals(item.activityId));
  2940. var activity = activityResult.list.Find(z => z.id.Equals(item.activityId));
  2941. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(activity.owner, BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
  2942. activities.Add(new ActivityExpertDto
  2943. {
  2944. activityId=item.activityId,
  2945. activityName=activity?.name,
  2946. stime=contest?.review?.stime??0,
  2947. etime=contest?.review?.etime??0,
  2948. taskCount=item.contestTasks.Count(),
  2949. completeCount=item.contestTasks.Where(z => z.status==1).Count(),
  2950. contestTasks=item.contestTasks,
  2951. sas=blob_sas,
  2952. url=blob_uri
  2953. }) ;
  2954. }
  2955. }
  2956. return Ok(new { activities,code=200 });
  2957. }
  2958. ///评分
  2959. case bool when $"{grant_type}".Equals("decide-score", StringComparison.OrdinalIgnoreCase):
  2960. {
  2961. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  2962. if (!request.TryGetProperty("scoreData", out JsonElement _scoreData)) return BadRequest();
  2963. ResponseMessage response = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  2964. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  2965. {
  2966. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  2967. Contest contest = JsonDocument.Parse(response.Content).RootElement.ToObject<Contest>();
  2968. if (contest.review!= null &&contest.review.stime<now &&contest.review.etime>now)
  2969. {
  2970. if (contest.review.reviewStatus==1)
  2971. {
  2972. //作品安分配次数,如果分数全部打完成,自动汇算
  2973. ReviewScoreData scoreData= _scoreData.ToObject<ReviewScoreData>();
  2974. var ruleResponse= await client.GetContainer(Constant.TEAMModelOS, Constant.Normal).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("ReviewRule-disposable"));
  2975. ReviewRule reviewRule = JsonDocument.Parse(ruleResponse.Content).RootElement.ToObject<ReviewRule>();
  2976. if (reviewRule.scoreDetail==1) {
  2977. if (!scoreData.detailScore.IsNotEmpty())
  2978. {
  2979. return Ok(new { code = 5, msg = "需要进行细项评分!" });
  2980. }
  2981. }
  2982. if (scoreData.score<0) {
  2983. return Ok(new { code = 6, msg = "分数不能小于0!" });
  2984. }
  2985. if (!string.IsNullOrWhiteSpace(scoreData.uploadId))
  2986. {
  2987. ActivityExpertTask expertTask = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<ActivityExpertTask>(tmdid, new PartitionKey($"ActivityExpertTask-{_activityId}"));
  2988. var task = expertTask.contestTasks.Find(x => x.uploadId.Equals(scoreData.uploadId));
  2989. task.score = scoreData.score;
  2990. task.status=1;
  2991. task.comment=scoreData.comment;
  2992. task.detailScore = ActivityService.TreeToList(scoreData.detailScore, new List<RuleConfig>()) ;
  2993. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(expertTask, new PartitionKey($"ActivityExpertTask-{_activityId}"));
  2994. //检查作品是否完成评审自动结算
  2995. {
  2996. string sql = $"select distinct value c from c join b in c.contestTasks where c.activityId='{_activityId}' and b.uploadId='{scoreData.uploadId}'";
  2997. var uploadAllResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(sql, $"ActivityExpertTask-{_activityId}");
  2998. if (uploadAllResult.list.IsNotEmpty())
  2999. {
  3000. var unfinish = uploadAllResult.list.SelectMany(x=>x.contestTasks).Where(z => z.status!=1 && z.uploadId.Equals(scoreData.uploadId));
  3001. if (!(unfinish!=null && unfinish.Count()>0)) {
  3002. //没有未完成的评审作品自动结算、
  3003. string enrollSQL =$"select value c from c where c.upload.uploadId='{scoreData.uploadId}'and c.pk ='ActivityEnroll' ";
  3004. var enrollResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(enrollSQL, $"ActivityEnroll-{_activityId}");
  3005. foreach (var item in enrollResult.list)
  3006. {
  3007. bool change = false;
  3008. List<ExpertUploadScore> expertScores= new List<ExpertUploadScore>();
  3009. foreach (var expertScore in uploadAllResult.list)
  3010. {
  3011. var taskScore = expertScore.contestTasks.Find(z => z.uploadId.Equals(item.upload.uploadId));
  3012. if (taskScore!= null) {
  3013. expertScores.Add(new ExpertUploadScore {
  3014. id= expertScore.id,
  3015. name=expertScore.name,
  3016. score=taskScore.score,
  3017. detailScore=taskScore.detailScore
  3018. });
  3019. }
  3020. }
  3021. switch (reviewRule.scoreRule)
  3022. {
  3023. case "only":
  3024. if (expertScores.IsNotEmpty() && expertScores.Count==1)
  3025. {
  3026. item.upload.score= expertScores.First().score;
  3027. change=true;
  3028. }
  3029. break;
  3030. case "avg":
  3031. if (expertScores.IsNotEmpty() && expertScores.Count>=2)
  3032. {
  3033. item.upload.score= expertScores.Average(z => z.score);
  3034. change=true;
  3035. }
  3036. break;
  3037. case "top":
  3038. if (expertScores.IsNotEmpty() && expertScores.Count>2) {
  3039. item.upload.score= expertScores.Max(z => z.score);
  3040. change=true;
  3041. }
  3042. break;
  3043. case "rmLowAvg":
  3044. if (expertScores.IsNotEmpty() && expertScores.Count>=3)
  3045. {
  3046. expertScores.Remove(expertScores.Min());
  3047. if (expertScores.IsNotEmpty()) {
  3048. item.upload.score= expertScores.Average(z => z.score);
  3049. change=true;
  3050. }
  3051. }
  3052. break;
  3053. case "rmTopAvg":
  3054. if (expertScores.IsNotEmpty() && expertScores.Count>=3)
  3055. {
  3056. expertScores.Remove(expertScores.Max());
  3057. if (expertScores.IsNotEmpty())
  3058. {
  3059. item.upload.score= expertScores.Average(z => z.score);
  3060. change=true;
  3061. }
  3062. }
  3063. break;
  3064. case "rmLowTopAvg":
  3065. if (expertScores.IsNotEmpty() && expertScores.Count>=4)
  3066. {
  3067. expertScores.Remove(expertScores.Max());
  3068. expertScores.Remove(expertScores.Min());
  3069. if (expertScores.IsNotEmpty())
  3070. {
  3071. item.upload.score= expertScores.Average(z => z.score);
  3072. change=true;
  3073. }
  3074. }
  3075. break;
  3076. }
  3077. if (change)
  3078. {
  3079. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(item, new PartitionKey($"ActivityEnroll-{_activityId}"));
  3080. }
  3081. }
  3082. }
  3083. }
  3084. }
  3085. return Ok(new { code = 200, completeCount = expertTask.contestTasks.Where(z => z.status==1).Count(), contestTasks = expertTask.contestTasks });
  3086. }
  3087. else
  3088. {
  3089. return Ok(new { code = 4, msg = "参数错误!" });
  3090. }
  3091. }
  3092. else
  3093. {
  3094. return Ok(new { code = 2, msg = "评审已关闭!" });
  3095. }
  3096. }
  3097. else
  3098. {
  3099. return Ok(new { code = 1, msg = "已过评审时间!" });
  3100. }
  3101. }
  3102. else {
  3103. return Ok(new { code = 3, msg = "活动不存在!" });
  3104. }
  3105. }
  3106. }
  3107. return Ok();
  3108. }
  3109. /// <summary>
  3110. /// 教师在赛课模块的操作
  3111. /// </summary>
  3112. /// <param name="request"></param>
  3113. /// <returns></returns>
  3114. [ProducesDefaultResponseType]
  3115. [HttpPost("teacher-contest")]
  3116. [AuthToken(Roles = "teacher")]
  3117. #if !DEBUG
  3118. [Authorize(Roles = "IES")]
  3119. #endif
  3120. public async Task<IActionResult> TeacherContest(JsonElement request)
  3121. {
  3122. (string tmdid, string name, string picture, _) = HttpContext.GetAuthTokenInfo();
  3123. if (!request.TryGetProperty("grant_type", out JsonElement grant_type)) return BadRequest();
  3124. if ($"{grant_type}".Equals("update-teacher-enroll"))
  3125. {
  3126. if (!request.TryGetProperty("teacherEnroll", out JsonElement _teacherEnroll))
  3127. {
  3128. return Ok(new { code = 0, msg = "报名信息未完善!" });
  3129. };
  3130. TeacherEnroll teacherEnroll = _teacherEnroll.ToObject<TeacherEnroll>();
  3131. teacherEnroll.id=tmdid;
  3132. teacherEnroll.code="TeacherEnroll";
  3133. teacherEnroll.pk="TeacherEnroll";
  3134. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(teacherEnroll, new PartitionKey("TeacherEnroll"));
  3135. return Ok(new { code = 200, teacherEnroll });
  3136. }
  3137. if ($"{grant_type}".Equals("get-teacher-enroll"))
  3138. {
  3139. TeacherEnroll teacherEnroll = null;
  3140. ResponseMessage responseTeacherEnroll= await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey("TeacherEnroll"));
  3141. if (responseTeacherEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3142. {
  3143. teacherEnroll= JsonDocument.Parse(responseTeacherEnroll.Content).RootElement.ToObject<TeacherEnroll>();
  3144. return Ok(new { code = 200, teacherEnroll });
  3145. }
  3146. else {
  3147. return Ok(new { code = 1, msg="未填写" });
  3148. }
  3149. }
  3150. if (!request.TryGetProperty("activityId", out JsonElement _activityId)) return BadRequest();
  3151. var client = _azureCosmos.GetCosmosClient();
  3152. ResponseMessage response = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Activity"));
  3153. ResponseMessage responseContest = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  3154. try
  3155. {
  3156. if (response.StatusCode==System.Net.HttpStatusCode.OK)
  3157. {
  3158. int code = -1;
  3159. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  3160. Activity activity = JsonDocument.Parse(response.Content).RootElement.ToObject<Activity>();
  3161. Contest contest = null;
  3162. if (responseContest.StatusCode==System.Net.HttpStatusCode.OK)
  3163. {
  3164. contest=JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  3165. }
  3166. else
  3167. {
  3168. return Ok(new { code = 33, msg = "未设置赛课模块!" });
  3169. }
  3170. if (!activity.modules.Contains("Contest"))
  3171. {
  3172. return Ok(new { code = 33, msg = "未设置赛课模块!" });
  3173. }
  3174. if (activity.publish>=1)
  3175. {
  3176. //如果包含了评审模块
  3177. if (contest.modules.Contains("review"))
  3178. {
  3179. if (contest.review!=null)
  3180. {
  3181. if (now>= contest.review?.stime && !$"{grant_type}".Equals("get-enroll", StringComparison.OrdinalIgnoreCase))
  3182. {
  3183. //只能查看报名信息
  3184. return Ok(new { code = 35, msg = "已到截至日期,不能操作!" });
  3185. }
  3186. }
  3187. else
  3188. {
  3189. return Ok(new { code = 34, msg = "评审模块信息未完善!" });
  3190. }
  3191. }
  3192. switch (true)
  3193. {
  3194. //移除队员
  3195. case bool when $"{grant_type}".Equals("remove-member", StringComparison.OrdinalIgnoreCase):
  3196. {
  3197. if (!request.TryGetProperty("removeMember", out JsonElement _removeMember)) return BadRequest();
  3198. if (tmdid.Equals(_removeMember.GetString()))
  3199. {
  3200. return Ok(new { code = 5, msg = "不能移除自己!" });
  3201. }
  3202. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3203. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3204. {
  3205. ActivityEnroll enrollOld = JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3206. if (enrollOld!=null && enrollOld?.contest?.leader==1 && enrollOld?.contest?.type==1)
  3207. {
  3208. ResponseMessage responseActivityEnrollRemove = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(_removeMember.GetString(), new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3209. if (responseActivityEnrollRemove.StatusCode==System.Net.HttpStatusCode.OK)
  3210. {
  3211. ActivityEnroll enrollRemove = JsonDocument.Parse(responseActivityEnrollRemove.Content).RootElement.ToObject<ActivityEnroll>();
  3212. if (enrollRemove!=null && enrollRemove?.contest!=null && enrollOld?.contest?.type==1)
  3213. {
  3214. if (enrollOld.contest.cipher.Equals(enrollRemove.contest.cipher))
  3215. {
  3216. enrollRemove.contest.cipher=null;
  3217. //string cipher = await ActivityService.GenCipher(client, _dingDing, _option, _activityId.GetString());
  3218. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enrollRemove, new PartitionKey(enrollRemove.code));
  3219. return Ok(new { code = 200, msg = "移除成功!" });
  3220. }
  3221. else
  3222. {
  3223. return Ok(new { code = 4, msg = "指定的队长不是同一团队人员!" });
  3224. }
  3225. }
  3226. else
  3227. {
  3228. return Ok(new { code = 3, msg = "指定的队长未参加本次活动!" });
  3229. }
  3230. }
  3231. else
  3232. {
  3233. return Ok(new { code = 3, msg = "指定的队长未参加本次活动!" });
  3234. }
  3235. }
  3236. else
  3237. {
  3238. return Ok(new { code = 1, msg = "你不是队长!" });
  3239. }
  3240. }
  3241. else
  3242. {
  3243. return Ok(new { code = 2, msg = "你未参加本次活动!" });
  3244. }
  3245. }
  3246. ///移交队长
  3247. case bool when $"{grant_type}".Equals("change-team-leader", StringComparison.OrdinalIgnoreCase):
  3248. {
  3249. if (!request.TryGetProperty("targetLeader", out JsonElement _targetLeader)) return BadRequest();
  3250. if (tmdid.Equals(_targetLeader.GetString()))
  3251. {
  3252. return Ok(new { code = 5, msg = "不能将队长移交给自己!" });
  3253. }
  3254. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3255. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3256. {
  3257. ActivityEnroll enrollOld = JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3258. if (enrollOld!=null && enrollOld?.contest?.leader==1 && enrollOld?.contest?.type==1)
  3259. {
  3260. ResponseMessage responseActivityEnrollNew = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(_targetLeader.GetString(), new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3261. if (responseActivityEnrollNew.StatusCode==System.Net.HttpStatusCode.OK)
  3262. {
  3263. ActivityEnroll enrollNew = JsonDocument.Parse(responseActivityEnrollNew.Content).RootElement.ToObject<ActivityEnroll>();
  3264. if (enrollNew!=null && enrollNew?.contest!=null && enrollOld?.contest?.type==1)
  3265. {
  3266. if (enrollOld.contest.cipher.Equals(enrollNew.contest.cipher))
  3267. {
  3268. enrollOld.contest.leader=0;
  3269. enrollNew.contest.leader=1;
  3270. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enrollNew, new PartitionKey(enrollNew.code));
  3271. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enrollOld, new PartitionKey(enrollOld.code));
  3272. return Ok(new { code = 200, msg = "移交成功!" });
  3273. }
  3274. else
  3275. {
  3276. return Ok(new { code = 4, msg = "指定的队长不是同一团队人员!" });
  3277. }
  3278. }
  3279. else
  3280. {
  3281. return Ok(new { code = 3, msg = "指定的队长未参加本次活动!" });
  3282. }
  3283. }
  3284. else
  3285. {
  3286. return Ok(new { code = 3, msg = "指定的队长未参加本次活动!" });
  3287. }
  3288. }
  3289. else
  3290. {
  3291. return Ok(new { code = 1, msg = "你不是队长!" });
  3292. }
  3293. }
  3294. else
  3295. {
  3296. return Ok(new { code = 2, msg = "你未参加本次活动!" });
  3297. }
  3298. }
  3299. ///取消报名
  3300. case bool when $"{grant_type}".Equals("cancel-enroll", StringComparison.OrdinalIgnoreCase):
  3301. {
  3302. ActivityEnroll enroll = null;
  3303. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3304. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3305. {
  3306. enroll= JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3307. if (enroll.contest!=null && enroll.contest.leader==1)
  3308. {
  3309. // 如果没有其他队员,则可以直接退出
  3310. //检查是否还有其他成员
  3311. string cipherSQL = $"select value c.id from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enroll.contest.cipher}' and c.id<>'{tmdid}' ";
  3312. var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<string>(cipherSQL, $"ActivityEnroll-{_activityId}");
  3313. if (cipherResult.list.Count>0)
  3314. {
  3315. return Ok(new { code = 3, msg = "队伍中还有其他参赛队员,请移交队长后或移除队员后再退出参赛!" });
  3316. }
  3317. }
  3318. ResponseMessage responseActivityEnrollDel = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemStreamAsync(enroll.id, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3319. if (activity.joinMode.Equals("invite"))
  3320. {
  3321. string sqlInvite = $"select value c from c join t in c.inviteTeachers where t.id='{tmdid}' and c.pk='ActivityTeacher'";
  3322. var activityTeacherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityTeacher>(sqlInvite, $"ActivityTeacher-{_activityId}");
  3323. foreach (var activityTeacher in activityTeacherResult.list)
  3324. {
  3325. activityTeacher.inviteTeachers.ForEach(z =>
  3326. {
  3327. if (z.id.Equals(tmdid))
  3328. {
  3329. z.status=0;
  3330. }
  3331. });
  3332. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityTeacher, new PartitionKey($"ActivityTeacher-{_activityId}"));
  3333. }
  3334. }
  3335. //已分配作品,强制删除。
  3336. if (!string.IsNullOrWhiteSpace(enroll.upload?.uploadId))
  3337. {
  3338. string sql = $"select value c from c join t in c.contestTasks where t.uploadId='{enroll.upload.uploadId}' and c.pk='ActivityExpertTask' ";
  3339. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(sql, $"ActivityExpertTask-{_activityId}");
  3340. if (result.list.IsNotEmpty())
  3341. {
  3342. foreach (var activityExpertTask in result.list)
  3343. {
  3344. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).DeleteItemStreamAsync(activityExpertTask.id, new PartitionKey(activityExpertTask.code));
  3345. }
  3346. }
  3347. }
  3348. if (responseActivityEnrollDel.Status==204)
  3349. {
  3350. return Ok(new { code = 204, msg = "退出成功!" });
  3351. }
  3352. else
  3353. {
  3354. return Ok(new { code = 2, msg = "退出失败!" });
  3355. }
  3356. }
  3357. return Ok(new { code = 1, msg = "暂无报名数据!", });
  3358. }
  3359. ///获取报名
  3360. case bool when $"{grant_type}".Equals("get-enroll", StringComparison.OrdinalIgnoreCase):
  3361. {
  3362. ActivityEnroll enroll = null;
  3363. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3364. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3365. {
  3366. //更新邀请状态
  3367. if (activity.joinMode.Equals("invite"))
  3368. {
  3369. string sqlInvite = $"select value c from c join t in c.inviteTeachers where t.id='{tmdid}' and c.pk='ActivityTeacher' and t.status=0 ";
  3370. var activityTeacherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityTeacher>(sqlInvite, $"ActivityTeacher-{_activityId}");
  3371. foreach (var activityTeacher in activityTeacherResult.list)
  3372. {
  3373. activityTeacher.inviteTeachers.ForEach(z =>
  3374. {
  3375. if (z.id.Equals(tmdid))
  3376. {
  3377. z.status=1;
  3378. }
  3379. });
  3380. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityTeacher, new PartitionKey($"ActivityTeacher-{_activityId}"));
  3381. }
  3382. }
  3383. enroll= JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3384. double score = -1;
  3385. int levelStatus = -1;
  3386. string scoreLevel = string.Empty;
  3387. int showType = -1;
  3388. //是否已经分配作品 0未分配 1 已分配
  3389. int allotStatus = 0;
  3390. List<dynamic> detailScore = new List<dynamic>();
  3391. if (contest.score!=null && contest.score.scoreStatus==1 && now>contest.score?.stime && now<contest.score.etime && enroll.upload!=null)
  3392. {
  3393. score=enroll.upload.score;
  3394. if (enroll.upload.showScore==1) {
  3395. score=enroll.upload.maskScore;
  3396. }
  3397. List<ActivityScoreLevel> contestScores = await ActivityService.ActivityScores(_azureCosmos, _activityId, enroll.id);
  3398. var levels = contestScores.SelectMany(x => x.scores).Where(x => x.tmdid.Equals(enroll.id));
  3399. ActivityTeacherScoreLevel level = null;
  3400. if (level!=null && levels.Count()>0)
  3401. {
  3402. level=levels.First();
  3403. levelStatus=1;
  3404. scoreLevel=level.scoreLevel;
  3405. score= level.score;
  3406. }
  3407. else {
  3408. levelStatus=0;
  3409. }
  3410. showType=contest.score.showType;
  3411. }
  3412. if (!string.IsNullOrWhiteSpace(enroll.upload?.uploadId))
  3413. {
  3414. string sql = $"select value c from c join t in c.contestTasks where t.uploadId='{enroll.upload.uploadId}' and c.pk='ActivityExpertTask' ";
  3415. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityExpertTask>(sql, $"ActivityExpertTask-{_activityId}");
  3416. if (result.list.IsNotEmpty())
  3417. {
  3418. if (contest.score!=null && contest.score.showDetail==1)
  3419. {
  3420. result.list.ForEach(x => {
  3421. var upload = x.contestTasks.Find(z => z.uploadId.Equals(enroll.upload.uploadId));
  3422. if (upload!= null)
  3423. {
  3424. detailScore.Add(new { upload.detailScore, x.id, name = "***" });
  3425. }
  3426. });
  3427. }
  3428. allotStatus=1;
  3429. }
  3430. }
  3431. if (enroll.upload!=null) {
  3432. enroll.upload.score=-1;
  3433. enroll.upload.maskScore=-1;
  3434. }
  3435. return Ok(new { code = 200, enroll,scoreData=new { allotStatus, levelStatus , score, scoreLevel, showType, detailScore } });
  3436. }
  3437. return Ok(new { code = 1, msg = "暂无报名数据!", });
  3438. }
  3439. //生成组队口令
  3440. case bool when $"{grant_type}".Equals("gen-cipher", StringComparison.OrdinalIgnoreCase):
  3441. {
  3442. //ResponseMessage responseContest = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  3443. //if (responseContest.Status==200 && activity.modules.Contains("Contest"))
  3444. //{
  3445. // Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  3446. //}
  3447. if (contest.modules.Contains("sign") && contest.sign!=null && contest.sign.type==1)
  3448. {
  3449. string cipher = await ActivityService.GenCipher(client, _dingDing, _option, _activityId.GetString());
  3450. return Ok(new { code = 200, cipher });
  3451. }
  3452. return Ok(new { code = 1, msg = "组队口令生成失败!" });
  3453. }
  3454. //根据口令获取团队和队员信息
  3455. case bool when $"{grant_type}".Equals("search-team-by-cipher", StringComparison.OrdinalIgnoreCase):
  3456. {
  3457. if (!request.TryGetProperty("cipher", out JsonElement _cipher)) return BadRequest();
  3458. //ResponseMessage responseContest = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  3459. //if (responseContest.Status==200 && activity.modules.Contains("Contest"))
  3460. //{
  3461. // Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  3462. //}
  3463. if (contest.modules.Contains("sign") && contest.sign!=null && contest.sign.type==1)
  3464. {
  3465. string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId}' and c.contest.type=1 and c.contest.cipher='{_cipher}' ";
  3466. var cipherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  3467. List<TeacherEnrollContestDto> teamMembers = new List<TeacherEnrollContestDto>();
  3468. teamMembers= cipherResult.list.Select(z => new TeacherEnrollContestDto
  3469. {
  3470. tmdid= z.id,
  3471. tmdPicture= z.tmdPicture,
  3472. tmdName= z.tmdName,
  3473. schoolName=z.schoolName,
  3474. schoolPicture= z.schoolPicture,
  3475. schoolId= z.schoolId,
  3476. cipher= z.contest.cipher,
  3477. enrollTime= z.contest.enrollTime,
  3478. leader= z.contest.leader,
  3479. teamName= z.contest.teamName,
  3480. type=z.contest.type,
  3481. enrollInfos= z.contest.enrollInfos
  3482. }).ToList();
  3483. return Ok(new
  3484. {
  3485. code = 200,
  3486. teamMembers = teamMembers.Select(z => new
  3487. {
  3488. z.tmdid,
  3489. z.tmdPicture,
  3490. z.tmdName,
  3491. z.schoolName,
  3492. z.schoolPicture,
  3493. z.schoolId,
  3494. z.cipher,
  3495. z.enrollTime,
  3496. z.leader,
  3497. z.teamName,
  3498. z.type,
  3499. z.enrollInfos
  3500. })
  3501. });
  3502. }
  3503. return Ok(new { code = 1, msg = "未找到团队!" });
  3504. }
  3505. //教师报名参加
  3506. case bool when $"{grant_type}".Equals("sign-contest", StringComparison.OrdinalIgnoreCase):
  3507. {
  3508. request.TryGetProperty("mock", out JsonElement _mock);
  3509. if (!request.TryGetProperty("enrollData", out JsonElement _enrollData))
  3510. {
  3511. return Ok(new { code = 0, msg = "报名信息未完善!" });
  3512. };
  3513. TeacherEnrollContestDto enrollData = _enrollData.ToObject<TeacherEnrollContestDto>();
  3514. if (!string.IsNullOrWhiteSpace($"{_mock}")) {
  3515. tmdid= enrollData.tmdid;
  3516. }
  3517. ActivityEnroll enroll = null;
  3518. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3519. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3520. {
  3521. enroll= JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3522. }
  3523. //邀请制
  3524. List<ActivityTeacher> activityTeachers = new List<ActivityTeacher>();
  3525. if (activity.joinMode.Equals("invite"))
  3526. {
  3527. string sqlInvite = $"select value c from c join t in c.inviteTeachers where t.id='{tmdid}' and c.pk='ActivityTeacher'";
  3528. var activityTeacherResult = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityTeacher>(sqlInvite, $"ActivityTeacher-{_activityId}");
  3529. if (activityTeacherResult.list.IsNotEmpty())
  3530. {
  3531. activityTeachers.AddRange(activityTeacherResult.list);
  3532. var exsit = activityTeacherResult.list.Exists(z => z.id.Equals(enrollData.schoolId));
  3533. if (!exsit)
  3534. {
  3535. code=16;
  3536. return Ok(new { code, msg = "填报的学校与邀请的学校不一致!" });
  3537. }
  3538. else
  3539. {
  3540. code=200;
  3541. }
  3542. }
  3543. else
  3544. {
  3545. code=1;
  3546. return Ok(new { code, msg = "教师未被邀请" });
  3547. }
  3548. }
  3549. //如果邀请制没有检查通过,则检查其他模式
  3550. if (code!=200)
  3551. {
  3552. //如果是 活动主办方设置了 部分学校参加(包含区级以及公开,选择了学校的)
  3553. if (activity.invitedSchools.IsNotEmpty() && activity.confirmedSchools.IsNotEmpty())
  3554. {
  3555. if (!string.IsNullOrWhiteSpace(enrollData.schoolId))
  3556. {
  3557. if (!activity.invitedSchools.Exists(z => z.id.Equals(enrollData.schoolId)))
  3558. {
  3559. return Ok(new { code = 3, msg = "学校未被邀请参与本次活动!" });
  3560. }
  3561. if (!activity.confirmedSchools.Exists(z => z.id.Equals(enrollData.schoolId) && z.status==1))
  3562. {
  3563. return Ok(new { code = 4, msg = "学校未确认参与本次活动!" });
  3564. }
  3565. code=200;
  3566. }
  3567. else
  3568. {
  3569. return Ok(new { code = 2, msg = "请以学校教师身份参加本次活动!" });
  3570. }
  3571. }
  3572. //完全开放的
  3573. else if (activity.scope.Equals("public") && activity.invitedSchools.IsEmpty())
  3574. {
  3575. code=200;
  3576. }
  3577. else if (activity.scope.Equals("school"))
  3578. {
  3579. if (!string.IsNullOrWhiteSpace(enrollData.schoolId))
  3580. {
  3581. if (activity.owner.Equals(enrollData.schoolId))
  3582. {
  3583. code=200;
  3584. }
  3585. else
  3586. {
  3587. return Ok(new { code = 5, msg = "不是本校的教师不能参加本次活动!" });
  3588. }
  3589. }
  3590. else { return Ok(new { code = 2, msg = "请以学校教师身份参加本次活动!" }); }
  3591. }
  3592. else if (activity.scope.Equals("area") && activity.confirmedSchools.IsNotEmpty()) {
  3593. if (!string.IsNullOrWhiteSpace(enrollData.schoolId))
  3594. {
  3595. if (!activity.confirmedSchools.Exists(z => z.id.Equals(enrollData.schoolId) && z.status==1))
  3596. {
  3597. return Ok(new { code = 4, msg = "学校未确认参与本次活动!" });
  3598. }
  3599. else {
  3600. code=200;
  3601. }
  3602. }
  3603. else { return Ok(new { code = 2, msg = "请以学校教师身份参加本次活动!" }); }
  3604. }
  3605. else
  3606. {
  3607. await _dingDing.SendBotMsg($"{_option.Location},活动类型错误:{activity.id}", GroupNames.成都开发測試群組);
  3608. return Ok(new { code = 6, msg = "活动类型错误!" });
  3609. }
  3610. }
  3611. if (code==200)
  3612. {
  3613. ///检查被报名的活动是是否符合
  3614. if (activity.publish==1)
  3615. {
  3616. //ResponseMessage responseContest = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  3617. //if (responseContest.Status==200 && activity.modules.Contains("Contest"))
  3618. //{
  3619. // Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  3620. //}
  3621. //else
  3622. //{
  3623. // return Ok(new { code = 14, msg = "活动未设置赛课模块!" });
  3624. //}
  3625. if (contest.modules.Contains("sign") && contest.sign!=null)
  3626. {
  3627. //报名时间检查
  3628. if (contest.sign.stime<=now && contest.sign.etime>=now)
  3629. {
  3630. code=200;
  3631. }
  3632. else
  3633. {
  3634. return Ok(new { code = 7, msg = "不在报名时间范围内!" });
  3635. }
  3636. //检查报名人数
  3637. if (contest.sign.limit>0)
  3638. {
  3639. //报名人数,除去自己
  3640. string countEnrollSQL = $"select value c.id from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.id<>'{tmdid}' ";
  3641. var countEnrollResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<string>(countEnrollSQL, $"ActivityEnroll-{_activityId.GetString()}");
  3642. if (countEnrollResult.list.Count+1>contest.sign.limit)
  3643. {
  3644. return Ok(new { code = 8, msg = "已超过报名人数限制!" });
  3645. }
  3646. else { code=200; }
  3647. }
  3648. //检查团队组,检查口令
  3649. int checkTeam = -1;
  3650. int cipherChange = -1;
  3651. if (contest.sign.type==1)
  3652. {
  3653. if (enrollData.type==1 && !string.IsNullOrWhiteSpace(enrollData.cipher))
  3654. {
  3655. //检查组队口令
  3656. string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enrollData.cipher}' and c.contest.leader=1 ";
  3657. var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  3658. if (cipherResult.list.IsNotEmpty())
  3659. {
  3660. //如果队伍存在
  3661. if (!cipherResult.list.First().schoolId.Equals(enrollData.schoolId))
  3662. {
  3663. return Ok(new { code = 18, msg = "报名选择的学校与组队学校不一致!" });
  3664. }
  3665. enrollData.teamName= cipherResult.list.First().contest?.teamName;
  3666. }
  3667. if (enrollData.leader==1)
  3668. {
  3669. //队长
  3670. if (cipherResult.list.IsNotEmpty())
  3671. {
  3672. //组队口令已被其他团队使用,此处已顺便处理成员篡位的逻辑
  3673. var otherTeam = cipherResult.list.FindAll(z => !z.id.Equals(tmdid));
  3674. if (otherTeam.IsNotEmpty())
  3675. {
  3676. return Ok(new { code = 10, msg = "组队口令已被其他团队使用!" });
  3677. }
  3678. else
  3679. {
  3680. //队长更改信息。
  3681. //检查 更新信息的 组队口令是否有变化,如果有变化则队员的组队口令也跟着变化
  3682. if (!string.IsNullOrWhiteSpace(enroll?.contest?.cipher) && !enroll.contest.cipher.Equals(enrollData.cipher))
  3683. {
  3684. cipherChange=1;
  3685. }
  3686. checkTeam=1;
  3687. }
  3688. }
  3689. else
  3690. {
  3691. //队长更改信息。
  3692. //检查 更新信息的 组队口令是否有变化,如果有变化则队员的组队口令也跟着变化
  3693. if (!string.IsNullOrWhiteSpace(enroll?.contest?.cipher) && !enroll.contest.cipher.Equals(enrollData.cipher))
  3694. {
  3695. cipherChange=1;
  3696. }
  3697. checkTeam=1;
  3698. }
  3699. }
  3700. else
  3701. {
  3702. //队长跑路
  3703. if (enroll!=null && enroll.contest!=null && enroll.contest.leader==1 && enrollData.leader==0)
  3704. {
  3705. return Ok(new { code = 17, msg = "你是队长,不能变更身份!" });
  3706. }
  3707. //队员
  3708. if (cipherResult.list.IsNotEmpty())
  3709. {
  3710. if (cipherResult.list.Count==1)
  3711. {
  3712. checkTeam=1;
  3713. }
  3714. else
  3715. {
  3716. await _dingDing.SendBotMsg($"{_option.Location},组队口令重复:{enrollData.cipher}", GroupNames.成都开发測試群組);
  3717. return Ok(new { code = 12, msg = "组队口令重复!" });
  3718. }
  3719. }
  3720. else
  3721. {
  3722. return Ok(new { code = 11, msg = "队伍未组建或不存在!" });
  3723. }
  3724. }
  3725. }
  3726. else
  3727. {
  3728. return Ok(new { code = 9, msg = "参加组别不一致!" });
  3729. }
  3730. }
  3731. else
  3732. {
  3733. //个人组
  3734. if (contest.sign.type== enrollData.type)
  3735. {
  3736. checkTeam=1;
  3737. }
  3738. else
  3739. {
  3740. return Ok(new { code = 9, msg = "参加组别不一致!" });
  3741. }
  3742. }
  3743. if (checkTeam==1)
  3744. {
  3745. if (enroll!=null)
  3746. {
  3747. //更新组队信息
  3748. enroll.contest.teamName= enrollData.teamName;
  3749. enroll.contest.cipher=enrollData.cipher;
  3750. enroll.contest.type=enrollData.type;
  3751. enroll.contest.leader=enrollData.leader;
  3752. enroll.contest.enrollInfos=enrollData.enrollInfos;
  3753. enroll.contest.enrollTime=now;
  3754. enroll.schoolPicture=enrollData.schoolPicture;
  3755. enroll.schoolId=enrollData.schoolId;
  3756. enroll.schoolName=enrollData.schoolName;
  3757. enroll.tmdName=enrollData.tmdName;
  3758. enroll.tmdPicture=enrollData.tmdPicture;
  3759. }
  3760. else
  3761. {
  3762. enroll= new ActivityEnroll
  3763. {
  3764. id=tmdid,
  3765. schoolName=enrollData.schoolName,
  3766. schoolId=enrollData.schoolId,
  3767. schoolPicture=enrollData.schoolPicture,
  3768. activityId=_activityId.GetString(),
  3769. code=$"ActivityEnroll-{_activityId}",
  3770. pk="ActivityEnroll",
  3771. tmdName=enrollData.tmdName,
  3772. tmdPicture=enrollData.tmdPicture,
  3773. contest=new EnrollContest
  3774. {
  3775. cipher=enrollData.cipher,
  3776. leader=enrollData.leader,
  3777. teamName=enrollData.teamName,
  3778. type=enrollData.type,
  3779. enrollTime=now,
  3780. enrollInfos=enrollData.enrollInfos
  3781. }
  3782. };
  3783. }
  3784. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enroll, new PartitionKey(enroll.code));
  3785. List<TeacherEnrollContestDto> teamMembers = new List<TeacherEnrollContestDto>();
  3786. //获取组队队员信息
  3787. if (enrollData.type==1 && !string.IsNullOrWhiteSpace(enrollData.cipher))
  3788. {
  3789. //获取队员报名信息
  3790. string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enrollData.cipher}' ";
  3791. var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  3792. if (cipherChange==1)
  3793. {
  3794. //队长更新其他队员的组队口令
  3795. cipherResult.list.RemoveAll(z => z.contest.leader==1);
  3796. foreach (var z in cipherResult.list)
  3797. {
  3798. z.contest.cipher=enrollData.cipher;
  3799. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(z, new PartitionKey(z.code));
  3800. }
  3801. }
  3802. teamMembers= cipherResult.list.Select(z => new TeacherEnrollContestDto
  3803. {
  3804. tmdid= z.id,
  3805. tmdPicture= z.tmdPicture,
  3806. tmdName= z.tmdName,
  3807. schoolName=z.schoolName,
  3808. schoolPicture= z.schoolPicture,
  3809. schoolId= z.schoolId,
  3810. cipher= z.contest.cipher,
  3811. enrollTime= z.contest.enrollTime,
  3812. leader= z.contest.leader,
  3813. teamName= z.contest.teamName,
  3814. type=z.contest.type,
  3815. enrollInfos= z.contest.enrollInfos,
  3816. }).ToList();
  3817. }
  3818. foreach (var activityTeacher in activityTeachers)
  3819. {
  3820. //反向更新邀请状态
  3821. activityTeacher.inviteTeachers.ForEach(z => { if (z.id.Equals(enrollData.tmdid)) { z.status=1; } });
  3822. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(activityTeacher, new PartitionKey($"ActivityTeacher-{_activityId}"));
  3823. }
  3824. return Ok(new
  3825. {
  3826. code = 200,
  3827. enroll,
  3828. teamMembers = teamMembers.Select(z => new
  3829. {
  3830. z.tmdid,
  3831. z.tmdPicture,
  3832. z.tmdName,
  3833. z.schoolName,
  3834. z.schoolPicture,
  3835. z.schoolId,
  3836. z.cipher,
  3837. z.enrollTime,
  3838. z.leader,
  3839. z.teamName,
  3840. z.type,
  3841. z.enrollInfos
  3842. })
  3843. });
  3844. }
  3845. else
  3846. {
  3847. return Ok(new { code = 12, msg = "报名组别检查未通过!" });
  3848. }
  3849. }
  3850. else
  3851. {
  3852. return Ok(new { code = 15, msg = "活动未设置信息填报模块!" });
  3853. }
  3854. }
  3855. else
  3856. {
  3857. return Ok(new { code = 13, msg = "活动未发布!" });
  3858. }
  3859. }
  3860. else
  3861. {
  3862. return Ok(new { code = 6, msg = "活动类型错误!" });
  3863. }
  3864. }
  3865. //作品上传
  3866. case bool when $"{grant_type}".Equals("upload-contest", StringComparison.OrdinalIgnoreCase):
  3867. {
  3868. request.TryGetProperty("mock", out JsonElement _mock);
  3869. if (!request.TryGetProperty("uploadData", out JsonElement _uploadData))
  3870. {
  3871. return Ok(new { code = 0, msg = "上传信息未完善!" });
  3872. };
  3873. TeacherUploadContestDto uploadContest = _uploadData.ToObject<TeacherUploadContestDto>();
  3874. if (!string.IsNullOrWhiteSpace($"{_mock}"))
  3875. {
  3876. tmdid= uploadContest.tmdid;
  3877. }
  3878. if (contest.modules.Contains("upload") && contest.upload!=null)
  3879. {
  3880. int check = -1;
  3881. //作品上传时间
  3882. if (!(contest.upload.stime<=now && contest.upload.etime>=now))
  3883. {
  3884. return Ok(new { code = 4, msg = "未到上传作品时间!" });
  3885. }
  3886. ActivityEnroll enroll = null;
  3887. int captainUpload = -1;
  3888. ResponseMessage responseActivityEnroll = await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemStreamAsync(tmdid, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  3889. if (responseActivityEnroll.StatusCode==System.Net.HttpStatusCode.OK)
  3890. {
  3891. enroll= JsonDocument.Parse(responseActivityEnroll.Content).RootElement.ToObject<ActivityEnroll>();
  3892. if (contest.modules.Contains("sign"))
  3893. {
  3894. if (enroll.contest==null)
  3895. {
  3896. return Ok(new { code = 2, msg = "请先报名后再上传作品!" });
  3897. }
  3898. else
  3899. {
  3900. if (contest.upload.captainUpload==1)
  3901. {
  3902. if (enroll.contest.type==1)
  3903. {
  3904. if (enroll.contest.leader!=1)
  3905. {
  3906. return Ok(new { code = 3, msg = "作品上传要求队长上传!" });
  3907. }
  3908. else
  3909. {
  3910. check=1;
  3911. captainUpload=1;
  3912. }
  3913. }
  3914. else
  3915. {
  3916. return Ok(new { code = 3, msg = "作品上传要求队长上传!" });
  3917. }
  3918. }
  3919. else
  3920. {
  3921. check=1;
  3922. }
  3923. }
  3924. }
  3925. else
  3926. {
  3927. //没有报名模块,直接上传
  3928. check=1;
  3929. }
  3930. }
  3931. else
  3932. {
  3933. if (contest.modules.Contains("sign"))
  3934. {
  3935. return Ok(new { code = 2, msg = "请先报名后再上传作品!" });
  3936. }
  3937. else
  3938. {
  3939. //没有报名模块,直接上传
  3940. check=1;
  3941. enroll= new ActivityEnroll
  3942. {
  3943. id=tmdid,
  3944. code=$"ActivityEnroll-{_activityId}",
  3945. pk="ActivityEnroll",
  3946. schoolId= uploadContest.schoolId,
  3947. schoolName=uploadContest.schoolName,
  3948. schoolPicture=uploadContest.schoolPicture,
  3949. activityId=_activityId.GetString()
  3950. };
  3951. }
  3952. }
  3953. if (check==1)
  3954. {
  3955. if (uploadContest.complexes.IsNotEmpty())
  3956. {
  3957. if (contest.upload.limit>0)
  3958. {
  3959. if (contest.upload.limit<contest.upload.uploadType.Count())
  3960. {
  3961. ///上传类型数量限制小于文件类型数量,表示可以上传任意N种类型的文件。
  3962. if (uploadContest.complexes.Count>=contest.upload.limit && uploadContest.complexes.Count<= contest.upload.uploadType.Count())
  3963. {
  3964. var types = uploadContest.complexes.Select(x => x.type).ToHashSet();
  3965. foreach (var type in types)
  3966. {
  3967. if (!contest.upload.uploadType.Contains(type))
  3968. {
  3969. return Ok(new { code = 7, msg = "上传的文件类型与活动要求的文件类型不符!" });
  3970. }
  3971. }
  3972. }
  3973. else
  3974. {
  3975. return Ok(new { code = 10, msg = "文件上传数量不满足活动要求上传的文件类型数量!" });
  3976. }
  3977. }
  3978. else
  3979. {
  3980. ///上传类型数量限制大于等于则表示需要上传所有类型的文件。
  3981. if (uploadContest.complexes.Count== contest.upload.uploadType.Count())
  3982. {
  3983. var types = uploadContest.complexes.Select(x => x.type).ToHashSet();
  3984. bool hasError = false;
  3985. foreach (var type in contest.upload.uploadType)
  3986. {
  3987. if (!contest.upload.uploadType.Contains(type))
  3988. {
  3989. hasError=true;
  3990. }
  3991. }
  3992. if (hasError)
  3993. {
  3994. return Ok(new { code = 7, msg = "上传的文件类型与活动要求的文件类型不符!" });
  3995. }
  3996. }
  3997. else
  3998. {
  3999. return Ok(new { code = 10, msg = "文件上传数量不满足活动要求上传的文件类型数量!" });
  4000. }
  4001. }
  4002. }
  4003. else
  4004. {
  4005. ///在上传类型范围内,不限制上传文件的种类和类型的数量。
  4006. var types = uploadContest.complexes.Select(x => x.type).ToHashSet();
  4007. foreach (var type in types)
  4008. {
  4009. if (!contest.upload.uploadType.Contains(type))
  4010. {
  4011. return Ok(new { code = 7, msg = "上传的文件类型与活动要求的文件类型不符!" });
  4012. }
  4013. }
  4014. }
  4015. ///检查必须上传的类型
  4016. if (contest.upload.uploadTypeNecessary!=null && contest.upload.uploadTypeNecessary.Count>0)
  4017. {
  4018. var types = uploadContest.complexes.Select(x => x.type).ToHashSet();
  4019. foreach (var type in contest.upload.uploadTypeNecessary)
  4020. {
  4021. if (!types.Contains(type))
  4022. {
  4023. return Ok(new { code = 9, msg = "没有上传活动要求必须上传的文件类型!" });
  4024. }
  4025. }
  4026. }
  4027. //覆盖更新
  4028. enroll.upload= new EnrollUpload
  4029. {
  4030. uploadTime=now,
  4031. complexes=uploadContest.complexes,
  4032. uploadType=uploadContest.complexes.Select(x => x.type).ToHashSet(),
  4033. //作品id变更,已经上传过不会发生变更。
  4034. uploadId=string.IsNullOrWhiteSpace(enroll?.upload?.uploadId) ? Guid.NewGuid().ToString(): enroll.upload.uploadId,
  4035. name=uploadContest.name,
  4036. };
  4037. await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enroll, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  4038. if (captainUpload==1&& !string.IsNullOrWhiteSpace(enroll.contest.cipher))
  4039. {
  4040. //获取队员报名信息
  4041. string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enroll.contest.cipher}' ";
  4042. var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  4043. //队长统一上传
  4044. cipherResult.list.RemoveAll(z => z.contest.leader==1);
  4045. foreach (var z in cipherResult.list)
  4046. {
  4047. z.upload=enroll.upload;
  4048. //队长统一上传的作品不需要单独生成作品id.
  4049. // z.upload.uploadId=Guid.NewGuid().ToString();
  4050. await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(z, new PartitionKey(z.code));
  4051. }
  4052. }
  4053. return Ok(new { code = 200, });
  4054. }
  4055. else
  4056. {
  4057. return Ok(new { code = 6, msg = "未通过作品验证!" });
  4058. }
  4059. //if (contest.upload.type.Equals(uploadContest.type))
  4060. //{
  4061. // if (uploadContest.type.Equals("sokrates"))
  4062. // {
  4063. // //校验苏格拉底
  4064. // //var httpClient = _httpClientFactory.CreateClient();
  4065. // //if (!httpClient.DefaultRequestHeaders.Contains("x-functions-key"))
  4066. // //{
  4067. // // httpClient.DefaultRequestHeaders.Add("x-functions-key", "2BcXFR_hvzG1pZjqIkaM7Dx74Hcu6m0PwwOacFpDpq44AzFuHJBRXA==");
  4068. // //}
  4069. // //string paramJson = JsonConvert.SerializeObject(new { fmt = "0" });
  4070. // //var content = new StringContent(paramJson, Encoding.UTF8, "application/json");
  4071. // //HttpResponseMessage httpResponse = await httpClient.PostAsync("https://malearn.teammodel.cn/api/txtwc", content);
  4072. // //if (httpResponse.IsSuccessStatusCode)
  4073. // //{
  4074. // // string str = await httpResponse.Content.ReadAsStringAsync();
  4075. // //}
  4076. // // 处理队长统一上传
  4077. // return Ok(new { code = 200 });
  4078. // }
  4079. // else if (uploadContest.type.Equals("lesson"))
  4080. // {
  4081. // foreach (var ext in uploadContest.lessons.Select(z => z.extension).ToHashSet())
  4082. // {
  4083. // if (!contest.upload.fileType.Contains(ext))
  4084. // {
  4085. // return Ok(new { code = 7, msg = "上传的文件类型与活动要求的文件类型不符!" });
  4086. // }
  4087. // }
  4088. // //覆盖更新
  4089. // enroll.upload= new EnrollUpload
  4090. // {
  4091. // uploadTime=now,
  4092. // lessons=uploadContest.lessons,
  4093. // type=uploadContest.type,
  4094. // uploadId=Guid.NewGuid().ToString(),
  4095. // name=uploadContest.name,
  4096. // };
  4097. // await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enroll, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  4098. // if (captainUpload==1&& !string.IsNullOrWhiteSpace(enroll.contest.cipher))
  4099. // {
  4100. // //获取队员报名信息
  4101. // string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enroll.contest.cipher}' ";
  4102. // var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  4103. // //队长统一上传
  4104. // cipherResult.list.RemoveAll(z => z.contest.leader==1);
  4105. // foreach (var z in cipherResult.list)
  4106. // {
  4107. // z.upload=enroll.upload;
  4108. // //队长统一上传的作品不需要单独生成作品id.
  4109. // // z.upload.uploadId=Guid.NewGuid().ToString();
  4110. // await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(z, new PartitionKey(z.code));
  4111. // }
  4112. // }
  4113. // return Ok(new { code = 200, });
  4114. // }
  4115. // else if (uploadContest.type.Equals("file"))
  4116. // {
  4117. // foreach (var ext in uploadContest.files.Select(z => z.extension).ToHashSet())
  4118. // {
  4119. // if (!contest.upload.fileType.Contains(ext))
  4120. // {
  4121. // return Ok(new { code = 7, msg = "上传的文件类型与活动要求的文件类型不符!" });
  4122. // }
  4123. // }
  4124. // //覆盖更新
  4125. // enroll.upload= new EnrollUpload
  4126. // {
  4127. // uploadTime=now,
  4128. // files=uploadContest.files,
  4129. // type=uploadContest.type,
  4130. // uploadId=Guid.NewGuid().ToString(),
  4131. // name=uploadContest.name,
  4132. // };
  4133. // await client.GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(enroll, new PartitionKey($"ActivityEnroll-{_activityId.GetString()}"));
  4134. // if (captainUpload==1&& !string.IsNullOrWhiteSpace(enroll.contest.cipher))
  4135. // {
  4136. // //获取队员报名信息
  4137. // string cipherSQL = $"select value c from c where c.contest!=null and c.activityId='{_activityId.GetString()}' and c.contest.type=1 and c.contest.cipher='{enroll.contest.cipher}' ";
  4138. // var cipherResult = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).GetList<ActivityEnroll>(cipherSQL, $"ActivityEnroll-{_activityId}");
  4139. // //队长统一上传
  4140. // cipherResult.list.RemoveAll(z => z.contest.leader==1);
  4141. // foreach (var z in cipherResult.list)
  4142. // {
  4143. // z.upload=enroll.upload;
  4144. // //队长统一上传的作品不需要单独生成作品id.
  4145. // // z.upload.uploadId=Guid.NewGuid().ToString();
  4146. // await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Teacher).UpsertItemAsync(z, new PartitionKey(z.code));
  4147. // }
  4148. // }
  4149. // return Ok(new { code = 200, });
  4150. // }
  4151. // else
  4152. // {
  4153. // return Ok(new { code = 8, msg = "上传类型不一致!" });
  4154. // }
  4155. //}
  4156. //else
  4157. //{
  4158. // return Ok(new { code = 5, msg = "上传的作品类型与活动要求的作品类型不符!" });
  4159. //}
  4160. }
  4161. else
  4162. {
  4163. return Ok(new { code = 6, msg = "未通过作品验证!" });
  4164. }
  4165. }
  4166. else
  4167. {
  4168. return Ok(new { code = 1, msg = "未设置上传模块!" });
  4169. }
  4170. //ResponseMessage responseContest = await client.GetContainer(Constant.TEAMModelOS, Constant.Common).ReadItemStreamAsync(_activityId.GetString(), new PartitionKey("Contest"));
  4171. //if (responseContest.Status==200 && activity.modules.Contains("Contest"))
  4172. //{
  4173. // Contest contest = JsonDocument.Parse(responseContest.Content).RootElement.ToObject<Contest>();
  4174. //}
  4175. //else { return Ok(new { code = 1, msg = "未设置上传模块!" }); }
  4176. }
  4177. }
  4178. }
  4179. else
  4180. {
  4181. return Ok(new { code = 31, msg = "活动未发布!" });
  4182. }
  4183. }
  4184. else { return Ok(new { code = 32, msg = "活动不存在!" }); }
  4185. }
  4186. catch (Exception ex)
  4187. {
  4188. await _dingDing.SendBotMsg($"{_option.Location},报名信息{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  4189. return BadRequest(ex.Message);
  4190. }
  4191. return Ok();
  4192. }
  4193. /// <summary>
  4194. /// portal站的
  4195. /// </summary>
  4196. /// <param name="request"></param>
  4197. /// <returns></returns>
  4198. [ProducesDefaultResponseType]
  4199. [HttpPost("list-portal")]
  4200. public async Task<IActionResult> ListPortal(JsonElement request)
  4201. {
  4202. //var authtoken = HttpContext.GetXAuth("AuthToken");
  4203. //string userid = string.Empty;
  4204. //object schoolid = null;
  4205. //if (!string.IsNullOrWhiteSpace(authtoken)) {
  4206. // var jwt = new JwtSecurityToken(authtoken);
  4207. // //TODO 此驗證IdToken先簡單檢查,後面需向Core ID新API,驗證Token
  4208. // userid= jwt.Payload.Sub;
  4209. // jwt.Payload.TryGetValue("azp", out schoolid);
  4210. //}
  4211. if (!request.TryGetProperty("route", out JsonElement _route)) return BadRequest();
  4212. List<ActivityDto> activities = new List<ActivityDto>();
  4213. string sql = $"select value c from c where c.route='{_route}'";
  4214. var result = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Normal).GetList<ActivityWebsite>(sql, "ActivityWebsite");
  4215. ActivityWebsite website = null;
  4216. if (result.list.Count>1)
  4217. {
  4218. return Ok(new { code = 1, msg = "路由匹配多个区校" });
  4219. }
  4220. else
  4221. {
  4222. if (result.list.Count==1)
  4223. {
  4224. website= result.list[0];
  4225. }
  4226. }
  4227. if (website!=null)
  4228. {
  4229. if (website.scope.Equals("area"))
  4230. {
  4231. //区级所有学校
  4232. string sqlOpen = $"select value c from c where c.scope='area' and (c.publish=1 or c.publish=2 ) and c.owner='{website.id}' ";
  4233. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
  4234. activities.AddRange(resultOpen.list);
  4235. }
  4236. if (website.scope.Equals("school"))
  4237. {
  4238. School schoolbase = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.School).ReadItemAsync<School>(website.id, new PartitionKey("Base"));
  4239. //区级下放的
  4240. if (!string.IsNullOrWhiteSpace(schoolbase.areaId))
  4241. {
  4242. //区级所有学校
  4243. string sqlOpen = $"select value c from c join s in c.confirmedSchools where c.scope='area' and (c.publish=1 or c.publish=2 ) and c.owner='{schoolbase.areaId}' and( ARRAY_LENGTH(c.invitedSchools)=0 or IS_DEFINED(c.invitedSchools) = false) and s.id='{schoolbase.id}' and s.status=1 ";
  4244. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
  4245. activities.AddRange(resultOpen.list);
  4246. //区级部分学校
  4247. string sqlSchool = $"select value c from c join i in c.invitedSchools join s in c.confirmedSchools where c.scope='area'and (c.publish=1 or c.publish=2 ) and c.owner='{schoolbase.areaId}' and i.id='{schoolbase.id}' and s.id='{schoolbase.id}' and s.status=1 ";
  4248. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
  4249. activities.AddRange(resultSchool.list);
  4250. }
  4251. {
  4252. ///学校自己的
  4253. string sqlSchool = $"select value c from c where c.scope='school' and (c.publish=1 or c.publish=2 ) and c.owner='{schoolbase.id}' ";
  4254. var resultSchool = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlSchool, "Activity");
  4255. activities.AddRange(resultSchool.list);
  4256. }
  4257. }
  4258. //获取开放的
  4259. {
  4260. //完全开放 所有的学校
  4261. string sqlOpen = $"select value c from c where c.scope='public' and (c.publish=1 or c.publish=2 ) ";
  4262. var resultOpen = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Common).GetList<ActivityDto>(sqlOpen, "Activity");
  4263. activities.AddRange(resultOpen.list);
  4264. }
  4265. }
  4266. long now = DateTimeOffset.Now.ToUnixTimeMilliseconds();
  4267. activities.ForEach(z =>
  4268. {
  4269. var (blob_uri, blob_sas) = _azureStorage.GetBlobContainerSAS(z.owner, BlobContainerSasPermissions.Read);
  4270. z.sas=blob_sas;
  4271. z.url=blob_uri;
  4272. if (z.etime<now) {
  4273. z.publish=2;
  4274. }
  4275. });
  4276. return Ok(new { activities, website });
  4277. }
  4278. }
  4279. }