TEAMModelOS/TEAMModeBI/Controllers/BISchool/BatchAreaController.cs

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Models;
using Azure.Cosmos;
using DingTalk.Api;
using DingTalk.Api.Request;
using DingTalk.Api.Response;
using System.Text.Json;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.Services.Common;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using Azure.Storage.Blobs.Models;
using Azure.Storage.Blobs;
using System.Text;
using Azure.Storage.Sas;
using Azure.Storage.Blobs.Specialized;
using Azure;
using TEAMModelOS.SDK.Models.Cosmos.BI;
using Azure.Messaging.ServiceBus;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models.Service;
using TEAMModeBI.Filter;

namespace TEAMModeBI.Controllers.BISchool
{
    [Route("batcharea")]
    [ApiController]
    public class BatchAreaController : ControllerBase
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureStorageFactory _azureStorage;
        private readonly IConfiguration _configuration;
        private readonly NotificationService _notificationService;
        private readonly AzureServiceBusFactory _serviceBus;

        public BatchAreaController(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, IOptionsSnapshot<Option> option, IConfiguration configuration, NotificationService notificationService, AzureServiceBusFactory serviceBus)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _azureStorage = azureStorage;
            _option = option?.Value;
            _configuration = configuration;
            _notificationService = notificationService;
            _serviceBus = serviceBus;
        }

        /// <summary>
        /// 查询所有的区域标准
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-areas")]
        public async Task<IActionResult> GetArea()
        {
            try
            {
                List<Area> areas = new List<Area>();
                var azureClient = _azureCosmos.GetCosmosClient();
                await foreach (var item in azureClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: $"select * from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
                {
                    areas.Add(item);
                }

                return Ok(new { state = 200, areas });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI,{_option.Location} batcharea/get-areas \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 批量创区 
        /// </summary>
        /// <param name="areas"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("upd-area")]
        public async Task<IActionResult> batchCreateArea(List<Area> areas)
        {
            try
            {
                List<Area> standards = new List<Area>();
                bool isCreate = true;
                if (areas.Count > 0)
                {
                    foreach (Area itemarea in areas)
                    {
                        await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
                        {
                            if (item.standard.Equals(itemarea.standard))
                            {
                                standards.Add(itemarea);
                                isCreate = false;
                            }
                        }

                        if (isCreate == true)
                        {
                            Area addArea = new Area()
                            {
                                id = Guid.NewGuid().ToString(),
                                code = $"Base-Area",
                                name = itemarea.name,
                                provCode = itemarea.provCode,
                                provName = itemarea.provName,
                                cityCode = itemarea.cityCode,
                                cityName = itemarea.cityName,
                                standard = itemarea.standard,
                                standardName = itemarea.standardName,
                                institution = itemarea.institution
                            };

                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync<Area>(addArea, new PartitionKey("Base-Area"));
                        }
                    }
                }
                else return Ok(new { sate = 1, message = "区域参数为空" });
                if (standards.Count > 0)
                    return Ok(new { state = 201, message = "已有部分区域批量创建成功；标准项已重复！请检查标准项！", standards = standards });
                else return Ok(new { state = 200, message = "批量创区全部完成", });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI,{_option.Location} batcharea/batch-createarea \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 批量创区 新接口
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("batch-area")]
        public async Task<IActionResult> batchArea(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("name", out JsonElement name)) return BadRequest();
                jsonElement.TryGetProperty("provCode", out JsonElement provCode);
                jsonElement.TryGetProperty("provName", out JsonElement provName);
                jsonElement.TryGetProperty("cityCode", out JsonElement cityCode);
                jsonElement.TryGetProperty("cityName", out JsonElement cityName);
                if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
                if (!jsonElement.TryGetProperty("standardName", out JsonElement standardName)) return BadRequest();
                jsonElement.TryGetProperty("institution", out JsonElement institution);
                if (!jsonElement.TryGetProperty("tmdId", out JsonElement _tmdId)) return BadRequest();
                if (!jsonElement.TryGetProperty("tmdName", out JsonElement _tmdName)) return BadRequest();
                jsonElement.TryGetProperty("oldId", out JsonElement _oldId);
                jsonElement.TryGetProperty("oldStandard", out JsonElement oldStandard);

                //操作记录实体
                var tempStandard = !string.IsNullOrEmpty($"{oldStandard}") && !string.IsNullOrEmpty($"{_oldId}") ? $"{oldStandard}" : "standard2";
                
                var cosmosClient = _azureCosmos.GetCosmosClient();//数据库连接
                //查询新的是否存在
                await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: $"select value(c) from c where c.standard='{standard}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
                {
                    if (item.standard.Equals($"{standard}"))
                    {
                        return Ok(new { state = 1, message = "新创区的standard已存在请检查" });
                    }
                }

                //区级的ID
                string areaId = Guid.NewGuid().ToString();
                Area addArea = new Area()
                {
                    id = areaId,
                    code = $"Base-Area",
                    name = $"{name}",
                    provCode = $"{provCode}",
                    provName = $"{provName}",
                    cityCode = $"{cityCode}",
                    cityName = $"{cityName}",
                    standard = $"{standard}",
                    standardName = $"{standardName}",
                    institution = $"{institution}"
                };

                //创建区域
                await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync<Area>(addArea, new PartitionKey("Base-Area"));

                //消息分区键
                string partitionCode = "copyAbility-mark";

                #region 使用Function创区
                //string areaCode = "copyArea-mark";
                //BatchCopyAreaRelevant bCopyArea = new BatchCopyAreaRelevant()
                //{
                //    tmdid = $"{_tmdId}",
                //    tmdName = $"{_tmdName}",
                //    codeKey = areaCode,
                //    tmdIds = new List<string> { $"{_tmdId}"},
                //    oldStandard = $"{oldStandard}",
                //    oldId = $"{_oldId}",
                //    standard = $"{standard}",
                //    areaId = areaId,
                //    cut="",
                //};
                //var messageBatchCopyArea = new ServiceBusMessage(bCopyArea.ToJsonString());
                //messageBatchCopyArea.ApplicationProperties.Add("name", "CopyAreaRelevant");
                //var activeTaskArea = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                //await _serviceBus.GetServiceBusClient().SendMessageAsync(activeTaskArea, messageBatchCopyArea);
                #endregion

                #region 旧的批量创区

                List<Task<ItemResponse<Ability>>> abilities = new List<Task<ItemResponse<Ability>>>();      //存储区域数据
                List<Task<ItemResponse<AbilityTask>>> abilityTasks = new List<Task<ItemResponse<AbilityTask>>>();  //存储章节

                if (!string.IsNullOrEmpty($"{oldStandard}") && !string.IsNullOrEmpty($"{_oldId}"))
                {
                    //查询要复制区域的能力标准点 
                    await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Ability>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{oldStandard}") }))
                    {
                        if (!string.IsNullOrEmpty(item.blob))
                        {
                            item.blob = item.blob.Replace($"/{oldStandard}/", $"/{standard}/");
                        };

                        item.standard = $"{standard}";
                        item.code = $"Ability-{standard}";
                        item.school = $"{standard}";

                        //添加区能力标准点
                        abilities.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(item, new PartitionKey($"Ability-{standard}")));
                    }

                    if (abilities.Count < 256)
                    {
                        await Task.WhenAll(abilities);
                    }
                    else
                    {
                        int pages = (abilities.Count + 255) / 256;
                        for (int i = 0; i < pages; i++)
                        {
                            List<Task<ItemResponse<Ability>>> tempAbility = abilities.Skip((i) * 256).Take(256).ToList();
                            await Task.WhenAll(tempAbility);
                        }
                    }

                    //微能力点
                    await foreach (var atask in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{oldStandard}") }))
                    {
                        List<Tnode> tnodes = new List<Tnode>();
                        foreach (Tnode tnode in atask.children)
                        {
                            if (tnode.rnodes != null)
                            {
                                List<Rnode> rnodes = new List<Rnode>();
                                foreach (Rnode rnode in tnode.rnodes)
                                {
                                    if (!string.IsNullOrEmpty($"{rnode.link}"))
                                    {
                                        rnode.link = rnode.link.Replace($"/{oldStandard}/", $"/{standard}/");
                                    }
                                    rnodes.Add(rnode);
                                }
                                tnode.rnodes = rnodes;
                            }
                            tnodes.Add(tnode);
                        }

                        atask.children = tnodes;
                        atask.code = $"AbilityTask-{standard}";
                        atask.standard = $"{standard}";
                        atask.codeval = $"{standard}";

                        //添加区能力标准点中的节点 
                        //abilityTasks.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{standard}")));
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{standard}"));
                    }

                    //if (abilityTasks.Count > 0) 
                    //{
                    //    for (int i = 0; i < abilityTasks.Count; i++)
                    //    {
                    //        List<Task<ItemResponse<AbilityTask>>> tempAbilityTasks = abilityTasks.Skip((i)).Take(1).ToList();
                    //        await Task.WhenAll(tempAbilityTasks);
                    //    }
                    //}

                    //新政策文件
                    await foreach (StandardFile standardFile in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<StandardFile>(queryText: $"select value(c) from c where  c.id='{_oldId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"StandardFile") }))
                    {
                        if (standardFile != null)
                        {
                            standardFile.standard = $"{standard}";
                            standardFile.id = areaId;
                            await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(standardFile, new PartitionKey($"StandardFile"));
                        }
                    }

                    //新的区域设置
                    await foreach (AreaSetting areaSetting in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: $"select value(c) from c where c.id='{_oldId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
                    {
                        if (areaSetting != null)
                        {
                            areaSetting.accessConfig = null;
                            areaSetting.id = areaId;
                            await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(areaSetting, new PartitionKey($"AreaSetting"));
                        }
                    }
                }
                else
                {
                    Area area = null;
                    await foreach (var tempArea in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Area>(queryText: $"select value(c) from c where c.standard='standard2'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base-Area") }))
                    {
                        area = tempArea;
                    }
                    if (area != null)
                    {
                        //查询要复制区域的能力标准点 
                        await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Ability>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{area.standard}") }))
                        {
                            if (!string.IsNullOrEmpty(item.blob))
                            {
                                item.blob = item.blob.Replace($"/{area.standard}/", $"/{standard}/");
                            };

                            item.standard = $"{standard}";
                            item.code = $"Ability-{standard}";
                            item.school = $"{standard}";

                            //添加区能力标准点
                            abilities.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(item, new PartitionKey($"Ability-{standard}")));
                        }

                        if (abilities.Count < 256)
                        {
                            await Task.WhenAll(abilities);
                        }
                        else
                        {
                            int pages = (abilities.Count + 255) / 256;
                            for (int i = 0; i < pages; i++)
                            {
                                List<Task<ItemResponse<Ability>>> tempAbility = abilities.Skip((i) * 256).Take(256).ToList();
                                await Task.WhenAll(tempAbility);
                            }
                        }

                        //微能力点
                        await foreach (var atask in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{area.standard}") }))
                        {
                            List<Tnode> tnodes = new List<Tnode>();
                            foreach (Tnode tnode in atask.children)
                            {
                                if (tnode.rnodes != null)
                                {
                                    List<Rnode> rnodes = new List<Rnode>();
                                    foreach (Rnode rnode in tnode.rnodes)
                                    {
                                        if (!string.IsNullOrEmpty($"{rnode.link}"))
                                        {
                                            rnode.link = rnode.link.Replace($"/{area.standard}/", $"/{standard}/");
                                        }
                                        rnodes.Add(rnode);
                                    }
                                    tnode.rnodes = rnodes;
                                }
                                tnodes.Add(tnode);
                            }

                            atask.children = tnodes;
                            atask.code = $"AbilityTask-{standard}";
                            atask.standard = $"{standard}";
                            atask.codeval = $"{standard}";

                            //添加区能力标准点中的节点 
                            //abilityTasks.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{standard}")));
                            await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{standard}"));
                        }

                        //if (abilityTasks.Count > 0)
                        //{
                        //    for (int i = 0; i < abilityTasks.Count; i++)
                        //    {
                        //        List<Task<ItemResponse<AbilityTask>>> tempAbilityTasks = abilityTasks.Skip(i).Take(1).ToList();
                        //        await Task.WhenAll(tempAbilityTasks);
                        //    }
                        //}

                        //新政策文件
                        await foreach (StandardFile standardFile in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<StandardFile>(queryText: $"select value(c) from c where  c.id='{area.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"StandardFile") }))
                        {
                            if (standardFile != null)
                            {
                                standardFile.standard = $"{standard}";
                                standardFile.id = areaId;
                                await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(standardFile, new PartitionKey($"StandardFile"));
                            }
                        }

                        //新的区域设置
                        await foreach (AreaSetting areaSetting in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: $"select value(c) from c where c.id='{area.id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
                        {
                            if (areaSetting != null)
                            {
                                areaSetting.accessConfig = null;
                                areaSetting.id = areaId;
                                await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(areaSetting, new PartitionKey($"AreaSetting"));
                            }
                        }
                    }
                    else return Ok(new { state = 201, message = "未找到默认能力点!" });
                }

                #endregion

                //执行复制操作
                BatchCopyFile batchCopyFile = new BatchCopyFile();
                batchCopyFile.blobCntr = "teammodelos";
                batchCopyFile.oldFileName = $"{oldStandard}";
                batchCopyFile.newFileName = $"{standard}";
                batchCopyFile.tmdid = $"{_tmdId}";
                batchCopyFile.tmdIds = new List<string> { $"{ _tmdId}" };
                batchCopyFile.codeKey = partitionCode;
                batchCopyFile.tmdName = $"{_tmdName}";
                var messageBatchCopyFile = new ServiceBusMessage(batchCopyFile.ToJsonString());
                messageBatchCopyFile.ApplicationProperties.Add("name", "CopyStandardFile");
                var activeTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                await _serviceBus.GetServiceBusClient().SendMessageAsync(activeTask, messageBatchCopyFile);

                //发送消息实体
                Notification notification = new Notification
                {
                    hubName = "hita",
                    type = "msg",
                    from = $"ies5:{_option.Location}:private",
                    to = new List<string> { $"{ _tmdId}" },
                    label = $"{partitionCode}_start",
                    body = new { location = _option.Location, biz = partitionCode, tmdid = $"{_tmdId}", tmdname = $"{_tmdName}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
                    expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
                };

                var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
                var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                var location = _option.Location;
                await _notificationService.SendNotification(clientID, clientSecret, location, url, notification); //站内发送消息

                //保存操作记录
                await _azureStorage.SaveLog("area-add", $"{_tmdName}【{_tmdId}】已操作创区功能模块：{name}，当前标准【{standard}】，复制的微能力点：{tempStandard}", _dingDing, httpContext: HttpContext);

                return Ok(new { state = 200, area = addArea });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI,{_option.Location}  /batcharea/batch-area \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 创区后切换能力点， 先删除原来的能力点，后复制新的能力点  
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("cut-standard")]
        public async Task<IActionResult> CutStandard(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("oldId", out JsonElement _oldId)) return BadRequest();
                if (!jsonElement.TryGetProperty("oldStandard", out JsonElement _oldStandard)) return BadRequest();
                if (!jsonElement.TryGetProperty("newId", out JsonElement _newId)) return BadRequest();
                if (!jsonElement.TryGetProperty("newStandard", out JsonElement _newStandard)) return BadRequest();
                if (!jsonElement.TryGetProperty("tmdId", out JsonElement _tmdId)) return BadRequest();
                if (!jsonElement.TryGetProperty("tmdName", out JsonElement _tmdName)) return BadRequest();

                //操作记录实体
                string blobOrTable = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString();
                
                var cosmosClient = _azureCosmos.GetCosmosClient();

                List<string> abilityIds = new List<string>();  //册别的ID集合

                //查询册别信息
                await foreach (var tempAbility in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Ability>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{_oldStandard}") }))
                {
                    abilityIds.Add(tempAbility.id);  //查询出来册别ID添加册别ID集合
                }
                //删除册别
                if (abilityIds.IsNotEmpty())
                {
                    var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityIds, $"Ability-{_oldStandard}");
                }

                List<string> abilityTaskIds = new List<string>();  //章节ID集合
                foreach (var abilityId in abilityIds)
                {
                    await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c where c.abilityId='{abilityId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{_oldStandard}") }))
                    {
                        abilityTaskIds.Add(item.id);   //查询出来的章节信息ID添加到战绩集合
                    }
                }
                //删除章节
                if (abilityTaskIds.IsNotEmpty())
                {
                    var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityTaskIds, $"AbilityTask-{_oldStandard}");
                }

                List<Task<ItemResponse<Ability>>> abilities = new List<Task<ItemResponse<Ability>>>();      //存储册别数据
                List<Task<ItemResponse<AbilityTask>>> abilityTasks = new List<Task<ItemResponse<AbilityTask>>>();  //存储章节

                //查询要复制区域的能力标准点 
                await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Ability>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{_newStandard}") }))
                {
                    if (!string.IsNullOrEmpty(item.blob))
                    {
                        item.blob = item.blob.Replace($"/{_newStandard}/", $"/{_oldStandard}/");
                    };

                    item.standard = $"{_oldStandard}";
                    item.code = $"Ability-{_oldStandard}";
                    item.school = $"{_oldStandard}";

                    //添加区能力标准点
                    abilities.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(item, new PartitionKey($"Ability-{_oldStandard}")));
                }

                if (abilities.Count < 256)
                {
                    await Task.WhenAll(abilities);
                }
                else
                {
                    int pages = (abilities.Count + 255) / 256;
                    for (int i = 0; i < pages; i++)
                    {
                        List<Task<ItemResponse<Ability>>> tempAbility = abilities.Skip((i) * 256).Take(256).ToList();
                        await Task.WhenAll(tempAbility);
                    }
                }

                //微能力点
                await foreach (var atask in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c ", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{_newStandard}") }))
                {
                    List<Tnode> tnodes = new List<Tnode>();
                    foreach (Tnode tnode in atask.children)
                    {
                        if (tnode.rnodes != null)
                        {
                            List<Rnode> rnodes = new List<Rnode>();
                            foreach (Rnode rnode in tnode.rnodes)
                            {
                                if (!string.IsNullOrEmpty($"{rnode.link}"))
                                {
                                    rnode.link = rnode.link.Replace($"/{_newStandard}/", $"/{_oldStandard}/");
                                }
                                rnodes.Add(rnode);
                            }
                            tnode.rnodes = rnodes;
                        }
                        tnodes.Add(tnode);
                    }

                    atask.children = tnodes;
                    atask.code = $"AbilityTask-{_oldStandard}";
                    atask.standard = $"{_oldStandard}";
                    atask.codeval = $"{_oldStandard}";

                    ////添加区能力标准点中的节点 
                    //abilityTasks.Add(cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{_oldStandard}")));
                    await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(atask, new PartitionKey($"AbilityTask-{_oldStandard}"));
                }

                //新政策文件
                await foreach (StandardFile standardFile in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<StandardFile>(queryText: $"select value(c) from c where  c.id='{_newId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"StandardFile") }))
                {
                    if (standardFile != null)
                    {
                        standardFile.standard = $"{_oldStandard}";
                        standardFile.id = $"{_oldId}";
                        //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(standardFile, new PartitionKey($"StandardFile")); // 需要删除原来的政策文件数据在进行添加
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReplaceItemAsync<StandardFile>(standardFile, standardFile.id, new PartitionKey("StandardFile")); //直接替换以前的数据
                    }
                }

                //新的区域设置
                await foreach (AreaSetting areaSetting in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: $"select value(c) from c where c.id='{_newId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("AreaSetting") }))
                {
                    if (areaSetting != null)
                    {
                        areaSetting.accessConfig = null;
                        areaSetting.id = $"{_oldId}";
                        //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(areaSetting, new PartitionKey($"AreaSetting"));  //需要删除原来的区域设置数据在进行添加
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReplaceItemAsync<AreaSetting>(areaSetting, areaSetting.id, new PartitionKey($"AreaSetting"));   //直接替换以前的数据
                    }
                }

                //发送消息分区键
                string partitionCode = "DelBeforeCopyAbility-mark";

                //执行复制操作
                BatchCopyFile batchCopyFile = new BatchCopyFile();
                batchCopyFile.blobCntr = "teammodelos";
                batchCopyFile.oldFileName = $"{_newStandard}";
                batchCopyFile.newFileName = $"{_oldStandard}";
                batchCopyFile.tmdid = $"{_tmdId}";
                batchCopyFile.tmdIds = new List<string> { $"{ _tmdId}" };
                batchCopyFile.codeKey = partitionCode;
                batchCopyFile.tmdName = $"{_tmdName}";
                var messageBatchCopyFile = new ServiceBusMessage(batchCopyFile.ToJsonString());
                messageBatchCopyFile.ApplicationProperties.Add("name", "CopyStandardFile");   //Function暂时还未写
                var activeTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");
                await _serviceBus.GetServiceBusClient().SendMessageAsync(activeTask, messageBatchCopyFile);  //先执行删除操作，在执行复制

                //发送消息实体
                Notification notification = new Notification
                {
                    hubName = "hita",
                    type = "msg",
                    from = $"BI:{_option.Location}:private",
                    to = new List<string> { $"{ _tmdId}" },
                    label = $"{partitionCode}_start",
                    body = new { location = _option.Location, biz = partitionCode, tmdid = $"{_tmdId}", tmdname = $"{_tmdName}", status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
                    expires = DateTimeOffset.UtcNow.AddDays(7).ToUnixTimeSeconds()
                };

                var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
                var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
                var location = _option.Location;
                await _notificationService.SendNotification(clientID, clientSecret, location, url, notification); //发送站内发送消息

                //保存操作记录
                await _azureStorage.SaveLog("standard-cut", $"{_tmdName}【{_tmdId}】已操作【{_oldStandard}】切换至{_newStandard}微能力点，复制标准：{_newStandard}", _dingDing, httpContext: HttpContext);

                return Ok(new { state = 200 });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI,{_option.Location}   batcharea/cut-standard \n  {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

    }

}