TmidController.cs 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531
  1. using Microsoft.Azure.Cosmos;
  2. using Microsoft.AspNetCore.Authorization;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Table;
  5. using Microsoft.Extensions.Configuration;
  6. using Microsoft.Extensions.Options;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using System.Reflection;
  11. using System.Text.Json;
  12. using System.Threading.Tasks;
  13. using TEAMModelOS.Models;
  14. using TEAMModelOS.SDK;
  15. using TEAMModelOS.SDK.DI;
  16. using TEAMModelOS.SDK.Extension;
  17. using TEAMModelOS.SDK.Models;
  18. using TEAMModelOS.SDK.Services;
  19. using static TEAMModelBI.Models.Extension.GeoRegion;
  20. namespace TEAMModelBI.Controllers.BITmid
  21. {
  22. [Route("tmid")]
  23. [ApiController]
  24. public class TmidController : ControllerBase
  25. {
  26. private readonly AzureCosmosFactory _azureCosmos;
  27. private readonly AzureStorageFactory _azureStorage;
  28. private readonly AzureRedisFactory _azureRedis;
  29. private readonly DingDing _dingDing;
  30. private readonly Option _option;
  31. private readonly IConfiguration _configuration;
  32. private readonly HttpTrigger _httpTrigger;
  33. public TmidController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, HttpTrigger httpTrigger)
  34. {
  35. _azureCosmos = azureCosmos;
  36. _azureStorage = azureStorage;
  37. _azureRedis = azureRedis;
  38. _dingDing = dingDing;
  39. _option = option?.Value;
  40. _configuration = configuration;
  41. _httpTrigger = httpTrigger;
  42. }
  43. /// <summary>
  44. /// 取得TMID綜合資料
  45. /// </summary>
  46. /// <param name="jsonElement"></param>
  47. /// <returns></returns>
  48. [ProducesDefaultResponseType]
  49. [Authorize(Roles = "IES")]
  50. [HttpPost("get-tmidstics")]
  51. public async Task<IActionResult> GetTmidStics(JsonElement jsonElement)
  52. {
  53. try
  54. {
  55. if (!jsonElement.TryGetProperty("tmids", out JsonElement tmidsJobj)) return BadRequest();//TMID(array)
  56. var tmids = tmidsJobj.Deserialize<List<string>>();
  57. if (tmids.Count is 0) return BadRequest();
  58. var datetime = DateTimeOffset.UtcNow.AddDays(-1);
  59. int y = datetime.Year;
  60. int m = datetime.Month;
  61. int d = datetime.Day;
  62. string dateFromStr = (jsonElement.TryGetProperty("dateFrom", out JsonElement dateFromJobj)) ? dateFromJobj.GetString() : string.Empty; //查詢日期:起始(string)[例]2023-03-05
  63. string dateToStr = (jsonElement.TryGetProperty("dateTo", out JsonElement dateToJobj)) ? dateToJobj.GetString() : string.Empty; //查詢日期:結束(string)[例]2023-03-27
  64. string dateUnit = (jsonElement.TryGetProperty("dateUnit", out JsonElement dateUnitJobj)) ? dateUnitJobj.GetString().ToLower() : "month";
  65. string mode = (jsonElement.TryGetProperty("mode", out JsonElement modeJobj)) ? modeJobj.GetString().ToLower() : "default";
  66. //起始終止日期換算
  67. long dateTimeFromSec = 0;
  68. long dateTimeToSec = 0;
  69. if(!string.IsNullOrWhiteSpace(dateFromStr) && !string.IsNullOrWhiteSpace(dateToStr))
  70. {
  71. DateTimeOffset dateTimeFrom;
  72. DateTimeOffset dateTimeTo;
  73. List<string> dateFromList = dateFromStr.Split('-').ToList();
  74. int dateFromYear = Convert.ToInt32(dateFromList[0], 10);
  75. int dateFromMonth = (dateUnit.Equals("day") || dateUnit.Equals("month")) ? Convert.ToInt32(dateFromList[1], 10) : 1;
  76. int dateFromDay = (dateUnit.Equals("day")) ? Convert.ToInt32(dateFromList[2], 10) : 1;
  77. List<string> dateToList = dateToStr.Split('-').ToList();
  78. int dateToYear = Convert.ToInt32(dateToList[0], 10);
  79. int dateToMonth = (dateUnit.Equals("day") || dateUnit.Equals("month")) ? Convert.ToInt32(dateToList[1], 10) : 1;
  80. int dateToDay = (dateUnit.Equals("day")) ? Convert.ToInt32(dateToList[2], 10) : 1;
  81. switch (dateUnit)
  82. {
  83. case "year":
  84. dateTimeFrom = new DateTimeOffset(dateFromYear, 1, 1, 0, 0, 0, TimeSpan.Zero);
  85. dateTimeTo = new DateTimeOffset(dateToYear, 12, 31, 23, 59, 59, TimeSpan.Zero);
  86. break;
  87. case "month":
  88. dateTimeFrom = new DateTimeOffset(dateFromYear, dateFromMonth, 1, 0, 0, 0, TimeSpan.Zero);
  89. dateTimeTo = new DateTimeOffset(dateToYear, dateToMonth, DateTime.DaysInMonth(dateToYear, dateToMonth), 23, 59, 59, TimeSpan.Zero);
  90. break;
  91. case "day":
  92. dateTimeFrom = new DateTimeOffset(dateFromYear, dateFromMonth, dateFromDay, 0, 0, 0, TimeSpan.Zero);
  93. dateTimeTo = new DateTimeOffset(dateToYear, dateToMonth, dateToDay, 23, 59, 59, TimeSpan.Zero);
  94. break;
  95. default:
  96. dateTimeFrom = new DateTimeOffset(y, m, d, 0, 0, 0, TimeSpan.Zero);
  97. dateTimeTo = new DateTimeOffset(y, m, d, 23, 59, 59, TimeSpan.Zero);
  98. break;
  99. }
  100. dateTimeFromSec = dateTimeFrom.ToUnixTimeSeconds();
  101. dateTimeToSec = dateTimeTo.ToUnixTimeSeconds();
  102. y = 0;
  103. m = 0;
  104. d = 0;
  105. }
  106. //取得項目列表
  107. List<string> eventList = new List<string>();
  108. if(mode.Equals("simple"))
  109. {
  110. eventList = new List<string>() { "points" };
  111. } else
  112. {
  113. eventList = new List<string>() { "coupons", "login", "prod", "points", "iot", "ies5", "benefits", "sokrates" };
  114. }
  115. //服務Client端
  116. var cosmosClientIes5 = _azureCosmos.GetCosmosClient(); //CosmosDB IES5
  117. var cosmosClientCsv2 = _azureCosmos.GetCosmosClient(name: "CoreServiceV2"); //CosmosDB CSV2
  118. var storageClientCsv2 = _azureStorage.GetCloudTableClient(name: "CoreServiceV2"); //Storage CSV2
  119. var tableCouponClient = storageClientCsv2.GetTableReference("Coupon");
  120. var tablePointsClient = storageClientCsv2.GetTableReference("Points");
  121. var redisClient = _azureRedis.GetRedisClient(4);
  122. //取得TMID基本資料
  123. Dictionary<string, TmidStics> tmidDic = new();
  124. QueryDefinition query =
  125. new QueryDefinition(@"SELECT c.id, c.name, c.picture, c.mobile, c.mail, c.lang, c.wechat, c.facebook, c.google, c.ding, c.apple, c.educloudtw, c.ts FROM c WHERE (ARRAY_CONTAINS(@key, c.id) OR ARRAY_CONTAINS(@key, c.mobile))")
  126. .WithParameter("@key", tmids);
  127. await foreach (var item in cosmosClientCsv2
  128. .GetContainer("Core", "ID2")
  129. .GetItemQueryStreamIteratorSql(query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("base") }))
  130. {
  131. using var json = await JsonDocument.ParseAsync(item.Content);
  132. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  133. {
  134. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  135. {
  136. string id = doc.GetProperty("id").GetString();
  137. if(!tmids.Contains(id)) tmids.Add(id);
  138. //基本資料
  139. TmidStics tmidStics = (tmidDic.ContainsKey(id)) ? tmidDic[id] : new() { id = id };
  140. if (eventList.Contains("ies5")) tmidStics.ies5 = new();
  141. if (eventList.Contains("points")) tmidStics.points = new();
  142. if (eventList.Contains("sokrates")) tmidStics.sokrates = new();
  143. if (eventList.Contains("benefits")) tmidStics.benefits = new();
  144. if (eventList.Contains("iot")) tmidStics.iot = new();
  145. tmidStics.name = doc.GetProperty("name").GetString();
  146. tmidStics.picture = doc.GetProperty("picture").GetString();
  147. tmidStics.mobile = GenDataMask(doc.GetProperty("mobile").GetString(), "mobile");
  148. tmidStics.mail = GenDataMask(doc.GetProperty("mail").GetString(), "mail");
  149. tmidStics.lang = (doc.TryGetProperty("lang", out JsonElement lang)) ? lang.GetString() : string.Empty;
  150. tmidStics.wechat = (doc.TryGetProperty("wechat", out JsonElement wechat) && !string.IsNullOrWhiteSpace(wechat.GetString())) ? true : false;
  151. tmidStics.facebook = (doc.TryGetProperty("facebook", out JsonElement facebook) && !string.IsNullOrWhiteSpace(facebook.GetString())) ? true : false;
  152. tmidStics.google = (doc.TryGetProperty("google", out JsonElement google) && !string.IsNullOrWhiteSpace(google.GetString())) ? true : false;
  153. tmidStics.ding = (doc.TryGetProperty("ding", out JsonElement ding) && !string.IsNullOrWhiteSpace(ding.GetString())) ? true : false;
  154. tmidStics.apple = (doc.TryGetProperty("apple", out JsonElement apple) && !string.IsNullOrWhiteSpace(apple.GetString())) ? true : false;
  155. tmidStics.ts = (doc.TryGetProperty("ts", out JsonElement ts)) ? ts.GetInt64() : 0;
  156. tmidDic.Add(id, tmidStics);
  157. }
  158. }
  159. }
  160. //取得TMID進階資料
  161. regiondata regionData = GetRegionData(); //取得國省市區地理資訊架構
  162. query = new QueryDefinition(@"SELECT c.id, c.name, c.mobile, c.mail, c.country, c.province, c.city, c.schoolCode, c.schoolCodeW, c.unitType, c.unitName, c.jobTitle FROM c WHERE (ARRAY_CONTAINS(@key, c.id) OR ARRAY_CONTAINS(@key, c.mobile))")
  163. .WithParameter("@key", tmids);
  164. await foreach (var item in cosmosClientCsv2
  165. .GetContainer("Core", "ID2")
  166. .GetItemQueryStreamIteratorSql(query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("base-ex") }))
  167. {
  168. using var json = await JsonDocument.ParseAsync(item.Content);
  169. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  170. {
  171. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  172. {
  173. string id = doc.GetProperty("id").GetString();
  174. TmidStics tmidStics = (tmidDic.ContainsKey(id)) ? tmidDic[id] : new() { id = id };
  175. if (eventList.Contains("ies5")) tmidStics.ies5 = new();
  176. if (eventList.Contains("points")) tmidStics.points = new();
  177. if (eventList.Contains("sokrates")) tmidStics.sokrates = new();
  178. if (eventList.Contains("benefits")) tmidStics.benefits = new();
  179. if (eventList.Contains("iot")) tmidStics.iot = new();
  180. if (string.IsNullOrWhiteSpace(tmidStics.name)) tmidStics.name = doc.GetProperty("name").GetString();
  181. if (string.IsNullOrWhiteSpace(tmidStics.mobile)) tmidStics.mobile = GenDataMask(doc.GetProperty("mobile").GetString(), "mobile");
  182. if (string.IsNullOrWhiteSpace(tmidStics.mail)) tmidStics.mail = GenDataMask(doc.GetProperty("mail").GetString(), "mail");
  183. string country = doc.GetProperty("country").GetString();
  184. string province = doc.GetProperty("province").GetString();
  185. string city = doc.GetProperty("city").GetString();
  186. string district = string.Empty;
  187. if (!string.IsNullOrWhiteSpace(country) && country.Equals("TW"))
  188. {
  189. district = city;
  190. city = province;
  191. province = string.Empty;
  192. }
  193. tmidStics.country = (!string.IsNullOrWhiteSpace(country) && regionData.country.ContainsKey(country)) ? regionData.country[country].name.Replace("地區", "").Replace("地区", "") : country;
  194. tmidStics.province = (!string.IsNullOrWhiteSpace(country) && regionData.country.ContainsKey(country) && !string.IsNullOrWhiteSpace(province) && regionData.province.ContainsKey(country) && regionData.province[country].ContainsKey(province)) ? regionData.province[country][province].name : province;
  195. if (!string.IsNullOrWhiteSpace(country) && country.Equals("TW"))
  196. tmidStics.city = (regionData.city.ContainsKey(country) && !string.IsNullOrWhiteSpace(city) && regionData.city[country]["tw"].ContainsKey(city)) ? regionData.city[country]["tw"][city].name : city;
  197. else if (!string.IsNullOrWhiteSpace(country) && country.Equals("CN"))
  198. tmidStics.city = (regionData.city.ContainsKey(country) && !string.IsNullOrWhiteSpace(province) && !string.IsNullOrWhiteSpace(city) && regionData.city[country].ContainsKey(province) && regionData.city[country][province].ContainsKey(city)) ? regionData.city[country][province][city].name : city;
  199. tmidStics.dist = (!string.IsNullOrWhiteSpace(district) && country.Equals("TW") && regionData.city[country]["tw"].ContainsKey(city) && regionData.dist[country]["tw"][city].ContainsKey(district)) ? regionData.dist[country]["tw"][city][district].name : district;
  200. tmidStics.schoolCode = (doc.TryGetProperty("schoolCode", out JsonElement schCode)) ? schCode.GetString() : string.Empty;
  201. tmidStics.schoolCodeW = (doc.TryGetProperty("schoolCodeW", out JsonElement schCodeW)) ? schCodeW.GetString() : string.Empty;
  202. tmidStics.unitType = (doc.TryGetProperty("unitType", out JsonElement unitType)) ? unitType.GetString() : string.Empty;
  203. tmidStics.unitName = (doc.TryGetProperty("unitName", out JsonElement unitName)) ? unitName.GetString() : string.Empty;
  204. tmidStics.jobTitle = (doc.TryGetProperty("jobTitle", out JsonElement jobTitle)) ? jobTitle.GetString() : string.Empty;
  205. }
  206. }
  207. }
  208. if(tmidDic.Count.Equals(0)) return Ok(new List<object>());
  209. //取得 票券、登入各服務的時間、取得積分、個人服務授權、IOT
  210. foreach (KeyValuePair<string, TmidStics> dicItem in tmidDic)
  211. {
  212. string id = dicItem.Key;
  213. TmidStics tmidStics = dicItem.Value;
  214. //票券
  215. if (eventList.Contains("coupons"))
  216. {
  217. var usersCoupons = tableCouponClient.Get<DynamicTableEntity>(id);
  218. foreach (var coupon in usersCoupons)
  219. {
  220. tmidStics.coupons.Add(
  221. new TmidCoupon()
  222. {
  223. code = coupon.RowKey,
  224. exchange = coupon.Properties["exchangeTime"].DateTimeOffsetValue.Value.ToUnixTimeSeconds(),
  225. });
  226. }
  227. }
  228. //取得登入各服務的時間
  229. if (eventList.Contains("login"))
  230. {
  231. var loginTime = await redisClient.HashGetAllAsync(id);
  232. foreach (var t in loginTime)
  233. {
  234. if (!t.Name.StartsWith("HiTeach") && !_dicClientIds.ContainsKey(t.Name)) continue;
  235. tmidStics.login.Add(
  236. new TmidLoginTime()
  237. {
  238. product = t.Name.StartsWith("HiTeach") ? t.Name.ToString().Split("-")[0] : _dicClientIds[t.Name],
  239. time = (long)t.Value
  240. });
  241. }
  242. }
  243. //個人服務授權
  244. if (eventList.Contains("prod"))
  245. {
  246. tmidStics.prod = await getTMIDAuthService(cosmosClientCsv2, id, "", true);
  247. }
  248. }
  249. //IOT
  250. if (eventList.Contains("iot"))
  251. {
  252. List<string> ids = tmidDic.Keys.ToList();
  253. List<TmidAnalysisCal> iotResult = new List<TmidAnalysisCal>();
  254. Dictionary<string, List<TmidAnalysisCal>> iotDic = new Dictionary<string, List<TmidAnalysisCal>>();
  255. if (!string.IsNullOrWhiteSpace(dateFromStr) && !string.IsNullOrWhiteSpace(dateToStr) && !string.IsNullOrWhiteSpace(dateUnit))
  256. {
  257. if (dateUnit.ToLower().Equals("year"))
  258. {
  259. iotDic["HiTeach-year"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "year", y, 0, 0, dateTimeFromSec, dateTimeToSec);
  260. iotDic["HiTeachCC-year"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "year", y, 0, 0, dateTimeFromSec, dateTimeToSec);
  261. }
  262. else if (dateUnit.ToLower().Equals("month"))
  263. {
  264. iotDic["HiTeach-month"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "month", y, m, 0, dateTimeFromSec, dateTimeToSec);
  265. iotDic["HiTeachCC-month"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "month", y, m, 0, dateTimeFromSec, dateTimeToSec);
  266. }
  267. else if (dateUnit.ToLower().Equals("day"))
  268. {
  269. iotDic["HiTeach-day"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "day", y, m, d, dateTimeFromSec, dateTimeToSec);
  270. iotDic["HiTeachCC-day"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "day", y, m, d, dateTimeFromSec, dateTimeToSec);
  271. }
  272. }
  273. else
  274. {
  275. iotDic["HiTeach-year"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "year", y, 0, 0, dateTimeFromSec, dateTimeToSec);
  276. iotDic["HiTeach-month"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "month", y, m, 0, dateTimeFromSec, dateTimeToSec);
  277. iotDic["HiTeach-day"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeach", "day", y, m, d, dateTimeFromSec, dateTimeToSec);
  278. iotDic["HiTeachCC-year"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "year", y, 0, 0, dateTimeFromSec, dateTimeToSec);
  279. iotDic["HiTeachCC-month"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "month", y, m, 0, dateTimeFromSec, dateTimeToSec);
  280. iotDic["HiTeachCC-day"] = await getTMIDIotData(cosmosClientIes5, ids, "HiTeachCC", "day", y, m, d, dateTimeFromSec, dateTimeToSec);
  281. }
  282. //資料整理
  283. List<string> iotDicKeyList = new List<string>() { "HiTeach-year", "HiTeachCC-year", "HiTeach-month", "HiTeachCC-month", "HiTeach-day", "HiTeachCC-day" };
  284. foreach(string iotDicKey in iotDicKeyList)
  285. {
  286. if (iotDic.ContainsKey(iotDicKey))
  287. {
  288. foreach(TmidAnalysisCal iotCalData in iotDic[iotDicKey])
  289. {
  290. string id = iotCalData.tmid;
  291. TmidStics tmidStics = tmidDic[id];
  292. switch (iotDicKey)
  293. {
  294. case "HiTeach-year":
  295. tmidStics.iot.hiteach.year = iotCalData;
  296. break;
  297. case "HiTeachCC-year":
  298. tmidStics.iot.hiteachcc.year = iotCalData;
  299. break;
  300. case "HiTeach-month":
  301. tmidStics.iot.hiteach.month = iotCalData;
  302. break;
  303. case "HiTeachCC-month":
  304. tmidStics.iot.hiteachcc.month = iotCalData;
  305. break;
  306. case "HiTeach-day":
  307. tmidStics.iot.hiteach.day = iotCalData;
  308. break;
  309. case "HiTeachCC-day":
  310. tmidStics.iot.hiteachcc.day = iotCalData;
  311. break;
  312. }
  313. }
  314. }
  315. }
  316. }
  317. //積分
  318. if (eventList.Contains("points"))
  319. {
  320. List<string> ids = tmidDic.Keys.ToList();
  321. //防止Query過長,分次取得
  322. Dictionary<int, List<string>> idsDic = new Dictionary<int, List<string>>();
  323. int idCount = 0;
  324. int max = 100; //要分割成多少人一組
  325. foreach (string id in ids)
  326. {
  327. int indx = idCount / max;
  328. if (!idsDic.ContainsKey(indx)) idsDic.Add(indx, new List<string>());
  329. idsDic[indx].Add(id);
  330. idCount++;
  331. }
  332. foreach(var itemd in idsDic)
  333. {
  334. string filter = TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "Points");
  335. string rkFilterCombine = string.Empty;
  336. foreach (string rowKey in itemd.Value)
  337. {
  338. string rkFilter = TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, rowKey);
  339. if (string.IsNullOrWhiteSpace(rkFilterCombine))
  340. {
  341. rkFilterCombine = rkFilter;
  342. }
  343. else
  344. {
  345. rkFilterCombine = TableQuery.CombineFilters(rkFilterCombine, TableOperators.Or, rkFilter);
  346. }
  347. }
  348. filter = TableQuery.CombineFilters(filter, TableOperators.And, rkFilterCombine);
  349. TableQuery tableQuery = new TableQuery().Where(filter);
  350. var usersPoints = tablePointsClient.ExecuteQuery(tableQuery);
  351. if (usersPoints.Any())
  352. {
  353. foreach (DynamicTableEntity item in usersPoints)
  354. {
  355. string id = item.RowKey.ToString();
  356. TmidStics tmidStics = tmidDic[id];
  357. tmidStics.points.points = (usersPoints != null) ? item.Properties["Points"].Int32Value.Value : 0;
  358. tmidStics.points.level = (usersPoints != null) ? item.Properties["Level"].Int32Value.Value : 0;
  359. tmidStics.points.balance = (usersPoints != null) ? item.Properties["Balance"].Int32Value.Value : 0;
  360. }
  361. }
  362. }
  363. }
  364. //IES5
  365. if (eventList.Contains("ies5"))
  366. {
  367. query = new QueryDefinition(@"SELECT c.id, c.defaultSchool, c.schools FROM c WHERE ARRAY_CONTAINS(@key, c.id)")
  368. .WithParameter("@key", tmidDic.Keys.ToList());
  369. await foreach (var item in cosmosClientIes5
  370. .GetContainer(Constant.TEAMModelOS, "Teacher")
  371. .GetItemQueryStreamIteratorSql(query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  372. {
  373. using var json = await JsonDocument.ParseAsync(item.Content);
  374. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  375. {
  376. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  377. {
  378. string id = doc.GetProperty("id").GetString();
  379. TmidStics tmidStics = tmidDic[id];
  380. //IES5學校資訊
  381. string defaultschool = (doc.TryGetProperty("defaultSchool", out JsonElement _defaultSchool)) ? _defaultSchool.ToString() : string.Empty; //預設學校
  382. List<string> schoolIds = new List<string>();
  383. if (doc.TryGetProperty("schools", out JsonElement schoolsJobj))
  384. {
  385. foreach (var obj in schoolsJobj.EnumerateArray())
  386. {
  387. string schoolCodeNow = $"{obj.GetProperty("schoolId")}";
  388. string status = $"{obj.GetProperty("status")}";
  389. if (status.Equals("join"))
  390. {
  391. schoolIds.Add(schoolCodeNow); //放入學校ID列,一次取
  392. }
  393. }
  394. }
  395. if (schoolIds.Count > 0)
  396. {
  397. QueryDefinition querysc = new QueryDefinition(@"SELECT c.id, c.name, c.region, c.province, c.city, c.dist, c.size, c.period FROM c WHERE ARRAY_CONTAINS(@key, c.id)")
  398. .WithParameter("@key", schoolIds);
  399. await foreach (var itemsc in cosmosClientIes5
  400. .GetContainer(Constant.TEAMModelOS, "School")
  401. .GetItemQueryStreamIteratorSql(querysc, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
  402. {
  403. using var jsonsc = await JsonDocument.ParseAsync(itemsc.Content);
  404. if (jsonsc.RootElement.TryGetProperty("_count", out JsonElement countsc) && countsc.GetUInt16() > 0)
  405. {
  406. foreach (var school in jsonsc.RootElement.GetProperty("Documents").EnumerateArray())
  407. {
  408. string schoolCodeNow = school.GetProperty("id").GetString();
  409. //當前學年 ※若有多學段,取第一個學段來取得學年資訊吧
  410. Period period = school.GetProperty("period").Deserialize<List<Period>>().First();
  411. var info = SchoolService.GetSemester(period, 0, DateTime.Now.ToString());
  412. int studyYear = info.studyYear;
  413. //學校Blob使用狀況
  414. (long usedSize, long teach, long total, long surplus, Dictionary<string, double?> catalog) schoolUsedBlob = await BlobService.GetSurplusSpace(schoolCodeNow, "school", _option.Location, _azureCosmos, _azureRedis, _azureStorage, _dingDing, _httpTrigger);
  415. //老師在此學校的課程數 ※只取當前學年
  416. int courseCnt = 0;
  417. var queryCrs = $"SELECT VALUE COUNT(1) FROM ( SELECT DISTINCT VALUE(c.id) FROM c JOIN schedules IN c.schedules WHERE schedules.teacherId = '{id}' AND c.year = {studyYear} )";
  418. await foreach (int itemCrs in cosmosClientIes5.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIteratorSql<int>(queryText: queryCrs, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"CourseTask-{schoolCodeNow}") }))
  419. {
  420. courseCnt = itemCrs;
  421. }
  422. //IES5學校資料製作
  423. TmidSticsIes5School schoolobj = new TmidSticsIes5School();
  424. long ssize = (school.TryGetProperty("size", out JsonElement ssizeJson)) ? ssizeJson.GetInt32() : 0;
  425. long sused = schoolUsedBlob.usedSize + schoolUsedBlob.teach * 1073741824;
  426. long stotal = ssize * 1073741824;
  427. object schzize = new
  428. {
  429. used = sused,
  430. total = stotal,
  431. avaliable = stotal - sused,
  432. };
  433. schoolobj.schoolId = schoolCodeNow;
  434. schoolobj.name = school.GetProperty("name").GetString();
  435. schoolobj.region = school.GetProperty("region").GetString();
  436. schoolobj.province = school.GetProperty("province").GetString();
  437. schoolobj.city = school.GetProperty("city").GetString();
  438. schoolobj.dist = school.GetProperty("dist").GetString();
  439. schoolobj.size = schzize;
  440. schoolobj.courseCnt = courseCnt;
  441. schoolobj.defaultSchool = (!string.IsNullOrWhiteSpace(defaultschool) && defaultschool.Equals(schoolCodeNow)) ? true : false;
  442. tmidStics.ies5.schools.Add(schoolobj);
  443. }
  444. }
  445. }
  446. }
  447. //IES5個人空間
  448. var (usedSize, teach, total, surplus, catalog) = await BlobService.GetSurplusSpace(id, "private", _option.Location, _azureCosmos, _azureRedis, _azureStorage, _dingDing, _httpTrigger);
  449. tmidStics.ies5.usedSize = usedSize;
  450. tmidStics.ies5.teachSize = teach * 1073741824;
  451. tmidStics.ies5.totalSize = total * 1073741824;
  452. tmidStics.ies5.surplusSize = surplus;
  453. //IES5個人資源數
  454. tmidStics.ies5.resCount = 0; //教材數
  455. tmidStics.ies5.itemCount = 0; //題目數
  456. tmidStics.ies5.paperCount = 0; //試卷數
  457. ///IES5個人題目數
  458. await foreach (int itemC in cosmosClientIes5.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<int>(queryText: $"SELECT VALUE COUNT(1) FROM c WHERE c.pid = null", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-{id}") }))
  459. {
  460. tmidStics.ies5.itemCount = itemC;
  461. }
  462. ///IES5個人試卷數
  463. await foreach (int paperC in cosmosClientIes5.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<int>(queryText: $"SELECT VALUE COUNT(1) FROM c WHERE c.scope = 'private'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Paper-{id}") }))
  464. {
  465. tmidStics.ies5.paperCount = paperC;
  466. }
  467. ///IES5個人教材數
  468. List<BlobService.BlobCount> blogCountList = await BlobService.BloblogCount(cosmosClientIes5, "private", id, "", "");
  469. foreach (BlobService.BlobCount blobCountRow in blogCountList)
  470. {
  471. switch (blobCountRow.type)
  472. {
  473. case "doc":
  474. case "image":
  475. case "res":
  476. case "video":
  477. case "audio":
  478. case "other":
  479. tmidStics.ies5.resCount += blobCountRow.count;
  480. break;
  481. }
  482. }
  483. if (!tmidDic.ContainsKey(id)) tmidDic.Add(id, tmidStics);
  484. }
  485. }
  486. }
  487. }
  488. //個人權益
  489. if (eventList.Contains("benefits"))
  490. {
  491. query = new QueryDefinition(@"SELECT * FROM c WHERE (ARRAY_CONTAINS(@key, c.id))")
  492. .WithParameter("@key", tmidDic.Keys.ToList());
  493. await foreach (var item in cosmosClientCsv2
  494. .GetContainer("Core", "ID2")
  495. .GetItemQueryStreamIteratorSql(query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("benefits") }))
  496. {
  497. using var json = await JsonDocument.ParseAsync(item.Content);
  498. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  499. {
  500. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  501. {
  502. string id = doc.GetProperty("id").GetString();
  503. if (doc.TryGetProperty("hiteach", out var elementHiteachData))
  504. {
  505. tmidDic[id].benefits.hiteach = elementHiteachData.ToObject<List<object>>();
  506. }
  507. if (doc.TryGetProperty("hiteachcc", out var elementHiteachCCData))
  508. {
  509. tmidDic[id].benefits.hiteachcc = elementHiteachCCData.ToObject<List<object>>();
  510. }
  511. }
  512. }
  513. }
  514. }
  515. //蘇格拉底資料
  516. if (eventList.Contains("sokrates"))
  517. {
  518. query = new QueryDefinition(@"SELECT * FROM c WHERE (ARRAY_CONTAINS(@key, c.id))")
  519. .WithParameter("@key", tmidDic.Keys.ToList());
  520. await foreach (var item in cosmosClientCsv2
  521. .GetContainer("Core", "ID2")
  522. .GetItemQueryStreamIteratorSql(query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("sokrates") }))
  523. {
  524. using var json = await JsonDocument.ParseAsync(item.Content);
  525. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  526. {
  527. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  528. {
  529. string id = doc.GetProperty("id").GetString();
  530. if (doc.TryGetProperty("hiteach_data", out var elementHiteachData))
  531. {
  532. tmidDic[id].sokrates.hiteach_data = elementHiteachData.ToObject<TmidSokratesHiteach>();
  533. }
  534. if (doc.TryGetProperty("user_channels", out var elementUserChannels))
  535. {
  536. tmidDic[id].sokrates.user_channels = elementUserChannels.ToObject<object>();
  537. }
  538. }
  539. }
  540. }
  541. }
  542. //輸出
  543. List<object> data = new();
  544. foreach (KeyValuePair<string, TmidStics> dicItem in tmidDic)
  545. {
  546. data.Add(dicItem.Value);
  547. }
  548. return Ok(data);
  549. }
  550. catch (Exception ex)
  551. {
  552. //await _dingDing.SendBotMsg($"BI,{_option.Location} /tmid/get-tmidstics \n {ex.Message}\n{ex.StackTrace}", GroupNames.台北開發測試群組);
  553. return BadRequest();
  554. }
  555. }
  556. /// <summary>
  557. /// 取得TMID IOT資料
  558. /// </summary>
  559. /// <param name="jsonElement"></param>
  560. /// <returns></returns>
  561. [ProducesDefaultResponseType]
  562. [Authorize(Roles = "IES")]
  563. [HttpPost("get-tmid-iot")]
  564. public async Task<IActionResult> GetTmidIot(JsonElement jsonElement)
  565. {
  566. try
  567. {
  568. if (!jsonElement.TryGetProperty("tmids", out JsonElement tmidsJobj)) return BadRequest(); //TMID(array)
  569. var tmids = tmidsJobj.Deserialize<List<string>>();
  570. if (tmids.Count is 0) return BadRequest();
  571. string dateFromStr = (jsonElement.TryGetProperty("dateFrom", out JsonElement dateFromJobj)) ? dateFromJobj.GetString() : string.Empty; //查詢日期:起始(string)[例]2023-03-05
  572. string dateToStr = (jsonElement.TryGetProperty("dateTo", out JsonElement dateToJobj)) ? dateToJobj.GetString() : string.Empty; //查詢日期:結束(string)[例]2023-03-27
  573. string dateUnit = (jsonElement.TryGetProperty("dateUnit", out JsonElement dateUnitJobj)) ? dateUnitJobj.GetString().ToLower() : "month";
  574. if(string.IsNullOrWhiteSpace(dateFromStr) || string.IsNullOrWhiteSpace(dateToStr))
  575. {
  576. return BadRequest();
  577. }
  578. Dictionary<string, TmidStics> tmidDic = await GetTmidIotCore(tmids, dateFromStr, dateToStr, dateUnit);
  579. //輸出
  580. List<object> data = new();
  581. foreach (KeyValuePair<string, TmidStics> dicItem in tmidDic)
  582. {
  583. data.Add(dicItem.Value);
  584. }
  585. return Ok(data);
  586. }
  587. catch (Exception ex)
  588. {
  589. //await _dingDing.SendBotMsg($"BI,{_option.Location} /tmid/get-tmidstics \n {ex.Message}\n{ex.StackTrace}", GroupNames.台北開發測試群組);
  590. return BadRequest();
  591. }
  592. }
  593. private async Task<Dictionary<string, TmidStics>> GetTmidIotCore(List<string> tmids, string dateFromStr, string dateToStr, string dateUnit)
  594. {
  595. //起始終止日期換算
  596. long dateTimeFromSec = 0;
  597. long dateTimeToSec = 0;
  598. DateTimeOffset dateTimeFrom;
  599. DateTimeOffset dateTimeTo;
  600. List<string> dateFromList = dateFromStr.Split('-').ToList();
  601. int dateFromYear = Convert.ToInt32(dateFromList[0], 10);
  602. int dateFromMonth = (dateUnit.Equals("day") || dateUnit.Equals("month")) ? Convert.ToInt32(dateFromList[1], 10) : 1;
  603. int dateFromDay = (dateUnit.Equals("day")) ? Convert.ToInt32(dateFromList[2], 10) : 1;
  604. List<string> dateToList = dateToStr.Split('-').ToList();
  605. int dateToYear = Convert.ToInt32(dateToList[0], 10);
  606. int dateToMonth = (dateUnit.Equals("day") || dateUnit.Equals("month")) ? Convert.ToInt32(dateToList[1], 10) : 1;
  607. int dateToDay = (dateUnit.Equals("day")) ? Convert.ToInt32(dateToList[2], 10) : 1;
  608. switch (dateUnit)
  609. {
  610. case "year":
  611. dateTimeFrom = new DateTimeOffset(dateFromYear, 1, 1, 0, 0, 0, TimeSpan.Zero);
  612. dateTimeTo = new DateTimeOffset(dateToYear, 12, 31, 23, 59, 59, TimeSpan.Zero);
  613. break;
  614. case "month":
  615. dateTimeFrom = new DateTimeOffset(dateFromYear, dateFromMonth, 1, 0, 0, 0, TimeSpan.Zero);
  616. dateTimeTo = new DateTimeOffset(dateToYear, dateToMonth, DateTime.DaysInMonth(dateToYear, dateToMonth), 23, 59, 59, TimeSpan.Zero);
  617. break;
  618. case "day":
  619. dateTimeFrom = new DateTimeOffset(dateFromYear, dateFromMonth, dateFromDay, 0, 0, 0, TimeSpan.Zero);
  620. dateTimeTo = new DateTimeOffset(dateToYear, dateToMonth, dateToDay, 23, 59, 59, TimeSpan.Zero);
  621. break;
  622. default: //同"month"
  623. dateTimeFrom = new DateTimeOffset(dateFromYear, dateFromMonth, 1, 0, 0, 0, TimeSpan.Zero);
  624. dateTimeTo = new DateTimeOffset(dateToYear, dateToMonth, DateTime.DaysInMonth(dateToYear, dateToMonth), 23, 59, 59, TimeSpan.Zero);
  625. break;
  626. }
  627. dateTimeFromSec = dateTimeFrom.ToUnixTimeSeconds();
  628. dateTimeToSec = dateTimeTo.ToUnixTimeSeconds();
  629. //資料取得
  630. Dictionary<string, TmidStics> tmidDic = new();
  631. foreach (string id in tmids)
  632. {
  633. if (!tmidDic.ContainsKey(id))
  634. {
  635. TmidStics tmidStics = new TmidStics() { id = id, iot = new() };
  636. tmidDic.Add(id, tmidStics);
  637. }
  638. }
  639. //IOT資料
  640. var cosmosClientIes5 = _azureCosmos.GetCosmosClient(); //CosmosDB IES5
  641. List<TmidAnalysisCal> iotResult = new List<TmidAnalysisCal>();
  642. Dictionary<string, List<TmidAnalysisCal>> iotDic = new Dictionary<string, List<TmidAnalysisCal>>();
  643. if (dateUnit.ToLower().Equals("year"))
  644. {
  645. iotDic["HiTeach-year"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeach", "year", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  646. iotDic["HiTeachCC-year"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeachCC", "year", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  647. }
  648. else if (dateUnit.ToLower().Equals("month"))
  649. {
  650. iotDic["HiTeach-month"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeach", "month", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  651. iotDic["HiTeachCC-month"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeachCC", "month", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  652. }
  653. else if (dateUnit.ToLower().Equals("day"))
  654. {
  655. iotDic["HiTeach-day"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeach", "day", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  656. iotDic["HiTeachCC-day"] = await getTMIDIotData(cosmosClientIes5, tmids, "HiTeachCC", "day", 0, 0, 0, dateTimeFromSec, dateTimeToSec);
  657. }
  658. //IOT資料整理
  659. List<string> iotDicKeyList = new List<string>() { "HiTeach-year", "HiTeachCC-year", "HiTeach-month", "HiTeachCC-month", "HiTeach-day", "HiTeachCC-day" };
  660. foreach (string iotDicKey in iotDicKeyList)
  661. {
  662. if (iotDic.ContainsKey(iotDicKey))
  663. {
  664. foreach (TmidAnalysisCal iotCalData in iotDic[iotDicKey])
  665. {
  666. string id = iotCalData.tmid;
  667. TmidStics tmidStics = tmidDic[id];
  668. switch (iotDicKey)
  669. {
  670. case "HiTeach-year":
  671. tmidStics.iot.hiteach.year = iotCalData;
  672. break;
  673. case "HiTeachCC-year":
  674. tmidStics.iot.hiteachcc.year = iotCalData;
  675. break;
  676. case "HiTeach-month":
  677. tmidStics.iot.hiteach.month = iotCalData;
  678. break;
  679. case "HiTeachCC-month":
  680. tmidStics.iot.hiteachcc.month = iotCalData;
  681. break;
  682. case "HiTeach-day":
  683. tmidStics.iot.hiteach.day = iotCalData;
  684. break;
  685. case "HiTeachCC-day":
  686. tmidStics.iot.hiteachcc.day = iotCalData;
  687. break;
  688. }
  689. }
  690. }
  691. }
  692. return tmidDic;
  693. }
  694. /// <summary>
  695. /// 取得TMID使用產品資料
  696. /// </summary>
  697. /// <param name="jsonElement"></param>
  698. /// <returns></returns>
  699. [ProducesDefaultResponseType]
  700. [Authorize(Roles = "IES")]
  701. [HttpPost("get-tmid-useprod")]
  702. public async Task<IActionResult> GetTmidUseProd(JsonElement jsonElement)
  703. {
  704. string dateFromStr = (jsonElement.TryGetProperty("dateFrom", out JsonElement dateFromJobj)) ? dateFromJobj.GetString() : string.Empty; //查詢日期:起始(string)[例]2023-03-05
  705. string dateToStr = (jsonElement.TryGetProperty("dateTo", out JsonElement dateToJobj)) ? dateToJobj.GetString() : string.Empty; //查詢日期:結束(string)[例]2023-03-27
  706. List<DateFromTo> dateList = (jsonElement.TryGetProperty("dateList", out JsonElement dateListJobj)) ? dateListJobj.ToObject<List<DateFromTo>>() : new List<DateFromTo>(); //查詢日期起始結束列表
  707. bool dateFromToValid = (!string.IsNullOrWhiteSpace(dateFromStr) && !string.IsNullOrWhiteSpace(dateToStr)) ? true : false;
  708. bool dateListValid = (dateList.Count > 0) ? true : false;
  709. if (dateFromToValid.Equals(false) && dateListValid.Equals(false)) return BadRequest();
  710. List<string> targets = (jsonElement.TryGetProperty("targets", out JsonElement targetsJobj)) ? targetsJobj.ToObject<List<string>>() : new List<string>() {"tmid", "sch", "geo" }; //資料取得 "tmid":必定會取 "sch":學校資訊 "geo":地理資訊
  711. bool getLoginTime = (jsonElement.TryGetProperty("getLoginTime", out JsonElement getLoginTimeJobj)) ? getLoginTimeJobj.GetBoolean() : false; //是否取得各服務Login時間
  712. if (dateFromToValid)
  713. {
  714. object result = await GetTmidUseprodCore(dateFromStr, dateToStr, targets, getLoginTime);
  715. return Ok(result);
  716. }
  717. else if(dateListValid)
  718. {
  719. List<object> result = new List<object>();
  720. foreach (DateFromTo dateFromTo in dateList)
  721. {
  722. string dateFrom = dateFromTo.dateFrom;
  723. string dateTo = dateFromTo.dateTo;
  724. object tmidUseprod = await GetTmidUseprodCore(dateFrom, dateTo, targets, getLoginTime);
  725. result.Add(tmidUseprod);
  726. }
  727. return Ok(result);
  728. }
  729. else
  730. {
  731. return Ok(new { });
  732. }
  733. }
  734. private async Task<object> GetTmidUseprodCore(string dateFromStr, string dateToStr, List<string> targets, bool getLoginTime)
  735. {
  736. Dictionary<string, TmidStics> tmidDic = new();
  737. HashSet<string> schIds = new HashSet<string>(); //生成的TMID所關聯的學校ID列表
  738. DateTime dateFrom = DateTime.ParseExact(dateFromStr, "yyyy-MM-dd", null);
  739. DateTime dateTo = DateTime.ParseExact(dateToStr, "yyyy-MM-dd", null).Add(new TimeSpan(0, 23, 59, 59));
  740. DateTimeOffset dateTimeFrom = new DateTimeOffset(dateFrom, TimeSpan.Zero);
  741. DateTimeOffset dateTimeTo = new DateTimeOffset(dateTo, TimeSpan.Zero);
  742. long unixTimeFrom = dateTimeFrom.ToUnixTimeSeconds();
  743. long unixTimeTo = dateTimeTo.ToUnixTimeSeconds();
  744. //大陸站 ID計算方式特化處理
  745. if (_option.Location.Contains("China"))
  746. {
  747. unixTimeFrom += 5000000000;
  748. unixTimeTo += 5000000000;
  749. }
  750. //服務Client端
  751. var cosmosClientIes5 = _azureCosmos.GetCosmosClient(); //CosmosDB IES5
  752. var cosmosClientCsv2 = _azureCosmos.GetCosmosClient(name: "CoreServiceV2"); //CosmosDB CSV2
  753. var cosmosClientCsv2CnRead = _azureCosmos.GetCosmosClient(name: "CoreServiceV2CnRead"); //CosmosDB CSV2 CN Read
  754. var storageClientCsv2 = _azureStorage.GetCloudTableClient(name: "CoreServiceV2"); //Storage CSV2
  755. var tableCouponClient = storageClientCsv2.GetTableReference("Coupon");
  756. var tablePointsClient = storageClientCsv2.GetTableReference("Points");
  757. var redisClient = _azureRedis.GetRedisClient(4);
  758. //取得TMID資料
  759. HashSet<string> tmids = new HashSet<string>();
  760. int pageSize = (getLoginTime) ? 100 : 5000;
  761. string? continuationToken = null;
  762. string query = $"SELECT * FROM c WHERE {unixTimeFrom} <= StringToNumber(c.id) AND StringToNumber(c.id) <= {unixTimeTo}";
  763. do
  764. {
  765. await foreach (var item in cosmosClientCsv2
  766. .GetContainer("Core", "ID2")
  767. .GetItemQueryStreamIteratorSql(query, continuationToken: continuationToken, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("base"), MaxItemCount = pageSize }))
  768. {
  769. using var json = await JsonDocument.ParseAsync(item.Content);
  770. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  771. {
  772. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  773. {
  774. string id = doc.GetProperty("id").GetString();
  775. if (!tmidDic.ContainsKey(id)) tmidDic.Add(id, new TmidStics());
  776. tmids.Add(id);
  777. TmidStics tmidStics = tmidDic[id];
  778. //基本資料
  779. tmidStics.name = doc.GetProperty("name").GetString();
  780. //取得登入各服務的時間 ※getLoginTime == true 才取
  781. if (getLoginTime)
  782. {
  783. var loginTime = await redisClient.HashGetAllAsync(id);
  784. foreach (var t in loginTime)
  785. {
  786. if (!t.Name.StartsWith("HiTeach") && !_dicClientIds.ContainsKey(t.Name)) continue;
  787. tmidStics.login.Add(
  788. new TmidLoginTime()
  789. {
  790. product = t.Name.StartsWith("HiTeach") ? t.Name.ToString().Split("-")[0] : _dicClientIds[t.Name],
  791. time = (long)t.Value
  792. });
  793. }
  794. }
  795. }
  796. }
  797. continuationToken = item.GetContinuationToken();
  798. }
  799. }
  800. while (!string.IsNullOrWhiteSpace(continuationToken));
  801. //取得TMID進階資料
  802. continuationToken = null;
  803. do
  804. {
  805. QueryDefinition querye = new QueryDefinition(@"SELECT c.id, c.name, c.mobile, c.mail, c.country, c.province, c.city, c.schoolCode, c.schoolCodeW, c.unitType, c.unitName, c.jobTitle FROM c WHERE (ARRAY_CONTAINS(@key, c.id) OR ARRAY_CONTAINS(@key, c.mobile))")
  806. .WithParameter("@key", tmids);
  807. await foreach (var item in cosmosClientCsv2
  808. .GetContainer("Core", "ID2")
  809. .GetItemQueryStreamIteratorSql(querye, continuationToken: continuationToken, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("base-ex"), MaxItemCount = pageSize }))
  810. {
  811. using var json = await JsonDocument.ParseAsync(item.Content);
  812. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  813. {
  814. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  815. {
  816. string id = doc.GetProperty("id").GetString();
  817. TmidStics tmidStics = tmidDic[id];
  818. tmidStics.schoolCode = (doc.TryGetProperty("schoolCode", out JsonElement schCode)) ? schCode.GetString() : string.Empty;
  819. tmidStics.schoolCodeW = (doc.TryGetProperty("schoolCodeW", out JsonElement schCodeW)) ? schCodeW.GetString() : string.Empty;
  820. if (!string.IsNullOrWhiteSpace(tmidStics.schoolCode)) schIds.Add(tmidStics.schoolCode);
  821. if (!string.IsNullOrWhiteSpace(tmidStics.schoolCodeW)) schIds.Add(tmidStics.schoolCodeW);
  822. if (!string.IsNullOrWhiteSpace(tmidStics.schoolCode) && string.IsNullOrWhiteSpace(tmidStics.schoolId))
  823. {
  824. tmidStics.schoolId = tmidStics.schoolCode;
  825. }
  826. else if (!string.IsNullOrWhiteSpace(tmidStics.schoolCodeW) && string.IsNullOrWhiteSpace(tmidStics.schoolId))
  827. {
  828. tmidStics.schoolId = tmidStics.schoolCodeW;
  829. }
  830. }
  831. }
  832. continuationToken = item.GetContinuationToken();
  833. }
  834. }
  835. while (!string.IsNullOrWhiteSpace(continuationToken));
  836. //TMID資料整理
  837. foreach (var item in tmidDic)
  838. {
  839. TmidStics tmidStics = item.Value;
  840. if (!string.IsNullOrWhiteSpace(tmidStics.schoolCode) || !string.IsNullOrWhiteSpace(tmidStics.schoolCodeW))
  841. {
  842. if (!string.IsNullOrWhiteSpace(tmidStics.schoolCode))
  843. {
  844. tmidStics.schoolId = tmidStics.schoolCode;
  845. }
  846. else if (!string.IsNullOrWhiteSpace(tmidStics.schoolCodeW))
  847. {
  848. tmidStics.schoolId = tmidStics.schoolCodeW;
  849. }
  850. }
  851. }
  852. //取得學校資料
  853. Dictionary<string, Dictionary<string, string>> school = new Dictionary<string, Dictionary<string, string>>();
  854. if (targets.Contains("sch"))
  855. {
  856. string querys = $"SELECT * FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(schIds)}, c.shortCode, true)";
  857. await foreach (var item in cosmosClientCsv2CnRead
  858. .GetContainer("Core", "School")
  859. .GetItemQueryStreamIteratorSql(querys, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("base") }))
  860. {
  861. using var json = await JsonDocument.ParseAsync(item.Content);
  862. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  863. {
  864. foreach (var doc in json.RootElement.GetProperty("Documents").EnumerateArray())
  865. {
  866. Dictionary<string, string> schoolRow = new Dictionary<string, string>();
  867. string shortCode = doc.GetProperty("shortCode").GetString();
  868. string name = doc.GetProperty("name").GetString();
  869. string countryId = doc.GetProperty("countryId").GetString();
  870. string countryName = doc.GetProperty("countryName").GetString();
  871. string provinceId = doc.GetProperty("provinceId").GetString();
  872. string provinceName = doc.GetProperty("provinceName").GetString();
  873. string cityId = doc.GetProperty("cityId").GetString();
  874. string cityName = doc.GetProperty("cityName").GetString();
  875. string distId = doc.GetProperty("distId").GetString();
  876. string distName = doc.GetProperty("distName").GetString();
  877. schoolRow.Add("shortCode", shortCode);
  878. schoolRow.Add("name", name);
  879. schoolRow.Add("countryId", countryId);
  880. schoolRow.Add("countryName", countryName);
  881. schoolRow.Add("provinceId", provinceId);
  882. schoolRow.Add("provinceName", provinceName);
  883. schoolRow.Add("cityId", cityId);
  884. schoolRow.Add("cityName", cityName);
  885. schoolRow.Add("distId", distId);
  886. schoolRow.Add("distName", distName);
  887. school.Add(shortCode, schoolRow);
  888. }
  889. }
  890. }
  891. }
  892. //返回值整理
  893. List<TmidIotProdCnt> tmid = new List<TmidIotProdCnt>();
  894. List<TmidIotProdCntGeo> sch = new List<TmidIotProdCntGeo>(); //取得的IOT學校統計資訊
  895. foreach (var item in tmidDic)
  896. {
  897. //TMID
  898. string id = item.Key;
  899. TmidIotProdCnt tmidRow = new TmidIotProdCnt();
  900. tmidRow.id = id;
  901. tmidRow.name = item.Value.name;
  902. tmidRow.schid = (!string.IsNullOrWhiteSpace(item.Value.schoolId)) ? item.Value.schoolId : null;
  903. foreach (TmidLoginTime login in item.Value.login)
  904. {
  905. switch (login.product)
  906. {
  907. case "HiTeach":
  908. tmidRow.hiteach++;
  909. break;
  910. case "HiTeachCC":
  911. tmidRow.hiteachcc++;
  912. break;
  913. case "HiTA":
  914. tmidRow.hita++;
  915. break;
  916. case "IES5":
  917. tmidRow.ies5++;
  918. break;
  919. case "Account":
  920. tmidRow.account++;
  921. break;
  922. case "Sokrates":
  923. tmidRow.sokrates++;
  924. break;
  925. case "SokAPP":
  926. tmidRow.sokapp++;
  927. break;
  928. case "IRS":
  929. tmidRow.irs++;
  930. break;
  931. }
  932. }
  933. tmid.Add(tmidRow);
  934. //school
  935. if (targets.Contains("sch"))
  936. {
  937. if (!string.IsNullOrWhiteSpace(tmidRow.schid))
  938. {
  939. var schRow = sch.Where(s => s.id.Equals(tmidRow.schid)).FirstOrDefault();
  940. if (schRow == null)
  941. {
  942. TmidIotProdCntGeo tmpData = new TmidIotProdCntGeo();
  943. tmpData.id = tmidRow.schid;
  944. tmpData.schid = tmidRow.schid;
  945. if (school.ContainsKey(tmidRow.schid))
  946. {
  947. tmpData.name = school[tmidRow.schid]["name"];
  948. tmpData.countryId = school[tmidRow.schid]["countryId"];
  949. tmpData.countryName = school[tmidRow.schid]["countryName"];
  950. tmpData.provinceId = school[tmidRow.schid]["provinceId"];
  951. tmpData.provinceName = school[tmidRow.schid]["provinceName"];
  952. tmpData.cityId = school[tmidRow.schid]["cityId"];
  953. tmpData.cityName = school[tmidRow.schid]["cityName"];
  954. tmpData.distId = school[tmidRow.schid]["distId"];
  955. tmpData.distName = school[tmidRow.schid]["distName"];
  956. }
  957. sch.Add(tmpData);
  958. schRow = sch.Where(s => s.id.Equals(tmidRow.schid)).FirstOrDefault();
  959. }
  960. if (tmidRow.hiteach > 0) schRow.hiteach++;
  961. if (tmidRow.hiteachcc > 0) schRow.hiteachcc++;
  962. if (tmidRow.hita > 0) schRow.hita++;
  963. if (tmidRow.ies5 > 0) schRow.ies5++;
  964. if (tmidRow.account > 0) schRow.account++;
  965. if (tmidRow.sokrates > 0) schRow.sokrates++;
  966. if (tmidRow.sokapp > 0) schRow.sokapp++;
  967. if (tmidRow.irs > 0) schRow.irs++;
  968. if (!schRow.tmids.Contains(id)) schRow.tmids.Add(id);
  969. }
  970. }
  971. }
  972. //geo
  973. List<TmidIotProdCntGeo> geo = new List<TmidIotProdCntGeo>();
  974. if (targets.Contains("geo"))
  975. {
  976. foreach (TmidIotProdCntGeo schRow in sch)
  977. {
  978. string countryId = (!string.IsNullOrWhiteSpace(schRow.countryId)) ? schRow.countryId : string.Empty;
  979. string provinceId = (!string.IsNullOrWhiteSpace(schRow.provinceId)) ? schRow.provinceId : string.Empty;
  980. string cityId = (!string.IsNullOrWhiteSpace(schRow.cityId)) ? schRow.cityId : string.Empty;
  981. string distId = (!string.IsNullOrWhiteSpace(schRow.distId)) ? schRow.distId : string.Empty;
  982. string geoid = $"{countryId}-{provinceId}-{cityId}-{distId}";
  983. var geoRow = geo.Where(s => s.id.Equals(geoid)).FirstOrDefault();
  984. if (geoRow == null)
  985. {
  986. geo.Add(new TmidIotProdCntGeo()
  987. {
  988. id = geoid,
  989. name = string.Empty,
  990. countryId = schRow.countryId,
  991. countryName = schRow.countryName,
  992. provinceId = schRow.provinceId,
  993. provinceName = schRow.provinceName,
  994. cityId = schRow.cityId,
  995. cityName = schRow.cityName,
  996. distId = schRow.distId,
  997. distName = schRow.distName,
  998. });
  999. geoRow = geo.Where(s => s.id.Equals(geoid)).FirstOrDefault();
  1000. }
  1001. geoRow.hiteach += schRow.hiteach;
  1002. geoRow.hiteachcc += schRow.hiteachcc;
  1003. geoRow.hita += schRow.hita;
  1004. geoRow.ies5 += schRow.ies5;
  1005. geoRow.account += schRow.account;
  1006. geoRow.sokrates += schRow.sokrates;
  1007. geoRow.sokapp += schRow.sokapp;
  1008. geoRow.irs += schRow.irs;
  1009. geoRow.tmids = geoRow.tmids.Union(schRow.tmids).ToList();
  1010. }
  1011. }
  1012. //IOT(學校)
  1013. string queryiot = $"SELECT * FROM c WHERE ARRAY_CONTAINS({JsonSerializer.Serialize(schIds)}, c.schoolId, true) AND c.toolType = 'HiTeach' AND c.dateUnit = 'month' AND c.dateTime >= {dateTimeFrom.ToUnixTimeSeconds()} AND c.dateTime <= {dateTimeTo.ToUnixTimeSeconds()}";
  1014. await foreach (ProdAnalysisCosmos item in cosmosClientIes5.GetContainer("TEAMModelOS", "School").GetItemQueryIteratorSql<ProdAnalysisCosmos>(queryText: queryiot, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"ProdAnalysis") }))
  1015. {
  1016. //各校IOT累加
  1017. var schRow = sch.Where(s => s.id.Equals(item.schoolId)).FirstOrDefault();
  1018. if (schRow != null)
  1019. {
  1020. schRow.tLesson += item.tLesson;
  1021. schRow.tGreen += item.tGreen;
  1022. //地理位置IOT累加
  1023. string countryId = (!string.IsNullOrWhiteSpace(schRow.countryId)) ? schRow.countryId : string.Empty;
  1024. string provinceId = (!string.IsNullOrWhiteSpace(schRow.provinceId)) ? schRow.provinceId : string.Empty;
  1025. string cityId = (!string.IsNullOrWhiteSpace(schRow.cityId)) ? schRow.cityId : string.Empty;
  1026. string distId = (!string.IsNullOrWhiteSpace(schRow.distId)) ? schRow.distId : string.Empty;
  1027. string geoid = $"{countryId}-{provinceId}-{cityId}-{distId}";
  1028. var geoRow = geo.Where(s => s.id.Equals(geoid)).FirstOrDefault();
  1029. if (geoRow != null)
  1030. {
  1031. geoRow.tLesson += item.tLesson;
  1032. geoRow.tGreen += item.tGreen;
  1033. }
  1034. }
  1035. }
  1036. //總IOT累加
  1037. Dictionary<string, int> iotResult = new Dictionary<string, int>();
  1038. iotResult.Add("tLesson", 0);
  1039. iotResult.Add("tGreen", 0);
  1040. Dictionary<string, TmidStics> iotDic = await GetTmidIotCore(tmids.ToList(), dateFromStr, dateToStr, "month");
  1041. foreach (KeyValuePair<string, TmidStics> iot in iotDic)
  1042. {
  1043. string tid = iot.Key;
  1044. TmidStics iotCalData = iot.Value;
  1045. if (iotCalData.iot.hiteach.month != null)
  1046. {
  1047. iotResult["tLesson"] += iotCalData.iot.hiteach.month.tLesson;
  1048. iotResult["tGreen"] += iotCalData.iot.hiteach.month.tGreen;
  1049. }
  1050. }
  1051. return new { dateFrom = dateFromStr, dateTo = dateToStr, tmids, tmid, sch, geo, iot = iotResult };
  1052. }
  1053. //取得TMID服務授權週期
  1054. public async Task<List<object>> getTMIDAuthService(CosmosClient cosmosClientCsv2, string tmid, string prodCode, bool validFlg)
  1055. {
  1056. long now = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
  1057. var qryOption = new QueryRequestOptions() { PartitionKey = new PartitionKey("servicePeriod") };
  1058. string whereSql = $"c.saleClient.tmid = '{tmid}'";
  1059. if (!string.IsNullOrWhiteSpace(prodCode)) whereSql += $" AND c.prodCode = '{prodCode}'";
  1060. if (validFlg) whereSql += $" AND c.startDate <= {now} AND {now} <= c.endDate";
  1061. string sql = $"SELECT c.id, c.prodCode, c.type, c.startDate, c.endDate, c.number, c.unit, c.aprule FROM c WHERE {whereSql}";
  1062. var client = cosmosClientCsv2.GetContainer("Habb", "Auth");
  1063. var result = new List<object>();
  1064. await foreach (var item in client.GetItemQueryStreamIteratorSql(queryText: sql, requestOptions: qryOption))
  1065. {
  1066. var json = await JsonDocument.ParseAsync(item.Content);
  1067. if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
  1068. {
  1069. foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
  1070. {
  1071. result.Add(
  1072. new
  1073. {
  1074. id = obj.GetProperty("id").GetString(),
  1075. prodCode = obj.GetProperty("prodCode").GetString(),
  1076. type = obj.GetProperty("type").GetInt32(),
  1077. startDate = obj.GetProperty("startDate").GetInt64(),
  1078. endDate = obj.GetProperty("endDate").GetInt64(),
  1079. number = obj.GetProperty("number").GetInt32(),
  1080. aprule = obj.GetProperty("aprule")
  1081. });
  1082. }
  1083. }
  1084. }
  1085. return result;
  1086. }
  1087. //取得TMID購買紀錄
  1088. public async Task<List<Ies5OrderHis>> getTMIDAuthOrder(CosmosClient cosmosClientCsv2, string tmid, string prodCode)
  1089. {
  1090. SortedDictionary<string, Ies5OrderHis> OrderDic = new SortedDictionary<string, Ies5OrderHis>();
  1091. var qryOption = new QueryRequestOptions() { PartitionKey = new PartitionKey("order") };
  1092. //服務 ※序號、硬體 不列入購買紀錄
  1093. string strQueryV = $"SELECT * FROM c WHERE IS_DEFINED(c.saleClient.tmid) AND c.saleClient.tmid = '{tmid}' AND c.prodType = 'service'";
  1094. if (!string.IsNullOrWhiteSpace(prodCode))
  1095. {
  1096. strQueryV += $" AND c.prodCode = '{prodCode}'";
  1097. }
  1098. await foreach (OrderHisService orderService in cosmosClientCsv2.GetContainer("Habb", "Auth").GetItemQueryIteratorSql<OrderHisService>(strQueryV, null, qryOption))
  1099. {
  1100. Ies5OrderHisService ies5OrderVRow = new Ies5OrderHisService();
  1101. ies5OrderVRow.prodCode = orderService.prodCode;
  1102. ies5OrderVRow.type = (orderService.contract.Equals(1)) ? "C" : (orderService.contract.Equals(2)) ? "G" : "N"; //授權方式 [FROM]contract契約型態 0:新約 1:續約 2:變更 [TO]type N:新約 C:續約 G:變更
  1103. ies5OrderVRow.sdate = orderService.startDate;
  1104. ies5OrderVRow.edate = orderService.endDate;
  1105. ies5OrderVRow.number = orderService.number;
  1106. ies5OrderVRow.unit = orderService.unit;
  1107. //加入Order字典
  1108. string OrderID = orderService.orderinfo.orderid.ToString();
  1109. long OrderDate = orderService.orderinfo.createDate;
  1110. if (OrderDic.ContainsKey(OrderID))
  1111. {
  1112. OrderDic[OrderID].service.Add(ies5OrderVRow);
  1113. }
  1114. else
  1115. {
  1116. Ies5OrderHis ies5OrderHisNew = new Ies5OrderHis();
  1117. ies5OrderHisNew.id = OrderID;
  1118. ies5OrderHisNew.date = OrderDate;
  1119. ies5OrderHisNew.service.Add(ies5OrderVRow);
  1120. OrderDic.Add(OrderID, ies5OrderHisNew);
  1121. }
  1122. }
  1123. //輸出項
  1124. List<Ies5OrderHis> Result = new List<Ies5OrderHis>();
  1125. foreach (KeyValuePair<string, Ies5OrderHis> item in OrderDic)
  1126. {
  1127. Result.Add(item.Value);
  1128. }
  1129. return Result;
  1130. }
  1131. //Tool
  1132. //資料遮罩
  1133. ///規則:
  1134. ///1.手機、電話:隱藏後4碼
  1135. ///2.Mail:隱藏@前資料
  1136. ///3.姓名:只顯示第一個字元
  1137. ///4.身分證、護照:隱藏後4碼
  1138. public string GenDataMask(string data, string type)
  1139. {
  1140. int length = 0;
  1141. string subString = string.Empty;
  1142. if (!string.IsNullOrWhiteSpace(data))
  1143. {
  1144. switch (type)
  1145. {
  1146. case "mobile":
  1147. case "id":
  1148. length = (data.Length > 4) ? 4 : data.Length;
  1149. subString = data.Substring(data.Length - length, length);
  1150. data = data.Replace(subString, "****");
  1151. break;
  1152. case "mail":
  1153. string[] dataList = data.Split("@");
  1154. subString = dataList.First();
  1155. data = data.Replace(subString, "****");
  1156. break;
  1157. case "name":
  1158. length = 2;
  1159. subString = data.Substring(data.Length - length, length);
  1160. data = data.Replace(subString, "〇〇");
  1161. break;
  1162. }
  1163. }
  1164. return data;
  1165. }
  1166. private async Task<List<TmidAnalysisCal>> getTMIDIotData(CosmosClient cosmosClientIes5, List<string> tmids, string toolType, string dateUnit, int year, int month, int day, long from, long to)
  1167. {
  1168. List<TmidAnalysisCal> result = new List<TmidAnalysisCal>();
  1169. List<string> calPropList = new List<string>() { "lessonRecord", "useIES", "useIES5Resource", "useWebIrs", "useDeviceIrs", "useHaboard", "useHita", "lessonLengMin", "lessonLeng0", "stuShow", "stuLessonLengMin", "tGreen", "tLesson", "lTypeCoop", "lTypeIact", "lTypeMis", "lTypeTst", "lTypeDif", "lTypeNone", "lessonCnt928", "lessonCntId", "lessonCntDevice", "lessonCntIdDevice", "mission", "missionFin", "item", "interact", "sendSok", "learnPeer", "learnCoop", "useWordCloud", "useClouDAS", "useGPT", "useIes5Test", "usePaperTest", "useExcelTest", "useScoreBoard", "learnParticipationCnt", "learnParticipationT", "coopMission", "coopWork", "coopContributionT", "peerAct", "peerStuParticipationT" }; //要計算的ProdAnalysis欄位列表
  1170. string tmidsListStr = JsonSerializer.Serialize(tmids);
  1171. string strQuery = $"SELECT * FROM c WHERE ARRAY_CONTAINS({tmidsListStr}, c.tmid, true) AND c.toolType = '{toolType}'";
  1172. var qryOption = new QueryRequestOptions() { PartitionKey = new PartitionKey("TmidAnalysis") };
  1173. if (!string.IsNullOrWhiteSpace(dateUnit)) strQuery += $" AND c.dateUnit = '{dateUnit}'";
  1174. if (year > 0) strQuery += $" AND c.year = {year}";
  1175. if (month > 0) strQuery += $" AND c.month = {month}";
  1176. if (day > 0) strQuery += $" AND c.day = {day}";
  1177. if (from > 0) strQuery += $" AND c.dateTime >= {from}";
  1178. if (to > 0) strQuery += $" AND c.dateTime <= {to}";
  1179. await foreach (TmidAnalysisCosmos tmidAnalysis in cosmosClientIes5.GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIteratorSql<TmidAnalysisCosmos>(strQuery, null, qryOption))
  1180. {
  1181. //特殊修正
  1182. tmidAnalysis.lTypeNone = ((tmidAnalysis.lTypeNone - tmidAnalysis.lessonLeng0) < 0) ? 0 : tmidAnalysis.lTypeNone - tmidAnalysis.lessonLeng0; //無學習型態數值須扣除未上課
  1183. //一般項
  1184. TmidAnalysisCal tmidAnalysisCalNow = result.Where(t => t.tmid.Equals(tmidAnalysis.tmid)).FirstOrDefault();
  1185. if(tmidAnalysisCalNow == null)
  1186. {
  1187. TmidAnalysisCal tmpTmidAnalysisCal = new TmidAnalysisCal();
  1188. tmpTmidAnalysisCal.tmid = tmidAnalysis.tmid;
  1189. result.Add(tmpTmidAnalysisCal);
  1190. tmidAnalysisCalNow = result.Where(t => t.tmid.Equals(tmidAnalysis.tmid)).FirstOrDefault();
  1191. }
  1192. tmidAnalysisCalNow.dateUnit = tmidAnalysis.dateUnit;
  1193. tmidAnalysisCalNow.toolType = tmidAnalysis.toolType;
  1194. tmidAnalysisCalNow.date = tmidAnalysis.date;
  1195. if (tmidAnalysis.year > 0) tmidAnalysisCalNow.year = tmidAnalysis.year;
  1196. if (tmidAnalysis.month > 0) tmidAnalysisCalNow.month = tmidAnalysis.month;
  1197. if (tmidAnalysis.day > 0) tmidAnalysisCalNow.day = tmidAnalysis.day;
  1198. if (tmidAnalysisCalNow.from.Equals(0) || tmidAnalysis.dateTime <= tmidAnalysisCalNow.from) tmidAnalysisCalNow.from = tmidAnalysis.dateTime;
  1199. if (tmidAnalysisCalNow.to.Equals(0) || tmidAnalysis.dateTime >= tmidAnalysisCalNow.to) tmidAnalysisCalNow.to = tmidAnalysis.dateTime;
  1200. tmidAnalysisCalNow.dateList.Add(tmidAnalysis.date);
  1201. //統計項
  1202. foreach (PropertyInfo propertyInfo in tmidAnalysis.GetType().GetProperties()) //累加項目
  1203. {
  1204. if (calPropList.Contains(propertyInfo.Name))
  1205. {
  1206. var propType = propertyInfo.PropertyType;
  1207. var valNow = propertyInfo.GetValue(tmidAnalysisCalNow);
  1208. var valTodo = tmidAnalysis.GetType().GetProperty(propertyInfo.Name).GetValue(tmidAnalysis);
  1209. if (propType.Equals(typeof(long))) propertyInfo.SetValue(tmidAnalysisCalNow, Convert.ToInt64(valNow.ToString(), 10) + Convert.ToInt64(valTodo.ToString(), 10));
  1210. else propertyInfo.SetValue(tmidAnalysisCalNow, Convert.ToInt32(valNow.ToString(), 10) + Convert.ToInt32(valTodo.ToString(), 10));
  1211. }
  1212. }
  1213. tmidAnalysisCalNow.deviceList = tmidAnalysisCalNow.deviceList.Union(tmidAnalysis.deviceList).ToList();
  1214. tmidAnalysisCalNow.deviceCnt = tmidAnalysisCalNow.deviceList.Count;
  1215. tmidAnalysisCalNow.deviceNoAuthList = tmidAnalysisCalNow.deviceNoAuthList.Union(tmidAnalysis.deviceNoAuthList).ToList();
  1216. tmidAnalysisCalNow.deviceNoAuth = tmidAnalysisCalNow.deviceNoAuthList.Count;
  1217. tmidAnalysisCalNow.deviceAuthList = tmidAnalysisCalNow.deviceAuthList.Union(tmidAnalysis.deviceAuthList).ToList();
  1218. tmidAnalysisCalNow.deviceAuth = tmidAnalysisCalNow.deviceAuthList.Count;
  1219. tmidAnalysisCalNow.tmidList = tmidAnalysisCalNow.tmidList.Union(tmidAnalysis.tmidList).ToList();
  1220. tmidAnalysisCalNow.tmidCnt = tmidAnalysisCalNow.tmidList.Count;
  1221. tmidAnalysisCalNow.verList = tmidAnalysisCalNow.verList.Union(tmidAnalysis.verList).ToList();
  1222. decimal learnParticipationTmp = (tmidAnalysisCalNow.learnParticipationCnt > 0) ? (decimal)tmidAnalysisCalNow.learnParticipationT / (decimal)tmidAnalysisCalNow.learnParticipationCnt : 0;
  1223. tmidAnalysisCalNow.learnParticipation = Math.Round(learnParticipationTmp, 2); //學習參與度指數(平均)
  1224. }
  1225. return result;
  1226. }
  1227. //Model
  1228. //TMID統計 基本資訊
  1229. private class TmidStics
  1230. {
  1231. public string id { get; set; }
  1232. public string name { get; set; }
  1233. public string picture { get; set; }
  1234. public string mobile { get; set; }
  1235. public string mail { get; set; }
  1236. public string country { get; set; }
  1237. public string province { get; set; }
  1238. public string city { get; set; }
  1239. public string dist { get; set; }
  1240. public string schoolCode { get; set; }
  1241. public string schoolCodeW { get; set; }
  1242. public string lang { get; set; }
  1243. public string unitType { get; set; } //1:基礎教育機構(K-小學) 2:中等教育機構(國中、高中/職) 3:高等教育機構 4:政府單位機構 5:NGO機構 6:企業機構 7:其他 8:學前教育 9:特殊教育
  1244. public string unitName { get; set; }
  1245. public string jobTitle { get; set; }
  1246. public TmidSticsIes5 ies5 { get; set; } //IES統計資料
  1247. public TmidPoints points { get; set; }
  1248. public TmidSokrates sokrates { get; set; }
  1249. public TmidBenefits benefits { get; set; }
  1250. public List<TmidCoupon> coupons { get; set; } = new();
  1251. public List<TmidLoginTime> login { get; set; } = new();
  1252. public List<object> prod { get; set; } = new();
  1253. public TmidIot iot { get; set; }
  1254. public bool wechat { get; set; }
  1255. public bool facebook { get; set; }
  1256. public bool google { get; set; }
  1257. public bool ding { get; set; }
  1258. public bool apple { get; set; }
  1259. public bool educloudtw { get; set; }
  1260. public long ts { get; set; } //資料最終變更時間
  1261. public string schoolId { get; set; } //歸屬學校資訊
  1262. }
  1263. //TMID統計 IES5資訊
  1264. private class TmidSticsIes5
  1265. {
  1266. public long usedSize { get; set; } //已使用的存儲空間(Byte)
  1267. public long teachSize { get; set; } //分配給教師的空間(Byte)
  1268. public long totalSize { get; set; } //總空間(Byte)
  1269. public long surplusSize { get; set; } //剩余的空間(Byte)
  1270. public List<TmidSticsIes5School> schools { get; set; } = new(); //各學校資料
  1271. public int resCount { get; set; } //教材數
  1272. public int itemCount { get; set; } //題目數
  1273. public int paperCount { get; set; } //試卷數
  1274. }
  1275. private class TmidSticsIes5School
  1276. {
  1277. public string schoolId { get; set; }
  1278. public string name { get; set; }
  1279. public string region { get; set; }
  1280. public string province { get; set; }
  1281. public string city { get; set; }
  1282. public string dist { get; set; }
  1283. public object size { get; set; } = new();
  1284. public int courseCnt { get; set; }
  1285. public bool defaultSchool { get; set; }
  1286. }
  1287. private class TmidPoints
  1288. {
  1289. public int points { get; set; } = 0; //累積的點數(只加不減)
  1290. public int balance { get; set; } = 0; //可用的點數
  1291. public int level { get; set; } = 0; //等級
  1292. }
  1293. private class TmidCoupon
  1294. {
  1295. public string code { get; set; }
  1296. public long exchange { get; set; }
  1297. }
  1298. private class TmidLoginTime
  1299. {
  1300. public string product { get; set; }
  1301. public long time { get; set; }
  1302. }
  1303. private class TmidSokrates
  1304. {
  1305. public object hiteach_data { get; set; }
  1306. public object user_channels { get; set; }
  1307. }
  1308. public class TmidSokratesHiteach
  1309. {
  1310. public TmidSokratesHiteachItem total { get; set; }
  1311. public TmidSokratesHiteachItem this_year { get; set; }
  1312. public TmidSokratesHiteachItem this_month { get; set; }
  1313. public TmidSokratesHiteachItem this_week { get; set; }
  1314. }
  1315. public class TmidSokratesHiteachItem
  1316. {
  1317. public string start_date { get; set; } = "";
  1318. public string end_date { get; set; } = "";
  1319. public string t_data { get; set; } = "0";
  1320. public string duration { get; set; } = "0";
  1321. public string attendance { get; set; } = "0";
  1322. public string interaction { get; set; } = "0";
  1323. public string t_green { get; set; } = "0";
  1324. public string learning_duration { get; set; } = "0";
  1325. public string all_total { get; set; } = "0";
  1326. public string double_green_light { get; set; } = "0";
  1327. public string public_count { get; set; } = "0";
  1328. public string material_count { get; set; } = "0";
  1329. public string personal_comment { get; set; } = "0";
  1330. public string comment_count { get; set; } = "0";
  1331. public string watchHistory { get; set; } = "0";
  1332. public string sokrates_summary { get; set; } = "0";
  1333. }
  1334. private class TmidBenefits
  1335. {
  1336. public List<object> hiteach { get; set; }
  1337. public List<object> hiteachcc { get; set; }
  1338. }
  1339. private class TmidIot
  1340. {
  1341. public TmidIotYMD hiteach { get; set; } = new();
  1342. public TmidIotYMD hiteachcc { get; set; } = new();
  1343. }
  1344. private class TmidIotYMD
  1345. {
  1346. public TmidAnalysisCal year { get; set; }
  1347. public TmidAnalysisCal month { get; set; }
  1348. public TmidAnalysisCal day { get; set; }
  1349. }
  1350. private class TmidIotSchool
  1351. {
  1352. public string id { get; set; }
  1353. public string name { get; set; }
  1354. public string country { get; set; }
  1355. public string province { get; set; }
  1356. public string city { get; set; }
  1357. public string dist { get; set; }
  1358. }
  1359. private class TmidIotProdCnt
  1360. {
  1361. public string id { get; set; }
  1362. public string name { get; set; }
  1363. public string schid { get; set; }
  1364. public int hiteach { get; set; }
  1365. public int hiteachcc { get; set; }
  1366. public int hita { get; set; }
  1367. public int ies5 { get; set; }
  1368. public int account { get; set; }
  1369. public int sokrates { get; set; }
  1370. public int sokapp { get; set; }
  1371. public int irs { get; set; }
  1372. public int tLesson { get; set; }
  1373. public int tGreen { get; set; }
  1374. }
  1375. private class TmidIotProdCntGeo : TmidIotProdCnt
  1376. {
  1377. public string countryId { get; set; }
  1378. public string countryName { get; set; }
  1379. public string provinceId { get; set; }
  1380. public string provinceName { get; set; }
  1381. public string cityName { get; set; }
  1382. public string cityId { get; set; }
  1383. public string distId { get; set; }
  1384. public string distName { get; set; }
  1385. public List<string> tmids { get; set; } = new();
  1386. }
  1387. //[API輸出] 訂單履歷
  1388. public class Ies5OrderHis
  1389. {
  1390. public Ies5OrderHis()
  1391. {
  1392. service = new List<Ies5OrderHisService>();
  1393. }
  1394. public string id { get; set; }
  1395. public long date { get; set; }
  1396. public List<Ies5OrderHisService> service { get; set; } = new ();
  1397. }
  1398. //[API輸出] 訂單履歷.服務型產品
  1399. public class Ies5OrderHisService
  1400. {
  1401. public string prodCode { get; set; } //產品代碼
  1402. public string type { get; set; } //授權方式 N:新約 C:續約
  1403. public long sdate { get; set; } //授權起始時間
  1404. public long edate { get; set; } //授權終止時間
  1405. public int number { get; set; } //購買數量
  1406. public string unit { get; set; } //購買單位 無單位者為null
  1407. }
  1408. //[承接DB] DB: Habb.Auth
  1409. //[承接DB] 訂單履歷基本Class
  1410. public class OrderHisBase
  1411. {
  1412. public string id { get; set; } //OPID
  1413. public OrderHisOrderInfo orderinfo { get; set; } //訂單資訊
  1414. public string prodCode { get; set; } //產品代碼
  1415. public SerialSaleClient saleClient { get; set; } = null; //銷售終端
  1416. public string prodType { get; set; } //產品類型 serial:序號 service:服務 hard:硬體
  1417. public string dataType { get; set; } //資料類型
  1418. public long operationTime { get; set; } //最新資料變更時間戳記
  1419. public int ttl { get; set; } = -1; //過期刪除秒數
  1420. }
  1421. //[承接DB] 訂單履歷基本Class.銷售終端
  1422. public class SerialSaleClient
  1423. {
  1424. public string name { get; set; } //[String]銷售終端姓名
  1425. public string schoolCode { get; set; } = null; //[String]銷售終端學校代碼
  1426. public string clientId { get; set; } = null; //[String]銷售終端客戶ID
  1427. public string tmid { get; set; } = null; //[String]TMID
  1428. public string type { get; set; } //[String]銷售終端資料類型 school:學校 client:經銷商客戶
  1429. public string countryId { get; set; } //[String]國家代碼
  1430. public string provinceId { get; set; } //[String]省代碼
  1431. public string cityId { get; set; } //[String]市代碼
  1432. public string schoolShortCode { get; set; } //[String]學校簡碼
  1433. public string districtId { get; set; } //[String]區代碼
  1434. public string dataCenter { get; set; } //[String]數據中心
  1435. }
  1436. //[承接DB] 訂單履歷基本Class.訂單資訊
  1437. public class OrderHisOrderInfo
  1438. {
  1439. public string orderid { get; set; } //[String]訂單編號
  1440. public int orderAudit { get; set; } //[Int]訂單審核狀態 0:待審, 1:通過, 2:否決, 3:問題
  1441. public int orderProperty { get; set; } //[Int]訂單類型 0:銷售,1:展示申請 2:內部申請
  1442. public long createDate { get; set; } //訂單創建時間
  1443. }
  1444. //[承接DB] 訂單履歷 服務類
  1445. public class OrderHisService : OrderHisBase
  1446. {
  1447. public int type { get; set; } //[Int]授權類型 0:銷售 1:試用
  1448. public int contract { get; set; } //[Int]契約型態 0:新約 1:續約
  1449. public long startDate { get; set; } //[long]授權起始日期 Timestamp(UTC)
  1450. public long endDate { get; set; } //[long]授權終止日期 Timestamp(UTC)
  1451. public int number { get; set; } //[Int]數量
  1452. public string unit { get; set; } //[String]單位 (無者為空)
  1453. }
  1454. //雲端服務ClientId列表
  1455. private readonly Dictionary<string, string> _dicClientIds = new()
  1456. {
  1457. { "917d02f2-5b91-404e-a71d-7bdd926ddd81", "HiTeach" },
  1458. { "c5328340-b8eb-4489-8650-8c8862d7acfe", "HiTeach" },
  1459. { "118d2d4d-32a3-44c0-808a-792ca73d3706", "HiTeachCC" },
  1460. { "227082f4-8db0-4517-b281-93dba9428bc7", "HiTeachCC" },
  1461. { "371a99aa-7efd-4c3a-90a8-95b7db4f42c0", "HiTA" },
  1462. { "0ed38cde-e7fe-4fa6-9eaa-33ad404eb532", "HiTA" },
  1463. { "531fecd1-b1a5-469a-93ca-7984e1d392f2", "IES5" },
  1464. { "c7317f88-7cea-4e48-ac57-a16071f7b884", "IES5" },
  1465. { "c8de822b-3fcf-4831-adba-cdd14653bf7f", "Account" },
  1466. { "516148eb-6a38-4657-ba98-a3699061937f", "Account" },
  1467. { "d7193896-9b12-4046-ad44-c991dd48cc39", "Sokrates" },
  1468. { "59009e38-6e30-4116-814b-7605939edc47", "Sokrates" },
  1469. { "626c7285-15aa-4abe-8c0d-2c5ff1381538", "SokAPP" },
  1470. { "5bcc16a5-7d20-4cc4-b5c2-8ed0416f32b6", "SokAPP" },
  1471. { "044482b5-d024-4f23-9b55-906884243405", "IRS" },
  1472. { "5e27b7e3-b36c-4ce9-b838-e94fd0cea080", "IRS" }
  1473. };
  1474. //TMID IOT date
  1475. public class tmidIotDate
  1476. {
  1477. public string dateUnit { get; set; } //[string]日期單位:年月日 year, month, day
  1478. public int year { get; set; } //[Int]年
  1479. public int month { get; set; } //[Int]月
  1480. public int day { get; set; } //[Int]日
  1481. public long from { get; set; } //[long]UTC timestamp 起始日
  1482. public long to { get; set; } //[long]UTC timestamp 終止日
  1483. }
  1484. public class TmidAnalysisCal : TmidAnalysisCosmos
  1485. {
  1486. public long from { get; set; } //[long]UTC timestamp 起始日
  1487. public long to { get; set; } //[long]UTC timestamp 終止日
  1488. public List<string> dateList { get; set; } = new();
  1489. }
  1490. private class DateFromTo
  1491. {
  1492. public string dateFrom { get; set; }
  1493. public string dateTo { get; set; }
  1494. }
  1495. }
  1496. }