TEAMModelOS/TEAMModelOS.FunctionV4/HttpTrigger/IESHttpTrigger.cs

using Azure.Cosmos;
using Azure.Storage.Blobs.Models;
using HTEXLib.COMM.Helpers;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Reflection;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Models.Cosmos.Teacher;
using TEAMModelOS.SDK.Models.Table;
using static TEAMModelOS.SDK.Models.Teacher;

namespace TEAMModelOS.FunctionV4.HttpTrigger
{
    public class IESHttpTrigger
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        public IESHttpTrigger(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage
      , AzureRedisFactory azureRedis)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
        }
        /// <summary>
        /// 数据推送接口
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [Function("system-info-function")]
        public async Task<HttpResponseData> SystemInfo([HttpTrigger(AuthorizationLevel.Anonymous, "get", Route = null)] HttpRequestData req)
        {
            var response = req.CreateResponse(HttpStatusCode.OK);
            Type attr = this.GetType();
            string currentDirectory = Path.GetDirectoryName(attr.Assembly.Location);
            Assembly assembly = Assembly.LoadFrom($"{currentDirectory}\\TEAMModelOS.FunctionV4.dll");
            var description = assembly.GetCustomAttribute<AssemblyDescriptionAttribute>().Description;
            //var v1 = Assembly.GetEntryAssembly().GetName().Version;
            //var v2 = Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyFileVersionAttribute>().Version;
            // var description = Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyDescriptionAttribute>().Description;
            var version = Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyFileVersionAttribute>().Version;
            long nowtime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
            //Console.WriteLine($"Assembly.GetEntryAssembly().GetName().Version: " +

            //                  $"{Assembly.GetEntryAssembly().GetName().Version}");5.2107.12.1

            //Console.WriteLine($"Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyFileVersionAttribute>().Version:" +
            //                  $"{Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyFileVersionAttribute>().Version}");5.2107.12.1

            //Console.WriteLine($"Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyInformationalVersionAttribute>().InformationalVersion:" +

            //                  $"{Assembly.GetEntryAssembly().GetCustomAttribute<AssemblyInformationalVersionAttribute>().InformationalVersion}");5.2107.12
            await response.WriteAsJsonAsync(new { version, description, nowtime });
            return response;


        }
        /// <summary>
        /// 数据推送接口
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [Function("knowledge-change")]
        public async Task<HttpResponseData> KnowledgeChange([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
        {
            var response = req.CreateResponse(HttpStatusCode.OK);
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            var json = JsonDocument.Parse(data).RootElement;
            List<OldNew> old_new = null;
            string school = null;
            if (json.TryGetProperty("school", out JsonElement _school))
            {
                school = _school.GetString();
            }
            if (json.TryGetProperty("old_new", out JsonElement _old_new))
            {
                old_new = _old_new.ToObject<List<OldNew>>();
            }
            if (old_new.IsNotEmpty() && !string.IsNullOrWhiteSpace(school))
            {
                foreach (var on in old_new)
                {
                    List<ItemInfo> items = new List<ItemInfo>();
                    string sql = $"select value(c) from c    where array_contains(c.knowledge,'{on._old}') ";
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<ItemInfo>
                        (queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Item-{_school}") }))
                    {
                        items.Add(item);
                    }

                    items.ForEach(item =>
                    {
                        //修改知识点
                        if (!string.IsNullOrEmpty(on._new))
                        {
                            for (int i = 0; i < item.knowledge.Count; i++)
                            {
                                if (item.knowledge[i].Equals(on._old))
                                {
                                    item.knowledge[i] = on._new;
                                }
                            }
                        }
                        else
                        {
                            //表示删除知识点
                            item.knowledge.RemoveAll(x => x.Equals(on._old));
                        }
                    });
                    foreach (var item in items)
                    {
                        ItemBlob itemBlob = null;
                        try
                        {
                            BlobDownloadInfo blobDownloadResult = await _azureStorage.GetBlobContainerClient($"{school}").GetBlobClient($"/item/{item.id}/{item.id}.json").DownloadAsync();
                            if (blobDownloadResult != null)
                            {
                                var blob = JsonDocument.Parse(blobDownloadResult.Content);
                                itemBlob = blob.RootElement.ToObject<ItemBlob>();
                                itemBlob.exercise.knowledge = item.knowledge;
                                await _azureStorage.UploadFileByContainer($"{school}", itemBlob.ToJsonString(), "item", $"{item.id}/{item.id}.json", true);
                            }
                        }
                        catch (Exception ex)
                        {
                            itemBlob = null;
                        }
                        await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync(item, item.id, new PartitionKey(item.code));
                    }
                }
            }
            await response.WriteAsJsonAsync(new { data = json });
            return response;
        }

        /// <summary>
        /// 在线人数记录
        /// </summary>
        /// <param name="msg"></param>
        /// <returns></returns>
        [Function("onlin-record")]
        public async Task<HttpResponseData> OnlinRecord([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequestData req)
        {
            var response = req.CreateResponse(HttpStatusCode.OK);
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            var json = JsonDocument.Parse(data).RootElement;

            string school = null;
            string scope = null;
            string id = null;
            string ip = null;
            int expire = 1;
            if (json.TryGetProperty("school", out JsonElement _school))
            {
                school = _school.GetString();
            }

            if (json.TryGetProperty("scope", out JsonElement _scope))
            {
                scope = _scope.GetString();
            }

            if (json.TryGetProperty("id", out JsonElement _id))
            {
                id = _id.GetString();
            }

            if (json.TryGetProperty("ip", out JsonElement _ip))
            {
                ip = _ip.GetString();
            }

            if (json.TryGetProperty("expire", out JsonElement _expire))
            {
                expire = _expire.GetInt32();
            }

            var table = _azureStorage.GetCloudTableClient().GetTableReference("IESLogin");
            var cosmosClient = _azureCosmos.GetCosmosClient();

            DateTimeOffset dateTime = DateTimeOffset.UtcNow;
            var dateHour = dateTime.ToString("yyyyMMddHH"); //获取当天的小时
            var dateDay = dateTime.ToString("yyyyMMdd"); //获取当天的日期
            var dateMonth = dateTime.ToString("yyyyMM");//获取当月的日期
            var currentHour = dateTime.Hour;
            var currentDay = dateTime.Day;
            long Expire = dateTime.AddHours(expire).ToUnixTimeMilliseconds();  //token到期时间
            long now = dateTime.ToUnixTimeMilliseconds();   //时间戳

            DateTime hour = DateTime.UtcNow.AddHours(25);   //25小时到期
            DateTime month = DateTime.UtcNow.AddDays(32);   //一个月到期

            switch (scope)
            {
                case "teacher":
                    try
                    {
                        Teacher teacher = await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
                        teacher.loginInfos = new List<LoginInfo>() { new LoginInfo { expire = Expire, ip = ip, time = now } };
                        await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey("Base"));
                    }
                    catch { }
                    break;
                case "student":
                    try
                    {
                        Student student = await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReadItemAsync<Student>(id, new PartitionKey($"Base-{school}"));
                        student.loginInfos = new List<LoginInfo>() { new LoginInfo { expire = Expire, ip = ip, time = now } };
                        await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReplaceItemAsync<Student>(student, student.id, new PartitionKey("Base"));
                    }
                    catch { }
                    break;
                case "tmduser":
                    try
                    {
                        TmdUser tmdUser = await cosmosClient.GetContainer("TEAMModelOS", "Student").ReadItemAsync<TmdUser>(id, new PartitionKey("Base"));
                        tmdUser.loginInfos = new List<LoginInfo>() { new LoginInfo { expire = Expire, ip = ip, time = now } };
                        await cosmosClient.GetContainer("TEAMModelOS", "Teacher").ReplaceItemAsync<TmdUser>(tmdUser, tmdUser.id, new PartitionKey("Base"));
                    }
                    catch { }
                    break;
            }

            await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Login:IES:{scope}:{dateDay}", $"{currentHour}", 1);//一天24小时
            await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Login:IES:{scope}:{dateMonth}", $"{currentDay}", 1); //当天的累计

            var resDay = await _azureRedis.GetRedisClient(8).KeyTimeToLiveAsync($"Login:IES:{scope}:{dateDay}");
            if (resDay == null)
            {
                await _azureRedis.GetRedisClient(8).KeyExpireAsync($"Login:IES:{scope}:{dateDay}", hour);  //设置到期时间
            }

            var rspMonth = await _azureRedis.GetRedisClient(8).KeyTimeToLiveAsync($"Login:IES:{scope}:{dateMonth}");
            if (rspMonth == null)
            {
                await _azureRedis.GetRedisClient(8).KeyExpireAsync($"Login:IES:{scope}:{dateMonth}", month);  //设置到期时间
            }

            ////查询Redis是否有值
            //var dayCnt = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Login:IES:{scope}:{dateDay}");
            //List<dynamic> dayCounts = new();
            //if (dayCnt != null && dayCnt.Length > 0)
            //{
            //    foreach (var hourCnt in dayCnt)
            //    {
            //        dayCounts.Add(new { code = hourCnt.Element.ToString(), count = (int)hourCnt.Score });
            //    }
            //}

            //var monthCnt = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Login:IES:{scope}:{dateMonth}");
            //List<dynamic> monthCounts = new();
            //if (monthCnt != null && monthCnt.Length > 0)
            //{
            //    foreach (var mCnt in monthCnt)
            //    {
            //        monthCounts.Add(new { code = mCnt.Element.ToString(), count = (int)mCnt.Score });
            //    }
            //}

            //保存当天每小时的峰值
            List<HourLogin> hourLogins = await table.QueryWhereString<HourLogin>($"PartitionKey eq 'HourLogin' and RowKey eq '{dateHour}'");
            if (hourLogins.Count > 0)
            {
                foreach (var hourLogin in hourLogins)
                {
                    //hourLogin.Hour = currentHour;
                    if (scope.Equals("teacher"))
                        hourLogin.Teacher += 1;
                    else if (scope.Equals("student"))
                        hourLogin.Student += 1;
                    else
                        hourLogin.TmdUser += 1;
                }

                try
                {
                    await table.SaveOrUpdateAll(hourLogins);
                }
                catch { }
            }
            else
            {
                HourLogin hourLogin = new() { PartitionKey = $"HourLogin", RowKey = dateHour, Hour = currentHour };
                if (scope.Equals("teacher"))
                {
                    hourLogin.Teacher = 1;
                    hourLogin.Student = 0;
                    hourLogin.TmdUser = 0;
                }
                else if (scope.Equals("student"))
                {
                    hourLogin.Teacher = 0;
                    hourLogin.Student = 1;
                    hourLogin.TmdUser = 0;
                }
                else
                {
                    hourLogin.Teacher = 0;
                    hourLogin.Student = 0;
                    hourLogin.TmdUser = 1;
                }
                try
                {
                    await table.SaveOrUpdate<HourLogin>(hourLogin);//保存在线数据
                }
                catch { }
            }

            //保存当天的峰值
            List<DayLogin> dayLogins = await table.QueryWhereString<DayLogin>($"PartitionKey eq 'DayLogin' and RowKey eq '{dateDay}'");
            if (dayLogins.Count > 0)
            {
                foreach (var dayLogin in dayLogins)
                {
                    //dayLogin.Day = currentDay;
                    if (scope.Equals("teacher"))
                        dayLogin.Teacher += 1;
                    else if (scope.Equals("student"))
                        dayLogin.Student += 1;
                    else
                        dayLogin.TmdUser += 1;
                }

                try
                {
                    await table.SaveOrUpdateAll(dayLogins);
                }
                catch { }
            }
            else
            {
                //保存当月每天的峰值
                DayLogin dayLogin = new() { PartitionKey = $"DayLogin", RowKey = dateDay, Day = currentDay };
                if (scope.Equals("teacher"))
                {
                    dayLogin.Teacher = 1;
                    dayLogin.Student = 0;
                    dayLogin.TmdUser = 0;
                }
                else if (scope.Equals("student"))
                {
                    dayLogin.Teacher = 0;
                    dayLogin.Student = 1;
                    dayLogin.TmdUser = 0;
                }
                else
                {
                    dayLogin.Teacher = 0;
                    dayLogin.Student = 0;
                    dayLogin.TmdUser = 1;
                }
                try
                {
                    await table.SaveOrUpdate<DayLogin>(dayLogin);//保存当月每天在线数据
                }
                catch { }
            }

            if (!string.IsNullOrWhiteSpace(school))
            {
                await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Login:School:{school}:{scope}:{dateDay}", $"{currentHour}", 1);//当天当前小时在线人加1
                await _azureRedis.GetRedisClient(8).SortedSetIncrementAsync($"Login:School:{school}:{scope}:{dateMonth}", $"{currentDay}", 1); //当天的在线加1

                var reScDay = await _azureRedis.GetRedisClient(8).KeyTimeToLiveAsync($"Login:School:{school}:{scope}:{dateDay}");
                if (reScDay == null)
                {
                    await _azureRedis.GetRedisClient(8).KeyExpireAsync($"Login:School:{school}:{scope}:{dateDay}", hour);  //设置到期时间
                }

                var reScMonth = await _azureRedis.GetRedisClient(8).KeyTimeToLiveAsync($"Login:School:{school}:{scope}:{dateMonth}");
                if (reScMonth == null)
                {
                    await _azureRedis.GetRedisClient(8).KeyExpireAsync($"Login:School:{school}:{scope}:{dateMonth}", month);  //设置到期时间
                }

                ////查询Redis是否有值
                //var scDayCnt = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Login:School:{school}:{scope}:{dateDay}");
                //List<dynamic> scDayCounts = new();
                //if (scDayCnt != null && scDayCnt.Length > 0)
                //{
                //    foreach (var itemHour in scDayCnt)
                //    {
                //        scDayCounts.Add(new { code = itemHour.Element.ToString(), count = (int)itemHour.Score });
                //    }
                //}
                //var ScMonth = _azureRedis.GetRedisClient(8).SortedSetRangeByScoreWithScores($"Login:School:{school}:{scope}:{dateMonth}");
                //List<dynamic> scMonthCount = new();
                //if (ScMonth != null && ScMonth.Length > 0)
                //{
                //    foreach (var count in ScMonth)
                //    {
                //        scMonthCount.Add(new { code = count.Element.ToString(), count = (int)count.Score });
                //    }
                //}

                //保存学校当天每小时的
                List<HourLoginSchool> hourLoginSchools = await table.QueryWhereString<HourLoginSchool>($"PartitionKey eq 'HourLogin-{school}' and RowKey eq '{dateHour}'");
                if (hourLoginSchools.Count > 0)
                {
                    foreach (var hLoginSc in hourLoginSchools)
                    {
                        //hLoginSc.Hour = currentHour;
                        if (scope.Equals("teacher"))
                            hLoginSc.Teacher += 1;
                        else if (scope.Equals("student"))
                            hLoginSc.Student += 1;
                        else
                            hLoginSc.TmdUser += 1;
                    }

                    try
                    {
                        await table.SaveOrUpdateAll(hourLoginSchools);
                    }
                    catch { }
                }
                else
                {
                    //学校小时峰值
                    HourLoginSchool hourLoginSc = new() { PartitionKey = $"HourLogin-{school}", RowKey = dateHour, Hour = currentHour, School = school };
                    if (scope.Equals("teacher"))
                    {
                        hourLoginSc.Teacher = 1;
                        hourLoginSc.Student = 0;
                        hourLoginSc.TmdUser = 0;
                    }
                    else if (scope.Equals("student"))
                    {
                        hourLoginSc.Teacher = 0;
                        hourLoginSc.Student = 1;
                        hourLoginSc.TmdUser = 0;
                    }
                    else
                    {
                        hourLoginSc.Teacher = 0;
                        hourLoginSc.Student = 0;
                        hourLoginSc.TmdUser = 1;
                    }

                    try
                    {
                        await table.SaveOrUpdate<HourLoginSchool>(hourLoginSc);//保存在线数据
                    }
                    catch { }
                }

                //学校天峰值
                List<DayLoginSchool> DayLoginSchools = await table.QueryWhereString<DayLoginSchool>($"PartitionKey eq 'DayLogin-{school}' and RowKey eq '{dateDay}'");
                if (DayLoginSchools.Count > 0)
                {
                    foreach (var dLoginSc in DayLoginSchools)
                    {
                        //dLoginSc.Day = currentDay;
                        if (scope.Equals("teacher"))
                            dLoginSc.Teacher += 1;
                        else if (scope.Equals("student"))
                            dLoginSc.Student += 1;
                        else
                            dLoginSc.TmdUser += 1;
                    }

                    try
                    {
                        await table.SaveOrUpdateAll(DayLoginSchools);
                    }
                    catch { }
                }
                else
                {
                    //学校天峰值
                    DayLoginSchool dayLoginSc = new() { PartitionKey = $"DayLogin-{school}", RowKey = dateDay, Day = currentDay, School = school };
                    if (scope.Equals("teacher"))
                    {
                        dayLoginSc.Teacher = 1;
                        dayLoginSc.Student = 0;
                        dayLoginSc.TmdUser = 0;
                    }
                    else if (scope.Equals("student"))
                    {
                        dayLoginSc.Teacher = 0;
                        dayLoginSc.Student = 1;
                        dayLoginSc.TmdUser = 0;
                    }
                    else
                    {
                        dayLoginSc.Teacher = 0;
                        dayLoginSc.Student = 0;
                        dayLoginSc.TmdUser = 1;
                    }

                    try
                    {
                        await table.SaveOrUpdate<DayLoginSchool>(dayLoginSc);//保存在线数据
                    }
                    catch { }
                }
            }

            await response.WriteAsJsonAsync(new { data = json });
            return response;
        }
    }
}