TANG JIANG 1 年之前
父節點
當前提交
0128ce1df0

+ 2 - 2
src/Sharing.Api/Controllers/HotlineMessageReceiveController.cs

@@ -51,7 +51,7 @@ namespace Sharing.Api.Controllers
         private readonly IProvinceService _provinceService;
         private readonly IRepository<KnowledgeRawData> _knowledgeRawDataRepository;
         private readonly IChannelConfigurationManager _channelConfigurationManager;
-        private readonly IRepository<DataOrderPush> _dataOrderPushRepository;
+        private readonly IRepository<DataOrder> _dataOrderPushRepository;
 
         /// <summary>
         /// 
@@ -107,7 +107,7 @@ namespace Sharing.Api.Controllers
           IProvinceService provinceService,
           IRepository<KnowledgeRawData> knowledgeRawDataRepository,
           IChannelConfigurationManager channelConfigurationManager,
-          IRepository<DataOrderPush> dataOrderPushRepository)
+          IRepository<DataOrder> dataOrderPushRepository)
         {
             _mediator = mediator;
             _logger = logger;

+ 2 - 3
src/Sharing.Application/HotlineMsgReceiver.cs

@@ -10,13 +10,12 @@ namespace Sharing.Application
     /// </summary>
     public class HotlineMsgReceiver : ICapSubscribe
     {
-        private readonly IDataOrderRepository _dataOrderRepository;
+        //private readonly IDataOrderRepository _dataOrderRepository;
         private readonly IMediator _mediator;
         private readonly ILogger<HotlineMsgReceiver> _logger;
 
-        public HotlineMsgReceiver(IDataOrderRepository dataOrderRepository, IMediator mediator, ILogger<HotlineMsgReceiver> logger)
+        public HotlineMsgReceiver( IMediator mediator, ILogger<HotlineMsgReceiver> logger)
         {
-            _dataOrderRepository = dataOrderRepository;
             _mediator = mediator;
             _logger = logger;
         }

+ 2 - 2
src/Sharing.Province/Handlers/HuiJu/OrderCreatedHandler.cs

@@ -17,7 +17,7 @@ namespace Sharing.Province.Handlers.HuiJu
         private readonly PusherProvider _pusherProvider;
         private readonly IMapper _mapper;
         private readonly IRepository<SubmitCaseInfo> _submitCaseInfoRepository;
-        private readonly IRepository<DataOrderPush> _dataOrderPushRepository;
+        private readonly IRepository<DataOrder> _dataOrderPushRepository;
 
         /// <summary>
         /// 
@@ -28,7 +28,7 @@ namespace Sharing.Province.Handlers.HuiJu
         /// <param name="submitCaseInfoRepository"></param>
         /// <param name="dataOrderPushRepository"></param>
         public OrderCreatedHandler(IChannelConfigurationManager channelConfigurationManager, PusherProvider pusherProvider, IMapper mapper
-            , IRepository<SubmitCaseInfo> submitCaseInfoRepository, IRepository<DataOrderPush> dataOrderPushRepository)
+            , IRepository<SubmitCaseInfo> submitCaseInfoRepository, IRepository<DataOrder> dataOrderPushRepository)
         {
             _channelConfigurationManager = channelConfigurationManager;
             _pusherProvider = pusherProvider;

+ 2 - 2
src/Sharing.Province/Handlers/HuiJu/SubmitCaseResultHandler.cs

@@ -20,7 +20,7 @@ namespace Sharing.Province.Handlers.HuiJu
         private readonly IMapper _mapper;
         private readonly IRepository<SubmitCaseResult> _submitCaseResultRepository;
         private readonly IWaitingPushDataRepository _waitingPushDataRepository;
-        private readonly IRepository<DataOrderPush> _dataOrderPushRepository;
+        private readonly IRepository<DataOrder> _dataOrderPushRepository;
 
         /// <summary>
         /// 
@@ -33,7 +33,7 @@ namespace Sharing.Province.Handlers.HuiJu
         /// <param name="dataOrderPushRepository"></param>
         public SubmitCaseResultHandler(IChannelConfigurationManager channelConfigurationManager, PusherProvider pusherProvider
             , IMapper mapper, IRepository<SubmitCaseResult> submitCaseResultRepository, IWaitingPushDataRepository waitingPushDataRepository
-            , IRepository<DataOrderPush> dataOrderPushRepository)
+            , IRepository<DataOrder> dataOrderPushRepository)
         {
             _channelConfigurationManager = channelConfigurationManager;
             _pusherProvider = pusherProvider;

+ 2 - 2
src/Sharing.Province/Handlers/HuiJu/SubmitVisitInfoHandler.cs

@@ -20,7 +20,7 @@ namespace Sharing.Province.Handlers.HuiJu
         private readonly IMapper _mapper;
         private readonly IRepository<SubmitVisitInfo> _submitVisitInfoRepository;
         private readonly IWaitingPushDataRepository _waitingPushDataRepository;
-        private readonly IRepository<DataOrderPush> _dataOrderPushRepository;
+        private readonly IRepository<DataOrder> _dataOrderPushRepository;
 
         /// <summary>
         /// 
@@ -32,7 +32,7 @@ namespace Sharing.Province.Handlers.HuiJu
         /// <param name="waitingPushDataRepository"></param>
         public SubmitVisitInfoHandler(IChannelConfigurationManager channelConfigurationManager, PusherProvider pusherProvider, IMapper mapper
             , IRepository<SubmitVisitInfo> submitVisitInfoRepository, IWaitingPushDataRepository waitingPushDataRepository
-            , IRepository<DataOrderPush> dataOrderPushRepository)
+            , IRepository<DataOrder> dataOrderPushRepository)
         {
             _channelConfigurationManager = channelConfigurationManager;
             _pusherProvider = pusherProvider;

+ 18 - 0
src/Sharing.Repository/DataOrderRepository.cs

@@ -0,0 +1,18 @@
+using Sharing.Orders;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+using XF.Domain.Dependency;
+
+namespace Sharing.Repository
+{
+    public class DataOrderRepository : BaseRepository<DataOrder>, IDataOrderRepository, IScopeDependency
+    {
+        public DataOrderRepository(ISugarUnitOfWork<SharingDbContext> uow) : base(uow)
+        {
+        }
+    }
+}

+ 1 - 2
src/Sharing/Orders/DataOrder.cs

@@ -7,8 +7,7 @@ namespace Sharing.Orders;
 /// <summary>
 /// / 工单数据,推送省平台记录
 /// </summary>
-[Description("/ 工单数据,推送省平台记录")]
-public class DataOrderPush : CreationModificationEntity
+public class DataOrder : CreationModificationEntity
 {
     /*
      工单id	工单编号	上传省工单编号	省编号	受理时间	第一次工单同步省平台时间	工单上传间隔(s)	工单是否及时上传	同步诉求渠道	最新应办结时间	最新工单同步省平台时间	第一次结果同步时间	

+ 13 - 0
src/Sharing/Orders/IDataOrderRepository.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using XF.Domain.Repository;
+
+namespace Sharing.Orders
+{
+    public interface IDataOrderRepository : IRepository<DataOrder>
+    {
+    }
+}