TestController.cs 64 KB

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