路腾仓的周转数据，早上7点要全量刷新一次

AutoGeneratePurchaseAdvise/GeneratePurchaseAdviseBackgroundService.cs

@@ -39,6 +39,13 @@ namespace AutoGeneratePurchaseAdvise
                 //    Console.WriteLine($"结束推送 jit甲油采购建议 任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                 //}
 
+                if (now.Hour == 07 && now.Minute == 01)
+                {
+                    Console.WriteLine($"开始 刷新路腾仓周转数，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                    AutoTurnOver.DB.dc_auto_turnover.ResetSpecialData();
+                    Console.WriteLine($"结束 刷新路腾仓周转数，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+
+                }
                 if (now.Hour == 08 && now.Minute == 30)
                 {
                     Console.WriteLine($"开始推送 jit甲油采购建议 任务，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");

AutoGeneratePurchaseAdvise/Program.cs

@@ -24,6 +24,8 @@ namespace AutoGeneratePurchaseAdvise
                 //PurchaseAdviseServices.Generate($"早上的全量周转 {DateTime.Now.ToString("HH: mm")}", DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00")), is_clear_data: true);
                 //PurchaseAdviseServices.Generate($"早上的全量周转 {DateTime.Now.ToString("HH: mm")}", DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 00:00:00")), is_clear_data: false);
                 //PurchaseAdviseServices.Generate($"下午的补充周转 {DateTime.Now.ToString("HH: mm")}", DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd 12:00:00")));
+
+             
             }
             catch (Exception ex)
             {

AutoTurnOver.DB/dc_auto_turnover.cs

@@ -2751,6 +2751,39 @@ order by t1.gmt_modified asc
                 sales_day_config_details = data.sales_day_config_details
             });
         }
+
+        /// <summary>
+        /// 刷新特殊周转数据
+        /// (英国路腾仓有余需要统计到早上7点的数据，所以7点之后，需要重算周转)
+        /// </summary>
+        public static void ResetSpecialData()
+        {
+            
+            int page = 1;
+            int rows = 1000;
+            while (true)
+            {
+                var bailun_skus = _connection.Query<bailun_sku_warehouse_dto>($@" select t1.bailun_sku,t1.warehouse_code from dc_auto_turnover as t1 
+where t1.gmt_modified>=@btime and t1.warehouse_code='GB4PXBL' limit {(page-1)*rows},{rows} ",new { btime  = DateTime.Now.AddDays(-3)}).ToList();
+                page++;
+                if(bailun_skus!=null && bailun_skus.Count>=1)
+                {
+                    foreach (var item in bailun_skus)
+                    {
+                        _connection.Insert( new dc_base_queue
+                        {
+                            submit_date = DateTime.Now,
+                            error_message = "",
+                            consume_date = null,
+                            error_stack_trace = "",
+                            message = new { bailun_sku = item.bailun_sku, warehouse_code = item.warehouse_code }.ToJson(),
+                            type = "刷新周转表",
+                            remarks = "7点之后，补算 路腾仓"
+                        });
+                    }
+                }
+            }
+        }
     }
 
 }
\ No newline at end of file

AutoTurnOver.Models/bailun_sku_warehouse_dto.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace AutoTurnOver.Models
+{
+    public class bailun_sku_warehouse_dto
+    {
+        public string bailun_sku { get; set; }
+        public string warehouse_code { get; set; }
+    }
+}