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;

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("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();
            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);
            }
            string sql = $" SELECT value(c) FROM c where ARRAY_LENGTH(c.binds)>0 ";

            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
            //5.3.1.13学员能力点测评结果批量回写-UpdateTeacherListDiagnosis
            //5.3.1.17学员课堂实录批量回写-UploadKTSLList
            //5.3.1.22学员校本教研PDF(每人可以返回多条)批量回写-UploadSBTARPDFListV2
            return new OkObjectResult(new { });
        }

        /// <summary>
        /// 
        /// </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 = null;
            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("ProjectID", "22");
            //parameterMap.Add("ProjectItemID", "22");
            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();
                    }
                }
                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()}", GroupNames.成都开发測試群組);
                return new OkObjectResult(abilityNos);
            }
        }
        /// <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()}", GroupNames.成都开发測試群組);
                return new OkObjectResult(teacher);
            }
        }
    }
}