TEAMModelOS/TEAMModelOS/Controllers/XTest/TestController.cs

using Azure.Cosmos;
using Azure.Messaging.ServiceBus;
using Azure.Storage.Blobs.Models;
using HTEXLib.Helpers.ShapeHelpers;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.International.Converters.PinYinConverter;
using Microsoft.International.Converters.TraditionalChineseToSimplifiedConverter;
using Newtonsoft.Json;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Json;
using System.Text;
using System.Text.Json;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using TEAMModelOS.Services.Common;

namespace TEAMModelOS.Controllers
{
    [Route("test")]
    [ApiController]
    public class TestController : ControllerBase
    {
        public IWebHostEnvironment _environment { get; set; }
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly AzureServiceBusFactory _serviceBus;
        public IConfiguration _configuration { get; set; }
        public TestController(IWebHostEnvironment environment, AzureCosmosFactory azureCosmos, AzureRedisFactory azureRedis, AzureStorageFactory azureStorage, IConfiguration configuration, AzureServiceBusFactory serviceBus, DingDing dingDing)
        {
            _azureCosmos = azureCosmos;
            _azureRedis = azureRedis;
            _azureStorage = azureStorage;
            _dingDing = dingDing;
            _serviceBus = serviceBus; _configuration = configuration;
            _environment = environment;
        }
        public static List<string> comeRemoveStr = new List<string>() { "省", "市", "区", "州", "县", "旗", "盟", "自治" };
        public static List<string> prvcRemoveStr = new List<string>() { "回族", "维吾尔", "壮族", };
        public static List<string> cityRemoveStr = new List<string>() { "蒙古族", "地区", "壮族", "朝鲜族", "直辖" };
        public static List<string> nationRemoveStr = new List<string> {
            "维吾尔","回族", "自治", "满族", "蒙古", "壮族", "苗族" , "侗族", "瑶族",
            "达斡尔","鄂温克","朝鲜","畲族","土家","各族","仫佬","毛南","羌族","彝族","仡佬","布依","水族",
            "傣族","纳西","哈尼","拉祜","佤族","傈僳","独龙","怒族","白族","普米","固族","哈萨克","土族","撒拉","景颇","族"
        };
        public static List<string> schooRemoveStr = new List<string>() {"（","）", "(",")","省", "市", "校区", "区", "州", "县", "旗", "盟", "自治",
            "第","学校","校园","镇","村","乡","街","路","部","楼","与","站","馆","街道","办事处","义务"
        };
        public static List<KeyValuePair<string, string>> areaRemoveStr = new List<KeyValuePair<string, string>>{
             new KeyValuePair<string, string>("国际", "际") ,
            new KeyValuePair<string, string>("中国", ""),
            new KeyValuePair<string, string>("国家", ""),
            new KeyValuePair<string, string>("新区", ""),
            new KeyValuePair<string, string>("高新", "高"),
            new KeyValuePair<string, string>("园区", ""),
            new KeyValuePair<string, string>("产业", "产"),
            new KeyValuePair<string, string>("经济", "经"),
            new KeyValuePair<string, string>("开发", "开"),
            new KeyValuePair<string, string>("中心", "") ,
            new KeyValuePair<string, string>("集团", "") ,
            new KeyValuePair<string, string>("公司", "") ,
            new KeyValuePair<string, string>("有限", "") ,
            new KeyValuePair<string, string>("股份", "") ,
            new KeyValuePair<string, string>("服务", "") ,
            new KeyValuePair<string, string>("基地", "") ,
            new KeyValuePair<string, string>("社区", "社") ,
            new KeyValuePair<string, string>("职工", "") ,
            new KeyValuePair<string, string>("专修", "")
            ,
        };
        public static List<KeyValuePair<string, string>> schooReplaceStr = new List<KeyValuePair<string, string>> {
            new KeyValuePair<string, string>("职业技术学院", "职技") ,
            new KeyValuePair<string, string>("创新创业", "创") ,
            new KeyValuePair<string, string>("就业创业", "就") ,
            new KeyValuePair<string, string>("应用核技术", "核") ,
            new KeyValuePair<string, string>("职业学院", "职") ,
            new KeyValuePair<string, string>("幼儿园", "幼") ,
            new KeyValuePair<string, string>("幼儿", "幼") ,
            new KeyValuePair<string, string>("小学", "小") ,
            new KeyValuePair<string, string>("中学", "中") ,
            new KeyValuePair<string, string>("中专", "中") ,
            new KeyValuePair<string, string>("初中", "初") ,
            new KeyValuePair<string, string>("初级", "初") ,
            new KeyValuePair<string, string>("高中", "高") ,
            new KeyValuePair<string, string>("高级", "高") ,
            new KeyValuePair<string, string>("大学", "大") ,
            new KeyValuePair<string, string>("学院", "院") ,
            new KeyValuePair<string, string>("职业", "职") ,
            new KeyValuePair<string, string>("技术", "技") ,
            new KeyValuePair<string, string>("专科", "专") ,
            new KeyValuePair<string, string>("外国语", "外") ,
            new KeyValuePair<string, string>("实验", "验") ,
            new KeyValuePair<string, string>("年制", "制") ,
            new KeyValuePair<string, string>("高等", "高") ,
            new KeyValuePair<string, string>("分校", "分") ,
            new KeyValuePair<string, string>("分园", "分") ,
            new KeyValuePair<string, string>("分院", "分") ,
            new KeyValuePair<string, string>("院校", "院") ,
            new KeyValuePair<string, string>("初等", "小") ,
            new KeyValuePair<string, string>("附属", "附"),
            new KeyValuePair<string, string>("五年", "五") ,
            new KeyValuePair<string, string>("卫生", "卫") ,
            new KeyValuePair<string, string>("九年", "九") ,
            new KeyValuePair<string, string>("创业", "创") ,
            new KeyValuePair<string, string>("继续", "继") ,
            new KeyValuePair<string, string>("开放", "开") ,
            new KeyValuePair<string, string>("技师", "技") ,
            new KeyValuePair<string, string>("成人", "成") ,
            new KeyValuePair<string, string>("教育", "教") ,
            new KeyValuePair<string, string>("科技", "科") ,
            new KeyValuePair<string, string>("行政", "政") ,
            new KeyValuePair<string, string>("生物", "生") ,
            new KeyValuePair<string, string>("美术", "美") ,
            new KeyValuePair<string, string>("设计", "设") ,
            new KeyValuePair<string, string>("传播", "传") ,
            new KeyValuePair<string, string>("计算机", "算") ,
            new KeyValuePair<string, string>("土木", "土") ,
            new KeyValuePair<string, string>("石油", "油") ,
            new KeyValuePair<string, string>("科普", "普") ,
            new KeyValuePair<string, string>("电信", "信") ,
            new KeyValuePair<string, string>("联合", "联") ,
            new KeyValuePair<string, string>("电商", "商") ,
            new KeyValuePair<string, string>("纺织", "织") ,
            new KeyValuePair<string, string>("服装", "服") ,
            new KeyValuePair<string, string>("新闻", "新") ,
            new KeyValuePair<string, string>("网络", "网") ,
            new KeyValuePair<string, string>("应用", "应") ,
            new KeyValuePair<string, string>("畜牧", "畜") ,
            new KeyValuePair<string, string>("兽医", "兽") ,
            new KeyValuePair<string, string>("师范", "师") ,
            new KeyValuePair<string, string>("人文", "文") ,
            new KeyValuePair<string, string>("创新", "创") ,
            new KeyValuePair<string, string>("法官", "法") ,
            new KeyValuePair<string, string>("邮电", "邮") ,
            new KeyValuePair<string, string>("文化", "文") ,
            new KeyValuePair<string, string>("函授", "函") ,
            new KeyValuePair<string, string>("科学", "科") ,
            new KeyValuePair<string, string>("信息", "息") ,
            new KeyValuePair<string, string>("水利", "利") ,
            new KeyValuePair<string, string>("水电", "电") ,
            new KeyValuePair<string, string>("电力", "力") ,
            new KeyValuePair<string, string>("环境", "环") ,
            new KeyValuePair<string, string>("建材", "材") ,
            new KeyValuePair<string, string>("机电", "机") ,
            new KeyValuePair<string, string>("航空", "空") ,
            new KeyValuePair<string, string>("航天", "天") ,
            new KeyValuePair<string, string>("警察", "警") ,
            new KeyValuePair<string, string>("警官", "警") ,
            new KeyValuePair<string, string>("财贸", "财") ,
            new KeyValuePair<string, string>("电子", "电") ,
            new KeyValuePair<string, string>("建筑", "筑") ,
            new KeyValuePair<string, string>("艺术", "艺") ,
            new KeyValuePair<string, string>("体育", "体") ,
            new KeyValuePair<string, string>("城市", "城") ,
            new KeyValuePair<string, string>("地质", "地") ,
            new KeyValuePair<string, string>("医药", "药") ,
            new KeyValuePair<string, string>("政法", "法") ,
            new KeyValuePair<string, string>("铁路", "铁") ,
            new KeyValuePair<string, string>("铁道", "道") ,
            new KeyValuePair<string, string>("轨道", "轨") ,
            new KeyValuePair<string, string>("交通", "通") ,
            new KeyValuePair<string, string>("医学院", "医") ,
            new KeyValuePair<string, string>("医学", "医") ,
            new KeyValuePair<string, string>("传媒", "媒") ,
            new KeyValuePair<string, string>("工程", "程") ,
            new KeyValuePair<string, string>("临床", "临") ,
            new KeyValuePair<string, string>("化工", "化") ,
            new KeyValuePair<string, string>("林业", "林") ,
            new KeyValuePair<string, string>("老年", "老") ,
            new KeyValuePair<string, string>("旅游", "游") ,
            new KeyValuePair<string, string>("护理", "护") ,
            new KeyValuePair<string, string>("贸易", "贸") ,
            new KeyValuePair<string, string>("中医药", "中医") ,
            new KeyValuePair<string, string>("资源", "源") ,
            new KeyValuePair<string, string>("冶金", "冶") ,
            new KeyValuePair<string, string>("能源", "能") ,
            new KeyValuePair<string, string>("汽车", "车") ,
            new KeyValuePair<string, string>("医科", "医") ,
            new KeyValuePair<string, string>("机械", "械") ,
            new KeyValuePair<string, string>("应用", "应") ,
            new KeyValuePair<string, string>("电气", "电") ,
            new KeyValuePair<string, string>("材料", "材") ,
            new KeyValuePair<string, string>("劳动", "劳") ,
            new KeyValuePair<string, string>("轻工", "轻") ,
            new KeyValuePair<string, string>("农业", "农") ,
            new KeyValuePair<string, string>("委员会", "委") ,
            
            new KeyValuePair<string, string>("广播", "广"),
            new KeyValuePair<string, string>("电视", "电") ,
            new KeyValuePair<string, string>("工商", "商") ,
      
            new KeyValuePair<string, string>("工业", "工") ,
            new KeyValuePair<string, string>("管理", "管") ,
            
            new KeyValuePair<string, string>("社会主义", "社") ,
            new KeyValuePair<string, string>("社会", "社") ,
            new KeyValuePair<string, string>("自动化", "自") ,

                    

        };
        public static List<KeyValuePair<string, string>> proReplaceStr = new List<KeyValuePair<string, string>> {
            new KeyValuePair<string, string>("北京","京") ,
            new KeyValuePair<string, string>("天津","津") ,
            new KeyValuePair<string, string>("河北","冀") ,
            new KeyValuePair<string, string>("山西","晋") ,
            new KeyValuePair<string, string>("内蒙古","蒙") ,
            new KeyValuePair<string, string>("辽宁","辽") ,
            new KeyValuePair<string, string>("吉林","吉") ,
            new KeyValuePair<string, string>("黑龙江","黑") ,
            new KeyValuePair<string, string>("上海","沪") ,
            new KeyValuePair<string, string>("江苏","苏") ,
            new KeyValuePair<string, string>("浙江","浙") ,
            new KeyValuePair<string, string>("安徽","皖") ,
            new KeyValuePair<string, string>("福建","闽") ,
            new KeyValuePair<string, string>("江西","赣") ,
            new KeyValuePair<string, string>("山东","鲁") ,
            new KeyValuePair<string, string>("河南","豫") ,
            new KeyValuePair<string, string>("湖北","鄂") ,
            new KeyValuePair<string, string>("湖南","湘") ,
            new KeyValuePair<string, string>("广东","粤") ,
            new KeyValuePair<string, string>("广西","桂") ,
            new KeyValuePair<string, string>("海南","琼") ,
            new KeyValuePair<string, string>("四川","川") ,
            new KeyValuePair<string, string>("贵州","贵") ,
            new KeyValuePair<string, string>("云南","云") ,
            new KeyValuePair<string, string>("重庆","渝") ,
            new KeyValuePair<string, string>("西藏","藏") ,
            new KeyValuePair<string, string>("陕西","陕") ,
            new KeyValuePair<string, string>("甘肃","甘") ,
            new KeyValuePair<string, string>("青海","青") ,
            new KeyValuePair<string, string>("宁夏","宁") ,
            new KeyValuePair<string, string>("新疆","新") ,
            new KeyValuePair<string, string>("香港","港") ,
            new KeyValuePair<string, string>("澳门","澳") ,
            new KeyValuePair<string, string>("台湾","台")
        };
        // new List<string>() {"省", "市", "校区", "区", "州", "县", "旗", "盟", "自治","小学","第","学校","中学","大学","初中","高中", "学院", "职业","技术","幼儿园","（","）", "(",")","分校","分园","附属","校园","镇","村","乡","街","路","部"

