src/DataSharing.Host/Controllers/TestController.cs

@@ -10,6 +10,7 @@ using MapsterMapper;
 using MediatR;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using StackExchange.Redis;
 using System.Security.Cryptography;
 using System.Text;
 using XC.RSAUtil;
@@ -40,22 +41,11 @@ namespace DataSharing.Host.Controllers
         private readonly ISharingConfigurationManager _sharingConfigurationManager;
 
         private readonly IRepository<DsWaitSendTaskSubmitCaseRecord> _waitSendTaskSubmitCaseRecordRepository;
+        private readonly IRepository<DsOrderSend> _dsOrderSendRepository;
+        private readonly IRepository<DsOrder> _dsOrderRepository;
+
+
 
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="mapper"></param>
-        /// <param name="mediator"></param>
-        /// <param name="capPublisher"></param>
-        /// <param name="channelConfigurationManager"></param>
-        /// <param name="dataOrderRepository"></param>
-        /// <param name="dsReceiveProvinceDataRepository"></param>
-        /// <param name="getCaseMaterialInfoRepository"></param>
-        /// <param name="getCaseBackApplyRepository"></param>
-        /// <param name="sendCaseInfoRepository"></param>
-        /// <param name="xieTongClient"></param>
-        /// <param name="fwClient"></param>
-        /// <param name="sendFwErrorDataRepository"></param>
         public TestController(IMapper mapper,
              IMediator mediator,
              ICapPublisher capPublisher,
@@ -73,7 +63,10 @@ namespace DataSharing.Host.Controllers
              IIdentityAppService identityAppService,
               IRepository<DsTelCall> dsTelCallRepository,
               ISharingConfigurationManager sharingConfigurationManager,
-              IRepository<DsWaitSendTaskSubmitCaseRecord> waitSendTaskSubmitCaseRecordRepository
+              IRepository<DsWaitSendTaskSubmitCaseRecord> waitSendTaskSubmitCaseRecordRepository,
+            IRepository<DsOrderSend> dsOrderSendRepository,
+           IRepository<DsOrder> dsOrderRepository
+
               )
         {
             _mapper = mapper;
@@ -94,9 +87,36 @@ namespace DataSharing.Host.Controllers
             _dsTelCallRepository = dsTelCallRepository;
             _sharingConfigurationManager = sharingConfigurationManager;
             _waitSendTaskSubmitCaseRecordRepository = waitSendTaskSubmitCaseRecordRepository;
+            _dsOrderSendRepository = dsOrderSendRepository;
+            _dsOrderRepository = dsOrderRepository;
         }
         #endregion
 
+        /// <summary>
+        /// 处理历史数据标题
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet("updateordersource")]
+        [AllowAnonymous]
+        public async Task UpdateOrderSource()
+        {
+            var list = await _dsOrderSendRepository.Queryable()
+                   .Where(p => p.Title == null || p.Title == "")
+                   .ToListAsync();
+            if (list != null && list.Count > 0)
+            {
+                foreach (var item in list)
+                {
+                    var data = await _dsOrderRepository.GetAsync(p => p.OrderId == item.OrderId, HttpContext.RequestAborted);
+                    if (data != null)
+                    {
+                        item.Title = data.Title;
+                        _dsOrderSendRepository.Updateable(item).UpdateColumns(p => p.Title).ExecuteCommand();
+                    }
+                }
+            }
+        }
+
         /// <summary>
         /// 测试token
         /// </summary>