|
|
@@ -16,6 +16,7 @@ using MapsterMapper;
|
|
|
using MediatR;
|
|
|
using Newtonsoft.Json;
|
|
|
using Sharing.Province.Dtos.HuiJu.Send;
|
|
|
+using System.Net;
|
|
|
using XF.Domain.Dependency;
|
|
|
using XF.Domain.Repository;
|
|
|
|
|
|
@@ -74,9 +75,10 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
private readonly PusherProvider _pusherProvider;
|
|
|
private readonly IHttpClientFactory _httpClientFactory;
|
|
|
private readonly IRepository<DsGetCaseDistrecordSend> _getCaseDistrecordSendRepository;
|
|
|
+ private readonly XieTongClient _xieTongClient;
|
|
|
|
|
|
/// <summary>
|
|
|
- /// 注入
|
|
|
+ ///
|
|
|
/// </summary>
|
|
|
/// <param name="submitCaseInfoRepository"></param>
|
|
|
/// <param name="mapper"></param>
|
|
|
@@ -128,6 +130,7 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
/// <param name="pusherProvider"></param>
|
|
|
/// <param name="httpClientFactory"></param>
|
|
|
/// <param name="getCaseDistrecordSendRepository"></param>
|
|
|
+ /// <param name="xieTongClient"></param>
|
|
|
public PusherProviderService(IRepository<DsSubmitCaseInfo> submitCaseInfoRepository,
|
|
|
IMapper mapper,
|
|
|
IMediator mediator,
|
|
|
@@ -177,7 +180,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
IRepository<DsOrderWorkFlow> dataOrderWorkFlowRepository,
|
|
|
PusherProvider pusherProvider,
|
|
|
IHttpClientFactory httpClientFactory,
|
|
|
- IRepository<DsGetCaseDistrecordSend> getCaseDistrecordSendRepository)
|
|
|
+ IRepository<DsGetCaseDistrecordSend> getCaseDistrecordSendRepository,
|
|
|
+ XieTongClient xieTongClient)
|
|
|
{
|
|
|
_submitCaseInfoRepository = submitCaseInfoRepository;
|
|
|
_mapper = mapper;
|
|
|
@@ -229,6 +233,7 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
_pusherProvider = pusherProvider;
|
|
|
_httpClientFactory = httpClientFactory;
|
|
|
_getCaseDistrecordSendRepository = getCaseDistrecordSendRepository;
|
|
|
+ _xieTongClient = xieTongClient;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
@@ -238,38 +243,52 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
/// <param name="submitCaseInfo"></param>
|
|
|
/// <param name="cancellationToken"></param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task ProvinceOrderCreatedPusher(DsSubmitCaseInfo submitCaseInfo, CancellationToken cancellationToken)
|
|
|
+ public async Task ProvinceOrderCreatedPusher(List<DsSubmitCaseInfo> submitCaseInfo, CancellationToken cancellationToken)
|
|
|
{
|
|
|
var pusher = _pusherProvider.CreatePusher(_channelConfigurationManager);
|
|
|
|
|
|
- var dataReceive = _mapper.Map<CaseInfo>(submitCaseInfo);
|
|
|
+ var dataReceive = _mapper.Map<List<CaseInfo>>(submitCaseInfo);
|
|
|
var request = new SubmitCaseInfoRequest();
|
|
|
|
|
|
request.ForeachClass(dataReceive);
|
|
|
|
|
|
var data = new SubmitCaseInfoData
|
|
|
{
|
|
|
- CaseInfos = new List<CaseInfo>
|
|
|
- {
|
|
|
- dataReceive
|
|
|
- }
|
|
|
+ CaseInfos = dataReceive
|
|
|
};
|
|
|
|
|
|
request.SetData(data);
|
|
|
|
|
|
var response = await pusher.PushOrderCreatedAsync(request, cancellationToken);
|
|
|
-
|
|
|
//如果推送成功修改数据状态
|
|
|
if (response != null)
|
|
|
{
|
|
|
- if (response.Code == "1")
|
|
|
- submitCaseInfo.SyncState = "1";
|
|
|
- else
|
|
|
- submitCaseInfo.SyncState = "2";
|
|
|
+ if (response != null)
|
|
|
+ {
|
|
|
+ List<ErrorInfo> list = new();
|
|
|
+ if (response.custom != null && response.custom.errorObjs != null && response.custom.errorObjs.Count > 0)
|
|
|
+ {
|
|
|
+ list = response.custom.errorObjs;
|
|
|
+ }
|
|
|
+ foreach (var item in submitCaseInfo)
|
|
|
+ {
|
|
|
+ if (list != null && list.Count > 0)
|
|
|
+ {
|
|
|
+ if (list.Find(p => p.caseid == item.CaseSerial) != null)
|
|
|
+ item.SyncState = "2";
|
|
|
+ else
|
|
|
+ item.SyncState = "1";
|
|
|
+ }
|
|
|
+ else
|
|
|
+ item.SyncState = "1";
|
|
|
|
|
|
- submitCaseInfo.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
- await _submitCaseInfoRepository.UpdateAsync(submitCaseInfo, cancellationToken);
|
|
|
+ await _submitCaseInfoRepository.UpdateAsync(item, cancellationToken);
|
|
|
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -279,7 +298,7 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
/// <param name="dto"></param>
|
|
|
/// <param name="cancellationToken"></param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task SubmitVisitInfoPusher(DsGetVisitInfoReceive data, CancellationToken cancellationToken)
|
|
|
+ public async Task GetVisitInfoReceivePusher(DsGetVisitInfoReceive data, CancellationToken cancellationToken)
|
|
|
{
|
|
|
//信息上报
|
|
|
var pusher = _pusherProvider.CreatePusher(_channelConfigurationManager);
|
|
|
@@ -302,6 +321,10 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
data.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _getVisitInfoReceiveRepository.UpdateAsync(data, cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(data.Id, data.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -327,18 +350,47 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
});
|
|
|
|
|
|
var response = await pusher.PushSubmitCaseRecordAsync(request, cancellationToken);
|
|
|
-
|
|
|
//如果推送成功修改数据状态
|
|
|
if (response != null)
|
|
|
{
|
|
|
- //if (response.Code == "1")
|
|
|
- // notification.DataOrder.SyncState = "1";
|
|
|
- //else
|
|
|
- // notification.DataOrder.SyncState = "2";
|
|
|
+ if (response != null)
|
|
|
+ {
|
|
|
+ List<ErrorInfo> list = new();
|
|
|
+ if (response.custom != null && response.custom.errorObjs != null && response.custom.errorObjs.Count > 0)
|
|
|
+ {
|
|
|
+ list = response.custom.errorObjs;
|
|
|
+ }
|
|
|
+ foreach (var item in dto)
|
|
|
+ {
|
|
|
+ if (list != null && list.Count > 0)
|
|
|
+ {
|
|
|
+ if (list.Find(p => p.caseid == item.CaseSerial) != null)
|
|
|
+ item.SyncState = "2";
|
|
|
+ else
|
|
|
+ item.SyncState = "1";
|
|
|
+ }
|
|
|
+ else
|
|
|
+ item.SyncState = "1";
|
|
|
+
|
|
|
+ await _submitCaseRecordRepository.UpdateAsync(item, cancellationToken);
|
|
|
|
|
|
- //notification.DataOrder.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
- //await _submitCaseRecordRepository.UpdateAsync(notification.DataOrder);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
+ ////如果推送成功修改数据状态
|
|
|
+ //if (response != null)
|
|
|
+ //{
|
|
|
+ // //if (response.Code == "1")
|
|
|
+ // // notification.DataOrder.SyncState = "1";
|
|
|
+ // //else
|
|
|
+ // // notification.DataOrder.SyncState = "2";
|
|
|
+
|
|
|
+ // //notification.DataOrder.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
+ // //await _submitCaseRecordRepository.UpdateAsync(notification.DataOrder);
|
|
|
+ //}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
@@ -411,6 +463,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
caseInfo.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _receiveCaseExtendsRepository.UpdateAsync(caseInfo, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(caseInfo.Id, caseInfo.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -444,6 +499,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _sendCaseInfoRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -453,7 +511,7 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
/// <param name="dto"></param>
|
|
|
/// <param name="cancellationToken"></param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task SubmitCaseProcessPusher(DsGetCaseProcessReceive dto, CancellationToken cancellationToken)
|
|
|
+ public async Task GetCaseProcessReceivePusher(DsGetCaseProcessReceive dto, CancellationToken cancellationToken)
|
|
|
{
|
|
|
var pusher = _pusherProvider.CreatePusher(_channelConfigurationManager);
|
|
|
|
|
|
@@ -475,6 +533,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _getCaseProcessReceiveRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -506,6 +566,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _getCaseBackApplyRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -537,6 +599,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _sendSuperviseProcessInfoRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -568,6 +632,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _sendSuperviseResultInfoRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -600,6 +666,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = JsonConvert.SerializeObject(response);
|
|
|
await _screenCaseInfoSendRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -631,6 +699,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _remindCaseInfoRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -662,6 +732,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _getKnowledgeInfoSendRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -693,6 +765,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _getKnowledgeInfoUpdateRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -726,6 +800,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _getKnowledgeInfoAbandonRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -757,6 +833,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _sendRealTimeStatusRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -788,6 +866,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _delayCaseInfoSendRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -819,6 +899,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _zMHDCaseInfoPublicRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -859,6 +941,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _submitCaseTotalRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -890,6 +974,8 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _supplyCaseInfoSendRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -921,6 +1007,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
|
|
|
dto.ReturnResult = Newtonsoft.Json.JsonConvert.SerializeObject(response);
|
|
|
await _revokeCaseInfoRepository.UpdateAsync(dto, cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(dto.Id, dto.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -973,7 +1062,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
item.SyncState = "1";
|
|
|
|
|
|
await _submitCaseProcessRepository.UpdateAsync(item, cancellationToken);
|
|
|
- await _waitingPushDataRepository.RemoveAsync(p => p.SyncID == item.Id, cancellationToken: cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1039,7 +1130,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
item.SyncState = "1";
|
|
|
|
|
|
await _submitCaseResultRepository.UpdateAsync(item, cancellationToken);
|
|
|
- await _waitingPushDataRepository.RemoveAsync(p => p.SyncID == item.Id, cancellationToken: cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1103,7 +1196,9 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
item.SyncState = "1";
|
|
|
|
|
|
await _submitVisitInfoRepository.UpdateAsync(item, cancellationToken);
|
|
|
- await _waitingPushDataRepository.RemoveAsync(p => p.SyncID == item.Id, cancellationToken: cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(response), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -1122,22 +1217,22 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
var dataReceive = _mapper.Map<GetCaseMaterialInfoModel>(item);
|
|
|
|
|
|
//附件上传
|
|
|
- var result = "";// await SendFile(dataReceive, item.FileName);
|
|
|
-
|
|
|
- //结果处理
|
|
|
- if (result == "1")
|
|
|
+ var result = await SendFileData(dataReceive, item.FileName, item.FileId, cancellationToken);
|
|
|
+ if (result != null && result.ReturnInfo != null)
|
|
|
{
|
|
|
- //移除待发表数据
|
|
|
- await _waitingPushDataRepository.RemoveAsync(p => p.SyncID == item.Id, cancellationToken: cancellationToken);
|
|
|
-
|
|
|
- //更新推送表状态
|
|
|
- item.SyncState = "1";
|
|
|
+ //结果处理
|
|
|
+ if (result.ReturnInfo.Code == "1")
|
|
|
+ //更新推送表状态
|
|
|
+ item.SyncState = "1";
|
|
|
+ else
|
|
|
+ item.SyncState = "2";
|
|
|
}
|
|
|
else
|
|
|
- {
|
|
|
item.SyncState = "2";
|
|
|
- }
|
|
|
await _getCaseMaterialInfoRepository.UpdateAsync(item, cancellationToken);
|
|
|
+
|
|
|
+ //处理同步记录
|
|
|
+ await UpdateWaitingPushData(item.Id, item.SyncState, JsonConvert.SerializeObject(result), cancellationToken: cancellationToken);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -1184,5 +1279,99 @@ namespace Hotline.DataSharing.Province.Services
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 将文件流上传到附件服务器 ----还需要拉取文件流
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="dto"></param>
|
|
|
+ /// <param name="fileName"></param>
|
|
|
+ /// <param name="fileId"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ private async Task<ProvinceResponse> SendFileData(GetCaseMaterialInfoModel dto, string fileName, string fileId, CancellationToken cancellationToken)
|
|
|
+ {
|
|
|
+ //获取配置信息
|
|
|
+ var configProvince = _channelConfigurationManager.GetConfigurationProvince();
|
|
|
+ var businessFile = _channelConfigurationManager.GetConfigurationBusinessFile();
|
|
|
+ byte[] fileContentBytes = null;
|
|
|
+ try
|
|
|
+ {
|
|
|
+ string url = string.Format("{0}{1}?Source={2}&Id={3}", businessFile.BaseUrl, businessFile.DownloadUrlAddress, businessFile.Source, fileId);
|
|
|
+ using (var client = _httpClientFactory.CreateClient())
|
|
|
+ using (var response = await client.GetAsync(url))
|
|
|
+ {
|
|
|
+ if (response.StatusCode == HttpStatusCode.OK)
|
|
|
+ {
|
|
|
+ using var memoryStream = new MemoryStream();
|
|
|
+ await response.Content.CopyToAsync(memoryStream);
|
|
|
+ memoryStream.Seek(0, SeekOrigin.Begin);
|
|
|
+ fileContentBytes = memoryStream.ToArray();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //获取附件上传Token
|
|
|
+ string strToken = await _xieTongClient.GetTokenAsync(cancellationToken);
|
|
|
+
|
|
|
+ //组装请求参数
|
|
|
+ var model = new GetCaseMaterialInfoRequest
|
|
|
+ {
|
|
|
+ paras = dto,
|
|
|
+ token = new ClientInfo(configProvince.ClientId, configProvince.ClientSecret)
|
|
|
+ };
|
|
|
+
|
|
|
+ Dictionary<string, object> dicParam = new()
|
|
|
+ {
|
|
|
+ { "params", Newtonsoft.Json.JsonConvert.SerializeObject(model) } // 第一个接口参数，json格式字符串
|
|
|
+ };
|
|
|
+
|
|
|
+ // 构造字典文件数据
|
|
|
+ // 接口参数名称为files
|
|
|
+ CFormUpload.FileParameter fileParameter = new CFormUpload.FileParameter("files", fileContentBytes, fileName, null);
|
|
|
+ dicParam.Add(fileName, fileParameter);
|
|
|
+
|
|
|
+ string strUrl = configProvince.HuiJu + "get_case_material_info";
|
|
|
+ // 上传附件
|
|
|
+ string strResult = CFormUpload.MultipartFormDataPost(strUrl, null, dicParam, strToken);
|
|
|
+
|
|
|
+ return Newtonsoft.Json.JsonConvert.DeserializeObject<ProvinceResponse>(strResult);
|
|
|
+ }
|
|
|
+ catch (Exception)
|
|
|
+ { }
|
|
|
+
|
|
|
+ return Newtonsoft.Json.JsonConvert.DeserializeObject<ProvinceResponse>("");
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ ///
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="dataId"></param>
|
|
|
+ /// <param name="SyncState"></param>
|
|
|
+ /// <param name="result"></param>
|
|
|
+ /// <param name="cancellationToken"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ private async Task UpdateWaitingPushData(string dataId, string SyncState, string result, CancellationToken cancellationToken)
|
|
|
+ {
|
|
|
+ //处理同步记录
|
|
|
+ var waitingPushData = await _waitingPushDataRepository.GetAsync(p => p.SyncID == dataId);
|
|
|
+ if (waitingPushData != null)
|
|
|
+ {
|
|
|
+ //第一次同步时间
|
|
|
+ if (waitingPushData.FirstSyncProvinceTime is null)
|
|
|
+ waitingPushData.FirstSyncProvinceTime = DateTime.Now;
|
|
|
+ else
|
|
|
+ waitingPushData.SyncCount++;
|
|
|
+
|
|
|
+ //同步成功时间
|
|
|
+ if (SyncState == "1")
|
|
|
+ {
|
|
|
+ waitingPushData.SuccessSyncTime = DateTime.Now;
|
|
|
+ }
|
|
|
+ //最新同步时间
|
|
|
+ waitingPushData.NewSyncProvinceTime = DateTime.Now;
|
|
|
+ waitingPushData.SyncState = SyncState;
|
|
|
+ waitingPushData.ReturnResult = JsonConvert.SerializeObject(result);
|
|
|
+ await _waitingPushDataRepository.UpdateAsync(waitingPushData, cancellationToken: cancellationToken);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
}
|
xf