123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751 |
- 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);
- }
- }
- }
- }
|