TEAMModelOS/TEAMModelBI/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 System.Text.Json;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using TEAMModelOS.SDK.Models.Cosmos.BI;
using Azure.Messaging.ServiceBus;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models.Service;
using TEAMModelBI.Filter;
using TEAMModelBI.Tool.Extension;
using TEAMModelBI.Tool;
using TEAMModelBI.Tool.Context;
using TEAMModelBI.DI.BIAzureStorage;
using Azure.Storage.Blobs.Models;
using Azure;
using Azure.Storage.Blobs.Specialized;

namespace TEAMModelBI.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(JsonElement jsonElement)
        {
            try
            {
                jsonElement.TryGetProperty("site", out JsonElement site);
                List<RecArea> areas = new();
                var table = _azureStorage.GetCloudTableClient().GetTableReference("IESLogin");
                var azureClient = _azureCosmos.GetCosmosClient();
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    azureClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                    table = _azureStorage.GetCloudTableClient(BIConst.GlobalSite).GetTableReference("IESLogin");
                }

                await foreach (var item in azureClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<RecArea>(queryText: $"select c.id,c.code,c.pk,c.name,c.provCode,c.provName,c.cityCode,c.cityName,c.standard,c.standardName,c.institution from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base-Area") }))
                {
                    areas.Add(item);
                }

                foreach (var recArea in areas)
                {
                    recArea.schoolCount = await CommonFind.GetSqlValueCount(azureClient, "School", $"select value(count(c.id)) from c where c.areaId='{recArea.id}' and c.standard='{recArea.standard}'", "Base");
                    List<AreaQuoteRecord> aqr = await table.QueryWhereString<AreaQuoteRecord>($"PartitionKey eq 'QuoteRecord' and  areaId eq '{recArea.id}'");
                    aqr.Sort((x, y) => y.RowKey.CompareTo(x.RowKey));
                    recArea.aquoteRec = aqr;
                }
                return Ok(new { state = 200, areas });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI,{_option.Location} batcharea/get-areas \n {ex.Message}\n{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 { state = 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}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 批量创区 新接口
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "admin,rdc")]
        [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);
                jsonElement.TryGetProperty("oldId", out JsonElement _oldId);
                jsonElement.TryGetProperty("oldStandard", out JsonElement oldStandard);
                jsonElement.TryGetProperty("oldName", out JsonElement oldName);
                jsonElement.TryGetProperty("site", out JsonElement site);

                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

                //操作记录实体
                var tempStandard = !string.IsNullOrEmpty($"{oldStandard}") && !string.IsNullOrEmpty($"{_oldId}") ? $"{oldStandard}" : "standard2";

                //var table = _azureStorage.GetCloudTableClient().GetTableReference("IESLogin");
                var cosmosClient = _azureCosmos.GetCosmosClient();//数据库连接
                var tableClient = _azureStorage.GetCloudTableClient();
                var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
                var serBusClient = _serviceBus.GetServiceBusClient();
                var activeTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");//秘钥地址
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                    tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                    //serBusClient = _serviceBus.GetServiceBusClient(BIConst.GlobalSite);  //暂未确定使用默认
                    //activeTask = _configuration.GetValue<string>("GlobalAzure:ServiceBus:ActiveTask");   //暂未确定使用默认
                }

                var table = tableClient.GetTableReference("IESLogin");

                //查询新的是否存在
                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"));

                //保存引用记录
                await table.SaveOrUpdate<AreaQuoteRecord>(new AreaQuoteRecord() { PartitionKey = "QuoteRecord", RowKey = $"{DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()}", areaId = $"{areaId}", quoteId = $"{_oldId}", quoteName = $"{oldName}", standard = tempStandard });

                //消息分区键
                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}")));
                    }
                    try
                    {
                        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);
                            }
                        }
                    }
                    catch
                    {
                        return Ok(new { state = 200, msg = "创区成功,能力标准点复制失败，遗留数据影响！" });
                    }

                    try
                    {
                        //微能力点
                        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}"));
                        }
                    }
                    catch
                    {
                        return Ok(new { state = 200, msg = "创区成功,能力标准创建成功，微能力点复制失败，遗留数据影响！" });
                    }

                    //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}")));
                        }

                        try
                        {
                            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);
                                }
                            }
                        }
                        catch
                        {
                            return Ok(new { state = 200, msg = "创区成功,能力标准点复制失败，遗留数据影响！" });
                        }

                        try
                        {
                            //微能力点
                            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}"));
                            }
                        }
                        catch
                        {
                            return Ok(new { state = 200, msg = "创区成功,能力标准创建成功，微能力点复制失败，遗留数据影响！" });
                        }


                        //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");

                try
                {
                    //await  _serviceBus.GetServiceBusClient().SendMessageAsync(activeTask, messageBatchCopyFile);
                    await serBusClient.SendMessageAsync(activeTask, messageBatchCopyFile);
                }
                catch (Exception)
                {
                    return Ok(new { state = 201, msg = "能力点复制成功，复制能力点的文件失败，" });
                }

                //发送消息实体
                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.SaveBILog("area-add", $"{_tmdName}【{_tmdId}】已操作创区功能模块：{name}，当前标准【{standard}】，复制的微能力点：{tempStandard}", _dingDing, httpContext: HttpContext);
                await BIAzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "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}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 创区后切换能力点， 先删除原来的能力点，后复制新的能力点  
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "admin,rdc")]
        [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();
                jsonElement.TryGetProperty("newName", out JsonElement newName);
                jsonElement.TryGetProperty("site", out JsonElement site);

                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
                //操作记录实体
                string blobOrTable = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString();
                var tableClient = _azureStorage.GetCloudTableClient();
                var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
                var cosmosClient = _azureCosmos.GetCosmosClient();
                var serBusClient = _serviceBus.GetServiceBusClient();
                var activeTask = _configuration.GetValue<string>("Azure:ServiceBus:ActiveTask");//秘钥地址
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                    tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                    blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                    serBusClient = _serviceBus.GetServiceBusClient(BIConst.GlobalSite);    //暂未确定使用默认 
                    //activeTask = _configuration.GetValue<string>("GlobalAzure:ServiceBus:ActiveTask");  //暂未确定使用默认
                }
                var table = tableClient.GetTableReference("IESLogin");
                //保存引用记录
                //await table.SaveOrUpdate<AreaQuoteRecord>(new AreaQuoteRecord() { PartitionKey = "QuoteRecord", RowKey = $"{DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()}", areaId = $"{_oldId}", quoteId = $"{_newId}", quoteName = $"{newName}", standard = $"{_newStandard}" });

                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集合
                await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c", 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}")));
                }

                try
                {
                    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);
                        }
                    }
                }
                catch
                {
                    return Ok(new { state = 200, msg = "创区成功,能力标准点复制失败，遗留数据影响！" });
                }

                try
                {
                    //微能力点
                    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();
                        foreach (Tnode tnode in atask.children)
                        {
                            if (tnode.rnodes != null)
                            {
                                List<Rnode> rnodes = new();
                                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}"));
                    }

                }
                catch
                {
                    return Ok(new { state = 200, msg = "创区成功,能力标准创建成功，微能力点复制失败，遗留数据影响！" });
                }

                StandardFile saveFile = new();

                //新政策文件
                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}";

                        saveFile = standardFile;
                    }
                }
                StandardFile tempFile = new();
                try
                {
                    tempFile = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<StandardFile>(saveFile.id, new PartitionKey("StandardFile"));
                }
                catch
                {
                }
                if (tempFile.id != null)
                {
                    if (tempFile.id.Equals(saveFile.id))
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReplaceItemAsync<StandardFile>(saveFile, saveFile.id, new PartitionKey("StandardFile")); //直接替换以前的数据
                    else
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(saveFile, new PartitionKey($"StandardFile")); // 需要删除原来的政策文件数据在进行添加
                }

                //新的区域设置
                AreaSetting saveSetting = new AreaSetting();
                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}";

                        saveSetting = areaSetting;
                    }
                }

                AreaSetting tempSetting = new();
                try
                {
                    tempSetting = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemAsync<AreaSetting>(saveSetting.id, new PartitionKey("StandardFile"));
                }
                catch
                {
                }
                if (tempSetting.id != null)
                {
                    if (tempSetting.id.Equals(saveSetting.id))
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReplaceItemAsync<AreaSetting>(saveSetting, saveSetting.id, new PartitionKey($"AreaSetting"));   //直接替换以前的数据
                    else
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").CreateItemAsync(saveSetting, 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");  
                try
                {
                    //await _serviceBus.GetServiceBusClient().SendMessageAsync(activeTask, messageBatchCopyFile);  //先执行删除操作，在执行复制  单一
                    await serBusClient.SendMessageAsync(activeTask, messageBatchCopyFile);  //先执行删除操作，在执行复制
                }
                catch (Exception)
                {
                    return Ok(new { state = 201 ,msg = "能力点复制成功，复制能力点的文件失败，" });
                }

                //发送消息实体
                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.SaveBILog("area-cut", $"{_tmdName}【{_tmdId}】已操作【{_oldStandard}】切换至{_newStandard}微能力点，复制标准：{_newStandard}", _dingDing, httpContext: HttpContext);
                await BIAzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "area-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}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 删除区域和区域的册别、能力点、区域文件、区域设置
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [HttpPost("del-area")]
        public async Task<IActionResult> DelArea(JsonElement jsonElement) 
        {
            if (!jsonElement.TryGetProperty("areaId", out JsonElement areaId)) return BadRequest();
            if (!jsonElement.TryGetProperty("standard", out JsonElement standard)) return BadRequest();
            jsonElement.TryGetProperty("site", out JsonElement site);
            var blobClient = _azureStorage.GetBlobContainerClient(containerName: "teammodelos");
            var cosmosClient = _azureCosmos.GetCosmosClient();
            if ($"{site}".Equals(BIConst.GlobalSite))
            {
                cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                blobClient = _azureStorage.GetBlobContainerClient(containerName: "teammodelos", BIConst.GlobalSite);
            }

            var response = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync("areaId", new PartitionKey("Base-Area"));
            if (response.Status == 200)
            {
                using var json = await JsonDocument.ParseAsync(response.ContentStream);
                Area area = json.ToObject<Area>();
                if (area.standard == $"{standard}") 
                {
                    //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemAsync<Area>(area.id, new PartitionKey("Base-Area")); //删除区

                    List<string> abilityIds = new();  //册别的ID集合
                    List<string> abilityTaskIds = new();  //章节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-{area.standard}") }))
                    {
                        abilityIds.Add(tempAbility.id);  //查询出来册别ID添加册别ID集合
                    }
                    //删除册别
                    if (abilityIds.IsNotEmpty())
                    {
                        //var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityIds, $"Ability-{area.standard}");
                    }

                    await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{area.standard}") }))
                    {
                        abilityTaskIds.Add(item.id);   //查询出来的章节信息ID添加到战绩集合
                    }
                    //删除章节
                    if (abilityTaskIds.IsNotEmpty())
                    {
                        //var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityTaskIds, $"AbilityTask-{_oldStandard}");
                    }
                    //区域政策文件
                    StandardFile delFile = new();
                    var responseFile = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync(area.id, new PartitionKey("StandardFile"));
                    if(responseFile.Status == 200)
                    {
                        using var fileJson = await JsonDocument.ParseAsync(responseFile.ContentStream);
                        delFile = fileJson.ToObject<StandardFile>();
                        //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemAsync<StandardFile>(delFile.id, new PartitionKey("StandardFile"));
                    }

                    //区域设置
                    AreaSetting delSet = new();
                    var responseSet = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").ReadItemStreamAsync(area.id, new PartitionKey("StandardFile"));
                    if (responseFile.Status == 200)
                    {
                        using var fileJson = await JsonDocument.ParseAsync(responseFile.ContentStream);
                        delSet = fileJson.ToObject<AreaSetting>();
                        //await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemAsync<AreaSetting>(delSet.id, new PartitionKey("AreaSetting"));
                    }

                    List<object> fileobj = new();
                    //先删除原有的文件
                    List<Task<Response<bool>>> DelList = new List<Task<Response<bool>>>();
                    await foreach (BlobItem blobItem in blobClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, $"yxpt/{area.standard}/"))
                    {
                        fileobj.Add(blobItem);
                        //DelList.Add(blobClient.GetBlobBaseClient(blobItem.Name).DeleteIfExistsAsync());
                    }

                    //if (DelList.Count <= 256)
                    //{
                    //    await Task.WhenAll(DelList);
                    //}
                    //else
                    //{
                    //    int pages = (DelList.Count + 255) / 256;
                    //    for (int i = 0; i < pages; i++)
                    //    {
                    //        List<Task<Response<bool>>> delList = DelList.Skip((i) * 256).Take(256).ToList();
                    //        await Task.WhenAll(delList);
                    //    }
                    //}

                    return Ok(new { state = 200,area, abilityIds, abilityTaskIds, });
                }
                else return Ok(new { state = 400, msg = "id和standard不匹配！" });
            }
            else return Ok(new { state = 404,msg="依据Id未找到该区！" });
        }

        /// <summary>
        /// 区域列表
        /// </summary>
        public record RecArea
        {
            public string id { get; set; }
            public string code { get; set; }
            public string pk { get; set; }
            public string name { get; set; }
            public string provCode { get; set; }
            public string provName { get; set; }
            public string cityCode { get; set; }
            public string cityName { get; set; }
            public string standard { get; set; }
            public string standardName { get; set; }
            public string institution { get; set; }
            public int schoolCount { get; set; }
            public List<AreaQuoteRecord> aquoteRec { get; set; } = new List<AreaQuoteRecord>();
        }
    }
}