ActivityController.cs 255 KB

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