TEAMModelOS/TEAMModelBI/Controllers/LoginController.cs

using Azure.Cosmos;
using DingTalk.Api;
using DingTalk.Api.Request;
using DingTalk.Api.Response;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.Models;
using HTEXLib.COMM.Helpers;
using TEAMModelOS.Models;
using Microsoft.Extensions.Options;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Models.Service;
using Microsoft.AspNetCore.Authorization;
using Azure.Storage.Blobs.Models;
using System.IdentityModel.Tokens.Jwt;
using System.Net.Http;
using System.Text;
using System.Net;
using Newtonsoft.Json;
using System.Collections;
using Newtonsoft.Json.Linq;
using TEAMModelOS.SDK.Models.Cosmos.BI;
using Azure.Storage.Sas;
using System.Net.Http.Json;
using TEAMModelBI.Filter;
using TEAMModelBI.Models.Extension;
using TEAMModelOS.SDK;
using Microsoft.AspNetCore.Hosting;
using TEAMModelBI.Tool;
using TEAMModelBI.DI.BIAzureStorage;
using TEAMModelBI.Tool.Context;
//using static DingTalk.Api.Response.OapiV2UserGetResponse;

namespace TEAMModelBI.Controllers
{
    [ProducesResponseType(StatusCodes.Status200OK)]
    [ProducesResponseType(StatusCodes.Status400BadRequest)]
    [Route("common/login")]
    [ApiController]
    public class LoginController : ControllerBase
    {
        private readonly IConfiguration _configuration;
        //数据容器
        private readonly AzureCosmosFactory _azureCosmos;
        //文件容器
        private readonly AzureStorageFactory _azureStorage;
        //钉钉提示信息
        private readonly DingDing _dingDing;
        private readonly Option _option;
        //隐式登录
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly IHttpClientFactory _http;
        private readonly IWebHostEnvironment _environment; //读取文件

        public LoginController(IConfiguration configuration, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option, CoreAPIHttpService coreAPIHttpService, IHttpClientFactory http, IWebHostEnvironment environment)
        {
            _configuration = configuration;
            _azureCosmos = azureCosmos;
            _azureStorage = azureStorage;
            _dingDing = dingDing;
            _option = option?.Value;
            _coreAPIHttpService = coreAPIHttpService;
            _http = http;
            _environment = environment;
        }

