TestController.cs 98 KB

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