TEAMModelOS/TEAMModelOS/Controllers/OpenApi/Business/BizCustomizeController.cs

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK;
using TEAMModelOS.Models;
using Microsoft.Extensions.Options;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Models.Dtos;
using TEAMModelOS.SDK.Context.Constant;
using System.Collections.Generic;
using System.Text.Json;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.Filter;
using TEAMModelOS.SDK.Models;
using Microsoft.Azure.Cosmos;
using TEAMModelOS.SDK.Models.Cosmos.OpenEntity;
using System;
using System.Text;
using Azure.Core;

using TEAMModelOS.SDK.Models.Cosmos.Common;


using TEAMModelOS.Controllers.Analysis;
using System.Net.Http;
using Microsoft.AspNetCore.Hosting;

namespace TEAMModelOS.Controllers
{  /// <summary>
   /// 企业定制化接口
   /// </summary>
    [Route("customize")]
    [ApiController]
    public class BizCustomizeController : ControllerBase
    {
        public AzureCosmosFactory _azureCosmos;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly IConfiguration _configuration;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly SnowflakeId _snowflakeId;
        private readonly IHttpClientFactory _httpClient;
        private readonly IWebHostEnvironment _environment;

        public BizCustomizeController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, AzureRedisFactory azureRedis, AzureServiceBusFactory serviceBus, DingDing dingDing, CoreAPIHttpService coreAPIHttpService, IOptionsSnapshot<Option> option, IConfiguration configuration, SnowflakeId snowflakeId, IHttpClientFactory httpClient, IWebHostEnvironment hostingEnvironment)
        {
            _azureCosmos = azureCosmos;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _dingDing = dingDing;
            _option = option?.Value;
            _configuration = configuration;
            _coreAPIHttpService = coreAPIHttpService;
            _serviceBus = serviceBus;
            _snowflakeId = snowflakeId;
            _httpClient = httpClient;
            _environment = hostingEnvironment;
        }
        //shasdu
        #region  杉达公司

