TEAMModelOS/TEAMModelBI/Controllers/DingDingStruc/TableDingDingInfoController.cs

using Microsoft.AspNetCore.Http;
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 Microsoft.Extensions.Options;
using System.Net.Http;
using Microsoft.Extensions.Configuration;
using DingTalk.Api;
using DingTalk.Api.Request;
using DingTalk.Api.Response;
using System.Text.Json;
using System.Net.Http.Json;
using TEAMModelOS.SDK.Models.Cosmos.BI;
using System.Net;
using TEAMModelOS.SDK.Extension;
using OpenXmlPowerTools;
using System.Text;
using Azure.Cosmos;
using Microsoft.Azure.Cosmos.Table;
using TEAMModelBI.Filter;
using TEAMModelBI.Tool.Extension;

namespace TEAMModelBI.Controllers.DingDingStruc
{
    [Route("tabledd")]
    [ApiController]
    public class TableDingDingInfoController : ControllerBase
    {
        //读取配置文件
        private readonly IConfiguration _configuration;
        //数据容器
        private readonly AzureCosmosFactory _azureCosmos;
        //blob和table容器
        private readonly AzureStorageFactory _azureStorage;
        //钉钉提示信息
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly IHttpClientFactory _http;

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

        /// <summary>
        /// 从钉钉的组织架构中人员信息数据，并保存或者更新至Blob中
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("get-dingdingusers")]
        public async Task<IActionResult> GetDingDingUser(JsonElement jsonElement)
        {
            try
            {
                string appKey = _configuration["DingDingAuth:appKey"];
                string appSecret = _configuration["DingDingAuth:appSecret"];
                string divide = _configuration["CustomParam:SiteScope"];
                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

                HttpClient httpClient = _http.CreateClient();
                string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");

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

                //access_token的有效期为7200秒（2小时），有效期内重复获取会返回相同结果并自动续期，过期后获取会返回新的access_token
                string access_token = tokenRespone.AccessToken;
                //获取部门接口
                IDingTalkClient deptListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
                //一级部门
                OapiV2DepartmentListsubRequest reqDeptList1 = new OapiV2DepartmentListsubRequest() { DeptId = 1L, Language = "zh_CN" };
                OapiV2DepartmentListsubResponse rspDeptList1 = deptListClient.Execute(reqDeptList1, access_token);

                List<DingDingUserInfo> ddUserInfos = new List<DingDingUserInfo>();

                if (rspDeptList1.Result != null)
                {
                    foreach (var tempDept1 in rspDeptList1.Result)
                    {
                        //获取一级部门用户信息
                        List<DingDingUserInfo> dingDingUserInfos1 = await GetDingDingUserInfo(divide, tempDept1.DeptId, tempDept1.ParentId, tempDept1.Name, access_token);
                        //if (dingDingUserInfos1.Count > 0) ddUserInfos.AddRange(ddUserInfos.Union(dingDingUserInfos1.ToList()));
                        if (dingDingUserInfos1.Count > 0) ddUserInfos.AddRange(dingDingUserInfos1);

                        //获取二级部门
                        OapiV2DepartmentListsubRequest reqDeptList2 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept1.DeptId, Language = "zh_CN" };
                        OapiV2DepartmentListsubResponse rspDeptList2 = deptListClient.Execute(reqDeptList2, access_token);
                        if (rspDeptList2.Result != null)
                        {
                            foreach (var tempDept2 in rspDeptList2.Result)
                            {
                                //获取二级部门用户信息
                                List<DingDingUserInfo> dingDingUserInfos2 = await GetDingDingUserInfo(divide, tempDept2.DeptId, tempDept2.ParentId, tempDept2.Name, access_token);
                                //if (dingDingUserInfos2.Count > 0) ddUserInfos.AddRange(ddUserInfos.Union(dingDingUserInfos2.ToList()));
                                if (dingDingUserInfos2.Count > 0) ddUserInfos.AddRange(dingDingUserInfos2);

                                //获取三级部门
                                OapiV2DepartmentListsubRequest reqDeptList3 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept2.DeptId, Language = "zh_CN" };
                                OapiV2DepartmentListsubResponse rspDeptList3 = deptListClient.Execute(reqDeptList3, access_token);
                                if (rspDeptList3.Result != null)
                                {
                                    foreach (var tempDept3 in rspDeptList3.Result)
                                    {
                                        //获取三级部门用户信息
                                        List<DingDingUserInfo> dingDingUserInfos3 = await GetDingDingUserInfo(divide, tempDept3.DeptId, tempDept3.ParentId, tempDept3.Name, access_token);
                                        //if (dingDingUserInfos3.Count > 0) ddUserInfos.AddRange(ddUserInfos.Union(dingDingUserInfos3.ToList()));
                                        if (dingDingUserInfos3.Count > 0) ddUserInfos.AddRange(dingDingUserInfos3);

                                        //获取四级部门
                                        OapiV2DepartmentListsubRequest reqDeptList4 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept3.DeptId, Language = "zh_CN" };
                                        OapiV2DepartmentListsubResponse rspDeptList4 = deptListClient.Execute(reqDeptList4, access_token);
                                        if (rspDeptList4.Result != null)
                                        {
                                            foreach (var tempDept4 in rspDeptList4.Result)
                                            {
                                                //获取四级部门用户信息
                                                List<DingDingUserInfo> dingDingUserInfos4 = await GetDingDingUserInfo(divide, tempDept4.DeptId, tempDept4.ParentId, tempDept4.Name, access_token);
                                                //if (dingDingUserInfos4.Count > 0) ddUserInfos.AddRange(ddUserInfos.Union(dingDingUserInfos4.ToList()));
                                                if (dingDingUserInfos4.Count > 0) ddUserInfos.AddRange(dingDingUserInfos4);

                                                //获取五级部门
                                                OapiV2DepartmentListsubRequest reqDeptList5 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept4.DeptId, Language = "zh_CN" };
                                                OapiV2DepartmentListsubResponse rspDeptList5 = deptListClient.Execute(reqDeptList5, access_token);
                                                if (rspDeptList5.Result != null)
                                                {
                                                    foreach (var tempDept5 in rspDeptList5.Result)
                                                    {
                                                        //获取五级部门用户信息
                                                        List<DingDingUserInfo> dingDingUserInfos5 = await GetDingDingUserInfo(divide, tempDept5.DeptId, tempDept5.ParentId, tempDept5.Name, access_token);
                                                        //if (dingDingUserInfos5.Count > 0) ddUserInfos.AddRange(ddUserInfos.Union(dingDingUserInfos5).ToList());
                                                        if (dingDingUserInfos5.Count > 0) ddUserInfos.AddRange(dingDingUserInfos5);

                                                    }
                                                }
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }

                //保存操作记录
                await _azureStorage.SaveLog("tabledd-update", $"{_tmdName}【{_tmdId}】从钉钉组织结构更新至Azure Table表【DDUserInfo】中。", _dingDing, httpContext: HttpContext);

                var tempddUserInfos = ddUserInfos.GroupBy(c => c.RowKey).Select(c => c.First()).ToList();//去重
                //List<DingDingUserInfo> TempdingDingUserInfos = await _azureStorage.SaveOrUpdateAll(dingDingUserInfos);  //只是保存至Table
                List<DingDingUserInfo> TempdingDingUserInfos = await _azureStorage.SaveOrUpdateAll(tempddUserInfos);  //保存和修改至Table
                return Ok(new { state = 200, UserInfo = TempdingDingUserInfos });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI，{_option.Location}  /tabledd/get-dingdingusers  \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 查询钉钉信息和醍摩豆信息
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-ddusers")]
        public async Task<IActionResult> GetDingDingUsers()
        {
            try
            {
                string divide = _configuration["CustomParam:SiteScope"];
                Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", $"{divide}" } };
                List<DingDingUserInfo> ddUserInfoList = await _azureStorage.FindListByDict<DingDingUserInfo>(dic);

                List<ddUserInfo> ddUserInfos = new();
                foreach (var item in ddUserInfoList)
                {
                    ddUserInfo ddUserInfo = new ddUserInfo()
                    {
                        partitionKey = item.PartitionKey,
                        rowKey = item.RowKey,
                        unionId = item.unionId,
                        name = item.name,
                        title = item.title,
                        mobile = item.mobile,
                        jobNumber = item.jobNumber,
                        pid = item.pid,
                        deptId = item.deptId,
                        deptName = item.deptName,
                        depts = item.depts,
                        avatar = item.avatar,
                        isAdmin = item.isAdmin,
                        tmdId = item.tmdId,
                        tmdName = item.tmdName,
                        tmdMobile = item.tmdMobile,
                        mail = item.mail,
                        picture = item.picture,
                        roles = item.roles,
                        permissions = item.permissions,
                        handleRoles = !string.IsNullOrEmpty($"{item.roles}") ? new List<string>(item.roles.Split(",")) : new List<string>(),
                        handlePermissions = !string.IsNullOrEmpty($"{item.permissions}") ? new List<string>(item.permissions.Split(",")) : new List<string>(),
                    };
                    ddUserInfos.Add(ddUserInfo);
                }
                return Ok(new { state = 200, ddUserInfos = ddUserInfos });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI，{_option.Location} /tabledd/get-ddusers  \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 查询钉钉待入职人员的ID添加至Table数据表中
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("set-ddinductionuser")]
        public async Task<IActionResult> SetDingDingInductionUser(JsonElement jsonElement)
        {
            try
            {
                string appKey = _configuration["DingDingAuth:appKey"];
                string appSecret = _configuration["DingDingAuth:appSecret"];
                string divide = _configuration["CustomParam:SiteScope"];
                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

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

                //access_token的有效期为7200秒（2小时），有效期内重复获取会返回相同结果并自动续期，过期后获取会返回新的access_token
                string access_token = response.AccessToken;

                IDingTalkClient InductionClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querypreentry");
                OapiSmartworkHrmEmployeeQuerypreentryRequest reqInduction = new OapiSmartworkHrmEmployeeQuerypreentryRequest() { Offset = 0L, Size = 50 };
                reqInduction.SetHttpMethod("GET");
                OapiSmartworkHrmEmployeeQuerypreentryResponse rspInduction = InductionClient.Execute(reqInduction, access_token);
                if (rspInduction.Result.DataList != null)
                {
                    List<DingDingUserInfo> ddUserInfos = new List<DingDingUserInfo>();
                    foreach (var itemId in rspInduction.Result.DataList)
                    {
                        DingDingUserInfo ddUserInfo = new DingDingUserInfo();
                        ddUserInfo.PartitionKey = divide;
                        ddUserInfo.RowKey = itemId;
                        ddUserInfos.Add(ddUserInfo);
                    }

                    List<DingDingUserInfo> tempddUserInfos = await _azureStorage.SaveAll(ddUserInfos);

                    //保存操作记录
                    await _azureStorage.SaveLog("tabledd-add", $"{_tmdName}【{_tmdId}】添加待入职员工至table数据表中", _dingDing, httpContext: HttpContext);

                    if (ddUserInfos.Count == tempddUserInfos.Count)
                    {
                        return Ok(new { state = 200, UserInfo = tempddUserInfos });
                    }
                    else
                    {
                        var diffArr = tempddUserInfos.Where(c => !ddUserInfos.Contains(c)).ToList();
                        return Ok(new { state = 201, notUserInfo = diffArr });
                    }
                }
                else
                {
                    return Ok(new { state = 400, rspInduction.SubErrCode, rspInduction.SubErrMsg });
                }
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI，{_option.Location}  /tabledd/set-ddinductionuser   \n  {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 获取钉钉离职人员ID并删除Table表中的数据
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("del-ddquituser")]
        public async Task<IActionResult> DeleteDDQuitUser(JsonElement jsonElement)
        {
            try
            {
                string appKey = _configuration["DingDingAuth:appKey"];
                string appSecret = _configuration["DingDingAuth:appSecret"];
                string divide = _configuration["CustomParam:SiteScope"];

                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

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

                //access_token的有效期为7200秒（2小时），有效期内重复获取会返回相同结果并自动续期，过期后获取会返回新的access_token
                string access_token = response.AccessToken;

                IDingTalkClient quitStaffClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/smartwork/hrm/employee/querydimission");
                OapiSmartworkHrmEmployeeQuerydimissionRequest reqDimission = new OapiSmartworkHrmEmployeeQuerydimissionRequest() { Offset = 0L, Size = 50L };
                OapiSmartworkHrmEmployeeQuerydimissionResponse rspDimission = quitStaffClient.Execute(reqDimission, access_token);
                if (rspDimission.Result != null)
                {
                    List<DingDingUserInfo> ddUserInfos = new List<DingDingUserInfo>();
                    foreach (var itemId in rspDimission.Result.DataList)
                    {
                        await _azureStorage.DeleteSingle<DingDingUserInfo>(divide, $"{itemId}");
                    }

                    //保存操作记录
                    await _azureStorage.SaveLog("tabledd-del", $"{_tmdName}【{_tmdId}】从table数据表中删除离职员工", _dingDing, httpContext: HttpContext);

                    return Ok(new { state = 200 });
                }
                else
                {
                    return Ok(new { state = rspDimission.SubErrCode });
                }

            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI，{_option.Location}   /tabledd/del-ddquituser   \n  {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }

        /// <summary>
        /// 更新钉钉和醍摩豆的BI权限
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("set-permissions")]
        public async Task<IActionResult> SetPermissions(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("partitionKey", out JsonElement partitionKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("rowKey", out JsonElement userId)) return BadRequest();
                if (!jsonElement.TryGetProperty("permissions", out JsonElement _permissions)) return BadRequest();
                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

                StringBuilder stringBuilder = new StringBuilder($"{_tmdName}【{_tmdId}】醍摩豆账号");
                List<DingDingUserInfo> ddUserInfo = new List<DingDingUserInfo>();
                var tempUser = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", $"{partitionKey}" }, { "RowKey", $"{userId}" } });
                List<string> listper = _permissions.ToObject<List<string>>();
                List<string> roles = new();//角色列表
                List<string> permissions = new List<string>();//权限列表

                foreach (var item in tempUser)
                {
                    stringBuilder.Append($"操作醍摩豆账户{item.tmdName}【{item.tmdId}】修改权限:{string.Join("|", listper.ToArray())}");
                    if (string.IsNullOrEmpty($"{item.roles}"))
                    {
                        item.roles = "assist";
                    }

                    string tempPermissions = "";
                    foreach (var itemPer in listper)
                    {
                        tempPermissions += !string.IsNullOrEmpty($"{tempPermissions}") ? $",{itemPer}" : $"{itemPer}";
                    }
                    item.permissions = tempPermissions;
                    ddUserInfo.Add(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>();
                }

                ddUserInfo = await _azureStorage.UpdateAll<DingDingUserInfo>(ddUserInfo);

                //保存操作记录
                await _azureStorage.SaveLog("tabledd-update", stringBuilder?.ToString(), _dingDing, httpContext: HttpContext);

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


        /// <summary>
        /// 依据部门ID获取部门列表
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-dddeptiduser")]
        public async Task<IActionResult> GetDDDeptIdUser(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("deptId", out JsonElement deptId)) return BadRequest();
                string divide = _configuration["CustomParam:SiteScope"];

                Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", $"{divide}" } };
                List<DingDingUserInfo> tempUserInfos = await _azureStorage.FindListByDict<DingDingUserInfo>(dic);

                List<DingDingUserInfo> userInfo = new();
                tempUserInfos.ForEach(x => {
                    if (x.depts.Contains($"{deptId}"))
                    {
                        userInfo.Add(x);
                    }

                    if (x.pid.Equals(long.Parse($"{deptId}")))
                    {
                        userInfo.Add(x);
                    }
                });
                //userInfo.Distinct().ToList(); //Equals实现去重
                userInfo.Where((x, i) => userInfo.FindIndex(z => z.RowKey.Equals(x.RowKey)) == i);//Lambda表达式去重
                //userInfo.GroupBy(p => p).Select(p => p.Key).ToList();//去重复

                //List<DingDingUserInfo> ddUserInfo = new();
                //List<DingDingUserInfo> tempUser = new();

                //tempUser = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "deptId", $"{deptId}" } });
                //if (tempUser.Count == 0)
                //{
                //    tempUser = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "pid", $"{deptId}" } });
                //}

                //foreach (var itemUser in tempUser)
                //{
                //    var tempUser1 = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "pid", $"{deptId}" } });
                //    foreach (var itemUser1 in tempUser1)
                //    {
                //        if (!long.Parse($"{deptId}").Equals(itemUser1.pid))
                //        {
                //            var tempUser2 = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "pid", $"{itemUser1.pid}" } });
                //            foreach (var itemUser2 in tempUser2)
                //            {
                //                if (!itemUser1.pid.Equals(itemUser2.pid))
                //                {
                //                    var tempUser3 = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "pid", $"{itemUser2.pid}" } });
                //                    foreach (var itemUser3 in tempUser3)
                //                    {
                //                        if (!itemUser2.pid.Equals(itemUser3.pid))
                //                        {
                //                            var tempUser4 = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "pid", $"{itemUser3.pid}" } });
                //                            foreach (var itemUser4 in tempUser4)
                //                            {
                //                                if (!itemUser3.pid.Equals(itemUser4.pid)) { }
                //                                if (ddUserInfo.Find(x => x.RowKey.Equals(itemUser4.RowKey)) == null)
                //                                {
                //                                    ddUserInfo.Add(itemUser4);
                //                                }
                //                            }
                //                        }
                //                        if (ddUserInfo.Find(x => x.RowKey.Equals(itemUser3.RowKey)) == null)
                //                        {
                //                            ddUserInfo.Add(itemUser3);
                //                        }
                //                    }
                //                }
                //                if (ddUserInfo.Find(x => x.RowKey.Equals(itemUser2.RowKey)) == null)
                //                {
                //                    ddUserInfo.Add(itemUser2);
                //                }
                //            }
                //        }
                //        if (ddUserInfo.Find(x => x.RowKey.Equals(itemUser1.RowKey)) == null)
                //        {
                //            ddUserInfo.Add(itemUser1);
                //        }
                //    }
                //    if (ddUserInfo.Find(x => x.RowKey.Equals(itemUser.RowKey)) == null)
                //    {
                //        ddUserInfo.Add(itemUser);
                //    }
                //}

                List<ddUserInfo> ddUserInfos = new();
                foreach (var item in userInfo)
                {
                    ddUserInfo tempUserInfo = new ddUserInfo()
                    {
                        partitionKey = item.PartitionKey,
                        rowKey = item.RowKey,
                        unionId = item.unionId,
                        name = item.name,
                        title = item.title,
                        mobile = item.mobile,
                        jobNumber = item.jobNumber,
                        pid = item.pid,
                        deptId = item.deptId,
                        deptName = item.deptName,
                        depts = item.depts,
                        avatar = item.avatar,
                        isAdmin = item.isAdmin,
                        tmdId = item.tmdId,
                        tmdName = item.tmdName,
                        tmdMobile = item.tmdMobile,
                        mail = item.mail,
                        picture = item.picture,
                        roles = item.roles,
                        permissions = item.permissions,
                        handleRoles = !string.IsNullOrEmpty($"{item.roles}") ? new List<string>(item.roles.Split(",")) : new List<string>(),
                        handlePermissions = !string.IsNullOrEmpty($"{item.permissions}") ? new List<string>(item.permissions.Split(",")) : new List<string>(),
                    };
                    ddUserInfos.Add(tempUserInfo);
                }

                return Ok(new { state = 200, ddUserInfos });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI， {_option.Location}   /tabledd/get-dddeptiduser \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }
        }
        
        /// <summary>
        /// 后端钉钉账户和醍摩豆账户进行绑定
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "assist")]
        [HttpPost("set-backenbind")]
        public async Task<IActionResult> SetBackenBind(JsonElement jsonElement) 
        {
            try
            {
                if (!jsonElement.TryGetProperty("rowKey", out JsonElement rowKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("mobile", out JsonElement mobile)) return BadRequest();

                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
                List<DingDingUserInfo> tempddUsers = null;
                List<DingDingUserInfo> ddUsers = new List<DingDingUserInfo>();
                StringBuilder tableSql = new StringBuilder();

                if (!string.IsNullOrEmpty($"{rowKey}"))
                    tableSql.Append($"RowKey {QueryComparisons.Equal}  '{rowKey}'");

                string tmdId = null;
                string tmdName = null;
                string tmdMobile = null;
                string mail = null;
                string picture = null;

                HttpClient httpClient = _http.CreateClient();
                string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");
                List<string> mobiles = new List<string>() { $"{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 item in json_id)
                        {
                            tmdId = item.GetProperty("id").ToString();
                            tmdName = item.GetProperty("name").ToString();
                            tmdMobile = item.GetProperty("mobile").ToString();
                            mail = item.GetProperty("mail").ToString();
                            picture = item.GetProperty("picture").ToString();
                        }
                    }
                    else return Ok(new { state = 1, message = "该手机号未找到醍摩豆账户" });
                }

                tempddUsers = await _azureStorage.QueryWhereString<DingDingUserInfo>(tableSql.ToString());

                if (tempddUsers.Count > 0)
                {
                    foreach (var item in tempddUsers)
                    {
                        if (item.RowKey.Equals($"{rowKey}"))
                        {
                            item.tmdId = tmdId;
                            item.tmdName = tmdName;
                            item.tmdMobile = tmdMobile;
                            item.mail = mail;
                            item.picture = picture;

                            ddUsers.Add(item);
                        }
                    }
                }
                else return Ok(new { state = 2, message = "钉钉ID错误请检查钉钉ID" });
                if (ddUsers.Count > 0) ddUsers = await _azureStorage.SaveOrUpdateAll(ddUsers);

                //保存操作记录
                await _azureStorage.SaveLog("tabledd-update", $"{_tmdName}【{_tmdId}】操作：绑定钉钉账户[{rowKey}]和醍摩豆账户[{tmdId}]", _dingDing, httpContext: HttpContext);

                return Ok(new { state = 200, ddUsers });
            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI， {_option.Location}   /tabledd/set-backenbind \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
                return BadRequest();
            }        
        }

        /// <summary>
        /// 设置系统管理员
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [AuthToken(Roles = "admin")]
        [HttpPost("set-backend")]
        public async Task<IActionResult> SetBackendAdmin(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("columnKey", out JsonElement partitionKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("rowKey", out JsonElement rowKey)) return BadRequest();
                if (!jsonElement.TryGetProperty("isAdmin", out JsonElement isAdmin)) return BadRequest();

                var (_tmdId, _tmdName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);

                var tempUser = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "PartitionKey", $"{partitionKey}" }, { "RowKey", $"{rowKey}" } });
                List<ddUserInfo> ddUserInfos = new();
                List<string> roles = new();//角色列表
                List<string> permissions = new List<string>();//权限列表

                StringBuilder msg = new StringBuilder($"{_tmdName}【{_tmdId}】");
                if (bool.Parse($"{isAdmin}") == true)
                {
                    foreach (var user in tempUser)
                    {
                        if (string.IsNullOrEmpty(user.roles))
                        {
                            user.roles = "admin,assist";
                        }
                        List<string> tempRoles = new List<string>(user.roles.Split(","));
                        if (!tempRoles.Contains("admin"))
                        {
                            tempRoles.Add("admin");
                        }
                        user.roles = string.Join(",", tempRoles);

                        DingDingUserInfo respUser = await _azureStorage.SaveOrUpdate<DingDingUserInfo>(user);

                        if (respUser != null)
                        {
                            roles = !string.IsNullOrEmpty($"{respUser.roles}") ? new List<string>(respUser.roles.Split(",")) : new List<string>();
                        }
                    }
                }
                else
                {
                    foreach (var user in tempUser)
                    {
                        List<string> tempRoles = new List<string>(user.roles.Split(","));                        
                        if (tempRoles.Contains("admin")) 
                        {
                            tempRoles.Remove("admin");
                        }
                        user.roles = string.Join(",", tempRoles);

                        DingDingUserInfo respUser = await _azureStorage.SaveOrUpdate<DingDingUserInfo>(user);

                        if (respUser != null)
                        {
                            roles = !string.IsNullOrEmpty($"{respUser.roles}") ? new List<string>(respUser.roles.Split(",")) : new List<string>();
                            msg.Append($"取消{respUser.name}【{respUser.RowKey}】账号的BI管理员");
                        }
                    }
                }

                //保存操作记录
                await _azureStorage.SaveLog("tabledd-update", msg.ToString(), _dingDing, httpContext: HttpContext);

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

            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI， {_option.Location}   /tabledd/set-backend \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);

                return BadRequest();
            }
        }



        /// <summary>
        /// 获取钉钉用户信息
        /// 并查询本地Table数据表中是否存在
        /// </summary>
        /// <param name="deptId"></param>
        /// <param name="parentId"></param>
        /// <param name="name"></param>
        /// <param name="access_token"></param>
        /// <returns></returns>
        public async Task<List<DingDingUserInfo>> GetDingDingUserInfo(string partitionKey, long deptId, long parentId, string name, string access_token)
        {
            List<DingDingUserInfo> ddUserInfos = new List<DingDingUserInfo>();

            //获取部门人员信息
            IDingTalkClient userListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/list");

            //获取部门用户
            OapiV2UserListRequest reqUserList = new OapiV2UserListRequest()
            {
                DeptId = deptId,
                Cursor = 0L,
                Size = 50L,
                OrderField = "custom",
                Language = "zh_CN"
            };
            reqUserList.SetHttpMethod("GET");
            OapiV2UserListResponse rspV2UserList = userListClient.Execute(reqUserList, access_token);

            if (rspV2UserList.Result.List != null)
            {
                foreach (var itemUser in rspV2UserList.Result.List)
                {
                    var tempInfo = ddUserInfos.Find(x => x.RowKey.Equals(itemUser.Unionid));
                    if (string.IsNullOrEmpty($"{tempInfo}"))
                    {
                        var tableUsers = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "RowKey", $"{itemUser.Userid}" }, { "unionId", $"{itemUser.Unionid}" } });
                        if (tableUsers.Count > 0)
                        {
                            foreach (var tableUser in tableUsers)
                            {
                                DingDingUserInfo ddUserInfo = new DingDingUserInfo();
                                ddUserInfo.PartitionKey = tableUser.PartitionKey;
                                ddUserInfo.RowKey = itemUser.Userid;
                                ddUserInfo.unionId = itemUser.Unionid;
                                ddUserInfo.name = itemUser.Name;
                                ddUserInfo.title = itemUser.Title;
                                ddUserInfo.mobile = itemUser.Mobile;
                                ddUserInfo.jobNumber = itemUser.JobNumber;
                                ddUserInfo.pid = parentId;
                                ddUserInfo.deptId = deptId;
                                ddUserInfo.deptName = name;
                                ddUserInfo.depts = string.Join(",", itemUser.DeptIdList.ToArray());
                                ddUserInfo.avatar = itemUser.Avatar;
                                ddUserInfo.isAdmin = itemUser.Admin;
                                ddUserInfo.PartitionKey = partitionKey;
                                ddUserInfo.tmdId = tableUser.tmdId;
                                ddUserInfo.tmdName = tableUser.tmdName;
                                ddUserInfo.tmdMobile = tableUser.tmdMobile;
                                ddUserInfo.mail = tableUser.mail;
                                ddUserInfo.picture = tableUser.picture;
                                ddUserInfo.roles = tableUser.roles;
                                ddUserInfo.permissions = tableUser.permissions;

                                ddUserInfos.Add(ddUserInfo);
                            }
                        }
                        else
                        {
                            DingDingUserInfo ddUserInfo = new DingDingUserInfo();
                            ddUserInfo.RowKey = itemUser.Userid;
                            ddUserInfo.unionId = itemUser.Unionid;
                            ddUserInfo.name = itemUser.Name;
                            ddUserInfo.title = itemUser.Title;
                            ddUserInfo.mobile = itemUser.Mobile;
                            ddUserInfo.jobNumber = itemUser.JobNumber;
                            ddUserInfo.pid = parentId;
                            ddUserInfo.deptId = deptId;
                            ddUserInfo.deptName = name;
                            ddUserInfo.depts = string.Join(",", itemUser.DeptIdList.ToArray());
                            ddUserInfo.avatar = itemUser.Avatar;
                            ddUserInfo.isAdmin = itemUser.Admin;
                            ddUserInfo.PartitionKey = partitionKey;
                            ddUserInfo.tmdId = "";
                            ddUserInfo.tmdName = "";
                            ddUserInfo.tmdMobile = "";
                            ddUserInfo.mail = "";
                            ddUserInfo.picture = "";
                            ddUserInfo.roles = "assist";
                            ddUserInfo.permissions = "abilitystandard-read,batcharea-read,batchschool-read,orgusers-read";

                            ddUserInfos.Add(ddUserInfo);
                        }
                    }
                }
            }

            return ddUserInfos;
        }

        public record ddUserInfo
        {
            public string partitionKey { get; set; }
            public string rowKey { get; set; }
            public string unionId { get; set; }
            public string name { get; set; }
            public string title { get; set; }
            public string mobile { get; set; }
            public string jobNumber { get; set; }
            public long pid { get; set; }
            public long deptId { get; set; }
            public string deptName { get; set; }
            public string depts { get; set; }
            public string avatar { get; set; }
            public bool isAdmin { get; set; }
            public string tmdId { get; set; }
            public string tmdName { get; set; }
            public string tmdMobile { get; set; }
            public string mail { get; set; }
            public string picture { get; set; }
            public string roles { get; set; }
            public string permissions { get; set; }
            public List<string> handleRoles { get; set; }
            public List<string> handlePermissions { get; set; }
        }
    }
}