|
|
@@ -1,638 +0,0 @@
|
|
|
-using Azure.Cosmos;
|
|
|
-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;
|
|
|
-using System.Text.Json;
|
|
|
-using System.Threading.Tasks;
|
|
|
-using TEAMModelBI.Filter;
|
|
|
-using TEAMModelBI.Models.Extension;
|
|
|
-using TEAMModelBI.Tool.Extension;
|
|
|
-using TEAMModelOS.Models;
|
|
|
-using TEAMModelOS.SDK.Context.BI;
|
|
|
-using TEAMModelOS.SDK.DI;
|
|
|
-using TEAMModelOS.SDK.Extension;
|
|
|
-using TEAMModelOS.SDK.Models.Cosmos.BI;
|
|
|
-using TEAMModelOS.SDK.Models.Service;
|
|
|
-
|
|
|
-namespace TEAMModelBI.Controllers.BINormal
|
|
|
-{
|
|
|
- [Route("appcompany")]
|
|
|
- [ApiController]
|
|
|
- public class AppCompanyController : ControllerBase
|
|
|
- {
|
|
|
- public readonly AzureCosmosFactory _azureCosmos;
|
|
|
- public readonly AzureStorageFactory _azureStorage;
|
|
|
- public readonly DingDing _dingDing;
|
|
|
- public readonly Option _option;
|
|
|
- private readonly IConfiguration _configuration;
|
|
|
- private readonly NotificationService _notificationService;
|
|
|
-
|
|
|
- public AppCompanyController(AzureCosmosFactory azureCosmos, AzureStorageFactory azureStorage, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, NotificationService notificationService)
|
|
|
- {
|
|
|
- _azureCosmos = azureCosmos;
|
|
|
- _azureStorage = azureStorage;
|
|
|
- _dingDing = dingDing;
|
|
|
- _option = option?.Value;
|
|
|
- _configuration = configuration;
|
|
|
- _notificationService = notificationService;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 查询应用信息
|
|
|
- /// </summary>
|
|
|
- /// <param name="jsonElement"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [ProducesDefaultResponseType]
|
|
|
- [HttpPost("get-info")]
|
|
|
- public async Task<IActionResult> GetInfo(JsonElement jsonElement)
|
|
|
- {
|
|
|
- jsonElement.TryGetProperty("appId", out JsonElement appId);
|
|
|
- jsonElement.TryGetProperty("eid", out JsonElement eid);
|
|
|
- jsonElement.TryGetProperty("audit", out JsonElement audit);
|
|
|
- jsonElement.TryGetProperty("site", out JsonElement site);
|
|
|
-
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- StringBuilder sqlTxt = new($"select c.id,c.pk,c.code,c.name,c.descr,c.picture,c.jwtKey,c.status,c.audit,c.refuseDesc,c.gateways,c.apis,c.webhookDomain,c.webHooks,c.schools from c where c.pk='App'");
|
|
|
- if (!string.IsNullOrEmpty($"{appId}"))
|
|
|
- {
|
|
|
- sqlTxt.Append($" and id='{appId}'");
|
|
|
- }
|
|
|
- if (!string.IsNullOrEmpty($"{audit}"))
|
|
|
- {
|
|
|
- sqlTxt.Append($" and audit='{audit}'");
|
|
|
- }
|
|
|
-
|
|
|
- List<ReadCompany> appCompanys = new();
|
|
|
- await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Normal").GetItemQueryStreamIterator(queryText: sqlTxt.ToString(), requestOptions: string.IsNullOrEmpty($"{eid}") ? new QueryRequestOptions() { } : new QueryRequestOptions() { PartitionKey = new PartitionKey($"App-{eid}") }))
|
|
|
- {
|
|
|
- using var json = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetUInt16() > 0)
|
|
|
- {
|
|
|
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
|
|
|
- {
|
|
|
- ReadCompany readCompany = new()
|
|
|
- {
|
|
|
- id = obj.GetProperty("id").GetString(),
|
|
|
- pk = obj.GetProperty("pk").GetString(),
|
|
|
- code = obj.GetProperty("code").GetString(),
|
|
|
- name = obj.GetProperty("name").GetString(),
|
|
|
- descr = obj.GetProperty("descr").GetString(),
|
|
|
- picture = obj.GetProperty("picture").GetString(),
|
|
|
- jwtKey = obj.GetProperty("jwtKey").GetString(),
|
|
|
- status = obj.GetProperty("status").GetInt32(),
|
|
|
- audit = obj.GetProperty("audit").GetInt32(),
|
|
|
- refuseDesc = obj.GetProperty("refuseDesc").GetString(),
|
|
|
- gateways = obj.GetProperty("gateways").GetString(),
|
|
|
- apis = obj.GetProperty("apis").ToObject<List<AppApiState>>(),
|
|
|
- webhookDomain = obj.GetProperty("webhookDomain").GetString(),
|
|
|
- webHooks = obj.GetProperty("webHooks").ToObject<List<WebHookState>>(),
|
|
|
- schools = obj.GetProperty("schools").ToObject<List<ApplySchool>>()
|
|
|
- };
|
|
|
-
|
|
|
- appCompanys.Add(readCompany);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return Ok(new { state = 200, appCompanys });
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 新增或者修改应用
|
|
|
- /// </summary>
|
|
|
- /// <param name="appCompany"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [ProducesDefaultResponseType]
|
|
|
- [AuthToken(Roles = "admin,rdc,company")]
|
|
|
- [HttpPost("set-info")]
|
|
|
- public async Task<IActionResult> SetAppInfo(AppCompany appCompany, [FromHeader] string site)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- var (loginId, loginName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- var tableClient = _azureStorage.GetCloudTableClient();
|
|
|
- var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- {
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
|
|
|
- blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
|
|
|
- }
|
|
|
- StringBuilder stringBuilder = new($"{loginName}【{loginId}】");
|
|
|
- string type = "";
|
|
|
- //新建
|
|
|
- if (string.IsNullOrEmpty($"{appCompany.id}"))
|
|
|
- {
|
|
|
- appCompany.id = GenerateRandom.StrRandom(8, large: true, small: true);
|
|
|
- appCompany.code = $"App-{appCompany.code}";
|
|
|
- appCompany.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
|
|
|
- appCompany.status = -1;
|
|
|
- appCompany.audit = -1;
|
|
|
- appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").CreateItemAsync<AppCompany>(appCompany, new PartitionKey(appCompany.code));
|
|
|
- stringBuilder.Append($"新增应用,应用ID:{appCompany.id},应用名称:{appCompany.name}");
|
|
|
- type = "appCompany-add";
|
|
|
- }
|
|
|
- //修改
|
|
|
- else
|
|
|
- {
|
|
|
- var response = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemStreamAsync(appCompany.id, new PartitionKey(appCompany.code));
|
|
|
- if (response.Status == 200)
|
|
|
- {
|
|
|
- appCompany.pk = "App";
|
|
|
- appCompany.ttl = -1;
|
|
|
- appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReplaceItemAsync<AppCompany>(appCompany, appCompany.id, new PartitionKey(appCompany.code));
|
|
|
- stringBuilder.Append($"修改应用,应用ID:{appCompany.id},应用名称:{appCompany.name}");
|
|
|
- type = "appCompany-update";
|
|
|
- }
|
|
|
- else return Ok(new { state = 404, msg = "未找到该id相关的企业应用信息" });
|
|
|
- }
|
|
|
-
|
|
|
- //保存操作记录
|
|
|
- //await _azureStorage.SaveBILog(type, stringBuilder.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, type, stringBuilder.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- return Ok(new { state = 200, appCompany });
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- await _dingDing.SendBotMsg($"BI,{_option.Location} , /appcompany/set-info \n {e.Message}\n{e.StackTrace} \n ", GroupNames.成都开发測試群組);
|
|
|
- return BadRequest();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 查询未审核的信息
|
|
|
- /// </summary>
|
|
|
- /// <param name="jsonElement"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [ProducesDefaultResponseType]
|
|
|
- [HttpPost("get-noaudit")]
|
|
|
- public async Task<IActionResult> GetNoAudit(JsonElement jsonElement)
|
|
|
- {
|
|
|
- if(!jsonElement.TryGetProperty("operate", out JsonElement operate)) return BadRequest();
|
|
|
- jsonElement.TryGetProperty("site", out JsonElement site);
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- var tableClient = _azureStorage.GetCloudTableClient();
|
|
|
- var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- {
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
|
|
|
- blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
|
|
|
- }
|
|
|
- StringBuilder sqlTxt = new();
|
|
|
-
|
|
|
- switch (operate.GetString())
|
|
|
- {
|
|
|
- case "api":
|
|
|
- sqlTxt.Append($"SELECT c.id, c.code,c.name,c.pk,c.audit,ARRAY(SELECT VALUE a FROM a in c.apis where a.status = -1) as operate FROM c where c.pk='App' and c.audit=1");
|
|
|
- break;
|
|
|
- case "school":
|
|
|
- sqlTxt.Append($"SELECT c.id, c.code,c.name,c.pk,c.audit,ARRAY(SELECT VALUE a FROM a in c.schools where a.status = -1) as operate FROM c where c.pk='App' and c.audit=1");
|
|
|
- break;
|
|
|
- default:
|
|
|
- sqlTxt.Append($"select c.id,c.code,c.name,c.pk,c.audit from c where c.audit=-1 and c.pk='App'");
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- List<NoAudit> noAudits = new();
|
|
|
-
|
|
|
- await foreach (var item in cosmosClient.GetContainer("TEAMModelOS", "Normal").GetItemQueryStreamIterator(queryText: sqlTxt.ToString(), requestOptions: new QueryRequestOptions() { }))
|
|
|
- {
|
|
|
- var json = await JsonDocument.ParseAsync(item.ContentStream);
|
|
|
- if (json.RootElement.TryGetProperty("_count", out JsonElement count) && count.GetInt16() > 0)
|
|
|
- {
|
|
|
- foreach (var obj in json.RootElement.GetProperty("Documents").EnumerateArray())
|
|
|
- {
|
|
|
- NoAudit noAudit = new();
|
|
|
- noAudit.id = obj.GetProperty("id").GetString();
|
|
|
- noAudit.code = obj.GetProperty("code").GetString();
|
|
|
- noAudit.pk = obj.GetProperty("pk").GetString();
|
|
|
- noAudit.name = obj.GetProperty("name").GetString();
|
|
|
- if (!string.IsNullOrEmpty($"{operate}"))
|
|
|
- {
|
|
|
- noAudit.operate = obj.GetProperty("operate").ToObject<List<object>>();
|
|
|
- }
|
|
|
- noAudit.audit = obj.GetProperty("audit").GetInt32();
|
|
|
-
|
|
|
- noAudits.Add(noAudit);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return Ok(new { state = 200, noAudits });
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 审核应用是否通过
|
|
|
- /// </summary>
|
|
|
- /// <param name="jsonElement"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [AuthToken(Roles = "admin,rdc")]
|
|
|
- [HttpPost("get-apply")]
|
|
|
- public async Task<IActionResult> SetAuditApp(JsonElement jsonElement)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- var (loginId, loginName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
|
|
|
- if (!jsonElement.TryGetProperty("appIds", out JsonElement appIds)) return BadRequest();
|
|
|
- if (!jsonElement.TryGetProperty("isAudit", out JsonElement isAudit)) return BadRequest();
|
|
|
- jsonElement.TryGetProperty("refuseDesc", out JsonElement refuseDesc);
|
|
|
- jsonElement.TryGetProperty("site", out JsonElement site);
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- var tableClient = _azureStorage.GetCloudTableClient();
|
|
|
- var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- {
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
|
|
|
- blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
|
|
|
- }
|
|
|
- StringBuilder strMsg = new($"{loginName}【{loginId}】");
|
|
|
- List<AppIdOrCode> idOrCode = appIds.ToObject<List<AppIdOrCode>>();
|
|
|
- List<AppIdOrCode> haveIds = new();
|
|
|
- if (idOrCode.Count > 0)
|
|
|
- {
|
|
|
- foreach (var idCode in idOrCode)
|
|
|
- {
|
|
|
- AppCompany appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemAsync<AppCompany>(idCode.id, new PartitionKey(idCode.code));
|
|
|
- strMsg.Append($"审核应用{appCompany.name}【{appCompany.id}】，审核状态：");
|
|
|
- //var response = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemStreamAsync(idCode.id, new PartitionKey(idCode.code));
|
|
|
- if (bool.Parse($"{isAudit}") == true)
|
|
|
- {
|
|
|
- appCompany.audit = 1;
|
|
|
- appCompany.jwtKey = JwtAuth.CreateApplyJwtKeyBI(_option.HostName, _option.JwtSecretKey, appCompany);
|
|
|
- strMsg.Append("通过。");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- appCompany.audit = 0;
|
|
|
- appCompany.refuseDesc = $"{refuseDesc}";
|
|
|
- strMsg.Append("拒绝通过。");
|
|
|
- }
|
|
|
- try
|
|
|
- {
|
|
|
-
|
|
|
- await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReplaceItemAsync<AppCompany>(appCompany, appCompany.id, new PartitionKey(idCode.code));
|
|
|
- }
|
|
|
- catch
|
|
|
- {
|
|
|
- haveIds.Add(idCode);
|
|
|
- strMsg.Append($"异常:id:{idCode.id},code:{idCode.code}；");
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- else return Ok(new { state = 404, msg = "appIds参数错误" });
|
|
|
-
|
|
|
- //保存操作记录
|
|
|
- //await _azureStorage.SaveBILog("appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
-
|
|
|
- if (haveIds.Count > 0)
|
|
|
- return Ok(new { state = 201, msg = "部分应用审核失败！", haveIds });
|
|
|
- else return Ok(new { state = 200 });
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- await _dingDing.SendBotMsg($"BI,{_option.Location} , /appcompany/get-applyapi \n {e.Message}\n{e.StackTrace} \n ", GroupNames.成都开发測試群組);
|
|
|
- return BadRequest();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 应用申请Api接口信息
|
|
|
- /// 审核应用api接口信息
|
|
|
- /// </summary>
|
|
|
- /// <param name="jsonElement"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [ProducesDefaultResponseType]
|
|
|
- [AuthToken(Roles = "admin,rdc,company")]
|
|
|
- [HttpPost("set-applyapi")]
|
|
|
- public async Task<IActionResult> SetApplyApi(JsonElement jsonElement)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- var (loginId, loginName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
|
|
|
- if (!jsonElement.TryGetProperty("applyApis", out JsonElement jsApplyApis)) return BadRequest();
|
|
|
- if (!jsonElement.TryGetProperty("operate", out JsonElement operate)) return BadRequest();
|
|
|
- jsonElement.TryGetProperty("site", out JsonElement site);
|
|
|
-
|
|
|
- StringBuilder strMsg = new($"{loginName}【{loginId}】");
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- var tableClient = _azureStorage.GetCloudTableClient();
|
|
|
- var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- {
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
|
|
|
- blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
|
|
|
- }
|
|
|
- string bizcode = ""; //消息名称
|
|
|
- List<string> sendWhom = new();//消息分发给谁 待完善
|
|
|
- List<ApplyApi> applyApis = jsApplyApis.ToObject<List<ApplyApi>>();
|
|
|
- List<ApplyApi> haveApi = new(); //存在api接口
|
|
|
- Dictionary<string,string> noAudit = new();
|
|
|
-
|
|
|
- foreach (var tempApp in applyApis)
|
|
|
- {
|
|
|
- AppCompany appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemAsync<AppCompany>($"{tempApp.appId}", new PartitionKey($"{tempApp.appCode}"));
|
|
|
-
|
|
|
- if (appCompany != null || appCompany.audit != -1 || appCompany.audit != 0)
|
|
|
- {
|
|
|
- switch (operate.GetString())
|
|
|
- {
|
|
|
- case "apply":
|
|
|
- strMsg.Append($"申请：{appCompany.name}【{appCompany.id}】应用的Api：");
|
|
|
- if (!jsonElement.TryGetProperty("applyDesc", out JsonElement applyDesc)) return BadRequest();
|
|
|
- tempApp.apiIds.ForEach(x =>
|
|
|
- {
|
|
|
- var strt = appCompany.apis.Find(y => y.no.Equals($"{x}"));
|
|
|
- if (strt == null)
|
|
|
- {
|
|
|
- appCompany.apis.Add(new AppApiState() { no = $"{x}", applyDesc = $"{applyDesc}", status = -1 });
|
|
|
- strMsg.Append($"{x},");
|
|
|
- }
|
|
|
- else haveApi.Add(tempApp);
|
|
|
- });
|
|
|
- sendWhom.Add(appCompany.id);
|
|
|
- bizcode = "applyapi";
|
|
|
- if (haveApi.Count > 0) strMsg.Append($"已有存在的api:{haveApi.ToJsonString()}。");
|
|
|
- break;
|
|
|
- case "audit":
|
|
|
- if (!jsonElement.TryGetProperty("isAudit", out JsonElement isAudit)) return BadRequest();
|
|
|
- string refuseDesc = "";
|
|
|
- if (bool.Parse($"{isAudit}") == false)
|
|
|
- {
|
|
|
- if (!jsonElement.TryGetProperty("refuseDesc", out JsonElement jsonRefuseDesc)) return BadRequest();
|
|
|
- refuseDesc = jsonRefuseDesc.GetString();
|
|
|
- }
|
|
|
-
|
|
|
- strMsg.Append($"审核{appCompany.name}【{appCompany.id}】应用的Api:");
|
|
|
- tempApp.apiIds.ForEach(x =>
|
|
|
- {
|
|
|
- var temp = appCompany.apis.Find(n => n.no == x);
|
|
|
- if (temp != null)
|
|
|
- {
|
|
|
- AppApiState appApiState = appCompany.apis.Single(a => a.no == x);
|
|
|
- if (bool.Parse($"{isAudit}") == true)
|
|
|
- {
|
|
|
- appApiState.status = 1;
|
|
|
- appApiState.refuseDesc = null;
|
|
|
- appCompany.jwtKey = JwtAuth.CreateApplyJwtKeyBI(_option.HostName, _option.JwtSecretKey, appCompany);
|
|
|
- strMsg.Append($"{appApiState.no}通过，");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- appApiState.status = 0;
|
|
|
- appApiState.refuseDesc = $"{refuseDesc}";
|
|
|
- strMsg.Append($"{appApiState.no}失败，");
|
|
|
- }
|
|
|
- }
|
|
|
- else haveApi.Add(tempApp);
|
|
|
- });
|
|
|
-
|
|
|
- if (haveApi.Count > 0) strMsg.Append($"该应用没有申请相关API接口：{haveApi.ToJsonString()}。");
|
|
|
- sendWhom.Add(appCompany.id);
|
|
|
- bizcode = "auditapi";
|
|
|
-
|
|
|
- break;
|
|
|
- default:
|
|
|
- return Ok(new { state = 400, msg = "operate参数错误" });
|
|
|
- }
|
|
|
- appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReplaceItemAsync<AppCompany>(appCompany, appCompany.id, new PartitionKey(appCompany.code));
|
|
|
- }
|
|
|
- else noAudit.Add($"{appCompany.id}", $"{appCompany.name}");
|
|
|
- }
|
|
|
-
|
|
|
- //发送消息
|
|
|
- var location = _option.Location;
|
|
|
- Notification notification = new()
|
|
|
- {
|
|
|
- hubName = bizcode,
|
|
|
- type = "msg",
|
|
|
- from = $"BI:{_option.Location}:private",
|
|
|
- to = sendWhom,
|
|
|
- label = $"{bizcode}-appCompany",
|
|
|
- body = new { location = location, biz = bizcode, appid = sendWhom, appName = sendWhom, status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
|
|
|
- };
|
|
|
-
|
|
|
- var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
|
|
|
- var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
|
|
|
- var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
|
|
|
- await _notificationService.SendNotification(clientID, clientSecret, location, url, notification); //站内发送消息
|
|
|
-
|
|
|
- //保存操作记录
|
|
|
- //await _azureStorage.SaveBILog("appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- if (haveApi.Count > 0 || noAudit.Count > 0)
|
|
|
- return Ok(new { state = 201, msg = "部分成功", haveApi, noAudit });
|
|
|
- else return Ok(new { state = 200 });
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- await _dingDing.SendBotMsg($"BI,{_option.Location} , /appcompany/get-applyapi \n {e.Message}\n{e.StackTrace} \n ", GroupNames.成都开发測試群組);
|
|
|
- return BadRequest();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 应用申请学校
|
|
|
- /// 应用审核申请的学校
|
|
|
- /// </summary>
|
|
|
- /// <param name="jsonElement"></param>
|
|
|
- /// <returns></returns>
|
|
|
- [ProducesDefaultResponseType]
|
|
|
- [AuthToken(Roles = "admin,rdc,company")]
|
|
|
- [HttpPost("set-applyschool")]
|
|
|
- public async Task<IActionResult> SetAuditSchool(JsonElement jsonElement)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- var (loginId, loginName, pic, did, dname, dpic) = HttpJwtAnalysis.JwtXAuthBI(HttpContext.GetXAuth("AuthToken"), _option);
|
|
|
- if (!jsonElement.TryGetProperty("appId", out JsonElement appId)) return BadRequest();
|
|
|
- if (!jsonElement.TryGetProperty("appCode", out JsonElement appCode)) return BadRequest();
|
|
|
- if (!jsonElement.TryGetProperty("schooCode", out JsonElement schooCode)) return BadRequest();
|
|
|
- if (!jsonElement.TryGetProperty("operate", out JsonElement operate)) return BadRequest();
|
|
|
- jsonElement.TryGetProperty("site", out JsonElement site);
|
|
|
-
|
|
|
- var cosmosClient = _azureCosmos.GetCosmosClient();
|
|
|
- var tableClient = _azureStorage.GetCloudTableClient();
|
|
|
- var blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public");
|
|
|
- if ($"{site}".Equals(BIConst.Global))
|
|
|
- {
|
|
|
- cosmosClient = _azureCosmos.GetCosmosClient(name: BIConst.Global);
|
|
|
- tableClient = _azureStorage.GetCloudTableClient(BIConst.Global);
|
|
|
- blobClient = _azureStorage.GetBlobContainerClient(containerName: "0-public", BIConst.Global);
|
|
|
- }
|
|
|
- StringBuilder strMsg = new($"{loginName}【{loginId}】操作：");
|
|
|
- List<string> haveSchool = new();
|
|
|
- List<string> sendWhom = new();//消息分发给谁 待完善
|
|
|
- string bizcode = ""; //消息名称
|
|
|
-
|
|
|
- AppCompany appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReadItemAsync<AppCompany>($"{appId}", new PartitionKey($"{appCode}"));
|
|
|
- if (appCompany.audit == -1 || appCompany.audit == 0)
|
|
|
- {
|
|
|
- return Ok(new { state = 401, msg = "应用未审核请先审核应用程序" });
|
|
|
- }
|
|
|
-
|
|
|
- if (appCompany != null)
|
|
|
- {
|
|
|
- switch (operate.GetString())
|
|
|
- {
|
|
|
- case "apply":
|
|
|
- var aSchool = appCompany.schools.Find(x => x.id.Equals($"{schooCode}"));
|
|
|
- if (!jsonElement.TryGetProperty("name", out JsonElement name)) return BadRequest();
|
|
|
- if (aSchool == null)
|
|
|
- {
|
|
|
- jsonElement.TryGetProperty("picture", out JsonElement picture);
|
|
|
- strMsg.Append($"应用{appCompany.name}【{appCompany.id}】申请学校{name}【{schooCode}】，申请成功。");
|
|
|
- appCompany.schools.Add(new ApplySchool() { id = $"{schooCode}", name = $"{name}", picture = $"{picture}" });
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- haveSchool.Add(schooCode.GetString());
|
|
|
- strMsg.Append($"应用{appCompany.name}【{appCompany.id}】申请的学校{name}【{schooCode}】已存在。");
|
|
|
- }
|
|
|
- sendWhom = new List<string> { "1528783103", "1636016499" };
|
|
|
- bizcode = "applyschool";
|
|
|
-
|
|
|
- break;
|
|
|
- case "audit":
|
|
|
- if (!jsonElement.TryGetProperty("isAudit", out JsonElement isAudit)) return BadRequest();
|
|
|
- string refuseDesc = "";
|
|
|
- if (bool.Parse($"{isAudit}") == false)
|
|
|
- {
|
|
|
- if (!jsonElement.TryGetProperty("refuseDesc", out JsonElement jsonRefuseDesc)) return BadRequest();
|
|
|
- refuseDesc = jsonRefuseDesc.GetString();
|
|
|
- }
|
|
|
-
|
|
|
- var applySchool = appCompany.schools.Find(x => x.id.Equals($"{schooCode}"));
|
|
|
- strMsg.Append($"审核应用{appCompany.name}【{appCompany.id}】状态：");
|
|
|
- if (applySchool != null)
|
|
|
- {
|
|
|
- if (bool.Parse($"{isAudit}") == true)
|
|
|
- {
|
|
|
- applySchool.status = 1;
|
|
|
- applySchool.refuseDesc = null;
|
|
|
- appCompany.jwtKey = JwtAuth.CreateApplyJwtKeyBI(_option.HostName, _option.JwtSecretKey, appCompany);
|
|
|
- strMsg.Append($"审核成功。");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- applySchool.status = 0;
|
|
|
- applySchool.refuseDesc = $"{refuseDesc}";
|
|
|
- strMsg.Append($"审核失败。");
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- haveSchool.Add(schooCode.GetString());
|
|
|
- strMsg.Append($"已审核状态！");
|
|
|
- }
|
|
|
- sendWhom = new List<string> { "1528783103", "1636016499" };
|
|
|
- bizcode = "auditschool";
|
|
|
-
|
|
|
- break;
|
|
|
- default:
|
|
|
- return Ok(new { state = 400, msg = "operate参数错误" });
|
|
|
- }
|
|
|
-
|
|
|
- appCompany = await cosmosClient.GetContainer("TEAMModelOS", "Normal").ReplaceItemAsync<AppCompany>(appCompany, appCompany.id, new PartitionKey(appCompany.code));
|
|
|
- }
|
|
|
- else return Ok(new { state = 404, msg = "未找到该应用" });
|
|
|
-
|
|
|
- //发送消息
|
|
|
- var location = _option.Location;
|
|
|
- Notification notification = new()
|
|
|
- {
|
|
|
- hubName = bizcode,
|
|
|
- type = "msg",
|
|
|
- from = $"BI:{_option.Location}:private",
|
|
|
- to = sendWhom,
|
|
|
- label = $"{bizcode}-appCompany",
|
|
|
- body = new { location = location, biz = bizcode, appid = appCompany.id, appName = appCompany.name, status = 1, time = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() }.ToJsonString(),
|
|
|
- };
|
|
|
-
|
|
|
- var url = _configuration.GetValue<string>("HaBookAuth:CoreService:sendnotification");
|
|
|
- var clientID = _configuration.GetValue<string>("HaBookAuth:CoreService:clientID");
|
|
|
- var clientSecret = _configuration.GetValue<string>("HaBookAuth:CoreService:clientSecret");
|
|
|
- await _notificationService.SendNotification(clientID, clientSecret, location, url, notification); //站内发送消息
|
|
|
-
|
|
|
- //保存操作记录
|
|
|
- //await _azureStorage.SaveBILog("appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- await AzureStorageBlobExtensions.SaveBILog(blobClient, tableClient, "appCompany-update", strMsg.ToString(), _dingDing, httpContext: HttpContext);
|
|
|
- if (haveSchool.Count > 0) return Ok(new { state = 201, msg = "已存在学校，无须申请！", haveSchool });
|
|
|
- else return Ok(new { state = 200 });
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- await _dingDing.SendBotMsg($"BI,{_option.Location} , /appcompany/set-auditschool \n {e.Message}\n{e.StackTrace}\n{e.StackTrace} \n ", GroupNames.成都开发測試群組);
|
|
|
- return BadRequest();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 应用申请和审核api信息
|
|
|
- /// </summary>
|
|
|
- public record ApplyApi
|
|
|
- {
|
|
|
- public string appId { get; set; }
|
|
|
- public string appCode { get; set; }
|
|
|
- public List<string> apiIds { get; set; }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 审核应用
|
|
|
- /// </summary>
|
|
|
- public record AppIdOrCode
|
|
|
- {
|
|
|
- public string id { get; set; }
|
|
|
- public string code { get; set; }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 未审核应用
|
|
|
- /// </summary>
|
|
|
- public record NoAudit
|
|
|
- {
|
|
|
- public string id { get; set; }
|
|
|
- public string code { get; set; }
|
|
|
-
|
|
|
- public string pk { get; set; }
|
|
|
-
|
|
|
- public string name { get;set; }
|
|
|
- public List<object> operate { get; set; }
|
|
|
- public int audit { get; set; }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 显示应用
|
|
|
- /// </summary>
|
|
|
- public record ReadCompany
|
|
|
- {
|
|
|
- public string id { get; set; }
|
|
|
- public string pk { get; set; }
|
|
|
- public string code { get; set; }
|
|
|
- public string name { get; set; }
|
|
|
- public string descr { get; set; }
|
|
|
- public string picture { get; set; }
|
|
|
- public string jwtKey { get; set; }
|
|
|
- public int status { get; set; }
|
|
|
- public int audit { get; set; }
|
|
|
- public string refuseDesc { get; set; }
|
|
|
- public string gateways { get; set; }
|
|
|
- public List<AppApiState> apis { get; set; }
|
|
|
- public string webhookDomain { get; set; }
|
|
|
- public List<WebHookState> webHooks { get; set; }
|
|
|
- public List<ApplySchool> schools { get; set; }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-}
|
Li