        /// <summary>
        /// 钉钉扫码登录获取扫码信息
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-ddscancode")]
        public async Task<IActionResult> GetDingDingScanCode(JsonElement jsonElement)
        {
            try
            {
                string appKey = _configuration["DingDingAuth:appKey"];
                string appSecret = _configuration["DingDingAuth:appSecret"];                
                string proDeptId = _configuration["CustomParam:proDeptId"]; 
                //string divide = _configuration["CustomParam:SiteScope"];
                string divide = _option.Location;
                var cosmosClient = _azureCosmos.GetCosmosClient();
                string Website = "China";

                if (string.IsNullOrWhiteSpace(appKey) || string.IsNullOrWhiteSpace(appSecret))
                {
                    return Ok(new { state = 0, msg = "请检查配置钉钉的信息" });
                }
                //自己传的code
                if (!jsonElement.TryGetProperty("code", out JsonElement LoginTempCode)) return BadRequest();
                jsonElement.TryGetProperty("site", out JsonElement site);
                var tableClient = _azureStorage.GetCloudTableClient();
                var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                    blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                    Website = BIConst.GlobalSite;
                }

                //获取access_token
                IDingTalkClient tokenClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
                OapiGettokenRequest tokenRequest = new() { Appkey = appKey, Appsecret = appSecret };
                tokenRequest.SetHttpMethod("Get");
                OapiGettokenResponse tokenRespone = tokenClient.Execute(tokenRequest);
                if (tokenRespone.IsError) return BadRequest();

                string access_token = tokenRespone.AccessToken;
                //获取临时授权码 获取授权用户的个人信息
                DefaultDingTalkClient clientinfo = new("https://oapi.dingtalk.com/sns/getuserinfo_bycode");
                OapiSnsGetuserinfoBycodeRequest req = new() { TmpAuthCode = $"{LoginTempCode}" };  //通过扫描二维码，跳转到指定的Url后，向Url中追加Code临时授权码
                OapiSnsGetuserinfoBycodeResponse response = clientinfo.Execute(req, appKey, appSecret);

                if (response.Errcode.Equals(40078))
                {
                    return Ok(new { state = 0, msg = $"state:{response.Errcode}；Err{response.Errmsg}/临时授权码过期请重新扫码" });
                }

                string unionid = response.UserInfo.Unionid;
                IDingTalkClient client2 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/getbyunionid"); //userid地址
                OapiUserGetbyunionidRequest byunionidRequest = new() { Unionid = unionid };
                OapiUserGetbyunionidResponse byunionidResponse = client2.Execute(byunionidRequest, access_token);
                if (byunionidResponse.IsError || byunionidResponse.Errcode == 60121)
                {
                    return Ok(new { state = 0, msg = byunionidResponse.Errmsg });
                }
                // 根据userId获取用户信息
                string userid = byunionidResponse.Result.Userid;
                IDingTalkClient client3 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
                OapiV2UserGetRequest v2GetRequest = new()
                {
                    Userid = userid,
                    Language = "zh_CN"
                };

                v2GetRequest.SetHttpMethod("POST");
                OapiV2UserGetResponse v2GetResponse = client3.Execute(v2GetRequest, access_token);
                if (v2GetResponse.IsError)
                {
                    return Ok(new { state = 0, msg = "扫码登录失败" });
                }

                var table = _azureStorage.GetCloudTableClient().GetTableReference("BIDDUserInfo");
                var id_token = "";
                string osblob_uri = null, osblob_sas = null;
                List<string> roles = new();//角色列表
                List<string> permissions = new();//权限列表
                bool isExploit = false;

                List<DingDingUserInfo> ddusers = await table.FindListByDict<DingDingUserInfo>(new Dictionary<string, object>() { { "userId", $"{v2GetResponse.Result.Userid}" }, { "unionId", $"{v2GetResponse.Result.Unionid}" } });

                if (ddusers.Count > 0)
                {
                    List<DingDingUserInfo> saveInfo = new();
                    StringBuilder strMsg = new();

                    foreach (var item in ddusers)
                    {
                        if (string.IsNullOrEmpty(item.tmdId))
                        {
                            List<string> mobiles = new() { $"{ item.mobile}" };
                            var content = new StringContent(mobiles.ToJsonString(), Encoding.UTF8, "application/json");
                            string json = await _coreAPIHttpService.GetUserInfos(content);
                            if (!string.IsNullOrEmpty(json))
                            {
                                List<JsonElement> json_id = json.ToObject<List<JsonElement>>();
                                foreach (var tmd in json_id)
                                {
                                    item.tmdId = tmd.GetProperty("id").ToString();
                                    item.tmdName = tmd.GetProperty("name").ToString();
                                    item.tmdMobile = tmd.GetProperty("mobile").ToString();
                                    item.picture = tmd.GetProperty("picture").ToString();
                                    item.mail = tmd.GetProperty("mail").ToString();
                                }
                            }
                            else return Ok(new { state = 404, msg = "依据钉钉手机号未找到醍摩豆账号！" });

                            //HttpClient httpClient = _http.CreateClient();
                            //string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");
                            //List<string> mobiles = new() { $"{ item.mobile}" };
                            //HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync(url, mobiles);
                            //if (responseMessage.StatusCode == HttpStatusCode.OK)
                            //{
                            //    string temp = responseMessage.Content.ReadAsStringAsync().Result;
                            //    List<JsonElement> json_id = temp.ToObject<List<JsonElement>>();
                            //    if (json_id.Count > 0)
                            //    {
                            //        foreach (var tmd in json_id)
                            //        {
                            //            item.tmdId = tmd.GetProperty("id").ToString();
                            //            item.tmdName = tmd.GetProperty("name").ToString();
                            //            item.tmdMobile = tmd.GetProperty("mobile").ToString();
                            //            item.picture = tmd.GetProperty("picture").ToString();
                            //            item.mail = tmd.GetProperty("mail").ToString();
                            //        }
                            //    }
                            //    else return Ok(new { state = 404, msg = "依据钉钉手机号未找到醍摩豆账号！" });
                            //}

                            strMsg.Append($"{item.tmdName}【{item.tmdId}】醍摩豆账号和{item.name}【{item.userId}】钉钉账户绑定成功");

                            //保存操作记录
                            //await _azureStorage.SaveBILog("tabledd-update", strMsg?.ToString(), _dingDing, httpContext: HttpContext, twebsite: Website, tid: item.tmdId, tname: item.tmdName);
                            await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", strMsg?.ToString(), _dingDing, httpContext: HttpContext, twebsite: Website, tid: item.tmdId, tname: item.tmdName);

                            saveInfo.Add(item);                            
                        }

                        List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, item.tmdId);
                        if (schoolIds.Count > 0)
                        {
                            item.schoolIds = string.Join("|", schoolIds);
                            await table.SaveOrUpdate<DingDingUserInfo>(item);
                        }

                        roles = !string.IsNullOrEmpty($"{item.roles}") ? new List<string>(item.roles.Split(",")) : new List<string>();
                        permissions = !string.IsNullOrEmpty($"{item.permissions}") ? new List<string>(item.permissions.Split(",")) : new List<string>();
                        if (item.depts.Contains($"{proDeptId}")) isExploit = true;
                        if (item.deptId == long.Parse($"{proDeptId}")) isExploit = true;
                        if (item.pid == long.Parse($"{proDeptId}")) isExploit = true;

                        //自己写的
                        id_token = JwtAuth.CreateAuthTokenBI(_option.HostName, item.tmdId?.ToString(), item.tmdName?.ToString(), item.picture?.ToString(), _option.JwtSecretKey, scope: "assist", webSite: Website, isex: isExploit, item.userId?.ToString(), item.name?.ToString(), item.avatar?.ToString(), roles: roles?.ToArray(), permissions: permissions?.ToArray(), expire: 3);

                        (osblob_uri, osblob_sas) = roles.Contains("assist") ? _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
                    }
                    if (saveInfo.Count > 0)
                    {
                        ddusers = await table.UpdateAll<DingDingUserInfo>(saveInfo);
                    }
                }
                else
                {
                    DingDingUserInfo ddUserInfo = new()
                    {
                        PartitionKey = divide,
                        RowKey = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString(),
                        userId = v2GetResponse.Result.Userid,
                        unionId = v2GetResponse.Result.Unionid,
                        name = v2GetResponse.Result.Name,
                        title = v2GetResponse.Result.Title,
                        mobile = v2GetResponse.Result.Mobile,
                        jobNumber = v2GetResponse.Result.JobNumber,
                        pid = 0,
                        deptId = 0,
                        deptName = null,
                        depts = string.Join(",", v2GetResponse.Result.DeptIdList.ToArray()),
                        avatar = v2GetResponse.Result.Avatar,
                        isAdmin = v2GetResponse.Result.Admin,
                        roles = "assist",
                        permissions = "abilitystandard-read,batcharea-read,batchschool-read,orgusers-read"
                    };

                    if (!string.IsNullOrEmpty($"{ddUserInfo.mobile}"))
                    {
                        HttpClient httpClient = _http.CreateClient();
                        string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");

                        List<string> mobiles = new() { $"{ ddUserInfo.mobile}" };
                        HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync(url, mobiles);
                        if (responseMessage.StatusCode == HttpStatusCode.OK)
                        {
                            string temp = responseMessage.Content.ReadAsStringAsync().Result;
                            List<JsonElement> json_id = temp.ToObject<List<JsonElement>>();
                            if (json_id.Count > 0)
                            {
                                foreach (var tmd in json_id)
                                {
                                    ddUserInfo.tmdId = tmd.GetProperty("id").ToString();
                                    ddUserInfo.tmdName = tmd.GetProperty("name").ToString();
                                    ddUserInfo.tmdMobile = tmd.GetProperty("mobile").ToString();
                                    ddUserInfo.picture = tmd.GetProperty("picture").ToString();
                                    ddUserInfo.mail = tmd.GetProperty("mail").ToString();
                                }
                            }
                            else return Ok(new { state = 404, msg = "依据钉钉手机号未找到醍摩豆账号！" });
                        }
                    }
                    else return Ok(new { state = 404, msg = "钉钉手机号为空" });

                    List<string> schoolIds = await CommonFind.FindSchoolIds(cosmosClient, ddUserInfo.tmdId);
                    if (schoolIds.Count > 0)
                    {
                        ddUserInfo.schoolIds = string.Join("|", schoolIds);
                    }

                    ddUserInfo = await table.Save<DingDingUserInfo>(ddUserInfo);

                    //保存操作记录
                    //await _azureStorage.SaveBILog("tabledd-update", $"{ddUserInfo.tmdName}【{ddUserInfo.tmdId}】醍摩豆账号和{ddUserInfo.name}【{ddUserInfo.RowKey}】钉钉账户绑定成功", _dingDing, httpContext: HttpContext, tid: ddUserInfo.tmdId, tname: ddUserInfo.tmdName, twebsite: Website);
                    await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", $"{ddUserInfo.tmdName}【{ddUserInfo.tmdId}】醍摩豆账号和{ddUserInfo.name}【{ddUserInfo.RowKey}】钉钉账户绑定成功", _dingDing, httpContext: HttpContext, tid: ddUserInfo.tmdId, tname: ddUserInfo.tmdName, twebsite: Website);

                    roles = !string.IsNullOrEmpty($"{ddUserInfo.roles}") ? new List<string>(ddUserInfo.roles.Split(",")) : new List<string>();
                    permissions = !string.IsNullOrEmpty($"{ddUserInfo.permissions}") ? new List<string>(ddUserInfo.permissions.Split(",")) : new List<string>();
                    if (ddUserInfo.depts.Contains($"{proDeptId}")) isExploit = true;
                    if (ddUserInfo.deptId == long.Parse($"{proDeptId}")) isExploit = true;
                    if (ddUserInfo.pid == long.Parse($"{proDeptId}")) isExploit = true;

                    //自己写的
                    id_token = JwtAuth.CreateAuthTokenBI(_option.HostName, ddUserInfo.tmdId?.ToString(), ddUserInfo.tmdName?.ToString(), ddUserInfo.picture?.ToString(), _option.JwtSecretKey, scope: "assist", webSite: Website, isex: isExploit, ddUserInfo.userId?.ToString(), ddUserInfo.name?.ToString(), ddUserInfo.avatar?.ToString(), roles: roles?.ToArray(), permissions: permissions?.ToArray(), expire: 3);

                    (osblob_uri, osblob_sas) = roles.Contains("assist") ? _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);
                }

