TEAMModelOS/TEAMModelBI/Controllers/RepairApi/TeacherREPController.cs

using Azure.Cosmos;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Models;

namespace TEAMModelBI.Controllers.RepairApi
{
    [Route("teacherrep")]
    [ApiController]
    public class TeacherREPController : ControllerBase
    {
        private readonly AzureCosmosFactory _azureCosmos;
        public TeacherREPController(AzureCosmosFactory azureCosmos)
        {
            _azureCosmos = azureCosmos;

        }

        List<string> schools = new() { "dghznx", "cxhhlx", "xjaxx", "zjqxx", "xnygxx", "lxxcfx", "gxjrxx", "cdgxsx", "yzxx", "kjyxx", "wjylxx", "dsgjxx", "ydzt", "xndbxx", "sqtszx", "cdxczx", "ghsyzx", "lqsx", "cdxxps", "xcfx", "xyqxx", "xncbyy", "cdlqjk", "lqdmxx", "lqyx", "pclxxx", "cdfzx", "xnblxx", "ghsx", "khdycz", "khbmxx", "khdecz", "khzx", "khhbzx", "gxxcxx", "khhtxx", "khdxxx", "khsyxx" };

        /// <summary>
        /// 修改教师学校信息
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        [HttpPost("get-teachersc")]
        public async Task<IActionResult> SetTeacherSchool(JsonElement json)
        {
            var cosmosClient = _azureCosmos.GetCosmosClient();
            foreach (var item in schools)
            {
                School school = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemAsync<School>($"{item}", new PartitionKey("Base"));

                List<Teacher> teachers = new();
                await foreach (var tch in cosmosClient.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<Teacher>(queryText: $"SELECT value(c) FROM c join s in c.schools where s.schoolId='dghznx' and c.code='Base'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
                {
                    teachers.Add(tch);
                }

                if (teachers.Count > 0)
                {
                    foreach (var teacher in teachers)
                    {
                        teacher.schools.ForEach(tch => { if (tch.schoolId.Equals(item)) { tch.areaId = school.areaId; } });
                        await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey("Base"));
                    }
                }
            }

            return Ok(new { state = 200 });
        }
    }
}