Browse Source

泸州110对接 泸州边界平台业务对接

libin 2 months ago
parent
commit
e15f8f515d

+ 6 - 6
src/DataSharing.LuZhou/LuZhou110Service.cs

@@ -17,8 +17,8 @@ namespace DataSharing.LuZhou
     {
         private readonly IMapper _mapper;
         private readonly ILogger<LuZhou110Service> _logger;
-        private readonly IRepository<WaitSendTaskLuZhou110> _waitSendTaskLuZhou110Repository;
-        private readonly IRepository<SendTaskLuZhou110> _sendTaskLuZhou110Repository;
+        private readonly IRepository<WaitSendTaskLuzhou110> _waitSendTaskLuZhou110Repository;
+        private readonly IRepository<SendTaskLuzhou110> _sendTaskLuZhou110Repository;
 
         /// <summary>
         /// 
@@ -28,8 +28,8 @@ namespace DataSharing.LuZhou
         /// <param name="waitSendTaskLuZhou110Repository"></param>
         /// <param name="sendTaskLuZhou110Repository"></param>
         public LuZhou110Service(IMapper mapper, ILogger<LuZhou110Service> logger,
-            IRepository<WaitSendTaskLuZhou110> waitSendTaskLuZhou110Repository,
-            IRepository<SendTaskLuZhou110> sendTaskLuZhou110Repository
+            IRepository<WaitSendTaskLuzhou110> waitSendTaskLuZhou110Repository,
+            IRepository<SendTaskLuzhou110> sendTaskLuZhou110Repository
             )
         {
             _mapper = mapper;
@@ -266,7 +266,7 @@ namespace DataSharing.LuZhou
         /// <returns></returns>
         public async Task<string> InitSendData(string OrderId, string No, string TaskType, string Path, string RequestData, string Request, CancellationToken cancellationToken)
         {
-            WaitSendTaskLuZhou110 waitTask = new WaitSendTaskLuZhou110()
+            WaitSendTaskLuzhou110 waitTask = new WaitSendTaskLuzhou110()
             {
                 OrderId = OrderId,
                 No = No,
@@ -279,7 +279,7 @@ namespace DataSharing.LuZhou
             };
             waitTask.Id = await _waitSendTaskLuZhou110Repository.AddAsync(waitTask, cancellationToken);
 
-            var sendTask = _mapper.Map<SendTaskLuZhou110>(waitTask);
+            var sendTask = _mapper.Map<SendTaskLuzhou110>(waitTask);
             sendTask.Id = waitTask.Id;
             //写入推送主表
             return await _sendTaskLuZhou110Repository.AddAsync(sendTask, cancellationToken);

+ 7 - 7
src/DataSharing.Police110/HaiNengDa110/HndService.cs

@@ -20,8 +20,8 @@ namespace DataSharing.Police110.HaiNengDa110
         private readonly IRepository<DsPoliceSendChainDealHnd> _policeSendChainDealHndRepository;
         private readonly IRepository<DsOrder> _dsOrderRepository;
         private readonly ISharingConfigurationManager _sharingConfigurationManager;
-        private readonly IRepository<WaitSendTaskLuZhou110> _waitSendTaskLuZhou110Repository;
-        private readonly IRepository<SendTaskLuZhou110> _sendTaskLuZhou110Repository;
+        private readonly IRepository<WaitSendTaskLuzhou110> _waitSendTaskLuZhou110Repository;
+        private readonly IRepository<SendTaskLuzhou110> _sendTaskLuZhou110Repository;
 
         /// <summary>
         /// 
@@ -38,8 +38,8 @@ namespace DataSharing.Police110.HaiNengDa110
             IRepository<DsPoliceSendChainDealHnd> policeSendChainDealHndRepository,
             IRepository<DsOrder> dsOrderRepository,
             ISharingConfigurationManager sharingConfigurationManager,
-            IRepository<WaitSendTaskLuZhou110> waitSendTaskLuZhou110Repository,
-            IRepository<SendTaskLuZhou110> sendTaskLuZhou110Repository)
+            IRepository<WaitSendTaskLuzhou110> waitSendTaskLuZhou110Repository,
+            IRepository<SendTaskLuzhou110> sendTaskLuZhou110Repository)
         {
             _mapper = mapper;
             _logger = logger;
@@ -194,7 +194,7 @@ namespace DataSharing.Police110.HaiNengDa110
             if (!checkData)
             {
                 var actualOpinion = orderDto.ActualOpinion.Length > 100 ? orderDto.ActualOpinion.Substring(0, 80) : orderDto.ActualOpinion;
-                
+
                 var dataPolice = new DsPoliceSendChainDealHnd()
                 {
                     OrderId = orderDto.Id,
@@ -432,7 +432,7 @@ namespace DataSharing.Police110.HaiNengDa110
         /// <returns></returns>
         private async Task<string> InitSendData(string OrderId, string No, string TaskType, string Path, string RequestData, string Request, CancellationToken cancellationToken)
         {
-            WaitSendTaskLuZhou110 waitTask = new WaitSendTaskLuZhou110()
+            WaitSendTaskLuzhou110 waitTask = new WaitSendTaskLuzhou110()
             {
                 OrderId = OrderId,
                 No = No,
@@ -445,7 +445,7 @@ namespace DataSharing.Police110.HaiNengDa110
             };
             waitTask.Id = await _waitSendTaskLuZhou110Repository.AddAsync(waitTask, cancellationToken);
 
-            var sendTask = _mapper.Map<SendTaskLuZhou110>(waitTask);
+            var sendTask = _mapper.Map<SendTaskLuzhou110>(waitTask);
             sendTask.Id = waitTask.Id;
             //写入推送主表
             return await _sendTaskLuZhou110Repository.AddAsync(sendTask, cancellationToken);

+ 1 - 1
src/DataSharing/LuZhou/LuZhou110/SendTaskLuZhou110.cs

@@ -4,7 +4,7 @@ using XF.Domain.Repository;
 
 namespace DataSharing.LuZhou.LuZhou110
 {
-    public class SendTaskLuZhou110 : CreationEntity
+    public class SendTaskLuzhou110 : CreationEntity
     {
         /// <summary>
         /// 工单Id

+ 6 - 6
src/DataSharing/LuZhou/LuZhou110/TaskSendTaskLuZhou110Job.cs

@@ -12,8 +12,8 @@ namespace DataSharing.LuZhou.LuZhou110
     {
         private readonly IMapper _mapper;
         private readonly ILogger<TaskOtherPlatformsJob> _logger;
-        private readonly IRepository<SendTaskLuZhou110> _sendTaskLuZhou110Repository;
-        private readonly IRepository<WaitSendTaskLuZhou110> _waitSendTaskLuZhou110Repository;
+        private readonly IRepository<SendTaskLuzhou110> _sendTaskLuZhou110Repository;
+        private readonly IRepository<WaitSendTaskLuzhou110> _waitSendTaskLuZhou110Repository;
         private readonly LZ110Invoker _lz110Invoker;
         private readonly ISharingConfigurationManager _sharingConfigurationManager;
         private readonly IRepository<DsSendTaskDetailInfo> _sendTaskDetailInfoRepository;
@@ -29,8 +29,8 @@ namespace DataSharing.LuZhou.LuZhou110
         /// <param name="lz110Invoker"></param>
         public TaskSendTaskLuZhou110Job(IMapper mapper,
             ILogger<TaskOtherPlatformsJob> logger,
-            IRepository<SendTaskLuZhou110> sendTaskLuZhou110Repository,
-            IRepository<WaitSendTaskLuZhou110> waitSendTaskLuZhou110Repository,
+            IRepository<SendTaskLuzhou110> sendTaskLuZhou110Repository,
+            IRepository<WaitSendTaskLuzhou110> waitSendTaskLuZhou110Repository,
             LZ110Invoker lz110Invoker,
             ISharingConfigurationManager sharingConfigurationManager,
             IRepository<DsSendTaskDetailInfo> sendTaskDetailInfoRepository,
@@ -58,7 +58,7 @@ namespace DataSharing.LuZhou.LuZhou110
 
             if (tasks.Count != 0)
             {
-                List<WaitSendTaskLuZhou110> list = new List<WaitSendTaskLuZhou110>();
+                List<WaitSendTaskLuzhou110> list = new List<WaitSendTaskLuzhou110>();
                 //处理推送数据
                 foreach (var sendTask in tasks)
                 {
@@ -86,7 +86,7 @@ namespace DataSharing.LuZhou.LuZhou110
         /// <param name="list"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task SendData(List<WaitSendTaskLuZhou110> list, CancellationToken cancellationToken)
+        private async Task SendData(List<WaitSendTaskLuzhou110> list, CancellationToken cancellationToken)
         {
             var url = _sharingConfigurationManager.GetLuZhouConfig().LuZhou110.SendDataAddress;
             foreach (var item in list)

+ 1 - 1
src/DataSharing/LuZhou/LuZhou110/WaitSendTaskLuZhou110.cs

@@ -4,7 +4,7 @@ using XF.Domain.Repository;
 
 namespace DataSharing.LuZhou.LuZhou110
 {
-    public class WaitSendTaskLuZhou110 : CreationEntity
+    public class WaitSendTaskLuzhou110 : CreationEntity
     {
         /// <summary>
         /// 工单Id