src/DataSharing/Province/DefaultPusher.cs

@@ -1,332 +0,0 @@
-namespace DataSharing.Province
-{
-    /// <summary>
-    /// 默认策略（保持原数据策略）
-    /// </summary>
-    public class DefaultPusher : IProvincePusher
-    {
-        private readonly HuiJuClient _huiJuClient;
-        private readonly XieTongClient _xieTongClient;
-
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="huiJuClient"></param>
-        /// <param name="xieTongClient"></param>
-        public DefaultPusher(HuiJuClient huiJuClient, XieTongClient xieTongClient)
-        {
-            _huiJuClient = huiJuClient;
-            _xieTongClient = xieTongClient;
-        }
-
-        //#region 协同-第一批次
-        ///// <summary>
-        ///// 服务工单交办处理
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseResultReceiveAsync(GetCaseResultReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<GetCaseResultReceiveRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单交办处理过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseProcessReceiveAsync(GetCaseProcessReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<GetCaseProcessReceiveRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单交办评价
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetVisitInfoReceiveAsync(GetVisitInfoReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<GetVisitInfoReceiveRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 退回申请
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseBackApplyAsync(GetCaseBackApplyRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<GetCaseBackApplyRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单申请延时
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushDelayCaseInfoSendAsync(DelayCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<DelayCaseInfoSendRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单督办过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendSuperviseProcessInfoAsync(SendSuperviseProcessInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SendSuperviseProcessInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单督办结果
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendSuperviseResultInfoAsync(SendSuperviseResultInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SendSuperviseResultInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 工单发起甄别接
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushScreenCaseInfoSendAsync(ScreenCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<ScreenCaseInfoSendRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 政民互动提交公开
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushZMHDCaseInfoPublicAsync(ZmhdCaseInfoPublicRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<ZmhdCaseInfoPublicRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        //#endregion
-
-        //#region 汇聚-第二批次
-        ///// <summary>
-        ///// 服务工单受理
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushOrderCreatedAsync(SubmitCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单处理结果
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseResultAsync(SubmitCaseResultRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseResultRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单处理过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseProcessAsync(SubmitCaseProcessRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseProcessRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单回访评价
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitVisitInfoAsync(SubmitVisitInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitVisitInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 电话记录
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseRecordAsync(SubmitCaseRecordRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseRecordRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 统计数据
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseTotalAsync(SubmitCaseTotalRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseTotalRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单拓展信息
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseExtendsAsync(SubmitCaseExtendsRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SubmitCaseExtendsRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-        //#endregion
-
-        //#region 协同-第三批次
-        ///// <summary>
-        ///// 服务工单上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendCaseInfoAsync(SendCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SendCaseInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 上报补充诉求
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSupplyCaseInfoSendAsync(SupplyCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SupplyCaseInfoSendRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单撤单
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushRevokeCaseInfoAsync(SendRevokeCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SendRevokeCaseInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单催单
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendRemindCaseInfoAsync(SendRemindCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<SendRemindCaseInfoRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 服务工单上报12315过程信息查询
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<ProvinceDistrecordResponse> PushGetCaseDistrecordSendAsync(GetCaseDistrecordSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _xieTongClient.RequestAsync<GetCaseDistrecordSendRequest, ProvinceDistrecordResponse>(request, cancellationToken);
-        //    return response;
-        //}
-        //#endregion
-
-        //#region 协同-第四批次
-        ///// <summary>
-        ///// 知识库上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoSendAsync(GetKnowledgeInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<GetKnowledgeInfoSendRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 知识库变更
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoUpdateAsync(GetKnowledgeInfoUpdateRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<GetKnowledgeInfoUpdateRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 知识库下架
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoAbandonAsync(GetKnowledgeInfoAbandonRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<GetKnowledgeInfoAbandonRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        ///// <summary>
-        ///// 实时服务上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendRealTimeStatusAsync(SendRealTimeStatusRequest request, CancellationToken cancellationToken)
-        //{
-        //    var response = await _huiJuClient.RequestAsync<SendRealTimeStatusRequest, ProvinceResponse>(request, cancellationToken);
-        //    return response?.ReturnInfo;
-        //}
-
-        //#endregion
-    }
-}

src/DataSharing/Province/PusherProvider.cs

@@ -1,27 +0,0 @@
-using XF.Domain.Dependency;
-
-namespace DataSharing.Province
-{
-    public class PusherProvider : IScopeDependency, ISelfDependency
-    {
-        private readonly HuiJuClient _huiJuClient;
-        private readonly XieTongClient _xieTongClient;
-
-        public PusherProvider(HuiJuClient huiJuClient, XieTongClient xieTongClient)
-        {
-            _huiJuClient = huiJuClient;
-            _xieTongClient = xieTongClient;
-        }
-
-        public IProvincePusher CreatePusher(IChannelConfigurationManager channelConfigurationManager)
-        {
-            var configProvince = channelConfigurationManager.GetConfigurationProvince();
-            return configProvince.Scheme switch
-            {
-                ConfigurationConsts.SchemeDefault => new DefaultPusher(_huiJuClient, _xieTongClient),
-                ConfigurationConsts.SchemeSmart => new SmartPusher(),
-                _ => new DefaultPusher(_huiJuClient, _xieTongClient)
-            };
-        }
-    }
-}

src/DataSharing/Province/PusherProviderService.cs

@@ -16,7 +16,6 @@ namespace DataSharing.Province
         private readonly IMapper _mapper;
         private readonly IMediator _mediator;
         private readonly IChannelConfigurationManager _channelConfigurationManager;
-        private readonly PusherProvider _pusherProvider;
         private readonly IHttpClientFactory _httpClientFactory;
         private readonly XieTongClient _xieTongClient;
         private readonly IRepository<DsOrder> _dsOrderRepository;
@@ -28,14 +27,12 @@ namespace DataSharing.Province
         /// <param name="mapper"></param>
         /// <param name="mediator"></param>
         /// <param name="channelConfigurationManager"></param>
-        /// <param name="pusherProvider"></param>
         /// <param name="httpClientFactory"></param>
         /// <param name="xieTongClient"></param>
         /// <param name="dsOrderRepository"></param>
         /// <param name="dsSendTaskRepository"></param>
         public PusherProviderService(IMapper mapper, IMediator mediator,
             IChannelConfigurationManager channelConfigurationManager,
-            PusherProvider pusherProvider,
             IHttpClientFactory httpClientFactory,
             XieTongClient xieTongClient,
             IRepository<DsOrder> dsOrderRepository,
@@ -44,7 +41,6 @@ namespace DataSharing.Province
             _mapper = mapper;
             _mediator = mediator;
             _channelConfigurationManager = channelConfigurationManager;
-            _pusherProvider = pusherProvider;
             _httpClientFactory = httpClientFactory;
             _xieTongClient = xieTongClient;
             _dsOrderRepository = dsOrderRepository;

src/DataSharing/Province/SmartPusher.cs

@@ -1,292 +0,0 @@
-namespace DataSharing.Province
-{
-    /// <summary>
-    /// todo 留待扩展
-    /// </summary>
-    public class SmartPusher : IProvincePusher
-    {
-        //#region 协同-第一批次
-        ///// <summary>
-        ///// 服务工单交办处理
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseResultReceiveAsync(GetCaseResultReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单交办处理过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseProcessReceiveAsync(GetCaseProcessReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单交办评价
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetVisitInfoReceiveAsync(GetVisitInfoReceiveRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 退回申请
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetCaseBackApplyAsync(GetCaseBackApplyRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单申请延时
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushDelayCaseInfoSendAsync(DelayCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单督办过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendSuperviseProcessInfoAsync(SendSuperviseProcessInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单督办结果
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendSuperviseResultInfoAsync(SendSuperviseResultInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 工单发起甄别接
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushScreenCaseInfoSendAsync(ScreenCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 政民互动提交公开
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushZMHDCaseInfoPublicAsync(ZmhdCaseInfoPublicRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-        //#endregion
-
-        //#region 汇聚-第二批次
-        ///// <summary>
-        ///// 服务工单受理
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        ///// <exception cref="NotImplementedException"></exception>
-        //public async Task<BaseProvinceResponse> PushOrderCreatedAsync(SubmitCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单处理结果
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseResultAsync(SubmitCaseResultRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单处理过程
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseProcessAsync(SubmitCaseProcessRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单回访评价
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitVisitInfoAsync(SubmitVisitInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 电话记录
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseRecordAsync(SubmitCaseRecordRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 统计数据
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseTotalAsync(SubmitCaseTotalRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单拓展信息
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSubmitCaseExtendsAsync(SubmitCaseExtendsRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-        //#endregion
-
-        //#region 协同-第三批次
-        ///// <summary>
-        ///// 服务工单上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendCaseInfoAsync(SendCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 上报补充诉求
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSupplyCaseInfoSendAsync(SupplyCaseInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单撤单
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushRevokeCaseInfoAsync(SendRevokeCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单催单
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendRemindCaseInfoAsync(SendRemindCaseInfoRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 服务工单上报12315过程信息查询
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<ProvinceDistrecordResponse> PushGetCaseDistrecordSendAsync(GetCaseDistrecordSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-        //#endregion
-
-        //#region 协同-第四批次
-        ///// <summary>
-        ///// 知识库上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoSendAsync(GetKnowledgeInfoSendRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 知识库变更
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoUpdateAsync(GetKnowledgeInfoUpdateRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 知识库下架
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushGetKnowledgeInfoAbandonAsync(GetKnowledgeInfoAbandonRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-
-        ///// <summary>
-        ///// 实时服务上报
-        ///// </summary>
-        ///// <param name="request"></param>
-        ///// <param name="cancellationToken"></param>
-        ///// <returns></returns>
-        //public async Task<BaseProvinceResponse> PushSendRealTimeStatusAsync(SendRealTimeStatusRequest request, CancellationToken cancellationToken)
-        //{
-        //    throw new NotImplementedException();
-        //}
-        //#endregion
-    }
-}

src/DataSharing/Province/XieTongClient.cs

@@ -1,5 +1,6 @@
 using DataSharing.Share.Dtos.Province;
 using Microsoft.Extensions.DependencyInjection;
+using XF.Domain.Cache;
 using XF.Domain.Dependency;
 
 namespace DataSharing.Province
@@ -24,6 +25,27 @@ namespace DataSharing.Province
             return base.RequestAsync<TRequest, TResponse>(request, configProvince.XieTong, configProvince, cancellationToken);
         }
 
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <typeparam name="TResponse"></typeparam>
+        /// <param name="url"></param>
+        /// <param name="httpMethod"></param>
+        /// <param name="stringContent"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public Task<TResponse?> RequestAsync<TResponse>(string url, string httpMethod, string? stringContent = null, CancellationToken cancellationToken = default)
+        {
+            using var scope = _scopeFactory.CreateScope();
+            var provider = scope.ServiceProvider;
+            var channelconfigManager = provider.GetRequiredService<IChannelConfigurationManager>();
+            var httpInvoker = provider.GetRequiredService<IHttpInvoker>();
+            var cacheToken = provider.GetRequiredService<ITypedCache<TokenInfo>>();
+
+            var configProvince = channelconfigManager.GetConfigurationProvince();
+            return base.RequestAsync<TResponse>(configProvince.XieTong, configProvince, url, httpMethod, httpInvoker, cacheToken, stringContent, cancellationToken);
+        }
+
         /// <summary>
         /// 附件获取Token
         /// </summary>