TEAMModelOS/TEAMModelOS/Controllers/Third/Sc/ScDataInitController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using System.Text.Json;
using TEAMModelOS.SDK.Models;
using Microsoft.AspNetCore.Http;
using TEAMModelOS.SDK.Extension;
using Azure.Cosmos;
using System.Text;
using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
using Microsoft.Extensions.Options;
using Azure.Messaging.ServiceBus;
using Microsoft.Extensions.Configuration;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.SDK;
using System.IdentityModel.Tokens.Jwt;
using TEAMModelOS.Services;
using TEAMModelOS.SDK.Models.Service;
using System.IO;
using System.Dynamic;
using Microsoft.AspNetCore.Authorization;
using Azure.Storage.Blobs.Models;
using static TEAMModelOS.SDK.Models.Teacher;
using System.Web;
using static TEAMModelOS.Controllers.FixDataController;
using static TEAMModelOS.SDK.SchoolService;
using Microsoft.AspNetCore.Hosting;
using static TEAMModelOS.Controllers.ScController;

namespace TEAMModelOS.Controllers.Third
{
    /// <summary>
    /// 
    /// </summary>
    ///  
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    //
    //[Route("")]
    [Route("sc-init")]
    [ApiController]
    public class ScDataInitController : ControllerBase
    {
        private readonly SnowflakeId _snowflakeId;
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly AzureRedisFactory _azureRedis;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly ThirdApisService _scsApisService;
        public readonly string type = "scsyxpt";
        private readonly HttpTrigger _httpTrigger;
        private readonly IWebHostEnvironment _environment;
        private readonly ThirdApisService _thirdApisService;
        public IConfiguration _configuration { get; set; }
        public ScDataInitController(ThirdApisService thirdApisService, IWebHostEnvironment environment, AzureCosmosFactory azureCosmos, SnowflakeId snowflakeId, DingDing dingDing, IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage,
          AzureRedisFactory azureRedis, AzureServiceBusFactory serviceBus, IConfiguration configuration, CoreAPIHttpService coreAPIHttpService, ThirdApisService scsApisService, HttpTrigger httpTrigger)
        {
            _azureCosmos = azureCosmos;
            _snowflakeId = snowflakeId;
            _dingDing = dingDing;
            _option = option?.Value;
            _azureStorage = azureStorage;
            _serviceBus = serviceBus;
            _configuration = configuration;
            _azureRedis = azureRedis;
            _coreAPIHttpService = coreAPIHttpService;
            _scsApisService = scsApisService;
            _httpTrigger = httpTrigger;
            _environment = environment;
            _thirdApisService = thirdApisService;
        }

