TEAMModelOS/TEAMModelOS/Controllers/Third/Sc/ScController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using System.Text.Json;
using TEAMModelOS.SDK.Models;
using Microsoft.AspNetCore.Http;
using TEAMModelOS.SDK.Extension;
using Azure.Cosmos;
using System.Text;
using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
using Microsoft.Extensions.Options;
using Azure.Messaging.ServiceBus;
using Microsoft.Extensions.Configuration;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.SDK;
using System.IdentityModel.Tokens.Jwt;
using TEAMModelOS.Services;
using TEAMModelOS.SDK.Models.Service;
using System.IO;
using System.Dynamic;
using Microsoft.AspNetCore.Authorization;
using Azure.Storage.Blobs.Models;
using static TEAMModelOS.SDK.Models.Teacher;
using System.Web;
using static TEAMModelOS.Controllers.FixDataController;
using static TEAMModelOS.SDK.SchoolService;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Azure.Cosmos.Table;

namespace TEAMModelOS.Controllers
{

    /// <summary>
    /// 
    /// </summary>
    ///  
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    //
    //[Route("")]
    //[Route("api/[controller]")]
    [ApiController]
    public class ScController : ControllerBase
    {
        private readonly SnowflakeId _snowflakeId;
        private readonly AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureStorageFactory _azureStorage;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly AzureRedisFactory _azureRedis;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        public readonly string type = "scsyxpt";
        private readonly HttpTrigger _httpTrigger;
        private readonly IWebHostEnvironment _environment;
        private readonly ScsStudyApisService _scsStudyApisService;

        public IConfiguration _configuration { get; set; }
        public ScController(ScsStudyApisService scsStudyApisService, IWebHostEnvironment environment, AzureCosmosFactory azureCosmos, SnowflakeId snowflakeId, DingDing dingDing, IOptionsSnapshot<Option> option, AzureStorageFactory azureStorage,
          AzureRedisFactory azureRedis, AzureServiceBusFactory serviceBus, IConfiguration configuration, CoreAPIHttpService coreAPIHttpService,  HttpTrigger httpTrigger)
        {
            _azureCosmos = azureCosmos;
            _snowflakeId = snowflakeId;
            _dingDing = dingDing;
            _option = option?.Value;
            _azureStorage = azureStorage;
            _serviceBus = serviceBus;
            _configuration = configuration;
            _azureRedis = azureRedis;
            _coreAPIHttpService = coreAPIHttpService;
            _httpTrigger = httpTrigger;
            _environment = environment;
            _scsStudyApisService = scsStudyApisService;
        }