        public class SchoolData{
            public string province { get; set; }
            public string id { get; set; }
            public string name { get; set; }
            public string city { get; set; }
            public string address { get; set; }
        }
        /// <summary>
        /// 测试blob多线程写入同一个文件
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("generate-school-code")]
        public async Task<IActionResult> Servicebus(JsonElement json)
        {
            string path = $"{_environment.ContentRootPath}/JsonFile/Core/region.json";
            var schools = json.GetProperty("schools").ToObject<List<SchoolData>>();
            schools= schools.Where((x, i) => schools.FindIndex(n => n.name.Equals(x.name)) == i).ToList();
            StreamReader streamReader = new StreamReader(new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite), Encoding.UTF8);
            StringBuilder stringBuilder = new StringBuilder();
            string text;
            while ((text = streamReader.ReadLine()) != null)
            {
                stringBuilder.Append(text.ToString());
            }

            streamReader.Close();
            string input = stringBuilder.ToString();
            List<Region> region = input.ToObject<List<Region>>(); ;
            try
            {
                schools.ForEach(x =>
                {
                    x.province=  ChineseConverter.Convert(x.province, ChineseConversionDirection.TraditionalToSimplified);
                    x.city = ChineseConverter.Convert(x.city, ChineseConversionDirection.TraditionalToSimplified);
                    x.name = ChineseConverter.Convert(x.name, ChineseConversionDirection.TraditionalToSimplified);
                    if (!string.IsNullOrEmpty(x.address)) {
                        x.address = ChineseConverter.Convert(x.address, ChineseConversionDirection.TraditionalToSimplified);
                    }
                 
                    comeRemoveStr.ForEach(c => { x.province = x.province.Replace(c, ""); });
                    prvcRemoveStr.ForEach(c => { x.province = x.province.Replace(c, ""); });
                    var province = region.Find(r => r.name.Contains(x.province));
                    string tmpprovince = x.province;
                    string tmpcity = x.city;
                    if (province != null)
                    {
                        x.province = province.name;
                        comeRemoveStr.ForEach(c => { x.city = x.city.Replace(c, ""); });
                        cityRemoveStr.ForEach(c => { x.city = x.city.Replace(c, ""); });
                        nationRemoveStr.ForEach(c => { x.city = x.city.Replace(c, ""); });
                        tmpcity = x.city;
                        var city = province.children.Find(r => r.name.Contains(x.city));

                        if (city == null)
                        {
                            city = province.children.Find(r => r.name.Contains(x.city));
                            if (city == null)
                            {
                                city = province.children.SelectMany(x => x.children).ToList().Find(r => r.name.Contains(x.city));
                            }
                        }
                        if (city != null)
                        {
                            x.city = city.name;
                        }
                    }

                    string name = x.name;
                    string[] names = name.Split("(");
                    if (names.Length > 1)
                    {
                        name = $"{names[0]}{names[1].Substring(0, 1)}";
                    }
                    names = name.Split("（");
                    if (names.Length > 1)
                    {
                        name = $"{names[0]}{names[1].Substring(0, 1)}";
                    }
                    name = Regex.Replace(name, "[ \\[ \\] \\^ \\-|（）【】/' {}_*×――(^)$%~!@#$…&%￥—+=<>《》!！??？:：•`·、。，；,.;\"‘’“”-]", "");
                    name = Regex.Replace(name, @"\s", "");
                    name = name.Replace("\\", "");
                    if (name.Length > 6)
                    {
                        //新区，高新，产业等非新政单位
                        areaRemoveStr.ForEach(str =>
                        {
                            name = name.Replace(str.Key, str.Value);
                        });
                        //去除冗余的学校信息，只保留地名和校名关键信息
                        schooRemoveStr.ForEach(str =>
                        {
                            name = name.Replace(str, "");
                        });
                       
                        //替换民族信息词
                        if (name.Length > 6)
                        {
                            nationRemoveStr.ForEach(str =>
                            {
                                name = name.Replace(str, "");
                            });
                        }
                        //替换学校信息的副词
                        if (name.Length > 6)
                        {
                            foreach (var str in schooReplaceStr) {
                                if (name.Length <= 6)
                                {
                                    break;
                                }
                                name = name.Replace(str.Key, str.Value);
                                
                            }
                        }
                        //替换省简称信息词
                        string tmpname = name;
                        if (name.Length > 6)
                        {
                            proReplaceStr.ForEach(str =>
                            {
                                name = name.Replace(str.Key, str.Value);
                            });
                            //如果替换后仍然大于6位，则取消，直接替换省份完整的词
                            if (name.Length > 6)
                            {
                                name = tmpname.Replace(tmpprovince, "");
                            }
                        }
                        //替换城市信息词
                        if (name.Length > 6)
                        {
                            name = name.Replace(tmpcity, "");
                        }

                    }
                    int len = name.Length;
                    if (len >= 6)
                    {
                        name = $"{name.Substring(0, 1)}{name.Substring(len-5, 3)}{name.Substring(len - 2, 2)}";
                    }
                    //if (len <= 7 && len > 6)
                    //{
                    //    name = name.Substring(len - 6);
                    //}
                    if (len <= 4)
                    {
                        name = $"{x.city.Substring(0, 2)}{name}";
                    }
                    if (len == 5)
                    {
                        name = $"{x.city.Substring(0, 1)}{name}";
                    }
                    string code = ToPinYin(name);
                    x.address = name;
                    x.id = code;
                    
                });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
            }
            string a_z = "abcdefghijklmnopqrstuvwxyz";
            var data= schools.GroupBy(x=>x.id).Select(x=>new {key= x.Key,more=x.ToList().Count>2, count = x.ToList().Count, list= x.ToList()}).ToList();
            data.ForEach(x =>
            {
                if (x.count > 1)
                {
                    var first = x.list.First();
                    var same = x.list.Skip(1).Take(x.count - 1).ToList();
                    var fs = first.name.Select(x => x).ToArray();
                    same.ForEach(z =>
                    {
                        var sp = z.name.Select(x => x).ToArray();
                        int len = sp.Length;
                        if (sp.Length >= fs.Length)
                        {
                            len = fs.Count();
                        }
                        for (int index = 0; index < len; index++)
                        {
                            if (!$"{sp[index]}".Equals($"{fs[index]}"))
                            {
                                short st = ChineseChar.GetStrokeNumber(sp[index]);
                                if (st > 0)
                                {
                                    var ins = st % 27;
                                    var insch = a_z[ins];
                                    if (z.name.EndsWith($"{insch}"))
                                    {
                                        ins = (st + 1) % 27;
                                        insch = a_z[ins];
                                    }
                                    z.id = $"{z.id.Substring(0, z.id.Length - 1)}{insch}";
                                    break;
                                }
                            }
                        }
                    });
                }
            });
            return Ok(data);
        }
        public static string ToPinYin(string val)
        {
            val = Regex.Replace(val, "[ \\[ \\] \\^ \\-|（）【】/' {}_*×――(^)$%~!@#$…&%￥—+=<>《》!！?？:：•`·、。，；,.;\"‘’“”-]", "");
            val = Regex.Replace(val, @"\s", "");
            val = val.Replace("\\", "");
            StringBuilder sb = new StringBuilder();
            val.ToCharArray().ToList().ForEach(x =>
            {
                if (('a' <= x && x <= 'z') || ('A' <= x && x <= 'Z') || ('0' <= x && x <= '9'))
                {
                    sb.Append(x);
                }
                else
                {
                    try
                    {
                        ChineseChar cc = new ChineseChar(x);
                        if (cc.Pinyins.Count > 0 && cc.Pinyins[0].Length > 0)
                        {
                            sb.Append(cc.Pinyins[0][0]);
                        }
                    }
                    catch (Exception ex)
                    {
                    }
                }
            });
            return sb.ToString().ToLower();
        }
        /// <summary>
        /// 测试blob多线程写入同一个文件
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("servicebus")]
        public async Task<IActionResult> Servicebus(ItemCondDto jsonMsg)
        {
            var messageBlob = new ServiceBusMessage(jsonMsg.ToJsonString());
            await _serviceBus.GetServiceBusClient().SendMessageAsync("itemcond", messageBlob);
            return Ok();
        }

        /// <summary>
        /// 测试blob多线程写入同一个文件
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("blobroot")]
        public async Task<IActionResult> MultipleBlob(JsonElement jsonMsg)
        {
            if (jsonMsg.TryGetProperty("name", out JsonElement name) && name.ValueKind == JsonValueKind.String
                    && jsonMsg.TryGetProperty("root", out JsonElement root) && root.ValueKind == JsonValueKind.String)
            {
                List<Dictionary<string, double?>> list = new List<Dictionary<string, double?>>();
                string u = System.Web.HttpUtility.UrlDecode($"{root}", Encoding.UTF8).Split("/")[0];
                var client = _azureStorage.GetBlobContainerClient($"{name}");
                var size = await client.GetBlobsSize(u);
                await _azureRedis.GetRedisClient(8).SortedSetRemoveAsync($"Blob:Catalog:{name}", u);
                await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Blob:Catalog:{name}", u, size.HasValue ? size.Value : 0);
                var scores = await _azureRedis.GetRedisClient(8).SortedSetRangeByRankWithScoresAsync($"Blob:Catalog:{name}");
                double blobsize = 0;
                if (scores != default && scores != null)
                {
                    foreach (var score in scores)
                    {
                        blobsize = blobsize + score.Score;
                        list.Add(new Dictionary<string, double?>() { { score.Element.ToString(), score.Score } });
                    }
                }
                await _azureRedis.GetRedisClient(8).HashSetAsync($"Blob:Record", new RedisValue($"{name}"), new RedisValue($"{blobsize}"));

                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-ServiceBus,Blob() 容器:{name}使用:{root}，文件分类：{list.ToJsonString()}",
                    GroupNames.成都开发測試群組);
                return Ok(list);
            }
            else
            {
                return Ok();
            }

        }

        private async Task<int> SendNotification()
        {


            HttpClient _httpClient = new HttpClient();
            //  _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
            var pa = new { grant_type = "device", client_id = "9794e418-c4ef-4fd5-a42d-accaa2d96d6e", client_secret = "ruL?I79h0w1AZaZXtBaZeZuQLQXLa=:-" };
            HttpResponseMessage responseMessage = await _httpClient.PostAsJsonAsync("https://api2-rc.teammodel.net/oauth2/token", pa);
            if (responseMessage.StatusCode == HttpStatusCode.OK)
            {
                return 200;
            }
            else if (responseMessage.StatusCode == HttpStatusCode.Unauthorized)
            {
                return 401;
            }
            else
            {
                return 500;
            }
        }

        /// <summary>
        /// 测试redis通配符
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpGet("test-delete-read")]
        public async Task<IActionResult> TestDelete()
        {

            foreach (var cnt in _azureStorage.GetBlobServiceClient().GetBlobContainers())
            {
                Console.WriteLine(cnt.Name);
            }

            await SendNotification();
            var client = _azureCosmos.GetCosmosClient();
            string aaa = "0";
            try
            {
                ItemResponse<Student> a = await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemAsync<Student>("1111111", new PartitionKey($"Course-111111"));
                Ok(a.GetRawResponse().Status);
            }
            catch (CosmosException ex)
            {
                if (ex.Response.Status == 404)
                {
                    aaa = "404";
                }
            }

            try
            {
                ItemResponse<Student> a = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemAsync<Student>("1111111", new PartitionKey($"Course-111111"));
                Ok(a.GetRawResponse().Status);
            }
            catch (CosmosException ex)
            {
                if (ex.Response.Status == 404)
                {
                    aaa = aaa + " 404";
                }
            }
            try
            {
                var a = await client.GetContainer(Constant.TEAMModelOS, "Student").DeleteItemStreamAsync("1111111", new PartitionKey($"Course-111111"));
                Ok(a.Status);
            }
            catch (CosmosException ex)
            {
                if (ex.Response.Status == 404)
                {
                    aaa = "404";
                }
            }

            try
            {
                var a = await client.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync("1111111", new PartitionKey($"Course-111111"));
                Ok(a.Status);
            }
            catch (CosmosException ex)
            {
                if (ex.Response.Status == 404)
                {
                    aaa = aaa + " 404";
                }
            }
            return Ok(new { aaa });
        }
        /// <summary>
        /// 测试redis通配符
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpGet("test-redis")]
        public async Task<IActionResult> TestRedis()
        {

            try
            {
                var client = _azureCosmos.GetCosmosClient();
                List<ItemInfo> items = new List<ItemInfo>();
                var queryslt = $"SELECT  value(c) FROM c where  c.pid = null ";
                await foreach (var item in client.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ItemInfo>(queryText: queryslt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-hbcn") }))
                {

                    items.Add(item);
                }
                List<ItemCond> itemConds = new List<ItemCond>();
                items.GroupBy(x => x.periodId).Select(y => new { key = y.Key, list = y.ToList() }).ToList().ForEach(z =>
                {
                    ItemCond cond = new ItemCond() { id = z.key, code = $"ItemCond-hbcn", pk = "ItemCond", ttl = -1, count = z.list.Count, grades = new List<GradeCount>(), subjects = new List<SubjectCount>() };
                    z.list.ForEach(y =>
                    {
                        ItemService.CountItemCond(y, null, cond);
                    });

                    itemConds.Add(cond);
                });
                itemConds.ForEach(async cond =>
                {
                    await client.GetContainer(Constant.TEAMModelOS, "School").UpsertItemAsync<ItemCond>(cond, new PartitionKey(cond.code));
                });
                return Ok(new { itemConds });
            }
            catch (Exception ex) { await _dingDing.SendBotMsg($"TEAMModelFunction，ActivityHttpTrigger，fix-itemcond()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組); }
            return Ok(new { });

        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        //[AuthToken(Roles = "teacher")]
        [HttpPost("fix-blob-content")]
        public async Task<IActionResult> FixBlobContent(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("name", out JsonElement name)) return BadRequest();
                if (!request.TryGetProperty("scope", out JsonElement _scope)) return BadRequest();


                var client = _azureCosmos.GetCosmosClient();
                List<string> prefixs = new List<string>() { "audio", "doc", "image", "other", "res", "video", "thum" };
                var ContainerClient = _azureStorage.GetBlobContainerClient($"{name}");
                string scope = "private";


                scope = $"{_scope}";

                var tb = "Teacher";
                if (scope != "private")
                {
                    tb = "School";
                }
                long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();

                foreach (var prefix in prefixs)
                {
                    List<string> items = await ContainerClient.List(prefix);
                    foreach (var item in items)
                    {
                        var urlsSize = await ContainerClient.GetBlobsSize(item);
                        Bloblog bloblog = new Bloblog { id = Guid.NewGuid().ToString(), code = $"Bloblog-{name}", pk = "Bloblog", time = now, size = urlsSize != null && urlsSize.HasValue ? urlsSize.Value : 0, type = prefix };
                        await client.GetContainer(Constant.TEAMModelOS, tb).UpsertItemAsync(bloblog, new Azure.Cosmos.PartitionKey(bloblog.code));
                    }
                }


                return new OkObjectResult(new { });

            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"TEAMModelFunction，ActivityHttpTrigger，fix-blob-content()\n{ex.Message}{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return new BadRequestResult();
            }
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        //[AuthToken(Roles = "teacher")]
        [HttpPost("get-data")]
        public async Task<IActionResult> GetData(JsonElement request)
        {
            try
            {
                var client = _azureCosmos.GetCosmosClient();

                return Ok(new { code = 1 });
            }
            catch (Exception e)
            {
                return BadRequest(e.StackTrace);
            }
        }
    }

}