        /// <summary>
        /// 开课或者上传课例信息  是因支持VR/AR的公司(杉达)
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status400BadRequest)]
        [ProducesDefaultResponseType]
        [HttpPost("create-vrar-lesson-shanda-v2")]
        [ApiToken(Auth = "2007", Name = "VR·AR开课/上传课例信息", TName = "VR·AR開課/上傳課例信息", EName = "Start VR·AR lesson/upload VR·AR lesson ", RWN = "W", Limit = false)]
        public async Task<IActionResult> CreateVRARLessonShanDaV2(JsonElement jsonElement) {
            var (id, school) = HttpContext.GetApiTokenInfo();
            VRARLessonRecord lessonRecord= jsonElement.ToObject<VRARLessonRecord>();

            return null; 
        }

        /// <summary>
        /// 开课或者上传课例信息  是因支持VR/AR的公司(杉达)
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesResponseType(StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status400BadRequest)]
        [ProducesDefaultResponseType]
        [HttpPost("create-vrar-lesson-shanda")]
        [ApiToken(Auth = "2003", Name = "VR·AR开课/上传课例信息", TName = "VR·AR開課/上傳課例信息", EName = "Start VR·AR lesson/upload VR·AR lesson ", RWN = "W", Limit = false)]
        public async Task<IActionResult> CreateVRARLessonShanDa(JsonElement jsonElement)
        {
            var (id, school) = HttpContext.GetApiTokenInfo();
           
            try
            {
                jsonElement.TryGetProperty("baseJson", out JsonElement baseJson);    //课例基础文件信息json
                jsonElement.TryGetProperty("timLineJson", out JsonElement timLineJson); //时间json
                jsonElement.TryGetProperty("lessonId", out JsonElement lessonId);  //课例id
                if (!jsonElement.TryGetProperty("tmdId", out JsonElement tmdId)) return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "tmdId参数错误", data = null } });  //上课人ID
                jsonElement.TryGetProperty("tmdName", out JsonElement tmdName);  //上课人昵称
                jsonElement.TryGetProperty("tmdPicture", out JsonElement tmdpicture); //上课人头像
                if (!jsonElement.TryGetProperty("startTime", out JsonElement startTime)) return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "startTime参数错误", data = null } });  //开始时间
                if (!jsonElement.TryGetProperty("duration", out JsonElement duration)) return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "startTime参数错误", data = null } });  //上课时长
                jsonElement.TryGetProperty("periodId", out JsonElement periodId);  //学段id
                jsonElement.TryGetProperty("periodName", out JsonElement periodName); //学段名称
                jsonElement.TryGetProperty("groupIds", out JsonElement _groupIds); //名单id
                jsonElement.TryGetProperty("groupNames", out JsonElement _groupNames); //名单名称
                jsonElement.TryGetProperty("gradeIds", out JsonElement _gradeIds); //年级id
                jsonElement.TryGetProperty("gradeNames", out JsonElement _gradeNames); //年级名称
                jsonElement.TryGetProperty("subjectId", out JsonElement subjectId);  //科目id
                jsonElement.TryGetProperty("subjecName", out JsonElement subjecName); //科目名称
                jsonElement.TryGetProperty("courseId", out JsonElement courseId);  //课程id
                jsonElement.TryGetProperty("courseName", out JsonElement courseName); //课程名称

                LessonRecord lessonRecord = new();
                LessonBase lessonBase = null;
                TimeLine timeLine = null;
                if (!string.IsNullOrEmpty($"{baseJson}"))
                {
                    lessonBase = baseJson.ToObject<LessonBase>();
                    lessonRecord.upload = 1;
                }
                else
                    lessonRecord.upload = 0;
                if (!string.IsNullOrEmpty($"{timLineJson}"))
                {
                    timeLine = timLineJson.ToObject<TimeLine>();
                    lessonRecord.upload = 1;
                }
                else
                    lessonRecord.upload = 0;

                List<string> groupIds = new();
                List<string> groupNames = new();
                List<string> gradeIds = new();
                List<string> gradeNames = new();

                if (!string.IsNullOrEmpty($"{_groupIds}"))
                    groupIds = _groupIds.ToObject<List<string>>();
                if (!string.IsNullOrEmpty($"{_groupNames}"))
                    groupNames = _groupNames.ToObject<List<string>>();
                if (!string.IsNullOrEmpty($"{_gradeIds}"))
                    gradeIds = _gradeIds.ToObject<List<string>>();
                if (!string.IsNullOrEmpty($"{_gradeNames}"))
                    gradeNames = _gradeNames.ToObject<List<string>>();

                var cosmosClient = _azureCosmos.GetCosmosClient();
                string code = $"LessonRecord-{school}";

                var resLess = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync($"{lessonId}", new PartitionKey($"{code}"));
                if (resLess.StatusCode==System.Net.HttpStatusCode.OK)
                {
                    JsonDocument jsonD = JsonDocument.Parse(resLess.Content);
                    lessonRecord = jsonD.RootElement.ToObject<LessonRecord>();
                }
                else
                {
                    lessonRecord.id = _snowflakeId.NextId().ToString();
                    lessonRecord.code = code;
                }

                lessonRecord.tmdid = $"{tmdId}";
                lessonRecord.tmdname = $"{tmdName}";
                lessonRecord.tmdpicture = $"{tmdpicture}";
                lessonRecord.school = school;
                lessonRecord.scope = "school";
                lessonRecord.startTime = long.Parse($"{startTime}");
                lessonRecord.duration = double.Parse($"{duration}");
                lessonRecord.periodId = $"{periodId}";
                lessonRecord.periodName = $"{periodName}";
                lessonRecord.subjectId = $"{subjectId}";
                lessonRecord.subjecName = $"{subjecName}";
                lessonRecord.courseId = $"{courseId}";
                lessonRecord.courseName = $"{courseName}";
                lessonRecord.groupIds = groupIds;
                lessonRecord.groupNames = groupNames;
                lessonRecord.grade = gradeIds;
                lessonRecord.gradeName = gradeNames;

                if (!string.IsNullOrEmpty($"{baseJson}"))
                {
                    lessonRecord.name = lessonBase.summary.activityName;
                    lessonRecord.attendCount = lessonBase.summary.attendCount;
                    lessonRecord.clientCount = lessonBase.summary.clientCount;
                    lessonRecord.attendRate = lessonBase.summary.attendRate;
                    lessonRecord.groupCount = lessonBase.summary.groupCount;
                    lessonRecord.collateTaskCount = lessonBase.summary.collateTaskCount;
                    lessonRecord.collateCount = lessonBase.summary.collateCount;
                    lessonRecord.pushCount = lessonBase.summary.pushCount;
                    lessonRecord.totalPoint = lessonBase.summary.totalPoint;
                    lessonRecord.examQuizCount = lessonBase.summary.examQuizCount;
                    lessonRecord.interactionCount = lessonBase.summary.interactionCount;
                    lessonRecord.examPointRate = lessonBase.summary.examPointRate;
                    lessonRecord.clientInteractionCount = lessonBase.summary.clientInteractionCount;
                    lessonRecord.clientInteractionAverge = lessonBase.summary.clientInteractionAverge;
                    lessonRecord.examCount = lessonBase.summary.examCount;
                    lessonRecord.totalInteractPoint = lessonBase.summary.totalInteractPoint;
                    lessonRecord.learningCategory = lessonBase.summary.learningCategory;
                    lessonRecord.source = 1;

                    //计算TP灯
                    {
                        int T = -1;
                        int P = -1;
                        if (lessonRecord.clientInteractionAverge <= 0)
                        {
                            T = 0;
                        }
                        else if (lessonRecord.clientInteractionAverge >= 1 && lessonRecord.clientInteractionAverge <= 2)
                        {
                            T = 1;
                        }
                        else
                        {
                            T = 2;
                        }
                        //if (lessonRecord.examCount > 0)
                        //{
                        //    //有评测次数大于0则P是直接绿灯
                        //    P = 2;
                        //}
                        //else {

                        //}

                        int a = lessonRecord.hitaClientCmpCount;
                        int b = lessonRecord.pushCount;
                        int c = lessonRecord.examCount;
                        switch (true)
                        {
                            case bool when T == 0:
                                P = 0;
                                break;
                            case bool when T == 1 || T == 2:
                                if (a == 0 && b == 0 && c == 0)
                                {
                                    P = 0;
                                }
                                else if ((a > 0 && b > 0) || (a > 0 && c > 0) || (b > 0 && c > 0))
                                {
                                    P = 2;
                                }
                                else
                                {
                                    P = 1;
                                }
                                break;
                        }
                        lessonRecord.tLevel = T;
                        lessonRecord.pLevel = P;
                    }
                }
                if (resLess.StatusCode==System.Net.HttpStatusCode.OK)
                    lessonRecord = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync<LessonRecord>(lessonRecord, lessonRecord.id, new PartitionKey($"{code}"));
                else
                    lessonRecord = await cosmosClient.GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync<LessonRecord>(lessonRecord, new PartitionKey($"{code}"));

                var blobClient = _azureStorage.GetBlobContainerClient(containerName: $"{school}");
                if (!string.IsNullOrEmpty($"{baseJson}"))

                    //保存Basejson文件
                    await AzureStorageBlobExtensions.UploadFileByContainer(blobClient, lessonBase.ToJsonString(), $"records/{lessonRecord.id}/IES", $"Base.json");

                if (!string.IsNullOrEmpty($"{timLineJson}"))
                    //保存TimeLinejson文件
                    await AzureStorageBlobExtensions.UploadFileByContainer(blobClient, timeLine.ToJsonString(), $"records/{lessonRecord.id}/IES", $"TimeLine.json");

                return Ok(new
                {
                    responseData = new ResponseData<dynamic>()
                    {
                        code = RespondCode.Ok,
                        msg = "成功",
                        data = new
                        {
                            lessonRecord,
                            analysis = new
                            {
                                lessonRecord.id,
                                lessonRecord.name,
                                lessonRecord.subjectId,
                                lessonRecord.courseId,
                                intIndex = lessonRecord.tLevel,
                                learning = lessonRecord.pLevel,
                                atendCnt = lessonRecord.attendCount,
                                grCnt = lessonRecord.groupCount,
                                taskCnt = lessonRecord.collateTaskCount,
                                worksCnt = lessonRecord.collateCount,
                                pushCnt = lessonRecord.pushCount,
                                scoreCnt = lessonRecord.totalPoint,
                                emCnt = lessonRecord.examCount,
                                intTopicCnt = lessonRecord.interactionCount,
                                emPct = $"{lessonRecord.examPointRate} %",
                                stuIntCnt = lessonRecord.clientInteractionCount,
                                study = new
                                {
                                    coopCnt = lessonRecord.learningCategory.cooperation,
                                    testCnt = lessonRecord.learningCategory.exam,
                                    intCnt = lessonRecord.learningCategory.interaction,
                                    dCnt = lessonRecord.learningCategory.diffential,
                                    taskCnt = lessonRecord.learningCategory.task,
                                }
                            }
                        }
                    }
                });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OpenApi，{Environment.GetEnvironmentVariable("Option:Location")} BizOverallEducation/UpLessonRec()   参数：bizId:{id},school:{school},json:{jsonElement.ToJsonString()} \n  {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.Error, msg = "服务端异常" } });
            }
        }

        /// <summary>
        /// 获取学校课例  是因支持VR/AR的公司(杉达)
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-vrar-lessons")]
        [ApiToken(Auth = "2004", Name = "获取学校课例", TName = "獲取學校課例", EName = "Get school lessons", RWN = "R", Limit = false)]
        public async Task<IActionResult> GetLesson(JsonElement jsonElement)
        {
            var (id, school) = HttpContext.GetApiTokenInfo();
            jsonElement.TryGetProperty("lessonId", out JsonElement lessId);
            var cosmosClient = _azureCosmos.GetCosmosClient();

            StringBuilder sql = new("select value(c) from c where c.source=1");
            if (!string.IsNullOrEmpty($"{lessId}"))
                sql.Append($" and c.id='{lessId}'");

            List<OLessonRecord> lessonRecords = new();
            await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIteratorSql<OLessonRecord>(queryText: sql.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonRecord-{school}") }))
            {
                lessonRecords.Add(item);
            }

            return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.Ok, msg = "成功", data = lessonRecords } });
        }


        /// <summary>
        /// 获取学校课例分析结果  是因支持VR/AR的公司(杉达)
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-vrar-lesson-analysis")]
        [ApiToken(Auth = "2006", Name = "获取学校课例", TName = "獲取學校課例", EName = "Get school lessons", RWN = "R", Limit = false)]
        public async Task<IActionResult> GetLessonAnslysis(JsonElement jsonElement)
        {
            var (id, school) = HttpContext.GetApiTokenInfo();
            if (!jsonElement.TryGetProperty("lessonId", out JsonElement lessonId)) return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "lessId参数错误", data = null } });  //上课人ID  ;
            var cosmosClient = _azureCosmos.GetCosmosClient();

            dynamic analysis = null;

            await foreach (var item in cosmosClient.GetContainer(Constant.TEAMModelOS, "School").GetItemQueryStreamIteratorSql(queryText: $"select c.id,c.name,c.subjectId,c.courseId,c.tLevel,c.pLevel,c.attendCount,c.groupCount,c.collateTaskCount,c.collateCount,c.pushCount,c.totalPoint,c.examCount,c.interactionCount,c.examPointRate,c.clientInteractionCount,c.learningCategory from c where c.id='{lessonId}'", requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"LessonRecord-{school}") }))
            {
                using var json = await JsonDocument.ParseAsync(item.Content);
                if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                {
                    var accounts = json.RootElement.GetProperty("Documents").EnumerateArray();
                    while (accounts.MoveNext())
                    {
                        JsonElement account = accounts.Current;
                        LearningCategory learningCategory = account.GetProperty("learningCategory").ToObject<LearningCategory>();

                        analysis = new
                        {
                            id = account.GetProperty("id").GetString(),
                            name = account.GetProperty("name").GetString(),
                            subjectId = account.GetProperty("subjectId").GetString(),
                            courseId = account.GetProperty("courseId").GetString(),
                            intIndex = account.GetProperty("tLevel").GetInt64(),
                            learning = account.GetProperty("pLevel").GetInt64(),
                            atendCnt = account.GetProperty("attendCount").GetInt64(),
                            grCnt = account.GetProperty("groupCount").GetInt64(),
                            taskCnt = account.GetProperty("collateTaskCount").GetInt64(),
                            worksCnt = account.GetProperty("collateCount").GetInt64(),
                            pushCnt = account.GetProperty("pushCount").GetInt64(),
                            scoreCnt = account.GetProperty("totalPoint").GetInt64(),
                            emCnt = account.GetProperty("examCount").GetInt64(),
                            intTopicCnt = account.GetProperty("interactionCount").GetInt64(),
                            emPct = $"{account.GetProperty("examPointRate").GetDouble()} %",
                            stuIntCnt = account.GetProperty("clientInteractionCount").GetInt64(),
                            study = new
                            {
                                coopCnt = learningCategory.cooperation,
                                testCnt = learningCategory.exam,
                                intCnt = learningCategory.interaction,
                                dCnt = learningCategory.diffential,
                                taskCnt = learningCategory.task,
                            }
                        };

                        //var ids = account.GetProperty("id").GetString();
                        //var name = account.GetProperty("name").GetString();
                        //var intIndex = account.GetProperty("tLevel").GetInt64();
                        //var learning = account.GetProperty("pLevel").GetInt64();
                        //var atendCnt = account.GetProperty("attendCount").GetInt64();
                        //var grCnt = account.GetProperty("groupCount").GetInt64();
                        //var taskCnt = account.GetProperty("collateTaskCount").GetInt64();
                        //var worksCnt = account.GetProperty("collateCount").GetInt64();
                        //var pushCnt = account.GetProperty("pushCount").GetInt64();
                        //var scoreCnt = account.GetProperty("totalPoint").GetInt64();
                        //var emCnt = account.GetProperty("examCount").GetInt64();
                        //var intTopicCnt = account.GetProperty("interactionCount").GetInt64();
                        //var emPct = $"{account.GetProperty("examPointRate").GetDouble()} %";
                        //var stuIntCnt = account.GetProperty("clientInteractionCount").GetInt64();

                        //var study = new
                        //{
                        //    coopCnt = learningCategory.cooperation,
                        //    testCnt = learningCategory.exam,
                        //    intCnt = learningCategory.interaction,
                        //    dCnt = learningCategory.diffential
                        //};
                    }
                }
            }

            return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.Ok, msg = "成功", data = analysis } });

        }

        [ProducesDefaultResponseType]
        [HttpPost("get-analysis-course")]
        [ApiToken(Auth = "2008", Name = "分析课列", TName = "结算课列科技应用", EName = "application of accounting technology", RWN = "R", Limit = false)]
        public async Task<IActionResult> GetAnalysisCourse(JsonElement json)
        {
            var (id, school) = HttpContext.GetApiTokenInfo();
            var responseData = await OpenApiService.getCourseTechnology(_httpClient, _dingDing, id, school, json,_environment);
            return Ok(new { responseData });
        }

        #endregion

        #region 智音公司


        /// <summary>
        /// 添加/修改学生艺术评测（音乐）答题结果
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("upsert-student-score-zhiyin")]
        [ApiToken(Auth = "2005", Name = "添加/修改学生艺术评测（音乐）答题结果", TName = "添加/修改學生藝術評測音樂答題結果", EName = "Add/modify the music answer results of student art evaluation", RWN = "W", Limit = false)]
        public async Task<IActionResult> SetStudnetScore(JsonElement jsonElement)
        {
           
            try {
                var (id, school) = HttpContext.GetApiTokenInfo();
                if (!jsonElement.TryGetProperty("answer", out JsonElement _answer)) return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "answer参数错误", data = null } });
                OAnswerUp oAnswer = _answer.ToObject<OAnswerUp>();
                string fileId = string.IsNullOrWhiteSpace(oAnswer.thirdAnswerId) ? Guid.NewGuid().ToString() : oAnswer.thirdAnswerId;
                fileId = fileId.Replace("::", "--");
                await _azureStorage.GetBlobContainerClient("0-public").UploadFileByContainer(jsonElement.ToJsonString(), "zhiyinpush", $"{fileId}.json", true);
                StudentArtResult studentArtResult = new();
                var cosmosClient = _azureCosmos.GetCosmosClient();
                var ids = oAnswer.thirdAnswerId.Split("::");
                if (ids.Length == 3)
                {
                    string artId = ids[0];
                    string taskId = ids[1];
                    string studentId = ids[2];
                    var resArt = await cosmosClient.GetContainer(Constant.TEAMModelOS, "Student").ReadItemStreamAsync($"{school}-{studentId}", new PartitionKey($"ArtResult-{artId}"));
                    if (resArt.StatusCode==System.Net.HttpStatusCode.OK)
                    {
                        JsonDocument jsonD = JsonDocument.Parse(resArt.Content);
                        studentArtResult = jsonD.RootElement.ToObject<StudentArtResult>();
                        var temp = studentArtResult.results.Find(f => f.taskId.Equals(taskId));
                        if (temp == null)
                        {
                            temp = new ArtQuotaResult();
                            temp.subjectId = "subject_music";
                            temp.subjectName = "音乐";
                            temp.taskId = taskId;
                        }
                        temp.score = oAnswer.score;
                        //智音数据来源
                        temp.source = 1;

                        studentArtResult.zyanswer.questionId = oAnswer.questionId;
                        studentArtResult.zyanswer.thirdAnswerId = oAnswer.thirdAnswerId;
                        studentArtResult.zyanswer.score = oAnswer.score;
                        studentArtResult.zyanswer.detail = oAnswer.detail;
                        studentArtResult.zyanswer.time = DateTimeOffset.Now.ToUnixTimeMilliseconds();
                        await cosmosClient.GetContainer(Constant.TEAMModelOS, "Student").ReplaceItemAsync<StudentArtResult>(studentArtResult, studentArtResult.id, new PartitionKey(studentArtResult.code));
                        return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.Ok, msg = "成功", data = oAnswer } });
                    }
                    else
                    {
                        var client = _azureCosmos.GetCosmosClient();
                        string rId = string.Format("{0}{1}{2}", school, "-", studentId);
                        List<string> classIds = new();
                        List<GroupListGrp> groups = await GroupListService.GetMemberInGroupList(_coreAPIHttpService, client, _dingDing, studentId, 2, school, new List<string> { "class", "teach" });
                        foreach (var grp in groups)
                        {
                            classIds.Add(grp.id);
                        }
                        var aresponse = await client.GetContainer("TEAMModelOS", "Common").ReadItemStreamAsync(artId, new PartitionKey($"Art-{school}"));
                        if (aresponse.StatusCode==System.Net.HttpStatusCode.OK)
                        {
                            using var json = await JsonDocument.ParseAsync(aresponse.Content);
                            ArtEvaluation art = json.ToObject<ArtEvaluation>();
                            var artResult = new StudentArtResult
                            {
                                id = rId,
                                pk = "ArtResult",
                                code = $"ArtResult-{artId}",
                                studentId = studentId,
                                picture = "",
                                studentName = "",
                                school = school,
                                userType = 2,
                                artId = artId,
                                classIds = classIds,
                            };
                            foreach (var qIds in art.settings)
                            {
                                foreach (var task in qIds.task)
                                {
                                    ArtQuotaResult quotaResult = new()
                                    {
                                        quotaId = qIds.id,
                                        quotaName = qIds.quotaname,
                                        quotaType = (int)task.type,
                                        subjectId = task.subject,
                                        taskId = task.acId
                                    };
                                    if (!string.IsNullOrEmpty(quotaResult.taskId) && quotaResult.taskId.Equals(taskId))
                                    {
                                        quotaResult.subjectId = "subject_music";
                                        quotaResult.subjectName = "音乐";
                                        quotaResult.taskId = taskId;
                                        quotaResult.score = oAnswer.score;
                                        //智音数据来源
                                        quotaResult.source = 1;

                                    }
                                    artResult.results.Add(quotaResult);
                                }
                            }
                            artResult.zyanswer.questionId = oAnswer.questionId;
                            artResult.zyanswer.thirdAnswerId = oAnswer.thirdAnswerId;
                            artResult.zyanswer.score = oAnswer.score;
                            artResult.zyanswer.detail = oAnswer.detail;
                            await client.GetContainer("TEAMModelOS", "Student").CreateItemAsync(artResult, new PartitionKey($"{artResult.code}"));
                            return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.Ok, msg = "成功", data = oAnswer } });
                        }
                        else
                        {
                            return Ok(new { responseData = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "活动已被删除" } });
                        }
                        //初始化。
                    }
                }
                else
                {
                    return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.ParamsError, msg = "第三方id错误。", data = null } });
                }
            } catch (Exception ex) {
                await _dingDing.SendBotMsg($"智音数据推送数据已接受\n参数：{jsonElement.ToJsonString()}\n且发生系统异常\n{ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return Ok(new { responseDate = new ResponseData<dynamic>() { code = RespondCode.Error, msg = "系统错误", data = null } });
            }
        }
        #endregion


    }
}