TEAMModelOS/TEAMModelFunction/ScsApisHttpTrigger.cs

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using TEAMModelOS.SDK.DI;
using Azure.Cosmos;
using System.Text.Json;
using System.Collections.Generic;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.Models.Cosmos;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using System.Linq;
using TEAMModelOS.Services.Common;
using TEAMModelOS.SDK.Models.Service;
using HTEXLib.COMM.Helpers;
using System.Text;
using static TEAMModelOS.SDK.Models.Teacher;
using TEAMModelOS.SDK.Models.Cosmos.Common.Inner;
using Azure.Storage.Blobs.Models;

namespace TEAMModelFunction
{
    public class ScsApisHttpTrigger
    {
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureRedisFactory _azureRedis;
        private readonly ThirdApisService _thirdApisService;
        public static string Code { get; set; }
        public static Dictionary<string, object> parameterMap = null;
        public ScsApisHttpTrigger(AzureCosmosFactory azureCosmos, DingDing dingDing, AzureStorageFactory azureStorage, ThirdApisService thirdApisService
             , AzureRedisFactory azureRedis)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _azureStorage = azureStorage;
            _azureRedis = azureRedis;
            _thirdApisService = thirdApisService;
        }

        /// <summary>
        /// 数据推送接口
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("knowledge-change")]
        public async Task<IActionResult> KnowledgeChange([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log) {
            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($"hbcn").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("hbcn", 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));
                    }
                }
            }
            return new OkResult();
        }
        /// <summary>
        /// 数据推送接口
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("SchoolDataPush")]
        public async Task<IActionResult> SchoolDataPush([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log) {
            var client = _azureCosmos.GetCosmosClient();
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            JsonElement school = data.ToObject<JsonElement>().GetProperty("school");
            StringBuilder queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
            List<GroupList> yxtrain = new List<GroupList>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: queryText.ToString(),
            requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"GroupList-{school}") }))
            {
                yxtrain.Add(item);
            }
            List<TeacherTrain> trains = new List<TeacherTrain>();
            var members = yxtrain.SelectMany(x => x.members).ToList();
            if (members.IsNotEmpty()) {
                queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain' " +
                    $"and  c.id in ({string.Join(",", members.Select(x => $"'{x.id}'"))}) ");
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<TeacherTrain>(queryText: queryText.ToString(),
                requestOptions: new QueryRequestOptions() { PartitionKey = new Azure.Cosmos.PartitionKey($"TeacherTrain-{school}") }))
                {
                    trains.Add(item);
                }
            }

            string sql = $" SELECT value(c) FROM c join a in c.binds where ARRAY_LENGTH(c.binds)>0 and a.type='{config.config}' ";
            List<Teacher> teachers = new List<Teacher>();
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
                requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
            {
                teachers.Add(item);
            }
            //5.3.1.12学员培训基本情况批量回写-UpdateTeacherListSituation
            List<TeacherTrain> trains53112OK = new List<TeacherTrain>();

            //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
            List<TeacherTrain> trains53113OK = new List<TeacherTrain>();

            //5.3.1.17学员课堂实录批量回写-UploadKTSLList
            List<TeacherTrain> trains53117OK = new List<TeacherTrain>();

            //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
            List<TeacherTrain> trains53122OK = new List<TeacherTrain>();

            List<KeyValuePair<TeacherTrain,string>> trainsNO = new List<KeyValuePair<TeacherTrain, string>>();
            List<PushFail> fails= new List<PushFail>();
            trains.ForEach(x => {
                var teacher = teachers.Find(t => t.id.Equals(x.id));
                if (teacher == null)
                {
                    fails.Add(new PushFail { tmdid = x.id, msgs = new List<KeyValuePair<string, string>> { new KeyValuePair<string, string>("tmdid-unexistent", "账号不存在！") } });
                }
                else {
                    List<KeyValuePair<string, string>> msgs = new List<KeyValuePair<string, string>>();
                    var binddata = teachers.Where(t => t.id.Equals(x.id)).SelectMany(z => z.binds)
                        .Where(d => d.data.IsNotEmpty()).SelectMany(d => d.data)
                        .Where(d => string.IsNullOrEmpty(d) && d.Contains(config.config) && d.Contains(config.path));
                    if (binddata != null && binddata.Count() > 0)
                    {
                        var bindData = binddata.First().ToObject<ScBindData>();
                        if (binddata != null)
                        {
                        }
                        else
                        {
                            //如果没有找到绑定信息，则去blob查找。
                        }
                    }
                    else
                    {
                        //如果没有找到绑定信息，则去blob查找。
                    }
                }
            });
            return new OkObjectResult(new { });
        }

        /// <summary>
        /// 5.3.1.1获取项目列表
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetProjectInfoByTrainComID")]
        public async Task<IActionResult> GetProjectInfoByTrainComID([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
        {
            List<ScProject> projects = new List<ScProject>() ;
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetProjectInfoByTrainComID";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            ScsResult result = new ScsResult { code = Code, title = "5.3.1.1获取项目列表" };
            try
            {
                result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                if (result.result)
                {
                    projects = result.content.ToObject<List<ScProject>>();
                }
                else { 
                
                }
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetProjectInfoByTrainComID\n{ex.Message}{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
        }


        /// <summary>
        ///  5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetSchoolList")]
        public async Task<IActionResult> GetSchoolList([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
        {
            List<ScSchool> scSchools = new List<ScSchool>();
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetSchoolList";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            List<ScsResult> results = new List<ScsResult>();
            try
            {
                if (config.p.IsNotEmpty())
                {
                    foreach (var ps in config.p)
                    {
                        parameterMap["ProjectID"] = ps.pd;
                        parameterMap["ProjectItemID"] = ps.pid;
                        ScsResult result = new ScsResult { code = Code, title = " 5.3.1.18根据机构ID、项目ID、子项目ID返回学校列表" };
                        result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                        if (result.result)
                        {
                            List<ScSchool> schools = result.content.ToObject<List<ScSchool>>();
                            if (schools.IsNotEmpty())
                            {
                                scSchools.AddRange(schools);
                            }
                        }
                        results.Add(result);
                    }
                }
                return new OkObjectResult(new { data = scSchools.ToJsonString() });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetSchoolList\n{ex.Message}{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);
                return new OkObjectResult(new { data = scSchools.ToJsonString() });
            }
        }
        /// <summary>
        /// 5.3.1.2获取学员名单
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetTeachersListByProject")]
        public async Task<IActionResult> GetTeachersListByProject([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
        {
            List<ScTeacher> scTeachers = new List<ScTeacher>();
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetTeachersListByProject";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            List<ScsResult> results = new List<ScsResult>();
            try
            {
                if (config.p.IsNotEmpty())
                {
                    foreach (var ps in config.p)
                    {
                        parameterMap["ProjectID"] = ps.pd;
                        parameterMap["ProjectItemID"] = ps.pid;
                        ScsResult result = new ScsResult { code = Code, title = "5.3.1.2获取学员名单" };
                        result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                        if (result.result)
                        {
                            List<ScTeacher> teachers = result.content.ToObject<List<ScTeacher>>();
                            if (teachers.IsNotEmpty())
                            {
                                scTeachers.AddRange(teachers);
                            }
                        }
                        results.Add(result);
                    }
                }
                return new OkObjectResult(new { data = scTeachers.ToJsonString() });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetTeachersListByProject\n{ex.Message}{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);
                return new OkObjectResult(new { data = scTeachers.ToJsonString() });
            }
        }
        /// <summary>
        /// 5.3.1.20获取学校设置的可选能力点
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetSchoolDiagnosis")]
        public async Task<IActionResult> GetSchoolDiagnosis([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log) {
            List<ScsProjectDiagnosis> projects = new List<ScsProjectDiagnosis>();
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            JsonElement schoolCode = data.ToObject<JsonElement>().GetProperty("schoolCode");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetSchoolDiagnosis";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            List<ScsResult> results = new List<ScsResult>();
            try
            {
                if (config.p.IsNotEmpty())
                {
                    foreach (var ps in config.p)
                    {
                        parameterMap["ProjectID"] = ps.pd;
                        parameterMap["ProjectItemID"] = ps.pid;
                        parameterMap["SchoolID"] = $"{schoolCode}";
                        parameterMap["School"] = $"{schoolCode}";
                        ScsResult result = new ScsResult { code = Code, title = " 5.3.1.20获取学校设置的可选能力点" };
                        result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                        if (result.result)
                        {
                            List<ScPDiagnosis> diagnoses = result.content.ToObject<List<ScPDiagnosis>>();
                            if (diagnoses.IsNotEmpty())
                            {
                                projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = diagnoses });
                                await _azureStorage.SaveOrUpdate<ScProjectDiagnosis>(new ScProjectDiagnosis { RowKey = $"{ps.pid}-{schoolCode}", PartitionKey = "ScSchoolDiagnosis", abilityNos = diagnoses.ToJsonString() });
                            }
                        }
                        else
                        {
                            List<ScProjectDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScSchoolDiagnosis" }, { "RowKey", $"{ps.pid}-{schoolCode}" } });
                            if (teacherDiagnoses.IsNotEmpty())
                            {
                                projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });

                            }
                        }
                        results.Add(result);
                    }
                }
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
            catch (Exception ex)
            {
                //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetSchoolDiagnosis\n{ex.Message}{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);

                if (config.p.IsNotEmpty()) {
                    foreach (var ps in config.p)
                    {
                        List<ScProjectDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScSchoolDiagnosis" }, { "RowKey", $"{ps.pid}-{schoolCode}" } });
                        if (teacherDiagnoses.IsNotEmpty())
                        {
                            projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });

                        }
                    }
                }
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
        }
        /// <summary>
        /// 5.3.1.19获取项目设置的可选能力点
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetProjectDiagnosis")]
        public async Task<IActionResult> GetProjectDiagnosis([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
        {
            List<ScsProjectDiagnosis> projects =  new List<ScsProjectDiagnosis> () ;
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetProjectDiagnosis";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            List<ScsResult> results = new List<ScsResult>();
            try
            {
                if (config.p.IsNotEmpty())
                {
                    foreach (var ps in config.p)
                    {
                        parameterMap["ProjectID"] = ps.pd;
                        parameterMap["ProjectItemID"] = ps.pid;
                        ScsResult result = new ScsResult { code = Code, title = "5.3.1.19获取项目设置的可选能力点" };
                        result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                        if (result.result)
                        {
                            List<ScPDiagnosis> diagnoses = result.content.ToObject<List<ScPDiagnosis>>();
                            if (diagnoses.IsNotEmpty())
                            {
                                projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = diagnoses });
                                await _azureStorage.SaveOrUpdate<ScProjectDiagnosis>(new ScProjectDiagnosis { RowKey = $"{ps.pid}", PartitionKey = "ScProjectDiagnosis", abilityNos = diagnoses.ToJsonString() });
                            }
                        }
                        else
                        {
                            List<ScProjectDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScProjectDiagnosis" }, { "RowKey", $"{ps.pid}" } });
                            if (teacherDiagnoses.IsNotEmpty())
                            {
                                projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });

                            }
                        }
                        results.Add(result);
                    }
                }
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
            catch (Exception ex)
            {
                if (config.p.IsNotEmpty()) {
                    foreach (var ps in config.p)
                    {
                        //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetProjectDiagnosis\n{ex.Message}{ex.StackTrace}\n{results.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);
                        List<ScProjectDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScProjectDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScProjectDiagnosis" }, { "RowKey", $"{ps.pid}" } });
                        if (teacherDiagnoses.IsNotEmpty())
                        {
                            projects.Add(new ScsProjectDiagnosis { project = ps, diagnoses = teacherDiagnoses[0].abilityNos.ToObject<List<ScPDiagnosis>>() });

                        }
                    }
                }
                return new OkObjectResult(new { data = projects.ToJsonString() });
            }
        }

        /// <summary>
        /// 5.3.1.3通过项目编号获取学员测评能力项V2
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetDiagnosisListByProject_V2")]
        public async Task<IActionResult> GetDiagnosisListByProject_V2([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log) {
            List<string> abilityNos = new  List<string>();
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig=  data.ToObject<JsonElement>().GetProperty("accessConfig");
            JsonElement pxid = data.ToObject<JsonElement>().GetProperty("pxid");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetDiagnosisListByProject_V2";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            parameterMap.Add("PXID", pxid);
            ScsResult result = new ScsResult { code = Code, title = "5.3.1.3通过项目编号获取学员测评能力项V2" };
            try
            {
                result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                if (result.result)
                {
                    List<ScDiagnosis> diagnoses = result.content.ToObject<List<ScDiagnosis>>();
                    if (diagnoses != null)
                    {
                        abilityNos = diagnoses.Select(x => x.DiagnosisDicNum).ToList();
                    }
                    if (abilityNos .IsNotEmpty()) {
                        await _azureStorage.SaveOrUpdate<ScTeacherDiagnosis>(new ScTeacherDiagnosis { RowKey = $"{pxid}", PartitionKey = "ScTeacherDiagnosis",abilityNos=abilityNos.ToJsonString() });
                    }
                }
                else {

                    List<ScTeacherDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" },  { "RowKey", $"{pxid}" } });
                    if (teacherDiagnoses.IsNotEmpty()) {
                        abilityNos = teacherDiagnoses[0].abilityNos.ToObject<List<string>>();
                    }
                }
                return new  OkObjectResult(new { data= abilityNos .ToJsonString()});
            }
            catch (Exception ex)
            {
                //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:getDiagnosisListByProject_V2\n{ex.Message}{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);

                List<ScTeacherDiagnosis> teacherDiagnoses = await _azureStorage.FindListByDict<ScTeacherDiagnosis>(new Dictionary<string, object> { { "PartitionKey", "ScTeacherDiagnosis" }, { "RowKey", $"{pxid}" } });
                if (teacherDiagnoses.IsNotEmpty())
                {
                    abilityNos = teacherDiagnoses[0].abilityNos.ToObject<List<string>>();
                }
                return new OkObjectResult(new { data = abilityNos.ToJsonString() });
            }
        }
        /// <summary>
        /// 5.3.1.11获取跳转学员信息,用于sso单点，后端验证。
        /// </summary>
        /// <param name="req"></param>
        /// <param name="log"></param>
        /// <returns></returns>
        [FunctionName("GetSingleTeacherByProject")]
        public async Task<IActionResult> GetSingleTeacherByProject([HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, ILogger log)
        {
            string teacher=null;
            string data = await new StreamReader(req.Body).ReadToEndAsync();
            JsonElement accessConfig = data.ToObject<JsonElement>().GetProperty("accessConfig");
            JsonElement pxid = data.ToObject<JsonElement>().GetProperty("pxid");
            JsonElement tid = data.ToObject<JsonElement>().GetProperty("tid");
            ScAccessConfig config = $"{accessConfig}".ToObject<ScAccessConfig>();
            Code = "GetSingleTeacherByProject";
            parameterMap = new Dictionary<string, object>();
            parameterMap.Add("TrainComID", config.trainComID);
            parameterMap.Add("Pxid", $"{pxid}");
            parameterMap.Add("Tid", $"{tid}");
            ScsResult result = new ScsResult { code = Code, title = "5.3.1.11获取跳转学员信息,用于sso单点，后端验证。" };
            try
            {
                ///{“result”:true,”reason”:null,”content”:”{“PXID”:””,”TID”:””,”TeacherName”:””,”ProjectTitle”:””,”ProjectItemTitle”:””,”CityName”:””,
                ///”DisName”:””,”SchoolName”:””,”Sex”:””,”PXXK”:””,”PXXD”:””,”TeacherXK”:””,”TeacherXD”:””,”Email”:””}”,”pagecount”:1}
                result = await _thirdApisService.Post(config.url, Code, config.passKey, config.privateKey, parameterMap);
                if (result.result)
                {
                      teacher = result.content;
                }
                return new OkObjectResult(new {data= teacher });
            }
            catch (Exception ex)
            {
                //await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}，IES5.ScApisService:GetSingleTeacherByProject\n{ex.Message}{ex.StackTrace}\n{result.ToJsonString()}\n{data}", GroupNames.成都开发測試群組);
                return new OkObjectResult(new { data = teacher });
            }
        }

        public (int t53112OK, List<KeyValuePair<string, string>> msgs) check53112(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs)
        {
            //校验 基本情况是否满足
            int t53112OK = 1;
            if (teacherTrain.finalScore < 0)
            {
                msgs.Add(new KeyValuePair<string, string>("finalScore", $"最终评定结果参数：{teacherTrain.finalScore}"));
                t53112OK = 0;
            }
            if (string.IsNullOrEmpty(teacherTrain.summary) || teacherTrain.summary.Length > 300)
            {
                string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
                msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结：{msg}"));
                t53112OK = 0;
            }
            if (teacherTrain.totalTime <= 0)
            {
                msgs.Add(new KeyValuePair<string, string>("totalTime", $"未获得学时：{teacherTrain.totalTime}"));
                t53112OK = 0;
            }
            return (t53112OK, msgs);
        }

        public (int t53112OK, List<KeyValuePair<string, string>> msgs) check53113(TeacherTrain teacherTrain, List<KeyValuePair<string, string>> msgs)
        {
            //校验 基本情况是否满足
            int t53112OK = 1;
            if (teacherTrain.finalScore < 0)
            {
                msgs.Add(new KeyValuePair<string, string>("finalScore", $"最终评定结果参数：{teacherTrain.finalScore}"));
                t53112OK = 0;
            }
            if (string.IsNullOrEmpty(teacherTrain.summary) || teacherTrain.summary.Length > 300)
            {
                string msg = string.IsNullOrEmpty(teacherTrain.summary) ? "未填写" : teacherTrain.summary.Length > 300 ? "字数超过300." : "";
                msgs.Add(new KeyValuePair<string, string>("summary", $"教师培训总结：{msg}"));
                t53112OK = 0;
            }
            if (teacherTrain.totalTime <= 0)
            {
                msgs.Add(new KeyValuePair<string, string>("totalTime", $"未获得学时：{teacherTrain.totalTime}"));
                t53112OK = 0;
            }
            return (t53112OK, msgs);
        }
    }
}