1.隐藏所有基础接口

2.完善工作流接口-提交审批流
This commit is contained in:
qmj
2025-07-23 21:57:18 +08:00
parent b8a9595cc1
commit 55740e4bcf
4 changed files with 82 additions and 11 deletions
@@ -2,6 +2,7 @@
using System;
using System.Threading.Tasks;
using System.Web.Http;
using System.Web.Http.Description;
using UFIDA.U8.Framework.Api.ControlObject.Entity;
using UFIDA.U8.Framework.Api.Models;
using UFIDA.U8.Framework.Api.Unit;
@@ -19,7 +20,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <summary>
/// 日志对象
/// </summary>
protected readonly ILog logInfo = LogManager.GetLogger("logInfo");
private readonly ILog _logInfo = LogManager.GetLogger("logInfo");
/// <summary>
/// 获取加密字符串
@@ -28,6 +29,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpGet]
[Route("api/Common/GetEncryptString")]
[ApiExplorerSettings(IgnoreApi = true)]
public BaseResult<string> GetEncryptString(string input)
{
try
@@ -36,7 +38,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<string> { bSuccess = false, message = "加密失败", result = ex.Message };
}
@@ -49,6 +51,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpGet]
[Route("api/Common/GetDecryptString")]
[ApiExplorerSettings(IgnoreApi = true)]
public BaseResult<string> GetDecryptString(string input)
{
try
@@ -57,7 +60,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<string> { bSuccess = false, message = "解密失败", result =ex.Message };
}
@@ -70,6 +73,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpPost]
[Route("api/Common/GetAccountConfig")]
[ApiExplorerSettings(IgnoreApi = true)]
public async Task<BaseResult<dynamic>> GetAccountConfig([FromBody]U8AccountConfigInput input)
{
try
@@ -84,7 +88,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<dynamic> { bSuccess = false, message = "查询失败", result = ex.Message };
}
@@ -98,6 +102,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpPost]
[Route("api/Common/AddAccountConfig")]
[ApiExplorerSettings(IgnoreApi = true)]
public async Task<BaseResult<dynamic>> AddAccountConfig([FromBody] AddU8AccountConfigInput input)
{
try
@@ -117,7 +122,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<dynamic> { bSuccess = false, message = "新增失败", result = ex.Message };
}
@@ -131,6 +136,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpPost]
[Route("api/Common/UpdateAccountConfig")]
[ApiExplorerSettings(IgnoreApi = true)]
public async Task<BaseResult<dynamic>> UpdateAccountConfig([FromBody]AddU8AccountConfigInput input)
{
try
@@ -150,7 +156,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<dynamic> { bSuccess = false, message = "更新失败", result = ex.Message };
}
@@ -163,6 +169,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
/// <returns></returns>
[HttpPost]
[Route("api/Common/ListAccountConfig")]
[ApiExplorerSettings(IgnoreApi = true)]
public async Task<BaseResult<dynamic>> ListAccountConfig([FromBody] ListU8AccountConfigInput input)
{
try
@@ -177,7 +184,7 @@ namespace UFIDA.U8.Framework.Api.Controllers
}
catch (Exception ex)
{
logInfo.Error(ex.Message, ex);
_logInfo.Error(ex.Message, ex);
return new BaseResult<dynamic> { bSuccess = false, message = "查询失败", result = ex.Message };
}
@@ -26,7 +26,7 @@ namespace UFIDA.U8.Framework.Api.Controllers.U8
/// <summary>
/// 日志组件
/// </summary>
protected readonly ILog _logInfo = LogManager.GetLogger("logInfo");
private readonly ILog _logInfo = LogManager.GetLogger("logInfo");
private static readonly MemoryCache _cache = new MemoryCache(new MemoryCacheOptions { ExpirationScanFrequency = TimeSpan.FromMinutes(10) });
@@ -109,7 +109,7 @@ namespace UFIDA.U8.Framework.Api.Controllers.U8
{
var userToken = Request.Headers.GetValues("userToken").First();
_logInfo.Debug($"当前接口:api/U8/Workflow/SubmitApplicationMessage/Code,userToken:{userToken},单据:{cCardNum},事件:{eventId},单据编号:{cCode}");
_logInfo.Debug($"当前接口:api/U8/Workflow/SubmitApplicationMessage/Code/{userToken},单据:{cCardNum},事件:{eventId},单据编号:{cCode}");
var output = CommUnit.GetDecrypt(userToken).ToObject<LoginOutput>();
@@ -146,7 +146,7 @@ namespace UFIDA.U8.Framework.Api.Controllers.U8
}
/// <summary>
/// 提交审批流(单号)
/// 提交审批流(ID)
/// </summary>
/// <param name="cCardNum">单据类型编码</param>
/// <param name="voucherId">单据ID</param>
@@ -160,6 +160,11 @@ namespace UFIDA.U8.Framework.Api.Controllers.U8
{
try
{
if (Request.Headers.TryGetValues("userToken", out var userToken))
{
return await SubmitApplicationMessageToken(cCardNum, voucherId, eventId, bUap);
}
var db = CommUnit.GetDbClient();
var workId = SnowFlakeSingle.Instance.NextId();
@@ -198,5 +203,64 @@ namespace UFIDA.U8.Framework.Api.Controllers.U8
}
}
/// <summary>
/// 提交审批流(ID)
/// </summary>
/// <param name="cCardNum">单据类型编码</param>
/// <param name="voucherId">单据ID</param>
/// <param name="cAccId">系统注册号</param>
/// <param name="eventId">审批事件</param>
/// <param name="bUap">是否UAP单据</param>
/// <returns></returns>
[HttpGet]
[Route("api/U8/Workflow/SubmitApplicationMessage/ID/Token")]
public async Task<BaseResult<string>> SubmitApplicationMessageToken(string cCardNum, long voucherId, string eventId, bool bUap = false)
{
try
{
var userToken = Request.Headers.GetValues("userToken").First();
if (string.IsNullOrWhiteSpace(userToken))
{
throw new Exception($"userToken获取失败");
}
_logInfo.Debug($"当前接口:api/U8/Workflow/SubmitApplicationMessage/ID/{userToken},单据:{cCardNum},事件:{eventId},单据ID:{voucherId}");
var output = CommUnit.GetDecrypt(userToken).ToObject<LoginOutput>();
var token = CommUnit.GetDecrypt(output.userToken);
var workId = SnowFlakeSingle.Instance.NextId();
_logInfo.Debug($"作业Id:{workId}-----单据:{cCardNum},操作:新增,对接账套:{output.cAccId},单据ID:{voucherId}");
if (!_cache.TryGetValue($"U8_{userToken}_{output.cAccId}", out BaseLogin baseLogin))
{
_logInfo.Debug($"作业Id:{workId}-----未获取到缓存的登录信息,正在重新构建");
baseLogin = new BaseLogin();
baseLogin.Init(token, true, 5);
_cache.Clear();
_cache.Set($"U8_{userToken}_{output.cAccId}", baseLogin);
}
var services = new ServiceProxy();
return await services.SubmitApplicationMessage(baseLogin, cCardNum, eventId, voucherId, bUap);
}
catch (Exception ex)
{
_logInfo.Error(ex.Message, ex);
return new BaseResult<string> { bSuccess = false, message = ex.Message, result = ex.StackTrace };
}
}
}
}