|
@@ -4,6 +4,7 @@ using DataSharing.Province;
|
|
|
using DataSharing.Province.SendTask.SubmitCaseRecord;
|
|
|
using DataSharing.RawData;
|
|
|
using DataSharing.Share.Dtos;
|
|
|
+using DataSharing.Share.Dtos.HotlineWeb;
|
|
|
using DataSharing.Share.Dtos.Province;
|
|
|
using DotNetCore.CAP;
|
|
|
using MapsterMapper;
|
|
@@ -15,6 +16,7 @@ using StackExchange.Redis;
|
|
|
using System.Security.Cryptography;
|
|
|
using System.Text;
|
|
|
using XC.RSAUtil;
|
|
|
+using XF.Domain.Cache;
|
|
|
using XF.Domain.Exceptions;
|
|
|
using XF.Domain.Repository;
|
|
|
|
|
@@ -45,8 +47,8 @@ namespace DataSharing.Host.Controllers
|
|
|
private readonly IRepository<DsOrderSend> _dsOrderSendRepository;
|
|
|
private readonly IRepository<DsOrder> _dsOrderRepository;
|
|
|
private readonly ISharingSessionContext _sessionContext;
|
|
|
-
|
|
|
-
|
|
|
+ private readonly ITypedCache<string> _configurationInformationCache;
|
|
|
+ private readonly string GetSetTypedCacheKey = "testgetsetTypedCache";
|
|
|
|
|
|
public TestController(IMapper mapper,
|
|
|
IMediator mediator,
|
|
@@ -68,8 +70,8 @@ namespace DataSharing.Host.Controllers
|
|
|
IRepository<DsWaitSendTaskSubmitCaseRecord> waitSendTaskSubmitCaseRecordRepository,
|
|
|
IRepository<DsOrderSend> dsOrderSendRepository,
|
|
|
IRepository<DsOrder> dsOrderRepository,
|
|
|
- ISharingSessionContext sessionContext
|
|
|
-
|
|
|
+ ISharingSessionContext sessionContext,
|
|
|
+ ITypedCache<string> configurationInformationCache
|
|
|
)
|
|
|
{
|
|
|
_mapper = mapper;
|
|
@@ -93,6 +95,7 @@ namespace DataSharing.Host.Controllers
|
|
|
_dsOrderSendRepository = dsOrderSendRepository;
|
|
|
_dsOrderRepository = dsOrderRepository;
|
|
|
_sessionContext = sessionContext;
|
|
|
+ _configurationInformationCache = configurationInformationCache;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
@@ -104,7 +107,7 @@ namespace DataSharing.Host.Controllers
|
|
|
public async void asdaa()
|
|
|
{
|
|
|
var data = _channelConfigurationManager.GetConfigurationProvince();
|
|
|
- // var result = await _huiJuClient.RequestAsync<ProvinceResponse>(data.HuiJu + PtahDefaults.SubmitCaseInfo, "Post", "", HttpContext.RequestAborted);
|
|
|
+ // var result = await _huiJuClient.RequestAsync<ProvinceResponse>(data.HuiJu + PtahDefaults.SubmitCaseInfo, "Post", "", HttpContext.RequestAborted);
|
|
|
await _xieTongClient.RequestAsync<ProvinceResponse>(data.XieTong, "POST", "", HttpContext.RequestAborted);
|
|
|
var ss = _sessionContext;
|
|
|
}
|
|
@@ -324,5 +327,29 @@ namespace DataSharing.Host.Controllers
|
|
|
{
|
|
|
return $"test - {DateTime.Now.ToString()}";
|
|
|
}
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 缓存写入测试
|
|
|
+ /// </summary>
|
|
|
+ /// <returns></returns>
|
|
|
+ [HttpGet("TestSet")]
|
|
|
+ [AllowAnonymous]
|
|
|
+ public async Task<string> TestSet()
|
|
|
+ {
|
|
|
+ await _configurationInformationCache.SetAsync(GetSetTypedCacheKey, DateTime.Now.ToString(), TimeSpan.FromSeconds(5), HttpContext.RequestAborted);
|
|
|
+ return "写入成功";
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 缓存读取测试
|
|
|
+ /// </summary>
|
|
|
+ /// <returns></returns>
|
|
|
+ [HttpGet("TestGet")]
|
|
|
+ [AllowAnonymous]
|
|
|
+ public async Task<string> TestGet()
|
|
|
+ {
|
|
|
+ var data= await _configurationInformationCache.GetAsync(GetSetTypedCacheKey, HttpContext.RequestAborted);
|
|
|
+ return data;
|
|
|
+ }
|
|
|
}
|
|
|
}
|