12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613 |
- using DingTalk.Api;
- using DingTalk.Api.Request;
- using DingTalk.Api.Response;
- using Microsoft.AspNetCore.Http;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Configuration;
- using Microsoft.Extensions.Options;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text.Json;
- using System.Threading.Tasks;
- using TEAMModelOS.Models;
- using TEAMModelOS.SDK.DI;
- using TEAMModelOS.SDK.Extension;
- using TEAMModelOS.SDK.Models.Service;
- using Azure.Cosmos;
- using TEAMModelOS.SDK.Models;
- using TEAMModeBI.Controllers.BISchool;
- using TEAMModelOS.SDK.Models.Cosmos.BI;
- using Microsoft.Azure.Cosmos.Table;
- namespace TEAMModeBI.Controllers.DingDingStruc
- {
- [ProducesResponseType(StatusCodes.Status200OK)]
- [ProducesResponseType(StatusCodes.Status400BadRequest)]
- [Route("dd")]
- [ApiController]
- public class DDStructController : ControllerBase
- {
- private readonly IConfiguration _configuration;
- //数据容器
- private readonly AzureCosmosFactory _azureCosmos;
- //文件容器
- private readonly AzureStorageFactory _azureStorage;
- //钉钉提示信息
- private readonly DingDing _dingDing;
- //雪花ID
- private readonly SnowflakeId _snowflakeId;
- private readonly Option _option;
- public DDStructController(IConfiguration configuration, AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option, CoreAPIHttpService aoreAPIHttpService, SnowflakeId snowflakeId)
- {
- _configuration = configuration;
- _azureCosmos = azureCosmos;
- _azureStorage = azureStorage;
- _dingDing = dingDing;
- _option = option?.Value;
- _snowflakeId = snowflakeId;
- }
- /// <summary>
- /// 获取分支组织列表信息
- /// </summary>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("ddbranchstruc")]
- public async Task<IActionResult> DDBranchStruc()
- {
- string str_appKey = _configuration["DingDingAuth:appKey"];
- string str_appSecret = _configuration["DingDingAuth:appSecret"];
- //获取企业内部应用的accessToken
- IDingTalkClient Iclient = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
- OapiGettokenRequest request = new OapiGettokenRequest();
- request.Appkey = str_appKey;
- request.Appsecret = str_appSecret;
- request.SetHttpMethod("GET");
- OapiGettokenResponse tokenResponse = Iclient.Execute(request);
- if (tokenResponse.IsError)
- {
- return Ok(new { state = 0, message = "请检查配置" });
- }
- IDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/org/union/branch/get");
- OapiOrgUnionBranchGetRequest req = new OapiOrgUnionBranchGetRequest();
- OapiOrgUnionBranchGetResponse rsp = client.Execute(req, tokenResponse.AccessToken);
- return Ok(new { Result = rsp.Result, Body = rsp.Body, RequestId = rsp.RequestId, SubErrCode = rsp.SubErrCode, Success = rsp.Success });
- }
- /// <summary>
- /// 获取企业部门列表
- /// </summary>
- [ProducesDefaultResponseType]
- [HttpPost("get-deptlist")]
- public async Task<IActionResult> GetDeptList()
- {
- try
- {
- string appKey = _configuration["DingDingAuth:appKey"];
- string appSecret = _configuration["DingDingAuth:appSecret"];
- //获取access_token
- DefaultDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
- OapiGettokenRequest request = new OapiGettokenRequest();
- request.Appkey = appKey;
- request.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 v2ListsubClient1 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
- OapiV2DepartmentListsubRequest reqlistsub1 = new OapiV2DepartmentListsubRequest() { DeptId = 1L, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rsplistsub1 = v2ListsubClient1.Execute(reqlistsub1, access_token);
- List<DeptInfo> templsit = new List<DeptInfo>();
- if (rsplistsub1.Result != null)
- {
- foreach (var deptList in rsplistsub1.Result)
- {
- DeptInfo deptInfo = new DeptInfo();
- deptInfo.deptId = deptList.DeptId;
- deptInfo.deptName = deptList.Name;
- deptInfo.parentId = deptList.ParentId;
- //获取一级部门用户列表
- IDingTalkClient userListClient1 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/user/listid");
- OapiUserListidRequest reqUserList1 = new OapiUserListidRequest() { DeptId = deptList.DeptId };
- OapiUserListidResponse rspUserList1 = userListClient1.Execute(reqUserList1, access_token);
- if (rspUserList1.Result != null)
- {
- deptInfo.ddUserList = rspUserList1.Result.UseridList;
- }
- //获取用户详细信息
- IDingTalkClient v2UserListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
- OapiV2UserGetRequest reqv2UserList = new OapiV2UserGetRequest();
- OapiV2UserGetResponse rspv2UserList = v2UserListClient.Execute(reqv2UserList, access_token);
- //获取二级部门列表
- OapiV2DepartmentListsubRequest reqlistsub = new OapiV2DepartmentListsubRequest() { DeptId = deptList.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rsplistsub = v2ListsubClient1.Execute(reqlistsub, access_token);
- List<DeptBaseResponseDomain> deptBaseResponseDomainList = new List<DeptBaseResponseDomain>();
- if (rsplistsub.Result != null)
- {
- foreach (var deptlist2 in rsplistsub.Result)
- {
- //添加二级部门
- DeptBaseResponseDomain deptBaseResponseDomain2 = new DeptBaseResponseDomain();
- deptBaseResponseDomain2.deptId = deptlist2.DeptId;
- deptBaseResponseDomain2.Name = deptlist2.Name;
- deptBaseResponseDomain2.ParentId = deptlist2.ParentId;
- //获取三级部门用户列表
- OapiUserListidRequest reqUserList2 = new OapiUserListidRequest() { DeptId = deptlist2.DeptId };
- OapiUserListidResponse rspUserList2 = userListClient1.Execute(reqUserList2, access_token);
- if (rspUserList2.Result != null)
- {
- //添加三级部门用户
- deptBaseResponseDomain2.ddUserList = rspUserList2.Result.UseridList;
- }
- //获取三级部门列表
- OapiV2DepartmentListsubRequest reqlistsub3 = new OapiV2DepartmentListsubRequest() { DeptId = deptlist2.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rsplistsub3 = v2ListsubClient1.Execute(reqlistsub3, access_token);
- List<DeptBaseResponseDomain> deptBaseResponseDomain3List = new List<DeptBaseResponseDomain>();
- if (rsplistsub3.Result != null)
- {
- foreach (var dept3List in rsplistsub3.Result)
- {
- //添加三级部门
- DeptBaseResponseDomain deptBaseResponseDomain3 = new DeptBaseResponseDomain();
- deptBaseResponseDomain3.deptId = dept3List.DeptId;
- deptBaseResponseDomain3.Name = dept3List.Name;
- deptBaseResponseDomain3.ParentId = dept3List.ParentId;
- //获取部门用户列表
- OapiUserListidRequest reqUserList3 = new OapiUserListidRequest() { DeptId = dept3List.DeptId };
- OapiUserListidResponse rspUserList3 = userListClient1.Execute(reqUserList3, access_token);
- if (rspUserList3.Result != null)
- {
- //添加三级部门的用户
- deptBaseResponseDomain3.ddUserList = rspUserList3.Result.UseridList;
- }
- //获取部门列表 四级目录
- OapiV2DepartmentListsubRequest reqlistsub4 = new OapiV2DepartmentListsubRequest() { DeptId = dept3List.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rsplistsu4 = v2ListsubClient1.Execute(reqlistsub4, access_token);
- List<DeptBaseResponseDomain> deptBaseResponseDomain4List = new List<DeptBaseResponseDomain>();
- if (rsplistsu4.Result != null)
- {
- foreach (var dept4List in rsplistsu4.Result)
- {
- DeptBaseResponseDomain deptBaseResponseDomain4 = new DeptBaseResponseDomain();
- deptBaseResponseDomain4.deptId = dept4List.DeptId;
- deptBaseResponseDomain4.Name = dept4List.Name;
- deptBaseResponseDomain4.ParentId = dept4List.ParentId;
- deptBaseResponseDomain4List.Add(deptBaseResponseDomain4);
- //获取四级部门用户列表
- OapiUserListidRequest reqUserList4 = new OapiUserListidRequest() { DeptId = dept4List.DeptId };
- OapiUserListidResponse rspUserList4 = userListClient1.Execute(reqUserList4, access_token);
- if (rspUserList4.Result != null)
- {
- //添加四级部门的用户
- deptBaseResponseDomain4.ddUserList = rspUserList4.Result.UseridList;
- }
- }
- }
- //添加四级部门列表
- deptBaseResponseDomain3.LowerDeip_List = deptBaseResponseDomain4List;
- deptBaseResponseDomain3List.Add(deptBaseResponseDomain3);
- }
- }
- //添加三级部门列表
- deptBaseResponseDomain2.LowerDeip_List = deptBaseResponseDomain3List;
- deptBaseResponseDomainList.Add(deptBaseResponseDomain2);
- }
- }
- //添加二级部门列表
- deptInfo.deptList = deptBaseResponseDomainList;
- templsit.Add(deptInfo);
- }
- }
- return Ok(new { state = 200, deptlist = templsit });
- }
- catch (Exception ex)
- {
- return Ok(new { state = 1, message=$"查询失败!:状态:{ex.StackTrace}错误:{ex.Message}" }) ;
- }
- }
- /// <summary>
- /// 查询钉钉的研发中心B人员
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("get-tmdandddusers")]
- public async Task<IActionResult> GetTmdAndDdUsers(JsonElement jsonElement)
- {
- try
- {
- jsonElement.TryGetProperty("deptId", out JsonElement deptId);
- string tempDeptId = string.IsNullOrEmpty($"{deptId}") ? "67863053" : $"{deptId}";
- string appKey = _configuration["DingDingAuth:appKey"];
- string appSecret = _configuration["DingDingAuth:appSecret"];
- Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", "authority-bi" } };
- List<Authority> authorityBIList = await _azureStorage.FindListByDict<Authority>(dic);
- //获取access_token
- DefaultDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
- OapiGettokenRequest request = new OapiGettokenRequest();
- request.Appkey = appKey;
- request.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 userListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/list");
- OapiV2UserListRequest reqUserList1 = new OapiV2UserListRequest();
- reqUserList1.DeptId = long.Parse($"{tempDeptId}");
- reqUserList1.Cursor = 0L;
- reqUserList1.Size = 50L;
- reqUserList1.ContainAccessLimit = false;
- reqUserList1.OrderField = "custom";
- reqUserList1.Language = "zh_CN";
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList1 = userListClient.Execute(reqUserList1, access_token);
- List<DDUserInfoAndTMD> dDAndTmdInfos = new List<DDUserInfoAndTMD>();
- List<DingDingUserInfo> ddUserInfos = new List<DingDingUserInfo>();
- if (rspV2UserList1.Result.List != null)
- {
- foreach (var itemUser in rspV2UserList1.Result.List)
- {
- List<DingDingUserInfo> temp = await _azureStorage.FindListByDict<DingDingUserInfo>(new Dictionary<string, object> { { "RowKey", $"{itemUser.Userid}" } });
- foreach (var item in temp)
- {
- ddUserInfos.Add(item);
- }
- //DDUserInfoAndTMD dDAndTmdInfo = new DDUserInfoAndTMD();
- //dDAndTmdInfo.unionid = itemUser.Unionid;
- //dDAndTmdInfo.userid = itemUser.Userid;
- //dDAndTmdInfo.title = itemUser.Title;
- //dDAndTmdInfo.name = itemUser.Name;
- //dDAndTmdInfo.mobile = itemUser.Mobile;
- //dDAndTmdInfo.jobNumber = itemUser.JobNumber;
- //dDAndTmdInfo.avatar = itemUser.Avatar;
- //dDAndTmdInfo.depts = itemUser.DeptIdList;
- //List<string> roles = new List<string>();//角色列表
- //List<string> power = new List<string>();//权限列表
- //string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser.Userid}'";
- //try
- //{
- // await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- // {
- // dDAndTmdInfo.tmdId = item.id;
- // dDAndTmdInfo.isexist = true;
- // if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- // {
- // var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- // if (schoolRoles.Status == 200)
- // {
- // using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- // if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- // {
- // foreach (var obj in _roles.EnumerateArray())
- // {
- // //初始定义顾问的assistant 更改为assist
- // if (obj.GetString().Equals($"assist"))
- // {
- // roles.Add(obj.GetString());
- // }
- // }
- // }
- // if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- // {
- // foreach (var obj in _permissions.EnumerateArray())
- // {
- // //显示BI权限
- // foreach (var aut in authorityBIList)
- // {
- // if (aut.RowKey.Equals(obj.GetString()))
- // {
- // power.Add(obj.GetString());
- // }
- // }
- // }
- // }
- // }
- // dDAndTmdInfo.tmdroles = roles;
- // dDAndTmdInfo.tmdpower = power;
- // }
- // }
- //}
- //catch { }
- }
- }
- if (!string.IsNullOrEmpty($"{tempDeptId}"))
- {
- //获取下级部门列表
- IDingTalkClient v2DeptListClient2 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
- OapiV2DepartmentListsubRequest reqDeptList2 = new OapiV2DepartmentListsubRequest() { DeptId = long.Parse($"{tempDeptId}"), Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptLis2 = v2DeptListClient2.Execute(reqDeptList2, access_token);
- if (rspDeptLis2.Result != null)
- {
- foreach (var tempDept in rspDeptLis2.Result)
- {
- OapiV2UserListRequest reqUserList2 = new OapiV2UserListRequest();
- reqUserList2.DeptId = long.Parse($"{tempDept.DeptId}");
- reqUserList2.Cursor = 0L;
- reqUserList2.Size = 50L;
- reqUserList2.ContainAccessLimit = false;
- reqUserList2.OrderField = "custom";
- reqUserList2.Language = "zh_CN";
- reqUserList2.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList2 = userListClient.Execute(reqUserList2, access_token);
- if (rspV2UserList2.Result.List != null)
- {
- foreach (var itemUser2 in rspV2UserList2.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser2.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo2 = new DDUserInfoAndTMD();
- dDAndTmdInfo2.unionid = itemUser2.Unionid;
- dDAndTmdInfo2.userid = itemUser2.Userid;
- dDAndTmdInfo2.title = itemUser2.Title;
- dDAndTmdInfo2.name = itemUser2.Name;
- dDAndTmdInfo2.mobile = itemUser2.Mobile;
- dDAndTmdInfo2.jobNumber = itemUser2.JobNumber;
- dDAndTmdInfo2.avatar = itemUser2.Avatar;
- dDAndTmdInfo2.depts = itemUser2.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser2.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo2.tmdId = item.id;
- dDAndTmdInfo2.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo2.tmdroles = roles;
- dDAndTmdInfo2.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo2);
- }
- }
- }
- }
- }
- }
- return Ok(new { state = 200, count = ddUserInfos.Count, ddUserInfos }) ;
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"BI,{_option.Location} dd/get-tmdandddusers \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 依据钉钉UserID查询钉钉用户信息
- /// </summary>
- /// <param name="jsonElement"></param>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("get-dduserinfo")]
- public async Task<IActionResult> GetDDUserInfo(JsonElement jsonElement)
- {
- try
- {
- if (!jsonElement.TryGetProperty("userids", out JsonElement userIds)) return Ok(new { state = 1, message = "参数问题" });
- List<DDUserInfoAndTMD> dDUserInfoAndTMDs = new List<DDUserInfoAndTMD>();//返回钉钉信息和查询的醍摩豆信息
- string appKey = _configuration["DingDingAuth:appKey"];
- string appSecret = _configuration["DingDingAuth:appSecret"];
- //获取access_token
- DefaultDingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/gettoken");
- OapiGettokenRequest request = new OapiGettokenRequest();
- request.Appkey = appKey;
- request.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 userInfoClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/get");
- Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", "authority-bi" } };
- List<Authority> authorityBIList = await _azureStorage.FindListByDict<Authority>(dic);
- if (!string.IsNullOrEmpty($"{userIds}"))
- {
- //List<string> str_userids = userIds.ToObject<List<string>>().Distinct().ToList();//通过数组的Equals实现去重
- List<string> str_userids1 = userIds.ToObject<List<string>>();
- List<string> str_userids = str_userids1.Where((x, i) => str_userids1.FindIndex(z => z == x) == i).ToList();//Lambda表达式去重
- foreach (var tempid in str_userids)
- {
- OapiV2UserGetRequest reqUserInfo = new OapiV2UserGetRequest() { Userid = $"{tempid}", Language = "zh_CN" };
- OapiV2UserGetResponse rspUserInfo = userInfoClient.Execute(reqUserInfo, access_token);
- if (rspUserInfo.Result != null)
- {
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- DDUserInfoAndTMD dDUserInfoAndTMD = new DDUserInfoAndTMD();
- dDUserInfoAndTMD.unionid = rspUserInfo.Result.Unionid;
- dDUserInfoAndTMD.title = rspUserInfo.Result.Title;
- dDUserInfoAndTMD.userid = rspUserInfo.Result.Userid;
- dDUserInfoAndTMD.jobNumber = rspUserInfo.Result.JobNumber;
- dDUserInfoAndTMD.name = rspUserInfo.Result.Name;
- dDUserInfoAndTMD.depts = rspUserInfo.Result.DeptIdList;
- dDUserInfoAndTMD.mobile = rspUserInfo.Result.Mobile;
- dDUserInfoAndTMD.avatar = rspUserInfo.Result.Avatar;
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{tempid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDUserInfoAndTMD.tmdId = item.id;
- dDUserInfoAndTMD.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDUserInfoAndTMD.tmdroles = roles;
- dDUserInfoAndTMD.tmdpower = power;
- }
- }
- }
- catch { }
- dDUserInfoAndTMDs.Add(dDUserInfoAndTMD);
- }
- else return Ok(new { state = 2, message = "访问失败!" });
- }
- }
- return Ok(new { state = 200, ddUserInfos = dDUserInfoAndTMDs});
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"BI,{_option.Location},dd/get-dduserinfo \n{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
- return BadRequest();
- }
- }
- /// <summary>
- /// 查询钉钉和醍摩豆绑定信息
- /// </summary>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("get-allusers")]
- public async Task<IActionResult> GetAllUsers()
- {
- string appKey = _configuration["DingDingAuth:appKey"];
- string appSecret = _configuration["DingDingAuth:appSecret"];
- Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", "authority-bi" } };
- List<Authority> authorityBIList = await _azureStorage.FindListByDict<Authority>(dic);
- //获取access_token
- DefaultDingTalkClient 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 v2DeptListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
- OapiV2DepartmentListsubRequest reqDeptList1 = new OapiV2DepartmentListsubRequest() { DeptId = 1L, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList1 = v2DeptListClient.Execute(reqDeptList1, access_token);
- //获取部门人员信息
- IDingTalkClient userListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/list");
- //List<DeptUserInfo> deptUserInfos = new List<DeptUserInfo>();
- //人员集合
- List<DDUserInfoAndTMD> dDAndTmdInfos = new List<DDUserInfoAndTMD>();
- if (rspDeptList1.Result != null)
- {
- foreach (var tempDept1 in rspDeptList1.Result)
- {
- //获取一级
- OapiV2UserListRequest reqUserList1 = new OapiV2UserListRequest()
- {
- DeptId = tempDept1.DeptId,
- Cursor = 0L,
- Size = 50L,
- OrderField = "custom",
- Language= "zh_CN"
- };
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList1 = userListClient.Execute(reqUserList1, access_token);
- if (rspV2UserList1.Result.List != null)
- {
- foreach (var itemUser1 in rspV2UserList1.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser1.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo1 = new DDUserInfoAndTMD();
- dDAndTmdInfo1.unionid = itemUser1.Unionid;
- dDAndTmdInfo1.userid = itemUser1.Userid;
- dDAndTmdInfo1.title = itemUser1.Title;
- dDAndTmdInfo1.name = itemUser1.Name;
- dDAndTmdInfo1.mobile = itemUser1.Mobile;
- dDAndTmdInfo1.jobNumber = itemUser1.JobNumber;
- dDAndTmdInfo1.avatar = itemUser1.Avatar;
- dDAndTmdInfo1.deptId = tempDept1.DeptId;
- dDAndTmdInfo1.deptName = tempDept1.Name;
- //dDAndTmdInfo1.depts = itemUser.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser1.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo1.tmdId = item.id;
- dDAndTmdInfo1.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo1.tmdroles = roles;
- dDAndTmdInfo1.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo1);//添加一级
- }
- }
- }
-
- //获取二级部门
- OapiV2DepartmentListsubRequest reqDeptList2 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept1.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList2 = v2DeptListClient.Execute(reqDeptList2, access_token);
- if (rspDeptList2.Result != null)
- {
- foreach (var tempDept2 in rspDeptList2.Result)
- {
- //获取二级部门用户
- OapiV2UserListRequest reqUserList2 = new OapiV2UserListRequest()
- {
- DeptId = tempDept2.DeptId,
- Cursor = 0L,
- Size = 50L,
- OrderField = "custom",
- Language = "zh_CN"
- };
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList2 = userListClient.Execute(reqUserList2, access_token);
- if (rspV2UserList2.Result.List != null)
- {
- foreach (var itemUser2 in rspV2UserList2.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser2.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo2 = new DDUserInfoAndTMD();
- dDAndTmdInfo2.unionid = itemUser2.Unionid;
- dDAndTmdInfo2.userid = itemUser2.Userid;
- dDAndTmdInfo2.title = itemUser2.Title;
- dDAndTmdInfo2.name = itemUser2.Name;
- dDAndTmdInfo2.mobile = itemUser2.Mobile;
- dDAndTmdInfo2.jobNumber = itemUser2.JobNumber;
- dDAndTmdInfo2.avatar = itemUser2.Avatar;
- dDAndTmdInfo2.deptId = tempDept2.DeptId;
- dDAndTmdInfo2.deptName = tempDept2.Name;
- //dDAndTmdInfo1.depts = itemUser2.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser2.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo2.tmdId = item.id;
- dDAndTmdInfo2.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo2.tmdroles = roles;
- dDAndTmdInfo2.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo2);//添加二级
- }
- }
- }
- //获取三级部门
- OapiV2DepartmentListsubRequest reqDeptList3 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept2.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList3 = v2DeptListClient.Execute(reqDeptList3, access_token);
- if (rspDeptList3.Result != null)
- {
- foreach (var tempDept3 in rspDeptList3.Result)
- {
- //获取三级部门用户
- OapiV2UserListRequest reqUserList3 = new OapiV2UserListRequest()
- {
- DeptId = tempDept3.DeptId,
- Cursor = 0L,
- Size = 50L,
- OrderField = "custom",
- Language = "zh_CN"
- };
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList3 = userListClient.Execute(reqUserList3, access_token);
- if (rspV2UserList3.Result.List != null)
- {
- foreach (var itemUser3 in rspV2UserList3.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser3.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo3 = new DDUserInfoAndTMD();
- dDAndTmdInfo3.unionid = itemUser3.Unionid;
- dDAndTmdInfo3.userid = itemUser3.Userid;
- dDAndTmdInfo3.title = itemUser3.Title;
- dDAndTmdInfo3.name = itemUser3.Name;
- dDAndTmdInfo3.mobile = itemUser3.Mobile;
- dDAndTmdInfo3.jobNumber = itemUser3.JobNumber;
- dDAndTmdInfo3.avatar = itemUser3.Avatar;
- dDAndTmdInfo3.deptId = tempDept3.DeptId;
- dDAndTmdInfo3.deptName = tempDept3.Name;
- //dDAndTmdInfo1.depts = itemUser3.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser3.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo3.tmdId = item.id;
- dDAndTmdInfo3.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo3.tmdroles = roles;
- dDAndTmdInfo3.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo3);//添加二级
- }
- }
- }
- //获取四级部门
- OapiV2DepartmentListsubRequest reqDeptList4 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept2.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList4 = v2DeptListClient.Execute(reqDeptList4, access_token);
- if (rspDeptList4.Result != null)
- {
- foreach (var tempDept4 in rspDeptList4.Result)
- {
- //获取四级部门用户
- OapiV2UserListRequest reqUserList4 = new OapiV2UserListRequest()
- {
- DeptId = tempDept4.DeptId,
- Cursor = 0L,
- Size = 50L,
- OrderField = "custom",
- Language = "zh_CN"
- };
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList4 = userListClient.Execute(reqUserList4, access_token);
- if (rspV2UserList4.Result.List != null)
- {
- foreach (var itemUser4 in rspV2UserList4.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser4.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo3 = new DDUserInfoAndTMD();
- dDAndTmdInfo3.unionid = itemUser4.Unionid;
- dDAndTmdInfo3.userid = itemUser4.Userid;
- dDAndTmdInfo3.title = itemUser4.Title;
- dDAndTmdInfo3.name = itemUser4.Name;
- dDAndTmdInfo3.mobile = itemUser4.Mobile;
- dDAndTmdInfo3.jobNumber = itemUser4.JobNumber;
- dDAndTmdInfo3.avatar = itemUser4.Avatar;
- dDAndTmdInfo3.deptId = tempDept4.DeptId;
- dDAndTmdInfo3.deptName = tempDept4.Name;
- //dDAndTmdInfo1.depts = itemUser3.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser4.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo3.tmdId = item.id;
- dDAndTmdInfo3.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo3.tmdroles = roles;
- dDAndTmdInfo3.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo3);//添加四级用户信息
- }
- }
- }
- //获取五级部门
- OapiV2DepartmentListsubRequest reqDeptList5 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept2.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList5 = v2DeptListClient.Execute(reqDeptList5, access_token);
- if (rspDeptList5.Result != null)
- {
- foreach (var tempDept5 in rspDeptList4.Result)
- {
- //获取五级部门用户
- OapiV2UserListRequest reqUserList5 = new OapiV2UserListRequest()
- {
- DeptId = tempDept5.DeptId,
- Cursor = 0L,
- Size = 50L,
- OrderField = "custom",
- Language = "zh_CN"
- };
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList5 = userListClient.Execute(reqUserList5, access_token);
- if (rspV2UserList5.Result.List != null)
- {
- foreach (var itemUser5 in rspV2UserList5.Result.List)
- {
- var tempInfo = dDAndTmdInfos.Find(x => x.unionid.Equals(itemUser5.Unionid));
- if (string.IsNullOrEmpty($"{tempInfo}"))
- {
- DDUserInfoAndTMD dDAndTmdInfo5 = new DDUserInfoAndTMD();
- dDAndTmdInfo5.unionid = itemUser5.Unionid;
- dDAndTmdInfo5.userid = itemUser5.Userid;
- dDAndTmdInfo5.title = itemUser5.Title;
- dDAndTmdInfo5.name = itemUser5.Name;
- dDAndTmdInfo5.mobile = itemUser5.Mobile;
- dDAndTmdInfo5.jobNumber = itemUser5.JobNumber;
- dDAndTmdInfo5.avatar = itemUser5.Avatar;
- dDAndTmdInfo5.deptId = tempDept5.DeptId;
- dDAndTmdInfo5.deptName = tempDept5.Name;
- //dDAndTmdInfo1.depts = itemUser3.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser5.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo5.tmdId = item.id;
- dDAndTmdInfo5.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo5.tmdroles = roles;
- dDAndTmdInfo5.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo5);//添加五级用户信息
- }
- }
- }
- }
- }
- //五级部门和下面的人员信息 结束
- }
- }
- //四级部门和下面的人员信息 结束
- }
- }
- //三级部门和下面的人员信息 结束
- }
- }
- //三级部门和下面的人员信息 结束
- }
- }
- return Ok(new { state = 200, dDAndTmdInfos });
- }
- /// <summary>
- /// 查询钉钉所有人数 -----还未完成
- /// </summary>
- /// <returns></returns>
- [ProducesDefaultResponseType]
- [HttpPost("get-ddstrucandymdinfo")]
- public async Task<IActionResult> GetDDStrucAndTmdInfo()
- {
- try
- {
- string appKey = _configuration["DingDingAuth:appKey"];
- string appSecret = _configuration["DingDingAuth:appSecret"];
- Dictionary<string, object> dic = new Dictionary<string, object> { { "PartitionKey", "authority-bi" } };
- List<Authority> authorityBIList = await _azureStorage.FindListByDict<Authority>(dic);
- //获取access_token
- DefaultDingTalkClient 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 v2DeptListClient1 = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/department/listsub");
- OapiV2DepartmentListsubRequest reqDeptList1 = new OapiV2DepartmentListsubRequest() { DeptId = 1L, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList1 = v2DeptListClient1.Execute(reqDeptList1, access_token);
- IDingTalkClient userListClient = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/list");
- //var deptlist = rspDeptList1.Result;
- List<DeptStruc> deptStrucs = new List<DeptStruc>();
- if (rspDeptList1.Result != null)
- {
- foreach (var tempDept in rspDeptList1.Result)
- {
- DeptStruc deptStruc = new DeptStruc();
- deptStruc.deptId = tempDept.DeptId;
- deptStruc.parentId = tempDept.ParentId;
- deptStruc.name = tempDept.Name;
- OapiV2UserListRequest reqUserList1 = new OapiV2UserListRequest();
- reqUserList1.DeptId = tempDept.DeptId;
- reqUserList1.Cursor = 0L;
- reqUserList1.Size = 50L;
- reqUserList1.ContainAccessLimit = false;
- reqUserList1.OrderField = "custom";
- reqUserList1.Language = "zh_CN";
- reqUserList1.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList1 = userListClient.Execute(reqUserList1, access_token);
- if (rspV2UserList1.Result.List != null)
- {
- List<DDUserInfoAndTMD> dDAndTmdInfos = new List<DDUserInfoAndTMD>();
- foreach (var itemUser in rspV2UserList1.Result.List)
- {
- DDUserInfoAndTMD dDAndTmdInfo = new DDUserInfoAndTMD();
- dDAndTmdInfo.unionid = itemUser.Unionid;
- dDAndTmdInfo.userid = itemUser.Userid;
- dDAndTmdInfo.title = itemUser.Title;
- dDAndTmdInfo.name = itemUser.Name;
- dDAndTmdInfo.mobile = itemUser.Mobile;
- dDAndTmdInfo.jobNumber = itemUser.JobNumber;
- dDAndTmdInfo.avatar = itemUser.Avatar;
- dDAndTmdInfo.depts = itemUser.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo.tmdId = item.id;
- dDAndTmdInfo.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo.tmdroles = roles;
- dDAndTmdInfo.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos.Add(dDAndTmdInfo);
- deptStruc.tmddd = dDAndTmdInfos;
- }
- }
- //获取二级部门列表
- OapiV2DepartmentListsubRequest reqDeptList2 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList2 = v2DeptListClient1.Execute(reqDeptList2, access_token);
- if (rspDeptList2.Result != null)
- {
- List<DeptStruc> deptStrucs2 = new List<DeptStruc>();
- foreach (var tempDept2 in rspDeptList2.Result)
- {
- DeptStruc deptStruc2 = new DeptStruc();
- deptStruc2.deptId = tempDept2.DeptId;
- deptStruc2.parentId = tempDept2.ParentId;
- deptStruc2.name = tempDept2.Name;
- //获取二级部门列表
- OapiV2UserListRequest reqUserList2 = new OapiV2UserListRequest();
- reqUserList2.DeptId = tempDept2.DeptId;
- reqUserList2.Cursor = 0L;
- reqUserList2.Size = 50L;
- reqUserList2.ContainAccessLimit = false;
- reqUserList2.OrderField = "custom";
- reqUserList2.Language = "zh_CN";
- reqUserList2.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList2 = userListClient.Execute(reqUserList2, access_token);
- if (rspV2UserList2.Result.List != null)
- {
- List<DDUserInfoAndTMD> dDAndTmdInfos2 = new List<DDUserInfoAndTMD>();
- foreach (var itemUser in rspV2UserList2.Result.List)
- {
- DDUserInfoAndTMD dDAndTmdInfo2 = new DDUserInfoAndTMD();
- dDAndTmdInfo2.unionid = itemUser.Unionid;
- dDAndTmdInfo2.userid = itemUser.Userid;
- dDAndTmdInfo2.title = itemUser.Title;
- dDAndTmdInfo2.name = itemUser.Name;
- dDAndTmdInfo2.mobile = itemUser.Mobile;
- dDAndTmdInfo2.jobNumber = itemUser.JobNumber;
- dDAndTmdInfo2.avatar = itemUser.Avatar;
- dDAndTmdInfo2.depts = itemUser.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo2.tmdId = item.id;
- dDAndTmdInfo2.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo2.tmdroles = roles;
- dDAndTmdInfo2.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos2.Add(dDAndTmdInfo2);
- deptStruc2.tmddd = dDAndTmdInfos2;
- }
- }
- //获取三级部门列表
- OapiV2DepartmentListsubRequest reqDeptList3 = new OapiV2DepartmentListsubRequest() { DeptId = tempDept2.DeptId, Language = "zh_CN" };
- OapiV2DepartmentListsubResponse rspDeptList3 = v2DeptListClient1.Execute(reqDeptList2, access_token);
- if (rspDeptList3.Result != null)
- {
- List<DeptStruc> deptStrucs3 = new List<DeptStruc>();
- foreach (var tempDept3 in rspDeptList2.Result)
- {
- DeptStruc deptStruc3 = new DeptStruc();
- deptStruc3.deptId = tempDept3.DeptId;
- deptStruc3.parentId = tempDept3.ParentId;
- deptStruc3.name = tempDept3.Name;
- //获取三级部门列表
- OapiV2UserListRequest reqUserList3 = new OapiV2UserListRequest();
- reqUserList3.DeptId = tempDept3.DeptId;
- reqUserList3.Cursor = 0L;
- reqUserList3.Size = 50L;
- reqUserList3.ContainAccessLimit = false;
- reqUserList3.OrderField = "custom";
- reqUserList3.Language = "zh_CN";
- reqUserList3.SetHttpMethod("GET");
- OapiV2UserListResponse rspV2UserList3 = userListClient.Execute(reqUserList2, access_token);
- if (rspV2UserList3.Result.List != null)
- {
- List<DDUserInfoAndTMD> dDAndTmdInfos3 = new List<DDUserInfoAndTMD>();
- foreach (var itemUser in rspV2UserList3.Result.List)
- {
- DDUserInfoAndTMD dDAndTmdInfo3 = new DDUserInfoAndTMD();
- dDAndTmdInfo3.unionid = itemUser.Unionid;
- dDAndTmdInfo3.userid = itemUser.Userid;
- dDAndTmdInfo3.title = itemUser.Title;
- dDAndTmdInfo3.name = itemUser.Name;
- dDAndTmdInfo3.mobile = itemUser.Mobile;
- dDAndTmdInfo3.jobNumber = itemUser.JobNumber;
- dDAndTmdInfo3.avatar = itemUser.Avatar;
- dDAndTmdInfo3.depts = itemUser.DeptIdList;
- List<string> roles = new List<string>();//角色列表
- List<string> power = new List<string>();//权限列表
- string sqltxt = $"select distinct value(c) from c join A1 in c.ddbinds where A1.userid ='{itemUser.Userid}'";
- try
- {
- await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher").GetItemQueryIterator<Teacher>(queryText: sqltxt, requestOptions: new QueryRequestOptions() { PartitionKey = new PartitionKey("Base") }))
- {
- dDAndTmdInfo3.tmdId = item.id;
- dDAndTmdInfo3.isexist = true;
- if (!string.IsNullOrEmpty($"{item.defaultSchool}"))
- {
- var schoolRoles = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").ReadItemStreamAsync(item.id, new PartitionKey($"Teacher-{item.defaultSchool}"));
- if (schoolRoles.Status == 200)
- {
- using var json = await JsonDocument.ParseAsync(schoolRoles.ContentStream);
- if (json.RootElement.TryGetProperty("roles", out JsonElement _roles) && _roles.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _roles.EnumerateArray())
- {
- //初始定义顾问的assistant 更改为assist
- if (obj.GetString().Equals($"assist"))
- {
- roles.Add(obj.GetString());
- }
- }
- }
- if (json.RootElement.TryGetProperty("permissions", out JsonElement _permissions) && _permissions.ValueKind != JsonValueKind.Null)
- {
- foreach (var obj in _permissions.EnumerateArray())
- {
- //显示BI权限
- foreach (var aut in authorityBIList)
- {
- if (aut.RowKey.Equals(obj.GetString()))
- {
- power.Add(obj.GetString());
- }
- }
- }
- }
- }
- dDAndTmdInfo3.tmdroles = roles;
- dDAndTmdInfo3.tmdpower = power;
- }
- }
- }
- catch { }
- dDAndTmdInfos3.Add(dDAndTmdInfo3);
- deptStruc3.tmddd = dDAndTmdInfos3;
- }
- }
- deptStrucs3.Add(deptStruc2);
- deptStruc.depts = deptStrucs3;
- }
- }
- deptStrucs2.Add(deptStruc2);
- deptStruc.depts = deptStrucs2;
- }
- }
- deptStrucs.Add(deptStruc);
- var deptlist2 = rspDeptList2.Result;
- }
- }
- return Ok(new { deptStrucs });
- }
- catch (Exception ex)
- {
- await _dingDing.SendBotMsg($"BI,{_option.Location} dd/get-dduserinfo \n {ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
- return BadRequest();
- }
- }
- /// <summary>
- ///
- /// </summary>
- public record DeptStruc
- {
- /// <summary>
- /// 部门ID
- /// </summary>
- public long deptId { get; set; }
- /// <summary>
- /// 父级部门
- /// </summary>
- public long parentId { get; set; }
- /// <summary>
- /// 部门名称
- /// </summary>
- public string name { get; set; }
- public List<DeptStruc> depts { get; set; }
- public List<DDUserInfoAndTMD> tmddd { get; set; }
- }
- /// <summary>
- /// 返回钉钉和能查询到醍摩豆信息
- /// </summary>
- public class DDUserInfoAndTMD
- {
- /// <summary>
- /// 是否存在醍摩豆账户
- /// </summary>
- public bool isexist { get; set; }
- /// <summary>
- /// 绑定的醍摩豆账户
- /// </summary>
- public string tmdId { get; set; }
- /// <summary>
- /// 醍摩豆角色
- /// </summary>
- public List<string> tmdroles { get; set; }
- /// <summary>
- /// 醍摩豆角色权限
- /// </summary>
- public List<string> tmdpower { get; set; }
- /// <summary>
- /// 员工在当前开发者企业账号范围内的唯一标识
- /// </summary>
- public string unionid { get; set; }
- /// <summary>
- /// 用户ID
- /// </summary>
- public string userid { get; set; }
- /// <summary>
- /// 员工名称
- /// </summary>
- public string name { get; set; }
- /// <summary>
- /// 职位
- /// </summary>
- public string title { get; set; }
-
- /// <summary>
- /// 手机号
- /// </summary>
- public string mobile { get; set; }
- /// <summary>
- /// 员工工号
- /// </summary>
- public string jobNumber { get; set; }
- /// <summary>
- /// 所属部门
- /// </summary>
- public long deptId { get; set; }
- /// <summary>
- /// 部门名称
- /// </summary>
- public string deptName { get; set; }
- /// <summary>
- /// 所属部门id列表
- /// </summary>
- public List<long> depts { get; set; }
- /// <summary>
- /// 钉钉头像
- /// </summary>
- public string avatar { get; set; }
- }
- /// <summary>
- /// 部门信息
- /// </summary>
- public record DeptInfo
- {
- /// <summary>
- /// 部门ID
- /// </summary>
- public long deptId { get; set; }
- /// <summary>
- /// 部门名称
- /// </summary>
- public string deptName { get; set; }
- /// <summary>
- /// 父部门id,根部门为1
- /// </summary>
- public long parentId { get; set; }
- /// <summary>
- /// 部门集合
- /// </summary>
- public List<DeptBaseResponseDomain> deptList { get; set; }
- /// <summary>
- /// 钉钉用户列表
- /// </summary>
- public List<string> ddUserList { get; set; }
- }
- public record DeptBaseResponseDomain
- {
- /// <summary>
- /// 部门ID
- /// </summary>
- public long deptId { get; set; }
- /// <summary>
- /// 部门名称
- /// </summary>
- public string Name { get; set; }
- /// <summary>
- /// 父部门ID
- /// </summary>
- public long ParentId { get; set; }
- /// <summary>
- /// 下级列表
- /// </summary>
- public List<DeptBaseResponseDomain> LowerDeip_List { get; set; }
- /// <summary>
- /// 钉钉用户列表
- /// </summary>
- public List<string> ddUserList { get; set; }
- }
- }
- }
|