TestController.cs 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210
  1. using Azure.Cosmos;
  2. using DingTalk.Api;
  3. using DingTalk.Api.Request;
  4. using DingTalk.Api.Response;
  5. using HTEXLib.COMM.Helpers;
  6. using Microsoft.AspNetCore.Hosting;
  7. using Microsoft.AspNetCore.Http;
  8. using Microsoft.AspNetCore.Mvc;
  9. using Microsoft.Azure.Cosmos.Table;
  10. using Microsoft.Extensions.Configuration;
  11. using Microsoft.Extensions.Options;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.ComponentModel.DataAnnotations;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Text.Json;
  18. using System.Threading.Tasks;
  19. using TEAMModelBI.Filter;
  20. using TEAMModelBI.Models;
  21. using TEAMModelBI.Tool;
  22. using TEAMModelOS.Models;
  23. using TEAMModelOS.SDK;//引用创建学校Code
  24. using TEAMModelOS.SDK.Context.Attributes.Azure;
  25. using TEAMModelOS.SDK.DI;
  26. using TEAMModelOS.SDK.Extension;
  27. using TEAMModelOS.SDK.Models;
  28. using TEAMModelOS.SDK.Models.Cosmos.BI;
  29. using TEAMModelOS.SDK.Models.Cosmos.Common;
  30. using TEAMModelOS.SDK.Models.Service;
  31. using TEAMModelOS.SDK.Models.Table;
  32. //.Net 6新的特性
  33. using System.Threading;
  34. using System.Reflection;
  35. using System.Numerics;
  36. using System.Security.Cryptography;
  37. using System.Runtime.InteropServices;
  38. using System.Runtime.CompilerServices;
  39. using System.IdentityModel.Tokens.Jwt;
  40. using TEAMModelBI.Tool.Extension;
  41. using System.IO;
  42. using static TEAMModelBI.Controllers.BISchool.BatchSchoolController;
  43. using System.Net.Http;
  44. using System.Net.Http.Json;
  45. using System.Net;
  46. namespace TEAMModelBI.Controllers.BITest
  47. {
  48. [Route("apitest")]
  49. [ApiController]
  50. public class TestController : ControllerBase
  51. {
  52. private readonly AzureCosmosFactory _azureCosmos;
  53. private readonly DingDing _dingDing;
  54. private readonly Option _option;
  55. private readonly AzureStorageFactory _azureStorage;
  56. private readonly IWebHostEnvironment _environment; //读取文件
  57. //读取配置文件
  58. private readonly IConfiguration _configuration;
  59. private readonly CoreAPIHttpService _coreAPIHttpService;
  60. private readonly HttpClient _httpClient;
  61. public TestController(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, IOptionsSnapshot<Option> option, IWebHostEnvironment hostingEnvironment, IConfiguration configuration, CoreAPIHttpService coreAPIHttpService, HttpClient httpClient)
  62. {
  63. _azureCosmos = azureCosmos;
  64. _dingDing = dingDing;
  65. _azureStorage = azureStorage;
  66. _option = option?.Value;
  67. _environment = hostingEnvironment;
  68. _configuration = configuration;
  69. _coreAPIHttpService = coreAPIHttpService;
  70. _httpClient = httpClient;
  71. }
  72. /// <summary>
  73. /// 删除册别,删除章节 创区
  74. /// </summary>
  75. /// <param name="jsonElement"></param>
  76. /// <returns></returns>
  77. [HttpPost("del-standard")]
  78. public async Task<IActionResult> DelStandard(JsonElement jsonElement)
  79. {
  80. if (!jsonElement.TryGetProperty("oldStandard", out JsonElement _oldStandard)) return BadRequest();
  81. var cosmosClient = _azureCosmos.GetCosmosClient();
  82. List<string> abilityIds = new List<string>(); //册别的ID集合
  83. //查询册别信息
  84. await foreach (var tempAbility in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<Ability>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Ability-{_oldStandard}") }))
  85. {
  86. abilityIds.Add(tempAbility.id); //查询出来册别ID添加册别ID集合
  87. }
  88. //删除册别
  89. if (abilityIds.IsNotEmpty())
  90. {
  91. var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityIds, $"Ability-{_oldStandard}");
  92. }
  93. List<string> abilityTaskIds = new List<string>(); //章节ID集合
  94. await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AbilityTask>(queryText: $"select value(c) from c", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AbilityTask-{_oldStandard}") }))
  95. {
  96. abilityTaskIds.Add(item.id); //查询出来的章节信息ID添加到战绩集合
  97. }
  98. //删除章节
  99. if (abilityTaskIds.IsNotEmpty())
  100. {
  101. var sresponse = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Normal").DeleteItemsStreamAsync(abilityTaskIds, $"AbilityTask-{_oldStandard}");
  102. }
  103. return Ok(new { state = 200 });
  104. }
  105. /// <summary>
  106. /// 测试生产Code
  107. /// </summary>
  108. /// <param name="jsonElement"></param>
  109. /// <returns></returns>
  110. [ProducesDefaultResponseType]
  111. [HttpPost("get-schoolcode")]
  112. public async Task<IActionResult> GetSchoolCode(JsonElement jsonElement)
  113. {
  114. //string data = await SchoolCode.GenerateSchoolCode(jsonElement, _dingDing, _environment).ToString();
  115. CreateSchoolInfo createSchoolInfo = new CreateSchoolInfo();
  116. createSchoolInfo.province = "四川省";
  117. createSchoolInfo.id = "tmdplc";
  118. createSchoolInfo.name = "醍摩豆批量创校学校";
  119. createSchoolInfo.city = "成都市";
  120. createSchoolInfo.aname = "";
  121. createSchoolInfo.createCount = 0;
  122. //Random random = new Random();
  123. ////随机小写字母
  124. //int a = random.Next(0, 26);
  125. //char ch = (char)('a' + a);
  126. //string Number = GenerateRandom.Number(1);
  127. //string Number1 = GenerateRandom.Number(1, true);
  128. //string Str = GenerateRandom.Str(1);
  129. //string Str1 = GenerateRandom.Str(1, true);
  130. //string Str_char = GenerateRandom.Str_char(1);
  131. //string Str_char1 = GenerateRandom.Str_char(1, true);
  132. CreateSchoolInfo data = await SchoolCode.GenerateSchoolCode(createSchoolInfo, _dingDing, _environment);
  133. return Ok(new { state = 200, data, data.id });
  134. }
  135. /// <summary>
  136. /// 保存日志文件
  137. /// </summary>
  138. /// <param name="jsonElement"></param>
  139. /// <returns></returns>
  140. [ProducesDefaultResponseType]
  141. [AuthToken(Roles = "assist")]
  142. [HttpPost("set-savebilog")]
  143. public async Task<IActionResult> SetTestSaveBIlog(JsonElement jsonElement)
  144. {
  145. var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
  146. await _azureStorage.SaveLog(type: "table-save", msg: "测试保存方法01", dingDing: _dingDing, httpContext: HttpContext); //IES5 日志记录
  147. await _azureStorage.SaveBILog("Test-add", $"{_tmdName}【{_tmdId}】删除册别,删除ID:", _dingDing, httpContext: HttpContext);//BI 日志记录
  148. return Ok(new { state = 200 });
  149. }
  150. /// <summary>
  151. /// 查询table数据
  152. /// </summary>
  153. /// <param name="jsonElement"></param>
  154. /// <returns></returns>
  155. [HttpPost("file-table")]
  156. public async Task<IActionResult> SaveTable(JsonElement jsonElement)
  157. {
  158. jsonElement.TryGetProperty("single", out JsonElement single);
  159. jsonElement.TryGetProperty("startDate", out JsonElement startDate);
  160. jsonElement.TryGetProperty("endDate", out JsonElement endDate);
  161. jsonElement.TryGetProperty("platform", out JsonElement platform);
  162. List<string> strlist = new List<string>();
  163. if (!string.IsNullOrEmpty($"{single}"))
  164. strlist.Add($"RowKey {QueryComparisons.Equal} {single}");
  165. if (!string.IsNullOrEmpty($"{startDate}"))
  166. strlist.Add($"RowKey {QueryComparisons.GreaterThanOrEqual} {startDate}");
  167. if (!string.IsNullOrEmpty($"{endDate}"))
  168. strlist.Add($"RowKey {QueryComparisons.LessThanOrEqual} {endDate}");
  169. if (!string.IsNullOrEmpty($"{platform}"))
  170. strlist.Add($"platform {QueryComparisons.Equal} {platform}");
  171. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  172. string sql = string.Join(" and ", strlist);
  173. var temp = table.QueryWhereString<BIOptLog>(sql);
  174. return Ok(new { state = 200, temp });
  175. }
  176. /// <summary>
  177. /// 查询BI操作记录
  178. /// </summary>
  179. /// <param name="jsonElement"></param>
  180. /// <returns></returns>
  181. [HttpPost("get-operatelogbydate")]
  182. public async Task<IActionResult> GetOperateLogByDate(JsonElement jsonElement)
  183. {
  184. try
  185. {
  186. jsonElement.TryGetProperty("single", out JsonElement single);
  187. jsonElement.TryGetProperty("startDate", out JsonElement startDate);
  188. jsonElement.TryGetProperty("endDate", out JsonElement endDate);
  189. jsonElement.TryGetProperty("platform", out JsonElement platform);
  190. List<BIOptLog> operateLogs = new();
  191. StringBuilder tableSql = new();
  192. if (!string.IsNullOrEmpty($"{single}"))
  193. tableSql.Append($"RowKey {QueryComparisons.Equal} '{single}' ");
  194. if (!string.IsNullOrEmpty($"{startDate}"))
  195. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} RowKey {QueryComparisons.GreaterThanOrEqual} '{startDate}' " : $"RowKey {QueryComparisons.GreaterThanOrEqual} '{startDate}' ");
  196. if (!string.IsNullOrEmpty($"{endDate}"))
  197. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} RowKey {QueryComparisons.LessThanOrEqual} '{endDate}' " : $" RowKey { QueryComparisons.LessThanOrEqual} '{endDate}' ");
  198. if (!string.IsNullOrEmpty($"{platform}"))
  199. tableSql.Append(!string.IsNullOrEmpty(tableSql.ToString()) ? $" {TableOperators.And} platform {QueryComparisons.Equal} '{platform}' " : $" platform {QueryComparisons.Equal} '{platform}' ");
  200. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIOptLog");
  201. operateLogs = await table.QueryWhereString<BIOptLog>(tableSql.ToString());
  202. return Ok(new { state = 200, operateLogs });
  203. }
  204. catch (Exception ex)
  205. {
  206. await _dingDing.SendBotMsg($"BI,{_option.Location} /operatelog/get-operatelogbydate \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  207. return BadRequest();
  208. }
  209. }
  210. /// <summary>
  211. /// 查询离职信息
  212. /// </summary>
  213. /// <returns></returns>
  214. [ProducesDefaultResponseType]
  215. [HttpPost("quitstaff")]
  216. public async Task<IActionResult> QuitStaff()
  217. {
  218. string appKey = _configuration["DingDingAuth:appKey"];
  219. string appSecret = _configuration["DingDingAuth:appSecret"];
  220. string agentld = _configuration["DingDingAuth:Agentld"];
  221. //获取access_token
  222. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  223. OapiGettokenRequest request = new OapiGettokenRequest() { Appkey = appKey, Appsecret = appSecret };
  224. request.SetHttpMethod("Get");
  225. OapiGettokenResponse response = client.Execute(request);
  226. if (response.IsError)
  227. {
  228. return BadRequest();
  229. }
  230. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  231. string access_token = response.AccessToken;
  232. IDingTalkClient quitStaffClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querydimission");
  233. OapiSmartworkHrmEmployeeQuerydimissionRequest reqDimission = new OapiSmartworkHrmEmployeeQuerydimissionRequest() { Offset = 0L, Size = 50L };
  234. OapiSmartworkHrmEmployeeQuerydimissionResponse rspDimission = quitStaffClient.Execute(reqDimission, access_token);
  235. if (rspDimission.SubErrCode == "60011")
  236. {
  237. return Ok(new { state = 60011, message = "没有调用该接口的权限!" });
  238. }
  239. else if (rspDimission.Result != null)
  240. {
  241. var datalist = rspDimission.Result.DataList;
  242. return Ok(new { state = 200, datalist });
  243. }
  244. else
  245. {
  246. return Ok(new { state = rspDimission.SubErrCode, message = rspDimission.Errmsg });
  247. }
  248. }
  249. /// <summary>
  250. /// 测试获取待入职人员的userId接口
  251. /// </summary>
  252. /// <returns></returns>
  253. [ProducesDefaultResponseType]
  254. [HttpPost("Induction")]
  255. public async Task<IActionResult> Induction()
  256. {
  257. string appKey = _configuration["DingDingAuth:appKey"];
  258. string appSecret = _configuration["DingDingAuth:appSecret"];
  259. string agentld = _configuration["DingDingAuth:Agentld"];
  260. //获取access_token
  261. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  262. OapiGettokenRequest request = new OapiGettokenRequest() { Appkey = appKey, Appsecret = appSecret };
  263. request.SetHttpMethod("Get");
  264. OapiGettokenResponse response = client.Execute(request);
  265. if (response.IsError)
  266. {
  267. return BadRequest();
  268. }
  269. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  270. string access_token = response.AccessToken;
  271. IDingTalkClient InductionClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querypreentry");
  272. OapiSmartworkHrmEmployeeQuerypreentryRequest reqInduction = new OapiSmartworkHrmEmployeeQuerypreentryRequest() { Offset = 0L, Size = 50 };
  273. reqInduction.SetHttpMethod("GET");
  274. OapiSmartworkHrmEmployeeQuerypreentryResponse rspInduction = InductionClient.Execute(reqInduction, access_token);
  275. if (rspInduction.Result.DataList != null)
  276. {
  277. foreach (var itemId in rspInduction.Result.DataList)
  278. {
  279. IDingTalkClient client3 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
  280. OapiV2UserGetRequest v2GetRequest = new OapiV2UserGetRequest()
  281. {
  282. Userid = itemId,
  283. Language = "zh_CN"
  284. };
  285. OapiV2UserGetResponse v2GetResponse = client3.Execute(v2GetRequest, access_token);
  286. }
  287. return Ok(new { state = 200, rspInduction.Result.DataList });
  288. }
  289. else
  290. {
  291. return Ok(new { state = 400, rspInduction.SubErrCode, rspInduction.SubErrMsg });
  292. }
  293. }
  294. /// <summary>
  295. /// 获取在职ID
  296. /// </summary>
  297. /// <returns></returns>
  298. [HttpPost("get-onthejob")]
  299. public async Task<IActionResult> GetOnTheJob()
  300. {
  301. string appKey = _configuration["DingDingAuth:appKey"];
  302. string appSecret = _configuration["DingDingAuth:appSecret"];
  303. string agentld = _configuration["DingDingAuth:Agentld"];
  304. //获取access_token
  305. IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
  306. OapiGettokenRequest request = new OapiGettokenRequest() { Appkey = appKey, Appsecret = appSecret };
  307. request.SetHttpMethod("Get");
  308. OapiGettokenResponse response = client.Execute(request);
  309. if (response.IsError)
  310. {
  311. return BadRequest();
  312. }
  313. //access_token的有效期为7200秒(2小时),有效期内重复获取会返回相同结果并自动续期,过期后获取会返回新的access_token
  314. string access_token = response.AccessToken;
  315. //bool vars = false;
  316. //long offst = 1;
  317. //do
  318. //{
  319. // IDingTalkClient jobclient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/queryonjob");
  320. // OapiSmartworkHrmEmployeeQueryonjobRequest jobreq = new OapiSmartworkHrmEmployeeQueryonjobRequest { StatusList = "2,3,-1", Offset = offst, Size = 50 }; //2:试用期 3:正式 5:待离职 -1:无状态
  321. // OapiSmartworkHrmEmployeeQueryonjobResponse jobrsp = jobclient.Execute(jobreq, access_token);
  322. // if (jobrsp.Result.NextCursor > 0)
  323. // offst += 1;
  324. // else vars = true;
  325. //} while (vars);
  326. IDingTalkClient jobclient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/queryonjob");
  327. OapiSmartworkHrmEmployeeQueryonjobRequest jobreq = new OapiSmartworkHrmEmployeeQueryonjobRequest { StatusList = "2,3,-1", Offset = 1, Size = 50 }; //2:试用期 3:正式 5:待离职 -1:无状态
  328. OapiSmartworkHrmEmployeeQueryonjobResponse jobrsp = jobclient.Execute(jobreq, access_token);
  329. if (jobrsp.SubErrCode == "60011")
  330. {
  331. return Ok(new { state = 200, msg = jobrsp.SubErrMsg });
  332. }
  333. foreach (var item in jobrsp.Result.DataList)
  334. {
  335. }
  336. var ser = jobrsp.Result.DataList; // jobrsp.Body.GetEnumerator("result");
  337. return Ok(new { state = 200, jobrsp.Body, ser });
  338. }
  339. /// <summary>
  340. /// 测试 使用yield 优化
  341. /// 依据学校编号查询学校信息;若是没有传学校编号,则查询所有学校信息
  342. /// </summary>
  343. /// <param name="jsonElement"></param>
  344. /// <returns></returns>
  345. [ProducesDefaultResponseType]
  346. [HttpPost("get-schoolsinfo")]
  347. public async Task<IActionResult> GetSchoolsInfo(JsonElement jsonElement)
  348. {
  349. try
  350. {
  351. jsonElement.TryGetProperty("schoolCode", out JsonElement _schoolCode);
  352. var cosmosClient = _azureCosmos.GetCosmosClient();
  353. List<AssistSchool> schoolAssists = new();
  354. //StringBuilder stringBuilder = new StringBuilder("select value(c) from c");
  355. StringBuilder stringBuilder = new StringBuilder("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");
  356. if (!string.IsNullOrEmpty($"{_schoolCode}"))
  357. {
  358. stringBuilder.Append($" where c.id='{_schoolCode}'");
  359. }
  360. //await foreach (var itemSchool in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<School>(queryText: stringBuilder.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  361. //{
  362. // SchoolAssist schoolAssist = new()
  363. // {
  364. // id = itemSchool.id,
  365. // code = itemSchool.code,
  366. // schoolCode = itemSchool.schoolCode,
  367. // name = itemSchool.name,
  368. // region = itemSchool.region,
  369. // province = itemSchool.province,
  370. // city = itemSchool.city,
  371. // dist = itemSchool.dist,
  372. // size = itemSchool.size,
  373. // address = itemSchool.address,
  374. // picture = itemSchool.picture,
  375. // type = itemSchool.type,
  376. // scale = itemSchool.scale,
  377. // areaId = itemSchool.areaId,
  378. // standard = itemSchool.standard
  379. // };
  380. // var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(itemSchool.id, new PartitionKey("ProductSum"));
  381. // if (response.Status == 200)
  382. // {
  383. // using var json = await JsonDocument.ParseAsync(response.ContentStream);
  384. // schoolAssist.serial = json.RootElement.GetProperty("serial").GetArrayLength();
  385. // schoolAssist.service = json.RootElement.GetProperty("service").GetArrayLength();
  386. // schoolAssist.hard = json.RootElement.GetProperty("hard").GetArrayLength();
  387. // }
  388. // schoolAssist.assists = await CommonFind.FindSchoolRoles(cosmosClient, itemSchool.id, "assist");
  389. // schoolAssists.Add(schoolAssist);
  390. //}
  391. //return Ok(new { state = 200, schoolAssists });
  392. await foreach (var itemSchool in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: stringBuilder.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  393. {
  394. using var jsonSchool = await JsonDocument.ParseAsync(itemSchool.ContentStream);
  395. foreach (var objSchool in jsonSchool.RootElement.GetProperty("Documents").EnumerateArray())
  396. {
  397. var schoolId = objSchool.GetProperty("id").GetString();
  398. AssistSchool schoolAssist = new()
  399. {
  400. id = schoolId,
  401. code = objSchool.GetProperty("code").GetString(),
  402. schoolCode = objSchool.GetProperty("schoolCode").GetString(),
  403. name = objSchool.GetProperty("name").GetString(),
  404. region = objSchool.GetProperty("region").GetString(),
  405. province = objSchool.GetProperty("province").GetString(),
  406. city = objSchool.GetProperty("city").GetString(),
  407. dist = objSchool.GetProperty("dist").GetString(),
  408. size = objSchool.GetProperty("size").GetInt32(),
  409. address = objSchool.GetProperty("address").GetString(),
  410. picture = objSchool.GetProperty("picture").GetString(),
  411. type = objSchool.GetProperty("type").GetInt32(),
  412. //scale = objSchool.GetProperty("scale").GetInt32(),
  413. areaId = objSchool.GetProperty("areaId").GetString(),
  414. standard = objSchool.GetProperty("standard").GetString(),
  415. };
  416. try { schoolAssist.scale = objSchool.GetProperty("scale").GetInt32(); }
  417. catch { schoolAssist.scale = 0; }
  418. //var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(schoolId, new PartitionKey("ProductSum"));
  419. //if (response.Status == 200)
  420. //{
  421. // using var json = await JsonDocument.ParseAsync(response.ContentStream);
  422. // schoolAssist.serial = json.RootElement.GetProperty("serial").GetArrayLength();
  423. // schoolAssist.service = json.RootElement.GetProperty("service").GetArrayLength();
  424. // schoolAssist.hard = json.RootElement.GetProperty("hard").GetArrayLength();
  425. //}
  426. //schoolAssist.assists = await CommonFind.FindSchoolRoles(cosmosClient, schoolId, "assist");
  427. schoolAssists.Add(schoolAssist);
  428. }
  429. }
  430. List<AssistSchool> tempSchoolAssists = new();
  431. await foreach (var temp in GetSchools(cosmosClient, schoolAssists))
  432. {
  433. tempSchoolAssists.AddRange(temp);
  434. }
  435. return Ok(new { state = 200, schoolAssists = tempSchoolAssists });
  436. }
  437. catch (Exception ex)
  438. {
  439. await _dingDing.SendBotMsg($"BI,{_option.Location} /batchschool/get-schoolsinfo \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
  440. return BadRequest();
  441. }
  442. }
  443. /// <summary>
  444. /// 使用yield 优化
  445. /// </summary>
  446. /// <param name="cosmosClient"></param>
  447. /// <param name="schoolAssists"></param>
  448. /// <returns></returns>
  449. private async IAsyncEnumerable<List<AssistSchool>> GetSchools(CosmosClient cosmosClient, List<AssistSchool> schoolAssists)
  450. {
  451. List<AssistSchool> tempSchoolAssists = new();
  452. foreach (var temp in schoolAssists)
  453. {
  454. var response = await cosmosClient.GetContainer("TEAMModelOS", "School").ReadItemStreamAsync(temp.id, new PartitionKey("ProductSum"));
  455. if (response.Status == 200)
  456. {
  457. using var json = await JsonDocument.ParseAsync(response.ContentStream);
  458. temp.serial = json.RootElement.GetProperty("serial").GetArrayLength();
  459. temp.service = json.RootElement.GetProperty("service").GetArrayLength();
  460. temp.hard = json.RootElement.GetProperty("hard").GetArrayLength();
  461. }
  462. temp.assists = await CommonFind.FindSchoolRoles(cosmosClient, temp.id, "assist");
  463. tempSchoolAssists.Add(temp);
  464. }
  465. yield return tempSchoolAssists;
  466. }
  467. /// <summary>
  468. /// 赋值默认的顾问角色和BI默认的功能权限
  469. /// </summary>
  470. /// <returns></returns>
  471. [HttpPost("set-rolesorperm")]
  472. public async Task<IActionResult> SetRolesOrPermissions()
  473. {
  474. var table = _azureStorage.GetCloudTableClient().GetTableReference("BIDDUserInfo");
  475. List<DingDingUserInfo> ddUserId = await table.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", "continent" } });
  476. List<string> read = new() { "abilitystandard-read", "batcharea-read", "batchschool-read", "orgusers-read" };
  477. List<DingDingUserInfo> tempUserInfo = new();
  478. foreach (var user in ddUserId)
  479. {
  480. if (string.IsNullOrEmpty(user.roles))
  481. {
  482. user.roles = "assist";
  483. }
  484. if (string.IsNullOrEmpty(user.permissions))
  485. {
  486. user.permissions = string.Join(",", read);
  487. }
  488. List<string> tempRead = new(user.permissions.Split(","));
  489. foreach (var temp in read)
  490. {
  491. if (!tempRead.Contains(temp))
  492. {
  493. tempRead.Add(temp);
  494. }
  495. }
  496. user.permissions = string.Join(",", tempRead);
  497. tempUserInfo.Add(user);
  498. }
  499. var response = await table.SaveOrUpdateAll<DingDingUserInfo>(tempUserInfo);
  500. return Ok(new { state = 200, response });
  501. }
  502. /// <summary>
  503. /// 测试使用 CosmosDB中的COUNT 函数统计
  504. /// </summary>
  505. /// <param name="jsonElement"></param>
  506. /// <returns></returns>
  507. [HttpPost("get-count")]
  508. public async Task<IActionResult> GetCount(JsonElement jsonElement)
  509. {
  510. var cosmosClient = _azureCosmos.GetCosmosClient();
  511. List<KeyValuePair<int, int>> layerCount = new List<KeyValuePair<int, int>>();
  512. for (int i = 1; i <= 6; i++)
  513. {
  514. int total = 0;
  515. //string sqlText = $"select value(c.id) from c where c.pk='Item' and c.field={i}";
  516. string sqlText = $"select COUNT(c.id) AS totals from c where c.pk='Item' and c.field={i}";
  517. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: sqlText, requestOptions: new QueryRequestOptions() { }))
  518. {
  519. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  520. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt32() > 0)
  521. {
  522. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  523. {
  524. //total += obj.GetInt64();
  525. total += obj.GetProperty("totals").GetInt32();
  526. }
  527. //total += count.GetInt64();
  528. }
  529. }
  530. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Teacher").GetItemQueryStreamIterator(queryText: sqlText, requestOptions: new QueryRequestOptions() { }))
  531. {
  532. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  533. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  534. {
  535. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  536. {
  537. //total += obj.GetInt64();
  538. total += obj.GetProperty("totals").GetInt32();
  539. }
  540. }
  541. }
  542. layerCount.Add(new KeyValuePair<int, int>(i, total));
  543. }
  544. return Ok(new { state = 200, layerCount });
  545. }
  546. /// <summary>
  547. /// 测试算日期
  548. /// </summary>
  549. /// <returns></returns>
  550. [HttpPost("get-date")]
  551. public async Task<IActionResult> GetDate()
  552. {
  553. DateTimeOffset dateTime = DateTimeOffset.UtcNow.AddDays(0);
  554. int year = DateTimeOffset.UtcNow.Year;
  555. int month = DateTimeOffset.UtcNow.Month;
  556. List<string> strList = monthsOfYear("2021-1");
  557. var ere = DateTimeOffset.Parse("2024-02");
  558. var start = GetMonthStart(ere);
  559. var end = GetMonthEnd(ere);
  560. List<MonthStartEnd> endList = TimeHelper.GetYearMonthlyStartEnd10(DateTimeOffset.UtcNow.Year);
  561. List<MonthStartEnd> endList1 = TimeHelper.GetYearMonthlyStartEnd13(DateTimeOffset.UtcNow.Year);
  562. //return Ok(new { strList, dateTime, year, start, end, endList, endList1, endList2 });
  563. var (start1, end1) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow);
  564. var (start2, end2) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow,"week");
  565. var (start3, end3) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow,"month");
  566. var (start4, end4) = TimeHelper.GetStartOrEnd(DateTimeOffset.UtcNow, "year");
  567. return Ok(new { start1, end1, start2, end2, start3, end3, start4, end4 });
  568. }
  569. public static List<string> monthsOfYear(string yearMonth)
  570. {
  571. DateTime dateTime = DateTime.Parse(yearMonth);
  572. int year = dateTime.Year;
  573. int month = dateTime.Month;
  574. List<string> months = new List<string>();
  575. while (year > dateTime.Year - 1 || month > dateTime.Month)
  576. {
  577. months.Add($"{year}-{(month < 10 ? "0" : "") + month}");
  578. month -= 1;
  579. if (month <= 0)
  580. {
  581. year -= 1;
  582. month = 12;
  583. }
  584. }
  585. return months;
  586. }
  587. /// <summary>
  588. /// 统计一年中每月得新增校
  589. /// </summary>
  590. /// <returns></returns>
  591. [HttpPost("get-yearmonth")]
  592. public async Task<IActionResult> GetYearMonth()
  593. {
  594. var cosmosClient = _azureCosmos.GetCosmosClient();
  595. Dictionary<int, long> tempYear = new Dictionary<int, long>();
  596. List<TempSchool> tempSchools = new List<TempSchool>();
  597. for (int i = 1; i < 13; i++)
  598. {
  599. var start = 00022222330;
  600. long tempCount = 0;
  601. await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: $"SELECT c._ts,c.name,c.id FROM c WHERE c._ts>={start}L", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  602. {
  603. using var json = await JsonDocument.ParseAsync(item.ContentStream);
  604. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt64() > 0)
  605. {
  606. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  607. {
  608. TempSchool tempSchool = new TempSchool();
  609. tempSchool.id = obj.GetProperty("id").GetString();
  610. tempSchool.ts = obj.GetProperty("_ts").GetInt64();
  611. tempSchool.name = obj.GetProperty("name").GetString();
  612. tempSchools.Add(tempSchool);
  613. }
  614. tempCount += count.GetInt64();
  615. }
  616. }
  617. if (tempCount != 0)
  618. {
  619. tempYear.Add(i, tempCount);
  620. }
  621. }
  622. return Ok(new { state = 200, tempYear, tempSchools });
  623. }
  624. /// <summary>
  625. /// 测试.net 6 的一些特性
  626. /// </summary>
  627. /// <returns></returns>
  628. [HttpPost("get-newnet6")]
  629. public async Task<IActionResult> GetNewNet6()
  630. {
  631. ///PriorityQueue
  632. //.NET 6 新增的数据结构, PriorityQueue, 队列每个元素都有一个关联的优先级,它决定了出队顺序, 编号小的元素优先出列。
  633. PriorityQueue<string, int> priorityQueue = new();
  634. priorityQueue.Enqueue("Second", 2);
  635. priorityQueue.Enqueue("Fourth", 4);
  636. priorityQueue.Enqueue("Third 1", 3);
  637. priorityQueue.Enqueue("Third 2", 5);
  638. priorityQueue.Enqueue("First", 1);
  639. while (priorityQueue.Count > 0)
  640. {
  641. string item = priorityQueue.Dequeue();
  642. Console.WriteLine(item);
  643. }
  644. //PeriodicTimer
  645. //认识一个完全异步的“PeriodicTimer”, 更适合在异步场景中使用, 它有一个方法 WaitForNextTickAsync。
  646. //using PeriodicTimer timer = new(TimeSpan.FromSeconds(2));
  647. //while (await timer.WaitForNextTickAsync())
  648. //{
  649. // Console.WriteLine(DateTime.UtcNow);
  650. //}
  651. //检查元素是否可为空的反射API
  652. var example = new Example();
  653. var nullabilityInfoContext = new NullabilityInfoContext();
  654. foreach (var propertyInfo in example.GetType().GetProperties())
  655. {
  656. var nullabilityInfo = nullabilityInfoContext.Create(propertyInfo);
  657. Console.WriteLine($"{propertyInfo.Name} property is {nullabilityInfo.WriteState}");
  658. }
  659. //直接通过 Environment 获取进程ID和路径。
  660. int processId = Environment.ProcessId;
  661. string path = Environment.ProcessPath;
  662. Console.WriteLine(processId);
  663. Console.WriteLine(path);
  664. //CSPNG 密码安全伪随机数生成器
  665. byte[] bytes = RandomNumberGenerator.GetBytes(300);
  666. Console.WriteLine(string.Join("", bytes.ToArray()));
  667. //Power of 2
  668. //.NET 6 引入了用于处理 2 的幂的新方法。
  669. //‘IsPow2’ 判断指定值是否为 2 的幂。
  670. //‘RoundUpToPowerOf2’ 将指定值四舍五入到 2 的幂
  671. Console.WriteLine(BitOperations.IsPow2(121)); // True
  672. Console.WriteLine(BitOperations.RoundUpToPowerOf2(260)); // 256
  673. //WaitAsync on Task 您可以更轻松地等待异步任务执行, 如果超时会抛出 “TimeoutException”
  674. Task operationTask = DoSomethingLongAsync();
  675. await operationTask.WaitAsync(TimeSpan.FromSeconds(5));
  676. async Task DoSomethingLongAsync()
  677. {
  678. Console.WriteLine("DoSomethingLongAsync started.");
  679. await Task.Delay(TimeSpan.FromSeconds(10));
  680. Console.WriteLine("DoSomethingLongAsync ended.");
  681. }
  682. //新的数学API
  683. // New methods SinCos, ReciprocalEstimate and ReciprocalSqrtEstimate
  684. // Simultaneously computes Sin and Cos
  685. (double sin, double cos) = Math.SinCos(1.57);
  686. Console.WriteLine($"Sin = {sin}\nCos = {cos}");
  687. // Computes an approximate of 1 / x
  688. double recEst = Math.ReciprocalEstimate(5);
  689. Console.WriteLine($"Reciprocal estimate = {recEst}");
  690. // Computes an approximate of 1 / Sqrt(x)
  691. double recSqrtEst = Math.ReciprocalSqrtEstimate(5);
  692. Console.WriteLine($"Reciprocal sqrt estimate = {recSqrtEst}");
  693. // New overloads
  694. // Min, Max, Abs, Clamp and Sign supports nint and nuint
  695. (nint a, nint b) = (5, 10);
  696. nint min = Math.Min(a, b);
  697. nint max = Math.Max(a, b);
  698. nint abs = Math.Abs(a);
  699. nint clamp = Math.Clamp(abs, min, max);
  700. nint sign = Math.Sign(a);
  701. Console.WriteLine($"Min = {min}\nMax = {max}\nAbs = {abs}");
  702. Console.WriteLine($"Clamp = {clamp}\nSign = {sign}");
  703. // DivRem variants return a tuple
  704. (int quotient, int remainder) = Math.DivRem(2, 7);
  705. Console.WriteLine($"Quotient = {quotient}\nRemainder = {remainder}");
  706. //CollectionsMarshal.GetValueRefOrNullRef
  707. //这个是在字典中循环或者修改结可变结构体时用, 可以减少结构的副本复制, 也可以避免字典重复进行哈希计算,这个有点晦涩难懂
  708. Dictionary<int, MyStruct> dictionary = new()
  709. {
  710. { 1, new MyStruct { Count = 100 } }
  711. };
  712. int key = 1;
  713. MyStruct values = CollectionsMarshal.GetValueRefOrNullRef(dictionary, key);
  714. // Returns Unsafe.NullRef<TValue>() if it doesn't exist; check using Unsafe.IsNullRef(ref value)
  715. if (!Unsafe.IsNullRef(ref values))
  716. {
  717. Console.WriteLine(values.Count); // Output: 100
  718. // Mutate in-place
  719. values.Count++;
  720. Console.WriteLine(values.Count); // Output: 101
  721. }
  722. return Ok(new { state = 200 });
  723. }
  724. /// <summary>
  725. /// 去重、判断
  726. /// </summary>
  727. /// <param name="jsonElement"></param>
  728. /// <returns></returns>
  729. [HttpPost("get-repeat")]
  730. public async Task<IActionResult> GetRepeat(JsonElement jsonElement)
  731. {
  732. jsonElement.TryGetProperty("datetime", out JsonElement _datetime);
  733. Dictionary<string, string> prodict = new Dictionary<string, string>() { { "YMPCVCIM", "学情分析模组" }, { "IPDYZYLC", "智慧学校管理服务" }, { "3CLYJ6NP", "AClass ONE智慧学伴" }, { "IPALJ6NY", "数据储存服务空间" },{ "VABAJ6NV", "卷卡合一阅卷系统" } };
  734. var ste = prodict["IPDYZYLC"];
  735. List<string> str_str = new List<string>() { "12", "20", "13", "13", "14", "16" };
  736. List<strend> strends = new List<strend> { 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 } };
  737. //str_str.Distinct().ToList();
  738. strends.Where((x, i) => strends.FindIndex(z => z.id.Equals(x.id)) == i).ToList();
  739. List<strend> str_strend1 = strends.Where((x, i) => strends.FindIndex(z => z.id.Equals(x.id)) == i).ToList();
  740. List<strend> str_strend2 = strends.GroupBy(p => p).Select(p => p.Key).ToList();//去重复
  741. DateTime dt = DateTime.Parse($"{_datetime}");
  742. int year = dt.Year;
  743. DateTime dt0 = new DateTime(year, 1, 1);
  744. int days = (dt.Date - dt0.Date).Days + 1;
  745. //int pydays = ((lastYear + 1) % 4 == 0 && (lastYear + 1) % 100 != 0 || (lastYear + 1) % 400 == 0) ? 366 : 365;
  746. int pydays = (year % 4 == 0 && year % 100 != 0 || year % 400 == 0) ? 366 : 365;
  747. //int pydays = DateTimeHelper.getDays(year);
  748. return Ok(new { state = 200, pydays, days, strends , str_strend1, str_strend2 , ste });
  749. }
  750. /// <summary>
  751. /// 计算天数
  752. /// </summary>
  753. /// <param name="jsonElement"></param>
  754. /// <returns></returns>
  755. [HttpPost("get-dateday")]
  756. public async Task<IActionResult> GetDateDay(JsonElement jsonElement)
  757. {
  758. jsonElement.TryGetProperty("year", out JsonElement _year);
  759. jsonElement.TryGetProperty("moth", out JsonElement _moth);
  760. int year = int.Parse($"{_year}");
  761. int day = 0;
  762. List<int> moths = _moth.ToObject<List<int>>();
  763. foreach (var item in moths)
  764. {
  765. int days = 0;
  766. switch (item)
  767. {
  768. case 1:
  769. case 3:
  770. case 5:
  771. case 7:
  772. case 8:
  773. case 10:
  774. case 12:
  775. days = 31;
  776. break;
  777. case 4:
  778. case 6:
  779. case 9:
  780. case 11:
  781. days = 30;
  782. break;
  783. case 2:
  784. int years = 0;
  785. if (item <= 8 && item >= 3)
  786. years = year;
  787. else
  788. years = year+1;
  789. if (years % 4 == 0 && year % 100 != 0 || year % 400 == 0)
  790. days = 29;
  791. else
  792. days = 28;
  793. break;
  794. }
  795. day += days;
  796. }
  797. return Ok(new { state = 200, day });
  798. }
  799. /// <summary>
  800. /// 测试CosmosDB分页查询
  801. /// </summary>
  802. /// <param name="jsonElement"></param>
  803. /// <returns></returns>
  804. [HttpPost("get-page")]
  805. public async Task<IActionResult> cosmosDBPage(JsonElement jsonElement)
  806. {
  807. if (!jsonElement.TryGetProperty("pageSize", out JsonElement pageSize)) return BadRequest();
  808. if (!jsonElement.TryGetProperty("endPosition", out JsonElement endPosition)) return BadRequest();
  809. var cosmosClient = _azureCosmos.GetCosmosClient();
  810. List<School> schools = new List<School>();
  811. //string sqlTxt = $"SELECT * FROM c where c.code='Base' order by c.id offset {endPosition} limit {pageSize}";
  812. string sqlTxt = $"SELECT * FROM c order by c.id offset {pageSize} limit {endPosition}";
  813. await foreach (var tempPage in cosmosClient.GetContainer("TEAMModelOS", "School").GetItemQueryStreamIterator(queryText: sqlTxt, requestOptions:new QueryRequestOptions { PartitionKey = new PartitionKey("Base") }))
  814. {
  815. using var json = await JsonDocument.ParseAsync(tempPage.ContentStream);
  816. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
  817. {
  818. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  819. {
  820. schools.Add(obj.ToObject<School>());
  821. }
  822. }
  823. }
  824. IAsyncResult iAsyncResult = null;
  825. return Ok(new { state = 200, schools });
  826. }
  827. /// <summary>
  828. /// 测试隐式登录
  829. /// </summary>
  830. /// <returns></returns>
  831. [HttpPost("get-implicit")]
  832. public async Task<IActionResult> GetImplicit()
  833. {
  834. var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
  835. var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
  836. var location = _option.Location;
  837. if (location.Contains("China"))
  838. {
  839. location = "China";
  840. }
  841. else if (location.Contains("Global"))
  842. {
  843. location = "Global";
  844. }
  845. var token = await CoreTokenExtensions.CreateAccessToken(clientID, clientSecret, location);
  846. if (_httpClient.DefaultRequestHeaders.Contains("Authorization"))
  847. {
  848. _httpClient.DefaultRequestHeaders.Remove("Authorization");
  849. }
  850. _httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {token.AccessToken}");
  851. var url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
  852. url = $"{url}/oauth2/implicit";
  853. Dictionary<string, string> data = new()
  854. {
  855. { "grant_type", "implicit" },
  856. { "client_id", clientID },
  857. { "account", "1636016499" },
  858. { "nonce", Guid.NewGuid().ToString() }
  859. };
  860. HttpResponseMessage responseMessage = await _httpClient.PostAsJsonAsync(url, data);
  861. if (responseMessage.StatusCode == HttpStatusCode.OK) //BI连接字符
  862. {
  863. string content = await responseMessage.Content.ReadAsStringAsync();
  864. }
  865. return Ok(new { state = 200, token, responseMessage });
  866. }
  867. /// <summary>
  868. /// 测试
  869. /// </summary>
  870. /// <param name="jsonElement"></param>
  871. /// <returns></returns>
  872. [HttpPost("get-test")]
  873. public async Task<IActionResult> GetTest(JsonElement jsonElement)
  874. {
  875. List<Test> list1 = new List<Test>();
  876. list1.Add(new Test { score = 10, name = "001" });
  877. list1.Add(new Test { score = 20, name = "002" });
  878. list1.Add(new Test { score = 30, name = "003" });
  879. list1.Add(new Test { score = 40, name = "004" });
  880. list1.Add(new Test { score = 50, name = "005" });
  881. list1.Add(new Test { score = 60, name = "006" });
  882. List<Test> list2 = new List<Test>();
  883. list2.Add(new Test { score = 40, name = "004" });
  884. list2.Add(new Test { score = 50, name = "005" });
  885. list2.Add(new Test { score = 60, name = "006" });
  886. list2.Add(new Test { score = 70, name = "007" });
  887. list2.Add(new Test { score = 80, name = "008" });
  888. list2.Add(new Test { score = 90, name = "009" });
  889. list2.Add(new Test { score = 100, name = "010" });
  890. //list3 return 2
  891. List<Test> list3 = list1.Where(x => !list2.Any(x2 => x.score == x2.score && x.name==x2.name)).ToList();
  892. //list4 return 2
  893. List<Test> list4 = list1.Where(x => list2.All(x2 => x.score != x2.score)).ToList();
  894. List<Test> temp = list1.Where(p => !list2.Select(b => b.score).Contains(p.score)).ToList();
  895. //List<Test> mergedList = new List<Test>(list1);
  896. //mergedList.AddRange(list2.Except(list1));
  897. // var mergedList = list1.Union(list2);
  898. var en2 = list1.Concat(list2).Except(list1.Intersect(list2));// 容斥原理
  899. var bingji = list1.Union(list2).ToList();//并(全)集
  900. var cha = bingji.GroupBy(x => x.score).Select(c => c.First()).ToList();
  901. var jiaoji = list1.Intersect(list2).ToList();//交集
  902. var chaji = list1.Except(list2).ToList();//差集
  903. List<Test> have = list1.Where(a => !list2.Exists(t => a.score == t.score)).ToList();
  904. have.AddRange(list2.Where(a => !list1.Exists(t => a.score == t.score)).ToList());
  905. return Ok(new { state = 200, have, en2, bingji, cha, jiaoji, chaji, list3, list4, temp, list1 });
  906. }
  907. public class Test
  908. {
  909. public int age { get; set; }
  910. public string name { get; set; }
  911. public int score { get; set; }
  912. }
  913. public class strend
  914. {
  915. public int id { get; set; }
  916. public string name { get; set; }
  917. public int age { get; set; }
  918. }
  919. struct MyStruct
  920. {
  921. public int Count { get; set; }
  922. }
  923. class Example
  924. {
  925. public string? Name { get; set; }
  926. public string Value { get; set; }
  927. }
  928. public record TempSchool
  929. {
  930. public long ts { get; set; }
  931. public string id { get; set; }
  932. public string name { get; set; }
  933. }
  934. public static long GetMonthEnd(DateTimeOffset dt)
  935. {
  936. DateTime dtNew = new DateTime(dt.Year, dt.Month, 1);
  937. var ste = dtNew.AddMonths(1).AddDays(-1).Day;
  938. long iLastDay = DateTimeOffset.Parse($"{dt.Year}-{dt.Month}-{ste} 23:59:59").ToUnixTimeSeconds();
  939. return iLastDay;
  940. }
  941. public static long GetMonthStart(DateTimeOffset dt)
  942. {
  943. DateTime dtNew = new DateTime(dt.Year, dt.Month, 1);
  944. long iLastDay = DateTimeOffset.Parse($"{dtNew}").ToUnixTimeSeconds();
  945. return iLastDay;
  946. }
  947. public record lessons
  948. {
  949. public long countB { get; set; }
  950. public long countP { get; set; }
  951. public long countT { get; set; }
  952. public long countPT { get; set; }
  953. public LessonCount lesson { get; set; }
  954. }
  955. public record pageTest
  956. {
  957. public string keyt { get; set; }
  958. public string listv { get; set; }
  959. }
  960. public record pageTest1
  961. {
  962. public string keyt { get; set; }
  963. public List<string> listv { get; set; }
  964. }
  965. public class GenerateRandom1
  966. {
  967. /// <summary>
  968. /// 生成随机数字
  969. /// </summary>
  970. /// <param name="length">生成长度</param>
  971. /// <returns></returns>
  972. public static string Number(int Length)
  973. {
  974. return Number(Length, false);
  975. }
  976. /// <summary>
  977. /// 生成随机数字
  978. /// </summary>
  979. /// <param name="Length">生成长度</param>
  980. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  981. /// <returns></returns>
  982. public static string Number(int Length, bool Sleep)
  983. {
  984. if (Sleep)
  985. System.Threading.Thread.Sleep(3);
  986. string result = "";
  987. System.Random random = new Random();
  988. for (int i = 0; i < Length; i++)
  989. {
  990. result += random.Next(10).ToString();
  991. }
  992. return result;
  993. }
  994. /// <summary>
  995. /// 生成随机字母与数字
  996. /// </summary>
  997. /// <param name="IntStr">生成长度</param>
  998. /// <returns></returns>
  999. public static string Str(int Length)
  1000. {
  1001. return Str(Length, false);
  1002. }
  1003. /// <summary>
  1004. /// 生成随机字母与数字
  1005. /// </summary>
  1006. /// <param name="Length">生成长度</param>
  1007. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  1008. /// <returns></returns>
  1009. public static string Str(int Length, bool Sleep)
  1010. {
  1011. if (Sleep)
  1012. System.Threading.Thread.Sleep(3);
  1013. 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' };
  1014. string result = "";
  1015. int n = Pattern.Length;
  1016. System.Random random = new Random(~unchecked((int)DateTime.Now.Ticks));
  1017. for (int i = 0; i < Length; i++)
  1018. {
  1019. int rnd = random.Next(0, n);
  1020. result += Pattern[rnd];
  1021. }
  1022. return result;
  1023. }
  1024. /// <summary>
  1025. /// 生成随机纯字母随机数
  1026. /// </summary>
  1027. /// <param name="IntStr">生成长度</param>
  1028. /// <returns></returns>
  1029. public static string Str_char(int Length)
  1030. {
  1031. return Str_char(Length, false);
  1032. }
  1033. /// <summary>
  1034. /// 生成随机纯字母随机数
  1035. /// </summary>
  1036. /// <param name="Length">生成长度</param>
  1037. /// <param name="Sleep">是否要在生成前将当前线程阻止以避免重复</param>
  1038. /// <returns></returns>
  1039. public static string Str_char(int Length, bool Sleep)
  1040. {
  1041. if (Sleep) System.Threading.Thread.Sleep(3);
  1042. //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' };
  1043. 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' };
  1044. string result = "";
  1045. int n = Pattern.Length;
  1046. System.Random random = new Random(~unchecked((int)DateTime.Now.Ticks));
  1047. for (int i = 0; i < Length; i++)
  1048. {
  1049. int rnd = random.Next(0, n);
  1050. result += Pattern[rnd];
  1051. }
  1052. return result;
  1053. }
  1054. }
  1055. }
  1056. }