ActivityController.cs 236 KB

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