TEAMModelOS/TEAMModelOS/Controllers/Common/ArtController.cs

using Azure.Cosmos;
using DinkToPdf.Contracts;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Filter;
using TEAMModelOS.Models;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Models.Cosmos.Common;

namespace TEAMModelOS.Controllers.Common
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]

    [Route("common/art")]
    [ApiController]
    public class ArtController : ControllerBase
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly SnowflakeId _snowflakeId;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly IConverter _converter;
        public IConfiguration _configuration { get; set; }
        private readonly CoreAPIHttpService _coreAPIHttpService;
        public ArtController(IConverter converter, CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, AzureServiceBusFactory serviceBus, SnowflakeId snowflakeId, DingDing dingDing,
           IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, IConfiguration configuration)
        {
            _coreAPIHttpService = coreAPIHttpService;
            _azureCosmos = azureCosmos;
            _serviceBus = serviceBus;
            _snowflakeId = snowflakeId;
            _dingDing = dingDing;
            _option = option?.Value;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _configuration = configuration;
            _converter = converter;
        }
        /// <summary>
        /// 保存艺术评价信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("save")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> Save(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("art", out JsonElement art)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
                ArtEvaluation ae = art.ToObject<ArtEvaluation>();
                string code = ae.school;
                ae.publish = 0;
                ae.ttl = -1;
                ae.progress = "going";
                if (!ae.owner.Equals("area"))
                {
                    ae.owner = "school";
                    ae.code = "Art-" + code;
                    ae.scope = "school";
                    long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                    ae.createTime = now;
                }
                if (string.IsNullOrEmpty(ae.id))
                {
                    ae.id = Guid.NewGuid().ToString();
                    await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(ae, new PartitionKey($"{ae.code}"));
                }
                else
                {                    
                    await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(ae, ae.id, new PartitionKey($"{ae.code}"));
                }
                return Ok(new { ae });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/save()\n{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500, msg = ex.Message });
            }

        }

        [ProducesDefaultResponseType]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("delete")]
        [Authorize(Roles = "IES")]
        public async Task<IActionResult> Delete(JsonElement request)
        {
            try
            {
                //object userScope = null;
                //object _standard = null;
                if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
                if (!request.TryGetProperty("code", out JsonElement code)) return BadRequest();
               /* string standard = null;
                HttpContext?.Items?.TryGetValue("Scope", out userScope);
                if (userScope != null && $"{userScope}".Equals(Constant.ScopeTeacher))
                {
                    HttpContext?.Items?.TryGetValue("Standard", out _standard);
                    standard = _standard != null && string.IsNullOrEmpty($"{userScope}") ? _standard.ToString() : null;
                }*/
                var (userid, _, _, school) = HttpContext.GetAuthTokenInfo();
                var client = _azureCosmos.GetCosmosClient();
                var sresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(id.ToString(), new PartitionKey($"Art-{code}"));
                if (sresponse.Status == 200)
                {
                    using var json = await JsonDocument.ParseAsync(sresponse.ContentStream);
                    ArtEvaluation art = json.ToObject<ArtEvaluation>();
                    //必须是本人或者这个学校的管理者才能删除
                    bool flag = false;
                    if (art.creatorId == userid)
                    {
                        flag = true;
                    }
                    else
                    {
                        if (art.scope == "school" && art.school.Equals(school))
                        {
                            flag = true;
                        }
                    }
                    /*try
                    {
                        (List<RMember> members, List<RGroupList> groups) = await GroupListService.GetMemberByListids(_coreAPIHttpService, client, _dingDing, null, art.school, null);
                        await StatisticsService.DoChange(new TeacherTrainChange
                        { standard = standard, tmdids = members.Select(x => x.id)?.ToList(), school = art.school, update = new HashSet<string> { StatisticsService.OfflineRecord }, statistics = 0 }, _azureCosmos);
                    }
                    catch (Exception ex)
                    {
                        await _dingDing.SendBotMsg($"OS，{_option.Location}，art/delete()ex\n{ex.Message}\n{ex.StackTrace},\n", GroupNames.醍摩豆服務運維群組);
                    }*/
                    if (flag)
                    {

                        art.status = 404;
                        foreach (var info in art.settings) {
                            /* if (info.TryGetProperty("examId", out JsonElement eId)) { 

                             }*/
                            foreach (var acs in info.task) {
                                if (!string.IsNullOrEmpty(acs.acId)) {
                                    if (acs.type.Equals("exam"))
                                    {
                                        Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(acs.acId, new PartitionKey($"Exam-{code}"));
                                        if (response.Status == 200)
                                        {
                                            ExamInfo data = JsonDocument.Parse(response.Content).RootElement.Deserialize<ExamInfo>();
                                            data.status = 404;
                                            await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Exam-{code}"));
                                        }
                                    }
                                    if (acs.type.Equals("survey"))
                                    {
                                        Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(acs.acId, new PartitionKey($"Survey-{code}"));
                                        if (response.Status == 200)
                                        {
                                            Survey data = JsonDocument.Parse(response.Content).RootElement.Deserialize<Survey>();
                                            data.status = 404;
                                            await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Survey-{code}"));
                                        }
                                    }
                                    if (acs.type.Equals("homework"))
                                    {
                                        Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(acs.acId, new PartitionKey($"Homework-{code}"));
                                        if (response.Status == 200)
                                        {
                                            Homework data = JsonDocument.Parse(response.Content).RootElement.Deserialize<Homework>();
                                            data.status = 404;
                                            await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Homework-{code}"));
                                        }
                                    }
                                }
                                
                            }
                        }
                        /*if (!string.IsNullOrEmpty(art.examId))
                        {
                            Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(art.examId, new PartitionKey($"Exam-{code}"));
                            if (response.Status == 200)
                            {
                                ExamLite data = JsonDocument.Parse(response.Content).RootElement.Deserialize<ExamLite>();
                                data.status = 404;
                                await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Exam-{code}"));
                            }
                        }
                        if (!string.IsNullOrEmpty(art.surveyId))
                        {
                            Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(art.surveyId, new PartitionKey($"Survey-{code}"));
                            if (response.Status == 200)
                            {
                                Survey data = JsonDocument.Parse(response.Content).RootElement.Deserialize<Survey>();
                                data.status = 404;
                                await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Survey-{code}"));
                            }
                        }
                        if (!string.IsNullOrEmpty(art.workId))
                        {
                            Azure.Response response = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(art.workId, new PartitionKey($"Homework-{code}"));
                            if (response.Status == 200)
                            {
                                Homework data = JsonDocument.Parse(response.Content).RootElement.Deserialize<Homework>();
                                data.status = 404;
                                await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(data, data.id, new PartitionKey($"Homework-{code}"));
                            }
                        }*/
                        await client.GetContainer(Constant.TEAMModelOS, "Common").ReplaceItemAsync(art, art.id, new PartitionKey($"{art.code}"));
                    }

                }
                return Ok(new { id });

            }
            catch (Exception e)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/delete()\n{e.Message}\n{e.StackTrace},\n", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500 });
            }
        }

        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("find")]
        public async Task<IActionResult> Find(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("code", out JsonElement code)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
                var query = $"select c.id,c.img,c.name,c.type,c.startTime,c.endTime,c.presenter,c.topic,c.address,c.owner,c.progress from c where (c.status<>404 or IS_DEFINED(c.status) = false )";
                string continuationToken = string.Empty;
                string token = default;
                //是否需要进行分页查询，默认不分页
                bool iscontinuation = false;
                if (request.TryGetProperty("token", out JsonElement token_1))
                {
                    token = token_1.GetString();
                    iscontinuation = true;
                };
                //默认不指定返回大小
                int? topcout = null;
                if (request.TryGetProperty("count", out JsonElement jcount))
                {
                    if (!jcount.ValueKind.Equals(JsonValueKind.Undefined) && !jcount.ValueKind.Equals(JsonValueKind.Null) && jcount.TryGetInt32(out int data))
                    {
                        topcout = data;
                    }
                }

                List<object> arts = new();
                await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, continuationToken: token, requestOptions: new QueryRequestOptions() { MaxItemCount = topcout, PartitionKey = new PartitionKey($"Art-{code}") }))
                {

                    using var json = await JsonDocument.ParseAsync(item.ContentStream);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            arts.Add(obj.ToObject<object>());
                        }
                    }
                    if (iscontinuation)
                    {
                        continuationToken = item.GetContinuationToken();
                        break;
                    }

                }
                return Ok(new { arts });
            }
            catch (Exception e)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/find()\n{e.Message}\n{e.StackTrace}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500});
            }

        }

        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher,admin,student")]
        [HttpPost("find-summary")]
        public async Task<IActionResult> FindSummary(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
                if (!request.TryGetProperty("code", out JsonElement code)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
                ArtEvaluation art = await client.GetContainer(Constant.TEAMModelOS, "Common").ReadItemAsync<ArtEvaluation>(id.GetString(), new PartitionKey($"Art-{code}"));
                if (art != null)
                {
                    return Ok(new { art, code = 200 });
                }
                else
                {
                    return Ok(new { art, code = 404 });
                }
            }
            catch (CosmosException ex) when (ex.Status == 404)
            {
                return Ok(new { code = 404 });
            }
            catch (Exception e)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/FindSummary()\n{e.Message}\n{e.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500 });
            }

        }


        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("find-by-teacher")]
        public async Task<IActionResult> FindByTeacher(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("code", out JsonElement code)) return BadRequest();
                if (!request.TryGetProperty("tId", out JsonElement tId)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
                var query = $"select c.id,c.img,c.name,c.startTime,c.type,c.endTime,c.presenter,c.topic,c.address,c.owner from c join A0 in c.teachers where A0.id = '{tId}'";
                List<object> arts = new();
                await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: query, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{code}") }))
                {

                    using var json = await JsonDocument.ParseAsync(item.ContentStream);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            arts.Add(obj.ToObject<object>());
                        }
                    }
                }
                return Ok(new { arts });
            }
            catch (Exception e)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/find-by-teacher()\n{e.Message}\n{e.StackTrace}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500});
            }

        }

        [ProducesDefaultResponseType]
        [Authorize(Roles = "IES")]
        [AuthToken(Roles = "teacher,admin")]
        [HttpPost("find-summary-by-teacher")]
        public async Task<IActionResult> FindSummaryByTeacher(JsonElement request)
        {
            try
            {
                if (!request.TryGetProperty("id", out JsonElement id)) return BadRequest();
                if (!request.TryGetProperty("code", out JsonElement code)) return BadRequest();
                if (!request.TryGetProperty("tId", out JsonElement tId)) return BadRequest();
                var client = _azureCosmos.GetCosmosClient();
                List<object> arts = new();
                await foreach (var item in client.GetContainer("TEAMModelOS", "Common").GetItemQueryStreamIterator(queryText: $"select value(c) from c join A0 in c.teachers where A0.id = '{tId}' and c.id = '{id}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Art-{code}") }))
                {
                    using var json = await JsonDocument.ParseAsync(item.ContentStream);
                    if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                    {
                        foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
                        {
                            arts.Add(obj.ToObject<object>());
                        }
                    }
                }
                return Ok(new { arts });
            }
            catch (Exception e)
            {
                await _dingDing.SendBotMsg($"OS，{_option.Location}，art/find-summary-by-teacher()\n{e.Message}\n{e.StackTrace}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return Ok(new { code = 500 });
            }

        }
    }
}