修改处理工单来源推送

src/DataSharing.Host/Controllers/HotlineWebController.cs

@@ -20,6 +20,7 @@ using DataSharing.Share.Enums;
 using DataSharing.Share.Requests;
 using DotNetCore.CAP;
 using Hotline.Share.Dtos;
+using Hotline.Share.Dtos.Order;
 using MapsterMapper;
 using MediatR;
 using Microsoft.AspNetCore.Authorization;
@@ -1583,5 +1584,45 @@ jxrWXHbT1FB6DqkdOnBbQqS1Azqz5HxLlSyEK3F60e3SgB5iZsDZ
                  .ToPageListAsync(dto.PageIndex, dto.PageSize, total, HttpContext.RequestAborted);
             return new PagedDto<DsGetCaseMaterialInfo>(total, items);
         }
+
+        /// <summary>
+        /// 修改工单来源推送省平台
+        /// </summary>
+        /// <returns></returns>
+        [HttpGet("updateordersource")]
+        [AllowAnonymous]
+        public async Task UpdateOrderSourceAsync()
+        {
+            //查询数据
+            var items = await _dsOrderSendRepository.Queryable()
+                .LeftJoin<DsTelCall>((p, o) => p.CallId == o.CallId)
+                .Where((p, o) => p.FirstSendProvinceTime >= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 00:00:00"))
+                && p.FirstSendProvinceTime <= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 23:59:59")) && p.CaseSourceCode == "RGDH")
+                .Where((p, o) => p.FirstSendProvinceTime.HasValue && p.HandleState == "办理完成")
+                .Where((p, o) => o.CallId == null || o.CallId == "")
+                .OrderByDescending((p, o) => p.CreationTime)
+                .ToListAsync();
+
+            //处理数据
+            if (items != null && items.Any())
+            {
+                // _logger.LogWarning("读取到条数：" + "--------------" + items.Count);
+                List<string> Ids = [];
+                foreach (var item in items)
+                {
+                    Ids.Add(item.OrderId);
+                }
+                //推送数据
+                if (Ids != null && Ids.Count > 0)
+                {
+                    UpdateOrderSourceChannelDto data = new()
+                    {
+                        Ids = Ids,
+                        IsPush = true
+                    };
+                    await _fwClient.RequestNoTokenAsync<HotlineClientResponse>("api/v1/Order/update-order-sourcechannel", "Post", System.Text.Json.JsonSerializer.Serialize(data));
+                }
+            }
+        }
     }
 }

src/DataSharing/ChannelConfiguration.cs

@@ -7,11 +7,6 @@
         /// </summary>
         public string ProcessingServices { get; set; }
 
-        /// <summary>
-        /// 是否开启推送
-        /// </summary>
-        public bool IsOpenPush { get; set; }
-
         /// <summary>
         /// 业务系统附件上传配置
         /// </summary>

src/DataSharing/ChannelConfigurationManager.cs

@@ -28,15 +28,6 @@ namespace DataSharing
             return _channelOption.Value.ProcessingServices;
         }
 
-        /// <summary>
-        /// 是否开启推送
-        /// </summary>
-        /// <returns></returns>
-        public bool GetConfigurationIsOpenPush()
-        {
-            return _channelOption.Value.IsOpenPush;
-        }
-
         /// <summary>
         /// 业务系统附件上传配置
         /// </summary>

src/DataSharing/IChannelConfigurationManager.cs

@@ -8,12 +8,6 @@
         /// <returns></returns>
         string GetConfigurationProcessingServices();
 
-        /// <summary>
-        /// 是否开启推送
-        /// </summary>
-        /// <returns></returns>
-        bool GetConfigurationIsOpenPush();
-
         /// <summary>
         /// 业务系统附件上传配置
         /// </summary>

src/DataSharing/Province/SendTask/TaskUpdateOrderSourceJob.cs

@@ -34,39 +34,34 @@ namespace DataSharing.Province.SendTask
 
         public async Task Execute(IJobExecutionContext context)
         {
-            var isOpenPush = _channelConfigurationManager.GetConfigurationIsOpenPush();
-            _logger.LogWarning("是否开启：" + "--------------" + isOpenPush);
-            if (isOpenPush == true)
-            {
-                //查询数据
-                var items = await _dsOrderSendRepository.Queryable()
-                    .LeftJoin<DsTelCall>((p, o) => p.CallId == o.CallId)
-                    .Where((p, o) => p.FirstSendProvinceTime >= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 00:00:00"))
-                    && p.FirstSendProvinceTime <= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 23:59:59")) && p.CaseSourceCode == "RGDH")
-                    .Where((p, o) => p.FirstSendProvinceTime.HasValue && p.HandleState == "办理完成")
-                    .Where((p, o) => o.CallId == null || o.CallId == "")
-                    .OrderByDescending((p, o) => p.CreationTime)
-                    .ToListAsync();
+            //查询数据
+            var items = await _dsOrderSendRepository.Queryable()
+                .LeftJoin<DsTelCall>((p, o) => p.CallId == o.CallId)
+                .Where((p, o) => p.FirstSendProvinceTime >= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 00:00:00"))
+                && p.FirstSendProvinceTime <= Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 23:59:59")) && p.CaseSourceCode == "RGDH")
+                .Where((p, o) => p.FirstSendProvinceTime.HasValue && p.HandleState == "办理完成")
+                .Where((p, o) => o.CallId == null || o.CallId == "")
+                .OrderByDescending((p, o) => p.CreationTime)
+                .ToListAsync();
 
-                //处理数据
-                if (items != null && items.Any())
+            //处理数据
+            if (items != null && items.Any())
+            {
+                _logger.LogWarning("读取到条数：" + "--------------" + items.Count);
+                List<string> Ids = [];
+                foreach (var item in items)
                 {
-                    _logger.LogWarning("读取到条数：" + "--------------" + items.Count);
-                    List<string> Ids = [];
-                    foreach (var item in items)
-                    {
-                        Ids.Add(item.OrderId);
-                    }
-                    //推送数据
-                    if (Ids != null && Ids.Count > 0)
+                    Ids.Add(item.OrderId);
+                }
+                //推送数据
+                if (Ids != null && Ids.Count > 0)
+                {
+                    UpdateOrderSourceChannelDto data = new()
                     {
-                        UpdateOrderSourceChannelDto data = new()
-                        {
-                            Ids = Ids,
-                            IsPush = true
-                        };
-                        await _fwClient.RequestNoTokenAsync<HotlineClientResponse>("api/v1/Order/update-order-sourcechannel", "Post", System.Text.Json.JsonSerializer.Serialize(data));
-                    }
+                        Ids = Ids,
+                        IsPush = true
+                    };
+                    await _fwClient.RequestNoTokenAsync<HotlineClientResponse>("api/v1/Order/update-order-sourcechannel", "Post", System.Text.Json.JsonSerializer.Serialize(data));
                 }
             }
         }