                return Ok(new { state = 200, ddUserInfos = ddusers, id_token, roles, permissions, osblob_uri, osblob_sas });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI， {_option.Location} /common/login/get-ddscancode   \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 钉钉绑定醍摩豆
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("set-bind")]
        public async Task<IActionResult> BindUser(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("partitionKey", out JsonElement partitionKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("rowKey", out JsonElement userId)) return BadRequest();
                jsonElement.TryGetProperty("id_token", out JsonElement idtoken);
                jsonElement.TryGetProperty("mobile", out JsonElement mobile);
                jsonElement.TryGetProperty("site", out JsonElement site);
                string Website = "China";
                var tableClient = _azureStorage.GetCloudTableClient();
                var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                    blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                    Website = BIConst.GlobalSite;
                }

                HttpClient httpClient = _http.CreateClient();
                string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");
                var table = _azureStorage.GetCloudTableClient().GetTableReference("BIDDUserInfo");
                var tempUser = await table.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", $"{partitionKey}" }, { "userId", $"{userId}" } });

                var id_token = "";
                var auth_token = "";
                List<DingDingUserInfo> ddUserInfos = new();
                List<string> roles = new();//角色列表
                List<string> permissions = new();//权限列表

                foreach (var itemUser in tempUser)
                {
                    if (!string.IsNullOrEmpty($"{idtoken}"))
                    {
                        JwtSecurityToken jwt = new JwtSecurityToken($"{idtoken}");
                        var tmdId = jwt.Payload.Sub;
                        jwt.Payload.TryGetValue("name", out object tmdName);
                        jwt.Payload.TryGetValue("picture", out object picture);

                        itemUser.tmdId = tmdId;
                        itemUser.tmdName = $"{tmdName}";
                        itemUser.tmdMobile = itemUser.mobile;
                        itemUser.picture = $"{picture}";
                    }

                    if (!string.IsNullOrEmpty($"{mobile}"))
                    {
                        List<string> mobiles = new() { $"{mobile}" };
                        HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync(url, mobiles);
                        if (responseMessage.StatusCode == HttpStatusCode.OK)
                        {
                            var temp = await responseMessage.Content.ReadAsStringAsync();
                            if (temp.Length > 0)
                            {
                                List<JsonElement> itemjson = temp.ToObject<List<JsonElement>>();
                                foreach (var item in itemjson)
                                {
                                    itemUser.tmdId = item.GetProperty("id").ToString();
                                    itemUser.tmdName = item.GetProperty("name").ToString();
                                    itemUser.tmdMobile = item.GetProperty("mobile").ToString();
                                    itemUser.picture = item.GetProperty("picture").ToString();
                                    itemUser.mail = item.GetProperty("mail").ToString();
                                }
                            }
                        }
                        else return Ok(new { state = 404, msg = "手机号未找到醍摩豆账户" });
                    }

                    if (string.IsNullOrEmpty($"{mobile}") && string.IsNullOrEmpty($"{idtoken}"))
                        return Ok(new { state = 400, msg = "mobile、idtoken参数错误" });
                    else
                    {
                        ddUserInfos.Add(itemUser);
                        roles = !string.IsNullOrEmpty($"{itemUser.roles}") ? new List<string>(itemUser.roles.Split(",")) : new List<string>();

                        //保存操作记录
                        //await _azureStorage.SaveBILog("tabledd-update", $"{itemUser.tmdName}【{itemUser.tmdId}】醍摩豆账号和{itemUser.name}【{itemUser.userId}】钉钉账户绑定成功", _dingDing, tid: itemUser.tmdId, tname: itemUser.name, twebsite: Website, httpContext: HttpContext);
                        await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", $"{itemUser.tmdName}【{itemUser.tmdId}】醍摩豆账号和{itemUser.name}【{itemUser.userId}】钉钉账户绑定成功", _dingDing, tid: itemUser.tmdId, tname: itemUser.name, twebsite: Website, httpContext: HttpContext);

                        id_token = JwtAuth.CreateAuthTokenBI(_option.HostName, itemUser.tmdId?.ToString(), itemUser.tmdName?.ToString(), itemUser.picture?.ToString(), _option.JwtSecretKey, scope: "assist", webSite: Website, isex: false, itemUser.userId?.ToString(), itemUser.name?.ToString(), itemUser.avatar?.ToString(), roles: roles?.ToArray(), permissions: permissions?.ToArray(), expire: 3);
                    }
                }

                ddUserInfos = await table.UpdateAll(ddUserInfos);

                //blob 访问权限
                var (osblob_uri, osblob_sas) = roles.Contains("assist") ? _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);

                return Ok(new { state = 200, ddUserInfos, id_token, roles, osblob_uri, osblob_sas });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI， {_option.Location} /common/login/set-bind   \n {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 获取钉钉信息详情绑定醍摩豆和钉钉信息 二合一
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-ddinfo")]
        public async Task<IActionResult> GetDingDingInfo(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("mobile", out JsonElement moile)) return BadRequest();
                if (!jsonElement.TryGetProperty("partitionKey", out JsonElement partitionKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("rowKey", out JsonElement userId)) return BadRequest();
                
                jsonElement.TryGetProperty("site", out JsonElement site); 
                string Website = "China";
                var tableClient = _azureStorage.GetCloudTableClient();
                var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
                if ($"{site}".Equals(BIConst.GlobalSite))
                {
                    tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                    blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                    Website = BIConst.GlobalSite;
                }
                var table = tableClient.GetTableReference("BIDDUserInfo");
                var tempUser = await table.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", $"{partitionKey}" }, { "userId", $"{userId}" } });

                List<string> roles = new();//角色列表
                List<string> permissions = new();//权限列表
                List<DingDingUserInfo> ddUserInfos = new();
                var id_token = "";

                foreach (var itemUser in tempUser)
                {
                    if (!string.IsNullOrEmpty($"{itemUser.tmdId}") && !string.IsNullOrEmpty($"{itemUser.tmdName}"))
                    {
                        //roles = new List<string>(itemUser.roles.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries));
                        roles = !string.IsNullOrEmpty($"{itemUser.roles}") ? new List<string>(itemUser.roles.Split(",")) : new List<string>();
                        permissions = !string.IsNullOrEmpty($"{itemUser.permissions}") ? new List<string>(itemUser.permissions.Split(",")) : new List<string>();
                        ddUserInfos.Add(itemUser);
                    }
                    else
                    {
                        HttpClient httpClient = _http.CreateClient();
                        string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");
                        HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync(url, moile);

                        if (responseMessage.StatusCode == HttpStatusCode.OK)
                        {
                            var temp = await responseMessage.Content.ReadAsStringAsync();
                            if (temp.Length > 0)
                            {
                                List<JsonElement> itemjson = temp.ToObject<List<JsonElement>>();
                                string tmdId = null;
                                string tmdName = null;
                                foreach (var item in itemjson)
                                {
                                    tmdId = item.GetProperty("id").ToString();
                                    tmdName = item.GetProperty("name").ToString();
                                    itemUser.tmdId = tmdId?.ToString();
                                    itemUser.tmdName = tmdName?.ToString();
                                    itemUser.tmdMobile = item.GetProperty("mobile").ToString();
                                    itemUser.picture = item.GetProperty("picture").ToString();
                                    itemUser.mail = item.GetProperty("mail").ToString();
                                    roles = !string.IsNullOrEmpty($"{itemUser.roles}") ? new List<string>(itemUser.roles.Split(",")) : new List<string>();
                                    permissions = !string.IsNullOrEmpty($"{itemUser.permissions}") ? new List<string>(itemUser.permissions.Split(",")) : new List<string>();

                                    ddUserInfos.Add(itemUser);
                                }

                                ddUserInfos = await table.UpdateAll<DingDingUserInfo>(ddUserInfos);

                                //保存操作记录
                                //await _azureStorage.SaveBILog("tabledd-update", $"{tmdName}【{tmdId}】醍摩豆账号和{itemUser.name}【{itemUser.userId}】钉钉账户绑定成功", _dingDing, tid: itemUser.tmdId, tname: itemUser.name, twebsite: Website, httpContext: HttpContext);
                                await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", $"{tmdName}【{tmdId}】醍摩豆账号和{itemUser.name}【{itemUser.userId}】钉钉账户绑定成功", _dingDing, tid: itemUser.tmdId, tname: itemUser.name, twebsite: Website, httpContext: HttpContext);
                            }
                            else return Ok(new { state = 400, message = "该手机没有注册醍摩豆账号信息" });
                        }
                        else return Ok(new { state = responseMessage.StatusCode });
                    }
                    //自己写的
                    id_token = JwtAuth.CreateAuthTokenBI(_option.HostName, itemUser.tmdId?.ToString(), itemUser.tmdName?.ToString(), itemUser.picture?.ToString(), _option.JwtSecretKey, scope: "assist", webSite: Website, isex: false, itemUser.userId?.ToString(), itemUser.name?.ToString(), itemUser.avatar?.ToString(), roles: roles?.ToArray(), permissions: permissions?.ToArray(), expire: 3);
                }

                var (osblob_uri, osblob_sas) = roles.Contains("assist") ? _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Write | BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List | BlobContainerSasPermissions.Delete) : _azureStorage.GetBlobContainerSAS("teammodelos", BlobContainerSasPermissions.Read | BlobContainerSasPermissions.List);

                return Ok(new { state = 200, ddUserInfos, id_token, roles, permissions, osblob_uri, osblob_sas });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI，{_option.Location}  /common/login/get-ddinfo   \n  {ex.Message}\n{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 企业登录
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-commpany")]
        public async Task<IActionResult> GetCommpanyLogin(JsonElement jsonElement)
        {
            if (!jsonElement.TryGetProperty("account", out JsonElement accout)) return BadRequest();
            if (!jsonElement.TryGetProperty("password", out JsonElement password)) return BadRequest();
            jsonElement.TryGetProperty("site", out JsonElement site);

            string Website = "China";
            var cosmosClient = _azureCosmos.GetCosmosClient();
            var tableClient = _azureStorage.GetCloudTableClient();
            var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
            if ($"{site}".Equals(BIConst.GlobalSite))
            {
                cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                Website = BIConst.GlobalSite;
            }

            StringBuilder sqlTxt = new($"select value(c) from c");
            var temps = $"{accout}".Contains($"@");
            if (temps)
                sqlTxt.Append($" where c.emall='{accout}'");
            else
                sqlTxt.Append($" where c.mobile='{accout}'");

            Company company = new();
            List<Company> companies = new();
            string id_token = "";
            await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Normal").GetItemQueryIterator<Company>(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Company") }))
            {
                companies.Add(item);
            }
            if (companies.Count > 0)
            {
                foreach (var item in companies)
                {
                    var hashedPw = Utils.HashedPassword(password.ToString(), item.salt.ToString());
                    if (hashedPw.Equals(item.password))
                    {
                        company = item;
                        id_token = JwtAuth.CreateAuthTokenBI(_option.HostName, item.id?.ToString(), item.name?.ToString(), company.picture?.ToString(), _option.JwtSecretKey, scope: "company", webSite: Website, expire: 3);
                    }
                }
            }
            else return Ok(new { state = 404 });

            //保存操作记录
            //await _azureStorage.SaveBILog("tabledd-update", $"{company.name}【{company.id}】登录商务智能开放平台", _dingDing, tid: company.id, tname: company.name, twebsite: "BI", httpContext: HttpContext);
            await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", $"{company.name}【{company.id}】登录商务智能开放平台", _dingDing, tid: company.id, tname: company.name, twebsite: Website?.ToString(), httpContext: HttpContext);

            return Ok(new { error = 200, id_token, company });
        }

        /// <summary>
        /// 企业注册信息
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [HttpPost("set-registered")]
        public async Task<IActionResult> SetRegistered(JsonElement jsonElement)
        {
            if (!jsonElement.TryGetProperty("name", out JsonElement name)) return BadRequest();
            if (!jsonElement.TryGetProperty("credit", out JsonElement credit)) return BadRequest();
            if (!jsonElement.TryGetProperty("mobile", out JsonElement mobile)) return BadRequest();
            if (!jsonElement.TryGetProperty("password", out JsonElement password)) return BadRequest();
            jsonElement.TryGetProperty("site", out JsonElement site);

            string Website = "China";
            var cosmosClient = _azureCosmos.GetCosmosClient();
            var tableClient = _azureStorage.GetCloudTableClient();
            var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
            if ($"{site}".Equals(BIConst.GlobalSite))
            {
                cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.GlobalSite);
                tableClient = _azureStorage.GetCloudTableClient(BIConst.GlobalSite);
                blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.GlobalSite);
                Website = BIConst.GlobalSite;
            }

            string salt = Utils.CreatSaltString(8);

            string sqltxt = $"select value(c) from c where c.mobile='{mobile}'";
            await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Normal").GetItemQueryStreamIterator(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Company") }))
            {
                using var json = await JsonDocument.ParseAsync(item.ContentStream);
                if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
                {
                    return Ok(new { state = 201, msg = "手机号已存在，" });
                }
            }

            CreateSchoolInfo createCompanyCode = new CreateSchoolInfo()
            {
                province = "",
                id = "",
                name = $"{name}",
                city = "",
                aname = "",
                createCount = 0,
            };

            //生成企业ID
            bool tempStaus = true;
            do
            {
                createCompanyCode = await SchoolCode.GenerateSchoolCode(createCompanyCode, _dingDing, _environment);
                var companyState = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemStreamAsync($"{createCompanyCode.id}", new PartitionKey("Company"));
                if (companyState.Status != 200) tempStaus = false;
                else createCompanyCode.createCount = createCompanyCode.createCount >= 3 ? createCompanyCode.createCount = 3 : createCompanyCode.createCount += 1;
            } while (tempStaus);

            Company company = new() { name = $"{name}", credit = $"{credit}", mobile = $"{mobile}", salt = salt, password = Utils.HashedPassword($"{password}", salt), pk = "Company", code = "Company", createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() };

            company = await cosmosClient.GetContainer("TEAMModelOS", "Normal").CreateItemAsync<Company>(company, new PartitionKey("Company"));

            //保存操作记录
            //await _azureStorage.SaveBILog("tabledd-update", $"{company.name}【{company.id}】注册商务智能开放平台", _dingDing, tid: company.id, tname: company.name, twebsite: "BI", httpContext: HttpContext);
            await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "tabledd-update", $"{company.name}【{company.id}】注册商务智能开放平台", _dingDing, tid: company.id, tname: company.name, twebsite: Website?.ToString(), httpContext: HttpContext);


            return Ok(new { state = 200, company });
        }

        public record DingDingbinds
        {
            public string type { get; set; }

            /// <summary>
            /// 所属部门id列表
            /// </summary>
            public List<long> deptIdList { get; set; }

            /// <summary>
            /// 职位名称
            /// </summary>
            public string title { get; set; }

            /// <summary>
            /// 钉钉用户名
            /// </summary>
            public string name { get; set; }

            /// <summary>
            /// 钉钉unionid
            /// </summary>
            public string unionid { get; set; }

            /// <summary>
            /// 钉钉ID
            /// </summary>
            public string userid { get; set; }
        }

    }
}