        /// <summary>
        /// 检查教师绑定
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("sc/check-teacher-bind")]
        [AllowAnonymous]
        public async Task<IActionResult> CheckTeacherBind(JsonElement request)
        {
            if (!request.TryGetProperty("schoolId", out JsonElement _schoolId)) return BadRequest();

            var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
            List<ScSchool> schools = await table.FindListByDict<ScSchool>(new Dictionary<string, object>() { { "PartitionKey", "ScSchool" }, { "schoolCode", $"{_schoolId}" } });
            if (schools.IsNotEmpty())
            {
                List<ScTeacher> teachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object>() { { "PartitionKey", "ScTeacher" }, { "SchoolID", schools[0].schoolid } });
                return Ok(new { teachers = teachers });
            }
            else
            {
                return Ok();
            }
        }

        /// <summary>
        /// 检查醍摩豆id存在多个学校的情况
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("sc/check-bind")]
        [AllowAnonymous]
        public async Task<IActionResult> CheckBlobBinds(JsonElement json)
        {
            List<GroupList> teachers = new List<GroupList>();
            string sqs = "select   c.members   from c    where c.pk='GroupList' and c.type='yxtrain' and c.school in ('pjsyzx','pjzx','pjsazx','pjbjxx','pjxnxx','pjthxx','pjcyxx','pjfxxx','pjwjxx','pjzyzx','psywgy','hscjzx','cyhjnz','psasmx','psacjz','pwxjnx','pptsfx','pjjysx','xlzjnx','pdtjnx','pgxjnx','pcjjnx','pdxjnx','pnjyey','pbjyey','pcbyey','pcxyey','pcnyey','xjwhye','pxlyey','sazxye','saxcye','pthyey','psmyey','pshyey','pwxyey','pjysye','pfxyey','pgxyey','pcjyey','pcyhye','pbyyey','pdtyey','xyheye','xhyey','xbeyey','hhzyey','xxyey','saxgye','xllxye','dxxmye','dtxmye','dtydye','pnjdxy','pcxgmy','pcbgqy','saxccq','pjjsjx')  ";
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<GroupList>(queryText: sqs))
            {
                teachers.Add(item);

            }
            var a = teachers.SelectMany(x => x.members).GroupBy(y => y.id).ToList();
            var ae = a.Select(x => new { key = x.Key, val = x.ToList().Count() });
            ae = ae.Where(x => x.val > 1);
            return Ok(new { ae });
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("sc/fix-bind")]
        [AllowAnonymous]
        public async Task<IActionResult> FixBlobBinds(JsonElement json)
        {
            List<string> teacherids = new List<string>();
            string sql = $" SELECT value(c.id) FROM c where ARRAY_LENGTH(c.binds)>0 ";
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<string>(queryText: sql, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
            {
                teacherids.Add(item);
            }
            var bloblist = await _azureStorage.GetBlobContainerClient("teammodelos").List($"yxpt/scpjx/scbind");
            bloblist = bloblist.Select(x => x.Substring(18, 10)).ToList();

            List<string> tmdids = teacherids.Except(bloblist).ToList();
            List<Teacher> teachers = new List<Teacher>();
            sql = $" SELECT value(c) FROM c where ARRAY_LENGTH(c.binds)>0 ";
            if (tmdids != null)
            {
                sql = $"{sql} and c.id in ( {string.Join(",", tmdids.Select(x => $"'{x}'"))} )";
                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);
                }
            }
            List<string> unbind = new List<string>();
            List<string> list = new List<string>();
            HashSet<string> schoolIds = teachers.Where(z => z.schools.IsNotEmpty()).SelectMany(x => x.schools).Where(m => m.status.Equals("join")).Select(y => y.schoolId).ToHashSet();
            List<GroupList> groupLists = new List<GroupList>();
            foreach (var schoolid in schoolIds)
            {
                StringBuilder queryText = new StringBuilder($"SELECT distinct value(c) FROM c where c.type='yxtrain'");
                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-{schoolid}") }))
                {
                    groupLists.Add(item);
                }
            }

            foreach (var teacher in teachers)
            {
                var a = teacher.binds.SelectMany(y => y.data).ToList().Find(x => !string.IsNullOrWhiteSpace(x));
                if (a != null)
                {
                    await _azureStorage.GetBlobContainerClient("teammodelos").UploadFileByContainer(a, $"yxpt/scpjx/scbind", $"{teacher.id}.json");
                }
                else
                {
                    unbind.Add(teacher.id);
                }
                if (teacher.schools.IsNotEmpty())
                {
                    foreach (var school in teacher.schools)
                    {
                        if (!string.IsNullOrWhiteSpace(school.schoolId))
                        {

                            if (school.status.Equals("join"))
                            {
                                List<GroupList> yxtrain = groupLists.FindAll(x => x.code.Equals($"GroupList-{school.schoolId}"));
                                if (yxtrain.IsNotEmpty())
                                {
                                    var meber = yxtrain.SelectMany(x => x.members).Where(y => y.id.Equals(teacher.id));
                                    //不在研修名单
                                    if (meber == null || meber.Count() <= 0)
                                    {
                                        yxtrain[0].members.Add(new Member { id = teacher.id, type = 1 });
                                        await GroupListService.UpsertList(yxtrain[0], _azureCosmos, _configuration, _serviceBus);
                                    }
                                }
                                else
                                {
                                    GroupList groupList = new GroupList()
                                    {
                                        id = Guid.NewGuid().ToString(),
                                        code = $"GroupList-{school.schoolId}",
                                        creatorId = teacher.id,
                                        type = "yxtrain",
                                        year = DateTimeOffset.UtcNow.Year,
                                        members = new List<Member> { new Member { id = teacher.id, type = 1 } },
                                        scope = "school",
                                        school = school.schoolId,
                                        name = "研修名单",
                                        pk = "GroupList",
                                        ttl = -1,
                                        expire=0,
                                    };
                                    await GroupListService.UpsertList(groupList, _azureCosmos, _configuration, _serviceBus);
                                }
                            }
                            Azure.Response response = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(teacher.id, new PartitionKey($"Teacher-{school.schoolId}"));
                            if (response.Status != 200)
                            {
                                SchoolTeacher schoolTeacher = new SchoolTeacher
                                {
                                    id = teacher.id,
                                    code = $"Teacher-{school.schoolId}",
                                    pk = "Teacher",
                                    name = teacher.name,
                                    picture = teacher.picture,
                                    size = 0,
                                    roles = new List<string> { "teacher" },
                                    permissions = new List<string>(),
                                    status = school.status,
                                    createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                                    ttl = -1
                                };
                                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").CreateItemAsync(teacher.id, new PartitionKey($"Teacher-{school.schoolId}"));
                            }
                            else
                            {
                                JsonDocument document = await JsonDocument.ParseAsync(response.ContentStream);
                                SchoolTeacher schoolTeacher = document.RootElement.ToObject<SchoolTeacher>();
                                schoolTeacher.status = school.status;
                                schoolTeacher.pk = "Teacher";
                                schoolTeacher.name = teacher.name;
                                schoolTeacher.picture = teacher.picture;
                                if (!schoolTeacher.roles.IsEmpty())
                                {
                                    if (!schoolTeacher.roles.Contains("teacher"))
                                    {
                                        schoolTeacher.roles .Add("teacher");
                                    }
                                }
                                else {
                                    schoolTeacher.roles = new List<string> { "teacher" };
                                }
                                schoolTeacher.permissions = schoolTeacher.permissions.IsNotEmpty() ? schoolTeacher.permissions : new List<string>();

                                schoolTeacher.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
                                schoolTeacher.ttl = -1;
                                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReplaceItemAsync(schoolTeacher, schoolTeacher.id, new PartitionKey($"Teacher-{school.schoolId}"));
                            }
                        }
                    }
                }
            }
            return Ok(new { unbind, list });
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("sc/bind")]
        [AllowAnonymous]
        public async Task<IActionResult> Bind(SSO sso)
        {
            try
            {
                Teacher teacher = null;
                TmdidImplicit tmdidImplicit = null;
                if (!string.IsNullOrWhiteSpace(sso.mobile))
                {
                    var coreUser = await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", sso.mobile } }, _option.Location, _configuration);
                    if (coreUser != null)
                    {
                        var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                        tmdidImplicit = await _coreAPIHttpService.Implicit(new Dictionary<string, string> {   { "grant_type", "implicit" },
                                        { "client_id",clientID },
                                        { "account",coreUser.id },
                                        { "nonce",Guid.NewGuid().ToString()} }, _option.Location, _configuration);
                        if (tmdidImplicit != null && !string.IsNullOrWhiteSpace(tmdidImplicit.id_token))
                        {
                            sso.id_token = tmdidImplicit.id_token;
                        }
                        else
                        {
                            return Ok(new
                            {
                                location = _option.Location,
                                status = 2,
                            });
                        }
                    }
                    else {
                        return Ok(new
                        {
                            location = _option.Location,
                            status = 2,
                        });
                    }
                }
                if (string.IsNullOrWhiteSpace(sso.id_token))
                {
                    return Ok(new
                    {
                        location = _option.Location,
                        status = 2,
                    });
                }
                JwtSecurityToken jwt = null;
                try
                {
                    jwt = new JwtSecurityToken(sso.id_token);
                }
                catch (Exception ex)
                {
                    await _dingDing.SendBotMsg($"OS,{_option.Location}\n绑定失败,出现的原因可能是 参数异常：\n{sso.ToJsonString()},{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                    return BadRequest();
                }
                var id = jwt.Payload.Sub;
                CoreUser coreUserById=  await _coreAPIHttpService.GetUserInfo(new Dictionary<string, string> { { "key", $"{id}" } }, _option.Location, _configuration);
                if (coreUserById == null|| string.IsNullOrWhiteSpace(coreUserById.mobile)|| coreUserById.mobile.Length!=11)
                {
                    return Ok(new
                    {
                        location = _option.Location,
                        status = 2,
                    });
                }
                jwt.Payload.TryGetValue("name", out object name);
                jwt.Payload.TryGetValue("picture", out object picture);
                ScSSOData scsso = HttpUtility.UrlDecode(sso.param, Encoding.UTF8).ToObject<ScSSOData>();
                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                List<ScTeacher> scTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { Constant.PartitionKey, "ScTeacher" }, { "tmdid", id } });
                if (scTeachers.Count > 0 && !string.IsNullOrWhiteSpace(scTeachers[0].RowKey) && !scTeachers[0].RowKey.Equals(scsso.Pxid))
                {
                    return Ok(new
                    {
                        location = _option.Location,
                        //账号已被别的醍摩豆id绑定
                        status = 3,
                        tmdid = $"{id}",
                        name = name.Equals(scTeachers[0].TeacherName) ? $"{name}" : $"{name}({scTeachers[0].TeacherName})",
                        tid = scsso.tid
                    });
                }
                var client = _azureCosmos.GetCosmosClient();
                try
                {
                    teacher = await client.GetContainer(Constant.TEAMModelOS, "Teacher").ReadItemAsync<Teacher>(id, new PartitionKey("Base"));
                    //先检查绑定的平台是否已经被绑定
                    //四川研训平台跳转隐式登录/或者绑定IES平台接入规范
                    string sql = $"SELECT distinct value(c) FROM c join A1 in  c.binds where   A1.tid='{scsso.tid}'";
                    await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
                        requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
                    {
                        teacher = item;
                        break;
                    }
                    if (teacher != null)
                    {
                        if (teacher.id.Equals(id))
                        {
                            var bindData = scsso.data.ToObject<ScBindData>();
                            //var bind = teacher.binds.Find(x => x.source.Equals($"{scsso.Webid}") && x.userid.Equals($"{scsso.tid}"));
                            var bind = teacher.binds.Find(x => x.userid.Equals($"{scsso.tid}"));
                            if (bind == null)
                            {
                                teacher.binds = new List<Teacher.ThirdBind> { new Teacher.ThirdBind { data = new List<string> { scsso.data }, userid = $"{scsso.tid}", account = scsso.account, username = scsso.username, type = type } };
                                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
                            }
                            else
                            {
                                bind.username = scsso.username;
                                bind.account = scsso.account;

                                bool isnew = true;
                                for (int index = 0; index < bind.data.Count; index++)
                                {
                                    ScBindData scBind = bind.data[index].ToObject<ScBindData>();
                                    if (scBind.pxid.Equals(bindData.pxid))
                                    {
                                        bind.data[index] = bindData.ToJsonString();
                                        isnew = false;
                                    }
                                }
                                if (isnew)
                                {
                                    bind.data.Add(bindData.ToJsonString());
                                }
                                if (bindData != null)
                                {
                                    bindData.userid = scsso.tid;
                                    bindData.username = scsso.username;
                                    bindData.account = scsso.account;
                                }
                                await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
                            }
                            await _azureStorage.GetBlobContainerClient("teammodelos").UploadFileByContainer(bindData.ToJsonString(), $"yxpt/{scsso.path}/scbind", $"{teacher.id}.json");
                            await ThirdService.GetScTeacher(bindData, teacher, _azureStorage, _azureCosmos, _serviceBus, _configuration, _dingDing);
                        }
                        else
                        {
                            return Ok(new
                            {
                                location = _option.Location,
                                //账号已被别的醍摩豆id绑定
                                status = 3,
                                tmdid = teacher.id,
                                name = teacher.name,
                                tid = scsso.tid
                            });
                        }
                    }
                }
                catch (CosmosException ex) when (ex.Status ==404)
                {
                    teacher = new Teacher
                    {
                        createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
                        id = id,
                        pk = "Teacher",
                        code = "Base",
                        name = name?.ToString(),
                        picture = picture?.ToString(),
                        //创建账号并第一次登录IES5则默认赠送1G
                        size = 1,
                        defaultSchool = null,
                        schools = new List<Teacher.TeacherSchool>(),
                        binds = new List<Teacher.ThirdBind> { new Teacher.ThirdBind { username = scsso.username, account = scsso.account, data = new List<string> { scsso.data }, userid = $"{scsso.tid}", /*source = $"{scsso.Webid}",*/ type = type } }
                    };
                    var container = _azureStorage.GetBlobContainerClient(id);
                    await container.CreateIfNotExistsAsync(PublicAccessType.None); //嘗試創建Teacher私有容器，如存在則不做任何事，保障容器一定存在
                    teacher = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").CreateItemAsync<Teacher>(teacher, new PartitionKey("Base"));

                    ScBindData bindData = scsso.data.ToObject<ScBindData>();
                    await ThirdService.GetScTeacher(bindData, teacher, _azureStorage, _azureCosmos, _serviceBus, _configuration, _dingDing);
                    if (bindData != null)
                    {
                        bindData.userid = scsso.tid;
                        bindData.username = scsso.username;
                        bindData.account = scsso.account;
                        await _azureStorage.GetBlobContainerClient("teammodelos").UploadFileByContainer(bindData.ToJsonString(), $"yxpt/{scsso.path}/scbind", $"{teacher.id}.json");
                    }
                    else
                    {
                        await _azureStorage.GetBlobContainerClient("teammodelos").UploadFileByContainer(scsso.data.ToJsonString(), $"yxpt/{scsso.path}/scbind", $"{teacher.id}.json");
                    }
                }
                catch (Exception ex)
                {
                    await _dingDing.SendBotMsg($"OS,{_option.Location}\n绑定失败：\n{sso.ToJsonString()},{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                    return Ok(new
                    {
                        location = _option.Location,
                        status = 2,
                    });
                }
                return Ok(new
                {
                    tmdidImplicit = tmdidImplicit,
                    location = _option.Location,
                    status = 200,
                });

            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS,{_option.Location}\n绑定失败：\n{sso.ToJsonString()},{ex.Message}\n{ex.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                return Ok(new
                {
                    location = _option.Location,
                    status = 2,
                });
            }

        }

        /// <summary>
        /// 动态地址路由。"config":"scsyxpt","path":"sc{pjx/jinniu}"
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>

        [HttpGet("sc/gen-sso")]
        [AllowAnonymous]
        public async Task<IActionResult> GenSso([FromQuery] ScTchTmd tmd) {
            if (tmd != null && !string.IsNullOrWhiteSpace(tmd.tmdid))
            {
                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");
                List<ScTeacher> scTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" }, { "tmdid", $"{tmd.tmdid}" } });
                if (scTeachers.Any())
                {
                    string ep = $"Pxid={scTeachers[0].PXID}&Webid=1001&tid={scTeachers[0].TID}&time=1646617519";
                    string Encrypt = Md5Hash.GetMd5String(ep);
                    string url = $"https://www.teammodel.cn/sc/sso?{ep}&Encrypt={Encrypt}";
                    return Ok(new { url });
                }
                else
                {
                    return Ok("暂无ID的数据");
                }
            }
            else
            {
                return Ok("参数错误！");
            }
            
            
        }

        /// <summary>
        /// 动态地址路由。"config":"scsyxpt","path":"sc{pjx/jinniu}"
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>

        [HttpGet("{path}/sso")]
        [AllowAnonymous]
        public async Task<IActionResult> Sso([FromQuery] ScSSO scsso, string path)
        {
            string HostName = HttpContext.GetHostName();

            if (!string.IsNullOrWhiteSpace(_option.HostName))
            {
                HostName = _option.HostName;
            }
            if (path.Equals("jinniu"))
            {
                if (!_option.Location.Contains("Dep"))
                {
                    HostName = "jinniu.teammodel.cn";
                }
            }
            if (HostName.Equals("www.teammodel.cn")) {
                HostName = "scyx.teammodel.cn";
            }
            //var rurl = new StringBuilder($"https://{_option.HostName}/sso");
            var rurl = new StringBuilder($"https://{HostName}/sso");
            try
            {

                string parmas = $"Pxid={scsso.Pxid}&Webid={scsso.Webid}&tid={scsso.tid}&time={scsso.time}";
                if (Md5Hash.GetMd5String(parmas).Equals($"{scsso.Encrypt}"))
                {
                    //四川研训平台跳转隐式登录/或者绑定IES平台接入规范

                    long ssotime = long.Parse($"{scsso.time}");
                    long nowtime = DateTimeOffset.UtcNow.ToUnixTimeSeconds();
                    if (nowtime - ssotime > 60 * 10)//10分钟有效期
                    {
                        //  return Ok(new { status = 2, msg = "登录超时！" });
                    }
                }
                else
                {
                    return Redirect(rurl.Append($"?status=1").ToString());
                }
                var table = _azureStorage.GetCloudTableClient().GetTableReference("ScYxpt");

                string qurey = $"PartitionKey {QueryComparisons.Equal} 'ScTeacher' and TID {QueryComparisons.Equal} {scsso.tid} and  RowKey {QueryComparisons.Equal} '{scsso.Pxid}'  ";
                var result = await table.ExecuteQuerySegmentedAsync(new TableQuery<ScTeacher>().Where(qurey), null);
                List<ScTeacher> scTeachers = result.Results;
                // List<ScTeacher> scTeachers = await table.FindListByDict<ScTeacher>(new Dictionary<string, object> { { "PartitionKey", "ScTeacher" }, { "TID", scsso.tid }, { "RowKey", $"{scsso.Pxid}" } });
                if (!scTeachers.IsNotEmpty())
                {
                    //没有同步省平台
                    string enurl = $"status=5&param={HttpUtility.UrlEncode(new { scsso.Pxid, scsso.tid }.ToJsonString(), Encoding.UTF8)}";
                    return Redirect(rurl.Append($"?{enurl}").ToString());
                }
                string setsql = $"select  value(c) from c where   c.id ='{scTeachers[0].areaId}' and contains(c.accessConfig,'{ scTeachers[0].ProjectID}') and contains(c.accessConfig,'{ scTeachers[0].ProjectItemID}')  and contains(c.accessConfig,'scsyxpt') ";
                AreaSetting setting = null;
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Normal").GetItemQueryIterator<AreaSetting>(queryText: setsql,
                    requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"AreaSetting") }))
                {
                    setting = item;
                    break;
                }
                if (setting == null || (setting != null && string.IsNullOrWhiteSpace(setting.accessConfig)))
                {
                    return Redirect(rurl.Append($"?status=1").ToString());
                }
                string accessConfig = setting.accessConfig;
                Dictionary<string, object> dict = new() { { "accessConfig", accessConfig }, { "pxid", scsso.Pxid }, { "tid", scsso.tid }, { "areaId", $"{setting.id}" } };
                string SchoolName = "", SchoolID = "", ProjectID = "", ProjectItemID = "", TeacherName = "", Account = "";
                if (scTeachers.IsNotEmpty())
                {
                    ScTeacher scTeacher = scTeachers[0];
                    if (scTeacher != null && $"{scTeacher.PXID}".Equals(scsso.Pxid) && $"{scTeacher.TID}".Equals(scsso.tid))
                    {
                        SchoolName = scTeacher.SchoolName;
                        SchoolID = $"{scTeacher.SchoolID}";
                        ProjectID = $"{ scTeacher.ProjectID}";
                        ProjectItemID = $"{ scTeacher.ProjectItemID}";
                        TeacherName = $"{ scTeacher.TeacherName}";
                        Account = $"{ scTeacher.Account}";
                    }
                }
                if (string.IsNullOrWhiteSpace(SchoolID))
                {
                    //(int status, string json) = await _httpTrigger.RequestHttpTrigger(dict, _option.Location, "GetSingleTeacherByProject");
                    (int status, string json) = await _scsStudyApisService.GetSingleTeacherByProject(setting.id, accessConfig, scsso.Pxid, scsso.tid);
                    if (status == 200)
                    {
                        ScTeacher scTeacher = json.ToObject<ScTeacher>(new JsonSerializerOptions { PropertyNameCaseInsensitive = false });
                        if (scTeacher != null && $"{scTeacher.PXID}".Equals(scsso.Pxid) && $"{scTeacher.TID}".Equals(scsso.tid))
                        {
                            SchoolName = scTeacher.SchoolName;
                            SchoolID = $"{scTeacher.SchoolID}";
                            ProjectID = $"{ scTeacher.ProjectID}";
                            ProjectItemID = $"{ scTeacher.ProjectItemID}";
                            TeacherName = $"{ scTeacher.TeacherName}";
                            Account = $"{ scTeacher.Account}";
                        }
                    }
                    else
                    {
                        await _dingDing.SendBotMsg($"OS,{_option.Location}\n省平台教师信息：\nstatus：{status}{json}\n{dict.ToJsonString()} \nGetSingleTeacherByProject", GroupNames.醍摩豆服務運維群組);
                    }
                }
                ScBindData bindData = new()
                {
                    sn = SchoolName,
                    sid = SchoolID,
                    pd = ProjectID,
                    pid = ProjectItemID,
                    pxid = scsso.Pxid,
                    userid = scsso.tid,
                    username = TeacherName,
                    account = Account,
                    path = path,

                };
                var data = bindData.ToJsonString();
                ScSSOData sso = new ScSSOData
                {
                    username = TeacherName,
                    account = Account,
                    path = path,
                    Pxid = scsso.Pxid,
                    Encrypt = scsso.Encrypt,
                    tid = scsso.tid,
                    time = scsso.time,
                    data = data
                };
                Teacher teacher = null;
                //四川研训平台跳转隐式登录/或者绑定IES平台接入规范
                //string sql = $"SELECT distinct value(c) FROM c join A1 in  c.binds where A1.pxid='{sso.Pxid}' and A1.webid='{sso.Webid}' and A1.tid='{sso.tid}'";
                string sql = $"SELECT distinct value(c) FROM c join A1 in  c.binds where  A1.userid='{sso.tid}'";
                await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sql,
                    requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey($"Base") }))
                {
                    teacher = item;
                    break;
                }
                if (teacher == null)
                {
                    //string enurl = HttpUtility.UrlEncode(rurl.Append($"?status=4&param={sso.ToJsonString()}&type={type}&bindurl=sc/bind").ToString());
                    string enurl = $"status=4&param={HttpUtility.UrlEncode(sso.ToJsonString(), Encoding.UTF8)}&type={type}&bindurl=sc/bind";
                    return Redirect(rurl.Append($"?{enurl}").ToString());
                }
                else
                {
                    var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
                    var location = _option.Location;
                    TmdidImplicit implicit_token = await _coreAPIHttpService.Implicit(
                        new Dictionary<string, string>()
                        {
                        { "grant_type", "implicit" },
                        { "client_id",clientID },
                        { "account",teacher.id },
                        { "nonce",Guid.NewGuid().ToString()}
                        }, location, _configuration);
                    if (implicit_token != null)
                    {
                        if (string.IsNullOrWhiteSpace(implicit_token.id_token))
                        {
                            await _dingDing.SendBotMsg($"OS,隐式登录获得信息为空：{_option.Location}-\n{scsso.ToJsonString()} \npath:{path}\n{implicit_token.ToJsonString()}", GroupNames.醍摩豆服務運維群組);
                            return Redirect(rurl.Append($"?status=1").ToString());
                        }
                        //处理自动加入学校，加入培训名单
                        await ThirdService.GetScTeacher(bindData, teacher, _azureStorage, _azureCosmos, _serviceBus, _configuration, _dingDing);
                        var bind = teacher.binds.Find(x => x.userid.Equals(sso.tid));
                        //var bind = teacher.binds.Find(x => x.userid.Equals(sso.tid) && x.source.Equals(sso.Webid));
                        if (bind != null)
                        {
                            bool isnew = true;
                            for (int index = 0; index < bind.data.Count; index++)
                            {
                                ScBindData scBind = bind.data[index].ToObject<ScBindData>();
                                if (scBind.pxid.Equals(bindData.pxid))
                                {
                                    bind.data[index] = bindData.ToJsonString();
                                    isnew = false;
                                }
                            }
                            if (isnew)
                            {
                                bind.data.Add(bindData.ToJsonString());
                            }
                            bind.username = TeacherName;
                            bind.account = Account;
                            await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
                        }
                        try
                        {
                            await _azureStorage.GetBlobContainerClient("teammodelos").UploadFileByContainer(bindData.ToJsonString(), $"yxpt/{sso.path}/scbind", $"{teacher.id}.json");
                        }
                        catch (Exception ex)
                        {
                            await _dingDing.SendBotMsg($"OS,{_option.Location}-\n文件失败 \npath:{path}\n\n{ex.Message}\n{ex.StackTrace}\n yxpt/{sso.path}/scbind/{teacher.id}.json", GroupNames.醍摩豆服務運維群組);
                        }
                        rurl.Append($"?status=200&id_token={implicit_token.id_token}&access_token={implicit_token.access_token}&expires_in={HttpUtility.UrlEncode(implicit_token.expires_in)}&token_type={HttpUtility.UrlEncode(implicit_token.token_type)}").ToString();
                        string uri = rurl.ToString();
                        return Redirect(uri);
                    }
                    else
                    {
                        //绑定失效
                        //if (teacher.binds.IsNotEmpty())
                        //{
                        //    teacher.binds.RemoveAll(x => x.userid.Equals(sso.tid));
                        //    await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").ReplaceItemAsync<Teacher>(teacher, teacher.id, new PartitionKey(teacher.code));
                        //}
                        //string enurl = $"status=4&param={HttpUtility.UrlEncode(sso.ToJsonString(), Encoding.UTF8)}&type={type}&bindurl=sc/bind";
                        // return Redirect(rurl.Append($"?{enurl}").ToString());
                        return Redirect(rurl.Append($"?status=1").ToString());
                    }
                }
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"OS,{_option.Location}-\n{scsso.ToJsonString()} \npath:{path}\n\n{ex.Message}\n{ex.StackTrace}", GroupNames.醍摩豆服務運維群組);
                return Redirect(rurl.Append($"?status=1").ToString());
            }
        }


        public class DbBind
        {
            public string id { get; set; }
            public string userid { get; set; }
            public List<string> data { get; set; }
        }
    }
}