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>