        /// <summary>
        /// 0. 获取省平台相关的项目
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-scs-porject")]
        [AllowAnonymous]
        public async Task<IActionResult> GetScsPorject(JsonElement request)
        {
            var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
            List<ScComConfig> scComConfigs = await table.FindListByDict<ScComConfig>(new Dictionary<string, object> { { Constant.PartitionKey, "ScComConfig" } });
            string Code = "GetProjectInfoByTrainComID";
            List<ScProject> projectsSave = new List<ScProject>();
            foreach (var config in scComConfigs)
            {
                Dictionary<string, object> parameterMap = new Dictionary<string, object>();
                parameterMap.Add("TrainComID", config.trainComID);
                ScsResult result = new ScsResult { code = Code, title = "5.3.1.1获取项目列表" };
                result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                List<ScProject> projects = result.content.ToObject<List<ScProject>>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
                List<ScProject> scProjects = await table.FindListByDict<ScProject>(new Dictionary<string, object> { { Constant.PartitionKey, "ScProject" }, { "trainComID", $"{config.trainComID}" } });

                foreach (var project in projects)
                {
                    if (scProjects.IsNotEmpty())
                    {
                        ScProject scProject = scProjects.Find(x => x.ProjectItemID == project.ProjectItemID);
                        if (scProject != null)
                        {
                            scProject.PartitionKey = "ScProject";
                            scProject.trainComID = config.trainComID;
                            scProject.passKey = config.passKey;
                            scProject.privateKey = config.privateKey;
                            scProject.RowKey = $"{project.ProjectItemID}";
                            scProject.config = "scsyxpt";
                            scProject.ProjectID = project.ProjectID;
                            scProject.ProjectItemID = project.ProjectItemID;
                            scProject.ProjectItemTitle = project.ProjectItemTitle;
                            scProject.ProjectTitle = project.ProjectTitle;
                            scProject.TCount = project.TCount;
                            scProject.IsDiagnosis = project.IsDiagnosis;
                            scProject.IsQuota = project.IsQuota;
                            scProject.SchoolDiagnosisMinCount = project.SchoolDiagnosisMinCount;
                            scProject.SchoolDiagnosisMinDimension = project.SchoolDiagnosisMinDimension;
                            scProject.TeacherDiagnosisMinDimension = project.TeacherDiagnosisMinDimension;
                            projectsSave.Add(scProject);
                        }
                        else
                        {
                            projectsSave.Add(new ScProject
                            {
                                PartitionKey = "ScProject",
                                trainComID = config.trainComID,
                                passKey = config.passKey,
                                privateKey = config.privateKey,
                                RowKey = $"{project.ProjectItemID}",
                                config = "scsyxpt",
                                ProjectID = project.ProjectID,
                                ProjectItemID = project.ProjectItemID,
                                ProjectItemTitle = project.ProjectItemTitle,
                                ProjectTitle = project.ProjectTitle,
                                TCount = project.TCount,
                                IsDiagnosis = project.IsDiagnosis,
                                IsQuota = project.IsQuota,
                                SchoolDiagnosisMinCount = project.SchoolDiagnosisMinCount,
                                SchoolDiagnosisMinDimension = project.SchoolDiagnosisMinDimension,
                                TeacherDiagnosisMinDimension = project.TeacherDiagnosisMinDimension,
                            });
                        }
                    }
                    else
                    {
                        projectsSave.Add(new ScProject
                        {
                            PartitionKey = "ScProject",
                            trainComID = config.trainComID,
                            passKey = config.passKey,
                            privateKey = config.privateKey,
                            RowKey = $"{project.ProjectItemID}",
                            config = "scsyxpt",
                            ProjectID = project.ProjectID,
                            ProjectItemID = project.ProjectItemID,
                            ProjectItemTitle = project.ProjectItemTitle,
                            ProjectTitle = project.ProjectTitle,
                            TCount = project.TCount,
                            IsDiagnosis = project.IsDiagnosis,
                            IsQuota = project.IsQuota,
                            SchoolDiagnosisMinCount = project.SchoolDiagnosisMinCount,
                            SchoolDiagnosisMinDimension = project.SchoolDiagnosisMinDimension,
                            TeacherDiagnosisMinDimension = project.TeacherDiagnosisMinDimension,
                        });
                    }
                }
            }
            await table.SaveOrUpdateAll(projectsSave);
            return Ok(new { projectsSave });
        }

