TestController.cs 82 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714
  1. using Azure.Cosmos;
  2. using DingTalk.Api;
  3. using DingTalk.Api.Request;
  4. using DingTalk.Api.Response;
  5. using HTEXLib.COMM.Helpers;
  6. using Microsoft.AspNetCore.Hosting;
  7. using Microsoft.AspNetCore.Http;
  8. using Microsoft.AspNetCore.Mvc;
  9. using Microsoft.Azure.Cosmos.Table;
  10. using Microsoft.Extensions.Configuration;
  11. using Microsoft.Extensions.Options;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.ComponentModel.DataAnnotations;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Text.Json;
  18. using System.Threading.Tasks;
  19. using TEAMModelBI.Filter;
  20. using TEAMModelBI.Models;
  21. using TEAMModelBI.Tool;
  22. using TEAMModelOS.Models;
  23. using TEAMModelOS.SDK;//引用创建学校Code
  24. using TEAMModelOS.SDK.Context.Attributes.Azure;
  25. using TEAMModelOS.SDK.DI;
  26. using TEAMModelOS.SDK.Extension;
  27. using TEAMModelOS.SDK.Models;
  28. using TEAMModelOS.SDK.Models.Cosmos.BI;
  29. using TEAMModelOS.SDK.Models.Cosmos.Common;
  30. using TEAMModelOS.SDK.Models.Service;
  31. using TEAMModelOS.SDK.Models.Table;
  32. //.Net 6新的特性
  33. using System.Reflection;
  34. using System.Numerics;
  35. using System.Security.Cryptography;
  36. using System.Runtime.InteropServices;
  37. using System.Runtime.CompilerServices;
  38. using System.IdentityModel.Tokens.Jwt;
  39. using TEAMModelBI.Tool.Extension;
  40. using System.IO;
  41. using System.Net.Http;
  42. using System.Net.Http.Json;
  43. using System.Net;
  44. using TEAMModelBI.Tool.CosmosBank;
  45. using System.Diagnostics;
  46. using StackExchange.Redis;
  47. using TEAMModelOS.SDK.Models.Service.BI;
  48. using TEAMModelOS.SDK.Context.BI;
  49. using TEAMModelOS.SDK.Context.Constant;
  50. using Azure.Storage.Blobs.Models;
  51. using Azure.Storage.Blobs;
  52. using Azure.Storage.Blobs.Specialized;
  53. using System.Web;
  54. using Azure.Storage.Sas;
  55. using DocumentFormat.OpenXml.Drawing.Diagrams;
  56. namespace TEAMModelBI.Controllers.BITest
  57. {
  58. [Route("apitest")]
  59. [ApiController]
  60. public class TestController : ControllerBase
  61. {
  62. private readonly AzureCosmosFactory _azureCosmos;
  63. private readonly AzureStorageFactory _azureStorage;
  64. private readonly AzureRedisFactory _azureRedis;
  65. private readonly DingDing _dingDing;
  66. private readonly Option _option;
  67. private readonly IWebHostEnvironment _environment; //读取文件
  68. //读取配置文件
  69. private readonly IConfiguration _configuration;
  70. private readonly CoreAPIHttpService _coreAPIHttpService;
  71. private readonly HttpClient _httpClient;
  72. private IPSearcher _ipSearcher;
  73. public TestController(IPSearcher ipSearcher, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, DingDing dingDing, IOptionsSnapshot<Option> option, IWebHostEnvironment hostingEnvironment, IConfiguration configuration, CoreAPIHttpService coreAPIHttpService, HttpClient httpClient)
  74. {
  75. _azureCosmos = azureCosmos;
  76. _azureStorage = azureStorage;
  77. _azureRedis = azureRedis;
  78. _dingDing = dingDing;
  79. _option = option?.Value;
  80. _environment = hostingEnvironment;
  81. _configuration = configuration;
  82. _coreAPIHttpService = coreAPIHttpService;
  83. _httpClient = httpClient; _ipSearcher = ipSearcher;
  84. }
  85. /// <summary>
  86. /// 删除册别,删除章节 创区
  87. /// </summary>
  88. /// <param name="jsonElement"></param>
  89. /// <returns></returns>
  90. [HttpPost("del-standard")]
  91. public async Task<IActionResult> DelStandard(JsonElement jsonElement)
  92. {
  93. if (!jsonElement.TryGetProperty("oldStandard", out JsonElement _oldStandard)) return BadRequest();
  94. var cosmosClient = _azureCosmos.GetCosmosClient();
  95. List<string> abilityIds = new(); //册别的ID集合
  96. //查询册别信息
  97. 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}") }))
  98. {
  99. abilityIds.Add(tempAbility.id); //查询出来册别ID添加册别ID集合
  100. }
  101. //删除册别
  102. if (abilityIds.IsNotEmpty())
  103. {
  104. var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityIds, $"Ability-{_oldStandard}");
  105. }
  106. List<string> abilityTaskIds = new(); //章节ID集合
  107. 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}") }))
  108. {
  109. abilityTaskIds.Add(item.id); //查询出来的章节信息ID添加到战绩集合
  110. }
  111. //删除章节
  112. if (abilityTaskIds.IsNotEmpty())
  113. {
  114. var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityTaskIds, $"AbilityTask-{_oldStandard}");
  115. }
  116. return Ok(new { state = 200 });
  117. }
  118. /// <summary>
  119. /// 测试生产Code
  120. /// </summary>
  121. /// <param name="jsonElement"></param>
  122. /// <returns></returns>
  123. [ProducesDefaultResponseType]
  124. [HttpPost("get-schoolcode")]
  125. public async Task<IActionResult> GetSchoolCode(JsonElement jsonElement)
  126. {
  127. //string data = await SchoolCode.GenerateSchoolCode(jsonElement, _dingDing, _environment).ToString();
  128. CreateSchoolInfo createSchoolInfo = new CreateSchoolInfo();
  129. createSchoolInfo.province = "四川省";
  130. createSchoolInfo.id = "tmdplc";
  131. createSchoolInfo.name = "醍摩豆批量创校学校";
  132. createSchoolInfo.city = "成都市";
  133. createSchoolInfo.aname = "";
  134. createSchoolInfo.createCount = 0;
  135. //Random random = new Random();
  136. ////随机小写字母
  137. //int a = random.Next(0, 26);
  138. //char ch = (char)('a' + a);
  139. //string Number = GenerateRandom.Number(1);
  140. //string Number1 = GenerateRandom.Number(1, true);
  141. //string Str = GenerateRandom.Str(1);
  142. //string Str1 = GenerateRandom.Str(1, true);
  143. //string Str_char = GenerateRandom.Str_char(1);
  144. //string Str_char1 = GenerateRandom.Str_char(1, true);
  145. CreateSchoolInfo data = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  146. return Ok(new { state = 200, data, data.id });
  147. }
  148. /// <summary>
  149. /// 保存日志文件
  150. /// </summary>
  151. /// <param name="jsonElement"></param>
  152. /// <returns></returns>
  153. [ProducesDefaultResponseType]
  154. [AuthToken(Roles = "assist,admin")]
  155. [HttpPost("set-savebilog")]
  156. public async Task<IActionResult> SetTestSaveBIlog(JsonElement jsonElement)
  157. {
  158. //jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  159. jsonElement.TryGetProperty("msg", out JsonElement msg);
  160. var cosmosClient = _azureCosmos.GetCosmosClient();
  161. var tableClient = _azureStorage.GetCloudTableClient();
  162. var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
  163. var redisClinet = _azureRedis.GetRedisClient(8);
  164. ////分开部署,就不需要,一站多用时,取消注释
  165. //if ($"{site}".Equals(BIConst.Global))
  166. //{
  167. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  168. // tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
  169. // blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
  170. // redisClinet = _azureRedis.GetRedisClient(dbnum: 8, name: BIConst.Global);
  171. //}
  172. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  173. await _azureStorage.SaveLog(type: "table-save", msg: "测试保存方法01", dingDing: _dingDing, httpContext: HttpContext); //IES5 日志记录
  174. await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "Test-test", $"{msg}", _dingDing, httpContext: HttpContext);//BI 日志记录
  175. return Ok(new { state = 200 });
  176. }
  177. /// <summary>
  178. /// 查询table数据
  179. /// </summary>
  180. /// <param name="jsonElement"></param>
  181. /// <returns></returns>
  182. [HttpPost("file-table")]
  183. public async Task<IActionResult> SaveTable(JsonElement jsonElement)
  184. {
  185. jsonElement.TryGetProperty("single", out JsonElement single);
  186. jsonElement.TryGetProperty("startDate", out JsonElement startDate);
  187. jsonElement.TryGetProperty("endDate", out JsonElement endDate);
  188. jsonElement.TryGetProperty("platform", out JsonElement platform);
  189. List<string> strlist = new();
  190. if (!string.IsNullOrEmpty($"{single}"))
  191. strlist.Add($"RowKey {QueryComparisons.Equal} {single}");
  192. if (!string.IsNullOrEmpty($"{startDate}"))
  193. strlist.Add($"RowKey {QueryComparisons.GreaterThanOrEqual} {startDate}");
  194. if (!string.IsNullOrEmpty($"{endDate}"))
  195. strlist.Add($"RowKey {QueryComparisons.LessThanOrEqual} {endDate}");
  196. if (!string.IsNullOrEmpty($"{platform}"))
  197. strlist.Add($"platform {QueryComparisons.Equal} {platform}");
  198. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  199. string sql = string.Join(" and ", strlist);
  200. var temp = table.QueryWhereString<BIOptLog>(sql);
  201. return Ok(new { state = 200, temp });
  202. }
  203. /// <summary>
  204. /// 查询BI操作记录
  205. /// </summary>
  206. /// <param name="jsonElement"></param>
  207. /// <returns></returns>
  208. [HttpPost("get-operatelogbydate")]
  209. public async Task<IActionResult> GetOperateLogByDate(JsonElement jsonElement)
  210. {
  211. try
  212. {
  213. jsonElement.TryGetProperty("single", out JsonElement single);
  214. jsonElement.TryGetProperty("startDate", out JsonElement startDate);
  215. jsonElement.TryGetProperty("endDate", out JsonElement endDate);
  216. jsonElement.TryGetProperty("platform", out JsonElement platform);
  217. List<BIOptLog> operateLogs = new();
  218. StringBuilder tableSql = new();
  219. if (!string.IsNullOrEmpty($"{single}"))
  220. tableSql.Append($"RowKey {QueryComparisons.Equal} '{single}' ");
  221. if (!string.IsNullOrEmpty($"{startDate}"))
  222. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} RowKey {QueryComparisons.GreaterThanOrEqual} '{startDate}' " : $"RowKey {QueryComparisons.GreaterThanOrEqual} '{startDate}' ");
  223. if (!string.IsNullOrEmpty($"{endDate}"))
  224. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} RowKey {QueryComparisons.LessThanOrEqual} '{endDate}' " : $" RowKey { QueryComparisons.LessThanOrEqual} '{endDate}' ");
  225. if (!string.IsNullOrEmpty($"{platform}"))
  226. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} platform {QueryComparisons.Equal} '{platform}' " : $" platform {QueryComparisons.Equal} '{platform}' ");
  227. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  228. operateLogs = await table.QueryWhereString<BIOptLog>(tableSql.ToString());
  229. return Ok(new { state = 200, operateLogs });
  230. }
  231. catch (Exception ex)
  232. {
  233. await _dingDing.SendBotMsg($"BI,{_option.Location} /operatelog/get-operatelogbydate \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  234. return BadRequest();
  235. }
  236. }
  237. /// <summary>
  238. /// 查询离职信息
  239. /// </summary>
  240. /// <returns></returns>
  241. [ProducesDefaultResponseType]
  242. [HttpPost("quitstaff")]
  243. public async Task<IActionResult> QuitStaff()
  244. {
  245. string appKey = _configuration["DingDingAuth:appKey"];
  246. string appSecret = _configuration["DingDingAuth:appSecret"];
  247. string agentld = _configuration["DingDingAuth:Agentld"];
  248. //获取access_token
  249. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  250. OapiGettokenRequest request = new() { Appkey = appKey, Appsecret = appSecret };
  251. request.SetHttpMethod("Get");
  252. OapiGettokenResponse response = client.Execute(request);
  253. if (response.IsError)
  254. {
  255. return BadRequest();
  256. }
  257. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  258. string access_token = response.AccessToken;
  259. IDingTalkClient quitStaffClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querydimission");
  260. OapiSmartworkHrmEmployeeQuerydimissionRequest reqDimission = new() { Offset = 0L, Size = 50L };
  261. OapiSmartworkHrmEmployeeQuerydimissionResponse rspDimission = quitStaffClient.Execute(reqDimission, access_token);
  262. if (rspDimission.SubErrCode == "60011")
  263. {
  264. return Ok(new { state = 60011, message = "没有调用该接口的权限!" });
  265. }
  266. else if (rspDimission.Result != null)
  267. {
  268. var datalist = rspDimission.Result.DataList;
  269. return Ok(new { state = 200, datalist });
  270. }
  271. else
  272. {
  273. return Ok(new { state = rspDimission.SubErrCode, message = rspDimission.Errmsg });
  274. }
  275. }
  276. /// <summary>
  277. /// 测试获取待入职人员的userId接口
  278. /// </summary>
  279. /// <returns></returns>
  280. [ProducesDefaultResponseType]
  281. [HttpPost("Induction")]
  282. public async Task<IActionResult> Induction()
  283. {
  284. string appKey = _configuration["DingDingAuth:appKey"];
  285. string appSecret = _configuration["DingDingAuth:appSecret"];
  286. string agentld = _configuration["DingDingAuth:Agentld"];
  287. //获取access_token
  288. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  289. OapiGettokenRequest request = new() { Appkey = appKey, Appsecret = appSecret };
  290. request.SetHttpMethod("Get");
  291. OapiGettokenResponse response = client.Execute(request);
  292. if (response.IsError)
  293. {
  294. return BadRequest();
  295. }
  296. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  297. string access_token = response.AccessToken;
  298. IDingTalkClient InductionClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querypreentry");
  299. OapiSmartworkHrmEmployeeQuerypreentryRequest reqInduction = new() { Offset = 0L, Size = 50 };
  300. reqInduction.SetHttpMethod("GET");
  301. OapiSmartworkHrmEmployeeQuerypreentryResponse rspInduction = InductionClient.Execute(reqInduction, access_token);
  302. if (rspInduction.Result.DataList != null)
  303. {
  304. foreach (var itemId in rspInduction.Result.DataList)
  305. {
  306. IDingTalkClient client3 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
  307. OapiV2UserGetRequest v2GetRequest = new()
  308. {
  309. Userid = itemId,
  310. Language = "zh_CN"
  311. };
  312. OapiV2UserGetResponse v2GetResponse = client3.Execute(v2GetRequest, access_token);
  313. }
  314. return Ok(new { state = 200, rspInduction.Result.DataList });
  315. }
  316. else
  317. {
  318. return Ok(new { state = 400, rspInduction.SubErrCode, rspInduction.SubErrMsg });
  319. }
  320. }
  321. /// <summary>
  322. /// 获取在职ID
  323. /// </summary>
  324. /// <returns></returns>
  325. [HttpPost("get-onthejob")]
  326. public async Task<IActionResult> GetOnTheJob()
  327. {
  328. string appKey = _configuration["DingDingAuth:appKey"];
  329. string appSecret = _configuration["DingDingAuth:appSecret"];
  330. string agentld = _configuration["DingDingAuth:Agentld"];
  331. //获取access_token
  332. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  333. OapiGettokenRequest request = new() { Appkey = appKey, Appsecret = appSecret };
  334. request.SetHttpMethod("Get");
  335. OapiGettokenResponse response = client.Execute(request);
  336. if (response.IsError)
  337. {
  338. return BadRequest();
  339. }
  340. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  341. string access_token = response.AccessToken;
  342. //bool vars = false;
  343. //long offst = 1;
  344. //do
  345. //{
  346. // IDingTalkClient jobclient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/queryonjob");
  347. // OapiSmartworkHrmEmployeeQueryonjobRequest jobreq = new OapiSmartworkHrmEmployeeQueryonjobRequest { StatusList = "2,3,-1", Offset = offst, Size = 50 }; //2:试用期 3:正式 5:待离职 -1:无状态
  348. // OapiSmartworkHrmEmployeeQueryonjobResponse jobrsp = jobclient.Execute(jobreq, access_token);
  349. // if (jobrsp.Result.NextCursor > 0)
  350. // offst += 1;
  351. // else vars = true;
  352. //} while (vars);
  353. IDingTalkClient jobclient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/queryonjob");
  354. OapiSmartworkHrmEmployeeQueryonjobRequest jobreq = new() { StatusList = "2,3,-1", Offset = 1, Size = 50 }; //2:试用期 3:正式 5:待离职 -1:无状态
  355. OapiSmartworkHrmEmployeeQueryonjobResponse jobrsp = jobclient.Execute(jobreq, access_token);
  356. if (jobrsp.SubErrCode == "60011")
  357. {
  358. return Ok(new { state = 200, msg = jobrsp.SubErrMsg });
  359. }
  360. foreach (var item in jobrsp.Result.DataList)
  361. {
  362. }
  363. var ser = jobrsp.Result.DataList; // jobrsp.Body.GetEnumerator("result");
  364. return Ok(new { state = 200, jobrsp.Body, ser });
  365. }
  366. /// <summary>
  367. /// 测试 使用yield 优化
  368. /// 依据学校编号查询学校信息;若是没有传学校编号,则查询所有学校信息
  369. /// </summary>
  370. /// <param name="jsonElement"></param>
  371. /// <returns></returns>
  372. [ProducesDefaultResponseType]
  373. [HttpPost("get-schoolsinfo")]
  374. public async Task<IActionResult> GetSchoolsInfo(JsonElement jsonElement)
  375. {
  376. try
  377. {
  378. jsonElement.TryGetProperty("schoolCode", out JsonElement _schoolCode);
  379. var cosmosClient = _azureCosmos.GetCosmosClient();
  380. List<AssistSchool> schoolAssists = new();
  381. //StringBuilder stringBuilder = new StringBuilder("select value(c) from c");
  382. StringBuilder stringBuilder = new("select c.id,c.code,c.schoolCode,c.name,c.region,c.province,c.city,c.dist,c.size,c.address,c.picture,c.type,c.scale,c.areaId,c.standard from c");
  383. if (!string.IsNullOrEmpty($"{_schoolCode}"))
  384. {
  385. stringBuilder.Append($" where c.id='{_schoolCode}'");
  386. }
  387. //await foreach (var itemSchool in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: stringBuilder.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  388. //{
  389. // SchoolAssist schoolAssist = new()
  390. // {
  391. // id = itemSchool.id,
  392. // code = itemSchool.code,
  393. // schoolCode = itemSchool.schoolCode,
  394. // name = itemSchool.name,
  395. // region = itemSchool.region,
  396. // province = itemSchool.province,
  397. // city = itemSchool.city,
  398. // dist = itemSchool.dist,
  399. // size = itemSchool.size,
  400. // address = itemSchool.address,
  401. // picture = itemSchool.picture,
  402. // type = itemSchool.type,
  403. // scale = itemSchool.scale,
  404. // areaId = itemSchool.areaId,
  405. // standard = itemSchool.standard
  406. // };
  407. // var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(itemSchool.id, new PartitionKey("ProductSum"));
  408. // if (response.Status == 200)
  409. // {
  410. // using var json = await JsonDocument.ParseAsync(response.ContentStream);
  411. // if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  412. // {
  413. // schoolAssist.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  414. // }
  415. // if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  416. // {
  417. // schoolAssist.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  418. // }
  419. // if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  420. // {
  421. // schoolAssist.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  422. // }
  423. // }
  424. // schoolAssist.assists = await CommonFind.FindSchoolRoles(cosmosClient, itemSchool.id, "assist");
  425. // schoolAssists.Add(schoolAssist);
  426. //}
  427. //return Ok(new { state = 200, schoolAssists });
  428. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: stringBuilder.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  429. {
  430. using var jsonSchool = await JsonDocument.ParseAsync(itemSchool.ContentStream);
  431. foreach (var objSchool in jsonSchool.RootElement.GetProperty("Documents").EnumerateArray())
  432. {
  433. var schoolId = objSchool.GetProperty("id").GetString();
  434. AssistSchool schoolAssist = new()
  435. {
  436. id = schoolId,
  437. code = objSchool.GetProperty("code").GetString(),
  438. schoolCode = objSchool.GetProperty("schoolCode").GetString(),
  439. name = objSchool.GetProperty("name").GetString(),
  440. region = objSchool.GetProperty("region").GetString(),
  441. province = objSchool.GetProperty("province").GetString(),
  442. city = objSchool.GetProperty("city").GetString(),
  443. dist = objSchool.GetProperty("dist").GetString(),
  444. size = objSchool.GetProperty("size").GetInt32(),
  445. address = objSchool.GetProperty("address").GetString(),
  446. picture = objSchool.GetProperty("picture").GetString(),
  447. type = objSchool.GetProperty("type").GetInt32(),
  448. //scale = objSchool.GetProperty("scale").GetInt32(),
  449. areaId = objSchool.GetProperty("areaId").GetString(),
  450. standard = objSchool.GetProperty("standard").GetString(),
  451. };
  452. try { schoolAssist.scale = objSchool.GetProperty("scale").GetInt32(); }
  453. catch { schoolAssist.scale = 0; }
  454. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("ProductSum"));
  455. if (response.Status == 200)
  456. {
  457. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  458. if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  459. {
  460. schoolAssist.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  461. }
  462. if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  463. {
  464. schoolAssist.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  465. }
  466. if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  467. {
  468. schoolAssist.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  469. }
  470. }
  471. //schoolAssist.assists = await CommonFind.FindSchoolRoles(cosmosClient, schoolId, "assist");
  472. schoolAssists.Add(schoolAssist);
  473. }
  474. }
  475. List<AssistSchool> tempSchoolAssists = new();
  476. await foreach (var temp in GetSchools(cosmosClient, schoolAssists))
  477. {
  478. tempSchoolAssists.AddRange(temp);
  479. }
  480. return Ok(new { state = 200, schoolAssists = tempSchoolAssists });
  481. }
  482. catch (Exception ex)
  483. {
  484. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-schoolsinfo \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
  485. return BadRequest();
  486. }
  487. }
  488. /// <summary>
  489. /// 使用yield 优化
  490. /// </summary>
  491. /// <param name="cosmosClient"></param>
  492. /// <param name="schoolAssists"></param>
  493. /// <returns></returns>
  494. private async IAsyncEnumerable<List<AssistSchool>> GetSchools(CosmosClient cosmosClient, List<AssistSchool> schoolAssists)
  495. {
  496. List<AssistSchool> tempSchoolAssists = new();
  497. foreach (var temp in schoolAssists)
  498. {
  499. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(temp.id, new PartitionKey("ProductSum"));
  500. if (response.Status == 200)
  501. {
  502. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  503. if (json.RootElement.TryGetProperty("serial", out JsonElement serial) && !serial.ValueKind.Equals(JsonValueKind.Null))
  504. {
  505. temp.serial = serial.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  506. }
  507. if (json.RootElement.TryGetProperty("service", out JsonElement service) && !service.ValueKind.Equals(JsonValueKind.Null))
  508. {
  509. temp.service = service.ToObject<List<SchoolProductSumData>>().Select(x => x.prodCode).ToList();
  510. }
  511. if (json.RootElement.TryGetProperty("hard", out JsonElement hard) && !hard.ValueKind.Equals(JsonValueKind.Null))
  512. {
  513. temp.hard = hard.ToObject<List<SchoolProductSumDataHard>>().Select(x => x.prodCode).ToList();
  514. }
  515. }
  516. temp.assists = await CommonFind.FindSchoolRoles(cosmosClient, temp.id, "assist");
  517. tempSchoolAssists.Add(temp);
  518. }
  519. yield return tempSchoolAssists;
  520. }
  521. /// <summary>
  522. /// 赋值默认的顾问角色和BI默认的功能权限
  523. /// </summary>
  524. /// <returns></returns>
  525. [HttpPost("set-rolesorperm")]
  526. public async Task<IActionResult> SetRolesOrPermissions()
  527. {
  528. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIDDUserInfo");
  529. List<DingDingUserInfo> ddUserId = await table.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", "continent" } });
  530. List<string> read = new() { "abilitystandard-read", "batcharea-read", "batchschool-read", "orgusers-read" };
  531. List<DingDingUserInfo> tempUserInfo = new();
  532. foreach (var user in ddUserId)
  533. {
  534. if (string.IsNullOrEmpty(user.roles))
  535. {
  536. user.roles = "assist";
  537. }
  538. if (string.IsNullOrEmpty(user.permissions))
  539. {
  540. user.permissions = string.Join(",", read);
  541. }
  542. List<string> tempRead = new(user.permissions.Split(","));
  543. foreach (var temp in read)
  544. {
  545. if (!tempRead.Contains(temp))
  546. {
  547. tempRead.Add(temp);
  548. }
  549. }
  550. user.permissions = string.Join(",", tempRead);
  551. tempUserInfo.Add(user);
  552. }
  553. var response = await table.SaveOrUpdateAll<DingDingUserInfo>(tempUserInfo);
  554. return Ok(new { state = 200, response });
  555. }
  556. /// <summary>
  557. /// 测试使用 CosmosDB中的COUNT 函数统计
  558. /// </summary>
  559. /// <param name="jsonElement"></param>
  560. /// <returns></returns>
  561. [HttpPost("get-count")]
  562. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  563. {
  564. var cosmosClient = _azureCosmos.GetCosmosClient();
  565. List<KeyValuePair<int, int>> layerCount = new List<KeyValuePair<int, int>>();
  566. for (int i = 1; i <= 6; i++)
  567. {
  568. int total = 0;
  569. //string sqlText = $"select value(c.id) from c where c.pk='Item' and c.field={i}";
  570. string sqlText = $"select value(COUNT(c.id)) from c where c.pk='Item' and c.field={i}";
  571. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<int>(queryText: sqlText, requestOptions: new QueryRequestOptions() { }))
  572. {
  573. total += item;
  574. //using var json = await JsonDocument.ParseAsync(item.ContentStream);
  575. //if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt32() > 0)
  576. //{
  577. // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  578. // {
  579. // //total += obj.GetInt64();
  580. // total += obj.GetProperty("totals").GetInt32();
  581. // }
  582. // //total += count.GetInt64();
  583. //}
  584. }
  585. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Teacher").GetItemQueryIterator<int>(queryText: sqlText, requestOptions: new QueryRequestOptions() { }))
  586. {
  587. total += item;
  588. //using var json = await JsonDocument.ParseAsync(item.ContentStream);
  589. //if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  590. //{
  591. // foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  592. // {
  593. // //total += obj.GetInt64();
  594. // total += obj.GetProperty("totals").GetInt32();
  595. // }
  596. //}
  597. }
  598. layerCount.Add(new KeyValuePair<int, int>(i, total));
  599. }
  600. return Ok(new { state = 200, layerCount });
  601. }
  602. /// <summary>
  603. /// 测试算日期
  604. /// </summary>
  605. /// <returns></returns>
  606. [HttpPost("get-date")]
  607. public async Task<IActionResult> GetDate()
  608. {
  609. List<string> day7 = TimeHelper.GetNearDay(DateTimeOffset.UtcNow, 7);
  610. List<string> day30 = TimeHelper.GetNearDay(DateTimeOffset.UtcNow, 30);
  611. DateTimeOffset dateTime = DateTimeOffset.UtcNow.AddDays(0);
  612. int year = DateTimeOffset.UtcNow.Year;
  613. int month = DateTimeOffset.UtcNow.Month;
  614. var datetime7 = DateTimeOffset.UtcNow.AddDays(-7); //前七天的时间
  615. List<string> strList = monthsOfYear("2021-1");
  616. var ere = DateTimeOffset.Parse("2022-04-25");
  617. DateTimeOffset ste = new();
  618. if (ere.Month > 9)
  619. {
  620. ste = new DateTime(ere.Year, ere.Month - 4, 1);
  621. }
  622. else
  623. {
  624. ste = new DateTime(ere.Year - 1, ere.Month, 1);
  625. }
  626. var (start1, end1) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow);
  627. var (start2, end2) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "week");
  628. var (start3, end3) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "lastweek");
  629. var (start4, end4) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "term");
  630. var (start5, end5) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "lastterm");
  631. var (start6, end6) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "month");
  632. var (start7, end7) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "year");
  633. var start = GetMonthStart(ere);
  634. var end = GetMonthEnd(ere);
  635. List<MonthStartEnd> endList1 = TimeHelper.GetYearMonthlyStartEnd(DateTimeOffset.UtcNow.Year);
  636. //return Ok(new { strList, dateTime, year, start, end, endList, endList1, endList2 });
  637. return Ok(new { day7, day30, datetime7, start1, end1, start2, end2, start3, end3, start4, end4, start5, end5, start6, end6, start7, end7 });
  638. }
  639. public static List<string> monthsOfYear(string yearMonth)
  640. {
  641. DateTime dateTime = DateTime.Parse(yearMonth);
  642. int year = dateTime.Year;
  643. int month = dateTime.Month;
  644. List<string> months = new List<string>();
  645. while (year > dateTime.Year - 1 || month > dateTime.Month)
  646. {
  647. months.Add($"{year}-{(month < 10 ? "0" : "") + month}");
  648. month -= 1;
  649. if (month <= 0)
  650. {
  651. year -= 1;
  652. month = 12;
  653. }
  654. }
  655. return months;
  656. }
  657. /// <summary>
  658. /// 统计一年中每月得新增校
  659. /// </summary>
  660. /// <returns></returns>
  661. [HttpPost("get-yearmonth")]
  662. public async Task<IActionResult> GetYearMonth()
  663. {
  664. var cosmosClient = _azureCosmos.GetCosmosClient();
  665. Dictionary<int, long> tempYear = new();
  666. List<TempSchool> tempSchools = new();
  667. for (int i = 1; i < 13; i++)
  668. {
  669. var start = 00022222330;
  670. long tempCount = 0;
  671. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"SELECT c._ts,c.name,c.id FROM c WHERE c._ts>={start}L", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  672. {
  673. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  674. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  675. {
  676. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  677. {
  678. TempSchool tempSchool = new();
  679. tempSchool.id = obj.GetProperty("id").GetString();
  680. tempSchool.ts = obj.GetProperty("_ts").GetInt64();
  681. tempSchool.name = obj.GetProperty("name").GetString();
  682. tempSchools.Add(tempSchool);
  683. }
  684. tempCount += count.GetInt64();
  685. }
  686. }
  687. if (tempCount != 0)
  688. {
  689. tempYear.Add(i, tempCount);
  690. }
  691. }
  692. return Ok(new { state = 200, tempYear, tempSchools });
  693. }
  694. /// <summary>
  695. /// 测试.net 6 的一些特性
  696. /// </summary>
  697. /// <returns></returns>
  698. [HttpPost("get-newnet6")]
  699. public async Task<IActionResult> GetNewNet6()
  700. {
  701. ///PriorityQueue
  702. //.NET 6 新增的数据结构, PriorityQueue, 队列每个元素都有一个关联的优先级,它决定了出队顺序, 编号小的元素优先出列。
  703. PriorityQueue<string, int> priorityQueue = new();
  704. priorityQueue.Enqueue("Second", 2);
  705. priorityQueue.Enqueue("Fourth", 4);
  706. priorityQueue.Enqueue("Third 1", 3);
  707. priorityQueue.Enqueue("Third 2", 5);
  708. priorityQueue.Enqueue("First", 1);
  709. while (priorityQueue.Count > 0)
  710. {
  711. string item = priorityQueue.Dequeue();
  712. Console.WriteLine(item);
  713. }
  714. //PeriodicTimer
  715. //认识一个完全异步的“PeriodicTimer”, 更适合在异步场景中使用, 它有一个方法 WaitForNextTickAsync。
  716. //using PeriodicTimer timer = new(TimeSpan.FromSeconds(2));
  717. //while (await timer.WaitForNextTickAsync())
  718. //{
  719. // Console.WriteLine(DateTime.UtcNow);
  720. //}
  721. //检查元素是否可为空的反射API
  722. var example = new Example();
  723. var nullabilityInfoContext = new NullabilityInfoContext();
  724. foreach (var propertyInfo in example.GetType().GetProperties())
  725. {
  726. var nullabilityInfo = nullabilityInfoContext.Create(propertyInfo);
  727. Console.WriteLine($"{propertyInfo.Name} property is {nullabilityInfo.WriteState}");
  728. }
  729. //直接通过 Environment 获取进程ID和路径。
  730. int processId = Environment.ProcessId;
  731. string path = Environment.ProcessPath;
  732. Console.WriteLine(processId);
  733. Console.WriteLine(path);
  734. //CSPNG 密码安全伪随机数生成器
  735. byte[] bytes = RandomNumberGenerator.GetBytes(300);
  736. Console.WriteLine(string.Join("", bytes.ToArray()));
  737. //Power of 2
  738. //.NET 6 引入了用于处理 2 的幂的新方法。
  739. //‘IsPow2’ 判断指定值是否为 2 的幂。
  740. //‘RoundUpToPowerOf2’ 将指定值四舍五入到 2 的幂
  741. Console.WriteLine(BitOperations.IsPow2(121)); // True
  742. Console.WriteLine(BitOperations.RoundUpToPowerOf2(260)); // 256
  743. //WaitAsync on Task 您可以更轻松地等待异步任务执行, 如果超时会抛出 “TimeoutException”
  744. Task operationTask = DoSomethingLongAsync();
  745. await operationTask.WaitAsync(TimeSpan.FromSeconds(5));
  746. async Task DoSomethingLongAsync()
  747. {
  748. Console.WriteLine("DoSomethingLongAsync started.");
  749. await Task.Delay(TimeSpan.FromSeconds(10));
  750. Console.WriteLine("DoSomethingLongAsync ended.");
  751. }
  752. //新的数学API
  753. // New methods SinCos, ReciprocalEstimate and ReciprocalSqrtEstimate
  754. // Simultaneously computes Sin and Cos
  755. (double sin, double cos) = Math.SinCos(1.57);
  756. Console.WriteLine($"Sin = {sin}\nCos = {cos}");
  757. // Computes an approximate of 1 / x
  758. double recEst = Math.ReciprocalEstimate(5);
  759. Console.WriteLine($"Reciprocal estimate = {recEst}");
  760. // Computes an approximate of 1 / Sqrt(x)
  761. double recSqrtEst = Math.ReciprocalSqrtEstimate(5);
  762. Console.WriteLine($"Reciprocal sqrt estimate = {recSqrtEst}");
  763. // New overloads
  764. // Min, Max, Abs, Clamp and Sign supports nint and nuint
  765. (nint a, nint b) = (5, 10);
  766. nint min = Math.Min(a, b);
  767. nint max = Math.Max(a, b);
  768. nint abs = Math.Abs(a);
  769. nint clamp = Math.Clamp(abs, min, max);
  770. nint sign = Math.Sign(a);
  771. Console.WriteLine($"Min = {min}\nMax = {max}\nAbs = {abs}");
  772. Console.WriteLine($"Clamp = {clamp}\nSign = {sign}");
  773. // DivRem variants return a tuple
  774. (int quotient, int remainder) = Math.DivRem(2, 7);
  775. Console.WriteLine($"Quotient = {quotient}\nRemainder = {remainder}");
  776. //CollectionsMarshal.GetValueRefOrNullRef
  777. //这个是在字典中循环或者修改结可变结构体时用, 可以减少结构的副本复制, 也可以避免字典重复进行哈希计算,这个有点晦涩难懂
  778. Dictionary<int, MyStruct> dictionary = new()
  779. {
  780. { 1, new MyStruct { Count = 100 } }
  781. };
  782. int key = 1;
  783. MyStruct values = CollectionsMarshal.GetValueRefOrNullRef(dictionary, key);
  784. // Returns Unsafe.NullRef<TValue>() if it doesn't exist; check using Unsafe.IsNullRef(ref value)
  785. if (!Unsafe.IsNullRef(ref values))
  786. {
  787. Console.WriteLine(values.Count); // Output: 100
  788. // Mutate in-place
  789. values.Count++;
  790. Console.WriteLine(values.Count); // Output: 101
  791. }
  792. return Ok(new { state = 200 });
  793. }
  794. /// <summary>
  795. /// 去重、判断
  796. /// </summary>
  797. /// <param name="jsonElement"></param>
  798. /// <returns></returns>
  799. [HttpPost("get-repeat")]
  800. public async Task<IActionResult> GetRepeat(JsonElement jsonElement)
  801. {
  802. jsonElement.TryGetProperty("datetime", out JsonElement _datetime);
  803. Dictionary<string, string> prodict = new() { { "YMPCVCIM", "学情分析模组" }, { "IPDYZYLC", "智慧学校管理服务" }, { "3CLYJ6NP", "AClass ONE智慧学伴" }, { "IPALJ6NY", "数据储存服务空间" }, { "VABAJ6NV", "卷卡合一阅卷系统" } };
  804. var ste = prodict["IPDYZYLC"];
  805. List<string> str_str = new() { "12", "20", "13", "13", "14", "16" };
  806. List<strend> strends = new() { new strend { id = 1, name = "12", age = 20 }, new strend { id = 1, name = "13", age = 20 }, new strend { id = 2, name = "22", age = 22 }, new strend { id = 3, name = "23", age = 23 } };
  807. //str_str.Distinct().ToList();
  808. strends.Where((x, i) => strends.FindIndex(z => z.id.Equals(x.id)) == i).ToList();
  809. List<strend> str_strend1 = strends.Where((x, i) => strends.FindIndex(z => z.id.Equals(x.id)) == i).ToList();
  810. List<strend> str_strend2 = strends.GroupBy(p => p).Select(p => p.Key).ToList();//去重复
  811. DateTime dt = DateTime.Parse($"{_datetime}");
  812. int year = dt.Year;
  813. DateTime dt0 = new DateTime(year, 1, 1);
  814. int days = (dt.Date - dt0.Date).Days + 1;
  815. //int pydays = ((lastYear + 1) % 4 == 0 && (lastYear + 1) % 100 != 0 || (lastYear + 1) % 400 == 0) ? 366 : 365;
  816. int pydays = (year % 4 == 0 && year % 100 != 0 || year % 400 == 0) ? 366 : 365;
  817. //int pydays = DateTimeHelper.getDays(year);
  818. return Ok(new { state = 200, pydays, days, strends, str_strend1, str_strend2, ste });
  819. }
  820. /// <summary>
  821. /// 计算天数
  822. /// </summary>
  823. /// <param name="jsonElement"></param>
  824. /// <returns></returns>
  825. [HttpPost("get-dateday")]
  826. public async Task<IActionResult> GetDateDay(JsonElement jsonElement)
  827. {
  828. jsonElement.TryGetProperty("year", out JsonElement _year);
  829. jsonElement.TryGetProperty("moth", out JsonElement _moth);
  830. int year = int.Parse($"{_year}");
  831. int day = 0;
  832. List<int> moths = _moth.ToObject<List<int>>();
  833. foreach (var item in moths)
  834. {
  835. int days = 0;
  836. switch (item)
  837. {
  838. case 1:
  839. case 3:
  840. case 5:
  841. case 7:
  842. case 8:
  843. case 10:
  844. case 12:
  845. days = 31;
  846. break;
  847. case 4:
  848. case 6:
  849. case 9:
  850. case 11:
  851. days = 30;
  852. break;
  853. case 2:
  854. int years = 0;
  855. if (item <= 8 && item >= 3)
  856. years = year;
  857. else
  858. years = year + 1;
  859. if (years % 4 == 0 && year % 100 != 0 || year % 400 == 0)
  860. days = 29;
  861. else
  862. days = 28;
  863. break;
  864. }
  865. day += days;
  866. }
  867. return Ok(new { state = 200, day });
  868. }
  869. /// <summary>
  870. /// 测试CosmosDB分页查询 SQL语句分页
  871. /// </summary>
  872. /// <param name="jsonElement"></param>
  873. /// <returns></returns>
  874. [HttpPost("get-page")]
  875. public async Task<IActionResult> cosmosDBPage(JsonElement jsonElement)
  876. {
  877. if (!jsonElement.TryGetProperty("pageSize", out JsonElement pageSize)) return BadRequest();
  878. if (!jsonElement.TryGetProperty("endPosition", out JsonElement endPosition)) return BadRequest();
  879. var cosmosClient = _azureCosmos.GetCosmosClient();
  880. List<School> schools = new List<School>();
  881. //string sqlTxt = $"SELECT * FROM c where c.code='Base' order by c.id offset {endPosition} limit {pageSize}";
  882. string sqlTxt = $"SELECT * FROM c order by c.id offset {pageSize} limit {endPosition}";
  883. await foreach (var tempPage in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  884. {
  885. using var json = await JsonDocument.ParseAsync(tempPage.ContentStream);
  886. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
  887. {
  888. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  889. {
  890. schools.Add(obj.ToObject<School>());
  891. }
  892. }
  893. }
  894. IAsyncResult iAsyncResult = null;
  895. return Ok(new { state = 200, schools });
  896. }
  897. /// <summary>
  898. /// 分页案例
  899. /// </summary>
  900. /// <param name="jsonElement"></param>
  901. /// <returns></returns>
  902. [HttpPost("get-cosmodbtokenpage")]
  903. public async Task<IActionResult> GetCancellationTokenPage(JsonElement jsonElement)
  904. {
  905. var cosmosClient = _azureCosmos.GetCosmosClient();
  906. //默认不指定返回大小
  907. int? pageSize = null;
  908. string continuationToken = string.Empty;
  909. string pageToken = default;
  910. if (jsonElement.TryGetProperty("pageSize", out JsonElement jsonPageSize))
  911. {
  912. if (!jsonPageSize.ValueKind.Equals(JsonValueKind.Undefined) && !jsonPageSize.ValueKind.Equals(JsonValueKind.Null) && jsonPageSize.TryGetInt32(out int tempPageSize))
  913. {
  914. pageSize = tempPageSize;
  915. }
  916. }
  917. //是否需要进行分页查询,默认不分页
  918. bool iscontinuation = false;
  919. if (pageSize != null && pageSize.Value > 0)
  920. {
  921. iscontinuation = true;
  922. }
  923. if (jsonElement.TryGetProperty("contToken", out JsonElement ContToken))
  924. {
  925. pageToken = ContToken.GetString();
  926. }
  927. List<School> schools = new();
  928. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: "select value(c) from c", continuationToken: pageToken, requestOptions: new QueryRequestOptions() { MaxItemCount = pageSize, PartitionKey = new PartitionKey("Base") }))
  929. {
  930. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  931. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  932. {
  933. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  934. {
  935. schools.Add(obj.ToObject<School>());
  936. }
  937. if (iscontinuation)
  938. {
  939. continuationToken = item.GetContinuationToken();
  940. break;
  941. }
  942. }
  943. }
  944. return Ok(new { state = 200, continuationToken, count = schools.Count, schools });
  945. }
  946. /// <summary>
  947. /// 测试
  948. /// </summary>
  949. /// <param name="jsonElement"></param>
  950. /// <returns></returns>
  951. [HttpPost("get-test")]
  952. public async Task<IActionResult> GetTest(JsonElement jsonElement)
  953. {
  954. List<Test> list1 = new();
  955. list1.Add(new Test { score = 10, name = "001" });
  956. list1.Add(new Test { score = 20, name = "002" });
  957. list1.Add(new Test { score = 30, name = "003" });
  958. list1.Add(new Test { score = 40, name = "004" });
  959. list1.Add(new Test { score = 50, name = "005" });
  960. list1.Add(new Test { score = 60, name = "006" });
  961. List<Test> list2 = new();
  962. list2.Add(new Test { score = 40, name = "004" });
  963. list2.Add(new Test { score = 50, name = "005" });
  964. list2.Add(new Test { score = 60, name = "006" });
  965. list2.Add(new Test { score = 70, name = "007" });
  966. list2.Add(new Test { score = 80, name = "008" });
  967. list2.Add(new Test { score = 90, name = "009" });
  968. list2.Add(new Test { score = 100, name = "010" });
  969. //list3 return 2
  970. List<Test> list3 = list1.Where(x => !list2.Any(x2 => x.score == x2.score && x.name == x2.name)).ToList();
  971. //list4 return 2
  972. List<Test> list4 = list1.Where(x => list2.All(x2 => x.score != x2.score)).ToList();
  973. List<Test> temp = list1.Where(p => !list2.Select(b => b.score).Contains(p.score)).ToList();
  974. //List<Test> mergedList = new List<Test>(list1);
  975. //mergedList.AddRange(list2.Except(list1));
  976. // var mergedList = list1.Union(list2);
  977. var en2 = list1.Concat(list2).Except(list1.Intersect(list2));// 容斥原理
  978. var bingji = list1.Union(list2).ToList();//并(全)集
  979. var cha = bingji.GroupBy(x => x.score).Select(c => c.First()).ToList();
  980. var jiaoji = list1.Intersect(list2).ToList();//交集
  981. var chaji = list1.Except(list2).ToList();//差集
  982. List<Test> have = list1.Where(a => !list2.Exists(t => a.score == t.score)).ToList();
  983. have.AddRange(list2.Where(a => !list1.Exists(t => a.score == t.score)).ToList());
  984. var ss = DateTime.Now.AddDays(0 - Convert.ToInt16(DateTime.Now.DayOfWeek) - 7).ToString("yyyy-MM-dd");//上周日
  985. var sss = DateTime.Now.AddDays(6 - Convert.ToInt16(DateTime.Now.DayOfWeek) - 7).ToString("yyyy-MM-dd");//上周六
  986. var ssss = DateTime.Now.AddDays(1 - Convert.ToInt16(DateTime.Now.DayOfWeek) - 7 + 1).ToString("yyyy-MM-dd");//上周一
  987. var sssss = DateTime.Now.AddDays(7 - Convert.ToInt16(DateTime.Now.DayOfWeek) - 7 + 1).ToString("yyyy-MM-dd");//上周日
  988. //计算上周
  989. var date = DateTime.Now;
  990. var m = (date.DayOfWeek == DayOfWeek.Sunday ? (DayOfWeek)7 : date.DayOfWeek) - DayOfWeek.Monday;
  991. var s = (date.DayOfWeek == DayOfWeek.Sunday ? (DayOfWeek)7 : date.DayOfWeek) - (DayOfWeek)7;
  992. var Mon = date.AddDays((-7 - m)).ToString("yyyy-MM-dd");
  993. var Sun = date.AddDays((-7 - s)).ToString("yyyy-MM-dd");
  994. var (lastWeekStart, lastWeekEnd) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "lastweek");
  995. return Ok(new { state = 200, Mon, Sun, ss, sss, ssss, sssss, lastWeekStart, lastWeekEnd, have, en2, bingji, cha, jiaoji, chaji, list3, list4, temp, list1 });
  996. }
  997. /// <summary>
  998. /// table 表分页查询
  999. /// </summary>
  1000. /// <param name="jsonElement"></param>
  1001. /// <returns></returns>
  1002. [HttpPost("get-tablepage")]
  1003. public async Task<IActionResult> GetTablePage(JsonElement jsonElement)
  1004. {
  1005. jsonElement.TryGetProperty("page", out JsonElement jpage);
  1006. jsonElement.TryGetProperty("size", out JsonElement jsize);
  1007. int page = string.IsNullOrEmpty($"{jsize}") ? 1 : int.Parse($"{jpage}");
  1008. int size = string.IsNullOrEmpty($"{jsize}") ? 2 : int.Parse($"{jsize}");
  1009. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  1010. List<BIOptLog> operateLogs = new();
  1011. //lambda 表达式排序
  1012. operateLogs = await table.QueryWhereString<BIOptLog>();
  1013. //lambda 排序 降序
  1014. operateLogs.Sort((x, y) => y.time.CompareTo(x.time));
  1015. List<BIOptLog> bIOptLogs = operateLogs.Skip((page - 1) * size).Take(size).ToList();
  1016. return Ok(new { state = 200, allcount = operateLogs.Count, bIOptLogs });
  1017. }
  1018. /// <summary>
  1019. /// 流式传输响应
  1020. /// </summary>
  1021. /// <returns></returns>
  1022. [HttpPost("get-stream")]
  1023. public async Task<IActionResult> GetStream()
  1024. {
  1025. var sw = Stopwatch.StartNew();
  1026. //while (true)
  1027. //{
  1028. // var q = new Queue<int>();
  1029. // for (int i = 0; i < 100_000_000; i++)
  1030. // {
  1031. // q.Enqueue(i);
  1032. // q.Dequeue();
  1033. // }
  1034. // Console.WriteLine(sw.Elapsed);
  1035. //}
  1036. var ss = new SortedSet<int>(Enumerable.Repeat(42, 400_000));
  1037. Console.WriteLine(sw.Elapsed);
  1038. HttpContext.Response.ContentType = "text/plain";
  1039. StreamWriter writer;
  1040. //using (writer = new StreamWriter(HttpContext.Response.Body))
  1041. // for (int i = 0; i < 100; i++)
  1042. // {
  1043. // await writer.WriteAsync($"S-{i} \n");
  1044. // }
  1045. // //await writer.FlushAsync("Hello World");
  1046. return Ok(new { state = 200 });
  1047. }
  1048. [HttpPost("get-linqcount")]
  1049. public async Task<IActionResult> GetLinqCount()
  1050. {
  1051. List<linqTest> linqTests = new();
  1052. for (int i = 0; i < 10; i++)
  1053. {
  1054. linqTest linqt = new() { id = $"qwe{i}", name = $"名字{i}", linq1s = new List<linq1> { new linq1 { id = $"abc{i}", times = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }, new linq1 { id = $"def{i}", times = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() } } };
  1055. linqTests.Add(linqt);
  1056. }
  1057. //var set = linqTests.Select((x, y) => x.linq1s.Find(l => l.id.Equals($"abc0"))).ToList();
  1058. var set = linqTests.Where(x => !string.IsNullOrEmpty(x.linq1s.Find(l => l.id.Equals($"abc0")).ToString()));
  1059. //var tem220p = linqTests.ForEach(x => {
  1060. // var coreUser = linqTests.Find(c => c.id.Equals("abc0"));
  1061. // }); //.Except(linqTests.Select(y => y.linq1s.Find(n => n.times.Equals("abc0"))));
  1062. return Ok(new { state = 200, linqTests, set });
  1063. }
  1064. /// <summary>
  1065. /// 多个连接字符串方式
  1066. /// </summary>
  1067. /// <returns></returns>
  1068. [HttpPost("get-manydb")]
  1069. public async Task<IActionResult> GetMany(JsonElement jsonElement)
  1070. {
  1071. jsonElement.TryGetProperty("site", out JsonElement site);//分开部署,就不需要,一站多用时,取消注释
  1072. var cosmosClient = _azureCosmos.GetCosmosClient();
  1073. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIDDUserInfo");
  1074. var redisClinet = _azureRedis.GetRedisClient(8);
  1075. ////分开部署,就不需要,一站多用时,取消注释
  1076. //if ($"{site}".Equals(BIConst.Global))
  1077. //{
  1078. // cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
  1079. // table = _azureStorage.GetCloudTableClient(BIConst.Global).GetTableReference("");
  1080. // redisClinet = _azureRedis.GetRedisClient(dbnum: 8, name: BIConst.Global);
  1081. //}
  1082. #region 依赖注入的方式
  1083. DateTimeOffset dateTime = DateTimeOffset.UtcNow;
  1084. var dateDay = dateTime.ToString("yyyyMMdd"); //获取当天的日期
  1085. Dictionary<long, int> allDays = new(); //所有在线人数
  1086. Dictionary<long, int> tchDays = new(); //教师在线人数
  1087. SortedSetEntry[] tchDay = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Login:IES:teacher:{dateDay}");
  1088. if (tchDay.Length > 0)
  1089. {
  1090. foreach (var item in tchDay)
  1091. {
  1092. int val = ((int)item.Score);
  1093. int key = ((int)item.Element);
  1094. var utcTo = new DateTimeOffset(new DateTime(dateTime.Year, dateTime.Month, dateTime.Day, key, 0, 0)).Hour;
  1095. //var hour = int.Parse(DateTime.SpecifyKind(Convert.ToDateTime($"{dateTime.Year}/{dateTime.Month}/{ dateTime.Day} {key}:00:00"), DateTimeKind.Utc).ToLocalTime().ToString("HH"));
  1096. tchDays.Add(utcTo, val);
  1097. if (allDays.ContainsKey(utcTo))
  1098. allDays[utcTo] = (allDays[utcTo] + val);
  1099. else
  1100. allDays.Add(utcTo, val);
  1101. }
  1102. }
  1103. var redisGl = _azureRedis.GetRedisClient(dbnum: 0, name: "Global");
  1104. var temps = await _azureRedis.GetRedisClient(dbnum: 0, name: "Global").SortedSetIncrementAsync($"Login:IES:Test", $"1", 1);//一天24小时 小时为单位
  1105. var cosmosDefaulat = _azureCosmos.GetCosmosClient(); //默认数据库
  1106. List<School> schools = new();
  1107. await foreach (var item in cosmosDefaulat.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<School>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1108. {
  1109. schools.Add(item);
  1110. }
  1111. var cosmosGlobal = _azureCosmos.GetCosmosClient(name: "Global"); //默认数据库
  1112. List<School> schoolGlobals = new();
  1113. await foreach (var item in cosmosGlobal.GetContainer("TEAMModelOS", "School").GetItemQueryIterator<School>(queryText: "select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  1114. {
  1115. schoolGlobals.Add(item);
  1116. }
  1117. return Ok(new { state = 200, dcnt = schools.Count, schools, dgcnt = schoolGlobals.Count, schoolGlobals });
  1118. ////table多库连接
  1119. //var tableDefulat = _azureStorage.GetCloudTableClient().GetTableReference("IESLogin"); //Table默认表
  1120. //List<DayLogin> hourLoginsDefualt = await tableDefulat.FindListByDict<DayLogin>(new Dictionary<string, object> { { "PartitionKey", $"DayLogin" } });
  1121. //var table = _azureStorage.GetCloudTableClient("Global").GetTableReference("IESLogin"); //Table国际站
  1122. //List<DayLogin> hourLogins= await table.FindListByDict<DayLogin>(new Dictionary<string, object> { { "PartitionKey", $"DayLogin" } });
  1123. //return Ok(new { state = 200, hourLogins, hourLoginsDefualt });
  1124. #endregion
  1125. #region 原始方式
  1126. //cosmosDB连接字符串
  1127. //var clientUrl = _configuration.GetValue<string>("Azure:CosmosUrl:ConnectionString");
  1128. //var clientKey = _configuration.GetValue<string>("Azure:CosmosKey:ConnectionString");
  1129. //CosmosClient cosmosClient = new(clientUrl, clientKey);
  1130. //var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync("hbcn", new PartitionKey("Base"));
  1131. //School school = new();
  1132. //if (response.Status == 200)
  1133. //{
  1134. // using var json = await JsonDocument.ParseAsync(response.ContentStream);
  1135. // school = json.ToObject<School>();
  1136. //}
  1137. //Table连接字符串
  1138. //var tableUrl = _configuration.GetValue<string>("Azure:StorageUrl:ConnectionString");
  1139. //Uri url = new(tableUrl, UriKind.Absolute);
  1140. //var tableKey = _configuration.GetValue<string>("Azure:StorageKey:ConnectionString");
  1141. //StorageCredentials sta = new StorageCredentials("teammodeltest", tableKey);
  1142. //CloudTableClient cloudTableClient = new CloudTableClient(url, sta);
  1143. //var table1 = cloudTableClient.GetTableReference("IESLogin");
  1144. //var tableGlobal = _configuration.GetValue<string>("AzureGlobal");
  1145. //Dictionary<string, object> dic = new() { { "PartitionKey", $"HourLogin" } };
  1146. //List<HourLogin> hourLogin = await table1.FindListByDict<HourLogin>(dic);
  1147. //List<HourLogin> hourLogin1= await table.FindListByDict<HourLogin>(dic);
  1148. //var table = _azureStorage.GetCloudTableClient().GetTableReference("IESLogin");
  1149. //return Ok(new { state = 200 });
  1150. #endregion
  1151. }
  1152. /// <summary>
  1153. ///
  1154. /// </summary>
  1155. /// <param name="jsonElement"></param>
  1156. /// <returns></returns>
  1157. [HttpPost("get-loganalyse")]
  1158. public async Task<IActionResult> GetLogAnalyse(JsonElement jsonElement)
  1159. {
  1160. if (!jsonElement.TryGetProperty("path", out JsonElement path)) return BadRequest();
  1161. if (!jsonElement.TryGetProperty("timeType", out JsonElement jTimeType)) return BadRequest();
  1162. List<string> filename = new();
  1163. ////删除过期Blob 文件
  1164. //var azureClient = _azureStorage.GetBlobContainerClient("0-public");//获取容器连接地址
  1165. //int expireTime = int.Parse(DateTimeOffset.UtcNow.AddDays(-180).ToString("yyyyMMdd"));
  1166. //await foreach (var blobItem in azureClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, prefix: "visitCnt"))
  1167. //{
  1168. // string[] sub_name = blobItem.Name.Split('/');
  1169. // if (sub_name.Length > 2)
  1170. // {
  1171. // if (int.Parse(sub_name[1]) <= expireTime)
  1172. // {
  1173. // await azureClient.GetBlobBaseClient(blobItem.Name).DeleteIfExistsAsync();
  1174. // filename.add(sub_name[1]);
  1175. // }
  1176. // }
  1177. //}
  1178. var (an, saveUrl) = await BILogAnalyseService.GetPathAnalyse(_azureStorage, _ipSearcher, _dingDing, $"{path}", BIConst.LogChina, timeType:$"{jTimeType}");
  1179. return Ok(new { state = RespondCode.Ok, cnt = filename.Count, filename, an, saveUrl });
  1180. }
  1181. /// <summary>
  1182. /// 小时/天读取防火墙文件,分析;
  1183. /// </summary>
  1184. /// <param name="jsonElement"></param>
  1185. /// <returns></returns>
  1186. [HttpPost("get-savefile")]
  1187. public async Task<IActionResult> GetSaveFile(JsonElement jsonElement)
  1188. {
  1189. if (!jsonElement.TryGetProperty("time", out JsonElement time)) return BadRequest();
  1190. long str = time.GetInt64();
  1191. DateTimeOffset dateTimeJ = TimeHelper.GetDateTime(str);
  1192. var datetime = dateTimeJ.AddHours(-1);
  1193. var y = datetime.Year;
  1194. var m = datetime.Month >= 10 ? $"{datetime.Month}" : $"0{datetime.Month}";
  1195. var d = datetime.Day >= 10 ? $"{datetime.Day}" : $"0{datetime.Day}";
  1196. var h = datetime.Hour >= 10 ? $"{datetime.Hour}" : $"0{datetime.Hour}";
  1197. string path = $"resourceId=/SUBSCRIPTIONS/73B7F9EF-D8B7-4444-9E8D-D80B43BF3CD4/RESOURCEGROUPS/TEAMMODELCHENGDU/PROVIDERS/MICROSOFT.NETWORK/APPLICATIONGATEWAYS/OSFIREWARE/y={y}/m={m}/d={d}/h={h}/m=00/PT1H.json";
  1198. var retn = await BILogAnalyseService.GetPathAnalyse(_azureStorage, _ipSearcher, _dingDing, path, BIConst.LogChina);
  1199. if (retn.recCnts.IsNotEmpty())
  1200. {
  1201. //https://teammodelos.blob.core.chinacloudapi.cn/0-public/pie-borderRadius.html
  1202. string publishUrl = $"https://teammodelos.blob.core.chinacloudapi.cn/0-public/api-count.html?url={HttpUtility.UrlEncode(retn.saveUrls.First(), Encoding.UTF8)}&time={HttpUtility.UrlEncode(datetime.AddHours(8).ToString("yyyy年MM月dd日 HH时"), Encoding.UTF8)}";
  1203. string ulrs = $"https://teammodelos.blob.core.chinacloudapi.cn/0-public/api-count.html?url={retn.saveUrls.First()}&time={datetime.AddHours(8).ToString("yyyy年MM月dd日 HH时")}";
  1204. string ulr = $"http://cdhabook.teammodel.cn:8805/screen/screenshot-png?width=1920&height=1450&url={HttpUtility.UrlEncode(ulrs, Encoding.UTF8)}&delay=6000";
  1205. string image = "";
  1206. try
  1207. {
  1208. string strs = await _httpClient.GetStringAsync(ulr);
  1209. if (!string.IsNullOrWhiteSpace(strs))
  1210. {
  1211. JsonElement json = strs.ToObject<JsonElement>();
  1212. json.TryGetProperty("url", out JsonElement base64);
  1213. using (MemoryStream ms = new MemoryStream(Convert.FromBase64String($"{base64}")))
  1214. {
  1215. image = await _azureStorage.GetBlobContainerClient("0-public").UploadFileByContainer(ms, $"visitCnt/{y}{m}{d}", $"{h}.png", false);
  1216. }
  1217. }
  1218. }
  1219. catch (Exception ex) { }
  1220. //await _dingDing.SendBotMarkdown("防火墙日志记录", $"#### 测试(小时)-防火墙日志记录\n> 记录时间:{datetime.AddHours(8).ToString("yyyy-MM-dd HH")}\n> ![screenshot]({image})\n> ###### 发布时间:{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}" +
  1221. // $" [发布地址]({publishUrl}) \n", GroupNames.醍摩豆服務運維群組);
  1222. }
  1223. if (h.Equals("00"))
  1224. {
  1225. var pastTime = datetime.AddHours(-1);
  1226. var ptY = pastTime.Year;
  1227. var ptM = pastTime.Month >= 10 ? $"{pastTime.Month}" : $"0{pastTime.Month}";
  1228. var ptD = pastTime.Day >= 10 ? $"{pastTime.Day}" : $"0{pastTime.Day}";
  1229. string dayPath = $"resourceId=/SUBSCRIPTIONS/73B7F9EF-D8B7-4444-9E8D-D80B43BF3CD4/RESOURCEGROUPS/TEAMMODELCHENGDU/PROVIDERS/MICROSOFT.NETWORK/APPLICATIONGATEWAYS/OSFIREWARE/y={ptY}/m={ptM}/d={ptD}";
  1230. var dayRetn = await BILogAnalyseService.GetPathAnalyse(_azureStorage, _ipSearcher, _dingDing, dayPath, BIConst.LogChina, timeType: "Day");
  1231. if (dayRetn.recCnts.IsNotEmpty())
  1232. {
  1233. //一天的统计
  1234. string dayPublishUrl = $"https://teammodelos.blob.core.chinacloudapi.cn/0-public/api-count.html?url={HttpUtility.UrlEncode(dayRetn.saveUrls.First(), Encoding.UTF8)}&time={HttpUtility.UrlEncode(pastTime.ToString("yyyy年MM月dd日"), Encoding.UTF8)}";
  1235. string dayUrls = $"https://teammodelos.blob.core.chinacloudapi.cn/0-public/api-count.html?url={dayRetn.saveUrls.First()}&time={pastTime.ToString("yyyy年MM月dd日")}";
  1236. string dayUrl = $"http://cdhabook.teammodel.cn:8805/screen/screenshot-png?width=1920&height=1450&url={HttpUtility.UrlEncode(dayUrls, Encoding.UTF8)}&delay=6000";
  1237. string dayImage = "";
  1238. string dayStr = await _httpClient.GetStringAsync(dayUrl);
  1239. if (!string.IsNullOrWhiteSpace(dayStr))
  1240. {
  1241. JsonElement dayJson = dayStr.ToObject<JsonElement>();
  1242. dayJson.TryGetProperty("url", out JsonElement dayBase64);
  1243. using (MemoryStream dayMs = new(Convert.FromBase64String($"{dayBase64}")))
  1244. {
  1245. dayImage = await _azureStorage.GetBlobContainerClient("0-public").UploadFileByContainer(dayMs, $"visitCnt/{ptY}{ptM}{ptD}", "days.png", false);
  1246. }
  1247. }
  1248. await _dingDing.SendBotMarkdown("测试-防火墙日志记录", $"#### 测试(天)-防火墙日志记录\n> 记录时间:{pastTime.AddHours(2).ToString("yyyy-MM-dd")}\n> ![screenshot]({dayImage})\n> ###### 发布时间:{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}" +$" [发布地址]({dayPublishUrl}) \n", GroupNames.成都开发測試群組);
  1249. }
  1250. }
  1251. return Ok(new { state = 200});
  1252. }
  1253. /// <summary>
  1254. /// 测试研究table 表分页的问题
  1255. /// </summary>
  1256. /// <param name="jsonElement"></param>
  1257. /// <returns></returns>
  1258. [HttpPost("get-logrec")]
  1259. public async Task<IActionResult> GetLogRec(JsonElement jsonElement)
  1260. {
  1261. int takeCount = 500;
  1262. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  1263. var table1 = _azureStorage.GetCloudTableClient();
  1264. int pagesize = 10;
  1265. int pageNum = 2;
  1266. var query = (from entity in table.CreateQuery<BIOptLog>()
  1267. select entity).ToList().Skip(pagesize * (pageNum - 1)).Take(pagesize);
  1268. //var query = (from entity in table.CreateQuery<BIOptLog>()
  1269. // orderby entity.time descending
  1270. // select entity).Skip(pagesize * (pageNum - 1)).Take(pagesize);
  1271. //var ster = AzureStorageTableExtensions.GetTablePage<BIOptLog>(table1, "BIOptLog", 10, 1);
  1272. return Ok(new { state = 200, query });
  1273. }
  1274. [HttpPost("get-noticev2")]
  1275. public async Task<IActionResult> SetNoticeV2()
  1276. {
  1277. var cosmosClient = _azureCosmos.GetCosmosClient();
  1278. //v2通知
  1279. Teacher targetTeacher = await cosmosClient.GetContainer(Constant.TEAMModelOS, Constant.Teacher).ReadItemAsync<Teacher>("1636016499", new PartitionKey("Base"));
  1280. _coreAPIHttpService.PushNotify(new List<IdNameCode> { new IdNameCode { id = targetTeacher.id, name = targetTeacher.name, code = targetTeacher.lang } }, "create-school", Constant.NotifyType_IES5_Management, new Dictionary<string, object> { { "tmdname", $"{targetTeacher.name}" }, { "schooName", "商务智能学校(BI)" }, { "schoolId", "cswznb" }, { "tmdid", $"{targetTeacher.id}" } }, _option.Location, _configuration, _dingDing, _environment.ContentRootPath);
  1281. return Ok(new { state = RespondCode.Ok });
  1282. }
  1283. [HttpPost("set-copyfile")]
  1284. public async Task<IActionResult> SetCopyFile()
  1285. {
  1286. List<Task<CopyFromUriOperation>> filelist = new List<Task<CopyFromUriOperation>>();
  1287. //var azureClient = _azureStorage.GetBlobContainerClient($"0-public");//获取容器连接地址
  1288. ////查询目录下所有容器路径
  1289. //await foreach (BlobItem blobItem in azureClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, $"TestMP4Max/"))
  1290. //{
  1291. // string newurl = $"{blobItem.Name}".Replace($"/SourceFile/", $"/SourceFiles/");//替换成新的容器路径
  1292. // var urlSas = _azureStorage.GetBlobSAS($"0-public", blobItem.Name, BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  1293. // //await azureClient.GetBlobClient(newurl).StartCopyFromUriAsync(new Uri(urlSas));
  1294. // filelist.Add(azureClient.GetBlobClient(newurl).StartCopyFromUriAsync(new Uri(urlSas)));
  1295. // //await azureClient.GetBlobClient(newurl).SyncCopyFromUriAsync(new Uri(urlSas)); //添加复制文件到集合执行复制操作
  1296. //}
  1297. //if (filelist.Count <= 256)
  1298. //{
  1299. // await Task.WhenAll(filelist);
  1300. //}
  1301. //else
  1302. //{
  1303. // int pages = (filelist.Count + 255) / 256;
  1304. // for (int i = 0; i < pages; i++)
  1305. // {
  1306. // List<Task<CopyFromUriOperation>> rspBlobCopyInfos = filelist.Skip((i) * 256).Take(256).ToList();
  1307. // await Task.WhenAll(rspBlobCopyInfos);
  1308. // }
  1309. //}
  1310. var azureClient = _azureStorage.GetBlobContainerClient($"1636016499");//获取容器连接地址
  1311. //查询目录下所有容器路径
  1312. await foreach (BlobItem blobItem in azureClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, $"doc"))
  1313. {
  1314. string newurl = $"{blobItem.Name}".Replace($"doc/", $"/SourceFiles/");//替换成新的容器路径
  1315. var urlSas = _azureStorage.GetBlobSAS($"1636016499", blobItem.Name, BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  1316. //await azureClient.GetBlobClient(newurl).StartCopyFromUriAsync(new Uri(urlSas));
  1317. await azureClient.GetBlobClient(newurl).StartCopyFromUriAsync(new Uri(urlSas));
  1318. //await azureClient.GetBlobClient(newurl).SyncCopyFromUriAsync(new Uri(urlSas)); //添加复制文件到集合执行复制操作
  1319. }
  1320. return Ok(new { state = 200 , filelist });
  1321. }
  1322. [HttpPost("test-copy-file")]
  1323. public async Task<IActionResult> TestCaopyFile()
  1324. {
  1325. string blobName = "cswznb";
  1326. string oldFile = "https://teammodeltest.blob.core.chinacloudapi.cn/cswznb/survey%2Fd011c05b-c009-0a53-428f-b871a58092c7%2Findex.json";//"https://teammodeltest.blob.core.chinacloudapi.cn/1636016499/yxpt%2Fstandard2%2FTEAMModelOS%E6%95%B0%E6%8D%AE%E5%BA%93.doc";
  1327. string oldId = "survey";
  1328. string newId = "survey1";
  1329. List<Task<CopyFromUriOperation>> filelist = new(); //可复制256M以上文件
  1330. //var set = await BatchCopyFileService.SingleCopyFile(_azureStorage, blobName, oldFile, oldId, newId);
  1331. var set = await SingleCopyFile(_azureStorage, blobName, oldFile, oldId, newId);
  1332. //var azureClient = _azureStorage.GetBlobContainerClient($"{blobName}");//获取容器连接地址
  1333. //string newurl = $"{oldFile}".Replace($"/{oldId}/", $"/{newId}/");//替换成新的容器路径
  1334. //var urlSas = _azureStorage.GetBlobSAS($"{blobName}", $"{newurl}", BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  1335. //var setr = azureClient.GetBlobClient(newurl).StartCopyFromUriAsync(new Uri(urlSas)); //可复制256M以上文件
  1336. return Ok(new { state = 200 });
  1337. }
  1338. public static Task<int> SingleCopyFile(AzureStorageFactory _azureStorage, string blobName, string oldFile, string oldId, string newId)
  1339. {
  1340. var azureClient = _azureStorage.GetBlobContainerClient($"{blobName}");//获取容器连接地址
  1341. string newurl = oldFile.Substring(oldFile.IndexOf($"{blobName}/") + $"{blobName}/".Length).Replace($"{oldId}", $"{newId}");//替换成新的容器路径
  1342. string oldFileName = oldFile.Substring(oldFile.IndexOf($"{blobName}/") + $"{blobName}/".Length);
  1343. var urlSas = _azureStorage.GetBlobSAS($"{blobName}", "", BlobSasPermissions.Read | BlobSasPermissions.List); //获取容器sas和有效期
  1344. //var respCopy = azureClient.GetBlobClient(HttpUtility.UrlDecode(newurl)).SyncCopyFromUri(new Uri(urlSas)); //可复制256M以下文件
  1345. var respCopy1 = azureClient.GetBlobClient(HttpUtility.UrlDecode(newurl)).StartCopyFromUriAsync(new Uri(urlSas)); //可复制256M以上文件
  1346. return null;
  1347. }
  1348. public class linqTest
  1349. {
  1350. public string id { get; set; }
  1351. public string name { get; set; }
  1352. public List<linq1> linq1s { get; set; }
  1353. }
  1354. public class linq1
  1355. {
  1356. public string id { get; set; }
  1357. public long times { get; set; }
  1358. }
  1359. public class Test
  1360. {
  1361. public int age { get; set; }
  1362. public string name { get; set; }
  1363. public int score { get; set; }
  1364. }
  1365. public class strend
  1366. {
  1367. public int id { get; set; }
  1368. public string name { get; set; }
  1369. public int age { get; set; }
  1370. }
  1371. struct MyStruct
  1372. {
  1373. public int Count { get; set; }
  1374. }
  1375. class Example
  1376. {
  1377. public string? Name { get; set; }
  1378. public string Value { get; set; }
  1379. }
  1380. public record TempSchool
  1381. {
  1382. public long ts { get; set; }
  1383. public string id { get; set; }
  1384. public string name { get; set; }
  1385. }
  1386. public static long GetMonthEnd(DateTimeOffset dt)
  1387. {
  1388. DateTime dtNew = new DateTime(dt.Year, dt.Month, 1);
  1389. var ste = dtNew.AddMonths(1).AddDays(-1).Day;
  1390. long iLastDay = DateTimeOffset.Parse($"{dt.Year}-{dt.Month}-{ste} 23:59:59").ToUnixTimeSeconds();
  1391. return iLastDay;
  1392. }
  1393. public static long GetMonthStart(DateTimeOffset dt)
  1394. {
  1395. DateTime dtNew = new DateTime(dt.Year, dt.Month, 1);
  1396. long iLastDay = DateTimeOffset.Parse($"{dtNew}").ToUnixTimeSeconds();
  1397. return iLastDay;
  1398. }
  1399. public class GenerateRandom1
  1400. {
  1401. /// <summary>
  1402. /// 生成随机数字
  1403. /// </summary>
  1404. /// <param name="length">生成长度</param>
  1405. /// <returns></returns>
  1406. public static string Number(int Length)
  1407. {
  1408. return Number(Length, false);
  1409. }
  1410. /// <summary>
  1411. /// 生成随机数字
  1412. /// </summary>
  1413. /// <param name="Length">生成长度</param>
  1414. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  1415. /// <returns></returns>
  1416. public static string Number(int Length, bool Sleep)
  1417. {
  1418. if (Sleep)
  1419. System.Threading.Thread.Sleep(3);
  1420. string result = "";
  1421. System.Random random = new Random();
  1422. for (int i = 0; i < Length; i++)
  1423. {
  1424. result += random.Next(10).ToString();
  1425. }
  1426. return result;
  1427. }
  1428. /// <summary>
  1429. /// 生成随机字母与数字
  1430. /// </summary>
  1431. /// <param name="IntStr">生成长度</param>
  1432. /// <returns></returns>
  1433. public static string Str(int Length)
  1434. {
  1435. return Str(Length, false);
  1436. }
  1437. /// <summary>
  1438. /// 生成随机字母与数字
  1439. /// </summary>
  1440. /// <param name="Length">生成长度</param>
  1441. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  1442. /// <returns></returns>
  1443. public static string Str(int Length, bool Sleep)
  1444. {
  1445. if (Sleep)
  1446. System.Threading.Thread.Sleep(3);
  1447. char[] Pattern = new char[] { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' };
  1448. string result = "";
  1449. int n = Pattern.Length;
  1450. System.Random random = new Random(~unchecked((int)DateTime.Now.Ticks));
  1451. for (int i = 0; i < Length; i++)
  1452. {
  1453. int rnd = random.Next(0, n);
  1454. result += Pattern[rnd];
  1455. }
  1456. return result;
  1457. }
  1458. /// <summary>
  1459. /// 生成随机纯字母随机数
  1460. /// </summary>
  1461. /// <param name="IntStr">生成长度</param>
  1462. /// <returns></returns>
  1463. public static string Str_char(int Length)
  1464. {
  1465. return Str_char(Length, false);
  1466. }
  1467. /// <summary>
  1468. /// 生成随机纯字母随机数
  1469. /// </summary>
  1470. /// <param name="Length">生成长度</param>
  1471. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  1472. /// <returns></returns>
  1473. public static string Str_char(int Length, bool Sleep)
  1474. {
  1475. if (Sleep) System.Threading.Thread.Sleep(3);
  1476. //char[] Pattern = new char[] { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' };
  1477. char[] Pattern = new char[] { 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z' };
  1478. string result = "";
  1479. int n = Pattern.Length;
  1480. System.Random random = new Random(~unchecked((int)DateTime.Now.Ticks));
  1481. for (int i = 0; i < Length; i++)
  1482. {
  1483. int rnd = random.Next(0, n);
  1484. result += Pattern[rnd];
  1485. }
  1486. return result;
  1487. }
  1488. }
  1489. }
  1490. }