        /// <summary>
        /// 3. 处理 省平台最新的教师以及 反向更新没有绑定醍摩豆id 的账号。
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-scs-teacher")]
        [AllowAnonymous]
        public async Task<IActionResult> getScsTeacher(JsonElement request)
        {
            if (!request.TryGetProperty("accessConfig", out JsonElement accessConfig)) return BadRequest();
            if (!request.TryGetProperty("city", out JsonElement city)) return BadRequest();
            if (!request.TryGetProperty("dist", out JsonElement dist)) return BadRequest();
            if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
            if (!request.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
            //数据校验
            var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
            var ScTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "areaId", $"{areaId}" } });
            var ScSchools = await table.FindListByDict<ScSchool>(new Dictionary<string, object>() { { "PartitionKey", "ScSchool" }, { "areaId", $"{areaId}" } });
            Dictionary<string, object> dict = new Dictionary<string, object> { { "accessConfig", $"{accessConfig}" }, { "areaId", $"{areaId}" } };
            (int status, string json) = await _httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetTeachersListByProject");
            var teachers = json.ToObject<List<ScTeacher>>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
            //未保存在数据库的。
            var a = teachers.Select(x => $"{x.TID}").ToList();
            var s = ScTeachers.Select(y => $"{ y.TID}").ToList();
            var asin = a.Except(s).ToList();
            #region 省平台获取到最新的教师，并添加到Table中。
            var adds = teachers.FindAll(x => asin.Contains($"{x.TID}"));
            var addTeachers = ScTeachers.FindAll(x => adds.Select(y => $"{ y.PXID}").Contains($"{x.RowKey}"));
            if (addTeachers.IsNotEmpty())
            {
                //省平台更新的
                addTeachers.ForEach(x =>
                {
                    var tt = teachers.Find(z => x.RowKey.Equals($"{z.PXID}"));
                    if (tt != null)
                    {
                        x.status = 1;
                        x.TID = tt.TID;
                        x.TeacherName = tt.TeacherName;
                        x.SchoolID = tt.SchoolID;
                        x.SchoolName = tt.SchoolName;
                        x.ProjectID = tt.ProjectID;
                        x.ProjectItemID = tt.ProjectItemID;
                        x.ProjectItemTitle = tt.ProjectItemTitle;
                        x.ProjectTitle = tt.ProjectTitle;
                        x.CityID = tt.CityID;
                        x.DistrictID = tt.DistrictID;
                        x.CityName = tt.CityName;
                        x.DisName = tt.DisName;
                        x.Account = tt.Account;
                        x.TeacherXK = tt.TeacherXK;
                        x.TeacherXD = tt.TeacherXD;
                        x.Mobile = x.Mobile;
                        x.Email = tt.Email;
                        x.areaId = $"{areaId}";
                        x.PartitionKey = "ScTeacher";
                        x.tmdid = null;
                        var school = ScSchools.Find(s => s.schoolid == x.SchoolID);
                        x.schoolCode = school?.schoolCode;
                    }
                });
                addTeachers = await table.SaveOrUpdateAll(addTeachers);
            }
            else
            {
                //省平台更新的
                foreach (var x in adds)
                {
                    x.RowKey = $"{x.PXID}";
                    x.status = 1;
                    x.areaId = $"{areaId}";
                    x.PartitionKey = "ScTeacher";
                    var school = ScSchools.Find(s => s.schoolid == x.SchoolID);
                    x.schoolCode = school?.schoolCode;
                }
                addTeachers = await table.SaveOrUpdateAll(adds);
            }
            if (ScTeachers.Count == teachers.Count)
            {
                foreach (var x in ScTeachers)
                {
                    var tt = teachers.Find(z => x.RowKey.Equals($"{z.PXID}"));
                    if (tt != null)
                    {
                        x.status = 1;
                        x.TID = tt.TID;
                        x.TeacherName = tt.TeacherName;
                        x.SchoolID = tt.SchoolID;
                        x.SchoolName = tt.SchoolName;
                        x.ProjectID = tt.ProjectID;
                        x.ProjectItemID = tt.ProjectItemID;
                        x.ProjectItemTitle = tt.ProjectItemTitle;
                        x.ProjectTitle = tt.ProjectTitle;
                        x.CityID = tt.CityID;
                        x.DistrictID = tt.DistrictID;
                        x.CityName = tt.CityName;
                        x.DisName = tt.DisName;
                        x.Account = tt.Account;
                        x.TeacherXK = tt.TeacherXK;
                        x.TeacherXD = tt.TeacherXD;
                        x.Mobile = x.Mobile;
                        x.Email = tt.Email;
                        x.areaId = $"{areaId}";
                        x.PartitionKey = "ScTeacher";
                        x.tmdid = null;
                        var school = ScSchools.Find(s => s.schoolid == x.SchoolID);
                        x.schoolCode = school?.schoolCode;
                    }
                }
                addTeachers = await table.SaveOrUpdateAll(ScTeachers);
            }
            #endregion 省平台获取到最新的教师，并添加到Table中。
            //反向去补全四川省平台 Table中没有绑定tmdid的账号
            var unbindtmdid = ScTeachers.FindAll(x => string.IsNullOrEmpty(x.tmdid));
            var tids = unbindtmdid.Select(x => $"{x.TID}").ToHashSet();
            if (tids.Count() > 0)
            {
                List<DbBind> binds = new List<DbBind>();
                string sql = $"SELECT c.id,b.userid,b.data FROM c join b in c.binds  where b.userid in ({string.Join(",", tids.Select(x => $"'{x}'"))})";
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<DbBind>
                    (queryText: sql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
                {
                    binds.Add(item);
                }
                if (binds.IsNotEmpty())
                {
                    List<ScTeacher> update = new();
                    binds.ForEach(x =>
                    {
                        var exs = unbindtmdid.FindAll(z => $"{z.TID}".Equals(x.userid));
                        if (exs.IsNotEmpty())
                        {
                            exs.ForEach(y =>
                            {
                                y.tmdid = x.id;
                            });
                            update.AddRange(exs);
                        }
                    });
                    var group = update.GroupBy(x => x.RowKey).Select(z => new { z.Key, list = z.ToList() });
                    List<ScTeacher> scTeachers = new();
                    group.ToList().ForEach(x =>
                    {
                        if (x.list.Count() == 1)
                        {
                            scTeachers.Add(x.list[0]);
                        }
                        else if (x.list.Count > 1)
                        {
                            scTeachers.Add(x.list[0]);
                        }
                    });
                    scTeachers = await table.SaveOrUpdateAll(scTeachers);
                }
            }
            //反向更新教师绑定的省平台的SchoolID(int)和schoolCode(string)
            ScTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" }, { "areaId", $"{areaId}" } });
            var scSchools = await table.FindListByDict<ScSchool>(new Dictionary<string, object>() { { "PartitionKey", "ScSchool" }, { "areaId", $"{areaId}" } });
            List<ScTeacher> updateTch = new List<ScTeacher>();
            ScTeachers.FindAll(y => string.IsNullOrWhiteSpace(y.schoolCode)).ForEach(x =>
              {
                  var scSchool = scSchools.Find(s => s.schoolid == x.SchoolID);
                  x.schoolCode = scSchool?.schoolCode;
                  updateTch.Add(x);
              });
            if (updateTch.IsNotEmpty())
            {
                await table.SaveOrUpdateAll(updateTch);
            }
            return Ok(new { addTeachers, update = updateTch.Select(x => new { x.areaId, x.PXID, x.TID, x.TeacherName, x.tmdid, x.SchoolName, x.DisName }), ScTeachers });
        }
        /// <summary>
        ///1. 检查学校是否有同名的
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-sc-school")]
        [AllowAnonymous]
        public async Task<IActionResult> GetScSchool(JsonElement request)
        {
            if (!request.TryGetProperty("accessConfig", out JsonElement accessConfig)) return BadRequest();
            if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
            if (!request.TryGetProperty("city", out JsonElement city)) return BadRequest();
            if (!request.TryGetProperty("dist", out JsonElement dist)) return BadRequest();
            List<ScSchool> schools = null;
            List<ScSchool> matchSchools = null;
            int status = -1; string json = null;
            Dictionary<string, object> dict = new Dictionary<string, object> { { "accessConfig", $"{accessConfig}" }, { "areaId", $"{areaId}" } };
            List<School> ignore = new List<School>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: $"select value(c) from c where c.areaId='{areaId}'",
                requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
            {
                ignore.Add(item);
            }
            (status, json) = await _httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetSchoolList");
            if (status == 200)
            {
                schools = json.ToObject<List<ScSchool>>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
                if (ignore.IsNotEmpty())
                {
                    matchSchools = schools.FindAll(x => ignore.Select(y => y.name).Contains(x.schoolname));
                    if (matchSchools.IsNotEmpty())
                    {
                        if (matchSchools.Count != ignore.Count)
                        {
                            var matched = matchSchools.Select(x => x.schoolname);
                            var unmatch = ignore.Select(y => y.name).Except(matched);
                            List<string> scschoolUnmatch = schools.Select(y => y.schoolname).Except(matched).ToList();
                            if (scschoolUnmatch.IsNotEmpty())
                            {
                                return Ok(new { matched, unmatch, scschoolUnmatch });
                            }
                        }
                        else
                        {
                            matchSchools.ForEach(x =>
                            {
                                var exschool = ignore.Find(y => y.name.Equals(x.schoolname));
                                if (exschool != null)
                                {
                                    x.schoolCode = exschool.id;
                                    x.areaId = $"{areaId}";
                                    x.city = $"{city}";
                                    x.dist = $"{dist}";
                                }
                            });
                        }
                    }
                    else
                    {
                        return Ok(new { unmatch = ignore, schools = schools.Select(x => new { x.schoolname, x.schoolCode, x.schoolid, x.ProjectID, x.ProjectItemID }) });
                    }
                }
            }
            return Ok(new { schools = schools.Select(x => new { x.schoolname, x.schoolCode, x.schoolid, x.ProjectID, x.ProjectItemID }) });
        }
        /// <summary>
        /// 2. 处理 省平台最新的教师以及 反向更新没有绑定醍摩豆id 的账号。
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-project-school")]
        [AllowAnonymous]
        public async Task<IActionResult> GetProjectSchool(JsonElement request)
        {
            if (!request.TryGetProperty("accessConfig", out JsonElement accessConfig)) return BadRequest();
            if (!request.TryGetProperty("city", out JsonElement city)) return BadRequest();
            if (!request.TryGetProperty("dist", out JsonElement dist)) return BadRequest();
            if (!request.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
            if (!request.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
            List<School> ignore = new List<School>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: $"select value(c) from c where c.areaId='{areaId}'",
                requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
            {
                ignore.Add(item);
            }
            Dictionary<string, object> dict = new Dictionary<string, object> { { "accessConfig", $"{accessConfig}" }, { "areaId", $"{areaId}" } };
            int status = -1; string json = null;
            //5.3.1.1获取项目列表
            (status, json) = await _httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetProjectInfoByTrainComID");
            List<ScProject> projects = null;
            List<ScSchool> saveschools = null;
            List<ScSchool> schools = null;
            List<ScSchool> matchSchools = null;
            List<ScSchool> tbschools = null;
            if (status == 200)
            {
                projects = json.ToObject<List<ScProject>>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
            }
            var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");

            // 5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表
            (status, json) = await _httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetSchoolList");           
            if (status == 200)
            {               
                schools = json.ToObject<List<ScSchool>>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
                if (ignore.IsNotEmpty())
                {
                    matchSchools = schools.FindAll(x => ignore.Select(y => y.name).Contains(x.schoolname));
                    if (matchSchools.IsNotEmpty())
                    {
                        if (matchSchools.Count != ignore.Count)
                        {
                            var matched = matchSchools.Select(x => x.schoolname);
                            var unmatch = ignore.Select(y => y.name).Except(matched);
                            List<string> scschoolUnmatch = schools.Select(y => y.schoolname).Except(matched).ToList();
                            if (scschoolUnmatch.IsNotEmpty())
                            {
                                return Ok(new { matched, unmatch, scschoolUnmatch });
                            }
                        }
                        else
                        {
                            matchSchools.ForEach(x =>
                            {
                                var exschool = ignore.Find(y => y.name.Equals(x.schoolname));
                                if (exschool != null)
                                {
                                    x.schoolCode = exschool.id;
                                    x.areaId = $"{areaId}";
                                    x.city = $"{city}";
                                    x.dist = $"{dist}";

                                }
                            });
                        }
                    }
                    else
                    {
                        return Ok(new { unmatch = ignore, schools = schools.Select(x => new { x.schoolname, x.schoolCode, x.schoolid, x.ProjectID, x.ProjectItemID }) });
                    }
                }

                //数据校验
                tbschools = await table.FindListByDict<ScSchool>(new Dictionary<string, object>() { { "PartitionKey", "ScSchool" }, { "areaId", $"{areaId}" } });
                if (tbschools.IsNotEmpty())
                {

                    var a = tbschools.Select(y => $"{y.RowKey}").ToList();
                    saveschools = schools.Where(x => !a.Exists(z => z.Equals($"{x.schoolid}"))).ToList();
                    List<SchoolData> schoolDatas = new();
                    saveschools.ForEach(x =>
                    {
                        x.RowKey = $"{x.schoolid}";
                        x.PartitionKey = "ScSchool";
                        x.areaId = $"{areaId}";
                        x.city = $"{city}";
                        x.dist = $"{dist}";
                        var a = ignore.Find(z => z.name.Equals(x.schoolname));
                        if (a != null)
                        {
                            x.schoolCode = a.id;
                        }
                        else
                        {
                            if (string.IsNullOrEmpty(x.schoolCode))
                            {
                                schoolDatas.Add(new SchoolData { uid = $"{x.schoolid}", province = "四川省", city = $"{city}", name = x.schoolname });
                            }
                        }
                    });
                    schoolDatas = await GenerateSchoolCode(schoolDatas, _dingDing, _environment);
                    saveschools.ForEach(x =>
                    {

                        var schoolData = schoolDatas.Find(y => y.uid.Equals($"{x.schoolid}"));
                        if (schoolData != null && !string.IsNullOrEmpty(schoolData.id))
                        {

                            x.schoolCode = schoolData.id;
                            x.areaId = $"{areaId}";
                            x.city = $"{city}";
                            x.dist = $"{dist}";
                        }
                    });
                    saveschools.RemoveAll(x => string.IsNullOrEmpty(x.schoolCode));
                    saveschools.RemoveAll(x => tbschools.FindAll(z => !string.IsNullOrEmpty(z.schoolCode)).Exists(y => y.schoolCode.Equals(x.schoolCode)));
                    saveschools = await table.SaveAll(saveschools);
                }
                else
                {
                    List<SchoolData> schoolDatas = new List<SchoolData>();
                    schools.ForEach(x =>
                    {
                        x.RowKey = $"{x.schoolid}";
                        x.PartitionKey = "ScSchool";
                        x.areaId = $"{areaId}";
                        x.city = $"{city}";
                        x.dist = $"{dist}";
                        var a = ignore.Find(z => z.name.Equals(x.schoolname));
                        if (a != null)
                        {
                            x.schoolCode = a.id;
                        }
                        else
                        {
                            if (string.IsNullOrEmpty(x.schoolCode))
                            {
                                schoolDatas.Add(new SchoolData { uid = $"{x.schoolid}", province = "四川省", city = $"{city}", name = x.schoolname });
                            }
                        }
                    });
                    schoolDatas = await SchoolService.GenerateSchoolCode(schoolDatas, _dingDing, _environment);
                    schools.ForEach(x =>
                    {
                        var schoolData = schoolDatas.Find(y => y.uid.Equals($"{x.schoolid}"));
                        if (schoolData != null && !string.IsNullOrEmpty(schoolData.id))
                        {
                            x.schoolCode = schoolData.id;
                            x.areaId = $"{areaId}";
                            x.city = $"{city}";
                            x.dist = $"{dist}";

                        }
                    });
                    schools.RemoveAll(x => string.IsNullOrEmpty(x.schoolCode));
                    saveschools = await table.SaveOrUpdateAll(schools);
                }
            }
            List<string> unsave = new List<string>();
            if (saveschools.IsNotEmpty())
            {
                var ex = schools.Select(x => $"{x.schoolid}").Except(saveschools.Select(y => y.RowKey));
                if (ex.Count() > 0)
                {
                    unsave.AddRange(ex);
                }
            }
            if (tbschools.IsNotEmpty())
            {
                var ex = schools.Select(x => $"{x.schoolid}").Except(tbschools.Select(y => y.RowKey));
                if (ex.Count() > 0)
                {
                    unsave.AddRange(ex);
                }
            }

            var areaschools = await table.FindListByDict<ScSchool>(new Dictionary<string, object>() { { "PartitionKey", $"ScSchool" }, { "areaId", $"{areaId}" } });

            List<School> cosbdschools = new List<School>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: $"select value(c) from c where c.areaId='{areaId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
            {
                cosbdschools.Add(item);
            }

            var tbs = areaschools.FindAll(x => areaschools.Select(z => z.schoolCode).Except(cosbdschools.Select(x => x.id)).Contains(x.schoolCode));
            List<CSchool> cSchools = new List<CSchool>();
            foreach (var sch in tbs)
            {
                cSchools.Add(new CSchool
                {
                    id = sch.schoolCode,
                    name = sch.schoolname,
                    // admin = "1530606136",
                    period = new List<string>() { sch.schooltypename },
                    size = 1024,
                });
            }
            var client = _azureCosmos.GetCosmosClient();
            List<School> schoolsfailed = new List<School>();
            List<School> schoolsScucess = new List<School>();
            List<string> failedmsg = new List<string>();
            foreach (var sc in cSchools)
            {
                List<Period> periods = new List<Period>();
                string campusId = Guid.NewGuid().ToString();
                sc.period.ForEach(x =>
                {
                    periods.Add(new Period { id = Guid.NewGuid().ToString(), name = x, campusId = campusId });
                });
                School school = new School
                {
                    id = sc.id,
                    name = sc.name,
                    size = sc.size,
                    code = "Base",
                    campuses = new List<Campus> { new Campus { name = sc.name, id = campusId } },
                    region = "中国",
                    province = "四川省",
                    city = $"{city}",
                    timeZone = new SDK.Models.TimeZone { label = "(UTC+08:00) 北京，重庆，香港特别行政区，乌鲁木齐", value = "+08:00" },
                    type = 1,
                    pk = "School",
                    ttl = -1,
                    schoolCode = sc.id,
                    dist = $"{dist}",
                    period = periods,
                    areaId = $"{areaId}",
                    standard = $"{standard}"
                };
                try
                {
                    await client.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<School>(school, new PartitionKey(school.code));
                    schoolsScucess.Add(school);
                }
                catch (CosmosException ex)
                {
                    failedmsg.Add($"{school.ToJsonString()}\n \n{ex.Status}{ex.Message }\n {ex.StackTrace}");
                    schoolsfailed.Add(school);
                }
                catch (Exception ex)
                {
                    failedmsg.Add($"{school.ToJsonString()}\n{ex.Message }\n {ex.StackTrace}");
                    schoolsfailed.Add(school);
                }
            }
            return Ok(new
            {
                projects,
                msg = $"Table中已经有:{tbschools.Count}个学校，省平台获取到:" +
                $"{schools?.Count}个学校,本次保存有:{saveschools?.Count}，没有被保存的学校:" +
                $"{unsave?.Count}，创建失败的学校有:{schoolsfailed.Count()}，" +
                $"创建成功的的学校有:{schoolsScucess.Count()}",
                schoolsfailed,
                failedmsg,
                schoolsScucess,
                tbsch = tbschools.Select(x => new { x.schoolname, x.schoolCode }),

            });
        }
    }
}